diff --git a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/controller/UserController.java b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/controller/UserController.java index 220d3f3..82cc2ab 100644 --- a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/controller/UserController.java +++ b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/controller/UserController.java @@ -85,7 +85,9 @@ public class UserController { @PostMapping("/userCance") public Mono userCance(@RequestBody JSONObject jsonObject, @RequestHeader("Api-Token") String token, @RequestHeader("Api-Type") String type) { - return getAuthWebClient(token, type).post().uri(baseUrl + userCancelUrl).bodyValue(getMultiValueMap(jsonObject)).retrieve() + return getAuthWebClient(token, type).post().uri(baseUrl + userCancelUrl) + .bodyValue(getMultiValueMap(jsonObject)) + .retrieve() .bodyToMono(JSONObject.class).doOnNext(res -> { if (!Objects.equals(res.getInteger("code"), 1)) { throw new RuntimeException(res.getString("info")); @@ -99,9 +101,11 @@ public class UserController { @PostMapping("/edit/userInfo") public Mono editUserInfo(@RequestBody JSONObject jsonObject, @RequestHeader("Api-Token") String token, @RequestHeader("Api-Type") String type) { - return WebClient.builder() + return webClient.mutate() .defaultHeader("Api-Token", token) - .defaultHeader("Api-Type", type).build().post().uri(editUserInfoUrl).bodyValue(jsonObject).retrieve() + .defaultHeader("Api-Type", type).build().post().uri(editUserInfoUrl) + .bodyValue(jsonObject) + .retrieve() .bodyToMono(JSONObject.class).doOnNext(res -> { if (!Objects.equals(res.getInteger("code"), 200)) { throw new RuntimeException(res.getString("msg")); @@ -217,7 +221,7 @@ public class UserController { } private WebClient getAuthWebClient(String token, String type) { - return WebClient.builder() + return webClient.mutate() .defaultHeader(HttpHeaders.CONTENT_TYPE, APPLICATION_FORM_URLENCODED_VALUE) .defaultHeader("Api-Token", token) .defaultHeader("Api-Type", type).build(); diff --git a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogFilter.java b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogFilter.java new file mode 100644 index 0000000..3185a50 --- /dev/null +++ b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogFilter.java @@ -0,0 +1,33 @@ +package com.qiuguo.iot.user.api.filter; + +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; +import org.springframework.util.MultiValueMap; +import org.springframework.web.server.ServerWebExchange; +import org.springframework.web.server.WebFilter; +import org.springframework.web.server.WebFilterChain; +import reactor.core.publisher.Mono; + +/** + * XXX + * + * @author weiyachao + * @since 2023/8/8 10:27 + */ +@Component +@Slf4j +public class LogFilter implements WebFilter { + + @Override + public Mono filter(ServerWebExchange exchange, WebFilterChain chain) { + // 获取请求路径和参数 + String path = exchange.getRequest().getPath().toString(); + MultiValueMap queryParams = exchange.getRequest().getQueryParams(); + log.info("path------{}", path); + log.info("queryParams-------{}", queryParams); + log.info("getMethodValue-------{}", exchange.getRequest().getMethodValue()); + log.info("headers-------{}", exchange.getRequest().getHeaders().entrySet()); + return chain.filter(exchange); // 继续请求链 + + } +}