一、需求分析 针对川味冻品行业特点，批量价格调整功能需要满足以下核心需求： 1.支持按品类、品牌、规格等多维度筛选商品 2.支持多种价格调整策略（固定金额调整、百分比调整、阶梯定价等） 3.支持价格调整的预览和确认机制 4.记录完整的价格调整历史 5.考虑冻品行业的特殊属性（
一、需求分析
针对川味冻品行业特点，批量价格调整功能需要满足以下核心需求：
1. 支持按品类、品牌、规格等多维度筛选商品
2. 支持多种价格调整策略（固定金额调整、百分比调整、阶梯定价等）
3. 支持价格调整的预览和确认机制
4. 记录完整的价格调整历史
5. 考虑冻品行业的特殊属性（如保质期、批次等）
二、系统架构设计
1. 数据库设计
```sql
-- 商品表扩展
ALTER TABLE products ADD COLUMN is_frozen TINYINT(1) DEFAULT 0 COMMENT 是否冻品;
ALTER TABLE products ADD COLUMN frozen_type VARCHAR(50) COMMENT 冻品类型;
ALTER TABLE products ADD COLUMN production_date DATE COMMENT 生产日期;
ALTER TABLE products ADD COLUMN shelf_life INT COMMENT 保质期(天);
-- 价格调整记录表
CREATE TABLE price_adjustment_logs (
id BIGINT PRIMARY KEY AUTO_INCREMENT,
adjustment_name VARCHAR(100) NOT NULL COMMENT 调整名称,
adjustment_type TINYINT NOT NULL COMMENT 调整类型(1:固定金额,2:百分比,3:阶梯),
adjustment_value DECIMAL(10,2) NOT NULL COMMENT 调整值,
filter_conditions TEXT COMMENT 筛选条件JSON,
operator_id BIGINT NOT NULL COMMENT 操作人ID,
operator_name VARCHAR(50) NOT NULL COMMENT 操作人姓名,
create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT 创建时间,
status TINYINT NOT NULL DEFAULT 0 COMMENT 状态(0:草稿,1:已执行,2:已取消)
);
-- 价格调整明细表
CREATE TABLE price_adjustment_items (
id BIGINT PRIMARY KEY AUTO_INCREMENT,
log_id BIGINT NOT NULL COMMENT 调整记录ID,
product_id BIGINT NOT NULL COMMENT 商品ID,
original_price DECIMAL(10,2) NOT NULL COMMENT 原价格,
adjusted_price DECIMAL(10,2) NOT NULL COMMENT 调整后价格,
adjustment_amount DECIMAL(10,2) NOT NULL COMMENT 调整金额,
FOREIGN KEY (log_id) REFERENCES price_adjustment_logs(id)
);
```
2. 后端服务设计
核心接口
1. 获取筛选条件选项
```java
@GetMapping("/api/price-adjust/filter-options")
public ResponseEntity
>> getFilterOptions() {
// 返回品类、品牌、冻品类型等筛选选项
}
```
2. 预览价格调整
```java
@PostMapping("/api/price-adjust/preview")
public ResponseEntity previewAdjustment(
@RequestBody PriceAdjustRequest request) {
// 根据筛选条件和调整策略计算预览结果
}
```
3. 执行价格调整
```java
@PostMapping("/api/price-adjust/execute")
public ResponseEntity executeAdjustment(
@RequestBody @Valid PriceAdjustExecuteRequest request) {
// 执行价格调整并记录日志
}
```
4. 查询调整历史
```java
@GetMapping("/api/price-adjust/history")
public ResponseEntity> getAdjustmentHistory(
@RequestParam(defaultValue = "1") int page,
@RequestParam(defaultValue = "10") int size) {
// 分页查询价格调整历史
}
```
3. 前端实现要点
1. 筛选条件组件
- 多级联动选择器（品类→品牌→规格）
- 冻品特殊属性筛选（保质期范围、生产日期范围等）
2. 调整策略配置
```javascript
// 调整策略配置示例
const adjustmentStrategies = [
{ id: 1, name: 固定金额, component: FixedAmountAdjust },
{ id: 2, name: 百分比, component: PercentageAdjust },
{ id: 3, name: 阶梯定价, component: TieredPricingAdjust }
];
```
3. 预览表格
- 显示商品信息、原价格、调整后价格、调整金额
- 支持全选/反选
- 显示调整商品总数和总金额变化
三、核心业务逻辑实现
1. 价格调整服务类
```java
@Service
@RequiredArgsConstructor
public class PriceAdjustmentService {
private final ProductRepository productRepository;
private final PriceAdjustmentLogRepository logRepository;
private final PriceAdjustmentItemRepository itemRepository;
public PriceAdjustPreviewDTO previewAdjustment(PriceAdjustRequest request) {
// 1. 根据筛选条件查询商品
List products = productRepository.findByFilterConditions(request.getFilterConditions());
// 2. 根据调整策略计算新价格
List items = products.stream()
.map(product -> calculateNewPrice(product, request.getStrategy()))
.collect(Collectors.toList());
// 3. 计算汇总信息
BigDecimal totalAdjustment = items.stream()
.map(PriceAdjustItemDTO::getAdjustmentAmount)
.reduce(BigDecimal.ZERO, BigDecimal::add);
return new PriceAdjustPreviewDTO(items, totalAdjustment);
}
@Transactional
public void executeAdjustment(PriceAdjustExecuteRequest request) {
// 1. 创建调整记录
PriceAdjustmentLog log = new PriceAdjustmentLog();
// 设置log属性...
logRepository.save(log);
// 2. 执行价格调整
List products = productRepository.findByFilterConditions(request.getFilterConditions());
List items = new ArrayList<>();
for (Product product : products) {
BigDecimal newPrice = calculateNewPrice(product, request.getStrategy());
if (newPrice.compareTo(product.getPrice()) != 0) {
// 更新商品价格
product.setPrice(newPrice);
productRepository.save(product);
// 创建调整明细
PriceAdjustmentItem item = new PriceAdjustmentItem();
item.setLogId(log.getId());
item.setProductId(product.getId());
item.setOriginalPrice(product.getOriginalPrice()); // 保留原始价格
item.setAdjustedPrice(newPrice);
item.setAdjustmentAmount(newPrice.subtract(product.getOriginalPrice()));
items.add(item);
}
}
itemRepository.saveAll(items);
log.setStatus(1); // 已执行
logRepository.save(log);
}
private BigDecimal calculateNewPrice(Product product, AdjustmentStrategy strategy) {
// 根据不同策略计算新价格
switch (strategy.getType()) {
case FIXED_AMOUNT:
return product.getPrice().add(strategy.getValue());
case PERCENTAGE:
return product.getPrice().multiply(
BigDecimal.ONE.add(strategy.getValue().divide(BigDecimal.valueOf(100))));
case TIERED:
return calculateTieredPrice(product, strategy.getTiers());
default:
return product.getPrice();
}
}
}
```
2. 冻品特殊处理
```java
// 在商品查询服务中添加冻品特殊逻辑
public List findByFilterConditions(Map conditions) {
// 基础查询
Query query = new Query();
// 处理冻品特殊条件
if (conditions.containsKey("frozenType")) {
query.addCriteria(Criteria.where("frozenType").is(conditions.get("frozenType")));
}
if (conditions.containsKey("minShelfLife")) {
// 计算保质期截止日期
Date minExpiryDate = DateUtils.addDays(new Date(), -(Integer)conditions.get("minShelfLife"));
query.addCriteria(Criteria.where("productionDate").lte(minExpiryDate));
}
// 其他条件...
return mongoTemplate.find(query, Product.class);
}
```
四、安全与审计考虑
1. 权限控制
- 只有特定角色（如价格管理员）可以执行价格调整
- 关键操作需要二次验证（如输入管理员密码）
2. 操作审计
- 记录所有价格调整操作的详细日志
- 包括操作人、操作时间、调整前后的价格对比等
3. 数据备份
- 在执行价格调整前自动备份相关商品价格数据
- 支持回滚到指定时间点的价格
五、测试方案
1. 单元测试
- 测试不同调整策略的计算逻辑
- 测试边界条件（如价格为0、负数调整等）
2. 集成测试
- 测试完整流程：筛选→预览→执行→查询历史
- 测试事务处理（部分失败时的回滚）
3. 性能测试
- 测试批量调整10,000+商品时的性能
- 测试高并发场景下的稳定性
六、部署与监控
1. 部署方案
- 灰度发布：先在测试环境验证，再逐步发布到生产环境
- 回滚机制：支持快速回滚到上一个稳定版本
2. 监控指标
- 价格调整操作成功率
- 平均处理时间
- 失败操作数量及原因
3. 报警机制
- 价格调整失败时自动报警
- 异常价格调整（如价格调整超过阈值）时报警
通过以上方案，可以实现一个稳定、高效、安全的川味冻品批量价格调整系统，满足冻品行业特殊需求的同时，提供良好的用户体验和操作可追溯性。
