java对接企业微信

逃离我推掉我的手 2022-12-28 08:11 279阅读 0赞

最近项目需要对接企业微信把马上要超过预警值消息推送给相关用户，这里网上看了下对接企业微信提供的官方文档以及相关文章这里做一下整理。

# 一、准备 #

为了便于测试，在开始对接前注册一个企业微信。

注册地址：[https://work.weixin.qq.com/wework\_admin/register\_wx?from=loginpage][https_work.weixin.qq.com_wework_admin_register_wx_from_loginpage]

①注册完毕后我们可以得到企业微信的企业ID

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ExNTEwMjc4MDcwNQ_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ExNTEwMjc4MDcwNQ_size_16_color_FFFFFF_t_70 1][]

这个企业微信很重要，待会我们接口请求要用到。

②创建企业应用

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2MDkyNTg0_size_16_color_FFFFFF_t_70][]

这里创建完毕后可以得到Agentld和Secret，我们后面对接也会用到

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ExNTEwMjc4MDcwNQ_size_16_color_FFFFFF_t_70 2][]

# 二、开始接口测试 #

获取access\_token

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ExNTEwMjc4MDcwNQ_size_16_color_FFFFFF_t_70 3][]

用access\_token拼接接口推送企业微信消息

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ExNTEwMjc4MDcwNQ_size_16_color_FFFFFF_t_70 4][]

测试200成功，完毕！

## 代码：（用代码时请替换自己注册的企业id和secret） ##

package com.transferdata.demo.service;
    
    import java.io.IOException;
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.Map;
    
    import org.apache.http.HttpEntity;
    import org.apache.http.client.methods.CloseableHttpResponse;
    import org.apache.http.client.methods.HttpGet;
    import org.apache.http.client.methods.HttpPost;
    import org.apache.http.entity.StringEntity;
    import org.apache.http.impl.client.CloseableHttpClient;
    import org.apache.http.impl.client.HttpClients;
    import org.apache.http.util.EntityUtils;
    import org.springframework.stereotype.Component;
    
    import com.google.gson.Gson;
    import com.google.gson.reflect.TypeToken;
    import com.transferdata.demo.entity.UrlData;
    import com.transferdata.demo.entity.WeChatData;
    
    @Component
    public class QywxSendService {
    	
    	private CloseableHttpClient httpClient;
    	private HttpPost httpPost;			// 用于提交推送数据
    	private HttpGet httpGet;			// 用于获得access_token
    
    	public static final String CONTENT_TYPE = "Content-Type";
    	SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");	//推送时间
    	private static Gson gson = new Gson();
    
    	public String getToken(String corpId, String corpSecret) throws IOException {
    		//corpId、corpSecret问下企业微信管理后台,corpSecret应该是应用独立Secret
    		QywxSendService sw = new QywxSendService();
    		UrlData uData = new UrlData();
    		uData.setGetTokenUrl(corpId, corpSecret);
    		String resp = sw.toAuth(uData.getGetTokenUrl());// 就是按照GET方式拼接了字符串得到url
    		Map<String, Object> map = gson.fromJson(resp, new TypeToken<Map<String, Object>>() {}.getType());
    		System.out.println(map);
    		return map.get("access_token").toString();
    	}
    
    	protected String toAuth(String Get_Token_Url) throws IOException {
    
    		httpClient = HttpClients.createDefault();
    		httpGet = new HttpGet(Get_Token_Url);
    		CloseableHttpResponse response = httpClient.execute(httpGet);
    		System.out.println(response.toString());
    		String resp;
    		try {
    			HttpEntity entity = response.getEntity();
    			System.out.println(response.getAllHeaders());
    			resp = EntityUtils.toString(entity, "utf-8");
    			EntityUtils.consume(entity);
    		} finally {
    			response.close();
    		}
    		return resp;
    	}
    	
    	/**
    	 * 创建POST BODY
    	 */
    	private String createPostData(String touser, String msgtype, int agent_id, String contentKey, String contentValue) {
    		WeChatData weChatData = new WeChatData();
    		weChatData.setTouser(touser);
    		weChatData.setAgentid(agent_id);
    		weChatData.setMsgtype(msgtype);
    		Map<Object, Object> content = new HashMap<Object, Object>();
    		content.put(contentKey, contentValue + "\n--------\n" + df.format(new Date()));
    		weChatData.setText(content);
    		System.out.println(gson.toJson(weChatData));
    		return gson.toJson(weChatData);
    	}
    
    	/**
    	 * POST请求
    	 */
    	private String post(String charset, String contentType, String url, String data, String token) throws IOException {
    		CloseableHttpClient httpclient = HttpClients.createDefault();
    		httpPost = new HttpPost(url + token);
    		httpPost.setHeader(CONTENT_TYPE, contentType);
    		httpPost.setEntity(new StringEntity(data, charset));
    		CloseableHttpResponse response = httpclient.execute(httpPost);
    		String resp;
    		try {
    			HttpEntity entity = response.getEntity();
    			resp = EntityUtils.toString(entity, charset);
    			EntityUtils.consume(entity);
    		} finally {
    			response.close();
    		}
    		return resp;
    	}
    	
    	public void sendTextMesg(String toUser, String contentValue) throws IOException {
    		//String token = getToken("corpId", "corpSecret");
    		String token = getToken("wwf002eb1b82adeb", "rrj0M02BdHtk_XLTKhNQNjv92CHdTmnw0lcgo");//corpId、推送消息corpSecret
    		String postData = createPostData(toUser, "text", 1000002, "content", contentValue);
    		String response = post("utf-8", QywxSendService.CONTENT_TYPE, (new UrlData()).getSendMessageUrl(), postData, token);
    		System.out.println("获取到的token======>" + token);
    		System.out.println("请求数据======>" + postData);
    		System.out.println("发送企业微信的响应数据======>" + response);
    	}
    
    	public static void main(String[] args) {
    		QywxSendService qywxSendService=new QywxSendService();
    		try {
    			qywxSendService.sendTextMesg("@all","你好");
    		} catch (IOException e) {
    			e.printStackTrace();
    		}
    	}
    }

[https_work.weixin.qq.com_wework_admin_register_wx_from_loginpage]: https://work.weixin.qq.com/wework_admin/register_wx?from=loginpage
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ExNTEwMjc4MDcwNQ_size_16_color_FFFFFF_t_70]: /images/20221120/9ad1db9af2ca490fa480cda8d2ba1f32.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ExNTEwMjc4MDcwNQ_size_16_color_FFFFFF_t_70 1]: /images/20221120/8566b807356042109242ed2ce8d63970.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2MDkyNTg0_size_16_color_FFFFFF_t_70]: /images/20221120/d7d6c9d44b604152a8107c89ca22271f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ExNTEwMjc4MDcwNQ_size_16_color_FFFFFF_t_70 2]: /images/20221120/8d98c8ee10b84cda9a30cfff1e0efb4e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ExNTEwMjc4MDcwNQ_size_16_color_FFFFFF_t_70 3]: /images/20221120/1fced1ed96684eca98dcdc118a9033a3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ExNTEwMjc4MDcwNQ_size_16_color_FFFFFF_t_70 4]: /images/20221120/d4f5ecf1d2084ac6b2b42e4039b8f125.png