|
@@ -19,6 +19,7 @@ import com.fjhx.oa.mapper.netdisk.NetdiskMapper;
|
|
|
import com.fjhx.oa.service.netdisk.NetdiskService;
|
|
|
import com.obs.services.internal.ServiceException;
|
|
|
import com.ruoyi.common.utils.wrapper.IWrapper;
|
|
|
+import com.ruoyi.system.utils.UserUtil;
|
|
|
import io.seata.spring.annotation.GlobalTransactional;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
@@ -54,6 +55,7 @@ public class NetdiskServiceImpl extends ServiceImpl<NetdiskMapper, Netdisk> impl
|
|
|
}
|
|
|
wrapper.like(Netdisk::getName, dto.getKeyword());
|
|
|
Page<NetdiskVo> page = this.baseMapper.getPage(dto.getPage(), wrapper);
|
|
|
+ UserUtil.assignmentNickName(page.getRecords(), Netdisk::getCreateUser, NetdiskVo::setCreateUserName);
|
|
|
return page;
|
|
|
}
|
|
|
|
|
@@ -69,7 +71,7 @@ public class NetdiskServiceImpl extends ServiceImpl<NetdiskMapper, Netdisk> impl
|
|
|
@Override
|
|
|
public void add(NetdiskDto netdiskDto) {
|
|
|
//如果父文件夹id为空就赋值初始值-1
|
|
|
- if(ObjectUtil.isEmpty(netdiskDto.getParentFolderId())){
|
|
|
+ if (ObjectUtil.isEmpty(netdiskDto.getParentFolderId())) {
|
|
|
netdiskDto.setParentFolderId(-1l);
|
|
|
}
|
|
|
if (netdiskDto.getType() == 1) {
|
|
@@ -89,6 +91,12 @@ public class NetdiskServiceImpl extends ServiceImpl<NetdiskMapper, Netdisk> impl
|
|
|
netdisk.setType(netdiskDto.getType());
|
|
|
netdisk.setParentFolderId(netdiskDto.getParentFolderId());
|
|
|
netdisk.setName(obsFile.getFileName());
|
|
|
+ String fileType = "";
|
|
|
+ if (obsFile.getFileName().indexOf(".") > 0) {
|
|
|
+ fileType = obsFile.getFileName().substring(obsFile.getFileName().lastIndexOf(".") + 1);
|
|
|
+ }
|
|
|
+ netdisk.setFileType(fileType);
|
|
|
+ netdisk.setFileSize(obsFile.getFileSize());
|
|
|
netdiskList.add(netdisk);
|
|
|
//更新文件信息
|
|
|
FileInfo fileInfo = new FileInfo();
|
|
@@ -114,7 +122,7 @@ public class NetdiskServiceImpl extends ServiceImpl<NetdiskMapper, Netdisk> impl
|
|
|
if (ObjectUtil.isNotEmpty(fileInfo)) {
|
|
|
fileInfo.setFileName(netdiskDto.getName());
|
|
|
fileInfoService.updateById(fileInfo);
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
throw new ServiceException("文件信息不存在");
|
|
|
}
|
|
|
DynamicDataSourceContextHolder.poll();
|
|
@@ -126,7 +134,7 @@ public class NetdiskServiceImpl extends ServiceImpl<NetdiskMapper, Netdisk> impl
|
|
|
this.removeBatchByIds(ids);
|
|
|
DynamicDataSourceContextHolder.push(SourceConstant.BASE);
|
|
|
List<FileInfo> list = fileInfoService.list(q -> q.in(FileInfo::getBusinessId, ids));
|
|
|
- if(ObjectUtil.isNotEmpty(list)) {
|
|
|
+ if (ObjectUtil.isNotEmpty(list)) {
|
|
|
List<Long> fids = list.stream().map(FileInfo::getId).collect(Collectors.toList());
|
|
|
fileInfoService.removeBatchByIds(fids);
|
|
|
}
|