拉黑踢出群聊测试流程完善

risk-control-core/src/main/java/com/tzld/piaoquan/risk/control/service/impl/QywxUserDataService.java

@@ -250,7 +250,7 @@ public class QywxUserDataService {
     //根据名称查询用户
     public List<UserBase> getUserByNickName(String nickname) {
         UserBaseExample example = new UserBaseExample();
-        example.createCriteria().andRealnameEqualTo(nickname);
+        example.createCriteria().andNicknameEqualTo(nickname);
         List<UserBase> users = userBaseMapper.selectByExample(example);
         return users.isEmpty() ? null : users;
     }

risk-control-core/src/main/java/com/tzld/piaoquan/risk/control/service/impl/RiskUserHandleService.java

@@ -94,7 +94,7 @@ public class RiskUserHandleService {
                 //获取匹配到每个人的群信息
                 List<RoomListResponse.RoomInfo> chatRoomList = getChatList(userBase);
                 if (chatRoomList != null && !chatRoomList.isEmpty()) {
-                    log.info("handleRiskUserList hits, userInfo: {}", userBase);
+                    log.info("handleRiskUserList chat room hit, userInfo: {}", userBase);
                     for (RoomListResponse.RoomInfo roomInfo : chatRoomList) {
                         List<RoomListResponse.RoomInfo> matched = findRoomByChatRoomName(chatRoomList, userInfo);
                         if (matched != null && !matched.isEmpty()) {
@@ -127,7 +127,7 @@ public class RiskUserHandleService {
         requestBody.put("uuid", userBase.getUuid());
         requestBody.put("limit", 100);
         requestBody.put("star_index", 0);
-        LOGGER.info("getChatList, userBase: {}", userBase);
+        log.info("getChatList, userBase: {}", userBase);
         String params = JSON.toJSONString(requestBody);
         Optional<String> response = httpPoolClientDefault.postJson(qywxConfig.getDomain() + qywxConfig.getPath("get-chatList"), params);
         QwCommonResModel<RoomListResponse> roomList = null;
@@ -150,12 +150,18 @@ public class RiskUserHandleService {
         List<UserBase> userBaseList = new ArrayList<>();
         if (userInfo != null ) {
             List<RiskUserInfo.Admin> adminList = userInfo.getAdminList();
-            List<UserBase> staffList = qwUserService.getUserByNickName(userInfo.getExternalNickname());
+//            List<UserBase> staffList = qwUserService.getUserByNickName(userInfo.getExternalNickname());
             if (adminList != null && !adminList.isEmpty()) {
                 for (RiskUserInfo.Admin admin : adminList) {
                     String name = admin.getNickname();
                     if (name != null && !name.isEmpty()) {
-                        userBaseList.addAll(qwUserService.getUserByNickName(name));
+                        log.info("handleRiskUserList hits, userInfo: {}", name);
+                        List<UserBase> matched = qwUserService.getUserByNickName(name);
+                        if (matched != null && !matched.isEmpty()) {
+                            userBaseList.addAll(matched);
+                        } else {
+                            log.info("handleRiskUserList not hits, userInfo: {}", name);
+                        }
                     }
                 }
             }

risk-control-server/src/test/java/com/tzld/piaoquan/risk/control/service/DemoServiceTest.java

@@ -20,7 +20,7 @@ public class DemoServiceTest extends BaseTest {
 
     @Test
     void test(){
-        String riskInfo = "{\"chat_id\":\"wrreQkBgAAqfC7PyfSzRwj2ailPbXImg\",\"group_name\":\"一起成行-测试c\",\"corp_id\":\"ww84bf86fbc1f29e79\",\"admin_list\":[{\"userid\":\"woreQkBgAA0TWJDl2bJ-M5NIZtk3xohg\",\"nickname\":\"刘立冬\"},{\"userid\":\"pony\",\"nickname\":\"我是张三\"}],\"external_id\":\"wmreQkBgAA5XY8GeuzW5OTxMz0TXxtTw\",\"external_nickname\":\"我也不吃了\",\"join_time\":1747881759,\"join_scene\":3,\"risk_level\":0}";
+        String riskInfo = "{\"chat_id\":\"wrreQkBgAAqfC7PyfSzRwj2ailPbXImg\",\"group_name\":\"qqq\",\"corp_id\":\"ww84bf86fbc1f29e79\",\"admin_list\":[{\"userid\":\"woreQkBgAA0TWJDl2bJ-M5NIZtk3xohg\",\"nickname\":\"刘立冬3\"},{\"userid\":\"pony\",\"nickname\":\"我是张三\"}],\"external_id\":\"wmreQkBgAAXnVuQtd16o_TyiWMbj24vQ\",\"external_nickname\":\"ivy\",\"join_time\":1748189477,\"join_scene\":3,\"risk_level\":0}";
         RiskUserInfo riskUser = JSON.parseObject(riskInfo, RiskUserInfo.class);
         System.out.println(riskUser);
         riskUserHandleService.handleRiskUser(riskUser);