suzhuhong/zxjp-web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

预约面试发送消息卡片修改方法遗漏

Browse Source
This commit is contained in:
feng.li
2023-10-25 15:21:44 +08:00
parent 4c73375592
commit 3acf5ad9bc
2 changed files with 33 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
coolstore-partner-service/src/main/java/com/cool/store/service/impl/HyPartnerInterviewPlanServiceImpl.java
View File

@@ -10,6 +10,7 @@ import com.cool.store.dto.partner.PartnerInterviewInfoDTO;
import com.cool.store.entity.*;
import com.cool.store.enums.*;
import com.cool.store.exception.ApiException;
import com.cool.store.http.EventCenterHttpRequest;
import com.cool.store.http.ISVHttpRequest;
import com.cool.store.mapper.HyPartnerInterviewMapper;
import com.cool.store.mapper.HyPartnerInterviewPlanMapper;
@@ -34,10 +35,7 @@ import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.*;
import java.util.stream.Collectors;
/**
@@ -83,6 +81,8 @@ public class HyPartnerInterviewPlanServiceImpl implements HyPartnerInterviewPlan
@Resource
HyPartnerUserChannelDAO hyPartnerUserChannelDAO;
@Autowired
private EventCenterHttpRequest eventCenterHttpRequest;
@Value("${feishu.notice.link.url}")
private String linkUrl;
@@ -269,17 +269,20 @@ public class HyPartnerInterviewPlanServiceImpl implements HyPartnerInterviewPlan
return;
}
//发送消息
List<String> userIds = remindInterviewMsgDTOS.stream().map(RemindInterviewMsgDTO::getInterviewerId).collect(Collectors.toList());
Map<String, String> feishuUserIdsByUserIds = enterpriseUserDAO.getFeishuUserIdsByUserIds(userIds);
remindInterviewMsgDTOS.stream().forEach(interviewMsgDTO->{
try {
List<String> userIds = new ArrayList<>();
userIds.add(interviewMsgDTO.getInterviewerId());
SendCardMessageDTO sendCardMessageDTO = new SendCardMessageDTO();
sendCardMessageDTO.setUserIds(userIds);
sendCardMessageDTO.setMessageType(FeiShuNoticeMsgEnum.INTERVIEW_APPOINTMENT);
sendCardMessageDTO.setMessageUrl(linkUrl);
sendCardMessageDTO.setTitle("面试预约申请");
sendCardMessageDTO.setContent(interviewService.generateFeiShuInterviewMsg(interviewMsgDTO.getPartnerName(), interviewMsgDTO.getPartnerMobile(), interviewMsgDTO.getStartTime()));
isvHttpRequest.sendFeiShuCardMessage(sendCardMessageDTO);
// SendCardMessageDTO sendCardMessageDTO = new SendCardMessageDTO();
// sendCardMessageDTO.setUserIds(userIds);
// sendCardMessageDTO.setMessageType(FeiShuNoticeMsgEnum.INTERVIEW_APPOINTMENT);
// sendCardMessageDTO.setMessageUrl(linkUrl);
// sendCardMessageDTO.setTitle("面试预约申请");
// sendCardMessageDTO.setContent(interviewService.generateFeiShuInterviewMsg(interviewMsgDTO.getPartnerName(), interviewMsgDTO.getPartnerMobile(), interviewMsgDTO.getStartTime()));
//替换为事件中心发送
eventCenterHttpRequest.sendFeiShuNotice(FeiShuNoticeMsgEnum.INTERVIEW_APPOINTMENT,
Arrays.asList(feishuUserIdsByUserIds.get(interviewMsgDTO.getInterviewerId())),
interviewMsgDTO.getPartnerName(), interviewMsgDTO.getPartnerMobile(), interviewMsgDTO.getStartTime());
} catch (ApiException e) {
log.error("发送面试提醒消息失败",e);
}

28
coolstore-partner-service/src/main/java/com/cool/store/service/impl/InterviewServiceImpl.java
View File

@@ -21,6 +21,7 @@ import com.cool.store.entity.*;
import com.cool.store.enums.*;
import com.cool.store.exception.ApiException;
import com.cool.store.exception.ServiceException;
import com.cool.store.http.EventCenterHttpRequest;
import com.cool.store.http.ISVHttpRequest;
import com.cool.store.mapper.*;
import com.cool.store.request.*;
@@ -42,10 +43,7 @@ import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import java.util.*;
/**
* @Author: young.yu
@@ -100,6 +98,10 @@ public class InterviewServiceImpl implements InterviewService {
@Autowired
private WechatMiniAppService wechatMiniAppService;
@Autowired
private EventCenterHttpRequest eventCenterHttpRequest;
@Override
public List<InterviewVO> getInterviewList(GetInterviewListReq request) {
List<InterviewVO> interviewList = hyPartnerInterviewPlanMapper.getInterviewList(request);
@@ -493,13 +495,17 @@ public class InterviewServiceImpl implements InterviewService {
InterviewVO interviewVO = hyPartnerInterviewPlanMapper.getInterviewInfo(String.valueOf(interviewPlanId));
List<String> userIds = new ArrayList<>();
userIds.add(interviewrId);
SendCardMessageDTO sendCardMessageDTO = new SendCardMessageDTO();
sendCardMessageDTO.setUserIds(userIds);
sendCardMessageDTO.setMessageType(FeiShuNoticeMsgEnum.INTERVIEW_APPOINTMENT);
sendCardMessageDTO.setMessageUrl(linkUrl);
sendCardMessageDTO.setTitle("面试预约申请");
sendCardMessageDTO.setContent(generateFeiShuInterviewMsg(interviewVO.getPartnerName(), interviewVO.getPartnerMobile(), interviewVO.getStartTime()));
isvHttpRequest.sendFeiShuCardMessage(sendCardMessageDTO);
Map<String, String> feishuUserIdsByUserIds = enterpriseUserDAO.getFeishuUserIdsByUserIds(userIds);
// SendCardMessageDTO sendCardMessageDTO = new SendCardMessageDTO();
// sendCardMessageDTO.setUserIds(userIds);
// sendCardMessageDTO.setMessageType(FeiShuNoticeMsgEnum.INTERVIEW_APPOINTMENT);
// sendCardMessageDTO.setMessageUrl(linkUrl);
// sendCardMessageDTO.setTitle("面试预约申请");
// sendCardMessageDTO.setContent(generateFeiShuInterviewMsg(interviewVO.getPartnerName(), interviewVO.getPartnerMobile(), interviewVO.getStartTime()));
//替换为通过事件中心发送消息
eventCenterHttpRequest.sendFeiShuNotice(FeiShuNoticeMsgEnum.INTERVIEW_APPOINTMENT,
Arrays.asList(feishuUserIdsByUserIds.get(interviewrId)),
interviewVO.getPartnerName(), interviewVO.getPartnerMobile(), interviewVO.getStartTime());
//记录日志
PartnerUserInfoVO operator = PartnerUserHolder.getUser();