3dDisplayEngine YtiotVAlarmServiceImpl.java 吉超博 commit at 2021-01-04

3dDisplayEngine/buildingService/YtiotVAlarmServiceImpl.java

@@ -2462,3 +2462,112 @@ public class YtiotVAlarmServiceImpl implements YtiotVAlarmService {
 					wheresql = chkhw(sqlwhere)+" status<>'44' ";
 				else if(COMMSTATUS.equals("ONLY"))
 					wheresql = chkhw(sqlwhere)+" status='44' ";
+				else
+					wheresql = sqlwhere;
+			}else
+				wheresql = sqlwhere;
+			list = ytiotVAlarmDao.queryBySQL(" select count(*) as count, sum(clzt) as sum from ytiot_v_rtu "+((wheresql!=null)?wheresql:""));
+			if(list.size()>0) {
+				int NCount = 0;
+				for(Iterator iterator = list.iterator();iterator.hasNext();){
+					if(NCount==0) {
+						Object[] objects = (Object[]) iterator.next();
+						Map map = new HashMap();
+						map.put("count", objects[0].toString());
+						map.put("sum", objects[1]==null?"0":objects[1].toString());
+						map.put("id", "rtu_alarm");
+						list4 = ytiotVAlarmDao.RTUQuery(hqlwhere, "order by u.id.id", "desc", "0", "1");
+						JSONObject jSONObject = JSONObject.fromObject(map);
+						jSONArray.add(jSONObject);
+						break;
+					}
+					NCount++;
+				}
+			}
+			SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			for(int i=0;i<1;i++) {
+				YtiotVHjId HJid = new YtiotVHjId();
+				HJid.setTime(df.parse("1970-01-01 00:00:00"));
+				if(list2.size()>0) {
+					YtiotVHj hj = (YtiotVHj)list2.get(0);
+					HJid = hj.getId();
+				}
+				YtiotVSjId SJid = new YtiotVSjId();
+				SJid.setTime(df.parse("1970-01-01 00:00:00"));
+				if(list3.size()>0) {
+					YtiotVSj sj = (YtiotVSj)list3.get(0);
+					SJid = sj.getId();
+				}
+				YtiotVRtuId RTUid = new YtiotVRtuId();
+				RTUid.setTime(df.parse("1970-01-01 00:00:00"));
+				if(list4.size()>0) {
+					YtiotVRtu rtu = (YtiotVRtu)list4.get(0);
+					RTUid = rtu.getId();
+				}
+				if(HJid.getTime().getTime()>=SJid.getTime().getTime()) {
+					if(HJid.getTime().getTime()>=RTUid.getTime().getTime()) {
+						if(HJid.getTime().getTime()>0) {
+							Map map = new HashMap();
+							map.put("id", i+1);
+							map.put("company", HJid.getCompanyName());
+							map.put("name", HJid.getName()+((HJid.getData4().length()>0) ?("，"+HJid.getData4()):""));
+							map.put("data", HJid.getData2());
+							map.put("time", df.format(HJid.getTime()));
+							map.put("clzt", HJid.getClzt()==1?"已处理":"未处理");
+							JSONObject jSONObject = JSONObject.fromObject(map);
+							jSONArray2.add(jSONObject);
+						}
+						//					list2.remove(0);
+					}else {
+						if(RTUid.getTime().getTime()>0) {
+							Map map = new HashMap();
+							map.put("id", i+1);
+							map.put("company", RTUid.getCompanyName());
+							map.put("name", RTUid.getName());
+							map.put("data", RTUid.getData2());
+							map.put("time", df.format(RTUid.getTime()));
+							map.put("clzt", RTUid.getClzt()==1?"已处理":"未处理");
+							JSONObject jSONObject = JSONObject.fromObject(map);
+							jSONArray2.add(jSONObject);
+						}
+						//					list4.remove(0);
+					}
+				}else {
+					if(SJid.getTime().getTime()>=RTUid.getTime().getTime()) {
+						if(SJid.getTime().getTime()>0) {
+							Map map = new HashMap();
+							map.put("id", i+1);
+							map.put("company", SJid.getCompanyName());
+							map.put("name", SJid.getName());
+							map.put("data", SJid.getData1().equals("WP1")?"低压"
+									:(SJid.getData1().equals("WP2")?"高压"
+									:(SJid.getData1().equals("WP3")?"故障"
+									:(SJid.getData1().equals("WP4")?"离线"
+									:(SJid.getData1().equals("WP0")?"正常"
+									:(SJid.getData1().equals("LL1")?"低压"
+									:(SJid.getData1().equals("LL2")?"高压"
+									:(SJid.getData1().equals("LL3")?"故障"
+									:(SJid.getData1().equals("LL0")?"正常":SJid.getData1())))))))));
+							map.put("time", df.format(SJid.getTime()));
+							map.put("clzt", SJid.getClzt()==1?"已处理":"未处理");
+							JSONObject jSONObject = JSONObject.fromObject(map);
+							jSONArray2.add(jSONObject);
+						}
+						//					list3.remove(0);
+					}else {
+						if(RTUid.getTime().getTime()>0) {
+							Map map = new HashMap();
+							map.put("id", i+1);
+							map.put("company", RTUid.getCompanyName());
+							map.put("name", RTUid.getName());
+							map.put("data", RTUid.getData2());
+							map.put("time", df.format(RTUid.getTime()));
+							map.put("clzt", RTUid.getClzt()==1?"已处理":"未处理");
+							JSONObject jSONObject = JSONObject.fromObject(map);
+							jSONArray2.add(jSONObject);
+						}
+						//					list4.remove(0);
+					}
+				}
+			}
+			json.put("ALARM_LIST", jSONArray2);