华莱士

order-application-service/src/main/java/cn/freemud/service/impl/MallOrderServiceImpl.java

@@ -4,6 +4,10 @@ import cn.freemud.adapter.DeliveryAdapter;
 import cn.freemud.adapter.LightApplicationConvertToAssortmentSdkAdapter;
 import cn.freemud.adapter.MallOrderAdapter;
 import cn.freemud.adapter.OrderAdapter;
+import cn.freemud.amqp.Header;
+import cn.freemud.amqp.MQAction;
+import cn.freemud.amqp.MQMessage;
+import cn.freemud.amqp.MQService;
 import cn.freemud.base.entity.BaseResponse;
 import cn.freemud.base.log.LogTreadLocal;
 import cn.freemud.base.util.DateUtil;
@@ -50,7 +54,9 @@ import com.freemud.application.sdk.api.deliverycenter.response.CreateDeliveryOrd
 import com.freemud.application.sdk.api.deliverycenter.response.DeliveryInfoDto;
 import com.freemud.application.sdk.api.deliverycenter.response.DeliveryResponseDto;
 import com.freemud.application.sdk.api.deliverycenter.service.DeliveryService;
+import com.freemud.application.sdk.api.log.ApiLog;
 import com.freemud.application.sdk.api.log.LogThreadLocal;
+import com.freemud.application.sdk.api.log.ThirdPartyLog;
 import com.freemud.application.sdk.api.ordercenter.enums.AfterSalesStatus;
 import com.freemud.application.sdk.api.ordercenter.enums.AfterSalesType;
 import com.freemud.application.sdk.api.ordercenter.enums.OrderClientType;
@@ -136,6 +142,11 @@ public class MallOrderServiceImpl implements MallOrderService {
     @Autowired
     private AssortmentCustomerInfoManager customerInfoManager;
 
+    @Value("${program.backorders_change_order_status_consumer_queue}")
+    private String backOrdersChangeOrderStatusConsumerQueue;
+    @Value("${program.backorders_notify_activity_exchange}")
+    private String backOrdersNotifyActivityExchange;
+
     /**
      * 创建订单
      */
@@ -402,11 +413,15 @@ public class MallOrderServiceImpl implements MallOrderService {
     }
 
     @Autowired
+    private MQService mqService;
+
+    @Autowired
     private SpellGroupOrderDataManager spellGroupOrderDataManager;
 
     @Override
     public String paySuccessCallback(PaysuccessNoticeMessage message, ConfirmOrderDto confirmOrderDto, Map<String, QueryOrdersResponseDto.DataBean.OrderBean> orderBeans) {
         QueryOrdersResponseDto.DataBean.OrderBean orderBean = orderBeans.get(OrderBeanType.SAASORDER.getCode());
+
         String partnerId = orderBean.getCompanyId();
         String userId = orderBean.getUserId();
         String storeId = orderBean.getShopId();
@@ -444,11 +459,13 @@ public class MallOrderServiceImpl implements MallOrderService {
             GroupWorkJoinResponse groupWorkJoinResponse = spellGroupOrderDataManager.groupWorkJoin(orderBean,userLoginInfoDto);
             if(!ResponseResult.SUCCESS.getCode().equals(groupWorkJoinResponse.getStatusCode()) || groupWorkJoinResponse.getResult() == null){
                 orderRefund(orderBean, groupWorkJoinResponse.getMsg());
+                backOrdersNotifyActivity(orderBean, backOrdersChangeOrderStatusConsumerQueue, backOrdersNotifyActivityExchange);
                 return gson.toJson(message);
             }
 
             if("2".equals(groupWorkJoinResponse.getResult().getGroupStatus())){
                 orderRefund(orderBean, "成团失败,退款流程");
+                backOrdersNotifyActivity(orderBean, backOrdersChangeOrderStatusConsumerQueue, backOrdersNotifyActivityExchange);
                 return gson.toJson(message);
             }
             if(StringUtils.isEmpty(orderBean.getSpellGroupCode())){
@@ -640,6 +657,31 @@ public class MallOrderServiceImpl implements MallOrderService {
         partnerNoTakeOrder(orderRefundVo, orderBean, orderBean.getOid());
     }
 
+
+    private void backOrdersNotifyActivity(QueryOrdersResponseDto.DataBean.OrderBean orderBean, String backOrdersChangeOrderStatusConsumerQueue, String backOrdersNotifyActivityExchange) {
+        if (null == orderBean || backOrdersChangeOrderStatusConsumerQueue == null || backOrdersNotifyActivityExchange == null) {
+            return;
+        }
+        String oid = orderBean.getOid();
+        Integer status = orderBean.getStatus();
+        if (StringUtils.isEmpty(oid)) {
+            return;
+        }
+        ApiLog.info("backOrdersStatusChange", oid, String.valueOf(status));
+        OrderStatusChangeRequestDto requestDto = new OrderStatusChangeRequestDto();
+        requestDto.setOid(oid);
+        requestDto.setOrderStatus(status);
+        try {
+            Header header = new Header(MQAction.INSERT.getAction(), "backOrdersStatusChange", oid, backOrdersChangeOrderStatusConsumerQueue);
+            MQMessage<OrderStatusChangeRequestDto> message = new MQMessage<>(header, requestDto);
+            mqService.convertAndSend(backOrdersNotifyActivityExchange, backOrdersChangeOrderStatusConsumerQueue, message);
+        } catch (Exception e) {
+            //TODO 邮件告警
+            ThirdPartyLog.infoConvertJson(System.currentTimeMillis(), System.currentTimeMillis(),
+                    "backOrdersStatusChangeNotify_error", backOrdersNotifyActivityExchange, backOrdersChangeOrderStatusConsumerQueue);
+        }
+    }
+
     /**
      * 商家未接单,取消订单逻辑处理    1.调用支付退款 2.根据支付退款返回状态组装订单取消参数,调用订单取消接口
      *