* init

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

@@ -93,7 +93,7 @@ public class UserService {
                         .withDate(localDate)
                         .build());
 
-                if((0 < num) && list.stream().noneMatch(innerRow -> innerRow.getUid().equals(row.getSpread_uid()))) {
+                if(list.stream().noneMatch(innerRow -> innerRow.getUid().equals(row.getSpread_uid()))) {
                     //推荐人
                     resultList.add(UserCount.UserCountBuilder.anUserCount()
                             .withCreate_time(currentTime)
@@ -128,7 +128,14 @@ public class UserService {
             relateList.clear();
         });
         if(!resultList.isEmpty()){
-            userCountMapper.insertSelectiveForeach(resultList);
+            userCountMapper.insertSelectiveForeach(resultList.stream().collect(Collectors.groupingBy(UserCount::getUid)).entrySet().stream()
+                    .map(row -> UserCount.UserCountBuilder.anUserCount()
+                            .withUid(row.getKey())
+                            .withUser_type(UserTypeEnum.NORMAL.ordinal())
+                            .withDate(localDate)
+                            .withNum(row.getValue().stream().mapToInt(UserCount::getNum).sum())
+                            .withCreate_time(currentTime)
+                            .build()).toList());
         }
 
         resolverAgent(localDate);