|
@@ -56,8 +56,7 @@ public class MqttMsgRedisService {
|
|
|
|
|
|
//查询mqtt msg 表有延迟标记的未处理消息,放入线程池,等待延时时间结束执行创建工单
|
|
|
QueryWrapper<CareMqttMsg> queryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper.lambda().eq(CareMqttMsg::getStatus, MqttMsgStatusEnum.NO_HANDLE.getValue()).gt(CareMqttMsg::getDelayTime,0)
|
|
|
- .orderByAsc(CareMqttMsg::getCreateTime);
|
|
|
+ queryWrapper.lambda().eq(CareMqttMsg::getStatus, MqttMsgStatusEnum.NO_HANDLE.getValue()).gt(CareMqttMsg::getDelayTime,0);
|
|
|
|
|
|
List<CareMqttMsg> mqttMsgList = careMqttMsgService.list(queryWrapper);
|
|
|
if (CollUtil.isNotEmpty(mqttMsgList)) {
|