CANCEL SUBMIT FOLLOW UP CASH ADVANCE SETTLEMENT

-- Adrian, Mar 20, 2017

CREATE OR REPLACE FUNCTION cb_cancel_submit_follow_up_advance_settlement(bigint, character varying, bigint, character varying, bigint, character varying, character varying)
  RETURNS void AS
$BODY$
DECLARE
    pTenantId                           ALIAS FOR $1;
    pSessionId                          ALIAS FOR $2;
    pUserId                             ALIAS FOR $3;
    pDatetime                           ALIAS FOR $4;
    pFollowSettleId                                 ALIAS FOR $5;
    pRemarkApproval                     ALIAS FOR $6;
    pPrevProcessNo                      ALIAS FOR $7;

    vFollowSettleDocTypeId              bigint;
    vEmptyId                            bigint;
    vFunctionSubmit                     character varying;
    vStatusDocReleased                  character varying;
    vStatusDocDraft                     character varying;
    vStatusDocInProgress                character varying;
    vWorkflowStatusDraft                character varying;
    vYes                                character varying;
    vNo                                 character varying;
    vZero                               bigint;

    vOuId                               bigint;
    vJournalTrxId                       bigint;
    vDocNo                              character varying;
    vDocDate                            character varying;
    vScheme                             character varying;

    vDocJournal                         DOC_JOURNAL%ROWTYPE;
    vOuStructure                        OU_BU_STRUCTURE%ROWTYPE;
    result                              RECORD;

    vLedgerCode                         character varying;
    vStatusLedgerNotDone                character varying;

    vOuStructureJournalItem             OU_BU_STRUCTURE%ROWTYPE;

    vRefAmount                          numeric;
    vSignDebit                          character varying(1);
    vSignCredit                         character varying(1);
    vTypeRate                           character varying(3);
    vActivityCOA                        character varying(10);
    vRefId                              bigint;

BEGIN

    vFollowSettleDocTypeId := 641;
    vEmptyId := -99;
    vFunctionSubmit := 'cb_submit_follow_up_advance_settlement';
    vStatusDocReleased := 'R';
    vStatusDocDraft := 'D';
    vStatusDocInProgress := 'I';
    vWorkflowStatusDraft := 'DRAFT';
    vYes := 'Y';
    vNo := 'N';
    vZero := 0;

    vLedgerCode := 'CASH.BANK';
    vStatusLedgerNotDone := '0';

    vSignDebit := 'D';

    --RAISE EXCEPTION 'Function Submit For Document Follow up Advance Settlement is not yet Created';

    -- get data
    select f_get_ou_bu_structure(A.ou_id) AS ou, A.ou_id, A.doc_no, A.doc_date,
        f_get_document_journal(A.doc_type_id) as doc, C.scheme,
        A.ref_amount, A.ref_id
    FROM cb_in_out_cashbank A, m_document C
    WHERE A.in_out_cashbank_id = pFollowSettleId AND
        A.doc_type_id = C.doc_type_id AND
        A.doc_type_id = vFollowSettleDocTypeId AND
        A.status_doc = vStatusDocReleased
    INTO result;

    IF FOUND THEN
        vOuStructure := result.ou;
        vOuId := result.ou_id;
        vDocNo := result.doc_no;
        vDocDate := result.doc_date;
        vDocJournal := result.doc;
        vScheme := result.scheme;
        vRefAmount := result.ref_amount;
        vRefId := result.ref_id;

        -- Cek status ledger not yet closed
        IF EXISTS (
            SELECT 1
            FROM m_admin_process_ledger e, m_ou_structure f, t_ou g
            WHERE e.tenant_id = pTenantId
                AND e.ou_id = f.ou_bu_id
                AND f.ou_id = vOuId
                AND e.date_year_month = SUBSTR(vDocDate, 1, 6)
                AND e.ledger_code = vLedgerCode AND
                f.ou_id = g.ou_id AND e.status_ledger = vStatusLedgerNotDone) THEN

            /*
             * validasi flg_payment harus Y
             */
            IF NOT EXISTS (
                SELECT (1)
                FROM cb_trx_cashbank_balance A
                WHERE A.trx_cashbank_balance_id = vRefId
                    AND A.flg_payment <> vYes
            ) THEN

                -- update flag cb_trx_cashbank_balance
                UPDATE cb_trx_cashbank_balance
                SET flg_payment = vStatusDocInProgress,
                    ref_doc_type_id = vEmptyId,
                    ref_id = vEmptyId,
                    version = version + 1,
                    update_datetime = pDatetime,
                    update_user_id = pUserId
                WHERE trx_cashbank_balance_id = vRefId;

                -- update cb_in_out_cashbank : status doc to D, workflow status to DRAFT
                UPDATE cb_in_out_cashbank
                SET status_doc = vStatusDocDraft,
                    workflow_status = vWorkflowStatusDraft,
                    version = version + 1,
                    update_datetime = pDatetime,
                    update_user_id = pUserId
                WHERE in_out_cashbank_id = pFollowSettleId;

                DELETE
                FROM cb_in_out_cashbank_cost Z
                WHERE EXISTS (
                    SELECT (1)
                    FROM cb_in_out_cashbank A
                    WHERE A.in_out_cashbank_id = pFollowSettleId
                        AND Z.tenant_id = A.tenant_id
                        AND Z.in_out_cashbank_id = A.in_out_cashbank_id
                        AND Z.line_no = 1
                        AND Z.activity_gl_id = f_get_activity_gl_id_for_rounding(A.tenant_id)
                );

                /*
                 * jika refAmount < 0, artinya follow up settlement diselesaikan dengan cash/bank In
                 */
                IF vRefAmount < 0 THEN

                    UPDATE cb_cashbank_balance D
                    SET amount = D.amount - B.cashbank_amount,
                        version = D.version + 1,
                        update_datetime = pDatetime,
                        update_user_id = pUserId
                    FROM cb_in_out_cashbank A, cb_in_out_cashbank_payment B, m_cashbank_ou C
                    WHERE A.in_out_cashbank_id = B.in_out_cashbank_id AND
                            D.cashbank_id = C.cashbank_id AND
                            A.in_out_cashbank_id = pFollowSettleId AND
                            D.cash_bank_date = A.doc_date AND
                            D.tenant_id = A.tenant_id AND
                            D.ou_id = C.ou_id AND
                            D.cashbank_id = B.cashbank_id AND
                            D.rec_type = vSignDebit;

                END IF;

                -- PERFORM cancel gl_cancel_admin_journal_trx
                PERFORM gl_cancel_admin_journal_trx(pTenantId, (vOuStructure).ou_bu_id, vOuId, (vDocJournal).journal_type, f_get_year_month_date(vDocDate), 'DAILY', pDatetime, pUserId);

                -- Find journal trx id
                SELECT journal_trx_id INTO vJournalTrxId
                FROM gl_journal_trx
                WHERE tenant_id = pTenantId
                    AND journal_type = (vDocJournal).journal_type
                    AND doc_type_id = vFollowSettleDocTypeId
                    AND doc_id = pFollowSettleId
                    AND doc_no = vDocNo
                    AND doc_date = vDocDate
                    AND ou_bu_id = (vOuStructure).ou_bu_id
                    AND ou_branch_id = (vOuStructure).ou_branch_id
                    AND ou_sub_bu_id = (vOuStructure).ou_sub_bu_id;

                -- DELETE gl_journal_trx
                DELETE FROM gl_journal_trx
                WHERE journal_trx_id = vJournalTrxId;

                -- DELETE gl_journal_trx_item
                DELETE FROM gl_journal_trx_item
                WHERE journal_trx_id = vJournalTrxId;

                -- DELETE gl_journal_trx_mapping
                DELETE FROM gl_journal_trx_mapping
                WHERE journal_trx_id = vJournalTrxId;

                -- PERFORM f_reset_approval_to_draft
                PERFORM f_reset_approval_to_draft(pTenantId, pSessionId, vScheme, pFollowSettleId, vDocNo, pDatetime, pRemarkApproval);

                -- UPDATE t_process_message
                UPDATE t_process_message
                SET process_no = pPrevProcessNo,
                    update_datetime = pDatetime,
                    update_user_id = pUserId,
                    version = version + 1
                WHERE tenant_id = pTenantId
                    AND process_name = vFunctionSubmit
                    AND process_no = pFollowSettleId || '_' || vDocNo;

            ELSE
                RAISE EXCEPTION 'Follow up  for document with id % is on approval progress', pFollowSettleId;
            END IF;

        ELSE
            RAISE EXCEPTION 'Admin Process Ledger for Cashbank in year month % is already closed', SUBSTR(vDocDate, 1, 6);
        END IF;

    ELSE
        RAISE EXCEPTION 'Document with id % is not found or document is on approval progress', pFollowSettleId;
    END IF;

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