融合通信H5对接

common/AvconH5API.py

@@ -0,0 +1,486 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+import requests
+from utils.redis_util import *
+
+app_id = "820e2aa3903e46939abde098409319e1"
+secret= "92659e6e0dd3c550952df7c95a483d56"
+
+'''
+融合通信H5对接
+'''
+
+API_ROOT = "http://19.152.196.223:5050/rpy"
+
+# 1.1获取Token
+'''
+{
+ "code": 0,
+ "msg": "Success.",
+ "data": {
+ "app_id": "5cdf02e49d434b3ac4c272a39d3211ca",
+ "secret": "f3e2182a13690b75ff87c5273063201",
+ "token": "Bearer eyJhbGciOiJIUzUxMiJ9.eyJpc3MiOiJhdmNvbiIsInN1YiI6IjczNjkzYmI5ZGYwYTRiYjZiMWMyNTMxMWM0NjAwM2Q0IiwiaWF0IjoxNjM5MjA0MTgzLCJ1c2VyX3R5cGUiOiJvYXV0aCIsInJvbGVzIjpbIlJPTEVfb2F1dGgiXX0MS5JX9NJ7dQomZ4-udFukGMQsFFTMyYTKZ9wS0VgjTYM4A2MvpDZeGB4Ish3GOcH4Z_Sn2TAijyZYrJtLGAmww"} 
+}
+'''
+def get_token():
+    params = {
+        "app_id": app_id,
+        "secret": secret
+    }
+    api_url = API_ROOT + "/token"
+    print('param', params)
+    response = requests.get(url=api_url, params=params, timeout=15)
+    print(response.text)
+    if response.status_code == 200:
+        result = response.json()
+        if result['code'] == 0:
+            data = result['data']
+            return data['token']
+        
+def get_redis_token():
+    redis_key = "avcon_h5_api_token"
+    token_val = redis_get(redis_key)
+    if token_val is None:
+        token_val = get_token()
+        if token_val is not None:
+            redis_set_with_time(redis_key, token_val, 300)
+
+    print('token:', token_val)
+    return token_val
+
+# 2.1获取区域
+'''
+{
+	"code": 0,
+	"msg": "Success.",
+	"data": {	
+        count:1
+        region:[{
+        "region_id": "YS@hp",
+        "region_name": "演示图像资源"
+        }]
+	}
+}
+'''
+def get_region():
+    token = get_redis_token()
+    headers = {
+        'Content-Type': 'application/json;charset=UTF-8',
+        "Authorization": "Bearer " + token
+    }
+    api_url = API_ROOT + "/region"
+    response = requests.get(url=api_url, headers=headers, timeout=15)
+    print(response.text)
+    if response.status_code == 200:
+        result = response.json()
+        if result['code'] == 0:
+            data = result['data']
+            return data['region']
+        
+# 2.2获取区域组节点
+'''
+{
+    "code": 0,
+    "msg": "Success.",
+    "data": {
+        "count": 4,
+        "group": [
+            {
+                "group_id": "Gc@hp",
+                "group_name": "监控设备",
+                "domain": "hp",
+                "parent_id": "S1@hp",
+                "level_id": 1,
+                "order_id": 9999,
+                "child_count": 1
+            },
+            ....略....
+        ]
+    }
+}
+'''
+def get_group(region_id: str):
+    token = get_redis_token()
+    headers = {
+        'Content-Type': 'application/json;charset=UTF-8',
+        "Authorization": "Bearer " + token
+    }
+    params = {
+        "region_id": region_id
+    }
+    api_url = API_ROOT + "/group"
+    response = requests.get(url=api_url, headers=headers, params=params, timeout=15)
+    print(response.text)
+    if response.status_code == 200:
+        result = response.json()
+        if result['code'] == 0:
+            data = result['data']
+            return data['group']
+        
+# 2.3根据名称搜索区域下所有的节点
+'''
+{
+  "code": 0,
+  "msg": "Success.",
+  "data": [
+      {
+        "group_id": "G1@xf",
+        "group_name": "消防指挥域",
+        "domain": "xf",
+        "parent_id": "G0@xf",
+        "level_id": 1,
+        "order_id": 9999,
+        "child_count": 0,	//区域组数
+        "total_number": 0,	//设备数
+      },
+      {
+        "group_id": "G2@xf",
+        "group_name": "消防指挥域",
+        "domain": "xf",
+        "parent_id": "G1@xf",
+        "level_id": 2,
+        "order_id": 9999,
+        "child_count": 2,	//区域组数
+        "total_number": 1,	//设备数
+        "child_group": [
+          {
+            "group_id": "G110@xf",
+            "group_name": "指挥中心",
+            "domain": "xf",
+            "parent_id": "G2@xf",
+            "level_id": 2,
+            "order_id": 9999,
+            "child_count": 0,
+            "total_number": 1,	//设备数
+            "child_device": [
+                {
+                    "dev_id": "cy0001@xf",
+                    "dev_name": "sx",
+                    "domain": "xf",
+                    "group_id": "G110@xf",
+                    "channel_num": 1,
+                    "status": 0,
+                    "dev_type": "001",
+                    "child_channel": [
+                      {
+                        "channel_id": "cy0001@xf_00",
+                        "channel_name": "cy0001@xf_00",
+                        "channel_no": 0,
+                        "dev_id": "cy0001@xf",
+                        "status": 1,
+                         "lat": 28.28,
+                        "lng": 116.38
+                      }
+                    ]
+               }
+            ]
+         },
+         {
+            "group_id": "G110@xf",
+            "group_name": "电视墙",
+            "domain": "xf",
+            "parent_id": "G110@xf",
+            "level_id": 2,
+            "order_id": 9999,
+            "child_count": 0,
+            "total_number": 0
+         }
+        ],
+        "child_device": [
+                {
+                   "dev_id": "sx@xf",
+                   "dev_name": "sx",
+                   "domain": "xf",
+                   "group_id": "G110@xf",
+                   "channel_num": 1,
+                   "status": 0,
+                   "dev_type": "001",
+                   "child_channel": [
+                      {
+                        "channel_id": "sx@xf_00",
+                        "channel_name": "sx@xf_00",
+                        "channel_no": 0,
+                        "dev_id": "sx@xf",
+                        "status": 0
+                      }
+                   ]
+               }
+          ]
+      }
+  ]
+}
+'''
+def get_search_region(region_name: str):
+    token = get_redis_token()
+    headers = {
+        'Content-Type': 'application/json;charset=UTF-8',
+        "Authorization": "Bearer " + token
+    }
+    params = {
+        "region_name": region_name
+    }
+    api_url = API_ROOT + "/search/region"
+    response = requests.get(url=api_url, headers=headers, params=params, timeout=15)
+    print(response.text)
+    if response.status_code == 200:
+        result = response.json()
+        if result['code'] == 0:
+            data = result['data']
+            return data
+
+# 2.4搜索范围内的通道信息及直播流地址
+'''
+{
+    "code": 0,
+    "msg": "Success.",
+    "data": {
+        "count": 2,
+        "channel": [
+            {
+                "channel_id": "hk01@hp_00",
+                "channel_name": "学校校门外监控",
+                "channel_no": 0,
+                "dev_id": "hk01@hp",
+                "status": 1,
+                "lat": 28.631629,
+                "lng": 115.877328,
+                "live_url": "http://192.168.0.1:1935/live/hk01@hp_00.flv"
+            },
+            {
+                "channel_id": "hk02@hp_00",
+                "channel_name": "学校校门外监控2",
+                "channel_no": 0,
+                "dev_id": "hk02@hp",
+                "status": 1,
+                "lat": 28.631529,
+                "lng": 115.874328,
+                "live_url": "http://192.168.0.1:1935/live/hk02@hp_00.flv"
+            }
+           
+        ]
+    }
+}
+'''
+def get_search_live_location(center_lat: float, center_lng: float, point_lat: float, point_lng: float):
+    token = get_redis_token()
+    headers = {
+        'Content-Type': 'application/json;charset=UTF-8',
+        "Authorization": "Bearer " + token
+    }
+    params = {
+        "center_lat": center_lat,
+        "center_lng": center_lng,
+        "point_lat": point_lat,
+        "point_lng": point_lng
+    }
+    api_url = API_ROOT + "/search/live-location"
+    response = requests.get(url=api_url, headers=headers, params=params, timeout=15)
+    print(response.text)
+    if response.status_code == 200:
+        result = response.json()
+        if result['code'] == 0:
+            data = result['data']
+            return data['channel']
+        
+
+# 3.1获取设备
+'''
+{
+    "code": 0,
+    "msg": "Success.",
+    "data": {
+        "count": 10,
+        "device": [
+            {
+                "dev_id": "hk01@hp",
+                "dev_name": "海康设备",
+                "domain": "hp",
+                "group_id": "Gc@hp",
+                "channel_num": 1,
+                "status": 1,
+                "dev_type": "135"
+            },
+            {
+                "dev_id": "jkwg01@hp",
+                "dev_name": "监控网关",
+                "domain": "hp",
+                "group_id": "Gc@hp",
+                "channel_num": 0,
+                "status": 0,
+                "dev_type": "085"
+            }
+            ....略
+        ]
+    }
+}
+'''
+def get_group_device(group_id: str, dev_type: dict = None, status: int = -1):
+    token = get_redis_token()
+    headers = {
+        'Content-Type': 'application/json;charset=UTF-8',
+        "Authorization": "Bearer " + token
+    }
+    params = {}
+    if status != -1:
+        params['status'] = status
+    
+    if dev_type != None:
+        params['dev_type'] = "[" + ",".join(dev_type) + "]"
+    api_url = API_ROOT + "/group/" + group_id + "/device"
+    response = requests.get(url=api_url, headers=headers, params=params, timeout=15)
+    print(response.text)
+    if response.status_code == 200:
+        result = response.json()
+        if result['code'] == 0:
+            data = result['data']
+            return data['device']
+        
+# 4.1 获取通道
+'''
+{
+    "code": 0,
+    "msg": "Success.",
+    "data": {
+        "count": 1,
+        "channel": [
+            {
+                "channel_id": "hk01@hp_00",
+                "channel_name": "学校校门外监控",
+                "channel_no": 0,
+                "dev_id": "hk01@hp",
+                "status": 1,
+                "lat": 28.631629,
+                "lng": 115.877328
+            }
+        ]
+    }
+}
+'''
+def get_device_channel(device_id: str, status: int = -1):
+    token = get_redis_token()
+    headers = {
+        'Content-Type': 'application/json;charset=UTF-8',
+        "Authorization": "Bearer " + token
+    }
+    params = {}
+    if status != -1:
+        params['status'] = status
+    
+    api_url = API_ROOT + "/device/" + device_id + "/channel"
+    response = requests.get(url=api_url, headers=headers, params=params, timeout=15)
+    print(response.text)
+    if response.status_code == 200:
+        result = response.json()
+        if result['code'] == 0:
+            data = result['data']
+            return data['channel']
+        
+
+# 4.2 获取所有通道
+'''
+{
+    "code": 0,
+    "msg": "Success.",
+    "data": {
+        "count": 80,
+        "channel": [
+            {
+                "channel_id": "hk01@hp_00",
+                "channel_name": "学校校门外监控",
+                "channel_no": 0,
+                "dev_id": "hk01@hp",
+                "status": 1,
+                "lat": 28.631629,
+                "lng": 115.877328
+            },
+            {
+                "channel_id": "hk02@hp_00",
+                "channel_name": "学校校门外监控2",
+                "channel_no": 0,
+                "dev_id": "hk02@hp",
+                "status": 1,
+                "lat": 28.631529,
+                "lng": 115.874328
+            }
+            ...略
+        ]
+    }
+}
+'''
+def get_channel_all(status: int = -1, gpsonly: int = -1):
+    token = get_redis_token()
+    headers = {
+        'Content-Type': 'application/json;charset=UTF-8',
+        "Authorization": "Bearer " + token
+    }
+    params = {}
+    if status != -1:
+        params['status'] = status
+    if gpsonly != -1:
+        params['gpsonly'] = gpsonly
+    
+    api_url = API_ROOT + "/channel/all"
+    response = requests.get(url=api_url, headers=headers, params=params, timeout=15)
+    print(response.text)
+    if response.status_code == 200:
+        result = response.json()
+        if result['code'] == 0:
+            data = result['data']
+            return data['channel']
+        
+# 5.1 获取直播流
+'''
+{
+    "code": 0,
+    "msg": "success.",
+    "data": {
+        "live_url": "http://192.168.0.1:1935/live/hk01@hp_00.flv"
+    }
+}
+'''
+def get_live_streaming(channel_id: str):
+    token = get_redis_token()
+    headers = {
+        'Content-Type': 'application/json;charset=UTF-8',
+        "Authorization": "Bearer " + token
+    }
+    api_url = API_ROOT + "/live/streaming/" + channel_id
+    response = requests.get(url=api_url, headers=headers, timeout=15)
+    print(response.text)
+    if response.status_code == 200:
+        result = response.json()
+        if result['code'] == 0:
+            data = result['data']
+            return data['live_url']
+        
+# 5.2云台控制
+# 没用
+
+# 5.3获取通道直播页面完整地址
+'''
+{
+  "code":0,
+  "msg":"Success",
+  "data":{
+    "play_url":"http://192.168.0.88:5050/liveplay.html?liveurl=ws://192.168.0.88:9001/live/gbdh01@xf_00.flv"
+  }
+}
+'''
+def get_live_playing(channel_id: str):
+    token = get_redis_token()
+    headers = {
+        'Content-Type': 'application/json;charset=UTF-8',
+        "Authorization": "Bearer " + token
+    }
+    api_url = API_ROOT + "/live/playing/" + channel_id
+    response = requests.get(url=api_url, headers=headers, timeout=15)
+    print(response.text)
+    if response.status_code == 200:
+        result = response.json()
+        if result['code'] == 0:
+            data = result['data']
+            return data['play_url']
+
+if __name__ == '__main__':
+    get_region()

common/AvconWebService.py

@@ -6,6 +6,11 @@ from zeep.transports import Transport
 from xmltodict3 import XmlTextToDict
 from pprint import pprint
 
+
+'''
+融合通信WEB服务对接
+'''
+
 def get_aws_service():
     session = Session()
     session.auth = HTTPBasicAuth("orgadmin", "admin")