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

update:消息重发按照类型进行区分

Browse Source
This commit is contained in:
sunzheng
2024-07-29 11:24:46 +08:00
parent 424035f2c8
commit feeb980b82
1 changed files with 16 additions and 4 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/LawsUnifiedTodoLogServiceImpl.java
+16 -4
View File
@@ -11,6 +11,9 @@ import com.jero.common.api.PushWorkflowIntegrationAPI;
import com.jero.common.api.dto.message.UnifiedTodoVO;
import com.jero.common.api.vo.Result;
import com.jero.common.system.query.QueryGenerator;
import com.jero.modules.docking.feishu.dto.BotMessageDto;
import com.jero.modules.docking.feishu.dto.InstanceDto;
import com.jero.modules.docking.feishu.service.IFeiShuDockingService;
import com.jero.modules.docking.hiwork.entity.LawsUnifiedTodoLog;
import com.jero.modules.docking.hiwork.mapper.LawsUnifiedTodoLogMapper;
import com.jero.modules.docking.hiwork.service.LawsUnifiedTodoLogService;
@@ -32,6 +35,8 @@ public class LawsUnifiedTodoLogServiceImpl extends ServiceImpl<LawsUnifiedTodoLo
@Resource
private PushWorkflowIntegrationAPI pushWorkflowIntegrationAPI;
@Resource
private IFeiShuDockingService feiShuDockingService;
@Override
public Result<IPage<LawsUnifiedTodoLog>> getPage(LawsUnifiedTodoLog lawsUnifiedTodoLog, Integer pageNo,
@@ -73,10 +78,17 @@ public class LawsUnifiedTodoLogServiceImpl extends ServiceImpl<LawsUnifiedTodoLo
}
String jsonStr = lawsUnifiedTodoLogObj.getJsonStr();
// 转换为List<HiworkTodo>
List<UnifiedTodoVO> unifiedTodoVOList = JSON.parseObject(jsonStr, new TypeReference<List<UnifiedTodoVO>>() {});
pushWorkflowIntegrationAPI.sendTodoTask(unifiedTodoVOList);
Integer messageType = lawsUnifiedTodoLogObj.getMessageType();
if (messageType == 1) { // 重发OA
List<UnifiedTodoVO> unifiedTodoVOList = JSON.parseObject(jsonStr, new TypeReference<List<UnifiedTodoVO>>() {});
pushWorkflowIntegrationAPI.sendTodoTask(unifiedTodoVOList);
}else if (messageType == 2) { // 重发飞书-待办
InstanceDto instanceDto = JSON.parseObject(jsonStr, InstanceDto.class);
feiShuDockingService.synchronizeApprovalInstance(instanceDto);
}else { // 重发飞书-消息
BotMessageDto botMessageDto = JSON.parseObject(jsonStr, BotMessageDto.class);
feiShuDockingService.sendHrefMessageByBot(botMessageDto);
}
LambdaUpdateWrapper<LawsUnifiedTodoLog> queryLawsUnifiedTodoLog = new LambdaUpdateWrapper<>();
queryLawsUnifiedTodoLog.eq(LawsUnifiedTodoLog::getId,lawsUnifiedTodoLog.getId());
queryLawsUnifiedTodoLog.set(LawsUnifiedTodoLog::getState,1);