114 lines
5.5 KiB
Python
114 lines
5.5 KiB
Python
|
|
from model import Employments,Address,Company
|
|
|
|
|
|
def add_employment_dao(o,db): #新增就业信息函数
|
|
try:
|
|
# r = db.query(Employments).filter(Employments.id == o['id'] ).all() #
|
|
o.pop('id', None) #摘除id字段，自增字段无需手动添加
|
|
o1 = Employments( **o) #实例化参数
|
|
db.add(o1) #添加数据进入表
|
|
|
|
except Exception as e: #失败返回
|
|
print(f'添加失败，{e}')
|
|
db.rollback() #回滚数据
|
|
return False
|
|
else:
|
|
db.commit() #提交事务，永久保存
|
|
return True
|
|
|
|
def add_company_dao(o,db): #添加公司信息函数
|
|
try:
|
|
o.pop('id', None) #摘除id字段，自增字段无需手动添加
|
|
o1 = Company( **o) #实例化参数
|
|
db.add(o1) #添加数据进入表
|
|
except Exception as e: #失败返回
|
|
print(f'添加失败，{e}')
|
|
db.rollback() #回滚数据
|
|
return False
|
|
else:
|
|
db.commit() #提交事务，永久保存
|
|
return True
|
|
def add_address_dao(o,db): #添加地址区域信息函数
|
|
try:
|
|
o.pop('id', None) #摘除id字段，自增字段无需手动添加
|
|
o1 = Address( **o) #实例化参数
|
|
db.add(o1) #添加数据进入表
|
|
except Exception as e: #失败返回
|
|
print(f'添加失败，{e}')
|
|
db.rollback() #回滚数据
|
|
return False
|
|
else:
|
|
db.commit() #提交事务，永久保存
|
|
return True
|
|
|
|
|
|
def update_emp_dao(id,update_data,db): #更新数据函数
|
|
try:
|
|
rows = db.query( Employments )\
|
|
.filter( Employments.id == id )\
|
|
.update( update_data ) #更新条件匹配id
|
|
except Exception as e:
|
|
print(f'更新失败，{e}') #返回失败信息
|
|
db.rollback() #数据回滚
|
|
return False
|
|
else:
|
|
db.commit() #提交事务，永久保存
|
|
return rows
|
|
|
|
def get_emp_dao( #获取学生就业信息函数
|
|
# stuid,
|
|
stuname
|
|
,compname
|
|
,db
|
|
, min_salary: int = 0
|
|
, max_salary: int | None = None
|
|
# ,page
|
|
# ,page_size
|
|
): #根据选择条件获取信息
|
|
q = db.query(Employments,Company.compname,Address.somewhere)\
|
|
.join(Company,Employments.company_id==Company.id)\
|
|
.join(Address,Company.address_id==Address.id)\
|
|
.filter(Employments.is_deleted == 0) #连接公司表和地址表，筛选未被删除信息
|
|
# if stuid:
|
|
# q = q.filter( Employments.id == stuid )
|
|
|
|
if stuname: #根据学生姓名筛选
|
|
q = q.filter( Employments.stuname == stuname )
|
|
if compname: #根据公司姓名筛选
|
|
q=q.filter(Company.compname.like(f'%{compname}%'))
|
|
# r = q.offset( (page-1)*page_size ).limit( page_size ).all()
|
|
if min_salary is not None: #根据最小薪资筛选
|
|
q = q.filter(Employments.salary >= min_salary)
|
|
if max_salary is not None: ##根据最大薪资筛选
|
|
q = q.filter(Employments.salary <= max_salary)
|
|
r= q.all()
|
|
if r:
|
|
return [ {"id": i.id,
|
|
'stuname':i.stuname,
|
|
'stuclass':i.stuclass,
|
|
"company_name": compname,
|
|
"address":somewhere,
|
|
# "company_id": i.company_id,
|
|
"salary":i.salary,
|
|
# "address_id": i.address_id,
|
|
"employment_open_date":i.employment_open_date,
|
|
"offer_date":i.offer_date,
|
|
"created_date": i.created_date,
|
|
"updated_date": i.updated_date,
|
|
"is_deleted":i.is_deleted } for i,compname,somewhere in r ] #返回信息列表
|
|
|
|
|
|
def delete_emp_dao(id,db): #删除函数
|
|
try:
|
|
rows = db.query(Employments)\
|
|
.filter(Employments.id == id)\
|
|
.update( {'is_deleted':1} ) #软删除，is_deleted返回1
|
|
|
|
except Exception as e: #失败返回信息
|
|
print(f'删除失败，{e}')
|
|
db.rollback() #数据回滚
|
|
rows = 0 #返回0
|
|
else:
|
|
db.commit() #提交事务，永久保存
|
|
return rows |