KylinDamaiServiceImpl.java 删除 010 020后缀

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

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

@@ -813,6 +813,8 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
                 orderUtils.resetOrderListVo(orderTicketData.getUserId(), 2, orderTicketData.getOrderTicketsId(), null);
                 log.error("订单号为 {} 的订单超时支付", syncOrderParam.getOrderCode());
                 orderRefundsCallbackService.refundApply(orderTicketData.getOrderTicketsId(), syncOrderParam.getPaymentId(), syncOrderParam.getPaymentType());
+                //大麦退款
+                refundDamaiOrder(orderTickets.getOrderTicketsId());
             } else if ((orderTicketData.getStatus() == 3 || orderTicketData.getStatus() == 4) && syncOrderParam.getStatus().equals(1)) {
                 log.error("订单号为 {} 的订单正在退款 或者已退款", syncOrderParam.getOrderCode());
             } else if (syncOrderParam.getStatus().equals(1)) {
@@ -998,6 +1000,60 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
 //        }
     }
 
+    /**
+     * 同步 退款大麦订单
+     * @param orderId
+     * @return
+     */
+    private boolean refundDamaiOrder(String orderId) {
+        try {
+            KylinOrderTicketVo orderData = dataUtils.getOrderTicketVo(orderId);
+            KylinPerformanceVo vo = dataUtils.getPerformanceVo(orderData.getPerformanceId());
+            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) {
+                KylinOrderTicketVo orderVo = dataUtils.getOrderTicketVo(orderId);
+                List<KylinOrderTicketEntitiesVo> listData = orderVo.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
+                    }
+                    taobaoTicketUtils.withdrawDamaiOrder(ticketTimesKey, orderTicketEntitiesKey);
+                }
+                return true;
+            }
+            return true;
+        }catch (Exception e){
+            log.info("REFUND DAMAI ERROR = {}",e);
+            return false;
+        }
+    }
+
+    /**
+     * 同步大麦订单
+     * @param orderId
+     * @return
+     */
     private boolean sycDamaiOrder(String orderId) {
         try {
             KylinOrderTicketVo orderData = dataUtils.getOrderTicketVo(orderId);

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

@@ -2,6 +2,8 @@ package com.liquidnet.service.order.utils;
 
 import com.taobao.api.DefaultTaobaoClient;
 import com.taobao.api.TaobaoClient;
+import com.taobao.api.request.AlibabaDamaiMevOpenWithdrawticketRequest;
+import com.taobao.api.response.AlibabaDamaiMevOpenWithdrawticketResponse;
 import org.springframework.stereotype.Service;
 
 @Service
@@ -28,4 +30,21 @@ public class TaobaoTicketUtils {
     public Long getSystemId(){
         return SYSTEM_ID;
     }
+
+    public boolean withdrawDamaiOrder(long timesId, long orderEntitiesId) {
+        try {
+            TaobaoClient client = initTaobaoClient();
+            AlibabaDamaiMevOpenWithdrawticketRequest req = new AlibabaDamaiMevOpenWithdrawticketRequest();
+            AlibabaDamaiMevOpenWithdrawticketRequest.TicketIdOpenParam obj1 = new AlibabaDamaiMevOpenWithdrawticketRequest.TicketIdOpenParam();
+            obj1.setPerformId(timesId);//场次id
+            obj1.setVoucherId(orderEntitiesId);//票单号 入场人id
+            obj1.setSupplierSecret(SUPPLIER_SECRET);
+            obj1.setSystemId(SYSTEM_ID);
+            req.setTicketIdOpenParam(obj1);
+            AlibabaDamaiMevOpenWithdrawticketResponse rsp = client.execute(req);
+            return rsp.getResult().getSuccess();
+        } catch (Exception e) {
+            return false;
+        }
+    }
 }