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

src/main/java/com/ekexiu/portal/job/TaskJob.java

package com.ekexiu.portal.job;
import com.ekexiu.portal.cms.TemplateService;
import com.ekexiu.portal.service.WeixinService;
import com.ekexiu.portal.views.handler.LogHandler;
import com.ekexiu.portal.views.service.Main;
import com.ekexiu.push.service.PushService;
import org.jfw.apt.annotation.Bean;
import org.jfw.util.bean.AfterBeanFactory;
import org.jfw.util.bean.BeanFactory;
import org.jfw.util.context.JfwAppContext;
import javax.sql.DataSource;
import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import javax.sql.DataSource;
import org.jfw.apt.annotation.Bean;
import org.jfw.util.bean.AfterBeanFactory;
import org.jfw.util.bean.BeanFactory;
import org.jfw.util.context.JfwAppContext;
import com.ekexiu.portal.cms.TemplateService;
import com.ekexiu.portal.service.WeixinService;
import com.ekexiu.push.service.PushService;
@Bean
public class TaskJob implements AfterBeanFactory {
	private ScheduledExecutorService service;
			}
		}, 0, templateService.getRate(), TimeUnit.MILLISECONDS);
		Main main = (Main) bf.getBean("com_ekexiu_portal_views_service_Main");
		for (LogHandler lh : main.getHandlers()) {
			service.scheduleAtFixedRate(lh, lh.getInitialDelay(), lh.getPeriod(), TimeUnit.MILLISECONDS);
			JfwAppContext.addDestoryed(lh);
		}
	}
	private static long getTimeMillis(String time) {

src/main/java/com/ekexiu/portal/views/LogImageServlet.java

package com.ekexiu.portal.views;
import com.ekexiu.portal.views.service.Main;
import org.jfw.util.context.JfwAppContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.OutputStream;
public class LogImageServlet extends HttpServlet {
	private static final long serialVersionUID = 1L;
	private static byte[] png = new byte[] { -119, 80, 78, 71, 13, 10, 26, 10, 0, 0, 0, 13, 73, 72, 68, 82, 0, 0, 0, 1, 0, 0, 0, 1, 8, 2, 0, 0, 0, -112, 119,
			83, -34, 0, 0, 0, 1, 115, 82, 71, 66, 0, -82, -50, 28, -23, 0, 0, 0, 4, 103, 65, 77, 65, 0, 0, -79, -113, 11, -4, 97, 5, 0, 0, 0, 9, 112, 72, 89,
			115, 0, 0, 14, -61, 0, 0, 14, -61, 1, -57, 111, -88, 100, 0, 0, 0, 12, 73, 68, 65, 84, 24, 87, 99, -8, -1, -1, 63, 0, 5, -2, 2, -2, -89, 53, -127,
			-124, 0, 0, 0, 0, 73, 69, 78, 68, -82, 66, 96, -126 };
	private static int png_size = png.length;
	private Main main;
	@Override
	public void init() throws ServletException {
		main = (Main) JfwAppContext.getBeanFactory().getBean("com_ekexiu_portal_views_service_Main");
	}
	protected void doGet(HttpServletRequest request, HttpServletResponse res) throws ServletException, IOException {
		main.log(request.getParameterMap());
		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");
		res.setContentType("image/png");
		res.setContentLength(png_size);
		OutputStream out = res.getOutputStream();
		try {
			out.write(png);
		} finally {
			try {
				out.close();
			} catch (Exception e) {
			}
		}
	}
}

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

package com.ekexiu.portal.views.dao;
import com.ekexiu.portal.views.pojo.DayData;
import com.ekexiu.portal.views.pojo.PpatentSum;
import com.ekexiu.portal.views.pojo.ResourceSum;
import com.ekexiu.portal.views.pojo.WareSum;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.Exclude;
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.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;
import java.sql.SQLException;
import java.util.LinkedList;
import java.util.List;
@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 {
        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<=?");
        if (hasSource) {
            sb.append(" AND SOURCE IN(");
            for (int i = 0; i < srcs.length; ++i) {
                sb.append("?,");
            }
            sb.setCharAt(sb.length() - 1, ')');
        }
        if (hasid) {
            sb.append(" AND ID IN(");
            for (int i = 0; i < ids.length; ++i) {
                sb.append("?,");
            }
            sb.setCharAt(sb.length() - 1, ')');
        }
        if (sortStr != null && sortStr.trim().length() > 0) {
            sb.append(" ORDER BY ").append(sortStr);
        }
        int idx = 1;
        java.sql.PreparedStatement ps = con.prepareStatement(sb.toString());
        try {
            ps.setString(idx++, bt);
            ps.setString(idx++, et);
            if (hasSource) {
                for (int i = 0; i < srcs.length; ++i) {
                    ps.setString(idx++, srcs[i]);
                }
            }
            if (hasid) {
                for (int i = 0; i < ids.length; ++i) {
                    ps.setString(idx++, ids[i]);
                }
            }
            List<DayData> ret = new LinkedList<DayData>();
            java.sql.ResultSet rs = ps.executeQuery();
            try {
                while (rs.next()) {
                    DayData dd = new DayData();
                    dd.setId(rs.getString(1));
                    dd.setDay(rs.getString(2));
                    dd.setSource(rs.getString(3));
                    dd.setPv(rs.getInt(4));
                    ret.add(dd);
                }
                return ret;
            } finally {
                try {
                    rs.close();
                } catch (Exception _m_2) {
                }
            }
        } finally {
            try {
                ps.close();
            } catch (Exception _m_3) {
            }
        }
    }
    public List<DayData> query(Connection con, String tablePrefix, 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");
        java.sql.PreparedStatement ps = con.prepareStatement(sb.toString());
        try {
            ps.setString(1, bt);
            ps.setString(2, et);
            ps.setString(3, id);
            List<DayData> ret = new LinkedList<DayData>();
            java.sql.ResultSet rs = ps.executeQuery();
            try {
                while (rs.next()) {
                    DayData dd = new DayData();
                    dd.setId(rs.getString(1));
                    dd.setDay(rs.getString(2));
                    dd.setSource(rs.getString(3));
                    dd.setPv(rs.getInt(4));
                    ret.add(dd);
                }
                return ret;
            } finally {
                try {
                    rs.close();
                } catch (Exception _m_2) {
                }
            }
        } finally {
            try {
                ps.close();
            } catch (Exception _m_3) {
            }
        }
    }
    public List<DayData> query(Connection con, String tablePrefix, 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<=?");
        if (hasSource) {
            sb.append(" AND SOURCE IN (");
            for (int i = 0; i < srcs.length; ++i) {
                sb.append("?,");
            }
            sb.setCharAt(sb.length() - 1, ')');
        }
        sb.append(" GROUP BY ID ORDER BY PV DESC LIMIT ?");
        java.sql.PreparedStatement ps = con.prepareStatement(sb.toString());
        try {
            int idx = 1;
            ps.setString(idx++, bt);
            ps.setString(idx++, et);
            if (hasSource) {
                for (String src : srcs)
                    ps.setString(idx++, src);
            }
            ps.setInt(idx++, rows);
            List<DayData> ret = new LinkedList<DayData>();
            java.sql.ResultSet rs = ps.executeQuery();
            try {
                while (rs.next()) {
                    DayData dd = new DayData();
                    dd.setId(rs.getString(1));
                    dd.setPv(rs.getInt(2));
                    ret.add(dd);
                }
                return ret;
            } finally {
                try {
                    rs.close();
                } catch (Exception _m_2) {
                }
            }
        } finally {
            try {
                ps.close();
            } catch (Exception _m_3) {
            }
        }
    }
    @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 = {
            "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 = {
            "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;
    @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;
    @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 = {
            "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 = {
            "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/handler/LogHandler.java

package com.ekexiu.portal.views.handler;
import com.ekexiu.portal.views.pojo.LogEntry;
import java.util.Map;
import java.util.concurrent.ConcurrentLinkedQueue;
public abstract class LogHandler  implements Runnable{
	private long initialDelay;
	private long period;
	
	
	
	
	public long getInitialDelay() {
		return initialDelay;
	}
	public void setInitialDelay(long initialDelay) {
		this.initialDelay = initialDelay;
	}
	public long getPeriod() {
		return period;
	}
	public void setPeriod(long period) {
		this.period = period;
	}
	protected ConcurrentLinkedQueue<LogEntry> queue = new ConcurrentLinkedQueue<LogEntry>();
	
	public void add(Map<String,String[]> map){
		if(this.match(map.get("__lt"))){
			queue.offer(LogEntry.build(map));
		}
	}
	
	public abstract boolean match(String[] logType);
	
	
}

src/main/java/com/ekexiu/portal/views/handler/db/DbLogHandler.java

package com.ekexiu.portal.views.handler.db;
import com.ekexiu.portal.views.handler.LogHandler;
import org.jfw.util.log.LogFactory;
import org.jfw.util.log.Logger;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
public abstract class DbLogHandler extends LogHandler {
	private static final Logger log = LogFactory.getLog(DbLogHandler.class);
	private DataSource dataSource;
	protected Connection con;
	public DataSource getDataSource() {
		return dataSource;
	}
	public void setDataSource(DataSource dataSource) {
		this.dataSource = dataSource;
	}
	public abstract boolean pre() throws Exception;;
	public abstract void stroe() throws SQLException;
	public abstract void afterCommit();
	@Override
	synchronized public void run() {
		try {
			if(!this.pre())return;
			this.con = this.dataSource.getConnection();
			try {
				this.stroe();
				con.commit();
				this.afterCommit();
			}catch(Exception e){
				try {
					con.rollback();
				} catch (Exception ee) {
				}
				throw e;
			}
			finally {
				try {
					con.close();
				} catch (Exception e) {
				}
			}
		} catch (Exception e) {
			log.error("hand runnable.run error",e);
		}
	}
}

src/main/java/com/ekexiu/portal/views/handler/db/TimeLogHandler.java

package com.ekexiu.portal.views.handler.db;
import com.ekexiu.portal.views.pojo.LogEntry;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
public class TimeLogHandler extends DbLogHandler {
    private String logType;
    private String logTypeAlias;
    private String tableName;
    private String updateSql;
    private String insertSql;
    private String updateSumSql;
    private String insertSumSql;
    protected Map<String, Integer> cache = new HashMap<String, Integer>();
    public String getTableName() {
        return tableName;
    }
    public void setTableName(String tableName) {
        this.tableName = tableName;
        this.updateSql = "UPDATE " + this.tableName + " SET PV= PV+? WHERE ID=? AND DAY =? AND SOURCE =? AND PLATFORM = ?";
        this.insertSql = "INSERT INTO " + this.tableName + " (PV,ID,DAY,SOURCE,PLATFORM) VALUES (?,?,?,?,?)";
        this.updateSumSql = "UPDATE " + this.tableName + "_SUM SET SUM=SUM+? WHERE ID = ? AND PLATFORM = ?";
        this.insertSumSql = "INSERT INTO " + this.tableName + "_SUM (ID,SUM,PLATFORM) VALUES (?,?,?)";
    }
    public String getLogType() {
        return logType;
    }
    public void setLogType(String logType) {
        this.logType = logType;
    }
    public String getLogTypeAlias() {
        return logTypeAlias;
    }
    public void setLogTypeAlias(String logTypeAlias) {
        this.logTypeAlias = logTypeAlias;
    }
    @Override
    public boolean pre() throws Exception {
        LogEntry le;
        long num = 0;
        while ((le = this.queue.poll()) != null) {
            String day = le.getTimeString();
            String id = le.getString("id");
            String source = le.getString("src");
            String platform = le.getString("platform");
            if (id != null && id.length() > 0 && source != null && source.length() == 1 && platform != null && platform.length() > 0) {
                ++num;
                day = day + source + platform + id;
                Integer pv = cache.get(day);
                if (pv == null) {
                    pv = 1;
                } else {
                    pv = pv + 1;
                }
                cache.put(day, pv);
            }
        }
        return num > 0;
    }
    private boolean update(String id, String day, String source, int pv,String platform) throws SQLException {
        PreparedStatement ps = this.con.prepareStatement(this.updateSql);
        try {
            ps.setInt(1, pv);
            ps.setString(2, id);
            ps.setString(3, day);
            ps.setString(4, source);
            ps.setString(5,platform);
            return ps.executeUpdate() == 1;
        } finally {
            try {
                ps.close();
            } catch (Exception e) {
            }
        }
    }
    private boolean updateSum(String id, int pv,String platform) throws SQLException {
        PreparedStatement ps = this.con.prepareStatement(this.updateSumSql);
        try {
            ps.setInt(1, pv);
            ps.setString(2, id);
            ps.setString(3, platform);
            return ps.executeUpdate() == 1;
        } finally {
            try {
                ps.close();
            } catch (Exception e) {
            }
        }
    }
    public void insert(String id, String day, String source, int pv,String platform) throws SQLException {
        PreparedStatement ps = this.con.prepareStatement(this.insertSql);
        try {
            ps.setInt(1, pv);
            ps.setString(2, id);
            ps.setString(3, day);
            ps.setString(4, source);
            ps.setString(5, platform);
            ps.executeUpdate();
        } finally {
            try {
                ps.close();
            } catch (Exception e) {
            }
        }
    }
    public void insertSum(String id,int pv,String platform) throws SQLException {
        PreparedStatement ps = this.con.prepareStatement(this.insertSumSql);
        try {
            ps.setString(1, id);
            ps.setInt(2, pv);
            ps.setString(3, platform);
            ps.executeUpdate();
        } finally {
            try {
                ps.close();
            } catch (Exception e) {
            }
        }
    }
    @Override
    public void stroe() throws SQLException {
        for (Map.Entry<String, Integer> entry : cache.entrySet()) {
            String day = entry.getKey();
            int pv = entry.getValue().intValue();
            String source = day.substring(8, 9);
            String platform = day.substring(9, 41);
            String id = day.substring(41);
            day = day.substring(0, 8);
            if (!this.updateSum(id, pv,platform)) {
                this.insertSum(id,pv, platform);
            }
            if (!this.update(id, day, source, pv,platform)) {
                this.insert(id, day, source, pv,platform);
            }
        }
    }
    @Override
    public void afterCommit() {
        this.cache.clear();
    }
    @Override
    public boolean match(String[] lt) {
        return lt != null && lt.length == 1 && (this.logType.equals(lt[0]) || this.logTypeAlias.equals(lt[0]));
    }
    @Override
    public String toString() {
        return this.getClass().getName() + "[tableName:" + this.tableName + ",logType:" + this.logType + ",logTypeAlias:" + this.logTypeAlias + "]";
    }
}

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

package com.ekexiu.portal.views.pojo;
public class DayData {
	private String id;
	private String day;
	private String source;
	private int pv;
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	public String getDay() {
		return day;
	}
	public void setDay(String day) {
		this.day = day;
	}
	public String getSource() {
		return source;
	}
	public void setSource(String source) {
		this.source = source;
	}
	public int getPv() {
		return pv;
	}
	public void setPv(int pv) {
		this.pv = pv;
	}
}

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

package com.ekexiu.portal.views.pojo;
import org.jfw.util.DateUtil;
import java.util.HashMap;
import java.util.Map;
public class LogEntry {
	private long time;
	private Map<String,String[]> data = new HashMap<String,String[]>();
	
	public String getString(String key){
		String[] sa = data.get(key);
		return sa==null || sa.length==0 ?null:sa[0];
	}
	public String[] getStringArray(String key){
		return data.get(key);
	}
	public long getTime(){
		return time;
	}
	public String getTimeString(){
		return DateUtil.formatDate(this.time);
	}
	public static LogEntry build(Map<String,String[]> data){
		LogEntry le = new LogEntry();
		le.time = System.currentTimeMillis();		
		le.data.putAll(data);
		return le;
	}
	
	
	
}

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

package com.ekexiu.portal.views.pojo;
import com.ekexiu.portal.po.Ppatent;
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/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;
    @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/portal/views/pojo/ResourceSum.java

package com.ekexiu.portal.views.pojo;
import com.ekexiu.portal.po.Resource;
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/14.
 */
@ExtendView(fromSentence = "resource c INNER JOIN resource_day_sum cds on c.resource_id = cds.id", tableAlias = "c")
public class ResourceSum extends Resource {
    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/portal/views/pojo/WareSum.java

package com.ekexiu.portal.views.pojo;
import com.ekexiu.portal.ware.Ware;
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/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;
    @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/portal/views/service/Main.java

package com.ekexiu.portal.views.service;
import com.ekexiu.portal.views.dao.DayDao;
import com.ekexiu.portal.views.handler.LogHandler;
import com.ekexiu.portal.views.pojo.DayData;
import com.ekexiu.portal.views.pojo.PpatentSum;
import com.ekexiu.portal.views.pojo.ResourceSum;
import com.ekexiu.portal.views.pojo.WareSum;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.Path;
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;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;
@Path("/log")
public class Main {
    public static final String MAX_DAY = "99999999";
    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;
    }
    public void setHandlers(List<LogHandler> handlers) {
        this.handlers = handlers;
    }
    public DayDao getDayDao() {
        return dayDao;
    }
    public void setDayDao(DayDao dayDao) {
        this.dayDao = dayDao;
    }
    @Get
    @Path()
    public void log(@ParameterMap Map<String, String[]> pm) {
        for (LogHandler lh : this.handlers) {
            lh.add(pm);
        }
    }
    @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,
                               @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);
    }
    @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,
                               @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);
    }
    @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.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);
    }
    @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 {
        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);
            }
        });
    }
    @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 {
        if (orderBy.equals("1")) {
            return dayDao.queryWareTime(con, 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 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 {
        if (orderBy.equals("1")) {
            return dayDao.queryPpatentTime(con, 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 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 {
        if (orderBy.equals("1")) {
            return dayDao.queryResourceTime(con, 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 null;
    }
}

src/main/resources/database.sql

ALTER TABLE public.article ADD owner_id CHAR(32) NULL;
UPDATE public.article set owner_id = professor_id WHERE article_type = '1'
UPDATE public.article set owner_id = professor_id WHERE article_type = '1';
UPDATE public.article SET owner_id = org_id WHERE article_type = '2'
UPDATE public.article SET owner_id = org_id WHERE article_type = '2';
ALTER TABLE public.article DROP professor_id;
ALTER TABLE public.article DROP org_id
ALTER TABLE public.article DROP org_id;
--modify begin at 2.50
        OP_TIME TEXT NOT NULL,
        UNREAD INTEGER NOT NULL,
        ACTIVED CHAR(1) NOT NULL);
ALTER TABLE PLATFORM_MSG_IDX ADD PRIMARY KEY (PID,REQUESTOR,PROVIDER);
ALTER TABLE PLATFORM_MSG_IDX ADD PRIMARY KEY (PID,REQUESTOR,PROVIDER);
--modify begin at viewlog
CREATE TABLE WARE_DAY
(
	ID TEXT    NOT NULL,
	PV INTEGER NOT NULL,
	DAY TEXT    NOT NULL,
	SOURCE TEXT    NOT NULL,
	PLATFORM TEXT NOT NULL
);
CREATE TABLE WARE_DAY_SUM(
	ID TEXT NOT NULL,
	PLATFORM TEXT NOT NULL,
	SUM INTEGER NOT NULL
);
ALTER TABLE WARE_DAY_SUM ADD PRIMARY KEY (ID,PLATFORM);
CREATE TABLE PPATENT_DAY
(
	ID TEXT    NOT NULL,
	PV INTEGER NOT NULL,
	DAY TEXT    NOT NULL,
	SOURCE TEXT    NOT NULL,
	PLATFORM TEXT NOT NULL
);
CREATE TABLE PPATENT_DAY_SUM(
	ID TEXT NOT NULL,
	PLATFORM TEXT NOT NULL,
	SUM INTEGER NOT NULL
);
ALTER TABLE PPATENT_DAY_SUM ADD PRIMARY KEY (ID,PLATFORM);
CREATE TABLE RESOURCE_DAY
(
	ID TEXT    NOT NULL,
	PV INTEGER NOT NULL,
	DAY TEXT    NOT NULL,
	SOURCE TEXT    NOT NULL,
	PLATFORM TEXT NOT NULL
);
CREATE TABLE RESOURCE_DAY_SUM(
	ID TEXT NOT NULL,
	PLATFORM TEXT NOT NULL,
	SUM INTEGER NOT NULL
);
ALTER TABLE RESOURCE_DAY_SUM ADD PRIMARY KEY (ID,PLATFORM);

src/main/webapp/WEB-INF/web.xml

		<servlet-class>com.ekexiu.portal.util.ProfessorPdfServlet</servlet-class>
		<load-on-startup>7</load-on-startup>
	</servlet>
	<servlet>
		<servlet-name>img</servlet-name>
		<servlet-class>com.ekexiu.portal.views.LogImageServlet</servlet-class>
		<load-on-startup>8</load-on-startup>
	</servlet>
	<servlet-mapping>
		<servlet-name>ajax</servlet-name>
		<url-pattern>/ajax/*</url-pattern>
		<servlet-name>ProfessorPdfServlet</servlet-name>
		<url-pattern>/pdf/professor</url-pattern>
	</servlet-mapping>
	<servlet-mapping>
		<servlet-name>img</servlet-name>
		<url-pattern>/ajax/img</url-pattern>
	</servlet-mapping>
</web-app>