暂时提交

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

+package com.liquidnet.service.kylin.dto.vo;
+
+import com.liquidnet.service.kylin.entity.KylinPerformanceRelations;
+import com.liquidnet.service.kylin.entity.KylinPerformanceStatus;
+import com.liquidnet.service.kylin.entity.KylinPerformances;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.time.format.DateTimeFormatter;
+
+@Data
+public class PerformanceVo {
+
+    @ApiModelProperty(value = "主键")
+    private String performancesId;
+    @ApiModelProperty(value = "演出名称")
+    private String title;
+    @ApiModelProperty(value = "演出开始时间")
+    private String timeStart;
+    @ApiModelProperty(value = "演出结束时间")
+    private String timeEnd;
+    @ApiModelProperty(value = "停售时间")
+    private String stopSellTime;
+    @ApiModelProperty(value = "价格")
+    private String price;
+    @ApiModelProperty(value = "开售时间")
+    private String sellTime;
+
+    //    @ApiModelProperty(value = "场地相关")
+//    private String fields;
+//@ApiModelProperty(value = "巡演相关")
+//    private String roadShow;
+    // OSS
+//    @ApiModelProperty(value = "演出详情")
+//    private String details;
+    // OSS
+//    @ApiModelProperty(value = "购票须知")
+//    private String noticeImage;
+
+    @ApiModelProperty(value = "状态")
+    private int appStatus;
+    @ApiModelProperty(value = "是否可买")
+    private int statusSell;
+    @ApiModelProperty(value = "是否关联会员")
+    private int isMember;
+    @ApiModelProperty(value = "是否开启缺票登记")
+    private int isLackRegister;
+    @ApiModelProperty(value = "是否专属")
+    private int isExclusive;
+    @ApiModelProperty(value = "文案")
+    private String message;
+
+
+    public void setPerformance(KylinPerformances performance) {
+        this.performancesId = performance.getPerformancesId();
+        this.title = performance.getTitle();
+        this.timeStart = performance.getTimeStart().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+        this.timeEnd = performance.getTimeEnd().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+    }
+
+    public void setTimePriceVipAndLack() {
+        this.isLackRegister = 0;
+        this.timeEnd = "";
+        this.stopSellTime = "";
+        this.price = "";
+        this.sellTime = "";
+        this.isMember = 0;
+        this.isExclusive = 0;
+        this.appStatus = 0;
+    }
+
+    public void setPerformanceStatus(KylinPerformanceStatus performanceStatus) {
+        this.statusSell = performanceStatus.getStatusSell();
+//        this.message = performance.getPerformancesId();
+    }
+}

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

+package com.liquidnet.service.kylin.dto.vo;
+
+import com.liquidnet.service.kylin.entity.KylinPerformanceStatus;
+import com.liquidnet.service.kylin.entity.KylinPerformances;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.time.format.DateTimeFormatter;
+import java.util.List;
+
+@Data
+public class TicketTimesVo {
+
+    @ApiModelProperty(value = "主键")
+    private String ticketTimesId;
+    @ApiModelProperty(value = "名称")
+    private String title;
+    @ApiModelProperty(value = "类型 1单日 2通票")
+    private int type;
+    @ApiModelProperty(value = "适用开始时间")
+    private String useStart;
+    @ApiModelProperty(value = "适用结束时间")
+    private String useEnd;
+
+    @ApiModelProperty(value = "票种信息集合")
+    private List<TicketVo> ticketVoList;
+}

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

+package com.liquidnet.service.kylin.dto.vo;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+public class TicketVo {
+
+    @ApiModelProperty(value = "主键")
+    private String ticketsId;
+    @ApiModelProperty(value = "名称")
+    private String title;
+    @ApiModelProperty(value = "类型 1单日 2通票")
+    private String type;
+    @ApiModelProperty(value = "价格")
+    private String price;
+    @ApiModelProperty(value = "快递费")
+    private String price_express;
+    @ApiModelProperty(value = "会员价格")
+    private String member_price;
+    @ApiModelProperty(value = "优惠价格")
+    private String discount_price;
+    @ApiModelProperty(value = "票种描述")
+    private String describes;
+    @ApiModelProperty(value = "快递票说明")
+    private String describe_express;
+    @ApiModelProperty(value = "电子票说明")
+    private String describe_electronic;
+    @ApiModelProperty(value = "购票开始时间")
+    private String time_start;
+    @ApiModelProperty(value = "购票结束时间")
+    private String time_end;
+    @ApiModelProperty(value = "会员购票开始时间")
+    private String member_time_start;
+    @ApiModelProperty(value = "快递票结束时间")
+    private String timeEndExpress;
+    @ApiModelProperty(value = "适用开始时间")
+    private String useStart;
+    @ApiModelProperty(value = "适用结束时间")
+    private String useEnd;
+    @ApiModelProperty(value = "开票倒计时(分钟数)")
+    private String saleRemindMinute;
+    @ApiModelProperty(value = "是否学生票")
+    private String isStudent;
+    @ApiModelProperty(value = "是否电子票")
+    private String isElectronic;
+    @ApiModelProperty(value = "是否快递票")
+    private String isExpress;
+    @ApiModelProperty(value = "状态")
+    private String status;
+    @ApiModelProperty(value = "兑换状态")
+    private String statusExchange;
+    @ApiModelProperty(value = "是否缺票登记")
+    private String isLackRegister;
+    @ApiModelProperty(value = "快递状态 1寄付 2到付")
+    private String expressType;
+    @ApiModelProperty(value = "是否实名")
+    private String isTrueName;
+    @ApiModelProperty(value = "限购张数")
+    private String limitCount;
+    @ApiModelProperty(value = "是否会员专属")
+    private String isExclusive;
+    @ApiModelProperty(value = "是否会员")
+    private String isMember;
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/partner/IKylinPerformancesPartnerService.java

@@ -23,4 +23,8 @@ public interface IKylinPerformancesPartnerService extends IService<KylinPerforma
     PerformanceStep1Param getStep1(String performancesId);
 
     PerformanceStep2Param getStep2(String performancesId);
+
+    boolean onLinePerformance(String performancesId);
+
+    boolean outLinePerformance(String performancesId);
 }

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

@@ -86,7 +86,7 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
     @Override
     public PerformanceCreatePartnerVo performanceDetails(String performancesId) {
         PerformanceCreateParam performanceData = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performancesId)), PerformanceCreateParam.class, PerformanceCreateParam.class.getSimpleName());
-        List<TicketTimesCreatePartnerVo> ticketTimesCreatePartnerVos = ticketTimesPartnerService.getTimesMongo(performancesId);
+        List<TicketTimesCreatePartnerVo> ticketTimesCreatePartnerVos = ticketTimesPartnerService.getTimesMongoList(performancesId);
         List<TicketTimesTicketCreatePartnerVo> ticketTimesTicketCreatePartnerVoList = new ArrayList<TicketTimesTicketCreatePartnerVo>();
 
         ArrayList<BigDecimal> floatList = new ArrayList<>();
@@ -177,7 +177,7 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
 
 
                 //场次数据
-                List<TicketTimesCreatePartnerVo> ticketTimesCreatePartnerVos = ticketTimesPartnerService.getTimesMongo(performancesId);
+                List<TicketTimesCreatePartnerVo> ticketTimesCreatePartnerVos = ticketTimesPartnerService.getTimesMongoList(performancesId);
                 for (TicketTimesCreatePartnerVo ticketTimeItem : ticketTimesCreatePartnerVos) {
                     //创建场次
                     KylinTicketTimes ticketTimes = new KylinTicketTimes();
@@ -232,6 +232,7 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
                         ticketStatus.setTicketStatusId(IDGenerator.nextSnowId().toString());
                         ticketStatus.setTicketId(tickets.getTicketsId());
                         ticketStatus.setCounts(1);
+                        ticketStatus.setIsMember(1);
                         ticketStatus.setStatusExchange(7);
                         ticketStatus.setQrCodeShowTime(DateUtil.asLocalDateTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(ticketItem.getQrCodeShowTime())));
 

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/partner/KylinPerformancesPartnerServiceImpl.java

 package com.liquidnet.service.kylin.service.impl.partner;
 
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.service.kylin.dto.param.PerformanceCreateParam;
 import com.liquidnet.service.kylin.dto.param.PerformanceStep1Param;
 import com.liquidnet.service.kylin.dto.param.PerformanceStep2Param;
+import com.liquidnet.service.kylin.dto.vo.PerformanceVo;
 import com.liquidnet.service.kylin.dto.vo.partner.TicketCreatePartnerVo;
 import com.liquidnet.service.kylin.dto.vo.partner.TicketTimesCreatePartnerVo;
 import com.liquidnet.service.kylin.dto.vo.partner.TicketTimesTicketCreatePartnerVo;
-import com.liquidnet.service.kylin.entity.KylinPerformances;
-import com.liquidnet.service.kylin.mapper.KylinPerformancesMapper;
+import com.liquidnet.service.kylin.entity.*;
+import com.liquidnet.service.kylin.mapper.*;
 import com.liquidnet.service.kylin.service.partner.IKylinPerformancesPartnerService;
 import com.mongodb.BasicDBObject;
 import org.springframework.beans.BeanUtils;
@@ -43,6 +45,30 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
     @Autowired
     private MongoConverter mongoConverter;
 
+    @Autowired
+    private KylinPerformancesMapper performancesMapper;
+
+    @Autowired
+    private KylinPerformanceStatusMapper performanceStatusMapper;
+
+    @Autowired
+    private KylinPerformanceRelationsMapper performanceRelationsMapper;
+
+    @Autowired
+    private KylinTicketTimesMapper ticketTimesMapper;
+
+    @Autowired
+    private KylinTicketTimeRelationMapper ticketTimeRelationMapper;
+
+    @Autowired
+    private KylinTicketsMapper ticketsMapper;
+
+    @Autowired
+    private KylinTicketStatusMapper ticketStatusMapper;
+
+    @Autowired
+    private KylinTicketRelations ticketRelations;
+
     @Autowired
     private KylinTicketsPartnerServiceImpl ticketsPartnerService;
 
@@ -118,7 +144,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                         Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
                         object
                 );
-            }else{
+            } else {
                 // 提交 演出
                 performanceCreateParam.setStatus(1);
                 PerformanceCreateParam data = mongoTemplate.insert(
@@ -128,7 +154,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
 
 
             //提交 票
-            List<TicketTimesCreatePartnerVo> ticketTimesCreatePartnerVoList = ticketTimesPartnerService.getTimesMongo(performanceId);
+            List<TicketTimesCreatePartnerVo> ticketTimesCreatePartnerVoList = ticketTimesPartnerService.getTimesMongoList(performanceId);
             for (TicketTimesCreatePartnerVo ticketTimes : ticketTimesCreatePartnerVoList) {
                 ticketsPartnerService.submitTicketByTimes(ticketTimes.getTicketTimesId());
             }
@@ -140,7 +166,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                         Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
                         object
                 );
-            }else {
+            } else {
                 // 保存 演出
                 performanceCreateParam.setStatus(0);
                 PerformanceCreateParam data = mongoTemplate.insert(
@@ -155,9 +181,9 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
     @Override
     public PerformanceStep1Param getStep1(String performancesId) {
         PerformanceStep1Param data = mongoTemplate.findOne(
-                Query.query(Criteria.where("performancesId").is(performancesId)), PerformanceStep1Param.class,PerformanceStep1Param.class.getSimpleName()
+                Query.query(Criteria.where("performancesId").is(performancesId)), PerformanceStep1Param.class, PerformanceStep1Param.class.getSimpleName()
         );
-        if(data==null){
+        if (data == null) {
             return new PerformanceStep1Param();
         }
         return data;
@@ -166,14 +192,14 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
     @Override
     public PerformanceStep2Param getStep2(String performancesId) {
         PerformanceCreateParam data = mongoTemplate.findOne(
-                Query.query(Criteria.where("performancesId").is(performancesId)), PerformanceCreateParam.class,PerformanceCreateParam.class.getSimpleName()
+                Query.query(Criteria.where("performancesId").is(performancesId)), PerformanceCreateParam.class, PerformanceCreateParam.class.getSimpleName()
         );
 
-        if(data==null){
+        if (data == null) {
             return new PerformanceStep2Param();
         }
 
-        List<TicketTimesCreatePartnerVo> ticketTimesCreatePartnerVos = ticketTimesPartnerService.getTimesMongo(performancesId);
+        List<TicketTimesCreatePartnerVo> ticketTimesCreatePartnerVos = ticketTimesPartnerService.getTimesMongoList(performancesId);
         List<TicketTimesTicketCreatePartnerVo> ticketTimesTicketCreatePartnerVoList = new ArrayList<TicketTimesTicketCreatePartnerVo>();
 
         for (TicketTimesCreatePartnerVo ticketTimes : ticketTimesCreatePartnerVos) {
@@ -185,9 +211,52 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
         }
 
         PerformanceStep2Param performanceStep2Param = new PerformanceStep2Param();
-        BeanUtils.copyProperties(data,performanceStep2Param);
+        BeanUtils.copyProperties(data, performanceStep2Param);
         performanceStep2Param.setTicketTimes(ticketTimesTicketCreatePartnerVoList);
 
         return performanceStep2Param;
     }
+
+    @Override
+    public boolean onLinePerformance(String performancesId) {
+        try {
+            // mysql
+            LocalDateTime updatedAt = LocalDateTime.now();
+            KylinPerformanceStatus performanceStatusUpdate = new KylinPerformanceStatus();
+            performanceStatusUpdate.setStatus(9);
+            performanceStatusUpdate.setUpdatedAt(updatedAt);
+            performanceStatusMapper.update(performanceStatusUpdate
+                    , new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
+
+            //mongo操作
+            KylinPerformances performancesData = performancesMapper.selectOne(new UpdateWrapper<KylinPerformances>().eq("performance_id", performancesId));
+            KylinPerformanceStatus performanceStatusData =performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
+            PerformanceVo performanceVoData = new PerformanceVo();
+            performanceVoData.setPerformance(performancesData);
+            performanceVoData.setPerformanceStatus(performanceStatusData);
+
+
+
+
+            //redis操作
+            return true;
+        } catch (Exception e) {
+            return false;
+        }
+    }
+
+    @Override
+    public boolean outLinePerformance(String performancesId) {
+        try {
+            LocalDateTime updatedAt = LocalDateTime.now();
+            KylinPerformanceStatus performanceStatus = new KylinPerformanceStatus();
+            performanceStatus.setStatus(7);
+            performanceStatus.setUpdatedAt(updatedAt);
+            performanceStatusMapper.update(performanceStatus
+                    , new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
+            return true;
+        } catch (Exception e) {
+            return false;
+        }
+    }
 }