debug

src/main/java/com/cmeeting/controller/TencentMeetingController.java

 package com.cmeeting.controller;
 
 import com.cmeeting.service.TencentMeetingService;
+import com.cmeeting.service.WeComService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import javax.annotation.Resource;
+
 
 @RestController
 @RequestMapping("/tencentMeeting")
 public class TencentMeetingController {
     @Autowired
     private TencentMeetingService tencentMeetingService;
+    @Resource
+    private WeComService weComService;
 
     @GetMapping("/add")
     public void addUsers() {
         tencentMeetingService.doUsers();
     }
+    @GetMapping("/bind")
+    public void bind() {
+        weComService.userBind();
+    }
 }

src/main/java/com/cmeeting/job/CmeetingJob.java

@@ -109,6 +109,7 @@ public class CmeetingJob {
             log.info("-------企微人员定时同步任务结束--------");
         } catch (Exception e) {
             e.printStackTrace();
+            log.error("企微人员定时同步失败");
         } finally {
             redisUtils.del("weComUserSync");
         }

src/main/java/com/cmeeting/service/impl/WeComServiceImpl.java

@@ -18,6 +18,7 @@ import com.cmeeting.pojo.WeComUser;
 import com.cmeeting.service.TencentMeetingService;
 import com.cmeeting.service.WeComService;
 import com.cmeeting.util.RedisUtils;
+import com.google.common.collect.Lists;
 import lombok.extern.slf4j.Slf4j;
 import okhttp3.*;
 import org.apache.commons.lang3.StringUtils;
@@ -60,7 +61,11 @@ public class WeComServiceImpl extends ServiceImpl<WeComUserMapper, WeComUser>  i
 
     @Override
     public void batchInsert(List<WeComUser> users) {
-        weComUserMapper.batchInsert(users);
+        log.info("企业微信人员数量： {}", users.size());
+        List<List<WeComUser>> partition = Lists.partition(users, 1000);
+        for (List<WeComUser> weComUsers : partition) {
+            weComUserMapper.batchInsert(weComUsers);
+        }
     }
 
     @Override
@@ -69,6 +74,7 @@ public class WeComServiceImpl extends ServiceImpl<WeComUserMapper, WeComUser>  i
         JSONArray departmentList = getDepartmentList();
         Iterator<Object> iterator = departmentList.iterator();
         List<WeComUser> users = new ArrayList<>();
+        int sum = 0;
         while (iterator.hasNext()){
             JSONObject department = (JSONObject) iterator.next();
             String departmentId = String.valueOf(department.get("id"));
@@ -76,8 +82,8 @@ public class WeComServiceImpl extends ServiceImpl<WeComUserMapper, WeComUser>  i
             JSONArray userList = getUserListByDepartment(departmentId);
             for (int i = 0; i < userList.size(); i++) {
                 JSONObject userJson = (JSONObject)userList.get(i);
-                System.out.println("姓名: " + userJson.get("name") +
-                        ", UserID: " + userJson.get("userid"));
+                sum++;
+                System.out.println("姓名: " + userJson.get("name") + ", UserID: " + userJson.get("userid") + ", sum: " + sum);
                 // 转换为WeComUser集合
                 WeComUser user = new WeComUser();
                 user.setUserId(userJson.getString("userid"));
@@ -225,14 +231,15 @@ public class WeComServiceImpl extends ServiceImpl<WeComUserMapper, WeComUser>  i
                     continue;
                 }
                 UserId userId = UserId.builder().userName(user.getUserName()).wid(user.getUserId()).tid(hostUserId).build();
-                userIds.add(userId);
+//                userIds.add(userId);
+                userIdMapper.insert(userId);
+//                if(userIds.size() > 200){
+//                    userIdMapper.insertUsers(userIds);
+//                    userIds= new ArrayList<>();
+//                }
             }
         }catch (Exception e){
             throw new RuntimeException(e);
-        }finally {
-            if(!CollectionUtils.isEmpty(userIds)){
-                userIdMapper.insertUsers(userIds);
-            }
         }
     }
 
@@ -313,7 +320,7 @@ public class WeComServiceImpl extends ServiceImpl<WeComUserMapper, WeComUser>  i
      */
     public JSONArray getUserListByDepartment ( String departmentId) throws Exception {
         String urlStr = "https://qyapi.weixin.qq.com/cgi-bin/user/simplelist?access_token=" + getToken() + "&department_id=" + departmentId;
-
+        log.info("urlStr: {}", urlStr);
         URL url = new URL(urlStr);
         HttpURLConnection conn = (HttpURLConnection) url.openConnection();
         conn.setRequestMethod("GET");