Kezdőlap Felfedezés Súgó
Bejelentkezés
python
/
nongxiaohe
2
0
Másolás 0
Fájlok Problémák 0 Beolvasztási kérések 0 Wiki
Fa: 8997f9c98d
Branch-ok Tag-ek
nongxiaohe
/
front
/
api
/
device.py

device.py 31 KB
Előzmények Nyers

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403 
  1. #!/usr/bin/env python
    2. 

  2. # -*- coding: utf-8 -*-
    3. 

  3. """
    4. 

  4. 	demeter web
    5. 

  5. 	name:device.py 设备相关
    6. 

  6. 	author:rabin
    7. 

  7. """
    8. 

  8. from __load__ import *
    9. 

  9. 

  10. class index_path(Load):
    11. 

  11. 	"""
    12. 

  12. 	@api {get} /device 获取网关首页信息
    13. 

  13. 	@apiVersion 1.0.0
    14. 

  14. 	@apiName getDevice
    15. 

  15. 	@apiGroup Device
    16. 

  16. 

  17. 	@apiParam {String} id 网关id
    18. 

  18. 

  19. 	@apiSuccess {Object[]} setting 基本信息
    20. 

  20. 	@apiSuccess {String}   setting.name  站点名
    21. 

  21. 	@apiSuccess {Number}   setting.farm  当前的农场ID
    22. 

  22. 

  23. 	@apiSuccess {Object[]} info 网关状态基本信息
    24. 

  24. 	@apiSuccess {String}   info.id	网关ID
    25. 

  25. 	@apiSuccess {String}   info.name  网关名称
    26. 

  26. 	@apiSuccess {Bool}   info.status	网关状态
    27. 

  27. 	@apiSuccess {Number}   info.power	电量
    28. 

  28. 

  29. 	@apiSuccess {Object[]} device 设备数据
    30. 

  30. 	@apiSuccess {Number}   device.id	设备ID
    31. 

  31. 	@apiSuccess {String}   device.name  设备名称
    32. 

  32. 	@apiSuccess {String}   device.show	显示的数据
    33. 

  33. 	@apiSuccess {String}   device.unit	设备的单位
    34. 

  34. 	@apiSuccess {Number}   device.max	设备的上限
    35. 

  35. 	@apiSuccess {Number}   device.min	设备的下限
    36. 

  36. 	@apiSuccess {Bool}   device.status	设备状态
    37. 

  37. 

  38. 	@apiSuccess {Object[]} pic 图像数据
    39. 

  39. 	@apiSuccess {Number}   pic.id	图片ID
    40. 

  40. 	@apiSuccess {String}   pic.name  图片名称
    41. 

  41. 	@apiSuccess {String}   pic.show	图片地址
    42. 

  42. 	@apiSuccess {String}   pic.cdates	采集时间
    43. 

  43. 	@apiSuccess {String}   pic.cdate	采集时间戳
    44. 

  44. 

  45. 	@apiErrorExample 操作成功
    46. 

  46. 	{"status": 1, "msg": "yes", "code": 0, "data": {"info": {"status": true, "hardware_id": 10086, "name": "\u9ed8\u8ba4\u7f51\u5173", "farm_id": 1, "cdate": 1504233947, "state": true, "power_num": "", "power_status": "", "id": "ce37636b-3ce7-5de2-9160-0f3283f7d392"}, "device": [{"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100009, "name": "\u6e7f\u5ea6#100009", "type_id": 2, "max": 0, "farm_id": 1, "cdate": 1504253837, "state": true, "num": 30, "status": true, "min": 0, "show": "30", "id": "6d8a4c0e-4f85-524a-87f8-382c333c44da", "unit": "%RH"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100000, "name": "\u6e7f\u5ea6#100000", "type_id": 2, "max": 0, "farm_id": 1, "cdate": 1504253836, "state": true, "num": 5, "status": true, "min": 0, "show": "5", "id": "d644b079-9d4d-521c-8e65-8940c96ba9a7", "unit": "%RH"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100001, "name": "\u6e7f\u5ea6#100001", "type_id": 2, "max": 0, "farm_id": 1, "cdate": 1504253835, "state": true, "num": 4, "status": true, "min": 0, "show": "4", "id": "dc24428c-eafc-5715-b7d1-f3222d28c3bb", "unit": "%RH"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100004, "name": "\u6e7f\u5ea6#100004", "type_id": 2, "max": 0, "farm_id": 1, "cdate": 1504253834, "state": true, "num": 17, "status": true, "min": 0, "show": "17", "id": "62199416-cca0-5114-b900-a10f51e7e447", "unit": "%RH"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100005, "name": "\u6e7f\u5ea6#100005", "type_id": 2, "max": 0, "farm_id": 1, "cdate": 1504253833, "state": true, "num": 7, "status": true, "min": 0, "show": "7", "id": "456daa98-a1f0-59e6-a337-7ca1fa7b2527", "unit": "%RH"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100003, "name": "\u6e7f\u5ea6#100003", "type_id": 2, "max": 0, "farm_id": 1, "cdate": 1504253832, "state": true, "num": 39, "status": true, "min": 0, "show": "39", "id": "11bd4ad1-b4ff-5b1f-948a-935d859b408c", "unit": "%RH"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100007, "name": "\u6e7f\u5ea6#100007", "type_id": 2, "max": 0, "farm_id": 1, "cdate": 1504253828, "state": true, "num": 43, "status": true, "min": 0, "show": "43", "id": "f8e3a42a-7fa3-575a-b99e-2dab4f992239", "unit": "%RH"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100010, "name": "\u6e7f\u5ea6#100010", "type_id": 2, "max": 0, "farm_id": 1, "cdate": 1504253827, "state": true, "num": 20, "status": true, "min": 0, "show": "20", "id": "138876d7-1710-56fa-824b-10402cba17f8", "unit": "%RH"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100002, "name": "\u6e7f\u5ea6#100002", "type_id": 2, "max": 0, "farm_id": 1, "cdate": 1504253826, "state": true, "num": 43, "status": true, "min": 0, "show": "43", "id": "eecfe61f-de83-588f-8cbd-41519d4ebef3", "unit": "%RH"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100006, "name": "\u6e7f\u5ea6#100006", "type_id": 2, "max": 0, "farm_id": 1, "cdate": 1504253818, "state": true, "num": 4, "status": true, "min": 0, "show": "4", "id": "78bd90ac-6af3-5091-83e5-f3397063f743", "unit": "%RH"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100008, "name": "\u6e7f\u5ea6#100008", "type_id": 2, "max": 0, "farm_id": 1, "cdate": 1504253815, "state": true, "num": 37, "status": true, "min": 0, "show": "37", "id": "5fda8633-aed8-5a3b-8175-2c61e7553d91", "unit": "%RH"}], "setting": {"farm": 1, "user": 0, "name": "\u519c\u5c0f\u76d2", "copyright": "2017 nongxiaohe.com v1.0.0", "site": "http://www.nongxiaohe.com/"}, "pic": [{"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 5, "hardware_id": 200001, "name": "pic.jpg", "type_id": null, "farm_id": 1, "cdate": 1504262668, "cdates": "2017-09-01 10:44:28", "state": true, "num": 0, "status": true, "show": "/camera/2017/09/01/01c323ac0208580601252e2ce9eb3286.jpg", "id": "2f612150-f670-54e9-9886-a044cfb18e20"}]}}
    47. 

  47. 	@apiErrorExample 操作失败
    48. 

  48. 	{"status": 2, "msg": "\u64cd\u4f5c\u5931\u8d25", "code": 0, "data": {}}
    49. 

  49. 	"""
    50. 

  50. 	@auth
    51. 

  51. 	def get(self):
    52. 

  52. 		id = self.input('id', None)
    53. 

  53. 		if id:
    54. 

  54. 			self.data['info'] = self.service('common').one('device_gateway', id=id)
    55. 

  55. 			if not self.data['info']:
    56. 

  56. 				self.out('no')
    57. 

  57. 				return
    58. 

  58. 			self.data['device'] = self.service('common').list('device_info', state=True, search={'hardware_type':2, 'gateway_id':id})
    59. 

  59. 			if self.data['device']:
    60. 

  60. 				for key, value in enumerate(self.data['device']):
    61. 

  61. 					type = self.service('common').one('device_type', id=value['type_id'])
    62. 

  62. 					self.data['device'][key]['unit'] = type['unit']
    63. 

  63. 					set = self.service('common').one('device_set', device_id=value['id'])
    64. 

  64. 					if set:
    65. 

  65. 						self.data['device'][key]['max'] = set['max']
    66. 

  66. 						self.data['device'][key]['min'] = set['min']
    67. 

  67. 					else:
    68. 

  68. 						self.data['device'][key]['max'] = 0
    69. 

  69. 						self.data['device'][key]['min'] = 0
    70. 

  70. 

  71. 			self.data['pic'] = self.service('common').list('device_info', state=True, search={'hardware_type':6, 'gateway_id':id})
    72. 

  72. 			if self.data['pic']:
    73. 

  73. 				for key, value in enumerate(self.data['pic']):
    74. 

  74. 					self.data['pic'][key]['cdates'] = Demeter.date(value['cdate'])
    75. 

  75. 

  76. 			self.out('yes', self.data)
    77. 

  77. 		else:
    78. 

  78. 			self.out('no')
    79. 

  79. 

  80. class stat_path(Load):
    81. 

  81. 	"""
    82. 

  82. 	@api {get} /device/stat 获取数据统计
    83. 

  83. 	@apiVersion 1.0.0
    84. 

  84. 	@apiName getDeviceStat
    85. 

  85. 	@apiGroup Device
    86. 

  86. 

  87. 	@apiParam {String} id 网关id
    88. 

  88. 	@apiParam {String} device 设备id
    89. 

  89. 	@apiParam {String} search_group 周期ID
    90. 

  90. 	@apiParam {String} search_start 开始时间:2017-10-10 10:10:10
    91. 

  91. 	@apiParam {String} search_end 结束时间:2017-10-10 10:10:10
    92. 

  92. 

  93. 	@apiSuccess {Object[]} setting 基本信息
    94. 

  94. 	@apiSuccess {String}   setting.name  站点名
    95. 

  95. 	@apiSuccess {Number}   setting.farm  当前的农场ID
    96. 

  96. 

  97. 	@apiSuccess {Object[]} info 网关状态基本信息
    98. 

  98. 	@apiSuccess {String}   info.id	网关ID
    99. 

  99. 	@apiSuccess {String}   info.name  网关名称
    100. 

  100. 

  101. 	@apiSuccess {Object[]} data 设备选择
    102. 

  102. 	@apiSuccess {Number}   data.id	设备ID
    103. 

  103. 	@apiSuccess {String}   data.name  设备名称
    104. 

  104. 

  105. 	@apiSuccess {Object[]} group 周期选择
    106. 

  106. 	@apiSuccess {Number}   group.id	周期ID
    107. 

  107. 	@apiSuccess {String}   group.name  周期名称
    108. 

  108. 

  109. 	@apiSuccess {Object[]} cur_device 当前选择的设备
    110. 

  110. 	@apiSuccess {Number}   cur_device.id	设备ID
    111. 

  111. 	@apiSuccess {String}   cur_device.name  设备名称
    112. 

  112. 

  113. 	@apiSuccess {Object[]} data 设备数据,两条线
    114. 

  114. 	@apiSuccess {String}   data.name 本条数据名
    115. 

  115. 	@apiSuccess {Object[]}   data.data 本条数据的具体数据
    116. 

  116. 	@apiSuccess {String}   data.data.time 数据时间
    117. 

  117. 	@apiSuccess {String}   data.data.value 数据具体的值
    118. 

  118. 

  119. 	@apiSuccess {Object[]} search 当前搜索的值
    120. 

  120. 	@apiSuccess {String}   search.group	周期的值
    121. 

  121. 	@apiSuccess {String}   search.start  开始时间
    122. 

  122. 	@apiSuccess {String}   search.end  结束时间
    123. 

  123. 

  124. 	@apiErrorExample 操作成功
    125. 

  125. 	{"status": 1, "msg": "yes", "code": 0, "data": {"info": {"status": true, "hardware_id": 10086, "name": "\u9ed8\u8ba4\u7f51\u5173", "farm_id": 1, "cdate": 1504233947, "state": true, "power_num": "", "power_status": "", "id": "ce37636b-3ce7-5de2-9160-0f3283f7d392"}, "search": {"group": "1"}, "group": [{"id": "1", "name": "\u4e00\u5929"}, {"id": "7", "name": "\u4e00\u5468"}, {"id": "30", "name": "\u4e00\u4e2a\u6708"}, {"id": "180", "name": "\u534a\u5e74"}], "setting": {"farm": 1, "user": 0, "name": "\u519c\u5c0f\u76d2", "copyright": "2017 nongxiaohe.com v1.0.0", "site": "http://www.nongxiaohe.com/"}, "cur_device": {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": "", "hardware_type": 2, "hardware_id": 100001, "name": "\u6e7f\u5ea6#100001", "type_id": 2, "farm_id": 1, "cdate": 1504253835, "state": true, "num": 4, "status": true, "show": "4", "id": "dc24428c-eafc-5715-b7d1-f3222d28c3bb"}, "device": [{"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100009, "name": "\u6e7f\u5ea6#100009", "type_id": 2, "farm_id": 1, "cdate": 1504253837, "state": true, "num": 30, "status": true, "show": "30", "id": "6d8a4c0e-4f85-524a-87f8-382c333c44da"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100000, "name": "\u6e7f\u5ea6#100000", "type_id": 2, "farm_id": 1, "cdate": 1504253836, "state": true, "num": 5, "status": true, "show": "5", "id": "d644b079-9d4d-521c-8e65-8940c96ba9a7"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100001, "name": "\u6e7f\u5ea6#100001", "type_id": 2, "farm_id": 1, "cdate": 1504253835, "state": true, "num": 4, "status": true, "show": "4", "id": "dc24428c-eafc-5715-b7d1-f3222d28c3bb"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100004, "name": "\u6e7f\u5ea6#100004", "type_id": 2, "farm_id": 1, "cdate": 1504253834, "state": true, "num": 17, "status": true, "show": "17", "id": "62199416-cca0-5114-b900-a10f51e7e447"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100005, "name": "\u6e7f\u5ea6#100005", "type_id": 2, "farm_id": 1, "cdate": 1504253833, "state": true, "num": 7, "status": true, "show": "7", "id": "456daa98-a1f0-59e6-a337-7ca1fa7b2527"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100003, "name": "\u6e7f\u5ea6#100003", "type_id": 2, "farm_id": 1, "cdate": 1504253832, "state": true, "num": 39, "status": true, "show": "39", "id": "11bd4ad1-b4ff-5b1f-948a-935d859b408c"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100007, "name": "\u6e7f\u5ea6#100007", "type_id": 2, "farm_id": 1, "cdate": 1504253828, "state": true, "num": 43, "status": true, "show": "43", "id": "f8e3a42a-7fa3-575a-b99e-2dab4f992239"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100010, "name": "\u6e7f\u5ea6#100010", "type_id": 2, "farm_id": 1, "cdate": 1504253827, "state": true, "num": 20, "status": true, "show": "20", "id": "138876d7-1710-56fa-824b-10402cba17f8"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100002, "name": "\u6e7f\u5ea6#100002", "type_id": 2, "farm_id": 1, "cdate": 1504253826, "state": true, "num": 43, "status": true, "show": "43", "id": "eecfe61f-de83-588f-8cbd-41519d4ebef3"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100006, "name": "\u6e7f\u5ea6#100006", "type_id": 2, "farm_id": 1, "cdate": 1504253818, "state": true, "num": 4, "status": true, "show": "4", "id": "78bd90ac-6af3-5091-83e5-f3397063f743"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": null, "hardware_type": 2, "hardware_id": 100008, "name": "\u6e7f\u5ea6#100008", "type_id": 2, "farm_id": 1, "cdate": 1504253815, "state": true, "num": 37, "status": true, "show": "37", "id": "5fda8633-aed8-5a3b-8175-2c61e7553d91"}], "data": [{"data": {"rows": [["2017-09-01 11:15:00", 45], ["2017-09-01 11:20:00", 50], ["2017-09-01 11:25:00", 49], ["2017-09-01 11:30:00", 49], ["2017-09-01 11:35:00", 50], ["2017-09-01 11:40:00", 48], ["2017-09-01 11:45:00", 49], ["2017-09-01 11:50:00", 47], ["2017-09-01 11:55:00", 49], ["2017-09-01 12:00:00", 49], ["2017-09-01 12:05:00", 47], ["2017-09-01 12:10:00", 50], ["2017-09-01 12:15:00", 49], ["2017-09-01 12:20:00", 50], ["2017-09-01 12:25:00", 48], ["2017-09-01 12:30:00", 50], ["2017-09-01 12:35:00", 48], ["2017-09-01 12:40:00", 50], ["2017-09-01 12:45:00", 47], ["2017-09-01 12:50:00", 50], ["2017-09-01 12:55:00", 49], ["2017-09-01 13:00:00", 46], ["2017-09-01 13:05:00", 50], ["2017-09-01 13:10:00", 50], ["2017-09-01 13:15:00", 49], ["2017-09-01 13:20:00", 50], ["2017-09-01 13:25:00", 49], ["2017-09-01 13:30:00", 50], ["2017-09-01 13:35:00", 50], ["2017-09-01 13:40:00", 48], ["2017-09-01 13:45:00", 49], ["2017-09-01 13:50:00", 49], ["2017-09-01 13:55:00", 49], ["2017-09-01 14:00:00", 49], ["2017-09-01 14:05:00", 47], ["2017-09-01 14:10:00", 49], ["2017-09-01 14:15:00", 48], ["2017-09-01 14:20:00", 45], ["2017-09-01 14:25:00", 50], ["2017-09-01 14:30:00", 50], ["2017-09-01 14:35:00", 49], ["2017-09-01 14:40:00", 49], ["2017-09-01 14:45:00", 49], ["2017-09-01 14:50:00", 49], ["2017-09-01 14:55:00", 47], ["2017-09-01 15:00:00", 49], ["2017-09-01 15:05:00", 50], ["2017-09-01 15:10:00", 49], ["2017-09-01 15:15:00", 47], ["2017-09-01 15:25:00", 50], ["2017-09-01 15:30:00", 50], ["2017-09-01 15:35:00", 49], ["2017-09-01 15:40:00", 49], ["2017-09-01 15:45:00", 49], ["2017-09-01 15:50:00", 48], ["2017-09-01 15:55:00", 47], ["2017-09-01 16:05:00", 46], ["2017-09-01 16:10:00", 49], ["2017-09-01 16:15:00", 49]], "value": "[45, 50, 49, 49, 50, 48, 49, 47, 49, 49, 47, 50, 49, 50, 48, 50, 48, 50, 47, 50, 49, 46, 50, 50, 49, 50, 49, 50, 50, 48, 49, 49, 49, 49, 47, 49, 48, 45, 50, 50, 49, 49, 49, 49, 47, 49, 50, 49, 47, 50, 50, 49, 49, 49, 48, 47, 46, 49, 49]", "time": "[\"2017-09-01 11:15:00\", \"2017-09-01 11:20:00\", \"2017-09-01 11:25:00\", \"2017-09-01 11:30:00\", \"2017-09-01 11:35:00\", \"2017-09-01 11:40:00\", \"2017-09-01 11:45:00\", \"2017-09-01 11:50:00\", \"2017-09-01 11:55:00\", \"2017-09-01 12:00:00\", \"2017-09-01 12:05:00\", \"2017-09-01 12:10:00\", \"2017-09-01 12:15:00\", \"2017-09-01 12:20:00\", \"2017-09-01 12:25:00\", \"2017-09-01 12:30:00\", \"2017-09-01 12:35:00\", \"2017-09-01 12:40:00\", \"2017-09-01 12:45:00\", \"2017-09-01 12:50:00\", \"2017-09-01 12:55:00\", \"2017-09-01 13:00:00\", \"2017-09-01 13:05:00\", \"2017-09-01 13:10:00\", \"2017-09-01 13:15:00\", \"2017-09-01 13:20:00\", \"2017-09-01 13:25:00\", \"2017-09-01 13:30:00\", \"2017-09-01 13:35:00\", \"2017-09-01 13:40:00\", \"2017-09-01 13:45:00\", \"2017-09-01 13:50:00\", \"2017-09-01 13:55:00\", \"2017-09-01 14:00:00\", \"2017-09-01 14:05:00\", \"2017-09-01 14:10:00\", \"2017-09-01 14:15:00\", \"2017-09-01 14:20:00\", \"2017-09-01 14:25:00\", \"2017-09-01 14:30:00\", \"2017-09-01 14:35:00\", \"2017-09-01 14:40:00\", \"2017-09-01 14:45:00\", \"2017-09-01 14:50:00\", \"2017-09-01 14:55:00\", \"2017-09-01 15:00:00\", \"2017-09-01 15:05:00\", \"2017-09-01 15:10:00\", \"2017-09-01 15:15:00\", \"2017-09-01 15:25:00\", \"2017-09-01 15:30:00\", \"2017-09-01 15:35:00\", \"2017-09-01 15:40:00\", \"2017-09-01 15:45:00\", \"2017-09-01 15:50:00\", \"2017-09-01 15:55:00\", \"2017-09-01 16:05:00\", \"2017-09-01 16:10:00\", \"2017-09-01 16:15:00\"]"}, "name": "\u6700\u9ad8"}, {"data": {"rows": [["2017-09-01 11:15:00", 3], ["2017-09-01 11:20:00", 3], ["2017-09-01 11:25:00", 1], ["2017-09-01 11:30:00", 1], ["2017-09-01 11:35:00", 1], ["2017-09-01 11:40:00", 2], ["2017-09-01 11:45:00", 2], ["2017-09-01 11:50:00", 1], ["2017-09-01 11:55:00", 3], ["2017-09-01 12:00:00", 3], ["2017-09-01 12:05:00", 1], ["2017-09-01 12:10:00", 1], ["2017-09-01 12:15:00", 2], ["2017-09-01 12:20:00", 1], ["2017-09-01 12:25:00", 1], ["2017-09-01 12:30:00", 2], ["2017-09-01 12:35:00", 1], ["2017-09-01 12:40:00", 3], ["2017-09-01 12:45:00", 1], ["2017-09-01 12:50:00", 4], ["2017-09-01 12:55:00", 1], ["2017-09-01 13:00:00", 3], ["2017-09-01 13:05:00", 1], ["2017-09-01 13:10:00", 1], ["2017-09-01 13:15:00", 1], ["2017-09-01 13:20:00", 7], ["2017-09-01 13:25:00", 1], ["2017-09-01 13:30:00", 1], ["2017-09-01 13:35:00", 1], ["2017-09-01 13:40:00", 1], ["2017-09-01 13:45:00", 1], ["2017-09-01 13:50:00", 4], ["2017-09-01 13:55:00", 5], ["2017-09-01 14:00:00", 2], ["2017-09-01 14:05:00", 2], ["2017-09-01 14:10:00", 3], ["2017-09-01 14:15:00", 4], ["2017-09-01 14:20:00", 1], ["2017-09-01 14:25:00", 1], ["2017-09-01 14:30:00", 1], ["2017-09-01 14:35:00", 1], ["2017-09-01 14:40:00", 2], ["2017-09-01 14:45:00", 2], ["2017-09-01 14:50:00", 2], ["2017-09-01 14:55:00", 1], ["2017-09-01 15:00:00", 1], ["2017-09-01 15:05:00", 1], ["2017-09-01 15:10:00", 1], ["2017-09-01 15:15:00", 1], ["2017-09-01 15:25:00", 3], ["2017-09-01 15:30:00", 1], ["2017-09-01 15:35:00", 1], ["2017-09-01 15:40:00", 9], ["2017-09-01 15:45:00", 2], ["2017-09-01 15:50:00", 5], ["2017-09-01 15:55:00", 8], ["2017-09-01 16:05:00", 5], ["2017-09-01 16:10:00", 1], ["2017-09-01 16:15:00", 4]], "value": "[3, 3, 1, 1, 1, 2, 2, 1, 3, 3, 1, 1, 2, 1, 1, 2, 1, 3, 1, 4, 1, 3, 1, 1, 1, 7, 1, 1, 1, 1, 1, 4, 5, 2, 2, 3, 4, 1, 1, 1, 1, 2, 2, 2, 1, 1, 1, 1, 1, 3, 1, 1, 9, 2, 5, 8, 5, 1, 4]", "time": "[\"2017-09-01 11:15:00\", \"2017-09-01 11:20:00\", \"2017-09-01 11:25:00\", \"2017-09-01 11:30:00\", \"2017-09-01 11:35:00\", \"2017-09-01 11:40:00\", \"2017-09-01 11:45:00\", \"2017-09-01 11:50:00\", \"2017-09-01 11:55:00\", \"2017-09-01 12:00:00\", \"2017-09-01 12:05:00\", \"2017-09-01 12:10:00\", \"2017-09-01 12:15:00\", \"2017-09-01 12:20:00\", \"2017-09-01 12:25:00\", \"2017-09-01 12:30:00\", \"2017-09-01 12:35:00\", \"2017-09-01 12:40:00\", \"2017-09-01 12:45:00\", \"2017-09-01 12:50:00\", \"2017-09-01 12:55:00\", \"2017-09-01 13:00:00\", \"2017-09-01 13:05:00\", \"2017-09-01 13:10:00\", \"2017-09-01 13:15:00\", \"2017-09-01 13:20:00\", \"2017-09-01 13:25:00\", \"2017-09-01 13:30:00\", \"2017-09-01 13:35:00\", \"2017-09-01 13:40:00\", \"2017-09-01 13:45:00\", \"2017-09-01 13:50:00\", \"2017-09-01 13:55:00\", \"2017-09-01 14:00:00\", \"2017-09-01 14:05:00\", \"2017-09-01 14:10:00\", \"2017-09-01 14:15:00\", \"2017-09-01 14:20:00\", \"2017-09-01 14:25:00\", \"2017-09-01 14:30:00\", \"2017-09-01 14:35:00\", \"2017-09-01 14:40:00\", \"2017-09-01 14:45:00\", \"2017-09-01 14:50:00\", \"2017-09-01 14:55:00\", \"2017-09-01 15:00:00\", \"2017-09-01 15:05:00\", \"2017-09-01 15:10:00\", \"2017-09-01 15:15:00\", \"2017-09-01 15:25:00\", \"2017-09-01 15:30:00\", \"2017-09-01 15:35:00\", \"2017-09-01 15:40:00\", \"2017-09-01 15:45:00\", \"2017-09-01 15:50:00\", \"2017-09-01 15:55:00\", \"2017-09-01 16:05:00\", \"2017-09-01 16:10:00\", \"2017-09-01 16:15:00\"]"}, "name": "\u6700\u4f4e"}]}}
    126. 

  126. 	@apiErrorExample 操作失败
    127. 

  127. 	{"status": 2, "msg": "\u64cd\u4f5c\u5931\u8d25", "code": 0, "data": {}}
    128. 

  128. 	"""
    129. 

  129. 	@auth
    130. 

  130. 	def get(self):
    131. 

  131. 		id = self.input('id', None)
    132. 

  132. 		device = self.input('device', None)
    133. 

  133. 		if id and device:
    134. 

  134. 			self.data['info'] = self.service('common').one('device_gateway', id=id)
    135. 

  135. 			if not self.data['info']:
    136. 

  136. 				self.out('no')
    137. 

  137. 				return
    138. 

  138. 

  139. 			self.data['cur_device'] = self.service('common').one('device_info', id=device)
    140. 

  140. 			if not self.data['cur_device']:
    141. 

  141. 				self.out('no')
    142. 

  142. 				return
    143. 

  143. 			
    144. 

  144. 			self.data['device'] = self.service('common').list('device_info', state=True, search={'hardware_type':2, 'gateway_id':id})
    145. 

  145. 

  146. 			model = Demeter.model('data', 'tsdb')
    147. 

  147. 			self.data['group'] = model.dateConfig()
    148. 

  148. 

  149. 			search_group = self.input('search_group')
    150. 

  150. 			search_start = self.input('search_start')
    151. 

  151. 			search_end = self.input('search_end')
    152. 

  152. 

  153. 			search = {}
    154. 

  154. 			if search_group:
    155. 

  155. 				search['group'] = search_group
    156. 

  156. 			else:
    157. 

  157. 				search['group'] = '1'
    158. 

  158. 			if search_start:
    159. 

  159. 				search['start'] = search_start
    160. 

  160. 			if search_end:
    161. 

  161. 				search['end'] = search_end
    162. 

  162. 

  163. 			method = 'maxmin'
    164. 

  164. 			self.data['search'] = search
    165. 

  165. 

  166. 			self.data['data'] = model.getData(method, search, self.data['cur_device'])
    167. 

  167. 

  168. 			self.out('yes', self.data)
    169. 

  169. 		else:
    170. 

  170. 			self.out('no')
    171. 

  171. 

  172. 

  173. class pic_path(Load):
    174. 

  174. 	"""
    175. 

  175. 	@api {get} /device/pic 获取图像记录
    176. 

  176. 	@apiVersion 1.0.0
    177. 

  177. 	@apiName getDevicePic
    178. 

  178. 	@apiGroup Device
    179. 

  179. 

  180. 	@apiParam {String} page 页数
    181. 

  181. 

  182. 	@apiParam {String} id 网关id
    183. 

  183. 	@apiParam {String} search_date 拍照时间:2017-10-10
    184. 

  184. 

  185. 	@apiSuccess {Object[]} setting 基本信息
    186. 

  186. 	@apiSuccess {String}   setting.name  站点名
    187. 

  187. 	@apiSuccess {Number}   setting.farm  当前的农场ID
    188. 

  188. 

  189. 	@apiSuccess {Object[]} info 网关状态基本信息
    190. 

  190. 	@apiSuccess {String}   info.id	网关ID
    191. 

  191. 	@apiSuccess {String}   info.name  网关名称
    192. 

  192. 

  193. 	@apiSuccess {Object[]} pic 图像数据
    194. 

  194. 	@apiSuccess {Number}   pic.id	图片ID
    195. 

  195. 	@apiSuccess {String}   pic.name  图片名称
    196. 

  196. 	@apiSuccess {String}   pic.show	图片地址
    197. 

  197. 	@apiSuccess {String}   pic.cdates	采集时间
    198. 

  198. 	@apiSuccess {String}   pic.cdate	采集时间戳
    199. 

  199. 

  200. 	@apiSuccess {Object[]} search 当前搜索的值
    201. 

  201. 	@apiSuccess {String}   search.date	拍照时间
    202. 

  202. 

  203. 	@apiSuccess {String} url 网站url
    204. 

  204. 

  205. 	@apiSuccess {Object[]} page 分页信息
    206. 

  206. 	@apiSuccess {String}   page.current  当前页
    207. 

  207. 	@apiSuccess {String}   page.total	总页数
    208. 

  208. 	@apiSuccess {String}   page.num	每页数据条数
    209. 

  209. 	@apiSuccess {String}   page.totalNum	总数据条数
    210. 

  210. 

  211. 	@apiErrorExample 操作成功
    212. 

  212. 	{"status": 1, "msg": "yes", "code": 0, "data": {"info": {"status": true, "hardware_id": 10086, "name": "\u9ed8\u8ba4\u7f51\u5173", "farm_id": 1, "cdate": 1504233947, "state": true, "power_num": "", "power_status": "", "id": "ce37636b-3ce7-5de2-9160-0f3283f7d392"}, "url": "http://192.168.15.10:8088/", "pic": [{"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "pic": "/camera/2017/09/01/01c323ac0208580601252e2ce9eb3286.jpg", "farm_id": 1, "cdate": 1504262668, "cdates": "2017-09-01 10:44:28", "state": true, "id": "5ea5d688-e092-5131-a382-686298da4f94", "device_id": "2f612150-f670-54e9-9886-a044cfb18e20"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "pic": "/camera/2017/09/01/f5e1509cf0d6b1cb2f048a058dabd75b.jpg", "farm_id": 1, "cdate": 1504262666, "cdates": "2017-09-01 10:44:26", "state": true, "id": "bd36fa61-5210-57c5-b8b8-a81e5797ee85", "device_id": "2f612150-f670-54e9-9886-a044cfb18e20"}, {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "pic": "/camera/2017/09/01/8f3a6d9d614cd280d2cb4a78f90d121a.jpg", "farm_id": 1, "cdate": 1504262665, "cdates": "2017-09-01 10:44:25", "state": true, "id": "162ac864-b2e9-5a7a-84cb-ac57e31ef99c", "device_id": "2f612150-f670-54e9-9886-a044cfb18e20"}], "search_date": null, "setting": {"farm": 1, "user": 0, "name": "\u519c\u5c0f\u76d2", "copyright": "2017 nongxiaohe.com v1.0.0", "site": "http://www.nongxiaohe.com/"}, "page": {"current": 1, "ajax": false, "total": 1.0, "num": 15, "totalNum": 3}}}
    213. 

  213. 	@apiErrorExample 操作失败
    214. 

  214. 	{"status": 2, "msg": "\u64cd\u4f5c\u5931\u8d25", "code": 0, "data": {}}
    215. 

  215. 	"""
    216. 

  216. 	@auth
    217. 

  217. 	def get(self):
    218. 

  218. 		id = self.input('id', None)
    219. 

  219. 		if id:
    220. 

  220. 			self.data['info'] = self.service('common').one('device_gateway', id=id)
    221. 

  221. 			if not self.data['info']:
    222. 

  222. 				self.out('no')
    223. 

  223. 				return
    224. 

  224. 

  225. 			self.data['url'] = self.request.protocol + "://" + self.request.host + '/'
    226. 

  226. 			self.data['search_date'] = self.input('search_date')
    227. 

  227. 

  228. 			search = {}
    229. 

  229. 			search['gateway_id'] = id
    230. 

  230. 			if self.data['search_date']:
    231. 

  231. 				search['cdate'] = Demeter.mktime(self.data['search_date'])
    232. 

  232. 			self.data['pic'] = self.service('common').list('device_pic', state=True, search=search, page=True)
    233. 

  233. 			if self.data['pic']:
    234. 

  234. 				for key, value in enumerate(self.data['pic']):
    235. 

  235. 					self.data['pic'][key]['cdates'] = Demeter.date(value['cdate'])
    236. 

  236. 

  237. 			self.out('yes', self.data)
    238. 

  238. 		else:
    239. 

  239. 			self.out('no')
    240. 

  240. 

  241. class msg_path(Load):
    242. 

  242. 	"""
    243. 

  243. 	@api {get} /device/msg 获取设备日志
    244. 

  244. 	@apiVersion 1.0.0
    245. 

  245. 	@apiName getDeviceMsg
    246. 

  246. 	@apiGroup Device
    247. 

  247. 

  248. 	@apiParam {String} page 页数
    249. 

  249. 

  250. 	@apiParam {String} id 网关id
    251. 

  251. 	@apiParam {String} device 设备id
    252. 

  252. 

  253. 	@apiSuccess {Object[]} setting 基本信息
    254. 

  254. 	@apiSuccess {String}   setting.name  站点名
    255. 

  255. 	@apiSuccess {Number}   setting.farm  当前的农场ID
    256. 

  256. 

  257. 	@apiSuccess {Object[]} msg 日志列表
    258. 

  258. 	@apiSuccess {Number}   msg.id	日志ID
    259. 

  259. 	@apiSuccess {String}   msg.content  日志内容
    260. 

  260. 	@apiSuccess {String}   msg.cdates	日志时间
    261. 

  261. 	@apiSuccess {String}   msg.cdate	日志时间戳
    262. 

  262. 

  263. 	@apiSuccess {Object[]} page 分页信息
    264. 

  264. 	@apiSuccess {String}   page.current  当前页
    265. 

  265. 	@apiSuccess {String}   page.total	总页数
    266. 

  266. 	@apiSuccess {String}   page.num	每页数据条数
    267. 

  267. 	@apiSuccess {String}   page.totalNum	总数据条数
    268. 

  268. 

  269. 	@apiErrorExample 操作成功
    270. 

  270. 	{"status": 1, "msg": "yes", "code": 0, "data": {"info": {"status": true, "hardware_id": 10086, "name": "\u9ed8\u8ba4\u7f51\u5173", "farm_id": 1, "cdate": 1504233947, "state": true, "power_num": "", "power_status": "", "id": "ce37636b-3ce7-5de2-9160-0f3283f7d392"}, "msg": [], "setting": {"farm": 1, "user": 0, "name": "\u519c\u5c0f\u76d2", "copyright": "2017 nongxiaohe.com v1.0.0", "site": "http://www.nongxiaohe.com/"}, "cur_device": {"gateway_id": "ce37636b-3ce7-5de2-9160-0f3283f7d392", "hardware_station": "", "hardware_type": 2, "hardware_id": 100001, "name": "\u6e7f\u5ea6#100001", "type_id": 2, "farm_id": 1, "cdate": 1504253835, "state": true, "num": 4, "status": true, "show": "4", "id": "dc24428c-eafc-5715-b7d1-f3222d28c3bb"}}}
    271. 

  271. 	@apiErrorExample 操作失败
    272. 

  272. 	{"status": 2, "msg": "\u64cd\u4f5c\u5931\u8d25", "code": 0, "data": {}}
    273. 

  273. 	"""
    274. 

  274. 	@auth
    275. 

  275. 	def get(self):
    276. 

  276. 		id = self.input('id', None)
    277. 

  277. 		device = self.input('device', None)
    278. 

  278. 		if id and device:
    279. 

  279. 			self.data['info'] = self.service('common').one('device_gateway', id=id)
    280. 

  280. 			if not self.data['info']:
    281. 

  281. 				self.out('no')
    282. 

  282. 				return
    283. 

  283. 

  284. 			self.data['cur_device'] = self.service('common').one('device_info', id=device)
    285. 

  285. 			if not self.data['cur_device']:
    286. 

  286. 				self.out('no')
    287. 

  287. 				return
    288. 

  288. 

  289. 			search = {}
    290. 

  290. 			search['device_id'] = device
    291. 

  291. 

  292. 			self.data['msg'] = self.service('common').list('msg', state=True, search=search, page=True)
    293. 

  293. 			if self.data['msg']:
    294. 

  294. 				for key, value in enumerate(self.data['msg']):
    295. 

  295. 					self.data['msg'][key]['cdates'] = Demeter.date(value['cdate'])
    296. 

  296. 

  297. 			self.out('yes', self.data)
    298. 

  298. 		else:
    299. 

  299. 			self.out('no')
    300. 

  300. 

  301. 

  302. class set_path(Load):
    303. 

  303. 	"""
    304. 

  304. 	@api {get} /device/set 获取设备极限值信息
    305. 

  305. 	@apiVersion 1.0.0
    306. 

  306. 	@apiName getDeviceSet
    307. 

  307. 	@apiGroup Device
    308. 

  308. 

  309. 	@apiParam {String} id 网关id
    310. 

  310. 	@apiParam {String} device 设备id
    311. 

  311. 

  312. 	@apiSuccess {Object[]} setting 基本信息
    313. 

  313. 	@apiSuccess {String}   setting.name  站点名
    314. 

  314. 	@apiSuccess {Number}   setting.farm  当前的农场ID
    315. 

  315. 

  316. 	@apiSuccess {Object[]} device 设备数据
    317. 

  317. 	@apiSuccess {Number}   device.id	设备ID
    318. 

  318. 	@apiSuccess {String}   device.name  设备名称
    319. 

  319. 	@apiSuccess {String}   device.show	显示的数据
    320. 

  320. 	@apiSuccess {String}   device.unit	设备的单位
    321. 

  321. 	@apiSuccess {Number}   device.max	设备的上限
    322. 

  322. 	@apiSuccess {Number}   device.min	设备的下限
    323. 

  323. 	@apiSuccess {Bool}   device.status	设备状态
    324. 

  324. 

  325. 	@apiErrorExample 操作成功
    326. 

  326. 	{"status": 1, "msg": "yes", "code": 0, "data": {"setting": {"farm": 1, "user": 0, "name": "\u519c\u5c0f\u76d2", "copyright": "2017 nongxiaohe.com v1.0.0", "site": "http://www.nongxiaohe.com/"}, "list": [{"pic": "http://192.168.15.10:8087/upload/2017/08/30/455f9d6c26b5c989b32eda1809e58d5f.jpg", "method_id": null, "land_id": "249be20d-5759-5af0-9859-b770d9f44e2a", "farm_id": 1, "state": true, "amount": "100ml", "workdate": 1504105397, "category_id": "9365ea66-be55-56f7-a511-059fc85a9478", "cdate": 1504076614, "id": "19e05f00-ae55-5605-be12-86dcd2866df9"}], "page": {"current": 1, "ajax": false, "total": 1.0, "num": 15, "totalNum": 1}}}
    327. 

  327. 	@apiErrorExample 操作失败
    328. 

  328. 	{"status": 2, "msg": "\u64cd\u4f5c\u5931\u8d25", "code": 0, "data": {}}
    329. 

  329. 	"""
    330. 

  330. 	@auth
    331. 

  331. 	def get(self):
    332. 

  332. 		id = self.input('id', None)
    333. 

  333. 		device = self.input('device', None)
    334. 

  334. 		if id and device:
    335. 

  335. 			self.data['info'] = self.service('common').one('device_gateway', id=id)
    336. 

  336. 			if not self.data['info']:
    337. 

  337. 				self.out('no')
    338. 

  338. 				return
    339. 

  339. 

  340. 			self.data['device'] = self.service('common').one('device_info', id=device)
    341. 

  341. 			if not self.data['device']:
    342. 

  342. 				self.out('no')
    343. 

  343. 				return
    344. 

  344. 

  345. 			type = self.service('common').one('device_type', id=self.data['device']['type_id'])
    346. 

  346. 			self.data['device']['unit'] = type['unit']
    347. 

  347. 			set = self.service('common').one('device_set', device_id=self.data['device']['id'])
    348. 

  348. 			if set:
    349. 

  349. 				self.data['device']['max'] = set['max']
    350. 

  350. 				self.data['device']['min'] = set['min']
    351. 

  351. 			else:
    352. 

  352. 				self.data['device']['max'] = 0
    353. 

  353. 				self.data['device']['min'] = 0
    354. 

  354. 

  355. 			self.out('yes', self.data)
    356. 

  356. 		else:
    357. 

  357. 			self.out('no')
    358. 

  358. 

  359. 	"""
    360. 

  360. 	@api {post} /device/set 更新极限值设置
    361. 

  361. 	@apiVersion 1.0.0
    362. 

  362. 	@apiName updateDeviceSet
    363. 

  363. 	@apiGroup Farm
    364. 

  364. 

  365. 	@apiParam {String} id 设备id
    366. 

  366. 	@apiParam {String} update_max 最大上限
    367. 

  367. 	@apiParam {String} update_min 最小下限
    368. 

  368. 

  369. 	@apiSuccess {Bool} status 状态
    370. 

  370. 	@apiSuccess {String}   msg  描述
    371. 

  371. 	@apiSuccess {Number}   code  状态码
    372. 

  372. 

  373. 	@apiErrorExample 操作成功
    374. 

  374. 	{"status": 1, "msg": "操作成功", "code": 0, "data": {}}
    375. 

  375. 	@apiErrorExample 操作失败
    376. 

  376. 	{"status": 2, "msg": "\u64cd\u4f5c\u5931\u8d25", "code": 0, "data": {}}
    377. 

  377. 	"""
    378. 

  378. 	@auth
    379. 

  379. 	def post(self):
    380. 

  380. 		id = self.input('id', None)
    381. 

  381. 		if not id:
    382. 

  382. 			self.out('no')
    383. 

  383. 			return
    384. 

  384. 		device = self.service('common').one('device_info', id=id)
    385. 

  385. 		if not self.data['device']:
    386. 

  386. 			self.out('no')
    387. 

  387. 			return
    388. 

  388. 		update = {}
    389. 

  389. 		update['max'] = self.input('update_max')
    390. 

  390. 		update['min'] = self.input('update_min')
    391. 

  391. 		if not update['max']:
    392. 

  392. 			self.out(u'请输入最大上限')
    393. 

  393. 			return
    394. 

  394. 		if not update['min']:
    395. 

  395. 			self.out(u'请输入最小下限')
    396. 

  396. 			return
    397. 

  397. 

  398. 		data = self.service('common').one('device_info', id=id)
    399. 

  399. 		if not data:
    400. 

  400. 			state = self.service('common').update('device_info', None, update)
    401. 

  401. 		else:
    402. 

  402. 			state = self.service('common').update('device_info', data['id'], update)
    403. 

  403. 		self.out('yes', {'id':state})
    404.