diff --git a/app/repositories/project.py b/app/repositories/project.py index 388b25d..bbefe29 100644 --- a/app/repositories/project.py +++ b/app/repositories/project.py @@ -231,25 +231,25 @@ class ProjectRepository(BaseRepository[ProjectModel]): async def get_all(self): url = 'http://api.khanesaziceco.ir/api/api/project/table' headers = { - 'authorization': 'Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJodHRwOlwvXC9hcGkua2hhbmVzYXppY2Vjby5pclwvYXBpXC9hdXRoXC9sb2dpbiIsImlhdCI6MTcyOTg4MTc2OCwiZXhwIjoxNzMyNDczNzY4LCJuYmYiOjE3Mjk4ODE3NjgsImp0aSI6IjRiUGQ0dW1Wc2ZBSnNFUzUiLCJzdWIiOjEzNiwicHJ2IjoiMjNiZDVjODk0OWY2MDBhZGIzOWU3MDFjNDAwODcyZGI3YTU5NzZmNyJ9.LsinrL84iKAd4HaTHmsaDCALXJPwMLegNpeFhlJL0aY'} + 'authorization': 'Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJodHRwOlwvXC9hcGkua2hhbmVzYXppY2Vjby5pclwvYXBpXC9hdXRoXC9sb2dpbiIsImlhdCI6MTc0OTg0NjExMSwiZXhwIjoxNzUyNDM4MTExLCJuYmYiOjE3NDk4NDYxMTEsImp0aSI6Ikh6OURsZHR2U2FVRU5rd24iLCJzdWIiOjEzNiwicHJ2IjoiMjNiZDVjODk0OWY2MDBhZGIzOWU3MDFjNDAwODcyZGI3YTU5NzZmNyJ9.C7vRTRbhKrKuoFd334imKAIYFnU-9ygCIFmrwiPGVxY'} data = {"page": 1, "limit": 400, "sort": "_id" } res = requests.post(url, data=json.dumps(data), headers=headers) a = res.json() - print(a['rows'][0]) obj = [] - for i in a['rows']: + rows = a['rows'] + rows.reverse() + for i in rows: _set = ProjectModel( sts=1, counter=i['id'], design=Design(**i) ).init_id().cu_at() obj.append(_set.mongo_dict()) - print() - # await use_collection(TaskEnv.CLN_PROJECT).insert_many(obj) + await use_collection(TaskEnv.CLN_PROJECT).insert_many(obj) return res.json() diff --git a/app/urls/project.py b/app/urls/project.py index deea8b4..b063813 100644 --- a/app/urls/project.py +++ b/app/urls/project.py @@ -93,10 +93,10 @@ def fetch_delete(body: TableEngineRequestType = Body(...)): # pass -# @router.post('/get_all', tags=_tag_base) -# @shrink(repo.get_all) -# def get_all(): -# pass +@router.post('/get_all', tags=_tag_base) +@shrink(repo.get_all) +def get_all(): + pass app.include_router(router) \ No newline at end of file