fizzgate/fizz-gateway-node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

correct the util class

Browse Source
This commit is contained in:
Francis Dong
2021-04-15 17:46:33 +08:00
committed by dxfeng10
parent 0b672bdaac
commit b7385ab640
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fizz-core/src/main/java/we/fizz/input/extension/dubbo/DubboInput.java
View File

@@ -26,7 +26,7 @@ import org.noear.snack.ONode;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.util.StringUtils;
import org.springframework.util.CollectionUtils;
import reactor.core.publisher.Mono;
import we.constants.CommonConstants;
@@ -111,7 +111,7 @@ public class DubboInput extends RPCInput {
Map<String, Object> dataMapping = this.getConfig().getDataMapping();
if (dataMapping != null) {
Map<String, Object> requestMapping = (Map<String, Object>) dataMapping.get("request");
if (requestMapping != null && !StringUtils.isEmpty(requestMapping)) {
if (!CollectionUtils.isEmpty(requestMapping)) {
ONode ctxNode = PathMapping.toONode(stepContext);
// attachments
@@ -181,7 +181,7 @@ public class DubboInput extends RPCInput {
Map<String, Object> dataMapping = this.getConfig().getDataMapping();
if (dataMapping != null) {
Map<String, Object> responseMapping = (Map<String, Object>) dataMapping.get("response");
if (responseMapping != null && !StringUtils.isEmpty(responseMapping)) {
if (!CollectionUtils.isEmpty(responseMapping)) {
ONode ctxNode = PathMapping.toONode(stepContext);
// body

6
fizz-core/src/main/java/we/fizz/input/extension/grpc/GrpcInput.java
View File

@@ -21,7 +21,7 @@ import com.alibaba.fastjson.JSON;
import org.noear.snack.ONode;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.util.StringUtils;
import org.springframework.util.CollectionUtils;
import reactor.core.publisher.Mono;
import we.constants.CommonConstants;
@@ -105,7 +105,7 @@ public class GrpcInput extends RPCInput implements IInput {
Map<String, Object> dataMapping = this.getConfig().getDataMapping();
if (dataMapping != null) {
Map<String, Object> requestMapping = (Map<String, Object>) dataMapping.get("request");
if (requestMapping != null && !StringUtils.isEmpty(requestMapping)) {
if (!CollectionUtils.isEmpty(requestMapping)) {
ONode ctxNode = PathMapping.toONode(stepContext);
// attachments
@@ -176,7 +176,7 @@ public class GrpcInput extends RPCInput implements IInput {
Map<String, Object> dataMapping = this.getConfig().getDataMapping();
if (dataMapping != null) {
Map<String, Object> responseMapping = (Map<String, Object>) dataMapping.get("response");
if (responseMapping != null && !StringUtils.isEmpty(responseMapping)) {
if (!CollectionUtils.isEmpty(responseMapping)) {
ONode ctxNode = PathMapping.toONode(stepContext);
// body