ops/gin_ops/routers/api_warehouses.go

package routers

import (
	"saas/models"
	"strconv"

	"github.com/gin-gonic/gin"
)

// 定义接收JSON数据的结构体
type Add_item_json struct {
	// 使用结构体标签指定JSON字段名
	WarehouseID uint    `json:"warehouse_id"`
	Name        string  `json:"item_name"`
	Info        string  `json:"item_info"`
	SN          string  `json:"item_sn"`
	Who         string  `json:"item_who"`
	Int         int     `json:"item_int"`
	Consts      float32 `json:"item_consts"`
}

func V1_warehouses_api(r *gin.RouterGroup) {
	var err_code = Error_code["api_ok"]
	var err_msg string

	r.POST("/create", func(ctx *gin.Context) {
		err_msg = "warehouses_api_err"
		err_code = Error_code[err_msg]
		//先判断是否已经登录
		//获取中间件处理的结果
		is_login, _ := ctx.Get("is_login")
		if is_login == true {
			user_info, _ := ctx.Get("user_info")

			//转换传进来的数据
			var jsonData map[string]interface{}
			if err := ctx.ShouldBindJSON(&jsonData); err == nil {
				//fmt.Println(jsonData)
				if jsonData["warehouses_name"].(string) != "" {
					warehouses_data := models.Warehouse{
						Name:         jsonData["warehouses_name"].(string),
						Info:         jsonData["warehouses_info"].(string),
						CreatorID:    user_info.(*models.User_info).UserID,
						Capacity:     0,
						UsedCapacity: 0,
						Location:     "local",
					}
					models.DB.Create(&warehouses_data) // 传入指针
					//fmt.Println(dberr.Error)
					err_msg = "api_ok"
					err_code = Error_code[err_msg]

				} else {
					err_msg = "warehouses_name_err"
					err_code = Error_code[err_msg]
				}
			} else {
				err_msg = "json_error"
				err_code = Error_code[err_msg]
			}

		} else {
			//fmt.Println("no loged")
			err_msg = "user_no_sign"
			err_code = Error_code[err_msg]
		}

		ctx.JSON(200, map[string]interface{}{
			"api":      "ok",
			"err_code": err_code,
			"err_msg":  err_msg,
		})

	})

	r.POST("/add_item", func(ctx *gin.Context) {
		err_msg = "warehouses_api_err"
		err_code = Error_code[err_msg]
		//先判断是否已经登录
		//获取中间件处理的结果
		is_login, _ := ctx.Get("is_login")
		if is_login == true {

			//转换传进来的数据
			var item Add_item_json
			if err := ctx.ShouldBindJSON(&item); err == nil {
				//先判断是否有权限

				//（还没弄）

				//后插入数据
				user_info_, _ := ctx.Get("user_info")
				user_info := user_info_.(*models.User_info)
				var add_item_temp models.WarehouseItem
				add_item_temp.CreatedByID = user_info.UserID
				add_item_temp.WarehouseID = item.WarehouseID
				add_item_temp.Name = item.Name
				add_item_temp.SerialNumber = item.SN
				add_item_temp.Description = item.Info
				add_item_temp.Destiny = item.Who
				add_item_temp.Quantity = item.Int
				add_item_temp.ItemValue = int(item.Consts * 100)
				//插入一条数据
				models.DB.Create(&add_item_temp)
				//更新仓库信息
				var seach_wh models.Warehouse
				seach_wh.ID = item.WarehouseID
				var out_wh models.Warehouse
				models.DB.Where(&seach_wh).First(&out_wh)
				out_wh.UsedCapacity += 1
				models.DB.Where(&seach_wh).Updates(&out_wh)

				err_msg = "api_ok"
				err_code = Error_code[err_msg]

			} else {
				err_msg = "json_error"
				err_code = Error_code[err_msg]
			}

		} else {
			//fmt.Println("no loged")
			err_msg = "user_no_sign"
			err_code = Error_code[err_msg]
		}

		ctx.JSON(200, map[string]interface{}{
			"api":      "ok",
			"err_code": err_code,
			"err_msg":  err_msg,
		})

	})

	r.GET("/get_items/:wh_id", func(ctx *gin.Context) {
		err_msg = "warehouses_api_err"
		err_code = Error_code[err_msg]
		var seachf []models.WarehouseItem
		//先判断是否已经登录
		//获取中间件处理的结果
		is_login, _ := ctx.Get("is_login")
		if is_login == true {
			id := ctx.Param("wh_id")
			id_int, err := strconv.ParseInt(id, 10, 0)
			if err == nil {
				if id_int > 0 {

					seachf = models.Warehouse_get_items_from_whid(uint(id_int))
					//fmt.Println(seachf)

					err_msg = "api_ok"
					err_code = Error_code[err_msg]

				} else {
					err_msg = "warehouses_id_err"
					err_code = Error_code[err_msg]
				}

			} else {
				err_msg = "warehouses_id_err"
				err_code = Error_code[err_msg]
			}

		} else {
			//fmt.Println("no loged")
			err_msg = "user_no_sign"
			err_code = Error_code[err_msg]
		}

		ctx.JSON(200, map[string]interface{}{
			"api":      "ok",
			"err_code": err_code,
			"err_msg":  err_msg,
			"data":     seachf,
		})
	})

}