11

src/main/java/com/ekexiu/project/bridge/alarm/AlarmDao.java

@@ -17,6 +17,9 @@ import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.util.PageQueryResult;
@DAO
public interface AlarmDao {
	@Insert
	int insert(Connection con,AlarmDataError cnt)throws SQLException;
	
	@Insert
	int insert(Connection con,AlarmMsg msg)throws SQLException;
	@Insert

src/main/java/com/ekexiu/project/bridge/alarm/AlarmDataError.java

@@ -0,0 +1,36 @@
package com.ekexiu.project.bridge.alarm;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
@Table(descp="报警数据错误表")
public class AlarmDataError {
	private String cnt;
	private long  rtime;
	private String reason;
	
	@Column(descp="接口数据",value=DE.text_de)
	public String getCnt() {
		return cnt;
	}
	public void setCnt(String cnt) {
		this.cnt = cnt;
	}
	@Column(descp="接口数据接收时间",value=DE.long_de)
	public long getRtime() {
		return rtime;
	}
	public void setRtime(long rtime) {
		this.rtime = rtime;
	}
	@Column(descp="接口数据错误原因",value=DE.text_de)
	public String getReason() {
		return reason;
	}
	public void setReason(String reason) {
		this.reason = reason;
	}
	
	
}

src/main/java/com/ekexiu/project/bridge/alarm/AlarmService.java

@@ -51,14 +51,15 @@ public class AlarmService {
		}
		sb.append(") AND UID=? AND READED='0' GROUP BY SERVER");
		
		return JdbcUtil.queryList(con, sb.toString(), new ResultSetExtractor<Map<String,Integer>>() {
		return JdbcUtil.queryList(con, sb.toString(), new ResultSetExtractor<Map<String,Object>>() {
			@Override
			public Map<String, Integer> extractData(ResultSet rs) throws SQLException {
				Map<String,Integer> map = new HashMap<String,Integer>();
			public Map<String, Object> extractData(ResultSet rs) throws SQLException {
				Map<String,Object> map = new HashMap<String,Object>();
				String s= rs.getString(1);
				int c = rs.getInt(2);
				map.put(s, c);
				map.put("server",s);
				map.put("num",c);
				return map;
			}
		}, new PreparedStatementConfig() {

src/main/java/com/ekexiu/project/bridge/collect/CollectDao.java

@@ -17,6 +17,9 @@ import org.jfw.apt.orm.annotation.dao.param.LtEq;
@DAO
public interface CollectDao {
	@Insert
	int insertWaveDataError(Connection con,WaveDataError cnt)throws SQLException;
	
	@Insert
	@Batch
	int[] insertWaveDataItems(Connection con,List<WaveDataItem> items)throws SQLException;

src/main/java/com/ekexiu/project/bridge/collect/WaveDataError.java

@@ -0,0 +1,37 @@
package com.ekexiu.project.bridge.collect;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
@Table(descp="实时数据错误表")
public class WaveDataError {
	private String cnt;
	private long  rtime;
	private String reason;
	
	@Column(descp="接口数据",value=DE.text_de)
	public String getCnt() {
		return cnt;
	}
	public void setCnt(String cnt) {
		this.cnt = cnt;
	}
	@Column(descp="接口数据接收时间",value=DE.long_de)
	public long getRtime() {
		return rtime;
	}
	public void setRtime(long rtime) {
		this.rtime = rtime;
	}
	@Column(descp="接口数据错误原因",value=DE.text_de)
	public String getReason() {
		return reason;
	}
	public void setReason(String reason) {
		this.reason = reason;
	}
	
	
}

src/main/java/com/ekexiu/project/bridge/servlet/AlarmDataServlet.java

@@ -5,6 +5,7 @@ import java.io.IOException;
import java.io.InputStream;
import java.lang.reflect.Type;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
@@ -16,6 +17,7 @@ import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
import org.jfw.apt.util.Base64;
import org.jfw.util.ConstData;
import org.jfw.util.context.JfwAppContext;
import org.jfw.util.io.IoUtil;
@@ -24,6 +26,7 @@ import org.jfw.util.json.JsonService;
import org.jfw.util.reflect.TypeReference;
import com.ekexiu.project.bridge.alarm.AlarmDao;
import com.ekexiu.project.bridge.alarm.AlarmDataError;
import com.ekexiu.project.bridge.alarm.AlarmDataItem;
import com.ekexiu.project.bridge.alarm.AlarmMsg;
import com.ekexiu.project.bridge.mail.MailService;
@@ -64,157 +67,190 @@ public class AlarmDataServlet extends HttpServlet {
		final AlarmMsg msg = new AlarmMsg();
		StringBuilder sb = new StringBuilder();
		final Map<User, String> notices = new HashMap<User, String>();
		List<Object> datas = null;
		Map<Object, Object> map = null;
		AlarmDataItem item = null;
		final Map<String, String> errorData = new HashMap<String, String>();
		String pcnt = null;
		List<Object> datas = null;
		try {
			byte[] buf = new byte[8192];
			IoUtil.copy(in, baos, buf);
			Map<Object, Object> map = JsonService.fromJson(new String(baos.toByteArray(), ConstData.UTF8), DATA_TYPE);
			Object tmpObj = map.get("node_id");
			if (tmpObj != null && tmpObj instanceof String) {
				msg.setServer((String) tmpObj);
				tmpObj = map.get("alarm_no");
				if (tmpObj != null && tmpObj instanceof String) {
					msg.setAid((String) tmpObj);
					tmpObj = map.get("box_id");
					if (tmpObj != null && tmpObj instanceof String) {
						try {
							msg.setDevice(Integer.parseInt((String) tmpObj));
							tmpObj = map.get("data");
							if (tmpObj != null && tmpObj instanceof List) {
								datas = (List<Object>) tmpObj;
							}
						} catch (Exception e) {
						}
					}
			byte[] ba = baos.toByteArray();
			if (ba.length == 0) {
				errorData.put(" ", "EMPTY");
			} else {
				try {
					pcnt = new String(baos.toByteArray(), ConstData.UTF8);
				} catch (Exception e) {
					errorData.put(new String(Base64.encodeBase64(ba), ConstData.UTF8), "CHARSET");
				}
			}
			if (datas != null) {
				for (Object obj : datas) {
					item = new AlarmDataItem();
					if (obj != null && obj instanceof Map) {
						map = (Map<Object, Object>) obj;
						item.setId(msg.getAid());
						tmpObj = map.get("channel_id");
				if (pcnt != null) {
					try {
						map = JsonService.fromJson(pcnt, DATA_TYPE);
					} catch (Exception e) {
						errorData.put(pcnt, "JSON_PARSE");
					}
					if (map != null) {
						Object tmpObj = map.get("node_id");
						if (tmpObj != null && tmpObj instanceof String) {
							try {
								item.setSeq(Integer.parseInt((String) tmpObj));
							} catch (Exception e) {
								items.clear();
								break;
							msg.setServer((String) tmpObj);
							tmpObj = map.get("alarm_no");
							if (tmpObj != null && tmpObj instanceof String) {
								msg.setAid((String) tmpObj);
								tmpObj = map.get("box_id");
								if (tmpObj != null && tmpObj instanceof String) {
									try {
										msg.setDevice(Integer.parseInt((String) tmpObj));
										tmpObj = map.get("data");
										if (tmpObj != null && tmpObj instanceof List) {
											datas = (List<Object>) tmpObj;
										}
									} catch (Exception e) {
									}
								}
							}
						} else {
							items.clear();
							break;
						}
						tmpObj = map.get("start_time");
						if (tmpObj != null && tmpObj instanceof String) {
							item.setStime((String) tmpObj);
						} else {
							items.clear();
							break;
						}
						tmpObj = map.get("alarm_time");
						if (tmpObj != null && tmpObj instanceof String) {
							item.setStime((String) tmpObj);
							if (msg.getAlarmTime() == null) {
								String at = (String) tmpObj;
								at = at.substring(0, 14);
								msg.setAlarmTime(at);
							}
						if (datas != null) {
							for (Object obj : datas) {
								item = new AlarmDataItem();
								if (obj != null && obj instanceof Map) {
									map = (Map<Object, Object>) obj;
									item.setId(msg.getAid());
									tmpObj = map.get("channel_id");
									if (tmpObj != null && tmpObj instanceof String) {
										try {
											item.setSeq(Integer.parseInt((String) tmpObj));
										} catch (Exception e) {
											items.clear();
											break;
										}
									} else {
										items.clear();
										break;
									}
									tmpObj = map.get("start_time");
									if (tmpObj != null && tmpObj instanceof String) {
										item.setStime((String) tmpObj);
									} else {
										items.clear();
										break;
									}
									tmpObj = map.get("alarm_time");
									if (tmpObj != null && tmpObj instanceof String) {
										item.setStime((String) tmpObj);
										if (msg.getAlarmTime() == null) {
											String at = (String) tmpObj;
											at = at.substring(0, 14);
											msg.setAlarmTime(at);
										}
						} else {
							items.clear();
							break;
						}
									} else {
										items.clear();
										break;
									}
						sb.setLength(0);
						tmpObj = map.get("value");
						if (tmpObj != null && tmpObj instanceof List) {
							for (Object val : ((List) tmpObj)) {
								sb.append(val.toString()).append(",");
									sb.setLength(0);
									tmpObj = map.get("value");
									if (tmpObj != null && tmpObj instanceof List) {
										for (Object val : ((List) tmpObj)) {
											sb.append(val.toString()).append(",");
										}
									}
									if (sb.length() > 0) {
										item.setData(sb.substring(0, sb.length() - 1));
									} else {
										items.clear();
										break;
									}
									items.add(item);
								}
							}
						}
						if (sb.length() > 0) {
							item.setData(sb.substring(0, sb.length() - 1));
						} else {
							items.clear();
							break;
						}
						items.add(item);
					}
				}
			}
		} finally {
			in.close();
		}
		Connection con = null;
		try {
			con = this.dataSource.getConnection();
			BridgeServer server = this.bridgeServerDao.queryBySeq(con, msg.getServer());
			if (server != null) {
				Bridge bridge = this.bridgeDao.query(con, server.getBridgeId());
				if (bridge != null) {
					CollectDevice device = this.collectDeviceDao.query(con, server.getId(), msg.getDevice());
					if (device != null) {
						String atime = items.get(0).getAtime();
						String cnt = "您负责管理维护的桥梁：【" + bridge.getShortName() + "】，于【" + atime.substring(0, 4) + "-" + atime.substring(4, 6) + "-"
								+ atime.substring(6, 8) + " " + atime.substring(8, 10) + ":" + atime.substring(10, 12) + ":" + atime.substring(12, 14)
								+ "】，编号为【" + device.getCode() + "】的采集盒发生一起报警事件，请尽快登录平台查看详细的报警信息。";
						List<User> users = this.userDao.queryByBridgeId(con, bridge.getId(), true);
						if (users != null && users.size() > 0) {
							for (User u : users) {
								msg.setUid(u.getId());
								this.alarmDao.insert(con, msg);
								notices.put(u, cnt);
		if (items.size() > 0) {
			Connection con = null;
			try {
				con = this.dataSource.getConnection();
				BridgeServer server = this.bridgeServerDao.queryBySeq(con, msg.getServer());
				if (server != null) {
					Bridge bridge = this.bridgeDao.query(con, server.getBridgeId());
					if (bridge != null) {
						CollectDevice device = this.collectDeviceDao.query(con, server.getId(), msg.getDevice());
						if (device != null) {
							String atime = items.get(0).getAtime();
							String cnt = "您负责管理维护的桥梁：【" + bridge.getShortName() + "】，于【" + atime.substring(0, 4) + "-" + atime.substring(4, 6) + "-"
									+ atime.substring(6, 8) + " " + atime.substring(8, 10) + ":" + atime.substring(10, 12) + ":" + atime.substring(12, 14)
									+ "】，编号为【" + device.getCode() + "】的采集盒发生一起报警事件，请尽快登录平台查看详细的报警信息。";
							List<User> users = this.userDao.queryByBridgeId(con, bridge.getId(), true);
							if (users != null && users.size() > 0) {
								for (User u : users) {
									msg.setUid(u.getId());
									this.alarmDao.insert(con, msg);
									notices.put(u, cnt);
								}
								this.alarmDao.insertAlarmDataItems(con, items);
							} else {
								errorData.put(pcnt, "NOT FOUND USER");
								items.clear();
							}
							this.alarmDao.insertAlarmDataItems(con, items);
						} else {
							errorData.put(pcnt, "NOT FOUND DEVICE");
							items.clear();
						}
					} else {
						errorData.put(pcnt, "NOT FOUND BRIDGE");
						items.clear();
					}
				} else {
					errorData.put(pcnt, "NOT FOUND SERVER");
					items.clear();
				}
			} else {
				items.clear();
			}
			if (items.size() > 0) {
				con.commit();
				JfwAppContext.getScheduledExecutorService().equals(new Runnable() {
					@Override
					public void run() {
				if (items.size() > 0) {
					con.commit();
					JfwAppContext.getScheduledExecutorService().equals(new Runnable() {
						@Override
						public void run() {
						for (Map.Entry<User, String> entry : notices.entrySet()) {
							User u = entry.getKey();
							String to = u.getEmail();
							try {
								if (to != null && to.length() > 0) {
									mailService.sendSimpleMail(to, "【" + u.getName() + "】您好：<br>" + entry.getValue(), null, "桥梁临控报警");
							for (Map.Entry<User, String> entry : notices.entrySet()) {
								User u = entry.getKey();
								String to = u.getEmail();
								try {
									if (to != null && to.length() > 0) {
										mailService.sendSimpleMail(to, "【" + u.getName() + "】您好：<br>" + entry.getValue(), null, "桥梁临控报警");
									}
								} catch (Throwable thr) {
								}
							} catch (Throwable thr) {
							}
							to = u.getPhone();
							try {
								if (to != null && to.length() > 0) {
									phoneService.sendMessage(to, "【__USERNAME__】您好：" + entry.getValue(), "__USERNAME__", u.getName());
								to = u.getPhone();
								try {
									if (to != null && to.length() > 0) {
										phoneService.sendMessage(to, "【__USERNAME__】您好：" + entry.getValue(), "__USERNAME__", u.getName());
									}
								} catch (Throwable thr) {
								}
							} catch (Throwable thr) {
							}
						}
					}
				});
						}
					});
				}
			} catch (Exception e) {
				if (null != con)
					JdbcUtil.rollback(con);
				items.clear();
			} finally {
				if (null != con)
					JdbcUtil.close(con);
			}
		} catch (Exception e) {
			if (null != con)
				JdbcUtil.rollback(con);
			items.clear();
		} finally {
			if (null != con)
				JdbcUtil.close(con);
		} else {
			if (errorData.isEmpty())
				errorData.put(pcnt, "ALARMDATA_PARSE");
		}
		response.setDateHeader("Expires", 0);
@@ -228,10 +264,29 @@ public class AlarmDataServlet extends HttpServlet {
		response.setContentType("application/json");
		java.io.PrintWriter out = response.getWriter();
		if (items.isEmpty()) {
			out.write("{\"status\":0,}");
			out.write("{\"status\":0}");
			try {
				Connection con = dataSource.getConnection();
				try {
					for (Map.Entry<String, String> entry : errorData.entrySet()) {
						AlarmDataError wde = new AlarmDataError();
						wde.setCnt(entry.getKey());
						wde.setReason(entry.getValue());
						wde.setRtime(System.currentTimeMillis());
						alarmDao.insert(con, wde);
					}
					con.commit();
				} catch (SQLException e) {
					con.rollback();
				} finally {
					con.close();
				}
			} catch (Throwable thr) {
			}
			return;
		}
		out.write("{\"status\":1,}");
		out.write("{\"status\":1}");
	}
	@Override

src/main/java/com/ekexiu/project/bridge/servlet/WaveDataServlet.java

@@ -17,6 +17,7 @@ import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
import org.jfw.apt.util.Base64;
import org.jfw.util.ConstData;
import org.jfw.util.context.JfwAppContext;
import org.jfw.util.io.IoUtil;
@@ -25,6 +26,7 @@ import org.jfw.util.reflect.TypeReference;
import com.ekexiu.project.bridge.collect.CollectDao;
import com.ekexiu.project.bridge.collect.CollectService;
import com.ekexiu.project.bridge.collect.WaveDataError;
import com.ekexiu.project.bridge.collect.WaveDataItem;
public class WaveDataServlet extends HttpServlet {
@@ -35,7 +37,8 @@ public class WaveDataServlet extends HttpServlet {
	@SuppressWarnings("unused")
	private static final LinkedList<List<WaveDataItem>> EMPTY_LIST = new LinkedList<List<WaveDataItem>>();
	public static Type DATA_TYPE=new TypeReference<List<Object>>(){}.getType();
	public static Type DATA_TYPE = new TypeReference<List<Object>>() {
	}.getType();
	private DataSource dataSource;
	private CollectDao collectDao;
@@ -49,79 +52,104 @@ public class WaveDataServlet extends HttpServlet {
		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		InputStream in = request.getInputStream();
		final List<WaveDataItem> items = new LinkedList<WaveDataItem>();
		final Map<String, String> errorData = new HashMap<String, String>();
		String cnt = null;
		List<Object> param = null;
		try {
			byte[] buf = new byte[8192];
			IoUtil.copy(in, baos, buf);
			List<Object> param = JsonService.fromJson(new String(baos.toByteArray(), ConstData.UTF8), DATA_TYPE);
			for (Object obj : param) {
				if (obj instanceof List) {
					WaveDataItem item = new WaveDataItem();
					Object tmpObj = ((List) obj).get(0);
					if (tmpObj instanceof String) {
						item.setSeq((String) tmpObj);
					} else {
						items.clear();
						break;
					}
					tmpObj = ((List) obj).get(3);
					if (tmpObj instanceof String) {
						item.setCtime((String) tmpObj);
					} else {
						items.clear();
						break;
					}
					tmpObj = ((List) obj).get(1);
					if (tmpObj instanceof String) {
						try {
							item.setDid(Integer.parseInt((String) tmpObj));
						} catch (Exception e) {
							items.clear();
							break;
						}
					} else {
						items.clear();
						break;
					}
					tmpObj = ((List) obj).get(2);
					if (tmpObj instanceof String) {
						try {
							item.setCid(Integer.parseInt((String) tmpObj));
						} catch (Exception e) {
							items.clear();
							break;
						}
					} else {
						items.clear();
						break;
			byte[] ba = baos.toByteArray();
			if (ba.length == 0) {
				errorData.put(" ", "EMPTY");
			} else {
				try {
					cnt = new String(baos.toByteArray(), ConstData.UTF8);
				} catch (Exception e) {
					errorData.put(new String(Base64.encodeBase64(ba), ConstData.UTF8), "CHARSET");
				}
				if (cnt != null) {
					try {
						param = JsonService.fromJson(cnt, DATA_TYPE);
					} catch (Exception e) {
						errorData.put(cnt, "JSON_PARSE");
					}
					tmpObj = ((List) obj).get(4);
					if (tmpObj instanceof String) {
						try {
							item.setLvalue(Integer.parseInt((String) tmpObj));
						} catch (Exception e) {
							items.clear();
							break;
					if (param != null) {
						for (Object obj : param) {
							if (obj instanceof List && ((List)obj).size()>5) {
								WaveDataItem item = new WaveDataItem();
								Object tmpObj = ((List) obj).get(0);
								if (tmpObj instanceof String) {
									item.setSeq((String) tmpObj);
								} else {
									items.clear();
									break;
								}
								tmpObj = ((List) obj).get(3);
								if (tmpObj instanceof String) {
									item.setCtime((String) tmpObj);
								} else {
									items.clear();
									break;
								}
								tmpObj = ((List) obj).get(1);
								if (tmpObj instanceof String) {
									try {
										item.setDid(Integer.parseInt((String) tmpObj));
									} catch (Exception e) {
										items.clear();
										break;
									}
								} else {
									items.clear();
									break;
								}
								tmpObj = ((List) obj).get(2);
								if (tmpObj instanceof String) {
									try {
										item.setCid(Integer.parseInt((String) tmpObj));
									} catch (Exception e) {
										items.clear();
										break;
									}
								} else {
									items.clear();
									break;
								}
								tmpObj = ((List) obj).get(4);
								if (tmpObj instanceof String) {
									try {
										item.setLvalue(Integer.parseInt((String) tmpObj));
									} catch (Exception e) {
										items.clear();
										break;
									}
								} else {
									items.clear();
									break;
								}
								tmpObj = ((List) obj).get(5);
								if (tmpObj instanceof String) {
									try {
										item.setHvalue(Integer.parseInt((String) tmpObj));
									} catch (Exception e) {
										items.clear();
										break;
									}
								} else {
									items.clear();
									break;
								}
								items.add(item);
							} else {
								items.clear();
								break;
							}
						}
					} else {
						items.clear();
						break;
					}
					tmpObj = ((List) obj).get(5);
					if (tmpObj instanceof String) {
						try {
							item.setHvalue(Integer.parseInt((String) tmpObj));
						} catch (Exception e) {
							items.clear();
							break;
					
						if(items.isEmpty()){
							errorData.put(cnt,"WAVEDATA_PARSE");
						}
					} else {
						items.clear();
						break;
					}
					items.add(item);
				} else {
					items.clear();
					break;
				}
			}
		} finally {
@@ -139,6 +167,31 @@ public class WaveDataServlet extends HttpServlet {
		java.io.PrintWriter out = response.getWriter();
		if (items.isEmpty()) {
			out.write("{\"status\":0}");
			JfwAppContext.getScheduledExecutorService().execute(new Runnable() {
				@Override
				public void run() {
					try {
						Connection con = dataSource.getConnection();
						try {
							for(Map.Entry<String,String> entry:errorData.entrySet()){
								WaveDataError wde = new WaveDataError();
								wde.setCnt(entry.getKey());
								wde.setReason(entry.getValue());
								wde.setRtime(System.currentTimeMillis());
								collectDao.insertWaveDataError(con, wde);
							}
							con.commit();
						} catch (SQLException e) {
							con.rollback();
						} finally {
							con.close();
						}
					} catch (Throwable thr) {
					}
				}
			});
			
			return;
		}
		out.write("{\"status\":1}");
@@ -165,7 +218,6 @@ public class WaveDataServlet extends HttpServlet {
		});
	}
	@Override
	public void init() throws ServletException {
		this.dataSource = JfwAppContext.getDataSource();

src/main/java/com/ekexiu/project/bridge/system/service/DictService.java

@@ -122,7 +122,7 @@ public class DictService {
	@Post
	@Path("/modify")
	public int update(@JdbcConn(true) Connection con, String code, String dict, @Nullable String bcode, String caption, @Nullable String fullCaption,
			@Nullable String shortCut, @Nullable String remark, boolean readonly, @AfterCommit List<Runnable> runs) throws SQLException {
			@Nullable String shortCut, @Nullable String remark, @AfterCommit List<Runnable> runs) throws SQLException {
		int num = this.dictDao.update(con, bcode, caption, fullCaption, shortCut, remark, code, dict);
		if (num > 0) {
			final DictItem item = new DictItem();