From 2c9689ad1f2f3d80e068117b81448abd1619835c Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期二, 26 十二月 2023 20:40:24 +0800
Subject: [PATCH] #日志采集

---
 src/main/java/com/zy/core/thread/LiftThread.java |   17 +++++++++++++----
 1 files changed, 13 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/LiftThread.java b/src/main/java/com/zy/core/thread/LiftThread.java
index a9f40e5..977730e 100644
--- a/src/main/java/com/zy/core/thread/LiftThread.java
+++ b/src/main/java/com/zy/core/thread/LiftThread.java
@@ -10,9 +10,11 @@
 import com.core.exception.CoolException;
 import com.zy.asrs.entity.BasLift;
 import com.zy.asrs.entity.BasLiftOpt;
+import com.zy.asrs.entity.DeviceDataLog;
 import com.zy.asrs.mapper.WrkMastMapper;
 import com.zy.asrs.service.BasLiftOptService;
 import com.zy.asrs.service.BasLiftService;
+import com.zy.asrs.service.DeviceDataLogService;
 import com.zy.asrs.utils.Utils;
 import com.zy.common.utils.RedisUtil;
 import com.zy.core.News;
@@ -30,10 +32,7 @@
 import lombok.extern.slf4j.Slf4j;
 
 import java.text.MessageFormat;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
+import java.util.*;
 
 /**
  * 鎻愬崌鏈虹嚎绋�
@@ -279,6 +278,16 @@
                 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);
+
         } 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