package com.reyun.util; import com.alibaba.fastjson.JSONObject; import org.apache.commons.net.util.Base64; import org.apache.http.HttpResponse; import org.apache.http.client.HttpClient; import org.apache.http.client.methods.HttpPost; import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.HttpClients; import org.apache.http.util.EntityUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import javax.crypto.Mac; import javax.crypto.spec.SecretKeySpec; import java.net.URLEncoder; import java.nio.charset.StandardCharsets; public class DingDingSendMsgUtil { protected Logger logger = LoggerFactory.getLogger(DingDingSendMsgUtil.class); public static final String APP_ONLINE_MSG = "SECe0246056d9266f5ffebd23eeff96dc2c6fcf80f65adc73afd741b132ab4fa222"; public void sendMsg(String url,String content) { HttpClient httpclient = HttpClients.createDefault(); HttpPost httppost = new HttpPost(url); httppost.addHeader("Content-Type", "application/json; charset=utf-8"); String textMsg = "{ \"msgtype\": \"text\", \"text\": {\"content\": \""+content+"\"}}"; StringEntity se = new StringEntity(textMsg, "utf-8"); httppost.setEntity(se); try { HttpResponse response = httpclient.execute(httppost); String result= EntityUtils.toString(response.getEntity(), "utf-8"); JSONObject jsonObject = JSONObject.parseObject(result); if(jsonObject.get("errcode") !=null && !"0".equals(jsonObject.get("errcode").toString())){ logger.warn("钉钉消息发送失败:\r\nURL:"+url+"\r\nContent:"+content+"\r\n失败原因:"+result); } }catch (Exception e){ logger.error("钉钉消息发送失败:\r\nURL:"+url+"\r\nContent:"+content,e); } } /** * 功能描述:机器人加签所需,获取签名 * @param secret 密钥,机器人安全设置页面,加签一栏下面显示的SEC开头的字符串 * @param timestamp 当前时间戳,单位是毫秒,与请求调用时间误差不能超过1小时 * @author liyin * @date 2019/11/26 */ public String getSignNew(Long timestamp,String secret){ try { String stringToSign = timestamp + "\n" + secret; Mac mac = Mac.getInstance("HmacSHA256"); mac.init(new SecretKeySpec(secret.getBytes(StandardCharsets.UTF_8), "HmacSHA256")); byte[] signData = mac.doFinal(stringToSign.getBytes(StandardCharsets.UTF_8)); return URLEncoder.encode(new String(Base64.encodeBase64(signData)),"UTF-8"); }catch (Exception e){ logger.warn(e.getMessage()); return null; } } public static void main(String[] args) { DingDingSendMsgUtil dingDingUtil = new DingDingSendMsgUtil(); long timeMillis = System.currentTimeMillis(); String sign = dingDingUtil.getSignNew(timeMillis, DingDingSendMsgUtil.APP_ONLINE_MSG); String url = "https://oapi.dingtalk.com/robot/send?access_token=d2b4b62809fe0e469d8487ffe2e8678d596fb3ed10a2fc731df274fd7c473d3a×tamp=" + timeMillis + "&sign=" + sign; StringBuilder sb = new StringBuilder("Company:"); sb .append("热云").append("\r") .append("Email:").append("243242@reyun.com").append("\r") .append("App Key:").append("h2j34h23hjg43g4j2h4237y89qiw").append("\r") .append("App Name:").append("快手").append("\r") .append("预计上线时间:").append("2020-07-02").append("\r") .append("距离上线天数:").append(1+"天"); dingDingUtil.sendMsg(url, sb.toString()); } }