学员管理系统

环境：windows或者Linux，python3.6，mysql5.7
要求：
    用户角色，讲师＼学员， 用户登陆后根据角色不同，能做的事情不同，分别如下
    讲师视图
    　　管理班级，可创建班级，根据学员qq号把学员加入班级
    　　可创建指定班级的上课纪录，注意一节上课纪录对应多条学员的上课纪录， 即每节课都有整班学员上， 为了纪录每位学员的学习成绩，需在创建每节上课纪录是，同时         为这个班的每位学员创建一条上课纪录
    　　为学员批改成绩， 一条一条的手动修改成绩
    学员视图
    提交作业
    查看作业成绩
    一个学员可以同时属于多个班级，就像报了Linux的同时也可以报名Python一样， 所以提交作业时需先选择班级，再选择具体上课的节数
    附加：学员可以查看自己的班级成绩排名

项目结构：
rpc_client   ---|
                bin ---|
                        start.py     ......启动
                conf---|
                        config.py       ......配置参数
                        system.ini      ......配置文件
                core---|
                        entrance.py     ......登录认证的方法
                        main.py         ......学生视图，导师视图
                db  ---|
                        mysqldb.py       ......连接执行mysql

数据库结构：
student：
id , name姓名 , password密码 , qq

teacher:
id , name , password , qq

class:
id , class_name 班级名称

class_record:
id , class_id , course_num 班级课程节数  # class_id与表class中的id字段做外键关联

score：
id , class_record_id(class_record表中的id) , student_id(student表中的id) , socre(成绩) , sign(作业提交标志，0为未提交，1为提交)
# class_record_id与表class_record中的id字段做外键关联，student_id与表student中的id字段做外键关联

class_union_student (学生与班级多对多关联表)
id , class_id , student_id
# student_id与表student中的id字段做外键关联，class_id与表class中的id字段做外键关联

用法：
启动start.py
为方便测试，自动注册两个学员和一个老师，学员1账号,密码，qq号为 zh,123,123456,学员2为zs,123,654321，老师账号密码:alex,123
qq号作为加入班级是需要输入的
老师视图：
"创建班级"：输入班级名称创建班级（在class中添加记录）
"加入班级"：输入学员qq号加入班级（可添加多个，用,隔开）（在class_union_student中添加记录）
"创建上课记录"：创建上课记录，同时给学员创建学习记录（class_record 中添加一条记录，score中添加一条记录）
"批改成绩"：需要在学员提交了作业后才可批改成绩（在score中修改score成绩记录）

学生视图：
"提交作业"：在创建了上课记录后学员即可提交作业（在score中修改sign标志）
"查看成绩"：在老师批改成绩后学员可查看成绩
"查看班级排名"：在老师批改成绩后学员可查看班级排名

输入b返回上一级

bin:

#!/usr/bin/env python
# -*-coding:utf-8-*-
# Author:zh
import os
import sys
PATH = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
sys.path.append(PATH)
from core import entrance
from db import mysqldb

mysqldb.create_table()
mysqldb.test()  # 辅助注册用户，方便测试
entrance.run()

conf:

#!/usr/bin/env python
# -*-coding:utf-8-*-
# _author_=zh
import os
import configparser
PATH = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))


class Configuration(object):
    def __init__(self):
        self.config = configparser.ConfigParser()
        self.name = PATH+os.sep+"conf"+os.sep+"system.ini"

    def init_config(self):
        # 初始化配置文件，ip ：客户端IP，port：客户端端口
        if not os.path.exists(self.name):
            self.config["config"] = {"host": '192.168.200.128', "port": 3306, "user": 'root',
                                     "passwd": '123456', "db": 'mysql', "charset": 'utf8'}
            self.config.write(open(self.name, "w", encoding="utf-8", ))

    def get_config(self, head="config"):
        '''
        获取配置文件数据
        :param head: 配置文件的section，默认取初始化文件config的数据
        :return:返回head中的所有数据(列表)
        '''
        self.init_config() # 取文件数据之前生成配置文件
        self.config.read(self.name, encoding="utf-8")
        if self.config.has_section(head):
            section = self.config.sections()
            return self.config.items(section[0])

core:

#!/usr/bin/env python
# -*-coding:utf-8-*-
# Author:zh
import os
import sys
import hashlib
PATH = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
sys.path.append(PATH)
from db import mysqldb
from conf import config
from .import main


class Entrance(object):
    # 这个类用来提供注册和登陆方法
    def __init__(self, enter):
        self.num = enter
        obj = config.Configuration()
        data = obj.get_config()
        self.sql_obj = mysqldb.SqlServer(data[0][1], data[1][1], data[2][1], data[3][1], data[4][1], data[5][1])

    def __del__(self):
        self.sql_obj.close()

    def load(self):
        # 登陆
        while True:
            user_name = input("name:")
            if user_name == "b":
                break
            pwd = input("password:")
            pwd_hash = hashlib.md5()
            pwd_hash.update(pwd.encode())
            pwd = pwd_hash.hexdigest()
            if self.num == "1":
                table_name = "student"
            elif self.num == "2":
                table_name = "teacher"
            sql_data = "select password from %s where name = '%s';" % (table_name, user_name)
            try:
                self.sql_obj.run(sql_data)
                answer = self.sql_obj.get()
                if answer == ():
                    print("没有此用户，请重新登陆")
                else:
                    if pwd == answer[0][0]:
                        return user_name
                        print("welcome")
                        break
                    else:
                        print("密码错误！")
            except Exception as e1:
                print("输入错误,错误：%s" % e1)

    def register(self):
        # 注册
        while True:
            user_name = input("name:")
            if user_name == "b":
                break
            pwd = input("password:")
            pwd_hash = hashlib.md5()
            pwd_hash.update(pwd.encode())
            pwd = pwd_hash.hexdigest()
            qq = input("qq:")
            try:
                qq = int(qq)
            except ValueError:
                print("qq号格式不正确")
                continue
            if self.num == "1":
                table_name = "student"
            elif self.num == "2":
                table_name = "teacher"
            sql_data = "insert into %s (name,password,qq) values('%s','%s',%s);" % (table_name, user_name, pwd, qq)
            try:
                self.sql_obj.run(sql_data)
                self.sql_obj.commit()
                print("welcome")
                return user_name
            except Exception as e1:
                print("执行失败,错误：%s" % e1)


def show(n):
    # 这个方法用来展示数据
    for count, i in enumerate(n):
        print("%s: %s" % (count+1, i))


def run():
    while True:
        info = ["学生", "老师"]
        show(info)
        choose = input("请选择入口：")
        if choose == 'b':
            break
        if choose is "":
            continue
        if int(choose) in (1, len(info)):
            start_obj = Entrance(choose)
            while True:
                info = ["注册", "登陆"]
                show(info)
                num = input("请选择入口：")
                if num is "":
                    continue
                elif num == "1":
                    name = start_obj.register()
                    break
                elif num == "2":
                    name = start_obj.load()
                    break
                else:
                    print("输入错误！")
                    continue
            if choose == "2":
                info = ["创建班级", "加入班级", "创建上课记录", "批改成绩"]
                obj = main.TeacherView()
                data = {1: "create_class",
                        2: "join_class",
                        3: "class_record",
                        4: "alter_score"}
            elif choose == "1":
                info = ["提交作业", "查看成绩", "查看班级排名"]
                obj = main.StudentView(name)
                data = {1: "submit",
                        2: "view",
                        3: "rank"}
            while True:
                show(info)
                choose = input("选择操作:")
                if choose == 'b':
                    break
                if choose is "":
                    continue
                try:
                    choose = int(choose)
                except ValueError as e:
                    print("请输入数字！错误：%s" % e)
                    continue
                if hasattr(obj, data[choose]):
                    func = getattr(obj, data[choose])
                    func()
                else:
                    print("类中无此方法，请查看！")
        else:
            print("输入错误！")

#!/usr/bin/env python
# -*-coding:utf-8-*-
# Author:zh
import pymysql
from db import mysqldb
from conf import config


class TeacherView(object):
    # 这个类用来处理讲师视图
    def __init__(self):
        obj = config.Configuration()
        data = obj.get_config()
        self.sql_obj = mysqldb.SqlServer(data[0][1], data[1][1], data[2][1], data[3][1], data[4][1], data[5][1])

    def __del__(self):
        self.sql_obj.close()

    def create_class(self):
        # 这个方法用来创建班级
        while True:
            class_name = input("请输入班级名:")
            if class_name == "b":
                break
            sql_data = "insert into class (class_name) values('%s');" % class_name
            try:
                self.sql_obj.run(sql_data)
                self.sql_obj.commit()
                print("创建成功")
                break
            except pymysql.err.IntegrityError as e1:
                print("班级名已存在,错误：%s" % e1)
            except Exception as e1:
                print("错误：%s" % e1)

    def join_class(self):
        # 这个方法用来加入班级
        sign = True
        while sign:
            qq = input("请输入qq号(多个用,隔开):")
            if qq == "b":
                break
            sql_data = "select id from student where qq in (%s)" % qq  # 查看所有qq号
            self.sql_obj.run(sql_data)
            id_tuple = self.sql_obj.get()
            if id_tuple == ():
                print("无使用该qq的学员")
                continue
            class_name = show_class(self.sql_obj)
            if class_name is not None:
                count = 0
                for id in id_tuple:
                    sql_data = "insert into class_union_student(class_id,student_id) select (select id" 
                               " from class where class_name='%s') as class_id,%s from dual;" % (class_name, id[0])
                    try:
                        self.sql_obj.run(sql_data)
                        self.sql_obj.commit()
                        count += 1
                    except Exception as e1:
                        print("插入失败，错误内容：%s" % e1)
                print("成功%s个" % count)
                sign = False

    def class_record(self):
        # 这个方法用来创建上课记录
        class_name = show_class(self.sql_obj)
        if class_name is not None:
            sign = True
            while sign:
                class_num = input("请输入上课节数：")
                if class_num == "b":
                    break
                # 插入上课记录
                sql_class_record = "insert into class_record(class_id,course_num) " 
                                   "select id,%s from class where class_name = '%s'" % (class_num, class_name)
                try:
                    self.sql_obj.run(sql_class_record)
                except Exception as e1:
                    print("插入上课记录失败，错误:%s" % e1)
                sql_score = "select student_id from class_union_student" 
                            " where class_id =(select id from class where class_name = '%s')" % class_name
                self.sql_obj.run(sql_score)
                student_tuple = self.sql_obj.get()
                for student_id in student_tuple:
                    # 给所有班级的学生添加上课记录
                    sql_score = "insert into score(class_record_id,student_id) " 
                                "select(select id from class_record where class_id = " 
                                "(select id from class where class_name = '%s') and course_num = %s ) " 
                                "as class_record_id,%s from dual;" % (class_name, class_num, student_id[0])
                    try:
                        self.sql_obj.run(sql_score)
                    except Exception as e1:
                        print("上课记录插入失败，学生ID为%s,错误内容%s" % (student_id[0], e1))
                self.sql_obj.commit()
                sign = False

    def alter_score(self):
        # 这个方法用来修改学员成绩
        class_name = show_class(self.sql_obj)
        if class_name is not None:
            sql_student = "select name from student where id in " 
                          "(select student_id from class_union_student where class_id = " 
                          "(select id from class where class_name = '%s') " 
                          "union select student_id from score where sign = '1' )" % class_name
            self.sql_obj.run(sql_student)
            student_tuple = self.sql_obj.get()
            sign = True
            while sign:
                for count, i in enumerate(student_tuple):
                    print("%s: %s" % (count + 1, i[0]))
                num_student = input("请选择需要修改成绩的学生:")
                if num_student == "b":
                    break
                if num_student is "":
                    continue
                if int(num_student) in (1, len(student_tuple)):
                    student_name = student_tuple[int(num_student)-1][0]
                    sql_score = "select '%s',b.course_num,a.score,a.id from score a " 
                                "join class_record b on a.class_record_id = b.id where a.sign = '1' and a.student_id=(" 
                                "select id from student where name = '%s')" % (class_name, student_name)
                    self.sql_obj.run(sql_score)
                    student_score = self.sql_obj.get()
                    if student_score is ():
                        print("没有需要批改的作业")
                        continue
                    else:
                        count = 0
                        for i in student_score:
                            count += 1
                            print("%s: 班级:%s,节数:%s,成绩:%s" % (count, i[0], i[1], i[2]))
                    while sign:
                        enter = input("请选择需要修改的成绩：")
                        if enter == "b":
                            break
                        try:
                            enter = int(enter)
                        except ValueError as e1:
                            print("输入错误:%s" % e1)
                            continue
                        if enter is "":
                            continue
                        if enter in range(1, len(student_score) + 1):
                            score_id = student_score[enter-1][3]
                            while sign:
                                change_score = input("请输入修改的成绩:")
                                if change_score == "b":
                                    break
                                try:
                                    change_score = int(change_score)
                                except ValueError as e1:
                                    print("error:%s,请输入数字" % e1)
                                    continue
                                sql_change = "update score set score = %s where id = %s" % (change_score, score_id)
                                try:
                                    self.sql_obj.run(sql_change)
                                    self.sql_obj.commit()
                                    print("修改成功")
                                except Exception as e1:
                                    print("更新失败，name为：%s,class为:%s,错误内容：%s" % (student_name, class_name, e1))
                                sign = False
                        else:
                            print("输入错误")
                else:
                    print("输入错误")


class StudentView(object):
    # 这个类用来处理学生视图
    def __init__(self, user_name):
        # user_name：传入登陆人姓名
        self.name = user_name
        obj = config.Configuration()
        data = obj.get_config()
        self.sql_obj = mysqldb.SqlServer(data[0][1], data[1][1], data[2][1], data[3][1], data[4][1], data[5][1])

    def __del__(self):
        self.sql_obj.close()

    def submit(self):
        # 这个方法用来提交作业
        class_name = show_class(self.sql_obj)
        if class_name is not None:
            sql_num = "select id,'%s',course_num from class_record where class_id = " 
                      "(select id from class where class_name = '%s')" % (class_name, class_name)
            self.sql_obj.run(sql_num)
            course_num_tuple = self.sql_obj.get()
            if course_num_tuple is ():
                print("未建立上课记录")
            else:
                count = 0
                for course_num in course_num_tuple:
                    count += 1
                    print("%s: 班级:%s,节数:%s" % (count, class_name, course_num[2]))
                sign = True
                while sign:
                    class_num = input("请选择上课节数:")
                    if class_num is "":
                        continue
                    try:
                        class_num = int(class_num)
                    except ValueError as e1:
                        print("error:%s,请输入数字" % e1)
                        continue
                    if class_num in range(1, len(course_num_tuple) + 1):
                        sql_score = "update score set sign = '1' where class_record_id = %s and student_id =" 
                                    "(select id from student where name = '%s')" 
                                    % (course_num_tuple[class_num-1][0], self.name)
                        try:
                            self.sql_obj.run(sql_score)
                            self.sql_obj.commit()
                            print("提交成功！")
                        except Exception as e1:
                            print("更新失败，name为：%s,class为：%s,上课节数为:%s,错误内容：%s" % (self.name, class_name, class_num, e1))
                        sign = False

    def view(self):
        # 这个方法用来查看成绩
        class_name = show_class(self.sql_obj)
        if class_name is not None:
            sql_score = "select '%s',a.course_num,b.score,b.sign from class_record a join score b " 
                        "on b.class_record_id = a.id where b.student_id= (select id from student where name = '%s')" 
                        % (class_name, self.name)
            self.sql_obj.run(sql_score)
            score_tuple = self.sql_obj.get()
            for score in score_tuple:
                print("班级:%s,节数:%s,成绩:%s,是否提交:%s" % (score[0], score[1], score[2], score[3]))

    def rank(self):
        # 这个方法用来查看班级排名
        class_name = show_class(self.sql_obj)
        if class_name is not None:
            sql_rank = "select sum(score) a,student_id from score where class_record_id in " 
                       "(select id from class_record where class_id = " 
                       "(select id from class where class_name = '%s')) group by student_id order by a desc" % class_name
            self.sql_obj.run(sql_rank)
            rank_tuple = self.sql_obj.get()
            sql_score = "select sum(score) from score where student_id = " 
                        "(select id from student where name = '%s') and class_record_id  in" 
                        "(select id from class_record where class_id = " 
                        "(select id from class where class_name = '%s'))" % (self.name, class_name)
            self.sql_obj.run(sql_score)
            my_score_tuple = self.sql_obj.get()
            if my_score_tuple[0][0] is not None:
                for index, i in enumerate(rank_tuple):
                    if my_score_tuple[0][0] == i[0]:
                        print("第%s名" % str(index+1))
            else:
                print("没有成绩")


def show_class(class_obj):
    # 这个方法用来格式化显示班级
    # class_obj:数据库连接
    sql_data = "select class_name from class;"
    class_obj.run(sql_data)
    answer = class_obj.get()
    if answer == ():
        print("请先建立班级")
        class_name = None
    else:
        for count, i in enumerate(answer):
            print("%s: %s" % (count + 1, i[0]))
        while True:
            enter = input("请选择班级:")
            try:
                enter = int(enter)
            except ValueError as e1:
                print("输入错误:%s" % e1)
                continue
            if enter is "":
                continue
            if enter in range(1, len(answer)+1):
                class_name = answer[enter - 1][0]
                break
            else:
                print("输入错误")
    return class_name

db:

#!/usr/bin/env python
# -*-coding:utf-8-*-
# Author:zh
import pymysql
import os
import sys
PATH = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
sys.path.append(PATH)
from conf import config


class SqlServer(object):
    def __init__(self, host, port, user, passwd, db, charset):
        self.host = host
        self.port = port
        self.user = user
        self.passwd = passwd
        self.db = db
        self.charset = charset
        self.conn = pymysql.connect(host=self.host, port=int(self.port),
                                    user=self.user, passwd=self.passwd, db=self.db, charset=self.charset)
        self.cursor = self.conn.cursor()

    def run(self, sql):
        self.cursor.execute(sql)

    def get(self):
        answer = self.cursor.fetchall()
        return answer

    def commit(self):
        self.conn.commit()

    def close(self):
        self.cursor.close()
        self.conn.close()


table_data = [
    "create table class("
    "id int auto_increment primary key,"
    "class_name varchar(20) not null unique)",

    "create table student(id int auto_increment primary key,"
    "name varchar(20) not NULL unique,"
    "password varchar(32) not NULL,"
    "qq varchar(20) UNIQUE not NULL)",

    "create table teacher(id int auto_increment primary key,"
    "name varchar(20) not NULL unique,"
    "password varchar(32) not NULL,"
    "qq varchar(20) UNIQUE not NULL)",

    "create table class_record("
    "id int auto_increment primary key,"
    "class_id INT not NULL ,"
    "course_num INT not NULL,"
    "UNIQUE key u_class_record (class_id ,course_num),"
    "foreign key f_class_record (class_id) references class(id) on delete cascade on update cascade)",

    "create table score("
    "id int auto_increment primary key,"
    "class_record_id INT not NULL,"
    "student_id INT not NULL,"
    "score INT DEFAULT NULL ,"
    "sign Enum('0','1') DEFAULT '0',"
    "UNIQUE key u_score (class_record_id ,student_id ),"
    "foreign key f_score_1 (class_record_id) references class_record(id) on delete cascade on update cascade,"
    "foreign key f_score_2 (student_id) references student(id) on delete cascade on update cascade)",

    "create table class_union_student("
    "id int auto_increment primary key,"
    "class_id INT not NULL,"
    "student_id INT not NULL,"
    "UNIQUE key u_class_union_student (class_id ,student_id ),"
    "foreign key f1_class_union_student (class_id) references class(id) on delete cascade on update cascade,"
    "foreign key f2_class_union_student (student_id) references student(id) on delete cascade on update cascade)"
    ]


def create_table():
    obj = config.Configuration()
    data = obj.get_config()
    sql_obj = SqlServer(data[0][1], data[1][1], data[2][1], data[3][1], data[4][1], data[5][1])
    sql_conn = "select table_name from information_schema.tables " 
               "where table_schema= '%s' and table_name = 'class_union_student'" % data[4][1]
    sql_obj.run(sql_conn)
    table = sql_obj.get()
    if table == ():
        for j in table_data:
            sql_obj.run(j)
    sql_obj.close()


def test():
    obj = config.Configuration()
    data = obj.get_config()
    sql_obj = SqlServer(data[0][1], data[1][1], data[2][1], data[3][1], data[4][1], data[5][1])
    sql_conn = "select * from student;"
    sql_obj.run(sql_conn)
    answer = sql_obj.get()
    if answer == ():
        sql_list = ["insert into student(name,password,qq) values('zs','202cb962ac59075b964b07152d234b70','123456')",
                    "insert into student(name,password,qq) values('zh','202cb962ac59075b964b07152d234b70','654321')",
                    "insert into teacher(name,password,qq) values('alex','202cb962ac59075b964b07152d234b70','987654')"]
        for i in sql_list:
            sql_obj.run(i)
            sql_obj.commit()
    sql_obj.close()