ASJServer/Controller/DeviceLog.py

#!/usr/bin/env python3  
# -*- coding: utf-8 -*-  
"""
@Copyright (C) ansjer cop Video Technology Co.,Ltd.All rights reserved.
@AUTHOR: ASJRD018
@NAME: Ansjer
@software: PyCharm
@DATE: 2018/6/15 16:47
@Version: python3.6
@MODIFY DECORD:ansjer dev
@file: DeviceLog.py
@Contact: chanjunkai@163.com
"""
import datetime
from django.views.decorators.csrf import csrf_exempt
from Model.models import Device_Info
from Object.mongodb import mongodb
from Service.TokenManager import JSONTokenManager
from Service.ModelService import ModelService
from Service.DeviceOperation import DeviceOperation
from Service.ResponseService import *
'''
curl http://192.168.136.45:8077/devices/C2887N9EBS87ZAT1111A/logs -d "deviceData={\"UID\":\"C2887N9EBS87ZAT1111A\",\"type\":\"0x10014\",\"UserIP\":\"127.0.0.1\",\"time\":1529474865,\"name\":\"admin\"}"
http://192.168.136.40:8077/devices/2N1K3LE78TYJ38CE111A/logs?type=All&starttime=1529462169&endtime=1529462169
'''


@csrf_exempt
def DeviceLog(request, uid):
    # 存储设备日志
    if request.method == 'POST':
        request.encoding = 'utf-8'
        deviceData = request.POST.get('deviceData', None)
        device_info = Device_Info.objects.filter(UID=uid)
        if device_info.exists():
            try:
                data = json.loads(deviceData)
                mdb = mongodb()
                data['et'] = datetime.datetime.utcnow()
                col = "log_device_operation"
                id = mdb.insert_one(col=col, data=data)
                return ResponseJSON(0)
                # qs = mdb.findAll(col=col, page=1, line=10)
            except Exception as e:
                print(repr(e))
                return ResponseJSON(48,repr(e))
        else:
            return ResponseJSON(13)
    # 查找设备日志
    if request.method == 'GET':
        request.encoding = 'utf-8'
        token = request.GET.get('token', None)
        page = request.GET.get('page', None)
        line = request.GET.get('line', None)
        type = request.GET.get('type', None)
        search_class = request.GET.get('class', None)
        starttime = request.GET.get('starttime', None)
        endtime = request.GET.get('endtime', None)
        if token is not None:
            tokenManager = JSONTokenManager()
            error_code = tokenManager.verify_AToken(token)
            if error_code == 0:
                userID = tokenManager.accessDict.get('userID', None)
                if page is None and line is None:
                    page = 1
                    line = 10000
                param_flag = CommonService.get_param_flag(data=[userID, page, line, uid])
                own_dev = ModelService.check_own_device(userID=userID, UID=uid)
                own_per = ModelService.check_permission(userID=userID, permID=30)
                if own_dev is True or own_per is True:
                    if param_flag is True:
                        query = {'uid': uid}
                        if search_class == 'All' or type == 'All':
                            pass
                        else:
                            try:
                                class_data= DeviceOperation.getODla(search_class=search_class)
                                query['type'] = {'$gte': class_data[0], '$lte': class_data[1]}
                            except Exception as e:
                                if type is not None:
                                    query['type'] = type
                        # if starttime is not None and endtime is not None and starttime != '' and endtime != '':
                        #     query['time'] = {'$gte': int(starttime), '$lte': int(endtime)}
                        if starttime is not None and starttime != '' and endtime is not None and endtime != '':
                            query['time'] = {'$gte': int(starttime), '$lte': int(endtime)}
                        elif starttime is not None and starttime != '':
                            query['time'] = {'$gte': int(starttime)}
                        elif endtime is not None and endtime != '':
                            query['time'] = {'$lte': int(endtime)}
                        print('___________query____________')
                        print(query)
                        print('___________query____________')
                        mdb = mongodb()
                        col = "log_device_operation"
                        # if int(page) < 0:
                        #     count = mdb.cout(col=col,query=query)
                        #     total = math.ceil(count/int(line))
                        #     page = int(total)+int(page)+1
                        qs = mdb.findAll(col=col, page=int(page), line=int(line), query=query)
                        if qs is not False:
                            data_list = []
                            for i in qs['data']:
                                i['type'] = DeviceOperation.getOperation(type=i['type'])
                                data_list.append(i)
                            qs['data'] = data_list
                        return ResponseJSON(0,qs)
                else:
                    return ResponseJSON(404)
                return ResponseJSON(444)
            else:
                return HttpResponse(tokenManager.errorCodeInfo(error_code))
        else:
            return ResponseJSON(311)