Warning.go 8.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294
  1. package Warning
  2. import (
  3. "Cold_mqtt/conf"
  4. "Cold_mqtt/lib"
  5. "Cold_mqtt/logs"
  6. "Cold_mqtt/models/Device"
  7. "fmt"
  8. "github.com/astaxie/beego/cache"
  9. _ "github.com/astaxie/beego/cache/redis"
  10. "github.com/beego/beego/v2/adapter/orm"
  11. _ "github.com/go-sql-driver/mysql"
  12. "strconv"
  13. "strings"
  14. "time"
  15. )
  16. type Warning struct {
  17. Id int64 `orm:"column(ID);size(11);auto;pk"`
  18. T_pid int `orm:"size(256);null"` // Account.Company 绑定公司
  19. T_tp int `orm:"size(200);null"` // 报警类型 ->WarningList
  20. T_sn string `orm:"index;size(256);null"` // 设备序列号
  21. T_D_name string `orm:"size(256);null"` // 设备名称
  22. T_id int `orm:"size(200);null"` // 传感器 ID
  23. T_DS_name string `orm:"size(256);null"` // 传感器名称
  24. T_Remark string `orm:"type(text);null"` // 采集内容
  25. T_Ut time.Time `orm:"type(timestamp);null;"` // 采集时间
  26. T_fUt time.Time `orm:"type(timestamp);null;"` // 首次采集时间
  27. T_Text string `orm:"type(text);null"` // 处理备注
  28. T_Log string `orm:"type(text);null"` // 通知日志
  29. T_Msid int64 `orm:"size(256);null"` // 消息ID
  30. T_State int `orm:"size(2);default(2)"` // 0 删除 1 不处理 2 已处理 3 未处理
  31. CreateTime time.Time `orm:"column(create_time);type(timestamp);null;auto_now_add"` //auto_now_add 第一次保存时才设置时间
  32. UpdateTime time.Time `orm:"column(update_time);type(timestamp);null;auto_now"` //auto_now 每次 model 保存时都会对时间自动更新
  33. }
  34. // 多字段索引
  35. func (u *Warning) TableIndex() [][]string {
  36. return [][]string{
  37. []string{"T_pid", "T_tp", "T_State"},
  38. }
  39. }
  40. func (t *Warning) TableName() string {
  41. return "warning" // 数据库名称 // ************** 替换 FormulaList **************
  42. }
  43. var redisCache_Warning cache.Cache
  44. func init() {
  45. //注册模型
  46. orm.RegisterModel(new(Warning))
  47. config := fmt.Sprintf(`{"key":"%s","conn":"%s","dbNum":"%s","password":"%s"}`,
  48. "redis_WarningNum", conf.Redis_address, conf.Redis_dbNum, conf.Redis_password)
  49. logs.Println(config)
  50. var err error
  51. redisCache_Warning, err = cache.NewCache("redis", config)
  52. if err != nil || redisCache_Warning == nil {
  53. errMsg := "failed to init redis"
  54. logs.Println(errMsg, err)
  55. }
  56. }
  57. // ---------------- Redis -------------------
  58. // Redis_Set(m.T_sn,m) // Redis 更新缓存
  59. func Redis_Warning_Set(key string) (err error) {
  60. err = redisCache_Warning.Put(key, "", 24*time.Hour)
  61. if err != nil {
  62. logs.Println("set key:", key)
  63. }
  64. return
  65. }
  66. // if r,is :=Redis_Get(T_sn);is{
  67. // return r,nil
  68. // }
  69. func Redis_Warning_Repeat_T_sn_Msid(key string) (is bool) {
  70. if redisCache_Warning.IsExist(key) {
  71. //println("找到key:",key)
  72. return true
  73. }
  74. redisCache_Warning.Put(key, "", 1*time.Minute)
  75. return false
  76. }
  77. // 缓存报警次数 cut 持续秒 (计次,剩余时间s)
  78. func Redis_Warning_Num(key string) (int64, int) {
  79. if redisCache_Warning.IsExist(key) {
  80. //logs.Println("Redis_Warning_Num 找到key:", key)
  81. r := redisCache_Warning.Get(key)
  82. if r == nil {
  83. return 0, 0
  84. }
  85. value_str := string(r.([]byte))
  86. value_str_list := strings.Split(value_str, "|")
  87. if len(value_str_list) != 2 {
  88. return 0, 0
  89. }
  90. logs.Println("value_str_list:", value_str_list) //value_str_list: [[1 1677724222]]
  91. value_int, _ := strconv.ParseInt(value_str_list[0], 10, 64)
  92. cut := int(time.Unix(lib.To_int64(value_str_list[1]), 0).Unix() - time.Now().Unix()) // 计算 还剩 s秒时间
  93. return value_int, cut
  94. }
  95. return 0, 0
  96. }
  97. // 缓存报警次数 cut 持续秒 (计次,剩余时间s)
  98. func Redis_Warning_Num_W(key, cuts string) (int64, int) {
  99. cut, err := strconv.Atoi(cuts)
  100. if err != nil {
  101. logs.PrintlnError("Redis_Warning_Num err:", err)
  102. }
  103. if redisCache_Warning.IsExist(key) {
  104. //logs.Println("Redis_Warning_Num 找到key:", key)
  105. r := redisCache_Warning.Get(key)
  106. if r == nil {
  107. goto breakHere // 跳转到标签
  108. }
  109. value_str := string(r.([]byte))
  110. value_str_list := strings.Split(value_str, "|")
  111. logs.Println("value_str_list:", value_str_list) //value_str_list: [[1 1677724222]]
  112. if len(value_str_list) != 2 {
  113. goto breakHere // 跳转到标签
  114. }
  115. value_int, _ := strconv.ParseInt(value_str_list[0], 10, 64)
  116. value_int += 1 // 数量
  117. //logs.Println("有数据 value_int:", value_int)
  118. cut = int(time.Unix(lib.To_int64(value_str_list[1]), 0).Unix() - time.Now().Unix()) // 计算 还剩 s秒时间
  119. redisCache_Warning.Put(key, fmt.Sprintf("%d|%s", value_int, value_str_list[1]), time.Duration(cut)*time.Second)
  120. logs.Println("Redis_Warning_Num KEY:", key, "->", value_int, " 还剩时间 ->", cut)
  121. return value_int, cut
  122. }
  123. breakHere:
  124. //logs.Println("没有数据 value_int:", 1)
  125. s, _ := time.ParseDuration(fmt.Sprintf("%ds", cut))
  126. redisCache_Warning.Put(key, fmt.Sprintf("1|%d", time.Now().Add(s).Unix()), time.Duration(cut)*time.Second)
  127. logs.Println("Redis_Warning_Num NewKEY:", key, " cut:", cut)
  128. return 1, cut
  129. }
  130. // 管理员 缓存报警次数
  131. func Redis_WarningToAdmin_Num(key string) bool {
  132. if redisCache_Warning.IsExist(key) {
  133. ////logs.Println("Redis_Warning_Num 找到key:", key)
  134. //r := redisCache_Warning.Get(key)
  135. //value_str := string(r.([]byte))
  136. //value_int, _ := strconv.ParseInt(value_str, 10, 64)
  137. //value_int += 1
  138. ////logs.Println("有数据 value_int:", value_int)
  139. ////redisCache_Warning.Put(key, strconv.FormatInt(value_int, 10), 11*time.Minute)
  140. return false
  141. }
  142. //logs.Println("没有数据 value_int:", 1)
  143. redisCache_Warning.Put(key, "1", 30*time.Minute)
  144. return true
  145. }
  146. // ---------------- 特殊方法 -------------------
  147. // 添加
  148. func Add_Warning(m Warning) (id int64, err error) {
  149. // 查看 sn 是否有归属
  150. if m.T_pid == 0 { // 寻找报警归属
  151. if len(m.T_sn) > 1 {
  152. r_Device, err := Device.Read_Device_ByT_sn(m.T_sn)
  153. if err != nil {
  154. logs.Println("MessageDisconnected 没有该设备:", m.T_sn)
  155. }
  156. m.T_pid = r_Device.T_pid
  157. }
  158. }
  159. if m.T_id == -1 {
  160. m.T_DS_name = m.T_D_name
  161. }
  162. if len(m.T_DS_name) == 0 {
  163. m.T_DS_name = m.T_D_name
  164. }
  165. //if(conf.Test_server){
  166. // logs.Println("Add_Warning:",m)
  167. // return id, err
  168. //}
  169. o := orm.NewOrm()
  170. id, err = o.Insert(&m)
  171. if err != nil {
  172. logs.PrintlnError("Add_Warning err:", err)
  173. }
  174. // 插入分表
  175. //warningDB := WarningDB{
  176. // T_pid: int32(m.T_pid),
  177. // T_tp: m.T_tp,
  178. // T_sn: m.T_sn,
  179. // T_D_name: m.T_D_name,
  180. // T_id: int32(m.T_id),
  181. // T_DS_name: m.T_DS_name,
  182. // T_Remark: m.T_Remark,
  183. // T_Ut: m.T_Ut,
  184. // T_fUt: m.T_fUt,
  185. // T_Text: m.T_Text,
  186. // T_Log: m.T_Log,
  187. // T_Msid: m.T_Msid,
  188. // T_State: m.T_State,
  189. // CreateTime: m.CreateTime,
  190. // UpdateTime: m.UpdateTime,
  191. //}
  192. //warningDB.Create("warning_" + m.T_Ut.Format("2006_01"))
  193. INSERT("warning_"+m.T_Ut.Format("2006_01"), m.Id) // 旧 备份
  194. return id, err
  195. }
  196. // 修改
  197. func Update_Warning(r Warning, cols ...string) bool {
  198. o := orm.NewOrm()
  199. if num, err := o.Update(&r, cols...); err == nil {
  200. logs.Println("Number of records updated in database:", num)
  201. // 插入备份表
  202. UPDATE("warning_"+r.T_Ut.Format("2006_01"), r.Id, r.T_Log)
  203. return true
  204. }
  205. return false
  206. }
  207. // 追加 日志
  208. func Add_Warning_Log(r *Warning, T_Log string) {
  209. r.T_Log = r.T_Log + T_Log
  210. return
  211. }
  212. func Add_DeviceLogs(T_tp int, r_Device Device.Device, T_Remark string) Warning {
  213. var Warning_r Warning
  214. Warning_r.T_pid = r_Device.T_pid
  215. Warning_r.T_tp = T_tp
  216. Warning_r.T_sn = r_Device.T_sn
  217. Warning_r.T_D_name = r_Device.T_devName
  218. Warning_r.T_DS_name = r_Device.T_devName
  219. Warning_r.T_id = -1
  220. Warning_r.T_Remark = T_Remark
  221. Warning_r.T_Ut = time.Now()
  222. Warning_r.T_State = 1
  223. // 查看 sn 是否有归属
  224. if Warning_r.T_pid == 0 { // 寻找报警归属
  225. if len(Warning_r.T_sn) > 10 {
  226. r_Device, err := Device.Read_Device_ByT_sn(Warning_r.T_sn)
  227. if err != nil {
  228. logs.Println("MessageDisconnected 没有该设备:", Warning_r.T_sn)
  229. }
  230. Warning_r.T_pid = r_Device.T_pid
  231. }
  232. }
  233. // 添加报警
  234. id, _ := Add_Warning(Warning_r)
  235. Warning_r.Id = id
  236. return Warning_r
  237. }
  238. // 指定设备与类型最新的记录
  239. func Read_T_snT_tp(T_sn string, T_tp int) Warning {
  240. o := orm.NewOrm()
  241. // 也可以直接使用 Model 结构体作为表名
  242. qs := o.QueryTable(new(Warning))
  243. var r Warning
  244. qs.Filter("T_sn", T_sn).Filter("T_tp", T_tp).OrderBy("-T_Ut").One(&r)
  245. return r
  246. }
  247. // 指定设备与类型消息ID最新的记录
  248. func Read_T_snT_tpT_Msid(T_sn string, T_tp, T_Msid int) Warning {
  249. o := orm.NewOrm()
  250. // 也可以直接使用 Model 结构体作为表名
  251. qs := o.QueryTable(new(Warning))
  252. var r Warning
  253. qs.Filter("T_sn", T_sn).Filter("T_tp", T_tp).Filter("T_Msid", T_Msid).OrderBy("-T_Ut").One(&r)
  254. return r
  255. }