| | |
|---|
| | | package com.java110.job.smo; |
|---|
| | | import com.java110.common.constant.RuleDomain; |
|---|
| | | import com.java110.common.util.DateUtil; |
|---|
| | | import com.java110.common.util.StringUtil; |
|---|
| | | import com.java110.utils.constant.RuleDomain; |
|---|
| | | import com.java110.utils.util.DateUtil; |
|---|
| | | import com.java110.utils.util.StringUtil; |
|---|
| | | import com.java110.job.dao.IHcFtpFileDAO; |
|---|
| | | |
|---|
| | | import com.java110.job.model.FtpTaskLog; |
|---|
| | |
|---|
| | | import java.util.*; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * Ftp定时任务执行类，所有的任务都在这里执行，主要为了ftp文件保存到文件系统，业务逻辑单独处理 |
|---|
| | | * |
|---|
| | | * 特别注意，事前过程调用是没有传递参数的，事后过程调用是需要传递一个param的参数，需要在子类process方法中写入，如果不需要传也要传个""过来， |
|---|
| | | * 相应过程需要两个参数，一个是入参一个是出参 |
|---|
| | | * |
|---|
| | | * @author wuxw7 add by 2016-01-03 |
|---|
| | | * @author |
|---|
| | | * |
|---|
| | | */ |
|---|
| | | public abstract class HcFtpToFileSystemQuartz { |
|---|
| | | public abstract class HcFtpToFileSystemQuartz{ |
|---|
| | | |
|---|
| | | protected static final Logger logger = LoggerFactory.getLogger(HcFtpToFileSystemQuartz.class); |
|---|
| | | @Autowired |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 保存任务执行主要日志信息 |
|---|
| | | //获取LOGID 默认生成规则为tadkid去掉年月日之前的值+66 |
|---|
| | | String id = ftpItemConfigInfo.get("TASKID").toString(); |
|---|
| | | id = id.substring(10,id.length()); |
|---|
| | | long logid = Long.parseLong (id+"22"); |
|---|
| | | ftpItemConfigInfo.put("logid",logid); |
|---|
| | | long taskLogID = insertTaskInfo(ftpItemConfigInfo); |
|---|
| | | |
|---|
| | | ftpItemConfigInfo.put("logid", taskLogID); |
|---|
| | |
|---|
| | | */ |
|---|
| | | protected void saveTaskLogDetail(Map taskInfo) { |
|---|
| | | FtpTaskLogDetail logdetail = new FtpTaskLogDetail(); |
|---|
| | | logdetail.setId(Long.valueOf(taskInfo.get("logid").toString()+"66")); |
|---|
| | | logdetail.setLogid(Long.valueOf(taskInfo.get("logid").toString())); |
|---|
| | | logdetail.setTaskid(Long.valueOf(taskInfo.get("taskid").toString())); |
|---|
| | | logdetail.setState((String) taskInfo.get("threadrunstate")); |
|---|
