数据归集39006转移服务

数据归集39006转移服务

1.queryFerry

GenericResponse<List> rst= xmlLogDataService.getFerryData();

select tl.bsm as logbsm,tl.xmlbsm,tl.xmlpath,tl.bucketname  from (select bsm,qxdm,fwqbm,logbsm,sfbb  from (select x.bsm,x.qxdm,x.fwqbm,x.logbsm,x.sfbb from t_jx_xml x where x.logbsm>0 and x.dbsj>'2020-12-20' and x.sfbb in ('0','1') order by x.bsm desc ) alias limit 1000) tx ,t_jx_log tl where tl.xmlbsm=tx.bsm and tl.qxdm=tx.qxdm and tl.bsm=tx.logbsm

2.sftp

connect sftp[sftp@192.168.11.155]
Download file success
Change path to /home/sftp
Change directory ferry
Create directory 1630631755596
Change directory 1630631755596

3.update

dao.push.TJxLogDAO.updateBB  : ==>  Preparing: 
update t_jx_log set SFBB = ?, BBINFO = ?, ZYSJ= now() where BSM = ?
2(Integer), 转移成功(String), 4254(Long)
update t_jx_xml t set t.sfbb=? where t.bsm=? and t.logbsm=?
2(Integer), 352(Long), 4254(Long)

t_jx_xml.sfbb---->1代表需要报部，2代表转移成功，3代表转移失败

t_jx_xml.jxzt----->解析状态（0 未解析 1 解析成功 2 解析失败 3 暂不解析 4 校验失败）

t_jx_log.sfbb----->是否报部