]j>3ddlZddlZddlZddlZddlmZddlmZeejddZ ejddZ ejdd Z ejd d Z d Zd Zedk(reyy)N)datetime) load_dotenvDB_HOST localhostDB_NAMEsgd_wkveDB_USER sgd_wkve_userDB_PASS 2hOyYbkJUchqcvtj|st|jdk(ryt|j} t j |d}|j dS#t$r; t j |d}|j dcYS#t$rYYywxYwwxYw)Nz%d/%m/%Y %H:%M:%Sz%Y-%m-%d %H:%M:%Sz%d/%m/%Y)pdisnastrstriprstrptimestrftime ValueError)data_strdts 7/var/www/html/robot/execution/process_attachment_sgd.pyconverter_data_horars wwxCM//1R78}""$H   x)< ={{.//  ""8Z8B;;23 3   s0 &A44 B8>&B'$B8' B40B83B44B8ctttjdkr tdtjdtjd}t j j|s#td|tjdtd| tj|d} td k(rPt j jd r1 tjjd tt t" }n3tjjttt t"}|j%d}gd}j'D]e\}} t)|j*d} tj,|j*ds| j/dk(rVtj0|j*drt)|j*dnd} tj0|j*drt)|j*dnd} tj0|j*drt)|j*dnd} tj0|j*drt)|j*dnd} tj0|j*drt)|j*dnd}tj0|j*drt)|j*dnd}tj0|j*drt)|j*dnd}tj0|j*drt)|j*dnd}tj0|j*drt)|j*dnd}t3|j*d}t3|j*d}t3|j*d}t3|j*d}t3|j*d}tj0|j*d rt)|j*d nd}tj0|j*d!rt)|j*d!nd}tj0|j*d"rt)|j*d"nd}tj0|j*d#rt)|j*d#nd}tj0|j*d$rt)|j*d$nd}tj0|j*d%rt)|j*d%nd}tj0|j*d&rt)|j*d&nd}j5d'| f|j7}id(| d)| d*| d+| d,|d-|d.|d/|d0|d1|d2|d3|d4|d5|d6|d7|d8|||||d9} |r+g}!g}"g}#| j9D]\}$}%|j;|$}&|$|vr|& t)|&}&|% t)|%}%t)|&t)|%k7sM|!j=|$d:|"j=|%|#j=| |$|&|%f|!rz|"j=| d;d|(jCtd?| d@n[td?| dAnKdB})| | | | | |||||||||||||||||f}*|j5|)|*jCtd?| dChtdG tdHddddddI}+j5dJ|jE},dK}-g}.|,D]1}/|/dL}0|/d(}1|+j;|1d}2|.j=|0|2f3|.r:|jG|-|.jCtdMt|.dNtdOdP}3|j5|3jCtdQ|jHdRtdSdT}4|j5|4|jCtdU|jHdRtdVjKjK t jL|tdX|dYy#t$r.}td|tjdYd}~d}~wwxYw#t$rM}td |d tjjttt t"}Yd}~d}~wwxYw#t$r.}td|tjdYd}~d}~wwxYw#t$r,}tdD|dE|j*ddF|Yd}~d}~wwxYw#t$r}5tdW|5Yd}5~5hd}5~5wwxYw#tN$r}tdZ|d[|Yd}~yd}~wwxYw)\Nu.Erro: Caminho do arquivo Excel não fornecido.u Erro: Arquivo não encontrado - zProcessando arquivo: r)headerzErro ao ler arquivo Excel: rz/var/run/mysqld/mysqld.sock) unix_socketdatabaseuserpasswordu!Conexão via Unix socket falhou (z). Tentando via TCP...)hostrr r!T) dictionaryz$Erro ao conectar ao banco de dados: )inicio_esperadoprazocriacao encerradoentrega_estimadar z'SELECT * FROM tarefas WHERE tarefa = %sstatus_tarefasdescricao_resumida companhiaunidade_negocio grupo_suportedesignado_paraitem_requisicaorequisitado_porsolicitado_parar$r%r&r'r(info_adicionaisserv_detalhado atualizadopor) atualizacaomotivoemailemail_ponto_focalz = %szUPDATE tarefas SET z, z WHERE tarefa = %sz\INSERT INTO log_alteracoes (tarefa, campo, valor_antigo, valor_novo) VALUES (%s, %s, %s, %s)zTarefa 'z' atualizada com sucesso.u' já está atualizada.aV INSERT INTO tarefas ( tarefa, status_tarefas, descricao_resumida, companhia, unidade_negocio, grupo_suporte, designado_para, item_requisicao, requisitado_por, solicitado_para, inicio_esperado, prazo, criacao, encerrado, entrega_estimada, info_adicionais, serv_detalhado, atualizadopor, atualizacao, motivo, email, email_ponto_focal ) VALUES ( %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s ) z' inserida com sucesso.zErro processando linha z (tarefa: z): u.Iniciando sincronização pós-importação...z!Sincronizando tabela de status...)z Em andamento ResolvidoPendente Cancelado Encerradoz,SELECT idtarefa, status_tarefas FROM tarefasz INSERT INTO status (idtarefa, id_status) VALUES (%s, %s) ON DUPLICATE KEY UPDATE id_status = VALUES(id_status) idtarefazStatus atualizados: z registros.zAtualizando levantamento...u~ INSERT INTO levantamento ( idtarefa, tarefa, nome_demanda, escopo, data_solicitacao, idUsuario, id_status, status_siged, id_focal, id_gat, idlocalidade ) SELECT t.idtarefa, t.tarefa, t.info_adicionais, t.serv_detalhado, t.criacao, 57, s.id_status, sd.status_nome, 120, CASE WHEN t.grupo_suporte LIKE '%CARAJAS%' THEN 31 WHEN t.grupo_suporte LIKE '%SÃO LUIS%' THEN 58 WHEN t.grupo_suporte LIKE '%SOSSEGO%' THEN 32 WHEN t.grupo_suporte LIKE '%S11D%' THEN 37 WHEN t.grupo_suporte LIKE '%MARABÁ%' THEN 61 WHEN t.grupo_suporte LIKE '%SALOBO%' THEN 32 WHEN t.grupo_suporte LIKE '%SERRA SUL%' THEN 37 WHEN t.grupo_suporte LIKE '%ACAILÂNDIA%' THEN 61 WHEN t.grupo_suporte LIKE '%BELÉM%' THEN 87 WHEN t.grupo_suporte LIKE '%SANTA INÊS%' THEN 61 WHEN t.grupo_suporte LIKE '%OURILANDIA%' THEN 32 ELSE 1 END, CASE WHEN t.grupo_suporte LIKE '%SALOBO%' THEN 1 WHEN t.grupo_suporte LIKE '%CARAJAS%' THEN 3 WHEN t.grupo_suporte LIKE '%SÃO LUIS%' THEN 12 WHEN t.grupo_suporte LIKE '%SOSSEGO%' THEN 5 WHEN t.grupo_suporte LIKE '%S11D%' THEN 2 WHEN t.grupo_suporte LIKE '%MARABÁ%' THEN 11 WHEN t.grupo_suporte LIKE '%SERRA SUL%' THEN 2 WHEN t.grupo_suporte LIKE '%OURILANDIA%' THEN 6 WHEN t.grupo_suporte = 'PRJ Cabling WKVE -LA BR MG-DIFL' THEN 23 ELSE 12 END FROM tarefas t LEFT JOIN status s ON t.idtarefa = s.idtarefa LEFT JOIN status_demanda sd ON s.id_status = sd.id_status ON DUPLICATE KEY UPDATE nome_demanda = VALUES(nome_demanda), escopo = VALUES(escopo) z6Levantamento atualizado com sucesso (linhas afetadas: z).z#Corrigindo info_adicionais nulos...zQUPDATE tarefas SET info_adicionais = serv_detalhado WHERE info_adicionais IS NULLz-Info adicionais corrigidos (linhas afetadas: u'Sincronização concluída com sucesso!u,Erro durante o processo de sincronização: uArquivo temporário z deletado com sucesso.zErro ao deletar o arquivo z: )(lensysargvprintexitospathexistsr read_excel Exceptionrmysql connectorconnectrr r cursoriterrowsrilocrrnotnarexecutefetchoneitemsgetappendjointuplecommitfetchall executemanyrowcountcloseremoveOSError)6 file_pathdfeconn socket_errr^ date_columnsindexrowtarefastatusr=r>r?r@rArBrCrDr$r%r&r'r(rErFrGrHrIrJrKexisting novos_dadoscampos_para_atualizarvalores_para_atualizaralteracoes_logcampo novo_valor valor_atual sql_update log_entry sql_insertvalores_insert status_maptarefas_statussql_upsert_statusstatus_recordstid_val status_str status_idsql_levantamentosql_info_adicionaissync_errs6 rmainrs  388}q >?   I 77>>) $ 0 <=   !) -. ]]9Q /  k !bggnn5R&S .. =$ $ /??**  +D - \LkkmrR sq R!%Fwwsxx{#v||~';)+#((1+)>S!%DF57XXchhqk5JSXXa[!1PT ,.HHSXXa[,ACHHQK(tI24((388A;2Gc#((1+.TO02!0EC ,4M13#((1+1FS!-DN24((388A;2Gc#((1+.TO24((388A;2Gc#((1+.TO24((388A;2Gc#((1+.TO1#((2,?O' 5E)#((2,7G+CHHRL9I2388B<@ 3588CHHRL3Ic#((2,/tO24((388B<2HS".dN13#((2,1GC -TM/1xx /E#chhrl+4K*,((388B<*@S"&dF)+#((2,)?C %TE57XXchhrl5KCHHRL 1QU  NNDvi P(H &$&8Y"?     !. "?"?"?"?7Y#$4"? !.!" #$ + %6+K0(*%)+&!#)4):):)< X%E:"*,,u"5K ,&2*-k*:K%1),ZJ;'3z?:-44we_E.55jA&--vuk:.VW X)*11&9#6tyyAV7W6XXj!kJNN:u5K/LM&4 z% KKMHVH,EFGHVH,CDE  F$6 ?!>?OUd#UGY@PRa"M;O` " z>: (?@A_rRj :;ZI 12   EF*   7Az]F+,J"z15I  ! !69"5 6  7    0. A KKM (^)<(=[I J +,) T '(  FvFWWYZ[ 34q*+  =foo=NbQR 78 LLNJJL= ) $YK/EFG{  +A3/0   9*E[\].. $ $ /   4QC89  p R +E7*SXXa[MQCP Q Q R| I Dh6 Ei.$j) f 2#ff # g9,Ag4.g<4g99g<< h3#h..h36 i+?!i&&i+. j7j  j j7j22j7__main__)rVrRpandasrmysql.connectorr[rdotenvrgetenvrrr r rr__name__rrs  "))I{ + "))Iz * "))I / "))I~ . O=b zFr