| | |
| | | package com.java110.job.task; |
| | | |
| | | import com.java110.common.util.SpringBeanInvoker; |
| | | 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; |
| | |
| | | |
| | | |
| | | /** |
| | | * 将集团文件同步至本地支持的文件系统 |
| | | * |
| | | * @author wuxw7 |
| | | * @author |
| | | * |
| | | */ |
| | | |
| | |
| | | public static String JOB_GROUP_NAME = "ftpToFileSystemJobGroup"; // 任务的 分组名称 |
| | | @Autowired |
| | | private IHcFtpFileDAO iHcFtpFileDAO; |
| | | @Autowired |
| | | private HcFtpToFileSystemQuartz hcFtpToFileSystemQuartz; |
| | | |
| | | private HcFtpToFileSystemQuartz hcFtpToFileSystemQuartz; |
| | | protected void executeInternal(JobExecutionContext context) { |
| | | try { |
| | | |
| | |
| | | } |
| | | |
| | | String dealClass = ftpItemConfigInfo.get("DEAL_CLASS").toString(); |
| | | hcFtpToFileSystemQuartz = (HcFtpToFileSystemQuartz) SpringBeanInvoker.getBean(dealClass); |
| | | |
| | | hcFtpToFileSystemQuartz = (HcFtpToFileSystemQuartz) ApplicationContextFactory.getBean(dealClass); |
| | | hcFtpToFileSystemQuartz.startFtpTask(ftpItemConfigInfo); |
| | | |
| | | } catch (Throwable ex) { |
| | | logger.error("执行任务失败:", ex); |
| | | } |