Cold_GoodsOrder/controllers/Couriers.go

package controllers

import (
	"Cold_GoodsOrder/Nats/NatsServer"
	"Cold_GoodsOrder/conf"
	"Cold_GoodsOrder/lib"
	"Cold_GoodsOrder/models/Account"
	"Cold_GoodsOrder/models/Function"
	beego "github.com/beego/beego/v2/server/web"
	"math"
)

// CouriersController Handle
type CouriersController struct {
	beego.Controller
	User_r Account.User // 登陆的用户
	T_pid  int          // 公司id
}

func (c *CouriersController) Prepare() {
	c.User_r = *Account.User_r
	c.T_pid = *Account.T_pid
}

func (c *CouriersController) Couriers_List() {
	type R_JSONS struct {
		//必须的大写开头
		Data      []Function.CouriersR
		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
	}
	Name := c.GetString("T_name")

	r_jsons.Data, r_jsons.Num = Function.Read_Couriers_List(c.User_r.T_pid, page, page_z, Name)
	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 *CouriersController) CouriersAdd() {
	Phone := c.GetString("Phone")
	Name := c.GetString("T_name")
	var_ := Function.Couriers{
		UserId: c.User_r.T_pid,
		Phone:  Phone,
		Name:   Name,
	}
	id, err := Function.Add_Couriers(var_)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 301, Msg: "添加失败!"}
		c.ServeJSON()
		return
	}
	NatsServer.AddUserLogs(Account.User_r.T_uuid, "配送员管理", "添加", var_)
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: id}
	c.ServeJSON()
	return
}
func (c *CouriersController) CouriersGet() {

	id, _ := c.GetInt("T_id")
	r := Function.Read_Couriers_ById(id)
	// 记录不存在
	if r.Id == 0 {
		c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}
	if c.User_r.T_pid != r.UserId {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "没有权限!"}
		c.ServeJSON()
		return
	}
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Function.CouriersToCouriersR(r)}
	c.ServeJSON()
	return
}

func (c *CouriersController) CouriersEdit() {
	id, _ := c.GetInt("T_id")
	r := Function.Read_Couriers_ById(id)

	if r.Id == 0 {
		c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_id !"}
		c.ServeJSON()
		return
	}
	if c.User_r.T_pid != r.UserId {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "没有权限!"}
		c.ServeJSON()
		return
	}
	Phone := c.GetString("Phone")
	Name := c.GetString("T_name")

	if len(Phone) > 0 {
		r.Phone = Phone
	}
	if len(Name) > 0 {
		r.Name = Name
	}
	is := Function.Update_Couriers(r, "phone", "name")
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
		c.ServeJSON()
		return
	}
	NatsServer.AddUserLogs(Account.User_r.T_uuid, "配送员管理", "修改", r)
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}

func (c *CouriersController) CouriersDel() {
	id, _ := c.GetInt("T_id")
	r := Function.Read_Couriers_ById(id)

	if r.Id == 0 {
		c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_id !"}
		c.ServeJSON()
		return
	}
	if c.User_r.T_pid != r.UserId {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "没有权限!"}
		c.ServeJSON()
		return
	}
	if is := Function.Delete_Couriers(r); !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败!"}
		c.ServeJSON()
		return
	}
	NatsServer.AddUserLogs(Account.User_r.T_uuid, "配送员管理", "删除", r)

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