From e4cdc7621b6be4039feba033eeaa915093d4956a Mon Sep 17 00:00:00 2001 From: SUNJIABIN Date: Tue, 20 Jun 2023 11:46:56 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=90=8C=E6=AD=A5es=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E7=9A=84=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sarBussionessStandState/sync/StateSync.java | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) 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); + } } }