基于Spring Boot的助农农产品销售平台

1. 引言

针对农产品流通环节多、信息不对称、农户增收难等问题，构建"互联网+农业"电商平台。通过Spring Boot技术栈整合产销资源，建立从田间到餐桌的数字化供应链，助力乡村振兴。

2. 技术架构

技术栈

• ​​后端​​：Spring Boot 3.2 + MyBatis-Plus + Spring Security
• ​​前端​​：Vue3 + Element Plus（响应式设计）
• ​​数据库​​：MySQL 8.0（GIS空间索引支持）
• ​​即时通讯​​：WebSocket + STOMP协议
• ​​地图服务​​：高德地图API（农产品溯源）
• ​​部署​​：Docker Compose + Nginx

3. 核心功能模块

3.1 农户直连系统

// FarmerController.java
@RestController
@RequestMapping("/api/farmer")
public class FarmerController {
    @Autowired
    private FarmerService farmerService;

    @PostMapping("/register")
    public Result register(@Valid @RequestBody FarmerDTO dto) {
        // 农户实名认证（对接公安系统）
        boolean verified = idCardVerify(dto.getIdNumber(), dto.getName());
        if(!verified) throw new BusinessException("实名认证失败");
        
        // 地理位置解析
        Address address = gaodeMapService.parseAddress(dto.getLocationDesc());
        dto.setLongitude(address.getLongitude());
        dto.setLatitude(address.getLatitude());
        
        return Result.success(farmerService.register(dto));
    }
}

3.2 智能溯源系统

// TraceabilityService.java
@Service
public class TraceabilityService {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Transactional
    public void recordProduction(Long productId, String process) {
        // 记录生产环节
        TraceRecord record = new TraceRecord();
        record.setProductId(productId);
        record.setProcess(process);
        record.setTimestamp(LocalDateTime.now());
        traceRecordMapper.insert(record);
        
        // 发送溯源消息到MQ
        rabbitTemplate.convertAndSend(
            "trace.exchange",
            "trace.record",
            new TraceMessage(productId, process)
        );
    }
}

4. 特色功能实现

4.1 产销对接地图

// 前端Vue组件
<template>
  <el-amap 
    :center="center"
    :zoom="12"
    @click="handleMapClick">
    <el-amap-marker 
      v-for="farm in farms"
      :position="[farm.longitude, farm.latitude]"
      :events="markerEvents">
    </el-amap-marker>
  </el-amap>
</template>

<script setup>
const fetchNearbyFarms = async (lng, lat) => {
  const { data } = await axios.get('/api/farm/nearby', {
    params: { longitude: lng, latitude: lat, radius: 10 }
  });
  farms.value = data;
};
</script>

4.2 订单智能分配

// OrderDispatchService.java
@Service
public class OrderDispatchService {
    public void dispatchOrder(Order order) {
        // 基于GIS的最近农户匹配
        List<Farmer> candidates = farmerMapper.findWithinRadius(
            order.getDeliveryLng(),
            order.getDeliveryLat(),
            50 // 50公里半径
        );
        
        // 综合评分算法（价格、评分、库存）
        Farmer bestFarmer = candidates.stream()
            .min(Comparator.comparingDouble(f -> 
                calculateScore(f, order)
            ))
            .orElseThrow(() -> new BusinessException("无可用农户"));
        
        order.setFarmerId(bestFarmer.getId());
        orderMapper.updateById(order);
    }
}

5. 数据库设计

核心表结构

CREATE TABLE `farmer` (
  `id` bigint NOT NULL AUTO_INCREMENT,
  `name` varchar(50) NOT NULL,
  `id_number` varchar(18) NOT NULL COMMENT '加密存储',
  `longitude` decimal(10,7) NOT NULL,
  `latitude` decimal(10,7) NOT NULL,
  `certified` tinyint(1) DEFAULT '0',
  PRIMARY KEY (`id`),
  SPATIAL KEY `idx_location` (`longitude`,`latitude`)
);

CREATE TABLE `product_trace` (
  `id` bigint NOT NULL AUTO_INCREMENT,
  `product_id` bigint NOT NULL,
  `process` varchar(100) NOT NULL,
  `timestamp` datetime NOT NULL,
  PRIMARY KEY (`id`),
  KEY `idx_product` (`product_id`)
);

6. 安全方案

数据加密配置

// SecurityConfig.java
@Configuration
public class SecurityConfig {
    @Bean
    public PasswordEncoder passwordEncoder() {
        return new BCryptPasswordEncoder();
    }

    @Bean
    public DataSource dataSource() {
        // 敏感数据加密数据源
        HikariDataSource ds = new HikariDataSource();
        ds.setJdbcUrl("jdbc:mysql://localhost:3306/agri_db");
        ds.addDataSourceProperty("encrypt", "true");
        ds.addDataSourceProperty("trustCertificateKeyStoreUrl", "classpath:keystore.jks");
        return ds;
    }
}

7. 部署方案

Docker Compose配置

version: '3.8'
services:
  app:
    image: agri-platform:latest
    environment:
      - SPRING_DATASOURCE_URL=jdbc:mysql://mysql:3306/agri_db
      - SPRING_REDIS_HOST=redis
    depends_on:
      - mysql
      - redis

  mysql:
    image: mysql:8.0
    volumes:
      - mysql_data:/var/lib/mysql
    environment:
      - MYSQL_ROOT_PASSWORD=${DB_PASSWORD}

  redis:
    image: redis:7.0
    ports:
      - "6379:6379"

volumes:
  mysql_data:

8. 测试方案

压力测试脚本

# 使用Locust进行接口测试
locust -f load_test.py --headless -u 1000 -r 100 --host http://localhost:8080

# load_test.py核心逻辑
class UserBehavior(TaskSet):
    @task(3)
    def browse_products(self):
        self.client.get("/api/products?category=vegetable")

    @task(1)
    def place_order(self):
        self.client.post("/api/orders", json={
            "productId": 1,
            "quantity": 5,
            "address": "测试地址"
        })

9. 运营数据分析

销售数据看板

// StatisticsController.java
@GetMapping("/dashboard")
public Result getDashboardData() {
    // 农产品销量趋势
    List<SalesTrend> trends = orderMapper.selectSalesTrend(
        LocalDate.now().minusMonths(3),
        LocalDate.now()
    );
    
    // 区域销售分布
    Map<String, BigDecimal> areaSales = orderMapper.selectAreaSales();
    
    return Result.success(Map.of(
        "trends", trends,
        "areaSales", areaSales
    ));
}

10. 乡村振兴特色功能

助农金融积分系统

// PointsService.java
@Service
public class PointsService {
    @Transactional
    public void addPoints(Long farmerId, int points) {
        // 积分规则：销售100元=1积分
        Farmer farmer = farmerMapper.selectById(farmerId);
        farmer.setPoints(farmer.getPoints() + points);
        
        // 达到阈值自动兑换农资
        if(farmer.getPoints() >= 100) {
            materialService.issueMaterial(farmerId, points/100);
        }
    }
}

11. 技术挑战与解决方案

12. 总结

本平台创新点包括：

1. 基于GIS的智能产销匹配算法
2. 区块链+物联网的农产品溯源体系
3. 助农金融积分激励模型

完整实现需包含：

1. 农户APP移动端代码
2. 物流对接接口文档
3. 数据库备份方案
4. 灾难恢复演练手册