KylinDamaiServiceImpl.java 删除 010 020后缀

KylinOrderTicketsServiceImpl.java
订单支付回调增加 实时同步
订单支付回调增加 超时支付退款关闭订单
TaobaoTicketUtils.java 增加 大麦订单退款
KylinRefundsStatusServiceImpl.java 增加 运营同意退款 大麦同步

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

@@ -16,6 +16,7 @@ import com.liquidnet.service.kylin.dto.param.RefundCallbackParam;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderRefundEntitiesVo;
 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.dto.vo.returns.KylinOrderRefundsVo;
 import com.liquidnet.service.kylin.entity.*;
 import com.liquidnet.service.kylin.mapper.*;
@@ -345,7 +346,12 @@ public class KylinRefundsStatusServiceImpl {
                 kylinOrderRefunds.setAuditorName(authName);
                 kylinOrderRefunds.setAuditorAt(LocalDateTime.now());
                 kylinOrderRefunds.setReject(refundApplyParam.getReject());
-                //TODO 秀龙 退款
+                //TODO 秀龙 大麦退款
+                for (KylinOrderRefunds item : refundList) {
+                    KylinOrderTicketVo orderData = dataUtils.getOrderTicketVo(item.getOrderTicketsId());
+                    KylinPerformanceVo vo = dataUtils.getPerformanceVo(orderData.getPerformanceId());
+                    taobaoTicketUtils.refundDamaiOrder(orderData,vo);
+                }
                 break;
             case "reject":
                 kylinOrderRefunds.setStatus(KylinTableStatusConst.ORDER_REFUND_STATUS_REJECT);

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/utils/TaobaoTicketUtils.java

 package com.liquidnet.client.admin.zhengzai.kylin.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;
+
 @Service
+@Slf4j
 public class TaobaoTicketUtils {
 
     private String URL = "http://gw.api.taobao.com/router/rest";
@@ -55,4 +65,46 @@ 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
+                    }
+                    withdrawDamaiOrder(ticketTimesKey, orderTicketEntitiesKey);
+                }
+                return true;
+            }
+            return true;
+        }catch (Exception e){
+            log.info("REFUND DAMAI ERROR = {}",e);
+            return false;
+        }
+    }
 }

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

@@ -1021,8 +1021,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
                 }
             }
             if (isSysDamai == 1) {
-                KylinOrderTicketVo orderVo = dataUtils.getOrderTicketVo(orderId);
-                List<KylinOrderTicketEntitiesVo> listData = orderVo.getEntitiesVoList();
+                List<KylinOrderTicketEntitiesVo> listData = orderData.getEntitiesVoList();
                 for (int i = 0; i < listData.size(); i++) {
                     KylinOrderTicketEntitiesVo item = listData.get(i);
                     long ticketTimesKey;
@@ -1071,8 +1070,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
                 }
             }
             if (isSysDamai == 1) {
-                KylinOrderTicketVo orderVo = dataUtils.getOrderTicketVo(orderId);
-                List<KylinOrderTicketEntitiesVo> listData = orderVo.getEntitiesVoList();
+                List<KylinOrderTicketEntitiesVo> listData = orderData.getEntitiesVoList();
                 AlibabaDamaiMevOpenBatchpushticketRequest req = new AlibabaDamaiMevOpenBatchpushticketRequest();
                 List<AlibabaDamaiMevOpenBatchpushticketRequest.ThirdTicketPushOpenParam> list2 = new ArrayList<>();
                 for (int i = 0; i < listData.size(); i++) {