diff --git a/services/product_service.py b/services/product_service.py index 3e5e3d38c92de1bb1540e66a2610f164168d9c74..164a8b8d7c481a8369b4789eee8682692d2e2286 100644 --- a/services/product_service.py +++ b/services/product_service.py @@ -26,8 +26,12 @@ async def get_products(name=None, is_paginate='', page_num=1, page_size=10): return product_list -async def get_run_record(user_infos, page_num=1, page_size=10): - product_list = await TestProduct.query_page(page_num=page_num, page_size=page_size) +async def get_run_record(user, page_num=1, page_size=10): + if user['role'] == User_Role.VISITOR.value: + product_list = await TestProduct.query_page(page_num=page_num, page_size=page_size, + search={'executor': user['user_name']}) + else: + product_list = await TestProduct.query_page(page_num=page_num, page_size=page_size) for product in product_list.get('data'): category = await ProductCategory.query_obj_one(ProductCategory.id == product.get('category_id')) if category: