envdata

src/main/java/com/ekexiu/project/bridge/envdata/EnvDataService.java

@@ -29,17 +29,36 @@ public class EnvDataService {
        this.envDataDao = envDataDao;
    }
    public void setLastData(List<EnvData> lastData) {
        if (lastData.size() == 0) {
            return;
        }
        if (this.lastData.get().size() == 0) {
            this.lastData.set(lastData);
        } else {
            if (this.lastData.get().get(0).getCreateTime().compareTo(lastData.get(0).getCreateTime()) < 0) {
                this.lastData.set(lastData);
            }
        }
    }
    @Path
    @Get
    public List<EnvData> query(@JdbcConn Connection con)throws SQLException {
    public List<EnvData> query(@JdbcConn Connection con) throws SQLException {
        return envDataDao.query(con);
    }
    @Path("/byTime")
    @Get
    public List<EnvData> query(@JdbcConn Connection con, @DefaultValue("\"00000000000000\"")String bt, @DefaultValue("\"99999999999999\"")String et)throws SQLException {
    public List<EnvData> query(@JdbcConn Connection con, @DefaultValue("\"00000000000000\"") String bt, @DefaultValue("\"99999999999999\"") String et) throws SQLException {
        return envDataDao.query(con, bt, et);
    }
    @Path("/lastData")
    @Get
    public List<EnvData> query()throws SQLException {
        return lastData.get();
    }
}

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

@@ -1,6 +1,7 @@
package com.ekexiu.project.bridge.servlet;
import com.ekexiu.project.bridge.envdata.EnvData;
import com.ekexiu.project.bridge.envdata.EnvDataService;
import org.jfw.util.DateUtil;
import org.jfw.util.context.JfwAppContext;
@@ -28,6 +29,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
public class EnvDataServlet extends HttpServlet {
    private static final long serialVersionUID = 749116393196185727L;
    private DataSource dataSource;
    private EnvDataService envDataService;
    private List<EnvThread> envThreadList = new CopyOnWriteArrayList<EnvThread>();
    private ListenThread listenThread;
@@ -36,6 +38,10 @@ public class EnvDataServlet extends HttpServlet {
    @Override
    public void init(ServletConfig config) throws ServletException {
        dataSource = JfwAppContext.getDataSource();
        envDataService = (EnvDataService) JfwAppContext.getBeanFactory().getBean("com_ekexiu_project_bridge_envdata_EnvDataService");
        if (envDataService == null) {
            throw new ServletException("not found EnvDataService");
        }
        running.set(true);
        try {
            ServerSocket serverSocket = new ServerSocket(4000);
@@ -105,10 +111,12 @@ public class EnvDataServlet extends HttpServlet {
        @Override
        public void run() {
            int idx, len, ret, offset;
            InputStream inputStream = null;
            while (running.get()) {
                try {
                    InputStream inputStream = socket.getInputStream();
                    String createTime = DateUtil.formatDateTime(System.currentTimeMillis());
                    if (inputStream == null) {
                        inputStream = socket.getInputStream();
                    }
                    byte[] head = new byte[52];
                    idx = 0;
                    len = 52;
@@ -149,6 +157,7 @@ public class EnvDataServlet extends HttpServlet {
                            throw new IOException("a");
                        }
                    }
                    String createTime = DateUtil.formatDateTime(System.currentTimeMillis());
                    len = body.length;
                    offset = 0;
                    List<EnvData> list = new ArrayList<EnvData>();
@@ -199,6 +208,7 @@ public class EnvDataServlet extends HttpServlet {
                                ps.executeUpdate();
                            }
                            con.commit();
                            envDataService.setLastData(list);
                        } catch (SQLException e) {
                            con.rollback();
                        } finally {
@@ -207,8 +217,6 @@ public class EnvDataServlet extends HttpServlet {
                    } catch (Throwable thr) {
                    }
                } catch (Exception e) {
                    break;
                }