* 商品详情接口bug修复

src/main/java/com/tdba/cxb/ares/api/controller/RegionController.java

@@ -15,7 +15,7 @@ import static com.tdba.cxb.ares.api.model.TDBAResponseBuilder.buildSuccess;
  * @author: libo
  * @create: 2022-06-02 18:23:33
  */
-@TDBAController("/api/v1/system/city")
+//@TDBAController("/api/v1/system/city")
 public class RegionController {
 
     @Resource
@@ -25,4 +25,8 @@ public class RegionController {
     public TDBAResponse list(){
         return buildSuccess(districtService.regionList());
     }
+
+    public static void main(String[] args) {
+        System.out.println("\u50a8\u84c4\u4fdd");
+    }
 }

src/main/java/com/tdba/cxb/ares/api/controller/UserController.java

@@ -0,0 +1,67 @@
+package com.tdba.cxb.ares.api.controller;
+
+import com.tdba.cxb.ares.api.model.BaseUser;
+import com.tdba.cxb.ares.api.model.BindUserAdd;
+import com.tdba.cxb.ares.api.model.OperatorLoginReq;
+import com.tdba.cxb.ares.api.model.TDBAResponse;
+import com.tdba.cxb.ares.api.service.UserService;
+import com.tdba.cxb.ares.api.util.TDBAController;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import javax.annotation.Resource;
+
+import java.time.LocalDate;
+
+import static com.tdba.cxb.ares.api.model.TDBAResponseBuilder.buildSuccess;
+
+/**
+ * @program: order-web
+ * @description: 用户登录
+ * @author: libo
+ * @create: 2022-06-06 17:48:41
+ */
+@TDBAController("/api/v1/operate")
+public class UserController {
+
+    @Resource
+    private UserService userService;
+
+    @GetMapping("statistics_list")
+    public TDBAResponse statistics_list(){
+        userService.createSpreadInfo(LocalDate.of(2021, 4, 9));
+        return buildSuccess("");
+    }
+
+    /**
+     * 登录
+     * @param param 请求参数
+     * @return
+     */
+    @PostMapping("login")
+    public TDBAResponse login(@RequestBody @Validated OperatorLoginReq param){
+        return buildSuccess("");
+    }
+
+    /**
+     * 绑定的成员列表
+     * @param param
+     * @return
+     */
+    @GetMapping("bind_list")
+    public TDBAResponse bind_list(BaseUser baseUser){
+        return buildSuccess("");
+    }
+
+    /**
+     * 绑定用户
+     * @param baseUser
+     * @return
+     */
+    @PostMapping("bind_add")
+    public TDBAResponse bind_add(@RequestBody @Validated BindUserAdd param, BaseUser baseUser){
+        return buildSuccess("");
+    }
+}

src/main/java/com/tdba/cxb/ares/api/model/BindUserAdd.java

@@ -0,0 +1,48 @@
+package com.tdba.cxb.ares.api.model;
+
+import javax.validation.constraints.NotEmpty;
+
+/**
+ * @program: order-web
+ * @description: 运营商新增团队成员请求参数
+ * @author: libo
+ * @create: 2022-06-08 11:21:30
+ */
+public class BindUserAdd {
+
+    /** 名称*/
+    @NotEmpty(message = "名称不能为空")
+    private String name;
+
+    /** 手机号*/
+    @NotEmpty(message = "手机号不能为空")
+    private String mobile;
+
+    /** 验证码*/
+    @NotEmpty(message = "验证码不能为空")
+    private String code;
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getMobile() {
+        return mobile;
+    }
+
+    public void setMobile(String mobile) {
+        this.mobile = mobile;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+}

src/main/java/com/tdba/cxb/ares/api/model/OperatorLoginReq.java

@@ -0,0 +1,36 @@
+package com.tdba.cxb.ares.api.model;
+
+import javax.validation.constraints.NotEmpty;
+
+/**
+ * @program: order-web
+ * @description: 运营商登录请求参数
+ * @author: libo
+ * @create: 2022-06-08 11:08:13
+ */
+public class OperatorLoginReq {
+
+    /** 手机号*/
+    @NotEmpty(message = "手机号不能为空")
+    private String mobile;
+
+    /** 验证码*/
+    @NotEmpty(message = "验证码不能为空")
+    private String code;
+
+    public String getMobile() {
+        return mobile;
+    }
+
+    public void setMobile(String mobile) {
+        this.mobile = mobile;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+}

src/main/java/com/tdba/cxb/ares/api/model/UserCount.java

@@ -0,0 +1,118 @@
+package com.tdba.cxb.ares.api.model;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+/**
+ * @program: order-web
+ * @description: 注册用户数量统计
+ * @author: libo
+ * @create: 2022-06-06 16:52:23
+ */
+public class UserCount {
+
+    /** 用户ID*/
+    private Integer uid;
+
+    /** 数量*/
+    private Integer num;
+
+    /** 日期*/
+    private LocalDate date;
+
+    /** 创建时间*/
+    private LocalDateTime create_time;
+
+    /** 用户类型: 0普通用户1大仓会员2商户3渠道商4代理商*/
+    private Integer user_type;
+
+    public Integer getUid() {
+        return uid;
+    }
+
+    public void setUid(Integer uid) {
+        this.uid = uid;
+    }
+
+    public Integer getNum() {
+        return num;
+    }
+
+    public void setNum(Integer num) {
+        this.num = num;
+    }
+
+    public LocalDate getDate() {
+        return date;
+    }
+
+    public void setDate(LocalDate date) {
+        this.date = date;
+    }
+
+    public LocalDateTime getCreate_time() {
+        return create_time;
+    }
+
+    public void setCreate_time(LocalDateTime create_time) {
+        this.create_time = create_time;
+    }
+
+    public Integer getUser_type() {
+        return user_type;
+    }
+
+    public void setUser_type(Integer user_type) {
+        this.user_type = user_type;
+    }
+
+    public static final class UserCountBuilder {
+        private Integer uid;
+        private Integer num;
+        private LocalDate date;
+        private LocalDateTime create_time;
+        private Integer user_type;
+
+        private UserCountBuilder() {
+        }
+
+        public static UserCountBuilder anUserCount() {
+            return new UserCountBuilder();
+        }
+
+        public UserCountBuilder withUid(Integer uid) {
+            this.uid = uid;
+            return this;
+        }
+
+        public UserCountBuilder withNum(Integer num) {
+            this.num = num;
+            return this;
+        }
+
+        public UserCountBuilder withDate(LocalDate date) {
+            this.date = date;
+            return this;
+        }
+
+        public UserCountBuilder withCreate_time(LocalDateTime create_time) {
+            this.create_time = create_time;
+            return this;
+        }
+
+        public UserCountBuilder withUser_type(Integer user_type) {
+            this.user_type = user_type;
+            return this;
+        }
+
+        public UserCount build() {
+            UserCount userCount = new UserCount();
+            userCount.setUid(uid);
+            userCount.setNum(num);
+            userCount.setDate(date);
+            userCount.setCreate_time(create_time);
+            userCount.setUser_type(user_type);
+            return userCount;
+        }
+    }
+}

src/main/java/com/tdba/cxb/ares/api/model/UserDto.java

@@ -0,0 +1,86 @@
+package com.tdba.cxb.ares.api.model;
+
+/**
+ * @program: admin-web
+ * @description:
+ * @author: libo
+ * @create: 2022-06-06 15:26:14
+ */
+public class UserDto {
+
+    /**
+     * 用户ID
+     */
+    private Integer uid;
+
+    /**
+     * 推荐人用户ID
+     */
+    private Integer spread_uid;
+
+    /**
+     * 数量
+     */
+    private Integer num;
+
+    public Integer getUid() {
+        return uid;
+    }
+
+    public void setUid(Integer uid) {
+        this.uid = uid;
+    }
+
+    public Integer getSpread_uid() {
+        return spread_uid;
+    }
+
+    public void setSpread_uid(Integer spread_uid) {
+        this.spread_uid = spread_uid;
+    }
+
+    public Integer getNum() {
+        return num;
+    }
+
+    public void setNum(Integer num) {
+        this.num = num;
+    }
+
+
+    public static final class UserDtoBuilder {
+        private Integer uid;
+        private Integer spread_uid;
+        private Integer num;
+
+        private UserDtoBuilder() {
+        }
+
+        public static UserDtoBuilder anUserDto() {
+            return new UserDtoBuilder();
+        }
+
+        public UserDtoBuilder withUid(Integer uid) {
+            this.uid = uid;
+            return this;
+        }
+
+        public UserDtoBuilder withSpread_uid(Integer spread_uid) {
+            this.spread_uid = spread_uid;
+            return this;
+        }
+
+        public UserDtoBuilder withNum(Integer num) {
+            this.num = num;
+            return this;
+        }
+
+        public UserDto build() {
+            UserDto userDto = new UserDto();
+            userDto.setUid(uid);
+            userDto.setSpread_uid(spread_uid);
+            userDto.setNum(num);
+            return userDto;
+        }
+    }
+}

src/main/java/com/tdba/cxb/ares/api/model/UserRelate.java

@@ -0,0 +1,81 @@
+package com.tdba.cxb.ares.api.model;
+
+import java.time.LocalDateTime;
+
+/**
+ * @program: order-web
+ * @description: 用户注册关联关系
+ * @author: libo
+ * @create: 2022-06-06 17:10:08
+ */
+public class UserRelate {
+
+    /** 用户ID*/
+    private Integer uid;
+
+    /** 关联用户ID*/
+    private Integer pid;
+
+    /** 创建时间*/
+    private LocalDateTime create_time;
+
+    public Integer getUid() {
+        return uid;
+    }
+
+    public void setUid(Integer uid) {
+        this.uid = uid;
+    }
+
+    public Integer getPid() {
+        return pid;
+    }
+
+    public void setPid(Integer pid) {
+        this.pid = pid;
+    }
+
+    public LocalDateTime getCreate_time() {
+        return create_time;
+    }
+
+    public void setCreate_time(LocalDateTime create_time) {
+        this.create_time = create_time;
+    }
+
+    public static final class UserRelateBuilder {
+        private Integer uid;
+        private Integer pid;
+        private LocalDateTime create_time;
+
+        private UserRelateBuilder() {
+        }
+
+        public static UserRelateBuilder anUserRelate() {
+            return new UserRelateBuilder();
+        }
+
+        public UserRelateBuilder withUid(Integer uid) {
+            this.uid = uid;
+            return this;
+        }
+
+        public UserRelateBuilder withPid(Integer pid) {
+            this.pid = pid;
+            return this;
+        }
+
+        public UserRelateBuilder withCreate_time(LocalDateTime create_time) {
+            this.create_time = create_time;
+            return this;
+        }
+
+        public UserRelate build() {
+            UserRelate userRelate = new UserRelate();
+            userRelate.setUid(uid);
+            userRelate.setPid(pid);
+            userRelate.setCreate_time(create_time);
+            return userRelate;
+        }
+    }
+}

src/main/java/com/tdba/cxb/ares/api/model/UserTypeEnum.java

@@ -0,0 +1,21 @@
+package com.tdba.cxb.ares.api.model;
+
+/**
+ * @program: order-web
+ * @description: 用户类型枚举
+ * @author: libo
+ * @create: 2022-06-08 14:29:11
+ */
+public enum UserTypeEnum {
+
+    /** 0普通用户*/
+    NORMAL,
+    /** 1大仓会员*/
+    DACANG,
+    /** 2商户*/
+    MERCHANT,
+    /** 3渠道商*/
+    CHANNEL,
+    /** 4代理商*/
+    AGENT;
+}

src/main/java/com/tdba/cxb/ares/api/repository/UserCountMapper.java

@@ -0,0 +1,22 @@
+package com.tdba.cxb.ares.api.repository;
+
+import com.tdba.cxb.ares.api.model.UserCount;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+/**
+ * @program: order-web
+ * @description: 用户注册统计
+ * @author: libo
+ * @create: 2022-06-06 17:35:04
+ */
+@Mapper
+public interface UserCountMapper {
+
+    int insertSelective(UserCount record);
+
+    int updateByPrimaryKeySelective(UserCount record);
+
+    int insertSelectiveForeach(List<UserCount> list);
+}

src/main/java/com/tdba/cxb/ares/api/repository/UserMapper.java

@@ -0,0 +1,39 @@
+package com.tdba.cxb.ares.api.repository;
+
+import com.tdba.cxb.ares.api.model.UserDto;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * @program: order-web
+ * @description: 登录用户
+ * @author: libo
+ * @create: 2022-06-06 15:52:40
+ */
+@Mapper
+public interface UserMapper {
+
+    /**
+     * 根据时间段，获取用户信息
+     * @param beginTime 开始时间
+     * @param endTime   结束时间
+     * @return
+     */
+    List<UserDto> selectByTimeRegion(@Param("beginTime")LocalDateTime beginTime,
+                                     @Param("endTime")LocalDateTime endTime);
+
+    List<UserDto> selectDacang(@Param("beginTime")LocalDateTime beginTime,
+                               @Param("endTime")LocalDateTime endTime);
+
+    List<UserDto> selectMerchant(@Param("beginTime")LocalDateTime beginTime,
+                               @Param("endTime")LocalDateTime endTime);
+
+    List<UserDto> selectChannel(@Param("beginTime")LocalDateTime beginTime,
+                               @Param("endTime")LocalDateTime endTime);
+
+    List<UserDto> selectAgent(@Param("beginTime")LocalDateTime beginTime,
+                               @Param("endTime")LocalDateTime endTime);
+}

src/main/java/com/tdba/cxb/ares/api/repository/UserRelateMapper.java

@@ -0,0 +1,33 @@
+package com.tdba.cxb.ares.api.repository;
+
+import com.tdba.cxb.ares.api.model.UserRelate;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * @program: order-web
+ * @description: 用户关联关系
+ * @author: libo
+ * @create: 2022-06-06 17:37:16
+ */
+@Mapper
+public interface UserRelateMapper {
+
+    /**
+     * 根据用户ID，获取关联信息
+     * @param uid    用户ID
+     * @return
+     */
+    List<UserRelate> selectByUid(@Param("uid") Integer uid);
+
+    int insertSelective(UserRelate record);
+
+    int updateByPrimaryKeySelective(UserRelate record);
+
+    int insertSelectiveForeach(List<UserRelate> list);
+
+    Integer updateByUid(@Param("userType") Integer userType,
+                        @Param("uid") Integer uid);
+}

src/main/java/com/tdba/cxb/ares/api/service/UserService.java

@@ -0,0 +1,299 @@
+package com.tdba.cxb.ares.api.service;
+
+import com.tdba.cxb.ares.api.model.UserCount;
+import com.tdba.cxb.ares.api.model.UserDto;
+import com.tdba.cxb.ares.api.model.UserRelate;
+import com.tdba.cxb.ares.api.model.UserTypeEnum;
+import com.tdba.cxb.ares.api.repository.UserCountMapper;
+import com.tdba.cxb.ares.api.repository.UserMapper;
+import com.tdba.cxb.ares.api.repository.UserRelateMapper;
+import com.tdba.cxb.ares.api.util.TDBAException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
+import javax.annotation.Resource;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @program: order-web
+ * @description: 登录用户
+ * @author: libo
+ * @create: 2022-06-06 15:58:31
+ */
+@Service
+public class UserService {
+
+    private static Logger logger = LoggerFactory.getLogger(UserService.class);
+
+    @Resource
+    private UserMapper userMapper;
+
+    @Resource
+    private UserCountMapper userCountMapper;
+
+    @Resource
+    private UserRelateMapper userRelateMapper;
+
+    public void createSpreadInfo(LocalDate localDate){
+
+        LocalDateTime currentTime = LocalDateTime.now();
+        List<UserCount> resultList = new ArrayList<>();
+        List<UserRelate> relateList = new ArrayList<>();
+        List<UserDto> list = userMapper.selectByTimeRegion(LocalDateTime.of(localDate, LocalTime.MIN), LocalDateTime.of(localDate, LocalTime.MAX));
+        list.stream().forEach(row -> {
+            Integer num = countOfChildren(row, list);
+            if(0 < num) {
+                resultList.add(UserCount.UserCountBuilder.anUserCount()
+                        .withUid(row.getUid())
+                        .withDate(localDate)
+                        .withNum(num)
+                        .withCreate_time(currentTime)
+                        .build());
+
+                List<Integer> idlist = listOfChildren(row, list);
+                for(int i = 0; i < idlist.size(); i++){
+                    Integer currentId = idlist.get(i);
+                    relateList.add(UserRelate.UserRelateBuilder.anUserRelate()
+                            .withUid(currentId)
+                            .withPid(row.getUid())
+                            .build());
+                    for(int j = i + 1; j < idlist.size(); j++){
+                        relateList.add(UserRelate.UserRelateBuilder.anUserRelate()
+                                .withUid(idlist.get(j))
+                                .withPid(currentId)
+                                .build());
+                    }
+                }
+            }
+
+            final Integer finallyNum = (0 > num)? num: 1;
+            //-- 追溯之前的数据
+            if((null != row.getSpread_uid()) && (0 < row.getSpread_uid())){
+                relateList.add(UserRelate.UserRelateBuilder.anUserRelate()
+                        .withUid(row.getUid())
+                        .withPid(row.getSpread_uid())
+                        .build());
+                //推荐人
+                resultList.add(UserCount.UserCountBuilder.anUserCount()
+                        .withCreate_time(currentTime)
+                        .withNum(finallyNum)
+                        .withUser_type(UserTypeEnum.NORMAL.ordinal())
+                        .withUid(row.getSpread_uid())
+                        .withDate(localDate)
+                        .build());
+
+                //往前追溯的推荐人
+                userRelateMapper.selectByUid(row.getSpread_uid()).stream().forEach(innerRow -> {
+                    resultList.add(UserCount.UserCountBuilder.anUserCount()
+                            .withCreate_time(currentTime)
+                            .withNum(finallyNum)
+                            .withUser_type(UserTypeEnum.NORMAL.ordinal())
+                            .withUid(innerRow.getPid())
+                            .withDate(localDate)
+                            .build());
+                });
+            }
+
+        });
+        if(!resultList.isEmpty()){
+            userCountMapper.insertSelectiveForeach(resultList);
+        }
+        if(!relateList.isEmpty()){
+            userRelateMapper.insertSelectiveForeach(relateList);
+        }
+        resolverAgent(localDate);
+        resolverDacang(localDate);
+        resolverMerchant(localDate);
+        resolverChannel(localDate);
+    }
+
+    /**
+     * 大仓会员
+     * @param localDateTime 日期
+     */
+    public void resolverDacang(LocalDate localDate){
+        LocalDateTime currentTime = LocalDateTime.now();
+        List<UserDto> userList = userMapper.selectDacang(LocalDateTime.of(localDate, LocalTime.MIN), LocalDateTime.of(localDate, LocalTime.MAX));
+        List<UserCount> resultList = new ArrayList<>();
+        userList.stream().forEach(row -> {
+            if(0 < row.getNum()) {
+                resultList.add(UserCount.UserCountBuilder.anUserCount()
+                        .withUid(row.getSpread_uid())
+                        .withDate(localDate)
+                        .withNum(row.getNum())
+                        .withUser_type(UserTypeEnum.DACANG.ordinal())
+                        .withCreate_time(currentTime)
+                        .build());
+                userRelateMapper.updateByUid(UserTypeEnum.DACANG.ordinal(), row.getSpread_uid());
+
+                userRelateMapper.selectByUid(row.getSpread_uid()).stream().forEach(innerRow -> {
+                    resultList.add(UserCount.UserCountBuilder.anUserCount()
+                            .withCreate_time(currentTime)
+                            .withNum(row.getNum())
+                            .withUser_type(UserTypeEnum.DACANG.ordinal())
+                            .withUid(innerRow.getPid())
+                            .withDate(localDate)
+                            .build());
+                });
+            }
+        });
+        if(!resultList.isEmpty()){
+            userCountMapper.insertSelectiveForeach(resultList);
+        }
+    }
+
+    /**
+     * 商户
+     * @param localDateTime 日期
+     */
+    public void resolverMerchant(LocalDate localDate){
+        LocalDateTime currentTime = LocalDateTime.now();
+        List<UserDto> userList = userMapper.selectMerchant(LocalDateTime.of(localDate, LocalTime.MIN), LocalDateTime.of(localDate, LocalTime.MAX));
+        List<UserCount> resultList = new ArrayList<>();
+        userList.stream().forEach(row -> {
+            if(0 < row.getNum()) {
+                resultList.add(UserCount.UserCountBuilder.anUserCount()
+                        .withUid(row.getSpread_uid())
+                        .withDate(localDate)
+                        .withNum(row.getNum())
+                        .withUser_type(UserTypeEnum.MERCHANT.ordinal())
+                        .withCreate_time(currentTime)
+                        .build());
+                userRelateMapper.updateByUid(UserTypeEnum.MERCHANT.ordinal(), row.getSpread_uid());
+
+                userRelateMapper.selectByUid(row.getSpread_uid()).stream().forEach(innerRow -> {
+                    resultList.add(UserCount.UserCountBuilder.anUserCount()
+                            .withCreate_time(currentTime)
+                            .withNum(row.getNum())
+                            .withUser_type(UserTypeEnum.MERCHANT.ordinal())
+                            .withUid(innerRow.getPid())
+                            .withDate(localDate)
+                            .build());
+                });
+            }
+        });
+        if(!resultList.isEmpty()){
+            userCountMapper.insertSelectiveForeach(resultList);
+        }
+    }
+
+    /**
+     * 渠道商
+     * @param localDateTime 日期
+     */
+    public void resolverChannel(LocalDate localDate){
+        LocalDateTime currentTime = LocalDateTime.now();
+        List<UserDto> userList = userMapper.selectChannel(LocalDateTime.of(localDate, LocalTime.MIN), LocalDateTime.of(localDate, LocalTime.MAX));
+        List<UserCount> resultList = new ArrayList<>();
+        userList.stream().forEach(row -> {
+            if(0 < row.getNum()) {
+                resultList.add(UserCount.UserCountBuilder.anUserCount()
+                        .withUid(row.getSpread_uid())
+                        .withDate(localDate)
+                        .withNum(row.getNum())
+                        .withUser_type(UserTypeEnum.CHANNEL.ordinal())
+                        .withCreate_time(currentTime)
+                        .build());
+                userRelateMapper.updateByUid(UserTypeEnum.CHANNEL.ordinal(), row.getSpread_uid());
+
+                userRelateMapper.selectByUid(row.getSpread_uid()).stream().forEach(innerRow -> {
+                    resultList.add(UserCount.UserCountBuilder.anUserCount()
+                            .withCreate_time(currentTime)
+                            .withNum(row.getNum())
+                            .withUser_type(UserTypeEnum.CHANNEL.ordinal())
+                            .withUid(innerRow.getPid())
+                            .withDate(localDate)
+                            .build());
+                });
+            }
+        });
+        if(!resultList.isEmpty()){
+            userCountMapper.insertSelectiveForeach(resultList);
+        }
+    }
+
+    /**
+     * 代理商
+     * @param localDateTime 日期
+     */
+    public void resolverAgent(LocalDate localDate){
+        LocalDateTime currentTime = LocalDateTime.now();
+        List<UserDto> userList = userMapper.selectAgent(LocalDateTime.of(localDate, LocalTime.MIN), LocalDateTime.of(localDate, LocalTime.MAX));
+        List<UserCount> resultList = new ArrayList<>();
+        userList.stream().forEach(row -> {
+            if(0 < row.getNum()) {
+                resultList.add(UserCount.UserCountBuilder.anUserCount()
+                        .withUid(row.getSpread_uid())
+                        .withDate(localDate)
+                        .withNum(row.getNum())
+                        .withUser_type(UserTypeEnum.AGENT.ordinal())
+                        .withCreate_time(currentTime)
+                        .build());
+                userRelateMapper.updateByUid(UserTypeEnum.AGENT.ordinal(), row.getSpread_uid());
+
+                userRelateMapper.selectByUid(row.getSpread_uid()).stream().forEach(innerRow -> {
+                    resultList.add(UserCount.UserCountBuilder.anUserCount()
+                            .withCreate_time(currentTime)
+                            .withNum(row.getNum())
+                            .withUser_type(UserTypeEnum.AGENT.ordinal())
+                            .withUid(innerRow.getPid())
+                            .withDate(localDate)
+                            .build());
+                });
+            }
+        });
+        if(!resultList.isEmpty()){
+            userCountMapper.insertSelectiveForeach(resultList);
+        }
+    }
+
+    private List<Integer> listOfChildren(UserDto userDto, List<UserDto> list){
+        if(userDto == null || CollectionUtils.isEmpty(list)){
+            return List.of();
+        }
+
+        List<Integer> resultList = new ArrayList<>();
+        for(UserDto row : list){
+            if(userDto.getUid() == row.getUid()){
+                continue;
+            }
+            if(row.getSpread_uid() == userDto.getUid()){
+                if(row.getUid() == userDto.getSpread_uid()){
+                    logger.error("循环嵌套 row.getSpread_uid() = {}, userDto.getUid() = {}", row.getSpread_uid(), userDto.getSpread_uid());
+                    throw new TDBAException("循环嵌套");
+                }
+                resultList.addAll(listOfChildren(row, list));
+            }
+        }
+        return resultList;
+    }
+
+
+    private Integer countOfChildren(UserDto userDto, List<UserDto> list){
+
+        if(userDto == null || CollectionUtils.isEmpty(list)){
+            return 0;
+        }
+
+        Integer result = 0;
+        for(UserDto row : list){
+            if(userDto.getUid() == row.getUid()){
+                continue;
+            }
+            if(row.getSpread_uid() == userDto.getUid()){
+                if(row.getUid() == userDto.getSpread_uid()){
+                    logger.error("循环嵌套 row.getSpread_uid() = {}, userDto.getUid() = {}", row.getSpread_uid(), userDto.getSpread_uid());
+                    throw new TDBAException("循环嵌套");
+                }
+                result = 1 + countOfChildren(row, list);
+            }
+        }
+        return result;
+    }
+}

src/main/resources/mapper/UserCountMapper.xml

@@ -0,0 +1,82 @@
+<?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.tdba.cxb.ares.api.repository.UserCountMapper">
+
+    <insert id="insertSelective">
+        insert into user_count
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="null != uid">
+                uid,
+            </if>
+            <if test="null != num">
+                num,
+            </if>
+            <if test="null != date">
+                date,
+            </if>
+            <if test="null != create_time">
+                create_time,
+            </if>
+            <if test="null != del_flag">
+                del_flag,
+            </if>
+        </trim>
+
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="null != uid">
+                #{ uid },
+            </if>
+            <if test="null != num">
+                #{ num },
+            </if>
+            <if test="null != date">
+                #{ date },
+            </if>
+            <if test="null != create_time">
+                #{create_time},
+            </if>
+            <if test="null != del_flag">
+                #{del_flag},
+            </if>
+        </trim>
+    </insert>
+
+    <update id="updateByPrimaryKeySelective">
+        update user_count
+        <set>
+            <if test="null != uid">
+                uid = #{ uid },
+            </if>
+            <if test="null != num">
+                num = #{ num },
+            </if>
+            <if test="null != date">
+                date = #{ date },
+            </if>
+            <if test="null != create_time">
+                create_time = #{create_time},
+            </if>
+            <if test="null != del_flag">
+                del_flag = #{del_flag},
+            </if>
+        </set>
+        where id = #{id}
+    </update>
+
+    <insert id="insertSelectiveForeach">
+        insert into user_count
+        (
+        uid,
+        num,
+        date,
+        create_time       )
+        values
+        <foreach collection="list" separator="," item="row">
+            (
+            #{row.uid },
+            #{row.num },
+            #{row.date },
+            #{row.create_time }     )
+        </foreach>
+    </insert>
+</mapper>

src/main/resources/mapper/UserMapper.xml

@@ -0,0 +1,85 @@
+<?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.tdba.cxb.ares.api.repository.UserMapper">
+
+    <select id="selectByTimeRegion" resultType="com.tdba.cxb.ares.api.model.UserDto">
+        select
+            uid,
+            spread_uid
+        from
+            rrx_user
+        where
+            test_user = 0
+            <![CDATA[ and spread_uid > 0 ]]>
+            <![CDATA[ and create_time >= #{beginTime} ]]>
+            <![CDATA[ and create_time <= #{endTime} ]]>
+    </select>
+
+    <select id="selectDacang" resultType="com.tdba.cxb.ares.api.model.UserDto">
+        select
+            count(1) 'num',
+            u.spread_uid
+        from
+            rrx_da_cang_user da
+        left join
+            rrx_user u
+            on da.uid = u.uid
+        where
+            da.status = 1
+             <![CDATA[ and da.ctime >= #{beginTime} ]]>
+             <![CDATA[ and da.ctime <= #{endTime} ]]>
+            and u.test_user = 0
+            and u.spread_uid > 0
+    </select>
+
+    <select id="selectMerchant" resultType="com.tdba.cxb.ares.api.model.UserDto">
+        select
+            count(1) 'num',
+            u.spread_uid
+        from
+            rrx_merchant_admin da
+            left join
+            rrx_user u
+            on da.uid = u.uid
+        where
+            da.status = 1
+            <![CDATA[ and da.create_time >= #{beginTime} ]]>
+            <![CDATA[ and da.create_time <=#{endTime} ]]>
+            and u.test_user = 0
+            and u.spread_uid > 0
+    </select>
+
+    <select id="selectChannel" resultType="com.tdba.cxb.ares.api.model.UserDto">
+        select
+            count(1) 'num',
+            u.spread_uid
+        from
+            rrx_channel_user da
+        left join
+            rrx_user u
+            on da.uid = u.uid
+        where
+            da.status = 1
+            <![CDATA[ and da.ctime >= #{beginTime} ]]>
+            <![CDATA[ and da.ctime <= #{endTime} ]]>
+            and u.test_user = 0
+            and u.spread_uid > 0
+    </select>
+
+    <select id="selectAgent" resultType="com.tdba.cxb.ares.api.model.UserDto">
+        select
+            count(1) 'num',
+            u.spread_uid
+        from
+            rrx_user_agent da
+            left join
+            rrx_user u
+            on da.user_id = u.uid
+        where
+            da.status = 1
+            <![CDATA[ and da.add_time >= #{beginTime} ]]>
+            <![CDATA[ and da.add_time <= #{endTime} ]]>
+            and u.test_user = 0
+            and u.spread_uid > 0
+    </select>
+</mapper>

src/main/resources/mapper/UserRelateMapper.xml

@@ -0,0 +1,82 @@
+<?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.tdba.cxb.ares.api.repository.UserRelateMapper">
+
+    <insert id="insertSelective">
+        insert into user_relate
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="null != uid">
+                uid,
+            </if>
+            <if test="null != pid">
+                pid,
+            </if>
+            <if test="null != del_flag">
+                del_flag,
+            </if>
+        </trim>
+
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="null != uid">
+                #{ uid },
+            </if>
+            <if test="null != pid">
+                #{ pid },
+            </if>
+            <if test="null != del_flag">
+                #{del_flag},
+            </if>
+        </trim>
+    </insert>
+
+    <update id="updateByPrimaryKeySelective">
+        update user_relate
+        <set>
+            <if test="null != uid">
+                uid = #{ uid },
+            </if>
+            <if test="null != pid">
+                pid = #{ pid },
+            </if>
+            <if test="null != del_flag">
+                del_flag = #{del_flag},
+            </if>
+        </set>
+        where id = #{id}
+    </update>
+
+    <insert id="insertSelectiveForeach">
+        insert into user_relate
+        (
+        uid,
+        pid      )
+        values
+        <foreach collection="list" separator="," item="row">
+            (
+            #{row.uid },
+            #{row.pid }       )
+        </foreach>
+    </insert>
+
+    <select id="selectByUid" resultType="com.tdba.cxb.ares.api.model.UserRelate">
+        select * from user_relate where del_flag = 0 and uid = #{uid}
+    </select>
+
+    <select id="updateByUid">
+        update user_relate set
+            <if test="userType == 1">
+                is_dacang = 1
+            </if>
+            <if test="userType == 2">
+                is_merchant = 1
+            </if>
+            <if test="userType == 3">
+                is_channel = 1
+            </if>
+            <if test="userType == 4">
+                is_agent = 1
+            </if>
+
+        where uid = #{uid}
+    </select>
+</mapper>

src/test/java/com/tdba/cxb/ares/api/user/UserDto.java

@@ -0,0 +1,33 @@
+package com.tdba.cxb.ares.api.user;
+
+/**
+ * @program: admin-web
+ * @description:
+ * @author: libo
+ * @create: 2022-06-06 15:26:14
+ */
+public class UserDto {
+
+    /** 用户ID*/
+    private Integer uid;
+
+    /** 推荐人用户ID*/
+    private Integer spread_uid;
+
+    public Integer getUid() {
+        return uid;
+    }
+
+    public void setUid(Integer uid) {
+        this.uid = uid;
+    }
+
+    public Integer getSpread_uid() {
+        return spread_uid;
+    }
+
+    public void setSpread_uid(Integer spread_uid) {
+        this.spread_uid = spread_uid;
+    }
+
+}

src/test/java/com/tdba/cxb/ares/api/user/UserRelateTest.java

@@ -0,0 +1,27 @@
+package com.tdba.cxb.ares.api.user;
+
+import com.tdba.cxb.ares.api.ApplicationStartup;
+import com.tdba.cxb.ares.api.service.UserService;
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import javax.annotation.Resource;
+import java.time.LocalDate;
+
+/**
+ * @program: order-web
+ * @description:
+ * @author: libo
+ * @create: 2022-06-06 17:40:27
+ */
+@SpringBootTest(classes = ApplicationStartup.class)
+public class UserRelateTest {
+
+    @Resource
+    private UserService userService;
+
+    @Test
+    public void test(){
+        userService.createSpreadInfo(LocalDate.of(2021, 4, 9));
+    }
+}

src/test/java/com/tdba/cxb/ares/api/user/UserTest.java

@@ -0,0 +1,68 @@
+package com.tdba.cxb.ares.api.user;
+
+import com.tdba.cxb.ares.api.util.TDBAException;
+import org.junit.jupiter.api.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.util.CollectionUtils;
+
+import java.util.List;
+
+/**
+ * @program: admin-web
+ * @description:
+ * @author: libo
+ * @create: 2022-06-06 15:17:42
+ */
+public class UserTest {
+
+    private static Logger logger = LoggerFactory.getLogger(UserTest.class);
+
+    @Test
+    public void test(){
+
+        List<UserDto> list = List.of(UserDto.UserDtoBuilder.anUserDto()
+                .withUid(2)
+                .withSpread_uid(1)
+                .build(),
+                UserDto.UserDtoBuilder.anUserDto()
+                        .withUid(3)
+                        .withSpread_uid(2)
+                        .build(),
+                UserDto.UserDtoBuilder.anUserDto()
+                        .withUid(1)
+                        .withSpread_uid(0)
+                        .build(),
+                UserDto.UserDtoBuilder.anUserDto()
+                        .withUid(4)
+                        .withSpread_uid(0)
+                        .build());
+
+        list.stream().forEach(row -> {
+            logger.info("uid = {}, count = {}", row.getUid(), countOfChildren(row, list));
+        });
+
+    }
+
+    public static Integer countOfChildren(UserDto userDto, List<UserDto> list){
+
+        if(userDto == null || CollectionUtils.isEmpty(list)){
+            return 0;
+        }
+
+        Integer result = 0;
+        for(UserDto row : list){
+            if(userDto.getUid() == row.getUid()){
+                continue;
+            }
+           if(row.getSpread_uid() == userDto.getUid()){
+               if(row.getUid() == userDto.getSpread_uid()){
+                   logger.error("循环嵌套 row.getSpread_uid() = {}, userDto.getUid() = {}", row.getSpread_uid(), userDto.getSpread_uid());
+                   throw new TDBAException("循环嵌套");
+               }
+                result = 1 + countOfChildren(row, list);
+           }
+        }
+        return result;
+    }
+}