修复:连接ftp过多;。

src/main/java/com/hywa/banktest/bankframework/schedule/TransSchedule.java

@@ -23,7 +23,6 @@ import com.hywa.banktest.bankframework.utils.FtpUtil;
 import com.hywa.banktest.bankframework.utils.TransUtils;
 import com.hywa.banktest.model.OrderInfo;
 import com.jfinal.kit.JsonKit;
-import com.jfinal.plugin.activerecord.Db;
 import org.springframework.transaction.annotation.Transactional;
 
 @Slf4j
@@ -138,6 +137,34 @@ public class TransSchedule {
 		}
 	}
 
+	@Scheduled(cron = "0 0/5 * * * ?")
+	public void checkClearFile(){
+		log.info("--->开始调度文件了啊");
+		String checkTime = DateUtils.formatDate(new Date(),DateUtils.DEFAULT_FORMAT);
+		//得到转账中oderInfo的转账文件
+		List<String> transFiles = clearingRecordService.getBankClearingFilesByTimed(checkTime);
+		log.info("------>有没有文件"+ JSONObject.toJSONString(transFiles));
+
+		List<String> resFiles = new ArrayList<>();
+		if(null!=transFiles && transFiles.size()>0){
+			for (String transFile : transFiles) {
+				//回盘文件名称
+				String transRetFile = transFile.replaceFirst("qut", "res");
+				resFiles.add(transRetFile);
+			}
+		}
+		//邮储已经回盘文件下载到本地
+		List<String> localNewFiles = ftpUtil.localNewFiles(ftpDownloadDir, resFiles, baseDir + File.separator);
+
+		//执行回盘业务处理
+		if (localNewFiles != null && localNewFiles.size() > 0) {
+			for (String newFile : localNewFiles){
+				List<TransVo> trans = TransUtils.fileToTransVo(baseDir, newFile);
+				bankService.updateOrderInfoPaymentRec(trans,newFile,newFile.replaceFirst("res", "qut"));
+			}
+		}
+	}
+
 	public String getClearText(String fileName){
 		if (StringUtil.isEmpty(fileName)){
 			return null;

src/main/java/com/hywa/banktest/bankframework/utils/FtpUtil.java

@@ -7,6 +7,9 @@ import java.io.IOException;
 import java.io.InputStream;
 import java.io.OutputStream;
 import java.net.MalformedURLException;
+import java.util.ArrayList;
+import java.util.List;
+
 import org.apache.commons.net.ftp.FTPClient;
 import org.apache.commons.net.ftp.FTPFile;
 import org.apache.commons.net.ftp.FTPReply;
@@ -43,6 +46,7 @@ public class FtpUtil {
 			e.printStackTrace();
 		} catch (IOException e) {
 			e.printStackTrace();
+			throw new RuntimeException("登陆ftp服务器失败");
 		}
 		return null;
 	}
@@ -207,4 +211,60 @@ public class FtpUtil {
 			closeFtpClient(ftpClient);
 		}
 	}
+
+	/**
+	 * * 下载新文件
+	 * @param ftpDir FTP服务器文件目录
+	 * @param ftpFileNames 文件名称
+	 * @param localpath 下载后的文件路径
+	 * @return
+	 */
+	public List<String> localNewFiles(String ftpDir, List<String> ftpFileNames, String localpath) {
+		List<String> localNewFiles = new ArrayList<>();
+		OutputStream os = null;
+		//检查文件是否存在
+		if (ftpFileNames != null && ftpFileNames.size() > 0){
+			FTPClient ftpClient = getFtpClient();
+			try {
+				ftpClient.changeWorkingDirectory(ftpDir);
+				int replyCode = ftpClient.getReplyCode();
+				if (!FTPReply.isPositiveCompletion(replyCode)) {
+					throw new RuntimeException("ftp服务目录不存在");
+				}
+			} catch (Exception e) {
+				e.printStackTrace();
+				return localNewFiles;
+			}
+
+			for (String ftpFileName:ftpFileNames) {
+				try {
+					FTPFile[] ftpFileArr = ftpClient.listFiles(ftpFileName);
+					//文件存在下载到本地
+					if (null == ftpFileArr || ftpFileArr.length > 0) {
+						File localFile = new File(localpath + ftpFileName);
+						FileKit.createFile(localpath + ftpFileName);
+						os = new FileOutputStream(localFile);
+						ftpClient.retrieveFile(ftpFileArr[0].getName(), os);
+						os.close();
+						if(!localNewFiles.contains(ftpFileName)){
+							localNewFiles.add(ftpFileName);
+						}
+					}
+				} catch (Exception e2) {
+					e2.printStackTrace();
+				}finally {
+					if (null != os) {
+						try {
+							os.close();
+						} catch (IOException e) {
+							e.printStackTrace();
+						}
+					}
+				}
+			}
+			closeFtpClient(ftpClient);
+		}
+
+		return localNewFiles;
+	}
 }