校验登录想让用户数量 账号和密码 再去user表里面查出 和 用户输入的对比 如果有信息不对提示什么错误 要是没有信息不对提示登陆成功day03_book_router.post(/login,description用户登录,summary用户登录) async def post_book(user_data:UserRegister): dataawait User.get_or_none(usernameuser_data.username) if not data: return {code: 400, message: 用户不存在} if data.password ! user_data.password: return {code: 400, message: 密码错误} return { code: 200, message: 登录成功, data: { username: data.username, password: data.password } }查询全部部门通过GET方法day03_book_router.get(/list,description获取部门列表,summary获取部门列表) async def get_book_list(): data await Department.all().prefetch_related(employees) data_list[] for i in data: data_list.append({ id: i.id, name: i.name, description: i.location, created_at: i.phone, updated_at: i.updated_at, }) return { code: 200, message: 获取成功, data:data_list, total: len(data_list), }for 里面是想要返回的字段 部门ID、名称、位置、联系电话、更新时间for i in data: data_list.append({ id: i.id, name: i.name, description: i.location, created_at: i.phone, updated_at: i.updated_at, })新增部门POST接受到前端传过来的值Department.create(**department_data.dict())这一块是转成为字典day03_book_router.post(/create,description创建部门,summary创建部门) async def post_department(department_data:DepartmentRegister): data await Department.create(**department_data.dict()) return {code: 200, message: 创建成功, data: data}编辑部门 PUT根据前端传过来的ID进行查询部门exclude_unsetTrue 更新前端传过来的字段update_from_dict 更新数据并保存day03_book_router.put(/update,description更新部门,summary更新部门) async def get_department(id:int, department_data:DepartmentUpdate): data await Department.filter(idid).first() li department_data.dict(exclude_unsetTrue) if not data: return {code: 400, message: 部门不存在} await data.update_from_dict(li) await data.save() return {code: 200, message: 更新成功, data: data}删除部门 DELETE加载员工关联判断部门下是否存在员工有员工提示下面有员工不能删除这个部门无员工执行删除命令day03_book_router.delete(/delete,description删除部门,summary删除部门) async def delete_department(id:int): articles await Department.get_or_none(idid).prefetch_related(employees) if not articles: return {code: 400, message: 部门不存在} if len(articles.employees)0: return {code: 400, message: 部门下有员工请先删除员工} await articles.delete() return {code: 200, message: 删除成功}员工分页列表GET支持分页page/size、姓名模糊查询、部门ID筛选、状态筛选用Q拼接多条件查询预加载所属部门并格式化返回员工全部基础信息字段day03_book_router.get(/all,description获取员工列表,summary获取员工列表) async def get_department_list( page:int1, size:int10, name:str | NoneQuery(None,description姓名模糊搜索), department:int | NoneQuery(None,description部门ID), status:str | NoneQuery(None,description员工状态) ): filter_conditionQ() if name: filter_condition Q(name__containsname) if department: filter_condition Q(department_iddepartment) if status: filter_condition Q(statusstatus) offset (page - 1) * size query await Employee.filter(filter_condition).prefetch_related(department).offset(offset).limit(size) # data await query.offset(offset).limit(size) data_list[] for i in query: i_info{ id: i.id, name: i.name, emp_no: i.emp_no, gender: i.gender, age: i.age, phone: i.phone, email: i.email, hore_date: i.hore_date, salary: i.salary, status: i.status, department:None } if i.department: i_info[department]{ name: i.department.name } data_list.append(i_info) return { code: 200, message: 获取成功, data:data_list }增加员工POSTday03_book_router.post(/creatall,description创建员工,summary创建员工) async def post_employee(employee_data:EmployeeRegister): dic employee_data.dict() dic[department_id] dic.pop(department) data await Employee.create(**dic) return {code: 200, message: 创建成功, data: data}employee_data.dict()把Pydantic对象转换成普通python字典里面存放前端提交所有字段。前端传参示例{name:张三,emp_no:001,department:1,...}dic.pop(department)pop(department取出字典中department 的值就是前端传的部门ID 数字)·同时从字典里删除department 这个 keydic[department_id] .·给字典新增键department_id值为上面拿到的部门ID修改 PUT根据 id 查询部门exclude_unsetTrue只更新前端传入字段day03_book_router.put(/updateall,description更新员工,summary更新员工) async def put_employee(id:int, employee_data:EmployeeUpdate): data await Employee.filter(idid).first() if not data: return {code: 400, message: 员工不存在} li employee_data.dict(exclude_unsetTrue) await data.update_from_dict(li) await data.save() return {code: 200, message: 更新成功, data: data}删除DELETE删除员工时加载相关档案 同步删除员工档案day03_book_router.delete(/deleteall,description删除员工,summary删除员工) async def delete_employee(id:int): data await Employee.filter(idid).first().prefetch_related(profile) if not data: return {code: 400, message: 员工不存在} await data.delete() return {code: 200, message: 删除成功}
校验登录想让用户数量 账号和密码 再去user表里面查出 和 用户输入的对比 如果有信息不对提示什么错误 要是没有信息不对提示登陆成功day03_book_router.post(/login,description用户登录,summary用户登录) async def post_book(user_data:UserRegister): dataawait User.get_or_none(usernameuser_data.username) if not data: return {code: 400, message: 用户不存在} if data.password ! user_data.password: return {code: 400, message: 密码错误} return { code: 200, message: 登录成功, data: { username: data.username, password: data.password } }查询全部部门通过GET方法day03_book_router.get(/list,description获取部门列表,summary获取部门列表) async def get_book_list(): data await Department.all().prefetch_related(employees) data_list[] for i in data: data_list.append({ id: i.id, name: i.name, description: i.location, created_at: i.phone, updated_at: i.updated_at, }) return { code: 200, message: 获取成功, data:data_list, total: len(data_list), }for 里面是想要返回的字段 部门ID、名称、位置、联系电话、更新时间for i in data: data_list.append({ id: i.id, name: i.name, description: i.location, created_at: i.phone, updated_at: i.updated_at, })新增部门POST接受到前端传过来的值Department.create(**department_data.dict())这一块是转成为字典day03_book_router.post(/create,description创建部门,summary创建部门) async def post_department(department_data:DepartmentRegister): data await Department.create(**department_data.dict()) return {code: 200, message: 创建成功, data: data}编辑部门 PUT根据前端传过来的ID进行查询部门exclude_unsetTrue 更新前端传过来的字段update_from_dict 更新数据并保存day03_book_router.put(/update,description更新部门,summary更新部门) async def get_department(id:int, department_data:DepartmentUpdate): data await Department.filter(idid).first() li department_data.dict(exclude_unsetTrue) if not data: return {code: 400, message: 部门不存在} await data.update_from_dict(li) await data.save() return {code: 200, message: 更新成功, data: data}删除部门 DELETE加载员工关联判断部门下是否存在员工有员工提示下面有员工不能删除这个部门无员工执行删除命令day03_book_router.delete(/delete,description删除部门,summary删除部门) async def delete_department(id:int): articles await Department.get_or_none(idid).prefetch_related(employees) if not articles: return {code: 400, message: 部门不存在} if len(articles.employees)0: return {code: 400, message: 部门下有员工请先删除员工} await articles.delete() return {code: 200, message: 删除成功}员工分页列表GET支持分页page/size、姓名模糊查询、部门ID筛选、状态筛选用Q拼接多条件查询预加载所属部门并格式化返回员工全部基础信息字段day03_book_router.get(/all,description获取员工列表,summary获取员工列表) async def get_department_list( page:int1, size:int10, name:str | NoneQuery(None,description姓名模糊搜索), department:int | NoneQuery(None,description部门ID), status:str | NoneQuery(None,description员工状态) ): filter_conditionQ() if name: filter_condition Q(name__containsname) if department: filter_condition Q(department_iddepartment) if status: filter_condition Q(statusstatus) offset (page - 1) * size query await Employee.filter(filter_condition).prefetch_related(department).offset(offset).limit(size) # data await query.offset(offset).limit(size) data_list[] for i in query: i_info{ id: i.id, name: i.name, emp_no: i.emp_no, gender: i.gender, age: i.age, phone: i.phone, email: i.email, hore_date: i.hore_date, salary: i.salary, status: i.status, department:None } if i.department: i_info[department]{ name: i.department.name } data_list.append(i_info) return { code: 200, message: 获取成功, data:data_list }增加员工POSTday03_book_router.post(/creatall,description创建员工,summary创建员工) async def post_employee(employee_data:EmployeeRegister): dic employee_data.dict() dic[department_id] dic.pop(department) data await Employee.create(**dic) return {code: 200, message: 创建成功, data: data}employee_data.dict()把Pydantic对象转换成普通python字典里面存放前端提交所有字段。前端传参示例{name:张三,emp_no:001,department:1,...}dic.pop(department)pop(department取出字典中department 的值就是前端传的部门ID 数字)·同时从字典里删除department 这个 keydic[department_id] .·给字典新增键department_id值为上面拿到的部门ID修改 PUT根据 id 查询部门exclude_unsetTrue只更新前端传入字段day03_book_router.put(/updateall,description更新员工,summary更新员工) async def put_employee(id:int, employee_data:EmployeeUpdate): data await Employee.filter(idid).first() if not data: return {code: 400, message: 员工不存在} li employee_data.dict(exclude_unsetTrue) await data.update_from_dict(li) await data.save() return {code: 200, message: 更新成功, data: data}删除DELETE删除员工时加载相关档案 同步删除员工档案day03_book_router.delete(/deleteall,description删除员工,summary删除员工) async def delete_employee(id:int): data await Employee.filter(idid).first().prefetch_related(profile) if not data: return {code: 400, message: 员工不存在} await data.delete() return {code: 200, message: 删除成功}
