diff --git a/api/api_v1/endpoints/interview.py b/api/api_v1/endpoints/interview.py index e567328..12682e8 100644 --- a/api/api_v1/endpoints/interview.py +++ b/api/api_v1/endpoints/interview.py @@ -47,6 +47,23 @@ async def interview_find( return schemas.Msg(code=200, msg='ok', data=data) +# 面试查询 +@router.post("/interview_home_find") +async def interview_find( + request: Request, + interview: InterviewDo = Depends(InterviewDo), + db: CKDrive = Depends(get_ck_db), +) -> schemas.Msg: + """ interview面试数据查询 """ + await interview.init() + res = interview.find_interview_home_sql() + sql = res['sql'] + data = await db.execute(sql) + if not data: + return schemas.Msg(code=-9, msg='无数据', data=None) + return schemas.Msg(code=200, msg='ok', data=data) + + # 面试修改 @router.post("/interview_update") async def interview_update( @@ -120,11 +137,13 @@ async def interview_insert( else: data['age'] = int(true_age.group()) work_exp = data['work_exp'] + if not work_exp: + data['work_exp'] = 0 # 工作经验float转化 if work_exp and isinstance(work_exp, str): true_work_exp = re.search(r"\d+\.?\d*", work_exp) if len(true_work_exp.group()) > 3: - data['work_exp'] = 1.0 + data['work_exp'] = 0 else: data['work_exp'] = float(true_work_exp.group()) print(data) diff --git a/models/interview_zsgc.py b/models/interview_zsgc.py index 61d2f11..eca6201 100644 --- a/models/interview_zsgc.py +++ b/models/interview_zsgc.py @@ -89,10 +89,12 @@ class InterviewDo: data_true['age'] = int(true_age.group()) work_exp = data_true['work_exp'] # 工作经验float转化 + if not work_exp: + data_true['work_exp'] = 0 if work_exp and isinstance(work_exp, str): true_work_exp = re.search(r"\d+\.?\d*", work_exp) if len(true_work_exp.group()) > 3: - data_true['work_exp'] = 1.0 + data_true['work_exp'] = 0.0 else: data_true['work_exp'] = float(true_work_exp.group()) res_data.append(data_true) @@ -134,12 +136,33 @@ class InterviewDo: whereStr += str(key) + ' = ' + str(value) + ' ' whereStr = whereStr.strip() findStr = findStr.strip().strip(',') - # sql = f"select {findStr} from HR.resumes where {whereStr}" - sql = f"select * from HR.resumes where {whereStr}" + sql = f"select {findStr} from HR.resumes where {whereStr}" + # sql = f"select * from HR.resumes where {whereStr}" print(sql) return {'sql': sql, } + # 主页查询 + def find_interview_home_sql(self): + whereStr = '' + findStr = '' + # 主页查询字段 + self.find_column = ["age","gender","at_school","name","event_time", "owner_name", "education", "school", "specialty", "interview_name", "mmended_state", "work_list", "work_exp", "job_name"] + for fstr in self.find_column: + findStr += fstr + ', ' + for key, value in self.where.items(): + if isinstance(value, str): + whereStr += str(key) + ' = ' + "'" + value + "'" + ' ' + continue + whereStr += str(key) + ' = ' + str(value) + ' ' + whereStr = whereStr.strip() + findStr = findStr.strip().strip(',') + sql = f"select {findStr} from HR.resumes where {whereStr}" + print(sql) + return {'sql': sql, + } + + if __name__ == '__main__': find = re.search(r"\d+\.?\d*", "18岁") print(len(find.group())) \ No newline at end of file diff --git a/utils/jianli.py b/utils/jianli.py index cd01a53..4865681 100644 --- a/utils/jianli.py +++ b/utils/jianli.py @@ -33,7 +33,7 @@ data_mode = { "phone": "", "job_name": "", "hr_name": "吴操", - "work_exp": 0.0, + "work_exp": 0, "interview_stage": 1, "owner_name": 2, "education": 1,