From 47b131ba09ed6bfed0188c65ff1a707d7da6a1eb Mon Sep 17 00:00:00 2001 From: ljl Date: Fri, 3 Nov 2023 19:02:20 +0800 Subject: [PATCH] yh --- .../ms/biz/service/impl/DsMessageServiceImpl.java | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/ms-biz/src/main/java/com/ms/biz/service/impl/DsMessageServiceImpl.java b/ms-biz/src/main/java/com/ms/biz/service/impl/DsMessageServiceImpl.java index 26198e4..02015a8 100644 --- a/ms-biz/src/main/java/com/ms/biz/service/impl/DsMessageServiceImpl.java +++ b/ms-biz/src/main/java/com/ms/biz/service/impl/DsMessageServiceImpl.java @@ -14,6 +14,7 @@ import com.doudian.open.api.supplyCenter_refund_operate.param.SkuRefundInfosItem import com.doudian.open.api.supplyCenter_refund_operate.param.SupplyCenterRefundOperateParam; import com.ms.biz.consts.DsMessageConst; import com.ms.biz.consts.PurchaseOrderConst; +import com.ms.biz.consts.Refund1688Const; import com.ms.biz.consts.StatusConst; import com.ms.biz.dto.openspi.request.SkuOrder; import com.ms.biz.service.DsMessageConsumerBufferService; @@ -235,6 +236,8 @@ public class DsMessageServiceImpl implements DsMessageService { throw new RuntimeException("时间格式错误"); } + handlePurchaseOrderRefund(purchaseOrderDTO, purchaseOrder, skuIdAndPlatformPurchaseOrderSkuMap); + if (!Objects.equals(purchaseOrder.getPurchaseOrderStatus(),purchaseOrderStatus)){ switch (purchaseOrderStatus) { case PurchaseOrderConst.PURCHASE_ORDER_STATUS_WAIT_SEND: @@ -263,7 +266,6 @@ public class DsMessageServiceImpl implements DsMessageService { purchaseOrderItemMapper.updateStatusByPurchaseOrderIds(StatusConst.delete, Collections.singletonList(purchaseOrder.getPurchaseOrderId())); } } - handlePurchaseOrderRefund(purchaseOrderDTO, purchaseOrder, skuIdAndPlatformPurchaseOrderSkuMap); } private void handlePurchaseOrderAfterPay(PurchaseOrderDTO purchaseOrderDTO, Date messageCreateTime, PurchaseOrder purchaseOrder, Map skuIdAndPlatformPurchaseOrderSkuMap) { @@ -349,6 +351,15 @@ public class DsMessageServiceImpl implements DsMessageService { DDApi.supplyCenterRefundOperate(param); } + private int getOperateType(String refundStatus) { + /*Refund1688Const.REFUND_STATUS_WAIT_SELLER_AGREE 0 + Refund1688Const.REFUND_STATUS_WAIT_BUYER_SEND 2 + Refund1688Const.REFUND_STATUS_WAIT_BUYER_RECEIVE 4 + Refund1688Const.REFUND_STATUS_REFUND_CLOSE 5 + Refund1688Const.REFUND_STATUS_REFUND_CLOSE 3*/ + return 0; + } + private void handlePurchaseOrderCancel(PurchaseOrderCancelMessageDTO messageDTO) { }