MrTech/ctg-app-cap
5
0
Fork 0
Code Releases Activity

更新代码

Browse Source
This commit is contained in:
Alawn
2021-03-17 15:28:45 +08:00
parent 1ed3e2049e
commit 176da94d47
12 changed files with 384 additions and 276 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cap/applib/ctg.jar
BIN
View File
Binary file not shown.
cap/etc/batch/204025_CTL.XML
+122 -113
View File
@@ -304,124 +304,133 @@
<Arg name="CrdNo" value="$AC_NO"/>
</Exec>
<Set>RTR_IN.BNK_TYP=$BNK_TYP</Set>
<Set>RTR_IN.CRD_FLG=$CRD_FLG</Set>
<Set>RTR_IN.CRD_NM=$CRD_NM</Set>
<Set>CAPTXNJNL.BNK_TYP=$BNK_TYP</Set>
<Set>CAPTXNJNL.CRD_FLG=$CRD_FLG</Set>
<Set>CAPTXNJNL.CRD_NM=$CRD_NM</Set>
<Exec func="PUB:ReadRecord">
<Arg name="SqlCmd" value="QRY_LBNKNO"/>
</Exec>
<If condition="~RetCod !=0">
<Set>Rsp_Cd=80</Set>
<Set>Rsp_Msg=查询联行号失败</Set>
</If>
<Else>
<Set>CAPTXNJNL.LBNK_NO=$PTY_ID</Set><!--联行号-->
<Set>CAPTXNJNL.LBNK_NAM=$PTY_NM</Set><!--联行名称-->
</Else>
<!--所有参数由节点RTR_IN传进路由-->
<Set>RTR_IN.ORD_TYP=$ORD_TYP</Set>
<Set>RTR_IN.PAY_TYP=$PAY_TYP</Set>
<Set>RTR_IN.AC_NO=$CAPTXNJNL.ACCT_NO</Set>
<Set>RTR_IN.TXN_AMT=$TXN_AMT</Set>
<Set>RTR_IN.TXN_CNL=HRO</Set>
<Set>RTR_IN.TXN_MOD=$TXN_MOD</Set>
<Set>RTR_IN.GRP_NM=$GRP_NM</Set>
<!-- 预留增加动态路由选择 -->
<Call package="RTR" function="RANDOM_SELECT_ORG">
<!--Input>GWA|ORD_TYP|PAY_TYP|AC_NO|TXN_AMT|BNK_COD|TXN_CNL</Input-->
<Input>RTR_IN</Input>
<Output>MSG_CD|RTR_OUT</Output>
<!--Output>MSG_CD|BNK_TYP|CRD_FLG|CRD_NM|CORG_NO|LBNK_NO|UNION_FLG</Output-->
</Call>
<!--所有参数由节点RTR_OUT传出路由-->
<Set>CORG_NO=@O.RTR_OUT.CORG_NO</Set>
<Set>ROUT_FLG=@O.RTR_OUT.ROUT_FLG</Set>
<Set>CAPTXNJNL.ROUT_FLG=$ROUT_FLG</Set>
<Set>CAPTXNJNL.CORG_NO=$CORG_NO</Set>
<Set>CORG_NO=@O.RTR_OUT.CORG_NO</Set>
<If condition="IS_EQUAL_STRING($BNK_CD,$CORG_NO)">
<Set>CAPTXNJNL.BNK_FLG=Y</Set>
</If>
<Else>
<Set>CAPTXNJNL.BNK_FLG=N</Set>
</Else>
<If condition="SUBSTR(@O.MSG_CD,4,5)!=00000">
<Set>Rsp_Cd=80</Set>
<Set>Rsp_Msg=计算动态路由失败</Set>
<Exec func="PUB:RollbackWork"/>
<Return/>
</If>
<!--路由查找失败-->
<If condition="IS_EQUAL_STRING(SUBSTR(@O.MSG_CD,4,5),99999)">
<Set>Rsp_Cd=99</Set>
<Set>Rsp_Msg=路由查找失败</Set>
<Exec func="PUB:RollbackWork"/>
<Return/>
</If>
<ElseIf condition="IS_EQUAL_STRING(SUBSTR(@O.MSG_CD,4,5),88888)">
<Set>Rsp_Cd=88</Set>
<Set>Rsp_Msg=交易路由查找失败</Set>
<Exec func="PUB:RollbackWork"/>
<Return/>
</ElseIf>
<Else>
<Set>CORG_NO=@O.RTR_OUT.CORG_NO</Set>
<Set>Rsp_Cd=00</Set>
</Else>
<Set>TXN_AMT2=AMTPOWER($TXN_AMT,2)</Set>
<!--查询支付地账户-->
<Exec func="PUB:ReadRecord" error="IGNORE">
<Arg name="SqlCmd" value="QRY_CAPACCOUNTINF"/>
<Arg name="GrpNam" value="CAPTXNJNL"/>
</Exec>
<If condition="~RetCod!=0">
<Set>Rsp_Cd=31</Set>
<Set>Rsp_Msg=支付地信息有误</Set>
<Exec func="PUB:RollbackWork"/>
<Return/>
</If>
<Set>ACT_FLG=$ACT_FLG</Set>
<Set>ACT_FLG=PL</Set>
<Quote name="GET_JRN_NO"/> <!--取交易流水号-->
<Quote name="GET_CAP_ORD_NO"/>
<Set>CAPTXNJNL.JRN_NO=$JRN_NO</Set>
<Set>CAPTXNJNL.CAP_ORD_NO=$CAP_ORD_NO</Set>
<!--计算商户手续费-->
<Set>CAPTXNJNL.MERC_FEE_AMT=0</Set> <!-- 手续费 -->
<Set>CAPTXNJNL.AC_DT=$AC_DT</Set>
<Set>TXN_AMT2=AMTPOWER($CAPTXNJNL.TXN_AMT,2)</Set>
<!--客户批量限额判断-->
<Call package="CEL" function="MERC_AMT_QTM_VERIFY">
<Input>TXN_AMT2|TIM_RAG|</Input>
<Output>MSG_CD|TXN_STS|RSP_CD|RSP_MSG|</Output>
</Call>
<If condition="SUBSTR(@O.MSG_CD,4,5)!=00000">
<Set>CAPTXNJNL.TXN_STS=@O.TXN_STS</Set>
<Set>CAPTXNJNL.RSP_CD=@O.RSP_CD</Set>
<Set>CAPTXNJNL.RSP_MSG=@O.RSP_MSG</Set>
<Set>CAPTXNJNL.RSP_MSG=@O.RSP_MSG</Set>
<If condition="ISNULL($BNK_TYP)">
<Set>CAPTXNJNL.TXN_STS=F</Set>
<Set>CAPTXNJNL.RSP_CD=80</Set>
<Set>CAPTXNJNL.RSP_MSG=卡宾查找失败</Set>
<Set>CAPTXNJNL.DSK_NAM_STS=4</Set>
</If>
<Else>
<Set>TIM_RAG.DAY_AMT=ADD($TIM_RAG.DAY_AMT,$TXN_AMT2)</Set><!--当月交易金额累加-->
<Set>TIM_RAG.MTH_AMT=ADD($TIM_RAG.MTH_AMT,$TXN_AMT2)</Set><!--当月交易金额累加-->
<Set>TIM_RAG.YAR_AMT=ADD($TIM_RAG.YAR_AMT,$TXN_AMT2)</Set><!--当月交易金额累加-->
<Set>RTR_IN.BNK_TYP=$BNK_TYP</Set>
<Set>RTR_IN.CRD_FLG=$CRD_FLG</Set>
<Set>RTR_IN.CRD_NM=$CRD_NM</Set>
<Set>CAPTXNJNL.BNK_TYP=$BNK_TYP</Set>
<Set>CAPTXNJNL.CRD_FLG=$CRD_FLG</Set>
<Set>CAPTXNJNL.CRD_NM=$CRD_NM</Set>
<Exec func="PUB:ReadRecord">
<Arg name="SqlCmd" value="QRY_LBNKNO"/>
</Exec>
<If condition="~RetCod !=0">
<Set>Rsp_Cd=80</Set>
<Set>Rsp_Msg=查询联行号失败</Set>
</If>
<Else>
<Set>CAPTXNJNL.LBNK_NO=$PTY_ID</Set><!--联行号-->
<Set>CAPTXNJNL.LBNK_NAM=$PTY_NM</Set><!--联行名称-->
</Else>
<!--所有参数由节点RTR_IN传进路由-->
<Set>RTR_IN.ORD_TYP=$ORD_TYP</Set>
<Set>RTR_IN.PAY_TYP=$PAY_TYP</Set>
<Set>RTR_IN.AC_NO=$CAPTXNJNL.ACCT_NO</Set>
<Set>RTR_IN.TXN_AMT=$TXN_AMT</Set>
<Set>RTR_IN.TXN_CNL=HRO</Set>
<Set>RTR_IN.TXN_MOD=$TXN_MOD</Set>
<Set>RTR_IN.GRP_NM=$GRP_NM</Set>
<!-- 预留增加动态路由选择 -->
<Call package="RTR" function="RANDOM_SELECT_ORG">
<!--Input>GWA|ORD_TYP|PAY_TYP|AC_NO|TXN_AMT|BNK_COD|TXN_CNL</Input-->
<Input>RTR_IN</Input>
<Output>MSG_CD|RTR_OUT</Output>
<!--Output>MSG_CD|BNK_TYP|CRD_FLG|CRD_NM|CORG_NO|LBNK_NO|UNION_FLG</Output-->
</Call>
<!--所有参数由节点RTR_OUT传出路由-->
<Set>CORG_NO=@O.RTR_OUT.CORG_NO</Set>
<Set>ROUT_FLG=@O.RTR_OUT.ROUT_FLG</Set>
<Set>CAPTXNJNL.ROUT_FLG=$ROUT_FLG</Set>
<Set>CAPTXNJNL.CORG_NO=$CORG_NO</Set>
<Set>CORG_NO=@O.RTR_OUT.CORG_NO</Set>
<If condition="IS_EQUAL_STRING($BNK_CD,$CORG_NO)">
<Set>CAPTXNJNL.BNK_FLG=Y</Set>
</If>
<Else>
<Set>CAPTXNJNL.BNK_FLG=N</Set>
</Else>
<If condition="SUBSTR(@O.MSG_CD,4,5)!=00000">
<Set>Rsp_Cd=80</Set>
<Set>Rsp_Msg=计算动态路由失败</Set>
<Exec func="PUB:RollbackWork"/>
<Return/>
</If>
<!--路由查找失败-->
<If condition="IS_EQUAL_STRING(SUBSTR(@O.MSG_CD,4,5),99999)">
<Set>Rsp_Cd=99</Set>
<Set>Rsp_Msg=路由查找失败</Set>
<Exec func="PUB:RollbackWork"/>
<Return/>
</If>
<ElseIf condition="IS_EQUAL_STRING(SUBSTR(@O.MSG_CD,4,5),88888)">
<Set>Rsp_Cd=88</Set>
<Set>Rsp_Msg=交易路由查找失败</Set>
<Exec func="PUB:RollbackWork"/>
<Return/>
</ElseIf>
<Else>
<Set>CORG_NO=@O.RTR_OUT.CORG_NO</Set>
<Set>Rsp_Cd=00</Set>
</Else>
<Set>TXN_AMT2=AMTPOWER($TXN_AMT,2)</Set>
<!--查询支付地账户-->
<Exec func="PUB:ReadRecord" error="IGNORE">
<Arg name="SqlCmd" value="QRY_CAPACCOUNTINF"/>
<Arg name="GrpNam" value="CAPTXNJNL"/>
</Exec>
<If condition="~RetCod!=0">
<Set>Rsp_Cd=31</Set>
<Set>Rsp_Msg=支付地信息有误</Set>
<Exec func="PUB:RollbackWork"/>
<Return/>
</If>
<Set>ACT_FLG=$ACT_FLG</Set>
<Set>ACT_FLG=PL</Set>
<Quote name="GET_JRN_NO"/> <!--取交易流水号-->
<Quote name="GET_CAP_ORD_NO"/>
<Set>CAPTXNJNL.JRN_NO=$JRN_NO</Set>
<Set>CAPTXNJNL.CAP_ORD_NO=$CAP_ORD_NO</Set>
<!--计算商户手续费-->
<Set>CAPTXNJNL.MERC_FEE_AMT=0</Set> <!-- 手续费 -->
<Set>CAPTXNJNL.AC_DT=$AC_DT</Set>
<Set>TXN_AMT2=AMTPOWER($CAPTXNJNL.TXN_AMT,2)</Set>
<!--客户批量限额判断-->
<Call package="CEL" function="MERC_AMT_QTM_VERIFY">
<Input>TXN_AMT2|TIM_RAG|</Input>
<Output>MSG_CD|TXN_STS|RSP_CD|RSP_MSG|</Output>
</Call>
<If condition="SUBSTR(@O.MSG_CD,4,5)!=00000">
<Set>CAPTXNJNL.TXN_STS=@O.TXN_STS</Set>
<Set>CAPTXNJNL.RSP_CD=@O.RSP_CD</Set>
<Set>CAPTXNJNL.RSP_MSG=@O.RSP_MSG</Set>
<Set>CAPTXNJNL.RSP_MSG=@O.RSP_MSG</Set>
<Set>CAPTXNJNL.DSK_NAM_STS=4</Set>
</If>
<Else>
<Set>TIM_RAG.DAY_AMT=ADD($TIM_RAG.DAY_AMT,$TXN_AMT2)</Set><!--当月交易金额累加-->
<Set>TIM_RAG.MTH_AMT=ADD($TIM_RAG.MTH_AMT,$TXN_AMT2)</Set><!--当月交易金额累加-->
<Set>TIM_RAG.YAR_AMT=ADD($TIM_RAG.YAR_AMT,$TXN_AMT2)</Set><!--当月交易金额累加-->
</Else>
</Else>
<!--预记代收流水-->
<Exec func="PUB:InsertRecord" error="IGNORE">
<Arg name="TblNam" value="CAPTXNJNL"/>
cap/etc/batch/BAT_GET_DISK_RESULT_CTL.XML
+3 -5
View File
@@ -9,14 +9,14 @@
select dsk_nam from (select A.dsk_nam,B.rank from CAPDSKINF A,CAPCUSINF B
where A.dsk_nam in (select dsk_nam from
(select dsk_nam,sum(unfinished_num) unfinished_num,sum(finish_num) finish_num
from (select dsk_nam,(case when BAT_STS!= '4' then 1 else 0 end)
unfinished_num ,(case when BAT_STS= '4' then 1 else 0 end) finish_num
from (select dsk_nam,(case when BAT_STS not in ('4','0') then 1 else 0 end)
unfinished_num ,(case when BAT_STS in ('4','2') then 1 else 0 end) finish_num
from CAPBATINF b where b.dsk_nam in
(select DSK_NAM from CAPDSKINF a where a.dsk_sts = '1' and ORD_DT &gt;= ? )) group by dsk_nam) c
where c.unfinished_num = 0 and c.finish_num &gt; 0)
AND A.Customer_Id = B.Customer_Id
order by rank )
where ROWNUM &lt;= '5'
where ROWNUM &lt;= '5'
</Sentence>
<Fields>DT_BEFER|</Fields>
</DynSentence>
@@ -126,7 +126,6 @@
<Return/>
</ElseIf>
<Exec func="PUB:ReadRecord" error="IGNORE">
<Arg name="SqlCmd" value="QRY_CAPDSKINF_DSK_NAM"/>
</Exec>
@@ -214,7 +213,6 @@
<Set>DSK_STS=4</Set>
<Exec func="PUB:CommitWork"/>
<!--调用HRO送盘接口-->
<Set>DISK_NO=$DSK_NO</Set>
cap/etc/batch/BAT_GET_TIMER_CTL.XML
+6 -4
View File
@@ -16,13 +16,14 @@
AND A.ORD_DT &gt; ?
AND A.CORG_NO =?
AND A.PRO_JRL = '0'
AND (SND_TIME&lt;=?)
AND (A.GET_TIME &lt;=? OR A.GET_TIME IS NULL)
AND A.DSK_NAM = B.DSK_NAM AND B.Customer_Id = C.Customer_Id
order by rank)
where ROWNUM = '1' )
FOR UPDATE skip locked
</Sentence>
<Fields>TOD_DT|CORG_NO|C_GET_TIME|</Fields>
<Fields>TOD_DT|CORG_NO|C_SND_TIME|C_GET_TIME|</Fields>
</DynSentence>
<DynSentence name="UpdPRO_JRL">
<Sentence>
@@ -40,15 +41,16 @@
<Quote name="Init_CAP01"/> <!--交易初始化-->
<!--此处需要增加代付批次发送第三方的处理-->
<Set>SND_TIME_INTERVAL=$SND_TIME_INTERVAL</Set>
<!-- 组合一些关键信息 -->
<Set>END_DT=$CRE_DT</Set>
<Set>END_TM=$CRE_TM</Set>
<Set>TOD_DT=CALCDATE(GETDATE(),-,d,3)</Set>
<!--Set>TOD_DT=GETDATE()</Set-->
<While>
<Set>C_GET_TIME=SUBSTR(CALCTIME(GETDATETIME(MMDDHHMISS),-,m,10),3,8)</Set>
<While>
<Set>C_SND_TIME=SUBSTR(CALCTIME(GETDATETIME(MMDDHHMISS),-,m,$SND_TIME_INTERVAL),3,8)</Set>
<Set>C_GET_TIME=SUBSTR(CALCTIME(GETDATETIME(MMDDHHMISS),-,m,5),3,8)</Set>
<Exec func="PUB:ReadRecord" error="IGNORE">
<Arg name="SqlCmd" value="QryBatLst"/>
</Exec>
cap/etc/batch/BAT_QRYRFD_TIMER_CTL.XML
+2 -5
View File
@@ -6,11 +6,8 @@
</Attributes>
<DynSentence name="QryTAccNo"> <!--查询付款方账户-->
<Sentence>
select br_no brNo,acct_no acctNo,'B' ACCT_TYPE from CAPACCOUNTINF
where bank_code='CMB' and enabled='Y' and acct_no='755936020410802'
union all
select br_no brNo,acct_no acctNo, 'N' ACCT_TYPE from CAPACCOUNTINF
where bank_code='CMB' and enabled='Y' and acct_no='755936020410802'
select br_no brNo,acct_no acctNo,ACCT_TYPE from CAPACCOUNTINF
where bank_code='CMB' and enabled='Y'
</Sentence>
<Fields>|</Fields>
</DynSentence>
cap/etc/batch/DISKRESULLT_PKG.XML
+1 -1
View File
@@ -8,7 +8,7 @@
<Sentence>
SELECT DSK_STS,ORN_CNT TOTAL_COUNT,ORN_AMT TOTAL_AMOUNT,SUC_CNT SUCC_COUNT,SUC_AMT SUCC_AMOUNT,FAL_CNT
FAIL_COUNT,FAL_AMT FAIL_AMOUNT,TITLE_ID,CUSTOMER_ID,ORD_DT FROM CAPDSKINF
WHERE DSK_NO = ?
WHERE DSK_NAM = ?
</Sentence>
<Fields>DSK_NAM|</Fields>
</DynSentence>
cap/etc/batch/ZLL_TEST_CTL.XML
+10 -1
View File
@@ -69,7 +69,16 @@
<Arg name="ObjSvr" value="SCAICBC3"/>
</Exec>
</ElseIf>
<ElseIf condition="IS_EQUAL_STRING($TESTNO,7)">
<Set>TESTNAME=initBatch_CMB</Set>
<Set>DSK_NAM=2021031500002</Set>
<Set>ORD_DT=GETDATE()</Set>
<Set>TXN_MOD=02</Set>
<Set>MERC_ID=769346321368612</Set>
<Set>FIL_TYP=02</Set>
<Set>AC_DT=GETDATE()</Set>
<Set>SERVER=OFRTCAP1</Set>
</ElseIf>
<Exec func="PUB:CallThirdService">
<Arg name="HTxnCd" value="$TESTNAME" />
<Arg name="ObjSvr" value="$SERVER" />
cap/etc/channel/cmb/Batch_CMB.XML
+158 -95
View File
@@ -3,7 +3,7 @@
<!--初始化批次___招商银行 -->
<Transaction code="initBatch_CMB" log_switch='1' desc="生成招行批次">
<Quote name="SQL_RcvConfirm"/>
<DynSentence name="QryBatCnt"><!--查询该批次有多少记录 -->
<DynSentence name="QryBatCnt"><!--查询超网该批次有多少记录 -->
<Sentence>
SELECT COUNT(*) BAT_CNT FROM CAPTXNJNL
WHERE DSK_NAM=? AND ROUT_FLG=? AND TAC_TYP=? AND ORD_DT=? AND CORG_NO=? AND TXN_MOD=? AND
@@ -12,23 +12,47 @@
</Sentence>
<Fields>DSK_NAM|ROUT_FLG|TAC_TYP|ORD_DT|CORG_NO|TXN_MOD|MAX_CNT</Fields>
</DynSentence>
<DynSentence name="QryBatCnt1"><!--查询非超网该批次有多少记录 -->
<Sentence>
SELECT COUNT(*) BAT_CNT FROM CAPTXNJNL
WHERE DSK_NAM=? AND ROUT_FLG IN ('LARGE','SMALL') AND TAC_TYP=? 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|TAC_TYP|ORD_DT|CORG_NO|TXN_MOD|MAX_CNT</Fields>
</DynSentence>
<DynSentence name="QryFourBat"><!--查询未打包的批次（四种维度 代发工资，代发其它，超网代发工资，超网代发其它） -->
<Sentence>
SELECT ROUT_FLG,tac_typ FROM CAPTXNJNL
SELECT ROUTFLAG,tac_typ FROM (
SELECT decode(ROUT_FLG,'SUPER','SUPER','LARGE','NOSUP','SMALL','NOSUP') ROUTFLAG ,tac_typ 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;= ?
group by ROUT_FLG,tac_typ
TXN_STS='U' AND CORG_DSK_NO = '0')
group by ROUTFLAG,tac_typ
</Sentence>
<Fields>DSK_NAM|ORD_DT|CORG_NO|TXN_MOD|MAX_CNT</Fields>
<Fields>DSK_NAM|ORD_DT|CORG_NO|TXN_MOD|</Fields>
</DynSentence>
<DynSentence name="UpdDskNo">
<Sentence>
UPDATE CAPTXNJNL SET CORG_DSK_NO = ?,trx_seq=lpad(rownum,8,0)
WHERE DSK_NAM=? AND ROUT_FLG=? AND ORD_DT=? AND CORG_NO=? AND TXN_MOD=? AND DSK_NAM_STS='0' AND
UPDATE CAPTXNJNL SET CORG_DSK_NO = ?,trx_seq=lpad(rownum,8,0),TXN_CD = ?, TTXN_CD = ?
WHERE DSK_NAM=? AND ROUT_FLG=? AND TAC_TYP=? 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|DSK_NAM|ROUT_FLG|ORD_DT|CORG_NO|TXN_MOD|MAX_CNT</Fields>
<Fields>CORG_DSK_NO|TXN_CD|TTXN_CD|DSK_NAM|ROUT_FLG|TAC_TYP|ORD_DT|CORG_NO|TXN_MOD|MAX_CNT|</Fields>
</DynSentence>
<DynSentence name="UpdDskNo1">
<Sentence>
UPDATE CAPTXNJNL SET CORG_DSK_NO = ?,trx_seq=lpad(rownum,8,0),TXN_CD = ?, TTXN_CD = ?
WHERE DSK_NAM=? AND ROUT_FLG IN ('LARGE','SMALL') AND TAC_TYP=? 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|TXN_CD|TTXN_CD|DSK_NAM|TAC_TYP|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
@@ -36,21 +60,6 @@
</Sentence>
<Fields>DSK_NAM|ORD_DT|CORG_NO|CORG_DSK_NO</Fields>
</DynSentence>
<DynSentence name="InitTxnJnl"> <!--初始化流水信息(第三方交易码，批次号)-->
<Sentence>
UPDATE CAPTXNJNL SET TXN_CD = ?, TTXN_CD = ?
WHERE DSK_NAM=? AND ORD_DT = ? AND CORG_NO=? AND CORG_DSK_NO = ? AND DSK_NAM_STS='0' AND TXN_STS='U'
</Sentence>
<Fields>TXN_CD|TTXN_CD|DSK_NAM|ORD_DT|CORG_NO|CORG_DSK_NO</Fields>
</DynSentence>
<DynSentence name="UpdBatVerSts">
<Sentence>
UPDATE CAPBATINF SET BAT_VER_STS= '1'
WHERE DSK_NAM=? AND ORD_DT = ? AND CORG_NO=? AND CORG_DSK_NO = ?
</Sentence>
<Fields>DSK_NAM|ORD_DT|CORG_NO|CORG_DSK_NO</Fields>
</DynSentence>
<FlowCtrl>
<!--清理数据 -->
@@ -73,10 +82,9 @@
<Arg name="CursorName" value="CURSOR_1"/>
</Exec>
<If condition="~RetCod=-1">
<Exec func="PUB:GWASetMsg">
<Arg name="MsgCd" value="LPS00001"/>
<Arg name="MsgDat" value="数据库操作错误"/>
</Exec>
<Set>Rsp_Cd=80</Set>
<Set>Rsp_Msg=查询数据库失败</Set>
<Return/>
</If>
<While>
<Exec func="PUB:FetchCursor" error="IGNORE"/>
@@ -85,15 +93,49 @@
<Break/>
</If>
<ElseIf condition="~RetCod!=0">
<Set>Rsp_Cd=80</Set>
<Set>Rsp_Msg=循环游标失败</Set>
<Exec func="PUB:RollbackWork"/>
<Set>Rsp_Cd=80</Set>
<Set>Rsp_Msg=查询数据库失败</Set>
<Return/>
</ElseIf>
<Set>ROUT_FLG=$ROUT_FLG</Set>
<Set>ROUT_FLG=$ROUTFLAG</Set>
<Set>TAC_TYP=$TAC_TYP</Set>
<!--初始化流水信息 -->
<Set>TXN_CD=204020</Set>
<!--超网代发工资-->
<If condition="AND(IS_EQUAL_STRING($ROUT_FLG,SUPER),IS_EQUAL_STRING($TAC_TYP,B))">
<Set>TTXN_CD=NTAGCSAI</Set>
<Set>CHECK_TMPE=QryBatCnt</Set>
<Set>UPDATE_TMPE=UpdDskNo</Set>
</If>
<!--超网代发其它-->
<ElseIf condition="AND(IS_EQUAL_STRING($ROUT_FLG,SUPER),IS_EQUAL_STRING($TAC_TYP,N))">
<Set>TTXN_CD=NTAGCAPI</Set>
<Set>CHECK_TMPE=QryBatCnt</Set>
<Set>UPDATE_TMPE=UpdDskNo</Set>
</ElseIf>
<!--代发工资-->
<ElseIf condition="AND(IS_NOEQUAL_STRING($ROUT_FLG,SUPER),IS_EQUAL_STRING($TAC_TYP,B))">
<Set>TTXN_CD=NTAGCSAL</Set>
<Set>CHECK_TMPE=QryBatCnt1</Set>
<Set>UPDATE_TMPE=UpdDskNo1</Set>
</ElseIf>
<!--代发其它-->
<ElseIf condition="AND(IS_NOEQUAL_STRING($ROUT_FLG,SUPER),IS_EQUAL_STRING($TAC_TYP,N))">
<Set>TTXN_CD=NTAGCAPY</Set>
<Set>CHECK_TMPE=QryBatCnt1</Set>
<Set>UPDATE_TMPE=UpdDskNo1</Set>
</ElseIf>
<Else>
<Set>TTXN_CD=</Set>
</Else>
<While>
<Exec func="PUB:ReadRecord" error="IGNORE">
<Arg name="SqlCmd" value="QryBatCnt"/>
<Arg name="SqlCmd" value="$CHECK_TMPE"/>
</Exec>
<If condition="~RetCod=-1">
<Set>Rsp_Cd=80</Set>
@@ -115,7 +157,7 @@
<!--更新批次号-->
<Exec func="PUB:ExecSql" error="IGNORE">
<Arg name="SqlCmd" value="UpdDskNo"/>
<Arg name="SqlCmd" value="$UPDATE_TMPE"/>
</Exec>
<If condition="~RetCod != 0">
<Set>Rsp_Cd=80</Set>
@@ -135,38 +177,8 @@
</If>
<Set>BAT_ORN_AMT=$BAT_SUM</Set>
<Set>BAT_ORN_CNT=$BAT_CNT</Set>
<!--初始化流水信息 -->
<Set>TXN_CD=204020</Set>
<!--超网代发工资-->
<If condition="AND(IS_EQUAL_STRING($ROUT_FLG,SUPER),IS_EQUAL_STRING($TAC_TYP,B))">
<Set>TTXN_CD=NTAGCSAI</Set>
</If>
<!--超网代发其它-->
<ElseIf condition="AND(IS_EQUAL_STRING($ROUT_FLG,SUPER),IS_EQUAL_STRING($TAC_TYP,N))">
<Set>TTXN_CD=NTAGCAPI</Set>
</ElseIf>
<!--代发工资-->
<ElseIf condition="AND(IS_NOEQUAL_STRING($ROUT_FLG,SUPER),IS_EQUAL_STRING($TAC_TYP,B))">
<Set>TTXN_CD=NTAGCSAL</Set>
</ElseIf>
<!--代发其它-->
<ElseIf condition="AND(IS_NOEQUAL_STRING($ROUT_FLG,SUPER),IS_EQUAL_STRING($TAC_TYP,N))">
<Set>TTXN_CD=NTAGCAPY</Set>
</ElseIf>
<Else>
<Set>TTXN_CD=</Set>
</Else>
<Exec func="PUB:ExecSql" error="IGNORE">
<Arg name="SqlCmd" value="InitTxnJnl"/>
</Exec>
<If condition="~RetCod != 0">
<Set>Rsp_Cd=80</Set>
<Set>Rsp_Msg=初始化流水信息失败</Set>
<Exec func="PUB:RollbackWork"/>
<Return/>
</If>
<!--Set>CORG_FIL_NAM=STRCAT(batReq_,$CORG_NO,_,GETDATETIME(YYMMDD),_,$CORG_DSK_NO,.txt)</Set -->
<Set>BAT_VER_STS=1</Set>
<Set>CORG_MERC_ID=CMB</Set> <!--单位编号 -->
@@ -192,15 +204,7 @@
<!--提交事务-->
<Exec func="PUB:CommitWork"/>
<!--<Exec func="PUB:ExecSql" error="IGNORE">
<Arg name="SqlCmd" value="UpdBatVerSts"/>
</Exec>-->
<!--If condition="~RetCod != 0">
<Set>Rsp_Cd=80</Set>
<Set>Rsp_Msg=更新批次帐户验证状态失败</Set>
<Exec func="PUB:RollbackWork"/>
<Return/>
</If-->
</While>
</While>
<Exec func="PUB:CloseCursor"> <!-- 关闭游标 -->
@@ -238,9 +242,9 @@
SELECT TAC_TYP,ROUT_FLG,BR_NO,TAC_NO,substrb(POSTSCRIPT,0,40) POSTSCRIPT
FROM CAPTXNJNL
WHERE DSK_NAM=?
AND CORG_DSK_NO=? and rownum=1
AND CORG_DSK_NO=? and ORD_DT = ? and rownum=1
</Sentence>
<Fields>DSK_NAM|CORG_DSK_NO|</Fields>
<Fields>DSK_NAM|CORG_DSK_NO|ORD_DT|</Fields>
</DynSentence>
<DynSentence name="Qry_Export"> <!--招行代发工资/其它 查询打包记录 -->
<Sentence>
@@ -297,8 +301,7 @@
SET BAT_STS=?,
RSP_CD = ?,
RSP_MSG = ?,
CORG_JRN_NO=?,
snd_time=to_char(sysdate,'yyyy')
CORG_JRN_NO=?
WHERE
ORD_DT=?
AND CORG_NO=?
@@ -315,6 +318,28 @@
</Sentence>
<Fields>ORD_DT|CORG_NO|CORG_DSK_NO|</Fields>
</DynSentence>
<!--更新该批次失败记录 -->
<DynSentence name="UpdJnlStsF">
<Sentence>
UPDATE CAPTXNJNL
SET DSK_NAM_STS='1',
TXN_STS='F',
TTXN_ST='F',
RSP_CD = '80',
RSP_MSG = ?,
WHERE DSK_NAM=?
AND
ORD_DT=?
AND CORG_NO=?
AND CORG_DSK_NO = ?
AND TXN_MOD=?
AND
DSK_NAM_STS='0'
AND TXN_STS='U'
</Sentence>
<Fields>RSP_MSG|DSK_NAM|ORD_DT|CORG_NO|CORG_DSK_NO|TXN_MOD|</Fields>
</DynSentence>
<Function name="_before">
<Process>
<Exec func="PUB:DumpETF"/>
@@ -349,6 +374,8 @@
</Function>
<FlowCtrl>
<!--清理数据 -->
<Delete>TRSP_CD</Delete>
<Delete>TRSP_MSG</Delete>
<Delete>RSP_CD</Delete>
<Delete>RSP_MSG</Delete>
<Delete>SUM</Delete>
@@ -498,16 +525,27 @@
<If condition="IS_NOEQUAL_STRING($RET_CODE,SUC0000)">
<Set>BAT_STS=3</Set>
<Set>Rsp_Cd=$resultcode</Set>
<Set>TRsp_Msg=$resultmsg</Set>
<Set>Rsp_Msg=$resultmsg</Set>
<Set>TRsp_Msg=SUBSTR($resultmsg,1,100)</Set>
<Set>Rsp_Msg=SUBSTR($resultmsg,1,100)</Set>
<Set>TRSP_CD=$resultcode</Set>
<If condition="IS_EQUAL_STRING($RET_CODE,NCB1101)">
<Set>BAT_STS=2</Set>
<!-- 更新流水状态为发送处理完成 -->
<Exec func="PUB:ExecSql" error="IGNORE">
<Arg name="SqlCmd" value="UpdJnlSts"/>
</Exec>
<If condition="~RetCod=-1">
<Set>Rsp_Cd=80</Set>
<Set>Rsp_Msg=更新该批次流水处理状态失败</Set>
</If>
</If>
</If>
<Else>
<!--更新流水状态为发送处理成功-->
<Set>BAT_STS=1</Set>
<Set>Rsp_Cd=80</Set>
<Set>TRsp_Msg=交易成功</Set>
<Set>Rsp_Msg=$resultmsg</Set>
<Set>Rsp_Msg=SUBSTR($resultmsg,1,100)</Set>
<Set>TRSP_CD=$resultcode</Set>
</Else>
<Break/>
@@ -580,16 +618,17 @@
<Sentence>
UPDATE CAPTXNJNL A
SET
(TTXN_ST,TXN_STS,DSK_NAM_STS,TACC_DT,TACC_TM,TRSP_CD,TRSP_MSG,RSP_MSG,CORG_JRN_NO)
(TTXN_ST,TXN_STS,DSK_NAM_STS,TACC_DT,TACC_TM,TRSP_CD,TRSP_MSG,RSP_CD,RSP_MSG,CORG_JRN_NO)
=
( SELECT 'F' TTXN_ST,
'F' TXN_STS,
'4',
?,
?,
' ',
' ',
' ',
?,
?,
?,
?,
' ' CORG_JRN_NO
from dual
)
@@ -598,8 +637,9 @@
AND A.CORG_DSK_NO = ?
AND (A.TTXN_ST = 'U' OR
A.TTXN_ST = 'P')
AND ORD_DT=?
</Sentence>
<Fields>TACC_DT|TACC_TM|OCORG_DSK_NO</Fields>
<Fields>TACC_DT|TACC_TM|TRSP_CD|TRSP_MSG|RSP_CD|RSP_MSG|OCORG_DSK_NO|OORD_DT|</Fields>
</DynSentence>
<DynSentence name="UpdCMBTxnJnl"> <!--更新批扣流水 -->
<Sentence>
@@ -625,8 +665,9 @@
AND A.CORG_DSK_NO = ?
AND (A.TTXN_ST = 'U' OR
A.TTXN_ST = 'P')
AND ORD_DT=?
</Sentence>
<Fields>TACC_DT|TACC_TM|OCORG_DSK_NO</Fields>
<Fields>TACC_DT|TACC_TM|OCORG_DSK_NO|OORD_DT|</Fields>
</DynSentence>
<DynSentence name="UpdDskInf">
<Sentence>
@@ -740,8 +781,13 @@
</Function>
<FlowCtrl>
<!--清理数据 -->
<Delete>RSPCOD</Delete>
<Delete>RESULTCODE</Delete>
<Delete>REQSTA</Delete>
<Delete>RSP_CD</Delete>
<Delete>RSP_MSG</Delete>
<Delete>TRSP_CD</Delete>
<Delete>TRSP_MSG</Delete>
<Delete>SUM</Delete>
<!--导入临时表数据之前删除临时表数据 -->
<Exec func="PUB:ExecSql" error="IGNORE">
@@ -819,6 +865,7 @@
<Exec func="PUB:RollbackWork"/>
<Return/>
</If>
<Set>rspcod=$rspcod</Set>
<If condition="IS_EQUAL_STRING($rspcod,A6A0587)">
<!--账户透支 发送预警-->
<Set>EVENT.DRW_AC_BAL=0.01</Set>
@@ -833,7 +880,21 @@
</Exec>
</If>
<!--概要查询通讯成功且第三方没有返回流程实例号则该笔批次没有进入第三方系统，判断整批失败-->
<If condition="AND(IS_EQUAL_STRING($resultcode,SUC0000),ISNULL($reqsta))">
<If condition="OR(AND(IS_EQUAL_STRING($resultcode,SUC0000),ISNULL($reqsta)),IS_EQUAL_STRING($rspcod,A6A0587))">
<If condition="IS_EQUAL_STRING($rspcod,A6A0587)">
<Set>Rsp_Cd=80</Set>
<Set>Rsp_Msg=付款账户余额不足</Set>
<Set>TRsp_Cd=$A6A0587</Set>
<Set>TRsp_Msg=账户透支</Set>
</If>
<Else>
<Set>Rsp_Cd=80</Set>
<Set>Rsp_Msg=银行整批处理失败</Set>
<Set>TRsp_Cd= </Set>
<Set>TRsp_Msg= </Set>
</Else>
<!--更新流水-->
<Exec func="PUB:ExecSql" error="IGNORE">
<Arg name="SqlCmd" value="UpdCMBTxnJnlFail"/>
@@ -845,8 +906,6 @@
</If>
<!--接收标志 U:预计 0:已确认，待发送 1:发送处理完成 2:发送处理失败 3:接收处理中 4:接收处理完成 5:接收处理失败 9:有待处理记录-->
<Set>BAT_STS=4</Set>
<Set>Rsp_Cd=00</Set>
<Set>Rsp_Msg=交易处理中...</Set>
<Set>BAT_SUC_AMT=0</Set>
<Set>BAT_SUC_CNT=0</Set>
<Set>BAT_FAL_AMT=$BAT_SUM</Set>
@@ -993,7 +1052,7 @@
<!--接收标志 U:预计 0:已确认，待发送 1:发送处理完成 2:发送处理失败 3:接收处理中 4:接收处理完成 5:接收处理失败 9:有待处理记录-->
<Set>BAT_STS=4</Set>
<Set>Rsp_Cd=00</Set>
<Set>Rsp_Msg=交易处理中...</Set>
<Set>Rsp_Msg=交易整批处理失败</Set>
<Set>BAT_SUC_AMT=0</Set>
<Set>BAT_SUC_CNT=0</Set>
<Set>BAT_FAL_AMT=$BAT_SUM</Set>
@@ -1028,12 +1087,15 @@
<Sentence>
update CAPCMBRFD set (MERC_ORD_NO,CAP_ORD_NO,TAC_NO,TAC_NAM,DSK_NAM)=
(select MERC_ORD_NO,CAP_ORD_NO,TAC_NO,TAC_NAM,DSK_NAM from CAPTXNJNL
where trx_seq=? and corg_dsk_no=?)
where trx_seq=? and corg_dsk_no=? and CORG_NO='CMB')
where yur_ref=? and bth_dtl=?
</Sentence>
<Fields>BTH_DTL|yur_ref|yur_ref|BTH_DTL</Fields>
</DynSentence>
<FlowCtrl>
<Delete>TRSP_CD</Delete>
<Delete>TRSP_MSG</Delete>
<Quote name="GET_CUP_BAT_NO"/>
<Set>CORG_DSK_NO=STRCAT(GETDATETIME(),$CORG_DSK_NO)</Set>
<Set>bbknbr=$brNo</Set><!--分行号-->
@@ -1096,7 +1158,7 @@
<Set>RSP_MSG=交易成功</Set>
</FlowCtrl>
</Transaction>
<!--心跳检查 -->
<Transaction code="HEARTBEAT_CMB" log_switch='1' desc="心跳检查">
<FlowCtrl>
@@ -1108,11 +1170,12 @@
<Arg name="HTxnCd" value="DCLISMOD"/>
<Arg name="ObjSvr" value="SCMBPAY1"/>
</Exec>
<If condition="~RetCod !=0">
<Set>RET_CODE=$resultcode</Set>
<If condition="IS_NOEQUAL_STRING($RET_CODE,SUC0000)">
<!--发送预警-->
<Set>EVENT.DRW_AC_BAL=0.01</Set>
<Set>EVENT.UDRW_AC_BAL=0.02</Set>
<Set>EVT_TYP=EVT_ORG_AMT_OFW</Set>
<Set>EVENT.CORG_NO=CMB</Set>
<Set>EVENT.ERR_MSG=招行通道通讯异常</Set>
<Set>EVT_TYP=EVT_CHANNEL_COMMU_FAILURE</Set>
<Exec func="PUB:InvokeService" error="IGNORE">
<Arg name="ServiceName" value="PUSH_EVENT" />
</Exec>
cap/etc/channel/cmb/SCMBPAY1_ATR.XML
+22 -22
View File
@@ -1,29 +1,29 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE Server PUBLIC "-//HISUN//DTD//ATR" "ATR.dtd">
<Server name="SCMBPAY1" type="SCA" trace="DEBUG">
<Declare name="connector" class="com.murong.ctg.protocol.http.client.cmb.CmbHttpConnector">
<Param name="_url" value="${_URL}" />
<Param name="_publicKeyStr" value="${_PUBLICKEYSTR}" />
<Param name="_privateKeyStr" value="${_PRIVATEKEYSTR}" />
<Param name="_aesKey" value="${_AESKEY}" />
</Declare>
<Server name="SCMBPAY1" type="SCA" trace="INFO">
<Declare name="itfengine" class="com.hisun.engine.HiEngine">
<Param name="ITF" value="etc/channel/cmb/SCMBPAY1_ITF.XML" /> <!--接口配置文件 -->
</Declare>
<Declare name="jsonxmlfmtconvert" class="com.hisun.handler.HiJsonXmlConvertHandler">
</Declare>
<Process name="proc1" msgtype="DEFAULT">
<Handler name="itfengine" />
<Handler name="jsonxmlfmtconvert" method="xml2json" />
<Handler name="connector" />
<Handler name="jsonxmlfmtconvert" method="json2xml" />
<Handler name="itfengine" />
</Process>
<Declare name="connector" class="com.murong.ctg.protocol.http.client.cmb.CmbHttpConnector">
<Param name="_url" value="${_URL}" />
<Param name="_publicKeyStr" value="${_PUBLICKEYSTR}" />
<Param name="_privateKeyStr" value="${_PRIVATEKEYSTR}" />
<Param name="_aesKey" value="${_AESKEY}" />
</Declare>
<Declare name="itfengine" class="com.hisun.engine.HiEngine">
<Param name="ITF" value="etc/channel/cmb/SCMBPAY1_ITF.XML" /> <!--接口配置文件 -->
</Declare>
<Declare name="jsonxmlfmtconvert" class="com.hisun.handler.HiJsonXmlConvertHandler">
</Declare>
<Process name="proc1" msgtype="DEFAULT">
<Handler name="itfengine" />
<Handler name="jsonxmlfmtconvert" method="xml2json" />
<Handler name="connector" />
<Handler name="jsonxmlfmtconvert" method="json2xml" />
<Handler name="itfengine" />
</Process>
</Server>
cap/etc/channel/icbc/BATCH_ICBC.XML
+32 -8
View File
@@ -198,7 +198,7 @@
<Set>BAT_ORN_CNT=$BAT_CNT</Set>
<Set>CORG_MERC_ID=$MERC_ID</Set> <!--单位编号 -->
<Set>CORG_MERC_ID=ICBC</Set> <!--单位编号 -->
<Set>Rsp_Cd=STRCAT( , )</Set>
<Set>Rsp_Msg=STRCAT( , )</Set>
@@ -265,6 +265,30 @@
<Fields>DSK_NAM|ORD_DT|CORG_NO|CORG_DSK_NO|TXN_MOD|</Fields>
</DynSentence>
<!--更新该批次失败记录 -->
<DynSentence name="UpdJnlStsF">
<Sentence>
UPDATE CAPTXNJNL
SET DSK_NAM_STS='1',
TXN_STS='F',
TTXN_ST='F',
RSP_CD = '80',
RSP_MSG = ?,
WHERE DSK_NAM=?
AND
ORD_DT=?
AND CORG_NO=?
AND CORG_DSK_NO = ?
AND TXN_MOD=?
AND
DSK_NAM_STS='0'
AND TXN_STS='U'
</Sentence>
<Fields>RSP_MSG|DSK_NAM|ORD_DT|CORG_NO|CORG_DSK_NO|TXN_MOD|</Fields>
</DynSentence>
<!--更新批次状态 -->
<DynSentence name="UpdBatSts">
<Sentence>
@@ -471,13 +495,13 @@
<!--第三方失败-->
<Set>BAT_STS=3</Set>
<Set>RSP_CD=80</Set>
<Set>RSP_MSG=文件发送成功</Set>
<Set>RSP_MSG=批次已发送</Set>
<Break/>
</Case>
<Case value="-1">
<Set>BAT_STS=3</Set>
<Set>RSP_CD=80</Set>
<Set>RSP_MSG=文件发送成功</Set>
<Set>RSP_MSG=批次已发送</Set>
<Break/>
</Case>
<Case value="3">
@@ -486,7 +510,7 @@
<Set>RSP_MSG=$TRSP_MSG</Set>
<!--更新流水状态为处理-->
<Exec func="PUB:ExecSql" error="IGNORE">
<Arg name="SqlCmd" value="UpdJnlSts"/>
<Arg name="SqlCmd" value="UpdJnlStsF"/>
</Exec>
<If condition="~RetCod != 0">
<Set>Rsp_Cd=80</Set>
@@ -499,7 +523,7 @@
<!--更新流水状态为发送处理成功-->
<Set>BAT_STS=1</Set>
<Set>Rsp_Cd=$TRsp_Cd</Set>
<Set>TRsp_Msg=交易成功</Set>
<Set>TRsp_Msg=批次提交成功</Set>
<Set>Rsp_Msg=$TRsp_Msg</Set>
<!-- 更新流水状态为发送处理完成 -->
@@ -514,9 +538,9 @@
</Case>
<Default>
<!--第三方失败-->
<Set>BAT_STS=3</Set> <!--成功-->
<Set>BAT_STS=3</Set>
<Set>RSP_CD=80</Set>
<Set>RSP_MSG=交易发送成功</Set>
<Set>RSP_MSG=批次已发送</Set>
</Default>
</Switch>
<Set>CORG_JRN_NO=$SERIAL_NO</Set>
@@ -914,7 +938,7 @@
</If>
<Set>Rsp_Cd=00</Set>
<Set>Rsp_Msg=交易成功</Set>
<Set>Rsp_Msg=批次处理完成</Set>
<Set>BAT_STS=4</Set> <!-- 接收处理完成 -->
<!--更新批次信息 -->
cap/etc/common/MACRO_BNK_CFG.XML
+1 -1
View File
@@ -2,7 +2,7 @@
<FrontTab>
<Macro name="Batch_Cfg_CMB" desc="招行批量参数">
<Set>PARA.MAX_CNT=5</Set> <!--最大笔数-->
<Set>PARA.MAX_CNT=1000</Set> <!--最大笔数-->
</Macro>
<Macro name="Batch_Cfg_ICBC" desc="工行批量参数">
<Set>GRP_CIS=020090002434552</Set> <!--集团CIS号-->
cap/etc/scheduler/TIMCON_PUB.XML
+27 -21
View File
@@ -1,30 +1,36 @@
<?xml version='1.0' encoding='UTF-8'?>
<Cycles>
<!--轮询发送批次-->
<!--CycleItem istxn='0' objsvr="OFRTCAP1" txncod='BAT_SEND_TIMER' txndatatype='text/etf' txndat='' funcname='' funcpath = '' interval="600" sndflag ='0' tmout="3600" minute='*' hour='*' monthday='*' weekday='*' monthweek='*' month='*' trace='1'>
<Data><ROOT><GWA><SYS_CNL>SYS</SYS_CNL></GWA></ROOT></Data>
</CycleItem-->
<!--轮询取批量回盘-->
<!--CycleItem istxn='0' objsvr="OFRTCAP1" txncod='BAT_GET_TIMER' txndatatype='text/etf' txndat='' funcname='' funcpath = '' interval="600" sndflag ='0' tmout="3600" minute='*' hour='*' monthday='*' weekday='*' monthweek='*' month='*' trace='1'>
<Data><ROOT><GWA><SYS_CNL>SYS</SYS_CNL></GWA></ROOT></Data>
</CycleItem-->
<!--超时轮询批量回盘-->
<!--CycleItem istxn='0' objsvr="OFRTCAP1" txncod='BAT_TIMEOUT_TIMER' txndatatype='text/etf' txndat='' funcname='' funcpath = '' interval="600" sndflag ='0' tmout="3600" minute='*' hour='*' monthday='*' weekday='*' monthweek='*' month='*' trace='1'>
<Data><ROOT><GWA><SYS_CNL>SYS</SYS_CNL></GWA></ROOT></Data>
</CycleItem-->
<!--软路由定时服务-->
<!--CycleItem istxn='0' objsvr="OFRTCAP1" txncod='TIMCHK' txndatatype='text/etf' txndat='' funcname='' funcpath = '' interval="60" sndflag ='0' tmout="3600" minute='*' hour='*' monthday='*' weekday='*' monthweek='*' month='*' trace='1'>
<Data><ROOT><GWA><SYS_CNL>SYS</SYS_CNL></GWA></ROOT></Data>
</CycleItem-->
<!--定时轮训大批回盘-->
<!--CycleItem istxn='0' objsvr="OFRTCAP2" txncod='BAT_GET_DISK_RESULT' txndatatype='text/etf' txndat='' funcname='' funcpath = '' interval="120" sndflag ='0' tmout="3600" minute='/5' hour='*' monthday='*' weekday='*' monthweek='*' month='*' trace='1'>
<CycleItem istxn='0' objsvr="OFRTCAP2" txncod='BAT_GET_DISK_RESULT' txndatatype='text/etf' txndat='' funcname='' funcpath = '' interval="120" sndflag ='0' tmout="3600" minute='/5' hour='*' monthday='*' weekday='*' monthweek='*' month='*' trace='1'>
<Data><ROOT><GWA><SYS_CNL>SYS</SYS_CNL></GWA></ROOT></Data>
</CycleItem-->
</CycleItem>
<!--定时对账-->
<!--CycleItem istxn='0' objsvr="OCAPCHK1" txncod='HRO_CHK' txndatatype='text/etf' txndat='' funcname='' funcpath = '' interval="" sndflag ='0' tmout="3600" minute='30' hour='1' monthday='*' weekday='*' monthweek='*' month='*' trace='1'>
<CycleItem istxn='0' objsvr="OCAPCHK1" txncod='HRO_CHK' txndatatype='text/etf' txndat='' funcname='' funcpath = '' sndflag ='0' tmout="3600" minute='30' hour='1' monthday='*' weekday='*' monthweek='*' month='*' trace='1'>
<Data><ROOT><GWA><SYS_CNL>SYS</SYS_CNL></GWA></ROOT></Data>
</CycleItem-->
</CycleItem>
<!--定时查询退票信息-->
<CycleItem istxn='0' objsvr="OFRTCAP1" txncod='BAT_QRYRFD_TIMER' txndatatype='text/etf' txndat='' funcname='' funcpath = '' sndflag ='0' tmout="3600" minute='30' hour='21' monthday='*' weekday='*' monthweek='*' month='*' trace='1'>
<Data><ROOT><GWA><SYS_CNL>SYS</SYS_CNL></GWA></ROOT></Data>
</CycleItem>
<!--心跳招行-->
<CycleItem istxn='0' objsvr="OFRTCAP1" txncod='HEARTBEAT_CMB' txndatatype='text/etf' txndat='' funcname='' funcpath = '' interval="30" sndflag ='0' tmout="30" minute='*' hour='*' monthday='*' weekday='*' monthweek='*' month='*' trace='1'>
<Data><ROOT><GWA><SYS_CNL>SYS</SYS_CNL></GWA></ROOT></Data>
</CycleItem>
<!--心跳工行-->
<CycleItem istxn='0' objsvr="OFRTCAP1" txncod='HEARTBEAT_ICBC' txndatatype='text/etf' txndat='' funcname='' funcpath = '' interval="30" sndflag ='0' tmout="30" minute='*' hour='*' monthday='*' weekday='*' monthweek='*' month='*' trace='1'>
<Data><ROOT><GWA><SYS_CNL>SYS</SYS_CNL></GWA></ROOT></Data>
</CycleItem>
<!--接入批次长时间未处理完成查询-->
<CycleItem istxn='0' objsvr="OFRTCAP2" txncod='BAT_DSK_TIMEOUT' txndatatype='text/etf' txndat='' funcname='' funcpath = '' interval="600" sndflag ='0' tmout="30" minute='*' hour='*' monthday='*' weekday='*' monthweek='*' month='*' trace='1'>
<Data><ROOT><GWA><SYS_CNL>SYS</SYS_CNL></GWA></ROOT></Data>
</CycleItem>
<!--接出批次长时间未处理完成查询-->
<CycleItem istxn='0' objsvr="OFRTCAP2" txncod='BAT_DSK_CORG_TIMEOUT' txndatatype='text/etf' txndat='' funcname='' funcpath = '' interval="300" sndflag ='0' tmout="30" minute='*' hour='*' monthday='*' weekday='*' monthweek='*' month='*' trace='1'>
<Data><ROOT><GWA><SYS_CNL>SYS</SYS_CNL></GWA></ROOT></Data>
</CycleItem>
</Cycles>