138 lines
5.2 KiB
Plaintext
138 lines
5.2 KiB
Plaintext
```
|
||
String finalNickName = currentUserNickName;
|
||
CompletableFuture.runAsync(() -> {
|
||
try {
|
||
if (uploadFile != null && uploadFile.exists()) {
|
||
String planUserIds = dingTalkProperties.getPlanUserId();
|
||
if (StringUtils.isNotBlank(planUserIds)) {
|
||
String mediaId = mediaService.uploadMedia("file", uploadFile.getAbsolutePath());
|
||
// 支持多人推送，假设多个 userId 以逗号分隔
|
||
String[] userIds = planUserIds.split(",");
|
||
for (String userId : userIds) {
|
||
String cleanUserId = userId.trim();
|
||
if (StringUtils.isNotBlank(cleanUserId)) {
|
||
try {
|
||
robotGroupService.sendFileToUser(cleanUserId, mediaId, originalFilename);
|
||
log.info("上传的工艺计划表已成功发送给用户: {}", cleanUserId);
|
||
} catch (Exception e) {
|
||
log.error("发送文件给用户 {} 异常", cleanUserId, e);
|
||
}
|
||
}
|
||
}
|
||
} else {
|
||
log.warn("未配置钉钉工艺计划接收人(planUserId)，跳过发送文件");
|
||
}
|
||
}
|
||
} catch (Exception e) {
|
||
log.error("发送文件给工艺计划接收人异常", e);
|
||
} finally {
|
||
if (uploadFile != null && uploadFile.exists()) {
|
||
uploadFile.delete();
|
||
}
|
||
}
|
||
```
|
||
|
||
```
|
||
/**
|
||
* 发送文件给个人
|
||
*
|
||
* @param userId 接收人userId
|
||
* @param mediaId 媒体文件ID
|
||
* @param fileName 文件名
|
||
* @return success
|
||
*/
|
||
public String sendFileToUser(String userId, String mediaId, String fileName) {
|
||
try {
|
||
Config config = new Config();
|
||
config.protocol = "https";
|
||
config.regionId = "central";
|
||
Client client = new Client(config);
|
||
|
||
BatchSendOTOHeaders headers = new BatchSendOTOHeaders();
|
||
headers.xAcsDingtalkAccessToken = tokenManager.getAccessToken();
|
||
|
||
String msgParam = String.format("{\"mediaId\":\"%s\",\"fileName\":\"%s\"}",
|
||
mediaId, fileName);
|
||
|
||
BatchSendOTORequest request = new BatchSendOTORequest()
|
||
.setRobotCode(properties.getRobotCode())
|
||
.setUserIds(Arrays.asList(userId))
|
||
.setMsgKey("sampleFile")
|
||
.setMsgParam(msgParam);
|
||
|
||
client.batchSendOTOWithOptions(request, headers, new com.aliyun.teautil.models.RuntimeOptions());
|
||
log.info("机器人个人文件发送成功, userId: {}, fileName: {}", userId, fileName);
|
||
return "success";
|
||
} catch (Exception e) {
|
||
log.error("机器人个人文件发送失败", e);
|
||
throw new DingException("机器人个人文件发送失败", e);
|
||
}
|
||
}
|
||
```
|
||
|
||
```
|
||
/**
|
||
* 发送Markdown消息给个人 (批量单聊)
|
||
*
|
||
* @param userId 接收人userId
|
||
* @param title 标题
|
||
* @param text Markdown内容
|
||
*/
|
||
public void sendMarkdownToUser(String userId, String title, String text) {
|
||
try {
|
||
Config config = new Config();
|
||
config.protocol = "https";
|
||
config.regionId = "central";
|
||
Client client = new Client(config);
|
||
|
||
BatchSendOTOHeaders headers = new BatchSendOTOHeaders();
|
||
headers.xAcsDingtalkAccessToken = tokenManager.getAccessToken();
|
||
|
||
String msgParam = String.format("{\"title\":\"%s\",\"text\":\"%s\"}",
|
||
title.replace("\"", "\\\""),
|
||
text.replace("\"", "\\\"").replace("\n", "\\n"));
|
||
|
||
BatchSendOTORequest request = new BatchSendOTORequest()
|
||
.setRobotCode(properties.getRobotCode())
|
||
.setUserIds(Collections.singletonList(userId))
|
||
.setMsgKey("sampleMarkdown")
|
||
.setMsgParam(msgParam);
|
||
|
||
client.batchSendOTOWithOptions(request, headers, new RuntimeOptions());
|
||
log.info("机器人个人Markdown消息发送成功, userId: {}, title: {}", userId, title);
|
||
} catch (Exception e) {
|
||
log.error("机器人个人Markdown消息发送失败", e);
|
||
throw new DingException("机器人个人Markdown消息发送失败", e);
|
||
}
|
||
}
|
||
```
|
||
|
||
```
|
||
/**
|
||
* 刷新AccessToken
|
||
*/
|
||
private void refresh() {
|
||
try {
|
||
Config config = new Config();
|
||
config.protocol = "https";
|
||
config.regionId = "central";
|
||
Client client = new Client(config);
|
||
GetAccessTokenRequest request = new GetAccessTokenRequest()
|
||
.setAppKey(properties.getAppKey())
|
||
.setAppSecret(properties.getAppSecret());
|
||
|
||
GetAccessTokenResponse response = client.getAccessToken(request);
|
||
if (response.getBody() != null) {
|
||
this.accessToken = response.getBody().getAccessToken();
|
||
// 设置过期时间，提前100秒刷新
|
||
this.expireTime = System.currentTimeMillis() + (response.getBody().getExpireIn() * 1000) - 100000;
|
||
log.info("钉钉AccessToken刷新成功，过期时间: {}", this.expireTime);
|
||
} else {
|
||
throw new DingException("刷新AccessToken失败，返回为空");
|
||
}
|
||
} catch (Exception e) {
|
||
log.error("刷新钉钉AccessToken失败", e);
|
||
throw new DingException("刷新钉钉AccessToken失败: " + e.getMessage(), e);
|
||
}
|
||
}
|
||
``` |