sky

一.获取自定义机器人webhook

二.引入钉钉jar

<dependency>
 <groupId>com.dingtalk</groupId>
 <artifactId>com.dingtalk</artifactId>
 <scope>system</scope>
 <systemPath>${project.basedir}/src/main/resources/lib/taobao-sdk-java-auto_1479188381469-20191225.jar</systemPath>
</dependency>
<build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 <configuration>
 <includeSystemScope>true</includeSystemScope>
 </configuration>
 </plugin>
 </plugins>
</build>

三.接口调用

@RequestMapping("/alarm")
@RestController
@Slf4j
public class AlarmController {
 private String secret = "你的secret";
 private String webhook = "https://oapi.dingtalk.com/robot/send?access_token=*******";
 @RequestMapping(value = "/pushData", method = RequestMethod.POST)
 public void alarm(@RequestBody List<AlarmMessageDto> alarmMessageList) {
 log.info("alarmMessage:{}", alarmMessageList.toString());
 alarmMessageList.forEach(info -> {
 try {
 Long timestamp = System.currentTimeMillis();
 String stringToSign = timestamp + "\n" + secret;
 Mac mac = Mac.getInstance("HmacSHA256");
 mac.init(new SecretKeySpec(secret.getBytes("UTF-8"), "HmacSHA256"));
 byte[] signData = mac.doFinal(stringToSign.getBytes("UTF-8"));
 String sign = "&timestamp=" + timestamp + "&sign=" + URLEncoder.encode(new String(Base64.encodeBase64(signData)), "UTF-8");
 DingTalkClient client = new DefaultDingTalkClient(webhook + sign);
 OapiRobotSendRequest request = new OapiRobotSendRequest();
 request.setMsgtype("text");
 OapiRobotSendRequest.Text text = new OapiRobotSendRequest.Text();
 text.setContent("业务告警:\n" + info.getAlarmMessage());
 request.setText(text);
 OapiRobotSendRequest.At at = new OapiRobotSendRequest.At();
 at.setAtMobiles(Arrays.asList("所有人"));
 request.setAt(at);
 OapiRobotSendResponse response = client.execute(request);
 log.info("execute:{}" + response.toString());
 } catch (Exception e) {
 e.printStackTrace();
 }
 });
 }
}

四.效果

五.代码