[Home] [Help]
343:
344: -- Get the last run for TRX_MSGS
345: CURSOR get_last_run_csr ( p_trx_id IN NUMBER) IS
346: SELECT NVL(MAX(TMG.tmg_run),0) last_run
347: FROM OKL_TRX_MSGS TMG
348: WHERE TMG.trx_id = p_trx_id;
349:
350: l_last_run NUMBER := 0;
351: l_module_name VARCHAR2(500) := G_MODULE_NAME || 'get_last_run';
409: -- Get the unfilled TMG_RUN rows for the trx_id
410: CURSOR get_empty_tmg_run_csr ( p_trx_id IN NUMBER) IS
411: SELECT TMG.id,
412: TMG.object_version_number
413: FROM OKL_TRX_MSGS TMG
414: WHERE TMG.trx_id = p_trx_id
415: AND TMG.tmg_run IS NULL;
416:
417: l_last_run NUMBER;
414: WHERE TMG.trx_id = p_trx_id
415: AND TMG.tmg_run IS NULL;
416:
417: l_last_run NUMBER;
418: lp_tmgv_tbl OKL_TRX_MSGS_PUB.tmgv_tbl_type;
419: lx_tmgv_tbl OKL_TRX_MSGS_PUB.tmgv_tbl_type;
420:
421: l_return_status VARCHAR2(1) := OKL_API.G_RET_STS_SUCCESS;
422:
415: AND TMG.tmg_run IS NULL;
416:
417: l_last_run NUMBER;
418: lp_tmgv_tbl OKL_TRX_MSGS_PUB.tmgv_tbl_type;
419: lx_tmgv_tbl OKL_TRX_MSGS_PUB.tmgv_tbl_type;
420:
421: l_return_status VARCHAR2(1) := OKL_API.G_RET_STS_SUCCESS;
422:
423: l_api_version CONSTANT NUMBER := 1;
459: i := i + 1;
460:
461: END LOOP;
462:
463: -- Update the TMG_RUN of OKL_TRX_MSGS with l_last_run+1 for the TRX_ID with null TMG_RUN
464: IF (lp_tmgv_tbl.COUNT > 0) THEN
465:
466: IF (is_debug_statement_on) THEN
467: OKL_DEBUG_PUB.LOG_DEBUG(G_LEVEL_STATEMENT,l_module_name,'calling OKL_TRX_MSGS_PUB.update_trx_msgs');
463: -- Update the TMG_RUN of OKL_TRX_MSGS with l_last_run+1 for the TRX_ID with null TMG_RUN
464: IF (lp_tmgv_tbl.COUNT > 0) THEN
465:
466: IF (is_debug_statement_on) THEN
467: OKL_DEBUG_PUB.LOG_DEBUG(G_LEVEL_STATEMENT,l_module_name,'calling OKL_TRX_MSGS_PUB.update_trx_msgs');
468: END IF;
469: OKL_TRX_MSGS_PUB.update_trx_msgs (
470: p_api_version => l_api_version,
471: p_init_msg_list => OKL_API.G_FALSE,
465:
466: IF (is_debug_statement_on) THEN
467: OKL_DEBUG_PUB.LOG_DEBUG(G_LEVEL_STATEMENT,l_module_name,'calling OKL_TRX_MSGS_PUB.update_trx_msgs');
468: END IF;
469: OKL_TRX_MSGS_PUB.update_trx_msgs (
470: p_api_version => l_api_version,
471: p_init_msg_list => OKL_API.G_FALSE,
472: x_return_status => l_return_status,
473: x_msg_count => l_msg_count,
474: x_msg_data => l_msg_data,
475: p_tmgv_tbl => lp_tmgv_tbl,
476: x_tmgv_tbl => lx_tmgv_tbl);
477: IF (is_debug_statement_on) THEN
478: OKL_DEBUG_PUB.LOG_DEBUG(G_LEVEL_STATEMENT,l_module_name,'called OKL_TRX_MSGS_PUB.update_trx_msgs , return status: ' || l_return_status);
479: END IF;
480:
481: IF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR) THEN
482: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;