Commit b6319a03 by rui.zhu

Merge branch 'master' into feature/rui.zhu/退款接口逻辑调整

# Conflicts:
#	order-application-service/src/main/java/cn/freemud/service/RefundService.java
parents cb52e1b2 842a7544
...@@ -104,7 +104,7 @@ public class OrderCallBackMQService { ...@@ -104,7 +104,7 @@ public class OrderCallBackMQService {
this.sendOrderStatusProcessCenterMQ(body); this.sendOrderStatusProcessCenterMQ(body);
//支付宝订单状态变更上报 //支付宝订单状态变更上报
sendzfbOrderMQ(body); // sendzfbOrderMQ(body);
} }
/** /**
...@@ -410,25 +410,25 @@ public class OrderCallBackMQService { ...@@ -410,25 +410,25 @@ public class OrderCallBackMQService {
} }
} }
private void sendzfbOrderMQ(OrderCallBackRequestVo body) { // private void sendzfbOrderMQ(OrderCallBackRequestVo body) {
try { // try {
if (Objects.isNull(body) || StringUtils.isEmpty(body.getContent())) { // if (Objects.isNull(body) || StringUtils.isEmpty(body.getContent())) {
return; // return;
} // }
if (OrderClientType.ALIPAY.getIndex() != body.getOrderClient()) { // if (OrderClientType.ALIPAY.getIndex() != body.getOrderClient()) {
return; // return;
} // }
logUtil.info("sendzfbOrderMQ orderCode:{} ", body.getOrderCode()); // logUtil.info("sendzfbOrderMQ orderCode:{} ", body.getOrderCode());
//
// 支付宝订单状态推送 tapd需求id 1032865 // // 支付宝订单状态推送 tapd需求id 1032865
if ("1".equals(body.getMsgType())) { // if ("1".equals(body.getMsgType())) {
Header header = new Header(MQAction.UPDATE.getAction(), "call-back-service-api", // Header header = new Header(MQAction.UPDATE.getAction(), "call-back-service-api",
null, OrderCallBackConfig.ZFB_ORDER_SEND_QUEUE); // null, OrderCallBackConfig.ZFB_ORDER_SEND_QUEUE);
MQMessage<OrderCallBackRequestVo> message = new MQMessage<>(header, body); // MQMessage<OrderCallBackRequestVo> message = new MQMessage<>(header, body);
mqService.convertAndSend(OrderCallBackConfig.TOPIC_EXCHANGE_NAME, OrderCallBackConfig.ZFB_ORDER_SEND_QUEUE_ROUTING_KEY, message); // mqService.convertAndSend(OrderCallBackConfig.TOPIC_EXCHANGE_NAME, OrderCallBackConfig.ZFB_ORDER_SEND_QUEUE_ROUTING_KEY, message);
} // }
} catch (Exception e) { // } catch (Exception e) {
logUtil.error("", "sendzfbOrderMQ orderCode:{} ", e, body.getOrderCode()); // logUtil.error("", "sendzfbOrderMQ orderCode:{} ", e, body.getOrderCode());
} // }
} // }
} }
...@@ -45,6 +45,7 @@ import com.freemud.application.sdk.api.ordercenter.response.orderInfo.QueryByCod ...@@ -45,6 +45,7 @@ import com.freemud.application.sdk.api.ordercenter.response.orderInfo.QueryByCod
import com.freemud.application.sdk.api.ordercenter.service.OrderSdkService; import com.freemud.application.sdk.api.ordercenter.service.OrderSdkService;
import com.freemud.application.sdk.api.structure.request.PushMessageNoticeDto; import com.freemud.application.sdk.api.structure.request.PushMessageNoticeDto;
import com.freemud.application.sdk.api.structure.service.MessageCenterClient; import com.freemud.application.sdk.api.structure.service.MessageCenterClient;
import com.freemud.sdk.api.assortment.order.adapter.OrderSdkAdapter;
import com.freemud.sdk.api.assortment.order.constant.OrderRedisKeyConstant; import com.freemud.sdk.api.assortment.order.constant.OrderRedisKeyConstant;
import com.freemud.sdk.api.assortment.order.entities.OrderRefundConfigEntity; import com.freemud.sdk.api.assortment.order.entities.OrderRefundConfigEntity;
import com.freemud.sdk.api.assortment.order.enums.AutoOrderConfigTime; import com.freemud.sdk.api.assortment.order.enums.AutoOrderConfigTime;
...@@ -76,6 +77,7 @@ public class RefundService { ...@@ -76,6 +77,7 @@ public class RefundService {
private final OrderSdkService orderSdkService; private final OrderSdkService orderSdkService;
private final RedisCache redisCache; private final RedisCache redisCache;
private final PaymentHandle paymentHandle; private final PaymentHandle paymentHandle;
private final OrderSdkAdapter orderSdkAdapter;
private final OrderCenterSdkService orderCenterSdkService; private final OrderCenterSdkService orderCenterSdkService;
private final OrderQueueService orderQueueService; private final OrderQueueService orderQueueService;
private final EcologyAdminApplicationClient ecologyAdminApplicationClient; private final EcologyAdminApplicationClient ecologyAdminApplicationClient;
...@@ -144,7 +146,7 @@ public class RefundService { ...@@ -144,7 +146,7 @@ public class RefundService {
if (NewOrderStatus.PLACE_AN_ORDER.getIndex().equals(order.getOrderState())) { if (NewOrderStatus.PLACE_AN_ORDER.getIndex().equals(order.getOrderState())) {
// 商家未接单逻辑处理 1.调用支付退款 2.根据支付退款返回状态组装订单取消参数,调用订单取消接口 // 商家未接单逻辑处理 1.调用支付退款 2.根据支付退款返回状态组装订单取消参数,调用订单取消接口
refundOrder(order, isPartRefund, reason, remark, refundDeliveryFee, refundMode); refundOrder(order, isPartRefund, reason, remark, refundDeliveryFee, refundMode);
orderQueueService.backOrdersStatusChange(order.getOrderCode(), order.getOrderState(), order.getPayState(), order.getPartnerId()); orderQueueService.backOrdersStatusChange(order.getOrderCode(), orderSdkAdapter.getOldStatus(order.getOrderState()), order.getPayState(), order.getPartnerId());
} else { } else {
// 已接单的,创建售后单 // 已接单的,创建售后单
createAfterSales(order, refundAmount, isPartRefund, reason, remark, refundDeliveryFee, refundMode); createAfterSales(order, refundAmount, isPartRefund, reason, remark, refundDeliveryFee, refundMode);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment