diff --git a/services/tone_service.py b/services/tone_service.py index 3a38734c09e4fa5c62ff590febb834750becf31c..e72cad420532f65efcc5e2f22372251b9e9dc916 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):