From dbae31a7a7cd59048ada9b51fe8faff545324c59 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期五, 15 三月 2024 16:02:53 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/thread/SiemensCrnThread.java |  296 ++++++++++++++++++++++++++++++++++++-----------------------
 1 files changed, 181 insertions(+), 115 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/SiemensCrnThread.java b/src/main/java/com/zy/core/thread/SiemensCrnThread.java
index ccf1d69..a11b349 100644
--- a/src/main/java/com/zy/core/thread/SiemensCrnThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensCrnThread.java
@@ -106,6 +106,9 @@
                     case 4:
                         writeAuto((CrnCommand) task.getData());
                         break;
+                    case 5:
+                        write((CrnCommand) task.getData());
+                        break;
                     default:
                         break;
                 }
@@ -151,7 +154,7 @@
 //            deviceErrorService.addDeviceError("crn", slave.getId(), "鍫嗗灈鏈簆lc杩炴帴澶辫触");
             initCrnProtocol();
         }
-        siemensNet.ConnectClose();
+//        siemensNet.ConnectClose();
         return result;
     }
 
@@ -194,91 +197,15 @@
             // 澶嶄綅淇″彿
             if (crnProtocol.getTaskFinish() == 0) {
                 if (resetFlag) {
-                    //鍫嗗灈鏈轰换鍔″畬鎴愬悗璁块棶wms璇锋眰浠诲姟瀹屾垚 locationDone 璐т綅澶勭悊瀹屾垚
-                    TaskWrkService taskWrkService = SpringUtils.getBean(TaskWrkService.class);
-                    TaskWrk taskWrk = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("wrk_no",crnProtocol.getTaskNo()));
-                    String tasktype = null;
-                    switch (taskWrk.getIoType()){
-                        case 1:
-                            tasktype= "RK";
-                            break;
-                        case 2:
-                            tasktype= "CK";
-                            break;
-                        case 3:
-                            tasktype= "YK";
-                            break;
-                        default:
-                            tasktype= "鏈煡";
-                    }
-                    Map<String, Object> map = new HashMap<>();
-                    map.put("x-api-key","7a15b5db-29b6-552c-8cff-0cfec3756da2");
-                    TaskOverToWms taskOverToWms = new TaskOverToWms();
-                    taskOverToWms.setFeedbackFrom("WCS"); //鏉ユ簮
-                    taskOverToWms.setWarehouseId("1688469798893297665"); //浠撳簱鏍囪瘑
-                    taskOverToWms.setTaskNo(taskWrk.getTaskNo()); //浠诲姟鍙�
-                    taskOverToWms.setTaskType(tasktype); // 浠诲姟绫诲瀷
-                    taskOverToWms.setContainerCode(taskWrk.getBarcode()); // 瀹瑰櫒缂栫爜
-                    if (taskWrk.getIoType() ==1 || taskWrk.getIoType() == 3){
-                        taskOverToWms.setEquipmentCode(String.valueOf(taskWrk.getCrnNo())); //璁惧缂栫爜
-                        taskOverToWms.setTargetLocationCode(taskWrk.getOriginTargetPoint()); //鐩爣搴撲綅
-                    }else if (taskWrk.getIoType() ==2){
-                        Map<Integer,String> map1 = new HashMap<>();
-                        map1.put(102,"J-1101");
-                        map1.put(106,"J-1103");
-                        map1.put(110,"J-1105");
-                        map1.put(114,"J-1107");
-                        map1.put(118,"J-1109");
-                        map1.put(122,"J-1111");
-                        map1.put(305,"H-1101");
-                        map1.put(405,"G-1101");
-                        taskOverToWms.setEquipmentCode(map1.get(taskWrk.getTargetPoint())); //璁惧缂栫爜
-                        taskOverToWms.setSourceLocationCode(taskWrk.getOriginStartPoint()); //婧愬簱浣�
-                    }
-
-                    taskOverToWms.setTaskStatus("location_done"); //浠诲姟鐘舵��
-                    String response = null;
-                    try {
-                        response = new HttpHandler.Builder()
-                                .setHeaders(map)
-                                .setUri("10.32.53.195:8080")
-                                .setPath("wcsManager/wcsInterface/taskStatusFeedback")
-                                .setJson(JSON.toJSONString(taskOverToWms))
-                                .build()
-                                .doPost();
-                    }catch (Exception e){
-                       log.error("鍫嗗灈鏈轰换鍔″畬鎴愶紝璇锋眰wms浠诲姟瀹屾垚鎺ュ彛澶辫触");
-                    }
-                    ApiLogService apiLogService = SpringUtils.getBean(ApiLogService.class);
-                    apiLogService.save("Wms浠诲姟瀹屾垚鎺ュ彛"
-                            ,"10.32.53.195:8080"+"/wcsManager/wcsInterface/taskStatusFeedback"
-                            ,null
-                            ,"127.0.0.1"
-                            ,JSON.toJSONString(taskOverToWms)
-                            ,response
-                            ,true
-                    );
-                    JSONObject jsonObject = JSON.parseObject(response);
-                    if (jsonObject.getInteger("code").equals(200)){
-                        if (taskWrk.getIoType() == 3){
-                            taskWrk.setWrkSts(4);
-                        }
-                        taskWrk.setStatus(5);
-                        if (!taskWrkService.update(taskWrk,new EntityWrapper<TaskWrk>().eq("wrk_no",crnProtocol.getTaskNo()))){
-                            log.error("鍫嗗灈鏈轰换鍔″畬鎴愶紝鏀瑰彉浠诲姟鐘舵�佸け璐�");
-                        }
-
-                        log.info("鍫嗗灈鏈轰换鍔″畬鎴愶紝璇锋眰wms浠诲姟瀹屾垚鎺ュ彛鎴愬姛");
-                    }else {
-                        log.error("鍫嗗灈鏈轰换鍔″畬鎴愶紝璇锋眰wms浠诲姟瀹屾垚鎺ュ彛瀹屾垚锛屼絾杩斿洖澶辫触");
-                    }
-
-
                     CrnCommand crnCommand = new CrnCommand();
                     crnCommand.setAckFinish((short)1);
                     if (write(crnCommand)) {
                         resetFlag = false;
+
                     }
+
+
+
                 }
             }
 
@@ -311,6 +238,21 @@
             log.error("鍫嗗灈鏈哄啓鍏ュ懡浠や负绌�");
             return false;
         }
+        //杞崲鍓嶅厠闅嗕竴浠�
+        CrnCommand crnCommand = new CrnCommand();
+        crnCommand.setCrnNo(command.getCrnNo());
+        crnCommand.setAckFinish(command.getAckFinish());
+        crnCommand.setTaskNo(command.getTaskNo());
+        crnCommand.setTaskMode(command.getTaskMode());
+        crnCommand.setSourcePosX(command.getSourcePosX());
+        crnCommand.setSourcePosY(command.getSourcePosY());
+        crnCommand.setSourcePosZ(command.getSourcePosZ());
+        crnCommand.setDestinationPosX(command.getDestinationPosX());
+        crnCommand.setDestinationPosY(command.getDestinationPosY());
+        crnCommand.setDestinationPosZ(command.getDestinationPosZ());
+//        crnCommand.setSourceStaNo(command.getSourceStaNo());
+//        crnCommand.setDestinationStaNo(command.getDestinationStaNo());
+        crnCommand.setCommand(command.getCommand());
         if (command.getTaskNo() == 0 && command.getAckFinish() == 0 && command.getAuto() != 1) {
             command.setTaskNo((short) 9999);
         }
@@ -342,13 +284,13 @@
                     command.getCrnNo(),    // 鍫嗗灈鏈篬闈炵┖]
                     new Date(),    // 涓嬪彂鏃堕棿
                     command.getTaskModeType() == null ? null : command.getTaskModeType().toString(),    // 妯″紡
-                    command.getSourcePosX().intValue(),    // 婧愭帓
-                    command.getSourcePosY().intValue(),    // 婧愬垪
-                    command.getSourcePosZ().intValue(),    // 婧愬眰
+                    command.getSourcePosZ().intValue(),    // 婧愭帓
+                    command.getSourcePosX().intValue(),    // 婧愬垪
+                    command.getSourcePosY().intValue(),    // 婧愬眰
                     null,    // 婧愮珯
-                    command.getDestinationPosX().intValue(),    // 鐩爣鎺�
-                    command.getDestinationPosY().intValue(),    // 鐩爣鍒�
-                    command.getDestinationPosZ().intValue(),    // 鐩爣灞�
+                    command.getDestinationPosZ().intValue(),    // 鐩爣鎺�
+                    command.getDestinationPosX().intValue(),    // 鐩爣鍒�
+                    command.getDestinationPosY().intValue(),    // 鐩爣灞�
                     null,    // 鐩爣绔�
                     null,    // 鍝嶅簲缁撴灉
                     null,    // 淇敼鏃堕棿
@@ -358,24 +300,79 @@
         }
 
         if (result.IsSuccess) {
-            log.warn("鍫嗗灈鏈哄懡浠や笅鍙慬id:{},鏃堕棿锛歿}] >>>>> {}", slave.getId(), DateUtils.convert(new Date(), DateUtils.yyyyMMddHHmmsssss_F), JSON.toJSON(command));
-            OutputQueue.CRN.offer(MessageFormat.format("銆恵0}銆慬id:{1}] >>>>> 鍛戒护涓嬪彂锛� {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(command)));
-            return true;
+//            log.warn("鍫嗗灈鏈哄懡浠や笅鍙慬id:{},鏃堕棿锛歿}] >>>>> {}", slave.getId(), DateUtils.convert(new Date(), DateUtils.yyyyMMddHHmmsssss_F), JSON.toJSON(command));
+//            OutputQueue.CRN.offer(MessageFormat.format("銆恵0}銆慬id:{1}] >>>>> 鍛戒护涓嬪彂锛� {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(command)));
+//            return true;
         } else {
             OutputQueue.CRN.offer(MessageFormat.format("銆恵0}銆戝啓鍏ュ爢鍨涙満plc鏁版嵁澶辫触 ===>> [id:{1}] [ip:{2}] [port:{3}] [rack:{4}] [slot:{5}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot()));
             log.error("鍐欏叆鍫嗗灈鏈簆lc鏁版嵁澶辫触 ===>> [id:{}] [ip:{}] [port:{}] [rack:{}] [slot:{}]", slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot());
             return false;
         }
+
+
+        try{
+            //鍫嗗灈鏈轰换鍔″啓鍏ュ悗锛屽洖璇讳竴娆★紝鐪嬫槸鍚︽垚鍔�
+            Thread.sleep(500);
+            OperateResultExOne<byte[]> resultRead = siemensNet.Read("DB100.0", (short) 24);
+            if (resultRead.IsSuccess) {
+                CrnCommand one = new CrnCommand();
+                one.setAckFinish(siemensNet.getByteTransform().TransInt16(resultRead.Content, 0));
+                one.setTaskNo(siemensNet.getByteTransform().TransInt16(resultRead.Content, 2));
+                //one.setTaskMode(siemensNet.getByteTransform().TransInt16(resultRead.Content, 4));
+                one.setSourcePosZ(siemensNet.getByteTransform().TransInt16(resultRead.Content, 6));
+                one.setSourcePosX(siemensNet.getByteTransform().TransInt16(resultRead.Content, 8));
+                one.setSourcePosY(siemensNet.getByteTransform().TransInt16(resultRead.Content, 10));
+                one.setDestinationPosZ(siemensNet.getByteTransform().TransInt16(resultRead.Content, 12));
+                one.setDestinationPosX(siemensNet.getByteTransform().TransInt16(resultRead.Content, 14));
+                one.setDestinationPosY(siemensNet.getByteTransform().TransInt16(resultRead.Content, 16));
+//                one.setSourceStaNo(siemensNet.getByteTransform().TransInt16(resultRead.Content, 18));
+//                one.setDestinationStaNo(siemensNet.getByteTransform().TransInt16(resultRead.Content, 20));
+                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())
+
+                ){
+                    log.error("鍫嗗灈鏈哄懡浠ゅ湴鍧�鍐欏叆鍚庡洖璇诲け璐id:{}] >>>>> 鍐欏叆[{}],===>>鍥炶[{}]", slave.getId(), JSON.toJSON(command),JSON.toJSON(one));
+                    log.error("鍫嗗灈鏈哄懡浠ゅ洖璇诲け璐ュ悗锛岄噸鏂版坊鍔犱换鍔″埌闃熷垪 ===>> [id:{}],{}", slave.getId(), JSON.toJSON(crnCommand));
+                    MessageQueue.offer(SlaveType.Crn, slave.getId(), new Task(5, crnCommand));
+                    Thread.sleep(100);
+                    readStatus();
+                    return false;
+                } else {
+                    log.info("鍫嗗灈鏈哄懡浠ゅ湴鍧�鍐欏叆鍚庡洖璇绘垚鍔焄id:{}] >>>>> 鍐欏叆[{}],===>>鍥炶[{}]", slave.getId(), JSON.toJSON(command),JSON.toJSON(one));
+                    OutputQueue.CRN.offer(MessageFormat.format("銆恵0}銆慬id:{1}] >>>>> 鍛戒护涓嬪彂锛� {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(command)));
+                }
+            }
+        }catch (Exception e){
+            log.error("鍫嗗灈鏈哄懡浠ゅ湴鍧�鍐欏叆鍚庡洖璇诲嚭閿�");
+        }
+        return true;
     }
 
     /**
      * 鍐欏叆鏁版嵁
      */
-    private boolean write2(CrnCommand command){
+    private boolean write2(CrnCommand command) throws InterruptedException {
         if (null == command) {
             log.error("鍫嗗灈鏈哄啓鍏ュ懡浠や负绌�");
             return false;
         }
+        //杞崲鍓嶅厠闅嗕竴浠�
+        CrnCommand crnCommand = new CrnCommand();
+        crnCommand.setCrnNo(command.getCrnNo());
+        crnCommand.setAckFinish(command.getAckFinish());
+        crnCommand.setTaskNo(command.getTaskNo());
+        crnCommand.setTaskMode(command.getTaskMode());
+        crnCommand.setSourcePosX(command.getSourcePosX());
+        crnCommand.setSourcePosY(command.getSourcePosY());
+        crnCommand.setSourcePosZ(command.getSourcePosZ());
+        crnCommand.setDestinationPosX(command.getDestinationPosX());
+        crnCommand.setDestinationPosY(command.getDestinationPosY());
+        crnCommand.setDestinationPosZ(command.getDestinationPosZ());
+//        crnCommand.setSourceStaNo(command.getSourceStaNo());
+//        crnCommand.setDestinationStaNo(command.getDestinationStaNo());
+        crnCommand.setCommand(command.getCommand());
         if (command.getTaskNo() == 0 && command.getAckFinish() == 0 && command.getAuto() != 1) {
             command.setTaskNo((short) 9999);
         }
@@ -395,11 +392,10 @@
         array[6] = command.getDestinationPosZ();
         array[7] = command.getDestinationPosX();
         array[8] = command.getDestinationPosY();
-        array[9] = command.getCommand();
+//        array[9] = command.getCommand();
         // 浣滀笟淇℃伅
         OperateResult result = siemensNet.Write("DB100.0", array);
-        // 鏃ュ織璁板綍
-//        try {
+
             if (command.getAckFinish() != 1) {
                 BasCrnOptService bean = SpringUtils.getBean(BasCrnOptService.class);
                 BasCrnOpt basCrnOpt = new BasCrnOpt(
@@ -421,38 +417,26 @@
                 );
                 bean.insert(basCrnOpt);
             }
-//        } catch (Exception ignore) {}
+
 
         //鏇存柊鍛戒护鏃ュ織
         CommandInfoLogService commandInfoLogService = SpringUtils.getBean(CommandInfoLogService.class);
         CommandInfoService commandInfoService = SpringUtils.getBean(CommandInfoService.class);
         CommandInfo commandInfo = commandInfoService.selectById(command.getCommandId());
+        if (Cools.isEmpty(commandInfo)){
+            commandInfo = commandInfoService.selectOne(new EntityWrapper<CommandInfo>()
+                    .eq("wrk_no",crnProtocol.getTaskNo())
+                    .eq("device","Crn"));
+        }
         CommandInfoLog commandInfoLog = JSON.parseObject(JSON.toJSONString(commandInfo), CommandInfoLog.class);
         commandInfoLog.setId(null);
-//        CommandInfoLog commandInfoLog = new CommandInfoLog();
-//        if (commandInfo != null) {
-//            commandInfoLog = JSON.parseObject(JSON.toJSONString(commandInfo), CommandInfoLog.class);
-//            commandInfoLog.setId(null);
-//        }else {
-//            Date now = new Date();
-//            commandInfoLog.setCommand(JSON.toJSONString(command));
-//            commandInfoLog.setCommandStatus(3);
-//            commandInfoLog.setStartTime(now);
-//            commandInfoLog.setExecuteTime(now);
-//            commandInfoLog.setCompleteTime(now);
-//            commandInfoLog.setDevice(SlaveType.Devp.toString());
-//            commandInfoLog.setWrkNo(9999);
-//            commandInfoLog.setTaskNo("9999");
-//            commandInfoLog.setCommandDesc("鎵嬪姩鍛戒护");
-//        }
+
 
 
         if (result.IsSuccess) {
-            log.warn("鍫嗗灈鏈哄懡浠や笅鍙慬id:{},鏃堕棿锛歿}] >>>>> {}", slave.getId(), DateUtils.convert(new Date(), DateUtils.yyyyMMddHHmmsssss_F), JSON.toJSON(command));
-            OutputQueue.CRN.offer(MessageFormat.format("銆恵0}銆慬id:{1}] >>>>> 鍛戒护涓嬪彂锛� {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(command)));
+//            log.warn("鍫嗗灈鏈哄懡浠や笅鍙慬id:{},鏃堕棿锛歿}] >>>>> {}", slave.getId(), DateUtils.convert(new Date(), DateUtils.yyyyMMddHHmmsssss_F), JSON.toJSON(command));
 
             Date now = new Date();
-
             //鏇存柊鎸囦护鏃ュ織
             commandInfoLog.setDeviceLog("鎸囦护涓嬪彂鎴愬姛");
             commandInfoLogService.insert(commandInfoLog);
@@ -473,7 +457,7 @@
                 taskWrkService.updateById(taskWrk);
             }
 
-            return true;
+
         } else {
             OutputQueue.CRN.offer(MessageFormat.format("銆恵0}銆戝啓鍏ュ爢鍨涙満plc鏁版嵁澶辫触 ===>> [id:{1}] [ip:{2}] [port:{3}] [rack:{4}] [slot:{5}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot()));
             log.error("鍐欏叆鍫嗗灈鏈簆lc鏁版嵁澶辫触 ===>> [id:{}] [ip:{}] [port:{}] [rack:{}] [slot:{}]", slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot());
@@ -483,6 +467,85 @@
             commandInfoLogService.insert(commandInfoLog);
             return false;
         }
+        //鍫嗗灈鏈轰换鍔″啓鍏ュ悗锛屽洖璇讳竴娆★紝鐪嬫槸鍚︽垚鍔�
+        Thread.sleep(200);
+        try{
+            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.setSourcePosZ(siemensNet.getByteTransform().TransInt16(resultRead.Content, 6));
+                one.setSourcePosX(siemensNet.getByteTransform().TransInt16(resultRead.Content, 8));
+                one.setSourcePosY(siemensNet.getByteTransform().TransInt16(resultRead.Content, 10));
+                one.setDestinationPosZ(siemensNet.getByteTransform().TransInt16(resultRead.Content, 12));
+                one.setDestinationPosX(siemensNet.getByteTransform().TransInt16(resultRead.Content, 14));
+                one.setDestinationPosY(siemensNet.getByteTransform().TransInt16(resultRead.Content, 16));
+//                one.setTraySize(siemensNet.getByteTransform().TransBool(resultRead.Content, 22));
+                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())
+
+                ){
+                    try{
+                        log.error("鍫嗗灈鏈哄懡浠ゅ湴鍧�鍐欏叆鍚庡洖璇诲け璐id:{}] >>>>> 鍐欏叆[{}],===>>鍥炶[{}]", slave.getId(), JSON.toJSON(command),JSON.toJSON(one));
+                    }catch (Exception e){
+                        try{
+                            log.error("鏃ュ織鎵撳嵃澶辫触锛�===>>鍙傛暟one鎶ラ敊 [id:{}],{}", slave.getId(), JSON.toJSON(command),JSON.toJSON(resultRead));
+                        }catch (Exception e1){
+                            log.error("鏃ュ織鎵撳嵃澶辫触锛�===>> [id:{}],{}", slave.getId(), JSON.toJSON(command));
+                        }
+                    }
+                    log.error("鍫嗗灈鏈哄懡浠ゅ洖璇诲け璐ュ悗锛岄噸鏂版坊鍔犱换鍔″埌闃熷垪 ===>> [id:{}],{}", slave.getId(), JSON.toJSON(command));
+                    MessageQueue.offer(SlaveType.Crn, slave.getId(), new Task(5, command));
+                    Thread.sleep(100);
+                    readStatus();
+                    return false;
+                } else {
+                    log.info("鍫嗗灈鏈哄懡浠ゅ湴鍧�鍐欏叆鍚庡洖璇绘垚鍔焄id:{}] >>>>> 鍐欏叆[{}],===>>鍥炶[{}]", slave.getId(), JSON.toJSON(command),JSON.toJSON(one));
+                }
+            }
+        }catch (Exception e){
+            log.error("鍫嗗灈鏈哄懡浠ゅ湴鍧�鍐欏叆鍚庡洖璇诲嚭閿�");
+        }
+
+
+        if (command.getAckFinish() == 0) {
+            if (result.IsSuccess) {
+                Thread.sleep(300);
+                //浠诲姟涓嬪彂娆℃暟
+                int writeCount2 = 0;
+
+                do {
+                    writeCount2++;
+                    short commandFinish = (short) 1;
+                    result = siemensNet.Write("DB100.18", commandFinish);
+                    if(result.IsSuccess){
+                        //鍫嗗灈鏈轰换鍔″啓鍏ュ悗锛屽洖璇讳竴娆★紝鐪嬫槸鍚︽垚鍔�
+                        Thread.sleep(200);
+                        OperateResultExOne<byte[]> resultRead = siemensNet.Read("DB100.18", (short) 2);
+                        if (resultRead.IsSuccess) {
+                            commandFinish=siemensNet.getByteTransform().TransInt16(resultRead.Content, 0);
+                            if (commandFinish != 1){
+                                log.error("鍫嗗灈鏈轰换鍔$‘璁や綅"+commandFinish+"鍐欏叆鏁版嵁涓庡洖璇绘暟鎹笉涓�鑷达紒"+"寰幆鎵ц娆℃暟:"+writeCount2+"娆�");
+                            }else{
+                                //浠诲姟鍛戒护鍐欏叆鎴愬姛
+                                log.info("鍫嗗灈鏈轰换鍔$‘璁や綅"+commandFinish+"鍥炶鎴愬姛锛�"+"寰幆鎵ц娆℃暟:"+writeCount2+"娆�");
+                                break;
+                            }
+                        }else {
+                            log.error("鍫嗗灈鏈轰换鍔$‘璁や綅"+commandFinish+"鍥炶澶辫触锛�"+"寰幆鎵ц娆℃暟:"+writeCount2+"娆�");
+                        }
+                    } else {
+                        log.error("鍫嗗灈鏈轰换鍔$‘璁や綅"+commandFinish+"鍐欏叆澶辫触锛�"+"寰幆鎵ц娆℃暟:"+writeCount2+"娆�");
+                    }
+                }while (writeCount2<5);
+            }
+        }
+
+
+        return true;
     }
 
     private boolean writeAuto(CrnCommand command){
@@ -508,6 +571,9 @@
         }else if (command.getOnlineWrk4() != 0){
             array[0] = command.getOnlineWrk4();
             result = siemensNet.Write("DB103.8", array);
+        } else if (command.getReset() != 0) {
+            array[0] = command.getReset();
+            result = siemensNet.Write("DB103.10", array);
         }
 
 

--
Gitblit v1.9.1