feat: 年度制修订-主动上报流程发消息

This commit is contained in:
2024-01-29 09:04:30 +08:00
parent c9e62d7968
commit 93227f81e5
2 changed files with 29 additions and 3 deletions
@@ -4,6 +4,8 @@ import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.jero.common.api.CommonAPI;
import com.jero.common.api.dto.message.SendMessageDTO;
import com.jero.common.api.vo.SendMessageAPI;
import com.jero.common.aspect.TranslationAspect;
import com.jero.common.constant.enums.YesOrNoEnum;
import com.jero.common.exception.JeroBootException;
@@ -19,12 +21,14 @@ import com.jero.modules.activiti.process.esAnnualReport.mapper.ProcessEsAnnualRe
import com.jero.modules.activiti.process.esAnnualReport.service.ProcessEsAnnualReportService;
import com.jero.modules.activiti.process.esInitChange.entity.enums.ESPChangeType;
import com.jero.modules.activiti.process.esInitChange.entity.enums.ESPProjectType;
import com.jero.modules.activiti.process.esRevision.entity.HandleAdviceEnum;
import com.jero.modules.activiti.process.fb.dto.BasicProcessInfoDTO;
import com.jero.modules.activiti.process.fb.service.IProcessHandleService;
import com.jero.modules.activiti.process.fb.vo.ProcessInfoVO;
import com.jero.modules.activiti.service.ProcessAllService;
import com.jero.modules.activiti.service.ProcessNodeLinkService;
import com.jero.modules.activiti.util.ExcelUtils;
import com.jero.modules.laws.common.constant.MessageTemplateCodeCommon;
import com.jero.modules.laws.common.util.ImportUtil;
import com.jero.modules.laws.standard.entity.LawsEnterpriseStandard;
import com.jero.modules.laws.standard.service.ILawsEnterpriseStandardService;
@@ -91,6 +95,9 @@ public class ProcessEsAnnualReportServiceImpl extends ServiceImpl<ProcessEsAnnua
@Resource
private TranslationAspect translationAspect;
@Resource
private SendMessageAPI sendMessageAPI;
@Override
public void startProcess(AnnualReportDataVO annualReportData) {
// 流程Key
@@ -130,7 +137,7 @@ public class ProcessEsAnnualReportServiceImpl extends ServiceImpl<ProcessEsAnnua
Integer prcType = ProcessTypeEnum.ES_ANNUAL_REPORT.getValue();
actFlowCommonService.updateProcessAll(processInstanceId, userId, prcName, prcMes, prcType, dueTime);
// 执行流程发起前的操作
this.startRunTask(annualReportData);
this.startRunTask(annualReportData, processInstanceId);
}
public Map<String, Object> setVariables(AnnualReportDataVO annualReportData) {
@@ -152,8 +159,26 @@ public class ProcessEsAnnualReportServiceImpl extends ServiceImpl<ProcessEsAnnua
return variables;
}
public void startRunTask(AnnualReportDataVO annualReportDataVO) {
// TODO info部长
public void startRunTask(AnnualReportDataVO annualReportDataVO, String processInstanceId) {
ProcessAll processAll = processAllService.getByProcessInstanceId(processInstanceId);
// 发消息
CommonVO commonVO = annualReportDataVO.getCommonVO();
Map<String, Object> flowUser = annualReportDataVO.getFlowUser();
String contactUsers = (String) flowUser.get("contactUserList");
String processDescription = commonVO.getProcessDescription();
String[] contactUserList = contactUsers.split(",");
for (String contactUser : contactUserList) {
SendMessageDTO sendMessageDTO = new SendMessageDTO();
sendMessageDTO.setTemplateCode(MessageTemplateCodeCommon.ES_ANNUAL_REPORT_CONTACT_USER);
sendMessageDTO.setToUserId(contactUser);
Map<String, String> sendMap = new HashMap<>();
sendMap.put("prcNum", processAll.getPrcNum());
sendMap.put("prcName", processAll.getPrcName());
sendMap.put("description", processDescription);
sendMessageDTO.setMap(sendMap);
sendMessageAPI.sendMessage(sendMessageDTO);
}
}
@Override
@@ -27,5 +27,6 @@ public class MessageTemplateCodeCommon {
public static final String ES_INIT_CHANGE_MAIN_DRAFT_USER_COPY = "es_init_change_main_draft_user_copy"; // 【企标立项变更】抄送主起草人
public static final String ES_REVISION_STANDARD_RELEASE = "es_revision_standard_release"; // 【企标修订】标准发布
public static final String ES_REVISION_ADVICE = "es_revision_advice"; // 【企标修订】征求意见
public static final String ES_ANNUAL_REPORT_CONTACT_USER = "es_annual_report_contact_user"; // 【企标年度制修订-各部门主动上报】部门联络人下发
}