mirror of
https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git
synced 2025-06-08 06:17:55 +08:00
[fix] 修改枚举问题
This commit is contained in:
parent
0505d6d201
commit
903ba88787
@ -7,6 +7,7 @@ import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.proxy.Server
|
|||||||
import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.ServerHandlerOutFlowHandler;
|
import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.ServerHandlerOutFlowHandler;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.proxy.ServerHandlerOutProxyFlowHandler;
|
import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.proxy.ServerHandlerOutProxyFlowHandler;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodeProperties;
|
import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodeProperties;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyProxyFlowApplication;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyVisitorPortFlowApplication;
|
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyVisitorPortFlowApplication;
|
||||||
import org.springframework.beans.factory.config.BeanDefinition;
|
import org.springframework.beans.factory.config.BeanDefinition;
|
||||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
|
||||||
@ -69,8 +70,8 @@ public class ServerFlowConfiguration {
|
|||||||
*/
|
*/
|
||||||
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
|
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
|
||||||
@Bean
|
@Bean
|
||||||
public ServerHandlerInProxyFlowHandler serverHandlerInProxyFlowHandler(LazyVisitorPortFlowApplication lazyVisitorPortFlowApplication, ServerNodeProperties serverNodeProperties) {
|
public ServerHandlerInProxyFlowHandler serverHandlerInProxyFlowHandler(LazyProxyFlowApplication lazyProxyFlowApplication,ServerNodeProperties serverNodeProperties) {
|
||||||
return new ServerHandlerInProxyFlowHandler(lazyVisitorPortFlowApplication, serverNodeProperties);
|
return new ServerHandlerInProxyFlowHandler(lazyProxyFlowApplication,serverNodeProperties);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -80,8 +81,8 @@ public class ServerFlowConfiguration {
|
|||||||
*/
|
*/
|
||||||
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
|
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
|
||||||
@Bean
|
@Bean
|
||||||
public ServerHandlerOutProxyFlowHandler serverHandlerOutProxyFlowHandler(LazyVisitorPortFlowApplication lazyVisitorPortFlowApplication, ServerNodeProperties serverNodeProperties) {
|
public ServerHandlerOutProxyFlowHandler serverHandlerOutProxyFlowHandler(LazyProxyFlowApplication lazyProxyFlowApplication, ServerNodeProperties serverNodeProperties) {
|
||||||
return new ServerHandlerOutProxyFlowHandler(lazyVisitorPortFlowApplication,serverNodeProperties);
|
return new ServerHandlerOutProxyFlowHandler(lazyProxyFlowApplication,serverNodeProperties);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@ -8,19 +8,17 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolTy
|
|||||||
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodeProperties;
|
import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodeProperties;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyProxyFlowApplication;
|
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyProxyFlowApplication;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyVisitorPortFlowApplication;
|
|
||||||
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.proxy.flow.LazyProxyFlowStoryCommand;
|
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.proxy.flow.LazyProxyFlowStoryCommand;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 进口流量处理
|
* 进口流量处理
|
||||||
*/
|
*/
|
||||||
public class ServerHandlerInProxyFlowHandler extends AbstractHandleChannelProxyFlowAdvanced {
|
public class ServerHandlerInProxyFlowHandler extends AbstractHandleChannelProxyFlowAdvanced {
|
||||||
private final LazyVisitorPortFlowApplication lazyVisitorPortFlowApplication;
|
|
||||||
private final LazyProxyFlowApplication lazyProxyFlowApplication;
|
private final LazyProxyFlowApplication lazyProxyFlowApplication;
|
||||||
private final ServerNodeProperties serverNodeProperties;
|
private final ServerNodeProperties serverNodeProperties;
|
||||||
|
|
||||||
public ServerHandlerInProxyFlowHandler(LazyVisitorPortFlowApplication lazyVisitorPortFlowApplication, LazyProxyFlowApplication lazyProxyFlowApplication, ServerNodeProperties serverNodeProperties) {
|
public ServerHandlerInProxyFlowHandler(LazyProxyFlowApplication lazyProxyFlowApplication, ServerNodeProperties serverNodeProperties) {
|
||||||
this.lazyVisitorPortFlowApplication = lazyVisitorPortFlowApplication;
|
|
||||||
this.lazyProxyFlowApplication = lazyProxyFlowApplication;
|
this.lazyProxyFlowApplication = lazyProxyFlowApplication;
|
||||||
this.serverNodeProperties = serverNodeProperties;
|
this.serverNodeProperties = serverNodeProperties;
|
||||||
}
|
}
|
||||||
|
@ -5,22 +5,27 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.flow.proxy.Abs
|
|||||||
import org.framework.lazy.cloud.network.heartbeat.common.advanced.flow.ChannelFlow;
|
import org.framework.lazy.cloud.network.heartbeat.common.advanced.flow.ChannelFlow;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.common.advanced.flow.proxy.ChannelProxyFlow;
|
import org.framework.lazy.cloud.network.heartbeat.common.advanced.flow.proxy.ChannelProxyFlow;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelFlowEnum;
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelFlowEnum;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodeProperties;
|
import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodeProperties;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyProxyFlowApplication;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyVisitorPortFlowApplication;
|
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyVisitorPortFlowApplication;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.proxy.flow.LazyProxyFlowStoryCommand;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.flow.LazyVisitorPortFlowStoryCommand;
|
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.flow.LazyVisitorPortFlowStoryCommand;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 出口流量处理
|
* 出口流量处理
|
||||||
*/
|
*/
|
||||||
public class ServerHandlerOutProxyFlowHandler extends AbstractHandleChannelProxyFlowAdvanced {
|
public class ServerHandlerOutProxyFlowHandler extends AbstractHandleChannelProxyFlowAdvanced {
|
||||||
private final LazyVisitorPortFlowApplication lazyVisitorPortFlowApplication;
|
private final LazyProxyFlowApplication lazyProxyFlowApplication;
|
||||||
private final ServerNodeProperties serverNodeProperties;
|
private final ServerNodeProperties serverNodeProperties;
|
||||||
|
|
||||||
public ServerHandlerOutProxyFlowHandler(LazyVisitorPortFlowApplication lazyVisitorPortFlowApplication, ServerNodeProperties serverNodeProperties) {
|
public ServerHandlerOutProxyFlowHandler(LazyProxyFlowApplication lazyProxyFlowApplication, ServerNodeProperties serverNodeProperties) {
|
||||||
this.lazyVisitorPortFlowApplication = lazyVisitorPortFlowApplication;
|
this.lazyProxyFlowApplication = lazyProxyFlowApplication;
|
||||||
this.serverNodeProperties = serverNodeProperties;
|
this.serverNodeProperties = serverNodeProperties;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 处理是否支持这种类型
|
* 处理是否支持这种类型
|
||||||
*
|
*
|
||||||
@ -45,16 +50,24 @@ public class ServerHandlerOutProxyFlowHandler extends AbstractHandleChannelProxy
|
|||||||
@Override
|
@Override
|
||||||
protected void doHandler(Channel channel, ChannelProxyFlow channelProxyFlow) {
|
protected void doHandler(Channel channel, ChannelProxyFlow channelProxyFlow) {
|
||||||
String clientId = channelProxyFlow.clientId();
|
String clientId = channelProxyFlow.clientId();
|
||||||
|
String ip = channelProxyFlow.ip();
|
||||||
Integer port = channelProxyFlow.port();
|
Integer port = channelProxyFlow.port();
|
||||||
Integer flow = channelProxyFlow.flow();
|
Integer flow = channelProxyFlow.flow();
|
||||||
|
ChannelProtocolType channelProtocolType = channelProxyFlow.channelProtocolType();
|
||||||
|
ChannelProxyType channelProxyType = channelProxyFlow.channelProxyType();
|
||||||
|
|
||||||
|
|
||||||
// 出口流量处理
|
// 出口流量处理
|
||||||
LazyVisitorPortFlowStoryCommand visitorPortFlow = new LazyVisitorPortFlowStoryCommand();
|
LazyProxyFlowStoryCommand lazyProxyFlowStoryCommand = new LazyProxyFlowStoryCommand();
|
||||||
visitorPortFlow.setOutFlow(flow);
|
lazyProxyFlowStoryCommand.setOutFlow(flow);
|
||||||
visitorPortFlow.setClientId(clientId);
|
lazyProxyFlowStoryCommand.setClientId(clientId);
|
||||||
visitorPortFlow.setVisitorPort(port);
|
lazyProxyFlowStoryCommand.setIp(ip);
|
||||||
visitorPortFlow.setIsDeleted(false);
|
lazyProxyFlowStoryCommand.setPort(port);
|
||||||
lazyVisitorPortFlowApplication.flowIncreaseStory(visitorPortFlow);
|
lazyProxyFlowStoryCommand.setProtocolType(channelProtocolType);
|
||||||
|
lazyProxyFlowStoryCommand.setProxyType(channelProxyType);
|
||||||
|
|
||||||
|
lazyProxyFlowStoryCommand.setIsDeleted(false);
|
||||||
|
lazyProxyFlowApplication.flowIncreaseStory(lazyProxyFlowStoryCommand);
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -1,13 +1,12 @@
|
|||||||
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.proxy.flow;
|
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.proxy.flow;
|
||||||
|
|
||||||
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
import java.lang.String;
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.lang.Long;
|
|
||||||
import java.lang.Integer;
|
|
||||||
import java.lang.Boolean;
|
|
||||||
/**
|
/**
|
||||||
* describe 代理流量
|
* describe 代理流量
|
||||||
*
|
*
|
||||||
@ -82,14 +81,14 @@ public class LazyProxyFlowQueryListCommand {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -3,6 +3,9 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
|
|||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
|
|
||||||
import java.lang.String;
|
import java.lang.String;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.lang.Long;
|
import java.lang.Long;
|
||||||
@ -82,14 +85,14 @@ public class LazyProxyFlowQueryOneCommand {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -3,6 +3,9 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
|
|||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
|
|
||||||
import java.lang.String;
|
import java.lang.String;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.lang.Long;
|
import java.lang.Long;
|
||||||
@ -82,14 +85,14 @@ public class LazyProxyFlowRemoveCommand {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -3,6 +3,9 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
|
|||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
|
|
||||||
import java.lang.String;
|
import java.lang.String;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.lang.Long;
|
import java.lang.Long;
|
||||||
@ -82,14 +85,14 @@ public class LazyProxyFlowStoryCommand {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -3,6 +3,9 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
|
|||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
|
|
||||||
import java.lang.String;
|
import java.lang.String;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.lang.Long;
|
import java.lang.Long;
|
||||||
@ -82,14 +85,14 @@ public class LazyProxyFlowUpdateCommand {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -3,6 +3,9 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
|
|||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
|
|
||||||
import java.lang.String;
|
import java.lang.String;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.lang.Long;
|
import java.lang.Long;
|
||||||
@ -89,14 +92,14 @@ public class LazyProxyPerDayFlowQueryListCommand {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -3,6 +3,9 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
|
|||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
|
|
||||||
import java.lang.String;
|
import java.lang.String;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.lang.Long;
|
import java.lang.Long;
|
||||||
@ -89,14 +92,14 @@ public class LazyProxyPerDayFlowQueryOneCommand {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -3,6 +3,9 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
|
|||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
|
|
||||||
import java.lang.String;
|
import java.lang.String;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.lang.Long;
|
import java.lang.Long;
|
||||||
@ -89,14 +92,14 @@ public class LazyProxyPerDayFlowRemoveCommand {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -3,6 +3,9 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
|
|||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
|
|
||||||
import java.lang.String;
|
import java.lang.String;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.lang.Long;
|
import java.lang.Long;
|
||||||
@ -89,14 +92,14 @@ public class LazyProxyPerDayFlowStoryCommand {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -1,13 +1,12 @@
|
|||||||
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.proxy.per.day.flow;
|
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.proxy.per.day.flow;
|
||||||
|
|
||||||
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
import java.lang.String;
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.lang.Long;
|
|
||||||
import java.lang.Integer;
|
|
||||||
import java.lang.Boolean;
|
|
||||||
/**
|
/**
|
||||||
* describe 每日统计代理流量
|
* describe 每日统计代理流量
|
||||||
*
|
*
|
||||||
@ -89,14 +88,14 @@ public class LazyProxyPerDayFlowUpdateCommand {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -3,6 +3,8 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
|
|||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
import org.wu.framework.core.utils.ByteSizeUtil;
|
import org.wu.framework.core.utils.ByteSizeUtil;
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
@ -73,13 +75,13 @@ public class LazyClientProxyFlowDTO {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description = "协议类型", name = "protocolType", example = "")
|
@Schema(description = "协议类型", name = "protocolType", example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description = "代理类型", name = "proxyType", example = "")
|
@Schema(description = "代理类型", name = "proxyType", example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 服务端ID
|
* 服务端ID
|
||||||
|
@ -3,6 +3,8 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
|
|||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
import org.wu.framework.core.utils.ByteSizeUtil;
|
import org.wu.framework.core.utils.ByteSizeUtil;
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
@ -72,13 +74,13 @@ public class LazyProxyFlowDTO {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description = "协议类型", name = "protocolType", example = "")
|
@Schema(description = "协议类型", name = "protocolType", example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description = "代理类型", name = "proxyType", example = "")
|
@Schema(description = "代理类型", name = "proxyType", example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 服务端ID
|
* 服务端ID
|
||||||
|
@ -3,6 +3,9 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
|
|||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
|
|
||||||
import java.lang.String;
|
import java.lang.String;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.lang.Long;
|
import java.lang.Long;
|
||||||
@ -89,14 +92,14 @@ public class LazyProxyPerDayFlowDTO {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -1,6 +1,8 @@
|
|||||||
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.impl;
|
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.impl;
|
||||||
|
|
||||||
import jakarta.annotation.Resource;
|
import jakarta.annotation.Resource;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodeProperties;
|
import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodeProperties;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyProxyFlowApplication;
|
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyProxyFlowApplication;
|
||||||
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler.LazyProxyFlowDTOAssembler;
|
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler.LazyProxyFlowDTOAssembler;
|
||||||
@ -73,8 +75,8 @@ public class LazyProxyFlowApplicationImpl implements LazyProxyFlowApplication {
|
|||||||
public Result<LazyProxyFlow> flowIncreaseStory(LazyProxyFlowStoryCommand lazyProxyFlowStoryCommand) {
|
public Result<LazyProxyFlow> flowIncreaseStory(LazyProxyFlowStoryCommand lazyProxyFlowStoryCommand) {
|
||||||
String clientId = lazyProxyFlowStoryCommand.getClientId();
|
String clientId = lazyProxyFlowStoryCommand.getClientId();
|
||||||
String ip = lazyProxyFlowStoryCommand.getIp();
|
String ip = lazyProxyFlowStoryCommand.getIp();
|
||||||
String protocolType = lazyProxyFlowStoryCommand.getProtocolType();
|
ChannelProtocolType protocolType = lazyProxyFlowStoryCommand.getProtocolType();
|
||||||
String proxyType = lazyProxyFlowStoryCommand.getProxyType();
|
ChannelProxyType proxyType = lazyProxyFlowStoryCommand.getProxyType();
|
||||||
Integer port = lazyProxyFlowStoryCommand.getPort();
|
Integer port = lazyProxyFlowStoryCommand.getPort();
|
||||||
String serverId = serverNodeProperties.getNodeId();
|
String serverId = serverNodeProperties.getNodeId();
|
||||||
lazyProxyFlowStoryCommand.setServerId(serverId);
|
lazyProxyFlowStoryCommand.setServerId(serverId);
|
||||||
|
@ -3,6 +3,9 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.mode
|
|||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
|
|
||||||
import java.lang.String;
|
import java.lang.String;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.lang.Long;
|
import java.lang.Long;
|
||||||
@ -82,14 +85,14 @@ public class LazyProxyFlow {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -3,6 +3,9 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.mode
|
|||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
|
|
||||||
import java.lang.String;
|
import java.lang.String;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.lang.Long;
|
import java.lang.Long;
|
||||||
@ -89,14 +92,14 @@ public class LazyProxyPerDayFlow {
|
|||||||
* 协议类型
|
* 协议类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* 代理类型
|
* 代理类型
|
||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -2,6 +2,8 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastruct
|
|||||||
|
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
import org.wu.framework.lazy.orm.core.stereotype.LazyTableIndex;
|
import org.wu.framework.lazy.orm.core.stereotype.LazyTableIndex;
|
||||||
import org.wu.framework.core.stereotype.LayerField;
|
import org.wu.framework.core.stereotype.LayerField;
|
||||||
import org.wu.framework.core.stereotype.LayerField.LayerFieldType;
|
import org.wu.framework.core.stereotype.LayerField.LayerFieldType;
|
||||||
@ -100,7 +102,7 @@ public class LazyProxyFlowDO {
|
|||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
@LazyTableField(name="protocol_type",comment="协议类型",columnType="varchar(255)")
|
@LazyTableField(name="protocol_type",comment="协议类型",columnType="varchar(255)")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
@ -108,7 +110,7 @@ public class LazyProxyFlowDO {
|
|||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
@LazyTableField(name="proxy_type",comment="代理类型",columnType="varchar(255)")
|
@LazyTableField(name="proxy_type",comment="代理类型",columnType="varchar(255)")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
@ -2,6 +2,8 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastruct
|
|||||||
|
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProtocolType;
|
||||||
|
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelProxyType;
|
||||||
import org.wu.framework.lazy.orm.core.stereotype.LazyTableIndex;
|
import org.wu.framework.lazy.orm.core.stereotype.LazyTableIndex;
|
||||||
import org.wu.framework.core.stereotype.LayerField;
|
import org.wu.framework.core.stereotype.LayerField;
|
||||||
import org.wu.framework.core.stereotype.LayerField.LayerFieldType;
|
import org.wu.framework.core.stereotype.LayerField.LayerFieldType;
|
||||||
@ -108,7 +110,7 @@ public class LazyProxyPerDayFlowDO {
|
|||||||
*/
|
*/
|
||||||
@Schema(description ="协议类型",name ="protocolType",example = "")
|
@Schema(description ="协议类型",name ="protocolType",example = "")
|
||||||
@LazyTableField(name="protocol_type",comment="协议类型",columnType="varchar(255)")
|
@LazyTableField(name="protocol_type",comment="协议类型",columnType="varchar(255)")
|
||||||
private String protocolType;
|
private ChannelProtocolType protocolType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
@ -116,7 +118,7 @@ public class LazyProxyPerDayFlowDO {
|
|||||||
*/
|
*/
|
||||||
@Schema(description ="代理类型",name ="proxyType",example = "")
|
@Schema(description ="代理类型",name ="proxyType",example = "")
|
||||||
@LazyTableField(name="proxy_type",comment="代理类型",columnType="varchar(255)")
|
@LazyTableField(name="proxy_type",comment="代理类型",columnType="varchar(255)")
|
||||||
private String proxyType;
|
private ChannelProxyType proxyType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
|
Loading…
x
Reference in New Issue
Block a user