diff --git a/api/api_v1/endpoints/interview.py b/api/api_v1/endpoints/interview.py index 25a7982..6defae8 100644 --- a/api/api_v1/endpoints/interview.py +++ b/api/api_v1/endpoints/interview.py @@ -37,7 +37,7 @@ async def interview_find( ) -> schemas.Msg: """ interview面试数据查询 """ await interview.init() - res = await interview.find_interview_sql() + res = interview.find_interview_sql() sql = res['sql'] data = await db.execute(sql) return schemas.Msg(code=200, msg='ok', data=data) @@ -52,7 +52,7 @@ async def interview_update( ) -> schemas.Msg: """ interview面试数据更新 """ await interview.init() - res = await interview.update_interview_sql() + res = interview.update_interview_sql() sql = res['sql'] data = await db.execute(sql) return schemas.Msg(code=200, msg='ok', data=data) @@ -67,7 +67,7 @@ async def interview_insert( ) -> schemas.Msg: """ interview面试数据写入 """ await interview.init() - res = await interview.insert_interview_sql() + res = interview.insert_interview_sql() sql = res['sql'] insert_data = res['insert_data'] data = await db.execute_dict(sql, insert_data) diff --git a/models/interview_zsgc.py b/models/interview_zsgc.py index a628324..342287e 100644 --- a/models/interview_zsgc.py +++ b/models/interview_zsgc.py @@ -43,7 +43,7 @@ class InterviewDo: # sql = f"insert into test.interview(auth, state, name, phone, position, teacher_name, boss_name, stage, " \ # f"interview_type,interview_location, interview_time) values" - sql = f"insert into test.interview(name, kardid) values" + sql = f"insert into HR.resumes(name, kardid) values" print(sql) return {'sql': sql, 'insert_data': insert_data @@ -58,14 +58,14 @@ class InterviewDo: whereStr += str(key) + ' = ' + str(value) + ' ' updateStr = updateStr.strip() whereStr = whereStr.strip() - sql = f"alter table test.interview update `{updateStr}` where `{whereStr}`" + sql = f"alter table HR.resumes update `{updateStr}` where `{whereStr}`" print(sql) return {'sql': sql, } def find_interview_sql(self): - sql = f"select `{self.find_column}` from test.interview where {self.where}" + sql = f"select `{self.find_column}` from HR.resumes where {self.where}" print(sql) return {'sql': sql, }