feature 增加项目同步接口

jsglkh-common/src/main/java/com/rongwei/bscommon/sys/service/SynchronizationDataService.java

@@ -4,9 +4,6 @@ import com.rongwei.rwcommon.base.R;
 
 import java.util.List;
 
-import java.util.List;
-import java.util.Map;
-
 /**
  * @author ：sc
  * @since ：2024/12/2
@@ -14,9 +11,13 @@ import java.util.Map;
 public interface SynchronizationDataService {
     R pushDataSync(String ids, String code);
 
-    R deleteDataSync(List<String> id, List<String>  dataIds, String code);
+    R deleteDataSync(List<String> id, List<String> dataIds, String code);
 
     R uploadFile(String fileId);
 
     R allPush(List<String> ids);
+
+    R projectPush(String id);
+
+    R projectDelete(String id);
 }

jsglkh-common/src/main/java/com/rongwei/bscommon/sys/service/impl/SynchronizationDataServiceImpl.java

@@ -7,6 +7,7 @@ import com.rongwei.bscommon.sys.strategy.api.*;
 import com.rongwei.bscommon.sys.utils.AttendanceAssessmentSdk;
 import com.rongwei.bsentity.domain.*;
 import com.rongwei.bsentity.dto.ApiCallDto;
+import com.rongwei.rwcommon.base.BaseDo;
 import com.rongwei.rwcommon.base.R;
 import com.rongwei.rwcommon.base.exception.CustomException;
 import com.rongwei.rwcommon.utils.StringUtils;
@@ -19,9 +20,10 @@ import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 
 import java.io.File;
-import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * @author ：sc
@@ -60,6 +62,18 @@ public class SynchronizationDataServiceImpl implements SynchronizationDataServic
     private JtZdxmszmnServiceImpl jtZdxmszmnService;
     @Autowired
     private JtXcjhqdServiceImpl jtXcjhqdService;
+    @Autowired
+    private JtGsjtbsjServiceImpl jtGsjtbsjService;
+    @Autowired
+    private JtZjfjflqdServiceImpl jtZjfjflqdService;
+    @Autowired
+    private JtJscgpyqdServiceImpl jtJscgpyqdService;
+    @Autowired
+    private JtYxwjfbqdServiceImpl jtYxwjfbqdService;
+    @Autowired
+    private JtJsglcgqdServiceImpl jtJsglcgqdService;
+    @Autowired
+    private JtXysjyqServiceImpl jtXysjyqService;
 
     /**
      * allPush数据推送
@@ -80,7 +94,7 @@ public class SynchronizationDataServiceImpl implements SynchronizationDataServic
                 this.pushDataSync(id, "KC103");
             }
         } else {
-           log.info("项目考核-分级管理项目数据为 null");
+            log.info("项目考核-分级管理项目数据为 null");
         }
 
         List<JtKcsjxm> jtKcsjxmList = jtKcsjxmService.list(new LambdaQueryWrapper<JtKcsjxm>()
@@ -230,6 +244,100 @@ public class SynchronizationDataServiceImpl implements SynchronizationDataServic
         return R.ok();
     }
 
+    @Override
+    public R projectPush(String id) {
+        JtGsjtbsj jtGsjtbsj = jtGsjtbsjService.getById(id);
+        if (jtGsjtbsj == null) {
+            throw new CustomException("无法获取到公司考核管理数据");
+        }
+        this.pushDataSync(id, "KC101");
+
+        //巡查计划清单 KC133
+        List<JtXcjhqd> jtXcjhqdList = jtXcjhqdService.list(new LambdaQueryWrapper<JtXcjhqd>().eq(JtXcjhqd::getMainid, id).eq(BaseDo::getDeleted, "0"));
+        if (!jtXcjhqdList.isEmpty()) {
+            this.pushDataSync(jtXcjhqdList.stream().map(JtXcjhqd::getId).collect(Collectors.joining(",")), "KC133");
+        }
+        //专家分级分类 KC135
+        List<JtZjfjflqd> JtZjfjflqdList = jtZjfjflqdService.list(new LambdaQueryWrapper<JtZjfjflqd>().eq(JtZjfjflqd::getMainid, id).eq(BaseDo::getDeleted, "0"));
+        if (!JtZjfjflqdList.isEmpty()) {
+            this.pushDataSync(JtZjfjflqdList.stream().map(JtZjfjflqd::getId).collect(Collectors.joining(",")), "KC135");
+        }
+        //技术成果评优 KC137
+        List<JtJscgpyqd> JtJscgpyqdList = jtJscgpyqdService.list(new LambdaQueryWrapper<JtJscgpyqd>().eq(JtJscgpyqd::getMainid, id).eq(BaseDo::getDeleted, "0"));
+        if (!JtJscgpyqdList.isEmpty()) {
+            this.pushDataSync(JtJscgpyqdList.stream().map(JtJscgpyqd::getId).collect(Collectors.joining(",")), "KC137");
+        }
+        //有效文件 KC139
+        List<JtYxwjfbqd> JtYxwjfbqdList = jtYxwjfbqdService.list(new LambdaQueryWrapper<JtYxwjfbqd>().eq(JtYxwjfbqd::getMainid, id).eq(BaseDo::getDeleted, "0"));
+        if (!JtYxwjfbqdList.isEmpty()) {
+            this.pushDataSync(JtYxwjfbqdList.stream().map(JtYxwjfbqd::getId).collect(Collectors.joining(",")), "KC139");
+        }
+        // 技术管理成果 KC141
+        List<JtJsglcgqd> JtJsglcgqdList = jtJsglcgqdService.list(new LambdaQueryWrapper<JtJsglcgqd>().eq(JtJsglcgqd::getMainid, id).eq(BaseDo::getDeleted, "0"));
+        if (!JtJsglcgqdList.isEmpty()) {
+            this.pushDataSync(JtJsglcgqdList.stream().map(JtJsglcgqd::getId).collect(Collectors.joining(",")), "KC141");
+        }
+        // 响应上级要求 KC143
+        List<JtXysjyq> JtXysjyqList = jtXysjyqService.list(new LambdaQueryWrapper<JtXysjyq>().eq(JtXysjyq::getMainid, id).eq(BaseDo::getDeleted, "0"));
+        if (!JtXysjyqList.isEmpty()) {
+            this.pushDataSync(JtXysjyqList.stream().map(JtXysjyq::getId).collect(Collectors.joining(",")), "KC143");
+        }
+        return R.ok();
+    }
+
+    @Override
+    public R projectDelete(String id) {
+        JtGsjtbsj jtGsjtbsj = jtGsjtbsjService.getById(id);
+        if (jtGsjtbsj == null) {
+            throw new CustomException("无法获取到公司考核管理数据");
+        }
+        this.deleteDataSync(Arrays.asList(id), Arrays.asList(jtGsjtbsj.getDataid()), "KC102");
+        //巡查计划清单 KC134
+        List<JtXcjhqd> jtXcjhqdList = jtXcjhqdService.list(new LambdaQueryWrapper<JtXcjhqd>().eq(JtXcjhqd::getMainid, id).eq(BaseDo::getDeleted, "0"));
+        if (!jtXcjhqdList.isEmpty()) {
+            List<String> ids = jtXcjhqdList.stream().map(JtXcjhqd::getId).collect(Collectors.toList());
+            List<String> dataIds = jtXcjhqdList.stream().map(data -> data.getDataid() == null ? " " : data.getDataid()).collect(Collectors.toList());
+            this.deleteDataSync(ids, dataIds, "KC134");
+        }
+
+        //专家分级分类 KC136
+        List<JtZjfjflqd> JtZjfjflqdList = jtZjfjflqdService.list(new LambdaQueryWrapper<JtZjfjflqd>().eq(JtZjfjflqd::getMainid, id).eq(BaseDo::getDeleted, "0"));
+        if (!JtZjfjflqdList.isEmpty()) {
+            List<String> ids = JtZjfjflqdList.stream().map(JtZjfjflqd::getId).collect(Collectors.toList());
+            List<String> dataIds = JtZjfjflqdList.stream().map(data -> data.getDataid() == null ? " " : data.getDataid()).collect(Collectors.toList());
+            this.deleteDataSync(ids, dataIds, "KC136");
+        }
+        //技术成果评优 KC138
+        List<JtJscgpyqd> JtJscgpyqdList = jtJscgpyqdService.list(new LambdaQueryWrapper<JtJscgpyqd>().eq(JtJscgpyqd::getMainid, id).eq(BaseDo::getDeleted, "0"));
+        if (!JtJscgpyqdList.isEmpty()) {
+            List<String> ids = JtJscgpyqdList.stream().map(JtJscgpyqd::getId).collect(Collectors.toList());
+            List<String> dataIds = JtJscgpyqdList.stream().map(data -> data.getDataid() == null ? " " : data.getDataid()).collect(Collectors.toList());
+            this.deleteDataSync(ids, dataIds, "KC138");
+        }
+        //有效文件 KC140
+        List<JtYxwjfbqd> JtYxwjfbqdList = jtYxwjfbqdService.list(new LambdaQueryWrapper<JtYxwjfbqd>().eq(JtYxwjfbqd::getMainid, id).eq(BaseDo::getDeleted, "0"));
+        if (!JtYxwjfbqdList.isEmpty()) {
+            List<String> ids = JtYxwjfbqdList.stream().map(JtYxwjfbqd::getId).collect(Collectors.toList());
+            List<String> dataIds = JtYxwjfbqdList.stream().map(data -> data.getDataid() == null ? " " : data.getDataid()).collect(Collectors.toList());
+            this.deleteDataSync(ids, dataIds, "KC140");
+        }
+        // 技术管理成果 KC142
+        List<JtJsglcgqd> JtJsglcgqdList = jtJsglcgqdService.list(new LambdaQueryWrapper<JtJsglcgqd>().eq(JtJsglcgqd::getMainid, id).eq(BaseDo::getDeleted, "0"));
+        if (!JtJsglcgqdList.isEmpty()) {
+            List<String> ids = JtJsglcgqdList.stream().map(JtJsglcgqd::getId).collect(Collectors.toList());
+            List<String> dataIds = JtJsglcgqdList.stream().map(data -> data.getDataid() == null ? " " : data.getDataid()).collect(Collectors.toList());
+            this.deleteDataSync(ids, dataIds, "KC142");
+        }
+        // 响应上级要求 KC144
+        List<JtXysjyq> JtXysjyqList = jtXysjyqService.list(new LambdaQueryWrapper<JtXysjyq>().eq(JtXysjyq::getMainid, id).eq(BaseDo::getDeleted, "0"));
+        if (!JtXysjyqList.isEmpty()) {
+            List<String> ids = JtXysjyqList.stream().map(JtXysjyq::getId).collect(Collectors.toList());
+            List<String> dataIds = JtXysjyqList.stream().map(data -> data.getDataid() == null ? " " : data.getDataid()).collect(Collectors.toList());
+            this.deleteDataSync(ids, dataIds, "KC144");
+        }
+        return R.ok();
+    }
+
 
     /**
      * 业务数据同步方法
@@ -397,7 +505,7 @@ public class SynchronizationDataServiceImpl implements SynchronizationDataServic
         CalculatorContext primaryContext = new CalculatorContext(apiRequestAndProcessingStrategy);
 
         for (int i = 0; i < idList.size(); i++) {
-            Map<String, Object> apiCallData=null;
+            Map<String, Object> apiCallData = null;
             // 数据组装
             if (StringUtils.isNotBlank(dataIdList.get(i))) {
                 apiCallData = primaryContext.executeStrategy(idList.get(i), dataIdList.get(i), code);

jsglkh-server/src/main/java/com/rongwei/controller/SynchronizationDataController.java

@@ -14,9 +14,6 @@ import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 
-import java.util.List;
-import java.util.Map;
-
 /**
  * @author ：sc
  * @since ：2024/12/2
@@ -37,8 +34,6 @@ public class SynchronizationDataController {
     }
 
 
-
-
     /**
      * 删除接口同步方法
      */
@@ -47,12 +42,11 @@ public class SynchronizationDataController {
         String dataIds = jsonDatas.getOrDefault("dataIds", "");
         List<String> list = Arrays.asList(dataIds.split(","));
         List<String> ids = list.stream().map(data -> data.split(":")[0]).collect(Collectors.toList());
-        List<String> dataIdList = list.stream().map(data -> data.split(":").length>1?data.split(":")[1]:"").collect(Collectors.toList());
+        List<String> dataIdList = list.stream().map(data -> data.split(":").length > 1 ? data.split(":")[1] : "").collect(Collectors.toList());
         return synchronizationDataService.deleteDataSync(ids, dataIdList, jsonDatas.getOrDefault("code", ""));
     }
 
 
-
     /**
      * 模仿测试文件上传
      */
@@ -68,6 +62,7 @@ public class SynchronizationDataController {
             return null;
         }
     }
+
     /**
      * allpush
      */
@@ -85,4 +80,21 @@ public class SynchronizationDataController {
         return synchronizationDataService.uploadFile(fileId);
     }
 
+
+    /**
+     * 新增和修改接口同步方法
+     */
+    @PostMapping("/project/push/{id}")
+    public R projectPush(@PathVariable String id) {
+        return synchronizationDataService.projectPush(id);
+    }
+
+
+    /**
+     * 删除接口同步方法
+     */
+    @PostMapping("/project/delete/{id}")
+    public R projectDelete(@PathVariable String id) {
+        return synchronizationDataService.projectDelete(id);
+    }
 }