From fc178515868eb2c443f781fd0253ac98f36540d5 Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期二, 20 五月 2025 11:42:08 +0800
Subject: [PATCH] 修改错误的通讯方式

---
 hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/RawGlassTask.java |   89 ++++++++++++++++++++++----------------------
 1 files changed, 44 insertions(+), 45 deletions(-)

diff --git a/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/RawGlassTask.java b/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/RawGlassTask.java
index 62d17e9..fc39593 100644
--- a/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/RawGlassTask.java
+++ b/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/RawGlassTask.java
@@ -17,8 +17,6 @@
 import com.mes.rawglassstation.service.RawGlassStorageStationService;
 import com.mes.rawglasstask.entity.RawGlassStorageTask;
 import com.mes.rawglasstask.service.RawGlassStorageTaskService;
-import com.mes.s7.entity.S7Data;
-import com.mes.s7.job.S7Job;
 import com.mes.uppattenusage.entity.UpPattenUsage;
 import com.mes.uppattenusage.entity.vo.UpPattenUsageVO;
 import com.mes.uppattenusage.mapper.UpPattenUsageMapper;
@@ -78,40 +76,39 @@
 
     @Scheduled(fixedDelay = 1000)
     public void rawStorageTask() throws Exception {
-
-        String requestWord = S7Job.S7DataWL1.getRequest().toString();
-        String confireWord = S7Job.S7DataWL1.getConfirmation().toString();
-        String reportWord = S7Job.S7DataWL1.getReportWord().toString();
-        String taskWord = S7Job.S7DataWL1.getTaskWord().toString();
-
-//        ReadWriteEntity requestWord = miloService.readFromOpcUa("CC.CC.request");
-//        ReadWriteEntity confireWord = miloService.readFromOpcUa("CC.CC.confirmation");
-//        ReadWriteEntity reportWord = miloService.readFromOpcUa("CC.CC.reportWord");
-//        ReadWriteEntity taskWord = miloService.readFromOpcUa("CC.CC.taskWord");
-        String requestValue = requestWord;
-//        String requestValue = requestWord.getValue() + "";
+//        S7Data S7DataWL1 = s7Serializer.read(S7Data.class);
+//        String requestWord = S7DataWL1.getRequest().toString();
+//        String confireWord = S7DataWL1.getConfirmation().toString();
+//        String reportWord = S7DataWL1.getReportWord().toString();
+//        String taskWord = S7DataWL1.getTaskWord().toString();
+//        String requestValue = requestWord;
+        ReadWriteEntity requestWord = miloService.readFromOpcUa("CC.CC.request");
+        ReadWriteEntity confireWord = miloService.readFromOpcUa("CC.CC.confirmation");
+        ReadWriteEntity reportWord = miloService.readFromOpcUa("CC.CC.reportWord");
+        ReadWriteEntity taskWord = miloService.readFromOpcUa("CC.CC.taskWord");
+        String requestValue = requestWord.getValue() + "";
         if ("0".equals(requestValue)) {
             if ("1".equals(confireWord) && "0".equals(reportWord)) {
 //            if ("1".equals(confireWord.getValue() + "") && "0".equals(reportWord.getValue() + "")) {
-                S7Data s7Data=new S7Data();
-                s7Data.setConfirmation((short)0);
-                s7Serializer.write(s7Data);
-//                List<ReadWriteEntity> list = new ArrayList<>();
-//                list.add(generateReadWriteEntity("CC.CC.confirmation", 0));
-//                miloService.writeToOpcWord(list);
+//                S7Data s7Data = new S7Data();
+//                s7Data.setConfirmation((short) 0);
+//                s7Serializer.write(s7Data);
+                List<ReadWriteEntity> list = new ArrayList<>();
+                list.add(generateReadWriteEntity("CC.CC.confirmation", 0));
+                miloService.writeToOpcWord(list);
             }
-            if ("1".equals(taskWord)) {
-//          if ("1".equals(taskWord.getValue() + "")) {
-                S7Data s7Data=new S7Data();
-                s7Data.setTaskWord((short)0);
-                s7Data.setStartSlot((short)0);
-                s7Data.setEndSlot((short)0);
-                s7Serializer.write(s7Data);
-//                List<ReadWriteEntity> list = new ArrayList<>();
-//                list.add(generateReadWriteEntity("CC.CC.taskWord", 0));
-//                list.add(generateReadWriteEntity("CC.CC.startSlot", 0));
-//                list.add(generateReadWriteEntity("CC.CC.endSlot", 0));
-//                miloService.writeToOpcWord(list);
+//            if ("1".equals(taskWord)) {
+          if ("1".equals(taskWord.getValue() + "")) {
+//                S7Data s7Data = new S7Data();
+//                s7Data.setTaskWord((short) 0);
+//                s7Data.setStartSlot((short) 0);
+//                s7Data.setEndSlot((short) 0);
+//                s7Serializer.write(s7Data);
+                List<ReadWriteEntity> list = new ArrayList<>();
+                list.add(generateReadWriteEntity("CC.CC.taskWord", 0));
+                list.add(generateReadWriteEntity("CC.CC.startSlot", 0));
+                list.add(generateReadWriteEntity("CC.CC.endSlot", 0));
+                miloService.writeToOpcWord(list);
             }
             return;
         }
@@ -151,9 +148,10 @@
 
     @Scheduled(fixedDelay = 1000)
     public void rawStorageInCar() throws Exception {
-        String value = S7Job.S7DataWL1.getInCar().toString();
-//        ReadWriteEntity entity = miloService.readFromOpcUa("CC.CC.inCar");
-//        String value = entity.getValue() + "";
+//        S7Data S7DataWL1 = s7Serializer.read(S7Data.class);
+//        String value = S7DataWL1.getInCar().toString();
+        ReadWriteEntity entity = miloService.readFromOpcUa("CC.CC.inCar");
+        String value = entity.getValue() + "";
         if (!"1".equals(value)) {
             log.info("澶ц溅涓婃病鏈夋灦瀛�");
             return;
@@ -171,9 +169,10 @@
 
     @Scheduled(fixedDelay = 1000)
     public void rawStorageFinish() throws Exception {
-        String value = S7Job.S7DataWL1.getReportWord().toString();
-//        ReadWriteEntity entity = miloService.readFromOpcUa("CC.CC.reportWord");
-//        String value = entity.getValue() + "";
+//        S7Data S7DataWL1 = s7Serializer.read(S7Data.class);
+//        String value = S7DataWL1.getReportWord().toString();
+        ReadWriteEntity entity = miloService.readFromOpcUa("CC.CC.reportWord");
+        String value = entity.getValue() + "";
         if ("0".equals(value)) {
             log.info("褰撳墠浠诲姟鏈眹鎶ワ紝缁撴潫鏈浠诲姟");
             return;
@@ -236,12 +235,12 @@
                     .set(RawGlassStorageTask::getTaskState, Const.RAW_GLASS_TASK_FAILURE));
 
         }
-        S7Data s7Data=new S7Data();
-        s7Data.setConfirmation((short)1);
-        s7Serializer.write(s7Data);
-//        List<ReadWriteEntity> list = new ArrayList<>();
-//        list.add(generateReadWriteEntity("CC.CC.confirmation", 1));
-//        miloService.writeToOpcWord(list);
+//        S7Data s7Data = new S7Data();
+//        s7Data.setConfirmation((short) 1);
+//        s7Serializer.write(s7Data);
+        List<ReadWriteEntity> list = new ArrayList<>();
+        list.add(generateReadWriteEntity("CC.CC.confirmation", 1));
+        miloService.writeToOpcWord(list);
     }
 
     private boolean isHasRunningTask() {
@@ -434,7 +433,7 @@
         if (CollectionUtils.isEmpty(loadStationList)) {
             log.info("1鍙蜂笂鐗囦綅鐢熸垚璋冨害浠诲姟");
             RawGlassStorageDetails rawDetails = getRawGlassStorageDetailsBySize(usageVOS.get(0), usageVOS.size());
-            if(CollectionUtils.isEmpty(loadStationList)){
+            if (CollectionUtils.isEmpty(loadStationList)) {
                 log.info("浠撳簱鍐呮棤鍖归厤鐨勭幓鐠�");
                 return Boolean.FALSE;
             }

--
Gitblit v1.8.0