leietal/senmesh-zc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix 消息通知接收方

Browse Source
This commit is contained in:
ran.shang
2025-06-26 17:58:41 +08:00
parent 881f196ef1
commit d10b7ca6d2
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/main/java/com/newyetai/recruit/position/service/impl/PositionRegistrationServiceImpl.java
View File

@@ -332,7 +332,9 @@ public class PositionRegistrationServiceImpl implements PositionRegistrationServ
ActionUtils.diff(operatorDTO.getId(), PositionRegistration.builder().status(PositionRegistrationStatusEnum.ALREADY_REGISTERED.getStatus()).build() ActionUtils.diff(operatorDTO.getId(), PositionRegistration.builder().status(PositionRegistrationStatusEnum.ALREADY_REGISTERED.getStatus()).build()
, PositionRegistration.builder().status(PositionRegistrationStatusEnum.WAIT_FOR_AN_INTERVIEW.getStatus()).build()); , PositionRegistration.builder().status(PositionRegistrationStatusEnum.WAIT_FOR_AN_INTERVIEW.getStatus()).build());
// 发送通知 // 发送通知
sendNotice(NoticeTemplateCodeEnum.POSITION_INVITE, positionRegistrationMapper.noticeInvite(operatorDTO.getId(), UserContextHolder.getLoginUserId())); sendNotice(NoticeTemplateCodeEnum.POSITION_INVITE, positionRegistrationDTO.getUserId(),
positionRegistrationMapper.noticeInvite(operatorDTO.getId(),
UserContextHolder.getLoginUserId()));
} }
@@ -387,20 +389,26 @@ public class PositionRegistrationServiceImpl implements PositionRegistrationServ
, PositionRegistration.builder().status(operatorDTO.getStatus()).build()); , PositionRegistration.builder().status(operatorDTO.getStatus()).build());
// 发送通知 // 发送通知
if (PositionRegistrationStatusEnum.FAIL_THE_INTERVIEW.getStatus().equals(operatorDTO.getStatus())){ if (PositionRegistrationStatusEnum.FAIL_THE_INTERVIEW.getStatus().equals(operatorDTO.getStatus())){
sendNotice(NoticeTemplateCodeEnum.POSITION_INTERVIEW_FAIL, positionRegistrationMapper.noticeInterview(operatorDTO.getId(), UserContextHolder.getLoginUserId())); sendNotice(NoticeTemplateCodeEnum.POSITION_INTERVIEW_FAIL, positionRegistrationDTO.getUserId(),
positionRegistrationMapper.noticeInterview(operatorDTO.getId(),
UserContextHolder.getLoginUserId()));
} else { } else {
sendNotice(NoticeTemplateCodeEnum.POSITION_INTERVIEW_PASS, positionRegistrationMapper.noticeInterview(operatorDTO.getId(), UserContextHolder.getLoginUserId())); sendNotice(NoticeTemplateCodeEnum.POSITION_INTERVIEW_PASS,
positionRegistrationDTO.getUserId(),
positionRegistrationMapper.noticeInterview(operatorDTO.getId(),
UserContextHolder.getLoginUserId()));
} }
} }
//发送站内信 //发送站内信
private void sendNotice(NoticeTemplateCodeEnum templateCodeEnum, Map<String, Object> contentParamDataMap) { private void sendNotice(NoticeTemplateCodeEnum templateCodeEnum, Long receiverUserId, Map<String, Object> contentParamDataMap) {
String templateCode = templateCodeEnum.getType(); String templateCode = templateCodeEnum.getType();
try { try {
NoticeSendRecordOperateDTO sendRecordOperateDTO = NoticeSendRecordOperateDTO.builder() NoticeSendRecordOperateDTO sendRecordOperateDTO = NoticeSendRecordOperateDTO.builder()
.templateCode(templateCode) .templateCode(templateCode)
.channelType(NoticeChannelTypeEnum.SITE.getType()) .channelType(NoticeChannelTypeEnum.SITE.getType())
.contentParamDataMap(contentParamDataMap) .contentParamDataMap(contentParamDataMap)
.receiverUserIds(Sets.newHashSet(receiverUserId))
.build(); .build();
noticeSendRecordService.create(sendRecordOperateDTO); noticeSendRecordService.create(sendRecordOperateDTO);
} catch (Exception e) { } catch (Exception e) {