物联网课程设计基于Django框架的校园卡管理系统Python源码.zip

import datetime import gzip import json import time import urllib import requests from django.http import HttpResponse, Http404 from django.shortcuts import render # 首页 查询数据库名 import pymysql from dbutils.pooled_db import PooledDB from tool.exportion_history import Insert_exportion_history,Select_exportion_history import aiohttp import asyncio # CONCURRENCY = 5 # semaphore = asyncio.Semaphore(CONCURRENCY) from hbzk_show.settings import DB MYSQL_HOST = DB['MYSQL_HOST'] USER = DB['USER'] PASSWORD = DB['PASSWORD'] DB = DB['DB'] PORT = 3306 pool = PooledDB(pymysql, 10, host=MYSQL_HOST, user=USER, passwd=PASSWORD, db=DB, port=PORT) # 5为连接池里的最少连接数 # 登录 def login(request): if request.method == 'GET': return render(request, 'login.html') if request.method == 'POST': user = request.POST.get('name', '') password = request.POST.get('password', '') db = pool.connection() cursor = db.cursor() try: sql = 'select password,name from user where user = "{}"'.format(user) print(sql) cursor.execute(sql) password1,name= cursor.fetchall()[0] cursor.close() db.close() if password == password1: request.session['name'] = name return HttpResponse('200') else: return HttpResponse('400') except: return HttpResponse('400') # 退出登录 def logout(request): request.session.flush() if not request.session.get('nickname'): return render(request,'login.html') def query(request): if request.method == 'GET': name = request.session.get('name') return render(request, 'select.html',locals()) def get_count(request): name = request.session.get('name') if name: if request.method == 'GET': db = pool.connection() cursor = db.cursor() tablename = request.GET['data'] keyword = request.GET['keyword'] tim = request.GET['time'] period = request.GET['time_period'] discipline = request.GET['discipline'] subdiscipline = request.GET['subdiscipline'] is_ch = request.GET['is_ch'] classify = request.GET['classify'] if discipline: discipline_ = " and discipline in ('" + urllib.parse.unquote_plus(discipline.replace('check_box_discipline=','').replace("&","','")) + "') " else: discipline_ = '' if subdiscipline: subdiscipline_ = " and subdiscipline in ('" + urllib.parse.unquote_plus(subdiscipline.replace('check_box_subdiscipline=','').replace("&","','")) + "') " else: subdiscipline_ = '' if classify: classify_ = " and classify in ('" + urllib.parse.unquote_plus(classify.replace('check_box_classify=','').replace("&","','")) + "') " else: classify_ = '' if period: print("period",period) start = str(period).split("-")[0:3] s_tim = "" for times,i in enumerate(start): s_tim += i.strip() if times == 2 else i.strip()+"-" print("start",s_tim) end = str(period).split("-")[-3:] e_tim = "" for times,j in enumerate(end): e_tim += j.strip() if times == 2 else j.strip()+"-" print("end", e_tim) period_ = 'and create_date >= "{}" and create_date <= "{}"'.format(s_tim,e_tim) else: period_ = '' is_ch_ = ' and is_ch = ' + '"'+ is_ch + '"' if is_ch else '' keyword_ = ' and ( keyword like "%{}%" or article like "%{}%" ) '.format(keyword,keyword) if keyword else '' tim_ = ' and time = '+ '"'+ tim +'"' if tim else '' _sql = 'SELECT count(id) from ' + tablename + ' where 1=1 ' + discipline_ + is_ch_ + classify_ + subdiscipline_ + keyword_ + tim_ + period_ print(_sql) cursor.execute(_sql) # total = len(cursor.fetchall()) total = cursor.fetchall()[0] return HttpResponse(total) # 返回查询数据列表 def data(request): global a,sql,_sql name = request.session.get('name') if name: if request.method == 'GET': tablename = request.GET['data'] keyword = request.GET['keyword'] tim = request.GET['time'] period = request.GET['time_period'] discipline = request.GET['discipline'] subdiscipline = request.GET['subdiscipline'] is_ch = request.GET['is_ch'] classify = request.GET['classify'] print("classify", classify) pagesize = int(request.GET['offset']) - 1 pagenumber = int(request.GET['pagesize']) if discipline: discipline_ = " and discipline in ('" + urllib.parse.unquote_plus(discipline.replace('check_box_discipline=','').replace("&","','")) + "') " else: discipline_ = '' if subdiscipline: subdiscipline_ = " and subdiscipline in ('" + urllib.parse.unquote_plus(subdiscipline.replace('check_box_subdiscipline=','').replace("&","','")) + "') " else: subdiscipline_ = '' if classify: classify_ = " and classify in ('" + urllib.parse.unquote_plus(classify.replace('check_box_classify=','').replace("&","','")) + "') " else: classify_ = '' if period: print("peropd",period) start = str(period).split("-")[0:3] s_tim = "" for times,i in enumerate(start): s_tim += i.strip() if times == 2 else i.strip()+"-" print("start",s_tim) end = str(period).split("-")[-3:] e_tim = "" for times,j in enumerate(end): e_tim += j.strip() if times == 2 else j.strip()+"-" print("end", e_tim) period_ = 'and create_date >= "{}" and create_date <= "{}"'.format(s_tim,e_tim) else: period_ = '' is_ch_ = ' and is_ch = ' + '"'+ is_ch + '"' if is_ch else '' keyword_ = ' and ( keyword like "%{}%" or article like "%{}%" ) '.format(keyword,keyword) if keyword else '' tim_ = ' and time = '+ '"'+ tim +'"' if tim else '' db = pool.connection() cursor = db.cursor() sql_judge = f"SELECT COLUMN_NAME FROM information_schema.COLUMNS WHERE TABLE_SCHEMA = '{DB}' AND TABLE_NAME = '{tablename}'" cursor.execute(sql_judge) data = cursor.fetchall() # print(data) a = ('discipline', 'subdiscipline', 'classify', 'email', 'name', 'article', 'is_ch', 'is_qikan', 'keyword', 'conference', 'time') if "conference" in str(data[-1]) else ('discipline', 'subdiscipline', 'classify', 'email','name','article','is_ch','is_qikan','keyword','','time') sql = 'SELECT discipline,subdiscipline,classify,email,name,article,is_ch,is_qikan,keyword,conference,time from ' + tablename + ' where 1=1 ' + discipline_ + is_ch_ + classify_ + subdiscipline_ + keyword_ + tim_ + period_ +' limit {},{}'.format( pagesize * pagenumber, pagenumber) if "conference" in str(data[-1]) else 'SELECT discipline,subdiscipline,classify,email,name,article,is_ch,is_qikan,keyword,NULL,time from '+tablename +' where 1=1 ' + discipline_ + is_ch_ + classify_ + subdiscipline_ + keyword_ + tim_ + per