使用Java程序發送企業微信

Java程序發送微信消息，全部代碼，已測試通過

urlData.java   “微信授權請求”數據對象文件：

package Alert.weChat;

public class urlData {
    String corpid;
    String corpsecret;
    String Get_Token_Url;
    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 void setGet_Token_Url(String corpid,String corpsecret) {
        this.Get_Token_Url ="https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid="+corpid+"&corpsecret="+corpsecret;
    }
    public String getGet_Token_Url() {
        return Get_Token_Url;
    }
    public String getSendMessage_Url(){
        SendMessage_Url = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=";
        return SendMessage_Url;
    }
    
}

 

weChatData.java  “微信消息發送”的post數據對象文件：

package Alert.weChat;


public class weChatData {
    //發送微信消息的URL
//    String sendMsgUrl="https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=";
    String touser;
    String msgtype;
    int agentid;
    Object text;//實際接收Map類型數據

    public Object getText() {
        return text;
    }
    public void setText(Object text) {
        this.text = text;
    }
    public String getMsgtype() {
        return msgtype;
    }
    public void setMsgtype(String msgtype) {
        this.msgtype = msgtype;
    }
    public int getAgentid() {
        return agentid;
    }
    public void setAgentid(int agentid) {
        this.agentid = agentid;
    }
    public String getTouser() {
        return touser;
    }
    public void setTouser(String touser) {
        this.touser = touser;
    }

}

 

send_weChatMsg.java  “發送微信實體”代碼

package Alert.weChat;

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.slf4j.LoggerFactory;

import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;


public class send_weChatMsg {
     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);
        } finally {
            response.close();
        }
        LoggerFactory.getLogger(getClass()).info(" resp:{}", resp);
        return resp;
    }

    /**
     * 獲取toAuth(String Get_Token_Url)返回結果中鍵值對中access_token鍵的值
     * @param corpid應用組織編號   corpsecret應用秘鑰
     */    
    protected  String getToken(String corpid,String corpsecret) throws IOException {        
        send_weChatMsg sw = new send_weChatMsg();
        urlData uData = new urlData();
        uData.setGet_Token_Url(corpid,corpsecret);
        String resp = sw.toAuth(uData.getGet_Token_Url());
        
        Map<String, Object> map = gson.fromJson(resp,
                new TypeToken<Map<String, Object>>() {
                }.getType());
        return map.get("access_token").toString();
    }

    
    /** 
    * @Title:創建微信發送請求post數據  
    * @param  touser發送消息接收者    ，msgtype消息類型（文本/圖片等），
    * @param application_id應用編號。
    * @param 本方法適用於text型微信消息，contentKey和contentValue只能組一對
    * @return String     
    */
    protected 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+"\n--------\n"+df.format(new Date()));
        wcd.setText(content);
        return gson.toJson(wcd);
    }

    /** 
    * @Title  創建微信發送請求post實體
    * @param  charset消息編碼    ，contentType消息體內容類型，
    * @param  url微信消息發送請求地址，data為post數據，token鑒權token
    * @return String     
    */
    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 Alert.weChat;

import java.io.IOException;

public class test {
    public static void main(String[] args) {
        send_weChatMsg sw = new send_weChatMsg();
        try {
            String token = sw.getToken("wxbXXXXX","YYYYYYYYYY");
            String postdata = sw.createpostdata("Luosu", "text", 1, "content","This alert Email come from IapppayBJQA");
            String resp = sw.post("utf-8", send_weChatMsg.CONTENT_TYPE,(new urlData()).getSendMessage_Url(), postdata, token);
            System.out.println("獲取到的token======>" + token);
            System.out.println("請求數據======>" + postdata);
            System.out.println("發送微信的響應數據======>" + resp);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

 

test.java代碼輸出：

log4j:WARN No appenders could be found for logger (org.apache.http.client.protocol.RequestAddCookies).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
獲取到的token======>_kv4OeDXcsXIUG6lWwQCbz12thqlAN8HGhzx4B_HBRnYCQpt5CxwnnyMThS2ep3V
請求數據======>{"touser":"AAA","msgtype":"text","agentid":1,"text":{"content":"This alert Email come from IapppayBJQA\n--------\n2017-03-17 09:06:45"}}
發送微信的響應數據======>{"errcode":0,"errmsg":"ok"}