11

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

@@ -1,13 +1,19 @@
package com.ekexiu.project.bridge.collect;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
@PrimaryKey({"id","seq"})
@Table(descp="报警数据")
public class AlarmDataItem {
    private String id;
    private int seq;
    private String stime;
    private String atime;
    private String data;
    
    @Column(descp="报警编号",value=DE.text_de)
	public String getId() {
		return id;
@@ -16,6 +22,40 @@ public class AlarmDataItem {
	public void setId(String id) {
		this.id = id;
	}
	@Column(descp="传感内部编号",value=DE.int_de)
	public int getSeq() {
		return seq;
	}
	public void setSeq(int seq) {
		this.seq = seq;
	}
    @Column(descp="起始时间",value=DE.text_de)
	public String getStime() {
		return stime;
	}
	public void setStime(String stime) {
		this.stime = stime;
	}
    @Column(descp="报警时间",value=DE.text_de)
	public String getAtime() {
		return atime;
	}
	public void setAtime(String atime) {
		this.atime = atime;
	}
    @Column(descp="报警数据，共300个数据点，以英文逗号分隔",value=DE.text_de)
	public String getData() {
		return data;
	}
	public void setData(String data) {
		this.data = data;
	}
    
	
	
    
}

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

@@ -0,0 +1,74 @@
package com.ekexiu.project.bridge.collect;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.defaultImpl.FixLenStringHandler;
import org.jfw.apt.orm.core.enums.DE;
@PrimaryKey({"uid","aid"})
@Table(descp="报警消息")
public class AlarmMsg {
	private String uid;
	private String aid;
	private String seq;
	private int  device;
	private boolean readed;
	private String readTime;
	private String createTime;
	
	@Column(descp="用户ID",value=DE.refid_32)
	public String getUid() {
		return uid;
	}
	public void setUid(String uid) {
		this.uid = uid;
	}
	@Column(descp="报警ID",value=DE.text_de)
	public String getAid() {
		return aid;
	}
	public void setAid(String aid) {
		this.aid = aid;
	}
	@Column(descp="采集服务器内部编号",value=DE.text_de)
	public String getSeq() {
		return seq;
	}
	public void setSeq(String seq) {
		this.seq = seq;
	}
	@Column(descp="采集盒内部编号",value=DE.int_de)
	public int getDevice() {
		return device;
	}
	public void setDevice(int device) {
		this.device = device;
	}
	@Column(descp="是否已读",value=DE.boolean_de,fixSqlValueWithInsert="'0'")
	public boolean isReaded() {
		return readed;
	}
	public void setReaded(boolean readed) {
		this.readed = readed;
	}
	@Column(descp="读取时间",value=DE.Text_de)
	public String getReadTime() {
		return readTime;
	}
	public void setReadTime(String readTime) {
		this.readTime = readTime;
	}
	@Column(descp="创建时间（YYYYMMDDHH24MISS）不可修改", handlerClass = FixLenStringHandler.class, dbType = "CHAR(14)", fixSqlValueWithInsert = "TO_CHAR(NOW(),'YYYYMMDDHH24MISS')", insertable = true, nullable = false, queryable = true, renewable = false)
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	
	
	
	
}

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

@@ -31,4 +31,10 @@ public interface CollectDao {
	@SelectList
	@OrderBy("ORDER BY CTIME")
	List<WaveDataItem> query(Connection con,String seq,int did,int cid,@Alias("ctime") @GtEq String btime,@Alias("ctime") @LtEq String etime)throws SQLException;
	
	@Insert
	int insert(Connection con,AlarmMsg msg)throws SQLException;
	@Insert
	@Batch
	int[] insert(Connection con,AlarmDataItem[] items)throws SQLException;
}

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

@@ -14,8 +14,7 @@ public class WaveDataItem {
	private int cid;
	private int hvalue;
	private int lvalue;
	private String htime;
	private String ltime;
	
	
	@Column(descp="采集服务器内部编号",value=DE.text_de)
@@ -60,19 +59,4 @@ public class WaveDataItem {
	public void setLvalue(int lvalue) {
		this.lvalue = lvalue;
	}
	@Column(descp="一秒内最大幅度值时间（YYYYMMDDHH24MISS.zzz）",value=DE.text_de)
	public String getHtime() {
		return htime;
	}
	public void setHtime(String htime) {
		this.htime = htime;
	}
	@Column(descp="一秒内最小幅度值时间（YYYYMMDDHH24MISS.zzz）",value=DE.text_de)
	public String getLtime() {
		return ltime;
	}
	public void setLtime(String ltime) {
		this.ltime = ltime;
	}
	
}

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

@@ -0,0 +1,199 @@
package com.ekexiu.project.bridge.servlet;
import java.io.ByteArrayOutputStream;
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;
import java.util.Map;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
import org.jfw.util.ConstData;
import org.jfw.util.context.JfwAppContext;
import org.jfw.util.io.IoUtil;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.json.JsonService;
import org.jfw.util.reflect.TypeReference;
import com.ekexiu.project.bridge.collect.AlarmDataItem;
import com.ekexiu.project.bridge.collect.AlarmMsg;
import com.ekexiu.project.bridge.collect.CollectDao;
import com.ekexiu.project.bridge.collect.CollectService;
import com.ekexiu.project.bridge.collect.WaveDataItem;
import com.ekexiu.project.bridge.resource.po.Bridge;
import com.ekexiu.project.bridge.system.dao.UserDao;
import com.ekexiu.project.bridge.system.po.User;
public class AlarmDataServlet extends HttpServlet {
	private static final long serialVersionUID = 4989044137656168797L;
	public static Type DATA_TYPE=new TypeReference<Map<Object,Object>>(){}.getType();
	private DataSource dataSource;
	private CollectDao collectDao;
	private UserDao userDao;
	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		response.sendError(400);
	}
	@SuppressWarnings({ "rawtypes", "unchecked" })
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		InputStream in = request.getInputStream();
		 List<AlarmDataItem> items = new LinkedList<AlarmDataItem>();
		final AlarmMsg msg = new AlarmMsg();
		StringBuilder sb = new StringBuilder();
		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.setSeq((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){
						}
					}
				}
			}
			if(datas!=null){
				for(Object obj:datas){
					AlarmDataItem 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);
						}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(",");
							}
						}
						if(sb.length()>0){
							item.setData(sb.substring(0,sb.length()-1));
						}else{
							items.clear();
							break;
						}
					}
				}
			}
		} finally {
			in.close();
		}
		
		Connection con = this.dataSource.getConnection();
		try{
		//	final Bridge bridge = this
			
		//	List<User> users = this.userDao.queryByBridgeCode(con, msg.getSeq(), true);
			
			
		}finally{
			JdbcUtil.close(con);
		}
		
		response.setDateHeader("Expires", 0);
		response.setHeader("Cache-Control", "no-store, no-cache, must-revalidate");
		response.addHeader("Cache-Control", "post-check=0, pre-check=0");
		response.setHeader("Pragma", "no-cache");
		if (null == request.getCharacterEncoding()) {
			request.setCharacterEncoding("UTF-8");
			request.setCharacterEncoding("UTF-8");
		}
		response.setContentType("application/json");
		java.io.PrintWriter out = response.getWriter();
		if (items.isEmpty()) {
			out.write("{\"status\":0,}");
			return;
		}
		out.write("{\"status\":1,}");
		synchronized (DATA_CACHE) {
			DATA_CACHE.put(items.get(0).getSeq(), items);
		}
		JfwAppContext.getScheduledExecutorService().execute(new Runnable() {
			@Override
			public void run() {
				try {
					Connection con = dataSource.getConnection();
					try {
						collectDao.insert(con, items);
						con.commit();
					} catch (SQLException e) {
						con.rollback();
					} finally {
						con.close();
					}
				} catch (Throwable thr) {
				}
			}
		});
	}
	@Override
	public void init() throws ServletException {
		this.dataSource = JfwAppContext.getDataSource();
		if (this.dataSource == null) {
			throw new ServletException("not found datasource");
		}
		this.collectDao = (CollectDao) JfwAppContext.getBeanFactory().getBean("com_ekexiu_project_bridge_collect_CollectDao");
		if (this.dataSource == null) {
			throw new ServletException("not found collectDao");
		}
		this.userDao = (UserDao) JfwAppContext.getBeanFactory().getBean("com_ekexiu_project_bridge_system_dao_UserDao");
		if (userDao == null) {
			throw new ServletException("not found userDao");
		}
	}
}

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

@@ -18,7 +18,6 @@ import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
import org.jfw.util.ConstData;
import org.jfw.util.DateUtil;
import org.jfw.util.context.JfwAppContext;
import org.jfw.util.io.IoUtil;
import org.jfw.util.json.JsonService;
@@ -36,8 +35,7 @@ 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<Map<String, Object>>() {
	}.getType();
	public static Type DATA_TYPE=new TypeReference<List<Object>>(){}.getType();
	private DataSource dataSource;
	private CollectDao collectDao;
@@ -46,95 +44,83 @@ public class WaveDataServlet extends HttpServlet {
		response.sendError(400);
	}
	@SuppressWarnings("unchecked")
	@SuppressWarnings({ "rawtypes" })
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		InputStream in = request.getInputStream();
		final List<WaveDataItem> items = new LinkedList<WaveDataItem>();
		long currTime = System.currentTimeMillis();
		String ctime = DateUtil.formatDateTime(currTime);
		// String otime = DateUtil.formatDateTime(currTime -(5* 60*1000));
		String serverId = null;
		try {
			byte[] buf = new byte[8192];
			IoUtil.copy(in, baos, buf);
			Map<String, Object> map = JsonService.fromJson(new String(baos.toByteArray(), ConstData.UTF8), DATA_TYPE);
			Object tmpObj = map.get("node_id");
			if (null != tmpObj && (tmpObj instanceof String)) {
				serverId = (String) tmpObj;
				tmpObj = map.get("data");
				if (null != tmpObj && (tmpObj instanceof List)) {
					List<Object> ds = (List<Object>) tmpObj;
					for (Object wo : ds) {
						WaveDataItem item = new WaveDataItem();
						item.setCtime(ctime);
						item.setSeq(serverId);
						if (wo instanceof Map) {
							Map<Object, Object> im = (Map<Object, Object>) wo;
							tmpObj = im.get("box_id");
							if (tmpObj == null || (!(tmpObj instanceof Double))) {
								items.clear();
								break;
							}
							item.setDid(((Double) tmpObj).intValue());
							tmpObj = im.get("box_id");
							if (tmpObj == null || (!(tmpObj instanceof Double))) {
								items.clear();
								break;
							}
							item.setCid(((Double) tmpObj).intValue());
							tmpObj = im.get("value");
							if (null == tmpObj && (!(tmpObj instanceof List))) {
								items.clear();
								break;
							}
							List<Object> vs = (List<Object>) tmpObj;
							if (vs.size() != 2) {
								items.clear();
								break;
							}
							tmpObj = vs.get(0);
							if (tmpObj == null || (!(tmpObj instanceof List)) || (2 != ((List<?>) tmpObj).size())) {
								items.clear();
								break;
							}
							List<Object> vi = (List<Object>) tmpObj;
							tmpObj = vi.get(0);
							if (tmpObj == null || (!(tmpObj instanceof String))) {
								items.clear();
								break;
							}
							item.setLtime((String) tmpObj);
							tmpObj = vi.get(1);
							if (tmpObj == null || (!(tmpObj instanceof Double))) {
								items.clear();
								break;
							}
							item.setLvalue(((Double) tmpObj).intValue());
							tmpObj = vs.get(1);
							if (tmpObj == null || (!(tmpObj instanceof List)) || (2 != ((List<?>) tmpObj).size())) {
								items.clear();
								break;
							}
							vi = (List<Object>) tmpObj;
							tmpObj = vi.get(0);
							if (tmpObj == null || (!(tmpObj instanceof String))) {
								items.clear();
								break;
							}
							item.setHtime((String) tmpObj);
							tmpObj = vi.get(1);
							if (tmpObj == null || (!(tmpObj instanceof Double))) {
								items.clear();
								break;
							}
							item.setHvalue(((Double) tmpObj).intValue());
							items.add(item);
						} else {
			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;
					}
					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;
					}
				} else {
					items.clear();
					break;
				}
			}
		} finally {
@@ -154,38 +140,31 @@ public class WaveDataServlet extends HttpServlet {
			out.write("{\"status\":0,}");
			return;
		}
		List<WaveDataItem> olist = null;
		out.write("{\"status\":1,}");
		synchronized (DATA_CACHE) {
			olist = DATA_CACHE.get(serverId);
			DATA_CACHE.put(items.get(0).getSeq(), items);
		}
		if (olist == null || olist.get(0).getCtime().compareTo(ctime) < 0) {
			synchronized (DATA_CACHE) {
				DATA_CACHE.put(serverId, items);
			}
			JfwAppContext.getScheduledExecutorService().execute(new Runnable() {
				@Override
				public void run() {
		JfwAppContext.getScheduledExecutorService().execute(new Runnable() {
			@Override
			public void run() {
				try {
					Connection con = dataSource.getConnection();
					try {
						Connection con = dataSource.getConnection();
						try {
							collectDao.insert(con, items);
							con.commit();
						} catch (SQLException e) {
							con.rollback();
						} finally {
							con.close();
						}
					} catch (Throwable thr) {
						collectDao.insert(con, items);
						con.commit();
					} catch (SQLException e) {
						con.rollback();
					} finally {
						con.close();
					}
				} catch (Throwable thr) {
				}
			});
		}
		out.write("{\"status\":1,}");
		return;
			}
		});
	}
	@Override
	public void init() throws ServletException {
		this.dataSource = JfwAppContext.getDataSource();
@@ -202,66 +181,4 @@ public class WaveDataServlet extends HttpServlet {
		}
		s.setWaveCache(DATA_CACHE);
	}
	public static void main(String args[]) throws Exception {
		Map<Object, Object> map = JsonService.fromJson("{\r\n" + "\"node_id\": \"12345\",\r\n" + "    \"data\": [	\r\n" + "        {		\r\n"
				+ "            \"box_id\": 1, \r\n" + "            \"channel_id\": 1, 	\r\n" + "            \"value\": [	\r\n" + "                [\r\n"
				+ "                    \"20180101101010.000\",	\r\n" + "                    -12	\r\n" + "                ], \r\n" + "                [\r\n"
				+ "                    \"20180101101011.500\", \r\n" + "                    13			\r\n" + "                ]\r\n" + "            ]\r\n"
				+ "        }, \r\n" + "        {\r\n" + "            \"box_id\": 2, \r\n" + "            \"channel_id\": 9, \r\n"
				+ "            \"value\": [\r\n" + "                [\r\n" + "                    \"20180101101010.100\", \r\n" + "                    -2\r\n"
				+ "                ], \r\n" + "                [\r\n" + "                    \"20180101101011.200\", \r\n" + "                    34\r\n"
				+ "                ]\r\n" + "            ]\r\n" + "        }\r\n" + "    ]\r\n" + "}", DATA_TYPE);
		outMap(0, map);
	}
	@SuppressWarnings("unchecked")
	public static void outList(int left, List<Object> list) {
		for (Object obj : list) {
			for (int i = 0; i < left; ++i) {
				System.out.print(" ");
			}
			System.out.print(obj.getClass().getName() + "  ");
			if (obj instanceof List) {
				System.out.println("===>List");
				outList(left + 8, (List<Object>) obj);
			} else if (obj instanceof Map) {
				System.out.println("===>Map");
				outMap(left + 8, (Map<Object, Object>) obj);
			} else {
				System.out.println("===>" + ((obj instanceof Double) ? ((Double) obj).intValue() : obj.toString()));
			}
		}
	}
	@SuppressWarnings("unchecked")
	public static void outMap(int left, Map<Object, Object> map) {
		for (Map.Entry<Object, Object> entry : map.entrySet()) {
			for (int i = 0; i < left; ++i) {
				System.out.print(" ");
			}
			Object obj = entry.getKey();
			System.out.println("KEY:" + obj.getClass().getName() + "    " + obj.toString());
			for (int i = 0; i < left; ++i) {
				System.out.print(" ");
			}
			obj = entry.getValue();
			System.out.print("VALUE:");
			if (obj instanceof List) {
				System.out.println("===>List");
				outList(left + 8, (List<Object>) obj);
			} else if (obj instanceof Map) {
				System.out.println("===>Map");
				outMap(left + 8, (Map<Object, Object>) obj);
			} else {
				System.out.println("===>" + obj.getClass().getName() + "       " + obj.toString());
			}
		}
	}
}