第三方导入-合并元素表时覆盖任务

src/main/java/com/shkpr/service/alambizplugin/dbdao/mapper/GisSurveyLayerApplyMapper.java

@@ -63,4 +63,12 @@ public interface GisSurveyLayerApplyMapper {
      * @return 合并数量
      */
     int mergeCopyByJobId(@Param("jobId") String jobId);
+
+    /**
+     * 根据任务Id删除
+     *
+     * @param jobId jobId
+     * @return 删除数量
+     */
+    int deleteByJobId(@Param("jobId") String jobId);
 }

src/main/java/com/shkpr/service/alambizplugin/dbdao/mapper/GisSurveyPropertyValueMapper.java

@@ -16,4 +16,12 @@ public interface GisSurveyPropertyValueMapper {
      * @return 合并数量
      */
     int mergeCopyByJobId(@Param("jobId") String jobId);
+
+    /**
+     * 根据任务Id删除
+     *
+     * @param jobId jobId
+     * @return 删除数量
+     */
+    int deleteByJobId(@Param("jobId") String jobId);
 }

src/main/java/com/shkpr/service/alambizplugin/dbdao/services/GisSurveyLayerApplyServiceImpl.java

@@ -322,6 +322,10 @@ public class GisSurveyLayerApplyServiceImpl implements GisSurveyLayerApplyServic
                 GisSurveyJobInfoMapper jobInfoMapper = sqlSession.getMapper(GisSurveyJobInfoMapper.class);
                 GisSurveyJobStatusTrackMapper jobStatusTrackMapper = sqlSession.getMapper(GisSurveyJobStatusTrackMapper.class);
 
+                //删除原本job
+                layerApplyMapper.deleteByJobId(jobId);
+                propertyValueMapper.deleteByJobId(jobId);
+
                 //需要合并的数量
                 long mergeCount = layerApplyThirdCopyMapper.countByJobId(jobId);
 

src/main/resources/mapper/GisSurveyLayerApplyMapper.xml

@@ -168,4 +168,10 @@
         where job_id = #{jobId,jdbcType=VARCHAR}
         order by job_id, code
     </insert>
+
+    <delete id="deleteByJobId">
+        delete
+        from k3_gis_survey_layer_apply
+        where job_id = #{jobId,jdbcType=VARCHAR}
+    </delete>
 </mapper>

src/main/resources/mapper/GisSurveyPropertyValueMapper.xml

@@ -21,4 +21,9 @@
         where job_id = #{jobId,jdbcType=VARCHAR}
         order by job_id, code, property;
     </insert>
+    <delete id="deleteByJobId">
+        delete
+        from k3_gis_survey_property_value
+        where job_id = #{jobId,jdbcType=VARCHAR}
+    </delete>
 </mapper>