修改mq消息的位置

clx-performance-web/src/main/java/com/clx/performance/listener/SendCarrierInternalMessageListener.java

@@ -4,7 +4,7 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.TypeReference;
 import com.clx.performance.common.MqWrapper;
 import com.clx.performance.constant.RabbitKeyConstants;
-import com.clx.performance.dto.InternalMessageDTO;
+import com.clx.performance.param.mq.InternalMessageParam;
 import com.clx.performance.service.SendInternalMessageService;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -28,8 +28,8 @@ public class SendCarrierInternalMessageListener {
     public void onMessage(Message message) {
         try{
             log.info("监听到承运发送站内信开始，消息内容{}", new String(message.getBody()));
-            InternalMessageDTO data = JSON.parseObject(new String(message.getBody()),
-                    new TypeReference<MqWrapper<InternalMessageDTO>>() {
+            InternalMessageParam data = JSON.parseObject(new String(message.getBody()),
+                    new TypeReference<MqWrapper<InternalMessageParam>>() {
                     }).getData();
 
             sendInternalMessageService.sendCarrierInternalMessage(data);

clx-performance-web/src/main/java/com/clx/performance/service/SendInternalMessageService.java

 package com.clx.performance.service;
 
-import com.clx.performance.dto.InternalMessageDTO;
+import com.clx.performance.param.mq.InternalMessageParam;
 
 import java.util.List;
 
@@ -10,5 +10,5 @@ public interface SendInternalMessageService {
     void sendInternalMessageMq(String productCode,String businessType, Integer typeCode, List<String> variableList, Long userNo);
 
     //发送承运站内信
-    void sendCarrierInternalMessage(InternalMessageDTO internalMessageDTO);
+    void sendCarrierInternalMessage(InternalMessageParam internalMessageDTO);
 }

clx-performance-web/src/main/java/com/clx/performance/service/impl/SendInternalMessageServiceImpl.java

@@ -3,12 +3,10 @@ package com.clx.performance.service.impl;
 import com.alibaba.fastjson.JSON;
 import com.clx.performance.common.MqWrapper;
 import com.clx.performance.config.ConfiguredOpenProperties;
-import com.clx.performance.dto.InternalMessageDTO;
 import com.clx.performance.enums.InternalMessageTemplateEnum;
-import com.clx.performance.enums.ResultEnum;
+import com.clx.performance.param.mq.InternalMessageParam;
 import com.clx.performance.service.SendInternalMessageService;
 import com.msl.common.base.PageData;
-import com.msl.common.exception.ServiceSystemException;
 import com.msl.common.open.ConfiguredOpenClient;
 import com.msl.common.result.Result;
 import com.msl.message.in.app.api.content.DefaultMessageContent;
@@ -61,14 +59,14 @@ public class SendInternalMessageServiceImpl implements SendInternalMessageServic
 
     @Override
     public void sendInternalMessageMq(String productCode,String businessType, Integer typeCode, List<String> variableList, Long userNo){
-        InternalMessageDTO dto = new InternalMessageDTO();
-        dto.setBusinessType(businessType);
-        dto.setTypeCode(typeCode);
-        dto.setVariableList(variableList);
-        dto.setUserNo(userNo);
-        dto.setProductCode(productCode);
-        log.info("发送站内信消息开始,站内信业务类型{}，实际业务Code：{},消息内容:{}", businessType,typeCode,JSON.toJSONString(dto));
-        Message body = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(dto)).getBytes()).build();
+        InternalMessageParam param = new InternalMessageParam();
+        param.setBusinessType(businessType);
+        param.setTypeCode(typeCode);
+        param.setVariableList(variableList);
+        param.setUserNo(userNo);
+        param.setProductCode(productCode);
+        log.info("发送站内信消息开始,站内信业务类型{}，实际业务Code：{},消息内容:{}", businessType,typeCode,JSON.toJSONString(param));
+        Message body = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(param)).getBytes()).build();
         rabbitTemplate.send(SEND_CARRIER_INTERNAL_MESSAGE_EXCHANGE,
                 SEND_CARRIER_INTERNAL_MESSAGE_ROUTING_KEY, body);
         log.info("发送站内信消息结束,站内信业务类型{}，实际业务Code：{},", businessType,typeCode);
@@ -109,7 +107,7 @@ public class SendInternalMessageServiceImpl implements SendInternalMessageServic
 
     //发送承运站内信
     @Override
-    public void sendCarrierInternalMessage(InternalMessageDTO internalMessageDTO) {
+    public void sendCarrierInternalMessage(InternalMessageParam internalMessageDTO) {
 
         Map<Integer, String> businessRelationMap = InternalMessageTemplateEnum.businessTypeMap.get(
                 internalMessageDTO.getBusinessType());

clx-performance-web/src/main/java/com/clx/performance/dto/InternalMessageDTO.java → performance-api/src/main/java/com/clx/performance/param/mq/InternalMessageParam.java

-package com.clx.performance.dto;
+package com.clx.performance.param.mq;
 
 import lombok.Getter;
 import lombok.Setter;
@@ -14,7 +14,7 @@ import java.util.List;
  */
 @Getter
 @Setter
-public class InternalMessageDTO {
+public class InternalMessageParam {
     //站内信大类业务code
     private String businessType;