钉钉通知Java

    //请求消息
    String sendMessage = String.format(messageBody, "\n", reportMessage.getUserName() + "\n",
            reportMessage.getUserId() + "\n", reportMessage.getReportInstanceId() + "\n",
            reportMessage.getReportType() + "\n",
            reportMessage.getReportName() + "\n", reportMessage.getFailDesc() + "\n",
            reportMessage.getCreateTime());
    //钉钉消息
    String dingMessage = DingMessageUtil.generateMessageBody(sendMessage, false, null);
    //发送钉钉消息
    DingMessageUtil.sendMessage(reportSecret, dingMessage, dingWebHookUrl);
}
/**
 * 组装请求报文
 * @param content 通知内容
 * @param isNotifyAll 是否通知所有人
 * @param mobileList 通知手机号
 * @return
 */
public static String generateMessageBody(String content, boolean isNotifyAll, List<String> mobileList) {
    // 消息内容
    Map<String, String> contentMap = new HashMap<>(16);
    contentMap.put("content", content);
    // 通知人
    Map<String, Object> atMap = new HashMap<>(16);
    // 是否通知所有人
    atMap.put("isAtAll", isNotifyAll);
    // 通知具体人的手机号码列表
    atMap.put("atMobiles", mobileList);
    Map<String, Object> reqMap = new HashMap<>(16);
    reqMap.put("msgtype", "text");
    reqMap.put("text", contentMap);
    reqMap.put("at", atMap);
    return JSONObject.toJSONString(reqMap);
}
/**
 *  钉钉发送消息
 * @param secret 钉钉机器人密钥
 * @param message 消息
 * @param dingUrl 钉钉机器人hook地址
 */
public static void sendMessage(String secret, String message, String dingUrl) {
    final String actionLog = "【发送钉钉消息】";
    log.info("{}, secret:{}, message:{}, dingUrl:{}, mobileList:{}", actionLog, secret, message,
            dingUrl);
    try {
        // 系统时间戳
        Long timestamp = System.currentTimeMillis();
        // 拼接
        String signStr = timestamp + "\n" + secret;
        // 使用HmacSHA256算法计算签名
        Mac mac = Mac.getInstance("HmacSHA256");
        mac.init(new SecretKeySpec(secret.getBytes("UTF-8"), "HmacSHA256"));
        byte[] signData = mac.doFinal(signStr.getBytes("UTF-8"));
        String sign = URLEncoder.encode(new String(Base64.encodeBase64(signData)), "UTF-8");
        String requestUrl = dingUrl + "&timestamp=" + timestamp + "&sign=" + sign;
        // 推送消息（http请求）
        HttpPost httpPost = new HttpPost(requestUrl.trim());
        RequestConfig requestConfig = RequestConfig.custom()
                .setConnectTimeout(30000)
                .setConnectionRequestTimeout(30000)
                .setSocketTimeout(30000).build();
        httpPost.setConfig(requestConfig);
        // 设置参数
        httpPost.setEntity(new StringEntity(message, ContentType.DEFAULT_TEXT.withCharset("UTF-8")));
        httpPost.setHeader(new BasicHeader("Content-Type", "application/json"));
        // 发送请求,获取返回数据
        String response = execute(httpPost);
        log.info("{}, 钉钉返回：{}", response);
        log.info("{}, 消息处理完毕");
    } catch (Exception e) {
        e.printStackTrace();
    }
}
private static String execute(HttpRequestBase requestBase) throws Exception {
    CloseableHttpClient httpclient = HttpClients.createDefault();
    String body = null;
    try {
        CloseableHttpResponse response = httpclient.execute(requestBase);
        try {
            HttpEntity entity = response.getEntity();
            if (entity != null) {
                body = EntityUtils.toString(entity, "UTF-8");
            }
            EntityUtils.consume(entity);
        } catch (Exception e) {
            throw e;
        } finally {
            response.close();
        }
    } catch (Exception e) {
        throw e;
    } finally {
        httpclient.close();
    }
    return body;
}

/**
 * 消费钉钉消息
 * @param message
 * @param consumeContext
 * @return
 */
@Override
public Action consume(Message message, ConsumeContext consumeContext) {
    try {
        Boolean notifyOpen = messageConfig.getNotifyOpen();
        if (!notifyOpen) {
            log.info("报告通知开关已关闭或未配置 notifyOpen:{}", notifyOpen);
            return Action.CommitMessage;
        }
        //钉钉报告地址
        String dingWebHookUrl = messageConfig.getDingReportUrl();
        //钉钉报告机密钥
        String reportSecret = messageConfig.getDingReportSecret();
        /**钉钉报告消息体 报告预警提示~\n用户昵称：%s\n用户ID：%s\n报告编号：%s\n报告类型：%s\n报告名称：%s\n
         * 预警描述：%s\n报告预警时间：%s
         */
        String messageBody = messageConfig.getDingReportMessageBody();
        if (StringUtils.isEmpty(messageBody) || StringUtils.isEmpty(dingWebHookUrl)
                || StringUtils.isEmpty(reportSecret)) {
            log.info("发送报告钉钉消息， 消息配置项未配置");
            return Action.CommitMessage;
        }
        //请求体
        String requestBody = new String(message.getBody(), StandardCharsets.UTF_8);
        //报告消息体
        DingReportFailMessage reportMessage = JSONObject.parseObject(requestBody, DingReportFailMessage.class);
        //请求消息
        String sendMessage = String.format(messageBody, "\n", reportMessage.getUserName() + "\n",
                reportMessage.getUserId() + "\n", reportMessage.getReportInstanceId() + "\n",
                reportMessage.getReportType() + "\n",
                reportMessage.getReportName() + "\n", reportMessage.getFailDesc() + "\n",
                reportMessage.getCreateTime());
        //钉钉消息
        String dingMessage = DingMessageUtil.generateMessageBody(sendMessage, false, null);
        //发送钉钉消息
        DingMessageUtil.sendMessage(reportSecret, dingMessage, dingWebHookUrl);
        return Action.CommitMessage;
    } catch (Exception e) {
        log.error("发送钉钉失败报告消息异常 e:{}", e);
        return Action.ReconsumeLater;
    }
}