JAVA实现接入企业微信报警

梦里梦外; 2023-07-11 12:38 17阅读 0赞

引言

原来系统中报警采用短信和邮件方式，短信采用阿里的短信，近期由于 一些原因，项目中想将报警信息发送到 企业微信中，由于之前小编玩zabbix的时候实现过这个需求，所以认为通过java应该比较简单， 下面分享接入代码，直接上干货。

一、创建应用

1）、登录企业微信后台管理页面，选择应用管理

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNDU0Mzc_size_16_color_FFFFFF_t_70][]

2）、在最下面 创建应用

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNDU0Mzc_size_16_color_FFFFFF_t_70 1][]

这里面可以控制那些人收到报警信息，其中质量的Secret 就是我们后面**代码中的秘钥**；

3）获得企业id

在 管理后台-》我的企业 一栏的最下面可以找到企业ID

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNDU0Mzc_size_16_color_FFFFFF_t_70 2][]

二、代码实现

添看到依赖

<dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpcore</artifactId>
        <version>4.4.6</version>
    </dependency>
    <dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpclient</artifactId>
        <version>4.5.5</version>
    </dependency>

代码实现

1、实体类

package com.jack.common.utils;
    
    /**
     * @Description:
     * @author: zhenghao
     * @date: 2020/3/5 17:24
    */
    public class IacsUrlDataVo {
        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;
        }
    }

package com.jack.common.utils;
    
    /**
     * @Description:
     * @author: zhenghao
     * @date: 2020/3/5 17:24
    */
    public class IacsWeChatDataVo {
        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;
        }
    
    }

2、消息发送代码

package com.jack.common.utils;
    
    import com.google.gson.Gson;
    import com.google.gson.reflect.TypeToken;
    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 org.springframework.http.HttpHeaders;
    import org.springframework.http.MediaType;
    import org.springframework.http.ResponseEntity;
    import org.springframework.web.client.RestTemplate;
    
    import java.io.IOException;
    import java.text.SimpleDateFormat;
    import java.util.*;
    
    /**
     * @Description: 企业微信发送代码
     * @author: zhenghao
     * @date: 2020/3/5 17:25
    */
    public class SendWeChatUtils {
    
        private CloseableHttpClient httpClient;
        private static HttpPost httpPost;//用于提交登陆数据
        private  static  HttpGet httpGet;//用于获得登录后的页面
        public static final String CONTENT_TYPE = "Content-Type";
        static  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
         */
        public 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 应用秘钥
         */
        public static String getToken(String corpid, String corpsecret) throws IOException {
            SendWeChatUtils sw = new SendWeChatUtils();
            IacsUrlDataVo uData = new IacsUrlDataVo();
            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();
        }
    
    
        /**
         * @param touser         发送消息接收者    ，msgtype消息类型（文本/图片等），
         * @param application_id 应用编号。
         * @return String
         * @Title:创建微信发送请求post数据
         */
        public static String createpostdata(String touser, String msgtype,
                                     int application_id, String contentKey, String contentValue) {
            IacsWeChatDataVo wcd = new IacsWeChatDataVo();
            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);
        }
    
        /**
         * @param charset 消息编码    ，contentType 消息体内容类型，
         * @param url     微信消息发送请求地址，data为post数据，token鉴权token
         * @return String
         * @Title 创建微信发送请求post实体
         */
        public static 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(SendWeChatUtils.class).info(
                    "call [{}], param:{}, resp:{}", url, data, resp);
            return resp;
        }
    
    
        public static void sendMsg(String strContent){
            try {
                String token = getToken("企业id", "秘钥");
                String postdata = createpostdata("@all", "text", 1000011, "content",strContent);
                String resp = post("utf-8", "text", (new IacsUrlDataVo()).getSendMessage_Url(), postdata, token);
    //            System.out.println("获取到的token======>" + token);
    //            System.out.println("请求数据======>" + postdata);
    //            System.out.println("发送微信的响应数据======>" + resp);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

上面代码中我们需要填写我们自己的企业id和秘钥；

3、业务调用

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNDU0Mzc_size_16_color_FFFFFF_t_70 3][]

# 如需发送其他类型信息，附参考文档 #

[腾讯企业微信官方文档：https://work.weixin.qq.com/api/doc\#10167][https_work.weixin.qq.com_api_doc_10167]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNDU0Mzc_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/2020030517341713.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNDU0Mzc=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNDU0Mzc_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200305173536945.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNDU0Mzc=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNDU0Mzc_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200305174946867.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNDU0Mzc=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNDU0Mzc_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/2020030517265928.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNDU0Mzc=,size_16,color_FFFFFF,t_70
[https_work.weixin.qq.com_api_doc_10167]: https://work.weixin.qq.com/api/doc#10167