[Home] [Help]
1578: application_short_name => 'MSC',
1579: statement_type => AD_DDL.CREATE_INDEX,
1580: statement =>
1581: 'create index MSC_ST_JOB_OP_NETWORKS_N1_'||v_instance_code
1582: ||' on MSC_ST_JOB_OPERATION_NETWORKS '
1583: ||'(SR_INSTANCE_CODE, WIP_ENTITY_NAME, FROM_OPERATION_SEQ_CODE, TO_OPERATION_SEQ_CODE) '
1584: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
1585: object_name =>'MSC_ST_JOB_OP_NETWORKS_N1_'||v_instance_code);
1586: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_DEBUG_1,'Created Index MSC_ST_JOB_OP_NETWORKS_N1_'||v_instance_code);
45868:
45869:
45870: CURSOR c2(p_batch_id NUMBER) IS
45871: SELECT rowid
45872: FROM msc_st_job_operation_networks
45873: WHERE process_flag IN (G_IN_PROCESS,G_ERROR_FLG)
45874: AND sr_instance_code = v_instance_code
45875: AND batch_id = p_batch_id;
45876:
45906: AND deleted_flag = SYS_NO;
45907:
45908: BEGIN
45909:
45910: -- -- Pre processing for MSC_ST_JOB_OPERATION_NETWORKS
45911: --Duplicate records check for the records whose source is XML
45912:
45913: lv_return := MSC_ST_UTIL.GET_ERROR_MESSAGE
45914: (p_app_short_name => 'MSC',
45922:
45923: v_sql_stmt := 1;
45924:
45925: lv_sql_stmt :=
45926: 'UPDATE msc_st_job_operation_networks mson1 '
45927: ||' SET process_flag = '||G_ERROR_FLG||','
45928: ||' error_text = '||''''||lv_message_text||''''
45929: ||' WHERE message_id < ( SELECT max(message_id) '
45930: ||' FROM msc_st_job_operation_networks mson2'
45926: 'UPDATE msc_st_job_operation_networks mson1 '
45927: ||' SET process_flag = '||G_ERROR_FLG||','
45928: ||' error_text = '||''''||lv_message_text||''''
45929: ||' WHERE message_id < ( SELECT max(message_id) '
45930: ||' FROM msc_st_job_operation_networks mson2'
45931: ||' WHERE mson2.wip_entity_name = mson1.wip_entity_name'
45932: ||' AND mson2.organization_code = mson1.organization_code'
45933: ||' AND mson2.from_operation_seq_code = mson1.from_operation_seq_code'
45934: ||' AND mson2.to_operation_seq_code = mson1.to_operation_seq_code'
45964:
45965: v_sql_stmt := 2;
45966:
45967: lv_sql_stmt :=
45968: 'UPDATE msc_st_job_operation_networks mson1'
45969: ||' SET process_flag = '||G_ERROR_FLG||','
45970: ||' error_text = '||''''||lv_message_text||''''
45971: ||' WHERE EXISTS ( SELECT 1 '
45972: ||' FROM msc_st_job_operation_networks mson2'
45968: 'UPDATE msc_st_job_operation_networks mson1'
45969: ||' SET process_flag = '||G_ERROR_FLG||','
45970: ||' error_text = '||''''||lv_message_text||''''
45971: ||' WHERE EXISTS ( SELECT 1 '
45972: ||' FROM msc_st_job_operation_networks mson2'
45973: ||' WHERE mson2.wip_entity_name = mson1.wip_entity_name'
45974: ||' AND mson2.organization_code = mson1.organization_code'
45975: ||' AND mson2.from_operation_seq_code = mson1.from_operation_seq_code'
45976: ||' AND mson2.to_operation_seq_code = mson1.to_operation_seq_code'
46027:
46028: v_sql_stmt := 4;
46029:
46030: lv_sql_stmt :=
46031: ' UPDATE msc_st_job_operation_networks '
46032: ||' SET batch_id = :lv_batch_id'
46033: ||' WHERE process_flag IN ('||G_IN_PROCESS||','||G_ERROR_FLG||')'
46034: ||' AND sr_instance_code = :v_instance_code'
46035: ||' AND NVL(batch_id,'||NULL_VALUE||') = '||NULL_VALUE
46048:
46049: v_sql_stmt := 5;
46050:
46051: FORALL j IN lb_rowid.FIRST..lb_rowid.LAST
46052: UPDATE msc_st_job_operation_networks
46053: SET st_transaction_id = msc_st_job_op_networks_s.NEXTVAL,
46054: refresh_id = v_refresh_id,
46055: last_update_date = v_current_date,
46056: last_updated_by = v_current_user,
46074: END IF;
46075:
46076: v_sql_stmt := 6;
46077: lv_sql_stmt :=
46078: 'UPDATE msc_st_job_operation_networks'
46079: ||' SET error_text = '||''''||lv_message_text||''''||','
46080: ||' process_flag = '||G_ERROR_FLG
46081: ||' WHERE NVL(wip_entity_name,'||''''||NULL_CHAR||''''||') '
46082: ||' = '||''''||NULL_CHAR||''''
46098: p_error_code => 'MSC_PP_NO_DELETION',
46099: p_message_text => lv_message_text,
46100: p_error_text => lv_error_text,
46101: p_token1 => 'TABLE_NAME',
46102: p_token_value1 => 'MSC_ST_JOB_OPERATION_NETWORKS');
46103:
46104: IF lv_return <> 0 THEN
46105: RAISE ex_logging_err;
46106: END IF;
46107:
46108: --Deletion is not allowed on this table.
46109: v_sql_stmt := 06;
46110: lv_sql_stmt :=
46111: ' UPDATE msc_st_job_operation_networks '
46112: ||' SET process_flag ='||G_ERROR_FLG||','
46113: ||' error_text = '||''''||lv_message_text||''''
46114: ||' WHERE deleted_flag = '||SYS_YES
46115: ||' AND process_flag = '||G_IN_PROCESS
46141: lv_where_str :=
46142: ' AND NVL(deleted_flag,'||NULL_VALUE||') NOT IN(1,2)';
46143:
46144: lv_return := MSC_ST_UTIL.LOG_ERROR
46145: (p_table_name => 'MSC_ST_JOB_OPERATION_NETWORKS',
46146: p_instance_code => v_instance_code,
46147: p_row => lv_column_names,
46148: p_severity => G_SEV_WARNING,
46149: p_message_text => lv_message_text,
46174: -- Error out the records whose PLANNING_PCT is NULL
46175:
46176: v_sql_stmt := 7;
46177: lv_sql_stmt :=
46178: 'UPDATE msc_st_job_operation_networks'
46179: ||' SET process_flag ='||G_ERROR_FLG||','
46180: ||' error_text = '||''''||lv_message_text||''''
46181: ||' WHERE NVL(PLANNING_PCT,'||NULL_VALUE||') = '||NULL_VALUE
46182: ||' AND sr_instance_code = :v_instance_code'
46204: -- Error out the records where RECOMMENDED is not 'Y' or 'N'
46205:
46206: v_sql_stmt := 7;
46207: lv_sql_stmt :=
46208: 'UPDATE msc_st_job_operation_networks'
46209: ||' SET process_flag ='||G_ERROR_FLG||','
46210: ||' error_text = '||''''||lv_message_text||''''
46211: ||' WHERE recommended NOT IN (''Y'', ''N'')'
46212: ||' AND sr_instance_code = :v_instance_code'
46234: -- Error out the records whose Assembly Name is NULL
46235:
46236: v_sql_stmt := 8;
46237: lv_sql_stmt :=
46238: 'UPDATE msc_st_job_operation_networks'
46239: ||' SET process_flag ='||G_ERROR_FLG||','
46240: ||' error_text = '||''''||lv_message_text||''''
46241: ||' WHERE NVL(assembly_name,'||''''||NULL_CHAR||''''||') '
46242: ||' = '||''''||NULL_CHAR||''''
46254:
46255: v_sql_stmt := 9;
46256:
46257: lv_sql_stmt :=
46258: 'UPDATE msc_st_job_operation_networks '
46259: ||' SET routing_name = assembly_name'
46260: ||' WHERE sr_instance_code = :v_instance_code'
46261: ||' AND process_flag = '||G_IN_PROCESS
46262: ||' AND NVL(routing_name,'||''''||NULL_CHAR||''''||') '
46281: END IF;
46282:
46283: --Derive Organization_id
46284: lv_return := MSC_ST_UTIL.DERIVE_PARTNER_ORG_ID
46285: (p_table_name => 'MSC_ST_JOB_OPERATION_NETWORKS',
46286: p_org_partner_name => 'ORGANIZATION_CODE',
46287: p_org_partner_id => 'ORGANIZATION_ID',
46288: p_instance_code => v_instance_code,
46289: p_partner_type => G_ORGANIZATION,
46300:
46301: --Deriving wip_entity_id
46302: v_sql_stmt := 10;
46303: lv_sql_stmt :=
46304: 'UPDATE msc_st_job_operation_networks mss'
46305: ||' SET wip_entity_id = (SELECT local_id'
46306: ||' FROM msc_local_id_supply mls'
46307: ||' WHERE mls.char4 = mss.wip_entity_name'
46308: ||' AND mls.char3 = mss.organization_code'
46333: ||'ORGANIZATION_CODE,WIP_ENTITY_NAME',
46334: p_token2 => 'MASTER_TABLE',
46335: p_token_value2 => 'MSC_ST_SUPPLIES',
46336: p_token3 => 'CHILD_TABLE' ,
46337: p_token_value3 => 'MSC_ST_JOB_OPERATION_NETWORKS' );
46338:
46339: IF lv_return <> 0 THEN
46340: RAISE ex_logging_err;
46341: END IF;
46344: -- Error out the records if WIP_ENTITY_ID NULL
46345:
46346: v_sql_stmt := 11;
46347: lv_sql_stmt:=
46348: 'UPDATE msc_st_job_operation_networks msrr'
46349: ||' SET process_flag ='||G_ERROR_FLG||','
46350: ||' error_text = '||''''||lv_message_text||''''
46351: ||' WHERE NVL(wip_entity_id,'||NULL_VALUE||') = '||NULL_VALUE
46352: ||' AND sr_instance_code = :v_instance_code'
46376: -- Error out the records whose from_operation_seq_code or to_operation_seq_code is NULL
46377:
46378: v_sql_stmt := 12;
46379: lv_sql_stmt :=
46380: 'UPDATE msc_st_job_operation_networks'
46381: ||' SET process_flag ='||G_ERROR_FLG||','
46382: ||' error_text = '||''''||lv_message_text||''''
46383: ||' WHERE ( NVL(from_operation_seq_code,'||''''||NULL_CHAR||''''||') = '||''''||NULL_CHAR||''''
46384: ||' OR NVL(to_operation_seq_code,'||''''||NULL_CHAR||''''||') = '||''''||NULL_CHAR||''''||') '
46407: -- Error out the records whose from_operation_seq_code is same as to_op_seq_code
46408:
46409: v_sql_stmt := 13;
46410: lv_sql_stmt :=
46411: 'UPDATE msc_st_job_operation_networks'
46412: ||' SET process_flag ='||G_ERROR_FLG||','
46413: ||' error_text = '||''''||lv_message_text||''''
46414: ||' WHERE NVL(to_operation_seq_code,'||''''||NULL_CHAR||''''||') = NVL(from_operation_seq_code,'||''''||NULL_CHAR||''''||')'
46415: ||' AND sr_instance_code = :v_instance_code'
46434: ||'ORGANIZATION_CODE,ROUTING_NAME',
46435: p_token2 => 'MASTER_TABLE',
46436: p_token_value2 => 'MSC_ST_ROUTINGS',
46437: p_token3 => 'CHILD_TABLE' ,
46438: p_token_value3 => 'MSC_ST_JOB_OPERATION_NETWORKS' );
46439:
46440: IF lv_return <> 0 THEN
46441: RAISE ex_logging_err;
46442: END IF;
46444: -- Derive the ROUTING_SEQUENCE_ID from LOCAL ID table
46445:
46446: lv_return :=
46447: MSC_ST_UTIL.DERIVE_ROUTING_SEQUENCE_ID
46448: (p_table_name => 'MSC_ST_JOB_OPERATION_NETWORKS',
46449: p_rtg_col_name => 'ROUTING_NAME',
46450: p_rtg_col_id => 'ROUTING_SEQUENCE_ID',
46451: p_instance_code => v_instance_code,
46452: p_severity => G_SEV_ERROR,
46481: lv_where_str :=
46482: ' AND NVL(from_op_effectivity_date,SYSDATE-36500 ) = SYSDATE-36500 ' ;
46483:
46484: lv_return := MSC_ST_UTIL.LOG_ERROR
46485: (p_table_name => 'MSC_ST_JOB_OPERATION_NETWORKS',
46486: p_instance_code => v_instance_code,
46487: p_row => lv_column_names,
46488: p_severity => G_SEV_WARNING,
46489: p_message_text => lv_message_text,
46519: lv_where_str :=
46520: ' AND NVL(to_op_effectivity_date,SYSDATE-36500 ) = SYSDATE-36500 ' ;
46521:
46522: lv_return := MSC_ST_UTIL.LOG_ERROR
46523: (p_table_name => 'MSC_ST_JOB_OPERATION_NETWORKS',
46524: p_instance_code => v_instance_code,
46525: p_row => lv_column_names,
46526: p_severity => G_SEV_WARNING,
46527: p_message_text => lv_message_text,
46539: -- Derive from_op_seq_id, from_op_seq_num
46540:
46541: v_sql_stmt := 16;
46542: lv_sql_Stmt :=
46543: 'UPDATE msc_st_job_operation_networks mson'
46544: ||' SET (from_op_seq_id, from_op_seq_num) = (SELECT local_id, number1'
46545: ||' FROM msc_local_id_setup mlis'
46546: ||' WHERE mlis.char1 = mson.sr_instance_code'
46547: ||' AND NVL(mlis.char2,'||''''||NULL_CHAR||''''||') '
46582: -- Error out the records whose from_op_seq_id, from _op_seq_num is NULL
46583:
46584: v_sql_stmt := 17;
46585: lv_sql_stmt :=
46586: 'UPDATE msc_st_job_operation_networks'
46587: ||' SET process_flag ='||G_ERROR_FLG||','
46588: ||' error_text = '||''''||lv_message_text||''''
46589: ||' WHERE (NVL(from_op_seq_id,'||NULL_VALUE||') ='||NULL_VALUE
46590: ||' OR NVL(from_op_seq_num,'||NULL_VALUE||') ='||NULL_VALUE||')'
46601: -- Derive to_op_seq_id, to_op_seq_num
46602:
46603: v_sql_stmt := 18;
46604: lv_sql_Stmt :=
46605: 'UPDATE msc_st_job_operation_networks mson'
46606: ||' SET (to_op_seq_id, to_op_seq_num) = (SELECT local_id, number1'
46607: ||' FROM msc_local_id_setup mlis'
46608: ||' WHERE mlis.char1 = mson.sr_instance_code'
46609: ||' AND NVL(mlis.char2,'||''''||NULL_CHAR||''''||') '
46644: -- Error out the records whose to_op_seq_id, to_op_seq_num is NULL
46645:
46646: v_sql_stmt := 19;
46647: lv_sql_stmt :=
46648: 'UPDATE msc_st_job_operation_networks'
46649: ||' SET process_flag ='||G_ERROR_FLG||','
46650: ||' error_text = '||''''||lv_message_text||''''
46651: ||' WHERE (NVL(to_op_seq_id,'||NULL_VALUE||') ='||NULL_VALUE
46652: ||' OR NVL(to_op_seq_num,'||NULL_VALUE||') ='||NULL_VALUE||')'
46679: lv_where_str :=
46680: ' AND NVL(transition_type,'||NULL_VALUE||') NOT IN (1,2)';
46681:
46682: lv_return := MSC_ST_UTIL.LOG_ERROR
46683: (p_table_name => 'MSC_ST_JOB_OPERATION_NETWORKS',
46684: p_instance_code => v_instance_code,
46685: p_row => lv_column_names,
46686: p_severity => G_SEV_WARNING,
46687: p_message_text => lv_message_text,
46703: (ERRBUF => lv_error_text,
46704: RETCODE => lv_return,
46705: pBatchID => lv_batch_id,
46706: pInstanceCode => v_instance_code,
46707: pEntityName => 'MSC_ST_JOB_OPERATION_NETWORKS',
46708: pInstanceID => v_instance_id);
46709:
46710: IF NVL(lv_return,0) <> 0 THEN
46711: RAISE ex_logging_err;
46731: END IF;
46732:
46733: v_sql_stmt := 21;
46734: lv_sql_stmt :=
46735: 'UPDATE msc_st_job_operation_networks mson1'
46736: ||' SET process_flag = '||G_ERROR_FLG||','
46737: ||' error_text = '||''''||lv_message_text||''''
46738: ||' WHERE 1 < ( SELECT COUNT(*) '
46739: ||' FROM msc_st_job_operation_networks mson2'
46735: 'UPDATE msc_st_job_operation_networks mson1'
46736: ||' SET process_flag = '||G_ERROR_FLG||','
46737: ||' error_text = '||''''||lv_message_text||''''
46738: ||' WHERE 1 < ( SELECT COUNT(*) '
46739: ||' FROM msc_st_job_operation_networks mson2'
46740: ||' WHERE mson2.wip_entity_name = mson1.wip_entity_name'
46741: ||' AND mson2.organization_code = mson1.organization_code'
46742: ||' AND mson2.from_operation_seq_code = mson1.from_operation_seq_code'
46743: ||' AND mson2.sr_instance_code = mson1.sr_instance_code'
46774: END IF;
46775:
46776: v_sql_stmt := 22;
46777: lv_sql_stmt :=
46778: 'UPDATE msc_st_job_operation_networks mson1'
46779: ||' SET process_flag = '||G_ERROR_FLG||','
46780: ||' error_text = '||''''||lv_message_text||''''
46781: ||' WHERE 100 <> ( SELECT SUM(planning_pct) '
46782: ||' FROM msc_st_job_operation_networks mson2'
46778: 'UPDATE msc_st_job_operation_networks mson1'
46779: ||' SET process_flag = '||G_ERROR_FLG||','
46780: ||' error_text = '||''''||lv_message_text||''''
46781: ||' WHERE 100 <> ( SELECT SUM(planning_pct) '
46782: ||' FROM msc_st_job_operation_networks mson2'
46783: ||' WHERE mson2.wip_entity_name = mson1.wip_entity_name'
46784: ||' AND mson2.organization_code = mson1.organization_code'
46785: ||' AND mson2.from_operation_seq_code = mson1.from_operation_seq_code'
46786: ||' AND mson2.sr_instance_code = mson1.sr_instance_code'
46799: EXECUTE IMMEDIATE lv_sql_stmt USING v_instance_code;
46800:
46801: -- Set the process flag as Valid and derive sr_instance_id
46802: lv_return :=
46803: MSC_ST_UTIL.SET_PROCESS_FLAG(p_table_name => 'MSC_ST_JOB_OPERATION_NETWORKS',
46804: p_instance_id => v_instance_id,
46805: p_instance_code => v_instance_code,
46806: p_process_flag => G_VALID,
46807: p_error_text => lv_error_text,
46813:
46814: -- At the end calling the LOG_ERROR for logging all errored out records
46815:
46816: lv_return :=
46817: MSC_ST_UTIL.LOG_ERROR(p_table_name => 'MSC_ST_JOB_OPERATION_NETWORKS',
46818: p_instance_code => v_instance_code,
46819: p_row => lv_column_names,
46820: p_severity => G_SEV_ERROR,
46821: p_message_text => NULL,
47145: ||'ORGANIZATION_CODE,WIP_ENTITY_NAME',
47146: p_token2 => 'MASTER_TABLE',
47147: p_token_value2 => 'MSC_ST_SUPPLIES',
47148: p_token3 => 'CHILD_TABLE' ,
47149: p_token_value3 => 'MSC_ST_JOB_OPERATION_NETWORKS' );
47150:
47151: IF lv_return <> 0 THEN
47152: RAISE ex_logging_err;
47153: END IF;
50856: prec.internal_repair_flag:=SYS_YES;
50857: prec.external_repair_flag:=SYS_YES;
50858: End IF;
50859:
50860: lv_count:= SET_IN_PROCESS (p_table_name => 'MSC_ST_JOB_OPERATION_NETWORKS');
50861: IF lv_count > 0 Then
50862: prec.wip_flag:= SYS_YES;
50863: End IF;
50864: lv_count:= SET_IN_PROCESS (p_table_name => 'MSC_ST_JOB_OPERATIONS');