95 lines
3.8 KiB
MySQL
95 lines
3.8 KiB
MySQL
|
-- 首先，我们需要找到所有符合条件的订单（已支付且使用余额支付）
|
|||
|
|
-- 然后关联到shop_order_goods，计算每个用户的总余额使用情况
|
|||
|
|
-- 最后更新user_balance表的use_balance字段
|
|||
|
|
|
|||
|
|
-- 先创建一个临时表来存储每个用户的use_balance计算结果
|
|||
|
|
CREATE TEMPORARY TABLE IF NOT EXISTS temp_user_balance_calc (
|
|||
|
|
ab98_user_id BIGINT NOT NULL,
|
|||
|
|
total_use_balance BIGINT NOT NULL DEFAULT 0,
|
|||
|
|
PRIMARY KEY (ab98_user_id)
|
|||
|
|
);
|
|||
|
|
|
|||
|
|
-- 清空临时表
|
|||
|
|
TRUNCATE TABLE temp_user_balance_calc;
|
|||
|
|
|
|||
|
|
-- 计算每个用户的use_balance
|
|||
|
|
-- 规则：status为1的total_amount总和 - status为2的total_amount总和
|
|||
|
|
-- 注意：total_amount是元，需要转换为分（乘以100）
|
|||
|
|
INSERT INTO temp_user_balance_calc (ab98_user_id, total_use_balance)
|
|||
|
|
SELECT
|
|||
|
|
COALESCE(
|
|||
|
|
-- 优先使用ab98_user_id直接关联
|
|||
|
|
so.ab98_user_id,
|
|||
|
|
-- 通过openid关联ab98_user表
|
|||
|
|
au.ab98_user_id,
|
|||
|
|
-- 通过openid关联wx_user表，再关联ab98_user表
|
|||
|
|
wu.ab98_user_id,
|
|||
|
|
-- 通过userid关联ab98_user表
|
|||
|
|
au_by_userid.ab98_user_id,
|
|||
|
|
-- 通过userid关联qy_user表，再关联ab98_user表
|
|||
|
|
qu.ab98_user_id
|
|||
|
|
) AS final_ab98_user_id,
|
|||
|
|
-- 计算总使用余额（单位：分）
|
|||
|
|
SUM(
|
|||
|
|
CASE sog.status
|
|||
|
|
WHEN 1 THEN CAST(sog.total_amount * 100 AS UNSIGNED) -- 正常购买，增加使用余额
|
|||
|
|
-- WHEN 2 THEN -CAST(sog.total_amount * 100 AS UNSIGNED) -- 退货，减少使用余额
|
|||
|
|
ELSE 0
|
|||
|
|
END
|
|||
|
|
) AS total_use_balance
|
|||
|
|
FROM shop_order so
|
|||
|
|
-- 关联订单商品
|
|||
|
|
INNER JOIN shop_order_goods sog ON so.order_id = sog.order_id
|
|||
|
|
-- 通过openid关联ab98_user表
|
|||
|
|
LEFT JOIN ab98_user au ON so.openid = au.openid COLLATE utf8mb4_unicode_ci
|
|||
|
|
-- 通过openid关联wx_user表，再获取ab98_user_id
|
|||
|
|
LEFT JOIN wx_user wu ON so.openid = wu.openid COLLATE utf8mb4_unicode_ci
|
|||
|
|
-- 通过userid关联ab98_user表（使用userid字段）
|
|||
|
|
LEFT JOIN ab98_user au_by_userid ON so.userid = au_by_userid.userid COLLATE utf8mb4_unicode_ci
|
|||
|
|
-- 通过userid关联qy_user表
|
|||
|
|
LEFT JOIN qy_user qu ON so.userid = qu.userid COLLATE utf8mb4_unicode_ci
|
|||
|
|
WHERE so.pay_status = 2 -- 已支付
|
|||
|
|
AND so.payment_method = 'balance' -- 余额支付方式
|
|||
|
|
-- 限定特定的corpid，请将'wpZ1ZrEgAA2QTxIRcB4cMtY7hQbTcPAw'替换为实际的corpid
|
|||
|
|
AND so.corpid = 'wpZ1ZrEgAA2QTxIRcB4cMtY7hQbTcPAw' COLLATE utf8mb4_unicode_ci
|
|||
|
|
-- 确保商品状态是1或2
|
|||
|
|
AND sog.status IN (1, 2)
|
|||
|
|
-- 确保能关联到ab98_user
|
|||
|
|
AND (
|
|||
|
|
so.ab98_user_id IS NOT NULL
|
|||
|
|
OR au.ab98_user_id IS NOT NULL
|
|||
|
|
OR wu.ab98_user_id IS NOT NULL
|
|||
|
|
OR au_by_userid.ab98_user_id IS NOT NULL
|
|||
|
|
OR qu.ab98_user_id IS NOT NULL
|
|||
|
|
)
|
|||
|
|
GROUP BY final_ab98_user_id
|
|||
|
|
HAVING final_ab98_user_id IS NOT NULL;
|
|||
|
|
|
|||
|
|
-- 更新user_balance表的use_balance字段
|
|||
|
|
UPDATE user_balance ub
|
|||
|
|
INNER JOIN temp_user_balance_calc calc ON ub.ab98_user_id = calc.ab98_user_id
|
|||
|
|
SET ub.use_balance = calc.total_use_balance
|
|||
|
|
-- 限定特定的corpid，请将'wpZ1ZrEgAA2QTxIRcB4cMtY7hQbTcPAw'替换为实际的corpid
|
|||
|
|
WHERE ub.corpid = 'wpZ1ZrEgAA2QTxIRcB4cMtY7hQbTcPAw' COLLATE utf8mb4_unicode_ci;
|
|||
|
|
|
|||
|
|
-- 修改user_balance的balance值为balance_limit - use_balance
|
|||
|
|
UPDATE user_balance ub
|
|||
|
|
SET ub.balance = ub.balance_limit - ub.use_balance
|
|||
|
|
WHERE ub.corpid = 'wpZ1ZrEgAA2QTxIRcB4cMtY7hQbTcPAw' COLLATE utf8mb4_unicode_ci;
|
|||
|
|
|
|||
|
|
-- 删除临时表
|
|||
|
|
DROP TEMPORARY TABLE IF EXISTS temp_user_balance_calc;
|
|||
|
|
|
|||
|
|
-- 显示更新结果
|
|||
|
|
SELECT
|
|||
|
|
ub.user_balance_id,
|
|||
|
|
ub.ab98_user_id,
|
|||
|
|
ub.balance,
|
|||
|
|
ub.use_balance,
|
|||
|
|
ub.balance_limit,
|
|||
|
|
CONCAT(FORMAT(ub.use_balance / 100, 2), '元') AS use_balance_yuan,
|
|||
|
|
CONCAT(FORMAT(ub.balance / 100, 2), '元') AS balance_yuan,
|
|||
|
|
CONCAT(FORMAT(ub.balance_limit / 100, 2), '元') AS balance_limit_yuan
|
|||
|
|
FROM user_balance ub
|
|||
|
|
WHERE ub.corpid = 'wpZ1ZrEgAA2QTxIRcB4cMtY7hQbTcPAw' COLLATE utf8mb4_unicode_ci
|
|||
|
|
ORDER BY ub.ab98_user_id;
|