3dDisplayEngine YtiotVDataServiceImpl.java 李欣儒 commit at 2021-04-08

3dDisplayEngine/buildingService/YtiotVDataServiceImpl.java

@@ -3267,3 +3267,172 @@ public class YtiotVDataServiceImpl implements YtiotVDataService {
 					map.put("time", df.format(HJid.getTime()));
 					map.put("clzt", HJid.getClzt()==1?"已处理":"未处理");
 					JSONObject jSONObject = JSONObject.fromObject(map);
+					jSONArray3.add(jSONObject);
+				}
+					break;
+				case 3:
+				{
+					Map map = new HashMap();
+					map.put("id", 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);
+					jSONArray3.add(jSONObject);
+				}
+					break;
+				case 4:
+				{
+					Map map = new HashMap();
+					map.put("id", 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);
+					jSONArray3.add(jSONObject);
+				}
+					break;
+				case 5:
+				{
+					Object[] objects = (Object[]) list5.get(0);
+					Map map = new HashMap();
+					map.put("id", 1);
+					map.put("company", objects[1].toString());
+					map.put("name", objects[2].toString());
+					map.put("data", objects[3].toString().equals("EF0")?"告警撤销"
+							:objects[3].toString().equals("EF1")?"欠压报警"
+									:objects[3].toString().equals("EF2")?"过压报警"
+											:objects[3].toString().equals("EF3")?"过流报警"
+													:objects[3].toString().equals("EF4")?"漏电报警"
+															:objects[3].toString().equals("EF5")?"温度1超高报警"
+																	:objects[3].toString().equals("EF6")?"温度2超高报警"
+																			:objects[3].toString().equals("EF7")?"温度3超高报警"
+																					:objects[3].toString().equals("EF8")?"温度4超高报警"
+																							:objects[3].toString().equals("EF9")?"设备离线"
+																									:objects[3].toString());
+					map.put("time", objects[4].toString());
+					map.put("clzt", objects[5].toString().equals("1")?"已处理":"未处理");
+					JSONObject jSONObject = JSONObject.fromObject(map);
+					jSONArray3.add(jSONObject);
+				}
+					break;
+				}
+				json.put("ALARM_LIST", jSONArray3);
+			}
+			json.put("check", "true");
+		}else {
+			json.put("check", "false");
+		}
+		return json.toString();
+	}
+
+	@Override
+	public String getSyncDataByDays(String queryJson) throws Exception {
+		// TODO Auto-generated method stub
+		String company_code = null;
+		String company_code_list = null;
+		String company_name = null;
+		String device_code = null;
+		String device_code_list = null;
+		String time_start = null;
+		String time_end = null;
+		String COMMSTATUS = null;
+		String V_LOGINNAME = null;
+		String V_PASSWORD = null;
+		int E_STATUS=-1;
+		String sqlwhere = null;
+		JSONObject q_json = null;
+		JSONArray jSONArray = new JSONArray();
+		JSONObject json = new JSONObject();
+		List list2 = null,list3 = null,list4 = null;
+		json.put("action", "getConfirmStatusByDays");
+		if(queryJson!=null) {
+			q_json = JSONObject.fromObject(queryJson);
+			company_name = q_json.has("company_name")?q_json.getString("company_name"):null;
+			time_start = q_json.has("time_start")?q_json.getString("time_start"):null;
+			time_end = q_json.has("time_end")?q_json.getString("time_end"):null;
+			COMMSTATUS = q_json.has("COMMSTATUS")?q_json.getString("COMMSTATUS"):null;
+			if(q_json.has("company_code")) {
+				if((q_json.optJSONObject("company_code")!=null)&&(q_json.optJSONObject("company_code").isArray())) {
+					JSONArray j_tmp = q_json.getJSONArray("company_code");
+					for(int i=0;i<j_tmp.size();i++) {
+						if(i==0)
+							company_code_list = j_tmp.getString(i);
+						else
+							company_code_list += ","+j_tmp.getString(i);
+					}
+				}else
+					company_code = q_json.getString("company_code");
+			}
+			if(q_json.has("device_code")) {
+				if(q_json.getJSONObject("device_code").isArray()) {
+					JSONArray j_tmp = q_json.getJSONArray("device_code");
+					for(int i=0;i<j_tmp.size();i++) {
+						if(i==0)
+							device_code_list = j_tmp.getString(i);
+						else
+							device_code_list += ","+j_tmp.getString(i);
+					}
+				}else
+					device_code = q_json.getString("device_code");
+			}
+			V_LOGINNAME = q_json.has("V_LOGINNAME")?q_json.getString("V_LOGINNAME"):null;
+			V_PASSWORD = q_json.has("V_PASSWORD")?q_json.getString("V_PASSWORD"):null;
+		}
+		if((V_LOGINNAME!=null)&&(V_PASSWORD!=null)) {
+			List list = ytiotTAdminDao.query(" where MD5(u.VLoginname)='"+MD5Util.EncoderByMd5(V_LOGINNAME)+"' and u.VPassword='"
+					+MD5Util.EncoderByMd5(MD5Util.EncoderByMd5(V_PASSWORD))+"' ", null, null, null, null);
+			if(list.size()>0) {
+				YtiotTAdmin o = (YtiotTAdmin)list.get(0);
+				E_STATUS = Integer.parseInt(o.getEStatus());
+			}
+		}
+		if(E_STATUS==1) {
+			if(company_name!=null) {
+				sqlwhere = chkhw(sqlwhere)+" company_name like '%"+company_name+"%' ";
+			}
+			if(time_start!=null) {
+				sqlwhere = chkhw(sqlwhere)+" data_time >= '"+time_start+"' ";
+			}
+			if(time_end!=null) {
+				sqlwhere = chkhw(sqlwhere)+" data_time <= '"+time_end+"' ";
+			}
+			if(company_code!=null) {
+				sqlwhere = chkhw(sqlwhere)+" company_code like '%"+company_code+"%' ";
+			}
+			if(company_code_list!=null) {
+				sqlwhere = chkhw(sqlwhere)+" company_code in ("+company_code_list+") ";
+			}
+			if(device_code!=null) {
+				sqlwhere = chkhw(sqlwhere)+" device_code like '%"+device_code+"%' ";
+			}
+			if(device_code_list!=null) {
+				sqlwhere = chkhw(sqlwhere)+" device_code in ("+device_code_list+") ";
+			}
+//			String wheresql = null;
+//			if(COMMSTATUS!=null) {
+//				if(COMMSTATUS.equals("NO"))
+//					wheresql = chkhw(sqlwhere)+" data1 <> 'U44' ";
+//				else if(COMMSTATUS.equals("ONLY"))
+//					wheresql = chkhw(sqlwhere)+" data1 = 'U44' ";
+//			}
+			List list = ytiotVAlarmDao.queryBySQL(" select DATE_FORMAT(ytiot_v_sync_water.data_time, \"%Y-%m-%d\") as days, count(*) as count, sum(device_code) as sum, company_name from ytiot_v_sync_water "+(sqlwhere)+" group by days order by days desc");
+			int count=0,sum=0;
+			JSONArray daylist = new JSONArray();
+			JSONArray countlist = new JSONArray();
+			JSONArray sumlist = new JSONArray();
+			if(list.size()>0) {
+				int Nrow = 0;
+				for(Iterator iterator = list.iterator();iterator.hasNext();){