在线花店系统详细设计与具体代码实现

一、系统需求分析与架构设计

1.1 核心功能模块划分

在线花店系统需覆盖用户端、管理端与支付系统三大核心场景：

• 用户端功能：商品浏览（分类/搜索/详情）、购物车管理、订单提交、支付集成、物流跟踪、评价系统
• 管理端功能：商品管理（CRUD/库存预警）、订单处理（状态流转/异常处理）、用户管理（权限分级）、数据统计（销售报表/用户画像）
• 支付系统：多支付渠道集成（支付宝/微信支付）、交易状态同步、退款处理

1.2 技术架构选型

采用分层架构设计提升系统可维护性：

• 前端层：React/Vue构建响应式界面，配合Element UI/Ant Design实现组件化开发
• 后端层：Spring Boot框架提供RESTful API，Spring Security实现JWT认证
• 数据库层：MySQL主库存储业务数据，Redis缓存热点数据（商品详情/会话信息）
• 中间件层：RabbitMQ处理异步任务（订单超时关闭/短信通知），Elasticsearch支持全文搜索

二、数据库设计与优化

2.1 核心数据表结构

-- 商品表
CREATE TABLE product (
    id BIGINT PRIMARY KEY AUTO_INCREMENT,
    name VARCHAR(100) NOT NULL,
    category_id BIGINT NOT NULL,
    price DECIMAL(10,2) NOT NULL,
    stock INT DEFAULT 0,
    description TEXT,
    create_time DATETIME DEFAULT CURRENT_TIMESTAMP,
    update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
);
-- 订单表
CREATE TABLE order_main (
    id BIGINT PRIMARY KEY AUTO_INCREMENT,
    user_id BIGINT NOT NULL,
    total_amount DECIMAL(10,2) NOT NULL,
    status TINYINT DEFAULT 0 COMMENT '0:待支付 1:已支付 2:已发货 3:已完成 4:已取消',
    payment_time DATETIME,
    delivery_address TEXT NOT NULL,
    create_time DATETIME DEFAULT CURRENT_TIMESTAMP
);

2.2 索引优化策略

• 对商品表的category_id、name字段建立复合索引
• 订单表的user_id、status、create_time字段建立联合索引
• 使用EXPLAIN分析查询执行计划，避免全表扫描

三、核心功能代码实现

3.1 商品搜索与筛选实现

// Controller层
@GetMapping("/products")
public Result<PageInfo<ProductVO>> searchProducts(
        @RequestParam(required = false) String keyword,
        @RequestParam(required = false) Long categoryId,
        @RequestParam(defaultValue = "1") Integer pageNum,
        @RequestParam(defaultValue = "10") Integer pageSize) {
    // 构建ES查询条件
    BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
    if (StringUtils.isNotBlank(keyword)) {
        boolQuery.must(QueryBuilders.matchQuery("name", keyword));
    }
    if (categoryId != null) {
        boolQuery.must(QueryBuilders.termQuery("categoryId", categoryId));
    }
    // 分页查询
    NativeSearchQuery searchQuery = new NativeSearchQueryBuilder()
            .withQuery(boolQuery)
            .withPageable(PageRequest.of(pageNum - 1, pageSize))
            .build();
    SearchHits<Product> searchHits = elasticsearchTemplate.search(searchQuery, Product.class);
    // 转换结果...
}

3.2 订单状态机设计

public enum OrderStatus {
    PENDING_PAYMENT("待支付"),
    PAID("已支付"),
    SHIPPED("已发货"),
    COMPLETED("已完成"),
    CANCELLED("已取消");
    private String description;
    OrderStatus(String description) {
        this.description = description;
    }
    // 状态流转规则
    public boolean canTransitionTo(OrderStatus newStatus) {
        switch (this) {
            case PENDING_PAYMENT:
                return newStatus == PAID || newStatus == CANCELLED;
            case PAID:
                return newStatus == SHIPPED || newStatus == CANCELLED;
            // 其他状态流转规则...
            default:
                return false;
        }
    }
}

3.3 支付系统集成

// 微信支付实现示例
@Service
public class WeChatPayService {
    @Value("${wechat.appid}")
    private String appId;
    @Value("${wechat.mchid}")
    private String mchId;
    public Map<String, String> createPrepayOrder(Long orderId, BigDecimal amount) {
        // 1. 生成预支付订单号
        String outTradeNo = "WX" + System.currentTimeMillis();
        // 2. 组装请求参数
        Map<String, String> params = new HashMap<>();
        params.put("appid", appId);
        params.put("mch_id", mchId);
        params.put("nonce_str", UUID.randomUUID().toString().replace("-", ""));
        params.put("body", "鲜花购买");
        params.put("out_trade_no", outTradeNo);
        params.put("total_fee", amount.multiply(new BigDecimal(100)).intValue() + "");
        params.put("spbill_create_ip", "127.0.0.1");
        params.put("notify_url", "https://yourdomain.com/pay/notify");
        params.put("trade_type", "NATIVE");
        // 3. 生成签名并调用微信API
        String sign = generateSign(params, "YOUR_API_KEY");
        params.put("sign", sign);
        // 4. 返回支付二维码URL
        Map<String, String> result = new HashMap<>();
        result.put("code_url", "weixin://wxpay/bizpayurl?" + buildQuery(params));
        return result;
    }
}

四、系统优化与安全防护

4.1 性能优化方案

• CDN加速：静态资源（图片/CSS/JS）部署至CDN节点
• 数据库分表：订单表按用户ID哈希分表，缓解单表数据压力
• 异步处理：使用消息队列解耦订单创建与库存扣减操作

4.2 安全防护措施

• SQL注入防御：使用MyBatis参数绑定或JPA Criteria API
• XSS防护：前端使用DOMPurify过滤输入，后端对输出进行转义
• CSRF防护：Spring Security自动生成CSRF Token
• 敏感数据加密：用户密码使用BCrypt加密存储，支付信息通过国密SM4加密

五、部署与运维方案

5.1 容器化部署

# Dockerfile示例
FROM openjdk:11-jre-slim
VOLUME /tmp
ARG JAR_FILE=target/*.jar
COPY ${JAR_FILE} app.jar
ENTRYPOINT ["java","-Djava.security.egd=file:/dev/./urandom","-jar","/app.jar"]

5.2 监控告警体系

• Prometheus + Grafana：监控JVM指标、数据库连接池、接口响应时间
• ELK日志系统：集中管理应用日志，支持关键字告警
• Sentinel限流：对核心接口（如支付接口）进行QPS限制

六、扩展功能建议

1. AI推荐系统：基于用户浏览历史实现协同过滤推荐
2. AR试花功能：通过WebAR技术让用户预览鲜花摆放效果
3. 供应链管理：集成供应商系统实现自动补货
4. 会员体系：设计成长型会员等级与积分兑换系统

本系统设计通过模块化架构实现高内聚低耦合，核心代码示例展示了关键业务逻辑的实现方式。实际开发中需结合具体业务场景调整技术选型，建议采用灰度发布策略逐步上线新功能，并通过自动化测试保障系统稳定性。