编程导航会员会员
登录/注册

从0到1写一个茶业平台的小程序 逐步迭代中

需求文档

介绍

茶园直供平台是一个创新的短链交易平台，通过微信小程序和APP实现茶园到餐桌的直接连接。平台消除中间环节，让茶农获得更高收益（售价提升100%+），消费者享受更优价格（成本降低40%-60%），确保茶叶从采摘到送达在72小时内完成，提供最新鲜的茶叶体验。

需求

需求 1 - 茶农极简开店系统

用户故事： 作为中小茶园主，我希望能够快速开设网店并展示我的茶叶产品，以便直接向消费者销售并获得更好的收益。

验收标准

  1. 当茶农首次注册时，系统应当通过身份证验证和茶园地理位置认证自动生成店铺页面
  2. 当茶农上传茶园照片时，系统应当自动获取GPS定位信息并在店铺页面显示
  3. 当茶农录制产品介绍时，系统应当支持方言语音转文字功能
  4. 当茶农发布商品时，系统应当基于采茶工价和加工费成本自动建议售价区间
  5. 当茶农设置价格时，系统应当提供防止定价失误的提醒功能

需求 2 - 产销管理和共享仓储

用户故事： 作为茶农，我希望能够高效管理我的产品库存和发货流程，以便降低运营成本并提高发货效率。

验收标准

  1. 当茶农查看附近仓库时，系统应当显示3公里内的合作冷库及价格（5元/斤/月）
  2. 当茶农选择仓库后，系统应当自动将新订单流转至绑定的仓库进行发货
  3. 当茶农发布拼单需求时，系统应当匹配3公里内同目的地的其他茶农订单
  4. 当有拼单机会时，系统应当通知相关茶农并显示运费分摊详情
  5. 当茶农查看数据看板时，系统应当显示销售趋势、客户地域分布和复购率排名

需求 3 - 源头直采体验

用户故事： 作为茶叶消费者，我希望能够直接观看茶园实况并参与采摘过程，以便获得最真实的茶叶来源体验。

验收标准

  1. 当用户进入茶园页面时，系统应当提供24小时茶园直播橱窗功能
  2. 当用户观看直播时，系统应当支持打赏茶农功能
  3. 当用户预约采摘时，系统应当显示可预约的时间段和相关费用
  4. 当节气前15天时，系统应当开放新茶预售功能（如"谷雨龙井"）
  5. 当用户参与预售时，系统应当支持预付30%享受8折优惠

需求 4 - 一物一码溯源系统

用户故事： 作为消费者，我希望能够完整追溯我购买茶叶的来源信息，以便确保产品的真实性和品质。

验收标准

  1. 当用户扫描茶叶包装二维码时，系统应当显示茶园海拔、采摘时间、炒茶师傅工号
  2. 当用户查看溯源信息时，系统应当提供SGS检测报告的查看功能
  3. 当用户购买茶叶时，系统应当自动为每个产品生成唯一的溯源码
  4. 当用户查询溯源信息时，系统应当显示从采摘到发货的完整时间轴
  5. 当检测到异常信息时，系统应当立即标记并通知相关人员

需求 5 - 个性化风味管理

用户故事： 作为茶叶爱好者，我希望能够记录和管理我对不同茶叶的口感偏好，以便获得更精准的推荐。

验收标准

  1. 当用户品尝茶叶后，系统应当允许用户为茶叶添加口感标签
  2. 当用户完成口感评价时，系统应当自动生成个人风味护照
  3. 当用户浏览茶叶时，系统应当基于风味护照推荐相似口感的茶品
  4. 当用户使用DIY拼配功能时，系统应当提供3款基础茶的选择
  5. 当用户完成拼配时，系统应当免费提供电子配方卡和混合工具包

需求 6 - 72小时鲜达履约

用户故事： 作为消费者，我希望能够在最短时间内收到最新鲜的茶叶，以便享受最佳的茶叶品质。

验收标准

  1. 当用户下单时，系统应当验证配送地址是否在500公里产区范围内
  2. 当订单确认后，系统应当显示"锁鲜倒计时"，实时显示茶叶离开茶园的小时数
  3. 当茶叶在72小时内时，系统应当在产品页面显示"鲜"字角标
  4. 当茶叶按时发货时，系统应当按照晨采→当夜加工→次日发货→第三天送达的流程执行
  5. 当用户选择故事增值包时，系统应当提供茶农手写故事卡和茶园四季明信片套装

需求 7 - 双向评价和匹配系统

用户故事： 作为平台用户，我希望能够建立互相信任的评价体系，以便获得更好的交易体验和个性化服务。

验收标准

  1. 当交易完成后，系统应当允许茶农为消费者添加标签（如"懂茶行家"）
  2. 当茶农发布新茶时，系统应当优先推送给高匹配度的用户
  3. 当消费者评价茶农时，系统应当记录评价内容并影响茶农的信誉等级
  4. 当用户查看茶农信息时，系统应当显示其他消费者的评价和推荐度
  5. 当系统检测到高匹配用户时，应当提供专属的新茶情报推送

需求 8 - 价格透明化和保险保障

用户故事： 作为消费者，我希望能够清楚了解茶叶的价格构成，并获得品质保障，以便放心购买。

验收标准

  1. 当用户查看商品价格时，系统应当显示详细的成本构成：茶园价（60%）+物流（15%）+包装（5%）+平台佣金（20%）
  2. 当用户下单时，系统应当自动为每笔订单购买PICC品质险
  3. 当检测到农残超标或产地不实时，系统应当支持退全款并赔付3倍
  4. 当用户需要包装时，系统应当提供免费基础包装设计（含平台LOGO和溯源二维码）
  5. 当茶农按订单量定制包装时，系统应当提供零库存包装解决方案

需求 9 - 我的茶树情感连接

用户故事： 作为茶叶爱好者，我希望能够与特定的茶树建立情感连接，以便获得更深层次的茶文化体验。

验收标准

  1. 当用户支付299元/年时，系统应当允许用户为专属茶树命名
  2. 当茶树生长时，系统应当定期向用户发送生长视频
  3. 当茶树到达采摘期时，系统应当优先通知茶树主人并提供专属采摘权
  4. 当用户查看茶树信息时，系统应当显示茶树的详细生长记录和照片
  5. 当茶树产出茶叶时，系统应当为茶树主人提供专属包装和证书

需求 10 - 茶农运营效率提升

用户故事： 作为茶农，我希望能够批量处理订单和管理库存，以便提高运营效率和降低操作成本。

验收标准

  1. 当茶农有多个订单需要发货时，系统应当支持批量选择订单并一键打印快递面单
  2. 当预售商品库存不足时，系统应当自动提醒茶农补充库存
  3. 当茶农查看批量操作记录时，系统应当显示打印时间、订单数量和快递公司信息
  4. 当系统检测到预售商品距离交付时间不足7天且库存为0时，应当发送紧急库存提醒
  5. 当茶农进行批量操作时，系统应当提供操作确认和撤销功能

需求 11 - 消费者价格智能服务

用户故事： 作为茶叶消费者，我希望能够订阅关注茶叶的价格变化，以便在合适的时机购买心仪的茶叶。

验收标准

  1. 当用户关注某款茶叶时，系统应当允许用户订阅该茶叶的价格走势通知
  2. 当订阅茶叶价格下降超过10%时，系统应当通过微信公众号模板消息通知用户
  3. 当系统运行定时任务时，应当每日扫描所有订阅商品的价格变化
  4. 当用户查看价格走势时，系统应当显示近30天的价格曲线图
  5. 当用户取消订阅时，系统应当停止发送该商品的价格变化通知

需求 12 - 积分奖励和社交分享

用户故事： 作为平台用户，我希望通过分享和推荐获得奖励，以便降低购茶成本并享受更多优惠。

验收标准

  1. 当用户成功分享商品链接且有新用户注册时，系统应当为分享者奖励100积分
  2. 当用户积分达到500分时，系统应当允许用户兑换价值50元的茶叶代金券
  3. 当用户查看积分商城时，系统应当显示可兑换的礼品清单和所需积分
  4. 当用户完成首次购买时，系统应当奖励新用户50积分
  5. 当用户连续7天签到时，系统应当额外奖励100积分

# 设计文档

概述

茶园直供平台采用前后端分离的微服务架构，支持微信小程序和移动APP双端访问。系统设计围绕"72小时鲜达"的核心价值，通过实时数据同步、地理位置服务、直播技术和区块链溯源等技术手段，实现茶园到餐桌的短链交易。

核心设计原则

  • 实时性：支持直播、实时库存、物流跟踪
  • 可追溯性：完整的产品溯源链路
  • 高可用性：99.9%服务可用性保障
  • 安全性：数据加密、支付安全、隐私保护
  • 可扩展性：支持大规模茶农和消费者接入

架构

整体架构图

▼
mermaid
复制代码
graph TD
Start --> Stop

▼
mermaid
复制代码
graph TB
    subgraph "客户端层"
        A[微信小程序] 
        B[iOS/Android APP]
        C[茶农管理端]
        D[直播推流端]
    end
    
    subgraph "网关层"
        E[API网关]
        F[负载均衡器]
    end
    
    subgraph "业务服务层"
        G[用户服务]
        H[商品服务] 
        I[订单服务]
        J[支付服务]
        K[物流服务]
        L[直播服务]
        M[溯源服务]
        N[推荐服务]
    end
    
    subgraph "数据层"
        O[MySQL主库]
        P[MySQL从库]
        Q[Redis缓存]
        R[MongoDB日志]
        S[OSS存储]
    end
    
    subgraph "外部服务"
        T[微信支付]
        U[物流API]
        V[地图服务]
        W[直播CDN]
        X[短信服务]
    end
    
    A --> E
    B --> E
    C --> E
    D --> L
    E --> F
    F --> G
    F --> H
    F --> I
    F --> J
    F --> K
    F --> L
    F --> M
    F --> N
    
    G --> O
    H --> O
    I --> O
    J --> T
    K --> U
    L --> W
    M --> O
    N --> Q
    
    O --> P
    G --> Q
    H --> Q
    I --> Q
    
    L --> S
    M --> S

技术栈选择

前端技术

  • 微信小程序：uniapp + Vant Weapp UI组件库
  • 茶农管理端：Vue.js 3 + Element Plus

后端技术

  • 开发语言：java
  • Web框架：springboot+mybaitsplus
  • 数据库：MySQL 8.0 (主数据) + MongoDB (日志) + Redis (缓存)
  • 简化开发 Lombok
  • 消息队列：Redis + Bull Queue
  • 文件存储：腾讯云Cos
  • 直播服务：阿里云直播服务

基础设施

  • 容器化：Docker + Kubernetes
  • CI/CD：GitHub Actions
  • 监控：Prometheus + Grafana
  • 日志：ELK Stack

组件和接口

核心业务组件

1. 用户管理组件

▼
typescript
复制代码
interface UserService {
  // 茶农注册认证
  registerFarmer(identityInfo: FarmerIdentity): Promise<FarmerProfile>
  
  // 消费者微信授权登录
  wechatLogin(code: string): Promise<ConsumerProfile>
  
  // 双向评价系统
  addUserTag(fromUserId: string, toUserId: string, tag: UserTag): Promise<void>
  
  // 获取用户匹配度
  getUserMatchScore(farmerId: string, consumerId: string): Promise<number>
}

interface FarmerIdentity {
  idCard: string
  teaGardenLocation: GeoLocation
  businessLicense?: string
}

interface UserTag {
  type: 'expertise' | 'preference' | 'behavior'
  value: string
  weight: number
}

2. 商品管理组件

▼
typescript
复制代码
interface ProductService {
  // 智能定价助手
  suggestPrice(costInfo: CostInfo): Promise<PriceRange>
  
  // 商品发布
  publishProduct(product: TeaProduct): Promise<string>
  
  // 预售管理
  createPresale(presaleInfo: PresaleInfo): Promise<string>
  
  // 库存同步
  syncInventory(productId: string, quantity: number): Promise<void>
}

interface CostInfo {
  pickingCost: number    // 采茶工价
  processingCost: number // 加工费
  packagingCost: number  // 包装费
}

interface TeaProduct {
  name: string
  category: TeaCategory
  origin: GeoLocation
  harvestTime: Date
  processingMethod: string
  images: string[]
  description: string
  price: number
  inventory: number
}

3. 订单履约组件

▼
typescript
复制代码
interface OrderService {
  // 创建订单
  createOrder(orderInfo: OrderInfo): Promise<Order>
  
  // 拼单匹配
  findShippingPartners(farmerId: string, destination: string): Promise<ShippingPartner[]>
  
  // 72小时履约跟踪
  trackFreshness(orderId: string): Promise<FreshnessStatus>
  
  // 仓储分配
  allocateWarehouse(farmerId: string, productWeight: number): Promise<Warehouse>
}

interface FreshnessStatus {
  harvestTime: Date
  processingTime: Date
  shippingTime: Date
  estimatedDelivery: Date
  hoursFromHarvest: number
  isFresh: boolean // ≤72小时
}

4. 溯源服务组件

▼
typescript
复制代码
interface TraceabilityService {
  // 生成溯源码
  generateTraceCode(product: TeaProduct, batch: ProductBatch): Promise<string>
  
  // 查询溯源信息
  getTraceInfo(traceCode: string): Promise<TraceInfo>
  
  // 上传检测报告
  uploadTestReport(productId: string, report: TestReport): Promise<void>
  
  // 区块链存证
  storeOnBlockchain(traceInfo: TraceInfo): Promise<string>
}

interface TraceInfo {
  productId: string
  farmInfo: FarmInfo
  harvestInfo: HarvestInfo
  processingInfo: ProcessingInfo
  testReports: TestReport[]
  blockchainHash: string
}

5. 直播服务组件

▼
typescript
复制代码
interface LiveStreamService {
  // 创建直播间
  createLiveRoom(farmerId: string, teaGardenId: string): Promise<LiveRoom>
  
  // 24小时直播管理
  manage24HourStream(roomId: string): Promise<void>
  
  // 打赏功能
  processTip(roomId: string, fromUserId: string, amount: number): Promise<void>
  
  // 直播录制回放
  getStreamRecordings(roomId: string, date: Date): Promise<Recording[]>
}

API接口设计

RESTful API规范

▼
text
复制代码
GET    /api/v1/farmers/{farmerId}/products     # 获取茶农商品列表
POST   /api/v1/products                        # 发布新商品
GET    /api/v1/products/{productId}/trace      # 获取溯源信息
POST   /api/v1/orders                          # 创建订单
GET    /api/v1/orders/{orderId}/freshness      # 查询新鲜度状态
POST   /api/v1/livestream/rooms                # 创建直播间
GET    /api/v1/users/{userId}/recommendations  # 获取个性化推荐

WebSocket实时接口

▼
text
复制代码
/ws/livestream/{roomId}        # 直播间实时消息
/ws/order/{orderId}/tracking   # 订单实时跟踪
/ws/freshness/{productId}      # 新鲜度倒计时

数据模型

核心数据表设计

用户相关表

▼
sql
复制代码
-- 茶农信息表
CREATE TABLE farmers (
    id VARCHAR(36) PRIMARY KEY,
    user_id VARCHAR(36) NOT NULL,
    identity_verified BOOLEAN DEFAULT FALSE,
    tea_garden_location POINT NOT NULL,
    business_license VARCHAR(255),
    reputation_score DECIMAL(3,2) DEFAULT 5.00,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    SPATIAL INDEX(tea_garden_location)
);

-- 消费者信息表  
CREATE TABLE consumers (
    id VARCHAR(36) PRIMARY KEY,
    user_id VARCHAR(36) NOT NULL,
    wechat_openid VARCHAR(64) UNIQUE,
    taste_profile JSON, -- 风味护照
    my_tea_tree_id VARCHAR(36), -- 专属茶树
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

-- 用户标签表
CREATE TABLE user_tags (
    id VARCHAR(36) PRIMARY KEY,
    from_user_id VARCHAR(36) NOT NULL,
    to_user_id VARCHAR(36) NOT NULL,
    tag_type ENUM('expertise', 'preference', 'behavior'),
    tag_value VARCHAR(100) NOT NULL,
    weight DECIMAL(3,2) DEFAULT 1.00,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

商品相关表

▼
sql
复制代码
-- 茶叶商品表
CREATE TABLE tea_products (
    id VARCHAR(36) PRIMARY KEY,
    farmer_id VARCHAR(36) NOT NULL,
    name VARCHAR(255) NOT NULL,
    category ENUM('green', 'black', 'oolong', 'white', 'puer', 'yellow'),
    origin_location POINT NOT NULL,
    harvest_time DATETIME NOT NULL,
    processing_method VARCHAR(255),
    price DECIMAL(10,2) NOT NULL,
    cost_breakdown JSON, -- 成本构成
    inventory INT DEFAULT 0,
    trace_code VARCHAR(64) UNIQUE,
    status ENUM('draft', 'active', 'sold_out', 'archived') DEFAULT 'draft',
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    SPATIAL INDEX(origin_location)
);

-- 预售商品表
CREATE TABLE presale_products (
    id VARCHAR(36) PRIMARY KEY,
    product_id VARCHAR(36) NOT NULL,
    presale_start_date DATE NOT NULL,
    presale_end_date DATE NOT NULL,
    discount_rate DECIMAL(3,2) DEFAULT 0.20, -- 8折 = 0.20折扣
    deposit_rate DECIMAL(3,2) DEFAULT 0.30,  -- 30%预付
    estimated_harvest_date DATE NOT NULL,
    FOREIGN KEY (product_id) REFERENCES tea_products(id)
);

订单相关表

▼
sql
复制代码
-- 订单主表
CREATE TABLE orders (
    id VARCHAR(36) PRIMARY KEY,
    consumer_id VARCHAR(36) NOT NULL,
    farmer_id VARCHAR(36) NOT NULL,
    product_id VARCHAR(36) NOT NULL,
    quantity DECIMAL(8,2) NOT NULL,
    unit_price DECIMAL(10,2) NOT NULL,
    total_amount DECIMAL(12,2) NOT NULL,
    shipping_address JSON NOT NULL,
    status ENUM('pending', 'paid', 'processing', 'shipped', 'delivered', 'completed', 'cancelled'),
    harvest_time DATETIME, -- 采摘时间
    processing_time DATETIME, -- 加工时间  
    shipping_time DATETIME, -- 发货时间
    delivery_time DATETIME, -- 送达时间
    freshness_hours INT, -- 从采摘到发货的小时数
    insurance_policy_no VARCHAR(100), -- 保险单号
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

-- 拼单信息表
CREATE TABLE shipping_groups (
    id VARCHAR(36) PRIMARY KEY,
    destination_city VARCHAR(100) NOT NULL,
    shipping_date DATE NOT NULL,
    total_weight DECIMAL(8,2) DEFAULT 0,
    shipping_cost DECIMAL(10,2) DEFAULT 0,
    status ENUM('forming', 'confirmed', 'shipped') DEFAULT 'forming',
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

溯源相关表

▼
sql
复制代码
-- 溯源信息表
CREATE TABLE traceability_records (
    id VARCHAR(36) PRIMARY KEY,
    trace_code VARCHAR(64) UNIQUE NOT NULL,
    product_id VARCHAR(36) NOT NULL,
    farm_altitude INT, -- 茶园海拔
    harvest_worker_id VARCHAR(36), -- 采茶工ID
    processor_id VARCHAR(36), -- 炒茶师傅ID
    processing_temperature INT, -- 加工温度
    processing_duration INT, -- 加工时长(分钟)
    test_reports JSON, -- SGS检测报告
    blockchain_hash VARCHAR(128), -- 区块链存证哈希
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    FOREIGN KEY (product_id) REFERENCES tea_products(id)
);

MongoDB文档设计

直播数据

▼
javascript
复制代码
// 直播间集合
{
  _id: ObjectId,
  farmerId: String,
  teaGardenId: String,
  roomId: String,
  title: String,
  status: "live" | "offline" | "scheduled",
  viewerCount: Number,
  streamUrl: String,
  playbackUrl: String,
  startTime: Date,
  endTime: Date,
  tips: [{
    userId: String,
    amount: Number,
    message: String,
    timestamp: Date
  }],
  recordings: [{
    date: Date,
    duration: Number,
    fileUrl: String
  }]
}

用户行为日志

▼
javascript
复制代码
// 用户行为集合
{
  _id: ObjectId,
  userId: String,
  userType: "farmer" | "consumer",
  action: String,
  resource: String,
  resourceId: String,
  metadata: Object,
  timestamp: Date,
  sessionId: String,
  deviceInfo: Object
}

错误处理

错误码规范

▼
typescript
复制代码
enum ErrorCode {
  // 用户相关 1000-1999
  USER_NOT_FOUND = 1001,
  FARMER_NOT_VERIFIED = 1002,
  INSUFFICIENT_REPUTATION = 1003,
  
  // 商品相关 2000-2999  
  PRODUCT_OUT_OF_STOCK = 2001,
  INVALID_PRICE_RANGE = 2002,
  PRESALE_EXPIRED = 2003,
  
  // 订单相关 3000-3999
  ORDER_PAYMENT_FAILED = 3001,
  FRESHNESS_EXCEEDED = 3002, // 超过72小时
  SHIPPING_AREA_NOT_SUPPORTED = 3003,
  
  // 溯源相关 4000-4999
  TRACE_CODE_INVALID = 4001,
  TEST_REPORT_MISSING = 4002,
  BLOCKCHAIN_STORE_FAILED = 4003,
  
  // 直播相关 5000-5999
  LIVE_ROOM_FULL = 5001,
  STREAM_QUALITY_POOR = 5002,
  TIP_AMOUNT_INVALID = 5003
}

全局异常处理

▼
typescript
复制代码
@Catch()
export class GlobalExceptionFilter implements ExceptionFilter {
  catch(exception: any, host: ArgumentsHost) {
    const ctx = host.switchToHttp()
    const response = ctx.getResponse()
    const request = ctx.getRequest()
    
    const status = exception instanceof HttpException 
      ? exception.getStatus() 
      : HttpStatus.INTERNAL_SERVER_ERROR
      
    const errorResponse = {
      code: exception.code || ErrorCode.INTERNAL_ERROR,
      message: exception.message || '服务器内部错误',
      timestamp: new Date().toISOString(),
      path: request.url,
      traceId: request.headers['x-trace-id']
    }
    
    // 记录错误日志
    this.logger.error(
      `${request.method} ${request.url}`,
      exception.stack,
      'GlobalExceptionFilter'
    )
    
    response.status(status).json(errorResponse)
  }
}

业务异常处理策略

新鲜度超时处理

▼
typescript
复制代码
class FreshnessTimeoutHandler {
  async handleTimeout(orderId: string) {
    // 1. 标记订单状态
    await this.orderService.markAsFreshnessExpired(orderId)
    
    // 2. 自动退款
    await this.paymentService.refund(orderId, '超过72小时新鲜保证')
    
    // 3. 通知用户
    await this.notificationService.notifyFreshnessTimeout(orderId)
    
    // 4. 记录茶农信誉
    await this.reputationService.deductScore(farmerId, 'freshness_timeout')
  }
}

支付失败重试机制

▼
typescript
复制代码
class PaymentRetryHandler {
  @Retry(3, 1000) // 重试3次，间隔1秒
  async processPayment(orderInfo: OrderInfo): Promise<PaymentResult> {
    try {
      return await this.wechatPayService.pay(orderInfo)
    } catch (error) {
      if (error.code === 'INSUFFICIENT_BALANCE') {
        throw new BusinessException(ErrorCode.PAYMENT_INSUFFICIENT_BALANCE)
      }
      throw error
    }
  }
}

测试策略

测试金字塔

单元测试 (70%)

▼
typescript
复制代码
// 商品服务单元测试示例
describe('ProductService', () => {
  let service: ProductService
  let mockRepository: jest.Mocked<ProductRepository>
  
  beforeEach(async () => {
    const module = await Test.createTestingModule({
      providers: [
        ProductService,
        { provide: ProductRepository, useValue: mockRepository }
      ]
    }).compile()
    
    service = module.get<ProductService>(ProductService)
  })
  
  describe('suggestPrice', () => {
    it('should suggest correct price range based on cost', async () => {
      const costInfo = {
        pickingCost: 50,
        processingCost: 30,
        packagingCost: 10
      }
      
      const result = await service.suggestPrice(costInfo)
      
      expect(result.min).toBe(180) // 成本*2
      expect(result.max).toBe(270) // 成本*3
      expect(result.recommended).toBe(225) // 成本*2.5
    })
  })
})

集成测试 (20%)

▼
typescript
复制代码
// 订单流程集成测试
describe('Order Integration', () => {
  it('should complete full order flow within freshness limit', async () => {
    // 1. 创建订单
    const order = await orderService.createOrder(mockOrderInfo)
    
    // 2. 支付
    await paymentService.processPayment(order.id)
    
    // 3. 分配仓库
    const warehouse = await orderService.allocateWarehouse(order.farmerId, order.quantity)
    
    // 4. 检查新鲜度
    const freshness = await orderService.trackFreshness(order.id)
    expect(freshness.hoursFromHarvest).toBeLessThan(72)
    
    // 5. 发货
    await shippingService.ship(order.id, warehouse.id)
    
    // 6. 验证订单状态
    const updatedOrder = await orderService.findById(order.id)
    expect(updatedOrder.status).toBe('shipped')
  })
})

E2E测试 (10%)

▼
typescript
复制代码
// 端到端测试
describe('Tea Purchase E2E', () => {
  it('should allow consumer to purchase tea from farm to table', async () => {
    // 模拟完整的购买流程
    await request(app.getHttpServer())
      .post('/api/v1/auth/wechat-login')
      .send({ code: 'mock_wechat_code' })
      .expect(200)
    
    const response = await request(app.getHttpServer())
      .get('/api/v1/products')
      .query({ location: '30.2741,120.1551', radius: 50 })
      .expect(200)
    
    const product = response.body.data[0]
    
    await request(app.getHttpServer())
      .post('/api/v1/orders')
      .send({
        productId: product.id,
        quantity: 1,
        shippingAddress: mockAddress
      })
      .expect(201)
  })
})

性能测试

负载测试指标

  • 并发用户数：支持10,000并发用户
  • 响应时间：API响应时间 < 200ms (95th percentile)
  • 吞吐量：支持1000 TPS
  • 直播并发：单直播间支持5000并发观看

压力测试场景

▼
javascript
复制代码
// K6压力测试脚本
import http from 'k6/http'
import { check } from 'k6'

export let options = {
  stages: [
    { duration: '2m', target: 100 },
    { duration: '5m', target: 500 },
    { duration: '2m', target: 1000 },
    { duration: '5m', target: 1000 },
    { duration: '2m', target: 0 }
  ]
}

export default function() {
  // 测试商品列表API
  let response = http.get('https://api.tea-platform.com/api/v1/products')
  check(response, {
    'status is 200': (r) => r.status === 200,
    'response time < 200ms': (r) => r.timings.duration < 200
  })
  
  // 测试直播间API
  response = http.get('https://api.tea-platform.com/api/v1/livestream/rooms/active')
  check(response, {
    'livestream response time < 500ms': (r) => r.timings.duration < 500
  })
}

安全测试

安全检查清单

  • SQL注入防护
  • XSS攻击防护
  • CSRF防护
  • 敏感数据加密
  • API访问频率限制
  • 支付安全验证
  • 用户身份验证
  • 数据传输加密(HTTPS)

安全测试用例

▼
typescript
复制代码
describe('Security Tests', () => {
  it('should prevent SQL injection in product search', async () => {
    const maliciousQuery = "'; DROP TABLE products; --"
    
    const response = await request(app.getHttpServer())
      .get('/api/v1/products/search')
      .query({ keyword: maliciousQuery })
      .expect(400)
    
    expect(response.body.message).toContain('Invalid search parameter')
  })
  
  it('should require authentication for order creation', async () => {
    await request(app.getHttpServer())
      .post('/api/v1/orders')
      .send(mockOrderData)
      .expect(401)
  })
})

这个设计文档涵盖了茶园直供平台的完整技术架构，包括系统架构、核心组件、数据模型、错误处理和测试策略。设计充分考虑了72小时鲜达、溯源追踪、直播互动等核心业务需求，并提供了可扩展的技术方案。

项目
0个评论
全部评论
点击登录，快来和大家讨论吧～
表情
图片
暂无评论
鱼友9142
鱼友9142
等级
内容推荐
更多
易扣AI (Go + CloudWeGo) 企业级AI智能体项目教程 第5章：后端项目基于Eino对话记忆的对话历史模块搭建
5
GitHub 每周精选｜2026 W25
5
AI 热点监控平台项目 VibeCoding 学习 -未完成 后续要持续更新
3
耄耋专属AI Loop全自动编码器技术笔记
4
开源我的 Vibe Coding 工作流，已有人靠它把项目做完了
7
作者分享
更多
重庆本地招人开发 前端 8K 后端10K
3
直播写回收商城（日本客户）
1
下载 APP