From 0197af4fbe51c84886f6d508353d86b722dcaa4b Mon Sep 17 00:00:00 2001 From: wanggeng888 <450292408@qq.com> Date: Wed, 14 Apr 2021 11:39:34 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 40 +- .../wgink/gateway/WgGatewayApplication.java | 7 +- .../ink/wgink/gateway/config/BeanConfig.java | 44 ++ .../wgink/gateway/consts/ISystemConst.java | 19 + .../controller/api/route/RouteController.java | 47 ++ .../java/ink/wgink/gateway/dao/BaseDao.java | 47 ++ .../java/ink/wgink/gateway/dao/IBaseDao.java | 65 +++ .../wgink/gateway/dao/route/IRouteDao.java | 21 + .../gateway/dao/route/impl/RouteDaoImpl.java | 94 ++++ .../filter/global/CountGlobalFilter.java | 16 +- .../java/ink/wgink/gateway/pojo/BasePOJO.java | 26 + .../java/ink/wgink/gateway/pojo/ListPage.java | 33 ++ .../gateway/pojo/dtos/route/RouteDTO.java | 33 ++ .../wgink/gateway/pojo/pos/route/RoutePO.java | 35 ++ .../gateway/pojo/result/ErrorResult.java | 99 ++++ .../gateway/pojo/result/SuccessResult.java | 22 + .../pojo/result/SuccessResultData.java | 36 ++ .../pojo/result/SuccessResultList.java | 61 +++ .../pojo/result/UploadExcelResultDTO.java | 61 +++ .../wgink/gateway/pojo/vos/route/RouteVO.java | 57 +++ .../wgink/gateway/service/BaseService.java | 14 + .../gateway/service/route/IRouteService.java | 38 ++ .../service/route/impl/RouteServiceImpl.java | 44 ++ .../java/ink/wgink/gateway/util/DateUtil.java | 457 ++++++++++++++++++ .../ink/wgink/gateway/util/ReflectUtil.java | 124 +++++ .../java/ink/wgink/gateway/util/UUIDUtil.java | 20 + src/main/resources/application.yml | 8 + src/main/resources/static/route/list.html | 10 + 28 files changed, 1572 insertions(+), 6 deletions(-) create mode 100644 src/main/java/ink/wgink/gateway/config/BeanConfig.java create mode 100644 src/main/java/ink/wgink/gateway/consts/ISystemConst.java create mode 100644 src/main/java/ink/wgink/gateway/controller/api/route/RouteController.java create mode 100644 src/main/java/ink/wgink/gateway/dao/BaseDao.java create mode 100644 src/main/java/ink/wgink/gateway/dao/IBaseDao.java create mode 100644 src/main/java/ink/wgink/gateway/dao/route/IRouteDao.java create mode 100644 src/main/java/ink/wgink/gateway/dao/route/impl/RouteDaoImpl.java create mode 100644 src/main/java/ink/wgink/gateway/pojo/BasePOJO.java create mode 100644 src/main/java/ink/wgink/gateway/pojo/ListPage.java create mode 100644 src/main/java/ink/wgink/gateway/pojo/dtos/route/RouteDTO.java create mode 100644 src/main/java/ink/wgink/gateway/pojo/pos/route/RoutePO.java create mode 100644 src/main/java/ink/wgink/gateway/pojo/result/ErrorResult.java create mode 100644 src/main/java/ink/wgink/gateway/pojo/result/SuccessResult.java create mode 100644 src/main/java/ink/wgink/gateway/pojo/result/SuccessResultData.java create mode 100644 src/main/java/ink/wgink/gateway/pojo/result/SuccessResultList.java create mode 100644 src/main/java/ink/wgink/gateway/pojo/result/UploadExcelResultDTO.java create mode 100644 src/main/java/ink/wgink/gateway/pojo/vos/route/RouteVO.java create mode 100644 src/main/java/ink/wgink/gateway/service/BaseService.java create mode 100644 src/main/java/ink/wgink/gateway/service/route/IRouteService.java create mode 100644 src/main/java/ink/wgink/gateway/service/route/impl/RouteServiceImpl.java create mode 100644 src/main/java/ink/wgink/gateway/util/DateUtil.java create mode 100644 src/main/java/ink/wgink/gateway/util/ReflectUtil.java create mode 100644 src/main/java/ink/wgink/gateway/util/UUIDUtil.java create mode 100644 src/main/resources/static/route/list.html diff --git a/pom.xml b/pom.xml index f7bd389..c075360 100644 --- a/pom.xml +++ b/pom.xml @@ -9,14 +9,19 @@ ink.wgink - gateway + wg-gateway 1.0.0-SNAPSHOT wg-gateway 网关 + 1.8 + 2.9.4 + 1.18.16 + 1.2.73 2020.0.2 + org.springframework.cloud @@ -26,12 +31,35 @@ org.springframework.cloud spring-cloud-starter-gateway - + + org.springframework.boot + spring-boot-starter-data-mongodb + org.springframework.boot spring-boot-starter-test test + + org.apache.commons + commons-lang3 + + + com.alibaba + fastjson + ${fastjson.version} + + + joda-time + joda-time + ${jodatime.version} + + + org.projectlombok + lombok + ${lombok.version} + provided + @@ -50,6 +78,14 @@ org.springframework.boot spring-boot-maven-plugin + + + + org.projectlombok + lombok + + + diff --git a/src/main/java/ink/wgink/gateway/WgGatewayApplication.java b/src/main/java/ink/wgink/gateway/WgGatewayApplication.java index 78227dc..c0f41ef 100644 --- a/src/main/java/ink/wgink/gateway/WgGatewayApplication.java +++ b/src/main/java/ink/wgink/gateway/WgGatewayApplication.java @@ -6,6 +6,7 @@ import org.springframework.boot.context.properties.EnableConfigurationProperties import org.springframework.cloud.gateway.route.RouteLocator; import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder; import org.springframework.context.annotation.Bean; +import org.yaml.snakeyaml.util.UriEncoder; @EnableConfigurationProperties @SpringBootApplication @@ -19,9 +20,9 @@ public class WgGatewayApplication { public RouteLocator routes(RouteLocatorBuilder builder) { RouteLocator routeLocator = builder.routes() .route(r -> r - .path("/study") - .filters(f -> f.addRequestHeader("name", "张三").addRequestParameter("test", "gogo")) - .uri("http://127.0.0.1:7008/study")) + .path("/study/**") + .filters(f -> f.rewritePath("/study/", "/twoduty/").addRequestHeader("name", UriEncoder.encode("zhangsan")).addRequestParameter("test", "gogo")) + .uri("http://192.168.0.120:8080")) .build(); routeLocator.getRoutes().toStream().forEach(System.out::println); return routeLocator; diff --git a/src/main/java/ink/wgink/gateway/config/BeanConfig.java b/src/main/java/ink/wgink/gateway/config/BeanConfig.java new file mode 100644 index 0000000..27deced --- /dev/null +++ b/src/main/java/ink/wgink/gateway/config/BeanConfig.java @@ -0,0 +1,44 @@ +package ink.wgink.gateway.config; + +import com.alibaba.fastjson.serializer.SerializerFeature; +import com.alibaba.fastjson.support.config.FastJsonConfig; +import com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.fasterxml.jackson.databind.SerializationFeature; +import org.springframework.boot.autoconfigure.web.servlet.WebMvcAutoConfiguration; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.http.MediaType; +import org.springframework.http.converter.HttpMessageConverter; +import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter; +import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder; +import org.springframework.security.crypto.password.PasswordEncoder; + +import java.nio.charset.Charset; +import java.util.ArrayList; +import java.util.List; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: BeanConfig + * @Description: bean配置 + * @Author: wanggeng + * @Date: 2021/2/5 6:44 下午 + * @Version: 1.0 + */ +@Configuration +public class BeanConfig { + + /** + * 解决 disable SerializationFeature.FAIL_ON_EMPTY_BEANS 问题，由于没有属性导致 + * + * @return + */ + @Bean + public ObjectMapper objectMapper() { + return new ObjectMapper().disable(SerializationFeature.FAIL_ON_EMPTY_BEANS); + } + +} diff --git a/src/main/java/ink/wgink/gateway/consts/ISystemConst.java b/src/main/java/ink/wgink/gateway/consts/ISystemConst.java new file mode 100644 index 0000000..622c060 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/consts/ISystemConst.java @@ -0,0 +1,19 @@ +package ink.wgink.gateway.consts; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: ISystemConst + * @Description: 常量 + * @Author: wanggeng + * @Date: 2021/4/14 10:16 上午 + * @Version: 1.0 + */ +public interface ISystemConst { + + String UUID = "uuid"; + + String COUNT = "count"; + +} diff --git a/src/main/java/ink/wgink/gateway/controller/api/route/RouteController.java b/src/main/java/ink/wgink/gateway/controller/api/route/RouteController.java new file mode 100644 index 0000000..2f4be1e --- /dev/null +++ b/src/main/java/ink/wgink/gateway/controller/api/route/RouteController.java @@ -0,0 +1,47 @@ +package ink.wgink.gateway.controller.api.route; + +import ink.wgink.gateway.dao.route.IRouteDao; +import ink.wgink.gateway.pojo.ListPage; +import ink.wgink.gateway.pojo.dtos.route.RouteDTO; +import ink.wgink.gateway.pojo.result.SuccessResult; +import ink.wgink.gateway.pojo.result.SuccessResultList; +import ink.wgink.gateway.pojo.vos.route.RouteVO; +import ink.wgink.gateway.service.route.IRouteService; +import ink.wgink.gateway.util.ReflectUtil; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RestController; + +import java.util.List; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: RouteController + * @Description: 路由 + * @Author: wanggeng + * @Date: 2021/4/13 6:41 下午 + * @Version: 1.0 + */ +@RestController("sys/route") +public class RouteController { + + @Autowired + private IRouteService routeService; + + @PostMapping("save") + public SuccessResult save(@RequestBody RouteVO routeVO) throws ReflectUtil.ReflectException { + routeService.save(routeVO); + return new SuccessResult(); + } + + @GetMapping("list") + public SuccessResultList> listPage(ListPage page) { + return routeService.listPage(page); + } + +} diff --git a/src/main/java/ink/wgink/gateway/dao/BaseDao.java b/src/main/java/ink/wgink/gateway/dao/BaseDao.java new file mode 100644 index 0000000..572409a --- /dev/null +++ b/src/main/java/ink/wgink/gateway/dao/BaseDao.java @@ -0,0 +1,47 @@ +package ink.wgink.gateway.dao; + +import ink.wgink.gateway.pojo.BasePOJO; +import ink.wgink.gateway.util.DateUtil; +import ink.wgink.gateway.util.UUIDUtil; +import org.springframework.data.mongodb.core.query.Update; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: BaseDao + * @Description: dao接口 + * @Author: wanggeng + * @Date: 2021/4/13 5:56 下午 + * @Version: 1.0 + */ +public class BaseDao { + + public static final String CREATOR = "creator"; + public static final String MODIFIER = "modifier"; + public static final String GMT_CREATE = "gmtCreate"; + public static final String GMT_MODIFIED = "gmtModified"; + + protected void setSave(BasePOJO base) { + String datetime = DateUtil.getTime(); + base.setUuid(UUIDUtil.getUUID()); + base.setCreator("1"); + base.setGmtCreate(datetime); + base.setModifier("1"); + base.setGmtModified(datetime); + } + + protected void setUpdate(Update update) { + update.set(GMT_MODIFIED, DateUtil.getTime()); + update.set(MODIFIER, "1"); + } + + protected int getLimit(int size) { + return size; + } + + protected long getSkip(int page, int size) { + return (page - 1) * size; + } + +} diff --git a/src/main/java/ink/wgink/gateway/dao/IBaseDao.java b/src/main/java/ink/wgink/gateway/dao/IBaseDao.java new file mode 100644 index 0000000..0efef2b --- /dev/null +++ b/src/main/java/ink/wgink/gateway/dao/IBaseDao.java @@ -0,0 +1,65 @@ +package ink.wgink.gateway.dao; + +import ink.wgink.gateway.pojo.BasePOJO; + +import java.util.List; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: IBaseDao + * @Description: + * @Author: wanggeng + * @Date: 2021/4/13 6:29 下午 + * @Version: 1.0 + */ +public interface IBaseDao { + + /** + * 新增 + * + * @param po + */ + void save(PO po); + + /** + * 删除 + * + * @param ids + */ + void remote(List ids); + + /** + * 修改 + * + * @param id + * @param po + */ + void update(String id, PO po); + + /** + * 详情 + * + * @param id + * @return + */ + DTO get(String id); + + /** + * 列表 + * + * @param page + * @param size + * @return + */ + List list(int page, int size); + + /** + * 统计 + * + * @return + */ + Long count(); + +} diff --git a/src/main/java/ink/wgink/gateway/dao/route/IRouteDao.java b/src/main/java/ink/wgink/gateway/dao/route/IRouteDao.java new file mode 100644 index 0000000..487d708 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/dao/route/IRouteDao.java @@ -0,0 +1,21 @@ +package ink.wgink.gateway.dao.route; + +import ink.wgink.gateway.dao.IBaseDao; +import ink.wgink.gateway.pojo.dtos.route.RouteDTO; +import ink.wgink.gateway.pojo.pos.route.RoutePO; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: IRouteDao + * @Description: 路由 + * @Author: wanggeng + * @Date: 2021/4/13 5:28 下午 + * @Version: 1.0 + */ +public interface IRouteDao extends IBaseDao { + + String COLLECTION_NAME = "sys_route"; + +} diff --git a/src/main/java/ink/wgink/gateway/dao/route/impl/RouteDaoImpl.java b/src/main/java/ink/wgink/gateway/dao/route/impl/RouteDaoImpl.java new file mode 100644 index 0000000..cce2c20 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/dao/route/impl/RouteDaoImpl.java @@ -0,0 +1,94 @@ +package ink.wgink.gateway.dao.route.impl; + +import ink.wgink.gateway.consts.ISystemConst; +import ink.wgink.gateway.dao.BaseDao; +import ink.wgink.gateway.dao.route.IRouteDao; +import ink.wgink.gateway.pojo.dtos.route.RouteDTO; +import ink.wgink.gateway.pojo.pos.route.RoutePO; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.data.mongodb.core.aggregation.Aggregation; +import org.springframework.data.mongodb.core.aggregation.AggregationOperation; +import org.springframework.data.mongodb.core.aggregation.AggregationResults; +import org.springframework.data.mongodb.core.query.Criteria; +import org.springframework.data.mongodb.core.query.Query; +import org.springframework.data.mongodb.core.query.Update; +import org.springframework.stereotype.Repository; + +import java.util.ArrayList; +import java.util.List; +import java.util.Map; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: RouteDaoImpl + * @Description: 路由 + * @Author: wanggeng + * @Date: 2021/4/13 5:32 下午 + * @Version: 1.0 + */ +@Slf4j +@Repository +public class RouteDaoImpl extends BaseDao implements IRouteDao { + + @Autowired + private MongoTemplate mongoTemplate; + + @Override + public void save(RoutePO routePO) { + setSave(routePO); + mongoTemplate.save(routePO); + } + + @Override + public void remote(List ids) { + if (ids.isEmpty()) { + return; + } + Criteria queryCriteria = Criteria.where(ISystemConst.UUID); + for (int i = 0; i < ids.size(); i++) { + if (i > 0) { + queryCriteria.and(ISystemConst.UUID); + } + queryCriteria.is(ids.get(i)); + } + + mongoTemplate.remove(new Query(queryCriteria), RoutePO.class); + } + + @Override + public void update(String uuid, RoutePO routePO) { + Update update = new Update(); + update.set("system", routePO.getSystem()); + update.set("summary", routePO.getSummary()); + update.set("inUrl", routePO.getInUrl()); + update.set("outUrl", routePO.getOutUrl()); + setUpdate(update); + mongoTemplate.updateMulti(new Query(Criteria.where(ISystemConst.UUID).is(uuid)), update, RoutePO.class); + } + + @Override + public RouteDTO get(String uuid) { + return mongoTemplate.findOne(new Query(Criteria.where(ISystemConst.UUID).is(uuid)), RouteDTO.class); + } + + @Override + public List list(int page, int size) { + Query query = new Query(); + query.limit(getLimit(size)); + query.skip(getSkip(page, size)); + return mongoTemplate.find(query, RouteDTO.class); + } + + @Override + public Long count() { + List operations = new ArrayList<>(); + operations.add(Aggregation.group(ISystemConst.UUID).count().as(ISystemConst.COUNT)); + Aggregation aggregation = Aggregation.newAggregation(operations); + AggregationResults results = mongoTemplate.aggregate(aggregation, COLLECTION_NAME, Map.class); + return Long.parseLong(results.getMappedResults().get(0).get(ISystemConst.COUNT).toString()); + } +} diff --git a/src/main/java/ink/wgink/gateway/filter/global/CountGlobalFilter.java b/src/main/java/ink/wgink/gateway/filter/global/CountGlobalFilter.java index d923da7..36dba80 100644 --- a/src/main/java/ink/wgink/gateway/filter/global/CountGlobalFilter.java +++ b/src/main/java/ink/wgink/gateway/filter/global/CountGlobalFilter.java @@ -1,12 +1,19 @@ package ink.wgink.gateway.filter.global; +import lombok.extern.slf4j.Slf4j; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.cloud.gateway.filter.GatewayFilterChain; import org.springframework.cloud.gateway.filter.GlobalFilter; import org.springframework.core.Ordered; +import org.springframework.core.annotation.Order; import org.springframework.stereotype.Component; import org.springframework.web.server.ServerWebExchange; import reactor.core.publisher.Mono; +import java.net.URI; +import java.util.concurrent.atomic.AtomicInteger; + /** * When you feel like quitting. Think about why you started * 当你想要放弃的时候，想想当初你为何开始 @@ -17,12 +24,19 @@ import reactor.core.publisher.Mono; * @Date: 2021/4/13 12:10 * @Version: 1.0 **/ +@Slf4j @Component public class CountGlobalFilter implements GlobalFilter, Ordered { + private AtomicInteger count = new AtomicInteger(0); + @Override public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) { - System.out.println("count filter"); + URI uri = exchange.getRequest().getURI(); + System.out.println(); + System.out.println("uri: " + uri); + System.out.println("count: "+ count.getAndAdd(1)); + System.out.println(); return chain.filter(exchange); // return exchange.getResponse().setComplete(); } diff --git a/src/main/java/ink/wgink/gateway/pojo/BasePOJO.java b/src/main/java/ink/wgink/gateway/pojo/BasePOJO.java new file mode 100644 index 0000000..5a5f783 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/pojo/BasePOJO.java @@ -0,0 +1,26 @@ +package ink.wgink.gateway.pojo; + +import lombok.Data; +import org.springframework.data.mongodb.core.index.Indexed; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: BasePO + * @Description: + * @Author: wanggeng + * @Date: 2021/4/13 5:56 下午 + * @Version: 1.0 + */ +@Data +public class BasePOJO { + + @Indexed + private String uuid; + private String gmtCreate; + private String creator; + private String gmtModified; + private String modifier; + +} diff --git a/src/main/java/ink/wgink/gateway/pojo/ListPage.java b/src/main/java/ink/wgink/gateway/pojo/ListPage.java new file mode 100644 index 0000000..d58128a --- /dev/null +++ b/src/main/java/ink/wgink/gateway/pojo/ListPage.java @@ -0,0 +1,33 @@ +package ink.wgink.gateway.pojo; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: ListPage + * @Description: + * @Author: wanggeng + * @Date: 2021/4/13 6:19 下午 + * @Version: 1.0 + */ +public class ListPage { + + private Integer page; + private Integer size; + + public Integer getPage() { + return page == null ? 1 : page; + } + + public void setPage(Integer page) { + this.page = page; + } + + public Integer getSize() { + return size == null ? 20 : size; + } + + public void setSize(Integer size) { + this.size = size; + } +} diff --git a/src/main/java/ink/wgink/gateway/pojo/dtos/route/RouteDTO.java b/src/main/java/ink/wgink/gateway/pojo/dtos/route/RouteDTO.java new file mode 100644 index 0000000..6e586e4 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/pojo/dtos/route/RouteDTO.java @@ -0,0 +1,33 @@ +package ink.wgink.gateway.pojo.dtos.route; + +import ink.wgink.gateway.pojo.BasePOJO; +import lombok.Data; +import lombok.ToString; +import org.springframework.data.annotation.Id; +import org.springframework.data.mongodb.core.index.Indexed; +import org.springframework.data.mongodb.core.mapping.Document; + +import java.io.Serializable; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: RouteDTO + * @Description: 路由 + * @Author: wanggeng + * @Date: 2021/4/13 7:15 下午 + * @Version: 1.0 + */ +@Data +@ToString +@Document(collection = "sys_route") +public class RouteDTO extends BasePOJO implements Serializable { + + private static final long serialVersionUID = -4892456861969101733L; + private String system; + private String summary; + private String outUrl; + private String inUrl; + +} diff --git a/src/main/java/ink/wgink/gateway/pojo/pos/route/RoutePO.java b/src/main/java/ink/wgink/gateway/pojo/pos/route/RoutePO.java new file mode 100644 index 0000000..d1d4d45 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/pojo/pos/route/RoutePO.java @@ -0,0 +1,35 @@ +package ink.wgink.gateway.pojo.pos.route; + +import ink.wgink.gateway.pojo.BasePOJO; +import lombok.Data; +import lombok.ToString; +import org.springframework.data.annotation.Id; +import org.springframework.data.mongodb.core.index.Indexed; +import org.springframework.data.mongodb.core.mapping.Document; + +import java.io.Serializable; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: RoutePO + * @Description: 路由 + * @Author: wanggeng + * @Date: 2021/4/13 5:20 下午 + * @Version: 1.0 + */ +@Data +@ToString +@Document(collection = "sys_route") +public class RoutePO extends BasePOJO implements Serializable { + private static final long serialVersionUID = 3471850588453134724L; + @Indexed + private String system; + private String summary; + @Indexed + private String outUrl; + @Indexed + private String inUrl; + +} diff --git a/src/main/java/ink/wgink/gateway/pojo/result/ErrorResult.java b/src/main/java/ink/wgink/gateway/pojo/result/ErrorResult.java new file mode 100644 index 0000000..83e471a --- /dev/null +++ b/src/main/java/ink/wgink/gateway/pojo/result/ErrorResult.java @@ -0,0 +1,99 @@ +package ink.wgink.gateway.pojo.result; + +import java.io.Serializable; + +/** + * @ClassName: ErrorResult + * @Description: 错误结果 + * @Author: WangGeng + * @Date: 2019/3/2 3:37 PM + * @Version: 1.0 + **/ +public class ErrorResult implements Serializable { + + private Integer code; + private String msg; + private String detail; + + public ErrorResult() { + } + + public ErrorResult(Integer code, String msg) { + this.code = code; + this.msg = msg; + } + + public Integer getCode() { + return code; + } + + public void setCode(Integer code) { + this.code = code; + } + + public String getMsg() { + return msg; + } + + public void setMsg(String msg) { + this.msg = msg; + } + + public String getDetail() { + return detail == null ? "" : detail.trim(); + } + + public void setDetail(String detail) { + this.detail = detail; + } + + @Override + public String toString() { + final StringBuilder sb = new StringBuilder("{"); + sb.append("\"code\":") + .append(code); + sb.append(",\"msg\":\"") + .append(msg).append('\"'); + sb.append(",\"detail\":\"") + .append(detail).append('\"'); + sb.append('}'); + return sb.toString(); + } + + public enum ErrorResultCodeEnum { + + /** + * 错误类型 + */ + SYSTEM_ERROR(40001), + ENCODE_ERROR(40002), + DECODE_ERROR(40003), + APP_DEPENDENCY_ERROR(40004), + PROPERTIES_ERROR(40005), + TEXT_ILLEGAL(40101), + PARAMS_ERROR(40102), + QUERY_ERROR(40101), + SAVE_ERROR(40102), + UPDATE_ERROR(40103), + REMOVE_ERROR(40104), + FILE_ERROR(40401), + TEST_ERROR(40201), + LOGIN_OUT(40301), + TOKEN_ERROR(40302), + USERNAME_PASSWORD_ERROR(40303), + USER_EXIST(40304), + PERMISSION_ERROR(40401), + DEVICE_ERROR(40501), + DEVICE_VERSION_ERROR(40502); + + private int value; + + ErrorResultCodeEnum(int value) { + this.value = value; + } + + public int getValue() { + return value; + } + } +} diff --git a/src/main/java/ink/wgink/gateway/pojo/result/SuccessResult.java b/src/main/java/ink/wgink/gateway/pojo/result/SuccessResult.java new file mode 100644 index 0000000..80b4de8 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/pojo/result/SuccessResult.java @@ -0,0 +1,22 @@ +package ink.wgink.gateway.pojo.result; + +import java.io.Serializable; + +/** + * @ClassName: SuccessResult + * @Description: 成功结果 + * @Author: WangGeng + * @Date: 2019/3/2 11:52 PM + * @Version: 1.0 + **/ +public class SuccessResult implements Serializable { + + private static final long serialVersionUID = 2794583329290530150L; + + @Override + public String toString() { + final StringBuilder sb = new StringBuilder("{"); + sb.append('}'); + return sb.toString(); + } +} diff --git a/src/main/java/ink/wgink/gateway/pojo/result/SuccessResultData.java b/src/main/java/ink/wgink/gateway/pojo/result/SuccessResultData.java new file mode 100644 index 0000000..997ec52 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/pojo/result/SuccessResultData.java @@ -0,0 +1,36 @@ +package ink.wgink.gateway.pojo.result; + +/** + * @ClassName: SuccessResultData + * @Description: 返回结果带对象 + * @Author: WangGeng + * @Date: 2019/3/11 9:31 AM + * @Version: 1.0 + **/ +public class SuccessResultData extends SuccessResult { + + private static final long serialVersionUID = 2292105832378967169L; + private T data; + + public SuccessResultData(T data) { + this.data = data; + } + + public T getData() { + return data; + } + + public void setData(T data) { + this.data = data; + } + + @Override + public String toString() { + final StringBuilder sb = new StringBuilder("{"); + sb.append("\"data\":") + .append(data); + sb.append('}'); + return sb.toString(); + } + +} diff --git a/src/main/java/ink/wgink/gateway/pojo/result/SuccessResultList.java b/src/main/java/ink/wgink/gateway/pojo/result/SuccessResultList.java new file mode 100644 index 0000000..9d58f16 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/pojo/result/SuccessResultList.java @@ -0,0 +1,61 @@ +package ink.wgink.gateway.pojo.result; + +/** + * @ClassName: SuccessResultList + * @Description: 成功列表结果 + * @Author: WangGeng + * @Date: 2019/3/3 12:21 AM + * @Version: 1.0 + **/ +public class SuccessResultList extends SuccessResult { + + private List rows; + private Integer page; + private Long total; + + public SuccessResultList() { + } + + public SuccessResultList(List rows, Integer page, Long total) { + this.rows = rows; + this.page = page; + this.total = total; + } + + public List getRows() { + return rows; + } + + public void setRows(List rows) { + this.rows = rows; + } + + public Integer getPage() { + return page; + } + + public void setPage(Integer page) { + this.page = page; + } + + public Long getTotal() { + return total; + } + + public void setTotal(Long total) { + this.total = total; + } + + @Override + public String toString() { + final StringBuilder sb = new StringBuilder("{"); + sb.append("\"rows\":") + .append(rows); + sb.append(",\"page\":") + .append(page); + sb.append(",\"total\":") + .append(total); + sb.append('}'); + return sb.toString(); + } +} diff --git a/src/main/java/ink/wgink/gateway/pojo/result/UploadExcelResultDTO.java b/src/main/java/ink/wgink/gateway/pojo/result/UploadExcelResultDTO.java new file mode 100644 index 0000000..1695ea2 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/pojo/result/UploadExcelResultDTO.java @@ -0,0 +1,61 @@ +package ink.wgink.gateway.pojo.result; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: UploadExcelResultDTO + * @Description: 上传Excel结果 + * @Author: WangGeng + * @Date: 2020/1/6 10:41 下午 + * @Version: 1.0 + **/ +public class UploadExcelResultDTO { + + private Integer failedCount; + private Long usedTime; + private String errorExcel; + + public UploadExcelResultDTO(Integer failedCount, Long usedTime, String errorExcel) { + this.failedCount = failedCount; + this.usedTime = usedTime; + this.errorExcel = errorExcel; + } + + public Integer getFailedCount() { + return failedCount; + } + + public void setFailedCount(Integer failedCount) { + this.failedCount = failedCount; + } + + public Long getUsedTime() { + return usedTime; + } + + public void setUsedTime(Long usedTime) { + this.usedTime = usedTime; + } + + public String getErrorExcel() { + return errorExcel == null ? "" : errorExcel.trim(); + } + + public void setErrorExcel(String errorExcel) { + this.errorExcel = errorExcel; + } + + @Override + public String toString() { + final StringBuilder sb = new StringBuilder("{"); + sb.append("\"failedCount\":") + .append(failedCount); + sb.append(",\"usedTime\":") + .append(usedTime); + sb.append(",\"errorExcel\":") + .append("\"").append(errorExcel).append("\""); + sb.append('}'); + return sb.toString(); + } +} diff --git a/src/main/java/ink/wgink/gateway/pojo/vos/route/RouteVO.java b/src/main/java/ink/wgink/gateway/pojo/vos/route/RouteVO.java new file mode 100644 index 0000000..9e2727f --- /dev/null +++ b/src/main/java/ink/wgink/gateway/pojo/vos/route/RouteVO.java @@ -0,0 +1,57 @@ +package ink.wgink.gateway.pojo.vos.route; + +import lombok.Data; +import lombok.ToString; +import org.springframework.data.mongodb.core.index.Indexed; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: RouteVO + * @Description: 路由 + * @Author: wanggeng + * @Date: 2021/4/13 6:45 下午 + * @Version: 1.0 + */ +@Data +@ToString +public class RouteVO { + + private String system; + private String summary; + private String outUrl; + private String inUrl; + + public String getSystem() { + return system == null ? "" : system; + } + + public void setSystem(String system) { + this.system = system; + } + + public String getSummary() { + return summary == null ? "" : summary; + } + + public void setSummary(String summary) { + this.summary = summary; + } + + public String getOutUrl() { + return outUrl == null ? "" : outUrl; + } + + public void setOutUrl(String outUrl) { + this.outUrl = outUrl; + } + + public String getInUrl() { + return inUrl == null ? "" : inUrl; + } + + public void setInUrl(String inUrl) { + this.inUrl = inUrl; + } +} diff --git a/src/main/java/ink/wgink/gateway/service/BaseService.java b/src/main/java/ink/wgink/gateway/service/BaseService.java new file mode 100644 index 0000000..35b122b --- /dev/null +++ b/src/main/java/ink/wgink/gateway/service/BaseService.java @@ -0,0 +1,14 @@ +package ink.wgink.gateway.service; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: BaseService + * @Description: + * @Author: wanggeng + * @Date: 2021/4/13 6:42 下午 + * @Version: 1.0 + */ +public class BaseService { +} diff --git a/src/main/java/ink/wgink/gateway/service/route/IRouteService.java b/src/main/java/ink/wgink/gateway/service/route/IRouteService.java new file mode 100644 index 0000000..4eac0c2 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/service/route/IRouteService.java @@ -0,0 +1,38 @@ +package ink.wgink.gateway.service.route; + +import ink.wgink.gateway.pojo.ListPage; +import ink.wgink.gateway.pojo.dtos.route.RouteDTO; +import ink.wgink.gateway.pojo.result.SuccessResultList; +import ink.wgink.gateway.pojo.vos.route.RouteVO; +import ink.wgink.gateway.util.ReflectUtil; + +import java.util.List; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: IRouteService + * @Description: 路由 + * @Author: wanggeng + * @Date: 2021/4/13 6:42 下午 + * @Version: 1.0 + */ +public interface IRouteService { + + /** + * 保存 + * + * @param routeVO + * @throws ReflectUtil.ReflectException + */ + void save(RouteVO routeVO) throws ReflectUtil.ReflectException; + + /** + * 分页列表 + * + * @param page + * @return + */ + SuccessResultList> listPage(ListPage page); +} diff --git a/src/main/java/ink/wgink/gateway/service/route/impl/RouteServiceImpl.java b/src/main/java/ink/wgink/gateway/service/route/impl/RouteServiceImpl.java new file mode 100644 index 0000000..c276ec8 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/service/route/impl/RouteServiceImpl.java @@ -0,0 +1,44 @@ +package ink.wgink.gateway.service.route.impl; + +import ink.wgink.gateway.dao.route.IRouteDao; +import ink.wgink.gateway.pojo.ListPage; +import ink.wgink.gateway.pojo.dtos.route.RouteDTO; +import ink.wgink.gateway.pojo.pos.route.RoutePO; +import ink.wgink.gateway.pojo.result.SuccessResultList; +import ink.wgink.gateway.pojo.vos.route.RouteVO; +import ink.wgink.gateway.service.BaseService; +import ink.wgink.gateway.service.route.IRouteService; +import ink.wgink.gateway.util.ReflectUtil; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: RouteServiceImpl + * @Description: 路由 + * @Author: wanggeng + * @Date: 2021/4/13 6:42 下午 + * @Version: 1.0 + */ +@Service +public class RouteServiceImpl extends BaseService implements IRouteService { + + @Autowired + private IRouteDao routeDao; + + @Override + public void save(RouteVO routeVO) throws ReflectUtil.ReflectException { + routeDao.save(ReflectUtil.beanToBean(routeVO, RoutePO.class)); + } + + @Override + public SuccessResultList> listPage(ListPage page) { + List routeDTOs = routeDao.list(page.getPage(), page.getSize()); + Long count = routeDao.count(); + return new SuccessResultList<>(routeDTOs, page.getPage(), count); + } +} diff --git a/src/main/java/ink/wgink/gateway/util/DateUtil.java b/src/main/java/ink/wgink/gateway/util/DateUtil.java new file mode 100644 index 0000000..7ed6940 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/util/DateUtil.java @@ -0,0 +1,457 @@ +package ink.wgink.gateway.util; + +import org.joda.time.DateTime; +import org.springframework.util.StringUtils; + +import java.text.DateFormat; +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.util.Calendar; +import java.util.Date; + +/** + * 说明：日期处理 创建人：CM 修改时间：2015年11月24日 + */ +public class DateUtil { + + public final static String AM = "AM"; + public final static String PM = "PM"; + public final static SimpleDateFormat sdfYear = new SimpleDateFormat("yyyy"); + public final static SimpleDateFormat sdfMonth = new SimpleDateFormat("MM"); + public final static SimpleDateFormat sdfd = new SimpleDateFormat("dd"); + public final static SimpleDateFormat sdfDay = new SimpleDateFormat("yyyy-MM-dd"); + public final static SimpleDateFormat sdfDayZh = new SimpleDateFormat("yyyy年MM月dd日"); + public final static SimpleDateFormat sdfDays = new SimpleDateFormat("yyyyMMdd"); + public final static SimpleDateFormat sdfTime = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + public final static SimpleDateFormat sdfTimes = new SimpleDateFormat("yyyyMMddHHmmss"); + public final static SimpleDateFormat sdfYearMonth = new SimpleDateFormat("yyyyMM"); + + public static String getZhDate(String date) { + try { + return sdfDayZh.format(sdfDay.parse(date)); + } catch (Exception e) { + e.printStackTrace(); + return date; + } + } + + /** + * 校验日期格式 + * + * @param date + * @param simpleDateFormat + * @return + */ + public static boolean checkFormat(String date, SimpleDateFormat simpleDateFormat) { + if (StringUtils.isEmpty(date) || simpleDateFormat == null) { + return false; + } + try { + simpleDateFormat.parse(date); + return true; + } catch (ParseException e) { + return false; + } + } + + /** + * 获取YYYYMM格式 + * + * @return + */ + public static String getSdfYearMonth() { + return sdfYearMonth.format(new Date()); + } + + /** + * 获取YYYYMMDDHHMMSS格式 + * + * @return + */ + public static String getSdfTimes() { + return sdfTimes.format(new Date()); + } + + /** + * 获取YYYY格式 + * + * @return + */ + public static String getYear() { + return sdfYear.format(new Date()); + } + + /** + * 获取MM格式 + * + * @return + */ + public static String getMonth() { + return sdfMonth.format(new Date()); + } + + /** + * 获取dd格式 + * + * @return + */ + public static String getToday() { + return sdfd.format(new Date()); + } + + /** + * 获取YYYY-MM-DD格式 + * + * @return + */ + public static String getDay() { + return sdfDay.format(new Date()); + } + + /** + * 获取YYYYMMDD格式 + * + * @return + */ + public static String getDays() { + return sdfDays.format(new Date()); + } + + /** + * 获取YYYY-MM-DD HH:mm:ss格式 + * + * @return + */ + public static String getTime() { + return sdfTime.format(new Date()); + } + + /** + * 截取日期 + * + * @param datetime + * @return + */ + public static String getDate(String datetime) { + return datetime.substring(0, 10); + } + + /** + * @param s + * @param e + * @return boolean + * @throws @author fh + * @Title: compareDate + * @Description: TODO(日期比较 ， 如果s > = e 返回true 否则返回false) + */ + public static boolean compareDate(String s, String e) { + if (fomatDate(s) == null || fomatDate(e) == null) { + return false; + } + return fomatDate(s).getTime() >= fomatDate(e).getTime(); + } + + /** + * 格式化日期 + * + * @param date + * @return + */ + public static Date fomatDate(String date) { + DateFormat fmt = new SimpleDateFormat("yyyy-MM-dd"); + try { + return fmt.parse(date); + } catch (ParseException e) { + e.printStackTrace(); + return null; + } + } + + /** + * 校验日期是否合法 + * + * @param s + * @return + */ + public static boolean isValidDate(String s) { + DateFormat fmt = new SimpleDateFormat("yyyy-MM-dd"); + try { + fmt.parse(s); + return true; + } catch (Exception e) { + // 如果throw java.text.ParseException或者NullPointerException，就说明格式不对 + return false; + } + } + + /** + * @param startTime + * @param endTime + * @return + */ + public static int getDiffYear(String startTime, String endTime) { + DateFormat fmt = new SimpleDateFormat("yyyy-MM-dd"); + try { + // long aa=0; + int years = (int) (((fmt.parse(endTime).getTime() - fmt.parse(startTime).getTime()) / (1000 * 60 * 60 * 24)) + / 365); + return years; + } catch (Exception e) { + // 如果throw java.text.ParseException或者NullPointerException，就说明格式不对 + return 0; + } + } + + /** + *
  • 功能描述：时间相减得到天数 + * + * @param beginDateStr + * @param endDateStr + * @return long + * @author Administrator + */ + public static long getDaySub(String beginDateStr, String endDateStr) { + long day = 0; + SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); + Date beginDate = null; + Date endDate = null; + + try { + beginDate = format.parse(beginDateStr); + endDate = format.parse(endDateStr); + } catch (ParseException e) { + e.printStackTrace(); + } + day = (endDate.getTime() - beginDate.getTime()) / (24 * 60 * 60 * 1000); + // System.out.println("相隔的天数="+day); + + return day; + } + + /** + * 得到n天之后的日期 + * + * @param days + * @return + */ + public static String getAfterDayDate(String days) { + int daysInt = Integer.parseInt(days); + // java.util包 + Calendar canlendar = Calendar.getInstance(); + // 日期减 如果不够减会将月变动 + canlendar.add(Calendar.DATE, daysInt); + Date date = canlendar.getTime(); + + SimpleDateFormat sdfd = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String dateStr = sdfd.format(date); + + return dateStr; + } + + /** + * 得到n天之后是周几 + * + * @param days + * @return + */ + public static String getAfterDayWeek(String days) { + int daysInt = Integer.parseInt(days); + // java.util包 + Calendar canlendar = Calendar.getInstance(); + // 日期减 如果不够减会将月变动 + canlendar.add(Calendar.DATE, daysInt); + Date date = canlendar.getTime(); + SimpleDateFormat sdf = new SimpleDateFormat("E"); + String dateStr = sdf.format(date); + return dateStr; + } + + /** + * 计算年龄生日格式yyyy-MM-dd + * + * @param birth + * @return + */ + public static String getAge(String birth) { + int cYear = Integer.parseInt(getYear()); + String[] births = birth.split("-"); + int year = Integer.parseInt(births[0]); + if (cYear <= year) { + return "0"; + } + int cMonth = Integer.parseInt(getMonth()); + int cDay = Integer.parseInt(getToday()); + int month = Integer.parseInt(births[1]); + int day = Integer.parseInt(births[2]); + int age = cYear - year; + if (cMonth - month > 0) { + return String.valueOf(age); + } + if (cDay - day > 0) { + return String.valueOf(age); + } + return String.valueOf(age - 1); + } + + /** + * 获取本周周一的日期 + */ + public static String weekStartDate(String pattern) { + return new DateTime().dayOfWeek().withMinimumValue().toString(pattern); + } + + /** + * 获取本周周一的日期 + */ + public static Date weekStartDate() { + return new DateTime().dayOfWeek().withMinimumValue().toDate(); + } + + /** + * 获取本周最后一天 + * + * @return + */ + public static String weekEndDate(String pattern) { + return new DateTime().dayOfWeek().withMaximumValue().toString(pattern); + } + + /** + * 获取本周最后一天 + * + * @return + */ + public static Date weekEndDate() { + return new DateTime().dayOfWeek().withMaximumValue().toDate(); + } + + /** + * 获取本月开始日期 + * + * @param pattern + * @return + */ + public static String monthStartDate(String pattern) { + return new DateTime().dayOfMonth().withMinimumValue().toString(pattern); + } + + /** + * 获取本月开始日期 + * + * @return + */ + public static Date monthStartDate() { + return new DateTime().dayOfMonth().withMinimumValue().toDate(); + } + + /** + * 获取本月结束日期 + * + * @param pattern + * @return + */ + public static String monthEndDate(String pattern) { + return new DateTime().dayOfMonth().withMaximumValue().toString(pattern); + } + + /** + * 获取本月结束日期 + * + * @return + */ + public static Date monthEndDate() { + return new DateTime().dayOfMonth().withMaximumValue().toDate(); + } + + /** + * 格式化日期 + * + * @param parseLong + * @param format + * @return + */ + public static String formatDate(long parseLong, String format) { + SimpleDateFormat simpleDateFormat = new SimpleDateFormat(format); + String date; + try { + date = simpleDateFormat.format(new Date(parseLong)); + } catch (Exception e) { + e.printStackTrace(); + return null; + } + return date; + } + + /** + * 获取前几天的日期，带格式 + * + * @param day + * @param format + * @return + */ + public static String getBeforeDate(int day, String format) { + DateTime time = new DateTime().plusDays(-day); + return sdfDay.format(time.toDate()); + } + + /** + * 计算时间差 + * + * @param startTime + * @param endTime + * @param format + * @return + */ + public static long getTimeConsuming(String startTime, String endTime, String format) throws ParseException { + SimpleDateFormat simpleDateFormat = new SimpleDateFormat("HH:mm"); + long start = simpleDateFormat.parse(startTime).getTime(); + long end = simpleDateFormat.parse(endTime).getTime(); + long useTime = end - start; + return useTime < 0 ? 0 : useTime; + } + + /** + * 计算年龄 + * + * @param birthday yyyy-MM-dd + * @return + */ + public static int getAgeByBirthday(String birthday) { + int age = 0; + String[] days = getDay().split("-"); + String[] births = birthday.split("-"); + int year = Integer.parseInt(days[0]); + int birthYear = Integer.parseInt(births[0]); + int month = Integer.parseInt(days[1]); + int birthMonth = Integer.parseInt(births[1]); + int day = Integer.parseInt(days[2]); + int birthDay = Integer.parseInt(births[2]); + // 判断年龄是否相等 + if (year - birthYear > 0) { + if (month - birthMonth > 0) { + return year - birthYear; + } else if (month - birthMonth == 0) { + if (day - birthDay > 0) { + return year - birthYear; + } + return year - birthYear - 1; + } + return year - birthYear - 1; + } + return age; + } + + /** + * 获得上下午标识 + * + * @return + */ + public static String getAmPm() { + DateTime dateTime = new DateTime(); + int hour = dateTime.getHourOfDay(); + if (hour < 13) { + return AM; + } + return PM; + } +} diff --git a/src/main/java/ink/wgink/gateway/util/ReflectUtil.java b/src/main/java/ink/wgink/gateway/util/ReflectUtil.java new file mode 100644 index 0000000..34417c6 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/util/ReflectUtil.java @@ -0,0 +1,124 @@ +package ink.wgink.gateway.util; + +import ink.wgink.gateway.pojo.pos.route.RoutePO; +import ink.wgink.gateway.pojo.vos.route.RouteVO; +import org.apache.commons.lang3.StringUtils; + +import java.lang.reflect.Field; +import java.lang.reflect.InvocationTargetException; +import java.lang.reflect.Method; +import java.util.Locale; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: ReflectUtil + * @Description: 反射工具 + * @Author: WangGeng + * @Date: 2021/2/25 20:10 + * @Version: 1.0 + **/ +public class ReflectUtil { + + /** + * 获取单例对象 + * + * @param className 完整类路径 + * @param superClass 父级类或接口，没有就是当前类 + * @param + * @return + * @throws ReflectException + */ + public static T getSingleInstance(String className, Class superClass) throws ReflectException { + return getSingleInstance(className, superClass, null); + } + + /** + * 获取单例对象 + * + * @param className 完整类路径 + * @param superClass 父级类或接口，没有就是当前类 + * @param getInstanceMethodName 单例方法名，默认 getInstance + * @param + * @return + * @throws ReflectException + */ + public static T getSingleInstance(String className, Class superClass, String getInstanceMethodName) throws ReflectException { + if (className == null) { + throw new ReflectException("className 不能为空"); + } + if (superClass == null) { + throw new ReflectException("superClass 不能为空"); + } + Object singleInstanceObject = null; + try { + Class clazz = Class.forName(className); + Method[] methods = clazz.getDeclaredMethods(); + for (Method method : methods) { + if (StringUtils.equals(method.getName(), StringUtils.isBlank(getInstanceMethodName) ? "getInstance" : getInstanceMethodName)) { + singleInstanceObject = method.invoke(null); + } + } + } catch (ClassNotFoundException | IllegalAccessException | InvocationTargetException e) { + throw new ReflectException(e.getMessage(), e); + } + if (singleInstanceObject == null) { + throw new ReflectException("非单例对象"); + } + return (T) singleInstanceObject; + } + + /** + * bean转bean，相同属性的值可以相互复制 + * + * @param srcBean 源bean + * @param destBeanClass 转换后的bean类 + * @param + * @return + * @throws ReflectException + */ + public static T beanToBean(Object srcBean, Class destBeanClass) throws ReflectException { + try { + Field[] srcFieldArray = srcBean.getClass().getDeclaredFields(); + Field[] destFieldArray = destBeanClass.getDeclaredFields(); + T t = destBeanClass.newInstance(); + for (Field field : srcFieldArray) { + for (Field destField : destFieldArray) { + String destFieldName = destField.getName(); + if (!StringUtils.equals(field.getName(), destFieldName)) { + continue; + } + String firstLetter = destFieldName.substring(0, 1).toUpperCase(); + String firstUpperMethodName = firstLetter + destFieldName.substring(1, destFieldName.length()); + Method getMethod = srcBean.getClass().getMethod("get" + firstUpperMethodName); + Object value = getMethod.invoke(srcBean); + Method setMethod = destBeanClass.getMethod("set" + firstUpperMethodName, value.getClass()); + setMethod.invoke(t, value); + } + } + return t; + } catch (InstantiationException | IllegalAccessException | NoSuchMethodException | InvocationTargetException e) { + throw new ReflectException(e.getMessage(), e); + } + } + + public static class ReflectException extends ReflectiveOperationException { + + public ReflectException() { + } + + public ReflectException(String message) { + super(message); + } + + public ReflectException(String message, Throwable cause) { + super(message, cause); + } + + public ReflectException(Throwable cause) { + super(cause); + } + } + +} diff --git a/src/main/java/ink/wgink/gateway/util/UUIDUtil.java b/src/main/java/ink/wgink/gateway/util/UUIDUtil.java new file mode 100644 index 0000000..34c8b93 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/util/UUIDUtil.java @@ -0,0 +1,20 @@ +package ink.wgink.gateway.util; + +import java.util.UUID; + +/** + * UuidUtil + * + * @author WangGeng + */ +public class UUIDUtil { + + public static String getUUID() { + return UUID.randomUUID().toString().trim(); + } + + public static String get32UUID() { + return getUUID().replaceAll("-", ""); + } + +} diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index c09c7c8..cff7fdc 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -4,3 +4,11 @@ spring: cloud: gateway: enabled: true + data: + mongodb: + uri: mongodb://127.0.0.1:27017/gateway + +logging: + level: + org: debug + ink.wgink: debug \ No newline at end of file diff --git a/src/main/resources/static/route/list.html b/src/main/resources/static/route/list.html new file mode 100644 index 0000000..7fd1b69 --- /dev/null +++ b/src/main/resources/static/route/list.html @@ -0,0 +1,10 @@ + + + + + Title + + +

    Hello Gateway

    + + \ No newline at end of file