diff --git a/PLGP/PLGP.sql b/PLGP/PLGP.sql index cb0109fbd..7288007b2 100644 --- a/PLGP/PLGP.sql +++ b/PLGP/PLGP.sql @@ -22,31 +22,52 @@ SET DEFINE OFF ------ payload begin ------ ---CREATE OR REPLACE PACKAGE PLGP ---AS +CREATE OR REPLACE PACKAGE PLGP +AS + FUNCTION getfirststartdate(p_startdatum IN DATE, p_refdatum IN DATE, p_cyclus IN NUMBER) + RETURN DATE; - ---END; ---/ +END; +/ ---CREATE OR REPLACE PACKAGE BODY PLGP ---AS - +CREATE OR REPLACE PACKAGE BODY PLGP +AS + FUNCTION getfirststartdate(p_startdatum IN DATE, p_refdatum IN DATE, p_cyclus IN NUMBER) + RETURN DATE + AS + v_startdatum DATE; + BEGIN + IF (p_startdatum0) + THEN + v_startdatum := ADD_MONTHS(p_startdatum, p_cyclus*12); + + IF (v_startdatum'GROEP' - AND UPPER(rec.obj_soort)<> 'ELEMENT') - THEN + + IF ( UPPER(rec.groep)<>'GROEP' + AND UPPER(rec.obj_soort)<> 'ELEMENT') + THEN - -- Laten we vast de object structuur aanmaken - v_aanduiding:='Ophalen discipline '; - BEGIN - SElECT ins_discipline_key - INTO v_ins_discipline_key - FROM ins_tab_discipline i - WHERE i.ins_discipline_omschrijving='MJOB' - AND i.ins_discipline_verwijder IS NULL; - EXCEPTION - WHEN NO_DATA_FOUND THEN - INSERT INTO ins_tab_discipline (ins_discipline_aanmaak, - ins_discipline_module, - ins_discipline_omschrijving) - VALUES (SYSDATE, 'INS','MJOB') - RETURNING ins_discipline_key - INTO v_ins_discipline_key; - END; - - IF v_ins_discipline_key>0 THEN - v_aanduiding:='Ophalen srtgroep '||rec.groep; - BEGIN - SELECT ins_srtgroep_key INTO v_ins_srtgroep_key - FROM ins_srtgroep sg - WHERE sg.ins_discipline_key=v_ins_discipline_key - AND sg.ins_srtgroep_upper=UPPER(rec.groep) - AND sg.ins_srtgroep_verwijder IS NULL; - EXCEPTION - WHEN NO_DATA_FOUND THEN - INSERT INTO ins_srtgroep(ins_discipline_key, - ins_srtgroep_omschrijving, - ins_srtgroep_module, - ins_srtgroep_upper, - ins_srtgroep_aanmaak) - VALUES(v_ins_discipline_key, - rec.groep, - 'INS', - UPPER(rec.groep), - SYSDATE) - RETURNING ins_srtgroep_key - INTO v_ins_srtgroep_key; - END; - v_aanduiding:='Ophalen srtobject '||rec.obj_soort; - BEGIN - SELECT isd.ins_srtdeel_key INTO v_ins_srtdeel_key - FROM ins_srtdeel isd - WHERE UPPER(isd.INS_SRTDEEL_OMSCHRIJVING) = UPPER(rec.obj_soort) - AND isd.INS_SRTGROEP_KEY = v_ins_srtgroep_key - AND isd.INS_SRTDEEL_VERWIJDER IS NULL; - EXCEPTION - WHEN NO_DATA_FOUND THEN - INSERT INTO ins_srtdeel(ins_srtgroep_key, - ins_srtdeel_module, - ins_srtdeel_code, - ins_srtdeel_code_upper, - ins_srtdeel_omschrijving, - ins_srtdeel_upper, - ins_srtdeel_binding, - ins_srtdeel_aanmaak, - ins_srtdeel_eenheid) - VALUES(v_ins_srtgroep_key, - 'INS', - rec.nlsfb, - UPPER(rec.nlsfb), - rec.obj_soort, - UPPER(rec.obj_soort), - 1, -- allen ruimtes - SYSDATE, - rec.eenheid) - RETURNING ins_srtdeel_key - INTO v_ins_srtdeel_key; - - END; - -- Moeten we nog meer controleren ?? - -- Nog een keer lkopen - -- dan kijken of het een uniek obejct is maar hoe - -- IS de groep, soort, locatie en aantal gelijk dan zalhet een beknde zijn. - - v_nu:= 'NU:('||v_count||') '||rec.groep||'-'||rec.obj_soort||'-'||rec.locatie||'-'||rec.aantal||'-'||rec.eenheid; - v_was:= 'VORIGE:'||v_groep_vorige||'-'|| v_obj_soort_vorige||'-'||v_locatie_vorige||'-'||v_aantal_vorige||'-'||v_eenheid_vorige; - -- fac.imp_writelog (p_import_key, - -- 'W', - -- v_was, - -- v_nu); - IF ( (rec.groep<>v_groep_vorige - OR rec.obj_soort <> v_obj_soort_vorige - OR rec.fabrikant <> v_fabrikant_vorige - OR rec.type <> v_type_vorige - OR rec.locatie <> v_locatie_vorige - OR rec.aantal <> v_aantal_vorige - OR rec.eenheid <> v_eenheid_vorige) - OR v_count=2) - THEN - -- volgens mij hebben we nu een nieuw object. - v_aanduiding:='Ophalen ruimte '||rec.locatie; - BEGIN - select a.alg_ruimte_key - INTO v_ruimte_key - from ALG_V_ALLONRGOED_GEGEVENS a , alg_locatie l - WHERE l.alg_locatie_code=v_locatie_code - AND a.alg_locatie_key= l.alg_locatie_key - AND a.alg_gebouw_code=v_gebouw_code - AND a.alg_verdieping_code = v_verdieping_code - AND UPPER(alg_ruimte_Omschrijving) like UPPER(rec.locatie||'%'); - - EXCEPTION - WHEN OTHERS - THEN - v_ruimte_key:=p_ruimte_key; - END; - - IF length(rec.bouwjaar)=4 - THEN + -- Laten we vast de object structuur aanmaken + v_aanduiding:='Ophalen discipline '; + BEGIN + SElECT ins_discipline_key + INTO v_ins_discipline_key + FROM ins_tab_discipline i + WHERE i.ins_discipline_omschrijving='MJOB' + AND i.ins_discipline_verwijder IS NULL; + EXCEPTION + WHEN NO_DATA_FOUND THEN + INSERT INTO ins_tab_discipline (ins_discipline_aanmaak, + ins_discipline_module, + ins_discipline_omschrijving) + VALUES (SYSDATE, 'INS','MJOB') + RETURNING ins_discipline_key + INTO v_ins_discipline_key; + + INSERT INTO ins_disc_params(ins_discipline_key, ins_disc_params_type,ins_disc_params_autonum) + VALUES(v_ins_discipline_key,0,3); + END; + + IF v_ins_discipline_key>0 THEN + v_aanduiding:='Ophalen srtgroep '||rec.groep; + BEGIN + SELECT ins_srtgroep_key INTO v_ins_srtgroep_key + FROM ins_srtgroep sg + WHERE sg.ins_discipline_key=v_ins_discipline_key + AND sg.ins_srtgroep_upper=UPPER(rec.groep) + AND sg.ins_srtgroep_verwijder IS NULL; + EXCEPTION + WHEN NO_DATA_FOUND THEN + INSERT INTO ins_srtgroep(ins_discipline_key, + ins_srtgroep_omschrijving, + ins_srtgroep_module, + ins_srtgroep_upper, + ins_srtgroep_aanmaak) + VALUES(v_ins_discipline_key, + rec.groep, + 'INS', + UPPER(rec.groep), + SYSDATE) + RETURNING ins_srtgroep_key + INTO v_ins_srtgroep_key; + END; + v_aanduiding:='Ophalen srtobject '||rec.obj_soort; + BEGIN + SELECT isd.ins_srtdeel_key INTO v_ins_srtdeel_key + FROM ins_srtdeel isd + WHERE UPPER(isd.INS_SRTDEEL_OMSCHRIJVING) = UPPER(rec.obj_soort) + AND isd.INS_SRTGROEP_KEY = v_ins_srtgroep_key + AND isd.INS_SRTDEEL_VERWIJDER IS NULL; + EXCEPTION + WHEN NO_DATA_FOUND THEN + INSERT INTO ins_srtdeel(ins_srtgroep_key, + ins_srtdeel_module, + ins_srtdeel_code, + ins_srtdeel_code_upper, + ins_srtdeel_omschrijving, + ins_srtdeel_upper, + ins_srtdeel_binding, + ins_srtdeel_aanmaak, + ins_srtdeel_eenheid) + VALUES(v_ins_srtgroep_key, + 'INS', + rec.nlsfb, + UPPER(rec.nlsfb), + rec.obj_soort, + UPPER(rec.obj_soort), + 1, -- allen ruimtes + SYSDATE, + rec.eenheid) + RETURNING ins_srtdeel_key + INTO v_ins_srtdeel_key; + + END; + -- Moeten we nog meer controleren ?? + -- Nog een keer lkopen + -- dan kijken of het een uniek obejct is maar hoe + -- IS de groep, soort, locatie en aantal gelijk dan zalhet een beknde zijn. + + v_nu:= 'NU:('||v_count||') '||rec.groep||'-'||rec.obj_soort||'-'||rec.locatie||'-'||rec.aantal||'-'||rec.eenheid; + v_was:= 'VORIGE:'||v_groep_vorige||'-'|| v_obj_soort_vorige||'-'||v_locatie_vorige||'-'||v_aantal_vorige||'-'||v_eenheid_vorige; + -- fac.imp_writelog (p_import_key, + -- 'W', + -- v_was, + -- v_nu); + IF ( (rec.groep<>v_groep_vorige + OR rec.obj_soort <> v_obj_soort_vorige + OR rec.fabrikant <> v_fabrikant_vorige + OR rec.type <> v_type_vorige + OR rec.locatie <> v_locatie_vorige + OR rec.aantal <> v_aantal_vorige + OR rec.eenheid <> v_eenheid_vorige) + OR v_count=2) + THEN + -- volgens mij hebben we nu een nieuw object. + v_aanduiding:='Ophalen ruimte '||rec.locatie; + BEGIN + select a.alg_ruimte_key + INTO v_ruimte_key + from ALG_V_ALLONRGOED_GEGEVENS a , alg_locatie l + WHERE l.alg_locatie_code=v_locatie_code + AND a.alg_locatie_key= l.alg_locatie_key + AND a.alg_gebouw_code=v_gebouw_code + AND a.alg_verdieping_code = v_verdieping_code + AND UPPER(alg_ruimte_Omschrijving) like UPPER(rec.locatie||'%'); + + EXCEPTION + WHEN OTHERS + THEN + v_ruimte_key:=p_ruimte_key; + END; + + IF length(rec.bouwjaar)=4 + THEN v_bouwjaar:=fac.safe_to_date('01-01-'||rec.bouwjaar,'DD-MM-YYYY'); ELSE v_bouwjaar:=TRUNC(SYSDATE); - END IF; - IF INSTR(rec.aantal,',')>0 - THEN + END IF; + IF INSTR(rec.aantal,',')>0 + THEN v_aantal:=fac.safe_to_number(SUBSTR(rec.aantal,0, INSTR(rec.aantal,',')-1)); - ELSE + ELSE v_aantal:=fac.safe_to_number(rec.aantal); - END IF; - v_aanduiding:='Aanmaken object '||v_objectid; - BEGIN + END IF; + v_aanduiding:='Aanmaken object '||v_objectid; + BEGIN SELECT i.ins_deel_key INTO v_ins_deel_key FROM ins_deel i @@ -280,9 +300,9 @@ BEGIN AND ins_discipline_key = v_ins_discipline_key AND ins_srtdeel_key = v_ins_srtdeel_key AND ins_deel_opmerking = COALESCE(rec.fabrikant,'')||' '||COALESCE(rec.type,'')||' ('||rec.locatie||')'; - EXCEPTION - WHEN NO_DATA_FOUND THEN - + EXCEPTION + WHEN NO_DATA_FOUND THEN + INSERT INTO ins_deel (ins_discipline_key, ins_srtdeel_key, ins_deel_module, @@ -307,30 +327,30 @@ BEGIN COALESCE(v_aantal,1)) RETURNING ins_deel_key INTO v_ins_deel_key; - END; + END; END IF; - v_groep_vorige:=rec.groep; - v_obj_soort_vorige:=rec.obj_soort; - v_locatie_vorige:=rec.locatie; - v_aantal_vorige:=rec.aantal; - v_eenheid_vorige:=rec.eenheid; - v_fabrikant_vorige:=rec.fabrikant; - v_type_vorige:=rec.type; - UPDATE fac_imp_csv - SET fac_imp_csv_col50=v_ins_deel_key - WHERE fac_imp_csv_key=rec.fac_imp_csv_key; - ELSE - - fac.imp_writelog (p_import_key, - 'W', - 'Disipline MJOB', - 'Discipline niet gevonden'); - END IF; - - END IF; - END LOOP; - + v_groep_vorige:=rec.groep; + v_obj_soort_vorige:=rec.obj_soort; + v_locatie_vorige:=rec.locatie; + v_aantal_vorige:=rec.aantal; + v_eenheid_vorige:=rec.eenheid; + v_fabrikant_vorige:=rec.fabrikant; + v_type_vorige:=rec.type; + UPDATE fac_imp_csv + SET fac_imp_csv_col50=v_ins_deel_key + WHERE fac_imp_csv_key=rec.fac_imp_csv_key; + ELSE + + fac.imp_writelog (p_import_key, + 'W', + 'Disipline MJOB', + 'Discipline niet gevonden'); + END IF; + + END IF; + END LOOP; + EXCEPTION WHEN NO_DATA_FOUND THEN @@ -341,7 +361,7 @@ THEN fac.imp_writelog (p_import_key, 'E', v_errormsg, - v_errorhint); + v_errorhint); END; / @@ -349,10 +369,10 @@ END; CREATE OR REPLACE PROCEDURE PLGP_UPDATE_MJOB_TAKEN(p_import_key IN NUMBER) AS - CURSOR obj - IS - SELECT fac_imp_csv_key fac_imp_csv_key, - fac_imp_csv_col01 groep, + CURSOR obj + IS + SELECT fac_imp_csv_key fac_imp_csv_key, + fac_imp_csv_col01 groep, fac_imp_csv_col50 ins_deel_key, fac_imp_csv_col02 ins_srtdeel_code, fac_imp_csv_col06 aantal, @@ -362,74 +382,74 @@ AS fac_imp_csv_col11 startjaar, fac_imp_csv_col13 cyclus, fac_imp_csv_col20 kosten - FROM fac_imp_csv - WHERE fac_import_key=p_import_key - ORDER BY fac_imp_csv_key; + FROM fac_imp_csv + WHERE fac_import_key=p_import_key + ORDER BY fac_imp_csv_key; - v_errormsg VARCHAR2 (1000); - v_errorhint VARCHAR2 (1000); - v_aanduiding VARCHAR2 (1000); - oracle_err_num NUMBER; - oracle_err_mes VARCHAR2 (200); - - v_taak_datum DATE; - v_cyclus_eenheid NUMBER; - v_taakcat_key NUMBER; - v_srtcontrole_key NUMBER; - v_srtkenmerk_doc NUMBER; - v_ins_discipline_key NUMBER; - v_ins_srtgroep_key NUMBER; + v_errormsg VARCHAR2 (1000); + v_errorhint VARCHAR2 (1000); + v_aanduiding VARCHAR2 (1000); + oracle_err_num NUMBER; + oracle_err_mes VARCHAR2 (200); + + v_taak_datum DATE; + v_cyclus_eenheid NUMBER; + v_taakcat_key NUMBER; + v_srtcontrole_key NUMBER; + v_srtkenmerk_doc NUMBER; + v_ins_discipline_key NUMBER; + v_ins_srtgroep_key NUMBER; v_ins_srtdeel_key NUMBER; - v_ins_srtcontrole_niveau VARCHAR2(1); - v_kosten NUMBER; - v_kosten_eenheid NUMBER; - v_aantal NUMBER; - v_ins_srtcontroledl_xcp_key NUMBER; - v_count NUMBER; + v_ins_srtcontrole_niveau VARCHAR2(1); + v_kosten NUMBER; + v_kosten_eenheid NUMBER; + v_aantal NUMBER; + v_ins_srtcontroledl_xcp_key NUMBER; + v_count NUMBER; BEGIN v_count:=0; - v_cyclus_eenheid:=4; - v_ins_srtcontrole_niveau:='S'; - - v_aanduiding:= 'Fout bij taak categorie MJOB Vervanging'; - SELECT ins_discipline_key + v_cyclus_eenheid:=4; + v_ins_srtcontrole_niveau:='S'; + + v_aanduiding:= 'Fout bij taak categorie MJOB Vervanging'; + SELECT ins_discipline_key INTO v_taakcat_key FROM ins_tab_discipline WHERE ins_discipline_module='CTR' AND UPPER(ins_discipline_omschrijving) = UPPER('MJOB-Vervanging') AND ins_discipline_verwijder IS NULL; - - BEGIN - SELECT ins_srtkenmerk_key - INTO v_srtkenmerk_doc - FROM ins_srtkenmerk i - WHERE i.ins_srtkenmerk_code='DOCUMENTEN' - AND i.ins_srtkenmerk_verwijder IS NULL; + + BEGIN + SELECT ins_srtkenmerk_key + INTO v_srtkenmerk_doc + FROM ins_srtkenmerk i + WHERE i.ins_srtkenmerk_code='DOCUMENTEN' + AND i.ins_srtkenmerk_verwijder IS NULL; EXCEPTION WHEN NO_DATA_FOUND THEN v_srtkenmerk_doc:=-1; END; - - FOR rec in obj - LOOP - v_count:=v_count+1; + + FOR rec in obj + LOOP + v_count:=v_count+1; IF (rec.groep<>'Groep') THEN -- fac.imp_writelog (p_import_key, - -- 'W', - -- 'Regel '||v_count, - -- rec.groep||'-'||rec.ins_deel_key); + -- 'W', + -- 'Regel '||v_count, + -- rec.groep||'-'||rec.ins_deel_key); -- COMMIT; - v_aanduiding:= 'Fout bij ophalen object :'||rec.ins_deel_key; - - SELECT ins_discipline_key, ins_srtgroep_key, ins_srtdeel_key + v_aanduiding:= 'Fout bij ophalen object :'||rec.ins_deel_key; + + SELECT ins_discipline_key, ins_srtgroep_key, ins_srtdeel_key INTO v_ins_discipline_key, v_ins_srtgroep_key, v_ins_srtdeel_key FROM ins_v_deel_gegevens WHERE ins_deel_key = rec.ins_deel_key; - + BEGIN SELECT ins_srtcontrole_key INTO v_srtcontrole_key @@ -470,7 +490,7 @@ BEGIN ins_srtkenmerk_key, ins_srtinstallatie_key, ins_kenmerk_niveau, - ins_kenmerk_bewerkniveau, + ins_kenmerk_bewerkniveau, ins_kenmerk_groep, ins_kenmerk_volgnummer, ins_kenmerk_hint, @@ -487,74 +507,74 @@ BEGIN 'Documenten' ); END IF; - END; - - IF LENGTH(rec.startjaar)=4 - THEN - -- Alleen wat doen als we ook een startjaar hebben. - - v_taak_datum:=fac.safe_to_date('01-01-'||rec.startjaar,'DD-MM-YYYY'); - v_kosten := fac.safe_to_number(REPLACE((REPLACE(REPLACE(rec.kosten,'€',''),'.','')),',','.')); - IF INSTR(rec.aantal,',')>0 - THEN + END; + + IF LENGTH(rec.startjaar)=4 + THEN + -- Alleen wat doen als we ook een startjaar hebben. + + v_taak_datum:=fac.safe_to_date('01-01-'||rec.startjaar,'DD-MM-YYYY'); + v_kosten := fac.safe_to_number(REPLACE((REPLACE(REPLACE(rec.kosten,'€',''),'.','')),',','.')); + IF INSTR(rec.aantal,',')>0 + THEN v_aantal:=fac.safe_to_number(SUBSTR(rec.aantal,0, INSTR(rec.aantal,',')-1)); ELSE v_aantal:=fac.safe_to_number(rec.aantal); END IF; v_kosten_eenheid:=v_kosten/v_aantal; - - BEGIN - SELECT ins_srtcontroledl_xcp_key - INTO v_ins_srtcontroledl_xcp_key - FROM ins_srtcontroledl_xcp - WHERE ins_srtcontrole_key=v_srtcontrole_key - AND ins_deel_key=rec.ins_deel_key - AND ins_srtcontroledl_xcp_eenheid=v_cyclus_eenheid - AND ins_srtcontroledl_xcp_aantal=v_aantal - AND ins_srtcontroledl_xcp_periode=rec.cyclus - AND ins_srtcontroledl_xcp_startdat=v_taak_datum - AND ins_srtcontroledl_xcp_aanteh = rec.eenheid - AND ins_scenario_key=1; - - UPDATE ins_srtcontroledl_xcp - SET ins_srtcontroledl_xcp_kosten = v_kosten_eenheid - WHERE ins_srtcontroledl_xcp_key = v_ins_srtcontroledl_xcp_key; - EXCEPTION - WHEN NO_DATA_FOUND - THEN - - v_aanduiding:='Fout bij toevoegen XCP record voor object '||rec.ins_deel_key||' voor controle '||v_srtcontrole_key; - - INSERT INTO ins_srtcontroledl_xcp - (ins_srtcontrole_key, - ins_deel_key, - ins_srtcontroledl_xcp_eenheid, - ins_srtcontroledl_xcp_aantal, - ins_srtcontroledl_xcp_periode, - ins_srtcontroledl_xcp_startdat, - ins_srtcontroledl_xcp_kosten, - ins_srtcontroledl_xcp_opmerk, - ins_srtcontroledl_xcp_aanteh) - VALUES (v_srtcontrole_key, - rec.ins_deel_key, - v_cyclus_eenheid, - v_aantal, - rec.cyclus, - v_taak_datum, - v_kosten_eenheid, - SUBSTR(rec.taak_opm,0,300), - rec.eenheid); - END; + + BEGIN + SELECT ins_srtcontroledl_xcp_key + INTO v_ins_srtcontroledl_xcp_key + FROM ins_srtcontroledl_xcp + WHERE ins_srtcontrole_key=v_srtcontrole_key + AND ins_deel_key=rec.ins_deel_key + AND ins_srtcontroledl_xcp_eenheid=v_cyclus_eenheid + AND ins_srtcontroledl_xcp_aantal=v_aantal + AND ins_srtcontroledl_xcp_periode=rec.cyclus + AND ins_srtcontroledl_xcp_startdat=v_taak_datum + AND ins_srtcontroledl_xcp_aanteh = rec.eenheid + AND ins_scenario_key=1; + + UPDATE ins_srtcontroledl_xcp + SET ins_srtcontroledl_xcp_kosten = v_kosten_eenheid + WHERE ins_srtcontroledl_xcp_key = v_ins_srtcontroledl_xcp_key; + EXCEPTION + WHEN NO_DATA_FOUND + THEN + + v_aanduiding:='Fout bij toevoegen XCP record voor object '||rec.ins_deel_key||' voor controle '||v_srtcontrole_key; + + INSERT INTO ins_srtcontroledl_xcp + (ins_srtcontrole_key, + ins_deel_key, + ins_srtcontroledl_xcp_eenheid, + ins_srtcontroledl_xcp_aantal, + ins_srtcontroledl_xcp_periode, + ins_srtcontroledl_xcp_startdat, + ins_srtcontroledl_xcp_kosten, + ins_srtcontroledl_xcp_opmerk, + ins_srtcontroledl_xcp_aanteh) + VALUES (v_srtcontrole_key, + rec.ins_deel_key, + v_cyclus_eenheid, + v_aantal, + rec.cyclus, + v_taak_datum, + v_kosten_eenheid, + SUBSTR(rec.taak_opm,0,300), + rec.eenheid); + END; END IF; - - - END IF; - - - - END LOOP; - + + + END IF; + + + + END LOOP; + EXCEPTION WHEN NO_DATA_FOUND THEN @@ -568,6 +588,1315 @@ THEN v_errorhint); END; / +-- Einde MJOB import op basis van Excel sheet + +-- IMPORTS +-- MJOB elementen import van O-Prognose XML Object export +CREATE OR REPLACE PROCEDURE plgp_import_mjobelementen (p_import_key IN NUMBER) +IS + c_delim VARCHAR2 (2) := fac.import_delimiter(p_import_key); + v_newline fac_imp_file.fac_imp_file_line%TYPE; -- Input line + v_errormsg VARCHAR2 (1000); + v_errorhint VARCHAR2 (1000); + oracle_err_num NUMBER; + oracle_err_mes VARCHAR2 (200); + header_is_valid NUMBER; + v_count_tot NUMBER (10); + v_count_import NUMBER (10); + v_ongeldig NUMBER (1); + v_aanduiding VARCHAR (400); + v_dummy VARCHAR (255); + v_ins_kenmerk_key1 VARCHAR2 (255); + v_ins_kenmerk_key2 VARCHAR2 (255); + v_ins_kenmerk_key3 VARCHAR2 (255); + v_ins_kenmerk_key4 VARCHAR2 (255); + v_ins_kenmerk_key5 VARCHAR2 (255); + v_ins_kenmerk_key6 VARCHAR2 (255); + v_ins_kenmerk_key7 VARCHAR2 (255); + v_ins_kenmerk_key8 VARCHAR2 (255); + v_ins_kenmerk_key9 VARCHAR2 (255); + v_ins_kenmerk_key10 VARCHAR2 (255); + v_ins_kenmerk_key11 VARCHAR2 (255); + v_ins_kenmerk_key12 VARCHAR2 (255); + v_ins_kenmerk_key13 VARCHAR2 (255); + v_ins_kenmerk_key14 VARCHAR2 (255); + v_ins_kenmerk_key15 VARCHAR2 (255); + v_ins_kenmerk_key16 VARCHAR2 (255); + v_ins_kenmerk_key17 VARCHAR2 (255); + v_ins_kenmerk_key18 VARCHAR2 (255); + v_ins_kenmerk_key19 VARCHAR2 (255); + v_ins_kenmerk_key20 VARCHAR2 (255); + -- De importvelden + v_ins_discipline_omschrijving VARCHAR2 (255); -- C60 + v_ins_discipline_kostensoort VARCHAR2 (255); --C60 + v_ins_srtgroep_omschrijving VARCHAR2 (255); -- C60 + v_ins_srtdeel_code VARCHAR2 (255); -- C10 + v_ins_srtdeel_omschrijving VARCHAR2 (255); -- C100 + v_ins_deel_omschrijving VARCHAR2 (255); -- C60 + v_ins_deel_opmerking VARCHAR2 (1000); -- C320 + v_ins_deel_externnr VARCHAR2 (255); -- C60 + v_alg_locatie_code VARCHAR2 (255); -- C10 + v_alg_gebouw_code VARCHAR2 (255); -- C12 + v_oprognose_gebouw_code VARCHAR2 (255); + v_alg_verdieping_volgnr VARCHAR2 (255); -- N3 + v_alg_ruimte_nr VARCHAR2 (255); -- C20 + + v_ins_kenmerkwaarde1 VARCHAR2 (4053); + v_ins_kenmerkwaarde2 VARCHAR2 (4053); + v_ins_kenmerkwaarde3 VARCHAR2 (4053); + v_ins_kenmerkwaarde4 VARCHAR2 (4053); + v_ins_kenmerkwaarde5 VARCHAR2 (4053); + v_ins_kenmerkwaarde6 VARCHAR2 (4053); + v_ins_kenmerkwaarde7 VARCHAR2 (4053); + v_ins_kenmerkwaarde8 VARCHAR2 (4053); + v_ins_kenmerkwaarde9 VARCHAR2 (4053); + v_ins_kenmerkwaarde10 VARCHAR2 (4053); + v_ins_kenmerkwaarde11 VARCHAR2 (4053); + v_ins_kenmerkwaarde12 VARCHAR2 (4053); + v_ins_kenmerkwaarde13 VARCHAR2 (4053); + v_ins_kenmerkwaarde14 VARCHAR2 (4053); + v_ins_kenmerkwaarde15 VARCHAR2 (4053); + v_ins_kenmerkwaarde16 VARCHAR2 (4053); + v_ins_kenmerkwaarde17 VARCHAR2 (4053); + v_ins_kenmerkwaarde18 VARCHAR2 (4053); + v_ins_kenmerkwaarde19 VARCHAR2 (4053); + v_ins_kenmerkwaarde20 VARCHAR2 (4053); + v_ins_deel_aanmaak VARCHAR2 (255); -- DATE + v_ins_deel_aanmaak_d DATE; + v_ins_deel_vervaldatum VARCHAR2 (255); -- DATE + v_ins_deel_vervaldatum_d DATE; + v_ins_deel_aantal VARCHAR2 (255); -- N8,2 + v_ins_deel_aantal_n NUMBER(8, 2); + v_file_index NUMBER; + + v_alg_gebouw_key NUMBER; + v_alg_verdieping_key NUMBER; + v_alg_ruimte_key NUMBER; + v_ins_deel_key NUMBER; + v_ins_srtdeel_key NUMBER; + v_ins_srtgroep_key NUMBER; + v_ins_discipline_key NUMBER; + v_ins_deel_volgnr NUMBER; + -- Overige velden: + CURSOR c1 + IS + SELECT * + FROM fac_imp_file + WHERE fac_import_key = p_import_key + ORDER BY fac_imp_file_index; + + CURSOR c IS + SELECT * + FROM fac_imp_ins + ORDER BY alg_gebouw_code, ins_deel_omschrijving; + + -- Controleer tijdens import-fase alleen op het bestaan van een kenmerk met de meegegeven omschrijving of kenmerk key. + -- De omschrijving (header van kolom) kan de omschrijving zijn van het kenmerksoort of het kenmerk. + -- De omschrijving van het kenmerksoort kan namelijk overruled worden door de omschrijving van het kenmerk. + -- Daarnaast kan hetzelfde kenmerk vaker voorkomen voor verschillende groepen. + -- Of het kenmerksoort/kenmerk wel is gedefinieerd voor de betreffende + -- object-discipline/groep/soort, volgt pas tijdens de update-fase)! + -- + -- p_kw is bijvoorbeeld 'Parkeercode', 'Parkeercode|3', 234 of 234|3 waarbij de tweede en laatste in groep 3 zitten + -- het resultaat is NULL (als niet gevonden) of Parkeercode|3 of 234|3 voor kenmer_key 234 in groep 3 + -- Als geen groep is meegegeven dan wordt 'Parkeercode|0' opgeleverd (de default groep) + FUNCTION bepaal_kenmerk (p_kw IN VARCHAR) + RETURN VARCHAR + IS + v_kenmerk_key NUMBER; + v_kenmerk_groep NUMBER; + v_kw VARCHAR(250); + BEGIN + v_kenmerk_groep := 0; + v_kw := p_kw; + IF INSTR (v_kw, '|') > 1 + THEN + v_kenmerk_groep := SUBSTR (v_kw, INSTR (v_kw, '|') + 1); + v_kw := SUBSTR (v_kw, 1, INSTR (v_kw, '|') - 1); + END IF; + + IF fac.safe_to_number (v_kw) IS NULL + THEN -- kenmerkwaarde is alfanumeriek (dus omschrijving)! + SELECT MIN(k.ins_kenmerk_key) + INTO v_kenmerk_key + FROM ins_v_aanwezigkenmerk k, + ins_v_aanwezigsrtkenmerk sk + WHERE k.ins_srtkenmerk_key = sk.ins_srtkenmerk_key + AND k.ins_kenmerk_groep = v_kenmerk_groep + AND COALESCE(UPPER(k.ins_kenmerk_omschrijving), sk.ins_srtkenmerk_upper) = UPPER(v_kw) + AND sk.ins_srtkenmerk_kenmerktype IN ('C', 'D', 'N', 'R', 'S', 'X', 'B', 'V'); + ELSE -- kenmerkwaarde is numeriek (dus key)! + SELECT k.ins_kenmerk_key + INTO v_kenmerk_key + FROM ins_v_aanwezigkenmerk k, + ins_v_aanwezigsrtkenmerk sk + WHERE k.ins_srtkenmerk_key = sk.ins_srtkenmerk_key + AND k.ins_kenmerk_groep = v_kenmerk_groep + AND k.ins_kenmerk_key = fac.safe_to_number (v_kw) + AND sk.ins_srtkenmerk_kenmerktype IN ('C', 'D', 'N', 'R', 'S', 'X', 'B', 'V'); + END IF; + + IF v_kenmerk_key IS NULL + THEN + RETURN NULL; + ELSE + -- Er is een kenmerksoort of kenmerk aanwezig met de omschrijving/kenmerk_key (v_kw) + RETURN v_kw || '|' || TO_CHAR(v_kenmerk_groep); + END IF; + EXCEPTION + WHEN NO_DATA_FOUND + THEN + IF p_kw IS NULL OR UPPER (p_kw) LIKE 'KENMERK%' + THEN + RETURN NULL; + ELSE + fac.imp_writelog (p_import_key, + 'W', + 'Fout bij bepalen kenmerk [' || p_kw || ']', + 'Bestaat niet of type ongeldig'); + COMMIT; + RETURN NULL; + END IF; + END; + +BEGIN + -- Eerst opruiming + DELETE FROM fac_imp_ins; + + COMMIT; + + v_count_tot := 0; + v_count_import := 0; + header_is_valid := 0; + + FOR rec1 IN c1 + LOOP + BEGIN + v_newline := rec1.fac_imp_file_line; + v_file_index := rec1.fac_imp_file_index; + v_errormsg := 'Fout bij opvragen importregel'; + v_aanduiding := ''; + v_ongeldig := 0; + -- Lees alle veldwaarden + fac.imp_getfield (v_newline, c_delim, v_oprognose_gebouw_code); -- Objectcode + fac.imp_getfield (v_newline, c_delim, v_ins_srtdeel_code); -- Componentcode + fac.imp_getfield (v_newline, c_delim, v_ins_deel_externnr); -- Element-ID + fac.imp_getfield (v_newline, c_delim, v_ins_deel_opmerking); -- Component omschrijving +-- fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde1); -- Opmerkingen// + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde2); -- Fabrikant + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde3); -- Kenmerken + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde4); -- Type + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde5); -- Cap + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde6); -- Eenheid Cap + fac.imp_getfield (v_newline, c_delim, v_ins_deel_aantal); -- Aantal + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde7); -- Eenheid aantal + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde8); -- Bouwjaar + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde9); + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde10); + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde11); + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde12); + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde13); + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde14); + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde15); + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde16); + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde17); + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde18); + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde19); + fac.imp_getfield (v_newline, c_delim, v_ins_kenmerkwaarde20); + + v_aanduiding := + '[' + || v_alg_gebouw_code + || '|' + || v_ins_deel_externnr + || '|' + || v_ins_srtdeel_code + || '] '; + + -- Ik controleer of ik een geldige header heb, dat is: in de juiste kolommen + -- de juiste kolomkop. Ik controleer daarbij alle NIET-kenmerk kolommen! + -- Ik negeer alles totdat ik een geldige header ben gepasseerd. + IF (header_is_valid = 0) + THEN + IF UPPER (v_oprognose_gebouw_code) = 'GEBOUW_CODE' + AND UPPER (v_ins_srtdeel_code) = 'SRTDEEL_CODE' + AND UPPER (v_ins_deel_externnr) = 'DEEL_EXTERNNR' + AND UPPER (v_ins_deel_opmerking) = 'DEEL_OPMERKING' + AND UPPER (v_ins_kenmerkwaarde2) = 'FABRIKANT' + AND UPPER (v_ins_kenmerkwaarde3) = 'OPMERKINGEN' + AND UPPER (v_ins_kenmerkwaarde4) = 'TYPE' + AND UPPER (v_ins_kenmerkwaarde5) = 'CAP' + AND UPPER (v_ins_kenmerkwaarde6) = 'EENHEID CAP' + AND UPPER (v_ins_deel_aantal) = 'DEEL_AANTAL' + AND UPPER (v_ins_kenmerkwaarde7) = 'EENHEID AANTAL' + AND UPPER (v_ins_kenmerkwaarde8) = 'BOUWJAAR' + THEN + v_ins_kenmerk_key1 := bepaal_kenmerk (v_ins_kenmerkwaarde1); + v_ins_kenmerk_key2 := bepaal_kenmerk (v_ins_kenmerkwaarde2); + v_ins_kenmerk_key3 := bepaal_kenmerk (v_ins_kenmerkwaarde3); + v_ins_kenmerk_key4 := bepaal_kenmerk (v_ins_kenmerkwaarde4); + v_ins_kenmerk_key5 := bepaal_kenmerk (v_ins_kenmerkwaarde5); + v_ins_kenmerk_key6 := bepaal_kenmerk (v_ins_kenmerkwaarde6); + v_ins_kenmerk_key7 := bepaal_kenmerk (v_ins_kenmerkwaarde7); + v_ins_kenmerk_key8 := bepaal_kenmerk (v_ins_kenmerkwaarde8); + v_ins_kenmerk_key9 := bepaal_kenmerk (v_ins_kenmerkwaarde9); + v_ins_kenmerk_key10 := bepaal_kenmerk (v_ins_kenmerkwaarde10); + v_ins_kenmerk_key11 := bepaal_kenmerk (v_ins_kenmerkwaarde11); + v_ins_kenmerk_key12 := bepaal_kenmerk (v_ins_kenmerkwaarde12); + v_ins_kenmerk_key13 := bepaal_kenmerk (v_ins_kenmerkwaarde13); + v_ins_kenmerk_key14 := bepaal_kenmerk (v_ins_kenmerkwaarde14); + v_ins_kenmerk_key15 := bepaal_kenmerk (v_ins_kenmerkwaarde15); + v_ins_kenmerk_key16 := bepaal_kenmerk (v_ins_kenmerkwaarde16); + v_ins_kenmerk_key17 := bepaal_kenmerk (v_ins_kenmerkwaarde17); + v_ins_kenmerk_key18 := bepaal_kenmerk (v_ins_kenmerkwaarde18); + v_ins_kenmerk_key19 := bepaal_kenmerk (v_ins_kenmerkwaarde19); + v_ins_kenmerk_key20 := bepaal_kenmerk (v_ins_kenmerkwaarde20); + + header_is_valid := 1; + ELSE + IF rec1.fac_imp_file_index = 1 + THEN + + fac.imp_writelog (p_import_key, + 'E', + 'Ongeldige header aangetroffen:', + 'GEBOUW_CODE: ' || UPPER (v_alg_gebouw_code) || CHR(10) || + 'SRTDEEL_CODE: ' || UPPER (v_ins_srtdeel_code) || CHR(10) || + 'DEEL_EXTERNNR: ' || UPPER (v_ins_deel_externnr) || CHR(10) || + 'DEEL_OPMERKING: ' || UPPER (v_ins_deel_opmerking) || CHR(10) || + 'FABRIKANT: ' || UPPER (v_ins_kenmerkwaarde2) || CHR(10) || + 'OPMERKINGEN: ' || UPPER (v_ins_kenmerkwaarde3) || CHR(10) || + 'TYPE: ' || UPPER (v_ins_kenmerkwaarde4) || CHR(10) || + 'CAP: ' || UPPER (v_ins_kenmerkwaarde5) || CHR(10) || + 'EENHEID CAP: ' || UPPER (v_ins_kenmerkwaarde6) || CHR(10) || + 'DEEL_AANTAL: ' || UPPER (v_ins_deel_aantal) || CHR(10) || + 'EENHEID AANTAL: ' || UPPER (v_ins_kenmerkwaarde7) || CHR(10) || + 'BOUWJAAR: ' || UPPER (v_ins_kenmerkwaarde8)); + END IF; + END IF; + ELSE + v_count_tot := v_count_tot + 1; + -- Controleer alle veldwaarden + + v_errormsg := 'Gebouwcode kan niet gevonden worden'; + v_oprognose_gebouw_code := TRIM (v_oprognose_gebouw_code); + + SELECT alg_gebouw_key, alg_gebouw_code, alg_locatie_code + INTO v_alg_gebouw_key, v_alg_gebouw_code, v_alg_locatie_code + FROM alg_gebouw g, alg_locatie l, alg_onrgoedkenmerk aok + WHERE g.alg_locatie_key = l.alg_locatie_key + AND alg_gebouw_verwijder IS NULL + AND aok.alg_onrgoed_key = g.alg_gebouw_key + AND aok.alg_onrgoed_niveau='G' + AND UPPER(aok.alg_onrgoedkenmerk_waarde) = UPPER(v_oprognose_gebouw_code); + + v_alg_verdieping_volgnr := 0; + BEGIN + SELECT alg_verdieping_key + INTO v_alg_verdieping_key + FROM alg_verdieping + WHERE alg_verdieping_verwijder IS NULL + AND alg_gebouw_key = v_alg_gebouw_key + AND alg_verdieping_volgnr = 0; + EXCEPTION WHEN NO_DATA_FOUND + THEN + INSERT INTO alg_verdieping (alg_gebouw_key, alg_verdieping_volgnr, alg_verdieping_omschrijving, alg_verdieping_code) + VALUES (v_alg_gebouw_key, 0, 'Begane grond', '0') + RETURNING alg_verdieping_key INTO v_alg_verdieping_key; + fac.imp_writelog (p_import_key, 'I', v_aanduiding, 'Verdieping aangemaakt'); + END; + + v_alg_ruimte_nr := '_'; + BEGIN + SELECT alg_ruimte_key + INTO v_alg_ruimte_key + FROM alg_ruimte + WHERE alg_ruimte_verwijder IS NULL + AND alg_verdieping_key = v_alg_verdieping_key + AND alg_ruimte_nr = '_'; + EXCEPTION WHEN NO_DATA_FOUND + THEN + INSERT INTO alg_ruimte (alg_verdieping_key, alg_ruimte_nr, alg_ruimte_omschrijving) + VALUES (v_alg_verdieping_key, '_', 'MJOP ruimte') + RETURNING alg_ruimte_key INTO v_alg_ruimte_key; + fac.imp_writelog (p_import_key, 'I', v_aanduiding, 'Ruimte aangemaakt'); + END; + -- + + v_errormsg := 'Bepaal objectsoort'; + BEGIN + v_ins_srtdeel_code := TRIM(v_ins_srtdeel_code); + SELECT ins_srtdeel_omschrijving, ins_srtdeel_key, ins_srtgroep_key + INTO v_ins_srtdeel_omschrijving, v_ins_srtdeel_key, v_ins_srtgroep_key + FROM ins_srtdeel + WHERE ins_srtdeel_verwijder IS NULL + AND ins_srtdeel_code = v_ins_srtdeel_code; + + v_errormsg := 'Bepaal objectgroep'; + SELECT ins_srtgroep_omschrijving, ins_discipline_key + INTO v_ins_srtgroep_omschrijving, v_ins_discipline_key + FROM ins_srtgroep + WHERE ins_srtgroep_key = v_ins_srtgroep_key; + + v_errormsg := 'Bepaal discipline'; + SELECT ins_discipline_omschrijving + INTO v_ins_discipline_omschrijving + FROM ins_discipline + WHERE ins_discipline_key = v_ins_discipline_key; + + EXCEPTION WHEN NO_DATA_FOUND + THEN + v_errormsg := 'Nieuwe NL/SfB code'; + v_ins_discipline_omschrijving := 'MJOB'; + BEGIN + IF length(v_ins_srtdeel_code)=6 + THEN + SELECT ins_srtdeel_omschrijving, ins_srtdeel_key, ins_srtgroep_key + INTO v_ins_srtdeel_omschrijving, v_ins_srtdeel_key, v_ins_srtgroep_key + FROM ins_srtdeel + WHERE ins_srtdeel_verwijder IS NULL + AND ins_srtdeel_code =SUBSTR(v_ins_srtdeel_code,1,4); + + ELSE + v_ins_srtdeel_omschrijving := v_ins_srtdeel_code || ' - Onbekend'; + END IF; + + EXCEPTION + WHEN NO_DATA_FOUND THEN + v_ins_srtdeel_omschrijving := v_ins_srtdeel_code || ' - Onbekend'; + END; + + BEGIN + SELECT ins_srtgroep_omschrijving + INTO v_ins_srtgroep_omschrijving + FROM ins_v_srtgroep_gegevens + WHERE ins_discipline_omschrijving = 'MJOB' + AND SUBSTR(v_ins_srtdeel_code, 1, 2) = SUBSTR(ins_srtgroep_omschrijving, 1,2); + + EXCEPTION WHEN NO_DATA_FOUND + THEN + v_ins_srtgroep_omschrijving := SUBSTR(v_ins_srtdeel_code, 1, 2) || '- Onbekend'; + END; + END; + + BEGIN + v_errormsg := 'Bepaal object id - Kijk of het externnr bestaat'; + SELECT d.ins_deel_omschrijving + INTO v_ins_deel_omschrijving + FROM ins_v_deel_gegevens dg, ins_deel d + WHERE dg.ins_deel_key = d.ins_deel_key + AND dg.alg_gebouw_upper = v_alg_gebouw_code + AND d.ins_deel_externnr = v_ins_deel_externnr; + + EXCEPTION WHEN NO_DATA_FOUND + THEN + v_ins_deel_omschrijving := NULL; + END; + + IF v_ins_deel_omschrijving IS NULL + THEN + v_errormsg := 'Bepaal object id - maak een nieuw nummer aan'; + SELECT MAX(FAC.safe_to_number(SUBSTR(ins_deel_omschrijving, INSTR(ins_deel_omschrijving, '-')+1, 100))) + INTO v_ins_deel_volgnr + FROM ins_v_deel_gegevens + WHERE ins_discipline_omschrijving = 'MJOB' + AND ins_deel_omschrijving LIKE v_ins_srtdeel_code || '%'; + + IF v_ins_deel_volgnr IS NULL + THEN + v_ins_deel_volgnr := 0; + END IF; + +-- v_ins_deel_omschrijving := v_ins_srtdeel_code || LPAD(v_ins_deel_volgnr + 1, 3, '0'); + v_ins_deel_omschrijving := v_ins_srtdeel_code||'-'||v_ins_deel_externnr; + END IF; + + v_errormsg := 'Objectopmerking ongeldig'; + v_ins_deel_opmerking := TRIM (v_ins_deel_opmerking); + + IF LENGTH (v_ins_deel_opmerking) > 320 + THEN + v_ins_deel_opmerking := SUBSTR (v_ins_deel_opmerking, 1, 320); + fac.imp_writelog ( + p_import_key, + 'W', + v_aanduiding || v_errormsg, + 'Objectopmerking wordt afgebroken tot [' + || v_ins_deel_opmerking + || ']' + ); + END IF; + + -- + v_errormsg := 'Aantal ongeldig; maximale grootte 999999.99'; + v_ins_deel_aantal := TRIM (v_ins_deel_aantal); + v_ins_deel_aantal := REPLACE (v_ins_deel_aantal, ',', '.'); + v_ins_deel_aantal_n := NULL; + + IF (v_ins_deel_aantal IS NOT NULL AND fac.getSetting('ins_explode_objects') = 0) + THEN + IF (fac.safe_to_number (v_ins_deel_aantal) IS NULL) + THEN + v_ongeldig := 1; + fac.imp_writelog (p_import_key, + 'W', + v_aanduiding || v_errormsg, + 'Regel wordt overgeslagen!'); + ELSE + v_ins_deel_aantal_n := fac.safe_to_number (v_ins_deel_aantal); + END IF; + ELSE + v_ins_deel_aantal_n := 1; + END IF; + + -- + v_errorhint := 'Bepaling registratiedatum'; + v_ins_kenmerkwaarde8 := TRIM(v_ins_kenmerkwaarde8); + IF v_ins_kenmerkwaarde8 IS NOT NULL AND LENGTH(v_ins_kenmerkwaarde8) = 4 + THEN + v_ins_deel_aanmaak := '01-01-' || TRIM(v_ins_kenmerkwaarde8); + v_ins_deel_aanmaak_d := TO_DATE(v_ins_deel_aanmaak, 'dd-mm-yyyy'); + END IF; + + -- De rest alleen ff trimmen. + v_ins_kenmerkwaarde1 := TRIM (v_ins_kenmerkwaarde1); + v_ins_kenmerkwaarde2 := TRIM (v_ins_kenmerkwaarde2); + v_ins_kenmerkwaarde3 := TRIM (v_ins_kenmerkwaarde3); + v_ins_kenmerkwaarde4 := TRIM (v_ins_kenmerkwaarde4); + v_ins_kenmerkwaarde5 := TRIM (v_ins_kenmerkwaarde5); + v_ins_kenmerkwaarde6 := TRIM (v_ins_kenmerkwaarde6); + v_ins_kenmerkwaarde7 := TRIM (v_ins_kenmerkwaarde7); + v_ins_kenmerkwaarde8 := TRIM (v_ins_kenmerkwaarde8); + v_ins_kenmerkwaarde9 := TRIM (v_ins_kenmerkwaarde9); + v_ins_kenmerkwaarde10 := TRIM (v_ins_kenmerkwaarde10); + v_ins_kenmerkwaarde11 := TRIM (v_ins_kenmerkwaarde11); + v_ins_kenmerkwaarde12 := TRIM (v_ins_kenmerkwaarde12); + v_ins_kenmerkwaarde13 := TRIM (v_ins_kenmerkwaarde13); + v_ins_kenmerkwaarde14 := TRIM (v_ins_kenmerkwaarde14); + v_ins_kenmerkwaarde15 := TRIM (v_ins_kenmerkwaarde15); + v_ins_kenmerkwaarde16 := TRIM (v_ins_kenmerkwaarde16); + v_ins_kenmerkwaarde17 := TRIM (v_ins_kenmerkwaarde17); + v_ins_kenmerkwaarde18 := TRIM (v_ins_kenmerkwaarde18); + v_ins_kenmerkwaarde19 := TRIM (v_ins_kenmerkwaarde19); + v_ins_kenmerkwaarde20 := TRIM (v_ins_kenmerkwaarde20); + + + -- Insert geformatteerde import record + IF v_ongeldig = 0 + THEN + BEGIN + v_errormsg := 'Fout bij wegschrijven importregel'; + + -- Als uit kenmerkheader een geldige kenmerksoort-key volgt, + -- dan is kenmerkwaarde gevuld met =; zoniet, + -- dan is kenmerkwaarde gevuld met ! + -- NB. Een NULL-waarde resulteert NIET in het wissen van een + -- kenmerkveld (bijwerken kan wel, maar wissen dus niet)! + INSERT INTO fac_imp_ins ( + ins_discipline_omschrijving, + ins_discipline_kostensoort, + ins_srtgroep_omschrijving, + ins_srtdeel_code, + ins_srtdeel_omschrijving, + ins_deel_omschrijving, + ins_deel_opmerking, + alg_locatie_code, + alg_gebouw_code, + alg_verdieping_volgnr, + alg_ruimte_nr, + ins_kenmerkwaarde1, + ins_kenmerkwaarde2, + ins_kenmerkwaarde3, + ins_kenmerkwaarde4, + ins_kenmerkwaarde5, + ins_kenmerkwaarde6, + ins_kenmerkwaarde7, + ins_kenmerkwaarde8, + ins_kenmerkwaarde9, + ins_kenmerkwaarde10, + ins_kenmerkwaarde11, + ins_kenmerkwaarde12, + ins_kenmerkwaarde13, + ins_kenmerkwaarde14, + ins_kenmerkwaarde15, + ins_kenmerkwaarde16, + ins_kenmerkwaarde17, + ins_kenmerkwaarde18, + ins_kenmerkwaarde19, + ins_kenmerkwaarde20, + ins_deel_aanmaak, + ins_deel_aantal, + ins_deel_externnr + ) + VALUES ( + v_ins_discipline_omschrijving, + v_ins_discipline_kostensoort, + v_ins_srtgroep_omschrijving, + v_ins_srtdeel_code, + v_ins_srtdeel_omschrijving, + v_ins_deel_omschrijving, + v_ins_deel_opmerking, + v_alg_locatie_code, + v_alg_gebouw_code, + v_alg_verdieping_volgnr, + v_alg_ruimte_nr, + DECODE (v_ins_kenmerk_key1, NULL, v_ins_kenmerkwaarde1, DECODE(v_ins_kenmerk_key1, NULL, NULL, TO_CHAR (v_ins_kenmerk_key1) || '=' || SUBSTR (v_ins_kenmerkwaarde1, 1, 3900))), + DECODE (v_ins_kenmerk_key2, NULL, v_ins_kenmerkwaarde2, DECODE(v_ins_kenmerk_key2, NULL, NULL, TO_CHAR (v_ins_kenmerk_key2) || '=' || SUBSTR (v_ins_kenmerkwaarde2, 1, 3900))), + DECODE (v_ins_kenmerk_key3, NULL, v_ins_kenmerkwaarde3, DECODE(v_ins_kenmerk_key3, NULL, NULL, TO_CHAR (v_ins_kenmerk_key3) || '=' || SUBSTR (v_ins_kenmerkwaarde3, 1, 3900))), + DECODE (v_ins_kenmerk_key4, NULL, v_ins_kenmerkwaarde4, DECODE(v_ins_kenmerk_key4, NULL, NULL, TO_CHAR (v_ins_kenmerk_key4) || '=' || SUBSTR (v_ins_kenmerkwaarde4, 1, 3900))), + DECODE (v_ins_kenmerk_key5, NULL, v_ins_kenmerkwaarde5, DECODE(v_ins_kenmerk_key5, NULL, NULL, TO_CHAR (v_ins_kenmerk_key5) || '=' || SUBSTR (v_ins_kenmerkwaarde5, 1, 3900))), + DECODE (v_ins_kenmerk_key6, NULL, v_ins_kenmerkwaarde6, DECODE(v_ins_kenmerk_key6, NULL, NULL, TO_CHAR (v_ins_kenmerk_key6) || '=' || SUBSTR (v_ins_kenmerkwaarde6, 1, 3900))), + DECODE (v_ins_kenmerk_key7, NULL, v_ins_kenmerkwaarde7, DECODE(v_ins_kenmerk_key7, NULL, NULL, TO_CHAR (v_ins_kenmerk_key7) || '=' || SUBSTR (v_ins_kenmerkwaarde7, 1, 3900))), + DECODE (v_ins_kenmerk_key8, NULL, v_ins_kenmerkwaarde8, DECODE(v_ins_kenmerk_key8, NULL, NULL, TO_CHAR (v_ins_kenmerk_key8) || '=' || SUBSTR (v_ins_kenmerkwaarde8, 1, 3900))), + DECODE (v_ins_kenmerk_key9, NULL, v_ins_kenmerkwaarde9, DECODE(v_ins_kenmerk_key9, NULL, NULL, TO_CHAR (v_ins_kenmerk_key9) || '=' || SUBSTR (v_ins_kenmerkwaarde9, 1, 3900))), + DECODE (v_ins_kenmerk_key10, NULL, v_ins_kenmerkwaarde10, DECODE(v_ins_kenmerk_key10, NULL, NULL, TO_CHAR (v_ins_kenmerk_key10) || '=' || SUBSTR (v_ins_kenmerkwaarde10, 1, 3900))), + DECODE (v_ins_kenmerk_key11, NULL, v_ins_kenmerkwaarde11, DECODE(v_ins_kenmerk_key11, NULL, NULL, TO_CHAR (v_ins_kenmerk_key11) || '=' || SUBSTR (v_ins_kenmerkwaarde11, 1, 3900))), + DECODE (v_ins_kenmerk_key12, NULL, v_ins_kenmerkwaarde12, DECODE(v_ins_kenmerk_key12, NULL, NULL, TO_CHAR (v_ins_kenmerk_key12) || '=' || SUBSTR (v_ins_kenmerkwaarde12, 1, 3900))), + DECODE (v_ins_kenmerk_key13, NULL, v_ins_kenmerkwaarde13, DECODE(v_ins_kenmerk_key13, NULL, NULL, TO_CHAR (v_ins_kenmerk_key13) || '=' || SUBSTR (v_ins_kenmerkwaarde13, 1, 3900))), + DECODE (v_ins_kenmerk_key14, NULL, v_ins_kenmerkwaarde14, DECODE(v_ins_kenmerk_key14, NULL, NULL, TO_CHAR (v_ins_kenmerk_key14) || '=' || SUBSTR (v_ins_kenmerkwaarde14, 1, 3900))), + DECODE (v_ins_kenmerk_key15, NULL, v_ins_kenmerkwaarde15, DECODE(v_ins_kenmerk_key15, NULL, NULL, TO_CHAR (v_ins_kenmerk_key15) || '=' || SUBSTR (v_ins_kenmerkwaarde15, 1, 3900))), + DECODE (v_ins_kenmerk_key16, NULL, v_ins_kenmerkwaarde16, DECODE(v_ins_kenmerk_key16, NULL, NULL, TO_CHAR (v_ins_kenmerk_key16) || '=' || SUBSTR (v_ins_kenmerkwaarde16, 1, 3900))), + DECODE (v_ins_kenmerk_key17, NULL, v_ins_kenmerkwaarde17, DECODE(v_ins_kenmerk_key17, NULL, NULL, TO_CHAR (v_ins_kenmerk_key17) || '=' || SUBSTR (v_ins_kenmerkwaarde17, 1, 3900))), + DECODE (v_ins_kenmerk_key18, NULL, v_ins_kenmerkwaarde18, DECODE(v_ins_kenmerk_key18, NULL, NULL, TO_CHAR (v_ins_kenmerk_key18) || '=' || SUBSTR (v_ins_kenmerkwaarde18, 1, 3900))), + DECODE (v_ins_kenmerk_key19, NULL, v_ins_kenmerkwaarde19, DECODE(v_ins_kenmerk_key19, NULL, NULL, TO_CHAR (v_ins_kenmerk_key19) || '=' || SUBSTR (v_ins_kenmerkwaarde19, 1, 3900))), + DECODE (v_ins_kenmerk_key20, NULL, v_ins_kenmerkwaarde20, DECODE(v_ins_kenmerk_key20, NULL, NULL, TO_CHAR (v_ins_kenmerk_key20) || '=' || SUBSTR (v_ins_kenmerkwaarde20, 1, 3900))), + v_ins_deel_aanmaak_d, + v_ins_deel_aantal_n, + v_ins_deel_externnr + ); + + COMMIT; + v_count_import := v_count_import + 1; + END; + + END IF; + END IF; + EXCEPTION + WHEN OTHERS + THEN + oracle_err_num := SQLCODE; + oracle_err_mes := SUBSTR (SQLERRM, 1, 200); + v_errormsg := + v_errormsg + || ' ORACLE (error ' + || oracle_err_num + || '/' + || oracle_err_mes + || ')'; + fac.imp_writelog (p_import_key, + 'W', + v_aanduiding || v_errormsg, + ''); + COMMIT; + END; + END LOOP; + + -- We gaan nu de nummering van de objecten aanpassen. Ze hebben allemaal het hoogste bestaande nummer + 1 meegekregen. + --v_alg_gebouw_code := 'Leeg'; Niet gebruiken bij PLGP want we lezen 1 gebouw per keer in. +-- v_ins_srtdeel_code := 'Leeg'; +-- +-- FOR rec IN c +-- LOOP +-- BEGIN +-- IF rec.alg_gebouw_code <> v_alg_gebouw_code +-- OR rec.ins_srtdeel_code <> v_ins_srtdeel_code +-- THEN +-- v_ins_deel_volgnr := +-- FAC.safe_to_number ( +-- SUBSTR (rec.ins_deel_omschrijving, INSTR (rec.ins_deel_omschrijving, '-', 1) + 1, 100)); +-- v_alg_gebouw_code := rec.alg_gebouw_code; +-- v_ins_srtdeel_code := rec.ins_srtdeel_code; +-- ELSE +-- v_ins_deel_volgnr := v_ins_deel_volgnr + 1; +-- +-- UPDATE fac_imp_ins +-- SET ins_deel_omschrijving = +-- rec.ins_srtdeel_code +-- || LPAD (v_ins_deel_volgnr, 3, '0') +-- WHERE ins_deel_externnr = rec.ins_deel_externnr +-- AND alg_gebouw_code = v_alg_gebouw_code; +-- END IF; +-- END; +-- END LOOP; + + IF (header_is_valid = 1) + THEN + fac.imp_writelog ( + p_import_key, + 'S', + 'Objecten/aantal ingelezen importregels: ' || TO_CHAR (v_count_tot), + '' + ); + fac.imp_writelog ( + p_import_key, + 'S', + 'Objecten/aantal ongeldige niet ingelezen importregels: ' + || TO_CHAR (v_count_tot - v_count_import), + '' + ); + END IF; + + COMMIT; +EXCEPTION + WHEN OTHERS + THEN + oracle_err_num := SQLCODE; + oracle_err_mes := SUBSTR (SQLERRM, 1, 200); + v_errormsg := + v_errormsg + || ' ORACLE (error ' + || oracle_err_num + || '/' + || oracle_err_mes + || ')'; + fac.imp_writelog (p_import_key, + 'E', + v_aanduiding || v_errormsg, + 'Inleesproces objecten afgebroken! regel:' || v_file_index); +END plgp_import_mjobelementen; +/ + +CREATE OR REPLACE PROCEDURE plgp_update_mjobelementen ( + p_import_key IN NUMBER) +IS + +BEGIN + fac_update_ins (p_import_key); +END; +/ +-- EINE MJOB Elementen Import + +CREATE OR REPLACE PROCEDURE plgp_import_mjobtaken (p_import_key IN NUMBER) +IS + c_delim VARCHAR2 (2) := fac.import_delimiter(p_import_key); + v_newline fac_imp_file.fac_imp_file_line%TYPE; -- Input line + v_errormsg VARCHAR2 (1000); + v_errorhint VARCHAR2 (1000); + oracle_err_num NUMBER; + oracle_err_mes VARCHAR2 (200); + header_is_valid NUMBER; + v_count_tot NUMBER (10); + v_count_import NUMBER (10); + v_ongeldig NUMBER (1); + v_aanduiding VARCHAR (400); + v_dummy VARCHAR (255); + v_oprognose_gebouw_code VARCHAR2 (255); + v_alg_gebouw_code VARCHAR2 (255); --VARCHAR2(12), + v_ins_deel_externnr VARCHAR2 (255); --VARCHAR2(256), + v_ins_deel_omschrijving VARCHAR2 (255); --VARCHAR2(60), + v_ins_srtcontrole_omschrijving VARCHAR2 (255); --VARCHAR2(60), + v_ins_srtcontrole_level VARCHAR2 (255); --NUMBER(3), + v_ins_srtcontroledl_xcp_materia VARCHAR2 (255); --NUMBER(9,2), + v_ins_srtcontroledl_xcp_aantal VARCHAR2 (255); --NUMBER(8,2), + v_ins_srtcontroledl_xcp_startdat VARCHAR2 (255); --DATE, + v_ins_srtcontroledl_xcp_periode VARCHAR2 (255); --NUMBER(6,2) + v_ins_srtcontroledl_xcp_perc VARCHAR2 (255); --NUMBER(3) + v_ins_srtcontroledl_xcp_eenh VARCHAR2 (255); + + v_file_index NUMBER; + + CURSOR c1 + IS + SELECT * + FROM fac_imp_file + WHERE fac_import_key = p_import_key + ORDER BY fac_imp_file_index; + +BEGIN + -- Eerst opruiming + + + v_count_tot := 0; + v_count_import := 0; + header_is_valid := 0; + + FOR rec1 IN c1 + LOOP + BEGIN + v_newline := rec1.fac_imp_file_line; + v_file_index := rec1.fac_imp_file_index; + v_errormsg := 'Fout bij opvragen importregel'; + v_aanduiding := ''; + v_ongeldig := 0; + -- Lees alle veldwaarden + + fac.imp_getfield (v_newline, c_delim, v_oprognose_gebouw_code); + fac.imp_getfield (v_newline, c_delim, v_ins_deel_externnr); + fac.imp_getfield (v_newline, c_delim, v_ins_deel_omschrijving); + fac.imp_getfield (v_newline, c_delim, v_ins_srtcontrole_omschrijving); + fac.imp_getfield (v_newline, c_delim, v_ins_srtcontroledl_xcp_materia); + fac.imp_getfield (v_newline, c_delim, v_ins_srtcontroledl_xcp_aantal); + fac.imp_getfield (v_newline, c_delim, v_ins_srtcontrole_level); + fac.imp_getfield (v_newline, c_delim, v_ins_srtcontroledl_xcp_startdat); + fac.imp_getfield (v_newline, c_delim, v_ins_srtcontroledl_xcp_periode); + fac.imp_getfield (v_newline, c_delim, v_ins_srtcontroledl_xcp_perc); + fac.imp_getfield (v_newline, c_delim, v_ins_srtcontroledl_xcp_eenh); + + v_aanduiding := + '[' + || v_alg_gebouw_code + || '|' + || v_ins_deel_externnr + || '|' + || v_ins_deel_omschrijving + || '|' + || v_ins_srtcontrole_omschrijving + || '] '; + + -- Ik controleer of ik een geldige header heb, dat is: in de juiste kolommen + -- de juiste kolomkop. Ik controleer daarbij alle NIET-kenmerk kolommen! + -- Ik negeer alles totdat ik een geldige header ben gepasseerd. + IF (header_is_valid = 0) + THEN + IF UPPER (v_oprognose_gebouw_code) = 'GEBOUW_CODE' + AND UPPER (v_ins_deel_externnr) = 'DEEL_EXTERNNR' + AND UPPER (v_ins_deel_omschrijving) = 'DEEL_OMSCHRIJVING' + AND UPPER (v_ins_srtcontrole_omschrijving) = 'SRTCONTROLE_OMSCHRIJVING' + AND UPPER (v_ins_srtcontroledl_xcp_materia) = 'SRTCONTROLEDL_XCP_MATERIA' + AND UPPER (v_ins_srtcontroledl_xcp_aantal) = 'SRTCONTROLEDL_XCP_AANTAL' + AND UPPER (v_ins_srtcontrole_level) = 'SRTCONTROLE_LEVEL' + AND UPPER (v_ins_srtcontroledl_xcp_startdat) = 'SRTCONTROLE_STARTJAAR' + AND UPPER (v_ins_srtcontroledl_xcp_periode) = 'SRTCONTROLE_PERIODE' + AND UPPER (v_ins_srtcontroledl_xcp_perc) = 'SRTCONTROLE_PERCENTAGE' + THEN + header_is_valid := 1; + ELSE + IF rec1.fac_imp_file_index = 1 + THEN + + fac.imp_writelog (p_import_key, + 'E', + 'Ongeldige header aangetroffen:', + 'GEBOUW_CODE: ' || UPPER (v_oprognose_gebouw_code) || CHR(10) || + 'DEEL_EXTERNNR: ' || UPPER (v_ins_deel_externnr) || CHR(10) || + 'DEEL_OMSCHRIJVING: ' || UPPER (v_ins_deel_omschrijving) || CHR(10) || + 'SRTCONTROLE_OMSCHRIJVING: ' || UPPER (v_ins_srtcontrole_omschrijving) || CHR(10) || + 'SRTCONTROLEDL_XCP_MATERIA: ' || UPPER (v_ins_srtcontroledl_xcp_materia) || CHR(10) || + 'SRTCONTROLEDL_XCP_AANTAL: ' || UPPER (v_ins_srtcontroledl_xcp_aantal) || CHR(10) || + 'SRTCONTROLE_LEVEL: ' || UPPER (v_ins_srtcontrole_level) || CHR(10) || + 'SRTCONTROLE_STARTJAAR: ' || UPPER (v_ins_srtcontroledl_xcp_startdat) || CHR(10) || + 'SRTCONTROLE_PERIODE: ' || UPPER (v_ins_srtcontroledl_xcp_periode) || CHR(10) || + 'SRTCONTROLE_PERCENTAGE: ' || UPPER (v_ins_srtcontroledl_xcp_perc)); + END IF; + END IF; + ELSE + v_count_tot := v_count_tot + 1; + -- Controleer alle veldwaarden + + v_errormsg := 'Gebouwcode kan niet gevonden worden'; + v_oprognose_gebouw_code := TRIM (v_oprognose_gebouw_code); + + BEGIN + SELECT g.alg_gebouw_code + INTO v_alg_gebouw_code + FROM alg_gebouw g, alg_onrgoedkenmerk aok + WHERE g.alg_gebouw_verwijder IS NULL + AND aok.alg_onrgoed_key = g.alg_gebouw_key + AND aok.alg_onrgoed_niveau='G' + AND UPPER(aok.alg_onrgoedkenmerk_waarde) = UPPER(v_oprognose_gebouw_code); + EXCEPTION WHEN NO_DATA_FOUND + THEN + fac.imp_writelog ( + p_import_key, + 'E', + v_aanduiding || v_errormsg, + 'Gebouw is niet gevonden' + ); + v_ongeldig := 1; + END; + + v_errormsg := 'Objectid kan niet gevonden worden'; + v_ins_deel_omschrijving := TRIM (v_ins_deel_omschrijving); + IF v_ins_deel_omschrijving IS NOT NULL + THEN + BEGIN + SELECT 1 + INTO v_dummy + FROM ins_v_deel_gegevens + WHERE UPPER(ins_deel_omschrijving) = UPPER(v_ins_deel_omschrijving) + AND alg_gebouw_upper = UPPER(v_alg_gebouw_code); + EXCEPTION WHEN NO_DATA_FOUND + THEN + fac.imp_writelog ( + p_import_key, + 'E', + v_aanduiding || v_errormsg, + 'Object is niet gevonden op id ' + ); + v_ongeldig := 1; + END; + END IF; + + v_errormsg := 'Object externnr kan niet gevonden worden'; + v_ins_deel_externnr := TRIM (v_ins_deel_externnr); + IF v_ins_deel_externnr IS NOT NULL + THEN + BEGIN + SELECT 1 + INTO v_dummy + FROM ins_v_deel_gegevens dg, ins_deel d + WHERE dg.ins_deel_key = d.ins_deel_key + AND UPPER(d.ins_deel_externnr) = UPPER(v_ins_deel_externnr) + AND dg.alg_gebouw_upper = UPPER(v_alg_gebouw_code); + EXCEPTION WHEN NO_DATA_FOUND + THEN + fac.imp_writelog ( + p_import_key, + 'E', + v_aanduiding || v_errormsg, + 'Object is niet gevonden op extern id ' + ); + v_ongeldig := 1; + END; + END IF; + + v_errormsg := 'Controle op kosten'; + IF FAC.safe_to_number(v_ins_srtcontroledl_xcp_materia) IS NULL + THEN + fac.imp_writelog ( + p_import_key, + 'E', + v_aanduiding || v_errormsg,'' + ); + v_ongeldig := 1; + END IF; + + v_errormsg := 'Controle op aantal'; + IF v_ins_srtcontroledl_xcp_aantal IS NOT NULL AND FAC.safe_to_number(v_ins_srtcontroledl_xcp_aantal) IS NULL + THEN + fac.imp_writelog ( + p_import_key, + 'E', + v_aanduiding || v_errormsg,'' + ); + v_ongeldig := 1; + END IF; + + v_errormsg := 'Controle op startjaar'; + IF v_ins_srtcontroledl_xcp_startdat IS NOT NULL AND FAC.safe_to_date('01-01-' || v_ins_srtcontroledl_xcp_startdat, 'dd-mm-yyyy') IS NULL + THEN + fac.imp_writelog ( + p_import_key, + 'E', + v_aanduiding || v_errormsg,'' + ); + v_ongeldig := 1; + END IF; + + v_errormsg := 'Controle op periode'; + IF v_ins_srtcontroledl_xcp_periode IS NOT NULL AND FAC.safe_to_number(v_ins_srtcontroledl_xcp_periode) IS NULL + THEN + fac.imp_writelog ( + p_import_key, + 'E', + v_aanduiding || v_errormsg,'' + ); + v_ongeldig := 1; + END IF; + + v_errormsg := 'Controle op percentage'; + IF v_ins_srtcontroledl_xcp_perc IS NOT NULL AND FAC.safe_to_number(v_ins_srtcontroledl_xcp_perc) IS NULL + THEN + fac.imp_writelog ( + p_import_key, + 'E', + v_aanduiding || v_errormsg,'' + ); + v_ongeldig := 1; + END IF; + + -- Insert geformatteerde import record + IF v_ongeldig = 0 + THEN + BEGIN + v_errormsg := 'Fout bij wegschrijven importregel'; + + -- Als uit kenmerkheader een geldige kenmerksoort-key volgt, + -- dan is kenmerkwaarde gevuld met =; zoniet, + -- dan is kenmerkwaarde gevuld met ! + -- NB. Een NULL-waarde resulteert NIET in het wissen van een + -- kenmerkveld (bijwerken kan wel, maar wissen dus niet)! + + + INSERT INTO fac_imp_csv (FAC_IMPORT_KEY, + fac_imp_csv_index, + fac_imp_csv_col01, + fac_imp_csv_col02, + fac_imp_csv_col03, + fac_imp_csv_col04, + fac_imp_csv_col05, + fac_imp_csv_col06, + fac_imp_csv_col07, + fac_imp_csv_col08, + fac_imp_csv_col09, + fac_imp_csv_col10, + fac_imp_csv_col11) + VALUES ( p_import_key, + v_file_index, + SUBSTR(v_alg_gebouw_code,1,12), + SUBSTR(v_ins_deel_externnr,1,256), + SUBSTR(v_ins_deel_omschrijving,1,60), + SUBSTR(v_ins_srtcontrole_omschrijving,1,60), + FAC.safe_to_number(v_ins_srtcontrole_level), + FAC.safe_to_number(v_ins_srtcontroledl_xcp_materia), -- de prijs m,oet per stuk zijn. + FAC.safe_to_number(v_ins_srtcontroledl_xcp_aantal), + '01-01-' || v_ins_srtcontroledl_xcp_startdat, + v_ins_srtcontroledl_xcp_periode, + FAC.safe_to_number(v_ins_srtcontroledl_xcp_perc), + v_ins_srtcontroledl_xcp_eenh); + + COMMIT; + v_count_import := v_count_import + 1; + END; + + END IF; + END IF; + EXCEPTION + WHEN OTHERS + THEN + oracle_err_num := SQLCODE; + oracle_err_mes := SUBSTR (SQLERRM, 1, 200); + v_errormsg := + v_errormsg + || ' ORACLE (error ' + || oracle_err_num + || '/' + || oracle_err_mes + || ')'; + fac.imp_writelog (p_import_key, + 'W', + v_aanduiding || v_errormsg, + ''); + COMMIT; + END; + END LOOP; + + IF (header_is_valid = 1) + THEN + fac.imp_writelog ( + p_import_key, + 'S', + 'Taken/aantal ingelezen importregels: ' || TO_CHAR (v_count_tot), + '' + ); + fac.imp_writelog ( + p_import_key, + 'S', + 'Taken/aantal ongeldige niet ingelezen importregels: ' + || TO_CHAR (v_count_tot - v_count_import), + '' + ); + END IF; + + COMMIT; +EXCEPTION + WHEN OTHERS + THEN + oracle_err_num := SQLCODE; + oracle_err_mes := SUBSTR (SQLERRM, 1, 200); + v_errormsg := + v_errormsg + || ' ORACLE (error ' + || oracle_err_num + || '/' + || oracle_err_mes + || ')'; + fac.imp_writelog (p_import_key, + 'E', + v_aanduiding || v_errormsg, + 'Inleesproces taken afgebroken! regel:' || v_file_index); +END plgp_import_mjobtaken; +/ + + +CREATE OR REPLACE PROCEDURE plgp_update_mjobtaken ( + p_import_key IN NUMBER) +IS + + CURSOR c IS + SELECT fac_imp_csv_col01 alg_gebouw_code, + fac_imp_csv_col02 ins_deel_externnr, + fac_imp_csv_col03 ins_deel_omschrijving, + fac_imp_csv_col04 ins_srtcontrole_omschrijving, + fac_imp_csv_col05 ins_srtcontrole_level, + fac_imp_csv_col06 ins_srtcontroledl_xcp_materia, + fac_imp_csv_col07 ins_srtcontroledl_xcp_aantal, + fac_imp_csv_col08 ins_srtcontroledl_xcp_startdat, + fac_imp_csv_col09 ins_srtcontroledl_xcp_periode, + fac_imp_csv_col10 ins_srtcontroledl_xcp_perc, + fac_imp_csv_col11 ins_srtcontroledl_xcp_eenh + FROM fac_imp_csv + WHERE fac_import_key=p_import_key; + + v_errormsg VARCHAR2 (1000); + v_errorhint VARCHAR2 (1000); + oracle_err_num NUMBER; + oracle_err_mes VARCHAR2 (200); + v_count_tot NUMBER (10); + v_count_import NUMBER (10); + v_ongeldig NUMBER (1); + v_aanduiding VARCHAR (400); + v_ins_deel_key NUMBER; + v_ins_deel_aantal NUMBER; + v_ins_srtdeel_key NUMBER; + v_ins_srtcontrole_key NUMBER; + v_ins_srtcontroledl_xcp_key NUMBER; + v_ctr_discipline_key NUMBER; + v_alg_gebouw_key NUMBER; + v_ins_srtdeel_code INS_SRTDEEL.INS_SRTDEEL_CODE%TYPE; + v_ins_deel_eenheid VARCHAR2(30); + v_ins_srtcontroledl_xcp_startdat DATE; + v_ins_srtcontroledl_xcp_aantal NUMBER; + v_ins_srtcontroledl_xcp_perc NUMBER; + v_refdate DATE; + +BEGIN + SELECT MIN(ctr_ins_discipline_key) + INTO v_ctr_discipline_key + FROM ctr_disc_params + WHERE ctr_disc_params_ismjob = 1; + + -- controleer op verwijderde records + FOR rec IN c + LOOP + BEGIN + v_ins_deel_key := NULL; + v_aanduiding := rec.alg_gebouw_code || '|' || rec.ins_deel_omschrijving || '|' || rec.ins_deel_externnr || '|' || rec.ins_srtcontrole_omschrijving; + v_errormsg := 'Gebouwcode kan niet gevonden worden'; + + BEGIN + SELECT alg_gebouw_key + INTO v_alg_gebouw_key + FROM alg_gebouw g + WHERE alg_gebouw_verwijder IS NULL + AND UPPER(alg_gebouw_code) = rec.alg_gebouw_code; + EXCEPTION WHEN NO_DATA_FOUND + THEN + fac.imp_writelog ( + p_import_key, + 'E', + v_aanduiding || v_errormsg, + 'Gebouw is niet gevonden' + ); + END; + + v_errormsg := 'Objectid kan niet gevonden worden'; + IF rec.ins_deel_omschrijving IS NOT NULL + THEN + BEGIN + SELECT dg.ins_deel_key, + sd.ins_srtdeel_key, + sd.ins_srtdeel_code, + dg.ins_deel_aantal, + ken.ins_kenmerkdeel_waarde + INTO v_ins_deel_key, v_ins_srtdeel_key, v_ins_srtdeel_code, v_ins_deel_aantal, v_ins_deel_eenheid + FROM ins_v_deel_gegevens dg, + ins_srtdeel sd, + (SELECT ikd.ins_deel_key, ikd.ins_kenmerkdeel_waarde + FROM ins_kenmerkdeel ikd, ins_kenmerk ik + WHERE ikd.ins_kenmerk_key = ik.ins_kenmerk_key + AND ik.ins_kenmerk_code = 'MJOB_EENHEID_AANTAL' + AND ikd.ins_kenmerkdeel_verwijder IS NULL) ken + WHERE dg.ins_srtdeel_key = sd.ins_srtdeel_key + AND UPPER(dg.ins_deel_omschrijving) = UPPER(rec.ins_deel_omschrijving) + AND ken.ins_deel_key(+) = dg.ins_deel_key + AND dg.alg_gebouw_upper = UPPER(rec.alg_gebouw_code); + + EXCEPTION WHEN NO_DATA_FOUND + THEN + fac.imp_writelog ( + p_import_key, + 'E', + v_aanduiding || v_errormsg, + 'Object is niet gevonden op id ' + ); + v_ongeldig := 1; + END; + END IF; + + v_errormsg := 'Object externnr kan niet gevonden worden'; + IF rec.ins_deel_externnr IS NOT NULL AND v_ins_deel_key IS NULL + THEN + BEGIN + SELECT d.ins_deel_key, sd.ins_srtdeel_key, sd.ins_srtdeel_code, d.ins_deel_aantal + INTO v_ins_deel_key, v_ins_srtdeel_key, v_ins_srtdeel_code, v_ins_deel_aantal + FROM ins_v_deel_gegevens dg, ins_deel d, ins_srtdeel sd + WHERE dg.ins_deel_key = d.ins_deel_key + AND d.ins_srtdeel_key = sd.ins_srtdeel_key + AND UPPER(d.ins_deel_externnr) = UPPER(rec.ins_deel_externnr) + AND dg.alg_gebouw_upper = UPPER(rec.alg_gebouw_code); + EXCEPTION WHEN NO_DATA_FOUND + THEN + fac.imp_writelog ( + p_import_key, + 'E', + v_aanduiding || v_errormsg, + 'Object is niet gevonden op extern id ' + ); + v_ongeldig := 1; + END; + END IF; + + -- kijk of de srtcontrole al bestaat + v_errormsg := 'Kijk of de taak al bestaat'; + BEGIN + SELECT ins_srtcontrole_key + INTO v_ins_srtcontrole_key + FROM ins_srtcontrole + WHERE ins_srtinstallatie_key = v_ins_srtdeel_key + AND ins_srtcontrole_niveau = 'S' + AND ins_srtcontrole_omschrijving = SUBSTR(v_ins_srtdeel_code || ' - ' || rec.ins_srtcontrole_omschrijving, 1, 60) + AND ctr_discipline_key = v_ctr_discipline_key; + + UPDATE ins_srtcontrole + SET ins_srtcontrole_level = rec.ins_srtcontrole_level + WHERE ins_srtcontrole_key = v_ins_srtcontrole_key; + + EXCEPTION WHEN NO_DATA_FOUND + THEN + v_errormsg := 'Aanmaken nieuwe taak'; + INSERT INTO ins_srtcontrole (ins_srtinstallatie_key, + ins_srtcontrole_niveau, + ins_srtcontrole_omschrijving, + ctr_discipline_key, + ins_srtcontrole_periode, + ins_srtcontrole_eenheid, + ins_srtcontrole_level, + ins_srtcontrole_materiaal, + ins_srtcontrole_percentage) + VALUES (v_ins_srtdeel_key, + 'S', + SUBSTR(v_ins_srtdeel_code || ' - ' || rec.ins_srtcontrole_omschrijving, 1, 60), + v_ctr_discipline_key, + 0, -- periode wordt in het xcp record opgegeven + 4, -- standaard jaar voor MJOB + rec.ins_srtcontrole_level, + 0, -- kosten worden in het xcp record vermeld. + 100) + RETURNING ins_srtcontrole_key INTO v_ins_srtcontrole_key; + END; + + v_ins_srtcontroledl_xcp_perc:=FAC.safe_to_number(rec.ins_srtcontroledl_xcp_perc)*100; + + + IF v_ins_srtcontroledl_xcp_perc < 100 THEN + v_ins_srtcontroledl_xcp_aantal:=NULL; + ELSE + IF rec.ins_srtcontroledl_xcp_aantal <> v_ins_deel_aantal THEN + v_ins_srtcontroledl_xcp_aantal:=FAC.safe_to_number(rec.ins_srtcontroledl_xcp_aantal); + ELSE + v_ins_srtcontroledl_xcp_aantal:=NULL; + END IF; + + END IF; + + + -- wat is het aantal op de taak (in de oprognose staat een hvh_reken die we hier gebruiken ipv de ins_deel_aantal) + -- v_ins_srtcontroledl_xcp_aantal := FAC.safe_to_number(rec.ins_srtcontroledl_xcp_aantal); + -- IF (v_ins_srtcontroledl_xcp_aantal=1 AND v_ins_deel_aantal>1) + -- THEN + -- v_ins_srtcontroledl_xcp_aantal:= v_ins_deel_aantal; + -- END IF; + + + + -- Ophalen freeze jaar en eerst stardatum + v_ins_srtcontroledl_xcp_startdat:=FAC.safe_to_date(rec.ins_srtcontroledl_xcp_startdat, 'dd-mm-yyyy'); + v_refdate := FAC.safe_to_date('01-01-'||fac.getsetting('mjb_start_year'),'DD-MM-YYYY'); + + IF (v_ins_srtcontroledl_xcp_startdat<=v_refdate) + THEN + v_ins_srtcontroledl_xcp_startdat := plgp.getfirststartdate(v_ins_srtcontroledl_xcp_startdat, v_refdate,rec.ins_srtcontroledl_xcp_periode); + END IF; + + + --IF FAC.safe_to_number(rec.ins_srtcontroledl_xcp_perc)<1 THEN + -- v_ins_srtcontroledl_xcp_perc:=FAC.safe_to_number(rec.ins_srtcontroledl_xcp_perc)*100; + --ELSE + -- v_ins_srtcontroledl_xcp_perc:=FAC.safe_to_number(rec.ins_srtcontroledl_xcp_perc); + --END IF; + + -- kijk of de taak uitzondering al bestaat + + v_errormsg := 'Kijk of de XCP taak al bestaat'; + BEGIN + + + SELECT ins_srtcontroledl_xcp_key + INTO v_ins_srtcontroledl_xcp_key + FROM ins_srtcontroledl_xcp + WHERE ins_deel_key = v_ins_deel_key + AND ins_srtcontrole_key = v_ins_srtcontrole_key; + + UPDATE ins_srtcontroledl_xcp + SET ins_srtcontroledl_xcp_periode = FAC.safe_to_number(rec.ins_srtcontroledl_xcp_periode), + ins_srtcontroledl_xcp_aantal = v_ins_srtcontroledl_xcp_aantal, + ins_srtcontroledl_xcp_materia = FAC.safe_to_number(rec.ins_srtcontroledl_xcp_materia), + ins_srtcontroledl_xcp_perc = FAC.safe_to_number(rec.ins_srtcontroledl_xcp_perc), + ins_srtcontroledl_xcp_startdat = v_ins_srtcontroledl_xcp_startdat + WHERE ins_srtcontroledl_xcp_key = v_ins_srtcontroledl_xcp_key; + + EXCEPTION WHEN NO_DATA_FOUND + THEN + v_errormsg := 'Aanmaken nieuwe taak uitzondering '; + INSERT INTO ins_srtcontroledl_xcp (ins_deel_key, + ins_srtcontrole_key, + ins_srtcontroledl_xcp_periode, + ins_srtcontroledl_xcp_aantal, + ins_srtcontroledl_xcp_materia, + ins_srtcontroledl_xcp_perc, + ins_srtcontroledl_xcp_startdat, + ins_srtcontroledl_xcp_aanteh) + VALUES (v_ins_deel_key, + v_ins_srtcontrole_key, + FAC.safe_to_number(rec.ins_srtcontroledl_xcp_periode), + v_ins_srtcontroledl_xcp_aantal, + FAC.safe_to_number(rec.ins_srtcontroledl_xcp_materia), + v_ins_srtcontroledl_xcp_perc, + v_ins_srtcontroledl_xcp_startdat, + rec.ins_srtcontroledl_xcp_eenh) + RETURNING ins_srtcontroledl_xcp_key INTO v_ins_srtcontroledl_xcp_key; + END; + + -- Moeten we nu kijken welke XCP taken er zijn aangemaakt en of deze al afgerond hadden moeten zijn zodat ze niet worden doorgeschoven naar het volgene jaar ? + + + + + + + + fac.imp_writelog (p_import_key, 'I', v_aanduiding || 'Taak is aangemaakt: ' || v_aanduiding, ''); + COMMIT; + + -- TODO moeten we ook taken gaan verwijderen? + + EXCEPTION + WHEN OTHERS + THEN + oracle_err_num := SQLCODE; + oracle_err_mes := SUBSTR (SQLERRM, 1, 200); + v_errormsg := + v_errormsg + || ' ORACLE (error ' + || oracle_err_num + || '/' + || oracle_err_mes + || ')'; + fac.imp_writelog (p_import_key, + 'E', + v_aanduiding || v_errormsg, + ''); + COMMIT; + END; + END LOOP; + +END; +/ +-- EIND MJOB Taken +-- Einde MJOB import op basis van OPrognose + + -- EXPORTS -- Export View