[Home] [Help]
27: --| from the JMF_SHIKYU_ADJUSTMENTS table since |
28: --| it is redundant of the request_id column. |
29: --| All references to transaction_id have been |
30: --| replaced by request_id in this package. |
31: --| 03-OCT-2005 shu Added calls to JMF_SHIKYU_UTIL.debug_output. |
32: --| 05-OCT-2005 shu Added Open cursor statement before fetch. |
33: --| Replaced the condition cursor%FOUND with |
34: --| cursor%ROWCOUNT > 0. |
35: --| 06-OCT-2005 shu Added x_chr_errbuff,x_chr_retcode parameters |
136: l_cur_batch_max_adj_id NUMBER;
137: l_counter NUMBER;
138:
139: l_batch_id NUMBER;
140: l_workers jmf_shikyu_util.g_request_tbl_type;
141: l_adjust_rows NUMBER; -- the number of adjustments records with group_id = NVL(p_group_id,group_id)
142:
143: l_request_id NUMBER; --the request id for the worker
144: l_return_status VARCHAR2(1); --FND_API.G_RET_STS_SUCCESS or other status
204: ELSE
205: l_p_max_workers := p_max_workers;
206: END IF;
207: -- **** for debug information in readonly UT environment.--- begin ****
208: JMF_SHIKYU_UTIL.debug_output
209: (
210: p_output_to => 'FND_LOG.STRING'
211: ,p_api_name => G_MODULE_PREFIX || l_api_name
212: ,p_message => 'begin, l_p_batch_size:' || l_p_batch_size ||
300: -- Submit concurrent request for a Consumption Adjustments worker, which would
301: -- check if the count of workers has reached max_workers count; if it has, wait
302: -- until a worker finishes and then invoke the worker to process the batch
303:
304: jmf_shikyu_util.submit_worker(p_batch_id => l_batch_id
305: ,p_request_count => l_p_max_workers
306: ,p_cp_short_name => 'JMFSKADW'
307: ,p_cp_product_code => 'JMF'
308: ,x_workers => l_workers
317: (
318: p_output_to => 'FND_LOG.STRING'
319: ,p_api_name => G_MODULE_PREFIX || l_api_name
320: ,p_message => 'c_negative_adj%ROWCOUNT:' || c_negative_adj%ROWCOUNT ||
321: 'jmf_shikyu_util.submit_worker, l_return_status:' ||
322: l_return_status || ',l_request_id:' || l_request_id
323: );
324: -- **** for debug information in readonly UT environment.--- end ****
325:
368: END IF; -- IF c_negative_adj%ROWCOUNT > 0; end of c_negative_adj %FOUND
369: CLOSE c_negative_adj;
370:
371: --Wait for all the workers submitted for the negative adjustmemt data to complete;
372: jmf_shikyu_util.wait_for_all_workers(p_workers => l_workers);
373:
374: -- Process the positive adjustment data
375: OPEN c_positive_adj;
376: FETCH c_positive_adj BULK COLLECT
429: -- Submit concurrent request for a Consumption Adjustments worker, which would
430: -- check if the count of workers has reached max_workers count; if it has, wait
431: -- until a worker finishes and then invoke the worker to process the batch
432:
433: jmf_shikyu_util.submit_worker(p_batch_id => l_batch_id
434: ,p_request_count => l_p_max_workers
435: ,p_cp_short_name => 'JMFSKADW'
436: ,p_cp_product_code => 'JMF'
437: ,x_workers => l_workers
447: (
448: p_output_to => 'FND_LOG.STRING'
449: ,p_api_name => G_MODULE_PREFIX || l_api_name
450: ,p_message => 'c_positive_adj%ROWCOUNT:' || c_positive_adj%ROWCOUNT ||
451: 'jmf_shikyu_util.submit_worker, l_return_status:' ||
452: l_return_status || ',l_request_id:' || l_request_id
453: );
454: -- **** for debug information in readonly UT environment.--- end ****
455:
497: CLOSE c_positive_adj;
498:
499: --20051212 add wait the submit workers, and check the workers' status to set the return manager status.
500: --Wait for all the workers submitted for the positive adjustmemt data to complete;
501: jmf_shikyu_util.wait_for_all_workers(p_workers => l_workers);
502:
503: IF g_fnd_debug = 'Y' AND
504: FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL
505: THEN
639: -- PRE-COND :
640: -- EXCEPTIONS:
641: --========================================================================
642: PROCEDURE check_workers_status
643: (p_workers IN jmf_shikyu_util.g_request_tbl_type
644: ,x_return_status OUT NOCOPY VARCHAR2
645: )
646: IS
647: l_api_name CONSTANT VARCHAR2(30) := 'check_workers_status';