| | |
|---|
| | | import com.zy.core.network.entity.ZyDualCrnStatusEntity; |
|---|
| | | import com.zy.core.thread.DualCrnThread; |
|---|
| | | import com.zy.core.thread.StationThread; |
|---|
| | | import com.zy.core.utils.DeviceLogRedisKeyBuilder; |
|---|
| | | import com.zy.core.task.DeviceAsyncLogPublisher; |
|---|
| | | import lombok.Data; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | |
|---|
| | |
|---|
| | | private ZyDualCrnConnectDriver zyDualCrnConnectDriver; |
|---|
| | | private DualCrnProtocol crnProtocol; |
|---|
| | | private int deviceLogCollectTime = 200; |
|---|
| | | private final DeviceAsyncLogPublisher deviceAsyncLogPublisher; |
|---|
| | | |
|---|
| | | public ZySiemensDualCrnThread(DeviceConfig deviceConfig, RedisUtil redisUtil) { |
|---|
| | | this.deviceConfig = deviceConfig; |
|---|
| | | this.redisUtil = redisUtil; |
|---|
| | | this.deviceAsyncLogPublisher = SpringUtils.getBean(DeviceAsyncLogPublisher.class); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | |
|---|
| | | deviceDataLog.setDeviceNo(crnProtocol.getCrnNo()); |
|---|
| | | deviceDataLog.setCreateTime(new Date()); |
|---|
| | | |
|---|
| | | redisUtil.set(DeviceLogRedisKeyBuilder.build(deviceDataLog), deviceDataLog, 60 * 60 * 24); |
|---|
| | | deviceAsyncLogPublisher.publishLatest(deviceDataLog); |
|---|
| | | //更新采集时间 |
|---|
| | | crnProtocol.setDeviceDataLog(System.currentTimeMillis()); |
|---|
| | | } |
|---|
