库存调整修改2

liujiandao

2024-04-22 ce055975bf3880012871835719b2c5f7a79a3b41

库存调整修改2

 controllers/location_product_amount.go

@@ -105,8 +105,8 @@
            }
        } else {
            if len(operation.Details) > 0 {
                records[k].AdjustAmount = operation.Details[0].Amount
                records[k].DifferenceAmount = v.Amount.Add(v.AdjustAmount)
                records[k].DifferenceAmount = operation.Details[0].Amount
                records[k].AdjustAmount = v.DifferenceAmount.Sub(v.Amount)
            }
            records[k].OperationId = operation.Id
            records[k].Status = operation.Status
@@ -303,7 +303,8 @@
        return
    }
    operationSearch := models.NewOperationSearch().SetPreload(true)
    operationSearch.SetOrm(operationSearch.Orm.InnerJoins("inner join wms_operation_details on wms_operation_details.operation_id=wms_operation.id").Where("wms_operation_details.product_id=? and wms_operation.id=?", reqParams.ProductId, reqParams.OperationId))
    operationSearch.SetOrm(operationSearch.Orm.InnerJoins("inner join wms_operation_details on wms_operation_details.operation_id="+
        "wms_operation.id").Where("wms_operation_details.product_id=? and wms_operation.id=?", reqParams.ProductId, reqParams.OperationId))
    operation, err := operationSearch.First()
    if err != nil {
        util.ResponseFormat(c, code.RequestParamError, "未找到相关信息:"+err.Error())
@@ -318,19 +319,20 @@
        util.ResponseFormat(c, code.RequestError, err.Error())
        return
    }
    locProdtAmount, err := models.NewLocationProductAmountSearch().SetID(reqParams.LocationProductAmountId).First()
    locProductAmount, err := models.NewLocationProductAmountSearch().SetID(reqParams.LocationProductAmountId).First()
    if err != nil {
        util.ResponseFormat(c, code.RequestError, err.Error())
        return
    }
    adjustAmount := operation.Details[0].Amount.Sub(locProductAmount.Amount)
    if err := models.WithTransaction(func(tx *gorm.DB) error {
        if err := models.NewOperationSearch().SetOrm(tx).SetID(reqParams.OperationId).Update(&models.Operation{Status: constvar.OperationStatus_Finish}); err != nil {
            return err
        }
        if err := models.NewMaterialSearch().SetOrm(tx).SetID(reqParams.ProductId).Update(&models.Material{Amount: material.Amount.Add(operation.Details[0].Amount)}); err != nil {
        if err := models.NewMaterialSearch().SetOrm(tx).SetID(reqParams.ProductId).Update(&models.Material{Amount: material.Amount.Add(adjustAmount)}); err != nil {
            return err
        }
        if err := models.NewLocationProductAmountSearch().SetOrm(tx).SetID(reqParams.LocationProductAmountId).Update(&models.LocationProductAmount{Amount: locProdtAmount.Amount.Add(operation.Details[0].Amount)}); err != nil {
        if err := models.NewLocationProductAmountSearch().SetOrm(tx).SetID(reqParams.LocationProductAmountId).Update(&models.LocationProductAmount{Amount: operation.Details[0].Amount}); err != nil {
            return err
        }
        return nil