Compare commits

...

2 Commits

Author SHA1 Message Date
0905bb396d feat(REQ-5865) - 添加执行过程日志 2025-12-04 16:54:45 +08:00
43be1fc801 feat(REQ-5865) - 添加执行过程日志 2025-12-04 16:51:05 +08:00
3 changed files with 4 additions and 0 deletions

View File

@ -48,6 +48,7 @@ public class CustomActivityTriggerCmd extends AbstractCommand<Void> implements S
@Override @Override
public Void execute(CommandContext commandContext) { public Void execute(CommandContext commandContext) {
log.info("CustomActivityTriggerCmd execute start, dto: {}", JSON.toJSONString(dto));
ProcessEngineConfigurationImpl processEngineConfiguration = ProcessEngineConfigurationImpl processEngineConfiguration =
CommandContextUtil.getProcessEngineConfiguration(commandContext); CommandContextUtil.getProcessEngineConfiguration(commandContext);
@ -68,6 +69,7 @@ public class CustomActivityTriggerCmd extends AbstractCommand<Void> implements S
addComment(commandContext, task, COMMENT_TYPE_OPERATION_DESC, "已同意"); addComment(commandContext, task, COMMENT_TYPE_OPERATION_DESC, "已同意");
RuntimeService runtimeService = processEngineConfiguration.getRuntimeService(); RuntimeService runtimeService = processEngineConfiguration.getRuntimeService();
log.info("CustomActivityTriggerCmd triggerAsync");
runtimeService.triggerAsync(dto.getTriggerId()); runtimeService.triggerAsync(dto.getTriggerId());
return null; return null;
} }

View File

@ -47,6 +47,7 @@ public class BpmnProcessActivityServiceImpl implements BpmnProcessActivityServic
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void trigger(BpmnActivityTriggerDTO dto) { public void trigger(BpmnActivityTriggerDTO dto) {
log.info("processActivityService trigger called");
CommandExecutor commandExecutor = processEngineConfiguration.getCommandExecutor(); CommandExecutor commandExecutor = processEngineConfiguration.getCommandExecutor();
if (Boolean.TRUE.equals(dto.getAsync())) { if (Boolean.TRUE.equals(dto.getAsync())) {
commandExecutor.execute(new CustomActivityTriggerAsyncCmd(dto)); commandExecutor.execute(new CustomActivityTriggerAsyncCmd(dto));

View File

@ -81,6 +81,7 @@ public class BpmnProcessActivityController extends BasicPopulateAvatarController
@Override @Override
@RepeatSubmit @RepeatSubmit
public CommonResponse<Boolean> trigger(@Validated @RequestBody BpmnActivityTriggerDTO dto) { public CommonResponse<Boolean> trigger(@Validated @RequestBody BpmnActivityTriggerDTO dto) {
log.info("businessNode trigger ===>>>参数:{}", JSON.toJSONString(dto));
String header = request.getHeader(HEADER_SERVER_NAME); String header = request.getHeader(HEADER_SERVER_NAME);
String remoteAddr = request.getRemoteAddr(); String remoteAddr = request.getRemoteAddr();
log.info("业务节点唤醒 trigger ===>>>参数:{}, 请求来自微服务: {}, ip: {}", JSON.toJSONString(dto), header, remoteAddr); log.info("业务节点唤醒 trigger ===>>>参数:{}, 请求来自微服务: {}, ip: {}", JSON.toJSONString(dto), header, remoteAddr);