考务导入接口

themis-mq/src/main/java/com/qmth/themis/mq/listener/RocketTaskConsumer.java

@@ -69,12 +69,11 @@ public class RocketTaskConsumer implements MessageListenerConcurrently {
                 log.info(":{}-:{} taskConsumer接收到的消息:{}", threadId, threadName, JacksonUtil.parseJson(mqDto));
                 log.info(":{}-:{} taskConsumer mqDto sequence:{},tag:{}", threadId, threadName, mqDto.getSequence(), mqDto.getTag());
                 if (Objects.nonNull(mqDto.getAck()) && mqDto.getAck().intValue() != SystemConstant.STANDARD_ACK_TYPE && Objects.nonNull(redisUtil.getMqTopicList(SystemConstant.TASKLOG_TOPIC_BUFFER_LIST, mqDto.getId())) && redisUtil.lock(SystemConstant.REDIS_LOCK_MQ_PREFIX, mqDto.getId(), SystemConstant.REDIS_LOCK_MQ_TIME_OUT, TimeUnit.SECONDS)) {
-                    MqDto finalMqDto = mqDto;
+                    Map<String, Object> map = (Map<String, Object>) mqDto.getBody();
                     myThreadPool.arbitratePoolTaskExecutor.execute(() -> {
                         TaskImportTemplete examStudentTemplete = new TaskExamStudentTemplete();
                         try {
-                            Object o = finalMqDto.getBody();
-                            examStudentTemplete.importTask((Map<String, Object>) o);
+                            examStudentTemplete.importTask(map);
                         } catch (IOException e) {
                             e.printStackTrace();
                         }