如何解决Gorm事务提示「已提交或回滚」的重复操作错误？

你遇到的错误核心是：事务对象在执行Rollback()或Commit()后，生命周期已结束，后续任何对它的操作都会触发该错误。结合你的代码，主要存在两个关键问题：

代码中的隐患 #

1. 业务检查逻辑顺序错误：d.checkSackPackagesAreUnloaded()的错误判断放在了tx.Commit()之后，此时事务已经提交，就算检查出错也无法回滚，完全违背了事务原子性的设计初衷。
2. 未兜底事务回滚逻辑：虽然出错时手动调用了Rollback()，但如果代码出现未捕获的panic或遗漏的错误分支，事务会长期处于未提交状态；若后续不小心复用该tx对象，就会触发「事务已提交或回滚」的错误。

修复后的代码 #

func (d *DistributeService) Distribute(vehicleNumberPlate string, request model.DistributeRequest) (*model.DistributeResponse, error) {
    var response model.DistributeResponse
    response.Vehicle = vehicleNumberPlate
    var routeList []model.RouteResponse

    tx := d.repo.BeginTransaction()
    // 用defer兜底：仅当事务未提交时执行回滚
    defer func() {
        if r := recover(); r != nil {
            _ = tx.Rollback()
            panic(r) // 可根据业务需求调整是否重新抛出panic
        } else if tx != nil {
            // 简单处理：若未主动提交事务则回滚，具体可结合ORM特性判断事务状态
            _ = tx.Rollback()
        }
    }()

    for _, routes := range request.RouteRequest {
        var routeResponse model.RouteResponse
        strategy, isStrategyExists := d.strategies[routes.DeliveryPoint]
        if !isStrategyExists {
            logrus.Errorf("Invalid delivery point: %v", routes.DeliveryPoint)
            return nil, errors.New("invalid delivery point")
        }

        resp, err := strategy.Distribute(routes.Deliveries, vehicleNumberPlate, tx)
        if err != nil {
            logrus.Errorf("Error while distributing: %v", err)
            // 回滚事务并处理回滚本身的错误
            if rollbackErr := tx.Rollback(); rollbackErr != nil {
                logrus.Errorf("Failed to rollback transaction: %v", rollbackErr)
            }
            return nil, err
        }

        routeResponse.DeliveryPoint = routes.DeliveryPoint
        routeResponse.Deliveries = *resp
        routeList = append(routeList, routeResponse)
    }

    // 先执行业务检查，确认无误再提交事务
    err := d.checkSackPackagesAreUnloaded()
    if err != nil {
        logrus.Errorf("Check sack packages failed: %v", err)
        if rollbackErr := tx.Rollback(); rollbackErr != nil {
            logrus.Errorf("Failed to rollback transaction: %v", rollbackErr)
        }
        return nil, err
    }

    // 提交事务，提交成功后tx对象失效
    if err := tx.Commit(); err != nil {
        logrus.Errorf("Failed to commit transaction: %v", err)
        return nil, err
    }
    // 标记tx为nil，避免defer中重复回滚已提交的事务
    tx = nil

    response.RouteResponse = routeList
    return &response, nil
}

关键优化点 #

• defer兜底回滚：确保任何异常或错误分支下，未提交的事务都会被回滚，避免事务悬置或重复操作。
• 调整业务检查顺序：将业务校验放在事务提交前，保证校验失败时能正常回滚事务，符合事务原子性要求。
• 显式处理回滚/提交错误：不忽略Rollback()和Commit()本身可能出现的异常（如数据库连接中断）。
• 提交后清空tx引用：避免defer中的回滚逻辑再次操作已结束的事务。

内容的提问来源于stack exchange，提问作者Mert Özler