[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 ,
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 ,
956: 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;
5253: WHERE transaction_temp_id = p_transaction_number;
5254:
5255: IF(l_debug = 1) THEN
5256: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for task: '||p_transaction_number;
5257: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5258: END IF;
5259:
5260: --Munish
5261: OPEN c_cd_task (p_transaction_number);
5361: END IF;
5362:
5363: IF(l_debug = 1) THEN
5364: l_err_msg := 'Status returned by API wms_waveplan_tasks_pvt.query_tasks: '||x_return_status;
5365: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5366: END IF;
5367:
5368: IF (x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
5369: /* SELECT * BULK COLLECT
5517: END;
5518:
5519: IF(l_debug = 1) THEN
5520: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for cycle count task: '||p_transaction_number;
5521: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5522: inv_trx_util_pub.trace('Cycle Count Name '||v_cycle_count_name);
5523: END IF;
5524:
5525: wms_waveplan_tasks_pvt.query_tasks(
5518:
5519: IF(l_debug = 1) THEN
5520: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for cycle count task: '||p_transaction_number;
5521: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5522: inv_trx_util_pub.trace('Cycle Count Name '||v_cycle_count_name);
5523: END IF;
5524:
5525: wms_waveplan_tasks_pvt.query_tasks(
5526: p_add => FALSE
5562:
5563:
5564: IF(l_debug = 1) THEN
5565: l_err_msg := 'Status returned by API wms_waveplan_tasks_pvt.query_tasks for cycle count task: '||x_return_status;
5566: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5567: END IF;
5568:
5569: IF (x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
5570: /* SELECT * BULK COLLECT
5702: EXCEPTION
5703: WHEN NO_DATA_FOUND THEN
5704: --start changes for completed tasks
5705: BEGIN
5706: inv_trx_util_pub.trace('checking in wdth for completed inbound or crossdock tasks');
5707: SELECT *
5708: INTO l_wdth_rec
5709: FROM wms_dispatched_tasks_history
5710: WHERE transaction_id = p_transaction_number;
5710: WHERE transaction_id = p_transaction_number;
5711:
5712: IF(l_debug = 1) THEN
5713: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for task: '||p_transaction_number;
5714: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5715: END IF;
5716:
5717: --Munish checking completed crossdock task
5718: OPEN c_cd_task1 (p_transaction_number);
5719: FETCH c_cd_task1 into c_cd_exist;
5720: CLOSE c_cd_task1;
5721:
5722: If (c_cd_exist = 1) THEN
5723: inv_trx_util_pub.trace('calling API wms_waveplan_tasks_pvt.query_tasks for completed crossdock task');
5724: --CALLL wms_waveplan_tasks_pvt.query_tasks API WITH
5725: --p_crossdock_include=true and p_outbound_include=false and p_inbound_include=false
5726: wms_waveplan_tasks_pvt.query_tasks(
5727: p_add => FALSE
5766: );
5767: ELSE
5768: --CALLL wms_waveplan_tasks_pvt.query_tasks API WITH p_crossdock_include=false and
5769: --p_outbound_include=true and p_inbound_include=true
5770: inv_trx_util_pub.trace('calling completed inbound task');--mkgupta2
5771: IF l_wdth_rec.is_parent ='Y' THEN
5772: inv_trx_util_pub.trace('checking if its a parent task completed inbound task');
5773: l_wdth_rec.source_subinventory_code:=NULL;
5774: l_wdth_rec.source_locator_id:=NULL;
5768: --CALLL wms_waveplan_tasks_pvt.query_tasks API WITH p_crossdock_include=false and
5769: --p_outbound_include=true and p_inbound_include=true
5770: inv_trx_util_pub.trace('calling completed inbound task');--mkgupta2
5771: IF l_wdth_rec.is_parent ='Y' THEN
5772: inv_trx_util_pub.trace('checking if its a parent task completed inbound task');
5773: l_wdth_rec.source_subinventory_code:=NULL;
5774: l_wdth_rec.source_locator_id:=NULL;
5775: END IF;
5776: wms_waveplan_tasks_pvt.query_tasks(
5817: END IF;
5818:
5819: IF(l_debug = 1) THEN
5820: l_err_msg := 'Status returned by API wms_waveplan_tasks_pvt.query_tasks: '||x_return_status;
5821: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5822: END IF;
5823:
5824: IF (x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
5825: SELECT
5947: WHERE transaction_temp_id = p_transaction_number;
5948: END IF;
5949: EXCEPTION
5950: WHEN NO_DATA_FOUND THEN
5951: inv_trx_util_pub.trace('in the NO_DATA_FOUND exception block of inbound/crossdock completed task');
5952: BEGIN
5953: inv_trx_util_pub.trace('checking in mmt for outbound/warehouse/manufacturing completed task');
5954: SELECT *
5955: INTO l_mmt_rec
5949: EXCEPTION
5950: WHEN NO_DATA_FOUND THEN
5951: inv_trx_util_pub.trace('in the NO_DATA_FOUND exception block of inbound/crossdock completed task');
5952: BEGIN
5953: inv_trx_util_pub.trace('checking in mmt for outbound/warehouse/manufacturing completed task');
5954: SELECT *
5955: INTO l_mmt_rec
5956: FROM mtl_material_transactions
5957: WHERE transaction_id = p_transaction_number;
5954: SELECT *
5955: INTO l_mmt_rec
5956: FROM mtl_material_transactions
5957: WHERE transaction_id = p_transaction_number;
5958: inv_trx_util_pub.trace('task existing in mmt');
5959:
5960: IF(l_debug = 1) THEN
5961: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for task: '||p_transaction_number;
5962: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5958: inv_trx_util_pub.trace('task existing in mmt');
5959:
5960: IF(l_debug = 1) THEN
5961: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for task: '||p_transaction_number;
5962: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5963: END IF;
5964:
5965: inv_trx_util_pub.trace('checking for bulk task');
5966: IF l_mmt_rec.parent_transaction_id IS NOT NULL THEN
5961: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for task: '||p_transaction_number;
5962: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
5963: END IF;
5964:
5965: inv_trx_util_pub.trace('checking for bulk task');
5966: IF l_mmt_rec.parent_transaction_id IS NOT NULL THEN
5967: l_mmt_rec.pick_slip_number:=NULL;
5968: END IF;
5969: wms_waveplan_tasks_pvt.query_tasks(
6009: );
6010:
6011: IF(l_debug = 1) THEN
6012: l_err_msg := 'Status returned by API wms_waveplan_tasks_pvt.query_tasks: '||x_return_status;
6013: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6014: END IF;
6015:
6016: IF (x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
6017: SELECT
6140:
6141: END IF;
6142: EXCEPTION
6143: WHEN NO_DATA_FOUND THEN
6144: inv_trx_util_pub.trace('in the exception block of outbond/manufacturing/warehousing complete tasks');
6145: fnd_message.set_name('WMS', 'WMS_INVALID_TASK');
6146: fnd_msg_pub.ADD;
6147: x_return_status := fnd_api.g_ret_sts_unexp_error;
6148: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6147: x_return_status := fnd_api.g_ret_sts_unexp_error;
6148: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6149: l_err_msg := 'Failed to fetch data from MMTT,MCCE,MMT or WDTH tables for transaction number '||p_transaction_number;
6150: IF(l_debug = 1) THEN
6151: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6152: END IF;
6153: END;
6154: --end the begin block for outbond/manufacturing/warehousing complete tasks
6155: END;
6160: x_return_status := fnd_api.g_ret_sts_unexp_error;
6161: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6162: l_err_msg := substr(SQLERRM,1,1000);
6163: IF(l_debug = 1) THEN
6164: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6165: END IF;
6166: END;
6167: --end the begin block for uncompleted tasks
6168:
6310: IF (l_execute_qry) THEN
6311:
6312: IF(l_debug = 1) THEN
6313: l_err_msg := 'Calling API wms_waveplan_tasks_pvt.query_tasks for Query: '||p_query_name;
6314: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6315: END IF;
6316:
6317: wms_waveplan_tasks_pvt.query_tasks (
6318: FALSE, ---p_add BOOLEAN DEFAULT FALSE,
6419: );
6420:
6421: IF(l_debug = 1) THEN
6422: l_err_msg := 'Status returned by API wms_waveplan_tasks_pvt.query_tasks: '||x_return_status;
6423: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6424: END IF;
6425:
6426: IF(x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
6427: /* SELECT * BULK COLLECT
6558: x_return_status := fnd_api.g_ret_sts_unexp_error;
6559: fnd_message.set_name('WMS', 'WMS_INVALID_VALUE');
6560: fnd_msg_pub.ADD;
6561: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6562: inv_trx_util_pub.trace(l_api_name||': '||'Invalid Parameters Passed');
6563: END IF; ----if p_transaction_number is not null
6564:
6565: EXCEPTION
6566: WHEN l_invalid_org THEN
6566: WHEN l_invalid_org THEN
6567: x_return_status := fnd_api.g_ret_sts_unexp_error;
6568: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6569: IF(l_debug = 1) THEN
6570: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6571: END IF;
6572: NULL;
6573:
6574: WHEN l_qry_fail THEN
6574: WHEN l_qry_fail THEN
6575: x_return_status := fnd_api.g_ret_sts_unexp_error;
6576: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6577: IF(l_debug = 1) THEN
6578: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6579: END IF;
6580: NULL;
6581:
6582: WHEN OTHERS THEN
6583: x_return_status := fnd_api.g_ret_sts_unexp_error;
6584: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
6585: l_err_msg := substr(SQLERRM,1,1000);
6586: IF(l_debug = 1) THEN
6587: inv_trx_util_pub.trace(l_api_name||': '||l_err_msg);
6588: END IF;
6589: NULL;
6590:
6591: END query_task;
7309: x_msg_data := l_msg;
7310: x_msg_count := l_msg_count;
7311: l_err_msg :='New task status not in Pending or Queued state or Unreleased state';
7312: IF(l_debug = 1) THEN
7313: inv_trx_util_pub.trace(l_api_name|| ': '||l_err_msg);
7314: END IF;
7315: 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);
7316: RETURN;
7317: END IF;
7335: x_msg_data := l_msg;
7336: x_msg_count := l_msg_count;
7337: l_err_msg :='Operation Plan is not enabled';
7338: IF(l_debug = 1) THEN
7339: inv_trx_util_pub.trace(l_api_name|| ': '||l_err_msg);
7340: END IF;
7341: log_error(p_transaction_number => p_transaction_number,
7342: p_task_table => p_task_table,
7343: p_error_msg => l_msg,
7379: x_msg_count := x_msg_count + 1;
7380:
7381: 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';
7382: IF(l_debug = 1) THEN
7383: inv_trx_util_pub.trace(l_api_name|| ': '||l_err_msg);
7384: END IF;
7385: x_updated_tasks(i) := l_updated_tasks(i);
7386: x_updated_tasks(i).RESULT := 'E';
7387: x_updated_tasks(i).ERROR := l_msg;
7412: x_msg_data := l_msg;
7413: x_msg_count := l_msg_count;
7414: -- l_err_msg :='Task Validation Failed';
7415: IF(l_debug = 1) THEN
7416: inv_trx_util_pub.trace(l_api_name|| ': '||l_msg);
7417: END IF;
7418: RETURN;
7419: END IF;
7420: IF (l_valid_task_counter <=0 ) THEN
7455: x_updated_tasks(i).RESULT := 'E';
7456: x_updated_tasks(i).ERROR := l_error_msg;
7457: END LOOP;
7458: IF(l_debug = 1) THEN
7459: inv_trx_util_pub.trace(l_api_name|| ': '||l_error_msg);
7460: END IF;
7461: RETURN;
7462: END IF;
7463: ELSE
7466: fnd_msg_pub.ADD;
7467: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data );
7468: l_err_msg := 'Some tasks have failed validation,cartonization cannot be done';
7469: IF(l_debug = 1) THEN
7470: inv_trx_util_pub.trace(l_api_name|| ': '||l_err_msg);
7471: END IF;
7472: RETURN;
7473: END IF;
7474: END IF;
7491: l_err_msg := substr(SQLERRM,1,1000);
7492: x_updated_tasks(i).RESULT := 'E';
7493: x_updated_tasks(i).ERROR := l_err_msg;
7494: IF(l_debug = 1) THEN
7495: inv_trx_util_pub.trace(l_api_name|| ': '||l_err_msg);
7496: END IF;
7497: END;
7498: p_temp_task_rec := x_updated_tasks(i);
7499:
7666: x_return_status := fnd_api.g_ret_sts_unexp_error;
7667: fnd_msg_pub.count_and_get(p_encoded => FND_API.G_FALSE,p_count => x_msg_count, p_data => x_msg_data);
7668: l_err_msg := substr(SQLERRM,1,1000);
7669: IF(l_debug = 1) THEN
7670: inv_trx_util_pub.trace(l_api_name|| ': '||l_err_msg);
7671: END IF;
7672:
7673: END modify_task;
7674:
7728: l_task_table := p_wms_task;
7729:
7730:
7731: IF l_debug = 1 THEN
7732: inv_trx_util_pub.trace('CANCEL_TASK: Enter...');
7733: END IF;
7734:
7735: WMS_TASK_MGMT_PUB.validate_tasks( p_transaction_number => l_transaction_number ,
7736: p_task_table => l_task_table ,
7736: p_task_table => l_task_table ,
7737: x_wms_task => l_ret_task_table ,
7738: x_return_status => l_val_ret_status );
7739: IF l_debug = 1 THEN
7740: inv_trx_util_pub.trace('cancel_task l_val_ret_status is : '||l_val_ret_status);
7741: END IF;
7742:
7743: IF (l_val_ret_status = fnd_api.g_ret_sts_success) THEN
7744: IF l_debug = 1 THEN
7741: END IF;
7742:
7743: IF (l_val_ret_status = fnd_api.g_ret_sts_success) THEN
7744: IF l_debug = 1 THEN
7745: inv_trx_util_pub.trace('l_ret_task_table.count : '||l_ret_task_table.count);
7746: END IF;
7747:
7748: FOR i in 1..l_ret_task_table.count LOOP
7749: IF l_debug = 1 THEN
7746: END IF;
7747:
7748: FOR i in 1..l_ret_task_table.count LOOP
7749: IF l_debug = 1 THEN
7750: inv_trx_util_pub.trace('cancel_task l_ret_task_table(i).RESULT '||l_ret_task_table(i).RESULT);
7751: END IF;
7752: IF ( nvl(l_ret_task_table(i).RESULT,'X')<> FND_API.G_RET_STS_ERROR)THEN
7753: IF l_debug = 1 THEN
7754: inv_trx_util_pub.trace('cancel_task transaction_number '||l_ret_task_table(i).transaction_number);
7750: inv_trx_util_pub.trace('cancel_task l_ret_task_table(i).RESULT '||l_ret_task_table(i).RESULT);
7751: END IF;
7752: IF ( nvl(l_ret_task_table(i).RESULT,'X')<> FND_API.G_RET_STS_ERROR)THEN
7753: IF l_debug = 1 THEN
7754: inv_trx_util_pub.trace('cancel_task transaction_number '||l_ret_task_table(i).transaction_number);
7755: END IF;
7756: SAVEPOINT SAVEPOINT1;
7757: WMS_CROSS_DOCK_PVT.cancel_crossdock_task(p_transaction_temp_id => l_ret_task_table(i).transaction_number
7758: ,x_return_status => x_return_status
7758: ,x_return_status => x_return_status
7759: ,x_msg_data => x_msg_data
7760: ,x_msg_count => x_msg_count);
7761: IF l_debug = 1 THEN
7762: inv_trx_util_pub.trace('cancel_task CANCEL_TASK: x_return_status: ' || x_return_status);
7763: END IF;
7764:
7765: IF (x_return_status<>FND_API.G_RET_STS_SUCCESS) THEN
7766: FND_MESSAGE.SET_NAME('WMS', 'WMS_CANCEL_FAILED');
7779: l_msg := fnd_message.get;
7780: x_msg_count := x_msg_count + 1;
7781: x_msg_data := x_msg_data || l_msg;
7782: IF l_debug = 1 THEN
7783: inv_trx_util_pub.trace('Validate_task returned error for this record');
7784: END IF;
7785: x_unprocessed_crossdock_tasks(l_unprocessed_crossdock_count).transaction_number := l_transaction_number;
7786: x_unprocessed_crossdock_tasks(l_unprocessed_crossdock_count).result := l_ret_task_table(i).RESULT;
7787: x_unprocessed_crossdock_tasks(l_unprocessed_crossdock_count).error := l_msg;
7788: l_unprocessed_crossdock_count := l_unprocessed_crossdock_count+1;
7789: END IF;
7790: END LOOP;
7791: IF l_debug = 1 THEN
7792: inv_trx_util_pub.trace('CANCEL_TASK: x_unprocessed_crossdock_tasks: ' || x_unprocessed_crossdock_tasks.count);
7793: inv_trx_util_pub.trace('CANCEL_TASK: Exiting...');
7794: END IF;
7795: ELSE
7796: IF l_debug = 1 THEN
7789: END IF;
7790: END LOOP;
7791: IF l_debug = 1 THEN
7792: inv_trx_util_pub.trace('CANCEL_TASK: x_unprocessed_crossdock_tasks: ' || x_unprocessed_crossdock_tasks.count);
7793: inv_trx_util_pub.trace('CANCEL_TASK: Exiting...');
7794: END IF;
7795: ELSE
7796: IF l_debug = 1 THEN
7797: inv_trx_util_pub.trace('CANCEL_TASK: Error occured while validating the transaction_number or table of transaction_number...');
7793: inv_trx_util_pub.trace('CANCEL_TASK: Exiting...');
7794: END IF;
7795: ELSE
7796: IF l_debug = 1 THEN
7797: inv_trx_util_pub.trace('CANCEL_TASK: Error occured while validating the transaction_number or table of transaction_number...');
7798: END IF;
7799: x_return_status:=FND_API.G_RET_STS_UNEXP_ERROR;
7800: RETURN;
7801: END IF;
7805: END IF;
7806: EXCEPTION
7807: WHEN fnd_api.g_exc_error THEN
7808: IF l_debug = 1 THEN
7809: inv_trx_util_pub.trace('CANCEL_TASK: Expected Error occurred while performing cancel cross dock task:'|| SQLCODE);
7810: END IF;
7811: x_return_status:=FND_API.G_RET_STS_ERROR;
7812: ROLLBACK TO SAVEPOINT1;
7813: RETURN;
7812: ROLLBACK TO SAVEPOINT1;
7813: RETURN;
7814: WHEN OTHERS THEN
7815: IF l_debug = 1 THEN
7816: inv_trx_util_pub.trace('CANCEL_TASK: Unknown Error occurred while performing cancel cross dock task:'|| SQLCODE);
7817: END IF;
7818: x_return_status:=FND_API.G_RET_STS_UNEXP_ERROR;
7819: ROLLBACK TO SAVEPOINT1;
7820: RETURN;