构建mq延时消息公用

themis-business/src/main/java/com/qmth/themis/business/service/impl/TOeExamRecordServiceImpl.java

@@ -36,8 +36,6 @@ import javax.annotation.Resource;
 import java.io.File;
 import java.math.BigDecimal;
 import java.text.SimpleDateFormat;
-import java.time.LocalDateTime;
-import java.time.ZoneOffset;
 import java.util.*;
 
 /**
@@ -1187,17 +1185,8 @@ public class TOeExamRecordServiceImpl extends ServiceImpl<TOeExamRecordMapper, T
                     }
                 }
             }
-            Map<String, Object> tranMap = new HashMap<>();
-            Integer time = SystemConstant.mqDelayLevel.get(level);
-            LocalDateTime dt = LocalDateTime.now();
-            if (level.contains("m")) {
-                dt = dt.plusMinutes(Long.parseLong(level.replace("m", "")));
-            } else {
-                dt = dt.plusSeconds(Long.parseLong(level.replace("s", "")));
-            }
+            Map<String, Object> tranMap = mqDtoService.buildMqDelayMsg(level);
             tranMap.put("recordId", recordId);
-            tranMap.put("timeOut", time);
-            tranMap.put("mqExecTime", dt.toInstant(ZoneOffset.of("+8")).toEpochMilli());
             //考试断点延时消息 发送mq start
             MqDto mqDtoBreakDelay = new MqDto(mqUtil.getMqGroupDomain().getTopic(),
                     MqTagEnum.EXAM_BREAK_DELAY.name(), MqTagEnum.EXAM_BREAK_DELAY, MqTagEnum.EXAM_BREAK_DELAY,