exit lSet

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

@@ -593,12 +593,6 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
             ticketStatus.setIsAgent(status);
             ticketStatusMapper.update(ticketStatus, new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketId));
             performanceVoUtils.performanceVoStatus(performancesId);
-            //开启/关闭代理存 redis
-            if (status.equals(1)) {
-                smileRedisUtils.lSet(SmileRedisConst.SMILE_SHOW.concat(":").concat(performancesId),ticketId);
-            }else {
-                smileRedisUtils.lRemove(SmileRedisConst.SMILE_SHOW.concat(":").concat(performancesId), 1, ticketId);
-            }
             List<KylinPerformances> kylinPerformances = kylinPerformancesMapper.selectPerIdByAgent();
             List<String> collect = kylinPerformances.stream().map(KylinPerformances::getPerformancesId).collect(Collectors.toList());
             String perId = StringUtils.join(collect,",");

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/service/impl/SmileAgentServiceImpl.java

@@ -10,8 +10,10 @@ import com.liquidnet.client.admin.zhengzai.smile.service.ISmileAgentService;
 import com.liquidnet.client.admin.zhengzai.smile.utils.SmileRedisUtils;
 import com.liquidnet.service.goblin.constant.SmileRedisConst;
 import com.liquidnet.service.goblin.dto.vo.SmileAgentVo;
+import com.liquidnet.service.kylin.dao.KylinPerformancesDao;
 import com.liquidnet.service.kylin.dao.ShowAgentDao;
 import com.liquidnet.service.kylin.entity.KylinTickets;
+import com.liquidnet.service.kylin.mapper.KylinPerformancesMapper;
 import com.liquidnet.service.kylin.mapper.KylinTicketsMapper;
 import com.liquidnet.service.smile.entity.SmileAgent;
 import com.liquidnet.service.smile.mapper.SmileAgentMapper;
@@ -44,6 +46,9 @@ public class SmileAgentServiceImpl extends ServiceImpl<SmileAgentMapper, SmileAg
     @Autowired
     KylinTicketsMapper kylinTicketsMapper;
 
+    @Autowired
+    KylinPerformancesMapper kylinPerformancesMapper;
+
     @Override
     public SmileAgent listAgentByShowIdAndTicketId(String performanceId, String ticketId) {
         if (StringUtils.isNotEmpty(performanceId) && StringUtils.isNotEmpty(ticketId)) {
@@ -104,15 +109,16 @@ public class SmileAgentServiceImpl extends ServiceImpl<SmileAgentMapper, SmileAg
 
     @Override
     public AjaxResult getAgent(String performancesId) {
-        //从redis取出开启代理的票id
-        List<Object> ticketsList = smileRedisUtils.lGet(SmileRedisConst.SMILE_SHOW.concat(":").concat(performancesId), 0, -1);
-        if (StringUtils.isNotEmpty(ticketsList)) {
-            List<ShowAgentDao> smileAgentDaoList = new ArrayList<>(ticketsList.size());
-            for (Object tickets : ticketsList) {
+        //查询该演出id 开启代理的票
+        List<KylinPerformancesDao> kylinPerformancesDaoList = kylinPerformancesMapper.selectTicketIdByPerId(performancesId);
+
+        if (StringUtils.isNotEmpty(kylinPerformancesDaoList)) {
+            List<ShowAgentDao> smileAgentDaoList = new ArrayList<>(kylinPerformancesDaoList.size());
+            for (KylinPerformancesDao kylinPerformancesDao : kylinPerformancesDaoList) {
                 //根据票id查询票名
                 LambdaQueryWrapper<KylinTickets> queryWrapper = Wrappers.lambdaQuery(KylinTickets.class);
-                queryWrapper.eq(KylinTickets::getTicketsId,tickets);
-                ShowAgentDao showAgentDao = kylinTicketsMapper.selectOneByPerIdAndTicketId((String) tickets);
+                queryWrapper.eq(KylinTickets::getTicketsId, kylinPerformancesDao.getTicketId());
+                ShowAgentDao showAgentDao = kylinTicketsMapper.selectOneByPerIdAndTicketId(kylinPerformancesDao.getTicketId());
                 smileAgentDaoList.add(showAgentDao);
             }
             return AjaxResult.success(smileAgentDaoList);

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/dao/KylinPerformancesDao.java

+package com.liquidnet.service.kylin.dao;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 演出
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-05
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class KylinPerformancesDao implements Serializable, Cloneable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Integer mid;
+
+    /**
+     * 演出id
+     */
+    private String ticketId;
+
+    /**
+     * performances_id
+     */
+    private String performancesId;
+
+    /**
+     * 演出名称
+     */
+    private String title;
+
+    /**
+     * 1音乐节 2演唱会 3小型演出 4展览 6舞台剧 101音乐节 102小型演出(livehouse演出) 103巡演
+     */
+    private Integer type;
+
+    /**
+     * 演出海报
+     */
+    private String imgPoster;
+
+    /**
+     * 省id
+     */
+    private String provinceId;
+
+    /**
+     * 省名称
+     */
+    private String provinceName;
+
+    /**
+     * 城市id
+     */
+    private Integer cityId;
+
+    /**
+     * 城市名称
+     */
+    private String cityName;
+
+    /**
+     * 县id
+     */
+    private Integer districtId;
+
+    /**
+     * 县名称
+     */
+    private String districtName;
+
+    /**
+     * 批文地址
+     */
+    private String approvalUrl;
+
+    /**
+     * 演出公告
+     */
+    private String notice;
+
+    /**
+     * 主办方id
+     */
+    private String sponsorId;
+
+    /**
+     * 主办方类型
+     */
+    private String sponsorType;
+
+    /**
+     * 主办方
+     */
+    private String sponsor;
+
+    /**
+     * 联系人
+     */
+    private String contacts;
+
+    /**
+     * 联系电话
+     */
+    private String mobile;
+
+    /**
+     * 演出简介
+     */
+    private String describes;
+
+    /**
+     * 演出详情
+     */
+    private String details;
+
+    /**
+     * 购票须知
+     */
+    private String noticeImage;
+
+    /**
+     * 演出开始时间
+     */
+    private LocalDateTime timeStart;
+
+    /**
+     * 演出结束时间
+     */
+    private LocalDateTime timeEnd;
+
+    /**
+     * 提审时间
+     */
+    private LocalDateTime auditTime;
+
+    /**
+     * 拒绝理由
+     */
+    private String rejectTxt;
+
+    /**
+     * 权重 高则在上
+     */
+    private Integer sort;
+
+    /**
+     * comment
+     */
+    private String comment;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 修改时间
+     */
+    private LocalDateTime updatedAt;
+
+    private static final KylinPerformancesDao obj = new KylinPerformancesDao();
+
+    public static KylinPerformancesDao getNew() {
+        try {
+            return (KylinPerformancesDao) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new KylinPerformancesDao();
+        }
+    }
+
+    public Object[] insert(KylinPerformancesDao vo) {
+        return new Object[]{
+                vo.getPerformancesId(),
+                vo.getTitle(),
+                vo.getType(),
+                vo.getImgPoster(),
+//                vo.getProvinceId(),
+//                vo.getProvinceName(),
+                vo.getCityId(),
+                vo.getCityName(),
+//                vo.getDistrictId(),
+//                vo.getDistrictName(),
+                vo.getApprovalUrl(),
+                vo.getNotice(),
+                vo.getSponsorId(),
+                vo.getSponsorType(),
+                vo.getSponsor(),
+                vo.getContacts(),
+                vo.getMobile(),
+                vo.getDescribes(),
+                vo.getDetails(),
+                vo.getNoticeImage(),
+                vo.getTimeStart(),
+                vo.getTimeEnd(),
+//                vo.getAuditTime(),
+//                vo.getRejectTxt(),
+                0,
+                vo.getComment(),
+                vo.getCreatedAt(),
+                vo.getUpdatedAt(),
+        };
+    }
+}

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinPerformancesMapper.java

@@ -68,4 +68,6 @@ public interface KylinPerformancesMapper extends BaseMapper<KylinPerformances> {
 
     List<KylinPerformances> selectPerIdByAgent();
 
+    List<KylinPerformancesDao> selectTicketIdByPerId(@Param("performancesId") String performancesId);
+
 }

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinPerformancesMapper.xml

@@ -669,5 +669,27 @@ GROUP BY user_mobile;
         order by kp.comment, kp.time_start asc
     </select>
 
+    <select id="selectTicketIdByPerId" resultType="com.liquidnet.service.kylin.dao.KylinPerformancesDao">
+        SELECT
+            kp.performances_id,
+            kts.ticket_id,
+            kt.title,
+            kp.title,
+            kp.city_name,
+            kp.time_end,
+            kp.COMMENT
+        FROM
+            kylin_performances AS kp
+                LEFT JOIN kylin_ticket_time_relation AS kttr ON kttr.performance_id = kp.performances_id
+                LEFT JOIN kylin_ticket_relations AS ktr ON ktr.times_id = kttr.times_id
+                INNER JOIN kylin_ticket_status AS kts ON kts.ticket_id = ktr.ticket_id
+                LEFT JOIN kylin_tickets AS kt ON kt.tickets_id = ktr.ticket_id
+        WHERE
+            kts.is_agent = 1 AND kp.performances_id = #{performancesId}
+        ORDER BY
+            kp.COMMENT,
+            kp.time_start ASC
+    </select>
+
 
 </mapper>