xiaoyong931011
2021-12-21 5932c45bd0d3ea78cbe1dbafc4136abd1492f11d
src/main/java/cc/mrbird/febs/video/service/impl/AdminVideoMemberServiceImpl.java
@@ -4,12 +4,15 @@
import cc.mrbird.febs.common.entity.QueryRequest;
import cc.mrbird.febs.common.exception.FebsException;
import cc.mrbird.febs.video.dto.AdminSetVipDto;
import cc.mrbird.febs.video.entity.AppVersion;
import cc.mrbird.febs.video.entity.VideoMemberEntity;
import cc.mrbird.febs.video.entity.VideoVipInfoEntity;
import cc.mrbird.febs.video.enumeration.VipTypeEnum;
import cc.mrbird.febs.video.mapper.AppVersionMapper;
import cc.mrbird.febs.video.mapper.VideoMemberMapper;
import cc.mrbird.febs.video.mapper.VideoVipInfoMapper;
import cc.mrbird.febs.video.service.IAdminVideoMemberService;
import cc.mrbird.febs.video.service.IApiVideoMemberService;
import cc.mrbird.febs.video.vo.AdminVideoMemberVo;
import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DateUtil;
@@ -24,6 +27,7 @@
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
@@ -33,6 +37,8 @@
public class AdminVideoMemberServiceImpl extends ServiceImpl<VideoMemberMapper, VideoMemberEntity> implements IAdminVideoMemberService {
    private final VideoVipInfoMapper videoVipInfoMapper;
    private final AppVersionMapper appVersionMapper;
    private final IApiVideoMemberService apiVideoMemberService;
    @Override
    public IPage<VideoMemberEntity> getVideoMembers(VideoMemberEntity videoMember, QueryRequest request) {
@@ -94,10 +100,12 @@
        videoMemberEntity.setIsVip(VideoMemberEntity.ISVIP_STATUS_YES);
        this.baseMapper.updateById(videoMemberEntity);
        List<VideoVipInfoEntity> videoVipInfoEntities = videoVipInfoMapper.selectVideoVipInfoByMemberIdAndState(adminSetVipDto.getId(),1);
        if(CollUtil.isNotEmpty(videoVipInfoEntities)){
        VideoVipInfoEntity videoVipInfoEntities = videoVipInfoMapper.selectVideoVipInfoByMemberIdAndState(adminSetVipDto.getId(),1);
        if(ObjectUtil.isNotEmpty(videoVipInfoEntities)){
            return new FebsResponse().fail().message("用户的会员还未失效");
        }
        apiVideoMemberService.extendVipTime(adminSetVipDto.getVipType(), videoMemberEntity.getId());
        VideoVipInfoEntity videoVipInfoEntity = new VideoVipInfoEntity();
        videoVipInfoEntity.setMemberId(adminSetVipDto.getId());
@@ -129,15 +137,52 @@
        }
        videoMemberEntity.setIsVip(VideoMemberEntity.ISVIP_STATUS_NO);
        this.baseMapper.updateById(videoMemberEntity);
        List<VideoVipInfoEntity> videoVipInfoEntities = videoVipInfoMapper.selectVideoVipInfoByMemberIdAndState(videoMemberEntity.getId(),1);
        if(CollUtil.isNotEmpty(videoVipInfoEntities)){
            for(VideoVipInfoEntity videoVipInfoEntity : videoVipInfoEntities){
                videoVipInfoEntity.setState(2);
                videoVipInfoMapper.updateById(videoVipInfoEntity);
            }
        VideoVipInfoEntity videoVipInfoEntities = videoVipInfoMapper.selectVideoVipInfoByMemberIdAndState(videoMemberEntity.getId(),1);
        if(ObjectUtil.isNotEmpty(videoVipInfoEntities)){
                videoVipInfoMapper.deleteById(videoVipInfoEntities.getId());
        }
        return new FebsResponse().success();
    }
    @Override
    public IPage<AppVersion> getAppVersionList(AppVersion appVersion, QueryRequest request) {
        Page<AppVersion> page = new Page<>(request.getPageNum(), request.getPageSize());
        IPage<AppVersion> appVersions = this.baseMapper.getAppVersionListInPage(page, appVersion);
        return appVersions;
    }
    @Override
    public FebsResponse delCategary(Long id) {
        AppVersion appVersion = appVersionMapper.selectById(id);
        if(ObjectUtil.isEmpty(appVersion)){
            return new FebsResponse().fail().message("系统繁忙,请刷新页面重试");
        }
        appVersionMapper.deleteById(id);
        return new FebsResponse().success();
    }
    @Override
    public FebsResponse addAppVersion(AppVersion appVersion) {
        appVersion.setCreatetime(new Date());
        appVersionMapper.insert(appVersion);
        return new FebsResponse().success();
    }
    @Override
    public FebsResponse updateAppVersion(AppVersion appVersion) {
        AppVersion appVersionBefore = appVersionMapper.selectById(appVersion.getId());
        if(ObjectUtil.isEmpty(appVersionBefore)){
            return new FebsResponse().fail().message("系统繁忙,请刷新页面重试");
        }
        appVersion.setCreatetime(new Date());
        appVersionMapper.updateById(appVersion);
        return new FebsResponse().success();
    }
    @Override
    public AppVersion getAppVersionInfoById(long id) {
        return appVersionMapper.selectById(id);
    }
}