DBA Data[Home] [Help]

PACKAGE BODY: APPS.WIP_MOVE_TXN_INTERFACE_CLEANUP

Source


1 PACKAGE BODY WIP_MOVE_TXN_INTERFACE_CLEANUP AS
2 /* $Header: wipmvclb.pls 115.7 2002/11/28 13:38:40 rmahidha ship $ */
3 
4   procedure fetch_and_delete(
5     p_grp_id in     number,
6     p_moves  in out nocopy wip_move_txn_interface_rec) is
7 
8     i number := 0;
9 
10     cursor get_moves(c_grp_id number) is
11     select
12       TRANSACTION_ID,
13       LAST_UPDATE_DATE,
14       LAST_UPDATED_BY,
15       LAST_UPDATED_BY_NAME,
16       CREATION_DATE,
17       CREATED_BY,
18       CREATED_BY_NAME,
19       LAST_UPDATE_LOGIN,
20       REQUEST_ID,
21       PROGRAM_APPLICATION_ID,
22       PROGRAM_ID,
23       PROGRAM_UPDATE_DATE,
24       GROUP_ID,
25       SOURCE_CODE,
26       SOURCE_LINE_ID,
27       PROCESS_PHASE,
28       PROCESS_STATUS,
29       TRANSACTION_TYPE,
30       ORGANIZATION_ID,
31       ORGANIZATION_CODE,
32       WIP_ENTITY_ID,
33       WIP_ENTITY_NAME,
34       ENTITY_TYPE,
35       PRIMARY_ITEM_ID,
36       LINE_ID,
37       LINE_CODE,
38       REPETITIVE_SCHEDULE_ID,
39       TRANSACTION_DATE,
40       ACCT_PERIOD_ID,
41       FM_OPERATION_SEQ_NUM,
42       FM_OPERATION_CODE,
43       FM_DEPARTMENT_ID,
44       FM_DEPARTMENT_CODE,
45       FM_INTRAOPERATION_STEP_TYPE,
46       TO_OPERATION_SEQ_NUM,
47       TO_OPERATION_CODE,
48       TO_DEPARTMENT_ID,
49       TO_DEPARTMENT_CODE,
50       TO_INTRAOPERATION_STEP_TYPE,
51       TRANSACTION_QUANTITY,
52       TRANSACTION_UOM,
53       PRIMARY_QUANTITY,
54       PRIMARY_UOM,
55       SCRAP_ACCOUNT_ID,
56       REASON_ID,
57       REASON_NAME,
58       REFERENCE,
59       ATTRIBUTE_CATEGORY,
60       ATTRIBUTE1,
61       ATTRIBUTE2,
62       ATTRIBUTE3,
63       ATTRIBUTE4,
64       ATTRIBUTE5,
65       ATTRIBUTE6,
66       ATTRIBUTE7,
67       ATTRIBUTE8,
68       ATTRIBUTE9,
69       ATTRIBUTE10,
70       ATTRIBUTE11,
71       ATTRIBUTE12,
72       ATTRIBUTE13,
73       ATTRIBUTE14,
74       ATTRIBUTE15,
75       qa_collection_id,
76       overcompletion_transaction_id,
77       overcompletion_transaction_qty,
78       overcompletion_primary_qty
79     from wip_move_txn_interface
80     where group_id = c_grp_id;
81 
82     move_rec get_moves%rowtype;
83   begin
84     -- initialize
85     if (p_moves.numrecs is NULL) then
86       -- p_moves is empty
87       p_moves.numrecs := i;
88     else
89       -- p_moves already has records
90       i := p_moves.numrecs;
91     end if;
92 
93     open get_moves(c_grp_id => p_grp_id);
94 
95     loop
96       fetch get_moves into move_rec;
97 
98       exit when (get_moves%NOTFOUND);
99 
100       i := i + 1;
101       p_moves.numrecs := i;
102       p_moves.TRANSACTION_ID(i) := move_rec.TRANSACTION_ID;
103       p_moves.LAST_UPDATE_DATE(i) := move_rec.LAST_UPDATE_DATE;
104       p_moves.LAST_UPDATED_BY(i) := move_rec.LAST_UPDATED_BY;
105       p_moves.LAST_UPDATED_BY_NAME(i) := move_rec.LAST_UPDATED_BY_NAME;
106       p_moves.CREATION_DATE(i) := move_rec.CREATION_DATE;
107       p_moves.CREATED_BY(i) := move_rec.CREATED_BY;
108       p_moves.CREATED_BY_NAME(i) := move_rec.CREATED_BY_NAME;
109       p_moves.LAST_UPDATE_LOGIN(i) := move_rec.LAST_UPDATE_LOGIN;
110       p_moves.REQUEST_ID(i) := move_rec.REQUEST_ID;
111       p_moves.PROGRAM_APPLICATION_ID(i) := move_rec.PROGRAM_APPLICATION_ID;
112       p_moves.PROGRAM_ID(i) := move_rec.PROGRAM_ID;
113       p_moves.PROGRAM_UPDATE_DATE(i) := move_rec.PROGRAM_UPDATE_DATE;
114       p_moves.GROUP_ID(i) := move_rec.GROUP_ID;
115       p_moves.SOURCE_CODE(i) := move_rec.SOURCE_CODE;
116       p_moves.SOURCE_LINE_ID(i) := move_rec.SOURCE_LINE_ID;
117       p_moves.PROCESS_PHASE(i) := move_rec.PROCESS_PHASE;
118       p_moves.PROCESS_STATUS(i) := move_rec.PROCESS_STATUS;
119       p_moves.TRANSACTION_TYPE(i) := move_rec.TRANSACTION_TYPE;
120       p_moves.ORGANIZATION_ID(i) := move_rec.ORGANIZATION_ID;
121       p_moves.ORGANIZATION_CODE(i) := move_rec.ORGANIZATION_CODE;
122       p_moves.WIP_ENTITY_ID(i) := move_rec.WIP_ENTITY_ID;
123       p_moves.WIP_ENTITY_NAME(i) := move_rec.WIP_ENTITY_NAME;
124       p_moves.ENTITY_TYPE(i) := move_rec.ENTITY_TYPE;
125       p_moves.PRIMARY_ITEM_ID(i) := move_rec.PRIMARY_ITEM_ID;
126       p_moves.LINE_ID(i) := move_rec.LINE_ID;
127       p_moves.LINE_CODE(i) := move_rec.LINE_CODE;
128       p_moves.REPETITIVE_SCHEDULE_ID(i) := move_rec.REPETITIVE_SCHEDULE_ID;
129       p_moves.TRANSACTION_DATE(i) := move_rec.TRANSACTION_DATE;
130       p_moves.ACCT_PERIOD_ID(i) := move_rec.ACCT_PERIOD_ID;
131       p_moves.FM_OPERATION_SEQ_NUM(i) := move_rec.FM_OPERATION_SEQ_NUM;
132       p_moves.FM_OPERATION_CODE(i) := move_rec.FM_OPERATION_CODE;
133       p_moves.FM_DEPARTMENT_ID(i) := move_rec.FM_DEPARTMENT_ID;
134       p_moves.FM_DEPARTMENT_CODE(i) := move_rec.FM_DEPARTMENT_CODE;
135       p_moves.FM_INTRAOPERATION_STEP_TYPE(i) := move_rec.FM_INTRAOPERATION_STEP_TYPE;
136       p_moves.TO_OPERATION_SEQ_NUM(i) := move_rec.TO_OPERATION_SEQ_NUM;
137       p_moves.TO_OPERATION_CODE(i) := move_rec.TO_OPERATION_CODE;
138       p_moves.TO_DEPARTMENT_ID(i) := move_rec.TO_DEPARTMENT_ID;
139       p_moves.TO_DEPARTMENT_CODE(i) := move_rec.TO_DEPARTMENT_CODE;
140       p_moves.TO_INTRAOPERATION_STEP_TYPE(i) := move_rec.TO_INTRAOPERATION_STEP_TYPE;
141       p_moves.TRANSACTION_QUANTITY(i) := move_rec.TRANSACTION_QUANTITY;
142       p_moves.TRANSACTION_UOM(i) := move_rec.TRANSACTION_UOM;
143       p_moves.PRIMARY_QUANTITY(i) := move_rec.PRIMARY_QUANTITY;
144       p_moves.PRIMARY_UOM(i) := move_rec.PRIMARY_UOM;
145       p_moves.SCRAP_ACCOUNT_ID(i) := move_rec.SCRAP_ACCOUNT_ID;
146       p_moves.REASON_ID(i) := move_rec.REASON_ID;
147       p_moves.REASON_NAME(i) := move_rec.REASON_NAME;
148       p_moves.REFERENCE(i) := move_rec.REFERENCE;
149       p_moves.ATTRIBUTE_CATEGORY(i) := move_rec.ATTRIBUTE_CATEGORY;
150       p_moves.ATTRIBUTE1(i) := move_rec.ATTRIBUTE1;
151       p_moves.ATTRIBUTE2(i) := move_rec.ATTRIBUTE2;
152       p_moves.ATTRIBUTE3(i) := move_rec.ATTRIBUTE3;
153       p_moves.ATTRIBUTE4(i) := move_rec.ATTRIBUTE4;
154       p_moves.ATTRIBUTE5(i) := move_rec.ATTRIBUTE5;
155       p_moves.ATTRIBUTE6(i) := move_rec.ATTRIBUTE6;
156       p_moves.ATTRIBUTE7(i) := move_rec.ATTRIBUTE7;
157       p_moves.ATTRIBUTE8(i) := move_rec.ATTRIBUTE8;
158       p_moves.ATTRIBUTE9(i) := move_rec.ATTRIBUTE9;
159       p_moves.ATTRIBUTE10(i) := move_rec.ATTRIBUTE10;
160       p_moves.ATTRIBUTE11(i) := move_rec.ATTRIBUTE11;
161       p_moves.ATTRIBUTE12(i) := move_rec.ATTRIBUTE12;
162       p_moves.ATTRIBUTE13(i) := move_rec.ATTRIBUTE13;
163       p_moves.ATTRIBUTE14(i) := move_rec.ATTRIBUTE14;
164       p_moves.ATTRIBUTE15(i) := move_rec.ATTRIBUTE15;
165       p_moves.QA_COLLECTION_ID(i) := move_rec.QA_COLLECTION_ID;
166       p_moves.overcompletion_transaction_id(i) := move_rec.overcompletion_transaction_id;
167       p_moves.overcompletion_transaction_qty(i) := move_rec.overcompletion_transaction_qty;
168       p_moves.overcompletion_primary_qty(i) := move_rec.overcompletion_primary_qty;
169     end loop;
170 
171     close get_moves;
172 
173     if (p_moves.numrecs > 0) then
174       delete from wip_move_txn_interface
175       where group_id = p_grp_id;
176     end if;
177   end fetch_and_delete;
178 
179   procedure insert_rows(
180     p_moves in wip_move_txn_interface_rec) is
181     i number := 1;
182   begin
183     while (i <= nvl(p_moves.numrecs, 0)) loop
184       insert into wip_move_txn_interface (
185         TRANSACTION_ID,
186         LAST_UPDATE_DATE,
187         LAST_UPDATED_BY,
188         LAST_UPDATED_BY_NAME,
189         CREATION_DATE,
190         CREATED_BY,
191         CREATED_BY_NAME,
192         LAST_UPDATE_LOGIN,
193         REQUEST_ID,
194         PROGRAM_APPLICATION_ID,
195         PROGRAM_ID,
196         PROGRAM_UPDATE_DATE,
197         GROUP_ID,
198         SOURCE_CODE,
199         SOURCE_LINE_ID,
200         PROCESS_PHASE,
201         PROCESS_STATUS,
202         TRANSACTION_TYPE,
203         ORGANIZATION_ID,
204         ORGANIZATION_CODE,
205         WIP_ENTITY_ID,
206         WIP_ENTITY_NAME,
207         ENTITY_TYPE,
208         PRIMARY_ITEM_ID,
209         LINE_ID,
210         LINE_CODE,
211         REPETITIVE_SCHEDULE_ID,
212         TRANSACTION_DATE,
213         ACCT_PERIOD_ID,
214         FM_OPERATION_SEQ_NUM,
215         FM_OPERATION_CODE,
216         FM_DEPARTMENT_ID,
217         FM_DEPARTMENT_CODE,
218         FM_INTRAOPERATION_STEP_TYPE,
219         TO_OPERATION_SEQ_NUM,
220         TO_OPERATION_CODE,
221         TO_DEPARTMENT_ID,
222         TO_DEPARTMENT_CODE,
223         TO_INTRAOPERATION_STEP_TYPE,
224         TRANSACTION_QUANTITY,
225         TRANSACTION_UOM,
226         PRIMARY_QUANTITY,
227         PRIMARY_UOM,
228         SCRAP_ACCOUNT_ID,
229         REASON_ID,
230         REASON_NAME,
231         REFERENCE,
232         ATTRIBUTE_CATEGORY,
233         ATTRIBUTE1,
234         ATTRIBUTE2,
235         ATTRIBUTE3,
236         ATTRIBUTE4,
237         ATTRIBUTE5,
238         ATTRIBUTE6,
239         ATTRIBUTE7,
240         ATTRIBUTE8,
241         ATTRIBUTE9,
242         ATTRIBUTE10,
243         ATTRIBUTE11,
244         ATTRIBUTE12,
245         ATTRIBUTE13,
246         ATTRIBUTE14,
247         ATTRIBUTE15,
248         qa_collection_id,
249 	overcompletion_transaction_id,
250 	overcompletion_transaction_qty,
251 	overcompletion_primary_qty
252       ) values (
253         p_moves.TRANSACTION_ID(i),
254         p_moves.LAST_UPDATE_DATE(i),
255         p_moves.LAST_UPDATED_BY(i),
256         p_moves.LAST_UPDATED_BY_NAME(i),
257         p_moves.CREATION_DATE(i),
258         p_moves.CREATED_BY(i),
259         p_moves.CREATED_BY_NAME(i),
260         p_moves.LAST_UPDATE_LOGIN(i),
261         p_moves.REQUEST_ID(i),
262         p_moves.PROGRAM_APPLICATION_ID(i),
263         p_moves.PROGRAM_ID(i),
264         p_moves.PROGRAM_UPDATE_DATE(i),
265         p_moves.GROUP_ID(i),
266         p_moves.SOURCE_CODE(i),
267         p_moves.SOURCE_LINE_ID(i),
268         p_moves.PROCESS_PHASE(i),
269         p_moves.PROCESS_STATUS(i),
270         p_moves.TRANSACTION_TYPE(i),
271         p_moves.ORGANIZATION_ID(i),
272         p_moves.ORGANIZATION_CODE(i),
273         p_moves.WIP_ENTITY_ID(i),
274         p_moves.WIP_ENTITY_NAME(i),
275         p_moves.ENTITY_TYPE(i),
276         p_moves.PRIMARY_ITEM_ID(i),
277         p_moves.LINE_ID(i),
278         p_moves.LINE_CODE(i),
279         p_moves.REPETITIVE_SCHEDULE_ID(i),
280         p_moves.TRANSACTION_DATE(i),
281         p_moves.ACCT_PERIOD_ID(i),
282         p_moves.FM_OPERATION_SEQ_NUM(i),
283         p_moves.FM_OPERATION_CODE(i),
284         p_moves.FM_DEPARTMENT_ID(i),
285         p_moves.FM_DEPARTMENT_CODE(i),
286         p_moves.FM_INTRAOPERATION_STEP_TYPE(i),
287         p_moves.TO_OPERATION_SEQ_NUM(i),
288         p_moves.TO_OPERATION_CODE(i),
289         p_moves.TO_DEPARTMENT_ID(i),
290         p_moves.TO_DEPARTMENT_CODE(i),
291         p_moves.TO_INTRAOPERATION_STEP_TYPE(i),
292         p_moves.TRANSACTION_QUANTITY(i),
293         p_moves.TRANSACTION_UOM(i),
294         p_moves.PRIMARY_QUANTITY(i),
295         p_moves.PRIMARY_UOM(i),
296         p_moves.SCRAP_ACCOUNT_ID(i),
297         p_moves.REASON_ID(i),
298         p_moves.REASON_NAME(i),
299         p_moves.REFERENCE(i),
300         p_moves.ATTRIBUTE_CATEGORY(i),
301         p_moves.ATTRIBUTE1(i),
302         p_moves.ATTRIBUTE2(i),
303         p_moves.ATTRIBUTE3(i),
304         p_moves.ATTRIBUTE4(i),
305         p_moves.ATTRIBUTE5(i),
306         p_moves.ATTRIBUTE6(i),
307         p_moves.ATTRIBUTE7(i),
308         p_moves.ATTRIBUTE8(i),
309         p_moves.ATTRIBUTE9(i),
310         p_moves.ATTRIBUTE10(i),
311         p_moves.ATTRIBUTE11(i),
312         p_moves.ATTRIBUTE12(i),
313         p_moves.ATTRIBUTE13(i),
314         p_moves.ATTRIBUTE14(i),
315         p_moves.ATTRIBUTE15(i),
316         p_moves.QA_COLLECTION_ID(i),
317 	p_moves.overcompletion_transaction_id(i),
318 	p_moves.overcompletion_transaction_qty(i),
319 	p_moves.overcompletion_primary_qty(i)
320       );
321 
322       i := i + 1;
323     end loop;
324   end insert_rows;
325 
326 END WIP_MOVE_TXN_INTERFACE_CLEANUP;