feat: 企标制修订流程最后一个节点判断标准编号是否重复
This commit is contained in:
-4
@@ -10,7 +10,6 @@ import com.jero.modules.activiti.process.esRevisionAdvice.service.EsRevisionAdvi
|
||||
import com.jero.modules.activiti.process.esRevisionAdvice.service.EsRevisionService;
|
||||
import com.jero.modules.laws.common.constant.FieldCommon;
|
||||
import com.jero.modules.laws.common.service.ILawsCommonService;
|
||||
import com.jero.modules.laws.enterprise.service.EnterpriseStandardPlanService;
|
||||
import com.jero.modules.tag.enums.TableNameEnum;
|
||||
import org.activiti.engine.delegate.DelegateExecution;
|
||||
import org.activiti.engine.delegate.ExecutionListener;
|
||||
@@ -29,9 +28,6 @@ import static com.jero.modules.laws.common.constant.FieldCommon.MAIN_DRAFT_USER;
|
||||
@Component
|
||||
public class ProcessESRevisionEndListener implements ExecutionListener {
|
||||
|
||||
@Resource
|
||||
private EnterpriseStandardPlanService espService;
|
||||
|
||||
@Resource
|
||||
private EsRevisionService esRevisionService;
|
||||
|
||||
|
||||
+15
@@ -1,5 +1,6 @@
|
||||
package com.jero.modules.activiti.process.esRevisionAdvice.service.impl;
|
||||
|
||||
import com.alibaba.fastjson.JSON;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||
import com.jero.common.api.SendMessageAPI;
|
||||
@@ -29,6 +30,8 @@ import com.jero.modules.laws.common.constant.MessageTemplateCodeCommon;
|
||||
import com.jero.modules.laws.enterprise.entity.ESPProjectStatus;
|
||||
import com.jero.modules.laws.enterprise.entity.EnterpriseStandardPlan;
|
||||
import com.jero.modules.laws.enterprise.service.EnterpriseStandardPlanService;
|
||||
import com.jero.modules.laws.standard.entity.LawsEnterpriseStandard;
|
||||
import com.jero.modules.laws.standard.service.ILawsEnterpriseStandardService;
|
||||
import com.jero.modules.sys.utils.UserUtils;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.activiti.engine.RuntimeService;
|
||||
@@ -82,6 +85,9 @@ public class EsRevisionServiceImpl extends ServiceImpl<EsRevisionMapper, Process
|
||||
@Resource
|
||||
private SendMessageAPI sendMessageAPI;
|
||||
|
||||
@Resource
|
||||
private ILawsEnterpriseStandardService esService;
|
||||
|
||||
@Override
|
||||
public void startProcess(ProcessInfoVO<ProcessRevisionVO> processInfoVO) {
|
||||
// 第一个节点业务数据处理
|
||||
@@ -252,6 +258,15 @@ public class EsRevisionServiceImpl extends ServiceImpl<EsRevisionMapper, Process
|
||||
String mainDraftUser = (String) taskService.getVariable(taskId, FieldCommon.MAIN_DRAFT_USER);
|
||||
this.sendMessageToMainDraftUser(mainDraftUser, processInstanceId, maxBatchNum);
|
||||
case SET_STANDARD_NUMBER:
|
||||
// 判断标准编号是否重复
|
||||
Map<String, Object> variables = JSON.parseObject(data.getBusinessJson(), Map.class);
|
||||
String standardNumber = (String) variables.get(FieldCommon.STANDARD_NUMBER);
|
||||
LambdaQueryWrapper<LawsEnterpriseStandard> queryWrapper = new LambdaQueryWrapper<>();
|
||||
queryWrapper.eq(LawsEnterpriseStandard::getStandardNumber, variables.get(FieldCommon.STANDARD_NUMBER));
|
||||
LawsEnterpriseStandard one = esService.getOne(queryWrapper);
|
||||
if (Objects.nonNull(one)) {
|
||||
throw new JeroBootException(ResultCommon.STANDARD_NUMBER_ALREADY_EXISTS);
|
||||
}
|
||||
// 保存数据
|
||||
updateById(data);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user