package jnpf.dmsMapper;
|
|
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
import jnpf.dmsEntity.permission.entity.DmsPermissionResourceEntity;
|
import jnpf.dmsEntity.permission.vo.DmsPermissionResourceVO;
|
import org.apache.ibatis.annotations.Mapper;
|
import org.apache.ibatis.annotations.Param;
|
import org.apache.ibatis.annotations.Select;
|
|
import java.util.Date;
|
import java.util.List;
|
import java.util.UUID;
|
|
@Mapper
|
public interface DmsPermissionResourceMapper extends BaseMapper<DmsPermissionResourceEntity> {
|
String RESOURCE_VIEW_SQL = "SELECT r.id, r.resource_type, "
|
+ "CASE r.resource_type WHEN 'FOLDER' THEN f.parent_id WHEN 'DOCUMENT' THEN d.folder_id "
|
+ "WHEN 'FILE_VERSION' THEN v.document_id END AS parent_id, "
|
+ "CASE r.resource_type WHEN 'FOLDER' THEN f.name WHEN 'DOCUMENT' THEN d.name "
|
+ "WHEN 'FILE_VERSION' THEN v.file_name END AS name, "
|
+ "CASE r.resource_type WHEN 'DOCUMENT' THEN d.id "
|
+ "WHEN 'FILE_VERSION' THEN v.document_id END AS document_id, "
|
+ "COALESCE(d.name, version_document.name) AS document_name, "
|
+ "COALESCE(d.document_no, version_document.document_no) AS document_no, "
|
+ "COALESCE(v.version_no, current_version.version_no) AS version_no, "
|
+ "COALESCE(v.version_label, current_version.version_label) AS version_label, "
|
+ "COALESCE(v.file_name, current_version.file_name) AS file_name, "
|
+ "COALESCE(v.mime_type, current_version.mime_type) AS mime_type, "
|
+ "COALESCE(v.size_bytes, current_version.size_bytes) AS size_bytes, "
|
+ "COALESCE(v.checksum_sha256, current_version.checksum_sha256) AS checksum_sha256, "
|
+ "COALESCE(version_state.lifecycle_status, current_state.lifecycle_status) AS lifecycle_status, "
|
+ "COALESCE(version_state.effective_from, current_state.effective_from) AS effective_from, "
|
+ "COALESCE(version_state.effective_to, current_state.effective_to) AS effective_to, "
|
+ "r.source_type, r.source_id, CASE r.resource_type "
|
+ "WHEN 'FOLDER' THEN f.created_at WHEN 'DOCUMENT' THEN current_version.created_at "
|
+ "WHEN 'FILE_VERSION' THEN v.created_at ELSE r.created_at END AS created_at "
|
+ "FROM public.dms_permission_resources r "
|
+ "LEFT JOIN public.dms_folders f ON r.resource_type = 'FOLDER' "
|
+ "AND f.tenant_id = r.tenant_id AND f.id = r.id "
|
+ "LEFT JOIN public.dms_documents d ON r.resource_type = 'DOCUMENT' "
|
+ "AND d.tenant_id = r.tenant_id AND d.id = r.id "
|
+ "LEFT JOIN public.dms_file_versions v ON r.resource_type = 'FILE_VERSION' "
|
+ "AND v.tenant_id = r.tenant_id AND v.id = r.id "
|
+ "LEFT JOIN public.dms_documents version_document ON r.resource_type = 'FILE_VERSION' "
|
+ "AND version_document.tenant_id = v.tenant_id AND version_document.id = v.document_id "
|
+ "LEFT JOIN public.dms_version_states current_state ON r.resource_type = 'DOCUMENT' "
|
+ "AND current_state.tenant_id = r.tenant_id AND current_state.document_id = r.id "
|
+ "AND current_state.lifecycle_status = 'EFFECTIVE' "
|
+ "AND CURRENT_TIMESTAMP >= current_state.effective_from "
|
+ "AND (current_state.effective_to IS NULL OR current_state.effective_to > CURRENT_TIMESTAMP) "
|
+ "LEFT JOIN public.dms_file_versions current_version ON current_version.tenant_id = current_state.tenant_id "
|
+ "AND current_version.document_id = current_state.document_id "
|
+ "AND current_version.id = current_state.file_version_id "
|
+ "LEFT JOIN public.dms_version_states version_state ON r.resource_type = 'FILE_VERSION' "
|
+ "AND version_state.tenant_id = v.tenant_id AND version_state.document_id = v.document_id "
|
+ "AND version_state.file_version_id = v.id ";
|
|
@Select("SELECT uuidv7()")
|
UUID nextUuidV7();
|
|
@Select("SELECT 1 FROM (SELECT pg_advisory_xact_lock(hashtextextended(#{tenantId} || ':' "
|
+ "|| #{sourceType} || ':' || #{sourceId}, 0))) advisory_lock")
|
Integer lockSource(@Param("tenantId") String tenantId,
|
@Param("sourceType") String sourceType,
|
@Param("sourceId") String sourceId);
|
|
@Select("SELECT id, tenant_id, resource_type, source_type, source_id, registered_by, created_at "
|
+ "FROM public.dms_permission_resources WHERE tenant_id = #{tenantId} AND id = #{id}")
|
DmsPermissionResourceEntity selectByTenantAndId(@Param("tenantId") String tenantId,
|
@Param("id") UUID id);
|
|
@Select("SELECT id, tenant_id, resource_type, source_type, source_id, registered_by, created_at "
|
+ "FROM public.dms_permission_resources WHERE tenant_id = #{tenantId} "
|
+ "AND source_type = #{sourceType} AND source_id = #{sourceId}")
|
DmsPermissionResourceEntity selectBySource(@Param("tenantId") String tenantId,
|
@Param("sourceType") String sourceType,
|
@Param("sourceId") String sourceId);
|
|
@Select({"<script>",
|
"SELECT id, tenant_id, resource_type, source_type, source_id, registered_by, created_at",
|
"FROM public.dms_permission_resources WHERE tenant_id = #{tenantId} AND id IN",
|
"<foreach collection='ids' item='id' open='(' separator=',' close=')'>#{id}</foreach>",
|
"</script>"})
|
List<DmsPermissionResourceEntity> selectByTenantAndIds(@Param("tenantId") String tenantId,
|
@Param("ids") List<UUID> ids);
|
|
@Select(RESOURCE_VIEW_SQL + "WHERE r.tenant_id = #{tenantId} AND r.id = #{id}")
|
DmsPermissionResourceVO selectView(@Param("tenantId") String tenantId, @Param("id") UUID id);
|
|
@Select({"<script>", RESOURCE_VIEW_SQL,
|
"WHERE r.tenant_id = #{tenantId}",
|
"<if test='resourceType != null and resourceType != \"\"'>",
|
"AND r.resource_type = #{resourceType}",
|
"</if>",
|
"<if test='cursorTime != null'>",
|
"AND (r.created_at, r.id) < (#{cursorTime}, #{cursorId})",
|
"</if>",
|
"ORDER BY r.created_at DESC, r.id DESC LIMIT #{limit}",
|
"</script>"})
|
List<DmsPermissionResourceVO> selectPage(@Param("tenantId") String tenantId,
|
@Param("resourceType") String resourceType,
|
@Param("cursorTime") Date cursorTime,
|
@Param("cursorId") UUID cursorId,
|
@Param("limit") int limit);
|
|
@Select({"<script>", RESOURCE_VIEW_SQL,
|
"WHERE r.tenant_id = #{tenantId}",
|
"<choose>",
|
"<when test='parentId == null'>",
|
"AND r.resource_type = 'FOLDER' AND f.parent_id IS NULL",
|
"</when>",
|
"<otherwise>",
|
"AND ((r.resource_type = 'FOLDER' AND f.parent_id = #{parentId})",
|
"OR (r.resource_type = 'DOCUMENT' AND d.folder_id = #{parentId})",
|
"OR (r.resource_type = 'FILE_VERSION' AND v.document_id = #{parentId}))",
|
"</otherwise>",
|
"</choose>",
|
"ORDER BY r.resource_type, name, r.id LIMIT #{limit}",
|
"</script>"})
|
List<DmsPermissionResourceVO> selectChildren(@Param("tenantId") String tenantId,
|
@Param("parentId") UUID parentId,
|
@Param("limit") int limit);
|
|
}
|
