import time
import simplejson as json
from django.utils.decorators import method_decorator
from django.views.decorators.csrf import csrf_exempt
from django.views.generic.base import View
from Object.ResponseObject import ResponseObject
from Object.TokenObject import TokenObject
from Model.models import UID_App
from Service.CommonService import CommonService
from Service.ModelService import ModelService
import traceback

'''
# 管理员获取信息
http://192.168.136.39:8000/uidApp/adminQuery?token=local&page=1&line=10
  管理员删除信息
http://192.168.136.39:8000/uidApp/adminDelete?token=local&id=2
  管理员添加信息
http://192.168.136.39:8000/uidApp/adminAdd?token=local&uid=321&app_id=1&app_type=2&token_val=ertewtwetrewrt
  管理员编辑信息
http://192.168.136.39:8000/uidApp/adminEdit?token=local&id=6&content={"token_val":"9999"}
'''


# 设备信息添加
class UidappView(View):
    @method_decorator(csrf_exempt)
    def dispatch(self, *args, **kwargs):
        return super(UidappView, self).dispatch(*args, **kwargs)

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

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

    def validation(self, request_dict, request, operation):
        response = ResponseObject()
        if operation is None:
            return response.json(444, 'error path')
        token = request_dict.get('token', None)
        # 设备主键uid
        tko = TokenObject(token)
        response.lang = tko.lang
        if tko.code != 0:
            return response.json(tko.code)
        userID = tko.userID
        if operation == 'adminDelete':
            return self.do_admin_delete(request_dict, userID, response)
        elif operation == 'adminQuery':
            return self.do_admin_query(request_dict, userID, response)
        elif operation == 'adminAdd':
            return self.do_admin_add(request_dict, userID, response)
        elif operation == 'adminEdit':
            return self.do_admin_edit(request_dict, userID, response)
        else:
            return response.json(444, 'error path')

    # 管理员删除
    def do_admin_delete(self, request_dict, userID, response):
        own_perm = ModelService.check_perm(userID, 20)
        if own_perm is True:
            id = request_dict.get('id')
            try:
                list = UID_App.objects.filter(id=id)
                if list.exists():
                    list.delete()
                    return response.json(0)
                else:
                    return response.json(173)
            except Exception as e:
                print(repr(e))
                return response.json(424, repr(e))
        else:
            return response.json(404)

    # 管理员查询接口
    def do_admin_query(self, request_dict, userID, response):
        own_perm = ModelService.check_perm(userID, 20)
        if own_perm is True:
            page = request_dict.get('page', None)
            line = request_dict.get('line', None)
            page = int(page)
            line = int(line)
            omqs = UID_App.objects.filter()
            if not omqs.exists():
                return response.json(0, [])
            count = omqs.count()
            order_ql = omqs[(page - 1) * line:page * line]. \
                values("id", "uid", "app_type", "token_val", "addTime", "updTime", "app__id", "app__appName")
            order_list = list(order_ql)
            return response.json(0, {'data': order_list, 'count': count})

        else:
            return response.json(404)

    # 管理员的添加
    def do_admin_add(self, request_dict, userID, response):
        own_perm = ModelService.check_perm(userID=userID, permID=40)
        if own_perm is not True:
            return response.json(404)
        uid = request_dict.get('uid', None)
        app_id = request_dict.get('app_id', None)
        app_type = request_dict.get('app_type', None)
        token_val = request_dict.get('token_val', None)
        timestamp = int(time.time())
        param_flag = CommonService.get_param_flag(
            data=[uid, app_id, app_type, token_val])
        if param_flag is not True:
            return response.json(444)
        try:
            Uidapp = UID_App(
                uid=uid,
                app_id=app_id,
                app_type=app_type,
                token_val=token_val,
                addTime=timestamp,
                updTime=timestamp)
            Uidapp.save()
            return response.json(0)
        except Exception:
            errorInfo = traceback.format_exc()
            print(errorInfo)
            return response.json(500, {'details': errorInfo})

    # 管理员的编辑
    def do_admin_edit(self, request_dict, userID, response):
        own_perm = ModelService.check_perm(userID=userID, permID=50)
        if own_perm is not True:
            return response.json(404)
        deviceContent = request_dict.get('content', None)
        id = request_dict.get('id', None)
        if not deviceContent or not id:
            return response.json(444, 'content,id')
        try:
            timestamp = int(time.time())
            deviceData = json.loads(deviceContent)
            uid_app = UID_App.objects.filter(id=id)
            if uid_app.exists():
                uid_app.update(updTime=timestamp, **deviceData)
                return response.json(0)
            else:
                return response.json(173)
        except Exception:
            errorInfo = traceback.format_exc()
            print(errorInfo)
            return response.json(500, {'details': errorInfo})


class NotificationView(View):

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

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

    def validation(self, request_dict, request, operation):
        response = ResponseObject()
        if operation is None:
            return response.json(444, 'error path')
        token = request_dict.get('token', None)
        time = request_dict.get('time',None)

        # 设备主键uid
        tko = TokenObject(token)
        response.lang = tko.lang
        if tko.code != 0:
            if operation == 'jpush':
                return
            elif operation == 'gcm':
                return
            elif operation == 'apns':
                return
            else:
                return response.json(414)
        else:
            return response.json(tko.code)

    def do_jpush(self):
        response = ResponseObject()
        devToken = ''
        app_key = ''
        master_secret = ''
        import jpush as jpush

        # 此处换成各自的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(devToken)

        push.notification = jpush.notification(alert="hello python jpush api")
        push.platform = jpush.all_
        try:
            res = push.send()
        except Exception as e:
            print("Exception")
            return response.json(10, repr(e))
        return response.json(0)

    def do_gmc(self):
        import json
        import requests

        data = {
            "key1": "abc",
            "key2": "def"
        }

        json_data = {
            "collapse_key": "WhatYouWant",
            "data": data,
            "delay_while_idle": False,
            "time_to_live": 3600,
            "registration_ids": [
                'eSooD4fAARg:APA91bEPenBPnSn5aXIQk56QdLOQ1Mu3hevHsekP_0eDpg458y2ZMBP6By2rVsGYIoxZrXxvkkptPKUE9CmUygBxaZXABddUWB9FyLlznRFerC7RG9X5PsEOH58xK9_aTUdkT7p6Ocld']
        }

        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)
        response = ResponseObject()

        return response.json(0)

    def do_apns(self):
        return