diff --git a/cap/etc/channel/icbc/BATCH_ICBC.XML b/cap/etc/channel/icbc/BATCH_ICBC.XML
new file mode 100644
index 0000000..12621ee
--- /dev/null
+++ b/cap/etc/channel/icbc/BATCH_ICBC.XML
@@ -0,0 +1,1029 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<Tran>
+   <Transaction code="initBatch_ICBC" log_switch='1' desc="生成工行批次">
+      <Quote name="SQL_RcvConfirm" />
+      <DynSentence name="QryBatCnt"><!-- 查询该批次有多少记录 -->
+         <Sentence>
+            SELECT COUNT(*) BAT_CNT FROM CAPTXNJNL
+            WHERE DSK_NAM=? AND ORD_DT=?  AND CORG_NO=?  AND TXN_MOD=?  AND DSK_NAM_STS='0' AND TXN_STS='U' AND CORG_DSK_NO = '0' AND ROWNUM &lt;= ?
+         </Sentence>
+         <Fields>DSK_NAM|ORD_DT|CORG_NO|TXN_MOD|MAX_CNT</Fields>
+      </DynSentence>
+      <DynSentence name="UpdDskNo">
+         <Sentence>
+            UPDATE CAPTXNJNL SET CORG_DSK_NO = ?,CORG_BUS_TYP =?,TXN_CD = '204020', TTXN_CD = ?,ACC_VER_STS= 'S'
+            WHERE DSK_NAM=? AND ORD_DT=? AND CORG_NO=? AND TXN_MOD=? AND DSK_NAM_STS='0' AND TXN_STS='U' AND CORG_DSK_NO = '0' AND ROWNUM &lt;= ?
+         </Sentence>
+         <Fields>CORG_DSK_NO|CORG_BUS_TYP|TTXN_CD|DSK_NAM|ORD_DT|CORG_NO|TXN_MOD|MAX_CNT</Fields>
+      </DynSentence>
+      <DynSentence name="QryBatAmt">
+         <Sentence>
+            SELECT COUNT(*) BAT_CNT,NVL(SUM(TXN_AMT),0) BAT_SUM FROM CAPTXNJNL
+            WHERE  DSK_NAM=? AND ORD_DT = ? AND CORG_NO=? AND CORG_DSK_NO = ? AND DSK_NAM_STS='0' AND TXN_STS='U'
+         </Sentence>
+         <Fields>DSK_NAM|ORD_DT|CORG_NO|CORG_DSK_NO</Fields>
+      </DynSentence>
+       
+      <DynSentence name="QRY_ICBCCORGBUSTYP_VAL">
+         <Sentence>
+            SELECT ICBCCORGBUSTYP.NEXTVAL CORG_BUS_TYP FROM DUAL
+         </Sentence>
+      </DynSentence>       
+      <FlowCtrl>
+         <!--清理数据 -->
+         <Delete>RSP_CD</Delete>
+         <Delete>RSP_MSG</Delete>
+         <Exec func="PUB:DumpETF" />
+
+         <!--读取参数配置 -->
+         <Quote name="Batch_Cfg_ICBC" />
+
+         <!--设置机构编号(工行) -->
+         <Set>CORG_NO=ICBC</Set>
+         <Set>MAX_CNT=$PARA.MAX_CNT</Set>
+
+         <!--查询合作机构检查-->
+         <Exec func="PUB:ReadRecord" error="IGNORE">
+            <Arg name="SqlCmd"       value="QryBnkInf"/>
+         </Exec>
+         <If condition="~RetCod=2">
+            <Set>Rsp_Cd=31</Set>
+            <Set>Rsp_Msg=该合作机构不存在</Set>
+            <Return/>
+         </If>
+         <ElseIf condition="~RetCod!=0">
+            <Set>Rsp_Cd=80</Set>
+            <Set>Rsp_Msg=查询数据库失败</Set>
+            <Return/>
+         </ElseIf>
+         <If condition="INTCMP($ENB_FLG,4,1)">
+            <Set>Rsp_Cd=31</Set>
+            <Set>Rsp_Msg=该合作机构未启用</Set>
+            <Return/>
+         </If>
+
+         <!--获取第三方业务种类编号1到999  当日不重复 每一个大批次获取一个-->
+         <Exec func="PUB:ReadRecord" error="IGNORE">
+            <Arg name="SqlCmd"       value="QRY_ICBCCORGBUSTYP_VAL"/>
+         </Exec> 
+         <If condition="~RetCod!=0">
+            <Set>Rsp_Cd=80</Set>
+            <Set>Rsp_Msg=获取业务种类编号失败</Set>
+            <Return/>
+         </If>
+         <Set>CORG_BUS_TYP=ADD($CORG_BUS_TYP,0)</Set>
+
+         <While>
+            <Exec func="PUB:ReadRecord" error="IGNORE">
+               <Arg name="SqlCmd" value="QryBatCnt" />
+            </Exec>
+            <If condition="~RetCod=-1">
+               <Set>Rsp_Cd=80</Set>
+               <Set>Rsp_Msg=查询数据库失败</Set>
+               <Exec func="PUB:RollbackWork" />
+               <Return />
+            </If>
+            <Set>BAT_CNT=$BAT_CNT</Set>
+            <!--无数据 -->
+            <If condition="INTCMP($BAT_CNT,2,0)">
+               <Break />
+            </If>
+
+            <Set>BAT_TYP=$FIL_TYP</Set>                 <!-- 交易模式 01 批扣 02 批付 99 联机 -->
+            <Set>SND_DT=SUBSTR($TACC_TM,1,8)</Set>
+            <Set>SND_TM=SUBSTR($TACC_TM,9,6)</Set>
+            <!--获取批次号 -->
+            <Quote name="GET_CUP_BAT_NO" />
+            <Set>CORG_DSK_NO=STRCAT(GETDATETIME(),$CORG_DSK_NO)</Set>
+
+            <!--交易类型 -->
+            <Set>TTXN_CD=PAYPERCOL_BAT</Set>
+            <!--更新批次号-->
+            <Exec func="PUB:ExecSql" error="IGNORE">
+               <Arg name="SqlCmd"         value="UpdDskNo"/>
+            </Exec>
+            <If condition="~RetCod != 0">
+               <Set>Rsp_Cd=80</Set>
+               <Set>Rsp_Msg=更新批次号失败</Set>
+               <Exec func="PUB:RollbackWork"/>
+               <Return/>
+            </If>
+            
+            <!--查询金额笔数数-->
+            <Exec func="PUB:ReadRecord" error="IGNORE">
+               <Arg name="SqlCmd"       value="QryBatAmt"/>
+            </Exec>
+            <If condition="~RetCod=-1">
+               <Set>Rsp_Cd=80</Set>
+               <Set>Rsp_Msg=查询数据库失败</Set>
+               <Exec func="PUB:RollbackWork"/>
+               <Return/>
+            </If>
+
+
+            <Set>BAT_STS=0</Set>
+            <Set>BAT_VER_STS=1</Set>
+            <Set>BAT_ORN_AMT=$BAT_SUM</Set>
+            <Set>BAT_ORN_CNT=$BAT_CNT</Set>
+
+
+            <Set>CORG_MERC_ID=$MERC_ID</Set> <!--单位编号 -->
+
+            <Set>Rsp_Cd=STRCAT( , )</Set>
+            <Set>Rsp_Msg=STRCAT( , )</Set>
+
+            <!--登记接出批量信息登记表 -->
+            <Exec func="PUB:InsertRecord" error="IGNORE">
+               <Arg name="TblNam" value="CAPBATINF" />
+            </Exec>
+            <If condition="~RetCod=-1">
+               <Set>Rsp_Cd=80</Set>
+               <Set>Rsp_Msg=登记接出批量信息登记表失败</Set>
+               <Exec func="PUB:RollbackWork" />
+               <Return />
+            </If>
+            <ElseIf condition="~RetCod=1">
+               <Set>Rsp_Cd=80</Set>
+               <Set>Rsp_Msg=批次重复</Set>
+               <Exec func="PUB:RollbackWork" />
+               <Return />
+            </ElseIf>
+
+            <!--提交事务-->
+            <Exec func="PUB:CommitWork"/>
+            
+         </While>
+
+         <!-- 交易成功 -->
+         <Set>RSP_CD=00</Set>
+         <Set>RSP_MSG=交易成功</Set>
+      </FlowCtrl>
+   </Transaction>
+
+   <!--发送 -->
+   <Transaction code="sendBatch_ICBC" log_switch="1" timeout="3600">
+
+      <DynSentence name="QRY_CAPBATINF_INF"> <!--查询批次信息-->
+         <Sentence>
+            SELECT * FROM CAPBATINF WHERE CORG_DSK_NO=? AND ORD_DT=? AND PRO_JRL='1'
+         </Sentence>
+         <Fields>CORG_DSK_NO|ORD_DT|</Fields>
+      </DynSentence>
+
+
+      <DynSentence name="UPD_ICBC_TXNJNL"> <!--更新批扣流水 -->
+         <Sentence>
+            UPDATE CAPTXNJNL
+            SET
+            TTXN_ST=?,TXN_STS=?,DSK_NAM_STS='4',TACC_DT,TACC_TM,TRSP_CD=?,TRSP_MSG=?,RSP_MSG=?
+            WHERE
+            CORG_NO = 'ICBC'
+            AND CORG_DSK_NO = ?
+            AND CAP_ORD_NO =?
+            AND (TTXN_ST = 'U' OR
+            TTXN_ST = 'P')
+            AND  ORD_DT=?
+         </Sentence>
+         <Fields>TTXN_ST|TTXN_STS|TACC_DT|TACC_TM|TRSP_CD|TRSP_MSG|TRSP_MSG|OCORG_DSK_NO|CAP_ORD_NO|OORD_DT|</Fields>
+      </DynSentence>
+
+      <DynSentence name="QRY_ICBC_TXNSTS"> <!--统计本批次数据处理结果中状态未明数据,具体状态待补充完善-->
+         <Sentence>
+            SELECT COUNT(*) UNDO_CNT FROM CAPTXNJNL
+            WHERE CORG_NO = 'ICBC'  AND CORG_DSK_NO = ? AND TTXN_ST IN ('P','U')
+         </Sentence>
+         <Fields>OCORG_DSK_NO|</Fields>
+      </DynSentence>
+
+      <DynSentence name="UPD_CUPS_DSK_NO">  <!-- 更新小批次处理信息 -->
+         <Sentence>
+            UPDATE CAPBATINF
+            SET BAT_STS=? ,
+            END_TM=? ,
+            END_DT=?,
+            BAT_SUC_AMT=?,
+            BAT_SUC_CNT=?,
+            BAT_FAL_AMT=?,
+            BAT_FAL_CNT=?,
+            RSP_CD = ?,
+            RSP_MSG = ?
+            WHERE ORD_DT=?
+            AND CORG_NO=?
+            AND CORG_DSK_NO=?
+            AND AC_DT=?
+            AND BAT_STS=?
+         </Sentence>
+         <Fields>BAT_STS|END_TM|END_DT|BAT_SUC_AMT|BAT_SUC_CNT|BAT_FAL_AMT|BAT_FAL_CNT|RSP_CD|RSP_MSG|OORD_DT|OCORG_NO|OCORG_DSK_NO|OAC_DT|OBAT_STS|
+         </Fields>
+      </DynSentence>
+
+      <DynSentence name="UPD_DSK_INF">  <!-- 更新大批次信息 -->
+         <Sentence>
+            UPDATE CAPDSKINF
+            SET SUC_CNT=TO_NUMBER(NVL(TRIM(SUC_CNT),0))
+            +
+            TO_NUMBER(NVL(TRIM(?),0)),
+            SUC_AMT=TO_NUMBER(NVL(TRIM(SUC_AMT),0)) +
+            TO_NUMBER(NVL(TRIM(?),0)),
+            FAL_CNT=TO_NUMBER(NVL(TRIM(FAL_CNT),0)) +
+            TO_NUMBER(NVL(TRIM(?),0)),
+            FAL_AMT=TO_NUMBER(NVL(TRIM(FAL_AMT),0)) +
+            TO_NUMBER(NVL(TRIM(?),0))
+            WHERE DSK_NAM=?
+         </Sentence>
+         <Fields>BAT_SUC_CNT|BAT_SUC_AMT|BAT_FAL_CNT|BAT_FAL_AMT|ODSK_NAM
+         </Fields>
+      </DynSentence>
+
+
+      <DynSentence name="Qry_Export"> <!--代付查询需要打包的记录 单笔数据打包-->
+         <Sentence>
+            SELECT TAC_NO AS PayAccNo,TAC_NAM AS PayAccNameCN,POSTSCRIPT AS UseCN,'%s' AS ReimburseNo,'%s' AS ReimburseNum,
+            '%s' AS StartDate,'%s' AS StartTime,'%s' AS PayAccNameEN,'%s' AS RecAccNameEN,
+            '%s' AS ERPSqn,'%s' AS BusCode,'%s' AS ERPcheckno,'%s' AS CrvouhType,
+            '%s' AS CrvouhName,'%s' AS CrvouhNo,'%s' AS Ref,CAP_ORD_NO AS iSeqno,AC_NO AS RecAccNo,
+            CUS_NAM AS RecAccNameCN,'  ' AS RecICBCCode,LBNK_NO AS RecBankNo,'001' AS CurrType,
+            TXN_AMT * 100  AS PayAmt,POSTSCRIPT AS PostScript,POSTSCRIPT AS Summary,CAP_ORD_NO AS Oref,'%s' AS RecCityName,
+            '%s' AS RecBankName,'%s' AS UseCode,'%s' AS EnSummary,decode(ROUT_FLG,'SUPER','3','LARGE','1','SMALL','2') AS  PayType,decode(BNK_FLG,'Y','1','N',2) AS  SysIOFlg
+            FROM CAPTXNJNL
+            WHERE DSK_NAM=?
+            AND CORG_NO = ?
+            AND CORG_DSK_NO = ?
+            AND ORD_DT=?
+            AND TXN_MOD=?
+            AND DSK_NAM_STS='0'
+            AND TXN_STS='U'
+            AND CAP_ORD_NO =?
+         </Sentence>
+         <Fields>ReimburseNo|ReimburseNum|StartDate|StartTime|PayAccNameEN|RecAccNameEN|ERPSqn|BusCode|ERPcheckno|CrvouhType|CrvouhName|CrvouhNo|Ref|RecCityName|RecBankName|UseCode|EnSummary|DSK_NAM|CORG_NO|CORG_DSK_NO|ORD_DT|TXN_MOD|CAP_ORD_NO|</Fields>
+      </DynSentence>
+
+      <DynSentence name="QRY_CAPTXNJNL_LST"> <!--查询小批次内需要循环发送的明细 -->
+         <Sentence>
+            SELECT  CAP_ORD_NO,CORG_BUS_TYP,(TXN_AMT * 100) AS TXNAMT
+            FROM CAPTXNJNL
+            WHERE DSK_NAM=?
+            AND CORG_NO = ?
+            AND CORG_DSK_NO = ?
+            AND ORD_DT=?
+            AND TXN_MOD=?
+            AND DSK_NAM_STS='0'
+            AND TXN_STS='U'
+         </Sentence>
+         <Fields>DSK_NAM|CORG_NO|CORG_DSK_NO|ORD_DT|TXN_MOD|</Fields>
+      </DynSentence>
+
+      <DynSentence name="TotFai"> <!--统计失败笔数 -->
+         <Sentence>
+            SELECT COUNT(*) BAT_FAL_CNT,NVL(SUM(TXN_AMT),0) BAT_FAL_AMT
+            FROM CAPTXNJNL
+            WHERE ORD_DT = ? AND CORG_NO = ? AND CORG_DSK_NO = ?
+            AND TTXN_ST =
+            'F'
+         </Sentence>
+         <Fields>OORD_DT|CORG_NO|OCORG_DSK_NO</Fields>
+      </DynSentence>
+
+      <DynSentence name="TotSuc"> <!--统计成功笔数 -->
+         <Sentence>
+            SELECT COUNT(*) BAT_SUC_CNT,NVL(SUM(TXN_AMT),0) BAT_SUC_AMT
+            FROM CAPTXNJNL
+            WHERE ORD_DT = ? AND CORG_NO = ? AND CORG_DSK_NO = ?
+            AND TTXN_ST =
+            'S'
+         </Sentence>
+         <Fields>OORD_DT|CORG_NO|OCORG_DSK_NO</Fields>
+      </DynSentence>
+
+      <Attributes>
+         <Attribute name="nodatabase" value="2"/>  <!--设置数据库全程连接-->
+      </Attributes>
+
+      <FlowCtrl>
+
+         <!--清理数据 -->
+         <Delete>RSP_CD</Delete>
+         <Delete>RSP_MSG</Delete>
+         <Delete>SUM</Delete>
+         <Delete>REC</Delete>
+         <Delete>rd</Delete>
+         <Exec func="PUB:DumpETF" />
+         <!--保存原始批次数据-->
+         <Set>OCORG_DSK_NO=$CORG_DSK_NO</Set>
+         <Set>OORD_DT=$ORD_DT</Set>
+         <Exec func="PUB:DeleteGroup" error="IGNORE">
+            <Arg name="GroupName"  value="REC"/>
+         </Exec>
+         <Quote name="Init_CAP01"/>                  <!--交易初始化-->
+         <Exec func="PUB:ReadRecord" error="IGNORE"> <!--查询批次信息-->
+            <Arg name="SqlCmd" value="QRY_CAPBATINF_INF"/>
+         </Exec>
+         <If condition="~RetCod!=0">
+            <Set>Rsp_Cd=80</Set>
+            <Set>Rsp_Msg=查询数据库出错</Set>
+            <Return/>
+         </If>
+
+
+
+         <!--打开游标 循环发送代付请求-->
+         <Exec func="PUB:OpenCursor" error="IGNORE">
+            <Arg name="SqlCmd" value="QRY_CAPTXNJNL_LST"/>
+            <Arg name="CursorName" value="CURSOR_1"/>
+         </Exec>
+         <If condition="~RetCod!=0">
+            <Set>Rsp_Cd=80</Set>
+            <Set>Rsp_Msg=游标打开失败</Set>
+            <Return/>
+         </If>
+
+         <While>
+
+            <Exec func="PUB:FetchCursor" error="IGNORE"/>
+            <If condition="~RetCod=2">
+               <Exec func="PUB:CloseCursor">
+                  <Arg name="CursorName" value="CURSOR_1"/>
+               </Exec>
+               <Break/>
+            </If>
+            <ElseIf condition="~RetCod!=0">
+               <Exec func="PUB:CloseCursor">
+                  <Arg name="CursorName" value="CURSOR_1"/>
+               </Exec>
+               <Break/>
+            </ElseIf>
+
+            <!-- 初始化参数 清理垃圾数据-->
+            <Set>BatCnt=1</Set>        <!-- 默认一笔 单笔发送-->
+            <Set>BatAmt=$TXNAMT</Set> <!-- 默认一笔 为该笔交易的汇总金额-->
+            <Delete>REC</Delete>
+            <Exec func="PUB:DeleteGroup" error="IGNORE">
+               <Arg name="GroupName"         value="REC"/>
+            </Exec>
+            <Exec func="PUB:DeleteGroup" error="IGNORE">
+               <Arg name="GroupName"         value="rd"/>
+            </Exec>
+            <!--读取参数配置 -->
+            <Set>TXN_DT=GETDATE()</Set>
+            <Set>TXN_TM=GETDATETIME(HHMISS)</Set>
+            <Set>SignTime=STRCAT(GETDATETIME(),000)</Set>  <!--签名时间    必输项    字符    17    格式是yyyyMMddHHmmssSSS-->
+            <Quote name="Batch_Cfg_ICBC" />
+            <Set>StartDate=GETDATE()</Set>                <!--接口中 启动日期和时间 用法待确认-->
+            <Set>StartTime=GETDATETIME(HHMISS)</Set>
+            <Set>RecICBCCode=STRCAT( , )</Set>   <!--默认为空 原程序代码中 地区码上送102-->
+            <Set>MAX_CNT=1</Set>  <!--单笔循环发送 默认为1-->
+
+            <!--帐户类型 -->
+
+            <Set>BAT_SEQ=0</Set>
+            <Set>TTXNSERVICE=PAYPERCOL</Set>        <!--交易代码 必输项 字符 10 PAYPER -->
+            <Set>TTXNSERVICE1=PAYPERCOL_BAT</Set>   <!--交易代码 必输项  10 PAYPER -->
+            <Set>QryExport=Qry_Export</Set>         <!--代付需要发往工行的数据 -->
+            <Set>ICBC_CYC_CD=001</Set>              <!--工行货币代码 -->
+
+            <!--业务数据初始化 -->
+            <Set>CORG_DSK_NO=$CORG_DSK_NO</Set>
+            <Set>CORG_MERC_ID=$CORG_MERC_ID</Set>
+            <Set>TACC_TM=$TACC_TM</Set>
+            <Set>TXN_TM=SUBSTR(GETDATETIME(),9,6)</Set>
+            <Set>BAT_TYP=$BAT_TYP</Set>
+            <Set>@MSG.TXNTYP=T</Set>
+            <Set>RSP_CD=STRCAT( , )</Set>
+            <Set>RSP_MSG=STRCAT( , )</Set>
+
+            <!--第三方数据拼接 -->
+            <Set>CIS=$GRP_CIS</Set>                <!--集团CIS号 必输项 字符 60 客户注册时的归属编码(发卡机构代码) -->
+            <Set>Bank_Code=102</Set>            <!--归属银行编号 必输项 长度为3 客户注册时的归属单位 -->
+            <Set>TranDate=GETDATE()</Set>            <!--交易日期 必输项 字符 8 ERP系统产生的交易日期，格式是yyyyMMdd -->
+            <Set>TranTime=STRCAT(GETDATETIME(HHMISS),000)</Set>            <!--交易时间 必输项 字符 12 字符 8 ERP系统产生的交易时间，格式如HHmmssSSS，精确到毫秒； -->
+            <Set>fSeqno=$CORG_DSK_NO</Set>  <!--指令包序列号 必输项 字符 35 字符 8 ERP系统产生的指令包序列号，一个集团永远不能重复； -->
+            <Set>OnlBatF=1</Set>            <!--联机批量标志 选输项 数字 1 1：联机 -->
+            <Set>SettleMode=0</Set>        <!--入账方式 必输项 数字 1 2：并笔入账 0：逐笔记账   该字段接口已经删除 待确认-->
+            <Set>TotalNum=$BatCnt</Set>            <!--总笔数 必输项 数字 6 指令包内的指令笔数 当前默认一笔 待确认-->
+            <Set>TotalAmt=AMTPOWER($BatAmt,2)</Set>            <!--总金额 必输项 数字 20 无正负号，不带小数点，以分作单位 -->
+
+            <Set>RECNUM=1</Set>
+            <Set>@MSG.CERTFIL=</Set>
+            <Set>@MSG.BANKCODE=$ATTACH_NO</Set>
+            <Set>@MSG.GROUPCIS=$GRP_CIS</Set>
+            <Set>@MSG.CERTID=$CERD_ID</Set>
+            <Set>@MSG.PACKAGEID=$CORG_DSK_NO</Set>
+            <Set>@MSG.TRANSCODE=$TTXNSERVICE</Set>
+            <Set>TransCode=@MSG.TRANSCODE</Set>
+            <Set>CIS=@MSG.GROUPCIS</Set>
+            <Set>PackageID=@MSG.PACKAGEID</Set>
+            <Set>ID=@MSG.CERTID</Set>
+            <Set>PackageID=@MSG.CERTID</Set>
+            <Set>ReimburseNo=STRCAT( , )</Set>
+            <Set>ReimburseNum=STRCAT( , )</Set>
+            <Set>StartDate=STRCAT( , )</Set>
+            <Set>StartTime=STRCAT( , )</Set>
+            <Set>PayAccNameEN=STRCAT( , )</Set>
+            <Set>RecAccNameEN=STRCAT( , )</Set>
+            <Set>ERPSqn=STRCAT( , )</Set>
+            <Set>BusCode=STRCAT( , )</Set>
+            <Set>ERPcheckno=STRCAT( , )</Set>
+            <Set>CrvouhType=STRCAT( , )</Set>
+            <Set>CrvouhName=STRCAT( , )</Set>
+            <Set>CrvouhNo=STRCAT( , )</Set>
+            <Set>RecCityName=STRCAT( , )</Set>
+            <Set>RecBankName=STRCAT( , )</Set>
+            <Set>UseCode=STRCAT( , )</Set>
+            <Set>EnSummary=STRCAT( , )</Set>
+            <Set>Ref=STRCAT( , )</Set>
+
+
+
+            <!-- 为保持接口兼容性 单笔发放数据也采用组模式处理-->
+            <Exec func="PUB:QueryInGroup" error="IGNORE">
+               <Arg name="SqlCmd" value="$QryExport"/>
+               <Arg name="RecordName" value="REC"/>
+               <Arg name="limit" value="$MAX_CNT"/>
+            </Exec>
+            <If condition="~RetCod!=0">
+               <Continue/>
+            </If>
+            <!-- 通过原子函数获取正确的前置机信息 获取通信信息模式 待确认-->
+            <Exec func="ROUTE:GETROUTEBANPAR" error="IGNORE">
+               <Arg name="BANKCODE" value="ICBC" />
+            </Exec>
+            <Set>@MSG.CERTID=$CERD_ID</Set>
+            <Set>ID=@MSG.CERTID</Set>
+            <If condition="~RetCod != 0">
+               <Return />
+            </If>
+            <Exec func="PUB:CallThirdComm" error="IGNORE">
+               <Arg name="HTxnCd"           value="$TTXNSERVICE1"/> <!-- 交易发往银行 -->
+               <Arg name="ObjSvr"           value="SICBCCPY"/><!-- 服务名 -->
+            </Exec>
+            <Switch expression="~RetCod">
+               <Case value="1">
+                  <!--状态未名 -->
+                  <Set>BAT_STS=3</Set>
+                  <Set>RSP_CD=80</Set>
+                  <Set>RSP_MSG=发送失败</Set>
+                  <Set>TTXN_ST=P</Set>
+                  <Set>TRSP_CD= </Set>
+                  <Set>TRSP_MSG= </Set>
+                  <Break/>
+               </Case>
+               <Case value="-1">
+                  <Set>BAT_STS=3</Set>
+                  <Set>RSP_CD=80</Set>
+                  <Set>RSP_MSG=发送失败</Set>
+                  <Set>TTXN_ST=P</Set>
+                  <Set>TRSP_CD= </Set>
+                  <Set>TRSP_MSG= </Set>
+                  <Break/>
+               </Case>
+               <Case value="3">
+                  <Set>BAT_STS=2</Set>
+                  <Set>RSP_CD=$TRSP_CD</Set>
+                  <Set>RSP_MSG=$TRSP_MSG</Set>
+                  <Set>TTXN_ST=F</Set>
+                  <Break/>
+               </Case>
+               <Case value="0"> <!--发送成功 需要根据明细交易结果判断交易是否成功 具体批次状态和单笔状态更新数据表 处理 待分析确认-->
+                  <!--更新流水状态为发送处理成功-->
+                  <Set>BAT_STS=1</Set>
+                  <Set>Rsp_Cd=$TRSP_CD</Set>
+                  <Set>Rsp_Msg=$TRsp_Msg</Set>
+
+                  <!-- 获取组节点赋值 -->
+                  <Set>TTXN_ST=$rd[1].TTXN_ST</Set>
+                  <Set>TRSP_CD=$rd[1].iRetCode</Set>
+                  <Set>TRSP_MSG=$rd[1].iRetMsg</Set>
+                  <!-- 获取组节点赋值 -->
+
+                  <Break/>
+               </Case>
+               <Default>
+                  <!--第三方失败-->
+                  <Set>BAT_STS=3</Set>
+                  <Set>RSP_CD=80</Set>
+                  <Set>RSP_MSG=交易发送成功</Set>
+               </Default>
+            </Switch>
+
+            <!-- 更新流水状态 -->
+            <Exec func="PUB:ExecSql" error="IGNORE">
+               <Arg name="SqlCmd" value="UPD_ICBC_TXNJNL" />
+            </Exec>
+            <If condition="~RetCod=-1">
+               <Set>Rsp_Cd=80</Set>
+               <Set>Rsp_Msg=更新流水交易状态失败</Set>
+               <Return />
+            </If>
+            <!--提交事务-->
+            <Exec func="PUB:CommitWork"/>
+
+            <!--循环处理结束-->
+         </While>
+
+         <!--批次状态更新-->
+         <Set>END_TM=GETDATETIME(HHMISS)</Set>
+         <Set>END_DT=GETDATE()</Set>
+         <Set>BAT_SUC_AMT=0</Set>
+         <Set>BAT_SUC_CNT=0</Set>
+         <Set>BAT_FAL_CNT=0</Set>
+         <Set>BAT_FAL_AMT=0</Set>
+         <!--查询流水表中本批次数据为状态P数据 -->
+         <Exec func="PUB:ReadRecord" error="IGNORE">
+            <Arg name="SqlCmd" value="QRY_ICBC_TXNSTS" />
+         </Exec>
+         <If condition="~RetCod != 0">
+            <Set>Rsp_Cd=80</Set>
+            <Set>Rsp_Msg=查询流水表批次记录状态为P的记录数失败</Set>
+            <Return />
+         </If>
+
+         <Set>UNDO_CNT=$UNDO_CNT</Set>
+         <!--存在处理中和状态未明数据 -->
+         <If condition="$UNDO_CNT != 0">
+            <Set>BAT_STS=3</Set>
+            <Set>Rsp_Cd=00</Set>
+            <Set>Rsp_Msg=交易处理中...</Set>
+
+            <Exec func="PUB:ExecSql" error="IGNORE">
+               <Arg name="SqlCmd"    value="UPD_CUPS_DSK_NO"/>
+            </Exec>
+            <If condition="~RetCod!=0">
+               <Set>Rsp_Cd=80</Set>
+               <Set>Rsp_Msg=更新该批次状态失败</Set>
+               <Break/>
+            </If>
+            <Return />
+         </If>
+
+
+         <!--本批次全部处理完成,统计成功，失败笔数 -->
+         <Exec func="PUB:ReadRecord" error="IGNORE">
+            <Arg name="SqlCmd" value="TotSuc" />
+         </Exec>
+         <Exec func="PUB:ReadRecord" error="IGNORE">
+            <Arg name="SqlCmd" value="TotFai" />
+         </Exec>
+
+         <Set>BAT_SUC_AMT=$BAT_SUC_AMT</Set>
+         <Set>BAT_SUC_CNT=$BAT_SUC_CNT</Set>
+         <Set>BAT_FAL_AMT=$BAT_FAL_AMT</Set>
+         <Set>BAT_FAL_CNT=$BAT_FAL_CNT</Set>
+
+         <!--更新文件信息 -->
+         <Exec func="PUB:ExecSql" error="IGNORE">
+            <Arg name="SqlCmd" value="UPD_DSK_INF" />
+         </Exec>
+         <If condition="~RetCod!=0">
+            <Set>Rsp_Cd=80</Set>
+            <Set>Rsp_Msg=累加更新接入批量信息表成功失败总笔数及总金额失败</Set>
+            <Return />
+         </If>
+
+         <Set>Rsp_Cd=00</Set>
+         <Set>Rsp_Msg=交易成功</Set>
+         <Set>BAT_STS=4</Set> <!-- 接收处理完成 -->
+
+         <!--更新小批次信息 -->
+         <Exec func="PUB:ExecSql" error="IGNORE">
+            <Arg name="SqlCmd" value="UPD_CUPS_DSK_NO" />
+         </Exec>
+         <If condition="~RetCod != 0">
+            <Set>Rsp_Cd=80</Set>
+            <Set>Rsp_Msg=更新该批次为发送处理状态失败</Set>
+            <Return />
+         </If>
+         <Exec func="PUB:CommitWork" />  <!--提交事务 -->
+
+         <Set>TXN_MOD_FLG=$OBAT_TYP</Set>
+         <Set>CAP_TYP=CAP_PAY_BAT</Set>
+         <Set>RUL_TYP=BIS</Set><!-- 转码规则类型 -->
+         <Set>CAP_TYP=$CAP_TYP</Set><!-- 交易类型 -->
+         <Set>CORG_NO=$OCORG_NO</Set><!-- 合作机构号 -->
+         <Set>CSW_TYP=0</Set><!-- 匹配类型 -->
+         <Set>ORD_DT=$OORD_DT</Set>
+         <Set>CORG_DSK_NO=$OCORG_DSK_NO</Set>
+         <Call package="CSW" function="CAP_BAT_CSW">
+            <Input>RUL_TYP|CAP_TYP|CORG_NO|CSW_TYP|ORD_DT|CORG_DSK_NO|</Input>
+            <Output></Output>
+         </Call>
+
+         <!--清理数据 -->
+         <Delete>RSP_CD</Delete>
+         <Delete>RSP_MSG</Delete>
+         <Delete>SUM</Delete>
+         <Delete>REC</Delete>
+         <Delete>rd</Delete>
+
+      </FlowCtrl>
+
+   </Transaction>
+
+
+
+   <!--工行交易结果查询 -->
+   <Transaction code="getBatch_ICBC" log_switch='1' timeout="3600" desc="获取工行交易结果">
+      <DynSentence name="UPD_CUPS_DSK_NO">  <!-- 更新小批次处理信息 -->
+         <Sentence>
+            UPDATE CAPBATINF
+            SET BAT_STS=? ,
+            END_TM=? ,
+            END_DT=?,
+            BAT_SUC_AMT=?,
+            BAT_SUC_CNT=?,
+            BAT_FAL_AMT=?,
+            BAT_FAL_CNT=?,
+            RSP_CD = ?,
+            RSP_MSG = ?
+            WHERE ORD_DT=?
+            AND CORG_NO=?
+            AND CORG_DSK_NO=?
+            AND AC_DT=?
+            AND BAT_STS=?
+         </Sentence>
+         <Fields>BAT_STS|END_TM|END_DT|BAT_SUC_AMT|BAT_SUC_CNT|BAT_FAL_AMT|BAT_FAL_CNT|RSP_CD|RSP_MSG|OORD_DT|OCORG_NO|OCORG_DSK_NO|OAC_DT|OBAT_STS|
+         </Fields>
+      </DynSentence>
+
+      <DynSentence name="UPD_ICBC_TXNJNL"> <!--更新批扣流水 -->
+         <Sentence>
+            UPDATE CAPTXNJNL
+            SET
+            TTXN_ST=?,TXN_STS=?,DSK_NAM_STS='4',TACC_DT,TACC_TM,TRSP_CD=?,TRSP_MSG=?,RSP_MSG=?
+            WHERE
+            CORG_NO = 'ICBC'
+            AND CORG_DSK_NO = ?
+            AND CAP_ORD_NO =?
+            AND (TTXN_ST = 'U' OR
+            TTXN_ST = 'P')
+         </Sentence>
+         <Fields>TTXN_ST|TTXN_STS|TACC_DT|TACC_TM|TRSP_CD|TRSP_MSG|TRSP_MSG|OCORG_DSK_NO|CAP_ORD_NO|</Fields>
+      </DynSentence>
+
+      <DynSentence name="UPD_DSK_INF">
+         <Sentence>
+            UPDATE CAPDSKINF
+            SET SUC_CNT=TO_NUMBER(NVL(TRIM(SUC_CNT),0))
+            +
+            TO_NUMBER(NVL(TRIM(?),0)),
+            SUC_AMT=TO_NUMBER(NVL(TRIM(SUC_AMT),0)) +
+            TO_NUMBER(NVL(TRIM(?),0)),
+            FAL_CNT=TO_NUMBER(NVL(TRIM(FAL_CNT),0)) +
+            TO_NUMBER(NVL(TRIM(?),0)),
+            FAL_AMT=TO_NUMBER(NVL(TRIM(FAL_AMT),0)) +
+            TO_NUMBER(NVL(TRIM(?),0))
+            WHERE DSK_NAM=?
+         </Sentence>
+         <Fields>BAT_SUC_CNT|BAT_SUC_AMT|BAT_FAL_CNT|BAT_FAL_AMT|ODSK_NAM
+         </Fields>
+      </DynSentence>
+
+      <DynSentence name="QRY_CAPTXNJNL_CHKLST"> <!--查询需要获取交易状态的明细数据 -->
+         <Sentence>
+            SELECT CAP_ORD_NO
+            FROM CAPTXNJNL
+            WHERE DSK_NAM='%s'
+            AND
+            CORG_NO = '%s'
+            AND CORG_DSK_NO = '%s'
+            AND ORD_DT='%s'
+            AND DSK_NAM_STS='1'
+            AND (A.TTXN_ST = 'U' OR A.TTXN_ST = 'P')
+         </Sentence>
+         <Fields>ODSK_NAM|OCORG_NO|OCORG_DSK_NO|OORD_DT|</Fields>
+      </DynSentence>
+
+
+      <DynSentence name="TotFai"> <!--统计失败笔数 -->
+         <Sentence>
+            SELECT COUNT(*) BAT_FAL_CNT,NVL(SUM(TXN_AMT),0) BAT_FAL_AMT
+            FROM CAPTXNJNL
+            WHERE ORD_DT = ? AND CORG_NO = ? AND CORG_DSK_NO = ?
+            AND TTXN_ST =
+            'F'
+         </Sentence>
+         <Fields>OORD_DT|CORG_NO|OCORG_DSK_NO</Fields>
+      </DynSentence>
+
+      <DynSentence name="TotSuc"> <!--统计成功笔数 -->
+         <Sentence>
+            SELECT COUNT(*) BAT_SUC_CNT,NVL(SUM(TXN_AMT),0) BAT_SUC_AMT
+            FROM CAPTXNJNL
+            WHERE ORD_DT = ? AND CORG_NO = ? AND CORG_DSK_NO = ?
+            AND TTXN_ST =
+            'S'
+         </Sentence>
+         <Fields>OORD_DT|CORG_NO|OCORG_DSK_NO</Fields>
+      </DynSentence>
+
+
+      <DynSentence name="InitPRO_JRL"> <!--初始化PRO_JRL-->
+         <Sentence>
+            UPDATE CAPBATINF SET PRO_JRL ='0'
+            WHERE  ORD_DT=? AND CORG_NO=? AND CORG_DSK_NO=? AND AC_DT=? AND PRO_JRL='1'
+         </Sentence>
+         <Fields>OORD_DT|OCORG_NO|OCORG_DSK_NO|OAC_DT|</Fields>
+      </DynSentence>
+      <Function name="_before">
+         <Process>
+            <Exec func="PUB:DumpETF"/>
+            <Set>LockKey=STRCAT($OCORG_NO,$OCORG_DSK_NO)</Set>
+            <!-- 应用加锁,防止并发 -->
+            <Exec func="PUB:Lock">
+               <Arg name="RecKey" value="$LockKey" error="IGNORE"/>
+               <Arg name="TimOut" value="1800" />
+               <Arg name="AutoUnlock" value="no" />
+            </Exec>
+            <If condition="~RetCod!=0">
+               <Set>Rsp_Cd=80</Set>
+               <Set>Rsp_Msg=加锁失败</Set>
+               <Exit/>
+            </If>
+            <Set>IS_LOCKED=TRUE</Set>
+         </Process>
+      </Function>
+      <Function name="_after">
+         <Process>
+            <Exec func="PUB:ExecSql" error="IGNORE">
+               <Arg name="SqlCmd"    value="InitPRO_JRL"/>
+            </Exec>
+            <If condition="IS_EQUAL_STRING($IS_LOCKED,TRUE)">
+               <!--解锁-->
+               <Exec func="PUB:UnLock">
+                  <Arg name="RecKey" value="$LockKey" />
+               </Exec>
+               <Exec func="PUB:DumpETF"/>
+            </If>
+         </Process>
+      </Function>
+      <FlowCtrl>
+         <!--清理数据 -->
+         <Delete>RSP_CD</Delete>
+         <Delete>RSP_MSG</Delete>
+         <Delete>SUM</Delete>
+         <Delete>REC</Delete>
+         <Delete>rd</Delete>
+         <Exec func="PUB:DeleteGroup" error="IGNORE">
+            <Arg name="GroupName"         value="rd"/>
+         </Exec>
+ 
+         <Exec func="PUB:DumpETF" />
+         <Set>ORD_TYP=$OBAT_TYP</Set>
+         <Quote name="Batch_Cfg_ICBC" />
+
+         <Quote name="GET_ICBC_CAP_ORD_NO" />          <!--取银联订单号 -->
+
+         <Set>TXN_DT=GETDATE()</Set>
+         <Set>TXN_TM=GETDATETIME(HHMISS)</Set>   <!--交易时间 -->
+         <Set>TACC_DT=$TXN_DT</Set>
+         <Set>TACC_TM=$TXN_TM</Set>
+
+         <Set>MerchantNo=$OCORG_MERC_ID</Set>    <!--商户编号 -->
+         <Set>TermId=0000000000000000000</Set>   <!--终端号 -->
+         <Set>FileName=$OCORG_FIL_NAM</Set>         <!--文件名 -->
+         <Quote name="GET_JRN_NO" />                     <!--取交易流水号 -->
+         <Set>trnId=$JRN_NO</Set>
+         <Set>payType=0</Set> <!--支付类型0:支付1:代发工资2:费用报销 -->
+         <Set>ORN_JRN_NO=$OCORG_DSK_NO</Set> <!--原批次号 -->
+
+         <Set>END_TM=GETDATETIME(HHMISS)</Set>
+         <Set>END_DT=GETDATE()</Set>
+         <Set>BAT_SUC_AMT=0</Set>
+         <Set>BAT_SUC_CNT=0</Set>
+         <Set>BAT_FAL_CNT=0</Set>
+         <Set>BAT_FAL_AMT=0</Set>
+         <Set>RSP_CD=STRCAT( , )</Set>
+         <Set>RSP_MSG=STRCAT( , )</Set>
+         <Set>CORG_NO=$OCORG_NO</Set>
+
+
+
+         <Exec func="PUB:OpenCursor" error="IGNORE">  <!--打开游标 循环发送查询请求-->
+            <Arg name="SqlCmd" value="QRY_CAPTXNJNL_CHKLST"/>
+            <Arg name="CursorName" value="CURSOR_1"/>
+         </Exec>
+         <If condition="~RetCod!=0">
+            <Set>Rsp_Cd=80</Set>
+            <Set>Rsp_Msg=打开游标失败</Set>
+            <Return/>
+         </If>
+
+         <While>
+
+            <Exec func="PUB:FetchCursor" error="IGNORE"/>
+            <If condition="~RetCod=2">
+               <Exec func="PUB:CloseCursor">
+                  <Arg name="CursorName" value="CURSOR_1"/>
+               </Exec>
+               <Break/>
+            </If>
+            <ElseIf condition="~RetCod!=0">
+               <Exec func="PUB:CloseCursor">
+                  <Arg name="CursorName" value="CURSOR_1"/>
+               </Exec>
+               <Break/>
+            </ElseIf>
+            <!--第三方数据拼接-->
+
+            <Set>TTXNSERVICE=QPAYPER</Set>
+            <Set>AC_TYP_FMT=BatICBCRSPPAYPERFmt01</Set>
+            <Exec func="PUB:GetUniqueNo">
+               <Arg name="Name" value="fSeqno" />
+               <Arg name="SeqNam" value="jrn_no_sequence" />
+               <Arg name="Len" value="10" />
+            </Exec>
+            <If condition="~RetCod!=0">
+               <Set>Rsp_Cd=80</Set>
+               <Set>Rsp_Msg=平台取流水号失败</Set>
+               <Return />
+            </If>
+            <Set>fSeqno=STRCAT(SUBSTR($AC_DT,3,6),$fSeqno)</Set>
+            <Set>@MSG.BANKCODE=$ATTACH_NO</Set>
+            <Set>@MSG.GROUPCIS=$GRP_CIS</Set>
+            <Set>@MSG.CERTID=$CERD_ID</Set>
+            <Set>@MSG.PACKAGEID=$fSeqno</Set>
+            <Set>@MSG.TRANSCODE=$TTXNSERVICE</Set>
+            <Set>@MSG.TXNTYP=Q</Set>
+            <Set>TransCode=@MSG.TRANSCODE</Set>
+            <Set>CIS=@MSG.GROUPCIS</Set>
+            <Set>Bank_Code=@MSG.BANKCODE</Set>  <!-- 联行行号3位 -->
+            <Set>ID=@MSG.CERTID</Set>
+            <Set>TranDate=$TXN_DT</Set>
+            <Set>TranTime=$TXN_TM</Set>
+            <Set>QryfSeqno=$ORN_JRN_NO</Set>
+            <Set>QrySerialNo=STRCAT( , )</Set>
+            <Set>ReqReserved1=STRCAT( , )</Set>
+            <Set>ReqReserved2=STRCAT( , )</Set>
+
+            <!-- 通过原子函数获取正确的前置机信息 待确认 获取方式-->
+            <Exec func="ROUTE:GETROUTEBANPAR" error="IGNORE">
+               <Arg name="BANKCODE" value="ICBC" />
+            </Exec>
+            <Set>@MSG.CERTID=$CERD_ID</Set>
+            <Set>ID=@MSG.CERTID</Set>
+            <If condition="~RetCod != 0">
+               <Return/>
+            </If>
+
+            <!--调用批量结果回盘文件查询接口 -->
+            <Exec func="PUB:CallThirdComm" error="IGNORE">
+               <Arg name="HTxnCd" value="$TTXNSERVICE" />
+               <Arg name="ObjSvr" value="SICBCCPY" />            <!-- 交易发往银行 -->
+            </Exec>
+            <Switch expression="~RetCod">
+               <Case value="1">
+                  <Set>Rsp_Cd=80</Set>
+                  <Set>Rsp_Msg=查询第三方失败</Set>
+                  <Break/>
+               </Case>
+               <Case value="-1">
+                  <Set>Rsp_Cd=80</Set>
+                  <Set>Rsp_Msg=查询第三方失败</Set>
+                  <Break/>
+               </Case>
+               <Case value="3">
+                  <Set>RSP_CD=$TRSP_CD</Set>
+                  <Set>RSP_MSG=$TRSP_MSG</Set>
+                  <If condition="IS_EQUAL_STRING($TRSP_CD,BIB008,D0055)"> <!--交易请求已受理，处理中-->
+                     <Set>BAT_STS=3</Set>
+                     <!--更新批次信息 待确认-->
+
+                  </If>
+                  <Else> <!--其他错误 流水处理模式待确认-->
+                     <Set>BAT_STS=5</Set>
+                     <!--更新批次信息 待确认-->
+
+                  </Else>
+                  <Break/>
+               </Case>
+               <Case value="0">
+
+                  <!-- 获取组节点赋值 -->
+                  <Set>TTXN_ST=$rd[1].TTXN_ST</Set>
+                  <Set>TRSP_CD=$rd[1].iRetCode</Set>
+                  <Set>TRSP_MSG=$rd[1].iRetMsg</Set>
+                  <!-- 获取组节点赋值 -->
+
+                  <!--更新流水状态 -->
+                  <Exec func="PUB:ExecSql" error="IGNORE">
+                     <Arg name="SqlCmd" value="UPD_ICBC_TXNJNL" />
+                  </Exec>
+                  <If condition="~RetCod=-1">
+                     <Set>Rsp_Cd=80</Set>
+                     <Set>Rsp_Msg=更新流水交易状态失败</Set>
+                     <Break/>
+                  </If>
+
+               </Case>
+               <Default>
+                  <Set>Rsp_Cd=80</Set>
+                  <Set>Rsp_Msg=系统错误</Set>
+                  <Break/>
+               </Default>
+            </Switch>
+            <!--提交事务-->
+            <Exec func="PUB:CommitWork"/>
+
+            <!--循环处理结束-->
+         </While>
+
+         <!--批次状态更新-->
+         <Set>END_TM=GETDATETIME(HHMISS)</Set>
+         <Set>END_DT=GETDATE()</Set>
+         <Set>BAT_SUC_AMT=0</Set>
+         <Set>BAT_SUC_CNT=0</Set>
+         <Set>BAT_FAL_CNT=0</Set>
+         <Set>BAT_FAL_AMT=0</Set>
+         <!--查询流水表中本批次数据为状态P数据 -->
+         <Exec func="PUB:ReadRecord" error="IGNORE">
+            <Arg name="SqlCmd" value="QRY_ICBC_TXNSTS" />
+         </Exec>
+         <If condition="~RetCod != 0">
+            <Set>Rsp_Cd=80</Set>
+            <Set>Rsp_Msg=查询流水表批次记录状态为P的记录数失败</Set>
+            <Return />
+         </If>
+
+         <Set>UNDO_CNT=$UNDO_CNT</Set>
+         <!--存在处理中和状态未明数据 -->
+         <If condition="$UNDO_CNT != 0">
+            <Set>BAT_STS=3</Set>
+            <Set>Rsp_Cd=00</Set>
+            <Set>Rsp_Msg=交易处理中...</Set>
+
+            <Exec func="PUB:ExecSql" error="IGNORE">
+               <Arg name="SqlCmd"    value="UPD_CUPS_DSK_NO"/>
+            </Exec>
+            <If condition="~RetCod!=0">
+               <Set>Rsp_Cd=80</Set>
+               <Set>Rsp_Msg=更新该批次状态失败</Set>
+               <Break/>
+            </If>
+            <Return />
+         </If>
+
+
+         <!--本批次全部处理完成,统计成功，失败笔数 -->
+         <Exec func="PUB:ReadRecord" error="IGNORE">
+            <Arg name="SqlCmd" value="TotSuc" />
+         </Exec>
+         <Exec func="PUB:ReadRecord" error="IGNORE">
+            <Arg name="SqlCmd" value="TotFai" />
+         </Exec>
+
+         <Set>BAT_SUC_AMT=$BAT_SUC_AMT</Set>
+         <Set>BAT_SUC_CNT=$BAT_SUC_CNT</Set>
+         <Set>BAT_FAL_AMT=$BAT_FAL_AMT</Set>
+         <Set>BAT_FAL_CNT=$BAT_FAL_CNT</Set>
+
+         <!--更新文件信息 -->
+         <Exec func="PUB:ExecSql" error="IGNORE">
+            <Arg name="SqlCmd" value="UPD_DSK_INF" />
+         </Exec>
+         <If condition="~RetCod!=0">
+            <Set>Rsp_Cd=80</Set>
+            <Set>Rsp_Msg=累加更新接入批量信息表成功失败总笔数及总金额失败</Set>
+            <Return />
+         </If>
+
+         <Set>Rsp_Cd=00</Set>
+         <Set>Rsp_Msg=交易成功</Set>
+         <Set>BAT_STS=4</Set> <!-- 接收处理完成 -->
+
+         <!--更新小批次信息 -->
+         <Exec func="PUB:ExecSql" error="IGNORE">
+            <Arg name="SqlCmd" value="UPD_CUPS_DSK_NO" />
+         </Exec>
+         <If condition="~RetCod != 0">
+            <Set>Rsp_Cd=80</Set>
+            <Set>Rsp_Msg=更新该批次为发送处理状态失败</Set>
+            <Return />
+         </If>
+         <Exec func="PUB:CommitWork" />  <!--提交事务 -->
+
+         <Set>TXN_MOD_FLG=$OBAT_TYP</Set>
+         <Set>CAP_TYP=CAP_PAY_BAT</Set>
+         <Set>RUL_TYP=BIS</Set><!-- 转码规则类型 -->
+         <Set>CAP_TYP=$CAP_TYP</Set><!-- 交易类型 -->
+         <Set>CORG_NO=$OCORG_NO</Set><!-- 合作机构号 -->
+         <Set>CSW_TYP=0</Set><!-- 匹配类型 -->
+         <Set>ORD_DT=$OORD_DT</Set>
+         <Set>CORG_DSK_NO=$OCORG_DSK_NO</Set>
+         <Call package="CSW" function="CAP_BAT_CSW">
+            <Input>RUL_TYP|CAP_TYP|CORG_NO|CSW_TYP|ORD_DT|CORG_DSK_NO|</Input>
+            <Output></Output>
+         </Call>
+
+
+         <!--提交事务-->
+         <Exec func="PUB:CommitWork"/>
+         <!--清理数据 -->
+         <Delete>RSP_CD</Delete>
+         <Delete>RSP_MSG</Delete>
+         <Delete>SUM</Delete>
+         <Delete>REC</Delete>
+         <Delete>rd</Delete>
+      </FlowCtrl>
+   </Transaction>
+
+
+</Tran>