/* Processed by ecpg (15.18 (Debian 15.18-0+deb12u1)) */
/* These include files are added by the preprocessor */
#include <ecpglib.h>
#include <ecpgerrno.h>
#include <sqlca.h>
/* End of automatic include section */

#line 1 "app/online/mg_ol_0014.pgc"
/* @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"


#line 1 "/usr/include/postgresql/sqlca.h"
#ifndef POSTGRES_SQLCA_H
#define POSTGRES_SQLCA_H

#ifndef PGDLLIMPORT
#if  defined(WIN32) || defined(__CYGWIN__)
#define PGDLLIMPORT __declspec (dllimport)
#else
#define PGDLLIMPORT
#endif							/* __CYGWIN__ */
#endif							/* PGDLLIMPORT */

#define SQLERRMC_LEN	150

#ifdef __cplusplus
extern "C"
{
#endif

struct sqlca_t
{
	char		sqlcaid[8];
	long		sqlabc;
	long		sqlcode;
	struct
	{
		int			sqlerrml;
		char		sqlerrmc[SQLERRMC_LEN];
	}			sqlerrm;
	char		sqlerrp[8];
	long		sqlerrd[6];
	/* Element 0: empty						*/
	/* 1: OID of processed tuple if applicable			*/
	/* 2: number of rows processed				*/
	/* after an INSERT, UPDATE or				*/
	/* DELETE statement					*/
	/* 3: empty						*/
	/* 4: empty						*/
	/* 5: empty						*/
	char		sqlwarn[8];
	/* Element 0: set to 'W' if at least one other is 'W'	*/
	/* 1: if 'W' at least one character string		*/
	/* value was truncated when it was			*/
	/* stored into a host variable.             */

	/*
	 * 2: if 'W' a (hopefully) non-fatal notice occurred
	 */	/* 3: empty */
	/* 4: empty						*/
	/* 5: empty						*/
	/* 6: empty						*/
	/* 7: empty						*/

	char		sqlstate[5];
};

struct sqlca_t *ECPGget_sqlca(void);

#ifndef POSTGRES_ECPG_INTERNAL
#define sqlca (*ECPGget_sqlca())
#endif

#ifdef __cplusplus
}
#endif

#endif

#line 18 "app/online/mg_ol_0014.pgc"


TX_SERVICE(MG_OL_0014, ctx)
{
    /* exec sql begin declare section */
     
     
     
     
      
      
    
#line 23 "app/online/mg_ol_0014.pgc"
 char h_qkey [ 16 ] ;
 
#line 24 "app/online/mg_ol_0014.pgc"
 char h_mtype [ 5 ] ;
 
#line 25 "app/online/mg_ol_0014.pgc"
 char h_bizdate [ 9 ] ;
 
#line 26 "app/online/mg_ol_0014.pgc"
 long h_amount ;
 
#line 27 "app/online/mg_ol_0014.pgc"
 int h_prio ;
 
#line 28 "app/online/mg_ol_0014.pgc"
 int h_pos ;
/* exec sql end declare section */
#line 29 "app/online/mg_ol_0014.pgc"


    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: 대기) */
    { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "insert into mg_queue ( qkey , msg_type , biz_date , amount , priority , status , enq_ts ) values ( $1  , $2  , $3  , $4  , $5  , 'W' , now ( ) )", 
	ECPGt_char,(h_qkey),(long)16,(long)1,(16)*sizeof(char), 
	ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, 
	ECPGt_char,(h_mtype),(long)5,(long)1,(5)*sizeof(char), 
	ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, 
	ECPGt_char,(h_bizdate),(long)9,(long)1,(9)*sizeof(char), 
	ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, 
	ECPGt_long,&(h_amount),(long)1,(long)1,sizeof(long), 
	ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, 
	ECPGt_int,&(h_prio),(long)1,(long)1,sizeof(int), 
	ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, ECPGt_EORT);}
#line 86 "app/online/mg_ol_0014.pgc"

    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;
    }

    /* 큐 내 위치 = 동일/선순위 대기건수 */
    { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "select count ( * ) from mg_queue where status = 'W' and priority <= $1 ", 
	ECPGt_int,&(h_prio),(long)1,(long)1,sizeof(int), 
	ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, 
	ECPGt_int,&(h_pos),(long)1,(long)1,sizeof(int), 
	ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EORT);}
#line 100 "app/online/mg_ol_0014.pgc"

    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);
}
