wulin/wl_management
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

一键催办使用线程发送

Browse Source
This commit is contained in:
wulin 2020-12-17 14:42:57 +08:00
parent caa3c109d8
commit f8ff21cf14
1 changed files with 58 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

98
src/main/java/com/lz/modules/job/business/DingtalkBusiness.java
View File

@ -985,49 +985,67 @@ public class DingtalkBusiness {
}
public void urging(List<FlowRecord> flowRecords, Map<Long, StaffEntity> mapStaffs, Map<Long, ResultRecord> mapReords) {
logger.info("批量催办");
ThirdAppConfig thirdAppConfig = thirdAppConfigService.getByAppId(appid);
String token = dingTalkUtil.getAccessTokenWitchEntity(thirdAppConfig);
if(token != null && token.length() > 0){
ThreadSendUrgingMessage threadSendUrgingMessage = new ThreadSendUrgingMessage(flowRecords, mapReords, mapStaffs);
Thread thread = new Thread(threadSendUrgingMessage);
thread.start();
for (FlowRecord flowRecord:flowRecords
) {
ResultRecord record = mapReords.get(flowRecord.getRecordId());
StaffEntity info = mapStaffs.get(flowRecord.getApprovalStaffId());
if(record != null && info != null){
String url = homeUrl;
if(url.contains("?")){
url += "&halokit=" + System.currentTimeMillis();
}else{
url += "?halokit=" + System.currentTimeMillis();
}
url += ("&detail=1&id=" + record.getId());
url = URLEncoder.encode(url);
url = "dingtalk://dingtalkclient/action/openapp?corpid=" + thirdAppConfig.getCorpId() +
"&container_type=work_platform&app_id=0_" +
appid + "&redirect_type=jump&redirect_url=" + url;
logger.info("发送消息给{}，url:{}", info, url);
String content = null;
if(!record.getStaffName().equals(info.getName())){
content = WorkMsgTypeEnum.URGING.getContent().replace("@", record.getStaffName());
}else{
content = WorkMsgTypeEnum.URGING.getContent().replace("@", "您");
}
dingTalkUtil.sendSingleActionCardMSG(appid, info, WorkMsgTypeEnum.URGING.getTitle(),
content, WorkMsgTypeEnum.URGING.getBtnText(), url, token);
}else{
logger.info("无对应的record");
}
}
}else{
logger.info("token无效"); ;
}
}
public class ThreadSendUrgingMessage implements Runnable{
List<FlowRecord> flowRecords;
Map<Long, ResultRecord> mapReords;
Map<Long, StaffEntity> mapStaffs;
public ThreadSendUrgingMessage(List<FlowRecord> flowRecords, Map<Long, ResultRecord> mapReords, Map<Long, StaffEntity> mapStaffs){
this.flowRecords = flowRecords;
this.mapReords = mapReords;
this.mapStaffs = mapStaffs;
}
@Override
public void run() {
logger.info("批量催办");
ThirdAppConfig thirdAppConfig = thirdAppConfigService.getByAppId(appid);
String token = dingTalkUtil.getAccessTokenWitchEntity(thirdAppConfig);
if(token != null && token.length() > 0){
for (FlowRecord flowRecord:flowRecords
) {
ResultRecord record = mapReords.get(flowRecord.getRecordId());
StaffEntity info = mapStaffs.get(flowRecord.getApprovalStaffId());
if(record != null && info != null){
String url = homeUrl;
if(url.contains("?")){
url += "&halokit=" + System.currentTimeMillis();
}else{
url += "?halokit=" + System.currentTimeMillis();
}
url += ("&detail=1&id=" + record.getId());
url = URLEncoder.encode(url);
url = "dingtalk://dingtalkclient/action/openapp?corpid=" + thirdAppConfig.getCorpId() +
"&container_type=work_platform&app_id=0_" +
appid + "&redirect_type=jump&redirect_url=" + url;
logger.info("发送消息给{}，url:{}", info, url);
String content = null;
if(!record.getStaffName().equals(info.getName())){
content = WorkMsgTypeEnum.URGING.getContent().replace("@", record.getStaffName());
}else{
content = WorkMsgTypeEnum.URGING.getContent().replace("@", "您");
}
dingTalkUtil.sendSingleActionCardMSG(appid, info, WorkMsgTypeEnum.URGING.getTitle(),
content, WorkMsgTypeEnum.URGING.getBtnText(), url, token);
}else{
logger.info("无对应的record");
}
}
}else{
logger.info("token无效"); ;
}
}
}
public class ThreadSendMessage implements Runnable{
List<StaffSimpleInfo> toStaffids;