wulin/qiuguo-iot
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

用户完成-3

Browse Source
This commit is contained in:
weiyachao 2023-08-08 13:05:15 +08:00
parent 2915b559ad
commit bf3de1d9f8
2 changed files with 41 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/controller/UserController.java
View File

@ -85,7 +85,9 @@ public class UserController {
@PostMapping("/userCance") @PostMapping("/userCance")
public Mono<JSONObject> userCance(@RequestBody JSONObject jsonObject, @RequestHeader("Api-Token") String token, public Mono<JSONObject> userCance(@RequestBody JSONObject jsonObject, @RequestHeader("Api-Token") String token,
@RequestHeader("Api-Type") String type) { @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 -> { .bodyToMono(JSONObject.class).doOnNext(res -> {
if (!Objects.equals(res.getInteger("code"), 1)) { if (!Objects.equals(res.getInteger("code"), 1)) {
throw new RuntimeException(res.getString("info")); throw new RuntimeException(res.getString("info"));
@ -99,9 +101,11 @@ public class UserController {
@PostMapping("/edit/userInfo") @PostMapping("/edit/userInfo")
public Mono<JSONObject> editUserInfo(@RequestBody JSONObject jsonObject, @RequestHeader("Api-Token") String token, public Mono<JSONObject> editUserInfo(@RequestBody JSONObject jsonObject, @RequestHeader("Api-Token") String token,
@RequestHeader("Api-Type") String type) { @RequestHeader("Api-Type") String type) {
return WebClient.builder() return webClient.mutate()
.defaultHeader("Api-Token", token) .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 -> { .bodyToMono(JSONObject.class).doOnNext(res -> {
if (!Objects.equals(res.getInteger("code"), 200)) { if (!Objects.equals(res.getInteger("code"), 200)) {
throw new RuntimeException(res.getString("msg")); throw new RuntimeException(res.getString("msg"));
@ -217,7 +221,7 @@ public class UserController {
} }
private WebClient getAuthWebClient(String token, String type) { private WebClient getAuthWebClient(String token, String type) {
return WebClient.builder() return webClient.mutate()
.defaultHeader(HttpHeaders.CONTENT_TYPE, APPLICATION_FORM_URLENCODED_VALUE) .defaultHeader(HttpHeaders.CONTENT_TYPE, APPLICATION_FORM_URLENCODED_VALUE)
.defaultHeader("Api-Token", token) .defaultHeader("Api-Token", token)
.defaultHeader("Api-Type", type).build(); .defaultHeader("Api-Type", type).build();

33
iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogFilter.java Normal file
View File

@ -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<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
// 获取请求路径和参数
String path = exchange.getRequest().getPath().toString();
MultiValueMap<String, String> 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); // 继续请求链
}
}