IT评测·应用市场-qidao123.com技术社区

标题: Java企业微敬佩务商代开辟获取AccessToken示例 [打印本页]

---

作者: 祗疼妳一个    时间: 2024-8-6 02:46
标题: Java企业微敬佩务商代开辟获取AccessToken示例
这里主要针对的是企业微敬佩务商代开辟模式 文档地点

可以看到内里大致有三种token，一个是服务商的token，一个是企业授权token，另有一个是应用的token
这内里主要有下面几个参数
首先是服务商的 corpid 和 provider_secret ，这个可以在 应用管理-通用开辟参数 内里查察

然后是企业的 corpid 和企业的永久授权码 permanent_code ，这两个是必要在企业授权的的时候通过回调获取的，具体请参考官方文档 获取永久授权码
最后就是应用的 suite_id 和 suite_secret 还必要一个 suite_ticket ，前面两个在应用信息内里就可以看到，suite_ticket 这个也是必要通过回调获取 ，具体参考官方文档 推送suite_ticket

拿到这些参数后就好说了，剩下的都是调接口
直接上代码

1. import com.alibaba.fastjson.JSON;
2. import com.alibaba.fastjson.JSONObject;
3. import com.qyzj.common.base.exception.BusinessException;
4. import com.qyzj.common.base.util.HttpsRequestUtil;
5. import com.qyzj.common.redis.constant.CacheKey;
6. import com.qyzj.common.redis.util.RedisUtil;
7. import com.qyzj.service.task.constant.WeiXinProviderConst;
8. import com.qyzj.service.task.constant.WeixinCorpKeyConst;
9. import com.qyzj.service.task.constant.WeixinCorpUrlConst;
10. import lombok.extern.java.Log;
11. import org.springframework.beans.factory.annotation.Autowired;
12. import org.springframework.stereotype.Component;
14. /**
15. * @author Sakura
16. * @date 2024/7/2 11:48
17. */
18. @Component
19. @Log
20. public class WxTokenUtil {
22.     @Autowired
23.     private RedisUtil redisUtil;
25.     // 获取服务商token
26.     // 这里有一个问题，企业微信本身可能会使token提前失效，所以有时需要强制重新获取token，详情见官方文档
27.     // https://developer.work.weixin.qq.com/document/path/91200
28.     // 所以此处加了一个cache用来判断是否需要走缓存拿token，正常情况默认走缓存即可
29.     public String getProviderAccessToken(Boolean cache) {
30.         try {
31.             // 如果Redis里面有则直接取Redis里面的
32.             if (cache &&redisUtil.hasKey(CacheKey.KEY_CORP_PROVIDER_ACCESS_TOKEN)) {
33.                 return redisUtil.get(CacheKey.KEY_CORP_PROVIDER_ACCESS_TOKEN).toString();
34.             }
36.             // 封装请求参数
37.             JSONObject json = new JSONObject();
38.             json.put("corpid", WeiXinProviderConst.corpId);
39.             json.put("provider_secret", WeiXinProviderConst.providerSecret);
41.             // 请求微信接口
42.             String accessTokenStr = HttpsRequestUtil.sendPostRequest(WeixinCorpUrlConst.PROVIDER_ACCESS_TOKEN, json.toJSONString());
43.             log.info("get provider access token return :" + accessTokenStr);
44.             JSONObject accessTokenJson = JSON.parseObject(accessTokenStr);
45.             // 获取 access_token
46.             String accessToken = accessTokenJson.getString(WeixinCorpKeyConst.providerAccessToken);
47.             //官方 expires_in 为 2个小时, 这里设置100分钟
48.             redisUtil.set(CacheKey.KEY_CORP_PROVIDER_ACCESS_TOKEN, accessToken, CacheKey.expireTime100);
50.             return accessToken;
51.         } catch (Exception e) {
52.             log.info("get provider access token error");
53.             e.printStackTrace();
54.             throw new BusinessException("get provider access token error");
55.         }
56.     }
58.     // 获取企业授权token
59.     public String getCorpAccessToken(String corpId, String permanentCode) {
60.         try {
61.             // 如果Redis里面有则直接取Redis里面的
62.             if (redisUtil.hasKey(CacheKey.KEY_CORP_ACCESS_TOKEN + "_" + corpId)) {
63.                 return redisUtil.get(CacheKey.KEY_CORP_ACCESS_TOKEN + "_" + corpId).toString();
64.             }
65.             String accessTokenUrl = WeixinCorpUrlConst.CORP_ACCESS_TOKEN
66.                     .replace("#{CORP_ID}", corpId)
67.                     .replace("#{CORP_SECRET}", permanentCode);
68.             String accessTokenStr = HttpsRequestUtil.sendGetRequest(accessTokenUrl);
69.             log.info("get corp access token return :" + accessTokenStr);
70.             JSONObject accessTokenJson = JSON.parseObject(accessTokenStr);
71.             // 获取 access_token
72.             String accessToken = accessTokenJson.getString(WeixinCorpKeyConst.accessToken);
73.             //官方 expires_in 为 2个小时, 这里设置 100 分钟
74.             redisUtil.set(CacheKey.KEY_CORP_ACCESS_TOKEN + "_" + corpId, accessToken, CacheKey.expireTime100);
76.             return accessToken;
77.         } catch (Exception e) {
78.             log.info("get corp access token error");
79.             e.printStackTrace();
80.             throw new BusinessException("get corp access token error");
81.         }
82.     }
84.     // SuiteTicket是通过回调获取的，企微每10分钟会推送一次
85.     // 如果没有可手动在服务商企业微信后台刷新
86.     public String getSuiteTicket() {
87.         // 如果Redis里面有则直接取Redis里面的
88.         if (redisUtil.hasKey(CacheKey.KEY_CORP_SUITE_TICKET)) {
89.             return redisUtil.get(CacheKey.KEY_CORP_SUITE_TICKET).toString();
90.         } else {
91.             log.info("get suite ticket error");
92.             throw new BusinessException("get suite ticket error");
93.         }
95.     }
97.     // 获取应用token
98.     // 注意suiteTicket是从回调接口获取的
99.     // 注意该token需要配置ip白名单
100.     public String getSuiteAccessToken() {
101.         try {
102.             // 如果Redis里面有则直接取Redis里面的
103.             if (redisUtil.hasKey(CacheKey.KEY_SUITE_ACCESS_TOKEN)) {
104.                 return redisUtil.get(CacheKey.KEY_SUITE_ACCESS_TOKEN).toString();
105.             }
106.             // 封装请求参数
107.             JSONObject json = new JSONObject();
108.             json.put(WeixinCorpKeyConst.suiteId, WeiXinProviderConst.suiteId);
109.             json.put(WeixinCorpKeyConst.suiteSecret, WeiXinProviderConst.suiteSecret);
110.             json.put(WeixinCorpKeyConst.suiteTicket, getSuiteTicket());
112.             String accessTokenStr = HttpsRequestUtil.sendPostRequest(WeixinCorpUrlConst.SUITE_ACCESS_TOKEN, json.toJSONString());
113.             log.info("get suite access token return :" + accessTokenStr);
114.             JSONObject accessTokenJson = JSON.parseObject(accessTokenStr);
115.             //获取 accessToken
116.             String accessToken = accessTokenJson.getString(WeixinCorpKeyConst.suiteAccessToken);
117.             //官方 expires_in 为 2个小时, 这里设置 100分钟
118.             redisUtil.set(CacheKey.KEY_SUITE_ACCESS_TOKEN, accessToken, CacheKey.expireTime100);
120.             return accessToken;
121.         } catch (Exception e) {
122.             log.info("get suite access token error");
123.             e.printStackTrace();
124.             throw new BusinessException("get suite access token error");
125.         }
127.     }
128. }

复制代码

这内里用到的 HttpsRequestUtil 工具类

1. import java.io.*;
2. import java.net.HttpURLConnection;
3. import java.net.URL;
5. /**
6. * @author Sakura
7. * @date 2024/6/24 17:07
8. */
9. public class HttpsRequestUtil {
11.     public static String sendPostRequest(String urlString, String jsonInputString) throws IOException {
12.         URL url = new URL(urlString);
13.         HttpURLConnection connection = (HttpURLConnection) url.openConnection();
15.         // 设置请求方法为POST
16.         connection.setRequestMethod("POST");
18.         // 设置请求头
19.         connection.setRequestProperty("Content-Type", "application/json");
20.         connection.setRequestProperty("Accept", "application/json");
22.         // 启用输出流，用于发送请求数据
23.         connection.setDoOutput(true);
25.         try (OutputStream os = connection.getOutputStream()) {
26.             byte[] input = jsonInputString.getBytes("utf-8");
27.             os.write(input, 0, input.length);
28.         }
30.         // 获取响应
31.         try (BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream(), "utf-8"))) {
32.             StringBuilder response = new StringBuilder();
33.             String responseLine;
34.             while ((responseLine = br.readLine()) != null) {
35.                 response.append(responseLine.trim());
36.             }
37.             return response.toString();
38.         } finally {
39.             // 关闭连接
40.             connection.disconnect();
41.         }
42.     }
44.     public static String sendGetRequest(String urlString) throws IOException {
45.         URL url = new URL(urlString);
46.         HttpURLConnection connection = (HttpURLConnection) url.openConnection();
48.         // 设置请求方法为GET
49.         connection.setRequestMethod("GET");
51.         // 设置请求头
52.         connection.setRequestProperty("Accept", "application/json");
54.         // 获取响应
55.         try (BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream(), "utf-8"))) {
56.             StringBuilder response = new StringBuilder();
57.             String responseLine;
58.             while ((responseLine = br.readLine()) != null) {
59.                 response.append(responseLine.trim());
60.             }
61.             return response.toString();
62.         } finally {
63.             // 关闭连接
64.             connection.disconnect();
65.         }
66.     }
68. }

复制代码

另有企业微信的两个基本配置类

1. public class WeixinCorpUrlConst {
2.     /**
3.      * 获取 provider_access_token 的 url
4.      */
5.     public static final String PROVIDER_ACCESS_TOKEN = "https://qyapi.weixin.qq.com/cgi-bin/service/get_provider_token";
7.     /**
8.      * 获取 suite_access_token 的 url
9.      */
10.     public static final String SUITE_ACCESS_TOKEN = "https://qyapi.weixin.qq.com/cgi-bin/service/get_suite_token";
11.     /**
12.      * 获取 pre_auth_code 的 url
13.      */
14.     public static final String PRE_AUTH_CODE = "https://qyapi.weixin.qq.com/cgi-bin/service/get_pre_auth_code?suite_access_token=";
15.     /**
16.      * 前端授权页面 的 url
17.      */
18.     public static final String URL_AUTH_PAGE = "https://open.work.weixin.qq.com/3rdapp/install";
19.     /**
20.      * 前端登录页面 的 url
21.      */
22.     public static final String URL_LOGIN_PAGE = "https://open.work.weixin.qq.com/wwopen/sso/3rd_qrConnect";
23.     /**
24.      * 获取 permanent_code 的 url
25.      */
26.     public static final String PERMANENT_CODE = "https://qyapi.weixin.qq.com/cgi-bin/service/get_permanent_code?suite_access_token=";
27.     /**
28.      * 获取 企业授权 access_token 的 url
29.      */
30.     public static final String CORP_ACCESS_TOKEN = "https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=#{CORP_ID}&corpsecret=#{CORP_SECRET}";
31.     /**
32.      * 获取 企业应用 access_token 的 url
33.      */
34.     public static final String ACCESS_TOKEN = "https://qyapi.weixin.qq.com/cgi-bin/gettoken";
35.     /**
36.      * 获取 应用信息 的 url
37.      */
38.     public static final String AGENT_INFO = "https://qyapi.weixin.qq.com/cgi-bin/agent/get?access_token=#{ACCESS_TOKEN}&agentid=#{AGENT_ID}";
39.     /**
40.      * 获取 部门列表 的 url
41.      */
42.     public static final String DEPARTMENT_LIST = "https://qyapi.weixin.qq.com/cgi-bin/department/list?access_token=#{ACCESS_TOKEN}";
43.     /**
44.      * 获取 部门成员列表 的 url
45.      */
46.     public static final String USER_LIST = "https://qyapi.weixin.qq.com/cgi-bin/user/list?access_token=#{ACCESS_TOKEN}&department_id=#{DEPARTMENT_ID}&fetch_child=1";
47.     /**
48.      * 获取 成员信息 的 url
49.      */
50.     public static final String USER_INFO = "https://qyapi.weixin.qq.com/cgi-bin/user/get?access_token=#{ACCESS_TOKEN}&userid=#{USER_ID}";
52.     /**
53.      * 获取 企业管理员 的 url
54.      */
55.     public static final String ADMIN_USER_LIST = "https://qyapi.weixin.qq.com/cgi-bin/service/get_admin_list?suite_access_token=";
56.     /**
57.      * 第三方应用：获取 企业成员登录信息 的 url
58.      */
59.     public static final String PROVIDER_LOGIN_INFO = "https://qyapi.weixin.qq.com/cgi-bin/service/get_login_info?access_token=";
60.     /**
61.      * 自建应用：获取 企业成员登录信息 的 url
62.      */
63.     public static final String LOCAL_LOGIN_INFO = "https://qyapi.weixin.qq.com/cgi-bin/user/getuserinfo?access_token=#{ACCESS_TOKEN}&code=#{CODE}";
65.     public static final String LOGIN_DETAIL_INFO = "https://qyapi.weixin.qq.com/cgi-bin/user/getuserdetail?access_token=#{ACCESS_TOKEN}";
67.     /**
68.      * 批量获取 客户列表 的 url
69.      */
70.     public static final String BATCH_CUSTOMER_LIST = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/batch/get_by_user?access_token=#{ACCESS_TOKEN}";
71.     /**
72.      * 获取 客户详情 的 url
73.      */
74.     public static final String CUSTOMER_INFO = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get?access_token=#{ACCESS_TOKEN}&external_userid=#{EXTERNAL_USERID}";
75.     /**
76.      * 修改 客户备注信息 的url
77.      */
78.     public static final String UPDATE_CUSTOMER_REMARK = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/remark?access_token=#{ACCESS_TOKEN}";
79.     /**
80.      * 编辑 客户标签 的url
81.      */
82.     public static final String MARK_CUSTOMER_TAG = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/mark_tag?access_token=#{ACCESS_TOKEN}";
84.     /**
85.      * 获取 企业标签 的 url
86.      */
87.     public static final String TAG_GROUP_LIST = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_corp_tag_list?access_token=";
89.     /**
90.      * 添加 企业标签 的 url
91.      */
92.     public static final String ADD_TAG_GROUP = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/add_corp_tag?access_token=";
94.     /**
95.      * 修改 企业标签 的 url
96.      */
97.     public static final String UPDATE_TAG_GROUP = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/edit_corp_tag?access_token=";
99.     /**
100.      * 删除 企业标签 的 url
101.      */
102.     public static final String DELETE_TAG_GROUP = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/del_corp_tag?access_token=";
104.     /**
105.      * 获取 客户群列表 的 url
106.      */
107.     public static final String GROUP_CHAT_LIST = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/groupchat/list?access_token=#{ACCESS_TOKEN}";
108.     /**
109.      * 获取 客户群详情 的 url
110.      */
111.     public static final String GROUP_CHAT_INFO = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/groupchat/get?access_token=#{ACCESS_TOKEN}";
112.     /**
113.      * 查询 联系我 的 url
114.      */
115.     public static final String GET_CONTACT_WAY = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_contact_way?access_token=#{ACCESS_TOKEN}";
116.     /**
117.      * 添加 联系我 的 url
118.      */
119.     public static final String ADD_CONTACT_WAY = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/add_contact_way?access_token=#{ACCESS_TOKEN}";
120.     /**
121.      * 更新 联系我 的 url
122.      */
123.     public static final String UPDATE_CONTACT_WAY = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/update_contact_way?access_token=#{ACCESS_TOKEN}";
124.     /**
125.      * 删除 联系我 的 url
126.      */
127.     public static final String DEL_CONTACT_WAY = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/del_contact_way?access_token=#{ACCESS_TOKEN}";
128.     /**
129.      * 发送 欢迎语  的 url
130.      */
131.     public static final String SEND_WELCOME_MSG = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/send_welcome_msg?access_token=#{ACCESS_TOKEN}";
132.     /**
133.      * 上传 临时素材 的 url
134.      */
135.     public static final String UPLOAD_MEDIA = "https://qyapi.weixin.qq.com/cgi-bin/media/upload?access_token=";
136.     /**
137.      * 添加 入群欢迎语素材  的 url
138.      */
139.     public static final String ADD_GROUP_WELCOME_TEMPLATE = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/group_welcome_template/add?access_token=#{ACCESS_TOKEN}";
140.     /**
141.      * 更新 入群欢迎语素材  的 url
142.      */
143.     public static final String UPDATE_GROUP_WELCOME_TEMPLATE = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/group_welcome_template/edit?access_token=#{ACCESS_TOKEN}";
144.     /**
145.      * 删除 入群欢迎语素材  的 url
146.      */
147.     public static final String DEL_GROUP_WELCOME_TEMPLATE = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/group_welcome_template/del?access_token=#{ACCESS_TOKEN}";
148.     /**
149.      * 发送 应用消息  的 url
150.      */
151.     public static final String SEND_APPLICATION_MESSAGE = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=#{ACCESS_TOKEN}";
152.     /**
153.      * 获取待分配的离职成员列表 的url
154.      */
155.     public static final String DIMISSION_WAIT_ALLOT_CLIENT = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_unassigned_list?access_token=#{ACCESS_TOKEN}";
156.     /**
157.      * 分配离职成员的客户
158.      */
159.     public static final String DIMISSION_ALLOT_Client = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/resigned/transfer_customer?access_token=#{ACCESS_TOKEN}";
160.     /**
161.      *  分配离职成员的客户群
162.      */
163.     public static final String DIMISSION_ALLOT_GROUP = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/groupchat/transfer?access_token=#{ACCESS_TOKEN}";
164.     /**
165.      * 创建企业群发
166.      */
167.     public static final String ADD_CORP_MASS_URL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/add_msg_template?access_token=#{ACCESS_TOKEN}";
168.     /**
169.      * 编辑客户企业标签
170.      */
171.     public static final String EDIT_CUSTOMER_CORP_TAG = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/mark_tag?access_token=#{ACCESS_TOKEN}";
172.     /**
173.      * 获取企业的jsapi_ticket
174.      */
175.     public static final String CORP_JS_API_TICKET = "https://qyapi.weixin.qq.com/cgi-bin/get_jsapi_ticket?access_token=";
176.     /**
177.      * 获取应用的jsapi_ticket
178.      */
179.     public static final String AGENT_JS_API_TICKET = "https://qyapi.weixin.qq.com/cgi-bin/ticket/get?type=agent_config&access_token=";
180.     /**
181.      * 获取 开通了会话存档的员工
182.      */
183.     public static final String MSG_AUDIT_EMPLOYEE = "https://qyapi.weixin.qq.com/cgi-bin/msgaudit/get_permit_user_list?access_token=#{ACCESS_TOKEN}";
184.     /**
185.      * corpid转换 的 url
186.      */
187.     public static final String CORPID_TO_OPENCORPID = "https://qyapi.weixin.qq.com/cgi-bin/service/corpid_to_opencorpid?provider_access_token=";
188.     /**
189.      * userid转换 的 url
190.      */
191.     public static final String USERID_TO_OPENUSERID = "https://qyapi.weixin.qq.com/cgi-bin/batch/userid_to_openuserid?access_token=";
193.     public static final String GET_NEW_EXTERNAL_USERID = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_new_external_userid?access_token=";
195.     public static final String UNIONID_TO_EXTERNAL_USERID = "https://qyapi.weixin.qq.com/cgi-bin/idconvert/unionid_to_external_userid?access_token=";
197.     public static final String EXTERNAL_USERID_TO_PENDING_ID = "https://qyapi.weixin.qq.com/cgi-bin/idconvert/batch/external_userid_to_pending_id?access_token=";
199.     public static final String FINISH_OPENID_MIGRATION = "https://qyapi.weixin.qq.com/cgi-bin/service/finish_openid_migration?provider_access_token=";
200. }

复制代码

1. public class WeixinCorpKeyConst {
2.     public static String errcode = "errcode";
3.     public static String errmsg = "errmsg";
5.     // 服务商相关
6.     public static String corpId = "corpid";
7.     public static String authCorpId = "auth_corpid";
8.     public static String corpName = "corp_name";
9.     public static String suiteId = "suite_id";
10.     public static String suiteSecret = "suite_secret";
11.     public static String providerSecret = "provider_secret";
12.     public static String corpSecret = "corpsecret";
13.     public static String suiteTicket = "suite_ticket";
14.     public static String suiteAccessToken = "suite_access_token";
15.     public static String providerAccessToken = "provider_access_token";
16.     public static String preAuthCode = "pre_auth_code";
17.     public static String authCode = "auth_code";
18.     public static String permanentCode = "permanent_code";
19.     public static String authCorpInfo = "auth_corp_info";
20.     public static String authInfo = "auth_info";
21.     public static String agent = "agent";
22.     public static String agentId = "agentid";
23.     public static String accessToken = "access_token";
25. }

复制代码

WeiXinProviderConst 就不贴了，内里就是记载上面那几个参数的
到这里可以发现，其实对接企业微信并不难，麻烦的地方就在于各种配置各种参数，然后就是回调，回调这个反面有空我也会整理出来

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

---

欢迎光临 IT评测·应用市场-qidao123.com技术社区 (https://dis.qidao123.com/)

Powered by Discuz! X3.4