j)ddlmZ ddlZddlZddlZddlZddlZddlZddl Z ddl m Z m Z m Z ddl mZddl mZddlmZejeZGddZdS) ) annotationsN)datedatetime timedelta)Any)UUID)format_vn_timec4eZdZdZ dddZ dddZdS)InvoiceGdtFetcherMixinz+Mixin for communicating with GDT endpoints.Nall config_idrtax_codestrusernamepasswordextradict[str, Any] from_date str | Noneto_date sync_typereturnc t|drT|d|\} } | r9d|dt| d} td| d|d| | dS||||| } | d d kr| d pd } | dpd }|| |||||\}}}d|d|d} |r| dd|dz } t|dr| d|| |d| d|d | ||||dS| dd}d} | d dko| dd}|r>t|dr.| d|d !} |d"t| d#z }| ||rd$nd%|d|| d d|| dS)&uKết nối thực tế và tải hóa đơn từng phần từ Cổng HĐĐT Tổng Cục Thuế (vượt Captcha tự động bằng AI).check_auth_cooldown gdt_portalu!Tài khoản Cổng Thuế (MST: u9) đang trong thời gian chờ an toàn 3 giờ (đến ut) sau lần thử thất bại để chống bị khóa tài khoản. Đã tự động bỏ qua phiên kết nối.u⏳ [GDT_AUTH] %scooldown_active)servicerstatusmessagecooldown_until)rrr extra_configrsuccesstoken cookie_header)r#rrrrr%u/Đã kết nối Tổng Cục Thuế và nạp u hóa đơn mới (u đã tồn tại).u Chi tiết: z, .clear_auth_cooldownSUCCESS)rrrr new_imported duplicatesrrru Lỗi xác thực Cổng Thuế.N auth_error is_auth_errorTset_auth_cooldowng@)hoursuK (Đã tự động kích hoạt chế độ chờ an toàn 3 giờ đến u# để chống khóa tài khoản). AUTH_ERRORAI_ERROR) hasattrrr loggerwarning_authenticate_gdt_portalget_fetch_and_persist_gdt_invoicesjoinr'_update_sync_statusr-)selfr rrrrrrr in_cooldowncd_untilmsgauth_res jwt_tokenr% new_count dup_countdetailserr_msgis_real_auth_errs RC:\Projects\DSCons\app\modules\invoices\infrastructure\adapters\gdt\gdt_fetcher.py_execute_real_gdt_connectionz3InvoiceGdtFetcherMixin._execute_real_gdt_connections 4. / / $($<$<\8$T$T !K nnn-h77nnn2C888+ (/"&. 008RW1   H  * * W--3I$LL99?RM,0,P,P!##+ -Q-- )Iy'AIAAbkAAAC =>""*  r$r#r%tuple[int, int, list[str]]c V ddl}tj}|s|} n; tj|d} n#t $r|} YnwxYw|s| t dz } nL tj|d} n##t $r| t dz } YnwxYw| | kr| | } } g} | } | | kr|| j| j \} }t| j| j |}t|| }| | |f| j dkrt| jdzdd} nt| j| j dzd} | | ktj }d|_tj|_d}d}g}g}|d vr| d |d vr| d | D]\}}|d }|d }d|d|d}|D]\}}d}d}d}|dkrdnd} |rd|nd|pdddddt%t'jdt*j| d }!||kr7|dz }d|d|}"|r%|"dt*j|z }"t%t'j|!d < t*j|"|!!}#t*j|#d"|#5}$t7j|$d$}%|%d%p-|%d&ptA|%tBr|%ng}&d}'d}(|&D]O})tA|)tDr8|#|)||}*|*d'kr |'dz }'|dz }?|*d(kr |(dz }(|dz }P|%d)}|rtI|&dkr ddd dddn #1swxYwYnq#tJ$rd}+tL'd*|d+|d,|d-|+| d.|d,|d/t%|+ddd0Yd}+~+nd}+~+wwxYw||k7tL(d1|d2|d3|d4| |d5krd6n |dkrd7nd8},| |,d/tI| d9|||fS):uTruy vấn danh sách hóa đơn từ Cổng Thuế theo khoảng thời gian và lưu trữ vào PostgreSQL. Quy định Cổng Thuế: Khoảng thời gian mỗi lần truy vấn không được vượt quá 1 tháng. Hàm tự động phân rã (chunking) khoảng ngày bất kỳ thành các kỳ tháng liên tiếp và hỗ trợ phân trang con trỏ (state cursor pagination). rNz%Y-%m-%d)days F)r purchase)inputrM)r sold)outputrOz%d/%m/%Yz tdlap=ge=zT00:00:00;tdlap=le=z T23:59:59rMu!Tìm kiếm (hóa đơn mua vào)u Tìm kiếm (hóa đơn bán ra)zBearer r$zoMozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/133.0.0.0 Safari/537.36z!application/json, text/plain, */*z7https://hoadondientu.gdt.gov.vn/tra-cuu/tra-cuu-hoa-donzhttps://hoadondientu.gdt.gov.vnz/tra-cuu/tra-cuu-hoa-don) AuthorizationCookiez User-AgentAcceptRefererOrigin request-idz end-pointactionz3https://hoadondientu.gdt.gov.vn/api/query/invoices/z ?sort=tdlap:desc&size=50&search=z&state=rW)headers)timeoutcontextzutf-8datasitemsnewdupstatezError fetching GDT invoices (z) for -z: uLỗi z ()z Synced chunk z to z: new=z, dup=r uMua vào & Bán rauMua vàouBán rau kỳ tháng)))calendarrtodayrstrptime ValueErrorr monthrangeyearmonthminappendsslcreate_default_contextcheck_hostname CERT_NONE verify_modestrftimeruuiduuid4urllibparsequoterequestRequesturlopenjsonloadsreaddecoder5 isinstancelistdict_persist_gdt_raw_invoicelen Exceptionr2r3info)-r9r#rrrrr%rdreto_dfrom_dchunkscurr_last_daycurr_month_end chunk_endctx total_new total_duprAdirections_to_syncs_de_ds_stre_str search_param direction path_type state_cursor page_count max_pages action_labelrYurlreqrespdata invoices_list chunk_new chunk_dupraw_invrese dir_labels- rDr6z6InvoiceGdtFetcherMixin._fetch_and_persist_gdt_invoicesgs   DD (*==BBDD     3I2....FF 3!*9jAAFFHH 3 3 3 r 2 2 22 3 D==DF+-dll"--diDDKAx!$)TZBBNND11I MM4+ , , ,zRDIM1a00DItzA~q99dll(**"-   + + +  % %&; < < <  ' '  % %&8 9 9 9J J HCLL,,ELL,,EQuQQQQQL(:A A $ 9#   !J..87;;@%G%6u%6%6%6R+1r#TAX?"%djll"3"3!;$l00>>  !9,,!OJJPYJJ|HJJC#LK););L)I)IKKK,/ ,=,=GL)"$n44S'4JJ#^33S4&!#':diikk.@.@.I.I#J#JD $ 1 1!L#'88G#4#4!L,6tT,B,B$JDD* )*I()I+8 7 7#-gt#<#< !7*.*G*G(/H+&+&C(+e||(1Q (1Q ),(1Q (1Q +/88G+<+P>$ Q 2 Q >Q Q Q Q  R8AR33R8)NNr )r rrrrrrrrrrrrrrrrr)NNr r$)r#rrrrrrrrrr%rrrG)__name__ __module__ __qualname____doc__rEr6rFrDr r sr55!%"LLLLLd!%"R-R-R-R-R-R-R-rFr ) __future__rr{loggingrm urllib.errorru urllib.parseurllib.requestrsrrrtypingrrapp.core.vn_timer getLoggerrr2r rrFrDrs""""""9   ..........++++++  8 $ $c-c-c-c-c-c-c-c-c-c-rF