CREATE OR REPLACE FUNCTION f_check_close_catalog (character varying,bigint,character varying,bigint)
  RETURNS void AS
$BODY$
DECLARE

    pDateTime       alias $1;
    pTenantId       alias $2;
    pUserId         alias $3;
    pSessionId      alias $4;

    vCatalogId      bigint;
    vNull           bigint;
    vDbName         text;
    vDbUser         text;
    vDbPassword     text;
    vDbPort         text;
    vDbHostAddr     text;

    vCursorCatalog  tt_summary_cn_ar%ROWTYPE;

BEGIN

    vCatalogId := -99;

    SELECT f_get_value_system_config_by_param_code(pTenantId, 'PALOMAWEB.DB.NAME')::text INTO vDbName;
    SELECT f_get_value_system_config_by_param_code(pTenantId, 'PALOMAWEB.DB.USER')::text INTO vDbUser;
    SELECT f_get_value_system_config_by_param_code(pTenantId, 'PALOMAWEB.DB.PASSWORD')::text INTO vDbPassword;
    SELECT f_get_value_system_config_by_param_code(pTenantId, 'PALOMAWEB.DB.PORT')::text INTO vDbPort;
    SELECT f_get_value_system_config_by_param_code(pTenantId, 'PALOMAWEB.DB.HOSTADDR')::text INTO vDbHostAddr;


    SELECT catalog_id INTO vCatalogId
    FROM m_catalog
    WHERE end_date = pDateTime;

    FOR vCursorCatalog IN SELECT *
                                FROM m_catalog
                                WHERE end_date = pDateTime;
    LOOP

        vCatalogId := vCursorCatalog.catalog_id

        -- Update di task hub
        PERFORM f_tutup_katalog(pTenantId,pSessionId,vCatalogId,pUserId,pDateTime);

        -- Update di web ds
        SELECT 1
        FROM dblink(
        'dbname='||vDbName||' port='||vDbPort||' hostaddr='||vDbHostAddr||' user='||vDbUser||' password='||vDbPassword||''::text,
        'SELECT f_intgr_t18('''||vCatalogId||''','||pUserId||','''||pDatetime''')');

    END LOOP;

END;
$BODY$
  LANGUAGE plpgsql VOLATILE
  COST 100;
/