数据上报39127服务


报文上报39127supervise-transfer-bwsb

1.数据包转移服务

1.1先遍历xml数据包文件

1.2校验数据包头部信息

1.3创建数据包、数据包存储地址为YWXML\success\~

1.4 开始转移数据包,路径为存储地址+xml数据包文件名

1.4sftp创建存xml数据包的文件目录

1.5数据包转移成功

1.6本地的xml数据包删除

1.7transfer.dao.TBwsbXmlDAO.queryXmlLogBsm

select BSM, YWH, QLBSM, QXDM, FWQBM, BDCDYH, JRYWBH, LRSJ, SFFF, LOGBSM, SLQXDM from t_bwsb_xml where ywh = ? and jrywbh = ? and bdcdyh = ? and qlbsm = ? and qxdm = ? and fwqbm = ? and exists (select 1 from t_bwsb_log where bsm=logbsm)
20210514-0004427(String), 2000402(String), 330183006001GB00968F00040001(String), 131008063(String), 330183(String), 1(Integer)

1.8transfer.dao.TBwsbXmlDAO.getSequenceBsm

select NEXTVAL("seq_bsm") from dual
select NEXTVAL("seq_bsm") from dual

1.9transfer.dao.TBwsbXmlDAO.insert

insert into t_bwsb_xml (BSM, YWH, QLBSM, QXDM, FWQBM, BDCDYH, JRYWBH, LRSJ, SFFF, LOGBSM,SLQXDM) values (?, ?, ?, ?, ?, ?, ?, now(), ?, ?,? )
526(Long), 20210514-0004427(String), 131008063(String), 330183(String), 1(Integer), 330183006001GB00968F00040001(String), 2000402(String), 1(String), 527(Long), 330183(String)

1.10transfer.dao.TBwsbLogDAO.insert

insert into t_bwsb_log (BSM, XMLBSM, XMLPATH, LOGINFO, LOGTYPE, SBZT, FFSJ, SBSJ, FFCS, SBCS, DBSJ, BFSJ,JXLOGBSM ) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, now(), ? )
527(Long), 526(Long), YWXML\success\330183\1\2021\05\14\2000402\20210514-0004427\330183006001GB00968F00040001\0\QXDM-330183-JRYWBH-2000402-YWH-20210514-0004427-BDCDYH-330183006001GB00968F00040001-FWQBM-1-FSCS-0.xml(String), null, null, 1(String), null, null, null, null, 2021-05-14 16:03:41.0(Timestamp), 4254(Long)

1.11查询转移后表的结果

select * from bdcdjjg1.t_bwsb_log;
select * from bdcdjjg1.t_bwsb_xml;

2.数据包报部服务

2.1transfer.dao.TBwsbXmlDAO.queryReport

select a.bdcdyh,b.* from t_bwsb_xml a,t_bwsb_log b where a.logbsm = b.bsm and b.sbzt=1 limit 1000

2.2transfer.dao.TBwsbLogDAO.updateSbzt

update t_bwsb_log set SBZT = ?, FFSJ=current_timestamp where bsm = ?
2(String), 527(Long)

2.3开始报部

2.4connect sftp

Download file success. TargetPath: YWXML/success/~

2.5transfer.dao.TBwsbXmlDAO.queryXmlLogBsm

select BSM, YWH, QLBSM, QXDM, FWQBM, BDCDYH, JRYWBH, LRSJ, SFFF, LOGBSM, SLQXDM from t_bwsb_xml where ywh = ? and jrywbh = ? and bdcdyh = ? and qlbsm = ? and qxdm = ? and fwqbm = ? and exists (select 1 from t_bwsb_log where bsm=logbsm)
20210514-0004427(String), 2000402(String), 330183006001GB00968F00040001(String), 131008063(String), 330183(String), 1(Integer)

2.6transfer.dao.TBwsbLogDAO.queryReportName

select REPORTNAME from t_bwsb_log where bsm = ?
527(Long)

2.7app.impl.ReportGenerationServiceImpl

报文数字签名成功,报文文件路径:D:\supervise-jghj\Biz\Biz330183210903000021.xml

2.8SFTP Session connected.

上传sftp文件耗时:60869,上报SFTP路径:/home/sftp/biz/330000/BizMsg,本地报文路径:D:\supervise-jghj\Biz\Biz330183210903000021.xml

2.9report.transfer.dao.TBwsbLogDAO.updateSbzt

update t_bwsb_log set SBZT = ?, LOGINFO = ?, SBSJ=current_timestamp, reportname= ? where bsm = ?
4(String), 上报成功(String), Biz330183210903000021(String), 527(Long)

文章作者: fejxc
版权声明: 本博客所有文章除特別声明外,均采用 CC BY 4.0 许可协议。转载请注明来源 fejxc !
评论
  目录