websocket消息逻辑整理

themis-task/src/main/java/com/qmth/themis/task/quartz/MqJob.java

@@ -86,6 +86,7 @@ public class MqJob extends QuartzJobBean {
                     //mq为延时消息，所以每分钟扫描时有可能mq消息还未执行，所以加上mq消息等级和当前时间对比，如超过mq的延时时间一分钟则执行
                     if (Objects.nonNull(mqExecTime) && (mqExecTime - System.currentTimeMillis()) / 1000 / 60 <= -1) {
                         mqDto.setReconsume(mqDto.getReconsume() + 1);
+                        redisUtil.set(redisKey, mqDto.getId(), mqDto);
                         producerServer.asyncDelayMsg(mqDto);
                     }
                 }