| | |
| | | import ( |
| | | "context" |
| | | "errors" |
| | | "fmt" |
| | | "github.com/gin-gonic/gin" |
| | | uuid "github.com/satori/go.uuid" |
| | | "github.com/shopspring/decimal" |
| | | "github.com/xuri/excelize/v2" |
| | | "gorm.io/gorm" |
| | | "io/ioutil" |
| | | "sort" |
| | | "strconv" |
| | | "strings" |
| | |
| | | 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 |
| | |
| | | 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 |
| | | if params.BaseOperationType != constvar.BaseOperationTypeAdjust { |
| | | if err := slf.FormatLocation(¶ms); err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, err.Error()) |
| | | return |
| | | } |
| | | |
| | | var operationType *models.OperationType |
| | | var err error |
| | | if params.OperationTypeId == 0 { |
| | | operationType, err := models.NewOperationTypeSearch(). |
| | | SetWarehouseId(params.WarehouseId).SetBaseOperationType(params.BaseOperationType). |
| | | First() |
| | | if err != nil || params.WarehouseId != operationType.WarehouseId { |
| | | util.ResponseFormat(c, code.RequestParamError, "参数缺失") |
| | | return |
| | | } |
| | | } else { |
| | | operationType, err = models.NewOperationTypeSearch().SetID(uint(params.OperationTypeId)).First() |
| | | if err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, err.Error()) |
| | | return |
| | | } |
| | | } |
| | | params.BaseOperationType = operationType.BaseOperationType |
| | | params.WarehouseId = operationType.WarehouseId |
| | | } |
| | | |
| | | userInfo := middleware.GetUserInfo(c) |
| | | params.CreatedBy = userInfo.Username |
| | | params.Status = constvar.OperationStatus_Ready |
| | | //params.Number = strconv.FormatInt(time.Now().Unix(), 10) |
| | | params.BaseOperationType = operationType.BaseOperationType |
| | | |
| | | var numberNum int64 |
| | | if err := mysqlx.GetDB().Model(&models.Operation{}).Where("number=?", params.Number).Count(&numberNum).Error; err != nil { |
| | |
| | | util.ResponseFormat(c, code.RequestParamError, "单号已存在") |
| | | return |
| | | } |
| | | err := models.WithTransaction(func(db *gorm.DB) error { |
| | | if err := models.NewOperationSearch().Create(¶ms); err != nil { |
| | | return err |
| | | } |
| | | /*od := params.Details |
| | | for _, v := range od { |
| | | //material, err := models.NewMaterialSearch().SetID(v.ProductId).First() |
| | | //if err != nil {return err} |
| | | material := new(models.Material) |
| | | material.ID = v.ProductId |
| | | material.Cost = v.Cost |
| | | material.SalePrice = v.SalePrice |
| | | if err := models.NewMaterialSearch().SetOrm(db).Update(material); err != nil { |
| | | return err |
| | | } |
| | | }*/ |
| | | return nil |
| | | }) |
| | | |
| | | if err := models.NewOperationSearch().Create(¶ms); err != nil { |
| | | if err != nil { |
| | | logx.Errorf("Operation create err: %v", err) |
| | | util.ResponseFormat(c, code.SaveFail, "添加失败:"+err.Error()) |
| | | return |
| | |
| | | return false |
| | | } |
| | | |
| | | // FormatLocation 位置检查 |
| | | func (slf OperationController) FormatLocation(params *models.Operation) error { |
| | | operationType, err := models.NewOperationTypeSearch().SetID(uint(params.OperationTypeId)).First() |
| | | if err != nil { |
| | |
| | | } |
| | | |
| | | func (slf OperationController) CheckParams(params models.Operation) error { |
| | | if params.SourceNumber == "" { |
| | | /*if params.SourceNumber == "" { |
| | | return errors.New("请填入源单号") |
| | | } |
| | | }*/ |
| | | |
| | | if params.Number == "" { |
| | | return errors.New("请填入单号") |
| | | } |
| | | |
| | | if params.OperationTypeId == 0 && int(params.BaseOperationType) == 0 { |
| | | return errors.New("未识别该记录类型") |
| | | return errors.New("未识别该记录类型1") |
| | | } |
| | | |
| | | if params.BaseOperationType != 0 { |
| | | if params.WarehouseId == 0 { |
| | | return errors.New("未识别该记录类型2") |
| | | } |
| | | } |
| | | |
| | | if params.OperationDate == "" { |
| | | return errors.New("请选择安排日期") |
| | | } |
| | | |
| | | if params.LocationID == 0 { |
| | | return errors.New("请选择源位置") |
| | | } |
| | | //if params.LocationID == 0 { |
| | | // return errors.New("请选择源位置") |
| | | //} |
| | | |
| | | if len(params.Details) <= 0 { |
| | | return errors.New("请添加明细信息") |
| | |
| | | // @Summary 入库/出库列表 |
| | | // @Produce application/json |
| | | // @Param object body request.OperationList true "查询参数" |
| | | // @Success 200 {object} util.Response "成功" |
| | | // @Success 200 {object} util.ResponseList{data=[]models.Operation} "成功" |
| | | // @Router /api-wms/v1/operation/list [post] |
| | | func (slf OperationController) List(c *gin.Context) { |
| | | var params request.OperationList |
| | |
| | | if int(params.Status) != 0 { |
| | | search.SetStatus(params.Status) |
| | | } |
| | | list, total, err := search.SetOperationTypeId(params.OperationTypeId).SetPreload(true).SetOrder("created_at desc").Find() |
| | | materials, err := models.NewMaterialSearch().FindNotTotal() |
| | | if err != nil { |
| | | util.ResponseFormat(c, code.RequestError, "查找失败:"+err.Error()) |
| | | return |
| | | } |
| | | costMap := make(map[string]decimal.Decimal) |
| | | salePriceMap := make(map[string]decimal.Decimal) |
| | | for _, material := range materials { |
| | | costMap[material.ID] = material.Cost |
| | | salePriceMap[material.ID] = material.SalePrice |
| | | } |
| | | list, total, err := search.SetOperationTypeId(params.OperationTypeId). |
| | | SetBaseOperationType(params.BaseOperationType). |
| | | SetPreload(true).SetOrder("created_at desc").Find() |
| | | if err != nil { |
| | | util.ResponseFormat(c, code.RequestError, "查找失败:"+err.Error()) |
| | | return |
| | | } |
| | | for _, v := range list { |
| | | for _, v1 := range v.Details { |
| | | //v1.SalePrice = decimal.NewFromFloat(1.2345) |
| | | //v1.Cost = decimal.NewFromFloat(9.678) |
| | | v1.SalePrice = v1.Cost |
| | | v1.Cost = v1.SalePrice |
| | | } |
| | | } |
| | | |
| | | util.ResponseFormatListWithPage(c, code.Success, list, int(total), params.Page, params.PageSize) |
| | |
| | | if !params.PageInfo.Check() { |
| | | return errors.New("数据分页信息错误") |
| | | } |
| | | if params.OperationTypeId == 0 { |
| | | return errors.New("operationTypeId为0") |
| | | if params.OperationTypeId == 0 && params.BaseOperationType == 0 { |
| | | return errors.New("operationTypeId和baseOperationType不能同时为0") |
| | | } |
| | | return nil |
| | | } |
| | |
| | | util.ResponseFormat(c, code.RequestParamError, "明细中不能存在重复的产品") |
| | | return |
| | | } |
| | | if err := slf.FormatLocation(¶ms); err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, err.Error()) |
| | | return |
| | | |
| | | if params.BaseOperationType != constvar.BaseOperationTypeAdjust { |
| | | 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 { |
| | |
| | | if err := models.NewOperationSearch().SetOrm(tx).SetID(params.Id).Save(¶ms); err != nil { |
| | | return err |
| | | } |
| | | /*od := params.Details |
| | | for _, v := range od { |
| | | //material, err := models.NewMaterialSearch().SetID(v.ProductId).First() |
| | | //if err != nil {return err} |
| | | material := new(models.Material) |
| | | material.ID = v.ProductId |
| | | material.Cost = v.Cost |
| | | material.SalePrice = v.SalePrice |
| | | if err := models.NewMaterialSearch().SetOrm(tx).Update(material); err != nil { |
| | | return err |
| | | } |
| | | }*/ |
| | | return nil |
| | | }); err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, "修改失败:"+err.Error()) |
| | |
| | | } |
| | | |
| | | if operation.BaseOperationType == constvar.BaseOperationTypeOutgoing || operation.BaseOperationType == constvar.BaseOperationTypeDisuse { |
| | | if err := service.FinishOperationOutput(tx, listDetails, mapLocAmount); err != nil { |
| | | if err := service.FinishOperationOutput(tx, listDetails, mapLocAmount, operation); err != nil { |
| | | return err |
| | | } |
| | | } |
| | | |
| | | if operation.BaseOperationType == constvar.BaseOperationTypeInternal { |
| | | if err := service.FinishOperationInternal(tx, listDetails); err != nil { |
| | | if err := service.FinishOperationInternal(tx, listDetails, operation); err != nil { |
| | | return err |
| | | } |
| | | } |
| | | |
| | | if operation.BaseOperationType == constvar.BaseOperationTypeAdjust { |
| | | if err := service.FinishOperationAdjust(tx, listDetails, mapLocAmount); err != nil { |
| | | if err := service.FinishOperationAdjust(tx, listDetails, mapLocAmount, operation); err != nil { |
| | | return err |
| | | } |
| | | } |
| | |
| | | util.ResponseFormat(c, code.Success, "操作成功") |
| | | } |
| | | |
| | | // outputOperation |
| | | // OutputOperation |
| | | // |
| | | // @Tags 入库/出库 |
| | | // @Summary 打印 |
| | |
| | | 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()) |
| | |
| | | } |
| | | |
| | | var fileUrl string |
| | | // 获取公司名称 |
| | | companyName := conf.WebConf.CompanyName |
| | | if companyName == "" { |
| | | util.ResponseFormat(c, code.RequestParamError, "缺少工厂名称配置") |
| | | return |
| | | } |
| | | // BaseOperationTypeIncoming 收货 |
| | | if operation.BaseOperationType == constvar.BaseOperationTypeIncoming { |
| | | if companyName == "jialian" { |
| | | fileUrl, err = JialianOperation(constvar.FileTemplateCategory_JialianInput, operation) |
| | | // 入库 |
| | | oT, err := models.NewOperationTypeSearch().SetID(uint(operation.OperationTypeId)).First() |
| | | if err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, err.Error()) |
| | | return |
| | | } |
| | | warehouse, err := models.NewWarehouseSearch().SetID(oT.WarehouseId).First() |
| | | if err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, err.Error()) |
| | | return |
| | | } |
| | | if err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, err.Error()) |
| | | return |
| | | } |
| | | |
| | | if warehouse.FileTemplateCategoryIn == constvar.FileTemplateCategory_JialianInput1 { |
| | | fileUrl, err = JialianOperation2(warehouse.FileTemplateCategoryIn, operation) |
| | | if err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, err.Error()) |
| | | return |
| | | } |
| | | |
| | | } else if warehouse.FileTemplateCategoryIn == constvar.FileWarehouseCategory_JialianInput2 { |
| | | fileUrl, err = JialianOperation1(warehouse.FileTemplateCategoryIn, operation) |
| | | if err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, err.Error()) |
| | | return |
| | | } |
| | | |
| | | } |
| | | |
| | | } else if companyName == "geruimi" { |
| | | fileUrl, err = ExportInputSelfmade(constvar.FileTemplateCategory_Selfmade, operation) |
| | | if err != nil { |
| | |
| | | return |
| | | } |
| | | } |
| | | } else if operation.BaseOperationType == constvar.BaseOperationTypeOutgoing { |
| | | } else if operation.BaseOperationType == constvar.BaseOperationTypeOutgoing { // 交货 |
| | | if companyName == "jialian" { |
| | | fileUrl, err = JialianOperation(constvar.FileTemplateCategory_JialianOutput, operation) |
| | | oT, err := models.NewOperationTypeSearch().SetID(uint(operation.OperationTypeId)).First() |
| | | if err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, err.Error()) |
| | | return |
| | | } |
| | | warehouse, err := models.NewWarehouseSearch().SetID(oT.WarehouseId).First() |
| | | if err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, err.Error()) |
| | | return |
| | | } |
| | | if err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, err.Error()) |
| | | return |
| | | } |
| | | |
| | | if warehouse.FileTemplateCategoryOut == constvar.FileTemplateCategory_JialianOutput1 { |
| | | fileUrl, err = JialianOperation2(warehouse.FileTemplateCategoryOut, operation) |
| | | if err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, err.Error()) |
| | | return |
| | | } |
| | | |
| | | } else if warehouse.FileTemplateCategoryOut == constvar.FileWarehouseCategory_JialianOutput2 { |
| | | fileUrl, err = JialianOperation1(warehouse.FileTemplateCategoryOut, operation) |
| | | if err != nil { |
| | | util.ResponseFormat(c, code.RequestParamError, err.Error()) |
| | | return |
| | | } |
| | | |
| | | } |
| | | } else if companyName == "geruimi" { |
| | | fileUrl, err = ExportInputSelfmade(constvar.FileTemplateCategory_Output, operation) |
| | |
| | | util.ResponseFormat(c, code.Success, m) |
| | | } |
| | | |
| | | func JialianOperation(category constvar.FileTemplateCategory, operation *models.Operation) (string, error) { |
| | | func JialianOperation1(category constvar.FileTemplateCategory, operation *models.Operation) (string, error) { |
| | | // 获取模板记录 |
| | | template, err := models.NewFileTemplateAttachmentSearch().SetCategory(category).First() |
| | | if err != nil { |
| | | return "", errors.New("获取模版记录失败:" + err.Error()) |
| | | } |
| | | fmt.Println(template) |
| | | // 根据模板路径获取模板消息 |
| | | readerCloser, err := http.HttpGetWithReadCloser(template.FileUrl) |
| | | if err != nil { |
| | | return "", errors.New("获取模版失败:" + err.Error()) |
| | | } |
| | | |
| | | // 读取模板内容 |
| | | f, err := excelize.OpenReader(readerCloser) |
| | | //fl, err := os.Open("E:\\家纺出入库单.xlsx") |
| | | //f, err := excelize.OpenReader(fl) |
| | | if err != nil { |
| | | return "", errors.New("读取excel模版失败:" + err.Error()) |
| | | } |
| | | readerCloser.Close() |
| | | |
| | | defer f.Close() |
| | | |
| | | f.SetCellValue("Sheet1", "H2", operation.OperationDate) |
| | | f.SetCellValue("Sheet1", "O2", operation.Number) |
| | | sheet := "Sheet1" |
| | | if category == constvar.FileWarehouseCategory_JialianInput2 { |
| | | sheet = "入库单" |
| | | } else if category == constvar.FileWarehouseCategory_JialianOutput2 { |
| | | sheet = "出库单" |
| | | } |
| | | |
| | | rowIndex := 5 |
| | | totalAmount := decimal.NewFromInt(0) |
| | | totalPrice := decimal.NewFromInt(0) |
| | | // 第二行 |
| | | f.SetCellValue(sheet, "K2", operation.Number) // 单号 |
| | | // 第三行 |
| | | f.SetCellValue(sheet, "D3", operation.CompanyName) // 公司 |
| | | f.SetCellValue(sheet, "G3", "") // 部门 |
| | | |
| | | // 时间 |
| | | date := operation.OperationDate |
| | | f.SetCellValue(sheet, "I3", date[0:4]) // 年 |
| | | f.SetCellValue(sheet, "L3", date[5:7]) // 月 |
| | | f.SetCellValue(sheet, "N3", date[8:10]) // 日 |
| | | |
| | | var entityIDs []string |
| | | for _, v := range operation.Details { |
| | | entityIDs = append(entityIDs, v.ProductId) |
| | | } |
| | | attributeMap := make(map[string]uint) |
| | | attributeValueMap := make(map[string]string) |
| | | attributes, err := models.NewAttributeSearch().SetEntityType(1).FindNotTotal() |
| | | if err != nil { |
| | | return "", errors.New("获取动态属性失败:" + err.Error()) |
| | | } |
| | | for _, v := range attributes { |
| | | attributeMap[v.Name] = v.ID |
| | | } |
| | | attributeValues, err := models.NewAttributeValueSearch().SetEntityIDs(entityIDs).FindNotTotal() |
| | | if err != nil { |
| | | return "", errors.New("获取动态属性值失败:" + err.Error()) |
| | | } |
| | | for _, v := range attributeValues { |
| | | attributeValueMap[fmt.Sprintf("%d%s", v.AttributeID, v.EntityID)] = v.Value |
| | | } |
| | | |
| | | // 第六行 循环填值 |
| | | totalAmount := decimal.NewFromInt(0) // 总金额 |
| | | totalPrice := decimal.NewFromInt(0) // 总价 |
| | | rowIndex := 6 |
| | | for i, v := range operation.Details { |
| | | //设置表单最多9条数据 |
| | | if i > 8 { |
| | | //设置表单最多6条数据 |
| | | if i > 6 { |
| | | break |
| | | } |
| | | f.SetCellValue("Sheet1", "A"+strconv.Itoa(rowIndex), v.Product.Name) |
| | | f.SetCellValue("Sheet1", "B"+strconv.Itoa(rowIndex), v.Product.Type) |
| | | f.SetCellValue("Sheet1", "C"+strconv.Itoa(rowIndex), v.Product.Unit) |
| | | f.SetCellValue("Sheet1", "D"+strconv.Itoa(rowIndex), v.Amount.String()) |
| | | f.SetCellValue("Sheet1", "E"+strconv.Itoa(rowIndex), v.Product.SalePrice.String()) |
| | | f.SetCellValue(sheet, "B"+strconv.Itoa(rowIndex), v.Product.Name) // 产品名称 |
| | | f.SetCellValue(sheet, "C"+strconv.Itoa(rowIndex), v.Product.Specs) //规格 |
| | | f.SetCellValue(sheet, "D"+strconv.Itoa(rowIndex), attributeValueMap[fmt.Sprintf("%d%s", attributeMap["颜色"], v.ProductId)]) //颜色 |
| | | f.SetCellValue(sheet, "E"+strconv.Itoa(rowIndex), attributeValueMap[fmt.Sprintf("%d%s", attributeMap["面料"], v.ProductId)]) //面料 |
| | | f.SetCellValue(sheet, "F"+strconv.Itoa(rowIndex), v.TotalGrossWeight.String()) //重量 |
| | | f.SetCellValue(sheet, "G"+strconv.Itoa(rowIndex), v.Amount.String()) //数量 |
| | | f.SetCellValue(sheet, "H"+strconv.Itoa(rowIndex), v.Product.SalePrice.String()) // 单价 |
| | | |
| | | // 金额 |
| | | if !v.Product.SalePrice.IsZero() { |
| | | ap := v.Amount.Mul(v.Product.SalePrice) |
| | | totalPrice = totalPrice.Add(ap) |
| | |
| | | split := strings.Split(price, ".") |
| | | if len(split) == 2 { |
| | | for n, a := range split[1] { |
| | | f.SetCellValue("Sheet1", string('M'+n)+strconv.Itoa(rowIndex), string(a)) |
| | | f.SetCellValue(sheet, string('N'+n)+strconv.Itoa(rowIndex), string(a)) |
| | | } |
| | | } |
| | | s := split[0] |
| | | n := 0 |
| | | for j := len(s) - 1; j >= 0; j-- { |
| | | if n == 6 { |
| | | f.SetCellValue("Sheet1", string('L'-n)+strconv.Itoa(rowIndex), s[:j]) |
| | | f.SetCellValue(sheet, string('M'-n)+strconv.Itoa(rowIndex), s[:j]) |
| | | break |
| | | } |
| | | f.SetCellValue("Sheet1", string('L'-n)+strconv.Itoa(rowIndex), string(s[j])) |
| | | f.SetCellValue(sheet, string('M'-n)+strconv.Itoa(rowIndex), string(s[j])) |
| | | n++ |
| | | } |
| | | } |
| | | |
| | | rowIndex++ |
| | | totalAmount = totalAmount.Add(v.Amount) |
| | | } |
| | | |
| | | //合计 |
| | | if !totalPrice.IsZero() { |
| | | price := totalPrice.String() |
| | | split := strings.Split(price, ".") |
| | | if len(split) == 2 { |
| | | for n, a := range split[1] { |
| | | f.SetCellValue("Sheet1", string('M'+n)+"14", string(a)) |
| | | f.SetCellValue(sheet, string('M'+n)+"12", string(a)) |
| | | } |
| | | } else { |
| | | f.SetCellValue("Sheet1", "M14", "0") |
| | | f.SetCellValue("Sheet1", "N14", "0") |
| | | f.SetCellValue(sheet, "N12", "0") |
| | | f.SetCellValue(sheet, "O12", "0") |
| | | } |
| | | s := split[0] |
| | | n := 0 |
| | | for j := len(s) - 1; j >= 0; j-- { |
| | | if n == 6 { |
| | | f.SetCellValue("Sheet1", string('L'-n)+"14", s[:j]) |
| | | f.SetCellValue(sheet, string('M'-n)+"12", s[:j]) |
| | | break |
| | | } |
| | | f.SetCellValue("Sheet1", string('L'-n)+"14", string(s[j])) |
| | | f.SetCellValue(sheet, string('M'-n)+"12", string(s[j])) |
| | | n++ |
| | | } |
| | | } |
| | | f.SetCellValue("Sheet1", "D14", totalAmount) |
| | | |
| | | f.SetCellValue("Sheet1", "B15", operation.Manager) |
| | | f.SetCellValue("Sheet1", "D15", operation.Accountant) |
| | | f.SetCellValue("Sheet1", "F15", operation.Custodian) |
| | | |
| | | // 备注 第13行 |
| | | f.SetCellValue(sheet, "B13", "备注:"+operation.Remark) |
| | | // 第14行 |
| | | f.SetCellValue(sheet, "C14", operation.Manager) // 审核 |
| | | f.SetCellValue(sheet, "F14", operation.Accountant) // 保管 |
| | | f.SetCellValue(sheet, "I14", operation.Custodian) //经办人 |
| | | buf, err := f.WriteToBuffer() |
| | | if err != nil { |
| | | return "", err |
| | | } |
| | | |
| | | fileUrl, err := upload.UploadFileToSeaWeed(string(constvar.FileType_File), uuid.NewV4().String()+".xlsx", buf.Bytes()) |
| | | ioutil.WriteFile("E:\\"+uuid.NewV4().String()+".xlsx", buf.Bytes(), 0644) |
| | | if err != nil { |
| | | //ioutil.WriteFile("E:\\"+uuid.NewV4().String()+".xlsx", buf.Bytes(), 0644) |
| | | logx.Errorf("file upload err: %v", err) |
| | | return "", err |
| | | } |
| | | return fileUrl, nil |
| | | } |
| | | |
| | | func JialianOperation2(category constvar.FileTemplateCategory, operation *models.Operation) (string, error) { |
| | | // 获取模板记录 |
| | | template, err := models.NewFileTemplateAttachmentSearch().SetCategory(category).First() |
| | | if err != nil { |
| | | return "", errors.New("获取模版记录失败:" + err.Error()) |
| | | } |
| | | fmt.Println(template) |
| | | // 根据模板路径获取模板消息 |
| | | readerCloser, err := http.HttpGetWithReadCloser(template.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() |
| | | |
| | | defer f.Close() |
| | | |
| | | sheet := "Sheet1" |
| | | f.SetCellValue(sheet, "A2", "单位(部门):"+operation.CompanyName) // 单位部门 |
| | | f.SetCellValue(sheet, "J2", operation.OperationDate) // 时间 |
| | | f.SetCellValue(sheet, "Q2", operation.Number) // 编号 |
| | | |
| | | totalAmount := decimal.NewFromInt(0) // 总金额 |
| | | totalPrice := decimal.NewFromInt(0) // 总价 |
| | | rowIndex := 5 |
| | | for i, v := range operation.Details { |
| | | //设置表单最多9条数据 |
| | | if i > 9 { |
| | | break |
| | | } |
| | | f.SetCellValue(sheet, "A"+strconv.Itoa(rowIndex), v.Product.Name) // 品名 |
| | | f.SetCellValue(sheet, "B"+strconv.Itoa(rowIndex), v.Product.Type) // 型号 |
| | | f.SetCellValue(sheet, "C"+strconv.Itoa(rowIndex), v.Product.Unit) // 单位 |
| | | f.SetCellValue(sheet, "D"+strconv.Itoa(rowIndex), v.Amount.String()) // 数量 |
| | | unit := service.CreateMoreUnit(v.Amount, v.Product.MoreUnitList) |
| | | for _, v1 := range unit { |
| | | if !v1.Amount.IsZero() { |
| | | f.SetCellValue(sheet, "E"+strconv.Itoa(rowIndex), v1.Amount) // 辅数量 |
| | | f.SetCellValue(sheet, "F"+strconv.Itoa(rowIndex), v1.Unit) // 辅单位 |
| | | break |
| | | } |
| | | } |
| | | f.SetCellValue(sheet, "G"+strconv.Itoa(rowIndex), v.Product.SalePrice.String()) // 单价 |
| | | // 金额 |
| | | if !v.Product.SalePrice.IsZero() { |
| | | ap := v.Amount.Mul(v.Product.SalePrice) |
| | | totalPrice = totalPrice.Add(ap) |
| | | price := ap.String() |
| | | split := strings.Split(price, ".") |
| | | if len(split) == 2 { |
| | | for n, a := range split[1] { |
| | | f.SetCellValue(sheet, string('O'+n)+strconv.Itoa(rowIndex), string(a)) |
| | | } |
| | | } |
| | | s := split[0] |
| | | n := 0 |
| | | for j := len(s) - 1; j >= 0; j-- { |
| | | if n == 6 { |
| | | f.SetCellValue(sheet, string('N'-n)+strconv.Itoa(rowIndex), s[:j]) |
| | | break |
| | | } |
| | | f.SetCellValue(sheet, string('N'-n)+strconv.Itoa(rowIndex), string(s[j])) |
| | | n++ |
| | | } |
| | | } |
| | | rowIndex++ |
| | | totalAmount = totalAmount.Add(v.Amount) |
| | | } |
| | | |
| | | //合计 |
| | | if !totalPrice.IsZero() { |
| | | price := totalPrice.String() |
| | | split := strings.Split(price, ".") |
| | | if len(split) == 2 { |
| | | for n, a := range split[1] { |
| | | f.SetCellValue(sheet, string('N'+n)+"14", string(a)) |
| | | } |
| | | } else { |
| | | f.SetCellValue(sheet, "O14", "0") |
| | | f.SetCellValue(sheet, "P14", "0") |
| | | } |
| | | s := split[0] |
| | | n := 0 |
| | | for j := len(s) - 1; j >= 0; j-- { |
| | | if n == 6 { |
| | | f.SetCellValue(sheet, string('N'-n)+"14", s[:j]) |
| | | break |
| | | } |
| | | f.SetCellValue(sheet, string('N'-n)+"14", string(s[j])) |
| | | n++ |
| | | } |
| | | } |
| | | |
| | | f.SetCellValue(sheet, "Q5", operation.Remark) // 备注 |
| | | |
| | | // 第14行 |
| | | f.SetCellValue(sheet, "B15", operation.Manager) // 主管 |
| | | f.SetCellValue(sheet, "D15", operation.Accountant) // 会计 |
| | | f.SetCellValue(sheet, "H15", operation.Custodian) //保管员 |
| | | f.SetCellValue(sheet, "Q15", operation.Custodian) //经手 |
| | | buf, err := f.WriteToBuffer() |
| | | if err != nil { |
| | | return "", err |
| | | } |
| | | |
| | | fileUrl, err := upload.UploadFileToSeaWeed(string(constvar.FileType_File), uuid.NewV4().String()+".xlsx", buf.Bytes()) |
| | | ioutil.WriteFile("E:\\"+uuid.NewV4().String()+".xlsx", buf.Bytes(), 0644) |
| | | if err != nil { |
| | | logx.Errorf("file upload err: %v", err) |
| | | return "", err |
| | | } |
| | | |
| | | return fileUrl, nil |
| | | } |
| | | |