提交 b6a24fe9 作者: 洪东保

debug

父级 c1c78f32
...@@ -153,9 +153,11 @@ public class WeComServiceImpl extends ServiceImpl<WeComUserMapper, WeComUser> i ...@@ -153,9 +153,11 @@ public class WeComServiceImpl extends ServiceImpl<WeComUserMapper, WeComUser> i
.build(); .build();
try (Response response = new OkHttpClient().newCall(request).execute()) { try (Response response = new OkHttpClient().newCall(request).execute()) {
org.json.JSONObject json = new org.json.JSONObject(response.body().string()); String string = response.body().string();
org.json.JSONObject json = new org.json.JSONObject(string);
MeetingInfo meetingInfo = new MeetingInfo(); MeetingInfo meetingInfo = new MeetingInfo();
if (json.getInt("errcode") != 0) { if (json.getInt("errcode") != 0) {
log.error(string);
return meetingInfo; // 或者抛出异常 return meetingInfo; // 或者抛出异常
} }
meetingInfo.setMeetingId(json.getString("meetingid")); meetingInfo.setMeetingId(json.getString("meetingid"));
...@@ -209,38 +211,29 @@ public class WeComServiceImpl extends ServiceImpl<WeComUserMapper, WeComUser> i ...@@ -209,38 +211,29 @@ public class WeComServiceImpl extends ServiceImpl<WeComUserMapper, WeComUser> i
@Override @Override
public void userBind() { public void userBind() {
String weComToken = getToken();
//查出没有建立关联的企微人员 //查出没有建立关联的企微人员
List<WeComUser> noBindUsers = noBindUsers(); List<WeComUser> noBindUsers = noBindUsers();
List<UserId> userIds = new ArrayList<>(); List<UserId> userIds = new ArrayList<>();
try{ for (WeComUser user : noBindUsers) {
for (WeComUser user : noBindUsers) { String weComToken = getToken();
MeetingInfo meetingInfo = createTempMeeting(user.getUserId(), weComToken); MeetingInfo meetingInfo = createTempMeeting(user.getUserId(), weComToken);
String meetingId = meetingInfo.getMeetingId(); String meetingId = meetingInfo.getMeetingId();
String meetingCode = meetingInfo.getMeetingCode(); String meetingCode = meetingInfo.getMeetingCode();
if (meetingCode == null || meetingCode.isEmpty()) { if (meetingCode == null || meetingCode.isEmpty()) {
log.error("会议创建失败,跳过用户: " + user.getUserId()); log.error("会议创建失败,跳过用户: " + user.getUserId());
continue; continue;
}
// 查询会议详情,获取主持人腾讯会议userid
String hostUserId = tencentMeetingService.getMeetingHost(meetingCode);
cancelMeeting(meetingId, weComToken); // 尝试取消无效会议
if (hostUserId == null || hostUserId.isEmpty()) {
log.error("获取主持人失败,跳过会议: " + meetingCode);
continue;
}
UserId userId = UserId.builder().userName(user.getUserName()).wid(user.getUserId()).tid(hostUserId).build();
// userIds.add(userId);
userIdMapper.insert(userId);
// if(userIds.size() > 200){
// userIdMapper.insertUsers(userIds);
// userIds= new ArrayList<>();
// }
} }
}catch (Exception e){ // 查询会议详情,获取主持人腾讯会议userid
throw new RuntimeException(e); String hostUserId = tencentMeetingService.getMeetingHost(meetingCode);
cancelMeeting(meetingId, weComToken); // 尝试取消无效会议
if (hostUserId == null || hostUserId.isEmpty()) {
log.error("获取主持人失败,跳过会议: " + meetingCode);
continue;
}
UserId userId = UserId.builder().userName(user.getUserName()).wid(user.getUserId()).tid(hostUserId).build();
userIdMapper.insert(userId);
} }
log.info("执行userBind完成");
} }
@Override @Override
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论