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

device-manager-ui/admin/src/components/SearchForm.vue

@@ -273,7 +273,7 @@ export default {
     onSubmit() {
       let { path, query } = this.$route;
       let data = this.decode(this.form);
-      delete this.form["deviceStatusList"]
+      //delete this.form["deviceStatusList"]
       this.$router.push({
         path: path,
         query: Object.assign({}, query, data),

device-manager-ui/admin/src/views/device/list.vue

@@ -319,6 +319,7 @@ export default {
     },
 
     changeStat(val, enabled) {
+      return;
       //去除其它条件
       delete this.query["productId"]
       delete this.query["deviceName"]
@@ -524,6 +525,12 @@ export default {
             type: "select",
             label: "设备类型",
           },
+
+          {
+            name: "deviceStatus",
+            type: "select",
+            label: "设备状态",
+          },
         ],
         columns: [
           {

device-manager/src/main/java/com/mortals/xhx/daemon/task/DeviceStatTaskImpl.java

@@ -44,16 +44,21 @@ public class DeviceStatTaskImpl implements ITaskExcuteService {
         //获取所有在线设备
         List<DeviceEntity> deviceList = deviceService.find(new DeviceQuery().deviceStatus(DeviceStatusEnum.在线.getValue()));
         //更新离线
-        List<DeviceEntity> deviceOfflineList = deviceList.stream().map(item -> {
+        List<DeviceEntity> deviceOfflineList = deviceList.parallelStream().map(item -> {
+            if(ObjectUtils.isEmpty(item.getDeviceCode())) return null;
             boolean exists = cacheService.exists(RedisKey.KEY_DEVICE_ONLINE_CACHE + item.getDeviceCode());
+            log.info("deviceCode:{},exists:{}",item.getDeviceCode(),exists);
             if (!exists) {
                 item.setDeviceStatus(DeviceStatusEnum.离线.getValue());
                 item.setOfflineTime(new Date());
+                return item;
             }
-            return item;
-        }).filter(f -> f.getDeviceStatus().equals(DeviceStatusEnum.离线.getValue())).collect(Collectors.toList());
+            return null;
+        }).filter(f -> f!=null).collect(Collectors.toList());
 
         if (!ObjectUtils.isEmpty(deviceOfflineList)) {
+            log.info("修正设备数量:size:{}",deviceOfflineList.size());
+
             deviceService.update(deviceOfflineList);
             deviceOfflineList.forEach(deviceEntity -> {
                 PlatformEntity platformEntity = platformService.get(deviceEntity.getPlatformId());