代码整理

themis-business/src/main/java/com/qmth/themis/business/domain/TencentYunDomain.java

@@ -21,6 +21,7 @@ public class TencentYunDomain implements Serializable {
     private String secretKey;
     private Long vodAppId;
     private String callbackPwd;
+    private String callbackTime;
 
     public TencentYunDomain() {
 
@@ -34,7 +35,8 @@ public class TencentYunDomain implements Serializable {
                             String secretId,
                             String secretKey,
                             Long vodAppId,
-                            String callbackPwd) {
+                            String callbackPwd,
+                            String callbackTime) {
         this.appId = appId;
         this.key = key;
         this.urls = urls;
@@ -44,6 +46,15 @@ public class TencentYunDomain implements Serializable {
         this.secretKey = secretKey;
         this.vodAppId = vodAppId;
         this.callbackPwd = callbackPwd;
+        this.callbackTime = callbackTime;
+    }
+
+    public String getCallbackTime() {
+        return callbackTime;
+    }
+
+    public void setCallbackTime(String callbackTime) {
+        this.callbackTime = callbackTime;
     }
 
     public String getCallbackPwd() {

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

@@ -1201,9 +1201,7 @@ public class TEExamServiceImpl extends ServiceImpl<TEExamMapper, TEExam> impleme
 
         if (Objects.nonNull(monitorRecord) && !Objects.equals(monitorRecord.trim().replaceAll(" ", ""), "")) {
             //发送腾讯云回调延时mq消息start
-//            Map<String, Object> tranMap = mqDtoService.buildMqDelayMsg("1h");
-            //TODO 测试用
-            Map<String, Object> tranMap = mqDtoService.buildMqDelayMsg("10m");
+            Map<String, Object> tranMap = mqDtoService.buildMqDelayMsg(tencentYunUtil.getTencentYunDomain().getCallbackTime());
             tranMap.put(SystemConstant.RECORD_ID, recordId);
             MqDto mqDtoTencentVideo = new MqDto(mqUtil.getMqGroupDomain().getTopic(), MqTagEnum.TENCENT_VIDEO.name(), MqTagEnum.TENCENT_VIDEO.name(), MqTagEnum.TENCENT_VIDEO, String.valueOf(recordId), tranMap, String.valueOf(recordId));
             mqDtoService.assembleSendAsyncDelayMsg(mqDtoTencentVideo);

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

@@ -58,8 +58,8 @@ public class TMRocketMessageServiceImpl extends ServiceImpl<TMRocketMessageMappe
         Gson gson = new Gson();
         TMRocketMessage tmRocketMessage = gson.fromJson(gson.toJson(mqDto), TMRocketMessage.class);
         tmRocketMessage.setBody(JacksonUtil.parseJson(tmRocketMessage.getBody()));
-        tmRocketMessage.setSourceId(tmRocketMessage.getId());
-        tmRocketMessage.setId(SystemConstant.getUuid());
+//        tmRocketMessage.setSourceId(tmRocketMessage.getId());
+//        tmRocketMessage.setId(SystemConstant.getUuid());
         this.saveOrUpdate(tmRocketMessage);
         redisUtil.delete(key, mqDto.getId());
     }

themis-business/src/main/java/com/qmth/themis/business/util/TencentYunUtil.java

@@ -42,7 +42,8 @@ public class TencentYunUtil {
                 tencentYunDomain.getSecretId(),
                 tencentYunDomain.getSecretKey(),
                 tencentYunDomain.getVodAppId(),
-                tencentYunDomain.getCallbackPwd());
+                tencentYunDomain.getCallbackPwd(),
+                tencentYunDomain.getCallbackTime());
         return this.tencentYunDomain;
     }