diff --git a/src/main/java/com/kiisoo/ic/wx/service/QWMailListManageService.java b/src/main/java/com/kiisoo/ic/wx/service/QWMailListManageService.java index 59606ee..31adf06 100644 --- a/src/main/java/com/kiisoo/ic/wx/service/QWMailListManageService.java +++ b/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 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 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 getUnassignedList() throws WxErrorException { + wxCpService = WxCpConfiguration.getCpService(applicationid); + + int q = 20; + int w = 0; + List 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; + } + /** * 修改企业微信用户 */ diff --git a/src/test/java/test/Test.java b/src/test/java/test/Test.java index e28363d..19a065c 100644 --- a/src/test/java/test/Test.java +++ b/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(); } }