|
|
@@ -77,7 +77,7 @@ public class RedisExpiredAndWorkListener extends KeyExpirationEventMessageListen
|
|
|
JSONObject jsonObj = (JSONObject) JSONObject.parseObject(delayStr[1], Object.class, Feature.OrderedField);
|
|
|
LabDealyNotifyVo dealyNotifyVo = jsonObj.getObject(BaseConstants.DELAY_QUEUE, new TypeReference <LabDealyNotifyVo>(){});
|
|
|
|
|
|
- if (redisService.getCacheObject("subjectByYa" + dealyNotifyVo.getSubId()) != null) {
|
|
|
+ if (redisService.getCacheObject("subjectByYa" + dealyNotifyVo.getSubId()) == null) {
|
|
|
//这里类型固定写死2,智能通风
|
|
|
List <Long> ids = new ArrayList <>();
|
|
|
ids.add(2L);
|