欧诺最新代码

mjava-ounuo/src/main/java/com/malk/tuosi/config/AsyncConfig.java

@@ -9,7 +9,7 @@ import java.util.concurrent.Executor;
 import java.util.concurrent.ThreadPoolExecutor;
 
 @Configuration
-public class AsyncConfig {
+public class AsyncConfig_A {
     @Bean("businessTaskExecutor")
     public Executor businessTaskExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

mjava-ounuo/src/main/java/com/malk/tuosi/controller/TBController.java

@@ -43,7 +43,7 @@ public class TBController {
 
     /*TODO：TB事件订阅接口*/
     @PostMapping("/tbTaskUpdate")
-    McR tbTaskUpdate(@RequestBody Map body) throws JsonProcessingException{
+    McR tbTaskUpdate(@RequestBody Map body) throws JsonProcessingException {
         return McR.success(tbService.tbTaskUpdate(body));
     }
 

mjava-ounuo/src/main/java/com/malk/tuosi/service/TBService.java

@@ -18,9 +18,9 @@ public interface TBService {
     McR OuNuoXinAccessToken() throws JsonProcessingException;
 
    /*TODO:接收TB推送的数据*/
-    McR tbTaskUpdate_A(Map body) throws JsonProcessingException;//TODO:原始方法
+    McR tbTaskUpdate(Map body) throws JsonProcessingException;//TODO:原始方法
 
-    McR tbTaskUpdate(Map body) throws JsonProcessingException;//TODO:异步执行
+//    void tbTaskUpdate(Map body);//TODO:异步执行
 
     /*TODO：钉盘文件上传接口*/
     McR uploadKnowledge(String pathName,String fileName,String fileType) throws JsonProcessingException;

mjava-ounuo/src/main/java/com/malk/tuosi/service/impl/TbServiceImpl.java

@@ -7,6 +7,7 @@ import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.malk.core.AsyncConfig;
 import com.malk.server.common.McException;
 import com.malk.server.common.McR;
 import com.malk.server.common.VenR;
@@ -39,6 +40,9 @@ import java.util.stream.Collectors;
 @Service
 public class TbServiceImpl implements TBService {
 
+    //异步自定义线程池
+    @Autowired
+    private AsyncConfig asyncConfig;
 
     /*TODO:TB获取应用token*/
     @Override
@@ -84,28 +88,27 @@ public class TbServiceImpl implements TBService {
     //TODO:异步执行
 
     // 耗时操作必须放在独立方法上（不能和 Controller 在同一个类！）
-    @Async("businessTaskExecutor") // 指定线程池
-    public McR tbTaskUpdate(Map body) throws JsonProcessingException{
-        try {
-            // 模拟耗时操作（实际替换为你的业务）
-//            Thread.sleep(50000); // 50秒
-
-
-            tbTaskUpdate_A(body);
-
-        } catch (Exception e) {
-            // ⚠ 异步任务异常不会抛到 Controller，必须自己处理！
-            log.error("异步业务执行失败, 宜搭前端传参{}", body, e);
-            // 可选：发送告警、存入重试队列等
-        }
-        return McR.success();
-    }
+//    @Async("businessTaskExecutor") // 指定线程池
+//    public void tbTaskUpdate(Map body){
+//        try {
+//            // 模拟耗时操作（实际替换为你的业务）
+////            Thread.sleep(50000); // 50秒
+//
+//
+//            tbTaskUpdate_A(body);
+//
+//        } catch (Exception e) {
+//            // ⚠ 异步任务异常不会抛到 Controller，必须自己处理！
+//            log.error("异步业务执行失败, 宜搭前端传参{}", body, e);
+//            // 可选：发送告警、存入重试队列等
+//        }
+//    }
 
 
     //TODO:原始方法
     @SneakyThrows
     @Override
-    public McR tbTaskUpdate_A(Map body) throws JsonProcessingException {
+    public McR tbTaskUpdate(Map body) throws JsonProcessingException {
         log.info("----开始接收webhook----");
         String s = JSON.toJSONString(body);
         JSONObject jsonObject = JSON.parseObject(s);