Ver Fonte

1、增加面试的定时任务

rayson há 1 ano atrás
pai
commit
22ceacfe24

+ 9 - 0
menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/controller/appadmin/job/vo/AppAdminJobSimpleRespVO.java

@@ -9,4 +9,13 @@ import lombok.Data;
 @Data
 public class AppAdminJobSimpleRespVO extends JobAdvertisedSimpleRespVO {
 
+    @Schema(description = "工作地址")
+    private String address;
+
+    @Schema(description = "经度")
+    private String longitude;
+
+    @Schema(description = "维度")
+    private String latitude;
+
 }

+ 3 - 1
menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/dal/mysql/interview/InterviewInviteMapper.java

@@ -16,6 +16,7 @@ import com.citu.module.menduner.system.dal.dataobject.enterprise.EnterpriseDO;
 import com.citu.module.menduner.system.dal.dataobject.interview.InterviewInviteDO;
 import com.citu.module.menduner.system.dal.dataobject.job.JobAdvertisedDO;
 import com.citu.module.menduner.system.dal.dataobject.person.PersonInfoDO;
+import com.citu.module.menduner.system.enums.interview.InterviewInviteStatusEnum;
 import org.apache.ibatis.annotations.Mapper;
 
 import java.time.LocalDateTime;
@@ -83,7 +84,7 @@ public interface InterviewInviteMapper extends BaseMapperX<InterviewInviteDO> {
 
         query.innerJoin(JobAdvertisedDO.class, JobAdvertisedDO::getId, InterviewInviteDO::getJobId);
         query.eq(InterviewInviteDO::getEnterpriseId, enterpriseId);
-        query.eq(InterviewInviteDO::getUserId, userId);
+        query.eq(InterviewInviteDO::getInviteUserId, userId);
         query
                 .eqIfPresent(InterviewInviteDO::getJobId, reqVO.getJobId())
                 .eqIfPresent(InterviewInviteDO::getType, reqVO.getType())
@@ -121,6 +122,7 @@ public interface InterviewInviteMapper extends BaseMapperX<InterviewInviteDO> {
         // 设置查询条件,筛选time在threeHoursAgo和now之间的记录
         query.ge(InterviewInviteDO::getTime, threeHoursAgo);
         query.le(InterviewInviteDO::getTime, now);
+        query.eq(InterviewInviteDO::getStatus, InterviewInviteStatusEnum.PENDING_INTERVIEW.getStatus());
 
         return selectJoinList(InterviewInviteDO.class, query);
     }

+ 3 - 2
menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/scheduled/InterviewInviteScheduled.java

@@ -2,13 +2,13 @@ package com.citu.module.menduner.system.scheduled;
 
 import cn.hutool.core.collection.CollUtil;
 import com.citu.framework.tenant.core.aop.TenantIgnore;
-import com.citu.module.menduner.system.controller.app.interview.vo.AppInterviewInviteRespVO;
 import com.citu.module.menduner.system.dal.dataobject.interview.InterviewInviteDO;
 import com.citu.module.menduner.system.dal.mysql.interview.InterviewInviteMapper;
 import com.citu.module.menduner.system.enums.interview.InterviewInviteStatusEnum;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.util.StopWatch;
 
@@ -32,8 +32,9 @@ public class InterviewInviteScheduled {
      * 即将到达的面试提醒
      * 每隔5分钟扫描一遍
      **/
+    @Async
     @TenantIgnore
-    @Scheduled(cron = "* 5 * * * ?")
+    @Scheduled(cron = "0 */5 * * * ?")
     public void approachingInterview() {
         List<InterviewInviteDO> list = mapper.getApproachingInterviewList();