/* 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_0019.pgc" /* @tier easy @module rc @transform reconciliation-online */ /* * rc_ol_0019.pgc - 대사 원장반영 연계 온라인 서비스 (RC_OL_0019) * * 매입확정('M') 된 대사 원장 1건을 정산계로 반영(연계) 한다. * * [처리 규칙] * 1. KEY 로 원장 1건을 조회한다. * 2. 상태가 매입확정('M') 이 아니면 반영 대상이 아니므로 원장을 변경하지 * 않고 RESULT=NOTREADY 로 응답한다. * 3. 매입확정 건이면 원장 반영액(순액) = 거래금액 - 수수료 를 산출하고, * 상태를 정산완료('S') 로 전이한다. RESULT=SETTLED. * * [상태 전이] * 매입확정('M') --원장반영--> 정산완료('S') * * 정산계 연계 금액은 SETTLEAMT 필드로 응답에 실어 후속 정산 배치가 * 소비할 수 있게 한다. 커서를 사용하지 않는 단건 처리 서비스이다. */ #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 28 "app/online/rc_ol_0019.pgc" TX_SERVICE(RC_OL_0019, ctx) { rc_rec_t rec; char key[16]; long settle_amt = 0; int rc; tx_log(TX_LOG_INFO, "[RC_OL_0019] 대사 원장반영 연계 서비스 진입"); if (tx_buf_get(ctx->in, "KEY", key, sizeof(key)) != TX_OK) { tx_log(TX_LOG_ERROR, "[RC_OL_0019] KEY 누락"); tx_return(ctx, TX_EINVAL, ctx->out); return; } if (key[0] == '\0') { tx_log(TX_LOG_WARN, "[RC_OL_0019] KEY 공백"); tx_return(ctx, TX_EINVAL, ctx->out); return; } tx_log(TX_LOG_INFO, "[RC_OL_0019] 원장반영 대상 key=%s", key); memset(&rec, 0, sizeof(rec)); rc = rc_rec_select(key, &rec); if (rc != TX_OK) { tx_log(TX_LOG_WARN, "[RC_OL_0019] 원장 조회 실패 key=%s rc=%d(%s)", key, rc, tx_strerror(rc)); tx_return(ctx, rc, ctx->out); return; } tx_log(TX_LOG_INFO, "[RC_OL_0019] 원장 조회 key=%s 상태=%s 거래액=%ld 수수료=%ld", key, rec.status, rec.amount, rec.fee); /* 반영 대상은 매입확정('M') 건으로 한정 */ if (rec.status[0] != RC_ST_DONE[0]) { tx_log(TX_LOG_WARN, "[RC_OL_0019] 반영대상 아님(매입확정 아님) key=%s status=%s", key, rec.status); tx_buf_reset(ctx->out); tx_buf_sets(ctx->out, "KEY", rec.key); tx_buf_setlong(ctx->out, "AMOUNT", rec.amount); tx_buf_setlong(ctx->out, "FEE", rec.fee); tx_buf_setlong(ctx->out, "SETTLEAMT", 0); tx_buf_sets(ctx->out, "OLDSTATUS", rec.status); tx_buf_sets(ctx->out, "NEWSTATUS", rec.status); tx_buf_sets(ctx->out, "RESULT", "NOTREADY"); tx_return(ctx, TX_OK, ctx->out); return; } /* 원장 반영액 = 거래금액 - 수수료 (순액) */ settle_amt = rec.amount - rec.fee; if (settle_amt < 0) { /* 수수료가 거래금액을 초과하는 비정상 데이터 방어 */ tx_log(TX_LOG_ERROR, "[RC_OL_0019] 반영액 음수(데이터 오류) key=%s amount=%ld fee=%ld", key, rec.amount, rec.fee); tx_return(ctx, TX_EINVAL, ctx->out); return; } tx_log(TX_LOG_INFO, "[RC_OL_0019] 정산반영 산출 key=%s 거래액=%ld 수수료=%ld 반영액=%ld", key, rec.amount, rec.fee, settle_amt); /* * 상태 전이는 rc 표준 DBIO(rc_rec_update_status) 로만 수행한다. * 원장을 매입확정('M')에서 정산완료('S')로 전이하며, 실패 시 응답 없이 * 원 오류코드를 그대로 상위로 반환한다. */ rc = rc_rec_update_status(key, RC_ST_SETTLED); if (rc != TX_OK) { tx_log(TX_LOG_ERROR, "[RC_OL_0019] 정산완료 전이 실패 key=%s rc=%d", key, rc); tx_return(ctx, rc, ctx->out); return; } tx_buf_reset(ctx->out); tx_buf_sets(ctx->out, "KEY", rec.key); tx_buf_setlong(ctx->out, "AMOUNT", rec.amount); tx_buf_setlong(ctx->out, "FEE", rec.fee); tx_buf_setlong(ctx->out, "SETTLEAMT", settle_amt); tx_buf_sets(ctx->out, "OLDSTATUS", RC_ST_DONE); tx_buf_sets(ctx->out, "NEWSTATUS", RC_ST_SETTLED); tx_buf_sets(ctx->out, "RESULT", "SETTLED"); /* 정산계 연계 내역을 rc_settle_link 에 임베디드 SQL 로 적재 */ { /* exec sql begin declare section */ #line 122 "app/online/rc_ol_0019.pgc" char h_sl_key [ 16 ] ; #line 123 "app/online/rc_ol_0019.pgc" char h_sl_merch [ 16 ] ; #line 124 "app/online/rc_ol_0019.pgc" long h_sl_amt ; /* exec sql end declare section */ #line 125 "app/online/rc_ol_0019.pgc" strncpy(h_sl_key, key, sizeof(h_sl_key) - 1); h_sl_key[sizeof(h_sl_key) - 1] = '\0'; strncpy(h_sl_merch, rec.merch_id, sizeof(h_sl_merch) - 1); h_sl_merch[sizeof(h_sl_merch) - 1] = '\0'; h_sl_amt = settle_amt; if (tx_begin() == TX_OK) { { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "insert into rc_settle_link ( rec_key , merch_id , settle_amt , link_status ) values ( $1 , $2 , $3 , 'L' )", ECPGt_char,(h_sl_key),(long)16,(long)1,(16)*sizeof(char), ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_char,(h_sl_merch),(long)16,(long)1,(16)*sizeof(char), ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_long,&(h_sl_amt),(long)1,(long)1,sizeof(long), ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, ECPGt_EORT);} #line 136 "app/online/rc_ol_0019.pgc" if (sqlca.sqlcode != TX_SQL_OK) { TX_DBIO_LOG_ERR("INSERT rc_settle_link"); tx_abort(); } else { tx_commit(); } } } tx_log(TX_LOG_INFO, "[RC_OL_0019] 원장반영 완료 key=%s 반영액=%ld 상태=%s->%s", key, settle_amt, RC_ST_DONE, RC_ST_SETTLED); tx_return(ctx, TX_OK, ctx->out); }