修改校验

device-manager/src/main/java/com/mortals/xhx/busiz/web/DeviceApiController.java

@@ -605,7 +605,10 @@ public class DeviceApiController {
             productVersionQuery.setProductId(deviceEntity.getProductId());
             productVersionQuery.setSiteId(deviceEntity.getSiteId());
             productVersionQuery.setOrderColList(Arrays.asList(new OrderCol("version", OrderCol.DESCENDING)));
-            ProductVersionEntity productVersionEntity = productVersionService.find(productVersionQuery).stream().filter(item -> StrUtil.endWith(item.getFilePath(), ".apk", true)).findFirst().orElseGet(() -> null);
+            ProductVersionEntity productVersionEntity = productVersionService.find(productVersionQuery)
+                    .stream()
+                   // .filter(item -> StrUtil.endWith(item.getFilePath(), ".apk", true))
+                    .findFirst().orElseGet(() -> null);
             // ProductVersionEntity productVersionEntity = productVersionService.selectOne(productVersionQuery);
             if (ObjectUtils.isEmpty(productVersionEntity)) {
                 throw new AppException(DEVICE_VERSION_UNEXIST, DEVICE_VERSION_UNEXIST_CONTENT);

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

@@ -71,7 +71,7 @@ public class DeviceStatTaskImpl implements ITaskExcuteService {
         }*/
         //获取所有在线设备
 
-        List<DeviceEntity> deviceList = deviceService.getCacheList().stream().filter(f->DeviceStatusEnum.在线.getValue()==f.getDeviceStatus()).collect(Collectors.toList());
+        List<DeviceEntity> deviceList = deviceService.getCacheList().stream().filter(f -> DeviceStatusEnum.在线.getValue() == f.getDeviceStatus()).collect(Collectors.toList());
 
         // List<DeviceEntity> deviceList = deviceService.find(new DeviceQuery().deviceStatus(DeviceStatusEnum.在线.getValue()));
         //更新离线
@@ -92,15 +92,15 @@ public class DeviceStatTaskImpl implements ITaskExcuteService {
             log.info("修正设备数量:size:{}", deviceOfflineList.size());
 
             // deviceService.update(deviceOfflineList);
-            deviceOfflineList.forEach(deviceEntity -> {
-                cacheService.lpush(RedisKey.KEY_DEVICE_UPDATE_QUEUE,deviceEntity);
-
+            for (DeviceEntity deviceEntity : deviceOfflineList) {
+                cacheService.lpush(RedisKey.KEY_DEVICE_UPDATE_QUEUE, deviceEntity);
+                if (ObjectUtils.isEmpty(deviceEntity.getPlatformId())) continue;
+                if (ObjectUtils.isEmpty(deviceEntity.getProductId())) continue;
                 PlatformEntity platformEntity = platformService.getCache(deviceEntity.getPlatformId().toString());
                 ProductEntity productEntity = productService.getCache(deviceEntity.getProductId().toString());
                 if (!ObjectUtils.isEmpty(platformEntity) && !ObjectUtils.isEmpty(productEntity)) {
                     //通知第三方平台
                     deviceService.sendThirdParty(deviceEntity, productEntity, platformEntity, DeviceMethodEnum.OFFLINE);
-
                     //保存业务消息为离线
                     BizLogPdu bizLogPdu = new BizLogPdu();
                     bizLogPdu.initAttrValue();
@@ -117,7 +117,7 @@ public class DeviceStatTaskImpl implements ITaskExcuteService {
                     messageProducer.syncBizSend(bizLogPdu);
 
                 }
-            });
+            }
         }
     }
 

device-manager/src/test/java/com/mortals/httpclient/system.http

@@ -84,6 +84,19 @@ Content-Type: application/json
 {"affairCode":"abcd1234ddddd"}
 
 
+###测试json提交
+POST {{baseUrl}}/test/sendThirdParty
+Content-Type: application/json
+
+{}
+
+###测试json提交
+POST {{baseUrl}}/api/checkVersion
+Content-Type: application/json
+
+{"deviceCode":"8C-C5-8C-02-BC-5A"}
+
+