From 5762b0ef3e937042a21d4a19ddfee59207ea43f3 Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期五, 25 七月 2025 13:56:16 +0800
Subject: [PATCH] *

---
 src/main/java/com/zy/core/thread/SiemensCrnThread.java |   93 +++++++++++++++++++++++++++++++++++++---------
 1 files changed, 74 insertions(+), 19 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/SiemensCrnThread.java b/src/main/java/com/zy/core/thread/SiemensCrnThread.java
index 3b40137..7a69cef 100644
--- a/src/main/java/com/zy/core/thread/SiemensCrnThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensCrnThread.java
@@ -105,7 +105,7 @@
                     default:
                         break;
                 }
-                Thread.sleep(500);
+                Thread.sleep(200);
             } catch (Exception e) {
 //                e.printStackTrace();
             }
@@ -138,6 +138,12 @@
         crnProtocol.setyDistance((short) 0);
         crnProtocol.setxDuration((short) 0);
         crnProtocol.setyDuration((short) 0);
+        try{
+            CrnErrCache.updateCrnErr(crnProtocol.getCrnNo(), "绂荤嚎");
+        } catch (Exception e1){
+
+        }
+
     }
 
     @Override
@@ -204,10 +210,18 @@
                         if(crnProtocol.getTaskNo()==9999){
                             backHpFlag = false;
                         }
-                        CrnCommand crnCommand = new CrnCommand();
-                        crnCommand.setAckFinish((short)1);
-                        if (write(crnCommand)) {
-                            resetFlag = false;
+
+                        if (!Cools.isEmpty(crnProtocol.getLaneNo()) && crnProtocol.getLaneNo()!=0){
+                            CrnCommand crnCommand = new CrnCommand();
+                            crnCommand.setAckFinish((short)1);
+//                            crnCommand.setTaskNo(crnProtocol.getTaskNo());
+                            crnCommand.setLaneNo(crnProtocol.getLaneNo());
+                            crnCommand.setTaskMode(CrnTaskModeType.NONE); // 浠诲姟妯″紡
+                            if (write(crnCommand)) {
+                                resetFlag = false;
+                            }
+                        } else {
+                            CrnErrCache.updateCrnErr(crnProtocol.getCrnNo(), "宸烽亾鍙蜂负0");
                         }
                     }
                 }
@@ -268,21 +282,19 @@
             log.error("鍫嗗灈鏈哄啓鍏ュ懡浠や负绌�");
             return false;
         }
-        CrnErrCache.updateCrnErr(slave.getId(), "-");
         try{
             DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
-            deviceErrorService.addDeviceError("crnWrite", slave.getId(), "宸烽亾鍙�"+command.getLaneNo()+";鍫嗗灈鏈烘寚浠や笅鍙�:"+JSON.toJSONString(command.getNowTask()));
-        } catch (Exception e2){
+            deviceErrorService.addDeviceError("crnWriteIng", slave.getId(), "宸烽亾鍙�"+command.getLaneNo()+";鍫嗗灈鏈哄緟涓嬪彂鎸囦护:"+JSON.toJSONString(command.getNowTask()));
+        } catch (Exception e){
         }
+
         try{
-            BasErrLogService basErrLogService = SpringUtils.getBean(BasErrLogService.class);
-            BasErrLog basErrLog = new BasErrLog(command,"","闈炲紓甯革紝浠诲姟涓嬪彂璁板綍");
-            if (!basErrLogService.insert(basErrLog)) {
-                log.error("鍫嗗灈鏈簆lc寮傚父璁板綍澶辫触 ===>> [id:{}] [error:{}]", slave.getId(), "浠诲姟涓嬪彂璁板綍澶辫触");
-            }
-        } catch (Exception e3){
+            CrnErrCache.updateCrnErr(slave.getId(), "-");
+        } catch (Exception e){
+            log.error(JSON.toJSONString(e));
+            log.error("鍫嗗灈鏈轰换鍔″啓寮傚父锛氬紓甯稿畾浣嶅�硷細crnWrite-294琛�");
         }
-//        convertRow(command);
+
         command.setCrnNo(slave.getId());
         short[] array = new short[10];
         array[0] = command.getAckFinish();
@@ -294,8 +306,14 @@
         array[6] = command.getDestinationPosX();
         array[7] = command.getDestinationPosY();
         array[8] = command.getDestinationPosZ();
-        array[9] = command.getCommand();
+//        array[9] = command.getCommand();
+        array[9] = (short)0;
         OperateResult result18 = siemensNet.Write("DB100.18", (short)0);
+
+        if (command.getAckFinish() == 0) {
+            OperateResult result100 = siemensNet.Write("DB100.0", (short)0);
+        }
+
         try{
             Thread.sleep(50L);
         } catch (Exception e){}
@@ -308,11 +326,25 @@
             try{
                 Thread.sleep(100L);
             } catch (Exception e){}
-            OperateResultExOne<byte[]> resultRead = siemensNet.Read("DB101.0", (short) 4);
+            OperateResultExOne<byte[]> resultRead = siemensNet.Read("DB100.0", (short) 20);
             if (resultRead.IsSuccess) {
                 CrnCommand one = new CrnCommand();
                 one.setTaskNo(siemensNet.getByteTransform().TransInt16(resultRead.Content, 2));
+                one.setTaskMode(siemensNet.getByteTransform().TransInt16(resultRead.Content, 4));
+                one.setSourcePosX(siemensNet.getByteTransform().TransInt16(resultRead.Content, 6));
+                one.setSourcePosY(siemensNet.getByteTransform().TransInt16(resultRead.Content, 8));
+                one.setSourcePosZ(siemensNet.getByteTransform().TransInt16(resultRead.Content, 10));
+                one.setDestinationPosX(siemensNet.getByteTransform().TransInt16(resultRead.Content, 12));
+                one.setDestinationPosY(siemensNet.getByteTransform().TransInt16(resultRead.Content, 14));
+                one.setDestinationPosZ(siemensNet.getByteTransform().TransInt16(resultRead.Content, 16));
                 if (!command.getTaskNo().equals(one.getTaskNo())
+                        || !command.getTaskMode().equals(one.getTaskMode())
+                        || !command.getSourcePosX().equals(one.getSourcePosX())
+                        || !command.getSourcePosY().equals(one.getSourcePosY())
+                        || !command.getSourcePosZ().equals(one.getSourcePosZ())
+                        || !command.getDestinationPosX().equals(one.getDestinationPosX())
+                        || !command.getDestinationPosY().equals(one.getDestinationPosY())
+                        || !command.getDestinationPosZ().equals(one.getDestinationPosZ())
                 ){
                     i++;
                     CrnErrCache.updateCrnErr(slave.getId(), "鍫嗗灈鏈哄懡浠ゅ湴鍧�鍐欏叆鍚庡洖璇诲け璐�");
@@ -321,7 +353,7 @@
 
                     try{
                         DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
-                        deviceErrorService.addDeviceError("crnErr", slave.getId(), "宸烽亾鍙�"+command.getLaneNo()+";鍐欏叆娆℃暟"+i+";鍫嗗灈鏈哄懡浠ゅ湴鍧�鍐欏叆鍚庡洖璇诲け璐�:"+JSON.toJSONString(command.getNowTask()));
+                        deviceErrorService.addDeviceError("CrnErr", slave.getId(), "宸烽亾鍙�"+command.getLaneNo()+";鍐欏叆娆℃暟"+i+";鍫嗗灈鏈哄懡浠ゅ湴鍧�鍐欏叆鍚庡洖璇诲け璐�:"+JSON.toJSONString(command.getNowTask()));
                     } catch (Exception e2){
                     }
                     try{
@@ -334,6 +366,11 @@
                     }
                     result = siemensNet.Write("DB100.0", array);
                 }else{
+                    try{
+                        DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
+                        deviceErrorService.addDeviceError("crnWrite", slave.getId(), "宸烽亾鍙�"+command.getLaneNo()+";鍫嗗灈鏈烘寚浠や笅鍙�:"+JSON.toJSONString(command.getNowTask()));
+                    } catch (Exception e2){
+                    }
                     break;
                 }
             }
@@ -355,7 +392,7 @@
                     CrnErrCache.updateCrnErr(slave.getId(), "涓嬪彂DB100.18  鍥炶澶辫触");
                     try{
                         DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
-                        deviceErrorService.addDeviceError("crnErr", slave.getId(), "宸烽亾鍙�"+command.getLaneNo()+";鍐欏叆娆℃暟"+signFinish+";涓嬪彂DB100.18  鍥炶澶辫触:"+JSON.toJSONString(command.getNowTask()));
+                        deviceErrorService.addDeviceError("CrnErr", slave.getId(), "宸烽亾鍙�"+command.getLaneNo()+";鍐欏叆娆℃暟"+signFinish+";涓嬪彂DB100.18  鍥炶澶辫触:"+JSON.toJSONString(command.getNowTask()));
                     } catch (Exception e2){
                     }
                     try{
@@ -548,4 +585,22 @@
     public void setWrkSign() {
     }
 
+
+    /**
+     * 娓呴櫎浣滀笟鍚姩涓�
+     */
+    @Override
+    public void setResetFlag(boolean flag) {
+        this.resetFlag = flag;
+    }
+
+
+    /**
+     * 娓呴櫎浣滀笟鍚姩涓�
+     */
+    @Override
+    public boolean getResetFlag() {
+        return resetFlag;
+    }
+
 }

--
Gitblit v1.9.1