更新下发消息为线程池发送

device-manager/src/main/java/com/mortals/xhx/module/device/service/impl/DeviceServiceImpl.java

@@ -693,7 +693,7 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
     @Override
     public void downMsg(List<DeviceMsgReq> list) {
         try {
-            //ArrayList<DeviceLogEntity> deviceLogList = new ArrayList<>();
+            ArrayList<DeviceLogEntity> deviceLogList = new ArrayList<>();
             List<DeviceMsgReq> collect = list.stream().sorted(Comparator.comparing(DeviceMsgReq::getTimestamp)).collect(Collectors.toList());
             List<List<DeviceMsgReq>> partition = ListUtil.partition(collect, 10);
             for (List<DeviceMsgReq> deviceMsgReqs : partition) {
@@ -732,8 +732,8 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
                         deviceLogEntity.setLogType(LogTypeEnum.下发服务.getValue());
                         deviceLogEntity.setCreateUserId(1L);
                         deviceLogEntity.setCreateTime(new Date());
-                        //  deviceLogList.add(deviceLogEntity);
-                        deviceLogService.save(deviceLogEntity, null);
+                        deviceLogList.add(deviceLogEntity);
+                       // deviceLogService.save(deviceLogEntity, null);
                     } else {
                         log.info("未找到设备，deviceCode:{}", item.getDeviceCode());
                     }