package jnpf.dmsService;
|
|
import jnpf.base.UserInfo;
|
import jnpf.dmsEntity.permission.model.DmsSubjectSet;
|
import jnpf.dmsEntity.permission.enums.DmsPermissionAction;
|
import jnpf.dmsEntity.permission.enums.DmsResourceType;
|
import jnpf.dmsEntity.permission.vo.DmsCursorPageVO;
|
import jnpf.dmsEntity.permission.vo.DmsFileCenterItemVO;
|
import jnpf.dmsEntity.permission.vo.DmsFolderTreeNodeVO;
|
import jnpf.dmsMapper.DmsFileCenterMapper;
|
import jnpf.dmsPermission.DmsCurrentIdentity;
|
import jnpf.dmsPermission.DmsFileCenterCursorCodec;
|
import jnpf.dmsPermission.DmsFileCenterQuery;
|
import jnpf.dmsPermission.DmsFileSearchPolicy;
|
import jnpf.dmsPermission.DmsPermissionError;
|
import jnpf.dmsPermission.DmsPermissionException;
|
import jnpf.dmsPermission.DmsPermissionGroupMembershipResolver;
|
import jnpf.dmsPermission.DmsPermissionProperties;
|
import jnpf.dmsPermission.DmsSubjectResolver;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.Collections;
|
import java.util.List;
|
import java.util.UUID;
|
import java.util.function.Function;
|
|
@Service
|
@RequiredArgsConstructor
|
public class DmsFileCenterService {
|
private static final String FOLDER_CURSOR = "FOLDER";
|
private static final String CURRENT_CURSOR = "CURRENT_FOLDER";
|
private static final String HISTORICAL_CURSOR = "HISTORICAL_FOLDER";
|
private static final String CURRENT_DOCUMENT_VERSIONS_CURSOR = "CURRENT_DOCUMENT_VERSIONS";
|
private static final String HISTORICAL_DOCUMENT_VERSIONS_CURSOR = "HISTORICAL_DOCUMENT_VERSIONS";
|
private static final String SHARED_CURRENT_CURSOR = "SHARED_CURRENT";
|
private static final String SHARED_HISTORICAL_CURSOR = "SHARED_HISTORICAL";
|
|
private final DmsCurrentIdentity currentIdentity;
|
private final DmsSubjectResolver subjectResolver;
|
private final DmsPermissionGroupMembershipResolver groupMembershipResolver;
|
private final DmsPermissionProperties properties;
|
private final DmsFileCenterCursorCodec cursorCodec;
|
private final DmsFileCenterMapper mapper;
|
private final DmsPermissionDecisionService decisionService;
|
|
@Transactional(readOnly = true)
|
public DmsCursorPageVO<DmsFolderTreeNodeVO> folderTree(UUID parentId, String cursor, Integer pageSize) {
|
DmsCursorPageVO<DmsFileCenterItemVO> page = folders(parentId, cursor, pageSize, true);
|
List<DmsFolderTreeNodeVO> nodes = new ArrayList<>();
|
for (DmsFileCenterItemVO item : page.getList()) {
|
DmsFolderTreeNodeVO node = new DmsFolderTreeNodeVO();
|
node.setId(item.getId());
|
node.setParentId(item.getParentId());
|
node.setName(item.getName());
|
node.setSortCode(item.getSortCode());
|
node.setHasChildren(Boolean.TRUE.equals(item.getHasChildren()));
|
nodes.add(node);
|
}
|
DmsCursorPageVO<DmsFolderTreeNodeVO> result = new DmsCursorPageVO<>();
|
result.setList(nodes);
|
result.setHasMore(page.isHasMore());
|
result.setNextCursor(page.getNextCursor());
|
return result;
|
}
|
|
@Transactional(readOnly = true)
|
public DmsCursorPageVO<DmsFileCenterItemVO> rootFolders(String cursor, Integer pageSize) {
|
return folders(null, cursor, pageSize);
|
}
|
|
@Transactional(readOnly = true)
|
public DmsCursorPageVO<DmsFileCenterItemVO> childFolders(UUID parentId, String cursor,
|
Integer pageSize) {
|
return folders(parentId, cursor, pageSize);
|
}
|
|
@Transactional(readOnly = true)
|
public DmsCursorPageVO<DmsFileCenterItemVO> currentDocuments(UUID folderId, String cursor,
|
Integer pageSize, String keyword) {
|
DmsFileCenterQuery query = query();
|
query.setFolderId(folderId);
|
query.setKeyword(DmsFileSearchPolicy.normalizeKeyword(keyword));
|
int limit = pageSize(pageSize);
|
String fingerprint = cursorCodec.fingerprint(query.getKeyword());
|
applyCursor(query, cursorCodec.decode(cursor, CURRENT_CURSOR, query.getTenantId(),
|
query.getUserId(), folderId, fingerprint));
|
query.setLimit(limit + 1);
|
List<DmsFileCenterItemVO> rows = query.getKeyword() == null
|
? mapper.selectCurrentDocuments(query) : mapper.selectCurrentFiles(query);
|
return page(rows, limit,
|
item -> cursorCodec.encode(CURRENT_CURSOR, query.getTenantId(), query.getUserId(),
|
folderId, fingerprint, cursor(item)));
|
}
|
|
@Transactional(readOnly = true)
|
public boolean fileNameExists(UUID folderId, String fileName, String version) {
|
if (folderId == null || fileName == null || fileName.trim().isEmpty()) {
|
throw DmsPermissionException.of(DmsPermissionError.INVALID_REQUEST,
|
"目录 ID 和文件名不能为空");
|
}
|
UserInfo user = currentIdentity.requireUser();
|
if (!currentIdentity.isPermissionAdministrator()) {
|
decisionService.requireAllowed(DmsResourceType.FOLDER, folderId, DmsPermissionAction.CREATE);
|
}
|
return mapper.fileNameExists(currentIdentity.tenantId(user), folderId, fileName.trim());
|
}
|
|
@Transactional(readOnly = true)
|
public DmsCursorPageVO<DmsFileCenterItemVO> historicalVersions(UUID folderId, String cursor,
|
Integer pageSize, String keyword) {
|
DmsFileCenterQuery query = query();
|
query.setFolderId(folderId);
|
query.setKeyword(DmsFileSearchPolicy.normalizeKeyword(keyword));
|
int limit = pageSize(pageSize);
|
String fingerprint = cursorCodec.fingerprint(query.getKeyword());
|
applyCursor(query, cursorCodec.decode(cursor, HISTORICAL_CURSOR, query.getTenantId(),
|
query.getUserId(), folderId, fingerprint));
|
query.setLimit(limit + 1);
|
List<DmsFileCenterItemVO> rows = query.getKeyword() == null
|
? mapper.selectHistoricalVersions(query) : mapper.selectHistoricalFiles(query);
|
return page(rows, limit,
|
item -> cursorCodec.encode(HISTORICAL_CURSOR, query.getTenantId(), query.getUserId(),
|
folderId, fingerprint, cursor(item)));
|
}
|
|
@Transactional(readOnly = true)
|
public DmsCursorPageVO<DmsFileCenterItemVO> documentVersions(UUID documentId, String center,
|
String cursor, Integer pageSize,
|
String keyword) {
|
boolean historical = normalizeCenter(center);
|
String cursorKind = historical
|
? HISTORICAL_DOCUMENT_VERSIONS_CURSOR : CURRENT_DOCUMENT_VERSIONS_CURSOR;
|
DmsFileCenterQuery query = query();
|
query.setDocumentId(documentId);
|
query.setKeyword(DmsFileSearchPolicy.normalizeKeyword(keyword));
|
int limit = pageSize(pageSize);
|
String fingerprint = cursorCodec.fingerprint(query.getKeyword());
|
applyCursor(query, cursorCodec.decode(cursor, cursorKind, query.getTenantId(),
|
query.getUserId(), documentId, fingerprint));
|
query.setLimit(limit + 1);
|
List<DmsFileCenterItemVO> rows = historical
|
? mapper.selectDocumentVersions(query) : mapper.selectCurrentDocumentVersions(query);
|
return page(rows, limit,
|
item -> cursorCodec.encode(cursorKind, query.getTenantId(), query.getUserId(),
|
documentId, fingerprint, cursor(item)));
|
}
|
|
@Transactional(readOnly = true)
|
public DmsCursorPageVO<DmsFileCenterItemVO> sharedDocuments(String center, String cursor,
|
Integer pageSize) {
|
boolean historical = normalizeCenter(center);
|
String cursorKind = historical ? SHARED_HISTORICAL_CURSOR : SHARED_CURRENT_CURSOR;
|
DmsFileCenterQuery query = query();
|
int limit = pageSize(pageSize);
|
String fingerprint = cursorCodec.fingerprint(null);
|
applyCursor(query, cursorCodec.decode(cursor, cursorKind, query.getTenantId(),
|
query.getUserId(), null, fingerprint));
|
query.setLimit(limit + 1);
|
List<DmsFileCenterItemVO> rows = historical
|
? mapper.selectSharedHistoricalVersions(query) : mapper.selectSharedDocuments(query);
|
return page(rows, limit,
|
item -> cursorCodec.encode(cursorKind, query.getTenantId(), query.getUserId(),
|
null, fingerprint, cursor(item)));
|
}
|
|
private DmsCursorPageVO<DmsFileCenterItemVO> folders(UUID parentId, String cursor,
|
Integer pageSize) {
|
return folders(parentId, cursor, pageSize, false);
|
}
|
|
private DmsCursorPageVO<DmsFileCenterItemVO> folders(UUID parentId, String cursor,
|
Integer pageSize, boolean includeFolderChildren) {
|
DmsFileCenterQuery query = query();
|
query.setIncludeFolderChildren(includeFolderChildren);
|
query.setParentId(parentId);
|
int limit = pageSize(pageSize);
|
String fingerprint = cursorCodec.fingerprint(null);
|
applyCursor(query, cursorCodec.decode(cursor, FOLDER_CURSOR, query.getTenantId(),
|
query.getUserId(), parentId, fingerprint));
|
query.setLimit(limit + 1);
|
return page(mapper.selectFolders(query), limit,
|
item -> cursorCodec.encode(FOLDER_CURSOR, query.getTenantId(), query.getUserId(),
|
parentId, fingerprint, cursor(item)));
|
}
|
|
private DmsFileCenterQuery query() {
|
UserInfo user = currentIdentity.requireUser();
|
DmsFileCenterQuery query = new DmsFileCenterQuery();
|
query.setTenantId(currentIdentity.tenantId(user));
|
query.setUserId(user.getUserId().trim());
|
query.setAdministrator(currentIdentity.isPermissionAdministrator());
|
if (query.isAdministrator()) {
|
return query;
|
}
|
DmsSubjectSet subjects = subjectResolver.resolve(user);
|
groupMembershipResolver.resolveAll(subjects, properties.getMaxPermissionGroupScan());
|
query.setDirectOrgIds(new ArrayList<>(subjects.getDirectOrgIds()));
|
query.setImmediateParentOrgIds(new ArrayList<>(subjects.getImmediateParentOrgIds()));
|
query.setAncestorOrgIds(new ArrayList<>(subjects.getAncestorOrgIds()));
|
query.setPositionIds(new ArrayList<>(subjects.getPositionIds()));
|
query.setRoleIds(new ArrayList<>(subjects.getRoleIds()));
|
query.setPermissionGroupIds(new ArrayList<>(subjects.getPermissionGroupIds()));
|
return query;
|
}
|
|
private void applyCursor(DmsFileCenterQuery query, DmsFileCenterCursorCodec.Cursor cursor) {
|
query.setCursorName(cursor.getName());
|
query.setCursorDocumentId(cursor.getDocumentId());
|
query.setCursorVersionNo(cursor.getVersionNo());
|
query.setCursorSortCode(cursor.getSortCode());
|
query.setCursorId(cursor.getId());
|
}
|
|
private DmsFileCenterCursorCodec.Cursor cursor(DmsFileCenterItemVO item) {
|
return new DmsFileCenterCursorCodec.Cursor(
|
item.getName(), item.getDocumentId(), item.getVersionNo(), item.getSortCode(), item.getId());
|
}
|
|
private DmsCursorPageVO<DmsFileCenterItemVO> page(
|
List<DmsFileCenterItemVO> values, int limit, Function<DmsFileCenterItemVO, String> encoder) {
|
List<DmsFileCenterItemVO> rows = values == null
|
? Collections.<DmsFileCenterItemVO>emptyList() : values;
|
boolean hasMore = rows.size() > limit;
|
if (hasMore) {
|
rows = new ArrayList<>(rows.subList(0, limit));
|
}
|
DmsCursorPageVO<DmsFileCenterItemVO> result = new DmsCursorPageVO<>();
|
result.setList(rows);
|
result.setHasMore(hasMore);
|
if (hasMore && !rows.isEmpty()) {
|
result.setNextCursor(encoder.apply(rows.get(rows.size() - 1)));
|
}
|
return result;
|
}
|
|
private int pageSize(Integer requested) {
|
int value = requested == null ? properties.getDefaultPageSize() : requested;
|
if (value < 1 || value > properties.getMaxPageSize()) {
|
throw DmsPermissionException.of(DmsPermissionError.INVALID_REQUEST,
|
"pageSize 必须在 1 到 " + properties.getMaxPageSize() + " 之间");
|
}
|
return value;
|
}
|
|
private boolean normalizeCenter(String value) {
|
if (value == null || value.trim().isEmpty() || "CURRENT".equalsIgnoreCase(value.trim())) {
|
return false;
|
}
|
if ("HISTORICAL".equalsIgnoreCase(value.trim())) {
|
return true;
|
}
|
throw DmsPermissionException.of(DmsPermissionError.INVALID_REQUEST,
|
"center 必须是 CURRENT 或 HISTORICAL");
|
}
|
}
|
