基于SpringBoot的崂山绿茶产地直供电商平台的设计与实现

QQ1217920499

164人浏览 · 2026-08-18 07:39:46

QQ1217920499 · 2026-08-18 07:39:46 发布

一、项目背景与意义

崂山绿茶作为中国地理标志产品，以其独特的品质和深厚的文化底蕴享誉国内外。然而，传统的茶叶销售模式存在诸多痛点：

信息不对称：消费者难以追溯茶叶的真实产地、种植过程和加工工艺。
流通环节多：从茶农到消费者，中间商层层加价，导致茶农收益低，消费者购买价格高。
品牌信任度低：市场上以次充好、假冒伪劣现象时有发生，损害了崂山绿茶的品牌形象。
营销渠道单一：主要依赖线下门店和传统批发，难以触达更广泛的年轻消费群体。

因此，构建一个基于SpringBoot的崂山绿茶产地直供电商平台，具有重要的现实意义：

助力乡村振兴：缩短流通链条，让茶农获得更多收益，直接带动产地经济发展。
保障产品品质：通过平台实现从茶园到茶杯的全流程可追溯，建立消费者信任。
创新营销模式：利用互联网拓展销售渠道，提升崂山绿茶品牌知名度和市场占有率。
提升消费体验：为消费者提供便捷、透明、可靠的购买渠道和丰富的产品信息。

本项目旨在设计并实现一个技术先进、功能完善、用户体验良好的垂直电商平台，为崂山绿茶产业的数字化转型提供实践案例。

二、技术栈选型

平台采用前后端分离的架构设计，后端基于SpringBoot微服务框架，前端采用Vue.js，确保系统的高性能、可扩展性和可维护性。

2.1 后端技术栈

核心框架：Spring Boot 2.7.x
安全框架：Spring Security + JWT (JSON Web Token)
数据持久层：MyBatis-Plus
数据库：MySQL 8.0 (主业务数据) + Redis 7.x (缓存与Session)
API文档：SpringDoc OpenAPI 3 (Swagger UI)
消息队列：RabbitMQ (用于订单异步处理、库存扣减)
搜索引擎：Elasticsearch 8.x (商品全文检索、智能推荐)
对象存储：阿里云OSS (存储商品图片、茶园溯源视频)
部署与监控：Docker + Nginx + Spring Boot Admin + Prometheus/Grafana

2.2 前端技术栈

框架：Vue 3 + Composition API + TypeScript
UI组件库：Element Plus
状态管理：Pinia
路由：Vue Router 4
HTTP客户端：Axios
构建工具：Vite

2.3 第三方服务与工具

支付：支付宝沙箱/微信支付API
短信：阿里云短信服务 (用于注册、登录验证码)
物流查询：快递鸟API
地图服务：高德地图JavaScript API (展示茶园地理位置)
版本控制：Git + GitHub/GitLab
CI/CD：Jenkins 或 GitHub Actions

三、系统核心功能模块设计

平台主要分为前台用户系统和后台管理系统两大部分。

3.1 前台用户系统

用户中心：注册、登录(JWT)、个人信息管理、收货地址管理。
商品模块：商品分类浏览、Elasticsearch全文搜索、商品详情页(含茶园溯源信息、360°图片)、商品收藏与对比。
购物流程：购物车管理、订单创建(库存预扣减)、多种支付方式集成(支付宝、微信)、订单状态跟踪、物流信息查询。
溯源模块：基于区块链理念(或中心化数据库)的溯源信息展示，包括茶树品种、种植海拔、采摘时间、加工师傅、质检报告等。
社区与营销：用户评价晒单、茶叶知识文章、限时秒杀、优惠券发放与使用、积分体系。

3.2 后台管理系统

权限管理：基于RBAC模型的用户、角色、菜单权限控制。
商品管理：SPU/SKU管理、库存管理、价格管理、溯源信息录入与关联。
订单管理：订单列表、详情、发货、退款/售后处理。
营销管理：优惠券管理、秒杀活动配置、文章发布。
数据统计：销售数据看板、用户行为分析、商品热度排行。
系统监控：服务器状态、API调用日志、异常告警。

四、核心代码实现示例

4.1 用户登录与JWT签发 (Spring Security配置)

import io.jsonwebtoken.Jwts;
import io.jsonwebtoken.SignatureAlgorithm;
import org.springframework.security.authentication.AuthenticationManager;
import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
import org.springframework.security.core.Authentication;
import org.springframework.security.core.userdetails.UserDetails;
import org.springframework.stereotype.Service;
import java.util.Date;

@Service
public class AuthService {
    @Value("${jwt.secret}")
    private String jwtSecret;
    @Value("${jwt.expiration}")
    private Long jwtExpiration;

    private final AuthenticationManager authenticationManager;
    private final UserDetailsServiceImpl userDetailsService;

    public AuthService(AuthenticationManager authenticationManager, UserDetailsServiceImpl userDetailsService) {
        this.authenticationManager = authenticationManager;
        this.userDetailsService = userDetailsService;
    }

    public String login(String username, String password) {
        // 1. 认证
        Authentication authentication = authenticationManager.authenticate(
                new UsernamePasswordAuthenticationToken(username, password)
        );
        // 2. 生成JWT
        UserDetails userDetails = (UserDetails) authentication.getPrincipal();
        return Jwts.builder()
                .setSubject(userDetails.getUsername())
                .setIssuedAt(new Date())
                .setExpiration(new Date(System.currentTimeMillis() + jwtExpiration))
                .signWith(SignatureAlgorithm.HS512, jwtSecret)
                .compact();
    }
}

4.2 商品搜索服务 (集成Elasticsearch)

import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.elasticsearch.core.SearchRequest;
import co.elastic.clients.elasticsearch.core.SearchResponse;
import co.elastic.clients.elasticsearch.core.search.Hit;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.io.IOException;
import java.util.List;
import java.util.stream.Collectors;

@Service
public class ProductSearchService {
    @Autowired
    private ElasticsearchClient elasticsearchClient;

    public List<ProductDTO> searchProducts(String keyword, Integer page, Integer size) throws IOException {
        SearchRequest searchRequest = SearchRequest.of(s -> s
                .index("products") // Elasticsearch索引名
                .query(q -> q
                        .bool(b -> b
                                .should(sh -> sh.match(m -> m.field("name").query(keyword).boost(2.0f)))
                                .should(sh -> sh.match(m -> m.field("description").query(keyword)))
                                .should(sh -> sh.match(m -> m.field("origin").query(keyword)))
                        )
                )
                .from((page - 1) * size)
                .size(size)
                .highlight(h -> h
                        .fields("name", f -> f)
                        .fields("description", f -> f)
                )
        );

        SearchResponse<ProductDocument> response = elasticsearchClient.search(searchRequest, ProductDocument.class);
        return response.hits().hits().stream()
                .map(Hit::source)
                .map(this::convertToDTO)
                .collect(Collectors.toList());
    }

    private ProductDTO convertToDTO(ProductDocument doc) {
        // 转换逻辑...
        return new ProductDTO();
    }
}

4.3 订单创建与库存扣减 (RabbitMQ异步处理)

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class OrderService {
    @Autowired
    private ProductStockMapper productStockMapper;
    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Transactional
    public String createOrder(OrderCreateRequest request) {
        // 1. 校验并预扣库存 (乐观锁)
        for (OrderItem item : request.getItems()) {
            int updated = productStockMapper.reduceStockWithLock(item.getProductId(), item.getQuantity());
            if (updated == 0) {
                throw new BusinessException("商品库存不足: " + item.getProductId());
            }
        }
        // 2. 创建订单 (待支付状态)
        Order order = convertToOrder(request);
        orderMapper.insert(order);
        // 3. 发送延迟消息，30分钟后检查订单是否支付，未支付则取消并回滚库存
        rabbitTemplate.convertAndSend("order.delay.exchange", "order.delay.key", order.getOrderNo(),
                message -> {
                    message.getMessageProperties().setDelay(30 * 60 * 1000); // 30分钟
                    return message;
                });
        return order.getOrderNo();
    }

    @RabbitListener(queues = "order.delay.queue")
    public void checkOrderPayment(String orderNo) {
        Order order = orderMapper.selectByOrderNo(orderNo);
        if (order != null && OrderStatus.UNPAID.equals(order.getStatus())) {
            // 超时未支付，取消订单
            cancelOrderAndRollbackStock(order);
        }
    }

    private void cancelOrderAndRollbackStock(Order order) {
        // 回滚库存逻辑...
    }
}

4.4 茶园溯源信息展示 (MyBatis-Plus查询)

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
import java.util.List;

@Service
public class TraceabilityServiceImpl extends ServiceImpl<TraceabilityMapper, Traceability> implements TraceabilityService {
    @Override
    public TraceabilityDetailVO getDetailByProductId(Long productId) {
        // 查询核心溯源信息
        LambdaQueryWrapper<Traceability> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(Traceability::getProductId, productId)
                .orderByAsc(Traceability::getRecordTime);
        List<Traceability> records = this.list(wrapper);

        TraceabilityDetailVO detailVO = new TraceabilityDetailVO();
        detailVO.setProductId(productId);
        detailVO.setRecords(records.stream().map(this::convertToRecordVO).collect(Collectors.toList()));
        // 关联茶园地理信息
        TeaGarden garden = teaGardenMapper.selectByProductId(productId);
        if (garden != null) {
            detailVO.setGardenName(garden.getName());
            detailVO.setLocation(garden.getLocation());
            detailVO.setAltitude(garden.getAltitude());
            detailVO.setSoilType(garden.getSoilType());
        }
        return detailVO;
    }
}