package controllers import ( "ERP_storage/Nats" "ERP_storage/Nats/NatsServer" "ERP_storage/conf" "ERP_storage/dto" "ERP_storage/logs" "ERP_storage/models/Account" "ERP_storage/models/Basic" "ERP_storage/models/Contract" "ERP_storage/models/Stock" "errors" "fmt" "math" "os" "sort" "strconv" "strings" "time" "github.com/beego/beego/v2/adapter/orm" beego "github.com/beego/beego/v2/server/web" "github.com/robfig/cron/v3" "github.com/xuri/excelize/v2" natslibs "gogs.baozhida.cn/zoie/ERP_libs/Nats" userlibs "gogs.baozhida.cn/zoie/ERP_libs/User" "gogs.baozhida.cn/zoie/ERP_libs/lib" ) type StockController struct { beego.Controller User userlibs.User } func (c *StockController) Prepare() { c.User = *Account.User_r } func (c *StockController) Device_List() { // 分页参数 初始化 page, _ := c.GetInt("page") if page < 1 { page = 1 } page_z, _ := c.GetInt("page_z") if page_z < 1 { page_z = conf.Page_size } T_state, _ := c.GetInt("T_state") T_name := c.GetString("T_name") T_product_name := c.GetString("T_product_name") // 产品名称 T_product_model := c.GetString("T_product_model") // 产品型号 DeviceDao := Stock.NewDevice(orm.NewOrm()) R_List, R_cnt := DeviceDao.Read_Device_List(T_name, T_product_name, T_product_model, T_state, page, page_z) var r_jsons lib.R_JSONS r_jsons.Num = R_cnt r_jsons.Data = R_List r_jsons.Page = page r_jsons.Page_size = int(math.Ceil(float64(R_cnt) / float64(page_z))) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } func (c *StockController) Device_Excel() { T_state, _ := c.GetInt("T_state") T_name := c.GetString("T_name") T_product_name := c.GetString("T_product_name") // 产品名称 T_product_model := c.GetString("T_product_model") // 产品型号 DeviceDao := Stock.NewDevice(orm.NewOrm()) R_List, _ := DeviceDao.Read_Device_List(T_name, T_product_name, T_product_model, T_state, 0, 9999) // 生成Excel文件名 filename := fmt.Sprintf("设备列表(%s)", lib.GetRandstring(6, "0123456789", 0)) // 创建Excel文件 f := excelize.NewFile() // 设置样式 Style1, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 14, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"}, }) Style2, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 10, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) Style3, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 10, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) // 设置工作表名称 f.SetSheetName("Sheet1", "设备列表") // 设置标题 f.MergeCell("设备列表", "A1", "M1") f.SetRowStyle("设备列表", 1, 1, Style1) f.SetCellValue("设备列表", "A1", "宝智达科技设备列表") f.SetRowHeight("设备列表", 1, 30) // 设置表头 f.SetCellStyle("设备列表", "A2", "M2", Style2) f.SetRowHeight("设备列表", 2, 20) // 设置表头内容 f.SetCellValue("设备列表", "A2", "序号") f.SetCellValue("设备列表", "B2", "合同编号") f.SetCellValue("设备列表", "C2", "出库单号") f.SetCellValue("设备列表", "D2", "关联项目") f.SetCellValue("设备列表", "E2", "产品名称") f.SetCellValue("设备列表", "F2", "产品分类") f.SetCellValue("设备列表", "G2", "产品型号") f.SetCellValue("设备列表", "H2", "产品规格") f.SetCellValue("设备列表", "I2", "设备SN") f.SetCellValue("设备列表", "J2", "模组imei") f.SetCellValue("设备列表", "K2", "物联网卡号") f.SetCellValue("设备列表", "L2", "设备编号") f.SetCellValue("设备列表", "M2", "状态") // 设置列宽 f.SetColWidth("设备列表", "A", "A", 8) // 序号 f.SetColWidth("设备列表", "B", "B", 15) // 合同编号 f.SetColWidth("设备列表", "C", "C", 15) // 出库单号 f.SetColWidth("设备列表", "D", "D", 20) // 关联项目 f.SetColWidth("设备列表", "E", "E", 20) // 产品名称 f.SetColWidth("设备列表", "F", "F", 15) // 产品分类 f.SetColWidth("设备列表", "G", "G", 15) // 产品型号 f.SetColWidth("设备列表", "H", "H", 15) // 产品规格 f.SetColWidth("设备列表", "I", "I", 20) // 设备SN f.SetColWidth("设备列表", "J", "J", 15) // 模组imei f.SetColWidth("设备列表", "K", "K", 20) // 物联网卡号 f.SetColWidth("设备列表", "L", "L", 18) // 设备编号 f.SetColWidth("设备列表", "M", "M", 10) // 状态 // 填充数据 for i, device := range R_List { row := i + 3 // 从第3行开始填充数据 // 状态转换 stateText := "未出库" if device.T_State == 1 { stateText = "已出库" } f.SetCellStyle("设备列表", fmt.Sprintf("A%d", row), fmt.Sprintf("M%d", row), Style3) //f.SetRowHeight("设备列表", row, 20) f.SetCellValue("设备列表", fmt.Sprintf("A%d", row), i+1) // 序号 f.SetCellValue("设备列表", fmt.Sprintf("B%d", row), device.T_contract_number) // 合同编号 f.SetCellValue("设备列表", fmt.Sprintf("C%d", row), device.T_out_number) // 出库单号 f.SetCellValue("设备列表", fmt.Sprintf("D%d", row), device.T_project) // 关联项目 f.SetCellValue("设备列表", fmt.Sprintf("E%d", row), device.T_product_name) // 产品名称 f.SetCellValue("设备列表", fmt.Sprintf("F%d", row), device.T_product_class_name) // 产品分类 f.SetCellValue("设备列表", fmt.Sprintf("G%d", row), device.T_product_model) // 产品型号 f.SetCellValue("设备列表", fmt.Sprintf("H%d", row), device.T_product_spec) // 产品规格 f.SetCellValue("设备列表", fmt.Sprintf("I%d", row), device.T_sn) // 设备SN f.SetCellValue("设备列表", fmt.Sprintf("J%d", row), device.T_imei) // 模组imei f.SetCellValue("设备列表", fmt.Sprintf("K%d", row), device.T_iccid) // 物联网卡号 f.SetCellValue("设备列表", fmt.Sprintf("L%d", row), device.T_device_number) // 设备编号 f.SetCellValue("设备列表", fmt.Sprintf("M%d", row), stateText) // 状态 } // 保存文件 if err := f.SaveAs("ofile/" + filename + ".xlsx"); err != nil { fmt.Println(err) } var url string //// 上传 OSS nats := natslibs.NewNats(Nats.Nats, conf.NatsSubj_Prefix) url, is := nats.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+filename+".xlsx", "ofile/"+filename+".xlsx") if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "oss!"} c.ServeJSON() return } //删除目录 err := os.Remove("ofile/" + filename + ".xlsx") if err != nil { logs.Error(lib.FuncName(), err) } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url} c.ServeJSON() return } func (c *StockController) Device_Check() { T_sn := c.GetString("T_sn") T_type, _ := c.GetInt("T_type") //1-出库 2-入库 T_product_id, _ := c.GetInt("T_product_id") T_date := c.GetString("T_date") // 检查MQTT授权 //mqtt := Stock.Read_MqttUser(T_sn) //if len(mqtt.Username) == 0 { // c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("【%s】未授权，请先授权！", T_sn)} // c.ServeJSON() // return //} DeviceDao := Stock.NewDevice(orm.NewOrm()) date, is := lib.DateStrToTime(T_date) if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "日期格式错误!"} c.ServeJSON() return } checkTime := date.Format("2006-01-02") + time.Now().Format(" 15:04:05") // T_State 1-已出库 2-未出库/入库 // 查询checkTime时间前最后一条记录 lastBeforeCheckTime, errBefore := DeviceDao.Read_Device_LastBeforeCheckTime(T_sn, checkTime) // 查询checkTime时间后第一条记录 firstAfterCheckTime, errAfter := DeviceDao.Read_Device_FirstAfterCheckTime(T_sn, checkTime) // 如果是入库操作 if T_type == 2 { // 根据表格逻辑判断： // 1. 时间前无数据，时间后有入库记录 if (errBefore != nil || lastBeforeCheckTime.Id == 0) && errAfter == nil && firstAfterCheckTime.T_State == 2 && len(firstAfterCheckTime.T_in_number) > 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("【%s】已入库，请勿重复提交！", T_sn)} c.ServeJSON() return } // 2. 时间前已入库 if errBefore == nil && lastBeforeCheckTime.T_State == 2 && len(lastBeforeCheckTime.T_in_number) > 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("【%s】已入库，请勿重复提交！", T_sn)} c.ServeJSON() return } // 3. 时间前已出库，时间后有入库记录 if errBefore == nil && lastBeforeCheckTime.T_State == 1 && len(lastBeforeCheckTime.T_out_number) > 0 && errAfter == nil && firstAfterCheckTime.T_State == 2 && len(firstAfterCheckTime.T_in_number) > 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("【%s】已入库，请勿重复提交！", T_sn)} c.ServeJSON() return } } // 如果是出库操作 if T_type == 1 { // 根据表格逻辑判断： // 1. 时间前无数据 -> 未入库 if errBefore != nil || lastBeforeCheckTime.Id == 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("【%s】未入库，请先入库！", T_sn)} c.ServeJSON() return } // 2. 时间前已入库，时间后有出库记录 if lastBeforeCheckTime.T_State == 2 && len(lastBeforeCheckTime.T_in_number) > 0 && errAfter == nil && firstAfterCheckTime.T_State == 1 && len(firstAfterCheckTime.T_out_number) > 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("【%s】已出库，请勿重复提交！", T_sn)} c.ServeJSON() return } // 3. 时间前已出库 if lastBeforeCheckTime.T_State == 1 && len(lastBeforeCheckTime.T_out_number) > 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("【%s】已出库，请勿重复提交！", T_sn)} c.ServeJSON() return } // 检查产品是否一致 if lastBeforeCheckTime.T_product_id != T_product_id { c.Data["json"] = lib.JSONS{Code: 202, Msg: "入库产品与出库产品不一致，请检查！"} c.ServeJSON() return } } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"} c.ServeJSON() return } func (c *StockController) Device_Take_Stock() { T_product_name := c.GetString("T_product_name") // 产品名称 T_product_model := c.GetString("T_product_model") // 产品型号 T_sn_list := c.GetString("T_sn_list") // sn列表 DeviceDao := Stock.NewDevice(orm.NewOrm()) // 获取库存中的所有设备（如果有产品名称和型号过滤） R_List, _ := DeviceDao.Read_Device_List("", T_product_name, T_product_model, 0, 0, 9999) // 创建设备SN到设备信息的映射，用于快速查找 deviceMap := make(map[string]Stock.Device_R) // 保存在库设备列表 var inStockDevices []Stock.Device_R for _, device := range R_List { deviceMap[device.T_sn] = device // 收集所有在库设备（状态为2） if device.T_State == 2 { inStockDevices = append(inStockDevices, device) } } // 创建结果数据结构 type DeviceCheckResult struct { T_sn string `json:"t_sn"` // 设备SN T_exists bool `json:"t_exists"` // 是否存在于库存 T_state int `json:"t_state"` // 设备状态：1-已出库 2-未出库/入库 T_state_desc string `json:"t_state_desc"` // 状态描述 T_product_id int `json:"t_product_id"` // 产品ID T_product_name string `json:"t_product_name"` // 产品名称 T_product_model string `json:"t_product_model"` // 产品型号 T_iccid string `json:"t_iccid"` // SIM卡号 T_imei string `json:"t_imei"` // 模组IMEI T_in_number string `json:"t_in_number"` // 入库编号 T_out_number string `json:"t_out_number"` // 出库编号 T_from_input bool `json:"t_from_input"` // 是否来自输入列表 } // 处理每个输入的SN var results []DeviceCheckResult var processedSNs = make(map[string]bool) // 用于跟踪已处理的SN // 解析输入的SN列表（如果有） var snList []string if len(T_sn_list) > 0 { snList = lib.SplitString(T_sn_list, ",") for _, sn := range snList { sn = strings.TrimSpace(sn) if len(sn) == 0 { continue } result := DeviceCheckResult{ T_sn: sn, T_exists: false, T_from_input: true, // 标记为来自输入列表 } // 检查设备是否存在于库存 if device, exists := deviceMap[sn]; exists { result.T_exists = true result.T_state = device.T_State result.T_product_id = device.T_product_id result.T_product_name = device.T_product_name result.T_product_model = device.T_product_model result.T_iccid = device.T_iccid result.T_imei = device.T_imei result.T_in_number = device.T_in_number result.T_out_number = device.T_out_number // 设置状态描述 if device.T_State == 1 { result.T_state_desc = "已出库" } else if device.T_State == 2 { result.T_state_desc = "在库" } else { result.T_state_desc = "未知状态" } } else { // 设备不存在于库存 result.T_state_desc = "未入库" } results = append(results, result) processedSNs[sn] = true } } // 添加所有在库设备（如果还没有处理过） for _, device := range inStockDevices { // 如果这个SN已经处理过（来自输入列表），则跳过 if _, processed := processedSNs[device.T_sn]; processed { continue } result := DeviceCheckResult{ T_sn: device.T_sn, T_exists: true, T_state: device.T_State, T_state_desc: "在库", T_product_id: device.T_product_id, T_product_name: device.T_product_name, T_product_model: device.T_product_model, T_iccid: device.T_iccid, T_imei: device.T_imei, T_in_number: device.T_in_number, T_out_number: device.T_out_number, T_from_input: false, // 标记为不是来自输入列表 } results = append(results, result) } // 统计结果 totalInputCount := 0 existsCount := 0 inStockCount := 0 outStockCount := 0 notExistsCount := 0 for _, result := range results { if result.T_from_input { totalInputCount++ if result.T_exists { existsCount++ if result.T_state == 2 { inStockCount++ } else if result.T_state == 1 { outStockCount++ } } else { notExistsCount++ } } } // 组装返回数据 r_jsons := map[string]interface{}{ "devices": results, "stats": map[string]interface{}{ "total_input": totalInputCount, "exists": existsCount, "in_stock": inStockCount, "out_stock": outStockCount, "not_exists": notExistsCount, "total_in_stock": len(inStockDevices), }, } c.Data["json"] = lib.JSONS{Code: 200, Msg: "盘点完成", Data: r_jsons} c.ServeJSON() return } func (c *StockController) Stock_List() { // 分页参数 初始化 page, _ := c.GetInt("page") if page < 1 { page = 1 } page_z, _ := c.GetInt("page_z") if page_z < 1 { page_z = conf.Page_size } // 查询 T_depot_id, _ := c.GetInt("T_depot_id") // 查询 T_product_name := c.GetString("T_product_name") T_product_model := c.GetString("T_product_model") T_product_class, _ := c.GetInt("T_product_class") userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() StockDao := Stock.NewStock(orm.NewOrm()) R_List, R_cnt := StockDao.Read_Stock_List(T_depot_id, T_product_class, T_product_name, T_product_model, page, page_z) var r_jsons lib.R_JSONS r_jsons.Num = R_cnt r_jsons.Data = R_List r_jsons.Page = page r_jsons.Page_size = int(math.Ceil(float64(R_cnt) / float64(page_z))) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } // 修改库存排序 func (c *StockController) Stock_Edit_Sort() { T_id, _ := c.GetInt("T_id") T_sort, _ := c.GetInt("T_sort") StockDao := Stock.NewStock(orm.NewOrm()) Stock_r, err := StockDao.Read_Stock_ById(T_id) if err != nil { c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_id Err!"} c.ServeJSON() return } Stock_r.T_sort = T_sort if err = StockDao.Update_Stock(Stock_r, "T_sort"); err != nil { c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改失败"} c.ServeJSON() return } NatsServer.AddUserLogs(c.User.T_uuid, "库存", "修改", Stock_r) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"} c.ServeJSON() return } func (c *StockController) Stock_Detail_List() { // 查询 T_depot_id, _ := c.GetInt("T_depot_id") // 查询 T_product_id, _ := c.GetInt("T_product_id") T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") now := time.Now() if len(T_start_date) == 0 { T_start_date = time.Date(now.Year(), 1, 1, 0, 0, 0, 0, time.Local).Format("2006-01") } else { T_start_date_t, _ := lib.DateStrToTime(T_start_date) T_start_date = T_start_date_t.Format("2006-01") } if len(T_end_date) == 0 { T_end_date = now.Format("2006-01") } else { T_end_date_t, _ := lib.DateStrToTime(T_end_date) T_end_date = T_end_date_t.Format("2006-01") } StockOutDao := Stock.NewStockOut(orm.NewOrm()) StockMonthDao := Stock.NewStockMonth(orm.NewOrm()) R_List := StockMonthDao.Read_StockMonth_List(T_depot_id, T_product_id, 0, T_start_date, T_end_date) for i := 0; i < len(R_List); i++ { R_List[i].T_project = strings.Join(StockOutDao.Read_StockOut_T_project(T_depot_id, R_List[i].T_product_id, R_List[i].T_month), "|") } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: R_List} c.ServeJSON() return } func (c *StockController) Stock_Detail_Excel() { // 查询 T_depot_id, _ := c.GetInt("T_depot_id") T_product_id, _ := c.GetInt("T_product_id") // 查询 T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") now := time.Now() if len(T_start_date) == 0 { T_start_date = time.Date(now.Year(), 1, 1, 0, 0, 0, 0, time.Local).Format("2006-01") } else { T_start_date_t, _ := lib.DateStrToTime(T_start_date) T_start_date = T_start_date_t.Format("2006-01") } if len(T_end_date) == 0 { T_end_date = now.Format("2006-01") } else { T_end_date_t, _ := lib.DateStrToTime(T_end_date) T_end_date = T_end_date_t.Format("2006-01") } var class_List []Basic.ProductClass_R filename := fmt.Sprintf("进销存(%s)", lib.GetRandstring(6, "0123456789", 0)) if T_product_id > 0 { product, _ := Basic.Read_Product_ById(T_product_id) filename = fmt.Sprintf("进销存-%s明细(%s)", product.T_name, lib.GetRandstring(6, "0123456789", 0)) class, _ := Basic.Read_ProductClass_ById(product.T_class) class_List = append(class_List, Basic.ProductClassToProductClass_R(class)) } else { class_List, _ = Basic.Read_ProductClass_List("", 0, 0, 9999) } f := excelize.NewFile() // 设置单元格的值 Style1, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 12, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"}, }) Style2, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 10, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) Style3, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 10, Family: "宋体", Color: "FF0000"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) Style4, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 10, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) StockMonthDao := Stock.NewStockMonth(orm.NewOrm()) StockOutDao := Stock.NewStockOut(orm.NewOrm()) var j = 0 for _, r := range class_List { StockList := StockMonthDao.Read_StockMonth_List(T_depot_id, T_product_id, r.Id, T_start_date, T_end_date) if len(StockList) == 0 { continue } if j == 0 { f.SetSheetName("Sheet1", r.T_name) } else { f.NewSheet(r.T_name) } j += 1 f.MergeCell(r.T_name, "A1", "K1") f.SetRowStyle(r.T_name, 1, 1, Style1) f.SetCellValue(r.T_name, "A1", fmt.Sprintf("宝智达科技产品进销存统计表")) f.SetRowHeight(r.T_name, 1, 30) // 这里设置表头 f.SetCellStyle(r.T_name, "A2", "K2", Style2) f.SetRowHeight(r.T_name, 2, 20) f.SetCellValue(r.T_name, "A2", "序号") f.SetCellValue(r.T_name, "B2", "产品名称") f.SetCellValue(r.T_name, "C2", "型号") f.SetCellValue(r.T_name, "D2", "规格") f.SetCellValue(r.T_name, "E2", "月份") f.SetCellValue(r.T_name, "F2", "期初库存") f.SetCellValue(r.T_name, "G2", "当月入库(正常生产新购入库产品)") f.SetCellValue(r.T_name, "H2", "退货入库(退还重新入库产品)") f.SetCellValue(r.T_name, "I2", "当月出库") f.SetCellValue(r.T_name, "J2", "期末库存") f.SetCellValue(r.T_name, "K2", "出库项目") //f.SetCellValue(r.T_name, "K2", "备注") // 设置列宽 f.SetColWidth(r.T_name, "A", "A", 10) f.SetColWidth(r.T_name, "B", "B", 10) f.SetColWidth(r.T_name, "C", "D", 10) f.SetColWidth(r.T_name, "D", "D", 10) f.SetColWidth(r.T_name, "E", "E", 10) f.SetColWidth(r.T_name, "F", "F", 10) f.SetColWidth(r.T_name, "G", "G", 10) f.SetColWidth(r.T_name, "H", "H", 10) f.SetColWidth(r.T_name, "I", "I", 10) f.SetColWidth(r.T_name, "J", "J", 10) f.SetColWidth(r.T_name, "K", "K", 70) //f.SetColWidth(r.T_name, "K", "K", 10) line := 2 // 循环写入数据 for _, v := range StockList { line++ product, _ := Basic.Read_Product_ById(v.T_product_id) f.SetCellValue(r.T_name, fmt.Sprintf("A%d", line), line-2) f.SetCellValue(r.T_name, fmt.Sprintf("B%d", line), product.T_name) f.SetCellValue(r.T_name, fmt.Sprintf("C%d", line), product.T_model) f.SetCellValue(r.T_name, fmt.Sprintf("D%d", line), product.T_spec) f.SetCellValue(r.T_name, fmt.Sprintf("E%d", line), v.T_month) f.SetCellValue(r.T_name, fmt.Sprintf("F%d", line), v.T_beginning) f.SetCellValue(r.T_name, fmt.Sprintf("G%d", line), v.T_in) f.SetCellValue(r.T_name, fmt.Sprintf("H%d", line), v.T_return) f.SetCellValue(r.T_name, fmt.Sprintf("I%d", line), v.T_out) f.SetCellValue(r.T_name, fmt.Sprintf("J%d", line), v.T_ending) if product.T_early_warning > v.T_ending { f.SetCellStyle(r.T_name, fmt.Sprintf("J%d", line), fmt.Sprintf("J%d", line), Style3) } else { f.SetCellStyle(r.T_name, fmt.Sprintf("J%d", line), fmt.Sprintf("J%d", line), Style4) } T_project := StockOutDao.Read_StockOut_T_project(T_depot_id, product.Id, v.T_month) //f.SetCellValue(r.T_name, fmt.Sprintf("J%d", line), v.T_project) f.SetCellValue(r.T_name, fmt.Sprintf("K%d", line), strings.Join(T_project, "\r\n")) } f.SetCellStyle(r.T_name, "A2", fmt.Sprintf("I%d", line), Style4) Style5, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 10, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "left", Vertical: "center", WrapText: true}, 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}, }, }) f.SetCellStyle(r.T_name, "K2", fmt.Sprintf("K%d", line), Style5) } // 保存文件 if err := f.SaveAs("ofile/" + filename + ".xlsx"); err != nil { fmt.Println(err) } var url string //// 上传 OSS nats := natslibs.NewNats(Nats.Nats, conf.NatsSubj_Prefix) url, is := nats.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+filename+".xlsx", "ofile/"+filename+".xlsx") if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "oss!"} c.ServeJSON() return } //删除目录 err := os.Remove("ofile/" + filename + ".xlsx") if err != nil { logs.Error(lib.FuncName(), err) } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url} c.ServeJSON() return } func (c *StockController) StockIn_List() { // 分页参数 初始化 page, _ := c.GetInt("page") if page < 1 { page = 1 } page_z, _ := c.GetInt("page_z") if page_z < 1 { page_z = conf.Page_size } // 查询 T_depot_id, _ := c.GetInt("T_depot_id") T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") T_name := c.GetString("T_name") T_batch_number := c.GetString("T_batch_number") userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() StockInDao := Stock.NewStockIn(orm.NewOrm()) R_List, R_cnt := StockInDao.Read_StockIn_List(T_batch_number, T_name, T_depot_id, T_start_date, T_end_date, page, page_z) var r_jsons lib.R_JSONS r_jsons.Num = R_cnt r_jsons.Data = R_List r_jsons.Page = page r_jsons.Page_size = int(math.Ceil(float64(R_cnt) / float64(page_z))) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } func (c *StockController) StockIn_List_Product() { // 分页参数 初始化 page, _ := c.GetInt("page") if page < 1 { page = 1 } page_z, _ := c.GetInt("page_z") if page_z < 1 { page_z = conf.Page_size } // 查询 T_depot_id, _ := c.GetInt("T_depot_id") T_name := c.GetString("T_name") T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") T_product_name := c.GetString("T_product_name") // 产品名称 T_product_model := c.GetString("T_product_model") // 产品型号 userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() StockInDao := Stock.NewStockIn(orm.NewOrm()) R_List, R_cnt := StockInDao.Read_StockInProduct_List(T_name, T_start_date, T_end_date, T_depot_id, T_product_name, T_product_model, page, page_z) var r_jsons lib.R_JSONS r_jsons.Num = R_cnt r_jsons.Data = R_List r_jsons.Page = page r_jsons.Page_size = int(math.Ceil(float64(R_cnt) / float64(page_z))) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } func (c *StockController) StockIn_List_Product_Excel() { // 查询 T_depot_id, _ := c.GetInt("T_depot_id") T_name := c.GetString("T_name") T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") T_product_name := c.GetString("T_product_name") // 产品名称 T_product_model := c.GetString("T_product_model") // 产品型号 userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() StockInDao := Stock.NewStockIn(orm.NewOrm()) R_List, _ := StockInDao.Read_StockInProduct_List(T_name, T_start_date, T_end_date, T_depot_id, T_product_name, T_product_model, 0, 9999) filename := fmt.Sprintf("入库明细单(%s)", lib.GetRandstring(6, "0123456789", 0)) f := excelize.NewFile() // 设置单元格的值 Style1, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 12, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"}, }) Style2, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 11, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"}, 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}, }, }) Style3, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 11, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "left", Vertical: "center", WrapText: true}, 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}, }, }) f.MergeCell("Sheet1", "A1", "L1") f.SetRowStyle("Sheet1", 1, 1, Style1) f.SetCellValue("Sheet1", "A1", fmt.Sprintf("入库明细单")) f.SetRowHeight("Sheet1", 1, 30) // 这里设置表头 f.SetCellStyle("Sheet1", "A2", "L2", Style2) f.SetRowHeight("Sheet1", 2, 20) f.SetCellValue("Sheet1", "A2", "序号") f.SetCellValue("Sheet1", "B2", "入库单号") f.SetCellValue("Sheet1", "C2", "经办人") f.SetCellValue("Sheet1", "D2", "入库日期") f.SetCellValue("Sheet1", "E2", "入库仓库") f.SetCellValue("Sheet1", "F2", "入库类型") f.SetCellValue("Sheet1", "G2", "产品名称") f.SetCellValue("Sheet1", "H2", "产品型号") f.SetCellValue("Sheet1", "I2", "数量") f.SetCellValue("Sheet1", "J2", "是否关联SN") f.SetCellValue("Sheet1", "K2", "备注") f.SetCellValue("Sheet1", "L2", "SN") // 设置列宽 f.SetColWidth("Sheet1", "A", "A", 10) f.SetColWidth("Sheet1", "B", "B", 15) f.SetColWidth("Sheet1", "C", "D", 10) f.SetColWidth("Sheet1", "D", "D", 10) f.SetColWidth("Sheet1", "E", "E", 10) f.SetColWidth("Sheet1", "F", "F", 10) f.SetColWidth("Sheet1", "G", "G", 20) f.SetColWidth("Sheet1", "H", "H", 15) f.SetColWidth("Sheet1", "I", "I", 10) f.SetColWidth("Sheet1", "J", "J", 12) f.SetColWidth("Sheet1", "K", "K", 30) f.SetColWidth("Sheet1", "L", "L", 100) line := 2 for _, product := range R_List { line += 1 f.SetCellValue("Sheet1", fmt.Sprintf("A%d", line), line-2) f.SetCellValue("Sheet1", fmt.Sprintf("B%d", line), product.T_number) f.SetCellValue("Sheet1", fmt.Sprintf("C%d", line), product.T_submit_name) f.SetCellValue("Sheet1", fmt.Sprintf("D%d", line), product.T_date) f.SetCellValue("Sheet1", fmt.Sprintf("E%d", line), product.T_depot_name) var type_str string if product.T_type == 1 { type_str = "入库" } else { type_str = "退库" } f.SetCellValue("Sheet1", fmt.Sprintf("F%d", line), type_str) f.SetCellValue("Sheet1", fmt.Sprintf("G%d", line), product.T_product_name) f.SetCellValue("Sheet1", fmt.Sprintf("H%d", line), product.T_product_model) f.SetCellValue("Sheet1", fmt.Sprintf("I%d", line), product.T_num) var relation_sn string if product.T_product_relation_sn == 1 { relation_sn = "是" } else { relation_sn = "否" } f.SetCellValue("Sheet1", fmt.Sprintf("J%d", line), relation_sn) f.SetCellValue("Sheet1", fmt.Sprintf("K%d", line), product.T_remark) f.SetCellValue("Sheet1", fmt.Sprintf("L%d", line), product.T_relation_sn) } f.SetCellStyle("Sheet1", "A3", fmt.Sprintf("L%d", line), Style3) // 保存文件 if err := f.SaveAs("ofile/" + filename + ".xlsx"); err != nil { fmt.Println(err) } var url string //// 上传 OSS nats := natslibs.NewNats(Nats.Nats, conf.NatsSubj_Prefix) url, is := nats.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+filename+".xlsx", "ofile/"+filename+".xlsx") if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "oss!"} c.ServeJSON() return } //删除目录 err := os.Remove("ofile/" + filename + ".xlsx") if err != nil { logs.Error(lib.FuncName(), err) } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url} c.ServeJSON() return } func (c *StockController) StockIn_Get() { // 查询 T_number := c.GetString("T_number") o := orm.NewOrm() StockInDao := Stock.NewStockIn(o) StockInProductDao := Stock.NewStockInProduct(o) stockIn, err := StockInDao.Read_StockIn_ByT_number(T_number) if err != nil { c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } productList := StockInProductDao.Read_StockInProduct_List_ByT_number(stockIn.T_number) var pList []Stock.StockInProduct_R for _, v := range productList { pList = append(pList, Stock.StockInProductToStockInProduct_R(v)) } userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Stock.StockInToStockIn_Detail(stockIn, pList)} c.ServeJSON() return } func (c *StockController) StockIn_generate_number() { StockOutDao := Stock.NewStockOut(orm.NewOrm()) rand_x := 0 T_number := "" for true { T_number = "RK-" + lib.GetRandstring(8, "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789", int64(rand_x)) _, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err != nil && err.Error() == orm.ErrNoRows.Error() { break } rand_x += 1 } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } func (c *StockController) StockIn_Add() { o := orm.NewOrm() o.Begin() StockInDao := Stock.NewStockIn(o) T_number := c.GetString("T_number") // 检查前端传入的T_number是否已提交过 _, err := StockInDao.Read_StockIn_ByT_number(T_number) if err != nil && err.Error() != orm.ErrNoRows.Error() { // 数据库查询错误 o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "查询入库编号失败"} c.ServeJSON() return } if err == nil { // 入库编号已存在，不需要做任何处理 o.Rollback() c.Data["json"] = lib.JSONS{Code: 200, Msg: "入库编号已存在，无需重复提交!", Data: T_number} c.ServeJSON() return } T_depot_id, _ := c.GetInt("T_depot_id") T_type, _ := c.GetInt("T_type") // 1-入库 2-退库 T_date := c.GetString("T_date") T_product := c.GetString("T_product") T_remark := c.GetString("T_remark") T_project := c.GetString("T_project") T_return_user := c.GetString("T_return_user") T_batch_number := c.GetString("T_batch_number") T_company_name := c.GetString("T_company_name") date, is := lib.DateStrToTime(T_date) if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "日期格式错误!"} c.ServeJSON() return } if T_type == 2 && len(T_project) == 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: "退库时，项目不能为空!"} c.ServeJSON() return } NatsServer.AddUserLogs(c.User.T_uuid, "仓库管理", "入库", T_product) var_ := Stock.StockIn{ T_number: T_number, T_depot_id: T_depot_id, T_type: T_type, T_date: T_date, T_remark: T_remark, T_submit: c.User.T_uuid, T_project: T_project, T_return_user: T_return_user, T_batch_number: T_batch_number, T_state: Stock.StockInWarehouse, T_warehouse: c.User.T_uuid, T_company_name: T_company_name, } StockInProductDao := Stock.NewStockInProduct(o) StockDao := Stock.NewStock(o) DeviceDao := Stock.NewDevice(o) _, err = StockInDao.Add_StockIn(var_) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "入库失败"} c.ServeJSON() return } if len(T_product) == 0 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "产品明细不能为空"} c.ServeJSON() return } productList := lib.SplitString(T_product, "|") allProductList := []int{} for _, v := range productList { product_id, _ := strconv.Atoi(strings.Split(v, "-")[0]) allProductList = append(allProductList, product_id) product, _ := Basic.Read_Product_ById(product_id) num, _ := strconv.Atoi(strings.Split(v, "-")[1]) T_relation_sn := strings.Split(v, "-")[2] if T_relation_sn == "" && product.T_relation_sn == 1 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s关联SN，请先添加SN！", product.T_name)} c.ServeJSON() return } if len(T_relation_sn) > 0 { snList := strings.Split(strings.Trim(T_relation_sn, ","), ",") num = len(snList) for _, sn := range snList { mqtt := Stock.Read_MqttUser(sn) // 添加设备 device := Stock.Device{ T_contract_number: "", T_out_number: "", T_product_id: product_id, T_in_number: T_number, T_sn: sn, T_iccid: mqtt.Iccid, T_imei: mqtt.Imei, T_State: 2, T_batch_number: T_batch_number, CreateTime: date, } _, err = DeviceDao.AddOrUpdate_Device(device, 2) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: sn + "入库失败"} c.ServeJSON() return } } } stockInProduct := Stock.StockInProduct{ T_number: T_number, T_product_id: product_id, T_depot_id: T_depot_id, T_num: num, // 入库数量 T_date: T_date, // 入库日期 T_relation_sn: T_relation_sn, T_batch_number: T_batch_number, } _, err = StockInProductDao.Add_StockInProduct(stockInProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "入库失败"} c.ServeJSON() return } _, err = StockDao.AddOrUpdate_Stock(T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, num, 2) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "入库失败"} c.ServeJSON() return } } // 批量更新所有相关设备的批次号 err = DeviceDao.Update_Device_BatchNumber_ByInNumber(T_number, T_batch_number) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "更新设备批次号失败"} c.ServeJSON() return } o.Commit() StockIn_Edit_StockMonth(T_date, T_depot_id, allProductList) NatsServer.AddUserLogs(c.User.T_uuid, "入库", "入库", var_) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } func StockIn_Edit_StockMonth(T_date string, T_depot_id int, allProductList []int) error { if len(T_date) == 0 { return errors.New("日期不能为空") } date, _ := lib.DateStrToTime(T_date) //if date.Year() == time.Now().Year() && date.Month() == time.Now().Month() { // // 修改本月数据不同步库存 // return nil //} //T_month := date.Format("2006-01") months := generateMonthList(date, "in") o := orm.NewOrm() StockOutDao := Stock.NewStockOut(o) StockMonthDao := Stock.NewStockMonth(o) StockOutProductDao := Stock.NewStockOutProduct(o) StockInProductDao := Stock.NewStockInProduct(o) for _, T_product_id := range allProductList { for _, T_month := range months { // 获取当前产品本月出入库数量 lastMonth := StockMonthDao.Read_LastMonth_StockMonth_ByT_depot_id_T_product_id(T_depot_id, T_product_id, T_month) stockMonth := StockMonthDao.Read_StockMonth_ByT_depot_id_T_product_id(T_depot_id, T_product_id, T_month) if stockMonth.Id > 0 { // 修改 stockMonth.T_in = StockInProductDao.Read_StockIn_Total(T_depot_id, T_product_id, T_month) stockMonth.T_return = StockInProductDao.Read_StockReturn_Total(T_depot_id, T_product_id, T_month) if len(lastMonth) > 0 { stockMonth.T_beginning = lastMonth[0].T_ending } else { stockMonth.T_beginning = 0 } // 期末库存 = 期初库存+入库-出库 stockMonth.T_ending = stockMonth.T_beginning + stockMonth.T_in - stockMonth.T_out err := StockMonthDao.Update_StockMonth(stockMonth, "T_in", "T_return", "T_beginning", "T_ending") if err != nil { return err } } else { product, _ := Basic.Read_Product_ById(T_product_id) // 添加库存记录 stockMonth = Stock.StockMonth{ T_depot_id: T_depot_id, T_product_id: T_product_id, T_product_class: product.T_class, T_month: T_month, } // 获取当前产品本月出入库数量 stockMonth.T_in = StockInProductDao.Read_StockIn_Total(T_depot_id, T_product_id, T_month) stockMonth.T_out = StockOutProductDao.Read_StockOut_Total(T_depot_id, T_product_id, T_month) stockMonth.T_return = StockInProductDao.Read_StockReturn_Total(T_depot_id, T_product_id, T_month) if len(lastMonth) > 0 { stockMonth.T_beginning = lastMonth[0].T_ending } else { stockMonth.T_beginning = 0 } // 期末库存 = 期初库存+入库-出库 stockMonth.T_ending = stockMonth.T_beginning + stockMonth.T_in - stockMonth.T_out stockMonth.T_project = StockOutDao.Read_StockOut_T_contract_number(T_depot_id, T_product_id, T_month) _, err := StockMonthDao.Add_StockMonth(stockMonth) if err != nil { return err } } } } return nil } func (c *StockController) StockIn_Edit() { T_number := c.GetString("T_number") // 入库单号 //T_depot_id, _ := c.GetInt("T_depot_id") T_date := c.GetString("T_date") T_product := c.GetString("T_product") T_remark := c.GetString("T_remark") T_project := c.GetString("T_project") T_return_user := c.GetString("T_return_user") T_batch_number := c.GetString("T_batch_number") T_company_name := c.GetString("T_company_name") date, is := lib.DateStrToTime(T_date) if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "日期格式错误!"} c.ServeJSON() return } if date.Year() != time.Now().Year() && date.Month() != time.Now().Month() { T_date = "" } NatsServer.AddUserLogs(c.User.T_uuid, "仓库管理", "修改入库", T_product) o := orm.NewOrm() o.Begin() StockInDao := Stock.NewStockIn(o) StockInProductDao := Stock.NewStockInProduct(o) StockDao := Stock.NewStock(o) DeviceDao := Stock.NewDevice(o) // 查询入库信息 stockIn, err := StockInDao.Read_StockIn_ByT_number(T_number) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } T_old_date := stockIn.T_date // 查询入库产品信息 productOldList := StockInProductDao.Read_StockInProduct_List_ByT_number(stockIn.T_number) var oldProductList []dto.StockProduct var newProductList []dto.StockProduct allProductListMap := make(map[int]struct{}) productOldMap := map[int]dto.StockProduct{} for _, product := range productOldList { stockProduct := dto.StockProduct{ T_product_id: product.T_product_id, T_num: product.T_num, T_relation_sn: lib.SplitString(product.T_relation_sn, ","), } oldProductList = append(oldProductList, stockProduct) productOldMap[product.T_product_id] = stockProduct if _, ok := allProductListMap[product.T_product_id]; !ok { allProductListMap[product.T_product_id] = struct{}{} } } productNewList := lib.SplitString(T_product, "|") productNewMap := map[int]dto.StockProduct{} for _, v := range productNewList { product_id, _ := strconv.Atoi(strings.Split(v, "-")[0]) num, _ := strconv.Atoi(strings.Split(v, "-")[1]) T_relation_sn := strings.Split(v, "-")[2] snList := lib.SplitString(T_relation_sn, ",") if len(snList) > 0 { num = len(snList) } stockProduct := dto.StockProduct{ T_product_id: product_id, T_num: num, T_relation_sn: snList, } newProductList = append(newProductList, stockProduct) productNewMap[product_id] = stockProduct if _, ok := allProductListMap[product_id]; !ok { allProductListMap[product_id] = struct{}{} } } // 判断产品列表信息是否相同 StockProductListIsEqual, needDelete, needAdd, needEdit, snDiff := dto.StockProductListsEqual(oldProductList, newProductList) // 两次提交的数据相同，则不用修改 if !StockProductListIsEqual { if len(needDelete) > 0 { // 删除入库产品列表 for _, v := range needDelete { product, _ := Basic.Read_Product_ById(v.T_product_id) // 删除入库产品列表 err = StockInProductDao.Delete_StockInProduct(stockIn.T_number, stockIn.T_depot_id, v.T_product_id) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除产品入库信息失败!"} c.ServeJSON() return } if product.T_relation_sn == 1 { // 删除该入库单关联sn for _, sn := range v.T_relation_sn { err = DeviceDao.Delete_Device_ByT_in_number(stockIn.T_number, sn) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "删除入库设备失败"} c.ServeJSON() return } } } // 减少库存 _, err = StockDao.AddOrUpdate_Stock(stockIn.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, v.T_num, 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "更新库存信息失败"} c.ServeJSON() return } } } if len(needAdd) > 0 { // 新增入库产品列表 for _, v := range needAdd { product, _ := Basic.Read_Product_ById(v.T_product_id) if product.T_relation_sn == 1 && len(v.T_relation_sn) == 0 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s关联SN，请先添加SN！", product.T_name)} c.ServeJSON() return } // 添加该入库单关联sn for _, sn := range v.T_relation_sn { mqtt := Stock.Read_MqttUser(sn) // 添加设备 device := Stock.Device{ T_contract_number: "", T_out_number: "", T_product_id: v.T_product_id, T_in_number: stockIn.T_number, T_sn: sn, T_iccid: mqtt.Iccid, T_imei: mqtt.Imei, T_State: 2, T_batch_number: T_batch_number, CreateTime: date, UpdateTime: stockIn.UpdateTime, } _, err = DeviceDao.AddOrUpdate_Device(device, 2) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: sn + "入库失败"} c.ServeJSON() return } } stockInProduct := Stock.StockInProduct{ T_number: T_number, T_product_id: v.T_product_id, T_depot_id: stockIn.T_depot_id, T_num: v.T_num, // 入库数量 T_date: stockIn.T_date, // 入库日期 T_relation_sn: strings.Join(v.T_relation_sn, ","), } _, err = StockInProductDao.Add_StockInProduct(stockInProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "入库失败"} c.ServeJSON() return } // 增加库存 _, err = StockDao.AddOrUpdate_Stock(stockIn.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, v.T_num, 2) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "增加库存失败"} c.ServeJSON() return } } } if len(needEdit) > 0 { for _, v := range needEdit { product, _ := Basic.Read_Product_ById(v.T_product_id) stockInProduct := Stock.StockInProduct{ T_number: stockIn.T_number, T_product_id: v.T_product_id, T_depot_id: stockIn.T_depot_id, T_num: productNewMap[v.T_product_id].T_num, // 入库数量 T_date: stockIn.T_date, // 入库日期 } // 入库数量比之前多，增加库存 var T_type int var T_num int if productNewMap[v.T_product_id].T_num > productOldMap[v.T_product_id].T_num { // 增加库存 T_type = 2 T_num = productNewMap[v.T_product_id].T_num - productOldMap[v.T_product_id].T_num } else { // 减少库存 T_type = 1 T_num = productOldMap[v.T_product_id].T_num - productNewMap[v.T_product_id].T_num } _, err = StockDao.AddOrUpdate_Stock(stockIn.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, T_num, T_type) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: err.Error()} c.ServeJSON() return } // 更新产品库存表 err = StockInProductDao.Update_StockInProduct(stockInProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改入库产品信息失败"} c.ServeJSON() return } } } for _, diff := range snDiff { product, _ := Basic.Read_Product_ById(diff.T_product_id) // 删除减少的sn if len(diff.T_delete_relation_sn) > 0 { for _, sn := range diff.T_delete_relation_sn { err = DeviceDao.Delete_Device_ByT_in_number(stockIn.T_number, sn) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: err.Error()} c.ServeJSON() return } } // 减少库存 _, err = StockDao.AddOrUpdate_Stock(stockIn.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, len(diff.T_delete_relation_sn), 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: err.Error()} c.ServeJSON() return } } if len(diff.T_add_relation_sn) > 0 { for _, sn := range diff.T_add_relation_sn { mqtt := Stock.Read_MqttUser(sn) // 添加设备 device := Stock.Device{ T_contract_number: "", T_out_number: "", T_product_id: diff.T_product_id, T_in_number: stockIn.T_number, T_sn: sn, T_iccid: mqtt.Iccid, T_imei: mqtt.Imei, T_State: 2, CreateTime: date, UpdateTime: stockIn.UpdateTime, } _, err = DeviceDao.AddOrUpdate_Device(device, 2) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: sn + "入库失败"} c.ServeJSON() return } } // 增加库存 _, err = StockDao.AddOrUpdate_Stock(stockIn.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, len(diff.T_add_relation_sn), 2) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "入库失败"} c.ServeJSON() return } } stockInProduct := Stock.StockInProduct{ T_number: stockIn.T_number, T_product_id: diff.T_product_id, T_depot_id: stockIn.T_depot_id, T_num: productNewMap[diff.T_product_id].T_num, // 入库数量 T_date: stockIn.T_date, // 入库日期 T_relation_sn: strings.Join(productNewMap[diff.T_product_id].T_relation_sn, ","), } // 更新产品库存表 err = StockInProductDao.Update_StockInProduct(stockInProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改入库产品信息失败"} c.ServeJSON() return } } } stockIn.T_remark = T_remark if len(T_date) > 0 { stockIn.T_date = T_date } if len(T_project) > 0 { stockIn.T_project = T_project } if len(T_return_user) > 0 { stockIn.T_return_user = T_return_user } if len(T_batch_number) > 0 { stockIn.T_batch_number = T_batch_number } if len(T_company_name) > 0 { stockIn.T_company_name = T_company_name } err = StockInDao.Update_StockIn(stockIn, "T_remark", "T_date", "T_project", "T_return_user", "T_batch_number", "T_company_name") if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改入库失败"} c.ServeJSON() return } o.Commit() if len(T_date) > 0 && T_old_date != T_date { // 修改出库产品日期 StockInProductDao.Update_StockInProduct_T_date(stockIn.T_number, T_date) DeviceDao.Update_Device_CreateTimeByT_in_number(stockIn.T_number, T_date) } // 修改出库产品日期 StockInProductDao.Update_StockInProduct_T_batch_number(stockIn.T_number, T_batch_number) // 修改设备批次号 DeviceDao.Update_Device_BatchNumber_ByInNumber(stockIn.T_number, T_batch_number) // 更新月份统计表 allProductList := []int{} for i, _ := range allProductListMap { allProductList = append(allProductList, i) } StockIn_Edit_StockMonth(stockIn.T_date, stockIn.T_depot_id, allProductList) NatsServer.AddUserLogs(c.User.T_uuid, "入库", "修改", stockIn) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } // 删除入库 func (c *StockController) StockIn_Del() { T_number := c.GetString("T_number") // 入库单号 o := orm.NewOrm() o.Begin() StockInDao := Stock.NewStockIn(o) StockInProductDao := Stock.NewStockInProduct(o) StockDao := Stock.NewStock(o) DeviceDao := Stock.NewDevice(o) // 查询入库信息 stockIn, err := StockInDao.Read_StockIn_ByT_number(T_number) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } // 查询入库产品信息 productOldList := StockInProductDao.Read_StockInProduct_List_ByT_number(stockIn.T_number) var oldProductList []dto.StockProduct allProductList := []int{} for _, product := range productOldList { oldProductList = append(oldProductList, dto.StockProduct{ T_product_id: product.T_product_id, T_num: product.T_num, T_relation_sn: lib.SplitString(product.T_relation_sn, ","), }) allProductList = append(allProductList, product.T_product_id) } // 删除入库产品列表 for _, v := range oldProductList { product, _ := Basic.Read_Product_ById(v.T_product_id) // 删除入库产品列表 err = StockInProductDao.Delete_StockInProduct(stockIn.T_number, stockIn.T_depot_id, v.T_product_id) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除产品入库信息失败!"} c.ServeJSON() return } if product.T_relation_sn == 1 { // 删除该入库单关联sn for _, sn := range v.T_relation_sn { err = DeviceDao.Delete_Device_ByT_in_number(stockIn.T_number, sn) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "删除入库设备失败"} c.ServeJSON() return } } } // 减少库存 _, err = StockDao.AddOrUpdate_Stock(stockIn.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, v.T_num, 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "更新库存信息失败"} c.ServeJSON() return } } err = StockInDao.Delete_StockIn(stockIn) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "删除入库失败"} c.ServeJSON() return } o.Commit() // 更新月份统计表 StockIn_Edit_StockMonth(stockIn.T_date, stockIn.T_depot_id, allProductList) NatsServer.AddUserLogs(c.User.T_uuid, "入库", "删除", stockIn) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } // 导出出库单 func (c *StockController) StockIn_Excel() { // 查询 T_number := c.GetString("T_number") o := orm.NewOrm() StockInDao := Stock.NewStockIn(o) StockInProductDao := Stock.NewStockInProduct(o) stockIn, err := StockInDao.Read_StockIn_ByT_number(T_number) if err != nil { c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } productList := StockInProductDao.Read_StockInProduct_List_ByT_number(stockIn.T_number) var pList []Stock.StockInProduct_R for _, v := range productList { pList = append(pList, Stock.StockInProductToStockInProduct_R(v)) } userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) stockInDetail := Stock.StockInToStockIn_Detail(stockIn, pList) T_date, _ := lib.DateStrToTime(stockIn.T_date) filename := fmt.Sprintf("冷链产品入库单(%s)", lib.GetRandstring(6, "0123456789", 0)) f := excelize.NewFile() // 设置单元格的值 Style1, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 12, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"}, }) Style2, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 11, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "left", Vertical: "center"}, }) Style3, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 10, Family: "宋体", Bold: true}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) Style4, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 11, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) productList2 := lib.ChunkBy(productList, 10) for i, products := range productList2 { if len(products) < 10 { products = append(products, make([]Stock.StockInProduct, 10-len(products))...) } row := i*17 + 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style1) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("宝智达科技产品进销存统计表")) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style1) title := "硬件入库单" if len(productList2) > 1 { title += fmt.Sprintf(" %d/%d", i+1, len(productList2)) } f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), title) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("入库单号：%s", stockIn.T_number)) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("项目名称：%s", stockIn.T_remark)) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("入库时间：%s", T_date.Format("2006年01月02日"))) f.SetRowHeight("Sheet1", row, 20) // 这里设置表头 row += 1 f.SetRowHeight("Sheet1", row, 20) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), "序号") f.SetCellValue("Sheet1", fmt.Sprintf("B%d", row), "产品名称") f.SetCellValue("Sheet1", fmt.Sprintf("C%d", row), "型号") f.SetCellValue("Sheet1", fmt.Sprintf("D%d", row), "单位") f.SetCellValue("Sheet1", fmt.Sprintf("E%d", row), "领用数量") f.SetCellValue("Sheet1", fmt.Sprintf("F%d", row), "备注") // 设置列宽 f.SetColWidth("Sheet1", "A", "A", 5) f.SetColWidth("Sheet1", "B", "B", 20) f.SetColWidth("Sheet1", "C", "C", 12) f.SetColWidth("Sheet1", "D", "D", 10) f.SetColWidth("Sheet1", "E", "E", 10) f.SetColWidth("Sheet1", "F", "F", 15) f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row), Style3) sRow := row // 循环写入数据 for j, v := range products { row += 1 product, _ := Basic.Read_Product_ById(v.T_product_id) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), j+1) f.SetCellValue("Sheet1", fmt.Sprintf("B%d", row), product.T_name) f.SetCellValue("Sheet1", fmt.Sprintf("C%d", row), product.T_model) f.SetCellValue("Sheet1", fmt.Sprintf("D%d", row), product.T_spec) if v.T_num > 0 { f.SetCellValue("Sheet1", fmt.Sprintf("E%d", row), v.T_num) f.SetCellValue("Sheet1", fmt.Sprintf("F%d", row), stockIn.T_remark) } } f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", sRow), fmt.Sprintf("F%d", row), Style4) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("C%d", row)) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("制单：%s", c.User.T_name)) f.MergeCell("Sheet1", fmt.Sprintf("D%d", row), fmt.Sprintf("F%d", row)) f.SetCellValue("Sheet1", fmt.Sprintf("D%d", row), fmt.Sprintf("经办人：%s", stockInDetail.T_submit_name)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetRowHeight("Sheet1", row, 20) } // 保存文件 if err = f.SaveAs("ofile/" + filename + ".xlsx"); err != nil { fmt.Println(err) } var url string //// 上传 OSS nats := natslibs.NewNats(Nats.Nats, conf.NatsSubj_Prefix) url, is := nats.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+filename+".xlsx", "ofile/"+filename+".xlsx") if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "oss!"} c.ServeJSON() return } //删除目录 err = os.Remove("ofile/" + filename + ".xlsx") if err != nil { logs.Error(lib.FuncName(), err) } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url} c.ServeJSON() return } // 批量导出出库单 func (c *StockController) StockIn_Excel_Batch() { // 查询 T_number_list := c.GetString("T_number_list") o := orm.NewOrm() StockInDao := Stock.NewStockIn(o) StockInProductDao := Stock.NewStockInProduct(o) list := strings.Split(strings.Trim(T_number_list, "|"), "|") userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) filename := fmt.Sprintf("冷链产品入库单(%s)", lib.GetRandstring(6, "0123456789", 0)) f := excelize.NewFile() // 设置单元格的值 Style1, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 12, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"}, }) Style2, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 11, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "left", Vertical: "center"}, }) Style3, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 10, Family: "宋体", Bold: true}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) Style4, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 11, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) var num int for _, T_number := range list { stockIn, err := StockInDao.Read_StockIn_ByT_number(T_number) if err != nil { c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } productList := StockInProductDao.Read_StockInProduct_List_ByT_number(stockIn.T_number) var pList []Stock.StockInProduct_R for _, v := range productList { pList = append(pList, Stock.StockInProductToStockInProduct_R(v)) } stockInDetail := Stock.StockInToStockIn_Detail(stockIn, pList) T_date, _ := lib.DateStrToTime(stockIn.T_date) productList2 := lib.ChunkBy(productList, 10) for i, products := range productList2 { if len(products) < 10 { products = append(products, make([]Stock.StockInProduct, 10-len(products))...) } row := num*18 + 1 num += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style1) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("宝智达科技产品进销存统计表")) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style1) title := "硬件入库单" if len(productList2) > 1 { title += fmt.Sprintf(" %d/%d", i+1, len(productList2)) } f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), title) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("入库单号：%s", stockIn.T_number)) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("项目名称：%s", stockIn.T_remark)) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("入库时间：%s", T_date.Format("2006年01月02日"))) f.SetRowHeight("Sheet1", row, 20) // 这里设置表头 row += 1 f.SetRowHeight("Sheet1", row, 20) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), "序号") f.SetCellValue("Sheet1", fmt.Sprintf("B%d", row), "产品名称") f.SetCellValue("Sheet1", fmt.Sprintf("C%d", row), "型号") f.SetCellValue("Sheet1", fmt.Sprintf("D%d", row), "单位") f.SetCellValue("Sheet1", fmt.Sprintf("E%d", row), "领用数量") f.SetCellValue("Sheet1", fmt.Sprintf("F%d", row), "备注") // 设置列宽 f.SetColWidth("Sheet1", "A", "A", 5) f.SetColWidth("Sheet1", "B", "B", 20) f.SetColWidth("Sheet1", "C", "C", 12) f.SetColWidth("Sheet1", "D", "D", 10) f.SetColWidth("Sheet1", "E", "E", 10) f.SetColWidth("Sheet1", "F", "F", 15) f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row), Style3) sRow := row // 循环写入数据 for j, v := range products { row += 1 product, _ := Basic.Read_Product_ById(v.T_product_id) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), j+1) f.SetCellValue("Sheet1", fmt.Sprintf("B%d", row), product.T_name) f.SetCellValue("Sheet1", fmt.Sprintf("C%d", row), product.T_model) f.SetCellValue("Sheet1", fmt.Sprintf("D%d", row), product.T_spec) if v.T_num > 0 { f.SetCellValue("Sheet1", fmt.Sprintf("E%d", row), v.T_num) f.SetCellValue("Sheet1", fmt.Sprintf("F%d", row), stockIn.T_remark) } } f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", sRow), fmt.Sprintf("F%d", row), Style4) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("C%d", row)) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("制单：%s", c.User.T_name)) f.MergeCell("Sheet1", fmt.Sprintf("D%d", row), fmt.Sprintf("F%d", row)) f.SetCellValue("Sheet1", fmt.Sprintf("D%d", row), fmt.Sprintf("经办人：%s", stockInDetail.T_submit_name)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetRowHeight("Sheet1", row, 20) // 空一行 row += 1 //f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) //f.SetRowStyle("Sheet1", row, row, Style1) //f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), "") // 插入下一页分页符 f.InsertPageBreak("Sheet1", fmt.Sprintf("A%d", row)) } } // 保存文件 if err := f.SaveAs("ofile/" + filename + ".xlsx"); err != nil { fmt.Println(err) } var url string //// 上传 OSS nats := natslibs.NewNats(Nats.Nats, conf.NatsSubj_Prefix) url, is := nats.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+filename+".xlsx", "ofile/"+filename+".xlsx") if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "oss!"} c.ServeJSON() return } //删除目录 err := os.Remove("ofile/" + filename + ".xlsx") if err != nil { logs.Error(lib.FuncName(), err) } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url} c.ServeJSON() return } // 退库申请 func (c *StockController) StockIn_Apply_List() { // 分页参数 初始化 page, _ := c.GetInt("page") if page < 1 { page = 1 } page_z, _ := c.GetInt("page_z") if page_z < 1 { page_z = conf.Page_size } // 查询 T_depot_id, _ := c.GetInt("T_depot_id") T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") T_name := c.GetString("T_name") T_state := c.GetString("T_state") userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() StockInDao := Stock.NewStockIn(orm.NewOrm()) R_List, R_cnt := StockInDao.Read_StockIn_Apply_List(Stock.StockInTypeApply, c.User.T_uuid, T_state, T_name, T_depot_id, T_start_date, T_end_date, page, page_z) var r_jsons lib.R_JSONS r_jsons.Num = R_cnt r_jsons.Data = R_List r_jsons.Page = page r_jsons.Page_size = int(math.Ceil(float64(R_cnt) / float64(page_z))) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } func (c *StockController) StockIn_Apply_Warehouse_List() { // 分页参数 初始化 page, _ := c.GetInt("page") if page < 1 { page = 1 } page_z, _ := c.GetInt("page_z") if page_z < 1 { page_z = conf.Page_size } // 查询 T_depot_id, _ := c.GetInt("T_depot_id") T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") T_name := c.GetString("T_name") T_state := c.GetString("T_state") T_uuid := c.GetString("T_uuid") userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() StockInDao := Stock.NewStockIn(orm.NewOrm()) R_List, R_cnt := StockInDao.Read_StockIn_Apply_List(Stock.StockInTypeWarehouse, T_uuid, T_state, T_name, T_depot_id, T_start_date, T_end_date, page, page_z) var r_jsons lib.R_JSONS r_jsons.Num = R_cnt r_jsons.Data = R_List r_jsons.Page = page r_jsons.Page_size = int(math.Ceil(float64(R_cnt) / float64(page_z))) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } func (c *StockController) StockIn_Apply() { o := orm.NewOrm() o.Begin() StockInDao := Stock.NewStockIn(o) T_number := c.GetString("T_number") // 检查前端传入的T_number是否已提交过 _, err := StockInDao.Read_StockIn_ByT_number(T_number) if err != nil && err.Error() != orm.ErrNoRows.Error() { // 数据库查询错误 o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "查询入库编号失败"} c.ServeJSON() return } if err == nil { // 入库编号已存在，不需要做任何处理 o.Rollback() c.Data["json"] = lib.JSONS{Code: 200, Msg: "入库编号已存在，无需重复提交!", Data: T_number} c.ServeJSON() return } T_depot_id, _ := c.GetInt("T_depot_id") T_product := c.GetString("T_product") T_remark := c.GetString("T_remark") T_project := c.GetString("T_project") T_company_name := c.GetString("T_company_name") T_return_user := c.GetString("T_return_user") if len(T_return_user) == 0 { T_return_user = c.User.T_uuid } if len(T_project) == 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: "项目不能为空!"} c.ServeJSON() return } NatsServer.AddUserLogs(c.User.T_uuid, "仓库管理", "退库", T_product) var_ := Stock.StockIn{ T_number: T_number, T_depot_id: T_depot_id, T_type: 2, T_remark: T_remark, T_submit: c.User.T_uuid, T_project: T_project, T_return_user: T_return_user, T_company_name: T_company_name, T_state: 1, T_application_date: time.Now().Format("2006-01-02"), } StockInProductDao := Stock.NewStockInProduct(o) _, err = StockInDao.Add_StockIn(var_) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "入库失败"} c.ServeJSON() return } if len(T_product) == 0 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "产品明细不能为空"} c.ServeJSON() return } productList := lib.SplitString(T_product, "|") allProductList := []int{} for _, v := range productList { product_id, _ := strconv.Atoi(strings.Split(v, "-")[0]) allProductList = append(allProductList, product_id) num, _ := strconv.Atoi(strings.Split(v, "-")[1]) stockInProduct := Stock.StockInProduct{ T_number: T_number, T_product_id: product_id, T_depot_id: T_depot_id, T_num: num, // 入库数量 } _, err = StockInProductDao.Add_StockInProduct(stockInProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "入库失败"} c.ServeJSON() return } } o.Commit() NatsServer.AddUserLogs(c.User.T_uuid, "退库申请", "退库申请", var_) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } func (c *StockController) StockIn_Apply_Edit() { T_number := c.GetString("T_number") // 入库单号 //T_depot_id, _ := c.GetInt("T_depot_id") T_product := c.GetString("T_product") T_remark := c.GetString("T_remark") T_project := c.GetString("T_project") T_batch_number := c.GetString("T_batch_number") T_company_name := c.GetString("T_company_name") NatsServer.AddUserLogs(c.User.T_uuid, "仓库管理", "修改入库", T_product) o := orm.NewOrm() o.Begin() StockInDao := Stock.NewStockIn(o) StockInProductDao := Stock.NewStockInProduct(o) // 查询入库信息 stockIn, err := StockInDao.Read_StockIn_ByT_number(T_number) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } // 查询入库产品信息 productOldList := StockInProductDao.Read_StockInProduct_List_ByT_number(stockIn.T_number) var oldProductList []dto.StockProduct var newProductList []dto.StockProduct allProductListMap := make(map[int]struct{}) productOldMap := map[int]dto.StockProduct{} for _, product := range productOldList { stockProduct := dto.StockProduct{ T_product_id: product.T_product_id, T_num: product.T_num, T_relation_sn: lib.SplitString(product.T_relation_sn, ","), } oldProductList = append(oldProductList, stockProduct) productOldMap[product.T_product_id] = stockProduct if _, ok := allProductListMap[product.T_product_id]; !ok { allProductListMap[product.T_product_id] = struct{}{} } } productNewList := lib.SplitString(T_product, "|") productNewMap := map[int]dto.StockProduct{} for _, v := range productNewList { product_id, _ := strconv.Atoi(strings.Split(v, "-")[0]) num, _ := strconv.Atoi(strings.Split(v, "-")[1]) T_relation_sn := strings.Split(v, "-")[2] snList := lib.SplitString(T_relation_sn, ",") if len(snList) > 0 { num = len(snList) } stockProduct := dto.StockProduct{ T_product_id: product_id, T_num: num, T_relation_sn: snList, } newProductList = append(newProductList, stockProduct) productNewMap[product_id] = stockProduct if _, ok := allProductListMap[product_id]; !ok { allProductListMap[product_id] = struct{}{} } } // 判断产品列表信息是否相同 StockProductListIsEqual, needDelete, needAdd, needEdit, _ := dto.StockProductListsEqual(oldProductList, newProductList) // 两次提交的数据相同，则不用修改 if !StockProductListIsEqual { if len(needDelete) > 0 { // 删除入库产品列表 for _, v := range needDelete { // 删除入库产品列表 err = StockInProductDao.Delete_StockInProduct(stockIn.T_number, stockIn.T_depot_id, v.T_product_id) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除产品入库信息失败!"} c.ServeJSON() return } } } if len(needAdd) > 0 { // 新增入库产品列表 for _, v := range needAdd { stockInProduct := Stock.StockInProduct{ T_number: T_number, T_product_id: v.T_product_id, T_depot_id: stockIn.T_depot_id, T_num: v.T_num, // 入库数量 T_date: stockIn.T_date, // 入库日期 T_relation_sn: strings.Join(v.T_relation_sn, ","), } _, err = StockInProductDao.Add_StockInProduct(stockInProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "入库失败"} c.ServeJSON() return } } } if len(needEdit) > 0 { for _, v := range needEdit { stockInProduct := Stock.StockInProduct{ T_number: stockIn.T_number, T_product_id: v.T_product_id, T_depot_id: stockIn.T_depot_id, T_num: productNewMap[v.T_product_id].T_num, // 入库数量 T_date: stockIn.T_date, // 入库日期 } // 更新产品库存表 err = StockInProductDao.Update_StockInProduct(stockInProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改入库产品信息失败"} c.ServeJSON() return } } } } stockIn.T_remark = T_remark if len(T_project) > 0 { stockIn.T_project = T_project } if len(T_batch_number) > 0 { stockIn.T_batch_number = T_batch_number } if len(T_company_name) > 0 { stockIn.T_company_name = T_company_name } err = StockInDao.Update_StockIn(stockIn, "T_remark", "T_project", "T_batch_number", "T_company_name") if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改入库失败"} c.ServeJSON() return } o.Commit() NatsServer.AddUserLogs(c.User.T_uuid, "退库", "修改", stockIn) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } // 删除入库 func (c *StockController) StockIn_Apply_Del() { T_number := c.GetString("T_number") // 入库单号 o := orm.NewOrm() o.Begin() StockInDao := Stock.NewStockIn(o) StockInProductDao := Stock.NewStockInProduct(o) // 查询入库信息 stockIn, err := StockInDao.Read_StockIn_ByT_number(T_number) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } // 查询入库产品信息 productOldList := StockInProductDao.Read_StockInProduct_List_ByT_number(stockIn.T_number) var oldProductList []dto.StockProduct allProductList := []int{} for _, product := range productOldList { oldProductList = append(oldProductList, dto.StockProduct{ T_product_id: product.T_product_id, T_num: product.T_num, T_relation_sn: lib.SplitString(product.T_relation_sn, ","), }) allProductList = append(allProductList, product.T_product_id) } // 删除入库产品列表 for _, v := range oldProductList { // 删除入库产品列表 err = StockInProductDao.Delete_StockInProduct(stockIn.T_number, stockIn.T_depot_id, v.T_product_id) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除产品入库信息失败!"} c.ServeJSON() return } } err = StockInDao.Delete_StockIn(stockIn) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "删除入库失败"} c.ServeJSON() return } o.Commit() NatsServer.AddUserLogs(c.User.T_uuid, "入库申请", "删除", stockIn) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } func (c *StockController) StockIn_Warehouse() { T_number := c.GetString("T_number") T_date := c.GetString("T_date") T_remark := c.GetString("T_remark") T_project := c.GetString("T_project") T_product := c.GetString("T_product") date, is := lib.DateStrToTime(T_date) if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "日期格式错误!"} c.ServeJSON() return } if len(T_project) == 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: "项目不能为空!"} c.ServeJSON() return } NatsServer.AddUserLogs(c.User.T_uuid, "退库申请", "确认入库", T_product) o := orm.NewOrm() o.Begin() StockInDao := Stock.NewStockIn(o) StockInProductDao := Stock.NewStockInProduct(o) StockDao := Stock.NewStock(o) DeviceDao := Stock.NewDevice(o) // 查询入库信息 stockIn, err := StockInDao.Read_StockIn_ByT_number(T_number) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } productList := lib.SplitString(T_product, "|") allProductList := []int{} for _, v := range productList { product_id, _ := strconv.Atoi(strings.Split(v, "-")[0]) allProductList = append(allProductList, product_id) product, _ := Basic.Read_Product_ById(product_id) num, _ := strconv.Atoi(strings.Split(v, "-")[1]) if num == 0 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s出库数量不能为0！", product.T_name)} c.ServeJSON() return } T_relation_sn := strings.Split(v, "-")[2] if T_relation_sn == "" && product.T_relation_sn == 1 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s关联SN，请先添加SN！", product.T_name)} c.ServeJSON() return } if len(T_relation_sn) > 0 { snList := strings.Split(T_relation_sn, ",") if product.T_relation_sn == 1 && num != len(snList) { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s SN数量与出库数量不一致，请核查！", product.T_name)} c.ServeJSON() return } if len(snList) > 0 { for _, sn := range snList { mqtt := Stock.Read_MqttUser(sn) // 根据IMEI查询上次入库的批次号 batchNumber, err := DeviceDao.Read_Device_BatchNumber_ByImei(mqtt.Imei) if err != nil { logs.Error(lib.FuncName(), err) } device := Stock.Device{ T_product_id: product_id, T_in_number: T_number, T_sn: sn, T_iccid: mqtt.Iccid, T_imei: mqtt.Imei, T_State: 2, T_project: stockIn.T_project, T_batch_number: batchNumber, CreateTime: date, } _, err = DeviceDao.AddOrUpdate_Device(device, 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "出库失败"} c.ServeJSON() return } } } } // 3、添加出库产品清单 stockInProduct := Stock.StockInProduct{ T_number: T_number, T_product_id: product_id, T_depot_id: stockIn.T_depot_id, T_num: num, // 入库数量 T_date: T_date, // 入库日期 T_relation_sn: T_relation_sn, T_state: 1, } // 更新产品表 err = StockInProductDao.Update_StockInProduct(stockInProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改出库产品信息失败"} c.ServeJSON() return } // 5、更新产品库存列表、占用库存 _, err = StockDao.AddOrUpdate_Stock(stockIn.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, num, 2) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "入库失败"} c.ServeJSON() return } } if len(T_remark) > 0 { stockIn.T_remark = T_remark } if len(T_project) > 0 { stockIn.T_project = T_project } stockIn.T_warehouse = c.User.T_uuid stockIn.T_state = Stock.StockInWarehouse stockIn.T_date = T_date err = StockInDao.Update_StockIn(stockIn, "T_state", "T_date", "T_warehouse", "T_project", "T_remark") if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "出库审批失败"} c.ServeJSON() return } o.Commit() // 更新月份统计表 StockIn_Edit_StockMonth(stockIn.T_date, stockIn.T_depot_id, allProductList) NatsServer.AddUserLogs(c.User.T_uuid, "入库申请", "确认出库", stockIn) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } func (c *StockController) StockOut_List() { // 分页参数 初始化 page, _ := c.GetInt("page") if page < 1 { page = 1 } page_z, _ := c.GetInt("page_z") if page_z < 1 { page_z = conf.Page_size } // 查询 T_depot_id, _ := c.GetInt("T_depot_id") T_contract_number := c.GetString("T_contract_number") T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") T_name := c.GetString("T_name") userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() StockOutDao := Stock.NewStockOut(orm.NewOrm()) R_List, R_cnt := StockOutDao.Read_StockOut_List(T_name, T_depot_id, T_contract_number, T_start_date, T_end_date, page, page_z) var r_jsons lib.R_JSONS r_jsons.Num = R_cnt r_jsons.Data = R_List r_jsons.Page = page r_jsons.Page_size = int(math.Ceil(float64(R_cnt) / float64(page_z))) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } func (c *StockController) StockOut_List_Product() { // 分页参数 初始化 page, _ := c.GetInt("page") if page < 1 { page = 1 } page_z, _ := c.GetInt("page_z") if page_z < 1 { page_z = conf.Page_size } // 查询 T_depot_id, _ := c.GetInt("T_depot_id") T_name := c.GetString("T_name") T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") T_product_name := c.GetString("T_product_name") // 产品名称 T_product_model := c.GetString("T_product_model") // 产品型号 userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() StockOutDao := Stock.NewStockOut(orm.NewOrm()) R_List, R_cnt := StockOutDao.Read_StockOutProduct_List(T_name, T_start_date, T_end_date, T_depot_id, T_product_name, T_product_model, page, page_z) var r_jsons lib.R_JSONS r_jsons.Num = R_cnt r_jsons.Data = R_List r_jsons.Page = page r_jsons.Page_size = int(math.Ceil(float64(R_cnt) / float64(page_z))) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } func (c *StockController) StockOut_List_Product_Excel() { // 查询 T_depot_id, _ := c.GetInt("T_depot_id") T_name := c.GetString("T_name") T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") T_product_name := c.GetString("T_product_name") // 产品名称 T_product_model := c.GetString("T_product_model") // 产品型号 userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() StockOutDao := Stock.NewStockOut(orm.NewOrm()) R_List, _ := StockOutDao.Read_StockOutProduct_List(T_name, T_start_date, T_end_date, T_depot_id, T_product_name, T_product_model, 0, 9999) filename := fmt.Sprintf("出库明细单(%s)", lib.GetRandstring(6, "0123456789", 0)) f := excelize.NewFile() // 设置单元格的值 Style1, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 12, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"}, }) Style2, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 11, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"}, 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}, }, }) Style3, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 11, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "left", Vertical: "center", WrapText: true}, 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}, }, }) f.MergeCell("Sheet1", "A1", "L1") f.SetRowStyle("Sheet1", 1, 1, Style1) f.SetCellValue("Sheet1", "A1", fmt.Sprintf("出库明细单")) f.SetRowHeight("Sheet1", 1, 30) // 这里设置表头 f.SetCellStyle("Sheet1", "A2", "L2", Style2) f.SetRowHeight("Sheet1", 2, 20) f.SetCellValue("Sheet1", "A2", "序号") f.SetCellValue("Sheet1", "B2", "出库单号") f.SetCellValue("Sheet1", "C2", "领取人") f.SetCellValue("Sheet1", "D2", "出库日期") f.SetCellValue("Sheet1", "E2", "出库仓库") f.SetCellValue("Sheet1", "F2", "关联项目") f.SetCellValue("Sheet1", "G2", "产品名称") f.SetCellValue("Sheet1", "H2", "产品型号") f.SetCellValue("Sheet1", "I2", "数量") f.SetCellValue("Sheet1", "J2", "是否关联SN") f.SetCellValue("Sheet1", "K2", "备注") f.SetCellValue("Sheet1", "L2", "SN") // 设置列宽 f.SetColWidth("Sheet1", "A", "A", 10) f.SetColWidth("Sheet1", "B", "B", 15) f.SetColWidth("Sheet1", "C", "D", 10) f.SetColWidth("Sheet1", "D", "D", 10) f.SetColWidth("Sheet1", "E", "E", 10) f.SetColWidth("Sheet1", "F", "F", 20) f.SetColWidth("Sheet1", "G", "G", 20) f.SetColWidth("Sheet1", "H", "H", 15) f.SetColWidth("Sheet1", "I", "I", 10) f.SetColWidth("Sheet1", "J", "J", 12) f.SetColWidth("Sheet1", "K", "K", 30) f.SetColWidth("Sheet1", "L", "L", 100) line := 2 for _, product := range R_List { line += 1 f.SetCellValue("Sheet1", fmt.Sprintf("A%d", line), line-2) f.SetCellValue("Sheet1", fmt.Sprintf("B%d", line), product.T_number) f.SetCellValue("Sheet1", fmt.Sprintf("C%d", line), product.T_receive_name) f.SetCellValue("Sheet1", fmt.Sprintf("D%d", line), product.T_date) f.SetCellValue("Sheet1", fmt.Sprintf("E%d", line), product.T_depot_name) f.SetCellValue("Sheet1", fmt.Sprintf("F%d", line), product.T_project) f.SetCellValue("Sheet1", fmt.Sprintf("G%d", line), product.T_product_name) f.SetCellValue("Sheet1", fmt.Sprintf("H%d", line), product.T_product_model) f.SetCellValue("Sheet1", fmt.Sprintf("I%d", line), product.T_num) var relation_sn string if product.T_product_relation_sn == 1 { relation_sn = "是" } else { relation_sn = "否" } f.SetCellValue("Sheet1", fmt.Sprintf("J%d", line), relation_sn) f.SetCellValue("Sheet1", fmt.Sprintf("K%d", line), product.T_remark) f.SetCellValue("Sheet1", fmt.Sprintf("L%d", line), product.T_relation_sn) } f.SetCellStyle("Sheet1", "A3", fmt.Sprintf("L%d", line), Style3) // 保存文件 if err := f.SaveAs("ofile/" + filename + ".xlsx"); err != nil { fmt.Println(err) } var url string //// 上传 OSS nats := natslibs.NewNats(Nats.Nats, conf.NatsSubj_Prefix) url, is := nats.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+filename+".xlsx", "ofile/"+filename+".xlsx") if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "oss!"} c.ServeJSON() return } //删除目录 err := os.Remove("ofile/" + filename + ".xlsx") if err != nil { logs.Error(lib.FuncName(), err) } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url} c.ServeJSON() return } func (c *StockController) StockOut_Get() { // 查询 T_number := c.GetString("T_number") o := orm.NewOrm() StockOutDao := Stock.NewStockOut(o) StockOutProductDao := Stock.NewStockOutProduct(o) stockOut, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err != nil { c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } productList := StockOutProductDao.Read_StockOutProduct_List(stockOut.T_number) var pList []Stock.StockOutProduct_R for _, v := range productList { pList = append(pList, Stock.StockOutProductToStockOutProduct_R(v)) } userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Stock.StockOutToStockOut_Detail(stockOut, pList)} c.ServeJSON() return } func (c *StockController) StockOut_generate_number() { StockOutDao := Stock.NewStockOut(orm.NewOrm()) rand_x := 0 T_number := "" for true { T_number = "CK-" + lib.GetRandstring(8, "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789", int64(rand_x)) _, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err != nil && err.Error() == orm.ErrNoRows.Error() { break } rand_x += 1 } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } func (c *StockController) StockOut_Add() { o := orm.NewOrm() o.Begin() StockOutDao := Stock.NewStockOut(o) // 检查前端传入的T_number是否已提交过 T_number := c.GetString("T_number") _, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err == nil { // 入库编号已存在，不需要做任何处理 o.Rollback() c.Data["json"] = lib.JSONS{Code: 200, Msg: "出库编号已存在，无需重复提交!", Data: T_number} c.ServeJSON() return } if err != nil && err.Error() != orm.ErrNoRows.Error() { // 数据库查询错误 o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "查询入库编号失败"} c.ServeJSON() return } T_contract_number := c.GetString("T_contract_number") T_depot_id, _ := c.GetInt("T_depot_id") T_type, _ := c.GetInt("T_type") // 出库类型 1-领料出库 2-销售出库 T_date := c.GetString("T_date") T_receive := c.GetString("T_receive") T_product := c.GetString("T_product") T_remark := c.GetString("T_remark") T_project := c.GetString("T_project") T_delivery_type, _ := c.GetInt("T_delivery_type") T_signer_unit := c.GetString("T_signer_unit") T_signer := c.GetString("T_signer") T_signer_phone := c.GetString("T_signer_phone") T_signer_date := c.GetString("T_signer_date") T_courier_number := c.GetString("T_courier_number") date, is := lib.DateStrToTime(T_date) if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "日期格式错误!"} c.ServeJSON() return } var_ := Stock.StockOut{ T_number: T_number, T_contract_number: T_contract_number, T_depot_id: T_depot_id, T_type: T_type, T_date: T_date, T_receive: T_receive, T_remark: T_remark, T_project: T_project, T_submit: c.User.T_uuid, // 销售出库 T_delivery_type: T_delivery_type, // 1-自送 2-自提 3-快递 T_signer_unit: T_signer_unit, T_signer: T_signer, T_signer_phone: T_signer_phone, T_signer_date: T_signer_date, T_courier_number: T_courier_number, T_state: Stock.StockOutAlreadyOut, } StockOutProductDao := Stock.NewStockOutProduct(o) StockDao := Stock.NewStock(o) DeviceDao := Stock.NewDevice(o) ContractDao := Contract.NewContract(o) ContractProductDao := Contract.NewContractProduct(o) _, err = StockOutDao.Add_StockOut(var_) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "出库失败"} c.ServeJSON() return } // 1、添加出库单 contract, _ := ContractDao.Read_Contract_ByT_number(T_contract_number) if contract.Id == 0 && T_type == 2 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "合同编号错误！"} c.ServeJSON() return } if len(T_product) == 0 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "产品明细不能为空"} c.ServeJSON() return } productList := lib.SplitString(T_product, "|") allProductList := []int{} for _, v := range productList { product_id, _ := strconv.Atoi(strings.Split(v, "-")[0]) allProductList = append(allProductList, product_id) product, _ := Basic.Read_Product_ById(product_id) num, _ := strconv.Atoi(strings.Split(v, "-")[1]) T_relation_sn := strings.Split(v, "-")[2] if T_relation_sn == "" && product.T_relation_sn == 1 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s关联SN，请先添加SN！", product.T_name)} c.ServeJSON() return } if len(T_relation_sn) > 0 { snList := lib.SplitString(T_relation_sn, ",") num = len(snList) for _, sn := range snList { mqtt := Stock.Read_MqttUser(sn) // 根据IMEI查询上次入库的批次号 batchNumber, err := DeviceDao.Read_Device_BatchNumber_ByImei(mqtt.Imei) if err != nil { logs.Error(lib.FuncName(), err) } device := Stock.Device{ T_contract_number: T_contract_number, T_product_id: product_id, T_out_number: T_number, T_sn: sn, T_iccid: mqtt.Iccid, T_imei: mqtt.Imei, T_State: 1, T_project: T_project, T_batch_number: batchNumber, CreateTime: date, } _, err = DeviceDao.AddOrUpdate_Device(device, 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "出库失败"} c.ServeJSON() return } } } // 3、添加出库产品清单 stockOutProduct := Stock.StockOutProduct{ T_number: T_number, T_product_id: product_id, T_depot_id: T_depot_id, T_num: num, // 出库数量 T_date: T_date, // 出库日期 T_relation_sn: T_relation_sn, T_state: 1, } _, err = StockOutProductDao.Add_StockOutProduct(stockOutProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "出库失败"} c.ServeJSON() return } // 4、更改合同产品列表清单 contractProduct, _ := ContractProductDao.Read_ContractProduct_ByT_number_T_product_id(T_contract_number, product_id) contractProduct.T_product_out += num if contractProduct.T_product_out > contractProduct.T_product_total && T_type == 2 { o.Rollback() p, _ := Basic.Read_Product_ById(product_id) c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("【%s】出库数量超过预计出库数量！", p.T_name)} c.ServeJSON() return } contractProduct.T_State = 2 if contractProduct.T_product_out == 0 { contractProduct.T_State = 1 } if contractProduct.T_product_out == contractProduct.T_product_total { contractProduct.T_State = 3 } err = ContractProductDao.Update_ContractProduct(contractProduct, "T_product_out", "T_State") if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "更新合同产品清单失败"} c.ServeJSON() return } // 5、更新产品库存列表 _, err = StockDao.AddOrUpdate_Stock(T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, num, 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "更新库存失败" + err.Error()} c.ServeJSON() return } } o.Commit() o2 := orm.NewOrm() o2.Begin() ContractDao2 := Contract.NewContract(o2) ContractProductDao2 := Contract.NewContractProduct(o2) // 5、更新合同出库状态 var T_out int if contract.T_State == 1 { T_out = 2 // 查询合同产品清单是否全部都为已出库 state := ContractProductDao2.Read_ContractProduct_T_State_List(contract.T_number) if state == 1 { T_out = 1 } if state == 3 { T_out = 3 } } if T_out != contract.T_out { contract.T_out = T_out err = ContractDao2.Update_Contract(contract, "T_out") if err != nil { o2.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "更新合同出库状态失败"} c.ServeJSON() return } } o2.Commit() StockOut_Edit_StockMonth(T_date, T_depot_id, allProductList) NatsServer.AddUserLogs(c.User.T_uuid, "出库", "出库", var_) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } func (c *StockController) StockOut_Edit_Delivery() { T_number := c.GetString("T_number") T_remark := c.GetString("T_remark") T_project := c.GetString("T_project") T_delivery_type, _ := c.GetInt("T_delivery_type") T_signer_unit := c.GetString("T_signer_unit") T_signer := c.GetString("T_signer") T_signer_phone := c.GetString("T_signer_phone") T_signer_date := c.GetString("T_signer_date") T_courier_number := c.GetString("T_courier_number") o := orm.NewOrm() StockOutDao := Stock.NewStockOut(o) stockOut, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err != nil { c.Data["json"] = lib.JSONS{Code: 203, Msg: "出库编号错误！"} c.ServeJSON() return } if len(T_remark) > 0 { stockOut.T_remark = T_remark } if len(T_project) > 0 { stockOut.T_project = T_project } if T_delivery_type > 0 { stockOut.T_delivery_type = T_delivery_type } if len(T_signer_unit) > 0 { stockOut.T_signer_unit = T_signer_unit } if len(T_signer) > 0 { stockOut.T_signer = T_signer } if len(T_signer_phone) > 0 { stockOut.T_signer_phone = T_signer_phone } if len(T_signer_date) > 0 { stockOut.T_signer_date = T_signer_date } if len(T_courier_number) > 0 { stockOut.T_courier_number = T_courier_number } err = StockOutDao.Update_StockOut(stockOut, "T_remark", "T_delivery_type", "T_signer_unit", "T_signer", "T_signer_phone", "T_signer_date", "T_courier_number", "T_project") if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "出库失败"} c.ServeJSON() return } NatsServer.AddUserLogs(c.User.T_uuid, "出库", "修改发货单", stockOut) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } func (c *StockController) StockOut_Edit() { T_number := c.GetString("T_number") // 出库单号 //T_depot_id, _ := c.GetInt("T_depot_id") T_date := c.GetString("T_date") T_receive := c.GetString("T_receive") T_project := c.GetString("T_project") T_product := c.GetString("T_product") T_remark := c.GetString("T_remark") date, is := lib.DateStrToTime(T_date) if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "日期格式错误!"} c.ServeJSON() return } if date.Year() != time.Now().Year() && date.Month() != time.Now().Month() { T_date = "" } NatsServer.AddUserLogs(c.User.T_uuid, "仓库管理", "修改出库", T_product) o := orm.NewOrm() o.Begin() StockOutDao := Stock.NewStockOut(o) StockOutProductDao := Stock.NewStockOutProduct(o) StockDao := Stock.NewStock(o) DeviceDao := Stock.NewDevice(o) // 查询出库信息 StockOut, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } T_old_date := StockOut.T_date // 查询出库产品信息 productOldList := StockOutProductDao.Read_StockOutProduct_List(StockOut.T_number) var oldProductList []dto.StockProduct var newProductList []dto.StockProduct productOldMap := map[int]dto.StockProduct{} allProductListMap := make(map[int]struct{}) for _, product := range productOldList { stockProduct := dto.StockProduct{ T_product_id: product.T_product_id, T_num: product.T_num, T_relation_sn: lib.SplitString(product.T_relation_sn, ","), } oldProductList = append(oldProductList, stockProduct) productOldMap[product.T_product_id] = stockProduct if _, ok := allProductListMap[product.T_product_id]; !ok { allProductListMap[product.T_product_id] = struct{}{} } } productNewList := lib.SplitString(T_product, "|") productNewMap := map[int]dto.StockProduct{} for _, v := range productNewList { product_id, _ := strconv.Atoi(strings.Split(v, "-")[0]) num, _ := strconv.Atoi(strings.Split(v, "-")[1]) T_relation_sn := strings.Split(v, "-")[2] snList := lib.SplitString(T_relation_sn, ",") if len(snList) > 0 { num = len(snList) } stockProduct := dto.StockProduct{ T_product_id: product_id, T_num: num, T_relation_sn: snList, } newProductList = append(newProductList, stockProduct) productNewMap[product_id] = stockProduct if _, ok := allProductListMap[product_id]; !ok { allProductListMap[product_id] = struct{}{} } } // 判断产品列表信息是否相同 StockProductListIsEqual, needDelete, needAdd, needEdit, snDiff := dto.StockProductListsEqual(oldProductList, newProductList) // 两次提交的数据相同，则不用修改 if !StockProductListIsEqual { if len(needDelete) > 0 { // 删除入库产品列表 for _, v := range needDelete { product, _ := Basic.Read_Product_ById(v.T_product_id) // 删除入库产品列表 err = StockOutProductDao.Delete_StockOutProduct(StockOut.T_number, StockOut.T_depot_id, v.T_product_id) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除产品入库信息失败!"} c.ServeJSON() return } if product.T_relation_sn == 1 { // 删除该入库单关联sn for _, sn := range v.T_relation_sn { err = DeviceDao.Delete_Device_ByT_out_number(StockOut.T_number, sn) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "删除入库设备失败"} c.ServeJSON() return } } } // 增加库存 _, err = StockDao.AddOrUpdate_Stock(StockOut.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, v.T_num, 2) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "更新库存信息失败"} c.ServeJSON() return } } } if len(needAdd) > 0 { // 新增入库产品列表 for _, v := range needAdd { product, _ := Basic.Read_Product_ById(v.T_product_id) if product.T_relation_sn == 1 && len(v.T_relation_sn) == 0 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s关联SN，请先添加SN！", product.T_name)} c.ServeJSON() return } // 添加该入库单关联sn for _, sn := range v.T_relation_sn { mqtt := Stock.Read_MqttUser(sn) // 添加设备 device := Stock.Device{ T_contract_number: "", T_out_number: StockOut.T_number, T_product_id: v.T_product_id, T_in_number: "", T_sn: sn, T_iccid: mqtt.Iccid, T_imei: mqtt.Imei, T_State: 1, CreateTime: date, UpdateTime: StockOut.UpdateTime, } _, err = DeviceDao.AddOrUpdate_Device(device, 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: sn + "入库失败"} c.ServeJSON() return } } StockOutProduct := Stock.StockOutProduct{ T_number: T_number, T_product_id: v.T_product_id, T_depot_id: StockOut.T_depot_id, T_num: v.T_num, // 入库数量 T_date: StockOut.T_date, // 入库日期 T_relation_sn: strings.Join(v.T_relation_sn, ","), T_state: 1, } _, err = StockOutProductDao.Add_StockOutProduct(StockOutProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "入库失败"} c.ServeJSON() return } // 减少库存 _, err = StockDao.AddOrUpdate_Stock(StockOut.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, v.T_num, 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "增加库存失败"} c.ServeJSON() return } } } if len(needEdit) > 0 { for _, v := range needEdit { product, _ := Basic.Read_Product_ById(v.T_product_id) StockOutProduct := Stock.StockOutProduct{ T_number: StockOut.T_number, T_product_id: v.T_product_id, T_depot_id: StockOut.T_depot_id, T_num: productNewMap[v.T_product_id].T_num, // 入库数量 T_date: StockOut.T_date, // 入库日期 T_state: 1, } // 出库数量比之前多，减少库存 var T_type int var T_num int if productNewMap[v.T_product_id].T_num > productOldMap[v.T_product_id].T_num { // 减少库存 T_type = 1 T_num = productNewMap[v.T_product_id].T_num - productOldMap[v.T_product_id].T_num } else { // 增加库存 T_type = 2 T_num = productOldMap[v.T_product_id].T_num - productNewMap[v.T_product_id].T_num } _, err = StockDao.AddOrUpdate_Stock(StockOut.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, T_num, T_type) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: err.Error()} c.ServeJSON() return } // 更新产品库存表 err = StockOutProductDao.Update_StockOutProduct(StockOutProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改出库产品信息失败"} c.ServeJSON() return } } } for _, diff := range snDiff { product, _ := Basic.Read_Product_ById(diff.T_product_id) // 删除减少的sn if len(diff.T_delete_relation_sn) > 0 { for _, sn := range diff.T_delete_relation_sn { err = DeviceDao.Delete_Device_ByT_out_number(StockOut.T_number, sn) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: err.Error()} c.ServeJSON() return } } // 增加库存 _, err = StockDao.AddOrUpdate_Stock(StockOut.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, len(diff.T_delete_relation_sn), 2) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: err.Error()} c.ServeJSON() return } } if len(diff.T_add_relation_sn) > 0 { for _, sn := range diff.T_add_relation_sn { mqtt := Stock.Read_MqttUser(sn) // 添加设备 device := Stock.Device{ T_contract_number: "", T_out_number: StockOut.T_number, T_product_id: diff.T_product_id, T_in_number: "", T_sn: sn, T_iccid: mqtt.Iccid, T_imei: mqtt.Imei, T_State: 1, CreateTime: date, UpdateTime: StockOut.UpdateTime, } _, err = DeviceDao.AddOrUpdate_Device(device, 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: sn + "入库失败"} c.ServeJSON() return } } // 减少库存 _, err = StockDao.AddOrUpdate_Stock(StockOut.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, len(diff.T_add_relation_sn), 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "入库失败"} c.ServeJSON() return } } StockOutProduct := Stock.StockOutProduct{ T_number: StockOut.T_number, T_product_id: diff.T_product_id, T_depot_id: StockOut.T_depot_id, T_num: productNewMap[diff.T_product_id].T_num, // 入库数量 T_date: StockOut.T_date, // 入库日期 T_relation_sn: strings.Join(productNewMap[diff.T_product_id].T_relation_sn, ","), T_state: 1, } // 更新产品库存表 err = StockOutProductDao.Update_StockOutProduct(StockOutProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改出库产品信息失败"} c.ServeJSON() return } } } StockOut.T_remark = T_remark if len(T_receive) > 0 { StockOut.T_receive = T_receive } if len(T_project) > 0 { StockOut.T_project = T_project } if len(T_date) > 0 { StockOut.T_date = T_date } err = StockOutDao.Update_StockOut(StockOut, "T_remark", "T_receive", "T_project", "T_date") if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改入库失败"} c.ServeJSON() return } o.Commit() if len(T_date) > 0 && T_old_date != T_date { // 修改出库产品日期 StockOutProductDao.Update_StockOutProduct_T_date(StockOut.T_number, T_date) DeviceDao.Update_Device_CreateTimeByT_out_number(StockOut.T_number, T_date) } if len(T_project) > 0 { DeviceDao.Update_Device_ByT_out_number_T_project(StockOut.T_number, T_project) } // 更新月份统计表 allProductList := []int{} for i, _ := range allProductListMap { allProductList = append(allProductList, i) } StockOut_Edit_StockMonth(StockOut.T_date, StockOut.T_depot_id, allProductList) NatsServer.AddUserLogs(c.User.T_uuid, "出库", "修改", StockOut) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } // 删除出库 func (c *StockController) StockOut_Del() { T_number := c.GetString("T_number") // 入库单号 o := orm.NewOrm() o.Begin() StockOutDao := Stock.NewStockOut(o) StockOutProductDao := Stock.NewStockOutProduct(o) StockDao := Stock.NewStock(o) DeviceDao := Stock.NewDevice(o) // 查询出库信息 stockOut, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } // 查询出库产品信息 productOldList := StockOutProductDao.Read_StockOutProduct_List(stockOut.T_number) var oldProductList []dto.StockProduct allProductList := []int{} for _, product := range productOldList { oldProductList = append(oldProductList, dto.StockProduct{ T_product_id: product.T_product_id, T_num: product.T_num, T_relation_sn: lib.SplitString(product.T_relation_sn, ","), }) allProductList = append(allProductList, product.T_product_id) } // 删除入库产品列表 for _, v := range oldProductList { product, _ := Basic.Read_Product_ById(v.T_product_id) // 删除入库产品列表 err = StockOutProductDao.Delete_StockOutProduct(stockOut.T_number, stockOut.T_depot_id, v.T_product_id) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除产品出库信息失败!"} c.ServeJSON() return } if product.T_relation_sn == 1 { // 删除该入库单关联sn for _, sn := range v.T_relation_sn { err = DeviceDao.Delete_Device_ByT_out_number(stockOut.T_number, sn) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "删除出库设备失败"} c.ServeJSON() return } } } // 增加库存 _, err = StockDao.AddOrUpdate_Stock(stockOut.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, v.T_num, 2) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "更新库存信息失败"} c.ServeJSON() return } } err = StockOutDao.Delete_StockOut(stockOut) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "删除出库失败"} c.ServeJSON() return } o.Commit() // 更新月份统计表 StockOut_Edit_StockMonth(stockOut.T_date, stockOut.T_depot_id, allProductList) NatsServer.AddUserLogs(c.User.T_uuid, "出库", "删除", stockOut) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } // 导出出库单 func (c *StockController) StockOut_Excel() { // 查询 T_number := c.GetString("T_number") o := orm.NewOrm() StockOutDao := Stock.NewStockOut(o) StockOutProductDao := Stock.NewStockOutProduct(o) stockOut, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err != nil { c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } productList := StockOutProductDao.Read_StockOutProduct_List(stockOut.T_number) //productList = append(productList, productList...) //productList = append(productList, productList...) //productList = append(productList, productList...) var pList []Stock.StockOutProduct_R for _, v := range productList { pList = append(pList, Stock.StockOutProductToStockOutProduct_R(v)) } userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) stockOutDetail := Stock.StockOutToStockOut_Detail(stockOut, pList) T_date, _ := lib.DateStrToTime(stockOut.T_date) filename := fmt.Sprintf("冷链产品出库单(%s)", lib.GetRandstring(6, "0123456789", 0)) f := excelize.NewFile() // 设置单元格的值 Style1, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 12, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"}, }) Style2, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 11, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "left", Vertical: "center"}, }) Style3, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 10, Family: "宋体", Bold: true}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) Style4, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 11, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) productList2 := lib.ChunkBy(productList, 10) for i, products := range productList2 { if len(products) < 10 { products = append(products, make([]Stock.StockOutProduct, 10-len(products))...) } row := i*17 + 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style1) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("宝智达科技产品进销存统计表")) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style1) title := "硬件出库单" if len(productList2) > 1 { title += fmt.Sprintf(" %d/%d", i+1, len(productList2)) } f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), title) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("出库单号：%s", stockOut.T_number)) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("项目名称：%s", stockOut.T_project)) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("领用时间：%s", T_date.Format("2006年01月02日"))) f.SetRowHeight("Sheet1", row, 20) // 这里设置表头 row += 1 f.SetRowHeight("Sheet1", row, 20) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), "序号") f.SetCellValue("Sheet1", fmt.Sprintf("B%d", row), "产品名称") f.SetCellValue("Sheet1", fmt.Sprintf("C%d", row), "型号") f.SetCellValue("Sheet1", fmt.Sprintf("D%d", row), "单位") f.SetCellValue("Sheet1", fmt.Sprintf("E%d", row), "领用数量") f.SetCellValue("Sheet1", fmt.Sprintf("F%d", row), "备注") // 设置列宽 f.SetColWidth("Sheet1", "A", "A", 5) f.SetColWidth("Sheet1", "B", "B", 20) f.SetColWidth("Sheet1", "C", "C", 12) f.SetColWidth("Sheet1", "D", "D", 10) f.SetColWidth("Sheet1", "E", "E", 10) f.SetColWidth("Sheet1", "F", "F", 15) f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row), Style3) sRow := row // 循环写入数据 for j, v := range products { row += 1 product, _ := Basic.Read_Product_ById(v.T_product_id) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), j+1) f.SetCellValue("Sheet1", fmt.Sprintf("B%d", row), product.T_name) f.SetCellValue("Sheet1", fmt.Sprintf("C%d", row), product.T_model) f.SetCellValue("Sheet1", fmt.Sprintf("D%d", row), product.T_spec) if v.T_num > 0 { f.SetCellValue("Sheet1", fmt.Sprintf("E%d", row), v.T_num) f.SetCellValue("Sheet1", fmt.Sprintf("F%d", row), stockOut.T_remark) } } f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", sRow), fmt.Sprintf("F%d", row), Style4) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("C%d", row)) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("制单：%s", c.User.T_name)) f.MergeCell("Sheet1", fmt.Sprintf("D%d", row), fmt.Sprintf("F%d", row)) f.SetCellValue("Sheet1", fmt.Sprintf("D%d", row), fmt.Sprintf("领用人：%s", stockOutDetail.T_receive_name)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetRowHeight("Sheet1", row, 20) } // 保存文件 if err = f.SaveAs("ofile/" + filename + ".xlsx"); err != nil { fmt.Println(err) } var url string //// 上传 OSS nats := natslibs.NewNats(Nats.Nats, conf.NatsSubj_Prefix) url, is := nats.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+filename+".xlsx", "ofile/"+filename+".xlsx") if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "oss!"} c.ServeJSON() return } //删除目录 err = os.Remove("ofile/" + filename + ".xlsx") if err != nil { logs.Error(lib.FuncName(), err) } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url} c.ServeJSON() return } func (c *StockController) StockOut_Excel_Batch() { // 查询 T_number_list := c.GetString("T_number_list") o := orm.NewOrm() StockOutDao := Stock.NewStockOut(o) StockOutProductDao := Stock.NewStockOutProduct(o) list := strings.Split(strings.Trim(T_number_list, "|"), "|") userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) filename := fmt.Sprintf("冷链产品出库单(%s)", lib.GetRandstring(6, "0123456789", 0)) f := excelize.NewFile() // 设置单元格的值 Style1, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 12, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"}, }) Style2, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 11, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "left", Vertical: "center"}, }) Style3, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 10, Family: "宋体", Bold: true}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) Style4, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 11, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) var num int for _, T_number := range list { stockOut, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err != nil { c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } productList := StockOutProductDao.Read_StockOutProduct_List(stockOut.T_number) var pList []Stock.StockOutProduct_R for _, v := range productList { pList = append(pList, Stock.StockOutProductToStockOutProduct_R(v)) } stockOutDetail := Stock.StockOutToStockOut_Detail(stockOut, pList) T_date, _ := lib.DateStrToTime(stockOut.T_date) productList2 := lib.ChunkBy(productList, 10) for i, products := range productList2 { if len(products) < 10 { products = append(products, make([]Stock.StockOutProduct, 10-len(products))...) } row := num*18 + 1 num += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style1) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("宝智达科技产品进销存统计表")) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style1) title := "硬件出库单" if len(productList2) > 1 { title += fmt.Sprintf(" %d/%d", i+1, len(productList2)) } f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), title) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("出库单号：%s", stockOut.T_number)) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("项目名称：%s", stockOut.T_project)) f.SetRowHeight("Sheet1", row, 20) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("领用时间：%s", T_date.Format("2006年01月02日"))) f.SetRowHeight("Sheet1", row, 20) // 这里设置表头 row += 1 f.SetRowHeight("Sheet1", row, 20) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), "序号") f.SetCellValue("Sheet1", fmt.Sprintf("B%d", row), "产品名称") f.SetCellValue("Sheet1", fmt.Sprintf("C%d", row), "型号") f.SetCellValue("Sheet1", fmt.Sprintf("D%d", row), "单位") f.SetCellValue("Sheet1", fmt.Sprintf("E%d", row), "领用数量") f.SetCellValue("Sheet1", fmt.Sprintf("F%d", row), "备注") // 设置列宽 f.SetColWidth("Sheet1", "A", "A", 5) f.SetColWidth("Sheet1", "B", "B", 20) f.SetColWidth("Sheet1", "C", "C", 12) f.SetColWidth("Sheet1", "D", "D", 10) f.SetColWidth("Sheet1", "E", "E", 10) f.SetColWidth("Sheet1", "F", "F", 15) f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row), Style3) sRow := row // 循环写入数据 for j, v := range products { row += 1 product, _ := Basic.Read_Product_ById(v.T_product_id) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), j+1) f.SetCellValue("Sheet1", fmt.Sprintf("B%d", row), product.T_name) f.SetCellValue("Sheet1", fmt.Sprintf("C%d", row), product.T_model) f.SetCellValue("Sheet1", fmt.Sprintf("D%d", row), product.T_spec) if v.T_num > 0 { f.SetCellValue("Sheet1", fmt.Sprintf("E%d", row), v.T_num) f.SetCellValue("Sheet1", fmt.Sprintf("F%d", row), stockOut.T_remark) } } f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", sRow), fmt.Sprintf("F%d", row), Style4) row += 1 f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("C%d", row)) f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("制单：%s", c.User.T_name)) f.MergeCell("Sheet1", fmt.Sprintf("D%d", row), fmt.Sprintf("F%d", row)) f.SetCellValue("Sheet1", fmt.Sprintf("D%d", row), fmt.Sprintf("领用人：%s", stockOutDetail.T_receive_name)) f.SetRowStyle("Sheet1", row, row, Style2) f.SetRowHeight("Sheet1", row, 20) // 空一行 row += 1 //f.MergeCell("Sheet1", fmt.Sprintf("A%d", row), fmt.Sprintf("F%d", row)) //f.SetRowStyle("Sheet1", row, row, Style1) //f.SetCellValue("Sheet1", fmt.Sprintf("A%d", row), "") // 插入下一页分页符 f.InsertPageBreak("Sheet1", fmt.Sprintf("A%d", row)) } } // 保存文件 if err := f.SaveAs("ofile/" + filename + ".xlsx"); err != nil { fmt.Println(err) } var url string //// 上传 OSS nats := natslibs.NewNats(Nats.Nats, conf.NatsSubj_Prefix) url, is := nats.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+filename+".xlsx", "ofile/"+filename+".xlsx") if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "oss!"} c.ServeJSON() return } //删除目录 err := os.Remove("ofile/" + filename + ".xlsx") if err != nil { logs.Error(lib.FuncName(), err) } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url} c.ServeJSON() return } func StockOut_Edit_StockMonth(T_date string, T_depot_id int, allProductList []int) error { date, _ := lib.DateStrToTime(T_date) //if date.Year() == time.Now().Year() && date.Month() == time.Now().Month() { // // 修改本月数据不同步库存 // return nil //} //T_month := date.Format("2006-01") months := generateMonthList(date, "out") o := orm.NewOrm() StockOutDao := Stock.NewStockOut(o) StockMonthDao := Stock.NewStockMonth(o) StockOutProductDao := Stock.NewStockOutProduct(o) StockInProductDao := Stock.NewStockInProduct(o) for _, T_product_id := range allProductList { for _, T_month := range months { // 获取当前产品本月出入库数量 lastMonth := StockMonthDao.Read_LastMonth_StockMonth_ByT_depot_id_T_product_id(T_depot_id, T_product_id, T_month) stockMonth := StockMonthDao.Read_StockMonth_ByT_depot_id_T_product_id(T_depot_id, T_product_id, T_month) if stockMonth.Id > 0 { // 修改 stockMonth.T_out = StockOutProductDao.Read_StockOut_Total(T_depot_id, T_product_id, T_month) stockMonth.T_return = StockInProductDao.Read_StockReturn_Total(T_depot_id, T_product_id, T_month) if len(lastMonth) > 0 { stockMonth.T_beginning = lastMonth[0].T_ending } else { stockMonth.T_beginning = 0 } // 期末库存 = 期初库存+入库-出库 stockMonth.T_ending = stockMonth.T_beginning + stockMonth.T_in - stockMonth.T_out err := StockMonthDao.Update_StockMonth(stockMonth, "T_out", "T_return", "T_beginning", "T_ending") if err != nil { return err } } else { product, _ := Basic.Read_Product_ById(T_product_id) // 添加库存记录 stockMonth = Stock.StockMonth{ T_depot_id: T_depot_id, T_product_id: T_product_id, T_product_class: product.T_class, T_month: T_month, } // 获取当前产品本月出入库数量 stockMonth.T_in = StockInProductDao.Read_StockIn_Total(T_depot_id, T_product_id, T_month) stockMonth.T_out = StockOutProductDao.Read_StockOut_Total(T_depot_id, T_product_id, T_month) stockMonth.T_return = StockInProductDao.Read_StockReturn_Total(T_depot_id, T_product_id, T_month) if len(lastMonth) > 0 { stockMonth.T_beginning = lastMonth[0].T_ending } else { stockMonth.T_beginning = 0 } // 期末库存 = 期初库存+入库-出库 stockMonth.T_ending = stockMonth.T_beginning + stockMonth.T_in - stockMonth.T_out stockMonth.T_project = StockOutDao.Read_StockOut_T_contract_number(T_depot_id, T_product_id, T_month) _, err := StockMonthDao.Add_StockMonth(stockMonth) if err != nil { return err } } } } return nil } func Cron_StockMonth() { //创建一个定时任务对象 c := cron.New(cron.WithSeconds()) //给对象增加定时任务 // @monthly 每月运行一次，每月第一天午夜 0 0 0 1 * * //c.AddFunc("0 */1 * * * ?", Cron_StockMonth_Add) c.AddFunc("@monthly", Cron_StockMonth_Add) //启动定时任务 c.Start() defer c.Stop() //查询语句，阻塞，让main函数不退出，保持程序运行 select {} } // 保存每月入库出库明细 func Cron_StockMonth_Add() { T_month := time.Now().Format("2006-01") //T_month := time.Now().AddDate(0, -1, 0).Format("2006-01") logs.Info("开始统计" + T_month + "库存明细数据") o := orm.NewOrm() StockDao := Stock.NewStock(o) StockOutDao := Stock.NewStockOut(o) StockMonthDao := Stock.NewStockMonth(o) StockOutProductDao := Stock.NewStockOutProduct(o) StockInProductDao := Stock.NewStockInProduct(o) stockList, _ := StockDao.Read_Stock_List(0, 0, "", "", 0, 9999) for _, stock := range stockList { lastMonth := StockMonthDao.Read_LastMonth_StockMonth_ByT_depot_id_T_product_id(stock.T_depot_id, stock.T_product_id, T_month) stockMonth := StockMonthDao.Read_StockMonth_ByT_depot_id_T_product_id(stock.T_depot_id, stock.T_product_id, T_month) if stockMonth.Id > 0 { // 修改 stockMonth.T_in = StockInProductDao.Read_StockIn_Total(stock.T_depot_id, stock.T_product_id, T_month) stockMonth.T_out = StockOutProductDao.Read_StockOut_Total(stock.T_depot_id, stock.T_product_id, T_month) stockMonth.T_return = StockInProductDao.Read_StockReturn_Total(stock.T_depot_id, stock.T_product_id, T_month) if len(lastMonth) > 0 { stockMonth.T_beginning = lastMonth[0].T_ending } else { stockMonth.T_beginning = 0 } // 期末库存 = 期初库存+入库-出库 stockMonth.T_ending = stockMonth.T_beginning + stockMonth.T_in - stockMonth.T_out err := StockMonthDao.Update_StockMonth(stockMonth, "T_in", "T_out", "T_beginning", "T_ending", "T_return") if err != nil { NatsServer.AddSysLogs("库存明细统计", fmt.Sprintf("库存明细统计失败%s:%d:%d", T_month, stock.T_depot_id, stock.T_product_id), stockMonth) } } else { stockMonth = Stock.StockMonth{ T_depot_id: stock.T_depot_id, T_product_id: stock.T_product_id, T_product_class: stock.T_product_class, T_month: T_month, } // 获取当前产品本月出入库数量 stockMonth.T_in = StockInProductDao.Read_StockIn_Total(stock.T_depot_id, stock.T_product_id, T_month) stockMonth.T_out = StockOutProductDao.Read_StockOut_Total(stock.T_depot_id, stock.T_product_id, T_month) if len(lastMonth) > 0 { stockMonth.T_beginning = lastMonth[0].T_ending } else { stockMonth.T_beginning = 0 } // 期末库存 = 期初库存+入库-出库 stockMonth.T_ending = stockMonth.T_beginning + stockMonth.T_in - stockMonth.T_out stockMonth.T_project = StockOutDao.Read_StockOut_T_contract_number(stock.T_depot_id, stock.T_product_id, T_month) _, err := StockMonthDao.Add_StockMonth(stockMonth) if err != nil { NatsServer.AddSysLogs("库存明细统计", fmt.Sprintf("库存明细统计失败%s:%d:%d", T_month, stock.T_depot_id, stock.T_product_id), stockMonth) } } } } func generateMonthList(startMonth time.Time, t_type string) []string { var months []string endMonth := time.Now() if t_type == "in" { endMonth = endMonth.AddDate(0, 1, 0) } for month := startMonth; month.Before(endMonth); month = month.AddDate(0, 1, 0) { months = append(months, month.Format("2006-01")) } return months } // 我的申请列表 func (c *StockController) StockOut_Apply_List() { // 分页参数 初始化 page, _ := c.GetInt("page") if page < 1 { page = 1 } page_z, _ := c.GetInt("page_z") if page_z < 1 { page_z = conf.Page_size } // 查询 T_depot_id, _ := c.GetInt("T_depot_id") T_state, _ := c.GetInt("T_state") T_contract_number := c.GetString("T_contract_number") T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") T_name := c.GetString("T_name") userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() StockOutDao := Stock.NewStockOut(orm.NewOrm()) R_List, R_cnt := StockOutDao.Read_StockOut_Audit_List(c.User.T_uuid, T_name, Stock.StockInTypeApply, T_state, T_depot_id, T_contract_number, T_start_date, T_end_date, page, page_z) var r_jsons lib.R_JSONS r_jsons.Num = R_cnt r_jsons.Data = R_List r_jsons.Page = page r_jsons.Page_size = int(math.Ceil(float64(R_cnt) / float64(page_z))) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } // 出库申请 func (c *StockController) StockOut_Apply() { rand_x := 0 T_number := "" o := orm.NewOrm() StockOutDao := Stock.NewStockOut(o) for true { T_number = "CK-" + lib.GetRandstring(8, "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789", int64(rand_x)) _, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err != nil && err.Error() == orm.ErrNoRows.Error() { break } rand_x += 1 } T_contract_number := c.GetString("T_contract_number") T_depot_id, _ := c.GetInt("T_depot_id") T_product := c.GetString("T_product") T_remark := c.GetString("T_remark") T_project := c.GetString("T_project") T_company_name := c.GetString("T_company_name") T_payment_method := c.GetString("T_payment_method") T_receive := c.GetString("T_receive") if len(T_company_name) == 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: "公司名称不能为空"} c.ServeJSON() return } if len(T_payment_method) == 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: "付款方式不能为空"} c.ServeJSON() return } if len(T_receive) == 0 { T_receive = c.User.T_uuid } var_ := Stock.StockOut{ T_number: T_number, T_contract_number: T_contract_number, T_depot_id: T_depot_id, T_type: 1, T_application_date: time.Now().Format("2006-01-02"), T_receive: T_receive, T_remark: T_remark, T_project: T_project, T_submit: c.User.T_uuid, T_state: Stock.StockOutWaitAudit, T_company_name: T_company_name, T_payment_method: T_payment_method, } o.Begin() StockOutProductDao := Stock.NewStockOutProduct(o) StockDao := Stock.NewStock(o) _, err := StockOutDao.Add_StockOut(var_) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "出库失败"} c.ServeJSON() return } // 1、添加出库单 if len(T_product) == 0 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "产品明细不能为空"} c.ServeJSON() return } productList := lib.SplitString(T_product, "|") allProductList := []int{} for _, v := range productList { product_id, _ := strconv.Atoi(strings.Split(v, "-")[0]) allProductList = append(allProductList, product_id) product, _ := Basic.Read_Product_ById(product_id) num, _ := strconv.Atoi(strings.Split(v, "-")[1]) if num == 0 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s出库数量不能为0！", product.T_name)} c.ServeJSON() return } // 2、添加出库产品清单 stockOutProduct := Stock.StockOutProduct{ T_number: T_number, T_product_id: product_id, T_depot_id: T_depot_id, T_num: num, // 出库数量 T_state: 2, } _, err = StockOutProductDao.Add_StockOutProduct(stockOutProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "申请出库失败"} c.ServeJSON() return } // 3、增加占用库存 _, err = StockDao.AddOrUpdate_Occupy_Stock(T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, num, 2) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "更新占用库存失败" + err.Error()} c.ServeJSON() return } } o.Commit() NatsServer.AddUserLogs(c.User.T_uuid, "出库申请", "出库申请", var_) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } // 修改出库申请 func (c *StockController) StockOut_Apply_Edit() { T_number := c.GetString("T_number") // 出库单号 //T_depot_id, _ := c.GetInt("T_depot_id") T_project := c.GetString("T_project") T_product := c.GetString("T_product") T_remark := c.GetString("T_remark") T_receive := c.GetString("T_receive") T_company_name := c.GetString("T_company_name") T_payment_method := c.GetString("T_payment_method") NatsServer.AddUserLogs(c.User.T_uuid, "仓库管理", "修改出库", T_product) o := orm.NewOrm() o.Begin() StockOutDao := Stock.NewStockOut(o) StockOutProductDao := Stock.NewStockOutProduct(o) StockDao := Stock.NewStock(o) // 查询入库信息 StockOut, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } if StockOut.T_state == Stock.StockOutAlreadyOut { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "当前出库单已出库，不能修改!"} c.ServeJSON() return } // 查询入库产品信息 productOldList := StockOutProductDao.Read_StockOutProduct_List(StockOut.T_number) var oldProductList []dto.StockProduct var newProductList []dto.StockProduct productOldMap := map[int]dto.StockProduct{} allProductListMap := make(map[int]struct{}) for _, product := range productOldList { stockProduct := dto.StockProduct{ T_product_id: product.T_product_id, T_num: product.T_num, T_relation_sn: lib.SplitString(product.T_relation_sn, ","), } oldProductList = append(oldProductList, stockProduct) productOldMap[product.T_product_id] = stockProduct if _, ok := allProductListMap[product.T_product_id]; !ok { allProductListMap[product.T_product_id] = struct{}{} } if StockOut.T_state != Stock.StockOutAuditManagerUnPass && StockOut.T_state != Stock.StockOutAuditFinanceUnPass { // 减少占用库存 product2, _ := Basic.Read_Product_ById(product.T_product_id) _, err = StockDao.AddOrUpdate_Occupy_Stock(StockOut.T_depot_id, product2.Id, product2.T_class, product2.T_name, product2.T_model, product.T_num, 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "更新占用库存失败"} c.ServeJSON() return } } } productNewList := lib.SplitString(T_product, "|") productNewMap := map[int]dto.StockProduct{} for _, v := range productNewList { product_id, _ := strconv.Atoi(strings.Split(v, "-")[0]) product, _ := Basic.Read_Product_ById(product_id) num, _ := strconv.Atoi(strings.Split(v, "-")[1]) if num == 0 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s出库数量不能为0！", product.T_name)} c.ServeJSON() return } T_relation_sn := strings.Split(v, "-")[2] stockProduct := dto.StockProduct{ T_product_id: product_id, T_num: num, T_relation_sn: lib.SplitString(T_relation_sn, ","), } newProductList = append(newProductList, stockProduct) productNewMap[product_id] = stockProduct if _, ok := allProductListMap[product_id]; !ok { allProductListMap[product_id] = struct{}{} } // 增加占用库存 _, err = StockDao.AddOrUpdate_Occupy_Stock(StockOut.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, num, 2) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "更新占用库存失败"} c.ServeJSON() return } } // 判断产品列表信息是否相同 StockProductListIsEqual, needDelete, needAdd, needEdit, _ := dto.StockProductListsEqual(oldProductList, newProductList) // 两次提交的数据相同，则不用修改 if !StockProductListIsEqual { if len(needDelete) > 0 { // 删除入库产品列表 for _, v := range needDelete { // 删除入库产品列表 err = StockOutProductDao.Delete_StockOutProduct(StockOut.T_number, StockOut.T_depot_id, v.T_product_id) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除产品入库信息失败!"} c.ServeJSON() return } } } if len(needAdd) > 0 { // 新增入库产品列表 for _, v := range needAdd { StockOutProduct := Stock.StockOutProduct{ T_number: T_number, T_product_id: v.T_product_id, T_depot_id: StockOut.T_depot_id, T_num: v.T_num, // 出库数量 T_state: 1, } _, err = StockOutProductDao.Add_StockOutProduct(StockOutProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "入库失败"} c.ServeJSON() return } } } if len(needEdit) > 0 { for _, v := range needEdit { StockOutProduct := Stock.StockOutProduct{ T_number: StockOut.T_number, T_product_id: v.T_product_id, T_depot_id: StockOut.T_depot_id, T_num: productNewMap[v.T_product_id].T_num, // 入库数量 T_state: 1, } // 更新产品表 err = StockOutProductDao.Update_StockOutProduct(StockOutProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改出库产品信息失败"} c.ServeJSON() return } } } } StockOut.T_remark = T_remark if len(T_project) > 0 { StockOut.T_project = T_project } if len(T_company_name) > 0 { StockOut.T_company_name = T_company_name } if len(T_payment_method) > 0 { StockOut.T_payment_method = T_payment_method } if len(T_receive) > 0 { StockOut.T_receive = T_receive } StockOut.T_state = Stock.StockOutWaitAudit err = StockOutDao.Update_StockOut(StockOut, "T_remark", "T_receive", "T_project", "T_company_name", "T_payment_method", "T_state") if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改入库失败"} c.ServeJSON() return } o.Commit() NatsServer.AddUserLogs(c.User.T_uuid, "出库申请", "修改", StockOut) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } // 删除出库申请 func (c *StockController) StockOut_Apply_Del() { T_number := c.GetString("T_number") // 入库单号 o := orm.NewOrm() o.Begin() StockOutDao := Stock.NewStockOut(o) StockOutProductDao := Stock.NewStockOutProduct(o) StockDao := Stock.NewStock(o) // 查询出库信息 stockOut, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } // 查询出库产品信息 productOldList := StockOutProductDao.Read_StockOutProduct_List(stockOut.T_number) var oldProductList []dto.StockProduct allProductList := []int{} for _, product := range productOldList { oldProductList = append(oldProductList, dto.StockProduct{ T_product_id: product.T_product_id, T_num: product.T_num, T_relation_sn: lib.SplitString(product.T_relation_sn, ","), }) allProductList = append(allProductList, product.T_product_id) } // 删除入库产品列表 for _, v := range oldProductList { product, _ := Basic.Read_Product_ById(v.T_product_id) // 删除入库产品列表 err = StockOutProductDao.Delete_StockOutProduct(stockOut.T_number, stockOut.T_depot_id, v.T_product_id) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除产品出库信息失败!"} c.ServeJSON() return } // 减少占用库存 _, err = StockDao.AddOrUpdate_Occupy_Stock(stockOut.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, v.T_num, 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "更新占用库存失败" + err.Error()} c.ServeJSON() return } } err = StockOutDao.Delete_StockOut(stockOut) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "删除出库失败"} c.ServeJSON() return } o.Commit() NatsServer.AddUserLogs(c.User.T_uuid, "出库申请", "删除", stockOut) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } // 财务 func (c *StockController) StockOut_Finance_List() { // 分页参数 初始化 page, _ := c.GetInt("page") if page < 1 { page = 1 } page_z, _ := c.GetInt("page_z") if page_z < 1 { page_z = conf.Page_size } // 查询 T_depot_id, _ := c.GetInt("T_depot_id") T_state, _ := c.GetInt("T_state") T_contract_number := c.GetString("T_contract_number") T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") T_name := c.GetString("T_name") userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() StockOutDao := Stock.NewStockOut(orm.NewOrm()) R_List, R_cnt := StockOutDao.Read_StockOut_Audit_List("", T_name, Stock.StockOutTypeFinance, T_state, T_depot_id, T_contract_number, T_start_date, T_end_date, page, page_z) var r_jsons lib.R_JSONS r_jsons.Num = R_cnt r_jsons.Data = R_List r_jsons.Page = page r_jsons.Page_size = int(math.Ceil(float64(R_cnt) / float64(page_z))) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } // 管理员 func (c *StockController) StockOut_Manager_List() { // 分页参数 初始化 page, _ := c.GetInt("page") if page < 1 { page = 1 } page_z, _ := c.GetInt("page_z") if page_z < 1 { page_z = conf.Page_size } // 查询 T_depot_id, _ := c.GetInt("T_depot_id") T_state, _ := c.GetInt("T_state") T_contract_number := c.GetString("T_contract_number") T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") T_name := c.GetString("T_name") userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() StockOutDao := Stock.NewStockOut(orm.NewOrm()) R_List, R_cnt := StockOutDao.Read_StockOut_Audit_List("", T_name, Stock.StockOutTypeManager, T_state, T_depot_id, T_contract_number, T_start_date, T_end_date, page, page_z) var r_jsons lib.R_JSONS r_jsons.Num = R_cnt r_jsons.Data = R_List r_jsons.Page = page r_jsons.Page_size = int(math.Ceil(float64(R_cnt) / float64(page_z))) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } // 仓管 func (c *StockController) StockOut_Warehouse_List() { // 分页参数 初始化 page, _ := c.GetInt("page") if page < 1 { page = 1 } page_z, _ := c.GetInt("page_z") if page_z < 1 { page_z = conf.Page_size } // 查询 T_depot_id, _ := c.GetInt("T_depot_id") T_state, _ := c.GetInt("T_state") T_contract_number := c.GetString("T_contract_number") T_start_date := c.GetString("T_start_date") T_end_date := c.GetString("T_end_date") T_name := c.GetString("T_name") userList, _ := NatsServer.Read_User_List_All() Account.Read_User_All_Map(userList) Basic.Read_Depot_All_Map() StockOutDao := Stock.NewStockOut(orm.NewOrm()) R_List, R_cnt := StockOutDao.Read_StockOut_Audit_List(c.User.T_uuid, T_name, Stock.StockOutTypeWarehouse, T_state, T_depot_id, T_contract_number, T_start_date, T_end_date, page, page_z) var r_jsons lib.R_JSONS r_jsons.Num = R_cnt r_jsons.Data = R_List r_jsons.Page = page r_jsons.Page_size = int(math.Ceil(float64(R_cnt) / float64(page_z))) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } // 财务/总经理审核 func (c *StockController) StockOut_Audit() { T_number := c.GetString("T_number") // 出库单号 //T_depot_id, _ := c.GetInt("T_depot_id") T_audit, _ := c.GetInt("T_audit") // 审核 2财务通过 3财务不通过 4总经理通过 5总经理不通过 6已出库 T_approval_opinion := c.GetString("T_approval_opinion") // 审批意见 T_approval_img := c.GetString("T_approval_img") // 审批意见 T_type := c.GetString("T_type") // 类型 Finance Manager o := orm.NewOrm() o.Begin() StockOutDao := Stock.NewStockOut(o) StockDao := Stock.NewStock(o) StockOutProductDao := Stock.NewStockOutProduct(o) StockOut, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } StockOut.T_state = T_audit if T_type == Stock.StockOutTypeFinance { StockOut.T_finance_approval_opinion = T_approval_opinion StockOut.T_finance_approval_img = T_approval_img } else { StockOut.T_manager_approval_opinion = T_approval_opinion StockOut.T_manager_approval_img = T_approval_img } if T_audit == Stock.StockOutAuditFinanceUnPass || T_audit == Stock.StockOutAuditManagerUnPass { productList := StockOutProductDao.Read_StockOutProduct_List(StockOut.T_number) for _, v := range productList { product, _ := Basic.Read_Product_ById(v.T_product_id) _, err = StockDao.AddOrUpdate_Occupy_Stock(StockOut.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, v.T_num, 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: err.Error()} c.ServeJSON() return } } } err = StockOutDao.Update_StockOut(StockOut, "T_state", "T_finance_approval_opinion", "T_manager_approval_opinion", "T_finance_approval_img", "T_manager_approval_img") if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "出库审批失败"} c.ServeJSON() return } o.Commit() NatsServer.AddUserLogs(c.User.T_uuid, "出库申请", "审批", StockOut) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } // 仓管出库 func (c *StockController) StockOut_Warehouse() { T_number := c.GetString("T_number") // 出库单号 T_date := c.GetString("T_date") date, is := lib.DateStrToTime(T_date) if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "日期格式错误!"} c.ServeJSON() return } NatsServer.AddUserLogs(c.User.T_uuid, "仓库管理", "确认出库", T_number) o := orm.NewOrm() o.Begin() StockOutDao := Stock.NewStockOut(o) StockOutProductDao := Stock.NewStockOutProduct(o) DeviceDao := Stock.NewDevice(o) StockDao := Stock.NewStock(o) // 查询入库信息 StockOut, err := StockOutDao.Read_StockOut_ByT_number(T_number) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"} c.ServeJSON() return } T_product := c.GetString("T_product") productList := lib.SplitString(T_product, "|") allProductList := []int{} for _, v := range productList { product_id, _ := strconv.Atoi(strings.Split(v, "-")[0]) allProductList = append(allProductList, product_id) product, _ := Basic.Read_Product_ById(product_id) num, _ := strconv.Atoi(strings.Split(v, "-")[1]) if num == 0 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s出库数量不能为0！", product.T_name)} c.ServeJSON() return } T_relation_sn := strings.Split(v, "-")[2] if T_relation_sn == "" && product.T_relation_sn == 1 { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s关联SN，请先添加SN！", product.T_name)} c.ServeJSON() return } if len(T_relation_sn) > 0 { snList := strings.Split(T_relation_sn, ",") if product.T_relation_sn == 1 && num != len(snList) { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s SN数量与出库数量不一致，请核查！", product.T_name)} c.ServeJSON() return } if len(snList) > 0 { for _, sn := range snList { mqtt := Stock.Read_MqttUser(sn) // 根据IMEI查询上次入库的批次号 batchNumber, err := DeviceDao.Read_Device_BatchNumber_ByImei(mqtt.Imei) if err != nil { logs.Error(lib.FuncName(), err) } device := Stock.Device{ T_contract_number: StockOut.T_contract_number, T_product_id: product_id, T_out_number: T_number, T_sn: sn, T_iccid: mqtt.Iccid, T_imei: mqtt.Imei, T_State: 1, T_project: StockOut.T_project, T_batch_number: batchNumber, CreateTime: date, } _, err = DeviceDao.AddOrUpdate_Device(device, 1) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 202, Msg: "出库失败"} c.ServeJSON() return } } } } // 3、添加出库产品清单 stockOutProduct := Stock.StockOutProduct{ T_number: T_number, T_product_id: product_id, T_depot_id: StockOut.T_depot_id, T_num: num, // 出库数量 T_date: T_date, // 出库日期 T_relation_sn: T_relation_sn, T_state: 1, } // 更新产品表 err = StockOutProductDao.Update_StockOutProduct(stockOutProduct) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改出库产品信息失败"} c.ServeJSON() return } // 5、更新产品库存列表、占用库存 _, err = StockDao.Stock_Warehouse(StockOut.T_depot_id, product.Id, product.T_class, product.T_name, product.T_model, num) if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: err.Error()} c.ServeJSON() return } } StockOut.T_warehouse = c.User.T_uuid StockOut.T_state = Stock.StockOutAlreadyOut StockOut.T_date = T_date err = StockOutDao.Update_StockOut(StockOut, "T_state", "T_date", "T_warehouse") if err != nil { o.Rollback() c.Data["json"] = lib.JSONS{Code: 203, Msg: "出库审批失败"} c.ServeJSON() return } o.Commit() StockOut_Edit_StockMonth(StockOut.T_date, StockOut.T_depot_id, allProductList) NatsServer.AddUserLogs(c.User.T_uuid, "出库申请", "出库", StockOut) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_number} c.ServeJSON() return } // StockMonth_Update_Return 批量更新所有StockMonth的退库数据 func (c *StockController) StockMonth_Update_Return() { // 可选参数：指定仓库和时间范围 T_depot_id, _ := c.GetInt("T_depot_id") T_start_date := c.GetString("T_start_date") // 格式：2024-01 T_end_date := c.GetString("T_end_date") // 格式：2024-12 // 调用后台更新函数 count, err := UpdateAllStockMonthReturn(T_depot_id, T_start_date, T_end_date) if err != nil { c.Data["json"] = lib.JSONS{Code: 203, Msg: fmt.Sprintf("更新失败：%v", err)} c.ServeJSON() return } NatsServer.AddUserLogs(c.User.T_uuid, "库存月度统计", "批量更新退库数据", fmt.Sprintf("更新了%d条记录", count)) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: fmt.Sprintf("成功更新%d条记录", count)} c.ServeJSON() } // UpdateAllStockMonthReturn 批量更新所有StockMonth记录的退库数量 // T_depot_id: 仓库ID，0表示所有仓库 // T_start_date: 开始月份，格式：2024-01，为空则不限制 // T_end_date: 结束月份，格式：2024-12，为空则不限制 func UpdateAllStockMonthReturn(T_depot_id int, T_start_date, T_end_date string) (count int, err error) { o := orm.NewOrm() StockMonthDao := Stock.NewStockMonth(o) StockInProductDao := Stock.NewStockInProduct(o) // 读取所有StockMonth记录 allStockMonths, err := StockMonthDao.Read_All_StockMonth() if err != nil { logs.Error(lib.FuncName(), err) return 0, err } count = 0 for _, stockMonth := range allStockMonths { // 如果指定了仓库ID，则过滤 if T_depot_id > 0 && stockMonth.T_depot_id != T_depot_id { continue } // 如果指定了开始月份，则过滤 if len(T_start_date) > 0 && stockMonth.T_month < T_start_date { continue } // 如果指定了结束月份，则过滤 if len(T_end_date) > 0 && stockMonth.T_month > T_end_date { continue } // 查询该产品在该月份的退库数量 returnTotal := StockInProductDao.Read_StockReturn_Total(stockMonth.T_depot_id, stockMonth.T_product_id, stockMonth.T_month) // 如果退库数量与原值不同，则更新 if stockMonth.T_return != returnTotal { stockMonth.T_return = returnTotal err = StockMonthDao.Update_StockMonth(stockMonth, "T_return") if err != nil { logs.Error(lib.FuncName(), fmt.Sprintf("更新失败：仓库%d，产品%d，月份%s", stockMonth.T_depot_id, stockMonth.T_product_id, stockMonth.T_month), err) continue } count++ } } logs.Info(fmt.Sprintf("批量更新退库数据完成，共更新%d条记录", count)) return count, nil } // Company_Device_Statistics 查询公司借出和退回设备统计 func (c *StockController) Company_Device_Statistics() { // 查询参数（对前端返回扁平化分组列表，不再返回分页包装） T_company_name := c.GetString("T_company_name") // 公司名称 T_depot_id, _ := c.GetInt("T_depot_id") // 仓库ID T_start_date := c.GetString("T_start_date") // 开始日期 T_end_date := c.GetString("T_end_date") // 结束日期 StockOutDao := Stock.NewStockOut(orm.NewOrm()) R_List, _ := StockOutDao.Read_Company_Device_Statistics(T_company_name, T_start_date, T_end_date, T_depot_id, 1, 9999) // 1) 先按公司分组并排序，顺序与导出一致 companyMap := make(map[string][]Stock.CompanyDeviceStatistics) for _, stat := range R_List { if len(stat.T_stock_out_list) == 0 { continue } companyMap[stat.T_company_name] = append(companyMap[stat.T_company_name], stat) } companyNames := make([]string, 0, len(companyMap)) for name := range companyMap { companyNames = append(companyNames, name) } sort.Strings(companyNames) // 2) 构造前端友好的结构：按公司返回 rows 列表 + 汇总 type RowItem struct { Seq int `json:"seq"` OutNumber string `json:"out_number"` ProductName string `json:"product_name"` DeviceSN string `json:"device_sn"` Num int `json:"num"` Unit string `json:"unit"` Remark string `json:"remark"` ReturnNumber string `json:"return_number"` ReturnDeviceSN string `json:"return_device_sn"` ReturnRemark string `json:"return_remark"` } type CompanyBlock struct { CompanyName string `json:"company_name"` StatisticDateLabel string `json:"statistic_date_label"` OutTotal int `json:"out_total"` ReturnTotal int `json:"return_total"` Rows []RowItem `json:"rows"` } resp := make([]CompanyBlock, 0, len(companyNames)) for _, companyName := range companyNames { statList := companyMap[companyName] // 构建退库 SN -> 信息 的映射 type ReturnInfo struct { ReturnNumber string SN string Num int Unit string Total float64 Remark string } returnSNMap := make(map[string]ReturnInfo) for _, stat := range statList { for _, ret := range stat.T_stock_return_list { for _, sn := range ret.T_device_list { if len(sn) > 0 { returnSNMap[sn] = ReturnInfo{ ReturnNumber: ret.T_stock_return_number, SN: sn, Num: ret.T_num, Unit: ret.T_unit, Total: ret.T_total, Remark: ret.T_remark, } } } } } seqNo := 1 cumulativeOutTotal := 0 cumulativeReturnTotal := 0 rows := make([]RowItem, 0) for _, stat := range statList { for _, out := range stat.T_stock_out_list { validSNs := make([]string, 0) for _, sn := range out.T_device_list { if len(sn) > 0 { validSNs = append(validSNs, sn) } } if len(validSNs) == 0 { continue } cumulativeOutTotal += out.T_num currentReturnNum := 0 returnRemark := "" for _, sn := range validSNs { if retInfo, exists := returnSNMap[sn]; exists { currentReturnNum++ if len(returnRemark) == 0 { returnRemark = retInfo.Remark } } } cumulativeReturnTotal += currentReturnNum for idx, sn := range validSNs { row := RowItem{ DeviceSN: sn, } if retInfo, ok := returnSNMap[sn]; ok { row.ReturnDeviceSN = sn row.ReturnNumber = retInfo.ReturnNumber } if idx == 0 { row.Seq = seqNo row.ProductName = out.T_product_name row.OutNumber = stat.T_stock_out_number row.Num = out.T_num row.Unit = out.T_unit row.Remark = out.T_remark if len(returnRemark) > 0 { row.ReturnRemark = returnRemark } } rows = append(rows, row) } seqNo++ } } resp = append(resp, CompanyBlock{ OutTotal: cumulativeOutTotal, ReturnTotal: cumulativeReturnTotal, Rows: rows, }) } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: resp} c.ServeJSON() return } // Company_Device_Statistics_Excel 导出公司借出和退回设备统计Excel func (c *StockController) Company_Device_Statistics_Excel() { // 查询参数 T_company_name := c.GetString("T_company_name") // 公司名称 T_depot_id, _ := c.GetInt("T_depot_id") // 仓库ID T_start_date := c.GetString("T_start_date") // 开始日期 T_end_date := c.GetString("T_end_date") // 结束日期 StockOutDao := Stock.NewStockOut(orm.NewOrm()) R_List, _ := StockOutDao.Read_Company_Device_Statistics(T_company_name, T_start_date, T_end_date, T_depot_id, 1, 9999) // 生成Excel文件名 filename := fmt.Sprintf("公司设备借出退回统计(%s)", lib.GetRandstring(6, "0123456789", 0)) // 创建Excel文件 f := excelize.NewFile() // 设置样式 StyleTitle, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 14, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"}, }) StyleHeader, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Bold: true, Size: 10, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, Fill: excelize.Fill{Type: "pattern", Color: []string{"#E0E0E0"}, Pattern: 1}, }) StyleCell, _ := f.NewStyle( &excelize.Style{ Font: &excelize.Font{Size: 10, Family: "宋体"}, Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true}, 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}, }, }) currentRow := 1 sheetName := "Sheet1" // 按公司名称分组数据 companyMap := make(map[string][]Stock.CompanyDeviceStatistics) for _, stat := range R_List { if len(stat.T_stock_out_list) == 0 { continue } companyMap[stat.T_company_name] = append(companyMap[stat.T_company_name], stat) } // 提取并排序公司名称，确保导出顺序稳定 companyNames := make([]string, 0, len(companyMap)) for name := range companyMap { companyNames = append(companyNames, name) } sort.Strings(companyNames) // 按排序后的公司名称遍历 for _, companyName := range companyNames { statList := companyMap[companyName] // 合并标题行 f.MergeCell(sheetName, fmt.Sprintf("A%d", currentRow), fmt.Sprintf("L%d", currentRow)) f.SetCellValue(sheetName, fmt.Sprintf("A%d", currentRow), "出库申请单/退库单") f.SetCellStyle(sheetName, fmt.Sprintf("A%d", currentRow), fmt.Sprintf("L%d", currentRow), StyleTitle) f.SetRowHeight(sheetName, currentRow, 25) currentRow++ // 出库信息行 f.MergeCell(sheetName, fmt.Sprintf("A%d", currentRow), fmt.Sprintf("H%d", currentRow)) f.SetCellValue(sheetName, fmt.Sprintf("A%d", currentRow), "公司名称："+companyName) f.MergeCell(sheetName, fmt.Sprintf("I%d", currentRow), fmt.Sprintf("L%d", currentRow)) f.SetCellValue(sheetName, fmt.Sprintf("I%d", currentRow), "") f.SetCellStyle(sheetName, fmt.Sprintf("A%d", currentRow), fmt.Sprintf("L%d", currentRow), StyleCell) currentRow++ // 日期行 f.MergeCell(sheetName, fmt.Sprintf("A%d", currentRow), fmt.Sprintf("H%d", currentRow)) f.SetCellValue(sheetName, fmt.Sprintf("A%d", currentRow), "统计日期："+time.Now().Format("2006-01-02")) f.MergeCell(sheetName, fmt.Sprintf("I%d", currentRow), fmt.Sprintf("L%d", currentRow)) f.SetCellValue(sheetName, fmt.Sprintf("I%d", currentRow), "") f.SetCellStyle(sheetName, fmt.Sprintf("A%d", currentRow), fmt.Sprintf("L%d", currentRow), StyleCell) currentRow++ // 表头（增加出库单号和退库单号列） headers := []string{"序号", "出库单号", "品名", "设备编号", "数量", "单位", "累计", "备注", "退库单号", "退库设备编号", "累计", "备注"} for i, header := range headers { cell := fmt.Sprintf("%s%d", string(rune('A'+i)), currentRow) f.SetCellValue(sheetName, cell, header) f.SetCellStyle(sheetName, cell, cell, StyleHeader) } currentRow++ // 构建出库SN到退库信息的映射（包含退库单号） type ReturnInfo struct { ReturnNumber string // 退库单号 SN string Num int Unit string Total float64 Remark string } returnSNMap := make(map[string]ReturnInfo) // 出库SN -> 退库信息 // 收集该公司所有的退库信息 for _, stat := range statList { for _, ret := range stat.T_stock_return_list { for _, sn := range ret.T_device_list { if len(sn) > 0 { returnSNMap[sn] = ReturnInfo{ ReturnNumber: ret.T_stock_return_number, // 关联的退库单号 SN: sn, Num: ret.T_num, Unit: ret.T_unit, Total: ret.T_total, Remark: ret.T_remark, } } } } } // 遍历该公司所有出库单的出库明细，按SN展开 seqNo := 1 cumulativeOutTotal := 0 // 累计出库总数 cumulativeReturnTotal := 0 // 累计退库总数 cumulativeStartRow := currentRow // 记录每个出库单号的起始行和结束行，用于后续合并 type OutNumberRange struct { StartRow int EndRow int Number string } outNumberRanges := make([]OutNumberRange, 0) // 记录每个退库单号的起始行和结束行 type ReturnNumberRange struct { StartRow int EndRow int Number string } //returnNumberRanges := make([]ReturnNumberRange, 0) for _, stat := range statList { outNumberStartRow := currentRow // 记录当前出库单号的起始行 //hasReturnInThisOut := false // 标记当前出库单是否有退库 //returnNumberStartRow := currentRow for _, out := range stat.T_stock_out_list { // 过滤掉空的SN validSNs := make([]string, 0) for _, sn := range out.T_device_list { if len(sn) > 0 { validSNs = append(validSNs, sn) } } if len(validSNs) == 0 { continue } // 累加当前产品的出库数量 cumulativeOutTotal += out.T_num // 计算当前产品的退库数量和获取退库备注 currentReturnNum := 0 returnRemark := "" for _, sn := range validSNs { if retInfo, exists := returnSNMap[sn]; exists { currentReturnNum++ if len(returnRemark) == 0 { returnRemark = retInfo.Remark // 使用第一个退库记录的备注 } } } cumulativeReturnTotal += currentReturnNum // 标记该出库单是否有退库 //if currentReturnNum > 0 { // hasReturnInThisOut = true //} startRow := currentRow // 为每个SN创建一行 for idx, sn := range validSNs { // 出库单号（C列）和设备编号（D列） f.SetCellValue(sheetName, fmt.Sprintf("D%d", currentRow), sn) // 退库信息（如果该SN已退库，则显示） if retInfo, exists := returnSNMap[sn]; exists { f.SetCellValue(sheetName, fmt.Sprintf("J%d", currentRow), sn) // 退库设备编号 f.SetCellValue(sheetName, fmt.Sprintf("I%d", currentRow), retInfo.ReturnNumber) // 退库单号只在第一行显示 // if idx == 0 && currentReturnNum > 0 { // f.SetCellValue(sheetName, fmt.Sprintf("I%d", currentRow), retInfo.ReturnNumber) // } } // 只在第一行设置序号、品名、出库单号、数量、单位、累计、备注 if idx == 0 { f.SetCellValue(sheetName, fmt.Sprintf("A%d", currentRow), seqNo) f.SetCellValue(sheetName, fmt.Sprintf("C%d", currentRow), out.T_product_name) f.SetCellValue(sheetName, fmt.Sprintf("B%d", currentRow), stat.T_stock_out_number) // 出库单号 f.SetCellValue(sheetName, fmt.Sprintf("E%d", currentRow), out.T_num) f.SetCellValue(sheetName, fmt.Sprintf("F%d", currentRow), out.T_unit) //f.SetCellValue(sheetName, fmt.Sprintf("G%d", currentRow), cumulativeOutTotal) // 显示累计出库总数 f.SetCellValue(sheetName, fmt.Sprintf("H%d", currentRow), out.T_remark) // 退库数量、单位、累计合计、备注 if currentReturnNum > 0 { //f.SetCellValue(sheetName, fmt.Sprintf("K%d", currentRow), currentReturnNum) //f.SetCellValue(sheetName, fmt.Sprintf("L%d", currentRow), out.T_unit) //f.SetCellValue(sheetName, fmt.Sprintf("M%d", currentRow), cumulativeReturnTotal) // 显示累计退库总数 f.SetCellValue(sheetName, fmt.Sprintf("L%d", currentRow), returnRemark) // 显示退库备注 } } // 设置单元格样式 for col := 'A'; col <= 'L'; col++ { cell := fmt.Sprintf("%s%d", string(col), currentRow) f.SetCellStyle(sheetName, cell, cell, StyleCell) } currentRow++ } // 如果有多个SN，合并序号、品名、数量、单位、累计、备注列（出库单号C列和退库单号I列在外层统一合并） if len(validSNs) > 1 { endRow := currentRow - 1 f.MergeCell(sheetName, fmt.Sprintf("A%d", startRow), fmt.Sprintf("A%d", endRow)) f.MergeCell(sheetName, fmt.Sprintf("C%d", startRow), fmt.Sprintf("C%d", endRow)) f.MergeCell(sheetName, fmt.Sprintf("E%d", startRow), fmt.Sprintf("E%d", endRow)) f.MergeCell(sheetName, fmt.Sprintf("F%d", startRow), fmt.Sprintf("F%d", endRow)) f.MergeCell(sheetName, fmt.Sprintf("G%d", startRow), fmt.Sprintf("G%d", endRow)) f.MergeCell(sheetName, fmt.Sprintf("H%d", startRow), fmt.Sprintf("H%d", endRow)) } seqNo++ } // 记录当前出库单号的范围 if currentRow > outNumberStartRow { outNumberRanges = append(outNumberRanges, OutNumberRange{ StartRow: outNumberStartRow, EndRow: currentRow - 1, Number: stat.T_stock_out_number, }) } } // 合并相同出库单号的单元格（C列） for _, rng := range outNumberRanges { if rng.EndRow > rng.StartRow { f.MergeCell(sheetName, fmt.Sprintf("B%d", rng.StartRow), fmt.Sprintf("B%d", rng.EndRow)) } } // 合并相同退库单号的单元格（I列） // for _, rng := range returnNumberRanges { // if rng.EndRow > rng.StartRow { // f.MergeCell(sheetName, fmt.Sprintf("I%d", rng.StartRow), fmt.Sprintf("I%d", rng.EndRow)) // } // } // 合并出库累计 f.MergeCell(sheetName, fmt.Sprintf("G%d", cumulativeStartRow), fmt.Sprintf("G%d", currentRow-1)) f.SetCellValue(sheetName, fmt.Sprintf("G%d", cumulativeStartRow), cumulativeOutTotal) // 显示累计出库总数 // 合并退库累计 f.MergeCell(sheetName, fmt.Sprintf("K%d", cumulativeStartRow), fmt.Sprintf("K%d", currentRow-1)) f.SetCellValue(sheetName, fmt.Sprintf("K%d", cumulativeStartRow), cumulativeReturnTotal) // 显示累计退库总数 // 添加空行 currentRow++ } // 设置列宽（14列） f.SetColWidth(sheetName, "A", "A", 8) // 序号 f.SetColWidth(sheetName, "B", "B", 20) // 品名 f.SetColWidth(sheetName, "C", "C", 20) // 出库单号 f.SetColWidth(sheetName, "D", "D", 30) // 设备编号 f.SetColWidth(sheetName, "E", "F", 10) // 数量、单位 f.SetColWidth(sheetName, "G", "G", 12) // 累计 f.SetColWidth(sheetName, "H", "H", 20) // 备注 f.SetColWidth(sheetName, "I", "I", 20) // 退库单号 f.SetColWidth(sheetName, "J", "J", 30) // 退库设备编号 f.SetColWidth(sheetName, "K", "K", 12) // 累计 f.SetColWidth(sheetName, "L", "L", 20) // 备注 // 保存文件 filepath := "./ofile/" + filename + ".xlsx" if err := f.SaveAs(filepath); err != nil { logs.Error(lib.FuncName(), err) c.Data["json"] = lib.JSONS{Code: 201, Msg: "生成Excel失败"} c.ServeJSON() return } var url string //// 上传 OSS nats := natslibs.NewNats(Nats.Nats, conf.NatsSubj_Prefix) url, is := nats.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+filename+".xlsx", "ofile/"+filename+".xlsx") if !is { c.Data["json"] = lib.JSONS{Code: 202, Msg: "oss!"} c.ServeJSON() return } //删除目录 err := os.Remove("ofile/" + filename + ".xlsx") if err != nil { logs.Error(lib.FuncName(), err) } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url} c.ServeJSON() return } // Company_Name_List 获取所有出库的公司名称列表 func (c *StockController) Stock_Out_Company_Name_List() { T_name := c.GetString("T_name") // 公司名称（模糊查询） StockOutDao := Stock.NewStockOut(orm.NewOrm()) R_List, err := StockOutDao.Read_Company_Name_List(T_name) if err != nil { c.Data["json"] = lib.JSONS{Code: 201, Msg: "查询失败"} c.ServeJSON() return } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: R_List} c.ServeJSON() return } // Company_Name_List 获取所有出库的公司名称列表 func (c *StockController) Stock_Out_Project_List() { T_name := c.GetString("T_name") // 公司名称（模糊查询） StockOutDao := Stock.NewStockOut(orm.NewOrm()) R_List, err := StockOutDao.Read_Project_List(T_name) if err != nil { c.Data["json"] = lib.JSONS{Code: 201, Msg: "查询失败"} c.ServeJSON() return } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: R_List} c.ServeJSON() return }