package com.gkhy.exam.system.service.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.gkhy.exam.common.api.CommonPage; import com.gkhy.exam.common.constant.UserConstant; import com.gkhy.exam.common.domain.entity.SysUser; import com.gkhy.exam.common.enums.PrivatizeEnum; import com.gkhy.exam.common.enums.UserTypeEnum; import com.gkhy.exam.common.exception.ApiException; import com.gkhy.exam.common.utils.PageUtils; import com.gkhy.exam.common.utils.SecurityUtils; import com.gkhy.exam.system.domain.ExResource; import com.gkhy.exam.system.domain.vo.UploadObjectVO; import com.gkhy.exam.system.mapper.ExResourceMapper; import com.gkhy.exam.system.service.ExResourceService; import com.gkhy.exam.system.service.SysCommonService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; /** *

* 课程资源表 服务实现类 *

* * @author kzy * @since 2024-06-06 10:25:36 */ @Service public class ExResourceServiceImpl extends ServiceImpl implements ExResourceService { @Autowired private SysCommonService commonService; @Override public CommonPage selectResourseList(ExResource resource) { SysUser currentUser = SecurityUtils.getLoginUser().getUser(); if(!currentUser.getUserType().equals(UserTypeEnum.SYSTEM_USER.getCode())){ resource.setCompanyId(currentUser.getCompanyId()); } PageUtils.startPage(); List resourceList=baseMapper.selectResourceList(resource); return CommonPage.restPage(resourceList); } @Override public ExResource selectResourceById(Long resourceId) { return baseMapper.selectResourceById(resourceId); } @Override public ExResource selectResourceByPeriodId(Long periodId) { return baseMapper.selectResourceByPeriodId(periodId); } @Override public int insertResource(ExResource resource) { if(!checkNameUnique(resource)){ throw new ApiException("资源名称已存在"); } SysUser user=SecurityUtils.getLoginUser().getUser(); if(user.getUserType().equals(UserTypeEnum.SYSTEM_USER.getCode())){ resource.setPrivatize(PrivatizeEnum.PUBLIC.getCode()); }else{ if(user.getCompanyId()==null){ throw new ApiException("获取用户公司id失败"); } resource.setCompanyId(user.getCompanyId()); resource.setPrivatize(PrivatizeEnum.PRIVATE.getCode()); } UploadObjectVO uploadObjectVO =commonService.doUpload(resource.getFile()); resource.setResourceUri(uploadObjectVO.getPath()); resource.setVideoVid(uploadObjectVO.getFilename()); resource.setResourceSize(uploadObjectVO.getSize()); resource.setCreateBy(SecurityUtils.getUsername()); int row=baseMapper.insert(resource); if(row<1){ try { //删除原文件 commonService.removeFile(uploadObjectVO.getPath()); }catch (Exception e){ log.error("新增资源,删除文件失败="+e.getMessage()); } throw new ApiException("新增资源失败"); } return row; } @Override public int updateResource(ExResource resource) { if(!checkNameUnique(resource)){ throw new ApiException("资源名称已存在"); } int row=baseMapper.updateById(resource); if(row<1){ throw new ApiException("更新资源失败"); } return row; } @Override public int deleteResourceById(Long resourceId) { //校验资源是否绑定 ExResource resource=getById(resourceId); int row=baseMapper.deleteById(resourceId); if(row<1){ throw new ApiException("删除资源失败"); } //删除文件 commonService.removeFile(resource.getResourceUri()); return row; } @Override public boolean checkNameUnique(ExResource resource) { Long resourceId=resource.getId()==null?-1L:resource.getId(); ExResource res= baseMapper.checkNameUnique(resource.getName(),resource.getCompanyId()); if(res!=null&&res.getId().longValue()!=resourceId.longValue()){ return UserConstant.NOT_UNIQUE; } return UserConstant.UNIQUE; } }