From c77bfd5eaf122cd26276c3bf30ba269e77e7a865 Mon Sep 17 00:00:00 2001 From: zhouz <> Date: Wed, 15 Jul 2026 17:02:59 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=96=B0=E5=A2=9E=E7=BC=96=E7=A0=81?= =?UTF-8?q?=E8=A7=84=E5=88=99=E7=AE=A1=E7=90=86Service?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../base/service/codegen/CodeRuleService.java | 71 +++++++ .../service/codegen/CodeRuleServiceImpl.java | 190 ++++++++++++++++++ 2 files changed, 261 insertions(+) create mode 100644 nl-module-base/nl-module-base-server/src/main/java/cn/code/nl/module/base/service/codegen/CodeRuleService.java create mode 100644 nl-module-base/nl-module-base-server/src/main/java/cn/code/nl/module/base/service/codegen/CodeRuleServiceImpl.java diff --git a/nl-module-base/nl-module-base-server/src/main/java/cn/code/nl/module/base/service/codegen/CodeRuleService.java b/nl-module-base/nl-module-base-server/src/main/java/cn/code/nl/module/base/service/codegen/CodeRuleService.java new file mode 100644 index 00000000..f178f5c9 --- /dev/null +++ b/nl-module-base/nl-module-base-server/src/main/java/cn/code/nl/module/base/service/codegen/CodeRuleService.java @@ -0,0 +1,71 @@ +package cn.code.nl.module.base.service.codegen; + +import cn.code.nl.framework.common.pojo.PageResult; +import cn.code.nl.module.base.controller.admin.codegen.vo.CodeRulePageReqVO; +import cn.code.nl.module.base.controller.admin.codegen.vo.CodeRuleSaveReqVO; +import cn.code.nl.module.base.dal.dataobject.codegen.CodeRuleDO; +import jakarta.validation.Valid; + +import java.util.List; + +/** + * 编码规则管理 Service 接口 + * + * @author zhouz + */ +public interface CodeRuleService { + + /** + * 创建编码规则 + * + * @param createReqVO 创建信息 + * @return 规则ID + */ + Long createRule(@Valid CodeRuleSaveReqVO createReqVO); + + /** + * 更新编码规则 + * + * @param updateReqVO 更新信息 + */ + void updateRule(@Valid CodeRuleSaveReqVO updateReqVO); + + /** + * 删除编码规则 + * + * @param id 规则ID + */ + void deleteRule(Long id); + + /** + * 获取编码规则详情 + * + * @param id 规则ID + * @return 编码规则 + */ + CodeRuleDO getRule(Long id); + + /** + * 根据规则编码获取规则（带缓存） + * + * @param ruleCode 规则编码 + * @return 编码规则 + */ + CodeRuleDO getRuleByCode(String ruleCode); + + /** + * 分页查询编码规则 + * + * @param pageReqVO 分页条件 + * @return 分页结果 + */ + PageResult getRulePage(CodeRulePageReqVO pageReqVO); + + /** + * 获取启用状态的编码规则精简列表 + * + * @return 规则列表 + */ + List getEnabledRuleList(); + +} diff --git a/nl-module-base/nl-module-base-server/src/main/java/cn/code/nl/module/base/service/codegen/CodeRuleServiceImpl.java b/nl-module-base/nl-module-base-server/src/main/java/cn/code/nl/module/base/service/codegen/CodeRuleServiceImpl.java new file mode 100644 index 00000000..5232691e --- /dev/null +++ b/nl-module-base/nl-module-base-server/src/main/java/cn/code/nl/module/base/service/codegen/CodeRuleServiceImpl.java @@ -0,0 +1,190 @@ +package cn.code.nl.module.base.service.codegen; + +import cn.code.nl.framework.common.pojo.PageResult; +import cn.code.nl.framework.common.util.object.BeanUtils; +import cn.code.nl.module.base.controller.admin.codegen.vo.CodeRulePageReqVO; +import cn.code.nl.module.base.controller.admin.codegen.vo.CodeRuleSaveReqVO; +import cn.code.nl.module.base.dal.dataobject.codegen.CodeRuleDO; +import cn.code.nl.module.base.dal.mysql.codegen.CodeRuleMapper; +import cn.code.nl.module.base.service.codegen.enums.SeqStrategyEnum; +import cn.hutool.core.util.StrUtil; +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.ObjectMapper; +import jakarta.annotation.Resource; +import lombok.extern.slf4j.Slf4j; +import org.springframework.data.redis.core.StringRedisTemplate; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.validation.annotation.Validated; + +import java.util.List; +import java.util.concurrent.TimeUnit; + +import static cn.code.nl.framework.common.exception.util.ServiceExceptionUtil.exception; +import static cn.code.nl.module.base.enums.ErrorCodeConstants.*; + +/** + * 编码规则管理 Service 实现类 + * + * @author zhouz + */ +@Slf4j +@Service +@Validated +public class CodeRuleServiceImpl implements CodeRuleService { + + /** + * Redis 缓存 key 前缀 + */ + private static final String CACHE_KEY_PREFIX = "codegen:rule:"; + + /** + * 缓存过期时间（30分钟） + */ + private static final long CACHE_TTL_MINUTES = 30; + + @Resource + private CodeRuleMapper codeRuleMapper; + + @Resource + private StringRedisTemplate stringRedisTemplate; + + @Resource + private ObjectMapper objectMapper; + + @Override + @Transactional(rollbackFor = Exception.class) + public Long createRule(CodeRuleSaveReqVO createReqVO) { + // 校验规则编码唯一性 + validateRuleCodeUnique(createReqVO.getRuleCode(), null); + + // 插入 + CodeRuleDO rule = BeanUtils.toBean(createReqVO, CodeRuleDO.class); + rule.setSegmentConfig(createReqVO.getSegments()); + // 默认策略 + if (StrUtil.isBlank(rule.getSeqStrategy())) { + rule.setSeqStrategy(SeqStrategyEnum.SEGMENT.getCode()); + } + codeRuleMapper.insert(rule); + log.info("创建编码规则成功，ruleCode={}", rule.getRuleCode()); + return rule.getId(); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public void updateRule(CodeRuleSaveReqVO updateReqVO) { + // 校验存在 + CodeRuleDO existRule = validateRuleExists(updateReqVO.getId()); + // 校验规则编码唯一性 + validateRuleCodeUnique(updateReqVO.getRuleCode(), updateReqVO.getId()); + + // 更新 + CodeRuleDO updateObj = BeanUtils.toBean(updateReqVO, CodeRuleDO.class); + updateObj.setSegmentConfig(updateReqVO.getSegments()); + codeRuleMapper.updateById(updateObj); + + // 清除缓存 + clearCache(existRule.getRuleCode()); + // 如果 ruleCode 变更了，也清除旧 key + if (!existRule.getRuleCode().equals(updateReqVO.getRuleCode())) { + clearCache(existRule.getRuleCode()); + } + log.info("更新编码规则成功，ruleCode={}", updateReqVO.getRuleCode()); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public void deleteRule(Long id) { + // 校验存在 + CodeRuleDO rule = validateRuleExists(id); + // 删除 + codeRuleMapper.deleteById(id); + // 清除缓存 + clearCache(rule.getRuleCode()); + log.info("删除编码规则成功，ruleCode={}", rule.getRuleCode()); + } + + @Override + public CodeRuleDO getRule(Long id) { + return validateRuleExists(id); + } + + @Override + public CodeRuleDO getRuleByCode(String ruleCode) { + // 先从缓存读取 + String cacheKey = CACHE_KEY_PREFIX + ruleCode; + String cached = stringRedisTemplate.opsForValue().get(cacheKey); + if (StrUtil.isNotBlank(cached)) { + try { + return objectMapper.readValue(cached, CodeRuleDO.class); + } catch (JsonProcessingException e) { + log.warn("解析编码规则缓存失败，ruleCode={}", ruleCode, e); + } + } + + // 缓存未命中，查数据库 + CodeRuleDO rule = codeRuleMapper.selectByRuleCode(ruleCode); + if (rule == null) { + throw exception(CODE_RULE_NOT_EXISTS); + } + // 校验启用状态 + if (rule.getStatus() != null && rule.getStatus() == 1) { + throw exception(CODE_RULE_DISABLED); + } + + // 写入缓存 + try { + String json = objectMapper.writeValueAsString(rule); + stringRedisTemplate.opsForValue().set(cacheKey, json, CACHE_TTL_MINUTES, TimeUnit.MINUTES); + } catch (JsonProcessingException e) { + log.warn("序列化编码规则缓存失败，ruleCode={}", ruleCode, e); + } + return rule; + } + + @Override + public PageResult getRulePage(CodeRulePageReqVO pageReqVO) { + return codeRuleMapper.selectPage(pageReqVO); + } + + @Override + public List getEnabledRuleList() { + // 查询启用状态的规则 + return codeRuleMapper.selectList(CodeRuleDO::getStatus, 0); + } + + /** + * 清除规则缓存 + */ + private void clearCache(String ruleCode) { + stringRedisTemplate.delete(CACHE_KEY_PREFIX + ruleCode); + } + + /** + * 校验规则编码唯一性 + */ + private void validateRuleCodeUnique(String ruleCode, Long excludeId) { + CodeRuleDO exist = codeRuleMapper.selectByRuleCode(ruleCode); + if (exist == null) { + return; + } + if (excludeId == null || !exist.getId().equals(excludeId)) { + throw exception(CODE_RULE_CODE_DUPLICATE); + } + } + + /** + * 校验规则存在 + */ + private CodeRuleDO validateRuleExists(Long id) { + if (id == null) { + throw exception(CODE_RULE_NOT_EXISTS); + } + CodeRuleDO rule = codeRuleMapper.selectById(id); + if (rule == null) { + throw exception(CODE_RULE_NOT_EXISTS); + } + return rule; + } + +}