电信部门电子档案系统建设全流程实操指南

系统架构与选型

电信部门档案主要包含客户协议、网络建设图纸、运维工单、合规文件等，具有数据量大、格式杂、保密性高、保存期限长等特点。系统需满足长期保存、快速检索、权限精细控制等核心需求。

技术栈选择

采用微服务架构，便于后期按业务模块扩展。具体技术选型如下：

• 存储层：结构化元数据（如档案编号、名称、时间、责任人）使用 PostgreSQL 13+，利用其 JSONB 字段存储动态扩展属性。非结构化文件（PDF、CAD、图片）使用 MinIO 对象存储，实现高可靠低成本。
• 服务层：使用 Java Spring Boot 2.7 构建核心业务服务，Python FastAPI 构建文件处理异步任务。
• 检索层：结合 Elasticsearch 8.x 实现全文检索与多维度组合检索。
• 基础设施：使用 Docker 23.0+ 容器化部署，通过 Docker Compose 或 Kubernetes 编排。

最小化部署环境准备

以下为单节点开发/测试环境部署命令，需提前安装 Docker 与 Docker Compose。

创建 docker-compose.yml 文件：

``` version: '3.8' services: postgres: image: postgres:15-alpine environment: POSTGRES_DB: telecom_archive POSTGRES_USER: admin POSTGRES_PASSWORD: YourStrongPassword123! volumes: - pg_data:/var/lib/postgresql/data ports: - "5432:5432" minio: image: minio/minio:latest command: server /data --console-address ":9001" environment: MINIO_ROOT_USER: minioadmin MINIO_ROOT_PASSWORD: minioadmin123 volumes: - minio_data:/data ports: - "9000:9000" API端口 - "9001:9001" 控制台端口 elasticsearch: image: elasticsearch:8.11.0 environment: - discovery.type=single-node - xpack.security.enabled=false - "ES_JAVA_OPTS=-Xms512m -Xmx512m" ulimits: memlock: soft: -1 hard: -1 volumes: - es_data:/usr/share/elasticsearch/data ports: - "9200:9200" volumes: pg_data: minio_data: es_data: ```

在文件所在目录执行 docker-compose up -d 启动所有服务。

核心模块实现步骤

1. 档案元数据模型设计

在 PostgreSQL 中创建核心表。连接数据库后执行以下 SQL：

``` CREATE TABLE archive_category ( id SERIAL PRIMARY KEY, code VARCHAR(50) NOT NULL UNIQUE, -- 如：CUST_CONTRACT name VARCHAR(100) NOT NULL, -- 如：客户协议 retention_years INTEGER NOT NULL, -- 保留年限 created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ); CREATE TABLE archive_item ( id VARCHAR(36) PRIMARY KEY DEFAULT gen_random_uuid(), -- UUID作为主键 archive_number VARCHAR(100) NOT NULL UNIQUE, -- 档案编号规则：部门-年份-序列号 category_code VARCHAR(50) NOT NULL REFERENCES archive_category(code), title VARCHAR(500) NOT NULL, original_filename VARCHAR(500) NOT NULL, file_size BIGINT NOT NULL, file_md5 VARCHAR(32) NOT NULL, -- 用于文件完整性校验 storage_path VARCHAR(1000) NOT NULL, -- MinIO中的存储路径 confidential_level INTEGER NOT NULL CHECK (confidential_level BETWEEN 1 AND 5), -- 密级1-5 created_by VARCHAR(50) NOT NULL, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, metadata JSONB -- 动态扩展字段，如客户ID、项目编号等 ); CREATE INDEX idx_archive_item_category ON archive_item(category_code); CREATE INDEX idx_archive_item_created_at ON archive_item(created_at); CREATE INDEX idx_archive_item_metadata ON archive_item USING GIN (metadata); ```

2. 文件上传与存储服务

使用 Spring Boot 实现文件上传接口，关键步骤如下：

创建 MinIO 配置类 MinioConfig.java：

``` import io.minio.MinioClient; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class MinioConfig { @Value("${minio.endpoint:http://localhost:9000}") private String endpoint; @Value("${minio.accessKey:minioadmin}") private String accessKey; @Value("${minio.secretKey:minioadmin123}") private String secretKey; @Bean public MinioClient minioClient() { return MinioClient.builder() .endpoint(endpoint) .credentials(accessKey, secretKey) .build(); } } ```

创建文件上传服务类 ArchiveStorageService.java，包含核心上传方法：

``` import io.minio.MinioClient; import io.minio.PutObjectArgs; import org.apache.commons.codec.digest.DigestUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile; import java.io.InputStream; @Service public class ArchiveStorageService { @Autowired private MinioClient minioClient; @Value("${minio.bucket:telecom-archive}") private String bucketName; public String uploadFile(MultipartFile file, String categoryCode, String operator) throws Exception { // 1. 计算文件MD5 String md5; try (InputStream is = file.getInputStream()) { md5 = DigestUtils.md5Hex(is); } // 2. 生成存储路径：类别/年/月/日/UUID_原文件名 String originalFilename = file.getOriginalFilename(); String fileExtension = originalFilename.substring(originalFilename.lastIndexOf(".")); String newFilename = java.util.UUID.randomUUID() + fileExtension; java.time.LocalDate now = java.time.LocalDate.now(); String objectPath = String.format("%s/%d/%02d/%02d/%s", categoryCode, now.getYear(), now.getMonthValue(), now.getDayOfMonth(), newFilename); // 3. 上传到MinIO try (InputStream fileIs = file.getInputStream()) { minioClient.putObject( PutObjectArgs.builder() .bucket(bucketName) .object(objectPath) .stream(fileIs, file.getSize(), -1) .contentType(file.getContentType()) .build() ); } // 4. 返回存储路径，供后续存入数据库 return objectPath; } } ```

3. 档案索引与检索服务

档案存入数据库后，需同步至 Elasticsearch 以支持复杂检索。创建同步任务类：

``` import co.elastic.clients.elasticsearch.ElasticsearchClient; import co.elastic.clients.elasticsearch.core.IndexRequest; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.io.IOException; @Service public class ArchiveIndexService { @Autowired private ElasticsearchClient esClient; private final String INDEX_NAME = "telecom_archive"; public void indexArchiveItem(ArchiveItem item) throws IOException { // 构建索引文档 IndexDocument doc = new IndexDocument(); doc.setId(item.getId()); doc.setArchiveNumber(item.getArchiveNumber()); doc.setTitle(item.getTitle()); doc.setCategoryCode(item.getCategoryCode()); doc.setConfidentialLevel(item.getConfidentialLevel()); doc.setCreatedAt(item.getCreatedAt()); doc.setCreatedBy(item.getCreatedBy()); // 将JSONB中的关键字段也平铺出来便于检索 if (item.getMetadata() != null) { doc.setCustomerId(item.getMetadata().get("customerId").asText()); doc.setProjectCode(item.getMetadata().get("projectCode").asText()); } IndexRequest request = IndexRequest.of(i -> i .index(INDEX_NAME) .id(item.getId()) .document(doc) ); esClient.index(request); } } ```

创建组合检索的 REST 接口，接收多条件查询：

``` @PostMapping("/search") public SearchResult search(@RequestBody SearchRequest request) { // 构建Elasticsearch复合查询 Query query = BoolQuery.of(b -> b .must(m -> m.match(t -> t.field("title").query(request.getKeyword()))) // 标题关键词 .must(m -> m.term(t -> t.field("categoryCode").value(request.getCategoryCode()))) // 类别 .must(m -> m.range(r -> r.field("confidentialLevel").lte(request.getMaxConfidentialLevel()))) // 密级 .must(m -> m.range(r -> r.field("createdAt").gte(request.getStartDate().toString()))) // 时间范围 )._toQuery(); SearchResponse response = esClient.search(s -> s .index(INDEX_NAME) .query(query) .from((request.getPage() - 1) request.getSize()) .size(request.getSize()) .sort(so -> so.field(f -> f.field("createdAt").order(SortOrder.Desc))), // 按时间倒排 IndexDocument.class ); // 处理并返回结果... } ```

权限控制与安全策略

基于角色的访问控制（RBAC）实现

在数据库中创建权限相关表：

``` CREATE TABLE sys_role ( id SERIAL PRIMARY KEY, role_code VARCHAR(50) UNIQUE NOT NULL, -- 如：ARCHIVE_ADMIN, DEPARTMENT_USER role_name VARCHAR(100) NOT NULL ); CREATE TABLE archive_permission ( id SERIAL PRIMARY KEY, role_code VARCHAR(50) NOT NULL REFERENCES sys_role(role_code), category_code VARCHAR(50) NOT NULL REFERENCES archive_category(code), allow_view BOOLEAN DEFAULT FALSE, allow_upload BOOLEAN DEFAULT FALSE, allow_download BOOLEAN DEFAULT FALSE, allow_delete BOOLEAN DEFAULT FALSE, max_allowed_confidential_level INTEGER CHECK (max_allowed_confidential_level BETWEEN 1 AND 5) ); ```

在每个业务接口中，如文件下载，必须进行权限校验：

``` @GetMapping("/download/{archiveId}") public ResponseEntity downloadArchive(@PathVariable String archiveId, HttpServletRequest request) { // 1. 根据archiveId查询档案信息 ArchiveItem item = archiveRepository.findById(archiveId).orElseThrow(...); // 2. 获取当前用户角色（从Session或Token中） String userRole = getCurrentUserRole(request); // 3. 查询权限表，校验该角色对该档案类别是否有download权限，且用户密级权限 >= 档案密级 Permission permission = permissionRepository.findByRoleCodeAndCategoryCode( userRole, item.getCategoryCode()); if (permission == null || !permission.isAllowDownload() || permission.getMaxAllowedConfidentialLevel() < item.getConfidentialLevel()) { throw new AccessDeniedException("无权下载此档案"); } // 4. 从MinIO获取文件流返回... } ```

系统监控与日志

为确保系统可观测性，必须记录关键操作日志。创建操作日志表：

``` CREATE TABLE operation_log ( id BIGSERIAL PRIMARY KEY, operator VARCHAR(50) NOT NULL, operation_type VARCHAR(20) NOT NULL, -- UPLOAD, DOWNLOAD, DELETE, SEARCH archive_number VARCHAR(100), target_info TEXT, -- 操作对象详情 ip_address INET, user_agent TEXT, operation_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP, success BOOLEAN NOT NULL, error_message TEXT ); ```

使用 Spring AOP 对所有档案操作进行环绕日志记录：

``` @Aspect @Component public class OperationLogAspect { @Autowired private OperationLogRepository logRepository; @Around("@annotation(com.example.ArchiveOperation)") public Object logOperation(ProceedingJoinPoint joinPoint) throws Throwable { OperationLog log = new OperationLog(); HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder .currentRequestAttributes()).getRequest(); log.setOperator(getCurrentUser(request)); log.setIpAddress(request.getRemoteAddr()); log.setUserAgent(request.getHeader("User-Agent")); try { Object result = joinPoint.proceed(); log.setSuccess(true); return result; } catch (Exception e) { log.setSuccess(false); log.setErrorMessage(e.getMessage()); throw e; } finally { logRepository.save(log); } } } ```

数据备份与恢复方案

自动化备份脚本

创建 /opt/backup/archive_backup.sh 脚本，并设置 crontab 每日凌晨2点执行：

``` !/bin/bash BACKUP_DIR="/opt/backup/data" DATE=$(date +%Y%m%d_%H%M%S) 1. 备份PostgreSQL数据库 pg_dump -h localhost -U admin telecom_archive | gzip > $BACKUP_DIR/telecom_archive_$DATE.sql.gz 2. 使用MinIO客户端mc备份存储桶（需提前配置mc alias） /usr/local/bin/mc mirror --overwrite /data/minio/telecom-archive $BACKUP_DIR/minio_backup_$DATE/ 3. 备份Elasticsearch索引（使用elasticdump） /usr/bin/npx elasticdump \ --input=http://localhost:9200/telecom_archive \ --output=$BACKUP_DIR/telecom_archive_es_$DATE.json \ --type=data 4. 删除7天前的备份 find $BACKUP_DIR -name ".gz" -mtime +7 -delete find $BACKUP_DIR -name "minio_backup_" -type d -mtime +7 -exec rm -rf {} \; find $BACKUP_DIR -name "_es_.json" -mtime +7 -delete ```

设置执行权限并添加定时任务：

``` chmod +x /opt/backup/archive_backup.sh crontab -e 添加以下行 0 2 /opt/backup/archive_backup.sh >> /var/log/archive_backup.log 2>&1 ```

按照以上步骤，你可以从零开始搭建一个功能完整、安全可控的电信部门电子档案系统。每个模块的代码和配置均可直接复制使用，并根据实际网络环境和业务规则调整连接参数与字段定义。