Commit 2ccf1687 authored by 赵啸非's avatar 赵啸非

设备添加产品编码字段,并添加同步更新产品编码字段

parent b6624288
...@@ -47,7 +47,6 @@ public class DeviceStatTaskImpl implements ITaskExcuteService { ...@@ -47,7 +47,6 @@ public class DeviceStatTaskImpl implements ITaskExcuteService {
List<DeviceEntity> deviceOfflineList = deviceList.parallelStream().map(item -> { List<DeviceEntity> deviceOfflineList = deviceList.parallelStream().map(item -> {
if(ObjectUtils.isEmpty(item.getDeviceCode())) return null; if(ObjectUtils.isEmpty(item.getDeviceCode())) return null;
boolean exists = cacheService.exists(RedisKey.KEY_DEVICE_ONLINE_CACHE + item.getDeviceCode()); boolean exists = cacheService.exists(RedisKey.KEY_DEVICE_ONLINE_CACHE + item.getDeviceCode());
log.info("deviceCode:{},exists:{}",item.getDeviceCode(),exists);
if (!exists) { if (!exists) {
item.setDeviceStatus(DeviceStatusEnum.离线.getValue()); item.setDeviceStatus(DeviceStatusEnum.离线.getValue());
item.setOfflineTime(new Date()); item.setOfflineTime(new Date());
...@@ -58,7 +57,6 @@ public class DeviceStatTaskImpl implements ITaskExcuteService { ...@@ -58,7 +57,6 @@ public class DeviceStatTaskImpl implements ITaskExcuteService {
if (!ObjectUtils.isEmpty(deviceOfflineList)) { if (!ObjectUtils.isEmpty(deviceOfflineList)) {
log.info("修正设备数量:size:{}",deviceOfflineList.size()); log.info("修正设备数量:size:{}",deviceOfflineList.size());
deviceService.update(deviceOfflineList); deviceService.update(deviceOfflineList);
deviceOfflineList.forEach(deviceEntity -> { deviceOfflineList.forEach(deviceEntity -> {
PlatformEntity platformEntity = platformService.get(deviceEntity.getPlatformId()); PlatformEntity platformEntity = platformService.get(deviceEntity.getPlatformId());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment