基于Java的开源文档管理平台/企业网盘设计源码

/* Copyright (c) 2019. 本项目所有源码受中华人民共和国著作权法保护，已登记软件著作权。 * 本项目版权归南昌瀚为云科技有限公司所有，本项目仅供学习交流使用，未经许可不得进行商用，开源（社区版）遵守AGPL-3.0协议。 * */ package com.honvay.hdms.dms.document.service.impl; import com.honvay.hdms.dms.authorize.service.AuthorizeService; import com.honvay.hdms.dms.document.entity.Document; import com.honvay.hdms.dms.document.enums.DocumentAccessibility; import com.honvay.hdms.dms.document.enums.DocumentType; import com.honvay.hdms.dms.document.repository.DocumentRepository; import com.honvay.hdms.dms.document.service.DocumentWriteService; import com.honvay.hdms.dms.event.*; import com.honvay.hdms.dms.model.request.*; import com.honvay.hdms.dms.mount.entity.Mount; import com.honvay.hdms.dms.mount.service.MountService; import com.honvay.hdms.dms.permission.enums.PermissionType; import com.honvay.hdms.dms.storage.Storage; import com.honvay.hdms.framework.core.exception.ServiceException; import com.honvay.hdms.user.domain.User; import com.honvay.hdms.user.enums.UserStatus; import com.honvay.hdms.user.service.UserService; import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.ApplicationEvent; import org.springframework.context.ApplicationEventPublisher; import org.springframework.context.ApplicationListener; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.Assert; import org.springframework.validation.annotation.Validated; import java.util.*; /** * @author LIQIU * created on 2019/2/28 **/ @Validated @Service @Transactional public class DocumentWriteServiceImpl implements DocumentWriteService, ApplicationListener { @Autowired private Storage storage; @Autowired private MountService mountService; @Autowired private UserService userService; @Autowired private AuthorizeService authorizeService; @Autowired private DocumentRepository documentRepository; @Autowired private ApplicationEventPublisher applicationEventPublisher; /** * 移动文件夹 */ @Override public void move(MoveRequest request) { Document parent = null; if (request.getParent() != null) { parent = this.findById(request.getParent()); } for (Integer documentId : request.getDocumentIds()) { Document document = this.findById(documentId); //TODO 判断子是否有锁定的文件 Assert.isTrue(!document.getLocked(), "已锁定的文件不能移动"); if (DocumentType.isFile(document.getType()) && parent == null && request.getMount().equals(request.getUser().getOrganizationMount().getId())) { throw new IllegalArgumentException("不能将文件移动到企业文档根目录"); } Assert.isTrue(authorizeService.checkPermission(request.getUser(), document, PermissionType.REMOVE), "无权限复制文件到其他目录"); if (parent != null) { if (DocumentType.isFile(document.getType())) { Assert.isTrue(authorizeService.checkPermission(request.getUser(), parent, PermissionType.CREATE), "无权权限创建文件夹"); } else { Assert.isTrue(authorizeService.checkPermission(request.getUser(), parent, PermissionType.UPLOAD), "无权权限复制文件"); } Assert.isTrue(!parent.getId().equals(document.getId()), "不能移动到原文件夹中"); } Document originalParent = null; Integer originalMount = document.getMount(); String originalPath = document.getPath(); String originalFullName = document.getFullName(); String originalParentName = null; //获取原父文件夹名称 if (document.getParent() != -1) { originalParent = this.findById(document.getParent()); } //移动到根目录下 if (parent == null) { Assert.isTrue(!(request.getMount().equals(document.getMount()) && document.getParent() == -1), "不能移动到自身"); document.setMount(request.getMount()); document.setParent(-1); } else { Assert.isTrue(!parent.getId().equals(document.getId()), "不能移动到自身"); document.setMount(parent.getMount()); document.setParent(request.getParent()); } //设置唯一的名称 this.setUniqueName(document); //同步父目录的信息 this.syncByParent(document, parent); this.documentRepository.update(document); if (DocumentType.isDirectory(document.getType())) { //this.moveChildren(document); //批量修改文件 this.documentRepository.batchUpdateChildren(document.getMount(), originalPath, document.getPath(), originalFullName, document.getFullName()); } MoveEvent moveEvent = new MoveEvent(document, originalParent, parent, originalMount, document.getMount(), request.getUser().getId()); applicationEventPublisher.publishEvent(moveEvent); } } private void moveChildren(Document document) { List<Document> children = this.documentRepository.findByParent(document.getId()); for (Document child : children) { child.setMount(document.getMount()); this.syncByParent(child, document); this.documentRepository.update(child); if (DocumentType.isDirectory(child.getType())) { this.moveChildren(child); } } } @Override public void transfer(Integer source, Integer target) { User user = this.userService.get(Integer.valueOf(source)); Assert.isTrue(UserStatus.DISABLED.getValue().equals(user.getStatus()), "只能移交已失效用户的文档!"); Assert.isTrue(target != null, "参数错误，移交对象缺失"); Assert.isTrue(!source.equals(target), "参数错误，移交人相同"); List<Document> children = this.documentRepository.findByParent(source); for (Document document : children) { //提交到新的用户 document.setMount(target); this.setUniqueName(document); this.syncByParent(document); this.documentRepository.update(document); if (DocumentType.isDirectory(document.getType())) { this.transferChildren(document); } } } @Override public void update(Document document) { this.documentRepository.update(document); } @Override public void lock(LockRequest request) { for (Integer id : request.getDocumentIds()) { Document document = this.findById(id); Assert.isTrue(!document.getLocked(), "该文件已经锁定"); Assert.isTrue(!DocumentType.isDirectory(document.getType()), "不能锁定文件夹"); Assert.isTrue(authorizeService.checkPermission(request.getUser(), document, PermissionType.LOCK), "无权限锁定文件"); this.documentRepository.lock(id, request.getUser().getId()); LockEvent lockEvent = new LockEvent(document, request.getUser().getId()); applicationEventPublisher.publishEvent(lockEvent); } } @Override public void unlock(UnLockRequest request) { for (Integer id : request.getDocumentIds()) { Document document = this.findById(id); Assert.isTrue(document.getLockedBy().equals(request.getUser().getId()), "文件夹解锁只能锁定者操作"); Assert.isTrue(document.getLocked(), "该文件没有锁定"); Assert.isTrue(authorizeService.checkPermission(request.getUser(), document, PermissionType.LOCK), "无权限解锁文件"); this.documentRepository.unlock(id, request.getUser().getId()); UnlockEvent unlockEvent = new UnlockEvent(document, request.getUser().getId()); applicationEventPublisher.publishEvent(unlockEvent); } } /** * 复制文件夹 */ @Override public void copy(CopyRequest request) { Document parent = null; if (request.getParent() != null && request.getParent() != -1) { parent = this.findById(request.getParent()); } Assert.isTrue(request.getParent() != null || request.getMount() != null, "复制到目标参数为空"); for (Integer id : request.getDocumentIds())