The following lines contain the word 'select', 'insert', 'update' or 'delete':
select wip_entity_type,
organization_id,
transaction_source_id,
repetitive_line_id,
inventory_item_id, --5
transaction_action_id,
primary_quantity, --qty is relative to inv, but is also relative to wip in this case (completions are positive)
transaction_quantity,
transaction_date,
completion_transaction_id, --10
kanban_card_id,
qa_collection_id,
operation_seq_num,
revision, --14
transaction_header_id,
transaction_status,
overcompletion_transaction_id,
overcompletion_primary_qty,
last_updated_by,
created_by,
nvl(content_lpn_id, lpn_id),
transaction_mode,
move_transaction_id,
material_allocation_temp_id
into l_cplRec.wipEntityType,
l_cplRec.orgID,
l_cplRec.wipEntityID,
l_cplRec.repLineID,
l_cplRec.itemID, --5
l_cplRec.txnActionID,
l_cplRec.priQty,
l_cplRec.txnQty,
l_cplRec.txnDate,
l_cplRec.cplTxnID, --10
l_cplRec.kanbanCardID,
l_cplRec.qaCollectionID,
l_cplRec.lastOpSeq,
l_cplRec.revision,--14
l_cplRec.txnHdrID,
l_cplRec.txnStatus,
l_cplRec.overCplTxnID,
l_cplRec.overCplPriQty,
l_cplRec.lastUpdBy,
l_cplRec.createdBy,
l_cplRec.lpnID,
l_cplRec.txnMode,
l_cplRec.movTxnID,
l_cplRec.mtlAlcTmpID
from mtl_material_transactions_temp
where transaction_temp_id = p_txnTmpID;
update mtl_material_transactions_temp
set overcompletion_transaction_id = wip_transactions_s.nextval
where transaction_temp_id = p_txnTmpID returning overcompletion_transaction_id into l_cplRec.overCplTxnID;
select primary_cost_method
into l_primaryCostMethod
from mtl_parameters
where organization_id = l_cplRec.orgID;
select sum(quantity_in_queue)
+ sum(quantity_running)
+ sum(quantity_waiting_to_move)
+ sum(quantity_rejected)
into l_remain_qty
from wip_operations
where wip_entity_id = p_cplRec.wipEntityID
and organization_id = p_cplRec.orgID;
select rowid,
quantity_completed,
start_quantity - quantity_scrapped - quantity_completed, --remaining qty to complete
serialization_start_op,
job_type,
date_completed
into l_rowid,
l_qtyCompleted,
l_qtyAvailToComplete,
x_serialStartOp,
l_jobType,
l_cplDate
from wip_discrete_jobs
where wip_entity_id = p_cplRec.wipEntityID
for update of quantity_completed nowait;
l_errMsg := 'Kanban update failed.'; --set message in case it fails
inv_kanban_pvt.UPDATE_CARD_SUPPLY_STATUS
(p_kanban_card_id => p_cplRec.kanbanCardID,
p_supply_status => inv_kanban_pvt.g_supply_status_full,
p_document_type => l_docType,
p_document_header_id => p_cplRec.wipEntityID,
p_document_detail_id => null,
p_replenish_quantity => p_cplRec.priQty,
x_return_status => x_returnStatus);
update wip_discrete_jobs --increase the qty completed
set quantity_completed = l_qtyCompleted + p_cplRec.priQty, --remember txn qty is negative for returns
date_completed = l_cplDate,
status_type = nvl(l_jobStatus, status_type),
last_updated_by = fnd_global.user_id,
last_update_date = sysdate,
request_id = fnd_global.conc_request_id,
program_application_id = fnd_global.prog_appl_id,
program_id = fnd_global.conc_program_id,
program_update_date = sysdate
where rowid = l_rowid;
select quantity_waiting_to_move, rowid
into l_toMoveQty, l_rowid
from wip_operations
where wip_entity_id = p_cplRec.wipEntityID
and operation_seq_num = p_cplRec.lastOpSeq
for update of quantity_waiting_to_move nowait;
update wip_operations --lower the quantity available to complete
set quantity_waiting_to_move = quantity_waiting_to_move - p_cplRec.priQty,
date_last_moved = decode(p_cplRec.txnActionID, wip_constants.cplassy_action, p_cplRec.txnDate, date_last_moved),
last_updated_by = fnd_global.user_id,
last_update_date = sysdate,
request_id = fnd_global.conc_request_id,
program_application_id = fnd_global.prog_appl_id,
program_id = fnd_global.conc_program_id,
program_update_date = sysdate
where rowid = l_rowid;
select WIP_ENTITY_NAME into l_job_name from wip_entities where WIP_ENTITY_ID = p_cplRec.wipEntityID;
select wrs.repetitive_schedule_id,
wrs.bom_revision,
wrs.daily_production_rate * wrs.processing_work_days,
wrs.quantity_completed,
wo.quantity_waiting_to_move,
wmat.primary_quantity,
rowidtochar(wrs.rowid),
rowidtochar(wo.rowid)
from wip_operations wo,
wip_repetitive_schedules wrs,
wip_mtl_allocations_temp wmat
where wrs.wip_entity_id = p_cplRec.wipEntityID
and wrs.line_id = p_cplRec.repLineID
and wrs.status_type in (wip_constants.released, wip_constants.comp_chrg)
and wrs.repetitive_schedule_id = wo.repetitive_schedule_id (+)
and wrs.wip_entity_id = wo.wip_entity_id (+)
and v_lastOpSeq = wo.operation_seq_num (+)
and wrs.repetitive_schedule_id = wmat.repetitive_schedule_id
and wmat.transaction_temp_id = p_txnTmpID
order by wrs.first_unit_start_date
for update of wo.quantity_completed, wrs.quantity_completed nowait;
inv_kanban_pvt.update_card_supply_status
(p_kanban_card_id => p_cplRec.kanbanCardID,
p_supply_status => inv_kanban_pvt.g_supply_status_full,
p_document_type => inv_kanban_pvt.g_doc_type_rep_schedule,
p_document_header_id => p_cplRec.wipEntityID,
p_document_detail_id => null,
p_replenish_quantity => p_cplRec.priQty,
x_return_status => x_returnStatus);
l_errMsg := 'Kanban update failed.'; --set message in case it fails
select nvl(sum(quantity_scrapped), 0)
into l_scrapQty
from wip_operations
where repetitive_schedule_id = l_schedRecTbl.schedID(i);
update wip_operations
set quantity_waiting_to_move = quantity_waiting_to_move - l_schedRecTbl.preAlcQty(i),
date_last_moved = sysdate,
last_updated_by = fnd_global.user_id,
last_update_date = sysdate,
request_id = fnd_global.conc_request_id,
program_application_id = fnd_global.prog_appl_id,
program_id = fnd_global.conc_program_id,
program_update_date = sysdate
where rowid = chartorowid(l_schedRecTbl.woRowID(i))
returning quantity_waiting_to_move into l_newSchedQty;
update wip_repetitive_schedules
set quantity_completed = quantity_completed + l_schedRecTbl.preAlcQty(i),
status_type = l_status,
last_updated_by = fnd_global.user_id,
last_update_date = sysdate,
request_id = fnd_global.conc_request_id,
program_application_id = fnd_global.prog_appl_id,
program_id = fnd_global.conc_program_id,
program_update_date = sysdate
where rowid = chartorowid(l_schedRecTbl.wrsRowID(i));
p_update_status => wip_constants.yes,
p_success_flag => l_rollFwdSuccess,
p_error_msg => l_errMsg);
insert into mtl_material_txn_allocations(transaction_id,
repetitive_schedule_id,
organization_id,
last_update_date,
last_updated_by,
creation_date,
created_by,
last_update_login,
primary_quantity,
transaction_quantity,
request_id,
program_application_id,
program_id,
transaction_date)
select p_cplRec.mtlAlcTmpID,
wmat.repetitive_schedule_id,
wmat.organization_id,
sysdate,
fnd_global.user_id,
sysdate,
fnd_global.user_id,
fnd_global.login_id,
wmat.primary_quantity,
wmat.transaction_quantity,
fnd_global.conc_request_id,
fnd_global.prog_appl_id,
fnd_global.conc_program_id,
wmat.transaction_date
from wip_mtl_allocations_temp wmat
where wmat.transaction_temp_id = p_txnTmpID;
wip_logger.log('inserted ' || SQL%ROWCOUNT || ' rows into MMTA', l_returnStatus);
delete wip_mtl_allocations_temp
where transaction_temp_id = p_txnTmpID;
wip_logger.log('deleted ' || SQL%ROWCOUNT || ' rows from WMAT', l_returnStatus);
select required_quantity
from wip_requirement_operations
where repetitive_schedule_id = v_schedID
for update of required_quantity nowait;
select required_quantity
from wip_requirement_operations
where wip_entity_id = v_wipEntityID
for update of required_quantity nowait;
wip_overcompletion.insert_oc_move_txn( p_primary_quantity => p_cplRec.overCplPriQty,
p_cpl_profile => wip_constants.online,
p_oc_txn_id => p_cplRec.overCplTxnID,
p_parent_cpl_txn_id => p_cplRec.cplTxnID,
p_first_schedule_id => l_firstSchedID,
p_user_id => p_cplRec.lastUpdBy, --fnd_global.user_id,
p_login_id => fnd_global.conc_login_id,
p_req_id => fnd_global.conc_request_id,
p_appl_id => fnd_global.prog_appl_id,
p_prog_id => fnd_global.conc_program_id,
p_child_txn_id => p_cplrec.movTxnID,
p_first_operation_seq_num => l_firstOpSeq,
p_err_mesg => l_errMsg);
l_errMsg := 'wip_overcompletion.insert_oc_move_txn: ' || l_errMsg;
p_insertAssy => fnd_api.g_true,
p_do_backflush => fnd_api.g_false,--backflush was already done
p_cmp_txn_id => null,
x_returnStatus => x_returnStatus);
update wip_requirement_operations
set required_quantity = round(required_quantity + p_cplRec.overCplPriQty * quantity_per_assembly, wip_constants.inv_max_precision)
where repetitive_schedule_id = l_lastSchedID;
update wip_requirement_operations
set required_quantity = round(required_quantity + p_cplRec.overCplPriQty * quantity_per_assembly, wip_constants.inv_max_precision)
where wip_entity_id = p_cplRec.wipEntityID
AND nvl(basis_type,1) <> WIP_CONSTANTS.LOT_BASED_MTL; /* LBM Project */
select wrs.repetitive_schedule_id repSchedID,
wrs.bom_revision bomRev,
nvl(wo.quantity_waiting_to_move,
((wrs.daily_production_rate * wrs.processing_work_days) - wrs.quantity_completed)) availQty,
nvl(sum(wmat.primary_quantity), 0) tempQty
from wip_operations wo,
wip_repetitive_schedules wrs,
wip_mtl_allocations_temp wmat
where wrs.wip_entity_id = v_wipEntityID
and wrs.line_id = v_repLineID
and wrs.date_released < v_txnDate
and wrs.status_type in (wip_constants.released, wip_constants.comp_chrg)
and wrs.repetitive_schedule_id = wo.repetitive_schedule_id (+)
and wrs.wip_entity_id = wo.wip_entity_id (+)
and v_lastOpSeq = wo.operation_seq_num (+)
and wrs.repetitive_schedule_id = wmat.repetitive_schedule_id (+)
group by wrs.repetitive_schedule_id,
wrs.bom_revision,
wo.quantity_waiting_to_move,
wrs.daily_production_rate,
wrs.processing_work_days,
wrs.quantity_completed,
wrs.first_unit_start_date
order by wrs.first_unit_start_date;
select wrs.repetitive_schedule_id repSchedID,
wrs.bom_revision bomRev,
wrs.quantity_completed availQty,
nvl(sum(wmat.primary_quantity), 0) tempQty
from wip_repetitive_schedules wrs,
wip_mtl_allocations_temp wmat
where wrs.wip_entity_id = v_wipEntityID
and wrs.line_id = v_repLineID
and wrs.date_released < v_txnDate
and wrs.status_type in (wip_constants.released, wip_constants.comp_chrg)
and wrs.repetitive_schedule_id = wmat.repetitive_schedule_id (+)
group by wrs.repetitive_schedule_id,
wrs.bom_revision,
wrs.daily_production_rate,
wrs.processing_work_days,
wrs.quantity_completed,
wrs.first_unit_start_date
order by wrs.first_unit_start_date desc;
select transaction_temp_id txnTmpID,
operation_seq_num lastOpSeq,
revision,
transaction_date txnDate,
primary_quantity priQty,
transaction_quantity txnQty,
overcompletion_primary_qty,
organization_id
from mtl_material_transactions_temp
where completion_transaction_id = p_cplTxnID
and transaction_header_id = p_txnHdrID
and transaction_source_id = p_wipEntityID
and transaction_source_type_id = 5
and transaction_action_id in (wip_constants.cplassy_action, wip_constants.retassy_action);
select transaction_interface_id,
operation_seq_num lastOpSeq,
revision,
transaction_date txnDate,
primary_quantity priQty,
transaction_quantity txnQty,
overcompletion_primary_qty,
organization_id
from mtl_transactions_interface
where completion_transaction_id = p_cplTxnID
and transaction_header_id = p_txnHdrID
and transaction_source_id = p_wipEntityID
and transaction_source_type_id = 5
and transaction_action_id in (wip_constants.cplassy_action, wip_constants.retassy_action);
select ((wrs.daily_production_rate * wrs.processing_work_days) - wrs.quantity_completed) - nvl(sum(wo.quantity_scrapped), 0)
into l_schedRecTbl.availQty(j)
from wip_repetitive_schedules wrs,
wip_operations wo
where wrs.wip_entity_id = p_wipEntityID
and wrs.repetitive_schedule_id = l_schedRecTbl.repSchedID(j)
and wrs.repetitive_schedule_id = wo.repetitive_schedule_id (+)
and wrs.wip_entity_id = wo.wip_entity_id (+)
group by wrs.daily_production_rate,
wrs.processing_work_days,
wrs.quantity_completed;
wip_logger.log('inserting into temp table; sched:' || l_schedRecTbl.repSchedID(j) || '; qty:' || l_schedQty, l_returnStatus);
insert into wip_mtl_allocations_temp
(transaction_temp_id,
completion_transaction_id,
repetitive_schedule_id,
organization_id,
last_update_date,
last_updated_by,
creation_date,
created_by,
last_update_login,
request_id,
program_application_id,
program_id,
program_update_date,
transaction_quantity,
primary_quantity,
transaction_date)
values
(l_txnRecTbl.txnID(i),
p_cplTxnID,
l_schedRecTbl.repSchedID(j),
l_txnRecTbl.orgID(i),
sysdate,
fnd_global.user_id,
sysdate,
fnd_global.user_id,
fnd_global.login_id,
fnd_global.conc_request_id,
fnd_global.prog_appl_id,
fnd_global.conc_program_id,
sysdate,
round(l_txnRecTbl.txnQty(i) * l_schedQty/l_txnRecTbl.priQty(i), wip_constants.inv_max_precision), --% of qty completed * txn Qty
l_schedQty,
l_txnRecTbl.txnDate(i));
update wip_mtl_allocations_temp
set transaction_quantity = transaction_quantity +
(transaction_quantity/primary_quantity * l_remainingQty),
primary_quantity = primary_quantity + l_remainingQty
where transaction_temp_id = l_txnRecTbl.txnID(i)
and repetitive_schedule_id = l_lastSchedID;
wip_logger.log('update failed. inserting new row', l_returnStatus);
* , so we have to insert a value into this column. This bug only
* occur when overcompletion and available quantity is zero.
*/
insert into wip_mtl_allocations_temp
(transaction_temp_id,
completion_transaction_id,
repetitive_schedule_id,
organization_id,
last_update_date,
last_updated_by,
creation_date,
created_by,
last_update_login,
request_id,
program_application_id,
program_id,
program_update_date,
transaction_quantity,
primary_quantity,
transaction_date)
values
(l_txnRecTbl.txnID(i),
p_cplTxnID,
l_lastSchedID,
l_txnRecTbl.orgID(i),
sysdate,
fnd_global.user_id,
sysdate,
fnd_global.user_id,
fnd_global.login_id,
fnd_global.conc_request_id,
fnd_global.prog_appl_id,
fnd_global.conc_program_id,
sysdate,
l_txnRecTbl.txnQty(i),
l_txnRecTbl.priQty(i),
l_txnRecTbl.txnDate(i));
select wrs.repetitive_schedule_id,
((wrs.daily_production_rate * wrs.processing_work_days) - wrs.quantity_completed) startQty,
wrs.quantity_completed cplQty,
sum(wmat.primary_quantity) tempQty
from wip_repetitive_schedules wrs,
wip_mtl_allocations_temp wmat
where wrs.wip_entity_id = p_wipEntityID
and wrs.line_id = p_repLineID
and wrs.status_type in (wip_constants.released, wip_constants.comp_chrg)
and wrs.repetitive_schedule_id = wmat.repetitive_schedule_id (+)
group by wrs.repetitive_schedule_id,
wrs.bom_revision,
wrs.daily_production_rate,
wrs.processing_work_days,
wrs.quantity_completed,
wrs.first_unit_start_date
order by wrs.first_unit_start_date;
insert into wip_mtl_allocations_temp
(transaction_temp_id,
repetitive_schedule_id,
organization_id,
last_update_date,
last_updated_by,
creation_date,
created_by,
last_update_login,
request_id,
program_application_id,
program_id,
program_update_date,
transaction_quantity,
primary_quantity,
transaction_date)
select mmtt.transaction_temp_id,
l_schedID,
mmtt.organization_id,
sysdate,
fnd_global.user_id,
sysdate,
fnd_global.user_id,
fnd_global.login_id,
fnd_global.conc_request_id,
fnd_global.prog_appl_id,
fnd_global.conc_program_id,
sysdate,
mmtt.transaction_quantity,
mmtt.primary_quantity,
mmtt.transaction_date
from mtl_material_transactions_temp mmtt
where mmtt.transaction_header_id = p_txnHdrID
and mmtt.completion_transaction_id = p_cplTxnID
and mmtt.transaction_action_id = wip_constants.retassy_action;
insert into wip_mtl_allocations_temp
(transaction_temp_id,
repetitive_schedule_id,
organization_id,
last_update_date,
last_updated_by,
creation_date,
created_by,
last_update_login,
request_id,
program_application_id,
program_id,
program_update_date,
transaction_quantity,
primary_quantity,
transaction_date)
select mti.transaction_interface_id,
l_schedID,
mti.organization_id,
sysdate,
fnd_global.user_id,
sysdate,
fnd_global.user_id,
fnd_global.login_id,
fnd_global.conc_request_id,
fnd_global.prog_appl_id,
fnd_global.conc_program_id,
sysdate,
mti.transaction_quantity,
mti.primary_quantity,
mti.transaction_date
from mtl_transactions_interface mti
where mti.transaction_header_id = p_txnHdrID
and mti.completion_transaction_id = p_cplTxnID
and mti.transaction_action_id = wip_constants.retassy_action;
wip_logger.log('inserted ' || SQL%ROWCOUNT || ' rows', l_returnStatus);
SELECT transaction_source_id wip_entity_id,
organization_id org_id,
inventory_item_id item_id,
transaction_action_id action_id,
primary_quantity primary_qty,
transaction_quantity txn_qty,
transaction_date txn_date,
completion_transaction_id cmp_txn_id,
overcompletion_transaction_id oc_txn_id,
kanban_card_id,
qa_collection_id,
operation_seq_num op_seq_num,
revision,
overcompletion_primary_qty oc_primary_qty,
last_updated_by,
created_by
FROM mtl_material_transactions_temp
WHERE transaction_temp_id = p_interface_id;
SELECT COUNT(1)
INTO l_mti_lot_rec
FROM mtl_transaction_lots_interface mtli,
mtl_transactions_interface mti
WHERE mtli.transaction_interface_id = mti.transaction_interface_id
AND mti.transaction_header_id = p_mtl_header_id
AND mti.transaction_action_id in (WIP_CONSTANTS.RETASSY_ACTION,WIP_CONSTANTS.CPLASSY_ACTION)
and MTI.TRANSACTION_TYPE_ID in (WIP_CONSTANTS.RETASSY_TYPE,WIP_CONSTANTS.CPLASSY_TYPE)
AND mti.transaction_source_type_id = TPS_INV_JOB_OR_SCHED ;
UPDATE mtl_transaction_lots_interface mtli
SET lot_expiration_date =
(SELECT MIN(mln.expiration_date)
FROM mtl_transactions_interface mti,
mtl_system_items msi,
mtl_lot_numbers mln
WHERE mti.organization_id = msi.organization_id
AND mti.inventory_item_id = msi.inventory_item_id
AND mti.transaction_header_id = p_mtl_header_id
AND mti.transaction_action_id in (WIP_CONSTANTS.RETASSY_ACTION,WIP_CONSTANTS.CPLASSY_ACTION)
AND mti.transaction_type_id in (WIP_CONSTANTS.RETASSY_TYPE,WIP_CONSTANTS.CPLASSY_TYPE)
AND mti.transaction_source_type_id = TPS_INV_JOB_OR_SCHED
AND mti.wip_entity_type =WIP_CONSTANTS.DISCRETE
AND msi.lot_control_code = WIP_CONSTANTS.LOT
AND mln.lot_number = mtli.lot_number
AND mln.inventory_item_id = mti.inventory_item_id
AND mln.organization_id = mti.organization_id)
WHERE mtli.transaction_interface_id IN
(SELECT mti.transaction_interface_id
FROM mtl_transactions_interface mti,
mtl_system_items msi
WHERE mti.organization_id = msi.organization_id
AND mti.inventory_item_id = msi.inventory_item_id
AND mti.transaction_header_id = p_mtl_header_id
AND mti.transaction_action_id in (WIP_CONSTANTS.RETASSY_ACTION,WIP_CONSTANTS.CPLASSY_ACTION)
AND mti.transaction_type_id in (WIP_CONSTANTS.RETASSY_TYPE,WIP_CONSTANTS.CPLASSY_TYPE)
AND mti.transaction_source_type_id = TPS_INV_JOB_OR_SCHED
AND msi.lot_control_code = WIP_CONSTANTS.LOT
AND mti.wip_entity_type = WIP_CONSTANTS.DISCRETE
)
AND mtli.lot_expiration_date is null;
fnd_message.set_name('WIP', 'WIP_UPDATED_ROWS');
/* Removed group by and modIFied select and where conditions to avoid
oracle error 1427. See bugs 866408 and 938422. */
UPDATE mtl_transaction_lots_interface mtli
SET lot_expiration_date =
(SELECT mti.transaction_date + NVL(msi.shelf_life_days,0)
FROM mtl_transactions_interface mti,
mtl_system_items msi
WHERE mti.transaction_header_id =p_mtl_header_id
AND mti.transaction_action_id in (WIP_CONSTANTS.RETASSY_ACTION,WIP_CONSTANTS.CPLASSY_ACTION)
AND mti.transaction_type_id in (WIP_CONSTANTS.RETASSY_TYPE,WIP_CONSTANTS.CPLASSY_TYPE)
AND mti.transaction_source_type_id = TPS_INV_JOB_OR_SCHED
AND mti.wip_entity_type =WIP_CONSTANTS.DISCRETE
AND msi.lot_control_code = WIP_CONSTANTS.LOT
AND msi.organization_id = mti.organization_id
AND msi.inventory_item_id = mti.inventory_item_id
AND msi.shelf_life_code = WIP_CONSTANTS.SHELF_LIFE
AND mtli.transaction_interface_id =
mti.transaction_interface_id)
WHERE mtli.lot_expiration_date IS NULL
AND mtli.transaction_interface_id IN
(SELECT mti.transaction_interface_id
FROM mtl_transactions_interface mti,
mtl_system_items msi
WHERE mti.organization_id = msi.organization_id
AND mti.inventory_item_id = msi.inventory_item_id
AND mti.transaction_header_id = p_mtl_header_id
AND mti.transaction_action_id in (WIP_CONSTANTS.RETASSY_ACTION,WIP_CONSTANTS.CPLASSY_ACTION)
AND mti.transaction_type_id in (WIP_CONSTANTS.RETASSY_TYPE,WIP_CONSTANTS.CPLASSY_TYPE)
AND mti.transaction_source_type_id = TPS_INV_JOB_OR_SCHED
AND mti.wip_entity_type =WIP_CONSTANTS.DISCRETE
AND msi.lot_control_code = WIP_CONSTANTS.LOT);
fnd_message.set_name('WIP', 'WIP_UPDATED_ROWS');
SELECT primary_cost_method
INTO l_cost_method
FROM mtl_parameters
WHERE organization_id = p_org_id;
l_oc_rec.lastUpdBy := l_cmp_txn.last_updated_by;
wip_utilities.update_serial(p_serial_number => p_assySerial,
p_inventory_item_id => l_cmp_txn.item_id,
p_organization_id => l_cmp_txn.org_id,
p_wip_entity_id => l_cmp_txn.wip_entity_id,
p_operation_seq_num => l_op_seq,
p_intraoperation_step_type => l_step,
x_return_status => x_returnStatus);