package com.iailab.module.system.service.notify; import cn.hutool.core.util.ReUtil; import cn.hutool.core.util.StrUtil; import com.iailab.framework.common.pojo.PageResult; import com.iailab.framework.common.util.object.BeanUtils; import com.iailab.module.system.controller.admin.notify.vo.template.NotifyTemplatePageReqVO; import com.iailab.module.system.controller.admin.notify.vo.template.NotifyTemplateSaveReqVO; import com.iailab.module.system.dal.dataobject.notify.NotifyTemplateDO; import com.iailab.module.system.dal.mysql.notify.NotifyTemplateMapper; import com.iailab.module.system.dal.redis.RedisKeyConstants; import com.google.common.annotations.VisibleForTesting; import lombok.extern.slf4j.Slf4j; import org.springframework.cache.annotation.CacheEvict; import org.springframework.cache.annotation.Cacheable; import org.springframework.stereotype.Service; import org.springframework.validation.annotation.Validated; import javax.annotation.Resource; import java.util.List; import java.util.Map; import java.util.regex.Pattern; import static com.iailab.framework.common.exception.util.ServiceExceptionUtil.exception; import static com.iailab.module.system.enums.ErrorCodeConstants.NOTIFY_TEMPLATE_CODE_DUPLICATE; import static com.iailab.module.system.enums.ErrorCodeConstants.NOTIFY_TEMPLATE_NOT_EXISTS; /** * 站内信模版 Service 实现类 * * @author xrcoder */ @Service @Validated @Slf4j public class NotifyTemplateServiceImpl implements NotifyTemplateService { /** * æ£åˆ™è¡¨è¾¾å¼ï¼ŒåŒ¹é… {} ä¸çš„å˜é‡ */ private static final Pattern PATTERN_PARAMS = Pattern.compile("\\{(.*?)}"); @Resource private NotifyTemplateMapper notifyTemplateMapper; @Override public Long createNotifyTemplate(NotifyTemplateSaveReqVO createReqVO) { // æ ¡éªŒç«™å†…ä¿¡ç¼–ç æ˜¯å¦é‡å¤ validateNotifyTemplateCodeDuplicate(null, createReqVO.getCode()); // æ’å…¥ NotifyTemplateDO notifyTemplate = BeanUtils.toBean(createReqVO, NotifyTemplateDO.class); notifyTemplate.setParams(parseTemplateContentParams(notifyTemplate.getContent())); notifyTemplateMapper.insert(notifyTemplate); return notifyTemplate.getId(); } @Override @CacheEvict(cacheNames = RedisKeyConstants.NOTIFY_TEMPLATE, allEntries = true) // allEntries 清空所有缓å˜ï¼Œå› 为å¯èƒ½ä¿®æ”¹åˆ° code å—æ®µï¼Œä¸å¥½æ¸…ç† public void updateNotifyTemplate(NotifyTemplateSaveReqVO updateReqVO) { // æ ¡éªŒå˜åœ¨ validateNotifyTemplateExists(updateReqVO.getId()); // æ ¡éªŒç«™å†…ä¿¡ç¼–ç æ˜¯å¦é‡å¤ validateNotifyTemplateCodeDuplicate(updateReqVO.getId(), updateReqVO.getCode()); // æ›´æ–° NotifyTemplateDO updateObj = BeanUtils.toBean(updateReqVO, NotifyTemplateDO.class); updateObj.setParams(parseTemplateContentParams(updateObj.getContent())); notifyTemplateMapper.updateById(updateObj); } @VisibleForTesting public List<String> parseTemplateContentParams(String content) { return ReUtil.findAllGroup1(PATTERN_PARAMS, content); } @Override @CacheEvict(cacheNames = RedisKeyConstants.NOTIFY_TEMPLATE, allEntries = true) // allEntries 清空所有缓å˜ï¼Œå› 为 id 䏿˜¯ç›´æŽ¥çš„ç¼“å˜ code,ä¸å¥½æ¸…ç† public void deleteNotifyTemplate(Long id) { // æ ¡éªŒå˜åœ¨ validateNotifyTemplateExists(id); // åˆ é™¤ notifyTemplateMapper.deleteById(id); } private void validateNotifyTemplateExists(Long id) { if (notifyTemplateMapper.selectById(id) == null) { throw exception(NOTIFY_TEMPLATE_NOT_EXISTS); } } @Override public NotifyTemplateDO getNotifyTemplate(Long id) { return notifyTemplateMapper.selectById(id); } @Override @Cacheable(cacheNames = RedisKeyConstants.NOTIFY_TEMPLATE, key = "#code", unless = "#result == null") public NotifyTemplateDO getNotifyTemplateByCodeFromCache(String code) { return notifyTemplateMapper.selectByCode(code); } @Override public PageResult<NotifyTemplateDO> getNotifyTemplatePage(NotifyTemplatePageReqVO pageReqVO) { return notifyTemplateMapper.selectPage(pageReqVO); } @VisibleForTesting void validateNotifyTemplateCodeDuplicate(Long id, String code) { NotifyTemplateDO template = notifyTemplateMapper.selectByCode(code); if (template == null) { return; } // 如果 id 为空,说明ä¸ç”¨æ¯”较是å¦ä¸ºç›¸åŒ id çš„å—典类型 if (id == null) { throw exception(NOTIFY_TEMPLATE_CODE_DUPLICATE, code); } if (!template.getId().equals(id)) { throw exception(NOTIFY_TEMPLATE_CODE_DUPLICATE, code); } } /** * æ ¼å¼åŒ–站内信内容 * * @param content 站内信模æ¿çš„内容 * @param params ç«™å†…ä¿¡å†…å®¹çš„å‚æ•° * @return æ ¼å¼åŒ–åŽçš„内容 */ @Override public String formatNotifyTemplateContent(String content, Map<String, Object> params) { return StrUtil.format(content, params); } }