1、优化es数据同步

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

@@ -107,7 +107,7 @@ public class ESConsumer implements RocketMQListener<ESJobAdvertisedMergeSendMess
                     break;
             }
             log.info("消息处理完备[{}]", message);
-        }catch (Exception ex) {
+        } catch (Exception ex) {
             ex.printStackTrace();
         }
 
@@ -130,12 +130,13 @@ public class ESConsumer implements RocketMQListener<ESJobAdvertisedMergeSendMess
             log.error("找不到招聘职位信息 {} ", id);
             return;
         }
-        if(JobStatusEnum.DISABLE.getStatus().equals(job.getStatus())) {
+        if (JobStatusEnum.DISABLE.getStatus().equals(job.getStatus())) {
             jobDel(job.getId());
         }
-        EnterpriseDO enterpriseDO = enterpriseMapper.selectById(job.getEnterpriseId());
-
-        repository.save(build(job, enterpriseDO));
+        if (JobStatusEnum.ENABLE.getStatus().equals(job.getStatus())) {
+            EnterpriseDO enterpriseDO = enterpriseMapper.selectById(job.getEnterpriseId());
+            repository.save(build(job, enterpriseDO));
+        }
     }
 
     /**

menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/mq/producer/ESProducer.java

@@ -54,7 +54,8 @@ public class ESProducer {
         rocketMQTemplate.syncSend(
                 ESJobAdvertisedMergeSendMessage.TOPIC,
                 message,
-                10000
+                10000,
+                2
         );
     }