|
@@ -229,6 +229,10 @@ public class ESConsumer implements RocketMQListener<ESJobAdvertisedMergeSendMess
|
|
|
|
|
|
List<JobAdvertisedDO> jobAdvertisedList = jobAdvertisedMapper.selectList();
|
|
|
for (JobAdvertisedDO job : jobAdvertisedList) {
|
|
|
+ // 判断职位是否过期
|
|
|
+ if (checkJobExpireTime(job)) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
EnterpriseDO enterpriseDO = enterpriseMapper.selectById(job.getEnterpriseId());
|
|
|
repository.save(build(job, enterpriseDO));
|
|
|
}
|