[Home] [Help]
190: /* Process batch header record */
191: build_batch_hdr(p_batch_header_mig => get_batches,
192: x_batch_header => l_batch_header);
193:
194: SELECT wip_entities_s.NEXTVAL INTO l_wip_entity_id FROM DUAL;
195: l_batch_header.plant_code := NULL;
196: l_batch_header.batch_status := 1;
197: l_batch_header.enforce_step_dependency := 0;
198: l_batch_header.terminated_ind := 0;
298: l_subinventory := NULL;
299: END IF;
300: END IF;
301:
302: SELECT gem5_line_id_s.NEXTVAL INTO l_mtl_dtl_tbl(i).material_detail_id FROM DUAL;
303: l_mtl_dtl_tbl(i).batch_id := l_batch_header.batch_id;
304: l_mtl_dtl_tbl(i).actual_qty := 0;
305: l_mtl_dtl_tbl(i).wip_plan_qty := NULL;
306: l_mtl_dtl_tbl(i).backordered_qty := 0;
335: x_steps => l_steps_tbl);
336:
337: FOR i IN 1..l_steps_tbl.count LOOP
338: l_old_batchstep_id := l_steps_tbl(i).batchstep_id;
339: SELECT gme_batch_step_s.NEXTVAL INTO l_steps_tbl(i).batchstep_id FROM DUAL;
340: l_steps_tbl(i).batch_id := l_batch_header.batch_id;
341: l_steps_tbl(i).step_status := 1;
342: l_steps_tbl(i).actual_start_date := NULL;
343: l_steps_tbl(i).actual_cmplt_date := NULL;
357: gme_debug.put_line('No. of activities = '||l_activities_mig_tbl.count);
358: END IF;
359: FOR j IN (l_actv_count + 1)..l_activities_tbl.count LOOP
360: l_old_bstep_activ_id := l_activities_tbl(j).batchstep_activity_id;
361: SELECT gme_batch_step_activity_s.NEXTVAL INTO l_activities_tbl(j).batchstep_activity_id FROM DUAL;
362: l_activities_tbl(j).batch_id := l_batch_header.batch_id;
363: l_activities_tbl(j).batchstep_id := l_steps_tbl(i).batchstep_id;
364: l_activities_tbl(j).actual_start_date := NULL;
365: l_activities_tbl(j).actual_cmplt_date := NULL;
377: gme_debug.put_line('No. of resources = '||l_resources_mig_tbl.count);
378: END IF;
379: FOR k IN (l_rsrc_count + 1)..l_resources_tbl.count LOOP
380: l_old_bstep_rsrc_id := l_resources_tbl(k).batchstep_resource_id;
381: SELECT gem5_batchstepline_id_s.NEXTVAL INTO l_resources_tbl(k).batchstep_resource_id FROM DUAL;
382: l_resources_tbl(k).batch_id := l_batch_header.batch_id;
383: l_resources_tbl(k).batchstep_id := l_steps_tbl(i).batchstep_id;
384: l_resources_tbl(k).batchstep_activity_id := l_activities_tbl(j).batchstep_activity_id;
385: l_resources_tbl(k).actual_start_date := NULL;
397: IF (g_debug <= gme_debug.g_log_statement) THEN
398: gme_debug.put_line('No. of process params = '||l_proc_param_mig_tbl.count);
399: END IF;
400: FOR m IN (l_pprm_count + 1)..l_proc_param_tbl.count LOOP
401: SELECT gme_process_parameters_id_s.NEXTVAL INTO l_proc_param_tbl(m).process_param_id FROM DUAL;
402: l_proc_param_tbl(m).batch_id := l_batch_header.batch_id;
403: l_proc_param_tbl(m).batchstep_id := l_steps_tbl(i).batchstep_id;
404: l_proc_param_tbl(m).batchstep_activity_id := l_activities_tbl(j).batchstep_activity_id;
405: l_proc_param_tbl(m).batchstep_resource_id := l_resources_tbl(k).batchstep_resource_id;
416: IF (g_debug <= gme_debug.g_log_statement) THEN
417: gme_debug.put_line('No. of rsrc txns = '||l_rsrc_txns_mig_tbl.count);
418: END IF;
419: FOR n IN (l_rtxn_count + 1)..l_rsrc_txns_tbl.count LOOP
420: SELECT gem5_poc_trans_id_s.NEXTVAL INTO l_rsrc_txns_tbl(n).poc_trans_id FROM DUAL;
421: l_rsrc_txns_tbl(n).orgn_code := NULL;
422: l_rsrc_txns_tbl(n).doc_id := l_batch_header.batch_id;
423: l_rsrc_txns_tbl(n).line_id := l_resources_tbl(k).batchstep_resource_id;
424: END LOOP; /* Resource Txns Loop */
1430: OPEN Cur_step_txfrs;
1431: FETCH Cur_step_txfrs BULK COLLECT INTO l_step_txfrs_mig_tbl;
1432: CLOSE Cur_step_txfrs;
1433: FOR i IN 1..l_step_txfrs_mig_tbl.count LOOP
1434: SELECT gem5_wip_trans_id_s.NEXTVAL INTO l_step_txfrs_tbl(i).wip_trans_id FROM DUAL;
1435: l_step_txfrs_tbl(i).batch_id := p_new_batch_id;
1436: l_step_txfrs_tbl(i).batchstep_no := l_step_txfrs_mig_tbl(i).batchstep_no;
1437: l_step_txfrs_tbl(i).transfer_step_no := l_step_txfrs_mig_tbl(i).transfer_step_no;
1438: l_step_txfrs_tbl(i).line_type := l_step_txfrs_mig_tbl(i).line_type;
1660: AND hmap.old_batch_id = v_old_batch_id;
1661:
1662: CURSOR Cur_verify_phantoms(v_batch_id NUMBER) IS
1663: SELECT 1
1664: FROM DUAL
1665: WHERE EXISTS (SELECT batch_id
1666: FROM gme_material_details
1667: WHERE batch_id = v_batch_id
1668: AND phantom_type > 0
2342: l_msg_name := 'GME_MIG_ITEM_NOT_TXNS_ENABLED';
2343: RAISE defined_error;
2344: END IF;
2345:
2346: SELECT mtl_material_transactions_s.NEXTVAL INTO gme_common_pvt.g_transaction_header_id FROM DUAL;
2347: IF (g_debug <= gme_debug.g_log_statement) THEN
2348: gme_debug.put_line('Transaction header ID = '||gme_common_pvt.g_transaction_header_id);
2349: END IF;
2350:
2790: RAISE defined_error;
2791: END IF;
2792:
2793: l_mmti_rec.transaction_date := l_date;
2794: SELECT mtl_material_transactions_s.NEXTVAL INTO gme_common_pvt.g_transaction_header_id FROM DUAL;
2795: IF (g_debug <= gme_debug.g_log_statement) THEN
2796: gme_debug.put_line('Transaction header ID for reservation is '||gme_common_pvt.g_transaction_header_id);
2797: END IF;
2798:
3492: END IF;
3493:
3494: /* Create a misc issue in original org/sub/loc and then a reciept in final org/sub/loc */
3495: SELECT mtl_material_transactions_s.NEXTVAL INTO
3496: l_issue_rec.transaction_interface_id FROM DUAL;
3497: l_issue_rec.transaction_header_id := gme_common_pvt.g_transaction_header_id;
3498: l_issue_rec.source_code := 'OPM_GME_MIGRATION';
3499: l_issue_rec.source_line_id := p_txn_rec.trans_id;
3500: l_issue_rec.source_header_id := p_txn_rec.doc_id;
3591: l_receipt_rec.transaction_date := l_date;
3592: END IF;
3593:
3594: SELECT mtl_material_transactions_s.NEXTVAL INTO
3595: l_receipt_rec.transaction_interface_id FROM DUAL;
3596:
3597: l_receipt_rec.organization_id := p_batch_org_id;
3598:
3599: /* We are creating a receipt txn in a sub which has the same name as org. This will always exist */