增加线程池

ipp-idp/src/main/java/com/jiayue/ipp/idp/IppIdpApplication.java

@@ -6,6 +6,8 @@ import org.apache.velocity.app.VelocityEngine;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.annotation.Bean;
+import org.springframework.scheduling.TaskScheduler;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 
 import java.util.Properties;
 
@@ -37,4 +39,14 @@ public class IppIdpApplication {
 		ve.init(properties);
 		return ve;
 	}
+
+	@Bean
+	public TaskScheduler taskScheduler(){
+		ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
+		// 线程池大小
+		taskScheduler.setPoolSize(10);
+		// 线程名字的前缀
+		taskScheduler.setThreadNamePrefix("taskScheduler");
+		return taskScheduler;
+	}
 }

ipp-idp/src/main/java/com/jiayue/ipp/idp/job/AccuracyCalculationJob.java

@@ -36,7 +36,13 @@ public class AccuracyCalculationJob {
         log.info("准确率定时计算任务开始执行");
         List<ElectricField> electricFieldList = electricFieldService.list();
         for (ElectricField e : electricFieldList) {
-            accuracyCalculationService.calculate(e);
+            try{
+                accuracyCalculationService.calculate(e);
+            }
+            catch (Exception ex){
+                log.error(e.getName()+"计算准确率异常：",ex);
+            }
+
         }
         log.info("准确率定时计算任务执行完毕");
 

ipp-idp/src/main/java/com/jiayue/ipp/idp/service/impl/AccuracyCalculationServiceImpl.java

@@ -16,6 +16,7 @@ import com.syjy.calculate.entity.CalculationFormula;
 import com.syjy.calculate.entity.CalculationInfo;
 import com.syjy.calculate.repository.CalculationFormulaRepository;
 import com.syjy.calculate.service.AccuracyPassRateCalculateService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -38,6 +39,7 @@ import java.util.stream.Collectors;
  * @date 2022-10-17 15:08:48
  */
 @Service
+@Slf4j
 public class AccuracyCalculationServiceImpl extends ServiceImpl<AccuracyCalculationMapper, AccuracyCalculation> implements AccuracyCalculationService {
     @Autowired
     AccuracyPassRateCalculateService accuracyPassRateCalculateService;