修改通知去重复

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

@@ -85,10 +85,17 @@ public class SyncMeetStatusTaskImpl implements ITaskExcuteService {
                 RoomEntity roomEntity = roomService.get(recordEntity.getRoomId(), null);
                 if (!ObjectUtils.isEmpty(roomEntity)) {
                     List<String> deviceList = roomDeviceService.find(new RoomDeviceQuery().roomId(roomEntity.getId())).stream().map(i -> i.getDeviceCode()).collect(Collectors.toList());
+
                     uploadDeviceReq.setDeviceCodeList(deviceList);
                     uploadDeviceReq.setAction("refreshMetting");
                     messageFeign.downMsg(uploadDeviceReq);
 
+                    uploadDeviceReq = new UploadDeviceReq();
+                    uploadDeviceReq.setDeviceCodeList(deviceList);
+                    uploadDeviceReq.setAction("preMeetStart");
+                    uploadDeviceReq.setContent(JSON.toJSONString(recordEntity));
+                    messageFeign.downMsg(uploadDeviceReq);
+
                     log.info("推送等待--》进行中:{}", JSON.toJSONString(deviceList));
                 }
             }
@@ -123,14 +130,6 @@ public class SyncMeetStatusTaskImpl implements ITaskExcuteService {
                     Rest<String> rest = messageFeign.downMsg(uploadDeviceReq);
                     log.info("推送自动结束 postMeet  :{}", JSON.toJSONString(Arrays.asList(roomDeviceEntity.getDeviceCode())));
 
-
-         /*           long sub = DateUtil.between(pendRecordEntity.getMeetTimeStart(), pendRecordEntity.getMeetTimeEnd(), DateUnit.SECOND, true);
-                    boolean setnx = cacheService.setnx(RedisKey.KEY_METTING_END_CACHE, pendRecordEntity.getId(), sub);
-                    if (setnx) {
-
-                    }else{
-
-                    }*/
                 }
 
             }