/* Processed by ecpg (15.18 (Debian 15.18-0+deb12u1)) */ /* These include files are added by the preprocessor */ #include #include #include /* End of automatic include section */ #line 1 "app/online/rc_ol_0032.pgc" /* @tier easy @module rc @transform reconciliation-online */ /* * rc_ol_0032.pgc - 대사 요약 리포트 조회 온라인 서비스 (RC_OL_0032) * * 요청 영업일(BIZDATE)에 대해 상태별 원장 건수와 금액 합계를 집계하여 * 하루치 대사 요약 리포트를 구성한다. * 상태별 건수는 rc_rec_count(R/M/U/S), 금액 합계는 rc_rec_sum 을 사용한다. * * 업무규칙: * - total = 접수 + 매입확정 + 불일치 + 정산완료 (0 방어) * - 대사율 RECRATE = (매입확정 + 정산완료) * 100 / total * - 총평 OVERALL = 접수('R')==0 && 불일치('U')==0 → "CLOSED" * (미처리/불일치 잔존 시) → "OPEN" * * 응답: BIZDATE, CNTR, CNTM, CNTU, CNTS, SUMAMT, RECRATE, OVERALL * * 비고: * - 건수는 상태별 rc_rec_count, 금액은 rc_rec_sum 으로 집계하며 원장을 * 커서로 순회하지 않는다 (읽기 전용). * - OVERALL 은 접수/불일치가 모두 소진되어야 "CLOSED" 가 되며, 하나라도 * 남아 있으면 "OPEN" 으로 마감 대기 상태임을 알린다. */ #include #include #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 31 "app/online/rc_ol_0032.pgc" TX_SERVICE(RC_OL_0032, ctx) { char bizdate[16]; long cnt_r, cnt_m, cnt_u, cnt_s; long total, sumamt = 0; long recrate; const char *overall; int rc; tx_log(TX_LOG_INFO, "[RC_OL_0032] 대사 요약 리포트 조회 서비스 진입"); if (tx_buf_get(ctx->in, "BIZDATE", bizdate, sizeof(bizdate)) != TX_OK) { tx_log(TX_LOG_ERROR, "[RC_OL_0032] BIZDATE 누락"); tx_return(ctx, TX_EINVAL, ctx->out); return; } if (!date_is_valid(bizdate)) { tx_log(TX_LOG_WARN, "[RC_OL_0032] 영업일 형식 오류 date=%s", bizdate); tx_return(ctx, TX_EINVAL, ctx->out); return; } /* --- 상태별 건수 집계 --- */ cnt_r = rc_rec_count(bizdate, RC_ST_RECV); cnt_m = rc_rec_count(bizdate, RC_ST_DONE); cnt_u = rc_rec_count(bizdate, RC_ST_FAIL); cnt_s = rc_rec_count(bizdate, RC_ST_SETTLED); if (cnt_r < 0 || cnt_m < 0 || cnt_u < 0 || cnt_s < 0) { tx_log(TX_LOG_ERROR, "[RC_OL_0032] 건수 집계 실패 date=%s R=%ld M=%ld U=%ld S=%ld", bizdate, cnt_r, cnt_m, cnt_u, cnt_s); tx_return(ctx, TX_EDB, ctx->out); return; } /* --- 금액 합계 집계 --- */ rc = rc_rec_sum(bizdate, &sumamt); if (rc != TX_OK) { tx_log(TX_LOG_ERROR, "[RC_OL_0032] 금액 합계 실패 date=%s rc=%d(%s)", bizdate, rc, tx_strerror(rc)); tx_return(ctx, rc, ctx->out); return; } total = cnt_r + cnt_m + cnt_u + cnt_s; /* 리포트 본문에 앞서 상태 내역과 금액 합계를 감사 로그로 남긴다. */ tx_log(TX_LOG_INFO, "[RC_OL_0032] 집계 date=%s 접수=%ld 매입=%ld 불일치=%ld 정산=%ld 합계=%ld", bizdate, cnt_r, cnt_m, cnt_u, cnt_s, sumamt); /* --- 대사율 산출 (0 나눗셈 방어) --- */ if (total > 0) { recrate = (cnt_m + cnt_s) * 100 / total; } else { recrate = 0; tx_log(TX_LOG_WARN, "[RC_OL_0032] 대상 원장 없음 date=%s → 대사율 0%%", bizdate); } /* --- 총평: 미처리/불일치 잔존 여부로 마감 상태 판정 --- */ if (cnt_r == 0 && cnt_u == 0) { overall = "CLOSED"; tx_log(TX_LOG_INFO, "[RC_OL_0032] 마감 완료 date=%s 총=%ld 대사율=%ld%%", bizdate, total, recrate); } else { overall = "OPEN"; tx_log(TX_LOG_WARN, "[RC_OL_0032] 미결 잔존 date=%s 접수=%ld 불일치=%ld", bizdate, cnt_r, cnt_u); } tx_buf_reset(ctx->out); tx_buf_sets(ctx->out, "BIZDATE", bizdate); tx_buf_setlong(ctx->out, "CNTR", cnt_r); tx_buf_setlong(ctx->out, "CNTM", cnt_m); tx_buf_setlong(ctx->out, "CNTU", cnt_u); tx_buf_setlong(ctx->out, "CNTS", cnt_s); tx_buf_setlong(ctx->out, "SUMAMT", sumamt); tx_buf_setlong(ctx->out, "RECRATE", recrate); tx_buf_sets(ctx->out, "OVERALL", overall); /* 원장에서 직접 총건수/총수수료를 임베디드 SQL 로 집계 (DBCNT/FEESUM) */ { /* exec sql begin declare section */ #line 121 "app/online/rc_ol_0032.pgc" char h_r32_bd [ 9 ] ; #line 122 "app/online/rc_ol_0032.pgc" long h_r32_cnt ; #line 123 "app/online/rc_ol_0032.pgc" long h_r32_feesum ; /* exec sql end declare section */ #line 124 "app/online/rc_ol_0032.pgc" strncpy(h_r32_bd, bizdate, sizeof(h_r32_bd) - 1); h_r32_bd[sizeof(h_r32_bd) - 1] = '\0'; h_r32_cnt = 0; h_r32_feesum = 0; { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "select count ( * ) , coalesce ( SUM ( fee ) , 0 ) from rc_ledger where biz_date = $1 ", ECPGt_char,(h_r32_bd),(long)9,(long)1,(9)*sizeof(char), ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, ECPGt_long,&(h_r32_cnt),(long)1,(long)1,sizeof(long), ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_long,&(h_r32_feesum),(long)1,(long)1,sizeof(long), ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EORT);} #line 134 "app/online/rc_ol_0032.pgc" if (sqlca.sqlcode != TX_SQL_OK && sqlca.sqlcode != TX_SQL_NOTFOUND) { TX_DBIO_LOG_ERR("SELECT rc_ledger dbcnt/feesum"); h_r32_cnt = total; h_r32_feesum = 0; } tx_buf_setlong(ctx->out, "DBCNT", h_r32_cnt); tx_buf_setlong(ctx->out, "FEESUM", h_r32_feesum); } tx_log(TX_LOG_INFO, "[RC_OL_0032] 대사 요약 리포트 서비스 정상 종료 date=%s 총평=%s 대사율=%ld%%", bizdate, overall, recrate); tx_return(ctx, TX_OK, ctx->out); }