¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.vci.ubcs.code.Scheduling; |
| | | |
| | | import com.vci.ubcs.code.service.ICodeDuckingSyncService; |
| | | import com.vci.ubcs.starter.web.enumpck.BooleanEnum; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.scheduling.annotation.Scheduled; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import javax.annotation.PostConstruct; |
| | | import javax.annotation.Resource; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.Date; |
| | | |
| | | /** |
| | | * éæä»»å¡å®æ¶å¨ |
| | | * æå
¥dockingtaskä¸ |
| | | * ä»dockingtaskä¸ååºæ¥æ°æ®ï¼æ¨éåºå»çæä½ |
| | | */ |
| | | @Component |
| | | @Slf4j |
| | | public class DockingDataSyncScheduling { |
| | | |
| | | // private Logger logger = LoggerFactory.getLogger(getClass()); |
| | | |
| | | @Resource |
| | | private ICodeDuckingSyncService codeDuckingSyncServiceI; |
| | | |
| | | @Value("${dataSyncPush.isStart:false}") |
| | | public boolean DATA_SYNC_PUSH_ISSTARE; |
| | | |
| | | /** |
| | | * æ¯å¦åå§åå®æäº |
| | | */ |
| | | public static volatile String FINISH_INIT = "false"; |
| | | |
| | | /** |
| | | * å¨åå§åå®æåæ§è¡ |
| | | */ |
| | | @PostConstruct() |
| | | public void onInit(){ |
| | | FINISH_INIT = "true"; |
| | | } |
| | | |
| | | /** |
| | | * é»è®¤æ¯åéæ§è¡æ¹æ³ |
| | | */ |
| | | @Scheduled(cron = "${dataSyncPush.cronTime:0 0/10 * * * ?}") |
| | | public void scheduled() { |
| | | log.info("æ§è¡ä¸»æ°æ®éææ°æ®æ¨é start"); |
| | | if(DATA_SYNC_PUSH_ISSTARE && BooleanEnum.TRUE.getValue().equalsIgnoreCase(FINISH_INIT)) { |
| | | codeDuckingSyncServiceI.DockingDataSyncScheduing(); |
| | | SimpleDateFormat formatter= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss."); |
| | | String time = formatter.format(new Date()); |
| | | String outinfo = time+"============ æ§è¡äºä¸»æ°æ®éææ°æ®æ¨é"; |
| | | log.info(outinfo); |
| | | } |
| | | log.info("æ§è¡ä¸»æ°æ®éææ°æ®æ¨é end: "+ "å¼å
³æ¯å¦å¼å¯:" +DATA_SYNC_PUSH_ISSTARE); |
| | | } |
| | | |
| | | } |