#!/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/6/4 11:44 @Version: python3.6 @MODIFY DECORD:ansjer dev @file: LangArea.py @Contact: chanjunkai@163.com """ from var_dump import var_dump import json from django.http import HttpResponse from django.views.generic import TemplateView from django.views.decorators.csrf import csrf_exempt from django.utils.decorators import method_decorator from object.ResponseObject import ResponseObject from django.contrib.auth.hashers import make_password, check_password from model.models import UserModel, LangSetModel, LangAreaModel, LangKeyModel, LangValModel, LangPermModel import time from object.TokenObject import TokenObject from django.db.models import Q class LangWordView(TemplateView): def post(self, request, *args, **kwargs): request.encoding = 'utf-8' operation = kwargs.get('operation', None) request_dict = json.loads(request.body.decode('utf-8')) return self.validate(request_dict, operation) def get(self, request, *args, **kwargs): request.encoding = 'utf-8' request_dict = request.GET operation = kwargs.get('operation', None) return self.validate(request_dict, operation) def validate(self, request_dict, operation): response = ResponseObject() print('request_dict:', request_dict) print('operation:',operation) token = request_dict.get('token', None) tko = TokenObject(token) # print('tko:',tko.userID) if tko.code == 0: userID = tko.userID if operation == 'add': user_qs = UserModel.objects.filter(id=userID, username='admin') if not user_qs.exists(): return response.json(403) return self.do_add(request_dict, response) elif operation == 'update': return self.do_update(request_dict, response, userID) elif operation == 'delete': user_qs = UserModel.objects.filter(id=userID, username='admin') if not user_qs.exists(): return response.json(403) return self.do_delete(request_dict, userID, response) # search index table elif operation == 'query': return self.do_query(request_dict, response, userID) elif operation == 'reset': return self.do_reset(request_dict, response, userID) else: return response.json(414) else: return response.json(tko.code) def do_add(self, request_dict, response): word_key = request_dict.get('word_key', None) word_arr = request_dict.get('word_arr', None) word_key_type = request_dict.get('word_key_type', None) if not word_key_type: return response.json(444, 'word_key_type') nowTime = int(time.time()) lang_key_dict = { 'word_key': word_key, 'addTime': nowTime, 'updTime': nowTime, 'type': word_key_type } try: # var_dump(lang_key_dict) lk = LangKeyModel.objects.filter(word_key=word_key) if lk.exists(): print(lk[0].type) print(word_key_type) type = lk[0].type & word_key_type print(type) if lk[0].type & word_key_type != 0: var_dump(list(lk)) return response.json(473,'key已存在') else: type = word_key_type | lk[0].type data = { 'type': type, 'updTime': nowTime } lk.update(**data) return response.json(0) lk = LangKeyModel.objects.create(**lang_key_dict) for w in word_arr: LangValModel.objects.create(la_id=w['la_id'], lk_id=lk.id, addTime=nowTime, updTime=nowTime, word_val=w['val'], status=1) except Exception as e: print(repr(e)) return response.json(404, repr(e)) else: return response.json(0) ''' post_data = { word_key_id:1, word_key:xxx, word_arr:[ {'lang':'','val':''}, {'lang':'','val':''}, {'lang':'','val':''} ] } ''' def do_update(self, request_dict, response, userID): old_word_key = request_dict.get('old_word_key', None) word_key = request_dict.get('word_key', None) word_arr = request_dict.get('word_arr', None) status = request_dict.get('status', 0) # from var_dump import var_dump # var_dump(request_dict) lk = LangKeyModel.objects.filter(word_key=old_word_key) nowTime = int(time.time()) if lk.exists(): lk_id = lk[0].id if old_word_key != word_key: user_qs = UserModel.objects.filter(id=userID, username='admin') if user_qs.exists(): lk.update(word_key=word_key, updTime=nowTime) else: lk.update(updTime=nowTime) # 如果是管理员，是status的值为1，表示记录为新增 user = UserModel.objects.get(id=userID) lang_perm_ql = LangPermModel.objects.filter(user__id=userID).values_list('lang__lang', flat=True) lang_perm_ls = list(lang_perm_ql) print(lang_perm_ls) if user.role_type == 1: status = 1 for w in word_arr: lv_qs = LangValModel.objects.filter(lk__word_key=word_key, lk__project__isnull=True, la__lang=w) if lv_qs.exists() and w in lang_perm_ql: lv_qs.update(updTime=nowTime, word_val=word_arr[w], status=status) else: la_qs = LangAreaModel.objects.filter(lang=w) if la_qs.exists(): la_id = la_qs[0].id LangValModel.objects.create(la_id=la_id, lk_id=lk_id, addTime=nowTime, updTime=nowTime, word_val=word_arr[w], status=status) return response.json(0) else: return response.json(404) def do_delete(self, request_dict, userID, response): print('delete') user_qs = UserModel.objects.filter(id=userID, username='admin') if not user_qs.exists(): return response.json(403) word_key = request_dict.get('word_key', None) word_key_type = request_dict.get('work_key_type', None) print(word_key_type) if not word_key_type: return response.json(444, 'work_key_type') try: word_key_type = int(word_key_type) print(word_key_type) lk_qs = LangKeyModel.objects.filter(word_key=word_key) if lk_qs.exists(): lk = lk_qs[0] print(lk.type) if lk.type < word_key_type: return response.json(444, 'work_key_type') else: lk.type -= word_key_type if lk.type > 0: lk.save() else: lk_qs.delete() LangValModel.objects.filter(lk__word_key=word_key).delete() except Exception as e: return response.json(404, repr(e)) else: return response.json(0) def do_query(self, request_dict, response, userID): print(request_dict) page = int(request_dict.get('page', None)) line = int(request_dict.get('line', None)) searchKey = request_dict.get('searchKey', None) searchVal = request_dict.get('searchVal', None) langType = request_dict.get('langType', 0) if searchKey: searchKey = searchKey.strip() if searchVal: searchKey = searchKey.strip() orderByupdate = request_dict.get('orderByupdate', 0) if page and line: lang_set_list = LangSetModel.objects.filter(user__id=userID).values_list('lang__id', flat=True) print('lang_set_list:',lang_set_list) lang_set_list = list(lang_set_list) print('lang_set_list:', lang_set_list) la_qs = LangAreaModel.objects.filter(id__in=lang_set_list).values('lang', 'id') print(langType) tmpType = int(langType) print(tmpType) if tmpType == 0: lk_qs = LangKeyModel.objects.filter(type__in=(1, 3, 5, 7)) print('lk_qs:', lk_qs) elif tmpType == 1: lk_qs = LangKeyModel.objects.filter(type__in=(2, 3, 6, 7)) elif tmpType == 2: lk_qs = LangKeyModel.objects.filter(type__in=(4, 5, 6, 7)) if searchKey and searchVal: if searchKey == 'key': lk_qs = lk_qs.filter(word_key__contains=searchVal) # lk_qs = lk_qs.filter(word_key=searchVal) else: lk_qs = lk_qs.filter(langvalmodel__word_val__contains=searchVal, langvalmodel__la__lang=searchKey) count = lk_qs.count() # lk_qs = lk_qs[(page - 1) * line:page * line].values_list('word_key', flat=True) if orderByupdate == 1: lk_qs = lk_qs.order_by('updTime') else: lk_qs = lk_qs.order_by('-updTime') lk_qs = lk_qs.values('word_key', 'updTime').distinct()[(page - 1) * line: page * line] k_list = [] lw_dict = {} for lk in lk_qs: k_list.append(lk['word_key']) lw_dict[lk['word_key']] = {'updTime': lk['updTime']} print('k_list:',k_list) lv_qs = LangValModel.objects.filter(lk__word_key__in=k_list, la__id__in=lang_set_list). \ values('word_val', 'la__id', 'la__lang', 'lk__word_key', 'lk__id', 'status') print('lv_qs:', lv_qs) user = UserModel.objects.get(id=userID) lang_perm_ql = LangPermModel.objects.filter(user__id=userID).values_list('lang__lang', flat=True) lang_perm_ls = list(lang_perm_ql) print('lang_perm_ql:', lang_perm_ql) print('lw_dict:', lw_dict) for lv in lv_qs: lang = lv['la__lang'] # print('lang=%s' % lang) lw_dict[lv['lk__word_key']][lang] = lv['word_val'] # print('lw_dict_word_val:', lw_dict) if user.role_type == 1: lw_dict[lv['lk__word_key']]['status'] = 0 elif lang in lang_perm_ls: lw_dict[lv['lk__word_key']]['status'] = lv['status'] # print('lw_dict_status:', lw_dict) res = { 'la_list': list(la_qs), 'lw_dict': lw_dict, # 'lk_list': list(lk_qs), # 'lv_list': list(lv_qs) 'count': count } print('res:',res) return response.json(0, res) else: return response.json(444, 'page,line') def do_reset(self, request_dict, response, userID): word_key = request_dict.get('word_key', None) if word_key: word_key_list = word_key.split(',') # 获取该用户可以修改的语种 lp_qs = LangPermModel.objects.filter(user_id=userID).values_list('lang__id') lq_list = list(lp_qs) print('lq_list:', lq_list) # ls_qs = LangSetModel.objects.filter(user_id=userID, lang_id__in=lq_list).values_list('lang__id') # ls_list = list(ls_qs) lk = LangKeyModel.objects.filter(word_key__in=word_key_list).values_list('id') lv_qs = LangValModel.objects.filter(Q(lk_id__in=lk) & ~Q(status=0) & Q(la_id__in=lq_list)) # print(lv_qs.values()) if lv_qs.exists(): lv_qs.update(status=0) return response.json(0) else: return response.json(10,"数据已重置") else: return response.json(404)