ASJLanguageSys/controller/SysSet.py

#!/usr/bin/env python3  
# -*- coding: utf-8 -*-  
"""
@Copyright (C) ansjer cop Video Technology Co.,Ltd.All rights reserved.
@AUTHOR: ASJRD018
@NAME: langer
@software: PyCharm
@DATE: 2019/9/6 11:02
@Version: python3.6
@MODIFY DECORD:ansjer dev
@file: SysSet.py
@Contact: chanjunkai@163.com
"""
import json
import time
from var_dump import var_dump

from django.views.generic import TemplateView

from model.models import SysSetModel
from object.ResponseObject import ResponseObject
from object.TokenObject import TokenObject
from object.RedisObject import RedisObject


class queryView(TemplateView):
    def post(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        request_dict = json.loads(request.body.decode('utf-8'))
        return self.validate(request_dict)

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

    def validate(self, request_dict):
        response = ResponseObject()
        token = request_dict.get('token', None)
        key_list = request_dict.get('key_list')
        tko = TokenObject(token)
        if tko.code == 0:
            userID = tko.userID
            if key_list:
                sys_qs = SysSetModel.objects.filter(key__in=key_list).values('id', 'key', 'val')
                res = {}
                for i in sys_qs:
                    res[i['key']] = i['val']
                return response.json(0, res)
            else:
                pass
        else:
            return response.json(tko.code)


class updateView(TemplateView):
    def post(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        request_dict = json.loads(request.body.decode('utf-8'))
        return self.validate(request_dict)

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

    def validate(self, request_dict):
        response = ResponseObject()
        token = request_dict.get('token', None)
        update_data = request_dict.get('update_data', None)
        # asinterval = request_dict.get('update_data', None)
        # asimgEmail = request_dict.get('asimgEmail', None)
        from var_dump import var_dump
        var_dump(update_data)
        if not update_data:
            return response.json(0)
        nowTime = int(time.time())
        tko = TokenObject(token)
        redisObj = RedisObject()
        if tko.code == 0:
            for i in update_data:
                sys_qs = SysSetModel.objects.filter(key=i['key'])
                if sys_qs.exists():
                    if i['key'] == 'asinterval':
                        redisObj.set_data(key='asinterval', val=1, expire=int(i['val']))
                    sys_qs.update(val=i['val'], updTime=nowTime)
                else:
                    if i['key'] == 'asinterval':
                        redisObj.set_data(key='asinterval', val=1, expire=int(i['val']))
                    create_dict = {
                        'addTime': nowTime,
                        'updTime': nowTime,
                        'key': i['key'],
                        'val': i['val'],
                    }
                    SysSetModel.objects.create(**create_dict)
            return response.json(0)
        else:
            return response.json(tko.code)