基于大数据的客户分析系统.zip

import json import random from datetime import datetime import user_portrait import pandas as pd import numpy as np import matplotlib.pyplot as plt import base64 from io import BytesIO import matplotlib import warnings import re from wordcloud import WordCloud import seaborn as sns from sklearn.cluster import KMeans from sklearn.metrics import silhouette_score from sklearn.preprocessing import StandardScaler, MinMaxScaler # %matplotlib inline plt.rcParams['font.sans-serif'] = 'SimHei' plt.rcParams['axes.unicode_minus'] = False matplotlib.rcParams.update({'font.size' : 16}) plt.style.use('ggplot') warnings.filterwarnings('ignore') from flask import Flask, render_template, request, flash, redirect, session, jsonify import pymysql from sqlalchemy import null app = Flask(__name__) app.secret_key = "123" def conn_db(): ######## 数据库操作 # 1.链接数据库 conn = pymysql.connect( host="127.0.0.1", port=3306, db="customer_analysis", user="root", password="yyqxwhc.", charset="utf8" ) return conn @app.route('/') def home(): # put application's code here return redirect("/page/template/login/login.html") # **************** 登录 **************** @app.route('/page/template/login/login.html') def login(): # put application's code here return render_template("page/template/login/login.html") @app.route('/doLogin', methods=['GET', 'POST']) def doLogin(): # 获取姓名 request.get('key') name = request.form.get("username") pwd = request.form.get("password") print("username:", name, "password:", pwd) # 1.连接数据库 conn = conn_db() # 2.创建游标对象 cursor = conn.cursor() # 3.sql语句 sql = "select * from user where username=%s and password=%s" row = cursor.execute(sql, [name, pwd]) # 4.提交 conn.commit() # 5.关闭 conn.close() if row > 0: session['username'] = name return redirect("/index") else: flash("密码不正确") return redirect("/page/template/login/login.html") # **************** 注册 **************** @app.route('/page/template/login/reg.html') def reg(): return render_template("page/template/login/reg.html") @app.route('/doReg', methods=['GET', 'POST']) def doReg(): # 获取姓名 request.get('key') name = request.form.get("username") pwd = request.form.get("password") email = request.form.get("email") ######## 数据库操作 # 1.链接数据库 conn = conn_db() # 2.创建游标对象 cursor = conn.cursor() # 3.sql语句 sql = "insert into user values(null, %s, %s, %s)" row = cursor.execute(sql, [name, pwd, email]) # 4.提交 conn.commit() # 5.关闭 conn.close() if row > 0: return redirect("/page/template/login/login.html") else: flash("注册失败") return redirect("/page/template/login/reg.html") # **************** 忘记密码 **************** @app.route('/page/template/login/forget.html') def forget(): # put application's code here return render_template("page/template/login/forget.html") @app.route('/doForget', methods=['GET', 'POST']) def doForget(): # 获取姓名 request.get('key') email = request.form.get("email") pwd = request.form.get("password") # 2.创建游标对象 conn = conn_db() cursor = conn.cursor() # 3.sql语句 sql = "update user set password=%s where email=%s " row = cursor.execute(sql, [pwd, email]) # 4.提交 conn.commit() # 5.关闭 conn.close() if row > 0: return redirect("/page/template/login/login.html") else: flash("更改失败") return redirect("/page/template/login/forget.html") # **************** 首页 **************** @app.route('/index') def index(): return render_template('index.html') # **************** 首页-顶部栏 **************** @app.route('/page/tpl/tpl-message.html') def tpl_message(): return render_template('page/tpl/tpl-message.html') @app.route('/page/tpl/tpl-lock-screen.html') def tpl_lock_screen(): return render_template('page/tpl/tpl-lock-screen.html') @app.route('/page/tpl/tpl-note.html') def tpl_note(): return render_template('page/tpl/tpl-note.html') @app.route('/page/tpl/tpl-password.html') def tpl_password(): return render_template('page/tpl/tpl-password.html') # 修改密码 @app.route('/page/tpl/tpl-password/change', methods=['GET', 'POST']) def tpl_password_change(): username = session.get('username') oldPsw = request.form.get('oldPsw') newPsw = request.form.get('newPsw') # 2.创建游标对象 conn = conn_db() cursor = conn.cursor() # 3.sql语句 sql = "update user set password=%s where username=%s and password=%s" row = cursor.execute(sql, [newPsw, username, oldPsw]) # 4.提交 conn.commit() # 5.关闭 conn.close() if row == 0: flash("更改失败") return redirect("/index") @app.route('/page/tpl/tpl-theme.html') def tpl_theme(): return render_template('page/tpl/tpl-theme.html') # **************** 首页-侧边栏-DashBoard **************** # 工作台 @app.route("/page/console/workplace.html") def workPlace(): return render_template("page/console/workplace.html") # 控制台 @app.route("/page/console/console.html") def console(): return render_template("page/console/console.html") # 分析页 @app.route("/page/console/dashboard.html") def dashBoard(): return render_template("page/console/dashboard.html") # ****************首页-侧边栏-客户管理 **************** # 客户管理 @app.route("/page/customer/customer.html") def customerIndex(): return render_template("page/customer/customer.html") def getCustomerJson(result): # 数据库中的role数据转为json格式用于前端Table输出 customer_vip = {} customer_vip['code'] = 0 customer_vip['msg'] = '' data = [] count = 0 for r in result: count = count + 1 dict = {} dict["memberId"] = r[0] dict["bitrhday"] = r[1] dict["sex"] = r[2] dict["registerTime"] = r[3] data.append(dict) customer_vip['count'] = count customer_vip['data'] = data # print(user) return jsonify(customer_vip) @app.route("/page/customer/customer/jsonData", methods=['GET', 'POST']) def customerJsonData(): # 展示以及查找数据库中的user数据 memberId = request.args.get("memberId") sex = request.args.get("sex") bitrhday = request.args.get("bitrhday") # 2.创建游标对象 conn = conn_db() cursor = conn.cursor() if memberId: if sex: if bitrhday: sql = "select * from vip_info1 where memberId=%s and sex=%s and bitrhday=%s " row = cursor.execute(sql, [memberId, sex, bitrhday]) else: sql = "select * from vip_info1 where memberId=%s and sex=%s " row = cursor.execute(sql, [memberId, sex]) else: if bitrhday: sql = "select * from vip_info1 where memberId=%s and bitrhday=%s " row = cursor.execute(sql, [memberId, bitrhday]) else: sql = "select * from vip_info1 where memberId=%s " row = cursor.execute(sql, [memberId]) else: if sex: if bitrhday: sql = "select * from vip_info1 where sex=%s and bitrhday=%s " row = cursor.execute(sql, [sex, bitrhday]) else: sql = "select * from vip_info1 where sex=%s " row = cursor.execute(sql, [sex]) else: if bitrhday: sql = "select * from vip_info1 where bitrhday=%s " row = cursor.execute(sql, [bitrhday]) else: sql = "select * from vip_info1 " row = cursor.execute(sql) result = cursor.fetchall()