1595 lines
52 KiB
Go
1595 lines
52 KiB
Go
package model
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/codinl/go-logger"
|
|
"github.com/xuri/excelize/v2"
|
|
"time"
|
|
)
|
|
|
|
//go:generate goqueryset -in commodity.go
|
|
// gen:qs
|
|
type ErpStock struct {
|
|
Model
|
|
|
|
StoreId uint32 `json:"store_id" gorm:"index"`
|
|
StoreName string `json:"store_name"`
|
|
ErpCommodityId uint32 `json:"erp_commodity_id" gorm:"index"`
|
|
ErpCommodityName string `json:"erp_commodity_name"`
|
|
ErpCategoryId uint32 `json:"erp_category_id" gorm:"index"`
|
|
ErpCategoryName string `json:"erp_category_name"`
|
|
CommoditySerialNumber string `json:"commodity_serial_number" gorm:"index"`
|
|
IMEIType uint32 `json:"imei_type"` // 1-无串码 2-串码
|
|
RetailPrice uint32 `json:"retail_price"`
|
|
MinRetailPrice uint32 `json:"min_retail_price"`
|
|
Count uint32 `json:"count"`
|
|
DispatchCount uint32 `json:"dispatch_count"`
|
|
//ErpSupplierId uint32 `json:"erp_supplier_id" gorm:"index"`
|
|
//ErpSupplierName string `json:"erp_supplier_name"`
|
|
//IMEI string `json:"imei"`
|
|
//StockTime time.Time `json:"stock_time"`
|
|
//StaffCostPrice uint32 `json:"staff_cost_price"`
|
|
//WholesalePrice uint32 `json:"wholesale_price"`
|
|
//OriginalSn string `json:"original_sn" gorm:"index"`
|
|
Commodities []ErpStockCommodity `json:"commodities" gorm:"-"`
|
|
|
|
// erp_stock
|
|
}
|
|
|
|
// gen:qs
|
|
type ErpStockCommodity struct {
|
|
Model
|
|
|
|
ErpStockId uint32 `json:"erp_stock_id" gorm:"index"`
|
|
StoreId uint32 `json:"store_id" gorm:"index"`
|
|
StoreName string `json:"store_name"`
|
|
ErpCommodityId uint32 `json:"erp_commodity_id" gorm:"index"`
|
|
ErpCommodityName string `json:"erp_commodity_name"`
|
|
CommoditySerialNumber string `json:"commodity_serial_number" gorm:"index"`
|
|
ErpCategoryId uint32 `json:"erp_category_id" gorm:"index"`
|
|
ErpCategoryName string `json:"erp_category_name"`
|
|
IMEIType uint32 `json:"imei_type"` // 1-无串码 2-串码
|
|
IMEI string `json:"imei"`
|
|
ErpSupplierId uint32 `json:"erp_supplier_id" gorm:"index"`
|
|
ErpSupplierName string `json:"erp_supplier_name"`
|
|
StockTime time.Time `json:"stock_time"`
|
|
RetailPrice uint32 `json:"retail_price"`
|
|
MinRetailPrice uint32 `json:"min_retail_price"`
|
|
StaffCostPrice uint32 `json:"staff_cost_price"`
|
|
WholesalePrice uint32 `json:"wholesale_price"`
|
|
OriginalSn string `json:"original_sn" gorm:"index"`
|
|
State uint32 `json:"state"` // 状态:1-在库 2-已售 3-采购退货 4-调拨中
|
|
Count uint32 `json:"count"`
|
|
StockSn string `json:"stock_sn"`
|
|
StorageType uint32 `json:"storage_type"` //1-系统入库 2-采购入库
|
|
FirstStockTime time.Time `json:"first_stock_time"`
|
|
Age uint32 `json:"age" gorm:"-"`
|
|
AllAge uint32 `json:"all_age" gorm:"-"`
|
|
|
|
//DispatchCount uint32 `json:"dispatch_count"`
|
|
// erp_stock_commodity
|
|
}
|
|
|
|
// gen:qs
|
|
type ErpCommodity struct {
|
|
Model
|
|
|
|
SerialNumber string `json:"serial_number"`
|
|
Number uint32 `json:"number"`
|
|
Name string `json:"name"`
|
|
ErpCategoryId uint32 `json:"erp_category_id" gorm:"index"`
|
|
ErpCategoryName string `json:"erp_category_name"`
|
|
IMEIType uint32 `json:"imei_type"` // 1-无串码 2-串码
|
|
IMEI string `json:"imei"`
|
|
ErpSupplierId uint32 `json:"erp_supplier_id" gorm:"index"`
|
|
ErpSupplierName string `json:"erp_supplier_name"`
|
|
RetailPrice uint32 `json:"retail_price"`
|
|
MinRetailPrice uint32 `json:"min_retail_price"`
|
|
StaffCostPrice uint32 `json:"staff_cost_price"`
|
|
WholesalePrice uint32 `json:"wholesale_price"`
|
|
Brokerage1 float64 `json:"brokerage_1"`
|
|
Brokerage2 float64 `json:"brokerage_2"`
|
|
MemberDiscount float64 `json:"member_discount"` // 会员优惠
|
|
Origin string `json:"origin"`
|
|
Remark string `json:"remark" gorm:"type:varchar(512)"`
|
|
|
|
ErpCategory *ErpCategory `json:"erp_category" gorm:"-"`
|
|
// erp_commodity
|
|
}
|
|
|
|
// gen:qs
|
|
type ErpCategory struct {
|
|
Model
|
|
|
|
Name string `json:"name"` // 名称
|
|
Priority string `json:"priority"` // 分类
|
|
Number uint32 `json:"number"`
|
|
FullNum uint32 `json:"full_num"`
|
|
State uint32 `json:"state"` // 1-未使用 2-使用 3-隐藏
|
|
Level uint32 `json:"level"` // 分类层级
|
|
Pid uint32 `json:"pid" gorm:"index"`
|
|
Sort uint32 `json:"sort"`
|
|
SubCats []ErpCategory `json:"sub_cats" gorm:"-"` // 子列表
|
|
// erp_category
|
|
}
|
|
|
|
// gen:qs
|
|
type ErpSupplier struct {
|
|
Model
|
|
|
|
Number string `json:"number" gorm:"index"`
|
|
Name string `json:"name"`
|
|
Contact string `json:"contact"`
|
|
Tel string `json:"tel"`
|
|
Address string `json:"address"`
|
|
OpeningBank string `json:"opening_bank"`
|
|
BankAccount string `json:"bank_account"`
|
|
PaymentCycle uint32 `json:"payment_cycle"`
|
|
TaxNumber string `json:"tax_number"`
|
|
StoreIds string `json:"store_ids"`
|
|
Landline string `json:"landline"`
|
|
Email string `json:"email"`
|
|
CompanyWebsite string `json:"company_website"`
|
|
// erp_supplier
|
|
}
|
|
|
|
// gen:qs
|
|
type ErpInventoryStock struct {
|
|
Model
|
|
|
|
StoreId uint32 `json:"store_id" gorm:"index"`
|
|
StoreName string `json:"store_name"`
|
|
ErpCommodityId uint32 `json:"erp_commodity_id" gorm:"index"`
|
|
ErpCommodityName string `json:"erp_commodity_name"`
|
|
ErpCategoryId uint32 `json:"erp_category_id" gorm:"index"`
|
|
ErpCategoryName string `json:"erp_category_name"`
|
|
CommoditySerialNumber string `json:"commodity_serial_number" gorm:"index"`
|
|
IMEIType uint32 `json:"imei_type"` // 1-无串码 2-串码
|
|
RetailPrice uint32 `json:"retail_price"`
|
|
MinRetailPrice uint32 `json:"min_retail_price"`
|
|
Count uint32 `json:"count"`
|
|
Sn string `json:"sn" gorm:"index"`
|
|
//ErpSupplierId uint32 `json:"erp_supplier_id" gorm:"index"`
|
|
//ErpSupplierName string `json:"erp_supplier_name"`
|
|
//IMEI string `json:"imei"`
|
|
//StockTime time.Time `json:"stock_time"`
|
|
//StaffCostPrice uint32 `json:"staff_cost_price"`
|
|
//WholesalePrice uint32 `json:"wholesale_price"`
|
|
// erp_inventory_stock
|
|
}
|
|
|
|
// gen:qs
|
|
type ErpInventoryStockCommodity struct {
|
|
Model
|
|
|
|
ErpInventoryStockId uint32 `json:"erp_inventory_stock_id" gorm:"index"`
|
|
ErpCommodityId uint32 `json:"erp_commodity_id" gorm:"index"`
|
|
ErpCommodityName string `json:"erp_commodity_name"`
|
|
CommoditySerialNumber string `json:"commodity_serial_number" gorm:"index"`
|
|
IMEIType uint32 `json:"imei_type"` // 1-无串码 2-串码
|
|
IMEI string `json:"imei"`
|
|
ErpSupplierId uint32 `json:"erp_supplier_id" gorm:"index"`
|
|
ErpSupplierName string `json:"erp_supplier_name"`
|
|
StockTime time.Time `json:"stock_time"`
|
|
RetailPrice uint32 `json:"retail_price"`
|
|
MinRetailPrice uint32 `json:"min_retail_price"`
|
|
StaffCostPrice uint32 `json:"staff_cost_price"`
|
|
WholesalePrice uint32 `json:"wholesale_price"`
|
|
Count uint32 `json:"count"`
|
|
StorageType uint32 `json:"storage_type"`
|
|
Sn string `json:"sn" gorm:"index"`
|
|
//StoreId uint32 `json:"store_id" gorm:"index"`
|
|
//StoreName string `json:"store_name"`
|
|
//ErpCategoryId uint32 `json:"erp_category_id" gorm:"index"`
|
|
//ErpCategoryName string `json:"erp_category_name"`
|
|
// erp_inventory_stock_commodity
|
|
}
|
|
|
|
type ErpCommodityListReq struct {
|
|
SerialNumber string `json:"serial_number"`
|
|
Name string `json:"name"`
|
|
ErpCategoryId uint32 `json:"erp_category_id"`
|
|
IMEI string `json:"imei"`
|
|
ErpSupplierId uint32 `json:"erp_supplier_id"`
|
|
PageNum int `json:"page_num"`
|
|
PageSize int `json:"page_size"`
|
|
IsExport uint32 `json:"is_export"` // 1-导出
|
|
}
|
|
type ErpCommodityListResp struct {
|
|
List []ErpCommodity `json:"list"`
|
|
Total int `json:"total"`
|
|
PageNum int `json:"page_num"`
|
|
PageSize int `json:"page_size"`
|
|
ExportUrl string `json:"export_url"`
|
|
}
|
|
|
|
func (m *ErpCommodityListReq) List() (*ErpCommodityListResp, error) {
|
|
resp := &ErpCommodityListResp{
|
|
PageNum: m.PageNum,
|
|
PageSize: m.PageSize,
|
|
}
|
|
page := m.PageNum - 1
|
|
if page < 0 {
|
|
page = 0
|
|
}
|
|
if m.PageSize == 0 {
|
|
m.PageSize = 10
|
|
}
|
|
qs := DB.Table("erp_commodity")
|
|
if m.SerialNumber != "" {
|
|
qs = qs.Where("serial_number=?", m.SerialNumber)
|
|
}
|
|
if m.Name != "" {
|
|
//qs = qs.Where("name Like %" + m.Name + "%")
|
|
qs = qs.Where("name LIKE ?", m.Name)
|
|
}
|
|
if m.IMEI != "" {
|
|
qs = qs.Where("imei=?", m.IMEI)
|
|
}
|
|
if m.ErpCategoryId != 0 {
|
|
qs = qs.Where("erp_category_id=?", m.ErpCategoryId)
|
|
}
|
|
if m.ErpSupplierId != 0 {
|
|
qs = qs.Where("erp_supplier_id=?", m.ErpSupplierId)
|
|
}
|
|
|
|
var count int64
|
|
err := qs.Count(&count).Error
|
|
if err != nil {
|
|
logger.Error("count err:", err)
|
|
return resp, err
|
|
}
|
|
resp.Total = int(count)/m.PageSize + 1
|
|
var commodities []ErpCommodity
|
|
|
|
if m.IsExport == 1 {
|
|
err = qs.Order("id DESC").Find(&commodities).Error
|
|
if err != nil && err != RecordNotFound {
|
|
logger.Error("dailys err:", err)
|
|
return resp, err
|
|
}
|
|
|
|
listExport, err := ErpCommodityListExport(commodities)
|
|
if err != nil {
|
|
logger.Error("list export err:", err)
|
|
}
|
|
resp.ExportUrl = listExport
|
|
} else {
|
|
err = qs.Order("id DESC").Offset(page * m.PageSize).Limit(m.PageSize).Find(&commodities).Error
|
|
if err != nil && err != RecordNotFound {
|
|
logger.Error("erp commodity list err:", err)
|
|
return resp, err
|
|
}
|
|
resp.List = commodities
|
|
}
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
func ErpCommodityListExport(list []ErpCommodity) (string, error) {
|
|
file := excelize.NewFile()
|
|
streamWriter, err := file.NewStreamWriter("Sheet1")
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
}
|
|
|
|
url := "http://39.108.188.218:8000/img/export/"
|
|
fileName := time.Now().Format(TimeFormat) + "商品" + ".xlsx"
|
|
|
|
//title := []interface{}{"供应商编号", "供应商名称", "联系人", "手机号", "地址", "开户银行", "银行账号", "付款周期/天"}
|
|
title := []interface{}{"商品编号", "商品名称", "商品分类", "是否串码", "主供应商", "零售价", "最低零售价", "员工成本价",
|
|
"采购价", "提成等级1", "提成等级2", "产地", "备注", "会员折扣(零售价的百分比)"}
|
|
cell, _ := excelize.CoordinatesToCellName(1, 1)
|
|
if err = streamWriter.SetRow(cell, title); err != nil {
|
|
fmt.Println(err)
|
|
}
|
|
var row []interface{}
|
|
for rowId := 0; rowId < len(list); rowId++ {
|
|
isIMEI := "否"
|
|
if list[rowId].IMEIType == 2 {
|
|
isIMEI = "是"
|
|
}
|
|
|
|
row = []interface{}{list[rowId].SerialNumber, list[rowId].Name, list[rowId].ErpCategoryName,
|
|
isIMEI, list[rowId].ErpSupplierName, list[rowId].RetailPrice,
|
|
list[rowId].MinRetailPrice, list[rowId].StaffCostPrice, list[rowId].WholesalePrice, list[rowId].Brokerage1,
|
|
list[rowId].Brokerage2, list[rowId].Origin, list[rowId].Remark, list[rowId].MemberDiscount}
|
|
cell, _ := excelize.CoordinatesToCellName(1, rowId+2)
|
|
if err := streamWriter.SetRow(cell, row); err != nil {
|
|
fmt.Println(err)
|
|
}
|
|
}
|
|
if err := streamWriter.Flush(); err != nil {
|
|
fmt.Println(err)
|
|
}
|
|
if err := file.SaveAs("/www/server/images/export/" + fileName); err != nil {
|
|
//if err := file.SaveAs("./" + fileName); err != nil {
|
|
fmt.Println(err)
|
|
}
|
|
return url + fileName, nil
|
|
}
|
|
|
|
//func (c *ErpCommodity) IdInit() {
|
|
// if c.ErpCategoryId != 0 {
|
|
// if c.ErpCategory == nil {
|
|
// category, err := GetErpCategory(c.ErpCategoryId)
|
|
// if err != nil {
|
|
// logger.Error("get erp category err:", err)
|
|
// return
|
|
// }
|
|
// c.ErpCategory = category
|
|
// }
|
|
// c.ErpCategoryName = c.ErpCategory.Name
|
|
// }
|
|
//
|
|
// if c.ErpSupplierId != 0 {
|
|
// supplier, err := GetErpSupplier(c.ErpSupplierId)
|
|
// if err != nil {
|
|
// logger.Error("get erp category err:", err)
|
|
// } else {
|
|
// c.ErpSupplierName = supplier.Name
|
|
// }
|
|
// }
|
|
//}
|
|
|
|
//func GetErpCategory(id uint32) (*ErpCategory, error) {
|
|
// category := new(ErpCategory)
|
|
// err := orm.Eloquent.Table("erp_category").Where("id=?", id).Find(category).Error
|
|
// if err != nil {
|
|
// logger.Error("category err:", err)
|
|
// return category, err
|
|
// }
|
|
// return category, nil
|
|
//}
|
|
//
|
|
//func GetErpSupplier(id uint32) (*ErpSupplier, error) {
|
|
// supplier := new(ErpSupplier)
|
|
// err := orm.Eloquent.Table("erp_supplier").Where("id=?", id).Find(supplier).Error
|
|
// if err != nil {
|
|
// logger.Error("category err:", err)
|
|
// return supplier, err
|
|
// }
|
|
// return supplier, err
|
|
//}
|
|
|
|
//func (c *ErpCommodity) SetErpCategory() error {
|
|
// if c.ErpCategoryId != 0 {
|
|
// category, err := GetErpCategory(c.ErpCategoryId)
|
|
// if err != nil {
|
|
// logger.Error("get erp category err:", err)
|
|
// return err
|
|
// }
|
|
// c.ErpCategory = category
|
|
// return nil
|
|
// }
|
|
// return errors.New("erp category id null")
|
|
//}
|
|
|
|
//type ErpCommodityListReq struct {
|
|
// SerialNumber string `json:"serial_number"`
|
|
// Name string `json:"name"`
|
|
// ErpCategoryId uint32 `json:"erp_category_id"`
|
|
// IMEI string `json:"imei"`
|
|
// ErpSupplierId uint32 `json:"erp_supplier_id"`
|
|
// PageNum int `json:"page_num"`
|
|
// PageSize int `json:"page_size"`
|
|
// IsExport uint32 `json:"is_export"` // 1-导出
|
|
//}
|
|
//type ErpCommodityListResp struct {
|
|
// List []ErpCommodity `json:"list"`
|
|
// Total int `json:"total"`
|
|
// PageNum int `json:"page_num"`
|
|
// PageSize int `json:"page_size"`
|
|
// ExportUrl string `json:"export_url"`
|
|
//}
|
|
//
|
|
//func (m *ErpCommodityListReq) List() (*ErpCommodityListResp, error) {
|
|
// resp := &ErpCommodityListResp{
|
|
// PageNum: m.PageNum,
|
|
// PageSize: m.PageSize,
|
|
// }
|
|
// page := m.PageNum - 1
|
|
// if page < 0 {
|
|
// page = 0
|
|
// }
|
|
// if m.PageSize == 0 {
|
|
// m.PageSize = 10
|
|
// }
|
|
// qs := orm.Eloquent.Table("erp_commodity")
|
|
// if m.SerialNumber != "" {
|
|
// qs = qs.Where("serial_number=?", m.SerialNumber)
|
|
// }
|
|
// if m.Name != "" {
|
|
// //qs = qs.Where("name Like %" + m.Name + "%")
|
|
// qs = qs.Where("name LIKE ?", m.Name)
|
|
// }
|
|
// if m.IMEI != "" {
|
|
// qs = qs.Where("imei=?", m.IMEI)
|
|
// }
|
|
// if m.ErpCategoryId != 0 {
|
|
// qs = qs.Where("erp_category_id=?", m.ErpCategoryId)
|
|
// }
|
|
// if m.ErpSupplierId != 0 {
|
|
// qs = qs.Where("erp_supplier_id=?", m.ErpSupplierId)
|
|
// }
|
|
//
|
|
// var count int64
|
|
// err := qs.Count(&count).Error
|
|
// if err != nil {
|
|
// logger.Error("count err:", err)
|
|
// return resp, err
|
|
// }
|
|
// resp.Total = int(count)/m.PageSize + 1
|
|
// var commodities []ErpCommodity
|
|
//
|
|
// if m.IsExport == 1 {
|
|
// err = qs.Order("id DESC").Find(&commodities).Error
|
|
// if err != nil && err != RecordNotFound {
|
|
// logger.Error("dailys err:", err)
|
|
// return resp, err
|
|
// }
|
|
//
|
|
// listExport, err := ErpCommodityListExport(commodities)
|
|
// if err != nil {
|
|
// logger.Error("list export err:", err)
|
|
// }
|
|
// resp.ExportUrl = listExport
|
|
// } else {
|
|
// err = qs.Order("id DESC").Offset(page * m.PageSize).Limit(m.PageSize).Find(&commodities).Error
|
|
// if err != nil && err != RecordNotFound {
|
|
// logger.Error("erp commodity list err:", err)
|
|
// return resp, err
|
|
// }
|
|
// resp.List = commodities
|
|
// }
|
|
//
|
|
// return resp, nil
|
|
//}
|
|
//
|
|
//type ErpCategoryListReq struct {
|
|
// ErpCategoryId uint32 `json:"erp_category_id"`
|
|
// Pid uint32 `json:"pid"`
|
|
// Level uint32 `json:"level"` // 分类层级
|
|
// State uint32 `json:"state"` // 1-未使用 2-使用 3-隐藏
|
|
// PageNum int `json:"page_num"`
|
|
// PageSize int `json:"page_size"`
|
|
// IsExport uint32 `json:"is_export"` // 1-导出
|
|
//}
|
|
//type ErpCategoryListResp struct {
|
|
// List []ErpCategory `json:"list"`
|
|
// Total int `json:"total"`
|
|
// PageNum int `json:"page_num"`
|
|
// PageSize int `json:"page_size"`
|
|
// ExportUrl string `json:"export_url"`
|
|
//}
|
|
//
|
|
//func (m *ErpCategoryListReq) List() (*ErpCategoryListResp, error) {
|
|
// resp := &ErpCategoryListResp{
|
|
// PageNum: m.PageNum,
|
|
// PageSize: m.PageSize,
|
|
// }
|
|
// //page := m.PageNum - 1
|
|
// //if page < 0 {
|
|
// // page = 0
|
|
// //}
|
|
// //if m.PageSize == 0 {
|
|
// // m.PageSize = 10
|
|
// //}
|
|
// //qs := orm.Eloquent.Table("erp_category")
|
|
// //if m.Level != 0 {
|
|
// // qs = qs.Where("level=?", m.Level)
|
|
// //}
|
|
// ////if m.ErpCategoryId != 0 {
|
|
// //// qs = qs.IDEq(m.ErpCategoryId)
|
|
// ////}
|
|
// //if m.Pid != 0 {
|
|
// // qs = qs.Where("pid", m.Pid)
|
|
// //}
|
|
// //var count int64
|
|
// //err := qs.Count(&count).Error
|
|
// //if err != nil {
|
|
// // logger.Error("count err:", err)
|
|
// // return resp, err
|
|
// //}
|
|
// //resp.Total = int(count)/m.PageSize + 1
|
|
// //var categories []ErpCategory
|
|
// //err = qs.Order("id DESC").Offset(page * m.PageSize).Limit(m.PageSize).Find(&categories).Error
|
|
// //if err != nil && err != RecordNotFound {
|
|
// // logger.Error("erp commodity list err:", err)
|
|
// // return resp, err
|
|
// //}
|
|
//
|
|
// var categories []ErpCategory
|
|
// qs := orm.Eloquent.Table("erp_category").Where("level=?", 1)
|
|
// if m.Pid != 0 {
|
|
// qs = qs.Where("id=?", m.Pid)
|
|
// }
|
|
// if m.State != 0 {
|
|
// qs.Where("state=?", m.State)
|
|
// }
|
|
//
|
|
// err := qs.Order("sort DESC").Find(&categories).Error
|
|
// if err != nil {
|
|
// logger.Error("erp commodity list err:", err)
|
|
// return resp, err
|
|
// }
|
|
// pids := make([]uint32, 0)
|
|
// for i, _ := range categories {
|
|
// pids = append(pids, categories[i].ID)
|
|
// }
|
|
//
|
|
// var subCat []ErpCategory
|
|
// subQs := orm.Eloquent.Table("erp_category").Where("pid in (?)", pids)
|
|
// if m.State != 0 {
|
|
// subQs.Where("state=?", m.State)
|
|
// }
|
|
// err = subQs.Order("sort DESC").Find(&subCat).Error
|
|
// if err != nil {
|
|
// logger.Errorf("pCat err:%#v", err)
|
|
// return resp, err
|
|
// }
|
|
//
|
|
// pCatMap := make(map[uint32][]ErpCategory, 0)
|
|
// for i, _ := range subCat {
|
|
// pCatMap[subCat[i].Pid] = append(pCatMap[subCat[i].Pid], subCat[i])
|
|
// }
|
|
//
|
|
// for i, _ := range categories {
|
|
// v, ok := pCatMap[categories[i].ID]
|
|
//
|
|
// if ok {
|
|
// categories[i].SubCats = v
|
|
// }
|
|
// }
|
|
//
|
|
// if m.IsExport == 1 {
|
|
// listExport, err := ErpCategoryListExport(categories)
|
|
// if err != nil {
|
|
// logger.Error("list export err:", err)
|
|
// }
|
|
// resp.ExportUrl = listExport
|
|
// }
|
|
//
|
|
// resp.List = categories
|
|
// return resp, nil
|
|
//}
|
|
//
|
|
//func GetErpCashierMap(ids []uint32) (map[uint32]*ErpCashier, error) {
|
|
// cashierMap := make(map[uint32]*ErpCashier, 0)
|
|
// if len(ids) == 0 {
|
|
// return cashierMap, nil
|
|
// }
|
|
// var erpCashiers []ErpCashier
|
|
// err := orm.Eloquent.Table("erp_cashier").Where("id IN (?)", ids).Find(&erpCashiers).Error
|
|
// if err != nil {
|
|
// logger.Error("erp cashiers err:", err)
|
|
// return cashierMap, err
|
|
// }
|
|
// for i, _ := range erpCashiers {
|
|
// cashierMap[erpCashiers[i].ID] = &erpCashiers[i]
|
|
// }
|
|
//
|
|
// return cashierMap, nil
|
|
//}
|
|
//
|
|
//var ErpCommodityFileExcelCols = []string{"category_1", "category_2", "name", "is_imei", "erp_supplier_name",
|
|
// "brokerage_1_string", "brokerage_2_string", "retail_price_string", "min_retail_price_string",
|
|
// "staff_cost_price_string", "wholesale_price_string", "origin", "remark"}
|
|
//
|
|
//type ErpCommodityFileExcel struct {
|
|
// Category1 string `json:"category_1"`
|
|
// Category2 string `json:"category_2"`
|
|
// IsIMEI string `json:"is_imei"`
|
|
//
|
|
// RetailPriceString string `json:"retail_price_string"`
|
|
// MinRetailPriceString string `json:"min_retail_price_string"`
|
|
// StaffCostPriceString string `json:"staff_cost_price_string"`
|
|
// WholesalePriceString string `json:"wholesale_price_string"`
|
|
// Brokerage1String string `json:"brokerage_1_string"`
|
|
// Brokerage2String string `json:"brokerage_2_string"`
|
|
//
|
|
// Code string `json:"code"`
|
|
// ErpCommodity
|
|
//}
|
|
//
|
|
//func (e *ErpCommodityFileExcel) Processing() {
|
|
// if e.IsIMEI == "是" {
|
|
// e.IMEIType = 2
|
|
// } else if e.IsIMEI == "否" {
|
|
// e.IMEIType = 1
|
|
// }
|
|
//
|
|
// e.RetailPrice = PercentFloatStringToUin32(e.RetailPriceString)
|
|
// e.MinRetailPrice = PercentFloatStringToUin32(e.MinRetailPriceString)
|
|
// e.StaffCostPrice = PercentFloatStringToUin32(e.StaffCostPriceString)
|
|
// e.WholesalePrice = PercentFloatStringToUin32(e.WholesalePriceString)
|
|
// e.Brokerage1 = PercentFloatStringToFloat(e.Brokerage1String)
|
|
// e.Brokerage2 = PercentFloatStringToFloat(e.Brokerage2String)
|
|
//}
|
|
//
|
|
//func PercentFloatStringToUin32(s string) uint32 {
|
|
// u := uint32(0)
|
|
// if s != "" {
|
|
// s = strings.ReplaceAll(s, "%", "")
|
|
// }
|
|
// f, err := strconv.ParseFloat(s, 64)
|
|
// if err != nil {
|
|
// logger.Error("parse float err:", err)
|
|
// return u
|
|
// }
|
|
//
|
|
// u = uint32(f * 100)
|
|
// return u
|
|
//}
|
|
//
|
|
//func PercentFloatStringToFloat(s string) float64 {
|
|
// //u := uint32(0)
|
|
// if s != "" {
|
|
// s = strings.ReplaceAll(s, "%", "")
|
|
// }
|
|
// f, err := strconv.ParseFloat(s, 64)
|
|
// if err != nil {
|
|
// logger.Error("parse float err:", err)
|
|
// return f
|
|
// }
|
|
//
|
|
// //u = uint32(f * 100)
|
|
// return f
|
|
//}
|
|
//
|
|
//func IntStringToUin32(s string) uint32 {
|
|
// u := uint32(0)
|
|
// if s != "" {
|
|
// s = strings.ReplaceAll(s, "%", "")
|
|
// }
|
|
// i, err := strconv.Atoi(s)
|
|
// if err != nil {
|
|
// logger.Error("parse float err:", err)
|
|
// return u
|
|
// }
|
|
//
|
|
// u = uint32(i)
|
|
// return u
|
|
//}
|
|
//
|
|
//type ErpCategorySub struct {
|
|
// Id uint32 `json:"id"`
|
|
// Name string `json:"name"`
|
|
// FullNum uint32 `json:"full_num"`
|
|
// SubMap map[string]ErpCategory
|
|
// //UnCodeMap map[string]uint32
|
|
//}
|
|
//
|
|
//func ErpCommodityFileExcelListProcessing(list []ErpCommodityFileExcel) {
|
|
// allCategoriesMap, err := GetErpCategorySubMap()
|
|
// if err != nil {
|
|
// logger.Error("all categories map err:", err)
|
|
// return
|
|
// }
|
|
// fmt.Println("allCategoriesMap:", allCategoriesMap)
|
|
// unCodeMap1 := make(map[string]string, 0)
|
|
// unCodeMap2 := make(map[string]string, 0)
|
|
// numberCount := &CommodityNumberCount{}
|
|
// numberCount.NumberMap = make(map[uint32]uint32, 0)
|
|
//
|
|
// for i, _ := range list {
|
|
// //if i == 0 {
|
|
// // continue
|
|
// //}
|
|
// list[i].Processing()
|
|
// cat1 := list[i].Category1
|
|
// unCode1, okUc1 := unCodeMap1[cat1]
|
|
// if okUc1 {
|
|
// cat1 = unCode1
|
|
// }
|
|
// catSub, ok := allCategoriesMap[cat1]
|
|
// if ok {
|
|
// if list[i].Category2 != "" {
|
|
// cat2 := list[i].Category2
|
|
// unCode2, okUc2 := unCodeMap2[cat2]
|
|
// if okUc2 {
|
|
// cat2 = unCode2
|
|
// }
|
|
// sub, ok1 := catSub.SubMap[unCode2]
|
|
// //unCodeCat, ok2 := unCodeMap2[list[i].Category2]
|
|
// if ok1 {
|
|
// list[i].ErpCommodity.ErpCategoryId = sub.ID
|
|
// list[i].ErpCommodity.ErpCategory = &sub
|
|
// numberCommodity, err := numberCount.GetErpCommodityNumberByCategoryId(sub.ID)
|
|
// if err != nil {
|
|
// logger.Error("category2 create err:", err)
|
|
// return
|
|
// }
|
|
// list[i].ErpCommodity.Number = numberCommodity
|
|
// list[i].ErpCommodity.ErpCategoryName = cat2
|
|
//
|
|
// } else {
|
|
// category2, err := ErpCategoryCreate(list[i].Category2, catSub.Id)
|
|
// if err != nil {
|
|
// logger.Error("category2 create err:", err)
|
|
// return
|
|
// }
|
|
// fmt.Println("分类id", category2.ID)
|
|
// list[i].ErpCommodity.ErpCategoryId = category2.ID
|
|
// list[i].ErpCommodity.ErpCategory = category2
|
|
// allCategoriesMap, err = GetErpCategorySubMap()
|
|
// if err != nil {
|
|
// logger.Error("all categories map err:", err)
|
|
// return
|
|
// }
|
|
// numberCount.NumberMap[category2.ID] = 1
|
|
// list[i].ErpCommodity.Number = 1
|
|
// list[i].ErpCommodity.ErpCategoryName = cat2
|
|
// unCodeMap2[list[i].Category2] = category2.Name
|
|
// }
|
|
// } else {
|
|
// list[i].ErpCommodity.ErpCategoryId = catSub.Id
|
|
// list[i].ErpCommodity.ErpCategory = &ErpCategory{Number: catSub.FullNum} // TODO
|
|
// numberCommodity, err := numberCount.GetErpCommodityNumberByCategoryId(catSub.Id)
|
|
// if err != nil {
|
|
// logger.Error("category2 create err:", err)
|
|
// return
|
|
// }
|
|
// list[i].ErpCommodity.Number = numberCommodity
|
|
// list[i].ErpCommodity.ErpCategoryName = catSub.Name
|
|
// }
|
|
//
|
|
// list[i].ErpCommodity.SerialNumber = fmt.Sprintf("%06d%04d", list[i].ErpCommodity.ErpCategory.FullNum, list[i].ErpCommodity.Number)
|
|
// } else {
|
|
// category1, err := ErpCategoryCreate(list[i].Category1, 0)
|
|
// if err != nil {
|
|
// logger.Error("category1 create err:", err)
|
|
// return
|
|
// }
|
|
// unCodeMap1[list[i].Category1] = category1.Name
|
|
// if list[i].Category2 != "" {
|
|
// category2, err := ErpCategoryCreate(list[i].Category2, category1.ID)
|
|
// if err != nil {
|
|
// logger.Error("category2 create err:", err)
|
|
// return
|
|
// }
|
|
// fmt.Println("分类id2", category2.ID)
|
|
// list[i].ErpCommodity.ErpCategoryId = category2.ID
|
|
// list[i].ErpCommodity.ErpCategoryName = list[i].Category2
|
|
// list[i].ErpCommodity.ErpCategory = category2
|
|
// unCodeMap2[list[i].Category2] = category2.Name
|
|
//
|
|
// numberCount.NumberMap[category2.ID] = 1
|
|
// list[i].ErpCommodity.Number = 1
|
|
// } else {
|
|
// list[i].ErpCommodity.ErpCategoryId = category1.ID
|
|
// list[i].ErpCommodity.ErpCategoryName = list[i].Category1
|
|
// list[i].ErpCommodity.ErpCategory = category1
|
|
//
|
|
// numberCount.NumberMap[category1.ID] = 1
|
|
// list[i].ErpCommodity.Number = 1
|
|
// }
|
|
//
|
|
// list[i].ErpCommodity.SerialNumber = fmt.Sprintf("%06d%04d", list[i].ErpCommodity.ErpCategory.FullNum, list[i].ErpCommodity.Number)
|
|
// allCategoriesMap, err = GetErpCategorySubMap()
|
|
// if err != nil {
|
|
// logger.Error("all categories map err:", err)
|
|
// return
|
|
// }
|
|
// } /**/
|
|
// }
|
|
//
|
|
//}
|
|
//
|
|
//type CommodityNumberCount struct {
|
|
// NumberMap map[uint32]uint32 `json:"number_map"`
|
|
//}
|
|
//
|
|
//func (m *CommodityNumberCount) GetErpCommodityNumberByCategoryId(categoryId uint32) (uint32, error) {
|
|
// v, ok := m.NumberMap[categoryId]
|
|
// if ok {
|
|
// m.NumberMap[categoryId] = v + 1
|
|
// return v + 1, nil
|
|
// }
|
|
// var commodity ErpCommodity
|
|
// err := orm.Eloquent.Raw(fmt.Sprintf(
|
|
// "SELECT number FROM erp_commodity WHERE erp_category_id=%d ORDER BY id DESC LIMIT 0,1;", categoryId)).Scan(&commodity).Error
|
|
// if err != nil {
|
|
// logger.Error("all categories map err:", err)
|
|
// return 0, err
|
|
// }
|
|
// m.NumberMap[categoryId] = commodity.Number + 1
|
|
// return commodity.Number + 1, nil
|
|
//}
|
|
//
|
|
//func GetErpCategorySubMap() (map[string]*ErpCategorySub, error) {
|
|
// var erpCategories []ErpCategory
|
|
// err := orm.Eloquent.Table("erp_category").Find(&erpCategories).Error
|
|
// if err != nil {
|
|
// logger.Error("erp categories err:", err)
|
|
// return nil, err
|
|
// }
|
|
// categoriesMaps := make(map[string]*ErpCategorySub, 0)
|
|
//
|
|
// pidMap := make(map[uint32]string, 0)
|
|
//
|
|
// for i, _ := range erpCategories {
|
|
// if erpCategories[i].Level == 1 {
|
|
// if erpCategories[i].Pid != 0 {
|
|
// logger.Error("erp categories level 1 pid gt 0")
|
|
// return nil, errors.New("erp categories level 1 pid gt 0")
|
|
// }
|
|
// if _, ok := categoriesMaps[erpCategories[i].Name]; !ok {
|
|
// categoriesMaps[erpCategories[i].Name] = &ErpCategorySub{
|
|
// Id: erpCategories[i].ID,
|
|
// Name: erpCategories[i].Name,
|
|
// FullNum: erpCategories[i].FullNum,
|
|
// SubMap: make(map[string]ErpCategory, 0),
|
|
// }
|
|
// pidMap[erpCategories[i].ID] = erpCategories[i].Name
|
|
// }
|
|
//
|
|
// }
|
|
// }
|
|
//
|
|
// for i, _ := range erpCategories {
|
|
// if erpCategories[i].Level == 2 {
|
|
// if erpCategories[i].Pid == 0 {
|
|
// logger.Error("erp categories level 2 pid is 0")
|
|
// return nil, errors.New("erp categories level 2 pid is 0")
|
|
// }
|
|
// name, ok := pidMap[erpCategories[i].Pid]
|
|
// if ok {
|
|
// categoriesMaps[name].SubMap[erpCategories[i].Name] = erpCategories[i]
|
|
// }
|
|
// }
|
|
// }
|
|
//
|
|
// return categoriesMaps, nil
|
|
//}
|
|
//
|
|
//func ErpCategoryCreate(name string, pid uint32) (*ErpCategory, error) {
|
|
// category := &ErpCategory{
|
|
// Number: 0,
|
|
// State: 2,
|
|
// Level: 1,
|
|
// Pid: pid,
|
|
// }
|
|
// var (
|
|
// pCategory ErpCategory
|
|
// sCategory ErpCategory
|
|
// )
|
|
// qs := orm.Eloquent.Table("erp_category")
|
|
// if category.Pid != 0 {
|
|
// category.Level = 2
|
|
// qs = qs.Where("id=?", pid)
|
|
// err := orm.Eloquent.Table("erp_category").Where("pid=?", pid).Order("id DESC").Limit(1).Find(&sCategory).Error
|
|
// if err != nil {
|
|
// logger.Error("s category err:", err)
|
|
// return category, err
|
|
// }
|
|
// } else {
|
|
// qs = qs.Where("level=1")
|
|
// }
|
|
// err := qs.Order("id DESC").Limit(1).Find(&pCategory).Error
|
|
// if err != nil && err != RecordNotFound {
|
|
// logger.Error("cat erp commodity err:", err)
|
|
// return category, err
|
|
// }
|
|
//
|
|
// if category.Level == 1 {
|
|
// category.Number = pCategory.Number + 1
|
|
// category.FullNum = pCategory.FullNum + 1000
|
|
// category.Name = fmt.Sprintf("%03d%s", category.Number, name)
|
|
// } else {
|
|
// category.Number = sCategory.Number + 1
|
|
// category.Name = fmt.Sprintf("%03d-%03d%s", pCategory.Number, category.Number, name)
|
|
// category.FullNum = pCategory.FullNum + category.Number
|
|
// }
|
|
//
|
|
// err = orm.Eloquent.Create(category).Error
|
|
// if err != nil {
|
|
// logger.Error("create commodity err:", err)
|
|
// return category, err
|
|
// }
|
|
// return category, nil
|
|
//}
|
|
//
|
|
//type ErpSupplierListResp struct {
|
|
// List []ErpSupplier `json:"list"`
|
|
// Total int `json:"total"`
|
|
// PageNum int `json:"page_num"`
|
|
// PageSize int `json:"page_size"`
|
|
// ExportUrl string `json:"export_url"`
|
|
//}
|
|
//
|
|
//var ErpStockFileExcelCols = []string{"store_name", "erp_commodity_name", "erp_category_name", "serial_number",
|
|
// "is_imei", "imei", "erp_supplier_name", "stock_time_string", "retail_price_string",
|
|
// "min_retail_price_string", "staff_cost_price_string", "wholesale_price_string", "count_string",
|
|
//}
|
|
//
|
|
//var EsfLock sync.Mutex
|
|
//var EsStockLock sync.Mutex
|
|
//
|
|
//type StockImporter struct {
|
|
// CensusMap map[uint32]map[uint32]uint32
|
|
// CommodityMap map[uint32]*ErpCommodity
|
|
// StoreMap map[uint32]string
|
|
// Inventories []*ErpInventoryStock
|
|
//}
|
|
//
|
|
//type ErpStockFileExcel struct {
|
|
// StockTimeString string `json:"stock_time_string"`
|
|
// IsIMEI string `json:"is_imei"`
|
|
//
|
|
// RetailPriceString string `json:"retail_price_string"`
|
|
// MinRetailPriceString string `json:"min_retail_price_string"`
|
|
// StaffCostPriceString string `json:"staff_cost_price_string"`
|
|
// WholesalePriceString string `json:"wholesale_price_string"`
|
|
// CountString string `json:"count_string"`
|
|
//
|
|
// //StoreName string `json:"store_name"`
|
|
// //ErpCommodityName string `json:"erp_commodity_name"`
|
|
// //ErpCategoryName string `json:"erp_category_name"`
|
|
// //SerialNumber string `json:"serial_number"`
|
|
// //IMEIType uint32 `json:"imei_type"` // 1-无串码 2-串码
|
|
// //IMEI string `json:"imei"`
|
|
// //ErpSupplierName string `json:"erp_supplier_name"`
|
|
//
|
|
// ErpStockCommodity
|
|
//}
|
|
//
|
|
//func NewStockImporter() *StockImporter {
|
|
// return &StockImporter{
|
|
// CensusMap: make(map[uint32]map[uint32]uint32, 0),
|
|
// CommodityMap: make(map[uint32]*ErpCommodity),
|
|
// StoreMap: make(map[uint32]string, 0),
|
|
// Inventories: make([]*ErpInventoryStock, 0),
|
|
// }
|
|
//}
|
|
//
|
|
//func (e *ErpStockFileExcel) Processing() {
|
|
// e.Count = IntStringToUin32(e.CountString)
|
|
// if e.IsIMEI == "是" {
|
|
// e.IMEIType = 2
|
|
// e.Count = 1
|
|
// } else if e.IsIMEI == "否" {
|
|
// e.IMEIType = 1
|
|
// }
|
|
// //parseTime, err := time.Parse(DateTimeFormat, e.StockTimeString)
|
|
// //fmt.Println("StockTimeString:", e.StockTimeString)
|
|
// //parseTime, err := time.Parse("01-02-06", e.StockTimeString)
|
|
// format := "2006/01/02"
|
|
// parseTime, err := time.Parse(format, e.StockTimeString)
|
|
// if err != nil {
|
|
// logger.Error("parse err:", err)
|
|
// parseTime = time.Now()
|
|
// }
|
|
// e.StockTime = parseTime
|
|
//
|
|
// e.RetailPrice = PercentFloatStringToUin32(e.RetailPriceString)
|
|
// e.MinRetailPrice = PercentFloatStringToUin32(e.MinRetailPriceString)
|
|
// e.StaffCostPrice = PercentFloatStringToUin32(e.StaffCostPriceString)
|
|
// e.WholesalePrice = PercentFloatStringToUin32(e.WholesalePriceString)
|
|
//
|
|
//}
|
|
//
|
|
//func (m *StockImporter) ErpStockFileExcelListProcessing(list []ErpStockFileExcel) error {
|
|
// //allCategoriesMap, err := GetErpCategorySubMap()
|
|
// //if err != nil {
|
|
// // logger.Error("all categories map err:", err)
|
|
// // return
|
|
// //}
|
|
// // 加锁
|
|
// //m.CensusMap = make(map[uint32]map[uint32]uint32, 0)
|
|
// storeNameMap := make(map[string]uint32, 0)
|
|
// erpCommodityMap := make(map[string]*ErpCommodity, 0)
|
|
// erpCategoryNameMap := make(map[string]uint32, 0)
|
|
// erpSupplierNameMap := make(map[string]uint32, 0)
|
|
//
|
|
// storeNames := make([]string, 0, len(list))
|
|
// erpCommodityNames := make([]string, 0, len(list))
|
|
// erpCategoryNames := make([]string, 0, len(list))
|
|
// erpSupplierNames := make([]string, 0, len(list))
|
|
//
|
|
// for i, _ := range list {
|
|
// list[i].Processing()
|
|
// _, ok1 := storeNameMap[list[i].StoreName]
|
|
// if !ok1 {
|
|
// storeNames = append(storeNames, list[i].StoreName)
|
|
// }
|
|
// _, ok2 := erpCommodityMap[list[i].ErpCommodityName]
|
|
// if !ok2 {
|
|
// erpCommodityNames = append(erpCommodityNames, list[i].ErpCommodityName)
|
|
// }
|
|
// _, ok3 := erpCategoryNameMap[list[i].ErpCategoryName]
|
|
// if !ok3 {
|
|
// erpCategoryNames = append(erpCategoryNames, list[i].ErpCategoryName)
|
|
// }
|
|
// _, ok4 := erpSupplierNameMap[list[i].ErpSupplierName]
|
|
// if !ok4 {
|
|
// erpSupplierNames = append(erpSupplierNames, list[i].ErpSupplierName)
|
|
// }
|
|
// storeNameMap[list[i].StoreName] = uint32(0)
|
|
// erpCommodityMap[list[i].ErpCommodityName] = nil
|
|
// erpCategoryNameMap[list[i].ErpCategoryName] = uint32(0)
|
|
// erpSupplierNameMap[list[i].ErpSupplierName] = uint32(0)
|
|
//
|
|
// }
|
|
//
|
|
// var stores []Store
|
|
// err := orm.Eloquent.Table("store").Where("name IN (?)", storeNames).Find(&stores).Error
|
|
// if err != nil {
|
|
// logger.Error("stores err:", err)
|
|
// return err
|
|
// }
|
|
//
|
|
// var erpCommodities []ErpCommodity
|
|
// err = orm.Eloquent.Table("erp_commodity").Where("name IN (?)", erpCommodityNames).Find(&erpCommodities).Error
|
|
// if err != nil {
|
|
// logger.Error("stores err:", err)
|
|
// return err
|
|
// }
|
|
//
|
|
// var erpCategories []ErpCategory
|
|
// err = orm.Eloquent.Table("erp_category").Where("name IN (?)", erpCategoryNames).Find(&erpCategories).Error
|
|
// if err != nil {
|
|
// logger.Error("stores err:", err)
|
|
// return err
|
|
// }
|
|
//
|
|
// var erpSuppliers []ErpSupplier
|
|
// err = orm.Eloquent.Table("erp_supplier").Debug().Where("name IN (?)", erpSupplierNames).Find(&erpSuppliers).Error
|
|
// if err != nil && err != RecordNotFound {
|
|
// logger.Error("stores err:", err)
|
|
// return err
|
|
// }
|
|
//
|
|
// for i, _ := range stores {
|
|
// storeNameMap[stores[i].Name] = stores[i].ID
|
|
// m.StoreMap[stores[i].ID] = stores[i].Name
|
|
// }
|
|
//
|
|
// for i, _ := range erpCommodities {
|
|
// erpCommodityMap[erpCommodities[i].Name] = &erpCommodities[i]
|
|
// m.CommodityMap[erpCommodities[i].ID] = &erpCommodities[i]
|
|
// }
|
|
//
|
|
// for i, _ := range erpCategories {
|
|
// erpCategoryNameMap[erpCategories[i].Name] = erpCategories[i].ID
|
|
// }
|
|
//
|
|
// for i, _ := range erpSuppliers {
|
|
// erpSupplierNameMap[erpSuppliers[i].Name] = erpSuppliers[i].ID
|
|
// }
|
|
//
|
|
// //categoryCommodityNumMap := make(map[uint32]uint32, 0)
|
|
// //for i, _ := range erpCommodities {
|
|
// // var commodity ErpCommodity
|
|
// // err = orm.Eloquent.Table("erp_commodity").Where("erp_category_id=?", erpCommodities[i].ErpCategoryId).
|
|
// // Order("id DESC").Limit(1).Find(&commodity).Error
|
|
// // if err != nil {
|
|
// // logger.Error("commodity err:", err)
|
|
// // }
|
|
// // categoryCommodityNumMap[erpCommodities[i].ErpCategoryId] = commodity.Number
|
|
// //}
|
|
// nowTime := time.Now()
|
|
// for i, _ := range list {
|
|
// v1, ok1 := storeNameMap[list[i].StoreName]
|
|
//
|
|
// v2, ok2 := erpCommodityMap[list[i].ErpCommodityName]
|
|
//
|
|
// v3, ok3 := erpCategoryNameMap[list[i].ErpCategoryName]
|
|
//
|
|
// v4, ok4 := erpSupplierNameMap[list[i].ErpSupplierName]
|
|
//
|
|
// if !ok1 {
|
|
// logger.Error("store name err")
|
|
// return errors.New("store name err")
|
|
// }
|
|
// if !ok2 && v2 == nil {
|
|
// logger.Error("erp commodity name err")
|
|
// return errors.New("erp commodity name err")
|
|
// }
|
|
// if !ok3 {
|
|
// logger.Error("erp category name err")
|
|
// return errors.New("erp category name err")
|
|
// }
|
|
// if !ok4 {
|
|
// logger.Error("erp supplier name err")
|
|
// return errors.New("erp supplier name err")
|
|
// }
|
|
//
|
|
// list[i].StoreId = v1
|
|
// list[i].ErpCommodityId = v2.ID
|
|
// list[i].CommoditySerialNumber = v2.SerialNumber
|
|
// list[i].ErpCategoryId = v3
|
|
// list[i].ErpSupplierId = v4
|
|
// list[i].State = 1
|
|
// list[i].StorageType = 1
|
|
// list[i].FirstStockTime = nowTime
|
|
//
|
|
// //v6, ok6 := m.CommodityMap[v2]
|
|
//
|
|
// _, ok5 := m.CensusMap[list[i].StoreId]
|
|
// if ok5 {
|
|
// m.CensusMap[list[i].StoreId][list[i].ErpCommodityId] += list[i].Count
|
|
// } else {
|
|
// m.CensusMap[list[i].StoreId] = map[uint32]uint32{list[i].ErpCommodityId: list[i].Count}
|
|
// }
|
|
// //v5, ok5 := categoryCommodityNumMap[list[i].ErpCategoryId]
|
|
// //if !ok5 {
|
|
// // logger.Error("category commodity num err")
|
|
// // return errors.New("category commodity num err")
|
|
// //}
|
|
//
|
|
// }
|
|
// return nil
|
|
//}
|
|
//
|
|
//func (m *StockImporter) ErpStockCountUpdate(gdb *gorm.DB) error {
|
|
// for k1, v1 := range m.CensusMap {
|
|
// for k2, v2 := range v1 {
|
|
// exist, err := QueryRecordExist(fmt.Sprintf("SELECT * FROM erp_stock WHERE store_id=%d AND erp_commodity_id=%d", k1, k2))
|
|
// if err != nil {
|
|
// logger.Error("exist err:", err)
|
|
// return err
|
|
// }
|
|
// v, ok := m.CommodityMap[k2]
|
|
// fmt.Println("CommodityMap", m.CommodityMap)
|
|
// fmt.Println("ok", ok)
|
|
// fmt.Println("v", v)
|
|
// if exist {
|
|
// err = gdb.Exec(fmt.Sprintf(
|
|
// "UPDATE erp_stock SET count=count+%d WHERE store_id=%d AND erp_commodity_id=%d;", v2, k1, k2)).Error
|
|
// if err != nil {
|
|
// logger.Error("update stock err:", err)
|
|
// return err
|
|
// }
|
|
// } else {
|
|
// if ok && v != nil {
|
|
// stock := &ErpStock{
|
|
// StoreId: k1,
|
|
// StoreName: m.StoreMap[k1],
|
|
// ErpCommodityId: v.ID,
|
|
// ErpCommodityName: v.Name,
|
|
// ErpCategoryId: v.ErpCategoryId,
|
|
// ErpCategoryName: v.ErpCategoryName,
|
|
// CommoditySerialNumber: v.SerialNumber,
|
|
// IMEIType: v.IMEIType,
|
|
// RetailPrice: v.RetailPrice,
|
|
// MinRetailPrice: v.MinRetailPrice,
|
|
// Count: v2,
|
|
// DispatchCount: 0,
|
|
// }
|
|
// err = gdb.Create(stock).Error
|
|
// if err != nil {
|
|
// logger.Error("create stock err:", err)
|
|
// return err
|
|
// }
|
|
// }
|
|
//
|
|
// }
|
|
// if ok && v != nil {
|
|
// inventoryStock := &ErpInventoryStock{
|
|
// StoreId: k1,
|
|
// StoreName: m.StoreMap[k1],
|
|
// ErpCommodityId: v.ID,
|
|
// ErpCommodityName: v.Name,
|
|
// ErpCategoryId: v.ErpCategoryId,
|
|
// ErpCategoryName: v.ErpCategoryName,
|
|
// CommoditySerialNumber: v.SerialNumber,
|
|
// IMEIType: v.IMEIType,
|
|
// RetailPrice: v.RetailPrice,
|
|
// MinRetailPrice: v.MinRetailPrice,
|
|
// Count: v2,
|
|
// }
|
|
// fmt.Println("inventoryStock", inventoryStock.Count)
|
|
// m.Inventories = append(m.Inventories, inventoryStock)
|
|
// }
|
|
//
|
|
// }
|
|
// }
|
|
//
|
|
// return nil
|
|
//}
|
|
//
|
|
//func (m *StockImporter) ErpInventoryStockCreate(gdb *gorm.DB, list []ErpStockFileExcel) error {
|
|
// defer func() {
|
|
// if err := recover(); err != nil {
|
|
// logger.Error("err:", err)
|
|
// return
|
|
// }
|
|
// }()
|
|
//
|
|
// inventoryStockIdMap := make(map[string]uint32, 0)
|
|
// for _, inventory := range m.Inventories {
|
|
// //err := gdb.Create(inventory).Error
|
|
// err := orm.Eloquent.Create(inventory).Error
|
|
// if err != nil {
|
|
// logger.Error("create erp inventory stock err:", err)
|
|
// return err
|
|
// }
|
|
// inventoryStockIdMap[fmt.Sprintf("%d_%d", inventory.StoreId, inventory.ErpCommodityId)] = inventory.ID
|
|
// }
|
|
//
|
|
// begin := orm.Eloquent.Begin()
|
|
// total := len(list)
|
|
// size := 500
|
|
// page := total / size
|
|
// if total%size != 0 {
|
|
// page += 1
|
|
// }
|
|
//
|
|
// errGroup := errgroup.Group{}
|
|
// for i := 0; i < page; i++ {
|
|
// if i == page-1 {
|
|
// stockList := ErpStockCommodityToInventory(inventoryStockIdMap, list[i*size:])
|
|
// err := begin.Create(&stockList).Error
|
|
// if err != nil {
|
|
// begin.Rollback()
|
|
// logger.Error("create commodity err:", err)
|
|
// return err
|
|
// }
|
|
// } else {
|
|
// errGroup.Go(func() error {
|
|
// //stockList := list[i*size : (i+1)*size]
|
|
// stockList := ErpStockCommodityToInventory(inventoryStockIdMap, list[i*size:(i+1)*size])
|
|
// err := begin.Create(&stockList).Error
|
|
// if err != nil {
|
|
// begin.Rollback()
|
|
// logger.Error("create commodity err:", err)
|
|
// return err
|
|
// }
|
|
// return nil
|
|
// })
|
|
// }
|
|
// }
|
|
// err := errGroup.Wait()
|
|
// if err != nil {
|
|
// logger.Error("wait err:", err)
|
|
// return err
|
|
// }
|
|
// err = begin.Commit().Error
|
|
// if err != nil {
|
|
// logger.Error("commit err:", err)
|
|
// return err
|
|
// }
|
|
//
|
|
// //go func() {
|
|
// // //inventoryStockIdMap := make(map[string]uint32, 0)
|
|
// // //for _, inventory := range m.Inventories {
|
|
// // // //err := gdb.Create(inventory).Error
|
|
// // // err := orm.Eloquent.Create(inventory).Error
|
|
// // // if err != nil {
|
|
// // // logger.Error("create erp inventory stock err:", err)
|
|
// // // return
|
|
// // // }
|
|
// // // inventoryStockIdMap[fmt.Sprintf("%d_%d", inventory.StoreId, inventory.ErpCommodityId)] = inventory.ID
|
|
// // //}
|
|
// //
|
|
// // //stock := ErpStockFileExcel{}
|
|
// // //ErpInventoryStock
|
|
// // for i, _ := range list {
|
|
// // v, ok := inventoryStockIdMap[fmt.Sprintf("%d_%d", list[i].StoreId, list[i].ErpCommodityId)]
|
|
// // if ok {
|
|
// // inventoryCommodity := &ErpInventoryStockCommodity{
|
|
// // ErpInventoryStockId: v,
|
|
// // ErpCommodityId: list[i].ErpCommodityId,
|
|
// // ErpCommodityName: list[i].ErpCommodityName,
|
|
// // SerialNumber: list[i].SerialNumber,
|
|
// // IMEIType: list[i].IMEIType,
|
|
// // IMEI: list[i].IMEI,
|
|
// // ErpSupplierId: list[i].ErpSupplierId,
|
|
// // ErpSupplierName: list[i].ErpSupplierName,
|
|
// // StockTime: list[i].StockTime,
|
|
// // RetailPrice: list[i].RetailPrice,
|
|
// // MinRetailPrice: list[i].MinRetailPrice,
|
|
// // StaffCostPrice: list[i].StaffCostPrice,
|
|
// // WholesalePrice: list[i].WholesalePrice,
|
|
// // Count: list[i].Count,
|
|
// // }
|
|
// // //err := gdb.Create(inventoryCommodity).Error
|
|
// // err := orm.Eloquent.Create(inventoryCommodity).Error
|
|
// // if err != nil {
|
|
// // logger.Error("create erp inventory stock commodity err:", err)
|
|
// // return
|
|
// // }
|
|
// // }
|
|
// //
|
|
// // }
|
|
// //}()
|
|
// return nil
|
|
//}
|
|
//
|
|
//func ErpStockCommodityToInventory(inventoryStockIdMap map[string]uint32, list []ErpStockFileExcel) []*ErpInventoryStockCommodity {
|
|
// inventoryList := make([]*ErpInventoryStockCommodity, 0, len(list))
|
|
// for i, _ := range list {
|
|
// v, ok := inventoryStockIdMap[fmt.Sprintf("%d_%d", list[i].StoreId, list[i].ErpCommodityId)]
|
|
// if ok {
|
|
// inventoryCommodity := &ErpInventoryStockCommodity{
|
|
// ErpInventoryStockId: v,
|
|
// ErpCommodityId: list[i].ErpCommodityId,
|
|
// ErpCommodityName: list[i].ErpCommodityName,
|
|
// CommoditySerialNumber: list[i].CommoditySerialNumber,
|
|
// IMEIType: list[i].IMEIType,
|
|
// IMEI: list[i].IMEI,
|
|
// ErpSupplierId: list[i].ErpSupplierId,
|
|
// ErpSupplierName: list[i].ErpSupplierName,
|
|
// StockTime: list[i].StockTime,
|
|
// RetailPrice: list[i].RetailPrice,
|
|
// MinRetailPrice: list[i].MinRetailPrice,
|
|
// StaffCostPrice: list[i].StaffCostPrice,
|
|
// WholesalePrice: list[i].WholesalePrice,
|
|
// Count: list[i].Count,
|
|
// }
|
|
// //err := gdb.Create(inventoryCommodity).Error
|
|
// inventoryList = append(inventoryList, inventoryCommodity)
|
|
// //err := orm.Eloquent.Create(inventoryCommodity).Error
|
|
// //if err != nil {
|
|
// // logger.Error("create erp inventory stock commodity err:", err)
|
|
// // return inventoryList
|
|
// //}
|
|
// }
|
|
// }
|
|
// return inventoryList
|
|
//}
|
|
//
|
|
//func GetErpCommodityMap(ids []uint32) (map[uint32]ErpCommodity, error) {
|
|
// commodityMap := make(map[uint32]ErpCommodity, 0)
|
|
// if len(ids) == 0 {
|
|
// return commodityMap, nil
|
|
// }
|
|
// var commodities []ErpCommodity
|
|
// err := orm.Eloquent.Table("erp_commodity").Where("id IN (?)", ids).Find(&commodities).Error
|
|
// if err != nil {
|
|
// logger.Error("commodities err:", err)
|
|
// return commodityMap, err
|
|
// }
|
|
//
|
|
// for i, _ := range commodities {
|
|
// commodityMap[commodities[i].ID] = commodities[i]
|
|
// }
|
|
//
|
|
// return commodityMap, nil
|
|
//}
|
|
//
|
|
//func ErpSupplierListExport(list []ErpSupplier) (string, error) {
|
|
// file := excelize.NewFile()
|
|
// streamWriter, err := file.NewStreamWriter("Sheet1")
|
|
// if err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
//
|
|
// url := "http://39.108.188.218:8000/img/export/"
|
|
// fileName := time.Now().Format(TimeFormat) + "供应商" + ".xlsx"
|
|
//
|
|
// //title := []interface{}{"门店", "用户ID", "订单编号", "下单时间", "卡带", "说明", "回收价", "闲麦价", "审核时间", "审核人", "操作", "复核时间", "复核状态"}
|
|
// title := []interface{}{"供应商编号", "供应商名称", "联系人", "手机号", "地址", "开户银行", "银行账号", "付款周期/天"}
|
|
// cell, _ := excelize.CoordinatesToCellName(1, 1)
|
|
// if err = streamWriter.SetRow(cell, title); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// var row []interface{}
|
|
// for rowId := 0; rowId < len(list); rowId++ {
|
|
// row = []interface{}{list[rowId].Number, list[rowId].Name, list[rowId].Contact,
|
|
// list[rowId].Tel, list[rowId].Address, list[rowId].OpeningBank,
|
|
// list[rowId].BankAccount, list[rowId].PaymentCycle}
|
|
// cell, _ := excelize.CoordinatesToCellName(1, rowId+2)
|
|
// if err := streamWriter.SetRow(cell, row); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// }
|
|
// if err := streamWriter.Flush(); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// if err := file.SaveAs("/www/server/images/export/" + fileName); err != nil {
|
|
// //if err := file.SaveAs("./" + fileName); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// return url + fileName, nil
|
|
//}
|
|
//
|
|
//func ErpCommodityListExport(list []ErpCommodity) (string, error) {
|
|
// file := excelize.NewFile()
|
|
// streamWriter, err := file.NewStreamWriter("Sheet1")
|
|
// if err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
//
|
|
// url := "http://39.108.188.218:8000/img/export/"
|
|
// fileName := time.Now().Format(TimeFormat) + "商品" + ".xlsx"
|
|
//
|
|
// //title := []interface{}{"供应商编号", "供应商名称", "联系人", "手机号", "地址", "开户银行", "银行账号", "付款周期/天"}
|
|
// title := []interface{}{"商品编号", "商品名称", "商品分类", "是否串码", "主供应商", "零售价", "最低零售价", "员工成本价",
|
|
// "采购价", "提成等级1", "提成等级2", "产地", "备注", "会员折扣(零售价的百分比)"}
|
|
// cell, _ := excelize.CoordinatesToCellName(1, 1)
|
|
// if err = streamWriter.SetRow(cell, title); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// var row []interface{}
|
|
// for rowId := 0; rowId < len(list); rowId++ {
|
|
// isIMEI := "否"
|
|
// if list[rowId].IMEIType == 2 {
|
|
// isIMEI = "是"
|
|
// }
|
|
//
|
|
// row = []interface{}{list[rowId].SerialNumber, list[rowId].Name, list[rowId].ErpCategoryName,
|
|
// isIMEI, list[rowId].ErpSupplierName, list[rowId].RetailPrice,
|
|
// list[rowId].MinRetailPrice, list[rowId].StaffCostPrice, list[rowId].WholesalePrice, list[rowId].Brokerage1,
|
|
// list[rowId].Brokerage2, list[rowId].Origin, list[rowId].Remark, list[rowId].MemberDiscount}
|
|
// cell, _ := excelize.CoordinatesToCellName(1, rowId+2)
|
|
// if err := streamWriter.SetRow(cell, row); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// }
|
|
// if err := streamWriter.Flush(); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// if err := file.SaveAs("/www/server/images/export/" + fileName); err != nil {
|
|
// //if err := file.SaveAs("./" + fileName); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// return url + fileName, nil
|
|
//}
|
|
//
|
|
//func ErpStoreCashierListExport(list []ErpStoreCashier) (string, error) {
|
|
// file := excelize.NewFile()
|
|
// streamWriter, err := file.NewStreamWriter("Sheet1")
|
|
// if err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
//
|
|
// url := "http://39.108.188.218:8000/img/export/"
|
|
// fileName := time.Now().Format(TimeFormat) + "支付账号" + ".xlsx"
|
|
//
|
|
// //title := []interface{}{"门店", "用户ID", "订单编号", "下单时间", "卡带", "说明", "回收价", "闲麦价", "审核时间", "审核人", "操作", "复核时间", "复核状态"}
|
|
// title := []interface{}{"所属门店", "账号名称", "银行全称", "银行账号"}
|
|
// cell, _ := excelize.CoordinatesToCellName(1, 1)
|
|
// if err = streamWriter.SetRow(cell, title); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// var row []interface{}
|
|
// for rowId := 0; rowId < len(list); rowId++ {
|
|
// row = []interface{}{list[rowId].StoreName, list[rowId].Name, list[rowId].BankName,
|
|
// list[rowId].BankAccount}
|
|
// cell, _ := excelize.CoordinatesToCellName(1, rowId+2)
|
|
// if err := streamWriter.SetRow(cell, row); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// }
|
|
// if err := streamWriter.Flush(); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// if err := file.SaveAs("/www/server/images/export/" + fileName); err != nil {
|
|
// //if err := file.SaveAs("./" + fileName); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// return url + fileName, nil
|
|
//}
|
|
//
|
|
//func ErpCategoryListExport(list []ErpCategory) (string, error) {
|
|
// file := excelize.NewFile()
|
|
// streamWriter, err := file.NewStreamWriter("Sheet1")
|
|
// if err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
//
|
|
// url := "http://39.108.188.218:8000/img/export/"
|
|
// fileName := time.Now().Format(TimeFormat) + "分类列表数据" + ".xlsx"
|
|
//
|
|
// //title := []interface{}{"门店", "用户ID", "订单编号", "下单时间", "卡带", "说明", "回收价", "闲麦价", "审核时间", "审核人", "操作", "复核时间", "复核状态"}
|
|
// title := []interface{}{"一级分类", "二级分类"}
|
|
// cell, _ := excelize.CoordinatesToCellName(1, 1)
|
|
// if err = streamWriter.SetRow(cell, title); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// rowIdx := 2
|
|
// var row []interface{}
|
|
// for rowId := 0; rowId < len(list); rowId++ {
|
|
// cats := list[rowId].SubCats
|
|
// for i := 0; i < len(cats); i++ {
|
|
// rowName := list[rowId].Name
|
|
// if i != 0 {
|
|
// rowName = ""
|
|
// }
|
|
// row = []interface{}{rowName, cats[i].Name}
|
|
// cell, _ := excelize.CoordinatesToCellName(1, rowIdx)
|
|
// if err := streamWriter.SetRow(cell, row); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// rowIdx++
|
|
// }
|
|
// }
|
|
// if err := streamWriter.Flush(); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// if err := file.SaveAs("/www/server/images/export/" + fileName); err != nil {
|
|
// //if err := file.SaveAs("./" + fileName); err != nil {
|
|
// fmt.Println(err)
|
|
// }
|
|
// return url + fileName, nil
|
|
//}
|
|
//
|
|
//type ErpStockListReq struct {
|
|
// SerialNumber string `json:"serial_number"`
|
|
// CommodityName string `json:"commodity_name"`
|
|
// ErpCategoryId uint32 `json:"erp_category_id"`
|
|
// StockType uint32 `json:"stock_type"` // 库存:1-全部 2-有库存 3-无库存
|
|
// PageNum int `json:"page_num"`
|
|
// PageSize int `json:"page_size"`
|
|
// IsExport uint32 `json:"is_export"` // 1-导出
|
|
//}
|
|
//type ErpStockListResp struct {
|
|
// List []ErpStock `json:"list"`
|
|
// Total int `json:"total"`
|
|
// PageNum int `json:"page_num"`
|
|
// PageSize int `json:"page_size"`
|
|
// ExportUrl string `json:"export_url"`
|
|
//}
|
|
//
|
|
//func (m *ErpStockListReq) List() (*ErpStockListResp, error) {
|
|
// resp := &ErpStockListResp{
|
|
// PageNum: m.PageNum,
|
|
// PageSize: m.PageSize,
|
|
// }
|
|
// page := m.PageNum - 1
|
|
// if page < 0 {
|
|
// page = 0
|
|
// }
|
|
// if m.PageSize == 0 {
|
|
// m.PageSize = 10
|
|
// }
|
|
// qs := orm.Eloquent.Table("erp_stock")
|
|
// if m.SerialNumber != "" {
|
|
// qs = qs.Where("serial_number=?", m.SerialNumber)
|
|
// }
|
|
// if m.CommodityName != "" {
|
|
// qs = qs.Where("name Like %" + m.CommodityName + "%")
|
|
// }
|
|
// if m.ErpCategoryId != 0 {
|
|
// qs = qs.Where("erp_category_id=?", m.ErpCategoryId)
|
|
// }
|
|
// if m.StockType != 0 {
|
|
// if m.StockType == 2 {
|
|
// qs = qs.Where("count>0")
|
|
// } else if m.StockType == 3 {
|
|
// qs = qs.Where("count=0")
|
|
// }
|
|
// }
|
|
// var count int64
|
|
// err := qs.Count(&count).Error
|
|
// if err != nil {
|
|
// logger.Error("count err:", err)
|
|
// return resp, err
|
|
// }
|
|
// resp.Total = int(count)/m.PageSize + 1
|
|
// var commodities []ErpStock
|
|
//
|
|
// if m.IsExport == 1 {
|
|
// err = qs.Order("id DESC").Find(&commodities).Error
|
|
// if err != nil && err != RecordNotFound {
|
|
// logger.Error("dailys err:", err)
|
|
// return resp, err
|
|
// }
|
|
//
|
|
// //listExport, err := ErpCommodityListExport(commodities)
|
|
// //if err != nil {
|
|
// // logger.Error("list export err:", err)
|
|
// //}
|
|
// //resp.ExportUrl = listExport
|
|
// } else {
|
|
// err = qs.Order("id DESC").Offset(page * m.PageSize).Limit(m.PageSize).Find(&commodities).Error
|
|
// if err != nil && err != RecordNotFound {
|
|
// logger.Error("erp commodity list err:", err)
|
|
// return resp, err
|
|
// }
|
|
// resp.List = commodities
|
|
// }
|
|
//
|
|
// return resp, nil
|
|
//}
|
|
//
|
|
//func ErpStockCommodityListSetAge(commodities []ErpStockCommodity) {
|
|
// nowTime := time.Now()
|
|
// for i, _ := range commodities {
|
|
// commodities[i].Age = uint32(nowTime.Sub(commodities[i].StockTime).Hours()) / 24
|
|
// commodities[i].AllAge = uint32(nowTime.Sub(commodities[i].FirstStockTime).Hours()) / 24
|
|
// }
|
|
//}
|