活动代码修改

zxl

5 天以前 dbbad373cfa576ced45044abf7dfc887ebd12be8

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

@@ -14,6 +14,7 @@
import cn.lili.modules.lmk.domain.vo.ActivityVO;
import cn.lili.modules.lmk.mapper.ActivityMapper;
import cn.lili.modules.lmk.service.ActivityAuditRecordService;
import cn.lili.modules.lmk.service.ActivityReportService;
import cn.lili.modules.lmk.service.ActivityService;
import cn.lili.modules.lmk.service.LmkFileService;
import cn.lili.modules.member.entity.vo.MemberVO;
@@ -25,14 +26,17 @@
import lombok.RequiredArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.Assert;
import org.springframework.web.multipart.MultipartFile;

import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

@Service
@RequiredArgsConstructor
@Transactional
public class ActivityServiceImpl extends ServiceImpl<ActivityMapper, Activity> implements ActivityService {

    private final LmkFileService lmkFileService;
@@ -41,12 +45,14 @@

    private final ActivityAuditRecordService activityAuditRecordService;

    private final ActivityReportService activityReportService;


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

        Activity entity = ActivityForm.getEntityByForm(form, null);
        System.out.println(entity);

        //默认新增活动为
        entity.setStatus(ActivityStatusEnum.NOT_STARTED.getType());
        //默认不为推荐
@@ -55,6 +61,7 @@
        entity.setPublish(false);
        //设置申请人id
        entity.setMemberId(UserContext.getCurrentUserId());
        entity.setStoreId(UserContext.getCurrentUser().getStoreId());
        baseMapper.insert(entity);
        mangerSaveOrUpdate(isManager,entity);
        return Result.ok("添加成功");
@@ -80,46 +87,81 @@
        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());
            activityAuditRecordForm = ActivityAuditRecordForm.getFormByManager(entity.getId());
        }else {
            activityAuditRecordForm = ActivityAuditRecordForm.getEntityByBuyerBuildForm(entity.getId());
            activityAuditRecordForm = ActivityAuditRecordForm.getFormByBuyer(entity.getId());
        }
        activityAuditRecordService.addOrUpdateAuditActivity(activityAuditRecordForm);
    }
    @Override
    public Result remove(List<String> ids) {
        baseMapper.deleteBatchIds(ids);
        //判断活动id是否已经存在报名人员
        for(String id : ids){
            canDeleteActivity(id);

        }

        return Result.ok("删除成功");
    }
    /**
     * 判断是否能删除活动 并删除活动相关信息
     * @param id
     * @return
     */
    public Result canDeleteActivity(String id){
        Activity activity = baseMapper.selectById(id);

        //活动是否发布
        if (activity.getPublish()){
            return Result.error("存在活动已发布删除前请下架该活动！");
        }
        //检查报名人员前判断活动是否结束了 结束了就允许删除
        Date currentDate = new Date();
        if (currentDate.before(activity.getEndTime())){
            //活动未结束 且报名人员的情况
            if(haveApplicationMembers(activity.getId())){
                //todo 报名人员存在 但是需要删除的情况预留
//                return Result.error("活动未结束且已有报名人员，无法删除！");
            }

        }
        delActivityAndInformation(activity);
        return Result.ok("删除成功");
    }
    //判断活动是否存在报名人员
    public Boolean haveApplicationMembers(String id){
        ActivityMembersQuery activityMembersQuery = new ActivityMembersQuery();
        activityMembersQuery.setId(id);
        return (long) activityMembersPage(activityMembersQuery).get("total") > 0;
    }
    //判断互动是否发布

    //删除活动同时删除活动的相关信息
    public void delActivityAndInformation(Activity activity){
        if (StringUtils.isNotEmpty(activity.getCover())){
            lmkFileService.deleteObject(activity.getCover());
        }
        baseMapper.deleteById(activity.getId());
        //删除审核记录
        activityAuditRecordService.delActivityAuditById(activity.getId());
        //删除活动报名人员
        activityReportService.delByActivityId(activity.getId());
    }



    @Override
    public Result removeById(String id) {
        //先判断活动是否有报名人员
        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("删除成功");
        return canDeleteActivity(id);
    }

    @Override
@@ -137,18 +179,24 @@

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

        //传入当前请求用户的id
        query.setMemberId(UserContext.getCurrentUserId());
        String storeId = UserContext.getCurrentUser().getStoreId();
        if (storeId == null){
            query.setMemberId(UserContext.getCurrentUserId());
        }else {
            query.setStoreId(storeId);
        }

        //更具用户id获得活动
        IPage<ActivityVO> page = PageUtil.getPage(query, ActivityVO.class);
        baseMapper.getPage(page, query);
        baseMapper.storeGetPage(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());
    }

@@ -200,31 +248,36 @@

    @Override
    public Result activityChangeStatus(ActivityForm form) {
        //判断活动
        Activity entity = baseMapper.selectById(form.getId());

        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("该活动无法下架，已存在报名人员");
            Date currentTime = new Date();

            if (currentTime.before(entity.getEndTime())){
                if(haveApplicationMembers(form.getId())){
//                    return Result.error("该活动无法下架，已存在报名人员");
                    //todo 报名人员存在 但是需要下架的情况预留

                }


            }
            return Result.ok();

        }else {
            //判断该活动是否审核通过
           if(activityAuditRecordService.getActivityActivityIsAudit(form.getId())){
               baseMapper.updateById(entity);
               return Result.ok();
           }else {
           if(!activityAuditRecordService.getActivityActivityIsAudit(form.getId())){
               return Result.error("活动未通过审核");

           }



        }



        baseMapper.updateById(entity);
        return Result.ok();
    }

    @Override