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(
               "---【PrvncFtpToFileSystemQuartz.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