wangliang 3 anos atrás
pai
commit
d7587004d0

+ 5 - 1
themis-mq/src/main/java/com/qmth/themis/mq/service/impl/MqLogicServiceImpl.java

@@ -18,7 +18,10 @@ import com.qmth.themis.business.service.*;
 import com.qmth.themis.business.templete.TaskExportTemplete;
 import com.qmth.themis.business.templete.TaskExportTemplete;
 import com.qmth.themis.business.templete.TaskImportTemplete;
 import com.qmth.themis.business.templete.TaskImportTemplete;
 import com.qmth.themis.business.templete.impl.*;
 import com.qmth.themis.business.templete.impl.*;
-import com.qmth.themis.business.util.*;
+import com.qmth.themis.business.util.JacksonUtil;
+import com.qmth.themis.business.util.RedisUtil;
+import com.qmth.themis.business.util.TencentYunUtil;
+import com.qmth.themis.business.util.UidUtil;
 import com.qmth.themis.common.contanst.Constants;
 import com.qmth.themis.common.contanst.Constants;
 import com.qmth.themis.common.exception.BusinessException;
 import com.qmth.themis.common.exception.BusinessException;
 import com.qmth.themis.common.util.SimpleBeanUtil;
 import com.qmth.themis.common.util.SimpleBeanUtil;
@@ -190,6 +193,7 @@ public class MqLogicServiceImpl implements MqLogicService {
         if (Objects.isNull(tbSession)) {
         if (Objects.isNull(tbSession)) {
             throw new BusinessException("缓存session为空");
             throw new BusinessException("缓存session为空");
         }
         }
+        tbSessionService.saveOrUpdate(tbSession);
         tmRocketMessageService.saveMqMessageSuccess(mqDto, key);
         tmRocketMessageService.saveMqMessageSuccess(mqDto, key);
     }
     }