test

src/main/java/com/kiisoo/ic/wx/service/QWMailListManageService.java

@@ -1,6 +1,8 @@
 package com.kiisoo.ic.wx.service;
 
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.kiisoo.ic.config.WxCpConfiguration;
 import com.kiisoo.ic.customer.CustomerService;
@@ -93,6 +95,48 @@ public class QWMailListManageService {
         return userService.listByDepartment(MAIN_DEPARTMENT_ID, true, 0);
     }
 
+    /**
+     * 查询企业微信用户
+     */
+    public List<WxCpUser> syncUserNew() throws WxErrorException {
+        wxCpService = WxCpConfiguration.getCpService(applicationid);
+        String str = wxCpService.get("https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_follow_user_list", "");
+        JSONObject obj = JSONObject.parseObject(str);
+        JSONArray arr = obj.getJSONArray("follow_user");
+
+        List<String> list = new ArrayList<>();
+        for (int i = 0; i < arr.size(); i++) {
+            String item = arr.get(i).toString();
+            list.add(item);
+        }
+        System.out.println(list.size());
+        return null;
+    }
+
+    /**
+     * 查询企业微信用户
+     */
+    public List<String> getUnassignedList() throws WxErrorException {
+        wxCpService = WxCpConfiguration.getCpService(applicationid);
+
+        int q = 20;
+        int w = 0;
+        List<String> list = new ArrayList<>();
+
+        String str = wxCpService.get("https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_unassigned_list", "{'page_id':" + q + ",'page_size':1000}");
+        JSONObject obj = JSONObject.parseObject(str);
+        JSONArray arr = obj.getJSONArray("info");
+
+        for (int i = 0; i < arr.size(); i++) {
+            JSONObject item = arr.getJSONObject(i);
+            list.add(item.toJSONString());
+        }
+
+
+        System.out.println(list.size());
+        return null;
+    }
+
     /**
      * 修改企业微信用户
      */

src/test/java/test/Test.java

@@ -5,6 +5,8 @@ import com.kiisoo.ic.app.IcApplication;
 import com.kiisoo.ic.common.utils.RedisUtil;
 import com.kiisoo.ic.employee.entity.PrivilageCpUserDO;
 import com.kiisoo.ic.employee.mapper.PrivilageCpUserDOMapper;
+import com.kiisoo.ic.employee.service.EmployeeService;
+import com.kiisoo.ic.job.count.CustomerCountJob;
 import com.kiisoo.ic.store.constant.Constants;
 import com.kiisoo.ic.store.entity.PoiStore;
 import com.kiisoo.ic.store.entity.PoiStoreStaff;
@@ -12,6 +14,8 @@ import com.kiisoo.ic.store.mapper.PoiStoreDOMapper;
 import com.kiisoo.ic.store.mapper.PoiStoreStaffDOMapper;
 import com.kiisoo.ic.store.service.StoreEmployeeService;
 import com.kiisoo.ic.wx.service.AddWXService;
+import com.kiisoo.ic.wx.service.QWMailListManageService;
+import me.chanjar.weixin.common.error.WxErrorException;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -154,11 +158,32 @@ public class Test {
     @Autowired
     private RedisUtil redisUtil;
 
+    @Autowired
+    private EmployeeService employeeService;
+
+    @org.junit.Test
+    public void test7() throws Exception {
+
+        employeeService.syncUser();
+
+    }
+
+    @Autowired
+    private CustomerCountJob customerDataJob;
+
     @org.junit.Test
-    public void test7(){
-        //
+    public void test8() throws Exception {
+        customerDataJob.handle(true,null);
+    }
+
 
-//        redisUtil.hget();
 
+    @Autowired
+    private QWMailListManageService qwMailListManageService;
+
+    @org.junit.Test
+    public void test9() throws WxErrorException {
+//        qwMailListManageService.syncUserNew();
+        qwMailListManageService.getUnassignedList();
     }
 }