fix:risk服务依赖及配置调整

yt-risk/risk-manage/pom.xml

@@ -52,6 +52,15 @@
             <artifactId>yt-question-feign</artifactId>
             <version>1.0-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>com.ytpm</groupId>
+            <artifactId>lemon-ios-feign</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-pool2</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

yt-risk/risk-manage/src/main/java/com/ytpm/RiskManageApplication.java

@@ -5,23 +5,15 @@ import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 import org.springframework.cloud.openfeign.EnableFeignClients;
-import org.springframework.context.annotation.Bean;
-import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.web.bind.annotation.RestController;
 
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.ScheduledThreadPoolExecutor;
-import java.util.concurrent.ThreadPoolExecutor;
-
 @RestController
 @SpringBootApplication
 @EnableDiscoveryClient
 @MapperScan(basePackages = "com.ytpm.dao")
-@EnableFeignClients(basePackages = {"com.ytpm.feign","com.ytpm.*.feign","com.ytpm.*.*.feign"})
-public class RiskManageApplication
-{
-    public static void main( String[] args )
-    {
+@EnableFeignClients(basePackages = {"com.ytpm.feign", "com.ytpm.*.feign"})
+public class RiskManageApplication {
+    public static void main(String[] args) {
         SpringApplication.run(RiskManageApplication.class, args);
     }
 }

yt-risk/risk-manage/src/main/java/com/ytpm/config/SchedulerConfig.java

@@ -19,7 +19,7 @@ public class SchedulerConfig {
             t.setDaemon(true);
             return t;
         };
-        ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(2, factory, new ThreadPoolExecutor.DiscardPolicy());
+        ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(5, factory, new ThreadPoolExecutor.DiscardPolicy());
         executor.setRemoveOnCancelPolicy(true);
         return executor;
     }

yt-risk/risk-manage/src/main/java/com/ytpm/handle/CustomerExceptionHandler.java

@@ -159,14 +159,14 @@ public class CustomerExceptionHandler implements HandlerExceptionResolver {
 
     @ResponseBody
     @ExceptionHandler(MaxUploadSizeExceededException.class)
-    public Result handlerFileUploadException(MaxUploadSizeExceededException ex) {
-        log.error("抛出异常信息，异常信息为：ex={}", ex);
-        return new Result(StatusCode.ERROR, "文件超出限制(10MB)");
+    public Result<?> handlerFileUploadException(MaxUploadSizeExceededException ex) {
+        log.error("抛出异常信息，异常信息为：ex={}", ex.getMessage(), ex);
+        return new Result<>(StatusCode.ERROR, "文件超出限制(10MB)");
     }
 
     @Override
     public ModelAndView resolveException(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o, Exception e) {
-        log.error(" 系统异常，异常信息为：e={}", e.getMessage());
+        log.error(" 系统异常，异常信息为：e={}", e.getMessage(), e);
         ModelAndView mv = new ModelAndView(new MappingJackson2JsonView());
         if (e instanceof MultipartException) {
             mv.addObject("message", "系统异常");
@@ -181,7 +181,7 @@ public class CustomerExceptionHandler implements HandlerExceptionResolver {
     @ResponseBody
     @ExceptionHandler(CustomerException.class)
     public Result<?> handleCustomerException(Exception ex) {
-        log.error("自定义校验异常信息捕获，异常信息为：ex={}", ex);
+        log.error("自定义校验异常信息捕获，异常信息为：ex={}", ex.getMessage(), ex);
         String msg = ex.getMessage();
         return new Result<>(StatusCode.ACCESS_ERR, msg);
     }

yt-risk/risk-manage/src/main/resources/bootstrap.yml

@@ -1,5 +1,7 @@
 server:
   port: 25522
+  tomcat:
+    max-threads: 500
 spring:
   main:
     allow-bean-definition-overriding: true