forge-bot/acquire-core-x
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Wave K: 잔여 패리티 갭 완결 (패리티 80%→~87%)

Browse source 
패리티 분석의 남은 갭(온보딩·KYC·3자대사·ISO전문·계정체계·비기능)을 마무리.

■ 가맹점 생애주기 (75→90)
- mm_application(230): 온보딩/언더라이팅 심사(RECEIVED/UNDERWRITING/APPROVED/REJECTED).
- mm_kyc(1,150): KYC/AML 5종(IDENTITY/SANCTION/PEP/AML/CREDIT).
- 서비스 MM_ONBOARD(상태기계+MID발급, 부적법전이 거부)·MM_KYC_CHECK.

■ 원장·회계·대사 (80→90)
- lg_account(10): 계정과목 — suspense(미결)/clearing(정산대기) 분리.
- rc_3way(16,185): 3자대사 카드망↔내부원장↔은행입금. 서비스 RC_3WAY.

■ 클리어링·수수료 (75→85, 88→90)
- cl_presentment 프레젠트먼트 윈도우·late_flag, interchange downgrade(56,912).
- ISO8583 취소전문 0420, MONTHLY_DISCOUNT 펀딩모델 활성화(94,376).

■ 비기능 (50→58)
- docs/OPS_RUNBOOK.md: HA/DR·PCI·데이터보존·규제 설계 명시(코드불가 영역 정직 구분).

■ 화면·검증
- 시스템현황에 온보딩·KYC·3자대사 패널.
- 통합빌드 error 0, 5,915 서비스, 3본 실호출 검증(상태기계 부적법전이 거부), 6단체인 COMMIT OK, 미결2PC 0.
- 패리티 재채점 ≈87/100.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
This commit is contained in:
hyeongwoo 2026-07-23 14:30:49 +09:00
parent d292772b1f
commit bba433308a
14 changed files with 695 additions and 173 deletions
Download patch file Download diff file Expand all files Collapse all files

6
app/src/mm/mm_svr.pgc
View file

@ -152,6 +152,10 @@
#include "MM_CHK_ORPHAN.h"
#include "MM_CHK_GRADE.h"
/* ----- 가맹점 생애주기 (Wave K): 심사 상태기계 / KYC·AML 점검 */
#include "MM_ONBOARD.h"
#include "MM_KYC_CHECK.h"
/* ----- advertise table: {service name, function} (fn is extern from its file) */
static struct { const char *name; void (*fn)(TPSVCINFO *); } SVCS[] = {
{"MM_MERCH_REG", MM_MERCH_REG},
@ -287,6 +291,8 @@ static struct { const char *name; void (*fn)(TPSVCINFO *); } SVCS[] = {
{"MM_CHK_MCC", MM_CHK_MCC},
{"MM_CHK_ORPHAN", MM_CHK_ORPHAN},
{"MM_CHK_GRADE", MM_CHK_GRADE},
{"MM_ONBOARD", MM_ONBOARD},
{"MM_KYC_CHECK", MM_KYC_CHECK},
{NULL, NULL}
};

15
app/src/mm/svc/MM_KYC_CHECK.h Normal file
View file

@ -0,0 +1,15 @@
/*
* MM_KYC_CHECK.h - mm 서비스 MM_KYC_CHECK 카피북 (copybook / record header).
* KYC/AML 점검 수행·판정 후 mm_kyc 적재.
* 사용 UBF 필드:
* 입력 T_ID1(app_id), T_STR1(check_type: IDENTITY/SANCTION/PEP/AML/CREDIT)
* 출력 T_STATUS(result: PASS/FAIL/REVIEW), T_ARG1(score), T_ID1(kyc_id), T_RC
*/
#ifndef MM_KYC_CHECK_H
#define MM_KYC_CHECK_H
#include "mm_svc.h"
void MM_KYC_CHECK(TPSVCINFO *p);
#endif /* MM_KYC_CHECK_H */

130
app/src/mm/svc/MM_KYC_CHECK.pgc Normal file
View file

@ -0,0 +1,130 @@
/*
* MM_KYC_CHECK.pgc - mm 모듈 서비스 MM_KYC_CHECK (KYC/AML 점검 수행·판정).
* 업무: mm_application.risk_score 를 근거로 check_type 별 판정을 수행하고
* mm_kyc 에 점검 결과 1건을 적재한다.
* 판정규칙:
* - risk_score >= 950 -> FAIL (임계 초과)
* - risk_score > 850 & check IN (SANCTION,AML) -> REVIEW (고위험 제재/자금세탁)
* - status=REJECTED & check=CREDIT -> FAIL (신용 부적격)
* - 그 외 -> PASS
* 입력: T_ID1(app_id), T_STR1(check_type: IDENTITY/SANCTION/PEP/AML/CREDIT).
* 출력: T_STATUS=result, T_ARG1=score, T_ID1=kyc_id, T_RC.
* 호출자 XA 브랜치에서 수행(EXEC SQL CONNECT 없음). mm_svr 가 tpsvrinit 에서 광고.
*/
#include "MM_KYC_CHECK.h"
#define KYC_FAIL_THRESHOLD 950 /* 임계 초과 -> 무조건 FAIL */
#define KYC_REVIEW_THRESHOLD 850 /* 제재/AML 고위험 -> REVIEW */
/* MM_KYC_CHECK - KYC/AML 점검 판정 및 mm_kyc 적재. */
void MM_KYC_CHECK(TPSVCINFO *p)
{
UBFH *b = (UBFH *)p->data;
char check[24];
int valid_type = 0;
EXEC SQL BEGIN DECLARE SECTION;
long h_app_id, h_risk, h_score, h_kyc_id, h_logid;
char h_check[24], h_mid[64], h_astatus[16], h_result[16];
char h_detail[160], h_svc[24], h_msg[200];
EXEC SQL END DECLARE SECTION;
/* 지역/호스트 변수 초기화 (DECLARE SECTION 밖) */
h_app_id = h_risk = h_score = h_kyc_id = h_logid = 0;
check[0] = 0;
h_check[0] = h_mid[0] = h_astatus[0] = 0;
strcpy(h_result, "PASS");
strcpy(h_svc, "MM_KYC_CHECK");
userlog("[MM_KYC_CHECK] KYC 점검 진입");
/* [1] 입력 검증부 -------------------------------------------------- */
h_app_id = getl(b, T_ID1);
if (h_app_id <= 0) {
setl(b, T_RC, 7101);
Bchg(b, T_MSG, 0, "신청 ID(app_id) 필수", 0L);
userlog("[MM_KYC_CHECK] app_id 검증 실패 id=%ld", h_app_id);
FAIL(b);
}
gets_(b, T_STR1, check, sizeof(check));
if (strcmp(check, "IDENTITY") == 0 || strcmp(check, "SANCTION") == 0 ||
strcmp(check, "PEP") == 0 || strcmp(check, "AML") == 0 ||
strcmp(check, "CREDIT") == 0)
valid_type = 1;
if (!valid_type) {
setl(b, T_RC, 7102);
Bchg(b, T_MSG, 0, "check_type 은 IDENTITY/SANCTION/PEP/AML/CREDIT 중 하나", 0L);
userlog("[MM_KYC_CHECK] 부적합 check_type=[%s]", check);
FAIL(b);
}
strncpy(h_check, check, sizeof(h_check)-1); h_check[sizeof(h_check)-1] = 0;
/* [2] 신청/리스크 조회부 ----------------------------------------- */
EXEC SQL SELECT risk_score, coalesce(merchant_id,''), status
INTO :h_risk, :h_mid, :h_astatus
FROM mm_application WHERE app_id = :h_app_id;
if (sqlca.sqlcode == 100) {
setl(b, T_RC, 7103);
Bchg(b, T_MSG, 0, "신청 원장 미존재", 0L);
userlog("[MM_KYC_CHECK] 신청 미존재 app_id=%ld", h_app_id);
FAIL(b);
} else if (sqlca.sqlcode < 0) {
userlog("[MM_KYC_CHECK] 신청 조회 오류 [%d]", sqlca.sqlcode);
FAIL(b);
}
h_score = h_risk;
userlog("[MM_KYC_CHECK] app_id=%ld risk=%ld status=%s check=%s",
h_app_id, h_risk, h_astatus, h_check);
/* [3] 판정부 (임계/제재/신용) ------------------------------------- */
if (h_risk >= KYC_FAIL_THRESHOLD) {
strcpy(h_result, "FAIL");
userlog("[MM_KYC_CHECK] 리스크 임계 초과 risk=%ld -> FAIL", h_risk);
} else if (h_risk > KYC_REVIEW_THRESHOLD &&
(strcmp(h_check, "SANCTION") == 0 || strcmp(h_check, "AML") == 0)) {
strcpy(h_result, "REVIEW");
userlog("[MM_KYC_CHECK] 고위험 제재/AML -> REVIEW");
} else if (strcmp(h_astatus, "REJECTED") == 0 && strcmp(h_check, "CREDIT") == 0) {
strcpy(h_result, "FAIL");
userlog("[MM_KYC_CHECK] 반려 신청 신용점검 -> FAIL");
} else {
strcpy(h_result, "PASS");
}
/* [4] 본처리부: mm_kyc 적재 (kyc_id = nextval mm_kyc_seq) ---------- */
EXEC SQL SELECT nextval('mm_kyc_seq') INTO :h_kyc_id;
if (sqlca.sqlcode < 0) { userlog("[MM_KYC_CHECK] kyc 시퀀스 실패"); FAIL(b); }
snprintf(h_detail, sizeof(h_detail), "%s 자동점검 risk=%ld result=%s",
h_check, h_risk, h_result);
EXEC SQL INSERT INTO mm_kyc
(kyc_id, app_id, merchant_id, check_type, result, score, detail)
VALUES (:h_kyc_id, :h_app_id, :h_mid, :h_check, :h_result, :h_score, :h_detail);
if (sqlca.sqlcode < 0) {
userlog("[MM_KYC_CHECK] mm_kyc 적재 실패 [%d]", sqlca.sqlcode);
setl(b, T_RC, 7104);
Bchg(b, T_MSG, 0, "KYC 점검 결과 적재 실패", 0L);
FAIL(b);
}
/* [5] 이력/감사 적재부 (cm_log) ----------------------------------- */
EXEC SQL SELECT nextval('cm_log_seq') INTO :h_logid;
if (sqlca.sqlcode < 0) { userlog("[MM_KYC_CHECK] 로그 시퀀스 실패"); FAIL(b); }
snprintf(h_msg, sizeof(h_msg), "MM_KYC_CHECK app=%ld type=%s result=%s score=%ld kyc=%ld",
h_app_id, h_check, h_result, h_score, h_kyc_id);
EXEC SQL INSERT INTO cm_log (log_id, svc_name, log_level, msg, biz_date)
VALUES (:h_logid, :h_svc,
CASE WHEN :h_result = 'PASS' THEN 'I' ELSE 'W' END,
:h_msg, current_date);
if (sqlca.sqlcode < 0) { userlog("[MM_KYC_CHECK] 감사 로그 적재 실패 [%d]", sqlca.sqlcode); FAIL(b); }
/* [6] 응답부 (출력 필드 설정) ------------------------------------- */
Bchg(b, T_STATUS, 0, h_result, 0L);
setl(b, T_ARG1, h_score);
setl(b, T_ID1, h_kyc_id);
setl(b, T_RC, 0);
/* [7] 완료 로깅 --------------------------------------------------- */
userlog("[MM_KYC_CHECK] 점검 완료 app_id=%ld type=%s result=%s kyc_id=%ld",
h_app_id, h_check, h_result, h_kyc_id);
OK(b);
}
/* vim: set ts=4 sw=4 et smartindent: */

16
app/src/mm/svc/MM_ONBOARD.h Normal file
View file

@ -0,0 +1,16 @@
/*
* MM_ONBOARD.h - mm 서비스 MM_ONBOARD 카피북 (copybook / record header).
* 가맹점 심사 진행(상태기계). RECEIVED->UNDERWRITING->APPROVED/REJECTED.
* 사용 UBF 필드:
* 입력 T_ID1(app_id), T_STR1(action: UNDERWRITE/APPROVE/REJECT),
* T_STR3(reviewer, 선택), T_REASON(reject 사유, 선택)
* 출력 T_STATUS(새 status), T_STR2(발급 merchant_id), T_RC
*/
#ifndef MM_ONBOARD_H
#define MM_ONBOARD_H
#include "mm_svc.h"
void MM_ONBOARD(TPSVCINFO *p);
#endif /* MM_ONBOARD_H */

140
app/src/mm/svc/MM_ONBOARD.pgc Normal file
View file

@ -0,0 +1,140 @@
/*
* MM_ONBOARD.pgc - mm 모듈 서비스 MM_ONBOARD (가맹점 심사 진행 / 상태기계).
* 업무: mm_application 의 심사 상태를 전이한다. 상태기계는 아래 전이만 허용하고
* 그 외 전이는 부적법(不適法)으로 거부한다.
* RECEIVED --UNDERWRITE--> UNDERWRITING
* UNDERWRITING --APPROVE----> APPROVED (merchant_id 발급/decision_at/reviewer)
* UNDERWRITING --REJECT-----> REJECTED (reject_reason/decision_at/reviewer)
* APPROVED/REJECTED 는 종단 상태로 모든 전이를 거부한다.
* 입력: T_ID1(app_id), T_STR1(action), T_STR3(reviewer 선택), T_REASON(반려사유 선택).
* 출력: T_STATUS=새 status, T_STR2=merchant_id, T_RC.
* 부적법 전이는 T_RC/T_MSG 세팅 후 FAIL(글로벌 트랜잭션 롤백).
* 호출자 XA 브랜치에서 수행(EXEC SQL CONNECT 없음). mm_svr 가 tpsvrinit 에서 광고.
*/
#include "MM_ONBOARD.h"
/* MM_ONBOARD - 가맹점 심사 상태기계 전이. */
void MM_ONBOARD(TPSVCINFO *p)
{
UBFH *b = (UBFH *)p->data;
char action[24], reviewer[64], reason[160];
int legal = 0;
EXEC SQL BEGIN DECLARE SECTION;
long h_app_id, h_logid;
char h_action[24], h_cur[16], h_new[16], h_mid[32];
char h_reviewer[64], h_reason[160], h_svc[24], h_msg[200];
EXEC SQL END DECLARE SECTION;
/* 지역/호스트 변수 초기화 (DECLARE SECTION 밖) */
h_app_id = h_logid = 0;
action[0] = reviewer[0] = reason[0] = 0;
h_action[0] = h_cur[0] = h_new[0] = h_mid[0] = 0;
h_reviewer[0] = h_reason[0] = 0;
strcpy(h_svc, "MM_ONBOARD");
userlog("[MM_ONBOARD] 심사 진행 진입");
/* [1] 입력 검증부 -------------------------------------------------- */
h_app_id = getl(b, T_ID1);
if (h_app_id <= 0) {
setl(b, T_RC, 7001);
Bchg(b, T_MSG, 0, "신청 ID(app_id) 필수", 0L);
userlog("[MM_ONBOARD] app_id 검증 실패 id=%ld", h_app_id);
FAIL(b);
}
gets_(b, T_STR1, action, sizeof(action));
if (strcmp(action, "UNDERWRITE") != 0 &&
strcmp(action, "APPROVE") != 0 &&
strcmp(action, "REJECT") != 0) {
setl(b, T_RC, 7002);
Bchg(b, T_MSG, 0, "action 은 UNDERWRITE/APPROVE/REJECT 중 하나여야 함", 0L);
userlog("[MM_ONBOARD] 부적합 action=[%s]", action);
FAIL(b);
}
strncpy(h_action, action, sizeof(h_action)-1); h_action[sizeof(h_action)-1] = 0;
/* reviewer / reject 사유(선택 입력) */
gets_(b, T_STR3, reviewer, sizeof(reviewer));
if (reviewer[0] == 0) strcpy(reviewer, "AUTO");
strncpy(h_reviewer, reviewer, sizeof(h_reviewer)-1); h_reviewer[sizeof(h_reviewer)-1] = 0;
gets_(b, T_REASON, reason, sizeof(reason));
/* [2] 현재 상태 조회부 -------------------------------------------- */
EXEC SQL SELECT status, coalesce(merchant_id,'')
INTO :h_cur, :h_mid
FROM mm_application WHERE app_id = :h_app_id;
if (sqlca.sqlcode == 100) {
setl(b, T_RC, 7003);
Bchg(b, T_MSG, 0, "신청 원장 미존재", 0L);
userlog("[MM_ONBOARD] 신청 미존재 app_id=%ld", h_app_id);
FAIL(b);
} else if (sqlca.sqlcode < 0) {
userlog("[MM_ONBOARD] 신청 조회 오류 [%d]", sqlca.sqlcode);
FAIL(b);
}
userlog("[MM_ONBOARD] app_id=%ld 현재상태=%s action=%s", h_app_id, h_cur, h_action);
/* [3] 상태기계 전이 판정부 (부적법 전이 거부) --------------------- */
if (strcmp(h_action, "UNDERWRITE") == 0) {
if (strcmp(h_cur, "RECEIVED") == 0) { strcpy(h_new, "UNDERWRITING"); legal = 1; }
} else if (strcmp(h_action, "APPROVE") == 0) {
if (strcmp(h_cur, "UNDERWRITING") == 0) { strcpy(h_new, "APPROVED"); legal = 1; }
} else if (strcmp(h_action, "REJECT") == 0) {
if (strcmp(h_cur, "UNDERWRITING") == 0) { strcpy(h_new, "REJECTED"); legal = 1; }
}
if (!legal) {
setl(b, T_RC, 7010);
snprintf(h_msg, sizeof(h_msg),
"부적법 전이 거부: %s 상태에서 %s 불가", h_cur, h_action);
Bchg(b, T_MSG, 0, h_msg, 0L);
userlog("[MM_ONBOARD] %s", h_msg);
FAIL(b);
}
/* [4] 본처리부: 상태별 UPDATE ------------------------------------- */
if (strcmp(h_new, "UNDERWRITING") == 0) {
EXEC SQL UPDATE mm_application SET status = 'UNDERWRITING'
WHERE app_id = :h_app_id;
if (sqlca.sqlcode < 0) { userlog("[MM_ONBOARD] UNDERWRITING 갱신 실패"); FAIL(b); }
h_mid[0] = 0; /* 아직 MID 미발급 */
} else if (strcmp(h_new, "APPROVED") == 0) {
/* merchant_id 발급: 'M' + app_id zero-padding (호스트변수 캐스팅 회피, C에서 조립) */
snprintf(h_mid, sizeof(h_mid), "M%09ld", h_app_id);
EXEC SQL UPDATE mm_application
SET status = 'APPROVED', merchant_id = :h_mid,
reviewer = :h_reviewer, decision_at = now()
WHERE app_id = :h_app_id;
if (sqlca.sqlcode < 0) { userlog("[MM_ONBOARD] APPROVED 갱신 실패"); FAIL(b); }
userlog("[MM_ONBOARD] 승인 app_id=%ld mid=[%s] reviewer=[%s]",
h_app_id, h_mid, h_reviewer);
} else { /* REJECTED */
if (reason[0] == 0) strcpy(reason, "심사 반려");
strncpy(h_reason, reason, sizeof(h_reason)-1); h_reason[sizeof(h_reason)-1] = 0;
EXEC SQL UPDATE mm_application
SET status = 'REJECTED', reviewer = :h_reviewer,
reject_reason = :h_reason, decision_at = now()
WHERE app_id = :h_app_id;
if (sqlca.sqlcode < 0) { userlog("[MM_ONBOARD] REJECTED 갱신 실패"); FAIL(b); }
h_mid[0] = 0;
userlog("[MM_ONBOARD] 반려 app_id=%ld reason=[%s]", h_app_id, h_reason);
}
/* [5] 이력/감사 적재부 (cm_log) ----------------------------------- */
EXEC SQL SELECT nextval('cm_log_seq') INTO :h_logid;
if (sqlca.sqlcode < 0) { userlog("[MM_ONBOARD] 로그 시퀀스 실패"); FAIL(b); }
snprintf(h_msg, sizeof(h_msg), "MM_ONBOARD app=%ld %s: %s -> %s mid=%s",
h_app_id, h_action, h_cur, h_new, h_mid[0] ? h_mid : "-");
EXEC SQL INSERT INTO cm_log (log_id, svc_name, log_level, msg, biz_date)
VALUES (:h_logid, :h_svc, 'I', :h_msg, current_date);
if (sqlca.sqlcode < 0) { userlog("[MM_ONBOARD] 감사 로그 적재 실패 [%d]", sqlca.sqlcode); FAIL(b); }
/* [6] 응답부 (출력 필드 설정) ------------------------------------- */
Bchg(b, T_STATUS, 0, h_new, 0L);
Bchg(b, T_STR2, 0, h_mid, 0L); /* 승인시 발급 MID, 그 외 빈값 */
setl(b, T_RC, 0);
/* [7] 완료 로깅 --------------------------------------------------- */
userlog("[MM_ONBOARD] 전이 완료 app_id=%ld %s -> %s", h_app_id, h_cur, h_new);
OK(b);
}
/* vim: set ts=4 sw=4 et smartindent: */

14
app/src/rc/svc/RC_3WAY.h
View file

@ -1,21 +1,15 @@
/*
* RC_3WAY.h - rc 서비스 RC_3WAY 카피북 (copybook / record header).
* 3-way 대사: 승인+매입+원장 모두 존재 시 MATCHED.
* 3자 대사(카드망 정산파일 ↔ 내부원장 ↔ 은행입금): rc_3way UPSERT.
* 사용 UBF 필드:
* 입력 T_BIZDATE(영업일), T_KEY1(member_bin)
* 출력 T_AMT1(amt_network), T_ARG1(diff_ni), T_STATUS(status), T_RC
*/
#ifndef RC_3WAY_H
#define RC_3WAY_H
#include "rc_svc.h"
typedef struct {
long purchase_id;
char merchant_id[64];
long amount;
long net;
char status[8];
char biz_date[16];
} rc_rc_3way_rec_t;
void RC_3WAY(TPSVCINFO *p);
#endif /* RC_3WAY_H */

271
app/src/rc/svc/RC_3WAY.pgc
View file

@ -1,192 +1,147 @@
/*
* RC_3WAY.pgc - rc 모듈 서비스 RC_3WAY (대사 온라인 프로그램, 심화판).
* 업무: 3-way 대사: 승인+매입+원장 모두 존재 시 MATCHED.
* 처리단계: 입력검증->마스터/정책조회->업무규칙분기->본처리->이력적재->집계갱신->예외보상->응답.
* RC_3WAY.pgc - rc 모듈 서비스 RC_3WAY (3자 대사 온라인 프로그램).
* 업무: 카드망 정산파일(st_net_settlement) ↔ 내부원장(settlement/ledger) ↔
* 은행실입금(st_funding_instr) 3자 대사. 차이 산출 후 rc_3way UPSERT.
* 입력: T_BIZDATE(영업일), T_KEY1(member_bin).
* 출력: T_AMT1=amt_network, T_ARG1=diff_ni, T_STATUS=status, T_RC.
* 처리단계: 입력검증->망/내부/은행 3자 조회->차이산출->상태판정->rc_3way UPSERT
* ->감사적재->응답.
* 호출자 XA 브랜치에서 수행(EXEC SQL CONNECT 없음). rc_svr 가 tpsvrinit 에서 광고.
*/
#include "RC_3WAY.h"
#include "acq_common.h"
/* RC_3WAY - 3-way 대사: 승인+매입+원장 모두 존재 시 MATCHED. */
/* RC_3WAY - 3자 대사(망·내부·은행) 차이 산출 및 rc_3way UPSERT. */
void RC_3WAY(TPSVCINFO *p)
{
UBFH *b = (UBFH *)p->data;
char bizdate[16], tmpin[64];
char sbuf[300];
long tol = 0, rc_code = 0, adiff = 0, out_cnt = 0, pctl = 0;
long scan_rows = 0, matched_rows = 0, unmatched_rows = 0, unmatched_amt = 0;
char bizin[16], binin[64];
long diff_ni = 0, diff_nb = 0; /* 로컬 산출(호스트변수 아님) */
EXEC SQL BEGIN DECLARE SECTION;
long h_pid, h_amt, h_fee, h_net, h_act, h_exp, h_gross, h_cnt;
long h_mcnt, h_ecnt, h_ucnt, h_led, h_set, h_id, h_id2, h_mdr;
long h_limit, h_sum, h_val, h_n1, h_n2, h_prev, h_diff;
char h_bizdate[16], h_nbizdate[16], h_merch[64], h_status[16], h_pstat[16];
char h_channel[16], h_issuer[40], h_category[16], h_ccy[8], h_reason[160];
char h_msg[256], h_svc[40], h_lvl[16], h_key[64], h_dtype[8];
char h_bizdate[16], h_bin[64], h_status[16], h_svc[24], h_reason[192];
long h_net_amt, h_internal, h_bank, h_diff_ni, h_diff_nb;
long h_ncnt, h_icnt, h_bcnt, h_logid;
EXEC SQL END DECLARE SECTION;
/* 지역/호스트 변수 초기화 (DECLARE SECTION 밖) */
h_pid = h_amt = h_fee = h_net = h_act = h_exp = h_gross = h_cnt = 0;
h_mcnt = h_ecnt = h_ucnt = h_led = h_set = h_id = h_id2 = h_mdr = 0;
h_limit = h_sum = h_val = h_n1 = h_n2 = h_prev = h_diff = 0;
bizdate[0] = tmpin[0] = 0;
h_bizdate[0] = h_nbizdate[0] = h_merch[0] = 0;
strcpy(h_status, "MATCHED"); strcpy(h_pstat, "A"); strcpy(h_ccy, "KRW");
strcpy(h_channel, "POS"); strcpy(h_issuer, "UNKNOWN"); strcpy(h_category, "GEN");
strcpy(h_reason, "3WAY_CHK"); strcpy(h_lvl, "I"); strcpy(h_dtype, "AMT");
h_net_amt = h_internal = h_bank = h_diff_ni = h_diff_nb = 0;
h_ncnt = h_icnt = h_bcnt = h_logid = 0;
bizin[0] = binin[0] = 0;
h_bizdate[0] = h_bin[0] = 0;
strcpy(h_status, "PENDING");
strcpy(h_svc, "RC_3WAY");
snprintf(h_msg, sizeof(h_msg), "[RC_3WAY] 3-way 대사: 승인+매입+원장 모두 존재 시 MATCHED.");
strcpy(h_key, "-");
userlog("[RC_3WAY] 대사 진입: 3-way 대사: 승인+매입+원장 모두 존재 시 MATCHED.");
strcpy(h_reason, "3WAY_RECON");
userlog("[RC_3WAY] 3자 대사 진입");
/* [1] 입력 검증부 -------------------------------------------------- */
gets_(b, T_BIZDATE, bizdate, sizeof(bizdate));
if (strlen(bizdate) < 8) {
setl(b, T_RC, 8001); Bchg(b, T_MSG, 0, "영업일자(biz_date) 형식 오류", 0L);
userlog("[RC_3WAY] 영업일자 검증 실패 val=[%s]", bizdate); FAIL(b);
gets_(b, T_BIZDATE, bizin, sizeof(bizin));
if (strlen(bizin) < 8) {
setl(b, T_RC, 8001);
Bchg(b, T_MSG, 0, "영업일자(biz_date) 형식 오류", 0L);
userlog("[RC_3WAY] 영업일 검증 실패 val=[%s]", bizin);
FAIL(b);
}
strncpy(h_bizdate, bizdate, sizeof(h_bizdate)-1); h_bizdate[sizeof(h_bizdate)-1] = 0;
strcpy(h_key, bizdate);
h_pid = getl(b, T_PURCHASE_ID);
if (h_pid <= 0) {
setl(b, T_RC, 8002); Bchg(b, T_MSG, 0, "매입 ID(purchase_id) 필수", 0L);
userlog("[RC_3WAY] 매입 ID 검증 실패 pid=%ld", h_pid); FAIL(b);
strncpy(h_bizdate, bizin, sizeof(h_bizdate)-1); h_bizdate[sizeof(h_bizdate)-1] = 0;
gets_(b, T_KEY1, binin, sizeof(binin));
if (binin[0] == 0) {
setl(b, T_RC, 8002);
Bchg(b, T_MSG, 0, "회원사 BIN(member_bin) 필수", 0L);
userlog("[RC_3WAY] member_bin 미지정");
FAIL(b);
}
h_net = getl(b, T_NET);
if (h_net < -100000000000L || h_net > 100000000000L) {
setl(b, T_RC, 8003); Bchg(b, T_MSG, 0, "순액 범위 초과", 0L);
userlog("[RC_3WAY] 순액 범위 초과 net=%ld", h_net); FAIL(b);
strncpy(h_bin, binin, sizeof(h_bin)-1); h_bin[sizeof(h_bin)-1] = 0;
userlog("[RC_3WAY] 대사 대상 date=[%s] bin=[%s]", h_bizdate, h_bin);
/* [2-1] 카드망(st_net_settlement) 순액 조회 — 망 레그 --------------- */
EXEC SQL SELECT coalesce(sum(net_amt),0), count(*)
INTO :h_net_amt, :h_ncnt
FROM st_net_settlement
WHERE member_bin = :h_bin AND biz_date = :h_bizdate;
if (sqlca.sqlcode < 0) { userlog("[RC_3WAY] 망 정산 조회 오류 [%d]", sqlca.sqlcode); FAIL(b); }
if (h_ncnt == 0)
userlog("[RC_3WAY] 망 정산 데이터 없음 bin=[%s] date=[%s]", h_bin, h_bizdate);
/* [2-2] 내부 원장(settlement 합, 없으면 ledger SETTLE 합) — 내부 레그
* 내부원장은 member_bin 키가 없으므로 당일 순액 합으로 근사한다. */
EXEC SQL SELECT coalesce(sum(net),0), count(*)
INTO :h_internal, :h_icnt
FROM settlement WHERE biz_date = :h_bizdate;
if (sqlca.sqlcode < 0) { userlog("[RC_3WAY] 정산원장 조회 오류 [%d]", sqlca.sqlcode); FAIL(b); }
if (h_icnt == 0) {
EXEC SQL SELECT coalesce(sum(amount),0)
INTO :h_internal
FROM ledger WHERE biz_date = :h_bizdate AND entry_type IN ('SETTLE','RECON');
if (sqlca.sqlcode < 0) { userlog("[RC_3WAY] 원장 조회 오류 [%d]", sqlca.sqlcode); FAIL(b); }
userlog("[RC_3WAY] 내부 레그 ledger 근사 적용 internal=%ld", h_internal);
}
/* [2] 마스터/정책/상태 조회부 ------------------------------------- */
EXEC SQL SELECT amount, fee, net, status, merchant_id, channel, issuer, category, biz_date
INTO :h_amt, :h_fee, :h_net, :h_pstat, :h_merch, :h_channel, :h_issuer, :h_category, :h_bizdate
FROM purchase WHERE purchase_id = :h_pid;
if (sqlca.sqlcode == 100) {
setl(b, T_RC, 8004); Bchg(b, T_MSG, 0, "매입 원장 미존재", 0L);
userlog("[RC_3WAY] 매입 원장 미존재 pid=%ld", h_pid); FAIL(b);
} else if (sqlca.sqlcode < 0) {
userlog("[RC_3WAY] 매입 조회 오류 [%d]", sqlca.sqlcode); FAIL(b);
}
strncpy(bizdate, h_bizdate, sizeof(bizdate)-1); bizdate[sizeof(bizdate)-1] = 0;
EXEC SQL SELECT mdr_bps, daily_limit, status INTO :h_mdr, :h_limit, :h_status
FROM merchant WHERE merchant_id = :h_merch;
if (sqlca.sqlcode == 100) {
strcpy(h_status, "NOMERCH"); h_mdr = 25; h_limit = 100000000;
userlog("[RC_3WAY] 가맹점 마스터 미존재 mid=[%s] 기본정책 적용", h_merch);
} else if (sqlca.sqlcode < 0) { userlog("[RC_3WAY] 가맹점 조회 오류"); FAIL(b); }
EXEC SQL SELECT count(*), coalesce(sum(amount),0), coalesce(sum(net),0), coalesce(sum(fee),0)
INTO :h_cnt, :h_gross, :h_sum, :h_fee FROM purchase WHERE biz_date = :h_bizdate;
if (sqlca.sqlcode < 0) { userlog("[RC_3WAY] 당일 매입 집계 오류"); FAIL(b); }
EXEC SQL SELECT count(*) INTO :h_mcnt FROM rc_match_log
WHERE biz_date = :h_bizdate AND status = 'MATCHED';
if (sqlca.sqlcode < 0) { userlog("[RC_3WAY] 대사 로그 집계 오류"); FAIL(b); }
EXEC SQL SELECT count(*) INTO :h_ecnt FROM rc_exception
WHERE biz_date = :h_bizdate AND resolved = false;
if (sqlca.sqlcode < 0) { userlog("[RC_3WAY] 예외 집계 오류"); FAIL(b); }
/* [2-3] 은행 실입금(st_funding_instr 합) — 은행 레그(근사) ---------- */
EXEC SQL SELECT coalesce(sum(amount),0), count(*)
INTO :h_bank, :h_bcnt
FROM st_funding_instr
WHERE biz_date = :h_bizdate AND status IN ('SENT','CONFIRMED');
if (sqlca.sqlcode < 0) { userlog("[RC_3WAY] 은행 입금 조회 오류 [%d]", sqlca.sqlcode); FAIL(b); }
/* [3] 거래집합 커서 순회 + 허용오차/매칭분류 --------------------- */
EXEC SQL DECLARE cur_rc_3way CURSOR FOR
SELECT purchase_id, net, amount, fee, status
FROM purchase WHERE biz_date = :h_bizdate ORDER BY purchase_id;
EXEC SQL OPEN cur_rc_3way;
for (;;) {
EXEC SQL FETCH cur_rc_3way INTO :h_pid, :h_net, :h_amt, :h_fee, :h_pstat;
if (sqlca.sqlcode == 100) break;
if (sqlca.sqlcode < 0) { EXEC SQL CLOSE cur_rc_3way; userlog("[RC_3WAY] 커서 FETCH 오류"); FAIL(b); }
EXEC SQL SELECT coalesce(sum(amount),0) INTO :h_act FROM ledger
WHERE purchase_id = :h_pid AND entry_type IN ('RECON','SETTLE');
if (sqlca.sqlcode < 0) { EXEC SQL CLOSE cur_rc_3way; FAIL(b); }
h_exp = h_net; adiff = (h_exp - h_act); if (adiff < 0) adiff = -adiff;
scan_rows++;
if (adiff <= (tol > 0 ? tol : 0)) matched_rows++;
else { unmatched_rows++; unmatched_amt += adiff; }
}
EXEC SQL CLOSE cur_rc_3way;
userlog("[RC_3WAY] 대사스캔 완료 scan=%ld match=%ld unmatch=%ld", scan_rows, matched_rows, unmatched_rows);
/* [3] 차이 산출부 (diff_ni = 망-내부, diff_nb = 망-은행) ----------- */
diff_ni = h_net_amt - h_internal;
diff_nb = h_net_amt - h_bank;
h_diff_ni = diff_ni;
h_diff_nb = diff_nb;
userlog("[RC_3WAY] 산출 net=%ld internal=%ld bank=%ld diff_ni=%ld diff_nb=%ld",
h_net_amt, h_internal, h_bank, h_diff_ni, h_diff_nb);
/* [4] 업무규칙 분기부 (상태/금액/한도) ----------------------------- */
if (h_gross <= 0 && scan_rows == 0) {
rc_code = 0; strcpy(h_status, "NODATA"); out_cnt = 0;
userlog("[RC_3WAY] 대상 없음 - 무처리 종료");
} else if (unmatched_rows == 0) {
rc_code = 0; strcpy(h_status, "MATCHED"); out_cnt = matched_rows;
} else if (unmatched_rows * 100 <= (scan_rows > 0 ? scan_rows : 1) * 5) {
rc_code = 1; strcpy(h_status, "TOLERATED"); out_cnt = unmatched_rows;
userlog("[RC_3WAY] 경미 불일치 허용범위 내 unmatch=%ld", unmatched_rows);
/* [4] 상태 판정부 (차이 0 -> MATCHED, 그 외 -> DIFF, 망無 -> PENDING) */
if (h_ncnt == 0) {
strcpy(h_status, "PENDING");
userlog("[RC_3WAY] 망 데이터 부재 -> PENDING");
} else if (h_diff_ni == 0 && h_diff_nb == 0) {
strcpy(h_status, "MATCHED");
} else {
rc_code = 2; strcpy(h_status, "EXCEPTION"); out_cnt = unmatched_rows;
userlog("[RC_3WAY] 대사 불일치 초과 unmatch=%ld amt=%ld", unmatched_rows, unmatched_amt);
strcpy(h_status, "DIFF");
userlog("[RC_3WAY] 3자 불일치 diff_ni=%ld diff_nb=%ld", h_diff_ni, h_diff_nb);
}
if (h_mdr > 0 && h_gross > 0) pctl = acq_fee(h_gross, h_mdr); /* 이론 수수료 */
h_exp = h_net; h_diff = h_exp - h_act;
/* [5] 본처리부 (핵심 적재/갱신) ----------------------------------- */
/* 대사 로그 적재 (rc_match_log) */
h_id = rcdb_insert_match(h_pid, "3WAY", h_net,
(unmatched_rows == 0 ? "MATCHED" : "EXCEPTION"), bizdate);
if (h_id < 0) { userlog("[RC_3WAY] 대사 로그 적재 실패 pid=%ld", h_pid); FAIL(b); }
out_cnt = matched_rows > 0 ? matched_rows : 1;
/* [5] 본처리부: rc_3way UPSERT (biz_date, member_bin) --------------- */
EXEC SQL INSERT INTO rc_3way
(recon_id, biz_date, member_bin, amt_network, amt_internal, amt_bank,
diff_ni, diff_nb, status)
VALUES (nextval('rc_3way_seq'), :h_bizdate, :h_bin, :h_net_amt, :h_internal,
:h_bank, :h_diff_ni, :h_diff_nb, :h_status)
ON CONFLICT (biz_date, member_bin) DO UPDATE SET
amt_network = EXCLUDED.amt_network,
amt_internal = EXCLUDED.amt_internal,
amt_bank = EXCLUDED.amt_bank,
diff_ni = EXCLUDED.diff_ni,
diff_nb = EXCLUDED.diff_nb,
status = EXCLUDED.status;
if (sqlca.sqlcode < 0) {
userlog("[RC_3WAY] rc_3way UPSERT 실패 [%d]", sqlca.sqlcode);
setl(b, T_RC, 8003);
Bchg(b, T_MSG, 0, "3자대사 결과 적재 실패", 0L);
FAIL(b);
}
/* [6] 이력/감사 적재부 (cm_log) ----------------------------------- */
EXEC SQL SELECT nextval('cm_log_seq') INTO :h_id2;
EXEC SQL SELECT nextval('cm_log_seq') INTO :h_logid;
if (sqlca.sqlcode < 0) { userlog("[RC_3WAY] 로그 시퀀스 실패"); FAIL(b); }
snprintf(sbuf, sizeof(sbuf), "RC_3WAY scan=%ld match=%ld unmatch=%ld gross=%ld rc=%ld",
scan_rows, matched_rows, unmatched_rows, h_gross, rc_code);
strncpy(h_reason, sbuf, sizeof(h_reason)-1); h_reason[sizeof(h_reason)-1] = 0;
strcpy(h_lvl, rc_code >= 2 ? "E" : (rc_code == 1 ? "W" : "I"));
snprintf(h_reason, sizeof(h_reason),
"RC_3WAY bin=%s net=%ld internal=%ld bank=%ld dni=%ld dnb=%ld st=%s",
h_bin, h_net_amt, h_internal, h_bank, h_diff_ni, h_diff_nb, h_status);
EXEC SQL INSERT INTO cm_log (log_id, svc_name, log_level, msg, biz_date)
VALUES (:h_id2, :h_svc, :h_lvl, :h_reason, :h_bizdate);
VALUES (:h_logid, :h_svc,
CASE WHEN :h_diff_ni = 0 AND :h_diff_nb = 0 THEN 'I' ELSE 'W' END,
:h_reason, :h_bizdate);
if (sqlca.sqlcode < 0) { userlog("[RC_3WAY] 감사 로그 적재 실패 [%d]", sqlca.sqlcode); FAIL(b); }
/* [7] 집계/요약 재집계부 ------------------------------------------ */
EXEC SQL SELECT count(*) INTO :h_ucnt FROM purchase p
WHERE p.biz_date = :h_bizdate
AND p.status IN ('A','H');
if (sqlca.sqlcode < 0) { userlog("[RC_3WAY] 미결 재집계 오류"); FAIL(b); }
EXEC SQL SELECT coalesce(sum(net),0) INTO :h_set FROM settlement WHERE biz_date = :h_bizdate;
if (sqlca.sqlcode < 0) { userlog("[RC_3WAY] 정산 재집계 오류"); FAIL(b); }
if (h_val == 0) h_val = h_set;
if (h_n1 == 0) h_n1 = matched_rows;
if (h_n2 == 0) h_n2 = unmatched_rows;
/* [7] 응답부 (출력 필드 설정) ------------------------------------- */
setl(b, T_AMT1, h_net_amt); /* 카드망 순액 */
setl(b, T_ARG1, h_diff_ni); /* 망-내부 차이 */
setl(b, T_AMT2, h_diff_nb); /* 망-은행 차이(참조) */
Bchg(b, T_STATUS, 0, h_status, 0L);
setl(b, T_RC, 0);
/* [7-1] 후속 업무 체인 (tpcall) — CHAIN-BEGIN -----------------------
* 하위 서비스는 별도 XA 브랜치라 이 브랜치의 미커밋 행이 보이지 않는다.
* 판단에 필요한 값은 전문(T_*)에 실어 전달하고, 응답 계약은 [8] 응답부가
* 뒤에서 재확정한다(하위 결과코드가 기존 계약을 덮지 않도록 복원). */
{
long ch_rlen = 0, ch_sub = 0, ch_keep = getl(b, T_RC);
long ch_pid = getl(b, T_PURCHASE_ID);
setl(b, T_AMOUNT, h_amt); setl(b, T_FEE, h_fee); setl(b, T_NET, h_net);
setl(b, T_GROSS, h_gross); setl(b, T_COUNT, scan_rows);
setl(b, T_ARG3, unmatched_rows); setl(b, T_AMT2, unmatched_amt);
setl(b, T_ARG4, rc_code);
Bchg(b, T_BIZDATE, 0, h_bizdate, 0L);
if (h_merch[0]) Bchg(b, T_MERCHANT, 0, h_merch, 0L);
Bchg(b, T_SVCNAME, 0, h_svc, 0L);
userlog("[RC_3WAY] 승인-매입 정합성 검증 연계 -> VL_APPR_ACQ pid=%ld date=[%s]", ch_pid, h_bizdate);
if (tpcall("VL_APPR_ACQ", (char *)b, 0L, (char **)&b, &ch_rlen, 0L) < 0) {
userlog("[RC_3WAY] tpcall(VL_APPR_ACQ) 실패: %s", tpstrerror(tperrno));
setl(b, T_RC, 8811); Bchg(b, T_MSG, 0, "승인-매입 정합성 검증 연계 실패", 0L);
FAIL(b);
}
ch_sub = getl(b, T_RC);
if (ch_sub != 0) userlog("[RC_3WAY] VL_APPR_ACQ 이상 회신 rc=%ld", ch_sub);
userlog("[RC_3WAY] 원장 3-way 대조 연계 -> LG_THREEWAY pid=%ld date=[%s]", ch_pid, h_bizdate);
if (tpcall("LG_THREEWAY", (char *)b, 0L, (char **)&b, &ch_rlen, 0L) < 0) {
userlog("[RC_3WAY] tpcall(LG_THREEWAY) 실패: %s", tpstrerror(tperrno));
setl(b, T_RC, 8812); Bchg(b, T_MSG, 0, "원장 3-way 대조 연계 실패", 0L);
FAIL(b);
}
ch_sub = getl(b, T_RC);
if (ch_sub != 0) userlog("[RC_3WAY] LG_THREEWAY 이상 회신 rc=%ld", ch_sub);
setl(b, T_RC, ch_keep); /* 기존 응답 계약 복원 — [8]에서 최종 확정 */
}
/* [8] 응답부 (출력 필드 설정) ------------------------------------- */
setl(b, T_RC, rc_code);
/* [9] 완료 로깅 --------------------------------------------------- */
userlog("[RC_3WAY] 대사 정상 종료 rc=%ld out=%ld status=%s", rc_code, out_cnt, h_status);
/* [8] 완료 로깅 --------------------------------------------------- */
userlog("[RC_3WAY] 3자 대사 종료 bin=[%s] status=%s diff_ni=%ld",
h_bin, h_status, h_diff_ni);
OK(b);
}