[新增] 权限申请流程监听器
This commit is contained in:
bupengxiang
@@ -0,0 +1,47 @@
|
|||||||
|
package com.adc.da.wkflow.listener;
|
||||||
|
|
||||||
|
import org.apache.commons.lang3.StringUtils;
|
||||||
|
|
||||||
|
public enum FlagEnum {
|
||||||
|
|
||||||
|
AGREE("1","同意"),
|
||||||
|
DISAGREE("2","不同意");
|
||||||
|
|
||||||
|
private String value;
|
||||||
|
private String label;
|
||||||
|
|
||||||
|
private FlagEnum(String value, String label) {
|
||||||
|
this.value = value;
|
||||||
|
this.label = label;
|
||||||
|
}
|
||||||
|
public String getValue() {
|
||||||
|
return value;
|
||||||
|
}
|
||||||
|
public String getLabel() {
|
||||||
|
return label;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static String getLabel(String value) {
|
||||||
|
if (StringUtils.isEmpty(value)) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
for(FlagEnum flowTypeEnum : FlagEnum.values()) {
|
||||||
|
if (value.equals(flowTypeEnum.getValue())) {
|
||||||
|
return flowTypeEnum.getLabel();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static String getName(String value) {
|
||||||
|
if (StringUtils.isEmpty(value)) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
for(FlagEnum flowTypeEnum : FlagEnum.values()) {
|
||||||
|
if (value.equals(flowTypeEnum.getValue())) {
|
||||||
|
return flowTypeEnum.name();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,26 @@
|
|||||||
|
package com.adc.da.wkflow.listener;
|
||||||
|
|
||||||
|
import com.adc.da.wkflow.business_main.entity.BusProcessNew;
|
||||||
|
import com.adc.da.wkflow.business_main.service.IBusProcessNewService;
|
||||||
|
import com.adc.da.wkflow.util.SpringContextUtil;
|
||||||
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||||
|
import org.activiti.engine.delegate.DelegateTask;
|
||||||
|
import org.activiti.engine.delegate.TaskListener;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
public class SetupPersonnelFront implements TaskListener {
|
||||||
|
@Override
|
||||||
|
public void notify(DelegateTask delegateTask) {
|
||||||
|
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
|
||||||
|
|
||||||
|
QueryWrapper queryWrapper = new QueryWrapper();
|
||||||
|
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
|
||||||
|
queryWrapper.isNull("TASK_ID");
|
||||||
|
List<BusProcessNew> list = busBean.list(queryWrapper);
|
||||||
|
if(list != null && !list.isEmpty()){
|
||||||
|
BusProcessNew bus = list.get(0);
|
||||||
|
bus.setTaskId(delegateTask.getId());
|
||||||
|
busBean.saveOrUpdate(bus);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,58 @@
|
|||||||
|
package com.adc.da.wkflow.listener.powerApply;
|
||||||
|
|
||||||
|
import com.adc.da.login.util.UserUtils;
|
||||||
|
import com.adc.da.report.dao.mysql.PowerApplyActDao;
|
||||||
|
import com.adc.da.report.eo.PowerApplyAct;
|
||||||
|
import com.adc.da.wkflow.business_main.entity.BusProcessApprove;
|
||||||
|
import com.adc.da.wkflow.business_main.entity.BusProcessNew;
|
||||||
|
import com.adc.da.wkflow.business_main.service.IBusProcessApproveService;
|
||||||
|
import com.adc.da.wkflow.business_main.service.IBusProcessNewService;
|
||||||
|
import com.adc.da.wkflow.listener.FlagEnum;
|
||||||
|
import com.adc.da.wkflow.util.SpringContextUtil;
|
||||||
|
import com.alibaba.fastjson.JSONObject;
|
||||||
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||||
|
import org.activiti.engine.delegate.DelegateTask;
|
||||||
|
import org.activiti.engine.delegate.TaskListener;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 权限申请流程 发起流程
|
||||||
|
*/
|
||||||
|
public class aid1 implements TaskListener {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void notify(DelegateTask delegateTask) {
|
||||||
|
PowerApplyActDao powerApplyActDao = SpringContextUtil.getBean(PowerApplyActDao.class);
|
||||||
|
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
|
||||||
|
IBusProcessApproveService approveService = SpringContextUtil.getBean(IBusProcessApproveService.class);
|
||||||
|
//查询task任务
|
||||||
|
LambdaQueryWrapper<PowerApplyAct> queryWrapper = new LambdaQueryWrapper<>();
|
||||||
|
queryWrapper.eq(PowerApplyAct::getTaskId, delegateTask.getId());
|
||||||
|
List<PowerApplyAct> powerApplyActs = powerApplyActDao.selectList(queryWrapper);
|
||||||
|
PowerApplyAct powerApplyAct = new PowerApplyAct();
|
||||||
|
if (powerApplyActs.size()>0){
|
||||||
|
powerApplyAct = powerApplyActs.get(0);
|
||||||
|
}
|
||||||
|
//构建工作流代办
|
||||||
|
BusProcessNew busProcessNew = new BusProcessNew();
|
||||||
|
// busProcessNew.setUserId(powerApplyAct.getUpdateUserId());
|
||||||
|
busProcessNew.setUserId(UserUtils.getUserId());
|
||||||
|
busProcessNew.setPId(delegateTask.getProcessInstanceId());
|
||||||
|
busProcessNew.setTaskInfo(delegateTask.getEventName());
|
||||||
|
busProcessNew.setTaskId(delegateTask.getId());
|
||||||
|
// busProcessNew.set(FlowTypeEnum.BGQXSQLC.getValue());
|
||||||
|
busProcessNew.setDataId(powerApplyAct.getDataId());
|
||||||
|
busBean.save(busProcessNew);
|
||||||
|
|
||||||
|
//审批结果
|
||||||
|
LambdaQueryWrapper<BusProcessApprove> approveWrapper = new LambdaQueryWrapper<>();
|
||||||
|
approveWrapper.eq(BusProcessApprove::getTaskId, delegateTask.getId());
|
||||||
|
BusProcessApprove one = approveService.getOne(approveWrapper);
|
||||||
|
String fromValsJson = one.getFromValsJson();
|
||||||
|
JSONObject object = JSONObject.parseObject(fromValsJson);
|
||||||
|
String s = object.getString("flag") == "" || object.getString("flag") == null ? FlagEnum.AGREE.getValue() : object.getString("flag");
|
||||||
|
// 1: 同意 2：退回
|
||||||
|
delegateTask.setVariable("flag",s);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,58 @@
|
|||||||
|
package com.adc.da.wkflow.listener.powerApply;
|
||||||
|
|
||||||
|
import com.adc.da.login.util.UserUtils;
|
||||||
|
import com.adc.da.report.dao.mysql.PowerApplyActDao;
|
||||||
|
import com.adc.da.report.eo.PowerApplyAct;
|
||||||
|
import com.adc.da.wkflow.business_main.entity.BusProcessApprove;
|
||||||
|
import com.adc.da.wkflow.business_main.entity.BusProcessNew;
|
||||||
|
import com.adc.da.wkflow.business_main.service.IBusProcessApproveService;
|
||||||
|
import com.adc.da.wkflow.business_main.service.IBusProcessNewService;
|
||||||
|
import com.adc.da.wkflow.listener.FlagEnum;
|
||||||
|
import com.adc.da.wkflow.util.SpringContextUtil;
|
||||||
|
import com.alibaba.fastjson.JSONObject;
|
||||||
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||||
|
import org.activiti.engine.delegate.DelegateTask;
|
||||||
|
import org.activiti.engine.delegate.TaskListener;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 权限申请流程 发起流程
|
||||||
|
*/
|
||||||
|
public class aid2 implements TaskListener {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void notify(DelegateTask delegateTask) {
|
||||||
|
PowerApplyActDao powerApplyActDao = SpringContextUtil.getBean(PowerApplyActDao.class);
|
||||||
|
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
|
||||||
|
IBusProcessApproveService approveService = SpringContextUtil.getBean(IBusProcessApproveService.class);
|
||||||
|
//查询task任务
|
||||||
|
LambdaQueryWrapper<PowerApplyAct> queryWrapper = new LambdaQueryWrapper<>();
|
||||||
|
queryWrapper.eq(PowerApplyAct::getTaskId, delegateTask.getId());
|
||||||
|
List<PowerApplyAct> powerApplyActs = powerApplyActDao.selectList(queryWrapper);
|
||||||
|
PowerApplyAct powerApplyAct = new PowerApplyAct();
|
||||||
|
if (powerApplyActs.size()>0){
|
||||||
|
powerApplyAct = powerApplyActs.get(0);
|
||||||
|
}
|
||||||
|
//构建工作流代办
|
||||||
|
BusProcessNew busProcessNew = new BusProcessNew();
|
||||||
|
// busProcessNew.setUserId(powerApplyAct.getUpdateUserId());
|
||||||
|
busProcessNew.setUserId(UserUtils.getUserId());
|
||||||
|
busProcessNew.setPId(delegateTask.getProcessInstanceId());
|
||||||
|
busProcessNew.setTaskInfo(delegateTask.getEventName());
|
||||||
|
busProcessNew.setTaskId(delegateTask.getId());
|
||||||
|
// busProcessNew.set(FlowTypeEnum.BGQXSQLC.getValue());
|
||||||
|
busProcessNew.setDataId(powerApplyAct.getDataId());
|
||||||
|
busBean.save(busProcessNew);
|
||||||
|
|
||||||
|
//审批结果
|
||||||
|
LambdaQueryWrapper<BusProcessApprove> approveWrapper = new LambdaQueryWrapper<>();
|
||||||
|
approveWrapper.eq(BusProcessApprove::getTaskId, delegateTask.getId());
|
||||||
|
BusProcessApprove one = approveService.getOne(approveWrapper);
|
||||||
|
String fromValsJson = one.getFromValsJson();
|
||||||
|
JSONObject object = JSONObject.parseObject(fromValsJson);
|
||||||
|
String s = object.getString("flag") == "" || object.getString("flag") == null ? FlagEnum.AGREE.getValue() : object.getString("flag");
|
||||||
|
// 1: 同意 2：退回
|
||||||
|
delegateTask.setVariable("flag",s);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,58 @@
|
|||||||
|
package com.adc.da.wkflow.listener.powerApply;
|
||||||
|
|
||||||
|
import com.adc.da.login.util.UserUtils;
|
||||||
|
import com.adc.da.report.dao.mysql.PowerApplyActDao;
|
||||||
|
import com.adc.da.report.eo.PowerApplyAct;
|
||||||
|
import com.adc.da.wkflow.business_main.entity.BusProcessApprove;
|
||||||
|
import com.adc.da.wkflow.business_main.entity.BusProcessNew;
|
||||||
|
import com.adc.da.wkflow.business_main.service.IBusProcessApproveService;
|
||||||
|
import com.adc.da.wkflow.business_main.service.IBusProcessNewService;
|
||||||
|
import com.adc.da.wkflow.listener.FlagEnum;
|
||||||
|
import com.adc.da.wkflow.util.SpringContextUtil;
|
||||||
|
import com.alibaba.fastjson.JSONObject;
|
||||||
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||||
|
import org.activiti.engine.delegate.DelegateTask;
|
||||||
|
import org.activiti.engine.delegate.TaskListener;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 权限申请流程 发起流程
|
||||||
|
*/
|
||||||
|
public class aid3 implements TaskListener {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void notify(DelegateTask delegateTask) {
|
||||||
|
PowerApplyActDao powerApplyActDao = SpringContextUtil.getBean(PowerApplyActDao.class);
|
||||||
|
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
|
||||||
|
IBusProcessApproveService approveService = SpringContextUtil.getBean(IBusProcessApproveService.class);
|
||||||
|
//查询task任务
|
||||||
|
LambdaQueryWrapper<PowerApplyAct> queryWrapper = new LambdaQueryWrapper<>();
|
||||||
|
queryWrapper.eq(PowerApplyAct::getTaskId, delegateTask.getId());
|
||||||
|
List<PowerApplyAct> powerApplyActs = powerApplyActDao.selectList(queryWrapper);
|
||||||
|
PowerApplyAct powerApplyAct = new PowerApplyAct();
|
||||||
|
if (powerApplyActs.size()>0){
|
||||||
|
powerApplyAct = powerApplyActs.get(0);
|
||||||
|
}
|
||||||
|
//构建工作流代办
|
||||||
|
BusProcessNew busProcessNew = new BusProcessNew();
|
||||||
|
// busProcessNew.setUserId(powerApplyAct.getUpdateUserId());
|
||||||
|
busProcessNew.setUserId(UserUtils.getUserId());
|
||||||
|
busProcessNew.setPId(delegateTask.getProcessInstanceId());
|
||||||
|
busProcessNew.setTaskInfo(delegateTask.getEventName());
|
||||||
|
busProcessNew.setTaskId(delegateTask.getId());
|
||||||
|
// busProcessNew.set(FlowTypeEnum.BGQXSQLC.getValue());
|
||||||
|
busProcessNew.setDataId(powerApplyAct.getDataId());
|
||||||
|
busBean.save(busProcessNew);
|
||||||
|
|
||||||
|
//审批结果
|
||||||
|
LambdaQueryWrapper<BusProcessApprove> approveWrapper = new LambdaQueryWrapper<>();
|
||||||
|
approveWrapper.eq(BusProcessApprove::getTaskId, delegateTask.getId());
|
||||||
|
BusProcessApprove one = approveService.getOne(approveWrapper);
|
||||||
|
String fromValsJson = one.getFromValsJson();
|
||||||
|
JSONObject object = JSONObject.parseObject(fromValsJson);
|
||||||
|
String s = object.getString("flag") == "" || object.getString("flag") == null ? FlagEnum.AGREE.getValue() : object.getString("flag");
|
||||||
|
// 1: 同意 2：退回
|
||||||
|
delegateTask.setVariable("flag",s);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,58 @@
|
|||||||
|
package com.adc.da.wkflow.listener.powerApply;
|
||||||
|
|
||||||
|
import com.adc.da.login.util.UserUtils;
|
||||||
|
import com.adc.da.report.dao.mysql.PowerApplyActDao;
|
||||||
|
import com.adc.da.report.eo.PowerApplyAct;
|
||||||
|
import com.adc.da.wkflow.business_main.entity.BusProcessApprove;
|
||||||
|
import com.adc.da.wkflow.business_main.entity.BusProcessNew;
|
||||||
|
import com.adc.da.wkflow.business_main.service.IBusProcessApproveService;
|
||||||
|
import com.adc.da.wkflow.business_main.service.IBusProcessNewService;
|
||||||
|
import com.adc.da.wkflow.listener.FlagEnum;
|
||||||
|
import com.adc.da.wkflow.util.SpringContextUtil;
|
||||||
|
import com.alibaba.fastjson.JSONObject;
|
||||||
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||||
|
import org.activiti.engine.delegate.DelegateTask;
|
||||||
|
import org.activiti.engine.delegate.TaskListener;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 权限申请流程 发起流程
|
||||||
|
*/
|
||||||
|
public class aid4 implements TaskListener {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void notify(DelegateTask delegateTask) {
|
||||||
|
PowerApplyActDao powerApplyActDao = SpringContextUtil.getBean(PowerApplyActDao.class);
|
||||||
|
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
|
||||||
|
IBusProcessApproveService approveService = SpringContextUtil.getBean(IBusProcessApproveService.class);
|
||||||
|
//查询task任务
|
||||||
|
LambdaQueryWrapper<PowerApplyAct> queryWrapper = new LambdaQueryWrapper<>();
|
||||||
|
queryWrapper.eq(PowerApplyAct::getTaskId, delegateTask.getId());
|
||||||
|
List<PowerApplyAct> powerApplyActs = powerApplyActDao.selectList(queryWrapper);
|
||||||
|
PowerApplyAct powerApplyAct = new PowerApplyAct();
|
||||||
|
if (powerApplyActs.size()>0){
|
||||||
|
powerApplyAct = powerApplyActs.get(0);
|
||||||
|
}
|
||||||
|
//构建工作流代办
|
||||||
|
BusProcessNew busProcessNew = new BusProcessNew();
|
||||||
|
// busProcessNew.setUserId(powerApplyAct.getUpdateUserId());
|
||||||
|
busProcessNew.setUserId(UserUtils.getUserId());
|
||||||
|
busProcessNew.setPId(delegateTask.getProcessInstanceId());
|
||||||
|
busProcessNew.setTaskInfo(delegateTask.getEventName());
|
||||||
|
busProcessNew.setTaskId(delegateTask.getId());
|
||||||
|
// busProcessNew.set(FlowTypeEnum.BGQXSQLC.getValue());
|
||||||
|
busProcessNew.setDataId(powerApplyAct.getDataId());
|
||||||
|
busBean.save(busProcessNew);
|
||||||
|
|
||||||
|
//审批结果
|
||||||
|
LambdaQueryWrapper<BusProcessApprove> approveWrapper = new LambdaQueryWrapper<>();
|
||||||
|
approveWrapper.eq(BusProcessApprove::getTaskId, delegateTask.getId());
|
||||||
|
BusProcessApprove one = approveService.getOne(approveWrapper);
|
||||||
|
String fromValsJson = one.getFromValsJson();
|
||||||
|
JSONObject object = JSONObject.parseObject(fromValsJson);
|
||||||
|
String s = object.getString("flag") == "" || object.getString("flag") == null ? FlagEnum.AGREE.getValue() : object.getString("flag");
|
||||||
|
// 1: 同意 2：退回
|
||||||
|
delegateTask.setVariable("flag",s);
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user