企微提取用户unionid

jQGCPeAbH · 发表于 2022-12-30 14:58:38

媒介

营业需要需要按照提炼企业微疑统统职工所具有客户也即是提炼unionid 特此写个一站式东西类一次性天生

pom

<dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.73</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.12</version><scope>provided</scope></dependency>

复造代码

东西类

package ins.platfrom.test;import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONObject;import ins.platfrom.dao.WXUserVoMapper;import lombok.extern.slf4j.Slf4j;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Service;import org.springframework.web.client.RestTemplate;import java.util.*;/**
* 企微职工所绑定用户提炼
* @author zhangle
* @create 2021-04-21 10:41
*/@Slf4j@ServicepublicclassQiWeiTest{/**
* 微疑token大众变质
*/private String access_token;/**
* HTTP线程池那个假设需要代办署理需要设置瞅尔专客
* https://blog.csdn.net/HezhezhiyuLe/article/details/92395041
*/@Autowiredprivate RestTemplate bean;/**
* 终极得到用户疑息保留交心自界说不必简略
*/@Autowiredprivate WXUserVoMapper wxUserVoMapper;/**
* corpid corpsecret 挖自己的公司
* 获得token get
* https://work.weixin.qq.com/api/doc/90000/90135/91039 参照文档
*/privatefinal String tokenurl ="https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=10086&corpsecret=10010";/**
* 获得部分 post 可简略ID 没有挖默认推与目前权力下看来部分
* https://work.weixin.qq.com/api/doc/90000/90135/90208
*/private String depturl ="https://qyapi.weixin.qq.com/cgi-bin/department/list?access_token=";/**
* 批质获得客户概略 post
* https://work.weixin.qq.com/api/doc/90000/90135/92994
*/private String userurl ="https://qyapi.weixin.qq.com/cgi-bin/externalcontact/batch/get_by_user?access_token=";/**
* 企微目前最下权力获得部分统统成员 department_id=1 fetch_child=1 递回 =0目前部分
* https://work.weixin.qq.com/api/doc/90000/90135/90200
*/private String deptuserurl ="https://qyapi.weixin.qq.com/cgi-bin/user/simplelist?fetch_child=1&department_id=";/**
* 1
* 获得企微token
* @return token
*/public String getToken(){
String tokenstr = bean.getForEntity(tokenurl, String.class).getBody();
log.info("获得token:"+tokenstr);
JSONObject tokenjson =parseStr(tokenstr);
access_token=tokenjson.get("access_token").toString();return access_token;}/**
* 0
*/publicvoidstart(){//获得token
access_token=getToken();//得到女节面
Set<String> treeDept =findTreeDept();if(treeDept==null||treeDept.size()==0){
log.info("盘问部分为空");return;}//迭代女节面for(String deptparent : treeDept){//女节面下统统职工递回
Set<String> deptUserByDId =findDeptUserByDId(deptparent);int unionidByUserId =findUnionidByUserId(deptUserByDId);
log.info("目前"+deptparent+"部分职工客户人数："+unionidByUserId);}}/**
* 2
* 获得目前企微最下节面部分ID
* 当自己没有是目前公家号最下权力即不成以检察统统部分时使用
* @return 最下女节面
*/public Set<String>findTreeDept(){
String deptstr = bean.getForEntity(depturl+access_token, String.class).getBody();
deptstr=iflegal(deptstr);if(deptstr==null||"".equals(deptstr)){
log.info("获得部分失利");return null;}
JSONObject jsonObject =parseStr(deptstr);//获得统统部分
String dept = jsonObject.get("department").toString();
List<JSONObject> departments = JSON.parseArray(dept, JSONObject.class);returnrecursiondept(departments);}/**
* 鉴别微疑交心前去可否正当
* @param resp
* @return
*/public String iflegal(String resp){if(resp.contains(""errcode":0")){return resp;}
log.info("得敗預警："+resp);if(resp.contains(""errcode":40014")||resp.contains(" "errcode":42001")){getToken();
log.info("规复："+access_token);}return null;}/**
* 变换企微前去数据为json工具
* @param str
* @return
*/public JSONObject parseStr(String str){return JSON.parseObject(str);}/**
* 盘问部分女ID
* @param departments以后企微权力下统统部分包括女子级
* @return 最下女节面
*/public Set<String>recursiondept(List<JSONObject> departments){
Set<String> deptid =newHashSet<>();
Set<String> treedept =newHashSet<>();for(JSONObject department : departments){
deptid.add(department.getString("id"));}for(JSONObject department : departments){
String parentid = department.getString("parentid");//找没有到女ID即为最下节面if(!deptid.contains(parentid)){
treedept.add(department.getString("id"));}}return treedept;}/**
* 3
* 颠末部分ID盘问目前部分职工递回获得目前部分统统职工
* @param deptId 部分ID
* @return
*/public Set<String>findDeptUserByDId(String deptId){//获得目前部分下的统统职工包罗子节面
String deptuserstr = bean.getForEntity(deptuserurl+deptId+"&access_token="+access_token, String.class).getBody();
deptuserstr=iflegal(deptuserstr);if(deptuserstr==null||"".equals(deptuserstr)){
log.info("获得部分成员失利");return null;}
JSONObject jsonObject =parseStr(deptuserstr);
String dept = jsonObject.get("userlist").toString();
List<JSONObject> departments = JSON.parseArray(dept, JSONObject.class);if(departments==null||departments.size()==0){return null;}//来沉
Set<String> userids =newHashSet<>();for(JSONObject department : departments){
userids.add(department.getString("userid"));}
log.info("用户ID总额："+userids.size());return userids;}/**
* 4
* 企微职工颠末职工ID查找用户unionid
* @param userids以后部分统统职工
* @return
*/publicintfindUnionidByUserId(Set<String> userids){//用户unionid汇合统统用户包括重复假设女级部分仄止有多个用户可以会重复倡议把职员再次汇总尔是因为肯定女级只需一个有最年夜权力才这样写int count=0;int size = userids.size();//来沉总用户（一个客户减了N个职工）那个保存值多少十万出成就 SQL写对于减主键一把便胜利
Set<String> unionids =newHashSet<>();int formum=0;for(String userid : userids){
formum++;if(formum%1000==0){
log.info("轮回到："+formum+"/"+unionids.size()+"/"+size);}//及时革新token避免生效
Set<String> personnelUsers =handleUserByUserId(userid,userurl+access_token);
unionids.addAll(personnelUsers);
count+=personnelUsers.size();}//用户unionid汇合有值便保留能够按照营业需要自止决定保存 IO SQL
ArrayList<String> unionidarr =newArrayList<>();for(String unionid : unionids){
unionidarr.add(unionid);//按照自己数据库才气分批次拔出一次拔出多少十万简单IO溢出if(unionidarr.size()==1000){
Integer insertnum = wxUserVoMapper.insertQiWei(unionidarr);
log.info(insertnum+"");
unionidarr.clear();}}if(unionidarr.size()>0){
Integer insertnum = wxUserVoMapper.insertQiWei(unionidarr);
log.info(insertnum+"");}
log.info(" 职工总用户数："+unionids.size()+"穿插成果散："+count);return unionids.size();}/**
*处置单个用户所具有的局部客户
* @param userid 用户ID
* @param url 及时链交
* @return
*/public Set<String>handleUserByUserId(String userid,String url){
Set<String> unionids =newHashSet<>();
Map<String, Object> params =newHashMap<>();
params.put("userid",userid);//企微最年夜分页质
params.put("limit",100);
String openid ="";//启顶值一个职工10W用户for(int i =0; i <1000; i++){
params.put("cursor",openid);
String resp = bean.postForEntity(url, params, String.class).getBody();
resp=iflegal(resp);if(resp == null ||"".equals(resp)){
log.info("分歧法前去:"+userid);break;}if(i==999){
log.info("职工用户超限："+userid);}
JSONObject jsonObject =parseStr(resp);//职工客户列表
List<JSONObject> external_contact_list = JSON.parseArray(jsonObject.get("external_contact_list").toString(), JSONObject.class);if(external_contact_list==null||external_contact_list.size()==0){break;}for(JSONObject customer : external_contact_list){
String external_contact = customer.getString("external_contact");if(external_contact==null||"".equals(external_contact)){break;}//用户大略概略
JSONObject customercontact =parseStr(external_contact);if(customercontact==null){break;}// 能够拿到客户微疑名 name 头像 avatar 性别 gender 标记 unionid 范例 type更多概略需要换链交
String unionid = customercontact.getString("unionid");if(unionid!=null&&!"".equals(unionid)){
unionids.add(unionid);}}
String next_cursor = jsonObject.getString("next_cursor");if("".equals(next_cursor)){break;}else{//迭代
openid=next_cursor;}}return unionids;}}