envdata

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

@@ -0,0 +1,52 @@
package com.ekexiu.project.bridge.envdata;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
/**
 * Created by TT on 2019/3/8.
 */
@Table(descp = "环境数据")
public class EnvData {
    private int itemId;
    private double itemValue;
    private String itemTime;
    private String createTime;
    @Column(descp = "ID", value = DE.int_de)
    public int getItemId() {
        return itemId;
    }
    public void setItemId(int itemId) {
        this.itemId = itemId;
    }
    @Column(descp = "值", value = DE.double_de)
    public double getItemValue() {
        return itemValue;
    }
    public void setItemValue(double itemValue) {
        this.itemValue = itemValue;
    }
    @Column(descp = "检测时间", value = DE.text_de)
    public String getItemTime() {
        return itemTime;
    }
    public void setItemTime(String itemTime) {
        this.itemTime = itemTime;
    }
    @Column(descp = "入库时间", value = DE.text_de)
    public String getCreateTime() {
        return createTime;
    }
    public void setCreateTime(String createTime) {
        this.createTime = createTime;
    }
}

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

@@ -0,0 +1,29 @@
package com.ekexiu.project.bridge.envdata;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import org.jfw.apt.orm.annotation.dao.param.Alias;
import org.jfw.apt.orm.annotation.dao.param.GtEq;
import org.jfw.apt.orm.annotation.dao.param.LtEq;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
/**
 * Created by TT on 2019/3/8.
 */
@DAO
public interface EnvDataDao {
    @SelectList
    @Where(" CREATE_TIME = (SELECT MAX(CREATE_TIME) FROM ENV_DATA) ")
    List<EnvData> query(Connection con) throws SQLException;
    @SelectList
    @OrderBy("ORDER BY CREATE_TIME DESC")
    List<EnvData> query(Connection con, @GtEq @Alias("createTime")String bt,@LtEq @Alias("createTime") String et) throws SQLException;
}

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

@@ -0,0 +1,45 @@
package com.ekexiu.project.bridge.envdata;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.param.JdbcConn;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import java.util.concurrent.atomic.AtomicReference;
/**
 * Created by TT on 2019/3/8.
 */
@Path("/envData")
public class EnvDataService {
    private AtomicReference<List<EnvData>> lastData = new AtomicReference<List<EnvData>>();
    @Autowrie
    private EnvDataDao envDataDao;
    public EnvDataDao getEnvDataDao() {
        return envDataDao;
    }
    public void setEnvDataDao(EnvDataDao envDataDao) {
        this.envDataDao = envDataDao;
    }
    @Path
    @Get
    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 {
        return envDataDao.query(con, bt, et);
    }
}

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

@@ -1,21 +1,17 @@
package com.ekexiu.project.bridge.servlet;
import com.ekexiu.project.bridge.envdata.EnvData;
import org.jfw.util.DateUtil;
import org.jfw.util.context.JfwAppContext;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.jdbc.PreparedStatementConfig;
import org.jfw.util.json.JsonService;
import static java.lang.Thread.sleep;
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
import java.io.IOException;
import java.io.InputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.sql.Connection;
@@ -23,7 +19,6 @@ import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.atomic.AtomicBoolean;
@@ -38,74 +33,6 @@ public class EnvDataServlet extends HttpServlet {
    private AtomicBoolean running = new AtomicBoolean(false);
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse res) throws ServletException, IOException {
        res.setDateHeader("Expires", 0);
        res.setHeader("Cache-Control", "no-store, no-cache, must-revalidate");
        res.addHeader("Cache-Control", "post-check=0, pre-check=0");
        res.setHeader("Pragma", "no-cache");
        List<Map<String, Object>> result = null;
        if (null == req.getCharacterEncoding()) {
            req.setCharacterEncoding("UTF-8");
            res.setCharacterEncoding("UTF-8");
        }
        res.setContentType("text/html");
        PrintWriter out = res.getWriter();
        try {
            String param = req.getParameter("bt");
            String bt = "00000000000000";
            if (null != param && param.length() != 0) {
                bt = param;
            }
            param = req.getParameter("et");
            String et = "99999999999999";
            if (null != param && param.length() != 0) {
                et = param;
            }
            Connection con = this.dataSource.getConnection();
            try {
                result = query(con, bt, et);
            } finally {
                try {
                    con.close();
                } catch (Throwable _m_1) {
                }
            }
        } catch (Exception e) {
            JsonService.write(e, out);
            return;
        }
        out.write("<!DOCTYPE html><html><head><meta http-equiv='Content-Type' content='text/html; charset=UTF-8'></head><body>");
        out.write("<table border=\"1\">\n" +
                "<tr>\n" +
                "  <td>id</td>\n" +
                "  <td>显示内容</td>\n" +
                "  <td>单位</td>\n" +
                "  <td>值</td>\n" +
                "  <td>更新时间</td>\n" +
                "</tr>");
        for (Map<String, Object> map : result) {
            out.write("<tr>\n" +
                    "  <td>" + map.get("item_id") + "</td>\n" +
                    "  <td>" + map.get("caption") + "</td>\n" +
                    "  <td>" + map.get("unit") + "</td>\n" +
                    "  <td>" + map.get("item_value") + "</td>\n" +
                    "  <td>" + map.get("item_time") + "</td>\n" +
                    "</tr>");
        }
        out.write("</table></body></html>");
    }
    public List<Map<String, Object>> query(Connection con, final String bt, final String et) throws SQLException {
        return JdbcUtil.queryMaps(con, "SELECT e.item_id,COALESCE(d.caption, '没有对应值') as caption,COALESCE(d.unit, '没有对应值') as unit,e.item_value,e.item_time FROM env_data e LEFT JOIN env_id_dict d on e.item_id = d.item_id where e.item_time>= ? and e.item_time<=?", new PreparedStatementConfig() {
            @Override
            public void config(PreparedStatement preparedStatement) throws SQLException {
                preparedStatement.setString(1, bt);
                preparedStatement.setString(2, et);
            }
        });
    }
    @Override
    public void init(ServletConfig config) throws ServletException {
        dataSource = JfwAppContext.getDataSource();
@@ -181,6 +108,7 @@ public class EnvDataServlet extends HttpServlet {
            while (running.get()) {
                try {
                    InputStream inputStream = socket.getInputStream();
                    String createTime = DateUtil.formatDateTime(System.currentTimeMillis());
                    byte[] head = new byte[52];
                    idx = 0;
                    len = 52;
@@ -255,6 +183,7 @@ public class EnvDataServlet extends HttpServlet {
                        envData.setItemId(id);
                        envData.setItemValue(value);
                        envData.setItemTime(new String(timeArray));
                        envData.setCreateTime(createTime);
                        list.add(envData);
                    }
@@ -262,10 +191,11 @@ public class EnvDataServlet extends HttpServlet {
                        Connection con = dataSource.getConnection();
                        try {
                            for (EnvData envData : list) {
                                PreparedStatement ps = con.prepareStatement("INSERT INTO ENV_DATA (ITEM_ID,ITEM_VALUE,ITEM_TIME) VALUES (?,?,?)");
                                PreparedStatement ps = con.prepareStatement("INSERT INTO ENV_DATA (ITEM_ID,ITEM_VALUE,ITEM_TIME,CREATE_TIME) VALUES (?,?,?,?)");
                                ps.setInt(1, envData.getItemId());
                                ps.setDouble(2, envData.getItemValue());
                                ps.setString(3, envData.getItemTime());
                                ps.setString(4, envData.getCreateTime());
                                ps.executeUpdate();
                            }
                            con.commit();
@@ -311,36 +241,6 @@ public class EnvDataServlet extends HttpServlet {
        return Double.longBitsToDouble(value);
    }
    public static class EnvData {
        private int itemId;
        private double itemValue;
        private String itemTime;
        public int getItemId() {
            return itemId;
        }
        public void setItemId(int itemId) {
            this.itemId = itemId;
        }
        public double getItemValue() {
            return itemValue;
        }
        public void setItemValue(double itemValue) {
            this.itemValue = itemValue;
        }
        public String getItemTime() {
            return itemTime;
        }
        public void setItemTime(String itemTime) {
            this.itemTime = itemTime;
        }
    }
}