服务专利资源的平台浏览量统计

src/main/java/com/ekexiu/portal/views/dao/DayDao.java

@DAO
public abstract class DayDao {
    public List<DayData> query(Connection con, String tablePrefix, String[] srcs, String[] ids, String bt, String et, String sortStr) throws SQLException {
    public List<DayData> query(Connection con, String tablePrefix,String platform, String[] srcs, String[] ids, String bt, String et, String sortStr) throws SQLException {
        StringBuilder sb = new StringBuilder();
        boolean hasSource = srcs != null && srcs.length > 0;
        boolean hasid = ids != null && ids.length > 0;
        sb.append("SELECT ID,DAY,SOURCE,PV FROM ").append(tablePrefix).append("_DAY WHERE DAY>=? AND DAY<=?");
        sb.append("SELECT ID,DAY,SOURCE,PV FROM ").append(tablePrefix).append("_DAY WHERE PLATFORM = ? AND DAY>=? AND DAY<=?");
        if (hasSource) {
            sb.append(" AND SOURCE IN(");
            for (int i = 0; i < srcs.length; ++i) {
        int idx = 1;
        java.sql.PreparedStatement ps = con.prepareStatement(sb.toString());
        try {
            ps.setString(idx++,platform);
            ps.setString(idx++, bt);
            ps.setString(idx++, et);
            if (hasSource) {
        }
    }
    public List<DayData> query(Connection con, String tablePrefix, String id, String bt, String et) throws SQLException {
    public List<DayData> query(Connection con, String tablePrefix,String platform, String id, String bt, String et) throws SQLException {
        StringBuilder sb = new StringBuilder();
        sb.append("SELECT ID,DAY,SOURCE,PV FROM ").append(tablePrefix).append("_DAY WHERE DAY>=? AND DAY<=? AND ID=? ORDER BY DAY");
        sb.append("SELECT ID,DAY,SOURCE,PV FROM ").append(tablePrefix).append("_DAY WHERE PLATFORM = ? AND DAY>=? AND DAY<=? AND ID=? ORDER BY DAY");
        java.sql.PreparedStatement ps = con.prepareStatement(sb.toString());
        try {
            ps.setString(1, bt);
            ps.setString(2, et);
            ps.setString(3, id);
            ps.setString(1,platform);
            ps.setString(2, bt);
            ps.setString(3, et);
            ps.setString(4, id);
            List<DayData> ret = new LinkedList<DayData>();
            java.sql.ResultSet rs = ps.executeQuery();
            try {
        }
    }
    public List<DayData> query(Connection con, String tablePrefix, String bt, String et, @Nullable String[] srcs, int rows) throws SQLException {
    public List<DayData> query(Connection con, String tablePrefix,String platform, String bt, String et, @Nullable String[] srcs, int rows) throws SQLException {
        boolean hasSource = srcs != null && srcs.length > 0;
        StringBuilder sb = new StringBuilder();
        sb.append("SELECT ID,SUM(PV) PV FROM ").append(tablePrefix).append("_DAY WHERE DAY>=? AND DAY<=?");
        sb.append("SELECT ID,SUM(PV) PV FROM ").append(tablePrefix).append("_DAY WHERE PLATFORM = ? AND DAY>=? AND DAY<=?");
        if (hasSource) {
            sb.append(" AND SOURCE IN (");
            for (int i = 0; i < srcs.length; ++i) {
        java.sql.PreparedStatement ps = con.prepareStatement(sb.toString());
        try {
            int idx = 1;
            ps.setString(idx++,platform);
            ps.setString(idx++, bt);
            ps.setString(idx++, et);
            if (hasSource) {
    @PageQuery
    @OrderBy("ORDER BY c.MODIFY_TIME DESC NULLS LAST")
    @Exclude("descp")
    public abstract PageQueryResult<WareSum> queryWareTime(Connection con, @Nullable @Like String name, @Nullable @GroupSqlColumn(handlerClass = StringHandler.class, value = {
    public abstract PageQueryResult<WareSum> queryWareTime(Connection con, String platform, @Nullable @Like String name, @Nullable @GroupSqlColumn(handlerClass = StringHandler.class, value = {
            "CATEGORY='1' AND OWNER IN(SELECT ID FROM PROFESSOR WHERE NAME LIKE ?)",
            "CATEGORY ='2' AND OWNER IN(SELECT ID FROM ORGANIZATION WHERE NAME LIKE ? OR FOR_SHORT LIKE ?)"},
            additional = 1, isAnd = false, force = true) String author, @Nullable @GtEq @Alias("modifyTime") String bt, @Nullable @Alias("modifyTime") @LtEq String et, int pageSize, int pageNo) throws SQLException;
    @PageQuery
    @OrderBy("ORDER BY cds.SUM DESC")
    @Exclude("descp")
    public abstract PageQueryResult<WareSum> queryWareViews(Connection con, @Nullable @Like String name, @Nullable @GroupSqlColumn(handlerClass = StringHandler.class, value = {
    public abstract PageQueryResult<WareSum> queryWareViews(Connection con, String platform, @Nullable @Like String name, @Nullable @GroupSqlColumn(handlerClass = StringHandler.class, value = {
            "CATEGORY='1' AND OWNER IN(SELECT ID FROM PROFESSOR WHERE NAME LIKE ?)",
            "CATEGORY ='2' AND OWNER IN(SELECT ID FROM ORGANIZATION WHERE NAME LIKE ? OR FOR_SHORT LIKE ?)"},
            additional = 1, isAnd = false, force = true) String author, @Nullable @GtEq @Alias("modifyTime") String bt, @Nullable @Alias("modifyTime") @LtEq String et, int pageSize, int pageNo) throws SQLException;
    @Exclude("summary")
    @PageQuery
    @OrderBy("ORDER BY c.CREATE_TIME DESC NULLS LAST")
    public abstract PageQueryResult<PpatentSum> queryPpatentTime(Connection con, @Nullable @Like String name,@Nullable @Like String authors,@Nullable @GtEq @Alias("createTime") String bt, @Nullable @Alias("createTime") @LtEq String et, int pageSize, int pageNo) throws SQLException;
    public abstract PageQueryResult<PpatentSum> queryPpatentTime(Connection con, String platform, @Nullable @Like String name,@Nullable @Like String authors,@Nullable @GtEq @Alias("createTime") String bt, @Nullable @Alias("createTime") @LtEq String et, int pageSize, int pageNo) throws SQLException;
    @Exclude("summary")
    @PageQuery
    @OrderBy("ORDER BY cds.SUM DESC NULLS LAST")
    public abstract PageQueryResult<PpatentSum> queryPpatentViews(Connection con, @Nullable @Like String name,@Nullable @Like String authors,@Nullable @GtEq @Alias("createTime") String bt, @Nullable @Alias("createTime") @LtEq String et, int pageSize, int pageNo) throws SQLException;
    public abstract PageQueryResult<PpatentSum> queryPpatentViews(Connection con, String platform, @Nullable @Like String name,@Nullable @Like String authors,@Nullable @GtEq @Alias("createTime") String bt, @Nullable @Alias("createTime") @LtEq String et, int pageSize, int pageNo) throws SQLException;
    @PageQuery
    @OrderBy(" ORDER BY c.publish_time DESC NULLS LAST")
    @Exclude("descp")
    public abstract PageQueryResult<ResourceSum> queryResourceTime(Connection con, @Nullable @Like String resourceName,@Nullable @GroupSqlColumn(handlerClass = StringHandler.class, value = {
    public abstract PageQueryResult<ResourceSum> queryResourceTime(Connection con, String platform, @Nullable @Like String resourceName,@Nullable @GroupSqlColumn(handlerClass = StringHandler.class, value = {
            "RESOURCE_TYPE='1' AND PROFESSOR_ID IN(SELECT ID FROM PROFESSOR WHERE NAME LIKE ?)",
            "RESOURCE_TYPE ='2' AND ORGANIZATION_ID IN(SELECT ID FROM ORGANIZATION WHERE NAME LIKE ? OR FOR_SHORT LIKE ?)"},
            additional = 1, isAnd = false, force = true) String author, @Nullable @GtEq @Alias("publishTime") String bt, @Nullable @Alias("publishTime") @LtEq String et, int pageSize, int pageNo) throws SQLException;
    @PageQuery
    @OrderBy(" ORDER BY cds.sum DESC")
    @Exclude("descp")
    public abstract PageQueryResult<ResourceSum> queryResourceViews(Connection con, @Nullable @Like String resourceName,@Nullable @GroupSqlColumn(handlerClass = StringHandler.class, value = {
    public abstract PageQueryResult<ResourceSum> queryResourceViews(Connection con, String platform, @Nullable @Like String resourceName,@Nullable @GroupSqlColumn(handlerClass = StringHandler.class, value = {
            "RESOURCE_TYPE='1' AND PROFESSOR_ID IN(SELECT ID FROM PROFESSOR WHERE NAME LIKE ?)",
            "RESOURCE_TYPE ='2' AND ORGANIZATION_ID IN(SELECT ID FROM ORGANIZATION WHERE NAME LIKE ? OR FOR_SHORT LIKE ?)"},
            additional = 1, isAnd = false, force = true) String author, @Nullable @GtEq @Alias("publishTime") String bt, @Nullable @Alias("publishTime") @LtEq String et, int pageSize, int pageNo) throws SQLException;

src/main/java/com/ekexiu/portal/views/pojo/PpatentSum.java

import org.jfw.apt.orm.annotation.entry.CalcColumn;
import org.jfw.apt.orm.annotation.entry.ExtendView;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
/**
 * Created by TT on 2019/3/14.
@ExtendView(fromSentence = "ppatent c INNER JOIN ppatent_day_sum cds on c.id = cds.id", tableAlias = "c")
public class PpatentSum extends Ppatent {
    private int sum;
    private String platform;
    @CalcColumn(handlerClass = StringHandler.class, column = "cds.platform")
    public String getPlatform() {
        return platform;
    }
    public void setPlatform(String platform) {
        this.platform = platform;
    }
    @CalcColumn(handlerClass = IntHandler.class, column = "cds.sum")
    public int getSum() {

src/main/java/com/ekexiu/portal/views/pojo/ResourceSum.java

import org.jfw.apt.orm.annotation.entry.CalcColumn;
import org.jfw.apt.orm.annotation.entry.ExtendView;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
/**
 * Created by TT on 2019/3/14.
public class ResourceSum extends Resource {
    private int sum;
    private String platform;
    @CalcColumn(handlerClass = StringHandler.class, column = "cds.platform")
    public String getPlatform() {
        return platform;
    }
    public void setPlatform(String platform) {
        this.platform = platform;
    }
    @CalcColumn(handlerClass = IntHandler.class, column = "cds.sum")
    public int getSum() {
        return sum;

src/main/java/com/ekexiu/portal/views/pojo/WareSum.java

import org.jfw.apt.orm.annotation.entry.CalcColumn;
import org.jfw.apt.orm.annotation.entry.ExtendView;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
/**
 * Created by TT on 2019/3/14.
@ExtendView(fromSentence = "ware c INNER JOIN ware_day_sum cds on c.id = cds.id", tableAlias = "c")
public class WareSum extends Ware {
    private int sum;
    private String platform;
    @CalcColumn(handlerClass = StringHandler.class, column = "cds.platform")
    public String getPlatform() {
        return platform;
    }
    public void setPlatform(String platform) {
        this.platform = platform;
    }
    @CalcColumn(handlerClass = IntHandler.class, column = "cds.sum")
    public int getSum() {

src/main/java/com/ekexiu/portal/views/service/Main.java

    @Get
    @Path("/qm")
    public List<DayData> query(@JdbcConn Connection con, String tn, @Nullable String[] src, @Nullable String[] id, @DefaultValue("com.ekexiu.portal.views.service.Main.MIN_DAY") String bt,
    public List<DayData> query(@JdbcConn Connection con, String tn,String platform, @Nullable String[] src, @Nullable String[] id, @DefaultValue("com.ekexiu.portal.views.service.Main.MIN_DAY") String bt,
                               @DefaultValue("com.ekexiu.portal.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);
        return dayDao.query(con, tn,platform, src, id, bt, et, sort);
    }
    @Get
    @Path("/qo")
    public List<DayData> query(@JdbcConn Connection con, String tn, String id, @DefaultValue("com.ekexiu.portal.views.service.Main.MIN_DAY") String bt,
    public List<DayData> query(@JdbcConn Connection con, String tn,String platform, String id, @DefaultValue("com.ekexiu.portal.views.service.Main.MIN_DAY") String bt,
                               @DefaultValue("com.ekexiu.portal.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);
        return dayDao.query(con, tn,platform, id, bt, et);
    }
    @Get
    @Path("/qo/sum")
    public int query(@JdbcConn Connection con, String tn, final String id) throws SQLException,JfwBaseException {
    public int query(@JdbcConn Connection con, String tn, final String platform, 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() {
        return JdbcUtil.queryInt(con, "SELECT SUM FROM " + tn + "_DAY_SUM WHERE PLATFORM = ? AND ID = ?", new PreparedStatementConfig() {
            @Override
            public void config(PreparedStatement preparedStatement) throws SQLException {
                preparedStatement.setString(1, id);
                preparedStatement.setString(1,platform);
                preparedStatement.setString(2, id);
            }
        }, 0);
    }
    @Get
    @Path("/qs")
    public List<DayData> query(@JdbcConn Connection con, String tn, @Nullable String[] src, @DefaultValue("com.ekexiu.portal.views.service.Main.MIN_DAY") String bt,
    public List<DayData> query(@JdbcConn Connection con, String tn,String platform, @Nullable String[] src, @DefaultValue("com.ekexiu.portal.views.service.Main.MIN_DAY") String bt,
                               @DefaultValue("com.ekexiu.portal.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);
        return dayDao.query(con, tn,platform, bt, et, src, rows);
    }
    @Get
    @Path("/total")
    public List<Map<String, Object>> total(@JdbcConn Connection con,String tn, @DefaultValue("com.ekexiu.portal.views.service.Main.MIN_DAY") final String bt) throws SQLException, JfwBaseException {
    public List<Map<String, Object>> total(@JdbcConn Connection con, String tn, final String platform, @DefaultValue("com.ekexiu.portal.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() {
        return JdbcUtil.queryMaps(con, "SELECT day,sum(pv)as pv,source FROM "+tn+"_day WHERE PLATFORM = ? AND day>=? GROUP BY day,source ORDER BY day DESC ", new PreparedStatementConfig() {
            @Override
            public void config(PreparedStatement preparedStatement) throws SQLException {
                preparedStatement.setString(1, bt);
                preparedStatement.setString(1,platform);
                preparedStatement.setString(2, bt);
            }
        });
    }
    @Get
    @Path("/ware/pq")
    public PageQueryResult<WareSum> queryWare(@JdbcConn Connection con, @Nullable String name,@Nullable String author, @Nullable String bt, @Nullable String et, String orderBy, int pageSize, int pageNo) throws SQLException {
    public PageQueryResult<WareSum> queryWare(@JdbcConn Connection con, String platform, @Nullable String name,@Nullable String author, @Nullable String bt, @Nullable String et, String orderBy, int pageSize, int pageNo) throws SQLException {
        if (orderBy.equals("1")) {
            return dayDao.queryWareTime(con, name == null ? null : "%" + name + "%", author == null ? null : "%" + author + "%", bt, et, pageSize, pageNo);
            return dayDao.queryWareTime(con, platform, name == null ? null : "%" + name + "%", author == null ? null : "%" + author + "%", bt, et, pageSize, pageNo);
        } else if (orderBy.equals("2")) {
            return dayDao.queryWareViews(con, name == null ? null : "%" + name + "%", author == null ? null : "%" + author + "%",  bt, et, pageSize, pageNo);
            return dayDao.queryWareViews(con, platform, name == null ? null : "%" + name + "%", author == null ? null : "%" + author + "%",  bt, et, pageSize, pageNo);
        }
        return null;
    }
    @Get
    @Path("/ppatent/pq")
    public PageQueryResult<PpatentSum> queryPpatent(@JdbcConn Connection con, @Nullable String name, @Nullable String author, @Nullable String bt, @Nullable String et, String orderBy, int pageSize, int pageNo) throws SQLException {
    public PageQueryResult<PpatentSum> queryPpatent(@JdbcConn Connection con, String platform, @Nullable String name, @Nullable String author, @Nullable String bt, @Nullable String et, String orderBy, int pageSize, int pageNo) throws SQLException {
        if (orderBy.equals("1")) {
            return dayDao.queryPpatentTime(con, name == null ? null : "%" + name + "%", author == null ? null : "%" + author + "%", bt, et, pageSize, pageNo);
            return dayDao.queryPpatentTime(con, platform, name == null ? null : "%" + name + "%", author == null ? null : "%" + author + "%", bt, et, pageSize, pageNo);
        } else if (orderBy.equals("2")) {
            return dayDao.queryPpatentViews(con, name == null ? null : "%" + name + "%", author == null ? null : "%" + author + "%",  bt, et, pageSize, pageNo);
            return dayDao.queryPpatentViews(con, platform, name == null ? null : "%" + name + "%", author == null ? null : "%" + author + "%",  bt, et, pageSize, pageNo);
        }
        return null;
    }
    @Get
    @Path("/resource/pq")
    public PageQueryResult<ResourceSum> queryResource(@JdbcConn Connection con, @Nullable String name, @Nullable String author, @Nullable String bt, @Nullable String et, String orderBy, int pageSize, int pageNo) throws SQLException {
    public PageQueryResult<ResourceSum> queryResource(@JdbcConn Connection con, String platform, @Nullable String name, @Nullable String author, @Nullable String bt, @Nullable String et, String orderBy, int pageSize, int pageNo) throws SQLException {
        if (orderBy.equals("1")) {
            return dayDao.queryResourceTime(con, name == null ? null : "%" + name + "%", author == null ? null : "%" + author + "%", bt, et, pageSize, pageNo);
            return dayDao.queryResourceTime(con, platform, name == null ? null : "%" + name + "%", author == null ? null : "%" + author + "%", bt, et, pageSize, pageNo);
        } else if (orderBy.equals("2")) {
            return dayDao.queryResourceViews(con, name == null ? null : "%" + name + "%", author == null ? null : "%" + author + "%",  bt, et, pageSize, pageNo);
            return dayDao.queryResourceViews(con, platform, name == null ? null : "%" + name + "%", author == null ? null : "%" + author + "%",  bt, et, pageSize, pageNo);
        }
        return null;
    }