ASJServer/Controller/DetectController.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""
@Copyright (C) ansjer cop Video Technology Co.,Ltd.All rights reserved.
@AUTHOR: ASJRD018
@NAME: AnsjerFormal
@software: PyCharm
@DATE: 2019/1/14 15:57
@Version: python3.6
@MODIFY DECORD:ansjer dev
@file: DetectController.py
@Contact: chanjunkai@163.com
"""
import json
import os
import time

import apns2
import jpush as jpush
import oss2
import requests
from django.utils.decorators import method_decorator
from django.views.decorators.csrf import csrf_exempt
from django.views.generic.base import View
from Ansjer.config import OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET
from Ansjer.config import BASE_DIR
from Ansjer.config import SERVER_DOMAIN
from Model.models import Device_Info, App_Info, UID_App
from Model.models import Equipment_Info
from Object.ResponseObject import ResponseObject
from Object.TokenObject import TokenObject
from Object.UidTokenObject import UidTokenObject
from django.http import JsonResponse
from Service.CommonService import CommonService


# http://192.168.136.40:8077/detect/changeStatus?uid=JW3684H8BSHG9TTM111A&token_val=18071adc03536302f34&appBundleId=com.ansjer.zccloud_ab&push_type=2&token=local&status=1
class DetectControllerView(View):
    @method_decorator(csrf_exempt)
    def dispatch(self, *args, **kwargs):
        return super(DetectControllerView, self).dispatch(*args, **kwargs)

    def get(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        operation = kwargs.get('operation')
        return self.validation(request.GET, operation)

    def post(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        operation = kwargs.get('operation')
        return self.validation(request.POST, operation)

    def validation(self, request_dict, operation):
        response = ResponseObject()
        if operation is None:
            return response.json(444, 'error path')
        token = request_dict.get('token', None)
        tko = TokenObject(token)
        if tko.code == 0:
            userID = tko.userID
            if operation == 'changeStatus':
                return self.do_change_status(userID, request_dict, response)
            if operation == 'queryInfo':
                return self.do_query(request_dict, response, userID)
            else:
                return response.json(414)
        else:
            return response.json(tko.code)

    def do_query(self, request_dict, response, userID):
        page = int(request_dict.get('page', None))
        line = int(request_dict.get('line', None))
        if not page or not line:
            return response.json(444, 'page,line')
        qs = Equipment_Info.objects.filter(userID_id=userID)
        uid = request_dict.get('uid', None)
        if uid:
            qs.filter(devUid=uid)
        if not qs.exists():
            return response.json(0, {'datas': [], 'count': 0})
        qs = qs.values('id', 'devUid', 'devNickName', 'Channel', 'eventType', 'status', 'alarm', 'eventTime',
                       'receiveTime')
        count = qs.count()
        qr = qs[(page - 1) * line:page * line]
        # send_json = CommonService.qs_to_dict(res)
        res = []
        import oss2
        auth = oss2.Auth('LTAIyMkGfEdogyL9', '71uIjpsqVOmF7DAITRyRuc259jHOjO')
        bucket = oss2.Bucket(auth, 'oss-cn-shenzhen.aliyuncs.com', 'apg')
        for p in qr:
            p['img'] = bucket.sign_url('GET',
                                       '{uid}/{channel}/{time}.jpeg'.format(uid=p['devUid'], channel=p['Channel'],
                                                                            time=p['time']), 300)
            res.append(p)
        return response.json(0, {'datas': res, 'count': count})

    def do_change_status(self, userID, request_dict, response):
        uid = request_dict.get('uid', None)
        token_val = request_dict.get('token_val', None)
        appBundleId = request_dict.get('appBundleId', None)
        push_type = request_dict.get('push_type', None)
        status = request_dict.get('status', None)
        print('status')
        print(status)
        if status == '0':
            uid_app_qs = UID_App.objects.filter(appBundleId=appBundleId, userID_id=userID, token_val=token_val,
                                                uid=uid)
            if uid_app_qs.exists():
                uid_app_qs.update(status=0)
                return response.json(0)
            else:
                return response.json(173)
        elif status == '1':
            # return response.json(10)

            dvqs = Device_Info.objects.filter(userID_id=userID, UID=uid)
            aiqs = App_Info.objects.filter(appBundleId=appBundleId).values('app_type')
            print(dvqs)
            print(aiqs)
            if dvqs.exists() and aiqs.exists():
                now_time = int(time.time())
                try:
                    uid_app_qs = UID_App.objects.filter(appBundleId=appBundleId, userID_id=userID, token_val=token_val,
                                                        uid=uid)
                    print(uid_app_qs)
                    if uid_app_qs.exists():
                        uid_app_qs.update(status=1)
                    else:
                        UID_App.objects.create(
                            uid=uid,
                            userID_id=userID,
                            appBundleId=appBundleId,
                            app_type=aiqs[0]['app_type'],
                            push_type=push_type,
                            token_val=token_val,
                            status=1,
                            addTime=now_time,
                            updTime=now_time)
                except Exception as e:
                    print(repr(e))
                    return response.json(10, repr(e))
                else:
                    utko = UidTokenObject()
                    utko.generate(data={'uid': uid})
                    detectUrl = "{SERVER_DOMAIN}notify/push?uidToken={uidToken}". \
                        format(uidToken=utko.token, SERVER_DOMAIN=SERVER_DOMAIN)
                    return response.json(0, {'detectUrl': detectUrl})
            else:
                return response.json(173)


# http://192.168.136.40:8077/notify/push?uidToken=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1aWQiOiJUTjdNUEUzMjExVUU3NkFQMTExQSJ9.k501567VdnhFpn_ygzGRDat3Kqlz5CsEA9jAC2dDk_g&obj=12341234&n_time=1234561234
# 移动侦测接口
class NotificationView(View):

    def get(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        # operation = kwargs.get('operation')
        return self.validation(request.GET)

    def post(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        # operation = kwargs.get('operation')
        return self.validation(request.POST)

    def validation(self, request_dict):
        response = ResponseObject()
        uidToken = request_dict.get('uidToken', None)
        channel = request_dict.get('channel', None)
        n_time = request_dict.get('n_time')
        if not all([uidToken, channel, n_time]):
            return JsonResponse(status=404)
            # return response.json(444)
        utko = UidTokenObject(uidToken)
        uid = utko.UID
        uaqs = UID_App.objects.filter(uid=uid). \
            values('token_val', 'app_type', 'appBundleId', 'push_type', 'uid', 'userID_id', 'userID__NickName')
        if uaqs.exists():
            for ua in uaqs:
                push_type = ua['push_type']
                # ios apns
                if push_type == 0:
                    self.do_apns(request_dict, ua, response)
                # android gcm
                elif push_type == 1:
                    self.do_gmc(request_dict, ua, response)
                # android jpush
                elif push_type == 2:
                    self.do_jpush(request_dict, ua, response)
                self.do_save_equipment_info(ua, n_time, channel)
            #############
            # 阿里云主账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维，请登录 https://ram.console.aliyun.com 创建RAM账号。
            auth = oss2.Auth(OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET)
            # Endpoint以杭州为例，其它Region请按实际情况填写。
            bucket = oss2.Bucket(auth, 'oss-cn-shenzhen.aliyuncs.com', 'apg')
            obj = '{uid}/{channel}/{filename}.jpeg'.format(uid=uid, channel=channel, filename=n_time)
            # 设置此签名URL在60秒内有效。
            url = bucket.sign_url('PUT', obj, 7200)
            res_data = {
                'code': 0,
                'img_push': url,
                'msg': 'success'
            }
            return JsonResponse(status=200, data=res_data)
            ############
        else:
            return JsonResponse(status=200, data={
                'code': 173,
                'msg': 'data is not exist'})

    def do_jpush(self, request_dict, uaql, response):
        jpush_config = {
            'com.ansjer.accloud_ab': {
                'Key': 'f0dc047e5e53fd14199de5b0',
                'Secret': 'aa7f7db33e9f0a7f3871aa1c'},
            'com.ansjer.adcloud_ab': {
                'Key': '76d97b535185114985608234',
                'Secret': 'c9a92b301043cc9c52778692'},
            'com.ansjer.zccloud_ab': {
                'Key': 'd9924f56d3cc7c6017965130',
                'Secret': '869d832d126a232f158b5987'},
            'com.ansjer.loocamccloud_ab': {
                'Key': 'd1cc44797b4642b0e05304fe',
                'Secret': 'c3e8b4ca8c576de61401e56a'},
            'com.ansjer.loocamdcloud_ab': {
                'Key': '76d97b535185114985608234',
                'Secret': 'c9a92b301043cc9c52778692'},
            'com.ansjer.zccloud_a': {
                'Key': '57de2a80d68bf270fd6bdf5a',
                'Secret': '3d354eb6a0b49c2610decf42'},
            'com.ansjer.accloud_a': {
                'Key': 'ff95ee685f49c0dc4013347b',
                'Secret': 'de2c20959f5516fdeeafe78e'},
            'com.ansjer.adcloud_a': {
                'Key': '2e47eb1aee9b164460df3668',
                'Secret': 'b9137d8d684bc248f1809b6d'},
            'com.ansjer.loocamccloud_a': {
                'Key': '23c9213215c7ca0ec945629b',
                'Secret': '81e4b1e859cc8387e2e6c431'},
            'com.ansjer.loocamdcloud_a': {
                'Key': '1dbdd60a16e9892d6f68a073',
                'Secret': '80a97690e7e043109059b403'},
            'com.ansjer.customizedb_a': {
                'Key': '9d79630aa49adfa291fe2568',
                'Secret': '4d8ff52f88136561875a0212'},
        }
        n_time = request_dict.get('n_time', None)
        appBundleId = uaql['appBundleId']
        token_val = uaql['token_val']
        uid = uaql['uid']
        response = ResponseObject()
        app_key = jpush_config[appBundleId]['Key']
        master_secret = jpush_config[appBundleId]['Secret']

        # 此处换成各自的app_key和master_secret
        _jpush = jpush.JPush(app_key, master_secret)
        push = _jpush.create_push()
        # if you set the logging level to "DEBUG",it will show the debug logging.
        _jpush.set_logging("DEBUG")
        # push.audience = jpush.all_
        push.audience = jpush.registration_id(token_val)
        push_data = {"alert": "Motion ", "event_time": n_time, "event_type": "51", "msg": "",
                     "received_at": n_time, "sound": "sound.aif", "uid": uid}
        push_msg = json.dumps(push_data)
        # push.notification = jpush.notification(alert="hello jpush api")
        # push.notification = jpush.notification(alert=push_msg)
        # android = jpush.android(alert="Hello, Android msg",extras=push_data)

        # push.notification = jpush.notification(alert="Hello, JPush!", android=android)
        # push.notification = jpush.message(msg_content=push_data, extras=push_data)
        push.message = jpush.message('Motion', extras=push_data, title='KPNS', content_type='text')
        push.platform = jpush.all_
        try:
            res = push.send()
            print(res)
        except Exception as e:
            print("Exception")
            print(repr(e))
            return response.json(10, repr(e))
        else:
            return response.json(0)

    def do_gmc(self, request_dict, uaql, response):

        n_time = request_dict.get('n_time')
        appBundleId = uaql['appBundleId']
        token_val = uaql['token_val']
        uid = uaql['uid']
        gcm_config = {
            'com.ansjer.zccloud_a': 'AAAAb9YP3rk:APA91bHu8u-CTpcd0g6lKPo0WNVqCi8jZub1cPPbSAY9AucT1HxlF65ZDUko9iG8q2ch17bwu9YWHpK1xI1gHSRXCslLvZlXEmHZC0AG3JKg15XuUvlFKACIajUFV-pOeGRT8tM6-31I',
            'com.ansjer.loocamccloud_a': 'AAAAb9YP3rk:APA91bFCgd-kbVmpK4EVpfdHH_PJZQCYTkOGnTZdIuBWEz2r7aMRsJYHOH3sB-rwcbaRWgnufTyjX9nGQxb6KxQbWVk4ah_H-M3IqGh6Mb60WQQAuR33V6g_Jes5pGL6ViuIxGHqVMaR',
            'com.ansjer.loocamdcloud_a': 'AAAAb9YP3rk:APA91bGw2I2KMD4i-5T7nZO_wB8kuAOuqgyqe5rxmY-W5qkpYEx9IL2IfmC_qf6B_xOyjIDDSjckvMo-RauN__SEoxvAkis7042GRkoKpw7cjZ_H8lC-d50PC0GclPzccrOGFusyKbFY',
            'com.ansjer.customizedb_a': 'AAAAb9YP3rk:APA91bE7kI4vcm-9h_CJNFlOZfc-xwP4Btn6AnjOrwoKV6fgYN7fdarkO76sYxVZiAbDnxsFfOJyP7vQfwyan6mdjuyD5iHdt_XgO22VqniC0vA1V4GJiCS8Tp7LxIX8JVKZl9I_Powt',
            'com.ansjer.customizeda_a': 'AAAAb9YP3rk:APA91bF0HzizVWDc6dKzobY9fsaKDK4veqkOZehDXshVXs8pEEvNWjR_YWbhP60wsRYCHCal8fWN5cECVOWNMMzDsfU88Ty2AUl8S5FtZsmeDTkoGntQOswBr8Ln7Fm_LAp1VqTf9CpM',
        }
        serverKey = gcm_config[appBundleId]
        push_data = {"alert": "Motion ", "event_time": n_time, "event_type": "51", "msg": "",
                     "received_at": n_time, "sound": "sound.aif", "uid": uid}
        json_data = {
            "collapse_key": "WhatYouWant",
            "data": push_data,
            "delay_while_idle": False,
            "time_to_live": 3600,
            "registration_ids": [token_val]
        }

        url = 'https://android.googleapis.com/gcm/send'
        # serverKey = "AAAAb9YP3rk:APA91bHu8u-CTpcd0g6lKPo0WNVqCi8jZub1cPPbSAY9AucT1HxlF65ZDUko9iG8q2ch17bwu9YWHpK1xI1gHSRXCslLvZlXEmHZC0AG3JKg15XuUvlFKACIajUFV-pOeGRT8tM6-31I"

        data = json.dumps(json_data).encode('utf-8')
        headers = {'Content-Type': 'application/json', 'Authorization': 'key=%s' % serverKey}
        req = requests.post(url, data, headers=headers)
        return response.json(0)

    def do_apns(self, request_dict, uaql, response):
        token_val = uaql['token_val']
        n_time = request_dict.get('n_time')
        appBundleId = uaql['appBundleId']
        uid = uaql['uid']
        apns_config = {
            'appbundleId': {'pem_path': 'xxxx', 'topic': 'topic', 'password': 'password'}
        }
        try:
            # daytime = time.strftime("%Y%m%d%H%M", time.localtime(1547256103))
            # print(daytime)
            pem_path = os.path.join(BASE_DIR, apns_config[appBundleId]['topic'])
            # pem_path = os.path.join(BASE_DIR, 'Ansjer/file/apns-dev.pem')
            cli = apns2.APNSClient(mode="dev", client_cert=pem_path, password='111111')
            body = json.dumps({'uid': uid, 'n_time': n_time})
            alert = apns2.PayloadAlert(body="body!", title="title!")
            payload = apns2.Payload(alert=alert)
            n = apns2.Notification(payload=payload, priority=apns2.PRIORITY_LOW)
            res = cli.push(n=n, device_token=token_val, topic=apns_config[appBundleId]['pem_path'])
            # assert res.status_code == 200, res.reason
            # assert res.apns_id 
            if res.status_code == 200:
                return response.json(0)
            else:
                return response.json(404, res.reason)
        except Exception as e:
            return response.json(10, repr(e))

    def do_save_equipment_info(self, uaql, n_time, channel):
        Equipment_Info.objects.create(
            userID_id=uaql['userID_id'],
            eventTime=n_time,
            eventType=1,
            devUid=uaql['uid'],
            devNickName=uaql['userID__NickName'],
            Channel=channel,
            alarm='0',
            receiveTime=n_time)