版本更改
This commit is contained in:
@@ -191,8 +191,6 @@ pytest --cov=. --cov-report=html
|
|||||||
- `tests/unit/test_parsers.py` – 解析器单元测试
|
- `tests/unit/test_parsers.py` – 解析器单元测试
|
||||||
- `tests/integration/test_database.py` – 数据库集成测试
|
- `tests/integration/test_database.py` – 数据库集成测试
|
||||||
|
|
||||||
<<<<<<< HEAD
|
|
||||||
=======
|
|
||||||
#### 3.3.1 测试模式(ONLINE / OFFLINE)
|
#### 3.3.1 测试模式(ONLINE / OFFLINE)
|
||||||
|
|
||||||
- `TEST_MODE=ONLINE`(默认)时,测试会模拟实时 API,完整执行 E/T/L。
|
- `TEST_MODE=ONLINE`(默认)时,测试会模拟实时 API,完整执行 E/T/L。
|
||||||
@@ -221,7 +219,6 @@ python scripts/run_tests.py --preset offline_realdb
|
|||||||
python scripts/run_tests.py --list-presets # 查看或自定义 scripts/test_presets.py
|
python scripts/run_tests.py --list-presets # 查看或自定义 scripts/test_presets.py
|
||||||
```
|
```
|
||||||
|
|
||||||
>>>>>>> main
|
|
||||||
---
|
---
|
||||||
|
|
||||||
## 4. 项目结构与文件说明
|
## 4. 项目结构与文件说明
|
||||||
@@ -308,11 +305,8 @@ etl_billiards/
|
|||||||
│ │ ├── __init__.py
|
│ │ ├── __init__.py
|
||||||
│ │ ├── test_config.py
|
│ │ ├── test_config.py
|
||||||
│ │ └── test_parsers.py
|
│ │ └── test_parsers.py
|
||||||
<<<<<<< HEAD
|
|
||||||
=======
|
|
||||||
│ ├── testdata_json/ # 清洗入库用的测试Json文件
|
│ ├── testdata_json/ # 清洗入库用的测试Json文件
|
||||||
│ │ └── XX.json
|
│ │ └── XX.json
|
||||||
>>>>>>> main
|
|
||||||
│ └── integration/ # 集成测试
|
│ └── integration/ # 集成测试
|
||||||
│ ├── __init__.py
|
│ ├── __init__.py
|
||||||
│ └── test_database.py
|
│ └── test_database.py
|
||||||
|
|||||||
@@ -3,8 +3,6 @@
|
|||||||
from tasks.orders_task import OrdersTask
|
from tasks.orders_task import OrdersTask
|
||||||
from tasks.payments_task import PaymentsTask
|
from tasks.payments_task import PaymentsTask
|
||||||
from tasks.members_task import MembersTask
|
from tasks.members_task import MembersTask
|
||||||
<<<<<<< HEAD
|
|
||||||
=======
|
|
||||||
from tasks.products_task import ProductsTask
|
from tasks.products_task import ProductsTask
|
||||||
from tasks.tables_task import TablesTask
|
from tasks.tables_task import TablesTask
|
||||||
from tasks.assistants_task import AssistantsTask
|
from tasks.assistants_task import AssistantsTask
|
||||||
@@ -16,7 +14,6 @@ from tasks.topups_task import TopupsTask
|
|||||||
from tasks.table_discount_task import TableDiscountTask
|
from tasks.table_discount_task import TableDiscountTask
|
||||||
from tasks.assistant_abolish_task import AssistantAbolishTask
|
from tasks.assistant_abolish_task import AssistantAbolishTask
|
||||||
from tasks.ledger_task import LedgerTask
|
from tasks.ledger_task import LedgerTask
|
||||||
>>>>>>> main
|
|
||||||
|
|
||||||
class TaskRegistry:
|
class TaskRegistry:
|
||||||
"""任务注册和工厂"""
|
"""任务注册和工厂"""
|
||||||
@@ -44,12 +41,6 @@ class TaskRegistry:
|
|||||||
|
|
||||||
# 默认注册表
|
# 默认注册表
|
||||||
default_registry = TaskRegistry()
|
default_registry = TaskRegistry()
|
||||||
<<<<<<< HEAD
|
|
||||||
default_registry.register("ORDERS", OrdersTask)
|
|
||||||
default_registry.register("PAYMENTS", PaymentsTask)
|
|
||||||
default_registry.register("MEMBERS", MembersTask)
|
|
||||||
# 可以继续注册其他任务...
|
|
||||||
=======
|
|
||||||
default_registry.register("PRODUCTS", ProductsTask)
|
default_registry.register("PRODUCTS", ProductsTask)
|
||||||
default_registry.register("TABLES", TablesTask)
|
default_registry.register("TABLES", TablesTask)
|
||||||
default_registry.register("MEMBERS", MembersTask)
|
default_registry.register("MEMBERS", MembersTask)
|
||||||
@@ -64,4 +55,3 @@ default_registry.register("TOPUPS", TopupsTask)
|
|||||||
default_registry.register("TABLE_DISCOUNT", TableDiscountTask)
|
default_registry.register("TABLE_DISCOUNT", TableDiscountTask)
|
||||||
default_registry.register("ASSISTANT_ABOLISH", AssistantAbolishTask)
|
default_registry.register("ASSISTANT_ABOLISH", AssistantAbolishTask)
|
||||||
default_registry.register("LEDGER", LedgerTask)
|
default_registry.register("LEDGER", LedgerTask)
|
||||||
>>>>>>> main
|
|
||||||
|
|||||||
@@ -1,9 +1,3 @@
|
|||||||
<<<<<<< HEAD
|
|
||||||
class TablesTask(BaseTask):
|
|
||||||
def get_task_code(self) -> str: # 返回 "TABLES"
|
|
||||||
def execute(self) -> dict: # 拉取 /Table/GetSiteTables
|
|
||||||
def _parse_table(self, raw: dict) -> dict | None:
|
|
||||||
=======
|
|
||||||
# -*- coding: utf-8 -*-
|
# -*- coding: utf-8 -*-
|
||||||
"""台桌档案任务"""
|
"""台桌档案任务"""
|
||||||
|
|
||||||
@@ -89,4 +83,3 @@ class TablesTask(BaseTask):
|
|||||||
),
|
),
|
||||||
"raw_data": json.dumps(raw, ensure_ascii=False),
|
"raw_data": json.dumps(raw, ensure_ascii=False),
|
||||||
}
|
}
|
||||||
>>>>>>> main
|
|
||||||
|
|||||||
Reference in New Issue
Block a user