文章目录
- 第 8 章：简易商品管理系统实战项目-实战项目1：简易商品管理系统
- 8.1 项目需求与架构设计
- 8.1.1 核心需求（细化版）
- 8.1.2 架构设计（分层设计）
- 8.1.3 数据模型设计（`MongoDB文档结构`）
- 8.2 实战实操代码
- 8.2.1 环境准备
- 8.2.2 完整代码实现
- 步骤1：配置文件（.env）
- 步骤2：数据层（DAO层）- [goods_dao.py](goods_dao.py)
- 步骤3：业务层（Service层）- [goods_service.py](goods_service.py)
- 步骤4：接口层（CLI层）- [main.py](main.py)
- 8.2.3 代码运行与测试
- 8.3 扩展与优化建议
第 8 章：简易商品管理系统实战项目-实战项目1：简易商品管理系统
8.1 项目需求与架构设计
- 第 8 章：简易商品管理系统实战项目-实战项目-Python源代码
- 第 8 章：简易商品管理系统实战项目-实战项目-Python源代码
- 第 8 章：简易商品管理系统实战项目-实战项目-Python源代码
8.1.1 核心需求（细化版）
| 功能模块 | 具体需求 |
|---|---|
| 商品添加 | 支持录入完整商品信息（含嵌套分类、标签数组），校验必填字段（名称、价格、库存） |
| 多条件查询 | 支持按名称（模糊）、分类（一级/二级）、价格区间、库存区间、标签组合查询 |
| 库存更新 | 支持库存增加/减少，校验库存不能为负数 |
| 商品删除 | 支持按商品ID删除，支持批量删除（可选） |
| 分类统计 | 按一级分类/二级分类统计商品数量、总库存、商品总价值（现价×库存） |
| 数据校验 | 所有操作需校验数据合法性（价格≥0、库存≥0、必填字段非空） |
8.1.2 架构设计（分层设计）
采用经典的 三层架构，解耦数据操作、业务逻辑和用户交互：
| 层级 | 职责 | 核心技术/实现方式 |
|---|---|---|
| 数据层（DAO） | 封装MongoDB的CRUD操作，屏蔽数据存储细节，仅对外提供数据操作接口 | Python + PyMongo（MongoDB官方驱动） |
| 业务层（Service） | 处理核心业务逻辑（数据校验、业务规则），调用数据层接口完成操作 | 面向对象封装（业务类+方法） |
| 接口层（CLI / API） | 提供用户交互入口，接收用户输入，调用业务层处理，返回结果展示 | 命令行界面（CLI）/Flask Web API（可选） |
8.1.3 数据模型设计（MongoDB文档结构）
MongoDB为 文档型数据库，商品文档设计包含基础字段、嵌套文档（分类）、数组字段（标签），具体结构如下：
{
"_id": ObjectId("655e8b78f1234567890abcde"), // MongoDB自动生成的唯一ID
"goods_id": "G001", // 自定义商品编号（唯一）
"goods_name": "华为Mate70 Pro", // 商品名称（必填）
"category": {
// 嵌套文档：商品分类
"first_cate": "手机数码", // 一级分类
"second_cate": "智能手机" // 二级分类
},
"price": {
// 嵌套文档：价格信息
"original_price": 6999.0, // 原价
"current_price": 6499.0 // 现价（必填）
},
"stock": 100, // 库存数量（≥0，必填）
"tags": ["鸿蒙", "5G", "旗舰"], // 数组字段：商品标签
"shelf_time": ISODate("2025-01-01T00:00:00Z"), // 上架时间
"description": "华为2025旗舰机型，搭载鸿蒙5.0" // 商品描述（可选）
}8.2 实战实操代码
8.2.1 环境准备
- 安装依赖包：
pip install pymongo python-dotenv- 启动MongoDB（本地部署或使用MongoDB Atlas云服务），记录连接信息。
8.2.2 完整代码实现
步骤1：配置文件（.env）
存放MongoDB连接信息，解耦配置与代码：
# .env文件内容
MONGO_URI=mongodb://localhost:27017/
MONGO_DB_NAME=goods_management
MONGO_COLLECTION_NAME=goods步骤2：数据层（DAO层）- goods_dao.py
封装MongoDB的CRUD操作，仅负责数据存取：
import os
from dotenv import load_dotenv
from pymongo import MongoClient
from pymongo.collection import Collection
from bson.objectid import ObjectId
from datetime import datetime
# 加载环境变量
load_dotenv()
class GoodsDAO:
"""商品数据访问层，封装MongoDB操作"""
def __init__(self):
# 初始化MongoDB连接
self.client = MongoClient(os.getenv("MONGO_URI"))
self.db = self.client[os.getenv("MONGO_DB_NAME")]
self.collection: Collection = self.db[os.getenv("MONGO_COLLECTION_NAME")]
def add_goods(self, goods_data: dict) -> bool:
"""添加商品"""
try:
# 补充上架时间（默认当前时间）
if "shelf_time" not in goods_data:
goods_data["shelf_time"] = datetime.now()
self.collection.insert_one(goods_data)
return True
except Exception as e:
print(f"添加商品失败：{
e}")
return False
# 在 goods_dao.py 文件中的 query_goods 方法中修改如下部分
def query_goods(self, query_conditions: dict) -> list:
"""多条件查询商品"""
try:
# 转换ObjectId（如果有_id查询）
if "_id" in query_conditions:
query_conditions["_id"] = ObjectId(query_conditions["_id"])
# 执行查询并返回列表（转换ObjectId和datetime为字符串）
goods_list = []
for goods in self.collection.find(query_conditions):
goods["_id"] = str(goods["_id"]) # 转换为字符串方便展示
# 将 datetime 对象转换为字符串
if "shelf_time" in goods and isinstance(goods["shelf_time"], datetime):
goods["shelf_time"] = goods["shelf_time"].isoformat()
goods_list.append(goods)
return goods_list
except Exception as e:
print(f"查询商品失败：