提交 同步演出同步订单

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

@@ -155,13 +155,13 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
                             KylinTicketStatus ticketStatus = new KylinTicketStatus();
                             ticketStatus.setUpdatedAt(updatedAt);
                             ticketStatus.setStatus(status);
-                            dataUtils.setTEMVo(ticketItem.getTicketsId(),dataUtils.getTEMMerchantVo(ticketItem.getTicketsId()));
+                            dataUtils.setTEMVo(ticketItem.getTicketsId(), dataUtils.getTEMMerchantVo(ticketItem.getTicketsId()));
                             ticketStatusMapper.update(ticketStatus, new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketItem.getTicketsId()));
                         }
                     }
                     performanceVoUtils.performanceVoStatus(performancesId);
-                    //权限
-//                    innerService.reportP(dataUtils.getPerformanceVo(performancesId),data.getApprovalUrl(),data.getSponsorId());
+                    //同步演出
+                    innerService.reportP(dataUtils.getPerformanceVo(performancesId), null, null);
                 } else { //只修改演出相关 场次 票 (不包括 库存 售卖时间 限购)
                     log.info(" PERFORMANCE  演出审核 修改");
 

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

+package com.liquidnet.service.order.service;
+
+import com.alibaba.fastjson.JSON;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.liquidnet.common.cache.redis.util.RedisUtil;
+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.ResponseDto;
+import com.liquidnet.service.kylin.constant.KylinRedisConst;
+import com.liquidnet.service.kylin.dto.param.ticketSystem.STInsertOrderParam;
+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.ticketSystem.OrderVo;
+import com.liquidnet.service.order.utils.DataUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.util.MultiValueMap;
+
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
+
+@Service
+@Slf4j
+public class InnerService {
+
+    @Value("${liquidnet.service.platform.url}")
+    private String platform;
+    @Autowired
+    DataUtils dataUtils;
+    @Autowired
+    RedisUtil redisUtil;
+
+    //上报订单
+    public boolean reportO(KylinOrderTicketVo vo, String channelName) {
+        try {
+            STInsertOrderParam insertOrderParam = STInsertOrderParam.getNew();
+            insertOrderParam.setOrderId(vo.getOrderTicketsId());
+            insertOrderParam.setOrderTime(vo.getTimePay());
+            insertOrderParam.setChannelType(1);
+            insertOrderParam.setChannelName(channelName);
+            insertOrderParam.setTicketNum(vo.getNumber());
+            insertOrderParam.setTotalAmount(vo.getPriceActual().multiply(BigDecimal.valueOf(100)).intValue());
+            insertOrderParam.setTicketType(1);
+            insertOrderParam.setTicketMode(vo.getGetTicketType().equalsIgnoreCase("express") ? 1 : 2);
+            insertOrderParam.setAuthMode(dataUtils.getPerformanceIsTrueName(vo.getPerformanceId()) == 1 ? 3 : 1);
+            int voucherPrice = vo.getPriceVoucher().multiply(BigDecimal.valueOf(100)).divide(BigDecimal.valueOf(vo.getNumber())).intValue();
+            List<OrderVo> orderVos = new ArrayList();
+            for (KylinOrderTicketEntitiesVo item : vo.getEntitiesVoList()) {
+                OrderVo orderVo = OrderVo.getNew();
+                orderVo.setTicketOrderId(item.getOrderTicketEntitiesId());
+                orderVo.setPerformanceId(item.getPerformanceId());
+                orderVo.setSessionId(item.getTimeId());
+                orderVo.setSessionCode(getSessionCode(item.getTimeId()));
+                orderVo.setPriceId(getPriceId(item.getTicketId()));
+                orderVo.setTicketPrice(vo.getPrice().multiply(BigDecimal.valueOf(100)).intValue());
+                orderVo.setTicketId(item.getTicketId());
+                orderVo.setTicketOrderAmount(orderVo.getTicketPrice() - voucherPrice);
+                orderVos.add(orderVo);
+            }
+            insertOrderParam.setTicketOrderList(orderVos);
+            MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
+            header.add("Accept", "application/json;charset=UTF-8");
+            String resultData = HttpUtil.postRaw(platform + "/platform/st/order/insert", JSON.toJSONString(insertOrderParam), header);
+            ResponseDto<Boolean> innerReturnVo = JsonUtils.fromJson(resultData, new TypeReference<ResponseDto<Boolean>>() {
+            });
+            return innerReturnVo.getData();
+        } catch (Exception e) {
+            log.error("[ERROR REPORT ORDER] , {}", e);
+            return false;
+        }
+    }
+
+    //获取SessionCode
+    private String getSessionCode(String ticketTimeId) {
+        return (String) redisUtil.get(KylinRedisConst.TIMES_SESSION_CODE.concat(ticketTimeId));
+    }
+
+    private String getPriceId(String ticketId) {
+        return ticketId.concat("01");
+    }
+}

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

@@ -7,7 +7,6 @@ import com.liquidnet.commons.lang.util.*;
 import com.liquidnet.service.adam.dto.vo.AdamAddressesVo;
 import com.liquidnet.service.adam.dto.vo.AdamEntersVo;
 import com.liquidnet.service.adam.dto.vo.AdamRscPolymer01Vo;
-import com.liquidnet.service.adam.dto.vo.AdamUserMemberVo;
 import com.liquidnet.service.base.*;
 import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.kylin.constant.KylinRedisConst;
@@ -26,8 +25,7 @@ import com.liquidnet.service.kylin.dto.vo.returns.PayInnerResultVo;
 import com.liquidnet.service.kylin.dto.vo.returns.PayResultVo;
 import com.liquidnet.service.kylin.entity.*;
 import com.liquidnet.service.kylin.service.IKylinOrderTicketsOrderService;
-import com.liquidnet.service.order.dto.SweetOpenSendMsgParam;
-import com.liquidnet.service.order.dto.TemplateOrderParam;
+import com.liquidnet.service.order.service.InnerService;
 import com.liquidnet.service.order.utils.*;
 import com.taobao.api.TaobaoClient;
 import com.taobao.api.request.AlibabaDamaiMevOpenBatchpushticketRequest;
@@ -74,6 +72,8 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
     @Autowired
     private RedisUtil redisUtil;
     @Autowired
+    private InnerService innerService;
+    @Autowired
     private OrderUtils orderUtils;
     @Autowired
     private MongoTemplate mongoTemplate;
@@ -1011,6 +1011,8 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
 //                }
                 //加分
                 orderUtils.doTask(orderTicketData.getUserId(), orderTicketData.getPerformanceTitle(), orderTicketData.getPriceActual());
+                //
+                innerService.reportO(orderTicketData,"摩登天空");
                 //大麦回调
                 sycDamaiOrder(orderTickets.getOrderTicketsId(), orderTicketData.getIsMember());
             }