DBA Data[Home] [Help]

APPS.WMS_CAROUSEL_INTEGRATION_PVT dependencies on WMS_CAROUSEL_DIRECTIVE_QUEUE

Line 233: FROM wms_carousel_directive_queue

229: p_response IN VARCHAR2
230: )
231: IS
232: SELECT *
233: FROM wms_carousel_directive_queue
234: WHERE status = 'C'
235: AND NVL (NVL (device_id, p_device_id), -1) = NVL (p_device_id, -1)
236: AND NVL (p_response, 'null') LIKE NVL (response, 'null')
237: FOR UPDATE;

Line 246: FROM wms_carousel_directive_queue

242: p_response IN VARCHAR2
243: )
244: IS
245: SELECT *
246: FROM wms_carousel_directive_queue
247: WHERE status = 'C'
248: AND NVL (NVL (device_id, p_device_id), -1) = NVL (p_device_id, -1)
249: AND NVL (p_response, 'null') LIKE NVL (response, 'null')
250: FOR UPDATE;

Line 310: UPDATE wms_carousel_directive_queue

306: || ', v_replace_response='
307: || v_replace_response
308: );
309: END IF;
310: UPDATE wms_carousel_directive_queue
311: SET status = 'F'
312: WHERE CURRENT OF c_error_directive;
313:
314: IF l_debug > 0 THEN

Line 335: UPDATE WMS_CAROUSEL_DIRECTIVE_QUEUE Q

331:
332: --
333: IF (INSTR(p_response, 'ERROR') > 0) THEN
334: --Mark the dependent directives as 'Cancelled'
335: UPDATE WMS_CAROUSEL_DIRECTIVE_QUEUE Q
336: SET STATUS = 'X', LAST_UPDATE_DATE = SYSDATE
337: WHERE REQUEST_ID = NVL(v_error_directive.REQUEST_ID,0)
338: AND SEQUENCE_ID > NVL(v_error_directive.SEQUENCE_ID,SEQUENCE_ID);
339: ELSIF (INSTR(p_response, 'FULL') > 0) THEN

Line 341: UPDATE WMS_CAROUSEL_DIRECTIVE_QUEUE Q

337: WHERE REQUEST_ID = NVL(v_error_directive.REQUEST_ID,0)
338: AND SEQUENCE_ID > NVL(v_error_directive.SEQUENCE_ID,SEQUENCE_ID);
339: ELSIF (INSTR(p_response, 'FULL') > 0) THEN
340: --Mark the dependent directives as 'Pending' for PAUSE processing
341: UPDATE WMS_CAROUSEL_DIRECTIVE_QUEUE Q
342: SET STATUS = 'P', LAST_UPDATE_DATE = SYSDATE
343: WHERE REQUEST_ID = NVL(v_error_directive.REQUEST_ID,0)
344: AND SEQUENCE_ID > NVL(v_error_directive.SEQUENCE_ID,SEQUENCE_ID);
345: END IF;

Line 458: UPDATE wms_carousel_directive_queue

454: || ', send_pipe='
455: || v_directive.send_pipe
456: );
457: END IF;
458: UPDATE wms_carousel_directive_queue
459: SET status = 'S'
460: WHERE CURRENT OF c_corresponding_directive;
461: END LOOP;
462:

Line 511: v_directive wms_carousel_directive_queue%ROWTYPE;

507: AND BUSINESS_EVENT_ID = P_BUSINESS_EVENT_ID
508: AND active_ind = 'Y'
509: ORDER BY sequence_id;
510:
511: v_directive wms_carousel_directive_queue%ROWTYPE;
512: v_dir_dep_seg_id VARCHAR2 (64) := NULL;
513: v_dir_dep_seq_id NUMBER := NULL;
514: v_query VARCHAR2 (1024);
515: l_debug number := NVL(FND_PROFILE.VALUE('INV_DEBUG_TRACE'),0);

Line 624: p_directive IN OUT NOCOPY wms_carousel_directive_queue%ROWTYPE,

620: --
621: --
622: PROCEDURE get_directive_config (
623: p_task IN wms_device_requests_wcsv%ROWTYPE,
624: p_directive IN OUT NOCOPY wms_carousel_directive_queue%ROWTYPE,
625: p_dir_dep_seg_id OUT NOCOPY VARCHAR2,
626: p_dir_dep_seq_id OUT NOCOPY NUMBER
627: )
628: IS

Line 720: p_directive IN OUT NOCOPY wms_carousel_directive_queue%ROWTYPE,

716: END;
717:
718: PROCEDURE add_directive_to_queue (
719: p_task IN wms_device_requests_wcsv%ROWTYPE,
720: p_directive IN OUT NOCOPY wms_carousel_directive_queue%ROWTYPE,
721: p_dir_dep_seg_id IN VARCHAR2,
722: p_dir_dep_seq_id IN NUMBER
723: )
724: IS

Line 781: INSERT INTO wms_carousel_directive_queue

777: || ', l_directive_queue_status='
778: || l_directive_queue_status
779: );
780: END IF;
781: INSERT INTO wms_carousel_directive_queue
782: (CAROUSEL_DIRECTIVE_QUEUE_ID , request_id, task_id,
783: sequence_id, SUBINVENTORY,
784: directive, prev_id,
785: request, response,

Line 802: VALUES (WMS_CAROUSEL_DIRECTIVE_QUEUE_S.NEXTVAL, p_task.request_id, p_task.task_id,

798: ,CREATED_BY
799: ,LAST_UPDATE_LOGIN
800: ,business_event_id
801: )
802: VALUES (WMS_CAROUSEL_DIRECTIVE_QUEUE_S.NEXTVAL, p_task.request_id, p_task.task_id,
803: p_directive.sequence_id, p_directive.subinventory,
804: p_directive.directive, p_directive.prev_id,
805: p_directive.request, p_directive.response,
806: p_directive.response_timeout, p_directive.max_attempts,

Line 868: p_directive IN wms_carousel_directive_queue%ROWTYPE,

864:
865: --
866: --
867: FUNCTION get_dependency_id (
868: p_directive IN wms_carousel_directive_queue%ROWTYPE,
869: p_dir_dep_seg_id IN VARCHAR2,
870: p_dir_dep_seq_id IN NUMBER
871: )
872: RETURN NUMBER

Line 966: || ' from wms_carousel_directive_queue'

962: );
963: END IF;
964: v_query :=
965: 'select max(CAROUSEL_DIRECTIVE_QUEUE_ID) '
966: || ' from wms_carousel_directive_queue'
967: || ' where sequence_id='
968: || ':dir_dep_seq_id'
969: || ' and '
970: || ':seg_formula'

Line 995: FROM wms_carousel_directive_queue a

991: -- Cursor for directives to process
992: CURSOR c_directives_to_process
993: IS
994: SELECT *
995: FROM wms_carousel_directive_queue a
996: WHERE ( -- this set of clauses is for timed-out directives
997: status = 'C' -- has to be current
998: AND (SYSDATE - last_attempt) * 24 * 60 * 60 >= response_timeout
999: )

Line 1004: FROM wms_carousel_directive_queue b

1000: OR ( -- this set of clauses is for independent directives
1001: NVL(status,'P') = 'P' -- has to be a new directive
1002: AND CAROUSEL_DIRECTIVE_QUEUE_ID = -- has to be the first of such by sequence
1003: (SELECT MIN (CAROUSEL_DIRECTIVE_QUEUE_ID)
1004: FROM wms_carousel_directive_queue b
1005: WHERE b.request_id = a.request_id
1006: -- same request
1007: AND b.task_id = a.task_id -- same task
1008: AND NVL (b.status, 'P') in ('P','C')

Line 1016: FROM wms_carousel_directive_queue c

1012: prev_id IS NULL -- either independent by itself
1013: OR NOT EXISTS -- or the predecessor is finished
1014: (
1015: SELECT *
1016: FROM wms_carousel_directive_queue c
1017: WHERE c.CAROUSEL_DIRECTIVE_QUEUE_ID = a.prev_id -- dependency
1018: AND NVL (c.status, 'P') in ('P','C')
1019: -- include current ones
1020: )

Line 1026: v_status wms_carousel_directive_queue.status%TYPE;

1022: )
1023: ORDER BY CAROUSEL_DIRECTIVE_QUEUE_ID
1024: FOR UPDATE;
1025:
1026: v_status wms_carousel_directive_queue.status%TYPE;
1027: v_count NUMBER := 1;
1028: l_debug number := NVL(FND_PROFILE.VALUE('INV_DEBUG_TRACE'),0);
1029: l_exec_action VARCHAR2 (4000);
1030: l_directive_pause_delay NUMBER;

Line 1063: UPDATE wms_carousel_directive_queue

1059:
1060: IF l_directive_cascade_failure = 'Y' THEN
1061: -- Mark as Failure
1062: -- The current directive as well as all the rest of them in sequence
1063: UPDATE wms_carousel_directive_queue
1064: SET status = 'F', last_attempt = SYSDATE
1065: WHERE request_id = v_directive.request_id
1066: AND task_id = v_directive.task_id
1067: AND sequence_id >= v_directive.sequence_id;

Line 1071: UPDATE wms_carousel_directive_queue

1067: AND sequence_id >= v_directive.sequence_id;
1068: ELSE
1069: -- Mark as Failure
1070: -- Only the current directive
1071: UPDATE wms_carousel_directive_queue
1072: SET status = 'F', last_attempt = SYSDATE
1073: WHERE request_id = v_directive.request_id
1074: AND task_id = v_directive.task_id
1075: AND directive = v_directive.directive;

Line 1215: UPDATE wms_carousel_directive_queue

1211: v_status := 'C';
1212: END IF;
1213:
1214: -- Update the directive status, set attempts and last_attempt
1215: UPDATE wms_carousel_directive_queue
1216: SET status = v_status,
1217: attempts = NVL (v_directive.attempts, 0) + 1,
1218: last_attempt = SYSDATE
1219: WHERE CURRENT OF c_directives_to_process;

Line 1403: FROM WMS_CAROUSEL_DIRECTIVE_QUEUE q

1399: p_config_name IN VARCHAR2,
1400: p_task_id IN NUMBER)
1401: IS
1402: SELECT *
1403: FROM WMS_CAROUSEL_DIRECTIVE_QUEUE q
1404: WHERE q.REQUEST_ID = P_REQUEST_ID
1405: AND NVL(q.TASK_ID,0) = NVL(P_TASK_ID,NVL(q.TASK_ID,0))
1406: AND NVL (q.STATUS, 'P') IN ('C', 'P')
1407: AND q.DIRECTIVE IN

Line 1424: UPDATE WMS_CAROUSEL_DIRECTIVE_QUEUE Q

1420: FOR v_current_msg IN c_current_msg (p_request_id => p_request_id,
1421: p_config_name => p_config_name,
1422: p_task_id => p_task_id)
1423: LOOP
1424: UPDATE WMS_CAROUSEL_DIRECTIVE_QUEUE Q
1425: SET STATUS = P_STATUS,
1426: LAST_UPDATE_DATE = SYSDATE
1427: WHERE CURRENT OF c_current_msg;
1428: END LOOP;

Line 1488: DELETE FROM wms_carousel_directive_queue

1484: BEGIN
1485: v_purge_interval :=
1486: NVL (get_config_parameter ('QUEUE_PURGE_INTERVAL'), 3600);
1487:
1488: DELETE FROM wms_carousel_directive_queue
1489: WHERE status IN ('S', 'F', 'X') -- Success, failure, or cancelled
1490: AND (SYSDATE - nvl(last_attempt,LAST_UPDATE_DATE)) * 24 * 60 * 60 >= v_purge_interval;
1491:
1492: /*