DBA Data[Home] [Help]

APPS.WMS_CAROUSEL_INTEGRATION_PVT dependencies on WMS_CAROUSEL_DIRECTIVE_QUEUE

Line 235: FROM wms_carousel_directive_queue

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

Line 248: FROM wms_carousel_directive_queue

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

Line 312: UPDATE wms_carousel_directive_queue

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

Line 337: UPDATE WMS_CAROUSEL_DIRECTIVE_QUEUE Q

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

Line 343: UPDATE WMS_CAROUSEL_DIRECTIVE_QUEUE Q

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

Line 460: UPDATE wms_carousel_directive_queue

456: || ', send_pipe='
457: || v_directive.send_pipe
458: );
459: END IF;
460: UPDATE wms_carousel_directive_queue
461: SET status = 'S', response=nvl(p_response,v_directive.response) --bug9749354
462: WHERE CURRENT OF c_corresponding_directive;
463: END LOOP;
464:

Line 520: v_directive wms_carousel_directive_queue%ROWTYPE;

516: and wcc_dev.config_value = p_device_id
517: AND wcc_dev.active_ind = 'Y'
518: ORDER BY sequence_id;
519:
520: v_directive wms_carousel_directive_queue%ROWTYPE;
521: v_dir_dep_seg_id VARCHAR2 (64) := NULL;
522: v_dir_dep_seq_id NUMBER := NULL;
523: v_query VARCHAR2 (1024);
524: l_debug number := NVL(FND_PROFILE.VALUE('INV_DEBUG_TRACE'),0);

Line 634: p_directive IN OUT NOCOPY wms_carousel_directive_queue%ROWTYPE,

630: --
631: --
632: PROCEDURE get_directive_config (
633: p_task IN wms_device_requests_wcsv%ROWTYPE,
634: p_directive IN OUT NOCOPY wms_carousel_directive_queue%ROWTYPE,
635: p_dir_dep_seg_id OUT NOCOPY VARCHAR2,
636: p_dir_dep_seq_id OUT NOCOPY NUMBER
637: )
638: IS

Line 730: p_directive IN OUT NOCOPY wms_carousel_directive_queue%ROWTYPE,

726: END;
727:
728: PROCEDURE add_directive_to_queue (
729: p_task IN wms_device_requests_wcsv%ROWTYPE,
730: p_directive IN OUT NOCOPY wms_carousel_directive_queue%ROWTYPE,
731: p_dir_dep_seg_id IN VARCHAR2,
732: p_dir_dep_seq_id IN NUMBER
733: )
734: IS

Line 791: INSERT INTO wms_carousel_directive_queue

787: || ', l_directive_queue_status='
788: || l_directive_queue_status
789: );
790: END IF;
791: INSERT INTO wms_carousel_directive_queue
792: (CAROUSEL_DIRECTIVE_QUEUE_ID , request_id, task_id,
793: sequence_id, SUBINVENTORY,
794: directive, prev_id,
795: request, response,

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

808: ,CREATED_BY
809: ,LAST_UPDATE_LOGIN
810: ,business_event_id
811: )
812: VALUES (WMS_CAROUSEL_DIRECTIVE_QUEUE_S.NEXTVAL, p_task.request_id, p_task.task_id,
813: p_directive.sequence_id, p_directive.subinventory,
814: p_directive.directive, p_directive.prev_id,
815: p_directive.request, p_directive.response,
816: p_directive.response_timeout, p_directive.max_attempts,

Line 878: p_directive IN wms_carousel_directive_queue%ROWTYPE,

874:
875: --
876: --
877: FUNCTION get_dependency_id (
878: p_directive IN wms_carousel_directive_queue%ROWTYPE,
879: p_dir_dep_seg_id IN VARCHAR2,
880: p_dir_dep_seq_id IN NUMBER
881: )
882: RETURN NUMBER

Line 976: || ' from wms_carousel_directive_queue'

972: );
973: END IF;
974: v_query :=
975: 'select max(CAROUSEL_DIRECTIVE_QUEUE_ID) '
976: || ' from wms_carousel_directive_queue'
977: || ' where sequence_id='
978: || ':dir_dep_seq_id'
979: || ' and '
980: || ':seg_formula'

Line 1005: FROM wms_carousel_directive_queue a

1001: -- Cursor for directives to process
1002: CURSOR c_directives_to_process
1003: IS
1004: SELECT *
1005: FROM wms_carousel_directive_queue a
1006: WHERE ( -- this set of clauses is for timed-out directives
1007: status = 'C' -- has to be current
1008: AND (SYSDATE - last_attempt) * 24 * 60 * 60 >= response_timeout
1009: )

Line 1014: FROM wms_carousel_directive_queue b

1010: OR ( -- this set of clauses is for independent directives
1011: NVL(status,'P') = 'P' -- has to be a new directive
1012: AND CAROUSEL_DIRECTIVE_QUEUE_ID = -- has to be the first of such by sequence
1013: (SELECT MIN (CAROUSEL_DIRECTIVE_QUEUE_ID)
1014: FROM wms_carousel_directive_queue b
1015: WHERE b.request_id = a.request_id
1016: -- same request
1017: AND b.task_id = a.task_id -- same task
1018: AND NVL (b.status, 'P') in ('P','C')

Line 1026: FROM wms_carousel_directive_queue c

1022: prev_id IS NULL -- either independent by itself
1023: OR NOT EXISTS -- or the predecessor is finished
1024: (
1025: SELECT *
1026: FROM wms_carousel_directive_queue c
1027: WHERE c.CAROUSEL_DIRECTIVE_QUEUE_ID = a.prev_id -- dependency
1028: AND NVL (c.status, 'P') in ('P','C')
1029: -- include current ones
1030: )

Line 1036: v_status wms_carousel_directive_queue.status%TYPE;

1032: )
1033: ORDER BY CAROUSEL_DIRECTIVE_QUEUE_ID
1034: FOR UPDATE;
1035:
1036: v_status wms_carousel_directive_queue.status%TYPE;
1037: v_count NUMBER := 1;
1038: l_debug number := NVL(FND_PROFILE.VALUE('INV_DEBUG_TRACE'),0);
1039: l_exec_action VARCHAR2 (4000);
1040: l_directive_pause_delay NUMBER;

Line 1073: UPDATE wms_carousel_directive_queue

1069:
1070: IF l_directive_cascade_failure = 'Y' THEN
1071: -- Mark as Failure
1072: -- The current directive as well as all the rest of them in sequence
1073: UPDATE wms_carousel_directive_queue
1074: SET status = 'F', last_attempt = SYSDATE
1075: WHERE request_id = v_directive.request_id
1076: AND task_id = v_directive.task_id
1077: AND sequence_id >= v_directive.sequence_id;

Line 1081: UPDATE wms_carousel_directive_queue

1077: AND sequence_id >= v_directive.sequence_id;
1078: ELSE
1079: -- Mark as Failure
1080: -- Only the current directive
1081: UPDATE wms_carousel_directive_queue
1082: SET status = 'F', last_attempt = SYSDATE
1083: WHERE request_id = v_directive.request_id
1084: AND task_id = v_directive.task_id
1085: AND directive = v_directive.directive;

Line 1225: UPDATE wms_carousel_directive_queue

1221: v_status := 'C';
1222: END IF;
1223:
1224: -- Update the directive status, set attempts and last_attempt
1225: UPDATE wms_carousel_directive_queue
1226: SET status = v_status,
1227: attempts = NVL (v_directive.attempts, 0) + 1,
1228: last_attempt = SYSDATE
1229: WHERE CURRENT OF c_directives_to_process;

Line 1413: FROM WMS_CAROUSEL_DIRECTIVE_QUEUE q

1409: p_config_name IN VARCHAR2,
1410: p_task_id IN NUMBER)
1411: IS
1412: SELECT *
1413: FROM WMS_CAROUSEL_DIRECTIVE_QUEUE q
1414: WHERE q.REQUEST_ID = P_REQUEST_ID
1415: AND NVL(q.TASK_ID,0) = NVL(P_TASK_ID,NVL(q.TASK_ID,0))
1416: AND NVL (q.STATUS, 'P') IN ('C', 'P')
1417: AND q.DIRECTIVE IN

Line 1434: UPDATE WMS_CAROUSEL_DIRECTIVE_QUEUE Q

1430: FOR v_current_msg IN c_current_msg (p_request_id => p_request_id,
1431: p_config_name => p_config_name,
1432: p_task_id => p_task_id)
1433: LOOP
1434: UPDATE WMS_CAROUSEL_DIRECTIVE_QUEUE Q
1435: SET STATUS = P_STATUS,
1436: LAST_UPDATE_DATE = SYSDATE
1437: WHERE CURRENT OF c_current_msg;
1438: END LOOP;

Line 1498: DELETE FROM wms_carousel_directive_queue

1494: BEGIN
1495: v_purge_interval :=
1496: NVL (get_config_parameter ('QUEUE_PURGE_INTERVAL'), 3600);
1497:
1498: DELETE FROM wms_carousel_directive_queue
1499: WHERE status IN ('S', 'F', 'X') -- Success, failure, or cancelled
1500: AND (SYSDATE - nvl(last_attempt,LAST_UPDATE_DATE)) * 24 * 60 * 60 >= v_purge_interval;
1501:
1502: /*

Line 2234: from wms_carousel_directive_queue

2230:
2231: IF l_response_record.business_event is null then
2232: begin
2233: select business_event_id into l_response_record.business_event
2234: from wms_carousel_directive_queue
2235: where request_id = p_request_id;
2236: exception
2237: when others then
2238: l_response_record.business_event := null;