From 1642e3c793311569c520dfa0f8dd05d8844e70f2 Mon Sep 17 00:00:00 2001 From: gaoqr <13665037151@163.com> Date: Sat, 15 Feb 2025 07:17:57 +0800 Subject: [PATCH] =?UTF-8?q?=E7=B3=BB=E7=BB=9F=E7=AE=A1=E7=90=86=EF=BC=9A?= =?UTF-8?q?=E9=80=9A=E7=9F=A5=E5=85=AC=E5=91=8A=E6=94=AF=E6=8C=81=E6=8C=89?= =?UTF-8?q?=E6=9C=BA=E6=9E=84=E5=88=92=E5=88=86=E3=80=81=E8=B6=85=E7=AE=A1?= =?UTF-8?q?=E6=93=8D=E4=BD=9C=E5=85=AC=E5=91=8A=E4=B8=BA=E5=86=85=E7=BD=AE?= =?UTF-8?q?=E5=85=AC=E5=91=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../system/enums/ErrorCodeConstants.java | 1 + .../admin/notice/vo/NoticePageReqVO.java | 5 ++ .../admin/notice/vo/NoticeSaveReqVO.java | 1 + .../dal/dataobject/notice/NoticeDO.java | 16 +++++ .../system/dal/mysql/notice/NoticeMapper.java | 17 +++++- .../service/notice/NoticeServiceImpl.java | 58 +++++++++++++++++-- 6 files changed, 92 insertions(+), 6 deletions(-) diff --git a/cf-module-system/cf-module-system-api/src/main/java/com/cf/imes/module/system/enums/ErrorCodeConstants.java b/cf-module-system/cf-module-system-api/src/main/java/com/cf/imes/module/system/enums/ErrorCodeConstants.java index 9cb9ac62f..1491880c2 100644 --- a/cf-module-system/cf-module-system-api/src/main/java/com/cf/imes/module/system/enums/ErrorCodeConstants.java +++ b/cf-module-system/cf-module-system-api/src/main/java/com/cf/imes/module/system/enums/ErrorCodeConstants.java @@ -94,6 +94,7 @@ public class ErrorCodeConstants { // ========== 通知公告 1-002-008-000 ========== public static final ErrorCode NOTICE_NOT_FOUND = new ErrorCode(1_002_008_001, "当前通知公告不存在"); public static final ErrorCode NOTICE_NAME_UNIQE_ERROR = new ErrorCode(1_002_008_002, "公告标题已存在，请编辑后重试"); + public static final ErrorCode NOTICE_BUILDIN_MODIFY_PERMISSION_ERROR = new ErrorCode(1_002_008_003, "内置通知公告编辑权限不足"); // ========== 短信渠道 1-002-011-000 ========== public static final ErrorCode SMS_CHANNEL_NOT_EXISTS = new ErrorCode(1_002_011_000, "短信渠道不存在"); diff --git a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/controller/admin/notice/vo/NoticePageReqVO.java b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/controller/admin/notice/vo/NoticePageReqVO.java index 1de067edc..8fedeaf26 100644 --- a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/controller/admin/notice/vo/NoticePageReqVO.java +++ b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/controller/admin/notice/vo/NoticePageReqVO.java @@ -21,4 +21,9 @@ public class NoticePageReqVO extends PageParam { @CommonStatus private Integer status; + @Schema(description = "组织id") + private Long organId; + + @Schema(description = "通知公告来源") + private Integer source; } diff --git a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/controller/admin/notice/vo/NoticeSaveReqVO.java b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/controller/admin/notice/vo/NoticeSaveReqVO.java index 47cc6c34a..5dc9113b6 100644 --- a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/controller/admin/notice/vo/NoticeSaveReqVO.java +++ b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/controller/admin/notice/vo/NoticeSaveReqVO.java @@ -25,6 +25,7 @@ public class NoticeSaveReqVO { private Integer type; @Schema(description = "公告内容", requiredMode = Schema.RequiredMode.REQUIRED, example = "半生编码") + @NotBlank(message = "公告内容不能为空") private String content; @Schema(description = "状态，参见 CommonStatusEnum 枚举类", requiredMode = Schema.RequiredMode.REQUIRED, example = "1") diff --git a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/dal/dataobject/notice/NoticeDO.java b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/dal/dataobject/notice/NoticeDO.java index 02ffc404b..380ad33a7 100644 --- a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/dal/dataobject/notice/NoticeDO.java +++ b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/dal/dataobject/notice/NoticeDO.java @@ -1,7 +1,10 @@ package com.cf.imes.module.system.dal.dataobject.notice; +import com.baomidou.mybatisplus.annotation.FieldFill; +import com.baomidou.mybatisplus.annotation.TableField; import com.cf.imes.framework.common.enums.CommonStatusEnum; import com.cf.imes.framework.mybatis.core.dataobject.BaseDO; +import com.cf.imes.module.system.enums.notice.NoticeSourceEnum; import com.cf.imes.module.system.enums.notice.NoticeTypeEnum; import com.baomidou.mybatisplus.annotation.KeySequence; import com.baomidou.mybatisplus.annotation.TableName; @@ -33,6 +36,14 @@ public class NoticeDO extends BaseDO { * 枚举 {@link NoticeTypeEnum} */ private Integer type; + + /** + * 公告来源 + *

+ * 枚举 {@link NoticeSourceEnum} + */ + private NoticeSourceEnum source; + /** * 公告内容 */ @@ -44,4 +55,9 @@ public class NoticeDO extends BaseDO { */ private Integer status; + /** + * 组织ID + */ + @TableField(fill = FieldFill.INSERT_UPDATE) + private Long organId; } diff --git a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/dal/mysql/notice/NoticeMapper.java b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/dal/mysql/notice/NoticeMapper.java index 8b36d8ca3..7a7af7993 100644 --- a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/dal/mysql/notice/NoticeMapper.java +++ b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/dal/mysql/notice/NoticeMapper.java @@ -3,18 +3,33 @@ package com.cf.imes.module.system.dal.mysql.notice; import com.cf.imes.framework.common.pojo.PageResult; import com.cf.imes.framework.mybatis.core.mapper.BaseMapperX; import com.cf.imes.framework.mybatis.core.query.LambdaQueryWrapperX; +import com.cf.imes.framework.organ.core.context.OrganContextHolder; import com.cf.imes.module.system.controller.admin.notice.vo.NoticePageReqVO; import com.cf.imes.module.system.dal.dataobject.notice.NoticeDO; +import com.cf.imes.module.system.enums.notice.NoticeSourceEnum; import org.apache.ibatis.annotations.Mapper; @Mapper public interface NoticeMapper extends BaseMapperX { default PageResult selectPage(NoticePageReqVO reqVO) { + if (NoticeSourceEnum.SYSTEM.getSource().equals(reqVO.getSource())) { + // 超管只看内置的 + return selectPage(reqVO, new LambdaQueryWrapperX() + .likeIfPresent(NoticeDO::getTitle, reqVO.getTitle()) + .eqIfPresent(NoticeDO::getStatus, reqVO.getStatus()) + .eqIfPresent(NoticeDO::getSource, NoticeSourceEnum.SYSTEM) + .orderByDesc(NoticeDO::getId)); + } + // 普通用户查机构下的和内置的 return selectPage(reqVO, new LambdaQueryWrapperX() .likeIfPresent(NoticeDO::getTitle, reqVO.getTitle()) .eqIfPresent(NoticeDO::getStatus, reqVO.getStatus()) - .orderByDesc(NoticeDO::getId)); + .and(wr -> wr.or(wrapper -> wrapper + .eq(NoticeDO::getOrganId, OrganContextHolder.getOrganId()) + .eq(NoticeDO::getSource, NoticeSourceEnum.CUSTOM)) + .or(wrapper -> wrapper.eq(NoticeDO::getSource, NoticeSourceEnum.SYSTEM))) + .orderByDesc(NoticeDO::getId)); } } diff --git a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/service/notice/NoticeServiceImpl.java b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/service/notice/NoticeServiceImpl.java index 2e7accf72..b852545c6 100644 --- a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/service/notice/NoticeServiceImpl.java +++ b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/service/notice/NoticeServiceImpl.java @@ -1,17 +1,21 @@ package com.cf.imes.module.system.service.notice; import cn.hutool.core.util.ObjectUtil; +import cn.hutool.extra.spring.SpringUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.cf.imes.framework.common.exception.util.ServiceExceptionUtil; import com.cf.imes.framework.common.pojo.PageResult; import com.cf.imes.framework.common.util.object.BeanUtils; import com.cf.imes.framework.mybatis.core.query.LambdaQueryWrapperX; +import com.cf.imes.framework.organ.core.aop.OrganIgnore; +import com.cf.imes.framework.organ.core.context.OrganContextHolder; +import com.cf.imes.framework.security.core.util.SecurityFrameworkUtils; import com.cf.imes.module.system.controller.admin.notice.vo.NoticePageReqVO; import com.cf.imes.module.system.controller.admin.notice.vo.NoticeSaveReqVO; import com.cf.imes.module.system.dal.dataobject.notice.NoticeDO; import com.cf.imes.module.system.dal.mysql.notice.NoticeMapper; import com.cf.imes.module.system.enums.ErrorCodeConstants; -import com.google.common.annotations.VisibleForTesting; +import com.cf.imes.module.system.enums.notice.NoticeSourceEnum; import org.springframework.stereotype.Service; import javax.annotation.Resource; @@ -30,11 +34,19 @@ public class NoticeServiceImpl implements NoticeService { @Resource private NoticeMapper noticeMapper; + + private NoticeServiceImpl getSelf() { + return SpringUtil.getBean(getClass()); + } + @Override public Long createNotice(NoticeSaveReqVO createReqVO) { // 标题唯一性校验 validateNameExists(createReqVO); NoticeDO notice = BeanUtils.toBean(createReqVO, NoticeDO.class); + + // 超管创建的都是内置公告 + modifySource(notice); noticeMapper.insert(notice); return notice.getId(); } @@ -42,24 +54,32 @@ public class NoticeServiceImpl implements NoticeService { @Override public void updateNotice(NoticeSaveReqVO updateReqVO) { // 校验是否存在 - validateNoticeExists(updateReqVO.getId()); + getSelf().validateNoticeExists(updateReqVO.getId()); // 标题唯一性校验 - validateNameExists(updateReqVO); + getSelf().validateNameExists(updateReqVO); // 更新通知公告 NoticeDO updateObj = BeanUtils.toBean(updateReqVO, NoticeDO.class); + // 超管创建的都是内置公告 + modifySource(updateObj); noticeMapper.updateById(updateObj); } @Override public void deleteNotice(Long id) { // 校验是否存在 - validateNoticeExists(id); + getSelf().validateNoticeExists(id); // 删除通知公告 noticeMapper.deleteById(id); } @Override + @OrganIgnore public PageResult getNoticePage(NoticePageReqVO reqVO) { + boolean isSuperAdmin = SecurityFrameworkUtils.isSuperAdmin(); + // 超管查看内置公告 + if (isSuperAdmin) { + reqVO.setSource(NoticeSourceEnum.SYSTEM.getSource()); + } return noticeMapper.selectPage(reqVO); } @@ -68,7 +88,7 @@ public class NoticeServiceImpl implements NoticeService { return noticeMapper.selectById(id); } - @VisibleForTesting + @OrganIgnore public void validateNoticeExists(Long id) { if (id == null) { return; @@ -77,6 +97,13 @@ public class NoticeServiceImpl implements NoticeService { if (notice == null) { throw ServiceExceptionUtil.exception(ErrorCodeConstants.NOTICE_NOT_FOUND); } + if (!NoticeSourceEnum.SYSTEM.equals(notice.getSource()) && !notice.getOrganId().equals(OrganContextHolder.getOrganId())) { + throw ServiceExceptionUtil.exception(ErrorCodeConstants.NOTICE_NOT_FOUND); + } + // 只有超管可以操作内置公告 + if (NoticeSourceEnum.SYSTEM.equals(notice.getSource()) && !SecurityFrameworkUtils.isSuperAdmin()) { + throw ServiceExceptionUtil.exception(ErrorCodeConstants.NOTICE_BUILDIN_MODIFY_PERMISSION_ERROR); + } } /** @@ -84,14 +111,35 @@ public class NoticeServiceImpl implements NoticeService { * * @param reqVO */ + @OrganIgnore public void validateNameExists(NoticeSaveReqVO reqVO) { + boolean isSuperAdmin = SecurityFrameworkUtils.isSuperAdmin(); + Long noticeId = reqVO.getId(); LambdaQueryWrapper wrapper = new LambdaQueryWrapperX().eq(NoticeDO::getTitle, reqVO.getTitle()); if (ObjectUtil.isNotNull(noticeId)) { wrapper.ne(NoticeDO::getId, noticeId); } + if (isSuperAdmin) { + wrapper.eq(NoticeDO::getSource, NoticeSourceEnum.SYSTEM); + } else { + wrapper.eq(NoticeDO::getOrganId, OrganContextHolder.getOrganId()); + } if (noticeMapper.exists(wrapper)) { throw exception(NOTICE_NAME_UNIQE_ERROR); } } + + /** + * 公告来源赋值 + * + * @param notice + */ + private void modifySource(NoticeDO notice) { + if (SecurityFrameworkUtils.isSuperAdmin()) { + notice.setSource(NoticeSourceEnum.SYSTEM); + } else { + notice.setSource(NoticeSourceEnum.CUSTOM); + } + } }