Commit db6f3ce3 authored by 王明生's avatar 王明生

stash

parent 83cbdfb6
package com.afanticar.afantiopenapi.constant;
public enum PrincipalEnum {
BYD_WC("1270917477950984192", "比亚迪-王朝"),
BYD_HY("1270917477950984192", "比亚迪-海洋"),
BYD_TS("1270917477950984192", "比亚迪-腾势"),
BYD_FCB("1270917477950984192", "比亚迪-方程豹");
// TODO: 修改ID
public final String id;
public final String name;
PrincipalEnum(String id, String name) {
this.id = id;
this.name = name;
}
}
package com.afanticar.afantiopenapi.mapper;
import com.afanticar.afantiopenapi.model.entity.MemberInfo;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;
import java.util.List;
@Mapper
@DS("tmp")
public interface MemberInfoMapper extends BaseMapper<MemberInfo> {
@Select("select * \n" +
"from dim_matrix_member_info \n" +
"where end_time ='2099-01-01'\n" +
"and is_valid =1\n" +
"and matrix_member_id in " +
"<foreach collection='memberIds' item='item' open='(' separator=',' close=')'>" +
" #{item} " +
"</foreach>"
)
List<MemberInfo> queryMemberInfoListByMemberIds(List<String> memberIds);
}
package com.afanticar.afantiopenapi.mapper;
import com.afanticar.afantiopenapi.model.entity.XiaoHongShuAuthorDay;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
@Mapper
@DS("tmp")
public interface XiaoHongShuAuthorDayMapper extends BaseMapper<XiaoHongShuAuthorDay> {
}
package com.afanticar.afantiopenapi.mapper;
import com.afanticar.afantiopenapi.model.entity.XiaoHongShuAuthorInfo;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
@Mapper
@DS("tmp")
public interface XiaoHongShuAuthorInfoMapper extends BaseMapper<XiaoHongShuAuthorInfo> {
}
package com.afanticar.afantiopenapi.mapper;
import com.afanticar.afantiopenapi.model.entity.XiaoHongShuMemberDay;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import java.time.LocalDate;
import java.util.List;
import java.util.Set;
@Mapper
@DS("tmp")
public interface XiaoHongShuMemberDayMapper extends BaseMapper<XiaoHongShuMemberDay> {
@Select("select a.* \n" +
"from dws_xiaohongshu_member_action_day a \n" +
"inner join (select matrix_member_ids from ads_xiaohongshu_author_info where contains(principal_ids, #{principalId})) b \n" +
"on contains(b.matrix_member_ids,a.matrix_member_id)\n" +
"where 1=1\n" +
"and statistics_day >= #{startDate}\n" +
"and statistics_day <= #{endDate}")
List<XiaoHongShuMemberDay> queryMemberDayByPrincipalId(@Param("principalId") String principalId,
@Param("startDate") LocalDate startDate,
@Param("endDate") LocalDate endDate);
}
package com.afanticar.afantiopenapi.mapper;
import com.afanticar.afantiopenapi.model.entity.XiaoHongShuNoteDay;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
@Mapper
@DS("tmp")
public interface XiaoHongShuNoteDayMapper extends BaseMapper<XiaoHongShuNoteDay> {
}
package com.afanticar.afantiopenapi.mapper;
import com.afanticar.afantiopenapi.model.entity.XiaoHongShuNoteInfo;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
@Mapper
@DS("tmp")
public interface XiaoHongShuNoteInfoMapper extends BaseMapper<XiaoHongShuNoteInfo> {
}
package com.afanticar.afantiopenapi.model.entity;
import com.alibaba.fastjson.annotation.JSONType;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.databind.annotation.JsonNaming;
import lombok.Data;
import java.util.Date;
@Data
@TableName("dim_matrix_member_info")
@JsonNaming(value = com.fasterxml.jackson.databind.PropertyNamingStrategy.SnakeCaseStrategy.class)
@JSONType(naming = com.alibaba.fastjson.PropertyNamingStrategy.SnakeCase)
public class MemberInfo {
/**
* 成员id
*/
private String matrixMemberId;
/**
* 成员名称
*/
private String matrixMemberName;
/**
* 成员类型 1:经销商 2:官号 3:直营店 4:二网 5:城市站 6:KOL/KOC
*/
private Byte matrixMemberType;
/**
* 成员编码
*/
private String matrixMemberCode;
/**
* 联络人
*/
private String username;
/**
* 联络人手机号
*/
private String mobile;
/**
* 邀请码
*/
private String invitationCode;
/**
* 省份ID
*/
private String provinceId;
/**
* 省份名称
*/
private String provinceName;
/**
* 城市ID
*/
private String cityId;
/**
* 城市名称
*/
private String cityName;
/**
* 主体ID
*/
private String principalId;
/**
* 主体名称
*/
private String principalName;
/**
* 大区ID
*/
private String areaId;
/**
* 大区名称
*/
private String areaName;
/**
* 小区ID
*/
private String villageId;
/**
* 小区名称
*/
private String villageName;
/**
* 0:默认值,1:正常,2:退网
*/
private Byte status;
/**
* 操作时间
*/
private Date atime;
/**
* 创建时间
*/
private Date ctime;
/**
* 更新时间
*/
private Date mtime;
/**
* 创建人
*/
private String creator;
/**
* 操作人
*/
private String actor;
/**
* 是否已删除,(1:是;0:否)
*/
private Byte isDeleted;
/**
* 是否有效,0:无效,1:有效
*/
private Integer isValid;
/**
* 记录有效开始时间
*/
private Date startTime;
/**
* 记录有效结束时间
*/
private Date endTime;
}
package com.afanticar.afantiopenapi.model.entity;
import com.alibaba.fastjson.annotation.JSONType;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.databind.annotation.JsonNaming;
import lombok.Data;
import java.util.Date;
import java.util.List;
@Data
@TableName("dws_xiaohongshu_author_action_day")
@JsonNaming(value = com.fasterxml.jackson.databind.PropertyNamingStrategy.SnakeCaseStrategy.class)
@JSONType(naming = com.alibaba.fastjson.PropertyNamingStrategy.SnakeCase)
public class XiaoHongShuAuthorDay {
/**
* 统计日期,格式为YYYY-MM-DD 00:00:00
*/
private Date statisticsDay;
/**
* 主播ID
*/
private String authorId;
/**
* 粉丝总数
*/
private Integer fansCountTotal;
/**
* 本日新增粉丝数
*/
private Integer fansCountTotalDi;
/**
* 获赞+收藏总数
*/
private Integer favedCount;
/**
* 本日新增获赞+收藏数
*/
private Integer favedCountDi;
/**
* 关注总数
*/
private Integer followingCount;
/**
* 本日新增关注数
*/
private Integer followingCountDi;
/**
* 本日笔记发布数
*/
private Integer noteCountDi;
/**
* 本日笔记新增观看数
*/
private Integer noteReadCountDi;
/**
* 本日笔记新增点赞数
*/
private Integer noteDiggCountDi;
/**
* 本日笔记新增收藏数
*/
private Integer noteCollectCountDi;
/**
* 本日笔记新增评论数
*/
private Integer noteCommentCountDi;
/**
* 本日笔记新增分享数
*/
private Integer noteShareCountDi;
/**
* 是否取自前一天的数据,0表示否,1表示是
*/
private Boolean isFromP0;
/**
* 数据更新时间
*/
private Date mtime;
/**
* 数据创建时间
*/
private Date ctime;
/**
* 成员ID数组
*/
private List<String> matrixMemberIds;
/**
* 是否为推测数据
*/
private Boolean isSimulateData;
/**
* 总点赞数
*/
private Integer diggCountTotal;
/**
* 本日新增点赞数
*/
private Integer diggCountDi;
/**
* 总收藏数
*/
private Integer collectCountTotal;
/**
* 本日新增收藏数
*/
private Integer collectCountDi;
/**
* 本日总作品数
*/
private Integer noteCountTotal;
/**
* 本日直播总场次
*/
private Integer liveTotalCount;
/**
* 本日直播总点赞数
*/
private Integer liveTotalLikeCount;
/**
* 本日直播总点赞人数
*/
private Integer liveTotalLikeUserCount;
/**
* 本日直播总评论数
*/
private Integer liveTotalCommentCount;
/**
* 本日直播总评论人数
*/
private Integer liveTotalCommentUserCount;
/**
* 本日直播总送礼数
*/
private Integer liveTotalGiftCount;
/**
* 本日直播总送礼人数
*/
private Integer liveTotalGiftUserCount;
/**
* 本日直播总互动数(评论数+点赞数+送礼数)
*/
private Integer liveTotalPollingCount;
/**
* 本日直播总互动人数
*/
private Integer liveTotalPollingUserCount;
/**
* 本日直播总时长
*/
private Integer liveTotalTime;
/**
* 本日直播总新增粉丝数
*/
private Integer liveTotalFansAdd;
/**
* 本日直播总薯钻
*/
private Integer liveTotalDiamondCount;
/**
* 本日直播总观看人数
*/
private Integer liveTotalWatchUserCount;
/**
* 本日直播总观看人次
*/
private Integer liveTotalWatchUserTime;
}
package com.afanticar.afantiopenapi.model.entity;
import com.alibaba.fastjson.annotation.JSONType;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.databind.annotation.JsonNaming;
import lombok.Data;
import java.util.Date;
import java.util.List;
@Data
@TableName("ads_xiaohongshu_author_info")
@JsonNaming(value = com.fasterxml.jackson.databind.PropertyNamingStrategy.SnakeCaseStrategy.class)
@JSONType(naming = com.alibaba.fastjson.PropertyNamingStrategy.SnakeCase)
public class XiaoHongShuAuthorInfo {
/**
* 主播ID
*/
private String authorId;
/**
* 主播签名
*/
private String signature;
/**
* 主播昵称
*/
private String nickname;
/**
* 主播头像
*/
private String avatar;
/**
* 主播小红书号
*/
private String code;
/**
* 主播主页背景图链接
*/
private String coverUrl;
/**
* 主播性别
*/
private Byte gender;
/**
* 主播生日
*/
private String birthday;
/**
* 主播所在城市code
*/
private String authorCityCode;
/**
* 主播所在城市名称
*/
private String authorCityName;
/**
* 主播所在省code
*/
private String authorProvinceCode;
/**
* 主播所在省名称
*/
private String authorProvinceName;
/**
* 主播总粉丝数
*/
private Integer fansCountTotal;
/**
* 小红书返回的主播状态,0正常、1注销、2封禁
*/
private Byte platformAuthorStatus;
/**
* 经销商id
*/
private String dealerId;
/**
* 经销商名称
*/
private String dealerName;
/**
* 经销商城市code
*/
private String dealerCityCode;
/**
* 经销商城市名称
*/
private String dealerCityName;
/**
* 经销商地区code
*/
private String dealerCountyCode;
/**
* 经销商地区名称
*/
private String dealerCountyName;
/**
* 经销商省份code
*/
private String dealerProvinceCode;
/**
* 经销商省份名称
*/
private String dealerProvinceName;
/**
* 经销商公司名
*/
private String dealerCompanyName;
/**
* 主机厂ids
*/
private List<String> manufactorIds;
/**
* 主机厂名称
*/
private List<String> manufactorNames;
/**
* 品牌ids
*/
private List<String> brandIds;
/**
* 品牌名称
*/
private List<String> brandNames;
/**
* 主体ids
*/
private List<String> principalIds;
/**
* 主体名称
*/
private List<String> principalNames;
/**
* 运营主体:1:品牌,2:主机厂,3:主体大区,4:经销商,5:KOIP,6:二手车商
*/
private String operateType;
/**
* 经销商大区id,多列值
*/
private List<String> dealerAreaIds;
/**
* 经销商大区名称,多列值
*/
private List<String> dealerAreaNames;
/**
* 经销商原始门店编码
*/
private String originStoreCode;
/**
* 排序权重
*/
private String sortWeight;
/**
* 主播状态是否删除, 0正常;1删除
*/
private Byte isDeleted;
/**
* 数据同步更新的时间点
*/
private Date dataUpdateTime;
/**
* 账号收录时间
*/
private Date includedTime;
/**
* 创建时间
*/
private Date ctime;
/**
* 更新时间
*/
private Date mtime;
/**
* 成员ids
*/
private List<String> matrixMemberIds;
/**
* 获赞+收藏
*/
private Integer favedCount;
/**
* 关注数
*/
private Integer followingCount;
/**
* 点赞数
*/
private Integer likeCountTotal;
/**
* 收藏数
*/
private Integer collectCountTotal;
/**
* 主播总作品数
*/
private Integer noteCountTotal;
/**
* 认证类型: 0-未认证, 1-个人认证,2-企业认证(蓝v),3-机构认证
*/
private String verificationType;
/**
* 是否代运营账号,1:是,0否
*/
private Integer isAgentAuthor;
}
package com.afanticar.afantiopenapi.model.entity;
import com.alibaba.fastjson.annotation.JSONType;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.databind.annotation.JsonNaming;
import lombok.Data;
import java.util.Date;
@Data
@TableName("dws_xiaohongshu_member_action_day")
@JsonNaming(value = com.fasterxml.jackson.databind.PropertyNamingStrategy.SnakeCaseStrategy.class)
@JSONType(naming = com.alibaba.fastjson.PropertyNamingStrategy.SnakeCase)
public class XiaoHongShuMemberDay {
/**
* 成员id
*/
private String matrixMemberId;
/**
* 获赞与收藏
*/
private Integer favedCount;
/**
* 关注数
*/
private Integer followingCount;
/**
* 粉丝数
*/
private Integer fansCountTotal;
/**
* 本日新增获赞与收藏数
*/
private Integer favedCountDi;
/**
* 本日新增关注数
*/
private Integer followingCountDi;
/**
* 本日新增粉丝数
*/
private Integer fansCountTotalDi;
/**
* 统计日期,YYYY-MM-DD 00:00:00
*/
private Date statisticsDay;
/**
* 数据更新时间
*/
private Date mtime;
/**
* 数据创建时间
*/
private Date ctime;
/**
* 本日笔记发布数
*/
private Integer noteCountDi;
/**
* 本日笔记新增观看数
*/
private Integer noteReadCountDi;
/**
* 本日笔记新增点赞数
*/
private Integer noteDiggCountDi;
/**
* 本日笔记新增收藏数
*/
private Integer noteCollectCountDi;
/**
* 本日笔记新增评论数
*/
private Integer noteCommentCountDi;
/**
* 本日笔记新增分享数
*/
private Integer noteShareCountDi;
/**
* 本日有发布笔记的主播账号数
*/
private Integer notePublishAuthorCount;
/**
* 是否删除
*/
private Byte isDeleted;
/**
* 0:默认值,1:正常,2:退网
*/
private Byte status;
/**
* 主播数量
*/
private Integer authorCount;
/**
* 总点赞数
*/
private Integer diggCountTotal;
/**
* 本日新增点赞数
*/
private Integer diggCountDi;
/**
* 总收藏数
*/
private Integer collectCountTotal;
/**
* 本日新增收藏数
*/
private Integer collectCountDi;
/**
* 本日总作品数
*/
private Integer noteCountTotal;
/**
* 本日直播总场次
*/
private Integer liveTotalCount;
/**
* 本日直播总点赞数
*/
private Integer liveTotalLikeCount;
/**
* 本日直播总点赞人数
*/
private Integer liveTotalLikeUserCount;
/**
* 本日直播总评论数
*/
private Integer liveTotalCommentCount;
/**
* 本日直播总评论人数
*/
private Integer liveTotalCommentUserCount;
/**
* 本日直播总送礼数
*/
private Integer liveTotalGiftCount;
/**
* 本日直播总送礼人数
*/
private Integer liveTotalGiftUserCount;
/**
* 本日直播总互动数(评论数+点赞数+送礼数)
*/
private Integer liveTotalPollingCount;
/**
* 本日直播总互动人数
*/
private Integer liveTotalPollingUserCount;
/**
* 本日直播总时长
*/
private Integer liveTotalTime;
/**
* 本日直播总新增粉丝数
*/
private Integer liveTotalFansAdd;
/**
* 本日直播总薯钻
*/
private Integer liveTotalDiamondCount;
/**
* 本日直播总观看人数
*/
private Integer liveTotalWatchUserCount;
/**
* 本日直播总观看人次
*/
private Integer liveTotalWatchUserTime;
}
package com.afanticar.afantiopenapi.model.entity;
import com.alibaba.fastjson.annotation.JSONType;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.databind.annotation.JsonNaming;
import lombok.Data;
import java.util.Date;
import java.util.List;
@Data
@TableName("dws_xiaohongshu_note_action_day")
@JsonNaming(value = com.fasterxml.jackson.databind.PropertyNamingStrategy.SnakeCaseStrategy.class)
@JSONType(naming = com.alibaba.fastjson.PropertyNamingStrategy.SnakeCase)
public class XiaoHongShuNoteDay {
/**
* 小红书号
*/
private String authorId;
/**
* 笔记id
*/
private String noteId;
/**
* 阅读量
*/
private Integer readCount;
/**
* 直接涨粉数
*/
private Integer fansTotalAdd;
/**
* 点赞量
*/
private Integer diggCount;
/**
* 收藏数
*/
private Integer collectCount;
/**
* 评论数
*/
private Integer commentCount;
/**
* 分享数
*/
private Integer shareCount;
/**
* 阅读量增量
*/
private Integer readCountDi;
/**
* 直接涨粉数增量
*/
private Integer fansTotalAddDi;
/**
* 点赞量增量
*/
private Integer diggCountDi;
/**
* 收藏数增量
*/
private Integer collectCountDi;
/**
* 评论数增量
*/
private Integer commentCountDi;
/**
* 分享数增量
*/
private Integer shareCountDi;
/**
* 该行是否取自自前一天, 0:否;1:是
*/
private Boolean isFromP0;
/**
* 统计日期,格式为YYYY-MM-DD 00:00:00
*/
private Date statisticsDay;
/**
* 入库时间
*/
private Date ctime;
/**
* 修改时间
*/
private Date mtime;
/**
* 成员ID数组
*/
private List<String> matrixMemberIds;
/**
* 是否为推测数据
*/
private Boolean isSimulateData;
/**
* 笔记状态: 1-可见,0-不可见
*/
private Integer noteStatus;
/**
* 预估的模拟阅读量:(点赞+评论+收藏+转发)*20
*/
private Integer simulateReadCount;
/**
* 预估的模拟阅读增量:(点赞增量+评论增量+收藏增量+转发增量)*20
*/
private Integer simulateReadCountDi;
}
package com.afanticar.afantiopenapi.model.entity;
import com.alibaba.fastjson.annotation.JSONType;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.databind.annotation.JsonNaming;
import lombok.Data;
import java.util.Date;
import java.util.List;
@Data
@TableName("ads_xiaohongshu_note_info")
@JsonNaming(value = com.fasterxml.jackson.databind.PropertyNamingStrategy.SnakeCaseStrategy.class)
@JSONType(naming = com.alibaba.fastjson.PropertyNamingStrategy.SnakeCase)
public class XiaoHongShuNoteInfo {
/**
* 小红书号
*/
private String authorId;
/**
* 笔记id
*/
private String noteId;
/**
* 笔记封面
*/
private String coverUrl;
/**
* 笔记标题
*/
private String noteTitle;
/**
* 笔记类型(normal:图文,video:视频)
*/
private String noteType;
/**
* 笔记链接
*/
private String shareUrl;
/**
* 阅读量
*/
private Integer readCount;
/**
* 直接涨粉数
*/
private Integer fansTotalAdd;
/**
* 点赞量
*/
private Integer diggCount;
/**
* 收藏数
*/
private Integer collectCount;
/**
* 评论数
*/
private Integer commentCount;
/**
* 分享数
*/
private Integer shareCount;
/**
* 入库时间
*/
private Date ctime;
/**
* 修改时间
*/
private Date mtime;
/**
* 成员ids
*/
private List<String> matrixMemberIds;
/**
* 笔记发布时间
*/
private Date publishTime;
/**
* 数据同步更新的时间点
*/
private Date dataUpdateTime;
/**
* 笔记状态: 1-可见,0-不可见
*/
private Integer noteStatus;
/**
* 话题ID列表
*/
private List<String> topicIds;
/**
* 话题名
*/
private String noteTopic;
/**
* 预估的模拟阅读量:(点赞+评论+收藏+转发)*20
*/
private Integer simulateReadCount;
/**
* 笔记图片数
*/
private Integer noteImageCount;
/**
* 笔记正文字数
*/
private Integer noteDescriptionWordCount;
/**
* 1级标签 id
*/
private String tagLevelOneId;
/**
* 1级标签 名
*/
private String tagLevelOneName;
/**
* 2级标签 id
*/
private String tagLevelTwoId;
/**
* 2级标签 名
*/
private String tagLevelTwoName;
/**
* 3级标签 id
*/
private String tagLevelThreeId;
/**
* 3级标签 名
*/
private String tagLevelThreeName;
/**
* 发布渠道,FENGHUOLUN=风火轮,SHARE_LINK=分享链接,BAIFUZHANG=百夫长
*/
private String publishChannel;
/**
* 产品id
*/
private String goodsId;
/**
* 产品名称
*/
private String goodsName;
}
package com.afanticar.afantiopenapi.model.vo;
import com.alibaba.fastjson.annotation.JSONType;
import com.fasterxml.jackson.databind.annotation.JsonNaming;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.time.LocalDate;
import java.util.List;
@Data
@JsonNaming(value = com.fasterxml.jackson.databind.PropertyNamingStrategy.SnakeCaseStrategy.class)
@JSONType(naming = com.alibaba.fastjson.PropertyNamingStrategy.SnakeCase)
public class BydXiaoHongShuMemberDayVO {
@ApiModelProperty(value = "门店名称", example = "南京宁星")
private Integer storeName;
@ApiModelProperty(value = "门店编码", example = "ABC123")
private Integer storeCode;
@ApiModelProperty(value = "门店ID", example = "200")
private Integer storeId;
@ApiModelProperty(value = "门店类型", example = "门店类型1")
private Integer storeType;
@ApiModelProperty(value = "大区名称", example = "大区名称1")
private Integer areaName;
@ApiModelProperty(value = "大区ID", example = "200")
private Integer villageName;
@ApiModelProperty(value = "品牌名称", example = "比亚迪-海洋")
private Integer principalName;
@ApiModelProperty(value = "省份名称", example = "广东")
private Integer provinceName;
@ApiModelProperty(value = "城市名称", example = "深圳")
private Integer cityName;
private List<BydXiaoHongShuMemberDayDetailVO> detailList;
@Data
public static class BydXiaoHongShuMemberDayDetailVO {
@ApiModelProperty(value = "统计日期", example = "2023-03-03")
private LocalDate statsDate;
@ApiModelProperty(value = "粉丝数", example = "200")
private Integer fansCntTotal;
@ApiModelProperty(value = "粉丝新增数", example = "200")
private Integer fansCntDi;
@ApiModelProperty(value = "笔记新增数", example = "200")
private Integer noteCntDi;
@ApiModelProperty(value = "笔记点赞新增数", example = "200")
private Integer noteLikeCntDi;
@ApiModelProperty(value = "笔记评论新增数", example = "200")
private Integer noteCommentCntDi;
@ApiModelProperty(value = "笔记收藏新增数", example = "200")
private Integer noteFavoriteCntDi;
@ApiModelProperty(value = "笔记分享新增数", example = "200")
private Integer noteShareCntDi;
}
}
package com.afanticar.afantiopenapi.service;
import com.afanticar.afantiopenapi.constant.PrincipalEnum;
import com.afanticar.afantiopenapi.mapper.*;
import com.afanticar.afantiopenapi.model.entity.HongqiAwemeIncentiveMonthly;
import com.afanticar.afantiopenapi.model.entity.MemberInfo;
import com.afanticar.afantiopenapi.model.entity.XiaoHongShuMemberDay;
import com.afanticar.afantiopenapi.model.entity.XiaoHongShuNoteInfo;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.time.LocalDate;
import java.util.List;
import java.util.stream.Collectors;
@Service
public class BydOpenService {
@Resource
MemberInfoMapper memberInfoMapper;
@Resource
XiaoHongShuMemberDayMapper memberDayMapper;
@Resource
XiaoHongShuAuthorInfoMapper authorInfoMapper;
@Resource
XiaoHongShuAuthorDayMapper authorDayMapper;
@Resource
XiaoHongShuNoteInfo noteInfoMapper;
@Resource
XiaoHongShuNoteDayMapper noteDayMapper;
public void fetchMemberDayData(PrincipalEnum principal,
LocalDate startDate, LocalDate endDate, Integer pageNum, Integer pageSize){
IPage<XiaoHongShuMemberDay> page = new Page<>(pageNum, pageSize);
QueryWrapper<XiaoHongShuMemberDay> queryWrapper = new QueryWrapper<>();
List<XiaoHongShuMemberDay> data = memberDayMapper.queryMemberDayByPrincipalId(principal.id, startDate, endDate);
List<String> memberIds = data.stream().map(XiaoHongShuMemberDay::getMatrixMemberId).collect(Collectors.toList());
List<MemberInfo> memberInfos = memberInfoMapper.queryMemberInfoListByMemberIds(memberIds);
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment