面试通知

src/main/java/cn/timer/api/controller/zpgl/sevice/ZpglServiceImpl.java

@@ -214,12 +214,24 @@ public class ZpglServiceImpl implements ZpglService {
         if(count && JxglEnumInterface.ResumeStatus.INTERVIEW.equals(zpglRcxxDto.getStatus()) && JxglEnumInterface.NoticeWay.WECHAT_PUBLIC.equals(zpglRcxxDto.getNoticeWay())){
         if(count && JxglEnumInterface.ResumeStatus.INTERVIEW.equals(zpglRcxxDto.getStatus()) && JxglEnumInterface.NoticeWay.WECHAT_PUBLIC.equals(zpglRcxxDto.getNoticeWay())){
             InterviewNotice interviewNotice = new InterviewNotice();
             InterviewNotice interviewNotice = new InterviewNotice();
             interviewNotice.setName(zpglRcxxEntity.getName());
             interviewNotice.setName(zpglRcxxEntity.getName());
+            interviewNotice.setType(zpglRcxxDto.getNoticeWay());
+            interviewNotice.setEmail(zpglRcxxEntity.getMail());
+            //公众号类型 1：8小时企业管理 2：优领人才网
+            interviewNotice.setWxgzhType(1);
+            //1 即时发送，2 定时发送
+            interviewNotice.setTiming(1);
             interviewNotice.setInterviewTime(zpglRcxxDto.getInterviewTime());
             interviewNotice.setInterviewTime(zpglRcxxDto.getInterviewTime());
             // 通知面试官
             // 通知面试官
-            interviewNotice.setMobile("");
+            YgglMainEmp ygglMainEmp = YgglMainEmp.builder().build().selectOne(new QueryWrapper<YgglMainEmp>().select("phone").lambda()
+                    .eq(YgglMainEmp::getOrgCode, userBean.getOrgCode()).eq(YgglMainEmp::getEmpNum, zpglRcxxDto.getId()));
+            if(!StringUtils.isEmpty(ygglMainEmp)){
+                interviewNotice.setMobile(ygglMainEmp.getPhone());
+                interviewNotice.setYgglMainEmpId(ygglMainEmp.getId());
+            }
             interviewNotice.setTemplateId(MessageTemplate.TEMPLATE_ID_TO_INTERVIEWER);
             interviewNotice.setTemplateId(MessageTemplate.TEMPLATE_ID_TO_INTERVIEWER);
             zpglWxgzptService.addInterviewMessageQueue(interviewNotice);
             zpglWxgzptService.addInterviewMessageQueue(interviewNotice);
             // 通知面试者
             // 通知面试者
+            interviewNotice.setZpglRcxxId(zpglRcxxEntity.getId());
             interviewNotice.setMobile(zpglRcxxEntity.getMobile());
             interviewNotice.setMobile(zpglRcxxEntity.getMobile());
             interviewNotice.setTemplateId(MessageTemplate.TEMPLATE_ID_TO_INTERVIEWEE);
             interviewNotice.setTemplateId(MessageTemplate.TEMPLATE_ID_TO_INTERVIEWEE);
             zpglWxgzptService.addInterviewMessageQueue(interviewNotice);
             zpglWxgzptService.addInterviewMessageQueue(interviewNotice);

src/main/java/cn/timer/api/controller/zpgl/sevice/ZpglWxgzptServiceImpl.java

@@ -34,6 +34,7 @@ public class ZpglWxgzptServiceImpl implements ZpglWxgzptService {
      * @param map
      * @param map
      * @return
      * @return
      */
      */
+    @Override
     public String addMessageQueue(Map<String, Object> map) {
     public String addMessageQueue(Map<String, Object> map) {
         return HttpUtil.post(serverUrl + "/wxgzh/addMessageQueue", map);
         return HttpUtil.post(serverUrl + "/wxgzh/addMessageQueue", map);
     }
     }
@@ -45,6 +46,7 @@ public class ZpglWxgzptServiceImpl implements ZpglWxgzptService {
      * @param interviewNotice
      * @param interviewNotice
      * @return
      * @return
      */
      */
+    @Override
     public String addInterviewMessageQueue(InterviewNotice interviewNotice) {
     public String addInterviewMessageQueue(InterviewNotice interviewNotice) {
         //消息队列对象
         //消息队列对象
         MessageQueueDto mqd = new MessageQueueDto();
         MessageQueueDto mqd = new MessageQueueDto();

src/main/java/cn/timer/api/dto/wxgzh/MessageQueueDto.java

@@ -104,6 +104,16 @@ public class MessageQueueDto {
      */
      */
     private Date updateTime;
     private Date updateTime;
 
 
+    /**
+     * 人才信息ID
+     */
+    private Integer zpglRcxxId;
+
+    /**
+     * 员工档案表ID
+     */
+    private Integer ygglMainEmpId;
+
     @TableField(exist = false)
     @TableField(exist = false)
     private static final long serialVersionUID = 1L;
     private static final long serialVersionUID = 1L;