提交缺票登记

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

+package com.liquidnet.service.kylin.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.kylin.entity.KylinLackRegisters;
+
+public interface IKylinLackRegistersService extends IService<KylinLackRegisters> {
+
+    ResponseDto<String> addLackRegister(String performanceId,String ticketId);
+
+}

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

@@ -102,7 +102,7 @@
 ////        String[] dbTableArray = new String[]{"kylin_buy_notice"};
 ////        String[] dbTableArray = new String[]{"kylin_order_tickets","kylin_order_ticket_relations","kylin_order_ticket_status","kylin_order_ticket_entities"};
 ////        String[] dbTableArray = new String[]{"kylin_check_user","kylin_check_user_performances"};
-//        String[] dbTableArray = new String[]{"express_batches","express_logs","express_timelines","expresses"};
+//        String[] dbTableArray = new String[]{"kylin_lack_registers"};
 //
 //        doGenerator(resourcePath, dsc, directory, dbTableArray);
 //    }

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/entity/KylinLackRegisters.java

+package com.liquidnet.service.kylin.entity;
+
+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;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class KylinLackRegisters implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Integer mid;
+
+    /**
+     * lack_registers_id
+     */
+    private String lackRegistersId;
+
+    /**
+     * performance_id
+     */
+    private String performanceId;
+
+    /**
+     * ticket_id
+     */
+    private String ticketId;
+
+    /**
+     * user_id
+     */
+    private String userId;
+
+    /**
+     * user_name
+     */
+    private String userName;
+
+    /**
+     * user_mobile
+     */
+    private String userMobile;
+
+    /**
+     * send_status
+     */
+    private Integer sendStatus;
+
+    /**
+     * ip_address
+     */
+    private String ipAddress;
+
+    /**
+     * created_at
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * updated_at
+     */
+    private LocalDateTime updatedAt;
+
+    /**
+     * 获取 支付回调 数据库参数
+     *
+     * @return
+     */
+    public Object[] getInsertObj() {
+        return new Object[]{
+                lackRegistersId, performanceId, ticketId,userId,userName,userMobile,0,ipAddress,createdAt
+        };
+    }
+}

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

+package com.liquidnet.service.kylin.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.liquidnet.service.kylin.entity.KylinLackRegisters;
+import com.liquidnet.service.kylin.entity.KylinOrderTicketRelations;
+
+/**
+ * <p>
+ * 订单关系 Mapper 接口
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-20
+ */
+public interface KylinLackRegistersMapper extends BaseMapper<KylinLackRegisters> {
+
+}

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

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.liquidnet.service.kylin.mapper.KylinLackRegistersMapper">
+
+</mapper>

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/docu/db_kylin_structure.sql

@@ -348,6 +348,7 @@ CREATE TABLE `kylin_lack_registers`
 (
     `mid`               int(11)      NOT NULL AUTO_INCREMENT,
     `lack_registers_id` varchar(255) NOT NULL DEFAULT '' COMMENT 'lack_registers_id',
+    `performance_id`         varchar(255) NOT NULL DEFAULT '' COMMENT '票种id',
     `ticket_id`         varchar(255) NOT NULL DEFAULT '' COMMENT '票种id',
     `user_id`           varchar(255) NOT NULL DEFAULT '' COMMENT '用户id',
     `user_name`         varchar(255) NOT NULL DEFAULT '' COMMENT '用户昵称',

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

@@ -4,6 +4,7 @@ package com.liquidnet.service.kylin.controller;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.liquidnet.service.kylin.dto.vo.returns.PayDetailVo;
+import com.liquidnet.service.kylin.service.impl.KylinLackRegistersServiceImpl;
 import com.liquidnet.service.kylin.service.impl.KylinPerformancesServiceImpl;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
@@ -31,6 +32,8 @@ public class KylinPerformancesController {
 
     @Autowired
     private KylinPerformancesServiceImpl kylinPerformancesService;
+    @Autowired
+    private KylinLackRegistersServiceImpl kylinLackRegistersService;
 
     @GetMapping("localList")
     @ApiOperation("本地演出列表")
@@ -218,4 +221,14 @@ public class KylinPerformancesController {
     public ResponseDto<String> checkPerformanceTime(){
         return ResponseDto.success(kylinPerformancesService.checkPerformanceTime());
     }
+
+    @PostMapping("lackRegister")
+    @ApiOperation("缺票登记")
+    @ApiImplicitParams({
+            @ApiImplicitParam(type = "query", dataType = "String", name = "performancesId", value = "演出id", required = true),
+            @ApiImplicitParam(type = "query", dataType = "String", name = "ticketsId", value = "票种id", required = true)
+    })
+    public ResponseDto<String> addLackRegister(@RequestParam("performancesId") String performancesId, @RequestParam("ticketsId") String ticketsId){
+        return kylinLackRegistersService.addLackRegister(performancesId,ticketsId);
+    }
 }

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

+package com.liquidnet.service.kylin.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.liquidnet.common.mq.constant.MQConst;
+import com.liquidnet.commons.lang.util.CurrentUtil;
+import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.base.SqlMapping;
+import com.liquidnet.service.kylin.entity.KylinLackRegisters;
+import com.liquidnet.service.kylin.mapper.KylinLackRegistersMapper;
+import com.liquidnet.service.kylin.service.IKylinLackRegistersService;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDateTime;
+import java.util.Map;
+
+@Service
+public class KylinLackRegistersServiceImpl extends ServiceImpl<KylinLackRegistersMapper, KylinLackRegisters> implements IKylinLackRegistersService {
+
+    @Autowired
+    private RabbitTemplate rabbitTemplate;
+
+    @Override
+    public ResponseDto<String> addLackRegister(String performanceId, String ticketId) {
+        try {
+            KylinLackRegisters lackRegisters = new KylinLackRegisters();
+            Map token = CurrentUtil.getTokenClaims();
+            lackRegisters.setLackRegistersId(IDGenerator.nextSnowId().toString());
+            lackRegisters.setPerformanceId(performanceId);
+            lackRegisters.setTicketId(ticketId);
+            lackRegisters.setUserId(CurrentUtil.getCurrentUid());
+            lackRegisters.setUserName(StringUtils.defaultString(((String) token.get("nickname")), ""));
+            lackRegisters.setUserMobile(StringUtils.defaultString(((String) token.get("mobile")), ""));
+            lackRegisters.setIpAddress(CurrentUtil.getCliIpAddr());
+            lackRegisters.setCreatedAt(LocalDateTime.now());
+            rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
+                    SqlMapping.get("kylin_order_ticket_status.close", lackRegisters.getInsertObj()));
+            return ResponseDto.success("登记成功");
+        }catch (Exception e){
+            return ResponseDto.success("登记失败");
+        }
+    }
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/resources/sqlmap.properties

@@ -17,3 +17,4 @@ kylin_order_ticket.synPay=UPDATE  kylin_order_tickets SET payment_type = ? ,pay_
 kylin_order_ticket.close=UPDATE  kylin_order_tickets SET updated_at = ? WHERE order_tickets_id = ? 
 
 # ----------------------------------------------------
+kylin_lack_register.insert=INSERT INTO `kylin_lack_registers`(`lack_registers_id` ,`performance_id` ,`ticket_id` ,`user_id` ,`user_name` ,`user_mobile` ,`send_status` ,`ip_address` ,`created_at` ,)VALUES(? ,? ,? ,? ,? ,? ,? ,? ,?);