Merge remote-tracking branch 'origin/master'

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

@@ -538,25 +538,36 @@ public class ExamineServiceImpl implements ExamineService {
         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());
-            jtXmkh.setProcessstatus("审批通过");
-            dataList.add(jtXmkh);
+        //根据year   gldw    和org  在表 jt_xmkh中查询数据是否已经存在 已经存在的数据不需要重复生产
+
+            // 拆分 ORG 字段
+            String[] orgArray = org.split(",");
+            List<JtXmkh> dataList = new ArrayList<>();
+            for (String orgValue : orgArray) {
+                JtXmkh jtXmkh1 = jtXmkhService.getOne(new LambdaQueryWrapper<JtXmkh>()
+                        .eq(JtXmkh::getYear, year)
+                        .eq(JtXmkh::getGldw, gldw)
+                        .eq(JtXmkh::getOrgid, orgValue)
+                        .eq(JtXmkh::getDeleted, "0"));
+                if (jtXmkh1 == null) {
+                    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());
+                    jtXmkh.setProcessstatus("审批通过");
+                    dataList.add(jtXmkh);
+                }
+            }
+        if (dataList.size() > 0) {
+            jtXmkhService.saveBatch(dataList);
         }
-        jtXmkhService.saveBatch(dataList);
         return R.ok("保存成功");
     }
 }