package jnpf.flowable.controller;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import jnpf.base.ActionResult;
|
import jnpf.base.UserInfo;
|
import jnpf.flowable.entity.TemplateJsonEntity;
|
import jnpf.flowable.entity.TemplateNodeEntity;
|
import jnpf.flowable.enums.NodeEnum;
|
import jnpf.flowable.model.trigger.TriggerDataFo;
|
import jnpf.message.model.TriggerDataModel;
|
import jnpf.message.model.TriggerModel;
|
import jnpf.flowable.service.TemplateJsonService;
|
import jnpf.flowable.service.TemplateNodeService;
|
import jnpf.flowable.util.OperatorUtil;
|
import jnpf.flowable.TriggerApi;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* 类的描述
|
*
|
* @author JNPF@YinMai Info. Co., Ltd
|
* @version 5.0.x
|
* @since 2024/9/11 10:39
|
*/
|
@Tag(name = "流程触发", description = "trigger")
|
@RestController
|
@RequestMapping("/trigger")
|
@Slf4j
|
public class TriggerController implements TriggerApi {
|
@Autowired
|
private OperatorUtil operatorUtil;
|
@Autowired
|
private TemplateNodeService templateNodeService;
|
@Autowired
|
private TemplateJsonService templateJsonService;
|
|
/**
|
* 任务流程触发
|
*
|
* @param model 参数
|
*/
|
@PostMapping("/Execute")
|
public ActionResult execute(@RequestBody TriggerModel model) throws Exception {
|
for (TriggerDataModel dataModel : model.getDataList()) {
|
try {
|
operatorUtil.handleTrigger(dataModel, model.getUserInfo());
|
} catch (Exception e) {
|
log.error("触发异常", e);
|
// triggerUtil.createErrorRecord();
|
}
|
}
|
return ActionResult.success();
|
}
|
|
/**
|
* 定时触发
|
*
|
* @param triggerModel 参数
|
*/
|
@PostMapping("/TimeExecute")
|
public ActionResult timeExecute(@RequestBody TriggerModel triggerModel) {
|
try {
|
operatorUtil.handleTimeTrigger(triggerModel);
|
} catch (Exception e) {
|
log.error("定时触发异常", e);
|
// triggerUtil.createErrorRecord();
|
}
|
return ActionResult.success();
|
}
|
|
/**
|
* 通知触发
|
*
|
* @param triggerModel 参数
|
*/
|
@PostMapping("/MsgExecute")
|
public ActionResult msgExecute(@RequestBody TriggerModel triggerModel) {
|
String msgId = triggerModel.getId();
|
UserInfo userInfo = triggerModel.getUserInfo();
|
|
QueryWrapper<TemplateNodeEntity> queryWrapper = new QueryWrapper<>();
|
queryWrapper.lambda().eq(TemplateNodeEntity::getNodeType, NodeEnum.noticeTrigger.getType())
|
.eq(TemplateNodeEntity::getFormId, msgId);
|
List<TemplateNodeEntity> triggerNodeList = templateNodeService.list(queryWrapper);
|
if (CollectionUtil.isNotEmpty(triggerNodeList)) {
|
List<String> flowIds = triggerNodeList.stream().map(TemplateNodeEntity::getFlowId).distinct().collect(Collectors.toList());
|
|
QueryWrapper<TemplateJsonEntity> wrapper = new QueryWrapper<>();
|
wrapper.lambda().eq(TemplateJsonEntity::getState, 1).in(TemplateJsonEntity::getId, flowIds);
|
List<TemplateJsonEntity> jsonEntityList = templateJsonService.list(wrapper);
|
|
for (TemplateNodeEntity triggerNode : triggerNodeList) {
|
String flowId = triggerNode.getFlowId();
|
TemplateJsonEntity jsonEntity = jsonEntityList.stream().filter(e -> ObjectUtil.equals(e.getId(), flowId)).findFirst().orElse(null);
|
if (null == jsonEntity) {
|
continue;
|
}
|
try {
|
operatorUtil.msgTrigger(triggerNode, userInfo);
|
} catch (Exception e) {
|
log.error("通知触发异常", e);
|
// triggerUtil.createErrorRecord();
|
}
|
}
|
}
|
return ActionResult.success();
|
}
|
|
@Override
|
@PostMapping("/getTriggerDataModel")
|
public List<TriggerDataModel> getTriggerDataModel(@RequestBody TriggerDataFo fo) {
|
return operatorUtil.getTriggerDataModel(fo);
|
}
|
}
|
