package com.hx.mp.util;
|
|
import com.hx.util.StringUtils;
|
import com.hz.util.http.HttpHzUtil;
|
import com.hz.util.http.dto.HttpHzResponse;
|
import net.sf.json.JSONArray;
|
import net.sf.json.JSONException;
|
import net.sf.json.JSONObject;
|
import org.apache.commons.io.IOUtils;
|
|
import java.io.OutputStream;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
import java.util.List;
|
|
/**
|
* 企业微信客户工具
|
*/
|
public class CorpMpClientUtil {
|
|
/**
|
* 生成联系我按钮参数的链接（生成config_id）
|
*/
|
public static final String CREATE_CONTACT_ID_URL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/add_contact_way?access_token=";
|
/**
|
* 获取企业客户详情链接
|
*/
|
public static final String GET_CLIENT_DETAIL_URL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get";
|
/**
|
* 获取获取企业标签库链接
|
*/
|
public static final String GET_CORP_TAG_LIST = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_corp_tag_list?access_token=";
|
/**
|
* 添加客户联系人标签
|
*/
|
public static final String ADD_TAG = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/add_corp_tag?access_token=";
|
/**
|
* 编辑企业客户标签
|
*/
|
public static final String EDIT_TAG = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/edit_corp_tag?access_token=";
|
/**
|
* 删除客户联系人标签
|
*/
|
public static final String DEL_TAG = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/del_corp_tag?access_token=";
|
/**
|
* 客户关联企业微信的标签url
|
*/
|
public static final String RELATION_TAG = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/mark_tag?access_token=";
|
|
/**
|
* 获取员工客户列表url
|
*/
|
public static final String EXTERNAL_CONTACT_LIST = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/list";
|
|
/**
|
* 创建获客链接url
|
*/
|
public static final String CUSTOMER_ACQUISITION_CREATE_LINK = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_acquisition/create_link?access_token=";
|
|
/**
|
* 获取获客客户列表
|
*/
|
public static final String CUSTOMER_ACQUISITION_CUSTOMER_LIST = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_acquisition/customer?access_token=";
|
|
/**
|
* 获取配置过客户群管理的客户群列表
|
*/
|
public static final String GROUP_CHAT_LIST = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/groupchat/list?access_token=";
|
|
|
/**
|
* 通过客户群ID，获取详情。包括群名、群成员列表、群成员入群时间、入群方式。（客户群是由具有客户群使用权限的成员创建的外部群）
|
*/
|
public static final String GROUP_CHAT_DETAIL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/groupchat/get?access_token=";
|
|
/**
|
* 企业微信发送普通邮件
|
*/
|
public static final String GROUP_SENT_EMAIL = "https://qyapi.weixin.qq.com/cgi-bin/exmail/app/compose_send?access_token=";
|
|
|
|
/**
|
* 生成企业成员联系我的id-单人
|
*
|
* @param accessToken 企业的accessToken
|
* @param userId 企业成员的userId
|
* @param state 企业自定义的state参数，用于区分不同的添加渠道，在调用“获取外部联系人详情”时会返回该参数值，不超过30个字符
|
* @param remark 联系方式的备注信息，用于助记，不超过30个字符
|
* @return 返回
|
*/
|
public static JSONObject createContactId(String accessToken, String userId, String state, String remark) {
|
|
String configId = null;
|
JSONObject data = new JSONObject();
|
data.put("type", 1);
|
data.put("scene", 1);
|
data.put("state", state);
|
data.put("remark", remark);
|
JSONArray userIds = new JSONArray();
|
userIds.add(userId);
|
data.put("user", userIds);
|
|
//请求，返回格式
|
/*{
|
"errcode": 0,
|
"errmsg": "ok",
|
"config_id":"42b34949e138eb6e027c123cba77fAAA"
|
}*/
|
|
return HttpURLUtil(CREATE_CONTACT_ID_URL + accessToken, data.toString());
|
}
|
|
/**
|
* 获取客户列表
|
* @param accessToken 企业的accessToken
|
* @param userId 企业成员的userId
|
* @return 返回
|
*/
|
public static JSONObject getExternalContactList(String accessToken, String userId) {
|
return HttpURLUtil(EXTERNAL_CONTACT_LIST + "?access_token=" + accessToken + "&userid=" + userId, null);
|
}
|
|
/**
|
* 获取企业客户详情信息
|
*
|
* @param accessToken 企业的accessToken
|
* @param externalUserId 外部人员的userId
|
* @return 返回
|
*/
|
public static JSONObject getClientData(String accessToken, String externalUserId) {
|
return HttpURLUtil(GET_CLIENT_DETAIL_URL + "?access_token=" + accessToken + "&external_userid=" + externalUserId, null);
|
}
|
|
/**
|
* 企业可通过此接口获取企业客户标签详情
|
*
|
* @param accessToken 企业的accessToken
|
* @param tagId 标签id
|
* @param groupId 标签组id
|
* @return 返回
|
*/
|
public static JSONObject getCorpTagList(String accessToken, JSONArray tagId, JSONArray groupId) {
|
JSONObject data = new JSONObject();
|
data.put("tag_id", tagId);
|
data.put("group_id", groupId);
|
return HttpURLUtil(GET_CORP_TAG_LIST + accessToken, data.toString());
|
}
|
|
/**
|
* 添加客户联系人标签，
|
* 如果要向指定的标签组下添加标签，需要填写group_id参数；如果要创建一个全新的标签组以及标签，
|
* 则需要通过group_name参数指定新标签组名称，如果填写的groupname已经存在，则会在此标签组下新建标签
|
*
|
* @param accessToken 企业的accessToken
|
* @param groupId 组id（组名称和组id必填一个）
|
* @param groupName 组名称 组名称和组id必填一个）
|
* @param groupOrder 组排序，不填默认企业微信生成规则
|
* @param tagArray 数组，格式：[{ "name": "TAG_NAME_1", "order": 1 }]
|
* @return 返回
|
*/
|
public static JSONObject addTable(String accessToken, String groupId, String groupName, String groupOrder, JSONArray tagArray) {
|
JSONObject data = new JSONObject();
|
data.put("group_id", groupId);
|
data.put("group_name", groupName);
|
data.put("order", groupOrder);
|
data.put("tag", tagArray);
|
return HttpURLUtil(ADD_TAG + accessToken, data.toString());
|
}
|
|
/**
|
* 编辑企业客户标签，
|
* 注意:修改后的标签组不能和已有的标签组重名，标签也不能和同一标签组下的其他标签重名。
|
*
|
* @param accessToken 企业的accessToken
|
* @param id 标签或标签组的id
|
* @param name 新的标签或标签组名称，最长为30个字符
|
* @param order 标签/标签组的次序值。order值大的排序靠前。有效的值范围是[0, 2^32)
|
* @return 返回
|
*/
|
public static JSONObject editTable(String accessToken, String id, String name, String order) {
|
JSONObject data = new JSONObject();
|
data.put("id", id);
|
data.put("name", name);
|
data.put("order", order);
|
return HttpURLUtil(EDIT_TAG + accessToken, data.toString());
|
}
|
|
/**
|
* 删除客户联系人标签
|
* groupArr和tagArr不可同时为空。
|
* 如果一个标签组下所有的标签均被删除，则标签组会被自动删除。
|
*
|
* @param accessToken 企业的accessToken
|
* @param groupArr 组id数组
|
* @param tagArr 标签id数组
|
* @return 返回
|
*/
|
public static JSONObject delTable(String accessToken, JSONArray groupArr, JSONArray tagArr) {
|
JSONObject data = new JSONObject();
|
data.put("tag_id", tagArr);
|
data.put("group_id", groupArr);
|
return HttpURLUtil(DEL_TAG + accessToken, data.toString());
|
}
|
|
/**
|
* 客户关联企业微信的标签
|
* 注意：请确保external_userid是userid的外部联系人。
|
* add_tag和remove_tag不可同时为空。
|
*
|
* @param accessToken 企业的accessToken
|
* @param userId 企业成员的userid
|
* @param externalUserId 外部联系人的id
|
* @param addTag 新增的标签id（企业标签的id）数组
|
* @param removeTag 删除的标签id（企业标签的id）数组
|
* @return 返回
|
*/
|
public static JSONObject relationTag(String accessToken, String userId, String externalUserId, JSONArray addTag, JSONArray removeTag) {
|
JSONObject data = new JSONObject();
|
data.put("userid", userId);
|
data.put("external_userid", externalUserId);
|
data.put("add_tag", addTag);
|
data.put("remove_tag", removeTag);
|
return HttpURLUtil(RELATION_TAG + accessToken, data.toString());
|
}
|
|
/**
|
* 请求http协议 获取信息工具
|
**/
|
public static JSONObject HttpURLUtil(String url, String data) {
|
HttpURLConnection con = null;
|
URL u = null;
|
String wxMsgXml = null;
|
JSONObject obj = null;
|
try {
|
u = new URL(url);
|
con = (HttpURLConnection) u.openConnection();
|
con.setRequestMethod("POST");
|
con.setDoOutput(true);
|
con.setDoInput(true);
|
con.setUseCaches(false);
|
con.setReadTimeout(5000);
|
con.setRequestProperty("Charset", "UTF-8");
|
con.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
|
|
if (data != null) {
|
OutputStream os = con.getOutputStream();
|
os.write(data.getBytes("utf-8"));
|
}
|
|
if (con.getResponseCode() != 200)
|
throw new RuntimeException("请求url失败");
|
// 读取返回内容
|
wxMsgXml = IOUtils.toString(con.getInputStream(), "utf-8");
|
obj = JSONObject.fromObject(wxMsgXml);
|
// //System.out.println("HttpURLUtil:"+wxMsgXml);
|
} catch (Exception e) {
|
e.printStackTrace();
|
obj = new JSONObject();
|
try {
|
obj.put("status", 1);
|
obj.put("errMsg", e.getMessage());
|
} catch (JSONException e1) {
|
e1.printStackTrace();
|
}
|
} finally {
|
if (con != null) {
|
con.disconnect();
|
}
|
}
|
return obj;
|
}
|
|
/**生成企业成员联系我的id-单人
|
* @param accessToken 企业的accessToken
|
* @param userId 企业成员的userId
|
* @param scene 场景，1-在小程序中联系，2-通过二维码联系
|
* @param state 企业自定义的state参数，用于区分不同的添加渠道，在调用“获取外部联系人详情”时会返回该参数值，不超过30个字符
|
* @param remark 联系方式的备注信息，用于助记，不超过30个字符
|
* @return 返回
|
*/
|
public static JSONObject createContactId(String accessToken,String userId,int scene,String state,String remark){
|
String configId = null;
|
JSONObject data = new JSONObject();
|
data.put("type",1);
|
data.put("scene",scene);
|
data.put("state",state);
|
data.put("remark",remark);
|
JSONArray userIds = new JSONArray();
|
userIds.add(userId);
|
data.put("user",userIds);
|
|
//请求，返回格式
|
/*{
|
"errcode": 0,
|
"errmsg": "ok",
|
"config_id":"42b34949e138eb6e027c123cba77fAAA"
|
}*/
|
|
return HttpURLUtil(CREATE_CONTACT_ID_URL+accessToken,data.toString());
|
}
|
|
/**
|
* 创建获客链接
|
*
|
* @param accessToken 企业的accessToken
|
* @param linkName 链接名称
|
* @param userList 员工用户userId
|
* @return 返回
|
*/
|
public static JSONObject createCustomerAcquisitionLink(String accessToken, String linkName, JSONArray userList) {
|
JSONObject data = new JSONObject();
|
data.put("link_name", linkName);
|
JSONObject subData = new JSONObject();
|
subData.accumulate("user_list", userList);
|
data.put("range", subData);
|
/** 返回数据
|
* {
|
* "link_id":"LINK_ID",
|
* "link_name":"获客链接1号",
|
* "range":
|
* {
|
* "user_list":["zhangsan","lisi"],
|
* "department_list":[2,3]
|
* },
|
* "skip_verify":true
|
* }
|
*/
|
return HttpURLUtil(CUSTOMER_ACQUISITION_CREATE_LINK + accessToken, data.toString());
|
}
|
|
/**
|
* 获取获客客户列表
|
*
|
* @param accessToken 企业的accessToken
|
* @param linkId 链接id
|
* @param cursor 分页游标
|
* @return 返回
|
*/
|
public static JSONObject getCustomerAcquisitionCustomerList(String accessToken, String linkId, String cursor) {
|
JSONObject data = new JSONObject();
|
data.put("link_id", linkId);
|
data.put("limit", 1000);
|
// 分页游标
|
if (!StringUtils.isEmpty(cursor)) {
|
data.put("cursor", cursor);
|
}
|
/** 返回数据
|
* {
|
* "errcode": 0,
|
* "errmsg": "ok",
|
* "customer_list":
|
* [
|
* {
|
* "external_userid":"woAJ2GCAAAXtWyujaWJHDDGi0mACAAA",
|
* "userid":"zhangsan",
|
* "chat_status":0,
|
* "state":"CHANNEL_A"
|
* }
|
* ],
|
* "next_cursor":"CURSOR"
|
* }
|
*/
|
return HttpURLUtil(CUSTOMER_ACQUISITION_CUSTOMER_LIST + accessToken, data.toString());
|
}
|
|
|
/**
|
* 该接口用于获取配置过客户群管理的客户群列表。
|
*
|
* @param accessToken 企业的accessToken
|
* @param statusFilter 客户群跟进状态过滤。0 - 所有列表(即不过滤) 1 - 离职待继承 2 - 离职继承中 3 - 离职继承完成
|
* @param userIdList 群主过滤 如果不填，表示获取应用可见范围内全部群主的数据可见范围人数超过1000人，为了防止数据包过大，会报错 81017 用户ID列表。最多100个
|
* @param cursor 分页下标
|
* @param limit 列表
|
* @return 返回
|
*/
|
public static HttpHzResponse getGroupChatList(String accessToken, Integer statusFilter, List<String> userIdList, String cursor, Integer limit) {
|
JSONObject bodyData = new JSONObject();
|
bodyData.put("status_filter", statusFilter);
|
//分页下标
|
if (StringUtils.noNull(cursor)) {
|
bodyData.put("cursor", cursor);
|
}
|
//默认100条
|
if (limit == null) {
|
limit = 100;
|
}
|
bodyData.put("limit", limit);
|
//过滤
|
if (userIdList != null && userIdList.size() > 0) {
|
JSONObject filter = new JSONObject();
|
filter.put("userid_list", userIdList);
|
bodyData.put("owner_filter", filter);
|
}
|
return HttpHzUtil.HttpURLUtilJson(GROUP_CHAT_LIST + accessToken, bodyData.toString(), null, null, "GET", null);
|
}
|
|
/**
|
* 通过客户群ID，获取详情。包括群名、群成员列表、群成员入群时间、入群方式。（客户群是由具有客户群使用权限的成员创建的外部群）
|
*
|
* @param chatId 客户群ID
|
* @param needName 是否需要返回群成员的名字0-不返回；1-返回
|
*/
|
public static HttpHzResponse getGroupChatDetail(String accessToken, String chatId, Integer needName) {
|
JSONObject bodyData = new JSONObject();
|
bodyData.put("chat_id", chatId);
|
if (needName == null) {
|
needName = 0;
|
}
|
bodyData.put("need_name", needName);
|
return HttpHzUtil.HttpURLUtilJson(GROUP_CHAT_DETAIL + accessToken, bodyData.toString(), null, null, "GET", null);
|
}
|
|
/**
|
* 企业微信发送普通邮件
|
* 接口地址: https://developer.work.weixin.qq.com/document/path/97445
|
* @param bodyData 参数
|
*/
|
public static JSONObject sentEmail(String accessToken, JSONObject bodyData) {
|
return HttpURLUtil(GROUP_SENT_EMAIL + accessToken, bodyData.toString());
|
}
|
}
|
