数据同步

performance-web/src/main/java/com/clx/performance/controller/temp/TempController.java

 package com.clx.performance.controller.temp;
 
-import com.clx.open.sdk.request.action.SyncOrderChildAction;
+import com.clx.open.sdk.callback.message.OrderChildSyncMessage;
 import com.clx.performance.extranal.transport.TransportService;
 import com.clx.performance.feign.TransportFeignService;
 import com.clx.performance.listener.OrderChildDtsListener;
@@ -43,8 +43,9 @@ public class TempController {
     @RequestMapping(value = "/test", method = RequestMethod.GET)
     public Result test() {
 
-        SyncOrderChildAction action = new SyncOrderChildAction();
-        orderChildDtsListener.thirdpartySync(action);
+        OrderChildSyncMessage message = new OrderChildSyncMessage();
+        message.setId(1);
+        orderChildDtsListener.thirdpartySync(message);
         return Result.ok();
     }
 

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

@@ -3,9 +3,8 @@ package com.clx.performance.listener;
 import com.alibaba.fastjson.JSON;
 import com.clx.open.sdk.callback.OpenCallBackClient;
 import com.clx.open.sdk.callback.message.OrderChildMessage;
+import com.clx.open.sdk.callback.message.OrderChildSyncMessage;
 import com.clx.open.sdk.enums.ResultStatusEnum;
-import com.clx.open.sdk.request.OpenRequestClient;
-import com.clx.open.sdk.request.action.SyncOrderChildAction;
 import com.clx.order.enums.OrderEnum;
 import com.clx.order.enums.SyncPlatformEnum;
 import com.clx.order.feign.OrderFeign;
@@ -59,7 +58,7 @@ public class OrderChildDtsListener  {
             OrderChildMessage before = DtsMapConvertUtil.convert(dataTransportDTO.getBeforeMap(), new OrderChildMessage());
             OrderChildMessage after = DtsMapConvertUtil.convert(dataTransportDTO.getAfterMap(), new OrderChildMessage());
 
-            thirdpartySync(DtsMapConvertUtil.convert(dataTransportDTO.getAfterMap(), new SyncOrderChildAction()));
+            thirdpartySync(DtsMapConvertUtil.convert(dataTransportDTO.getAfterMap(), new OrderChildSyncMessage()));
 
             if(Objects.equals(DtsOperationTypeEnum.INSERT.getCode(),dataTransportDTO.getOperationType().getCode())){
                 //同步after数据
@@ -143,7 +142,7 @@ public class OrderChildDtsListener  {
     /**
      * 第三方同步
      */
-    public void thirdpartySync(SyncOrderChildAction action){
+    public void thirdpartySync(OrderChildSyncMessage message){
 //        FeignOrderVO orderInfoFeign = orderFeign.getOrderInfoFeign("");
 //        if (orderInfoFeign == null) {
 //            return;
@@ -154,15 +153,15 @@ public class OrderChildDtsListener  {
 //        }
 
         try{
-            OpenRequestClient openRequestClient = thirdAppConfig.getOpenRequestClient(SyncPlatformEnum.Source.NEW_OWNER_CLIENT.getCode().toString());
-            log.info("运单同步:{}", action.getId());
-            Result<String> result = openRequestClient.doAction(action);
+            OpenCallBackClient openCallBackClient = thirdAppConfig.getOpenCallBackClient(SyncPlatformEnum.Source.NEW_OWNER_CLIENT.getCode().toString());
+            log.info("运单同步:{}", message.getId());
+            Result<?> result = openCallBackClient.encryptPost(JSON.toJSONString(message), message.topic());
             if (result.succeed()) {
-                log.info("运单同步成功:{}", action.getId());
+                log.info("运单同步成功:{}", message.getId());
 
 
             }else{
-                log.info("运单同步失败:{}", action.getId());
+                log.info("运单同步失败:{}", message.getId());
             }
 
         }catch (Exception e){