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

fix

Browse Source
This commit is contained in:
zhangchenbiao
2024-05-21 11:17:23 +08:00
parent cca3d71b25
commit ccfa009237
4 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
coolstore-partner-dao/src/main/java/com/cool/store/dao/LineInterviewDAO.java
View File

@@ -100,7 +100,7 @@ public class LineInterviewDAO {
* @param intervalMinutes
* @return
*/
public List<LineInterviewDO> getInterviewRemindList(Integer intervalMinutes) {
return lineInterviewMapper.getInterviewRemindList(intervalMinutes);
public List<LineInterviewDO> getInterviewRemindList(String startTime, String endTime) {
return lineInterviewMapper.getInterviewRemindList(startTime, endTime);
}
}

5
coolstore-partner-dao/src/main/java/com/cool/store/mapper/LineInterviewMapper.java
View File

@@ -71,8 +71,9 @@ public interface LineInterviewMapper extends Mapper<LineInterviewDO> {
/**
* 获取面试提醒列表
* @param intervalMinutes
* @param startTime
* @param endTime
* @return
*/
List<LineInterviewDO> getInterviewRemindList(@Param("intervalMinutes") Integer intervalMinutes);
List<LineInterviewDO> getInterviewRemindList(@Param("startTime") String startTime, @Param("endTime") String endTime);
}

2
coolstore-partner-dao/src/main/resources/mapper/LineInterviewMapper.xml
View File

@@ -127,7 +127,7 @@
</update>
<select id="getInterviewRemindList" resultMap="BaseResultMap">
select * from xfsg_line_interview where deleted = '0' and interview_type in (1, 2) and start_time between date_sub(now(), interval #{intervalMinutes} minute) and date_add(now(), interval #{intervalMinutes} minute)
select * from xfsg_line_interview where deleted = '0' and interview_type in (1, 2) and start_time between #{startTime} and #{endTime}
</select>
</mapper>

6
coolstore-partner-web/src/main/java/com/cool/store/job/XxlJobHandler.java
View File

@@ -40,7 +40,9 @@ import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.Instant;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;
@@ -451,7 +453,9 @@ public class XxlJobHandler {
@XxlJob("interviewRemind")
public void interviewRemind() {
log.info("------面试提醒------");
List<LineInterviewDO> interviewList = lineInterviewDAO.getInterviewRemindList(CommonConstants.FIVE);
String startTime = LocalDateTime.now().plusHours(1).minusMinutes(CommonConstants.FIVE).format(DateTimeFormatter.ofPattern(CoolDateUtils.DATE_FORMAT_SEC));
String endTime = LocalDateTime.now().plusHours(1).plusMinutes(CommonConstants.FIVE).format(DateTimeFormatter.ofPattern(CoolDateUtils.DATE_FORMAT_SEC));
List<LineInterviewDO> interviewList = lineInterviewDAO.getInterviewRemindList(startTime, endTime);
if (CollectionUtils.isEmpty(interviewList)) {
log.info("------今日没有待更新数据------");
return;