修改通知去重复

smart-office-manager/src/main/java/com/mortals/xhx/daemon/task/MeetSwitchTaskImpl.java

@@ -115,7 +115,7 @@ public class MeetSwitchTaskImpl implements ITaskExcuteService {
                     }
 
                     //通知设备进行数据更新
-                    boolean setnx = cacheService.setnx(RedisKey.KEY_METTING_START_CACHE, recordEntity.getId(), between * 60);
+                    boolean setnx = cacheService.setnx(RedisKey.KEY_METTING_START_CACHE, recordEntity.getId(),  60);
                     if (setnx) {
                         UploadDeviceReq uploadDeviceReq = new UploadDeviceReq();
                         uploadDeviceReq.setDeviceCodeList(Arrays.asList(roomDeviceEntity.getDeviceCode()));

smart-office-manager/src/main/java/com/mortals/xhx/module/metting/service/impl/MettingRecordServiceImpl.java

@@ -211,10 +211,11 @@ public class MettingRecordServiceImpl extends AbstractCRUDServiceImpl<MettingRec
             UploadDeviceReq uploadDeviceReq = new UploadDeviceReq();
             RoomEntity roomEntity = roomService.get(entity.getRoomId(), context);
             if (!ObjectUtils.isEmpty(roomEntity)) {
-                uploadDeviceReq.setDeviceCodeList(roomDeviceService.find(new RoomDeviceQuery().roomId(roomEntity.getId())).stream().map(i -> i.getDeviceCode()).collect(Collectors.toList()));
+                List<String> deviceList = roomDeviceService.find(new RoomDeviceQuery().roomId(roomEntity.getId())).stream().map(i -> i.getDeviceCode()).collect(Collectors.toList());
+                uploadDeviceReq.setDeviceCodeList(deviceList);
                 uploadDeviceReq.setAction("refreshMetting");
                 Rest<String> rest = messageFeign.downMsg(uploadDeviceReq);
-                log.info("删除会议记录后发送消息：{}", JSON.toJSONString(rest));
+                log.info("删除会议记录后发送消息 deviceCode：{}", JSON.toJSONString(deviceList));
 
             }
         });