/* 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_0027.pgc" /* @tier easy @module rc @transform reconciliation-online */ /* * rc_ol_0027.pgc - 대사율 조회 온라인 서비스 (RC_OL_0027) * * 요청 영업일(BIZDATE)에 대해 상태별 원장 건수를 집계하여 그날의 * 대사율(완료 비율)과 미대사율(잔여 비율)을 산출한다. * 상태별로 rc_rec_count 를 호출한다: * 접수('R'), 매입확정('M'), 불일치('U'), 정산완료('S'). * * 업무규칙: * - total = 접수 + 매입확정 + 불일치 + 정산완료 (0 방어) * - 대사율 RECRATE = (매입확정 + 정산완료) * 100 / total * - 미대사율 UNRECRATE = (접수 + 불일치) * 100 / total * * 응답: BIZDATE, TOTAL, CNTR, CNTM, CNTU, CNTS, RECRATE, UNRECRATE * * 비고: * - 원장(rc_ledger) 을 직접 순회하지 않고 상태별 집계 API 만 사용하므로 * 커서 없이 O(상태수) 회의 count 호출로 대사율을 계산한다 (읽기 전용). * - 백분율은 정수 나눗셈이라 절삭되며, RECRATE + UNRECRATE 가 100 미만이 * 될 수 있다. 이는 표시 목적의 근사치이며 감사에는 원건수를 사용한다. */ #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_0027.pgc" TX_SERVICE(RC_OL_0027, ctx) { char bizdate[16]; long cnt_r, cnt_m, cnt_u, cnt_s; long total; long recrate, unrecrate; long recdone; /* 대사완료 건수 (M + S) */ long recopen; /* 미대사 건수 (R + U) */ tx_log(TX_LOG_INFO, "[RC_OL_0027] 대사율 조회 서비스 진입"); /* --- 요청 필드 추출 및 검증 --- */ if (tx_buf_get(ctx->in, "BIZDATE", bizdate, sizeof(bizdate)) != TX_OK) { tx_log(TX_LOG_ERROR, "[RC_OL_0027] BIZDATE 누락"); tx_return(ctx, TX_EINVAL, ctx->out); return; } if (!date_is_valid(bizdate)) { tx_log(TX_LOG_WARN, "[RC_OL_0027] 영업일 형식 오류 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_0027] 건수 집계 실패 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; } total = cnt_r + cnt_m + cnt_u + cnt_s; recdone = cnt_m + cnt_s; /* 매입확정 + 정산완료 = 대사완료 */ recopen = cnt_r + cnt_u; /* 접수 + 불일치 = 미대사 */ /* 상태별 내역을 감사 로그로 남겨 이후 대사 추적을 돕는다. */ tx_log(TX_LOG_INFO, "[RC_OL_0027] 상태내역 date=%s 접수=%ld 매입=%ld 불일치=%ld 정산=%ld", bizdate, cnt_r, cnt_m, cnt_u, cnt_s); /* --- 대사율/미대사율 산출 (0 나눗셈 방어) --- */ if (total > 0) { recrate = recdone * 100 / total; unrecrate = recopen * 100 / total; } else { recrate = 0; unrecrate = 0; tx_log(TX_LOG_WARN, "[RC_OL_0027] 대상 원장 없음 date=%s → 대사율 0%%", bizdate); } /* 대사율과 미대사율의 합은 정상적으로 100(잔차 제외) 이어야 한다. * 정수 나눗셈 절삭으로 100 미만이 될 수 있어 참고용으로만 기록한다. */ tx_log(TX_LOG_INFO, "[RC_OL_0027] date=%s 총=%ld 완료=%ld 잔여=%ld 대사율=%ld%% 미대사율=%ld%%", bizdate, total, recdone, recopen, recrate, unrecrate); /* --- 대사율 수준별 정성 등급을 로그로 남긴다 (응답에는 미포함) --- */ if (total == 0) tx_log(TX_LOG_INFO, "[RC_OL_0027] 등급=N/A (대상 없음)"); else if (recrate >= 100) tx_log(TX_LOG_INFO, "[RC_OL_0027] 등급=완전대사 (100%%)"); else if (recrate >= 90) tx_log(TX_LOG_INFO, "[RC_OL_0027] 등급=양호 (대사율 %ld%%)", recrate); else if (recrate >= 70) tx_log(TX_LOG_WARN, "[RC_OL_0027] 등급=주의 (대사율 %ld%%)", recrate); else tx_log(TX_LOG_WARN, "[RC_OL_0027] 등급=미흡 (대사율 %ld%%)", recrate); /* --- 응답 구성 --- */ tx_buf_reset(ctx->out); tx_buf_sets(ctx->out, "BIZDATE", bizdate); tx_buf_setlong(ctx->out, "TOTAL", total); 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, "RECRATE", recrate); tx_buf_setlong(ctx->out, "UNRECRATE", unrecrate); /* 대사완료(M,S) 건수를 원장에서 직접 임베디드 SQL 로 집계 (DBRECDONE) */ { /* exec sql begin declare section */ #line 123 "app/online/rc_ol_0027.pgc" char h_r27_bd [ 9 ] ; #line 124 "app/online/rc_ol_0027.pgc" long h_r27_done ; /* exec sql end declare section */ #line 125 "app/online/rc_ol_0027.pgc" strncpy(h_r27_bd, bizdate, sizeof(h_r27_bd) - 1); h_r27_bd[sizeof(h_r27_bd) - 1] = '\0'; h_r27_done = 0; { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "select count ( * ) from rc_ledger where biz_date = $1 and status in ( 'M' , 'S' )", ECPGt_char,(h_r27_bd),(long)9,(long)1,(9)*sizeof(char), ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, ECPGt_long,&(h_r27_done),(long)1,(long)1,sizeof(long), ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EORT);} #line 135 "app/online/rc_ol_0027.pgc" if (sqlca.sqlcode != TX_SQL_OK && sqlca.sqlcode != TX_SQL_NOTFOUND) { TX_DBIO_LOG_ERR("SELECT rc_ledger recdone"); h_r27_done = recdone; } tx_buf_setlong(ctx->out, "DBRECDONE", h_r27_done); } tx_log(TX_LOG_INFO, "[RC_OL_0027] 대사율 조회 서비스 정상 종료 date=%s", bizdate); tx_return(ctx, TX_OK, ctx->out); }