DTS运单数据同步

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

@@ -6,6 +6,7 @@ import com.clx.performance.constant.RabbitKeyConstants;
 import com.clx.performance.data.OrderChildData;
 import com.msl.common.utils.DtsMapConvertUtil;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.*;
 import org.springframework.stereotype.Component;
 
@@ -16,11 +17,13 @@ public class OrderChildDtsListener  {
 
 
     @RabbitHandler
-    public void dealMessage(String message) {
+    public void dealMessage(Message message) {
         try {
-            log.info("DTS消息同步开始, database:order_service, msg:{}", message);
+            log.info("DTS消息同步开始, database:order_service, msg:{}", message.getBody());
 
-            JSONObject object = JSON.parseObject(message);
+            String msg = new String(message.getBody());
+
+            JSONObject object = JSON.parseObject(msg);
 
             JSONObject beforeMap = object.getJSONObject("beforeMap");
             JSONObject afterMap = object.getJSONObject("afterMap");