增加消息板块

ruoyi-system/src/main/java/com/ruoyi/wgz/service/IWgzMessageService.java

@@ -0,0 +1,55 @@
+package com.ruoyi.wgz.service;
+
+import com.ruoyi.wgz.domain.WgzMessage;
+import com.ruoyi.wgz.bo.WgzMessageQueryBo;
+import com.ruoyi.common.core.mybatisplus.core.IServicePlus;
+import com.ruoyi.common.core.page.TableDataInfo;
+
+import java.util.Collection;
+import java.util.List;
+
+/**
+ * 消息Service接口
+ *
+ * @author ruoyi
+ * @date 2025-02-24
+ */
+public interface IWgzMessageService extends IServicePlus<WgzMessage> {
+    /**
+     * 查询单个
+     * @return
+     */
+    WgzMessage queryById(Long id);
+
+    /**
+     * 查询列表
+     */
+    TableDataInfo<WgzMessage> queryPageList(WgzMessageQueryBo bo);
+
+    /**
+     * 查询列表
+     */
+    List<WgzMessage> queryList(WgzMessageQueryBo bo);
+
+    /**
+     * 根据新增业务对象插入消息
+     * @param bo 消息新增业务对象
+     * @return
+     */
+    Boolean insert(WgzMessage bo);
+
+    /**
+     * 根据编辑业务对象修改消息
+     * @param bo 消息编辑业务对象
+     * @return
+     */
+    Boolean update(WgzMessage bo);
+
+    /**
+     * 校验并删除数据
+     * @param ids 主键集合
+     * @param isValid 是否校验,true-删除前校验,false-不校验
+     * @return
+     */
+    Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid);
+}

ruoyi-system/src/main/java/com/ruoyi/wgz/service/impl/WgzMessageServiceImpl.java

@@ -0,0 +1,94 @@
+package com.ruoyi.wgz.service.impl;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ruoyi.common.utils.PageUtils;
+import com.ruoyi.common.core.page.PagePlus;
+import com.ruoyi.common.core.page.TableDataInfo;
+import org.springframework.stereotype.Service;
+import com.ruoyi.common.core.mybatisplus.core.ServicePlusImpl;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.ruoyi.wgz.bo.WgzMessageQueryBo;
+import com.ruoyi.wgz.domain.WgzMessage;
+import com.ruoyi.wgz.mapper.WgzMessageMapper;
+import com.ruoyi.wgz.service.IWgzMessageService;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Collection;
+
+/**
+ * 消息Service业务层处理
+ *
+ * @author ruoyi
+ * @date 2025-02-24
+ */
+@Service
+public class WgzMessageServiceImpl extends ServicePlusImpl<WgzMessageMapper, WgzMessage> implements IWgzMessageService {
+
+    @Override
+    public WgzMessage queryById(Long id){
+        return getById(id);
+    }
+
+    @Override
+    public TableDataInfo<WgzMessage> queryPageList(WgzMessageQueryBo bo) {
+        Page<WgzMessage> result = page(PageUtils.buildPage(), buildQueryWrapper(bo));
+        return PageUtils.buildDataInfo(result);
+    }
+
+    @Override
+    public List<WgzMessage> queryList(WgzMessageQueryBo bo) {
+        return list(buildQueryWrapper(bo));
+    }
+
+    private LambdaQueryWrapper<WgzMessage> buildQueryWrapper(WgzMessageQueryBo bo) {
+        Map<String, Object> params = bo.getParams();
+        LambdaQueryWrapper<WgzMessage> lqw = Wrappers.lambdaQuery();
+        lqw.eq(StrUtil.isNotBlank(bo.getSenderType()), WgzMessage::getSenderType, bo.getSenderType());
+        lqw.eq(bo.getSenderId() != null, WgzMessage::getSenderId, bo.getSenderId());
+        lqw.eq(StrUtil.isNotBlank(bo.getRecipientType()), WgzMessage::getRecipientType, bo.getRecipientType());
+        lqw.eq(bo.getRecipientId() != null, WgzMessage::getRecipientId, bo.getRecipientId());
+        lqw.eq(StrUtil.isNotBlank(bo.getHeadline()), WgzMessage::getHeadline, bo.getHeadline());
+        lqw.eq(StrUtil.isNotBlank(bo.getSubheading()), WgzMessage::getSubheading, bo.getSubheading());
+        lqw.eq(bo.getTableId() != null, WgzMessage::getTableId, bo.getTableId());
+        lqw.like(StrUtil.isNotBlank(bo.getTableName()), WgzMessage::getTableName, bo.getTableName());
+        lqw.eq(StrUtil.isNotBlank(bo.getMessageLargeType()), WgzMessage::getMessageLargeType, bo.getMessageLargeType());
+        lqw.eq(StrUtil.isNotBlank(bo.getMessageSmallType()), WgzMessage::getMessageSmallType, bo.getMessageSmallType());
+        lqw.eq(StrUtil.isNotBlank(bo.getReadStatus()), WgzMessage::getReadStatus, bo.getReadStatus());
+        return lqw;
+    }
+
+    @Override
+    public Boolean insert(WgzMessage bo) {
+        WgzMessage add = BeanUtil.toBean(bo, WgzMessage.class);
+        validEntityBeforeSave(add);
+        return save(add);
+    }
+
+    @Override
+    public Boolean update(WgzMessage bo) {
+        WgzMessage update = BeanUtil.toBean(bo, WgzMessage.class);
+        validEntityBeforeSave(update);
+        return updateById(update);
+    }
+
+    /**
+     * 保存前的数据校验
+     *
+     * @param entity 实体类数据
+     */
+    private void validEntityBeforeSave(WgzMessage entity){
+        //TODO 做一些数据校验,如唯一约束
+    }
+
+    @Override
+    public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
+        if(isValid){
+            //TODO 做一些业务上的校验,判断是否需要校验
+        }
+        return removeByIds(ids);
+    }
+}