flinksql 汇总订单表关联订单明细，实时汇总不同门店不同商品的金额，数量

在Flink SQL中，可以通过编写SQL查询语句来实时汇总不同门店不同商品的金额和数量。具体步骤如下：

1. **创建订单表和订单明细表**：假设我们有两个表，一个是订单表（orders），包含订单的基本信息；另一个是订单明细表（order_items），包含每个订单的详细信息。

2. **编写Flink SQL查询**：使用JOIN操作将订单表和订单明细表关联起来，并使用GROUP BY进行分组汇总。

以下是一个示例SQL查询语句：

CREATE TABLE orders (
    order_id STRING,
    store_id STRING,
    order_time TIMESTAMP,
    total_amount DECIMAL(10, 2),
    PRIMARY KEY (order_id) NOT ENFORCED
) WITH (
    -- 定义订单表的连接参数
);

CREATE TABLE order_items (
    item_id STRING,
    order_id STRING,
    product_id STRING,
    quantity INT,
    price DECIMAL(10, 2),
    PRIMARY KEY (item_id) NOT ENFORCED
) WITH (
    -- 定义订单明细表的连接参数
);

CREATE TABLE aggregated_result (
    store_id STRING,
    product_id STRING,
    total_amount DECIMAL(10, 2),
    total_quantity INT,
    window_start TIMESTAMP,
    window_end TIMESTAMP,
    PRIMARY KEY (store_id, product_id, window_start, window_end) NOT ENFORCED
) WITH (
    -- 定义结果表的连接参数
);

INSERT INTO aggregated_result
SELECT
    o.store_id,
    i.product_id,
    SUM(i.quantity * i.price) AS total_amount,
    SUM(i.quantity) AS total_quantity,
    TUMBLE_START(o.order_time, INTERVAL '1' HOUR) AS window_start,
    TUMBLE_END(o.order_time, INTERVAL '1' HOUR) AS window_end
FROM
    orders o
JOIN
    order_items i
ON
    o.order_id = i.order_id
GROUP BY
    o.store_id,
    i.product_id,
    TUMBLE(o.order_time, INTERVAL '1' HOUR);

在这个示例中：
- `orders` 表和 `order_items` 表通过 `order_id` 进行关联。
- 使用 `SUM` 函数计算总金额和总数量。
- 使用 `TUMBLE` 函数进行时间窗口的划分，这里以1小时为窗口。