添加主播七日数据接口

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

@@ -4,8 +4,10 @@ import cn.dev33.satoken.stp.StpUtil;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yupi.springbootinit.common.BaseResponse;
 import com.yupi.springbootinit.common.ResultUtils;
+import com.yupi.springbootinit.model.dto.host.HistoryDataDTO;
 import com.yupi.springbootinit.model.dto.host.HostInfoDTO;
 import com.yupi.springbootinit.model.vo.hosts.NewHostsVO;
+import com.yupi.springbootinit.model.vo.hosts.SevenDaysData;
 import com.yupi.springbootinit.service.HostInfoService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.*;
@@ -32,4 +34,12 @@ public class HostInfoController {
         Page<NewHostsVO> conditionHosts = hostInfoService.getConditionHosts(hostInfoDTO);
         return  ResultUtils.success(conditionHosts);
     }
+
+    @PostMapping("7days_data")
+    public BaseResponse<List<SevenDaysData>> sevenDaysData(@RequestBody HistoryDataDTO historyDataDTO){
+        Object loginId = StpUtil.getLoginId();
+        historyDataDTO.setUserId(Long.valueOf(loginId.toString()));
+        List<SevenDaysData> data = hostInfoService.getSevenDaysData(historyDataDTO);
+        return  ResultUtils.success(data);
+    }
 }

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

@@ -3,11 +3,13 @@ package com.yupi.springbootinit.mapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yupi.springbootinit.model.dto.host.HistoryDataDTO;
 import com.yupi.springbootinit.model.dto.host.HostInfoDTO;
 import com.yupi.springbootinit.model.entity.NewHosts;
 import java.util.List;
 
 import com.yupi.springbootinit.model.vo.hosts.NewHostsVO;
+import com.yupi.springbootinit.model.vo.hosts.SevenDaysData;
 import org.apache.ibatis.annotations.Param;
 
 /*
@@ -30,4 +32,7 @@ public interface NewHostsMapper extends BaseMapper<NewHosts> {
     int batchInsert(@Param("list") List<NewHosts> list);
 
     Page<NewHostsVO> selectPageByCondition(@Param("page") Page<NewHostsVO> page, @Param("hostInfoDTO") HostInfoDTO hostInfoDTO);
+
+    List<SevenDaysData> selectSevenDaysData(HistoryDataDTO historyDataDTO);
+
 }

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

@@ -0,0 +1,26 @@
+package com.yupi.springbootinit.model.dto.host;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/*
+ * @author: ziin
+ * @date: 2025/6/17 15:59
+ */
+@Data
+@ApiModel("历史数据")
+public class HistoryDataDTO {
+
+    @ApiModelProperty(value = "历史数据名称", example = "fans")
+    private String historyDataName;
+
+    @ApiModelProperty(value = "主播 Id")
+    private String hostsId;
+
+    @ApiModelProperty(value = "租户 Id", example = "1")
+    private Long tenantId;
+
+    @ApiModelProperty(value = "用户 Id", example = "1")
+    private Long userId;
+}

src/main/java/com/yupi/springbootinit/model/vo/hosts/SevenDaysData.java

@@ -0,0 +1,19 @@
+package com.yupi.springbootinit.model.vo.hosts;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+
+import java.util.Date;
+
+/*
+ * @author: ziin
+ * @date: 2025/6/17 16:05
+ */
+@Data
+public class SevenDaysData {
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date createTime;
+
+    private Integer DataContent;
+}

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

@@ -3,9 +3,11 @@ package com.yupi.springbootinit.service;
 
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.yupi.springbootinit.model.dto.host.HistoryDataDTO;
 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.model.vo.hosts.SevenDaysData;
 
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
@@ -18,4 +20,6 @@ public interface HostInfoService extends IService<NewHosts> {
 
 
     Page<NewHostsVO> getConditionHosts(HostInfoDTO hostInfoDTO);
+
+    List<SevenDaysData> getSevenDaysData(HistoryDataDTO historyDataDTO);
 }

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

@@ -7,9 +7,11 @@ import com.google.common.collect.Lists;
 import com.yupi.springbootinit.common.BaseResponse;
 import com.yupi.springbootinit.common.ResultUtils;
 import com.yupi.springbootinit.mapper.NewHostsMapper;
+import com.yupi.springbootinit.model.dto.host.HistoryDataDTO;
 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.model.vo.hosts.SevenDaysData;
 import com.yupi.springbootinit.service.HostInfoService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Async;
@@ -41,4 +43,10 @@ public class HostInfoServiceImpl extends ServiceImpl<NewHostsMapper, NewHosts> i
         Page<NewHostsVO> page = new Page<>(hostInfoDTO.getCurrent(),hostInfoDTO.getPageSize());
         return newHostsMapper.selectPageByCondition(page, hostInfoDTO);
     }
+
+    @Override
+    public List<SevenDaysData> getSevenDaysData(HistoryDataDTO historyDataDTO) {
+        List<SevenDaysData> data = newHostsMapper.selectSevenDaysData(historyDataDTO);
+        return data;
+    }
 }

src/main/resources/mapper/NewHostsMapper.xml

@@ -346,4 +346,29 @@
       </when>
     </choose>
   </select>
+
+  <select id="selectSevenDaysData" resultType="com.yupi.springbootinit.model.vo.hosts.SevenDaysData">
+    select create_time as createTime,
+    <choose>
+      <when test="historyDataName != null and historyDataName != ''">
+        <if test="historyDataName == 'fans' ">
+          fans dataContent
+        </if>
+        <if test="historyDataName == 'hostsCoins' ">
+          hosts_coins as dataContent
+        </if>
+        <if test="historyDataName == 'fllowernum'">
+          fllowernum as dataContent
+        </if>
+        <if test="historyDataName == 'onlineFans'">
+          online_fans as dataContent
+        </if>
+      </when>
+    </choose>
+     from server_new_hosts
+    where hosts_id =#{hostsId,jdbcType=VARCHAR}
+    and creator =#{userId,jdbcType=BIGINT}
+    and tenant_id =#{tenantId,jdbcType=BIGINT}
+    ORDER BY create_time DESC LIMIT 7
+  </select>
 </mapper>