统计数据

src/main/java/com/ekexiu/project/platform/views/handler/db/TimeLogHandler.java

@@ -80,11 +80,22 @@ public class TimeLogHandler extends DbLogHandler {
            ps.setString(2, id);
            ps.setString(3, day);
            ps.setString(4, source);
            int p = ps.executeUpdate();
            ps = this.con.prepareStatement(this.updateSumSql);
            return ps.executeUpdate()==1;
        } finally {
            try {
                ps.close();
            } catch (Exception e) {
            }
        }
    }
    private boolean updateSum(String id, int pv) throws SQLException {
        PreparedStatement ps =this.con.prepareStatement(this.updateSumSql);
        try {
            ps.setInt(1, pv);
            ps.setString(2, id);
            return p==1&&ps.executeUpdate() == 1;
            return ps.executeUpdate() == 1;
        } finally {
            try {
                ps.close();
@@ -101,7 +112,18 @@ public class TimeLogHandler extends DbLogHandler {
            ps.setString(3, day);
            ps.setString(4, source);
            ps.executeUpdate();
            ps = this.con.prepareStatement(this.insertSumSql);
        } finally {
            try {
                ps.close();
            } catch (Exception e) {
            }
        }
    }
    public void insertSum(String id) throws SQLException {
        PreparedStatement ps = this.con.prepareStatement(this.insertSumSql);
        try {
            ps.setString(1, id);
            ps.setInt(2, 1);
            ps.executeUpdate();
@@ -122,6 +144,9 @@ public class TimeLogHandler extends DbLogHandler {
            String source = day.substring(8, 9);
            String id = day.substring(9);
            day = day.substring(0, 8);
            if (!this.updateSum(id, pv)) {
                this.insertSum(id);
            }
            if (!this.update(id, day, source, pv)) {
                this.insert(id, day, source, pv);
            }

src/main/java/com/ekexiu/project/platform/views/service/Main.java

@@ -12,6 +12,7 @@ import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.ParameterMap;
import org.jfw.util.PageQueryResult;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.jdbc.PreparedStatementConfig;
@@ -27,11 +28,20 @@ public class Main {
    public static final String MIN_DAY = "00000000";
    private List<String> tns;
    private List<LogHandler> handlers;
    @Autowrie
    private DayDao dayDao;
    public List<String> getTns() {
        return tns;
    }
    public void setTns(List<String> tns) {
        this.tns = tns;
    }
    public List<LogHandler> getHandlers() {
        return handlers;
    }
@@ -59,21 +69,44 @@ public class Main {
    @Get
    @Path("/qm")
    public List<DayData> query(@JdbcConn Connection con, String tn, @Nullable String[] src, @Nullable String[] id, @DefaultValue("com.ekexiu.project.platform.views.service.Main.MIN_DAY") String bt,
                               @DefaultValue("com.ekexiu.project.platform.views.service.Main.MAX_DAY") String et, @Nullable String sort) throws SQLException {
                               @DefaultValue("com.ekexiu.project.platform.views.service.Main.MAX_DAY") String et, @Nullable String sort) throws SQLException, JfwBaseException {
        if (!this.tns.contains(tn)) {
            throw new JfwBaseException(-101, "unavailable tn");
        }
        return dayDao.query(con, tn, src, id, bt, et, sort);
    }
    @Get
    @Path("/qo")
    public List<DayData> query(@JdbcConn Connection con, String tn, String id, @DefaultValue("com.ekexiu.project.platform.views.service.Main.MIN_DAY") String bt,
                               @DefaultValue("com.ekexiu.project.platform.views.service.Main.MAX_DAY") String et) throws SQLException {
                               @DefaultValue("com.ekexiu.project.platform.views.service.Main.MAX_DAY") String et) throws SQLException, JfwBaseException {
        if (!this.tns.contains(tn)) {
            throw new JfwBaseException(-101, "unavailable tn");
        }
        return dayDao.query(con, tn, id, bt, et);
    }
    @Get
    @Path("/qo/sum")
    public int query(@JdbcConn Connection con, String tn, final String id) throws SQLException,JfwBaseException {
        if (!this.tns.contains(tn)) {
            throw new JfwBaseException(-101, "unavailable tn");
        }
        return JdbcUtil.queryInt(con, "SELECT SUM FROM " + tn + "_DAY_SUM WHERE ID = ?", new PreparedStatementConfig() {
            @Override
            public void config(PreparedStatement preparedStatement) throws SQLException {
                preparedStatement.setString(1, id);
            }
        }, 0);
    }
    @Get
    @Path("/qs")
    public List<DayData> query(@JdbcConn Connection con, String tn, @Nullable String[] src, @DefaultValue("com.ekexiu.project.platform.views.service.Main.MIN_DAY") String bt,
                               @DefaultValue("com.ekexiu.project.platform.views.service.Main.MAX_DAY") String et, @DefaultValue("20") int rows) throws SQLException {
                               @DefaultValue("com.ekexiu.project.platform.views.service.Main.MAX_DAY") String et, @DefaultValue("20") int rows) throws SQLException, JfwBaseException {
        if (!this.tns.contains(tn)) {
            throw new JfwBaseException(-101, "unavailable tn");
        }
        return dayDao.query(con, tn, bt, et, src, rows);
    }
@@ -89,9 +122,12 @@ public class Main {
    }
    @Get
    @Path("/article/total")
    public List<Map<String, Object>> total(@JdbcConn Connection con, @DefaultValue("com.ekexiu.project.platform.views.service.Main.MIN_DAY") final String bt) throws SQLException {
        return JdbcUtil.queryMaps(con, "SELECT day,sum(pv)as pv,source FROM article_day WHERE day>=? GROUP BY day,source ORDER BY day DESC ", new PreparedStatementConfig() {
    @Path("/total")
    public List<Map<String, Object>> total(@JdbcConn Connection con,String tn, @DefaultValue("com.ekexiu.project.platform.views.service.Main.MIN_DAY") final String bt) throws SQLException, JfwBaseException {
        if (!this.tns.contains(tn)) {
            throw new JfwBaseException(-101, "unavailable tn");
        }
        return JdbcUtil.queryMaps(con, "SELECT day,sum(pv)as pv,source FROM "+tn+"_day WHERE day>=? GROUP BY day,source ORDER BY day DESC ", new PreparedStatementConfig() {
            @Override
            public void config(PreparedStatement preparedStatement) throws SQLException {
                preparedStatement.setString(1, bt);

src/main/resources/database.sql

@@ -439,3 +439,7 @@ INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('main_lo
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('main_log_handlers.collection-eleRef-0','article_log_handler');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('com_ekexiu_project_platform_views_service_Main.handlers-ref','main_log_handlers');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('tns_list::collection','java.util.ArrayList');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('tns_list.collection-ele-0','article');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('com_ekexiu_project_platform_views_service_Main.tns-ref','tns_list');