dfy tongbu

SpringBatchServiceClient/src/main/java/com/zswl/cloud/springBatch/client/model/dfy/pub/SyncRequest.java

@@ -0,0 +1,26 @@
+package com.zswl.cloud.springBatch.client.model.dfy.pub;
+
+import com.zswl.cloud.springBatch.client.model.dfy.DfyBaseData;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class SyncRequest {
+    private String apiKey;
+    private String sign;
+    private String timestamp;
+    private Datas data;
+
+    @Data
+    @AllArgsConstructor
+    @NoArgsConstructor
+    public static class Datas {
+
+        private String orderId;
+
+
+    }
+}

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/controller/SycController.java

@@ -1,16 +1,19 @@
 package com.zswl.cloud.springBtach.server.core.controller;
 
+import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
 import com.xiaoju.open.oil.commons.OilRequest;
 import com.xiaoju.open.oil.core.executor.ResponseDTO;
 import com.zhongshu.payment.client.model.order.v2.UpdateGoodsModel;
 import com.zhongshu.payment.client.service.v2.OrderService2;
+import com.zswl.cloud.springBatch.client.model.dfy.pub.SyncRequest;
 import com.zswl.cloud.springBtach.server.core.api.video.YqdSyncOrderModel;
 import com.zswl.cloud.springBtach.server.core.dao.ApiLogDao;
 import com.zswl.cloud.springBtach.server.core.domain.ApiLog;
 import com.zswl.cloud.springBtach.server.core.service.XiaoJuService;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.log4j.Log4j2;
+import org.bson.json.JsonObject;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -64,4 +67,21 @@ public class SycController {
         apiLogDao.save(apiLog);
         return "ok";
     }
+
+
+    @ApiOperation("dfy订单同步")
+    @RequestMapping(value = "dfy/orderState", method = RequestMethod.POST)
+    public JSONObject dd(@RequestBody SyncRequest syncRequest) {
+        ApiLog apiLog = new ApiLog();
+        apiLog.setSystem("dfy");
+        apiLog.setRequest(JSONUtil.toJsonStr(syncRequest));
+        apiLog.setService("sync");
+        JSONObject entries = new JSONObject();
+        entries.set("success", "true");
+        entries.set("msg", "成功执行");
+        entries.set("errorCode", "200");
+        apiLog.setResponse(JSONUtil.toJsonStr(entries));
+        apiLogDao.save(apiLog);
+        return entries;
+    }
 }