main.py 3.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100
  1. import datetime
  2. import json,pymysql
  3. import os
  4. import time
  5. from MyUtils.ZillionUtil import ZillionUtil
  6. from MyUtils.MysqlUtils import MysqlUtils
  7. from MyUtils.Dingtalk import send_message_markdown
  8. import pytz
  9. def datetime_now():
  10. # datetime_now = datetime.datetime.now().strftime("%Y%m%d%H%M%S")
  11. #容器时间
  12. # tz = pytz.timezone('Asia/Shanghai') # 东八区
  13. datetime_now = datetime.datetime.fromtimestamp(int(time.time()),
  14. pytz.timezone('Asia/Shanghai')).strftime('%Y-%m-%d %H:%M:%S')
  15. return datetime_now
  16. # 获取能耗数据
  17. def get_data_time(zillionUtil,hbase_database, hbase_table, building,meters,funcid):
  18. Criteria = {
  19. "building": building,
  20. "meter": {
  21. "in":meters
  22. },
  23. "funcid": funcid
  24. }
  25. datas = zillionUtil.select(hbase_database, hbase_table, Criteria)
  26. return datas
  27. # with open("config.json", "r",encoding="utf-8") as f:
  28. # data = json.load(f)
  29. # hbase_database = data["metadata"]["database"]
  30. # url = data["metadata"]["url"]
  31. # building = data["building"]
  32. # funcid = data["funcid"]
  33. # # points = data["points"]
  34. # dingding = data["dingding"]
  35. points = {'1202': 'B2南新风机房浸水报警传感器',
  36. '1201': '2F空调机房浸水报警传感器',
  37. '1203': 'B2北新风机房浸水报警传感器',
  38. '1101': '制冷机房浸水报警传感器',
  39. '9002': '楼顶南新风机房浸水报警传感器',
  40. '9001': '楼顶北新风机房浸水报警传感器'}
  41. hbase_database = os.getenv("hbase_database")
  42. url = os.getenv("url")
  43. building = os.getenv("building")
  44. dingding = os.getenv("dingding")
  45. funcid = os.getenv("dingding")
  46. # points = os.getenv("dingding")
  47. #存报警
  48. alarm = {}
  49. zillionUtil = ZillionUtil(url)
  50. meters = [i for i in points]
  51. #存发送钉钉报警内容
  52. print("%s"%building)
  53. while True:
  54. messages = []
  55. datas = get_data_time(zillionUtil,hbase_database,"original_present",building,meters,funcid)
  56. for i in datas:
  57. value = i["data"]
  58. meter = i["meter"]
  59. receivetime = i["receivetime"]
  60. name = points[meter]
  61. if value == 1:
  62. #如果表之前未产生报警,直接发送报警,并将点位存在报警池中
  63. #如果之前已经有报警,不重复发送
  64. if meter not in alarm:
  65. message = (" - **空间名称:** %s \n" + " - **设备类名称:** 水浸传感器 \n" + " - **报警值:** %s \n" + " - **状态:** <font color=#FF0000>请及时查看处理</font> \n")%(name, value)
  66. messages.append(message)
  67. messages.append("___")
  68. alarm[meter] = value
  69. else:
  70. #如果报警恢复,删除报警池内容,发送恢复报警
  71. if meter in alarm:
  72. if alarm[meter] == 1:
  73. alarm.pop(meter)
  74. message = (" - **空间名称:** %s \n" + " - **设备类名称:** 水浸传感器 \n" + " - **报警值:** %s \n" + " - **状态:** 报警已恢复 \n") % (name, value)
  75. messages.append(message)
  76. messages.append("___")
  77. if messages:
  78. messages_info = "\n".join(messages)
  79. #如果有报警,发送钉钉
  80. title = "## <font color=#FF0000>【中海财富中心】位移传感器报警</font> "
  81. messages_info = title +"\n" + messages_info
  82. print(messages_info)
  83. send_message_markdown(title,messages_info,dingding)
  84. messages.clear()
  85. time.sleep(60)