/* @tier medium @module mg @transform msg-gateway-online */
/*
 * mg_ol_0014.pgc - 전문게이트웨이 전문 큐잉 서비스 (MG_OL_0014)  [tier=medium]
 *
 * 수신전문을 처리 우선순위에 따라 대기큐(mg_queue)에 적재한다.
 * 우선순위는 전문종별(정산 > 수신 > 응답)과 금액구간을 가중합산하여
 * 산출하며(값이 작을수록 선순위), raw EXEC SQL 로 INSERT 한 뒤 동일
 * 우선순위 이상 대기건수로 큐 내 위치(QPOS)를 계산해 응답한다.
 */
#include <stdio.h>
#include <string.h>

#include "txcore.h"
#include "txcore_dbio.h"
#include "acq_util.h"
#include "mg_core.h"

EXEC SQL INCLUDE sqlca;

TX_SERVICE(MG_OL_0014, ctx)
{
    EXEC SQL BEGIN DECLARE SECTION;
    char h_qkey[16];
    char h_mtype[5];
    char h_bizdate[9];
    long h_amount;
    int  h_prio;
    int  h_pos;
    EXEC SQL END DECLARE SECTION;

    char qkey[16], mtype[8], bizdate[16];
    long amount = 0;
    int  prio;

    tx_log(TX_LOG_INFO, "[MG_OL_0014] 전문 큐잉 서비스 진입");

    if (tx_buf_get(ctx->in, "KEY", qkey, sizeof(qkey)) != TX_OK ||
        tx_buf_get(ctx->in, "MSGTYPE", mtype, sizeof(mtype)) != TX_OK ||
        tx_buf_get(ctx->in, "BIZDATE", bizdate, sizeof(bizdate)) != TX_OK) {
        tx_log(TX_LOG_ERROR, "[MG_OL_0014] 필수 필드 누락(KEY/MSGTYPE/BIZDATE)");
        tx_return(ctx, TX_EINVAL, ctx->out);
        return;
    }
    tx_buf_getlong(ctx->in, "AMOUNT", &amount);

    if (!date_is_valid(bizdate) || !amount_is_valid(amount)) {
        tx_log(TX_LOG_WARN, "[MG_OL_0014] 입력 검증 실패 date=%s amt=%ld", bizdate, amount);
        tx_return(ctx, TX_EINVAL, ctx->out);
        return;
    }

    /* 우선순위 기본값: 전문종별 가중치 (작을수록 선순위) */
    if (strncmp(mtype, MSG_TYPE_RECON, 4) == 0)
        prio = 10;                 /* 정산전문 최우선 */
    else if (strncmp(mtype, MSG_TYPE_RECV, 4) == 0)
        prio = 30;                 /* 수신전문 */
    else if (strncmp(mtype, MSG_TYPE_RESP, 4) == 0)
        prio = 50;                 /* 응답전문 후순위 */
    else
        prio = 70;                 /* 기타 */

    /* 금액구간 가산: 고액일수록 선순위(가중치 차감) */
    if (amount >= 10000000)      prio -= 8;
    else if (amount >= 1000000)  prio -= 4;
    else if (amount >= 100000)   prio -= 2;
    if (prio < 1) prio = 1;

    strncpy(h_qkey, qkey, sizeof(h_qkey) - 1);
    h_qkey[sizeof(h_qkey) - 1] = '\0';
    strncpy(h_mtype, mtype, sizeof(h_mtype) - 1);
    h_mtype[sizeof(h_mtype) - 1] = '\0';
    strncpy(h_bizdate, bizdate, sizeof(h_bizdate) - 1);
    h_bizdate[sizeof(h_bizdate) - 1] = '\0';
    h_amount = amount;
    h_prio   = prio;

    if (tx_begin() != TX_OK) {
        tx_return(ctx, TX_FAIL, ctx->out);
        return;
    }

    /* 대기큐 적재 (상태 W: 대기) */
    EXEC SQL INSERT INTO mg_queue
        (qkey, msg_type, biz_date, amount, priority, status, enq_ts)
        VALUES
        (:h_qkey, :h_mtype, :h_bizdate, :h_amount, :h_prio, 'W', now());
    if (sqlca.sqlcode != TX_SQL_OK) {
        TX_DBIO_LOG_ERR("MG_OL_0014 mg_queue insert");
        tx_abort();
        tx_buf_reset(ctx->out);
        tx_buf_sets(ctx->out, "RESPCODE", RESP_SYSERR);
        tx_return(ctx, TX_EDB, ctx->out);
        return;
    }

    /* 큐 내 위치 = 동일/선순위 대기건수 */
    EXEC SQL SELECT count(*)
        INTO :h_pos
        FROM mg_queue
        WHERE status = 'W' AND priority <= :h_prio;
    if (sqlca.sqlcode != TX_SQL_OK) {
        TX_DBIO_LOG_ERR("MG_OL_0014 mg_queue position");
        tx_abort();
        tx_return(ctx, TX_EDB, ctx->out);
        return;
    }

    tx_commit();

    tx_buf_reset(ctx->out);
    tx_buf_sets(ctx->out, "RESPCODE", RESP_OK);
    tx_buf_sets(ctx->out, "KEY", qkey);
    tx_buf_setlong(ctx->out, "PRIORITY", (long)prio);
    tx_buf_setlong(ctx->out, "QPOS", (long)h_pos);
    tx_log(TX_LOG_INFO, "[MG_OL_0014] 큐잉 완료 key=%s prio=%d pos=%d", qkey, prio, h_pos);
    tx_return(ctx, TX_OK, ctx->out);
}