# Cursor 自动任务执行指令

**重要：请立即执行以下任务！**

**生成时间**: 2026-01-13 19:15:13

**待执行任务数量**: 2

## 任务完成后的操作

完成每个任务后，请更新 `tasks/pending_tasks.json` 中对应任务的 `status` 为 `completed`，
并填写 `code_name`（代码文件名）和 `code_path`（代码路径）。

调度脚本会自动将完成的任务同步到数据库。

## 任务约束要求

**重要约束**：完成脚本创建后，**不需要生成任务总结文件**。

- 不要创建任何 summary、report、总结类的文档文件
- 不要生成 task_summary.md、execution_report.md 等总结文件
- 只需创建任务要求的功能脚本文件
- 只需更新 `tasks/pending_tasks.json` 中的任务状态

---

## 任务 1: 导入产品库存表原始数据

- **任务ID**: `26`
- **创建时间**: 2026-01-13 18:02:57
- **创建者**: cursor

### 任务描述

# Task: 导入产品库存表原始数据

## DataFlow Configuration
- **Schema**: dags

## Data Source
- **Type**: RDBMS
- **Host**: 192.168.3.143
- **Port**: 5432
- **Database**: dataops

## Target Tables (DDL)
```sql
CREATE TABLE test_product_inventory (
    updated_at timestamp COMMENT '更新时间',
    created_at timestamp COMMENT '创建时间',
    is_active boolean COMMENT '是否启用',
    turnover_rate numeric(5, 2) COMMENT '周转率',
    outbound_quantity_30d integer COMMENT '30天出库数量',
    inbound_quantity_30d integer COMMENT '30天入库数量',
    last_outbound_date date COMMENT '最近出库日期',
    last_inbound_date date COMMENT '最近入库日期',
    stock_status varchar(50) COMMENT '库存状态',
    selling_price numeric(10, 2) COMMENT '销售价格',
    unit_cost numeric(10, 2) COMMENT '单位成本',
    max_stock integer COMMENT '最大库存',
    safety_stock integer COMMENT '安全库存',
    current_stock integer COMMENT '当前库存',
    warehouse varchar(100) COMMENT '仓库',
    supplier varchar(200) COMMENT '供应商',
    brand varchar(100) COMMENT '品牌',
    category varchar(100) COMMENT '类别',
    product_name varchar(200) COMMENT '产品名称',
    sku varchar(50) COMMENT 'SKU',
    id serial COMMENT 'ID',
    create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '数据创建时间'
);
COMMENT ON TABLE test_product_inventory IS '产品库存表';
```

## Update Mode
- **Mode**: Append (追加模式)
- **Description**: 新数据将追加到目标表，不删除现有数据

## Request Content
从数据源的原始数据表导入数据资源中的产品库存表

## Implementation Steps
1. Create an n8n workflow to execute the data import task
2. Configure the workflow to call `import_resource_data.py` Python script
3. Pass the following parameters to the Python execution node:
   - `--source-config`: JSON configuration for the remote data source
   - `--target-table`: Target table name (data resource English name)
   - `--update-mode`: append
4. The Python script will automatically:
   - Connect to the remote data source
   - Extract data from the source table
   - Write data to target table using append mode

---

## 任务 2: DF_DO202601130001

- **任务ID**: `27`
- **创建时间**: 2026-01-13 18:04:21
- **创建者**: system

### 任务描述

# Task: DF_DO202601130001

## DataFlow Configuration
- **DataFlow ID**: 2220
- **DataFlow Name**: 仓库库存汇总表_数据流程
- **Order ID**: 17
- **Order No**: DO202601130001

## Source Tables
- 产品库存表

## Target Table
- 仓库库存汇总表

## Update Mode
- **Mode**: Full Refresh (全量更新)
- **Description**: 目标表将被清空后重新写入数据

## Request Content
1.从产品库存表中提取字段：仓库编号、产品编号、库存数量；2.对库存数量进行按仓库编号进行求和计算；3.无特殊过滤条件；4.最终输出数据格式包含字段：仓库编号、总库存数量

## Implementation Steps
1. 连接数据源，读取源数据表
2. 根据处理逻辑执行数据转换
3. 写入目标数据表
4. 完成后回调更新订单状态为 onboard

---