From 17539021d35748ec5eb3fef1f677f221a95a34a8 Mon Sep 17 00:00:00 2001
From: zhaowenxuan <chacca165@163.com>
Date: 星期三, 26 三月 2025 17:46:40 +0800
Subject: [PATCH] 采样管理插入数据时判断项目是否存在

---
 ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java |   28 ++++++++++++++++++++--------
 1 files changed, 20 insertions(+), 8 deletions(-)

diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java
index 35765bb..2beedbf 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java
@@ -452,6 +452,8 @@
         if (null != detailList && detailList1) {
             String format = DateUtil.format(new Date(), "yyMMddHHmmssSSS");
             for (TjOrderDetail detail : detailList) {
+                int i = samplingService.isExistProId(order.getTjNumber(), String.valueOf(detail.getProId()));
+                if(i>0) continue;
                 TjSampling sampling = new TjSampling();
                 if (null == projectService.getById(detail.getProId())) continue;
                 TjProject project = projectService.getById(detail.getProId());
@@ -713,19 +715,27 @@
                         }
                 }
 
+                // 浣跨敤 stream 杩囨护鍑� proName 涓� "鑸掑紶鍘�" 鎴� "鏀剁缉鍘�" 鐨勫厓绱�
+                List<TjOrderDetail> filteredList = tjOrderDetailList.stream()
+                        .filter(a -> ("鑸掑紶鍘�".equals(a.getProName()) || "鏀剁缉鍘�".equals(a.getProName())) && a.getExceptionDesc()==1)
+                        .collect(Collectors.toList());
                 if(StrUtil.isNotBlank(ssyszys.toString())){
+
                     LambdaQueryWrapper<TjOrderYcxm> wq = new LambdaQueryWrapper<>();
                     wq.eq(TjOrderYcxm::getTjh, order.getTjNumber());
                     wq.like(TjOrderYcxm::getJcxm,"鑸掑紶鍘�");
                     ycxmService.remove(wq);
-                    TjOrderYcxm orderYcxm =new TjOrderYcxm();
-                    orderYcxm.setTjh(order.getTjNumber());
-                    orderYcxm.setParentName(tjProject.getProName());
-                    orderYcxm.setJcxm(ssyszys.toString().replaceFirst("/$", ""));
-                    orderYcxm.setJcjg(ssyszyjgs.toString().replaceFirst("/$", ""));
-                    orderYcxm.setJynr(JSONUtil.toJsonStr(jianyilis));
-                    orderYcxm.setJyjc("0");
-                    ycxmService.save(orderYcxm);
+
+                    if(!filteredList.isEmpty()){
+                        TjOrderYcxm orderYcxm =new TjOrderYcxm();
+                        orderYcxm.setTjh(order.getTjNumber());
+                        orderYcxm.setParentName(tjProject.getProName());
+                        orderYcxm.setJcxm(ssyszys.toString().replaceFirst("/$", ""));
+                        orderYcxm.setJcjg(ssyszyjgs.toString().replaceFirst("/$", ""));
+                        orderYcxm.setJynr(JSONUtil.toJsonStr(jianyilis));
+                        orderYcxm.setJyjc("0");
+                        ycxmService.save(orderYcxm);
+                    }
                 }
             }
         } catch (Exception e) {
@@ -932,6 +942,8 @@
             Date date = new Date();
             String format = DateUtil.format(date, "yyMMddHHmmssSSS");
             for (TjOrderDetail detail : detailList) {
+                int i = samplingService.isExistProId(order.getTjNumber(), String.valueOf(detail.getProId()));
+                if(i>0) continue;
                 TjSampling sampling = new TjSampling();
                 if (null == projectService.getById(detail.getProId())) continue;
                 TjProject project = projectService.getById(detail.getProId());

--
Gitblit v1.8.0