踢出群聊功能流程验证通

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

@@ -36,13 +36,13 @@ public class RiskUserHandleService {
     public void handleRiskUser(RiskUserInfo riskUserInfo){
         log.info("handleRiskUser, riskUserInfo: {}", riskUserInfo);
         //根据名称找到人
-//        List<UserBase> staffList = findStaffByName(riskUserInfo);
-        //for test
-        List<UserBase> staffList = new ArrayList<>();
-        UserBase staff1 = new UserBase();
-        staff1.setVid("1688858050719288");
-        staff1.setUuid("a09c1237a66a2f30868c9e71b0941fac");
-        staffList.add(staff1);
+        List<UserBase> staffList = findStaffByName(riskUserInfo);
+//        //for test
+//        List<UserBase> staffList = new ArrayList<>();
+//        UserBase staff1 = new UserBase();
+//        staff1.setVid("1688858050719288");
+//        staff1.setUuid("a09c1237a66a2f30868c9e71b0941fac");
+//        staffList.add(staff1);
 
         if (staffList.isEmpty()) return;
         //根据群名匹配到：人-群:哪个员工哪个群
@@ -66,7 +66,6 @@ public class RiskUserHandleService {
                 if (success) {
                     log.info("handleRiskUser to be kick user, vid: {},name: {}", externalVid,riskUserInfo.getExternalNickname());
                     return;
-                    //kick(staff, Long.parseLong(roomInfo.getRoomId()), externalVid);
                 }
             }
         }

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

@@ -49,7 +49,7 @@ public class RiskUserOperateService {
         requestBody.put("blacklist_vid",Arrays.asList(vid));
         String params = JSON.toJSONString(requestBody);
         LOGGER.info("kick, staff: {}, params: {}", staff, params);
-        Optional<String> response = httpPoolClientDefault.postJson(qywxConfig.getDomain() + qywxConfig.getPath(" kick-external"), params);
+        Optional<String> response = httpPoolClientDefault.postJson(qywxConfig.getDomain() + qywxConfig.getPath("kick-external"), params);
         if (response.isPresent()) {
             QwCommonResModel<RoomListResponse> roomInfo = QwCommonResModel.parseResponse(response.get(), RoomListResponse.class);
             if (roomInfo.getErrcode() == 0) {
@@ -82,8 +82,7 @@ public class RiskUserOperateService {
     private List<RoomMemberListInfo.Member> getRoomMemberList(UserBase staff, long roomId) {
         Map<String, Object> requestBody = new HashMap<>();
         requestBody.put("uuid", staff.getUuid());
-        requestBody.put("roomId", roomId);
-//        LOGGER.info("getRoomMemberList, staff: {}", staff);
+        requestBody.put("roomid", roomId);
         String params = JSON.toJSONString(requestBody);
         String url = qywxConfig.getDomain() + qywxConfig.getPath("get-roomMembers");
         Optional<String> response = httpPoolClientDefault.postJson(url, params);