1.修改优先卷相关退卷操作再退款回调调用

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinRefundsStatusServiceImpl.java

@@ -484,23 +484,6 @@ public class KylinRefundsStatusServiceImpl {
 
                     continue;
                 } else {
-                    //未退款入场人数量为0才退优先卷
-                    List<KylinOrderTicketEntities> kylinOrderTicketEntities = kylinOrderTicketEntitiesMapper.selectList(
-                            Wrappers.lambdaQuery(KylinOrderTicketEntities.class).eq(KylinOrderTicketEntities::getOrderId, refund.getOrderTicketsId()).eq(KylinOrderTicketEntities::getIsPayment, 1));
-                    log.info("admin退款请求未退款入场人数量number={}",kylinOrderTicketEntities.size());
-                    if(kylinOrderTicketEntities.size()==0){
-                        //获取订单详情
-                        KylinOrderTicketVo orderTicketVo = dataUtils.getOrderTicketVo(refund.getOrderTicketsId());
-                        //退优先卷
-                        ArrayList<KylinOrderCoupons> orderCoupons = dataUtils.getOrderCoupon(refund.getOrderTicketsId());
-                        if (orderCoupons.size() > 0) {
-                            for (KylinOrderCoupons item : orderCoupons) {
-                                if (item.getCouponType() == 101) {
-                                    dataUtils.backCoupon(item.getCouponCode(), orderTicketVo.getUserId());
-                                }
-                            }
-                        }
-                    }
                     // 同步大麦 票务平台
                     KylinOrderTicketVo orderData = dataUtils.getOrderTicketVo(refund.getOrderTicketsId());
                     KylinPerformanceVo vo = dataUtils.getPerformanceVo(orderData.getPerformanceId());

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/refund/KylinRefundsStatusServiceImpl.java

@@ -309,8 +309,25 @@ public class KylinRefundsStatusServiceImpl {
             }
             // 退积分
             goblinRedisUtils.integral(orderInfo.getUserId(), refundCallbackParam.getRefundPrice(), "演出订单退款:".concat(orderInfo.getPerformanceTitle()).concat(":").concat(orderInfo.getOrderCode().substring(orderInfo.getOrderCode().length() - 10)), 2);
-        }
 
+            //未退款入场人数量为0才退优先卷
+            List<KylinOrderTicketEntities> kylinOrderTicketEntities = kylinOrderTicketEntitiesMapper.selectList(
+                    Wrappers.lambdaQuery(KylinOrderTicketEntities.class).eq(KylinOrderTicketEntities::getOrderId, refundInfo.getOrderTicketsId()).eq(KylinOrderTicketEntities::getIsPayment, 1));
+            log.info("订单退款请求未退款入场人数量number={}",kylinOrderTicketEntities.size());
+            if(kylinOrderTicketEntities.size()==0){
+                //获取订单详情
+                KylinOrderTicketVo orderTicketVo = dataUtils.getOrderTicketVo(refundInfo.getOrderTicketsId());
+                //退优先卷
+                ArrayList<KylinOrderCoupons> orderCoupons = dataUtils.getOrderCoupon(refundInfo.getOrderTicketsId());
+                if (orderCoupons.size() > 0) {
+                    for (KylinOrderCoupons item : orderCoupons) {
+                        if (item.getCouponType() == 101) {
+                            dataUtils.backCoupon(item.getCouponCode(), orderTicketVo.getUserId());
+                        }
+                    }
+                }
+            }
+        }
         return true;
     }
 

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/utils/DataUtils.java

 package com.liquidnet.service.platform.utils;
 
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
+import com.liquidnet.commons.lang.util.CollectionUtil;
+import com.liquidnet.commons.lang.util.HttpUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.base.constant.RedisKeyExpireConst;
+import com.liquidnet.service.candy.param.BackCouponParam;
 import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.dto.vo.KylinApiCameraDevicesVo;
 import com.liquidnet.service.kylin.dto.vo.KylinTimePerformanceVo;
@@ -21,18 +25,22 @@ import com.liquidnet.service.slime.constant.SlimeRedisConst;
 import com.liquidnet.service.slime.dto.vo.SlimeFieldsVo;
 import com.liquidnet.service.sweet.constant.SweetConstant;
 import com.liquidnet.service.sweet.vo.SweetAppletUsersVo;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Component;
+import org.springframework.util.MultiValueMap;
 
 import java.util.ArrayList;
 import java.util.LinkedList;
 import java.util.List;
 
 @Component
+@Slf4j
 public class DataUtils {
 
     @Autowired
@@ -44,6 +52,9 @@ public class DataUtils {
     @Autowired
     private MongoVoUtils mongoVoUtils;
 
+    @Value("${liquidnet.service.candy.url}")
+    private String candyUrl;
+
     /**
      * 根据 购票须知 id 获取 购票须知文案
      *
@@ -494,4 +505,19 @@ public class DataUtils {
             return (KylinCamera) obj;
         }
     }
+
+    public void backCoupon(String uCouponId, String uid) {
+        try {
+            BackCouponParam param = BackCouponParam.getNew();
+            param.setuCouponIds(uCouponId);
+            param.setUid(uid);
+            MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
+            ArrayList<BackCouponParam> params = new ArrayList();
+            params.add(param);
+            String jsonString = JSON.toJSONString(params);
+            String returnData = HttpUtil.postRaw(candyUrl + "/candy-coupon/useBack", jsonString, header);
+        } catch (Exception e) {
+            log.error("回退券ERROR:{}", e);
+        }
+    }
 }