wangcheng 2 лет назад
Родитель
Сommit
69f9532217

+ 4 - 2
launch-admin/src/main/java/com/webflux/launchadmin/mysql/controller/planNew/PlanNewCommonOutController.java

@@ -8,6 +8,7 @@ import cn.hutool.json.JSONArray;
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
 import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSON;
+import com.plumelog.core.util.LogExceptionStackTrace;
 import com.webflux.launchadmin.global.BaseException;
 import com.webflux.launchadmin.global.BaseException;
 import com.webflux.launchadmin.mysql.controller.planNew.req.*;
 import com.webflux.launchadmin.mysql.controller.planNew.req.*;
 import com.webflux.launchadmin.mysql.controller.planNew.res.*;
 import com.webflux.launchadmin.mysql.controller.planNew.res.*;
@@ -25,6 +26,7 @@ import com.webflux.launchcommon.returnObj.RStatus;
 import jakarta.annotation.Resource;
 import jakarta.annotation.Resource;
 import jakarta.json.Json;
 import jakarta.json.Json;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.exception.ExceptionUtils;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.r2dbc.core.R2dbcEntityTemplate;
 import org.springframework.data.r2dbc.core.R2dbcEntityTemplate;
 import org.springframework.data.redis.core.ReactiveRedisTemplate;
 import org.springframework.data.redis.core.ReactiveRedisTemplate;
@@ -84,8 +86,8 @@ public class PlanNewCommonOutController {
     @GetMapping("getPlanNewCommonH5")
     @GetMapping("getPlanNewCommonH5")
     public Mono<RStatus<byte[]>> getPlanNewCommonH5(@RequestParam("code") String code) {
     public Mono<RStatus<byte[]>> getPlanNewCommonH5(@RequestParam("code") String code) {
         Mono<PlanNewCommon> planNewCommonMono = template.selectOne(Query.query(Criteria.where("code").is(code)), PlanNewCommon.class)
         Mono<PlanNewCommon> planNewCommonMono = template.selectOne(Query.query(Criteria.where("code").is(code)), PlanNewCommon.class)
-                .switchIfEmpty(Mono.error(new BaseException("计划code异常")))
-                .onErrorResume(throwable -> Mono.error(new Exception(throwable.getMessage() + "1")));
+                .switchIfEmpty(Mono.error(new BaseException("计划code异常" + ExceptionUtils.getStackTrace(new Exception()))))
+                .onErrorResume(throwable -> Mono.error(new Exception(LogExceptionStackTrace.erroStackTrace(throwable).toString())));
         Mono<PlanNewCommonRes> resMono = planNewCommonMono.flatMap(f -> {
         Mono<PlanNewCommonRes> resMono = planNewCommonMono.flatMap(f -> {
             // 群成员
             // 群成员
             Mono<List<GroupUserRes>> groupUserResMono = Mono.just(new ArrayList<>());
             Mono<List<GroupUserRes>> groupUserResMono = Mono.just(new ArrayList<>());

+ 5 - 2
launch-admin/src/test/java/com/webflux/launchadmin/LaunchAdminApplicationTests.java

@@ -1,7 +1,9 @@
 package com.webflux.launchadmin;
 package com.webflux.launchadmin;
 
 
+import com.plumelog.core.util.LogExceptionStackTrace;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.Test;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.boot.test.context.SpringBootTest;
+import reactor.core.publisher.Mono;
 
 
 import java.net.URI;
 import java.net.URI;
 import java.net.http.HttpClient;
 import java.net.http.HttpClient;
@@ -38,7 +40,8 @@ class LaunchAdminApplicationTests {
     @Test
     @Test
     public void testLog() {
     public void testLog() {
         String val = "123abc";
         String val = "123abc";
-        Integer num = Integer.parseInt(val);
-        System.out.println(num);
+        Mono.just(val).flatMap(f -> Mono.just(Integer.parseInt(f)))
+                .onErrorResume(e -> Mono.error(new Exception(LogExceptionStackTrace.erroStackTrace(e).toString())))
+                .subscribe(System.out::println);
     }
     }
 }
 }