| src/main/java/com/zy/common/CodeBuilder.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| src/main/java/com/zy/core/model/protocol/CrnProtocol.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| src/main/java/com/zy/core/thread/SiemensCrnThread.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
src/main/java/com/zy/common/CodeBuilder.java
@@ -1,6 +1,7 @@ package com.zy.common; import com.core.generators.CoolGenerator; import com.core.generators.constant.SqlOsType; /** * Created by vincent on 2019-06-04 @@ -15,11 +16,17 @@ // generator.password="xltys1995"; // generator.table="sys_host"; // sqlserver generator.url="192.168.3.208:1433;databasename=cool"; generator.sqlOsType = SqlOsType.SQL_SERVER; generator.url="127.0.0.1:1433;databasename=rqdzasrs"; generator.username="sa"; generator.password="sa@123"; generator.table="asr_wrk_detl"; generator.table="wcs_device_data_log"; generator.packagePath="com.zy.asrs"; generator.js = false; generator.html = false; generator.htmlDetail = false; generator.controller = false; generator.build(); } src/main/java/com/zy/core/model/protocol/CrnProtocol.java
@@ -195,6 +195,11 @@ public Float yDuration; /** * 日志采集时间 */ private Long deviceDataLog = System.currentTimeMillis(); /** * 上一次指令下发时间 */ private Long lastCommandTime = System.currentTimeMillis(); src/main/java/com/zy/core/thread/SiemensCrnThread.java
@@ -10,8 +10,10 @@ import com.core.common.SpringUtils; import com.zy.asrs.entity.BasCrnOpt; import com.zy.asrs.entity.BasCrnp; import com.zy.asrs.entity.DeviceDataLog; import com.zy.asrs.service.BasCrnOptService; import com.zy.asrs.service.BasCrnpService; import com.zy.asrs.service.DeviceDataLogService; import com.zy.common.utils.News; import com.zy.core.CrnThread; import com.zy.core.cache.MessageQueue; @@ -27,6 +29,7 @@ import lombok.extern.slf4j.Slf4j; import java.text.MessageFormat; import java.util.Base64; import java.util.Date; /** @@ -271,6 +274,22 @@ } } if (System.currentTimeMillis() - crnProtocol.getDeviceDataLog() > 200) { //采集时间超过5s,保存一次数据记录 //保存数据记录 DeviceDataLogService deviceDataLogService = SpringUtils.getBean(DeviceDataLogService.class); DeviceDataLog deviceDataLog = new DeviceDataLog(); deviceDataLog.setOriginData(Base64.getEncoder().encodeToString(result.Content)); deviceDataLog.setWcsData(JSON.toJSONString(crnProtocol)); deviceDataLog.setType("crn"); deviceDataLog.setDeviceNo(crnProtocol.getCrnNo()); deviceDataLog.setCreateTime(new Date()); deviceDataLogService.insert(deviceDataLog); //更新采集时间 crnProtocol.setDeviceDataLog(System.currentTimeMillis()); } try { // 根据实时信息更新数据库 BasCrnpService basCrnpService = SpringUtils.getBean(BasCrnpService.class);