opt;

liquidnet-bus-common/liquidnet-common-service-base/src/main/java/com/liquidnet/service/base/SmsMessage.java

@@ -12,6 +12,17 @@ public class SmsMessage implements Serializable, Cloneable {
     private String templateCode;
     private ObjectNode templateParam;
 
+    public SmsMessage() {
+    }
+
+    public SmsMessage(String json) {
+        SmsMessage smsMessage = JsonUtils.fromJson(json, SmsMessage.class);
+        this.phone = smsMessage.getPhone();
+        this.signName = smsMessage.getSignName();
+        this.templateCode = smsMessage.getTemplateCode();
+        this.templateParam = smsMessage.getTemplateParam();
+    }
+
     public String getPhone() {
         return phone;
     }
@@ -60,4 +71,8 @@ public class SmsMessage implements Serializable, Cloneable {
         this.templateParam.put(key, val);
         return this;
     }
+
+    public String toJson() {
+        return JsonUtils.toJson(this);
+    }
 }

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamLoginController.java

@@ -173,7 +173,7 @@ public class AdamLoginController {
             SmsMessage smsMessage = SmsMessage.builder().setPhone(mobile).setSignName(SmsEnum.ADSignName.正在现场.name())
                     .setTemplateCode(SmsEnum.ADTemplate.SMS_109535335.name())
                     .setTemplateParam("code", smsCode);
-            rabbitTemplate.convertAndSend(MQConst.EX_LNS_SMS_SENDER, MQConst.RK_SMS_CODE, smsMessage);
+            rabbitTemplate.convertAndSend(MQConst.EX_LNS_SMS_SENDER, MQConst.RK_SMS_CODE, smsMessage.toJson());
             adamRdmService.setSmsCodeByMobile(mobile, smsCode);
             return ResponseDto.success();
         } else {

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/service/processor/ConsumerAdamUCenterProcessor.java

@@ -68,8 +68,8 @@ public class ConsumerAdamUCenterProcessor {
         log.info("CONSUMER SQL ==> [consumerQueue:{},deliveryTag:{}]", consumerQueue, deliveryTag);
         String msgBody = new String(msg.getBody());
         log.debug("CONSUMER SQL ==> Preparing:{}", msgBody);
-        SqlMapping.SqlMessage sqlMessage = JsonUtils.fromJson(msgBody, SqlMapping.SqlMessage.class);
         try {
+            SqlMapping.SqlMessage sqlMessage = JsonUtils.fromJson(msgBody, SqlMapping.SqlMessage.class);
             Boolean rstBatchSqls = baseDao.batchSqls(sqlMessage.getSqls(), sqlMessage.getArgs());
             log.debug("CONSUMER SQL result of execution:{}", rstBatchSqls);
             if (rstBatchSqls) {
@@ -90,8 +90,8 @@ public class ConsumerAdamUCenterProcessor {
         log.info("CONSUMER SMS ==> [consumerQueue:{},deliveryTag:{}]", consumerQueue, deliveryTag);
         String msgBody = new String(msg.getBody());
         log.debug("CONSUMER SMS ==> Preparing:{}", msgBody);
-        SmsMessage smsMessage = JsonUtils.fromJson(msgBody, SmsMessage.class);
         try {
+            SmsMessage smsMessage = JsonUtils.fromJson(msgBody, SmsMessage.class);
             boolean result = smsProcessor.aliyunDysmsSend(smsMessage.getPhone(), smsMessage.getSignName(), smsMessage.getTemplateCode(), smsMessage.getTemplateParam().toString());
             log.debug("CONSUMER SMS result of execution:{}", result);
             if (result) {