|
|
@ -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.doudian.open.api.supplyCenter_refund_operate.param.SupplyCenterRefundOperateParam;
|
|
|
|
import com.ms.biz.consts.DsMessageConst;
|
|
|
|
import com.ms.biz.consts.DsMessageConst;
|
|
|
|
import com.ms.biz.consts.PurchaseOrderConst;
|
|
|
|
import com.ms.biz.consts.PurchaseOrderConst;
|
|
|
|
|
|
|
|
import com.ms.biz.consts.Refund1688Const;
|
|
|
|
import com.ms.biz.consts.StatusConst;
|
|
|
|
import com.ms.biz.consts.StatusConst;
|
|
|
|
import com.ms.biz.dto.openspi.request.SkuOrder;
|
|
|
|
import com.ms.biz.dto.openspi.request.SkuOrder;
|
|
|
|
import com.ms.biz.service.DsMessageConsumerBufferService;
|
|
|
|
import com.ms.biz.service.DsMessageConsumerBufferService;
|
|
|
@ -235,6 +236,8 @@ public class DsMessageServiceImpl implements DsMessageService {
|
|
|
|
throw new RuntimeException("时间格式错误");
|
|
|
|
throw new RuntimeException("时间格式错误");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
handlePurchaseOrderRefund(purchaseOrderDTO, purchaseOrder, skuIdAndPlatformPurchaseOrderSkuMap);
|
|
|
|
|
|
|
|
|
|
|
|
if (!Objects.equals(purchaseOrder.getPurchaseOrderStatus(),purchaseOrderStatus)){
|
|
|
|
if (!Objects.equals(purchaseOrder.getPurchaseOrderStatus(),purchaseOrderStatus)){
|
|
|
|
switch (purchaseOrderStatus) {
|
|
|
|
switch (purchaseOrderStatus) {
|
|
|
|
case PurchaseOrderConst.PURCHASE_ORDER_STATUS_WAIT_SEND:
|
|
|
|
case PurchaseOrderConst.PURCHASE_ORDER_STATUS_WAIT_SEND:
|
|
|
@ -263,7 +266,6 @@ public class DsMessageServiceImpl implements DsMessageService {
|
|
|
|
purchaseOrderItemMapper.updateStatusByPurchaseOrderIds(StatusConst.delete, Collections.singletonList(purchaseOrder.getPurchaseOrderId()));
|
|
|
|
purchaseOrderItemMapper.updateStatusByPurchaseOrderIds(StatusConst.delete, Collections.singletonList(purchaseOrder.getPurchaseOrderId()));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
handlePurchaseOrderRefund(purchaseOrderDTO, purchaseOrder, skuIdAndPlatformPurchaseOrderSkuMap);
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private void handlePurchaseOrderAfterPay(PurchaseOrderDTO purchaseOrderDTO, Date messageCreateTime, PurchaseOrder purchaseOrder, Map<Long, PlatformPurchaseOrderSku> skuIdAndPlatformPurchaseOrderSkuMap) {
|
|
|
|
private void handlePurchaseOrderAfterPay(PurchaseOrderDTO purchaseOrderDTO, Date messageCreateTime, PurchaseOrder purchaseOrder, Map<Long, PlatformPurchaseOrderSku> skuIdAndPlatformPurchaseOrderSkuMap) {
|
|
|
@ -349,6 +351,15 @@ public class DsMessageServiceImpl implements DsMessageService {
|
|
|
|
DDApi.supplyCenterRefundOperate(param);
|
|
|
|
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) {
|
|
|
|
private void handlePurchaseOrderCancel(PurchaseOrderCancelMessageDTO messageDTO) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|