新增同步es数据的定时任务

This commit is contained in:
SUNJIABIN
2023-06-20 11:46:56 +08:00
parent 24d44f8eef
commit e4cdc7621b
@@ -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);
}
}
}