From 859d6321b1b1c606de09e9b6a6286aaeace638fe Mon Sep 17 00:00:00 2001 From: yangys <y_ys79@sina.com> Date: 星期三, 16 十月 2024 21:03:52 +0800 Subject: [PATCH] 接收采集数据,增加了使用配置数据点限制,配置了的数据点才会保存。未配置则丢弃 --- collect/src/main/java/com/qianwen/mdc/collect/runner/InitRunner.java | 8 ++++---- 1 files changed, 4 insertions(+), 4 deletions(-) diff --git a/collect/src/main/java/com/qianwen/mdc/collect/runner/InitRunner.java b/collect/src/main/java/com/qianwen/mdc/collect/runner/InitRunner.java index 4bc3d32..e97e613 100644 --- a/collect/src/main/java/com/qianwen/mdc/collect/runner/InitRunner.java +++ b/collect/src/main/java/com/qianwen/mdc/collect/runner/InitRunner.java @@ -30,13 +30,13 @@ private TimeSliceCache timeSliceCache; @Autowired private DeviceStateMapper deviceStateMapper; - @Autowired - private WorkstationAppMappingService mappingService;; + //@Autowired + //private WorkstationAppMappingService mappingService;; @Override public void run(ApplicationArguments args) throws Exception { - mappingService.saveToCache(); + //mappingService.saveToCache(); //鐢熸垚鏃堕棿鍒囩墖 CacheBuildDTO cacheBuildDTO = CacheBuildDTO.builder().tenantIds(Sets.newHashSet(new String[]{"000000"})).targetDate(LocalDate.now()).build(); @@ -48,7 +48,7 @@ //@RedisLock("posting:lock:initStateFixPoint") public void checkNeedStateFixPoint() { DateTime dateTime = DateTime.now(); - log.info("杩涘叆绋嬪簭鍚姩鏍¢獙鏄惁瀛樺湪宸ヤ綅鎵撹繃鍥哄畾鐐�....... "); + log.info("绋嬪簭鍚姩鏍¢獙鏄惁瀛樺湪宸ヤ綅鎵撹繃鍥哄畾鐐�....... "); Long count = deviceStateMapper.fixPointCountByDate(Integer.valueOf(DatePattern.PURE_DATE_FORMAT.format(dateTime))); /* -- Gitblit v1.9.3