From f38ddded9d89383e848147305e3ffd7f89d1f910 Mon Sep 17 00:00:00 2001
From: zhang1106 <849185023@qq.com>
Date: Tue, 24 Feb 2026 13:30:15 +0800
Subject: [PATCH] =?UTF-8?q?feat(=E6=95=B0=E6=8D=AE=E5=BA=93):=20=E6=B7=BB?=
 =?UTF-8?q?=E5=8A=A0MySQL=E6=95=B0=E6=8D=AE=E5=BA=93=E4=BF=AE=E5=A4=8D?=
 =?UTF-8?q?=E8=84=9A=E6=9C=AC=E7=94=A8=E4=BA=8E=E8=A1=A5=E5=85=A8=E5=AD=97?=
 =?UTF-8?q?=E6=AE=B5=E5=92=8C=E5=88=9B=E5=BB=BA=E5=BD=92=E6=A1=A3=E8=A1=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 backend/scripts/fix-mysql-migration.js | 126 +++++++++++++++++++++++++
 1 file changed, 126 insertions(+)
 create mode 100644 backend/scripts/fix-mysql-migration.js

diff --git a/backend/scripts/fix-mysql-migration.js b/backend/scripts/fix-mysql-migration.js
new file mode 100644
index 0000000..cd45a02
--- /dev/null
+++ b/backend/scripts/fix-mysql-migration.js
@@ -0,0 +1,126 @@
+/**
+ * MySQL 数据库字段修复脚本
+ * 添加缺失的 isConsumableDeleted 字段和 consumableSnapshot 字段
+ */
+
+const { sequelize, DB_TYPE } = require('../db');
+
+async function fix() {
+  try {
+    console.log('开始修复 MySQL 数据库字段...');
+
+    if (DB_TYPE !== 'mysql') {
+      console.log('当前不是 MySQL 数据库，跳过修复');
+      process.exit(0);
+    }
+
+    // 检查字段是否存在
+    const [columns] = await sequelize.query(
+      `SHOW COLUMNS FROM consumable_logs LIKE 'isConsumableDeleted'`
+    );
+
+    if (columns.length === 0) {
+      console.log('添加 isConsumableDeleted 字段...');
+      await sequelize.query(`
+        ALTER TABLE consumable_logs
+        ADD COLUMN isConsumableDeleted BOOLEAN DEFAULT FALSE COMMENT '关联耗材是否已被删除'
+      `);
+      console.log('✓ 添加成功');
+    } else {
+      console.log('✓ isConsumableDeleted 字段已存在');
+    }
+
+    // 检查 consumableSnapshot 字段
+    const [snapshotColumns] = await sequelize.query(
+      `SHOW COLUMNS FROM consumable_logs LIKE 'consumableSnapshot'`
+    );
+
+    if (snapshotColumns.length === 0) {
+      console.log('添加 consumableSnapshot 字段...');
+      await sequelize.query(`
+        ALTER TABLE consumable_logs
+        ADD COLUMN consumableSnapshot JSON DEFAULT NULL COMMENT '耗材快照信息'
+      `);
+      console.log('✓ 添加成功');
+    } else {
+      console.log('✓ consumableSnapshot 字段已存在');
+    }
+
+    // 检查 relatedId 字段
+    const [relatedColumns] = await sequelize.query(
+      `SHOW COLUMNS FROM consumable_logs LIKE 'relatedId'`
+    );
+
+    if (relatedColumns.length === 0) {
+      console.log('添加 relatedId 字段...');
+      await sequelize.query(`
+        ALTER TABLE consumable_logs
+        ADD COLUMN relatedId VARCHAR(255) DEFAULT NULL COMMENT '关联归档ID'
+      `);
+      console.log('✓ 添加成功');
+    } else {
+      console.log('✓ relatedId 字段已存在');
+    }
+
+    // 检查索引是否存在
+    const [indexes] = await sequelize.query(
+      `SHOW INDEX FROM consumable_logs WHERE Key_name = 'consumable_logs_is_consumable_deleted'`
+    );
+
+    if (indexes.length === 0) {
+      console.log('添加索引...');
+      await sequelize.query(`
+        ALTER TABLE consumable_logs
+        ADD INDEX consumable_logs_is_consumable_deleted (isConsumableDeleted)
+      `);
+      console.log('✓ 索引添加成功');
+    } else {
+      console.log('✓ 索引已存在');
+    }
+
+    // 创建归档表
+    console.log('\n检查归档表...');
+    const [archiveTables] = await sequelize.query(
+      `SHOW TABLES LIKE 'consumable_log_archives'`
+    );
+
+    if (archiveTables.length === 0) {
+      console.log('创建归档表...');
+      await sequelize.query(`
+        CREATE TABLE consumable_log_archives (
+          id INTEGER PRIMARY KEY AUTO_INCREMENT,
+          archiveId VARCHAR(255) NOT NULL UNIQUE COMMENT '归档记录唯一标识',
+          consumableId VARCHAR(255) NOT NULL COMMENT '被删除的耗材ID',
+          consumableName VARCHAR(255) NOT NULL COMMENT '耗材名称',
+          consumableSnapshot JSON DEFAULT NULL COMMENT '耗材快照信息',
+          totalOperations INTEGER DEFAULT 0 COMMENT '操作记录总数',
+          firstOperationAt DATETIME COMMENT '首次操作时间',
+          lastOperationAt DATETIME COMMENT '最后操作时间',
+          totalInQuantity INTEGER DEFAULT 0 COMMENT '总入库数量',
+          totalOutQuantity INTEGER DEFAULT 0 COMMENT '总出库数量',
+          finalStock INTEGER DEFAULT 0 COMMENT '删除时库存',
+          deletedBy VARCHAR(255) COMMENT '删除人',
+          deletedAt DATETIME COMMENT '删除时间',
+          deleteReason VARCHAR(255) COMMENT '删除原因',
+          createdAt DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+          updatedAt DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+          INDEX idx_consumable_id (consumableId),
+          INDEX idx_archive_id (archiveId),
+          INDEX idx_deleted_at (deletedAt),
+          INDEX idx_consumable_deleted (consumableId, deletedAt)
+        ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='耗材操作日志归档表'
+      `);
+      console.log('✓ 归档表创建成功');
+    } else {
+      console.log('✓ 归档表已存在');
+    }
+
+    console.log('\n数据库修复完成！');
+    process.exit(0);
+  } catch (error) {
+    console.error('修复失败:', error);
+    process.exit(1);
+  }
+}
+
+fix();