Browse Source

FIX:修改产品信息同步修改入库信息

zoie 10 months ago
parent
commit
afe8f5cfa9
3 changed files with 23 additions and 2 deletions
  1. 10 0
      controllers/Basic.go
  2. 3 2
      controllers/Stock.go
  3. 10 0
      models/Stock/Stock.go

+ 10 - 0
controllers/Basic.go

@@ -391,6 +391,16 @@ func (c *BasicController) Product_Edit() {
 		return
 	}
 
+	// 修改库存关联的产品信息
+	StockDao := Stock.NewStock(orm.NewOrm())
+	list, err := StockDao.Read_Stock_List_ByT_product_id(T_id)
+	for _, v := range list {
+		v.T_product_class = Product_r.T_class
+		v.T_product_name = Product_r.T_name
+		v.T_product_model = Product_r.T_model
+		StockDao.Update_Stock(v, "T_product_class", "T_product_name", "T_product_model")
+	}
+
 	NatsServer.AddUserLogs(c.User.T_uuid, "产品", "修改", Product_r)
 
 	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}

+ 3 - 2
controllers/Stock.go

@@ -409,6 +409,7 @@ func (c *StockController) StockIn_Add() {
 		c.ServeJSON()
 		return
 	}
+	NatsServer.AddUserLogs(c.User.T_uuid, "仓库管理", "入库", T_product)
 
 	var_ := Stock.StockIn{
 		T_number:   T_number,
@@ -448,7 +449,7 @@ func (c *StockController) StockIn_Add() {
 		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!")}
+			c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s关联SN,请先添加SN!", T_relation_sn)}
 			c.ServeJSON()
 			return
 		}
@@ -470,7 +471,7 @@ func (c *StockController) StockIn_Add() {
 				_, err = DeviceDao.AddOrUpdate_Device(device, 2)
 				if err != nil {
 					o.Rollback()
-					c.Data["json"] = lib.JSONS{Code: 202, Msg: "入库失败"}
+					c.Data["json"] = lib.JSONS{Code: 202, Msg: sn + "入库失败"}
 					c.ServeJSON()
 					return
 				}

+ 10 - 0
models/Stock/Stock.go

@@ -149,6 +149,16 @@ func (dao *StockDaoImpl) Read_Stock_ByT_depot_id_T_product_id(T_depot_id, T_prod
 	return
 }
 
+// 同步库存产品信息
+func (dao *StockDaoImpl) Read_Stock_List_ByT_product_id(T_product_id int) (r []Stock, err error) {
+	qs := dao.orm.QueryTable(new(Stock))
+	_, err = qs.Filter("T_product_id", T_product_id).All(&r)
+	if err != nil {
+		logs.Error(lib.FuncName(), err)
+	}
+	return
+}
+
 // 修改
 func (dao *StockDaoImpl) Update_Stock(m Stock, cols ...string) error {
 	_, err := dao.orm.Update(&m, cols...)