Cold_Api/controllers/Product.go

package controllers

import (
	"Cold_Api/Nats/NatsServer"
	"Cold_Api/conf"
	"Cold_Api/controllers/lib"
	"Cold_Api/models/Device"
	"Cold_Api/models/Product"
	"Cold_Api/models/System"
	beego "github.com/beego/beego/v2/server/web"
	"math"
	"strconv"
)

type ProductController struct {
	beego.Controller
}

func (c *ProductController) ProductUpgrade_List() {
	// 验证登录
	//b_, _ := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	//if !b_ {
	//	c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
	//	c.ServeJSON()
	//	return
	//}
	type R_JSONS struct {
		//必须的大写开头
		Data      []Product.ProductUpgrade_R
		Num       int64
		Page      int
		Page_size int
	}

	var r_jsons R_JSONS

	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_model := c.GetString("T_model")
	r_jsons.Data, r_jsons.Num = Product.Read_ProductUpgrade_List(T_model, page, page_z)
	r_jsons.Page = page
	r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}
func (c *ProductController) ProductUpgrade_T_model_List() {
	// 验证登录
	b_, _ := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !b_ {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
		c.ServeJSON()
		return
	}

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Product.Read_ProductUpgrade_T_model()}
	c.ServeJSON()
	return
}
func (c *ProductController) ProductUpgrade_Add() {
	// 验证登录
	b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !b_ {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
		c.ServeJSON()
		return
	}

	T_model := c.GetString("T_model")
	T_version := c.GetString("T_version")
	T_file := c.GetString("T_file")
	T_remarks := c.GetString("T_remarks")
	T_carryout, _ := c.GetInt("T_carryout")

	var_ := Product.ProductUpgrade{
		T_model:    T_model,
		T_version:  T_version,
		T_file:     T_file,
		T_remarks:  T_remarks,
		T_carryout: T_carryout,
	}

	Id, err := Product.Add_ProductUpgrade(var_)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "添加失败"}
		c.ServeJSON()
		return
	}

	deviceList := Device.Read_Device_List_ByT_model(T_model)

	for _, v := range deviceList {
		NatsServer.Up_ProductUpgrade(v.T_sn, T_version, T_file)
		System.Add_UserLogs_T(admin_r.T_uuid, "设备版本升级", "同步", "SN:"+v.T_sn+T_version+T_file)
	}

	System.Add_UserLogs_T(admin_r.T_uuid, "设备版本升级管理", "添加", var_)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Id}
	c.ServeJSON()
	return
}
func (c *ProductController) ProductUpgrade_Del() {
	// 验证登录
	b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !b_ {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
		c.ServeJSON()
		return
	}

	id, _ := c.GetInt("T_id")

	_, err := Product.Read_ProductUpgrade_ById(id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}

	if is := Product.Delete_ProductUpgrade_ById(id); !is {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "删除失败!"}
		c.ServeJSON()
		return
	}

	System.Add_UserLogs(admin_r.T_uuid, "设备版本升级管理", "删除", strconv.Itoa(id))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}