romfast/comun
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
c6216e006e615fbd31b9d8de86cade08382afde8
comun/utile/Teste/cache_anaf/test_rand_nou_din_cache.prg
Marius Mutu 5c8a201438 Cache ANAF: verificarea in masa a codurilor fiscale, pe transe (SVN r17935) 
Verificarea "in masa" (VerificaListaCIF ... 'MASA') pica pe ORA-01795 peste 1000
de coduri, iar esecul trimitea tot lotul la ANAF, cu pauze de o secunda la fiecare
100 de coduri. Pe langa asta, fiecare rand servit din cache era salvat inapoi in
istoric si logat separat.

- programe/validare.prg: CitesteIstoricPentruCoduri citeste pe transe de maxim
  1000 de coduri legate cu OR in aceeasi interogare (fara obiecte noi in baza,
  compatibil cu Oracle 10g); plasa de siguranta cere codurile neacoperite o
  singura data, nu cod cu cod; SalveazaIstoricDinCursor sare peste randurile cu
  sursa CACHE*; bucla de log per rand devine o singura linie cu totalul.
- clase/overificari.vc2: completarea tabelului de parteneri foloseste index pe
  codul normalizat si SEEK in loc de LOCATE cu UDF (era patratic).
- utile/Teste/cache_anaf/: harness-uri de masurare si non-regresie pentru
  timpii de mai jos.

Masurat pe MARIUSM_AUTO, cu ANAF blocat: 1000 de coduri 5,1 s -> 0,318 s;
1001 coduri 16,6 s cu ORA-01795 -> 0,553 s fara eroare; 3000 de coduri 1,565 s;
200 de coduri din cache 3,93 s -> 0,05 s, cu 0 randuri noi in istoric;
completarea tabelului pentru 2000 de parteneri 11,97 s -> 0,028 s.
Randurile intoarse si verdictele raman identice.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01JCzVWfqscv1xyo5uvJiWiW
2026-08-02 07:27:42 +03:00

268 lines
10 KiB
Plaintext
Raw Blame History

* test_rand_nou_din_cache.prg - de ce apare un rand NOU in ISTORIC_CODURI_FISCALE cand
* verificarea in masa a fost servita integral din cache.
*
* Ruleaza VerificaListaCIF pe coduri proaspete (ANAF blocat), apoi identifica randurile
* adaugate peste watermark si le compara, camp cu camp, cu randul care exista deja pentru
* acelasi cod fiscal - ca sa se vada CE anume a considerat pachetul ca fiind "diferit"
* (pack_istoric_cf.SAVE_ISTORIC_COD_FISCAL compara ultima inregistrare cu parametrii primiti).
*
* Rulare: vfp9.exe -A -T "...\test_rand_nou_din_cache.prg" [N]
LPARAMETERS tcN
SET SAFETY OFF
SET TALK OFF
SET DELETED ON
SET EXACT ON
SET CENTURY ON
SET DATE DMY
SET NULLDISPLAY TO ''
CLOSE DATABASES
PUBLIC gcTestLog, gnApeluriANAF, gnErorriSQL, gcUltimaEroareSQL
gcTestLog = "D:\ROA\ROACONT\COMUN\utile\Teste\cache_anaf\test_rand_nou_din_cache_log.txt"
STRTOFILE("START " + TTOC(DATETIME()) + CHR(13) + CHR(10), gcTestLog)
gnApeluriANAF = 0
gnErorriSQL = 0
gcUltimaEroareSQL = ''
ON ERROR DO ErrRand WITH ERROR(), MESSAGE(), PROGRAM(), LINENO()
ON SHUTDOWN QUIT
DO D:\ROA\ROACONT\COMUN\utile\Teste\test_init_env_auto.prg WITH 'CENTRAL', 'MARIUSM_AUTO', 'ROMFASTSOFT'
IF gnHandle <= 0
DO WrLog4 WITH 'EROARE: conectare Oracle esuata - GATA'
QUIT
ENDIF
DO WrLog4 WITH 'mediu OK, schema=' + gcS
LOCAL loExecNou
loExecNou = CREATEOBJECT('oexec_fara_dialog2')
loExecNou.nHandle = gnHandle
goExecutor = loExecNou
LOCAL lnN, lcSql, lnZile, loVer
lnN = IIF(TYPE('tcN') = 'C' AND !EMPTY(tcN), INT(VAL(tcN)), 200)
loVer = CREATEOBJECT('VerificareANAFRand')
lnZile = loVer.ZileCache()
PUBLIC gnWm
gnWm = 0
IF goExecutor.oExecuta('SELECT NVL(MAX(ID),0) AS IDMAX FROM ISTORIC_CODURI_FISCALE', 'crsW')
gnWm = crsW.IDMAX
USE IN (SELECT('crsW'))
ENDIF
DO WrLog4 WITH 'watermark = ' + TRANSFORM(gnWm)
IF gnWm <= 0
DO WrLog4 WITH 'EROARE: watermark invalid - GATA'
QUIT
ENDIF
lcSql = 'SELECT COD_FISCAL_N FROM (SELECT DISTINCT COD_FISCAL_N FROM ISTORIC_CODURI_FISCALE'
lcSql = lcSql + ' WHERE COD_FISCAL_N IS NOT NULL AND DATAORAV_ANAF IS NOT NULL'
lcSql = lcSql + ' AND SYSDATE - DATAORAV_ANAF <= ' + TRANSFORM(lnZile)
lcSql = lcSql + ' ORDER BY COD_FISCAL_N) WHERE ROWNUM <= ' + TRANSFORM(lnN)
=goExecutor.oExecuta(lcSql, 'crsCodR')
IF USED('cLotR')
USE IN cLotR
ENDIF
CREATE CURSOR cLotR (cod_fiscal C(30) NULL, data D NULL)
SELECT crsCodR
SCAN
INSERT INTO cLotR (cod_fiscal, data) VALUES (ALLTRIM(TRANSFORM(crsCodR.COD_FISCAL_N)), DATE())
SELECT crsCodR
ENDSCAN
USE IN (SELECT('crsCodR'))
DO WrLog4 WITH 'lot = ' + TRANSFORM(RECCOUNT('cLotR')) + ' coduri proaspete'
=loVer.VerificaListaCIF('cLotR', DATE(), 'crsRezR', 'MASA')
DO WrLog4 WITH 'randuri intoarse: ' + TRANSFORM(IIF(USED('crsRezR'), RECCOUNT('crsRezR'), 0))
DO WrLog4 WITH 'apeluri ANAF (blocate): ' + TRANSFORM(gnApeluriANAF)
* --- ce s-a adaugat ---
lcSql = 'SELECT ID, COD_FISCAL, COD_FISCAL_N, FIRMA, ADRESA, JUDET, REGCOM, CODPOSTAL,'
lcSql = lcSql + ' TELEFON, FAX, DATATVAMFIN, PLATITORTVAMFIN, STARE, PLATITORTVAVIES,'
lcSql = lcSql + ' INACTIV, TVAINCASARE, SPLITTVA, SCHEMA_SURSA'
lcSql = lcSql + ' FROM ISTORIC_CODURI_FISCALE WHERE ID > ' + TRANSFORM(gnWm) + ' ORDER BY ID'
IF !goExecutor.oExecuta(lcSql, 'crsNoi')
DO WrLog4 WITH 'EROARE la citirea randurilor noi'
ELSE
DO WrLog4 WITH ''
DO WrLog4 WITH '=== randuri NOI adaugate: ' + TRANSFORM(RECCOUNT('crsNoi')) + ' ==='
SELECT crsNoi
SCAN
DO WrLog4 WITH ''
DO WrLog4 WITH 'ID nou ' + TRANSFORM(crsNoi.ID) + ' cod_fiscal=[' + TRANSFORM(crsNoi.COD_FISCAL) + ']' + ;
' cod_fiscal_n=' + TRANSFORM(crsNoi.COD_FISCAL_N)
DO ComparaCuAnterior WITH crsNoi.COD_FISCAL_N, crsNoi.ID
DO AratatCeSATrimis WITH crsNoi.COD_FISCAL_N
SELECT crsNoi
ENDSCAN
USE IN (SELECT('crsNoi'))
ENDIF
DO WrLog4 WITH ''
=goExecutor.oExecuta('DELETE FROM ISTORIC_CODURI_FISCALE WHERE ID > ' + TRANSFORM(gnWm))
=goExecutor.oExecuta('COMMIT')
DO WrLog4 WITH 'curatenie: sterse randurile cu ID > ' + TRANSFORM(gnWm)
DO WrLog4 WITH 'GATA ' + TTOC(DATETIME())
QUIT
*** ce a trimis SalveazaIstoricDinCursor pentru codul asta (randul din cursorul de rezultat)
PROCEDURE AratatCeSATrimis
LPARAMETERS tnCodN
LOCAL lcSel
lcSel = SELECT()
IF !USED('crsRezR')
RETURN
ENDIF
SELECT crsRezR
LOCATE FOR cui = tnCodN
IF !FOUND()
DO WrLog4 WITH ' (codul nu e in cursorul de rezultat)'
SELECT (lcSel)
RETURN
ENDIF
DO WrLog4 WITH ' trimis de VFP: sursa=[' + ALLTRIM(NVL(crsRezR.sursa, '')) + ']' + ;
' scptva=' + TRANSFORM(crsRezR.scpTVA) + ' tvainc=' + TRANSFORM(crsRezR.tvaincasare) + ;
' split=' + TRANSFORM(crsRezR.splittva) + ' inactiv=' + TRANSFORM(crsRezR.inactiv)
DO WrLog4 WITH ' iScp=' + DTOC(crsRezR.data_inceput_ScpTVA) + ' sScp=' + DTOC(crsRezR.data_sfarsit_ScpTVA) + ;
' aScp=' + DTOC(crsRezR.data_anul_imp_ScpTVA) + ' iInc=' + DTOC(crsRezR.dataInceputTvaInc) + ;
' sInc=' + DTOC(crsRezR.dataSfarsitTvaInc)
DO WrLog4 WITH ' inactivare=' + DTOC(crsRezR.dataInactivare) + ' reactivare=' + DTOC(crsRezR.dataReactivare) + ;
' iSplit=' + DTOC(crsRezR.dataInceputSplitTVA) + ' aSplit=' + DTOC(crsRezR.dataAnulareSplitTVA)
DO WrLog4 WITH ' lungimi trimise: firma=' + TRANSFORM(LEN(NVL(crsRezR.firma, ''))) + ;
' adresa=' + TRANSFORM(LEN(NVL(crsRezR.adresa, ''))) + ;
' judet=' + TRANSFORM(LEN(NVL(crsRezR.judet, ''))) + ;
' regcom=' + TRANSFORM(LEN(NVL(crsRezR.nrRegCom, '')))
DO WrLog4 WITH ' firma=[' + NVL(crsRezR.firma, '') + ']'
DO WrLog4 WITH ' adresa=[' + NVL(crsRezR.adresa, '') + ']'
DO AratatLungimiOracle WITH tnCodN
SELECT (lcSel)
ENDPROC
*** lungimile reale, in Oracle, ale campurilor text din randurile codului
PROCEDURE AratatLungimiOracle
LPARAMETERS tnCodN
LOCAL lcSql
lcSql = 'SELECT ID, LENGTH(FIRMA) AS LF, LENGTH(ADRESA) AS LA, LENGTH(JUDET) AS LJ,'
lcSql = lcSql + ' LENGTH(REGCOM) AS LR, LENGTH(CODPOSTAL) AS LC, LENGTH(TELEFON) AS LT,'
lcSql = lcSql + ' LENGTH(FAX) AS LX, LENGTH(DATATVAMFIN) AS LD, LENGTH(STARE) AS LS'
lcSql = lcSql + ' FROM ISTORIC_CODURI_FISCALE WHERE COD_FISCAL_N = ' + TRANSFORM(tnCodN) + ' ORDER BY ID'
IF goExecutor.oExecuta(lcSql, 'crsLen')
DO WrLog4 WITH ' lungimi in Oracle (NULL = gol):'
SELECT crsLen
SCAN
DO WrLog4 WITH ' id=' + TRANSFORM(crsLen.ID) + ' firma=' + TRANSFORM(NVL(crsLen.LF, -1)) + ;
' adresa=' + TRANSFORM(NVL(crsLen.LA, -1)) + ' judet=' + TRANSFORM(NVL(crsLen.LJ, -1)) + ;
' regcom=' + TRANSFORM(NVL(crsLen.LR, -1)) + ' cp=' + TRANSFORM(NVL(crsLen.LC, -1)) + ;
' tel=' + TRANSFORM(NVL(crsLen.LT, -1)) + ' fax=' + TRANSFORM(NVL(crsLen.LX, -1)) + ;
' dtvamfin=' + TRANSFORM(NVL(crsLen.LD, -1)) + ' stare=' + TRANSFORM(NVL(crsLen.LS, -1))
SELECT crsLen
ENDSCAN
USE IN (SELECT('crsLen'))
ENDIF
ENDPROC
PROCEDURE ComparaCuAnterior
LPARAMETERS tnCodN, tnIdNou
LOCAL lcSql, lcLinie
lcSql = 'SELECT ID, COD_FISCAL, FIRMA, ADRESA, JUDET, REGCOM, CODPOSTAL, TELEFON, FAX,'
lcSql = lcSql + ' DATA_INCEPUT_SCPTVA, DATA_SFARSIT_SCPTVA, DATA_ANUL_IMP_SCPTVA,'
lcSql = lcSql + ' DATA_INCEPUT_TVAINC, DATA_SFARSIT_TVAINC, DATA_INACTIVARE, DATA_REACTIVARE,'
lcSql = lcSql + ' DATA_INCEPUT_SPLITTVA, DATA_ANULARE_SPLITTVA,'
lcSql = lcSql + ' DATATVAMFIN, PLATITORTVAMFIN, STARE, PLATITORTVAVIES, INACTIV, TVAINCASARE, SPLITTVA,'
lcSql = lcSql + ' TO_CHAR(DATAORAV,' + CHR(39) + 'DD.MM.YYYY HH24:MI' + CHR(39) + ') AS DORAV, SCHEMA_SURSA'
lcSql = lcSql + ' FROM ISTORIC_CODURI_FISCALE WHERE COD_FISCAL_N = ' + TRANSFORM(tnCodN)
lcSql = lcSql + ' ORDER BY ID'
IF !goExecutor.oExecuta(lcSql, 'crsIst')
DO WrLog4 WITH ' eroare la citirea istoricului codului'
RETURN
ENDIF
DO WrLog4 WITH ' istoricul codului (' + TRANSFORM(RECCOUNT('crsIst')) + ' randuri):'
SELECT crsIst
SCAN
lcLinie = ' ' + IIF(crsIst.ID = tnIdNou, '>>', ' ') + ' id=' + TRANSFORM(crsIst.ID) + ;
' cf=[' + ALLTRIM(NVL(crsIst.COD_FISCAL, '')) + ']' + ;
' firma=[' + ALLTRIM(LEFT(NVL(crsIst.FIRMA, ''), 30)) + ']' + ;
' adresa=[' + ALLTRIM(LEFT(NVL(crsIst.ADRESA, ''), 25)) + ']' + ;
' judet=[' + ALLTRIM(NVL(crsIst.JUDET, '')) + ']' + ;
' regcom=[' + ALLTRIM(NVL(crsIst.REGCOM, '')) + ']'
DO WrLog4 WITH lcLinie
lcLinie = ' cp=[' + ALLTRIM(NVL(crsIst.CODPOSTAL, '')) + ']' + ;
' tel=[' + ALLTRIM(NVL(crsIst.TELEFON, '')) + ']' + ;
' fax=[' + ALLTRIM(NVL(crsIst.FAX, '')) + ']' + ;
' dtvamfin=[' + ALLTRIM(NVL(crsIst.DATATVAMFIN, '')) + ']' + ;
' ptvamfin=' + TRANSFORM(NVL(crsIst.PLATITORTVAMFIN, -1)) + ;
' stare=[' + ALLTRIM(NVL(crsIst.STARE, '')) + ']' + ;
' vies=' + TRANSFORM(NVL(crsIst.PLATITORTVAVIES, -1)) + ;
' inactiv=' + TRANSFORM(NVL(crsIst.INACTIV, -1)) + ;
' tvainc=' + TRANSFORM(NVL(crsIst.TVAINCASARE, -1)) + ;
' split=' + TRANSFORM(NVL(crsIst.SPLITTVA, -1)) + ;
' dataorav=' + ALLTRIM(NVL(crsIst.DORAV, '')) + ;
' schema=' + ALLTRIM(NVL(crsIst.SCHEMA_SURSA, ''))
DO WrLog4 WITH lcLinie
lcLinie = ' iScp=' + DTOC(NVL(crsIst.DATA_INCEPUT_SCPTVA, {})) + ;
' sScp=' + DTOC(NVL(crsIst.DATA_SFARSIT_SCPTVA, {})) + ;
' aScp=' + DTOC(NVL(crsIst.DATA_ANUL_IMP_SCPTVA, {})) + ;
' iInc=' + DTOC(NVL(crsIst.DATA_INCEPUT_TVAINC, {})) + ;
' sInc=' + DTOC(NVL(crsIst.DATA_SFARSIT_TVAINC, {})) + ;
' inact=' + DTOC(NVL(crsIst.DATA_INACTIVARE, {})) + ;
' react=' + DTOC(NVL(crsIst.DATA_REACTIVARE, {})) + ;
' iSpl=' + DTOC(NVL(crsIst.DATA_INCEPUT_SPLITTVA, {})) + ;
' aSpl=' + DTOC(NVL(crsIst.DATA_ANULARE_SPLITTVA, {}))
DO WrLog4 WITH lcLinie
SELECT crsIst
ENDSCAN
USE IN (SELECT('crsIst'))
ENDPROC
PROCEDURE WrLog4
LPARAMETERS tcText
STRTOFILE(TRANSFORM(tcText) + CHR(13) + CHR(10), gcTestLog, .T.)
ENDPROC
PROCEDURE ErrRand
LPARAMETERS tnError, tcMessage, tcProgram, tnLine
DO WrLog4 WITH 'EROARE ' + TRANSFORM(tnError) + ' [' + TRANSFORM(tcMessage) + '] in ' + ;
TRANSFORM(tcProgram) + ' linia ' + TRANSFORM(tnLine)
RETURN
ENDPROC
DEFINE CLASS oexec_fara_dialog2 AS oexecutor
FUNCTION oExecuta
LPARAMETERS tcSql, tcCursor, tlProgress, tcTitluProgress, tnHandle, tlShowError, tlQuitOnError, tlReconnect
LOCAL lcSql, lcCursor, lnHandle, lnRez
lcSql = IIF(EMPTY(tcSql), This.cSql, tcSql)
lcCursor = IIF(EMPTY(tcCursor), This.cCursor, tcCursor)
lnHandle = IIF(EMPTY(tnHandle), This.nHandle, tnHandle)
lnRez = This.oExecute(lcSql, lcCursor, tlProgress, tcTitluProgress, lnHandle)
IF lnRez < 1
gnErorriSQL = gnErorriSQL + 1
gcUltimaEroareSQL = TRANSFORM(This.cEroare)
ENDIF
RETURN (lnRez >= 1)
ENDFUNC
ENDDEFINE
DEFINE CLASS VerificareANAFRand AS VerificareANAF
PROCEDURE OrdineCache
LPARAMETERS tcTraseu
RETURN 'CACHE,ANAF'
ENDPROC
PROCEDURE ANAF_SincronWebService_PlatitorTva
LPARAMETERS tcCursorListaCIF, tdData, tcAlias
gnApeluriANAF = gnApeluriANAF + 1
RETURN IIF(EMPTY(tcAlias), 'crsANAF', tcAlias)
ENDPROC
ENDDEFINE
Reference in New Issue View Git Blame Copy Permalink