admin/heilan
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
wangxu
2025-10-08 19:32:05 +08:00
parent bff7559882
commit 00a51ac679
4 changed files with 569 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
数据分析/v3/正式-查询-钱货两清时间.sql
View File

@@ -945,5 +945,41 @@ ORDER BY SUBSTR(t2.member_register_time, 1, 4);
-- 7.4线上每年会员积分新增、消耗、清零数量
-- 积分类型
SELECT DISTINCT change_kind FROM dwd_basic_all_vip_point_dd;
-- 积分清零有大于0的
SELECT * FROM dwd_basic_all_vip_point_dd WHERE change_kind = '60' AND point_change > '0';
-- 正向积分 获取
SELECT SUBSTR(change_time, 1, 4) AS perYear, SUM(toDecimal64(point_change, 2))
FROM dwd_basic_all_vip_point_dd
WHERE member_id IN (SELECT DISTINCT member_id
FROM (SELECT DISTINCT store_code FROM custom_online_sale_order_local
WHERE mgclear_time <> '' AND SUBSTR(mgclear_time, 1, 10) >= '2022-01-01' AND SUBSTR(mgclear_time, 1, 10) <= '2025-06-30') t1
INNER JOIN dwd_basic_all_vip_info_dd t2 ON t1.store_code = t2.member_register_shop
WHERE t2.member_register_time <> '')
AND point_change > '0' AND change_time <> '' AND SUBSTR(change_time, 1, 10) >= '2022-01-01' AND SUBSTR(change_time, 1, 10) <= '2025-06-30' AND change_kind <> '60'
GROUP BY SUBSTR(change_time, 1, 4)
ORDER BY SUBSTR(change_time, 1, 4);
-- 逆向积分 消耗
SELECT SUBSTR(change_time, 1, 4) AS perYear, SUM(toDecimal64(point_change, 2))
FROM dwd_basic_all_vip_point_dd
WHERE member_id IN (SELECT DISTINCT member_id
FROM (SELECT DISTINCT store_code FROM custom_online_sale_order_local
WHERE mgclear_time <> '' AND SUBSTR(mgclear_time, 1, 10) >= '2022-01-01' AND SUBSTR(mgclear_time, 1, 10) <= '2025-06-30') t1
INNER JOIN dwd_basic_all_vip_info_dd t2 ON t1.store_code = t2.member_register_shop
WHERE t2.member_register_time <> '')
AND point_change < '0' AND change_time <> '' AND SUBSTR(change_time, 1, 10) >= '2022-01-01' AND SUBSTR(change_time, 1, 10) <= '2025-06-30' AND change_kind <> '60'
GROUP BY SUBSTR(change_time, 1, 4)
ORDER BY SUBSTR(change_time, 1, 4);
-- 积分清零
SELECT SUBSTR(change_time, 1, 4) AS perYear, SUM(toDecimal64(point_change, 2))
FROM dwd_basic_all_vip_point_dd
WHERE member_id IN (SELECT DISTINCT member_id
FROM (SELECT DISTINCT store_code FROM custom_online_sale_order_local
WHERE mgclear_time <> '' AND SUBSTR(mgclear_time, 1, 10) >= '2022-01-01' AND SUBSTR(mgclear_time, 1, 10) <= '2025-06-30') t1
INNER JOIN dwd_basic_all_vip_info_dd t2 ON t1.store_code = t2.member_register_shop
WHERE t2.member_register_time <> '')
AND point_change < '0' AND change_time <> '' AND SUBSTR(change_time, 1, 10) >= '2022-01-01' AND SUBSTR(change_time, 1, 10) <= '2025-06-30' AND change_kind = '60'
GROUP BY SUBSTR(change_time, 1, 4)
ORDER BY SUBSTR(change_time, 1, 4);
------------------------------------------------------------------