websocket消息逻辑整理

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

@@ -193,13 +193,7 @@ public class MqLogicServiceImpl implements MqLogicService {
         if (Objects.isNull(tbSession)) {
             throw new BusinessException("缓存session为空");
         }
-//        tmRocketMessageService.saveMqMessageSuccess(mqDto, key);
-        mqDto.setAck(SystemConstant.STANDARD_ACK_TYPE);
-        Gson gson = new Gson();
-        TMRocketMessage tmRocketMessage = gson.fromJson(gson.toJson(mqDto), TMRocketMessage.class);
-        tmRocketMessage.setBody(JacksonUtil.parseJson(tmRocketMessage.getBody()));
-        tmRocketMessageService.saveOrUpdate(tmRocketMessage);
-        redisUtil.delete(key, mqDto.getId());
+        tmRocketMessageService.saveMqMessageSuccess(mqDto, key);
     }
 
     /**