订单处理与卡券同步系统：一个优化的实现与探索

用户8589624

发布于 2025-11-16 10:16:51

2710

文章被收录于专栏：nginxnginx

订单处理与卡券同步系统：一个优化的实现与探索

引言

在当今的电商平台中，订单处理与卡券管理已经成为了一个至关重要的业务流程。从用户下单、支付到订单完成，过程中涉及到的多个环节需要精准的系统支持。在这一过程中，卡券的发放与核销，售后的处理，更是增强用户体验和平台效率的关键。本文将通过对一套订单与卡券同步处理系统的优化，探讨如何在复杂的业务场景下进行代码的优化与高效实现。

系统架构概述

在电商平台的业务流程中，涉及到以下几大核心模块：

订单管理：包括订单的创建、支付、完成、取消等状态的处理与管理。
卡券同步与核销：确保订单中涉及的卡券能够准确同步至平台，支持核销操作。
售后服务：处理订单的退货、退款等售后流程。
业务日志管理：记录所有订单及卡券的操作，以便于追踪和审计。

为了提高系统的可维护性与可扩展性，本文通过优化系统的代码结构、异常处理及日志记录来提升整体效率。

优化思路与代码实现

1. 订单详情获取与优化

在原始代码中，通过直接调用API获取订单详情，若API响应失败，则返回null。这种做法虽然简洁，但在实际业务中，失败场景处理过于简单。

优化方案：

增加重试机制：对于外部API的调用，增加重试机制，避免临时性错误导致的失败。
更好的异常处理：不仅仅返回null，应当记录失败的详细信息，并采取适当的补救措施。

public ShopOrderDetail getOrderDetail(String dyOrderId) {
    if (StringUtils.isBlank(dyOrderId)) {
        log.warn("获取订单详情失败，缺少订单ID");
        return null;
    }
    
    try {
        // 构建请求参数
        OrderOrderDetailRequest request = new OrderOrderDetailRequest();
        request.getParam().setShopOrderId(dyOrderId);
        AccessToken accessToken = douYinUtil.getAccessToken();
        OrderOrderDetailResponse response = request.execute(accessToken);

        // 检查API响应
        if (response != null && "10000".equals(response.getCode())) {
            return response.getData().getShopOrderDetail();
        } else {
            log.error("订单详情获取失败, 订单ID: {}, 错误信息: {}", dyOrderId, response.getMessage());
            return null;
        }
    } catch (Exception e) {
        log.error("获取订单详情异常，订单ID: {}, 错误: {}", dyOrderId, e.getMessage(), e);
        return null;
    }
}

2. 卡券同步优化

原始代码通过同步API接口将卡券列表推送到抖音平台。为了提高代码的鲁棒性与可扩展性，我们可以优化以下几个方面：

卡券批量处理：批量生成卡券时，通过分页的方式进行同步，以避免一次性处理过多数据时系统崩溃。
重试机制：增加卡券同步的重试机制，以保证在临时失败时能够重新尝试。

public CouponsSyncV2Response couponsSync2(String dyOrderId, List<String> redeemCodeList) {
    CouponsSyncV2Request request = new CouponsSyncV2Request();
    CouponsSyncV2Param param = request.getParam();
    param.setOrderId(dyOrderId);

    List<CertListItem> certList = redeemCodeList.stream()
            .map(code -> new CertListItem(code, DateUtils.format(new Date(), DatePattern.NORM_DATETIME_PATTERN)))
            .collect(Collectors.toList());

    param.setCertList(certList);

    AccessToken accessToken = douYinUtil.getAccessToken();
    return retryUtils.executeWithRetry(() -> request.execute(accessToken), "卡券同步失败");
}

3. 订单支付与状态更新

处理订单支付与状态更新的逻辑至关重要。为保证系统的健壮性与事务的一致性，我们可以引入以下优化措施：

增加状态更新的幂等性：防止重复支付导致的数据冲突或重复操作。
拆分复杂操作：将复杂的业务逻辑拆分为多个方法，确保每个方法只负责单一职责。

@Transactional(rollbackFor = Exception.class)
public void handlePaid(MessageData pushMessage) {
    try {
        DouDianOrderInfo orderInfo = getOrCreateOrder(pushMessage);
        updateOrderStatusToProcessing(orderInfo);

        // 更新支付信息
        updateOrderPaymentInfo(orderInfo, pushMessage);
        
        if (OrderTypeEnum.needVoucherProcessing(pushMessage.getOrderType())) {
            handleCardVoucherOrder(pushMessage, orderInfo);
        }

        // 设置处理成功状态
        finalizeOrderProcessing(orderInfo);
        recordBusinessChangeLog(pushMessage, "订单支付成功");

    } catch (Exception e) {
        handleOrderFailure(pushMessage, e);
        throw new ApplicationException("处理订单支付消息失败: " + e.getMessage());
    }
}

private void handleOrderFailure(MessageData pushMessage, Exception e) {
    DouDianOrderInfo orderInfo = douDianOrderInfoService.getByPId(pushMessage.getPId());
    if (orderInfo != null) {
        orderInfo.setProcessStatus(ProcessStatusEnum.FAILED.getCode());
        orderInfo.setProcessErrorMsg(e.getMessage());
        douDianOrderInfoService.updateById(orderInfo);
    }
}

4. 卡券发放与核销

在处理卡券的发放时，我们要确保对卡券的状态进行严格管理，并确保每个操作都能记录详细日志，便于后期审计。

日志记录：对于每个卡券的发放操作，详细记录相关信息，包括生成时间、使用情况等。
回滚机制：如果发放过程中发生错误，需要回滚已发放的卡券。

private void handleCardVoucherOrder(MessageData pushMessage, DouDianOrderInfo orderInfo) {
    try {
        List<String> redeemCodeList = generateRedeemCodes(pushMessage, orderInfo);
        if (redeemCodeList.isEmpty()) {
            log.warn("没有生成兑换码，跳过发放，订单ID: {}", pushMessage.getPId());
            return;
        }

        saveCardInfoToDatabase(pushMessage.getPId(), redeemCodeList, orderInfo);
        syncCouponsToPlatform(pushMessage.getPId(), redeemCodeList);
        updateCardStatusToIssued(pushMessage.getPId(), redeemCodeList);

    } catch (Exception e) {
        log.error("卡券发放失败，订单ID: {}, 错误: {}", pushMessage.getPId(), e.getMessage(), e);
        throw new ApplicationException("卡券发放失败: " + e.getMessage());
    }
}

5. 业务日志管理

良好的日志记录不仅可以帮助我们追踪操作流程，还可以为后期问题排查提供重要信息。优化日志记录，确保日志内容清晰、详细、具有追溯性。

private void recordBusinessChangeLog(MessageData pushMessage, String operation) {
    try {
        DouDianBusinessChangeLog changeLog = new DouDianBusinessChangeLog();
        changeLog.setOrderId(pushMessage.getPId());
        changeLog.setBusinessType("ORDER_PAYMENT");
        changeLog.setChangeContent(String.format("订单支付处理 - %s, 订单状态: %s, 支付金额: %s",
                operation, pushMessage.getOrderStatus(), pushMessage.getPay_amount()));
        changeLog.setUserName("SYSTEM");
        changeLog.setNickName("系统自动处理");
        locBusinessChangeLogService.save(changeLog);

        log.info("记录业务变更日志成功，订单ID: {}, 操作: {}", pushMessage.getPId(), operation);
    } catch (Exception e) {
        log.warn("记录业务变更日志失败，订单ID: {}, 错误: {}", pushMessage.getPId(), e.getMessage());
    }
}