Tenlion/wg-gateway-manage
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加序列化，依赖等

Browse Source
This commit is contained in:
wanggeng 2022-05-25 01:41:20 +08:00
parent 1e1f141efd
commit a4fa22c845
38 changed files with 353 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
pom.xml
View File

@ -96,6 +96,39 @@
<version>2.0.1</version>
</dependency>
<!-- mongodb start -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<!-- mongodb end -->
<!-- session share start -->
<dependency>
<groupId>org.springframework.session</groupId>
<artifactId>spring-session-data-redis</artifactId>
</dependency>
<!-- session share end -->
<!-- redis start -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- redis end -->
<dependency>
<groupId>ink.wgink</groupId>
<artifactId>mongo-login</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>ink.wgink</groupId>
<artifactId>mongo-menu</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>ink.wgink</groupId>
<artifactId>login-oauth2-server</artifactId>

5
src/main/java/ink/wgink/gatewaymanage/pojo/bos/api/ApiBO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.bos.api;
import java.io.Serializable;
/**
*
* @ClassName: ApiBO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.bos.api;
* @Date: 2021-08-16 14:50:40
* @Version: 3.0
**/
public class ApiBO {
public class ApiBO implements Serializable {
private static final long serialVersionUID = -6838504531704427115L;
private String apiId;
private String systemId;
private String title;

5
src/main/java/ink/wgink/gatewaymanage/pojo/bos/broker/BrokerBO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.bos.broker;
import java.io.Serializable;
/**
*
* @ClassName: BrokerBO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.bos.broker;
* @Date: 2021-08-23 21:44:01
* @Version: 3.0
**/
public class BrokerBO {
public class BrokerBO implements Serializable {
private static final long serialVersionUID = 4026458867068856264L;
private String brokerId;
private String clientId;
private String brokerName;

5
src/main/java/ink/wgink/gatewaymanage/pojo/bos/claim/ClaimBO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.bos.claim;
import java.io.Serializable;
/**
*
* @ClassName: ClaimBO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.bos.claim;
* @Date: 2021-08-16 14:58:13
* @Version: 3.0
**/
public class ClaimBO {
public class ClaimBO implements Serializable {
private static final long serialVersionUID = 2170652750366426373L;
private String claimId;
private String systemId;
private String apiId;

5
src/main/java/ink/wgink/gatewaymanage/pojo/bos/client/ClientBO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.bos.client;
import java.io.Serializable;
/**
*
* @ClassName: ClientBO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.bos.client;
* @Date: 2021-08-23 21:44:36
* @Version: 3.0
**/
public class ClientBO {
public class ClientBO implements Serializable {
private static final long serialVersionUID = -462280875565348320L;
private String clientId;
private String clientName;
private String clientSummary;

5
src/main/java/ink/wgink/gatewaymanage/pojo/bos/header/HeaderBO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.bos.header;
import java.io.Serializable;
/**
*
* @ClassName: HeaderBO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.bos.header;
* @Date: 2021-08-16 14:58:46
* @Version: 3.0
**/
public class HeaderBO {
public class HeaderBO implements Serializable {
private static final long serialVersionUID = -1097947988796128852L;
private String headerId;
private String systemId;
private String apiId;

5
src/main/java/ink/wgink/gatewaymanage/pojo/bos/message/MessageBO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.bos.message;
import java.io.Serializable;
/**
*
* @ClassName: MessageBO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.bos.message;
* @Date: 2021-08-23 21:45:28
* @Version: 3.0
**/
public class MessageBO {
public class MessageBO implements Serializable {
private static final long serialVersionUID = -5637364561243041119L;
private String messageId;
private String messageGroup;
private String messageTopic;

5
src/main/java/ink/wgink/gatewaymanage/pojo/bos/requestparams/RequestParamsBO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.bos.requestparams;
import java.io.Serializable;
/**
*
* @ClassName: RequestParamsBO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.bos.requestparams;
* @Date: 2021-08-16 14:59:34
* @Version: 3.0
**/
public class RequestParamsBO {
public class RequestParamsBO implements Serializable {
private static final long serialVersionUID = -8165161661872402160L;
private String requestParamsId;
private String systemId;
private String apiId;

5
src/main/java/ink/wgink/gatewaymanage/pojo/bos/responseparams/ResponseParamsBO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.bos.responseparams;
import java.io.Serializable;
/**
*
* @ClassName: ResponseParamsBO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.bos.responseparams;
* @Date: 2021-08-16 15:00:02
* @Version: 3.0
**/
public class ResponseParamsBO {
public class ResponseParamsBO implements Serializable {
private static final long serialVersionUID = -3903873517438084324L;
private String responseParamsId;
private String systemId;
private String apiId;

5
src/main/java/ink/wgink/gatewaymanage/pojo/bos/source/SourceBO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.bos.source;
import java.io.Serializable;
/**
*
* @ClassName: SourceBO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.bos.source;
* @Date: 2021-08-23 21:42:29
* @Version: 3.0
**/
public class SourceBO {
public class SourceBO implements Serializable {
private static final long serialVersionUID = 8616108160990417463L;
private String sourceId;
private String sourceName;
private String sourceSummary;

5
src/main/java/ink/wgink/gatewaymanage/pojo/bos/task/TaskBO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.bos.task;
import java.io.Serializable;
/**
*
* @ClassName: TaskBO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.bos.task;
* @Date: 2021-08-23 21:43:18
* @Version: 3.0
**/
public class TaskBO {
public class TaskBO implements Serializable {
private static final long serialVersionUID = 1037087039408507536L;
private String taskId;
private String taskName;
private String taskSummary;

5
src/main/java/ink/wgink/gatewaymanage/pojo/dtos/api/ApiDTO.java
View File

@ -3,6 +3,8 @@ package ink.wgink.gatewaymanage.pojo.dtos.api;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
/**
*
* @ClassName: ApiDTO
@ -12,8 +14,9 @@ import io.swagger.annotations.ApiModelProperty;
* @Version: 3.0
**/
@ApiModel
public class ApiDTO {
public class ApiDTO implements Serializable {
private static final long serialVersionUID = 1873242612175290281L;
@ApiModelProperty(name = "apiId", value = "主键")
private String apiId;
@ApiModelProperty(name = "systemId", value = "系统ID")

5
src/main/java/ink/wgink/gatewaymanage/pojo/dtos/broker/BrokerDTO.java
View File

@ -3,6 +3,8 @@ package ink.wgink.gatewaymanage.pojo.dtos.broker;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
/**
*
* @ClassName: BrokerDTO
@ -12,8 +14,9 @@ import io.swagger.annotations.ApiModelProperty;
* @Version: 3.0
**/
@ApiModel
public class BrokerDTO {
public class BrokerDTO implements Serializable {
private static final long serialVersionUID = -5304508586239848809L;
@ApiModelProperty(name = "brokerId", value = "")
private String brokerId;
@ApiModelProperty(name = "clientId", value = "客户端ID")

5
src/main/java/ink/wgink/gatewaymanage/pojo/dtos/claim/ClaimDTO.java
View File

@ -7,6 +7,8 @@ import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.ToString;
import java.io.Serializable;
/**
* @ClassName: ClaimDTO
* @Description: 接口认领
@ -17,8 +19,9 @@ import lombok.ToString;
@Data
@ToString
@ApiModel
public class ClaimDTO {
public class ClaimDTO implements Serializable {
private static final long serialVersionUID = 4799478018471131528L;
@ApiModelProperty(name = "claimId", value = "主键")
private String claimId;
@ApiModelProperty(name = "systemId", value = "系统ID")

5
src/main/java/ink/wgink/gatewaymanage/pojo/dtos/client/ClientDTO.java
View File

@ -3,6 +3,8 @@ package ink.wgink.gatewaymanage.pojo.dtos.client;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
/**
*
* @ClassName: ClientDTO
@ -12,8 +14,9 @@ import io.swagger.annotations.ApiModelProperty;
* @Version: 3.0
**/
@ApiModel
public class ClientDTO {
public class ClientDTO implements Serializable {
private static final long serialVersionUID = 2154620616133215587L;
@ApiModelProperty(name = "clientId", value = "主键")
private String clientId;
@ApiModelProperty(name = "clientName", value = "客户端名称")

5
src/main/java/ink/wgink/gatewaymanage/pojo/dtos/header/HeaderDTO.java
View File

@ -3,6 +3,8 @@ package ink.wgink.gatewaymanage.pojo.dtos.header;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
/**
*
* @ClassName: HeaderDTO
@ -12,8 +14,9 @@ import io.swagger.annotations.ApiModelProperty;
* @Version: 3.0
**/
@ApiModel
public class HeaderDTO {
public class HeaderDTO implements Serializable {
private static final long serialVersionUID = 650852083293975395L;
@ApiModelProperty(name = "headerId", value = "主键")
private String headerId;
@ApiModelProperty(name = "systemId", value = "系统ID")

5
src/main/java/ink/wgink/gatewaymanage/pojo/dtos/message/MessageDTO.java
View File

@ -5,6 +5,8 @@ import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.ToString;
import java.io.Serializable;
/**
*
* @ClassName: MessageDTO
@ -16,8 +18,9 @@ import lombok.ToString;
@Data
@ToString
@ApiModel
public class MessageDTO {
public class MessageDTO implements Serializable {
private static final long serialVersionUID = 7358689217243831191L;
@ApiModelProperty(name = "messageId", value = "主键")
private String messageId;
@ApiModelProperty(name = "messageGroup", value = "消息组")

5
src/main/java/ink/wgink/gatewaymanage/pojo/dtos/requestparams/RequestParamsDTO.java
View File

@ -3,6 +3,8 @@ package ink.wgink.gatewaymanage.pojo.dtos.requestparams;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
/**
*
* @ClassName: RequestParamsDTO
@ -12,8 +14,9 @@ import io.swagger.annotations.ApiModelProperty;
* @Version: 3.0
**/
@ApiModel
public class RequestParamsDTO {
public class RequestParamsDTO implements Serializable {
private static final long serialVersionUID = 2057622457073307405L;
@ApiModelProperty(name = "requestParamsId", value = "主键")
private String requestParamsId;
@ApiModelProperty(name = "systemId", value = "系统ID")

5
src/main/java/ink/wgink/gatewaymanage/pojo/dtos/responseparams/ResponseParamsDTO.java
View File

@ -3,6 +3,8 @@ package ink.wgink.gatewaymanage.pojo.dtos.responseparams;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
/**
*
* @ClassName: ResponseParamsDTO
@ -12,8 +14,9 @@ import io.swagger.annotations.ApiModelProperty;
* @Version: 3.0
**/
@ApiModel
public class ResponseParamsDTO {
public class ResponseParamsDTO implements Serializable {
private static final long serialVersionUID = 5241875395939202651L;
@ApiModelProperty(name = "responseParamsId", value = "主键")
private String responseParamsId;
@ApiModelProperty(name = "systemId", value = "系统ID")

5
src/main/java/ink/wgink/gatewaymanage/pojo/dtos/source/SourceDTO.java
View File

@ -3,6 +3,8 @@ package ink.wgink.gatewaymanage.pojo.dtos.source;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
/**
*
* @ClassName: SourceDTO
@ -12,8 +14,9 @@ import io.swagger.annotations.ApiModelProperty;
* @Version: 3.0
**/
@ApiModel
public class SourceDTO {
public class SourceDTO implements Serializable {
private static final long serialVersionUID = -9174342906617603492L;
@ApiModelProperty(name = "sourceId", value = "主键")
private String sourceId;
@ApiModelProperty(name = "sourceName", value = "源名称")

5
src/main/java/ink/wgink/gatewaymanage/pojo/dtos/system/SystemDTO.java
View File

@ -3,6 +3,8 @@ package ink.wgink.gatewaymanage.pojo.dtos.system;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
/**
* @ClassName: SystemDTO
* @Description: 接口系统
@ -11,8 +13,9 @@ import io.swagger.annotations.ApiModelProperty;
* @Version: 3.0
**/
@ApiModel
public class SystemDTO {
public class SystemDTO implements Serializable {
private static final long serialVersionUID = 5686792172461858480L;
@ApiModelProperty(name = "systemId", value = "")
private String systemId;
@ApiModelProperty(name = "name", value = "名称")

5
src/main/java/ink/wgink/gatewaymanage/pojo/dtos/task/TaskDTO.java
View File

@ -5,6 +5,8 @@ import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.ToString;
import java.io.Serializable;
/**
*
* @ClassName: TaskDTO
@ -16,8 +18,9 @@ import lombok.ToString;
@Data
@ToString
@ApiModel
public class TaskDTO {
public class TaskDTO implements Serializable {
private static final long serialVersionUID = 3374440825835076595L;
@ApiModelProperty(name = "taskId", value = "主键")
private String taskId;
@ApiModelProperty(name = "taskName", value = "任务名称")

5
src/main/java/ink/wgink/gatewaymanage/pojo/pos/api/ApiPO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.pos.api;
import java.io.Serializable;
/**
*
* @ClassName: ApiPO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.pos.api;
* @Date: 2021-08-16 14:50:40
* @Version: 3.0
**/
public class ApiPO {
public class ApiPO implements Serializable {
private static final long serialVersionUID = -8947525208445328822L;
private String apiId;
private String systemId;
private String title;

5
src/main/java/ink/wgink/gatewaymanage/pojo/pos/broker/BrokerPO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.pos.broker;
import java.io.Serializable;
/**
*
* @ClassName: BrokerPO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.pos.broker;
* @Date: 2021-08-23 21:44:01
* @Version: 3.0
**/
public class BrokerPO {
public class BrokerPO implements Serializable {
private static final long serialVersionUID = -3701731950338775047L;
private String brokerId;
private String clientId;
private String brokerName;

5
src/main/java/ink/wgink/gatewaymanage/pojo/pos/claim/ClaimPO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.pos.claim;
import java.io.Serializable;
/**
*
* @ClassName: ClaimPO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.pos.claim;
* @Date: 2021-08-16 14:58:13
* @Version: 3.0
**/
public class ClaimPO {
public class ClaimPO implements Serializable {
private static final long serialVersionUID = 8331887587709713262L;
private String claimId;
private String systemId;
private String apiId;

5
src/main/java/ink/wgink/gatewaymanage/pojo/pos/client/ClientPO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.pos.client;
import java.io.Serializable;
/**
*
* @ClassName: ClientPO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.pos.client;
* @Date: 2021-08-23 21:44:36
* @Version: 3.0
**/
public class ClientPO {
public class ClientPO implements Serializable {
private static final long serialVersionUID = -8367809247430054182L;
private String clientId;
private String clientName;
private String clientSummary;

5
src/main/java/ink/wgink/gatewaymanage/pojo/pos/header/HeaderPO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.pos.header;
import java.io.Serializable;
/**
* @ClassName: HeaderPO
* @Description: 请求头
@ -7,8 +9,9 @@ package ink.wgink.gatewaymanage.pojo.pos.header;
* @Date: 2021-08-16 14:58:46
* @Version: 3.0
**/
public class HeaderPO {
public class HeaderPO implements Serializable {
private static final long serialVersionUID = -6536640407738650931L;
private String headerId;
private String systemId;
private String apiId;

5
src/main/java/ink/wgink/gatewaymanage/pojo/pos/message/MessagePO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.pos.message;
import java.io.Serializable;
/**
*
* @ClassName: MessagePO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.pos.message;
* @Date: 2021-08-23 21:45:28
* @Version: 3.0
**/
public class MessagePO {
public class MessagePO implements Serializable {
private static final long serialVersionUID = -5120545653449503220L;
private String messageId;
private String messageGroup;
private String messageTopic;

5
src/main/java/ink/wgink/gatewaymanage/pojo/pos/requestparams/RequestParamsPO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.pos.requestparams;
import java.io.Serializable;
/**
*
* @ClassName: RequestParamsPO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.pos.requestparams;
* @Date: 2021-08-16 14:59:34
* @Version: 3.0
**/
public class RequestParamsPO {
public class RequestParamsPO implements Serializable {
private static final long serialVersionUID = -5409501883044105389L;
private String requestParamsId;
private String systemId;
private String apiId;

5
src/main/java/ink/wgink/gatewaymanage/pojo/pos/responseparams/ResponseParamsPO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.pos.responseparams;
import java.io.Serializable;
/**
*
* @ClassName: ResponseParamsPO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.pos.responseparams;
* @Date: 2021-08-16 15:00:02
* @Version: 3.0
**/
public class ResponseParamsPO {
public class ResponseParamsPO implements Serializable {
private static final long serialVersionUID = 8407149344367574306L;
private String responseParamsId;
private String systemId;
private String apiId;

5
src/main/java/ink/wgink/gatewaymanage/pojo/pos/source/SourcePO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.pos.source;
import java.io.Serializable;
/**
*
* @ClassName: SourcePO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.pos.source;
* @Date: 2021-08-23 21:42:29
* @Version: 3.0
**/
public class SourcePO {
public class SourcePO implements Serializable {
private static final long serialVersionUID = 7366485164533121694L;
private String sourceId;
private String sourceName;
private String sourceSummary;

5
src/main/java/ink/wgink/gatewaymanage/pojo/pos/task/TaskPO.java
View File

@ -1,5 +1,7 @@
package ink.wgink.gatewaymanage.pojo.pos.task;
import java.io.Serializable;
/**
*
* @ClassName: TaskPO
@ -8,8 +10,9 @@ package ink.wgink.gatewaymanage.pojo.pos.task;
* @Date: 2021-08-23 21:43:18
* @Version: 3.0
**/
public class TaskPO {
public class TaskPO implements Serializable {
private static final long serialVersionUID = -486194834676322314L;
private String taskId;
private String taskName;
private String taskSummary;

2
src/main/java/ink/wgink/gatewaymanage/service/broker/impl/BrokerServiceImpl.java
View File

@ -15,7 +15,6 @@ import ink.wgink.util.UUIDUtil;
import ink.wgink.util.map.HashMapUtil;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
@ -27,7 +26,6 @@ import java.util.Map;
* @Date: 2021-08-23 21:44:01
* @Version: 3.0
**/
@Service
public class BrokerServiceImpl extends DefaultBaseService implements IBrokerService {
@Autowired

153
src/main/java/ink/wgink/gatewaymanage/service/broker/impl/BrokerServiceMongoImpl.java Normal file
View File

@ -0,0 +1,153 @@
package ink.wgink.gatewaymanage.service.broker.impl;
import ink.wgink.common.base.DefaultBaseService;
import ink.wgink.gatewaymanage.pojo.bos.broker.BrokerBO;
import ink.wgink.gatewaymanage.pojo.dtos.broker.BrokerDTO;
import ink.wgink.gatewaymanage.pojo.pos.broker.BrokerPO;
import ink.wgink.gatewaymanage.pojo.vos.broker.BrokerVO;
import ink.wgink.gatewaymanage.service.broker.IBrokerService;
import ink.wgink.pojo.ListPage;
import ink.wgink.pojo.result.SuccessResultList;
import ink.wgink.util.UUIDUtil;
import ink.wgink.util.map.HashMapUtil;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Pageable;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
/**
* @ClassName: BrokerServiceMongoImpl
* @Description: 消息
* @Author: wanggeng
* @Date: 2022/5/25 01:24
* @Version: 1.0
*/
@Service
public class BrokerServiceMongoImpl extends DefaultBaseService implements IBrokerService {
private static final String COLLECTION_NAME = "broker";
@Autowired
private MongoTemplate mongoTemplate;
@Override
public void save(BrokerVO brokerVO) {
String brokerId = UUIDUtil.getUUID();
Map<String, Object> params = HashMapUtil.beanToMap(brokerVO);
params.put("brokerId", brokerId);
setSaveInfo(params);
BrokerDTO brokerDTO = new BrokerDTO();
BeanUtils.copyProperties(brokerVO, brokerDTO);
brokerDTO.setBrokerId(brokerId);
mongoTemplate.save(brokerDTO, COLLECTION_NAME);
}
@Override
public void save(String token, BrokerVO brokerVO) {
}
@Override
public String saveReturnId(BrokerVO brokerVO) {
return null;
}
@Override
public String saveReturnId(String token, BrokerVO brokerVO) {
return null;
}
@Override
public void remove(List<String> ids) {
mongoTemplate.remove(Query.query(Criteria.where("brokerId").in(ids)));
}
@Override
public void remove(String token, List<String> ids) {
}
@Override
public void delete(List<String> ids) {
}
@Override
public void update(String brokerId, BrokerVO brokerVO) {
BrokerDTO brokerDTO = new BrokerDTO();
BeanUtils.copyProperties(brokerVO, brokerDTO);
brokerDTO.setBrokerId(brokerId);
mongoTemplate.remove(Query.query(Criteria.where("brokerId").is(brokerId)), COLLECTION_NAME);
mongoTemplate.save(brokerDTO, COLLECTION_NAME);
}
@Override
public void update(String token, String brokerId, BrokerVO brokerVO) {
}
@Override
public BrokerDTO get(Map<String, Object> params) {
return null;
}
@Override
public BrokerDTO get(String brokerId) {
return mongoTemplate.findOne(Query.query(Criteria.where("brokerId").is(brokerId)), BrokerDTO.class, COLLECTION_NAME);
}
@Override
public BrokerBO getBO(Map<String, Object> params) {
return null;
}
@Override
public BrokerBO getBO(String brokerId) {
return null;
}
@Override
public BrokerPO getPO(Map<String, Object> params) {
return null;
}
@Override
public BrokerPO getPO(String brokerId) {
return null;
}
@Override
public List<BrokerDTO> list(Map<String, Object> params) {
return mongoTemplate.findAll(BrokerDTO.class, COLLECTION_NAME);
}
@Override
public List<BrokerBO> listBO(Map<String, Object> params) {
return null;
}
@Override
public List<BrokerPO> listPO(Map<String, Object> params) {
return null;
}
@Override
public SuccessResultList<List<BrokerDTO>> listPage(ListPage page) {
Query query = new Query();
long total = mongoTemplate.count(query, COLLECTION_NAME);
query.with(Pageable.ofSize(page.getRows()).withPage(page.getPage() - 1));
List<BrokerDTO> userLocationDTOs = mongoTemplate.find(query, BrokerDTO.class, COLLECTION_NAME);
return new SuccessResultList<>(userLocationDTOs, page.getPage(), total);
}
@Override
public Integer count(Map<String, Object> params) {
return null;
}
}

22
src/main/resources/application-prod.yml
View File

@ -7,6 +7,11 @@ server:
# default-home-page: route/system/default
servlet:
context-path: /gateway-manage
master-node: true
init:
table: true
menu: true
user: true
magic-api:
#配置web页面入口
@ -80,6 +85,21 @@ spring:
# 如果'enable.auto.commit'为true，则消费者偏移自动提交给Kafka的频率（以毫秒为单位），默认值为5000。
auto-commit-interval: 100
max-poll-records: 5
data:
mongodb:
uri: mongodb://study:study@192.168.0.103:27017/study
redis:
database: 6
host: 192.168.0.103
port: 6379
password: 666
timeout: 3000ms
jedis:
pool:
max-active: 8
max-wait: 1ms
max-idle: 8
min-idle: 0
# 数据库
@ -131,5 +151,5 @@ logging:
file:
name: E:\project\gateway\gateway-manage-logs.log
level:
org.springframework: debug
org.springframework: error
ink.wgink: debug

20
src/main/resources/application-test.yml
View File

@ -7,6 +7,11 @@ server:
# default-home-page: route/system/default
servlet:
context-path: /gateway-manage
master-node: true
init:
table: true
menu: true
user: true
magic-api:
#配置web页面入口
@ -80,6 +85,21 @@ spring:
# 如果'enable.auto.commit'为true，则消费者偏移自动提交给Kafka的频率（以毫秒为单位），默认值为5000。
auto-commit-interval: 100
max-poll-records: 5
data:
mongodb:
uri: mongodb://study:study@192.168.0.103:27017/study
redis:
database: 2
host: 192.168.0.103
port: 6379
password: 666
timeout: 3000ms
jedis:
pool:
max-active: 8
max-wait: 1ms
max-idle: 8
min-idle: 0
# 数据库

2
src/main/resources/mybatis/mybatis-config.xml
View File

@ -4,7 +4,7 @@
<settings>
<!-- 二级缓存，默认false -->
<setting name="cacheEnabled" value="true"/>
<setting name="cacheEnabled" value="false"/>
</settings>
<typeAliases>

25
src/main/resources/static/route/broker/list.html
View File

@ -16,20 +16,6 @@
<div class="layui-col-md12">
<div class="layui-card">
<div class="layui-card-body">
<div class="test-table-reload-btn" style="margin-bottom: 10px;">
<div class="layui-inline">
<input type="text" id="keywords" class="layui-input search-item" placeholder="输入关键字">
</div>
<div class="layui-inline">
<input type="text" id="startTime" class="layui-input search-item" placeholder="开始时间" readonly>
</div>
<div class="layui-inline">
<input type="text" id="endTime" class="layui-input search-item" placeholder="结束时间" readonly>
</div>
<button type="button" id="search" class="layui-btn layui-btn-sm">
<i class="fa fa-lg fa-search"></i> 搜索
</button>
</div>
<table class="layui-hide" id="dataTable" lay-filter="dataTable"></table>
<!-- 表头按钮组 -->
<script type="text/html" id="headerToolBar">
@ -74,7 +60,7 @@
id: 'dataTable',
url: top.restAjax.path(tableUrl, []),
width: admin.screen() > 1 ? '100%' : '',
height: $win.height() - 90,
height: $win.height() - 50,
limit: 20,
limits: [20, 40, 60, 80, 100, 200],
toolbar: '#headerToolBar',
@ -131,15 +117,6 @@
return rowData;
}
},
{field: 'gmtCreate', width: 180, title: '创建时间', align:'center',
templet: function(row) {
var rowData = row[this.field];
if(typeof(rowData) === 'undefined' || rowData == null || rowData == '') {
return '-';
}
return rowData;
}
},
]
],
page: true,