【接口設計】企業微信消息推送

代碼鏈接:https://github.com/AlenYang123456/corpwx

package com.gabriel.corpwx.task;

import com.alibaba.fastjson.JSON;
import com.gabriel.corpwx.comom.WxMsgConstant;
import com.gabriel.corpwx.comom.WxMsgTypeEnum;
import com.gabriel.corpwx.config.CorpWechatConfig;
import com.gabriel.corpwx.service.RedisService;
import com.gabriel.corpwx.util.DateUtils;
import com.gabriel.corpwx.util.HttpClientUtils;
import com.gabriel.corpwx.util.LocalDateTimeUtils;
import com.gabriel.corpwx.vo.resp.WxMessageResp;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.util.HashMap;
import java.util.Map;

/**
 * @author: yq
 * @date: 2019/12/13 17:35
 * @discription
 */
@Slf4j
@Component
public class WxMessageTask {

    @Autowired
    private CorpWechatConfig corpWechatConfig;

    @Autowired
    private RedisService redisService;


    /**
    * @Description: 企業微信消息推送 每天9點推送一次
    * @Param: [] Scheduled(cron = "0 0 9 1/1 * ? *") 正式環境使用 每天9點推送消息
    * @return: void
    * @Date: 2019-12-17
    */
    //@Scheduled(cron = "0 */5 * * * ?") //每5分鍾發送一次 調試用
    @Scheduled(cron = "0 0 9 1/1 * ?")
    public void pushMessage(){
        log.info("消息發送  開始=> 時間:[{}]", LocalDateTimeUtils.formatTime(LocalDateTime.now(), DateUtils.YYYY_MM_DD_HH_MM_SS));
        //1.獲取access_token -這里我是將access_token放到了redis緩存並添加失效時間,使用時取出來即可
        String accessToken = (String) redisService.get(WxMsgConstant.TOKEN);
        if (StringUtils.isBlank(accessToken)){
            //redis里面有重試
            log.info("消息推送:access_token獲 取失敗");
            throw new RuntimeException("access_token無法獲取");
        }

        //2.構造請求
        String url = String.format(corpWechatConfig.getSendMessageUrl(), accessToken);
        //請求頭
        Map<String,String> headers=new HashMap(16);
        headers.put("Content-Type", "application/json; charset=UTF-8");
        //請求體
        Map<String,Object> params=new HashMap<>(16);
        //TODO 暫時用自己的userId測試
        params.put(WxMsgConstant.TO_USER, "YangQiang");
        params.put(WxMsgConstant.MSG_TYPE, WxMsgTypeEnum.TEXT.getType());
        params.put(WxMsgConstant.AGENT_ID, corpWechatConfig.getAgentId());
        Map<String,String> contentMap =new HashMap<>(16);
        contentMap.put(WxMsgConstant.CONTENT, "測試消息-請及時查看");
        params.put(WxMsgConstant.TEXT, contentMap);
        log.info("企業微信消息推送==>> body:[{}],header:[{}],url:[{}]",params,headers,url);
        String result = HttpClientUtils.sendPostRequest(url, headers, JSON.toJSONString(params));

        if (StringUtils.isBlank(result)){
            throw new RuntimeException("消息發送失敗");
        }
        WxMessageResp wxMessageResp = JSON.parseObject(result, WxMessageResp.class);
        if (wxMessageResp.getErrcode()!=0){
            log.info("消息發送失敗 WxMessageResp:[{}],時間:[{}]",wxMessageResp,
                    LocalDateTimeUtils.formatTime(LocalDateTime.now(), DateUtils.YYYY_MM_DD_HH_MM_SS));
            throw  new RuntimeException("消息發送失敗");
        }
        log.info("消息發送成功=> wxMessageResp[{}],時間:[{}]",wxMessageResp,
                LocalDateTimeUtils.formatTime(LocalDateTime.now(), DateUtils.YYYY_MM_DD_HH_MM_SS));
    }

    /**
     * 手動測試的方法
     * @param args
     */
    public static void main(String[] args) {
        String url = String.format("https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=%s",
                "Z8fUMY3Z_BEhC8qFpXdLhjyu0B6NeTtgI3CRLzht-_FJugFS9705NFvuHmpT8kYezLY7C_sEwwr15UeN8LTcdrckIsKaIaSxhKka3UN_NFb2hvahUSBBnuYNMr-kGOZU1vv2TBIXDs5siXqI52Dq9Rw7cnTmq5t07soGu4qEvgIwwfNwp4CkBW1utf4giEVCDfWXn9rlAKZzo3UZ1Ie9uw");
        Map<String,String> headers=new HashMap(16);
        headers.put("Content-Type", "application/json; charset=UTF-8");

        Map<String,Object> params=new HashMap<>();
        params.put(WxMsgConstant.TO_USER, "XXXX");
        params.put(WxMsgConstant.MSG_TYPE,"text");
        params.put(WxMsgConstant.AGENT_ID, 1000002);
        Map<String,String> contentMap =new HashMap<>(16);
        contentMap.put(WxMsgConstant.CONTENT, "測試消息-請及時查看");
        params.put(WxMsgConstant.TEXT, contentMap);

        String result = HttpClientUtils.sendPostRequest(url, headers, JSON.toJSONString(params));
        if (StringUtils.isBlank(result)){
            throw new RuntimeException("消息發送失敗");
        }
        WxMessageResp wxMessageResp = JSON.parseObject(result, WxMessageResp.class);
        if (wxMessageResp.getErrcode()!=0){
            log.info("消息發送失敗 WxMessageResp:[{}]",wxMessageResp);
            throw  new RuntimeException("消息發送失敗");
        }
        log.info("消息發送成功:[{}]",wxMessageResp);
    }

}

 

相關參數配置

@Data
@Component
@ConfigurationProperties(prefix = "corpwechat")
public class CorpWechatConfig {

    /** 企業Id */
    private String corpid;

    /** 企業號密鑰 */
    private String corpsecret;
    
    /** 企業應用的id */
    private Integer agentId;
    
    /** 消息推送url */
    private String sendMessageUrl;
}

微信消息推送相關常量

public class WxMsgConstant {
    
    /** 接收消息的成員 */
    public  static final String TO_USER="toUser";
    
    /** 消息類型 */
    public static final String  MSG_TYPE="msgtype";

    /** 企業應用的id */
    public  static final String AGENT_ID="agentid";

    /** 消息內容 */
    public  static final String CONTENT="content";

    /** 微信access_token */
    public static final String TOKEN="WX_ACCESS_TOKEN";
}