/*** 微信发送消息

*

*@authorPC-MXF

**/

public classWeChatMsgSend {privateCloseableHttpClient httpClient;/*** 用于提交登录数据*/

privateHttpPost httpPost;/*** 用于获得登陆后页面*/

privateHttpGet httpGet;public static final String CONTENT_TYPE = "Content-Type";

SimpleDateFormat df= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");private static Gson gson = newGson();/*** 微信授权请求，GET类型，获取授权响应，用于其他方法截取token

*

*@paramGet_Token_Url

*@returnString 授权响应内容

*@throwsIOException*/

protected String toAuth(String Get_Token_Url) throwsIOException {

httpClient=HttpClients.createDefault();

httpGet= newHttpGet(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);returnresp;

}/*** corpid应用组织编号 corpsecret应用秘钥 获取toAuth(String

* Get_Token_Url)返回结果中键值对中access_token键的值

*

*@param

*/

public String getToken(String corpid, String corpsecret) throwsIOException {

WeChatMsgSend sw= newWeChatMsgSend();

WeChatUrlData uData= newWeChatUrlData();

uData.setGet_Token_Url(corpid, corpsecret);

String resp=sw.toAuth(uData.getGet_Token_Url());

System.out.println("resp=====:" +resp);try{

Map map = gson.fromJson(resp, new TypeToken>() {

}.getType());return map.get("access_token").toString();

}catch(Exception e) {

e.getStackTrace();returnresp;

}

}/*** 创建微信发送请求post数据 touser发送消息接收者 ，msgtype消息类型(文本/图片等)， application_id应用编号。

* 本方法适用于text型微信消息，contentKey和contentValue只能组一对

*

*@paramtouser

*@parammsgtype

*@paramapplication_id

*@paramcontentKey

*@paramcontentValue

*@return

*/

public String createpostdata(String touser, String msgtype, intapplication_id, String contentKey,

String contentValue) {

WeChatData wcd= newWeChatData();

wcd.setTouser(touser);

wcd.setAgentid(application_id+ "");

wcd.setMsgtype(msgtype);

Map content = new HashMap();

content.put(contentKey, contentValue);

wcd.setText(content);returngson.toJson(wcd);

}/*** @Title 创建微信发送请求post实体，charset消息编码 ，contentType消息体内容类型，

* url微信消息发送请求地址，data为post数据，token鉴权token

*@paramcharset

*@paramcontentType

*@paramurl

*@paramdata

*@paramtoken

*@return*@throwsIOException*/

public String post(String charset, String contentType, String url, String data, String token) throwsIOException {

CloseableHttpClient httpclient=HttpClients.createDefault();

httpPost= new HttpPost(url +token);

httpPost.setHeader(CONTENT_TYPE, contentType);

httpPost.setEntity(newStringEntity(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);returnresp;

}

}