应急管理部门数字档案馆系统从零构建与落地实操指南
一、系统架构与技术选型
针对应急管理部门对数据安全性、检索效率及海量非结构化文件存储的高要求，本方案采用前后端分离架构。后端基于Spring Boot 2.7，数据存储采用MySQL 8.0（元数据）+ MinIO（文件对象存储）+ Elasticsearch 7.17（全文检索）。前端使用Vue 3 + Element Plus。此架构轻量且易于私有化部署，完全满足信创环境适配需求。
二、基础环境快速搭建
为了确保零门槛启动，我们使用 Docker Compose 编排 MySQL、MinIO 和 Elasticsearch。请在服务器新建目录 archive-system，并在其中创建 docker-compose.yml 文件，直接复制以下内容：
```yaml version: '3.8' services: mysql: image: mysql:8.0 container_name: archive_mysql environment: MYSQL_ROOT_PASSWORD: root@123456 MYSQL_DATABASE: emergency_archive ports: - "3306:3306" volumes: - mysql_data:/var/lib/mysql minio: image: minio/minio:latest container_name: archive_minio environment: MINIO_ROOT_USER: admin MINIO_ROOT_PASSWORD: admin@123456 command: server /data --console-address ":9001" ports: - "9000:9000" - "9001:9001" volumes: - minio_data:/data elasticsearch: image: elasticsearch:7.17.0 container_name: archive_es environment: discovery.type: single-node ES_JAVA_OPTS: "-Xms512m -Xmx512m" ports: - "9200:9200" volumes: - es_data:/usr/share/elasticsearch/data volumes: mysql_data: minio_data: es_data: ```执行启动命令：
docker-compose up -d
启动后，需手动在 MinIO 控制台（http://服务器IP:9001）创建一个名为 emergency-docs 的 Bucket，并设置访问权限为 Public。
三、核心数据库设计
在 MySQL 中执行以下 SQL，建立档案主表。该表包含应急档案特有的属性，如事件类型、密级和关联事件ID。
```sql CREATE DATABASE IF NOT EXISTS emergency_archive CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci; USE emergency_archive; CREATE TABLE `archive_record` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键ID', `archive_no` varchar(64) NOT NULL COMMENT '档案编号，唯一标识', `title` varchar(255) NOT NULL COMMENT '档案标题', `event_type` varchar(50) DEFAULT NULL COMMENT '应急事件类型：地震,火灾,防汛等', `security_level` tinyint(1) DEFAULT '1' COMMENT '密级：1-公开，2-内部，3-机密', `file_path` varchar(500) DEFAULT NULL COMMENT 'MinIO存储路径', `file_name` varchar(255) DEFAULT NULL COMMENT '原始文件名', `file_size` bigint(20) DEFAULT NULL COMMENT '文件大小(字节)', `operator` varchar(50) DEFAULT NULL COMMENT '操作人', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '归档时间', PRIMARY KEY (`id`), UNIQUE KEY `uk_archive_no` (`archive_no`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='应急档案主表'; ```四、后端项目核心代码实现
创建 Spring Boot 项目，pom.xml 中必须引入以下依赖（版本号请根据 Spring Boot 版本自行匹配，这里给出核心坐标）：
```xml1. 配置文件 application.yml
将以下配置填入，替换其中的 IP 地址：
```yaml server: port: 8080 spring: datasource: url: jdbc:mysql://localhost:3306/emergency_archive?useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai username: root password: root@123456 servlet: multipart: max-file-size: 500MB max-request-size: 500MB MinIO 配置 minio: endpoint: http://localhost:9000 accessKey: admin secretKey: admin@123456 bucketName: emergency-docs Elasticsearch 配置 elasticsearch: rest: uris: http://localhost:9200 ```2. MinIO 工具类封装
创建 MinioConfig.java 和 MinioUtil.java，用于处理文件上传下载。这是文件落地的关键。
```java @Configuration @Data @Component @ConfigurationProperties(prefix = "minio") public class MinioConfig { private String endpoint; private String accessKey; private String secretKey; private String bucketName; @Bean public MinioClient minioClient() { return MinioClient.builder() .endpoint(endpoint) .credentials(accessKey, secretKey) .build(); } } ``` ```java @Component @Slf4j public class MinioUtil { @Autowired private MinioClient minioClient; @Autowired private MinioConfig minioConfig; public String uploadFile(MultipartFile file, String objectName) throws Exception { InputStream inputStream = file.getInputStream(); minioClient.putObject( PutObjectArgs.builder() .bucket(minioConfig.getBucketName()) .object(objectName) .stream(inputStream, file.getSize(), -1) .contentType(file.getContentType()) .build()); return minioConfig.getEndpoint() + "/" + minioConfig.getBucketName() + "/" + objectName; } } ```3. PDF 安全水印实现
应急档案对安全性要求极高，必须自动添加“应急内部资料”水印。创建 WatermarkService.java：
```java @Service public class WatermarkService { public InputStream addWatermark(MultipartFile file) throws IOException { PDDocument document = PDDocument.load(file.getInputStream()); // 加载字体，防止中文乱码（需确保服务器有中文字体或引入字体文件） // 这里简化处理，使用系统默认字体，生产环境建议加载自定义字体 ttf PDFont font = PDType1Font.HELVETICA_BOLD; for (PDPage page : document.getPages()) { PDPageContentStream contentStream = new PDPageContentStream( document, page, PDPageContentStream.AppendMode.APPEND, true, true); contentStream.setFont(font, 18); contentStream.setNonStrokingColor(200, 200, 200); // 浅灰色 // 获取页面尺寸 float width = page.getMediaBox().getWidth(); float height = page.getMediaBox().getHeight(); // 旋转文字30度 contentStream.beginText(); contentStream.setTextMatrix(Math.cos(0.5), Math.sin(0.5), -Math.sin(0.5), Math.cos(0.5), width/2, height/2); contentStream.showText("EMERGENCY INTERNAL USE - 应急内部资料"); contentStream.endText(); contentStream.close(); } ByteArrayOutputStream outputStream = new ByteArrayOutputStream(); document.save(outputStream); document.close(); return new ByteArrayInputStream(outputStream.toByteArray()); } } ```4. 档案归档核心业务逻辑
创建 ArchiveService.java，整合数据库存储、文件上传、水印处理和ES索引。
```java @Service public class ArchiveService { @Autowired private ArchiveMapper archiveMapper; @Autowired private MinioUtil minioUtil; @Autowired private WatermarkService watermarkService; @Autowired private ElasticsearchRestTemplate esTemplate; @Transactional(rollbackFor = Exception.class) public void archive(MultipartFile file, String title, String eventType, String operator) throws Exception { // 1. 生成唯一档案编号 String archiveNo = "ARC-" + System.currentTimeMillis(); // 2. PDF添加水印并转换流 InputStream watermarkedStream = watermarkService.addWatermark(file); // 3. 构造MinIO文件名 String originalFilename = file.getOriginalFilename(); String extension = originalFilename.substring(originalFilename.lastIndexOf(".")); String objectName = "archive/" + archiveNo + extension; // 4. 上传到MinIO (这里需要重写MinioUtil支持InputStream上传，或此处转MultipartFile，为简化代码逻辑，假设MinioUtil已重载支持InputStream) // 实际操作中，建议将InputStream转为临时MultipartFile或直接用MinioClient API上传Stream // 下面演示直接使用MinioClient上传Stream的片段逻辑： // minioClient.putObject(..., watermarkedStream, ...); // 5. 数据库入库 ArchiveRecord record = new ArchiveRecord(); record.setArchiveNo(archiveNo); record.setTitle(title); record.setEventType(eventType); record.setFileName(originalFilename); record.setFilePath(objectName); // 存储相对路径 record.setFileSize(file.getSize()); record.setOperator(operator); archiveMapper.insert(record); // 6. 写入Elasticsearch索引 ArchiveDoc esDoc = new ArchiveDoc(); esDoc.setId(record.getId().toString()); esDoc.setTitle(title); esDoc.setContent("此处应调用OCR提取文本内容，简化示例仅存标题"); // 实际项目需集成Tesseract esDoc.setEventType(eventType); esDoc.setCreateTime(new Date()); esTemplate.save(esDoc); } } ```五、全文检索实现
定义 ES 实体类 ArchiveDoc.java，用于映射索引结构：
```java @Document(indexName = "emergency_archive") @Data public class ArchiveDoc { @Id private String id; @Field(type = FieldType.Text, analyzer = "ik_max_word") private String title; @Field(type = FieldType.Text, analyzer = "ik_max_word") private String content; @Field(type = FieldType.Keyword) private String eventType; @Field(type = FieldType.Date) private Date createTime; } ``>编写查询接口，使用 NativeSearchQuery 构建复杂查询：
```java public List六、前端上传组件实现
在 Vue 3 项目中，使用 Element Plus 的 el-upload 组件实现拖拽上传。关键在于 http-request 覆盖默认上传行为，调用我们的后端接口。
```vue
拖拽应急档案文件到此处或 点击上传
七、系统部署与验证
后端打包为 JAR 包，前端打包为 Dist 静态文件。
1. 后端启动：
java -jar emergency-archive.jar
2. 前端部署：
将 Dist 目录内容配置至 Nginx：
访问 Nginx 配置的域名，拖入一份 PDF 测试文件。系统将自动完成：接收请求 -> 添加“应急内部资料”水印 -> 上传至 MinIO -> 记录 MySQL -> 写入 ES 索引。随后在搜索框输入关键词，即可验证毫秒级检索结果。至此，一套符合应急管理部门标准的数字档案馆系统核心功能已落地。
相关文章
