| | |
| | | private Logger logger = null; |
| | | public int battgroupid=0; |
| | | public FGCD_TestFBOFile fbofile=null; |
| | | public int file_downloadNum=0; |
| | | |
| | | |
| | | public FGCD_Export_Thread_SQL(MysqlConnPool m_ConnPool, FBOFile file,FGCD_TestFBOFile fbofile) { |
| | | public FGCD_Export_Thread_SQL(MysqlConnPool m_ConnPool, FBOFile file,FGCD_TestFBOFile fbofile,int file_downloadNum) { |
| | | super(); |
| | | this.m_ConnPool = m_ConnPool; |
| | | this.file = file; |
| | | //this.battgroupid=battgroupid; |
| | | this.fbofile=fbofile; |
| | | this.file_downloadNum=file_downloadNum; |
| | | this.logger = LogManager.getLogger(this); |
| | | } |
| | | |
| | |
| | | * @param file |
| | | * @param pool |
| | | */ |
| | | private boolean readFBOFileData(FBOFile file,MysqlConnPool pool) { |
| | | boolean flag = false; |
| | | private void readFBOFileData(FBOFile file,MysqlConnPool pool) { |
| | | File f = new File(file.filename); |
| | | System.err.println(f.getName()+" "+f.length()); |
| | | if(file.test_timelong > 0) { |
| | | flag=FboData.checkFboFileByOneSql(m_ConnPool,f,fbofile); |
| | | FboData.checkFboFileByOneSql(m_ConnPool,f,fbofile,file_downloadNum); |
| | | } |
| | | if(f.exists()) { |
| | | //删除下载的FBO文件 |
| | | f.delete(); |
| | | } |
| | | return flag; |
| | | } |
| | | |
| | | |