From 1035e4729e03c10138adfcf4b6788b24778e9469 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期四, 10 八月 2023 16:39:21 +0800
Subject: [PATCH] 日志

---
 src/main/java/com/zy/core/thread/SiemensDevpThread.java |   19 ++++++++++---------
 1 files changed, 10 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index 6f43d73..b04861f 100644
--- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -10,9 +10,11 @@
 import com.core.common.SpringUtils;
 import com.zy.asrs.entity.BasDevp;
 import com.zy.asrs.entity.CommandInfo;
+import com.zy.asrs.entity.TaskWrk;
 import com.zy.asrs.service.BasDevpService;
 import com.zy.asrs.service.CommandInfoService;
 import com.zy.asrs.service.DeviceErrorService;
+import com.zy.asrs.service.TaskWrkService;
 import com.zy.core.DevpThread;
 import com.zy.core.cache.MessageQueue;
 import com.zy.core.cache.OutputQueue;
@@ -250,15 +252,6 @@
         array[1] = staProtocol.getStaNo();
 //        OperateResult write = siemensS7Net.Write("DB100." + index*4, array);
 
-        CommandInfoService commandInfoService = SpringUtils.getBean(CommandInfoService.class);
-        CommandInfo commandInfo = new CommandInfo();
-        commandInfo.setWrkNo(staProtocol.getWorkNo().intValue());
-        commandInfo.setCommandStatus(1);
-        commandInfo.setStartTime(new Date());
-        commandInfo.setDevice("devp");
-        commandInfo.setCommand(JSON.toJSONString(staProtocol));
-        commandInfoService.insert(commandInfo);
-
         OperateResult writeResult;
         //浠诲姟涓嬪彂娆℃暟
         int writeCount = 0;
@@ -320,6 +313,14 @@
             if ((siteId == 101 || siteId == 201)&&(staProtocol.getWorkNo() == 0 && staProtocol.getStaNo() ==0)) {
                 staProtocol.setPakMk(true);
             }
+
+            //鏇存柊浠诲姟姝ュ簭
+            TaskWrkService taskWrkService = SpringUtils.getBean(TaskWrkService.class);
+            TaskWrk taskWrk = taskWrkService.selectByWrkNo(staProtocol.getWorkNo().intValue());
+            if (taskWrk != null) {
+                taskWrk.setCommandStep(taskWrk.getCommandStep() + 1);//鏇存柊鎸囦护姝ュ簭
+                taskWrkService.updateById(taskWrk);
+            }
         }
 
     }

--
Gitblit v1.9.1