diff --git a/app/main.py b/app/main.py index ab028f9..1466d84 100644 --- a/app/main.py +++ b/app/main.py @@ -106,9 +106,25 @@ async def deal_tab( b_str = body.decode() result = parse_qs(b_str) q = [DOMAIN, PROTOCOL, LANG, APP_SID] - logger.info(result) - logger.info(q) - return {"status": "success", "result": result, "q": q} + + def extract_id(params): + json_strings = params.get("PLACEMENT_OPTIONS", []) + for json_str in json_strings: + try: + data = json.loads(json_str) + if "ID" in data: + return data["ID"] + except json.JSONDecodeError: + print(f"Ошибка: Некорректная JSON-строка - {json_str}") + + deal_id = extract_id(result) + logger.info(deal_id) + + get_task_hook = f"{WEBHOOK}/tasks.task.list?select[]=ID&select[]=TITLE&filter[UF_CRM_TASK]=D_{deal_id}" + task_data = requests.get(get_task_hook) + task_data_json = task_data.json() + + return {"status": "success", "result": task_data_json} except Exception as e: logger.info(e) return {"status": "error"}