212: -- Statement level Logging
213: ----------------------------
214: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL)
215: THEN
216: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'CAC_TASK_PURGE_PVT.PURGE_STANDALONE_TASKS', 'Deleting data from staging table - JTF_TASK_PURGE');
217: END IF;
218:
219:
220: -- Cleanup process: Delete all the rows in the staging table corresponding
223:
224: -- Added INDEX hint by SBARAT on 19/01/2006 for bug# 4888496
225: -- Modified by SBARAT on 30/05/2006 for bug# 5213367
226:
227: Delete JTF_TASK_PURGE
228: Where concurrent_request_id In
229: (Select /*+ INDEX(p fnd_concurrent_programs_U1) */ r.request_id
230: From fnd_concurrent_requests r ,
231: fnd_concurrent_programs p
461:
462: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL)
463: THEN
464: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'CAC_TASK_PURGE_PVT.PURGE_STANDALONE_TASKS', 'No of fetched records = '||l_tab_task_id.count);
465: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'CAC_TASK_PURGE_PVT.PURGE_STANDALONE_TASKS', 'Inserting data into staging table - JTF_TASK_PURGE');
466: END IF;
467:
468: -- Inserting values into JTF_TASK_PURGE
469:
464: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'CAC_TASK_PURGE_PVT.PURGE_STANDALONE_TASKS', 'No of fetched records = '||l_tab_task_id.count);
465: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'CAC_TASK_PURGE_PVT.PURGE_STANDALONE_TASKS', 'Inserting data into staging table - JTF_TASK_PURGE');
466: END IF;
467:
468: -- Inserting values into JTF_TASK_PURGE
469:
470: FORALL i IN l_tab_task_id.FIRST..l_tab_task_id.LAST
471: Insert Into JTF_TASK_PURGE(object_type,
472: object_id,
467:
468: -- Inserting values into JTF_TASK_PURGE
469:
470: FORALL i IN l_tab_task_id.FIRST..l_tab_task_id.LAST
471: Insert Into JTF_TASK_PURGE(object_type,
472: object_id,
473: concurrent_request_id)
474: Values (l_tab_task_entity(i),
475: l_tab_task_id(i),
515: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL)
516: THEN
517: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'CAC_TASK_PURGE_PVT.PURGE_STANDALONE_TASKS', 'Final no of workers set = '||l_no_of_worker);
518: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'CAC_TASK_PURGE_PVT.PURGE_STANDALONE_TASKS', 'Batch size = '||l_batch_size);
519: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'CAC_TASK_PURGE_PVT.PURGE_STANDALONE_TASKS', 'Updating JTF_TASK_PURGE to set worker id');
520: END IF;
521:
522:
523: -- updating worker_id in JTF_TASK_PURGE table
519: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'CAC_TASK_PURGE_PVT.PURGE_STANDALONE_TASKS', 'Updating JTF_TASK_PURGE to set worker id');
520: END IF;
521:
522:
523: -- updating worker_id in JTF_TASK_PURGE table
524:
525: FOR i IN 1..l_no_of_worker LOOP
526: l_set_worker:=i;
527: Forall j In l_start..l_end
524:
525: FOR i IN 1..l_no_of_worker LOOP
526: l_set_worker:=i;
527: Forall j In l_start..l_end
528: Update JTF_TASK_PURGE Set worker_id=l_set_worker
529: Where concurrent_request_id=l_request_id
530: And object_id=l_tab_task_id(j);
531:
532: l_start:=l_start+l_batch_size;
730: RAISE fnd_api.g_exc_unexpected_error;
731: END IF;
732:
733: -- In case of 'NORMAL', setting OUT variable to successful,
734: -- committing the work and also truncating JTF_TASK_PURGE table
735:
736: IF l_main_conc_req_dev_status = 'NORMAL'
737: THEN
738: FND_MESSAGE.Set_Name('JTF', 'CAC_TASK_WORKER_RET_STAT_SUCC');
1170: l_msg_count NUMBER;
1171:
1172: Cursor C_Object_Id Is
1173: Select object_type, object_id
1174: From JTF_TASK_PURGE
1175: Where concurrent_request_id = p_concurrent_request_id
1176: And worker_id = p_worker_id
1177: And NVL(purge_status,'Y') <> 'E';
1178:
1233: -- Statement level Logging
1234: ----------------------------
1235: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL)
1236: THEN
1237: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'CAC_TASK_PURGE_PVT.POPULATE_PURGE_TMP', 'Fetching data from JTF_TASK_PURGE');
1238: END IF;
1239:
1240:
1241: Open C_Object_Id;
1247: -- Statement level Logging
1248: ----------------------------
1249: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL)
1250: THEN
1251: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'CAC_TASK_PURGE_PVT.POPULATE_PURGE_TMP', 'No of records fetched from JTF_TASK_PURGE');
1252: END IF;
1253:
1254:
1255: IF l_tab_task_id.COUNT > 0
1486: -- Statement level Logging
1487: ----------------------------
1488: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL)
1489: THEN
1490: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'CAC_TASK_PURGE_PVT.POPULATE_PURGE_TMP', 'Updating process_flag of JTF_TASK_PURGE');
1491: END IF;
1492:
1493:
1494: Forall j In l_tab_task_id.FIRST..l_tab_task_id.LAST
1491: END IF;
1492:
1493:
1494: Forall j In l_tab_task_id.FIRST..l_tab_task_id.LAST
1495: Update JTF_TASK_PURGE Set process_flag = 'Y'
1496: Where concurrent_request_id = p_concurrent_request_id
1497: And worker_id = p_worker_id
1498: And object_type = l_task_source_tab(j)
1499: And object_id = l_tab_task_id(j);
1504: -- Statement level Logging
1505: ----------------------------
1506: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL)
1507: THEN
1508: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'CAC_TASK_PURGE_PVT.POPULATE_PURGE_TMP', 'Updating purge_status of JTF_TASK_PURGE');
1509: END IF;
1510:
1511:
1512: Open C_Error_Tmp;
1515:
1516: IF l_tmp_object_id.COUNT > 0
1517: THEN
1518: Forall j In l_tmp_object_id.FIRST..l_tmp_object_id.LAST
1519: Update JTF_TASK_PURGE Set purge_status = l_tmp_purge_status(j),
1520: purge_error_message = l_tmp_purge_error_msg(j)
1521: Where object_id = l_tmp_object_id(j)
1522: And object_type = l_tmp_object_type(j)
1523: And concurrent_request_id = p_concurrent_request_id
1565:
1566: IF l_tab_task_id.COUNT > 0
1567: THEN
1568: Forall j In l_tab_task_id.FIRST..l_tab_task_id.LAST
1569: Update JTF_TASK_PURGE Set process_flag = 'Y' ,
1570: purge_status = 'E' ,
1571: purge_error_message = SUBSTRB(l_msg_data,1,4000)
1572: Where concurrent_request_id = p_concurrent_request_id
1573: And worker_id = p_worker_id
1601:
1602: IF l_tab_task_id.COUNT > 0
1603: THEN
1604: Forall j In l_tab_task_id.FIRST..l_tab_task_id.LAST
1605: Update JTF_TASK_PURGE Set process_flag = 'Y' ,
1606: purge_status = 'E' ,
1607: purge_error_message = SUBSTRB(l_msg_data,1,4000)
1608: Where concurrent_request_id = p_concurrent_request_id
1609: And worker_id = p_worker_id