DBA Data[Home] [Help]

APPS.XDP_AQ_UTILITIES dependencies on XDP_ORDER

Line 264: update XDP_ORDER_HEADERS

260: message_properties => lv_MessageProperties,
261: payload =>lv_wf_object,
262: msgid => lv_MsgID);
263:
264: update XDP_ORDER_HEADERS
265: set
266: last_updated_by = FND_GLOBAL.USER_ID,
267: last_update_date = sysdate,
268: last_update_login = FND_GLOBAL.LOGIN_ID,

Line 274: update XDP_ORDER_LINE_ITEMS

270: MSGID = lv_MsgID
271: where
272: order_id = p_order_id;
273:
274: update XDP_ORDER_LINE_ITEMS
275: set
276: last_updated_by = FND_GLOBAL.USER_ID,
277: last_update_date = sysdate,
278: last_update_login = FND_GLOBAL.LOGIN_ID,

Line 363: from xdp_order_headers

359: END;
360:
361: select state,previous_order_id,priority, provisioning_date
362: into lv_state,lv_order_id,lv_priority, lv_prov_date
363: from xdp_order_headers
364: where
365: order_id = lv_wf_object.order_id;
366:
367: if lv_state = 'SUSPENDED' THEN

Line 375: from xdp_order_headers

371: elsif lv_state IN ('WAIT','HOLD') THEN
372: if lv_order_id is not null then
373: begin
374: select state into lv_state2
375: from xdp_order_headers
376: where order_id = lv_order_id;
377: exception
378: when no_data_found then
379: lv_state2 := 'CANCELED';

Line 528: from xdp_order_headers

524: -- SetContext(lv_MessageProperties.sender_id.name)
525:
526: select state,previous_order_id,priority, provisioning_date
527: into lv_state,lv_order_id,lv_priority,lv_prov_date
528: from xdp_order_headers
529: where
530: order_id = lv_wf_object.order_id;
531:
532: if lv_state = 'SUSPENDED' THEN

Line 540: from xdp_order_headers

536: elsif lv_state IN ('WAIT','HOLD') THEN
537: if lv_order_id is not null then
538: begin
539: select state into lv_state2
540: from xdp_order_headers
541: where order_id = lv_order_id;
542: exception
543: when no_data_found then
544: lv_state2 := 'CANCELED';

Line 647: lv_MessageProperties.exception_queue := G_XDP_SCHEMA||'.'||'XDP_ORDER_PROCESSOR_EXPQ';

643: NULL);
644:
645: -- Enqueue it with the commit on a seperate transaction.
646: lv_EnqueueOptions.visibility := DBMS_AQ.ON_COMMIT;
647: lv_MessageProperties.exception_queue := G_XDP_SCHEMA||'.'||'XDP_ORDER_PROCESSOR_EXPQ';
648: lv_MessageProperties.priority := NVL(p_priority,100);
649:
650: if p_prov_date > lv_date then
651: lv_MessageProperties.delay :=

Line 661: queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_PROC_QUEUE',

657: -- Set the Correlation ID Message Property
658: lv_MessageProperties.correlation := p_order_type;
659:
660: DBMS_AQ.ENQUEUE(
661: queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_PROC_QUEUE',
662: enqueue_options => lv_EnqueueOptions,
663: message_properties => lv_MessageProperties,
664: payload =>lv_wf_object,
665: msgid => lv_MsgID);

Line 668: update XDP_ORDER_HEADERS

664: payload =>lv_wf_object,
665: msgid => lv_MsgID);
666:
667:
668: update XDP_ORDER_HEADERS
669: set last_updated_by = FND_GLOBAL.USER_ID,
670: last_update_date = sysdate,
671: last_update_login = FND_GLOBAL.LOGIN_ID,
672: status_code = 'READY',

Line 676: update XDP_ORDER_LINE_ITEMS

672: status_code = 'READY',
673: MSGID = lv_MsgID
674: where order_id = p_order_id;
675:
676: update XDP_ORDER_LINE_ITEMS
677: set last_updated_by = FND_GLOBAL.USER_ID,
678: last_update_date = sysdate,
679: last_update_login = FND_GLOBAL.LOGIN_ID,
680: status_code = 'READY'

Line 688: ,xdp_order.G_external_order_reference

684:
685: EXCEPTION
686: WHEN OTHERS THEN
687: xdp_utilities.generic_error('XDP_AQ_UTILITIES.Add_OrdertoProcessorQ'
688: ,xdp_order.G_external_order_reference
689: ,sqlcode
690: ,sqlerrm);
691: END Add_OrderToProcessorQ;
692:

Line 715: lv_queue_state := Get_Queue_State('XDP_ORDER_PROC_QUEUE');

711: BEGIN
712:
713: while 1=1 loop
714: -- Check queue state
715: lv_queue_state := Get_Queue_State('XDP_ORDER_PROC_QUEUE');
716: IF lv_queue_state = 'ENABLED' THEN -- proceed
717: savepoint order_q_tag;
718:
719: lv_DequeueOptions.visibility := DBMS_AQ.ON_COMMIT;

Line 729: queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_PROC_QUEUE',

725: -- Set Dequeue time out to be 1 second
726: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;
727:
728: DBMS_AQ.DEQUEUE(
729: queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_PROC_QUEUE',
730: dequeue_options => lv_DequeueOptions,
731: message_properties => lv_MessageProperties,
732: payload => lv_wf_object,
733: msgid => lv_MsgID);

Line 746: p_Q_NAME => 'XDP_ORDER_PROC_QUEUE',

742: p_WF_ITEM_TYPE => null,
743: p_WF_ITEM_KEY => null,
744: p_CALLER_NAME => 'Start_OrderProcessor_Workflow',
745: p_CALLBACK_TEXT => NULL ,
746: p_Q_NAME => 'XDP_ORDER_PROC_QUEUE',
747: p_ERROR_DESCRIPTION => 'Can not dequeue: ' || SQLERRM);
748: raise_application_error(-20530,'Can not dequeue: ' || SQLERRM);
749: END;
750:

Line 753: FROM xdp_order_headers

749: END;
750:
751: SELECT status_code
752: INTO lv_state
753: FROM xdp_order_headers
754: WHERE order_id = lv_wf_object.order_id;
755:
756: -- if lv_state = 'SUSPENDED' THEN
757: -- -- Update the msg delay to new high number

Line 766: DBMS_AQ.DEQUEUE( queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_PROC_QUEUE',

762: BEGIN
763: lv_DequeueOptions.msgid := lv_MsgID;
764: lv_DequeueOptions.dequeue_mode := DBMS_AQ.REMOVE_NODATA;
765:
766: DBMS_AQ.DEQUEUE( queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_PROC_QUEUE',
767: dequeue_options => lv_DequeueOptions,
768: message_properties => lv_MessageProperties,
769: payload => lv_tmp,
770: msgid => lv_MsgID);

Line 784: p_Q_NAME => 'XDP_ORDER_PROC_QUEUE',

780: p_WF_ITEM_TYPE => lv_wf_object.wf_item_type,
781: p_WF_ITEM_KEY => lv_wf_object.wf_item_key,
782: p_CALLER_NAME => 'Start_OrderProcessor_Workflow',
783: p_CALLBACK_TEXT => NULL ,
784: p_Q_NAME => 'XDP_ORDER_PROC_QUEUE',
785: p_ERROR_DESCRIPTION => 'Can not start workflow: ' || SQLERRM);
786: raise_application_error(-20530,
787: 'Can not create workflow: ' || SQLERRM);
788: end;

Line 841: DBMS_AQ.DEQUEUE( queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_PROC_QUEUE',

837: BEGIN
838: -- Set Dequeue time out to be 1 second
839: lv_DequeueOptions.wait := p_message_wait_timeout;
840:
841: DBMS_AQ.DEQUEUE( queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_PROC_QUEUE',
842: dequeue_options => lv_DequeueOptions,
843: message_properties => lv_MessageProperties,
844: payload => lv_wf_object,
845: msgid => lv_MsgID);

Line 859: p_Q_NAME => 'XDP_ORDER_PROC_QUEUE',

855: p_WF_ITEM_TYPE => null,
856: p_WF_ITEM_KEY => null,
857: p_CALLER_NAME => 'Start_OrderProcessor_Workflow',
858: p_CALLBACK_TEXT => NULL ,
859: p_Q_NAME => 'XDP_ORDER_PROC_QUEUE',
860: p_ERROR_DESCRIPTION => 'Can not dequeue: ' || SQLERRM);
861:
862: raise_application_error(-20530,'Can not dequeue: ' || SQLERRM);
863: END;

Line 889: p_Q_NAME => 'XDP_ORDER_PROC_QUEUE',

885: p_WF_ITEM_TYPE => lv_wf_object.wf_item_type,
886: p_WF_ITEM_KEY => lv_wf_object.wf_item_key,
887: p_CALLER_NAME => 'Start_OrderProcessor_Workflow',
888: p_CALLBACK_TEXT => NULL ,
889: p_Q_NAME => 'XDP_ORDER_PROC_QUEUE',
890: p_ERROR_DESCRIPTION => 'Can not start workflow: ' || SQLERRM);
891:
892: raise_application_error(-20530,'Can not create workflow: '||SQLERRM);
893: END;

Line 2022: l_OrderObj SYSTEM.XDP_ORDER_OBJ;

2018: p_ObjectType VARCHAR2,
2019: p_ReturnCode OUT NOCOPY NUMBER,
2020: p_ErrorDescription OUT NOCOPY VARCHAR2) IS
2021:
2022: l_OrderObj SYSTEM.XDP_ORDER_OBJ;
2023: l_EnqueueOptions DBMS_AQ.ENQUEUE_OPTIONS_T;
2024: l_MessageProperties DBMS_AQ.MESSAGE_PROPERTIES_T;
2025: l_MsgID RAW(16);
2026:

Line 2029: l_OrderObj := SYSTEM.XDP_ORDER_OBJ(

2025: l_MsgID RAW(16);
2026:
2027: BEGIN
2028:
2029: l_OrderObj := SYSTEM.XDP_ORDER_OBJ(
2030: p_OrderID,
2031: p_ObjectType);
2032:
2033: l_EnqueueOptions.visibility := DBMS_AQ.ON_COMMIT;

Line 2034: l_MessageProperties.exception_queue := G_XDP_SCHEMA||'.'||'XDP_ORDER_OBJ_Excep_Q';

2030: p_OrderID,
2031: p_ObjectType);
2032:
2033: l_EnqueueOptions.visibility := DBMS_AQ.ON_COMMIT;
2034: l_MessageProperties.exception_queue := G_XDP_SCHEMA||'.'||'XDP_ORDER_OBJ_Excep_Q';
2035:
2036:
2037: DBMS_AQ.ENQUEUE (
2038: queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_OBJ_Q',

Line 2038: queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_OBJ_Q',

2034: l_MessageProperties.exception_queue := G_XDP_SCHEMA||'.'||'XDP_ORDER_OBJ_Excep_Q';
2035:
2036:
2037: DBMS_AQ.ENQUEUE (
2038: queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_OBJ_Q',
2039: enqueue_options => l_EnqueueOptions,
2040: message_properties => l_MessageProperties,
2041: payload => l_OrderObj,
2042: msgid => l_MsgID);

Line 2668: PROCEDURE DQ_XDP_ORDER_PROC_QUEUE( p_return_code OUT NOCOPY NUMBER,

2664:
2665: /*
2666: * Dequeue from Order Queue
2667: */
2668: PROCEDURE DQ_XDP_ORDER_PROC_QUEUE( p_return_code OUT NOCOPY NUMBER,
2669: p_error_description OUT NOCOPY VARCHAR2) AS
2670:
2671: l_time_out VARCHAR2(20) ;
2672: l_message_key VARCHAR2(2000) ;

Line 2705: END DQ_XDP_ORDER_PROC_QUEUE;

2701: p_error_description := sqlerrm ;
2702: fnd_file.put_line(fnd_file.log,'Error Code : ' ||p_return_code);
2703: fnd_file.put_line(fnd_file.log,'Error Message : ' ||p_error_description);
2704:
2705: END DQ_XDP_ORDER_PROC_QUEUE;
2706:
2707: /*
2708: * Dequeue from Fulfillment Action Queue
2709: */

Line 2853: DQ_XDP_ORDER_PROC_REENQ( p_message_wait_timeout => g_msg_wait_timeout,

2849:
2850: /* Order Queue */
2851: BEGIN
2852:
2853: DQ_XDP_ORDER_PROC_REENQ( p_message_wait_timeout => g_msg_wait_timeout,
2854: p_correlation_id => null );
2855:
2856: EXCEPTION
2857: WHEN others THEN

Line 2860: fnd_file.put_line(fnd_file.log,'Error in DQ_EXCP_REENQ: DQ_XDP_ORDER_PROC_REENQ');

2856: EXCEPTION
2857: WHEN others THEN
2858: p_return_code := sqlcode ;
2859: p_error_description := sqlerrm ;
2860: fnd_file.put_line(fnd_file.log,'Error in DQ_EXCP_REENQ: DQ_XDP_ORDER_PROC_REENQ');
2861: fnd_file.put_line(fnd_file.log,'Error Code : ' ||sqlcode);
2862: fnd_file.put_line(fnd_file.log,'Error Message : ' ||sqlerrm);
2863:
2864: END;

Line 2970: PROCEDURE DQ_XDP_ORDER_PROC_REENQ( p_message_wait_timeout IN NUMBER DEFAULT 1,

2966:
2967: END DQ_EXCP_REENQ;
2968:
2969:
2970: PROCEDURE DQ_XDP_ORDER_PROC_REENQ( p_message_wait_timeout IN NUMBER DEFAULT 1,
2971: p_correlation_id IN VARCHAR2 )
2972:
2973: IS
2974:

Line 3003: DBMS_AQ.DEQUEUE( queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_PROCESSOR_EXPQ',

2999: FOR i IN 1..G_DQ_COUNT
3000: LOOP
3001:
3002: BEGIN
3003: DBMS_AQ.DEQUEUE( queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_PROCESSOR_EXPQ',
3004: dequeue_options => lv_DequeueOptions,
3005: message_properties => lv_MessageProperties,
3006: payload => lv_wf_object,
3007: msgid => lv_MsgID);

Line 3034: END DQ_XDP_ORDER_PROC_REENQ;

3030: WHEN OTHERS THEN
3031: ROLLBACK TO order_q_tag;
3032: RAISE;
3033:
3034: END DQ_XDP_ORDER_PROC_REENQ;
3035:
3036:
3037: PROCEDURE DQ_XDP_FA_REENQ( p_message_wait_timeout IN NUMBER DEFAULT 1,
3038: p_correlation_id IN VARCHAR2 )

Line 3748: FROM xdp_order_headers

3744: SELECT count(*)
3745: INTO l_count
3746: FROM fnd_lookup_values
3747: WHERE UPPER(lookup_code) = ( SELECT UPPER(order_type)
3748: FROM xdp_order_headers
3749: WHERE order_id = l_order_id )
3750: AND lookup_type = 'XDP_HA_ORDER_TYPES';
3751:
3752: IF l_count < 1 THEN