/* 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/rc_ol_0014.pgc"
/* @tier easy @module rc @transform reconciliation-online */
/*
 * rc_ol_0014.pgc - 미대사(접수 'R') 추출 조회 (CURSOR) 온라인 서비스 (RC_OL_0014)
 *
 * 지정 영업일(BIZDATE) 의 아직 대사되지 않은 접수건('R') 을 커서로
 * 순회하여 최대 LIMITN 건까지 응답에 실어 반환한다.
 *   - 각 건은 KEY0/AMT0, KEY1/AMT1 ... 형태로 번호를 붙여 push
 *   - 실제 push 한 건수(UNRECCNT) 와 금액합계(SUMAMT) 를 집계
 * 순수 조회 서비스이므로 상태전이/커밋 없이 읽기만 수행한다.
 *
 * 입력 TXBUF:
 *   BIZDATE (필수) 대상 영업일 YYYYMMDD
 *   LIMITN  (선택) 최대 추출 건수, 미지정/비정상 시 기본 10
 * 출력 TXBUF:
 *   UNRECCNT / SUMAMT / KEY0..KEYn / AMT0..AMTn
 *
 * 주의: 커서는 반드시 CLOSE 하며, FETCH 오류 시에도 그때까지 집계한
 *       결과를 정상 응답으로 돌려준다(부분 성공 허용).
 */
#include <stdio.h>
#include <string.h>

#include "txcore.h"
#include "txcore_dbio.h"
#include "acq_util.h"
#include "rc_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 28 "app/online/rc_ol_0014.pgc"


TX_SERVICE(RC_OL_0014, ctx)
{
    /* exec sql begin declare section */
     
     
     
    
#line 33 "app/online/rc_ol_0014.pgc"
 char h_biz_date [ 9 ] ;
 
#line 34 "app/online/rc_ol_0014.pgc"
 char h_key [ 16 ] ;
 
#line 35 "app/online/rc_ol_0014.pgc"
 long h_amount ;
/* exec sql end declare section */
#line 36 "app/online/rc_ol_0014.pgc"


    char bizdate[16];
    char fname[16];
    long limitn = 0;
    long pushed = 0;
    long sumamt = 0;
    int  opened = 0;

    tx_log(TX_LOG_INFO, "[RC_OL_0014] 미대사 추출 조회(커서) 서비스 진입");

    if (tx_buf_get(ctx->in, "BIZDATE", bizdate, sizeof(bizdate)) != TX_OK) {
        tx_log(TX_LOG_ERROR, "[RC_OL_0014] BIZDATE 누락");
        tx_return(ctx, TX_EINVAL, ctx->out);
        return;
    }
    if (!date_is_valid(bizdate)) {
        tx_log(TX_LOG_WARN, "[RC_OL_0014] 영업일 형식 오류 date=%s", bizdate);
        tx_return(ctx, TX_EINVAL, ctx->out);
        return;
    }
    /* 추출 상한(선택). 미지정/비정상이면 기본 10건, 과대 요청은 상한 clamp */
    if (tx_buf_getlong(ctx->in, "LIMITN", &limitn) != TX_OK || limitn <= 0)
        limitn = 10;
    if (limitn > 100) {
        tx_log(TX_LOG_WARN, "[RC_OL_0014] 추출상한 초과 요청 %ld → 100 clamp",
               limitn);
        limitn = 100;
    }
    tx_log(TX_LOG_INFO, "[RC_OL_0014] 추출조건 date=%s 상한=%ld", bizdate, limitn);

    strncpy(h_biz_date, bizdate, sizeof(h_biz_date) - 1);
    h_biz_date[sizeof(h_biz_date) - 1] = '\0';

    tx_buf_reset(ctx->out);

    ECPGset_var( 0, ( h_biz_date ), __LINE__);\
 /* declare cur_rc_ol_0014 cursor for select key , amount from rc_ledger where biz_date = $1  and status = 'R' order by key */
#line 77 "app/online/rc_ol_0014.pgc"

#line 77 "app/online/rc_ol_0014.pgc"


    { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "declare cur_rc_ol_0014 cursor for select key , amount from rc_ledger where biz_date = $1  and status = 'R' order by key", 
	ECPGt_char,(h_biz_date),(long)9,(long)1,(9)*sizeof(char), 
	ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, ECPGt_EORT);}
#line 79 "app/online/rc_ol_0014.pgc"

    if (sqlca.sqlcode != TX_SQL_OK) {
        TX_DBIO_LOG_ERR("OPEN cur_rc_ol_0014");
        tx_return(ctx, TX_EDB, ctx->out);
        return;
    }
    opened = 1;

    while (pushed < limitn) {
        memset(h_key, 0, sizeof(h_key));
        h_amount = 0;

        { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "fetch cur_rc_ol_0014", ECPGt_EOIT, 
	ECPGt_char,(h_key),(long)16,(long)1,(16)*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_EORT);}
#line 91 "app/online/rc_ol_0014.pgc"


        if (sqlca.sqlcode == TX_SQL_NOTFOUND)
            break;
        if (sqlca.sqlcode != TX_SQL_OK) {
            TX_DBIO_LOG_ERR("FETCH cur_rc_ol_0014");
            break;
        }

        snprintf(fname, sizeof(fname), "KEY%ld", pushed);
        tx_buf_sets(ctx->out, fname, h_key);
        snprintf(fname, sizeof(fname), "AMT%ld", pushed);
        tx_buf_setlong(ctx->out, fname, h_amount);

        sumamt += h_amount;
        pushed++;
    }

    if (opened)
        { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "close cur_rc_ol_0014", ECPGt_EOIT, ECPGt_EORT);}
#line 110 "app/online/rc_ol_0014.pgc"


    if (pushed == 0)
        tx_log(TX_LOG_INFO, "[RC_OL_0014] 미대사 접수건 없음 date=%s", bizdate);
    else if (pushed >= limitn)
        tx_log(TX_LOG_INFO,
               "[RC_OL_0014] 추출 상한 도달(추가 지연건 존재 가능) date=%s",
               bizdate);

    tx_buf_setlong(ctx->out, "UNRECCNT", pushed);
    tx_buf_setlong(ctx->out, "SUMAMT", sumamt);
    tx_log(TX_LOG_INFO, "[RC_OL_0014] 추출완료 date=%s 건수=%ld 합계=%ld",
           bizdate, pushed, sumamt);
    tx_return(ctx, TX_OK, ctx->out);
}