PanelLayerMould.go 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174
  1. package Panel
  2. import (
  3. "Cold_Api/conf"
  4. "Cold_Api/logs"
  5. "encoding/json"
  6. "fmt"
  7. "github.com/astaxie/beego/cache"
  8. _ "github.com/astaxie/beego/cache/redis"
  9. "github.com/beego/beego/v2/adapter/orm"
  10. _ "github.com/go-sql-driver/mysql"
  11. "time"
  12. )
  13. // 模板
  14. type PanelLayerMould struct {
  15. Id int `orm:"column(ID);size(11);auto;pk"`
  16. T_class int `orm:"size(200);null"` // 分类
  17. T_name string `orm:"size(256);null"` // 标题
  18. T_img string `orm:"size(256);null"` // 图片
  19. T_text string `orm:"type(text);null"` // 详情
  20. CreateTime time.Time `orm:"column(create_time);type(timestamp);null;auto_now_add"` //auto_now_add 第一次保存时才设置时间
  21. UpdateTime time.Time `orm:"column(update_time);type(timestamp);null;auto_now"` //auto_now 每次 model 保存时都会对时间自动更新
  22. }
  23. func (t *PanelLayerMould) TableName() string {
  24. return "PanelLayerMould" // 数据库名称 // ************** 替换 FormulaList **************
  25. }
  26. var redisCache_PanelLayerMould cache.Cache
  27. func init() {
  28. //注册模型
  29. orm.RegisterModel(new(PanelLayerMould))
  30. config := fmt.Sprintf(`{"key":"%s","conn":"%s","dbNum":"%s","password":"%s"}`,
  31. "redis_"+"PanelLayerMould", conf.Redis_address, conf.Redis_dbNum, conf.Redis_password)
  32. logs.Println(config)
  33. var err error
  34. redisCache_PanelLayerMould, err = cache.NewCache("redis", config)
  35. if err != nil || redisCache_PanelLayerMould == nil {
  36. errMsg := "failed to init redis"
  37. logs.Println(errMsg, err)
  38. }
  39. }
  40. // ---------------- Redis -------------------
  41. //Redis_Set(m.T_sn,m) // Redis 更新缓存
  42. func Redis_PanelLayerMould_Set(key string, r PanelLayerMould) (err error) {
  43. //json序列化
  44. str, err := json.Marshal(r)
  45. if err != nil {
  46. logs.Println(err)
  47. return
  48. }
  49. err = redisCache_PanelLayerMould.Put(key, str, 24*time.Hour)
  50. if err != nil {
  51. logs.Println("set key:", key, ",value:", str, err)
  52. }
  53. return
  54. }
  55. //if r,is :=Redis_Get(T_sn);is{
  56. //return r,nil
  57. //}
  58. func Redis_PanelLayerMould_Get(key string) (r PanelLayerMould, is bool) {
  59. if redisCache_PanelLayerMould.IsExist(key) {
  60. logs.Println("找到key:", key)
  61. v := redisCache_PanelLayerMould.Get(key)
  62. json.Unmarshal(v.([]byte), &r)
  63. return r, true
  64. }
  65. logs.Println("没有 找到key:", key)
  66. return PanelLayerMould{}, false
  67. }
  68. func Redis_PanelLayerMould_DelK(key string) (err error) {
  69. err = redisCache_PanelLayerMould.Delete(key)
  70. return
  71. }
  72. // ---------------- 特殊方法 -------------------
  73. // 获取 ById
  74. func Read_PanelLayerMould_ById(id int) (r PanelLayerMould, is bool) {
  75. o := orm.NewOrm()
  76. r = PanelLayerMould{Id: id}
  77. err := o.Read(&r) // o.Read(&r,"Tokey") 如果不是 主键 就得指定字段名
  78. if err != nil {
  79. logs.Println(err)
  80. return r, false
  81. }
  82. return r, true
  83. }
  84. // 获取 By
  85. func Read_PanelLayerMould_ByT_name(T_name string) (r PanelLayerMould, is bool) {
  86. //if r, is = Redis_PanelLayerMould_Get(T_name); is == true {
  87. // return r, true
  88. //}
  89. o := orm.NewOrm()
  90. qs := o.QueryTable(new(PanelLayerMould))
  91. err := qs.Filter("T_name", T_name).One(&r)
  92. if err != nil {
  93. return r, false
  94. }
  95. //Redis_PanelLayerMould_Set(T_name, r)
  96. return r, true
  97. }
  98. // 添加
  99. func Add_PanelLayerMould(r PanelLayerMould) (id int64, is bool) {
  100. o := orm.NewOrm()
  101. id, err := o.Insert(&r)
  102. if err != nil {
  103. logs.Println(err)
  104. return 0, false
  105. }
  106. //Redis_PanelLayerMould_Set(r.T_name, r)
  107. return id, true
  108. }
  109. // 修改
  110. func Update_PanelLayerMould_ById(m PanelLayerMould) bool {
  111. o := orm.NewOrm()
  112. v := PanelLayerMould{Id: m.Id}
  113. if err := o.Read(&v); err == nil {
  114. var num int64
  115. v.T_class = m.T_class
  116. v.T_name = m.T_name
  117. v.T_img = m.T_img
  118. v.T_text = m.T_text
  119. if num, err = o.Update(&m, "T_class", "T_name", "T_img", "T_text"); err == nil {
  120. fmt.Println("Number of records updated in database:", num)
  121. }
  122. //Redis_PanelLayerMould_Set(v.T_name, v)
  123. return true
  124. }
  125. return false
  126. }
  127. // 删除
  128. func Delete_PanelLayerMould_ById(v PanelLayerMould) bool {
  129. o := orm.NewOrm()
  130. if num, err := o.Delete(&v); err == nil {
  131. logs.Println("Number of records deleted in database:", num)
  132. } else {
  133. return false
  134. }
  135. //Redis_PanelLayerMould_DelK(v.T_name)
  136. return true
  137. }
  138. // 获取列表
  139. func Read_PanelLayerMould_1(T_name string,page int, page_z int) (r []PanelLayerMould, cnt int64) {
  140. o := orm.NewOrm()
  141. // 也可以直接使用 Model 结构体作为表名
  142. qs := o.QueryTable(new(PanelLayerMould))
  143. var offset int64
  144. if page <= 1 {
  145. offset = 0
  146. } else {
  147. offset = int64((page - 1) * page_z)
  148. }
  149. qs.Limit(page_z, offset).Filter("T_name__icontains",T_name).OrderBy("-Id").All(&r)
  150. cnt, _ = qs.Count()
  151. return r, cnt
  152. }