DB2存储过程例子

zhangbinmy

　　CREATE PROCEDURE IPD.st_inter_PROF ( IN in_Transfer_id dec(6,0),
                                     IN in_TRANS_TYPE_id dec(2,0),
                                     IN in_begin_date timestamp,
                                     IN in_TRANSFER_name varchar(1024),
                                     OUT o_err_no int,
                                     OUT o_err_msg varchar(1024) )
    LANGUAGE SQL
------------------------------------------------------------------------
-- SQL 存储过程  
------------------------------------------------------------------
--                                         --
--                                                               --
--              抽取acct_item_billingday,acct_item表             --
--              author :zsk   2002/06/27                         --
--              update   by zsk    at  2002/11/25  as  SZ        --
--              move from oracle to db2 by dengl 2002-12-8 as sz --
--              返回值结果：0：执行通过                          --
--                         1：执行不通过                         --
--                        -1：调用本过程时异常出错               --
--              联合体用户是 ADMINISTRATOR  BILL.BILL.* /BILL.CAL.* --
-------------------------------------------------------------------
------------------------------------------------------------------------
P1: BEGIN
      --临时变量出错变量
       declare rec              integer default 0;
       declare SQLCODE          integer default 0;
       declare stmt             varchar(1024);
       declare at_end           integer default 0;
       declare r_code           integer default 0;   
       declare state            varchar(1024) default 'AAA';--记录程序当前所作工作
       declare temp_int         integer default 0;
      --声明变量
       declare v_cycle_str   varchar(1000);
       declare v_sql_str     varchar(2000);
       declare n_num         bigint;
       declare n_rows        bigint;
       declare n_rows_all    bigint;

      --声明放游标的值
        
     --声明动态游标存储变量
        declare c_bill_task_id  integer;
         declare bill_task cursor for s1;
         

      --声明出错处理
        DECLARE EXIT HANDLER FOR SQLEXCEPTION  
          begin
             set r_code=SQLCODE;
             set o_err_no=1;
             set o_err_msg='处理'||state||'出错 '||'错误代码SQLCODE:'||CHAR(r_code);
          end;     
        DECLARE continue HANDLER for not found   
           begin
              SET at_end = 1;
              set o_err_no=100;
           end;

       --开始拉
       select  deal_cycle
       into  v_cycle_str
       from  ipd.transfer_task
       where transfer_id=in_transfer_Id;
       --v_cycle_str:='%'||v_cycle_str;

        if  in_trans_type_id=7
          then   
             set n_num=1;

             ---将汇总数据写入任务表

             update ipd.transfer_task
              set    rows_cnt=0
             where  transfer_id=in_transfer_id;
            
              --声明动态游标
             set stmt=' select  distinct bill_task_id  from  ADMINISTRATOR.bill_task_cycle a , ADMINISTRATOR.billing_cycle b where substr(char(b.CYCLE_BEGIN_DATE),1,4)||substr(char(b.CYCLE_BEGIN_DATE),6,2)='||char((integer(v_cycle_str)-1))||' and   a.billing_cycle_id=b.billing_cycle_id';  
             prepare s1 from stmt;
            -- execute s1;
            
             open bill_task; --using v_cycle_str;
          --声明完毕
             fetch_loop1:
             loop
                 fetch bill_task into c_bill_task_id   ;
  
         --由于db2和oracle的不同,db2必须先创建一个oracle相连的别名ADMINISTRATOR.*,而不像oracle直接用@to_jif 下面是oracl的源码
         --  v_sql_str:=' update transfer_task
         --                  set  rows_cnt=rows_cnt+(select count(*)
         --                                          from cal.acct_item_billingday_'||rec.bill_task_id||'@to_jf)
         --                  where transfer_id='||in_transfer_id;
         --update by dengl 2002-12-08
         
                set stmt='create nickname ADMINISTRATOR.ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id)||' for bill.cal.acct_item_billingday_'||char(c_bill_task_id);
        
          --记录
               set state='创建别名'||'ADMINISTRATOR.ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id);
               call ipd.sp_exec_dsql(stmt,o_err_no);
        
             --o_err_no 是返回的SQLCODE
               if o_err_no<>0
                 then  
                       update ipd.transfer_task
                       set    deal_flag=-1
                       where  transfer_id=in_transfer_id;
                       set o_err_msg='处理'||state||'出错 '||'错误代码SQLCODE:'||CHAR(o_err_no);  
                       set o_err_no=1;
                       return 0;
               end if;
               set v_sql_str=' update ipd.transfer_task set  rows_cnt=rows_cnt+(select count(*)  from '||'ADMINISTRATOR.ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id)||'    where transfer_id='||char(in_transfer_id);
         
               call ipd.sp_exec_dsql(v_sql_str,o_err_no);  
               if  o_err_no <> 0  
                  then
                     update ipd.transfer_task
                     set    deal_flag=-1
                     where  transfer_id=in_transfer_id;
                     set o_err_msg=char(in_TRANS_TYPE_id)||'传送出错！SQLCODE:'||char(o_err_no);
                     set o_err_no=1;
                     return 0;
               end if ;
               commit;
             end loop fetch_loop1;
             close bill_task;
--汇总数据写入完毕

--建立接口表并插入数据

       ---整理表空间。
             call ipd.bi_settle_tablespace(in_Transfer_id,
                             o_err_no,
                             o_err_msg);--调用此过程，检测表空间
              --返回值不为0，则不执行返回
             set state='整理表空间';
             if o_err_no<>0  
                 then
                    update ipd.TRANSFER_TASK
                    set    DEAL_FLAG=-1
                    where  Transfer_id=in_Transfer_id;
                    commit;  
                    set o_err_msg='处理'||state||'出错 '||'错误代码SQLCODE:'||CHAR(o_err_no);  
                    set o_err_no=1;   
                    return 0;
             end if;

              --创建任务需要的接口表 并把多个表的数据整合到一个表中去,如果是oracle就要使用零时表而db2用别名就代替了
             set stmt='create table ipd.'||in_TRANSFER_name;
             call ipd.sp_exec_dsql(stmt,o_err_no);
             set state='创建接口表ipd.'||in_TRANSFER_name;
             if o_err_no<>0
                 then  
                    update ipd.TRANSFER_TASK
                    set    DEAL_FLAG=-1
                    where  Transfer_id=in_Transfer_id;
                    commit;
                    set o_err_msg='处理'||state||'出错 '||'错误代码SQLCODE:'||CHAR(o_err_no);  
                    set o_err_no=1;   
                    return 0;     
             end if;
         
            --建表完毕开始组合sql语句

             open bill_task using v_cycle_str;
             fetch_loop2:
             loop
                fetch bill_task into c_bill_task_id;  
                if n_num=1  
                    then
                      set  v_sql_str='inter into ipd.'||in_TRANSFER_name||' select * from ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id);
                    else
                      set v_sql_str=v_sql_str||'   union select * from ADMINISTRATOR.ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id);
                end if;
                set n_num=n_num+1;
             end loop fetch_loop2;
         
             --组合完毕
         
             --  set v_sql_str:=v_sql_str||'   )';
             set state='向接口表ipd.'||in_TRANSFER_name||'插入数据';
             call ipd.sp_exec_dsql(v_sql_str,o_err_no);
             if o_err_no<>0
                     then  
                         update ipd.TRANSFER_TASK
                         set    DEAL_FLAG=-1
                         where  Transfer_id=in_Transfer_id;
                         commit;
                         set o_err_msg='处理'||state||'出错 '||'错误代码SQLCODE:'||CHAR(o_err_no);  
                         set o_err_no=1;   
                         return 0;  
                     else  
                         update  transfer_task
                         set     deal_flag=2
                         where   transfer_id=in_transfer_id;
                         set o_err_no=0;
                         set o_err_msg=o_err_msg||'任务号为'||char(in_TRANSFER_id)||'抽取成功！';
             end if;
             commit;
              --数据插入完毕

              --删除联合体的别名
             open bill_task using v_cycle_str;
             fetch_loop3:
             loop
                 set stmt='drop  nickname ADMINISTRATOR.ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id)||' for bill.cal.acct_item_billingday_'||char(c_bill_task_id);
        
                 --记录
                 set state='删除别名'||'ADMINISTRATOR.ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id);
                 call ipd.sp_exec_dsql(stmt,o_err_no);
                  --o_err_no 是返回的SQLCODE
                 if o_err_no<>0
                    then  
                        update ipd.transfer_task
                        set    deal_flag=-1
                        where  transfer_id=in_transfer_id;
                        set o_err_msg='处理'||state||'出错 '||'错误代码SQLCODE:'||CHAR(o_err_no);  
                        set o_err_no=1;
                        return 0;
                 end if;   
             end loop fetch_loop3;


           -----下账数据接口        
         
            
           else if in_trans_type_id =8  
                   then
                     --帐务表的联合体别名已经建好了

                      set v_sql_str='update ipd.transfer_task set rows_cnt=(select count(*) from   ADMINISTRATOR.acct_item  a , ADMINISTRATOR.billing_cycle b  where a.billing_cycle_id=b.billing_cycle_id  and     substr(char(b.CYCLE_BEGIN_DATE),1,4)||substr(char(b.CYCLE_BEGIN_DATE),6,2)= '''||upper(char(v_cycle_str))||''' ) where Transfer_id='||char(in_Transfer_id);
                      set state='汇总acct_item数据 ';
                      call ipd.sp_exec_dsql(v_sql_str,o_err_no);
                      if  o_err_no <> 0  
                         then
                             update ipd.transfer_task
                             set   deal_flag=-1
                             where transfer_id=in_transfer_id;
                             set o_err_no=1;
                             set o_err_msg=state||char(in_TRANS_TYPE_id)||'传送出错！';
                         return 0;
                      end if;  
                      --整理表空间。
                      call ipd.bi_settle_tablespace(in_Transfer_id,
                                 o_err_no,
                                 o_err_msg);--调用此过程，检测表空间
                        --返回值不为0，则不执行返回
                      set state='为acct_item整理表空间';
                       if o_err_no<>0  
                         then
                             update ipd.TRANSFER_TASK
                             set    DEAL_FLAG=-1
                             where  Transfer_id=in_Transfer_id;
                             set o_err_msg=state||'任务号'||char(in_TRANS_TYPE_id)||'传送出错！SQLCODE:'||char(o_err_no);
                             set   o_err_no=1;        
                             commit;
                             return 0;
                         end if;
                      --在任务表中将状态改为1，准备传送数据.
                      update ipd.TRANSFER_TASK
                      set    DEAL_FLAG=1
                      where  Transfer_id=in_Transfer_id;
                      commit;
                      set v_sql_str='create table ipd.'||in_TRANSFER_name||' like ADMINISTRATOR.ACCT_item)';
                      call ipd.sp_exec_dsql(v_sql_str,o_err_no);
                      set stmt='inset into ipd.'||in_TRANSFER_name||'  select  ACCT_ITEM_ID,SERV_ID,SERV_SEQ_NBR,EXT_SERV_ID, ACCT_ID,ACCT_SEQ_NBR,ACCT_ITEM_TYPE_ID,CHARGE,BILLING_CYCLE_ID,CREATED_DATE,PARTNER_ID,BILL_SERIAL_NBR,STATE,STATE_DATE, EXCHANGE_ID, PAYMENT_METHOD from ADMINISTRATOR.acct_item  where billing_cycle_id like  '''||upper(v_cycle_str)||'''';
                      call ipd.sp_exec_dsql(stmt,o_err_no);
                      set state='插入数据到ipd.'||in_TRANSFER_name;
                      if  o_err_no = 0  
                        then
                            update  transfer_task
                            set     deal_flag=2
                            where   transfer_id=in_transfer_id;
                            set o_err_no=0;
                        else
                            update transfer_task
                            set    deal_flag=-1
                            where  transfer_id=in_transfer_id;
                            set   o_err_msg=state||'任务号'||char(in_TRANS_TYPE_id)||'传送出错！SQLCODE:'||char(o_err_no);
                            set   o_err_no=1;  
                     end if ;
                    commit;
             end if;--下帐数据完毕
         end  if;
         set temp_int=0;
         call ipd.bi_check(in_transfer_id,
              in_transfer_name,
              temp_int,
              o_err_no,
              o_err_msg);
END P1
　　例子二：
　　DB2存储过程例子！
关键字: db2
CREATE PROCEDURE  KJZB.ZQINVEST_JT(out returnCode Integer,out
errorMsg varchar(255))
LANGUAGE SQL
BEGIN
    declare sql_code integer default 0;
    declare SQLSTATE char(5) default '00000';
    declare SQLCODE integer default 0;
    declare sqlMsg varchar(200) default '';
    declare stmt varchar(1024);
　　declare vCurdate    varchar(20);                   -- 当天日期
    declare vCurYMd     varchar(6);                    -- 当天所在的年月
    declare vCurDay  varchar(2) ;                         --所在天
    declare maxday      integer default 30;            -- 每个月按30天算
    declare fday         integer;                      -- 实际天数
    declare lastday      integer;                      -- 到期日的天数
    declare firstday     integer;                      -- 购买月的天数
    declare firstmonth   integer;                      -- 购买的月份
    declare lastmonth    integer;                      -- 到期日的月份
    declare firstyear    integer;                      -- 购买日的年份
    declare lastyear     integer;                      -- 到期年份
    declare disday       integer;                      -- 间隔天数
    declare dismonth     integer;                      -- 间隔月份
    declare disyear      integer;                      -- 间隔年份
    declare vLsh         varchar(32);                  -- 流水号
    declare vjgh         varchar(8);                    -- 机构码
    declare ywzh       varchar(32);                     -- 业务帐号
    declare vzh         varchar(32);                     -- 投资账号
    declare vJgbm       varchar(8) default '32022300';   -- 投资帐号对应的机构(默认为清算中心)
    declare vDfJgbm     varchar(8);                      -- 对方机构号
    declare gmrq        varchar(8);                      -- 购买日期
    declare dqrq        varchar(8);                      -- 到期日期
    declare zqpz        varchar(1);                      -- 债券品种
    declare hth         varchar(16);                     -- 合同号
    declare fxfs        varchar(1);                      -- 付息方式
    declare ywlx        varchar(3) default '888';        -- 业务类型(默认业务类型 888)
    declare tzqx        varchar(1);                      -- 投资期限
    declare ysjlxkmkzz  varchar(7);                      -- 应收(计)利息科目控制字
    declare tzsykmmkzz  varchar(7);                      -- 投资收益科目控制字
    declare yjkmkzz     varchar(7) default '142112';     -- 溢价科目控制字 长期投资(溢价142112)
    declare zjkmkzz     varchar(7) default '142113';     -- 折价科目控制字 长期投资(折价142113)
    declare fykmkzz     varchar(7) default '142111';     -- 相关费用科目控制字 长期投资(相关费用 142111)
    declare zid         varchar(32) default '0';         -- id 债券投资ID
    declare vId         varchar(32);                     -- id 债券流水ID
    declare yslx        double;                       -- 应收利息 (面值 * 票面利率 (年) /360 * 当月实际天数)
    declare yjlx        double;                       -- 应计利息 (面值 * 票面利率 (年) /360 * 当月实际天数)
    declare ysjlx       double;                       -- 应收计利息
    declare pmje        double;                       -- 票面金额
    declare pmll        double;                       -- 票面利率
    declare tzsy        DECIMAL(12, 2);                -- 投资收益       ( 应收(计)利息 - 每月摊销的溢价 - 每月摊销相关费用 )
    declare txyj        double;                       -- 月摊销溢价     ( 溢价/(到期日 - 购买日 + 1) * 当月实际天数 )
    declare txzj        double;                       -- 月摊销折价     ( 折价/(到期日 - 购买日 + 1) * 当月实际天数 )
    declare txfy        double;                       -- 月摊销费用     (相关费用)/(到期日 - 购买日 + 1) * 当月实际天数
    declare yj          double default 0.0;           -- 溢价
    declare zj          double default 0.0;           -- 折价
    declare fy          double default 0.0;           -- 相关费用
　　declare zqtz cursor for s1;
    -- 声明异常
    DECLARE CONTINUE HANDLER FOR NOT FOUND,SQLEXCEPTION,SQLWARNING
    begin
       set sql_code   = SQLCODE;
       set returnCode = sql_code;
    end;
　　set vCurdate = (select char(current_date) from sysibm.sysdummy1);
    set vCurdate = replace(vCurdate,'-','');
    set vCurYMd  = substr(vCurdate,1,6);
    set vCurDay  = substr(vCurdate,7,2);
　　-- 读取还没到期的长期债券投资信息
   set  stmt = ' select JGBM,ZH,HTH,ZQPZ,PMJE,LL,GMRQ,DQR,YSLX,YJLX,YJ,ZJ,FY,FXFS,id,cast(substr(GMRQ,7,2) as integer),cast(substr(DQR,7,2) as integer),cast(substr(GMRQ,5,2) as integer),cast(substr(DQR,5,2) as integer),cast(substr(GMRQ,1,4) as integer),cast(substr(DQR,1,4) as integer)  from kjzb.zqinvest where substr(dqr,1,6) >=''' ||  vCurYMd  || ''' and tzqx = ''2'' and tzzt <> ''2''';
   prepare s1 from stmt;
　　open zqtz;
    fetch zqtz into vDfJgbm,vzh,hth,zqpz,pmje,pmll,gmrq,dqrq,yslx,yjlx,yj,zj,fy,fxfs,zid,firstday,lastday,firstmonth,lastmonth,firstyear,lastyear;
    while sql_code <> 100 do
        -- 如果是31日购买的，第一个月不计提
        if ( firstday = 31 and substr(gmrq,1,6) = vCurYMd ) then
            goto EXIT;
        end if;
　　-- 如果是01日到期的，最后一个月不计提
if ( lastday = 1 and substr(dqrq,1,6) = vCurYMd ) then
    goto EXIT;
end if;
　　-- 间隔年份
        if ( firstyear = lastyear ) then
            set disyear = 0;
        else
            set disyear = lastyear - firstyear - 1;
        end if;
　　-- 同年
        if ( disyear = 0 ) then
            -- 下个月或同月(业务逻辑上不会发生，但程序上要判断防止业务人员误操作)
            if ( lastmonth - firstmonth <= 1 ) then
            set dismonth = 0;
            else
                set dismonth = lastmonth - firstmonth - 1;
            end if;
        else
            -- 不在同一年，间隔月份 = 第一年的月份 + 中间年的月份 + 最后一年的月份
            set dismonth = ( 12 - firstmonth ) + ( disyear * 12 ) + ( lastmonth - 1 ) ;
        end if;
　　-- 初始化摊销溢价、摊销折价、摊销费用
        set txyj = 0.0;
        set txzj = 0.0;
        set txfy = 0.0;
     if  fxfs  = '5'  then                              -- 根据付息方式来计应计利息还是应收利息科目控制字
      if zqpz = '1' then
      set ysjlxkmkzz = '142107';               -- 应计利息 国债     142107
      set tzsykmmkzz = '514111';               -- 投资收益（债券利息收入-国债利息收入）   514111
      end if;
      if zqpz = '2' then
      set ysjlxkmkzz = '142108';               -- 应计利息 金融债   142108
      set tzsykmmkzz = '514112';               -- 投资收益(债券利息收入-金融债券利息收入) 514112
      end if;
      if zqpz = '3' then
      set ysjlxkmkzz = '142109';            -- 应计利息 公司债   142109
      set tzsykmmkzz = '514113';               -- 债券利息收入-企业债券利息收入 514113
      end if;
      if zqpz = '4' then
      set ysjlxkmkzz = '142110';            -- 应计利息 其他债券 142110
      set tzsykmmkzz = '514114';               -- 债券利息收入-其他债券利息收入   514114
      end if;
   else
       if zqpz = '1' then
      set ysjlxkmkzz = '132102';               -- 应收利息 国债     132102
      set tzsykmmkzz = '514111';               -- 投资收益（债券利息收入-国债利息收入）   514111
      end if;
      if zqpz = '2' then
      set ysjlxkmkzz = '132103';               -- 应收利息 金融债   132103
      set tzsykmmkzz = '514112';               -- 投资收益(债券利息收入-金融债券利息收入) 514112     
      end if;
      if zqpz = '3' then
      set ysjlxkmkzz = '132104';            -- 应收利息 公司债   132104
       set tzsykmmkzz = '514113';               -- 债券利息收入-企业债券利息收入 514113    
      end if;
      if zqpz = '4' then
      set ysjlxkmkzz = '132105';            -- 应收利息 其他债券 132105
      set tzsykmmkzz = '514114';               -- 债券利息收入-其他债券利息收入   514114
      end if;      
   end if;
 
   if ( substr(dqrq,1,6) = vCurYMd ) then           -- 最后一个月计提
       set fday = lastday - 1;
   else
       if ( substr(gmrq,1,6) = vCurYMd ) then       -- 第一个月计提
   set fday = 30 - firstday + 1;
       else
       set fday = maxday;                        -- 平常按30天算
       end if;
   end if;
　　-- 实际天数 = 第一个月的天数 + 间隔月份 * 30 + 最后一个月的天数(到期日不算)
        set disday =  ( 30 - firstday + 1) + ( dismonth * 30 ) + ( lastday - 1 ); 
  
        --  记提公式:面值*票面利率(年)/ 360*当月实际天数
        set ysjlx = pmje * (pmll / 100) /360 * fday;
　　
        -- 投资收益公式 : 应收（计）利息 ( + 月摊销折价）— 月摊销溢价 - 月摊销费用
        set tzsy = ysjlx;
　　
        -- 设计思想为如果有溢价，则应该没有折价
       if yj <> 0.0 then
           set txyj = yj /disday * fday;
           set tzsy = tzsy - txyj;
       else
           if zj <> 0.0 then
set txzj = zj/disday* fday;
set tzsy = tzsy + txzj;     
           end if;
       end if;
      
       if fy <> 0.0 then
           set txfy = fy /disday * fday;
           set tzsy = tzsy - txfy;
       end if;
　　
        --借: 1321 应收利息[按月计提金额]
   set vId =  kjzb.getvId();
   set vLsh = kjzb.getLsh(32);                       -- 获取流水号
        set vjgh = kjzb.getJgh(vzh);                      -- 获取机构号
        set ywzh = kjzb.getZh(vjgh,ysjlxkmkzz);           -- 应收(计)利息账号
　　if ywzh is null then
               set sqlMsg = '债券记提走帐时找不到指定机构['||vjgh||']和科目控制字为['|| ysjlxkmkzz ||']的帐号';
               set errorMsg =  sqlMsg;
               goto ERROR_RETURN;
        end if;
　　insert into kjzb.FLLSB values(vId,vJgbm,ysjlxkmkzz,vLsh,hth,ywzh,'借',ysjlx,'','0000',vCurdate,ywlx);
　　if sql_code <> 0 then
           set sqlMsg = '债券走帐插入会计分录出错';
           set errorMsg =  sqlMsg;
           goto ERROR_RETURN;
        end if;
  
   -- 借: 1421 长期投资(折价)[按月计提金额]
   if zj <> 0.0 then
      set vId =  kjzb.getvId();
           set ywzh = kjzb.getZh(vjgh,zjkmkzz);          -- 长期投资(折价)账号
　　if ywzh is null then
       set sqlMsg = '债券记提走帐时找不到指定机构['||vjgh||']和科目控制字为['|| zjkmkzz ||']的帐号';
       set errorMsg =  sqlMsg;
       goto ERROR_RETURN;
   end if;
　　insert into kjzb.FLLSB values(vId,vJgbm,zjkmkzz,vLsh,hth,ywzh,'借',txzj,'','0000',vCurdate,ywlx);
           if sql_code <> 0 then
             set sqlMsg = '债券走帐插入会计分录出错';
             set errorMsg =  sqlMsg;
             goto ERROR_RETURN;
           end if;
   end if;
  
        -- 贷: 5141 投资收益  应收（计）利息-每月摊消的溢价-每月摊消相关费用
   set vId =  kjzb.getvId();
        set ywzh = kjzb.getZh(vjgh,tzsykmmkzz);           -- 投资收益账号
　　if ywzh is null then
    set sqlMsg = '债券记提走帐时找不到指定机构['||vjgh||']和科目控制字为['|| tzsykmmkzz ||']的帐号';
    set errorMsg =  sqlMsg;
    goto ERROR_RETURN;
end if;
　　insert into kjzb.FLLSB values(vId,vJgbm,tzsykmmkzz,vLsh,hth,ywzh,'贷',tzsy,'','0000',vCurdate,ywlx);
        if sql_code <> 0 then
           set sqlMsg = '债券走帐插入会计分录出错';
           set errorMsg =  sqlMsg;
           goto ERROR_RETURN;
        end if;
　　-- 贷: 1421 长期投资(溢价)[按月摊消]每月摊消的溢价(溢价/(到期日-购买日+1) *当月实际天数)
        if yj <> 0.0 then
      set vId =  kjzb.getvId();
        set ywzh = kjzb.getZh(vjgh,yjkmkzz);              -- 长期投资(溢价)账号
　　if ywzh is null then
    set sqlMsg = '债券记提走帐时找不到指定机构['||vjgh||']和科目控制字为['|| yjkmkzz ||']的帐号';
    set errorMsg =  sqlMsg;
    goto ERROR_RETURN;
end if;
　　insert into kjzb.FLLSB values(vId,vJgbm,yjkmkzz,vLsh,hth,ywzh,'贷',txyj,'','0000',vCurdate,ywlx);
        if sql_code <> 0 then
           set sqlMsg = '债券走帐插入会计分录出错';
           set errorMsg =  sqlMsg;
           goto ERROR_RETURN;
        end if;
        end if;
　　-- 贷: 1421 长期投资(相关费用)[按月摊消金额] 每月摊消相关费用(相关费用/(到期日-购买日+1) *当月实际天数)
        if (fy <> 0.0)   then
        set vId =  kjzb.getvId();
        set ywzh = kjzb.getZh(vjgh,fykmkzz);              -- 长期投资(相关费用)账号
　　if ywzh is null then
    set sqlMsg = '债券记提走帐时找不到指定机构['||vjgh||']和科目控制字为['|| fykmkzz ||']的帐号';
    set errorMsg =  sqlMsg;
    goto ERROR_RETURN;
end if;
　　insert into kjzb.FLLSB values(vId,vJgbm,yjkmkzz,vLsh,hth,ywzh,'贷',txfy,'','0000',vCurdate,ywlx);
        if sql_code <> 0 then
           set sqlMsg = '债券走帐插入会计分录出错';
           set errorMsg =  sqlMsg;
           goto ERROR_RETURN;
       end if;
        end if;
  
   -- 对 kjzb.zqinvest 表的以下字段进行更新
   -- yjtyjlx 【已计提应计利息】
        -- yjtyslx 【已计提应收利息】
        -- ytxyj   【已摊销溢价】
        -- ytxzj   【已摊销折价】
        -- ytxfy   【已摊销费用】
   if fxfs = '5' then
            update kjzb.zqinvest set yjtyjlx = yjtyjlx + ysjlx,ytxyj = ytxyj + txyj,ytxzj = ytxzj + txzj,ytxfy = ytxfy + txfy where id = zid;
            if sql_code <> 0 then
        set sqlMsg = '债券走帐时更新表出错';
        set errorMsg =  sqlMsg;
        goto ERROR_RETURN;
           end if;
        else
            update kjzb.zqinvest set yjtyslx = yjtyslx + ysjlx,ytxyj = ytxyj + txyj,ytxzj = ytxzj + txzj,ytxfy = ytxfy + txfy where id = zid;
            if sql_code <> 0 then
        set sqlMsg = '债券走帐时更新表出错';
        set errorMsg =  sqlMsg;
        goto ERROR_RETURN;
           end if;
       end if;
  
        EXIT:
         fetch zqtz into vDfJgbm,vzh,hth,zqpz,pmje,pmll,gmrq,dqrq,yslx,yjlx,yj,zj,fy,fxfs,zid,firstday,lastday,firstmonth,lastmonth,firstyear,lastyear;
　　end while;
　　close zqtz;                                    -- 关闭游标
　　COMMIT;
    set sqlMsg   = '债券投资自动计提成功!';
    set errorMsg =  sqlMsg;
    set sql_code = 0;
    set returnCode = sql_code;
    return 1;
　　ERROR_RETURN:
        ROLLBACK;
        return -1;
END