From 0496aed6e04c5084f05ce1035ba9ec38e3d4e9c7 Mon Sep 17 00:00:00 2001 From: xiejun <xiejun@vci-tech.com> Date: 星期五, 01 十一月 2024 15:17:41 +0800 Subject: [PATCH] 集成获取mdm分发通用数据格式接口集成 --- Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingDataSyncScheduling.java | 63 +++++++++++++++++++++++++++++++ 1 files changed, 63 insertions(+), 0 deletions(-) diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingDataSyncScheduling.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingDataSyncScheduling.java new file mode 100644 index 0000000..07f5124 --- /dev/null +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/Scheduling/DockingDataSyncScheduling.java @@ -0,0 +1,63 @@ +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涓� + * 浠巇ockingtask涓彇鍑烘潵鏁版嵁锛屾帹閫佸嚭鍘荤殑鎿嶄綔 + */ +@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); + } + +} -- Gitblit v1.9.3