数据库迁移:新增金额分字段并迁移历史数据
- 为所有金额字段新增对应的 _cent 字段(BIGINT) - 涉及表:users, rental_listings, rental_orders, order_checkouts, wallet_accounts, wallet_ledger, withdrawal_requests - 自动迁移历史数据:DECIMAL(12,2) * 100 -> BIGINT - 使用 goose 格式,支持 Up/Down 迁移 - 目标:全链路使用整数分存储,避免浮点精度问题 Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
This commit is contained in:
@@ -0,0 +1,160 @@
|
|||||||
|
-- +goose Up
|
||||||
|
-- +goose StatementBegin
|
||||||
|
-- ============================================
|
||||||
|
-- 金额统一重构:新增分字段(BIGINT)
|
||||||
|
-- 目标:所有金额存储使用整数分,避免浮点精度问题
|
||||||
|
-- 展示:统一到角精度(0.1元)
|
||||||
|
-- ============================================
|
||||||
|
|
||||||
|
-- 用户表:免押额度
|
||||||
|
ALTER TABLE users
|
||||||
|
ADD COLUMN deposit_free_quota_cent BIGINT NOT NULL DEFAULT 0 COMMENT '免押总额度(分)' AFTER deposit_free_quota;
|
||||||
|
|
||||||
|
-- 商品表:价格和押金
|
||||||
|
ALTER TABLE rental_listings
|
||||||
|
ADD COLUMN price_cent BIGINT NOT NULL DEFAULT 0 COMMENT '租金(分/小时)' AFTER price,
|
||||||
|
ADD COLUMN deposit_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '押金金额(分)' AFTER deposit_amount;
|
||||||
|
|
||||||
|
-- 订单表:租金、押金、平台费
|
||||||
|
ALTER TABLE rental_orders
|
||||||
|
ADD COLUMN rent_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '租金总额(分)' AFTER rent_amount,
|
||||||
|
ADD COLUMN owner_rent_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '号主实得租金(分)' AFTER owner_rent_amount,
|
||||||
|
ADD COLUMN deposit_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '实际收取押金(分)' AFTER deposit_amount,
|
||||||
|
ADD COLUMN deposit_original_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '商品原始押金(分)' AFTER deposit_original_amount,
|
||||||
|
ADD COLUMN deposit_waived_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '免押抵扣金额(分)' AFTER deposit_waived_amount,
|
||||||
|
ADD COLUMN platform_fee_cent BIGINT NOT NULL DEFAULT 0 COMMENT '平台手续费(分)' AFTER platform_fee;
|
||||||
|
|
||||||
|
-- 结算记录表:所有金额字段
|
||||||
|
ALTER TABLE order_checkouts
|
||||||
|
ADD COLUMN rent_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '租金(分)' AFTER rent_amount,
|
||||||
|
ADD COLUMN owner_rent_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '号主实得租金(分)' AFTER owner_rent_amount,
|
||||||
|
ADD COLUMN platform_fee_cent BIGINT NOT NULL DEFAULT 0 COMMENT '平台手续费(分)' AFTER platform_fee,
|
||||||
|
ADD COLUMN deposit_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '押金(分)' AFTER deposit_amount,
|
||||||
|
ADD COLUMN consumable_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '消耗品扣费(分)' AFTER consumable_amount,
|
||||||
|
ADD COLUMN other_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '其他费用(分)' AFTER other_amount,
|
||||||
|
ADD COLUMN deposit_deduct_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '押金扣除金额(分)' AFTER deposit_deduct_amount,
|
||||||
|
ADD COLUMN renter_refund_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '租客退款金额(分)' AFTER renter_refund_amount,
|
||||||
|
ADD COLUMN owner_income_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '号主收入金额(分)' AFTER owner_income_amount;
|
||||||
|
|
||||||
|
-- 钱包账户表:余额
|
||||||
|
ALTER TABLE wallet_accounts
|
||||||
|
ADD COLUMN available_balance_cent BIGINT NOT NULL DEFAULT 0 COMMENT '可用余额(分)' AFTER available_balance,
|
||||||
|
ADD COLUMN frozen_balance_cent BIGINT NOT NULL DEFAULT 0 COMMENT '冻结余额(分)' AFTER frozen_balance;
|
||||||
|
|
||||||
|
-- 钱包流水表:金额和余额
|
||||||
|
ALTER TABLE wallet_ledger
|
||||||
|
ADD COLUMN amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '金额(分)' AFTER amount,
|
||||||
|
ADD COLUMN balance_after_cent BIGINT NOT NULL DEFAULT 0 COMMENT '变动后余额(分)' AFTER balance_after;
|
||||||
|
|
||||||
|
-- 提现表:如果存在的话
|
||||||
|
ALTER TABLE withdrawal_requests
|
||||||
|
ADD COLUMN amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '提现金额(分)' AFTER amount,
|
||||||
|
ADD COLUMN fee_cent BIGINT NOT NULL DEFAULT 0 COMMENT '手续费(分)' AFTER fee,
|
||||||
|
ADD COLUMN actual_amount_cent BIGINT NOT NULL DEFAULT 0 COMMENT '实际到账(分)' AFTER actual_amount;
|
||||||
|
|
||||||
|
-- ============================================
|
||||||
|
-- 数据迁移:从 DECIMAL 复制到 BIGINT(分)
|
||||||
|
-- 注意:ROUND(value * 100) 确保精度
|
||||||
|
-- ============================================
|
||||||
|
|
||||||
|
-- 用户免押额度
|
||||||
|
UPDATE users SET deposit_free_quota_cent = ROUND(deposit_free_quota * 100) WHERE deposit_free_quota > 0;
|
||||||
|
|
||||||
|
-- 商品价格和押金
|
||||||
|
UPDATE rental_listings SET
|
||||||
|
price_cent = ROUND(price * 100),
|
||||||
|
deposit_amount_cent = ROUND(deposit_amount * 100)
|
||||||
|
WHERE price > 0 OR deposit_amount > 0;
|
||||||
|
|
||||||
|
-- 订单金额
|
||||||
|
UPDATE rental_orders SET
|
||||||
|
rent_amount_cent = ROUND(rent_amount * 100),
|
||||||
|
owner_rent_amount_cent = ROUND(owner_rent_amount * 100),
|
||||||
|
deposit_amount_cent = ROUND(deposit_amount * 100),
|
||||||
|
deposit_original_amount_cent = ROUND(deposit_original_amount * 100),
|
||||||
|
deposit_waived_amount_cent = ROUND(deposit_waived_amount * 100),
|
||||||
|
platform_fee_cent = ROUND(platform_fee * 100)
|
||||||
|
WHERE rent_amount > 0 OR owner_rent_amount > 0 OR deposit_amount > 0
|
||||||
|
OR deposit_original_amount > 0 OR deposit_waived_amount > 0 OR platform_fee > 0;
|
||||||
|
|
||||||
|
-- 结算记录
|
||||||
|
UPDATE order_checkouts SET
|
||||||
|
rent_amount_cent = ROUND(rent_amount * 100),
|
||||||
|
owner_rent_amount_cent = ROUND(owner_rent_amount * 100),
|
||||||
|
platform_fee_cent = ROUND(platform_fee * 100),
|
||||||
|
deposit_amount_cent = ROUND(deposit_amount * 100),
|
||||||
|
consumable_amount_cent = ROUND(consumable_amount * 100),
|
||||||
|
other_amount_cent = ROUND(other_amount * 100),
|
||||||
|
deposit_deduct_amount_cent = ROUND(deposit_deduct_amount * 100),
|
||||||
|
renter_refund_amount_cent = ROUND(renter_refund_amount * 100),
|
||||||
|
owner_income_amount_cent = ROUND(owner_income_amount * 100)
|
||||||
|
WHERE rent_amount > 0 OR owner_rent_amount > 0 OR platform_fee > 0
|
||||||
|
OR deposit_amount > 0 OR consumable_amount > 0 OR other_amount > 0
|
||||||
|
OR deposit_deduct_amount > 0 OR renter_refund_amount > 0 OR owner_income_amount > 0;
|
||||||
|
|
||||||
|
-- 钱包余额
|
||||||
|
UPDATE wallet_accounts SET
|
||||||
|
available_balance_cent = ROUND(available_balance * 100),
|
||||||
|
frozen_balance_cent = ROUND(frozen_balance * 100)
|
||||||
|
WHERE available_balance > 0 OR frozen_balance > 0;
|
||||||
|
|
||||||
|
-- 钱包流水
|
||||||
|
UPDATE wallet_ledger SET
|
||||||
|
amount_cent = ROUND(amount * 100),
|
||||||
|
balance_after_cent = ROUND(balance_after * 100)
|
||||||
|
WHERE amount != 0 OR balance_after != 0;
|
||||||
|
|
||||||
|
-- 提现记录
|
||||||
|
UPDATE withdrawal_requests SET
|
||||||
|
amount_cent = ROUND(amount * 100),
|
||||||
|
fee_cent = ROUND(fee * 100),
|
||||||
|
actual_amount_cent = ROUND(actual_amount * 100)
|
||||||
|
WHERE amount > 0 OR fee > 0 OR actual_amount > 0;
|
||||||
|
|
||||||
|
-- +goose StatementEnd
|
||||||
|
|
||||||
|
-- +goose Down
|
||||||
|
-- +goose StatementBegin
|
||||||
|
-- ============================================
|
||||||
|
-- 回滚:删除所有新增的分字段
|
||||||
|
-- ============================================
|
||||||
|
|
||||||
|
ALTER TABLE users DROP COLUMN deposit_free_quota_cent;
|
||||||
|
|
||||||
|
ALTER TABLE rental_listings
|
||||||
|
DROP COLUMN price_cent,
|
||||||
|
DROP COLUMN deposit_amount_cent;
|
||||||
|
|
||||||
|
ALTER TABLE rental_orders
|
||||||
|
DROP COLUMN rent_amount_cent,
|
||||||
|
DROP COLUMN owner_rent_amount_cent,
|
||||||
|
DROP COLUMN deposit_amount_cent,
|
||||||
|
DROP COLUMN deposit_original_amount_cent,
|
||||||
|
DROP COLUMN deposit_waived_amount_cent,
|
||||||
|
DROP COLUMN platform_fee_cent;
|
||||||
|
|
||||||
|
ALTER TABLE order_checkouts
|
||||||
|
DROP COLUMN rent_amount_cent,
|
||||||
|
DROP COLUMN owner_rent_amount_cent,
|
||||||
|
DROP COLUMN platform_fee_cent,
|
||||||
|
DROP COLUMN deposit_amount_cent,
|
||||||
|
DROP COLUMN consumable_amount_cent,
|
||||||
|
DROP COLUMN other_amount_cent,
|
||||||
|
DROP COLUMN deposit_deduct_amount_cent,
|
||||||
|
DROP COLUMN renter_refund_amount_cent,
|
||||||
|
DROP COLUMN owner_income_amount_cent;
|
||||||
|
|
||||||
|
ALTER TABLE wallet_accounts
|
||||||
|
DROP COLUMN available_balance_cent,
|
||||||
|
DROP COLUMN frozen_balance_cent;
|
||||||
|
|
||||||
|
ALTER TABLE wallet_ledger
|
||||||
|
DROP COLUMN amount_cent,
|
||||||
|
DROP COLUMN balance_after_cent;
|
||||||
|
|
||||||
|
ALTER TABLE withdrawal_requests
|
||||||
|
DROP COLUMN amount_cent,
|
||||||
|
DROP COLUMN fee_cent,
|
||||||
|
DROP COLUMN actual_amount_cent;
|
||||||
|
|
||||||
|
-- +goose StatementEnd
|
||||||
Reference in New Issue
Block a user