From 0df6e7bb33c9f6a18f026a500776b00cbf2ae62c Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期二, 24 十二月 2024 09:48:06 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/LiftThread.java | 39 ++++++++++++++++-----------------------
1 files changed, 16 insertions(+), 23 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/LiftThread.java b/src/main/java/com/zy/core/thread/LiftThread.java
index 977730e..bbbc3d3 100644
--- a/src/main/java/com/zy/core/thread/LiftThread.java
+++ b/src/main/java/com/zy/core/thread/LiftThread.java
@@ -207,20 +207,7 @@
basLift.setWrkNo(liftProtocol.getTaskNo().intValue());
basLift.setUpdateTime(new Date());
basLift.setPakMk(liftProtocol.getPakMk());
- basLift.setModel(liftProtocol.getModel());
- basLift.setBusy(liftProtocol.getBusy());
- basLift.setFrontOverrun(liftProtocol.getFrontOverrun());
- basLift.setBackOverrun(liftProtocol.getBackOverrun());
- basLift.setLeftOverrun(liftProtocol.getLeftOverrun());
- basLift.setRightOverrun(liftProtocol.getRightOverrun());
- basLift.setOverHeight(liftProtocol.getOverHeight());
- basLift.setOverWeight(liftProtocol.getOverWeight());
- basLift.setHasTray(liftProtocol.getHasTray());
- basLift.setHasCar(liftProtocol.getHasCar());
- basLift.setDeviceError(liftProtocol.getDeviceError());
- basLift.setDistAddress(liftProtocol.getDistAddress().intValue());
- basLift.setCompleteTaskNo(liftProtocol.getCompleteTaskNo().intValue());
- basLift.setLev(liftProtocol.getLev().intValue());
+ basLift.setDeviceStatus(JSON.toJSONString(liftProtocol));
if (liftService.updateById(basLift)) {
OutputQueue.LIFT.offer(MessageFormat.format("銆恵0}銆慬id:{1}] <<<<< 瀹炴椂鏁版嵁鏇存柊鎴愬姛",DateUtils.convert(new Date()), slave.getId()));
// log.info(MessageFormat.format("銆恵0}銆慬id:{1}] <<<<< 瀹炴椂鏁版嵁鏇存柊鎴愬姛",DateUtils.convert(new Date()), slave.getId()));
@@ -278,15 +265,21 @@
liftProtocol.setErrorCode(siemensS7Net.getByteTransform().TransInt16(result3.Content, 0));//閿欒鐮�
}
- //淇濆瓨鏁版嵁璁板綍
- DeviceDataLogService deviceDataLogService = SpringUtils.getBean(DeviceDataLogService.class);
- DeviceDataLog deviceDataLog = new DeviceDataLog();
- deviceDataLog.setOriginData(Base64.getEncoder().encodeToString(result1.Content));
- deviceDataLog.setWcsData(JSON.toJSONString(liftProtocol));
- deviceDataLog.setType("lift");
- deviceDataLog.setDeviceNo(liftProtocol.getLiftNo().intValue());
- deviceDataLog.setCreateTime(new Date());
- deviceDataLogService.insert(deviceDataLog);
+ if (System.currentTimeMillis() - liftProtocol.getDeviceDataLog() > 1000 * 5) {
+ //閲囬泦鏃堕棿瓒呰繃5s锛屼繚瀛樹竴娆℃暟鎹褰�
+ //淇濆瓨鏁版嵁璁板綍
+ DeviceDataLogService deviceDataLogService = SpringUtils.getBean(DeviceDataLogService.class);
+ DeviceDataLog deviceDataLog = new DeviceDataLog();
+ deviceDataLog.setOriginData(Base64.getEncoder().encodeToString(result1.Content));
+ deviceDataLog.setWcsData(JSON.toJSONString(liftProtocol));
+ deviceDataLog.setType("lift");
+ deviceDataLog.setDeviceNo(liftProtocol.getLiftNo().intValue());
+ deviceDataLog.setCreateTime(new Date());
+ deviceDataLogService.insert(deviceDataLog);
+
+ //鏇存柊閲囬泦鏃堕棿
+ liftProtocol.setDeviceDataLog(System.currentTimeMillis());
+ }
} catch (Exception e) {
OutputQueue.LIFT.offer(MessageFormat.format("銆恵0}銆戞彁鍗囨満plc鐘舵�佷俊鎭け璐� ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort()));
--
Gitblit v1.9.1