From e7462c51a1b2718dc27a722953d4e7ac596ae322 Mon Sep 17 00:00:00 2001
From: zhuo <2089219845@qq.com>
Date: 星期一, 31 三月 2025 08:49:03 +0800
Subject: [PATCH] 质量监督记录添加默认值

---
 inspect-server/src/main/java/com/ruoyi/inspect/service/impl/InsOrderPlanServiceImpl.java |  211 ++++++++++++++++++++++++++++++++++++----------------
 1 files changed, 145 insertions(+), 66 deletions(-)

diff --git a/inspect-server/src/main/java/com/ruoyi/inspect/service/impl/InsOrderPlanServiceImpl.java b/inspect-server/src/main/java/com/ruoyi/inspect/service/impl/InsOrderPlanServiceImpl.java
index d69da06..9198f79 100644
--- a/inspect-server/src/main/java/com/ruoyi/inspect/service/impl/InsOrderPlanServiceImpl.java
+++ b/inspect-server/src/main/java/com/ruoyi/inspect/service/impl/InsOrderPlanServiceImpl.java
@@ -72,6 +72,7 @@
 import java.math.RoundingMode;
 import java.nio.file.Files;
 import java.nio.file.Paths;
+import java.text.DecimalFormat;
 import java.text.SimpleDateFormat;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
@@ -158,6 +159,11 @@
     private ISysDictTypeService iSysDictTypeService;
     @Resource
     private InsOrderRatesService insOrderRatesService;
+    @Resource
+    private InsProductDeviationWarningService insProductDeviationWarningService;
+    @Resource
+    private InsProductDeviationWarningDetailService insProductDeviationWarningDetailService;
+
 
     @Override
     public IPage<InsOrderPlanVO> selectInsOrderPlanList(Page page, InsOrderPlanDTO insOrderPlanDTO) {
@@ -522,55 +528,60 @@
 
         // 娣诲姞璁惧璁板綍
         threadPoolTaskExecutor.execute(() -> {
-            InsOrder order = insOrderMapper.selectById(insSample.getInsOrderId());
-            User user = userMapper.selectById(userId);
-            // 鏌ヨ璁惧浣跨敤璁板綍鏌ヨ璇ヨ鍗曠殑浣跨敤璁板綍
-            List<InsOrderDeviceRecordDto> deviceRecordDtoList = insOrderDeviceRecordMapper.selectDeviceNumber(insSample.getInsOrderId());
-            Set<String> recordCodeset = deviceRecordDtoList.stream().map(InsOrderDeviceRecordDto::getManagementNumber).collect(Collectors.toSet());
+            // 娣诲姞璁惧浣跨敤璁板綍
+            addDeviceRecord(insSample, userId);
+        });
+    }
 
-            // 鑾峰彇璁㈠崟璁惧缂栧彿
-            List<InsProductResult> resultList = insProductResultMapper.selectResultByOrderId(insSample.getInsOrderId());
-            Set<String> deviceCodeSet = new HashSet<>();
-            for (InsProductResult result : resultList) {
-                // 娣诲姞璁惧缂栧彿
-                List<JSONObject> jsonObjects = JSON.parseArray(result.getEquipValue(), JSONObject.class);
-                for (JSONObject jsonObject : jsonObjects) {
-                    if (!"".equals(jsonObject.get("v") + "")) {
-                        List<String> v = StrUtil.split(jsonObject.get("v") + "", "锛�");
-                        deviceCodeSet.addAll(v);
-                    }
+    private synchronized void addDeviceRecord(InsSample insSample, Integer userId) {
+        InsOrder order = insOrderMapper.selectById(insSample.getInsOrderId());
+        User user = userMapper.selectById(userId);
+        // 鏌ヨ璁惧浣跨敤璁板綍鏌ヨ璇ヨ鍗曠殑浣跨敤璁板綍
+        List<InsOrderDeviceRecordDto> deviceRecordDtoList = insOrderDeviceRecordMapper.selectDeviceNumber(insSample.getInsOrderId());
+        Set<String> recordCodeset = deviceRecordDtoList.stream().map(InsOrderDeviceRecordDto::getManagementNumber).collect(Collectors.toSet());
+
+        // 鑾峰彇璁㈠崟璁惧缂栧彿
+        List<InsProductResult> resultList = insProductResultMapper.selectResultByOrderId(insSample.getInsOrderId());
+        Set<String> deviceCodeSet = new HashSet<>();
+        for (InsProductResult result : resultList) {
+            // 娣诲姞璁惧缂栧彿
+            List<JSONObject> jsonObjects = JSON.parseArray(result.getEquipValue(), JSONObject.class);
+            for (JSONObject jsonObject : jsonObjects) {
+                if (!"".equals(jsonObject.get("v") + "")) {
+                    List<String> v = StrUtil.split(jsonObject.get("v") + "", "锛�");
+                    deviceCodeSet.addAll(v);
                 }
             }
-            // 1.鍒ゆ柇鏄惁鏈夋病鏈夋坊鍔犵殑浣跨敤璁板綍
-            Set<String> orderDeviceNumbers = getDeviceDifference(deviceCodeSet, recordCodeset);
-            // 娣诲姞浣跨敤璁板綍, 鏍规嵁缂栧彿鏌ヨ璁惧id
-            if (CollectionUtils.isNotEmpty(orderDeviceNumbers)) {
-                List<Integer> orderDeviceIds = insOrderDeviceRecordMapper.selectDeviceIdsByNumbers(orderDeviceNumbers);
-                List<InsOrderDeviceRecord> collect = orderDeviceIds.stream().map(deviceId -> {
-                    InsOrderDeviceRecord insOrderDeviceRecord = new InsOrderDeviceRecord();
-                    insOrderDeviceRecord.setInsOrderId(insSample.getInsOrderId());
-                    insOrderDeviceRecord.setDeviceId(deviceId);
-                    insOrderDeviceRecord.setSampleCode(order.getEntrustCode());
-                    insOrderDeviceRecord.setUseBefore(1);
-                    insOrderDeviceRecord.setUseAfter(1);
-                    insOrderDeviceRecord.setUsePerson(user.getName());
-                    insOrderDeviceRecord.setUsePersonId(user.getId());
-                    return insOrderDeviceRecord;
-                }).collect(Collectors.toList());
+        }
+        // 1.鍒ゆ柇鏄惁鏈夋病鏈夋坊鍔犵殑浣跨敤璁板綍
+        Set<String> orderDeviceNumbers = getDeviceDifference(deviceCodeSet, recordCodeset);
+        // 娣诲姞浣跨敤璁板綍, 鏍规嵁缂栧彿鏌ヨ璁惧id
+        if (CollectionUtils.isNotEmpty(orderDeviceNumbers)) {
+            List<Integer> orderDeviceIds = insOrderDeviceRecordMapper.selectDeviceIdsByNumbers(orderDeviceNumbers);
+            List<InsOrderDeviceRecord> collect = orderDeviceIds.stream().map(deviceId -> {
+                InsOrderDeviceRecord insOrderDeviceRecord = new InsOrderDeviceRecord();
+                insOrderDeviceRecord.setInsOrderId(insSample.getInsOrderId());
+                insOrderDeviceRecord.setDeviceId(deviceId);
+                insOrderDeviceRecord.setSampleCode(order.getEntrustCode());
+                insOrderDeviceRecord.setUseBefore(1);
+                insOrderDeviceRecord.setUseAfter(1);
+                insOrderDeviceRecord.setUsePerson(user.getName());
+                insOrderDeviceRecord.setUsePersonId(user.getId());
+                return insOrderDeviceRecord;
+            }).collect(Collectors.toList());
 
-                insOrderDeviceRecordService.saveBatch(collect);
+            insOrderDeviceRecordService.saveBatch(collect);
 
-            }
+        }
 
-            // 2.鍒ゆ柇鏄惁鍙栨秷浜嗚澶囦娇鐢�
-            Set<String> repoprNumbers = getDeviceDifference(recordCodeset, deviceCodeSet);
-            if (CollectionUtils.isNotEmpty(repoprNumbers)) {
-                List<Integer> reportDeviceIds = insOrderDeviceRecordMapper.selectDeviceIdsByNumbers(repoprNumbers);
-                insOrderDeviceRecordMapper.delete(Wrappers.<InsOrderDeviceRecord>lambdaQuery()
-                        .in(InsOrderDeviceRecord::getDeviceId, reportDeviceIds)
-                        .eq(InsOrderDeviceRecord::getInsOrderId, insSample.getInsOrderId()));
-            }
-        });
+        // 2.鍒ゆ柇鏄惁鍙栨秷浜嗚澶囦娇鐢�
+        Set<String> repoprNumbers = getDeviceDifference(recordCodeset, deviceCodeSet);
+        if (CollectionUtils.isNotEmpty(repoprNumbers)) {
+            List<Integer> reportDeviceIds = insOrderDeviceRecordMapper.selectDeviceIdsByNumbers(repoprNumbers);
+            insOrderDeviceRecordMapper.delete(Wrappers.<InsOrderDeviceRecord>lambdaQuery()
+                    .in(InsOrderDeviceRecord::getDeviceId, reportDeviceIds)
+                    .eq(InsOrderDeviceRecord::getInsOrderId, insSample.getInsOrderId()));
+        }
     }
 
     private static Set<String> getDeviceDifference(Set<String> number1, Set<String> number2) {
@@ -669,7 +680,7 @@
     }
 
     /**
-     * todo: 娓呴櫎娌℃湁浣跨敤鐨勬楠岄」
+     * todo: 鍘熷璁板綍妯℃澘娓呴櫎娌℃湁浣跨敤鐨勬楠岄」(鏆傛椂鏈塨ug鏃犳硶浣跨敤)
      * @param sheet
      * @param itemNameList
      */
@@ -942,23 +953,10 @@
 
             // 16 鍒ゆ柇褰撳墠鏍峰搧鏄惁涓哄師鏉愭枡, 鍘熸潗鏂欓渶瑕佽繘琛屾暟鎹垎鏋�, 鍒ゆ柇涔嬪墠10鏉℃暟鎹悓涓�涓緵搴斿晢, 鍚屼竴涓楠岄」鐨勫亸宸槸鍚﹁秴杩�10%
             // 鏌ヨifs淇℃伅鑾峰彇鑾峰彇鍓�10涓緵搴斿晢涓�鏍风殑, 妫�楠岄」涓�鏍蜂俊鎭�
-//            threadPoolTaskExecutor.execute(() -> {
-//
-//                for (InsProduct insProduct : productList) {
-//                    // todo: 鏆傛椂鍒ゆ柇鏄惁鏄�佸寲
-//                    if (insProduct.getInspectionItem().contains("鑰佸寲")) {
-//                        List<InsProductAnalysisDto> insProductAnalysisDtoList = insProductMapper.selectAnalysis(insProduct, ifsInventoryQuantity.getSupplierName());
-//
-//                        // 鍒ゆ柇褰撳墠妫�娴嬮」鏄惁鍋忓樊瓒呰繃10%
-//                        List<String> laseValueList = insProductAnalysisDtoList.stream().map(InsProductAnalysisDto::getLastValue)
-//                                .collect(Collectors.toList());
-//
-//
-//
-//
-//                    }
-//                }
-//            });
+            threadPoolTaskExecutor.execute(() -> {
+                // 娣诲姞鍒嗘瀽鏁版嵁
+                addAnalysis(productList, ifsInventoryQuantity, order);
+            });
 
 
         } else {
@@ -980,6 +978,88 @@
     }
 
     /**
+     * *****娣诲姞鍒嗘瀽鏁版嵁******
+     * @param productList
+     * @param ifsInventoryQuantity
+     * @param order
+     */
+    private void addAnalysis(List<InsProduct> productList, IfsInventoryQuantity ifsInventoryQuantity, InsOrder order) {
+        for (InsProduct insProduct : productList) {
+            // todo: 鏆傛椂鍒ゆ柇鏄惁鏄�佸寲
+            if (insProduct.getInspectionItem().contains("鑰佸寲") && insProduct.getInsResult().equals(1)) {
+                List<InsProductDeviationWarningDetail> insProductAnalysisDtoList = insProductMapper.selectAnalysis(insProduct, ifsInventoryQuantity.getSupplierName());
+
+                if (insProductAnalysisDtoList.size() < 10) {
+                    continue;
+                }
+
+                // 鍒ゆ柇褰撳墠妫�娴嬮」鏄惁鍋忓樊瓒呰繃10%
+                List<String> laseValueList = insProductAnalysisDtoList.stream().map(InsProductDeviationWarningDetail::getTestValue)
+                        .collect(Collectors.toList());
+
+                double deviation = isDeviationOverTenPercent(laseValueList, insProduct.getLastValue());
+                // 鍒ゆ柇鍋忓樊鏄惁澶т簬10
+                if (deviation > 10) {
+                    // 鍒ゆ柇涔嬪墠鏄惁娣诲姞杩�, 娣诲姞杩囦笉闇�瑕佹坊鍔�
+                    long count = insProductDeviationWarningService.count(Wrappers.<InsProductDeviationWarning>lambdaQuery()
+                            .eq(InsProductDeviationWarning::getInsProductId, insProduct.getId()));
+                    if (count == 0L) {
+                        // 鍙戦�侀�氱煡, 骞朵笖娣诲姞鏁版嵁
+                        // 娣诲姞涓昏〃淇℃伅
+                        InsProductDeviationWarning deviationWarning = new InsProductDeviationWarning();
+                        deviationWarning.setInsOrderId(order.getId());
+                        deviationWarning.setInsSampleId(insProduct.getInsSampleId());
+                        deviationWarning.setInsProductId(insProduct.getId());
+                        deviationWarning.setEntrustCode(order.getEntrustCode());
+                        deviationWarning.setSampleCode(insProduct.getSampleCode());
+                        deviationWarning.setSupplierName(ifsInventoryQuantity.getSupplierName());
+                        deviationWarning.setDeviationValue(Double.toString(deviation));
+                        deviationWarning.setDetectionTime(insProduct.getUpdateTime());
+                        insProductDeviationWarningService.save(deviationWarning);
+
+                        // 娣诲姞璇︽儏鏁版嵁
+                        InsProductDeviationWarningDetail deviationWarningDetail = new InsProductDeviationWarningDetail();
+                        deviationWarningDetail.setInsOrderId(order.getId());
+                        deviationWarningDetail.setInsSampleId(insProduct.getInsSampleId());
+                        deviationWarningDetail.setInsProductId(insProduct.getId());
+                        deviationWarningDetail.setEntrustCode(order.getEntrustCode());
+                        deviationWarningDetail.setSampleCode(insProduct.getSampleCode());
+                        deviationWarningDetail.setSupplierName(ifsInventoryQuantity.getSupplierName());
+                        deviationWarningDetail.setTestValue(insProduct.getLastValue());
+                        deviationWarningDetail.setIsIssue(1);
+
+                        insProductAnalysisDtoList.add(deviationWarningDetail);
+
+                        // 娣诲姞id
+                        for (InsProductDeviationWarningDetail warningDetail : insProductAnalysisDtoList) {
+                            warningDetail.setDeviationWarningId(deviationWarning.getDeviationWarningId());
+                        }
+
+                        insProductDeviationWarningDetailService.saveBatch(insProductAnalysisDtoList);
+
+
+//                    String message = "";
+//                    message += "妫�楠屼换鍔″鏍搁�氱煡";
+//                    message += "\n鎻愪氦浜�: " + userName;
+//                    message += "\n濮旀墭缂栧彿: " + order.getEntrustCode();
+//                    message += "\n鏍峰搧鍚嶇О: " + insSample.getModel();
+//                    message += "\n瑙勬牸鍨嬪彿: " + order.getPartDetail();
+//                    if (ifsInventoryQuantity != null) {
+//                        message += "\n鎵规鍙�: " + ifsInventoryQuantity.getUpdateBatchNo();
+//                    }
+//                    //鍙戦�佷紒涓氬井淇℃秷鎭�氱煡  鎻愪氦澶嶆牳
+//                    try {
+//                        WxCpUtils.inform(sendUserAccount, message, null);
+//                    } catch (Exception e) {
+//                        throw new RuntimeException(e);
+//                    }
+                    }
+                }
+            }
+        }
+    }
+
+    /**
      * *****璁$畻鍋忓樊****
      * @param data
      * @param targetStr
@@ -998,7 +1078,10 @@
         double target = Double.parseDouble(targetStr);
         double deviationPercent = Math.abs(target - average) / average * 100;
 
-        return deviationPercent;
+        // 淇濈暀涓や綅灏忔暟
+        DecimalFormat df = new DecimalFormat("#.00");
+        String formatted = df.format(deviationPercent);
+        return Double.parseDouble(formatted);
     }
 
     /**
@@ -1953,10 +2036,6 @@
 
         ConfigureBuilder builder = Configure.builder();
         builder.useSpringEL(true);
-        // 鑾峰彇褰撳墠鏃堕棿
-        LocalDate currentDate = LocalDate.now();
-        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
-        String formattedDate = currentDate.format(formatter);
 
         InputStream inputStream = this.getClass().getResourceAsStream("/static/small-report-template.docx");
         XWPFTemplate template = XWPFTemplate.compile(inputStream, builder.build()).render(

--
Gitblit v1.9.3