统计数据

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

@@ -1,17 +1,17 @@
package com.ekexiu.project.job;
import java.sql.Connection;
import java.util.concurrent.ScheduledExecutorService;
import javax.sql.DataSource;
import com.ekexiu.project.platform.system.service.DictService;
import com.ekexiu.project.platform.views.handler.LogHandler;
import com.ekexiu.project.platform.views.service.Main;
import org.jfw.util.bean.AfterBeanFactory;
import org.jfw.util.bean.BeanFactory;
import org.jfw.util.context.JfwAppContext;
import org.jfw.util.jdbc.JdbcUtil;
import com.ekexiu.project.platform.system.service.DictService;
import javax.sql.DataSource;
import java.sql.Connection;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class TaskJob implements AfterBeanFactory {
@@ -31,6 +31,12 @@ public class TaskJob implements AfterBeanFactory {
		}finally{
			JdbcUtil.close(con);
		}
		Main main = (Main) bf.getBean("com_ekexiu_project_platform_views_service_Main");
		for (LogHandler lh : main.getHandlers()) {
			service.scheduleAtFixedRate(lh, lh.getInitialDelay(), lh.getPeriod(), TimeUnit.MILLISECONDS);
			JfwAppContext.addDestoryed(lh);
		}
	}

src/main/java/com/ekexiu/project/platform/system/service/SysService.java

@@ -1,5 +1,6 @@
package com.ekexiu.project.platform.system.service;
import com.ekexiu.project.platform.company.CompanyService;
import com.ekexiu.project.platform.system.dao.UserDao;
import com.ekexiu.project.platform.system.po.InvalidUser;
import com.ekexiu.project.platform.system.po.Manager;
@@ -9,6 +10,7 @@ import com.ekexiu.project.platform.system.vo.ManagerInfo;
import com.ekexiu.project.platform.system.vo.SessionManager;
import com.ekexiu.project.platform.system.vo.SessionUser;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.LoginUser;
import org.jfw.apt.web.annotation.Path;
@@ -168,14 +170,42 @@ public class SysService {
    @Path("/qo")
    public SessionManager managerQueryOne(@JdbcConn Connection con, String id) throws SQLException {
        ManagerInfo managerInfo = userDao.managerQuery(con, id);
        if(managerInfo==null){
            return null;
        }
        List<String> rightList = userDao.right(con, managerInfo.getId());
        managerInfo.setRightCode(rightList.toArray(new String[0]));
        return makeSessionManager(managerInfo);
    }
    @LoginUser
    @Path("/name")
    @Get
    public List<CompanyService.TypeaheadItem> queryName(@JdbcConn Connection con, @DefaultValue("\"%\"") String name, int size) throws SQLException {
        if (!name.equals("%")) {
            name = "%" + name + "%";
        }
        List<CompanyService.TypeaheadItem> ret = new ArrayList<>(size);
        final String finalKey = name;
        List<Map<String, Object>> typehead = JdbcUtil.queryMaps(con, "SELECT NAME,ID FROM manager m LEFT JOIN sys_right s on m.id = s.uid where s.right_code = '1' and m.name like ? ", new PreparedStatementConfig() {
            @Override
            public void config(PreparedStatement preparedStatement) throws SQLException {
                preparedStatement.setString(1, finalKey);
            }
        });
        for (Map<String, Object> map : typehead) {
            CompanyService.TypeaheadItem item = new CompanyService.TypeaheadItem();
            item.setId((String) map.get("id"));
            item.setName((String) map.get("name"));
            ret.add(item);
        }
        return ret;
    }
    @Path("/new")
    @Post
    public String addUser(@JdbcConn(true) Connection con, @LoginUser SessionManager au, @RequestParam(excludeFields = {"id", "acitved", "createor"}) Manager user, String[] rightCode) throws SQLException {
    public String addUser(@JdbcConn(true) Connection con, @LoginUser SessionManager au, @RequestParam(excludeFields = {"id", "actived", "creator"}) Manager user, String[] rightCode) throws SQLException {
        String id = StringUtil.buildUUID();
        user.setActived(true);
        user.setCreator(au.getId());

src/main/java/com/ekexiu/project/platform/views/LogImageServlet.java

@@ -0,0 +1,48 @@
package com.ekexiu.project.platform.views;
import com.ekexiu.project.platform.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_project_platform_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/project/platform/views/dao/DayDao.java

@@ -0,0 +1,168 @@
package com.ekexiu.project.platform.views.dao;
import com.ekexiu.project.platform.views.pojo.ArticleSum;
import com.ekexiu.project.platform.views.pojo.DayData;
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.param.Alias;
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.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 a.CREATE_TIME DESC")
	public abstract PageQueryResult<ArticleSum> queryByTime(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 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;
}

src/main/java/com/ekexiu/project/platform/views/handler/LogHandler.java

@@ -0,0 +1,47 @@
package com.ekexiu.project.platform.views.handler;
import com.ekexiu.project.platform.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/project/platform/views/handler/db/DbLogHandler.java

@@ -0,0 +1,55 @@
package com.ekexiu.project.platform.views.handler.db;
import com.ekexiu.project.platform.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/project/platform/views/handler/db/TimeLogHandler.java

@@ -0,0 +1,147 @@
package com.ekexiu.project.platform.views.handler.db;
import com.ekexiu.project.platform.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 =?";
        this.insertSql = "INSERT INTO " + this.tableName + " (PV,ID,DAY,SOURCE) VALUES (?,?,?,?)";
        this.updateSumSql = "UPDATE " + this.tableName + "_SUM SET SUM=SUM+? WHERE ID = ?";
        this.insertSumSql = "INSERT INTO " + this.tableName + "_SUM (ID,SUM) 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");
            if (id != null && id.length() > 0 && source != null && source.length() == 1) {
                ++num;
                day = day + source + 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) 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);
            int p = ps.executeUpdate();
            ps = this.con.prepareStatement(this.updateSumSql);
            ps.setInt(1, pv);
            ps.setString(2, id);
            return p==1&&ps.executeUpdate() == 1;
        } finally {
            try {
                ps.close();
            } catch (Exception e) {
            }
        }
    }
    public void insert(String id, String day, String source, int pv) 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.executeUpdate();
            ps = this.con.prepareStatement(this.insertSumSql);
            ps.setString(1, id);
            ps.setInt(2, 1);
            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 id = day.substring(9);
            day = day.substring(0, 8);
            if (!this.update(id, day, source, pv)) {
                this.insert(id, day, source, pv);
            }
        }
    }
    @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/project/platform/views/handler/db/UpperTimeLogHandler.java

@@ -0,0 +1,62 @@
package com.ekexiu.project.platform.views.handler.db;
import com.ekexiu.project.platform.views.pojo.LogEntry;
public class UpperTimeLogHandler  extends TimeLogHandler{
	private static final int LowerToUpper = 'a'-'A';
	
	@Override
	public boolean pre() throws Exception {
		LogEntry le;
		long num =0;
		StringBuilder sb = new StringBuilder();
		while ((le = this.queue.poll()) != null) {
			sb.delete(0,sb.length());
			sb.append(le.getTimeString());
			String id = le.getString("id");
			String source = le.getString("src");
			if (id != null && id.length() > 0 &&  source!=null && source.length()==1) {
				++num;
				sb.append(source);
				char[] cs = id.toCharArray();
				for(int i = 0 ;i < cs.length;++i){
					char c = cs[i];
					if(c>='a' && c<='z'){
						c-=LowerToUpper;
					}else if(c=='一'){
						c='1';
					}else if(c=='二'){
						c='2';
					}else if(c=='三'){
						c='3';
					}else if(c=='四'){
						c='4';
					}else if(c=='五'){
						c='5';
					}else if(c=='六'){
						c='6';
					}else if(c=='七'){
						c='7';
					}else if(c=='八'){
						c='8';
					}else if(c=='九'){
						c='9';
					}else if(c=='零'){
						c='0';
					}
					sb.append(c);
				}
				String day = sb.toString();
				Integer pv = cache.get(day);
				if (pv == null) {
					pv = 1;
				} else {
					pv = pv + 1;
				}
				cache.put(day, pv);
			}
		}
		return num>0;
	}
}

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

@@ -0,0 +1,23 @@
package com.ekexiu.project.platform.views.pojo;
import com.ekexiu.project.platform.article.Article;
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/1.
 */
@ExtendView(fromSentence = "article a INNER JOIN article_day_sum ads on a.id = ads.id",tableAlias = "a")
public class ArticleSum extends Article {
    private int sum;
    @CalcColumn(handlerClass = IntHandler.class, column = "ads.sum")
    public int getSum() {
        return sum;
    }
    public void setSum(int sum) {
        this.sum = sum;
    }
}

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

@@ -0,0 +1,32 @@
package com.ekexiu.project.platform.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/project/platform/views/pojo/LogEntry.java

@@ -0,0 +1,36 @@
package com.ekexiu.project.platform.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/project/platform/views/service/Main.java

@@ -0,0 +1,101 @@
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.DayData;
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.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<LogHandler> handlers;
    @Autowrie
    private DayDao dayDao;
    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.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 {
        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 {
        return dayDao.query(con, tn, id, bt, et);
    }
    @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 {
        return dayDao.query(con, tn, bt, et, src, rows);
    }
    @Get
    @Path("/article/pq")
    public PageQueryResult<ArticleSum> query(@JdbcConn Connection con, @Nullable String catalog, @Nullable String title, @Nullable String source, @Nullable String creator, @Nullable Boolean published, @Nullable String bt, @Nullable String et, String orderBy, int pageSize, int pageNo) throws SQLException {
        if (orderBy.equals("createTime")) {
            return dayDao.queryByTime(con, catalog, title == null ? null : "%" + title + "%", source == null ? null : "%" + source + "%", creator, published, bt, et, pageSize, pageNo);
        } else if (orderBy.equals("views")) {
            return dayDao.queryByViews(con, catalog, title == null ? null : "%" + title + "%", source == null ? null : "%" + source + "%", creator, published, bt, et, pageSize, pageNo);
        }
        return null;
    }
    @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() {
            @Override
            public void config(PreparedStatement preparedStatement) throws SQLException {
                preparedStatement.setString(1, bt);
            }
        });
    }
}

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

@@ -48,11 +48,19 @@
		</init-param>
		<load-on-startup>1</load-on-startup>
	</servlet>
	<servlet>
		<servlet-name>img</servlet-name>
		<servlet-class>com.ekexiu.project.platform.views.LogImageServlet</servlet-class>
		<load-on-startup>3</load-on-startup>
	</servlet>
	<servlet-mapping>
		<servlet-name>ajax</servlet-name>
		<url-pattern>/ajax/*</url-pattern>
	</servlet-mapping>
	<servlet-mapping>
		<servlet-name>img</servlet-name>
		<url-pattern>/img</url-pattern>
	</servlet-mapping>
	
	<session-config>
		<cookie-config>