From c2e92c3bd4fc134b27ba6a6271f63b032b2b9d99 Mon Sep 17 00:00:00 2001
From: admin <15939171744@163.com>
Date: 星期三, 28 八月 2024 15:46:32 +0800
Subject: [PATCH] -打印bug修改

---
 jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java |   16 ++++++++++++----
 1 files changed, 12 insertions(+), 4 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 52af3ee..e15299d 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
@@ -17,6 +17,7 @@
 import com.jcdm.common.utils.DateUtils;
 import com.jcdm.common.utils.SecurityUtils;
 import com.jcdm.common.utils.StringUtils;
+import com.jcdm.framework.websocket.WebSocketUsers;
 import com.jcdm.main.bs.formula.service.IBsFormulaInfoService;
 import com.jcdm.main.bs.formula.service.impl.BsFormulaInfoServiceImpl;
 import com.jcdm.main.bs.formulaChild.domain.BsFormulaChildInfo;
@@ -53,6 +54,7 @@
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
+import javax.websocket.Session;
 import java.text.SimpleDateFormat;
 import java.time.Instant;
 import java.util.*;
@@ -108,6 +110,9 @@
     private IDaPassingStationCollectionService daPassingStationCollectionService;
 
     public SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+    Map<String, Session> map = WebSocketUsers.getUsers();
+
 
     /**
      * 鏌ヨ璁惧浜у搧杩囩▼鍙傛暟閲囬泦
@@ -672,10 +677,10 @@
 //        String url = "https://imes-uat-group.geelycv-test.com/api/mom-open/restful/aMesSysIntegration/deviceResultFeedback";
         try{
             daParamCollection.setWeightValue(getRandomNumberBetween(312.5, 313.5));
-//            Object recordDataDone = miloService.readFromOpcUa("PACK" + "." + daParamCollection.getLocationCode() + ".MStepNumber").getValue();
-//            if(ObjectUtil.isNotNull(recordDataDone)){
-//                daParamCollection.setWeightValue(recordDataDone.toString());
-//            }
+            Object recordDataDone = miloService.readFromOpcUa("PACK" + "." + daParamCollection.getLocationCode() + ".weight").getValue();
+            if(ObjectUtil.isNotNull(recordDataDone)){
+                daParamCollection.setWeightValue(recordDataDone.toString());
+            }
             long timestampMillis = Instant.now().toEpochMilli();
             ParentVO parentVO = new ParentVO();
             ChildVO childVO = new ChildVO();
@@ -703,14 +708,17 @@
                 String resultCode = jsonObject.getJSONObject("data").getStr("resultCode");
                 if("success".equals(code)&&"S".equals(resultCode)){
                     //濡傛灉鎴愬姛锛屾墽琛屾姤宸ユ垚鍔熸柟娉曪紝淇敼鏄惁鎶ュ伐涓�1锛屾坊鍔犳姤宸ユ椂闂�
+                    WebSocketUsers.sendMessageToUserByText(map.get("POP430"), "reportSuccess");
                     omProductionOrdeInfoService.updateOrderByProductNum("1",daParamCollection.getProductBarcode(),"POP430");
                 }else{
+                    WebSocketUsers.sendMessageToUserByText(map.get("POP430"), "reportError");
                     //瑙f瀽宸ュ巶mes杩斿洖缁撴灉锛屽鏋滃け璐ワ紝鎵ц鎶ュ伐澶辫触鏂规硶锛屼慨鏀规槸鍚︽姤宸ヤ负2锛屾坊鍔犳姤宸ユ椂闂�
                     omProductionOrdeInfoService.updateOrderByProductNum("2",daParamCollection.getProductBarcode(),"POP430");
                 }
                 logger.info("OP430鎶ュ伐缁撴潫-宸ュ巶MES寮傛鏂规硶{}"+reportResult);
             });
         }catch (Exception e){
+            WebSocketUsers.sendMessageToUserByText(map.get("POP430"), "reportError");
             System.out.println(e.getMessage());
         }
 //        HttpResponse execute = HttpRequest.post(url).body(JSONUtil.toJsonStr(parentVO)).execute();

--
Gitblit v1.9.3