|
|
|
@ -11,6 +11,7 @@ import com.nm.gsgl.service.MinDualMachineService;
|
|
|
|
import com.nm.gsgl.service.MinFeeService;
|
|
|
|
import com.nm.gsgl.service.MinFeeService;
|
|
|
|
import com.nm.gsgl.service.MinFtpDownloadService;
|
|
|
|
import com.nm.gsgl.service.MinFtpDownloadService;
|
|
|
|
import com.nm.gsgl.service.SqliteBackupsService;
|
|
|
|
import com.nm.gsgl.service.SqliteBackupsService;
|
|
|
|
|
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
|
|
|
|
@ -79,7 +80,7 @@ public class MinFeeServiceImpl implements MinFeeService {
|
|
|
|
//开始查询sqlite任务表中华软未处理数据任务
|
|
|
|
//开始查询sqlite任务表中华软未处理数据任务
|
|
|
|
List<BusinessTasks> businessTasks = DatabaseUtil.selectBusines(sqliteDriverName, sqliteUrl, Constant.SELECT_BUSINESS_HANDLER_HR_MIN_FEE);
|
|
|
|
List<BusinessTasks> businessTasks = DatabaseUtil.selectBusines(sqliteDriverName, sqliteUrl, Constant.SELECT_BUSINESS_HANDLER_HR_MIN_FEE);
|
|
|
|
String minFeeThreadSize = PropertiesUtil.getValue("minFeeThreadSize");
|
|
|
|
String minFeeThreadSize = PropertiesUtil.getValue("minFeeThreadSize");
|
|
|
|
int minFeeThreadSizeInt = Integer.parseInt((minFeeThreadSize != null) ? minFeeThreadSize : "2");
|
|
|
|
int minFeeThreadSizeInt = Integer.parseInt((StringUtils.isNotBlank(minFeeThreadSize)) ? minFeeThreadSize : "2");
|
|
|
|
if (businessTasks.size() > 0) {
|
|
|
|
if (businessTasks.size() > 0) {
|
|
|
|
//创建线程池
|
|
|
|
//创建线程池
|
|
|
|
ExecutorService executor = Executors.newFixedThreadPool(minFeeThreadSizeInt); // 可以根据实际情况调整线程池的大小
|
|
|
|
ExecutorService executor = Executors.newFixedThreadPool(minFeeThreadSizeInt); // 可以根据实际情况调整线程池的大小
|
|
|
|
|