spdm消息通知

This commit is contained in:
2025-12-03 11:22:24 +08:00
parent caa5695661
commit 13f4d6f70d
2 changed files with 2 additions and 6 deletions

View File

@@ -400,6 +400,7 @@ public class RemoteServiceImpl implements IRemoteService {
messageOpenApiDTO.setContent("收到一条" + process.getName() + "审批任务代办,请前往任务中心-代办任务-流程任务审批");
messageOpenApiDTO.setStaffCode(String.valueOf(processNodeRecordAssignUserParamDto.getUserId()));
messageOpenApiDTO.setTenantCode(String.valueOf(TenantContextHolder.getTenantId()));
log.info("审批节点发送通知消息:{}", JSON.toJSONString(messageOpenApiDTO));
remoteMessageService.pushMessage(messageOpenApiDTO);
return R.ok();
}

View File

@@ -344,11 +344,6 @@ public class MessageListServiceImpl extends ServiceImpl<MessageListMapper, Messa
log.error("新增消息列表:消息枚举值查询消息配置为空,枚举值为 {} ", configKey);
throw new HoneycomException(MsgErrorType.MESSAGE_ADD_ERROR.getCode());
}
R<SysUserEntity> userByUsername = honeycomUserServiceFeign.getUserByUsername(dto.getStaffCode(), SecurityConstants.FROM_IN);
if (!userByUsername.isSuccess() || Objects.isNull(userByUsername.getData())) {
log.error("无法根据工号信息获取获取到用户信息!");
throw new HoneycomException(MsgErrorType.RECEIVER_NOT_EXITS.getCode());
}
MessageListEntity messageListEntity = new MessageListEntity();
BeanUtils.copyProperties(messageConfig, messageListEntity, "id");
messageListEntity.setConfigId(messageConfig.getId());
@@ -363,7 +358,7 @@ public class MessageListServiceImpl extends ServiceImpl<MessageListMapper, Messa
throw new HoneycomException(MsgErrorType.MESSAGE_ADD_ERROR.getCode());
}
//调用接口判断是否发布
isRelease(messageListEntity, messageConfig, Collections.singletonList(userByUsername.getData().getUserId()));
isRelease(messageListEntity, messageConfig, Collections.singletonList(Long.valueOf(dto.getStaffCode())));
}
/**