赞
踩
作者简介:Java领域优质创作者、CSDN博客专家 、CSDN内容合伙人、掘金特邀作者、阿里云博客专家、51CTO特邀作者、多年架构师设计经验、多年校企合作经验,被多个学校常年聘为校外企业导师,指导学生毕业设计并参与学生毕业答辩指导,有较为丰富的相关经验。期待与各位高校教师、企业讲师以及同行交流合作
主要内容:Java项目、Python项目、前端项目、PHP、ASP.NET、人工智能与大数据、单片机开发、物联网设计与开发设计、简历模板、学习资料、面试题库、技术互助、就业指导等
业务范围:免费功能设计、开题报告、任务书、中期检查PPT、系统功能实现、代码编写、论文编写和辅导、论文降重、长期答辩答疑辅导、腾讯会议一对一专业讲解辅导答辩、模拟答辩演练、和理解代码逻辑思路等。
收藏点赞不迷路 关注作者有好处
文末获取源码
语言环境:Python3.8
数据库:Mysql: mysql5.7
WEB框架:Django
开发工具:IDEA或PyCharm
项目获取地址:基于Python实现校园影院
随着社会的不断进步与发展,人们对生活质量要求逐步提升。如果开发一款柚子校园影院,可以让管理员和用户在最短的时间里享受到最好的服务;而开发本系统,又能够提高系统整体工作水平,简化工作程序,这对管理员和用户来说都是一件非常乐意的事情。
本论文针对柚子校园影院的特点,以Python为核心,以MySQL为数据库,B/S为系统构架,对柚子校园影院进行设计和开发。通过使用本系统可有效地减少运营成本,提高管理效率。
20世纪,随着科学技术的飞速发展,数字化和信息化成为了一个新的发展趋势,信息化的管理方式成为了各个行业的追求的目标,而信息化的管理方式更是成为了人们追求的目标。目前,我国高等院校工程技术和电子管理学已经将信息化技术作为必修课。
在当今社会,人们的生活节奏逐渐加快,人们对经济的要求逐渐降低,越来越多的人开始追求简单、快捷的方式。随着经济的发展,人民的生活水平也提高了,用户有了更多的时间去消费。然而,柚子校园影院管理模式的改进却是一项比较繁杂的工作,因此,管理人员要充分发挥信息化管理的作用,提高柚子校园影院的整体管理能力和整体素质。
在科技飞速发展的今天,柚子校园影院管理体系已全面更新,管理体系的更新,不但能让用户享受到更为高品质的服务,同时也能提升柚子校园影院管理的工作效率。通过管理上的便利,使管理上也更加有序。然而,当前大多仍采用大规模的人工管理方式,这种管理方式耗费了较多的人力物力,而且很难维持。而本系统要采用一种易于使用、处理速度快、计算准确且适应的服务需求的经营模式。这种新型的经营管理体系将有助于今后的发展,改进当前的经营状况,提升用户的工作效率,同时为柚子校园影院创造更高的效率。
功能模块设计
前端页面
后台管理员
- #coding:utf-8
- __author__ = "ila"
- import base64, copy, logging, os, sys, time, xlrd, json, datetime, configparser
- from django.http import JsonResponse
- from django.apps import apps
- from django.db.models.aggregates import Count,Sum
- from .models import dianyinggoupiao
- from util.codes import *
- from util.auth import Auth
- from util.common import Common
- import util.message as mes
- from django.db import connection
- import random
- from django.core.mail import send_mail
- from django.conf import settings
- from django.shortcuts import redirect
- from django.db.models import Q
- from util.baidubce_api import BaiDuBce
- from .config_model import config
-
-
-
-
-
-
-
- def dianyinggoupiao_register(request):
- if request.method in ["POST", "GET"]:
- msg = {'code': normal_code, "msg": mes.normal_code}
- req_dict = request.session.get("req_dict")
-
-
- error = dianyinggoupiao.createbyreq(dianyinggoupiao, dianyinggoupiao, req_dict)
- if error != None:
- msg['code'] = crud_error_code
- msg['msg'] = "用户已存在,请勿重复注册!"
- return JsonResponse(msg)
-
- def dianyinggoupiao_login(request):
- if request.method in ["POST", "GET"]:
- msg = {'code': normal_code, "msg": mes.normal_code}
- req_dict = request.session.get("req_dict")
-
- datas = dianyinggoupiao.getbyparams(dianyinggoupiao, dianyinggoupiao, req_dict)
- if not datas:
- msg['code'] = password_error_code
- msg['msg'] = mes.password_error_code
- return JsonResponse(msg)
- try:
- __sfsh__= dianyinggoupiao.__sfsh__
- except:
- __sfsh__=None
-
- if __sfsh__=='是':
- if datas[0].get('sfsh')!='是':
- msg['code']=other_code
- msg['msg'] = "账号已锁定,请联系管理员审核!"
- return JsonResponse(msg)
-
- req_dict['id'] = datas[0].get('id')
-
-
- return Auth.authenticate(Auth, dianyinggoupiao, req_dict)
-
-
- def dianyinggoupiao_logout(request):
- if request.method in ["POST", "GET"]:
- msg = {
- "msg": "登出成功",
- "code": 0
- }
-
- return JsonResponse(msg)
-
-
- def dianyinggoupiao_resetPass(request):
- '''
- '''
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": mes.normal_code}
-
- req_dict = request.session.get("req_dict")
-
- columns= dianyinggoupiao.getallcolumn( dianyinggoupiao, dianyinggoupiao)
-
- try:
- __loginUserColumn__= dianyinggoupiao.__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=dianyinggoupiao.getbyparams(dianyinggoupiao, dianyinggoupiao, recordsParam)
- if len(records)<1:
- msg['code'] = 400
- msg['msg'] = '用户不存在'
- return JsonResponse(msg)
-
- eval('''dianyinggoupiao.objects.filter({}='{}').update({}='{}')'''.format(username_str,username,password_str,init_pwd))
-
- return JsonResponse(msg)
-
-
-
- def dianyinggoupiao_session(request):
- '''
- '''
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code,"msg": mes.normal_code, "data": {}}
-
- req_dict={"id":request.session.get('params').get("id")}
- msg['data'] = dianyinggoupiao.getbyparams(dianyinggoupiao, dianyinggoupiao, req_dict)[0]
-
- return JsonResponse(msg)
-
-
- def dianyinggoupiao_default(request):
-
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code,"msg": mes.normal_code, "data": {}}
- req_dict = request.session.get("req_dict")
- req_dict.update({"isdefault":"是"})
- data=dianyinggoupiao.getbyparams(dianyinggoupiao, dianyinggoupiao, req_dict)
- if len(data)>0:
- msg['data'] = data[0]
- else:
- msg['data'] = {}
- return JsonResponse(msg)
-
- def dianyinggoupiao_page(request):
- '''
- '''
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": mes.normal_code, "data":{"currPage":1,"totalPage":1,"total":1,"pageSize":10,"list":[]}}
- req_dict = request.session.get("req_dict")
-
- #获取全部列名
- columns= dianyinggoupiao.getallcolumn( dianyinggoupiao, dianyinggoupiao)
-
- #当前登录用户所在表
- tablename = request.session.get("tablename")
-
-
- #authColumn=list(__authTables__.keys())[0]
- #authTable=__authTables__.get(authColumn)
-
- # if authTable==tablename:
- #params = request.session.get("params")
- #req_dict[authColumn]=params.get(authColumn)
-
- '''__authSeparate__此属性为真,params添加userid,后台只查询个人数据'''
- try:
- __authSeparate__=dianyinggoupiao.__authSeparate__
- except:
- __authSeparate__=None
-
- if __authSeparate__=="是":
- tablename=request.session.get("tablename")
- if tablename!="users" and 'userid' in columns:
- try:
- req_dict['userid']=request.session.get("params").get("id")
- except:
- pass
-
- #当项目属性hasMessage为”是”,生成系统自动生成留言板的表messages,同时该表的表属性hasMessage也被设置为”是”,字段包括userid(用户id),username(用户名),content(留言内容),reply(回复)
- #接口page需要区分权限,普通用户查看自己的留言和回复记录,管理员查看所有的留言和回复记录
- try:
- __hasMessage__=dianyinggoupiao.__hasMessage__
- except:
- __hasMessage__=None
- if __hasMessage__=="是":
- tablename=request.session.get("tablename")
- if tablename!="users":
- req_dict["userid"]=request.session.get("params").get("id")
-
-
-
- # 判断当前表的表属性isAdmin,为真则是管理员表
- # 当表属性isAdmin=”是”,刷出来的用户表也是管理员,即page和list可以查看所有人的考试记录(同时应用于其他表)
- __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__ == "是" and 'dianyinggoupiao' != 'forum':
- if req_dict.get("userid") and 'dianyinggoupiao' != 'chat':
- del req_dict["userid"]
-
- else:
- #非管理员权限的表,判断当前表字段名是否有userid
- if tablename!="users" and 'dianyinggoupiao'[:7]!='discuss'and "userid" in dianyinggoupiao.getallcolumn(dianyinggoupiao,dianyinggoupiao):
- req_dict["userid"] = request.session.get("params").get("id")
-
- #当列属性authTable有值(某个用户表)[该列的列名必须和该用户表的登陆字段名一致],则对应的表有个隐藏属性authTable为”是”,那么该用户查看该表信息时,只能查看自己的
- try:
- __authTables__=dianyinggoupiao.__authTables__
- except:
- __authTables__=None
-
- if __authTables__!=None and __authTables__!={}:
- try:
- del req_dict['userid']
- # tablename=request.session.get("tablename")
- # if tablename=="users":
- # del req_dict['userid']
-
- except:
- pass
- for authColumn,authTable in __authTables__.items():
- if authTable==tablename:
- params = request.session.get("params")
- req_dict[authColumn]=params.get(authColumn)
- username=params.get(authColumn)
- break
-
- q = Q()
-
- msg['data']['list'], msg['data']['currPage'], msg['data']['totalPage'], msg['data']['total'], \
- msg['data']['pageSize'] =dianyinggoupiao.page(dianyinggoupiao, dianyinggoupiao, req_dict, request, q)
-
- return JsonResponse(msg)
-
- def dianyinggoupiao_autoSort(request):
- '''
- .智能推荐功能(表属性:[intelRecom(是/否)],新增clicktime[前端不显示该字段]字段(调用info/detail接口的时候更新),按clicktime排序查询)
- 主要信息列表(如商品列表,新闻列表)中使用,显示最近点击的或最新添加的5条记录就行
- '''
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": mes.normal_code, "data":{"currPage":1,"totalPage":1,"total":1,"pageSize":10,"list":[]}}
- req_dict = request.session.get("req_dict")
- if "clicknum" in dianyinggoupiao.getallcolumn(dianyinggoupiao,dianyinggoupiao):
- req_dict['sort']='clicknum'
- elif "browseduration" in dianyinggoupiao.getallcolumn(dianyinggoupiao,dianyinggoupiao):
- 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'] = dianyinggoupiao.page(dianyinggoupiao,dianyinggoupiao, req_dict)
-
- return JsonResponse(msg)
-
-
- def dianyinggoupiao_list(request):
- '''
- 前台分页
- '''
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": mes.normal_code, "data":{"currPage":1,"totalPage":1,"total":1,"pageSize":10,"list":[]}}
- req_dict = request.session.get("req_dict")
- if req_dict.__contains__('vipread'):
- del req_dict['vipread']
-
- #获取全部列名
- columns= dianyinggoupiao.getallcolumn( dianyinggoupiao, dianyinggoupiao)
- #表属性[foreEndList]前台list:和后台默认的list列表页相似,只是摆在前台,否:指没有此页,是:表示有此页(不需要登陆即可查看),前要登:表示有此页且需要登陆后才能查看
- try:
- __foreEndList__=dianyinggoupiao.__foreEndList__
- except:
- __foreEndList__=None
-
- if __foreEndList__=="前要登":
- tablename=request.session.get("tablename")
- if tablename!="users" and 'userid' in columns:
- try:
- req_dict['userid']=request.session.get("params").get("id")
- except:
- pass
- #forrEndListAuth
- try:
- __foreEndListAuth__=dianyinggoupiao.__foreEndListAuth__
- except:
- __foreEndListAuth__=None
-
-
- #authSeparate
- try:
- __authSeparate__=dianyinggoupiao.__authSeparate__
- except:
- __authSeparate__=None
-
- if __foreEndListAuth__ =="是" and __authSeparate__=="是":
- tablename=request.session.get("tablename")
- if tablename!="users":
- req_dict['userid']=request.session.get("params",{"id":0}).get("id")
-
- tablename = request.session.get("tablename")
- if tablename == "users" and req_dict.get("userid") != None:#判断是否存在userid列名
- 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__ == "是":
- if req_dict.get("userid"):
- # del req_dict["userid"]
- pass
- else:
- #非管理员权限的表,判断当前表字段名是否有userid
- if "userid" in columns:
- try:
- pass
- except:
- pass
- #当列属性authTable有值(某个用户表)[该列的列名必须和该用户表的登陆字段名一致],则对应的表有个隐藏属性authTable为”是”,那么该用户查看该表信息时,只能查看自己的
- try:
- __authTables__=dianyinggoupiao.__authTables__
- except:
- __authTables__=None
-
- if __authTables__!=None and __authTables__!={} and __foreEndListAuth__=="是":
- try:
- del req_dict['userid']
- except:
- pass
- for authColumn,authTable in __authTables__.items():
- if authTable==tablename:
- params = request.session.get("params")
- req_dict[authColumn]=params.get(authColumn)
- username=params.get(authColumn)
- break
-
- if dianyinggoupiao.__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'] = dianyinggoupiao.page(dianyinggoupiao, dianyinggoupiao, req_dict, request, q)
-
- return JsonResponse(msg)
-
- def dianyinggoupiao_save(request):
- '''
- 后台新增
- '''
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
- req_dict = request.session.get("req_dict")
- if 'clicktime' in req_dict.keys():
- del req_dict['clicktime']
- tablename=request.session.get("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
-
-
- #获取全部列名
- columns= dianyinggoupiao.getallcolumn( dianyinggoupiao, dianyinggoupiao)
- if tablename!='users' and req_dict.get("userid")!=None and 'userid' in columns and __isAdmin__!='是':
- params=request.session.get("params")
- req_dict['userid']=params.get('id')
-
-
- if 'addtime' in req_dict.keys():
- del req_dict['addtime']
-
- error= dianyinggoupiao.createbyreq(dianyinggoupiao,dianyinggoupiao, req_dict)
- if error!=None:
- msg['code'] = crud_error_code
- msg['msg'] = error
-
- return JsonResponse(msg)
-
-
- def dianyinggoupiao_add(request):
- '''
- 前台新增
- '''
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
- req_dict = request.session.get("req_dict")
-
- #获取全部列名
- columns= dianyinggoupiao.getallcolumn( dianyinggoupiao, dianyinggoupiao)
- try:
- __authSeparate__=dianyinggoupiao.__authSeparate__
- except:
- __authSeparate__=None
-
- if __authSeparate__=="是":
- tablename=request.session.get("tablename")
- if tablename!="users" and 'userid' in columns:
- try:
- req_dict['userid']=request.session.get("params").get("id")
- except:
- pass
-
- try:
- __foreEndListAuth__=dianyinggoupiao.__foreEndListAuth__
- except:
- __foreEndListAuth__=None
-
- if __foreEndListAuth__ and __foreEndListAuth__!="否":
- tablename=request.session.get("tablename")
- if tablename!="users":
- req_dict['userid']=request.session.get("params").get("id")
-
-
- if 'addtime' in req_dict.keys():
- del req_dict['addtime']
- error= dianyinggoupiao.createbyreq(dianyinggoupiao,dianyinggoupiao, req_dict)
- if error!=None:
- msg['code'] = crud_error_code
- msg['msg'] = error
- return JsonResponse(msg)
-
- def dianyinggoupiao_thumbsup(request,id_):
- '''
- 点赞:表属性thumbsUp[是/否],刷表新增thumbsupnum赞和crazilynum踩字段,
- '''
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
- req_dict = request.session.get("req_dict")
- id_=int(id_)
- type_=int(req_dict.get("type",0))
- rets=dianyinggoupiao.getbyid(dianyinggoupiao,dianyinggoupiao,id_)
-
- update_dict={
- "id":id_,
- }
- if type_==1:#赞
- update_dict["thumbsupnum"]=int(rets[0].get('thumbsupnum'))+1
- elif type_==2:#踩
- update_dict["crazilynum"]=int(rets[0].get('crazilynum'))+1
- error = dianyinggoupiao.updatebyparams(dianyinggoupiao,dianyinggoupiao, update_dict)
- if error!=None:
- msg['code'] = crud_error_code
- msg['msg'] = error
- return JsonResponse(msg)
-
-
- def dianyinggoupiao_info(request,id_):
- '''
- '''
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
-
- data = dianyinggoupiao.getbyid(dianyinggoupiao,dianyinggoupiao, 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")
- #浏览点击次数
- try:
- __browseClick__= dianyinggoupiao.__browseClick__
- except:
- __browseClick__=None
-
- if __browseClick__=="是" and "clicknum" in dianyinggoupiao.getallcolumn(dianyinggoupiao,dianyinggoupiao):
- try:
- clicknum=int(data[0].get("clicknum",0))+1
- except:
- clicknum=0+1
- click_dict={"id":int(id_),"clicknum":clicknum}
- ret=dianyinggoupiao.updatebyparams(dianyinggoupiao,dianyinggoupiao,click_dict)
- if ret!=None:
- msg['code'] = crud_error_code
- msg['msg'] = ret
- return JsonResponse(msg)
-
- def dianyinggoupiao_detail(request,id_):
- '''
- '''
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
-
- data =dianyinggoupiao.getbyid(dianyinggoupiao,dianyinggoupiao, 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")
-
- #浏览点击次数
- try:
- __browseClick__= dianyinggoupiao.__browseClick__
- except:
- __browseClick__=None
-
- if __browseClick__=="是" and "clicknum" in dianyinggoupiao.getallcolumn(dianyinggoupiao,dianyinggoupiao):
- try:
- clicknum=int(data[0].get("clicknum",0))+1
- except:
- clicknum=0+1
- click_dict={"id":int(id_),"clicknum":clicknum}
-
- ret=dianyinggoupiao.updatebyparams(dianyinggoupiao,dianyinggoupiao,click_dict)
- if ret!=None:
- msg['code'] = crud_error_code
- msg['msg'] = retfo
- return JsonResponse(msg)
-
-
- def dianyinggoupiao_update(request):
- '''
- '''
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
- req_dict = request.session.get("req_dict")
- if req_dict.get("mima") and "mima" not in dianyinggoupiao.getallcolumn(dianyinggoupiao,dianyinggoupiao) :
- del req_dict["mima"]
- if req_dict.get("password") and "password" not in dianyinggoupiao.getallcolumn(dianyinggoupiao,dianyinggoupiao) :
- del req_dict["password"]
- try:
- del req_dict["clicknum"]
- except:
- pass
-
-
- error = dianyinggoupiao.updatebyparams(dianyinggoupiao, dianyinggoupiao, req_dict)
- if error!=None:
- msg['code'] = crud_error_code
- msg['msg'] = error
-
- return JsonResponse(msg)
-
-
- def dianyinggoupiao_delete(request):
- '''
- 批量删除
- '''
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
- req_dict = request.session.get("req_dict")
-
- error=dianyinggoupiao.deletes(dianyinggoupiao,
- dianyinggoupiao,
- req_dict.get("ids")
- )
- if error!=None:
- msg['code'] = crud_error_code
- msg['msg'] = error
- return JsonResponse(msg)
-
-
- def dianyinggoupiao_vote(request,id_):
- '''
- 浏览点击次数(表属性[browseClick:是/否],点击字段(clicknum),调用info/detail接口的时候后端自动+1)、投票功能(表属性[vote:是/否],投票字段(votenum),调用vote接口后端votenum+1)
- 统计商品或新闻的点击次数;提供新闻的投票功能
- '''
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": mes.normal_code}
-
-
- data= dianyinggoupiao.getbyid(dianyinggoupiao, dianyinggoupiao, int(id_))
- for i in data:
- votenum=i.get('votenum')
- if votenum!=None:
- params={"id":int(id_),"votenum":votenum+1}
- error=dianyinggoupiao.updatebyparams(dianyinggoupiao,dianyinggoupiao,params)
- if error!=None:
- msg['code'] = crud_error_code
- msg['msg'] = error
- return JsonResponse(msg)
-
- def dianyinggoupiao_importExcel(request):
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": "成功", "data": {}}
-
- excel_file = request.FILES.get("file", "")
- file_type = excel_file.name.split('.')[1]
-
- if file_type in ['xlsx', 'xls']:
- data = xlrd.open_workbook(filename=None, file_contents=excel_file.read())
- table = data.sheets()[0]
- rows = table.nrows
-
- try:
- for row in range(1, rows):
- row_values = table.row_values(row)
- req_dict = {}
- dianyinggoupiao.createbyreq(dianyinggoupiao, dianyinggoupiao, req_dict)
-
- except:
- pass
-
- else:
- msg = {
- "msg": "文件类型错误",
- "code": 500
- }
-
- return JsonResponse(msg)
-
- def dianyinggoupiao_sendemail(request):
- if request.method in ["POST", "GET"]:
- req_dict = request.session.get("req_dict")
-
- code = random.sample(['0', '1', '2', '3', '4', '5', '6', '7', '8', '9'], 4)
- to = []
- to.append(req_dict['email'])
-
- send_mail('用户注册', '您的注册验证码是【'+''.join(code)+'】,请不要把验证码泄漏给其他人,如非本人请勿操作。', 'yclw9@qq.com', to, fail_silently = False)
-
- cursor = connection.cursor()
- cursor.execute("insert into emailregistercode(email,role,code) values('"+req_dict['email']+"','用户','"+''.join(code)+"')")
-
- msg = {
- "msg": "发送成功",
- "code": 0
- }
-
- return JsonResponse(msg)
-
- # 推荐算法接口
- def dianyinggoupiao_autoSort2(request):
-
- if request.method in ["POST", "GET"]:
- req_dict = request.session.get("req_dict")
- cursor = connection.cursor()
- leixing = set()
- try:
- cursor.execute("select inteltype from storeup where userid = %d"%(request.session.get("params").get("id"))+" and tablename = 'dianyinggoupiao' order by addtime desc")
- rows = cursor.fetchall()
- for row in rows:
- for item in row:
- if item != None:
- leixing.add(item)
- except:
- leixing = set()
-
- L = []
- cursor.execute("select * from dianyinggoupiao where $intelRecomColumn in ('%s"%("','").join(leixing)+"') union all select * from dianyinggoupiao where $intelRecomColumn not in('%s"%("','").join(leixing)+"')")
- desc = cursor.description
- data_dict = [dict(zip([col[0] for col in desc], row)) for row in cursor.fetchall()]
- for online_dict in data_dict:
- for key in online_dict:
- if 'datetime.datetime' in str(type(online_dict[key])):
- online_dict[key] = online_dict[key].strftime(
- "%Y-%m-%d %H:%M:%S")
- else:
- pass
- L.append(online_dict)
-
-
- return JsonResponse({"code": 0, "msg": '', "data":{"currPage":1,"totalPage":1,"total":1,"pageSize":5,"list": L[0:int(req_dict["limit"])]}})
-
- def dianyinggoupiao_value(request, xColumnName, yColumnName, timeStatType):
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": "成功", "data": {}}
-
- where = ' where 1 = 1 '
- token = request.META.get('HTTP_TOKEN')
- decode_str = eval(base64.b64decode(token).decode("utf8"))
- if decode_str['tablename'] == 'yonghu':
- where = where + " and yonghuzhanghao ='{0}' ".format(decode_str['params']['yonghuzhanghao'])
- sql = ''
- if timeStatType == '日':
- sql = "SELECT DATE_FORMAT({0}, '%Y-%m-%d') {0}, sum({1}) total FROM dianyinggoupiao {2} GROUP BY DATE_FORMAT({0}, '%Y-%m-%d') LIMIT 10".format(xColumnName, yColumnName, where, '%Y-%m-%d')
-
- if timeStatType == '月':
- sql = "SELECT DATE_FORMAT({0}, '%Y-%m') {0}, sum({1}) total FROM dianyinggoupiao {2} GROUP BY DATE_FORMAT({0}, '%Y-%m') LIMIT 10".format(xColumnName, yColumnName, where, '%Y-%m')
-
- if timeStatType == '年':
- sql = "SELECT DATE_FORMAT({0}, '%Y') {0}, sum({1}) total FROM dianyinggoupiao {2} GROUP BY DATE_FORMAT({0}, '%Y') LIMIT 10".format(xColumnName, yColumnName, where, '%Y')
-
- L = []
- cursor = connection.cursor()
- cursor.execute(sql)
- desc = cursor.description
- data_dict = [dict(zip([col[0] for col in desc], row)) for row in cursor.fetchall()]
- for online_dict in data_dict:
- for key in online_dict:
- if 'datetime.datetime' in str(type(online_dict[key])):
- online_dict[key] = online_dict[key].strftime(
- "%Y-%m-%d %H:%M:%S")
- else:
- pass
- L.append(online_dict)
- msg['data'] = L
- return JsonResponse(msg)
-
- def dianyinggoupiao_o_value(request, xColumnName, yColumnName):
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": "成功", "data": {}}
-
- where = ' where 1 = 1 '
- token = request.META.get('HTTP_TOKEN')
- decode_str = eval(base64.b64decode(token).decode("utf8"))
- if decode_str['tablename'] == 'yonghu':
- where = where + " and yonghuzhanghao ='{0}' ".format(decode_str['params']['yonghuzhanghao'])
-
- sql = "SELECT {0}, sum({1}) AS total FROM dianyinggoupiao {2} GROUP BY {0} LIMIT 10".format(xColumnName, yColumnName, where)
- L = []
- cursor = connection.cursor()
- cursor.execute(sql)
- desc = cursor.description
- data_dict = [dict(zip([col[0] for col in desc], row)) for row in cursor.fetchall()]
- for online_dict in data_dict:
- for key in online_dict:
- if 'datetime.datetime' in str(type(online_dict[key])):
- online_dict[key] = online_dict[key].strftime(
- "%Y-%m-%d %H:%M:%S")
- else:
- pass
- L.append(online_dict)
- msg['data'] = L
- return JsonResponse(msg)
-
-
-
-
-
-
- def dianyinggoupiao_group(request, columnName):
- if request.method in ["POST", "GET"]:
- msg = {"code": normal_code, "msg": "成功", "data": {}}
-
- where = ' where 1 = 1 '
- token = request.META.get('HTTP_TOKEN')
- decode_str = eval(base64.b64decode(token).decode("utf8"))
- if decode_str['tablename'] == 'yonghu':
- where = where + " and yonghuzhanghao ='{0}' ".format(decode_str['params']['yonghuzhanghao'])
-
- sql = "SELECT COUNT(*) AS total, " + columnName + " FROM dianyinggoupiao " + where + " GROUP BY " + columnName + " LIMIT 10"
-
- L = []
- cursor = connection.cursor()
- cursor.execute(sql)
- desc = cursor.description
- data_dict = [dict(zip([col[0] for col in desc], row)) for row in cursor.fetchall()]
- for online_dict in data_dict:
- for key in online_dict:
- if 'datetime.datetime' in str(type(online_dict[key])):
- online_dict[key] = online_dict[key].strftime("%Y-%m-%d")
- else:
- pass
- L.append(online_dict)
- msg['data'] = L
- return JsonResponse(msg)
-
-
-
-
-
-
-
-
-
基于Java开发、Python开发、PHP开发、C#开发等相关语言开发的实战项目
基于Nodejs、Vue等前端技术开发的前端实战项目
基于微信小程序和安卓APP应用开发的相关作品
基于51单片机等嵌入式物联网开发应用
基于各类算法实现的AI智能应用
基于大数据实现的各类数据管理和推荐系统
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。