Compare commits
2 Commits
4cbc6eb390
...
0905bb396d
| Author | SHA1 | Date | |
|---|---|---|---|
| 0905bb396d | |||
| 43be1fc801 |
@ -48,6 +48,7 @@ public class CustomActivityTriggerCmd extends AbstractCommand<Void> implements S
|
||||
|
||||
@Override
|
||||
public Void execute(CommandContext commandContext) {
|
||||
log.info("CustomActivityTriggerCmd execute start, dto: {}", JSON.toJSONString(dto));
|
||||
ProcessEngineConfigurationImpl processEngineConfiguration =
|
||||
CommandContextUtil.getProcessEngineConfiguration(commandContext);
|
||||
|
||||
@ -68,6 +69,7 @@ public class CustomActivityTriggerCmd extends AbstractCommand<Void> implements S
|
||||
|
||||
addComment(commandContext, task, COMMENT_TYPE_OPERATION_DESC, "已同意");
|
||||
RuntimeService runtimeService = processEngineConfiguration.getRuntimeService();
|
||||
log.info("CustomActivityTriggerCmd triggerAsync");
|
||||
runtimeService.triggerAsync(dto.getTriggerId());
|
||||
return null;
|
||||
}
|
||||
|
||||
@ -47,6 +47,7 @@ public class BpmnProcessActivityServiceImpl implements BpmnProcessActivityServic
|
||||
@Override
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public void trigger(BpmnActivityTriggerDTO dto) {
|
||||
log.info("processActivityService trigger called");
|
||||
CommandExecutor commandExecutor = processEngineConfiguration.getCommandExecutor();
|
||||
if (Boolean.TRUE.equals(dto.getAsync())) {
|
||||
commandExecutor.execute(new CustomActivityTriggerAsyncCmd(dto));
|
||||
|
||||
@ -81,6 +81,7 @@ public class BpmnProcessActivityController extends BasicPopulateAvatarController
|
||||
@Override
|
||||
@RepeatSubmit
|
||||
public CommonResponse<Boolean> trigger(@Validated @RequestBody BpmnActivityTriggerDTO dto) {
|
||||
log.info("businessNode trigger ===>>>参数:{}", JSON.toJSONString(dto));
|
||||
String header = request.getHeader(HEADER_SERVER_NAME);
|
||||
String remoteAddr = request.getRemoteAddr();
|
||||
log.info("业务节点唤醒 trigger ===>>>参数:{}, 请求来自微服务: {}, ip: {}", JSON.toJSONString(dto), header, remoteAddr);
|
||||
|
||||
Loading…
Reference in New Issue
Block a user