| | |
| | | |
| | | import ( |
| | | "context" |
| | | "encoding/json" |
| | | "errors" |
| | | "fmt" |
| | | "github.com/gin-gonic/gin" |
| | |
| | | "github.com/shopspring/decimal" |
| | | "github.com/xuri/excelize/v2" |
| | | "gorm.io/gorm" |
| | | "os" |
| | | "sort" |
| | | "strconv" |
| | | "strings" |
| | |
| | | "wms/extend/code" |
| | | "wms/extend/util" |
| | | "wms/models" |
| | | "wms/opa" |
| | | "wms/pkg/logx" |
| | | "wms/pkg/mysqlx" |
| | | "wms/pkg/structx" |
| | |
| | | |
| | | } |
| | | |
| | | if operation.BaseOperationType == constvar.BaseOperationTypeOutgoing { |
| | | if operation.BaseOperationType == constvar.BaseOperationTypeOutgoing || operation.BaseOperationType == constvar.BaseOperationTypeDisuse { |
| | | for k, v := range listDetails { |
| | | //todo 演示测试数据 |
| | | data, err := os.ReadFile("conf/input.json") |
| | | if err != nil { |
| | | return errors.New("文件读取失败") |
| | | } |
| | | m := make(map[string]interface{}) |
| | | err = json.Unmarshal(data, &m) |
| | | if err != nil { |
| | | return errors.New("格式转换失败") |
| | | } |
| | | if opa.OpaCheck(c, m, "operation") { |
| | | if v.Product.Amount.LessThan(v.Amount) { |
| | | return errors.New(fmt.Sprintf("产品:%v,库存:%v,出库:%v,数量不够,无法完成出库操作", v.Product.Name, v.Product.Amount.String(), v.Amount.String())) |
| | | } |
| | | } |
| | | //data, err := os.ReadFile("conf/input.json") |
| | | //if err != nil { |
| | | // return errors.New("文件读取失败") |
| | | //} |
| | | //m := make(map[string]interface{}) |
| | | //err = json.Unmarshal(data, &m) |
| | | //if err != nil { |
| | | // return errors.New("格式转换失败") |
| | | //} |
| | | //if opa.OpaCheck(c, m, "operation") { |
| | | // if v.Product.Amount.LessThan(v.Amount) { |
| | | // return errors.New(fmt.Sprintf("产品:%v,库存:%v,出库:%v,数量不够,无法完成出库操作", v.Product.Name, v.Product.Amount.String(), v.Amount.String())) |
| | | // } |
| | | //} |
| | | //todo ================end=============================== |
| | | if v.Product.Amount.LessThan(v.Amount) { |
| | | return errors.New(fmt.Sprintf("产品:%v,库存:%v,出库:%v,数量不够,无法完成出库操作", v.Product.Name, v.Product.Amount.String(), v.Amount.String())) |
| | |
| | | } |
| | | } |
| | | } |
| | | |
| | | if operation.BaseOperationType == constvar.BaseOperationTypeAdjust { |
| | | for _, v := range listDetails { |
| | | if locAmount, aok := mapLocAmount[strconv.Itoa(v.ToLocationID)+v.ProductId]; aok { |
| | | locAmount.Amount = v.Amount |
| | | if res := models.NewLocationProductAmountSearch().Orm.Where("id=?", locAmount.ID).Save(locAmount); res.Error != nil { |
| | | return res.Error |
| | | } |
| | | } else { |
| | | if err := models.NewLocationProductAmountSearch().Create(&models.LocationProductAmount{ |
| | | LocationId: v.ToLocationID, |
| | | ProductCategoryID: v.Product.CategoryId, |
| | | ProductId: v.ProductId, |
| | | Amount: v.Amount, |
| | | CreateDate: time.Now().Format("2006-01-02 15:04:05"), |
| | | }); err != nil { |
| | | return err |
| | | } |
| | | } |
| | | } |
| | | } |
| | | return nil |
| | | }) |
| | | if err != nil { |