334: -- get an org_id from interface table
335: OPEN c_org;
336: FETCH c_org into l_org_id, l_org_code;
337: if c_org%NOTFOUND then
338: fnd_file.put_line(fnd_file.log, 'get_one_org_id: No entry is found in interface table');
339: return -1;
340: end if;
341: CLOSE c_org;
342:
351: exception
352: when others then
353: fnd_message.set_name('WSM','WSM_INVALID_FIELD');
354: fnd_message.set_token('FLD_NAME', 'Organization Code');
355: fnd_file.put_line(fnd_file.log, 'get_one_org_id: ' || fnd_message.get);
356: return -1;
357: end;
358: end if;
359:
373: exception
374: when others then
375: fnd_message.set_name('WSM','WSM_INVALID_FIELD');
376: fnd_message.set_token('FLD_NAME', 'Organization ID');
377: fnd_file.put_line(fnd_file.log, 'get_one_org_id: ' || fnd_message.get);
378: return -1;
379: end;
380:
381: return l_org_id;
407: END IF;
408:
409: if(l_profile = 2) then
410: g_create_job_copy := 'N';
411: fnd_file.put_line(fnd_file.log,
412: '++++++ Start calling WSMPLBJI.process_lbji_rows_1159 ++++++');
413: process_lbji_rows_1159 (retcode, errbuf, p_group_id);
414: fnd_file.put_line(fnd_file.log,
415: '++++++ End calling WSMPLBJI.process_lbji_rows_1159 ++++++');
410: g_create_job_copy := 'N';
411: fnd_file.put_line(fnd_file.log,
412: '++++++ Start calling WSMPLBJI.process_lbji_rows_1159 ++++++');
413: process_lbji_rows_1159 (retcode, errbuf, p_group_id);
414: fnd_file.put_line(fnd_file.log,
415: '++++++ End calling WSMPLBJI.process_lbji_rows_1159 ++++++');
416: else
417: g_create_job_copy := 'Y';
418: fnd_file.put_line(fnd_file.log,
414: fnd_file.put_line(fnd_file.log,
415: '++++++ End calling WSMPLBJI.process_lbji_rows_1159 ++++++');
416: else
417: g_create_job_copy := 'Y';
418: fnd_file.put_line(fnd_file.log,
419: '++++++ Start calling WSM_LBJ_INTERFACE_PVT.process_lbji_rows ++++++');
420: WSM_LBJ_INTERFACE_PVT.process_lbji_rows(retcode, errbuf, p_group_id);
421: fnd_file.put_line(fnd_file.log,
422: '++++++ End calling WSM_LBJ_INTERFACE_PVT.process_lbji_rows ++++++');
417: g_create_job_copy := 'Y';
418: fnd_file.put_line(fnd_file.log,
419: '++++++ Start calling WSM_LBJ_INTERFACE_PVT.process_lbji_rows ++++++');
420: WSM_LBJ_INTERFACE_PVT.process_lbji_rows(retcode, errbuf, p_group_id);
421: fnd_file.put_line(fnd_file.log,
422: '++++++ End calling WSM_LBJ_INTERFACE_PVT.process_lbji_rows ++++++');
423: end if;
424:
425: END process_interface_rows ;
456: END IF;
457:
458: if(l_profile = 2) then
459: g_create_job_copy := 'N';
460: fnd_file.put_line(fnd_file.log, '++++++ Calling WSMPLBJI.launch_worker_1159 ++++++');
461: WSMPLBJI.launch_worker_1159(retcode, errbuf, l_group_id, alotted_rows);
462: else
463: g_create_job_copy := 'Y';
464: fnd_file.put_line(fnd_file.log, '++++++ Calling WSM_LBJ_INTERFACE_PVT.launch_worker ++++++');
460: fnd_file.put_line(fnd_file.log, '++++++ Calling WSMPLBJI.launch_worker_1159 ++++++');
461: WSMPLBJI.launch_worker_1159(retcode, errbuf, l_group_id, alotted_rows);
462: else
463: g_create_job_copy := 'Y';
464: fnd_file.put_line(fnd_file.log, '++++++ Calling WSM_LBJ_INTERFACE_PVT.launch_worker ++++++');
465: WSM_LBJ_INTERFACE_PVT.launch_worker(retcode, errbuf, l_group_id, alotted_rows);
466: end if;
467:
468: END launch_worker;
838: where wo.wip_entity_id = p_wip_entity_id;
839:
840:
841: if (lbji_debug = 'Y') then
842: fnd_file.put_line(fnd_file.log,'update wo('||l_stmt_num||'): '|| SQL%ROWCOUNT);
843: end if;
844:
845: update WIP_OPERATIONS
846: --Bug 5207481:Actual quantity changes for bonus:costed_quantity_completed
852: where wip_entity_id = p_wip_entity_id
853: and operation_seq_num < abb_op_seq_num;
854:
855: if (lbji_debug = 'Y') then
856: fnd_file.put_line(fnd_file.log,'update quantity_cmplted in wo('||l_stmt_num||'): '|| SQL%ROWCOUNT);
857: end if;
858:
859: --Bug 5207481:Actual quantity changes for bonus-Start of changes
860: -- CJ: Start changes for Component Shrinkage project --
884: -- CJ: End changes for Component Shrinkage project --
885: --Bug 5207481:Actual quantity changes for bonus-End of changes
886:
887: if (lbji_debug = 'Y') then
888: fnd_file.put_line(fnd_file.log,'update quantity_issued in wro('||l_stmt_num||'): '|| SQL%ROWCOUNT);
889: end if;
890:
891: Exception
892:
1155: return;
1156: End;
1157:
1158: if lbji_debug = 'Y' then
1159: fnd_file.put_line(fnd_file.log, 'Inserted '||SQL%ROWCOUNT||' rows into wdj');
1160: end if;
1161:
1162: l_stmt_num := 130;
1163: begin
1207: return;
1208: end;
1209:
1210: if lbji_debug = 'Y' then
1211: fnd_file.put_line(fnd_file.log, 'Inserted '||SQL%ROWCOUNT||' rows into we');
1212: end if;
1213:
1214:
1215: l_stmt_num := 135;
1899: end if;
1900: --endfix 20026218
1901:
1902: if lbji_debug = 'Y' then
1903: fnd_file.put_line(fnd_file.log, 'Inserted '||SQL%ROWCOUNT||' rows into wo');
1904: end if;
1905:
1906: l_stat_num := 60;
1907: -- The below insert is used for Costing Changes (OP Yield)
1943: FROM WIP_OPERATION_YIELDS WOY
1944: WHERE WOY.WIP_ENTITY_ID = p_wip_entity_id);
1945:
1946: if lbji_debug = 'Y' then
1947: fnd_file.put_line(fnd_file.log, 'Inserted '||SQL%ROWCOUNT||' rows into woy');
1948: end if;
1949:
1950:
1951: l_stat_num := 80;
2010: from Wip_operation_resources WOR
2011: where WOR.wip_entity_id = p_wip_entity_id);
2012:
2013: if lbji_debug = 'Y' then
2014: fnd_file.put_line(fnd_file.log, 'Inserted '||SQL%ROWCOUNT||' rows into wor');
2015: end if;
2016:
2017: l_stat_num := 90;
2018: if p_job_seq_num = l_op_seq_incr then -- if this is the first operation
2050: if l_error_code <> 0 then
2051: p_error_msg := l_error_msg;
2052: p_error_code := -1;
2053: if (lbji_debug = 'Y') then
2054: fnd_file.put_line(fnd_file.log,p_error_msg);
2055: end if;
2056: return;
2057: end if;
2058:
2056: return;
2057: end if;
2058:
2059: if lbji_debug = 'Y' then
2060: fnd_file.put_line(fnd_file.log, 'Inserted rows into wro');
2061: end if;
2062:
2063: EXCEPTION
2064: WHEN NO_DATA_FOUND THEN
2064: WHEN NO_DATA_FOUND THEN
2065: p_error_msg := 'WSMPLBJI.insert_procedure('||l_stat_num||'): No Data Found';
2066: p_error_code := -1;
2067: if (lbji_debug = 'Y') then
2068: fnd_file.put_line(fnd_file.log,p_error_msg);
2069: end if;
2070:
2071: WHEN e_proc_error THEN
2072: p_error_msg := 'WSMPLBJI.insert_procedure('||l_stat_num||'): '||p_error_msg;
2071: WHEN e_proc_error THEN
2072: p_error_msg := 'WSMPLBJI.insert_procedure('||l_stat_num||'): '||p_error_msg;
2073: p_error_code := -1;
2074: if (lbji_debug = 'Y') then
2075: fnd_file.put_line(fnd_file.log,p_error_msg);
2076: end if;
2077:
2078: WHEN no_dept_error THEN
2079: fnd_message.set_name('WSM', 'WSM_NO_SCRAP_ACC');
2084: when others then
2085: p_error_code := SQLCODE;
2086: p_error_msg := 'WSMPLBJI.insert_procedure('||l_stat_num||')'|| substr(SQLERRM,1,200);
2087: if (lbji_debug = 'Y') then
2088: fnd_file.put_line(fnd_file.log,p_error_msg);
2089: end if;
2090:
2091: END insert_procedure;
2092:
2383: -- ED: bugfix 3299811
2384:
2385:
2386: if lbji_debug = 'Y' then
2387: fnd_file.put_line(fnd_file.log, 'Inserted '|| l_cnt ||' rows into wip_period_balances');
2388: end if;
2389:
2390: --if SQL%NOTFOUND then -- bug 3571360
2391: if l_cnt <= 0 then -- bug 3571360
2432: fnd_message.set_name('WSM','WSM_INVALID_FIELD');
2433: fnd_message.set_token('FLD_NAME', p_fld);
2434: x_err_msg := fnd_message.get;
2435: v_wlji_err_msg(v_index) := x_err_msg;
2436: fnd_file.put_line(fnd_file.log, 'stmt_num: '|| stmt_number||' '||x_err_msg||' '||aux_string);
2437: fnd_file.new_line(fnd_file.log, 3);
2438:
2439:
2440: END process_invalid_field;
2433: fnd_message.set_token('FLD_NAME', p_fld);
2434: x_err_msg := fnd_message.get;
2435: v_wlji_err_msg(v_index) := x_err_msg;
2436: fnd_file.put_line(fnd_file.log, 'stmt_num: '|| stmt_number||' '||x_err_msg||' '||aux_string);
2437: fnd_file.new_line(fnd_file.log, 3);
2438:
2439:
2440: END process_invalid_field;
2441:
2465: v_wlji_err_code(v_index) := -1;
2466: fnd_message.set_name(p_product, p_message_name);
2467: x_err_msg := fnd_message.get;
2468: v_wlji_err_msg(v_index) := x_err_msg;
2469: fnd_file.put_line(fnd_file.log, 'stmt_num: '|| stmt_number||' '||x_err_msg);
2470: fnd_file.new_line(fnd_file.log, 3);
2471:
2472:
2473: END process_errorred_field;
2466: fnd_message.set_name(p_product, p_message_name);
2467: x_err_msg := fnd_message.get;
2468: v_wlji_err_msg(v_index) := x_err_msg;
2469: fnd_file.put_line(fnd_file.log, 'stmt_num: '|| stmt_number||' '||x_err_msg);
2470: fnd_file.new_line(fnd_file.log, 3);
2471:
2472:
2473: END process_errorred_field;
2474:
2488: BEGIN
2489: v_wlji_process_status(v_index) := 3; --ERROR
2490: v_wlji_err_code(v_index) := p_err_code;
2491: v_wlji_err_msg(v_index) := substr(p_err_msg,1,2000);
2492: fnd_file.put_line(fnd_file.log, 'stmt_num: ' || stmt_number||' '||p_err_msg);
2493: fnd_file.new_line(fnd_file.log, 3);
2494:
2495: END handle_error;
2496:
2489: v_wlji_process_status(v_index) := 3; --ERROR
2490: v_wlji_err_code(v_index) := p_err_code;
2491: v_wlji_err_msg(v_index) := substr(p_err_msg,1,2000);
2492: fnd_file.put_line(fnd_file.log, 'stmt_num: ' || stmt_number||' '||p_err_msg);
2493: fnd_file.new_line(fnd_file.log, 3);
2494:
2495: END handle_error;
2496:
2497:
2512: dummy_err_code number;
2513: dummy_err_msg varchar2(2000);
2514:
2515: BEGIN
2516: fnd_file.new_line(fnd_file.log, 1);
2517: fnd_file.put_line(fnd_file.log, '*** WARNING MESSAGE BEGIN ***');
2518: fnd_file.put_line(fnd_file.log, p_err_msg);
2519: fnd_file.put_line(fnd_file.log, '*** WARNING MESSAGE END ***');
2520: fnd_file.new_line(fnd_file.log, 1);
2513: dummy_err_msg varchar2(2000);
2514:
2515: BEGIN
2516: fnd_file.new_line(fnd_file.log, 1);
2517: fnd_file.put_line(fnd_file.log, '*** WARNING MESSAGE BEGIN ***');
2518: fnd_file.put_line(fnd_file.log, p_err_msg);
2519: fnd_file.put_line(fnd_file.log, '*** WARNING MESSAGE END ***');
2520: fnd_file.new_line(fnd_file.log, 1);
2521: wsmputil.WRITE_TO_WIE (
2514:
2515: BEGIN
2516: fnd_file.new_line(fnd_file.log, 1);
2517: fnd_file.put_line(fnd_file.log, '*** WARNING MESSAGE BEGIN ***');
2518: fnd_file.put_line(fnd_file.log, p_err_msg);
2519: fnd_file.put_line(fnd_file.log, '*** WARNING MESSAGE END ***');
2520: fnd_file.new_line(fnd_file.log, 1);
2521: wsmputil.WRITE_TO_WIE (
2522: p_header_id,
2515: BEGIN
2516: fnd_file.new_line(fnd_file.log, 1);
2517: fnd_file.put_line(fnd_file.log, '*** WARNING MESSAGE BEGIN ***');
2518: fnd_file.put_line(fnd_file.log, p_err_msg);
2519: fnd_file.put_line(fnd_file.log, '*** WARNING MESSAGE END ***');
2520: fnd_file.new_line(fnd_file.log, 1);
2521: wsmputil.WRITE_TO_WIE (
2522: p_header_id,
2523: substr(p_err_msg,1,2000),
2516: fnd_file.new_line(fnd_file.log, 1);
2517: fnd_file.put_line(fnd_file.log, '*** WARNING MESSAGE BEGIN ***');
2518: fnd_file.put_line(fnd_file.log, p_err_msg);
2519: fnd_file.put_line(fnd_file.log, '*** WARNING MESSAGE END ***');
2520: fnd_file.new_line(fnd_file.log, 1);
2521: wsmputil.WRITE_TO_WIE (
2522: p_header_id,
2523: substr(p_err_msg,1,2000),
2524: p_request_id,
2635: l_resp_appl_id NUMBER;
2636:
2637: BEGIN
2638:
2639: fnd_file.put_line(fnd_file.log, 'Processing Interface rows..');
2640:
2641: retcode := 0; -- bugfix 2845397: set the code to 0 (success)
2642:
2643: l_user_id := fnd_global.USER_ID;
2665: if no_rows_per_worker < batch_size then
2666: no_rows_per_worker := batch_size;
2667: end if;
2668:
2669: fnd_file.put_line(fnd_file.log, 'Total Pending Rows = '||total_no_rows);
2670: fnd_file.put_line(fnd_file.log, 'Number of Workers = '||no_of_workers);
2671: fnd_file.put_line(fnd_file.log, 'Batch Size = '||batch_size);
2672: fnd_file.put_line(fnd_file.log, 'Number of Rows per worker = '||no_rows_per_worker);
2673:
2666: no_rows_per_worker := batch_size;
2667: end if;
2668:
2669: fnd_file.put_line(fnd_file.log, 'Total Pending Rows = '||total_no_rows);
2670: fnd_file.put_line(fnd_file.log, 'Number of Workers = '||no_of_workers);
2671: fnd_file.put_line(fnd_file.log, 'Batch Size = '||batch_size);
2672: fnd_file.put_line(fnd_file.log, 'Number of Rows per worker = '||no_rows_per_worker);
2673:
2674: select wsm_lot_job_interface_s.NEXTVAL
2667: end if;
2668:
2669: fnd_file.put_line(fnd_file.log, 'Total Pending Rows = '||total_no_rows);
2670: fnd_file.put_line(fnd_file.log, 'Number of Workers = '||no_of_workers);
2671: fnd_file.put_line(fnd_file.log, 'Batch Size = '||batch_size);
2672: fnd_file.put_line(fnd_file.log, 'Number of Rows per worker = '||no_rows_per_worker);
2673:
2674: select wsm_lot_job_interface_s.NEXTVAL
2675: into l_group_id
2668:
2669: fnd_file.put_line(fnd_file.log, 'Total Pending Rows = '||total_no_rows);
2670: fnd_file.put_line(fnd_file.log, 'Number of Workers = '||no_of_workers);
2671: fnd_file.put_line(fnd_file.log, 'Batch Size = '||batch_size);
2672: fnd_file.put_line(fnd_file.log, 'Number of Rows per worker = '||no_rows_per_worker);
2673:
2674: select wsm_lot_job_interface_s.NEXTVAL
2675: into l_group_id
2676: from dual;
2705: else
2706: commit;
2707: end if;
2708:
2709: fnd_file.put_line(fnd_file.log, 'Request_id: '||l_reqid||' submitted');
2710:
2711: if c_pir%notfound then exit; end if;
2712:
2713: if not c_pir%notfound then
2752: else
2753: commit;
2754: end if;
2755:
2756: fnd_file.put_line(fnd_file.log, 'Request_id: '||l_reqid||' submitted');
2757:
2758: else -- total_no_rows <= 0
2759: fnd_file.put_line(fnd_file.log, 'No Rows found in interface table');
2760: end if;
2755:
2756: fnd_file.put_line(fnd_file.log, 'Request_id: '||l_reqid||' submitted');
2757:
2758: else -- total_no_rows <= 0
2759: fnd_file.put_line(fnd_file.log, 'No Rows found in interface table');
2760: end if;
2761:
2762: end if; -- group_id
2763:
2766:
2767: when others then
2768: retcode := 1;
2769: errbuf := 'WSMLBJIB.process_lbji_rows_1159: stmt num= '||l_stmt_num||' '||SUBSTR(SQLERRM, 1,240);
2770: fnd_file.put_line(fnd_file.log,errbuf);
2771: conc_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',errbuf);
2772:
2773: END process_lbji_rows_1159 ;
2774:
3101: l_stmt_num := 3;
3102: WSMPLCVA.load_class_code;
3103:
3104: if lbji_debug = 'Y' then
3105: fnd_file.put_line(fnd_file.log, 'loading org/subinv/class-code values into memory (once per worker).. Success.');
3106: end if;
3107:
3108: exception
3109: when others then
3228: v_wlji_date_released --bugfix 2697295
3229: limit batch_size;
3230:
3231: if lbji_debug = 'Y' then
3232: fnd_file.put_line(fnd_file.log, 'no of rows loaded for the current batch: '||c_wlji_1%rowcount);
3233: end if;
3234:
3235: if c_wlji_1%rowcount - prev_rowcount <> 0 then
3236:
3257: update wsm_lot_job_interface
3258: set group_id = batch_group_id
3259: where header_id = v_wlji_header_id(indx);
3260:
3261: fnd_file.put_line(fnd_file.output, ' ---- Lot Based Job Creation ---- ');
3262: fnd_file.put_line(fnd_file.output, ' ');
3263: fnd_file.put_line(fnd_file.output, ' ');
3264:
3265: -- ==============================================================================================
3258: set group_id = batch_group_id
3259: where header_id = v_wlji_header_id(indx);
3260:
3261: fnd_file.put_line(fnd_file.output, ' ---- Lot Based Job Creation ---- ');
3262: fnd_file.put_line(fnd_file.output, ' ');
3263: fnd_file.put_line(fnd_file.output, ' ');
3264:
3265: -- ==============================================================================================
3266: -- processing of data begins here
3259: where header_id = v_wlji_header_id(indx);
3260:
3261: fnd_file.put_line(fnd_file.output, ' ---- Lot Based Job Creation ---- ');
3262: fnd_file.put_line(fnd_file.output, ' ');
3263: fnd_file.put_line(fnd_file.output, ' ');
3264:
3265: -- ==============================================================================================
3266: -- processing of data begins here
3267: -- ==============================================================================================
3271: while v_index <= v_wlji_header_id.last
3272: loop -- inner loop
3273:
3274: if lbji_debug = 'Y' then
3275: fnd_file.put_line(fnd_file.log,'***************************************************************');
3276: fnd_file.put_line(fnd_file.log,'new job ... wlji header_id: '||v_wlji_header_id(v_index));
3277: fnd_file.put_line(fnd_file.log,' ... job name: '||v_wlji_job_name(v_index));
3278: fnd_file.put_line(fnd_file.log,'***************************************************************');
3279: end if;
3272: loop -- inner loop
3273:
3274: if lbji_debug = 'Y' then
3275: fnd_file.put_line(fnd_file.log,'***************************************************************');
3276: fnd_file.put_line(fnd_file.log,'new job ... wlji header_id: '||v_wlji_header_id(v_index));
3277: fnd_file.put_line(fnd_file.log,' ... job name: '||v_wlji_job_name(v_index));
3278: fnd_file.put_line(fnd_file.log,'***************************************************************');
3279: end if;
3280:
3273:
3274: if lbji_debug = 'Y' then
3275: fnd_file.put_line(fnd_file.log,'***************************************************************');
3276: fnd_file.put_line(fnd_file.log,'new job ... wlji header_id: '||v_wlji_header_id(v_index));
3277: fnd_file.put_line(fnd_file.log,' ... job name: '||v_wlji_job_name(v_index));
3278: fnd_file.put_line(fnd_file.log,'***************************************************************');
3279: end if;
3280:
3281: SAVEPOINT row_skip;
3274: if lbji_debug = 'Y' then
3275: fnd_file.put_line(fnd_file.log,'***************************************************************');
3276: fnd_file.put_line(fnd_file.log,'new job ... wlji header_id: '||v_wlji_header_id(v_index));
3277: fnd_file.put_line(fnd_file.log,' ... job name: '||v_wlji_job_name(v_index));
3278: fnd_file.put_line(fnd_file.log,'***************************************************************');
3279: end if;
3280:
3281: SAVEPOINT row_skip;
3282:
3423: if v_wlji_load_type(v_index) = 5 and v_wlji_mode_flag(v_index) = 2
3424: and v_load_wsli = true then
3425:
3426: if (lbji_debug = 'Y') then
3427: fnd_file.put_line(fnd_file.log,'loading wsli for batch group id: '||batch_group_id||'..');
3428: end if;
3429:
3430: load_wsli_data(batch_group_id);
3431: v_load_wsli := false;
3504: end if;
3505: xst := true;
3506:
3507: if lbji_debug = 'Y' then
3508: fnd_file.put_line(fnd_file.log, 'Org Id Validation..Success.');
3509: end if;
3510: -- *** validate org id end ***
3511:
3512:
3542: end if;
3543: l_no_of_records := 0;
3544:
3545: if lbji_debug = 'Y' then
3546: fnd_file.put_line(fnd_file.log, 'Checking existance of inv lots of the same name.. Success');
3547: end if;
3548:
3549: end if; -- load type 5
3550:
3586: GOTO skip_validate_constants;
3587: elsif v_wlji_job_type(v_index) = 3 then
3588: if v_wlji_mode_flag(v_index) <> 1 then
3589: if lbji_debug = 'Y' then
3590: fnd_file.put_line(fnd_file.log, 'Ignoring mode_flag, has to be 1 for non-standard jobs.');
3591: end if;
3592: end if;
3593: if v_wlji_mode_flag(v_index) is null then
3594: v_wlji_mode_flag(v_index) := 1;
3652: end if;
3653: l_aux_mesg := '';
3654:
3655: if lbji_debug = 'Y' then
3656: fnd_file.put_line(fnd_file.log, 'Validating Constants.. Success.');
3657: end if;
3658:
3659: -- *** validate constants end ***
3660:
3717: l_error_code := -1;
3718: end if;
3719:
3720: if l_error_code = 0 and l_err_msg is not null then
3721: fnd_file.new_line(fnd_file.log, 2);
3722: fnd_file.put_line(fnd_file.log,l_err_msg);
3723: fnd_file.new_line(fnd_file.log, 2);
3724: l_err_msg := '';
3725: end if;
3718: end if;
3719:
3720: if l_error_code = 0 and l_err_msg is not null then
3721: fnd_file.new_line(fnd_file.log, 2);
3722: fnd_file.put_line(fnd_file.log,l_err_msg);
3723: fnd_file.new_line(fnd_file.log, 2);
3724: l_err_msg := '';
3725: end if;
3726: end if; -- non-standard validations end
3719:
3720: if l_error_code = 0 and l_err_msg is not null then
3721: fnd_file.new_line(fnd_file.log, 2);
3722: fnd_file.put_line(fnd_file.log,l_err_msg);
3723: fnd_file.new_line(fnd_file.log, 2);
3724: l_err_msg := '';
3725: end if;
3726: end if; -- non-standard validations end
3727:
3765: end if;
3766: l_aux_mesg := '';
3767:
3768: if lbji_debug = 'Y' and v_wlji_mode_flag(v_index) = 1 then
3769: fnd_file.put_line(fnd_file.log, 'Assembly Quantity OK');
3770: end if;
3771: end if; -- job_type
3772: -- *** validate assembly quantity end ***
3773:
3850: str := '';
3851: hash_value := 0;
3852:
3853: if lbji_debug = 'Y' then
3854: fnd_file.put_line(fnd_file.log, 'Validation of Item.. Success');
3855: end if;
3856:
3857: end if; -- load type 5
3858: -- *** validate mode one item id end ***
3893: l_err_msg,
3894: v_wlji_start_quantity(v_index)); --Fixed bug # 2313574
3895:
3896: if lbji_debug = 'Y' then
3897: fnd_file.put_line(fnd_file.log, 'Getting complete date based on item lead time');
3898: end if;
3899:
3900: END IF ;
3901:
3912: l_err_msg,
3913: v_wlji_start_quantity(v_index)); --Fixed bug # 2313574
3914:
3915: if lbji_debug = 'Y' then
3916: fnd_file.put_line(fnd_file.log, 'Getting start date based on item lead time');
3917: end if;
3918: END IF;
3919:
3920: if l_error_code <> 0 OR l_err_msg IS NOT NULL then
3930: end if;
3931: l_err_msg := '';
3932:
3933: if lbji_debug = 'Y' then
3934: fnd_file.put_line(fnd_file.log, 'Date Validation.. Success.');
3935: end if;
3936:
3937: end if; -- load type 5
3938: -- *** validate dates end ***
3967: end if;
3968: l_aux_mesg := '';
3969:
3970: if lbji_debug = 'Y' then
3971: fnd_file.put_line(fnd_file.log, 'Net Quantity Validation.. Success.');
3972: end if;
3973:
3974: end if; -- load type 5
3975: -- *** validate net quantity end ***
3992: GOTO skip_other_steps;
3993: end if;
3994:
3995: if lbji_debug = 'Y' then
3996: fnd_file.put_line(fnd_file.log, 'Co Product Supply Flag Validation.. Success.');
3997: end if;
3998:
3999: end if; -- load type 5
4000: -- *** validate coproduct-supply flag end ***
4044: GOTO skip_other_steps;
4045: end if;
4046:
4047: if lbji_debug = 'Y' then
4048: fnd_file.put_line(fnd_file.log, 'Getting Routing Sequence Id: '||routing_seq_id);
4049: end if;
4050:
4051: IF v_wlji_completion_subinventory(v_index) IS NULL AND
4052: v_wlji_completion_locator_id(v_index) IS NULL THEN
4172: end if;
4173: l_aux_mesg := '';
4174:
4175: if lbji_debug = 'Y' then
4176: fnd_file.put_line(fnd_file.log, 'Getting Bill Sequence Id: '||bom_seq_id);
4177: end if;
4178:
4179: end if; -- load type 5
4180: -- *** get bill_seq_id end ***
4229: l_aux_mesg := '';
4230: l_locator_id := 0;
4231:
4232: if lbji_debug = 'Y' then
4233: fnd_file.put_line(fnd_file.log, 'Locator Id Validation.. Success.');
4234: end if;
4235:
4236: end if; -- load type 5
4237: -- *** validate locator id end ***
4277: xst := true;
4278: end if;
4279:
4280: if lbji_debug = 'Y' then
4281: fnd_file.put_line(fnd_file.log, 'Last Updt By Validation.. Success.');
4282: end if;
4283:
4284: end if; -- load type 5
4285: -- *** validate last_updt_by end ***
4322: xst := true;
4323: end if;
4324:
4325: if lbji_debug = 'Y' then
4326: fnd_file.put_line(fnd_file.log, 'Created By Validation.. Success.');
4327: end if;
4328:
4329: end if; -- load type 5
4330: -- *** validate created_by end ***
4517: end if;
4518: l_aux_mesg := '';
4519:
4520: if lbji_debug = 'Y' then
4521: fnd_file.put_line(fnd_file.log, 'Job Name and Id Validation.. Success.');
4522: end if;
4523:
4524: l_dummy := 0;
4525: -- *** validate job name and id end ***
4599: str := '';
4600: hash_value := 0;
4601:
4602: if lbji_debug = 'Y' then
4603: fnd_file.put_line(fnd_file.log, 'Class Code Validation.. Success.');
4604: end if;
4605:
4606: end if; -- load type 5
4607: -- *** validate class code end ***
4612: if v_wlji_load_type(v_index) = 5 then
4613: v_wlji_lot_number(v_index) := v_wlji_job_name(v_index);
4614:
4615: if lbji_debug = 'Y' then
4616: fnd_file.put_line(fnd_file.log, 'Lot Number Defaulted.. Success.');
4617: end if;
4618: end if; -- load type 5
4619: -- *** default lot_number end ***
4620:
4653: GOTO skip_other_steps;
4654: end if;
4655:
4656: if lbji_debug = 'Y' then
4657: fnd_file.put_line(fnd_file.log, 'Getting Revisions.. Success.');
4658: end if;
4659:
4660: end if; -- load type 5
4661: -- *** get revisions end ***
4674: v_wlji_description(v_index) := RTRIM(v_wlji_description(v_index));
4675: end if;
4676:
4677: if lbji_debug = 'Y' then
4678: fnd_file.put_line(fnd_file.log, 'Default Description.. Success.');
4679: end if;
4680: end if; -- load type 5
4681: -- *** default description end ***
4682:
4951: l_dummy := 0;
4952: l_err_msg := '';
4953:
4954: if lbji_debug = 'Y' then
4955: fnd_file.put_line(fnd_file.log, 'Verify that the component is reqd. at the first operation of the assembly.. Success');
4956: end if;
4957:
4958: l_stmt_num := 640;
4959: -- abbKanban begin
5129: GOTO skip_other_steps;
5130: end if;
5131:
5132: if lbji_debug = 'Y' then
5133: fnd_file.put_line(fnd_file.log, 'Mode 2 Quantity Verification.. Success');
5134: end if;
5135: -- *** end validate quantity ***
5136:
5137:
5210: l_dummy := 0;
5211: l_err_msg := '';
5212:
5213: if lbji_debug = 'Y' then
5214: fnd_file.put_line(fnd_file.log, 'Verify that the starting lot is not phantom.. Success');
5215: end if;
5216: -- *** validate starting lot is not phantom end ***
5217:
5218: end if; -- mode flag 2
5257:
5258: v_wlji_date_released(v_index) := null;
5259:
5260: if lbji_debug = 'Y' then
5261: fnd_file.put_line(fnd_file.log, 'value for column DATE_RELEASED is being ignored for unreleased job');
5262: end if;
5263: elsif (v_wlji_status_type(v_index) = WIP_CONSTANTS.RELEASED ) then
5264: if (v_wlji_date_released(v_index) > sysdate ) then
5265:
5282:
5283: l_err_msg := '';
5284:
5285: if lbji_debug = 'Y' then
5286: fnd_file.put_line(fnd_file.log, 'Date_Released Validation.. First Phase Done.');
5287: end if;
5288:
5289: end if; -- load type 5
5290: -- bugfix 2697295 ends
5365: end if;
5366: l_dummy := 0;
5367:
5368: if lbji_debug = 'Y' then
5369: fnd_file.put_line(fnd_file.log, 'Schedule Group Id Verification.. Success');
5370: end if;
5371: -- *** validate schedule_group_id end ***
5372:
5373:
5416: GOTO skip_other_steps;
5417: end if;
5418:
5419: if lbji_debug = 'Y' then
5420: fnd_file.put_line(fnd_file.log, 'Build Seq. Id Verification.. Success');
5421: end if;
5422:
5423: end if; -- job type <> 3 for schedule group and build sequence.
5424: -- *** validate build_seq_id end ***
5510: v_wlji_bom_revision(v_index) := null;
5511: v_wlji_alt_bom_designator(v_index) := null;
5512: v_wlji_alt_routing_designator(v_index) := null;
5513:
5514: fnd_file.put_line(fnd_file.log, 'Ignoring any of the following fields if provided by the user for this standard job:');
5515: -- fnd_file.new_line(fnd_file.log, 1);
5516: fnd_file.put_line(fnd_file.log, 'ROUTING_REFERENCE_ID, BOM_REFERENCE_ID, ROUTING_REVISION_DATE, ROUTING_REVISION, BOM_REVISION_DATE, BOM_REVISION, ALTERNATE_BOM_DESIGNATOR, ALTERNATE_ROUTING_DESIGNATOR');
5517: end if;
5518:
5511: v_wlji_alt_bom_designator(v_index) := null;
5512: v_wlji_alt_routing_designator(v_index) := null;
5513:
5514: fnd_file.put_line(fnd_file.log, 'Ignoring any of the following fields if provided by the user for this standard job:');
5515: -- fnd_file.new_line(fnd_file.log, 1);
5516: fnd_file.put_line(fnd_file.log, 'ROUTING_REFERENCE_ID, BOM_REFERENCE_ID, ROUTING_REVISION_DATE, ROUTING_REVISION, BOM_REVISION_DATE, BOM_REVISION, ALTERNATE_BOM_DESIGNATOR, ALTERNATE_ROUTING_DESIGNATOR');
5517: end if;
5518:
5519: end if; -- job type 1
5512: v_wlji_alt_routing_designator(v_index) := null;
5513:
5514: fnd_file.put_line(fnd_file.log, 'Ignoring any of the following fields if provided by the user for this standard job:');
5515: -- fnd_file.new_line(fnd_file.log, 1);
5516: fnd_file.put_line(fnd_file.log, 'ROUTING_REFERENCE_ID, BOM_REFERENCE_ID, ROUTING_REVISION_DATE, ROUTING_REVISION, BOM_REVISION_DATE, BOM_REVISION, ALTERNATE_BOM_DESIGNATOR, ALTERNATE_ROUTING_DESIGNATOR');
5517: end if;
5518:
5519: end if; -- job type 1
5520: */ -- Bug 2762029 commenting ends
5893: GOTO skip_resched_validations;
5894: end if;
5895:
5896: elsif p_old_status_type <> 1 then
5897: fnd_file.put_line(fnd_file.log, 'Ignoring any of the following fields if provided by the user for this standard job:');
5898: fnd_file.put_line(fnd_file.log, 'ROUTING_REVISION_DATE, ROUTING_REVISION, BOM_REVISION_DATE, BOM_REVISION,
5899: ALTERNATE_BOM_DESIGNATOR, ALTERNATE_ROUTING_DESIGNATOR');
5900: end if; -- change bom/routing alternate
5901:
5894: end if;
5895:
5896: elsif p_old_status_type <> 1 then
5897: fnd_file.put_line(fnd_file.log, 'Ignoring any of the following fields if provided by the user for this standard job:');
5898: fnd_file.put_line(fnd_file.log, 'ROUTING_REVISION_DATE, ROUTING_REVISION, BOM_REVISION_DATE, BOM_REVISION,
5899: ALTERNATE_BOM_DESIGNATOR, ALTERNATE_ROUTING_DESIGNATOR');
5900: end if; -- change bom/routing alternate
5901:
5902: end if; -- job type 1, near l_stmt_num := 700.1;
5971: -- the update of status.
5972:
5973: if (p_change_bom_reference = 1 or p_change_routing_reference = 1)
5974: and p_old_status_type <> 1 then
5975: fnd_file.put_line(fnd_file.log,'Ignoring any of the following fields if provided by the user:');
5976: --fnd_file.new_line(fnd_file.log, 1);
5977: fnd_file.put_line(fnd_file.log, 'ROUTING_REFERENCE_ID, BOM_REFERENCE_ID, ROUTING_REVISION_DATE , ROUTING_REVISION, BOM_REVISION_DATE, BOM_REVISION, ALTERNATE_BOM_DESIGNATOR, ALTERNATE_ROUTING_DESIGNATOR');
5978: v_wlji_bom_revision_date(v_index):= p_old_bom_revision_date;
5979: v_wlji_bom_reference_id(v_index):= p_old_bom_reference_id;
5972:
5973: if (p_change_bom_reference = 1 or p_change_routing_reference = 1)
5974: and p_old_status_type <> 1 then
5975: fnd_file.put_line(fnd_file.log,'Ignoring any of the following fields if provided by the user:');
5976: --fnd_file.new_line(fnd_file.log, 1);
5977: fnd_file.put_line(fnd_file.log, 'ROUTING_REFERENCE_ID, BOM_REFERENCE_ID, ROUTING_REVISION_DATE , ROUTING_REVISION, BOM_REVISION_DATE, BOM_REVISION, ALTERNATE_BOM_DESIGNATOR, ALTERNATE_ROUTING_DESIGNATOR');
5978: v_wlji_bom_revision_date(v_index):= p_old_bom_revision_date;
5979: v_wlji_bom_reference_id(v_index):= p_old_bom_reference_id;
5980: v_wlji_alt_bom_designator(v_index):= p_old_alt_bom_designator;
5973: if (p_change_bom_reference = 1 or p_change_routing_reference = 1)
5974: and p_old_status_type <> 1 then
5975: fnd_file.put_line(fnd_file.log,'Ignoring any of the following fields if provided by the user:');
5976: --fnd_file.new_line(fnd_file.log, 1);
5977: fnd_file.put_line(fnd_file.log, 'ROUTING_REFERENCE_ID, BOM_REFERENCE_ID, ROUTING_REVISION_DATE , ROUTING_REVISION, BOM_REVISION_DATE, BOM_REVISION, ALTERNATE_BOM_DESIGNATOR, ALTERNATE_ROUTING_DESIGNATOR');
5978: v_wlji_bom_revision_date(v_index):= p_old_bom_revision_date;
5979: v_wlji_bom_reference_id(v_index):= p_old_bom_reference_id;
5980: v_wlji_alt_bom_designator(v_index):= p_old_alt_bom_designator;
5981: v_wlji_routing_revision_date(v_index):=p_old_routing_revision_date;
6251:
6252:
6253: if lbji_debug = 'Y' then
6254: if p_skip_updt = 1 then
6255: fnd_file.put_line(fnd_file.log, 'Planning to skip update of wo, wor, wro');
6256: else
6257: fnd_file.put_line(fnd_file.log, 'No Plans to skip update of wo, wor, wro');
6258: end if;
6259: end if;
6253: if lbji_debug = 'Y' then
6254: if p_skip_updt = 1 then
6255: fnd_file.put_line(fnd_file.log, 'Planning to skip update of wo, wor, wro');
6256: else
6257: fnd_file.put_line(fnd_file.log, 'No Plans to skip update of wo, wor, wro');
6258: end if;
6259: end if;
6260:
6261:
6425: v_wlji_err_code(v_index) := -1;
6426: fnd_message.set_name('WSM','WSM_NO_WAC_SCRAP_ACC');
6427: fnd_message.set_token('CC', l_temp_cc);
6428: v_wlji_err_msg(v_index) := fnd_message.get;
6429: fnd_file.put_line(fnd_file.log, 'stmt_num: '|| l_stmt_num ||' ' ||v_wlji_err_msg(v_index));
6430: fnd_file.new_line(fnd_file.log, 3);
6431: l_error_code := -1;
6432: GOTO skip_resched_validations;
6433: end if;
6426: fnd_message.set_name('WSM','WSM_NO_WAC_SCRAP_ACC');
6427: fnd_message.set_token('CC', l_temp_cc);
6428: v_wlji_err_msg(v_index) := fnd_message.get;
6429: fnd_file.put_line(fnd_file.log, 'stmt_num: '|| l_stmt_num ||' ' ||v_wlji_err_msg(v_index));
6430: fnd_file.new_line(fnd_file.log, 3);
6431: l_error_code := -1;
6432: GOTO skip_resched_validations;
6433: end if;
6434: if p_est_scrap_account is null or p_est_scrap_var_account is null then
6436: v_wlji_err_code(v_index) := -1;
6437: fnd_message.set_name('WSM','WSM_NO_WAC_SCRAP_ACC');
6438: fnd_message.set_token('CC', l_temp_cc);
6439: v_wlji_err_msg(v_index) := fnd_message.get;
6440: fnd_file.put_line(fnd_file.log, 'stmt_num: '|| l_stmt_num ||' ' ||v_wlji_err_msg(v_index));
6441: fnd_file.new_line(fnd_file.log, 3);
6442: l_error_code := -1;
6443: GOTO skip_resched_validations;
6444: end if;
6437: fnd_message.set_name('WSM','WSM_NO_WAC_SCRAP_ACC');
6438: fnd_message.set_token('CC', l_temp_cc);
6439: v_wlji_err_msg(v_index) := fnd_message.get;
6440: fnd_file.put_line(fnd_file.log, 'stmt_num: '|| l_stmt_num ||' ' ||v_wlji_err_msg(v_index));
6441: fnd_file.new_line(fnd_file.log, 3);
6442: l_error_code := -1;
6443: GOTO skip_resched_validations;
6444: end if;
6445: end if;
6893: WHERE ORGANIZATION_ID = v_wlji_org(v_index)
6894: AND WIP_ENTITY_ID = v_wlji_wip_entity_id(v_index);
6895:
6896: if lbji_debug = 'Y' then
6897: fnd_file.put_line(fnd_file.log, 'Updated '||SQL%ROWCOUNT||' rows into wo');
6898: end if;
6899:
6900: l_stmt_num := 1063;
6901: UPDATE WIP_OPERATION_RESOURCES
6915: WHERE ORGANIZATION_ID = v_wlji_org(v_index)
6916: AND WIP_ENTITY_ID = v_wlji_wip_entity_id(v_index);
6917:
6918: if lbji_debug = 'Y' then
6919: fnd_file.put_line(fnd_file.log, 'Updated '||SQL%ROWCOUNT||' rows into wor');
6920: end if;
6921:
6922: l_stmt_num := 1064;
6923: --LBM enh: modified the expression on required_quantity
6939: WHERE ORGANIZATION_ID = v_wlji_org(v_index)
6940: AND WIP_ENTITY_ID = v_wlji_wip_entity_id(v_index);
6941:
6942: if lbji_debug = 'Y' then
6943: fnd_file.put_line(fnd_file.log, 'Updated '||SQL%ROWCOUNT||' rows into wro');
6944: end if;
6945:
6946: l_stmt_num := 1065;
6947: -- abb H: optional scrap accounting
6971: v_wlji_err_code(v_index) := -1;
6972: fnd_message.set_name('WSM','WSM_NO_SCRAP_ACC');
6973: fnd_message.set_token('DEPT_ID',to_char(l_department_id));
6974: v_wlji_err_msg(v_index) := fnd_message.get;
6975: fnd_file.put_line(fnd_file.log, 'stmt_num: '|| l_stmt_num ||' '||v_wlji_err_msg(v_index));
6976: fnd_file.new_line(fnd_file.log, 3);
6977: l_error_code := -1;
6978: l_error_count := l_error_count + 1;
6979: GOTO skip_other_steps;
6972: fnd_message.set_name('WSM','WSM_NO_SCRAP_ACC');
6973: fnd_message.set_token('DEPT_ID',to_char(l_department_id));
6974: v_wlji_err_msg(v_index) := fnd_message.get;
6975: fnd_file.put_line(fnd_file.log, 'stmt_num: '|| l_stmt_num ||' '||v_wlji_err_msg(v_index));
6976: fnd_file.new_line(fnd_file.log, 3);
6977: l_error_code := -1;
6978: l_error_count := l_error_count + 1;
6979: GOTO skip_other_steps;
6980: end if;
6985: WHERE WIP_ENTITY_ID = v_wlji_wip_entity_id(v_index)
6986: and operation_seq_num = min_op_seq_num;
6987:
6988: if lbji_debug = 'Y' then
6989: fnd_file.put_line(fnd_file.log, 'Updated '||SQL%ROWCOUNT||' rows into woy');
6990: end if;
6991:
6992: select max(operation_seq_num)
6993: into max_op_seq_num
7006: v_wlji_err_code(v_index) := -1;
7007: fnd_message.set_name('WSM','WSM_NO_SCRAP_ACC');
7008: fnd_message.set_token('DEPT_ID',to_char(l_department_id));
7009: v_wlji_err_msg(v_index) := fnd_message.get;
7010: fnd_file.put_line(fnd_file.log, 'stmt_num: '|| l_stmt_num ||' '||v_wlji_err_msg(v_index));
7011: fnd_file.new_line(fnd_file.log, 3);
7012: l_error_code := -1;
7013: l_error_count := l_error_count + 1;
7014: GOTO skip_other_steps;
7007: fnd_message.set_name('WSM','WSM_NO_SCRAP_ACC');
7008: fnd_message.set_token('DEPT_ID',to_char(l_department_id));
7009: v_wlji_err_msg(v_index) := fnd_message.get;
7010: fnd_file.put_line(fnd_file.log, 'stmt_num: '|| l_stmt_num ||' '||v_wlji_err_msg(v_index));
7011: fnd_file.new_line(fnd_file.log, 3);
7012: l_error_code := -1;
7013: l_error_count := l_error_count + 1;
7014: GOTO skip_other_steps;
7015: end if;
7020: WHERE WIP_ENTITY_ID = v_wlji_wip_entity_id(v_index)
7021: and operation_seq_num = max_op_seq_num;
7022:
7023: if lbji_debug = 'Y' then
7024: fnd_file.put_line(fnd_file.log, 'Updated '||SQL%ROWCOUNT||' rows into woy');
7025: end if;
7026:
7027: end if;
7028:
7043: delete from wip_period_balances
7044: where wip_entity_id = v_wlji_wip_entity_id(v_index)
7045: and organization_id = v_wlji_org(v_index);
7046: if lbji_debug = 'Y' then
7047: fnd_file.put_line(fnd_file.log, 'Deleted '||SQL%ROWCOUNT||' rows from wpb');
7048: end if;
7049: end if;
7050:
7051: l_stmt_num := 1072;
7081: update wip_discrete_jobs wdj
7082: set status_type = 7
7083: where wdj.wip_entity_id = v_wlji_wip_entity_id(v_index);
7084: if lbji_debug = 'Y' then
7085: fnd_file.put_line(fnd_file.log, 'Updated status type to 7 in wdj');
7086: end if;
7087: --
7088: -- begin Bugfix 2820900 : Update the job name with sector lot extn. once canceled.
7089: -- Note: Since status update for canceled jobs are not allowed currently, there's
7211: -- bug 2762029 modification end
7212: end if; -- update jobs for which status is not cancelled
7213:
7214: if lbji_debug = 'Y' then
7215: fnd_file.put_line(fnd_file.log, 'Updated '||SQL%ROWCOUNT||' rows of wdj');
7216: end if;
7217:
7218:
7219: l_stmt_num := 1074;
7228: last_update_date = v_wlji_last_updt_date(v_index)
7229: where we.wip_entity_id = v_wlji_wip_entity_id(v_index);
7230:
7231: if lbji_debug = 'Y' then
7232: fnd_file.put_line(fnd_file.log, 'Updated '||SQL%ROWCOUNT||' rows into we');
7233: end if;
7234:
7235: Exception
7236: when others then
7253:
7254: if ((v_wlji_load_type(v_index) = 6) AND (v_wlji_class_code(v_index) is NULL)) then
7255: v_wlji_class_code(v_index) := p_old_class_code;
7256: end if;
7257: fnd_file.put_line(fnd_file.log, 'date released ****: '||v_wlji_date_released(v_index));
7258: insert_into_period_balances (
7259: p_wip_entity_id => v_wlji_wip_entity_id(v_index),
7260: p_organization_id => v_wlji_org(v_index),
7261: p_class_code => v_wlji_class_code(v_index),
7372: mtl_material_transactions_s.nextval /* Transaction Temp Id */
7373: ) RETURNING transaction_temp_id into txn_tmp_header_id;
7374:
7375: if lbji_debug = 'Y' then
7376: fnd_file.put_line(fnd_file.log, 'Inserted '||SQL%ROWCOUNT||' rows into mmtt');
7377: end if;
7378:
7379: l_stmt_num := 1160;
7380:
7401: -l_quantity_tobe_issued,
7402: v_wsli(v_wlji_source_line_id(v_index)).lot_number);
7403:
7404: if lbji_debug = 'Y' then
7405: fnd_file.put_line(fnd_file.log, 'Inserted '||SQL%ROWCOUNT||' rows into mtlt');
7406: end if;
7407:
7408: l_stmt_num := 1160;
7409: UPDATE WIP_REQUIREMENT_OPERATIONS
7439: IF p_old_status_type in (0,1,3,6) THEN -- Initialized Value,
7440: --Unreleased, released, Hold
7441: l_stmt_num := 1170;
7442: IF (lbji_debug='Y') THEN
7443: fnd_file.put_line(fnd_file.log, 'Before Calling WSM_LotAttr_PVT.create_update_lotattr');
7444: END IF;
7445: WSM_LotAttr_PVT.create_update_lotattr(
7446: x_err_code => l_error_code,
7447: x_err_msg => l_error_msg,
7456: l_error_count := l_error_count + 1;
7457: GOTO skip_other_steps;
7458: END IF;
7459: IF (lbji_debug='Y') THEN
7460: fnd_file.put_line(fnd_file.log, 'WSM_LotAttr_PVT.create_update_lotattr returned Success');
7461: END IF;
7462: l_stmt_num := 1180;
7463: END IF; -- p_old_status_type in (1,3,6)
7464:
7477: -- *** write into output file ***
7478: -- note that this is a rudimentary piece of commentary on the job created,
7479: -- or failed to create because there's no customer requirement on this.
7480: if v_wlji_load_type(v_index) = 5 then
7481: fnd_file.put_line(fnd_file.output, '-------------------------------------------------------');
7482: --bug 5051783:Replaced org_organization_definitions with mtl_parameters.
7483: select organization_code
7484: into org_code
7485: --from ORG_ORGANIZATION_DEFINITIONS
7485: --from ORG_ORGANIZATION_DEFINITIONS
7486: from mtl_parameters
7487: where organization_id = v_wlji_org(v_index);
7488:
7489: fnd_file.put_line(fnd_file.output, 'Organization: '||org_code);
7490: fnd_file.put_line(fnd_file.output, 'Job_name: '|| v_wlji_job_name(v_index));
7491: select meaning
7492: into job_type_meaning
7493: from mfg_lookups
7486: from mtl_parameters
7487: where organization_id = v_wlji_org(v_index);
7488:
7489: fnd_file.put_line(fnd_file.output, 'Organization: '||org_code);
7490: fnd_file.put_line(fnd_file.output, 'Job_name: '|| v_wlji_job_name(v_index));
7491: select meaning
7492: into job_type_meaning
7493: from mfg_lookups
7494: where lookup_type = 'WIP_DISCRETE_JOB'
7492: into job_type_meaning
7493: from mfg_lookups
7494: where lookup_type = 'WIP_DISCRETE_JOB'
7495: and lookup_code = v_wlji_job_type(v_index);
7496: fnd_file.put_line(fnd_file.output, 'Job Type: '|| job_type_meaning);
7497:
7498: begin
7499: select unique(concatenated_segments)
7500: into assembly_name
7504: exception
7505: when others then
7506: assembly_name := 'Unknown';
7507: end;
7508: fnd_file.put_line(fnd_file.output, 'Assembly: '|| assembly_name);
7509: fnd_file.put_line(fnd_file.output, 'Quantity: '|| v_wlji_start_quantity(v_index));
7510: fnd_file.put_line(fnd_file.output, 'Start Date: '|| v_wlji_fusd(v_index));
7511: fnd_file.put_line(fnd_file.output, 'Completion Date: '|| v_wlji_lucd(v_index));
7512: fnd_file.put_line(fnd_file.output, 'Kanban Card: '|| v_wlji_kanban_card_id(v_index));
7505: when others then
7506: assembly_name := 'Unknown';
7507: end;
7508: fnd_file.put_line(fnd_file.output, 'Assembly: '|| assembly_name);
7509: fnd_file.put_line(fnd_file.output, 'Quantity: '|| v_wlji_start_quantity(v_index));
7510: fnd_file.put_line(fnd_file.output, 'Start Date: '|| v_wlji_fusd(v_index));
7511: fnd_file.put_line(fnd_file.output, 'Completion Date: '|| v_wlji_lucd(v_index));
7512: fnd_file.put_line(fnd_file.output, 'Kanban Card: '|| v_wlji_kanban_card_id(v_index));
7513: if v_wlji_process_status(v_index) <> 3 then
7506: assembly_name := 'Unknown';
7507: end;
7508: fnd_file.put_line(fnd_file.output, 'Assembly: '|| assembly_name);
7509: fnd_file.put_line(fnd_file.output, 'Quantity: '|| v_wlji_start_quantity(v_index));
7510: fnd_file.put_line(fnd_file.output, 'Start Date: '|| v_wlji_fusd(v_index));
7511: fnd_file.put_line(fnd_file.output, 'Completion Date: '|| v_wlji_lucd(v_index));
7512: fnd_file.put_line(fnd_file.output, 'Kanban Card: '|| v_wlji_kanban_card_id(v_index));
7513: if v_wlji_process_status(v_index) <> 3 then
7514: status_name := 'Success';
7507: end;
7508: fnd_file.put_line(fnd_file.output, 'Assembly: '|| assembly_name);
7509: fnd_file.put_line(fnd_file.output, 'Quantity: '|| v_wlji_start_quantity(v_index));
7510: fnd_file.put_line(fnd_file.output, 'Start Date: '|| v_wlji_fusd(v_index));
7511: fnd_file.put_line(fnd_file.output, 'Completion Date: '|| v_wlji_lucd(v_index));
7512: fnd_file.put_line(fnd_file.output, 'Kanban Card: '|| v_wlji_kanban_card_id(v_index));
7513: if v_wlji_process_status(v_index) <> 3 then
7514: status_name := 'Success';
7515: else
7508: fnd_file.put_line(fnd_file.output, 'Assembly: '|| assembly_name);
7509: fnd_file.put_line(fnd_file.output, 'Quantity: '|| v_wlji_start_quantity(v_index));
7510: fnd_file.put_line(fnd_file.output, 'Start Date: '|| v_wlji_fusd(v_index));
7511: fnd_file.put_line(fnd_file.output, 'Completion Date: '|| v_wlji_lucd(v_index));
7512: fnd_file.put_line(fnd_file.output, 'Kanban Card: '|| v_wlji_kanban_card_id(v_index));
7513: if v_wlji_process_status(v_index) <> 3 then
7514: status_name := 'Success';
7515: else
7516: status_name := 'Falied To Create';
7514: status_name := 'Success';
7515: else
7516: status_name := 'Falied To Create';
7517: end if;
7518: fnd_file.put_line(fnd_file.output, 'Process Status: '|| Status_name);
7519: if v_wlji_process_status(v_index) = 3 then
7520: fnd_file.put_line(fnd_file.output, v_wlji_err_msg(v_index));
7521: end if;
7522: fnd_file.put_line(fnd_file.output, '-------------------------------------------------------');
7516: status_name := 'Falied To Create';
7517: end if;
7518: fnd_file.put_line(fnd_file.output, 'Process Status: '|| Status_name);
7519: if v_wlji_process_status(v_index) = 3 then
7520: fnd_file.put_line(fnd_file.output, v_wlji_err_msg(v_index));
7521: end if;
7522: fnd_file.put_line(fnd_file.output, '-------------------------------------------------------');
7523: end if; -- load type 5
7524: -- *** write into output file end***
7518: fnd_file.put_line(fnd_file.output, 'Process Status: '|| Status_name);
7519: if v_wlji_process_status(v_index) = 3 then
7520: fnd_file.put_line(fnd_file.output, v_wlji_err_msg(v_index));
7521: end if;
7522: fnd_file.put_line(fnd_file.output, '-------------------------------------------------------');
7523: end if; -- load type 5
7524: -- *** write into output file end***
7525:
7526:
7534:
7535: if v_wlji_process_status(v_index) <> 3 then
7536: v_wlji_process_status(v_index) := 5; -- 5 : complete without error
7537: if lbji_debug = 'Y' then
7538: fnd_file.put_line(fnd_file.log, 'Everything OK, changing the status of the row to 5..');
7539: end if;
7540: else
7541: -- abbkanban begin
7542: if v_wlji_kanban_card_id(v_index) is not null then
7580: dummy_err_code,
7581: dummy_err_msg );
7582:
7583: if dummy_err_code <> 0 then
7584: fnd_file.put_line(fnd_file.log, '*** WARNING ***');
7585: fnd_file.put_line(fnd_file.log, 'WSMPLBJI.launch_worker: '||dummy_err_msg);
7586: l_error_count := l_error_count + 1;
7587: end if;
7588: end if;
7581: dummy_err_msg );
7582:
7583: if dummy_err_code <> 0 then
7584: fnd_file.put_line(fnd_file.log, '*** WARNING ***');
7585: fnd_file.put_line(fnd_file.log, 'WSMPLBJI.launch_worker: '||dummy_err_msg);
7586: l_error_count := l_error_count + 1;
7587: end if;
7588: end if;
7589:
7591:
7592: end loop; -- inner loop
7593:
7594: if lbji_debug = 'Y' then
7595: fnd_file.put_line(fnd_file.log, ' ');
7596: fnd_file.put_line(fnd_file.log, ' ');
7597: fnd_file.put_line(fnd_file.log, ' ');
7598: fnd_file.put_line(fnd_file.log, ' ');
7599: end if;
7592: end loop; -- inner loop
7593:
7594: if lbji_debug = 'Y' then
7595: fnd_file.put_line(fnd_file.log, ' ');
7596: fnd_file.put_line(fnd_file.log, ' ');
7597: fnd_file.put_line(fnd_file.log, ' ');
7598: fnd_file.put_line(fnd_file.log, ' ');
7599: end if;
7600:
7593:
7594: if lbji_debug = 'Y' then
7595: fnd_file.put_line(fnd_file.log, ' ');
7596: fnd_file.put_line(fnd_file.log, ' ');
7597: fnd_file.put_line(fnd_file.log, ' ');
7598: fnd_file.put_line(fnd_file.log, ' ');
7599: end if;
7600:
7601: -- *** RETCODE return values ***
7594: if lbji_debug = 'Y' then
7595: fnd_file.put_line(fnd_file.log, ' ');
7596: fnd_file.put_line(fnd_file.log, ' ');
7597: fnd_file.put_line(fnd_file.log, ' ');
7598: fnd_file.put_line(fnd_file.log, ' ');
7599: end if;
7600:
7601: -- *** RETCODE return values ***
7602: -- 0: success
7606:
7607: if l_warning_count <> 0 then
7608: retcode := 1;
7609: errbuf := 'The interface process produced atleast one warning message';
7610: fnd_file.put_line(fnd_file.log,errbuf);
7611: conc_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',errbuf);
7612: end if;
7613:
7614: if l_error_count <> 0 then
7613:
7614: if l_error_count <> 0 then
7615: retcode := 1;
7616: errbuf := 'The interface process marked atleast one row as errored';
7617: fnd_file.put_line(fnd_file.log,errbuf);
7618: conc_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',errbuf);
7619: end if;
7620:
7621: -- *** bulk update wsm_lot_job_interface ***
7631:
7632: l_boolean_success := false;
7633:
7634: if l_atleast_one_row_in_mmtt <>0 THEN
7635: fnd_file.put_line(fnd_file.log, 'Invoking Inventory Worker with header id: '||to_char(txn_header_id));
7636: l_inv_worker_req_id := FND_REQUEST.submit_request (
7637: 'INV', 'INCTCW', NULL, NULL, FALSE,
7638: --to_char(txn_header_id), '1', NULL, NULL); -- bug 3733798
7639: to_char(txn_header_id), '4', NULL, NULL); -- bug 3733798
7639: to_char(txn_header_id), '4', NULL, NULL); -- bug 3733798
7640:
7641: commit;
7642:
7643: fnd_file.put_line(fnd_file.log,'Material Transaction temp_header_id is '
7644: ||to_char(txn_header_id));
7645:
7646: if l_inv_worker_req_id = 0 then
7647:
7647:
7648: retcode := 1;
7649: errbuf:= 'WSMPLBJI. Inventory worker returned failure '||
7650: '(Transaction_header_id=' ||txn_header_id||') : '|| SUBSTRB(SQLERRM,1,1000);
7651: fnd_file.put_line(fnd_file.log,errbuf);
7652: conc_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',errbuf);
7653: update wsm_lot_job_interface
7654: set process_status = 4,
7655: error_code = -2,
7657: where mode_flag = 2;
7658:
7659: else -- req_id <> 0
7660:
7661: fnd_file.put_line(fnd_file.log,'Inventory Transaction Worker request_id is '
7662: ||to_char(l_inv_worker_req_id));
7663: req_wait := FND_CONCURRENT.WAIT_FOR_REQUEST
7664: (request_id => l_inv_worker_req_id,
7665: interval => 10, -- 10 seconds interval
7669: dev_phase => req_devphase,
7670: dev_status => req_devstatus,
7671: message => req_message);
7672:
7673: fnd_file.put_line(fnd_file.log, 'Inventory Transaction Worker status is '
7674: ||req_status);
7675: fnd_file.put_line(fnd_file.log, 'Inventory Transaction Worker Completion Message: '
7676: ||req_message);
7677:
7671: message => req_message);
7672:
7673: fnd_file.put_line(fnd_file.log, 'Inventory Transaction Worker status is '
7674: ||req_status);
7675: fnd_file.put_line(fnd_file.log, 'Inventory Transaction Worker Completion Message: '
7676: ||req_message);
7677:
7678: if req_devphase <> 'COMPLETE' OR req_devstatus <> 'NORMAL' THEN
7679: retcode := 1;
7679: retcode := 1;
7680: errbuf:= 'WSMPLBJI. Inventory worker returned failure '||
7681: '(Transaction_header_id=' ||txn_header_id||') : '||
7682: SUBSTRB(SQLERRM,1,1000);
7683: fnd_file.put_line(fnd_file.log,errbuf);
7684: conc_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',errbuf);
7685: end if;
7686:
7687: check_errored_mmtt_records(txn_header_id, l_error_code, l_error_msg);
7689: if (l_error_code <> 0) or (l_error_msg is not null ) then
7690: retcode := 1;
7691: errbuf:= 'WSMPLBJI. Errored Records in mmtt ' ||
7692: '(Transaction_header_id=' ||txn_header_id||') : '|| SUBSTRB(SQLERRM,1,1000);
7693: fnd_file.put_line(fnd_file.log,errbuf);
7694: conc_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',errbuf);
7695: end if;
7696:
7697: end if; -- req_id
7717: SYSDATE-l_del_int_prof_value)
7718: );
7719:
7720: if lbji_debug = 'Y' then
7721: fnd_file.put_line(fnd_file.log, 'Deleted '||SQL%ROWCOUNT||' rows from wsli');
7722: end if;
7723: end if;
7724:
7725: delete from wsm_lot_job_interface
7731: NVL(transaction_date, creation_date) -1,
7732: SYSDATE-l_del_int_prof_value);
7733:
7734: if lbji_debug = 'Y' then
7735: fnd_file.put_line(fnd_file.log, 'Deleted '||SQL%ROWCOUNT||' rows from wlji');
7736: end if;
7737:
7738: Exception
7739: when others then
7738: Exception
7739: when others then
7740: retcode := 1;
7741: errbuf := 'Deletion of successful rows from interface table(s) failed';
7742: fnd_file.put_line(fnd_file.log,errbuf);
7743: conc_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',errbuf);
7744: End;
7745:
7746: commit;
7768: NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL,
7769: NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL
7770: ) ;
7771:
7772: fnd_file.put_line(fnd_file.log,'Concurrent Request for Requisition Inport Submitted');
7773: fnd_file.put_line(fnd_file.log,'Request_id: '||l_req_request_id);
7774: end if;
7775: -- osp end
7776:
7769: NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL
7770: ) ;
7771:
7772: fnd_file.put_line(fnd_file.log,'Concurrent Request for Requisition Inport Submitted');
7773: fnd_file.put_line(fnd_file.log,'Request_id: '||l_req_request_id);
7774: end if;
7775: -- osp end
7776:
7777: -- phantom project
7792: when abort_request then
7793: rollback to back_to_square_one;
7794: retcode := 2;
7795: errbuf := 'WSMLBJIB.launch_worker_1159: stmt num= '||l_stmt_num||' '||SUBSTR(SQLERRM, 1,240);
7796: fnd_file.put_line(fnd_file.log,errbuf);
7797: conc_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',errbuf);
7798: when others then
7799: rollback to back_to_square_one;
7800: retcode := 2;
7798: when others then
7799: rollback to back_to_square_one;
7800: retcode := 2;
7801: errbuf := 'WSMLBJIB.launch_worker_1159: stmt num= '||l_stmt_num||' '||SUBSTR(SQLERRM, 1,240);
7802: fnd_file.put_line(fnd_file.log,errbuf);
7803: conc_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',errbuf);
7804:
7805: END launch_worker_1159;
7806: