package Function

import (
	"Cold_Api/conf"
	"Cold_Api/models/Device"
	"fmt"
	"github.com/beego/beego/v2/adapter/orm"
	orm2 "github.com/beego/beego/v2/client/orm"
	_ "github.com/go-sql-driver/mysql"
	"time"
)

// 模板
type GoodsOrder struct {
	Id int `orm:"column(ID);size(11);auto;pk"`
	//T_id   string `orm:"size(50);null"` // 订单唯一ID
	T_pid int `orm:"index;size(256);null"` // Account.Company 绑定公司

	T_orderid    string `orm:"size(256);null"` // 订单号
	T_outorderid string `orm:"size(256);null"` // 出库订单号
	T_sn         string `orm:"size(256);null"` // 设备sn
	//T_snid         int `orm:"size(256);0"` // 设备id
	T_receiving string `orm:"size(256);null"` // 收货单位

	T_start_Ut   time.Time `orm:"type(timestamp);null;"` // 起运时间
	T_start_Ut_T float32   `orm:"size(10);0;"`           // 起运温度
	T_end_Ut     time.Time `orm:"type(timestamp);null;"` // 到达时间
	T_end_Ut_T   float32   `orm:"size(10);0;"`           // 到达时间

	T_text string `orm:"type(text);null"` // 详情

	T_State    int       `orm:"size(2);1"`                                             // 0 删除   1 正常
	CreateTime time.Time `orm:"column(create_time);type(timestamp);null;auto_now_add"` //auto_now_add 第一次保存时才设置时间
	UpdateTime time.Time `orm:"column(update_time);type(timestamp);null;auto_now"`     //auto_now 每次 model 保存时都会对时间自动更新
}
type GoodsOrderR struct {
	Id           int       // ID
	T_orderid    string    // 订单号
	T_outorderid string    // 出库订单号
	T_name       string    // 设备名称
	T_sn         string    // 设备sn
	T_receiving  string    // 收货单位
	T_start_Ut   time.Time // 起运时间
	T_start_Ut_T float32   // 起运温度
	T_end_Ut     time.Time // 到达时间
	T_end_Ut_T   float32   // 到达时间
	T_text       string    // 详情

}

func (t *GoodsOrder) TableName() string {
	return "goods_order" // 数据库名称   // ************** 替换 FormulaList **************
}

func init() {
	//注册模型
	orm.RegisterModel(new(GoodsOrder))

}

func GoodsOrderToGoodsOrderR(t GoodsOrder) (r GoodsOrderR) {
	r.Id = t.Id
	r.T_orderid = t.T_orderid
	r.T_outorderid = t.T_outorderid
	Device_r, err := Device.Read_Device_ByT_sn(t.T_sn)
	r.T_name = t.T_sn
	if err == nil {
		r.T_name = Device_r.T_devName
	}

	r.T_sn = t.T_sn
	r.T_receiving = t.T_receiving
	r.T_start_Ut = t.T_start_Ut
	r.T_start_Ut_T = t.T_start_Ut_T
	r.T_end_Ut = t.T_end_Ut
	r.T_end_Ut_T = t.T_end_Ut_T
	r.T_text = t.T_text
	return
}

// ---------------- 特殊方法 -------------------
// 获取 ById
func Read_GoodsOrder_ById(id int) (r GoodsOrder) {
	o := orm.NewOrm()
	r = GoodsOrder{Id: id}
	err := o.Read(&r) // o.Read(&r,"Tokey") 如果不是 主键 就得指定字段名
	if err != nil {
		fmt.Println(err)
	}
	return r
}

//// 获取 ById
//func Read_GoodsOrder_ByT_id(T_id string) (r GoodsOrder) {
//	o := orm.NewOrm()
//	r = GoodsOrder{T_id: T_id}
//	err := o.Read(&r, "T_id") // o.Read(&r,"Tokey") 如果不是 主键 就得指定字段名
//	if err != nil {
//		fmt.Println(err)
//	}
//	return r
//}

// 添加
func Add_GoodsOrder(m GoodsOrder) (id int64, err error) {
	o := orm.NewOrm()

	id, err = o.Insert(&m)
	if err != nil {
		fmt.Println(err)
	}
	return id, err
}

// 修改
func Update_TGoodsOrder(r GoodsOrder, cols ...string) bool {
	o := orm.NewOrm()
	if num, err := o.Update(&r, cols...); err == nil {
		fmt.Println("Number of records updated in database:", num)
		return true
	}
	return false
}

// 删除
func Delete_GoodsOrder_ById(r GoodsOrder) (err error) {
	r.T_State = 0
	Update_TGoodsOrder(r, "T_State")
	return
}

// 删除
func Delete_GoodsOrder(m GoodsOrder) (err error) {
	o := orm.NewOrm()
	if num, err := o.Delete(&m); err == nil {
		fmt.Println("Number of records deleted in database:", num)
	}
	return
}

// 获取列表
func Read_GoodsOrder_List(T_pid int, page int, page_z int, Name string) (t []GoodsOrderR, cnt int64) {
	o := orm.NewOrm()

	// 也可以直接使用 Model 结构体作为表名
	qs := o.QueryTable(new(GoodsOrder))
	var offset int64
	if page_z == 0 {
		page_z = conf.Page_size
	}
	var r []GoodsOrder
	if page <= 1 {
		offset = 0
	} else {
		offset = int64((page - 1) * page_z)
	}

	cond := orm.NewCondition()
	cond1 := cond.And("T_pid", T_pid).And("T_State", 1)

	if len(Name) > 0 {
		cond1 = cond1.AndCond(cond.Or("T_sn__icontains", Name).Or("T_orderid__icontains", Name).Or("T_outorderid__icontains", Name))
	}

	qs.Limit(page_z, offset).SetCond((*orm2.Condition)(cond1)).OrderBy("-Id").All(&r)
	cnt, _ = qs.SetCond((*orm2.Condition)(cond1)).Count()

	for _, v := range r {
		t = append(t, GoodsOrderToGoodsOrderR(v))
	}
	return t, cnt
}