Skip to content

D
datamanage
Commit 15bbeae6 by [zhangzhiwei]
Options

取消连通性测试

parent 846fad2b
Showing with 83 additions and 85 deletions
src/main/java/com/zhiwei/manage/handle/Task.java
package com.zhiwei.manage.handle;
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
......@@ -50,89 +48,89 @@ public class Task implements Runnable {
public void run() {
MessageService messageService = BeanFactory.getBean(MessageService.class);
NewsService newsService = BeanFactory.getBean(NewsService.class);
// 连通性测试
if (ping != null) {
if (MainThread.mainMap.get(ping.getTemplateId()) != null) {
URL url;
try {
url = new URL(ping.getPingUrlOne());
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setConnectTimeout(1000 * 10);
conn.setRequestProperty("User-Agent",
"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.62 Safari/537.36");
int code = conn.getResponseCode();
if (code > 399 || code < 200) {
Template tp = MainThread.mainMap.get(ping.getTemplateId());
Message msg = new Message();
msg.setCreateDate(new Date());
msg.setErrorMsg(code == 0 ? "访问超时" : ping.getPingUrlOne() + "访问失败,错误代码" + code);
msg.setHandle(false);
msg.setTemplateCreator(tp.getCreator());
msg.setTempName(ping.getTempName());
msg.setTemplateLv(tp.getTemplateLv());
msg.setErrorType("url");
msg.setPt(ping.getPt());
messageService.update(msg, ping.getPt());
} else {
Message msg = messageService.findMsg(ping.getTempName(), "url");
if (msg != null) {
messageService.delete(msg.getMessageId());
}
}
} catch (Exception e) {
Template tp = MainThread.mainMap.get(ping.getTemplateId());
Message msg = new Message();
msg.setCreateDate(new Date());
msg.setErrorMsg("访问出错,url不可访问");
msg.setHandle(false);
msg.setTemplateCreator(tp.getCreator());
msg.setTempName(ping.getTempName());
msg.setTemplateLv(1);
msg.setErrorType("url");
msg.setPt(ping.getPt());
messageService.update(msg, ping.getPt());
}
if (null != ping.getPingUrlTwo() && !ping.getPingUrlTwo().equals(""))
try {
url = new URL(ping.getPingUrlTwo());
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setRequestProperty("User-Agent",
"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.62 Safari/537.36");
conn.setConnectTimeout(1000 * 10);
int code = conn.getResponseCode();
if (code > 399 || code < 200) {
Template tp = MainThread.mainMap.get(ping.getTemplateId());
Message msg = new Message();
msg.setCreateDate(new Date());
msg.setErrorMsg(code == 0 ? ping.getPingUrlOne() + "访问失败,错误代码" + code : "访问超时");
msg.setHandle(false);
msg.setTemplateCreator(tp.getCreator());
msg.setTempName(ping.getTempName());
msg.setTemplateLv(tp.getTemplateLv());
msg.setErrorType("url");
msg.setPt(ping.getPt());
messageService.update(msg, ping.getPt());
} else {
Message msg = messageService.findMsg(ping.getTempName(), "url");
if (msg != null) {
messageService.delete(msg.getMessageId());
}
}
} catch (Exception e) {
Template tp = MainThread.mainMap.get(ping.getTemplateId());
Message msg = new Message();
msg.setCreateDate(new Date());
msg.setErrorMsg("访问出错,url不可访问");
msg.setHandle(false);
msg.setTemplateCreator(tp.getCreator());
msg.setTempName(ping.getTempName());
msg.setPt(ping.getPt());
msg.setErrorType("url");
msg.setTemplateLv(tp.getTemplateLv());
messageService.update(msg, ping.getPt());
}
}
}
// // 连通性测试
// if (ping != null) {
// if (MainThread.mainMap.get(ping.getTemplateId()) != null) {
// URL url;
// try {
// url = new URL(ping.getPingUrlOne());
// HttpURLConnection conn = (HttpURLConnection) url.openConnection();
// conn.setConnectTimeout(1000 * 10);
// conn.setRequestProperty("User-Agent",
// "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.62 Safari/537.36");
// int code = conn.getResponseCode();
// if (code > 399 || code < 200) {
// Template tp = MainThread.mainMap.get(ping.getTemplateId());
// Message msg = new Message();
// msg.setCreateDate(new Date());
// msg.setErrorMsg(code == 0 ? "访问超时" : ping.getPingUrlOne() + "访问失败,错误代码" + code);
// msg.setHandle(false);
// msg.setTemplateCreator(tp.getCreator());
// msg.setTempName(ping.getTempName());
// msg.setTemplateLv(tp.getTemplateLv());
// msg.setErrorType("url");
// msg.setPt(ping.getPt());
// messageService.update(msg, ping.getPt());
// } else {
// Message msg = messageService.findMsg(ping.getTempName(), "url");
// if (msg != null) {
// messageService.delete(msg.getMessageId());
// }
// }
// } catch (Exception e) {
// Template tp = MainThread.mainMap.get(ping.getTemplateId());
// Message msg = new Message();
// msg.setCreateDate(new Date());
// msg.setErrorMsg("访问出错,url不可访问");
// msg.setHandle(false);
// msg.setTemplateCreator(tp.getCreator());
// msg.setTempName(ping.getTempName());
// msg.setTemplateLv(1);
// msg.setErrorType("url");
// msg.setPt(ping.getPt());
// messageService.update(msg, ping.getPt());
// }
// if (null != ping.getPingUrlTwo() && !ping.getPingUrlTwo().equals(""))
// try {
// url = new URL(ping.getPingUrlTwo());
// HttpURLConnection conn = (HttpURLConnection) url.openConnection();
// conn.setRequestProperty("User-Agent",
// "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.62 Safari/537.36");
// conn.setConnectTimeout(1000 * 10);
// int code = conn.getResponseCode();
// if (code > 399 || code < 200) {
// Template tp = MainThread.mainMap.get(ping.getTemplateId());
// Message msg = new Message();
// msg.setCreateDate(new Date());
// msg.setErrorMsg(code == 0 ? ping.getPingUrlOne() + "访问失败,错误代码" + code : "访问超时");
// msg.setHandle(false);
// msg.setTemplateCreator(tp.getCreator());
// msg.setTempName(ping.getTempName());
// msg.setTemplateLv(tp.getTemplateLv());
// msg.setErrorType("url");
// msg.setPt(ping.getPt());
// messageService.update(msg, ping.getPt());
// } else {
// Message msg = messageService.findMsg(ping.getTempName(), "url");
// if (msg != null) {
// messageService.delete(msg.getMessageId());
// }
// }
// } catch (Exception e) {
// Template tp = MainThread.mainMap.get(ping.getTemplateId());
// Message msg = new Message();
// msg.setCreateDate(new Date());
// msg.setErrorMsg("访问出错,url不可访问");
// msg.setHandle(false);
// msg.setTemplateCreator(tp.getCreator());
// msg.setTempName(ping.getTempName());
// msg.setPt(ping.getPt());
// msg.setErrorType("url");
// msg.setTemplateLv(tp.getTemplateLv());
// messageService.update(msg, ping.getPt());
// }
// }
// }
if (delayed != null) {
log.info(delayed.getTempName() + "开始检测");
if (MainThread.mainMap.get(delayed.getTemplateId()) != null) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment