MicroCommunity/JobService/src/main/java/com/java110/job/dao/IHcFtpFileDAO.java

package com.java110.job.dao;

import com.java110.job.model.*;

import java.util.List;
import java.util.Map;

public interface IHcFtpFileDAO {


	/**
	 * 保存执行任务的日志，任务的执行状态
	 * @param
	 * @return Map
	 */
	public long saveTaskRunLog(FtpTaskLog loginfo);
	/**
	 * 更新执行任务的日志
	 * @param
	 * @return Map
	 */
	public void updateTaskRunLog(FtpTaskLog loginfo);
	/**
	 * 保存执行任务的详细日志，包含任务的传输信息，如果下载线程信息，线程是否执行完成，下载的起始，需要下载的数据大小
	 * @param
	 * @return Map
	 */
	public int saveTaskRunDetailLog(FtpTaskLogDetail logdetail);

	/**
	 * 执行存过，处理任务执行前后的事情
	 */
	public void saveDbFunction(String function);

	/**
	 * 执行存过(带参数)，处理任务执行前后的事情
	 */
	public void saveDbFunctionWithParam(Map info);

	/**
	 * 执行配置的sql
	 * @param dbsql
	 * @return 000777
	 */
	public List execConfigSql(String dbsql);

	/**
	 * 查询文件下载在文件系统的配置任务列表
	 * @param info
	 * @return   001
	 */
	public Map queryFtpItems(Map info);
	
	
	/**
	 * 保存文件下载配置
	 * @param info
	 * @return  0022
	 */
	public int addFtpItem(Map info);
	
	
	/**
	 * 根据TaskId 查询ftp配置信息
	 * @param info
	 * @return 0004
	 */
	public Map queryFtpItemByTaskId(Map info);
	
	/**
	 * 根据任务名称搜素
	 * @param info
	 * @return 000666
	 */
	public List<Map> searchFtpItemByTaskName(Map info);
	
	
	/**
	 * 修改ftp配置信息
	 * @param info
	 * @return  003
	 */
	public int updateFtpItemByTaskId(Map info);
	
	/**
	 * 删除ftp配置信息
	 * @param info
	 * @return 0006
	 */
	public int deleteFtpItemByTaskId(Map info);
	
	
	/**
	 * 根据taskids 获取将要操作的ftp配置信息 
	 * @param info
	 * @return   002
	 */
	public List<Map> queryFtpItemsByTaskIds(Map info);
	
	/**
	 * 查询FTPItem的属性信息
	 * @param info
	 * @return 0007
	 */
	public List<Map> queryFtpItemAttrsByTaskId(Map info);
	
	/**
	 * 创建taskId
	 * @return   000011
	 */
	public long newCreateTaskId();
	
	/**
	 * 保存FTPItem的属性信息
	 * @return  00333
	 */
	public int addFtpItemAttrs(List<Map> infos);
	
	/**
	 * 查询没有下载过的文件名
	 * @param info
	 * @return  0005
	 */
	public List<Map> queryFileNamesWithOutFtpLog(Map info);


	/**
	 * 查询ItemSpec
	 * @param info
	 * @return 0009
	 */
	public List<Map> queryItemSpec(Map info);
	
	/**
	 * 删除属性
	 * @param info
	 * @return 00044
	 */
	public int deleteFtpItemAttrsbyTaskId(Map info);


	public List queryTableColInfo(String tablename,String colnames);

	/**
	 * 修改ftp配置信息(状态)
	 * @param info
	 * @return
	 */
	public int updateFtpItemRunState(Map info);

	/**
	 * 保存下载文件名称
	 * @param info
	 * @return
	 */
	public int addDownloadFileName(Map info);

	/**
	 * 保存FTP下载的一行数据到表中
	 * @param
	 * @return Map
	 */
	public void insertFileData2Table(String insertSQL);


}