[Home] [Help]
316: fnd_msg_pub.ADD;
317: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE, p_count => l_msg_count, p_data => x_error_msg );
318: l_error_msg :='Invalid context for Carton LPN:'||p_new_carton_lpn_id;
319: IF(l_debug = 1) THEN
320: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
321: END IF;
322: RETURN;
323: ELSIF (l_carton_lpn_itm_id is NULL) THEN
324: x_return_status := fnd_api.g_ret_sts_error;
326: fnd_msg_pub.ADD;
327: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE, p_count => l_msg_count, p_data => x_error_msg );
328: l_error_msg :='Inventory item id is not present in carton LPN';
329: IF(l_debug = 1) THEN
330: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
331: END IF;
332: RETURN;
333: END IF;
334:
367: fnd_msg_pub.ADD;
368: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE, p_count => l_msg_count, p_data => x_error_msg );
369: l_error_msg :='Organization is not same for Carton LPN and Task';
370: IF(l_debug = 1) THEN
371: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
372: END IF;
373: RETURN;
374: END IF;
375: --Bulk tasks cannot be cartonized
383: fnd_msg_pub.ADD;
384: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE, p_count => l_msg_count, p_data => x_error_msg );
385: l_error_msg :='Bulk Tasks cannot be cartonized';
386: IF(l_debug = 1) THEN
387: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
388: END IF;
389: CLOSE c_bulk_task;
390: RETURN;
391: END IF;
412: fnd_msg_pub.ADD;
413: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => x_error_msg );
414: l_error_msg :='Data not present in WDD for the corresponding task :'||p_task_table(i).transaction_number;
415: IF(l_debug = 1) THEN
416: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
417: END IF;
418: RETURN;
419: ELSE
420: l_del_det_id_tab(l_del_det_id_tab.count +1) := l_temp_del_detail_id;
465: fnd_msg_pub.ADD;
466: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => x_error_msg );
467: l_error_msg :='Delivery grouping mismatch,cartonization cannot be done';
468: IF(l_debug = 1) THEN
469: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
470: END IF;
471: RETURN;
472: END IF;
473: END LOOP;
483: fnd_msg_pub.ADD;
484: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => x_error_msg );
485: l_error_msg :='Delivery mismatch,cartonization cannot be done';
486: IF(l_debug = 1) THEN
487: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
488: END IF;
489: RETURN;
490: END IF;
491: END LOOP;
517: fnd_msg_pub.ADD;
518: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => x_error_msg );
519: l_error_msg :='Error returned from WSH API';
520: IF(l_debug = 1) THEN
521: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
522: END IF;
523: RETURN;
524: END IF;
525: END IF;
627: WHEN OTHERS THEN
628: NULL;
629: l_msg := 'Error in querying Active tasks';
630: IF(l_debug = 1) THEN
631: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
632: END IF;
633: p_output_task_rec.RESULT := 'E';
634: p_output_task_rec.ERROR := l_err_msg;
635: RETURN;
639: fnd_msg_pub.ADD;
640: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
641: l_msg := 'Active task can be updated if tasks assigned to user is logged off the system';
642: IF(l_debug = 1) THEN
643: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
644: END IF;
645: p_output_task_rec.RESULT := 'E';
646: p_output_task_rec.ERROR := l_err_msg;
647: RETURN;
676: WHEN OTHERS THEN
677: NULL;
678: l_msg := 'Error in querying Dispatched tasks';
679: IF(l_debug = 1) THEN
680: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
681: END IF;
682: p_output_task_rec.RESULT := 'E';
683: p_output_task_rec.ERROR := l_err_msg;
684: RETURN;
688: fnd_msg_pub.ADD;
689: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
690: l_msg := 'Dispatcher task can be updated only if any of the task in group is not in Active status';
691: IF(l_debug = 1) THEN
692: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
693: END IF;
694: p_output_task_rec.RESULT := 'E';
695: p_output_task_rec.ERROR := l_err_msg;
696: RETURN;
708: fnd_msg_pub.ADD;
709: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
710: l_msg := 'Active task can be moved only to Pending or Unreleased state';
711: IF(l_debug = 1) THEN
712: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
713: END IF;
714: p_output_task_rec.RESULT := 'E';
715: p_output_task_rec.ERROR := l_err_msg;
716: RETURN;
723: fnd_msg_pub.ADD;
724: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
725: l_msg := 'Dispatcher task can be moved only to Pending or Unreleased state';
726: IF(l_debug = 1) THEN
727: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
728: END IF;
729: p_output_task_rec.RESULT := 'E';
730: p_output_task_rec.ERROR := l_err_msg;
731: RETURN;
738: fnd_msg_pub.ADD;
739: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
740: l_msg := 'Unreleased task can be moved only to Pending or Queued state';
741: IF(l_debug = 1) THEN
742: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
743: END IF;
744: p_output_task_rec.RESULT := 'E';
745: p_output_task_rec.ERROR := l_err_msg;
746: RETURN;
753: fnd_msg_pub.ADD;
754: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
755: l_msg := 'Pending task can be moved only to Queued state';
756: IF(l_debug = 1) THEN
757: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
758: END IF;
759: p_output_task_rec.RESULT := 'E';
760: p_output_task_rec.ERROR := l_err_msg;
761: RETURN;
765: fnd_msg_pub.ADD;
766: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
767: l_msg := 'Invalid task status';
768: IF(l_debug = 1) THEN
769: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
770: END IF;
771: p_output_task_rec.RESULT := 'E';
772: p_output_task_rec.ERROR := l_err_msg;
773: RETURN;
783: fnd_msg_pub.ADD;
784: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
785: l_msg := 'Inbound task priority cannot be updated';
786: IF(l_debug = 1) THEN
787: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
788: END IF;
789: p_output_task_rec.RESULT := 'E';
790: p_output_task_rec.ERROR := l_err_msg;
791: RETURN;
808: fnd_msg_pub.ADD;
809: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
810: l_msg := 'Standard task type associated with the user task is different from the current standard task type';
811: IF(l_debug = 1) THEN
812: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
813: END IF;
814: p_output_task_rec.RESULT := 'E';
815: p_output_task_rec.ERROR := l_err_msg;
816: RETURN;
829: p_output_task_rec.RESULT := 'E';
830: p_output_task_rec.ERROR := l_err_msg;
831: l_msg := 'Organization associated with the operation plan is different from that of the task';
832: IF(l_debug = 1) THEN
833: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
834: END IF;
835: RETURN;
836: END IF;
837: END IF;
860: p_output_task_rec.ERROR := l_err_msg;
861: l_msg := 'Inspection/Standard operation plan can only be replaced with another Inspection/Standard operation plan
862: and cross dock operation can be replaced with another cross dock operation plan or non-cross dock Operation plan ';
863: IF(l_debug = 1) THEN
864: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
865: END IF;
866: RETURN;
867: END IF;
868: ELSE
872: p_output_task_rec.RESULT := 'E';
873: p_output_task_rec.ERROR := l_err_msg;
874: l_msg := 'Current or new operation plan type is NULL';
875: IF(l_debug = 1) THEN
876: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
877: END IF;
878: RETURN;
879: END IF;
880: END IF;
888: p_output_task_rec.ERROR := l_err_msg;
889: p_output_task_rec.RESULT := 'E';
890: l_msg := 'Mismatch in the operation plan activity type and task type';
891: IF(l_debug = 1) THEN
892: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
893: END IF;
894: RETURN;
895: ELSE
896: --operation plan code changes start 6888354
904: FETCH C_OP_PLANS_B
905: INTO l_op_plan_b_rec;
906: IF (C_OP_PLANS_B%NOTFOUND) THEN
907: IF (l_debug=1) THEN
908: inv_trx_util_pub.trace('Records not found in WMS_OP_PLANS_B for given p_new_operation_plan_id');
909: fnd_message.set_name('WMS', ' WMS_INVALID_TASK');--new message
910: fnd_msg_pub.ADD;
911: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
912: l_msg := 'No of Records found in WMS_OP_PLANS_B for given operation plan id';
910: fnd_msg_pub.ADD;
911: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
912: l_msg := 'No of Records found in WMS_OP_PLANS_B for given operation plan id';
913: IF(l_debug = 1) THEN
914: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
915: END IF;
916: p_output_task_rec.RESULT := 'E';
917: p_output_task_rec.ERROR := l_err_msg;
918: RETURN;
918: RETURN;
919: END IF;
920: CLOSE C_OP_PLANS_B;
921: ELSE
922: inv_trx_util_pub.trace('updating wms_op_plan_instances.........');
923: UPDATE wms_op_plan_instances
924: SET OPERATION_PLAN_ID=l_op_plan_b_rec.OPERATION_PLAN_ID,
925: -- SYSTEM_TASK_TYPE =l_op_plan_b_rec.SYSTEM_TASK_TYPE , Bug#8978253
926: ACTIVITY_TYPE_ID =l_op_plan_b_rec.ACTIVITY_TYPE_ID ,
935: FETCH c_plan_detail
936: INTO l_operation_plan_detail_rec;
937: IF (c_plan_detail%NOTFOUND) THEN
938: IF (l_debug=1) THEN
939: inv_trx_util_pub.trace('Records not found in WMS_OP_PLAN_DETAILS for given operation plan id');
940: fnd_message.set_name('WMS', ' WMS_INVALID_TASK');--new message
941: fnd_msg_pub.ADD;
942: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
943: l_msg := 'No of Records found in WMS_OP_PLAN_DETAILS for given operation plan id';
941: fnd_msg_pub.ADD;
942: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
943: l_msg := 'No of Records found in WMS_OP_PLAN_DETAILS for given operation plan id';
944: IF(l_debug = 1) THEN
945: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
946: END IF;
947: p_output_task_rec.RESULT := 'E';
948: p_output_task_rec.ERROR := l_err_msg;
949: RETURN;
949: RETURN;
950: END IF;
951: CLOSE c_plan_detail;
952: ELSE
953: inv_trx_util_pub.trace('updating wms_op_operation_instances.........');
954: UPDATE wms_op_operation_instances
955: --SET OPERATION_TYPE =l_operation_plan_detail_rec.OPERATION_TYPE , Bug#8978253
956: SET OPERATION_PLAN_DETAIL_ID=l_operation_plan_detail_rec.OPERATION_PLAN_DETAIL_ID ,
957: OPERATION_SEQUENCE =l_operation_plan_detail_rec.OPERATION_SEQUENCE ,
971: fnd_msg_pub.ADD;
972: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
973: l_msg := 'STATUS in wms_op_plan_instances is not pending';
974: IF(l_debug = 1) THEN
975: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
976: END IF;
977: p_output_task_rec.RESULT := 'E';
978: p_output_task_rec.ERROR := l_err_msg;
979: RETURN;
999: EXCEPTION
1000: WHEN OTHERS THEN
1001: ROLLBACK TO inb_op_sp;
1002: p_output_task_rec.RESULT := 'E';
1003: inv_trx_util_pub.trace('Exception Occured while updating operation plan');
1004: RETURN;
1005: END;
1006: --operation plan code changes end 6888354
1007:
1014: fnd_msg_pub.ADD;
1015: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => l_err_msg );
1016: l_msg := 'Mismatch in the operation plan activity type and task type';
1017: IF(l_debug = 1) THEN
1018: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
1019: END IF;
1020: p_output_task_rec.RESULT := 'E';
1021: p_output_task_rec.ERROR := l_err_msg;
1022: RETURN;
1275: fnd_msg_pub.ADD;
1276: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => x_error_msg );
1277: l_error_msg :='Invalid context for Carton LPN:'||p_new_carton_lpn_id;
1278: IF(l_debug = 1) THEN
1279: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
1280: END IF;
1281: RETURN;
1282: END IF;
1283: IF (l_carton_lpn_ctx = 5 ) THEN
1307: fnd_msg_pub.ADD;
1308: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => x_error_msg );
1309: l_error_msg :='Organization is not same for Carton LPN and Task';
1310: IF(l_debug = 1) THEN
1311: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
1312: END IF;
1313: RETURN;
1314: END IF;
1315: --Bulk tasks cannot be cartonized
1323: fnd_msg_pub.ADD;
1324: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => x_error_msg );
1325: l_error_msg :='Bulk Tasks cannot be cartonized';
1326: IF(l_debug = 1) THEN
1327: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
1328: END IF;
1329: CLOSE c_bulk_task;
1330: RETURN;
1331: END IF;
1352: fnd_msg_pub.ADD;
1353: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => x_error_msg );
1354: l_error_msg :='Data not present in WDD for the corresponding task :'||p_task_table(i).transaction_number;
1355: IF(l_debug = 1) THEN
1356: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
1357: END IF;
1358: RETURN;
1359: ELSE
1360: l_del_det_id_tab(l_del_det_id_tab.count +1) := l_temp_del_detail_id;
1386: fnd_msg_pub.ADD;
1387: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => x_error_msg );
1388: l_error_msg :='Delivery mismatch,cartonization cannot be done';
1389: IF(l_debug = 1) THEN
1390: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
1391: END IF;
1392: RETURN;
1393: END IF;
1394: END LOOP;
1418: fnd_msg_pub.ADD;
1419: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => l_msg_count, p_data => x_error_msg );
1420: l_error_msg :='Carton group mismatch,cartonization cannot be done';
1421: IF(l_debug = 1) THEN
1422: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
1423: END IF;
1424: RETURN;
1425: END IF;
1426: END LOOP;
5342: WHERE transaction_temp_id = p_transaction_number;
5343:
5344: IF(l_debug = 1) THEN
5345: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for task: '||p_transaction_number;
5346: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5347: END IF;
5348:
5349: --Munish
5350: OPEN c_cd_task (p_transaction_number);
5452: END IF;
5453:
5454: IF(l_debug = 1) THEN
5455: l_err_msg := 'Status returned by API wms_waveplan_tasks_pvt.query_tasks: '||x_return_status;
5456: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5457: END IF;
5458:
5459: IF (x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
5460: /* SELECT * BULK COLLECT
5608: END;
5609:
5610: IF(l_debug = 1) THEN
5611: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for cycle count task: '||p_transaction_number;
5612: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5613: inv_trx_util_pub.trace('Cycle Count Name '||v_cycle_count_name);
5614: END IF;
5615:
5616: wms_waveplan_tasks_pvt.query_tasks(
5609:
5610: IF(l_debug = 1) THEN
5611: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for cycle count task: '||p_transaction_number;
5612: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5613: inv_trx_util_pub.trace('Cycle Count Name '||v_cycle_count_name);
5614: END IF;
5615:
5616: wms_waveplan_tasks_pvt.query_tasks(
5617: p_add => FALSE
5654:
5655:
5656: IF(l_debug = 1) THEN
5657: l_err_msg := 'Status returned by API wms_waveplan_tasks_pvt.query_tasks for cycle count task: '||x_return_status;
5658: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5659: END IF;
5660:
5661: IF (x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
5662: /* SELECT * BULK COLLECT
5794: EXCEPTION
5795: WHEN NO_DATA_FOUND THEN
5796: --start changes for completed tasks
5797: BEGIN
5798: inv_trx_util_pub.trace('checking in wdth for completed inbound or crossdock tasks');
5799: SELECT *
5800: INTO l_wdth_rec
5801: FROM wms_dispatched_tasks_history
5802: WHERE transaction_id = p_transaction_number;
5802: WHERE transaction_id = p_transaction_number;
5803:
5804: IF(l_debug = 1) THEN
5805: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for task: '||p_transaction_number;
5806: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5807: END IF;
5808:
5809: --Munish checking completed crossdock task
5810: OPEN c_cd_task1 (p_transaction_number);
5811: FETCH c_cd_task1 into c_cd_exist;
5812: CLOSE c_cd_task1;
5813:
5814: If (c_cd_exist = 1) THEN
5815: inv_trx_util_pub.trace('calling API wms_waveplan_tasks_pvt.query_tasks for completed crossdock task');
5816: --CALLL wms_waveplan_tasks_pvt.query_tasks API WITH
5817: --p_crossdock_include=true and p_outbound_include=false and p_inbound_include=false
5818: wms_waveplan_tasks_pvt.query_tasks(
5819: p_add => FALSE
5859: );
5860: ELSE
5861: --CALLL wms_waveplan_tasks_pvt.query_tasks API WITH p_crossdock_include=false and
5862: --p_outbound_include=true and p_inbound_include=true
5863: inv_trx_util_pub.trace('calling completed inbound task');--mkgupta2
5864: IF l_wdth_rec.is_parent ='Y' THEN
5865: inv_trx_util_pub.trace('checking if its a parent task completed inbound task');
5866: l_wdth_rec.source_subinventory_code:=NULL;
5867: l_wdth_rec.source_locator_id:=NULL;
5861: --CALLL wms_waveplan_tasks_pvt.query_tasks API WITH p_crossdock_include=false and
5862: --p_outbound_include=true and p_inbound_include=true
5863: inv_trx_util_pub.trace('calling completed inbound task');--mkgupta2
5864: IF l_wdth_rec.is_parent ='Y' THEN
5865: inv_trx_util_pub.trace('checking if its a parent task completed inbound task');
5866: l_wdth_rec.source_subinventory_code:=NULL;
5867: l_wdth_rec.source_locator_id:=NULL;
5868: END IF;
5869: wms_waveplan_tasks_pvt.query_tasks(
5911: END IF;
5912:
5913: IF(l_debug = 1) THEN
5914: l_err_msg := 'Status returned by API wms_waveplan_tasks_pvt.query_tasks: '||x_return_status;
5915: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5916: END IF;
5917:
5918: IF (x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
5919: SELECT
6041: WHERE transaction_temp_id = p_transaction_number;
6042: END IF;
6043: EXCEPTION
6044: WHEN NO_DATA_FOUND THEN
6045: inv_trx_util_pub.trace('in the NO_DATA_FOUND exception block of inbound/crossdock completed task');
6046: BEGIN
6047: inv_trx_util_pub.trace('checking in mmt for outbound/warehouse/manufacturing completed task');
6048: SELECT *
6049: INTO l_mmt_rec
6043: EXCEPTION
6044: WHEN NO_DATA_FOUND THEN
6045: inv_trx_util_pub.trace('in the NO_DATA_FOUND exception block of inbound/crossdock completed task');
6046: BEGIN
6047: inv_trx_util_pub.trace('checking in mmt for outbound/warehouse/manufacturing completed task');
6048: SELECT *
6049: INTO l_mmt_rec
6050: FROM mtl_material_transactions
6051: WHERE transaction_id = p_transaction_number;
6048: SELECT *
6049: INTO l_mmt_rec
6050: FROM mtl_material_transactions
6051: WHERE transaction_id = p_transaction_number;
6052: inv_trx_util_pub.trace('task existing in mmt');
6053:
6054: IF(l_debug = 1) THEN
6055: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for task: '||p_transaction_number;
6056: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6052: inv_trx_util_pub.trace('task existing in mmt');
6053:
6054: IF(l_debug = 1) THEN
6055: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for task: '||p_transaction_number;
6056: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6057: END IF;
6058:
6059: inv_trx_util_pub.trace('checking for bulk task');
6060: IF l_mmt_rec.parent_transaction_id IS NOT NULL THEN
6055: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for task: '||p_transaction_number;
6056: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6057: END IF;
6058:
6059: inv_trx_util_pub.trace('checking for bulk task');
6060: IF l_mmt_rec.parent_transaction_id IS NOT NULL THEN
6061: l_mmt_rec.pick_slip_number:=NULL;
6062: END IF;
6063: wms_waveplan_tasks_pvt.query_tasks(
6104: );
6105:
6106: IF(l_debug = 1) THEN
6107: l_err_msg := 'Status returned by API wms_waveplan_tasks_pvt.query_tasks: '||x_return_status;
6108: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6109: END IF;
6110:
6111: IF (x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
6112: SELECT
6235:
6236: END IF;
6237: EXCEPTION
6238: WHEN NO_DATA_FOUND THEN
6239: inv_trx_util_pub.trace('in the exception block of outbond/manufacturing/warehousing complete tasks');
6240: fnd_message.set_name('WMS', 'WMS_INVALID_TASK');
6241: fnd_msg_pub.ADD;
6242: x_return_status := fnd_api.g_ret_sts_unexp_error;
6243: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6242: x_return_status := fnd_api.g_ret_sts_unexp_error;
6243: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6244: l_err_msg := 'Failed to fetch data from MMTT,MCCE,MMT or WDTH tables for transaction number '||p_transaction_number;
6245: IF(l_debug = 1) THEN
6246: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6247: END IF;
6248: END;
6249: --end the begin block for outbond/manufacturing/warehousing complete tasks
6250: END;
6255: x_return_status := fnd_api.g_ret_sts_unexp_error;
6256: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6257: l_err_msg := substr(SQLERRM,1,1000);
6258: IF(l_debug = 1) THEN
6259: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6260: END IF;
6261: END;
6262: --end the begin block for uncompleted tasks
6263:
6405: IF (l_execute_qry) THEN
6406:
6407: IF(l_debug = 1) THEN
6408: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for Query: '||p_query_name;
6409: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6410: END IF;
6411:
6412: wms_waveplan_tasks_pvt.query_tasks (
6413: FALSE, ---p_add BOOLEAN DEFAULT FALSE,
6514: );
6515:
6516: IF(l_debug = 1) THEN
6517: l_err_msg := 'Status returned by API wms_waveplan_tasks_pvt.query_tasks: '||x_return_status;
6518: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6519: END IF;
6520:
6521: IF(x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
6522: /* SELECT * BULK COLLECT
6653: x_return_status := fnd_api.g_ret_sts_unexp_error;
6654: fnd_message.set_name('WMS', 'WMS_INVALID_VALUE');
6655: fnd_msg_pub.ADD;
6656: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6657: inv_trx_util_pub.trace(l_api_name||': '||'Invalid Parameters Passed');
6658: END IF; ----if p_transaction_number is not null
6659:
6660: EXCEPTION
6661: WHEN l_invalid_org THEN
6661: WHEN l_invalid_org THEN
6662: x_return_status := fnd_api.g_ret_sts_unexp_error;
6663: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6664: IF(l_debug = 1) THEN
6665: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6666: END IF;
6667: NULL;
6668:
6669: WHEN l_qry_fail THEN
6669: WHEN l_qry_fail THEN
6670: x_return_status := fnd_api.g_ret_sts_unexp_error;
6671: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6672: IF(l_debug = 1) THEN
6673: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6674: END IF;
6675: NULL;
6676:
6677: WHEN OTHERS THEN
6678: x_return_status := fnd_api.g_ret_sts_unexp_error;
6679: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6680: l_err_msg := substr(SQLERRM,1,1000);
6681: IF(l_debug = 1) THEN
6682: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6683: END IF;
6684: NULL;
6685:
6686: END query_task;
7408: x_msg_data := l_msg;
7409: x_msg_count := l_msg_count;
7410: l_err_msg :='New task status not in Pending or Queued state or Unreleased state';
7411: IF(l_debug = 1) THEN
7412: inv_trx_util_pub.trace(l_api_name|| ': '||l_err_msg);
7413: END IF;
7414: log_error(p_transaction_number => p_transaction_number, p_task_table => p_task_table, p_error_msg => l_msg, x_updated_tasks => x_updated_tasks);
7415: RETURN;
7416: END IF;
7434: x_msg_data := l_msg;
7435: x_msg_count := l_msg_count;
7436: l_err_msg :='Operation Plan is not enabled';
7437: IF(l_debug = 1) THEN
7438: inv_trx_util_pub.trace(l_api_name|| ': '||l_err_msg);
7439: END IF;
7440: log_error(p_transaction_number => p_transaction_number,
7441: p_task_table => p_task_table,
7442: p_error_msg => l_msg,
7478: x_msg_count := x_msg_count + 1;
7479:
7480: l_err_msg :='Error in querying task from Query_task API for transaction_number :'||p_task_table(i).transaction_number ||'This task will be skipped';
7481: IF(l_debug = 1) THEN
7482: inv_trx_util_pub.trace(l_api_name|| ': '||l_err_msg);
7483: END IF;
7484: x_updated_tasks(i) := l_updated_tasks(i);
7485: x_updated_tasks(i).RESULT := 'E';
7486: x_updated_tasks(i).ERROR := l_msg;
7511: x_msg_data := l_msg;
7512: x_msg_count := l_msg_count;
7513: -- l_err_msg :='Task Validation Failed';
7514: IF(l_debug = 1) THEN
7515: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
7516: END IF;
7517: RETURN;
7518: END IF;
7519: IF (l_valid_task_counter <=0 ) THEN
7554: x_updated_tasks(i).RESULT := 'E';
7555: x_updated_tasks(i).ERROR := l_error_msg;
7556: END LOOP;
7557: IF(l_debug = 1) THEN
7558: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
7559: END IF;
7560: RETURN;
7561: END IF;
7562: ELSE
7565: fnd_msg_pub.ADD;
7566: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data );
7567: l_err_msg := 'Some tasks have failed validation,cartonization cannot be done';
7568: IF(l_debug = 1) THEN
7569: inv_trx_util_pub.trace(l_api_name|| ': '||l_err_msg);
7570: END IF;
7571: RETURN;
7572: END IF;
7573: END IF;
7590: l_err_msg := substr(SQLERRM,1,1000);
7591: x_updated_tasks(i).RESULT := 'E';
7592: x_updated_tasks(i).ERROR := l_err_msg;
7593: IF(l_debug = 1) THEN
7594: inv_trx_util_pub.trace(l_api_name|| ': '||l_err_msg);
7595: END IF;
7596: END;
7597: p_temp_task_rec := x_updated_tasks(i);
7598:
7765: x_return_status := fnd_api.g_ret_sts_unexp_error;
7766: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
7767: l_err_msg := substr(SQLERRM,1,1000);
7768: IF(l_debug = 1) THEN
7769: inv_trx_util_pub.trace(l_api_name|| ': '||l_err_msg);
7770: END IF;
7771:
7772: END modify_task;
7773:
7827: l_task_table := p_wms_task;
7828:
7829:
7830: IF l_debug = 1 THEN
7831: inv_trx_util_pub.trace('CANCEL_TASK: Enter...');
7832: END IF;
7833:
7834: WMS_TASK_MGMT_PUB.validate_tasks( p_transaction_number => l_transaction_number ,
7835: p_task_table => l_task_table ,
7835: p_task_table => l_task_table ,
7836: x_wms_task => l_ret_task_table ,
7837: x_return_status => l_val_ret_status );
7838: IF l_debug = 1 THEN
7839: inv_trx_util_pub.trace('cancel_task l_val_ret_status is : '||l_val_ret_status);
7840: END IF;
7841:
7842: IF (l_val_ret_status = fnd_api.g_ret_sts_success) THEN
7843: IF l_debug = 1 THEN
7840: END IF;
7841:
7842: IF (l_val_ret_status = fnd_api.g_ret_sts_success) THEN
7843: IF l_debug = 1 THEN
7844: inv_trx_util_pub.trace('l_ret_task_table.count : '||l_ret_task_table.count);
7845: END IF;
7846:
7847: FOR i in 1..l_ret_task_table.count LOOP
7848: IF l_debug = 1 THEN
7845: END IF;
7846:
7847: FOR i in 1..l_ret_task_table.count LOOP
7848: IF l_debug = 1 THEN
7849: inv_trx_util_pub.trace('cancel_task l_ret_task_table(i).RESULT '||l_ret_task_table(i).RESULT);
7850: END IF;
7851: IF ( nvl(l_ret_task_table(i).RESULT,'X')<> FND_API.G_RET_STS_ERROR)THEN
7852: IF l_debug = 1 THEN
7853: inv_trx_util_pub.trace('cancel_task transaction_number '||l_ret_task_table(i).transaction_number);
7849: inv_trx_util_pub.trace('cancel_task l_ret_task_table(i).RESULT '||l_ret_task_table(i).RESULT);
7850: END IF;
7851: IF ( nvl(l_ret_task_table(i).RESULT,'X')<> FND_API.G_RET_STS_ERROR)THEN
7852: IF l_debug = 1 THEN
7853: inv_trx_util_pub.trace('cancel_task transaction_number '||l_ret_task_table(i).transaction_number);
7854: END IF;
7855: SAVEPOINT SAVEPOINT1;
7856: WMS_CROSS_DOCK_PVT.cancel_crossdock_task(p_transaction_temp_id => l_ret_task_table(i).transaction_number
7857: ,x_return_status => x_return_status
7857: ,x_return_status => x_return_status
7858: ,x_msg_data => x_msg_data
7859: ,x_msg_count => x_msg_count);
7860: IF l_debug = 1 THEN
7861: inv_trx_util_pub.trace('cancel_task CANCEL_TASK: x_return_status: ' || x_return_status);
7862: END IF;
7863:
7864: IF (x_return_status<>FND_API.G_RET_STS_SUCCESS) THEN
7865: FND_MESSAGE.SET_NAME('WMS', 'WMS_CANCEL_FAILED');
7878: l_msg := fnd_message.get;
7879: x_msg_count := x_msg_count + 1;
7880: x_msg_data := x_msg_data || l_msg;
7881: IF l_debug = 1 THEN
7882: inv_trx_util_pub.trace('Validate_task returned error for this record');
7883: END IF;
7884: x_unprocessed_crossdock_tasks(l_unprocessed_crossdock_count).transaction_number := l_transaction_number;
7885: x_unprocessed_crossdock_tasks(l_unprocessed_crossdock_count).result := l_ret_task_table(i).RESULT;
7886: x_unprocessed_crossdock_tasks(l_unprocessed_crossdock_count).error := l_msg;
7887: l_unprocessed_crossdock_count := l_unprocessed_crossdock_count+1;
7888: END IF;
7889: END LOOP;
7890: IF l_debug = 1 THEN
7891: inv_trx_util_pub.trace('CANCEL_TASK: x_unprocessed_crossdock_tasks: ' || x_unprocessed_crossdock_tasks.count);
7892: inv_trx_util_pub.trace('CANCEL_TASK: Exiting...');
7893: END IF;
7894: ELSE
7895: IF l_debug = 1 THEN
7888: END IF;
7889: END LOOP;
7890: IF l_debug = 1 THEN
7891: inv_trx_util_pub.trace('CANCEL_TASK: x_unprocessed_crossdock_tasks: ' || x_unprocessed_crossdock_tasks.count);
7892: inv_trx_util_pub.trace('CANCEL_TASK: Exiting...');
7893: END IF;
7894: ELSE
7895: IF l_debug = 1 THEN
7896: inv_trx_util_pub.trace('CANCEL_TASK: Error occured while validating the transaction_number or table of transaction_number...');
7892: inv_trx_util_pub.trace('CANCEL_TASK: Exiting...');
7893: END IF;
7894: ELSE
7895: IF l_debug = 1 THEN
7896: inv_trx_util_pub.trace('CANCEL_TASK: Error occured while validating the transaction_number or table of transaction_number...');
7897: END IF;
7898: x_return_status:=FND_API.G_RET_STS_UNEXP_ERROR;
7899: RETURN;
7900: END IF;
7904: END IF;
7905: EXCEPTION
7906: WHEN fnd_api.g_exc_error THEN
7907: IF l_debug = 1 THEN
7908: inv_trx_util_pub.trace('CANCEL_TASK: Expected Error occurred while performing cancel cross dock task:'|| SQLCODE);
7909: END IF;
7910: x_return_status:=FND_API.G_RET_STS_ERROR;
7911: ROLLBACK TO SAVEPOINT1;
7912: RETURN;
7911: ROLLBACK TO SAVEPOINT1;
7912: RETURN;
7913: WHEN OTHERS THEN
7914: IF l_debug = 1 THEN
7915: inv_trx_util_pub.trace('CANCEL_TASK: Unknown Error occurred while performing cancel cross dock task:'|| SQLCODE);
7916: END IF;
7917: x_return_status:=FND_API.G_RET_STS_UNEXP_ERROR;
7918: ROLLBACK TO SAVEPOINT1;
7919: RETURN;