Warning.go 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429
  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:"pk;column(ID);size(11);auto;"`
  18. T_pid int `orm:"size(256);null"` // Account.Company 绑定公司
  19. T_tp int `orm:"index;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:"index;size(200);null"` // 传感器 ID
  23. T_DS_name string `orm:"size(256);null"` // 传感器名称
  24. T_Remark string `orm:"type(text);"` // 采集内容
  25. T_t float32 `orm:"size(256);"` // 温度
  26. T_rh float32 `orm:"size(256);"` // 湿度
  27. T_site string `orm:"size(256);"` // GPS
  28. T_sp int `orm:"size(11);"` // 传感器参数id
  29. T_Ut time.Time `orm:"index;type(timestamp);null;"` // 采集时间
  30. T_fUt time.Time `orm:"type(timestamp);null;"` // 首次采集时间
  31. T_Text string `orm:"type(text);null"` // 处理备注
  32. T_Log string `orm:"type(text);null"` // 通知日志
  33. T_Msid int64 `orm:"size(256);null"` // 消息ID
  34. T_State int `orm:"size(2);default(2)"` // 0 删除 1 不处理 2 已处理 3 未处理
  35. CreateTime time.Time `orm:"column(create_time);type(timestamp);null;auto_now_add"` //auto_now_add 第一次保存时才设置时间
  36. UpdateTime time.Time `orm:"column(update_time);type(timestamp);null;auto_now"` // auto_now 每次 model 保存时都会对时间自动更新
  37. }
  38. // 多字段索引
  39. func (u *Warning) TableIndex() [][]string {
  40. return [][]string{
  41. []string{"T_pid", "T_tp", "T_State"},
  42. }
  43. }
  44. func (t *Warning) TableName() string {
  45. return "warning" // 数据库名称 // ************** 替换 FormulaList **************
  46. }
  47. var redisCache_Warning cache.Cache
  48. var redisCache_WarningStart cache.Cache // 缓存报警开始 时间点
  49. func init() {
  50. //注册模型
  51. orm.RegisterModel(new(Warning))
  52. config := fmt.Sprintf(`{"key":"%s","conn":"%s","dbNum":"%s","password":"%s"}`,
  53. "redis_WarningNum", conf.Redis_address, conf.Redis_dbNum, conf.Redis_password)
  54. logs.Println(config)
  55. var err error
  56. redisCache_Warning, err = cache.NewCache("redis", config)
  57. if err != nil || redisCache_Warning == nil {
  58. errMsg := "failed to init redis"
  59. logs.Println(errMsg, err)
  60. }
  61. config = fmt.Sprintf(`{"key":"%s","conn":"%s","dbNum":"%s","password":"%s"}`,
  62. "redis_WarningStart", conf.Redis_address, conf.Redis_dbNum, conf.Redis_password)
  63. logs.Println(config)
  64. redisCache_WarningStart, err = cache.NewCache("redis", config)
  65. if err != nil || redisCache_WarningStart == nil {
  66. errMsg := "failed to init redis"
  67. logs.Println(errMsg, err)
  68. }
  69. }
  70. // ---------------- Redis -------------------
  71. // Redis_Set(m.T_sn,m) // Redis 更新缓存
  72. func Redis_Warning_Set(key string) (err error) {
  73. err = redisCache_Warning.Put(key, "", 24*time.Hour)
  74. if err != nil {
  75. logs.Println("set key:", key)
  76. }
  77. return
  78. }
  79. func Redis_Warning_Repeat_T_sn_Msid(key string) (is bool) {
  80. if redisCache_Warning.IsExist(key) {
  81. redisCache_Warning.Put(key, "", 60*time.Minute)
  82. //println("找到key:",key)
  83. return true
  84. }
  85. redisCache_Warning.Put(key, "", 60*time.Minute)
  86. return false
  87. }
  88. // 缓存报警次数 cut 持续秒 (计次,剩余时间s)
  89. func Redis_Warning_Num(key string) (int64, int) {
  90. if redisCache_Warning.IsExist(key) {
  91. //logs.Println("Redis_Warning_Num 找到key:", key)
  92. r := redisCache_Warning.Get(key)
  93. if r == nil {
  94. return 0, 0
  95. }
  96. value_str := string(r.([]byte))
  97. value_str_list := strings.Split(value_str, "|")
  98. if len(value_str_list) != 2 {
  99. return 0, 0
  100. }
  101. logs.Println("value_str_list:", value_str_list) //value_str_list: [[1 1677724222]]
  102. value_int, _ := strconv.ParseInt(value_str_list[0], 10, 64)
  103. cut := int(time.Unix(lib.To_int64(value_str_list[1]), 0).Unix() - time.Now().Unix()) // 计算 还剩 s秒时间
  104. return value_int, cut
  105. }
  106. return 0, 0
  107. }
  108. // 缓存报警次数 cut 持续秒 (计次,剩余时间s)
  109. func Redis_Warning_Num_W(key, cuts string) (int64, int) {
  110. cut, err := strconv.Atoi(cuts)
  111. if err != nil {
  112. logs.PrintlnError("Redis_Warning_Num err:", err)
  113. }
  114. if redisCache_Warning.IsExist(key) {
  115. //logs.Println("Redis_Warning_Num 找到key:", key)
  116. r := redisCache_Warning.Get(key)
  117. if r == nil {
  118. goto breakHere // 跳转到标签
  119. }
  120. value_str := string(r.([]byte))
  121. value_str_list := strings.Split(value_str, "|")
  122. logs.Println("value_str_list:", value_str_list) //value_str_list: [[1 1677724222]]
  123. if len(value_str_list) != 2 {
  124. goto breakHere // 跳转到标签
  125. }
  126. value_int, _ := strconv.ParseInt(value_str_list[0], 10, 64)
  127. value_int += 1 // 数量
  128. //logs.Println("有数据 value_int:", value_int)
  129. cut = int(time.Unix(lib.To_int64(value_str_list[1]), 0).Unix() - time.Now().Unix()) // 计算 还剩 s秒时间
  130. redisCache_Warning.Put(key, fmt.Sprintf("%d|%s", value_int, value_str_list[1]), time.Duration(cut)*time.Second)
  131. logs.Println("Redis_Warning_Num KEY:", key, "->", value_int, " 还剩时间 ->", cut)
  132. return value_int, cut
  133. }
  134. breakHere:
  135. //logs.Println("没有数据 value_int:", 1)
  136. s, _ := time.ParseDuration(fmt.Sprintf("%ds", cut))
  137. redisCache_Warning.Put(key, fmt.Sprintf("1|%d", time.Now().Add(s).Unix()), time.Duration(cut)*time.Second)
  138. logs.Println("Redis_Warning_Num NewKEY:", key, " cut:", cut)
  139. return 1, cut
  140. }
  141. // 管理员 缓存报警次数
  142. func Redis_WarningToAdmin_Num(key string) bool {
  143. if redisCache_Warning.IsExist(key) {
  144. ////logs.Println("Redis_Warning_Num 找到key:", key)
  145. //r := redisCache_Warning.Get(key)
  146. //value_str := string(r.([]byte))
  147. //value_int, _ := strconv.ParseInt(value_str, 10, 64)
  148. //value_int += 1
  149. ////logs.Println("有数据 value_int:", value_int)
  150. ////redisCache_Warning.Put(key, strconv.FormatInt(value_int, 10), 11*time.Minute)
  151. return false
  152. }
  153. //logs.Println("没有数据 value_int:", 1)
  154. redisCache_Warning.Put(key, "1", 30*time.Minute)
  155. return true
  156. }
  157. // --- 缓存 报警时间,减轻数据库压力
  158. func Redis_WarningTimeListIs(m Warning) bool {
  159. key := m.T_sn + "|" + strconv.Itoa(m.T_id) + "|" + strconv.Itoa(m.T_tp) + "|" + m.T_Ut.Format("2006-01-02 15:04:05")
  160. if redisCache_WarningStart.IsExist(key) {
  161. return true
  162. }
  163. redisCache_WarningStart.Put(key, "", 60*time.Minute)
  164. return false
  165. }
  166. // 首次开始时间
  167. func Redis_WarningStart(m Warning) time.Time {
  168. key := m.T_sn + "|" + strconv.Itoa(m.T_id) + "|" + strconv.Itoa(m.T_tp)
  169. if redisCache_WarningStart.IsExist(key) {
  170. // 上一条报警时间
  171. val := redisCache_WarningStart.Get(key)
  172. // 将字符串转换为整数
  173. unixTime, err := strconv.ParseInt(string(val.([]uint8)), 10, 64)
  174. if err == nil {
  175. // 转换为 time.Time 类型
  176. time_ut_lod := time.Unix(unixTime, 0)
  177. if time_ut_lod != m.T_fUt {
  178. logs.Println("报警首时间不一样 (提示):",time_ut_lod.Format("2006-01-02 15:04:05"),m.T_fUt.Format("2006-01-02 15:04:05"))
  179. }
  180. return time_ut_lod
  181. }
  182. logs.Println("时间转换错误:",string(val.([]uint8)), err.Error())
  183. }
  184. redisCache_WarningStart.Put(key, fmt.Sprintf("%d", m.T_fUt.Unix()), 60*time.Minute)
  185. return m.T_fUt
  186. }
  187. //func Redis_WarningStart(m Warning, time_ut time.Time) (bool, time.Time) {
  188. // key := m.T_sn + "|" + strconv.Itoa(m.T_id) + "|" + strconv.Itoa(m.T_tp)
  189. // logs_s := ""
  190. // logs_s += key + "|" + time_ut.Format("2006-01-02 15:04:05") + "=>"
  191. // if redisCache_WarningStart.IsExist(key) {
  192. // // 上一条报警时间
  193. // val := redisCache_WarningStart.Get(key)
  194. //
  195. // // 将字符串转换为整数
  196. // //logs.Println("val:[]uint8 ",val.([]uint8), string(val.([]uint8)))
  197. // unixTime, err := strconv.ParseInt(string(val.([]uint8)), 10, 64)
  198. // if err != nil {
  199. // logs.Println("时间转换错误:",string(val.([]uint8)), err.Error())
  200. // goto to1
  201. // }
  202. //
  203. // // 转换为 time.Time 类型
  204. // time_ut_lod := time.Unix(unixTime, 0)
  205. //
  206. // logs_s += "找到上一条报警时间" + time_ut_lod.Format("2006-01-02 15:04:05") + ","
  207. // // 计算时间差
  208. // duration := time_ut.Sub(time_ut_lod)
  209. //
  210. // // 判断是否在 2~4 分钟范围
  211. // if duration < 2*time.Minute || duration >= 4*time.Minute {
  212. // logs_s += "距离间隔" + strconv.Itoa(int(duration)) + "秒,时间不在2~4分钟间隔范围,跳过报警!"
  213. // logs.Println("报警时间计算处理:", logs_s)
  214. // return false, time_ut_lod
  215. // }
  216. //
  217. // lib.PeriodWTime(m.T_fUt,m.T_fUt,2)
  218. // // 在当前时间上加2分钟
  219. // time_ut = time_ut.Add(2 * time.Minute)
  220. //
  221. // redisCache_WarningStart.Put(key, fmt.Sprintf("%d", time_ut.Unix()) , 60*time.Minute)
  222. // logs_s += "最终时间" + time_ut_lod.Format("2006-01-02 15:04:05")
  223. // logs.Println("报警时间计算处理:", logs_s)
  224. // return true, time_ut
  225. // }
  226. //to1:
  227. // redisCache_WarningStart.Put(key, fmt.Sprintf("%d", time_ut.Unix()), 60*time.Minute)
  228. // logs_s += "最终时间" + time_ut.Format("2006-01-02 15:04:05")
  229. // logs.Println("报警时间计算处理:", logs_s)
  230. // return true, time_ut
  231. //}
  232. // 清除报警机制
  233. func Redis_WarningStart_DelK(m Warning) (time.Time, bool) {
  234. key := m.T_sn + "|" + strconv.Itoa(m.T_id) + "|" + strconv.Itoa(m.T_tp)
  235. if redisCache_WarningStart.IsExist(key) {
  236. val := redisCache_WarningStart.Get(key)
  237. redisCache_WarningStart.Delete(key)
  238. unixTime, err := strconv.ParseInt(string(val.([]uint8)), 10, 64)
  239. if err != nil {
  240. logs.Println("时间转换错误:", string(val.([]uint8)), err.Error())
  241. }
  242. // 转换为 time.Time 类型
  243. time_ut_lod := time.Unix(unixTime, 0)
  244. return time_ut_lod, true
  245. }
  246. return time.Now(), false
  247. }
  248. // ---------------- 特殊方法 -------------------
  249. //
  250. // func Is2Subtable(T_tp int) bool {
  251. // //109 市电断电报警 市电断电报警,0,1,0,0,99999,0,0,0,0,0,0,0,0,0,0,0,0| 1
  252. // //110 市电已恢复 市电已恢复,0,1,0,0,99999,0,0,0,0,0,0,0,0,0,0,0,0| 1
  253. // values := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 109, 110}
  254. //
  255. // for _, value := range values {
  256. // if T_tp == value {
  257. //
  258. // return true
  259. // }
  260. // }
  261. // return false
  262. // }
  263. //
  264. // 添加
  265. func Add_Warning(m Warning) (id int64, err error) {
  266. // 查看 sn 是否有归属
  267. if m.T_pid == 0 { // 寻找报警归属
  268. if len(m.T_sn) > 1 {
  269. r_Device, err := Device.Read_Device_ByT_sn(m.T_sn)
  270. if err != nil {
  271. logs.Println("MessageDisconnected 没有该设备:", m.T_sn)
  272. }
  273. m.T_pid = r_Device.T_pid
  274. }
  275. }
  276. if m.T_id == -1 {
  277. m.T_DS_name = m.T_D_name
  278. }
  279. if len(m.T_DS_name) == 0 {
  280. m.T_DS_name = m.T_D_name
  281. }
  282. //if(conf.Test_server){
  283. // logs.Println("Add_Warning:",m)
  284. // return id, err
  285. //}
  286. o := orm.NewOrm()
  287. id, err = o.Insert(&m)
  288. if err != nil {
  289. logs.PrintlnError("Add_Warning err:", err)
  290. }
  291. // 插入分表
  292. //warningDB := WarningDB{
  293. // T_pid: int32(m.T_pid),
  294. // T_tp: m.T_tp,
  295. // T_sn: m.T_sn,
  296. // T_D_name: m.T_D_name,
  297. // T_id: int32(m.T_id),
  298. // T_DS_name: m.T_DS_name,
  299. // T_Remark: m.T_Remark,
  300. // T_Ut: m.T_Ut,
  301. // T_fUt: m.T_fUt,
  302. // T_Text: m.T_Text,
  303. // T_Log: m.T_Log,
  304. // T_Msid: m.T_Msid,
  305. // T_State: m.T_State,
  306. // CreateTime: m.CreateTime,
  307. // UpdateTime: m.UpdateTime,
  308. //}
  309. //warningDB.Create("warning_" + m.T_Ut.Format("2006_01"))
  310. INSERT("warning_"+m.T_Ut.Format("2006_01"), m.Id) // 旧 备份
  311. logs.PrintlnWData("WData", m.T_pid, m.T_tp, m.T_sn, m.T_Remark) // 记录报警日志
  312. return id, err
  313. }
  314. // 修改
  315. func Update_Warning(r Warning, cols ...string) bool {
  316. o := orm.NewOrm()
  317. if _, err := o.Update(&r, cols...); err == nil {
  318. //logs.Println("Number of records updated in database:", num)
  319. // 插入备份表
  320. UPDATE("warning_"+r.T_Ut.Format("2006_01"), r.Id, r.T_Log)
  321. return true
  322. }
  323. return false
  324. }
  325. // 追加 日志
  326. func Add_Warning_Log(r *Warning, T_Log string) {
  327. r.T_Log = r.T_Log + T_Log
  328. return
  329. }
  330. func Add_DeviceLogs(T_tp int, r_Device Device.Device, T_Remark string) Warning {
  331. var Warning_r Warning
  332. Warning_r.T_pid = r_Device.T_pid
  333. Warning_r.T_tp = T_tp
  334. Warning_r.T_sn = r_Device.T_sn
  335. Warning_r.T_D_name = r_Device.T_devName
  336. Warning_r.T_DS_name = r_Device.T_devName
  337. Warning_r.T_id = -1
  338. Warning_r.T_Remark = T_Remark
  339. Warning_r.T_Ut = time.Now()
  340. Warning_r.T_State = 1
  341. // 查看 sn 是否有归属
  342. if Warning_r.T_pid == 0 { // 寻找报警归属
  343. if len(Warning_r.T_sn) > 10 {
  344. r_Device, err := Device.Read_Device_ByT_sn(Warning_r.T_sn)
  345. if err != nil {
  346. logs.Println("MessageDisconnected 没有该设备:", Warning_r.T_sn)
  347. }
  348. Warning_r.T_pid = r_Device.T_pid
  349. }
  350. }
  351. // 添加报警
  352. id, _ := Add_Warning(Warning_r)
  353. Warning_r.Id = id
  354. return Warning_r
  355. }
  356. // 指定设备与类型最新的记录
  357. func Read_T_snT_tp(T_sn string, T_tp int) Warning {
  358. o := orm.NewOrm()
  359. // 也可以直接使用 Model 结构体作为表名
  360. qs := o.QueryTable(new(Warning))
  361. var r Warning
  362. qs.Filter("T_sn", T_sn).Filter("T_tp", T_tp).OrderBy("-T_Ut").One(&r)
  363. return r
  364. }
  365. // 指定设备与类型消息ID最新的记录
  366. func Read_T_snT_tpT_Msid(T_sn string, T_tp, T_Msid int) Warning {
  367. o := orm.NewOrm()
  368. // 也可以直接使用 Model 结构体作为表名
  369. qs := o.QueryTable(new(Warning))
  370. var r Warning
  371. qs.Filter("T_sn", T_sn).Filter("T_tp", T_tp).Filter("T_Msid", T_Msid).OrderBy("-T_Ut").One(&r)
  372. return r
  373. }
  374. // 指定设备与类型消息ID最新的记录
  375. func Read_T_snT_idT_tp(T_sn string, T_id, T_tp int) Warning {
  376. o := orm.NewOrm()
  377. // 也可以直接使用 Model 结构体作为表名
  378. qs := o.QueryTable(new(Warning))
  379. var r Warning
  380. qs.Filter("T_sn", T_sn).Filter("T_id", T_id).Filter("T_tp", T_tp).OrderBy("-T_Ut").One(&r)
  381. return r
  382. }