PZEE#75214 Implementatie Provincie Zeeland
svn path=/Customer/trunk/; revision=58115
This commit is contained in:
Suzan Wiegerinck
338
PZEE/PZEE.sql
Normal file
338
PZEE/PZEE.sql
Normal file
@@ -0,0 +1,338 @@
|
||||
--
|
||||
-- $Id$
|
||||
--
|
||||
-- Script containing customer specific sql statements for the FACILITOR database
|
||||
--
|
||||
|
||||
DEFINE thisfile = 'PZEE.SQL'
|
||||
DEFINE dbuser = 'PZEE'
|
||||
|
||||
SET ECHO ON
|
||||
SET DEFINE ON
|
||||
COLUMN fcltlogfile NEW_VALUE fcltlogfile NOPRINT;
|
||||
COLUMN fcltcusttxt NEW_VALUE fcltcusttxt NOPRINT;
|
||||
WHENEVER SQLERROR CONTINUE;
|
||||
SELECT adm.getscriptspoolfile('&thisfile') AS fcltlogfile FROM DUAL;
|
||||
SPOOL &fcltlogfile
|
||||
WHENEVER SQLERROR EXIT;
|
||||
SELECT adm.checkscriptcust('&dbuser') AS fcltcusttxt FROM DUAL;
|
||||
WHENEVER SQLERROR CONTINUE;
|
||||
---------------------------------------
|
||||
PROMPT &fcltcusttxt
|
||||
---------------------------------------
|
||||
SET DEFINE OFF
|
||||
|
||||
------ payload begin ------
|
||||
|
||||
CREATE OR REPLACE PROCEDURE pzee_import_perslid (p_import_key IN NUMBER)
|
||||
AS
|
||||
oracle_err_num NUMBER;
|
||||
oracle_err_mes VARCHAR2 (200);
|
||||
v_errormsg VARCHAR2 (400);
|
||||
v_errorhint VARCHAR2 (400);
|
||||
v_aantal_in_FCLT NUMBER;
|
||||
BEGIN
|
||||
v_errorhint := 'Generieke update';
|
||||
-- de sequence array staat beschreven in PRS_PAC.SRC bij de prs.import_perslid proc
|
||||
prs.import_perslid (
|
||||
p_import_key,
|
||||
'0;0;0;0;0;0;8;1;2;3;'
|
||||
|| '0;0;0;0;0;4;5;7;0;0;'
|
||||
|| '8;6;0;0;0;0;0;0;0;0;'
|
||||
|| '0;0;0;0;0;0;0;0;0;0;'
|
||||
|| '0;0;0;0;0;0',
|
||||
--- Achternaam Voorvoegsel Roepnaam TelefoonnummerVast TelefoonnummerMobiel Netwerknaam Email CodeOrganisatieEenheid
|
||||
'Achternaam;Voorvoegsel;Roepnaam;TelefoonnummerVast;TelefoonnummerMobiel;Netwerknaam;Email;CodeOrganisatieEenheid%');
|
||||
|
||||
COMMIT;
|
||||
|
||||
-- functie wordt niet gebruikt, dus deze wordt altijd 'onbekend'
|
||||
UPDATE fac_imp_perslid
|
||||
SET prs_srtperslid_omschrijving = 'Onbekend';
|
||||
|
||||
COMMIT;
|
||||
EXCEPTION
|
||||
WHEN OTHERS
|
||||
THEN
|
||||
oracle_err_num := SQLCODE;
|
||||
oracle_err_mes := SUBSTR (SQLERRM, 1, 100);
|
||||
v_errormsg := 'Error ' || oracle_err_num || '/' || oracle_err_mes;
|
||||
fac.imp_writelog (p_import_key,
|
||||
'E',
|
||||
v_errormsg,
|
||||
v_errorhint);
|
||||
END pzee_import_perslid;
|
||||
/
|
||||
|
||||
|
||||
CREATE OR REPLACE PROCEDURE pzee_update_perslid (p_import_key IN NUMBER)
|
||||
IS
|
||||
v_count NUMBER;
|
||||
|
||||
CURSOR c_perslid IS
|
||||
SELECT *
|
||||
FROM fac_imp_perslid
|
||||
WHERE prs_perslid_key IS NOT NULL;
|
||||
|
||||
-- Alle medewerkers van de provincie verwijderen die niet meer in import bestand voorkomen.
|
||||
CURSOR c_del IS
|
||||
SELECT p.prs_perslid_key,
|
||||
p.prs_perslid_email,
|
||||
pf.prs_perslid_naam_full
|
||||
FROM prs_perslid p, prs_v_perslid_fullnames_all pf
|
||||
WHERE pf.prs_perslid_key = p.prs_perslid_key
|
||||
AND p.prs_perslid_email IS NOT NULL
|
||||
AND p.prs_perslid_verwijder IS NULL
|
||||
AND p.prs_perslid_oslogin NOT LIKE '%\_%' ESCAPE '\'
|
||||
AND NOT EXISTS
|
||||
(SELECT *
|
||||
FROM fac_imp_perslid i
|
||||
WHERE UPPER (i.prs_perslid_email) =
|
||||
UPPER (p.prs_perslid_email));
|
||||
BEGIN
|
||||
-- generic update
|
||||
SELECT COUNT (*) INTO v_count FROM fac_imp_perslid;
|
||||
|
||||
IF v_count < 750
|
||||
THEN
|
||||
fac.imp_writelog (
|
||||
p_import_key,
|
||||
'E',
|
||||
'Het aantal te importeren personen is te klein ('
|
||||
|| TO_CHAR (v_count)
|
||||
|| ')',
|
||||
'Zie Specificatie');
|
||||
RETURN;
|
||||
END IF;
|
||||
|
||||
-- Match op 'e-mail'
|
||||
prs.update_perslid (p_import_key, 'EMAIL', NULL);
|
||||
|
||||
COMMIT;
|
||||
|
||||
-- Verwijder personen die niet meer in de import voorkomen.
|
||||
FOR rec IN c_del
|
||||
LOOP
|
||||
BEGIN
|
||||
prs.delete_perslid (p_import_key, rec.prs_perslid_key);
|
||||
END;
|
||||
END LOOP;
|
||||
|
||||
COMMIT;
|
||||
|
||||
END pzee_update_perslid;
|
||||
/
|
||||
|
||||
CREATE OR REPLACE PROCEDURE pzee_import_kpl (p_import_key IN NUMBER)
|
||||
IS
|
||||
c_fielddelimitor VARCHAR2 (1) := ';';
|
||||
c_headerline VARCHAR (1000)
|
||||
-- := 'Achternaam;E-mail adres;Extern emailadres;My Nyenrode Login;Studentnummer;Geboortedatum;Geslacht;Voorletters;Roepnaam;Voorvoegsels;Mobiel telefoonnummer;Telefoonnummer;Opleiding;Cohort';
|
||||
:= 'Kostenplaatstype ID;Kostenplaats type;Kostenplaats ID;Kostenplaatsnaam;Kostenplaats ERP ID;Kostenplaats online;Toegangsrecht rol ID;Rol;Gebruiker login;Gebruikernaam;Status gebruiker;Gebruiker verwijderd?';
|
||||
|
||||
v_newline VARCHAR2 (1000); -- Input line
|
||||
v_header VARCHAR2 (1000);
|
||||
v_aanduiding VARCHAR2 (200);
|
||||
v_errorhint VARCHAR2 (1000);
|
||||
v_errormsg VARCHAR2 (1000);
|
||||
oracle_err_num NUMBER;
|
||||
oracle_err_mes VARCHAR2 (200);
|
||||
header_is_valid NUMBER := 0;
|
||||
v_ongeldig NUMBER (1);
|
||||
v_count_tot NUMBER (10);
|
||||
v_count_import NUMBER (10);
|
||||
v_count NUMBER;
|
||||
-- De importvelden:
|
||||
v_kostenplaatstype_id VARCHAR2 (256);
|
||||
v_kostenplaats_type VARCHAR2 (256);
|
||||
v_kostenplaats_id VARCHAR2 (256);
|
||||
v_kostenplaatsnaam VARCHAR2 (256);
|
||||
v_kostenplaats_erp_id VARCHAR2 (256);
|
||||
v_kostenplaats_online VARCHAR2 (256);
|
||||
v_toegangsrecht_rol_id VARCHAR2 (256);
|
||||
v_rol VARCHAR2 (256);
|
||||
v_gebruiker_login VARCHAR2 (256);
|
||||
v_gebruikernaam VARCHAR2 (256);
|
||||
v_status_gebruiker VARCHAR2 (256);
|
||||
v_gebruiker_verwijderd VARCHAR2 (256);
|
||||
|
||||
CURSOR c1 IS
|
||||
SELECT *
|
||||
FROM fac_imp_file
|
||||
WHERE fac_import_key = p_import_key
|
||||
ORDER BY fac_imp_file_index;
|
||||
|
||||
BEGIN
|
||||
DELETE FROM fac_imp_kpn;
|
||||
|
||||
COMMIT;
|
||||
|
||||
v_count_tot := 0;
|
||||
v_count_import := 0;
|
||||
|
||||
FOR rec1 IN c1
|
||||
LOOP
|
||||
BEGIN
|
||||
v_newline := rec1.fac_imp_file_line;
|
||||
v_header := v_newline;
|
||||
v_aanduiding := '';
|
||||
v_errorhint := 'Fout bij opvragen te importeren rij';
|
||||
v_ongeldig := 0;
|
||||
|
||||
-- Lees alle veldwaarden
|
||||
fac.imp_getfield (v_newline, c_fielddelimitor, v_kostenplaatstype_id);
|
||||
fac.imp_getfield (v_newline, c_fielddelimitor, v_kostenplaats_type);
|
||||
fac.imp_getfield (v_newline, c_fielddelimitor, v_kostenplaats_id);
|
||||
fac.imp_getfield (v_newline, c_fielddelimitor, v_kostenplaatsnaam);
|
||||
fac.imp_getfield (v_newline, c_fielddelimitor, v_kostenplaats_erp_id);
|
||||
fac.imp_getfield (v_newline, c_fielddelimitor, v_kostenplaats_online);
|
||||
fac.imp_getfield (v_newline, c_fielddelimitor, v_toegangsrecht_rol_id);
|
||||
fac.imp_getfield (v_newline, c_fielddelimitor, v_rol);
|
||||
fac.imp_getfield (v_newline, c_fielddelimitor, v_gebruiker_login);
|
||||
fac.imp_getfield (v_newline, c_fielddelimitor, v_gebruikernaam);
|
||||
fac.imp_getfield (v_newline, c_fielddelimitor, v_status_gebruiker);
|
||||
fac.imp_getfield (v_newline, c_fielddelimitor, v_gebruiker_verwijderd);
|
||||
|
||||
v_aanduiding :=
|
||||
'['
|
||||
|| v_kostenplaats_id
|
||||
|| '|'
|
||||
|| v_kostenplaatsnaam
|
||||
|| '] ';
|
||||
|
||||
-- Ik controleer of ik een geldige header heb, dat is: in de juiste kolommen
|
||||
-- de juiste kolomkop. Ik controleer daarbij ALLE kolommen!
|
||||
-- Ik negeer alles totdat ik een geldige header ben gepasseerd.
|
||||
IF (header_is_valid = 0)
|
||||
THEN
|
||||
IF UPPER (v_header) LIKE UPPER (c_headerline || '%')
|
||||
THEN
|
||||
header_is_valid := 1;
|
||||
END IF;
|
||||
ELSE
|
||||
v_count_tot := v_count_tot + 1;
|
||||
|
||||
-- Insert geformatteerde import record
|
||||
IF header_is_valid = 1
|
||||
THEN
|
||||
BEGIN
|
||||
v_errorhint :=
|
||||
'Fout bij toevoegen regel aan importtabel fac_imp_kpn';
|
||||
|
||||
INSERT INTO fac_imp_kpn (prs_kostenplaats_nr,
|
||||
prs_kostenplaats_omschrijving,
|
||||
prs_kostenplaats_module,
|
||||
prs_kostenplaats_externnr ---- deze misbruiken we voor de budgehouder
|
||||
)
|
||||
|
||||
VALUES (v_kostenplaats_id,
|
||||
v_kostenplaatsnaam,
|
||||
DECODE (v_kostenplaats_type, ----ALG = Gebouwkostenplaats, PRS = Afdelingskostenplaats, PRJ = Projectkostenplaats
|
||||
'IBCF', 'PRJ' ,
|
||||
'IBTW', 'PRJ' ,
|
||||
'IKST', 'PRJ' ,
|
||||
'VB0' , 'PRJ'),
|
||||
v_gebruiker_login
|
||||
);
|
||||
|
||||
|
||||
COMMIT;
|
||||
|
||||
v_count_import := v_count_import + 1;
|
||||
EXCEPTION
|
||||
WHEN OTHERS
|
||||
THEN
|
||||
oracle_err_num := SQLCODE;
|
||||
oracle_err_mes := SUBSTR (SQLERRM, 1, 100);
|
||||
v_errormsg :=
|
||||
v_errorhint
|
||||
|| ' ORACLE (error '
|
||||
|| oracle_err_num
|
||||
|| '/'
|
||||
|| oracle_err_mes
|
||||
|| ')';
|
||||
fac.imp_writelog (
|
||||
p_import_key,
|
||||
'W',
|
||||
v_aanduiding || v_errormsg,
|
||||
'Ingelezen regel kan niet worden weggeschreven!');
|
||||
COMMIT;
|
||||
END;
|
||||
END IF;
|
||||
END IF; -- header_valid
|
||||
END;
|
||||
END LOOP;
|
||||
|
||||
--- nu even de juiste budgethouder op basis van het emailadres bepalen
|
||||
UPDATE fac_imp_kpn k
|
||||
SET k.prs_perslid_key =
|
||||
(SELECT p.prs_perslid_key
|
||||
FROM prs_perslid p
|
||||
WHERE UPPER (k.prs_kostenplaats_externnr) = UPPER (p.prs_perslid_email));
|
||||
|
||||
--- en de tijdelijke veldwaarde opruimen
|
||||
UPDATE fac_imp_kpn
|
||||
SET prs_kostenplaats_externnr = NULL
|
||||
WHERE prs_kostenplaats_externnr IS NOT NULL;
|
||||
|
||||
IF (header_is_valid = 1)
|
||||
THEN
|
||||
fac.imp_writelog (
|
||||
p_import_key,
|
||||
'S',
|
||||
'Kostenplaatsen: aantal ingelezen regels: ' || TO_CHAR (v_count_tot),
|
||||
'');
|
||||
fac.imp_writelog (
|
||||
p_import_key,
|
||||
'S',
|
||||
'Persoon: aantal ongeldige importregels: '
|
||||
|| TO_CHAR (v_count_tot - v_count_import),
|
||||
'');
|
||||
ELSE
|
||||
fac.imp_writelog (
|
||||
p_import_key,
|
||||
'E',
|
||||
'Ongeldige headerregel!',
|
||||
SUBSTR ('Moet zijn: "' || c_headerline || '"', 1, 1000));
|
||||
END IF;
|
||||
EXCEPTION
|
||||
WHEN OTHERS
|
||||
THEN
|
||||
oracle_err_num := SQLCODE;
|
||||
oracle_err_mes := SUBSTR (SQLERRM, 1, 100);
|
||||
v_errormsg :=
|
||||
'OTHERS (error '
|
||||
|| oracle_err_num
|
||||
|| '/'
|
||||
|| oracle_err_mes
|
||||
|| ')';
|
||||
fac.imp_writelog (p_import_key,
|
||||
'E',
|
||||
v_aanduiding || v_errormsg,
|
||||
v_errorhint);
|
||||
COMMIT;
|
||||
END pzee_import_kpl;
|
||||
/
|
||||
|
||||
CREATE OR REPLACE PROCEDURE pzee_update_kpl (p_import_key IN NUMBER)
|
||||
AS
|
||||
|
||||
BEGIN
|
||||
|
||||
fac_update_kpn (p_import_key);
|
||||
|
||||
END pzee_update_kpl;
|
||||
/
|
||||
|
||||
|
||||
------ payload end ------
|
||||
|
||||
SET DEFINE OFF
|
||||
BEGIN adm.systrackscriptId ('$Id$', 0); END;
|
||||
/
|
||||
|
||||
COMMIT;
|
||||
SET ECHO OFF
|
||||
SPOOL OFF
|
||||
SET DEFINE ON
|
||||
PROMPT Logfile of this upgrade is: &fcltlogfile
|
||||
Reference in New Issue
Block a user