/* @tier hard @module cl @transform closing-dbio */ /* * cl_io_0018.pgc - 마감 보조 DBIO (ECPG) [tier=hard] */ #include #include #include "txcore.h" #include "txcore_dbio.h" #include "cl_io_0018.h" EXEC SQL INCLUDE sqlca; int cl_io_0018_fetch(const char *key, long *out_amount) { EXEC SQL BEGIN DECLARE SECTION; char h_key[20]; long h_min; long h_max; short h_i1; short h_i2; EXEC SQL END DECLARE SECTION; if (!key || !out_amount) return TX_EINVAL; strncpy(h_key, key, sizeof(h_key) - 1); h_key[sizeof(h_key) - 1] = '\0'; EXEC SQL SELECT min(tax_amt), max(tax_amt) INTO :h_min:h_i1, :h_max:h_i2 FROM cls_summary WHERE acct_no = :h_key AND post_yn <> 'D'; if (sqlca.sqlcode == TX_SQL_NOTFOUND) return TX_ENOENT; if (sqlca.sqlcode != TX_SQL_OK) { TX_DBIO_LOG_ERR("cl_io_0018_fetch"); return TX_EDB; } if (h_i1 < 0 || h_i2 < 0) return TX_ENOENT; *out_amount = h_max - h_min; return TX_OK; } int cl_io_0018_touch(const char *key, long amount) { EXEC SQL BEGIN DECLARE SECTION; char h_key[20]; long h_amt; EXEC SQL END DECLARE SECTION; if (!key) return TX_EINVAL; strncpy(h_key, key, sizeof(h_key) - 1); h_key[sizeof(h_key) - 1] = '\0'; h_amt = amount; EXEC SQL INSERT INTO cls_daily_bal (acct_no, tax_amt, upd_ts) VALUES (:h_key, :h_amt, now()) ON CONFLICT (acct_no) DO UPDATE SET tax_amt = cls_daily_bal.tax_amt + EXCLUDED.tax_amt, upd_ts = now(); if (sqlca.sqlcode != TX_SQL_OK) { TX_DBIO_LOG_ERR("cl_io_0018_touch"); return TX_EDB; } if (sqlca.sqlerrd[2] == 0) return TX_ENOENT; return TX_OK; } long cl_io_0018_total(const char *biz_date) { EXEC SQL BEGIN DECLARE SECTION; char h_bd[9]; long h_sum; EXEC SQL END DECLARE SECTION; if (!biz_date) return -1; strncpy(h_bd, biz_date, sizeof(h_bd) - 1); h_bd[sizeof(h_bd) - 1] = '\0'; EXEC SQL SELECT coalesce(sum(d.tax_amt), 0) INTO :h_sum FROM cls_journal d JOIN cls_daily_bal m ON d.acct_no = m.acct_no WHERE d.post_dt = :h_bd AND m.post_yn = 'A'; if (sqlca.sqlcode != TX_SQL_OK) { TX_DBIO_LOG_ERR("cl_io_0018_total"); return -1; } return h_sum; }