diff --git a/api/api_v1/endpoints/interview.py b/api/api_v1/endpoints/interview.py index 7598eae..945fdf0 100644 --- a/api/api_v1/endpoints/interview.py +++ b/api/api_v1/endpoints/interview.py @@ -79,19 +79,19 @@ async def interview_insert( return schemas.Msg(code=200, msg='ok', data=data) -@router.post("/interview_insert") -async def interview_insert( - request: Request, - data_in: schemas.Interview, - ckdb: CKDrive = Depends(get_ck_db), -) -> schemas.Msg: - """ 面试情况 """ - await interview.init() - res = interview.insert_interview_sql() - sql = res['sql'] - insert_data = res['insert_data'] - data = await db.execute_dict(sql, insert_data) - return schemas.Msg(code=200, msg='ok', data=data) +# @router.post("/interview_insert") +# async def interview_insert( +# request: Request, +# data_in: schemas.Interview, +# ckdb: CKDrive = Depends(get_ck_db), +# ) -> schemas.Msg: +# """ 面试情况 """ +# await interview.init() +# res = interview.insert_interview_sql() +# sql = res['sql'] +# insert_data = res['insert_data'] +# data = await db.execute_dict(sql, insert_data) +# return schemas.Msg(code=200, msg='ok', data=data) @router.post("/add_job") async def event_edit( diff --git a/core/config.py b/core/config.py index 5e2b1e4..da47d8d 100644 --- a/core/config.py +++ b/core/config.py @@ -401,7 +401,7 @@ class Settings(BaseSettings): # DATABASE_URI = f'mongodb://{MDB_USER}:{MDB_PASSWORD}@{MDB_HOST}:{MDB_PORT}/admin' # 本地MongoDB的库测试 class Debug(Settings): - MDB_HOST: str = '127.0.0.1' + MDB_HOST: str = '10.0.0.240' MDB_PORT: int = 27017 MDB_DB: str = 'hr_system' diff --git a/models/interview_zsgc.py b/models/interview_zsgc.py index d069369..6ee67dd 100644 --- a/models/interview_zsgc.py +++ b/models/interview_zsgc.py @@ -11,9 +11,10 @@ import pandas as pd import numpy as np from sqlalchemy import func, or_, and_, not_ - +from copy import deepcopy import crud import schemas +from dateutil import parser from core.config import settings from db import get_database @@ -36,18 +37,31 @@ class InterviewDo: def insert_interview_sql(self): insert_data = [] + res_data = [] if isinstance(self.data_in, dict): insert_data = [self.data_in] if isinstance(self.data_in, list): insert_data = self.data_in - keys = () + + sql = f"insert into HR.resumes(interview_name, interview_type, interview_sign, feedback, interview_round, star_time, end_time, event_time, uid, name, phone, job_name, hr_name, work_exp, interview_stage, owner_name, education, work_undergo, school, specialty, mmended_state, mail, account, id_card, gender, interview_state, graduate_time, counts) values" for data in insert_data: - keys = tuple(data.keys()) - break - sql = f"insert into HR.resumes{keys} values" + s1 = data['star_time'] + s2 = data['end_time'] + s3 = data['event_time'] + s4 = data['graduate_time'] + if s1: + data['star_time'] = parser.parse(s1) + if s2: + data['end_time'] = parser.parse(s2) + if s3: + data['event_time'] = parser.parse(s3) + if s4: + data['graduate_time'] = parser.parse(s4) + data_true = deepcopy(data) + res_data.append(data_true) print(sql) return {'sql': sql, - 'insert_data': insert_data + 'insert_data': res_data } def update_interview_sql(self): diff --git a/接口文档/添加候选人接口文档.txt b/接口文档/添加候选人接口文档.txt new file mode 100644 index 0000000..96f664d --- /dev/null +++ b/接口文档/添加候选人接口文档.txt @@ -0,0 +1,38 @@ +·: /api/v1/itr/interview_insert + +: +{ + "data_in": { # + "interview_name": "", + "interview_type": 0, + "interview_sign": 1, + "feedback": 0, + "interview_round": 1, + "star_time": "2022-07-11T10:30:00", + "end_time": "2022-07-11T11:00:00", + "event_time": "2022-07-01T10:00:00", + "uid": "1234567890", + "name": "", + "phone": "13789923799", + "job_name": "python", + "hr_name": "", + "work_exp": "2", + "interview_stage": 1, + "owner_name": 2, + "education": 1, + "work_undergo": "", + "school": "人ѧ", + "specialty": "רҵ", + "mmended_state": 0, + "mail": "250213000@qq.com", + "account": "人", + "id_card": "421202199986750339", + "gender": "", + "interview_state": 2, + "graduate_time": "2022-07-01T08:00:00", + "counts": 1 + }, + "interview_query": {}, # ɸѡ Ӻѡ˽ӿ ֵ + "find_column": [ # ʾֶ Ӻѡ˽ӿ ֵ + ] +} \ No newline at end of file