Java技术债务处理案例

wen java案例 2026-08-01 198

Java技术债务处理案例

案例背景

某电商系统核心订单模块因历史原因积累了大量技术债务,导致：

Java技术债务处理案例

代码维护成本高
系统性能瓶颈明显
新功能开发效率低下

主要技术债务表现

// 债务1：超长方法（500+行）
public void processOrder(Order order) {
    // 验证逻辑
    if (order.getAmount() > 10000) {
        // 特殊审批逻辑...
    }
    if (order.getCustomerType() == VIP) {
        // VIP特殊折扣...
    }
    // 库存检查
    // 支付处理
    // 发票生成
    // 物流通知
    // 积分计算
    // 等等几十个业务逻辑...
}

// 债务2：重复代码
public void sendEmail(Order order) {
    // 订单确认邮件逻辑
    String content = "订单" + order.getOrderNo() + "已确认";
    EmailService.send("customer@email.com", "订单确认", content);
}
public void sendSMS(Order order) {
    String content = "订单" + order.getOrderNo() + "已确认";
    SMSService.send("13800138000", content);
}

// 债务3：未使用的废弃代码
@Deprecated
public String getOrderStatusString(Order order) {
    // 过时的状态处理逻辑，已废弃3年
    switch(order.getStatus()) {
        case 1: return "新建";
        case 2: return "审核中";
        // ...废弃逻辑
    }
    return "未知";
}

债务处理方案

系统重构计划

// 重构后：模块化设计
@Service
public class OrderProcessor {
    private final OrderValidator validator;
    private final InventoryChecker inventoryChecker;
    private final PaymentProcessor paymentProcessor;
    private final InvoiceGenerator invoiceGenerator;
    private final NotificationService notificationService;
    private final PointsCalculator pointsCalculator;
    public OrderResult processOrder(Order order) {
        // 1. 校验
        validator.validate(order);
        // 2. 库存检查
        inventoryChecker.checkStock(order.getItems());
        // 3. 支付处理
        Payment payment = paymentProcessor.process(order.getPayment());
        // 4. 生成发票
        Invoice invoice = invoiceGenerator.generate(order);
        // 5. 组装结果
        return new OrderResult(order, payment, invoice);
    }
}

消除重复代码

// 重构后：统一通知服务
@Component
public class NotificationService {
    public void sendOrderNotification(Order order, NotificationChannel channel) {
        String content = buildNotificationContent(order);
        String subject = "订单" + order.getOrderNo() + "状态通知";
        switch(channel) {
            case EMAIL:
                emailSender.send(order.getCustomerEmail(), subject, content);
                break;
            case SMS:
                smsSender.send(order.getCustomerPhone(), content);
                break;
            case WECHAT:
                wechatSender.send(order.getCustomerWechat(), content);
                break;
        }
    }
    private String buildNotificationContent(Order order) {
        Template template = templateEngine.getTemplate("order_notification");
        Map<String, Object> params = new HashMap<>();
        params.put("orderNo", order.getOrderNo());
        params.put("status", order.getStatus().getDesc());
        return template.render(params);
    }
}

清理废弃代码

// 清理后：删除废弃代码，统一枚举
public enum OrderStatus {
    CREATED(1, "新建"),
    PENDING_REVIEW(2, "待审核"),
    PROCESSING(3, "处理中"),
    COMPLETED(4, "已完成"),
    CANCELLED(5, "已取消");
    private final int code;
    private final String desc;
    OrderStatus(int code, String desc) {
        this.code = code;
        this.desc = desc;
    }
    public static OrderStatus fromCode(int code) {
        return Arrays.stream(values())
            .filter(status -> status.code == code)
            .findFirst()
            .orElseThrow(() -> new IllegalArgumentException("未知状态码: " + code));
    }
    public boolean isFinalState() {
        return this == COMPLETED || this == CANCELLED;
    }
}

性能优化

// 优化前：N+1查询问题
public List<OrderDetail> getOrderDetails(List<Order> orders) {
    List<OrderDetail> details = new ArrayList<>();
    for (Order order : orders) {
        // 每个订单都执行一次查询
        List<OrderItem> items = orderItemRepository.findByOrderId(order.getId());
        details.add(new OrderDetail(order, items));
    }
    return details;
}
// 优化后：批量查询
public List<OrderDetail> getOrderDetails(List<Order> orders) {
    List<Long> orderIds = orders.stream()
        .map(Order::getId)
        .collect(Collectors.toList());
    // 一次查询所有订单项
    Map<Long, List<OrderItem>> itemsMap = orderItemRepository
        .findByOrderIdIn(orderIds)
        .stream()
        .collect(Collectors.groupingBy(OrderItem::getOrderId));
    return orders.stream()
        .map(order -> new OrderDetail(order, itemsMap.getOrDefault(order.getId(), List.of())))
        .collect(Collectors.toList());
}

添加测试覆盖

@SpringBootTest
class OrderProcessorTest {
    @MockBean
    private InventoryChecker inventoryChecker;
    @Autowired
    private OrderProcessor orderProcessor;
    @Test
    void testProcessOrder_Success() {
        // 准备测试数据
        Order order = buildTestOrder();
        when(inventoryChecker.checkStock(anyList())).thenReturn(true);
        // 执行测试
        OrderResult result = orderProcessor.processOrder(order);
        // 验证结果
        assertNotNull(result);
        assertEquals(OrderStatus.PROCESSING, result.getOrder().getStatus());
        verify(inventoryChecker, times(1)).checkStock(anyList());
    }
    @Test
    void testProcessOrder_InvalidOrder() {
        Order order = buildInvalidOrder();
        assertThrows(ValidationException.class, () -> {
            orderProcessor.processOrder(order);
        });
        verify(inventoryChecker, never()).checkStock(anyList());
    }
}