diff --git a/src/main/java/com/yupi/springbootinit/controller/HostInfoController.java b/src/main/java/com/yupi/springbootinit/controller/HostInfoController.java index c32cb51..22fce97 100644 --- a/src/main/java/com/yupi/springbootinit/controller/HostInfoController.java +++ b/src/main/java/com/yupi/springbootinit/controller/HostInfoController.java @@ -1,8 +1,11 @@ package com.yupi.springbootinit.controller; +import cn.dev33.satoken.stp.StpUtil; 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.entity.NewHosts; +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; @@ -24,10 +27,18 @@ public class HostInfoController { @Resource private MQSender mqSender; + @Resource + private HostInfoService hostInfoService; @PostMapping("add_host") public BaseResponse addHost(@RequestBody List newHosts){ mqSender.send(newHosts); return ResultUtils.success(true); } + + @PostMapping("hosts_info") + public BaseResponse> hostsInfo(@RequestBody HostInfoDTO hostInfoDTO){ + List hostsVOList=hostInfoService.getConditionHosts(hostInfoDTO); + return ResultUtils.success(hostsVOList); + } } diff --git a/src/main/java/com/yupi/springbootinit/model/vo/hosts/NewHostsVO.java b/src/main/java/com/yupi/springbootinit/model/vo/hosts/NewHostsVO.java new file mode 100644 index 0000000..8c9f7db --- /dev/null +++ b/src/main/java/com/yupi/springbootinit/model/vo/hosts/NewHostsVO.java @@ -0,0 +1,81 @@ +package com.yupi.springbootinit.model.vo.hosts; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import lombok.Data; + +import java.util.Date; + +/* +* @author: ziin +* @date: 2025/6/10 18:54 +*/ +@Data +public class NewHostsVO { + /** + * 主键 + */ + @TableId(value = "id", type = IdType.AUTO) + private Long id; + + /** + * 主播id + */ + private String hostsId; + + /** + * 主播等级 + */ + private String hostsLevel; + + /** + * 主播金币 + */ + private Integer hostsCoins; + + /** + * 邀请类型 + */ + private Integer invitationType; + + /** + * 粉丝数量 + */ + private Integer fans; + + /** + * 关注数量 + */ + private Integer fllowernum; + + /** + * 昨日金币 + */ + private Integer yesterdayCoins; + + /** + * 主播国家 + */ + private String country; + + /** + * 直播类型 娱乐,游戏 + */ + private String hostsKind; + + /** + * 租户 Id + */ + private Long tenantId; + + /** + * 入库人 + */ + private Long creator; + + /** + * 数据插入时间 + */ + private Date createTime; + +} \ No newline at end of file diff --git a/src/main/java/com/yupi/springbootinit/service/HostInfoService.java b/src/main/java/com/yupi/springbootinit/service/HostInfoService.java index 856985b..70a82b8 100644 --- a/src/main/java/com/yupi/springbootinit/service/HostInfoService.java +++ b/src/main/java/com/yupi/springbootinit/service/HostInfoService.java @@ -2,7 +2,9 @@ package com.yupi.springbootinit.service; import com.baomidou.mybatisplus.extension.service.IService; +import com.yupi.springbootinit.model.dto.host.HostInfoDTO; import com.yupi.springbootinit.model.entity.NewHosts; +import com.yupi.springbootinit.model.vo.hosts.NewHostsVO; import java.util.List; import java.util.concurrent.CompletableFuture; @@ -16,4 +18,6 @@ public interface HostInfoService extends IService { public CompletableFuture saveHostInfo(List newHosts); public CompletableFuture processHosts(List hosts); + + List getConditionHosts(HostInfoDTO hostInfoDTO); } diff --git a/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java b/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java index a9f4c38..c625f6a 100644 --- a/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java +++ b/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java @@ -3,7 +3,9 @@ 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.NewHostsMapper; +import com.yupi.springbootinit.model.dto.host.HostInfoDTO; import com.yupi.springbootinit.model.entity.NewHosts; +import com.yupi.springbootinit.model.vo.hosts.NewHostsVO; import com.yupi.springbootinit.service.HostInfoService; import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling.annotation.Async; @@ -77,4 +79,10 @@ public class HostInfoServiceImpl extends ServiceImpl i } }); } + + @Override + public List getConditionHosts(HostInfoDTO hostInfoDTO) { + + return List.of(); + } }