import assert from 'node:assert/strict'
import test from 'node:test'
import { readInitialization, tableDefinitions, table, seedRows, roleAuthorities } from '../sql-baseline-contract-helpers.mjs'

const cn = readInitialization()
const overseas = readInitialization('OVERSEAS')
const domesticSchemas = ['baiyue_auth', 'baiyue_iam', 'baiyue_order', 'baiyue_warehouse',
  'baiyue_firstleg', 'baiyue_file', 'baiyue_audit', 'baiyue_finance']
const overseasSchemas = ['baiyue_lastleg', 'baiyue_lastlag_warehouse']

test('两个入口分别只操作八个主业务库与两个仓储业务库，包括限定名引用', () => {
  for (const [sql, allowed, other, count] of [[cn, domesticSchemas, overseasSchemas, 226], [overseas, overseasSchemas, domesticSchemas, 159]]) {
    assert.deepEqual([...sql.matchAll(/^CREATE DATABASE IF NOT EXISTS (\w+)/gm)].map(m => m[1]), allowed)
    assert.deepEqual([...new Set([...sql.matchAll(/^USE (\w+);/gm)].map(m => m[1]))], allowed)
    const body = sql.replace(/^--.*$/gm, '')
    for (const schema of other) assert.doesNotMatch(body, new RegExp('\\b' + schema + '\\b'))
    assert.equal(tableDefinitions(sql).size, count)
    for (const key of tableDefinitions(sql).keys()) assert.ok(allowed.includes(key.split('.')[0]))
  }
})

test('转运收货命令锁定原来源和原请求，多来源可共享目标资源锁', () => {
  const command = table(overseas, 'baiyue_lastleg', 'll_warehouse_transfer_receipt_command')
  assert.match(command, /UNIQUE KEY uk_ll_wh_receipt_cmd_source\s*\(transfer_order_id,\s*source_inventory_position_id\)/i)
  assert.match(command, /UNIQUE KEY uk_ll_wh_receipt_cmd_key\s*\(customer_id,\s*idempotency_key\)/i)
  assert.match(command, /request_json JSON NOT NULL/i)
  assert.match(command, /target_json JSON NOT NULL/i)
  assert.match(command, /resource_lock_id BIGINT NULL/i)
  assert.match(command, /CHECK\s*\(status IN \('PREPARED','RESERVED','COMPLETED'\)\)/i)
  assert.doesNotMatch(command, /UNIQUE[^\n]*resource_lock_id/i)
})

test('纯初始化禁止迁移、数据回填、清理、重复建表和提前成功', () => {
  for (const sql of [cn, overseas]) {
    const body = sql.replace(/^--.*$/gm, '')
    assert.doesNotMatch(body, /\bALTER\s+TABLE|\bDROP\s+(?:DATABASE|TABLE)|\bTRUNCATE\b|\bRENAME\s+TABLE/i)
    assert.doesNotMatch(body, /\bCREATE\s+(?:TEMPORARY\s+TABLE|PROCEDURE)|\bPREPARE\b|\bEXECUTE\b|\bON DUPLICATE KEY UPDATE|\bINSERT IGNORE/i)
    // Runtime trigger bodies legitimately update the current loading aggregate.
    assert.doesNotMatch(body.replace(/^CREATE TRIGGER [\s\S]*?\$\$/gm, ''), /^\s*(?:UPDATE|DELETE FROM|REPLACE INTO)\b/gmi)
    assert.doesNotMatch(body, /CREATE TABLE IF NOT EXISTS/i)
    assert.equal((body.match(/AS initialization_status/g) ?? []).length, 1)
    assert.match(body.trim(), /SELECT 'PASS' AS initialization_status, '(CN|OVERSEAS)' AS region, (226|159) AS initialized_tables;$/)
  }
})

test('车次直接成本按车次幂等并保留独立币种与不可变更正历史', () => {
  const cost = table(overseas, 'baiyue_lastleg', 'll_fleet_trip_cost')
  const history = table(overseas, 'baiyue_lastleg', 'll_fleet_trip_cost_history')
  assert.match(cost, /UNIQUE KEY uk_fleet_trip_cost_request\(trip_id,created_by,request_key\)/i)
  assert.match(cost, /FOREIGN KEY\(trip_id\) REFERENCES ll_fleet_trip\(id\)/i)
  assert.match(cost, /CHECK\(amount>=0\)/i)
  assert.match(cost, /CHECK\(currency IN \('CNY','USD'\)\)/i)
  assert.match(history, /UNIQUE KEY uk_fleet_trip_cost_history\(cost_id,record_version\)/i)
  assert.match(history, /FOREIGN KEY\(cost_id\) REFERENCES ll_fleet_trip_cost\(id\)/i)
  assert.match(history, /snapshot_json JSON NOT NULL/i)
})

test('退回实收按真实流水唯一保存，重派拣货必须明确唯一来源', () => {
  const receipt = table(overseas, 'baiyue_lastleg', 'll_return_stock_receipt')
  assert.match(receipt, /UNIQUE KEY uk_return_stock_receipt_ledger\(customer_id,inventory_ledger_id\)/i)
  assert.match(receipt, /UNIQUE KEY uk_return_stock_receipt_no\(customer_id,receipt_no\)/i)
  assert.match(receipt, /CHECK\(received_packages>0\)/i)
  for (const name of ['ll_dispatch_item', 'll_dispatch_pallet_lock', 'll_dispatch_pda_pick_order']) {
    assert.match(table(overseas, 'baiyue_lastleg', name), /return_receipt_id BIGINT NULL/i)
  }
  const pick = table(overseas, 'baiyue_lastleg', 'll_dispatch_pda_pick_order')
  assert.match(pick, /\breceipt_id BIGINT NULL/i)
  assert.match(pick, /CHECK\(\(receipt_id IS NOT NULL\) \+ \(return_receipt_id IS NOT NULL\) \+ \(return_carton_id IS NOT NULL\) = 1\)/i)
})

test('车辆报价与实测记录保留业务去重和不可变版本', () => {
  const booking = table(overseas, 'baiyue_lastleg', 'll_fleet_external_booking')
  assert.match(booking, /quote_source_json JSON NULL/i)
  assert.match(booking, /agreed_amount DECIMAL\(16,2\) NULL/i)
  const quote = table(overseas, 'baiyue_lastleg', 'll_fleet_quote')
  assert.match(quote, /UNIQUE KEY uk_fleet_quote_no \(quote_no\)/i)
  assert.match(quote, /UNIQUE KEY uk_fleet_quote_natural \(natural_key\)/i)
  assert.match(quote, /UNIQUE KEY uk_fleet_quote_create \(created_by,create_key\)/i)
  assert.match(table(overseas, 'baiyue_lastleg', 'll_fleet_quote_history'), /UNIQUE KEY uk_fleet_quote_history_version \(quote_id,record_version\)/i)
  const measured = table(overseas, 'baiyue_lastleg', 'll_fleet_trip_operations_record')
  assert.match(measured, /UNIQUE KEY uk_fleet_operations_version \(trip_no,record_version\)/i)
  assert.match(measured, /UNIQUE KEY uk_fleet_operations_request \(trip_no,operator_id,request_key\)/i)
})

test('公司车辆费用隔离于客户账务并约束实际付款金额', () => {
  const cost = table(cn, 'baiyue_finance', 'fin_vehicle_cost')
  assert.doesNotMatch(cost, /\b(customer_id|tenant_id)\b/i)
  assert.match(cost, /subject_id BIGINT UNSIGNED NOT NULL/i)
  assert.match(cost, /UNIQUE KEY uk_fin_vehicle_cost_source \(subject_id,source_type,source_no\)/i)
  assert.match(cost, /CHECK \(amount>0 AND paid_amount>=0 AND paid_amount<=amount\)/i)
  assert.match(table(cn, 'baiyue_finance', 'fin_vehicle_cost_payment'), /FOREIGN KEY \(cost_id\) REFERENCES fin_vehicle_cost\(id\)/i)
  assert.match(table(cn, 'baiyue_finance', 'fin_vehicle_cost_revision'), /UNIQUE KEY uk_fin_vehicle_cost_request \(operator_id,action,request_key\)/i)
  const admin = roleAuthorities(cn, 'PLATFORM_ADMIN'), merchant = roleAuthorities(cn, 'MERCHANT_OWNER')
  for (const action of ['list', 'approve', 'void', 'pay', 'upload']) {
    assert.ok(admin.has(`platform:finance:vehicle-cost:${action}`))
    assert.ok(!merchant.has(`platform:finance:vehicle-cost:${action}`))
  }
})

test('退货出库不可变流水限制重复扣减并保存数量守恒快照', () => {
  const journal = table(overseas, 'baiyue_lastleg', 'll_return_inventory_outbound_movement')
  assert.match(journal, /UNIQUE KEY uk_ll_return_outbound_pick_sku\(outbound_pick_id,sku_code\)/i)
  assert.match(journal, /UNIQUE KEY uk_ll_return_outbound_carton_sku\(customer_id,carton_id,sku_code\)/i)
  assert.match(journal, /CHECK\(quantity>0 AND total_after>=0 AND available_after>=0/i)
  assert.match(journal, /total_before-total_after=quantity AND available_before-available_after=quantity/i)
  assert.match(journal, /cartons_before-cartons_after=1 AND total_after>=available_after/i)
})

test('平台管理员由外部bcrypt引导，强制首登改密且不创建客户', () => {
  const accounts = seedRows(cn, 'auth_account')
  assert.equal(accounts.length, 1)
  assert.equal(accounts[0].username, 'platform_admin')
  assert.equal(accounts[0].password_change_required, '1')
  assert.match(accounts[0].password_hash, /@platform_admin_password_hash/)
  assert.match(accounts[0].password_hash, /REGEXP/)
  assert.match(accounts[0].password_hash, /, NULL\)$/)
  assert.doesNotMatch(cn, /'\$2[aby]\$[0-9]{2}\$[./A-Za-z0-9]{53}'/)
  assert.deepEqual(seedRows(cn, 'iam_tenant').map(r => r.id), ['0'])
  assert.deepEqual(seedRows(cn, 'iam_user').map(r => r.auth_user_id), ['1000001'])
  assert.doesNotMatch(cn, /'merchant_admin'|'IT_TEST'|'EXP-TEST'|'CAR-001'|'TP-001'|'YW-TP-002'/)
})

test('必要系统种子完整保留，但不写入示例资源与业务事实', () => {
  for (const [name, count] of Object.entries({ iam_role: 8, iam_permission: 419, iam_role_permission: 600,
    iam_data_scope: 7, wh_warehouse: 318, wh_warehouse_address: 318, wh_service_capability: 4,
    fl_fee_item: 112, fl_price_channel_catalog: 15, fl_price_origin_alias: 7, fl_price_warehouse_mapping: 4,
    file_export_task_guard: 1, fin_subject: 1 })) assert.equal(seedRows(cn, name).length, count, name)
  for (const name of ['wh_pallet', 'wh_location', 'wh_partner', 'wh_partner_type', 'wh_express_company',
    'ord_order', 'fl_inbound_order', 'fin_fee_source']) assert.equal(seedRows(cn, name).length, 0, name)
  assert.deepEqual([...new Set([...overseas.matchAll(/^INSERT INTO (\w+)/gm)].map(m => m[1]))], [])
  assert.ok(seedRows(cn, 'wh_warehouse').every(r => r.tenant_id === '0'))
  assert.ok(seedRows(cn, 'wh_service_capability').every(r => r.service_type === 'RECEIVING' || r.capability_code === 'RECEIVING' || Object.values(r).includes('RECEIVING')))
})

test('国内IAM权限与角色授权没有丢失或悬挂，客户模板仍完整', () => {
  const roles = seedRows(cn, 'iam_role'), permissions = seedRows(cn, 'iam_permission')
  const roleIds = new Set(roles.map(r => r.id)), permissionIds = new Set(permissions.map(r => r.id))
  assert.equal(new Set(permissions.map(r => r.permission_code)).size, permissions.length)
  for (const row of seedRows(cn, 'iam_role_permission')) {
    assert.ok(roleIds.has(row.role_id), 'missing role ' + row.role_id)
    assert.ok(permissionIds.has(row.permission_id), 'missing permission ' + row.permission_id)
  }
  for (const row of permissions) if (row.parent_id && row.parent_id !== '0') assert.ok(permissionIds.has(row.parent_id), 'missing parent ' + row.parent_id)
  const merchant = roleAuthorities(cn, 'MERCHANT_OWNER')
  for (const code of ['merchant:enterprise', 'merchant:order:quick-create', 'merchant:finance:statement',
    'merchant:warehouse:delivery:list', 'merchant:warehouse:delivery:create']) assert.ok(merchant.has(code), code)
  const admin = roleAuthorities(cn, 'PLATFORM_ADMIN')
  assert.ok(admin.has('platform:overseas-warehouse:discard:approve'), 'discard review endpoint must be grantable to platform administrator')
  for (const action of ['list', 'create', 'edit', 'status', 'review', 'upload']) {
    assert.ok(admin.has(`platform:overseas-master-data:driver:${action}`))
  }
  for (const action of ['list', 'create', 'edit', 'assign', 'cancel', 'cost-create', 'cost-edit']) {
    assert.ok(admin.has(`platform:fleet:trip:${action}`))
  }
  for (const action of ['list', 'create', 'edit', 'status', 'delete', 'import', 'export']) {
    assert.ok(admin.has(`platform:fleet:quote:${action}`))
    assert.ok(!merchant.has(`platform:fleet:quote:${action}`))
  }
  for (const action of ['list', 'export', 'edit']) {
    assert.ok(admin.has(`platform:fleet:operations:${action}`))
    assert.ok(!merchant.has(`platform:fleet:operations:${action}`))
  }
  assert.ok(!permissions.some(row => row.permission_code === 'platform:order:complete'),
    '订单完成必须由可信履约回写产生，不能恢复人工完成权限')
  for (const code of ['platform:order:declaration:edit', 'platform:firstleg:inbound:hold',
    'platform:overseas-warehouse:last-mile-order:list', 'platform:overseas-business:purchase:list',
    'platform:overseas-master-data:quote:list', 'platform:finance:fee-source:review',
    'platform:mojia-sku-sync:list', 'platform:mojia-sku-sync:edit',
    'platform:mojia-sku-sync:retry']) assert.ok(admin.has(code), code)
  const operator = roleAuthorities(cn, 'ORDER_OPERATOR')
  for (const code of ['platform:mojia-sku-sync:list', 'platform:mojia-sku-sync:edit',
    'platform:mojia-sku-sync:retry']) assert.ok(operator.has(code), code)
})

test('近期头程与海外结构完整进入各自统一初始化入口', () => {
  const membership = table(cn, 'baiyue_iam', 'iam_membership')
  assert.match(membership, /domestic_warehouse_id bigint DEFAULT NULL/i)
  assert.match(membership, /idx_membership_domestic_warehouse \(tenant_id,domestic_warehouse_id,status\)/i)

  const receipt = table(cn, 'baiyue_firstleg', 'fl_mojia_measurement_receipt')
  for (const field of ['measurement_kind', 'weight_kg', 'sync_status', 'sync_failure_code',
    'sync_failure_reason', 'lingxing_sku_id', 'revision']) assert.match(receipt, new RegExp(`\\b${field}\\b`, 'i'))
  assert.match(receipt, /weight_kg decimal\(18,3\) DEFAULT NULL/i)

  const relabel = table(overseas, 'baiyue_lastleg', 'll_relabel_application')
  assert.match(relabel, /KEY idx_ll_relabel_application_order \(lastleg_order_id\)/i)
  assert.doesNotMatch(relabel, /UNIQUE KEY uk_ll_relabel_application_order/i)
  assert.match(table(overseas, 'baiyue_lastlag_warehouse', 'wh_location'),
    /shared_overflow tinyint\(1\) NOT NULL DEFAULT '?0'?/i)
})

test('统一认证保留持久版本，不再初始化安全投影或桥接发件箱', () => {
  for (const retired of ['iam_security_event_outbox', 'll_security_event_inbox', 'll_security_projection']) {
    assert.doesNotMatch(cn + overseas, new RegExp('CREATE TABLE ' + retired + '\\b'))
  }
  assert.ok(table(cn, 'baiyue_iam', 'iam_security_subject_version'))
  assert.ok(table(cn, 'baiyue_iam', 'iam_security_tenant_version'))
  assert.equal(seedRows(overseas, 'll_security_projection').length, 0)
})

test('跨区域放错位置的最终字段归正确区域且保留财务精度', () => {
  const fee = table(overseas, 'baiyue_lastleg', 'll_finance_fee_source')
  for (const name of ['original_currency', 'original_amount', 'exchange_rate', 'exchange_rate_month',
    'chargeable_quantity', 'quantity_unit', 'unit_price', 'period_start', 'period_end']) assert.match(fee, new RegExp('\\b' + name + '\\b'))
  assert.match(fee, /original_amount decimal\(20,6\)/i)
  assert.match(fee, /exchange_rate decimal\(20,6\)/i)
  const returns = table(overseas, 'baiyue_lastleg', 'll_return_order')
  assert.match(returns, /lastleg_order_id bigint/i)
  assert.match(returns, /lastleg_order_no varchar\(32\)/i)
  assert.match(table(cn, 'baiyue_finance', 'fin_fee_source'), /idx_fin_fee_source_wallet_hold \(wallet_hold_id\)/)
})

test('最终业务触发器与循环外键均存在，不留下发布过程', () => {
  assert.equal((cn.match(/^CREATE TRIGGER /gm) ?? []).length, 64)
  assert.doesNotMatch(cn, /CREATE DEFINER=/)
  for (const name of ['trg_container_booking_before_update', 'trg_loading_pick_task_before_update',
    'trg_order_fulfillment_split_insert', 'trg_inbound_split_item_before_delete']) assert.match(cn, new RegExp('CREATE TRIGGER ' + name + '\\b'))
  assert.match(table(cn, 'baiyue_firstleg', 'fl_inbound_measurement_item'), /REFERENCES fl_inbound_split_item/)
  assert.match(table(cn, 'baiyue_firstleg', 'fl_inbound_split_item'), /REFERENCES fl_inbound_measurement_item/)
  const disable = cn.indexOf('SET SESSION foreign_key_checks = 0;')
  const enable = cn.indexOf('SET SESSION foreign_key_checks = 1;')
  assert.ok(disable >= 0 && enable > disable)
  assert.ok(!cn.slice(disable, enable).includes('INSERT INTO'))
})


test('退货合箱最终字段直接进入空库建表定义', () => {
  for (const [name, fields] of Object.entries({
    ll_return_packing_plan: ['source_items_json', 'result_marks_json', 'result_labels_json', 'request_hash', 'completion_hash'],
    ll_return_packing_trace: ['source_carton_mark', 'target_carton_mark', 'return_no', 'sku_code'],
    ll_return_inventory_carton_item: ['packing_reserved_quantity'],
    ll_return_inventory_operation: ['result_json'],
    ll_dispatch_pda_pick: ['return_carton_id'],
    ll_dispatch_pda_pick_order: ['return_carton_id', 'return_receipt_id']
  })) {
    const definition = table(overseas, 'baiyue_lastleg', name)
    for (const field of fields) assert.ok(definition.includes(field), name + '.' + field)
  }
})

test('退货预占状态符合空库数量和状态约束', () => {
  const carton = table(overseas, 'baiyue_lastleg', 'll_return_inventory_carton')
  for (const name of ['chk_ll_return_inventory_carton_quantity', 'chk_ll_return_inventory_carton_status']) {
    const constraint = carton.split('CONSTRAINT ' + name)[1].split('\n')[0]
    for (const status of ['PACKING_RESERVED', 'OUTBOUND_PENDING']) assert.ok(constraint.includes(status), name + ':' + status)
  }
})