This repository has been archived by the owner on Oct 22, 2024. It is now read-only.
forked from LucasMaciel7/Finalizar_atendimentos_IXC-API
-
Notifications
You must be signed in to change notification settings - Fork 0
/
atendimento.py
81 lines (68 loc) · 3.16 KB
/
atendimento.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
import requests
import base64
import json
import openpyxl
from datetime import datetime
import time
id_a_editar = []
data_hora_atual = datetime.now().isoformat()
planilha = openpyxl.load_workbook('atendimentos.xlsx') # faz o dowload da planilha Excel com os atendimentos
planilha_ativa = planilha.active
response_count = 0
# Define o Host, e a url onde será feito a requisição e o Token de autenticação
host = "provernet.com.br"
url = "https://{}/webservice/v1/su_mensagens/{}".format(host,id_a_editar)
token = "246:31c337437fb3431e4376e69f62c98960fccc9b90509c2da096106bf3e6f5256a".encode('utf-8')
# Ao iniciar o código printa a hora atual para visualização
print(f"Horario da inicialização {data_hora_atual}/n")
print("-"*50)
# Extrai o valor id da planilha e encaminha todos Ids para uma lista
for linha in planilha_ativa.iter_rows(min_row=2,values_only=True):
if linha[0] is not None:
id_a_editar.append(linha[0])
# Roda um for construindo realizando uma requisição para cada ID do Array a
for id in id_a_editar:
payload = {
"id_ticket": id,
"data":"CURRENT_TIMESTAMP",
'mensagens_nao_lida_cli': 'Finalizado via API devido erro no fluxo do processo',
"operador": "",
'su_status': 'S', # Muda o status para solucionadp
"mensagem": "Finalização de atendimentos em massa via API ",
"visibilidade_mensagens": "PU",
"existe_pendencia_externa": "0",
"id_evento_status": "0",
"ultima_atualizacao": data_hora_atual
}
# Define o cabeçalho de minha requisição
headers = {
'Authorization': 'Basic {}'.format(base64.b64encode(token).decode('utf-8')),
'Content-Type': 'application/json'
}
# Realiza uma tratativa de erro para o código não parar quando der algum erro na requisição
while True:
try:
response = requests.post(url, data=json.dumps(payload), headers=headers, timeout=30) # Timeout= aumenta o tempo limite para 30 segundos
if response.status_code == 200:
response_count += 1
# A cada 1000 requisições da um pause de 5 minutos
if response_count == 1000:
response_count = 0
print("1000 Atendimentos finalizados, realizando pausa de 5 minutos")
time.sleep(300)
break
# Se a resposta não for 200 da um pause de 5 minutos e tenta novamente
else:
print('Resposta da API não foi 200, realizando pausa de 5 minutos')
time.sleep(300)
# Faz a tratativa do erro que mais ocorria normalmente.
except requests.exceptions.Timeout:
print('Tempo limite de conexão excedido, realizando pausa de 5 minutos')
time.sleep(300)
except requests.exceptions.RequestException as e:
print('Erro ao fazer requisição:', e)
time.sleep(300)
print(response.text)
print("-"*50)
print(f"\nHorario da finalização ", datetime.now().isoformat())
print('\nComando enviado com SUCESSO, FINALIZADO!')