532596bab7
git-svn-id: http://locode01.ad.dom/svn/WEBMIP/trunk@3850 248e525c-4dfb-0310-94bc-949c084e9493
1810 lines
52 KiB
Plaintext
1810 lines
52 KiB
Plaintext
CREATE OR REPLACE PACKAGE mip_bulk_load IS
|
|
|
|
-- Author : HARDYA
|
|
-- Created : 08/01/2008 14:26:14
|
|
-- Purpose : Bulk data load routines
|
|
|
|
g_flow_id NUMBER DEFAULT nvl(apex_application.g_flow_id
|
|
,155);
|
|
|
|
PROCEDURE init;
|
|
|
|
PROCEDURE load_meters;
|
|
PROCEDURE load_modules;
|
|
PROCEDURE load_drawings;
|
|
PROCEDURE load_housings;
|
|
PROCEDURE load_bases;
|
|
PROCEDURE load_costs;
|
|
PROCEDURE load_postcodes;
|
|
PROCEDURE load_leadtimes;
|
|
|
|
PROCEDURE report_err;
|
|
|
|
PROCEDURE load_all;
|
|
|
|
END mip_bulk_load;
|
|
/
|
|
CREATE OR REPLACE PACKAGE BODY mip_bulk_load IS
|
|
|
|
g_other_manufacturer_id parties.id%TYPE;
|
|
|
|
PROCEDURE pl(p_in IN VARCHAR2) IS
|
|
BEGIN
|
|
dbms_output.put_line(to_char(SYSDATE
|
|
,'DD-MON-YYYY HH24:MI:SS') || '-' || p_in);
|
|
dbms_application_info.set_client_info(p_in);
|
|
END pl;
|
|
|
|
PROCEDURE get_dir_list(p_directory IN VARCHAR2) AS
|
|
LANGUAGE JAVA NAME 'DirList.getList( java.lang.String )';
|
|
|
|
FUNCTION file_available(p_filename IN VARCHAR2
|
|
,p_directory IN VARCHAR2 DEFAULT 'WEBMIP_BULK_LOAD')
|
|
RETURN BOOLEAN IS
|
|
l_exists BOOLEAN;
|
|
l_file_length NUMBER;
|
|
l_block_size NUMBER;
|
|
BEGIN
|
|
utl_file.fgetattr(location => p_directory
|
|
,filename => p_filename
|
|
,fexists => l_exists
|
|
,file_length => l_file_length
|
|
,block_size => l_block_size);
|
|
RETURN l_exists;
|
|
|
|
END file_available;
|
|
|
|
PROCEDURE get_globals IS
|
|
BEGIN
|
|
|
|
BEGIN
|
|
SELECT id
|
|
INTO g_other_manufacturer_id
|
|
FROM parties
|
|
WHERE NAME = 'OTHER'
|
|
AND prty_type = 'MANU';
|
|
EXCEPTION
|
|
WHEN no_data_found THEN
|
|
INSERT INTO parties
|
|
(id
|
|
,NAME
|
|
,manu_ref
|
|
,description
|
|
,prty_type
|
|
,created_on
|
|
,created_by)
|
|
VALUES
|
|
(prty_seq.NEXTVAL
|
|
,'OTHER'
|
|
,'OTHER'
|
|
,'Other Manufacturer'
|
|
,'MANU'
|
|
,SYSDATE
|
|
,USER)
|
|
RETURNING id INTO g_other_manufacturer_id;
|
|
END;
|
|
|
|
BEGIN
|
|
INSERT INTO meter_types
|
|
(code
|
|
,description)
|
|
VALUES
|
|
('OTHER'
|
|
,'OTHER Meter Type');
|
|
EXCEPTION
|
|
WHEN dup_val_on_index THEN
|
|
NULL;
|
|
END;
|
|
|
|
BEGIN
|
|
INSERT INTO meter_size_codes
|
|
(code
|
|
,description
|
|
,qmax
|
|
,valid_for_existing_meter
|
|
,valid_for_new_meter)
|
|
VALUES
|
|
('OTHER'
|
|
,'Other Meter Size'
|
|
,0
|
|
,'YES'
|
|
,'YES');
|
|
EXCEPTION
|
|
WHEN dup_val_on_index THEN
|
|
NULL;
|
|
END;
|
|
|
|
BEGIN
|
|
INSERT INTO meters
|
|
(code
|
|
,mesc_code
|
|
,mety_code
|
|
,prty_id
|
|
,valid_from)
|
|
VALUES
|
|
('OTHER'
|
|
,'OTHER'
|
|
,'OTHER'
|
|
,g_other_manufacturer_id
|
|
,SYSDATE);
|
|
EXCEPTION
|
|
WHEN dup_val_on_index THEN
|
|
NULL;
|
|
END;
|
|
|
|
BEGIN
|
|
INSERT INTO housing_types
|
|
(code
|
|
,description)
|
|
VALUES
|
|
('OTHER'
|
|
,'Other Housing Type');
|
|
EXCEPTION
|
|
WHEN dup_val_on_index THEN
|
|
NULL;
|
|
END;
|
|
|
|
BEGIN
|
|
INSERT INTO regulator_types
|
|
(code
|
|
,description)
|
|
VALUES
|
|
('OTHER'
|
|
,'Other Regulator Type');
|
|
EXCEPTION
|
|
WHEN dup_val_on_index THEN
|
|
NULL;
|
|
END;
|
|
|
|
BEGIN
|
|
INSERT INTO filter_types
|
|
(code
|
|
,description)
|
|
VALUES
|
|
('OTHER'
|
|
,'Other Filter Type');
|
|
EXCEPTION
|
|
WHEN dup_val_on_index THEN
|
|
NULL;
|
|
END;
|
|
|
|
BEGIN
|
|
INSERT INTO relief_valve_types
|
|
(code
|
|
,description)
|
|
VALUES
|
|
('OTHER'
|
|
,'Other Relief Valve Type');
|
|
EXCEPTION
|
|
WHEN dup_val_on_index THEN
|
|
NULL;
|
|
END;
|
|
|
|
BEGIN
|
|
INSERT INTO relief_valves
|
|
(code
|
|
,rvty_code)
|
|
VALUES
|
|
('OTHER'
|
|
,'OTHER');
|
|
EXCEPTION
|
|
WHEN dup_val_on_index THEN
|
|
NULL;
|
|
END;
|
|
|
|
BEGIN
|
|
INSERT INTO slamshut_types
|
|
(code
|
|
,description)
|
|
VALUES
|
|
('OTHER'
|
|
,'Other Slamshut Type ');
|
|
EXCEPTION
|
|
WHEN dup_val_on_index THEN
|
|
NULL;
|
|
END;
|
|
|
|
BEGIN
|
|
INSERT INTO slamshut_valves
|
|
(code
|
|
,slty_code)
|
|
VALUES
|
|
('OTHER'
|
|
,'OTHER');
|
|
EXCEPTION
|
|
WHEN dup_val_on_index THEN
|
|
NULL;
|
|
END;
|
|
|
|
BEGIN
|
|
INSERT INTO service_pressure_types
|
|
(code
|
|
,description)
|
|
VALUES
|
|
('OTHER'
|
|
,'Other Service Pressure Type ');
|
|
EXCEPTION
|
|
WHEN dup_val_on_index THEN
|
|
NULL;
|
|
END;
|
|
|
|
BEGIN
|
|
INSERT INTO drawings
|
|
(code
|
|
,description)
|
|
VALUES
|
|
('OTHER'
|
|
,'Other Drawing ');
|
|
EXCEPTION
|
|
WHEN dup_val_on_index THEN
|
|
NULL;
|
|
END;
|
|
|
|
END get_globals;
|
|
|
|
PROCEDURE load_meters IS
|
|
BEGIN
|
|
|
|
pl('load_meters');
|
|
|
|
IF NOT file_available('METERS.csv') THEN
|
|
pl('METERS.csv file missing');
|
|
RETURN;
|
|
END IF;
|
|
-- Meter Types
|
|
INSERT INTO meter_types
|
|
(code
|
|
,description)
|
|
(SELECT code
|
|
,initcap(code)
|
|
FROM (SELECT DISTINCT upper(TRIM(mety_code)) AS code
|
|
FROM ext_meters)
|
|
WHERE code IS NOT NULL
|
|
AND code NOT IN (SELECT code
|
|
FROM meter_types));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': meter_types');
|
|
-- Meter Sizes
|
|
INSERT INTO meter_size_codes
|
|
(code
|
|
,description
|
|
,qmax
|
|
,valid_for_existing_meter
|
|
,valid_for_new_meter)
|
|
(SELECT code
|
|
,initcap(code)
|
|
,0
|
|
,'YES'
|
|
,'NO'
|
|
FROM (SELECT DISTINCT upper(REPLACE(TRIM(mesc_code)
|
|
,'"'
|
|
,'inch')) AS code
|
|
FROM ext_meters)
|
|
WHERE code IS NOT NULL
|
|
AND code NOT IN (SELECT code
|
|
FROM meter_size_codes));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': meter_size_codes');
|
|
|
|
-- Manufacturers
|
|
INSERT INTO parties
|
|
(id
|
|
,manu_ref
|
|
,NAME
|
|
,description
|
|
,prty_type
|
|
,created_on
|
|
,created_by)
|
|
(SELECT prty_seq.NEXTVAL
|
|
,manu_ref
|
|
,manu_ref
|
|
,initcap(manu_ref)
|
|
,'MANU'
|
|
,SYSDATE
|
|
,USER
|
|
FROM (SELECT DISTINCT upper(TRIM(manu_ref)) AS manu_ref
|
|
FROM ext_meters)
|
|
WHERE manu_ref IS NOT NULL
|
|
AND manu_ref NOT IN (SELECT manu_ref
|
|
FROM parties
|
|
WHERE prty_type = 'MANU'));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': manufacturers');
|
|
|
|
-- Drawings
|
|
INSERT INTO drawings
|
|
(code
|
|
,description)
|
|
(SELECT code
|
|
,code
|
|
FROM (SELECT DISTINCT upper(TRIM(drwg_code)) AS code
|
|
FROM ext_meters)
|
|
WHERE code IS NOT NULL
|
|
AND code NOT IN (SELECT code
|
|
FROM drawings));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': drawings');
|
|
|
|
MERGE INTO meters metr
|
|
USING (SELECT upper(REPLACE(TRIM(code)
|
|
,'"'
|
|
,'inch')) AS code
|
|
,upper(TRIM(drwg_code)) AS drwg_code
|
|
,upper(TRIM(mety_code)) AS mety_code
|
|
,p.id AS prty_id
|
|
,dim_a
|
|
,dim_b
|
|
,dim_c
|
|
,centres
|
|
,weight
|
|
,qmax
|
|
,CASE
|
|
WHEN valid_from IS NULL THEN
|
|
SYSDATE
|
|
ELSE
|
|
to_date(valid_from
|
|
,'dd/mm/yyyy')
|
|
END AS valid_from
|
|
,CASE
|
|
WHEN valid_to IS NULL THEN
|
|
NULL
|
|
ELSE
|
|
to_date(valid_to
|
|
,'dd/mm/yyyy')
|
|
END AS valid_to
|
|
,qmin
|
|
,qnom
|
|
,upper(REPLACE(TRIM(mesc_code)
|
|
,'"'
|
|
,'inch')) AS mesc_code
|
|
FROM ext_meters
|
|
,parties p
|
|
WHERE p.manu_ref = upper(TRIM(ext_meters.manu_ref))
|
|
AND p.prty_type = 'MANU') e
|
|
ON (e.code = metr.code)
|
|
WHEN MATCHED THEN
|
|
UPDATE
|
|
SET drwg_code = e.drwg_code
|
|
,mety_code = e.mety_code
|
|
,prty_id = e.prty_id
|
|
,dim_a = e.dim_a
|
|
,dim_b = e.dim_b
|
|
,centres = e.centres
|
|
,dim_c = e.dim_c
|
|
,weight = e.weight
|
|
,qmax = e.qmax
|
|
,valid_from = e.valid_from
|
|
,valid_to = e.valid_to
|
|
,qnom = e.qnom
|
|
,qmin = e.qmin
|
|
,mesc_code = e.mesc_code
|
|
WHEN NOT MATCHED THEN
|
|
INSERT
|
|
(code
|
|
,drwg_code
|
|
,mety_code
|
|
,prty_id
|
|
,dim_a
|
|
,dim_b
|
|
,centres
|
|
,dim_c
|
|
,weight
|
|
,qmax
|
|
,valid_from
|
|
,valid_to
|
|
,qnom
|
|
,qmin
|
|
,mesc_code)
|
|
VALUES
|
|
(e.code
|
|
,e.drwg_code
|
|
,e.mety_code
|
|
,e.prty_id
|
|
,e.dim_a
|
|
,e.dim_b
|
|
,e.centres
|
|
,e.dim_c
|
|
,e.weight
|
|
,e.qmax
|
|
,e.valid_from
|
|
,e.valid_to
|
|
,e.qnom
|
|
,e.qmin
|
|
,e.mesc_code) log errors reject LIMIT unlimited;
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': meters');
|
|
END load_meters;
|
|
|
|
PROCEDURE load_modules IS
|
|
BEGIN
|
|
|
|
pl('load_modules');
|
|
|
|
IF NOT file_available('MODULES.csv') THEN
|
|
pl('MODULES.csv file missing');
|
|
RETURN;
|
|
END IF;
|
|
|
|
-- Add any missing foreign key objects
|
|
|
|
-- Connection types
|
|
INSERT INTO connection_types
|
|
(code
|
|
,description)
|
|
(SELECT code
|
|
,initcap(code)
|
|
FROM (SELECT DISTINCT code
|
|
FROM (SELECT upper(REPLACE(TRIM(inlet_cnty_code)
|
|
,'"'
|
|
,'inch')) AS code
|
|
FROM ext_modules
|
|
UNION
|
|
SELECT upper(REPLACE(TRIM(outlet_cnty_code)
|
|
,'"'
|
|
,'inch'))
|
|
FROM ext_modules))
|
|
WHERE code IS NOT NULL
|
|
AND code NOT IN (SELECT code
|
|
FROM connection_types));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': connection_types');
|
|
-- Drawings
|
|
INSERT INTO drawings
|
|
(code
|
|
,description)
|
|
(SELECT code
|
|
,code
|
|
FROM (SELECT DISTINCT upper(TRIM(drwg_code)) AS code
|
|
FROM ext_modules
|
|
WHERE TRIM(drwg_code) IS NOT NULL)
|
|
WHERE code IS NOT NULL
|
|
AND code NOT IN (SELECT code
|
|
FROM drawings));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': drawings');
|
|
|
|
-- Manufacturers
|
|
INSERT INTO parties
|
|
(id
|
|
,manu_ref
|
|
,NAME
|
|
,description
|
|
,prty_type
|
|
,created_on
|
|
,created_by)
|
|
(SELECT prty_seq.NEXTVAL
|
|
,manu_ref
|
|
,manu_ref
|
|
,initcap(manu_ref)
|
|
,'MANU'
|
|
,SYSDATE
|
|
,USER
|
|
FROM (SELECT DISTINCT upper(TRIM(manu_ref)) AS manu_ref
|
|
FROM ext_modules)
|
|
WHERE manu_ref IS NOT NULL
|
|
AND manu_ref NOT IN (SELECT manu_ref
|
|
FROM parties
|
|
WHERE prty_type = 'MANU'));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': manufacturers');
|
|
|
|
-- Relief valves
|
|
INSERT INTO relief_valves
|
|
(code
|
|
,rvty_code
|
|
,relief_valve_size
|
|
,relief_valve_setting)
|
|
(SELECT code
|
|
,'OTHER'
|
|
,999
|
|
,999
|
|
FROM (SELECT DISTINCT upper(TRIM(reva_code)) AS code
|
|
FROM ext_modules
|
|
WHERE TRIM(reva_code) IS NOT NULL)
|
|
WHERE code NOT IN (SELECT code
|
|
FROM relief_valves));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': relief_valves');
|
|
-- Slamshut valves
|
|
INSERT INTO slamshut_valves
|
|
(code
|
|
,slty_code
|
|
,slamshut_size
|
|
,slamshut_setting)
|
|
(SELECT code
|
|
,'OTHER'
|
|
,999
|
|
,999
|
|
FROM (SELECT DISTINCT upper(TRIM(slva_code)) AS code
|
|
FROM ext_modules
|
|
WHERE TRIM(slva_code) IS NOT NULL)
|
|
WHERE code NOT IN (SELECT code
|
|
FROM slamshut_valves));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': slamshut_valves');
|
|
|
|
-- Service pressures
|
|
INSERT INTO service_pressures
|
|
(code
|
|
,svcpt_code
|
|
,description)
|
|
(SELECT code
|
|
,'OTHER'
|
|
,code
|
|
FROM (SELECT DISTINCT upper(TRIM(svcp_code)) AS code
|
|
FROM ext_modules)
|
|
WHERE code IS NOT NULL
|
|
AND code NOT IN (SELECT code
|
|
FROM service_pressures));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': service_pressures');
|
|
|
|
-- Bases
|
|
INSERT INTO bases
|
|
(code
|
|
,drwg_code
|
|
,description
|
|
,dim_a
|
|
,dim_b
|
|
,dim_c
|
|
,dim_d
|
|
,dim_e
|
|
,dim_f
|
|
,dim_g
|
|
,dim_h
|
|
,dim_i
|
|
,depth)
|
|
(SELECT code
|
|
,'OTHER'
|
|
,code
|
|
,999
|
|
,999
|
|
,999
|
|
,999
|
|
,999
|
|
,999
|
|
,999
|
|
,999
|
|
,999
|
|
,999
|
|
FROM (SELECT DISTINCT upper(TRIM(bas_code)) AS code
|
|
FROM ext_modules)
|
|
WHERE code IS NOT NULL
|
|
AND code NOT IN (SELECT code
|
|
FROM bases));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': bases');
|
|
|
|
-- Housings
|
|
INSERT INTO housings
|
|
(code
|
|
,drwg_code
|
|
,hoty_code
|
|
,prty_id
|
|
,description
|
|
,dim_l
|
|
,dim_w
|
|
,dim_h
|
|
,weight)
|
|
(SELECT code
|
|
,'OTHER'
|
|
,'OTHER'
|
|
,g_other_manufacturer_id
|
|
,code
|
|
,999
|
|
,999
|
|
,999
|
|
,999
|
|
FROM (SELECT DISTINCT upper(TRIM(hou_code)) AS code
|
|
FROM ext_modules)
|
|
WHERE code IS NOT NULL
|
|
AND code NOT IN (SELECT code
|
|
FROM housings));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': housings');
|
|
|
|
-- Regulators
|
|
INSERT INTO regulators
|
|
(code
|
|
,rety_code
|
|
,description
|
|
,regulator_size
|
|
,lock_up)
|
|
(SELECT code
|
|
,'OTHER'
|
|
,code
|
|
,999
|
|
,999
|
|
FROM (SELECT DISTINCT upper(TRIM(regu_code)) AS code
|
|
FROM ext_modules)
|
|
WHERE code IS NOT NULL
|
|
AND code NOT IN (SELECT code
|
|
FROM regulators));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': regulators');
|
|
|
|
-- Filters
|
|
INSERT INTO filters
|
|
(code
|
|
,fity_code
|
|
,filter_size)
|
|
(SELECT code
|
|
,'OTHER'
|
|
,999
|
|
FROM (SELECT DISTINCT upper(TRIM(fltr_code)) AS code
|
|
FROM ext_modules)
|
|
WHERE code IS NOT NULL
|
|
AND code NOT IN (SELECT code
|
|
FROM filters));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': filters');
|
|
|
|
-- Connection orientations
|
|
INSERT INTO connection_orientations
|
|
(code
|
|
,description)
|
|
(SELECT code
|
|
,initcap(code)
|
|
FROM (SELECT DISTINCT code
|
|
FROM (SELECT upper(TRIM(inlet_cnor_code)) AS code
|
|
FROM ext_modules
|
|
UNION
|
|
SELECT upper(TRIM(outlet_cnor_code))
|
|
FROM ext_modules)
|
|
WHERE code IS NOT NULL)
|
|
WHERE code NOT IN (SELECT code
|
|
FROM connection_orientations));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': connection_orientations');
|
|
|
|
MERGE INTO modules modu
|
|
USING (SELECT upper(TRIM(code)) AS code
|
|
,upper(REPLACE(TRIM(outlet_cnty_code)
|
|
,'"'
|
|
,'inch')) AS outlet_cnty_code
|
|
,upper(REPLACE(TRIM(inlet_cnty_code)
|
|
,'"'
|
|
,'inch')) AS inlet_cnty_code
|
|
,upper(TRIM(drwg_code)) AS drwg_code
|
|
,upper(TRIM(metr_code)) AS metr_code
|
|
,upper(TRIM(reva_code)) AS reva_code
|
|
,upper(TRIM(slva_code)) AS slva_code
|
|
,upper(TRIM(svcp_code)) AS svcp_code
|
|
,weight
|
|
,inlet_height
|
|
,inlet_size
|
|
,outlet_pressure
|
|
,outlet_height
|
|
,outlet_size
|
|
,upper(TRIM(bas_code)) AS bas_code
|
|
,upper(TRIM(hou_code)) AS hou_code
|
|
,dim_a
|
|
,dim_b
|
|
,dim_c
|
|
,dim_d
|
|
,dim_e
|
|
,dim_f
|
|
,dim_h
|
|
,CASE
|
|
WHEN valid_from IS NULL THEN
|
|
trunc(SYSDATE)
|
|
ELSE
|
|
to_date(valid_from
|
|
,'dd/mm/yyyy')
|
|
END AS valid_from
|
|
,CASE
|
|
WHEN valid_to IS NULL THEN
|
|
NULL
|
|
ELSE
|
|
to_date(valid_to
|
|
,'dd/mm/yyyy')
|
|
END AS valid_to
|
|
,upper(TRIM(regu_code)) AS regu_code
|
|
,upper(TRIM(fltr_code)) AS fltr_code
|
|
,upper(TRIM(inlet_cnor_code)) AS inlet_cnor_code
|
|
,upper(TRIM(outlet_cnor_code)) AS outlet_cnor_code
|
|
,lead_time
|
|
,p.id AS prty_id
|
|
,qmax
|
|
FROM ext_modules e
|
|
,parties p
|
|
WHERE p.manu_ref = upper(TRIM(e.manu_ref))
|
|
AND p.prty_type = 'MANU') e
|
|
ON (upper(e.code) = modu.code)
|
|
WHEN MATCHED THEN
|
|
UPDATE
|
|
SET outlet_cnty_code = e.outlet_cnty_code
|
|
,inlet_cnty_code = e.inlet_cnty_code
|
|
,drwg_code = e.drwg_code
|
|
,metr_code = e.metr_code
|
|
,reva_code = e.reva_code
|
|
,slva_code = e.slva_code
|
|
,svcp_code = e.svcp_code
|
|
,weight = e.weight
|
|
,inlet_height = e.inlet_height
|
|
,inlet_size = e.inlet_size
|
|
,outlet_pressure = e.outlet_pressure
|
|
,outlet_height = e.outlet_height
|
|
,outlet_size = e.outlet_size
|
|
,bas_code = e.bas_code
|
|
,hou_code = e.hou_code
|
|
,dim_a = e.dim_a
|
|
,dim_b = e.dim_b
|
|
,dim_c = e.dim_c
|
|
,dim_e = e.dim_e
|
|
,dim_f = e.dim_f
|
|
,dim_h = e.dim_h
|
|
,valid_from = e.valid_from
|
|
,valid_to = e.valid_to
|
|
,regu_code = e.regu_code
|
|
,fltr_code = e.fltr_code
|
|
,inlet_cnor_code = e.inlet_cnor_code
|
|
,outlet_cnor_code = e.outlet_cnor_code
|
|
,lead_time = e.lead_time
|
|
,prty_id = e.prty_id
|
|
,qmax = e.qmax
|
|
WHEN NOT MATCHED THEN
|
|
INSERT
|
|
(code
|
|
,outlet_cnty_code
|
|
,inlet_cnty_code
|
|
,drwg_code
|
|
,metr_code
|
|
,reva_code
|
|
,slva_code
|
|
,svcp_code
|
|
,weight
|
|
,inlet_height
|
|
,inlet_size
|
|
,outlet_pressure
|
|
,outlet_height
|
|
,outlet_size
|
|
,bas_code
|
|
,hou_code
|
|
,dim_a
|
|
,dim_b
|
|
,dim_c
|
|
,dim_d
|
|
,dim_e
|
|
,dim_f
|
|
,dim_h
|
|
,valid_from
|
|
,valid_to
|
|
,regu_code
|
|
,fltr_code
|
|
,inlet_cnor_code
|
|
,outlet_cnor_code
|
|
,lead_time
|
|
,prty_id
|
|
,qmax)
|
|
VALUES
|
|
(e.code
|
|
,e.outlet_cnty_code
|
|
,e.inlet_cnty_code
|
|
,e.drwg_code
|
|
,e.metr_code
|
|
,e.reva_code
|
|
,e.slva_code
|
|
,e.svcp_code
|
|
,e.weight
|
|
,e.inlet_height
|
|
,e.inlet_size
|
|
,e.outlet_pressure
|
|
,e.outlet_height
|
|
,e.outlet_size
|
|
,e.bas_code
|
|
,e.hou_code
|
|
,e.dim_a
|
|
,e.dim_b
|
|
,e.dim_c
|
|
,e.dim_d
|
|
,e.dim_e
|
|
,e.dim_f
|
|
,e.dim_h
|
|
,e.valid_from
|
|
,e.valid_to
|
|
,e.regu_code
|
|
,e.fltr_code
|
|
,e.inlet_cnor_code
|
|
,e.outlet_cnor_code
|
|
,e.lead_time
|
|
,e.prty_id
|
|
,e.qmax) log errors reject LIMIT unlimited;
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': modules');
|
|
|
|
END load_modules;
|
|
|
|
PROCEDURE load_drawings IS
|
|
l_directory_path all_directories.directory_path%TYPE;
|
|
l_uri wwv_flow_files.NAME%TYPE;
|
|
l_source_file BFILE;
|
|
l_source_file_length BINARY_INTEGER;
|
|
l_blob BLOB;
|
|
l_success BOOLEAN;
|
|
l_load_count NUMBER := 0;
|
|
BEGIN
|
|
|
|
pl('load_drawings');
|
|
|
|
dbms_lob.createtemporary(lob_loc => l_blob
|
|
,cache => TRUE);
|
|
dbms_lob.OPEN(lob_loc => l_blob
|
|
,open_mode => dbms_lob.lob_readwrite);
|
|
|
|
SELECT directory_path
|
|
INTO l_directory_path
|
|
FROM all_directories
|
|
WHERE directory_name = 'WEBMIP_BULK_LOAD';
|
|
|
|
get_dir_list(l_directory_path);
|
|
|
|
FOR l_rec IN (SELECT filename AS filename
|
|
,upper(substr(filename
|
|
,1
|
|
,regexp_instr(filename
|
|
,'.(jpg)|.(jpeg)$'
|
|
,1
|
|
,1
|
|
,0
|
|
,'i') - 1)) AS drwg_code
|
|
,substr(filename
|
|
,regexp_instr(filename
|
|
,'.(jpg)|.(jpeg)$'
|
|
,1
|
|
,1
|
|
,0
|
|
,'i') + 1) AS filename_suffix
|
|
FROM gtt_dir_list g
|
|
WHERE g.filetype = 'F'
|
|
AND regexp_like(g.filename
|
|
,'.(jpg)|.(jpeg)$'
|
|
,'i')) LOOP
|
|
|
|
l_source_file := bfilename('WEBMIP_BULK_LOAD'
|
|
,l_rec.filename);
|
|
l_source_file_length := dbms_lob.getlength(l_source_file);
|
|
|
|
dbms_lob.OPEN(file_loc => l_source_file
|
|
,open_mode => dbms_lob.lob_readonly);
|
|
|
|
dbms_lob.loadfromfile(dest_lob => l_blob
|
|
,src_lob => l_source_file
|
|
,amount => l_source_file_length);
|
|
|
|
dbms_lob.fileclose(file_loc => l_source_file);
|
|
|
|
BEGIN
|
|
SAVEPOINT this_drawing_savepoint;
|
|
BEGIN
|
|
INSERT INTO drawings
|
|
(code
|
|
,description)
|
|
VALUES
|
|
(l_rec.drwg_code
|
|
,l_rec.drwg_code);
|
|
EXCEPTION
|
|
WHEN dup_val_on_index THEN
|
|
NULL;
|
|
END;
|
|
|
|
DELETE FROM wwv_flow_files
|
|
WHERE NAME LIKE '%/' || l_rec.filename;
|
|
|
|
DELETE FROM document_roles doro
|
|
WHERE doro.drwg_code = l_rec.drwg_code;
|
|
|
|
DELETE FROM documents doco
|
|
WHERE doco.uri = '%/' || l_rec.filename;
|
|
|
|
INSERT INTO wwv_flow_files
|
|
(NAME
|
|
,title
|
|
,mime_type
|
|
,flow_id
|
|
,doc_size
|
|
,description
|
|
,blob_content)
|
|
VALUES
|
|
(sys_guid() || '/' || l_rec.filename
|
|
,'Drawing'
|
|
,'image/' || l_rec.filename_suffix
|
|
,apex_application.g_flow_id
|
|
,l_source_file_length
|
|
,'Bulk Loaded on ' ||
|
|
to_char(SYSDATE
|
|
,'DD-MON-YYYY HH24:MI:SS')
|
|
,l_blob)
|
|
RETURNING NAME INTO l_uri;
|
|
|
|
l_success := mip_files.set_file_association(p_uri => l_uri
|
|
,p_description => 'Drawing'
|
|
,p_docu_type => 'INDO'
|
|
,p_rt_code => 'HIGH DEFINITION DRAWING'
|
|
,p_qute_id => NULL
|
|
,p_enqu_id => NULL
|
|
,p_drwg_code => l_rec.drwg_code
|
|
,p_doro_type => 'DRRO');
|
|
IF NOT l_success THEN
|
|
ROLLBACK TO this_drawing_savepoint;
|
|
ELSE
|
|
l_load_count := l_load_count + 1;
|
|
END IF;
|
|
END;
|
|
END LOOP;
|
|
|
|
pl(l_load_count || ': drawings');
|
|
END load_drawings;
|
|
|
|
PROCEDURE load_bases IS
|
|
BEGIN
|
|
|
|
pl('load_bases');
|
|
|
|
IF NOT file_available('BASES.csv') THEN
|
|
pl('BASES.csv file missing');
|
|
RETURN;
|
|
END IF;
|
|
|
|
-- Drawings
|
|
INSERT INTO drawings
|
|
(code
|
|
,description)
|
|
(SELECT code
|
|
,code
|
|
FROM (SELECT DISTINCT upper(TRIM(field_2)) AS code
|
|
FROM ext_bases
|
|
WHERE TRIM(field_2) IS NOT NULL)
|
|
WHERE code NOT IN (SELECT code
|
|
FROM drawings));
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': drawings');
|
|
MERGE INTO bases bas
|
|
USING (SELECT upper(TRIM(field_1)) AS field_1
|
|
,upper(TRIM(field_2)) AS field_2
|
|
,field_3
|
|
,field_4
|
|
,field_5
|
|
,field_6
|
|
,field_7
|
|
,field_8
|
|
,field_9
|
|
,field_10
|
|
,field_11
|
|
,field_12
|
|
,field_13
|
|
FROM ext_bases) e
|
|
ON (e.field_1 = bas.code)
|
|
WHEN MATCHED THEN
|
|
UPDATE
|
|
SET drwg_code = e.field_2
|
|
,description = nvl(e.field_3
|
|
,initcap(e.field_1))
|
|
,dim_a = e.field_4
|
|
,dim_b = e.field_5
|
|
,dim_c = e.field_6
|
|
,dim_d = e.field_7
|
|
,dim_e = e.field_8
|
|
,dim_f = e.field_9
|
|
,dim_g = e.field_10
|
|
,dim_h = e.field_11
|
|
,dim_i = e.field_12
|
|
,depth = e.field_13
|
|
WHEN NOT MATCHED THEN
|
|
INSERT
|
|
(code
|
|
,drwg_code
|
|
,description
|
|
,dim_a
|
|
,dim_b
|
|
,dim_c
|
|
,dim_d
|
|
,dim_e
|
|
,dim_f
|
|
,dim_g
|
|
,dim_h
|
|
,dim_i
|
|
,depth)
|
|
VALUES
|
|
(e.field_1
|
|
,e.field_2
|
|
,nvl(e.field_3
|
|
,initcap(e.field_1))
|
|
,e.field_4
|
|
,e.field_5
|
|
,e.field_6
|
|
,e.field_7
|
|
,e.field_8
|
|
,e.field_9
|
|
,e.field_10
|
|
,e.field_11
|
|
,e.field_12
|
|
,e.field_13) log errors reject LIMIT unlimited;
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': bases');
|
|
END load_bases;
|
|
|
|
PROCEDURE load_housings IS
|
|
BEGIN
|
|
|
|
pl('load_housings');
|
|
|
|
IF NOT file_available('HOUSINGS.csv') THEN
|
|
pl('HOUSINGS.csv file missing');
|
|
RETURN;
|
|
END IF;
|
|
|
|
-- Manufacturers
|
|
INSERT INTO parties
|
|
(id
|
|
,manu_ref
|
|
,NAME
|
|
,description
|
|
,prty_type
|
|
,created_on
|
|
,created_by)
|
|
(SELECT prty_seq.NEXTVAL
|
|
,manu_ref
|
|
,manu_ref
|
|
,initcap(manu_ref)
|
|
,'MANU'
|
|
,SYSDATE
|
|
,USER
|
|
FROM (SELECT DISTINCT upper(TRIM(field_2)) AS manu_ref
|
|
FROM ext_housings
|
|
WHERE TRIM(field_2) IS NOT NULL)
|
|
WHERE manu_ref NOT IN (SELECT manu_ref
|
|
FROM parties
|
|
WHERE prty_type = 'MANU'));
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': manufacturers');
|
|
|
|
-- Drawings
|
|
INSERT INTO drawings
|
|
(code
|
|
,description)
|
|
(SELECT code
|
|
,code
|
|
FROM (SELECT DISTINCT upper(TRIM(field_3)) AS code
|
|
FROM ext_housings
|
|
WHERE TRIM(field_3) IS NOT NULL)
|
|
WHERE code NOT IN (SELECT code
|
|
FROM drawings));
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': drawings');
|
|
|
|
-- Housing Types
|
|
INSERT INTO housing_types
|
|
(code
|
|
,description)
|
|
(SELECT code
|
|
,initcap(code)
|
|
FROM (SELECT DISTINCT upper(TRIM(field_4)) AS code
|
|
FROM ext_housings
|
|
WHERE TRIM(field_4) IS NOT NULL)
|
|
WHERE code NOT IN (SELECT code
|
|
FROM housing_types));
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': housing_types');
|
|
|
|
MERGE INTO housings hou
|
|
USING (SELECT upper(TRIM(field_1)) AS field_1
|
|
,p.id AS field_2
|
|
,upper(TRIM(field_3)) AS field_3
|
|
,upper(TRIM(field_4)) AS field_4
|
|
,field_5
|
|
,field_6
|
|
,field_7
|
|
,field_8
|
|
,field_9
|
|
FROM ext_housings
|
|
,parties p
|
|
WHERE p.manu_ref = upper(TRIM(field_2))
|
|
AND p.prty_type = 'MANU') e
|
|
ON (e.field_1 = hou.code)
|
|
WHEN MATCHED THEN
|
|
UPDATE
|
|
SET prty_id = e.field_2
|
|
,drwg_code = e.field_3
|
|
,hoty_code = e.field_4
|
|
,description = nvl(e.field_5
|
|
,initcap(e.field_1))
|
|
,dim_w = e.field_6
|
|
,dim_h = e.field_7
|
|
,dim_l = e.field_8
|
|
,weight = e.field_9
|
|
WHEN NOT MATCHED THEN
|
|
INSERT
|
|
(code
|
|
,prty_id
|
|
,drwg_code
|
|
,hoty_code
|
|
,description
|
|
,dim_w
|
|
,dim_h
|
|
,dim_l
|
|
,weight)
|
|
VALUES
|
|
(e.field_1
|
|
,e.field_2
|
|
,e.field_3
|
|
,e.field_4
|
|
,nvl(e.field_5
|
|
,initcap(e.field_1))
|
|
,e.field_6
|
|
,e.field_7
|
|
,e.field_8
|
|
,e.field_9) log errors reject LIMIT unlimited;
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': housings');
|
|
|
|
END load_housings;
|
|
|
|
PROCEDURE load_costs IS
|
|
l_cost_enty_code VARCHAR2(20);
|
|
BEGIN
|
|
pl('load_costs');
|
|
|
|
IF NOT file_available('LABOUR_COSTS.csv') THEN
|
|
pl('LABOUR_COSTS.csv file missing');
|
|
RETURN;
|
|
END IF;
|
|
|
|
IF NOT file_available('MATERIAL_COSTS.csv') THEN
|
|
pl('MATERIAL_COSTS.csv file missing');
|
|
RETURN;
|
|
END IF;
|
|
|
|
--
|
|
-- Additional Items
|
|
--
|
|
MERGE INTO costs cos
|
|
USING (SELECT upper(TRIM(adit_code)) AS adit_code
|
|
,selling_price
|
|
,cost_price
|
|
,delivery_cost
|
|
,CASE
|
|
WHEN valid_from IS NULL THEN
|
|
trunc(SYSDATE)
|
|
ELSE
|
|
to_date(valid_from
|
|
,'dd/mm/yyyy')
|
|
END AS valid_from
|
|
,CASE
|
|
WHEN valid_to IS NULL THEN
|
|
NULL
|
|
ELSE
|
|
to_date(valid_to
|
|
,'dd/mm/yyyy')
|
|
END AS valid_to
|
|
FROM ext_material_costs
|
|
WHERE upper(TRIM(cost_type)) = 'AICO') e
|
|
ON (e.adit_code = cos.adit_code AND e.valid_from = cos.valid_from AND cos.cost_type = 'AICO')
|
|
WHEN MATCHED THEN
|
|
UPDATE
|
|
SET selling_price = e.selling_price
|
|
,cost_price = e.cost_price
|
|
,delivery_cost = e.delivery_cost
|
|
,valid_to = e.valid_to
|
|
WHEN NOT MATCHED THEN
|
|
INSERT
|
|
(id
|
|
,selling_price
|
|
,cost_price
|
|
,delivery_cost
|
|
,valid_from
|
|
,valid_to
|
|
,cost_type
|
|
,adit_code)
|
|
VALUES
|
|
(cost_seq.NEXTVAL
|
|
,e.selling_price
|
|
,e.cost_price
|
|
,e.delivery_cost
|
|
,e.valid_from
|
|
,e.valid_to
|
|
,'AICO'
|
|
,e.adit_code) log errors reject LIMIT unlimited;
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': additional_items');
|
|
--
|
|
-- Base costs
|
|
--
|
|
MERGE INTO costs cos
|
|
USING (SELECT upper(TRIM(bas_code)) AS bas_code
|
|
,selling_price
|
|
,cost_price
|
|
,delivery_cost
|
|
,CASE
|
|
WHEN valid_from IS NULL THEN
|
|
trunc(SYSDATE)
|
|
ELSE
|
|
to_date(valid_from
|
|
,'dd/mm/yyyy')
|
|
END AS valid_from
|
|
,CASE
|
|
WHEN valid_to IS NULL THEN
|
|
NULL
|
|
ELSE
|
|
to_date(valid_to
|
|
,'dd/mm/yyyy')
|
|
END AS valid_to
|
|
FROM ext_material_costs
|
|
WHERE upper(TRIM(cost_type)) = 'BACO') e
|
|
ON (e.bas_code = cos.bas_code AND e.valid_from = cos.valid_from AND cos.cost_type = 'BACO')
|
|
WHEN MATCHED THEN
|
|
UPDATE
|
|
SET selling_price = e.selling_price
|
|
,cost_price = e.cost_price
|
|
,delivery_cost = e.delivery_cost
|
|
,valid_to = e.valid_to
|
|
WHEN NOT MATCHED THEN
|
|
INSERT
|
|
(id
|
|
,selling_price
|
|
,cost_price
|
|
,delivery_cost
|
|
,valid_from
|
|
,valid_to
|
|
,cost_type
|
|
,bas_code)
|
|
VALUES
|
|
(cost_seq.NEXTVAL
|
|
,e.selling_price
|
|
,e.cost_price
|
|
,e.delivery_cost
|
|
,e.valid_from
|
|
,e.valid_to
|
|
,'BACO'
|
|
,e.bas_code) log errors reject LIMIT unlimited;
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': bases');
|
|
--
|
|
-- Housing costs
|
|
--
|
|
MERGE INTO costs cos
|
|
USING (SELECT upper(TRIM(hou_code)) AS hou_code
|
|
,selling_price
|
|
,cost_price
|
|
,delivery_cost
|
|
,CASE
|
|
WHEN valid_from IS NULL THEN
|
|
trunc(SYSDATE)
|
|
ELSE
|
|
to_date(valid_from
|
|
,'dd/mm/yyyy')
|
|
END AS valid_from
|
|
,CASE
|
|
WHEN valid_to IS NULL THEN
|
|
NULL
|
|
ELSE
|
|
to_date(valid_to
|
|
,'dd/mm/yyyy')
|
|
END AS valid_to
|
|
FROM ext_material_costs
|
|
WHERE upper(TRIM(cost_type)) = 'HOCO') e
|
|
ON (e.hou_code = cos.hou_code AND e.valid_from = cos.valid_from AND cos.cost_type = 'HOCO')
|
|
WHEN MATCHED THEN
|
|
UPDATE
|
|
SET selling_price = e.selling_price
|
|
,cost_price = e.cost_price
|
|
,delivery_cost = e.delivery_cost
|
|
,valid_to = e.valid_to
|
|
WHEN NOT MATCHED THEN
|
|
INSERT
|
|
(id
|
|
,selling_price
|
|
,cost_price
|
|
,delivery_cost
|
|
,valid_from
|
|
,valid_to
|
|
,cost_type
|
|
,hou_code)
|
|
VALUES
|
|
(cost_seq.NEXTVAL
|
|
,e.selling_price
|
|
,e.cost_price
|
|
,e.delivery_cost
|
|
,e.valid_from
|
|
,e.valid_to
|
|
,'HOCO'
|
|
,e.hou_code) log errors reject LIMIT unlimited;
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': housings');
|
|
--
|
|
-- Module costs
|
|
--
|
|
MERGE INTO costs cos
|
|
USING (SELECT upper(TRIM(modu_code)) AS modu_code
|
|
,selling_price
|
|
,cost_price
|
|
,delivery_cost
|
|
,CASE
|
|
WHEN valid_from IS NULL THEN
|
|
trunc(SYSDATE)
|
|
ELSE
|
|
to_date(valid_from
|
|
,'dd/mm/yyyy')
|
|
END AS valid_from
|
|
,CASE
|
|
WHEN valid_to IS NULL THEN
|
|
NULL
|
|
ELSE
|
|
to_date(valid_to
|
|
,'dd/mm/yyyy')
|
|
END AS valid_to
|
|
FROM ext_material_costs
|
|
WHERE upper(TRIM(cost_type)) = 'MOCO') e
|
|
ON (e.modu_code = cos.modu_code AND e.valid_from = cos.valid_from AND cos.cost_type = 'MOCO')
|
|
WHEN MATCHED THEN
|
|
UPDATE
|
|
SET selling_price = e.selling_price
|
|
,cost_price = e.cost_price
|
|
,delivery_cost = e.delivery_cost
|
|
,valid_to = e.valid_to
|
|
WHEN NOT MATCHED THEN
|
|
INSERT
|
|
(id
|
|
,selling_price
|
|
,cost_price
|
|
,delivery_cost
|
|
,valid_from
|
|
,valid_to
|
|
,cost_type
|
|
,modu_code)
|
|
VALUES
|
|
(cost_seq.NEXTVAL
|
|
,e.selling_price
|
|
,e.cost_price
|
|
,e.delivery_cost
|
|
,e.valid_from
|
|
,e.valid_to
|
|
,'MOCO'
|
|
,e.modu_code) log errors reject LIMIT unlimited;
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': modules');
|
|
--
|
|
-- Labour costs
|
|
--
|
|
FOR l_enty IN (SELECT code
|
|
FROM enquiry_types) LOOP
|
|
l_cost_enty_code := CASE l_enty.code WHEN 'ADDON' THEN 'ADDON' WHEN 'ADVERSARIAL' THEN 'REMOVE' WHEN 'CHANGE CAPACITY' THEN 'CHANGE CAPACITY' WHEN 'EXCHANGE' THEN 'EXCHANGE' WHEN 'INSTALL' THEN 'INSTALL'
|
|
|
|
WHEN 'OFMAT' THEN 'OFMAT' WHEN 'OTHER' THEN 'OTHER' WHEN 'REMOVE' THEN 'REMOVE' WHEN 'STD EXCHANGE' THEN 'EXCHANGE' WHEN 'STD INSTALL' THEN 'INSTALL' WHEN 'STD REMOVE' THEN 'REMOVE' ELSE NULL END;
|
|
FOR l_network IN 1 .. 8 LOOP
|
|
MERGE INTO costs cos
|
|
USING (SELECT *
|
|
FROM (SELECT CASE l_network
|
|
WHEN 1 THEN
|
|
netw01_selling_price
|
|
WHEN 2 THEN
|
|
netw02_selling_price
|
|
WHEN 3 THEN
|
|
netw03_selling_price
|
|
WHEN 4 THEN
|
|
netw04_selling_price
|
|
WHEN 5 THEN
|
|
netw05_selling_price
|
|
WHEN 6 THEN
|
|
netw06_selling_price
|
|
WHEN 7 THEN
|
|
netw07_selling_price
|
|
WHEN 8 THEN
|
|
netw08_selling_price
|
|
END AS selling_price
|
|
,'NETW0' || l_network AS regi_code
|
|
,CASE
|
|
WHEN valid_from IS NULL THEN
|
|
trunc(SYSDATE)
|
|
ELSE
|
|
to_date(valid_from
|
|
,'dd/mm/yyyy')
|
|
END AS valid_from
|
|
,CASE
|
|
WHEN valid_to IS NULL THEN
|
|
NULL
|
|
ELSE
|
|
to_date(valid_to
|
|
,'dd/mm/yyyy')
|
|
END AS valid_to
|
|
,upper(TRIM(enty_code)) AS enty_code
|
|
,upper(REPLACE(TRIM(mesc_code)
|
|
,'"'
|
|
,'inch')) AS mesc_code
|
|
,upper(TRIM(svcpt_code)) AS svcpt_code
|
|
,upper(TRIM(mety_code)) AS mety_code
|
|
FROM ext_labour_costs
|
|
WHERE upper(TRIM(enty_code)) = l_cost_enty_code)
|
|
WHERE selling_price IS NOT NULL) e
|
|
ON (e.enty_code = cos.enty_code AND e.valid_from = cos.valid_from AND e.mety_code = cos.mety_code AND cos.cost_type = 'LACO' AND ((e.regi_code = cos.regi_code) OR (e.regi_code IS NULL AND cos.regi_code IS NULL)) AND ((e. mesc_code IS NULL AND cos.mesc_code IS NULL) OR (e.mesc_code = cos.mesc_code)) AND ((e.svcpt_code IS NULL AND cos.svcpt_code IS NULL) OR (e.svcpt_code = cos.svcpt_code)))
|
|
WHEN MATCHED THEN
|
|
UPDATE
|
|
SET selling_price = e.selling_price
|
|
,valid_to = e.valid_to
|
|
WHEN NOT MATCHED THEN
|
|
INSERT
|
|
(id
|
|
,regi_code
|
|
,selling_price
|
|
,valid_from
|
|
,valid_to
|
|
,cost_type
|
|
,enty_code
|
|
,mesc_code
|
|
,svcpt_code
|
|
,mety_code)
|
|
VALUES
|
|
(cost_seq.NEXTVAL
|
|
,e.regi_code
|
|
,e.selling_price
|
|
,e.valid_from
|
|
,e.valid_to
|
|
,'LACO'
|
|
,l_enty.code
|
|
,e.mesc_code
|
|
,e.svcpt_code
|
|
,e.mety_code) log errors reject LIMIT unlimited;
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': ' || l_enty.code || ':NETW0' ||
|
|
l_network || ': labour');
|
|
|
|
END LOOP;
|
|
END LOOP;
|
|
|
|
END load_costs;
|
|
|
|
PROCEDURE load_caveats IS
|
|
BEGIN
|
|
pl('load_caveats');
|
|
|
|
IF NOT file_available('CAVEATS.csv') THEN
|
|
pl('CAVEATS.csv file missing');
|
|
RETURN;
|
|
END IF;
|
|
--
|
|
-- Caveats
|
|
--
|
|
MERGE INTO caveat_texts
|
|
USING (SELECT upper(TRIM(field_1)) AS field_1
|
|
,upper(TRIM(field_2)) AS field_2
|
|
,upper(TRIM(field_3)) AS field_3
|
|
,upper(TRIM(field_4)) AS field_4
|
|
,upper(TRIM(field_5)) AS field_5
|
|
,TRIM(field_6) AS field_6
|
|
FROM ext_caveats) e
|
|
ON (field_1 = document_position AND field_2 = enty_code AND field_3 = mety_code AND field_4 = svcpt_code AND ((field_5 = sort_order) OR (field_5 IS NULL AND sort_order IS NULL)))
|
|
WHEN MATCHED THEN
|
|
UPDATE
|
|
SET text = field_6
|
|
WHEN NOT MATCHED THEN
|
|
INSERT
|
|
(id
|
|
,document_position
|
|
,enty_code
|
|
,mety_code
|
|
,svcpt_code
|
|
,sort_order
|
|
,text)
|
|
VALUES
|
|
(cate_seq.NEXTVAL
|
|
,field_1
|
|
,field_2
|
|
,field_3
|
|
,field_4
|
|
,field_5
|
|
,field_6) log errors reject LIMIT unlimited;
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': caveat_texts');
|
|
END load_caveats;
|
|
|
|
PROCEDURE load_postcodes IS
|
|
BEGIN
|
|
pl('load_postcodes');
|
|
|
|
IF NOT file_available('POSTCODES.csv') THEN
|
|
pl('POSTCODES.csv file missing');
|
|
RETURN;
|
|
END IF;
|
|
|
|
--
|
|
-- Regions
|
|
--
|
|
INSERT INTO regions
|
|
(code
|
|
,description)
|
|
(SELECT code
|
|
,initcap(code)
|
|
FROM (SELECT DISTINCT upper(TRIM(field_2)) AS code
|
|
FROM ext_postcodes)
|
|
WHERE code NOT IN (SELECT code
|
|
FROM regions));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': regions');
|
|
|
|
DELETE FROM postcodes pd
|
|
WHERE (outcode, nvl(incode
|
|
,'#NULL#')) IN
|
|
(SELECT outcode
|
|
,nvl(incode
|
|
,'#NULL#')
|
|
FROM (SELECT outcode
|
|
,incode
|
|
FROM postcodes p
|
|
MINUS
|
|
SELECT CASE instr(TRIM(field_1)
|
|
,' ')
|
|
WHEN 0 THEN
|
|
upper(TRIM(field_1))
|
|
ELSE
|
|
upper(substr(field_1
|
|
,1
|
|
,instr(field_1
|
|
,' ') - 1))
|
|
END AS outcode
|
|
,CASE instr(TRIM(field_1)
|
|
,' ')
|
|
WHEN 0 THEN
|
|
NULL
|
|
ELSE
|
|
substr(TRIM(field_1)
|
|
,instr(TRIM(field_1)
|
|
,' ') + 1)
|
|
END AS incode
|
|
FROM ext_postcodes));
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': postcodes - delete');
|
|
|
|
--
|
|
-- Postcodes
|
|
--
|
|
MERGE INTO postcodes p
|
|
USING (SELECT CASE instr(TRIM(field_1)
|
|
,' ')
|
|
WHEN 0 THEN
|
|
upper(TRIM(field_1))
|
|
ELSE
|
|
upper(substr(TRIM(field_1)
|
|
,1
|
|
,instr(TRIM(field_1)
|
|
,' ') - 1))
|
|
END AS outcode
|
|
,CASE instr(TRIM(field_1)
|
|
,' ')
|
|
WHEN 0 THEN
|
|
NULL
|
|
ELSE
|
|
substr(TRIM(field_1)
|
|
,instr(TRIM(field_1)
|
|
,' ') + 1)
|
|
END AS incode
|
|
,upper(TRIM(field_2)) AS regi_code
|
|
FROM ext_postcodes) e
|
|
ON (e.outcode = p.outcode AND ((e.incode = p.incode) OR (e.incode IS NULL AND p.incode IS NULL)))
|
|
WHEN MATCHED THEN
|
|
UPDATE
|
|
SET regi_code = regi_code
|
|
WHEN NOT MATCHED THEN
|
|
INSERT
|
|
(id
|
|
,outcode
|
|
,incode
|
|
,regi_code)
|
|
VALUES
|
|
(poco_seq.NEXTVAL
|
|
,e.outcode
|
|
,e.incode
|
|
,e.regi_code) log errors reject LIMIT unlimited;
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': postcodes - merge');
|
|
|
|
END load_postcodes;
|
|
|
|
PROCEDURE load_leadtimes IS
|
|
l_enty_code enquiry_types.code%TYPE;
|
|
BEGIN
|
|
|
|
--
|
|
-- leadtimes
|
|
--
|
|
IF NOT file_available('LEADTIMES.csv') THEN
|
|
pl('LEADTIMES.csv file missing');
|
|
RETURN;
|
|
END IF;
|
|
|
|
DELETE FROM lead_times;
|
|
MERGE INTO lead_times leti
|
|
USING (SELECT enty.code AS enty_code
|
|
,upper(TRIM(mety_code)) AS mety_code
|
|
,upper(TRIM(mesc_code)) AS mesc_code
|
|
,upper(TRIM(svcpt_code)) AS svcpt_code
|
|
,upper(TRIM(lead_time)) AS days
|
|
FROM ext_leadtimes el
|
|
,(SELECT CASE code
|
|
WHEN 'ADDON' THEN
|
|
'ADDON'
|
|
WHEN 'ADVERSARIAL' THEN
|
|
'REMOVE'
|
|
WHEN 'CHANGE CAPACITY' THEN
|
|
'CHANGE CAPACITY'
|
|
WHEN 'EXCHANGE' THEN
|
|
'EXCHANGE'
|
|
WHEN 'INSTALL' THEN
|
|
'INSTALL'
|
|
WHEN 'OFMAT' THEN
|
|
'OFMAT'
|
|
WHEN 'OTHER' THEN
|
|
'OTHER'
|
|
WHEN 'REMOVE' THEN
|
|
'REMOVE'
|
|
WHEN 'STD EXCHANGE' THEN
|
|
'EXCHANGE'
|
|
WHEN 'STD INSTALL' THEN
|
|
'INSTALL'
|
|
WHEN 'STD REMOVE' THEN
|
|
'REMOVE'
|
|
ELSE
|
|
NULL
|
|
END AS l_enty_code
|
|
,code
|
|
FROM enquiry_types) enty
|
|
WHERE upper(TRIM(enty_code)) = l_enty_code) e
|
|
ON (e.enty_code = leti.enty_code AND e.mety_code = leti.mety_code AND ((e.mesc_code = leti.mesc_code) OR (e.mesc_code IS NULL AND leti.mesc_code IS NULL)) AND ((e.svcpt_code = leti.svcpt_code) OR (e.svcpt_code IS NULL AND leti.svcpt_code IS NULL)))
|
|
WHEN MATCHED THEN
|
|
UPDATE
|
|
SET days = e.days
|
|
WHEN NOT MATCHED THEN
|
|
INSERT
|
|
(id
|
|
,enty_code
|
|
,mety_code
|
|
,mesc_code
|
|
,svcpt_code
|
|
,days)
|
|
VALUES
|
|
(leti_seq.NEXTVAL
|
|
,e.enty_code
|
|
,e.mety_code
|
|
,e.mesc_code
|
|
,e.svcpt_code
|
|
,e.days) log errors reject LIMIT unlimited;
|
|
|
|
pl(to_char(SQL%ROWCOUNT
|
|
,'FM099G999') || ': leadtimes - merge');
|
|
|
|
END load_leadtimes;
|
|
|
|
PROCEDURE init IS
|
|
l_sgid NUMBER;
|
|
BEGIN
|
|
|
|
get_globals;
|
|
|
|
pl('Application id:' || g_flow_id);
|
|
|
|
SELECT wwv_flow.get_current_flow_sgid(g_flow_id)
|
|
INTO l_sgid
|
|
FROM dual;
|
|
|
|
pl('Security group id:' || l_sgid);
|
|
|
|
wwv_flow_api.set_security_group_id(l_sgid);
|
|
apex_application.g_flow_id := g_flow_id;
|
|
|
|
DELETE FROM err$_bases;
|
|
DELETE FROM err$_caveat_texts;
|
|
DELETE FROM err$_costs;
|
|
DELETE FROM err$_housings;
|
|
DELETE FROM err$_meters;
|
|
DELETE FROM err$_modules;
|
|
DELETE FROM err$_parties;
|
|
DELETE FROM err$_postcodes;
|
|
|
|
END init;
|
|
|
|
PROCEDURE report_err IS
|
|
BEGIN
|
|
|
|
pl('report_err');
|
|
|
|
|
|
FOR l_rec IN (SELECT *
|
|
FROM err$_meters) LOOP
|
|
pl('meters:' || l_rec.ora_err_mesg$ || ':' || l_rec.ora_err_rowid$ || ':' ||
|
|
l_rec.ora_err_optyp$);
|
|
END LOOP;
|
|
|
|
FOR l_rec IN (SELECT *
|
|
FROM err$_bases) LOOP
|
|
pl('bases:' || l_rec.ora_err_mesg$ || ':' || l_rec.ora_err_rowid$ || ':' ||
|
|
l_rec.ora_err_optyp$);
|
|
END LOOP;
|
|
|
|
FOR l_rec IN (SELECT *
|
|
FROM err$_housings) LOOP
|
|
pl('housings:' || l_rec.ora_err_mesg$ || ':' || l_rec.ora_err_rowid$ || ':' ||
|
|
l_rec.ora_err_optyp$);
|
|
END LOOP;
|
|
|
|
FOR l_rec IN (SELECT *
|
|
FROM err$_modules) LOOP
|
|
pl('modules:' || l_rec.ora_err_mesg$ || ':' || l_rec.ora_err_rowid$ || ':' ||
|
|
l_rec.ora_err_optyp$);
|
|
END LOOP;
|
|
|
|
FOR l_rec IN (SELECT *
|
|
FROM err$_postcodes) LOOP
|
|
pl('postcodes:' || l_rec.ora_err_mesg$ || ':' ||
|
|
l_rec.ora_err_rowid$ || ':' || l_rec.ora_err_optyp$);
|
|
END LOOP;
|
|
|
|
FOR l_rec IN (SELECT *
|
|
FROM err$_costs) LOOP
|
|
pl('costs:' || l_rec.ora_err_mesg$ || ':' || l_rec.ora_err_rowid$ || ':' ||
|
|
l_rec.ora_err_optyp$);
|
|
END LOOP;
|
|
|
|
FOR l_rec IN (SELECT *
|
|
FROM err$_caveat_texts) LOOP
|
|
pl('caveats:' || l_rec.ora_err_mesg$ || ':' || l_rec.ora_err_rowid$ || ':' ||
|
|
l_rec.ora_err_optyp$);
|
|
END LOOP;
|
|
|
|
FOR l_rec IN (SELECT *
|
|
FROM err$_lead_times) LOOP
|
|
pl('lead_times:' || l_rec.ora_err_mesg$ || ':' || l_rec.ora_err_rowid$ || ':' ||
|
|
l_rec.ora_err_optyp$);
|
|
END LOOP;
|
|
|
|
pl('report_err - complete');
|
|
END report_err;
|
|
|
|
PROCEDURE load_all IS
|
|
BEGIN
|
|
|
|
init;
|
|
|
|
load_meters;
|
|
load_bases;
|
|
load_housings;
|
|
load_drawings;
|
|
load_modules;
|
|
load_postcodes;
|
|
load_costs;
|
|
load_caveats;
|
|
load_leadtimes;
|
|
|
|
report_err;
|
|
|
|
END load_all;
|
|
|
|
END mip_bulk_load;
|
|
/
|