管理端活动富文本编辑相关问题，审核活动

zxl

2025-07-11 f63685047444919d8778e3de9a09ffbed5d219e4

 framework/src/main/java/cn/lili/modules/lmk/service/impl/ActivityServiceImpl.java

@@ -1,24 +1,25 @@
package cn.lili.modules.lmk.service.impl;

import cn.lili.base.Result;
import cn.lili.common.enums.ActivityCoverTypeEnum;
import cn.lili.common.enums.ActivityStatusEnum;
import cn.lili.common.security.context.UserContext;
import cn.lili.modules.lmk.domain.entity.Activity;
import cn.lili.modules.lmk.domain.entity.ActivityReport;
import cn.lili.modules.lmk.domain.form.ActivityAuditRecordForm;
import cn.lili.modules.lmk.domain.form.ActivityForm;
import cn.lili.modules.lmk.domain.form.ActivityReportForm;
import cn.lili.modules.lmk.domain.query.ActivityAuditRecordQuery;
import cn.lili.modules.lmk.domain.query.ActivityMembersQuery;
import cn.lili.modules.lmk.domain.query.ActivityQuery;
import cn.lili.modules.lmk.domain.vo.ActivityReportVO;
import cn.lili.modules.lmk.domain.vo.ActivityAuditRecordVO;
import cn.lili.modules.lmk.domain.vo.ActivityVO;
import cn.lili.modules.lmk.mapper.ActivityMapper;
import cn.lili.modules.lmk.mapper.ActivityReportMapper;
import cn.lili.modules.lmk.service.ActivityAuditRecordService;
import cn.lili.modules.lmk.service.ActivityService;
import cn.lili.modules.lmk.service.LmkFileService;
import cn.lili.modules.lmk.service.MyActivityService;
import cn.lili.modules.member.entity.vo.MemberVO;
import cn.lili.utils.COSUtil;
import cn.lili.utils.PageUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import io.micrometer.core.instrument.util.StringUtils;
import lombok.RequiredArgsConstructor;
@@ -36,28 +37,35 @@

    private final LmkFileService lmkFileService;

    private final MyActivityService activityService;
    private final COSUtil cOSUtil;

    private final ActivityReportMapper activityReportMapper;
    private final ActivityAuditRecordService activityAuditRecordService;


    @Override
    public Result add(ActivityForm form) {
    public Result add(ActivityForm form,Boolean isManager) {

        Activity entity = ActivityForm.getEntityByForm(form, null);
        System.out.println(entity);
        //默认新增活动为
        entity.setStatus(ActivityStatusEnum.NOT_STARTED.getType());
        //默认不为推荐
        entity.setRecommend(false);

        //默认未发布
        entity.setPublish(false);
        //设置申请人id
        entity.setMemberId(UserContext.getCurrentUserId());
        baseMapper.insert(entity);
        mangerSaveOrUpdate(isManager,entity);
        return Result.ok("添加成功");
    }

    @Override
    public Result update(ActivityForm form) {
    public Result update(ActivityForm form,Boolean isManager) {

        Activity entity = baseMapper.selectById(form.getId());
        //判断修改前的封面类型是否为文本，文本不需要删除文件
        if (!"文字".equals(entity.getCoverType())){
        if (!ActivityCoverTypeEnum.TEXT.getType().equals(entity.getCoverType())){
            //判断路径是否改变
            if (!form.getCover().equals(entity.getCover())) {
                //删除云服务器中旧的图片
@@ -69,10 +77,25 @@
        Assert.notNull(entity, "记录不存在");
        BeanUtils.copyProperties(form, entity);

        mangerSaveOrUpdate(isManager,entity);
        baseMapper.updateById(entity);

        //直接重新生成一条审核记录
        BeanUtils.copyProperties(form, entity);

        return Result.ok("修改成功");
    }

    public void mangerSaveOrUpdate(Boolean isManager,Activity entity){
        ActivityAuditRecordForm activityAuditRecordForm;
        //添加审核记录
        if (isManager){
            //直接通过
            activityAuditRecordForm = ActivityAuditRecordForm.getEntityByManagerBuildForm(entity.getId());
        }else {
            activityAuditRecordForm = ActivityAuditRecordForm.getEntityByBuyerBuildForm(entity.getId());
        }
        activityAuditRecordService.addOrUpdateAuditActivity(activityAuditRecordForm);
    }
    @Override
    public Result remove(List<String> ids) {
        baseMapper.deleteBatchIds(ids);
@@ -81,18 +104,20 @@

    @Override
    public Result removeById(String id) {
        //TODO 先判断活动是否有报名人员
        //有的话不可删除 联中间表查询




        //先判断活动是否有报名人员
        ActivityMembersQuery activityMembersQuery = new ActivityMembersQuery();
        activityMembersQuery.setId(id);
        if((long)activityMembersPage(activityMembersQuery).get("total") > 0){
            return Result.error("该活动无法下架，已存在报名人员");
        }
        //删除，同时判断该对象的封面是否存在 ，存在则在云服务器删除
        ActivityVO vo = baseMapper.getById(id);
        if (StringUtils.isNotEmpty(vo.getCover())){
            lmkFileService.deleteObject(vo.getCover());
        }
        baseMapper.deleteById(id);
        //删除审核记录
        activityAuditRecordService.delActivityAuditById(id);

        return Result.ok("删除成功");
    }
@@ -103,9 +128,25 @@

        baseMapper.getPage(page, query);
        for (ActivityVO vo : page.getRecords()) {
            if (!"文字".equals(vo.getCoverType())){
                String url = lmkFileService.getPreviewUrl(vo.getCover());
                vo.setUrl(url);
            if (!ActivityCoverTypeEnum.TEXT.getType().equals(vo.getCoverType())){
                vo.setUrl(cOSUtil.getPreviewUrl(vo.getCover()));
            }
        }
        return Result.ok().data(page.getRecords()).total(page.getTotal());
    }

    @Override
    public Result getMyApplyActivityPage(ActivityQuery query){
        System.out.println(query);

        //传入当前请求用户的id
        query.setMemberId(UserContext.getCurrentUserId());
        //更具用户id获得活动
        IPage<ActivityVO> page = PageUtil.getPage(query, ActivityVO.class);
        baseMapper.getPage(page, query);
        for (ActivityVO vo : page.getRecords()) {
            if (!ActivityCoverTypeEnum.TEXT.getType().equals(vo.getCoverType())){
                vo.setUrl(cOSUtil.getPreviewUrl(vo.getCover()));
            }
        }
        return Result.ok().data(page.getRecords()).total(page.getTotal());
@@ -117,10 +158,23 @@
        Assert.notNull(vo, "记录不存在");
        return Result.ok().data(vo);
    }
    @Override
    public Result getCanReportPage(ActivityQuery query){
        //查询到的结果已经审核且发布
        IPage<ActivityVO> page = PageUtil.getPage(query, ActivityVO.class);
        //已发布的活动
        baseMapper.getCanReportPage(page, query);

        for(ActivityVO activityVO : page.getRecords()){
            activityVO.setUrl(cOSUtil.getPreviewUrl(activityVO.getCover()));
        }

        return Result.ok().data(page.getRecords()).total(page.getTotal());
    }

    @Override
    public Result all() {

        List<Activity> entities = baseMapper.selectList(null);
        List<ActivityVO> vos = entities.stream()
                .map(entity -> ActivityVO.getVoByEntity(entity, null))
@@ -147,9 +201,30 @@
    @Override
    public Result activityChangeStatus(ActivityForm form) {
        Activity entity = baseMapper.selectById(form.getId());
        entity.setStatus(form.getStatus());
        baseMapper.updateById(entity);
        return Result.ok();
        entity.setPublish(form.getPublish());
        if (!form.getPublish()){
            //下架判断是否有人员报名，有报名的话禁止提醒无法下架
            ActivityMembersQuery activityMembersQuery = new ActivityMembersQuery();
            activityMembersQuery.setId(form.getId());
            if((long)activityMembersPage(activityMembersQuery).get("total") > 0){
                return Result.error("该活动无法下架，已存在报名人员");
            }
            return Result.ok();
        }else {
            //判断该活动是否审核通过
           if(activityAuditRecordService.getActivityActivityIsAudit(form.getId())){
               baseMapper.updateById(entity);
               return Result.ok();
           }else {
               return Result.error("活动未通过审核");
           }



        }



    }

    @Override