Commit 1ebe86a6 by shenjinzhu

对于重复的预警消息只添加一条

parent 1cd7a1ad
...@@ -34,10 +34,8 @@ public class MessageDaoImpl implements MessageDao { ...@@ -34,10 +34,8 @@ public class MessageDaoImpl implements MessageDao {
@Override @Override
public String insert(Message message) { public String insert(Message message) {
Message msg = mongo.findOne(Query.query( Message msg = mongo.findOne(Query.query(Criteria.where("tempName").is(message.getTempName()).where("handle")
Criteria.where("tempName").is(message.getTempName()).andOperator(Criteria.where("handle").is(false)) .is(false).where("errorMsg").is(message.getErrorMsg())), Message.class);
.andOperator(Criteria.where("errorMsg").is(message.getErrorMsg()))),
Message.class);
if (msg == null) { if (msg == null) {
mongo.insert(message); mongo.insert(message);
return "添加成功"; return "添加成功";
......
...@@ -108,7 +108,7 @@ public class Task implements Runnable { ...@@ -108,7 +108,7 @@ public class Task implements Runnable {
Template tp = MainThread.mainMap.get(field.getTemplateId()); Template tp = MainThread.mainMap.get(field.getTemplateId());
Message msg = new Message(); Message msg = new Message();
msg.setCreateDate(new Date()); msg.setCreateDate(new Date());
msg.setErrorMsg("字段检测发现库内的数据小于预设检测数量:"+delayed.getTestCount()+"条,实际数据量为"+list.size()); msg.setErrorMsg("字段检测发现库内的数据小于预设检测数量:"+field.getTestCount()+"条,实际数据量为"+list.size());
msg.setHandle(false); msg.setHandle(false);
msg.setPt(field.getPt()); msg.setPt(field.getPt());
msg.setTemplateCreator(tp.getCreator()); msg.setTemplateCreator(tp.getCreator());
......
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