Parcourir la source

ai方法修改为异步处理,引用方式修改

zhangchen il y a 13 heures
Parent
commit
3d1bc7d928

+ 2 - 1
alien-lawyer/src/main/java/shop/alien/lawyer/config/AsyncConfig.java

@@ -6,6 +6,7 @@ import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
 import java.util.concurrent.Executor;
+import java.util.concurrent.ThreadPoolExecutor;
 
 /**
  * 异步任务配置类
@@ -36,7 +37,7 @@ public class AsyncConfig {
         // 线程名前缀
         executor.setThreadNamePrefix("async-task-lawyer-");
         // 拒绝策略:调用者运行策略
-        executor.setRejectedExecutionHandler(new java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy());
+        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
         // 等待所有任务结束后再关闭线程池
         executor.setWaitForTasksToCompleteOnShutdown(true);
         // 等待时间

+ 6 - 3
alien-lawyer/src/main/java/shop/alien/lawyer/service/impl/AiUserAuditTaskServiceImpl.java

@@ -6,8 +6,11 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.HttpEntity;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
+import org.springframework.web.client.HttpClientErrorException;
+import org.springframework.web.client.HttpServerErrorException;
 import org.springframework.web.client.RestTemplate;
 import shop.alien.lawyer.service.AiUserAuditTaskService;
 
@@ -45,16 +48,16 @@ public class AiUserAuditTaskServiceImpl implements AiUserAuditTaskService {
             log.info("异步调用AI用户申诉接口,URL:{},请求头:{}", aiUserAuditTaskUrl, aiHeaders);
 
             // 调用AI服务
-            org.springframework.http.ResponseEntity<String> responseEntity = restTemplate.postForEntity(
+            ResponseEntity<String> responseEntity = restTemplate.postForEntity(
                     aiUserAuditTaskUrl, request, String.class);
 
             log.info("异步调用AI用户申诉接口成功,响应状态:{},响应体:{}",
                     responseEntity.getStatusCode(), responseEntity.getBody());
 
-        } catch (org.springframework.web.client.HttpServerErrorException e) {
+        } catch (HttpServerErrorException e) {
             log.error("异步调用AI用户申诉接口返回服务器错误,状态码:{},响应体:{},URL:{}",
                     e.getStatusCode(), e.getResponseBodyAsString(), aiUserAuditTaskUrl, e);
-        } catch (org.springframework.web.client.HttpClientErrorException e) {
+        } catch (HttpClientErrorException e) {
             log.error("异步调用AI用户申诉接口返回客户端错误,状态码:{},响应体:{},URL:{}",
                     e.getStatusCode(), e.getResponseBodyAsString(), aiUserAuditTaskUrl, e);
         } catch (Exception e) {