统计数据

src/main/java/com/ekexiu/project/platform/article/Article.java

@@ -170,7 +170,6 @@ public class Article implements ManagedBaseTable {
    }
    @Column(descp = "关键词", value = DE.Text_de)
    public String getKeyWords() {
        return keyWords;
    }

src/main/java/com/ekexiu/project/platform/views/dao/DayDao.java

@@ -1,15 +1,22 @@
package com.ekexiu.project.platform.views.dao;
import com.ekexiu.project.platform.views.pojo.ArticleSum;
import com.ekexiu.project.platform.views.pojo.CompanySum;
import com.ekexiu.project.platform.views.pojo.DayData;
import com.ekexiu.project.platform.views.pojo.OrgSum;
import com.ekexiu.project.platform.views.pojo.ProductSum;
import com.ekexiu.project.platform.views.pojo.ProfessorSum;
import org.jfw.apt.annotation.Nullable;
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.operator.PageQuery;
import org.jfw.apt.orm.annotation.dao.method.operator.QueryList;
import org.jfw.apt.orm.annotation.dao.param.Alias;
import org.jfw.apt.orm.annotation.dao.param.GroupSqlColumn;
import org.jfw.apt.orm.annotation.dao.param.GtEq;
import org.jfw.apt.orm.annotation.dao.param.Like;
import org.jfw.apt.orm.annotation.dao.param.LtEq;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.util.PageQueryResult;
import java.sql.Connection;
@@ -164,5 +171,26 @@ public abstract class DayDao {
	@OrderBy("ORDER BY ads.sum DESC")
	public abstract PageQueryResult<ArticleSum> queryByViews(Connection con, @Nullable String catalog, @Nullable @Like String title, @Nullable @Like String source, @Nullable String creator, @Nullable Boolean published, @Nullable @GtEq @Alias("modifyTime") String bt, @Nullable @Alias("modifyTime") @LtEq String et, int pageSize, int pageNo)throws SQLException;
	@PageQuery
	@OrderBy("ORDER BY c.CREATE_TIME DESC")
	public abstract PageQueryResult<CompanySum> queryByTime(Connection con, @Nullable @Like String name, @Nullable @GroupSqlColumn(handlerClass = StringHandler.class,value = " ID IN (SELECT ID FROM COMP_KEY WHERE VALUE LIKE ? AND TYPE = 1)",isAnd = false) String industry, @Nullable Boolean actived, @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")
	public abstract PageQueryResult<CompanySum> queryByViews(Connection con, @Nullable @Like String name, @Nullable @GroupSqlColumn(handlerClass = StringHandler.class,value = " ID IN (SELECT ID FROM COMP_KEY WHERE VALUE LIKE ? AND TYPE = 1)",isAnd = false) String industry, @Nullable Boolean actived, @Nullable @GtEq @Alias("createTime") String bt, @Nullable @Alias("createTime") @LtEq String et, int pageSize, int pageNo)throws SQLException;
	@PageQuery
	@OrderBy("ORDER BY c.CREATE_TIME DESC")
	public abstract PageQueryResult<ProductSum> queryByTime(Connection con, @Nullable @Like String name, @Nullable String companyId, @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")
	public abstract PageQueryResult<ProductSum> queryByViews(Connection con, @Nullable @Like String name, @Nullable String companyId, @Nullable @GtEq @Alias("createTime") String bt, @Nullable @Alias("createTime") @LtEq String et, int pageSize, int pageNo)throws SQLException;
	@QueryList
	public abstract List<ProfessorSum> queryProSum(Connection con) throws SQLException;
	@QueryList
	public abstract List<OrgSum> queryOrgSum(Connection con) throws SQLException;
}

src/main/java/com/ekexiu/project/platform/views/pojo/CompanySum.java

@@ -0,0 +1,24 @@
package com.ekexiu.project.platform.views.pojo;
import com.ekexiu.project.platform.company.Company;
import org.jfw.apt.orm.annotation.entry.CalcColumn;
import org.jfw.apt.orm.annotation.entry.ExtendView;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
/**
 * Created by TT on 2019/3/13.
 */
@ExtendView(fromSentence = "company c INNER JOIN company_day_sum cds on c.id = cds.id",tableAlias = "c")
public class CompanySum extends Company {
    private int sum;
    @CalcColumn(handlerClass = IntHandler.class, column = "cds.sum")
    public int getSum() {
        return sum;
    }
    public void setSum(int sum) {
        this.sum = sum;
    }
}

src/main/java/com/ekexiu/project/platform/views/pojo/OrgSum.java

@@ -0,0 +1,23 @@
package com.ekexiu.project.platform.views.pojo;
import com.ekexiu.project.platform.organization.Organization;
import org.jfw.apt.orm.annotation.entry.CalcColumn;
import org.jfw.apt.orm.annotation.entry.ExtendView;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
/**
 * Created by TT on 2019/3/13.
 */
@ExtendView(fromSentence = "organization c INNER JOIN organization_day_sum cds on c.id = cds.id",tableAlias = "c")
public class OrgSum extends Organization {
    private int sum;
    @CalcColumn(handlerClass = IntHandler.class, column = "cds.sum")
    public int getSum() {
        return sum;
    }
    public void setSum(int sum) {
        this.sum = sum;
    }
}

src/main/java/com/ekexiu/project/platform/views/pojo/ProductSum.java

@@ -0,0 +1,23 @@
package com.ekexiu.project.platform.views.pojo;
import com.ekexiu.project.platform.product.Product;
import org.jfw.apt.orm.annotation.entry.CalcColumn;
import org.jfw.apt.orm.annotation.entry.ExtendView;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
/**
 * Created by TT on 2019/3/13.
 */
@ExtendView(fromSentence = "product c INNER JOIN product_day_sum cds on c.id = cds.id",tableAlias = "c")
public class ProductSum extends Product {
    private int sum;
    @CalcColumn(handlerClass = IntHandler.class, column = "cds.sum")
    public int getSum() {
        return sum;
    }
    public void setSum(int sum) {
        this.sum = sum;
    }
}

src/main/java/com/ekexiu/project/platform/views/pojo/ProfessorSum.java

@@ -0,0 +1,23 @@
package com.ekexiu.project.platform.views.pojo;
import com.ekexiu.project.platform.professor.Professor;
import org.jfw.apt.orm.annotation.entry.CalcColumn;
import org.jfw.apt.orm.annotation.entry.ExtendView;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
/**
 * Created by TT on 2019/3/13.
 */
@ExtendView(fromSentence = "professor c INNER JOIN professor_day_sum cds on c.id = cds.id",tableAlias = "c")
public class ProfessorSum extends Professor {
    private int sum;
    @CalcColumn(handlerClass = IntHandler.class, column = "cds.sum")
    public int getSum() {
        return sum;
    }
    public void setSum(int sum) {
        this.sum = sum;
    }
}

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

@@ -3,7 +3,11 @@ package com.ekexiu.project.platform.views.service;
import com.ekexiu.project.platform.views.dao.DayDao;
import com.ekexiu.project.platform.views.handler.LogHandler;
import com.ekexiu.project.platform.views.pojo.ArticleSum;
import com.ekexiu.project.platform.views.pojo.CompanySum;
import com.ekexiu.project.platform.views.pojo.DayData;
import com.ekexiu.project.platform.views.pojo.OrgSum;
import com.ekexiu.project.platform.views.pojo.ProductSum;
import com.ekexiu.project.platform.views.pojo.ProfessorSum;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
@@ -121,6 +125,40 @@ public class Main {
        return null;
    }
    @Get
    @Path("/company/pq")
    public PageQueryResult<CompanySum> query(@JdbcConn Connection con, @Nullable String name, @Nullable String industry, @Nullable Boolean actived, @Nullable String bt, @Nullable String et, String orderBy, int pageSize, int pageNo) throws SQLException {
        if (orderBy.equals("1")) {
            return dayDao.queryByTime(con, name == null ? null : "%" + name + "%", industry == null ? null : "%" + industry + "%", actived, bt, et, pageSize, pageNo);
        } else if (orderBy.equals("2")) {
            return dayDao.queryByViews(con, name == null ? null : "%" + name + "%", industry == null ? null : "%" + industry + "%", actived, bt, et, pageSize, pageNo);
        }
        return null;
    }
    @Get
    @Path("/product/pq")
    public PageQueryResult<ProductSum> query(@JdbcConn Connection con, @Nullable String title, @Nullable String companyId, @Nullable String bt, @Nullable String et, String orderBy, int pageSize, int pageNo) throws SQLException {
        if (orderBy.equals("1")) {
            return dayDao.queryByTime(con, title == null ? null : "%" + title + "%", companyId, bt, et, pageSize, pageNo);
        } else if (orderBy.equals("2")) {
            return dayDao.queryByViews(con, title == null ? null : "%" + title + "%", companyId, bt, et, pageSize, pageNo);
        }
        return null;
    }
    @Get
    @Path("/professor/pq")
    public List<ProfessorSum> queryProSum(@JdbcConn Connection con) throws SQLException {
        return dayDao.queryProSum(con);
    }
    @Get
    @Path("/org/pq")
    public List<OrgSum> queryOrgSum(@JdbcConn Connection con) throws SQLException {
        return dayDao.queryOrgSum(con);
    }
    @Get
    @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 {

src/main/resources/database.sql

@@ -446,3 +446,105 @@ INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('com_eke
ALTER TABLE public.article ADD key_words text NULL;
COMMENT ON COLUMN public.article.key_words IS '关键词';
CREATE TABLE COMPANY_DAY
(
        ID TEXT    NOT NULL,
        PV INTEGER NOT NULL,
        DAY TEXT    NOT NULL,
        SOURCE TEXT    NOT NULL
);
CREATE TABLE COMPANY_DAY_SUM(
        ID TEXT NOT NULL,
        SUM INTEGER NOT NULL
);
ALTER TABLE COMPANY_DAY_SUM ADD PRIMARY KEY (ID);
CREATE TABLE PRODUCT_DAY
(
        ID TEXT    NOT NULL,
        PV INTEGER NOT NULL,
        DAY TEXT    NOT NULL,
        SOURCE TEXT    NOT NULL
);
CREATE TABLE PRODUCT_DAY_SUM(
        ID TEXT NOT NULL,
        SUM INTEGER NOT NULL
);
ALTER TABLE PRODUCT_DAY_SUM ADD PRIMARY KEY (ID);
CREATE TABLE PROFESSOR_DAY
(
        ID TEXT    NOT NULL,
        PV INTEGER NOT NULL,
        DAY TEXT    NOT NULL,
        SOURCE TEXT    NOT NULL
);
CREATE TABLE PROFESSOR_DAY_SUM(
        ID TEXT NOT NULL,
        SUM INTEGER NOT NULL
);
ALTER TABLE PROFESSOR_DAY_SUM ADD PRIMARY KEY (ID);
CREATE TABLE ORGANIZATION_DAY
(
        ID TEXT    NOT NULL,
        PV INTEGER NOT NULL,
        DAY TEXT    NOT NULL,
        SOURCE TEXT    NOT NULL
);
CREATE TABLE ORGANIZATION_DAY_SUM(
        ID TEXT NOT NULL,
        SUM INTEGER NOT NULL
);
ALTER TABLE ORGANIZATION_DAY_SUM ADD PRIMARY KEY (ID);
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('company_log_handler','com.ekexiu.project.platform.views.handler.db.TimeLogHandler');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('company_log_handler.initialDelay::long','5000');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('company_log_handler.period::long','5000');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('company_log_handler.logType','2');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('company_log_handler.logTypeAlias','company');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('company_log_handler.tableName','COMPANY_DAY');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('company_log_handler.dataSource-ref','dataSource');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('main_log_handlers.collection-eleRef-1','company_log_handler');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('product_log_handler','com.ekexiu.project.platform.views.handler.db.TimeLogHandler');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('product_log_handler.initialDelay::long','5000');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('product_log_handler.period::long','5000');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('product_log_handler.logType','3');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('product_log_handler.logTypeAlias','product');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('product_log_handler.tableName','PRODUCT_DAY');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('product_log_handler.dataSource-ref','dataSource');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('main_log_handlers.collection-eleRef-2','product_log_handler');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('professor_log_handler','com.ekexiu.project.platform.views.handler.db.TimeLogHandler');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('professor_log_handler.initialDelay::long','5000');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('professor_log_handler.period::long','5000');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('professor_log_handler.logType','4');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('professor_log_handler.logTypeAlias','professor');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('professor_log_handler.tableName','PROFESSOR_DAY');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('professor_log_handler.dataSource-ref','dataSource');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('main_log_handlers.collection-eleRef-3','professor_log_handler');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('organization_log_handler','com.ekexiu.project.platform.views.handler.db.TimeLogHandler');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('organization_log_handler.initialDelay::long','5000');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('organization_log_handler.period::long','5000');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('organization_log_handler.logType','5');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('organization_log_handler.logTypeAlias','organization');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('organization_log_handler.tableName','ORGANIZATION_DAY');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('organization_log_handler.dataSource-ref','dataSource');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('main_log_handlers.collection-eleRef-4','organization_log_handler');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('tns_list.collection-ele-1','company');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('tns_list.collection-ele-2','product');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('tns_list.collection-ele-3','professor');
INSERT INTO "public"."console_config" ("cfg_name", "cfg_value") VALUES ('tns_list.collection-ele-4','organization');