QR/laws_chery_serve
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

飞书与oa异步发送

Browse Source
This commit is contained in:
梁琦涛
2024-08-15 11:45:52 +08:00
parent 8489db70d7
commit c6f1def54a
2 changed files with 30 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
laws-modules-docking/src/main/java/com/jero/modules/docking/hiwork/service/impl/SendFeiShuServiceImpl.java
+15 -3
View File
@@ -29,6 +29,8 @@ import javax.annotation.Resource;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.List; import java.util.List;
import java.util.Objects; import java.util.Objects;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ForkJoinPool;
/** /**
* *
@@ -74,11 +76,16 @@ public class SendFeiShuServiceImpl implements ISendFeiShuService {
if(CollectionUtils.isEmpty(unifiedTodoVOList)){ if(CollectionUtils.isEmpty(unifiedTodoVOList)){
return; return;
} }
sendData(unifiedTodoVOList); try {
log.info("发送飞书开始");
sendData(unifiedTodoVOList);
log.info("发送飞书结束");
}catch (Exception e){
log.error("飞书发送异常" + e.getMessage());
}
} }
private void sendData(List<UnifiedTodoVO> unifiedTodoVOList){ private void sendData(List<UnifiedTodoVO> unifiedTodoVOList){
for (UnifiedTodoVO unifiedTodoVO : unifiedTodoVOList) { for (UnifiedTodoVO unifiedTodoVO : unifiedTodoVOList) {
ProcessApprovalRecord processApprovalRecord = ProcessApprovalRecord processApprovalRecord =
processApprovalRecordService.getById(unifiedTodoVO.getRecordId()); processApprovalRecordService.getById(unifiedTodoVO.getRecordId());
@@ -107,6 +114,7 @@ public class SendFeiShuServiceImpl implements ISendFeiShuService {
queryProcessApprovalRecord.eq(ProcessApprovalRecord::getNodeId,processApprovalRecord.getNodeId()); queryProcessApprovalRecord.eq(ProcessApprovalRecord::getNodeId,processApprovalRecord.getNodeId());
long l = processApprovalRecordService.count(queryProcessApprovalRecord); long l = processApprovalRecordService.count(queryProcessApprovalRecord);
if(l == 1 && Objects.equals(processApprovalRecord.getNodeId(),processNode.getXmlNodeId())){ if(l == 1 && Objects.equals(processApprovalRecord.getNodeId(),processNode.getXmlNodeId())){
log.info("=============结束发送飞书");
continue; continue;
} }
@@ -178,7 +186,11 @@ public class SendFeiShuServiceImpl implements ISendFeiShuService {
.replace("{nodeId}",processApprovalRecord.getNodeId()); .replace("{nodeId}",processApprovalRecord.getNodeId());
String appBusinessLink = appUrl.replace("{url}", Objects.requireNonNull(ProcessTypeEnum.getFontReturnUrlPc(processAll.getPrcType()))); String appBusinessLink = appUrl.replace("{url}", Objects.requireNonNull(ProcessTypeEnum.getFontReturnUrlPc(processAll.getPrcType())));
instanceDto.setReviewPcLink(appBusinessLink); instanceDto.setReviewPcLink(appBusinessLink);
feiShuDockingService.synchronizeApprovalInstance(instanceDto); log.info("=============发送飞书");
ForkJoinPool pool = new ForkJoinPool();
CompletableFuture.runAsync(() -> {
feiShuDockingService.synchronizeApprovalInstance(instanceDto);
},pool);
} }
} }
} }
laws-modules-docking/src/main/java/com/jero/modules/docking/hiwork/service/impl/UnifiedTodoServiceImpl.java
+15 -14
View File
@@ -40,6 +40,8 @@ import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Objects; import java.util.Objects;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ForkJoinPool;
/** /**
* @Author: liao * @Author: liao
@@ -99,6 +101,7 @@ public class UnifiedTodoServiceImpl implements PushWorkflowIntegrationAPI {
return; return;
// throw new JeroBootException(ResultCommon.EMPTY_COMMON, "unifiedTodoVOList"); // throw new JeroBootException(ResultCommon.EMPTY_COMMON, "unifiedTodoVOList");
} }
long l = System.currentTimeMillis();
String newDate = DateUtil.formatDateTime(new Date()); String newDate = DateUtil.formatDateTime(new Date());
for (UnifiedTodoVO unifiedTodoVO : unifiedTodoVOList) { for (UnifiedTodoVO unifiedTodoVO : unifiedTodoVOList) {
String date = unifiedTodoVO.getDate(); String date = unifiedTodoVO.getDate();
@@ -111,26 +114,24 @@ public class UnifiedTodoServiceImpl implements PushWorkflowIntegrationAPI {
String reqJsonString = JSONObject.toJSONString(unifiedTodoVOList); String reqJsonString = JSONObject.toJSONString(unifiedTodoVOList);
String jsonString = JSONObject.toJSONString(unifiedTodoList); String jsonString = JSONObject.toJSONString(unifiedTodoList);
log.info("统一待办推送入参" + jsonString); log.info("统一待办推送入参" + jsonString);
long l = System.currentTimeMillis(); ForkJoinPool pool = new ForkJoinPool();
push(ip + todoUrl,jsonString,reqJsonString, unifiedTodoList.get(0).getRequestname()); CompletableFuture.runAsync(() -> {
long l1 = System.currentTimeMillis(); push(ip + todoUrl,jsonString,reqJsonString, unifiedTodoList.get(0).getRequestname());
System.out.println("===========================OA" + (l1-l)); },pool);
}catch (Exception e){ }catch (Exception e){
log.error("统一待办推送异常",e); log.error("统一待办推送异常" + e);
} }
long l1 = System.currentTimeMillis();
System.out.println("===========================OA" + (l1-l));
} }
@Override @Override
public void sendTodoTaskByFeiShu(List<UnifiedTodoVO> unifiedTodoVOList) { public void sendTodoTaskByFeiShu(List<UnifiedTodoVO> unifiedTodoVOList) {
try { long l = System.currentTimeMillis();
long l = System.currentTimeMillis(); // 发送飞书
// 发送飞书 sendFeiShuService.sendTodoTask(unifiedTodoVOList);
sendFeiShuService.sendTodoTask(unifiedTodoVOList); long l1 = System.currentTimeMillis();
long l1 = System.currentTimeMillis(); System.out.println("===========================feishu" + (l1-l));
System.out.println("===========================feishu" + (l1-l));
}catch (Exception e){
log.error("飞书发送异常",e.getMessage());
}
} }
private void push(String url, String jsonString,String reqJsonString, String title) { private void push(String url, String jsonString,String reqJsonString, String title) {