From 37575a4531124ac9c3413f4ed58b60b588d1e908 Mon Sep 17 00:00:00 2001
From: shiyj <1098226878@qq.com>
Date: 星期一, 09 九月 2019 15:44:54 +0800
Subject: [PATCH] JOB测试 功能以完成 使用业务模板时有问题 调试中
---
JobService/src/main/java/com/java110/job/util/FTPClientTemplate.java | 20 +++++++++-----------
1 files changed, 9 insertions(+), 11 deletions(-)
diff --git a/JobService/src/main/java/com/java110/job/util/FTPClientTemplate.java b/JobService/src/main/java/com/java110/job/util/FTPClientTemplate.java
index fb39233..59c8ad7 100644
--- a/JobService/src/main/java/com/java110/job/util/FTPClientTemplate.java
+++ b/JobService/src/main/java/com/java110/job/util/FTPClientTemplate.java
@@ -1,6 +1,5 @@
package com.java110.job.util;
-import com.java110.common.util.SpringBeanInvoker;
import com.java110.job.dao.IHcFtpFileDAO;
import com.java110.job.model.FtpTaskLogDetail;
import com.java110.job.smo.IHcFtpFileSMO;
@@ -10,8 +9,8 @@
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
import org.apache.log4j.Logger;
-import org.springframework.beans.factory.annotation.Autowired;
+import javax.annotation.Resource;
import java.io.*;
import java.net.SocketException;
import java.util.*;
@@ -47,10 +46,10 @@
private String localfilename; //鏈湴淇濆瓨鐨勬枃浠跺悕
private String transferflag; //浼犺緭绫诲瀷
private Map threadpara; //绾跨▼鎵ц鍙傛暟
- @Autowired
- private IHcFtpFileDAO iHcFtpFileDAO;
- @Autowired
- private IHcFtpFileSMO iHcFtpFileSMO;
+ @Resource(name = "hcFtpFileDAOImpl")
+ private IHcFtpFileDAO hcFtpFileDAOImpl;
+ @Resource(name = "hcFtpFileSMOImpl")
+ private IHcFtpFileSMO hcFtpFileSMOImpl;
public static String SPECIAL_SINGLESPLIT_a="+*|"; //瀛楃涓插垎闅旂鐗规畩瀛楃闇�瑕佺敤鍔�"\\"鏉ヨ浆璇�
//浼犺緭绫诲瀷锛堚�淯"鏄笂浼� upload 鈥滵鈥滄槸涓嬭浇 download锛�
public static class TransferType{
@@ -104,8 +103,7 @@
init();
}
private void init(){
- this.iHcFtpFileDAO = ((IHcFtpFileDAO) SpringBeanInvoker.getBean("provInner.iHcFtpFileDAO"));
- this.iHcFtpFileSMO=((IHcFtpFileSMO) SpringBeanInvoker.getBean("provInner.iHcFtpFileSMO"));
+
}
public Map call() throws Exception {
Map result=null;
@@ -500,7 +498,7 @@
tablename=tablename.trim();
tablename=tablename.substring(tablename.lastIndexOf(" "), tablename.length());
//鏌ュ瓧娈电殑鏁版嵁绫诲瀷
- List<Map> collist=iHcFtpFileDAO.queryTableColInfo(tablename.trim(), colnames.trim());
+ List<Map> collist=hcFtpFileDAOImpl.queryTableColInfo(tablename.trim(), colnames.trim());
RandomAccessFile raf = new RandomAccessFile(localfilename, "r");
long filelen=raf.length();
if (filelen != 0L) {
@@ -569,7 +567,7 @@
logdetail.setRemark((String)threadpara.get("remark"));
logdetail.setServerfilename((String)threadpara.get("serverfilename"));
logdetail.setLocalfilename((String)threadpara.get("localfilename"));
- iHcFtpFileSMO.saveTaskRunDetailLog(logdetail);
+ hcFtpFileSMOImpl.saveTaskRunDetailLog(logdetail);
}
public void saveStringToData(String data, String insertsql, String colnames, List<Map> collist){
//鎷兼帴鏁版嵁淇濆瓨鐨凷QL璇彞锛屾棩鏈熷瀷鐨勫�艰鏍煎紡鍖栦笅
@@ -588,7 +586,7 @@
}
insertsql=getInsertTableSQL(colnames,collist,datarows,insertsql);
//鎵цSQL璇彞锛屼繚瀛樻暟鎹�
- iHcFtpFileSMO.insertFileData2Table(insertsql);
+ hcFtpFileSMOImpl.insertFileData2Table(insertsql);
}
/**
* 鎷兼帴鏁版嵁淇濆瓨鐨凷QL璇彞锛屾棩鏈熷瀷鐨勫�艰鏍煎紡鍖栦笅
--
Gitblit v1.8.0