Home >Java >javaTutorial >How to access DingTalk custom robot alert notification with SpringBoot
<dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.8</version> </dependency>
import com.alibaba.fastjson.JSON; import lombok.extern.slf4j.Slf4j; import net.sf.json.JSONSerializer; import org.apache.http.HttpResponse; import org.apache.http.HttpStatus; 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 java.util.*; /** * @Author: yansf * @Description:钉钉消息发送工具类 * @Date: 10:44 AM 2019/6/12 * @Modified By: */ @Slf4j public class DingDingMsgSendUtils { /** * 处理发送的钉钉消息 * * @param accessToken * @param textMsg */ private static void dealDingDingMsgSend(String accessToken, String textMsg) { HttpClient httpclient = HttpClients.createDefault(); String WEBHOOK_TOKEN = "https://oapi.dingtalk.com/robot/send?access_token=" + accessToken; HttpPost httppost = new HttpPost(WEBHOOK_TOKEN); httppost.addHeader("Content-Type", "application/json; charset=utf-8"); StringEntity se = new StringEntity(textMsg, "utf-8"); httppost.setEntity(se); try { HttpResponse response = httpclient.execute(httppost); if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) { String result = EntityUtils.toString(response.getEntity(), "utf-8"); log.info("【发送钉钉群消息】消息响应结果:" + JSON.toJSONString(result)); } } catch (Exception e) { log.error("【发送钉钉群消息】error:" + e.getMessage(), e); } } /** * 发送钉钉群消息 * * @param accessToken * @param content */ public static void sendDingDingGroupMsg(String accessToken, String content) { String textMsg = "{ \"msgtype\": \"text\", \"text\": {\"content\": \"" + content + "\"}}"; dealDingDingMsgSend(accessToken, textMsg); } /** * 发送钉钉群消息(可以艾特人) * * @param accessToken 群机器人accessToken * @param content 发送内容 * @param atPhone 艾特人电话,如:176********,156********, */ public static void sendDingDingGroupMsg(String accessToken, String content, String atPhone) { content = content.replace("\"", "'"); String textMsg = ""; // String textMsg = "{\n" + // " \"msgtype\": \"text\", \n" + // " \"text\": {\n" + // " \"content\": \"" + content + "\"\n" + // " }, \n" + // " \"at\": {\n" + // " \"atMobiles\": [\n" + // " " + atPhone + // " ], \n" + // " \"isAtAll\": false\n" + // " }\n" + // "}"; MsgDto msgDto = new MsgDto(); msgDto.setMsgtype("text"); TextDto textDto = new TextDto(); textDto.setContent(content); msgDto.setText(textDto); AtDto atDto = new AtDto(); atDto.setIsAtAll(false); List<String> result = Arrays.asList(atPhone.split(",")); atDto.setAtMobiles(result); msgDto.setAt(atDto); textMsg = JSONSerializer.toJSON(msgDto).toString(); System.out.println(textMsg); dealDingDingMsgSend(accessToken, textMsg); } public static void main(String[] args) { try { int s = Integer.parseInt("df12"); // System.out.println(1 / 0); } catch (Exception e) { //e.printStackTrace(); sendDingDingGroupMsg(DingTokenEnum.SEND_SMS_BY_DEVELOPER_TOKEN.getToken(), "【JAVA系统消息】钉钉消息推送测试,by:闫淑芳..." + e, DingMsgPhoneEnum.DEVELOPER_PHONE_yansf.getPhone()); } } }
import lombok.Getter; /** * @Author: yansf * @Description:钉钉消息接收用户,配置钉钉绑定的电话即可 * @Date: 10:44 AM 2019/6/12 * @Modified By: */ @Getter public enum DingMsgPhoneEnum { GENERAL_PURPOSE("176*****983", "bug不存在的"), DEVELOPER_PHONE_yansf("176*****983", "yansf"), DEVELOPER_PHONE_all("176*****983,176*****982,176*****981,176*****980", "all"), PRODUCT_PERSONNEL_PHONE("", "产品人员"), DATA_ANALYST_PHONE("", "数据分析人员"); private String phone; private String name; DingMsgPhoneEnum(String phone, String name) { this.phone = phone; this.name = name; } }
import lombok.Getter; /** * @Author: yansf * @Description:钉钉消息群机器人access_token * @Date: 10:45 AM 2019/6/12 * @Modified By: */ @Getter public enum DingTokenEnum { SEND_SMS_BY_DEVELOPER_TOKEN("此处自己申请token", "系统消息通知,技术专用"); private String token; private String name; DingTokenEnum(String token, String name) { this.token = token; this.name = name; } }
import lombok.Data; import java.util.List; /** * @Author: yansf * @Description: * @Date:Creat in 2:13 PM 2019/6/12 * @Modified By: */ @Data public class AtDto { private List<String> atMobiles; private Boolean isAtAll = false; }
import lombok.Data; /** * @Author: yansf * @Description: * @Date:Creat in 2:13 PM 2019/6/12 * @Modified By: */ @Data public class MsgDto { private String msgtype; private TextDto text; private AtDto at; }
import lombok.Data; /** * @Author: yansf * @Description: * @Date:Creat in 2:13 PM 2019/6/12 * @Modified By: */ @Data public class TextDto { private String content; }
异常捕获 try{ //todo } catch (Exception ex) { DingDingMsgSendUtils.sendDingDingGroupMsg(DingTokenEnum.SEND_SMS_BY_DEVELOPER_TOKEN.getToken(), "***异常," + profile + "环境,errorMsg=" + ex, DingMsgPhoneEnum.DEVELOPER_PHONE_yansf.getPhone()); } profile配置 @Value("${spring.profiles.active}") private String profile;
The above is the detailed content of How to access DingTalk custom robot alert notification with SpringBoot. For more information, please follow other related articles on the PHP Chinese website!