Commit cb5e4987 authored by 赵啸非's avatar 赵啸非

修改通知去重复

parent 4b7ce947
...@@ -41,7 +41,7 @@ import java.util.stream.Collectors; ...@@ -41,7 +41,7 @@ import java.util.stream.Collectors;
* 会议室切换状态 * 会议室切换状态
*/ */
@Slf4j @Slf4j
@Service("MeetSwitchTaskTask") @Service("MeetSwitchTask")
public class MeetSwitchTaskImpl implements ITaskExcuteService { public class MeetSwitchTaskImpl implements ITaskExcuteService {
@Autowired @Autowired
...@@ -113,6 +113,8 @@ public class MeetSwitchTaskImpl implements ITaskExcuteService { ...@@ -113,6 +113,8 @@ public class MeetSwitchTaskImpl implements ITaskExcuteService {
//通知设备进行数据更新 //通知设备进行数据更新
long expire = between * 60 == 0 ? between * 60 : 60; long expire = between * 60 == 0 ? between * 60 : 60;
log.info("会议redis 设置过期时间:{}", expire);
try {
boolean setnx = cacheService.setnx(RedisKey.KEY_METTING_START_CACHE, recordEntity.getId(), expire); boolean setnx = cacheService.setnx(RedisKey.KEY_METTING_START_CACHE, recordEntity.getId(), expire);
if (setnx) { if (setnx) {
UploadDeviceReq uploadDeviceReq = new UploadDeviceReq(); UploadDeviceReq uploadDeviceReq = new UploadDeviceReq();
...@@ -122,6 +124,10 @@ public class MeetSwitchTaskImpl implements ITaskExcuteService { ...@@ -122,6 +124,10 @@ public class MeetSwitchTaskImpl implements ITaskExcuteService {
log.info("preMeetStart send msg :{}", roomDeviceEntity.getDeviceCode()); log.info("preMeetStart send msg :{}", roomDeviceEntity.getDeviceCode());
messageFeign.downMsg(uploadDeviceReq); messageFeign.downMsg(uploadDeviceReq);
} }
}catch (Exception e){
log.error("设置异常",e);
}
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment