|
|
|
|
@ -78,12 +78,11 @@ public class MinFeeServiceImpl implements MinFeeService {
|
|
|
|
|
minFtpDownloadService.getMinFeeHrMdTask(uuid);
|
|
|
|
|
//开始查询sqlite任务表中华软未处理数据任务
|
|
|
|
|
List<BusinessTasks> businessTasks = DatabaseUtil.selectBusines(sqliteDriverName, sqliteUrl, Constant.SELECT_BUSINESS_HANDLER_HR_MIN_FEE);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
String minFeeThreadSize = PropertiesUtil.getValue("minFeeThreadSize");
|
|
|
|
|
int minFeeThreadSizeInt = Integer.parseInt((minFeeThreadSize != null) ? minFeeThreadSize : "2");
|
|
|
|
|
if (businessTasks.size() > 0) {
|
|
|
|
|
|
|
|
|
|
//创建线程池
|
|
|
|
|
ExecutorService executor = Executors.newFixedThreadPool(2); // 可以根据实际情况调整线程池的大小
|
|
|
|
|
ExecutorService executor = Executors.newFixedThreadPool(minFeeThreadSizeInt); // 可以根据实际情况调整线程池的大小
|
|
|
|
|
for (BusinessTasks businessTask : businessTasks) {
|
|
|
|
|
final String protocolType = businessTask.getProtocolType();
|
|
|
|
|
executor.submit(() -> {
|
|
|
|
|
|