From cddd83f139af1786517759277ced8479cbe80d3b Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期三, 19 二月 2020 12:57:09 +0800
Subject: [PATCH] Merge branch 'master' of https://github.com/java110/MicroCommunity
---
JobService/src/main/java/com/java110/job/task/HcFtpToFileSystemJob.java | 31 ++++++++++++++++---------------
1 files changed, 16 insertions(+), 15 deletions(-)
diff --git a/JobService/src/main/java/com/java110/job/task/HcFtpToFileSystemJob.java b/JobService/src/main/java/com/java110/job/task/HcFtpToFileSystemJob.java
index d06efe0..712e956 100644
--- a/JobService/src/main/java/com/java110/job/task/HcFtpToFileSystemJob.java
+++ b/JobService/src/main/java/com/java110/job/task/HcFtpToFileSystemJob.java
@@ -1,7 +1,8 @@
package com.java110.job.task;
-import com.java110.common.util.SpringBeanInvoker;
-import com.java110.job.dao.IHccFtpFileDAO;
+import com.java110.utils.factory.ApplicationContextFactory;
+import com.java110.utils.util.SpringBeanInvoker;
+import com.java110.job.dao.IHcFtpFileDAO;
import com.java110.job.smo.HcFtpToFileSystemQuartz;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
@@ -15,9 +16,8 @@
/**
- * 灏嗛泦鍥㈡枃浠跺悓姝ヨ嚦鏈湴鏀寔鐨勬枃浠剁郴缁�
*
- * @author wuxw7
+ * @author
*
*/
@@ -29,10 +29,9 @@
public static String JOB_DATA_TASK_ID = "ftpToFileSystemTaskID";
public static String JOB_GROUP_NAME = "ftpToFileSystemJobGroup"; // 浠诲姟鐨� 鍒嗙粍鍚嶇О
@Autowired
- private IHccFtpFileDAO prvncFtpFileDAO;
- @Autowired
- private HcFtpToFileSystemQuartz prvncDumpQuartz;
+ private IHcFtpFileDAO iHcFtpFileDAO;
+ private HcFtpToFileSystemQuartz hcFtpToFileSystemQuartz;
protected void executeInternal(JobExecutionContext context) {
try {
@@ -56,8 +55,10 @@
}
String dealClass = ftpItemConfigInfo.get("DEAL_CLASS").toString();
- prvncDumpQuartz = (HcFtpToFileSystemQuartz) SpringBeanInvoker.getBean(dealClass);
- prvncDumpQuartz.startFtpTask(ftpItemConfigInfo);
+
+ hcFtpToFileSystemQuartz = (HcFtpToFileSystemQuartz) ApplicationContextFactory.getBean(dealClass);
+ hcFtpToFileSystemQuartz.startFtpTask(ftpItemConfigInfo);
+
} catch (Throwable ex) {
logger.error("鎵ц浠诲姟澶辫触锛�", ex);
}
@@ -72,7 +73,7 @@
private Map getFtpConfigInfo(long taskId) {
Map info = new HashMap();
info.put("taskId", taskId);
- Map ftpItem = getPrvncFtpFileDAO().queryFtpItemByTaskId(info);
+ Map ftpItem = getiHcFtpFileDAO().queryFtpItemByTaskId(info);
if (logger.isDebugEnabled()) {
logger.debug(
"---銆怭rvncFtpToFileSystemQuartz.getFtpConfigInfo銆戞煡璇㈠埌鐨勯厤缃暟鎹负锛�"
@@ -81,12 +82,12 @@
return ftpItem;
}
- public IHccFtpFileDAO getPrvncFtpFileDAO() {
- if (this.prvncFtpFileDAO == null) {
- this.prvncFtpFileDAO = ((IHccFtpFileDAO) SpringBeanInvoker
- .getBean("provInner.PrvncFtpFileDAO"));
+ public IHcFtpFileDAO getiHcFtpFileDAO() {
+ if (this.iHcFtpFileDAO == null) {
+ this.iHcFtpFileDAO = ((IHcFtpFileDAO) SpringBeanInvoker
+ .getBean("provInner.iHcFtpFileDAO"));
}
- return prvncFtpFileDAO;
+ return iHcFtpFileDAO;
}
@Override
--
Gitblit v1.8.0