From c5e9c5922da7de2bf6df6dce42e7162dbe5cdd2d Mon Sep 17 00:00:00 2001
From: 懒羊羊 <15939171744@163.com>
Date: 星期五, 12 四月 2024 13:21:26 +0800
Subject: [PATCH] -

---
 jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java |   21 ++++++++++++++++++---
 1 files changed, 18 insertions(+), 3 deletions(-)

diff --git a/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java b/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
index 7570daa..25de3cd 100644
--- a/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
+++ b/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
@@ -12,6 +12,7 @@
 import com.jcdm.main.da.passingStationCollection.domain.DaPassingStationCollection;
 import com.jcdm.main.da.passingStationCollection.service.IDaPassingStationCollectionService;
 import com.jcdm.main.plcserver.conf.OPCElement;
+import com.jcdm.main.plcserver.util.TimeUtil;
 import com.kangaroohy.milo.model.ReadWriteEntity;
 import com.kangaroohy.milo.runner.subscription.SubscriptionCallback;
 import com.kangaroohy.milo.service.MiloService;
@@ -19,6 +20,7 @@
 import org.springframework.stereotype.Component;
 
 import javax.websocket.Session;
+import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -86,6 +88,8 @@
                     if("1".equals(tabVlaue)){
                         recordDataDoneValue = "11";
                         //鏍¢獙鍏ョ珯鏄惁鍙互宸ヤ綔
+
+                        //plc缁欐垜浠竴涓猵ack鐮侊紝鎷縫ack鐮佹牎楠屽嚭鍨嬪彿
 
                         //杩涚珯淇濆瓨鏁版嵁
 //                        inSaveDate(thoroughfare,device)
@@ -174,6 +178,7 @@
                 String workOrderNo = miloService.readFromOpcUa(thoroughfare + "." + device + "." + "WorkOrderNumber").getValue().toString();
                 String productCode = miloService.readFromOpcUa(thoroughfare + "." + device + "." + "ProductType").getValue().toString();
 
+
                 saveStationInfo(snCode,thoroughfare,device,workOrderNo,productCode);
                 //3銆佷繚瀛樺弬鏁伴噰闆嗘暟鎹�
                 SaveParamData(snCode,thoroughfare,device,workOrderNo,productCode);
@@ -223,6 +228,8 @@
      * 淇濆瓨杩囩珯閲囬泦
      */
     public void saveStationInfo(String packCode,String thoroughfare,String device,String workOrderNo,String productCode) throws Exception {
+        SimpleDateFormat sdf = new SimpleDateFormat("EEE MMM dd HH:mm:ss zzz yyyy", Locale.US);
+        sdf.setTimeZone(TimeZone.getTimeZone("GMT+8")); // CST閫氬父琛ㄧず涓浗鏍囧噯鏃堕棿锛屽嵆涓滃叓鍖�
         String prefix = thoroughfare+"."+device+".";
         String startTime = miloService.readFromOpcUa(prefix + "StartTime").getValue().toString();
         String stopTime = miloService.readFromOpcUa(prefix + "StopTime").getValue().toString();
@@ -233,8 +240,10 @@
         daPassingStationCollection.setWorkOrderNo(workOrderNo);
         daPassingStationCollection.setProductCode(productCode);
         daPassingStationCollection.setLocationCode(device);
-//        daPassingStationCollection.setInboundTime(startTime);//鍏ョ珯鏃堕棿
-//        daPassingStationCollection.setOutboundTime(stopTime);//鍑虹珯鏃堕棿
+        String strt = TimeUtil.stringProcessing(startTime);
+        String end = TimeUtil.stringProcessing(stopTime);
+        daPassingStationCollection.setInboundTime(sdf.parse(strt));//鍏ョ珯鏃堕棿
+        daPassingStationCollection.setOutboundTime(sdf.parse(end));//鍑虹珯鏃堕棿
         daPassingStationCollection.setOutRsSign(stationStatus);//鍑虹珯鏄惁鍚堟牸
         daPassingStationCollectionService.insertDaPassingStationCollection(daPassingStationCollection);
     }
@@ -255,10 +264,16 @@
             List<DaParamCollection> daParamCollectionlist = new ArrayList<>();
             for(int i=0;i<nodeIdList.size();i++){
                 if(!readWriteEntityList.get(i).getValue().toString().equals("0.0")){
+                    String tt = readWriteEntityList.get(i).getValue().toString();
                     DaParamCollection ParamCollection = new DaParamCollection();
                     ParamCollection.setParamCode(list.get(i).getCollectParameterId());
                     ParamCollection.setLocationCode(device);
-                    ParamCollection.setParamValue(readWriteEntityList.get(i).getValue().toString());
+                    if(tt.contains("Time")){
+                        String str = TimeUtil.getTimestamp(TimeUtil.stringProcessing(tt));
+                        ParamCollection.setParamValue(str);
+                    }else {
+                        ParamCollection.setParamValue(readWriteEntityList.get(i).getValue().toString());
+                    }
                     ParamCollection.setSfcCode(packCode);
                     ParamCollection.setParamName(list.get(i).getCollectParameterName());
                     ParamCollection.setParamUpper(list.get(i).getParamUpper());

--
Gitblit v1.9.3