最近在开发activiti流程的时候有个需求:流程到达每个审批节点后,需要向该节点的审批人发送一个消息,提示有审批需要处理。
参考了一下微信的开发者文档和网络上的一些技术博客,现在记录一下。以便后续继续研究微信开发。【微信开发真的很好玩的】
首先,你需要注册一个企业微信账号:https://work.weixin.qq.com/wework_admin/register_wx?from=myhome
然后进入后台管理,创建一个应用
上面标红的信息,都是开发测试需要用到的,需要记录一下。
先贴代码:
WeChatData.java
package com.xfma.wx.test; /** * 微信消息发送实体类 * @author PC-MXF * */ public class WeChatData { //发送微信消息的URLString sendMsgUrl="https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token="; /** * 成员账号 */ private String touser; /** * 消息类型 */ private String msgtype; /** * 企业用用的agentid */ private String agentid; /** * 十几接收map类型数据 */ private Object text; public String getTouser() { return touser; } public void setTouser(String touser) { this.touser = touser; } public String getMsgtype() { return msgtype; } public void setMsgtype(String msgtype) { this.msgtype = msgtype; } public String getAgentid() { return agentid; } public void setAgentid(String agentid) { this.agentid = agentid; } public Object getText() { return text; } public void setText(Object text) { this.text = text; } }
WeChatUrlData.java
package com.xfma.wx.test; /** * 微信授权请求 * @author PC-MXF * */ public class WeChatUrlData { /** * 企业Id */ private String corpid; /** * secret管理组的凭证密钥 */ private String corpsecret; /** * 获取ToKen的请求 */ private String Get_Token_Url; /** * 发送消息的请求 */ private String SendMessage_Url; public String getCorpid() { return corpid; } public void setCorpid(String corpid) { this.corpid = corpid; } public String getCorpsecret() { return corpsecret; } public void setCorpsecret(String corpsecret) { this.corpsecret = corpsecret; } public String getGet_Token_Url() { return Get_Token_Url; } public void setGet_Token_Url(String corpid,String corpsecret) { Get_Token_Url = "https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid="+corpid+"&corpsecret="+corpsecret; } public String getSendMessage_Url() { SendMessage_Url = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token="; return SendMessage_Url; } public void setSendMessage_Url(String sendMessage_Url) { SendMessage_Url = sendMessage_Url; } }
WeChatMsgSend.java
package com.xfma.wx.test; import java.io.IOException; import java.text.SimpleDateFormat; 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.slf4j.LoggerFactory; import com.google.gson.Gson; import com.google.gson.reflect.TypeToken; /** * 微信发送消息 * * @author PC-MXF * */ public class WeChatMsgSend { private CloseableHttpClient httpClient; /** * 用于提交登录数据 */ private HttpPost httpPost; /** * 用于获得登陆后页面 */ private HttpGet httpGet; public static final String CONTENT_TYPE = "Content-Type"; SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); private static Gson gson = new Gson(); /** * 微信授权请求,GET类型,获取授权响应,用于其他方法截取token * * @param Get_Token_Url * @return String 授权响应内容 * @throws IOException */ protected String toAuth(String Get_Token_Url) throws IOException { httpClient = HttpClients.createDefault(); httpGet = new HttpGet(Get_Token_Url); CloseableHttpResponse response = httpClient.execute(httpGet); String resp = ""; try { HttpEntity entity = response.getEntity(); resp = EntityUtils.toString(entity, "utf-8"); EntityUtils.consume(entity); } catch (Exception e) { e.getStackTrace(); } finally { response.close(); } LoggerFactory.getLogger(getClass()).info(" resp:{}", resp); return resp; } /** * corpid应用组织编号 corpsecret应用秘钥 获取toAuth(String * Get_Token_Url)返回结果中键值对中access_token键的值 * * @param */ public String getToken(String corpid, String corpsecret) throws IOException { WeChatMsgSend sw = new WeChatMsgSend(); WeChatUrlData uData = new WeChatUrlData(); uData.setGet_Token_Url(corpid, corpsecret); String resp = sw.toAuth(uData.getGet_Token_Url()); System.out.println("resp=====:" + resp); try { Map<String, Object> map = gson.fromJson(resp, new TypeToken<Map<String, Object>>() { }.getType()); return map.get("access_token").toString(); } catch (Exception e) { e.getStackTrace(); return resp; } } /** * 创建微信发送请求post数据 touser发送消息接收者 ,msgtype消息类型(文本/图片等), application_id应用编号。 * 本方法适用于text型微信消息,contentKey和contentValue只能组一对 * * @param touser * @param msgtype * @param application_id * @param contentKey * @param contentValue * @return */ public String createpostdata(String touser, String msgtype, int application_id, String contentKey, String contentValue) { WeChatData wcd = new WeChatData(); wcd.setTouser(touser); wcd.setAgentid(application_id + ""); wcd.setMsgtype(msgtype); Map<Object, Object> content = new HashMap<Object, Object>(); content.put(contentKey, contentValue); wcd.setText(content); return gson.toJson(wcd); } /** * @Title 创建微信发送请求post实体,charset消息编码 ,contentType消息体内容类型, * url微信消息发送请求地址,data为post数据,token鉴权token * @param charset * @param contentType * @param url * @param data * @param token * @return * @throws IOException */ public 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(); } LoggerFactory.getLogger(getClass()).info("call [{}], param:{}, resp:{}", url, data, resp); return resp; } }
Test.java
package com.xfma.wx.test; public class Test { public static void main(String[] args) { WeChatMsgSend swx = new WeChatMsgSend(); try { String token = swx.getToken("ww44a4ede4d3626a","w6tRMGfN5WSFarMmqdpkwBztPRy-HVXRRs76QXvFU"); String postdata = swx.createpostdata("jiangpin", "text", 1000009, "content","这是一条测试信息"); String resp = swx.post("utf-8", WeChatMsgSend.CONTENT_TYPE,(new WeChatUrlData()).getSendMessage_Url(), postdata, token); System.out.println("获取到的token======>" + token); System.out.println("请求数据======>" + postdata); System.out.println("发送微信的响应数据======>" + resp); }catch (Exception e) { e.getStackTrace(); } } }