当前位置：首页 > news >正文

[附源码]JAVA+SSM农产品全链路追溯系统开发实战（源码+部署指南）

news 2026/3/27 5:57:49

1. 农产品追溯系统开发背景与价值

农产品安全一直是社会关注的焦点问题。记得去年我参与过一个农场项目，他们最头疼的就是无法向消费者证明自己的蔬菜没有使用农药。传统纸质记录方式不仅容易丢失，还经常出现信息不完整的情况。这就是为什么我们需要开发农产品全链路追溯系统。

这套系统能记录农产品从种植、加工、运输到销售的全过程信息。消费者扫描产品包装上的二维码，就能看到这个苹果是什么时候采摘的、经过哪些检测、运输过程中温度是否达标等详细信息。对于企业来说，这不仅是提升品牌信任度的利器，更是内部质量管理的好帮手。

从技术角度看，采用SSM框架开发这类系统有几个明显优势。Spring提供了完善的依赖注入和事务管理，SpringMVC让前后端交互变得简单，MyBatis则能高效操作数据库。这三个组件组合在一起，既保证了开发效率，又能应对农产品追溯场景下的复杂业务逻辑。

2. 开发环境快速搭建指南

在开始编码前，我们需要准备好开发环境。这里我推荐使用JDK1.8+Tomcat8.5+MySQL5.7的组合，这也是大多数企业项目的标准配置。

安装过程有几个容易踩坑的地方需要注意：

JDK安装后要记得配置JAVA_HOME环境变量
Tomcat的server.xml需要调整Connector端口
MySQL要设置好字符集为utf8mb4

这里给出一个快速验证环境是否正确的测试代码：

public class EnvTest { public static void main(String[] args) { System.out.println("Java版本：" + System.getProperty("java.version")); System.out.println("文件编码：" + System.getProperty("file.encoding")); } }

如果使用Maven管理项目，pom.xml中需要包含这些核心依赖：

<dependencies> <!-- Spring核心 --> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>5.2.8.RELEASE</version> </dependency> <!-- SpringMVC --> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-webmvc</artifactId> <version>5.2.8.RELEASE</version> </dependency> <!-- MyBatis --> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis</artifactId> <version>3.5.6</version> </dependency> </dependencies>

3. 数据库设计与关键表结构

农产品追溯系统的数据库设计要考虑数据的完整性和查询效率。经过多次项目实践，我总结出几个核心表：

产品基础表(product_base)：存储产品基本信息
生产记录表(production_record)：记录种植/养殖过程
检测报告表(inspection_report)：存储质检数据
流通记录表(circulation_record)：跟踪物流信息

以产品基础表为例，建表SQL应该是这样的：

CREATE TABLE `product_base` ( `id` bigint(20) NOT NULL AUTO_INCREMENT, `product_code` varchar(64) NOT NULL COMMENT '产品唯一编码', `product_name` varchar(100) NOT NULL, `product_type` varchar(50) NOT NULL, `farm_id` bigint(20) NOT NULL COMMENT '生产基地ID', `plant_date` date DEFAULT NULL COMMENT '种植日期', `harvest_date` date DEFAULT NULL COMMENT '采收日期', `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP, PRIMARY KEY (`id`), UNIQUE KEY `idx_product_code` (`product_code`), KEY `idx_farm` (`farm_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='产品基础信息表';

在设计数据库时，我建议遵循这几个原则：

所有表都要有创建时间字段
业务主键使用自增ID，同时要有业务编码字段
为常用查询条件建立合适索引
字段注释要完整

4. SSM框架整合与配置

SSM框架整合是项目的基础，这里分享一个经过多个项目验证的可靠配置方案。

首先看Spring的applicationContext.xml配置要点：

<!-- 包扫描路径 --> <context:component-scan base-package="com.trace.product"/> <!-- 数据源配置 --> <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"> <property name="url" value="${jdbc.url}"/> <property name="username" value="${jdbc.username}"/> <property name="password" value="${jdbc.password}"/> </bean> <!-- 事务管理 --> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean>

MyBatis的配置需要特别注意mapper扫描和分页插件：

<!-- MyBatis SqlSessionFactory --> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="dataSource" ref="dataSource"/> <property name="mapperLocations" value="classpath:mapper/*.xml"/> <property name="plugins"> <array> <bean class="com.github.pagehelper.PageInterceptor"> <property name="properties"> <value> helperDialect=mysql reasonable=true </value> </property> </bean> </array> </property> </bean> <!-- Mapper接口扫描 --> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <property name="basePackage" value="com.trace.product.dao"/> </bean>

SpringMVC的配置要处理好静态资源和JSON转换：

<!-- 启用注解驱动 --> <mvc:annotation-driven> <mvc:message-converters> <bean class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter"/> </mvc:message-converters> </mvc:annotation-driven> <!-- 静态资源处理 --> <mvc:resources mapping="/static/**" location="/static/"/> <!-- 视图解析器 --> <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver"> <property name="prefix" value="/WEB-INF/views/"/> <property name="suffix" value=".jsp"/> </bean>

5. 核心功能模块实现

5.1 产品信息管理模块

产品信息管理是系统的基础，我们先来看Controller层的实现：

@Controller @RequestMapping("/product") public class ProductController { @Autowired private ProductService productService; @GetMapping("/detail/{code}") @ResponseBody public Result<ProductDetailVO> getDetail(@PathVariable String code) { ProductDetailVO detail = productService.getDetailByCode(code); return Result.success(detail); } @PostMapping("/add") @ResponseBody public Result addProduct(@Valid @RequestBody ProductAddDTO dto) { productService.addProduct(dto); return Result.success(); } }

Service层需要处理业务逻辑和事务：

@Service @Transactional public class ProductServiceImpl implements ProductService { @Autowired private ProductDao productDao; @Override public ProductDetailVO getDetailByCode(String code) { ProductBase base = productDao.selectByCode(code); if(base == null) { throw new BusinessException("产品不存在"); } ProductDetailVO vo = new ProductDetailVO(); BeanUtils.copyProperties(base, vo); // 查询关联的生产记录 List<ProductionRecord> records = productionDao.listByProductId(base.getId()); vo.setProductionRecords(records); return vo; } }

5.2 追溯二维码生成模块

二维码是追溯系统的入口，这里使用ZXing库实现：

public class QrCodeUtil { private static final int WIDTH = 300; private static final int HEIGHT = 300; private static final String FORMAT = "png"; public static byte[] generate(String content) throws WriterException, IOException { Map<EncodeHintType, Object> hints = new HashMap<>(); hints.put(EncodeHintType.CHARACTER_SET, "UTF-8"); hints.put(EncodeHintType.MARGIN, 1); BitMatrix matrix = new MultiFormatWriter() .encode(content, BarcodeFormat.QR_CODE, WIDTH, HEIGHT, hints); ByteArrayOutputStream out = new ByteArrayOutputStream(); MatrixToImageWriter.writeToStream(matrix, FORMAT, out); return out.toByteArray(); } }

在实际项目中，我们会把二维码内容设计为包含产品ID和验证信息的URL，例如：https://trace.example.com/query?code=PROD20230001&sign=xxxx

5.3 数据可视化展示

使用ECharts展示农产品检测数据的前端代码示例：

function renderInspectionChart(data) { const chart = echarts.init(document.getElementById('chart')); const option = { title: { text: '农产品检测指标趋势' }, tooltip: { trigger: 'axis' }, legend: { data: ['农药残留', '重金属含量'] }, xAxis: { type: 'category', data: data.map(item => item.date) }, yAxis: { type: 'value' }, series: [ { name: '农药残留', type: 'line', data: data.map(item => item.pesticide) }, { name: '重金属含量', type: 'line', data: data.map(item => item.heavyMetal) } ] }; chart.setOption(option); }

6. 系统部署与运维

6.1 多环境配置管理

实际项目中我们需要区分开发、测试和生产环境。Spring提供了Profile机制：

# application-dev.properties jdbc.url=jdbc:mysql://localhost:3306/trace_dev jdbc.username=dev_user jdbc.password=dev123 # application-prod.properties jdbc.url=jdbc:mysql://prod-db:3306/trace_prod jdbc.username=prod_user jdbc.password=Prod@2023

在启动时通过-Dspring.profiles.active=prod指定环境。

6.2 Tomcat优化配置

在生产环境部署时，需要调整Tomcat的server.xml：

<Connector port="8080" protocol="HTTP/1.1" connectionTimeout="20000" maxThreads="500" minSpareThreads="30" acceptCount="100" compression="on" compressionMinSize="2048" compressableMimeType="text/html,text/xml,text/css,application/json" URIEncoding="UTF-8"/>

6.3 日志管理方案

建议使用Logback+ELK的方案：

<!-- logback-spring.xml --> <configuration> <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"> <file>logs/app.log</file> <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> <fileNamePattern>logs/app.%d{yyyy-MM-dd}.log</fileNamePattern> <maxHistory>30</maxHistory> </rollingPolicy> <encoder> <pattern>%d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n</pattern> </encoder> </appender> <root level="INFO"> <appender-ref ref="FILE"/> </root> </configuration>

7. 项目优化与扩展

7.1 缓存优化策略

对于高频访问的产品信息，可以使用Redis缓存：

@Service public class ProductServiceImpl implements ProductService { @Autowired private RedisTemplate<String, Object> redisTemplate; @Override @Cacheable(value = "product", key = "#code") public ProductDetailVO getDetailByCode(String code) { // 数据库查询逻辑 } @Override @CacheEvict(value = "product", key = "#dto.code") public void updateProduct(ProductUpdateDTO dto) { // 更新逻辑 } }

7.2 大数据量处理方案

当产品数据量很大时，需要优化查询：

public PageInfo<ProductVO> searchProducts(ProductQuery query, int pageNum, int pageSize) { PageHelper.startPage(pageNum, pageSize); List<ProductBase> list = productDao.search(query); return new PageInfo<>(list); }

对应的Mapper.xml要使用延迟加载：

<select id="search" resultMap="BaseResultMap"> SELECT <include refid="Base_Column_List"/> FROM product_base <where> <if test="name != null and name != ''"> AND product_name LIKE CONCAT('%',#{name},'%') </if> <if test="type != null"> AND product_type = #{type} </if> </where> ORDER BY create_time DESC </select>

7.3 微服务改造建议

随着业务发展，可以考虑将系统拆分为：

基础数据服务
追溯查询服务
报表分析服务
权限管理服务

使用Spring Cloud的FeignClient实现服务调用：

@FeignClient(name = "trace-data-service", path = "/api/product") public interface ProductDataService { @GetMapping("/{code}") Result<ProductDetailVO> getDetail(@PathVariable String code); @PostMapping Result<String> createProduct(@RequestBody ProductCreateDTO dto); }

查看全文

http://www.jsqmd.com/news/323370/