[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,
86: msc_sch_wb.atp_debug('***** Check if any ATPAble item exisst or not ****');
87: END IF;
88: select count(*)
89: into l_atp_count
90: from mrp_atp_schedule_temp
91: where session_id = p_session_id
92: and order_line_id = NVL(ato_model_line_id, order_line_id)
93: --bug 3378648
94: and status_flag in (99,4) --4658238
202: l_cto_lines_for_match.ORDERED_QUANTITY,
203: l_cto_lines_for_match.ORDER_QUANTITY_UOM,
204: --pass source org to CTO
205: l_cto_lines_for_match.SHIP_FROM_ORG_ID
206: from mrp_atp_schedule_temp mast
207: where Session_id = p_session_id and
208: --bug 3378648: Look only at ATP inserted data
209: status_flag in (99,4) and --4658238
210: Ato_model_line_id in
208: --bug 3378648: Look only at ATP inserted data
209: status_flag in (99,4) and --4658238
210: Ato_model_line_id in
211: (select mast_1.ato_model_line_id from
212: mrp_atp_schedule_temp mast_1
213: where mast_1.session_id = p_session_id
214: --bug 3378648
215: and status_flag in (99,4) --4658238
216: and mast_1.order_line_id = mast_1.ato_model_line_id
273: RAISE FND_API.G_EXC_ERROR ;
274: ---match fail
275: END;
276:
277: -- update mrp_atp_schedule_temp with match info Praent_ato_lin_id information
278: IF PG_DEBUG in ('Y', 'C') THEN
279: msc_sch_wb.atp_debug(' l_cto_lines_for_match count := ' || l_cto_lines_for_match.inventory_item_id.count);
280: msc_sch_wb.atp_debug('matched_item_id count := ' || l_cto_lines_for_match.config_item_id.count);
281: msc_sch_wb.atp_debug('gop_parent_ato_line_id count := ' || l_cto_lines_for_match.gop_parent_ato_line_id.count);
292:
293: END IF;
294: --update information returned by match API
295: FORALL i in 1..l_cto_lines_for_match.inventory_item_id.count
296: UPDATE mrp_atp_schedule_temp
297: SET ATO_Parent_Model_Line_Id = l_cto_lines_for_match.gop_parent_ato_line_id(i),
298: match_item_id = l_cto_lines_for_match.config_item_id(i),
299: wip_supply_type = l_cto_lines_for_match.wip_supply_type(i),
300: oss_error_code = l_cto_lines_for_match.oss_error_code(i),
365: IF p_dblink is null then
366: update msc_cto_sources
367: set status_flag = 2
368: where ato_line_id in (select order_line_id
369: from mrp_atp_schedule_temp
370: where session_id = p_session_id
371: and order_line_id = ato_model_line_id);
372: IF PG_DEBUG in ('Y', 'C') THEN
373: msc_sch_wb.atp_debug('Number of rows updated := ' || SQL%ROWCOUNT);
377: msc_sch_wb.atp_debug('Delete CTO Sources locally');
378: END IF;
379: delete msc_cto_sources
380: where line_id in (select order_line_id
381: from mrp_atp_schedule_temp
382: where session_id = p_session_id
383: and order_line_id = ato_model_line_id);
384:
385: IF PG_DEBUG in ('Y', 'C') THEN
391: msc_sch_wb.atp_debug('sql stmt := ' || l_sql_stmt);
392: END IF;
393: l_sql_stmt := l_sql_stmt || ' set status_flag = 2 '
394: || ' where ato_line_id in (select order_line_id '
395: || ' from mrp_atp_schedule_temp '
396: || ' where session_id = :p_session_id '
397: || ' and order_line_id = ato_model_line_id)';
398: IF PG_DEBUG in ('Y', 'C') THEN
399: msc_sch_wb.atp_debug('sql stmt := ' || l_sql_stmt);
474: CREATED_BY, LAST_UPDATED_BY, LAST_UPDATE_DATE,
475: MAKE_FLAG, refresh_number, session_id from msc_cto_sources
476: where session_id = :p_session_id
477: and line_id in (select order_line_id
478: from mrp_atp_schedule_temp
479: where session_id = :p_session_id
480: --bug 3378648
481: and status_flag = 99
482: and order_line_id = ato_model_line_id)';
1027: mast.QUANTITY_ORDERED,
1028: mast.parent_line_id,
1029: MSC_ATP_PVT.G_INSTANCE_ID,
1030: p_refresh_number
1031: FROM mrp_atp_schedule_temp mast,
1032: msc_item_id_lid mil
1033: where session_id = p_session_id
1034: --bug 3378648
1035: and status_flag = 99