from Teachers.model.tea_model import Tea
from datetime import datetime

#增加
def add_tea_dao(t,db):
    try:
        t1 = Tea(**t)
        db.add(t1)
    except:
        db.rollback()
        return False
    else:
        db.commit()
        return True

#更新
def update_tea_dao(id,update_data,db):
    try:
        rows = db.query(Tea).filter(Tea.id == id
                                    ,Tea.is_delete == False).update(update_data)
    except:
        db.rollback()
        return False
    else:
        db.commit()
        return rows

#查询
def get_tea_dao(t,db):
    query = db.query(Tea).filter(Tea.is_delete == False)
    if t.get('id'):
        query = query.filter(Tea.id == t.get('id') )
    if t.get('name'):
        query = query.filter(Tea.name == t.get('name') )
    if t.get("sex"):
        query = query.filter(Tea.sex == t.get('sex') )
    if t.get('class_id'):
        query = query.filter(Tea.class_id == t.get('claa_id') )
    if t.get('sub'):
        query = query.filter(Tea.sub == t.get('sub') )
    if t.get('home_place'):
        query = query.filter(Tea.home_place == t.get('home_place') )
    if t.get('specialty'):
        query = query.filter(Tea.specialty == t.get('specialty') )
    if t.get('start_time'):
        query = query.filter(Tea.start_time == t.get('start_time') )
    if t. get('work_experience'):
        query = query.filter(Tea.work_experience == t.get('work_experience') )
    if t.get('education'):
        query = query.filter(Tea.education == t.get('education') )
    if t.get('college'):
        query = query.filter(Tea.collage == t.get('college') )
    r = query.all()
    return [{'id':i.id,'name':i.name,'class_id':i.class_id,'sub':i.sub,'tea.sex':i.sex,'home_place':i.home_place
                ,'specialty':i.specialty,'start_time':i.start_time,'work_experience':i.work_experience,'college':i.college} for i in r]

#删除
def delete_tea_dao(id,db):
    try:
        row = db.query(Tea).filter(Tea.id == id
                                   ,Tea.is_delete == False
                                   ).update({'is_delete':True,'delete_time':datetime.now()})
    except:
        db.rollback()
        row = 0
        return
    else:
        db.commit()
        return row