From 4da282d3a87fb648ae6865929f5862b27d05a562 Mon Sep 17 00:00:00 2001 From: cpT <1@123> Date: 星期四, 03 七月 2025 15:07:25 +0800 Subject: [PATCH] #改造 --- src/main/java/com/zy/core/thread/SiemensCrnThread.java | 79 +++++++++++++++++++++++++++++++-------- 1 files changed, 63 insertions(+), 16 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..b6671ec 100644 --- a/src/main/java/com/zy/core/thread/SiemensCrnThread.java +++ b/src/main/java/com/zy/core/thread/SiemensCrnThread.java @@ -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"); } } } @@ -274,14 +288,14 @@ deviceErrorService.addDeviceError("crnWrite", slave.getId(), "宸烽亾鍙�"+command.getLaneNo()+";鍫嗗灈鏈烘寚浠や笅鍙�:"+JSON.toJSONString(command.getNowTask())); } catch (Exception e2){ } - 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){ - } +// 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){ +// } // convertRow(command); command.setCrnNo(slave.getId()); short[] array = new short[10]; @@ -294,7 +308,8 @@ 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); try{ Thread.sleep(50L); @@ -308,11 +323,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 +350,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{ @@ -355,7 +384,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 +577,22 @@ public void setWrkSign() { } + + /** + * 娓呴櫎浣滀笟鍚姩涓� + */ + @Override + public void setResetFlag(boolean flag) { + this.resetFlag = flag; + } + + + /** + * 娓呴櫎浣滀笟鍚姩涓� + */ + @Override + public boolean getResetFlag() { + return resetFlag; + } + } -- Gitblit v1.9.1