package Panel import ( "Cold_Api/conf" "Cold_Api/logs" "encoding/json" "fmt" "github.com/astaxie/beego/cache" _ "github.com/astaxie/beego/cache/redis" "github.com/beego/beego/v2/adapter/orm" _ "github.com/go-sql-driver/mysql" "time" ) // 模板 type PanelLayerMould struct { Id int `orm:"column(ID);size(11);auto;pk"` T_class int `orm:"size(200);null"` // 分类 T_name string `orm:"size(256);null"` // 标题 T_img string `orm:"size(256);null"` // 图片 T_text string `orm:"type(text);null"` // 详情 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 保存时都会对时间自动更新 } func (t *PanelLayerMould) TableName() string { return "PanelLayerMould" // 数据库名称 // ************** 替换 FormulaList ************** } var redisCache_PanelLayerMould cache.Cache func init() { //注册模型 orm.RegisterModel(new(PanelLayerMould)) config := fmt.Sprintf(`{"key":"%s","conn":"%s","dbNum":"%s","password":"%s"}`, "redis_"+"PanelLayerMould", conf.Redis_address, conf.Redis_dbNum, conf.Redis_password) logs.Println(config) var err error redisCache_PanelLayerMould, err = cache.NewCache("redis", config) if err != nil || redisCache_PanelLayerMould == nil { errMsg := "failed to init redis" logs.Println(errMsg, err) } } // ---------------- Redis ------------------- //Redis_Set(m.T_sn,m) // Redis 更新缓存 func Redis_PanelLayerMould_Set(key string, r PanelLayerMould) (err error) { //json序列化 str, err := json.Marshal(r) if err != nil { logs.Println(err) return } err = redisCache_PanelLayerMould.Put(key, str, 24*time.Hour) if err != nil { logs.Println("set key:", key, ",value:", str, err) } return } //if r,is :=Redis_Get(T_sn);is{ //return r,nil //} func Redis_PanelLayerMould_Get(key string) (r PanelLayerMould, is bool) { if redisCache_PanelLayerMould.IsExist(key) { logs.Println("找到key:", key) v := redisCache_PanelLayerMould.Get(key) json.Unmarshal(v.([]byte), &r) return r, true } logs.Println("没有 找到key:", key) return PanelLayerMould{}, false } func Redis_PanelLayerMould_DelK(key string) (err error) { err = redisCache_PanelLayerMould.Delete(key) return } // ---------------- 特殊方法 ------------------- // 获取 ById func Read_PanelLayerMould_ById(id int) (r PanelLayerMould, is bool) { o := orm.NewOrm() r = PanelLayerMould{Id: id} err := o.Read(&r) // o.Read(&r,"Tokey") 如果不是 主键 就得指定字段名 if err != nil { logs.Println(err) return r, false } return r, true } // 获取 By func Read_PanelLayerMould_ByT_name(T_name string) (r PanelLayerMould, is bool) { //if r, is = Redis_PanelLayerMould_Get(T_name); is == true { // return r, true //} o := orm.NewOrm() qs := o.QueryTable(new(PanelLayerMould)) err := qs.Filter("T_name", T_name).One(&r) if err != nil { return r, false } //Redis_PanelLayerMould_Set(T_name, r) return r, true } // 添加 func Add_PanelLayerMould(r PanelLayerMould) (id int64, is bool) { o := orm.NewOrm() id, err := o.Insert(&r) if err != nil { logs.Println(err) return 0, false } //Redis_PanelLayerMould_Set(r.T_name, r) return id, true } // 修改 func Update_PanelLayerMould_ById(m PanelLayerMould) bool { o := orm.NewOrm() v := PanelLayerMould{Id: m.Id} if err := o.Read(&v); err == nil { var num int64 v.T_class = m.T_class v.T_name = m.T_name v.T_img = m.T_img v.T_text = m.T_text if num, err = o.Update(&m, "T_class", "T_name", "T_img", "T_text"); err == nil { fmt.Println("Number of records updated in database:", num) } //Redis_PanelLayerMould_Set(v.T_name, v) return true } return false } // 删除 func Delete_PanelLayerMould_ById(v PanelLayerMould) bool { o := orm.NewOrm() if num, err := o.Delete(&v); err == nil { logs.Println("Number of records deleted in database:", num) } else { return false } //Redis_PanelLayerMould_DelK(v.T_name) return true } // 获取列表 func Read_PanelLayerMould_1(T_name string,page int, page_z int) (r []PanelLayerMould, cnt int64) { o := orm.NewOrm() // 也可以直接使用 Model 结构体作为表名 qs := o.QueryTable(new(PanelLayerMould)) var offset int64 if page <= 1 { offset = 0 } else { offset = int64((page - 1) * page_z) } qs.Limit(page_z, offset).Filter("T_name__icontains",T_name).OrderBy("-Id").All(&r) cnt, _ = qs.Count() return r, cnt }