package com.gs.dingtalk.service.impl;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.dingtalk.api.response.OapiV2UserGetbymobileResponse;
|
import com.google.gson.Gson;
|
import com.gs.dingtalk.dto.DingTalkMessage;
|
import com.gs.dingtalk.dto.DingTalkResponse;
|
import com.gs.dingtalk.entity.SendDingtalk;
|
import com.gs.dingtalk.entity.SendMessage;
|
import com.gs.dingtalk.mapper.SendDingtalkMapper;
|
import com.gs.dingtalk.service.SendDingtalkService;
|
import com.gs.dingtalk.service.SendMessageService;
|
import com.gs.dingtalk.service.SimpleExample;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.time.LocalDateTime;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
|
@Service
|
@RequiredArgsConstructor
|
@Transactional(rollbackFor = Exception.class)
|
public class SendDingtalkServiceImpl extends ServiceImpl<SendDingtalkMapper, SendDingtalk> implements SendDingtalkService {
|
|
|
private final SimpleExample simpleExample;
|
|
private final SendMessageService sendMessageService;
|
|
@Override
|
public void getDingTalkUserId() throws Exception {
|
String accessToken = simpleExample.getAccessToken();
|
|
LambdaQueryWrapper<SendDingtalk> wrapper = new LambdaQueryWrapper<>();
|
wrapper.isNull(SendDingtalk::getUserId);
|
List<SendDingtalk> list = list(wrapper);
|
|
list.forEach(s -> {
|
|
OapiV2UserGetbymobileResponse rsp = simpleExample.getOapiV2UserGetbymobileResponse(s, accessToken);
|
|
// 使用 Gson 解析响应数据
|
Gson gson = new Gson();
|
DingTalkResponse response = gson.fromJson(rsp.getBody(), DingTalkResponse.class);
|
|
if ("ok".equals(response.getErrmsg())) {
|
|
List<String> exclusiveAccountUseridList = response.getResult().getExclusiveAccountUseridList();
|
|
String userId = "";
|
if (CollectionUtil.isNotEmpty(exclusiveAccountUseridList)) {
|
userId = exclusiveAccountUseridList.get(0);
|
} else if (StrUtil.isNotEmpty(response.getResult().getUserid())) {
|
userId = response.getResult().getUserid();
|
}
|
|
LambdaUpdateWrapper<SendDingtalk> updateWrapper = new LambdaUpdateWrapper<>();
|
updateWrapper.set(SendDingtalk::getUserId, userId).eq(SendDingtalk::getId, s.getId());
|
|
update(updateWrapper);
|
}
|
|
});
|
}
|
|
@Override
|
public void sendDingTalkFiveMinute() throws Exception {
|
|
LambdaQueryWrapper<SendDingtalk> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(SendDingtalk::getFiveMinuteReminder, 1);
|
|
List<SendDingtalk> list = list(wrapper);
|
|
getMessage(list, 5);
|
}
|
|
@Override
|
public void sendDingTalkthirtyMinute() throws Exception {
|
LambdaQueryWrapper<SendDingtalk> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(SendDingtalk::getThirtyMinuteReminder, 1);
|
|
List<SendDingtalk> list = list(wrapper);
|
|
getMessage(list, 30);
|
}
|
|
@Override
|
public void chatSendMessage() throws Exception {
|
List<SendMessage> sendMessageList = sendMessageService.getSendMessageList();
|
|
sendMessageList.forEach(s -> {
|
|
//钉钉的规则限制 给同一员工一天只能发送一条内容相同的消息通知。
|
String message = s.getLineName() + s.getProcName() + ",请尽快处理";
|
|
DingTalkResponse dingTalkResponse = null;
|
|
try {
|
dingTalkResponse = simpleExample.chatSendMessage(message);
|
} catch (Exception e) {
|
throw new RuntimeException(e);
|
}
|
|
if (dingTalkResponse != null) {
|
if (dingTalkResponse.getErrcode() == 0) {
|
System.out.println("发送成功");
|
}
|
}
|
|
});
|
}
|
|
private void getMessage(List<SendDingtalk> list, int Minutes) {
|
List<SendMessage> sendMessageList = sendMessageService.getSendMessageList();
|
|
sendMessageList.forEach(s -> {
|
|
// 获取当前时间的 LocalDateTime，忽略秒
|
LocalDateTime now = LocalDateTime.now().withSecond(0).withNano(0);
|
|
// 比较时间，判断 sendDate 是否大于当前时间五分钟
|
boolean isGreaterThanFiveMinutes = s.getSendDate().plusMinutes(Minutes).isBefore(now);
|
|
if (!isGreaterThanFiveMinutes) {
|
return;
|
}
|
|
String userIdList = list.stream().filter(dingtalk -> {
|
String[] purviews = dingtalk.getPurview().split(",");
|
return Arrays.asList(purviews).contains(s.getProcNo());
|
}).map(SendDingtalk::getUserId).collect(Collectors.joining(","));
|
|
String message = s.getLineName() + s.getProcName() + ",请尽快处理";
|
|
DingTalkMessage dingTalkMessage = null;
|
try {
|
dingTalkMessage = simpleExample.sendMessage(userIdList, message);
|
} catch (Exception e) {
|
throw new RuntimeException(e);
|
}
|
|
if (dingTalkMessage.getErrcode() == 0) {
|
System.out.println("发送成功");
|
}
|
});
|
}
|
}
|
