weather.py 49 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210
  1. # -*- coding:utf-8 -*-
  2. # @Time : 2020/5/22 2:22 下午
  3. # @Author : Creat by Han
  4. import json
  5. import ast
  6. import copy
  7. import datetime
  8. import time
  9. import logging
  10. from django.forms.models import model_to_dict
  11. from django.db.models import Q
  12. from django.conf import settings
  13. from kedong.decoration import kedong_deco, PortError
  14. from smartfarming.models.device import MongoDevice, MongoCBDData
  15. from smartfarming.models.weather import MongoQXZ_Base_Info, QXZdata_New, MongoQXZ_Conf, QXZstatus_New, MongoQXZ_Alarm
  16. from smartfarming.api.views.weather.all_dict import qxz_dict
  17. from smartfarming.models.weather import (
  18. MongoQXZ_Switch,
  19. MongoQXZ_Auto_Switch,
  20. MongoQXZ_Timing_Switch,
  21. QXZ_Switch_Status,
  22. QXZ_Default_Conf
  23. )
  24. config_dict = settings.CONFIG
  25. logger = logging.getLogger("myapp")
  26. @kedong_deco(login_required=True)
  27. def qxz_page(request):
  28. """
  29. 气象设备列表接口 :
  30. 参数:
  31. page 非必传(num) 页码,默认为1
  32. device_id 非必传(str) 设备号
  33. device_status 非必传(str) 在线状态 1在线 0离线
  34. device_name 非必传(str) 设备名称
  35. device_type 非必传(str) 5气象站 8墒情站
  36. 返回值:
  37. {
  38. "data": {
  39. "ids": [
  40. {
  41. "d_id":"", 设备数据库ID
  42. "equip_name":"", 设备名称
  43. "equip_id":12313456, 设备ID
  44. "is_online":1, 在线状态 1在线 0离线
  45. "rssi":10, 信号强度
  46. "volt":22, 电压
  47. "lng":113, 经度
  48. "lat":113, 纬度
  49. "off_time":"" 离线时间
  50. "address":"" 设备地址
  51. "device_expire_time": 1234444 设备到期时间
  52. "device_expire": # 设备状态 0未到期,1已到期,2即将到期
  53. "device_expire_days": 到期天数
  54. }
  55. ],
  56. "nums": 0 设备总数
  57. },
  58. "formError": {},
  59. "errorCode": 0,
  60. "message": "",
  61. "params": {}
  62. }
  63. """
  64. device_id = request.POST.get("device_id")
  65. device_status = request.POST.get("device_status")
  66. device_name = request.POST.get("device_name")
  67. page = request.POST.get("page","")
  68. page_size = request.POST.get("page_size","")
  69. device_type = request.POST.get("device_type","5")
  70. if not page and not page_size:
  71. page = 1
  72. page_size = 8
  73. else:
  74. if not page.isdigit() and not page_size.isdigit():
  75. raise PortError("","字段类型有误")
  76. else:
  77. page = int(page)
  78. page_size = int(page_size)
  79. if device_type not in ("5","8"):
  80. raise PortError("","参数超出范围")
  81. devices = MongoDevice.objects.filter(device_type_id=device_type).order_by('-device_status', '-uptime')
  82. #设备状态查询
  83. if device_status:
  84. devices = devices.filter(device_status=int(device_status))
  85. #设备号查询
  86. if device_id:
  87. devices = devices.filter(Q(device_id__icontains=device_id) | Q(device_name__icontains=device_id))
  88. #设备名称查询
  89. if device_name:
  90. devices = devices.filter(device_name__icontains=device_name)
  91. date = []
  92. nums = devices.count()
  93. result = devices[(page_size*(page-1)):(page*page_size)]
  94. result_device_id_list = [item.device_id for item in result]
  95. qxz_base_dict = {item.device_id: item for item in MongoQXZ_Base_Info.objects.filter(device_id__in=result_device_id_list)}
  96. for i in result:
  97. try:
  98. qxz_base = qxz_base_dict[i.device_id]
  99. rssi = qxz_base.rssi
  100. volt = qxz_base.volt
  101. except:
  102. rssi = ""
  103. volt = ""
  104. lng = i.lng
  105. lat = i.lat
  106. address = i.province+i.city+i.district
  107. is_online = i.device_status
  108. uptime = i.uptime
  109. date.append({
  110. "d_id":i.id,
  111. "equip_name":i.device_name,
  112. "equip_id":i.device_id,
  113. "volt":volt,
  114. "rssi":rssi,
  115. "lng":lng,
  116. "lat":lat,
  117. "address":address,
  118. "is_online":is_online,
  119. "uptime":uptime,
  120. })
  121. data = {'ids':date, 'nums': nums}
  122. return data
  123. @kedong_deco(login_required=True)
  124. def qxz_detail(request):
  125. """
  126. 气象历史数据接口 :
  127. 参数:
  128. device_id 必传(string)
  129. page 非必传(num) 页码,默认为1
  130. start_time 非必传(string 时间戳) 开始时间 (用于时间搜索)
  131. end_time 非必传(string 时间戳) 结束时间 (用于时间搜索)
  132. 返回值:
  133. {
  134. "data": {
  135. "conf": {
  136. "e1":x.e1,"e2":x.e2,"e3":x.e3,"e4":x.e4,"e5":x.e5,
  137. "e6":x.e6,"e7":x.e7,"e8":x.e8,"e9":x.e9,"e10":x.e10,
  138. "e11":x.e11,"e12":x.e12,"e13":x.e13,"e14":x.e14,
  139. "e15":x.e15,"e16":x.e16,"e17":x.e17,"e18":x.e18,
  140. "e19":x.e19,"e20":x.e20,"e21":x.e21,"e22":x.e22,
  141. "e23":x.e23,"e24":x.e24,"e25":x.e25,"e26":x.e26,
  142. "e27":x.e27,"e28":x.e28,"e29":x.e29,"e30":x.e30
  143. },
  144. "nums": 0,
  145. "rainFall": 1 气象设备是否具有日雨量累计因子,有返回1,无返回0
  146. "data": [
  147. {
  148. "e1":qxz_list.e1,"e2":qxz_list.e2,"e3":qxz_list.e3,"e4":qxz_list.e4,"e5":qxz_list.e5,
  149. "e6":qxz_list.e6,"e7":qxz_list.e7,"e8":qxz_list.e8,"e9":qxz_list.e9,"e10":qxz_list.e10,
  150. "e11":qxz_list.e11,"e12":qxz_list.e12,"e13":qxz_list.e13,"e14":qxz_list.e14,
  151. "e15":qxz_list.e15,"e16":qxz_list.e16,"e17":qxz_list.e17,"e18":qxz_list.e18,
  152. "e19":qxz_list.e19,"e20":qxz_list.e20,"e21":qxz_list.e21,"e22":qxz_list.e22,
  153. "e23":qxz_list.e23,"e24":qxz_list.e24,"e25":qxz_list.e25,"e26":qxz_list.e26,
  154. "e27":qxz_list.e27,"e28":qxz_list.e28,"e29":qxz_list.e29,"e30":qxz_list.e30,
  155. "upl_time":qxz_list.upl_time.strftime('%Y-%m-%d %H:%M:%S')
  156. },
  157. {
  158. "e1":qxz_list.e1,"e2":qxz_list.e2,"e3":qxz_list.e3,"e4":qxz_list.e4,"e5":qxz_list.e5,
  159. "e6":qxz_list.e6,"e7":qxz_list.e7,"e8":qxz_list.e8,"e9":qxz_list.e9,"e10":qxz_list.e10,
  160. "e11":qxz_list.e11,"e12":qxz_list.e12,"e13":qxz_list.e13,"e14":qxz_list.e14,
  161. "e15":qxz_list.e15,"e16":qxz_list.e16,"e17":qxz_list.e17,"e18":qxz_list.e18,
  162. "e19":qxz_list.e19,"e20":qxz_list.e20,"e21":qxz_list.e21,"e22":qxz_list.e22,
  163. "e23":qxz_list.e23,"e24":qxz_list.e24,"e25":qxz_list.e25,"e26":qxz_list.e26,
  164. "e27":qxz_list.e27,"e28":qxz_list.e28,"e29":qxz_list.e29,"e30":qxz_list.e30,
  165. "upl_time":qxz_list.upl_time.strftime('%Y-%m-%d %H:%M:%S')
  166. },...
  167. ]
  168. }
  169. "params": {},
  170. "formError": {},
  171. "errorCode": 0,
  172. "message": "",
  173. }
  174. """
  175. f_tbegin = request.POST.get('start_time')
  176. f_tend = request.POST.get('end_time')
  177. device_id = request.POST.get("device_id")
  178. try:
  179. device = MongoDevice.objects.get(device_id=device_id)
  180. device_expire = device.device_expire
  181. device_expire_time = device.device_expire_time
  182. except:
  183. raise PortError('device_id',"暂无此设备")
  184. qxz_list = QXZdata_New.objects.filter(device_id=device_id)
  185. myuser_type = request.user_type
  186. if not myuser_type == 1 and not myuser_type == 5:
  187. if f_tbegin and int(f_tend) > int(device_expire_time):
  188. f_tend = device_expire_time
  189. if f_tbegin and f_tend:
  190. qxz_list =qxz_list.filter(uptime__range=(int(f_tbegin),int(f_tend))).order_by('-id')
  191. page = int(request.POST.get('page',1))
  192. data = []
  193. nums = qxz_list.count()
  194. conf = {}
  195. if nums:
  196. for i in qxz_list[(10*(page-1)):(page*10)]:
  197. dat = {}
  198. for e in range(1, 31):
  199. k = f'e{e}'
  200. v = getattr(i, k)
  201. dat[k] = v or ""
  202. data.append({"dat": dat, "time": i.uptime})
  203. try:
  204. x = MongoQXZ_Conf.objects.get(device_id=device_id)
  205. conf = {}
  206. for e in range(1, 31):
  207. k = f'e{e}'
  208. v = getattr(x, k)
  209. conf[k] = v or ""
  210. except Exception as e:
  211. conf = {}
  212. rainFall = 0
  213. for factor in conf.values():
  214. if factor == "降雨量累计#mm":
  215. rainFall = 1
  216. break
  217. data1 = {"data":data,"nums":nums,"conf":conf,"rainFall":rainFall}
  218. return data1
  219. @kedong_deco(login_required=True)
  220. def qxz_status(request):
  221. """
  222. 气象详情接口 :
  223. 参数:
  224. device_id 必传(string)
  225. 返回值:
  226. {
  227. "data": {
  228. 'dat':{
  229. "e1":qxz_list.e1,"e2":qxz_list.e2,"e3":qxz_list.e3,"e4":qxz_list.e4,"e5":qxz_list.e5,
  230. "e6":qxz_list.e6,"e7":qxz_list.e7,"e8":qxz_list.e8,"e9":qxz_list.e9,"e10":qxz_list.e10,
  231. "e11":qxz_list.e11,"e12":qxz_list.e12,"e13":qxz_list.e13,"e14":qxz_list.e14,
  232. "e15":qxz_list.e15,"e16":qxz_list.e16,"e17":qxz_list.e17,"e18":qxz_list.e18,
  233. "e19":qxz_list.e19,"e20":qxz_list.e20,"e21":qxz_list.e21,"e22":qxz_list.e22,
  234. "e23":qxz_list.e23,"e24":qxz_list.e24,"e25":qxz_list.e25,"e26":qxz_list.e26,
  235. "e27":qxz_list.e27,"e28":qxz_list.e28,"e29":qxz_list.e29,"e30":qxz_list.e30,
  236. "upl_time":qxz_list.upl_time.strftime('%Y-%m-%d %H:%M:%S')
  237. },
  238. 'conf':{
  239. "e1":x.e1,"e2":x.e2,"e3":x.e3,"e4":x.e4,"e5":x.e5,
  240. "e6":x.e6,"e7":x.e7,"e8":x.e8,"e9":x.e9,"e10":x.e10,
  241. "e11":x.e11,"e12":x.e12,"e13":x.e13,"e14":x.e14,
  242. "e15":x.e15,"e16":x.e16,"e17":x.e17,"e18":x.e18,
  243. "e19":x.e19,"e20":x.e20,"e21":x.e21,"e22":x.e22,
  244. "e23":x.e23,"e24":x.e24,"e25":x.e25,"e26":x.e26,
  245. "e27":x.e27,"e28":x.e28,"e29":x.e29,"e30":x.e30
  246. },
  247. "led":0, 0 无led点阵屏功能 1 有led点阵屏功能
  248. "ledinfo":"点阵屏内容"
  249. },
  250. "errorCode": 0,
  251. "message": "",
  252. "formError": {}
  253. }
  254. """
  255. e_id = request.POST.get("device_id")
  256. if not e_id:
  257. raise PortError("","参数缺失")
  258. qxz_list = QXZdata_New.objects.filter(device_id=e_id).first()
  259. if not qxz_list:
  260. raise PortError("","未找到此设备")
  261. data = []
  262. dat = {"e1":qxz_list.e1,"e2":qxz_list.e2,"e3":qxz_list.e3,"e4":qxz_list.e4,"e5":qxz_list.e5,
  263. "e6":qxz_list.e6,"e7":qxz_list.e7,"e8":qxz_list.e8,"e9":qxz_list.e9,"e10":qxz_list.e10,
  264. "e11":qxz_list.e11,"e12":qxz_list.e12,"e13":qxz_list.e13,"e14":qxz_list.e14,
  265. "e15":qxz_list.e15,"e16":qxz_list.e16,"e17":qxz_list.e17,"e18":qxz_list.e18,
  266. "e19":qxz_list.e19,"e20":qxz_list.e20,"e21":qxz_list.e21,"e22":qxz_list.e22,
  267. "e23":qxz_list.e23,"e24":qxz_list.e24,"e25":qxz_list.e25,"e26":qxz_list.e26,
  268. "e27":qxz_list.e27,"e28":qxz_list.e28,"e29":qxz_list.e29,"e30":qxz_list.e30, "uptime":qxz_list.uptime}
  269. try:
  270. x = MongoQXZ_Conf.objects.get(device_id=e_id)
  271. conf = {"e1":x.e1,"e2":x.e2,"e3":x.e3,"e4":x.e4,"e5":x.e5,
  272. "e6":x.e6,"e7":x.e7,"e8":x.e8,"e9":x.e9,"e10":x.e10,
  273. "e11":x.e11,"e12":x.e12,"e13":x.e13,"e14":x.e14,
  274. "e15":x.e15,"e16":x.e16,"e17":x.e17,"e18":x.e18,
  275. "e19":x.e19,"e20":x.e20,"e21":x.e21,"e22":x.e22,
  276. "e23":x.e23,"e24":x.e24,"e25":x.e25,"e26":x.e26,
  277. "e27":x.e27,"e28":x.e28,"e29":x.e29,"e30":x.e30}
  278. except:
  279. conf = {}
  280. try:
  281. led = MongoQXZ_Base_Info.objects.get(device_id=e_id).led
  282. except:
  283. led = "0"
  284. try:
  285. ledinfo = MongoQXZ_Base_Info.objects.get(device_id=e_id).ledinfo
  286. except:
  287. ledinfo = ""
  288. data = {'dat':dat,'conf':conf, "led":led,"ledinfo":ledinfo}
  289. return data
  290. @kedong_deco(login_required=True)
  291. def qxz_data_chart(request):
  292. """
  293. 气象折线图接口 :
  294. 参数:
  295. device_id 必传(string)
  296. begin 必传(string 时间戳) 开始时间 (用于时间搜索) 默认近一个月
  297. end 非必传(string 时间戳) 结束时间 (用于时间搜索)
  298. 返回值:
  299. {
  300. "data": {
  301. "conf": {
  302. "e1":x.e1,"e2":x.e2,"e3":x.e3,"e4":x.e4,"e5":x.e5,
  303. "e6":x.e6,"e7":x.e7,"e8":x.e8,"e9":x.e9,"e10":x.e10,
  304. "e11":x.e11,"e12":x.e12,"e13":x.e13,"e14":x.e14,
  305. "e15":x.e15,"e16":x.e16,"e17":x.e17,"e18":x.e18,
  306. "e19":x.e19,"e20":x.e20,"e21":x.e21,"e22":x.e22,
  307. "e23":x.e23,"e24":x.e24,"e25":x.e25,"e26":x.e26,
  308. "e27":x.e27,"e28":x.e28,"e29":x.e29,"e30":x.e30
  309. },
  310. "nums": 0,
  311. "data": [
  312. {
  313. "e1":qxz_list.e1,"e2":qxz_list.e2,"e3":qxz_list.e3,"e4":qxz_list.e4,"e5":qxz_list.e5,
  314. "e6":qxz_list.e6,"e7":qxz_list.e7,"e8":qxz_list.e8,"e9":qxz_list.e9,"e10":qxz_list.e10,
  315. "e11":qxz_list.e11,"e12":qxz_list.e12,"e13":qxz_list.e13,"e14":qxz_list.e14,
  316. "e15":qxz_list.e15,"e16":qxz_list.e16,"e17":qxz_list.e17,"e18":qxz_list.e18,
  317. "e19":qxz_list.e19,"e20":qxz_list.e20,"e21":qxz_list.e21,"e22":qxz_list.e22,
  318. "e23":qxz_list.e23,"e24":qxz_list.e24,"e25":qxz_list.e25,"e26":qxz_list.e26,
  319. "e27":qxz_list.e27,"e28":qxz_list.e28,"e29":qxz_list.e29,"e30":qxz_list.e30,
  320. "upl_time":qxz_list.upl_time.strftime('%Y-%m-%d %H:%M:%S')
  321. },
  322. {
  323. "e1":qxz_list.e1,"e2":qxz_list.e2,"e3":qxz_list.e3,"e4":qxz_list.e4,"e5":qxz_list.e5,
  324. "e6":qxz_list.e6,"e7":qxz_list.e7,"e8":qxz_list.e8,"e9":qxz_list.e9,"e10":qxz_list.e10,
  325. "e11":qxz_list.e11,"e12":qxz_list.e12,"e13":qxz_list.e13,"e14":qxz_list.e14,
  326. "e15":qxz_list.e15,"e16":qxz_list.e16,"e17":qxz_list.e17,"e18":qxz_list.e18,
  327. "e19":qxz_list.e19,"e20":qxz_list.e20,"e21":qxz_list.e21,"e22":qxz_list.e22,
  328. "e23":qxz_list.e23,"e24":qxz_list.e24,"e25":qxz_list.e25,"e26":qxz_list.e26,
  329. "e27":qxz_list.e27,"e28":qxz_list.e28,"e29":qxz_list.e29,"e30":qxz_list.e30,
  330. "upl_time":qxz_list.upl_time.strftime('%Y-%m-%d %H:%M:%S')
  331. },...
  332. ]
  333. }
  334. "params": {},
  335. "formError": {},
  336. "errorCode": 0,
  337. "message": "",
  338. }
  339. """
  340. device_id = request.POST.get("device_id")
  341. data = []
  342. f_tbegin = request.POST.get('begin')
  343. f_tend = request.POST.get('end')
  344. try:
  345. device = MongoDevice.objects.get(device_id=device_id)
  346. device_expire = device.device_expire
  347. device_expire_time = device.device_expire_time
  348. except:
  349. raise PortError('device_id',"暂无此设备")
  350. qxz_list = QXZdata_New.objects.filter(device_id=device_id)
  351. myuser_type = request.user_type
  352. if not myuser_type == 1 and not myuser_type == 5:
  353. if f_tbegin and int(f_tend) > int(device_expire_time):
  354. f_tend = device_expire_time
  355. if f_tbegin and f_tend:
  356. qxz_list =qxz_list.filter(uptime__range=(int(f_tbegin),int(f_tend))).order_by('-id')
  357. conf = {}
  358. for i in qxz_list:
  359. data.append({"dat":{"e1":i.e1,"e2":i.e2,"e3":i.e3,"e4":i.e4,"e5":i.e5,
  360. "e6":i.e6,"e7":i.e7,"e8":i.e8,"e9":i.e9,"e10":i.e10,
  361. "e11":i.e11,"e12":i.e12,"e13":i.e13,"e14":i.e14,
  362. "e15":i.e15,"e16":i.e16,"e17":i.e17,"e18":i.e18,
  363. "e19":i.e19,"e20":i.e20,"e21":i.e21,"e22":i.e22,
  364. "e23":i.e23,"e24":i.e24,"e25":i.e25,"e26":i.e26,
  365. "e27":i.e27,"e28":i.e28,"e29":i.e29,"e30":i.e30},
  366. "time":i.uptime})
  367. try:
  368. x = MongoQXZ_Conf.objects.get(device_id=device_id)
  369. conf = {"e1":x.e1,"e2":x.e2,"e3":x.e3,"e4":x.e4,"e5":x.e5,
  370. "e6":x.e6,"e7":x.e7,"e8":x.e8,"e9":x.e9,"e10":x.e10,
  371. "e11":x.e11,"e12":x.e12,"e13":x.e13,"e14":x.e14,
  372. "e15":x.e15,"e16":x.e16,"e17":x.e17,"e18":x.e18,
  373. "e19":x.e19,"e20":x.e20,"e21":x.e21,"e22":x.e22,
  374. "e23":x.e23,"e24":x.e24,"e25":x.e25,"e26":x.e26,
  375. "e27":x.e27,"e28":x.e28,"e29":x.e29,"e30":x.e30}
  376. except:
  377. conf = {}
  378. data1 = {"data":data,"conf":conf}
  379. return data1
  380. @kedong_deco(login_required=True)
  381. def qxz_early_warning(request):
  382. """
  383. 气象站查看短信预警信息接口\配置预警信息接口
  384. 参数:
  385. device_id 必传(str) 设备号
  386. status 必传(str) 当status等于see查看, 当status等于save保存
  387. alarm 非必传(json) 配置信息,例如:{"dat":{"e1":"1#12","e2":"0#","e3":"0#","e4":"0#","e5":"0#","e6":"0#","e7":"0#","e8":"0#","e9":"0#"},"tel":"18258845915","equip_id":"865553058440811"}
  388. 返回值:
  389. {
  390. "data" 0 0 保存成功 1失败
  391. }
  392. """
  393. status = request.POST.get("status")
  394. device_id = request.POST.get("device_id")
  395. if status == "see":
  396. try:
  397. qxz_alarm = MongoQXZ_Alarm.objects.get(device_id=device_id)
  398. alarm = ast.literal_eval(qxz_alarm.conf)
  399. phone = qxz_alarm.phone
  400. except Exception as e:
  401. print(e)
  402. alarm = ""
  403. phone = ""
  404. x = MongoQXZ_Conf.objects.get(device_id=device_id)
  405. conf = {"e1":x.e1,"e2":x.e2,"e3":x.e3,"e4":x.e4,"e5":x.e5,
  406. "e6":x.e6,"e7":x.e7,"e8":x.e8,"e9":x.e9,"e10":x.e10,
  407. "e11":x.e11,"e12":x.e12,"e13":x.e13,"e14":x.e14,
  408. "e15":x.e15,"e16":x.e16,"e17":x.e17,"e18":x.e18,
  409. "e19":x.e19,"e20":x.e20,"e21":x.e21,"e22":x.e22,
  410. "e23":x.e23,"e24":x.e24,"e25":x.e25,"e26":x.e26,
  411. "e27":x.e27,"e28":x.e28,"e29":x.e29,"e30":x.e30}
  412. for k in list(conf.keys()):
  413. if not conf[k]:
  414. del conf[k]
  415. data = {"conf":conf,"alarm":alarm,"phone":phone}
  416. elif status == "save":
  417. alarm = ast.literal_eval(request.POST.get('alarm'))
  418. conf = alarm["dat"]
  419. try:
  420. MongoQXZ_Alarm.objects.update_or_create(
  421. device_id=device_id,
  422. defaults={
  423. "conf": {"dat": conf},
  424. "upl_time": int(time.time())
  425. }
  426. )
  427. return {"code":0}
  428. except Exception as e:
  429. raise PortError("","更新失败")
  430. else:
  431. raise PortError("","参数超出范围")
  432. return data
  433. def qxz_configs(conf,e_data,es):
  434. """气象站要素配置"""
  435. e3s = conf.get(es,"")
  436. code = e_data.split('#')[1]
  437. if e3s:
  438. config = e3s.split("#")
  439. config.insert(0,code)
  440. else:
  441. config = qxz_dict_1[e_data.split('#')[1]]
  442. return config
  443. @kedong_deco(login_required=True)
  444. def qxz_day_data(request):
  445. """
  446. 气象24H数据接口 :
  447. 参数:
  448. device_id 必传(string)
  449. 返回值:
  450. {
  451. "data": {
  452. "conf": {
  453. "e1":x.e1,"e2":x.e2,"e3":x.e3,"e4":x.e4,"e5":x.e5,
  454. "e6":x.e6,"e7":x.e7,"e8":x.e8,"e9":x.e9,"e10":x.e10,
  455. "e11":x.e11,"e12":x.e12,"e13":x.e13,"e14":x.e14,
  456. "e15":x.e15,"e16":x.e16,"e17":x.e17,"e18":x.e18,
  457. "e19":x.e19,"e20":x.e20,"e21":x.e21,"e22":x.e22,
  458. "e23":x.e23,"e24":x.e24,"e25":x.e25,"e26":x.e26,
  459. "e27":x.e27,"e28":x.e28,"e29":x.e29,"e30":x.e30
  460. },
  461. "nums": 0,
  462. "data": [
  463. {
  464. "e1":qxz_list.e1,"e2":qxz_list.e2,"e3":qxz_list.e3,"e4":qxz_list.e4,"e5":qxz_list.e5,
  465. "e6":qxz_list.e6,"e7":qxz_list.e7,"e8":qxz_list.e8,"e9":qxz_list.e9,"e10":qxz_list.e10,
  466. "e11":qxz_list.e11,"e12":qxz_list.e12,"e13":qxz_list.e13,"e14":qxz_list.e14,
  467. "e15":qxz_list.e15,"e16":qxz_list.e16,"e17":qxz_list.e17,"e18":qxz_list.e18,
  468. "e19":qxz_list.e19,"e20":qxz_list.e20,"e21":qxz_list.e21,"e22":qxz_list.e22,
  469. "e23":qxz_list.e23,"e24":qxz_list.e24,"e25":qxz_list.e25,"e26":qxz_list.e26,
  470. "e27":qxz_list.e27,"e28":qxz_list.e28,"e29":qxz_list.e29,"e30":qxz_list.e30,
  471. "upl_time":qxz_list.upl_time.strftime('%Y-%m-%d %H:%M:%S')
  472. },
  473. {
  474. "e1":qxz_list.e1,"e2":qxz_list.e2,"e3":qxz_list.e3,"e4":qxz_list.e4,"e5":qxz_list.e5,
  475. "e6":qxz_list.e6,"e7":qxz_list.e7,"e8":qxz_list.e8,"e9":qxz_list.e9,"e10":qxz_list.e10,
  476. "e11":qxz_list.e11,"e12":qxz_list.e12,"e13":qxz_list.e13,"e14":qxz_list.e14,
  477. "e15":qxz_list.e15,"e16":qxz_list.e16,"e17":qxz_list.e17,"e18":qxz_list.e18,
  478. "e19":qxz_list.e19,"e20":qxz_list.e20,"e21":qxz_list.e21,"e22":qxz_list.e22,
  479. "e23":qxz_list.e23,"e24":qxz_list.e24,"e25":qxz_list.e25,"e26":qxz_list.e26,
  480. "e27":qxz_list.e27,"e28":qxz_list.e28,"e29":qxz_list.e29,"e30":qxz_list.e30,
  481. "upl_time":qxz_list.upl_time.strftime('%Y-%m-%d %H:%M:%S')
  482. },...
  483. ]
  484. }
  485. "params": {},
  486. "formError": {},
  487. "errorCode": 0,
  488. "message": "",
  489. }
  490. """
  491. device_id = request.POST.get("device_id")
  492. qxz_dict_1 = copy.deepcopy(qxz_dict) # 如果不拷贝 后面折线图修改字典会导致字典内容变化 从而造成数据错误
  493. times = ""
  494. try:
  495. MongoDevice.objects.get(device_id=device_id)
  496. except:
  497. logger.error(f"{device_id} 暂无此设备")
  498. raise PortError('device_id',"暂无此设备")
  499. qxz_list = QXZstatus_New.objects.filter(device_id=device_id).order_by("-uptime").first()
  500. if qxz_list:
  501. times = qxz_list.uptime
  502. # 获取最新一条数据的时间然后进行时间格式转换,再获取前一天时间
  503. if times:
  504. otherStyleTime = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(times))
  505. times_type = datetime.datetime.strptime(str(otherStyleTime), "%Y-%m-%d %H:%M:%S")
  506. now = times_type - datetime.timedelta(days=1)
  507. else:
  508. # 获取前一天的时间点从0点到24点时间
  509. now = datetime.datetime.now()- datetime.timedelta(days=1)
  510. zero_today = now - datetime.timedelta(hours=now.hour, minutes=now.minute, seconds=now.second,microseconds=now.microsecond)
  511. last_today = zero_today + datetime.timedelta(hours=23, minutes=59, seconds=59)
  512. start_time = int(time.mktime(time.strptime(str(zero_today), "%Y-%m-%d %H:%M:%S")))
  513. end_time = int(time.mktime(time.strptime(str(last_today), "%Y-%m-%d %H:%M:%S")))
  514. sta1 = QXZdata_New.objects.filter(device_id=device_id).filter(uptime__range=(start_time,end_time)).values()
  515. data = []
  516. e1 = []
  517. e1_time = []
  518. e2 = []
  519. e2_time = []
  520. e3 = []
  521. e3_time = []
  522. e4 = []
  523. e4_time = []
  524. e5 = []
  525. e5_time = []
  526. e6 = []
  527. e6_time = []
  528. e7 = []
  529. e7_time = []
  530. e8 = []
  531. e8_time = []
  532. e9 = []
  533. e9_time = []
  534. e10 = []
  535. e10_time = []
  536. e11 = []
  537. e11_time = []
  538. e12 = []
  539. e12_time = []
  540. e13 = []
  541. e13_time = []
  542. e14 = []
  543. e14_time = []
  544. e15 = []
  545. e15_time = []
  546. e16 = []
  547. e16_time = []
  548. e17 = []
  549. e17_time = []
  550. e18 = []
  551. e18_time = []
  552. e19 = []
  553. e19_time = []
  554. e20 = []
  555. e20_time = []
  556. e21 = []
  557. e21_time = []
  558. e22 = []
  559. e22_time = []
  560. e23 = []
  561. e23_time = []
  562. e24 = []
  563. e24_time = []
  564. e25 = []
  565. e25_time = []
  566. e26 = []
  567. e26_time = []
  568. e27 = []
  569. e27_time = []
  570. e28 = []
  571. e28_time = []
  572. e29 = []
  573. e29_time = []
  574. e30 = []
  575. e30_time = []
  576. for i in sta1[:200]:
  577. if i['e1']:
  578. e1.append(float(i['e1'].split('#')[0]))
  579. e1_time.append(i['uptime'])
  580. if i['e2']:
  581. e2.append(float(i['e2'].split('#')[0]))
  582. e2_time.append(i['uptime'])
  583. if i['e3']:
  584. e3.append(float(i['e3'].split('#')[0]))
  585. e3_time.append(i['uptime'])
  586. if i['e4']:
  587. e4.append(float(i['e4'].split('#')[0]))
  588. e4_time.append(i['uptime'])
  589. if i['e5']:
  590. e5.append(float(i['e5'].split('#')[0]))
  591. e5_time.append(i['uptime'])
  592. if i['e6']:
  593. e6.append(float(i['e6'].split('#')[0]))
  594. e6_time.append(i['uptime'])
  595. if i['e7']:
  596. e7.append(float(i['e7'].split('#')[0]))
  597. e7_time.append(i['uptime'])
  598. if i['e8']:
  599. e8.append(float(i['e8'].split('#')[0]))
  600. e8_time.append(i['uptime'])
  601. if i['e9']:
  602. e9.append(float(i['e9'].split('#')[0]))
  603. e9_time.append(i['uptime'])
  604. if i['e10']:
  605. e10.append(float(i['e10'].split('#')[0]))
  606. e10_time.append(i['uptime'])
  607. if i['e11']:
  608. e11.append(float(i['e11'].split('#')[0]))
  609. e11_time.append(i['uptime'])
  610. if i['e12']:
  611. e12.append(float(i['e12'].split('#')[0]))
  612. e12_time.append(i['uptime'])
  613. if i['e13']:
  614. e13.append(float(i['e13'].split('#')[0]))
  615. e13_time.append(i['uptime'])
  616. if i['e14']:
  617. e14.append(float(i['e14'].split('#')[0]))
  618. e14_time.append(i['uptime'])
  619. if i['e15']:
  620. e15.append(float(i['e15'].split('#')[0]))
  621. e15_time.append(i['uptime'])
  622. if i['e16']:
  623. e16.append(float(i['e16'].split('#')[0]))
  624. e16_time.append(i['uptime'])
  625. if i['e17']:
  626. e17.append(float(i['e17'].split('#')[0]))
  627. e17_time.append(i['uptime'])
  628. if i['e18']:
  629. e18.append(float(i['e18'].split('#')[0]))
  630. e18_time.append(i['uptime'])
  631. if i['e19']:
  632. e19.append(float(i['e19'].split('#')[0]))
  633. e19_time.append(i['uptime'])
  634. if i['e20']:
  635. e20.append(float(i['e20'].split('#')[0]))
  636. e20_time.append(i['uptime'])
  637. if i['e21']:
  638. e21.append(float(i['e21'].split('#')[0]))
  639. e21_time.append(i['uptime'])
  640. if i['e22']:
  641. e22.append(float(i['e22'].split('#')[0]))
  642. e22_time.append(i['uptime'])
  643. if i['e23']:
  644. e23.append(float(i['e23'].split('#')[0]))
  645. e23_time.append(i['uptime'])
  646. if i['e24']:
  647. e24.append(float(i['e24'].split('#')[0]))
  648. e24_time.append(i['uptime'])
  649. if i['e25']:
  650. e25.append(float(i['e25'].split('#')[0]))
  651. e25_time.append(i['uptime'])
  652. if i['e26']:
  653. e26.append(float(i['e26'].split('#')[0]))
  654. e26_time.append(i['uptime'])
  655. if i['e27']:
  656. e27.append(float(i['e27'].split('#')[0]))
  657. e27_time.append(i['uptime'])
  658. if i['e28']:
  659. e28.append(float(i['e28'].split('#')[0]))
  660. e28_time.append(i['uptime'])
  661. if i['e29']:
  662. e29.append(float(i['e29'].split('#')[0]))
  663. e29_time.append(i['uptime'])
  664. if i['e30']:
  665. e30.append(float(i['e30'].split('#')[0]))
  666. e30_time.append(i['uptime'])
  667. conf = {}
  668. x = MongoQXZ_Conf.objects.filter(device_id=device_id).first()
  669. if x:
  670. conf = {"e1":x.e1,"e2":x.e2,"e3":x.e3,"e4":x.e4,"e5":x.e5,
  671. "e6":x.e6,"e7":x.e7,"e8":x.e8,"e9":x.e9,"e10":x.e10,
  672. "e11":x.e11,"e12":x.e12,"e13":x.e13,"e14":x.e14,
  673. "e15":x.e15,"e16":x.e16,"e17":x.e17,"e18":x.e18,
  674. "e19":x.e19,"e20":x.e20,"e21":x.e21,"e22":x.e22,
  675. "e23":x.e23,"e24":x.e24,"e25":x.e25,"e26":x.e26,
  676. "e27":x.e27,"e28":x.e28,"e29":x.e29,"e30":x.e30}
  677. data = []
  678. try:
  679. if e1 != []:
  680. config = qxz_configs(conf,i['e1'],"e1")
  681. data.append({"max":max(e1),"maxtime":e1_time[e1.index(max(e1))],"min":min(e1),"mintime":e1_time[e1.index(min(e1))],"enum":config,"ekey":i['e1'].split('#')[2]})
  682. if e2 != []:
  683. config = qxz_configs(conf,i['e2'],"e2")
  684. data.append({"max":max(e2),"maxtime":e2_time[e2.index(max(e2))],"min":min(e2),"mintime":e2_time[e2.index(min(e2))],"enum":config,"ekey":i['e2'].split('#')[2]})
  685. if e3 != []:
  686. config = qxz_configs(conf,i['e3'],"e3")
  687. data.append({"max":max(e3),"maxtime":e3_time[e3.index(max(e3))],"min":min(e3),"mintime":e3_time[e3.index(min(e3))],"enum":config,"ekey":i['e3'].split('#')[2]})
  688. if e4 != []:
  689. config = qxz_configs(conf,i['e4'],"e4")
  690. data.append({"max":max(e4),"maxtime":e4_time[e4.index(max(e4))],"min":min(e4),"mintime":e4_time[e4.index(min(e4))],"enum":config,"ekey":i['e4'].split('#')[2]})
  691. if e5 != []:
  692. config = qxz_configs(conf,i['e5'],"e5")
  693. data.append({"max":max(e5),"maxtime":e5_time[e5.index(max(e5))],"min":min(e5),"mintime":e5_time[e5.index(min(e5))],"enum":config,"ekey":i['e5'].split('#')[2]})
  694. if e6 != []:
  695. config = qxz_configs(conf,i['e6'],"e6")
  696. data.append({"max":max(e6),"maxtime":e6_time[e6.index(max(e6))],"min":min(e6),"mintime":e6_time[e6.index(min(e6))],"enum":config,"ekey":i['e6'].split('#')[2]})
  697. if e7 != []:
  698. config = qxz_configs(conf,i['e7'],"e7")
  699. data.append({"max":max(e7),"maxtime":e7_time[e7.index(max(e7))],"min":min(e7),"mintime":e7_time[e7.index(min(e7))],"enum":config,"ekey":i['e7'].split('#')[2]})
  700. if e8 != []:
  701. config = qxz_configs(conf,i['e8'],"e8")
  702. data.append({"max":max(e8),"maxtime":e8_time[e8.index(max(e8))],"min":min(e8),"mintime":e8_time[e8.index(min(e8))],"enum":config,"ekey":i['e8'].split('#')[2]})
  703. if e9 != []:
  704. config = qxz_configs(conf,i['e9'],"e9")
  705. data.append({"max":max(e9),"maxtime":e9_time[e9.index(max(e9))],"min":min(e9),"mintime":e9_time[e9.index(min(e9))],"enum":config,"ekey":i['e9'].split('#')[2]})
  706. if e10 != []:
  707. config = qxz_configs(conf,i['e10'],"e10")
  708. data.append({"max":max(e10),"maxtime":e10_time[e10.index(max(e10))],"min":min(e10),"mintime":e10_time[e10.index(min(e10))],"enum":config,"ekey":i['e10'].split('#')[2]})
  709. if e11 != []:
  710. config = qxz_configs(conf,i['e11'],"e11")
  711. data.append({"max":max(e11),"maxtime":e11_time[e11.index(max(e11))],"min":min(e11),"mintime":e11_time[e11.index(min(e11))],"enum":config,"ekey":i['e11'].split('#')[2]})
  712. if e12 != []:
  713. config = qxz_configs(conf,i['e12'],"e12")
  714. data.append({"max":max(e12),"maxtime":e12_time[e12.index(max(e12))],"min":min(e12),"mintime":e12_time[e12.index(min(e12))],"enum":config,"ekey":i['e12'].split('#')[2]})
  715. if e13 != []:
  716. config = qxz_configs(conf,i['e13'],"e13")
  717. data.append({"max":max(e13),"maxtime":e13_time[e13.index(max(e13))],"min":min(e13),"mintime":e13_time[e13.index(min(e13))],"enum":config,"ekey":i['e13'].split('#')[2]})
  718. if e14 != []:
  719. config = qxz_configs(conf,i['e14'],"e14")
  720. data.append({"max":max(e14),"maxtime":e14_time[e14.index(max(e14))],"min":min(e14),"mintime":e14_time[e14.index(min(e14))],"enum":config,"ekey":i['e14'].split('#')[2]})
  721. if e15 != []:
  722. config = qxz_configs(conf,i['e15'],"e15")
  723. data.append({"max":max(e15),"maxtime":e15_time[e15.index(max(e15))],"min":min(e15),"mintime":e15_time[e15.index(min(e15))],"enum":config,"ekey":i['e15'].split('#')[2]})
  724. if e16 != []:
  725. config = qxz_configs(conf,i['e16'],"e16")
  726. data.append({"max":max(e16),"maxtime":e16_time[e16.index(max(e16))],"min":min(e16),"mintime":e16_time[e16.index(min(e16))],"enum":config,"ekey":i['e16'].split('#')[2]})
  727. if e17 != []:
  728. config = qxz_configs(conf,i['e17'],"e17")
  729. data.append({"max":max(e17),"maxtime":e17_time[e17.index(max(e17))],"min":min(e17),"mintime":e17_time[e17.index(min(e17))],"enum":config,"ekey":i['e17'].split('#')[2]})
  730. if e18 != []:
  731. config = qxz_configs(conf,i['e18'],"e18")
  732. data.append({"max":max(e18),"maxtime":e18_time[e18.index(max(e18))],"min":min(e18),"mintime":e18_time[e18.index(min(e18))],"enum":config,"ekey":i['e18'].split('#')[2]})
  733. if e19 != []:
  734. config = qxz_configs(conf,i['e19'],"e19")
  735. data.append({"max":max(e19),"maxtime":e19_time[e19.index(max(e19))],"min":min(e19),"mintime":e19_time[e19.index(min(e19))],"enum":config,"ekey":i['e19'].split('#')[2]})
  736. if e20 != []:
  737. config = qxz_configs(conf,i['e20'],"e20")
  738. data.append({"max":max(e20),"maxtime":e20_time[e20.index(max(e20))],"min":min(e20),"mintime":e20_time[e20.index(min(e20))],"enum":config,"ekey":i['e20'].split('#')[2]})
  739. if e21 != []:
  740. config = qxz_configs(conf,i['e21'],"e21")
  741. data.append({"max":max(e21),"maxtime":e21_time[e21.index(max(e21))],"min":min(e21),"mintime":e21_time[e21.index(min(e21))],"enum":config,"ekey":i['e21'].split('#')[2]})
  742. if e22 != []:
  743. config = qxz_configs(conf,i['e22'],"e22")
  744. data.append({"max":max(e22),"maxtime":e22_time[e22.index(max(e22))],"min":min(e22),"mintime":e22_time[e22.index(min(e22))],"enum":config,"ekey":i['e22'].split('#')[2]})
  745. if e23 != []:
  746. config = qxz_configs(conf,i['e23'],"e23")
  747. data.append({"max":max(e23),"maxtime":e23_time[e23.index(max(e23))],"min":min(e23),"mintime":e23_time[e23.index(min(e23))],"enum":config,"ekey":i['e23'].split('#')[2]})
  748. if e24 != []:
  749. config = qxz_configs(conf,i['e24'],"e24")
  750. data.append({"max":max(e24),"maxtime":e24_time[e24.index(max(e24))],"min":min(e24),"mintime":e24_time[e24.index(min(e24))],"enum":config,"ekey":i['e24'].split('#')[2]})
  751. if e25 != []:
  752. config = qxz_configs(conf,i['e25'],"e25")
  753. data.append({"max":max(e25),"maxtime":e25_time[e25.index(max(e25))],"min":min(e25),"mintime":e25_time[e25.index(min(e25))],"enum":config,"ekey":i['e25'].split('#')[2]})
  754. if e26 != []:
  755. config = qxz_configs(conf,i['e26'],"e26")
  756. data.append({"max":max(e26),"maxtime":e26_time[e26.index(max(e26))],"min":min(e26),"mintime":e26_time[e26.index(min(e26))],"enum":config,"ekey":i['e26'].split('#')[2]})
  757. if e27 != []:
  758. config = qxz_configs(conf,i['e27'],"e27")
  759. data.append({"max":max(e27),"maxtime":e27_time[e27.index(max(e27))],"min":min(e27),"mintime":e27_time[e27.index(min(e27))],"enum":config,"ekey":i['e27'].split('#')[2]})
  760. if e28 != []:
  761. config = qxz_configs(conf,i['e28'],"e28")
  762. data.append({"max":max(e28),"maxtime":e28_time[e28.index(max(e28))],"min":min(e28),"mintime":e28_time[e28.index(min(e28))],"enum":config,"ekey":i['e28'].split('#')[2]})
  763. if e29 != []:
  764. config = qxz_configs(conf,i['e29'],"e29")
  765. data.append({"max":max(e29),"maxtime":e29_time[e29.index(max(e29))],"min":min(e29),"mintime":e29_time[e29.index(min(e29))],"enum":config,"ekey":i['e29'].split('#')[2]})
  766. if e30 != []:
  767. config = qxz_configs(conf,i['e30'],"e30")
  768. data.append({"max":max(e30),"maxtime":e30_time[e30.index(max(e30))],"min":min(e30),"mintime":e30_time[e30.index(min(e30))],"enum":config,"ekey":i['e30'].split('#')[2]})
  769. except Exception as e:
  770. logger.error(f"气象站24h数据:{e}")
  771. raise PortError(" ", "计算数据失败,稍后重试")
  772. dat = {"data":data,"conf":conf}
  773. return dat
  774. @kedong_deco(login_required=False)
  775. def device_status_data(request):
  776. """
  777. 虫情测报灯/数据详情
  778. 设备实时状态接口
  779. 参数:
  780. device_id 必传 设备id
  781. 返回值:
  782. "data": {
  783. "upds": 1, 上仓门状态 1打开,0关闭
  784. "tpl": 5, 低温保护阈值温度
  785. "dver": "1.0.0", 设备固件版本
  786. "gs": 0, 通道状态 1落虫,0排水
  787. "hs": 0, 加热状态 1加热,0正常
  788. "dnds": 0, 下仓门状态 1打开,0关闭
  789. "is_online": 0, 在线状态
  790. "csq": 29, 信号强度
  791. "tph": 70, 高温保护阈值温度
  792. "ts": 0 定时模式 0光控,1时控
  793. "tps": 1 温控状态 1 温控,0 正常
  794. "lps": 0 光控状态 1 光控,0 正常
  795. "hrt": 22 加热仓实时温度
  796. "device_name":"这里是设备名称",
  797. "address": "这里是设备位置",
  798. "iccid": 1234444 SIM卡号
  799. }
  800. """
  801. post_info = request.POST
  802. _device_id = post_info.get("device_id")
  803. if not _device_id:
  804. raise PortError('device_id', "该设备不存在")
  805. try:
  806. device = MongoDevice.objects.get(device_id=_device_id)
  807. except:
  808. raise PortError('device_id','暂无此设备')
  809. d_id = device.id
  810. device_name = device.device_name
  811. province = device.province
  812. city = device.city
  813. district = device.district
  814. device_status = device.device_status # 在线状态
  815. myuser_type = request.user_type
  816. device_datas = MongoCBDData.objects.filter(device_id=d_id).order_by('-id')
  817. try:
  818. device_data = json.loads(device_datas[0].device_data)
  819. except json.JSONDecodeError as e:
  820. device_data = eval(device_datas[0].device_data)
  821. except:
  822. raise PortError("device_id","暂无数据")
  823. ds = device_data.get("ds",1 )
  824. ts = device_data.get("ts",1)
  825. up_st = {
  826. "is_online": device_status,
  827. "ts":ts,
  828. "hs":device_data["hs"],
  829. "upds":device_data["upds"],
  830. "dnds":device_data["dnds"],
  831. "csq":device_data["csq"],
  832. "dver":device_data["dver"],
  833. "tph":device_data["tph"],
  834. "tpl":device_data["tpl"],
  835. "tps":device_data["tps"],
  836. "lps":device_data["lps"],
  837. "hrt":device_data["hrt"],
  838. "iccid":device_data["iccid"],
  839. "rps":device_data["rps"],
  840. "ah":device_data["ah"],
  841. "at":device_data["at"],
  842. "ds":ds,
  843. "device_name":device_name,
  844. "address": province + city + district,
  845. }
  846. return up_st
  847. @kedong_deco(login_required=True)
  848. def qxz_switch_status(request):
  849. """
  850. 气象站开关、阈值状态接口
  851. 参数:
  852. device_id 必传(str) 设备号
  853. 返回值:
  854. {
  855. qxz_switch: "[{'status': 0, 'JK': 0}, {'status': 0, 'JK': 1}]" 开关状态
  856. switch_name: "[{'name': '开关0', 'JK': 0}, {'name': '', 'JK': 1}]" 开关名称
  857. timing_list: "[{'JK': 0, 'Duration': 4, 'StartTime': 3}, {'JK': 1, 'Duration': 8, 'StartTime': 7}]" 定时控制
  858. auto_list: [{'lower': 32767, 'JK': 0, 'method': 0, 'upper': 32767, 'eKey': 0}]" 阈值状态
  859. }
  860. """
  861. device_id = request.POST.get("device_id")
  862. data = []
  863. try:
  864. switch_obj = QXZ_Switch_Status.objects.get(device_id=device_id)
  865. qxz_switch = switch_obj.qxz_switch
  866. except:
  867. qxz_switch = ""
  868. try:
  869. switch_name_obj = MongoQXZ_Switch.objects.get(device_id=device_id)
  870. switch_name = switch_name_obj.qxz_switch_data
  871. except:
  872. switch_name = ""
  873. try:
  874. timing_list = MongoQXZ_Timing_Switch.objects.get(device_id=device_id).qxz_timing
  875. except:
  876. timing_list = ""
  877. try:
  878. auto_list = MongoQXZ_Auto_Switch.objects.get(device_id=device_id).qxz_auto
  879. except:
  880. auto_list = ""
  881. data = {'qxz_switch':qxz_switch, 'switch_name':switch_name, 'timing_list':timing_list,"auto_list":auto_list}
  882. return data
  883. @kedong_deco(login_required=False)
  884. def qxz_element_conf(request):
  885. """
  886. 气象站查看通道要素接口\保存通道要素接口:
  887. 参数:
  888. device_id 必传(str) 设备号
  889. status 必传(str) 当status等于see查看, 当status等于save保存
  890. ekey 非必传(str) 通道号 如e1
  891. conf 非必传(str) 通道标题,如大气温度#℃
  892. 说明:当status等于see查看,只需要传device_id,当status等于save保存 需传device_id、conf、ekey
  893. 返回值:
  894. 当status等于see时:
  895. "data": {
  896. "default": { 原来值
  897. "e1": "大气温度#℃",
  898. "e2": "大气湿度#%RH",
  899. "e3": "风速#m/s",
  900. "e4": "风向#°",
  901. "e5": "模拟气压#hpa",
  902. "e6": "简易总辐射#w/㎡"
  903. },
  904. "conf": { 修改值
  905. "e1": "大气温度#℃",
  906. "e2": "大气湿度#%RH",
  907. "e3": "风速#m/s",
  908. "e4": "风向#°",
  909. "e5": "模拟气压#hpa",
  910. "e6": "简易总辐射#w/㎡"
  911. }
  912. },
  913. 当status等于save时:
  914. {
  915. "data" 0 0 保存成功 1失败
  916. }
  917. """
  918. device_id = request.POST.get("device_id")
  919. status = request.POST.get("status")
  920. ekey = request.POST.get("ekey")
  921. conf = request.POST.get("conf")
  922. if status == "see":
  923. x = MongoQXZ_Conf.objects.get(device_id=device_id)
  924. i = QXZ_Default_Conf.objects.get(device_id=device_id)
  925. conf = {"e1":x.e1,"e2":x.e2,"e3":x.e3,"e4":x.e4,"e5":x.e5,
  926. "e6":x.e6,"e7":x.e7,"e8":x.e8,"e9":x.e9,"e10":x.e10,
  927. "e11":x.e11,"e12":x.e12,"e13":x.e13,"e14":x.e14,
  928. "e15":x.e15,"e16":x.e16,"e17":x.e17,"e18":x.e18,
  929. "e19":x.e19,"e20":x.e20,"e21":x.e21,"e22":x.e22,
  930. "e23":x.e23,"e24":x.e24,"e25":x.e25,"e26":x.e26,
  931. "e27":x.e27,"e28":x.e28,"e29":x.e29,"e30":x.e30}
  932. default = {"e1":i.e1,"e2":i.e2,"e3":i.e3,"e4":i.e4,"e5":i.e5,
  933. "e6":i.e6,"e7":i.e7,"e8":i.e8,"e9":i.e9,"e10":i.e10,
  934. "e11":i.e11,"e12":i.e12,"e13":i.e13,"e14":i.e14,
  935. "e15":i.e15,"e16":i.e16,"e17":i.e17,"e18":i.e18,
  936. "e19":i.e19,"e20":i.e20,"e21":i.e21,"e22":i.e22,
  937. "e23":i.e23,"e24":i.e24,"e25":i.e25,"e26":i.e26,
  938. "e27":i.e27,"e28":i.e28,"e29":i.e29,"e30":i.e30}
  939. for k in list(conf.keys()):
  940. if not conf[k]:
  941. del conf[k]
  942. for y in list(default.keys()):
  943. if not default[y]:
  944. del default[y]
  945. data = {"default":default,"conf":conf}
  946. elif status == "save":
  947. times = int(time.time())
  948. conf_obj = MongoQXZ_Conf.objects.get(device_id=device_id)
  949. if ekey == "e1":
  950. con = (conf_obj.e1).split("#")
  951. conf_obj.e1 = conf + "#"+ con[1]
  952. conf_obj.update = times
  953. conf_obj.save()
  954. data = {"code": 0}
  955. elif ekey == "e2":
  956. con = (conf_obj.e2).split("#")
  957. conf = conf + "#"+ con[1]
  958. conf_obj.e2 = conf
  959. conf_obj.update = times
  960. conf_obj.save()
  961. data = {"code": 0}
  962. elif ekey == "e3":
  963. con = (conf_obj.e3).split("#")
  964. conf_obj.e3 = conf + "#"+ con[1]
  965. conf_obj.update = times
  966. conf_obj.save()
  967. data = {"code": 0}
  968. elif ekey == "e4":
  969. con = (conf_obj.e4).split("#")
  970. conf_obj.e4 = conf + "#"+ con[1]
  971. conf_obj.update = times
  972. conf_obj.save()
  973. data = {"code": 0}
  974. elif ekey == "e5":
  975. con = (conf_obj.e5).split("#")
  976. conf_obj.e5 = conf + "#"+ con[1]
  977. conf_obj.update = times
  978. conf_obj.save()
  979. data = {"code": 0}
  980. elif ekey == "e6":
  981. con = (conf_obj.e6).split("#")
  982. conf_obj.e6 = conf + "#"+ con[1]
  983. conf_obj.update = times
  984. conf_obj.save()
  985. data = {"code": 0}
  986. elif ekey == "e7":
  987. con = (conf_obj.e7).split("#")
  988. conf_obj.e7 = conf + "#"+ con[1]
  989. conf_obj.update = times
  990. conf_obj.save()
  991. data = {"code": 0}
  992. elif ekey == "e8":
  993. con = (conf_obj.e8).split("#")
  994. conf_obj.e8 = conf + "#"+ con[1]
  995. conf_obj.update = times
  996. conf_obj.save()
  997. data = {"code": 0}
  998. elif ekey == "e9":
  999. con = (conf_obj.e9).split("#")
  1000. conf_obj.e9 = conf + "#"+ con[1]
  1001. conf_obj.update = times
  1002. conf_obj.save()
  1003. data = {"code": 0}
  1004. elif ekey == "e10":
  1005. con = (conf_obj.e10).split("#")
  1006. conf_obj.e10 = conf + "#"+ con[1]
  1007. conf_obj.update = times
  1008. conf_obj.save()
  1009. data = {"code": 0}
  1010. elif ekey == "e11":
  1011. con = (conf_obj.e11).split("#")
  1012. conf_obj.e11 = conf + "#"+ con[1]
  1013. conf_obj.update = times
  1014. conf_obj.save()
  1015. data = {"code": 0}
  1016. elif ekey == "e12":
  1017. con = (conf_obj.e12).split("#")
  1018. conf_obj.e12 = conf + "#"+ con[1]
  1019. conf_obj.update = times
  1020. conf_obj.save()
  1021. data = {"code": 0}
  1022. elif ekey == "e13":
  1023. con = (conf_obj.e13).split("#")
  1024. conf_obj.e13 = conf + "#"+ con[1]
  1025. conf_obj.update = times
  1026. conf_obj.save()
  1027. data = {"code": 0}
  1028. elif ekey == "e14":
  1029. con = (conf_obj.e14).split("#")
  1030. conf_obj.e14 = conf + "#"+ con[1]
  1031. conf_obj.update = times
  1032. conf_obj.save()
  1033. data = {"code": 0}
  1034. elif ekey == "e15":
  1035. con = (conf_obj.e15).split("#")
  1036. conf_obj.e15 = conf + "#"+ con[1]
  1037. conf_obj.update = times
  1038. conf_obj.save()
  1039. data = {"code": 0}
  1040. elif ekey == "e16":
  1041. con = (conf_obj.e16).split("#")
  1042. conf_obj.e16 = conf + "#"+ con[1]
  1043. conf_obj.update = times
  1044. conf_obj.save()
  1045. data = {"code": 0}
  1046. elif ekey == "e17":
  1047. con = (conf_obj.e17).split("#")
  1048. conf_obj.e17 = conf + "#"+ con[1]
  1049. conf_obj.update = times
  1050. conf_obj.save()
  1051. data = {"code": 0}
  1052. elif ekey == "e18":
  1053. con = (conf_obj.e18).split("#")
  1054. conf_obj.e18 = conf + "#"+ con[1]
  1055. conf_obj.update = times
  1056. conf_obj.save()
  1057. data = {"code": 0}
  1058. elif ekey == "e19":
  1059. con = (conf_obj.e19).split("#")
  1060. conf_obj.e19 = conf + "#"+ con[1]
  1061. conf_obj.update = times
  1062. conf_obj.save()
  1063. data = {"code": 0}
  1064. elif ekey == "e20":
  1065. con = (conf_obj.e20).split("#")
  1066. conf_obj.e20 = conf + "#"+ con[1]
  1067. conf_obj.update = times
  1068. conf_obj.save()
  1069. data = {"code": 0}
  1070. elif ekey == "e21":
  1071. con = (conf_obj.e21).split("#")
  1072. conf_obj.e21 = conf + "#"+ con[1]
  1073. conf_obj.update = times
  1074. conf_obj.save()
  1075. data = {"code": 0}
  1076. elif ekey == "e22":
  1077. con = (conf_obj.e22).split("#")
  1078. conf_obj.e22 = conf + "#"+ con[1]
  1079. conf_obj.update = times
  1080. conf_obj.save()
  1081. data = {"code": 0}
  1082. elif ekey == "e23":
  1083. con = (conf_obj.e23).split("#")
  1084. conf_obj.e23 = conf + "#"+ con[1]
  1085. conf_obj.update = times
  1086. conf_obj.save()
  1087. data = {"code": 0}
  1088. elif ekey == "e24":
  1089. con = (conf_obj.e24).split("#")
  1090. conf_obj.e24 = conf + "#"+ con[1]
  1091. conf_obj.update = times
  1092. conf_obj.save()
  1093. data = {"code": 0}
  1094. elif ekey == "e25":
  1095. con = (conf_obj.e25).split("#")
  1096. conf_obj.e25 = conf + "#"+ con[1]
  1097. conf_obj.update = times
  1098. conf_obj.save()
  1099. data = {"code": 0}
  1100. elif ekey == "e26":
  1101. con = (conf_obj.e26).split("#")
  1102. conf_obj.e26 = conf + "#"+ con[1]
  1103. conf_obj.update = times
  1104. conf_obj.save()
  1105. data = {"code": 0}
  1106. elif ekey == "e27":
  1107. con = (conf_obj.e27).split("#")
  1108. conf_obj.e27 = conf + "#"+ con[1]
  1109. conf_obj.update = times
  1110. conf_obj.save()
  1111. data = {"code": 0}
  1112. elif ekey == "e28":
  1113. con = (conf_obj.e28).split("#")
  1114. conf_obj.e28 = conf + "#"+ con[1]
  1115. conf_obj.update = times
  1116. conf_obj.save()
  1117. data = {"code": 0}
  1118. elif ekey == "e29":
  1119. con = (conf_obj.e29).split("#")
  1120. conf_obj.e29 = conf + "#"+ con[1]
  1121. conf_obj.update = times
  1122. conf_obj.save()
  1123. data = {"code": 0}
  1124. elif ekey == "e30":
  1125. con = (conf_obj.e30).split("#")
  1126. conf_obj.e30 = conf + "#"+ con[1]
  1127. conf_obj.update = times
  1128. conf_obj.save()
  1129. data = {"code": 0}
  1130. else:
  1131. data = {"code": 1}
  1132. else:
  1133. raise PortError("","参数超出范围")
  1134. return data