feat(mq): 新增直播明细消息队列与处理链路

- 新增 ServerLiveHostDetail 实体、Mapper、Service 及实现类
- MQSender 新增 liveHostDetailSend 方法，MQReceiver 新增 liveHostDetailReceive 消费者
- RabbitMQConfig 补充 LIVE_HOST_DETAIL 队列定义
- HostInfoController 新增 add_live_host_detail 接口，支持批量接收直播明细数据
- .gitignore 忽略 CLAUDE.md 日志文件

.gitignore

@@ -146,4 +146,5 @@ fabric.properties
 .idea/caches/build_file_checksums.ser
 
 !/.xcodemap/
-!/tk-data-save.log
+/tk-data-save.log
+/CLAUDE.md

pom.xml

@@ -88,7 +88,7 @@
         <dependency>
             <groupId>com.google.guava</groupId>
             <artifactId>guava</artifactId>
-            <version>r07</version>
+            <version>30.1-jre</version>
         </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>

src/main/java/com/yupi/springbootinit/aop/LogInterceptor.java

@@ -42,10 +42,10 @@ public class LogInterceptor {
         Object[] args = point.getArgs();
         String reqParam = "[" + StringUtils.join(args, ", ") + "]";
         // 输出请求日志
-//        log.info("request start，id: {}, path: {}, ip: {}, params: {}", requestId, url,
+        log.info("request start，id: {}, path: {}, ip: {}, params: {}", requestId, url,
-//                httpServletRequest.getRemoteHost(), reqParam);
+                httpServletRequest.getRemoteHost(), reqParam);
-        log.info("request start，id: {}, path: {}, ip: {}", requestId, url,
+//        log.info("request start，id: {}, path: {}, ip: {}", requestId, url,
-                httpServletRequest.getRemoteHost());
+//                httpServletRequest.getRemoteHost());
         // 执行原方法
         Object result = point.proceed();
         // 输出响应日志

src/main/java/com/yupi/springbootinit/common/DelayedRabbitMQStarter.java

@@ -0,0 +1,27 @@
+package com.yupi.springbootinit.common;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Component
+@Slf4j
+public class DelayedRabbitMQStarter implements ApplicationRunner {
+    
+    @Resource
+    private RabbitListenerEndpointRegistry registry; // Spring 提供的监听器注册表
+    
+    @Override
+    public void run(ApplicationArguments args) throws Exception {
+        // 延迟 5 秒后启动监听器
+        log.info("延迟5秒启动 rabbitMQ 监听");
+        Thread.sleep(5000);
+        registry.getListenerContainer("hosts").start();
+        registry.getListenerContainer("bigbrother").start();
+    }
+}

src/main/java/com/yupi/springbootinit/config/RabbitMQConfig.java

@@ -5,9 +5,11 @@ import com.fasterxml.jackson.annotation.PropertyAccessor;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.SerializationFeature;
 import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
-import com.rabbitmq.client.ConnectionFactory;
+import org.springframework.amqp.core.ExchangeBuilder;
+import org.springframework.amqp.core.HeadersExchange;
 import org.springframework.amqp.core.Queue;
-import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.amqp.rabbit.core.RabbitAdmin;
 import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
 import org.springframework.amqp.support.converter.MessageConverter;
 import org.springframework.context.annotation.Bean;
@@ -15,7 +17,17 @@ import org.springframework.context.annotation.Configuration;
 
 @Configuration
 public class RabbitMQConfig {
+
     private static final String QUEUE = "HOST_INFO_QUEUE";
+    private static final String LIVE_HOST_DETAIL_QUEUE = "LIVE_HOST_DETAIL";
+
+    public static final String EXCHANGE_NAME = "user.headers.exchange";
+
+    public static final String AI_CHAT_EXCHANGE_NAME = "ai.chat.headers.exchange";
+    public static final String BIG_BROTHER_EXCHANGE_NAME = "big.brother.headers.exchange";
+    public static final String WEB_AI_EXCHANGE_NAME = "web.ai.headers.exchange";
+
+
 
     //创建队列
     //true:表示持久化
@@ -26,12 +38,54 @@ public class RabbitMQConfig {
         return new Queue(QUEUE,true);
     }
 
+    @Bean
+    public Queue liveHostDetailQueue(){
+        return new Queue(LIVE_HOST_DETAIL_QUEUE,true);
+    }
+
 //
 //    @Bean
 //    public MessageConverter messageConverter(){
 //        return new Jackson2JsonMessageConverter();
 //    }
 
+
+
+    @Bean
+    public HeadersExchange userHeadersExchange() {
+        return ExchangeBuilder.headersExchange(EXCHANGE_NAME)
+                .durable(true)
+                .build();
+    }
+
+    @Bean
+    public HeadersExchange aiChatHeadersExchange() {
+        return ExchangeBuilder.headersExchange(AI_CHAT_EXCHANGE_NAME)
+                .durable(true)
+                .build();
+    }
+
+    @Bean
+    public HeadersExchange bigBrotherHeadersExchange() {
+        return ExchangeBuilder.headersExchange(BIG_BROTHER_EXCHANGE_NAME)
+                .durable(true)
+                .build();
+    }
+
+    @Bean
+    public HeadersExchange webAiHeadersExchange() {
+        return ExchangeBuilder.headersExchange(WEB_AI_EXCHANGE_NAME)
+                .durable(true)
+                .build();
+    }
+
+
+    @Bean
+    public RabbitAdmin rabbitAdmin(ConnectionFactory cf) {
+        return new RabbitAdmin(cf);
+    }
+
+
     @Bean
     public MessageConverter messageConverter() {
         ObjectMapper om = new ObjectMapper();

src/main/java/com/yupi/springbootinit/config/RedisConfig.java

@@ -6,6 +6,7 @@ import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.data.redis.connection.RedisConnectionFactory;
 import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
 import org.springframework.data.redis.serializer.RedisSerializer;
 import org.springframework.data.redis.serializer.StringRedisSerializer;
 
@@ -13,25 +14,24 @@ import org.springframework.data.redis.serializer.StringRedisSerializer;
 public class RedisConfig {
 
 
-    @Bean(name="redisTemplate")
+    @Bean
-    public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
-        RedisTemplate<String, String> template = new RedisTemplate<>();
+        RedisTemplate<String, Object> template = new RedisTemplate<>();
-        RedisSerializer<String> redisSerializer = new StringRedisSerializer();
         template.setConnectionFactory(factory);
-        //key序列化方式
+
-        template.setKeySerializer(redisSerializer);
+        // 使用 JSON 序列化器
-        //value序列化
+        GenericJackson2JsonRedisSerializer jsonSerializer = new GenericJackson2JsonRedisSerializer();
-        template.setValueSerializer(redisSerializer);
+
-        //value hashmap序列化
+        template.setKeySerializer(new StringRedisSerializer());
-        template.setHashValueSerializer(redisSerializer);
+        template.setValueSerializer(jsonSerializer);
-        //key haspmap序列化
+        template.setHashKeySerializer(new StringRedisSerializer());
-        template.setHashKeySerializer(redisSerializer);
+        template.setHashValueSerializer(jsonSerializer);
-        //
+
+        template.afterPropertiesSet();
         return template;
     }
 
 
 
 
-
 }

src/main/java/com/yupi/springbootinit/controller/BigBrotherController.java

@@ -2,15 +2,12 @@ package com.yupi.springbootinit.controller;
 
 import com.yupi.springbootinit.common.BaseResponse;
 import com.yupi.springbootinit.common.ResultUtils;
-import com.yupi.springbootinit.model.entity.NewHosts;
 import com.yupi.springbootinit.model.entity.ServerBigBrother;
 import com.yupi.springbootinit.rabbitMQ.MQSender;
-import com.yupi.springbootinit.service.HostInfoService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
-import java.util.List;
 
 /*
  * @author: ziin

src/main/java/com/yupi/springbootinit/controller/HostInfoController.java

@@ -2,15 +2,13 @@ package com.yupi.springbootinit.controller;
 
 import com.yupi.springbootinit.common.BaseResponse;
 import com.yupi.springbootinit.common.ResultUtils;
-import com.yupi.springbootinit.model.dto.host.HostInfoDTO;
 import com.yupi.springbootinit.model.dto.host.QueryCountDTO;
 import com.yupi.springbootinit.model.entity.NewHosts;
+import com.yupi.springbootinit.model.entity.ServerLiveHostDetail;
 import com.yupi.springbootinit.model.vo.country.CountryInfoVO;
-import com.yupi.springbootinit.model.vo.hosts.NewHostsVO;
 import com.yupi.springbootinit.rabbitMQ.MQSender;
 import com.yupi.springbootinit.service.HostInfoService;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.ibatis.annotations.Param;
 import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
@@ -39,6 +37,12 @@ public class HostInfoController {
         return ResultUtils.success(true);
     }
 
+    @PostMapping("add_live_host_detail")
+    public BaseResponse<Boolean> addLiveHostDetail(@RequestBody List<ServerLiveHostDetail> liveHostDetails){
+        mqSender.liveHostDetailSend(liveHostDetails);
+        return ResultUtils.success(true);
+    }
+
     @GetMapping("country_info")
     public BaseResponse<List<String>> getCountryInfo(@RequestParam(name = "countryName") String countryName){
         List<CountryInfoVO> countryInfo = hostInfoService.getCountryInfo(countryName);

src/main/java/com/yupi/springbootinit/controller/SseController.java

@@ -0,0 +1,42 @@
+package com.yupi.springbootinit.controller;
+
+import cn.hutool.json.JSONUtil;
+import com.yupi.springbootinit.model.entity.NewHosts;
+import com.yupi.springbootinit.utils.SseEmitterUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
+
+@Slf4j
+@RestController
+@RequestMapping("/sse")
+public class SseController {
+ 
+    /**
+     * 用于创建连接
+     */
+    @GetMapping("/connect/{tenantID}/{userId}")
+    public SseEmitter connect(@PathVariable String  tenantID,@PathVariable String userId) {
+        return SseEmitterUtil.connect(tenantID+"-"+userId);
+    }
+ 
+    /**
+     * 关闭连接
+     */
+    @GetMapping("/close/{tenantID}/{userId}")
+    public void close(@PathVariable String  tenantID,@PathVariable String userId) {
+        SseEmitterUtil.removeUser(tenantID+"-"+userId);
+    }
+ 
+    @GetMapping("/sse")
+    public void sse(String connectId,String message){
+        // 构建推送消息体
+        NewHosts newHosts = new NewHosts();
+        newHosts.setId(123123213L);
+        newHosts.setHostsId(message);
+        SseEmitterUtil.sendMessage(connectId, JSONUtil.toJsonStr(newHosts));
+    }
+}

src/main/java/com/yupi/springbootinit/mapper/ServerLiveHostDetailMapper.java

@@ -0,0 +1,12 @@
+package com.yupi.springbootinit.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yupi.springbootinit.model.entity.ServerLiveHostDetail;
+
+/*
+* @author: ziin
+* @date: 2025/12/17 20:45
+*/
+    
+public interface ServerLiveHostDetailMapper extends BaseMapper<ServerLiveHostDetail> {
+}

src/main/java/com/yupi/springbootinit/model/dto/host/HostInfoDTO.java

@@ -86,4 +86,6 @@ public class HostInfoDTO {
     @ApiModelProperty(value = "入库人", example = "1001")
     private Integer creator;
 
+
+
 }

src/main/java/com/yupi/springbootinit/model/entity/NewHosts.java

@@ -10,9 +10,9 @@ import java.time.LocalDateTime;
 import java.util.Date;
 
 /*
-* @author: ziin
+ * @author: ziin
-* @date: 2025/6/10 18:54
+ * @date: 2025/6/10 18:54
-*/
+ */
 @Data
 @ApiModel("主播信息DTO")
 public class NewHosts {
@@ -75,6 +75,9 @@ public class NewHosts {
     @ApiModelProperty(value = "主播国家", example = "中国")
     private String country;
 
+    @ApiModelProperty(value = "主播国家英文", example = "China")
+    private String countryEng;
+    
     /**
      * 直播类型 娱乐，游戏
      */

src/main/java/com/yupi/springbootinit/model/entity/ServerBigBrother.java

@@ -13,6 +13,7 @@ import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
 import com.fasterxml.jackson.databind.annotation.JsonSerialize;
 import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateDeserializer;
 import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
+import io.swagger.models.auth.In;
 import lombok.Data;
 import org.springframework.format.annotation.DateTimeFormat;
 
@@ -109,7 +110,11 @@ public class ServerBigBrother {
     private Long tenantId;
 
     @TableField(value = "create_time")
-
     private LocalDateTime createTime;
 
+    @TableField(value = "fans_level")
+    private Integer fansLevel;
+
+    @TableField(value = "secUid")
+    private String secUid;
 }

src/main/java/com/yupi/springbootinit/model/entity/ServerLiveHostDetail.java

@@ -0,0 +1,114 @@
+package com.yupi.springbootinit.model.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.util.Date;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+
+/*
+* @author: ziin
+* @date: 2025/12/17 20:45
+*/
+    
+/**
+ * 主播单场直播明细表
+ */
+@Data
+@TableName(value = "server_live_host_detail")
+public class ServerLiveHostDetail {
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 当前用户标识
+     */
+    @TableField(value = "user_id")
+    private Long userId;
+
+    /**
+     * 主播名称
+     */
+    @TableField(value = "hosts_id")
+    private String hostsId;
+
+    /**
+     * 粉丝团人数
+     */
+    @TableField(value = "fans_club_count")
+    private Integer fansClubCount;
+
+    /**
+     * 礼物之比
+     */
+    @TableField(value = "lighted_vs_total_gifts")
+    private String lightedVsTotalGifts;
+
+    /**
+     * 直播开始时间（格式化）
+     */
+    @TableField(value = "start_time_formatted")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date startTimeFormatted;
+
+    /**
+     * 直播结束时间（格式化）
+     */
+    @TableField(value = "end_time_formatted")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date endTimeFormatted;
+
+    /**
+     * 获得的点赞数量
+     */
+    @TableField(value = "like_count")
+    private Integer likeCount;
+
+    /**
+     * 持续时间（格式化）
+     */
+    @TableField(value = "duration_formatted")
+    private String durationFormatted;
+
+    /**
+     * 记录创建时间
+     */
+    @TableField(value = "create_time")
+    private Date createTime;
+
+    /**
+     * 记录更新时间
+     */
+    @TableField(value = "update_time")
+    private Date updateTime;
+
+    /**
+     * 租户 Id
+     */
+    @TableField(value = "tenant_id")
+    private Long tenantId;
+
+    /**
+     * 是否删除
+     */
+    @TableField(value = "deleted")
+    private Byte deleted;
+
+    /**
+     * 更新人
+     */
+    @TableField(value = "updater")
+    private String updater;
+
+    /**
+     * 创建人
+     */
+    @TableField(value = "creator")
+    private String creator;
+}

src/main/java/com/yupi/springbootinit/rabbitMQ/MQReceiver.java

@@ -7,11 +7,14 @@ import com.yupi.springbootinit.common.ErrorCode;
 import com.yupi.springbootinit.exception.BusinessException;
 import com.yupi.springbootinit.model.entity.NewHosts;
 import com.yupi.springbootinit.model.entity.ServerBigBrother;
+import com.yupi.springbootinit.model.entity.ServerLiveHostDetail;
 import com.yupi.springbootinit.service.HostInfoService;
 import com.yupi.springbootinit.service.ServerBigBrotherService;
+import com.yupi.springbootinit.service.ServerLiveHostDetailService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.context.annotation.Lazy;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
@@ -28,6 +31,9 @@ public class MQReceiver {
     @Resource
     private ServerBigBrotherService serverBigBrotherService;
 
+    @Resource
+    private ServerLiveHostDetailService serverLiveHostDetailService;
+
 
 //    //方法：接收消息
 //    @RabbitListener(queues = "HOST_INFO_QUEUE")
@@ -44,7 +50,7 @@ public class MQReceiver {
 //        }
 //    }
 
-    @RabbitListener(queues = "HOST_INFO_QUEUE")
+    @RabbitListener(queues = "HOST_INFO_QUEUE",id = "hosts", autoStartup = "false")
     @Async("taskExecutor")
     public void receive(List<NewHosts> hosts, Channel channel, Message message) throws IOException {
         long deliveryTag = message.getMessageProperties().getDeliveryTag();
@@ -61,7 +67,7 @@ public class MQReceiver {
         }
     }
 
-    @RabbitListener(queues = "BIG_BROTHER_QUEUE")
+    @RabbitListener(queues = "BIG_BROTHER_QUEUE",id = "bigbrother", autoStartup = "true")
     @Async("taskExecutor")
     public void bigBrotherReceive(ServerBigBrother bigBrotherList, Channel channel, Message message) throws IOException {
         long deliveryTag = message.getMessageProperties().getDeliveryTag();
@@ -78,4 +84,18 @@ public class MQReceiver {
             throw new BusinessException(ErrorCode.QUEUE_CONSUMPTION_FAILURE);
         }
     }
+
+    @RabbitListener(queues = "LIVE_HOST_DETAIL",id = "liveHostDetail", autoStartup = "true")
+    @Async("taskExecutor")
+    public void liveHostDetailReceive(List<ServerLiveHostDetail> details, Channel channel, Message message) throws IOException {
+        long deliveryTag = message.getMessageProperties().getDeliveryTag();
+        try {
+            serverLiveHostDetailService.processLiveHostDetails(details);
+            channel.basicAck(deliveryTag, false);
+        } catch (Exception e) {
+            channel.basicNack(deliveryTag, false, false);
+            log.error("直播明细消息消费失败，数量: {}", details.size(), e);
+            throw new BusinessException(ErrorCode.QUEUE_CONSUMPTION_FAILURE);
+        }
+    }
  }

src/main/java/com/yupi/springbootinit/rabbitMQ/MQSender.java

@@ -2,13 +2,20 @@ package com.yupi.springbootinit.rabbitMQ;
 
 import cn.hutool.core.date.DateTime;
 import com.yupi.springbootinit.common.ErrorCode;
+import com.yupi.springbootinit.config.RabbitMQConfig;
 import com.yupi.springbootinit.exception.BusinessException;
 import com.yupi.springbootinit.model.entity.NewHosts;
 import com.yupi.springbootinit.model.entity.ServerBigBrother;
+import com.yupi.springbootinit.model.entity.ServerLiveHostDetail;
+import io.swagger.models.auth.In;
+import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.core.HeadersExchange;
+import org.springframework.amqp.rabbit.core.RabbitAdmin;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
 import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -16,7 +23,8 @@ import java.time.LocalDateTime;
 import java.util.List;
 
 @Slf4j
-@Service
+@Component
+@RequiredArgsConstructor
 public class MQSender {
 
     @Resource
@@ -33,6 +41,16 @@ public class MQSender {
             throw  new BusinessException(ErrorCode.QUEUE_ERROR);
         }
     }
+
+    //方法:发送直播明细消息
+    public void liveHostDetailSend(List<ServerLiveHostDetail> list){
+        try {
+            rabbitTemplate.convertAndSend("LIVE_HOST_DETAIL",list);
+        }catch (Exception e){
+            throw  new BusinessException(ErrorCode.QUEUE_ERROR);
+        }
+    }
+
     //方法:发送消息
     public void bigBrotherSend(ServerBigBrother bigBrothers){
         try {
@@ -45,4 +63,31 @@ public class MQSender {
             throw  new BusinessException(ErrorCode.QUEUE_ERROR);
         }
     }
+
+
+    public void send(Long tenantId, Object payload) {
+        // 发送消息，把 userId 放进 header
+        rabbitTemplate.convertAndSend(RabbitMQConfig.AI_CHAT_EXCHANGE_NAME, "", payload, m -> {
+            m.getMessageProperties().getHeaders().put("tenantId", tenantId);
+            return m;
+        });
+    }
+
+    public void brotherSend(Long tenantId, Object payload) {
+        // 发送消息，把 userId 放进 header
+        rabbitTemplate.convertAndSend(RabbitMQConfig.BIG_BROTHER_EXCHANGE_NAME, "", payload, m -> {
+            m.getMessageProperties().getHeaders().put("tenantId", tenantId);
+            return m;
+        });
+    }
+
+    public void webAISend(Long tenantId, Object payload) {
+        // 发送消息，把 userId 放进 header
+        rabbitTemplate.convertAndSend(RabbitMQConfig.WEB_AI_EXCHANGE_NAME, "", payload, m -> {
+            m.getMessageProperties().getHeaders().put("tenantId", tenantId);
+            return m;
+        });
+    }
+
+
 }

src/main/java/com/yupi/springbootinit/service/ServerLiveHostDetailService.java

@@ -0,0 +1,18 @@
+package com.yupi.springbootinit.service;
+
+import com.yupi.springbootinit.model.entity.ServerLiveHostDetail;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+
+    /*
+* @author: ziin
+* @date: 2025/12/17 20:45
+*/
+
+public interface ServerLiveHostDetailService extends IService<ServerLiveHostDetail>{
+
+    CompletableFuture<Void> processLiveHostDetails(List<ServerLiveHostDetail> details);
+
+}

src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java

@@ -1,27 +1,29 @@
 package com.yupi.springbootinit.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.google.common.collect.Lists;
 import com.yupi.springbootinit.mapper.CountryInfoMapper;
 import com.yupi.springbootinit.mapper.NewHostsMapper;
 import com.yupi.springbootinit.model.dto.host.QueryCountDTO;
 import com.yupi.springbootinit.model.entity.NewHosts;
 import com.yupi.springbootinit.model.vo.country.CountryInfoVO;
+import com.yupi.springbootinit.rabbitMQ.MQSender;
 import com.yupi.springbootinit.service.HostInfoService;
+import com.yupi.springbootinit.utils.JsonUtils;
+import com.yupi.springbootinit.utils.RedisUtils;
+import com.yupi.springbootinit.utils.SseEmitterUtil;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.data.redis.core.StringRedisTemplate;
-import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StopWatch;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
 import javax.annotation.Resource;
-import java.util.ArrayList;
 import java.util.List;
+import java.util.Set;
 import java.util.concurrent.CompletableFuture;
 
+
 /*
  * @author: ziin
  * @date: 2025/6/10 19:04
@@ -39,6 +41,13 @@ public class HostInfoServiceImpl extends ServiceImpl<NewHostsMapper, NewHosts> i
     private RedisTemplate redisTemplate;
 
 
+    @Resource
+    private RedisUtils redisUtils;
+
+    @Resource
+    private MQSender mqSender;
+
+
 //
 //    private  final RedisTemplate<String,Object> redisTemplate;
 //
@@ -49,16 +58,46 @@ public class HostInfoServiceImpl extends ServiceImpl<NewHostsMapper, NewHosts> i
 
     @Override
     public CompletableFuture<Void> saveHostInfo(List<NewHosts> newHosts) {
+
         try {
             StopWatch stopWatch = new StopWatch();
             stopWatch.start();
             saveBatch(newHosts);
+            NewHosts sseConnectConfirmInfo = newHosts.get(0);
+            SseEmitter sseEmitter = SseEmitterUtil.getSseEmitter(sseConnectConfirmInfo.getTenantId().toString() + "-" + sseConnectConfirmInfo.getUserId().toString());
+            if (sseEmitter != null) {
+                NewHosts forChannelInfo = newHosts.get(0);
+                SseEmitterUtil.sendMessage(forChannelInfo.getTenantId().toString()+"-"+forChannelInfo.getUserId().toString(),"start");
+                newHosts.forEach(newHost -> {
+                    SseEmitterUtil.sendMessage(newHost.getTenantId().toString()+"-"+newHost.getUserId().toString(),
+                            JsonUtils.toJsonString(newHost));
+                });
+            }
+
+//            Boolean o = (Boolean) redisTemplate.opsForValue().get("ai_login:"+newHosts.get(0).getTenantId());
+            if (redisUtils.hasKeyByPrefix("ai_login:"+ newHosts.get(0).getTenantId())) {
+                newHosts.forEach(newHost -> {
+                    mqSender.send(newHost.getTenantId(),newHost);
+                });
+
+                log.info("发送消息到队列{}, 消息数量: {}", newHosts.get(0).getTenantId(), newHosts.size());
+            }
+
+            if (redisUtils.hasKeyByPrefix("webAI_login:"+ newHosts.get(0).getTenantId())) {
+                newHosts.forEach(newHost -> {
+                    mqSender.webAISend(newHost.getTenantId(),newHost);
+                });
+                log.info("发送消息到队列WebAI{}, 消息数量: {}", newHosts.get(0).getTenantId(), newHosts.size());
+            }
+
+
             stopWatch.stop();
             long totalTimeMillis = stopWatch.getTotalTimeMillis();
             log.info("当前存储数据量大小 {}, 存储花费: {}ms",newHosts.size(),totalTimeMillis);
             return CompletableFuture.completedFuture(null);
         } catch (Exception e) {
             // 将异常包装到Future，使调用方能处理
+            log.error(e.getMessage());
             return CompletableFuture.failedFuture(e);
         }
     }
@@ -109,7 +148,6 @@ public class HostInfoServiceImpl extends ServiceImpl<NewHostsMapper, NewHosts> i
 
     @Override
     public void queryCount(QueryCountDTO queryCountDTO) {
-
         redisTemplate.opsForValue().increment( "tkaccount:" + queryCountDTO.getTkAccount(),1);
     }
 

src/main/java/com/yupi/springbootinit/service/impl/ServerBigBrotherServiceImpl.java

@@ -3,6 +3,8 @@ package com.yupi.springbootinit.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
+import com.yupi.springbootinit.rabbitMQ.MQSender;
+import com.yupi.springbootinit.utils.RedisUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
@@ -14,6 +16,8 @@ import com.yupi.springbootinit.model.entity.ServerBigBrother;
 import com.yupi.springbootinit.service.ServerBigBrotherService;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StopWatch;
+
+import javax.annotation.Resource;
 /*
 * @author: ziin
 * @date: 2025/6/24 16:19
@@ -23,6 +27,12 @@ import org.springframework.util.StopWatch;
 @Slf4j
 public class ServerBigBrotherServiceImpl extends ServiceImpl<ServerBigBrotherMapper, ServerBigBrother> implements ServerBigBrotherService{
 
+    @Resource
+    private RedisUtils redisUtils;
+
+    @Resource
+    private MQSender mqSender;
+
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void saveData(ServerBigBrother bigBrother) {
@@ -34,6 +44,10 @@ public class ServerBigBrotherServiceImpl extends ServiceImpl<ServerBigBrotherMap
         ServerBigBrother serverBigBrother = baseMapper.selectOne(queryWrapper);
         if(serverBigBrother == null){
             save(bigBrother);
+            if (redisUtils.hasKeyByPrefix("bigbrother_login:"+ bigBrother.getTenantId())) {
+                    mqSender.brotherSend(bigBrother.getTenantId(),bigBrother);
+                log.info("发送消息到队列{}, 大哥 Id: {}", bigBrother.getTenantId(),bigBrother.getDisplayId());
+            }
             stopWatch.stop();
             long totalTimeMillis = stopWatch.getTotalTimeMillis();
             log.info("当前存储花费: {}ms",totalTimeMillis);
@@ -44,6 +58,10 @@ public class ServerBigBrotherServiceImpl extends ServiceImpl<ServerBigBrotherMap
             }
             bigBrother.setTotalGiftCoins(bigBrother.getHistoricHighCoins()+serverBigBrother.getTotalGiftCoins());
             updateById(bigBrother);
+            if (redisUtils.hasKeyByPrefix("bigbrother_login:"+ bigBrother.getTenantId())) {
+                mqSender.brotherSend(bigBrother.getTenantId(),bigBrother);
+                log.info("发送消息到队列{}, 大哥 Id: {}", bigBrother.getTenantId(),bigBrother.getDisplayId());
+            }
             stopWatch.stop();
             long totalTimeMillis = stopWatch.getTotalTimeMillis();
             log.info("当前更新花费: {}ms",totalTimeMillis);

src/main/java/com/yupi/springbootinit/service/impl/ServerLiveHostDetailServiceImpl.java

@@ -0,0 +1,34 @@
+package com.yupi.springbootinit.service.impl;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yupi.springbootinit.model.entity.ServerLiveHostDetail;
+import com.yupi.springbootinit.mapper.ServerLiveHostDetailMapper;
+import com.yupi.springbootinit.service.ServerLiveHostDetailService;
+/*
+* @author: ziin
+* @date: 2025/12/17 20:45
+*/
+
+@Service
+@Slf4j
+@Transactional(rollbackFor = Exception.class)
+public class ServerLiveHostDetailServiceImpl extends ServiceImpl<ServerLiveHostDetailMapper, ServerLiveHostDetail> implements ServerLiveHostDetailService{
+
+    @Override
+    public CompletableFuture<Void> processLiveHostDetails(List<ServerLiveHostDetail> details) {
+        try {
+            saveBatch(details);
+            log.info("直播明细数据存储成功，数量: {}", details.size());
+            return CompletableFuture.completedFuture(null);
+        } catch (Exception e) {
+            log.error("直播明细数据存储失败", e);
+            return CompletableFuture.failedFuture(e);
+        }
+    }
+
+}

src/main/java/com/yupi/springbootinit/utils/RedisUtils.java

@@ -0,0 +1,38 @@
+package com.yupi.springbootinit.utils;
+
+/*
+ * @author: ziin
+ * @date: 2025/8/27 20:35
+ */
+
+import org.springframework.data.redis.core.Cursor;
+import org.springframework.data.redis.core.RedisCallback;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.ScanOptions;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.Set;
+
+
+@Component
+public class RedisUtils {
+
+
+    @Resource
+    private RedisTemplate<String,Object> redisTemplate;
+
+    public boolean hasKeyByPrefix(String prefix) {
+        return Boolean.TRUE.equals(
+                redisTemplate.execute((RedisCallback<Boolean>) conn -> {
+                    try (Cursor<byte[]> cursor = conn.scan(
+                            ScanOptions.scanOptions()
+                                    .match(prefix + ":*")
+                                    .count(100)   // 每次返回条数，可调整
+                                    .build())) {
+                        return cursor.hasNext(); // 只要存在一条就返回 true
+                    }
+                })
+        );
+    }
+}

src/main/java/com/yupi/springbootinit/utils/SqlUtils.java

@@ -4,9 +4,6 @@ import org.apache.commons.lang3.StringUtils;
 
 /**
  * SQL 工具
- *
- * @author <a href="https://github.com/liyupi">程序员鱼皮</a>
- * @from <a href="https://yupi.icu">编程导航知识星球</a>
  */
 public class SqlUtils {
 

src/main/java/com/yupi/springbootinit/utils/SseEmitterUtil.java

@@ -0,0 +1,155 @@
+package com.yupi.springbootinit.utils;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.MediaType;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.*;
+import java.util.function.Consumer;
+
+/**
+ * SSE长链接工具类
+ */
+@Slf4j
+public class SseEmitterUtil {
+
+    private static final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
+    /**
+     * 使用map对象，便于根据userId来获取对应的SseEmitter，或者放redis里面
+     */
+    private final static Map<String, SseEmitter> sseEmitterMap = new ConcurrentHashMap<>();
+ 
+    public static SseEmitter connect(String userId) {
+        // 设置超时时间，0表示不过期。默认30S，超时时间未完成会抛出异常：AsyncRequestTimeoutException
+        SseEmitter sseEmitter = new SseEmitter(0L);
+
+        // 设置超时时间为0表示永不超时，或设置为较长的时间
+
+        // 注册回调
+        sseEmitter.onCompletion(completionCallBack(userId));
+        sseEmitter.onError(errorCallBack(userId));
+        sseEmitter.onTimeout(timeoutCallBack(userId));
+        sseEmitterMap.put(userId, sseEmitter);
+        log.info("创建新的 SSE 连接，当前用户 {}, 连接总数 {}", userId, sseEmitterMap.size());
+        // 启动一个任务定期发送心跳
+        ScheduledFuture<?> heartbeat = scheduler.scheduleAtFixedRate(() -> {
+            try {
+                // 发送心跳注释，防止代理或浏览器断开
+                sseEmitter.send(SseEmitter.event().comment("heartbeat"));
+            } catch (IOException e) {
+                sseEmitter.completeWithError(e);
+            }
+        }, 0, 10, TimeUnit.SECONDS); // 每10秒一次
+
+        return sseEmitter;
+    }
+
+
+
+ 
+    /**
+     * 给制定用户发送消息
+     *
+     * @param connectId 指定用户名
+     * @param sseMessage 消息体
+     */
+    public static void sendMessage(String connectId, String sseMessage) {
+        if (sseEmitterMap.containsKey(connectId)) {
+            try {
+                sseEmitterMap.get(connectId).send(sseMessage);
+                log.info("用户 {} 推送消息 {}", connectId, sseMessage);
+            } catch (IOException e) {
+                log.error("用户 {} 推送消息异常", connectId, e);
+                removeUser(connectId);
+            }
+        } else {
+            log.error("消息推送 用户 {} 不存在，链接总数 {}", connectId, sseEmitterMap.size());
+        }
+    }
+ 
+    /**
+     * 群发消息
+     */
+    public static void batchSendMessage(String message, List<String> ids) {
+        ids.forEach(userId -> sendMessage(userId, message));
+    }
+ 
+    /**
+     * 群发所有人
+     */
+    public static void batchSendMessage(String message) {
+        sseEmitterMap.forEach((k, v) -> {
+            try {
+                v.send(message, MediaType.APPLICATION_JSON);
+            } catch (IOException e) {
+                log.error("用户 {} 推送异常", k, e);
+                removeUser(k);
+            }
+        });
+    }
+ 
+    /**
+     * 移除用户连接
+     *
+     * @param userId 用户 ID
+     */
+    public static void removeUser(String userId) {
+        if (sseEmitterMap.containsKey(userId)) {
+            sseEmitterMap.get(userId).complete();
+            sseEmitterMap.remove(userId);
+            log.info("移除用户 {}, 剩余连接 {}", userId, sseEmitterMap.size());
+        } else {
+            log.error("消息推送 用户 {} 已被移除，剩余连接 {}", userId, sseEmitterMap.size());
+        }
+    }
+ 
+    /**
+     * 获取当前连接信息
+     *
+     * @return 所有的连接用户
+     */
+    public static List<String> getIds() {
+        return new ArrayList<>(sseEmitterMap.keySet());
+    }
+ 
+    /**
+     * 获取当前的连接数量
+     *
+     * @return 当前的连接数量
+     */
+    public static int getUserCount() {
+        return sseEmitterMap.size();
+    }
+
+    public static SseEmitter getSseEmitter(String userId) {
+        return sseEmitterMap.get(userId);
+    }
+
+
+
+
+ 
+    private static Runnable completionCallBack(String userId) {
+        return () -> {
+            log.info("用户 {} 结束连接", userId);
+        };
+    }
+ 
+    private static Runnable timeoutCallBack(String userId) {
+        return () -> {
+            log.error("用户 {} 连接超时", userId);
+            removeUser(userId);
+        };
+    }
+ 
+    private static Consumer<Throwable> errorCallBack(String userId) {
+        return throwable -> {
+            log.error("用户 {} 连接异常", userId);
+            removeUser(userId);
+        };
+    }
+}

src/main/resources/application-prod.yml

@@ -27,10 +27,7 @@ spring:
     listener:
       simple:
         acknowledge-mode: manual
-mybatis-plus:
+
-  configuration:
-    # 生产环境关闭日志
-    log-impl: ''
 # 接口文档配置
 knife4j:
   basic:

src/main/resources/application.yml

@@ -60,7 +60,7 @@ server:
 mybatis-plus:
   configuration:
     map-underscore-to-camel-case: false
-    log-impl: org.apache.ibatis.logging.nologging.NoLoggingImpl
+    log-impl: org.apache.ibatis.logging.slf4j.Slf4jImpl
     default-executor-type: batch
   global-config:
     banner: false
@@ -83,24 +83,6 @@ knife4j:
         api-rule-resources:
           - com.yupi.springbootinit.controller
 
-############## Sa-Token 配置 (文档: https://sa-token.cc) ##############
-sa-token:
-  # token 名称（同时也是 cookie 名称）
-  token-name: vvtoken
-  # token 有效期（单位：秒） 默认30天，-1 代表永久有效
-  timeout: 2592000
-  # token 最低活跃频率（单位：秒），如果 token 超过此时间没有访问系统就会被冻结，默认-1 代表不限制，永不冻结
-  active-timeout: -1
-  # 是否允许同一账号多地同时登录 （为 true 时允许一起登录, 为 false 时新登录挤掉旧登录）
-  is-concurrent: false
-  # 在多人登录同一账号时，是否共用一个 token （为 true 时所有登录共用一个 token, 为 false 时每次登录新建一个 token）
-  is-share: false
-  # token 风格（默认可取值：uuid、simple-uuid、random-32、random-64、random-128、tik）
-  token-style: random-128
-  # 是否输出操作日志
-  is-log: true
-
-
 logging:
   level:
     org.mybatis: off

src/main/resources/logback-spring.xml

@@ -34,10 +34,11 @@
             <appender-ref ref="STDOUT"/>
         </logger>
         <logger name="com.baomidou.mybatisplus" level="INFO">
-            <appender-ref ref="STDOUT"/>
             <appender-ref ref="FILE"/>
+            <appender-ref ref="STDOUT"/>
+        </logger>
+        <logger name="org.springframework" level="INFO">
         </logger>
-        <logger name="org.springframework" level="INFO"/>
         <logger name="org.redisson" level="INFO"/>
     </springProfile>
 
@@ -47,11 +48,12 @@
             <appender-ref ref="FILE"/>
         </root>
         <logger name="com.yupi.springbootinit" level="INFO" additivity="false">
-            <appender-ref ref="STDOUT"/>
             <appender-ref ref="FILE"/>
         </logger>
-        <logger name="org.springframework" level="INFO"/>
+        <logger name="org.springframework" level="INFO">
-        <logger name="com.baomidou.mybatisplus" level="INFO"/>
+        </logger>
+        <logger name="com.baomidou.mybatisplus" level="INFO">
+        </logger>
         <logger name="org.redisson" level="INFO"/>
     </springProfile>
 </configuration>

src/main/resources/mapper/NewHostsMapper.xml

@@ -15,15 +15,24 @@
     <result column="yesterday_coins" jdbcType="INTEGER" property="yesterdayCoins" />
     <result column="country" jdbcType="VARCHAR" property="country" />
     <result column="hosts_kind" jdbcType="VARCHAR" property="hostsKind" />
+    <result column="is_assigned" jdbcType="TINYINT" property="isAssigned" />
     <result column="tenant_id" jdbcType="BIGINT" property="tenantId" />
     <result column="creator" jdbcType="BIGINT" property="creator" />
     <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
-    <result column="uid" jdbcType="TIMESTAMP" property="uid" />
+    <result column="updater" jdbcType="VARCHAR" property="updater" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+    <result column="user_id" jdbcType="BIGINT" property="userId" />
+    <result column="deleted" jdbcType="TINYINT" property="deleted" />
+    <result column="uid" jdbcType="VARCHAR" property="uid" />
+    <result column="ai_operation" jdbcType="TINYINT" property="aiOperation" />
+    <result column="operation_status" jdbcType="TINYINT" property="operationStatus" />
+      <result column="country_eng" jdbcType="VARCHAR" property="countryEng" />
   </resultMap>
   <sql id="Base_Column_List">
     <!--@mbg.generated-->
-    id, hosts_id, hosts_level, hosts_coins, Invitation_type, online_fans,fans, fllowernum, yesterday_coins,
+    id, hosts_id, hosts_level, hosts_coins, Invitation_type, online_fans, fans, fllowernum,
-    country, hosts_kind, tenant_id, creator, create_time, updater, update_time,uid
+    yesterday_coins, country, hosts_kind, is_assigned, tenant_id, creator, create_time,
+    updater, update_time, user_id, deleted, `uid`, ai_operation, operation_status,country_eng
   </sql>
   <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
     <!--@mbg.generated-->
@@ -42,12 +51,12 @@
     insert into server_new_hosts (hosts_id, hosts_level, hosts_coins,
       Invitation_type, online_fans,fans, fllowernum,
       yesterday_coins, country, hosts_kind, 
-      tenant_id, creator,create_time,uid
+      tenant_id, creator,create_time,uid,country_eng
       )
     values (#{hostsId,jdbcType=VARCHAR}, #{hostsLevel,jdbcType=VARCHAR}, #{hostsCoins,jdbcType=INTEGER}, 
       #{invitationType,jdbcType=INTEGER}, #{onlineFans,jdbcType=INTEGER},#{fans,jdbcType=INTEGER}, #{fllowernum,jdbcType=INTEGER},
       #{yesterdayCoins,jdbcType=INTEGER}, #{country,jdbcType=VARCHAR}, #{hostsKind,jdbcType=VARCHAR}, 
-      #{tenantId,jdbcType=BIGINT}, #{creator,jdbcType=BIGINT},#{createTime,jdbcType=TIMESTAMP},#{uid,jdbcType=VARCHAR})
+      #{tenantId,jdbcType=BIGINT}, #{creator,jdbcType=BIGINT},#{createTime,jdbcType=TIMESTAMP},#{uid,jdbcType=VARCHAR},#{countryEng,jdbcType=VARCHAR})
   </insert>
   <insert id="insertSelective" keyColumn="id" keyProperty="id" parameterType="com.yupi.springbootinit.model.entity.NewHosts" useGeneratedKeys="true">
     <!--@mbg.generated-->
@@ -193,14 +202,14 @@
     <!--@mbg.generated-->
     insert into server_new_hosts
     (hosts_id, hosts_level, hosts_coins, Invitation_type, online_fans,fans, fllowernum, yesterday_coins,
-    country, hosts_kind, tenant_id, creator, user_id,create_time,uid)
+    country, hosts_kind, tenant_id, creator, user_id,create_time,uid,country_eng)
     values
     <foreach collection="list" item="item" separator=",">
       (#{item.hostsId,jdbcType=VARCHAR}, #{item.hostsLevel,jdbcType=VARCHAR}, #{item.hostsCoins,jdbcType=INTEGER},
       #{item.invitationType,jdbcType=INTEGER}, #{item.onlineFans,jdbcType=INTEGER},#{item.fans,jdbcType=INTEGER},
       #{item.fllowernum,jdbcType=INTEGER}, #{item.yesterdayCoins,jdbcType=INTEGER}, #{item.country,jdbcType=VARCHAR},
       #{item.hostsKind,jdbcType=VARCHAR}, #{item.tenantId,jdbcType=BIGINT}, #{item.creator,jdbcType=INTEGER},#{item.userId,jdbcType=BIGINT},
-      #{item.createTime,jdbcType=TIMESTAMP},#{item.uid,jdbcType=VARCHAR})
+      #{item.createTime,jdbcType=TIMESTAMP},#{item.uid,jdbcType=VARCHAR},#{item.countryEng,jdbcType=VARCHAR})
     </foreach>
   </insert>
 </mapper>

src/main/resources/mapper/ServerBigBrotherMapper.xml

@@ -19,11 +19,13 @@
     <result column="owner_id" jdbcType="VARCHAR" property="ownerId" />
     <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
     <result column="tenant_id" jdbcType="BIGINT" property="tenantId" />
+    <result column="fans_level" jdbcType="INTEGER" property="fansLevel" />
+      <result column="secUid" jdbcType="VARCHAR" property="secUid" />
   </resultMap>
   <sql id="Base_Column_List">
     <!--@mbg.generated-->
     id, display_id, user_id_str, nickname, `level`, hostcoins, follower_count, following_count, 
     region, historic_high_coins, total_gift_coins, host_display_id, owner_id, create_time, 
-    update_time, creator, updater, deleted, tenant_id
+    update_time, creator, updater, deleted, tenant_id,fans_level,secUid
   </sql>
 </mapper>

src/main/resources/mapper/ServerLiveHostDetailMapper.xml

@@ -0,0 +1,29 @@
+<?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.yupi.springbootinit.mapper.ServerLiveHostDetailMapper">
+  <resultMap id="BaseResultMap" type="com.yupi.springbootinit.model.entity.ServerLiveHostDetail">
+    <!--@mbg.generated-->
+    <!--@Table server_live_host_detail-->
+    <id column="id" jdbcType="BIGINT" property="id" />
+    <result column="userId" jdbcType="BIGINT" property="userid" />
+    <result column="hostsId" jdbcType="VARCHAR" property="hostsid" />
+    <result column="fans_club_count" jdbcType="INTEGER" property="fansClubCount" />
+    <result column="lighted_vs_total_gifts" jdbcType="VARCHAR" property="lightedVsTotalGifts" />
+    <result column="start_time_formatted" jdbcType="VARCHAR" property="startTimeFormatted" />
+    <result column="end_time_formatted" jdbcType="VARCHAR" property="endTimeFormatted" />
+    <result column="like_count" jdbcType="INTEGER" property="likeCount" />
+    <result column="duration_formatted" jdbcType="VARCHAR" property="durationFormatted" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+    <result column="tenant_id" jdbcType="BIGINT" property="tenantId" />
+    <result column="deleted" jdbcType="TINYINT" property="deleted" />
+    <result column="updater" jdbcType="VARCHAR" property="updater" />
+    <result column="creator" jdbcType="VARCHAR" property="creator" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, userId, hostsId, fans_club_count, lighted_vs_total_gifts, start_time_formatted, 
+    end_time_formatted, like_count, duration_formatted, create_time, update_time, tenant_id, 
+    deleted, updater, creator
+  </sql>
+</mapper>