* init

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

@@ -78,46 +78,45 @@ public class UserService {
                                 .build());
                     }
                 }
-            }
 
-            final Integer finallyNum = (0 > num)? num: 10;
-            //-- 追溯之前的数据
-            if((null != row.getSpread_uid()) && (0 < row.getSpread_uid())){
-                relateList.add(UserRelate.UserRelateBuilder.anUserRelate()
-                        .withUid(row.getUid())
-                        .withPid(row.getSpread_uid())
-                        .withDate(localDate)
-                        .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 -> {
+                //-- 追溯之前的数据
+                if((null != row.getSpread_uid()) && (0 < row.getSpread_uid())){
+                    relateList.add(UserRelate.UserRelateBuilder.anUserRelate()
+                            .withUid(row.getUid())
+                            .withPid(row.getSpread_uid())
+                            .withDate(localDate)
+                            .build());
+                    //推荐人
                     resultList.add(UserCount.UserCountBuilder.anUserCount()
                             .withCreate_time(currentTime)
-                            .withNum(finallyNum)
+                            .withNum(num)
                             .withUser_type(UserTypeEnum.NORMAL.ordinal())
-                            .withUid(innerRow.getPid())
+                            .withUid(row.getSpread_uid())
                             .withDate(localDate)
                             .build());
 
-                    relateList.add(UserRelate.UserRelateBuilder.anUserRelate()
-                            .withUid(row.getUid())
-                            .withPid(innerRow.getPid())
-                            .withDate(localDate)
-                            .build());
-                });
-            }
-            if(!relateList.isEmpty()){
-                userRelateMapper.insertSelectiveForeach(relateList);
+                    //往前追溯的推荐人
+                    userRelateMapper.selectByUid(row.getSpread_uid()).stream().forEach(innerRow -> {
+                        resultList.add(UserCount.UserCountBuilder.anUserCount()
+                                .withCreate_time(currentTime)
+                                .withNum(num)
+                                .withUser_type(UserTypeEnum.NORMAL.ordinal())
+                                .withUid(innerRow.getPid())
+                                .withDate(localDate)
+                                .build());
+
+                        relateList.add(UserRelate.UserRelateBuilder.anUserRelate()
+                                .withUid(row.getUid())
+                                .withPid(innerRow.getPid())
+                                .withDate(localDate)
+                                .build());
+                    });
+                }
+                if(!relateList.isEmpty()){
+                    userRelateMapper.insertSelectiveForeach(relateList);
+                }
+                relateList.clear();
             }
-            relateList.clear();
         });
         if(!resultList.isEmpty()){
             userCountMapper.insertSelectiveForeach(resultList);