IHcFtpFileDAO.java
2.97 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
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);
}