ауфе

resolved_task.py

@@ -0,0 +1,77 @@
+import csv
+import json
+import os
+import sys
+import time
+
+import requests
+
+
+from logging_config import setup_logging
+from urllib.parse import urlencode
+
+logger = setup_logging(__name__)
+
+base_dir = os.path.dirname(os.path.realpath(__file__))
+asana_data_json = os.path.join(base_dir, './data/data_asana.json')
+users_data = os.path.join(base_dir, './data/users.mapping.asana2ya.csv')
+
+sys.stdin.reconfigure(encoding='utf-8')
+sys.stdout.reconfigure(encoding='utf-8')
+
+
+QUEUE_NAME = 'TESTIMPORT'
+
+# headers = {
+#     'Host': 'api.tracker.yandex.net',
+#     'Authorization': 'OAuth y0_AgAEA7qkB3KjAArkXwAAAADzMlP9oR1lwMzBS2e94jHzdnII8Laxi7k',
+#     'X-Org-ID': '7095769',
+#     'Content-Type': 'appication/json',
+# }
+
+
+def close_tasks_in_queue(queue_name):
+    base_url = 'https://api.tracker.yandex.net/v2/issues/_search'
+    headers = {
+        'Host': 'api.tracker.yandex.net',
+        'Authorization': 'OAuth y0_AgAEA7qkB3KjAArkXwAAAADzMlP9oR1lwMzBS2e94jHzdnII8Laxi7k',
+        'X-Org-ID': '7095769',
+        'Content-Type': 'application/json',
+    }
+
+    payload = {
+        "filter": {
+            "queue": queue_name,
+            "status": "open"  # Фильтр для открытых задач в указанной очереди
+        }
+    }
+
+    response = requests.post(
+        base_url,
+        headers=headers,
+        data=json.dumps(payload)
+    )
+
+    if response.status_code == 200:
+        tasks = response.json().get('issues', [])
+        for task in tasks:
+            task_id = task['id']
+            close_payload = {
+                'status': 'resolved'  # Установка статуса "Закрыт"
+            }
+            close_url = f'https://api.tracker.yandex.net/v2/issues/{task_id}'
+            close_response = requests.patch(
+                close_url,
+                headers=headers,
+                data=json.dumps(close_payload)
+            )
+            if close_response.status_code == 200:
+                print(f'Задача {task_id} закрыта успешно')
+            else:
+                print(f'Ошибка при закрытии задачи {task_id}: {close_response.content}')
+    else:
+        print(f'Ошибка при получении задач для очереди {queue_name}: {response.content}')
+
+
+# Вызов функции для закрытия задач в очереди 'TESTIMPORT'
+close_tasks_in_queue('TESTIMPORT')