443: , agr.customer_id customer_id
444: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id
445: FROM
446: pji_fm_proj_batch_map bat
447: , pa_draft_revenues_all drv
448: , pa_agreements_all agr
449: WHERE
450: l_extraction_type = 'FULL'
451: and bat.worker_id = p_worker_id
484: , agr.customer_id customer_id
485: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id
486: FROM
487: pji_fm_proj_batch_map bat
488: , pa_draft_revenues_all drv
489: , pa_agreements_all agr
490: WHERE
491: l_extraction_type = 'INCREMENTAL'
492: and bat.worker_id = p_worker_id
522: , agr.customer_id customer_id
523: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id
524: FROM
525: pji_fm_proj_batch_map bat
526: , pa_draft_revenues_all drv
527: , pa_agreements_all agr
528: WHERE
529: l_extraction_type = 'INCREMENTAL'
530: and bat.worker_id = p_worker_id
561: , agr.customer_id customer_id
562: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id
563: FROM
564: pji_fm_proj_batch_map bat
565: , pa_draft_revenues_all drv
566: , pa_agreements_all agr
567: WHERE
568: l_extraction_type = 'PARTIAL'
569: and bat.worker_id = p_worker_id
742: if (sql%rowcount <> 0) then
743:
744: commit;
745:
746: UPDATE pa_draft_revenues_all drv
747: SET drv.pji_summarized_flag = null
748: WHERE drv.rowid in (select /*+ cardinality(drvn, 1) */
749: drvn.row_id
750: from PJI_FM_EXTR_DREVN drvn