pictable

src/main/java/com/ekexiu/console/system/dao/UserDao.java

import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
@DAO
public interface UserDao {
			@Nullable String email, @Nullable @GtEq @Alias("createTime") String bt, @Nullable @Alias("createTime") @LtEq String et, int pageNo, int pageSize)
			throws SQLException;
	@SelectList
	List<User> queryall(Connection con) throws SQLException;
	@DeleteWith
	@From(User.class)
	int delete(Connection con, String id) throws SQLException;

src/main/java/com/ekexiu/console/system/service/UserService.java

import org.jfw.util.StringUtil;
import org.jfw.util.auth.AuthUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.jdbc.JdbcTask;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.web.fileupload.UploadItemIterator;
import javax.sql.DataSource;
import java.io.IOException;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.*;
import java.util.concurrent.atomic.AtomicReference;
@Path("/sys/user")
public class UserService extends Upload {
	public static final String DEFAULT_AUTH_STR = AuthUtil.serialAuth(new int[] { 0 });
	private AtomicReference<Map<String, User>> cache = new AtomicReference<Map<String, User>>();
	public static final String DEFAULT_AUTH_STR = AuthUtil.serialAuth(new int[]{0});
	public static final String DEFAULT_PW_STR = StringUtil.md5("12345678");
	@Autowrie
	}
	public static void main(String[] args) throws Exception {
		System.out.println(AuthUtil.serialAuth(new int[] { 0 }));
		System.out.println(AuthUtil.serialAuth(new int[]{0}));
	}
	@Get
	@Path("/pq")
	public PageQueryResult<User> pageQuery(@JdbcConn Connection con, @Nullable String name, @Nullable Boolean actived, @Nullable String mobile,
			@Nullable String email, @Nullable String bt, @Nullable String et, @DefaultValue("1") int pageNo, @DefaultValue("10") int pageSize)
										   @Nullable String email, @Nullable String bt, @Nullable String et, @DefaultValue("1") int pageNo, @DefaultValue("10") int pageSize)
			throws SQLException {
		if (bt != null)
			bt = bt + "000000";
	@Post
	@Path
	public void insert(@JdbcConn(true) Connection con,
			@RequestParam(fields = { @FieldParam(value = "name", valueClass = String.class, required = true),
					@FieldParam(value = "email", valueClass = String.class, required = true),
					@FieldParam(value = "mobile", valueClass = String.class, required = false),
					@FieldParam(value = "descp", valueClass = String.class, required = false),
					@FieldParam(value = "head", valueClass = String.class, required = false) }) User user)
					   @RequestParam(fields = {@FieldParam(value = "name", valueClass = String.class, required = true),
							   @FieldParam(value = "email", valueClass = String.class, required = true),
							   @FieldParam(value = "mobile", valueClass = String.class, required = false),
							   @FieldParam(value = "descp", valueClass = String.class, required = false),
							   @FieldParam(value = "head", valueClass = String.class, required = false)}) User user)
			throws SQLException {
		String id = StringUtil.buildUUID();
		user.setId(id);
		this.userDao.insert(con, user);
	}
	@Get
	@Path("/all")
	public Collection<User> queryall(@JdbcConn Connection con) throws SQLException {
		return this.cache.get().values();
	}
	public void initByDataSource(DataSource ds) throws SQLException {
		final Connection con = ds.getConnection();
		JdbcUtil.executeAutoClose(con, new JdbcTask() {
			@Override
			public void exec() throws SQLException {
				List<User> list = userDao.queryall(con);
				Map<String, User> map = new HashMap<String, User>();
				for (User res : list) {
					map.put(res.getId(), res);
				}
				cache.set(map);
			}
		}, false);
	}
	@Put
	@Path
	public void update(@JdbcConn(true) Connection con, @RequestBody User user) throws SQLException {
		}
		return null;
	}
	@Post
	@Path("/right")
	public void updateRights(@JdbcConn(true) Connection con, String userid,int[] right)throws SQLException{
	public void updateRights(@JdbcConn(true) Connection con, String userid, int[] right) throws SQLException {
		this.userDao.update(con, userid, AuthUtil.serialAuth(AuthUtil.compress(right)));
	}
	@Post
	@Path("/del")
	public void delete(@JdbcConn(true)Connection con,String[] ids)throws SQLException {
	public void delete(@JdbcConn(true) Connection con, String[] ids) throws SQLException {
		this.userDao.delete(con, ids);
	}
	@Get
	@Path("/id/{id}")
	public User query(@JdbcConn Connection con, @PathVar String id)throws SQLException {
	public User query(@JdbcConn Connection con, @PathVar String id) throws SQLException {
		return this.userDao.queryById(con, id);
	}

src/main/java/com/ekexiu/console/util/GlobalInitBean.java

package com.ekexiu.console.util;
import java.util.LinkedList;
import java.util.List;
import java.util.ListIterator;
import java.util.concurrent.ScheduledExecutorService;
import javax.sql.DataSource;
import com.ekexiu.console.system.service.*;
import org.jfw.util.bean.AfterBeanFactory;
import org.jfw.util.bean.BeanFactory;
import org.jfw.util.context.JfwAppContext;
import com.ekexiu.console.system.service.DictService;
import com.ekexiu.console.system.service.RightService;
import com.ekexiu.console.system.service.RoleService;
import com.ekexiu.console.system.service.SysResourceService;
import javax.sql.DataSource;
import java.util.LinkedList;
import java.util.List;
import java.util.ListIterator;
import java.util.concurrent.ScheduledExecutorService;
public class GlobalInitBean implements AfterBeanFactory {
	private DataSource dataSource;
				getBean(SysResourceService.class).initByDataSource(dataSource);
			}
		});
		list.add(new Initable() {
			@Override
			public void init(GlobalInitBean gib) throws Exception {
				getBean(UserService.class).initByDataSource(dataSource);
			}
		});
		return list;
	}
	public <T> T getBean(Class<T> cls){