Merge remote-tracking branch 'origin/fix_foton_20230613' into fix_foton_20230613

This commit is contained in:
gaojiabao
2023-06-20 13:24:15 +08:00
@@ -1,5 +1,7 @@
package com.adc.da.slrs.sarBussionessStandState.sync; 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.dao.SarBussionessStandDao;
import com.adc.da.slrs.sarBussionessStand.entity.SarBussionessStand; import com.adc.da.slrs.sarBussionessStand.entity.SarBussionessStand;
import com.adc.da.slrs.sarBussionessStandState.entity.SarBussionessStandState; import com.adc.da.slrs.sarBussionessStandState.entity.SarBussionessStandState;
@@ -53,6 +55,8 @@ public class StateSync {
@Autowired @Autowired
private ISarUpdLogService sarUpdLogEOService; private ISarUpdLogService sarUpdLogEOService;
@Autowired
private ResetSearchCenterServiceTemp resetSearchCenterServiceTemp;
/** /**
* 根据配置文件设置是否开启定时器 * 根据配置文件设置是否开启定时器
*/ */
@@ -382,8 +386,13 @@ public class StateSync {
} }
} }
} }
@Scheduled(cron = "0 30 13 * * ?") @Scheduled(cron = "0 0 1 * * ?")//每天一点执行同步es任务
public void shangBan(){ public void ALLSearchCenter()throws Exception{
logger.info("下午的工作时间开始了,加油!"); if (isNotScheduled){
logger.info("开始执行es数据同步");
SearchCenter searchCenter = new SearchCenter();
searchCenter.setExecType("ALL");
resetSearchCenterServiceTemp.syncResetALLSearchCenter(searchCenter);
}
} }
} }