[Home] [Help]
25: IF PG_DEBUG in ('Y', 'C') THEN
26: msc_sch_wb.atp_debug('***** Begin Check_Lines_For_CTO_ATP *****');
27: END IF;
28:
29: --- put data in mrp_atp_schedule_temp, call put_into_temp
30: MSC_ATP_UTILS.put_into_temp_table(
31: NULL,
32: p_session_id,
33: p_atp_rec,
85: msc_sch_wb.atp_debug('***** Check if any ATPAble item exisst or not ****');
86: END IF;
87: select count(*)
88: into l_atp_count
89: from mrp_atp_schedule_temp
90: where session_id = p_session_id
91: and order_line_id = NVL(ato_model_line_id, order_line_id)
92: --bug 3378648
93: and status_flag in (99,4) --4658238
201: l_cto_lines_for_match.ORDERED_QUANTITY,
202: l_cto_lines_for_match.ORDER_QUANTITY_UOM,
203: --pass source org to CTO
204: l_cto_lines_for_match.SHIP_FROM_ORG_ID
205: from mrp_atp_schedule_temp mast
206: where Session_id = p_session_id and
207: --bug 3378648: Look only at ATP inserted data
208: status_flag in (99,4) and --4658238
209: Ato_model_line_id in
207: --bug 3378648: Look only at ATP inserted data
208: status_flag in (99,4) and --4658238
209: Ato_model_line_id in
210: (select mast_1.ato_model_line_id from
211: mrp_atp_schedule_temp mast_1
212: where mast_1.session_id = p_session_id
213: --bug 3378648
214: and status_flag in (99,4) --4658238
215: and mast_1.order_line_id = mast_1.ato_model_line_id
271: RAISE FND_API.G_EXC_ERROR ;
272: ---match fail
273: END;
274:
275: -- update mrp_atp_schedule_temp with match info Praent_ato_lin_id information
276: IF PG_DEBUG in ('Y', 'C') THEN
277: msc_sch_wb.atp_debug(' l_cto_lines_for_match count := ' || l_cto_lines_for_match.inventory_item_id.count);
278: msc_sch_wb.atp_debug('matched_item_id count := ' || l_cto_lines_for_match.config_item_id.count);
279: msc_sch_wb.atp_debug('gop_parent_ato_line_id count := ' || l_cto_lines_for_match.gop_parent_ato_line_id.count);
290:
291: END IF;
292: --update information returned by match API
293: FORALL i in 1..l_cto_lines_for_match.inventory_item_id.count
294: UPDATE mrp_atp_schedule_temp
295: SET ATO_Parent_Model_Line_Id = l_cto_lines_for_match.gop_parent_ato_line_id(i),
296: match_item_id = l_cto_lines_for_match.config_item_id(i),
297: wip_supply_type = l_cto_lines_for_match.wip_supply_type(i),
298: oss_error_code = l_cto_lines_for_match.oss_error_code(i),
363: IF p_dblink is null then
364: update msc_cto_sources
365: set status_flag = 2
366: where ato_line_id in (select order_line_id
367: from mrp_atp_schedule_temp
368: where session_id = p_session_id
369: and order_line_id = ato_model_line_id);
370: IF PG_DEBUG in ('Y', 'C') THEN
371: msc_sch_wb.atp_debug('Number of rows updated := ' || SQL%ROWCOUNT);
375: msc_sch_wb.atp_debug('Delete CTO Sources locally');
376: END IF;
377: delete msc_cto_sources
378: where line_id in (select order_line_id
379: from mrp_atp_schedule_temp
380: where session_id = p_session_id
381: and order_line_id = ato_model_line_id);
382:
383: IF PG_DEBUG in ('Y', 'C') THEN
389: msc_sch_wb.atp_debug('sql stmt := ' || l_sql_stmt);
390: END IF;
391: l_sql_stmt := l_sql_stmt || ' set status_flag = 2 '
392: || ' where ato_line_id in (select order_line_id '
393: || ' from mrp_atp_schedule_temp '
394: || ' where session_id = :p_session_id '
395: || ' and order_line_id = ato_model_line_id)';
396: IF PG_DEBUG in ('Y', 'C') THEN
397: msc_sch_wb.atp_debug('sql stmt := ' || l_sql_stmt);
472: CREATED_BY, LAST_UPDATED_BY, LAST_UPDATE_DATE,
473: MAKE_FLAG, refresh_number, session_id from msc_cto_sources
474: where session_id = :p_session_id
475: and line_id in (select order_line_id
476: from mrp_atp_schedule_temp
477: where session_id = :p_session_id
478: --bug 3378648
479: and status_flag = 99
480: and order_line_id = ato_model_line_id)';
1024: mast.QUANTITY_ORDERED,
1025: mast.parent_line_id,
1026: MSC_ATP_PVT.G_INSTANCE_ID,
1027: p_refresh_number
1028: FROM mrp_atp_schedule_temp mast,
1029: msc_item_id_lid mil
1030: where session_id = p_session_id
1031: --bug 3378648
1032: and status_flag = 99