From 44d6711c1afb71dccd78a39948dffe432c8989de Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期五, 21 八月 2020 13:25:05 +0800 Subject: [PATCH] # --- src/main/java/com/zy/core/thread/CrnThread.java | 33 ++++++++++++++++++++++++--------- 1 files changed, 24 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/zy/core/thread/CrnThread.java b/src/main/java/com/zy/core/thread/CrnThread.java index 06b844e..fcc56e1 100644 --- a/src/main/java/com/zy/core/thread/CrnThread.java +++ b/src/main/java/com/zy/core/thread/CrnThread.java @@ -6,6 +6,9 @@ import HslCommunication.Profinet.Siemens.SiemensS7Net; import com.alibaba.fastjson.JSON; import com.core.common.DateUtils; +import com.core.common.SpringUtils; +import com.zy.asrs.entity.BasCrnp; +import com.zy.asrs.service.BasCrnpService; import com.zy.core.ThreadHandler; import com.zy.core.cache.MessageQueue; import com.zy.core.cache.OutputQueue; @@ -130,14 +133,17 @@ // 寮傚父淇℃伅 crnProtocol.setError1(siemensNet.getByteTransform().TransBool(result.Content, 22, 2)); crnProtocol.setError2(siemensNet.getByteTransform().TransBool(result.Content, 24, 2)); - crnProtocol.setTemp1(siemensNet.getByteTransform().TransInt16(result.Content, 26)); - crnProtocol.setXSpeed(siemensNet.getByteTransform().TransSingle(result.Content, 28)); - crnProtocol.setYSpeed(siemensNet.getByteTransform().TransSingle(result.Content, 32)); - crnProtocol.setZSpeed(siemensNet.getByteTransform().TransSingle(result.Content, 36)); - crnProtocol.setXDistance(siemensNet.getByteTransform().TransSingle(result.Content, 40)); - crnProtocol.setYDistance(siemensNet.getByteTransform().TransSingle(result.Content, 44)); - crnProtocol.setXDuration(siemensNet.getByteTransform().TransSingle(result.Content, 48)); - crnProtocol.setYDuration(siemensNet.getByteTransform().TransSingle(result.Content, 52)); + crnProtocol.setError3(siemensNet.getByteTransform().TransBool(result.Content, 26, 2)); + crnProtocol.setError4(siemensNet.getByteTransform().TransBool(result.Content, 28, 2)); + crnProtocol.setError5(siemensNet.getByteTransform().TransBool(result.Content, 30, 2)); + crnProtocol.setError6(siemensNet.getByteTransform().TransBool(result.Content, 32, 2)); + crnProtocol.setXSpeed(siemensNet.getByteTransform().TransSingle(result.Content, 34)); + crnProtocol.setYSpeed(siemensNet.getByteTransform().TransSingle(result.Content, 38)); + crnProtocol.setZSpeed(siemensNet.getByteTransform().TransSingle(result.Content, 42)); + crnProtocol.setXDistance(siemensNet.getByteTransform().TransSingle(result.Content, 46)); + crnProtocol.setYDistance(siemensNet.getByteTransform().TransSingle(result.Content, 50)); + crnProtocol.setXDuration(siemensNet.getByteTransform().TransSingle(result.Content, 54)); + crnProtocol.setYDuration(siemensNet.getByteTransform().TransSingle(result.Content, 58)); /** * 褰撹鍒皊tatus == 90.浠诲姟瀹屾垚绛夊緟WCS纭 鏃� @@ -148,6 +154,15 @@ crnCommand.setAckFinish((short)1); write(crnCommand); } + + // 鏍规嵁瀹炴椂淇℃伅鏇存柊鏁版嵁搴� + BasCrnpService basCrnpService = SpringUtils.getBean(BasCrnpService.class); + BasCrnp basCrnp = new BasCrnp(); + basCrnp.setCrnNo(slave.getId()); + if (basCrnpService.updateById(crnProtocol.toSqlModel(basCrnp))){ + log.error("鍫嗗灈鏈簆lc鏁版嵁搴撴洿鏂板け璐� ===>> [id:{}] [ip:{}] [port:{}] [rack:{}] [slot:{}]", slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot()); + } + } 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()); @@ -176,7 +191,7 @@ OperateResult result = siemensNet.Write("DB8.0", array); if (result.IsSuccess) { System.out.println(MessageFormat.format("銆恵0}銆慬id:{1}] >>>>> {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(command))); - OutputQueue.CRN.offer(MessageFormat.format("銆恵0}銆慬id:{1}] >>>>> {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(command))); + OutputQueue.CRN.offer(MessageFormat.format("銆恵0}銆慬id:{1}] >>>>> 鍛戒护涓嬪彂锛� {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(command))); // readStatus(); } else { System.out.println(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())); -- Gitblit v1.9.1