package controllers import ( "context" "encoding/json" "errors" "fmt" "github.com/gin-gonic/gin" "github.com/shopspring/decimal" "github.com/xuri/excelize/v2" "google.golang.org/grpc" "google.golang.org/grpc/credentials/insecure" "gorm.io/gorm" "os" "sort" "strconv" "strings" "time" "wms/conf" "wms/constvar" "wms/extend/code" "wms/extend/util" "wms/models" "wms/opa" "wms/pkg/logx" "wms/pkg/structx" "wms/proto/client" "wms/proto/product_inventory" "wms/proto/purchase_wms" "wms/proto/supplier" "wms/request" "wms/service" "wms/utils/http" "wms/utils/upload" ) type OperationController struct { } // Add // @Tags 入库/出库 // @Summary 添加入库/出库 // @Produce application/json // @Param object body request.AddOperation true "入库/出库信息" // @Success 200 {object} util.Response "成功" // @Router /api-wms/v1/operation/operation [post] func (slf OperationController) Add(c *gin.Context) { var reqParams request.AddOperation var params models.Operation if err := c.BindJSON(&reqParams); err != nil { util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误") return } if err := structx.AssignTo(reqParams, ¶ms); err != nil { util.ResponseFormat(c, code.RequestParamError, "数据转换错误"+err.Error()) return } if err := slf.CheckParams(params); err != nil { util.ResponseFormat(c, code.RequestParamError, err.Error()) return } if err := slf.FormatLocation(¶ms); err != nil { util.ResponseFormat(c, code.RequestParamError, err.Error()) return } if CheckDetailsRepeat(params.Details) { util.ResponseFormat(c, code.RequestParamError, "明细中不能存在重复的产品") return } operationType, err := models.NewOperationTypeSearch().SetID(uint(params.OperationTypeId)).First() if err != nil { util.ResponseFormat(c, code.RequestParamError, err.Error()) return } params.Status = constvar.OperationStatus_Ready params.Number = strconv.FormatInt(time.Now().Unix(), 10) params.BaseOperationType = operationType.BaseOperationType if err := models.NewOperationSearch().Create(¶ms); err != nil { logx.Errorf("Operation create err: %v", err) util.ResponseFormat(c, code.SaveFail, "添加失败："+err.Error()) return } util.ResponseFormat(c, code.Success, "添加成功") } func CheckDetailsRepeat(details []*models.OperationDetails) bool { var detailIDs []string var tempID string for _, v := range details { detailIDs = append(detailIDs, v.ProductId) } sort.Strings(detailIDs) for _, v := range detailIDs { if v != tempID { tempID = v } else { return true } } return false } func (slf OperationController) FormatLocation(params *models.Operation) error { operationType, err := models.NewOperationTypeSearch().SetID(uint(params.OperationTypeId)).First() if err != nil { return err } if operationType.BaseOperationType == constvar.BaseOperationTypeIncoming { if location, err := models.NewLocationSearch().SetType(int(constvar.LocationTypeVendor)).First(); err != nil { return err } else { params.FromLocationID = location.Id } if params.ToLocationID == 0 { return errors.New("请选择目标位置") } } if operationType.BaseOperationType == constvar.BaseOperationTypeOutgoing { if location, err := models.NewLocationSearch().SetType(int(constvar.LocationTypeCustomer)).First(); err != nil { return err } else { params.ToLocationID = location.Id } if params.FromLocationID == 0 { return errors.New("请选择源位置") } } if operationType.BaseOperationType == constvar.BaseOperationTypeInternal { if params.ToLocationID == 0 { return errors.New("请选择目标位置") } if params.FromLocationID == 0 { return errors.New("请选择源位置") } } return nil } func (slf OperationController) CheckParams(params models.Operation) error { if params.SourceNumber == "" { return errors.New("请填入源单号") } if params.OperationTypeId == 0 && int(params.BaseOperationType) == 0 { return errors.New("未识别该记录类型") } if params.OperationDate == "" { return errors.New("请选择安排日期") } if len(params.Details) <= 0 { return errors.New("请添加明细信息") } //检查明细部分 for _, v := range params.Details { if v.ProductId == "" { return errors.New("productID为空") } //if v.ProductName == "" { // return errors.New("产品名称异常") //} if v.Amount.IsNegative() { return errors.New("产品数量出错") } } return nil } // GetOperationInfo // @Tags 入库/出库 // @Summary 入库/出库列表 // @Produce application/json // // @Param id path string true "id" // // @Success 200 {object} util.Response "成功" // @Router /api-wms/v1/operation/getOperationInfo/{id} [get] func (slf OperationController) GetOperationInfo(c *gin.Context) { number := c.Param("id") if number == "" { util.ResponseFormat(c, code.RequestParamError, "参数解析失败，参数不能为空") return } id, _ := strconv.Atoi(number) operation, err := models.NewOperationSearch().SetID(id).SetPreload(true).First() if err != nil { util.ResponseFormat(c, code.RequestParamError, err.Error()) return } util.ResponseFormat(c, code.Success, operation) } // List // @Tags 入库/出库 // @Summary 入库/出库列表 // @Produce application/json // @Param object body request.OperationList true "查询参数" // @Success 200 {object} util.Response "成功" // @Router /api-wms/v1/operation/list [post] func (slf OperationController) List(c *gin.Context) { var params request.OperationList if err := c.BindJSON(¶ms); err != nil { util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误:"+err.Error()) return } if err := slf.CheckListParams(¶ms); err != nil { util.ResponseFormat(c, code.RequestParamError, err.Error()) return } search := models.NewOperationSearch() search.SetPage(params.Page, params.PageSize) if params.Number != "" { search.SetKeyword(params.Number) } if int(params.Status) != 0 { search.SetStatus(params.Status) } list, total, err := search.SetOperationTypeId(params.OperationTypeId).SetPreload(true).SetOrder("created_at desc").Find() if err != nil { util.ResponseFormat(c, code.RequestError, "查找失败:"+err.Error()) return } util.ResponseFormatListWithPage(c, code.Success, list, int(total), params.Page, params.PageSize) } func (slf OperationController) CheckListParams(params *request.OperationList) error { if !params.PageInfo.Check() { return errors.New("数据分页信息错误") } if params.OperationTypeId == 0 { return errors.New("operationTypeId为0") } return nil } // Update // @Tags 入库/出库 // @Summary 修改入库/出库信息 // @Produce application/json // @Param object body request.UpdateOperation true "入库信息" // @Success 200 {object} util.Response "成功" // @Router /api-wms/v1/operation/update [post] func (slf OperationController) Update(c *gin.Context) { var reqParams request.UpdateOperation var params models.Operation if err := c.BindJSON(&reqParams); err != nil { util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误："+err.Error()) return } if reqParams.Status != constvar.OperationStatus_Ready { util.ResponseFormat(c, code.RequestParamError, "该入库信息已完成，无法进行修改") return } if err := structx.AssignTo(reqParams, ¶ms); err != nil { util.ResponseFormat(c, code.RequestParamError, "数据转换错误"+err.Error()) return } if err := slf.CheckParams(params); err != nil { util.ResponseFormat(c, code.RequestParamError, err.Error()) return } if CheckDetailsRepeat(params.Details) { util.ResponseFormat(c, code.RequestParamError, "明细中不能存在重复的产品") return } if err := slf.FormatLocation(¶ms); err != nil { util.ResponseFormat(c, code.RequestParamError, err.Error()) return } if err := models.WithTransaction(func(tx *gorm.DB) error { if err := models.NewOperationDetailsSearch().SetOrm(tx).SetOperationId(params.Id).Delete(); err != nil { return err } operationSearch := models.NewOperationSearch().SetOrm(tx) if err := operationSearch.Orm.Model(¶ms).Association("Details").Replace(params.Details); err != nil { return err } if err := models.NewOperationSearch().SetOrm(tx).SetID(params.Id).Save(¶ms); err != nil { return err } return nil }); err != nil { util.ResponseFormat(c, code.RequestParamError, "修改失败："+err.Error()) return } util.ResponseFormat(c, code.Success, "修改成功") } // Delete // // @Tags 入库/出库 // @Summary 删除入库/出库信息 // @Produce application/json // @Param id path int true "id" // @Success 200 {object} util.Response "成功" // @Router /api-wms/v1/operation/operation/{id} [delete] func (slf OperationController) Delete(c *gin.Context) { id, err := strconv.Atoi(c.Param("id")) if err != nil { util.ResponseFormat(c, code.RequestParamError, "错误的id值") return } if id == 0 { util.ResponseFormat(c, code.RequestParamError, "id为0") return } operation, err := models.NewOperationSearch().SetID(id).First() if err != nil { util.ResponseFormat(c, code.RequestParamError, "未找到相关出入库信息:"+err.Error()) return } if operation.Status != constvar.OperationStatus_Ready { util.ResponseFormat(c, code.RequestError, "该入库信息无法进行删除") return } if err := models.WithTransaction(func(tx *gorm.DB) error { if err := models.NewOperationDetailsSearch().SetOrm(tx).SetOperationId(id).Delete(); err != nil { return err } if err := models.NewOperationSearch().SetOrm(tx).SetID(id).Delete(); err != nil { return err } return nil }); err != nil { util.ResponseFormat(c, code.RequestParamError, "修改失败："+err.Error()) return } util.ResponseFormat(c, code.Success, "删除成功") } // Finish // // @Tags 入库/出库 // @Summary 更改记录状态 // @Produce application/json // @Param id path int true "id" // @Success 200 {object} util.Response "成功" // @Router /api-wms/v1/operation/finish/{id} [put] func (slf OperationController) Finish(c *gin.Context) { id, err := strconv.Atoi(c.Param("id")) if err != nil { util.ResponseFormat(c, code.RequestParamError, "错误的id值") return } if id == 0 { util.ResponseFormat(c, code.RequestParamError, "id为0") return } operation, err := models.NewOperationSearch().SetPreload(true).SetID(id).First() if err != nil { util.ResponseFormat(c, code.RequestParamError, "未找到相关出入库信息:"+err.Error()) return } if operation.Status != constvar.OperationStatus_Ready { util.ResponseFormat(c, code.RequestError, "该出入库信息无法完成") return } if err := models.WithTransaction(func(tx *gorm.DB) error { if err := models.NewOperationSearch().SetOrm(tx).SetID(id).Update(&models.Operation{Status: constvar.OperationStatus_Finish, AuditDate: time.Now().Format("2006-01-02 15:04:05")}); err != nil { return err } if err := AddMoveHistory([]*models.Operation{operation}, tx); err != nil { return err } var listProdtId []string var listProdt []*models.Material mapProdt := make(map[string]decimal.Decimal) listDetails, err := models.NewOperationDetailsSearch().SetOperationId(operation.Id).FindAll() if err != nil { return err } for _, v := range listDetails { listProdtId = append(listProdtId, v.ProductId) mapProdt[v.ProductId] = v.Amount } if err := models.NewMaterialSearch().Orm.Where("id IN ?", listProdtId).Find(&listProdt).Error; err != nil { return err } if operation.BaseOperationType == constvar.BaseOperationTypeIncoming { var operationInputs []*models.Operation for k, v := range listProdt { value, ok := mapProdt[v.ID] if !ok { return errors.New("产品种类异常") } listProdt[k].Amount = listProdt[k].Amount.Add(value) if err := tx.Save(listProdt[k]).Error; err != nil { return err } locationRule, err := models.NewLocationProductSearch().SetProductId(v.ID).SetAreaId(operation.ToLocationID).First() if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { return err } if err == nil { operationTransfer := &models.Operation{ Number: operation.Number, SourceNumber: operation.SourceNumber, OperationTypeId: 0, OperationTypeName: operation.OperationTypeName, Status: constvar.OperationStatus_Finish, FromLocationID: locationRule.AreaId, ToLocationID: locationRule.LocationId, OperationDate: operation.OperationDate, ContacterID: operation.ContacterID, ContacterName: operation.ContacterName, CompanyID: operation.CompanyID, CompanyName: operation.CompanyName, Comment: operation.Comment, BaseOperationType: constvar.BaseOperationTypeInternal, Details: []*models.OperationDetails{ { ProductId: v.ID, Amount: value, }, }, } operationInputs = append(operationInputs, operationTransfer) //if err := tx.Create(&operationTransfer).Error; err != nil { // return err //} locAmount, err := models.NewLocationProductAmountSearch(). SetProductId(v.ID). SetLocationId(locationRule.LocationId). First() if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { return err } locAmount.LocationId = locationRule.LocationId locAmount.ProductId = v.ID locAmount.CreateDate = time.Now().Format("2006-01-02 15:04:05") locAmount.Amount = locAmount.Amount.Add(value) locAmount.ProductCategoryID = v.CategoryId if res := models.NewLocationProductAmountSearch().Orm.Where("id=?", locAmount.ID).Save(locAmount); res.Error != nil { return res.Error } } else { locationRule, err = models.NewLocationProductSearch().SetProductCategoryId(v.CategoryId).SetAreaId(operation.ToLocationID).First() if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { return err } if err == nil { operationTransfer := &models.Operation{ Number: operation.Number, SourceNumber: operation.SourceNumber, OperationTypeId: 0, OperationTypeName: operation.OperationTypeName, Status: constvar.OperationStatus_Finish, FromLocationID: locationRule.AreaId, ToLocationID: locationRule.LocationId, OperationDate: operation.OperationDate, ContacterID: operation.ContacterID, ContacterName: operation.ContacterName, CompanyID: operation.CompanyID, CompanyName: operation.CompanyName, Comment: operation.Comment, BaseOperationType: constvar.BaseOperationTypeInternal, Details: []*models.OperationDetails{ { ProductId: v.ID, Amount: value, }, }, } operationInputs = append(operationInputs, operationTransfer) //if err := tx.Create(&operationTransfer).Error; err != nil { // return err //} locAmount, err := models.NewLocationProductAmountSearch(). SetProductId(v.ID). SetLocationId(locationRule.LocationId). First() if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { return err } locAmount.LocationId = locationRule.LocationId locAmount.ProductId = v.ID locAmount.CreateDate = time.Now().Format("2006-01-02 15:04:05") locAmount.Amount = locAmount.Amount.Add(value) locAmount.ProductCategoryID = v.CategoryId if res := models.NewLocationProductAmountSearch().Orm.Where("id=?", locAmount.ID).Save(locAmount); res.Error != nil { return res.Error } } else { locAmount, err := models.NewLocationProductAmountSearch(). SetProductId(v.ID). SetLocationId(operation.ToLocationID). First() if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { return err } locAmount.LocationId = operation.ToLocationID locAmount.ProductId = v.ID locAmount.CreateDate = time.Now().Format("2006-01-02 15:04:05") locAmount.Amount = locAmount.Amount.Add(value) locAmount.ProductCategoryID = v.CategoryId if res := models.NewLocationProductAmountSearch().Orm.Where("id=?", locAmount.ID).Save(locAmount); res.Error != nil { return res.Error } } } } if len(operationInputs) > 0 { if err := tx.Create(&operationInputs).Error; err != nil { return err } } if operation.SourceNumber != "" { go UpdatePurchaseStatus(operation.SourceNumber) } } if operation.BaseOperationType == constvar.BaseOperationTypeOutgoing { for k, v := range listProdt { value, ok := mapProdt[v.ID] if !ok { return errors.New("产品种类异常") } //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.Amount.LessThan(value) { return errors.New(fmt.Sprintf("产品：%v,库存：%v,出库：%v,数量不够，无法完成出库操作", v.Name, v.Amount.String(), value.String())) } } listProdt[k].Amount = listProdt[k].Amount.Sub(value) if err := tx.Save(listProdt[k]).Error; err != nil { return err } locAmount, res := models.NewLocationProductAmountSearch(). SetProductId(v.ID). SetLocationId(operation.ToLocationID). FirstRes() if res.Error != nil { return err } if locAmount.Amount.LessThan(value) { return errors.New(fmt.Sprintf("产品：%v,库存：%v,出库：%v,数量不够，无法完成出库操作", v.Name, v.Amount.String(), value.String())) } locAmount.Amount = locAmount.Amount.Sub(value) if err := models.NewLocationProductAmountSearch().SetID(locAmount.Id).Update(locAmount); err != nil { return err } } if operation.SourceNumber != "" { go UpdateSalesDetailStatus(operation.SourceNumber) } } if operation.BaseOperationType == constvar.BaseOperationTypeInternal { var operationInputs []*models.Operation for _, v := range listProdt { value, ok := mapProdt[v.ID] if !ok { return errors.New("产品种类异常") } //listProdt[k].Amount = listProdt[k].Amount.Add(value) //if err := tx.Save(listProdt[k]).Error; err != nil { // return err //} fromLocAmount, res := models.NewLocationProductAmountSearch(). SetProductId(v.ID). SetLocationId(operation.FromLocationID). FirstRes() if res.Error != nil { return err } if fromLocAmount.Amount.LessThan(value) { return errors.New(fmt.Sprintf("产品：%v,库存：%v,调拨：%v,数量不够，无法完成调拨操作", v.Name, v.Amount.String(), value.String())) } fromLocAmount.Amount = fromLocAmount.Amount.Sub(value) if err := models.NewLocationProductAmountSearch().SetID(fromLocAmount.Id).Update(fromLocAmount); err != nil { return err } locationRule, err := models.NewLocationProductSearch().SetProductId(v.ID).SetAreaId(operation.ToLocationID).First() if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { return err } if err == nil { operationTransfer := &models.Operation{ Number: operation.Number, SourceNumber: operation.SourceNumber, OperationTypeId: 0, OperationTypeName: operation.OperationTypeName, Status: constvar.OperationStatus_Finish, FromLocationID: locationRule.AreaId, ToLocationID: locationRule.LocationId, OperationDate: operation.OperationDate, ContacterID: operation.ContacterID, ContacterName: operation.ContacterName, CompanyID: operation.CompanyID, CompanyName: operation.CompanyName, Comment: operation.Comment, BaseOperationType: constvar.BaseOperationTypeInternal, Details: []*models.OperationDetails{ { ProductId: v.ID, Amount: value, }, }, } operationInputs = append(operationInputs, operationTransfer) //if err := tx.Create(&operationTransfer).Error; err != nil { // return err //} locAmount, err := models.NewLocationProductAmountSearch(). SetProductId(v.ID). SetLocationId(locationRule.LocationId). First() if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { return err } locAmount.LocationId = locationRule.LocationId locAmount.ProductId = v.ID locAmount.CreateDate = time.Now().Format("2006-01-02 15:04:05") locAmount.Amount = locAmount.Amount.Add(value) locAmount.ProductCategoryID = v.CategoryId if res := models.NewLocationProductAmountSearch().Orm.Where("id=?", locAmount.ID).Save(locAmount); res.Error != nil { return res.Error } } else { locationRule, err = models.NewLocationProductSearch().SetProductCategoryId(v.CategoryId).SetAreaId(operation.ToLocationID).First() if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { return err } if err == nil { operationTransfer := &models.Operation{ Number: operation.Number, SourceNumber: operation.SourceNumber, OperationTypeId: 0, OperationTypeName: operation.OperationTypeName, Status: constvar.OperationStatus_Finish, FromLocationID: locationRule.AreaId, ToLocationID: locationRule.LocationId, OperationDate: operation.OperationDate, ContacterID: operation.ContacterID, ContacterName: operation.ContacterName, CompanyID: operation.CompanyID, CompanyName: operation.CompanyName, Comment: operation.Comment, BaseOperationType: constvar.BaseOperationTypeInternal, Details: []*models.OperationDetails{ { ProductId: v.ID, Amount: value, }, }, } operationInputs = append(operationInputs, operationTransfer) //if err := tx.Create(&operationTransfer).Error; err != nil { // return err //} locAmount, err := models.NewLocationProductAmountSearch(). SetProductId(v.ID). SetLocationId(locationRule.LocationId). First() if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { return err } locAmount.LocationId = locationRule.LocationId locAmount.ProductId = v.ID locAmount.CreateDate = time.Now().Format("2006-01-02 15:04:05") locAmount.Amount = locAmount.Amount.Add(value) locAmount.ProductCategoryID = v.CategoryId if res := models.NewLocationProductAmountSearch().Orm.Where("id=?", locAmount.ID).Save(locAmount); res.Error != nil { return res.Error } } else { locAmount, err := models.NewLocationProductAmountSearch(). SetProductId(v.ID). SetLocationId(operation.ToLocationID). First() if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { return err } locAmount.LocationId = operation.ToLocationID locAmount.ProductId = v.ID locAmount.CreateDate = time.Now().Format("2006-01-02 15:04:05") locAmount.Amount = locAmount.Amount.Add(value) if res := models.NewLocationProductAmountSearch().Orm.Where("id=?", locAmount.ID).Save(locAmount); res.Error != nil { return res.Error } } } } if len(operationInputs) > 0 { if err := tx.Create(&operationInputs).Error; err != nil { return err } } } return nil }); err != nil { util.ResponseFormat(c, code.RequestError, err.Error()) return } util.ResponseFormat(c, code.Success, "操作成功") } func AddMoveHistory(operationList []*models.Operation, db *gorm.DB) error { var histories []*models.MoveHistory operationMap := make(map[string]*models.Operation, len(operationList)) for _, operation := range operationList { for _, v := range operation.Details { history := &models.MoveHistory{ Number: operation.Number, BaseOperationType: operation.BaseOperationType, OperationTypeId: operation.OperationTypeId, OperationTypeName: operation.OperationTypeName, OperationId: operation.Id, ProductId: v.ProductId, ProductName: v.Product.Name, Amount: v.Amount, Unit: v.Product.Unit, Weight: operation.Weight, FromLocationId: operation.FromLocationID, FromLocation: operation.FromLocation.Name, ToLocationId: operation.ToLocationID, ToLocation: operation.ToLocation.Name, } histories = append(histories, history) } operationMap[operation.Number] = operation } if err := db.Model(&models.MoveHistory{}).Create(&histories).Error; err != nil { return err } for _, history := range histories { service.AddNewHistoryReportRecord(history, operationMap[history.Number]) } return nil } var ( ProductInventoryServiceConn *grpc.ClientConn PurchaseServiceConn *grpc.ClientConn ) func InitProductInventoryServiceConn() { var err error ProductInventoryServiceConn, err = grpc.Dial(conf.GrpcServerConf.CrmAddr, grpc.WithTransportCredentials(insecure.NewCredentials())) if err != nil { logx.Errorf("grpc dial product service error: %v", err.Error()) return } PurchaseServiceConn, err = grpc.Dial(conf.GrpcServerConf.SrmAddr, grpc.WithTransportCredentials(insecure.NewCredentials())) if err != nil { logx.Errorf("grpc dial product service error: %v", err.Error()) return } } func CloseProductInventoryServiceConn() { if ProductInventoryServiceConn != nil { ProductInventoryServiceConn.Close() } if PurchaseServiceConn != nil { PurchaseServiceConn.Close() } } func UpdateSalesDetailStatus(number string) { client := product_inventory.NewProductInventoryServiceClient(ProductInventoryServiceConn) _, err := client.UpdateSalesDetailStatus(context.Background(), &product_inventory.UpdateSalesDetailStatusRequest{ Number: number, SalesDetailStatus: "已出库", }) if err != nil { logx.Errorf("grpc dial UpdateSalesDetailStatus service error: %v", err) } } func UpdatePurchaseStatus(number string) { client := purchase_wms.NewPurchaseServiceClient(PurchaseServiceConn) _, err := client.UpdatePurchaseStatus(context.Background(), &purchase_wms.UpdatePurchaseStatusRequest{Number: number}) if err != nil { logx.Errorf("grpc dial UpdatePurchaseStatus service error: %v", err) } } // ListTransfer // @Tags 入库/出库 // @Summary 库存调拨列表 // @Produce application/json // @Param object body request.OperationAllList true "参数" // @Success 200 {object} util.Response "成功" // @Router /api-wms/v1/operation/listTransfer [post] func (slf OperationController) ListTransfer(c *gin.Context) { var params request.OperationAllList if err := c.BindJSON(¶ms); err != nil { util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误:"+err.Error()) return } if !params.PageInfo.Check() { util.ResponseFormat(c, code.RequestParamError, "数据分页信息错误") return } search := models.NewOperationSearch() search.SetPage(params.Page, params.PageSize) search.SetPage(params.Page, params.PageSize) if params.Number != "" { search.SetKeyword(params.Number) } list, total, err := search.SetPreload(true).SetBaseOperationType(constvar.BaseOperationTypeInternal).SetOrder("created_at desc").Find() if err != nil { util.ResponseFormat(c, code.RequestError, "查找失败:"+err.Error()) return } util.ResponseFormatListWithPage(c, code.Success, list, int(total), params.Page, params.PageSize) } // GetLogisticCompanyList // @Tags 入库/出库 // @Summary 获取物流公司列表 // @Produce application/json // @Success 200 {object} util.ResponseList{data=[]models.LogisticCompany} "成功" // @Router /api-wms/v1/operation/getLogisticCompanyList [get] func (slf OperationController) GetLogisticCompanyList(c *gin.Context) { companies, err := models.NewLogisticCompanySearch().FindNotTotal() if err != nil { util.ResponseFormat(c, code.RequestError, "查找失败:"+err.Error()) return } util.ResponseFormat(c, code.Success, companies) } // Cancel // // @Tags 入库/出库 // @Summary 取消 // @Produce application/json // @Param id path int true "id" // @Success 200 {object} util.Response "成功" // @Router /api-wms/v1/operation/cancel/{id} [put] func (slf OperationController) Cancel(c *gin.Context) { id, err := strconv.Atoi(c.Param("id")) if err != nil { util.ResponseFormat(c, code.RequestParamError, "错误的id值") return } if id == 0 { util.ResponseFormat(c, code.RequestParamError, "id为0") return } operation, err := models.NewOperationSearch().SetPreload(true).SetID(id).First() if err != nil { util.ResponseFormat(c, code.RequestParamError, "未找到相关出入库信息:"+err.Error()) return } if operation.Status != constvar.OperationStatus_Ready { util.ResponseFormat(c, code.RequestError, "该出入库信息无法取消") return } operation.Status = constvar.OperationStatus_Cancel operation.AuditDate = time.Now().Format("2006-01-02 15:04:05") if err := models.NewOperationSearch().SetID(operation.Id).Save(operation); err != nil { util.ResponseFormat(c, code.SaveFail, err.Error()) return } util.ResponseFormat(c, code.Success, "操作成功") } // outputOperation // // @Tags 入库/出库 // @Summary 打印 // @Produce application/json // @Param id path int true "id" // @Success 200 {object} util.Response "成功" // @Router /api-wms/v1/operation/outputOperation/{id} [put] func (slf OperationController) OutputOperation(c *gin.Context) { id, err := strconv.Atoi(c.Param("id")) if err != nil { util.ResponseFormat(c, code.RequestParamError, "错误的id值") return } if id == 0 { util.ResponseFormat(c, code.RequestParamError, "id为0") return } operation, err := models.NewOperationSearch().SetPreload(true).SetID(id).First() if err != nil { util.ResponseFormat(c, code.RequestParamError, "未找到相关出入库信息:"+err.Error()) return } if len(operation.Details) == 0 { util.ResponseFormat(c, code.RequestParamError, "没有相关产品明细的信息") return } var fileUrl string if operation.BaseOperationType == constvar.BaseOperationTypeIncoming { fileUrl, err = ExportInputSelfmade(constvar.FileTemplateCategory_Selfmade, operation) if err != nil { util.ResponseFormat(c, code.RequestParamError, err.Error()) return } } else if operation.BaseOperationType == constvar.BaseOperationTypeOutgoing { fileUrl, err = ExportOutputOperation(constvar.FileTemplateCategory_Output, operation) if err != nil { util.ResponseFormat(c, code.RequestParamError, err.Error()) return } } else { util.ResponseFormat(c, code.RequestParamError, "该记录不支持打印") return } util.ResponseFormat(c, code.Success, fileUrl) } func ExportInputSelfmade(category constvar.FileTemplateCategory, operation *models.Operation) (string, error) { template, err := models.NewFileTemplateAttachmentSearch().SetPreload(true).SetCategory(category).First() if err != nil { return "", errors.New("获取模版记录失败:" + err.Error()) } readerCloser, err := http.HttpGetWithReadCloser(template.Attachment.FileUrl) if err != nil { return "", errors.New("获取模版失败:" + err.Error()) } f, err := excelize.OpenReader(readerCloser) if err != nil { return "", errors.New("读取excel模版失败：" + err.Error()) } readerCloser.Close() style, _ := f.NewStyle(&excelize.Style{ Border: []excelize.Border{ {Type: "left", Color: "#000000", Style: 2}, {Type: "top", Color: "#000000", Style: 2}, {Type: "bottom", Color: "#000000", Style: 2}, {Type: "right", Color: "#000000", Style: 2}, }, Alignment: &excelize.Alignment{ Horizontal: "center", Vertical: "center", }, }) styleLeft, _ := f.NewStyle(&excelize.Style{ Alignment: &excelize.Alignment{ Horizontal: "left", Vertical: "center", }, }) f.SetCellValue("Sheet1", "B3", operation.CompanyName) f.SetCellValue("Sheet1", "E3", operation.OperationDate) f.SetCellValue("Sheet1", "H3", operation.Number) rowIndex := 5 totalAmount := decimal.NewFromInt(0) for _, v := range operation.Details { f.SetCellValue("Sheet1", "A"+strconv.Itoa(rowIndex), v.ProductId) f.SetCellValue("Sheet1", "B"+strconv.Itoa(rowIndex), v.Product.Name) f.SetCellValue("Sheet1", "C"+strconv.Itoa(rowIndex), v.Product.Specs) f.SetCellValue("Sheet1", "D"+strconv.Itoa(rowIndex), v.Product.Unit) f.SetCellValue("Sheet1", "E"+strconv.Itoa(rowIndex), v.Amount.String()) f.SetCellValue("Sheet1", "H"+strconv.Itoa(rowIndex), operation.ToLocation.Name) f.SetCellValue("Sheet1", "I"+strconv.Itoa(rowIndex), operation.Comment) rowIndex++ totalAmount = totalAmount.Add(v.Amount) } if err := f.MergeCell("Sheet1", "A"+strconv.Itoa(rowIndex), "C"+strconv.Itoa(rowIndex)); err != nil { return "", err } f.SetCellValue("Sheet1", "A"+strconv.Itoa(rowIndex), "合计") f.SetCellValue("Sheet1", "E"+strconv.Itoa(rowIndex), totalAmount.String()) f.SetCellStyle("Sheet1", "A4", "I"+strconv.Itoa(rowIndex), style) rowIndex++ f.SetCellValue("Sheet1", "A"+strconv.Itoa(rowIndex), "审核：") f.SetCellValue("Sheet1", "D"+strconv.Itoa(rowIndex), "检验：") f.SetCellValue("Sheet1", "G"+strconv.Itoa(rowIndex), "保管：") f.SetCellStyle("Sheet1", "A"+strconv.Itoa(rowIndex), "G"+strconv.Itoa(rowIndex), styleLeft) buf, err := f.WriteToBuffer() if err != nil { return "", err } fileUrl, err := upload.UploadFileToSeaWeed(string(constvar.FileType_File), "xlsx", buf.Bytes()) if err != nil { logx.Errorf("file upload err: %v", err) return "", err } return fileUrl, nil } func ExportOutputOperation(category constvar.FileTemplateCategory, operation *models.Operation) (string, error) { repositoryLevels := strings.Split(operation.FromLocation.JointName, "/") template, err := models.NewFileTemplateAttachmentSearch().SetPreload(true).SetCategory(category).First() if err != nil { return "", errors.New("获取模版记录失败:" + err.Error()) } readerCloser, err := http.HttpGetWithReadCloser(template.Attachment.FileUrl) if err != nil { return "", errors.New("获取模版失败:" + err.Error()) } f, err := excelize.OpenReader(readerCloser) if err != nil { return "", errors.New("读取excel模版失败：" + err.Error()) } readerCloser.Close() style, _ := f.NewStyle(&excelize.Style{ Border: []excelize.Border{ {Type: "left", Color: "#000000", Style: 1}, {Type: "top", Color: "#000000", Style: 1}, {Type: "bottom", Color: "#000000", Style: 1}, {Type: "right", Color: "#000000", Style: 1}, }, Alignment: &excelize.Alignment{ Horizontal: "center", Vertical: "center", }, }) f.SetCellValue("Sheet1", "C2", repositoryLevels[0]) f.SetCellValue("Sheet1", "H2", operation.WaybillNumber) f.SetCellValue("Sheet1", "K2", operation.AuditDate) f.SetCellValue("Sheet1", "H3", operation.SourceNumber) f.SetCellValue("Sheet1", "K3", operation.Number) f.SetCellValue("Sheet1", "C4", operation.CompanyName) f.SetCellValue("Sheet1", "I4", operation.ReceiverAddr) f.SetCellValue("Sheet1", "C5", operation.ReceiverName) f.SetCellValue("Sheet1", "H5", operation.ReceiverPhone) rowIndex := 8 totalAmount := decimal.NewFromInt(0) totalWeight := decimal.NewFromInt(0) addRows := len(operation.Details) - 1 if addRows > 0 { f.InsertRows("Sheet1", 9, addRows) f.SetCellStyle("Sheet1", "A9", "K"+strconv.Itoa(rowIndex+addRows), style) } for k, v := range operation.Details { productTotalWeight := v.Amount.Mul(v.Product.Weight).Div(decimal.NewFromInt(1000)) f.SetCellValue("Sheet1", "A"+strconv.Itoa(rowIndex), k+1) f.SetCellValue("Sheet1", "B"+strconv.Itoa(rowIndex), v.Product.Name) f.SetCellValue("Sheet1", "H"+strconv.Itoa(rowIndex), v.Amount) f.SetCellValue("Sheet1", "I"+strconv.Itoa(rowIndex), v.Product.Weight) f.SetCellValue("Sheet1", "J"+strconv.Itoa(rowIndex), productTotalWeight) rowIndex++ totalAmount = totalAmount.Add(v.Amount) totalWeight = totalWeight.Add(productTotalWeight) } buf, err := f.WriteToBuffer() if err != nil { return "", err } fileUrl, err := upload.UploadFileToSeaWeed(string(constvar.FileType_File), "xlsx", buf.Bytes()) if err != nil { logx.Errorf("file upload err: %v", err) return "", err } return fileUrl, nil } // GetSupplierList // @Tags 入库/出库 // @Summary 获取物流公司列表 // @Produce application/json // // @Success 200 {object} util.Response "成功" // // @Router /api-wms/v1/operation/getSupplierList [get] func (slf OperationController) GetSupplierList(c *gin.Context) { cli := supplier.NewSupplierServiceClient(supplier.SupplierConn) resp, err := cli.GetSupplierList(c, &supplier.SupplierListRequest{Status: 1}) if err != nil { util.ResponseFormat(c, code.RequestParamError, "grpc调用失败:"+err.Error()) return } util.ResponseFormat(c, code.Success, resp.List) } // GetClientList // @Tags 入库/出库 // @Summary 获取物流公司列表 // @Produce application/json // // @Success 200 {object} util.Response "成功" // // @Router /api-wms/v1/operation/getClientList [get] func (slf OperationController) GetClientList(c *gin.Context) { cli := client.NewClientServiceClient(client.ClientConn) resp, err := cli.GetClientList(c, &client.ClientListRequest{}) if err != nil { util.ResponseFormat(c, code.RequestParamError, "grpc调用失败:"+err.Error()) return } util.ResponseFormat(c, code.Success, resp.List) }