修改列表

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

@@ -80,10 +80,19 @@ public interface IKylinTicketsPartnerService extends IService<KylinTickets> {
      */
     TicketPartnerVo getTicketsMongo(String ticketsId);
 
+    /**
+     * 票上线
+     * @param ticketsId 票id
+     * @return boolean
+     */
+    boolean onLine(String ticketsId);
 
-    //票 上线
-
-    //票 下线
+    /**
+     * 票下线
+     * @param ticketsId 票id
+     * @return boolean
+     */
+    boolean outLine(String ticketsId);
 
     //购票须知
 }

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

@@ -115,18 +115,25 @@
             <if test="title!=''">
                 AND title LIKE concat('%', #{title}, '%')
             </if>
-            <if test="status!='-2'">
+            <if test="status !='0'">
                 AND ps.STATUS = #{status}
+                <if test="status!='-2'">
+                    AND ps.STATUS = #{status}
+                </if>
+                <if test="auditStatus!='-2'">
+                    AND ps.audit_status = #{auditStatus}
+                </if>
+                <if test="timeStart!=''">
+                    AND p.time_start BETWEEN #{timeStart} AND #{timeEnd}
+                </if>
+                <if test="stopSellTime!=-1'">
+                    AND p.time_end BETWEEN #{stopSellTime} AND NOW()
+                </if>
             </if>
-            <if test="auditStatus!='-2'">
-                AND ps.audit_status = #{auditStatus}
-            </if>
-            <if test="timeStart!=''">
-                AND p.time_start BETWEEN #{timeStart} AND #{timeEnd}
-            </if>
-            <if test="stopSellTime!=-1'">
-                AND p.time_end BETWEEN #{stopSellTime} AND NOW()
+            <if test="status=='0'">
+                AND ps.STATUS = #{status}
             </if>
+
         </where>
         ORDER BY #{orderItem} #{orderSc}
     </select>

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

@@ -90,4 +90,28 @@ public class KylinTicketsPartnerController {
             return ResponseDto.success(result);
         }
     }
+
+    @PostMapping(value = "/onLine")
+    @ApiOperation(value = "票上线")
+    @ApiResponse(code = 200, message = "接口返回对象参数")
+    public ResponseDto<String> onLine(@RequestParam("ticketsId") String ticketsId) {
+        boolean result = ticketsPartnerService.onLine(ticketsId);
+        if (!result) {
+            return ResponseDto.failure("操作失败");
+        } else {
+            return ResponseDto.success("操作成功");
+        }
+    }
+
+    @PostMapping(value = "/outLine")
+    @ApiOperation(value = "票下线")
+    @ApiResponse(code = 200, message = "接口返回对象参数")
+    public ResponseDto<String> outLine(@RequestParam("ticketsId") String ticketsId) {
+        boolean result = ticketsPartnerService.outLine(ticketsId);
+        if (!result) {
+            return ResponseDto.failure("操作失败");
+        } else {
+            return ResponseDto.success("操作成功");
+        }
+    }
 }

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

@@ -7,6 +7,8 @@ import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.dto.param.TicketCreateParam;
+import com.liquidnet.service.kylin.dto.vo.TicketVo;
+import com.liquidnet.service.kylin.dto.vo.ignore.TicketIgnoreVo;
 import com.liquidnet.service.kylin.dto.vo.partner.TicketTimesPartnerVo;
 import com.liquidnet.service.kylin.dto.vo.partner.TicketPartnerVo;
 import com.liquidnet.service.kylin.entity.*;
@@ -284,4 +286,67 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
         return mongoTemplate.findOne(Query.query(Criteria.where("ticketsId").is(ticketsId)), TicketPartnerVo.class, TicketPartnerVo.class.getSimpleName());
     }
 
+    @Override
+    public boolean onLine(String ticketsId) {
+        LocalDateTime updatedAt = LocalDateTime.now();
+        KylinTicketStatus ticketStatus = ticketStatusMapper.selectOne(new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketsId));
+        if (ticketStatus.getStatus() >= 3 && ticketStatus.getStatus() != 4 && ticketStatus.getStatus() != 6) {//未提审||被拒绝
+            //mysql
+            KylinTicketStatus changeStatus = new KylinTicketStatus();
+            changeStatus.setUpdatedAt(updatedAt);
+            changeStatus.setStatus(6);
+            ticketStatusMapper.update(changeStatus, new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketsId));
+
+            // mongo 操作
+            KylinTicketStatus ticketStatusMongo = ticketStatusMapper.selectOne(new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketsId).between("status", 1, 10).ne("status", 7));
+            KylinTicketRelations ticketRelation = ticketRelationsMapper.selectOne(new UpdateWrapper<KylinTicketRelations>().eq("ticket_id", ticketsId));
+            KylinTickets tickets = ticketsMapper.selectOne(
+                    new UpdateWrapper<KylinTickets>().eq("tickets_id", ticketsId
+                    )
+            );
+
+            TicketVo ticketVo = new TicketVo();
+            ticketVo.setTimeId(ticketRelation.getTimesId());
+            ticketVo.setTicket(tickets);
+            ticketVo.setTicketStatus(ticketStatusMongo);
+
+            boolean ticketExists =
+                    mongoTemplate.exists(Query.query(Criteria.where("ticketsId").is(ticketVo.getTicketsId())), TicketVo.class, TicketVo.class.getSimpleName());
+            if (!ticketExists) {
+                mongoTemplate.insert(
+                        ticketVo, TicketVo.class.getSimpleName()
+                );
+            }
+            //TODO 修改misVo
+
+            return true;
+        } else {
+            return false;
+        }
+    }
+
+    @Override
+    public boolean outLine(String ticketsId) {
+        LocalDateTime updatedAt = LocalDateTime.now();
+        KylinTicketStatus ticketStatus = ticketStatusMapper.selectOne(new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketsId));
+        if (ticketStatus.getStatus() >= 3 && ticketStatus.getStatus() != 4 && ticketStatus.getStatus() != 7) {//未提审||被拒绝
+            //mysql
+            KylinTicketStatus changeStatus = new KylinTicketStatus();
+            changeStatus.setUpdatedAt(updatedAt);
+            changeStatus.setStatus(7);
+            ticketStatusMapper.update(changeStatus, new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketsId));
+            // mongo 操作
+            TicketVo ticketVoItem = mongoTemplate.findOne(Query.query(Criteria.where("ticketsId").is(ticketsId)), TicketVo.class, TicketVo.class.getSimpleName());
+            TicketIgnoreVo ticketIgnoreVo = new TicketIgnoreVo();
+            BeanUtils.copyProperties(ticketVoItem, ticketIgnoreVo);
+            mongoTemplate.remove(Query.query(Criteria.where("ticketsId").is(ticketVoItem.getTicketsId())), TicketIgnoreVo.class, TicketIgnoreVo.class.getSimpleName());
+            mongoTemplate.insert(ticketIgnoreVo, TicketIgnoreVo.class.getSimpleName());
+            mongoTemplate.remove(Query.query(Criteria.where("ticketsId").is(ticketVoItem.getTicketsId())), TicketVo.class, TicketVo.class.getSimpleName());
+            //TODO 删除misVo
+            return true;
+        } else {
+            return false;
+        }
+    }
+
 }