From cb4e543d5e4236ad3fc95ff4ed21a4a1f683062e Mon Sep 17 00:00:00 2001
From: admin <15939171744@163.com>
Date: 星期二, 15 十月 2024 09:33:58 +0800
Subject: [PATCH] 优化

---
 jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java |  134 +++++++++++++++++++++++++-------------------
 1 files changed, 77 insertions(+), 57 deletions(-)

diff --git a/jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java b/jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java
index 0921ff4..41f8706 100644
--- a/jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java
+++ b/jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java
@@ -405,6 +405,35 @@
             daParamCollectionTempService.insertBatch(saveParamListTemp);
         }
     }
+
+    @Override
+    public void pushStartStopTime(String paramCode, String paramName, String productNum) {
+        ParentVO parentVO = new ParentVO();
+        parentVO.setSiteCode("3983");
+        parentVO.setRecordId(String.valueOf(Instant.now().toEpochMilli()));
+        parentVO.setStationCode("OP165");
+        parentVO.setProductNum(productNum);
+        parentVO.setTotalResult("1");
+        List<ChildVO> listChildVo = new ArrayList<>();
+        ChildVO childVO = new ChildVO();
+        childVO.setItemCode(paramCode);
+        childVO.setItemType("3");
+        childVO.setItemText(paramName);
+        childVO.setItemValue(format.format(new Date()));
+        childVO.setCheckResult("1");
+        childVO.setCheckTime(format.format(new Date()));
+        listChildVo.add(childVO);
+        parentVO.setCheckList(listChildVo);
+        try{
+            CompletableFuture<Void> cp1 = CompletableFuture.runAsync(() -> {
+                HttpResponse execute = HttpRequest.post(Constants.FACTORY_EMS_UAT_GET_RUL+"deviceResultFeedback").body(JSONUtil.toJsonStr(parentVO)).execute();
+                System.out.println(execute.body());
+            });
+        }catch (Exception e){
+            System.out.println(e.getMessage());
+        }
+    }
+
     @Override
     public void insertBatch(List<DaParamCollection> confList){
         try{
@@ -561,43 +590,32 @@
             for (DaParamCollectionTemp daParamCollection : paramList) {
                 ChildVO childVO = new ChildVO();
                 childVO.setItemCode(daParamCollection.getParamCode());
-//                BsFormulaChildInfo childOne = bsFormulaChildInfoService.getOne(new LambdaQueryWrapper<BsFormulaChildInfo>().eq(BsFormulaChildInfo::getParamCode, daParamCollection.getParamCode()));
-//                DaCollectionParamConf paramConfOne = daCollectionParamConfService.getOne(new LambdaQueryWrapper<DaCollectionParamConf>().eq(DaCollectionParamConf::getCollectParameterId, daParamCollection.getParamCode()));
                 List<DaCollectionParamConf> paramConfOneList = daCollectionParamConfService.list(new LambdaQueryWrapper<DaCollectionParamConf>()
                         .eq(DaCollectionParamConf::getCollectParameterId, daParamCollection.getParamCode())
                         .eq(DaCollectionParamConf::getProcessesCode,stationCode));
                 DaCollectionParamConf paramConfOne = paramConfOneList.get(0);
-//                if(childOne!=null){
-//                    String operationType = childOne.getOperationType();
-//                    if(operationType.equals("1")){
-//                        childVO.setItemType("2");
-//                    }else if(operationType.equals("2")){
-//                        childVO.setItemType("1");
-//                    }
-//                }else {
-//                    childVO.setItemType("3");
-//                }
-                if(paramConfOne!=null){
-                    childVO.setItemType(paramConfOne.getItemType());
-                    childVO.setItemText(paramConfOne.getCollectParameterName());
-                }else {
-                    childVO.setItemType("3");
-                    childVO.setItemText("");
-                }
-                childVO.setItemValue(daParamCollection.getParamValue());
+                if(!paramConfOneList.isEmpty()){
+                    if(paramConfOne!=null){
+                        childVO.setItemType(paramConfOne.getItemType());
+                        childVO.setItemText(paramConfOne.getCollectParameterName());
+                    }else {
+                        childVO.setItemType("3");
+                        childVO.setItemText("");
+                    }
+                    childVO.setItemValue(daParamCollection.getParamValue());
 
-                if(daParamCollection.getParamValue().equals("1")){
-                    childVO.setCheckResult("1");
-                }else if(daParamCollection.getParamValue().equals("2")){
-                    childVO.setCheckResult("0");
-                    parentVO.setTotalResult("0");
-                    totalResult = "1";
-                }else {
-                    childVO.setCheckResult("1");
+                    if(daParamCollection.getParamValue().equals("1")){
+                        childVO.setCheckResult("1");
+                    }else if(daParamCollection.getParamValue().equals("2")){
+                        childVO.setCheckResult("0");
+                        parentVO.setTotalResult("0");
+                        totalResult = "1";
+                    }else {
+                        childVO.setCheckResult("1");
+                    }
+                    childVO.setCheckTime(format.format(daParamCollection.getCollectionTime()));
+                    listChildVo.add(childVO);
                 }
-                childVO.setCheckTime(format.format(daParamCollection.getCollectionTime()));
-                listChildVo.add(childVO);
-
             }
             parentVO.setCheckList(listChildVo);
             try{
@@ -763,32 +781,34 @@
     @Override
     public void manualWorkstationsAddBasicParameters(DaParamCollection daParamCollection) {
         // 鍋囪杩欐槸浠庢暟鎹簱鎴栧叾浠栧湴鏂硅幏鍙栫殑鍙傛暟鏁版嵁
-        Map<String, String> map = new HashMap<>();
-        map.put("GC", "鍗楁禂宸ュ巶");
-        map.put("CXBH", "Pack绾�");
-        map.put("SBBH", "璁惧001");
-        map.put("YGBH", SecurityUtils.getUsername());
-        map.put("GDBH", daParamCollection.getWorkOrderNo());
-        map.put("CPXH", daParamCollection.getProductCode());
-        map.put("INT", format.format(daParamCollection.getInboundTime()));
-        map.put("OUTT",format.format(new Date()));
-
-        map.forEach((key, value) -> {
-            DaCollectionParamConf daCollectionParamConf = new DaCollectionParamConf();
-            daCollectionParamConf.setProcessesCode(daParamCollection.getLocationCode());
-            daCollectionParamConf.setCollectParameterId(key);
-            List<DaCollectionParamConf> daCollectionParamConfs = daCollectionParamConfMapper.selectDaCollectionParamConfList(daCollectionParamConf);
-            DaParamCollection saveData = new DaParamCollection();
-            saveData.setWorkOrderNo(daParamCollection.getWorkOrderNo());
-            saveData.setProductCode(daParamCollection.getProductCode());
-            saveData.setLocationCode(daParamCollection.getLocationCode());
-            saveData.setSfcCode(daParamCollection.getProductBarcode());
-            saveData.setParamCode(daCollectionParamConfs.get(0).getCollectParameterId());
-            saveData.setParamName(daCollectionParamConfs.get(0).getCollectParameterName());
-            saveData.setCollectionTime(new Date());
-            saveData.setParamValue(value);
-            daParamCollectionMapper.insertDaParamCollection(saveData);
-        });
+//        Map<String, String> map = new HashMap<>();
+//        map.put("GC", "鍗楁禂宸ュ巶");
+//        map.put("CXBH", "Pack绾�");
+//        map.put("SBBH", "璁惧001");
+//        map.put("YGBH", SecurityUtils.getUsername());
+//        map.put("GDBH", daParamCollection.getWorkOrderNo());
+//        map.put("CPXH", daParamCollection.getProductCode());
+//        map.put("INT", format.format(daParamCollection.getInboundTime()));
+//        map.put("OUTT",format.format(new Date()));
+//
+//        map.forEach((key, value) -> {
+//            DaCollectionParamConf daCollectionParamConf = new DaCollectionParamConf();
+//            daCollectionParamConf.setProcessesCode(daParamCollection.getLocationCode());
+//            daCollectionParamConf.setCollectParameterId(key);
+//            List<DaCollectionParamConf> daCollectionParamConfs = daCollectionParamConfMapper.selectDaCollectionParamConfList(daCollectionParamConf);
+//            DaParamCollection saveData = new DaParamCollection();
+//            saveData.setWorkOrderNo(daParamCollection.getWorkOrderNo());
+//            saveData.setProductCode(daParamCollection.getProductCode());
+//            saveData.setLocationCode(daParamCollection.getLocationCode());
+//            saveData.setSfcCode(daParamCollection.getProductBarcode());
+//            if(daCollectionParamConfs.isEmpty()){
+//                saveData.setParamCode(daCollectionParamConfs.get(0).getCollectParameterId());
+//                saveData.setParamName(daCollectionParamConfs.get(0).getCollectParameterName());
+//            }
+//            saveData.setCollectionTime(new Date());
+//            saveData.setParamValue(value);
+//            daParamCollectionMapper.insertDaParamCollection(saveData);
+//        });
     }
 
     @Override

--
Gitblit v1.9.3