diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStandState/sync/StateSync.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStandState/sync/StateSync.java index 360b982f..2fb73bc5 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStandState/sync/StateSync.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStandState/sync/StateSync.java @@ -1,5 +1,7 @@ package com.adc.da.slrs.sarBussionessStandState.sync; +import com.adc.da.search.bean.SearchCenter; +import com.adc.da.search.server.ResetSearchCenterServiceTemp; import com.adc.da.slrs.sarBussionessStand.dao.SarBussionessStandDao; import com.adc.da.slrs.sarBussionessStand.entity.SarBussionessStand; import com.adc.da.slrs.sarBussionessStandState.entity.SarBussionessStandState; @@ -53,6 +55,8 @@ public class StateSync { @Autowired private ISarUpdLogService sarUpdLogEOService; + @Autowired + private ResetSearchCenterServiceTemp resetSearchCenterServiceTemp; /** * 根据配置文件设置是否开启定时器 */ @@ -382,8 +386,13 @@ public class StateSync { } } } - @Scheduled(cron = "0 30 13 * * ?") - public void shangBan(){ - logger.info("下午的工作时间开始了,加油!"); + @Scheduled(cron = "0 0 1 * * ?")//每天一点执行同步es任务 + public void ALLSearchCenter()throws Exception{ + if (isNotScheduled){ + logger.info("开始执行es数据同步"); + SearchCenter searchCenter = new SearchCenter(); + searchCenter.setExecType("ALL"); + resetSearchCenterServiceTemp.syncResetALLSearchCenter(searchCenter); + } } }