优化设备管理系统callback 下发消息效率

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

@@ -668,7 +668,9 @@ public class DeviceApiController {
         rsp.setCode(ApiRespCodeEnum.SUCCESS.getValue());
         try {
             List<DeviceMsgReq> collect = list.stream().sorted(Comparator.comparing(DeviceMsgReq::getTimestamp)).collect(Collectors.toList());
-            cacheService.lpush(KEY_DEVICE_DOWN_MSG_QUEUE,collect);
+           collect.forEach(item->{
+               cacheService.lpush(KEY_DEVICE_DOWN_MSG_QUEUE,item);
+           });
            // DownMsgTask downMsgTask = new DownMsgTask(list, platformService, productService, deviceService, deviceLogService, messageProducer);
            // sendTaskThreadPool.execute(downMsgTask);
         } catch (AppException e) {

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

@@ -24,6 +24,14 @@ Content-Type: application/json
 {}
 
 
+###首页
+POST {{baseUrl}}//api/callback
+Authorization: {{authToken}}
+Content-Type: application/json
+
+[{"deviceCode":"26-55-E7-3F-B1-AF","messageType":"waitqueue","timestamp":"1699428063250","data":"W10="}]
+
+
 ###站点树
 GET {{baseUrl}}/site/siteTree
 Authorization: {{authToken}}