ITPub博客

首页 > 数据库 > Oracle > ORACLE EBS自动处理物料搬运单

ORACLE EBS自动处理物料搬运单

原创 Oracle 作者:box 时间:2016-01-04 18:10:14 0 删除 编辑

文档来源:http://blog.csdn.net/cunxiyuan108/article/details/6006961
目的:模拟EBS Form界面的功能,调用标准的API实现自动处理物料搬运单。

实现思路:

1.  先创建一个客户化的表,这个表中用来保存物料搬运单的一些信息。

2.  调用标准的API:inv_loc_wms_pub.create_locator动态创建货位(根据项目、任务和库存三个段 来创建)。

3.  调用标准的API:inv_quantity_tree_pub.query_quantities检查某一库存组织的某一子库存下某一物料的现用量和可用量。

4.  调用标准的API:inv_mo_line_detail_util.insert_row在MMTT表中插入一条记录。

5.  调用标准的API:INV_Replenish_Detail_PUB.line_details_pub创建物料搬运单的分配行。

6.  调用标准的API:  inv_trolin_util.query_rows得到物料搬运单行的相关信息。

7.  调用标准的API:INV_PICK_WAVE_PICK_CONFIRM_PUB.Pick_Confirm进行自动挑库确认(处理物料搬运单)。

8.  调用标准的API:inv_mo_line_detail_util.delete_row删除MMTT表中的未处理的记录(如果步骤4中的记录没有被处理)。

9.  更新客户化表的处理状态和错误信息。

10. 将处理的结果进行统计,并使用HTML输出。


整个程序包如下:

[c-sharp] view plaincopy
  1. CREATE OR REPLACE PACKAGE BODY CUX_EDIINT_ITEM_MOVE_IN_PKG IS  
  2.   --自定义预置文件CUX_MO_DEBUG_FLAG:用来判断是否输出调试信息  
  3.   --fnd_profile.VALUE('CUX_MO_DEBUG_FLAG')为NULL,不输出调试信息,输出错误信息  
  4.   --fnd_profile.VALUE('CUX_MO_DEBUG_FLAG')为'N',不输出调试信息,输出错误信息  
  5.   --fnd_profile.VALUE('CUX_MO_DEBUG_FLAG')为'Y', 输出调试信息,输出错误信息  
  6.   l_mo_debug_falg VARCHAR2(1) := NVL(fnd_profile.VALUE('CUX_MO_DEBUG_FLAG'),  
  7.                                      'N');  
  8.   --日志  
  9.   PROCEDURE put_log(p_msg IN VARCHAR2) IS  
  10.   BEGIN  
  11.     fnd_file.put_line(fnd_file.log, p_msg);  
  12.   END put_log;  
  13.   --输出  
  14.   PROCEDURE put_file(p_msg IN VARCHAR2) IS  
  15.   BEGIN  
  16.     fnd_file.put_line(fnd_file.OUTPUT, p_msg);  
  17.   END put_file;  
  18.   /*======================================================= 
  19.   *  FUNCTION / PROCEDURE 
  20.   *       get_org_count 
  21.   *   DESCRIPTION: 
  22.   *      得到本次请求处理(成功或者失败)的物料搬运单的所有OU 数量,0表示不存在,1表示存在。 
  23.   *   ARGUMENT: 
  24.   *     p_org_id          :OU id 
  25.   *     p_process_id      :物料搬运单处理状态 
  26.   *   RETURN:   
  27.   *       N/A 
  28.   *   HISTORY: 
  29.   *     1.00 27/10/2010 cxy 
  30.   =========================================================*/  
  31.   FUNCTION get_org_count(p_org_id NUMBER, p_process_id NUMBER) RETURN NUMBER IS  
  32.     l_org_count NUMBER;  
  33.   BEGIN  
  34.     SELECT COUNT(1)  
  35.       INTO l_org_count  
  36.       FROM cux_ediint_item_move_in ceimi  
  37.      WHERE ceimi.ou_org_id  = p_org_id  
  38.        AND ceimi.process_id = p_process_id  
  39.        AND ceimi.request_id = fnd_global.conc_request_id  
  40.        AND ROWNUM           = 1;  
  41.     RETURN l_org_count;  
  42.   EXCEPTION  
  43.     WHEN OTHERS THEN  
  44.       put_log('得到OU关联的处理条数时候出现错误:' || SQLERRM);  
  45.       RETURN NULL;  
  46.   END get_org_count;  
  47.   /*======================================================= 
  48.    *  FUNCTION / PROCEDURE 
  49.    *       output_move_order_info 
  50.    *   DESCRIPTION: 
  51.    *       输出处理信息 
  52.    *   ARGUMENT: 
  53.    *   p_line_count         :本次请求处理的记录总数量 
  54.    *   p_line_seccess_count : 本次请求处理成功的记录数量   
  55.    *   RETURN: 
  56.    *       N/A 
  57.    *   HISTORY: 
  58.    *     1.00 27/10/2010 cxy 
  59.   =========================================================*/  
  60.   PROCEDURE output_move_order_info(p_line_count         IN NUMBER,  
  61.                                    p_line_success_count IN NUMBER) IS  
  62.     --取出物料搬运单客户化表中的业务实体的信息,不取重复的记录  
  63.     CURSOR cur_org_info IS  
  64.       SELECT DISTINCT   
  65.              hou.organization_id org_id, --库存组织id  
  66.              hou.name            org_name --库存组织名称  
  67.         FROM cux_ediint_item_move_in      ceimi,  
  68.              mtl_txn_request_lines        mtrl,  
  69.              mtl_txn_request_headers      mtrh,  
  70.              org_organization_definitions ood,  
  71.              hr_operating_units           hou  
  72.        WHERE ceimi.line_id       = mtrl.line_id  
  73.          AND mtrl.header_id      = mtrh.header_id  
  74.          AND ood.organization_id = mtrl.organization_id  
  75.          AND ood.operating_unit  = hou.organization_id  
  76.          AND ceimi.request_id    = fnd_global.conc_request_id;  
  77.     --处理成功的物料搬运单行信息     
  78.     CURSOR cur_move_order_success(p_org_id NUMBER) IS  
  79.       SELECT hou.name                    org_name,                --OU名称  
  80.              ceimi.header_id             header_id,               --物料搬运单头id  
  81.              mtrh.request_number         request_number,          --物料搬运单编号  
  82.              ml.meaning                  move_order_type_meaning, --物料搬运单类型  
  83.              ceimi.line_id               line_id,                 --物料搬运单行id  
  84.              mtrl.line_number            line_number,             --行编号  
  85.              msib.segment1               item_code,               --物料编码  
  86.              ceimi.transaction_quantity  transaction_quantity,    --事务处理数量  
  87.              ood.organization_code       organization_code,       --库存组织代码  
  88.              ood.organization_name       organization_name,       --库存组织名称  
  89.              mtrl.from_subinventory_code from_subinventory_code,  --来源子库存  
  90.              mtrl.to_subinventory_code   to_subinventory_code     --目标子库存  
  91.         FROM cux_ediint_item_move_in      ceimi,  
  92.              mtl_txn_request_lines        mtrl,  
  93.              mtl_txn_request_headers      mtrh,  
  94.              org_organization_definitions ood,  
  95.              hr_operating_units           hou,  
  96.              mfg_lookups                  ml,  
  97.              mtl_system_items_b           msib  
  98.        WHERE ceimi.line_id          = mtrl.line_id  
  99.          AND mtrl.header_id         = mtrh.header_id  
  100.          AND ood.organization_id    = mtrl.organization_id  
  101.          AND ood.operating_unit     = hou.organization_id  
  102.          AND mtrh.move_order_type   = ml.lookup_code  
  103.          AND ml.lookup_type         = 'MOVE_ORDER_TYPE'  
  104.          AND msib.organization_id   = mtrl.organization_id  
  105.          AND msib.inventory_item_id = mtrl.inventory_item_id  
  106.          AND ceimi.process_id       = 4 --处理成功的记录  
  107.          AND ceimi.request_id       = fnd_global.conc_request_id  
  108.          AND hou.organization_id    = p_org_id;  
  109.     --出错的物料搬运单行信息     
  110.     CURSOR cur_move_order_error(p_org_id NUMBER) IS  
  111.       SELECT hou.name                    org_name,              --OU名称  
  112.              ceimi.header_id             header_id,             --物料搬运单头id  
  113.              mtrh.request_number         request_number,        --物料搬运单编号  
  114.              ml.meaning                  move_order_type_meaning,--物料搬运单类型  
  115.              ceimi.line_id               line_id,               --物料搬运单行id  
  116.              mtrl.line_number            line_number,           --行编号  
  117.              msib.segment1               item_code,             --物料编码  
  118.              ceimi.transaction_quantity  transaction_quantity,  --事务处理数量  
  119.              ood.organization_code       organization_code,     --库存组织代码  
  120.              ood.organization_name       organization_name,     --库存组织名称  
  121.              mtrl.from_subinventory_code from_subinventory_code,--来源子库存  
  122.              mtrl.to_subinventory_code   to_subinventory_code,  --目标子库存  
  123.              ceimi.error_message         error_message          --错误信息  
  124.         FROM cux_ediint_item_move_in      ceimi,  
  125.              mtl_txn_request_lines        mtrl,  
  126.              mtl_txn_request_headers      mtrh,  
  127.              org_organization_definitions ood,  
  128.              hr_operating_units           hou,  
  129.              mfg_lookups                  ml,  
  130.              mtl_system_items_b           msib  
  131.        WHERE ceimi.line_id          = mtrl.line_id  
  132.          AND mtrl.header_id         = mtrh.header_id  
  133.          AND ood.organization_id    = mtrl.organization_id  
  134.          AND ood.operating_unit     = hou.organization_id  
  135.          AND mtrh.move_order_type   = ml.lookup_code  
  136.          AND ml.lookup_type         = 'MOVE_ORDER_TYPE'  
  137.          AND msib.organization_id   = mtrl.organization_id  
  138.          AND msib.inventory_item_id = mtrl.inventory_item_id  
  139.          AND ceimi.process_id       = 3 --处理失败的记录  
  140.          AND ceimi.request_id       = fnd_global.conc_request_id  
  141.          AND hou.organization_id    = p_org_id;  
  142.     l_user_name     VARCHAR2(100); --用户名  
  143.     l_success_index NUMBER; --循环标志  
  144.     l_error_index   NUMBER; --循环标志  
  145.     l_count         NUMBER; --循环标志  
  146.     l_org_count     NUMBER; --循环标志  
  147.   BEGIN  
  148.     SELECT fu.user_name  
  149.       INTO l_user_name  
  150.       FROM fnd_user fu  
  151.      WHERE fu.user_id = NVL(fnd_global.user_id, -1);  
  152.     put_file(chr(13) || chr(10));  
  153.     put_file('提交人:' || rpad(l_user_name, 20, ' '));  
  154.     put_file('报表日期:' || TO_CHAR(SYSDATE, 'YYYY-MM-DD HH24:MI:SS'));  
  155.     put_file(chr(13) || chr(10));  
  156.     put_file('本次处理的总的记录条数为: ' || to_char(p_line_count) || '  条');  
  157.     put_file('处理成功的记录条数为: ' || to_char(p_line_success_count) || '  条');  
  158.     IF (p_line_count > p_line_success_count) THEN  
  159.       put_file('处理出错的记录条数为: ' ||  
  160.                to_char(p_line_count - p_line_success_count) || '  条');  
  161.     END IF;  
  162.     put_file(chr(13) || chr(10));  
  163.     IF p_line_success_count <> 0 THEN  
  164.       put_file('处理成功的物料搬运单');  
  165.       put_file(lpad('-', 190, '-'));  
  166.       --输出处理成功的物料搬运单的信息   
  167.       FOR rec_org_info IN cur_org_info LOOP  
  168.         l_org_count := get_org_count(rec_org_info.org_id, 4);  
  169.         IF l_org_count <> 0 THEN  
  170.           put_file('业务实体:' || rec_org_info.org_name);  
  171.           put_file(rpad('-', 190, '-'));  
  172.           put_file(rpad('物料搬运单编号', 30, ' ') || rpad('类型', 20, ' ') ||  
  173.                    rpad('行号', 20, ' ') || rpad('物料', 40, ' ') ||  
  174.                    rpad('来源子库存', 20, ' ') || rpad('目标子库存', 20, ' ') ||  
  175.                    rpad('事务处理数量', 40, ' '));  
  176.           put_file(chr(13) || chr(10));  
  177.         END IF;  
  178.         FOR rec_move_order_succes IN cur_move_order_success(rec_org_info.org_id) LOOP  
  179.           put_file(rpad(rec_move_order_succes.request_number, 30, ' ') ||  
  180.                    rpad(rec_move_order_succes.move_order_type_meaning,  
  181.                         20,  
  182.                         ' ') ||  
  183.                    rpad(rec_move_order_succes.line_number, 20, ' ') ||  
  184.                    rpad(rec_move_order_succes.item_code, 40, ' ') ||  
  185.                    rpad(rec_move_order_succes.from_subinventory_code,  
  186.                         20,  
  187.                         ' ') || rpad(rec_move_order_succes.to_subinventory_code,  
  188.                                      20,  
  189.                                      ' ') ||  
  190.                    rpad(rec_move_order_succes.transaction_quantity,  
  191.                         40,  
  192.                         ' '));  
  193.           put_file(chr(13) || chr(10));  
  194.         END LOOP; --FOR rec_hold_order_info IN cur_hold_order_info LOOP  
  195.         put_file(chr(13) || chr(10));  
  196.       END LOOP; --FOR rec_org_info IN cur_org_info LOOP   
  197.       put_file(lpad('-', 95, '-') || rpad('-', 95, '-'));  
  198.     END IF;  
  199.     put_file(chr(13) || chr(10));  
  200.     --输出处理失败的物料搬运单  
  201.     IF p_line_count - p_line_success_count > 0 THEN  
  202.       put_file('处理出错的物料搬运单');  
  203.       put_file(lpad('处理出错的', 145, '-') || rpad('物料搬运单', 145, '-'));  
  204.       IF (p_line_count >= p_line_success_count) THEN  
  205.         --如果存在错误的记录  
  206.         --输出处理成功的物料搬运单的信息   
  207.         FOR rec_org_info IN cur_org_info LOOP  
  208.           l_org_count := get_org_count(rec_org_info.org_id, 3);  
  209.           IF l_org_count <> 0 THEN  
  210.             put_file('业务实体:' || rec_org_info.org_name);  
  211.             put_file(rpad('-', 290, '-'));  
  212.             put_file(rpad('物料搬运单编号', 30, ' ') || rpad('类型', 20, ' ') ||  
  213.                      rpad('行号', 20, ' ') || rpad('物料', 40, ' ') ||  
  214.                      rpad('来源子库存', 20, ' ') || rpad('目标子库存', 20, ' ') ||  
  215.                      rpad('事务处理数量', 40, ' ') || rpad('错误信息', 100, ' '));  
  216.             put_file(chr(13) || chr(10));  
  217.           END IF;  
  218.           FOR rec_move_order_error IN cur_move_order_error(rec_org_info.org_id) LOOP  
  219.             put_file(rpad(rec_move_order_error.request_number, 30, ' ') ||  
  220.                      rpad(rec_move_order_error.move_order_type_meaning,  
  221.                           20,  
  222.                           ' ') ||  
  223.                      rpad(rec_move_order_error.line_number, 20, ' ') ||  
  224.                      rpad(rec_move_order_error.item_code, 40, ' ') ||  
  225.                      rpad(rec_move_order_error.from_subinventory_code,  
  226.                           20,  
  227.                           ' ') || rpad(rec_move_order_error.to_subinventory_code,  
  228.                                        20,  
  229.                                        ' ') ||  
  230.                      rpad(rec_move_order_error.transaction_quantity,  
  231.                           40,  
  232.                           ' ') ||  
  233.                      rpad(rec_move_order_error.error_message, 100, ' '));  
  234.             put_file(chr(13) || chr(10));  
  235.           END LOOP; --FOR rec_hold_order_info IN cur_hold_order_info LOOP  
  236.         END LOOP; --FOR rec_org_info IN cur_org_info LOOP   
  237.         
  238.       END IF;  
  239.       IF p_line_count - p_line_success_count > 0 THEN  
  240.         put_file(lpad('-', 145, '-') || rpad('-', 145, '-'));  
  241.       END IF;  
  242.     END IF;  
  243.   END output_move_order_info;  
  244.   /*======================================================= 
  245.   *  FUNCTION / PROCEDURE 
  246.   *       get_move_order 
  247.   *   DESCRIPTION: 
  248.   *      得到物料搬运单的一条记录(一个物料搬运单头和对应的所有的物表搬运单的行) 
  249.   *   ARGUMENT: 
  250.   *     x_return_status  :状态 
  251.   *     x_msg_count      :错误信息数量 
  252.   *     x_msg_data       :错误信息 
  253.   *     x_trohdr_rec     :物料搬运单头的一行记录 
  254.   *     x_trohdr_val_rec :物料搬运单头的一行记录对应的值 
  255.   *     x_trolin_tbl     :一个物料搬运单头对应的所有物料搬运单行 
  256.   *     x_trolin_val_tbl :一个物料搬运单头对应的所有物料搬运单行的值 
  257.   *     p_header_id      :物料搬运单头id 
  258.   *   RETURN:   
  259.   *       N/A 
  260.   *   HISTORY: 
  261.   *     1.00 27/10/2010 cxy 
  262.   =========================================================*/  
  263.   PROCEDURE get_move_order(x_return_status  OUT NOCOPY VARCHAR2,  
  264.                            x_msg_count      OUT NOCOPY NUMBER,  
  265.                            x_msg_data       OUT NOCOPY VARCHAR2,  
  266.                            x_trohdr_rec     OUT NOCOPY INV_MOVE_ORDER_PUB.Trohdr_Rec_Type,  
  267.                            x_trohdr_val_rec OUT NOCOPY INV_MOVE_ORDER_PUB.Trohdr_Val_Rec_Type,  
  268.                            x_trolin_tbl     OUT NOCOPY INV_MOVE_ORDER_PUB.Trolin_Tbl_Type,  
  269.                            x_trolin_val_tbl OUT NOCOPY INV_MOVE_ORDER_PUB.Trolin_Val_Tbl_Type,  
  270.                            p_header_id      IN NUMBER) IS  
  271.   BEGIN  
  272.     --调用系统标准的API得到物料搬运单的相关信息  
  273.     INV_Move_Order_PUB.Get_Move_Order(p_api_version_number => 1.0,  
  274.                                       p_init_msg_list      => fnd_api.G_FALSE,  
  275.                                       p_return_values      => fnd_api.G_FALSE,  
  276.                                       x_return_status      => x_return_status,  
  277.                                       x_msg_count          => x_msg_count,  
  278.                                       x_msg_data           => x_msg_data,  
  279.                                       p_header_id          => p_header_id,  
  280.                                       p_header             => fnd_api.G_MISS_CHAR,  
  281.                                       x_trohdr_rec         => x_trohdr_rec,  
  282.                                       x_trohdr_val_rec     => x_trohdr_val_rec,  
  283.                                       x_trolin_tbl         => x_trolin_tbl,  
  284.                                       x_trolin_val_tbl     => x_trolin_val_tbl);  
  285.   EXCEPTION  
  286.     WHEN OTHERS THEN  
  287.       put_log('得到物料搬运单时出现异常:' || SQLERRM);  
  288.   END get_move_order;  
  289.   /*======================================================= 
  290.   *  FUNCTION / PROCEDURE 
  291.   *       get_locator_type 
  292.   *   DESCRIPTION: 
  293.   *      得到货位控制类型 
  294.   *   ARGUMENT: 
  295.   *   p_organization_id         :库存组织id 
  296.   *   p_secondary_inventory_code:子库存代码   
  297.   *   RETURN:   
  298.   *       货位控制类型 
  299.   *   HISTORY: 
  300.   *     1.00 27/10/2010 cxy 
  301.   =========================================================*/  
  302.   FUNCTION get_locator_type(p_organization_id          IN NUMBER,  
  303.                             p_secondary_inventory_code IN VARCHAR2)  
  304.     RETURN NUMBER IS  
  305.     l_locator_type_id NUMBER; --货位控制类型  
  306.   BEGIN  
  307.     SELECT msi.locator_type  
  308.       INTO l_locator_type_id  
  309.       FROM mtl_secondary_inventories msi  
  310.      WHERE msi.organization_id          = p_organization_id  
  311.        AND msi.secondary_inventory_name = p_secondary_inventory_code;  
  312.     RETURN l_locator_type_id;  
  313.   EXCEPTION  
  314.     WHEN NO_DATA_FOUND THEN  
  315.       RETURN NULL;  
  316.     WHEN TOO_MANY_ROWS THEN  
  317.       put_log('得到货位控制类型时返回的多个行!');  
  318.     WHEN OTHERS THEN  
  319.       put_log('得到货位控制类型时出现异常:' || SQLERRM);  
  320.   END get_locator_type;  
  321.   /*======================================================= 
  322.   *  FUNCTION / PROCEDURE 
  323.   *       create_locator 
  324.   *   DESCRIPTION: 
  325.   *      自动创建货位 
  326.   *   ARGUMENT: 
  327.   *     x_return_status     :状态 
  328.   *     x_msg_count         :错误信息数量 
  329.   *     x_msg_data          :错误信息 
  330.   *     x_locator_id        :货位id 
  331.   *     x_locator_exists    :是否存在货位 
  332.   *     p_organization_id   :库存组织id 
  333.   *     p_subinventory_code :子库存代码 
  334.   *     p_project_id        :项目id 
  335.   *     p_task_id           :任务id 
  336.   *     p_locator_type      :货位类型   
  337.   *   RETURN:   
  338.   *       N/A 
  339.   *   HISTORY: 
  340.   *     1.00 27/10/2010 cxy 
  341.   =========================================================*/  
  342.   PROCEDURE create_locator(x_return_status     OUT NOCOPY VARCHAR2,  
  343.                            x_msg_count         OUT NOCOPY NUMBER,  
  344.                            x_msg_data          OUT NOCOPY VARCHAR2,  
  345.                            x_locator_id        OUT NUMBER,  
  346.                            x_locator_exists    OUT VARCHAR2,  
  347.                            p_organization_id   IN NUMBER,  
  348.                            p_subinventory_code IN VARCHAR2,  
  349.                            p_project_id        IN NUMBER,  
  350.                            p_task_id           IN NUMBER,  
  351.                            p_locator_type      IN NUMBER) IS  
  352.     l_segment_delimiter     VARCHAR2(1); --键弹性域段分隔符    
  353.     l_concatenated_segments VARCHAR2(100); --库存货位组合       
  354.     l_project_number        VARCHAR2(25); --项目编号  
  355.     l_task_number           VARCHAR2(25); --任务编号      
  356.     l_user_id               NUMBER; --登录的用户  
  357.     l_resp_id               NUMBER; --职位id  
  358.     l_resp_appl_id          NUMBER; --职责应用id  
  359.   BEGIN  
  360.     --设置MFG_ORGANIZATION_ID预置文件的值                             
  361.     fnd_profile.put('MFG_ORGANIZATION_ID', p_organization_id);  
  362.     --得到段分隔符  
  363.     SELECT fifs.concatenated_segment_delimiter  
  364.       INTO l_segment_delimiter  
  365.       FROM fnd_id_flex_structures fifs  
  366.      WHERE fifs.id_flex_structure_code = 'STOCK_LOCATORS';  
  367.     --得到项目编号  
  368.     SELECT ppa.segment1  
  369.       INTO l_project_number  
  370.       FROM pa_projects_all ppa  
  371.      WHERE ppa.project_id = p_project_id;  
  372.     --得到任务编号  
  373.     SELECT pt.task_number  
  374.       INTO l_task_number  
  375.       FROM pa_tasks pt  
  376.      WHERE pt.task_id = p_task_id;  
  377.     --拼接子库存货位组合  
  378.     IF l_mo_debug_falg = 'Y' THEN  
  379.       --输出调试信息  
  380.       put_log('库存组织id:' || p_organization_id);  
  381.       put_log('货位类型:'   || p_locator_type);  
  382.       put_log('子库存:'     || p_subinventory_code);  
  383.     END IF;  
  384.     l_concatenated_segments := p_subinventory_code || l_segment_delimiter ||  
  385.                                l_project_number    || l_segment_delimiter ||  
  386.                                l_task_number;  
  387.     IF l_mo_debug_falg = 'Y' THEN--输出调试信息           
  388.       put_log('弹性域组合:' || l_concatenated_segments);  
  389.     END IF;  
  390.     --调用API自动创建货位  
  391.     inv_loc_wms_pub.create_locator(x_return_status            => x_return_status,  
  392.                                    x_msg_count                => x_msg_count,  
  393.                                    x_msg_data                 => x_msg_data,  
  394.                                    x_inventory_location_id    => x_locator_id,  
  395.                                    x_locator_exists           => x_locator_exists,  
  396.                                    p_organization_id          => p_organization_id,  
  397.                                    p_organization_code        => NULL,  
  398.                                    p_concatenated_segments    => l_concatenated_segments,  
  399.                                    p_description              => NULL,  
  400.                                    p_inventory_location_type  => p_locator_type,  
  401.                                    p_picking_order            => NULL,  
  402.                                    p_location_maximum_units   => NULL,  
  403.                                    p_subinventory_code        => p_subinventory_code,  
  404.                                    p_location_weight_uom_code => NULL,  
  405.                                    p_max_weight               => NULL,  
  406.                                    p_volume_uom_code          => NULL,  
  407.                                    p_max_cubic_area           => NULL,  
  408.                                    p_x_coordinate             => NULL,  
  409.                                    p_y_coordinate             => NULL,  
  410.                                    p_z_coordinate             => NULL,  
  411.                                    p_physical_location_id     => NULL,  
  412.                                    p_pick_uom_code            => NULL,  
  413.                                    p_dimension_uom_code       => NULL,  
  414.                                    p_length                   => NULL,  
  415.                                    p_width                    => NULL,  
  416.                                    p_height                   => NULL,  
  417.                                    p_status_id                => NULL,  
  418.                                    p_dropping_order           => NULL);  
  419.     IF l_mo_debug_falg = 'Y' THEN--输出调试信息                   
  420.       put_log('自动生成的货位返回状态:' || x_return_status);  
  421.       put_log('自动生成的货位错误条数:' || x_msg_count);  
  422.       put_log('自动生成的货位错误信息:' || x_msg_data);  
  423.       put_log('自动生成的货位id为:' || x_locator_id);  
  424.     END IF;  
  425.     IF x_locator_id IS NULL THEN  
  426.       put_log('自动创建货位时出错:' || x_msg_data);  
  427.     END IF;  
  428.   EXCEPTION  
  429.     WHEN OTHERS THEN  
  430.       put_log('自动创建货位时出现异常:' || SQLERRM);  
  431.   END create_locator;  
  432.   /*======================================================= 
  433.   *  FUNCTION / PROCEDURE 
  434.   *       check_and_create_locator 
  435.   *   DESCRIPTION: 
  436.   *      检查和生成货位 
  437.   *   ARGUMENT: 
  438.   *     x_return_status     :状态 
  439.   *     x_msg_count         :错误信息数量 
  440.   *     x_msg_data          :错误信息 
  441.   *     x_locator_type      :货位类型   
  442.   *     x_from_locator_id   :来源货位id 
  443.   *     x_to_locator_id     :目标货位id 
  444.   *     p_trolin_rec        :物料搬运单行的一行记录 
  445.   *   RETURN:   
  446.   *       N/A 
  447.   *   HISTORY: 
  448.   *     1.00 27/10/2010 cxy 
  449.   =========================================================*/  
  450.   PROCEDURE check_and_create_locator(x_return_status   OUT VARCHAR2,  
  451.                                      x_msg_data        OUT VARCHAR2,  
  452.                                      x_locator_type    OUT VARCHAR2,  
  453.                                      x_from_locator_id OUT NUMBER,  
  454.                                      x_to_locator_id   OUT NUMBER,  
  455.                                      p_trolin_rec      IN INV_MOVE_ORDER_PUB.Trolin_Rec_Type) IS  
  456.     l_from_inv_locator_type NUMBER; --源子库存的货位控制类型  
  457.     l_to_inv_locator_type   NUMBER; --目标子库存的货位控制类型       
  458.     x_msg_count             NUMBER; --错误信息数  
  459.     x_locator_id            NUMBER; --货位id  
  460.     x_locator_exists        VARCHAR2(1); --货位是否存在标志  
  461.   BEGIN  
  462.     --来源子库存的货位控制类型  
  463.     l_from_inv_locator_type := get_locator_type(p_trolin_rec.organization_id,  
  464.                                                 p_trolin_rec.from_subinventory_code);  
  465.     --目标子库存的货位控制类型                                              
  466.     l_to_inv_locator_type := get_locator_type(p_trolin_rec.organization_id,  
  467.                                               p_trolin_rec.to_subinventory_code);  
  468.     IF l_mo_debug_falg = 'Y' THEN--输出调试信息    
  469.       put_log(p_trolin_rec.from_subinventory_code || '的来源字库货位类型为:' ||  
  470.               l_from_inv_locator_type);  
  471.       put_log(p_trolin_rec.to_subinventory_code   || '的来源字库货位类型为:' ||  
  472.               l_to_inv_locator_type);  
  473.     END IF;  
  474.     IF l_from_inv_locator_type = l_to_inv_locator_type THEN  
  475.       IF l_from_inv_locator_type <> 0 THEN--启用了货位控制  
  476.         x_locator_type := l_from_inv_locator_type;  
  477.         IF p_trolin_rec.from_locator_id IS NOT NULL THEN --货位不为空  
  478.           x_return_status   := fnd_api.G_RET_STS_SUCCESS;  
  479.           x_from_locator_id := p_trolin_rec.from_locator_id;  
  480.         ELSE--货位为空  
  481.           --自动创建货位(源库存货位)  
  482.           create_locator(x_return_status     => x_return_status,  
  483.                          x_msg_count         => x_msg_count,  
  484.                          x_msg_data          => x_msg_data,  
  485.                          x_locator_id        => x_from_locator_id,  
  486.                          x_locator_exists    => x_locator_exists,  
  487.                          p_organization_id   => p_trolin_rec.organization_id,  
  488.                          p_subinventory_code => p_trolin_rec.from_subinventory_code,  
  489.                          p_project_id        => p_trolin_rec.project_id,  
  490.                          p_task_id           => p_trolin_rec.task_id,  
  491.                          p_locator_type      => x_locator_type);  
  492.           IF l_mo_debug_falg = 'Y' THEN--输出调试信息                     
  493.             put_log('x_return_status:' || x_return_status);  
  494.             put_log('x_msg_count:' || x_msg_count);  
  495.             put_log('x_msg_data:' || x_msg_data);  
  496.             put_log('x_from_locator_id:' || x_from_locator_id);  
  497.             put_log('x_locator_exists:' || x_locator_exists);  
  498.           END IF;  
  499.           IF x_from_locator_id IS NULL THEN  
  500.             x_msg_data := '自动创建货位时错误异常,请确认是否已经包含子库存、项目和任务的信息';  
  501.           END IF;  
  502.         END IF;  
  503.       ELSE--未启用货位控制  
  504.         x_locator_type := 0;  
  505.       END IF;  
  506.       IF l_to_inv_locator_type <> 0 THEN --启用了货位控制  
  507.         x_locator_type := l_to_inv_locator_type;  
  508.         IF p_trolin_rec.to_locator_id IS NOT NULL THEN--货位不为空  
  509.           x_return_status := fnd_api.G_RET_STS_SUCCESS;  
  510.           x_to_locator_id := p_trolin_rec.to_locator_id;  
  511.         ELSE--货位为空  
  512.           --自动创建货位(目标库存货位)  
  513.           create_locator(x_return_status     => x_return_status,  
  514.                          x_msg_count         => x_msg_count,  
  515.                          x_msg_data          => x_msg_data,  
  516.                          x_locator_id        => x_to_locator_id,  
  517.                          x_locator_exists    => x_locator_exists,  
  518.                          p_organization_id   => p_trolin_rec.organization_id,  
  519.                          p_subinventory_code => p_trolin_rec.to_subinventory_code,  
  520.                          p_project_id        => p_trolin_rec.project_id,  
  521.                          p_task_id           => p_trolin_rec.task_id,  
  522.                          p_locator_type      => x_locator_type);  
  523.           IF x_from_locator_id IS NULL THEN  
  524.             x_msg_data := '自动创建货位时错误异常,请确认是否已经包含子库存、项目和任务的信息';  
  525.           END IF;  
  526.         END IF;  
  527.       ELSE --未启用货位控制  
  528.         x_locator_type := 0;  
  529.       END IF;  
  530.     ELSE  
  531.       put_log('源子库存和目标子库存的货位控制类型不一致:');  
  532.     END IF;  
  533.   EXCEPTION  
  534.     WHEN OTHERS THEN  
  535.       put_log('检查和生成货位时出现异常:' || SQLERRM);  
  536.   END check_and_create_locator;  
  537.   /*======================================================= 
  538.   *  FUNCTION / PROCEDURE 
  539.   *       validate_subinv_quantity 
  540.   *   DESCRIPTION: 
  541.   *      验证子库存的现用量和可用量 
  542.   *   ARGUMENT: 
  543.   *     x_return_status          :状态 
  544.   *     x_msg_count              :错误信息数量 
  545.   *     x_msg_data               :错误信息 
  546.   *     p_trolin_rec             :物料搬运单行的一行记录   
  547.   *     p_transaction_quantity   :事务处理数量 
  548.   *     p_transaction_date       :事务处理日期 
  549.   *   RETURN:   
  550.   *       N/A 
  551.   *   HISTORY: 
  552.   *     1.00 27/10/2010 cxy 
  553.   =========================================================*/  
  554.   PROCEDURE validate_subinv_quantity(x_return_status        OUT NOCOPY VARCHAR2,  
  555.                                      x_msg_count            OUT NOCOPY NUMBER,  
  556.                                      x_msg_data             OUT NOCOPY VARCHAR2,  
  557.                                      p_trolin_rec           IN INV_MOVE_ORDER_PUB.Trolin_Rec_Type,  
  558.                                      p_transaction_quantity IN NUMBER,  
  559.                                      p_transaction_date     IN DATE) IS  
  560.     x_qoh               NUMBER; --quantity on hand  
  561.     x_rqoh              NUMBER; --reservable quantity on hand  
  562.     x_qr                NUMBER; --quantity reserved  
  563.     x_qs                NUMBER; --quantity suggested  
  564.     x_att               NUMBER; --available to transact  
  565.     x_atr               NUMBER := 0; --available to reserve  
  566.     x_sqoh              NUMBER; --secondary quantity on hand                  -- invConv change  
  567.     x_srqoh             NUMBER; --secondary reservable quantity on hand       -- invConv change  
  568.     x_sqr               NUMBER; --secondary quantity reserved                 -- invConv change  
  569.     x_sqs               NUMBER; --secondare quantity suggested                -- invConv change  
  570.     x_satt              NUMBER; --secondary available to transact             -- invConv change  
  571.     x_satr              NUMBER; --secondary available to reserve              -- invConv change  
  572.     l_lot_control_flag  BOOLEAN := FALSE;  
  573.     l_organization_code VARCHAR2(3);  --库存组织代码  
  574.     l_item_code         VARCHAR2(40); --物料代码  
  575.     x_locator_type      VARCHAR2(60); --货位控制类型  
  576.     x_from_locator_id   NUMBER;       --来源货位  
  577.     x_to_locator_id     NUMBER;       --目标货位  
  578.     l_locator_id        NUMBER;       --子库存的货位  
  579.   BEGIN  
  580.     --得到库存代码  
  581.     SELECT mp.organization_code  
  582.       INTO l_organization_code  
  583.       FROM mtl_parameters mp  
  584.      WHERE mp.organization_id = p_trolin_rec.organization_id;  
  585.     --得到物料代码  
  586.     SELECT msib.segment1  
  587.       INTO l_item_code  
  588.       FROM mtl_system_items_b msib  
  589.      WHERE msib.organization_id = p_trolin_rec.organization_id  
  590.        AND msib.inventory_item_id = p_trolin_rec.inventory_item_id;  
  591.     --调用系统的api检查某一库存组织某一字库的某一个物料的现有量、可用量等数量  
  592.     inv_quantity_tree_pub.query_quantities(p_api_version_number  => 1.0,  
  593.                                            x_return_status       => x_return_status,  
  594.                                            x_msg_count           => x_msg_count,  
  595.                                            x_msg_data            => x_msg_data,  
  596.                                            p_organization_id     => p_trolin_rec.organization_id, --库存组织  
  597.                                            p_inventory_item_id   => p_trolin_rec.inventory_item_id, --item id  
  598.                                            p_tree_mode           => 2,  
  599.                                            p_is_revision_control => FALSE,  
  600.                                            p_is_lot_control      => l_lot_control_flag, --是否启用批次控制  
  601.                                            p_lot_expiration_date => p_transaction_date, --事务处理数量  
  602.                                            p_is_serial_control   => FALSE,  
  603.                                            p_grade_code          => NULL, -- INVCONV NOT NEEDED NOW                                          
  604.                                            p_revision            => NULL, --版本号  
  605.                                            p_lot_number          => NULL, --批次控制  
  606.                                            p_subinventory_code   => p_trolin_rec.from_subinventory_code, --来源子库存代码  
  607.                                            p_locator_id          => NULL, --货位id  
  608.                                            x_qoh                 => x_qoh, --现有量  
  609.                                            x_rqoh                => x_rqoh, --现有包流量  
  610.                                            x_qr                  => x_qr, --保留量  
  611.                                            x_qs                  => x_qs, --建议保留量  
  612.                                            x_att                 => x_att, --可处理数量  
  613.                                            x_atr                 => x_atr, --保留量  
  614.                                            x_sqoh                => x_sqoh, -- INVCONV                                    
  615.                                            x_srqoh               => x_srqoh, -- INVCONV  
  616.                                            x_sqr                 => x_sqr, -- INVCONV  
  617.                                            x_sqs                 => x_sqs, -- INVCONV  
  618.                                            x_satt                => x_satt, -- INVCONV  
  619.                                            x_satr                => x_satr); -- INVCONV    
  620.     IF l_mo_debug_falg = 'Y' THEN  
  621.       --输出调试信息                                                   
  622.       put_log('得到的库存现用量的状态为:' || x_return_status);  
  623.       put_log('得到的库存现用量为:' || x_atr);  
  624.     END IF;  
  625.     IF x_atr <= 0 THEN  
  626.       x_return_status := fnd_api.G_RET_STS_UNEXP_ERROR;  
  627.       x_msg_data      := '库存组织 ' || l_organization_code || ' 的子库存 ' ||  
  628.                          p_trolin_rec.from_subinventory_code || ' 中物料 ' ||  
  629.                          l_item_code || ' 的可用量为' || x_atr;  
  630.       RETURN;  
  631.     END IF;  
  632.     --检查并创建货位  
  633.     check_and_create_locator(x_return_status   => x_return_status,  
  634.                              x_msg_data        => x_msg_data,  
  635.                              x_locator_type    => x_locator_type,  
  636.                              x_from_locator_id => x_from_locator_id,  
  637.                              x_to_locator_id   => x_to_locator_id,  
  638.                              p_trolin_rec      => p_trolin_rec);  
  639.     IF x_locator_type <> 0 THEN  
  640.       l_locator_id := x_from_locator_id;  
  641.     ELSE  
  642.       l_locator_id := NULL;  
  643.     END IF;  
  644.     IF x_return_status IS NULL THEN  
  645.       x_return_status := fnd_api.G_RET_STS_UNEXP_ERROR;  
  646.       x_msg_data      := x_msg_data;  
  647.       RETURN;  
  648.     END IF;  
  649.     --调用系统的api检查某一库存组织某一字库的某一个物料的现有量、可用量等数量  
  650.     x_qoh   := NULL;  
  651.     x_rqoh  := NULL;  
  652.     x_qr    := NULL;  
  653.     x_qs    := NULL;  
  654.     x_att   := NULL;  
  655.     x_atr   := NULL;  
  656.     x_sqoh  := NULL;  
  657.     x_srqoh := NULL;  
  658.     x_sqr   := NULL;  
  659.     x_sqs   := NULL;  
  660.     x_satt  := NULL;  
  661.     x_satr  := NULL;  
  662.     --调用API得到库存下的物料的现用量和可用量  
  663.     inv_quantity_tree_pub.query_quantities(p_api_version_number  => 1.0,  
  664.                                            x_return_status       => x_return_status,  
  665.                                            x_msg_count           => x_msg_count,  
  666.                                            x_msg_data            => x_msg_data,  
  667.                                            p_organization_id     => p_trolin_rec.organization_id, --库存组织  
  668.                                            p_inventory_item_id   => p_trolin_rec.inventory_item_id, --item id  
  669.                                            p_tree_mode           => 2,  
  670.                                            p_is_revision_control => FALSE,  
  671.                                            p_is_lot_control      => l_lot_control_flag, --是否启用批次控制  
  672.                                            p_lot_expiration_date => p_transaction_date, --事务处理数量  
  673.                                            p_is_serial_control   => FALSE,  
  674.                                            p_grade_code          => NULL, -- INVCONV      NOT NEEDED NOW                                          
  675.                                            p_revision            => NULL, --版本号  
  676.                                            p_lot_number          => NULL, --批次控制  
  677.                                            p_subinventory_code   => p_trolin_rec.from_subinventory_code, --来源子库存代码  
  678.                                            p_locator_id          => l_locator_id, --货位id  
  679.                                            x_qoh                 => x_qoh, --现有量  
  680.                                            x_rqoh                => x_rqoh, --现有包流量  
  681.                                            x_qr                  => x_qr, --保留量  
  682.                                            x_qs                  => x_qs, --建议保留量  
  683.                                            x_att                 => x_att, --可处理数量  
  684.                                            x_atr                 => x_atr, --保留量  
  685.                                            x_sqoh                => x_sqoh, -- INVCONV                                    
  686.                                            x_srqoh               => x_srqoh, -- INVCONV  
  687.                                            x_sqr                 => x_sqr, -- INVCONV  
  688.                                            x_sqs                 => x_sqs, -- INVCONV  
  689.                                            x_satt                => x_satt, -- INVCONV  
  690.                                            x_satr                => x_satr); -- INVCONV  
  691.     IF l_mo_debug_falg = 'Y' THEN  
  692.       --输出调试信息                                                  
  693.       put_log('库存组织');  
  694.     END IF;  
  695.     IF x_return_status <> fnd_api.G_RET_STS_SUCCESS THEN  
  696.       x_return_status := fnd_api.G_RET_STS_UNEXP_ERROR;  
  697.       x_msg_data      := '获取 库存组织 ' || l_organization_code || ' 的子库存 ' ||  
  698.                          p_trolin_rec.from_subinventory_code || ' 中物料 ' ||  
  699.                          l_item_code || ' 的可用量时出现异常!';  
  700.     END IF;  
  701.     IF l_mo_debug_falg = 'Y' THEN  
  702.       --输出调试信息  
  703.       put_log('得到的库存现用量的状态为:' || x_return_status);  
  704.       put_log('得到的库存现用量为:' || x_atr);  
  705.     END IF;  
  706.     IF x_atr <= 0 THEN  
  707.       x_return_status := fnd_api.G_RET_STS_UNEXP_ERROR;  
  708.       x_msg_data      := '库存组织 ' || l_organization_code || ' 的子库存 ' ||  
  709.                          p_trolin_rec.from_subinventory_code || ' 中物料 ' ||  
  710.                          l_item_code || ' 的可用量为 ' || x_atr;  
  711.     END IF;  
  712.     IF x_atr <> 0 AND x_atr < p_transaction_quantity THEN  
  713.       x_return_status := fnd_api.G_RET_STS_UNEXP_ERROR;  
  714.       x_msg_data      := '库存组织 ' || l_organization_code || ' 的子库存 ' ||  
  715.                          p_trolin_rec.from_subinventory_code || ' 中物料 ' ||  
  716.                          l_item_code || ' 的可用量 ' || x_atr || ' 小于处理数量 ' ||  
  717.                          p_transaction_quantity;  
  718.     END IF;  
  719.   EXCEPTION  
  720.     WHEN OTHERS THEN  
  721.       put_log('检查库存的现用量和可用量时出现异常:' || SQLERRM);  
  722.   END validate_subinv_quantity;  
  723.   /*======================================================= 
  724.   *  FUNCTION / PROCEDURE 
  725.   *       validate_data 
  726.   *   DESCRIPTION: 
  727.   *      验证客户化临时表的数据 
  728.   *   ARGUMENT: 
  729.   *     x_return_status          :状态 
  730.   *     x_msg_count              :错误信息数量 
  731.   *     x_msg_data               :错误信息 
  732.   *     p_trolin_rec             :物料搬运单行的一行记录   
  733.   *     p_line_id                :物料搬运单行id 
  734.   *     p_transaction_quantity   :事务处理数量 
  735.   *     p_transaction_date       :事务处理日期   
  736.   *   RETURN:   
  737.   *       N/A 
  738.   *   HISTORY: 
  739.   *     1.00 27/10/2010 cxy 
  740.   =========================================================*/  
  741.   PROCEDURE validate_data(x_return_status        OUT NOCOPY VARCHAR2,  
  742.                           x_msg_count            OUT NOCOPY NUMBER,  
  743.                           x_msg_data             OUT NOCOPY VARCHAR2,  
  744.                           p_trolin_rec           IN INV_MOVE_ORDER_PUB.Trolin_Rec_Type,  
  745.                           p_line_id              IN NUMBER,  
  746.                           p_transaction_quantity IN NUMBER,  
  747.                           p_transaction_date     IN DATE) IS  
  748.     l_error_flag    VARCHAR2(1) := 'N';    --错误标志  
  749.     l_error_message VARCHAR2(1000) := NULL;--错误信息  
  750.   BEGIN  
  751.     --初始化  
  752.     l_error_flag := 'N';  
  753.     IF p_trolin_rec.quantity <> p_transaction_quantity THEN  
  754.       --接口中的数量和EBS系统中的剩余的数量不一致  
  755.       l_error_flag    := 'Y';  
  756.       l_error_message := '接口中的数量' || p_transaction_quantity ||  
  757.                          '与EBS系统中的剩余的数量' || p_trolin_rec.quantity || '不一致';  
  758.       GOTO end_error;  
  759.     END IF;  
  760.     --检查并验证库存的现用量和可用量    
  761.     validate_subinv_quantity(x_return_status        => x_return_status,  
  762.                              x_msg_count            => x_msg_count,  
  763.                              x_msg_data             => x_msg_data,  
  764.                              p_trolin_rec           => p_trolin_rec,  
  765.                              p_transaction_quantity => p_transaction_quantity,  
  766.                              p_transaction_date     => p_transaction_date);  
  767.     
  768.     IF x_return_status <> fnd_api.G_RET_STS_SUCCESS THEN  
  769.       x_return_status := fnd_api.G_RET_STS_UNEXP_ERROR;  
  770.       RETURN;  
  771.     END IF;  
  772.     NULL; --添加一个可执行语句,防止GOTO语句出错  
  773.     <>  
  774.     IF l_error_flag = 'N' THEN  
  775.       x_return_status := fnd_api.G_RET_STS_SUCCESS;  
  776.     ELSE  
  777.       x_return_status := fnd_api.G_RET_STS_UNEXP_ERROR;  
  778.       x_msg_count     := 1;  
  779.       x_msg_data      := l_error_message;  
  780.     END IF;  
  781.   EXCEPTION  
  782.     WHEN OTHERS THEN  
  783.       put_log('进行数据有效性验证时出现异常:' || SQLERRM);  
  784.   END validate_data;  
  785.   
  786.   /*======================================================= 
  787.   *  FUNCTION / PROCEDURE 
  788.   *       get_trolin_rec 
  789.   *   DESCRIPTION: 
  790.   *      得到物料搬运单的一行记录 
  791.   *   ARGUMENT: 
  792.   *     x_return_status          :状态 
  793.   *     x_trolin_rec             :物料搬运单行的一行记录   
  794.   *     p_trolin_tbl             :一条物料搬运单的所有搬运单行 
  795.   *     p_line_id                :物料搬运单行id 
  796.   *   RETURN:   
  797.   *       N/A 
  798.   *   HISTORY: 
  799.   *     1.00 27/10/2010 cxy 
  800.   =========================================================*/  
  801.   PROCEDURE get_trolin_rec(x_return_status OUT NOCOPY VARCHAR2,  
  802.                            x_trolin_rec    OUT NOCOPY INV_MOVE_ORDER_PUB.Trolin_Rec_Type,  
  803.                            p_trolin_tbl    IN INV_MOVE_ORDER_PUB.Trolin_Tbl_Type,  
  804.                            p_line_id       IN NUMBER) IS  
  805.     l_table_index NUMBER := 0;  
  806.   BEGIN  
  807.     FOR l_table_index IN 1 .. p_trolin_tbl.COUNT LOOP  
  808.       IF p_line_id = p_trolin_tbl(l_table_index).line_id THEN  
  809.         x_trolin_rec    := p_trolin_tbl(l_table_index);  
  810.         x_return_status := fnd_api.G_RET_STS_SUCCESS;  
  811.         RETURN;  
  812.       END IF;  
  813.     END LOOP; --FOR x_table_index IN x_trolin_tbl.COUNT LOOP   
  814.     x_return_status := fnd_api.G_RET_STS_UNEXP_ERROR;  
  815.   EXCEPTION  
  816.     WHEN OTHERS THEN  
  817.       put_log('得到物料搬运单时出现异常:' || SQLERRM);  
  818.   END get_trolin_rec;  
  819.   /*======================================================= 
  820.   *  FUNCTION / PROCEDURE 
  821.   *       get_transaction_action_id 
  822.   *   DESCRIPTION: 
  823.   *      得到事务处理的活动id 
  824.   *   ARGUMENT: 
  825.   *   p_transaction_type_id:事务处理类型id 
  826.   *   RETURN:   
  827.   *       事务处理的活动id 
  828.   *   HISTORY: 
  829.   *     1.00 27/10/2010 cxy 
  830.   =========================================================*/  
  831.   FUNCTION get_transaction_action_id(p_transaction_type_id IN NUMBER)  
  832.     RETURN NUMBER IS  
  833.     l_transaction_action_id NUMBER;--事务处理的活动id  
  834.   BEGIN  
  835.     SELECT mtt.transaction_action_id  
  836.       INTO l_transaction_action_id  
  837.       FROM mtl_transaction_types mtt  
  838.      WHERE mtt.transaction_type_id = p_transaction_type_id;  
  839.     RETURN l_transaction_action_id;  
  840.   EXCEPTION  
  841.     WHEN NO_DATA_FOUND THEN  
  842.       RETURN NULL;  
  843.     WHEN TOO_MANY_ROWS THEN  
  844.       put_log('得到事务处理的活动id时返回的多个行!');  
  845.     WHEN OTHERS THEN  
  846.       put_log('得到物料搬运单活动id时出现异常:' || SQLERRM);  
  847.   END get_transaction_action_id;  
  848.   /*======================================================= 
  849.   *  FUNCTION / PROCEDURE 
  850.   *       get_acct_period_id 
  851.   *   DESCRIPTION: 
  852.   *      得到库存会计期id 
  853.   *   ARGUMENT: 
  854.   *   p_organization_id :库存组织id 
  855.   *   p_transaction_date:事务处理日期   
  856.   *   RETURN:   
  857.   *       库存会计期id 
  858.   *   HISTORY: 
  859.   *     1.00 27/10/2010 cxy 
  860.   =========================================================*/  
  861.   FUNCTION get_acct_period_id(p_organization_id  IN NUMBER,  
  862.                               p_transaction_date IN DATE) RETURN NUMBER IS  
  863.     l_acct_period_id NUMBER;--库存会计期id  
  864.   BEGIN  
  865.     SELECT oap.acct_period_id  
  866.       INTO l_acct_period_id  
  867.       FROM org_acct_periods oap  
  868.      WHERE oap.organization_id = p_organization_id  
  869.        AND (p_transaction_date BETWEEN oap.period_start_date AND  
  870.            oap.schedule_close_date);  
  871.     RETURN l_acct_period_id;  
  872.   EXCEPTION  
  873.     WHEN NO_DATA_FOUND THEN  
  874.       RETURN NULL;  
  875.     WHEN TOO_MANY_ROWS THEN  
  876.       put_log('得到库存会计期id时返回的多个行!');  
  877.     WHEN OTHERS THEN  
  878.       put_log('得到库存会计期id时出现异常:' || SQLERRM);  
  879.   END get_acct_period_id;  
  880.   
  881.   /*======================================================= 
  882.   *  FUNCTION / PROCEDURE 
  883.   *       insert_mmtt_row 
  884.   *   DESCRIPTION: 
  885.   *      插入某一物料搬运单事务处理临时表的一条记录 
  886.   *   ARGUMENT:   
  887.   *     x_return_status            :状态 
  888.   *     x_transaction_temp_id      :临时表id 
  889.   *     x_msg_data                 :错误信息 
  890.   *     x_trohdr_rec               :物料搬运单头的一行记录 
  891.   *     x_trohdr_val_rec           :物料搬运单头的一行记录对应的值 
  892.   *     x_trolin_tbl               :一个物料搬运单头对应的所有物料搬运单行 
  893.   *     x_trolin_val_tbl           :一个物料搬运单头对应的所有物料搬运单行的值 
  894.   *     p_header_id                :物料搬运单头id 
  895.   *     p_line_id                  :物料搬运单行id 
  896.   *     p_transaction_quantity     :事务处理数量 
  897.   *     p_transaction_date         :事务处理日期       
  898.   *   RETURN:   
  899.   *       N/A 
  900.   *   HISTORY: 
  901.   *     1.00 27/10/2010 cxy 
  902.   =========================================================*/  
  903.   PROCEDURE insert_mmtt_row(x_return_status        OUT NOCOPY VARCHAR2,  
  904.                             x_transaction_temp_id  OUT NUMBER,  
  905.                             p_trohdr_rec           IN INV_MOVE_ORDER_PUB.Trohdr_Rec_Type,  
  906.                             p_trohdr_val_rec       IN INV_MOVE_ORDER_PUB.Trohdr_Val_Rec_Type,  
  907.                             p_trolin_tbl           IN INV_MOVE_ORDER_PUB.Trolin_Tbl_Type,  
  908.                             p_trolin_val_tbl       IN INV_MOVE_ORDER_PUB.Trolin_Val_Tbl_Type,  
  909.                             p_header_id            IN NUMBER,  
  910.                             p_line_id              IN NUMBER,  
  911.                             p_transaction_quantity IN NUMBER,  
  912.                             p_transaction_date     IN DATE) IS  
  913.     l_mo_line_detail_rec  inv_mo_line_detail_util.g_mmtt_rec;  
  914.     l_transaction_temp_id NUMBER;        --临时表的id    
  915.     l_trolin_rec          INV_MOVE_ORDER_PUB.Trolin_Rec_Type;  
  916.     x_locator_type        VARCHAR2(60);   --货位控制类型  
  917.     x_from_locator_id     NUMBER;         --来源货位  
  918.     x_to_locator_id       NUMBER;         --目标货位  
  919.     x_msg_data            VARCHAR2(2000); --错误信息  
  920.   BEGIN  
  921.     --得到某一物料搬运单行的信息  
  922.     get_trolin_rec(x_return_status => x_return_status,  
  923.                    x_trolin_rec    => l_trolin_rec,  
  924.                    p_trolin_tbl    => p_trolin_tbl,  
  925.                    p_line_id       => p_line_id);  
  926.     --检查是否启用货位控制,如果启用,则动态生成货位  
  927.     SELECT mtl_material_transactions_s.nextval  
  928.       INTO l_transaction_temp_id  
  929.       FROM DUAL;  
  930.     --判断货位是否已经存在,如果存在,则自动创建货位  
  931.     check_and_create_locator(x_return_status   => x_return_status,  
  932.                              x_msg_data        => x_msg_data,  
  933.                              x_locator_type    => x_locator_type,  
  934.                              x_from_locator_id => x_from_locator_id,  
  935.                              x_to_locator_id   => x_to_locator_id,  
  936.                              p_trolin_rec      => l_trolin_rec);  
  937.     IF l_mo_debug_falg = 'Y' THEN  
  938.       --输出调试信息                           
  939.       put_log('项目号:'     || l_trolin_rec.project_id);  
  940.       put_log('项目号:'     || l_trolin_rec.task_id);  
  941.       put_log('来源货位id:' || x_from_locator_id);  
  942.       put_log('目标货位id:' || x_to_locator_id);  
  943.     END IF;  
  944.     l_mo_line_detail_rec.locator_id             := x_from_locator_id; --源子库存货位  
  945.     l_mo_line_detail_rec.transfer_to_location   := x_to_locator_id; --目标子库存货位    
  946.     l_mo_line_detail_rec.transaction_header_id  := NULL;  
  947.     l_mo_line_detail_rec.transaction_temp_id    := l_transaction_temp_id;  
  948.     l_mo_line_detail_rec.source_code            := NULL;  
  949.     l_mo_line_detail_rec.source_line_id         := NULL;  
  950.     l_mo_line_detail_rec.transaction_mode       := 1;  
  951.     l_mo_line_detail_rec.lock_flag              := 'N';  
  952.     l_mo_line_detail_rec.last_update_date       := SYSDATE;  
  953.     l_mo_line_detail_rec.last_updated_by        := fnd_global.user_id;  
  954.     l_mo_line_detail_rec.creation_date          := SYSDATE;  
  955.     l_mo_line_detail_rec.created_by             := fnd_global.user_id;  
  956.     l_mo_line_detail_rec.last_update_login      := fnd_global.user_id;  
  957.     l_mo_line_detail_rec.request_id             := NULL;  
  958.     l_mo_line_detail_rec.program_application_id := NULL;  
  959.     l_mo_line_detail_rec.program_id             := NULL;  
  960.     l_mo_line_detail_rec.program_update_date    := NULL;  
  961.     --从物料搬运单得到item_id  
  962.     l_mo_line_detail_rec.inventory_item_id := l_trolin_rec.inventory_item_id;  
  963.     l_mo_line_detail_rec.revision          := NULL;  
  964.     l_mo_line_detail_rec.organization_id   := l_trolin_rec.organization_id;  
  965.     l_mo_line_detail_rec.subinventory_code := l_trolin_rec.from_subinventory_code;  
  966.     --l_mo_line_detail_rec.locator_id           := l_trolin_rec.from_locator_id;  
  967.     l_mo_line_detail_rec.transaction_quantity        := p_transaction_quantity;  
  968.     l_mo_line_detail_rec.primary_quantity            := p_transaction_quantity;  
  969.     l_mo_line_detail_rec.transaction_uom             := l_trolin_rec.uom_code;  
  970.     l_mo_line_detail_rec.transaction_cost            := NULL;  
  971.     l_mo_line_detail_rec.transaction_type_id         := l_trolin_rec.transaction_type_id;  
  972.     l_mo_line_detail_rec.transaction_action_id       := get_transaction_action_id(l_trolin_rec.transaction_type_id);  
  973.     l_mo_line_detail_rec.transaction_source_type_id  := l_trolin_rec.transaction_source_type_id;  
  974.     l_mo_line_detail_rec.transaction_source_id       := p_header_id;  
  975.     l_mo_line_detail_rec.transaction_source_name     := NULL;  
  976.     l_mo_line_detail_rec.transaction_date            := p_transaction_date;  
  977.     l_mo_line_detail_rec.acct_period_id              := get_acct_period_id(l_trolin_rec.organization_id,  
  978.                                                                            p_transaction_date); --账户期间id  
  979.     l_mo_line_detail_rec.distribution_account_id     := NULL;  
  980.     l_mo_line_detail_rec.transaction_reference       := NULL;  
  981.     l_mo_line_detail_rec.requisition_line_id         := NULL;  
  982.     l_mo_line_detail_rec.requisition_distribution_id := NULL;  
  983.     l_mo_line_detail_rec.reason_id                   := l_trolin_rec.reason_id;  
  984.     l_mo_line_detail_rec.lot_number                  := l_trolin_rec.lot_number;  
  985.     l_mo_line_detail_rec.lot_expiration_date         := NULL;  
  986.     l_mo_line_detail_rec.serial_number               := NULL;  
  987.     l_mo_line_detail_rec.receiving_document          := NULL;  
  988.     l_mo_line_detail_rec.demand_id                   := NULL;  
  989.     l_mo_line_detail_rec.rcv_transaction_id          := NULL;  
  990.     l_mo_line_detail_rec.move_transaction_id         := NULL;  
  991.     l_mo_line_detail_rec.completion_transaction_id   := NULL;  
  992.     l_mo_line_detail_rec.wip_entity_type             := NULL;  
  993.     l_mo_line_detail_rec.schedule_id                 := NULL;  
  994.     l_mo_line_detail_rec.repetitive_line_id          := NULL;  
  995.     l_mo_line_detail_rec.employee_code               := NULL;  
  996.     l_mo_line_detail_rec.primary_switch              := NULL;  
  997.     l_mo_line_detail_rec.schedule_update_code        := NULL;  
  998.     l_mo_line_detail_rec.setup_teardown_code         := NULL;  
  999.     l_mo_line_detail_rec.item_ordering               := NULL;  
  1000.     l_mo_line_detail_rec.negative_req_flag           := NULL;  
  1001.     l_mo_line_detail_rec.operation_seq_num           := NULL;  
  1002.     l_mo_line_detail_rec.picking_line_id             := NULL;  
  1003.     l_mo_line_detail_rec.trx_source_line_id          := p_line_id;  
  1004.     l_mo_line_detail_rec.trx_source_delivery_id      := NULL;  
  1005.     l_mo_line_detail_rec.physical_adjustment_id      := NULL;  
  1006.     l_mo_line_detail_rec.cycle_count_id              := NULL;  
  1007.     l_mo_line_detail_rec.rma_line_id                 := NULL;  
  1008.     l_mo_line_detail_rec.customer_ship_id            := NULL;  
  1009.     l_mo_line_detail_rec.currency_code               := NULL;  
  1010.     l_mo_line_detail_rec.currency_conversion_rate    := NULL;  
  1011.     l_mo_line_detail_rec.currency_conversion_type    := NULL;  
  1012.     l_mo_line_detail_rec.currency_conversion_date    := NULL;  
  1013.     l_mo_line_detail_rec.ussgl_transaction_code      := NULL;  
  1014.     l_mo_line_detail_rec.vendor_lot_number           := NULL;  
  1015.     l_mo_line_detail_rec.encumbrance_account         := NULL;  
  1016.     l_mo_line_detail_rec.encumbrance_amount          := NULL;  
  1017.     l_mo_line_detail_rec.ship_to_location            := NULL;  
  1018.     l_mo_line_detail_rec.shipment_number             := NULL;  
  1019.     l_mo_line_detail_rec.transfer_cost               := NULL;  
  1020.     l_mo_line_detail_rec.transportation_cost         := NULL;  
  1021.     l_mo_line_detail_rec.transportation_account      := NULL;  
  1022.     l_mo_line_detail_rec.freight_code                := NULL;  
  1023.     l_mo_line_detail_rec.containers                  := NULL;  
  1024.     l_mo_line_detail_rec.waybill_airbill             := NULL;  
  1025.     l_mo_line_detail_rec.expected_arrival_date       := NULL;  
  1026.     l_mo_line_detail_rec.transfer_subinventory       := l_trolin_rec.to_subinventory_code;  
  1027.     l_mo_line_detail_rec.transfer_organization       := NULL;  
  1028.     l_mo_line_detail_rec.new_average_cost               := NULL;  
  1029.     l_mo_line_detail_rec.value_change                   := NULL;  
  1030.     l_mo_line_detail_rec.percentage_change              := NULL;  
  1031.     l_mo_line_detail_rec.material_allocation_temp_id    := NULL;  
  1032.     l_mo_line_detail_rec.demand_source_header_id        := p_header_id;  
  1033.     l_mo_line_detail_rec.demand_source_line             := to_char(p_line_id);  
  1034.     l_mo_line_detail_rec.demand_source_delivery         := NULL;  
  1035.     l_mo_line_detail_rec.item_segments                  := NULL;  
  1036.     l_mo_line_detail_rec.item_description               := NULL;  
  1037.     l_mo_line_detail_rec.item_trx_enabled_flag          := NULL;  
  1038.     l_mo_line_detail_rec.item_location_control_code     := NULL;  
  1039.     l_mo_line_detail_rec.item_restrict_subinv_code      := NULL;  
  1040.     l_mo_line_detail_rec.item_restrict_locators_code    := NULL;  
  1041.     l_mo_line_detail_rec.item_revision_qty_control_code := NULL;  
  1042.     l_mo_line_detail_rec.item_primary_uom_code          := NULL;  
  1043.     l_mo_line_detail_rec.item_uom_class                 := NULL;  
  1044.     l_mo_line_detail_rec.item_shelf_life_code           := NULL;  
  1045.     l_mo_line_detail_rec.item_shelf_life_days           := NULL;  
  1046.     l_mo_line_detail_rec.item_lot_control_code          := NULL;  
  1047.     l_mo_line_detail_rec.item_serial_control_code       := NULL;  
  1048.     l_mo_line_detail_rec.item_inventory_asset_flag      := NULL;  
  1049.     l_mo_line_detail_rec.allowed_units_lookup_code      := NULL;  
  1050.     l_mo_line_detail_rec.department_id                  := NULL;  
  1051.     l_mo_line_detail_rec.department_code                := NULL;  
  1052.     l_mo_line_detail_rec.wip_supply_type                := NULL;  
  1053.     l_mo_line_detail_rec.supply_subinventory            := NULL;  
  1054.     l_mo_line_detail_rec.supply_locator_id              := NULL;  
  1055.     l_mo_line_detail_rec.valid_subinventory_flag        := NULL;  
  1056.     l_mo_line_detail_rec.valid_locator_flag             := NULL;  
  1057.     l_mo_line_detail_rec.locator_segments               := NULL;  
  1058.     l_mo_line_detail_rec.current_locator_control_code   := NULL;  
  1059.     l_mo_line_detail_rec.number_of_lots_entered         := NULL;  
  1060.     l_mo_line_detail_rec.wip_commit_flag                := NULL;  
  1061.     l_mo_line_detail_rec.next_lot_number                := NULL;  
  1062.     l_mo_line_detail_rec.lot_alpha_prefix               := NULL;  
  1063.     l_mo_line_detail_rec.next_serial_number             := NULL;  
  1064.     l_mo_line_detail_rec.serial_alpha_prefix            := NULL;  
  1065.     l_mo_line_detail_rec.shippable_flag                 := NULL;  
  1066.     l_mo_line_detail_rec.posting_flag                   := 'Y';  
  1067.     l_mo_line_detail_rec.required_flag                  := NULL;  
  1068.     l_mo_line_detail_rec.process_flag                   := 'Y';  
  1069.     l_mo_line_detail_rec.error_code                     := NULL;  
  1070.     l_mo_line_detail_rec.error_explanation              := NULL;  
  1071.     l_mo_line_detail_rec.attribute_category             := NULL;  
  1072.     l_mo_line_detail_rec.attribute1                     := NULL;  
  1073.     l_mo_line_detail_rec.attribute2                     := NULL;  
  1074.     l_mo_line_detail_rec.attribute3                     := NULL;  
  1075.     l_mo_line_detail_rec.attribute4                     := NULL;  
  1076.     l_mo_line_detail_rec.attribute5                     := NULL;  
  1077.     l_mo_line_detail_rec.attribute6                     := NULL;  
  1078.     l_mo_line_detail_rec.attribute7                     := NULL;  
  1079.     l_mo_line_detail_rec.attribute8                     := NULL;  
  1080.     l_mo_line_detail_rec.attribute9                     := NULL;  
  1081.     l_mo_line_detail_rec.attribute10                    := NULL;  
  1082.     l_mo_line_detail_rec.attribute11                    := NULL;  
  1083.     l_mo_line_detail_rec.attribute12                    := NULL;  
  1084.     l_mo_line_detail_rec.attribute13                    := NULL;  
  1085.     l_mo_line_detail_rec.attribute14                    := NULL;  
  1086.     l_mo_line_detail_rec.attribute15                    := NULL;  
  1087.     l_mo_line_detail_rec.movement_id                    := NULL;  
  1088.     l_mo_line_detail_rec.reservation_quantity           := NULL;  
  1089.     l_mo_line_detail_rec.shipped_quantity               := NULL;  
  1090.     l_mo_line_detail_rec.transaction_line_number        := NULL;  
  1091.     l_mo_line_detail_rec.task_id                        := NULL;  
  1092.     l_mo_line_detail_rec.to_task_id                     := NULL;  
  1093.     l_mo_line_detail_rec.source_task_id                 := NULL;  
  1094.     l_mo_line_detail_rec.project_id                     := NULL;  
  1095.     l_mo_line_detail_rec.source_project_id              := NULL;  
  1096.     l_mo_line_detail_rec.pa_expenditure_org_id          := NULL;  
  1097.     l_mo_line_detail_rec.to_project_id                  := NULL;  
  1098.     l_mo_line_detail_rec.expenditure_type               := NULL;  
  1099.     l_mo_line_detail_rec.final_completion_flag          := 'N';  
  1100.     l_mo_line_detail_rec.transfer_percentage            := NULL;  
  1101.     l_mo_line_detail_rec.transaction_sequence_id        := NULL;  
  1102.     l_mo_line_detail_rec.material_account               := NULL;  
  1103.     l_mo_line_detail_rec.material_overhead_account      := NULL;  
  1104.     l_mo_line_detail_rec.resource_account               := NULL;  
  1105.     l_mo_line_detail_rec.outside_processing_account     := NULL;  
  1106.     l_mo_line_detail_rec.overhead_account               := NULL;  
  1107.     l_mo_line_detail_rec.flow_schedule                  := NULL;  
  1108.     l_mo_line_detail_rec.cost_group_id                  := NULL;  
  1109.     l_mo_line_detail_rec.demand_class                   := NULL;  
  1110.     l_mo_line_detail_rec.qa_collection_id               := NULL;  
  1111.     l_mo_line_detail_rec.kanban_card_id                 := NULL;  
  1112.     l_mo_line_detail_rec.overcompletion_transaction_id  := NULL;  
  1113.     l_mo_line_detail_rec.overcompletion_primary_qty     := NULL;  
  1114.     l_mo_line_detail_rec.overcompletion_transaction_qty := NULL;  
  1115.     l_mo_line_detail_rec.end_item_unit_number           := NULL;  
  1116.     l_mo_line_detail_rec.scheduled_payback_date         := NULL;  
  1117.     l_mo_line_detail_rec.line_type_code                 := NULL;  
  1118.     l_mo_line_detail_rec.parent_transaction_temp_id     := NULL;  
  1119.     l_mo_line_detail_rec.put_away_strategy_id           := NULL;  
  1120.     l_mo_line_detail_rec.put_away_rule_id               := NULL;  
  1121.     l_mo_line_detail_rec.pick_strategy_id               := l_trolin_rec.pick_strategy_id;  
  1122.     l_mo_line_detail_rec.pick_rule_id                   := NULL;  
  1123.     l_mo_line_detail_rec.common_bom_seq_id              := NULL;  
  1124.     l_mo_line_detail_rec.common_routing_seq_id          := NULL;  
  1125.     l_mo_line_detail_rec.cost_type_id                   := NULL;  
  1126.     l_mo_line_detail_rec.org_cost_group_id              := NULL;  
  1127.     l_mo_line_detail_rec.move_order_line_id             := p_line_id;  
  1128.     l_mo_line_detail_rec.task_group_id                  := NULL;  
  1129.     l_mo_line_detail_rec.pick_slip_number               := l_trolin_rec.pick_slip_number;  
  1130.     l_mo_line_detail_rec.reservation_id                 := NULL;  
  1131.     l_mo_line_detail_rec.transaction_status             := 2; -- --Indicates if it has to be processed or just saved. NULL or 1 is default behavior. 2 is save only. 3 is ready to process  
  1132.     l_mo_line_detail_rec.transfer_cost_group_id         := NULL;  
  1133.     l_mo_line_detail_rec.lpn_id                         := NULL;  
  1134.     l_mo_line_detail_rec.transfer_lpn_id                := NULL;  
  1135.     l_mo_line_detail_rec.pick_slip_date                 := l_trolin_rec.pick_slip_date;  
  1136.     l_mo_line_detail_rec.content_lpn_id                 := NULL;  
  1137.     l_mo_line_detail_rec.secondary_transaction_quantity := NULL;  
  1138.     l_mo_line_detail_rec.secondary_uom_code             := NULL;  
  1139.     --调用标准的API对MMTT进行插入  
  1140.     inv_mo_line_detail_util.insert_row(x_return_status      => x_return_status,  
  1141.                                        p_mo_line_detail_rec => l_mo_line_detail_rec);  
  1142.     IF l_mo_debug_falg = 'Y' THEN  
  1143.       --输出调试信息  
  1144.       put_log('x_return_status:' || x_return_status);  
  1145.     END IF;  
  1146.     IF x_return_status = fnd_api.G_RET_STS_SUCCESS THEN  
  1147.       x_transaction_temp_id := l_transaction_temp_id; --回传mmtt的唯一性标识  
  1148.     END IF;  
  1149.   EXCEPTION  
  1150.     WHEN OTHERS THEN  
  1151.       put_log('插入mmtt处理行时出现异常:' || SQLERRM);  
  1152.   END insert_mmtt_row;  
  1153.   
  1154.   /*======================================================= 
  1155.   *  FUNCTION / PROCEDURE 
  1156.   *       delete_mmtt_row 
  1157.   *   DESCRIPTION: 
  1158.   *      删除某一物料搬运单事务处理临时表的一条记录 
  1159.   *   ARGUMENT: 
  1160.   *   p_header_id:物料搬运单头id 
  1161.   *   p_line_id  :物料搬运单行id     
  1162.   *   RETURN:   
  1163.   *       N/A 
  1164.   *   HISTORY: 
  1165.   *     1.00 27/10/2010 cxy 
  1166.   =========================================================*/  
  1167.   PROCEDURE delete_mmtt_row(x_return_status       OUT VARCHAR2,  
  1168.                             p_line_id             IN NUMBER,  
  1169.                             p_transaction_temp_id IN NUMBER) IS  
  1170.   BEGIN  
  1171.     inv_mo_line_detail_util.delete_row(x_return_status  => x_return_status,  
  1172.                                        p_line_id        => p_line_id,  
  1173.                                        p_line_detail_id => p_transaction_temp_id);  
  1174.   EXCEPTION  
  1175.     WHEN OTHERS THEN  
  1176.       put_log('删除某一物料搬运单的处理行时出现异常:' || SQLERRM);  
  1177.   END delete_mmtt_row;  
  1178.   /*======================================================= 
  1179.   *  FUNCTION / PROCEDURE 
  1180.   *       process_data 
  1181.   *   DESCRIPTION: 
  1182.   *      自动处理物料搬运单 
  1183.   *   ARGUMENT: 
  1184.   *   x_return_status      :返回状态 
  1185.   *   x_msg_count          :返回的行数   
  1186.   *   x_msg_data           :返回的信息 
  1187.   *   p_line_id            :物料搬运单行id       
  1188.   *   RETURN:   
  1189.   *       N/A 
  1190.   *   HISTORY: 
  1191.   *     1.00 27/10/2010 cxy 
  1192.   =========================================================*/  
  1193.   PROCEDURE process_data(x_return_status OUT NOCOPY VARCHAR2,  
  1194.                          x_msg_count     OUT NOCOPY NUMBER,  
  1195.                          x_msg_data      OUT NOCOPY VARCHAR2,  
  1196.                          p_line_id       IN NUMBER) IS  
  1197.     x_number_of_rows       NUMBER;  
  1198.     x_detailed_qty         NUMBER;  
  1199.     x_revision             VARCHAR2(3);  
  1200.     x_locator_id           NUMBER;  
  1201.     x_transfer_to_location NUMBER;  
  1202.     x_lot_number           VARCHAR2(80);  
  1203.     x_expiration_date      DATE;  
  1204.     x_transaction_temp_id  NUMBER;  
  1205.     l_trolin_tbl           INV_MOVE_ORDER_PUB.Trolin_Tbl_Type;  
  1206.     l_mold_tbl             INV_MO_LINE_DETAIL_UTIL.g_mmtt_tbl_type;  
  1207.     x_mmtt_tbl             INV_MO_LINE_DETAIL_UTIL.g_mmtt_tbl_type;  
  1208.     x_trolin_tbl           INV_Move_Order_PUB.Trolin_Tbl_Type;  
  1209.     l_mo_line_detail_rec   inv_mo_line_detail_util.g_mmtt_rec;  
  1210.   BEGIN  
  1211.     IF l_mo_debug_falg = 'Y' THEN  
  1212.       --输出调试信息  
  1213.       put_log('--------创建物料搬运单分配行开始----------');  
  1214.     END IF;  
  1215.     INV_Replenish_Detail_PUB.line_details_pub(p_line_id               => p_line_id,  
  1216.                                               x_number_of_rows        => x_number_of_rows,  
  1217.                                               x_detailed_qty          => x_detailed_qty,  
  1218.                                               x_return_status         => x_return_status,  
  1219.                                               x_msg_count             => x_msg_count,  
  1220.                                               x_msg_data              => x_msg_data,  
  1221.                                               x_revision              => x_revision,  
  1222.                                               x_locator_id            => x_locator_id,  
  1223.                                               x_transfer_to_location  => x_transfer_to_location,  
  1224.                                               x_lot_number            => x_lot_number,  
  1225.                                               x_expiration_date       => x_expiration_date,  
  1226.                                               x_transaction_temp_id   => x_transaction_temp_id,  
  1227.                                               p_transaction_header_id => NULL,  
  1228.                                               p_transaction_mode      => NULL,  
  1229.                                               p_move_order_type       => 1,  
  1230.                                               p_serial_flag           => FND_API.G_TRUE,  
  1231.                                               p_plan_tasks            => NULL,  
  1232.                                               p_auto_pick_confirm     => NULL,  
  1233.                                               p_commit                => NULL);  
  1234.     IF l_mo_debug_falg = 'Y' THEN  
  1235.       --输出调试信息                                            
  1236.       put_log('x_number_of_rows:' || x_number_of_rows);  
  1237.       put_log('x_return_status:' || x_return_status);  
  1238.       put_log('--------创建物料搬运单分配行结束----------');  
  1239.     END IF;  
  1240.     IF x_number_of_rows > 0 AND x_return_status = fnd_api.G_RET_STS_SUCCESS THEN  
  1241.       --得到物料搬运单行信息  
  1242.       IF l_mo_debug_falg = 'Y' THEN --输出调试信息  
  1243.         put_log('--------获得物料搬运单行信息开始----------');  
  1244.       END IF;  
  1245.       l_trolin_tbl := inv_trolin_util.query_rows(p_line_id => p_line_id);  
  1246.       IF l_mo_debug_falg = 'Y' THEN--输出调试信息  
  1247.         put_log('--------获得物料搬运单行信息结束----------');  
  1248.         put_log('--------自动挑库确认开始----------');  
  1249.       END IF;  
  1250.       --自动挑库确认  
  1251.       INV_PICK_WAVE_PICK_CONFIRM_PUB.Pick_Confirm(p_api_version_number => 1.0,  
  1252.                                                   p_init_msg_list      => fnd_api.G_FALSE,  
  1253.                                                   p_commit             => fnd_api.G_FALSE,  
  1254.                                                   x_return_status      => x_return_status,  
  1255.                                                   x_msg_count          => x_msg_count,  
  1256.                                                   x_msg_data           => x_msg_data,  
  1257.                                                   p_move_order_type    => 1,  
  1258.                                                   p_transaction_mode   => 1,  
  1259.                                                   p_trolin_tbl         => l_trolin_tbl,  
  1260.                                                   p_mold_tbl           => l_mold_tbl,  
  1261.                                                   x_mmtt_tbl           => x_mmtt_tbl,  
  1262.                                                   x_trolin_tbl         => x_trolin_tbl,  
  1263.                                                   p_transaction_date   => NULL);  
  1264.       IF l_mo_debug_falg = 'Y' THEN--输出调试信息                                       
  1265.         put_log('x_return_status:' || x_return_status);  
  1266.         put_log('x_msg_count:'     || x_msg_count);  
  1267.         put_log('x_msg_data:'      || x_msg_data);  
  1268.         put_log('--------自动挑库确认结束----------');  
  1269.       END IF;  
  1270.     END IF;  
  1271.   EXCEPTION  
  1272.     WHEN OTHERS THEN  
  1273.       put_log('自动处理物料搬运单时出错:' || SQLERRM);  
  1274.   END process_data;  
  1275.   /*======================================================= 
  1276.   *  FUNCTION / PROCEDURE 
  1277.   *       process_history_data 
  1278.   *   DESCRIPTION: 
  1279.   *      处理上一次错误的历史记录 
  1280.   *   ARGUMENT: 
  1281.   *   x_processd_flag:上一次的错误记录是否已经被处理 
  1282.   *   p_line_id      :物料搬运单行id     
  1283.   *   RETURN:   
  1284.   *       N/A 
  1285.   *   HISTORY: 
  1286.   *     1.00 27/10/2010 cxy 
  1287.   =========================================================*/  
  1288.   PROCEDURE process_history_data(x_processd_flag OUT VARCHAR2,  
  1289.                                  p_line_id       IN NUMBER) IS  
  1290.     CURSOR cur_processed_order_info IS  
  1291.       SELECT mtrl.header_id            header_id,             --物料搬运单头id,  
  1292.              mtrh.request_number       request_number,        --物料搬运单编号  
  1293.              mtrl.line_id              line_id,               --物料搬运单行id  
  1294.              mtrl.line_number          line_number,           --行号  
  1295.              mtrl.organization_id      organization_id,       --库存组织ID  
  1296.              mtrl.inventory_item_id    inventory_item_id,     --物料ID  
  1297.              mtrh.transaction_type_id  transaction_type_id,   --事务处理类型ID  
  1298.              mtt.transaction_type_name transaction_type_name, --事务处理类型名称  
  1299.              mlt.lookup_code           line_status,           --行状态  
  1300.              mlt.meaning               line_status_meaning    --行状态含义       
  1301.         FROM mtl_txn_request_lines   mtrl,  
  1302.              mtl_txn_request_headers mtrh,  
  1303.              mtl_transaction_types   mtt,  
  1304.              mfg_lookups             mlt  
  1305.        WHERE mtrl.header_id            = mtrh.header_id  
  1306.          AND mtrl.transaction_type_id  = mtt.transaction_type_id  
  1307.          AND mtrl.line_status          = mlt.lookup_code  
  1308.          AND mlt.lookup_type           = 'MTL_TXN_REQUEST_STATUS'  
  1309.          AND mtrl.line_status          = 5 --表示已经关闭,表示上次错误的记录已经成功处理  
  1310.          AND mtt.transaction_action_id = 2 --事务处理的活动为 子库存转移 的记录  
  1311.          AND mtrl.line_id              = p_line_id;  
  1312.     l_processed_count NUMBER := 0;  
  1313.     v_processd_flag   VARCHAR2(1); --上次错误的 记录是否已经被处理  
  1314.   BEGIN  
  1315.     x_processd_flag := 'N'; --默认为上次的记录没有被处理  
  1316.     FOR rec_processed_order_info IN cur_processed_order_info LOOP  
  1317.       l_processed_count := l_processed_count + 1;  
  1318.       IF l_processed_count <> 0 THEN  
  1319.         v_processd_flag := 'Y';  
  1320.         EXIT;  
  1321.       END IF;  
  1322.     END LOOP;  
  1323.     IF l_processed_count = 0 THEN  
  1324.       v_processd_flag := 'N';  
  1325.     END IF;  
  1326.     IF v_processd_flag = 'Y' THEN  
  1327.       x_processd_flag := 'Y';  
  1328.       --如果上一次的错误记录已经被处理,则更新客户化表中的记录的状态  
  1329.       UPDATE cux_ediint_item_move_in ceimi  
  1330.          SET ceimi.process_id        = 4,    --将3改成4,表示此条记录已经被处理,将这条记录的状态改成已经处理  
  1331.              ceimi.error_message     = NULL, --错误信息修改成空  
  1332.              ceimi.attribute15       = '上一次处理出错,已经通过系统手工或者其他方式进行处理!',  
  1333.              ceimi.last_update_date  = SYSDATE,  
  1334.              ceimi.last_updated_by   = fnd_global.user_id,  
  1335.              ceimi.last_update_login = fnd_global.user_id  
  1336.        WHERE ceimi.line_id = p_line_id  
  1337.          AND ceimi.process_id IN (1, 3); --错误的状态  
  1338.     END IF;  
  1339.   EXCEPTION  
  1340.     WHEN OTHERS THEN  
  1341.       put_log('删除某一物料搬运单的处理行时出现异常:' || SQLERRM);  
  1342.   END process_history_data;  
  1343.   /*======================================================= 
  1344.    *  FUNCTION / PROCEDURE 
  1345.    *       main 
  1346.    *   DESCRIPTION: 
  1347.    *       并发程序入口 
  1348.    *   ARGUMENT: 
  1349.    *       errbuf            :并发程序的系统参数,返回错误信息   
  1350.    *       retcode           :并发程序的系统参数, 执行状态 
  1351.    *   RETURN: 
  1352.    *       N/A 
  1353.    *   HISTORY: 
  1354.    *     1.00 27/10/2010 cxy 
  1355.   =========================================================*/  
  1356.   /*================================================================ 
  1357.   *    主程序的步骤: 
  1358.   *    10 初始化 
  1359.   *    20 处理历史记录 
  1360.   *    30 验证数据有效性 
  1361.   *    40 在MMTT表中插入一条记录 
  1362.   *    50 自动处理物料搬运单 
  1363.   *    60 更新客户化表的状态和错误信息 
  1364.   *    70 输出处理结果 
  1365.   =================================================================*/  
  1366.   PROCEDURE main(errbuf OUT NOCOPY VARCHAR2, retcode OUT NOCOPY VARCHAR2) IS  
  1367.     
  1368.     --使用cursor取出客户化事务处理表中的所有物料搬运单头信息,不取重复的记录  
  1369.     CURSOR cur_item_move_imp_header IS  
  1370.       SELECT DISTINCT ceimi.header_id      header_id, --物料搬运单头id  
  1371.                       ceimi.request_number request_number --物料搬运单编号  
  1372.         FROM cux_ediint_item_move_in ceimi  
  1373.        WHERE ceimi.process_id IN (0, 3); ----处理新增或者上次出错的记录,0表示没有处理的记录,3表示上一次处理出错的记录       
  1374.     --使用cursor 取出客户化表中的物料搬运单行信息    
  1375.     CURSOR cur_item_move_imp_line(p_header_id NUMBER) IS  
  1376.       SELECT ceimi.header_id            header_id,            --物料搬运单头id  
  1377.              ceimi.request_number       request_number,       --物料搬运单编号  
  1378.              ceimi.line_id              line_id,              --物料搬运单行id  
  1379.              ceimi.transaction_quantity transaction_quantity, --事务处理数量  
  1380.              ceimi.transaction_date     transaction_date      --事务处理日期  
  1381.         FROM cux_ediint_item_move_in ceimi  
  1382.        WHERE ceimi.process_id IN (0, 3) --处理新增或者上次出错的记录,0表示没有处理的记录,3表示上一次处理出错的记录       
  1383.          AND ceimi.header_id = p_header_id  
  1384.        ORDER BY ceimi.line_id;  
  1385.     x_return_status       VARCHAR2(10);   --处理状态   
  1386.     x_msg_count           NUMBER;         --错误信息数量  
  1387.     x_msg_data            VARCHAR2(2000); --错误信息  
  1388.     x_trohdr_rec          INV_MOVE_ORDER_PUB.Trohdr_Rec_Type;     --物料搬运单头记录  
  1389.     x_trohdr_val_rec      INV_MOVE_ORDER_PUB.Trohdr_Val_Rec_Type; --物料搬运单头对应的记录  
  1390.     x_trolin_tbl          INV_MOVE_ORDER_PUB.Trolin_Tbl_Type;     --物料搬运单的所有行记录  
  1391.     x_trolin_val_tbl      INV_MOVE_ORDER_PUB.Trolin_Val_Tbl_Type; --物料搬运单的所有行对应的记录  
  1392.     x_trolin_rec          INV_MOVE_ORDER_PUB.Trolin_Rec_Type;     --一条物料搬运单行   
  1393.     l_line_count          NUMBER := 0; --处理的总行数  
  1394.     l_line_success_count  NUMBER := 0; --处理成功的行数  
  1395.     x_transaction_temp_id NUMBER;      --取得mmtt表的唯一性标识   
  1396.     x_processd_flag       VARCHAR2(1); --上一次的历史记录是否被手工处理  
  1397.   BEGIN  
  1398.     --循环所有的物料搬运单  
  1399.     FOR rec_item_move_imp_header IN cur_item_move_imp_header LOOP  
  1400.       /*============================================================ 
  1401.       * 10 初始化 
  1402.       * ------------------------------------------------------------ 
  1403.       * 描述:初始化变量,并得到物料搬运单的相关信息 
  1404.       =============================================================*/  
  1405.       x_trohdr_rec     := NULL; --物料搬运单头记录  
  1406.       x_trohdr_val_rec := NULL;  
  1407.       --得到物料搬运单信息  
  1408.       IF l_mo_debug_falg = 'Y' THEN--输出调试信息   
  1409.         put_log('---------------获取物料搬运单信息开始---------------------------');  
  1410.       END IF;  
  1411.       x_return_status := NULL; --处理状态   
  1412.       get_move_order(x_return_status  => x_return_status,  
  1413.                      x_msg_count      => x_msg_count,  
  1414.                      x_msg_data       => x_msg_data,  
  1415.                      x_trohdr_rec     => x_trohdr_rec,  
  1416.                      x_trohdr_val_rec => x_trohdr_val_rec,  
  1417.                      x_trolin_tbl     => x_trolin_tbl,  
  1418.                      x_trolin_val_tbl => x_trolin_val_tbl,  
  1419.                      p_header_id      => rec_item_move_imp_header.header_id);  
  1420.       IF l_mo_debug_falg = 'Y' THEN--输出调试信息           
  1421.         put_log('---------------获取物料搬运单行状态:x_return_status:' ||  
  1422.                 x_return_status);  
  1423.         put_log('---------------错误信息条数:x_msg_count:' || x_msg_count);  
  1424.         put_log('---------------错误信息:x_msg_data:' || x_msg_data);  
  1425.         put_log('---------------获取物料搬运单信息结束---------------------------');  
  1426.       END IF;  
  1427.       --物料搬运单头状态正常,则处理此物料搬运单的所有行记录  
  1428.       IF x_return_status = fnd_api.G_RET_STS_SUCCESS THEN  
  1429.         --循环物料搬运单的行,自动处理物料搬运单按照行进行处理  
  1430.         FOR rec_item_move_imp_line IN cur_item_move_imp_line(rec_item_move_imp_header.header_id) LOOP  
  1431.           --进行初始化  
  1432.           x_return_status := NULL; --处理状态   
  1433.           x_msg_count     := NULL; --错误信息条数  
  1434.           x_msg_data      := NULL; --错误信息  
  1435.           --为此执行块创建一个SAVEPOINT  
  1436.           BEGIN  
  1437.             --创建SAVEPOINT cux_item_move_line  
  1438.             SAVEPOINT cux_item_move_line;  
  1439.             UPDATE cux_ediint_item_move_in ceimi  
  1440.                SET ceimi.process_id        = 1, --1表示程序正在处理  
  1441.                    ceimi.request_id        = fnd_global.conc_request_id,  
  1442.                    ceimi.last_update_date  = SYSDATE,  
  1443.                    ceimi.last_updated_by   = fnd_global.user_id,  
  1444.                    ceimi.last_update_login = fnd_global.user_id  
  1445.              WHERE ceimi.line_id = rec_item_move_imp_line.line_id;  
  1446.             /*========================================================= 
  1447.             * 20 处理历史记录 
  1448.             * --------------------------------------------------------- 
  1449.             * 描述:检测历史数据是否已经被处理, 
  1450.             *       并更新客户表的状态和错误信息 
  1451.             ==========================================================*/  
  1452.             process_history_data(x_processd_flag => x_processd_flag,  
  1453.                                  p_line_id       => rec_item_move_imp_line.line_id);  
  1454.             IF x_processd_flag = 'N' THEN  
  1455.               --等于‘N'表示上次处理错误的记录没有被手工处理  
  1456.               --得到某一物料搬运单行的信息  
  1457.               get_trolin_rec(x_return_status => x_return_status,  
  1458.                              x_trolin_rec    => x_trolin_rec,  
  1459.                              p_trolin_tbl    => x_trolin_tbl,  
  1460.                              p_line_id       => rec_item_move_imp_line.line_id);  
  1461.               IF l_mo_debug_falg = 'Y' THEN--输出调试信息    
  1462.                 put_log('得到某一物料搬运单行的状态:' || x_return_status);  
  1463.               END IF;  
  1464.               IF x_return_status = fnd_api.G_RET_STS_SUCCESS THEN  
  1465.                 l_line_count := l_line_count + 1; --此次处理的总条数        
  1466.                 /*========================================================== 
  1467.                 * 30 验证数据有效性 
  1468.                 * ---------------------------------------------------------- 
  1469.                 * 描述:验证客户化表中的数据有效性,验证接口表中的数量是否 
  1470.                 *       等于物料搬运单的数量。并验证库存现用量和可用量。 
  1471.                 ============================================================*/  
  1472.                 IF l_mo_debug_falg = 'Y' THEN--输出调试信息  
  1473.                   put_log('----------------开始验证---------------------------');  
  1474.                 END IF;  
  1475.                 --验证数据的有效性,包括是否存在货位,物料可用量等信息  
  1476.                 validate_data(x_return_status        => x_return_status,  
  1477.                               x_msg_count            => x_msg_count,  
  1478.                               x_msg_data             => x_msg_data,  
  1479.                               p_trolin_rec           => x_trolin_rec,  
  1480.                               p_line_id              => rec_item_move_imp_line.line_id,  
  1481.                               p_transaction_quantity => rec_item_move_imp_line.transaction_quantity,  
  1482.                               p_transaction_date     => rec_item_move_imp_line.transaction_date);  
  1483.                 IF x_return_status <> fnd_api.G_RET_STS_SUCCESS THEN  
  1484.                   put_log('错误信息为:' || x_msg_data);  
  1485.                   --如果未通过验证,则结束本次循环  
  1486.                   GOTO line_end;  
  1487.                 END IF;  
  1488.                 IF l_mo_debug_falg = 'Y' THEN --输出调试信息  
  1489.                   put_log('---------------验证结束---------------------------');  
  1490.                 END IF;  
  1491.                 /*============================================================= 
  1492.                 * 40 在MMTT表中插入一条记录 
  1493.                 * ------------------------------------------------------------- 
  1494.                 * 描述:数据验证通过后,给MMTT表中的字段赋值,并 
  1495.                 *       在MMTT表中插入一条记录。 
  1496.                 ===============================================================*/  
  1497.                 IF l_mo_debug_falg = 'Y' THEN--输出调试信息  
  1498.                   put_log('---------------插入临时表MMTT表的一条记录开始---------------------------');  
  1499.                 END IF;  
  1500.                 --插入一条MMTT的记录  
  1501.                 insert_mmtt_row(x_return_status        => x_return_status,  
  1502.                                 x_transaction_temp_id  => x_transaction_temp_id,  
  1503.                                 p_trohdr_rec           => x_trohdr_rec,  
  1504.                                 p_trohdr_val_rec       => x_trohdr_val_rec,  
  1505.                                 p_trolin_tbl           => x_trolin_tbl,  
  1506.                                 p_trolin_val_tbl       => x_trolin_val_tbl,  
  1507.                                 p_header_id            => rec_item_move_imp_line.header_id,  
  1508.                                 p_line_id              => rec_item_move_imp_line.line_id,  
  1509.                                 p_transaction_quantity => rec_item_move_imp_line.transaction_quantity,  
  1510.                                 p_transaction_date     => rec_item_move_imp_line.transaction_date);  
  1511.                 IF l_mo_debug_falg = 'Y' THEN--输出调试信息                
  1512.                   put_log('---------------插入临时表MMTT表的一条记录:x_return_status:' ||  
  1513.                           x_return_status);  
  1514.                   put_log('---------------插入临时表MMTT表的一条记录结束---------------------------');  
  1515.                 END IF;  
  1516.                 /*=============================================================== 
  1517.                 * 50 自动处理物料搬运单 
  1518.                 * --------------------------------------------------------------- 
  1519.                 * 描述:调用API自动处理物料搬运单 
  1520.                 ================================================================*/  
  1521.                 IF x_return_status = fnd_api.G_RET_STS_SUCCESS THEN  
  1522.                   IF l_mo_debug_falg = 'Y' THEN--输出调试信息  
  1523.                     put_log('---------------自动处理物料搬运单开始---------------------------');  
  1524.                   END IF;  
  1525.                   --处理物料搬运单  
  1526.                   process_data(x_return_status => x_return_status,  
  1527.                                x_msg_count     => x_msg_count,  
  1528.                                x_msg_data      => x_msg_data,  
  1529.                                p_line_id       => rec_item_move_imp_line.line_id);  
  1530.                   IF l_mo_debug_falg = 'Y' THEN--输出调试信息              
  1531.                     put_log('---------------x_return_status:' ||  
  1532.                             x_return_status);  
  1533.                     put_log('---------------x_msg_count:' || x_msg_count);  
  1534.                     put_log('---------------x_msg_data:' || x_msg_data);  
  1535.                     put_log('---------------自动处理物料搬运单结束---------------------------');  
  1536.                   END IF;  
  1537.                 ELSE  
  1538.                   EXIT;  
  1539.                   put_log('错误信息为:' || x_msg_data);  
  1540.                   put_log('CUX:物料搬运单事务处理时,发生异常:' || SQLERRM);  
  1541.                 END IF;  
  1542.                 --本次循环结束标志  
  1543.                 <>  
  1544.               /*======================================================================== 
  1545.                 * 60 更新客户化表的状态和错误信息 
  1546.                 * ------------------------------------------------------------------------ 
  1547.                 * 描述:更新客户化表的状态:  
  1548.                 *       process_flag =0,表示为新的记录,需要进行处理。 
  1549.                 *       process_flag =1,表示正在处理 
  1550.                 *       process_flag =3,程序处理异常或者错误,并将错误信息赋值给error_message 
  1551.                 *       process_flag =4,表示处理成功。 
  1552.                 ========================================================================*/  
  1553.                 IF x_return_status = fnd_api.G_RET_STS_SUCCESS THEN --处理成功  
  1554.                   l_line_success_count := l_line_success_count + 1; --处理成功的记录  
  1555.                   --表示处理成功  
  1556.                   UPDATE cux_ediint_item_move_in ceimi  
  1557.                      SET ceimi.process_id        = 4, --表示处理成功  
  1558.                          ceimi.error_message     = NULL,  
  1559.                          ceimi.last_update_date  = SYSDATE,  
  1560.                          ceimi.last_updated_by   = fnd_global.user_id,  
  1561.                          ceimi.last_update_login = fnd_global.user_id  
  1562.                    WHERE ceimi.line_id = rec_item_move_imp_line.line_id;  
  1563.                 END IF;  
  1564.                 IF x_return_status = fnd_api.G_RET_STS_UNEXP_ERROR THEN--处理失败  
  1565.                   UPDATE cux_ediint_item_move_in ceimi  
  1566.                      SET ceimi.process_id        = 3, --程序出现异常  
  1567.                          ceimi.error_message     = TRIM(x_msg_data), --错误信息  
  1568.                          ceimi.last_update_date  = SYSDATE,  
  1569.                          ceimi.last_updated_by   = fnd_global.user_id,  
  1570.                          ceimi.last_update_login = fnd_global.user_id  
  1571.                    WHERE ceimi.line_id = rec_item_move_imp_line.line_id;  
  1572.                   --删除MMTT表中未被成功处理的记录   
  1573.                   delete_mmtt_row(x_return_status       => x_return_status,  
  1574.                                   p_line_id             => rec_item_move_imp_line.line_id,  
  1575.                                   p_transaction_temp_id => x_transaction_temp_id);  
  1576.                 END IF;  
  1577.               END IF;  
  1578.             ELSE--上次处理错误的记录被手工处理  
  1579.               l_line_count         := l_line_count + 1; --此次处理的总条数  
  1580.               l_line_success_count := l_line_success_count + 1; --处理成功的记录  
  1581.             END IF;  
  1582.             --一条物料搬运单行处理结束,进行事务处理的提交  
  1583.             COMMIT;  
  1584.           EXCEPTION --物料搬运行出现异常  
  1585.             WHEN OTHERS THEN  
  1586.               --如果此条记录出现异常,则回滚到SAVEPOINT cux_item_move_line  
  1587.               ROLLBACK TO cux_item_move_line;  
  1588.               put_log('处理物料搬运单行时,发生异常:' || SQLERRM);  
  1589.           END; --end begin    
  1590.         END LOOP; --FOR rec_item_move_imp_line IN cur_item_move_imp_line LOOP  
  1591.       ELSE  
  1592.         retcode := 1; --如果存在没有成功处理的物料搬运单,则显示警告  
  1593.         put_log('得到物料搬运单头时发生异常:' || x_msg_data);  
  1594.       END IF;  
  1595.     END LOOP; --FOR rec_item_move_imp_header IN cur_item_move_imp_header LOOP  
  1596.     --输出处理的信息(包括成功的信息和错误的信息)  
  1597.     IF l_mo_debug_falg = 'Y' THEN--输出调试信息  
  1598.       put_log('总行数:' || l_line_count);  
  1599.       put_log('处理成功的总行数:' || l_line_success_count);  
  1600.     END IF;  
  1601.     /*======================================================================== 
  1602.     * 70 输出处理结果 
  1603.     * ------------------------------------------------------------------------ 
  1604.     * 描述:处理物料搬运单的处理结果包括:  
  1605.     *       1.处理错误的记录 
  1606.     *       2.处理失败的记录及其错误信息 
  1607.     ========================================================================*/  
  1608.     output_move_order_info(p_line_count         => l_line_count,  
  1609.                            p_line_success_count => l_line_success_count);  
  1610.     IF (l_line_count <> 0) AND (l_line_count <> l_line_success_count) THEN--如果存在处理错误的信息,则请求显示警告  
  1611.       retcode := 1; --如果存在没有成功处理的物料搬运单,则显示警告  
  1612.     END IF;  
  1613.   EXCEPTION  
  1614.     WHEN OTHERS THEN  
  1615.       ROLLBACK;  
  1616.       retcode := 2;  
  1617.       put_log('错误信息为:' || x_msg_data);  
  1618.       put_log('CUX:物料搬运单事务处理时,发生异常:' || SQLERRM);  
  1619.   END main;  
  1620. END CUX_EDIINT_ITEM_MOVE_IN_PKG;  


来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/121967/viewspace-1970909/,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2011-03-09

  • 博文量
    77
  • 访问量
    186182