-- -*- coding: utf-8 -*- -- Feiqiu-ETL schema (JSON-first alignment) CREATE SCHEMA IF NOT EXISTS billiards; CREATE SCHEMA IF NOT EXISTS billiards_ods; CREATE SCHEMA IF NOT EXISTS etl_admin; COMMENT ON SCHEMA billiards IS '门店业务数据 Schema，存放维度/事实层（与 JSON 字段对应）'; COMMENT ON SCHEMA etl_admin IS 'ETL 调度、游标与运行记录 Schema'; -- ========================= -- Billiards ODS tables -- ========================= CREATE TABLE IF NOT EXISTS billiards_ods.ods_order_settle ( store_id bigint NOT NULL, order_settle_id bigint NOT NULL, order_trade_no bigint, page_no integer, page_size integer, source_file varchar(255), fetched_at timestamptz NOT NULL DEFAULT now(), payload jsonb NOT NULL, PRIMARY KEY (store_id, order_settle_id) ); COMMENT ON TABLE billiards_ods.ods_order_settle IS '订单/结算 ODS（/order/list、ticket 接口原始 JSON）'; COMMENT ON COLUMN billiards_ods.ods_order_settle.store_id IS '门店 ID'; COMMENT ON COLUMN billiards_ods.ods_order_settle.order_settle_id IS '结算单 ID (order_settle_id)'; COMMENT ON COLUMN billiards_ods.ods_order_settle.order_trade_no IS '订单交易号 (order_trade_no)'; COMMENT ON COLUMN billiards_ods.ods_order_settle.page_no IS '来源分页序号'; COMMENT ON COLUMN billiards_ods.ods_order_settle.page_size IS '来源分页大小'; COMMENT ON COLUMN billiards_ods.ods_order_settle.source_file IS '离线导出文件名/路径'; COMMENT ON COLUMN billiards_ods.ods_order_settle.fetched_at IS '入 ODS 时间'; COMMENT ON COLUMN billiards_ods.ods_order_settle.payload IS '原始 JSON 负载'; CREATE TABLE IF NOT EXISTS billiards_ods.ods_table_use_detail ( store_id bigint NOT NULL, ledger_id bigint NOT NULL, order_trade_no bigint, order_settle_id bigint, page_no integer, source_file varchar(255), fetched_at timestamptz NOT NULL DEFAULT now(), payload jsonb NOT NULL, PRIMARY KEY (store_id, ledger_id) ); COMMENT ON TABLE billiards_ods.ods_table_use_detail IS '台费/开台流水 ODS（siteTableUseDetailsList 等接口）'; CREATE TABLE IF NOT EXISTS billiards_ods.ods_assistant_ledger ( store_id bigint NOT NULL, ledger_id bigint NOT NULL, order_trade_no bigint, order_settle_id bigint, page_no integer, source_file varchar(255), fetched_at timestamptz NOT NULL DEFAULT now(), payload jsonb NOT NULL, PRIMARY KEY (store_id, ledger_id) ); COMMENT ON TABLE billiards_ods.ods_assistant_ledger IS '助教流水 ODS（orderAssistantDetails 等接口）'; CREATE TABLE IF NOT EXISTS billiards_ods.ods_assistant_abolish ( store_id bigint NOT NULL, abolish_id bigint NOT NULL, page_no integer, source_file varchar(255), fetched_at timestamptz NOT NULL DEFAULT now(), payload jsonb NOT NULL, PRIMARY KEY (store_id, abolish_id) ); COMMENT ON TABLE billiards_ods.ods_assistant_abolish IS '助教作废记录 ODS'; CREATE TABLE IF NOT EXISTS billiards_ods.ods_goods_ledger ( store_id bigint NOT NULL, order_goods_id bigint NOT NULL, order_trade_no bigint, order_settle_id bigint, page_no integer, source_file varchar(255), fetched_at timestamptz NOT NULL DEFAULT now(), payload jsonb NOT NULL, PRIMARY KEY (store_id, order_goods_id) ); COMMENT ON TABLE billiards_ods.ods_goods_ledger IS '商品销售流水 ODS（orderGoodsLedgers/orderGoodsList）'; CREATE TABLE IF NOT EXISTS billiards_ods.ods_payment ( store_id bigint NOT NULL, pay_id bigint NOT NULL, relate_type varchar(50), relate_id bigint, page_no integer, source_file varchar(255), fetched_at timestamptz NOT NULL DEFAULT now(), payload jsonb NOT NULL, PRIMARY KEY (store_id, pay_id) ); COMMENT ON TABLE billiards_ods.ods_payment IS '支付流水 ODS（payRecord/payList）'; CREATE TABLE IF NOT EXISTS billiards_ods.ods_refund ( store_id bigint NOT NULL, refund_id bigint NOT NULL, page_no integer, source_file varchar(255), fetched_at timestamptz NOT NULL DEFAULT now(), payload jsonb NOT NULL, PRIMARY KEY (store_id, refund_id) ); COMMENT ON TABLE billiards_ods.ods_refund IS '退款流水 ODS'; CREATE TABLE IF NOT EXISTS billiards_ods.ods_coupon_verify ( store_id bigint NOT NULL, coupon_id bigint NOT NULL, page_no integer, source_file varchar(255), fetched_at timestamptz NOT NULL DEFAULT now(), payload jsonb NOT NULL, PRIMARY KEY (store_id, coupon_id) ); COMMENT ON TABLE billiards_ods.ods_coupon_verify IS '团购/验券流水 ODS'; CREATE TABLE IF NOT EXISTS billiards_ods.ods_member ( store_id bigint NOT NULL, member_id bigint NOT NULL, page_no integer, source_file varchar(255), fetched_at timestamptz NOT NULL DEFAULT now(), payload jsonb NOT NULL, PRIMARY KEY (store_id, member_id) ); COMMENT ON TABLE billiards_ods.ods_member IS '会员档案 ODS'; CREATE TABLE IF NOT EXISTS billiards_ods.ods_member_card ( store_id bigint NOT NULL, card_id bigint NOT NULL, page_no integer, source_file varchar(255), fetched_at timestamptz NOT NULL DEFAULT now(), payload jsonb NOT NULL, PRIMARY KEY (store_id, card_id) ); COMMENT ON TABLE billiards_ods.ods_member_card IS '储值卡/会员卡 ODS'; CREATE TABLE IF NOT EXISTS billiards_ods.ods_package_coupon ( store_id bigint NOT NULL, package_id bigint NOT NULL, page_no integer, source_file varchar(255), fetched_at timestamptz NOT NULL DEFAULT now(), payload jsonb NOT NULL, PRIMARY KEY (store_id, package_id) ); COMMENT ON TABLE billiards_ods.ods_package_coupon IS '团购套餐定义 ODS'; CREATE TABLE IF NOT EXISTS billiards_ods.ods_inventory_stock ( store_id bigint NOT NULL, site_goods_id bigint NOT NULL, snapshot_key varchar(100) NOT NULL DEFAULT 'default', page_no integer, source_file varchar(255), fetched_at timestamptz NOT NULL DEFAULT now(), payload jsonb NOT NULL, PRIMARY KEY (store_id, site_goods_id, snapshot_key) ); COMMENT ON TABLE billiards_ods.ods_inventory_stock IS '库存汇总 ODS（inventorySummary 等接口）'; CREATE TABLE IF NOT EXISTS billiards_ods.ods_inventory_change ( store_id bigint NOT NULL, change_id bigint NOT NULL, page_no integer, source_file varchar(255), fetched_at timestamptz NOT NULL DEFAULT now(), payload jsonb NOT NULL, PRIMARY KEY (store_id, change_id) ); COMMENT ON TABLE billiards_ods.ods_inventory_change IS '库存变动记录 ODS'; -- ========================= -- Billiards dimension tables -- ========================= CREATE TABLE IF NOT EXISTS billiards.dim_store ( store_id bigint PRIMARY KEY, store_name varchar(200), tenant_id bigint, region_code varchar(30), address varchar(500), contact_name varchar(100), contact_phone varchar(30), created_time timestamptz, updated_time timestamptz, remark text, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb ); COMMENT ON TABLE billiards.dim_store IS '门店/场馆维度（siteProfile 信息快照）'; COMMENT ON COLUMN billiards.dim_store.store_id IS '门店 ID，主键（API storeId）'; COMMENT ON COLUMN billiards.dim_store.store_name IS '门店名称 (shop_name)'; COMMENT ON COLUMN billiards.dim_store.tenant_id IS '租户 ID (tenant_id)'; COMMENT ON COLUMN billiards.dim_store.region_code IS '区域编码/城市代码 (tenant_site_region_id)'; COMMENT ON COLUMN billiards.dim_store.address IS '完整地址 (full_address/address)'; COMMENT ON COLUMN billiards.dim_store.contact_name IS '联系人（可扩展）'; COMMENT ON COLUMN billiards.dim_store.contact_phone IS '联系电话 (business_tel)'; COMMENT ON COLUMN billiards.dim_store.created_time IS '创建时间'; COMMENT ON COLUMN billiards.dim_store.updated_time IS '更新时间'; COMMENT ON COLUMN billiards.dim_store.remark IS '备注'; COMMENT ON COLUMN billiards.dim_store.raw_data IS '原始 JSON 快照'; CREATE TABLE IF NOT EXISTS billiards.dim_assistant ( store_id bigint NOT NULL, assistant_id bigint NOT NULL, assistant_no varchar(64), nickname varchar(100), real_name varchar(100), gender varchar(20), mobile varchar(30), level varchar(50), team_id bigint, team_name varchar(100), assistant_status varchar(30), work_status varchar(30), entry_time timestamptz, resign_time timestamptz, start_time timestamptz, end_time timestamptz, create_time timestamptz, update_time timestamptz, system_role_id bigint, online_status varchar(30), allow_cx integer, charge_way varchar(30), pd_unit_price numeric(14,2), cx_unit_price numeric(14,2), is_guaranteed integer, is_team_leader integer, serial_number varchar(64), show_sort integer, is_delete integer, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, assistant_id) ); COMMENT ON TABLE billiards.dim_assistant IS '助教/技师维度（Assistant/List）'; COMMENT ON COLUMN billiards.dim_assistant.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.dim_assistant.assistant_id IS '助教 ID (id)'; COMMENT ON COLUMN billiards.dim_assistant.assistant_no IS '助教编号 (assistant_no)'; COMMENT ON COLUMN billiards.dim_assistant.nickname IS '昵称 (nickname)'; COMMENT ON COLUMN billiards.dim_assistant.real_name IS '真实姓名 (real_name)'; COMMENT ON COLUMN billiards.dim_assistant.gender IS '性别'; COMMENT ON COLUMN billiards.dim_assistant.mobile IS '手机号'; COMMENT ON COLUMN billiards.dim_assistant.level IS '等级/段位 (level)'; COMMENT ON COLUMN billiards.dim_assistant.team_id IS '团队 ID (team_id)'; COMMENT ON COLUMN billiards.dim_assistant.team_name IS '团队名称 (team_name)'; COMMENT ON COLUMN billiards.dim_assistant.assistant_status IS '账号状态 (assistant_status)'; COMMENT ON COLUMN billiards.dim_assistant.work_status IS '工作状态 (work_status)'; COMMENT ON COLUMN billiards.dim_assistant.entry_time IS '入职时间 (entry_time)'; COMMENT ON COLUMN billiards.dim_assistant.resign_time IS '离职时间 (resign_time)'; COMMENT ON COLUMN billiards.dim_assistant.start_time IS '可服务开始时间 (start_time)'; COMMENT ON COLUMN billiards.dim_assistant.end_time IS '可服务结束时间 (end_time)'; COMMENT ON COLUMN billiards.dim_assistant.create_time IS '创建时间 (create_time)'; COMMENT ON COLUMN billiards.dim_assistant.update_time IS '最近更新时间 (update_time)'; COMMENT ON COLUMN billiards.dim_assistant.system_role_id IS '系统角色 ID'; COMMENT ON COLUMN billiards.dim_assistant.online_status IS '在线/离线状态'; COMMENT ON COLUMN billiards.dim_assistant.allow_cx IS '是否允许撤销/重开'; COMMENT ON COLUMN billiards.dim_assistant.charge_way IS '计费方式 (charge_way)'; COMMENT ON COLUMN billiards.dim_assistant.pd_unit_price IS '陪打单价 (pd_unit_price)'; COMMENT ON COLUMN billiards.dim_assistant.cx_unit_price IS '拆洗/其它单价 (cx_unit_price)'; COMMENT ON COLUMN billiards.dim_assistant.is_guaranteed IS '是否保底'; COMMENT ON COLUMN billiards.dim_assistant.is_team_leader IS '是否队长'; COMMENT ON COLUMN billiards.dim_assistant.serial_number IS '序列号/展示码 (serial_number)'; COMMENT ON COLUMN billiards.dim_assistant.show_sort IS '展示排序 (show_sort)'; COMMENT ON COLUMN billiards.dim_assistant.is_delete IS '删除标记'; COMMENT ON COLUMN billiards.dim_assistant.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.dim_assistant.updated_at IS 'ETL 更新时间'; CREATE TABLE IF NOT EXISTS billiards.dim_member ( store_id bigint NOT NULL, member_id bigint NOT NULL, member_name varchar(100), phone varchar(30), balance numeric(18,4), status varchar(30), register_time timestamptz, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, member_id) ); COMMENT ON TABLE billiards.dim_member IS '会员维度（MemberProfile/GetTenantMemberList）'; COMMENT ON COLUMN billiards.dim_member.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.dim_member.member_id IS '会员 ID (memberId)'; COMMENT ON COLUMN billiards.dim_member.member_name IS '会员名称 (memberName)'; COMMENT ON COLUMN billiards.dim_member.phone IS '手机号 (phone)'; COMMENT ON COLUMN billiards.dim_member.balance IS '储值余额 (balance)'; COMMENT ON COLUMN billiards.dim_member.status IS '会员状态 (status)'; COMMENT ON COLUMN billiards.dim_member.register_time IS '注册时间 (registerTime)'; COMMENT ON COLUMN billiards.dim_member.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.dim_member.updated_at IS 'ETL 更新时间'; CREATE TABLE IF NOT EXISTS billiards.dim_package_coupon ( store_id bigint NOT NULL, package_id bigint NOT NULL, package_code varchar(100), package_name varchar(200), table_area_id bigint, table_area_name varchar(100), selling_price numeric(14,2), duration_seconds integer, start_time timestamptz, end_time timestamptz, type varchar(50), is_enabled integer, is_delete integer, usable_count integer, creator_name varchar(100), date_type varchar(50), group_type varchar(50), coupon_money numeric(14,2), area_tag_type varchar(50), system_group_type varchar(50), card_type_ids text, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, package_id) ); COMMENT ON TABLE billiards.dim_package_coupon IS '团购/套餐定义维度（Package/List）'; COMMENT ON COLUMN billiards.dim_package_coupon.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.dim_package_coupon.package_id IS '套餐主键 (id)'; COMMENT ON COLUMN billiards.dim_package_coupon.package_code IS '套餐编码 (package_id 或自定义编码)'; COMMENT ON COLUMN billiards.dim_package_coupon.package_name IS '套餐名称 (package_name)'; COMMENT ON COLUMN billiards.dim_package_coupon.table_area_id IS '适用台桌区域 ID'; COMMENT ON COLUMN billiards.dim_package_coupon.table_area_name IS '适用台桌区域名称'; COMMENT ON COLUMN billiards.dim_package_coupon.selling_price IS '售卖价格 (selling_price)'; COMMENT ON COLUMN billiards.dim_package_coupon.duration_seconds IS '可用时长（秒）(duration)'; COMMENT ON COLUMN billiards.dim_package_coupon.start_time IS '可用时间起'; COMMENT ON COLUMN billiards.dim_package_coupon.end_time IS '可用时间止'; COMMENT ON COLUMN billiards.dim_package_coupon.type IS '套餐类型 (type/group_type)'; COMMENT ON COLUMN billiards.dim_package_coupon.is_enabled IS '是否启用 (is_enabled)'; COMMENT ON COLUMN billiards.dim_package_coupon.is_delete IS '删除标记 (is_delete)'; COMMENT ON COLUMN billiards.dim_package_coupon.usable_count IS '可使用次数 (usable_count)'; COMMENT ON COLUMN billiards.dim_package_coupon.creator_name IS '创建人 (creator_name)'; COMMENT ON COLUMN billiards.dim_package_coupon.date_type IS '日期限制 (date_type)'; COMMENT ON COLUMN billiards.dim_package_coupon.group_type IS '渠道/团购类型 (group_type)'; COMMENT ON COLUMN billiards.dim_package_coupon.coupon_money IS '券面额 (coupon_money)'; COMMENT ON COLUMN billiards.dim_package_coupon.area_tag_type IS '区域标签类型'; COMMENT ON COLUMN billiards.dim_package_coupon.system_group_type IS '系统套餐类型 (system_group_type)'; COMMENT ON COLUMN billiards.dim_package_coupon.card_type_ids IS '适用会员卡类型列表 (card_type_ids)'; COMMENT ON COLUMN billiards.dim_package_coupon.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.dim_package_coupon.updated_at IS 'ETL 更新时间'; CREATE TABLE IF NOT EXISTS billiards.dim_product ( store_id bigint NOT NULL, product_id bigint NOT NULL, site_product_id bigint, product_name varchar(200) NOT NULL, category_id bigint, category_name varchar(100), second_category_id bigint, unit varchar(20), cost_price numeric(14,4), sale_price numeric(14,4), allow_discount boolean, status varchar(30), supplier_id bigint, barcode varchar(128), is_combo boolean, created_time timestamptz, updated_time timestamptz, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, product_id) ); COMMENT ON TABLE billiards.dim_product IS '商品维度（TenantGoods/QueryTenantGoods）'; COMMENT ON COLUMN billiards.dim_product.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.dim_product.product_id IS '商品 ID (siteGoodsId/tenantGoodsId)'; COMMENT ON COLUMN billiards.dim_product.site_product_id IS '站点/门店商品 ID (siteGoodsId)'; COMMENT ON COLUMN billiards.dim_product.product_name IS '商品名称 (goodsName/productName)'; COMMENT ON COLUMN billiards.dim_product.category_id IS '一级分类 ID (goodsCategoryId)'; COMMENT ON COLUMN billiards.dim_product.category_name IS '一级分类名称 (categoryName)'; COMMENT ON COLUMN billiards.dim_product.second_category_id IS '二级分类 ID (goodsSecondCategoryId)'; COMMENT ON COLUMN billiards.dim_product.unit IS '计量单位 (goodsUnit)'; COMMENT ON COLUMN billiards.dim_product.cost_price IS '成本价 (costPrice)'; COMMENT ON COLUMN billiards.dim_product.sale_price IS '销售价 (goodsPrice/salePrice)'; COMMENT ON COLUMN billiards.dim_product.allow_discount IS '是否允许折扣 (able_discount)'; COMMENT ON COLUMN billiards.dim_product.status IS '商品状态 (goodsState/status)'; COMMENT ON COLUMN billiards.dim_product.supplier_id IS '供应商 ID'; COMMENT ON COLUMN billiards.dim_product.barcode IS '条码 (barcode)'; COMMENT ON COLUMN billiards.dim_product.is_combo IS '是否组合/套餐商品 (isCombo)'; COMMENT ON COLUMN billiards.dim_product.created_time IS '创建时间 (createTime)'; COMMENT ON COLUMN billiards.dim_product.updated_time IS '更新时间 (updateTime)'; COMMENT ON COLUMN billiards.dim_product.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.dim_product.updated_at IS 'ETL 更新时间'; CREATE TABLE IF NOT EXISTS billiards.dim_product_price_scd ( product_scd_id bigserial PRIMARY KEY, store_id bigint NOT NULL, product_id bigint NOT NULL, product_name varchar(200), category_id bigint, category_name varchar(100), second_category_id bigint, cost_price numeric(14,4), sale_price numeric(14,4), allow_discount boolean, status varchar(30), valid_from timestamptz NOT NULL DEFAULT now(), valid_to timestamptz, is_current boolean NOT NULL DEFAULT true, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, CONSTRAINT fk_dpps_product FOREIGN KEY (store_id, product_id) REFERENCES billiards.dim_product(store_id, product_id) ON DELETE CASCADE, CONSTRAINT ck_dpps_range CHECK ( valid_from < COALESCE(valid_to, '9999-12-31 00:00:00+00'::timestamptz) ), CONSTRAINT uq_dpps_current UNIQUE (store_id, product_id) WHERE (is_current) ); COMMENT ON TABLE billiards.dim_product_price_scd IS '商品维度价格 SCD（记录价格/分类变动历史）'; COMMENT ON COLUMN billiards.dim_product_price_scd.product_scd_id IS '价格 SCD 主键'; COMMENT ON COLUMN billiards.dim_product_price_scd.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.dim_product_price_scd.product_id IS '商品 ID'; COMMENT ON COLUMN billiards.dim_product_price_scd.product_name IS '商品名称（冗余，方便简单查询）'; COMMENT ON COLUMN billiards.dim_product_price_scd.category_id IS '一级分类 ID'; COMMENT ON COLUMN billiards.dim_product_price_scd.category_name IS '一级分类名称'; COMMENT ON COLUMN billiards.dim_product_price_scd.second_category_id IS '二级分类 ID'; COMMENT ON COLUMN billiards.dim_product_price_scd.cost_price IS '成本价'; COMMENT ON COLUMN billiards.dim_product_price_scd.sale_price IS '销售价'; COMMENT ON COLUMN billiards.dim_product_price_scd.allow_discount IS '是否允许折扣'; COMMENT ON COLUMN billiards.dim_product_price_scd.status IS '商品状态 (上/下架)'; COMMENT ON COLUMN billiards.dim_product_price_scd.valid_from IS '生效时间'; COMMENT ON COLUMN billiards.dim_product_price_scd.valid_to IS '失效时间，NULL 表示当前版本'; COMMENT ON COLUMN billiards.dim_product_price_scd.is_current IS '当前有效版本标记'; COMMENT ON COLUMN billiards.dim_product_price_scd.raw_data IS '原始 JSON 快照'; CREATE VIEW IF NOT EXISTS billiards.dim_product_price_current AS SELECT product_scd_id, store_id, product_id, product_name, category_id, category_name, second_category_id, cost_price, sale_price, allow_discount, status, valid_from, valid_to, raw_data FROM billiards.dim_product_price_scd WHERE is_current; COMMENT ON VIEW billiards.dim_product_price_current IS '商品价格 SCD 当前有效版本视图'; COMMENT ON COLUMN billiards.dim_product_price_current.product_scd_id IS '价格 SCD 主键'; COMMENT ON COLUMN billiards.dim_product_price_current.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.dim_product_price_current.product_id IS '商品 ID'; COMMENT ON COLUMN billiards.dim_product_price_current.product_name IS '商品名称'; COMMENT ON COLUMN billiards.dim_product_price_current.category_id IS '一级分类 ID'; COMMENT ON COLUMN billiards.dim_product_price_current.category_name IS '一级分类名称'; COMMENT ON COLUMN billiards.dim_product_price_current.second_category_id IS '二级分类 ID'; COMMENT ON COLUMN billiards.dim_product_price_current.cost_price IS '成本价'; COMMENT ON COLUMN billiards.dim_product_price_current.sale_price IS '销售价'; COMMENT ON COLUMN billiards.dim_product_price_current.allow_discount IS '是否允许折扣'; COMMENT ON COLUMN billiards.dim_product_price_current.status IS '商品状态'; COMMENT ON COLUMN billiards.dim_product_price_current.valid_from IS '生效时间'; COMMENT ON COLUMN billiards.dim_product_price_current.valid_to IS '失效时间'; COMMENT ON COLUMN billiards.dim_product_price_current.raw_data IS '原始 JSON'; CREATE TABLE IF NOT EXISTS billiards.dim_table ( store_id bigint NOT NULL, table_id bigint NOT NULL, site_id bigint, area_id bigint, area_name varchar(100), table_name varchar(100) NOT NULL, table_price numeric(14,4), table_status varchar(30), table_status_name varchar(50), light_status integer, is_rest_area integer, show_status integer, virtual_table integer, charge_free integer, only_allow_groupon integer, is_online_reservation integer, created_time timestamptz, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, table_id) ); COMMENT ON TABLE billiards.dim_table IS '台桌档案维度（Table/GetSiteTables）'; COMMENT ON COLUMN billiards.dim_table.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.dim_table.table_id IS '台桌 ID (id)'; COMMENT ON COLUMN billiards.dim_table.site_id IS '场馆/站点 ID (site_id)'; COMMENT ON COLUMN billiards.dim_table.area_id IS '区域 ID (site_table_area_id)'; COMMENT ON COLUMN billiards.dim_table.area_name IS '区域名称 (areaName)'; COMMENT ON COLUMN billiards.dim_table.table_name IS '台桌名称 (table_name)'; COMMENT ON COLUMN billiards.dim_table.table_price IS '台费单价 (table_price)'; COMMENT ON COLUMN billiards.dim_table.table_status IS '台桌状态代码 (table_status)'; COMMENT ON COLUMN billiards.dim_table.table_status_name IS '台桌状态名称 (tableStatusName)'; COMMENT ON COLUMN billiards.dim_table.light_status IS '灯光状态 (light_status)'; COMMENT ON COLUMN billiards.dim_table.is_rest_area IS '是否休息区 (is_rest_area)'; COMMENT ON COLUMN billiards.dim_table.show_status IS '是否展示 (show_status)'; COMMENT ON COLUMN billiards.dim_table.virtual_table IS '是否虚拟台 (virtual_table)'; COMMENT ON COLUMN billiards.dim_table.charge_free IS '是否免收费 (charge_free)'; COMMENT ON COLUMN billiards.dim_table.only_allow_groupon IS '是否仅限团购 (only_allow_groupon)'; COMMENT ON COLUMN billiards.dim_table.is_online_reservation IS '是否可线上预约 (is_online_reservation)'; COMMENT ON COLUMN billiards.dim_table.created_time IS '创建时间 (create_time)'; COMMENT ON COLUMN billiards.dim_table.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.dim_table.updated_at IS 'ETL 更新时间'; -- ========================= -- Billiards fact tables -- ========================= CREATE TABLE IF NOT EXISTS billiards.fact_assistant_abolish ( store_id bigint NOT NULL, abolish_id bigint NOT NULL, table_id bigint, table_name varchar(100), table_area_id bigint, table_area varchar(100), assistant_no varchar(64), assistant_name varchar(100), charge_minutes integer, abolish_amount numeric(14,4), create_time timestamptz, trash_reason text, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, abolish_id) ); COMMENT ON TABLE billiards.fact_assistant_abolish IS '助教作废/撤单流水（Assistant/AbolishList）'; COMMENT ON COLUMN billiards.fact_assistant_abolish.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.fact_assistant_abolish.abolish_id IS '作废记录 ID (id)'; COMMENT ON COLUMN billiards.fact_assistant_abolish.table_id IS '台桌 ID (tableId)'; COMMENT ON COLUMN billiards.fact_assistant_abolish.table_name IS '台桌名称'; COMMENT ON COLUMN billiards.fact_assistant_abolish.table_area_id IS '台桌区域 ID'; COMMENT ON COLUMN billiards.fact_assistant_abolish.table_area IS '台桌区域名称'; COMMENT ON COLUMN billiards.fact_assistant_abolish.assistant_no IS '助教编号 (assistantOn)'; COMMENT ON COLUMN billiards.fact_assistant_abolish.assistant_name IS '助教姓名'; COMMENT ON COLUMN billiards.fact_assistant_abolish.charge_minutes IS '计费分钟 (pdChargeMinutes)'; COMMENT ON COLUMN billiards.fact_assistant_abolish.abolish_amount IS '作废金额 (assistantAbolishAmount)'; COMMENT ON COLUMN billiards.fact_assistant_abolish.create_time IS '创建时间 (createTime)'; COMMENT ON COLUMN billiards.fact_assistant_abolish.trash_reason IS '作废原因 (trashReason)'; COMMENT ON COLUMN billiards.fact_assistant_abolish.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.fact_assistant_abolish.updated_at IS 'ETL 更新时间'; CREATE TABLE IF NOT EXISTS billiards.fact_assistant_ledger ( store_id bigint NOT NULL, ledger_id bigint NOT NULL, assistant_no varchar(64), assistant_name varchar(100), nickname varchar(100), level_name varchar(50), table_name varchar(100), ledger_unit_price numeric(14,4), ledger_count numeric(14,4), ledger_amount numeric(14,4), projected_income numeric(14,4), service_money numeric(14,4), member_discount_amount numeric(14,4), manual_discount_amount numeric(14,4), coupon_deduct_money numeric(14,4), order_trade_no bigint, order_settle_id bigint, operator_id bigint, operator_name varchar(100), assistant_team_id bigint, assistant_level varchar(50), site_table_id bigint, order_assistant_id bigint, site_assistant_id bigint, user_id bigint, ledger_start_time timestamptz, ledger_end_time timestamptz, start_use_time timestamptz, last_use_time timestamptz, income_seconds integer, real_use_seconds integer, is_trash integer, trash_reason text, is_confirm integer, ledger_status varchar(30), create_time timestamptz, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, ledger_id) ); COMMENT ON TABLE billiards.fact_assistant_ledger IS '助教陪打计费流水（Assistant/LedgerList）'; COMMENT ON COLUMN billiards.fact_assistant_ledger.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.fact_assistant_ledger.ledger_id IS '流水 ID (id)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.assistant_no IS '助教编号'; COMMENT ON COLUMN billiards.fact_assistant_ledger.assistant_name IS '助教姓名'; COMMENT ON COLUMN billiards.fact_assistant_ledger.nickname IS '昵称'; COMMENT ON COLUMN billiards.fact_assistant_ledger.level_name IS '等级名称'; COMMENT ON COLUMN billiards.fact_assistant_ledger.table_name IS '服务台桌名称'; COMMENT ON COLUMN billiards.fact_assistant_ledger.ledger_unit_price IS '计费单价 (ledger_unit_price)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.ledger_count IS '计费数量 (ledger_count)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.ledger_amount IS '计费金额 (ledger_amount)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.projected_income IS '预计收益 (projected_income)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.service_money IS '服务费 (service_money)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.member_discount_amount IS '会员折扣金额'; COMMENT ON COLUMN billiards.fact_assistant_ledger.manual_discount_amount IS '手动折扣金额'; COMMENT ON COLUMN billiards.fact_assistant_ledger.coupon_deduct_money IS '券抵扣金额'; COMMENT ON COLUMN billiards.fact_assistant_ledger.order_trade_no IS '订单交易号 (order_trade_no)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.order_settle_id IS '结算单 ID (order_settle_id)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.operator_id IS '操作人 ID'; COMMENT ON COLUMN billiards.fact_assistant_ledger.operator_name IS '操作人姓名'; COMMENT ON COLUMN billiards.fact_assistant_ledger.assistant_team_id IS '助教团队 ID'; COMMENT ON COLUMN billiards.fact_assistant_ledger.assistant_level IS '助教等级'; COMMENT ON COLUMN billiards.fact_assistant_ledger.site_table_id IS '台桌 ID'; COMMENT ON COLUMN billiards.fact_assistant_ledger.order_assistant_id IS '订单内助教 ID'; COMMENT ON COLUMN billiards.fact_assistant_ledger.site_assistant_id IS '场馆助教 ID'; COMMENT ON COLUMN billiards.fact_assistant_ledger.user_id IS '会员/顾客 ID'; COMMENT ON COLUMN billiards.fact_assistant_ledger.ledger_start_time IS '计费开始时间'; COMMENT ON COLUMN billiards.fact_assistant_ledger.ledger_end_time IS '计费结束时间'; COMMENT ON COLUMN billiards.fact_assistant_ledger.start_use_time IS '开始使用时间'; COMMENT ON COLUMN billiards.fact_assistant_ledger.last_use_time IS '最后使用时间'; COMMENT ON COLUMN billiards.fact_assistant_ledger.income_seconds IS '计费秒数 (income_seconds)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.real_use_seconds IS '实际使用秒数 (real_use_seconds)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.is_trash IS '是否作废 (is_trash)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.trash_reason IS '作废原因 (trash_reason)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.is_confirm IS '是否确认 (is_confirm)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.ledger_status IS '状态 (ledger_status)'; COMMENT ON COLUMN billiards.fact_assistant_ledger.create_time IS '创建时间'; COMMENT ON COLUMN billiards.fact_assistant_ledger.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.fact_assistant_ledger.updated_at IS 'ETL 更新时间'; CREATE TABLE IF NOT EXISTS billiards.fact_inventory_change ( store_id bigint NOT NULL, change_id bigint NOT NULL, site_goods_id bigint, stock_type varchar(50), goods_name varchar(200), change_time timestamptz, start_qty numeric(18,4), end_qty numeric(18,4), change_qty numeric(18,4), unit varchar(20), price numeric(14,4), operator_name varchar(100), remark text, goods_category_id bigint, goods_second_category_id bigint, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, change_id) ); COMMENT ON TABLE billiards.fact_inventory_change IS '库存变更流水（Inventory/ChangeList）'; COMMENT ON COLUMN billiards.fact_inventory_change.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.fact_inventory_change.change_id IS '库存变动 ID (siteGoodsStockId)'; COMMENT ON COLUMN billiards.fact_inventory_change.site_goods_id IS '门店商品 ID (siteGoodsId)'; COMMENT ON COLUMN billiards.fact_inventory_change.stock_type IS '变动类型 (stockType)'; COMMENT ON COLUMN billiards.fact_inventory_change.goods_name IS '商品名称 (goodsName)'; COMMENT ON COLUMN billiards.fact_inventory_change.change_time IS '变动时间 (createTime)'; COMMENT ON COLUMN billiards.fact_inventory_change.start_qty IS '变动前数量 (startNum)'; COMMENT ON COLUMN billiards.fact_inventory_change.end_qty IS '变动后数量 (endNum)'; COMMENT ON COLUMN billiards.fact_inventory_change.change_qty IS '变化数量 (changeNum)'; COMMENT ON COLUMN billiards.fact_inventory_change.unit IS '单位 (unit)'; COMMENT ON COLUMN billiards.fact_inventory_change.price IS '单价 (price)'; COMMENT ON COLUMN billiards.fact_inventory_change.operator_name IS '操作人 (operatorName)'; COMMENT ON COLUMN billiards.fact_inventory_change.remark IS '备注 (remark)'; COMMENT ON COLUMN billiards.fact_inventory_change.goods_category_id IS '一级分类 ID'; COMMENT ON COLUMN billiards.fact_inventory_change.goods_second_category_id IS '二级分类 ID'; COMMENT ON COLUMN billiards.fact_inventory_change.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.fact_inventory_change.updated_at IS 'ETL 更新时间'; CREATE TABLE IF NOT EXISTS billiards.fact_order ( store_id bigint NOT NULL, order_id bigint NOT NULL, order_no varchar(64), member_id bigint, table_id bigint, order_time timestamptz, end_time timestamptz, total_amount numeric(14,4), discount_amount numeric(14,4), final_amount numeric(14,4), pay_status varchar(30), order_status varchar(30), remark text, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, order_id) ); COMMENT ON TABLE billiards.fact_order IS '订单事实表（/order/list 返回的结账记录）'; COMMENT ON COLUMN billiards.fact_order.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.fact_order.order_id IS '订单 ID (orderId)'; COMMENT ON COLUMN billiards.fact_order.order_no IS '订单编号 (orderNo)'; COMMENT ON COLUMN billiards.fact_order.member_id IS '会员 ID (memberId)'; COMMENT ON COLUMN billiards.fact_order.table_id IS '台桌 ID (tableId)'; COMMENT ON COLUMN billiards.fact_order.order_time IS '开单时间/开始时间 (orderTime)'; COMMENT ON COLUMN billiards.fact_order.end_time IS '结账时间 (endTime)'; COMMENT ON COLUMN billiards.fact_order.total_amount IS '订单总金额 (totalAmount)'; COMMENT ON COLUMN billiards.fact_order.discount_amount IS '折扣金额 (discountAmount)'; COMMENT ON COLUMN billiards.fact_order.final_amount IS '应付金额 (finalAmount)'; COMMENT ON COLUMN billiards.fact_order.pay_status IS '支付状态 (payStatus)'; COMMENT ON COLUMN billiards.fact_order.order_status IS '订单状态 (orderStatus)'; COMMENT ON COLUMN billiards.fact_order.remark IS '备注 (remark)'; COMMENT ON COLUMN billiards.fact_order.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.fact_order.updated_at IS 'ETL 更新时间'; CREATE TABLE IF NOT EXISTS billiards.fact_payment ( store_id bigint NOT NULL, pay_id bigint NOT NULL, order_id bigint, order_settle_id bigint, relate_type varchar(50), relate_id bigint, site_id bigint, tenant_id bigint, pay_time timestamptz, create_time timestamptz, pay_amount numeric(14,4), pay_type varchar(50), payment_method varchar(50), online_pay_channel varchar(50), pay_status varchar(30), pay_terminal varchar(50), remark text, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, pay_id) ); COMMENT ON TABLE billiards.fact_payment IS '支付流水（pay/records）'; COMMENT ON COLUMN billiards.fact_payment.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.fact_payment.pay_id IS '支付记录 ID (payId)'; COMMENT ON COLUMN billiards.fact_payment.order_id IS '旧版订单 ID (orderId)，保留兼容'; COMMENT ON COLUMN billiards.fact_payment.order_settle_id IS '结算单 ID (relate_id 当 relate_type=2)'; COMMENT ON COLUMN billiards.fact_payment.relate_type IS '关联类型 (relate_type)'; COMMENT ON COLUMN billiards.fact_payment.relate_id IS '关联 ID (relate_id)'; COMMENT ON COLUMN billiards.fact_payment.site_id IS '门店 ID（冗余自 payload）'; COMMENT ON COLUMN billiards.fact_payment.tenant_id IS '租户 ID'; COMMENT ON COLUMN billiards.fact_payment.pay_time IS '支付时间 (payTime)'; COMMENT ON COLUMN billiards.fact_payment.create_time IS '创建时间 (create_time)'; COMMENT ON COLUMN billiards.fact_payment.pay_amount IS '支付金额 (payAmount)'; COMMENT ON COLUMN billiards.fact_payment.pay_type IS '支付渠道 (payType)'; COMMENT ON COLUMN billiards.fact_payment.payment_method IS '支付方式 (payment_method)'; COMMENT ON COLUMN billiards.fact_payment.online_pay_channel IS '线上支付渠道 (online_pay_channel)'; COMMENT ON COLUMN billiards.fact_payment.pay_status IS '支付状态 (payStatus)'; COMMENT ON COLUMN billiards.fact_payment.pay_terminal IS '支付终端 (pay_terminal)'; COMMENT ON COLUMN billiards.fact_payment.remark IS '备注'; COMMENT ON COLUMN billiards.fact_payment.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.fact_payment.updated_at IS 'ETL 更新时间'; CREATE TABLE IF NOT EXISTS billiards.fact_refund ( store_id bigint NOT NULL, refund_id bigint NOT NULL, site_id bigint, tenant_id bigint, pay_amount numeric(14,4), pay_status varchar(30), pay_time timestamptz, create_time timestamptz, relate_type varchar(50), relate_id bigint, payment_method varchar(50), refund_amount numeric(14,4), action_type varchar(30), pay_terminal varchar(50), operator_id bigint, channel_pay_no varchar(100), channel_fee numeric(14,4), is_delete integer, member_id bigint, member_card_id bigint, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, refund_id) ); COMMENT ON TABLE billiards.fact_refund IS '退款流水（Pay/RefundList）'; COMMENT ON COLUMN billiards.fact_refund.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.fact_refund.refund_id IS '退款记录 ID (id)'; COMMENT ON COLUMN billiards.fact_refund.site_id IS '场地 ID (site_id)'; COMMENT ON COLUMN billiards.fact_refund.tenant_id IS '租户 ID (tenant_id)'; COMMENT ON COLUMN billiards.fact_refund.pay_amount IS '原支付金额 (pay_amount)'; COMMENT ON COLUMN billiards.fact_refund.pay_status IS '支付状态 (pay_status)'; COMMENT ON COLUMN billiards.fact_refund.pay_time IS '支付时间 (pay_time)'; COMMENT ON COLUMN billiards.fact_refund.create_time IS '创建时间 (create_time)'; COMMENT ON COLUMN billiards.fact_refund.relate_type IS '关联对象类型 (relate_type)'; COMMENT ON COLUMN billiards.fact_refund.relate_id IS '关联对象 ID (relate_id)'; COMMENT ON COLUMN billiards.fact_refund.payment_method IS '支付方式 (payment_method)'; COMMENT ON COLUMN billiards.fact_refund.refund_amount IS '退款金额 (refund_amount)'; COMMENT ON COLUMN billiards.fact_refund.action_type IS '操作类型 (action_type)'; COMMENT ON COLUMN billiards.fact_refund.pay_terminal IS '终端类型 (pay_terminal)'; COMMENT ON COLUMN billiards.fact_refund.operator_id IS '操作人 ID (operator_id)'; COMMENT ON COLUMN billiards.fact_refund.channel_pay_no IS '渠道支付单号 (channel_pay_no)'; COMMENT ON COLUMN billiards.fact_refund.channel_fee IS '渠道手续费 (channel_fee)'; COMMENT ON COLUMN billiards.fact_refund.is_delete IS '删除标记 (is_delete)'; COMMENT ON COLUMN billiards.fact_refund.member_id IS '会员 ID (member_id)'; COMMENT ON COLUMN billiards.fact_refund.member_card_id IS '会员卡 ID (member_card_id)'; COMMENT ON COLUMN billiards.fact_refund.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.fact_refund.updated_at IS 'ETL 更新时间'; CREATE TABLE IF NOT EXISTS billiards.fact_table_discount ( store_id bigint NOT NULL, discount_id bigint NOT NULL, adjust_type varchar(50), applicant_id bigint, applicant_name varchar(100), operator_id bigint, operator_name varchar(100), ledger_amount numeric(14,4), ledger_count numeric(14,4), ledger_name varchar(100), ledger_status varchar(30), order_settle_id bigint, order_trade_no bigint, site_table_id bigint, table_area_id bigint, table_area_name varchar(100), create_time timestamptz, is_delete integer, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, discount_id) ); COMMENT ON TABLE billiards.fact_table_discount IS '台费调价/折扣记录（Table/AdjustList）'; COMMENT ON COLUMN billiards.fact_table_discount.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.fact_table_discount.discount_id IS '调价记录 ID (id)'; COMMENT ON COLUMN billiards.fact_table_discount.adjust_type IS '调价类型 (adjust_type/adjustType)'; COMMENT ON COLUMN billiards.fact_table_discount.applicant_id IS '申请人 ID (applicant_id)'; COMMENT ON COLUMN billiards.fact_table_discount.applicant_name IS '申请人姓名 (applicant_name)'; COMMENT ON COLUMN billiards.fact_table_discount.operator_id IS '操作人 ID (operator_id)'; COMMENT ON COLUMN billiards.fact_table_discount.operator_name IS '操作人姓名 (operator_name)'; COMMENT ON COLUMN billiards.fact_table_discount.ledger_amount IS '台费金额调整 (ledger_amount)'; COMMENT ON COLUMN billiards.fact_table_discount.ledger_count IS '台费数量调整 (ledger_count)'; COMMENT ON COLUMN billiards.fact_table_discount.ledger_name IS '科目名称 (ledger_name)'; COMMENT ON COLUMN billiards.fact_table_discount.ledger_status IS '记录状态 (ledger_status)'; COMMENT ON COLUMN billiards.fact_table_discount.order_settle_id IS '结算单 ID (order_settle_id)'; COMMENT ON COLUMN billiards.fact_table_discount.order_trade_no IS '订单号 (order_trade_no)'; COMMENT ON COLUMN billiards.fact_table_discount.site_table_id IS '台桌 ID (site_table_id)'; COMMENT ON COLUMN billiards.fact_table_discount.table_area_id IS '台桌区域 ID'; COMMENT ON COLUMN billiards.fact_table_discount.table_area_name IS '台桌区域名称'; COMMENT ON COLUMN billiards.fact_table_discount.create_time IS '创建时间 (create_time)'; COMMENT ON COLUMN billiards.fact_table_discount.is_delete IS '删除标记 (is_delete)'; COMMENT ON COLUMN billiards.fact_table_discount.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.fact_table_discount.updated_at IS 'ETL 更新时间'; CREATE TABLE IF NOT EXISTS billiards.fact_topup ( store_id bigint NOT NULL, topup_id bigint NOT NULL, member_id bigint, member_name varchar(100), member_phone varchar(30), card_id bigint, card_type_name varchar(100), pay_amount numeric(14,4), consume_money numeric(14,4), settle_status varchar(30), settle_type varchar(30), settle_name varchar(100), settle_relate_id bigint, pay_time timestamptz, create_time timestamptz, operator_id bigint, operator_name varchar(100), payment_method varchar(50), refund_amount numeric(14,4), cash_amount numeric(14,4), card_amount numeric(14,4), balance_amount numeric(14,4), online_amount numeric(14,4), rounding_amount numeric(14,4), adjust_amount numeric(14,4), goods_money numeric(14,4), table_charge_money numeric(14,4), service_money numeric(14,4), coupon_amount numeric(14,4), order_remark text, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, topup_id) ); COMMENT ON TABLE billiards.fact_topup IS '储值充值结算流水（Topup/SettleList）'; COMMENT ON COLUMN billiards.fact_topup.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.fact_topup.topup_id IS '充值记录 ID (id)'; COMMENT ON COLUMN billiards.fact_topup.member_id IS '会员 ID (memberId)'; COMMENT ON COLUMN billiards.fact_topup.member_name IS '会员姓名 (memberName)'; COMMENT ON COLUMN billiards.fact_topup.member_phone IS '会员手机号 (memberPhone)'; COMMENT ON COLUMN billiards.fact_topup.card_id IS '会员卡 ID (tenantMemberCardId)'; COMMENT ON COLUMN billiards.fact_topup.card_type_name IS '会员卡类型名称 (memberCardTypeName)'; COMMENT ON COLUMN billiards.fact_topup.pay_amount IS '支付金额 (payAmount)'; COMMENT ON COLUMN billiards.fact_topup.consume_money IS '可消费金额/储值 (consumeMoney)'; COMMENT ON COLUMN billiards.fact_topup.settle_status IS '结算状态 (settleStatus)'; COMMENT ON COLUMN billiards.fact_topup.settle_type IS '结算方式 (settleType)'; COMMENT ON COLUMN billiards.fact_topup.settle_name IS '结算名称 (settleName)'; COMMENT ON COLUMN billiards.fact_topup.settle_relate_id IS '结算关联 ID (settleRelateId)'; COMMENT ON COLUMN billiards.fact_topup.pay_time IS '支付时间 (payTime)'; COMMENT ON COLUMN billiards.fact_topup.create_time IS '创建时间 (createTime)'; COMMENT ON COLUMN billiards.fact_topup.operator_id IS '操作人 ID (operatorId)'; COMMENT ON COLUMN billiards.fact_topup.operator_name IS '操作人姓名 (operatorName)'; COMMENT ON COLUMN billiards.fact_topup.payment_method IS '支付方式 (paymentMethod)'; COMMENT ON COLUMN billiards.fact_topup.refund_amount IS '退款金额 (refundAmount)'; COMMENT ON COLUMN billiards.fact_topup.cash_amount IS '现金金额 (cashAmount)'; COMMENT ON COLUMN billiards.fact_topup.card_amount IS '银行卡金额 (cardAmount)'; COMMENT ON COLUMN billiards.fact_topup.balance_amount IS '余额抵扣金额 (balanceAmount)'; COMMENT ON COLUMN billiards.fact_topup.online_amount IS '在线支付金额 (onlineAmount)'; COMMENT ON COLUMN billiards.fact_topup.rounding_amount IS '抹零金额 (roundingAmount)'; COMMENT ON COLUMN billiards.fact_topup.adjust_amount IS '调整金额 (adjustAmount)'; COMMENT ON COLUMN billiards.fact_topup.goods_money IS '商品金额 (goodsMoney)'; COMMENT ON COLUMN billiards.fact_topup.table_charge_money IS '台费金额 (tableChargeMoney)'; COMMENT ON COLUMN billiards.fact_topup.service_money IS '服务费 (serviceMoney)'; COMMENT ON COLUMN billiards.fact_topup.coupon_amount IS '券抵扣金额 (couponAmount)'; COMMENT ON COLUMN billiards.fact_topup.order_remark IS '备注 (orderRemark)'; COMMENT ON COLUMN billiards.fact_topup.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.fact_topup.updated_at IS 'ETL 更新时间'; CREATE TABLE IF NOT EXISTS billiards.fact_coupon_usage ( store_id bigint NOT NULL, usage_id bigint NOT NULL, coupon_code varchar(100), coupon_channel varchar(50), coupon_name varchar(200), sale_price numeric(14,4), coupon_money numeric(14,4), coupon_free_time integer, use_status varchar(30), create_time timestamptz, consume_time timestamptz, operator_id bigint, operator_name varchar(100), table_id bigint, site_order_id bigint, group_package_id bigint, coupon_remark text, deal_id varchar(100), certificate_id varchar(100), verify_id varchar(100), is_delete integer, raw_data jsonb NOT NULL DEFAULT '{}'::jsonb, updated_at timestamptz NOT NULL DEFAULT now(), PRIMARY KEY (store_id, usage_id) ); COMMENT ON TABLE billiards.fact_coupon_usage IS '平台券验券/核销流水（Coupon/UsageList）'; COMMENT ON COLUMN billiards.fact_coupon_usage.store_id IS '门店 ID'; COMMENT ON COLUMN billiards.fact_coupon_usage.usage_id IS '核销记录 ID (id)'; COMMENT ON COLUMN billiards.fact_coupon_usage.coupon_code IS '券码 (coupon_code)'; COMMENT ON COLUMN billiards.fact_coupon_usage.coupon_channel IS '券渠道 (coupon_channel)'; COMMENT ON COLUMN billiards.fact_coupon_usage.coupon_name IS '券名称 (coupon_name)'; COMMENT ON COLUMN billiards.fact_coupon_usage.sale_price IS '售卖价 (sale_price)'; COMMENT ON COLUMN billiards.fact_coupon_usage.coupon_money IS '券面额 (coupon_money)'; COMMENT ON COLUMN billiards.fact_coupon_usage.coupon_free_time IS '赠送/免单时长 (coupon_free_time)'; COMMENT ON COLUMN billiards.fact_coupon_usage.use_status IS '核销状态 (use_status)'; COMMENT ON COLUMN billiards.fact_coupon_usage.create_time IS '创建时间 (create_time)'; COMMENT ON COLUMN billiards.fact_coupon_usage.consume_time IS '核销时间 (consume_time)'; COMMENT ON COLUMN billiards.fact_coupon_usage.operator_id IS '操作人 ID (operator_id)'; COMMENT ON COLUMN billiards.fact_coupon_usage.operator_name IS '操作人姓名 (operator_name)'; COMMENT ON COLUMN billiards.fact_coupon_usage.table_id IS '台桌 ID (table_id)'; COMMENT ON COLUMN billiards.fact_coupon_usage.site_order_id IS '场馆订单 ID (site_order_id)'; COMMENT ON COLUMN billiards.fact_coupon_usage.group_package_id IS '套餐 ID (group_package_id)'; COMMENT ON COLUMN billiards.fact_coupon_usage.coupon_remark IS '备注 (coupon_remark)'; COMMENT ON COLUMN billiards.fact_coupon_usage.deal_id IS '团购/渠道 deal_id'; COMMENT ON COLUMN billiards.fact_coupon_usage.certificate_id IS '凭证号 (certificate_id)'; COMMENT ON COLUMN billiards.fact_coupon_usage.verify_id IS '核销流水号 (verify_id)'; COMMENT ON COLUMN billiards.fact_coupon_usage.is_delete IS '删除标记 (is_delete)'; COMMENT ON COLUMN billiards.fact_coupon_usage.raw_data IS '原始 JSON'; COMMENT ON COLUMN billiards.fact_coupon_usage.updated_at IS 'ETL 更新时间'; -- ========================= -- ETL admin tables -- ========================= CREATE TYPE IF NOT EXISTS etl_admin.run_status_enum AS ENUM ('SUCC', 'FAIL', 'PARTIAL'); COMMENT ON TYPE etl_admin.run_status_enum IS 'ETL 运行状态枚举（成功/失败/部分成功）'; CREATE TABLE IF NOT EXISTS etl_admin.etl_task ( task_id bigserial PRIMARY KEY, store_id bigint NOT NULL, task_code varchar(50) NOT NULL, description text, enabled boolean NOT NULL DEFAULT true, cursor_field varchar(100), window_minutes_default integer DEFAULT 60, overlap_seconds integer DEFAULT 120, page_size integer DEFAULT 200, retry_max integer DEFAULT 3, params jsonb NOT NULL DEFAULT '{}'::jsonb, created_at timestamptz NOT NULL DEFAULT now(), updated_at timestamptz NOT NULL DEFAULT now(), UNIQUE (store_id, task_code) ); COMMENT ON TABLE etl_admin.etl_task IS 'ETL 任务配置（启停、窗口、分页参数等）'; COMMENT ON COLUMN etl_admin.etl_task.task_id IS '任务 ID（自增主键）'; COMMENT ON COLUMN etl_admin.etl_task.store_id IS '门店 ID（任务所属门店）'; COMMENT ON COLUMN etl_admin.etl_task.task_code IS '任务代码（如 PRODUCTS、ORDERS）'; COMMENT ON COLUMN etl_admin.etl_task.description IS '任务描述'; COMMENT ON COLUMN etl_admin.etl_task.enabled IS '是否启用'; COMMENT ON COLUMN etl_admin.etl_task.cursor_field IS '游标使用的字段（如时间或 ID）'; COMMENT ON COLUMN etl_admin.etl_task.window_minutes_default IS '默认抓取窗口（分钟）'; COMMENT ON COLUMN etl_admin.etl_task.overlap_seconds IS '窗口重叠秒数，用于防重'; COMMENT ON COLUMN etl_admin.etl_task.page_size IS 'API 分页大小'; COMMENT ON COLUMN etl_admin.etl_task.retry_max IS 'API 最大重试次数'; COMMENT ON COLUMN etl_admin.etl_task.params IS '额外参数 (JSON)'; COMMENT ON COLUMN etl_admin.etl_task.created_at IS '创建时间'; COMMENT ON COLUMN etl_admin.etl_task.updated_at IS '更新时间'; CREATE TABLE IF NOT EXISTS etl_admin.etl_cursor ( cursor_id bigserial PRIMARY KEY, task_id bigint NOT NULL REFERENCES etl_admin.etl_task(task_id) ON DELETE CASCADE, store_id bigint NOT NULL, last_start timestamptz, last_end timestamptz, last_id bigint, extra jsonb NOT NULL DEFAULT '{}'::jsonb, last_run_id bigint, updated_at timestamptz NOT NULL DEFAULT now(), UNIQUE (task_id, store_id) ); COMMENT ON TABLE etl_admin.etl_cursor IS 'ETL 游标存储（记录每个任务的上次窗口与 ID）'; COMMENT ON COLUMN etl_admin.etl_cursor.cursor_id IS '游标主键'; COMMENT ON COLUMN etl_admin.etl_cursor.task_id IS '关联任务 ID'; COMMENT ON COLUMN etl_admin.etl_cursor.store_id IS '门店 ID'; COMMENT ON COLUMN etl_admin.etl_cursor.last_start IS '上次窗口起始时间'; COMMENT ON COLUMN etl_admin.etl_cursor.last_end IS '上次窗口结束时间'; COMMENT ON COLUMN etl_admin.etl_cursor.last_id IS '上次处理的 ID（适用于基于 ID 的翻页）'; COMMENT ON COLUMN etl_admin.etl_cursor.extra IS '额外游标信息 (JSON)'; COMMENT ON COLUMN etl_admin.etl_cursor.last_run_id IS '最后一次运行 run_id'; COMMENT ON COLUMN etl_admin.etl_cursor.updated_at IS '更新时间'; CREATE TABLE IF NOT EXISTS etl_admin.etl_run ( run_id bigserial PRIMARY KEY, run_uuid varchar(64) NOT NULL, task_id bigint NOT NULL REFERENCES etl_admin.etl_task(task_id) ON DELETE CASCADE, store_id bigint NOT NULL, status etl_admin.run_status_enum NOT NULL DEFAULT 'SUCC', started_at timestamptz NOT NULL DEFAULT now(), ended_at timestamptz, window_start timestamptz, window_end timestamptz, window_minutes integer, overlap_seconds integer, fetched_count integer DEFAULT 0, loaded_count integer DEFAULT 0, updated_count integer DEFAULT 0, skipped_count integer DEFAULT 0, error_count integer DEFAULT 0, unknown_fields integer DEFAULT 0, export_dir text, log_path text, request_params jsonb NOT NULL DEFAULT '{}'::jsonb, manifest jsonb NOT NULL DEFAULT '{}'::jsonb, error_message text, extra jsonb NOT NULL DEFAULT '{}'::jsonb ); CREATE INDEX IF NOT EXISTS idx_etl_run_task ON etl_admin.etl_run(task_id, started_at DESC); CREATE INDEX IF NOT EXISTS idx_etl_run_status ON etl_admin.etl_run(status); COMMENT ON TABLE etl_admin.etl_run IS 'ETL 运行记录（针对每次任务执行）'; COMMENT ON COLUMN etl_admin.etl_run.run_id IS '运行记录 ID'; COMMENT ON COLUMN etl_admin.etl_run.run_uuid IS '运行批次 UUID'; COMMENT ON COLUMN etl_admin.etl_run.task_id IS '任务 ID'; COMMENT ON COLUMN etl_admin.etl_run.store_id IS '门店 ID'; COMMENT ON COLUMN etl_admin.etl_run.status IS '运行状态 (SUCC/FAIL/PARTIAL)'; COMMENT ON COLUMN etl_admin.etl_run.started_at IS '开始时间'; COMMENT ON COLUMN etl_admin.etl_run.ended_at IS '结束时间'; COMMENT ON COLUMN etl_admin.etl_run.window_start IS '窗口起始时间'; COMMENT ON COLUMN etl_admin.etl_run.window_end IS '窗口结束时间'; COMMENT ON COLUMN etl_admin.etl_run.window_minutes IS '窗口长度（分钟）'; COMMENT ON COLUMN etl_admin.etl_run.overlap_seconds IS '重叠秒数'; COMMENT ON COLUMN etl_admin.etl_run.fetched_count IS '抓取条数'; COMMENT ON COLUMN etl_admin.etl_run.loaded_count IS '插入条数'; COMMENT ON COLUMN etl_admin.etl_run.updated_count IS '更新条数'; COMMENT ON COLUMN etl_admin.etl_run.skipped_count IS '跳过条数'; COMMENT ON COLUMN etl_admin.etl_run.error_count IS '错误条数'; COMMENT ON COLUMN etl_admin.etl_run.unknown_fields IS '未知字段次数'; COMMENT ON COLUMN etl_admin.etl_run.export_dir IS '导出目录'; COMMENT ON COLUMN etl_admin.etl_run.log_path IS '日志文件路径'; COMMENT ON COLUMN etl_admin.etl_run.request_params IS '本次请求参数 (JSON)'; COMMENT ON COLUMN etl_admin.etl_run.manifest IS '导出 manifest (JSON)'; COMMENT ON COLUMN etl_admin.etl_run.error_message IS '错误信息'; COMMENT ON COLUMN etl_admin.etl_run.extra IS '额外信息 (JSON)';