同步票务平台

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/constant/KylinRedisConst.java

@@ -30,6 +30,8 @@ public class KylinRedisConst {
     public static final String TICKET_EXPRESS_MODULE_P = "kylin:ticket:express_module:p:";//票种快递票模板关联vo [第三方非线上]
     public static final String TICKET_EXPRESS_MODULE = "kylin:ticket:express_module:";//票种快递票模板关联vo [线上]
 
+    public static final String TIMES_SESSION_CODE = "kylin:ticketTime:";//票种快递票模板关联vo [线上]
+
     public static final String ORDER_TRANSFER = "kylin:order:transfer:uid:";
     //订单导入失败key
     public static final String ORDER_IMPORT_FAIL = "kylin:order:import:fail:";

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/vo/ticketSystem/TicketVo.java

@@ -8,7 +8,7 @@ import java.io.Serializable;
 
 @Data
 @ApiModel
-public class TicketVo implements Serializable {
+public class TicketVo implements Serializable, Cloneable {
     private static final long serialVersionUID = 4073256621782131607L;
     @ApiModelProperty(value = "票ID [必传]")
     private String ticketId;
@@ -22,4 +22,14 @@ public class TicketVo implements Serializable {
     private String rowName;
     @ApiModelProperty(value = "座位号 [有座必传]")
     private String seatNo;
+    private static final TicketVo obj = new TicketVo();
+
+    public static TicketVo getNew() {
+        try {
+            return (TicketVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            e.printStackTrace();
+        }
+        return new TicketVo();
+    }
 }

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/vo/ticketSystem/TimesVo.java

@@ -18,9 +18,9 @@ public class TimesVo implements Serializable,Cloneable {
     @ApiModelProperty(value = "演出场所或场厅编码，兼容传递场所code [必传]")
     private String hallCode;
     @ApiModelProperty(value = "场次开始时间 [必传]")
-    private LocalDateTime sessionStartTime;
+    private String sessionStartTime;
     @ApiModelProperty(value = "场次演出结束时间 [必传]")
-    private LocalDateTime sessionEndTime;
+    private String sessionEndTime;
     @ApiModelProperty(value = "是否有座[必传 0：无座1：有座]")
     private Integer hasSeat;
     @ApiModelProperty(value = "票图URL [有座必传]")

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/admin/IKylinPerformancesAdminService.java

@@ -26,6 +26,9 @@ import java.util.List;
  */
 public interface IKylinPerformancesAdminService {
 
+
+    void test();
+
     /**
      * 获取演出详情
      *

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/kylin/KylinPerformancesController.java

@@ -56,6 +56,11 @@ public class KylinPerformancesController extends BaseController {
         return prefix + "/performances";
     }
 
+    @GetMapping(value = "/test")
+    public void test() {
+        kylinPerformancesService.test();
+    }
+
     /**
      * 查询演出列表
      */

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

+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.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.*;
+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.KylinPerformanceVo;
+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;
+
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.List;
+
+import static com.liquidnet.commons.lang.util.DateUtil.DTF_YMD_HMS;
+
+@Service
+public class InnerService {
+
+    //    @Value("${liquidnet.service.platform.url}")
+    private String platform = "http://127.0.0.1:9003";
+    @Autowired
+    RedisUtil reidsUtil;
+
+    //上报演出
+    public List<String> reportP(KylinPerformanceVo vo, String approval, String sponsorId) {
+        STInsertPerformanceParam insertPerformanceParam = STInsertPerformanceParam.getNew();
+        insertPerformanceParam.setPerformanceId(vo.getPerformancesId());
+        insertPerformanceParam.setPerformanceName(vo.getTitle());
+        if(approval!=null) {
+            insertPerformanceParam.setApproval(approval);//TODO 批文号
+        }
+        insertPerformanceParam.setTypeId(vo.getType() == 101 ? 2002 : 2003);
+        insertPerformanceParam.setPosterUrl(vo.getImgPoster());
+        insertPerformanceParam.setSponsor(sponsorId);
+        //场次相关
+        List<TimesVo> timesVos = new ArrayList();
+        List<KylinTicketTimesVo> kylinTimeVos = vo.getTicketTimeList();
+        for (KylinTicketTimesVo item : kylinTimeVos) {
+            TimesVo timesVo = TimesVo.getNew();
+            timesVo.setSessionId(item.getTicketTimesId());
+            timesVo.setSessionName(item.getTitle());
+            timesVo.setHallCode("320412009");//TODO
+            timesVo.setSessionStartTime(item.getUseStart());
+            String endTime = LocalDateTime.parse(item.getUseEnd() == null ? timesVo.getSessionStartTime() : item.getUseEnd(), DTF_YMD_HMS).plusDays(1).minusSeconds(1L).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+            timesVo.setSessionEndTime(endTime);
+            timesVo.setHasSeat(0);
+            timesVos.add(timesVo);
+        }
+        insertPerformanceParam.setSessionList(timesVos);
+        MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
+        header.add("Accept", "application/json;charset=UTF-8");
+        String resultData = HttpUtil.postRaw(platform + "/platform/st/performance/insert", JSON.toJSONString(insertPerformanceParam), header);
+        ResponseDto<JSONObject> innerReturnVo = JsonUtils.fromJson(resultData, new TypeReference<ResponseDto<JSONObject>>() {
+        });
+        List<String> sessionCodeList = CollectionUtil.linkedListString();
+        for (KylinTicketTimesVo item : kylinTimeVos) {
+            JSONObject jobj = innerReturnVo.getData();
+            String sessionCode = jobj.getString(item.getTicketTimesId());
+            sessionCodeList.add(sessionCode);
+            setSessionCode(item.getTicketTimesId(), sessionCode);
+        }
+        for (KylinTicketTimesVo item : vo.getTicketTimeList()) {
+            reportTP(item.getTicketList(), getSessionCode(item.getTicketTimesId()), vo.getPerformancesId(), item.getTicketTimesId());
+        }
+
+        return sessionCodeList;
+    }
+
+    //修改上报的演出项目数据
+    public boolean updateP(KylinTicketTimesVo vo, String performanceId, String sessionCode) {
+        STUpdateTimesParam updateTimesParam = STUpdateTimesParam.getNew();
+        updateTimesParam.setSessionId(vo.getTicketTimesId());
+        updateTimesParam.setSessionCode(sessionCode);
+        updateTimesParam.setSessionName(vo.getTitle());
+        updateTimesParam.setSessionStartTime(LocalDateTime.parse(vo.getUseStart(), DTF_YMD_HMS));
+        updateTimesParam.setSessionEndTime(LocalDateTime.parse(vo.getUseEnd(), DTF_YMD_HMS));
+        updateTimesParam.setHallCode("320412009");//TODO
+        updateTimesParam.setHasSeat(0);
+        updateTimesParam.setPerformanceId(performanceId);
+        updateTimesParam.setSessionStatus(1);
+        MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
+        header.add("Accept", "application/json;charset=UTF-8");
+        String resultData = HttpUtil.postRaw(platform + "/platform/performance/update", JSON.toJSONString(updateTimesParam), header);
+        ResponseDto<Boolean> innerReturnVo = JsonUtils.fromJson(resultData, new TypeReference<ResponseDto<Boolean>>() {
+        });
+        return innerReturnVo.getData();
+    }
+
+    //更新上报的场次数据
+    public boolean updateTT(KylinPerformanceVo vo, String approval, String sponsorId) {
+        STUpdatePerformanceParam updatePerformanceParam = STUpdatePerformanceParam.getNew();
+        updatePerformanceParam.setPerformanceId(vo.getPerformancesId());
+        updatePerformanceParam.setPerformanceName(vo.getTitle());
+        updatePerformanceParam.setTypeId(vo.getType() == 101 ? 2002 : 2003);
+        updatePerformanceParam.setPosterUrl(vo.getImgPoster());
+        updatePerformanceParam.setSponsor(sponsorId);
+        updatePerformanceParam.setApproval(approval);
+        MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
+        header.add("Accept", "application/json;charset=UTF-8");
+        String resultData = HttpUtil.postRaw(platform + "/platform/times/update", JSON.toJSONString(updatePerformanceParam), header);
+        ResponseDto<Boolean> innerReturnVo = JsonUtils.fromJson(resultData, new TypeReference<ResponseDto<Boolean>>() {
+        });
+        return innerReturnVo.getData();
+    }
+
+    //上报票价信息
+    private boolean reportTP(List<KylinTicketVo> vo, String sessionCode, String performanceId, String ticketTimeId) {
+        STInsertTicketPriceParam insertTicketPriceParam = STInsertTicketPriceParam.getNew();
+        insertTicketPriceParam.setSessionCode(sessionCode);
+        List<TicketPriceVo> priceVos = new ArrayList();
+        for (KylinTicketVo item : vo) {
+            TicketPriceVo priceVo = TicketPriceVo.getNew();
+            priceVo.setPerformanceId(performanceId);
+            priceVo.setSessionId(ticketTimeId);
+            priceVo.setPriceId(getPriceId(item.getTicketsId()));
+            priceVo.setPriceName(item.getTitle());
+            priceVo.setTicketPrice(item.getPrice().multiply(BigDecimal.valueOf(100)).intValue());
+            priceVo.setAvailableInventory(item.getTotalGeneral());//TODO 票量累加
+            priceVo.setUnavailableInventory(0);//工作人员位置等 无座位无用
+            priceVos.add(priceVo);
+        }
+        insertTicketPriceParam.setPriceList(priceVos);
+        MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
+        header.add("Accept", "application/json;charset=UTF-8");
+        String resultData = HttpUtil.postRaw(platform + "/platform/st/ticketPrice/insert", JSON.toJSONString(insertTicketPriceParam), header);
+        ResponseDto<Boolean> innerReturnVo = JsonUtils.fromJson(resultData, new TypeReference<ResponseDto<Boolean>>() {
+        });
+        reportT(performanceId, getSessionCode(ticketTimeId), vo, ticketTimeId);
+        return innerReturnVo.getData();
+    }
+
+    //上报票信息
+    private boolean reportT(String performanceId, String sessionCode, List<KylinTicketVo> ticketIdList, String ticketTimeId) {
+        STInsertTicketParam insertTicketParam = STInsertTicketParam.getNew();
+        insertTicketParam.setPerformanceId(performanceId);
+        insertTicketParam.setSessionId(ticketTimeId);
+        insertTicketParam.setSessionCode(sessionCode);
+        List<TicketVo> ticketVos = new ArrayList();
+        for (KylinTicketVo item : ticketIdList) {
+            insertTicketParam.setPriceId(getPriceId(item.getTicketsId()));
+            TicketVo ticketVo = TicketVo.getNew();
+            ticketVo.setTicketId(item.getTicketsId());
+            ticketVo.setAvailableSale(1);
+            ticketVos.add(ticketVo);
+        }
+        insertTicketParam.setTicketList(ticketVos);
+        MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
+        header.add("Accept", "application/json;charset=UTF-8");
+        String resultData = HttpUtil.postRaw(platform + "/platform/st/ticket/insert", JSON.toJSONString(insertTicketParam), header);
+        ResponseDto<Boolean> innerReturnVo = JsonUtils.fromJson(resultData, new TypeReference<ResponseDto<Boolean>>() {
+        });
+        return innerReturnVo.getData();
+    }
+
+    //设置SessionCode
+    private void setSessionCode(String ticketTimeId, String sessionCode) {
+        reidsUtil.set(KylinRedisConst.TIMES_SESSION_CODE.concat(ticketTimeId), sessionCode);
+    }
+
+    //获取SessionCode
+    private String getSessionCode(String ticketTimeId) {
+        return (String) reidsUtil.get(KylinRedisConst.TIMES_SESSION_CODE.concat(ticketTimeId));
+    }
+
+    private String getPriceId(String ticketId) {
+        return ticketId.concat("01");
+    }
+}

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

@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
+import com.liquidnet.client.admin.zhengzai.kylin.service.InnerService;
 import com.liquidnet.client.admin.zhengzai.kylin.utils.DataUtils;
 import com.liquidnet.client.admin.zhengzai.kylin.utils.PerformanceVoUtils;
 import com.liquidnet.client.admin.zhengzai.merchant.service.IMerchantAuthorizationRecordsAdminService;
@@ -81,6 +82,17 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
     private KylinOrderImportMapper orderImportMapper;
     @Autowired
     IMerchantAuthorizationRecordsAdminService merchantAuthorizationRecordsAdminService;
+    @Autowired
+    InnerService innerService;
+
+    @Override
+    public void test() {
+        String performancesId = "324517967623741449058314";
+        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, relationData.getMerchantId(), relationData.getFieldId(), data.getSponsorId());
+        innerService.reportP(dataUtils.getPerformanceVo(performancesId),null,data.getSponsorId());
+    }
 
     @Override
     public KylinPerformanceMisVo performanceDetails(String performancesId) {
@@ -147,6 +159,7 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
                     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, relationData.getMerchantId(), relationData.getFieldId(), data.getSponsorId());
+                    innerService.reportP(dataUtils.getPerformanceVo(performancesId),data.getApprovalUrl(),data.getSponsorId());
                 } else { //只修改演出相关 场次 票 (不包括 库存 售卖时间 限购)
                     log.info(" PERFORMANCE  演出审核 修改");
 

liquidnet-bus-service/liquidnet-service-merchant/liquidnet-service-merchant-impl/src/main/java/com/liquidnet/service/merchant/util/InnerUtils.java

 package com.liquidnet.service.merchant.util;
 
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.fasterxml.jackson.core.type.TypeReference;
+import com.google.gson.JsonObject;
 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.dto.param.ticketSystem.STInsertPerformanceParam;
-import com.liquidnet.service.kylin.dto.param.ticketSystem.STInsertTicketPriceParam;
-import com.liquidnet.service.kylin.dto.param.ticketSystem.STUpdatePerformanceParam;
-import com.liquidnet.service.kylin.dto.param.ticketSystem.STUpdateTimesParam;
+import com.liquidnet.service.kylin.dto.param.ticketSystem.*;
 import com.liquidnet.service.kylin.dto.vo.middle.KylinBuyNoticeVo;
 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.KylinPerformanceVo;
 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.apache.commons.lang.StringUtils;
 import org.springframework.beans.factory.annotation.Value;
@@ -23,8 +23,12 @@ import org.springframework.util.MultiValueMap;
 
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.stream.Collectors;
+
+import static com.liquidnet.commons.lang.util.DateUtil.DTF_YMD_HMS;
 
 @Component
 public class InnerUtils {
@@ -51,11 +55,11 @@ public class InnerUtils {
     }
 
     //上报演出
-    public boolean reportP(KylinPerformanceVo vo, String approval, String sponsorId) {
+    public List<String> reportP(KylinPerformanceVo vo, String approval, String sponsorId) {
         STInsertPerformanceParam insertPerformanceParam = STInsertPerformanceParam.getNew();
         insertPerformanceParam.setPerformanceId(vo.getPerformancesId());
         insertPerformanceParam.setPerformanceName(vo.getTitle());
-        insertPerformanceParam.setApproval(approval);
+//        insertPerformanceParam.setApproval(approval);
         insertPerformanceParam.setTypeId(vo.getType() == 101 ? 2002 : 2003);
         insertPerformanceParam.setPosterUrl(vo.getImgPoster());
         insertPerformanceParam.setSponsor(sponsorId);
@@ -67,18 +71,24 @@ public class InnerUtils {
             timesVo.setSessionId(item.getTicketTimesId());
             timesVo.setSessionName(item.getTitle());
             timesVo.setHallCode("320412009");//TODO
-            timesVo.setSessionStartTime(LocalDateTime.parse(item.getUseStart()));
-            timesVo.setSessionStartTime(LocalDateTime.parse(item.getUseEnd()));
+            timesVo.setSessionStartTime(item.getUseStart());
+            String endTime = LocalDateTime.parse(item.getUseEnd()).plusDays(1).minusSeconds(1L).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+            timesVo.setSessionEndTime(item.getUseEnd()==null?timesVo.getSessionStartTime():endTime);
             timesVo.setHasSeat(0);
             timesVos.add(timesVo);
         }
         insertPerformanceParam.setSessionList(timesVos);
         MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
         header.add("Accept", "application/json;charset=UTF-8");
-        String resultData = HttpUtil.postRaw(platform + "performance/insert", JSON.toJSONString(insertPerformanceParam), header);
-        ResponseDto<Boolean> innerReturnVo = JsonUtils.fromJson(resultData, new TypeReference<ResponseDto<Boolean>>() {
+        String resultData = HttpUtil.postRaw(platform + "/platform/performance/insert", JSON.toJSONString(insertPerformanceParam), header);
+        ResponseDto<JSONObject> innerReturnVo = JsonUtils.fromJson(resultData, new TypeReference<ResponseDto<JSONObject>>() {
         });
-        return innerReturnVo.getData();
+        List<String> sessionCodeList = CollectionUtil.linkedListString();
+        for (KylinTicketTimesVo item : kylinTimeVos) {
+            JSONObject jobj = innerReturnVo.getData();
+            sessionCodeList.add(jobj.getString(item.getTicketTimesId()));
+        }
+        return sessionCodeList;
     }
 
     //修改上报的演出项目数据
@@ -87,39 +97,36 @@ public class InnerUtils {
         updateTimesParam.setSessionId(vo.getTicketTimesId());
         updateTimesParam.setSessionCode(sessionCode);
         updateTimesParam.setSessionName(vo.getTitle());
-        updateTimesParam.setSessionStartTime(LocalDateTime.parse(vo.getUseStart()));
-        updateTimesParam.setSessionEndTime(LocalDateTime.parse(vo.getUseEnd()));
+        updateTimesParam.setSessionStartTime(LocalDateTime.parse(vo.getUseStart(),DTF_YMD_HMS));
+        updateTimesParam.setSessionEndTime(LocalDateTime.parse(vo.getUseEnd(),DTF_YMD_HMS));
         updateTimesParam.setHallCode("320412009");//TODO
         updateTimesParam.setHasSeat(0);
         updateTimesParam.setPerformanceId(performanceId);
         updateTimesParam.setSessionStatus(1);
         MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
         header.add("Accept", "application/json;charset=UTF-8");
-        String resultData = HttpUtil.postRaw(platform + "performance/update", JSON.toJSONString(updateTimesParam), header);
+        String resultData = HttpUtil.postRaw(platform + "/platform/performance/update", JSON.toJSONString(updateTimesParam), header);
         ResponseDto<Boolean> innerReturnVo = JsonUtils.fromJson(resultData, new TypeReference<ResponseDto<Boolean>>() {
         });
         return innerReturnVo.getData();
     }
 
-    //更新上报的场次数据
-    public boolean updateTT(KylinPerformanceVo vo, String approval, String sponsorId) {
-        STUpdatePerformanceParam updatePerformanceParam = STUpdatePerformanceParam.getNew();
-        updatePerformanceParam.setPerformanceId(vo.getPerformancesId());
-        updatePerformanceParam.setPerformanceName(vo.getTitle());
-        updatePerformanceParam.setTypeId(vo.getType() == 101 ? 2002 : 2003);
-        updatePerformanceParam.setPosterUrl(vo.getImgPoster());
-        updatePerformanceParam.setSponsor(sponsorId);
-        updatePerformanceParam.setApproval(approval);
+    //删除票价信息
+    public boolean delTP(String performanceId, String sessionCode, String ticketId) {
+        STDelTicketPriceParam delTicketPriceParam = STDelTicketPriceParam.getNew();
+        delTicketPriceParam.setPerformanceId(performanceId);
+        delTicketPriceParam.setSessionCode(sessionCode);
+        delTicketPriceParam.setPriceId(ticketId);
         MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
         header.add("Accept", "application/json;charset=UTF-8");
-        String resultData = HttpUtil.postRaw(platform + "times/update", JSON.toJSONString(updatePerformanceParam), header);
+        String resultData = HttpUtil.postRaw(platform + "/platform/ticketPrice/del", JSON.toJSONString(delTicketPriceParam), header);
         ResponseDto<Boolean> innerReturnVo = JsonUtils.fromJson(resultData, new TypeReference<ResponseDto<Boolean>>() {
         });
         return innerReturnVo.getData();
     }
 
     //上报票价信息
-    public boolean reportTP(List<KylinTicketVo> vo, String sessionCode,String performanceId,String ticketTimeId) {
+    public boolean reportTP(List<KylinTicketVo> vo, String sessionCode, String performanceId, String ticketTimeId) {
         STInsertTicketPriceParam insertTicketPriceParam = STInsertTicketPriceParam.getNew();
         insertTicketPriceParam.setSessionCode(sessionCode);
         List<TicketPriceVo> priceVos = new ArrayList();
@@ -137,7 +144,30 @@ public class InnerUtils {
         insertTicketPriceParam.setPriceList(priceVos);
         MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
         header.add("Accept", "application/json;charset=UTF-8");
-        String resultData = HttpUtil.postRaw(platform + "ticketPrice/insert", JSON.toJSONString(insertTicketPriceParam), header);
+        String resultData = HttpUtil.postRaw(platform + "/platformticketPrice/insert", JSON.toJSONString(insertTicketPriceParam), header);
+        ResponseDto<Boolean> innerReturnVo = JsonUtils.fromJson(resultData, new TypeReference<ResponseDto<Boolean>>() {
+        });
+        return innerReturnVo.getData();
+    }
+
+    //上报票信息
+    public boolean reportT(String performanceId, String sessionCode, String priceId, List<String> ticketIdList, String ticketTimeId) {
+        STInsertTicketParam insertTicketParam = STInsertTicketParam.getNew();
+        insertTicketParam.setPerformanceId(performanceId);
+        insertTicketParam.setSessionId(ticketTimeId);
+        insertTicketParam.setSessionCode(sessionCode);
+        insertTicketParam.setPriceId(priceId);
+        List<TicketVo> ticketVos = new ArrayList();
+        for (String ticketId : ticketIdList) {
+            TicketVo ticketVo = TicketVo.getNew();
+            ticketVo.setTicketId(ticketId);
+            ticketVo.setAvailableSale(1);
+            ticketVos.add(ticketVo);
+        }
+        insertTicketParam.setTicketList(ticketVos);
+        MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
+        header.add("Accept", "application/json;charset=UTF-8");
+        String resultData = HttpUtil.postRaw(platform + "/platformticket/insert", JSON.toJSONString(insertTicketParam), header);
         ResponseDto<Boolean> innerReturnVo = JsonUtils.fromJson(resultData, new TypeReference<ResponseDto<Boolean>>() {
         });
         return innerReturnVo.getData();

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

 package com.liquidnet.service.platform.controller.ticketSystem;
 
+import com.alibaba.fastjson.JSONObject;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.kylin.dto.param.ticketSystem.*;
 import com.liquidnet.service.platform.service.ticketSystem.ITicketSystemService;
@@ -36,7 +37,7 @@ public class TicketSystemController {
 
     @GetMapping("field/list")
     @ApiOperation("查询标准演出场所")
-    public ResponseDto<List<STFieldListVo>> getFieldList(STFieldListParam fieldListParam) {
+    public ResponseDto<List<STFieldListVo>> getFieldList(@RequestBody STFieldListParam fieldListParam) {
         try {
             String accessToken = ticketSystemService.getAccessToken();
             List<STFieldListVo> vo = ticketSystemService.getFieldList(accessToken, fieldListParam);
@@ -49,7 +50,7 @@ public class TicketSystemController {
 
     @PostMapping("field/insert")
     @ApiOperation("新增演出场厅")
-    public ResponseDto<STFieldChangeVo> insertField(STInsertFieldParam insertFieldParam) {
+    public ResponseDto<STFieldChangeVo> insertField(@RequestBody STInsertFieldParam insertFieldParam) {
         try {
             String accessToken = ticketSystemService.getAccessToken();
             STFieldChangeVo vo = ticketSystemService.insertField(accessToken, insertFieldParam);
@@ -63,10 +64,11 @@ public class TicketSystemController {
 
     @PostMapping("performance/insert")
     @ApiOperation("上报演出场次")
-    public ResponseDto<String> insertPerformance(STInsertPerformanceParam insertPerformanceParam) {
+    @ResponseBody
+    public ResponseDto<JSONObject> insertPerformance(@RequestBody STInsertPerformanceParam insertPerformanceParam) {
         try {
             String accessToken = ticketSystemService.getAccessToken();
-            String vo = ticketSystemService.insertPerformance(accessToken, insertPerformanceParam);
+            JSONObject vo = ticketSystemService.insertPerformance(accessToken, insertPerformanceParam);
             return ResponseDto.success(vo);
         } catch (Exception e) {
             log.error("上报演出场次 ERROR : {}", e);
@@ -76,7 +78,7 @@ public class TicketSystemController {
 
     @PostMapping("performance/update")
     @ApiOperation("更新上报的演出项目数据")
-    public ResponseDto<Boolean> updatePerformance(STUpdatePerformanceParam updatePerformanceParam) {
+    public ResponseDto<Boolean> updatePerformance(@RequestBody STUpdatePerformanceParam updatePerformanceParam) {
         try {
             String accessToken = ticketSystemService.getAccessToken();
             boolean vo = ticketSystemService.updatePerformance(accessToken, updatePerformanceParam);
@@ -89,7 +91,7 @@ public class TicketSystemController {
 
     @PostMapping("times/update")
     @ApiOperation("更新上报的场次数据")
-    public ResponseDto<Boolean> updateTimes(STUpdateTimesParam updateTimesParam) {
+    public ResponseDto<Boolean> updateTimes(@RequestBody STUpdateTimesParam updateTimesParam) {
         try {
             String accessToken = ticketSystemService.getAccessToken();
             boolean vo = ticketSystemService.updateTimes(accessToken, updateTimesParam);
@@ -102,7 +104,7 @@ public class TicketSystemController {
 
     @PostMapping("ticketPrice/insert")
     @ApiOperation("上报票价信息")
-    public ResponseDto<Boolean> insertTicketPrice(STInsertTicketPriceParam insertTicketPriceParam) {
+    public ResponseDto<Boolean> insertTicketPrice(@RequestBody STInsertTicketPriceParam insertTicketPriceParam) {
         try {
             String accessToken = ticketSystemService.getAccessToken();
             boolean vo = ticketSystemService.insertTicketPrice(accessToken, insertTicketPriceParam);
@@ -115,7 +117,7 @@ public class TicketSystemController {
 
     @PostMapping("ticketPrice/del")
     @ApiOperation("删除票价信息")
-    public ResponseDto<Boolean> delTicketPrice(STDelTicketPriceParam delTicketPriceParam) {
+    public ResponseDto<Boolean> delTicketPrice(@RequestBody STDelTicketPriceParam delTicketPriceParam) {
         try {
             String accessToken = ticketSystemService.getAccessToken();
             boolean vo = ticketSystemService.delTicketPrice(accessToken, delTicketPriceParam);
@@ -128,7 +130,7 @@ public class TicketSystemController {
 
     @PostMapping("ticket/insert")
     @ApiOperation("上报票信息")
-    public ResponseDto<Boolean> insertTicket(STInsertTicketParam insertTicketParam) {
+    public ResponseDto<Boolean> insertTicket(@RequestBody STInsertTicketParam insertTicketParam) {
         try {
             String accessToken = ticketSystemService.getAccessToken();
             boolean vo = ticketSystemService.insertTicket(accessToken, insertTicketParam);
@@ -141,7 +143,7 @@ public class TicketSystemController {
 
     @PostMapping("ticket/del")
     @ApiOperation("删除票信息")
-    public ResponseDto<Boolean> delTicket(STDelTicketParam delTicketParam) {
+    public ResponseDto<Boolean> delTicket(@RequestBody STDelTicketParam delTicketParam) {
         try {
             String accessToken = ticketSystemService.getAccessToken();
             boolean vo = ticketSystemService.delTicket(accessToken, delTicketParam);
@@ -155,7 +157,7 @@ public class TicketSystemController {
 
     @PostMapping("order/insert")
     @ApiOperation("上报订单信息")
-    public ResponseDto<Boolean> insertOrder(STInsertOrderParam insertOrderParam) {
+    public ResponseDto<Boolean> insertOrder(@RequestBody STInsertOrderParam insertOrderParam) {
         try {
             String accessToken = ticketSystemService.getAccessToken();
             boolean vo = ticketSystemService.insertOrder(accessToken, insertOrderParam);
@@ -168,7 +170,7 @@ public class TicketSystemController {
 
     @PostMapping("order/refund")
     @ApiOperation("上报退票信息")
-    public ResponseDto<Boolean> refundOrder(STRefundOrderParam refundOrderParam) {
+    public ResponseDto<Boolean> refundOrder(@RequestBody STRefundOrderParam refundOrderParam) {
         try {
             String accessToken = ticketSystemService.getAccessToken();
             Boolean vo = ticketSystemService.refundOrder(accessToken, refundOrderParam);
@@ -181,7 +183,7 @@ public class TicketSystemController {
 
     @PostMapping("check/insert")
     @ApiOperation("上报检票数据")
-    public ResponseDto<Boolean> insertCheck(List<CheckVo> ticketList) {
+    public ResponseDto<Boolean> insertCheck(@RequestBody List<CheckVo> ticketList) {
         try {
             String accessToken = ticketSystemService.getAccessToken();
             boolean vo = ticketSystemService.insertCheck(accessToken, ticketList);

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

 package com.liquidnet.service.platform.service.ticketSystem;
 
+import com.alibaba.fastjson.JSONObject;
 import com.liquidnet.service.kylin.dto.vo.ticketSystem.CheckVo;
 import com.liquidnet.service.kylin.dto.vo.ticketSystem.STFieldChangeVo;
 import com.liquidnet.service.kylin.dto.vo.ticketSystem.STFieldListVo;
@@ -58,7 +59,7 @@ public interface ITicketSystemService {
      * "sessionId2":"sessionCode2"
      * }
      */
-    String insertPerformance(String accessToken, STInsertPerformanceParam insertPerformanceParam);
+    JSONObject insertPerformance(String accessToken, STInsertPerformanceParam insertPerformanceParam);
 
 
     /**