项目费用导入，判断导入的年份是否已经存在数据，存在就删掉

module_kzks/src/main/java/org/jeecg/modules/projectChbSwf/mapper/ProjectChbSwfMapper.java

@@ -26,4 +26,20 @@ public interface ProjectChbSwfMapper extends BaseMapper<ProjectChbSwf> {
     *   date: 2023/11/21
     */
     public int deleteSwf();
+
+    /**
+     *   author: dzc
+     *   version: 1.0
+     *   des: 判断数据库中是否存在该年度的数据
+     *   date: 2024/1/4
+     */
+    int getIfHaveThisNd(@Param("nd") String nd);
+
+    /**
+    *   author: dzc
+    *   version: 1.0
+    *   des: 根据年度删除数据
+    *   date: 2024/1/4
+    */
+    int deleteSwfByNd(@Param("nd") String nd);
 }

module_kzks/src/main/java/org/jeecg/modules/projectChbSwf/mapper/xml/ProjectChbSwfMapper.xml

@@ -16,4 +16,11 @@
             )
     </delete>
 
+    <select id="getIfHaveThisNd" resultType="int">
+        SELECT count(*) FROM kzks_project_chb_swf WHERE nd = #{nd}
+    </select>
+
+    <delete id="deleteSwfByNd">
+        DELETE FROM kzks_project_chb_swf WHERE nd = #{nd}
+    </delete>
 </mapper>

module_kzks/src/main/java/org/jeecg/modules/projectChbSwf/service/IProjectChbSwfService.java

@@ -43,4 +43,19 @@ public interface IProjectChbSwfService extends IService<ProjectChbSwf> {
     */
     public int deleteSwf();
 
+    /**
+    *   author: dzc
+    *   version: 1.0
+    *   des: 判断数据库中是否存在该年度的数据
+    *   date: 2024/1/4
+    */
+    int getIfHaveThisNd(String nd);
+
+    /**
+    *   author: dzc
+    *   version: 1.0
+    *   des: 根据年度删除数据
+    *   date: 2024/1/4
+    */
+    int deleteSwfByNd(String nd);
 }

module_kzks/src/main/java/org/jeecg/modules/projectChbSwf/service/impl/ProjectChbSwfServiceImpl.java

@@ -159,4 +159,14 @@ public class ProjectChbSwfServiceImpl extends ServiceImpl<ProjectChbSwfMapper, P
     public int deleteSwf() {
         return swfMapper.deleteSwf();
     }
+
+    @Override
+    public int getIfHaveThisNd(String nd) {
+        return swfMapper.getIfHaveThisNd(nd);
+    }
+
+    @Override
+    public int deleteSwfByNd(String nd) {
+        return swfMapper.deleteSwfByNd(nd);
+    }
 }

module_kzks/src/main/java/org/jeecg/modules/projectChbWxf/mapper/ProjectChbWxfMapper.java

@@ -27,4 +27,21 @@ public interface ProjectChbWxfMapper extends BaseMapper<ProjectChbWxf> {
     *   date: 2023/11/21
     */
     public int deleteWxf();
+
+
+    /**
+     *   author: dzc
+     *   version: 1.0
+     *   des: 判断数据库中是否存在该年度的数据
+     *   date: 2024/1/4
+     */
+    int getIfHaveThisNd(@Param("nd") String nd);
+
+    /**
+     *   author: dzc
+     *   version: 1.0
+     *   des: 根据年度删除数据
+     *   date: 2024/1/4
+     */
+    int deleteWxfByNd(@Param("nd") String nd);
 }

module_kzks/src/main/java/org/jeecg/modules/projectChbWxf/mapper/xml/ProjectChbWxfMapper.xml

@@ -17,4 +17,11 @@
     </delete>
 
 
+    <select id="getIfHaveThisNd" resultType="int">
+        SELECT count(*) FROM kzks_project_chb_wxf WHERE nd = #{nd}
+    </select>
+
+    <delete id="deleteWxfByNd">
+        DELETE FROM kzks_project_chb_wxf WHERE nd = #{nd}
+    </delete>
 </mapper>

module_kzks/src/main/java/org/jeecg/modules/projectChbWxf/service/IProjectChbWxfService.java

@@ -36,4 +36,20 @@ public interface IProjectChbWxfService extends IService<ProjectChbWxf> {
      *   date: 2023/11/21
      */
     public int deleteWxf();
+
+    /**
+     *   author: dzc
+     *   version: 1.0
+     *   des: 判断数据库中是否存在该年度的数据
+     *   date: 2024/1/4
+     */
+    int getIfHaveThisNd(String nd);
+
+    /**
+     *   author: dzc
+     *   version: 1.0
+     *   des: 根据年度删除数据
+     *   date: 2024/1/4
+     */
+    int deleteWxfByNd(String nd);
 }

module_kzks/src/main/java/org/jeecg/modules/projectChbWxf/service/impl/ProjectChbWxfServiceImpl.java

@@ -155,4 +155,14 @@ public class ProjectChbWxfServiceImpl extends ServiceImpl<ProjectChbWxfMapper, P
     public int deleteWxf() {
         return wxfMapper.deleteWxf();
     }
+
+    @Override
+    public int getIfHaveThisNd(String nd) {
+        return wxfMapper.getIfHaveThisNd(nd);
+    }
+
+    @Override
+    public int deleteWxfByNd(String nd) {
+        return wxfMapper.deleteWxfByNd(nd);
+    }
 }

module_kzks/src/main/java/org/jeecg/modules/projectChbZyf/mapper/ProjectChbZyfMapper.java

@@ -28,4 +28,20 @@ public interface ProjectChbZyfMapper extends BaseMapper<ProjectChbZyf> {
     */
     public int deleteZyf();
 
+
+    /**
+     *   author: dzc
+     *   version: 1.0
+     *   des: 判断数据库中是否存在该年度的数据
+     *   date: 2024/1/4
+     */
+    int getIfHaveThisNd(@Param("nd") String nd);
+
+    /**
+     *   author: dzc
+     *   version: 1.0
+     *   des: 根据年度删除数据
+     *   date: 2024/1/4
+     */
+    int deleteZyfByNd(@Param("nd") String nd);
 }

module_kzks/src/main/java/org/jeecg/modules/projectChbZyf/mapper/xml/ProjectChbZyfMapper.xml

@@ -16,4 +16,12 @@
             )
     </delete>
 
+
+    <select id="getIfHaveThisNd" resultType="int">
+        SELECT count(*) FROM kzks_project_chb_zyf WHERE nd = #{nd}
+    </select>
+
+    <delete id="deleteZyfByNd">
+        DELETE FROM kzks_project_chb_zyf WHERE nd = #{nd}
+    </delete>
 </mapper>

module_kzks/src/main/java/org/jeecg/modules/projectChbZyf/service/IProjectChbZyfService.java

@@ -37,4 +37,21 @@ public interface IProjectChbZyfService extends IService<ProjectChbZyf> {
      *   date: 2023/11/21
      */
     public int deleteZyf();
+
+
+    /**
+     *   author: dzc
+     *   version: 1.0
+     *   des: 判断数据库中是否存在该年度的数据
+     *   date: 2024/1/4
+     */
+    int getIfHaveThisNd(String nd);
+
+    /**
+     *   author: dzc
+     *   version: 1.0
+     *   des: 根据年度删除数据
+     *   date: 2024/1/4
+     */
+    int deleteZyfByNd(String nd);
 }

module_kzks/src/main/java/org/jeecg/modules/projectChbZyf/service/impl/ProjectChbZyfServiceImpl.java

@@ -158,4 +158,14 @@ public class ProjectChbZyfServiceImpl extends ServiceImpl<ProjectChbZyfMapper, P
     public int deleteZyf() {
         return zyfMapper.deleteZyf();
     }
+
+    @Override
+    public int getIfHaveThisNd(String nd) {
+        return zyfMapper.getIfHaveThisNd(nd);
+    }
+
+    @Override
+    public int deleteZyfByNd(String nd) {
+        return zyfMapper.deleteZyfByNd(nd);
+    }
 }

module_kzks/src/main/java/org/jeecg/modules/projectImportList/service/impl/ProjectImportListServiceImpl.java

@@ -125,6 +125,11 @@ public class ProjectImportListServiceImpl extends ServiceImpl<ProjectImportListM
                 columnMap.put("nd",tasknoAndNd.getNd());
 //                columnMap.put("taskno",tasknoAndNd.getTaskno());
 //                swfService.removeByMap(columnMap);
+                // 如果导入的年份在数据库当中存在，则删除掉该年份的数据，然后重新导入
+                int counnt = swfService.getIfHaveThisNd(tasknoAndNd.getNd());
+                if (counnt != 0){
+                    swfService.deleteSwfByNd(tasknoAndNd.getNd());
+                }
             }
             swfService.saveBatch(swfList);
             for(TasknoAndNd tasknoAndNd : tnZYFList){
@@ -132,6 +137,10 @@ public class ProjectImportListServiceImpl extends ServiceImpl<ProjectImportListM
                 columnMap.put("nd",tasknoAndNd.getNd());
 //                columnMap.put("taskno",tasknoAndNd.getTaskno());
 //                zyfService.removeByMap(columnMap);
+                int count = zyfService.getIfHaveThisNd(tasknoAndNd.getNd());
+                if (count != 0){
+                    zyfService.deleteZyfByNd(tasknoAndNd.getNd());
+                }
             }
             zyfService.saveBatch(zyfList);
             for(TasknoAndNd tasknoAndNd : tnWXFList){
@@ -139,13 +148,17 @@ public class ProjectImportListServiceImpl extends ServiceImpl<ProjectImportListM
                 columnMap.put("nd",tasknoAndNd.getNd());
 //                columnMap.put("taskno",tasknoAndNd.getTaskno());
 //                wxfService.removeByMap(columnMap);
+                int count = wxfService.getIfHaveThisNd(tasknoAndNd.getNd());
+                if (count != 0){
+                    wxfService.deleteWxfByNd(tasknoAndNd.getNd());
+                }
             }
             wxfService.saveBatch(wxfList);
-            log.info("消耗时间" + (System.currentTimeMillis() - start) + "毫秒");
+            log.info("消耗时间" + (System.currentTimeMillis() - start) + "毫秒," + "数据行数：" + list.size());
             //update-end-author:taoyan date:20190528 for:批量插入数据
-            swfService.deleteSwf();
-            wxfService.deleteWxf();
-            zyfService.deleteZyf();
+            //swfService.deleteSwf();
+            //wxfService.deleteWxf();
+            //zyfService.deleteZyf();
             return Result.ok("文件导入成功！数据行数：" + list.size());
         } catch (Exception e) {
             //update-begin-author:taoyan date:20211124 for: 导入数据重复增加提示