From aa061fb78e743e040ffc6c72e796285604e08df8 Mon Sep 17 00:00:00 2001 From: zhumr Date: Thu, 23 Oct 2025 19:52:47 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E6=95=B0=E6=8D=AE=E5=A4=84?= =?UTF-8?q?=E7=90=86=E8=BF=87=E7=A8=8B-=E7=BA=BF=E4=B8=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../2 执行SQL/CAATS-01-02 数据处理过程-线下.txt | 1722 +++++++++++++++++ 1 file changed, 1722 insertions(+) diff --git a/底稿/附件/2 执行SQL/CAATS-01-02 数据处理过程-线下.txt b/底稿/附件/2 执行SQL/CAATS-01-02 数据处理过程-线下.txt index e69de29..5e70cc0 100644 --- a/底稿/附件/2 执行SQL/CAATS-01-02 数据处理过程-线下.txt +++ b/底稿/附件/2 执行SQL/CAATS-01-02 数据处理过程-线下.txt @@ -0,0 +1,1722 @@ +-- 一、建表 +----------------------------------- +-- 1 创建自定义（国内）门店销售 +----------------------------------- +DROP TABLE IF EXISTS audit_bi_pro.custom_offline_sale_return_local; +CREATE TABLE audit_bi_pro.custom_offline_sale_return_local +( + `source_system` String COMMENT '来源系统', + `sale_date` String COMMENT '销售日期', + `brand_code` String COMMENT '品牌编码', + `sale_time` Datetime('Asia/Shanghai') COMMENT '销售时间', + `store_code` String COMMENT '门店编码', + `store_name` String COMMENT '门店名称', + `receipt_no` String COMMENT '小票号', + `goods_amt` Decimal(18,2) COMMENT '商品金额', + `barcode` String COMMENT '条码', + `goods_name` String COMMENT '商品名称', + `qty` Int64 COMMENT '数量', + `price` Decimal(18,2) COMMENT '单价', + `pay_type` String COMMENT '收银方式', + `source_bill_no` String COMMENT '原单据号', + `sale_status` String COMMENT '销售状态' +)ENGINE = ReplicatedMergeTree('/clickhouse/tables/audit_bi_pro/custom_offline_sale_return_local/{shard}', + '{replica}') +PARTITION BY toYYYYMM(toDate(sale_date)) +ORDER BY receipt_no +SETTINGS index_granularity = 8192 +COMMENT '自定义门店销售'; + +----------------------------------- +-- 2 创建海一家订单号关联关系中间表 +----------------------------------- +DROP TABLE IF EXISTS audit_bi_pro.custom_offline_receipt_BES_local; +CREATE TABLE audit_bi_pro.custom_offline_receipt_BES_local( + receipt_no String COMMENT '现单号', + source_bill_no String COMMENT '来源订单号', + lv Int64 COMMENT '关联层级' +) +ENGINE = ReplicatedMergeTree('/clickhouse/tables/audit_bi_pro/custom_offline_receipt_BES_local/{shard}', + '{replica}') +ORDER BY receipt_no +SETTINGS index_granularity = 8192 +COMMENT '海一家小票号关联关系'; + +----------------------------------- +-- 3 创建自定义海外门店销售表 +----------------------------------- +DROP TABLE IF EXISTS audit_bi_pro.custom_offline_abroad_sale_return_local; +CREATE TABLE audit_bi_pro.custom_offline_abroad_sale_return_local +( + `source_system` String COMMENT '来源系统', + `sale_date` String COMMENT '销售日期', + `brand_code` String COMMENT '品牌编码', + `sale_time` Datetime('Asia/Shanghai') COMMENT '销售时间', + `store_code` String COMMENT '门店编码', + `store_name` String COMMENT '门店名称', + `receipt_no` String COMMENT '小票号', + `goods_amt` Decimal(18,2) COMMENT '商品金额', + `barcode` String COMMENT '条码', + `goods_name` String COMMENT '商品名称', + `qty` Int64 COMMENT '数量', + `price` Decimal(18,2) COMMENT '单价', + `pay_type` String COMMENT '收银方式', + `source_bill_no` String COMMENT '原单据号', + `sale_status` String COMMENT '销售状态' +)ENGINE = ReplicatedMergeTree('/clickhouse/tables/audit_bi_pro/custom_offline_abroad_sale_return_local/{shard}', + '{replica}') +PARTITION BY toYYYYMM(toDate(sale_date)) +ORDER BY receipt_no +SETTINGS index_granularity = 8192 +COMMENT '自定义海外门店销售'; + +----------------------------------- +-- 4 创建汇率表 +----------------------------------- +DROP TABLE IF EXISTS audit_bi_pro.custom_exchange_rate_local; +CREATE TABLE audit_bi_pro.custom_exchange_rate_local +( + `rate_date` Date COMMENT '日期', + `currency` String COMMENT '货币', + `exchange_rate` Decimal(10,6) COMMENT '兑人名币汇率' +) +ENGINE = Log +COMMENT '汇率表'; + +----------------------------------- +-- 5 创建自定义门店主数据汇总表 +----------------------------------- +DROP TABLE IF EXISTS audit_bi_pro.custom_store_info_all_local; +CREATE TABLE audit_bi_pro.custom_store_info_all_local +( + `brand_code` String COMMENT '品牌编码', + `store_code` String COMMENT '门店编码', + `store_name` String COMMENT '门店名称', + `store_nature` String COMMENT '门店性质(描述)', + `open_date` String COMMENT '开店时间', + `close_date` String COMMENT '关店时间', + `country` String COMMENT '国家(描述)', + `province` String COMMENT '省份(描述)', + `city` String COMMENT '城市(地级市)(描述)', + `store_status` String COMMENT '门店状态(描述)', + `period` String COMMENT '会计期间', + `source_table` String COMMENT '来源表' +)ENGINE = ReplicatedMergeTree('/clickhouse/tables/audit_bi_pro/custom_store_info_all_local/{shard}', + '{replica}') +ORDER BY store_code +COMMENT '自定义门店主数据汇总表' + +----------------------------------- +-- 6 创建自定义门店性质汇总表 +----------------------------------- +DROP TABLE IF EXISTS audit_bi_pro.custom_store_nature_all_local; +CREATE TABLE audit_bi_pro.custom_store_nature_all_local +( + `brand_code` String COMMENT '品牌编码', + `store_code` String COMMENT '门店编码', + `store_name` String COMMENT '门店名称', + `store_nature` String COMMENT '门店性质(描述)', + `open_date` String COMMENT '开店时间', + `close_date` String COMMENT '关店时间', + `country` String COMMENT '国家(描述)', + `province` String COMMENT '省份(描述)', + `city` String COMMENT '城市(地级市)(描述)', + `store_status` String COMMENT '门店状态(描述)', + `year` String COMMENT '年份', + `source_table` String COMMENT '来源表' +)ENGINE = ReplicatedMergeTree('/clickhouse/tables/audit_bi_pro/custom_store_nature_all_local/{shard}', + '{replica}') +ORDER BY store_code +COMMENT '自定义门店性质汇总表' + + +-- 7 创建线下城市表 +DROP TABLE IF EXISTS audit_bi_pro.custom_offline_region_city_local; +CREATE TABLE audit_bi_pro.custom_offline_region_city_local +( + `region` String COMMENT '地区', + `city` String COMMENT '城市' +)ENGINE =Log; + +TRUNCATE TABLE IF EXISTS audit_bi_pro.custom_offline_region_city_local; + +-- 8 创建SBZ新老系统店铺对应表 +DROP TABLE IF EXISTS audit_bi_pro.custom_offline_sbz_store_old_new; +CREATE TABLE audit_bi_pro.custom_offline_sbz_store_old_new +( + `old_store_code` String COMMENT '老系统店铺编码', + `old_store_name` String COMMENT '老系统店铺名称', + `store_code` String COMMENT '店铺编码', + `store_name` String COMMENT '店铺名称' +)ENGINE =Log; + + +-- 9 创建SBZ老系统销售数据表 +DROP TABLE IF EXISTS audit_bi_pro.custom_offline_sbz_old_system; +CREATE TABLE audit_bi_pro.custom_offline_sbz_old_system +( + `source_system` String COMMENT '来源系统', + `sale_date` String COMMENT '销售日期', + `brand_code` String COMMENT '品牌编码', + `sale_time` String COMMENT '销售时间', + `store_code` String COMMENT '门店编码', + `store_name` String COMMENT '门店名称', + `receipt_no` String COMMENT '小票号', + `goods_amt` Decimal(18,2) COMMENT '商品金额', + `barcode` String COMMENT '条码', + `goods_name` String COMMENT '商品名称', + `qty` Int64 COMMENT '数量', + `price` Decimal(18,2) COMMENT '单价', + `pay_type` String COMMENT '收银方式', + `source_bill_no` String COMMENT '原单据号' +)ENGINE = ReplicatedMergeTree('/clickhouse/tables/audit_bi_pro/custom_offline_sbz_old_system/{shard}', + '{replica}') +PARTITION BY toYYYYMM(toDate(sale_date)) +ORDER BY receipt_no +SETTINGS index_granularity = 8192 +COMMENT '自定义斯搏兹老系统销售表'; + + +------------------------------- +-- 10 自定义门店销售结算表 +------------------------------- +-- 国内 +DROP TABLE IF EXISTS audit_bi_pro.custom_offline_sale_return_settle_local; +CREATE TABLE audit_bi_pro.custom_offline_sale_return_settle_local +( + `source_system` String COMMENT '来源系统', + `sale_date` String COMMENT '销售日期', + `brand_code` String COMMENT '品牌编码', + `sale_time` Datetime('Asia/Shanghai') COMMENT '销售时间', + `store_code` String COMMENT '门店编码', + `store_name` String COMMENT '门店名称', + `receipt_no` String COMMENT '小票号', + `goods_amt` Decimal(18,2) COMMENT '商品金额', + `barcode` String COMMENT '条码', + `goods_name` String COMMENT '商品名称', + `qty` Int64 COMMENT '数量', + `price` Decimal(18,2) COMMENT '单价', + `pay_type` String COMMENT '收银方式', + `source_bill_no` String COMMENT '原单据号', + `sale_status` String COMMENT '销售状态', + `store_nature` String COMMENT '门店性质', + `settle_ratio` Decimal(18,4)COMMENT '结算比例' +)ENGINE = ReplicatedMergeTree('/clickhouse/tables/audit_bi_pro/custom_offline_sale_return_settle_local/{shard}', + '{replica}') +PARTITION BY toYYYYMM(toDate(sale_date)) +ORDER BY receipt_no +SETTINGS index_granularity = 8192 +COMMENT '自定义国内门店销售结算表'; + + +--海外 +DROP TABLE IF EXISTS audit_bi_pro.custom_offline_abroad_sale_return_settle_local; +CREATE TABLE audit_bi_pro.custom_offline_abroad_sale_return_settle_local +( + `source_system` String COMMENT '来源系统', + `sale_date` String COMMENT '销售日期', + `brand_code` String COMMENT '品牌编码', + `sale_time` Datetime('Asia/Shanghai') COMMENT '销售时间', + `store_code` String COMMENT '门店编码', + `store_name` String COMMENT '门店名称', + `receipt_no` String COMMENT '小票号', + `goods_amt` Decimal(18,2) COMMENT '商品金额', + `barcode` String COMMENT '条码', + `goods_name` String COMMENT '商品名称', + `qty` Int64 COMMENT '数量', + `price` Decimal(18,2) COMMENT '单价', + `pay_type` String COMMENT '收银方式', + `source_bill_no` String COMMENT '原单据号', + `sale_status` String COMMENT '销售状态', + `store_nature` String COMMENT '门店性质', + `settle_ratio` Decimal(18,4)COMMENT '结算比例' +)ENGINE = ReplicatedMergeTree('/clickhouse/tables/audit_bi_pro/custom_offline_abroad_sale_return_settle_local/{shard}', + '{replica}') +PARTITION BY toYYYYMM(toDate(sale_date)) +ORDER BY receipt_no +SETTINGS index_granularity = 8192 +COMMENT '自定义海外门店销售结算表'; + + +----------------------------------- +-- 创建结算比例表 +----------------------------------- +DROP TABLE IF EXISTS audit_bi_pro.custom_settle_ratio_local; +CREATE TABLE audit_bi_pro.custom_settle_ratio_local +( + `settle_year` String COMMENT '年份', + `store_nature` String COMMENT '门店性质', + `settle_ratio` Decimal(18,4) COMMENT '结算比例' +) +ENGINE = Log +COMMENT '结算比例表'; + +-- 二、插入数据 +----------------------------------- +-- 1 插入国内数据 +-- 1.1 插入非海一家、非男生女生销售、退款数据 +-- 2022-2023 +----------------------------------- +TRUNCATE TABLE IF EXISTS audit_bi_pro.custom_offline_sale_return_local; +INSERT INTO audit_bi_pro.custom_offline_sale_return_local +WITH sale_status AS ( +SELECT + store_code, + receipt_no, + CASE + -- 金额大于0 + WHEN SUM(goods_amt) > 0 AND MIN(qty) >= 0 THEN '销售' + WHEN SUM(goods_amt) > 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货销售' + -- 金额小于0 + WHEN SUM(goods_amt) < 0 AND MAX(qty) <= 0 THEN '退款' + WHEN SUM(goods_amt) < 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货' + -- 金额等于0 + WHEN SUM(goods_amt) = 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货或门店调整' + WHEN SUM(goods_amt) = 0 AND MIN(qty) > 0 THEN '单赠品销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) < 0 THEN '单赠品退款' + WHEN SUM(goods_amt) = 0 AND MIN(qty) >= 0 THEN '优惠销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) <= 0 THEN '优惠退款' + ELSE '其他' + END AS status +FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm +WHERE + toDateTime(sale_time,'Asia/Shanghai') >= '2022-01-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2024-01-01 00:00:00' + AND brand_code NOT IN ('BES','NCL') + AND barcode NOT IN ('3303000001','3303000002','3303000003','3303000004','3303000007','3303000008','3303000009','3303000010','3303000011', + '3303000012','3303004000000','3303004000001','3303004000002','1303000154','1303000085','1303000083','1303000084','1303000156') +GROUP BY store_code,receipt_no +HAVING status IN('销售','单赠品销售','优惠销售','退款','单赠品退款','优惠退款')) +SELECT + a.source_system, + a.sale_date, + a.brand_code, + a.saletime, + a.store_code, + a.store_name, + CASE + WHEN b.status = '销售' THEN a.receipt_no + WHEN b.status = '退款' AND a.source_bill_no <> '' THEN a.source_bill_no + ELSE a.receipt_no + END AS receipt_no, + a.goods_amt, + a.barcode, + a.goods_name, + a.qty, + a.price, + a.pay_type, + a.source_bill_no, + b.status +FROM( + SELECT + *, + toDateTime(sale_time,'Asia/Shanghai') AS saletime + FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm + WHERE CONCAT(store_code,receipt_no) IN (SELECT CONCAT(store_code,receipt_no) FROM sale_status) + AND barcode NOT IN ('3303000001','3303000002','3303000003','3303000004','3303000007','3303000008','3303000009','3303000010','3303000011', + '3303000012','3303004000000','3303004000001','3303004000002','1303000154','1303000085','1303000083','1303000084','1303000156') +) a +LEFT JOIN( + SELECT + store_code, + CASE + WHEN status IN('销售','单赠品销售','优惠销售') THEN '销售' + WHEN status IN('退款','单赠品退款','优惠退款') THEN '退款' + END AS status, + receipt_no + FROM sale_status +) b +ON a.store_code = b.store_code AND a.receipt_no = b.receipt_no; + +----------------------------------- +-- 1 插入国内数据 +-- 1.1 插入非海一家、非男生女生销售、退款数据 +-- 2024-2025 +----------------------------------- +TRUNCATE TABLE IF EXISTS audit_bi_pro.custom_offline_sale_return_local; +INSERT INTO audit_bi_pro.custom_offline_sale_return_local +WITH sale_status AS ( +SELECT + store_code, + receipt_no, + CASE + -- 金额大于0 + WHEN SUM(goods_amt) > 0 AND MIN(qty) >= 0 THEN '销售' + WHEN SUM(goods_amt) > 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货销售' + -- 金额小于0 + WHEN SUM(goods_amt) < 0 AND MAX(qty) <= 0 THEN '退款' + WHEN SUM(goods_amt) < 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货' + -- 金额等于0 + WHEN SUM(goods_amt) = 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货或门店调整' + WHEN SUM(goods_amt) = 0 AND MIN(qty) > 0 THEN '单赠品销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) < 0 THEN '单赠品退款' + WHEN SUM(goods_amt) = 0 AND MIN(qty) >= 0 THEN '优惠销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) <= 0 THEN '优惠退款' + ELSE '其他' + END AS status +FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm +WHERE + toDateTime(sale_time,'Asia/Shanghai') >= '2024-01-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2025-07-01 00:00:00' + AND brand_code NOT IN ('BES','NCL') + AND barcode NOT IN ('3303000001','3303000002','3303000003','3303000004','3303000007','3303000008','3303000009','3303000010','3303000011', + '3303000012','3303004000000','3303004000001','3303004000002','1303000154','1303000085','1303000083','1303000084','1303000156') +GROUP BY store_code,receipt_no +HAVING status IN('销售','单赠品销售','优惠销售','退款','单赠品退款','优惠退款')) +SELECT + a.source_system, + a.sale_date, + a.brand_code, + a.saletime, + a.store_code, + a.store_name, + CASE + WHEN b.status = '销售' THEN a.receipt_no + WHEN b.status = '退款' AND a.source_bill_no <> '' THEN a.source_bill_no + ELSE a.receipt_no + END AS receipt_no, + a.goods_amt, + a.barcode, + a.goods_name, + a.qty, + a.price, + a.pay_type, + a.source_bill_no, + b.status +FROM( + SELECT + *, + toDateTime(sale_time,'Asia/Shanghai') AS saletime + FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm + WHERE CONCAT(store_code,receipt_no) IN (SELECT CONCAT(store_code,receipt_no) FROM sale_status) + AND barcode NOT IN ('3303000001','3303000002','3303000003','3303000004','3303000007','3303000008','3303000009','3303000010','3303000011', + '3303000012','3303004000000','3303004000001','3303004000002','1303000154','1303000085','1303000083','1303000084','1303000156') +) a +LEFT JOIN( + SELECT + store_code, + CASE + WHEN status IN('销售','单赠品销售','优惠销售') THEN '销售' + WHEN status IN('退款','单赠品退款','优惠退款') THEN '退款' + END AS status, + receipt_no + FROM sale_status +) b +ON a.store_code = b.store_code AND a.receipt_no = b.receipt_no; + +----------------------------------- +-- 1 插入国内数据 +-- 1.2 插入非海一家, 非男生女生换货数据 +-- 2022-2023 +----------------------------------- +INSERT INTO audit_bi_pro.custom_offline_sale_return_local +WITH sale_status AS ( +SELECT + store_code, + receipt_no, + CASE + -- 金额大于0 + WHEN SUM(goods_amt) > 0 AND MIN(qty) >= 0 THEN '销售' + WHEN SUM(goods_amt) > 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货销售' + -- 金额小于0 + WHEN SUM(goods_amt) < 0 AND MAX(qty) <= 0 THEN '退款' + WHEN SUM(goods_amt) < 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货' + -- 金额等于0 + WHEN SUM(goods_amt) = 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货或门店调整' + WHEN SUM(goods_amt) = 0 AND MIN(qty) > 0 THEN '单赠品销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) < 0 THEN '单赠品退款' + WHEN SUM(goods_amt) = 0 AND MIN(qty) >= 0 THEN '优惠销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) <= 0 THEN '优惠退款' + ELSE '其他' + END AS status +FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm +WHERE + toDateTime(sale_time,'Asia/Shanghai') >= '2022-01-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2024-01-01 00:00:00' + AND brand_code NOT IN ('BES','NCL') + AND barcode NOT IN ('3303000001','3303000002','3303000003','3303000004','3303000007','3303000008','3303000009','3303000010','3303000011', + '3303000012','3303004000000','3303004000001','3303004000002','1303000154','1303000085','1303000083','1303000084','1303000156') +GROUP BY store_code,receipt_no +HAVING status IN('换货销售','换货')) +SELECT + a.source_system, + a.sale_date, + a.brand_code, + a.saletime, + a.store_code, + a.store_name, + CASE + WHEN (a.qty > 0 OR (a.qty = 0 AND a.goods_amt <=0)) AND a.source_bill_no <> '' THEN a.source_bill_no + WHEN ((a.qty < 0 AND a.goods_amt <=0) OR (a.qty = 0 and a.goods_amt > 0)) AND a.source_bill_no <> '' THEN a.source_bill_no + ELSE a.receipt_no + END AS receipt_no, + a.goods_amt, + a.barcode, + a.goods_name, + a.qty, + a.price, + a.pay_type, + a.source_bill_no, + CASE + WHEN a.qty > 0 OR (a.qty = 0 AND a.goods_amt <=0) THEN '销售' + WHEN (a.qty < 0 AND a.goods_amt <=0) OR (a.qty = 0 AND a.goods_amt > 0) THEN '退款' + END AS status +FROM( + SELECT + *, + toDateTime(sale_time,'Asia/Shanghai') AS saletime + FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm + WHERE CONCAT(store_code,receipt_no) IN (SELECT CONCAT(store_code,receipt_no) FROM sale_status) + AND barcode NOT IN ('3303000001','3303000002','3303000003','3303000004','3303000007','3303000008','3303000009','3303000010','3303000011', + '3303000012','3303004000000','3303004000001','3303004000002','1303000154','1303000085','1303000083','1303000084','1303000156') +) a +LEFT JOIN( + SELECT + store_code, + status, + receipt_no + FROM sale_status +) b +ON a.store_code = b.store_code AND a.receipt_no = b.receipt_no; + +----------------------------------- +-- 1 插入国内数据 +-- 1.2 插入非海一家, 非男生女生换货数据 +-- 2024-2025 +----------------------------------- +INSERT INTO audit_bi_pro.custom_offline_sale_return_local +WITH sale_status AS ( +SELECT + store_code, + receipt_no, + CASE + -- 金额大于0 + WHEN SUM(goods_amt) > 0 AND MIN(qty) >= 0 THEN '销售' + WHEN SUM(goods_amt) > 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货销售' + -- 金额小于0 + WHEN SUM(goods_amt) < 0 AND MAX(qty) <= 0 THEN '退款' + WHEN SUM(goods_amt) < 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货' + -- 金额等于0 + WHEN SUM(goods_amt) = 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货或门店调整' + WHEN SUM(goods_amt) = 0 AND MIN(qty) > 0 THEN '单赠品销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) < 0 THEN '单赠品退款' + WHEN SUM(goods_amt) = 0 AND MIN(qty) >= 0 THEN '优惠销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) <= 0 THEN '优惠退款' + ELSE '其他' + END AS status +FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm +WHERE + toDateTime(sale_time,'Asia/Shanghai') >= '2024-01-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2025-07-01 00:00:00' + AND brand_code NOT IN ('BES','NCL') + AND barcode NOT IN ('3303000001','3303000002','3303000003','3303000004','3303000007','3303000008','3303000009','3303000010','3303000011', + '3303000012','3303004000000','3303004000001','3303004000002','1303000154','1303000085','1303000083','1303000084','1303000156') +GROUP BY store_code,receipt_no +HAVING status IN('换货销售','换货')) +SELECT + a.source_system, + a.sale_date, + a.brand_code, + a.saletime, + a.store_code, + a.store_name, + CASE + WHEN (a.qty > 0 OR (a.qty = 0 AND a.goods_amt <=0)) AND a.source_bill_no <> '' THEN a.source_bill_no + WHEN ((a.qty < 0 AND a.goods_amt <=0) OR (a.qty = 0 and a.goods_amt > 0)) AND a.source_bill_no <> '' THEN a.source_bill_no + ELSE a.receipt_no + END AS receipt_no, + a.goods_amt, + a.barcode, + a.goods_name, + a.qty, + a.price, + a.pay_type, + a.source_bill_no, + CASE + WHEN a.qty > 0 OR (a.qty = 0 AND a.goods_amt <=0) THEN '销售' + WHEN (a.qty < 0 AND a.goods_amt <=0) OR (a.qty = 0 AND a.goods_amt > 0) THEN '退款' + END AS status +FROM( + SELECT + *, + toDateTime(sale_time,'Asia/Shanghai') AS saletime + FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm + WHERE CONCAT(store_code,receipt_no) IN (SELECT CONCAT(store_code,receipt_no) FROM sale_status) + AND barcode NOT IN ('3303000001','3303000002','3303000003','3303000004','3303000007','3303000008','3303000009','3303000010','3303000011', + '3303000012','3303004000000','3303004000001','3303004000002','1303000154','1303000085','1303000083','1303000084','1303000156') +) a +LEFT JOIN( + SELECT + store_code, + status, + receipt_no + FROM sale_status +) b +ON a.store_code = b.store_code AND a.receipt_no = b.receipt_no; + +----------------------------------- +-- 1 插入国内数据 +-- 1.3 插入海一家关联关系表数据 +----------------------------------- +TRUNCATE TABLE IF EXISTS audit_bi_pro.custom_offline_receipt_BES_local; +INSERT INTO audit_bi_pro.custom_offline_receipt_BES_local +WITH order_chain AS ( + SELECT + DISTINCT receipt_no, + source_bill_no + FROM + dwd_trade_hkaudit_shop_receipt_mt + WHERE brand_code = 'BES' +) +SELECT + l0.receipt_no as receipt_no, + multiIf( + l7.receipt_no <>'',l7.receipt_no, + l6.receipt_no <>'',l6.receipt_no, + l5.receipt_no <>'',l5.receipt_no, + l4.receipt_no <>'',l4.receipt_no, + l3.receipt_no <>'',l3.receipt_no, -- 第三级的原始单号 + l2.receipt_no <>'',l2.receipt_no, -- 第二级的原始单号 + l1.receipt_no <>'',l1.receipt_no, -- 第一级的原始单号 + l0.receipt_no -- 自己就是原始单号 + ) as source_bill_no, + CASE + when l7.receipt_no <>'' then 7 + when l6.receipt_no <>'' then 6 + when l5.receipt_no <>'' then 5 + when l4.receipt_no <>'' then 4 + when l3.receipt_no <>'' then 3 + when l2.receipt_no <>'' then 2 + when l1.receipt_no <>'' then 1 + else 0 + end as lv +FROM + order_chain l0 +LEFT JOIN + order_chain l1 +ON l1.receipt_no = l0.source_bill_no +LEFT JOIN + order_chain l2 +ON l2.receipt_no = l1.source_bill_no +LEFT JOIN + order_chain l3 +ON l3.receipt_no = l2.source_bill_no +LEFT JOIN + order_chain l4 +ON l4.receipt_no = l3.source_bill_no +LEFT JOIN + order_chain l5 +ON l5.receipt_no = l4.source_bill_no +LEFT JOIN + order_chain l6 +ON l6.receipt_no = l5.source_bill_no +LEFT JOIN + order_chain l7 +ON l7.receipt_no = l6.source_bill_no +WHERE lv <> 7 AND lv <> 0 + +----------------------------------- +-- 1 插入国内数据 +-- 1.4 插入海一家销售、退款数据 +----------------------------------- +TRUNCATE TABLE IF EXISTS audit_bi_pro.custom_offline_sale_return_local; +INSERT INTO audit_bi_pro.custom_offline_sale_return_local +WITH sale_status AS ( +SELECT + store_code, + receipt_no, + CASE + -- 金额大于0 + WHEN SUM(goods_amt) > 0 AND MIN(qty) >= 0 THEN '销售' + WHEN SUM(goods_amt) > 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货销售' + -- 金额小于0 + WHEN SUM(goods_amt) < 0 AND MAX(qty) <= 0 THEN '退款' + WHEN SUM(goods_amt) < 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货' + -- 金额等于0 + WHEN SUM(goods_amt) = 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货或门店调整' + WHEN SUM(goods_amt) = 0 AND MIN(qty) > 0 THEN '单赠品销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) < 0 THEN '单赠品退款' + WHEN SUM(goods_amt) = 0 AND MIN(qty) >= 0 THEN '优惠销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) <= 0 THEN '优惠退款' + ELSE '其他' + END AS status +FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm +WHERE + toDateTime(sale_time,'Asia/Shanghai') >= '2022-01-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2025-07-01 00:00:00' + AND brand_code ='BES' +GROUP BY store_code,receipt_no +HAVING status IN('销售','单赠品销售','优惠销售','退款','单赠品退款','优惠退款')) +SELECT + a.source_system, + a.sale_date, + a.brand_code, + a.saletime, + a.store_code, + a.store_name, + CASE + WHEN b.status = '销售' THEN a.receipt_no + WHEN b.status = '退款' AND c.source_bill_no <> '' THEN c.source_bill_no + ELSE a.receipt_no + END AS receipt_no, + a.goods_amt, + a.barcode, + a.goods_name, + a.qty, + a.price, + a.pay_type, + c.source_bill_no, + b.status +FROM( + SELECT + *, + toDateTime(sale_time,'Asia/Shanghai') AS saletime + FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm + WHERE CONCAT(store_code,receipt_no) IN (SELECT CONCAT(store_code,receipt_no) FROM sale_status) +) a +LEFT JOIN( + SELECT + store_code, + CASE + WHEN status IN('销售','单赠品销售','优惠销售') THEN '销售' + WHEN status IN('退款','单赠品退款','优惠退款') THEN '退款' + END AS status, + receipt_no + FROM sale_status +) b +ON a.store_code = b.store_code AND a.receipt_no = b.receipt_no +LEFT JOIN( + SELECT + receipt_no, + source_bill_no + FROM custom_offline_receipt_BES_local corbl + WHERE lv <> 0 +)c +ON a.receipt_no = c.receipt_no; + +----------------------------------- +-- 1 插入国内数据 +-- 1.5 插入海一家换货销售数据 +----------------------------------- +INSERT INTO audit_bi_pro.custom_offline_sale_return_local +WITH sale_status AS ( +SELECT + store_code, + receipt_no, + CASE + -- 金额大于0 + WHEN SUM(goods_amt) > 0 AND MIN(qty) >= 0 THEN '销售' + WHEN SUM(goods_amt) > 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货销售' + -- 金额小于0 + WHEN SUM(goods_amt) < 0 AND MAX(qty) <= 0 THEN '退款' + WHEN SUM(goods_amt) < 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货' + -- 金额等于0 + WHEN SUM(goods_amt) = 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货或门店调整' + WHEN SUM(goods_amt) = 0 AND MIN(qty) > 0 THEN '单赠品销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) < 0 THEN '单赠品退款' + WHEN SUM(goods_amt) = 0 AND MIN(qty) >= 0 THEN '优惠销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) <= 0 THEN '优惠退款' + ELSE '其他' + END AS status +FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm +WHERE + toDateTime(sale_time,'Asia/Shanghai') >= '2022-01-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2025-07-01 00:00:00' + AND brand_code ='BES' +GROUP BY store_code,receipt_no +HAVING status IN ('换货销售','换货')) +SELECT + a.source_system, + a.sale_date, + a.brand_code, + a.saletime, + a.store_code, + a.store_name, + CASE + WHEN (a.qty > 0 OR (a.qty = 0 AND a.goods_amt <=0)) AND c.source_bill_no <> '' THEN c.source_bill_no + WHEN ((a.qty < 0 AND a.goods_amt <=0) OR (a.qty = 0 and a.goods_amt > 0)) AND c.source_bill_no <> '' THEN c.source_bill_no + ELSE a.receipt_no + END AS receipt_no, + a.goods_amt, + a.barcode, + a.goods_name, + a.qty, + a.price, + a.pay_type, + c.source_bill_no, + CASE + WHEN a.qty > 0 OR (a.qty = 0 AND a.goods_amt <=0) THEN '销售' + WHEN (a.qty < 0 AND a.goods_amt <=0) OR (a.qty = 0 AND a.goods_amt > 0) THEN '退款' + END AS status +FROM( + SELECT + *, + toDateTime(sale_time,'Asia/Shanghai') AS saletime + FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm + WHERE CONCAT(store_code,receipt_no) IN (SELECT CONCAT(store_code,receipt_no) FROM sale_status) +) a +LEFT JOIN( + SELECT + store_code, + status, + receipt_no + FROM sale_status +) b +ON a.store_code = b.store_code AND a.receipt_no = b.receipt_no +LEFT JOIN( + SELECT + receipt_no, + source_bill_no + FROM custom_offline_receipt_BES_local corbl + WHERE lv <> 0 +)c +ON a.receipt_no = c.receipt_no; + +----------------------------------- +-- 1 插入国内数据 +-- 1.6 插入男生女生销售、退款数据 +----------------------------------- +TRUNCATE TABLE IF EXISTS audit_bi_pro.custom_offline_sale_return_local; + +INSERT INTO audit_bi_pro.custom_offline_sale_return_local +WITH sale_status AS ( +SELECT + store_code, + receipt_no, + CASE + -- 金额大于0 + WHEN SUM(goods_amt) > 0 AND MIN(qty) >= 0 THEN '销售' + WHEN SUM(goods_amt) > 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货销售' + -- 金额小于0 + WHEN SUM(goods_amt) < 0 AND MAX(qty) <= 0 THEN '退款' + WHEN SUM(goods_amt) < 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货' + -- 金额等于0 + WHEN SUM(goods_amt) = 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货或门店调整' + WHEN SUM(goods_amt) = 0 AND MIN(qty) > 0 THEN '单赠品销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) < 0 THEN '单赠品退款' + WHEN SUM(goods_amt) = 0 AND MIN(qty) >= 0 THEN '优惠销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) <= 0 THEN '优惠退款' + ELSE '其他' + END AS status +FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm +WHERE + toDateTime(sale_time,'Asia/Shanghai') >= '2022-01-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2025-07-01 00:00:00' + AND brand_code = 'NCL' + AND receipt_no NOT IN ('99N1LQ2305060003','99N0YU2304070005','99N1LQ2305100004','99N0YU2304100002') + OR (receipt_no IN('99N1LQ2305060003','99N0YU2304070005') AND goods_amt >0 AND qty>0) + OR (receipt_no IN('99N1LQ2305100004','99N0YU2304100002') AND goods_amt <0 AND qty<0) +GROUP BY store_code,receipt_no +HAVING status IN('销售','单赠品销售','优惠销售','退款','单赠品退款','优惠退款')) +SELECT + a.source_system, + a.sale_date, + a.brand_code, + a.saletime, + a.store_code, + a.store_name, + CASE + WHEN b.status = '销售' THEN a.receipt_no + WHEN b.status = '退款' AND a.source_bill_no <> '' THEN a.source_bill_no + ELSE a.receipt_no + END AS receipt_no, + a.goods_amt, + a.barcode, + a.goods_name, + a.qty, + a.price, + a.pay_type, + a.source_bill_no, + b.status +FROM( + SELECT + *, + toDateTime(sale_time,'Asia/Shanghai') AS saletime + FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm + WHERE CONCAT(store_code,receipt_no) IN (SELECT CONCAT(store_code,receipt_no) FROM sale_status) + AND receipt_no NOT IN ('99N1LQ2305060003','99N0YU2304070005','99N1LQ2305100004','99N0YU2304100002') + OR (receipt_no IN('99N1LQ2305060003','99N0YU2304070005') AND goods_amt >0 AND qty>0) + OR (receipt_no IN('99N1LQ2305100004','99N0YU2304100002') AND goods_amt <0 AND qty<0) +) a +LEFT JOIN( + SELECT + store_code, + CASE + WHEN status IN('销售','单赠品销售','优惠销售') THEN '销售' + WHEN status IN('退款','单赠品退款','优惠退款') THEN '退款' + END AS status, + receipt_no + FROM sale_status +) b +ON a.store_code = b.store_code AND a.receipt_no = b.receipt_no; + +----------------------------------- +-- 1 插入国内数据 +-- 1.7 插入男生女生换货数据 +----------------------------------- +INSERT INTO audit_bi_pro.custom_offline_sale_return_local +WITH sale_status AS ( +SELECT + store_code, + receipt_no, + CASE + -- 金额大于0 + WHEN SUM(goods_amt) > 0 AND MIN(qty) >= 0 THEN '销售' + WHEN SUM(goods_amt) > 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货销售' + -- 金额小于0 + WHEN SUM(goods_amt) < 0 AND MAX(qty) <= 0 THEN '退款' + WHEN SUM(goods_amt) < 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货' + -- 金额等于0 + WHEN SUM(goods_amt) = 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货或门店调整' + WHEN SUM(goods_amt) = 0 AND MIN(qty) > 0 THEN '单赠品销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) < 0 THEN '单赠品退款' + WHEN SUM(goods_amt) = 0 AND MIN(qty) >= 0 THEN '优惠销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) <= 0 THEN '优惠退款' + ELSE '其他' + END AS status +FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm +WHERE + toDateTime(sale_time,'Asia/Shanghai') >= '2022-01-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2025-07-01 00:00:00' + AND brand_code = 'NCL' + AND receipt_no NOT IN ('99N1LQ2305060003','99N0YU2304070005','99N1LQ2305100004','99N0YU2304100002') + OR (receipt_no IN('99N1LQ2305060003','99N0YU2304070005') AND goods_amt >0 AND qty>0) + OR (receipt_no IN('99N1LQ2305100004','99N0YU2304100002') AND goods_amt <0 AND qty<0) +GROUP BY store_code,receipt_no +HAVING status IN('换货销售','换货')) +SELECT + a.source_system, + a.sale_date, + a.brand_code, + a.saletime, + a.store_code, + a.store_name, + CASE + WHEN (a.qty > 0 OR (a.qty = 0 AND a.goods_amt <=0)) AND a.source_bill_no <> '' THEN a.source_bill_no + WHEN ((a.qty < 0 AND a.goods_amt <=0) OR (a.qty = 0 and a.goods_amt > 0)) AND a.source_bill_no <> '' THEN a.source_bill_no + ELSE a.receipt_no + END AS receipt_no, + a.goods_amt, + a.barcode, + a.goods_name, + a.qty, + a.price, + a.pay_type, + a.source_bill_no, + CASE + WHEN a.qty > 0 OR (a.qty = 0 AND a.goods_amt <=0) THEN '销售' + WHEN (a.qty < 0 AND a.goods_amt <=0) OR (a.qty = 0 AND a.goods_amt > 0) THEN '退款' + END AS status +FROM( + SELECT + *, + toDateTime(sale_time,'Asia/Shanghai') AS saletime + FROM + dwd_trade_hkaudit_shop_receipt_mt dthsrm + WHERE CONCAT(store_code,receipt_no) IN (SELECT CONCAT(store_code,receipt_no) FROM sale_status) +) a +LEFT JOIN( + SELECT + store_code, + status, + receipt_no + FROM sale_status +) b +ON a.store_code = b.store_code AND a.receipt_no = b.receipt_no; + +----------------------------------- +-- 1 插入国内数据 +-- 1.8 替换SBZ老系统店铺数据为新系统店铺数据 +----------------------------------- +TRUNCATE TABLE IF EXISTS audit_bi_pro.custom_offline_sbz_old_system; +INSERT INTO audit_bi_pro.custom_offline_sbz_old_system +SELECT + a.source_system, + a.sale_date, + a.brand_code, + a.sale_time, + CASE + WHEN b.store_code <> '' THEN b.store_code + WHEN b.store_code = '' THEN a.store_code + END AS store_code, + CASE + WHEN b.store_name <> '' THEN b.store_name + WHEN b.store_name = '' THEN a.store_name + END AS store_name, + a.receipt_no, + a.goods_amt, + a.barcode, + a.goods_name, + a.qty, + a.price, + a.pay_type, + a.source_bill_no +FROM ( + SELECT * FROM dwd_trade_hkaudit_shop_receipt_other_mt WHERE brand_code = 'SBZ' +)a +LEFT JOIN( + SELECT * FROM custom_offline_sbz_store_old_new +)b +ON a.store_code = b.old_store_code + +----------------------------------- +-- 1 插入国内数据 +-- 1.9 插入SBZ老系统数据 +----------------------------------- +TRUNCATE TABLE IF EXISTS audit_bi_pro.custom_offline_sale_return_local; +INSERT INTO audit_bi_pro.custom_offline_sale_return_local +WITH sale_status AS ( +SELECT + store_code, + CASE + WHEN receipt_no LIKE '%-%-%' AND LENGTH(receipt_no) = 25 THEN SUBSTR(receipt_no,1,23) + WHEN receipt_no LIKE '%-%-%' AND LENGTH(receipt_no) = 26 THEN SUBSTR(receipt_no,1,24) + WHEN receipt_no NOT LIKE '%-%-%' AND LENGTH(receipt_no) = 11 THEN SUBSTR(receipt_no,1,9) + WHEN receipt_no NOT LIKE '%-%-%' AND LENGTH(receipt_no) IN (23,24,25) THEN receipt_no + END AS order_id, + CASE + -- RC单算销售 + WHEN order_id LIKE 'RC%' THEN '销售' + -- 金额大于0 + WHEN sum(goods_amt) > 0 AND MIN(qty) >= 0 THEN '销售' + WHEN sum(goods_amt) > 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货销售' + -- 金额小于0 + WHEN sum(goods_amt) < 0 AND MAX(qty) <= 0 THEN '退款' + WHEN sum(goods_amt) < 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货' + -- 金额等于0s + WHEN sum(goods_amt) = 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货或门店调整' + WHEN sum(goods_amt) = 0 AND MIN(qty) > 0 THEN '单赠品销售' + WHEN sum(goods_amt) = 0 AND MAX(qty) < 0 THEN '单赠品退款' + WHEN sum(goods_amt) = 0 AND MIN(qty) >= 0 THEN '优惠销售' + WHEN sum(goods_amt) = 0 AND MAX(qty) <= 0 THEN '优惠退款' + ELSE '其他' + END AS status +FROM + custom_offline_sbz_old_system dthsrm +WHERE + toDateTime(sale_time,'Asia/Shanghai') >= '2024-05-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2025-07-01 00:00:00' + AND brand_code = 'SBZ' +GROUP BY store_code,order_id +HAVING status IN('销售','单赠品销售','优惠销售','退款','单赠品退款','优惠退款')) +SELECT + a.source_system, + a.sale_date, + a.brand_code, + a.saletime, + a.store_code, + a.store_name, + CASE + WHEN b.status = '销售' THEN a.a_receipt_no + WHEN b.status = '退款' AND a.source_bill_no <> '' THEN a.source_bill_no + ELSE a.a_receipt_no + END AS receipt_no, + a.goods_amt, + a.barcode, + a.goods_name, + a.qty, + a.price, + a.pay_type, + a.source_bill_no, + b.status +FROM( + SELECT + *, + CASE + WHEN receipt_no LIKE '%-%-%' AND LENGTH(receipt_no) = 25 THEN SUBSTR(receipt_no,1,23) + WHEN receipt_no LIKE '%-%-%' AND LENGTH(receipt_no) = 26 THEN SUBSTR(receipt_no,1,24) + WHEN receipt_no NOT LIKE '%-%-%' AND LENGTH(receipt_no) = 11 THEN SUBSTR(receipt_no,1,9) + WHEN receipt_no NOT LIKE '%-%-%' AND LENGTH(receipt_no) IN (23,24,25) THEN receipt_no + END AS a_receipt_no, + toDateTime(sale_time,'Asia/Shanghai') AS saletime + FROM + custom_offline_sbz_old_system dthsrm + WHERE CONCAT(store_code,a_receipt_no) IN (SELECT CONCAT(store_code,order_id) FROM sale_status) + AND toDateTime(sale_time,'Asia/Shanghai') >= '2024-05-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2025-07-01 00:00:00' +) a +LEFT JOIN( + SELECT + store_code, + CASE + WHEN status IN('销售','单赠品销售','优惠销售') THEN '销售' + WHEN status IN('退款','单赠品退款','优惠退款') THEN '退款' + END AS status, + order_id + FROM sale_status +) b +ON a.store_code = b.store_code AND a.a_receipt_no = b.order_id; +----------------------------------- +-- 1 插入国内数据 +-- 1.10 插入SBZ老系统换货数据 +----------------------------------- +INSERT INTO audit_bi_pro.custom_offline_sale_return_local +WITH sale_status AS ( +SELECT + store_code, + CASE + WHEN receipt_no LIKE '%-%-%' AND LENGTH(receipt_no) = 25 THEN SUBSTR(receipt_no,1,23) + WHEN receipt_no LIKE '%-%-%' AND LENGTH(receipt_no) = 26 THEN SUBSTR(receipt_no,1,24) + WHEN receipt_no NOT LIKE '%-%-%' AND LENGTH(receipt_no) = 11 THEN SUBSTR(receipt_no,1,9) + WHEN receipt_no NOT LIKE '%-%-%' AND LENGTH(receipt_no) IN (23,24,25) THEN receipt_no + END AS order_id, + CASE + -- 金额大于0 + WHEN sum(goods_amt) > 0 AND MIN(qty) >= 0 THEN '销售' + WHEN sum(goods_amt) > 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货销售' + -- 金额小于0 + WHEN sum(goods_amt) < 0 AND MAX(qty) <= 0 THEN '退款' + WHEN sum(goods_amt) < 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货' + -- 金额等于0 + WHEN sum(goods_amt) = 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货或门店调整' + WHEN sum(goods_amt) = 0 AND MIN(qty) > 0 THEN '单赠品销售' + WHEN sum(goods_amt) = 0 AND MAX(qty) < 0 THEN '单赠品退款' + WHEN sum(goods_amt) = 0 AND MIN(qty) >= 0 THEN '优惠销售' + WHEN sum(goods_amt) = 0 AND MAX(qty) <= 0 THEN '优惠退款' + ELSE '其他' + END AS status +FROM + custom_offline_sbz_old_system dthsrm +WHERE + toDateTime(sale_time,'Asia/Shanghai') >= '2024-05-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2025-07-01 00:00:00' + AND brand_code = 'SBZ' +GROUP BY store_code,order_id +HAVING status IN('换货销售','换货')) +SELECT + a.source_system, + a.sale_date, + a.brand_code, + a.saletime, + a.store_code, + a.store_name, + CASE + WHEN (a.qty > 0 OR (a.qty = 0 AND a.goods_amt <=0)) AND a.source_bill_no <> '' THEN a.source_bill_no + WHEN ((a.qty < 0 AND a.goods_amt <=0) OR (a.qty = 0 and a.goods_amt > 0)) AND a.source_bill_no <> '' THEN a.source_bill_no + ELSE a.a_receipt_no + END AS receipt_no, + a.goods_amt, + a.barcode, + a.goods_name, + a.qty, + a.price, + a.pay_type, + a.source_bill_no, + CASE + WHEN a.qty > 0 OR (a.qty = 0 AND a.goods_amt <=0) THEN '销售' + WHEN (a.qty < 0 AND a.goods_amt <=0) OR (a.qty = 0 AND a.goods_amt > 0) THEN '退款' + END AS status +FROM( + SELECT + *, + CASE + WHEN receipt_no LIKE '%-%-%' AND LENGTH(receipt_no) = 25 THEN SUBSTR(receipt_no,1,23) + WHEN receipt_no LIKE '%-%-%' AND LENGTH(receipt_no) = 26 THEN SUBSTR(receipt_no,1,24) + WHEN receipt_no NOT LIKE '%-%-%' AND LENGTH(receipt_no) = 11 THEN SUBSTR(receipt_no,1,9) + WHEN receipt_no NOT LIKE '%-%-%' AND LENGTH(receipt_no) IN (23,24,25) THEN receipt_no + END AS a_receipt_no, + toDateTime(sale_time,'Asia/Shanghai') AS saletime + FROM + custom_offline_sbz_old_system dthsrm + WHERE CONCAT(store_code,a_receipt_no) IN (SELECT CONCAT(store_code,order_id) FROM sale_status) + AND toDateTime(sale_time,'Asia/Shanghai') >= '2024-05-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2025-07-01 00:00:00' +) a +LEFT JOIN( + SELECT + store_code, + status, + order_id + FROM sale_status +) b +ON a.store_code = b.store_code AND a.a_receipt_no = b.order_id; +----------------------------------- +-- 2 插入海外数据 +-- 2.1导入海外销售、退款 +----------------------------------- +TRUNCATE TABLE IF EXISTS audit_bi_pro.custom_offline_abroad_sale_return_local; +INSERT INTO audit_bi_pro.custom_offline_abroad_sale_return_local +WITH sale_status AS ( +SELECT + store_code, + receipt_no, + CASE + -- 金额大于0 + WHEN SUM(goods_amt) > 0 AND MIN(qty) >= 0 THEN '销售' + WHEN SUM(goods_amt) > 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货销售' + -- 金额小于0 + WHEN SUM(goods_amt) < 0 AND MAX(qty) <= 0 THEN '退款' + WHEN SUM(goods_amt) < 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货' + -- 金额等于0 + WHEN SUM(goods_amt) = 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货或门店调整' + WHEN SUM(goods_amt) = 0 AND MIN(qty) > 0 THEN '单赠品销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) < 0 THEN '单赠品退款' + WHEN SUM(goods_amt) = 0 AND MIN(qty) >= 0 THEN '优惠销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) <= 0 THEN '优惠退款' + ELSE '其他' + END AS status +FROM + dwd_trade_hkaudit_shop_receipt_other_mt +WHERE + toDateTime(sale_time,'Asia/Shanghai') >= '2022-01-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2025-07-01 00:00:00' + AND brand_code <> 'SBZ' + AND receipt_no NOT IN ('01L082301170039009','01L082301170039012','01L082301160039013', + '01L082301160039015','02L352501190006299','01L082301160039008','01L082301170039011', + '01L082301170039016','02L082301160038947','01L352502040009339', + '02E022207240007125','02E042205220008537','04L522409150063759','02E022505010028060') +GROUP BY store_code,receipt_no +HAVING status IN('销售','单赠品销售','优惠销售','退款','单赠品退款','优惠退款')) +SELECT + a.source_system, + a.sale_date, + a.brand_code, + a.saletime, + a.store_code, + a.n_store_name, + CASE + WHEN b.status = '销售' THEN a.receipt_no + WHEN b.status = '退款' AND a.source_bill_no <> '' THEN a.source_bill_no + ELSE a.receipt_no + END AS receipt_no, + ROUND(a.goods_amt * rate.exchange_rate,2) AS goods_amt, + a.barcode, + a.goods_name, + a.qty, + a.price, + a.pay_type, + a.source_bill_no, + b.status +FROM( + SELECT + m.*, + CASE + WHEN n.store_name <> '' THEN n.store_name + WHEN n.store_name = '' THEN m.store_name + END AS n_store_name, + toDateTime(m.sale_time,'Asia/Shanghai') AS saletime, + CASE + WHEN SUBSTR(n_store_name,1,6) = '泰国' THEN 'THB' + WHEN SUBSTR(n_store_name,1,6) = '马来' THEN 'MYR' + WHEN SUBSTR(n_store_name,1,6) = '越南' THEN 'VND' + WHEN SUBSTR(n_store_name,1,6) = '菲律' THEN 'PHP' + WHEN SUBSTR(n_store_name,1,6) = '新加' THEN 'SGD' + WHEN SUBSTR(n_store_name,1,6) = '印尼' THEN 'IDR' + WHEN SUBSTR(n_store_name,1,6) = '肯尼' THEN 'KES' + END AS currency + FROM( + SELECT + * + FROM + dwd_trade_hkaudit_shop_receipt_other_mt + WHERE + CONCAT(store_code,receipt_no) IN (SELECT CONCAT(store_code,receipt_no) FROM sale_status) + AND brand_code <>'SBZ' + AND receipt_no NOT IN ('01L082301170039009','01L082301170039012','01L082301160039013', + '01L082301160039015','02L352501190006299','01L082301160039008','01L082301170039011', + '01L082301170039016','02L082301160038947','01L352502040009339', + '02E022207240007125','02E042205220008537','04L522409150063759','02E022505010028060') + ) m + LEFT JOIN ( + SELECT + store_code, + store_name + FROM + dim_hkaudit_store_other_mt + ) n + ON m.store_code = n.store_code +) a +LEFT JOIN( + SELECT + store_code, + CASE + WHEN status IN('销售','单赠品销售','优惠销售') THEN '销售' + WHEN status IN('退款','单赠品退款','优惠退款') THEN '退款' + END AS status, + receipt_no + FROM sale_status +) b +ON a.store_code = b.store_code AND a.receipt_no = b.receipt_no +LEFT JOIN ( + SELECT + rate_date, + currency, + exchange_rate + FROM + custom_exchange_rate_local +) rate ON rate.currency = a.currency AND toYear(rate.rate_date) = toYear(a.saletime) AND toMonth(rate.rate_date) = toMonth(a.saletime); + +----------------------------------- +-- 2 插入海外数据 +-- 2.2 插入海外换货数据 +----------------------------------- +INSERT INTO audit_bi_pro.custom_offline_abroad_sale_return_local +WITH sale_status AS ( +SELECT + store_code, + receipt_no, + CASE + -- 金额大于0 + WHEN SUM(goods_amt) > 0 AND MIN(qty) >= 0 THEN '销售' + WHEN SUM(goods_amt) > 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货销售' + -- 金额小于0 + WHEN SUM(goods_amt) < 0 AND MAX(qty) <= 0 THEN '退款' + WHEN SUM(goods_amt) < 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货' + -- 金额等于0 + WHEN SUM(goods_amt) = 0 AND MAX(qty) > 0 AND MIN(qty)<0 THEN '换货或门店调整' + WHEN SUM(goods_amt) = 0 AND MIN(qty) > 0 THEN '单赠品销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) < 0 THEN '单赠品退款' + WHEN SUM(goods_amt) = 0 AND MIN(qty) >= 0 THEN '优惠销售' + WHEN SUM(goods_amt) = 0 AND MAX(qty) <= 0 THEN '优惠退款' + ELSE '其他' + END AS status +FROM + dwd_trade_hkaudit_shop_receipt_other_mt dthsrm +WHERE + toDateTime(sale_time,'Asia/Shanghai') >= '2022-01-01 00:00:00' + AND toDateTime(sale_time,'Asia/Shanghai') < '2025-07-01 00:00:00' + AND brand_code <> 'SBZ' + AND receipt_no NOT IN ('01L082301170039009','01L082301170039012','01L082301160039013', + '01L082301160039015','02L352501190006299','01L082301160039008','01L082301170039011', + '01L082301170039016','02L082301160038947','01L352502040009339', + '02E022207240007125','02E042205220008537','04L522409150063759','02E022505010028060') +GROUP BY store_code,receipt_no +HAVING status IN ('换货销售','换货')) +SELECT + a.source_system, + a.sale_date, + a.brand_code, + a.saletime, + a.store_code, + a.n_store_name, + CASE + WHEN (a.qty > 0 OR (a.qty = 0 AND a.goods_amt <=0)) AND a.source_bill_no <> '' THEN a.source_bill_no + WHEN ((a.qty < 0 AND a.goods_amt <=0) OR (a.qty = 0 and a.goods_amt > 0)) AND a.source_bill_no <> '' THEN a.source_bill_no + ELSE a.receipt_no + END AS receipt_no, + ROUND(a.goods_amt * rate.exchange_rate,2) AS goods_amt, + a.barcode, + a.goods_name, + a.qty, + a.price, + a.pay_type, + a.source_bill_no, + CASE + WHEN a.qty > 0 OR (a.qty = 0 AND a.goods_amt <=0) THEN '销售' + WHEN (a.qty < 0 AND a.goods_amt <=0) OR (a.qty = 0 AND a.goods_amt > 0) THEN '退款' + END AS status +FROM( + SELECT + m.*, + CASE + WHEN n.store_name <> '' THEN n.store_name + WHEN n.store_name = '' THEN m.store_name + END AS n_store_name, + toDateTime(m.sale_time,'Asia/Shanghai') AS saletime, + CASE + WHEN SUBSTR(n_store_name,1,6) = '泰国' THEN 'THB' + WHEN SUBSTR(n_store_name,1,6) = '马来' THEN 'MYR' + WHEN SUBSTR(n_store_name,1,6) = '越南' THEN 'VND' + WHEN SUBSTR(n_store_name,1,6) = '菲律' THEN 'PHP' + WHEN SUBSTR(n_store_name,1,6) = '新加' THEN 'SGD' + WHEN SUBSTR(n_store_name,1,6) = '印尼' THEN 'IDR' + WHEN SUBSTR(n_store_name,1,6) = '肯尼' THEN 'KES' + END AS currency + FROM( + SELECT + * + FROM + dwd_trade_hkaudit_shop_receipt_other_mt + WHERE + CONCAT(store_code,receipt_no) IN (SELECT CONCAT(store_code,receipt_no) FROM sale_status) + AND brand_code <>'SBZ' + AND receipt_no NOT IN ('01L082301170039009','01L082301170039012','01L082301160039013', + '01L082301160039015','02L352501190006299','01L082301160039008','01L082301170039011', + '01L082301170039016','02L082301160038947','01L352502040009339', + '02E022207240007125','02E042205220008537','04L522409150063759','02E022505010028060') + ) m + LEFT JOIN ( + SELECT + store_code, + store_name + FROM + dim_hkaudit_store_other_mt + ) n + ON m.store_code = n.store_code +) a +LEFT JOIN( + SELECT + store_code, + status, + receipt_no + FROM sale_status +) b +ON a.store_code = b.store_code AND a.receipt_no = b.receipt_no +LEFT JOIN ( + SELECT + rate_date, + currency, + exchange_rate + FROM + custom_exchange_rate_local +) rate ON rate.currency = a.currency AND toYear(rate.rate_date) = toYear(a.saletime) AND toMonth(rate.rate_date) = toMonth(a.saletime); + + +----------------------------------- +-- 3 插入店铺数据 +-- 3.1 插入店铺主数据表 +----------------------------------- +TRUNCATE TABLE IF EXISTS audit_bi_pro.custom_store_info_all_local; +INSERT INTO audit_bi_pro.custom_store_info_all_local +SELECT + MIN(brand_code) AS brand_code, + store_code, + MIN(store_name) AS store_name, + '' AS store_nature, + MIN(open_date) AS open_date, + MIN(close_date) AS close_date, + MIN(country) AS country, + MIN(province) AS province, + MIN(city) AS city, + '' AS store_status, + '' AS period, + 'store' AS source_table +FROM dim_hkaudit_store_mt +GROUP BY store_code +UNION ALL +SELECT + brand_code, + store_code, + store_name, + '' AS store_nature, + open_date, + close_date, + country, + province, + city, + '' AS store_status, + '' AS period, + 'store_other' AS source_table +FROM dim_hkaudit_store_other_mt +WHERE store_code <>'B01R' +UNION ALL +SELECT + MIN(brand_code) AS min_brand_code, + store_code, + MIN(store_name) AS store_name, + '' AS store_nature, + MIN(open_date) AS open_date, + MIN(close_date) AS close_date, + MIN(country) AS country, + MIN(CASE + WHEN province = '天津' THEN '天津市' + WHEN province = '上海' THEN '上海市' + ELSE province + END) AS province, + MIN(CASE WHEN city = ' 西安市' THEN '西安市'ELSE city END) AS city, + '' AS store_status, + '' AS period, + 'jh_sbz' AS source_table +FROM dim_hkaudit_jh_sbz_store_mt +WHERE + CONCAT(brand_code,store_code) NOT IN ('jxhSW00150','sbzS100001') + AND store_code NOT IN ( + SELECT + store_code + FROM ( + SELECT store_code,MIN(store_name) as name from dim_hkaudit_store_mt dhsm group by store_code + UNION ALL + SELECT store_code,MIN(store_name) as name from dim_hkaudit_jh_sbz_store_mt dhjssm group by store_code + ) + GROUP BY store_code + HAVING COUNT(DISTINCT name) > 1 + ) +GROUP BY store_code; + +-- 3.2 插入缺少店铺数据 +INSERT INTO audit_bi_pro.custom_store_info_all_local(store_code,store_name,country,province,city,source_table,brand_code) VALUES +('S454','分销【唯品代销】的店铺','CN','北京市','北京市','store_other','SBZ'), +('S1538','分销【荟品仓】的店铺','CN','上海市','上海','store_other','SBZ'), +('S2440','濮阳盛友体育','CN','河南省','濮阳','store_other','SBZ'), +('S2368','NEO河北邯郸邯山陵西南大街5号阳光世贸广场店','CN','河北省','邯郸','store_other','SBZ'), +('S1072','上海虹口吉买盛店','CN','上海市','上海','store_other','SBZ'), +('S2427','常州京榜折扣店','CN','江苏省','常州','store_other','SBZ'), +('S3094','贵州浅若衣坊','CN','贵州省','贵阳','store_other','SBZ'); + +----------------------------------- +-- 3.3 插入门店性质表 +----------------------------------- +TRUNCATE TABLE IF EXISTS audit_bi_pro.custom_store_nature_all_local; +INSERT INTO audit_bi_pro.custom_store_nature_all_local +SELECT + a.brand_code, + a.store_code, + a.store_name, + b.store_nature, + a.open_date, + a.close_date, + a.country, + a.province, + a.city, + a.store_status, + b.period, + a.source_table +FROM( + SELECT + * + FROM + custom_store_info_all_local + WHERE + source_table = 'store' +) a +LEFT JOIN( + SELECT + store_code, + CASE + WHEN store_code ='K020' THEN '联营店' + ELSE store_nature + END AS store_nature, + SUBSTR(period,1,4) AS period + FROM + dim_hkaudit_store_mt dhsm +) b +ON a.store_code = b.store_code +UNION ALL +SELECT + a.brand_code, + a.store_code, + a.store_name, + CASE + WHEN a.store_code ='S454' THEN '联营店' + WHEN a.store_code ='S1538' THEN '联营店' + WHEN a.store_code ='S2440' THEN '联营店' + WHEN a.store_code ='S2368' THEN '联营店' + WHEN a.store_code ='S1072' THEN '联营店' + WHEN a.store_code ='S2427' THEN '联营店' + WHEN a.store_code ='S3094' THEN '联营店' + ELSE b.store_nature + END AS store_nature, + a.open_date, + a.close_date, + a.country, + a.province, + a.city, + a.store_status, + '' AS `year`, + a.source_table +FROM( + SELECT + * + FROM + custom_store_info_all_local + WHERE + source_table = 'store_other' +) a +LEFT JOIN( + SELECT + store_code, + MIN(store_nature) AS store_nature + FROM + dim_hkaudit_store_other_mt dhsom + GROUP BY + store_code +) b +ON a.store_code = b.store_code +UNION ALL +SELECT + a.brand_code, + a.store_code, + a.store_name, + b.store_nature, + a.open_date, + a.close_date, + a.country, + a.province, + a.city, + a.store_status, + '' AS `year`, + a.source_table +FROM( + SELECT + * + FROM + custom_store_info_all_local + WHERE + source_table = 'jh_sbz' +) a +LEFT JOIN( + SELECT + store_code, + MIN(store_nature) AS store_nature + FROM + dim_hkaudit_jh_sbz_store_mt dhjssm + GROUP BY + store_code +) b +ON a.store_code = b.store_code + +-- 3.4 补充剩余年份及性质到店铺性质表 +见导入截图 + + +--------------------------- +-- 4汇总数据至结算表 +-- 4.1 导入数据到结算比例表 +--------------------------- +见导入截图 + +----------------------------------- +-- 4.2 插入国内数据 +----------------------------------- +-- 2022-2023 +TRUNCATE TABLE IF EXISTS audit_bi_pro.custom_offline_sale_return_settle_local; + +INSERT INTO audit_bi_pro.custom_offline_sale_return_settle_local +SELECT + a.*, + CASE + WHEN b.store_nature <> '' THEN b.store_nature + WHEN b.store_nature = '' THEN c.store_nature + END AS store_nature, + CASE + WHEN a.brand_code IN ('SBZ','JXH') THEN 1 + WHEN toYear(a.sale_time)= 2022 AND store_nature = '直营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 1 + WHEN toYear(a.sale_time)= 2022 AND store_nature = '联营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.8256 + WHEN toYear(a.sale_time)= 2022 AND store_nature = '加盟店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.5494 + WHEN toYear(a.sale_time)= 2023 AND store_nature = '直营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 1 + WHEN toYear(a.sale_time)= 2023 AND store_nature = '联营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.7893 + WHEN toYear(a.sale_time)= 2023 AND store_nature = '加盟店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.5621 + WHEN toYear(a.sale_time)= 2024 AND store_nature = '直营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 1 + WHEN toYear(a.sale_time)= 2024 AND store_nature = '联营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.8041 + WHEN toYear(a.sale_time)= 2024 AND store_nature = '加盟店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.5684 + WHEN toYear(a.sale_time)= 2024 AND store_nature = '代理店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.6485 + WHEN toYear(a.sale_time)= 2025 AND store_nature = '直营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 1 + WHEN toYear(a.sale_time)= 2025 AND store_nature = '联营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.7925 + WHEN toYear(a.sale_time)= 2025 AND store_nature = '加盟店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.5579 + WHEN toYear(a.sale_time)= 2025 AND store_nature = '代理店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.5895 + END AS settle_ratio +FROM custom_offline_sale_return_local a +LEFT JOIN( + SELECT + store_code, + store_nature, + `year` AS period + FROM + custom_store_nature_all_local csnal + WHERE + source_table = 'store' +)b +ON a.store_code = b.store_code AND toString(toYear(a.sale_time)) = b.period +LEFT JOIN( + SELECT + store_code, + store_nature AS store_nature + FROM + custom_store_nature_all_local csnal + WHERE source_table <> 'store' +)c +ON a.store_code = c.store_code +WHERE a.sale_time >='2022-01-01 00:00:00' +AND a.sale_time <'2024-01-01 00:00:00'; + + + +-- 2024-2025 +INSERT INTO audit_bi_pro.custom_offline_sale_return_settle_local +SELECT + a.*, + CASE + WHEN b.store_nature <> '' THEN b.store_nature + WHEN b.store_nature = '' THEN c.store_nature + END AS store_nature, + CASE + WHEN a.brand_code IN ('SBZ','JXH') THEN 1 + WHEN toYear(a.sale_time)= 2022 AND store_nature = '直营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 1 + WHEN toYear(a.sale_time)= 2022 AND store_nature = '联营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.8256 + WHEN toYear(a.sale_time)= 2022 AND store_nature = '加盟店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.5494 + WHEN toYear(a.sale_time)= 2023 AND store_nature = '直营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 1 + WHEN toYear(a.sale_time)= 2023 AND store_nature = '联营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.7893 + WHEN toYear(a.sale_time)= 2023 AND store_nature = '加盟店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.5621 + WHEN toYear(a.sale_time)= 2024 AND store_nature = '直营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 1 + WHEN toYear(a.sale_time)= 2024 AND store_nature = '联营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.8041 + WHEN toYear(a.sale_time)= 2024 AND store_nature = '加盟店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.5684 + WHEN toYear(a.sale_time)= 2024 AND store_nature = '代理店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.6485 + WHEN toYear(a.sale_time)= 2025 AND store_nature = '直营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 1 + WHEN toYear(a.sale_time)= 2025 AND store_nature = '联营店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.7925 + WHEN toYear(a.sale_time)= 2025 AND store_nature = '加盟店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.5579 + WHEN toYear(a.sale_time)= 2025 AND store_nature = '代理店' AND a.brand_code NOT IN ('SBZ','JXH') THEN 0.5895 + END AS settle_ratio +FROM custom_offline_sale_return_local a +LEFT JOIN( + SELECT + store_code, + store_nature, + `year` AS period + FROM + custom_store_nature_all_local csnal + WHERE + source_table = 'store' +)b +ON a.store_code = b.store_code AND toString(toYear(a.sale_time)) = b.period +LEFT JOIN( + SELECT + store_code, + store_nature AS store_nature + FROM + custom_store_nature_all_local csnal + WHERE source_table <> 'store' +)c +ON a.store_code = c.store_code +WHERE a.sale_time >='2024-01-01 00:00:00' +AND a.sale_time <'2025-07-01 00:00:00'; + +----------------------------------- +-- 4.3 插入海外数据 +----------------------------------- +TRUNCATE TABLE IF EXISTS audit_bi_pro.custom_offline_abroad_sale_return_settle_local; +INSERT INTO audit_bi_pro.custom_offline_abroad_sale_return_settle_local +SELECT + a.*, + c.store_nature, + CASE + WHEN toYear(a.sale_time)= 2022 AND store_nature = '直营店' THEN 1 + WHEN toYear(a.sale_time)= 2022 AND store_nature = '联营店' THEN 0.8256 + WHEN toYear(a.sale_time)= 2022 AND store_nature = '加盟店' THEN 0.5494 + WHEN toYear(a.sale_time)= 2023 AND store_nature = '直营店' THEN 1 + WHEN toYear(a.sale_time)= 2023 AND store_nature = '联营店' THEN 0.7893 + WHEN toYear(a.sale_time)= 2023 AND store_nature = '加盟店' THEN 0.5621 + WHEN toYear(a.sale_time)= 2024 AND store_nature = '直营店' THEN 1 + WHEN toYear(a.sale_time)= 2024 AND store_nature = '联营店' THEN 0.8041 + WHEN toYear(a.sale_time)= 2024 AND store_nature = '加盟店' THEN 0.5684 + WHEN toYear(a.sale_time)= 2024 AND store_nature = '代理店' THEN 0.6485 + WHEN toYear(a.sale_time)= 2025 AND store_nature = '直营店' THEN 1 + WHEN toYear(a.sale_time)= 2025 AND store_nature = '联营店' THEN 0.7925 + WHEN toYear(a.sale_time)= 2025 AND store_nature = '加盟店' THEN 0.5579 + WHEN toYear(a.sale_time)= 2025 AND store_nature = '代理店' THEN 0.5895 + END AS settle_ratio +FROM custom_offline_abroad_sale_return_local a +LEFT JOIN( + SELECT + store_code, + store_nature AS store_nature + FROM + custom_store_nature_all_local csnal + WHERE source_table <> 'store' +)c +ON a.store_code = c.store_code; +