* init

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

@@ -39,5 +39,5 @@ public interface UserRelateMapper {
                                      @Param("userType") Integer userType);
 
     Integer updateByUidList(@Param("userType") Integer userType,
-                        @Param("uid_concat") String uid_concat);
+                        @Param("uidArray") String[] uidArray);
 }

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

@@ -123,18 +123,18 @@ public class UserService {
                 });
             }
             if(!relateList.isEmpty()){
-                userRelateMapper.insertSelectiveForeach(relateList);
+//                userRelateMapper.insertSelectiveForeach(relateList);
             }
             relateList.clear();
         });
         if(!resultList.isEmpty()){
-            userCountMapper.insertSelectiveForeach(resultList);
+//            userCountMapper.insertSelectiveForeach(resultList);
         }
 
         resolverAgent(localDate);
-        resolverDacang(localDate);
-        resolverMerchant(localDate);
-        resolverChannel(localDate);
+//        resolverDacang(localDate);
+//        resolverMerchant(localDate);
+//        resolverChannel(localDate);
     }
 
     /**
@@ -154,7 +154,7 @@ public class UserService {
                         .withUser_type(UserTypeEnum.DACANG.ordinal())
                         .withCreate_time(currentTime)
                         .build());
-                userRelateMapper.updateByUidList(UserTypeEnum.DACANG.ordinal(), row.getUid_concat());
+                userRelateMapper.updateByUidList(UserTypeEnum.DACANG.ordinal(), row.getUid_concat().split(","));
 
                 userRelateMapper.selectByUid(row.getSpread_uid()).stream().forEach(innerRow -> {
                     resultList.add(UserCount.UserCountBuilder.anUserCount()
@@ -199,7 +199,7 @@ public class UserService {
                         .withUser_type(UserTypeEnum.MERCHANT.ordinal())
                         .withCreate_time(currentTime)
                         .build());
-                userRelateMapper.updateByUidList(UserTypeEnum.MERCHANT.ordinal(), row.getUid_concat());
+                userRelateMapper.updateByUidList(UserTypeEnum.MERCHANT.ordinal(), row.getUid_concat().split(","));
 
                 userRelateMapper.selectByUid(row.getSpread_uid()).stream().forEach(innerRow -> {
                     resultList.add(UserCount.UserCountBuilder.anUserCount()
@@ -234,7 +234,7 @@ public class UserService {
                         .withUser_type(UserTypeEnum.CHANNEL.ordinal())
                         .withCreate_time(currentTime)
                         .build());
-                userRelateMapper.updateByUidList(UserTypeEnum.CHANNEL.ordinal(), row.getUid_concat());
+                userRelateMapper.updateByUidList(UserTypeEnum.CHANNEL.ordinal(), row.getUid_concat().split(","));
 
                 userRelateMapper.selectByUid(row.getSpread_uid()).stream().forEach(innerRow -> {
                     resultList.add(UserCount.UserCountBuilder.anUserCount()
@@ -269,7 +269,7 @@ public class UserService {
                         .withUser_type(UserTypeEnum.AGENT.ordinal())
                         .withCreate_time(currentTime)
                         .build());
-                userRelateMapper.updateByUidList(UserTypeEnum.AGENT.ordinal(), row.getUid_concat());
+                userRelateMapper.updateByUidList(UserTypeEnum.AGENT.ordinal(), row.getUid_concat().split(","));
 
                 userRelateMapper.selectByUid(row.getSpread_uid()).stream().forEach(innerRow -> {
                     resultList.add(UserCount.UserCountBuilder.anUserCount()
@@ -329,7 +329,7 @@ public class UserService {
                     logger.error("循环嵌套 row.getSpread_uid() = {}, userDto.getUid() = {}", row.getSpread_uid(), userDto.getSpread_uid());
                     throw new TDBAException("循环嵌套");
                 }
-                result = 1 + countOfChildren(row, list);
+                result += 1 + countOfChildren(row, list);
             }
         }
         return result;

src/main/resources/mapper/UserRelateMapper.xml

@@ -141,7 +141,10 @@
             is_agent = 1
         </if>
 
-        where uid in ( #{uid_concat} )
+        where uid in
+            <foreach collection="uidArray" item="item" open="(" separator="," close=")">
+                #{item}
+            </foreach>
     </select>
 
     <select id="countByUid" resultType="java.lang.Integer">