MaliciousIpCtrl.java
8.83 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
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
package com.ui.ctrl;
import com.alibaba.fastjson.JSON;
import com.ui.common.IpRuleConcatEnum;
import com.ui.common.IpRuleItemEnum;
import com.ui.common.IpRuleOperationEnum;
import com.ui.contants.HttpUriContants;
import com.ui.http.HttpRestClient;
import com.ui.model.BaseResponse;
import com.ui.model.domain.MalIpRule;
import com.ui.model.req.MaliciousIpRecordReq;
import com.ui.model.req.PageRequest;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;
import java.util.List;
import java.util.Map;
@Controller
@RequestMapping("/maliciousIp")
public class MaliciousIpCtrl {
@Autowired
private HttpRestClient httpClient;
@RequestMapping("/toMaliciousIps")
public ModelAndView toMaliciousIps(Model model) {
return new ModelAndView("malicious/maliciousIpList");
}
@RequestMapping("/toMaliciousIpsNew")
public ModelAndView toMaliciousIpsNew(Model model) {
return new ModelAndView("malicious/maliciousIpListNew");
}
@RequestMapping("/toMaliciousIpRecordList")
public ModelAndView toMaliciousIpRecordList(Model model) {
return new ModelAndView("malicious/maliciousIpRecordList");
}
@RequestMapping("/toMaliciousIpRecordForbidList")
public ModelAndView toMaliciousIpRecordForbidList(Model model) {
return new ModelAndView("malicious/maliciousIpRecordForbidList");
}
/**
* 从运维系统的mysql获取恶意ip
* @return
*/
@RequestMapping("/getMaliciousIpRecordList")
@ResponseBody
public BaseResponse getMaliciousIpRecordList(MaliciousIpRecordReq req) {
BaseResponse response = httpClient.defaultPost(HttpUriContants.GET_MIPS_RECORD_FROM_OPS_DB, req,
BaseResponse.class);
return response;
}
/**
* 从运维系统的mysql获取恶意ip-封sha
* @return
*/
@RequestMapping("/getMaliciousIpRecordForbidList")
@ResponseBody
public BaseResponse getMaliciousIpRecordForbidList(MaliciousIpRecordReq req) {
BaseResponse response = httpClient.defaultPost(HttpUriContants.GET_MIPS_RECORD_FROM_OPS_DB_FORBID, req,
BaseResponse.class);
return response;
}
/**
* 获取hbase信息
* @return
*/
@RequestMapping("/getMaliciousDetection")
@ResponseBody
public BaseResponse getMaliciousDetection(MaliciousIpRecordReq req) {
BaseResponse response = httpClient.defaultPost(HttpUriContants.GET_MIPS_RECORD_FROM_OPS_HBASE, req,
BaseResponse.class);
return response;
}
/**
* 从运维系统的redis获取恶意ip
* @return
*/
@RequestMapping("/getMipsFromOpsReids")
@ResponseBody
public BaseResponse<List<Object>> getMipsFromOpsReids() {
BaseResponse<List<Object>> response = httpClient.defaultPost(HttpUriContants.GET_MIPS_FROM_OPS_REIDS, null,
BaseResponse.class);
return response;
}
/**
* first调用相关系统提供的接口从正式封杀环境中删除,再从运维系统的redis删除恶意ip
* @return
*/
@RequestMapping("/delMipsFromOpsRedis")
@ResponseBody
public BaseResponse delMipsFromOpsRedis(String ip){
BaseResponse response = httpClient.defaultPost(HttpUriContants.DEL_MIPS_FROM_OPS_REDIS+"?ip="+ip, null,
BaseResponse.class);
return response;
}
/**
* first调用相关系统提供的接口从正式封杀环境中删除,再从运维系统的redis删除恶意ip
* @return
*/
@RequestMapping("/addMipsFromOpsRedis")
@ResponseBody
public BaseResponse addMipsFromOpsRedis(String ip){
BaseResponse response = httpClient.defaultPost(HttpUriContants.ADD_MIPS_FROM_OPS_REDIS+"?ip="+ip, null,
BaseResponse.class);
return response;
}
@RequestMapping("/toMaliciousIpsBL")
public ModelAndView toMaliciousIpsBL(Model model) {
return new ModelAndView("malicious/maliciousIpListBL");
}
@RequestMapping("/toMaliciousIpsCS")
public ModelAndView toMaliciousIpsCS(Model model) {
return new ModelAndView("malicious/maliciousIpListCS");
}
@RequestMapping("/showDetail")
public ModelAndView showDetail(Model model, String ip, String count, String type, String timeType, String timestamp) {
ModelAndView mdv = new ModelAndView("malicious/maliciousIpDetail");
mdv.addObject("type", type);
mdv.addObject("ip", ip);
mdv.addObject("count", count);
mdv.addObject("timeType", timeType);
mdv.addObject("timestamp", timestamp);
return mdv;
}
@SuppressWarnings("unchecked")
@RequestMapping("/getIps")
@ResponseBody
public BaseResponse<List<Object>> getIps(Model model,String timeType) {
BaseResponse<List<Object>> response = httpClient.defaultPost(HttpUriContants.GET_MALICIOUS_IP+"?timeType="+timeType, null,
BaseResponse.class);
return response;
}
@SuppressWarnings("unchecked")
@RequestMapping("/getDetail")
@ResponseBody
public BaseResponse<List<Object>> getDetail(Model model, String ip, String count,String timeType, String timestamp) {
BaseResponse<List<Object>> response = httpClient.defaultGet(HttpUriContants.GET_MALICIOUS_DETAIL + "?ip=" + ip + "&count=" + count + "&timeType=" + timeType + "×tamp=" + timestamp,
BaseResponse.class);
return response;
}
@SuppressWarnings("unchecked")
@RequestMapping("/uploadIp")
@ResponseBody
public BaseResponse<Object> uploadIp(UpLoadMaliciousIp ips) {
BaseResponse<Object> response = httpClient.defaultPost(HttpUriContants.GET_MALICIOUS_UPLOADIP, ips,
BaseResponse.class);
return response;
}
@RequestMapping("/showIps")
public ModelAndView showIps(Model model, String ip, String count) {
return new ModelAndView("malicious/maliciousIpLook");
}
@SuppressWarnings("unchecked")
@RequestMapping("/lookIps")
@ResponseBody
public BaseResponse<List<Object>> lookIps(Model model) {
BaseResponse<List<Object>> response = httpClient.defaultPost(HttpUriContants.GET_MALICIOUS_LOOKIP, null,
BaseResponse.class);
return response;
}
/**
* 从黑名单中移除ip
* @param ips
* @return
*/
@SuppressWarnings("unchecked")
@RequestMapping("/removeIp")
@ResponseBody
public BaseResponse<Object> removeIp(UpLoadMaliciousIp ips) {
BaseResponse<Object> response = httpClient.defaultPost(HttpUriContants.GET_MALICIOUS_REMOVEIP, ips,
BaseResponse.class);
return response;
}
/**
* 比例
* @param model
* @return
*/
@SuppressWarnings("unchecked")
@RequestMapping("/getIpsBL")
@ResponseBody
public BaseResponse<List<Object>> getIpsBL(Model model,String timeType) {
BaseResponse<List<Object>> response = httpClient.defaultPost(HttpUriContants.GET_MALICIOUS_IP_BL+"?timeType="+timeType, null,
BaseResponse.class);
return response;
}
/**
* 次数
* @param model
* @return
*/
@SuppressWarnings("unchecked")
@RequestMapping("/getIpsCS")
@ResponseBody
public BaseResponse<List<Object>> getIpsCS(Model model,String timeType) {
BaseResponse<List<Object>> response = httpClient.defaultPost(HttpUriContants.GET_MALICIOUS_IP_CS+"?timeType="+timeType, null,
BaseResponse.class);
return response;
}
/**
* 恶意ip规则管理**/
@RequestMapping("/toMaliciousIpRules")
public ModelAndView toMaliciousIpRules(Model model) {
List<Map<String,String>> itemList = IpRuleItemEnum.getAll();//规则项
String items = JSON.toJSONString(itemList);
List<String> opList = IpRuleOperationEnum.getAllOp();//规则比较符 列表
String operations = JSON.toJSONString(opList);
List<String> concatList = IpRuleConcatEnum.getAll();//规则连接符
String concats = JSON.toJSONString(concatList);
ModelAndView mv = new ModelAndView();
mv.setViewName("malicious/maliciousIpRulesList");
mv.addObject("items",items);
mv.addObject("operations",operations);
mv.addObject("concats",concats);
return mv;
}
/***
* 查询 恶意ip规则列表*/
@RequestMapping("/getIpRules")
@ResponseBody
public BaseResponse getIpRules(PageRequest req) {
BaseResponse response = httpClient.defaultPost(HttpUriContants.GET_MALICIOUS_IP_RULES, req, BaseResponse.class);
return response;
}
/***
* 新增 恶意ip规则*/
@RequestMapping("/saveIpRules")
@ResponseBody
public BaseResponse saveIpRules(@RequestBody MalIpRule malIpRule) {
BaseResponse response = httpClient.defaultPost(HttpUriContants.SAVE_MALICIOUS_IP_RULES, malIpRule, BaseResponse.class);
return response;
}
/***
* 删除 恶意ip规则*/
@RequestMapping("/deleteIpRule")
@ResponseBody
public BaseResponse deleteIpRule(int id ) {
BaseResponse response = httpClient.defaultPost(HttpUriContants.DEL_MALICIOUS_IP_RULE + "?id="+id, null, BaseResponse.class);
return response;
}
@RequestMapping("/toMaliciousIpFilterList")
public ModelAndView maliciousIpFilterList(){
return new ModelAndView("malicious/maliciousIpFilterList");
}
}