| | |
|---|
| | | import com.zy.core.network.DeviceConnectPool; |
|---|
| | | import com.zy.core.thread.StationThread; |
|---|
| | | import com.zy.core.thread.support.RecentStationArrivalTracker; |
|---|
| | | import com.zy.core.thread.support.StationErrLogSupport; |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.core.common.DateUtils; |
|---|
| | | import com.core.common.SpringUtils; |
|---|
| | |
|---|
| | | private ZyStationConnectDriver zyStationConnectDriver; |
|---|
| | | private int deviceLogCollectTime = 200; |
|---|
| | | private long deviceDataLogTime = System.currentTimeMillis(); |
|---|
| | | private final RecentStationArrivalTracker recentArrivalTracker = new RecentStationArrivalTracker(); |
|---|
| | | private final RecentStationArrivalTracker recentArrivalTracker; |
|---|
| | | |
|---|
| | | public ZyStationThread(DeviceConfig deviceConfig, RedisUtil redisUtil) { |
|---|
| | | this.deviceConfig = deviceConfig; |
|---|
| | | this.redisUtil = redisUtil; |
|---|
| | | this.recentArrivalTracker = new RecentStationArrivalTracker(redisUtil); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | |
|---|
| | | stationProtocol.setRunBlock(statusEntity.isRunBlock()); |
|---|
| | | stationProtocol.setEnableIn(statusEntity.isEnableIn()); |
|---|
| | | stationProtocol.setWeight(statusEntity.getWeight()); |
|---|
| | | stationProtocol.setIoMode(statusEntity.getIoMode()); |
|---|
| | | recentArrivalTracker.observe(statusEntity.getStationId(), statusEntity.getTaskNo(), statusEntity.isLoading()); |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | OutputQueue.DEVP.offer(MessageFormat.format("【{0}】[id:{1}] <<<<< 实时数据更新成功",DateUtils.convert(new Date()), deviceConfig.getDeviceNo())); |
|---|
| | | StationErrLogSupport.sync(deviceConfig, redisUtil, statusList); |
|---|
| | | |
|---|
| | | if (System.currentTimeMillis() - deviceDataLogTime > deviceLogCollectTime) { |
|---|
| | | //保存数据记录 |
|---|
