1723 lines
59 KiB
Plaintext
1723 lines
59 KiB
Plaintext
-- 一、建表
|
|
-----------------------------------
|
|
-- 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;
|
|
|