添加错误类型

src/main/java/com/zhiwei/manage/bean/Message.java

@@ -30,6 +30,14 @@ public class Message implements Serializable {
 	private String handler;
 	private String pt;
 	private String handleMsg;
+	private String errorType;
+	
+	public String getErrorType() {
+		return errorType;
+	}
+	public void setErrorType(String errorType) {
+		this.errorType = errorType;
+	}
 	public String getHandleMsg() {
 		return handleMsg;
 	}

src/main/java/com/zhiwei/manage/dao/MessageDaoImpl.java

@@ -35,7 +35,7 @@ public class MessageDaoImpl implements MessageDao {
 	@Override
 	public String insert(Message message) {
 		Message msg = mongo.findOne(Query.query(Criteria.where("tempName").is(message.getTempName()).where("handle")
-				.is(false).where("errorMsg").is(message.getErrorMsg())), Message.class);
+				.is(false).where("errorMsg").is(message.getErrorType())), Message.class);
 		if (msg == null) {
 			mongo.insert(message);
 			return "添加成功";

src/main/java/com/zhiwei/manage/handle/Task.java

@@ -56,6 +56,7 @@ public class Task implements Runnable {
 					msg.setTemplateCreator(tp.getCreator());
 					msg.setTempName(ping.getTempName());
 					msg.setTemplateLv(tp.getTemplateLv());
+					msg.setErrorType("url");
 					messageService.insert(msg);
 				}
 			} catch (Exception e) {
@@ -66,11 +67,11 @@ public class Task implements Runnable {
 				msg.setHandle(false);
 				msg.setTemplateCreator(tp.getCreator());
 				msg.setTempName(ping.getTempName());
-				msg.setTemplateLv(tp.getTemplateLv());
+				msg.setTemplateLv(1);
+				msg.setErrorType("url");
 				msg.setPt(ping.getPt());
 				messageService.insert(msg);
 			}
-			System.out.println(ping);
 			if (null!=ping.getPingUrlTwo()&& !ping.getPingUrlTwo().equals(""))
 				try {
 					url = new URL(ping.getPingUrlTwo());
@@ -86,6 +87,7 @@ public class Task implements Runnable {
 						msg.setTemplateCreator(tp.getCreator());
 						msg.setTempName(ping.getTempName());
 						msg.setTemplateLv(tp.getTemplateLv());
+						msg.setErrorType("url");
 						msg.setPt(ping.getPt());
 						messageService.insert(msg);
 					}
@@ -98,6 +100,7 @@ public class Task implements Runnable {
 					msg.setTemplateCreator(tp.getCreator());
 					msg.setTempName(ping.getTempName());
 					msg.setPt(ping.getPt());
+					msg.setErrorType("url");
 					msg.setTemplateLv(tp.getTemplateLv());
 					messageService.insert(msg);
 				}
@@ -115,6 +118,7 @@ public class Task implements Runnable {
 				msg.setPt(field.getPt());
 				msg.setTemplateCreator(tp.getCreator());
 				msg.setTemplateLv(tp.getTemplateLv());
+				msg.setErrorType("field");
 				msg.setTempName(field.getTempName());
 				messageService.insert(msg);
 			}
@@ -139,6 +143,7 @@ public class Task implements Runnable {
 					msg.setErrorMsg(fid + "字段存在缺失,完整率"+num / 1.0 / count+"其中一条："+str);
 					msg.setHandle(false);
 					msg.setPt(field.getPt());
+					msg.setErrorType("field");
 					msg.setTemplateCreator(tp.getCreator());
 					msg.setTemplateLv(tp.getTemplateLv());
 					msg.setTempName(field.getTempName());
@@ -158,6 +163,7 @@ public class Task implements Runnable {
 				msg.setErrorMsg("延时检测发现库内的数据小于预设检测数量："+delayed.getTestCount()+"条,实际数据量为"+list.size());
 				msg.setHandle(false);
 				msg.setPt(delayed.getPt());
+				msg.setErrorType("delayed");
 				msg.setTemplateCreator(tp.getCreator());
 				msg.setTemplateLv(tp.getTemplateLv());
 				msg.setTempName(delayed.getTempName());
@@ -186,6 +192,7 @@ public class Task implements Runnable {
 					msg.setErrorMsg("延时检测发现时间字段缺失");
 					msg.setHandle(false);
 					msg.setPt(delayed.getPt());
+					msg.setErrorType("delayed");
 					msg.setTemplateCreator(tp.getCreator());
 					msg.setTemplateLv(tp.getTemplateLv());
 					msg.setTempName(delayed.getTempName());
@@ -205,6 +212,7 @@ public class Task implements Runnable {
 				msg.setCreateDate(new Date());
 				msg.setErrorMsg("延时过高，延时检测为" + sum / 1.0 / 1000 / 60/cutSize + "分");
 				msg.setHandle(false);
+				msg.setErrorType("delayed");
 				msg.setTemplateCreator(tp.getCreator());
 				msg.setTemplateLv(tp.getTemplateLv());
 				msg.setPt(delayed.getPt());