超市支付退款 申请就同步大麦

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/OrderRefundOvertimeServiceImpl.java

@@ -5,9 +5,11 @@ import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.HttpUtil;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketEntitiesVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.liquidnet.service.kylin.entity.KylinOrderCoupons;
 import com.liquidnet.service.kylin.service.IKylinOrderRefundsService;
 import com.liquidnet.service.order.utils.DataUtils;
+import com.liquidnet.service.order.utils.TaobaoTicketUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -40,8 +42,8 @@ public class OrderRefundOvertimeServiceImpl implements IKylinOrderRefundsService
     @Autowired
     private DataUtils dataUtils;
 
-    @Value("${liquidnet.service.candy.url}")
-    private String candyUrl;
+    @Autowired
+    private TaobaoTicketUtils taobaoTicketUtils;
 
     public Boolean refundApply(String orderTicketsId, String paymentId, String paymentType) {
         log.info("订单超时支付refundApply-Start：[orderTicketsId={}, [paymentId={}, paymentType={}]",
@@ -70,6 +72,11 @@ public class OrderRefundOvertimeServiceImpl implements IKylinOrderRefundsService
         );
         if (res) {
             // 优惠券 库存 积分 大美已自己处理
+            // 同步大麦退款
+            KylinOrderTicketVo orderData = dataUtils.getOrderTicketVo(orderTicketsId);
+            KylinPerformanceVo vo = dataUtils.getPerformanceVo(orderData.getPerformanceId());
+            taobaoTicketUtils.refundDamaiOrder(orderData, vo);
+            // TODO: 2021/12/21 jxl 同步票务平台 
             return true;
         } else {
             return false;

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/utils/TaobaoTicketUtils.java

 package com.liquidnet.service.order.utils;
 
+import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.service.kylin.dto.vo.middle.KylinTicketTimesVo;
+import com.liquidnet.service.kylin.dto.vo.middle.KylinTicketVo;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketEntitiesVo;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.taobao.api.DefaultTaobaoClient;
 import com.taobao.api.TaobaoClient;
 import com.taobao.api.request.AlibabaDamaiMevOpenWithdrawticketRequest;
 import com.taobao.api.response.AlibabaDamaiMevOpenWithdrawticketResponse;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
+@Slf4j
 @Service
 public class TaobaoTicketUtils {
 
@@ -47,4 +57,52 @@ public class TaobaoTicketUtils {
             return false;
         }
     }
+
+    public boolean refundDamaiOrder(KylinOrderTicketVo orderData, KylinPerformanceVo vo) {
+        try {
+            int isSysDamai = 0;
+            for (int x = 0; x < vo.getTicketTimeList().size(); x++) {
+                KylinTicketTimesVo timeItem = vo.getTicketTimeList().get(x);
+                for (int y = 0; y < timeItem.getTicketList().size(); y++) {
+                    KylinTicketVo ticketItem = timeItem.getTicketList().get(y);
+                    if (ticketItem.getTicketsId().equals(orderData.getTicketId())) {
+                        isSysDamai = ticketItem.getSysDamai();
+                        break;
+                    }
+                }
+            }
+            if (isSysDamai == 1) {
+                List<KylinOrderTicketEntitiesVo> listData = orderData.getEntitiesVoList();
+                for (int i = 0; i < listData.size(); i++) {
+                    KylinOrderTicketEntitiesVo item = listData.get(i);
+                    long ticketTimesKey;
+                    if (item.getTicketId().length() > 13) {
+                        ticketTimesKey = Long.valueOf(IDGenerator.getDamaiCode(item.getTimeId()));
+                    } else {
+                        ticketTimesKey = Long.parseLong(item.getTimeId());
+                    }
+
+                    long orderTicketEntitiesKey;
+//                    if (item.getOrderTicketEntitiesId().length() > 13) {
+//                        orderTicketEntitiesKey = Long.valueOf(IDGenerator.getDamaiCode(item.getOrderTicketEntitiesId()));
+//                    } else {
+//                        orderTicketEntitiesKey = Long.valueOf(item.getOrderTicketEntitiesId());//票单号 入场人id
+//                    }
+                    if (orderData.getIsMember() == 1) {
+                        orderTicketEntitiesKey = Long.valueOf(IDGenerator.getDamaiCode(item.getOrderTicketEntitiesId()).toString().concat("010"));
+                    } else {
+                        orderTicketEntitiesKey = Long.valueOf(IDGenerator.getDamaiCode(item.getOrderTicketEntitiesId()).toString().concat("020"));
+                    }
+
+                    withdrawDamaiOrder(ticketTimesKey, orderTicketEntitiesKey);
+                }
+                return true;
+            }
+            return true;
+        }catch (Exception e){
+            log.info("REFUND DAMAI ERROR = {}",e);
+            return false;
+        }
+    }
+
 }

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

@@ -72,9 +72,6 @@ public class OrderRefundsCallbackServiceImpl extends ServiceImpl<KylinOrderRefun
     @Autowired
     private DataUtils dataUtils;
 
-    /*@Autowired
-    private TaobaoTicketUtils taobaoTicketUtils;*/
-
     public String refundCallback(RefundCallbackParam refundCallbackParam) {
         log.info("refundCallback订单退款回调参数: [RefundCallbackParam={}]", refundCallbackParam);
         KylinOrderRefunds refundInfo = kylinOrderRefundsMapper.selectOne(
@@ -162,11 +159,10 @@ public class OrderRefundsCallbackServiceImpl extends ServiceImpl<KylinOrderRefun
                 params.add("orderRefundCode", refundInfo.getOrderRefundCode());
                 params.add("paymentId", orderInfo.getPaymentId());
 
-                // log.info("退款参数" + JsonUtils.toJson(params));
                 log.info("\n支付宝退款主动查询参数：\n[{}] ", params.toString());
-                // 请求pay
+                // 请求dragon
                 try {
-                    String postResult = HttpUtil.post(refundApply, params);
+                    String postResult = HttpUtil.post(refundResult, params);
                     log.info("\n支付宝退款主动查询处理结果：\n[{}] " + postResult);
                 } catch (Exception e) {
                     log.info("\n支付宝退款主动查询失败：[errorMsg=[{}], [orderRefundsId=[{}]", e.getMessage(), refundInfo.getOrderRefundsId());
@@ -276,11 +272,6 @@ public class OrderRefundsCallbackServiceImpl extends ServiceImpl<KylinOrderRefun
                     dataUtils.delOrderRefundVoByOrderId(orderId);
 
                     continue;
-                } else {
-                    // 同步大麦退款
-                    /*KylinOrderTicketVo orderData = dataUtils.getOrderTicketVo(orderId);
-                    KylinPerformanceVo vo = dataUtils.getPerformanceVo(orderData.getPerformanceId());
-                    taobaoTicketUtils.refundDamaiOrder(orderData, vo);*/
                 }
             } catch (Exception e) {
                 log.info("退款请求pay失败e" + e.getMessage());