查看 | 历史 | 提交 | 提交对比
chenjiahe
2022-03-31 b5bfe58beeeeb8343bdea6a9412f8f6704b67633
提交 | 用户 | age
5c5945 1 package com.hx.mp.util;
E 2
3 import net.sf.json.JSONArray;
4 import net.sf.json.JSONException;
5 import net.sf.json.JSONObject;
6 import org.apache.commons.io.IOUtils;
7
8 import java.io.OutputStream;
9 import java.net.HttpURLConnection;
10 import java.net.URL;
11 import java.text.MessageFormat;
12
13 /**
14  * 企业微信客户工具
15  */
16 public class CorpMpClientUtil {
17
18    /**生成联系我按钮参数的链接（生成config_id）*/
19    public static final String CREATE_CONTACT_ID_URL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/add_contact_way?access_token=";
20    /**获取企业客户详情链接*/
21    public static final String GET_CLIENT_DETAIL_URL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get";
22    /**添加客户联系人标签*/
23    public static final String ADD_TAG = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/add_corp_tag?access_token=";
24    /**删除客户联系人标签*/
25    public static final String DEL_TAG = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/del_corp_tag?access_token=";
26    /**客户关联企业微信的标签url*/
27    public static final String RELATION_TAG = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/mark_tag?access_token=";
28
29
30     /**生成企业成员联系我的id-单人
31      * @param accessToken 企业的accessToken
32      * @param userId 企业成员的userId
33      * @param state 企业自定义的state参数，用于区分不同的添加渠道，在调用“获取外部联系人详情”时会返回该参数值，不超过30个字符
34      * @param remark 联系方式的备注信息，用于助记，不超过30个字符
35      * @return
36      */
37    public static JSONObject createContactId(String accessToken,String userId,String state,String remark){
38
39        String configId = null;
40        JSONObject data = new JSONObject();
41        data.put("type",1);
42        data.put("scene",1);
43        data.put("state",state);
44        data.put("remark",remark);
45        JSONArray userIds = new JSONArray();
46        userIds.add(userId);
47        data.put("user",userIds);
48
49        //请求，返回格式
50        /*{
51            "errcode": 0,
52                "errmsg": "ok",
53                "config_id":"42b34949e138eb6e027c123cba77fAAA"　　
54        }*/
55
56        return HttpURLUtil(CREATE_CONTACT_ID_URL+accessToken,data.toString());
57    }
58
59     /**获取企业客户详情信息
60      * @param accessToken 企业的accessToken
61      * @param externalUserId 外部人员的userId
62      * @return
63      */
64    public static JSONObject getClientData(String accessToken,String externalUserId){
65
66        return HttpURLUtil(GET_CLIENT_DETAIL_URL+"?access_token="+accessToken+"&external_userid="+externalUserId,null);
67    }
68
69     /** 添加客户联系人标签，
70      *如果要向指定的标签组下添加标签，需要填写group_id参数；如果要创建一个全新的标签组以及标签，
71      *则需要通过group_name参数指定新标签组名称，如果填写的groupname已经存在，则会在此标签组下新建标签
72      * @param accessToken 企业的accessToken
73      * @param groupId 组id（组名称和组id必填一个）
74      * @param groupName 组名称 组名称和组id必填一个）
75      * @param groupOrder 组排序，不填默认企业微信生成规则
76      * @param tagArray 数组，格式：[{ "name": "TAG_NAME_1", "order": 1 }]
77      * @return
78      */
79    public static JSONObject addTable(String accessToken,String groupId,String groupName,String groupOrder,JSONArray tagArray){
80        JSONObject data = new JSONObject();
81        data.put("group_id",groupId);
82        data.put("group_name",groupName);
83        data.put("order",groupOrder);
84        data.put("tag",tagArray);
85        return HttpURLUtil(ADD_TAG+accessToken,data.toString());
86    }
87
88     /**删除客户联系人标签
89      * groupArr和tagArr不可同时为空。
90      * 如果一个标签组下所有的标签均被删除，则标签组会被自动删除。
91      * @param accessToken 企业的accessToken
92      * @param groupArr 组id数组
93      * @param tagArr 标签id数组
94      * @return
95      */
96    public static JSONObject delTable(String accessToken,JSONArray groupArr,String tagArr){
97        JSONObject data = new JSONObject();
98        data.put("tag_id",tagArr);
99        data.put("group_id",groupArr);
100        return HttpURLUtil(DEL_TAG+accessToken,data.toString());
101    }
102
103     /**
104      * 客户关联企业微信的标签
105      * 注意：请确保external_userid是userid的外部联系人。
106      * add_tag和remove_tag不可同时为空。
107      * @param accessToken 企业的accessToken
108      * @param userId 企业成员的userid
109      * @param externalUserId 外部联系人的id
110      * @param addTag 新增的标签id（企业标签的id）数组
111      * @param removeTag 删除的标签id（企业标签的id）数组
112      * @return
113      */
114     public static JSONObject relationTag(String accessToken,String userId,String externalUserId
115             ,JSONArray addTag,JSONArray removeTag){
116         JSONObject data = new JSONObject();
117         data.put("userid",userId);
118         data.put("external_userid",externalUserId);
119         data.put("add_tag",addTag);
120         data.put("remove_tag",removeTag);
121         return HttpURLUtil(RELATION_TAG+accessToken,data.toString());
122     }
123
124
125     /** 请求http协议 获取信息工具 **/
126     public static JSONObject HttpURLUtil(String url, String data) {
127         HttpURLConnection con = null;
128         URL u = null;
129         String wxMsgXml = null;
130         JSONObject obj = null;
131         try {
132             u = new URL(url);
133             con = (HttpURLConnection) u.openConnection();
134             con.setRequestMethod("POST");
135             con.setDoOutput(true);
136             con.setDoInput(true);
137             con.setUseCaches(false);
138             con.setReadTimeout(5000);
139             con.setRequestProperty("Charset", "UTF-8");
140             con.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
141
142             if (data != null) {
143                 OutputStream os = con.getOutputStream();
144                 os.write(data.getBytes("utf-8"));
145             }
146
147             if (con.getResponseCode() != 200)
148                 throw new RuntimeException("请求url失败");
149             // 读取返回内容
150             wxMsgXml = IOUtils.toString(con.getInputStream(), "utf-8");
151             obj = JSONObject.fromObject(wxMsgXml);
152             // //System.out.println("HttpURLUtil:"+wxMsgXml);
153         } catch (Exception e) {
154             e.printStackTrace();
155             obj = new JSONObject();
156             try {
157                 obj.put("status", 1);
158                 obj.put("errMsg", e.getMessage());
159             } catch (JSONException e1) {
160                 e1.printStackTrace();
161             }
162         } finally {
163             if (con != null) {
164                 con.disconnect();
165             }
166         }
167         return obj;
168     }
169 }