From ecbac3660eb2152a940b45b5c3eef54195824ccb Mon Sep 17 00:00:00 2001 From: default Date: Thu, 8 Nov 2018 09:38:32 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Ddetection=5Finfo=E6=8F=92?= =?UTF-8?q?=E5=85=A5=E6=95=B0=E6=8D=AE=20=E5=90=8C=E6=97=B6=E6=A0=B9?= =?UTF-8?q?=E6=8D=AEdetection=5Finfo=E7=8A=B6=E6=80=81=E4=BF=AE=E6=94=B9de?= =?UTF-8?q?tection=5Finfo=5Fnew=E8=A1=A8=E7=9A=84=E7=8A=B6=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/com/nms/thread/service/ThreadService.java | 205 +++++++++--------- 1 file changed, 105 insertions(+), 100 deletions(-) diff --git a/src/com/nms/thread/service/ThreadService.java b/src/com/nms/thread/service/ThreadService.java index 6eba51a..8b96b5c 100644 --- a/src/com/nms/thread/service/ThreadService.java +++ b/src/com/nms/thread/service/ThreadService.java @@ -942,111 +942,116 @@ public class ThreadService { try{ List insert = split.get("insert"); List update = split.get("update"); - for (String[] alarm : insert) { - //seq_Id - String seqId= alarm[1]; - insertNewStmt.setObject(11, seqId); - //detection_set_info_id - String setInfoId=alarm[0]; - insertNewStmt.setObject(1, setInfoId); - // 监测服务启动时间， - String startTime =format.format(new Date(Long.parseLong(alarm[4]))); - insertNewStmt.setObject(5, startTime); - // 本次检测时间， - String checkTime =format.format(new Date(Long.parseLong(alarm[5]))); - insertNewStmt.setObject(7, checkTime); - // 告警级别 - String pLevel = alarm[6]; - String state = alarm[7]; - if(StringUtils.isEmpty(pLevel)){ - if("-2".equals(state)){ - pLevel = "1"; - }else if("2".equals(state)){ - pLevel = "99"; + if(null!=insert&&insert.size()>0) { + for (int i=insert.size()-1;i>=0;i--) { + String[] alarm= insert.get(i); + //seq_Id + String seqId= alarm[1]; + insertNewStmt.setObject(11, seqId); + //detection_set_info_id + String setInfoId=alarm[0]; + insertNewStmt.setObject(1, setInfoId); + // 监测服务启动时间， + String startTime =format.format(new Date(Long.parseLong(alarm[4]))); + insertNewStmt.setObject(5, startTime); + // 本次检测时间， + String checkTime =format.format(new Date(Long.parseLong(alarm[5]))); + insertNewStmt.setObject(7, checkTime); + // 告警级别 + String pLevel = alarm[6]; + String state = alarm[7]; + if(StringUtils.isEmpty(pLevel)){ + if("-2".equals(state)){ + pLevel = "1"; + }else if("2".equals(state)){ + pLevel = "99"; + } } + insertNewStmt.setObject(6, pLevel); + // 执行状态是否成功，记录的状态是否正常（用于报警 -2主动告警 -1执行失败 0不正常，1正常）， + insertNewStmt.setObject(9, state); + // 状态信息（描述信息）， + String stateInfo=alarm[8]; + insertNewStmt.setObject(2, stateInfo); + //性能数据， + String performaceData=alarm[8]; + insertNewStmt.setObject(3, performaceData); + //DATA_ARRIVE_TIME + insertNewStmt.setObject(8, arriveTimeStr); + //STATUS_CHANGE_TIME + insertNewStmt.setObject(10, checkTime); + //data_check_time_digital + String checkTimeDigtal=alarm[5]; + insertNewStmt.setObject(13, checkTimeDigtal); + //data_arrive_time_digital + String arriveTimeDigital=arriveTime.getTimeInMillis()+""; + insertNewStmt.setObject(14, arriveTimeDigital); + //POLICE_EMERGENT + String policeEmergent=alarm[10]; + insertNewStmt.setObject(15, policeEmergent); + //detection_info_id + String detectionId=computeId(alarm[5],seqId,setInfoId); + insertNewStmt.setObject(12, detectionId); + //currentTimes + insertNewStmt.setObject(4, null); + + insertNewStmt.addBatch(); + insert.remove(i); } - insertNewStmt.setObject(6, pLevel); - // 执行状态是否成功，记录的状态是否正常（用于报警 -2主动告警 -1执行失败 0不正常，1正常）， - insertNewStmt.setObject(9, state); - // 状态信息（描述信息）， - String stateInfo=alarm[8]; - insertNewStmt.setObject(2, stateInfo); - //性能数据， - String performaceData=alarm[8]; - insertNewStmt.setObject(3, performaceData); - //DATA_ARRIVE_TIME - insertNewStmt.setObject(8, arriveTimeStr); - //STATUS_CHANGE_TIME - insertNewStmt.setObject(10, checkTime); - //data_check_time_digital - String checkTimeDigtal=alarm[5]; - insertNewStmt.setObject(13, checkTimeDigtal); - //data_arrive_time_digital - String arriveTimeDigital=arriveTime.getTimeInMillis()+""; - insertNewStmt.setObject(14, arriveTimeDigital); - //POLICE_EMERGENT - String policeEmergent=alarm[10]; - insertNewStmt.setObject(15, policeEmergent); - //detection_info_id - String detectionId=computeId(alarm[5],seqId,setInfoId); - insertNewStmt.setObject(12, detectionId); - //currentTimes - insertNewStmt.setObject(4, null); - - insertNewStmt.addBatch(); - insert.remove(alarm); } - for (String[] alarm : update) { - - String seqId= alarm[1]; - updateNewStmt.setObject(14, seqId); - //detection_set_info_id - String setInfoId=alarm[0]; - updateNewStmt.setObject(13, setInfoId); - // 监测服务启动时间， - String startTime =format.format(new Date(Long.parseLong(alarm[4]))); - updateNewStmt.setObject(3, startTime); - // 本次检测时间， - String checkTime =format.format(new Date(Long.parseLong(alarm[5]))); - updateNewStmt.setObject(5, checkTime); - // 告警级别 - String pLevel = alarm[6]; - String state = alarm[7]; - if(StringUtils.isEmpty(pLevel)){ - if("-2".equals(state)){ - pLevel = "1"; - }else if("2".equals(state)){ - pLevel = "99"; + if(null!=update&&update.size()>0) { + for (int i=update.size()-1;i>=0;i--) { + String[] alarm= update.get(i); + String seqId= alarm[1]; + updateNewStmt.setObject(14, seqId); + //detection_set_info_id + String setInfoId=alarm[0]; + updateNewStmt.setObject(13, setInfoId); + // 监测服务启动时间， + String startTime =format.format(new Date(Long.parseLong(alarm[4]))); + updateNewStmt.setObject(3, startTime); + // 本次检测时间， + String checkTime =format.format(new Date(Long.parseLong(alarm[5]))); + updateNewStmt.setObject(5, checkTime); + // 告警级别 + String pLevel = alarm[6]; + String state = alarm[7]; + if(StringUtils.isEmpty(pLevel)){ + if("-2".equals(state)){ + pLevel = "1"; + }else if("2".equals(state)){ + pLevel = "99"; + } } + updateNewStmt.setObject(4, pLevel); + // 执行状态是否成功，记录的状态是否正常（用于报警 -2主动告警 -1执行失败 0不正常，1正常）， + updateNewStmt.setObject(7, state); + // 状态信息（描述信息）， + String stateInfo=alarm[8]; + updateNewStmt.setObject(1, stateInfo); + //性能数据， + String performaceData=alarm[8]; + updateNewStmt.setObject(2, performaceData); + //DATA_ARRIVE_TIME + updateNewStmt.setObject(6, arriveTimeStr); + //STATUS_CHANGE_TIME + updateNewStmt.setObject(8, alarm[alarm.length-1]); + //data_check_time_digital + String checkTimeDigtal=alarm[5]; + updateNewStmt.setObject(10, checkTimeDigtal); + //data_arrive_time_digital + String arriveTimeDigital=arriveTime.getTimeInMillis()+""; + updateNewStmt.setObject(11, arriveTimeDigital); + //POLICE_EMERGENT + String policeEmergent=alarm[10]; + updateNewStmt.setObject(12, policeEmergent); + //detection_info_id + String detectionId=computeId(alarm[5],seqId,setInfoId); + updateNewStmt.setObject(9, detectionId); + + updateNewStmt.addBatch(); + update.remove(i); } - updateNewStmt.setObject(4, pLevel); - // 执行状态是否成功，记录的状态是否正常（用于报警 -2主动告警 -1执行失败 0不正常，1正常）， - updateNewStmt.setObject(7, state); - // 状态信息（描述信息）， - String stateInfo=alarm[8]; - updateNewStmt.setObject(1, stateInfo); - //性能数据， - String performaceData=alarm[8]; - updateNewStmt.setObject(2, performaceData); - //DATA_ARRIVE_TIME - updateNewStmt.setObject(6, arriveTimeStr); - //STATUS_CHANGE_TIME - updateNewStmt.setObject(8, alarm[alarm.length-1]); - //data_check_time_digital - String checkTimeDigtal=alarm[5]; - updateNewStmt.setObject(10, checkTimeDigtal); - //data_arrive_time_digital - String arriveTimeDigital=arriveTime.getTimeInMillis()+""; - updateNewStmt.setObject(11, arriveTimeDigital); - //POLICE_EMERGENT - String policeEmergent=alarm[10]; - updateNewStmt.setObject(12, policeEmergent); - //detection_info_id - String detectionId=computeId(alarm[5],seqId,setInfoId); - updateNewStmt.setObject(9, detectionId); - - updateNewStmt.addBatch(); - update.remove(alarm); } }catch(Exception e){ e.printStackTrace();