From 4376a53d8e27d0a70038be2ecfa063f08b8b44d8 Mon Sep 17 00:00:00 2001 From: WenG <450292408@qq.com> Date: Mon, 19 Apr 2021 23:37:33 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E7=BD=91=E5=85=B3=E9=80=BB?= =?UTF-8?q?=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 7 +- .../ink/wgink/gateway/config/BeanConfig.java | 4 - .../controller/api/route/RouteController.java | 47 --------- .../java/ink/wgink/gateway/dao/IBaseDao.java | 65 ------------- .../wgink/gateway/dao/route/IRouteDao.java | 14 ++- .../gateway/dao/route/impl/RouteDaoImpl.java | 94 ------------------ .../filter/global/CountGlobalFilter.java | 3 - .../BaseDao.java => handler/BaseHandler.java} | 21 ++-- .../gateway/handler/route/RouteHandler.java | 97 +++++++++++++++++++ .../java/ink/wgink/gateway/pojo/BasePOJO.java | 4 +- .../wgink/gateway/pojo/pos/route/RoutePO.java | 36 ------- .../route/RouteDTO.java => route/Route.java} | 4 +- .../wgink/gateway/pojo/vos/route/RouteVO.java | 25 ----- .../ink/wgink/gateway/router/AllRoutes.java | 40 ++++++++ .../wgink/gateway/service/BaseService.java | 14 --- .../gateway/service/route/IRouteService.java | 38 -------- .../service/route/impl/RouteServiceImpl.java | 44 --------- .../ink/wgink/gateway/util/ReflectUtil.java | 3 - 18 files changed, 162 insertions(+), 398 deletions(-) delete mode 100644 src/main/java/ink/wgink/gateway/controller/api/route/RouteController.java delete mode 100644 src/main/java/ink/wgink/gateway/dao/IBaseDao.java delete mode 100644 src/main/java/ink/wgink/gateway/dao/route/impl/RouteDaoImpl.java rename src/main/java/ink/wgink/gateway/{dao/BaseDao.java => handler/BaseHandler.java} (72%) create mode 100644 src/main/java/ink/wgink/gateway/handler/route/RouteHandler.java delete mode 100644 src/main/java/ink/wgink/gateway/pojo/pos/route/RoutePO.java rename src/main/java/ink/wgink/gateway/pojo/{dtos/route/RouteDTO.java => route/Route.java} (86%) delete mode 100644 src/main/java/ink/wgink/gateway/pojo/vos/route/RouteVO.java create mode 100644 src/main/java/ink/wgink/gateway/router/AllRoutes.java delete mode 100644 src/main/java/ink/wgink/gateway/service/BaseService.java delete mode 100644 src/main/java/ink/wgink/gateway/service/route/IRouteService.java delete mode 100644 src/main/java/ink/wgink/gateway/service/route/impl/RouteServiceImpl.java diff --git a/pom.xml b/pom.xml index c075360..83a1612 100644 --- a/pom.xml +++ b/pom.xml @@ -33,7 +33,7 @@ org.springframework.boot - spring-boot-starter-data-mongodb + spring-boot-starter-data-mongodb-reactive org.springframework.boot @@ -44,11 +44,6 @@ org.apache.commons commons-lang3 - - com.alibaba - fastjson - ${fastjson.version} - joda-time joda-time diff --git a/src/main/java/ink/wgink/gateway/config/BeanConfig.java b/src/main/java/ink/wgink/gateway/config/BeanConfig.java index 8ad1011..4ce162c 100644 --- a/src/main/java/ink/wgink/gateway/config/BeanConfig.java +++ b/src/main/java/ink/wgink/gateway/config/BeanConfig.java @@ -2,8 +2,6 @@ package ink.wgink.gateway.config; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.SerializationFeature; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; /** * When you feel like quitting. Think about why you started @@ -15,7 +13,6 @@ import org.springframework.context.annotation.Configuration; * @Date: 2021/2/5 6:44 下午 * @Version: 1.0 */ -@Configuration public class BeanConfig { /** @@ -23,7 +20,6 @@ public class BeanConfig { * * @return */ - @Bean public ObjectMapper objectMapper() { return new ObjectMapper().disable(SerializationFeature.FAIL_ON_EMPTY_BEANS); } 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 deleted file mode 100644 index 2f4be1e..0000000 --- a/src/main/java/ink/wgink/gateway/controller/api/route/RouteController.java +++ /dev/null @@ -1,47 +0,0 @@ -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/IBaseDao.java b/src/main/java/ink/wgink/gateway/dao/IBaseDao.java deleted file mode 100644 index 0efef2b..0000000 --- a/src/main/java/ink/wgink/gateway/dao/IBaseDao.java +++ /dev/null @@ -1,65 +0,0 @@ -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 index 487d708..dcb58cc 100644 --- a/src/main/java/ink/wgink/gateway/dao/route/IRouteDao.java +++ b/src/main/java/ink/wgink/gateway/dao/route/IRouteDao.java @@ -1,8 +1,10 @@ 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; +import ink.wgink.gateway.pojo.route.Route; +import org.springframework.data.mongodb.repository.Query; +import org.springframework.data.mongodb.repository.ReactiveMongoRepository; +import org.springframework.stereotype.Repository; +import reactor.core.publisher.Mono; /** * When you feel like quitting. Think about why you started @@ -14,8 +16,12 @@ import ink.wgink.gateway.pojo.pos.route.RoutePO; * @Date: 2021/4/13 5:28 下午 * @Version: 1.0 */ -public interface IRouteDao extends IBaseDao { +@Repository +public interface IRouteDao extends ReactiveMongoRepository { String COLLECTION_NAME = "sys_route"; + @Query("db."+ COLLECTION_NAME+ ".find") + Mono list(String uuid); + } 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 deleted file mode 100644 index cf08242..0000000 --- a/src/main/java/ink/wgink/gateway/dao/route/impl/RouteDaoImpl.java +++ /dev/null @@ -1,94 +0,0 @@ -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("path", routePO.getPath()); - update.set("uri", routePO.getUri()); - 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 36dba80..2d75b0e 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,9 @@ 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; diff --git a/src/main/java/ink/wgink/gateway/dao/BaseDao.java b/src/main/java/ink/wgink/gateway/handler/BaseHandler.java similarity index 72% rename from src/main/java/ink/wgink/gateway/dao/BaseDao.java rename to src/main/java/ink/wgink/gateway/handler/BaseHandler.java index 572409a..d4cc877 100644 --- a/src/main/java/ink/wgink/gateway/dao/BaseDao.java +++ b/src/main/java/ink/wgink/gateway/handler/BaseHandler.java @@ -1,21 +1,20 @@ -package ink.wgink.gateway.dao; +package ink.wgink.gateway.handler; 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 下午 + * @ClassName: BaseHandler + * @Description: + * @Author: WangGeng + * @Date: 2021/4/19 21:57 * @Version: 1.0 - */ -public class BaseDao { + **/ +public class BaseHandler { public static final String CREATOR = "creator"; public static final String MODIFIER = "modifier"; @@ -31,9 +30,9 @@ public class BaseDao { base.setGmtModified(datetime); } - protected void setUpdate(Update update) { - update.set(GMT_MODIFIED, DateUtil.getTime()); - update.set(MODIFIER, "1"); + protected void setUpdate(BasePOJO base) { + base.setGmtCreate(DateUtil.getTime()); + base.setModifier("1"); } protected int getLimit(int size) { diff --git a/src/main/java/ink/wgink/gateway/handler/route/RouteHandler.java b/src/main/java/ink/wgink/gateway/handler/route/RouteHandler.java new file mode 100644 index 0000000..63d9585 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/handler/route/RouteHandler.java @@ -0,0 +1,97 @@ +package ink.wgink.gateway.handler.route; + +import ink.wgink.gateway.dao.route.IRouteDao; +import ink.wgink.gateway.handler.BaseHandler; +import ink.wgink.gateway.pojo.route.Route; +import org.springframework.http.MediaType; +import org.springframework.stereotype.Component; +import org.springframework.web.reactive.function.server.ServerRequest; +import org.springframework.web.reactive.function.server.ServerResponse; +import reactor.core.publisher.Mono; + +import java.util.Arrays; +import java.util.List; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: RouteHandler + * @Description: 路由 + * @Author: WangGeng + * @Date: 2021/4/19 21:40 + * @Version: 1.0 + **/ +@Component +public class RouteHandler extends BaseHandler { + + private IRouteDao routeDao; + + public RouteHandler(IRouteDao routeDao) { + this.routeDao = routeDao; + } + + /** + * 新增 + * + * @param serverRequest + * @return + */ + public Mono save(ServerRequest serverRequest) { + Mono routeMono = serverRequest.bodyToMono(Route.class); + return routeMono.flatMap(route -> { + setSave(route); + return routeDao.save(route); + }).then(ServerResponse.ok().build()); + } + + /** + * 删除 + * + * @param serverRequest + * @return + */ + public Mono delete(ServerRequest serverRequest) { + String ids = serverRequest.pathVariable("ids"); + List idList = Arrays.asList(ids.split(",")); + return Mono.from(routeDao.findAllById(idList).flatMap(route -> routeDao.delete(route))).then(ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).build()).switchIfEmpty(ServerResponse.notFound().build()); + } + + /** + * 修改 + * + * @param serverRequest + * @return + */ + public Mono update(ServerRequest serverRequest) { + String id = serverRequest.pathVariable("id"); + Mono routeMono = serverRequest.bodyToMono(Route.class); + return routeDao.findById(id).then(routeMono.flatMap(route -> { + route.setUuid(id); + setUpdate(route); + return routeDao.save(route); + })).then(ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).build()).switchIfEmpty(ServerResponse.notFound().build()); + } + + /** + * 列表 + * + * @param serverRequest + * @return + */ + public Mono list(ServerRequest serverRequest) { + return ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(routeDao.findAll(), Route.class); + } + + /** + * 列表 + * + * @param serverRequest + * @return + */ + public Mono get(ServerRequest serverRequest) { + String id = serverRequest.pathVariable("id"); + return ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(routeDao.findById(id), Route.class).switchIfEmpty(ServerResponse.notFound().build()); + } + +} diff --git a/src/main/java/ink/wgink/gateway/pojo/BasePOJO.java b/src/main/java/ink/wgink/gateway/pojo/BasePOJO.java index 5a5f783..5072fb8 100644 --- a/src/main/java/ink/wgink/gateway/pojo/BasePOJO.java +++ b/src/main/java/ink/wgink/gateway/pojo/BasePOJO.java @@ -1,7 +1,7 @@ package ink.wgink.gateway.pojo; import lombok.Data; -import org.springframework.data.mongodb.core.index.Indexed; +import org.springframework.data.annotation.Id; /** * When you feel like quitting. Think about why you started @@ -16,7 +16,7 @@ import org.springframework.data.mongodb.core.index.Indexed; @Data public class BasePOJO { - @Indexed + @Id private String uuid; private String gmtCreate; private String creator; 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 deleted file mode 100644 index 05bcc8c..0000000 --- a/src/main/java/ink/wgink/gateway/pojo/pos/route/RoutePO.java +++ /dev/null @@ -1,36 +0,0 @@ -package ink.wgink.gateway.pojo.pos.route; - -import ink.wgink.gateway.dao.route.IRouteDao; -import ink.wgink.gateway.pojo.BasePOJO; -import lombok.Data; -import lombok.ToString; -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 = IRouteDao.COLLECTION_NAME) -public class RoutePO extends BasePOJO implements Serializable { - private static final long serialVersionUID = 3471850588453134724L; - - @Indexed - private String system; - private String summary; - @Indexed - private String path; - @Indexed - private String uri; - -} diff --git a/src/main/java/ink/wgink/gateway/pojo/dtos/route/RouteDTO.java b/src/main/java/ink/wgink/gateway/pojo/route/Route.java similarity index 86% rename from src/main/java/ink/wgink/gateway/pojo/dtos/route/RouteDTO.java rename to src/main/java/ink/wgink/gateway/pojo/route/Route.java index 15ed11a..81340a1 100644 --- a/src/main/java/ink/wgink/gateway/pojo/dtos/route/RouteDTO.java +++ b/src/main/java/ink/wgink/gateway/pojo/route/Route.java @@ -1,4 +1,4 @@ -package ink.wgink.gateway.pojo.dtos.route; +package ink.wgink.gateway.pojo.route; import ink.wgink.gateway.dao.route.IRouteDao; import ink.wgink.gateway.pojo.BasePOJO; @@ -21,7 +21,7 @@ import java.io.Serializable; @Data @ToString @Document(collection = IRouteDao.COLLECTION_NAME) -public class RouteDTO extends BasePOJO implements Serializable { +public class Route extends BasePOJO implements Serializable { private static final long serialVersionUID = -4892456861969101733L; private String system; 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 deleted file mode 100644 index a4286d4..0000000 --- a/src/main/java/ink/wgink/gateway/pojo/vos/route/RouteVO.java +++ /dev/null @@ -1,25 +0,0 @@ -package ink.wgink.gateway.pojo.vos.route; - -import lombok.Data; -import lombok.ToString; - -/** - * 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 path; - private String uri; - -} diff --git a/src/main/java/ink/wgink/gateway/router/AllRoutes.java b/src/main/java/ink/wgink/gateway/router/AllRoutes.java new file mode 100644 index 0000000..e15d562 --- /dev/null +++ b/src/main/java/ink/wgink/gateway/router/AllRoutes.java @@ -0,0 +1,40 @@ +package ink.wgink.gateway.router; + +import ink.wgink.gateway.handler.route.RouteHandler; +import org.springframework.context.annotation.Bean; +import org.springframework.stereotype.Component; +import org.springframework.web.reactive.function.server.*; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: AllRoutes + * @Description: 总路由 + * @Author: WangGeng + * @Date: 2021/4/19 22:57 + * @Version: 1.0 + **/ +@Component +public class AllRoutes { + + /** + * 路由管理 + * + * @param routeHandler + * @return + */ + @Bean + public RouterFunction routeRouter(RouteHandler routeHandler) { + // 嵌套 + return RouterFunctions.nest(RequestPredicates.path("/route"), + RouterFunctions + .route(RequestPredicates.POST("/save"), routeHandler::save) + .andRoute(RequestPredicates.DELETE("/delete/{ids}"), routeHandler::delete) + .andRoute(RequestPredicates.PUT("/update/{id}"), routeHandler::update) + .andRoute(RequestPredicates.GET("/list"), routeHandler::list) + .andRoute(RequestPredicates.GET("get/{id}"), routeHandler::get) + ); + } + +} diff --git a/src/main/java/ink/wgink/gateway/service/BaseService.java b/src/main/java/ink/wgink/gateway/service/BaseService.java deleted file mode 100644 index 35b122b..0000000 --- a/src/main/java/ink/wgink/gateway/service/BaseService.java +++ /dev/null @@ -1,14 +0,0 @@ -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 deleted file mode 100644 index 4eac0c2..0000000 --- a/src/main/java/ink/wgink/gateway/service/route/IRouteService.java +++ /dev/null @@ -1,38 +0,0 @@ -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 deleted file mode 100644 index c276ec8..0000000 --- a/src/main/java/ink/wgink/gateway/service/route/impl/RouteServiceImpl.java +++ /dev/null @@ -1,44 +0,0 @@ -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/ReflectUtil.java b/src/main/java/ink/wgink/gateway/util/ReflectUtil.java index 34417c6..68bc26b 100644 --- a/src/main/java/ink/wgink/gateway/util/ReflectUtil.java +++ b/src/main/java/ink/wgink/gateway/util/ReflectUtil.java @@ -1,13 +1,10 @@ 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