| | |
|---|
| | | "wms/extend/code" |
|---|
| | | "wms/extend/util" |
|---|
| | | "wms/models" |
|---|
| | | "wms/pkg/mysqlx" |
|---|
| | | "wms/request" |
|---|
| | | "wms/response" |
|---|
| | | "wms/service" |
|---|
| | | ) |
|---|
| | | |
|---|
| | | type LocationProductAmountController struct { |
|---|
| | |
|---|
| | | search.Orm = search.Orm. |
|---|
| | | Table("wms_location_product_amount"). |
|---|
| | | Select(`wms_location_product_amount.id as location_product_amount_id,wms_location.id as location_id,wms_location.name as location_name,material.id as product_id,material.name as product_name,wms_location_product_amount.amount,material.unit,wms_location_product_amount.create_date`). |
|---|
| | | InnerJoins("inner join wms_location_product on wms_location_product.id=wms_location_product_amount.location_product_id"). |
|---|
| | | InnerJoins("inner join material on material.id=wms_location_product.product_id"). |
|---|
| | | InnerJoins("inner join wms_location on wms_location.id=wms_location_product.location_id") |
|---|
| | | //Joins("inner join wms_operation_details on wms_operation_details.product_id=wms_location_product.product_id"). |
|---|
| | | //Joins("inner join wms_operation on wms_operation.id=wms_operation_details.operation_id and wms_operation.base_operation_type=? and wms_operation.status=?", constvar.BaseOperationTypeAdjust, constvar.OperationStatus_Ready) |
|---|
| | | InnerJoins("inner join material on material.id=wms_location_product_amount.product_id"). |
|---|
| | | InnerJoins("inner join wms_location on wms_location.id=wms_location_product_amount.location_id") |
|---|
| | | |
|---|
| | | var ( |
|---|
| | | records = make([]*models.LocationProductAmountWithOperation, 0) |
|---|
| | | total int64 |
|---|
| | |
|---|
| | | } |
|---|
| | | var operation models.Operation |
|---|
| | | for k, v := range records { |
|---|
| | | if res := models.NewOperationSearch().Orm.Preload("Details", "product_id=?", v.ProductId).Where("wms_operation.base_operation_type=? and wms_operation.status=? and wms_operation.to_location_id=?", constvar.BaseOperationTypeAdjust, constvar.OperationStatus_Ready, v.LocationId).First(&operation); res.Error != nil { |
|---|
| | | if res := mysqlx.GetDB().Table("wms_operation").InnerJoins("inner join wms_operation_details on wms_operation_details.operation_id=wms_operation.id").Where("wms_operation.base_operation_type=? and wms_operation.status=? and wms_operation_details.to_location_id=? and wms_operation_details.product_id=?", constvar.BaseOperationTypeAdjust, constvar.OperationStatus_Ready, v.LocationId, v.ProductId).First(&operation); res.Error != nil { |
|---|
| | | if errors.Is(res.Error, gorm.ErrRecordNotFound) { |
|---|
| | | records[k].Status = constvar.OperationStatus_Finish |
|---|
| | | records[k].BaseOperationType = constvar.BaseOperationTypeAdjust |
|---|
| | | continue |
|---|
| | | } else { |
|---|
| | | util.ResponseFormat(c, code.RequestError, fmt.Errorf("find operation err: %v", res.Error.Error())) |
|---|
| | | return |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | records[k].AdjustAmount = operation.Details[0].Amount |
|---|
| | | if len(operation.Details) > 0 { |
|---|
| | | records[k].AdjustAmount = operation.Details[0].Amount |
|---|
| | | records[k].DifferenceAmount = v.Amount.Add(v.AdjustAmount) |
|---|
| | | } |
|---|
| | | records[k].OperationId = operation.Id |
|---|
| | | records[k].Status = operation.Status |
|---|
| | | records[k].DifferenceAmount = v.Amount.Add(v.AdjustAmount) |
|---|
| | | } |
|---|
| | | records[k].BaseOperationType = constvar.BaseOperationTypeAdjust |
|---|
| | | } |
|---|
| | | util.ResponseFormatListWithPage(c, code.Success, records, int(total), params.Page, params.PageSize) |
|---|
| | | } |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | var existCount int64 |
|---|
| | | if err := models.NewOperationSearch().Orm.Table("wms_operation").InnerJoins("inner join wms_operation_details on wms_operation_details.operation_id=wms_operation.id").Where("wms_operation.from_location_id=? and wms_operation_details.product_id=? and wms_operation.base_operation_type=? and wms_operation.status=?", reqParams.LocationId, reqParams.ProductId, constvar.BaseOperationTypeAdjust, constvar.OperationStatus_Ready).Count(&existCount).Error; err != nil { |
|---|
| | | if err := models.NewOperationSearch().Orm. |
|---|
| | | Table("wms_operation"). |
|---|
| | | InnerJoins("inner join wms_operation_details on wms_operation_details.operation_id=wms_operation.id"). |
|---|
| | | Where("wms_operation.location_id=? and wms_operation_details.product_id=? and wms_operation.base_operation_type=? and wms_operation.status=?", reqParams.LocationId, reqParams.ProductId, constvar.BaseOperationTypeAdjust, constvar.OperationStatus_Ready). |
|---|
| | | Count(&existCount).Error; err != nil { |
|---|
| | | return err |
|---|
| | | } |
|---|
| | | if existCount > 0 { |
|---|
| | | return errors.New("该商品在已选中的位置存在未验证的库存盘点信息，无法继续添加相关信息") |
|---|
| | | } |
|---|
| | | |
|---|
| | | locProduct, err := models.NewLocationProductSearch().SetLocationId(reqParams.LocationId).SetProductId(reqParams.ProductId).First() |
|---|
| | | if err != nil { |
|---|
| | | return errors.New("参数异常，未找到该上架规则") |
|---|
| | | } |
|---|
| | | |
|---|
| | | existAmount, err := models.NewLocationProductAmountSearch().SetLocationProductId(locProduct.Id).First() |
|---|
| | | if err != nil { |
|---|
| | | return err |
|---|
| | | existAmount, res := models.NewLocationProductAmountSearch().SetLocationId(reqParams.LocationId).SetProductId(reqParams.ProductId).FirstRes() |
|---|
| | | if res.Error != nil && !errors.Is(res.Error, gorm.ErrRecordNotFound) { |
|---|
| | | return res.Error |
|---|
| | | } |
|---|
| | | location, err := models.NewLocationSearch().SetType(int(constvar.LocationTypeAdjust)).First() |
|---|
| | | if err != nil { |
|---|
| | | return err |
|---|
| | | } |
|---|
| | | //reqParams.AdjustAmount = reqParams.Amount.Sub(reqParams.DifferenceAmount) |
|---|
| | | reqParams.AdjustAmount = reqParams.DifferenceAmount.Sub(reqParams.Amount) |
|---|
| | | var locAmount models.LocationProductAmount |
|---|
| | | if existAmount.Id == 0 { |
|---|
| | | if res.Error != nil && errors.Is(res.Error, gorm.ErrRecordNotFound) { |
|---|
| | | locAmount = models.LocationProductAmount{ |
|---|
| | | LocationProductId: locProduct.Id, |
|---|
| | | LocationId: reqParams.LocationId, |
|---|
| | | //TODO:此处新增了ProductCategoryId入参，目前不清楚这个值的来源 |
|---|
| | | ProductCategoryID: reqParams.ProductCategoryId, |
|---|
| | | ProductId: reqParams.ProductId, |
|---|
| | | Amount: decimal.NewFromInt(0), |
|---|
| | | CreateDate: time.Now().Format("2006-01-02 15:04:05"), |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | detail := &models.OperationDetails{ |
|---|
| | | ProductId: reqParams.ProductId, |
|---|
| | | Amount: reqParams.AdjustAmount, |
|---|
| | | ProductId: reqParams.ProductId, |
|---|
| | | Amount: reqParams.AdjustAmount, |
|---|
| | | FromLocationID: location.Id, |
|---|
| | | ToLocationID: reqParams.LocationId, |
|---|
| | | } |
|---|
| | | operation := models.Operation{ |
|---|
| | | Number: strconv.FormatInt(time.Now().Unix(), 10), |
|---|
| | |
|---|
| | | Comment: "库存盘点", |
|---|
| | | BaseOperationType: constvar.BaseOperationTypeAdjust, |
|---|
| | | Details: []*models.OperationDetails{detail}, |
|---|
| | | FromLocationID: location.Id, |
|---|
| | | ToLocationID: reqParams.LocationId, |
|---|
| | | } |
|---|
| | | |
|---|
| | | if err := models.WithTransaction(func(tx *gorm.DB) error { |
|---|
| | |
|---|
| | | }); err != nil { |
|---|
| | | return err |
|---|
| | | } |
|---|
| | | |
|---|
| | | service.AddNewLocationReportRecord(locAmount.Id) |
|---|
| | | return nil |
|---|
| | | } |
|---|
| | | |
|---|
