Dify工作流实践：text2Sql与图表生成

### 用户表CREATE TABLE users (    id SERIAL PRIMARY KEY, --用户ID，主键    username VARCHAR(50) NOT NULL UNIQUE, --用户名    phone VARCHAR(11) NOT NULL UNIQUE, --手机号    email VARCHAR(100) UNIQUE, --电子邮箱（唯一）    address VARCHAR(200), --收货地址    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP --创建时间);
### 产品表CREATE TABLE products (    id SERIAL PRIMARY KEY, --商品ID，主键    product_name VARCHAR(100) NOT NULL, --商品名称    price NUMERIC(10,2) NOT NULL CHECK (price > 0), --商品价格（必须＞0）    stock INT NOT NULL CHECK (stock >= 0), --库存数量（必须≥0）    status VARCHAR(10) CHECK (status IN ('上架', '下架')),  --商品状态（上架/下架）    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP --创建时间);
### 订单表CREATE TABLE orders (    id SERIAL PRIMARY KEY, --订单ID，主键    user_id INT REFERENCES users(id), --用户ID，外键关联users.id    order_no VARCHAR(20) NOT NULL UNIQUE, --订单编号    total_amount NUMERIC(10,2) NOT NULL, --订单总金额    status VARCHAR(10) CHECK (status IN ('已付款', '已发货', '已完成', '已取消')), --订单状态(已付款/已发货/已完成/已取消)    order_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP --下单时间);
### 订单明细表CREATE TABLE order_items (    id SERIAL PRIMARY KEY, --明细ID，主键    order_id INT REFERENCES orders(id), --订单ID，外键关联orders.id    product_id INT REFERENCES products(id), --商品ID，外键关联products.id    quantity INT NOT NULL CHECK (quantity > 0), --购买数量（必须＞0）    unit_price NUMERIC(10,2) NOT NULL, --下单时的商品单价    total_price NUMERIC(10,2) GENERATED ALWAYS AS (quantity * unit_price) stored --明细总价（自动计算：数量×单价）);

INSERT INTO users (username,phone,email,address,created_at) VALUES ('张三','13812345678','zhangsan@example.com','北京市朝阳区','2025-05-07 20:31:34.510'),('李四','13987654321','lisi@example.com','上海市浦东新区','2025-05-07 20:31:34.510'),('王五','13698765432','wangwu@example.com','广州市天河区','2025-05-07 20:31:34.510'),('赵六','13312341234','zhaoliu@example.com','深证福田区','2025-05-09 13:46:45.036');INSERT INTO products (product_name,price,stock,status,created_at) VALUES ('智能手机',2999.00,100,'上架','2025-05-07 20:31:38.313'),('无线耳机',499.00,200,'上架','2025-05-07 20:31:38.313'),('智能手表',899.00,50,'上架','2025-05-07 20:31:38.313'),('笔记本电脑',7999.00,30,'下架','2025-05-07 20:31:38.313'),('蓝牙鼠标',59.00,1000,'上架','2025-05-09 13:48:00.413'),('智能音箱',199.00,150,'上架','2025-05-09 13:48:31.846');INSERT INTO orders (user_id,order_no,total_amount,status,order_time) VALUES (2,'ORDER20231001567',1398.00,'已发货','2025-05-07 20:32:03.184'),(1,'ORDER20231001123',3997.00,'已付款','2025-05-07 20:32:03.184'),(3,'ORDER20231001999',8998.00,'已取消','2025-05-07 20:32:03.184'),(4,'ORDER20250509213',558.00,'已付款','2025-05-09 13:51:30.838');INSERT INTO order_items (order_id,product_id,quantity,unit_price,total_price) VALUES (1,1,1,2999.00,2999.00),(1,2,2,499.00,998.00),(2,3,1,899.00,899.00),(2,2,1,499.00,499.00),(3,4,1,7999.00,7999.00),(3,3,1,899.00,899.00),(4,2,1,499.00,499.00),(4,5,1,59.00,59.00);

#prompt提示词【角色设定】您是一位资深数据库专家，擅长根据业务需求将自然语言精准转换为符合规范的SQL语句。您具有以下核心能力：1. 精通关系型数据库设计，尤其熟悉PostgreSQL语法2. 深入理解当前业务系统的表结构{{#context#}}3. 能准确识别业务需求中的隐藏条件4. 熟悉SQL性能优化和事务控制
【输入处理流程】1. 结构确认：先验证涉及的表是否存在，检查字段名是否准确2. 关联分析：确认多表关联时的连接条件是否正确3. 条件推导：将模糊的业务描述转化为精确的WHERE条件4. 异常处理：识别可能存在的逻辑矛盾或性能陷阱
【输出要求】输出sql中不要添加注释信息采用如下格式返回结果：[符合ANSI标准的SQL语句]
【示例】用户问题："查询北京用户最近一个月购买过智能手机的订单"输出：-- 查询北京用户近一个月购买智能手机的订单SELECT o.order_no, u.username, oi.total_price, o.order_time FROM orders oJOIN users u ON o.user_id = u.idJOIN order_items oi ON o.id = oi.order_idJOIN products p ON oi.product_id = p.idWHERE u.address LIKE '北京市%'  AND p.product_name = '智能手机'  AND o.order_time >= CURRENT_DATE - INTERVAL '1 month'  AND o.status NOT IN ('已取消') ORDER BY o.order_time DESC;

#prompt提示词你是一个问答机器人。你的任务是根据下述给定的已知信息回答用户问题，回答的内容尽量通俗易懂。确保你的回复完全依据下述已知信息。不要编造答案。如果下述已知信息不足以回答用户的问题，请直接回复"我无法回答您的问题"。
已知信息:{{#1746692457950.text#}}
用户问：{{#sys.query#}}
请用中文字符串文本回答用户问题。

#prompt提示词你是一个专业的ECharts图表生成器，严格遵循以下规则：
输入规则：1. 接收格式：{{#context#}} + {{#sys.query#}}2. 仅当输入包含可图表化的结构化数据时响应
处理规则：1. 自动识别数据类型（数值/分类/时间序列等）2. 智能匹配最佳图表类型（柱状/折线/饼图等）3. 默认启用响应式布局
输出规则：1. 必须为字符串```echarts拼接上json字符串格式的echarts内容2. 包含完整option配置3. 务必不要添加注释或说明的文本4. 无效输入返回空字符串

with TopCustomers as (select	u.id as user_id, u.username, SUM(o.total_amount) as total_spent_this_monthfrom	users ujoin orders o on	u.id = o.user_idwhere	o.order_time >= date_trunc('month', CURRENT_DATE)and o.order_time < date_trunc('month', CURRENT_DATE) + interval '1 month'and o.status not in ('已取消', '待付款')group by	u.id, u.usernameorder by	total_spent_this_month desclimit 3 ),CustomerProductDetails as (select	tc.user_id, tc.username, tc.total_spent_this_month, p.product_name, 	SUM(oi.quantity) as total_quantity_bought, SUM(oi.total_price) as amount_spent_on_productfrom	TopCustomers tcjoin orders o on	tc.user_id = o.user_idjoin order_items oi on	o.id = oi.order_idjoin products p on	oi.product_id = p.idwhere	o.order_time >= date_trunc('month', CURRENT_DATE)and o.order_time < date_trunc('month', CURRENT_DATE) + interval '1 month'and o.status not in ('已取消', '待付款')group by	tc.user_id, tc.username, tc.total_spent_this_month, p.product_name )select	cpd.username,	cpd.total_spent_this_month,	cpd.product_name,	cpd.total_quantity_boughtfrom	CustomerProductDetails cpdorder by	cpd.total_spent_this_month desc,	cpd.username,	cpd.total_quantity_bought desc;