Browse Source

建立考核项目新增/删除

cgy 7 months ago
parent
commit
132d7be46d

+ 2 - 0
jsglkh-common/src/main/java/com/rongwei/bscommon/sys/dao/BusinessCommonMapper.java

@@ -19,4 +19,6 @@ public interface BusinessCommonMapper {
 
     void deletedAboutInfoByProjectName(@Param("projectName") String projectName,
                                        @Param("mainId") String mainId);
+    void deletedAboutInfoByProjectNameJlxm(@Param("projectName") String projectName,
+                                       @Param("mainId") String mainId);
 }

+ 2 - 0
jsglkh-common/src/main/java/com/rongwei/bscommon/sys/service/BusinessCommonService.java

@@ -13,4 +13,6 @@ import java.util.Map;
  */
 public interface BusinessCommonService {
     R deletedAboutInfoByProjectName(Map<String,String> projectNameMap);
+
+    R deletedAboutInfoByProjectNamJlxm(Map<String, String> projectNameMap);
 }

+ 7 - 0
jsglkh-common/src/main/java/com/rongwei/bscommon/sys/service/ExamineService.java

@@ -2,6 +2,9 @@ package com.rongwei.bscommon.sys.service;
 
 import com.rongwei.rwcommon.base.R;
 
+import java.util.List;
+import java.util.Map;
+
 /**
  * ExamineService class
  *
@@ -10,4 +13,8 @@ import com.rongwei.rwcommon.base.R;
  */
 public interface ExamineService {
     R calculateScore(String id,String khzbNum);
+
+    R createKhbm(List<Map<String, Object>> jsonDatas);
+
+    R addkhbm(Map<String, Object> jsonDatas) throws Exception;
 }

+ 13 - 0
jsglkh-common/src/main/java/com/rongwei/bscommon/sys/service/impl/BusinessCommonServiceImpl.java

@@ -34,4 +34,17 @@ public class BusinessCommonServiceImpl implements BusinessCommonService {
         businessCommonMapper.deletedAboutInfoByProjectName(projectName, mainId);
         return R.ok();
     }
+    @Override
+    public R deletedAboutInfoByProjectNamJlxm(Map<String, String> projectNameMap) {
+        String projectName = projectNameMap.getOrDefault("projectName", "");
+        if (StringUtils.isBlank(projectName)) {
+            throw new CustomException("数据异常");
+        }
+        String mainId = projectNameMap.getOrDefault("mainId", "");
+        if (StringUtils.isBlank(mainId)) {
+            throw new CustomException("数据异常");
+        }
+        businessCommonMapper.deletedAboutInfoByProjectNameJlxm(projectName, mainId);
+        return R.ok();
+    }
 }

+ 447 - 4
jsglkh-common/src/main/java/com/rongwei/bscommon/sys/service/impl/ExamineServiceImpl.java

@@ -1,7 +1,9 @@
 package com.rongwei.bscommon.sys.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.rongwei.bscommon.sys.service.ExamineService;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.rongwei.bscommon.sys.service.*;
 import com.rongwei.bscommon.sys.strategy.scoreCalculation.ScoreCalculationService;
 import com.rongwei.bscommon.sys.utils.JXKHUtils;
 import com.rongwei.bsentity.domain.*;
@@ -9,6 +11,7 @@ import com.rongwei.rwadmincommon.system.vo.SysUserVo;
 import com.rongwei.rwcommon.base.BaseDo;
 import com.rongwei.rwcommon.base.R;
 import com.rongwei.rwcommon.base.exception.CustomException;
+import com.rongwei.rwcommon.utils.SecurityUtil;
 import com.rongwei.rwcommon.utils.SpringContextUtils;
 import com.rongwei.rwcommon.utils.StringUtils;
 import org.slf4j.Logger;
@@ -17,9 +20,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -44,6 +45,30 @@ public class ExamineServiceImpl implements ExamineService {
     @Autowired
     private JtFjglxmServiceImpl jtFjglxmService;
     @Autowired
+    private JtKcsjxmServiceImpl jtKcsjxmService;
+    @Autowired
+    private JtGzdgServiceImpl jtGzdgService;
+    @Autowired
+    private JtZtfapsServiceImpl jtZtfapsService;
+    @Autowired
+    private JtWyysServiceImpl jtWyysService;
+    @Autowired
+    private JtYjbhglServiceImpl jtYjbhglService;
+    @Autowired
+    private JtScsdlServiceImpl jtScsdlService;
+    @Autowired
+    private JtWtbhglServiceImpl jtWtbhglService;
+    @Autowired
+    private JtScbhglServiceImpl jtScbhglService;
+    @Autowired
+    private JtSjjdqdServiceImpl jtSjjdqdService;
+    @Autowired
+    private JtSjbgqdServiceImpl jtSjbgqdService;
+    @Autowired
+    private JtZdxmszmnServiceImpl jtZdxmszmnService;
+    @Autowired
+    private JtXcjhqdServiceImpl jtXcjhqdService;
+    @Autowired
     private JtYcpfhzDetailServiceImpl jtYcpfhzDetailService;
 
     /**
@@ -115,4 +140,422 @@ public class ExamineServiceImpl implements ExamineService {
         jtYcpfhzDetailService.saveBatch(saveData, 10);
         return R.ok();
     }
+
+    @Override
+    public R createKhbm(List<Map<String, Object>> jsonDatas) {
+        // 创建一个列表存储所有的JtFjglxm
+        List<JtFjglxm> jtFjglxmList = new ArrayList<>();
+        /**
+         * 勘察设计项目清单  jt_kcsjxm
+         * 工作大纲/指导书审查率 jt_gzdg
+         * 总体方案评审清单 jt_ztfaps
+         * 外业验收清单 jt_wyys
+         * 意见闭环管理 jt_yjbhgl
+         * 审查审定率 jt_scsdl
+         * 问题闭环管理 jt_wtbhgl
+         * 审查闭环管理 jt_scbhgl
+         * 设计交底清单 jt_sjjdqd
+         * 设计变更清单 jt_sjbgqd
+         * 重点项目数值模拟 jt_zdxmszmn
+         * 巡查计划清单 jt_xcjhqd
+         */
+        List<JtKcsjxm> jtKcsjxmList = new ArrayList<>();
+        List<JtGzdg> jtGzdgList = new ArrayList<>();
+        List<JtZtfaps> jtZtfapsList = new ArrayList<>();
+        List<JtWyys> jtWyysList = new ArrayList<>();
+        List<JtYjbhgl> jtYjbhglList = new ArrayList<>();
+        List<JtScsdl>  jtScsdlList = new ArrayList<>();
+        List<JtWtbhgl> jtWtbhglList = new ArrayList<>();
+        List<JtScbhgl> jtScbhglList = new ArrayList<>();
+        List<JtSjjdqd> jtSjjdqdList = new ArrayList<>();
+        List<JtSjbgqd> jtSjbgqdList = new ArrayList<>();
+        List<JtZdxmszmn> jtZdxmszmnList = new ArrayList<>();
+        List<JtXcjhqd> jtXcjhqdList = new ArrayList<>();
+        // 遍历列表
+        jsonDatas.forEach(data -> {
+            String mainid = (String) data.getOrDefault("mainid", "");
+            String scxmbh = (String) data.getOrDefault("SCXMBH", ""); // 生产项目编号
+            String xmmc = (String) data.getOrDefault("XMMC", ""); // 项目名称
+            String xmzsjbm = (String) data.getOrDefault("XMZSJBM", ""); // 项目主数据编码
+            String year = (String) data.getOrDefault("YEAR", ""); // 考核年
+            String zbztdw = (String) data.getOrDefault("ZBZTDW", ""); // 中标主体单位
+
+            //根据 id 和 xmmc去 JtFjglxm表里查询有没有 maminid  xmmc=xmmc 的数据 如果有的话就不新增 如果没有就要新增一条数据
+            JtFjglxm jtFjglxm1 = jtFjglxmService.getOne(new LambdaQueryWrapper<JtFjglxm>()
+                    .eq(JtFjglxm::getMainid, mainid)
+                    .eq(JtFjglxm::getXmmc, xmmc)
+                    .eq(JtFjglxm::getDeleted, "0"));
+            if (jtFjglxm1 == null) {
+                JtFjglxm jtFjglxm = new JtFjglxm();
+                jtFjglxm.setId(SecurityUtil.getUUID());
+                jtFjglxm.setXmbh(scxmbh);      // 设置生产项目编号
+                jtFjglxm.setXmmc(xmmc);        // 设置项目名称
+                jtFjglxm.setXmzsjbm(xmzsjbm);  // 设置项目主数据编码
+                jtFjglxm.setYear(year);        // 设置考核年
+                jtFjglxm.setZbztdw(zbztdw);    // 设置中标主体单位
+                jtFjglxm.setDeleted("0");
+                jtFjglxm.setCreatedate(new Date());
+                jtFjglxm.setModifydate(new Date());
+                jtFjglxm.setCreateusername("系统生成");
+                jtFjglxm.setModifyusername("系统生成");
+                jtFjglxm.setMainid(mainid);
+                // 将 JtFjglxm 对象添加到列表中
+                jtFjglxmList.add(jtFjglxm);
+            }
+
+            /**
+             * 勘察设计项目清单  jtKcsjxmList
+             * 考核年	项目主数据编码	项目名称	项目编号	中标主体单位
+             */
+            JtKcsjxm jtKcsjxm1 = jtKcsjxmService.getOne(new LambdaQueryWrapper<JtKcsjxm>()
+                    .eq(JtKcsjxm::getMainid, mainid)
+                    .eq(JtKcsjxm::getXmmc, xmmc)
+                    .eq(JtKcsjxm::getDeleted, "0"));
+            if (jtKcsjxm1 == null) {
+                JtKcsjxm jtKcsjxm = new JtKcsjxm();
+                jtKcsjxm.setId(SecurityUtil.getUUID());
+                jtKcsjxm.setXmbh(scxmbh);      // 设置生产项目编号
+                jtKcsjxm.setXmmc(xmmc);        // 设置项目名称
+                jtKcsjxm.setXmzsjbm(xmzsjbm);  // 设置项目主数据编码
+                jtKcsjxm.setYear(year);        // 设置考核年
+                jtKcsjxm.setZbztdw(zbztdw);    // 设置中标主体单位
+                jtKcsjxm.setDeleted("0");
+                jtKcsjxm.setCreatedate(new Date());
+                jtKcsjxm.setModifydate(new Date());
+                jtKcsjxm.setCreateusername("系统生成");
+                jtKcsjxm.setModifyusername("系统生成");
+                jtKcsjxm.setMainid(mainid);
+                // 将 JtFjglxm 对象添加到列表中
+                jtKcsjxmList.add(jtKcsjxm);
+            }
+
+            /** 工作大纲/指导书审查率 jtGzdgList
+             *考核年	项目主数据编码	项目名称	项目编号	中标主体单位
+             */
+            JtGzdg jtGzdg1 = jtGzdgService.getOne(new LambdaQueryWrapper<JtGzdg>()
+                    .eq(JtGzdg::getMainid, mainid)
+                    .eq(JtGzdg::getXmmc, xmmc)
+                    .eq(JtGzdg::getDeleted, "0"));
+            if (jtGzdg1 == null) {
+                JtGzdg jtGzdg = new JtGzdg();
+                jtGzdg.setId(SecurityUtil.getUUID());
+                jtGzdg.setXmbh(scxmbh);      // 设置生产项目编号
+                jtGzdg.setXmmc(xmmc);        // 设置项目名称
+                jtGzdg.setXmzsjbm(xmzsjbm);  // 设置项目主数据编码
+                jtGzdg.setYear(year);         // 设置考核年
+                jtGzdg.setZbztdw(zbztdw);     // 设置中标主体单位
+                jtGzdg.setDeleted("0");
+                jtGzdg.setCreatedate(new Date());
+                jtGzdg.setModifydate(new Date());
+                jtGzdg.setCreateusername("系统生成");
+                jtGzdg.setModifyusername("系统生成");
+                jtGzdg.setMainid(mainid);
+                jtGzdgList.add(jtGzdg);
+            }
+
+            /**
+             * 总体方案评审清单 jtZtfapsList
+             *考核年	项目主数据编码	项目名称	项目编号	中标主体单位
+             */
+            JtZtfaps jtZtfaps1 = jtZtfapsService.getOne(new LambdaQueryWrapper<JtZtfaps>()
+                    .eq(JtZtfaps::getMainid, mainid)
+                    .eq(JtZtfaps::getXmmc, xmmc)
+                    .eq(JtZtfaps::getDeleted, "0"));
+            if (jtZtfaps1 == null) {
+                JtZtfaps jtZtfaps = new JtZtfaps();
+                jtZtfaps.setId(SecurityUtil.getUUID());
+                jtZtfaps.setXmbh(scxmbh);      // 设置生产项目编号
+                jtZtfaps.setXmmc(xmmc);        // 设置项目名称
+                jtZtfaps.setXmzsjbm(xmzsjbm);  // 设置项目主数据编码
+                jtZtfaps.setYear(year);         // 设置考核年
+                jtZtfaps.setZbztdw(zbztdw);     // 设置中标主体单位
+                jtZtfaps.setDeleted("0");
+                jtZtfaps.setCreatedate(new Date());
+                jtZtfaps.setModifydate(new Date());
+                jtZtfaps.setCreateusername("系统生成");
+                jtZtfaps.setModifyusername("系统生成");
+                jtZtfaps.setMainid(mainid);
+                jtZtfapsList.add(jtZtfaps);
+            }
+
+            /**
+             * 外业验收清单 jtWyysList
+             *考核年	项目主数据编码	项目名称	项目编号	中标主体单位
+             */
+            JtWyys jtWyys1 = jtWyysService.getOne(new LambdaQueryWrapper<JtWyys>()
+                    .eq(JtWyys::getMainid, mainid)
+                    .eq(JtWyys::getXmmc, xmmc)
+                    .eq(JtWyys::getDeleted, "0"));
+            if (jtWyys1 == null) {
+                JtWyys jtWyys = new JtWyys();
+                jtWyys.setId(SecurityUtil.getUUID());
+                jtWyys.setXmbh(scxmbh);      // 设置生产项目编号
+                jtWyys.setXmmc(xmmc);        // 设置项目名称
+                jtWyys.setXmzsjbm(xmzsjbm);  // 设置项目主数据编码
+                jtWyys.setYear(year);         // 设置考核年
+                jtWyys.setZbztdw(zbztdw);     // 设置中标主体单位
+                jtWyys.setDeleted("0");
+                jtWyys.setCreatedate(new Date());
+                jtWyys.setModifydate(new Date());
+                jtWyys.setCreateusername("系统生成");
+                jtWyys.setModifyusername("系统生成");
+                jtWyys.setMainid(mainid);
+                jtWyysList.add(jtWyys);
+            }
+
+            /**
+             * 意见闭环管理 jtYjbhglList
+             *	考核年	项目主数据编码	项目名称	项目编号	中标主体单
+             */
+            JtYjbhgl jtYjbhgl1 = jtYjbhglService.getOne(new LambdaQueryWrapper<JtYjbhgl>()
+                    .eq(JtYjbhgl::getMainid, mainid)
+                    .eq(JtYjbhgl::getXmmc, xmmc)
+                    .eq(JtYjbhgl::getDeleted, "0"));
+            if (jtYjbhgl1 == null) {
+                JtYjbhgl jtYjbhgl = new JtYjbhgl();
+                jtYjbhgl.setId(SecurityUtil.getUUID());
+                jtYjbhgl.setXmbh(scxmbh);      // 设置生产项目编号
+                jtYjbhgl.setXmmc(xmmc);        // 设置项目名称
+                jtYjbhgl.setXmzsjbm(xmzsjbm);  // 设置项目主数据编码
+                jtYjbhgl.setYear(year);         // 设置考核年
+                jtYjbhgl.setZbztdw(zbztdw);     // 设置中标主体单位
+                jtYjbhgl.setDeleted("0");
+                jtYjbhgl.setCreatedate(new Date());
+                jtYjbhgl.setModifydate(new Date());
+                jtYjbhgl.setCreateusername("系统生成");
+                jtYjbhgl.setModifyusername("系统生成");
+                jtYjbhgl.setMainid(mainid);
+                jtYjbhglList.add(jtYjbhgl);
+            }
+
+            /**
+             * 审查审定率 jtScsdlList
+             *考核年	项目主数据编码	项目名称	项目编号	中标主体单位
+             */
+            JtScsdl jtScsdl1 = jtScsdlService.getOne(new LambdaQueryWrapper<JtScsdl>()
+                    .eq(JtScsdl::getMainid, mainid)
+                    .eq(JtScsdl::getXmmc, xmmc)
+                    .eq(JtScsdl::getDeleted, "0"));
+            if (jtScsdl1 == null) {
+                JtScsdl jtScsdl = new JtScsdl();
+                jtScsdl.setId(SecurityUtil.getUUID());
+                jtScsdl.setXmbh(scxmbh);      // 设置生产项目编号
+                jtScsdl.setXmmc(xmmc);        // 设置项目名称
+                jtScsdl.setXmzsjbm(xmzsjbm);  // 设置项目主数据编码
+                jtScsdl.setYear(year);         // 设置考核年
+                jtScsdl.setZbztdw(zbztdw);     // 设置中标主体单位
+                jtScsdl.setDeleted("0");
+                jtScsdl.setCreatedate(new Date());
+                jtScsdl.setModifydate(new Date());
+                jtScsdl.setCreateusername("系统生成");
+                jtScsdl.setModifyusername("系统生成");
+                jtScsdl.setMainid(mainid);
+                jtScsdlList.add(jtScsdl);
+            }
+
+            /**
+             * 问题闭环管理 jtWtbhglList
+             *考核年	项目主数据编码	项目名称	项目编号	中标主体单位
+             */
+            JtWtbhgl jtWtbhgl1 = jtWtbhglService.getOne(new LambdaQueryWrapper<JtWtbhgl>()
+                    .eq(JtWtbhgl::getMainid, mainid)
+                    .eq(JtWtbhgl::getXmmc, xmmc)
+                    .eq(JtWtbhgl::getDeleted, "0"));
+            if (jtWtbhgl1 == null) {
+                JtWtbhgl jtWtbhgl = new JtWtbhgl();
+                jtWtbhgl.setId(SecurityUtil.getUUID());
+                jtWtbhgl.setXmbh(scxmbh);      // 设置生产项目编号
+                jtWtbhgl.setXmmc(xmmc);        // 设置项目名称
+                jtWtbhgl.setXmzsjbm(xmzsjbm);  // 设置项目主数据编码
+                jtWtbhgl.setYear(year);         // 设置考核年
+                jtWtbhgl.setZbztdw(zbztdw);     // 设置中标主体单位
+                jtWtbhgl.setDeleted("0");
+                jtWtbhgl.setCreatedate(new Date());
+                jtWtbhgl.setModifydate(new Date());
+                jtWtbhgl.setCreateusername("系统生成");
+                jtWtbhgl.setModifyusername("系统生成");
+                jtWtbhgl.setMainid(mainid);
+                jtWtbhglList.add(jtWtbhgl);
+            }
+
+            /**
+             * 审查闭环管理 jtScbhglList
+             *考核年	项目主数据编码	项目名称	生产项目编号	中标主体单位
+             */
+            JtScbhgl jtScbhgl1 = jtScbhglService.getOne(new LambdaQueryWrapper<JtScbhgl>()
+                    .eq(JtScbhgl::getMainid, mainid)
+                    .eq(JtScbhgl::getXmmc, xmmc)
+                    .eq(JtScbhgl::getDeleted, "0"));
+            if (jtScbhgl1 == null) {
+                JtScbhgl jtScbhgl = new JtScbhgl();
+                jtScbhgl.setId(SecurityUtil.getUUID());
+                jtScbhgl.setXmbh(scxmbh);      // 设置生产项目编号
+                jtScbhgl.setXmmc(xmmc);        // 设置项目名称
+                jtScbhgl.setXmzsjbm(xmzsjbm);  // 设置项目主数据编码
+                jtScbhgl.setYear(year);         // 设置考核年
+                jtScbhgl.setZbztdw(zbztdw);     // 设置中标主体单位
+                jtScbhgl.setDeleted("0");
+                jtScbhgl.setCreatedate(new Date());
+                jtScbhgl.setModifydate(new Date());
+                jtScbhgl.setCreateusername("系统生成");
+                jtScbhgl.setModifyusername("系统生成");
+                jtScbhgl.setMainid(mainid);
+                jtScbhglList.add(jtScbhgl);
+            }
+
+
+            /**
+             * 设计交底清单 jtSjjdqdList
+             *考核年	项目主数据编码	项目名称	生产项目编号	中标主体单位
+             */
+            JtSjjdqd jtSjjdqd1 = jtSjjdqdService.getOne(new LambdaQueryWrapper<JtSjjdqd>()
+                    .eq(JtSjjdqd::getMainid, mainid)
+                    .eq(JtSjjdqd::getXmmc, xmmc)
+                    .eq(JtSjjdqd::getDeleted, "0"));
+            if (jtSjjdqd1 == null) {
+                JtSjjdqd jtSjjdqd = new JtSjjdqd();
+                jtSjjdqd.setId(SecurityUtil.getUUID());
+                jtSjjdqd.setXmbh(scxmbh);      // 设置生产项目编号
+                jtSjjdqd.setXmmc(xmmc);        // 设置项目名称
+                jtSjjdqd.setXmzsjbm(xmzsjbm);  // 设置项目主数据编码
+                jtSjjdqd.setYear(year);         // 设置考核年
+                jtSjjdqd.setZbztdw(zbztdw);     // 设置中标主体单位
+                jtSjjdqd.setDeleted("0");
+                jtSjjdqd.setCreatedate(new Date());
+                jtSjjdqd.setModifydate(new Date());
+                jtSjjdqd.setCreateusername("系统生成");
+                jtSjjdqd.setModifyusername("系统生成");
+                jtSjjdqd.setMainid(mainid);
+                jtSjjdqdList.add(jtSjjdqd);
+            }
+
+            /**
+             * 设计变更清单 jtSjbgqdList
+             *考核年	项目主数据编码	项目名称	生产项目编号	中标主体单位
+             */
+            JtSjbgqd jtSjbgqd1 = jtSjbgqdService.getOne(new LambdaQueryWrapper<JtSjbgqd>()
+                    .eq(JtSjbgqd::getMainid, mainid)
+                    .eq(JtSjbgqd::getXmmc, xmmc)
+                    .eq(JtSjbgqd::getDeleted, "0"));
+            if (jtSjbgqd1 == null) {
+                JtSjbgqd jtSjbgqd = new JtSjbgqd();
+                jtSjbgqd.setId(SecurityUtil.getUUID());
+                jtSjbgqd.setXmbh(scxmbh);      // 设置生产项目编号
+                jtSjbgqd.setXmmc(xmmc);        // 设置项目名称
+                jtSjbgqd.setXmzsjbm(xmzsjbm);  // 设置项目主数据编码
+                jtSjbgqd.setYear(year);         // 设置考核年
+                jtSjbgqd.setZbztdw(zbztdw);     // 设置中标主体单位
+                jtSjbgqd.setDeleted("0");
+                jtSjbgqd.setCreatedate(new Date());
+                jtSjbgqd.setModifydate(new Date());
+                jtSjbgqd.setCreateusername("系统生成");
+                jtSjbgqd.setModifyusername("系统生成");
+                jtSjbgqd.setMainid(mainid);
+                jtSjbgqdList.add(jtSjbgqd);
+            }
+
+            /**
+             * 重点项目数值模拟 jtZdxmszmnList
+             *考核年	项目主数据编码	项目名称	项目编号	中标主体单位
+             */
+            JtZdxmszmn jtZdxmszmn1 = jtZdxmszmnService.getOne(new LambdaQueryWrapper<JtZdxmszmn>()
+                    .eq(JtZdxmszmn::getMainid, mainid)
+                    .eq(JtZdxmszmn::getXmmc, xmmc)
+                    .eq(JtZdxmszmn::getDeleted, "0"));
+            if (jtZdxmszmn1 == null) {
+                JtZdxmszmn jtZdxmszmn = new JtZdxmszmn();
+                jtZdxmszmn.setId(SecurityUtil.getUUID());
+                jtZdxmszmn.setXmbh(scxmbh);      // 设置生产项目编号
+                jtZdxmszmn.setXmmc(xmmc);        // 设置项目名称
+                jtZdxmszmn.setXmzsjbm(xmzsjbm);  // 设置项目主数据编码
+                jtZdxmszmn.setYear(year);         // 设置考核年
+                jtZdxmszmn.setZbztdw(zbztdw);     // 设置中标主体单位
+                jtZdxmszmn.setDeleted("0");
+                jtZdxmszmn.setCreatedate(new Date());
+                jtZdxmszmn.setModifydate(new Date());
+                jtZdxmszmn.setCreateusername("系统生成");
+                jtZdxmszmn.setModifyusername("系统生成");
+                jtZdxmszmn.setMainid(mainid);
+                jtZdxmszmnList.add(jtZdxmszmn);
+            }
+
+            /**
+             * 巡查计划清单 jtXcjhqdList
+             *考核年	项目主数据编码	项目名称	项目编号	中标主体单位
+             */
+            JtXcjhqd jtXcjhqd1 = jtXcjhqdService.getOne(new LambdaQueryWrapper<JtXcjhqd>()
+                    .eq(JtXcjhqd::getMainid, mainid)
+                    .eq(JtXcjhqd::getXmmc, xmmc)
+                    .eq(JtXcjhqd::getDeleted, "0"));
+            if (jtXcjhqd1 == null) {
+                JtXcjhqd jtXcjhqd = new JtXcjhqd();
+                jtXcjhqd.setId(SecurityUtil.getUUID());        // 设置唯一ID
+                jtXcjhqd.setXmbh(scxmbh);                      // 设置生产项目编号
+                jtXcjhqd.setXmmc(xmmc);                        // 设置项目名称
+                jtXcjhqd.setXmzsjbm(xmzsjbm);                  // 设置项目主数据编码
+                jtXcjhqd.setYear(year);                         // 设置考核年
+                jtXcjhqd.setZbztdw(zbztdw);                    // 设置中标主体单位
+                jtXcjhqd.setDeleted("0");                      // 设置删除标记
+                jtXcjhqd.setCreatedate(new Date());            // 设置创建时间
+                jtXcjhqd.setModifydate(new Date());            // 设置修改时间
+                jtXcjhqd.setCreateusername("系统生成");         // 设置创建用户名
+                jtXcjhqd.setModifyusername("系统生成");         // 设置修改用户名
+                jtXcjhqd.setMainid(mainid);
+                jtXcjhqdList.add(jtXcjhqd);
+            }
+
+       });
+       // 批量保存数据
+       jtFjglxmService.saveBatch(jtFjglxmList);
+       jtKcsjxmService.saveBatch(jtKcsjxmList);
+       jtGzdgService.saveBatch(jtGzdgList);
+       jtZtfapsService.saveBatch(jtZtfapsList);
+       jtWyysService.saveBatch(jtWyysList);
+       jtYjbhglService.saveBatch(jtYjbhglList);
+       jtScsdlService.saveBatch(jtScsdlList);
+       jtWtbhglService.saveBatch(jtWtbhglList);
+       jtScbhglService.saveBatch(jtScbhglList);
+       jtSjjdqdService.saveBatch(jtSjjdqdList);
+       jtSjbgqdService.saveBatch(jtSjbgqdList);
+       jtZdxmszmnService.saveBatch(jtZdxmszmnList);
+       jtXcjhqdService.saveBatch(jtXcjhqdList);
+       return R.ok("保存成功");
+   }
+
+    @Override
+    public R addkhbm(Map<String, Object> jsonDatas) throws Exception {
+        ObjectMapper objectMapper = new ObjectMapper();
+        // 将 Map 转换为 JSON 字符串后使用 readTree 解析 JSON 字符串为 JsonNode
+        String jsonString = objectMapper.writeValueAsString(jsonDatas);
+        JsonNode rootNode = objectMapper.readTree(jsonString);
+        // 获取字段
+        String year = rootNode.get("YEAR").asText();
+        String gldw = rootNode.get("GLDW").asText();
+        String org = rootNode.get("ORG").asText();
+        String reportStatus = rootNode.get("REPORTSTATUS").asText();
+        String processStatus = rootNode.has("PROCESSSTATUS") ? rootNode.get("PROCESSSTATUS").asText() : null;
+        String deleted = rootNode.get("DELETED").asText();
+        String createuserid = rootNode.get("createuserid").asText();
+        String name = rootNode.get("name").asText();
+
+        // 拆分 ORG 字段
+        String[] orgArray = org.split(",");
+        List<JtXmkh> dataList = new ArrayList<>();
+        for (String orgValue : orgArray) {
+            JtXmkh jtXmkh = new JtXmkh();
+            jtXmkh.setYear(year);
+            jtXmkh.setGldw(gldw);
+            jtXmkh.setOrgid(orgValue);
+            jtXmkh.setReportstatus(reportStatus);
+            jtXmkh.setProcessstatus(processStatus);
+            jtXmkh.setId(SecurityUtil.getUUID());
+            jtXmkh.setDeleted(deleted);
+            jtXmkh.setCreateuserid(createuserid);
+            jtXmkh.setCreateusername(name);
+            jtXmkh.setCreatedate(new Date());
+            dataList.add(jtXmkh);
+        }
+        jtXmkhService.saveBatch(dataList);
+        return R.ok("保存成功");
+    }
 }

+ 62 - 0
jsglkh-common/src/main/resources/mybatis/sys/BusinessCommonMapper.xml

@@ -79,4 +79,66 @@
         where MAINID = #{mainId}
           and XMMC = #{projectName}
     </update>
+    <update id="deletedAboutInfoByProjectNameJlxm">
+        UPDATE "jt_fjglxm"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_khxm"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_kcsjxm"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_gzdg"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_ztfaps"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_wyys"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_yjbhgl"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_kcsjxm"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_scsdl"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_wtbhgl"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_scbhgl"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_sjjdqd"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_sjbgqd"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_zdxmszmn"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName};
+        UPDATE "jt_xcjhqd"
+        SET DELETED = '1'
+        where MAINID = #{mainId}
+          and XMMC = #{projectName}
+    </update>
 </mapper>

+ 31 - 0
jsglkh-entity/src/main/java/com/rongwei/bsentity/domain/JtFjglxm.java

@@ -130,4 +130,35 @@ public class JtFjglxm extends BaseDo implements Serializable {
      */
     @TableField(value = "SYNCSTATE")
     private String syncstate;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "CREATEDATE")
+    private Date createdate;
+    /**
+     * 创建人
+     */
+    @TableField(value = "CREATEUSERNAME")
+    private String createusername;
+    /**
+     * 修改人
+     */
+    @TableField(value = "MODIFYUSERNAME")
+    private String modifyusername;
+    /**
+     * 修改时间
+     */
+    @TableField(value = "MODIFYDATE")
+    private Date modifydate;
+    /**
+     * 删除标识
+     */
+    @TableField(value = "DELETED")
+    private  String deleted;
+
+
+
+
+
 }

+ 12 - 0
jsglkh-entity/src/main/java/com/rongwei/bsentity/dto/CreatKhxmInfoVo.java

@@ -0,0 +1,12 @@
+package com.rongwei.bsentity.dto;
+
+import lombok.Data;
+
+/**
+ * 考核项目信息
+ * */
+@Data
+public class CreatKhxmInfoVo {
+    //新增数据 id
+    private String id;
+}

+ 4 - 0
jsglkh-server/src/main/java/com/rongwei/controller/BusinessCommonController.java

@@ -26,4 +26,8 @@ public class BusinessCommonController {
     public R deletedAboutInfoByProjectName(@RequestBody Map<String,String> projectNameMap){
         return businessCommonService.deletedAboutInfoByProjectName(projectNameMap);
     }
+    @PostMapping("/remove/project/jlxm")
+    public R deletedAboutInfoByProjectNameJlxm(@RequestBody Map<String,String> projectNameMap){
+        return businessCommonService.deletedAboutInfoByProjectNamJlxm(projectNameMap);
+    }
 }

+ 24 - 4
jsglkh-server/src/main/java/com/rongwei/controller/ExamineController.java

@@ -1,13 +1,14 @@
 package com.rongwei.controller;
 
 import com.rongwei.bscommon.sys.service.impl.ExamineServiceImpl;
+import com.rongwei.bsentity.dto.CreatKhxmInfoVo;
 import com.rongwei.rwcommon.base.R;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
 
 /**
  * ExamineController class
@@ -34,4 +35,23 @@ public class ExamineController {
                             @RequestParam(required = false) String khzbNum) {
         return examineService.calculateScore(id, khzbNum);
     }
+
+    /**
+     * 考核部门新建
+     */
+    @PostMapping("/addkhbm")
+    public R addkhbm(@RequestBody Map<String, Object> jsonDatas) throws Exception {
+        return examineService.addkhbm(jsonDatas);
+    }
+
+
+    /**
+     * 考核项目新建
+     */
+    @PostMapping("/create/khbm")
+    public R createKhbm(@RequestBody List<Map<String, Object>> jsonDatas) {
+        return examineService.createKhbm(jsonDatas);
+    }
+
+
 }