update damai

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

@@ -134,18 +134,18 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
             for (KylinTicketRelations ticketRelations : ticketRelation) {
                 long ticketTimesKey = IDGenerator.getDamaiCode(ticketRelations.getTimesId());
                 // 是否开启了同步的票种
-                KylinTicketStatus ticketStatus = ticketStatusMapper.selectOne(
-                        new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketRelations.getTicketId()).eq("sync_damai", 1)
+//                KylinTicketStatus ticketStatus = ticketStatusMapper.selectOne(
+//                        new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketRelations.getTicketId()).eq("sync_damai", 1)
+//                );
+//                if (null != ticketStatus) {
+                KylinTickets ticketData = ticketsMapper.selectOne(
+                        new UpdateWrapper<KylinTickets>().eq("tickets_id", ticketRelations.getTicketId())
                 );
-                if (null != ticketStatus) {
-                    KylinTickets ticketData = ticketsMapper.selectOne(
-                            new UpdateWrapper<KylinTickets>().eq("tickets_id", ticketRelations.getTicketId())
-                    );
-                    boolean result = sycTicket(ticketTimesKey, ticketData);
-                    if (!result) {
-                        return false;
-                    }
+                boolean result = sycTicket(ticketTimesKey, ticketData);
+                if (!result) {
+                    return false;
                 }
+//                }
             }
 
             // 同步订单
@@ -298,6 +298,8 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
 
             int batchSize = 100;
             int orderCount = 0;
+            int refundOrderCount = 0;
+            int transferRefundOrderCount = 0;
             for (int i = 0; i < dataSize; i += batchSize) {
 
                 List<ThirdTicketPushOpenParam> paramList = new ArrayList<>();
@@ -360,10 +362,12 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
                     // 场次id
                     obj3.setPerformId(timemId);
                     if (item.getIsMember() == 1) {
-                        obj3.setExt("登登登VIP");
+//                        obj3.setExt("登登登VIP");
+                        obj3.setExt("");
                         obj3.setTicketItemId(ticketIdMemberKey);
                     } else {
-                        obj3.setExt("登登登VIP");
+                        obj3.setExt("");
+//                        obj3.setExt("登登登VIP");
                         obj3.setTicketItemId(ticketsmId);
                     }
                     obj3.setQrCode("http://m.zhengzai.tv?c=" + IDGenerator.ticketQrCode(item.getOrderTicketEntitiesId()));
@@ -379,23 +383,32 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
                     //票类型
                     obj3.setTicketType(1L);
 
-                    paramList.add(obj3);
-
-                    orderCount += 1;
+                    List<ThirdTicketPushOpenParam> paramList2 = new ArrayList<>();
+                    paramList2.add(obj3);
+                    req.setThirdTicketSetOpenParamList(paramList2);
+                    AlibabaDamaiMevOpenBatchpushticketResponse rsp = client.execute(req);
+                    if (!rsp.getResult().getSuccess()) {
+                        log.error("[同步订单] res [BODY = {}]", rsp.getBody());
+                        return false;
+                    }
 
                     // 部分退款是不退的，但是阶梯退票客服手动申请的现在也是部分退款，用户自己申请的现在不确定
                     // 取消退款的貌似没处理 其实这块应该可以不用处理退款中的，因为印象中退款那里有接入同步大麦
                     // 0未支付 1已支付 2退款中 3已退款 4部分退款
-                    if (item.getIsPayment() == 3 || item.getIsPayment() == 2) {
+                    if (item.getIsPayment() == 3 || item.getIsPayment() == 2 || item.getIsPayment() == 4) {
                         taobaoTicketUtils.withdrawDamaiOrder(timemId, orderTicketEntitiesKey);
+                        refundOrderCount += 1;
                         // 已转赠是转出去了 被退回是被别人退回了 已退回是别人给我的我给退回了
                         // 0交易成功，1转增中，2已转赠，3转增订单，4待接收，5被退回 ,6已退回
                     } else if (item.getTransferStatus() == 2 || item.getTransferStatus() == 6) {
                         taobaoTicketUtils.withdrawDamaiOrder(timemId, orderTicketEntitiesKey);
+                        transferRefundOrderCount += 1;
+                    } else {
+                        orderCount += 1;
                     }
                 }
 
-                if (paramList.size() == 0) {
+                /*if (paramList.size() == 0) {
                     return true;
                 } else {
                     req.setThirdTicketSetOpenParamList(paramList);
@@ -404,10 +417,12 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
                         log.error("[同步订单] res [BODY = {}]", rsp.getBody());
                         return false;
                     }
-                }
+                }*/
             }
 
-            log.info("[同步订单] 同步成功总张数 = " + orderCount + " 票种id =" + ticketsId);
+            int count = orderCount + transferRefundOrderCount + refundOrderCount;
+            log.info("[同步订单] 同步成功总张数 = " + count
+                    + " orderCount =" + orderCount + " refund =" + refundOrderCount + " transfer =" + transferRefundOrderCount + " 票种id =" + ticketsId);
             return true;
         } catch (Exception e) {
             log.error("[同步订单] 异常:{}", e);