1

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

@@ -0,0 +1,17 @@
package com.ekexiu.project.bridge.collect;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.orm.annotation.dao.Batch;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
@DAO
public interface CollectDao {
	@Insert
	@Batch
	int[] insert(Connection con,List<WaveDataItem> items)throws SQLException;
}

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

@@ -0,0 +1,43 @@
package com.ekexiu.project.bridge.collect;
import java.util.List;
import java.util.Map;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
@Path("/collect")
public class CollectService {
	private Map<String, List<WaveDataItem>> waveCache;
	@Autowrie
	private CollectDao collectDao;
	public CollectDao getCollectDao() {
		return collectDao;
	}
	public void setCollectDao(CollectDao collectDao) {
		this.collectDao = collectDao;
	}
	public Map<String, List<WaveDataItem>> getWaveCache() {
		return waveCache;
	}
	public void setWaveCache(Map<String, List<WaveDataItem>> waveCache) {
		this.waveCache = waveCache;
	}
	@Get
	@Path("/wave/curr")
	public List<WaveDataItem> wave(String seq) {
		List<WaveDataItem> ret = null;
		synchronized (this.waveCache) {
			ret = waveCache.get(seq);
		}
		return ret;
	}
}

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

@@ -0,0 +1,64 @@
package com.ekexiu.project.bridge.collect;
public class WaveDataItem {
	private String ctime;
	private String seq;
	private int did;
	private int cid;
	private int hvalue;
	private int lvalue;
	private String htime;
	private String ltime;
	
	
	
	public String getSeq() {
		return seq;
	}
	public void setSeq(String seq) {
		this.seq = seq;
	}
	public String getCtime() {
		return ctime;
	}
	public void setCtime(String ctime) {
		this.ctime = ctime;
	}
	public int getDid() {
		return did;
	}
	public void setDid(int did) {
		this.did = did;
	}
	public int getCid() {
		return cid;
	}
	public void setCid(int cid) {
		this.cid = cid;
	}
	public int getHvalue() {
		return hvalue;
	}
	public void setHvalue(int hvalue) {
		this.hvalue = hvalue;
	}
	public int getLvalue() {
		return lvalue;
	}
	public void setLvalue(int lvalue) {
		this.lvalue = lvalue;
	}
	public String getHtime() {
		return htime;
	}
	public void setHtime(String htime) {
		this.htime = htime;
	}
	public String getLtime() {
		return ltime;
	}
	public void setLtime(String ltime) {
		this.ltime = ltime;
	}
	
}

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

@@ -26,6 +26,7 @@ public class VerifyCodeServlet extends HttpServlet {
	private static final long serialVersionUID = -384069991394456296L;
	private static final String DEFAULT_VERIFY_FLAG = "PIC_COMM";
	private static final String QUERY_FLAG ="exists";
	private static final long DEFAULT_TIMEOUT = 1000 * 60;
	private static final int DEFAULT_VERIFY_LEN = 4;
	private static final int DEFAULT_IMG_WIDTH = 100;
@@ -109,11 +110,35 @@ public class VerifyCodeServlet extends HttpServlet {
	}
	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		response.setHeader("Pragma", "No-cache");
		response.setHeader("Cache-Control", "no-cache");
		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");
		HttpSession session = request.getSession();
		String flag = request.getParameter("flag");
		if (flag == null || flag.length() == 0) {
			flag = DEFAULT_VERIFY_FLAG;
		}
		String val = request.getParameter(QUERY_FLAG);
		if(val!=null){
	        if(null == request.getCharacterEncoding()){
	            request.setCharacterEncoding("UTF-8");
	            request.setCharacterEncoding("UTF-8");
	        }
	        response.setContentType("application/json");
	        java.io.PrintWriter out = response.getWriter();
	        out.write("{\"success\":true,\"data\":");
			Long to = (Long)session.getAttribute("TIMEOUT_"+flag);
			if( val.equals(session.getAttribute(flag)) &&  (to!=null) && (to.longValue()>System.currentTimeMillis())){
			     	  out.write("true}");
	        }else{
	        	  out.write("false}");
	        	  session.removeAttribute("TIMEOUT_"+flag);
	        	  session.removeAttribute(flag);
	        }
	        return;
		}
		response.setContentType("image/jpeg");
		int width = 0, height = 0, len = 0;
		try {
			width = Integer.parseInt(request.getParameter("w"));
@@ -133,18 +158,11 @@ public class VerifyCodeServlet extends HttpServlet {
			len = Integer.parseInt(request.getParameter("l"));
		} catch (Exception e) {
		}
		if (width < 4 || width > 10) {
			width = DEFAULT_VERIFY_LEN;
		if (len < 4 || len > 10) {
			len = DEFAULT_VERIFY_LEN;
		}
		String flag = request.getParameter("flag");
		if (flag == null || flag.length() == 0) {
			flag = DEFAULT_VERIFY_FLAG;
		}
		String vc = generateVerifyCode(len, VERIFY_CODES);
		outputImage(width, height, response.getOutputStream(), vc);
		HttpSession session = request.getSession();
		session.setAttribute(flag, vc);
		long timeout = 0;
		try {
@@ -156,7 +174,6 @@ public class VerifyCodeServlet extends HttpServlet {
		}
		timeout += (5000 + System.currentTimeMillis());
		session.setAttribute("TIMEOUT_" + flag, timeout);
	}
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

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

@@ -0,0 +1,267 @@
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.DateUtil;
import org.jfw.util.context.JfwAppContext;
import org.jfw.util.io.IoUtil;
import org.jfw.util.json.JsonService;
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.WaveDataItem;
public class WaveDataServlet extends HttpServlet {
	private static final long serialVersionUID = 5218822832173871831L;
	private static final Map<String, List<WaveDataItem>> DATA_CACHE = new HashMap<String, List<WaveDataItem>>();
	@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();
	private DataSource dataSource;
	private CollectDao collectDao;
	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		response.sendError(400);
	}
	@SuppressWarnings("unchecked")
	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 {
							items.clear();
							break;
						}
					}
				}
			}
		} finally {
			in.close();
		}
		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;
		}
		List<WaveDataItem> olist = null;
		synchronized (DATA_CACHE) {
			olist = DATA_CACHE.get(serverId);
		}
		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() {
					try {
						Connection con = dataSource.getConnection();
						try {
							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();
		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");
		}
		CollectService s = (CollectService) JfwAppContext.getBeanFactory().getBean("com_ekexiu_project_bridge_collect_CollectService");
		if (s == null) {
			throw new ServletException("not found CollectService");
		}
		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());
			}
		}
	}
}