ORACLE存储过程中使用游标+BULK COLLECT的应用

经过半天的折腾，编译通过调试结果正确，掌握此过程中的知识点，oracle存储过程编写就应用到了90%。

CREATE OR REPLACE PROCEDURE JUNAN.P_IPT_QUOTN_INS (
--住院医嘱发药申请药品划价过程
writeId IN INT, --医嘱记录id
applyId IN INT, --发药申请id
operateId IN INT, --操作员id
exprdate IN INT, --减少库存时批次：0不控制效期,1控制效期
amount OUT NUMBER, --划价后得到的药品金额
mess OUT VARCHAR2 --OK为执行成功
)
IS
--本组变量保存医嘱信息
ow_drugId VARCHAR2(30); --药品id
ow_drugName VARCHAR2(120); --药品名称
ow_drugTypeId VARCHAR2(30); --药品类别id
ow_unitName VARCHAR2(30); --药品单位名称
ow_unitId NUMBER(12,0); --药品包装单位id
ow_count NUMBER(12,4); --药品数量
ow_baseCount NUMBER(12,4); --按基本单位算的药品数量
ow_status VARCHAR2(4); --医嘱状态
ow_deptId NUMBER(12,0); --药房id
ow_hosId NUMBER(12,0); --医院id
ow_relation NUMBER(12,6); --药品包装单位换算比
--本组变量保存临时库存批次信息
st_rowid ROWID; --库存批次表行系统rowid
st_id INT; --库存游标保存变量 库存记录id
st_unitId INT;  --库存包装单位id
st_relation NUMBER(22,6);  --换算比
st_count NUMBER(22,4);  --库存数量
st_price NUMBER(22,6);  --药房包装单位的零售价格
st_cost_price NUMBER(22,6);  --药房包装单位的成本价格
--其他变量
per_quantity NUMBER(22,4) :=0;  --每次库存循环处理数量
per_basequantity NUMBER(22,4) :=0;  --每次库存循环处理基本单位数量
per_amount NUMBER(22,2) :=0; --每次库存循环处理金额
total_quantity NUMBER(22,4) :=0;  --累计数量
total_amount NUMBER(22,2) :=0; --累计金额
operateName VARCHAR2(60); --操作员姓名
--库存处理游标
CURSOR cur_stock IS
  SELECT ROWID AS ROW_ID FROM T_DRUGSTORE_DRUG_STOCK_TEMP T
  WHERE T.STATUS = '1' AND T.BATCH_INVALID = '1'
    AND (CASE WHEN exprdate=1 THEN T.EXPIRATION_DATE ELSE TO_DATE('9999-12-31','YYYY-MM-dd') END) >= trunc(sysdate)
    AND T.QUANTITY > 0 AND T.DEPT_ID=ow_deptId AND T.DRUG_ID =ow_drugId
  order by EXPIRATION_DATE;
TYPE TP_TABLE_STOCK IS TABLE OF CUR_STOCK%ROWTYPE; --声明游标行类型的数据集类型
cllo_stock TP_TABLE_STOCK; --集合类型变量
BEGIN
mess:='';
--取得医嘱信息
  BEGIN
    SELECT DOCTOR_ORDER_ID,DOCTOR_ORDER_NAME,DRUG_COUNT,DRUG_COUNT_UNIT,DRUG_UNIT_ID,ORDER_STATUS_ID,EXECUTIVE_SECTION_ID,HOSPITAL_ID
     INTO ow_drugId,ow_drugName,ow_count,ow_unitName,ow_unitId,ow_status,ow_deptId,ow_hosId
     FROM T_IPT_DOCTOR_ORDER_WRITE WHERE DOCTOR_ORDER_TYPE_ID='drug' AND id=writeId FOR UPDATE NOWAIT;
  EXCEPTION WHEN NO_DATA_FOUND THEN
    mess:='住院医嘱记录不存在!';
    RETURN;
  END;
--取得医嘱药品包装单位换算比,药品类别id
  BEGIN
    SELECT a.RELATION,b.DRUG_TYPE_ID INTO ow_relation,ow_drugTypeId from T_PHARMACY_DRUG_PACKAGE a
    INNER JOIN T_PHARMACY_DRUG b ON b.ID=A.DRUG_ID
    WHERE ROWNUM=1 and a.STATUS='1' and a.ID=ow_unitId;
  EXCEPTION WHEN NO_DATA_FOUND THEN
    mess:='查询药品包装单位换算比无数据!';
    RETURN;
  END;
  IF ow_relation IS NULL THEN
    mess:='药品包装单位换算比为null!';
    RETURN;
  END IF;
--取操作员信息
  BEGIN
    SELECT name INTO operateName FROM T_SYS_OPERATOR WHERE id=operateId;
  EXCEPTION WHEN NO_DATA_FOUND THEN
    mess:='操作员记录不存在!';
    RETURN;
  END;
--换算医嘱药品数量为基本单位数量
ow_baseCount:=ROUND(ow_count*ow_relation,4);
--打开动态游标,将临时库存中本药品有效批次库存的行id保存用于后续扣减处理
open cur_stock;
LOOP
--遍历库存记录进行库存处理
  FETCH CUR_STOCK BULK COLLECT INTO cllo_stock LIMIT 200;
  EXIT WHEN cllo_stock.COUNT=0;
  FOR i IN cllo_stock.FIRST..cllo_stock.LAST
  LOOP
    st_rowid:=cllo_stock(i).ROW_ID;
    --取得当前id批次库存信息并锁定
    BEGIN
      SELECT ID,NEW_MAX_PACKAGE_UNIT_ID,RELATION,QUANTITY,DRUGSTORE_RETAIL_PRICE,ROUND(PURCHASE_PRICE/RELATION_MAX,6)
        INTO st_id,st_unitId,st_relation,st_count,st_price,st_cost_price 
        FROM T_DRUGSTORE_DRUG_STOCK_TEMP WHERE QUANTITY > 0 AND ROWID=st_rowid FOR UPDATE;
    EXCEPTION WHEN NO_DATA_FOUND THEN
      CONTINUE;
    END;
    --计算本批次扣减库存数量：批次库存小于等于待出库数量时取本批结余数，否则用待出库数
    per_basequantity:=(CASE WHEN st_count<=ow_baseCount THEN st_count ELSE ow_baseCount END);
    per_quantity:=ROUND(per_basequantity/ow_relation,4); --计算医嘱保装单位的数量
    --计算销售金额
    PER_AMOUNT:=ROUND(per_basequantity/st_relation*st_price,2);
    --更新本批次结存数量
    UPDATE T_DRUGSTORE_DRUG_STOCK_TEMP SET QUANTITY=QUANTITY-per_basequantity,UPDATE_OPER=operateId,UPDATE_DATE=SYSDATE
      WHERE QUANTITY>=per_basequantity AND ROWID=st_rowid;
    IF SQL%ROWCOUNT<1 THEN
      mess:='扣减临时库存更新了0行,库存记录id:'||st_id;
      GOTO ExitMidway;
    END IF;
    --写入药品划价记录
    st_cost_price:=st_cost_price*ow_relation/st_relation; --计算成本单据,防止医嘱单位和药房单位不一致
    INSERT INTO T_IPT_QUOTN (
    ID, HOSPITAL_ID, DEPT_ID, ORDER_WRITE_ID, APPLY_ID,STOCK_ID, DRUG_ID, UNIT_NAME,
    QUANTITY,BASE_QUANTITY, PRICE, AMOUNT,
    COST_PRICE,COST_AMOUNT,RETURN_QUANTITY,CREATE_TIME,CREATE_OPER)
    VALUES (SEQ_IPT_QUOTN.NEXTVAL,OW_HOSID,OW_DEPTID,writeId,applyId,ST_ID,OW_DRUGID,OW_UNITNAME,
      per_quantity,per_basequantity,ROUND(PER_AMOUNT/per_quantity,4),PER_AMOUNT,
      st_cost_price,ROUND(per_quantity*st_cost_price,2),0,SYSDATE,operateName);
    --更新累计出库数量和金额，待出库基本单位数量
    TOTAL_QUANTITY:=TOTAL_QUANTITY+per_basequantity;
    TOTAL_AMOUNT:=TOTAL_AMOUNT+PER_AMOUNT;
    ow_baseCount:=ow_baseCount-per_basequantity;
    --库存数量足额扣减退出循环
    EXIT WHEN ow_baseCount=0;
  END LOOP;
  EXIT WHEN ow_baseCount=0;
END LOOP;
CLOSE CUR_STOCK;
--循环结束判断待出库数量如果为非零,则说明不足出库
IF ow_baseCount!=0 THEN    
  mess:='临时库存不足,待扣减基本单位数量:'||ow_baseCount;
  RETURN;
END IF;
--更新医嘱药品费用金额
UPDATE T_IPT_DOCTOR_ORDER_WRITE SET SUM_PRICE=TOTAL_AMOUNT,
  PRICE=(CASE WHEN DRUG_COUNT=0 THEN 0 ELSE ROUND(TOTAL_AMOUNT/DRUG_COUNT,4) END),UPDATE_DATE=SYSDATE
  WHERE id=writeId;
amount:=TOTAL_AMOUNT;
mess:='OK';
RETURN;
<<ExitMidway>>
  CLOSE CUR_STOCK;
  RETURN;
EXCEPTION
  WHEN NO_DATA_FOUND THEN
    mess:='查询记录数据为空!';
  WHEN OTHERS THEN
    mess := SUBSTR(SQLERRM,1,2000);
END P_IPT_QUOTN_INS;
/