kedong/smartfarming/api/views/camera/camera_manage.py

import re
import requests
import time
from django.conf import settings
from django.db.models import Count
from django.core.paginator import Paginator

from smartfarming.api.views.forecast.all_dict import insect_dict, attract_discern
from smartfarming.models.sim_card import MongoMsg_Conf
from smartfarming.models.device import MongoDevice
from smartfarming.models.camera import MongoCameraPhoto, MongoCameraData, MongoCameraAccount
from smartfarming.serializers.device_serializers import DeviceSerializers
from smartfarming.utils import controlMove

from kedong.decoration import kedong_deco, PortError
config_dict = settings.CONFIG


@kedong_deco(login_required=True)
def list_camera(request):
    """
    获取监控设备列表 ：
    参数：
    
    page                    非必传(num)                     页码，默认为1
    device_id               非必传                          设备ID, 不传为监控列表， 传设备号为搜索
    page_size               非必传                          一页条数，默认为10

    返回值：
    {
    "data": {
        data : {
            "device_name":"",                            设备名称
            "device_id":"",                              设备ID
            "photo_num":"",                              是否拍过照片 0未拍过  1拍过
            "status":"",                                 设备状态  0离线  1在线
            "camera_playback":""                         用来判断是否有录像功能 0不支持 1支持
            "sim":""                                     监控SIM 卡
        }            
        counts : 99                                总数
            } 
    "errorCode": 0,
    "message": "",
    "formError": {}
    }

    """
    _list = []
    myuser = request.myuser
    post_info = request.POST
    device_id = post_info.get('device_id')
    page = int(post_info.get('page', 1))
    page_size = int(post_info.get('page_size', 10))

    search_dict = {
        "device_type_id": 6
    }
    if device_id:
        search_dict["device_id"] = re.compile(fr"^.*{device_id}.*$")

    # total_num, data_list = MongoDevice.get_device_list(myuser, match=search_dict, page_num=page, page_size=page_size)

    queryset = MongoDevice.objects.filter(device_type_id=6)
    total_num = queryset.count()
    paginator = Paginator(queryset, page_size)
    page_obj = paginator.get_page(page)
    serializers = DeviceSerializers(page_obj, many=True)
    data_list = serializers.data
    _list = []
    device_id_list = []
    for x in data_list:
        device_id = x.get("device_id")
        device_id_list.append(device_id)

        _list.append({
            "device_name": x.get("device_name"),
            "device_id": device_id,
            "photo_num": "",
            "status": x.get("device_status"),
            "camera_playback": "",
            "sim": x.get("simid")
        })

    photo_queryset = MongoCameraPhoto.objects.filter(device_id__in=device_id_list, photo_status=1).values('device_id').annotate(count=Count('device_id'))
    phote_dict = {p['device_id']: "1" for p in photo_queryset}
    playback_dict = {y['device_id']: y["camera_playback"] for y in MongoCameraData.objects.filter(device_id__in=device_id_list).values('device_id','camera_playback')}

    for item in _list:
        item["photo_num"] = phote_dict.get(device_id, "0")
        item["camera_playback"] = playback_dict.get(device_id,"0")
    datas = {"data": _list, "counts": total_num}
    return datas


@kedong_deco(login_required=True)
def addr_camera_list(request):
    """
    获取监控设备播放地址 
    参数:
    device_id           必传  (string)                  监控设备的序列号

    返回值:
    {
    "data": {
            "hls": "http://test.ys7.com:66/openlive/b475942b03544a5aa35b651670d8712c.m3u8",                  HLS流畅直播地址
            "hlsHd": "http://test.ys7.com:66/openlive/b475942b03544a5aa35b651670d8712c.hd.m3u8",             HLS高清直播地址
            "rtmp": "rtmp://10.82.0.190:1935/openlive/b475942b03544a5aa35b651670d8712c",                     RTMP流畅直播地址
            "rtmpHd": "rtmp://10.82.0.190:1935/openlive/b475942b03544a5aa35b651670d8712c.hd"                 RTMP高清直播地址
            }
    "errorCode": 0,
    "message": "",
    "formError": {}
    }

    """

    try:
        if 'HTTP_X_FORWARDED_FOR' in request.META:
            ip = request.META['HTTP_X_FORWARDED_FOR']
        else:
            ip = request.META['HTTP_X_REAL_IP']
    except Exception as KeyError:
        ip = request.META['REMOTE_ADDR']



    device_id = request.POST.get('device_id')
    # try:
    #     ic = InterfaceCallLog()
    #     ic.ip = ip
    #     ic.device_id = device_id
    #     ic.interface = "addr_camera_list"
    #     ic.meta = str(request.META)
    #     ic.save()
    # except Exception as e:
    #     pass

    # if device_id in jk_list.keys():
    #     if redis_pool.get(device_id):
    #         url_path = redis_pool.get(device_id)
    #     else:
    #         cameraIndexCode = jk_list.get(device_id,"")
    #         url = "http://223.151.55.58:8082/zhcg-serve/hkVideo/api/getPreviewURLsByHls?cameraIndexCode={}&streamType=0".format(cameraIndexCode)
    #         try:
    #            url_path = (requests.get(url,timeout=5).json())["data"]["url"]
    #         except:
    #             url_path = "" 
    #         # 设置播放地址到期时间5分钟
    #         redis_pool.set(device_id,url_path,300)
    #     # 因为其他设备返回的数值是字符串的,所以进行拼接
    #     data =  "{'hls':'%s','hlsHd':'%s','rtmp':'%s','rtmpHd':'%s'}"%(url_path,url_path,url_path,url_path)
    #     return data

    try:
        addr = MongoCameraData.objects.get(device_id=device_id).device_info
    except:
        addr = {}
    return addr


@kedong_deco(login_required=True)
def ctrl_camera(request):
    """
    控制监控设备转动 :
    参数:
    device_id          必传  (string)                  监控设备的序列号
    ctrl               必传  (string)                  操作指令  move 控制球机转动   stop 停止球机转动
    movenum            ctrl=move时必传(string)         0-上,1-下,2-左,3-右,8-放大,9-缩小

    返回值:
    {
    "data": success,     success成功   default失败
    "errorCode": 0,
    "message": "",
    "formError": {}
    }

    """
    device_id = request.POST.get('device_id')
    ctrl = request.POST.get('ctrl')
    account_id = MongoCameraData.objects.filter(device_id=device_id).first()
    if not account_id:
        raise PortError("","未找到此设备")
    camera_query = MongoCameraAccount.objects.filter(id=int(account_id.account_id)).first()
    if not camera_query:
        raise PortError("","未找到此账号")
    channelNo = "1"
    if device_id.find("-") != -1:
        channelNo = device_id.split("-")[1]
        device_id = device_id.split("-")[0]
    # 操作命令:0-上,1-下,2-左,3-右,4-左上,5-左下,6-右上,7-右下,8-放大,9-缩小,10-近焦距,11-远焦距
    if ctrl == "move":
        dire = request.POST.get('movenum')
        # 增加大华相机操作功能
        if camera_query.account_type == 1:
            if dire not in ("0","1","2","3","8","9"):
                raise PortError("movenum","暂不支持其它指令")
            appId = camera_query.app_key
            appSecret = camera_query.app_secret
            controlMove(appId,appSecret,device_id,dire,channelNo)
        else:
            accessToken = camera_query.token
            ctrl_url = 'https://open.ys7.com/api/lapp/device/ptz/start'
            speed = '1'
            data = {'accessToken':accessToken, 'deviceSerial':device_id, 'channelNo':channelNo, 'speed':speed, 'direction':dire}
            res1 = requests.post(ctrl_url,data=data)
    elif ctrl == "stop":
        time.sleep(0.4)
        # 增加大华相机操作功能
        if camera_query.account_type == 1:
            dire = "10"
            appId = camera_query.app_key
            appSecret = camera_query.app_secret
            controlMove(appId,appSecret,device_id,dire,channelNo)
        else:
            accessToken = camera_query.token
            ctrl_url = 'https://open.ys7.com/api/lapp/device/ptz/stop'
            data = {'accessToken':accessToken, 'deviceSerial':device_id, 'channelNo':channelNo}
            res2 = requests.post(ctrl_url,data=data)
    return True