电商商品上架全流程实操指南：从数据库设计到接口落地方案

一、数据库表结构设计与初始化

商品上架系统的核心在于如何高效存储和检索商品信息（SPU）与库存信息（SKU）。为了保证数据的一致性和查询性能，我们采用MySQL作为存储引擎，设计两张核心表：商品主表（t_goods）和商品规格表（t_goods_sku）。

1.1 商品主表设计

>

商品主表用于存储商品的公共属性，如商品名称、品牌、分类、详情图以及上架状态。以下是完整的建表SQL语句，包含了必要的索引优化：

```sql CREATE TABLE `t_goods` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '商品ID', `goods_name` varchar(128) NOT NULL COMMENT '商品名称', `category_id` bigint(20) NOT NULL COMMENT '分类ID', `brand_id` bigint(20) DEFAULT NULL COMMENT '品牌ID', `goods_desc` text COMMENT '商品详情富文本', `status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '状态：0-下架，1-上架，2-删除', `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `update_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', PRIMARY KEY (`id`), KEY `idx_category_id` (`category_id`), KEY `idx_status` (`status`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='商品主表'; ```

1.2 商品规格表设计

规格表（SKU）存储具体的库存单位，包含价格、库存、规格属性JSON（如颜色、内存组合）等。该表数据量通常较大，需特别注意索引策略：

```sql CREATE TABLE `t_goods_sku` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'SKU ID', `goods_id` bigint(20) NOT NULL COMMENT '关联商品ID', `specs` varchar(512) NOT NULL COMMENT '规格属性JSON：{"颜色":"红色","内存":"128G"}', `price` decimal(10,2) NOT NULL COMMENT '销售价格', `stock` int(11) NOT NULL DEFAULT '0' COMMENT '库存数量', `sku_code` varchar(64) NOT NULL COMMENT 'SKU编码，唯一标识', `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', PRIMARY KEY (`id`), UNIQUE KEY `uk_sku_code` (`sku_code`), KEY `idx_goods_id` (`goods_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='商品规格表'; ```

二、后端核心代码实现

本示例使用Spring Boot + MyBatis框架进行开发。首先确保项目中已引入相关依赖。在项目的pom.xml中添加如下依赖：

```xml org.springframework.boot spring-boot-starter-web org.mybatis.spring.boot mybatis-spring-boot-starter 2.2.2 mysql mysql-connector-java com.alibaba fastjson 1.2.83 ```

2.1 定义数据传输对象（DTO）

为了接收前端传递的复杂商品数据，我们需要定义一个包含SPU和SKU列表的DTO类：

```java public class GoodsPublishDTO { private String goodsName; private Long categoryId; private Long brandId; private String goodsDesc; private List skuList; // Getters and Setters public static class SkuDTO { private String specs; // JSON字符串 private BigDecimal price; private Integer stock; private String skuCode; // Getters and Setters } } ```

2.2 业务逻辑层实现

Service层是商品上架的核心，必须处理事务、数据校验以及库存初始化。以下是完整的Service代码：

```java import org.springframework.transaction.annotation.Transactional; import java.util.List; @Service public class GoodsService { @Autowired private GoodsMapper goodsMapper; @Autowired private GoodsSkuMapper goodsSkuMapper; / 商品上架核心逻辑 / @Transactional(rollbackFor = Exception.class) public void publishGoods(GoodsPublishDTO dto) { // 1. 基础数据校验 if (dto == null || dto.getSkuList() == null || dto.getSkuList().isEmpty()) { throw new IllegalArgumentException("商品信息或SKU列表不能为空"); } // 2. 构建SPU实体并插入 Goods goods = new Goods(); goods.setGoodsName(dto.getGoodsName()); goods.setCategoryId(dto.getCategoryId()); goods.setBrandId(dto.getBrandId()); goods.setGoodsDesc(dto.getGoodsDesc()); goods.setStatus(1); // 默认直接上架 goodsMapper.insert(goods); // 插入后主键会回填到goods对象中 // 3. 批量处理SKU数据 Long goodsId = goods.getId(); List skuEntities = new ArrayList<>(); for (GoodsPublishDTO.SkuDTO skuDto : dto.getSkuList()) { if (skuDto.getStock() < 0) { throw new IllegalArgumentException("SKU库存不能为负数"); } GoodsSku sku = new GoodsSku(); sku.setGoodsId(goodsId); sku.setSpecs(skuDto.getSpecs()); sku.setPrice(skuDto.getPrice()); sku.setStock(skuDto.getStock()); sku.setSkuCode(skuDto.getSkuCode()); skuEntities.add(sku); } // 4. 批量插入SKU goodsSkuMapper.batchInsert(skuEntities); // 5. TODO: 发送消息队列通知搜索系统同步数据 } } ```

2.3 Mapper层XML配置

为了支持批量插入，建议在MyBatis的XML文件中使用标签：

```xml INSERT INTO t_goods_sku (goods_id, specs, price, stock, sku_code, create_time) VALUES ({item.goodsId}, {item.specs}, {item.price}, {item.stock}, {item.skuCode}, NOW()) ```

三、搜索索引同步方案

商品上架后，必须同步到Elasticsearch等搜索引擎中，以便用户能搜索到。为了保证接口响应速度，严禁在主线程中直接调用搜索索引接口。我们采用Spring内置的事件机制或异步线程池来实现。

3.1 异步配置

首先在启动类或配置类中开启异步支持：

```java @EnableAsync @SpringBootApplication public class ShopApplication { public static void main(String[] args) { SpringApplication.run(ShopApplication.class, args); } } ```

3.2 异步同步实现

创建一个专门的Service处理搜索同步，并使用@Async注解：

```java @Service public class SearchSyncService { @Autowired private RestHighLevelClient esClient; // 假设已注入ES客户端 @Async("taskExecutor") // 指定线程池 public void syncGoodsToEs(Long goodsId) { // 1. 根据goodsId查询完整商品及SKU数据（含联表查询） // GoodsDetailVO detail = goodsMapper.findDetailById(goodsId); // 2. 构造ES索引文档对象 // IndexRequest request = new IndexRequest("goods_index"); // request.id(goodsId.toString()); // request.source(JSON.toJSONString(detail), XContentType.JSON); try { // 3. 执行索引操作 // esClient.index(request, RequestOptions.DEFAULT); System.out.println("商品ID: " + goodsId + " 同步搜索索引成功"); } catch (IOException e) { // 4. 记录日志，必要时加入重试队列 System.err.println("同步失败: " + e.getMessage()); } } } ```

在GoodsService的publishGoods方法末尾调用该方法：

```java @Autowired private SearchSyncService searchSyncService; // 在publishGoods方法最后调用 searchSyncService.syncGoodsToEs(goodsId); ```

四、控制层接口暴露

提供RESTful接口供前端调用。注意接口的幂等性设计，这里通过生成唯一ID来保证，实际生产中可结合防重Token。

```java @RestController @RequestMapping("/api/goods") public class GoodsController { @Autowired private GoodsService goodsService; @PostMapping("/publish") public Result publish(@RequestBody GoodsPublishDTO dto) { try { goodsService.publishGoods(dto); return Result.success("商品上架成功"); } catch (IllegalArgumentException e) { return Result.fail(e.getMessage()); } catch (Exception e) { return Result.fail("系统繁忙，请稍后重试"); } } } ```

五、实操避坑指南

在按照上述方案落地时，请务必注意以下三个高频踩雷点：

• SKU编码唯一性：在插入SKU表前，必须先查询数据库确认sku_code是否已存在，否则在批量插入时会因唯一索引冲突导致整个事务回滚，商品上架失败。
• 事务传播机制：如果搜索同步方法在同一个Service类中，即使加了@Async，由于Spring AOP的代理机制，事务可能依然会阻塞。务必将异步方法移到单独的Service类中调用。
• JSON字段长度：MySQL中specs字段使用了varchar(512)，如果前端传入的规格组合非常复杂（例如：颜色、尺寸、材质、版本、套餐），可能导致JSON字符串超长。建议根据业务实际情况调整为text类型，或者对规格键名进行压缩。