Compare commits
2 Commits
4cbc6eb390
...
0905bb396d
| Author | SHA1 | Date | |
|---|---|---|---|
| 0905bb396d | |||
| 43be1fc801 |
@ -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;
|
||||||
}
|
}
|
||||||
|
|||||||
@ -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));
|
||||||
|
|||||||
@ -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);
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user