[Home] [Help]
252: | Procedure Name : PROCESS_REQUEST |
253: | |
254: | Purpose : Processes the query and XML for a given request ID. This |
255: | is called by MassRequstMonitor. Main functionalities are: |
256: | - Inserts record into jtf_fm_int_request_header table. |
257: | - Inserts record into jtf_fm_int_request_batches table. |
258: | - Creates partition and inserts records into |
259: | jtff_fm_int_request_lines table. |
260: | |
517: --Checking records existence before calling the clean_stalled_request procedure.
518:
519: SELECT COUNT(ROWID)
520: INTO l_header_count
521: FROM jtf_fm_int_request_header
522: WHERE request_id = l_request_id;
523:
524:
525: IF ( l_header_count > 0)
528: , x_return_status => l_clean_request_status
529: );
530: END IF;
531:
532: INSERT INTO jtf_fm_int_request_header
533: ( request_id
534: , group_id
535: , server_id
536: , submit_dt_tm
944: validate_email(l_request_id );
945:
946: raiseBusinessEvent(l_request_id);
947:
948: UPDATE jtf_fm_int_request_header c
949: SET c.request_status = 'AVAILABLE'
950: WHERE c.request_id = l_request_id ;
951:
952: /* -- Moved to get_next_request procedure
1000: | |
1001: | Purpose : For a given set of lines id, this procedure updates the |
1002: | jtf_fm_int_request_lines table and sets the email status to |
1003: | the passed email status PL/SQL table. |
1004: | - Updates jtf_fm_int_request_header - for request status |
1005: | - Updates jtf_fm_status_all - for request status |
1006: | - Updates jtf_fm_request_history_all - for outcome code |
1007: | - Updates jtf_fm_email_stat - for email details |
1008: | |
1022: l_disabled_flag NUMBER;
1023: l_count NUMBER;
1024: CURSOR c_processed IS
1025: SELECT 'Y'
1026: FROM jtf_fm_int_request_header c
1027: WHERE c.request_id = l_request_id
1028: AND c.request_status = 'READYTOLOG' ;
1029: CURSOR c_details IS
1030: SELECT SUM(DECODE(c.contact_preference_flag,'N',1,0)) ,
1040: UPDATE jtf_fm_int_request_lines
1041: SET email_status = line_status(i)
1042: WHERE request_line_id = line_ids(i);
1043:
1044: UPDATE jtf_fm_int_request_header c
1045: SET c.request_status = 'READYTOLOG'
1046: WHERE c.request_id = l_request_id
1047: AND NOT EXISTS ( SELECT '1'
1048: FROM jtf_fm_int_request_lines a
1214: /*---------------------------------------------------------------------------------*
1215: | Procedure Name : UPDATE_INSTANCE_STATUS |
1216: | |
1217: | Purpose : - Updates jtf_fm_int_request_batches - for batch status |
1218: | - Updates jtf_fm_int_request_header - for request status |
1219: | - Updates jtf_fm_status_all - for request status |
1220: | - Updates jtf_fm_request_history_all - for outcome code |
1221: | - Updates jtf_fm_email_stat - for email details |
1222: | |
1237: l_disabled_flag NUMBER;
1238: l_count NUMBER;
1239: CURSOR c_header IS
1240: SELECT 'Y'
1241: FROM jtf_fm_int_request_header c
1242: WHERE c.request_id = l_request_id
1243: AND c.request_status = 'READYTOLOG' ;
1244:
1245: CURSOR c_lines IS
1256: SET batch_status = p_status,
1257: last_update_date = SYSDATE
1258: WHERE request_id = p_request_id;
1259:
1260: UPDATE jtf_fm_int_request_header c
1261: SET c.request_status = 'READYTOLOG'
1262: WHERE c.request_id = p_request_id
1263: AND NOT EXISTS ( SELECT '1'
1264: FROM jtf_fm_int_request_batches a
1435: /*---------------------------------------------------------------------------------*
1436: | Procedure Name : GET_NEXT_REQUEST |
1437: | |
1438: | Purpose : Selects from jtf_fm_int_request_lines , and |
1439: | - Updates jtf_fm_int_request_header - for request status |
1440: | - Updates jtf_fm_status_all - for request status |
1441: | - Updates jtf_fm_request_history_all - for outcome code |
1442: | |
1443: *---------------------------------------------------------------------------------*/
1564: parameter97,
1565: parameter98,
1566: parameter99,
1567: parameter100
1568: FROM jtf_fm_int_request_header
1569: WHERE request_status IN ('AVAILABLE','INPROGRESS' )
1570: AND server_id = p_server_id
1571: ORDER BY priority, creation_date DESC;
1572: l_header_request_id NUMBER;
1690: CLOSE c_header;
1691:
1692: l_header_request_id := p_request_id;
1693:
1694: UPDATE jtf_fm_int_request_header
1695: SET request_status = 'INPROGRESS'
1696: WHERE request_id = p_request_id
1697: AND request_status = 'AVAILABLE';
1698:
2356: , x_msg_data OUT NOCOPY VARCHAR2
2357: ) IS
2358: CURSOR c_history IS
2359: SELECT USER_HISTORY
2360: FROM jtf_fm_int_request_header
2361: WHERE request_id = p_request_id ;
2362: l_errbuf VARCHAR2(32767);
2363: l_retcode VARCHAR2(1);
2364: BEGIN
2653: | |
2654: | Purpose : Selects from jtf_fm_int_request_lines , and |
2655: | - Truncates partition for jtf_fm_int_request_lines |
2656: | - Deletes from jtf_fm_int_request_batches |
2657: | - Deletes from jtf_fm_int_request_header |
2658: | |
2659: *---------------------------------------------------------------------------------*/
2660: PROCEDURE clean_stalled_request ( p_request_id IN NUMBER
2661: , x_return_status OUT NOCOPY VARCHAR2
2691: ;
2692:
2693: --Deleting from header table
2694: DELETE
2695: FROM jtf_fm_int_request_header
2696: WHERE request_id = p_request_id
2697: ;
2698:
2699: COMMIT;