From ad7a51dbc0646250813476470929410141b9e3d9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E5=AD=A6=E5=B3=B0?= Date: Fri, 8 Jul 2022 14:40:39 +0800 Subject: [PATCH] fix: sync suite from tone --- services/tone_service.py | 38 +++++++++++++++++++++----------------- 1 file changed, 21 insertions(+), 17 deletions(-) diff --git a/services/tone_service.py b/services/tone_service.py index 3a38734..e72cad4 100644 --- a/services/tone_service.py +++ b/services/tone_service.py @@ -1,9 +1,8 @@ import asyncio import json - -from app import log from common.tone.api import TONE_SUITE_QUERY from common.tone.tone_request import get_res_from_tone +from app import log from models.tone_model import ToneCase, query_tone_case_type, query_tone_suite, ToneSyncPull, \ batch_insert_or_update_case @@ -39,21 +38,26 @@ async def sync_suite(): last_sync_time = last_sync_pull.gmt_created.strftime('%Y-%m-%d %H:%M:%S') else: last_sync_time = '2000-01-01 00:00:00' - result, ok = await query_suite_from_tone(last_sync_time) - if ok and result['data']: - case_list = list() - for case in result['data']: - exist_case = await ToneCase.query_obj_one(ToneCase.tone_case_id == case['case_id']) - if not exist_case: - case_obj = {'tone_case_id': case['case_id'], - 'tone_case_name': case['case_name'], - 'suite_id': case['suite_id'], - 'suite_name': case['suite_name'], - 'test_type': case['test_type']} - case_list.append(case_obj) - if len(case_list) > 0: - await ToneCase().batch_add(case_list) - await ToneSyncPull().save(dict()) + log.logger.info("begin sync suite result .......") + try: + result, ok = await query_suite_from_tone(last_sync_time) + if ok and result['data']: + case_list = list() + for case in result['data']: + exist_case = await ToneCase.query_obj_one(ToneCase.tone_case_id == case['case_id']) + if not exist_case: + case_obj = {'tone_case_id': case['case_id'], + 'tone_case_name': case['case_name'], + 'suite_id': case['suite_id'], + 'suite_name': case['suite_name'], + 'test_type': case['test_type']} + case_list.append(case_obj) + if len(case_list) > 0: + await ToneCase().batch_add(case_list) + await ToneSyncPull().save(dict()) + except Exception as err: + log.logger.error("sync suite error :" + str(err)) + log.logger.info("end sync suite result .......") async def query_suite_from_tone(last_sync_time): -- Gitee