添加积分消息队列接口

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/biz/OrderPayBiz.java

@@ -141,17 +141,6 @@ public class OrderPayBiz extends BaseBiz<OrderPayMapper,OrderPay> {
         if(num>0){
             OrderPay pay= list.get(0);
             if(StringUtils.isNotBlank(pay.getNotifyUrl())){
-                String url=pay.getNotifyUrl();
-                Integer type=pay.getType()==null?1:pay.getType();
-                url+="&tradeNo="+orderNo+"&type="+type;
-                log.error("---支付回调处理---orderNo======="+orderNo+"----notifyUrl===="+url);
-                String result="";
-                if(url.contains("https")||url.contains("HTTPS")){
-                     result= HTTPSUtils.httpRequest(url, "GET",null);
-                }else{
-                    result= HTTPUtils.doGet(url);
-                }
-                log.error("---支付回调处理---orderNo======="+orderNo+"---result==="+result);
                 //支付成功，添加积分
                 if(pay.getStatus() == 1) {
                     JSONObject jsonObject = new JSONObject();
@@ -169,6 +158,18 @@ public class OrderPayBiz extends BaseBiz<OrderPayMapper,OrderPay> {
                     log.info("支付成功获取积分：发送消息 exchange = {}, routingKey = {}, json = {}", MQconstant.INTEGRAL_EXCHANGE, MQconstant.INTEGRAL_ROUTING_KEY, jsonObject.toJSONString());
                     mqServiceBiZ.sendMessage(MQconstant.INTEGRAL_EXCHANGE, MQconstant.INTEGRAL_ROUTING_KEY, jsonObject.toJSONString());
                 }
+                String url=pay.getNotifyUrl();
+                Integer type=pay.getType()==null?1:pay.getType();
+                url+="&tradeNo="+orderNo+"&type="+type;
+                log.error("---支付回调处理---orderNo======="+orderNo+"----notifyUrl===="+url);
+                String result="";
+                if(url.contains("https")||url.contains("HTTPS")){
+                     result= HTTPSUtils.httpRequest(url, "GET",null);
+                }else{
+                    result= HTTPUtils.doGet(url);
+                }
+                log.error("---支付回调处理---orderNo======="+orderNo+"---result==="+result);
+
             }
         }
     }