1、优化es数据同步

menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/mq/consumer/ESConsumer.java

@@ -9,6 +9,7 @@ import com.citu.module.menduner.system.dal.es.job.ESJobAdvertisedMergeDO;
 import com.citu.module.menduner.system.dal.mysql.enterprise.EnterpriseMapper;
 import com.citu.module.menduner.system.dal.mysql.job.JobAdvertisedMapper;
 import com.citu.module.menduner.system.dal.repository.ESJobAdvertisedMergeRepository;
+import com.citu.module.menduner.system.enums.job.JobStatusEnum;
 import com.citu.module.menduner.system.mq.message.ESJobAdvertisedMergeSendMessage;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
@@ -129,6 +130,9 @@ public class ESConsumer implements RocketMQListener<ESJobAdvertisedMergeSendMess
             log.error("找不到招聘职位信息 {} ", id);
             return;
         }
+        if(JobStatusEnum.DISABLE.getStatus().equals(job.getStatus())) {
+            jobDel(job.getId());
+        }
         EnterpriseDO enterpriseDO = enterpriseMapper.selectById(job.getEnterpriseId());
 
         repository.save(build(job, enterpriseDO));