devbox
你好赵伟
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

数据库 | 基于opengauss的医院患者预约简易系统_医生预约名额需要加到数据库里面吗

作者：你好赵伟 | 2024-06-05 09:43:12

赞

踩

医生预约名额需要加到数据库里面吗

一、概述

        代码使用 python 进行开发，使用 pycharm 作为开发工具，连接到 openGauss 数据库。使用psycopg2库进行数据库的连接，在此基础上进行数据库的一系列操作。

        该系统实现医院预约的简易操作，创建医生、患者、科系、预约、预约备份、一般管理员账号密码信息 共6张表，共有4种登录类型：患者、医生、一般管理员、超级管理员。同时还创建了3个数据库存储过程函数，分别对应增删改3个触发器。通过触发器，系统自动完成对患者操作信息的记录。        

        （1）Data Studio上展示的ER图:

b075ab82eace4b78a2fa2bb6df92ad46.png

         （2）模式结构

9f062d2dfe674425b8aade30cb6d3ec9.png

二、实现功能

        系统可以实现的功能如下:

        (1)患者:进行预约、取消预约、修改预约、查询预约。

        (2)一般管理员:查询医院科室表、查询医生信息表、查询患者预约备份表、添加医院科室表、添加医 生信息表、清除所有预约信息。

        (3)超级管理员:查询一般管理员信息表、添加一般管理员、删除一般管理员、修改一般管理员、清空 患者预约备份表。

        (4)系统使用三个触发器，对患者进行预约，取消预约，修改预约的操作进行记录，把预约的相关信息 以及操作时间记录在预约备份表中。

三、连接数据库

        1.使用 Python 连接数据库

  1. # -*- coding: utf-8 -*-
  2. from multiprocessing import connection
  3. from psycopg2 import connect, OperationalError
  4. import os
  5.  
  6. def CreateConnect():
  7.     try:
  8.         env = os.environ
  9.         params = {
  10.             'database': env.get('OG_DATABASE', 'postgres'),     # 数据库名称
  11.             'user': env.get('OG_USER', 'tom'),                  # 用户姓名
  12.             'password': env.get('OG_PASSWORD', '12345'),        # 用户密码
  13.             'host': env.get('OG_HOST', '192.000.00.000'),       # 主机IP
  14.             'port': env.get('OG_PORT', 26000)                   # 端口号
  15.         }
  16.         conn: connection = connect(**params)
  17.         print('数据库连接成功!')
  18.         return conn
  19.     except OperationalError:
  20.         print('数据库连接失败!')
  21.  
  22. if __name__ == '__main__':
  23.     CreateConnect()

        2.使用 Java 连接数据库

  1. import java.sql.*; 
  2.  
  3. public class GaussDBJDBC {
  4.     public static void main(String[] args) throws ClassNotFoundException, SQLException {
  5.         //配置信息
  6.         //useUnicode=true&characterEncoding=utf-8 解决中文乱码
  7.         String url = "jdbc:postgresql://数据库ip地址:26000/school?useUnicode=true&characterEncoding=utf-8";
  8.         String username = "数据库用户名";
  9.         String password = "数据库密码";
  10.         //1.加载驱动
  11.         Class.forName("com.mysql.cj.jdbc.Driver");
  12.         //2.连接数据库,代表数据库
  13.         Connection connection = DriverManager.getConnection(url, username, password);
  14.         //3.向数据库发送SQL的对象Statement,PreparedStatement : CRUD
  15.         Statement statement = connection.createStatement();
  16.         //4.编写SQL
  17.         String sql = "select * from student";
  18.         //5.执行查询SQL，返回一个 ResultSet  ： 结果集
  19.         ResultSet rs = statement.executeQuery(sql);
  20.         while (rs.next()) {
  21.             //student表
  22.             System.out.print("id:" + rs.getObject("std_id"));
  23.             System.out.print(" name:" + rs.getObject("std_name"));
  24.             System.out.print(" sex:" + rs.getObject("std_sex"));
  25.             System.out.print(" birth:" + rs.getObject("std_birth"));
  26.             System.out.print(" in:" + rs.getObject("std_in"));
  27.             System.out.println(" address:" + rs.getObject("std_address"));
  28.         }
  29.         //6.关闭连接，释放资源(一定要做) 先开后关
  30.         rs.close();
  31.         statement.close();
  32.         connection.close();
  33.     }
  34. }

 三、源代码

        1、代码总览 

5eab877ecf774205900ac3d8fa3eccae.png

        2.初始化数据（InitializationCode）

        仅运行一次，创建表以及导入一些初始案例数数据，如医院科室信息、医生信息等。

        （1）Initialize_CreateTable.py

  1. # -*- coding: utf-8 -*-
  2. import os
  3. from multiprocessing import connection
  4. from psycopg2 import connect
  5.  
  6. '''连接数据库'''
  7. def CreateConnect():
  8.     try:
  9.         env = os.environ
  10.         params = {
  11.             'database': env.get('OG_DATABASE', 'postgres'),
  12.             'user': env.get('OG_USER', 'tom'),
  13.             'password': env.get('OG_PASSWORD', 'Huawei_123'),
  14.             'host': env.get('OG_HOST', '192.168.56.130'),
  15.             'port': env.get('OG_PORT', 26000)
  16.         }
  17.         conn: connection = connect(**params)
  18.         return conn
  19.     except:
  20.         print('数据库连接失败!')
  21.  
  22.  
  23. '''创建表'''
  24. # 科系表
  25. def CreateTable_Court(conn):
  26.     cursor = conn.cursor()
  27.     cursor.execute('''create table if not exists Court(
  28.                         c_id   int not null primary key,
  29.                         c_name varchar(500)
  30.                      )''')
  31.     conn.commit()
  32.     conn.close()
  33. # 医生表
  34. def CreateTable_Doctor(conn):
  35.     cursor = conn.cursor()
  36.     cursor.execute('''create table if not exists Doctor(
  37.                         d_id            int primary key,
  38.                         d_name          varchar(32) not null,
  39.                         dp_courtID      int,
  40.                         d_workWeekData  varchar(500),
  41.                         d_workStartTime varchar(500),
  42.                         d_workEndTime   varchar(500),
  43.                         foreign key(dp_courtID) references Court(c_id)  on delete cascade
  44.                      )''')
  45.     conn.commit()
  46.     conn.close()
  47. # 患者表
  48. def CreateTable_Patient(conn):
  49.     cursor = conn.cursor()
  50.     cursor.execute('''create table if not exists Patient(
  51.                         p_id        varchar(32) primary key,
  52.                         p_name      varchar(32) not null
  53.                      )''')
  54.     conn.commit()
  55.     conn.close()
  56. # 预约表
  57. def CreateTable_Appointment(conn):
  58.     cursor = conn.cursor()
  59.     cursor.execute('''create table if not exists Appointment(
  60.                         p_id    varchar(32),
  61.                         p_name  varchar(500),
  62.                         d_id    varchar(32)
  63.                      )''')
  64.     conn.commit()
  65.     conn.close()
  66. # 管理员账号密码表
  67. def CreateTable_Administrator(conn):
  68.     cursor = conn.cursor()
  69.     cursor.execute('''create table if not exists Administrator(
  70.                             a_id    varchar(32),
  71.                             a_name  varchar(500) primary key
  72.                          )''')
  73.     conn.commit()
  74.     conn.close()
  75. # 预约表副本
  76. def CreateTable_AppointmentRecord(conn):
  77.     cursor = conn.cursor()
  78.     cursor.execute('''create table if not exists AppointmentRecord(
  79.                                 p_id            varchar(32),
  80.                                 p_name          varchar(32),
  81.                                 d_id            varchar(32),
  82.                                 date_time       date primary key,
  83.                                 type            varchar(32)
  84.                              )''')
  85.     conn.commit()
  86.     conn.close()
  87.  
  88.  
  89. '''创建触发器函数'''
  90. # 创建INSERT触发器函数
  91. def CreateFunction_insertOnAppointmentRecord(conn):
  92.     cursor = conn.cursor()
  93.     cursor.execute('''CREATE OR REPLACE FUNCTION Record_insert_func ( ) RETURNS TRIGGER AS 
  94.                          $$ 
  95.                          DECLARE 
  96.                              BEGIN 
  97.                                  INSERT INTO AppointmentRecord(p_id,p_name,d_id,date_time,type) 
  98.                                     VALUES (NEW.p_id,NEW.p_name,NEW.d_id,now(),'预约医生'); 
  99.                                  RETURN NEW; 
  100.                              END 
  101.                          $$ 
  102.                          LANGUAGE PLPGSQL''')
  103.     conn.commit()
  104.     conn.close()
  105. # 创建UPDATE触发器函数
  106. def CreateFunction_updateOnAppointmentRecord(conn):
  107.     cursor = conn.cursor()
  108.     cursor.execute('''CREATE OR REPLACE FUNCTION Record_update_func ( ) RETURNS TRIGGER AS 
  109.                          $$ 
  110.                          DECLARE 
  111.                              BEGIN 
  112.                                  INSERT INTO AppointmentRecord(p_id,p_name,d_id,date_time,type) 
  113.                                     VALUES (NEW.p_id,NEW.p_name,NEW.d_id,now(),'修改预约'); 
  114.                                  RETURN NEW; 
  115.                              END 
  116.                          $$ 
  117.                          LANGUAGE PLPGSQL''')
  118.     conn.commit()
  119.     conn.close()
  120. # 创建DELETE触发器函数
  121. def CreateFunction_deleteOnAppointmentRecord(conn):
  122.     cursor = conn.cursor()
  123.     cursor.execute('''CREATE OR REPLACE FUNCTION Record_delete_func ( ) RETURNS TRIGGER AS 
  124.                          $$ 
  125.                          DECLARE 
  126.                              BEGIN 
  127.                                  INSERT INTO AppointmentRecord(p_id,p_name,d_id,date_time,type) 
  128.                                     VALUES (OLD.p_id,OLD.p_name,OLD.d_id,now(),'取消预约'); 
  129.                                  RETURN NEW; 
  130.                              END 
  131.                          $$ 
  132.                          LANGUAGE PLPGSQL''')
  133.     conn.commit()
  134.     conn.close()
  135.  
  136.  
  137. '''创建触发器'''
  138. # 创建INSERT触发器
  139. def CreateTrigger_insertOnAppointment(conn):
  140.     cursor = conn.cursor()
  141.     cursor.execute('''DROP TRIGGER IF EXISTS insert_trigger ON Appointment;
  142.                         CREATE TRIGGER insert_trigger 
  143.                          BEFORE INSERT ON Appointment 
  144.                          FOR EACH ROW 
  145.                          EXECUTE PROCEDURE Record_insert_func()''')
  146.     conn.commit()
  147.     conn.close()
  148. # 创建UPDATE触发器
  149. def CreateTrigger_updateOnAppointment(conn):
  150.     cursor = conn.cursor()
  151.     cursor.execute('''DROP TRIGGER IF EXISTS update_trigger ON Appointment;
  152.                         CREATE TRIGGER update_trigger 
  153.                          AFTER UPDATE ON Appointment 
  154.                          FOR EACH ROW 
  155.                          EXECUTE PROCEDURE Record_update_func()''')
  156.     conn.commit()
  157.     conn.close()
  158. # 创建DELETE触发器
  159. def CreateTrigger_deleteOnAppointment(conn):
  160.     cursor = conn.cursor()
  161.     cursor.execute('''DROP TRIGGER IF EXISTS delete_trigger ON Appointment;
  162.                         CREATE TRIGGER delete_trigger 
  163.                          BEFORE DELETE ON Appointment 
  164.                          FOR EACH ROW 
  165.                          EXECUTE PROCEDURE Record_delete_func()''')
  166.     conn.commit()
  167.     conn.close()
  168.  
  169.  
  170. # 初始化函数
  171. if __name__ == '__main__':
  172.     # 创建表
  173.     CreateTable_Court(CreateConnect())
  174.     CreateTable_Doctor(CreateConnect())
  175.     CreateTable_Patient(CreateConnect())
  176.     CreateTable_Appointment(CreateConnect())
  177.     CreateTable_Administrator(CreateConnect())
  178.     CreateTable_AppointmentRecord(CreateConnect())
  179.  
  180.     # 创建触发器函数
  181.     CreateFunction_insertOnAppointmentRecord(CreateConnect())
  182.     CreateFunction_updateOnAppointmentRecord(CreateConnect())
  183.     CreateFunction_deleteOnAppointmentRecord(CreateConnect())
  184.  
  185.     print('[提示] 表以及触发器创建成功!')

        （2）Initialize_InsertData.py

  1. # -*- coding: utf-8 -*-
  2. import os
  3. from multiprocessing import connection
  4. from psycopg2 import connect
  5.  
  6. '''连接数据库'''
  7. def CreateConnect():
  8.     try:
  9.         env = os.environ
  10.         params = {
  11.             'database': env.get('OG_DATABASE', 'postgres'),
  12.             'user': env.get('OG_USER', 'tom'),
  13.             'password': env.get('OG_PASSWORD', 'Huawei_123'),
  14.             'host': env.get('OG_HOST', '192.168.56.130'),
  15.             'port': env.get('OG_PORT', 26000)
  16.         }
  17.         conn: connection = connect(**params)
  18.         return conn
  19.     except:
  20.         print('数据库连接失败!')
  21.  
  22. '''插入数据'''
  23. # 插入管理员信息
  24. def InsertData_Administrator(conn):
  25.     cursor = conn.cursor()
  26.     cursor.execute('''insert into Administrator(a_id, a_name) values('adm1@1234567', 'adm1')''')
  27.     cursor.execute('''insert into Administrator(a_id, a_name) values('adm2@1234567', 'adm2')''')
  28.     cursor.execute('''insert into Administrator(a_id, a_name) values('adm3@1234567', 'adm3')''')
  29.     cursor.execute('''insert into Administrator(a_id, a_name) values('adm4@1234567', 'adm4')''')
  30.     cursor.execute('''insert into Administrator(a_id, a_name) values('adm5@1234567', 'adm5')''')
  31.     cursor.execute('''insert into Administrator(a_id, a_name) values('adm6@1234567', 'adm6')''')
  32.     conn.commit()
  33.     conn.close()
  34. # 插入科室信息
  35. def InsertData_Court(conn):
  36.     cursor = conn.cursor()
  37.     cursor.execute('''insert into Court(c_id, c_name) values(1, '急诊科')''')
  38.     cursor.execute('''insert into Court(c_id, c_name) values(2, '临床专科科')''')
  39.     cursor.execute('''insert into Court(c_id, c_name) values(3, '眼科')''')
  40.     cursor.execute('''insert into Court(c_id, c_name) values(4, '耳鼻喉科')''')
  41.     cursor.execute('''insert into Court(c_id, c_name) values(5, '皮肤科')''')
  42.     cursor.execute('''insert into Court(c_id, c_name) values(6, '口腔科')''')
  43.     cursor.execute('''insert into Court(c_id, c_name) values(7, '男科')''')
  44.     cursor.execute('''insert into Court(c_id, c_name) values(8, '内科')''')
  45.     cursor.execute('''insert into Court(c_id, c_name) values(9, '外科')''')
  46.     cursor.execute('''insert into Court(c_id, c_name) values(10, '妇产科')''')
  47.     cursor.execute('''insert into Court(c_id, c_name) values(11, '儿科')''')
  48.     cursor.execute('''insert into Court(c_id, c_name) values(12, '放射科')''')
  49.     cursor.execute('''insert into Court(c_id, c_name) values(13, '骨科')''')
  50.     conn.commit()
  51.     conn.close()
  52. # 插入医生信息
  53. def InsertData_Doctor(conn):
  54.     cursor = conn.cursor()
  55.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 1,'张三',1,'星期五','7:30','12:30')''')
  56.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 2,'李四',2,'星期三','8:30','12:30')''')
  57.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 3,'王五',3,'星期四','11:00','19:30')''')
  58.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 4,'孙六',4,'星期五','7:30','11:00')''')
  59.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 5,'单七',5,'星期日','8:00','14:30')''')
  60.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 6,'王平',6,'星期一','7:30','12:20')''')
  61.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 7,'李胜',7,'星期二','9:00','12:00')''')
  62.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 8,'宋江',3,'星期五','11:20','14:15')''')
  63.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 9,'李逵',9,'星期三','3:30','10:30')''')
  64.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 10,'李贵',10,'星期三','7:30','15:30')''')
  65.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 11,'李鬼',11,'星期五','14:30','22:30')''')
  66.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 12,'白璇',1,'星期六','7:30','11:30')''')
  67.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 13,'李白',8,'星期日','5:30','12:30')''')
  68.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 14,'杜甫',4,'星期二','13:30','22:30')''')
  69.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 15,'杨笑',1,'星期四','13:00','20:30')''')
  70.     cursor.execute('''insert into Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime) values( 16,'卢浩',1,'星期三','14:30','23:30')''')
  71.     conn.commit()
  72.     conn.close()
  73.  
  74.  
  75. if __name__ == '__main__':
  76.     InsertData_Administrator(CreateConnect())
  77.     InsertData_Court(CreateConnect())
  78.     InsertData_Doctor(CreateConnect())
  79.  
  80.     print('[提示] 案例数据导入成功!')

 

        3.主要代码（FunctionCode）

        程序主要代码，通过表的增删改查等操作，实现医院预约。

        (1) Connector.py

  1. # -*- coding: utf-8 -*-
  2. import os
  3. from multiprocessing import connection
  4. from psycopg2 import connect,OperationalError
  5.  
  6. '''连接数据库'''
  7. def CreateConnect():
  8.     try:
  9.         env = os.environ
  10.         params = {
  11.             'database': env.get('OG_DATABASE', 'postgres'),
  12.             'user': env.get('OG_USER', 'tom'),
  13.             'password': env.get('OG_PASSWORD', 'Huawei_123'),
  14.             'host': env.get('OG_HOST', '192.168.56.130'),
  15.             'port': env.get('OG_PORT', 26000)
  16.         }
  17.         conn: connection = connect(**params)
  18.         return conn
  19.     except OperationalError:
  20.         print('数据库连接失败!')

        (2) MainFunc.py

  1. # -*- coding: utf-8 -*-
  2. # 患者操作
  3. import Patient_InsertAppointment
  4. import Patient_CancelAppointment
  5. import Patient_AlterAppointment
  6. import Patient_QueryAppointment
  7. # 一般管理员操作
  8. import GeneralAdministrator_Login
  9. import GeneralAdministrator_InsertTable
  10. import GeneralAdministrator_ClearTable
  11. import GeneralAdministrator_QueryTable
  12. # 超级管理员操作
  13. import SuperAdministrator_Login
  14. import SuperAdministrator_OperateOnTable
  15.  
  16.  
  17. # 主菜单
  18. def ChooseOperatorMenu():
  19.     while True:
  20.         print('\n\n======== 操作菜单 ========')
  21.         print('\t\t1 --- 患者')
  22.         print('\t\t2 --- 管理员')
  23.         print('\t\t3 --- 结束')
  24.         print('========================')
  25.         flag = int(input('请输入菜单序号:'))
  26.         if flag == 1:
  27.             Patient_OperateMenu()
  28.             break
  29.         elif flag == 2:
  30.             Administrator_ChooseMenu()
  31.             break
  32.         elif flag == 3:
  33.             break
  34.  
  35.  
  36. # 管理员菜单
  37. def Administrator_ChooseMenu():
  38.     while True:
  39.         print('\n\n======== 操作菜单 ========')
  40.         print('\t\t1 --- 一般管理员')
  41.         print('\t\t2 --- 超级管理员')
  42.         print('\t\t3 --- 结束')
  43.         print('========================')
  44.         flag = int(input('请输入身份序号:'))
  45.         if flag == 1:
  46.             GeneralAdministrator_OperateMenu()
  47.             break
  48.         elif flag == 2:
  49.             SuperAdministrator_OperateMenu()
  50.             break
  51.         elif flag == 3:
  52.             break
  53.  
  54.  
  55. # 超级管理员菜单
  56. def SuperAdministrator_OperateMenu():
  57.     # [唯一账号] SuperAdministrator
  58.     # [唯一密码] SuperAdm_123
  59.     flag = True
  60.     while True:
  61.         a = SuperAdministrator_Login.Login()
  62.         if a == 'again':
  63.             continue
  64.         if a == 'allow':
  65.             print('[提示]登录成功!')
  66.             break
  67.         if a == 'over':
  68.             flag = False
  69.             break
  70.     while flag:
  71.         print('\n\n========= 操作菜单 =========')
  72.         print('\t1 --- 查询 一般管理员信息表')
  73.         print('\t2 --- 添加 一般管理员')
  74.         print('\t3 --- 删除 一般管理员')
  75.         print('\t4 --- 修改 一般管理员')
  76.         print('\t5 --- 清空 患者预约备份表')
  77.         print('\t6 --- 结束')
  78.         print('==========================')
  79.         flag = int(input('请输入操作序号:'))
  80.         if flag == 1:
  81.             SuperAdministrator_OperateOnTable.selectDate_GeneralAdministrator()
  82.         elif flag == 2:
  83.             SuperAdministrator_OperateOnTable.InsertData_GeneralAdministrator()
  84.         elif flag == 3:
  85.             SuperAdministrator_OperateOnTable.DeleteData_GeneralAdministrator()
  86.         elif flag == 4:
  87.             SuperAdministrator_OperateOnTable.UpdateData_GeneralAdministrator()
  88.         elif flag == 5:
  89.             SuperAdministrator_OperateOnTable.ClearData_AppointmentRecord()
  90.         elif flag == 6:
  91.             break
  92.  
  93.  
  94. # 一般管理员菜单
  95. def GeneralAdministrator_OperateMenu():
  96.     # [账号1] adm1
  97.     # [密码1] adm1@1234567
  98.     flag = True
  99.     while True:
  100.         a = GeneralAdministrator_Login.Login()
  101.         if a == 'again':
  102.             continue
  103.         if a == 'allow':
  104.             print('[提示]登录成功!')
  105.             break
  106.         if a == 'over':
  107.             flag = False
  108.             break
  109.     while flag:
  110.         print('\n\n========= 操作菜单 =========')
  111.         print('\t1 --- 查询 医院科室表')
  112.         print('\t2 --- 查询 医生信息表')
  113.         print('\t3 --- 查询 患者预约备份表')
  114.         print('\t4 --- 添加 医院科室表')
  115.         print('\t5 --- 添加 医生信息表')
  116.         print('\t6 --- 清除 所有预约信息')
  117.         print('\t7 --- 结束')
  118.         print('==========================')
  119.         flag = int(input('请输入操作序号:'))
  120.         if flag == 1:
  121.             GeneralAdministrator_QueryTable.ShowCourtMenu()
  122.         elif flag == 2:
  123.             GeneralAdministrator_QueryTable.ShowDoctorMenu()
  124.         elif flag == 3:
  125.             GeneralAdministrator_QueryTable.ShowAppointmentMenu()
  126.         elif flag == 4:
  127.             GeneralAdministrator_InsertTable.InsertCourt()
  128.         elif flag == 5:
  129.             GeneralAdministrator_InsertTable.InsertDoctor()
  130.         elif flag == 6:
  131.             GeneralAdministrator_ClearTable.ClearData()
  132.         elif flag == 7:
  133.             break
  134.  
  135.  
  136. # 患者菜单
  137. def Patient_OperateMenu():
  138.     while True:
  139.         print('\n\n========= 操作菜单 =========')
  140.         print('\t\t1 --- 开始预约')
  141.         print('\t\t2 --- 取消预约')
  142.         print('\t\t3 --- 修改预约')
  143.         print('\t\t4 --- 查询预约')
  144.         print('\t\t5 --- 结束预约')
  145.         print('==========================')
  146.         flag = int(input('请输入操作序号:'))
  147.         if flag == 1:
  148.             Patient_InsertAppointment.MainFunc()
  149.         elif flag == 2:
  150.             Patient_CancelAppointment.MainFunc()
  151.         elif flag == 3:
  152.             Patient_AlterAppointment.MainFunc()
  153.         elif flag == 4:
  154.             Patient_QueryAppointment.MainFunc()
  155.         elif flag == 5:
  156.             break
  157.  
  158.  
  159. if __name__ == '__main__':
  160.     ChooseOperatorMenu()

        (3) Patient_InsertAppointment.py

  1. # -*- coding: utf-8 -*-
  2. import GeneralAdministrator_QueryTable
  3. import Connector
  4.  
  5.  
  6. def MainFunc():
  7.     """
  8.     开始预约
  9.     :return: 预约患者的预约编号
  10.     """
  11.     while True:
  12.         # 展示科系表
  13.         GeneralAdministrator_QueryTable.ShowCourtMenu()
  14.         # 输入患者信息
  15.         p_name = input('请输入您的姓名:')
  16.         p_courtID = int(input('请输入您选择的科室序号:'))
  17.         while p_courtID > 11 or p_courtID < 0:
  18.             p_courtID = int(input('[提示]输入错误!请重新输入科室序号:'))
  19.         # 导入患者信息
  20.         p_id = InsertData_Patient(p_name)
  21.         # 展示医生信息
  22.         DoctorList = Show_AlternativeDoctor(p_courtID)
  23.         # 选择医生
  24.         d_id = int(input('请输入您选择的医生的序号:'))
  25.         while d_id not in DoctorList:
  26.             d_id = int(input('[提示]输入错误!请重新输入您选择的医生的序号:'))
  27.         # 导入预约表
  28.         InsertData_Appointment(p_name, d_id, p_id)
  29.         print('[提示]预约成功,您的预约单号为: ' + str(p_id))
  30.         p_id += 1
  31.         # 判断
  32.         if int(input('继续请输入1，退出请输入0:')) == 0:
  33.             break
  34.  
  35.  
  36. def Show_AlternativeDoctor(p_courtID):
  37.     """
  38.     展示可供预约的医生以及上班时间
  39.     :param p_courtID: 患者预约的科室号
  40.     :return: 展示可供预约医生的列表
  41.     """
  42.     # 数据库查询
  43.     conn = Connector.CreateConnect()
  44.     cursor = conn.cursor()
  45.     cursor.execute('''select d_id,c_name,d_name, d_workWeekData,d_workStartTime,d_workEndTime 
  46.                                 from Doctor,Court 
  47.                                 where Court.c_id = Doctor.dp_courtID 
  48.                                 and Doctor.dp_courtID = %s'''
  49.                    % (str(p_courtID)))
  50.     Doctor_rows = cursor.fetchall()
  51.     conn.commit()
  52.     conn.close()
  53.  
  54.     # 展示可供选择的医生以及上班时间
  55.     DoctorList = []
  56.     print("[提示]您可选择的医生及上班时间如下:")
  57.     print('\t\t------- 医生表 -------')
  58.     for row in Doctor_rows:
  59.         print(row[0], ' 科室:', row[1], ' 姓名:', row[2], ' 时间:', row[3], row[4], '到', row[5])
  60.         DoctorList.append(row[0])
  61.     print('\t\t----------------------')
  62.     return DoctorList
  63.  
  64.  
  65. def InsertData_Patient(p_name):
  66.     """
  67.     导入患者信息
  68.     :param p_name: 患者姓名
  69.     :return:
  70.     """
  71.     sql = '''select MAX(p_id) from Patient'''
  72.     conn = Connector.CreateConnect()
  73.     cursor = conn.cursor()
  74.     cursor.execute(sql)
  75.     ID = cursor.fetchone()
  76.     if ID == (None,):
  77.         p_id = 0
  78.     else:
  79.         p_id = int(''.join(ID)) + 1
  80.  
  81.     sql = "insert into Patient(p_id,p_name) values(%s,%s)"
  82.     cursor.execute(sql, (str(p_id), str(p_name)))
  83.     conn.commit()
  84.     conn.close()
  85.     return p_id
  86.  
  87.  
  88. def InsertData_Appointment(p_name, d_id, p_id):
  89.     """
  90.     导入患者预约信息
  91.     :param p_name: 患者姓名
  92.     :param p_id: 患者ID
  93.     :param d_id: 医生ID
  94.     :return:
  95.     """
  96.     sql = "insert into Appointment(p_id,p_name,d_id) values(%s,%s,%s)"
  97.     conn = Connector.CreateConnect()
  98.     cursor = conn.cursor()
  99.     cursor.execute(sql, (p_id, str(p_name), str(d_id)))
  100.     conn.commit()
  101.     conn.close()

        (4) Patient_AlterAppointment.py

  1. # -*- coding: utf-8 -*-
  2. import Connector
  3. import Patient_InsertAppointment
  4.  
  5.  
  6. def MainFunc():
  7.     """
  8.     修改预约信息
  9.     :return:
  10.     """
  11.     while True:
  12.         p_id = str(input('请输入您的预约单号:'))
  13.         # 查询患者预约的医生
  14.         Judge = Show_ReservedDoctor(p_id)
  15.         # 替换医生
  16.         if Judge:
  17.             d_id = int(input('请选择你希望替换的医生的序号:'))
  18.             UpdateData_Appointment(d_id, p_id)
  19.         # 操作备份
  20.         pass
  21.  
  22.         if int(input('继续请输入1，退出请输入0:')) == 0:
  23.             break
  24.  
  25.  
  26. def Show_ReservedDoctor(p_id):
  27.     """
  28.     展示已经预约的医生
  29.     :param p_id:
  30.     :return: 布尔型
  31.     """
  32.     sql = '''select Doctor.d_name 
  33.                  from Doctor,Appointment 
  34.                  where Appointment.d_id = Doctor.d_id
  35.                    and Appointment.p_id = %s''' % p_id
  36.     conn = Connector.CreateConnect()
  37.     cursor = conn.cursor()
  38.     cursor.execute(sql)
  39.     ExistingDoctor_rows = cursor.fetchall()
  40.  
  41.     if not ExistingDoctor_rows:
  42.         print('[提示]您不在预约表中!')
  43.         conn.commit()
  44.         conn.close()
  45.         return False
  46.     else:
  47.         print('[查询结果]您已预约的医生:', ''.join(ExistingDoctor_rows[0]))
  48.         sql = '''select Doctor.dp_courtID 
  49.                      from Doctor,Appointment 
  50.                      where Appointment.d_id = Doctor.d_id
  51.                        and Appointment.p_id = %s''' % p_id
  52.         cursor.execute(sql)
  53.         DoctorCourtID_rows = cursor.fetchall()
  54.         Patient_InsertAppointment.Show_AlternativeDoctor(DoctorCourtID_rows[0][0])
  55.         conn.commit()
  56.         conn.close()
  57.         return True
  58.  
  59.  
  60. def UpdateData_Appointment(d_id, p_id):
  61.     """
  62.     数据库中修改信息
  63.     :param d_id: 医生ID
  64.     :param p_id: 患者ID
  65.     :return:
  66.     """
  67.     sql = '''update Appointment
  68.                 set d_id = %s
  69.                 where p_id = %s'''
  70.     conn = Connector.CreateConnect()
  71.     cursor = conn.cursor()
  72.     cursor.execute(sql, (str(d_id), str(p_id)))
  73.     print("[提示]修改成功!")
  74.     conn.commit()
  75.     conn.close()

        (5) Patient_CancelAppointment.py

  1. # -*- coding: utf-8 -*-
  2. import Connector
  3.  
  4.  
  5. def MainFunc():
  6.     while True:
  7.         p_id = str(input('请输入您的预约单号:'))
  8.         DeleteData_Appointment(p_id)
  9.         if int(input('继续请输入1，退出请输入0:')) == 0:
  10.             break
  11.  
  12.  
  13. def DeleteData_Appointment(p_id):
  14.     """
  15.     数据库中取消预约
  16.     :param p_id: 患者ID
  17.     :return:
  18.     """
  19.     conn = Connector.CreateConnect()
  20.     cursor = conn.cursor()
  21.     cursor.execute("select * from Appointment where p_id = '%s'" % p_id)
  22.     if not cursor.fetchall():
  23.         print('[提示]您不在预约表中!')
  24.     else:
  25.         cursor.execute("delete from Appointment where p_id = '%s'" % p_id)
  26.         cursor.execute("delete from Patient where p_id = '%s' " % p_id)
  27.         print('[提示]预约取消成功!')
  28.     conn.commit()
  29.     conn.close()

        (6) Patient_QueryAppointment.py

  1. # -*- coding: utf-8 -*-
  2. import Connector
  3.  
  4.  
  5. def MainFunc():
  6.     while True:
  7.         p_id = str(input('请输入您的预约单号:'))
  8.  
  9.         sql = '''select Doctor.d_name
  10.                          from Doctor,Appointment,Patient 
  11.                          where Appointment.d_id = Doctor.d_id
  12.                            and Patient.p_id = Appointment.p_id
  13.                            and Patient.p_id = %s''' % p_id
  14.         conn = Connector.CreateConnect()
  15.         cursor = conn.cursor()
  16.         cursor.execute(sql)
  17.         ExistingDoctor_rows = cursor.fetchall()
  18.         conn.commit()
  19.         conn.close()
  20.  
  21.         if not ExistingDoctor_rows:
  22.             print('[提示]您不在预约表中!')
  23.             return False
  24.         else:
  25.             print('[查询结果]您已预约的医生: ', ''.join(ExistingDoctor_rows[0]))
  26.  
  27.         if int(input('继续请输入1，退出请输入0:')) == 0:
  28.             break

        (7) GeneralAdministrator_Login.py

  1. # -*- coding: utf-8 -*-
  2. import time
  3.  
  4. import Connector
  5.  
  6.  
  7. def Login():
  8.     Login_Account = str(input('\t[账号] '))
  9.     Login_ID = str(input('\t[密码] '))
  10.     Login_Num = int(3)
  11.     Login_flag = FindLoginMessage(Login_ID, Login_Account)
  12.     while Login_flag is False and Login_Num > 0:
  13.         flag = int(input('[提示]输入错误\n[提示]是否继续? 继续请输入1,否则输入0: '))
  14.         if flag == 0:
  15.             return 'over'
  16.         Login_Account = str(input('\t[账号] '))
  17.         Login_ID = str(input('\t[密码] '))
  18.         Login_flag = FindLoginMessage(Login_ID, Login_Account)
  19.         Login_Num = Login_Num - 1
  20.  
  21.     if Login_flag is True:
  22.         return 'allow'
  23.  
  24.     if Login_Num == 0:
  25.         flag = int(input('[提示]是否继续?继续请输入1,否则输入0:'))
  26.         if flag == 0:
  27.             return 'over'
  28.         else:
  29.             Login_Account = str(input('\t[账号] '))
  30.             Login_ID = str(input('\t[密码] '))
  31.  
  32.             if FindLoginMessage(Login_ID, Login_Account) is False:
  33.                 print('[提示]输入错误次数过多,请5分钟后再尝试:')
  34.                 time.sleep(30)
  35.                 return 'again'
  36.             else:
  37.                 return 'allow'
  38.  
  39.  
  40. def FindLoginMessage(Login_ID, Login_Account):
  41.     conn = Connector.CreateConnect()
  42.     cursor = conn.cursor()
  43.     cursor.execute("select * from Administrator where a_id = %s and a_name = %s", (Login_ID, Login_Account,))
  44.     if not cursor.fetchall():
  45.         flag = False
  46.     else:
  47.         flag = True
  48.     conn.commit()
  49.     conn.close()
  50.     return flag

        (8) GeneralAdministrator_InsertTable.py

  1. # -*- coding: utf-8 -*-
  2. import Connector
  3.  
  4.  
  5. # 添加 医院科室表
  6. def InsertCourt():
  7.     while True:
  8.         c_name = str(input('请输入新的科室名称:'))
  9.         c_id = getCourtNum()
  10.         InsertData_Court(c_id, c_name)
  11.         if int(input('继续请输入1，退出请输入0:')) == 0:
  12.             break
  13.  
  14.  
  15. def getCourtNum():
  16.     sql = '''select MAX(c_id) from Court'''
  17.     conn = Connector.CreateConnect()
  18.     cursor = conn.cursor()
  19.     cursor.execute(sql)
  20.     ID = cursor.fetchone()
  21.     if ID == (None,):
  22.         c_id = 0
  23.     else:
  24.         c_id = ID[0] + 1
  25.     conn.commit()
  26.     conn.close()
  27.     return c_id
  28.  
  29.  
  30. def InsertData_Court(c_id, c_name):
  31.     sql = '''insert into Court(c_id,c_name) values(%s,%s)'''
  32.     conn = Connector.CreateConnect()
  33.     cursor = conn.cursor()
  34.     cursor.execute(sql, (str(c_id), str(c_name)))
  35.     print("\n[提示]修改成功!")
  36.     conn.commit()
  37.     conn.close()
  38.  
  39.  
  40. # 添加 医生信息表
  41. def InsertDoctor():
  42.     while True:
  43.         d_name = int(input('请输入新的医生姓名:'))
  44.         d_id = getDoctorNum()
  45.         court_list = getCourtNum()
  46.         dp_courtID = int(input('请输入新的医生的科室号:'))
  47.         while dp_courtID not in court_list:
  48.             dp_courtID = int(input('\n[提示]输入科室号错误，重新输入!'))
  49.         d_workWeekData = str(input('请输入新的医生的上班日期:'))
  50.         d_workStartTime = str(input('请输入新的医生的开始上班时间:'))
  51.         d_workEndTime = str(input('请输入新的医生的结束上班时间:'))
  52.  
  53.         InsertData_Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime)
  54.         if int(input('继续请输入1，退出请输入0:')) == 0:
  55.             break
  56.  
  57.  
  58. def getCourtID():
  59.     court_list = []
  60.     sql = '''select c_id from Court'''
  61.     conn = Connector.CreateConnect()
  62.     cursor = conn.cursor()
  63.     cursor.execute(sql)
  64.     ID = cursor.fetchall()
  65.     for row in ID:
  66.         court_list.append(row[0])
  67.     conn.commit()
  68.     conn.close()
  69.     return court_list
  70.  
  71.  
  72. def getDoctorNum():
  73.     sql = '''select MAX(d_id) from Doctor'''
  74.     conn = Connector.CreateConnect()
  75.     cursor = conn.cursor()
  76.     cursor.execute(sql)
  77.     ID = cursor.fetchone()
  78.     if ID == (None,):
  79.         d_id = 0
  80.     else:
  81.         d_id = int(''.join(ID)) + 1
  82.     conn.commit()
  83.     conn.close()
  84.     return d_id
  85.  
  86.  
  87. def InsertData_Doctor(d_id, d_name, dp_courtID, d_workWeekData, d_workStartTime, d_workEndTime):
  88.     sql = '''insert into Doctor(d_id,d_name,dp_courtID,d_workWeekData,d_workStartTime,d_workEndTime) values(%s,%s,%s,%s,%s,%s)'''
  89.     conn = Connector.CreateConnect()
  90.     cursor = conn.cursor()
  91.     cursor.execute(sql, (
  92.         str(d_id), str(d_name), str(dp_courtID), str(d_workWeekData), str(d_workStartTime), str(d_workEndTime)))
  93.     print("[提示]修改成功!")
  94.     conn.commit()
  95.     conn.close()

        (9) GeneralAdministrator_QueryTable.py

  1. # -*- coding: utf-8 -*-
  2. import Connector
  3.  
  4.  
  5. def ShowCourtMenu():
  6.     sql = '''select c_name from Court order by c_id asc'''
  7.     conn = Connector.CreateConnect()
  8.     cursor = conn.cursor()
  9.     cursor.execute(sql)
  10.     Court_rows = cursor.fetchall()
  11.     conn.commit()
  12.     conn.close()
  13.  
  14.     print('\t\t------- 科系表 -------')
  15.     i = 1
  16.     for row in Court_rows:
  17.         print('\t\t\t' + str(i) + ' --- ' + ''.join(row))
  18.         i += 1
  19.     print('\t\t---------------------')
  20.  
  21.  
  22. def ShowDoctorMenu():
  23.     sql = '''select d_id,c_name,d_name, d_workWeekData,d_workStartTime,d_workEndTime 
  24.                             from Doctor,Court 
  25.                             where Court.c_id = Doctor.dp_courtID 
  26.                             order by d_id asc'''
  27.     conn = Connector.CreateConnect()
  28.     cursor = conn.cursor()
  29.     cursor.execute(sql)
  30.     Doctor_rows = cursor.fetchall()
  31.     conn.commit()
  32.     conn.close()
  33.  
  34.     print('\t\t------- 医生信息表 -------')
  35.     for row in Doctor_rows:
  36.         print(row[0], ' 科室:', row[1], ' \t姓名:', row[2], '\t时间:', row[3], row[4], '到', row[5])
  37.     print('\t\t--------------------------')
  38.  
  39.  
  40. def ShowAppointmentMenu():
  41.     sql = '''select p_id,p_name,d_id, date_time,type 
  42.                                 from AppointmentRecord
  43.                                 order by date_time asc'''
  44.     conn = Connector.CreateConnect()
  45.     cursor = conn.cursor()
  46.     cursor.execute(sql)
  47.     Doctor_rows = cursor.fetchall()
  48.     conn.commit()
  49.     conn.close()
  50.  
  51.     print('\t\t------- 预约记录表 -------')
  52.     for row in Doctor_rows:
  53.         print('操作类型:', row[4], ' 操作时间:', row[3], ' 患者预约号:', row[0], ' 患者姓名:', row[1], '\t医生编号:', row[2])
  54.     print('\t\t--------------------------')

        (10) GeneralAdministrator_ClearTable.py

  1. # -*- coding: utf-8 -*-
  2. import Connector
  3.  
  4.  
  5. def ClearData():
  6.     """
  7.     清除预约表和患者信息表
  8.     :return: 空
  9.     """
  10.     ClearData_Appointment()
  11.     ClearData_Patient()
  12.     print('[提示]清除成功!')
  13.  
  14.  
  15. def ClearData_Appointment():
  16.     """
  17.     清除预约表
  18.     :return: 空
  19.     """
  20.     sql = '''truncate table Appointment'''
  21.     conn = Connector.CreateConnect()
  22.     cursor = conn.cursor()
  23.     cursor.execute(sql)
  24.     conn.commit()
  25.     conn.close()
  26.  
  27.  
  28. def ClearData_Patient():
  29.     """
  30.     清除患者信息表
  31.     :return: 空
  32.     """
  33.     sql = '''truncate table Patient'''
  34.     conn = Connector.CreateConnect()
  35.     cursor = conn.cursor()
  36.     cursor.execute(sql)
  37.     conn.commit()
  38.     conn.close()

        (11) SuperAdministrator_Login.py

  1. # -*- coding: utf-8 -*-
  2. import time
  3.  
  4.  
  5. def Login():
  6.     Login_Account = str(input('\t[账号] '))
  7.     Login_ID = str(input('\t[密码] '))
  8.     Login_Num = int(3)
  9.     Login_flag = FindLoginMessage(Login_ID, Login_Account)
  10.     while Login_flag == False and Login_Num > 0:
  11.         flag = int(input('[提示]输入错误\n[提示]是否继续? 继续请输入1,否则输入0: '))
  12.         if flag == 0:
  13.             return 'over'
  14.         Login_Account = str(input('\t[账号] '))
  15.         Login_ID = str(input('\t[密码] '))
  16.         Login_flag = FindLoginMessage(Login_ID, Login_Account)
  17.         Login_Num = Login_Num - 1
  18.  
  19.     if Login_flag:
  20.         return 'allow'
  21.  
  22.     if Login_Num == 0:
  23.         flag = int(input('[提示]是否继续?继续请输入1,否则输入0:'))
  24.         if flag == 0:
  25.             return 'over'
  26.         else:
  27.             Login_Account = str(input('\t[账号] '))
  28.             Login_ID = str(input('\t[密码] '))
  29.  
  30.             if not FindLoginMessage(Login_ID, Login_Account):
  31.                 print('[提示]输入错误次数过多,请5分钟后再尝试:')
  32.                 time.sleep(30)
  33.                 return 'again'
  34.             else:
  35.                 return 'allow'
  36.  
  37.  
  38. def FindLoginMessage(Login_ID, Login_Account):
  39.     if Login_Account != 'SuperAdministrator' and Login_ID != 'SuperAdm_123':
  40.         flag = False
  41.     else:
  42.         flag = True
  43.     return flag

        (12) SuperAdministrator_OperateOnTable.py

  1. # -*- coding: utf-8 -*-
  2. import Connector
  3.  
  4. def selectDate_GeneralAdministrator():
  5.     sql = '''select a_id,a_name from Administrator'''
  6.     conn = Connector.CreateConnect()
  7.     cursor = conn.cursor()
  8.     cursor.execute(sql)
  9.     Administrator_rows = cursor.fetchall()
  10.     conn.commit()
  11.     conn.close()
  12.  
  13.     print('\t------- 管理员信息表 -------')
  14.     for row in Administrator_rows:
  15.         print('账号:', row[1], ' 密码:', row[0])
  16.     print('\t--------------------------')
  17.  
  18.  
  19. def InsertData_GeneralAdministrator():
  20.     Adm_Account = str(input('\t待添加的账号:'))
  21.     Adm_ID = str(input('\t待添加的密码:'))
  22.  
  23.     conn = Connector.CreateConnect()
  24.     cursor = conn.cursor()
  25.  
  26.     while True:
  27.         cursor.execute("select * from Administrator where a_name = '%s' " % Adm_Account)
  28.         if not cursor.fetchall():
  29.             break
  30.         else:
  31.             Adm_Account = str(input('[提示]已经存在该账户,请重新输入:'))
  32.  
  33.     sql = '''insert into Administrator(a_id,a_name) values(%s,%s)'''
  34.     cursor.execute(sql, (str(Adm_ID), str(Adm_Account)))
  35.     print("[提示]添加成功!")
  36.     conn.commit()
  37.     conn.close()
  38.  
  39.  
  40. def UpdateData_GeneralAdministrator():
  41.     conn = Connector.CreateConnect()
  42.     cursor = conn.cursor()
  43.  
  44.     flag = int(input('修改账户请输入1,修改密码请输入2,否则按任意键退出:'))
  45.     if flag == 1:
  46.         Adm_OldAccount = str(input('\t旧账号:'))
  47.         Adm_NewAccount = str(input('\t新账号:'))
  48.  
  49.         while True:
  50.             cursor.execute("select * from Administrator where a_name = '%s' " % Adm_OldAccount)
  51.             if not cursor.fetchall():
  52.                 str(input('[提示]该账户不存在,请重新输入账号:'))
  53.             else:
  54.                 break
  55.  
  56.         sql = '''update Appointment set a_name = %s where a_name = %s'''
  57.         cursor.execute(sql, (str(Adm_NewAccount), str(Adm_OldAccount)))
  58.         print("[提示]修改成功!")
  59.  
  60.         conn.commit()
  61.         conn.close()
  62.     elif flag == 2:
  63.         Adm_Account = str(input('\t账号:'))
  64.         Adm_NewID = str(input('\t新密码:'))
  65.  
  66.         while True:
  67.             cursor.execute("select * from Administrator where a_name = '%s' " % Adm_Account)
  68.             if not cursor.fetchall():
  69.                 Adm_Account = str(input('[提示]该账户不存在,请重新输入账号:'))
  70.             else:
  71.                 break
  72.         sql = '''update Appointment set a_id = %s where a_name = %s'''
  73.         cursor.execute(sql, (str(Adm_NewID), str(Adm_Account)))
  74.         print("[提示]修改成功!")
  75.  
  76.         conn.commit()
  77.         conn.close()
  78.     else:
  79.         return False
  80.  
  81.  
  82. def DeleteData_GeneralAdministrator():
  83.     Adm_Account = str(input('\t待删除的账号:'))
  84.     str(input('\t待删除的密码:'))
  85.  
  86.     conn = Connector.CreateConnect()
  87.     cursor = conn.cursor()
  88.  
  89.     while True:
  90.         cursor.execute("select * from Administrator where a_name = '%s' " % Adm_Account)
  91.         if not cursor.fetchall():
  92.             Adm_Account = str(input('[提示]该账户不存在,请重新输入账号:'))
  93.         else:
  94.             break
  95.  
  96.     cursor.execute("delete from Administrator where a_name = '%s'" % Adm_Account)
  97.     print('[提示]删除成功!')
  98.     conn.commit()
  99.     conn.close()
  100.  
  101.  
  102. def ClearData_AppointmentRecord():
  103.     sql = '''truncate table appointmentrecord'''
  104.     conn = Connector.CreateConnect()
  105.     cursor = conn.cursor()
  106.     cursor.execute(sql)
  107.     print('[提示]清理成功!')
  108.     conn.commit()
  109.     conn.close()

 

四、结果展示

        1、患者预约界面

        预约以及查询

ca4f2def71464265b0845a90ba71b693.png

b9b91f5ac6f1432783e4259b76df52ec.png

       修改

f89f197d7f7d44f1bdf003d29160f0ab.png

34a854cd9d444caf9c299acb9811e45d.png

         取消

16d163ce01cf4e7eb0ea96a4f4ceed5a.png

        2、一般管理员控制界面

 

        登录一般管理员:

6535536f4e1b42278f45a5344813854f.png

02801beed4f640b395ab95cb872cb2e4.png

        查询医院科系:

451cc04eaebf49bdbfd0d9171f3c8359.png

         查询医生信息:

 

 

 

b5bb324ef0a54822a033c951e9de84ca.png

         查询患者预约操作记录表:

f0de93d4fd174bd4914711ed691611ca.png

         添加医院科系:

 

 

 

0f2dc4bc15404339a19d7ec4eb58a865.png

5bf9d941fa964257a2ad55783cda1987.png

        清理所有预约信息（包括预约表以及患者信息表）:

 

33bdaac04a5d44df9e60cb7f630d3078.png

 

        3、超级管理员控制界面

                登录超级管理员:

7e803830e09642fe90d7a773e8043923.png

9c195ff547df43fca66f29a2a80a2eb3.png

                  查询 一般管理员信息表:

0bbc6760e237434e8812344dd632f0b6.png

                 添加 一般管理员:

f53b83448fae4f61a5a11a0a468fbfd2.png

7264ad65448246c8a48c575764d20c79.png

                删除 一般管理员: 

752e0d95028a4f28bf4bc95848380ca1.png

0f17de04e86a42218dd8cb35d56e271c.png

                 清空 患者预约备份表:

bb5fc19b4ea94b12bd4a29f26e75218d.png

                结束: 

9a9408445d0f47fb866f5dcd8d4e261f.png

 

五、总结反思

        这次作业通过 python 实现了医院预约的基本操作，但是还存在相当多不合理的地方，比如

        医生上班时间预约的人数没有设置上限；

        医院预约的患者没有设置会诊的时间，导致会诊时间混乱；

        患者、一般管理员、超级管理员的登录应当设置不同的数据库角色，通过 sql 语言实现超级管理员为一般管理员和患者的授权，而不是通过 python 语言实现；

        该作业全部为后端编写，通过控制台实现，没有GUI图形化界面或者HTML网页；

        等。

        因为时间仓促，加上一系列的考试，这次作业实现的并不理想。等到以后学习了前端开发，时间允许，我会再改进作业，以达到更好的效果。

 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/你好赵伟/article/detail/675958
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号