From 5e658e1ad328feeeca1133ae96f987d82186580a Mon Sep 17 00:00:00 2001 From: gaoshuguang Date: Mon, 18 Nov 2024 10:40:47 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/nm/gsgl/common/Constant.java | 1 + .../common/timetask/TaskThreadPoolConfig.java | 24 +++++++++++++ .../nm/gsgl/common/timetask/TimeTaskInfo.java | 23 +++++++++++++ .../com/nm/gsgl/common/utils/LogUtil.java | 5 +++ .../service/CallSendOutInterfaceService.java | 7 ++++ .../impl/CallSendOutInterfaceServiceImpl.java | 34 +++++++++++++++++-- .../main/resources/static/timeTask.properties | 2 ++ 7 files changed, 93 insertions(+), 3 deletions(-) diff --git a/ParamDownload/src/main/java/com/nm/gsgl/common/Constant.java b/ParamDownload/src/main/java/com/nm/gsgl/common/Constant.java index 1d17c7c3..e4b76b9b 100644 --- a/ParamDownload/src/main/java/com/nm/gsgl/common/Constant.java +++ b/ParamDownload/src/main/java/com/nm/gsgl/common/Constant.java @@ -234,6 +234,7 @@ public class Constant { public static final String STR_TO_DATE_FORMAT = "DATE_FORMAT(MMMMM,'%Y-%m-%d') = 'NNNNN'"; public static final String SELECT_ALL_ROAD_MIN_FEE_TABLE = "SELECT VERSION,VALIDTIME,ENPROV,ENID,EXPROV,EXID,FEEINFO FROM ALLROADMINFEE_TABLE"; public static final String SQLITE_PRE = "jdbc:sqlite:"; + public static final String SEND_FZX_HANG_TABLE_URL = "http://10.15.110.216:9020/SendCallBack/paramDownload/sendFZXHangTable"; } diff --git a/ParamDownload/src/main/java/com/nm/gsgl/common/timetask/TaskThreadPoolConfig.java b/ParamDownload/src/main/java/com/nm/gsgl/common/timetask/TaskThreadPoolConfig.java index f900abde..5e682a2d 100644 --- a/ParamDownload/src/main/java/com/nm/gsgl/common/timetask/TaskThreadPoolConfig.java +++ b/ParamDownload/src/main/java/com/nm/gsgl/common/timetask/TaskThreadPoolConfig.java @@ -18,6 +18,30 @@ import java.util.concurrent.ThreadPoolExecutor; @EnableScheduling // 开启定时任务 @EnableAsync //开启对异步定时任务的支持 public class TaskThreadPoolConfig { + @Bean("threadPoolSendFZXHangTable") // bean的名称，默认为首字母小写的方法名 + public Executor threadPoolSendFZXHangTable() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + //线程前缀名 + executor.setThreadNamePrefix("timeTaskSendFZXHangTable-thread-"); + //最大线程数 + executor.setMaxPoolSize(1); + //核心线程数 + executor.setCorePoolSize(1); + //任务队列的大小 + executor.setQueueCapacity(5); + //这种策略下，因为线程池已经无法接纳新的任务了，那么谁提交的这个任务，谁就去跑这个业务； + // + //比如，主线程向线程池提交了一个任务，线程池已经不能接纳这个任务了，那么此时就会让这个提交任务的主线程去执行这个任务； + // + //这种策略有两点好处：（1）这种策略，避免了业务损失；（2）可以让任务提交的速度降低下来，比如主线程提交的任务被打回来后，主线程就必须执行完这个被打回来的任务后，才能够向线程池提交下一个任务，而这就相当于给了线程池一个缓冲的时间； + //executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + //这种策略，会默默的把新来的这个任务给丢弃；我们不会得到通知； + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy()); + //线程初始化 + executor.initialize(); + + return executor; + } @Bean("threadPoolIntoDatabase241") // bean的名称，默认为首字母小写的方法名 public Executor threadPoolIntoDatabase241() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); diff --git a/ParamDownload/src/main/java/com/nm/gsgl/common/timetask/TimeTaskInfo.java b/ParamDownload/src/main/java/com/nm/gsgl/common/timetask/TimeTaskInfo.java index 098810d1..20aa273b 100644 --- a/ParamDownload/src/main/java/com/nm/gsgl/common/timetask/TimeTaskInfo.java +++ b/ParamDownload/src/main/java/com/nm/gsgl/common/timetask/TimeTaskInfo.java @@ -95,6 +95,29 @@ public class TimeTaskInfo { LogUtil.WriteLog_MinFee("[uuid:" + uuid + "]-]定时ETC参数(最小费额)下载及处理服务执行完成,耗时毫秒=" + (end - start), "TimeTaskInfo-timeTaskMinFee"); } + /** + * 根据配置时间定时是否调用自动下发接口 + * + * @author shuguang + * @date 2023-07-24 10:37 + */ + @Async("threadPoolSendFZXHangTable") + @Scheduled(cron = "${time.corn10}") + public void timeTaskSendFZXHangTable() { + String uuid = UuidUtil.getUuid(); + LogUtil.WriteLog_SendFZXHangTableInterface("[uuid:" + uuid + "]-定时调用自动下发接口下发分中心省内黑名单表，当前时间=" + LocalDateTime.now(), "TimeTaskInfo-timeTaskSendFZXHangTable"); + + long start = System.currentTimeMillis(); + boolean b = callSendOutInterfaceService.SendFZXHangTableInterface(uuid); + long end = System.currentTimeMillis(); + if (b) { + LogUtil.WriteLog_SendFZXHangTableInterface("[uuid:" + uuid + "]-]定时调用自动下发接口下发分中心省内黑名单表执行完成,耗时毫秒=" + (end - start), "TimeTaskInfo-timeTaskSendFZXHangTable"); + + } else { + LogUtil.WriteLog_SendFZXHangTableInterface("[uuid:" + uuid + "]-]当前程序不调用自动下发接口下发分中心省内黑名单表,耗时毫秒=" + (end - start), "TimeTaskInfo-timeTaskSendFZXHangTable"); + + } + } /** * 根据配置时间定时是否调用自动下发接口 * diff --git a/ParamDownload/src/main/java/com/nm/gsgl/common/utils/LogUtil.java b/ParamDownload/src/main/java/com/nm/gsgl/common/utils/LogUtil.java index 25767370..443e225a 100644 --- a/ParamDownload/src/main/java/com/nm/gsgl/common/utils/LogUtil.java +++ b/ParamDownload/src/main/java/com/nm/gsgl/common/utils/LogUtil.java @@ -51,6 +51,11 @@ public class LogUtil { String fileName = f.format(new Date()) + "_InsertDB"; WriteLog(fileName, msg, disStr); } + public static void WriteLog_SendFZXHangTableInterface(String msg, String disStr) { + SimpleDateFormat f = new SimpleDateFormat("yyyy-MM-dd-HH"); + String fileName = f.format(new Date()) + "_SendFZXHangTableInterface"; + WriteLog(fileName, msg, disStr); + } public static void WriteLog_CallDisInterface(String msg, String disStr) { SimpleDateFormat f = new SimpleDateFormat("yyyy-MM-dd-HH"); String fileName = f.format(new Date()) + "_CallDisInterface"; diff --git a/ParamDownload/src/main/java/com/nm/gsgl/service/CallSendOutInterfaceService.java b/ParamDownload/src/main/java/com/nm/gsgl/service/CallSendOutInterfaceService.java index 06c0cc56..59eed46b 100644 --- a/ParamDownload/src/main/java/com/nm/gsgl/service/CallSendOutInterfaceService.java +++ b/ParamDownload/src/main/java/com/nm/gsgl/service/CallSendOutInterfaceService.java @@ -6,6 +6,13 @@ package com.nm.gsgl.service; * @description: 调用自动下发接口 */ public interface CallSendOutInterfaceService { + /** + *调用自动下发接口（省内黑名单表直连分中心对相应片区的hang_table_collect表内数据直连分中心数据库完成对表HANG_TABLE的先删后插） + * @author shuguang + * @date 2024-11-15 10:18 + * @param uuid uuid + */ + boolean SendFZXHangTableInterface(String uuid); /** *调用自动下发接口 * @author shuguang diff --git a/ParamDownload/src/main/java/com/nm/gsgl/service/impl/CallSendOutInterfaceServiceImpl.java b/ParamDownload/src/main/java/com/nm/gsgl/service/impl/CallSendOutInterfaceServiceImpl.java index 7cad984a..4be679d8 100644 --- a/ParamDownload/src/main/java/com/nm/gsgl/service/impl/CallSendOutInterfaceServiceImpl.java +++ b/ParamDownload/src/main/java/com/nm/gsgl/service/impl/CallSendOutInterfaceServiceImpl.java @@ -1,7 +1,9 @@ package com.nm.gsgl.service.impl; +import com.nm.gsgl.common.Constant; import com.nm.gsgl.common.utils.CloseableHttpClientUtils; import com.nm.gsgl.common.utils.LogUtil; +import com.nm.gsgl.common.utils.PropertiesUtil; import com.nm.gsgl.entity.intermediary.AppAliveStatus; import com.nm.gsgl.mapper.AppAliveStatusMapper; import com.nm.gsgl.service.CallSendOutInterfaceService; @@ -25,6 +27,32 @@ public class CallSendOutInterfaceServiceImpl implements CallSendOutInterfaceServ private AppAliveStatusMapper appAliveStatusMapper; //public static Logger log = LoggerFactory.getLogger("CallDisInterface"); + /** + * 调用自动下发接口（省内黑名单表直连分中心对相应片区的hang_table_collect表内数据直连分中心数据库完成对表HANG_TABLE的先删后插） + * + * @param uuid uuid + * @author shuguang + * @date 2024-11-15 10:18 + */ + @Override + public boolean SendFZXHangTableInterface(String uuid) { + //双机方案 + //获取本机的机器ID,本机的机器ID 1-主机，2-备用机 + int mId = Integer.parseInt(machineId); + LogUtil.WriteLog_SendFZXHangTableInterface("[uuid:" + uuid + "]-获取当前机器的id为" + mId, "CallSendOutInterfaceServiceImpl-SendFZXHangTableInterface"); + AppAliveStatus appAliveStatus = appAliveStatusMapper.selectById(1); + int aLiveId = appAliveStatus.getALiveId(); + if (mId == aLiveId) { + String sendFZXHangTableUrl = PropertiesUtil.getValue("SendFZXHangTableUrl") == null ? Constant.SEND_FZX_HANG_TABLE_URL : PropertiesUtil.getValue("SendFZXHangTableUrl"); + LogUtil.WriteLog_SendFZXHangTableInterface("[uuid:" + uuid + "]-开始调用自动下发接口（省内黑名单表直连分中心对相应片区的hang_table_collect表内数据直连分中心数据库完成对表HANG_TABLE的先删后插）" + sendOutInterfaceUrl, "CallSendOutInterfaceServiceImpl-SendFZXHangTableInterface"); + CloseableHttpClientUtils.doGet(sendFZXHangTableUrl, null, null, 600000); + LogUtil.WriteLog_SendFZXHangTableInterface("[uuid:" + uuid + "]-调用自动下发接口（省内黑名单表直连分中心对相应片区的hang_table_collect表内数据直连分中心数据库完成对表HANG_TABLE的先删后插）完成" + sendOutInterfaceUrl, "CallSendOutInterfaceServiceImpl-SendFZXHangTableInterface"); + return true; + } else { + return false; + } + } + /** * 调用自动下发接口 * @@ -38,15 +66,15 @@ public class CallSendOutInterfaceServiceImpl implements CallSendOutInterfaceServ //获取本机的机器ID,本机的机器ID 1-主机，2-备用机 int mId = Integer.parseInt(machineId); //log.info("[uuid:{}]获取当前机器的id为{}", uuid, mId); - LogUtil.WriteLog_CallDisInterface("[uuid:" + uuid + "]-获取当前机器的id为" + mId, "CallSendOutInterfaceServiceImpl"); + LogUtil.WriteLog_CallDisInterface("[uuid:" + uuid + "]-获取当前机器的id为" + mId, "CallSendOutInterfaceServiceImpl-callSendOutInterface"); AppAliveStatus appAliveStatus = appAliveStatusMapper.selectById(1); int aLiveId = appAliveStatus.getALiveId(); if (mId == aLiveId) { //log.info("[uuid:{}]开始调用自动下发程序接口-{}进行下发", uuid, sendOutInterfaceUrl); - LogUtil.WriteLog_CallDisInterface("[uuid:" + uuid + "]-开始调用自动下发程序接口进行下发" + sendOutInterfaceUrl, "CallSendOutInterfaceServiceImpl"); + LogUtil.WriteLog_CallDisInterface("[uuid:" + uuid + "]-开始调用自动下发程序接口进行下发" + sendOutInterfaceUrl, "CallSendOutInterfaceServiceImpl-callSendOutInterface"); CloseableHttpClientUtils.doGet(sendOutInterfaceUrl, null, null, 600000); //log.info("[uuid:{}]调用自动下发程序接口-{}进行下发完成", uuid, sendOutInterfaceUrl); - LogUtil.WriteLog_CallDisInterface("[uuid:" + uuid + "]-调用自动下发程序接口下发完成" + sendOutInterfaceUrl, "CallSendOutInterfaceServiceImpl"); + LogUtil.WriteLog_CallDisInterface("[uuid:" + uuid + "]-调用自动下发程序接口下发完成" + sendOutInterfaceUrl, "CallSendOutInterfaceServiceImpl-callSendOutInterface"); return true; } else { return false; diff --git a/ParamDownload/src/main/resources/static/timeTask.properties b/ParamDownload/src/main/resources/static/timeTask.properties index 24167686..8dd1ffd8 100644 --- a/ParamDownload/src/main/resources/static/timeTask.properties +++ b/ParamDownload/src/main/resources/static/timeTask.properties @@ -21,3 +21,5 @@ time.corn7= 0 0/5 * * * ? time.corn8= 0 0/5 * * * ? #每5分钟执行一次 time.corn9= 0 0/5 * * * ? +#每一小时执行一次 +time.corn10= 0 0 0/1 * * ?