[Home] [Help]
103: end if;
104:
105: end prepare_error_message_table;
106:
107: procedure get_repln_rec(l_interface_rec IN csd_repairs_interface%rowtype,
108: lx_repln_rec OUT NOCOPY csd_repairs_pub.repln_rec_type);
109:
110: procedure get_repln_rec(l_interface_rec IN csd_repairs_interface%rowtype,
111: lx_repln_rec OUT NOCOPY csd_repairs_pub.repln_rec_type)
106:
107: procedure get_repln_rec(l_interface_rec IN csd_repairs_interface%rowtype,
108: lx_repln_rec OUT NOCOPY csd_repairs_pub.repln_rec_type);
109:
110: procedure get_repln_rec(l_interface_rec IN csd_repairs_interface%rowtype,
111: lx_repln_rec OUT NOCOPY csd_repairs_pub.repln_rec_type)
112: is
113: begin
114:
211:
212: -- get the repair line ids
213: select repair_line_id
214: bulk collect into l_repair_line_ids
215: from csd_repairs_interface
216: where group_id = p_group_id
217: and processing_phase = 2;
218:
219: if l_repair_line_ids.count > 0 then
1549:
1550: /******************************************************************************/
1551: /* Procedure Name: mass_create_repair_orders_cp */
1552: /* Description: The concurrent wrapper to process the records from */
1553: /* csd_repairs_interface table. The API does minimal validation and then */
1554: /* calls create_sr_repair_order in a loop. */
1555: /******************************************************************************/
1556: procedure mass_create_repair_orders_cp(errbuf out nocopy varchar2,
1557: retcode out nocopy varchar2,
1559: p_group_id in number
1560: )
1561: is
1562: lc_api_name varchar2(100) := 'csd_repair_manager_util.mass_create_repair_orders_cp';
1563: --l_interface_rec_type csd.csd_repairs_interface%rowtype;
1564: type l_interface_tbl_type is table of csd_repairs_interface%rowtype index by binary_integer;
1565: --type repln_tbl_type is table of csd_repairs_pub.repln_rec_type;
1566: l_repln_tbl csd_repairs_pub.repln_tbl_type;
1567: l_interface_tbl l_interface_tbl_type;
1560: )
1561: is
1562: lc_api_name varchar2(100) := 'csd_repair_manager_util.mass_create_repair_orders_cp';
1563: --l_interface_rec_type csd.csd_repairs_interface%rowtype;
1564: type l_interface_tbl_type is table of csd_repairs_interface%rowtype index by binary_integer;
1565: --type repln_tbl_type is table of csd_repairs_pub.repln_rec_type;
1566: l_repln_tbl csd_repairs_pub.repln_tbl_type;
1567: l_interface_tbl l_interface_tbl_type;
1568: l_sr_tbl sr_tbl_type;
1591: 'Begin processing for group_id ='||p_group_id||' p_one_sr_per_group '||p_one_sr_per_group);
1592: END IF;
1593:
1594: -- we will generate the transaction ids to identify each row.
1595: update csd_repairs_interface set transaction_id = csd_repairs_interface_s2.nextval
1596: where group_id = p_group_id;
1597:
1598: select *
1599: bulk collect into l_interface_tbl
1596: where group_id = p_group_id;
1597:
1598: select *
1599: bulk collect into l_interface_tbl
1600: from csd_repairs_interface
1601: where group_id = p_group_id
1602: and processing_phase = 1;
1603:
1604: -- mark all the records as in progress for this group.
1602: and processing_phase = 1;
1603:
1604: -- mark all the records as in progress for this group.
1605:
1606: update csd_repairs_interface set processing_phase = 2
1607: where group_id = p_group_id;
1608:
1609: -- we will commit the changes here. So that any subsequent reads will not pick up these records.
1610: commit;
1632: l_sr_tbl(i).create_sr_flag := 'N';
1633: exception
1634: when no_data_found then
1635: -- the passed incident id is invalid. skip the record.
1636: update csd_repairs_interface set processing_phase = 3
1637: where transaction_id = l_interface_tbl(i).transaction_id;
1638: l_continue_further := false;
1639: end;
1640:
1641: elsif l_interface_tbl(i).sr_incident_id is null then
1642: if not (l_interface_tbl(i).sr_account_id is not null and
1643: l_interface_tbl(i).sr_party_id is not null ) then
1644: -- not enough data to create a new SR. So we cannot create RO for this rec.
1645: update csd_repairs_interface set processing_phase = 3
1646: where transaction_id = l_interface_tbl(i).transaction_id;
1647: l_continue_further := false;
1648: else
1649: l_sr_tbl(i).sr_account_id := l_interface_tbl(i).sr_account_id;
1675: and organization_id = fnd_profile.value('CSD_DEF_REP_INV_ORG');
1676: end if;
1677: else
1678: -- the record is not eligible for the RO creation.
1679: update csd_repairs_interface set processing_phase = 3
1680: where transaction_id = l_interface_tbl(i).transaction_id;
1681: end if;
1682: end if;
1683: -- Create the SR, RO and product transaction lines.
1698: p_external_reference => l_interface_tbl(i).external_reference,
1699: p_lot_num => l_interface_tbl(i).lot_number
1700: );
1701: if x_return_status <> fnd_api.g_ret_sts_success then
1702: update csd_repairs_interface set processing_phase = 4
1703: where transaction_id = l_interface_tbl(i).transaction_id;
1704: else
1705: update csd_repairs_interface set incident_id = x_incident_id,repair_line_id = x_repair_line_id
1706: where transaction_id = l_interface_tbl(i).transaction_id;
1701: if x_return_status <> fnd_api.g_ret_sts_success then
1702: update csd_repairs_interface set processing_phase = 4
1703: where transaction_id = l_interface_tbl(i).transaction_id;
1704: else
1705: update csd_repairs_interface set incident_id = x_incident_id,repair_line_id = x_repair_line_id
1706: where transaction_id = l_interface_tbl(i).transaction_id;
1707:
1708:
1709: if p_one_sr_per_group <> 'Y' then
1730:
1731: -- write the concurrent program output.
1732: write_cp_output(p_group_id);
1733: -- delete all successfully processed records.
1734: delete from csd_repairs_interface where
1735: group_id = p_group_id and processing_phase = 2;
1736: commit;
1737: exception
1738: when fnd_api.g_exc_error then