#coding:utf-8
__author__ = "ila"
import base64, copy, logging, os, sys, time, xlrd, json, datetime, configparser
from import JsonResponse
from import apps
from import Count,Sum
from .models import news
from import *
from import Auth
from import Common
import as mes
from import connection
import random
from import send_mail
from import settings
from import redirect
from import Q
from util.baidubce_api import BaiDuBce
from .config_model import config
def news_register(request):
if in ["POST", "GET"]:
msg = {'code': normal_code, "msg": mes.normal_code}
req_dict = ("req_dict")
error = (news, news, req_dict)
if error != None:
msg['code'] = crud_error_code
msg['msg'] = "The user already exists, please do not register repeatedly!"
return JsonResponse(msg)
def news_login(request):
if in ["POST", "GET"]:
msg = {'code': normal_code, "msg": mes.normal_code}
req_dict = ("req_dict")
datas = (news, news, req_dict)
if not datas:
msg['code'] = password_error_code
msg['msg'] = mes.password_error_code
return JsonResponse(msg)
try:
__sfsh__= news.__sfsh__
except:
__sfsh__=None
if __sfsh__=='yes':
if datas[0].get('sfsh')!='yes':
msg['code']=other_code
msg['msg'] = "The account is locked, please contact the administrator to review!"
return JsonResponse(msg)
req_dict['id'] = datas[0].get('id')
return (Auth, news, req_dict)
def news_logout(request):
if in ["POST", "GET"]:
msg = {
"msg": "Login successfully",
"code": 0
}
return JsonResponse(msg)
def news_resetPass(request):
'''
'''
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": mes.normal_code}
req_dict = ("req_dict")
columns= ( news, news)
try:
__loginUserColumn__= news.__loginUserColumn__
except:
__loginUserColumn__=None
username=req_dict.get(list(req_dict.keys())[0])
if __loginUserColumn__:
username_str=__loginUserColumn__
else:
username_str=username
if 'mima' in columns:
password_str='mima'
else:
password_str='password'
init_pwd = '123456'
recordsParam = {}
recordsParam[username_str] = req_dict.get("username")
records=(news, news, recordsParam)
if len(records)<1:
msg['code'] = 400
msg['msg'] = 'The user does not exist'
return JsonResponse(msg)
eval('''({}='{}').update({}='{}')'''.format(username_str,username,password_str,init_pwd))
return JsonResponse(msg)
def news_session(request):
'''
'''
if in ["POST", "GET"]:
msg = {"code": normal_code,"msg": mes.normal_code, "data": {}}
req_dict={"id":('params').get("id")}
msg['data'] = (news, news, req_dict)[0]
return JsonResponse(msg)
def news_default(request):
if in ["POST", "GET"]:
msg = {"code": normal_code,"msg": mes.normal_code, "data": {}}
req_dict = ("req_dict")
req_dict.update({"isdefault":"yes"})
data=(news, news, req_dict)
if len(data)>0:
msg['data'] = data[0]
else:
msg['data'] = {}
return JsonResponse(msg)
def news_page(request):
'''
'''
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": mes.normal_code, "data":{"currPage":1,"totalPage":1,"total":1,"pageSize":10,"list":[]}}
req_dict = ("req_dict")
global news
#Get all column names
columns= ( news, news)
#The table where the current logged in user is located
tablename = ("tablename")
#authColumn=list(__authTables__.keys())[0]
#authTable=__authTables__.get(authColumn)
# if authTable==tablename:
#params = ("params")
#req_dict[authColumn]=(authColumn)
'''__authSeparate__This attribute is true, params add userid, and the background only querys personal data '''
try:
__authSeparate__=news.__authSeparate__
except:
__authSeparate__=None
if __authSeparate__=="yes":
tablename=("tablename")
if tablename!="users" and 'userid' in columns:
try:
req_dict['userid']=("params").get("id")
except:
pass
#When the project attribute hasMessage is "Yes", the generated system automatically generates the table messages for the message board. At the same time, the table attribute hasMessage of the table is also set to "Yes". The fields include userid (userid id), username (username), content (message content), reply (reply)
#Interface page requires permissions to be distinguished. Ordinary users view their own message and reply records, and administrators view all message and reply records.
try:
__hasMessage__=news.__hasMessage__
except:
__hasMessage__=None
if __hasMessage__=="yes":
tablename=("tablename")
if tablename!="users":
req_dict["userid"]=("params").get("id")
# determine the table attributes of the current table areAdmin, if true, it is the administrator table
# When the table attribute isAdmin = "Yes", the user table that is flashed is also an administrator, that is, page and list can view everyone's examination records (apply to other tables at the same time)
__isAdmin__ = None
allModels = apps.get_app_config('main').get_models()
for m in allModels:
if m.__tablename__==tablename:
try:
__isAdmin__ = m.__isAdmin__
except:
__isAdmin__ = None
break
# The current table is also a table with administrator privileges
if __isAdmin__ == "yes" and 'news' != 'forum':
if req_dict.get("userid") and 'news' != 'chat':
del req_dict["userid"]
else:
#Tables with non-administrator permissions, determine whether the current table field name has userid
if tablename!="users" and 'news'[:7]!='discuss'and "userid" in (news,news):
req_dict["userid"] = ("params").get("id")
#When the column attribute authTable has a value (a user table) [the column name must be the same as the login field name of the user table], then the corresponding table has a hidden attribute authTable that is "Yes", then when the user views the information of the table, he can only view his own
try:
__authTables__=news.__authTables__
except:
__authTables__=None
if __authTables__!=None and __authTables__!={} and __isAdmin__ == "yes":
try:
del req_dict['userid']
# tablename=("tablename")
# if tablename=="users":
# del req_dict['userid']
except:
pass
for authColumn,authTable in __authTables__.items():
if authTable==tablename:
params = ("params")
req_dict[authColumn]=(authColumn)
username=(authColumn)
break
q = Q()
msg['data']['list'], msg['data']['currPage'], msg['data']['totalPage'], msg['data']['total'], \
msg['data']['pageSize'] =(news, news, req_dict, request, q)
return JsonResponse(msg)
def news_autoSort(request):
'''
． Intelligent recommendation function (table attributes: [intelRecom (Yes/No)], add clicktime [the field is not displayed in the front end] field (updated when calling the info/detail interface), sort by clicktime)
Use it in the main information list (such as product list, news list), just display the 5 records that have been recently clicked or newly added.
'''
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": mes.normal_code, "data":{"currPage":1,"totalPage":1,"total":1,"pageSize":10,"list":[]}}
req_dict = ("req_dict")
if "clicknum" in (news,news):
req_dict['sort']='clicknum'
elif "browseduration" in (news,news):
req_dict['sort']='browseduration'
else:
req_dict['sort']='clicktime'
req_dict['order']='desc'
msg['data']['list'], msg['data']['currPage'], msg['data']['totalPage'], msg['data']['total'], \
msg['data']['pageSize'] = (news,news, req_dict)
return JsonResponse(msg)
def news_list(request):
'''
Front desk pagination
'''
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": mes.normal_code, "data":{"currPage":1,"totalPage":1,"total":1,"pageSize":10,"list":[]}}
req_dict = ("req_dict")
if req_dict.__contains__('vipread'):
del req_dict['vipread']
#Get all column names
columns= ( news, news)
#Table attribute [forEndList] Front-end list: Similar to the default list page in the background, but is placed in the foreground. No: means there is no this page, yes: means there is this page (you don't need to log in to view), before logging in: means there is this page and you need to log in to view
try:
__foreEndList__=news.__foreEndList__
except:
__foreEndList__=None
if __foreEndList__=="Click before":
tablename=("tablename")
if tablename!="users" and 'userid' in columns:
try:
req_dict['userid']=("params").get("id")
except:
pass
#forrEndListAuth
try:
__foreEndListAuth__=news.__foreEndListAuth__
except:
__foreEndListAuth__=None
#authSeparate
try:
__authSeparate__=news.__authSeparate__
except:
__authSeparate__=None
if __foreEndListAuth__ =="yes" and __authSeparate__=="yes":
tablename=("tablename")
if tablename!="users":
req_dict['userid']=("params",{"id":0}).get("id")
tablename = ("tablename")
if tablename == "users" and req_dict.get("userid") != None:#Judge whether the userid column name exists
del req_dict["userid"]
else:
__isAdmin__ = None
allModels = apps.get_app_config('main').get_models()
for m in allModels:
if m.__tablename__==tablename:
try:
__isAdmin__ = m.__isAdmin__
except:
__isAdmin__ = None
break
if __isAdmin__ == "yes":
if req_dict.get("userid"):
# del req_dict["userid"]
pass
else:
#Tables with non-administrator permissions, determine whether the current table field name has userid
if "userid" in columns:
try:
pass
except:
pass
#When the column attribute authTable has a value (a user table) [the column name must be the same as the login field name of the user table], then the corresponding table has a hidden attribute authTable that is "Yes", then when the user views the information of the table, he can only view his own
try:
__authTables__=news.__authTables__
except:
__authTables__=None
if __authTables__!=None and __authTables__!={} and __foreEndListAuth__=="yes":
try:
del req_dict['userid']
except:
pass
for authColumn,authTable in __authTables__.items():
if authTable==tablename:
params = ("params")
req_dict[authColumn]=(authColumn)
username=(authColumn)
break
if news.__tablename__[:7]=="discuss":
try:
del req_dict['userid']
except:
pass
q = Q()
msg['data']['list'], msg['data']['currPage'], msg['data']['totalPage'], msg['data']['total'], \
msg['data']['pageSize'] = (news, news, req_dict, request, q)
return JsonResponse(msg)
def news_save(request):
'''
New background
'''
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
req_dict = ("req_dict")
if 'clicktime' in req_dict.keys():
del req_dict['clicktime']
tablename=("tablename")
__isAdmin__ = None
allModels = apps.get_app_config('main').get_models()
for m in allModels:
if m.__tablename__==tablename:
try:
__isAdmin__ = m.__isAdmin__
except:
__isAdmin__ = None
break
#Get all column names
columns= ( news, news)
if tablename!='users' and req_dict.get("userid")!=None and 'userid' in columns and __isAdmin__!='yes':
params=("params")
req_dict['userid']=('id')
if 'addtime' in req_dict.keys():
del req_dict['addtime']
error= (news,news, req_dict)
if error!=None:
msg['code'] = crud_error_code
msg['msg'] = error
return JsonResponse(msg)
def news_add(request):
'''
Newly added to the front desk
'''
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
req_dict = ("req_dict")
#Get all column names
columns= ( news, news)
try:
__authSeparate__=news.__authSeparate__
except:
__authSeparate__=None
if __authSeparate__=="yes":
tablename=("tablename")
if tablename!="users" and 'userid' in columns:
try:
req_dict['userid']=("params").get("id")
except:
pass
try:
__foreEndListAuth__=news.__foreEndListAuth__
except:
__foreEndListAuth__=None
if __foreEndListAuth__ and __foreEndListAuth__!="no":
tablename=("tablename")
if tablename!="users":
req_dict['userid']=("params").get("id")
if 'addtime' in req_dict.keys():
del req_dict['addtime']
error= (news,news, req_dict)
if error!=None:
msg['code'] = crud_error_code
msg['msg'] = error
return JsonResponse(msg)
def news_thumbsup(request,id_):
'''
Like: table attribute thumbsUp [Yes/No], thumbsupnum like and crazilynum step fields are added to the table.
'''
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
req_dict = ("req_dict")
id_=int(id_)
type_=int(req_dict.get("type",0))
rets=(news,news,id_)
update_dict={
"id":id_,
}
if type_==1:#praise
update_dict["thumbsupnum"]=int(rets[0].get('thumbsupnum'))+1
elif type_==2:#new
update_dict["crazilynum"]=int(rets[0].get('crazilynum'))+1
error = (news,news, update_dict)
if error!=None:
msg['code'] = crud_error_code
msg['msg'] = error
return JsonResponse(msg)
def news_info(request,id_):
'''
'''
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
data = (news,news, int(id_))
if len(data)>0:
msg['data']=data[0]
if msg['data'].__contains__("reversetime"):
# msg['data']['reversetime'] = msg['data']['reversetime'].strftime("%Y-%m-%d %H:%M:%S")
reversetime = (msg['data']['reversetime'], '%Y-%m-%d %H:%M:%S')
msg['data']['reversetime'] = ("%Y-%m-%d %H:%M:%S")
#Number of views
try:
__browseClick__= news.__browseClick__
except:
__browseClick__=None
if __browseClick__=="yes" and "clicknum" in (news,news):
try:
clicknum=int(data[0].get("clicknum",0))+1
except:
clicknum=0+1
click_dict={"id":int(id_),"clicknum":clicknum}
ret=(news,news,click_dict)
if ret!=None:
msg['code'] = crud_error_code
msg['msg'] = ret
return JsonResponse(msg)
def news_detail(request,id_):
'''
'''
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
data =(news,news, int(id_))
if len(data)>0:
msg['data']=data[0]
if msg['data'].__contains__("reversetime"):
# msg['data']['reversetime'] = msg['data']['reversetime'].strftime("%Y-%m-%d %H:%M:%S")
reversetime = (msg['data']['reversetime'], '%Y-%m-%d %H:%M:%S')
msg['data']['reversetime'] = ("%Y-%m-%d %H:%M:%S")
#Number of views
try:
__browseClick__= news.__browseClick__
except:
__browseClick__=None
if __browseClick__=="yes" and "clicknum" in (news,news):
try:
clicknum=int(data[0].get("clicknum",0))+1
except:
clicknum=0+1
click_dict={"id":int(id_),"clicknum":clicknum}
ret=(news,news,click_dict)
if ret!=None:
msg['code'] = crud_error_code
msg['msg'] = retfo
return JsonResponse(msg)
def news_update(request):
'''
'''
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
req_dict = ("req_dict")
if req_dict.get("mima") and "mima" not in (news,news) :
del req_dict["mima"]
if req_dict.get("password") and "password" not in (news,news) :
del req_dict["password"]
try:
del req_dict["clicknum"]
except:
pass
error = (news, news, req_dict)
if error!=None:
msg['code'] = crud_error_code
msg['msg'] = error
return JsonResponse(msg)
def news_delete(request):
'''
Batch Delete
'''
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
req_dict = ("req_dict")
error=(news,
news,
req_dict.get("ids")
)
if error!=None:
msg['code'] = crud_error_code
msg['msg'] = error
return JsonResponse(msg)
def news_vote(request,id_):
'''
Number of browsing clicks (table attribute [browseClick: Yes/No], click field (clicknum), backend automatically +1 when calling info/detail interface), voting function (table attribute [vote: Yes/No], voting field (votenum), call backend votenum +1 when calling info/detail interface)
Statistics the number of clicks on a product or news; provides voting function for news
'''
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": mes.normal_code}
data= (news, news, int(id_))
for i in data:
votenum=('votenum')
if votenum!=None:
params={"id":int(id_),"votenum":votenum+1}
error=(news,news,params)
if error!=None:
msg['code'] = crud_error_code
msg['msg'] = error
return JsonResponse(msg)
def news_importExcel(request):
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": "success", "data": {}}
excel_file = ("file", "")
file_type = excel_file.('.')[1]
if file_type in ['xlsx', 'xls']:
data = xlrd.open_workbook(filename=None, file_contents=excel_file.read())
table = ()[0]
rows =
try:
for row in range(1, rows):
row_values = table.row_values(row)
req_dict = {}
(news, news, req_dict)
except:
pass
else:
msg = {
"msg": "File Type Error",
"code": 500
}
return JsonResponse(msg)
def news_sendemail(request):
if in ["POST", "GET"]:
req_dict = ("req_dict")
code = (['0', '1', '2', '3', '4', '5', '6', '7', '8', '9'], 4)
to = []
(req_dict['email'])
send_mail('User Registration', 'Your registration verification code is ['+''.join(code)+'】, please do not leak the verification code to others. If it is not me, please do not operate it. ', 'yclw9@', to, fail_silently = False)
cursor = ()
("insert into emailregistercode(email,role,code) values('"+req_dict['email']+"','user','"+''.join(code)+"')")
msg = {
"msg": "Send successfully",
"code": 0
}
return JsonResponse(msg)
def news_autoSort2(request):
return JsonResponse({"code": 0, "msg": '', "data":{}})
# (Statistics by value) Time statistics type
def news_value(request, xColumnName, yColumnName, timeStatType):
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": "success", "data": {}}
where = ' where 1 = 1 '
sql = ''
if timeStatType == 'day':
sql = "SELECT DATE_FORMAT({0}, '%Y-%m-%d') {0}, sum({1}) total FROM news {2} GROUP BY DATE_FORMAT({0}, '%Y-%m-%d') LIMIT 10".format(xColumnName, yColumnName, where, '%Y-%m-%d')
if timeStatType == 'moon':
sql = "SELECT DATE_FORMAT({0}, '%Y-%m') {0}, sum({1}) total FROM news {2} GROUP BY DATE_FORMAT({0}, '%Y-%m') LIMIT 10".format(xColumnName, yColumnName, where, '%Y-%m')
if timeStatType == 'Year':
sql = "SELECT DATE_FORMAT({0}, '%Y') {0}, sum({1}) total FROM news {2} GROUP BY DATE_FORMAT({0}, '%Y') LIMIT 10".format(xColumnName, yColumnName, where, '%Y')
L = []
cursor = ()
(sql)
desc =
data_dict = [dict(zip([col[0] for col in desc], row)) for row in ()]
for online_dict in data_dict:
for key in online_dict:
if '' in str(type(online_dict[key])):
online_dict[key] = online_dict[key].strftime(
"%Y-%m-%d %H:%M:%S")
else:
pass
(online_dict)
msg['data'] = L
return JsonResponse(msg)
# Statistics by value
def news_o_value(request, xColumnName, yColumnName):
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": "success", "data": {}}
where = ' where 1 = 1 '
sql = "SELECT {0}, sum({1}) AS total FROM news {2} GROUP BY {0} LIMIT 10".format(xColumnName, yColumnName, where)
L = []
cursor = ()
(sql)
desc =
data_dict = [dict(zip([col[0] for col in desc], row)) for row in ()]
for online_dict in data_dict:
for key in online_dict:
if '' in str(type(online_dict[key])):
online_dict[key] = online_dict[key].strftime(
"%Y-%m-%d %H:%M:%S")
else:
pass
(online_dict)
msg['data'] = L
return JsonResponse(msg)
# (Statistics by value) Time statistics type (multiple)
def news_valueMul(request, xColumnName, timeStatType):
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": "success", "data": []}
req_dict = ("req_dict")
where = ' where 1 = 1 '
for item in req_dict['yColumnNameMul'].split(','):
sql = ''
if timeStatType == 'day':
sql = "SELECT DATE_FORMAT({0}, '%Y-%m-%d') {0}, sum({1}) total FROM news {2} GROUP BY DATE_FORMAT({0}, '%Y-%m-%d') LIMIT 10".format(xColumnName, item, where, '%Y-%m-%d')
if timeStatType == 'moon':
sql = "SELECT DATE_FORMAT({0}, '%Y-%m') {0}, sum({1}) total FROM news {2} GROUP BY DATE_FORMAT({0}, '%Y-%m') LIMIT 10".format(xColumnName, item, where, '%Y-%m')
if timeStatType == 'Year':
sql = "SELECT DATE_FORMAT({0}, '%Y') {0}, sum({1}) total FROM news {2} GROUP BY DATE_FORMAT({0}, '%Y') LIMIT 10".format(xColumnName, item, where, '%Y')
L = []
cursor = ()
(sql)
desc =
data_dict = [dict(zip([col[0] for col in desc], row)) for row in ()]
for online_dict in data_dict:
for key in online_dict:
if '' in str(type(online_dict[key])):
online_dict[key] = online_dict[key].strftime(
"%Y-%m-%d %H:%M:%S")
else:
pass
(online_dict)
msg['data'].append(L)
return JsonResponse(msg)
# (Statistics by value (multiple))
def news_o_valueMul(request, xColumnName):
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": "success", "data": []}
req_dict = ("req_dict")
where = ' where 1 = 1 '
for item in req_dict['yColumnNameMul'].split(','):
sql = "SELECT {0}, sum({1}) AS total FROM news {2} GROUP BY {0} LIMIT 10".format(xColumnName, item, where)
L = []
cursor = ()
(sql)
desc =
data_dict = [dict(zip([col[0] for col in desc], row)) for row in ()]
for online_dict in data_dict:
for key in online_dict:
if '' in str(type(online_dict[key])):
online_dict[key] = online_dict[key].strftime(
"%Y-%m-%d %H:%M:%S")
else:
pass
(online_dict)
msg['data'].append(L)
return JsonResponse(msg)
def news_group(request, columnName):
if in ["POST", "GET"]:
msg = {"code": normal_code, "msg": "success", "data": {}}
where = ' where 1 = 1 '
sql = "SELECT COUNT(*) AS total, " + columnName + " FROM news " + where + " GROUP BY " + columnName + " LIMIT 10"
L = []
cursor = ()
(sql)
desc =
data_dict = [dict(zip([col[0] for col in desc], row)) for row in ()]
for online_dict in data_dict:
for key in online_dict:
if '' in str(type(online_dict[key])):
online_dict[key] = online_dict[key].strftime("%Y-%m-%d")
else:
pass
(online_dict)
msg['data'] = L
return JsonResponse(msg)