gongfuzhu 1 gadu atpakaļ
vecāks
revīzija
c8775203c2

+ 12 - 3
SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/controller/SycController.java

@@ -71,17 +71,26 @@ public class SycController {
 
     @ApiOperation("dfy订单同步")
     @RequestMapping(value = "dfy/orderState", method = RequestMethod.POST)
-    public JSONObject dd(@RequestBody JSONObject syncRequest) {
+    public JSONObject dfyOrderState(@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("success", true);
         entries.set("msg", "成功执行");
-        entries.set("errorCode", "200");
+        entries.set("errorCode", 200);
         apiLog.setResponse(JSONUtil.toJsonStr(entries));
         apiLogDao.save(apiLog);
+
+
+switch (syncRequest.getApiKey()){
+    case "248186_Ticket":
+
+}
+
+
+
         return entries;
     }
 }

+ 31 - 4
SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/service/impl/DfyHotelServiceImpl.java

@@ -6,12 +6,11 @@ import cn.hutool.json.JSONUtil;
 import com.github.microservice.auth.client.content.ResultContent;
 import com.github.microservice.auth.client.content.ResultState;
 import com.github.microservice.auth.security.helper.AuthHelper;
-import com.zhongshu.payment.client.model.order.v2.CreatOrderResultModel;
-import com.zhongshu.payment.client.model.order.v2.CreateOrder2Model;
-import com.zhongshu.payment.client.model.order.v2.GoodsResultModel;
+import com.zhongshu.payment.client.model.order.v2.*;
 import com.zhongshu.payment.client.service.v2.OrderService2;
 import com.zhongshu.payment.client.service.v2.PaymentService2;
 import com.zhongshu.payment.client.type.JobFlowMap;
+import com.zhongshu.payment.client.type.OrderType;
 import com.zhongshu.payment.client.type.TransferOwner;
 import com.zhongshu.payment.client.type.TransferType;
 import com.zswl.cloud.shop.client.service.ShopService;
@@ -193,7 +192,35 @@ public class DfyHotelServiceImpl implements DfyHotelService {
     }
 
     public ResultContent<OrderDetailResponse> orderDetail(OrderDetailRequest orderDetailRequest) {
-        return ResultContent.buildContent(domesticHotelApi.orderDetail(orderDetailRequest));
+        ResultContent<GoodsResultModel> goodsResultModelResultContent = orderService2.dfyHotelOrder(orderDetailRequest.getOrderId());
+        GoodsResultModel goodsResultModel = goodsResultModelResultContent.getContent();
+        OrderDetailResponse orderDetailResponse = domesticHotelApi.orderDetail(orderDetailRequest);
+        if (orderDetailResponse.getSuccess()) {
+            String orderStatus = orderDetailResponse.getData().getOrderInfo().getOrderStatus();
+            switch (orderStatus) {
+                case "已取消":
+                    UpdateOrder2Model updateOrder2Model = new UpdateOrder2Model();
+                    updateOrder2Model.setOrderType(OrderType.CLOSE);
+                    updateOrder2Model.setOrderNo(goodsResultModel.getOrderNo());
+                    orderService2.updateOrderType(updateOrder2Model);
+                    UpdateGoodsModel updateGoodsModel1 = new UpdateGoodsModel();
+                    updateGoodsModel1.setGoodsState(OrderType.CLOSE);
+                    orderService2.updateGoods(updateGoodsModel1);
+                    break;
+                case "已完成":
+                    UpdateGoodsModel updateGoodsModel = new UpdateGoodsModel();
+                    updateGoodsModel.setGoodsState(OrderType.USED);
+                    orderService2.updateGoods(updateGoodsModel);
+                    break;
+
+            }
+
+
+            return ResultContent.build(ResultState.Success, orderDetailResponse);
+        }
+
+
+        return ResultContent.build(ResultState.Fail, orderDetailResponse.getMsg());
     }
 
     public ResultContent<SubmitOrderResponse> submitOrder(SubmitOrderRequest submitOrderRequest) {

+ 23 - 4
SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/service/impl/DfyTicketServiceImpl.java

@@ -7,13 +7,11 @@ import cn.hutool.json.JSONUtil;
 import com.github.microservice.auth.client.content.ResultContent;
 import com.github.microservice.auth.client.content.ResultState;
 import com.github.microservice.auth.security.helper.AuthHelper;
-import com.zhongshu.payment.client.model.order.v2.ApplicantRefundParam2Model;
-import com.zhongshu.payment.client.model.order.v2.CreatOrderResultModel;
-import com.zhongshu.payment.client.model.order.v2.CreateOrder2Model;
-import com.zhongshu.payment.client.model.order.v2.GoodsResultModel;
+import com.zhongshu.payment.client.model.order.v2.*;
 import com.zhongshu.payment.client.service.v2.OrderService2;
 import com.zhongshu.payment.client.service.v2.PaymentService2;
 import com.zhongshu.payment.client.type.JobFlowMap;
+import com.zhongshu.payment.client.type.OrderType;
 import com.zhongshu.payment.client.type.TransferOwner;
 import com.zhongshu.payment.client.type.TransferType;
 import com.zswl.cloud.shop.client.dto.life.TripartiteShopDto;
@@ -190,8 +188,29 @@ public class DfyTicketServiceImpl implements DfyTicketService {
 
 
     public ResultContent<OrderDetailResponse> orderDetail(OrderDetailRequest orderDetailRequest) {
+        ResultContent<GoodsResultModel> goodsResultModelResultContent = orderService2.dfyTicktOrder(orderDetailRequest.getOrderId());
+        GoodsResultModel goodsResultModel = goodsResultModelResultContent.getContent();
         OrderDetailResponse orderDetailResponse = ticketApi.orderDetail(orderDetailRequest);
         if (orderDetailResponse.getSuccess()) {
+            String orderStatus = orderDetailResponse.getData().getOrderStatus();
+
+            switch (orderStatus) {
+                case "已取消":
+                    UpdateOrder2Model updateOrder2Model = new UpdateOrder2Model();
+                    updateOrder2Model.setOrderType(OrderType.CLOSE);
+                    updateOrder2Model.setOrderNo(goodsResultModel.getOrderNo());
+                    orderService2.updateOrderType(updateOrder2Model);
+                    UpdateGoodsModel updateGoodsModel1 = new UpdateGoodsModel();
+                    updateGoodsModel1.setGoodsState(OrderType.CLOSE);
+                    orderService2.updateGoods(updateGoodsModel1);
+                    break;
+                case "已完成":
+                    UpdateGoodsModel updateGoodsModel = new UpdateGoodsModel();
+                    updateGoodsModel.setGoodsState(OrderType.USED);
+                    orderService2.updateGoods(updateGoodsModel);
+                    break;
+
+            }
             return ResultContent.buildContent(orderDetailResponse);
         }
         return ResultContent.build(ResultState.Fail, orderDetailResponse.getMsg());