From f429ebd16a5dfd5af24f93df698604d877c123eb Mon Sep 17 00:00:00 2001 From: icanci Date: Sat, 12 Nov 2022 08:48:29 +0800 Subject: [PATCH] =?UTF-8?q?=E7=8E=AF=E5=A2=83=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../rec/admin/biz/service/DomainService.java | 16 +++++++-- .../biz/service/impl/DomainServiceImpl.java | 16 ++++++--- .../mongodb/daointerface/LogOperateDAO.java | 5 --- .../dal/mongodb/mongo/AbstractBaseDAO.java | 12 +++++-- .../dal/mongodb/mongo/MongoLogOperateDAO.java | 8 +++-- .../icanci/rec/admin/dal/utils/EnvUtils.java | 33 +++++++++++++++++++ .../icanci/rec/admin/dal/utils/IDHolder.java | 2 ++ .../admin/dal/utils/service/EnvService.java | 14 ++++++++ .../{ => service}/IDGeneratorService.java | 2 +- .../dal/utils/{ => service}/SnowFlake.java | 2 +- .../utils/service/impl/EnvServiceImpl.java | 30 +++++++++++++++++ .../impl}/IDGeneratorServiceImpl.java | 6 +++- .../src/main/resources/application.yml | 3 ++ 13 files changed, 130 insertions(+), 19 deletions(-) create mode 100644 rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/EnvUtils.java create mode 100644 rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/EnvService.java rename rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/{ => service}/IDGeneratorService.java (84%) rename rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/{ => service}/SnowFlake.java (98%) create mode 100644 rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/impl/EnvServiceImpl.java rename rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/{ => service/impl}/IDGeneratorServiceImpl.java (77%) diff --git a/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/service/DomainService.java b/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/service/DomainService.java index 69388d5..a4fc4d0 100644 --- a/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/service/DomainService.java +++ b/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/service/DomainService.java @@ -1,6 +1,6 @@ package cn.icanci.rec.admin.biz.service; -import cn.icanci.rec.admin.dal.mongodb.dateobject.DomainDO; +import cn.icanci.rec.common.model.config.DomainVO; import java.util.List; @@ -10,5 +10,17 @@ import java.util.List; */ public interface DomainService { - List queryAll(); + /** + * 查询所有Domain + * + * @return 返回所有Domain + */ + List queryAll(); + + /** + * 保存或者更新一条信息 + * + * @param domain domain + */ + void save(DomainVO domain); } diff --git a/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/service/impl/DomainServiceImpl.java b/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/service/impl/DomainServiceImpl.java index 65a4cd2..36ba0d5 100644 --- a/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/service/impl/DomainServiceImpl.java +++ b/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/service/impl/DomainServiceImpl.java @@ -1,8 +1,9 @@ package cn.icanci.rec.admin.biz.service.impl; +import cn.icanci.rec.admin.biz.mapper.DomainMapper; import cn.icanci.rec.admin.biz.service.DomainService; import cn.icanci.rec.admin.dal.mongodb.daointerface.DomainDAO; -import cn.icanci.rec.admin.dal.mongodb.dateobject.DomainDO; +import cn.icanci.rec.common.model.config.DomainVO; import java.util.List; @@ -19,10 +20,17 @@ import org.springframework.stereotype.Service; @Service public class DomainServiceImpl implements DomainService { @Resource - private DomainDAO domainDAO; + private DomainDAO domainDAO; + @Resource + private DomainMapper domainMapper; @Override - public List queryAll() { - return domainDAO.queryAll(); + public List queryAll() { + return domainMapper.dos2vos(domainDAO.queryAll()); + } + + @Override + public void save(DomainVO domain) { + } } diff --git a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/mongodb/daointerface/LogOperateDAO.java b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/mongodb/daointerface/LogOperateDAO.java index c570f66..5061819 100644 --- a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/mongodb/daointerface/LogOperateDAO.java +++ b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/mongodb/daointerface/LogOperateDAO.java @@ -19,11 +19,6 @@ public interface LogOperateDAO { */ Class COLLECTION_CLASS = LogOperateDO.class; - /** - * 默认环境 - */ - String DEFAULT_ENV = "test"; - /** * 插入文档一条记录 * diff --git a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/mongodb/mongo/AbstractBaseDAO.java b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/mongodb/mongo/AbstractBaseDAO.java index 27e85be..198118d 100644 --- a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/mongodb/mongo/AbstractBaseDAO.java +++ b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/mongodb/mongo/AbstractBaseDAO.java @@ -2,17 +2,20 @@ package cn.icanci.rec.admin.dal.mongodb.mongo; import cn.icanci.rec.admin.dal.mongodb.daointerface.BaseDAO; import cn.icanci.rec.admin.dal.mongodb.dateobject.BaseDO; +import cn.icanci.rec.admin.dal.utils.EnvUtils; import cn.icanci.rec.admin.dal.utils.IDHolder; import java.util.Date; +import org.springframework.beans.factory.InitializingBean; + /** * @author icanci * @since 1.0 Created in 2022/10/24 22:47 */ -public abstract class AbstractBaseDAO extends MongoPageHelper implements BaseDAO { +public abstract class AbstractBaseDAO extends MongoPageHelper implements BaseDAO, InitializingBean { - protected String DEFAULT_ENV = "test"; + protected String DEFAULT_ENV; @Override public void insert(T t) { @@ -29,4 +32,9 @@ public abstract class AbstractBaseDAO extends MongoPageHelper public void update(T t) { t.setUpdateTime(new Date()); } + + @Override + public void afterPropertiesSet() throws Exception { + DEFAULT_ENV = EnvUtils.getEnv(); + } } diff --git a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/mongodb/mongo/MongoLogOperateDAO.java b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/mongodb/mongo/MongoLogOperateDAO.java index bc1b082..d0195ee 100644 --- a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/mongodb/mongo/MongoLogOperateDAO.java +++ b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/mongodb/mongo/MongoLogOperateDAO.java @@ -3,6 +3,7 @@ package cn.icanci.rec.admin.dal.mongodb.mongo; import cn.icanci.rec.admin.dal.mongodb.common.PageList; import cn.icanci.rec.admin.dal.mongodb.daointerface.LogOperateDAO; import cn.icanci.rec.admin.dal.mongodb.dateobject.LogOperateDO; +import cn.icanci.rec.admin.dal.utils.EnvUtils; import java.util.List; @@ -20,6 +21,7 @@ import org.springframework.stereotype.Service; public class MongoLogOperateDAO extends MongoPageHelper implements LogOperateDAO { @Override public void insert(LogOperateDO t) { + t.setEnv(EnvUtils.getEnv()); mongoTemplate.insert(t); } @@ -30,7 +32,7 @@ public class MongoLogOperateDAO extends MongoPageHelper implements LogOperateDAO @Override public List queryAll() { - Criteria criteria = Criteria.where(LogColumn.env).is(DEFAULT_ENV); + Criteria criteria = Criteria.where(LogColumn.env).is(EnvUtils.getEnv()); Query query = new Query(criteria); return mongoTemplate.find(query, COLLECTION_CLASS, COLLECTION_NAME); @@ -38,7 +40,7 @@ public class MongoLogOperateDAO extends MongoPageHelper implements LogOperateDAO @Override public PageList pageQuery(LogOperateDO t, int pageNum, int pageSize) { - Criteria criteria = Criteria.where(LogColumn.env).is(DEFAULT_ENV); + Criteria criteria = Criteria.where(LogColumn.env).is(EnvUtils.getEnv()); if (StringUtils.isNotBlank(t.getModule())) { // 不分区大小写查询，其中操作符"i"：表示不分区大小写 criteria.and(LogColumn.module).is(t.getModule()); @@ -54,7 +56,7 @@ public class MongoLogOperateDAO extends MongoPageHelper implements LogOperateDAO @Override public LogOperateDO queryOneById(String _id) { Criteria criteria = Criteria.where(LogColumn._id).is(_id); - criteria.and(LogColumn.env).is(DEFAULT_ENV); + criteria.and(LogColumn.env).is(EnvUtils.getEnv()); Query query = new Query(criteria); return mongoTemplate.findOne(query, COLLECTION_CLASS, COLLECTION_NAME); } diff --git a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/EnvUtils.java b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/EnvUtils.java new file mode 100644 index 0000000..fe6db4e --- /dev/null +++ b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/EnvUtils.java @@ -0,0 +1,33 @@ +package cn.icanci.rec.admin.dal.utils; + +import cn.icanci.rec.admin.dal.utils.service.EnvService; +import cn.icanci.rec.admin.dal.utils.service.impl.EnvServiceImpl; + +import org.apache.commons.lang3.StringUtils; + +/** + * 环境标识 + * + * @author icanci + * @since 1.0 Created in 2022/11/12 08:26 + */ +public class EnvUtils { + + private static final String DEFAULT_ENV = "test"; + + private static EnvService envService; + + private static String currEnv; + + public static String getEnv() { + if (StringUtils.isBlank(currEnv)) { + String env = envService.getEnv(); + currEnv = StringUtils.isBlank(env) ? DEFAULT_ENV : env; + } + return currEnv; + } + + public static void setEnvService(EnvServiceImpl envService) { + EnvUtils.envService = envService; + } +} diff --git a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/IDHolder.java b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/IDHolder.java index 474f973..f211add 100644 --- a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/IDHolder.java +++ b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/IDHolder.java @@ -1,5 +1,7 @@ package cn.icanci.rec.admin.dal.utils; +import cn.icanci.rec.admin.dal.utils.service.IDGeneratorService; + /** * Id 生成器 * diff --git a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/EnvService.java b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/EnvService.java new file mode 100644 index 0000000..81e5a87 --- /dev/null +++ b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/EnvService.java @@ -0,0 +1,14 @@ +package cn.icanci.rec.admin.dal.utils.service; + +/** + * @author icanci + * @since 1.0 Created in 2022/11/12 08:28 + */ +public interface EnvService { + /** + * 获取当前的环境信息 + * + * @return 返回当前的环境信息 + */ + String getEnv(); +} diff --git a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/IDGeneratorService.java b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/IDGeneratorService.java similarity index 84% rename from rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/IDGeneratorService.java rename to rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/IDGeneratorService.java index 331f5a0..610f205 100644 --- a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/IDGeneratorService.java +++ b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/IDGeneratorService.java @@ -1,4 +1,4 @@ -package cn.icanci.rec.admin.dal.utils; +package cn.icanci.rec.admin.dal.utils.service; /** * @author icanci diff --git a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/SnowFlake.java b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/SnowFlake.java similarity index 98% rename from rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/SnowFlake.java rename to rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/SnowFlake.java index 7a079c7..10bdd65 100644 --- a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/SnowFlake.java +++ b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/SnowFlake.java @@ -1,4 +1,4 @@ -package cn.icanci.rec.admin.dal.utils; +package cn.icanci.rec.admin.dal.utils.service; /** * id生成器-雪花算法 diff --git a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/impl/EnvServiceImpl.java b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/impl/EnvServiceImpl.java new file mode 100644 index 0000000..8e3d825 --- /dev/null +++ b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/impl/EnvServiceImpl.java @@ -0,0 +1,30 @@ +package cn.icanci.rec.admin.dal.utils.service.impl; + +import cn.icanci.rec.admin.dal.utils.EnvUtils; +import cn.icanci.rec.admin.dal.utils.service.EnvService; + +import org.springframework.beans.BeansException; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.beans.factory.config.BeanPostProcessor; +import org.springframework.stereotype.Service; + +/** + * @author icanci + * @since 1.0 Created in 2022/11/12 08:29 + */ +@Service("envService") +public class EnvServiceImpl implements EnvService, BeanPostProcessor { + @Value("${rec.env}") + private String env; + + @Override + public String getEnv() { + return env; + } + + @Override + public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException { + EnvUtils.setEnvService(this); + return BeanPostProcessor.super.postProcessAfterInitialization(bean, beanName); + } +} diff --git a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/IDGeneratorServiceImpl.java b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/impl/IDGeneratorServiceImpl.java similarity index 77% rename from rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/IDGeneratorServiceImpl.java rename to rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/impl/IDGeneratorServiceImpl.java index 5357261..1548f8e 100644 --- a/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/IDGeneratorServiceImpl.java +++ b/rec-admin/rec-admin-dal/src/main/java/cn/icanci/rec/admin/dal/utils/service/impl/IDGeneratorServiceImpl.java @@ -1,4 +1,8 @@ -package cn.icanci.rec.admin.dal.utils; +package cn.icanci.rec.admin.dal.utils.service.impl; + +import cn.icanci.rec.admin.dal.utils.IDHolder; +import cn.icanci.rec.admin.dal.utils.service.IDGeneratorService; +import cn.icanci.rec.admin.dal.utils.service.SnowFlake; import org.apache.commons.lang3.RandomUtils; import org.springframework.beans.factory.InitializingBean; diff --git a/rec-admin/rec-admin-views/src/main/resources/application.yml b/rec-admin/rec-admin-views/src/main/resources/application.yml index 8f0941f..5f7ace1 100644 --- a/rec-admin/rec-admin-views/src/main/resources/application.yml +++ b/rec-admin/rec-admin-views/src/main/resources/application.yml @@ -9,6 +9,9 @@ server: logging: config: classpath:log4j2.xml +rec: + env: test + spring: # datasource: # driverClassName: com.mysql.cj.jdbc.Driver -- Gitee