APPS.BIX_EMAILS_SUMMARY_PKG dependencies on BIX_WORKER_JOBS

Line 147: This procedure inserts rows into BIX_WORKER_JOBS depening on no of workers and number of days the program need

143:
144:
145: /*
146:
147: This procedure inserts rows into BIX_WORKER_JOBS depening on no of workers and number of days the program need
148: to collect data.
149:
150: */
151:

Line 170: Delete BIX_WORKER_JOBS WHERE OBJECT_NAME = 'BIX_EMAIL_DETAILS_F';

166: g_no_of_jobs := l_count;
167:
168: write_log('Number of workers that need to be instantiated : ' || to_char(l_count));
169:
170: Delete BIX_WORKER_JOBS WHERE OBJECT_NAME = 'BIX_EMAIL_DETAILS_F';
171:
172: IF (l_count > 0) THEN
173: l_start_date_range := g_collect_start_date;
174:

Line 189: INSERT INTO BIX_WORKER_JOBS(OBJECT_NAME

185: IF (l_end_date_range > g_collect_end_date) THEN
186: l_end_date_range := g_collect_end_date;
187: END IF;
188:
189: INSERT INTO BIX_WORKER_JOBS(OBJECT_NAME
190: , START_DATE_RANGE
191: , END_DATE_RANGE
192: , WORKER_NUMBER
193: , STATUS)

Line 5846: /* Get the status of all the jobs in BIX_WORKER_JOBS */

5842: l_count:= 0;
5843:
5844: LOOP
5845:
5846: /* Get the status of all the jobs in BIX_WORKER_JOBS */
5847: SELECT NVL(sum(decode(status,'UNASSIGNED', 1, 0)),0),
5848: NVL(sum(decode(status,'FAILED', 1, 0)),0),
5849: NVL(sum(decode(status,'IN PROCESS', 1, 0)),0),
5850: NVL(sum(decode(status,'COMPLETED',1 , 0)),0),

Line 5857: FROM BIX_WORKER_JOBS

5853: l_failed_cnt,
5854: l_wip_cnt,
5855: l_completed_cnt,
5856: l_total_cnt
5857: FROM BIX_WORKER_JOBS
5858: WHERE object_name = 'BIX_EMAIL_DETAILS_F';
5859:
5860: write_log('Job status - Unassigned: '||l_unassigned_cnt||
5861: ' In Process: '||l_wip_cnt||

Line 5878: UPDATE BIX_WORKER_JOBS

5874: EXIT;
5875: ELSIF (l_unassigned_cnt > 0) THEN
5876: /* Pickup any one unassigned job to process */
5877: write_log('Picking up an unassigned job');
5878: UPDATE BIX_WORKER_JOBS
5879: SET status = 'IN PROCESS',
5880: worker_number = p_worker_no
5881: WHERE status = 'UNASSIGNED'
5882: AND rownum < 2

Line 5905: FROM BIX_WORKER_JOBS

5901:
5902: /* Collect data for half hour time buckets for the date range of the job */
5903: SELECT start_date_range, end_date_range
5904: INTO l_start_date_range, l_end_date_range
5905: FROM BIX_WORKER_JOBS
5906: WHERE worker_number = p_worker_no
5907: AND status = 'IN PROCESS'
5908: AND object_name = 'BIX_EMAIL_DETAILS_F';
5909:

Line 5919: UPDATE BIX_WORKER_JOBS

5915: collect_emails;
5916: write_log('End procedure collect_emails');
5917:
5918: /* Update the status of job to 'COMPLETED' */
5919: UPDATE BIX_WORKER_JOBS
5920: SET status = 'COMPLETED'
5921: WHERE status = 'IN PROCESS'
5922: AND worker_number = p_worker_no
5923: AND object_name = 'BIX_EMAIL_DETAILS_F';

Line 5931: UPDATE BIX_WORKER_JOBS

5927: EXCEPTION
5928: WHEN OTHERS THEN
5929: retcode := -1;
5930:
5931: UPDATE BIX_WORKER_JOBS
5932: SET status = 'FAILED'
5933: WHERE worker_number = p_worker_no
5934: AND status = 'IN PROCESS'
5935: AND object_name = 'BIX_EMAIL_DETAILS_F';

Line 6051: FROM BIX_WORKER_JOBS

6047: l_completed_cnt,
6048: l_wip_cnt,
6049: l_failed_cnt,
6050: l_tot_cnt
6051: FROM BIX_WORKER_JOBS
6052: WHERE OBJECT_NAME = 'BIX_EMAIL_DETAILS_F';
6053:
6054: IF (l_failed_cnt > 0) THEN
6055: RAISE G_CHILD_PROCESS_ISSUE;