更新 database_manager.py
parent
70c0c7925d
commit
74d63734bc
|
|
@ -1,3 +1,5 @@
|
|||
from utils.time_utils import check_now_time
|
||||
from utils.time_utils import get_time_by_ids
|
||||
from db.connection import MySQLPool
|
||||
import bcrypt
|
||||
|
||||
|
|
@ -149,7 +151,7 @@ WHERE
|
|||
result = self.execute(sql, val)
|
||||
return result
|
||||
|
||||
def get_class_courses(self,student_number):
|
||||
def get_class_courses(self, student_number):
|
||||
# 1. 查询学生的主修专业
|
||||
major_sql = "SELECT major_id FROM student WHERE student_number = %s;"
|
||||
major_result = self.fetch(major_sql, student_number)
|
||||
|
|
@ -175,13 +177,15 @@ WHERE
|
|||
class_name = self.fetch(sql_student, (student_number,))[0]['class_name']
|
||||
|
||||
# 使用class_name和day_of_week从schedule表获取course_id
|
||||
sql_schedule = "SELECT course_id, FROM schedule WHERE day_of_week = %s AND class_name = %s;"
|
||||
course_id = self.fetch(sql_schedule, (day_of_week, class_name))
|
||||
print(course_id)
|
||||
|
||||
# 对于每一个course_id,从course表中查询course_name
|
||||
sql_course = "SELECT course_name FROM course WHERE course_id = %s;"
|
||||
course_name = self.fetch(sql_course, (course_id['course_id'],))
|
||||
data = {"course_name": course_name, "course_id": course_id}
|
||||
sql_schedule = "SELECT course_id,period_id FROM schedule WHERE day_of_week = %s AND class_name = %s;"
|
||||
schedule_results = self.fetch(sql_schedule, (day_of_week, class_name))
|
||||
print(schedule_results)
|
||||
data = []
|
||||
for i in schedule_results:
|
||||
course_id = i['course_id']
|
||||
sql_course = "SELECT course_name FROM course WHERE course_id = %s;"
|
||||
course_name = self.fetch(sql_course, (course_id))[0]['course_name']
|
||||
id = i['period_id']
|
||||
time = get_time_by_ids(id)
|
||||
data.append({"course_name": course_name, "time": time})
|
||||
return data
|
||||
|
||||
|
|
|
|||
Reference in New Issue