Add#轮训mq

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

@@ -388,20 +388,20 @@ public class OrderServiceImpl implements Orderservice {
      * @param fmId
      * @param orderId
      */
-    //public void putDelMq(String partnerId, String storeId, String fmId, String orderId,Integer payChanelType) {
-    //    PaymentMqMessageDto dto = new PaymentMqMessageDto();
-    //    try {
-    //        dto.setFmId(fmId);
-    //        dto.setOrderId(orderId);
-    //        dto.setPartnerId(partnerId);
-    //        dto.setStoreId(storeId);
-    //        dto.setPayChannelType(payChanelType);
-    //        dto.setTrackingNo(LogThreadLocal.getTrackingNo());
-    //        paymentQueueService.paymentCallback(dto);
-    //    } catch (Exception e) {
-    //        log.info("paymentQueueService.paymentCallback" + dto + " error" + e);
-    //    }
-    //}
+    public void putDelMq(String partnerId, String storeId, String fmId, String orderId,Integer payChanelType) {
+        PaymentMqMessageDto dto = new PaymentMqMessageDto();
+        try {
+            dto.setFmId(fmId);
+            dto.setOrderId(orderId);
+            dto.setPartnerId(partnerId);
+            dto.setStoreId(storeId);
+            dto.setPayChannelType(payChanelType);
+            dto.setTrackingNo(LogThreadLocal.getTrackingNo());
+            paymentQueueService.paymentCallback(dto);
+        } catch (Exception e) {
+            log.info("paymentQueueService.paymentCallback" + dto + " error" + e);
+        }
+    }
     @Override
     public String paySuccessCallback(PaysuccessNoticeMessage message, ConfirmOrderDto confirmOrderDto, Map<String, QueryOrdersResponseDto.DataBean.OrderBean> orderBeans) {
         OrderBean orderBean = orderBeans.get(OrderBeanType.SAASORDER.getCode());
@@ -3230,11 +3230,11 @@ public class OrderServiceImpl implements Orderservice {
                     /**
                      * 加入轮训队列
                      */
-                    //putDelMq(createPrepayRequestDto.getPartnerId()
-                    //        , createPrepayRequestDto.getStoreId()
-                    //        , orderPayResponse.getFmId()
-                    //        ,createPrepayRequestDto.getTransId()
-                    //        , PayChannelType.getByEbcode(payPlatform.getEbCode()).getIndex().intValue());
+                    putDelMq(createPrepayRequestDto.getPartnerId()
+                            , createPrepayRequestDto.getStoreId()
+                            , orderPayResponse.getFmId()
+                            , createPrepayRequestDto.getTransId()
+                            , PayChannelType.getByEbcode(payPlatform.getEbCode()).getIndex().intValue());
 
                 }
             }