远通数据源接入机制:

①系统启动时执行全数据检查机制
②每天每个整点的10分和15分分别执行原始数据和小时用水量数据的检查 检查范围为
小时用水量 当前时间到昨天23点的数据
历史数据 当前时间到昨天0点的数据

src/main/java/com/shkpr/service/aimodelpower/bizmgr/KprAimTapWaterBizFun.java

@@ -4,22 +4,18 @@ import com.global.base.log.LogLevelFlag;
 import com.global.base.log.LogPrintMgr;
 import com.global.base.tools.FastJsonUtil;
 import com.shkpr.service.aimodelpower.commtools.TimeTool;
-import com.shkpr.service.aimodelpower.constants.LogFlagBusiType;
 import com.shkpr.service.aimodelpower.dbdao.DBMgrProxy;
-import com.shkpr.service.aimodelpower.dbdao.otherDataSource.service.intef.WaterTapWaterService;
+import com.shkpr.service.aimodelpower.dbdao.shizilaishuiDataSource.service.intef.WaterTapWaterService;
 import com.shkpr.service.aimodelpower.dto.TraceRunnable;
 import com.shkpr.service.aimodelpower.globalmgr.ThreadTaskMgr;
 import com.shkpr.service.aimodelpower.globalmgr.TraceLogMgr;
-import org.apache.commons.collections.list.SynchronizedList;
 import org.springframework.util.CollectionUtils;
 
-import java.text.DateFormat;
 import java.time.Duration;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
 import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 /**

src/main/java/com/shkpr/service/aimodelpower/controllerapi/CustomXXXController.java

@@ -8,7 +8,7 @@ import com.shkpr.service.aimodelpower.commtools.HttpTool;
 import com.shkpr.service.aimodelpower.constants.ApiURI;
 import com.shkpr.service.aimodelpower.constants.LogFlagBusiType;
 import com.shkpr.service.aimodelpower.controllerfilter.TokenAuthenticationService;
-import com.shkpr.service.aimodelpower.dbdao.otherDataSource.WaterZILAISHUIDao;
+import com.shkpr.service.aimodelpower.dbdao.shizilaishuiDataSource.WaterZILAISHUIDao;
 import com.shkpr.service.aimodelpower.dto.MsgNotifyBean;
 import com.shkpr.service.aimodelpower.dto.ResponseCode;
 import com.shkpr.service.aimodelpower.dto.ResponseRes;

src/main/java/com/shkpr/service/aimodelpower/dbdao/DBMgrProxy.java

@@ -1,7 +1,7 @@
 package com.shkpr.service.aimodelpower.dbdao;
 
 import com.shkpr.service.aimodelpower.SpringContextUtil;
-import com.shkpr.service.aimodelpower.dbdao.otherDataSource.service.intef.WaterTapWaterService;
+import com.shkpr.service.aimodelpower.dbdao.shizilaishuiDataSource.service.intef.WaterTapWaterService;
 import com.shkpr.service.aimodelpower.dbdao.services.intef.*;
 
 public class DBMgrProxy {

src/main/java/com/shkpr/service/aimodelpower/dbdao/otherDataSource/TestDao.java

@@ -1,4 +1,4 @@
-package com.shkpr.service.aimodelpower.dbdao.otherDataSource;
+package com.shkpr.service.aimodelpower.dbdao.shizilaishuiDataSource;
 
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.jdbc.core.JdbcTemplate;

src/main/java/com/shkpr/service/aimodelpower/dbdao/otherDataSource/WaterZILAISHUIDao.java

@@ -1,4 +1,4 @@
-package com.shkpr.service.aimodelpower.dbdao.otherDataSource;
+package com.shkpr.service.aimodelpower.dbdao.shizilaishuiDataSource;
 
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;

src/main/java/com/shkpr/service/aimodelpower/dbdao/otherDataSource/service/WaterTapWaterServiceImpl.java

@@ -1,19 +1,12 @@
-package com.shkpr.service.aimodelpower.dbdao.otherDataSource.service;
+package com.shkpr.service.aimodelpower.dbdao.shizilaishuiDataSource.service;
 
 
 import com.global.base.log.LogLevelFlag;
-import com.global.base.log.LogPrintMgr;
-import com.shkpr.service.aimodelpower.commtools.CommTool;
-import com.shkpr.service.aimodelpower.constants.LogFlagBusiType;
-import com.shkpr.service.aimodelpower.dbdao.mapper.UserMapper;
-import com.shkpr.service.aimodelpower.dbdao.otherDataSource.WaterZILAISHUIDao;
-import com.shkpr.service.aimodelpower.dbdao.otherDataSource.service.intef.WaterTapWaterService;
-import com.shkpr.service.aimodelpower.dbdao.services.intef.UserDBService;
-import com.shkpr.service.aimodelpower.dbdao.tables.UserTable;
+import com.shkpr.service.aimodelpower.dbdao.shizilaishuiDataSource.WaterZILAISHUIDao;
+import com.shkpr.service.aimodelpower.dbdao.shizilaishuiDataSource.service.intef.WaterTapWaterService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 

src/main/java/com/shkpr/service/aimodelpower/dbdao/otherDataSource/service/intef/WaterTapWaterService.java

@@ -1,4 +1,4 @@
-package com.shkpr.service.aimodelpower.dbdao.otherDataSource.service.intef;
+package com.shkpr.service.aimodelpower.dbdao.shizilaishuiDataSource.service.intef;
 
 import java.util.List;
 import java.util.Map;