添加积分消息队列接口

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

@@ -141,23 +141,23 @@ public class OrderPayBiz extends BaseBiz<OrderPayMapper,OrderPay> {
         log.error("---支付回调处理---num====="+num+"----orderNo======="+orderNo);
         if(num>0){
             //支付成功，添加积分
-            if(orderPay.getStatus() == 1) {
+            OrderPay pay= list.get(0);
+            if(pay.getStatus() == 1) {
                 JSONObject jsonObject = new JSONObject();
-                jsonObject.put("userId", orderPay.getUserId());
-                jsonObject.put("amount", orderPay.getAmount());
-                jsonObject.put("channelId", orderPay.getOrderNo());
-                if(orderPay.getChannel() == 1) {//租车
+                jsonObject.put("userId", pay.getUserId());
+                jsonObject.put("amount", pay.getAmount());
+                jsonObject.put("channelId", pay.getOrderNo());
+                if(pay.getChannel() == 1) {//租车
                     jsonObject.put("integralRuleCode", "RENTRV");
-                } else if(orderPay.getChannel() == 2) { //旅游
+                } else if(pay.getChannel() == 2) { //旅游
                     jsonObject.put("integralRuleCode", "BUYROUT");
-                } else if(orderPay.getChannel() == 3) {  //会员
+                } else if(pay.getChannel() == 3) {  //会员
                     jsonObject.put("integralRuleCode", "BUYMEMBER");
                 }
-                log.info("支付订单号：orderNo = {}, orderType = {}", orderPay.getOrderNo(), orderPay.getChannel());
+                log.info("支付订单号：orderNo = {}, orderType = {}", pay.getOrderNo(), pay.getChannel());
                 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());
             }
-            OrderPay pay= list.get(0);
             if(StringUtils.isNotBlank(pay.getNotifyUrl())){
                 String url=pay.getNotifyUrl();
                 Integer type=pay.getType()==null?1:pay.getType();