同步订单 完成

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

@@ -3,6 +3,7 @@ package com.liquidnet.client.admin.zhengzai.kylin.service;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.fasterxml.jackson.core.type.TypeReference;
+import com.liquidnet.client.admin.zhengzai.kylin.utils.DataUtils;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.HttpUtil;
@@ -20,7 +21,6 @@ import com.liquidnet.service.kylin.dto.vo.ticketSystem.TicketPriceVo;
 import com.liquidnet.service.kylin.dto.vo.ticketSystem.TicketVo;
 import com.liquidnet.service.kylin.dto.vo.ticketSystem.TimesVo;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.util.MultiValueMap;
 
@@ -38,7 +38,9 @@ public class InnerService {
     //    @Value("${liquidnet.service.platform.url}")
     private String platform = "http://127.0.0.1:9003";
     @Autowired
-    RedisUtil reidsUtil;
+    RedisUtil redisUtil;
+    @Autowired
+    DataUtils dataUtils;
 
     //上报演出
     public List<String> reportP(KylinPerformanceVo vo, String approval, String sponsorId) {
@@ -173,12 +175,12 @@ public class InnerService {
 
     //设置SessionCode
     private void setSessionCode(String ticketTimeId, String sessionCode) {
-        reidsUtil.set(KylinRedisConst.TIMES_SESSION_CODE.concat(ticketTimeId), sessionCode);
+        redisUtil.set(KylinRedisConst.TIMES_SESSION_CODE.concat(ticketTimeId), sessionCode);
     }
 
     //获取SessionCode
     private String getSessionCode(String ticketTimeId) {
-        return (String) reidsUtil.get(KylinRedisConst.TIMES_SESSION_CODE.concat(ticketTimeId));
+        return (String) redisUtil.get(KylinRedisConst.TIMES_SESSION_CODE.concat(ticketTimeId));
     }
 
     private String getPriceId(String ticketId) {
@@ -187,7 +189,7 @@ public class InnerService {
 
 
     //上报订单
-    private boolean reportO(KylinOrderTicketVo vo, String channelName) {
+    public boolean reportO(KylinOrderTicketVo vo, String channelName) {
         STInsertOrderParam insertOrderParam = STInsertOrderParam.getNew();
         insertOrderParam.setOrderId(vo.getOrderTicketsId());
         insertOrderParam.setOrderTime(vo.getTimePay());
@@ -197,7 +199,7 @@ public class InnerService {
         insertOrderParam.setTotalAmount(vo.getPriceActual().multiply(BigDecimal.valueOf(100)).intValue());
         insertOrderParam.setTicketType(1);
         insertOrderParam.setTicketMode(vo.getGetTicketType().equalsIgnoreCase("express") ? 1 : 2);
-        insertOrderParam.setAuthMode(vo.getIsTrueName() == 1 ? 3 : 1);
+        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()) {

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

@@ -87,13 +87,15 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
 
     @Override
     public void test() {
-        //同步演出
-//        String performancesId = "324517967623741449058314";
+//        //同步演出
+//        String performancesId = "324470932321198083852669";
 //        KylinPerformances data = performancesMapper.selectOne(new QueryWrapper<KylinPerformances>().in("performances_id", performancesId));
 //        KylinPerformanceRelations relationData = performanceRelationsMapper.selectOne(new QueryWrapper<KylinPerformanceRelations>().in("performance_id", performancesId));
 //        merchantAuthorizationRecordsAdminService.authorizationInit(performancesId, "484418569471385607065926", "528301618682265605017366", "528268445384048648038465");
 //        innerService.reportP(dataUtils.getPerformanceVo(performancesId),null,data.getSponsorId());
-        //同步订单
+//        //同步订单
+//        String orderId = "324561214127595525805856";
+//        innerService.reportO(dataUtils.getOrderTicketVo(orderId),"摩登天空");
     }
 
     @Override

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/ticketSystem/impl/ITicketSystemServiceImpl.java

@@ -281,10 +281,12 @@ public class ITicketSystemServiceImpl implements ITicketSystemService {
         params.put("ticketMode", insertOrderParam.getTicketMode().toString());
         params.put("authMode", insertOrderParam.getAuthMode().toString());
         params.put("ticketOrderList", JSON.toJSONString(insertOrderParam.getTicketOrderList()));
+        log.debug("JSON = " + getJsonStr(params));
         ResponseDataVo<Boolean> response =
                 JsonUtils.fromJson(HttpUtil.postRaw(ticketSystemUrl + "/report/order", getJsonStr(params), headers),
                         new TypeReference<ResponseDataVo<Boolean>>() {
                         });
+        log.debug("RESULT = " + response);
         return response.getData();
     }