init by jiapeng

pom.xml

@@ -0,0 +1,85 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>com.ekexiu.project</groupId>
	<artifactId>platformConsole</artifactId>
	<version>0.0.1</version>
	<packaging>war</packaging>
	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<maven.compiler.source>1.7</maven.compiler.source>
		<maven.compiler.target>1.7</maven.compiler.target>
		<maven.war.filteringDeploymentDescriptors>true</maven.war.filteringDeploymentDescriptors>
		<maven.tomcat.path>/</maven.tomcat.path>
	</properties>
	<dependencies>
		<dependency>
			<groupId>org.postgresql</groupId>
			<artifactId>postgresql</artifactId>
			<version>9.4.1207.jre7</version>
		</dependency>
		<dependency>
			<groupId>org.jfw</groupId>
			<artifactId>jfwApt</artifactId>
			<version>0.0.2-SNAPSHOT</version>
			<optional>true</optional>
		</dependency>
		<dependency>
			<groupId>org.jfw</groupId>
			<artifactId>jfwAptOrm</artifactId>
			<version>0.0.2-SNAPSHOT</version>
			<optional>true</optional>
		</dependency>
		<dependency>
			<groupId>org.jfw</groupId>
			<artifactId>jfwAptWeb</artifactId>
			<version>0.0.2-SNAPSHOT</version>
			<optional>true</optional>
		</dependency>
		<dependency>
			<groupId>org.jfw</groupId>
			<artifactId>jfwUtil</artifactId>
			<version>0.0.2-SNAPSHOT</version>
		</dependency>
		<dependency>
			<groupId>org.jfw</groupId>
			<artifactId>jfwWebUtil</artifactId>
			<version>0.0.2-SNAPSHOT</version>
		</dependency>
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>servlet-api</artifactId>
			<scope>provided</scope>
			<version>2.5</version>
		</dependency>
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>druid</artifactId>
			<version>1.0.20</version>
		</dependency>
		<dependency>
			<groupId>javax.mail</groupId>
			<artifactId>mail</artifactId>
			<version>1.4</version>
		</dependency>
	</dependencies>
	<build>
		<plugins>
			<plugin>
				<groupId>org.mortbay.jetty</groupId>
				<artifactId>jetty-maven-plugin</artifactId>
				<version>8.1.0.RC5</version>
				<configuration>
					<stopPort>9966</stopPort>
					<stopKey>foo</stopKey>
					<webAppConfig>
						<contextPath>/platformConsole</contextPath>
					</webAppConfig>
                    <reload>automatic</reload>
                    <scanIntervalSeconds>3</scanIntervalSeconds>
				</configuration>
			</plugin>
		</plugins>
		<finalName>platformConsole</finalName>
	</build>
</project>

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

@@ -0,0 +1,37 @@
package com.ekexiu.project.job;
import java.sql.Connection;
import java.util.concurrent.ScheduledExecutorService;
import javax.sql.DataSource;
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;
public class TaskJob implements AfterBeanFactory {
	private ScheduledExecutorService service;
	private DataSource dataSource;
	@Override
	public void handle(BeanFactory bf) throws Throwable {
		this.service = JfwAppContext.getScheduledExecutorService();
		this.dataSource =(DataSource) bf.getBean("dataSource");
		Connection con  = this.dataSource.getConnection();
		try{
		
		DictService ds = (DictService) bf.getBean("com_ekexiu_project_platform_system_service_DictService");
		ds.load(con);
		
		}finally{
			JdbcUtil.close(con);
		}
	}
}

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

@@ -0,0 +1,118 @@
package com.ekexiu.project.platform.article;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.project.platform.base.po.ManagedBaseTable;
@PrimaryKey("id")
@Table
public class Article implements ManagedBaseTable {
	private String id;
	private long shareId;
	private String catalog;
	private String title;
	private String source;
	private String imgUrl;
	private String cnt;
	private boolean published;
	private boolean actived;
	private String createTime;
	private String modifyTime;
	private String creator;
	private String modifier;
	
	@Column(DE.id_32)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	@Column(value=DE.long_de,insertable = false,renewable = false)
	public long getShareId() {
		return shareId;
	}
	public void setShareId(long shareId) {
		this.shareId = shareId;
	}
	@Column(DE.Text_de)
	public String getCatalog() {
		return catalog;
	}
	public void setCatalog(String catalog) {
		this.catalog = catalog;
	}
	@Column(DE.text_de)
	public String getTitle() {
		return title;
	}
	public void setTitle(String title) {
		this.title = title;
	}
	@Column(DE.Text_de)
	public String getSource() {
		return source;
	}
	public void setSource(String source) {
		this.source = source;
	}
	@Column(DE.Text_de)
	public String getImgUrl() {
		return imgUrl;
	}
	public void setImgUrl(String imgUrl) {
		this.imgUrl = imgUrl;
	}
	@Column(DE.Text_de)
	public String getCnt() {
		return cnt;
	}
	public void setCnt(String cnt) {
		this.cnt = cnt;
	}
	@Column(DE.boolean_de)
	public boolean isPublished() {
		return published;
	}
	public void setPublished(boolean published) {
		this.published = published;
	}
	@Column(DE.boolean_de)
	public boolean isActived() {
		return actived;
	}
	public void setActived(boolean actived) {
		this.actived = actived;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	public String getCreator() {
		return creator;
	}
	public void setCreator(String creator) {
		this.creator = creator;
	}
	public String getModifier() {
		return modifier;
	}
	public void setModifier(String modifier) {
		this.modifier = modifier;
	}
	
	
}

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

@@ -0,0 +1,33 @@
package com.ekexiu.project.platform.article;
import java.sql.Connection;
import java.sql.SQLException;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.DeleteWith;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
@DAO
public interface ArticleDao {
	
	@UpdateWith
	@From(Article.class)
	@Where("ACTIVED ='1'")
	@SetSentence("ACTIVED='0'")
	int invalid(Connection con,String id)throws SQLException;
	
	
	@UpdateWith
	@From(Article.class)
	@Where("ACTIVED ='0'")
	@SetSentence("ACTIVED='1'")
	int valid(Connection con,String id)throws SQLException;
	
	@DeleteWith
	@From(InvalidArticle.class)
	int delete(Connection con,String id)throws SQLException;
}

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

@@ -0,0 +1,59 @@
package com.ekexiu.project.platform.article;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.web.annotation.LoginUser;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.util.auth.AuthUser;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.jdbc.PreparedStatementConfig;
@Path("/article")
public class ArticleService {
	@Autowrie
	private ArticleDao articleDao;
	public ArticleDao getArticleDao() {
		return articleDao;
	}
	public void setArticleDao(ArticleDao articleDao) {
		this.articleDao = articleDao;
	}
	@Path("/invalid")
	@Post
	public int invalid(@JdbcConn(true) Connection con, final String id, final @LoginUser AuthUser user) throws SQLException {
		if (articleDao.invalid(con, id) != 0) {
			JdbcUtil.execute(con, "INSERT INVALID_ARTICLE (ID,TITLE,CREATOR,CREATE_TIME,INVALID_TIME,INVALID_OPERATOR) "
					+ "SELECT ID,TITLE,CREATOR,CREATE_TIME,TO_CHAR(NOW(),'YYYYMMDDHH24MISS'),? FROM ARTICLE WHERE ID=?", new PreparedStatementConfig() {
						@Override
						public void config(PreparedStatement ps) throws SQLException {
							ps.setString(1, user.getId());
							ps.setString(2, id);
						}
					});
			return 1;
		}
		return 0;
	}
	
	@LoginUser
	@Path("/valid")
	@Post
	public int valid(@JdbcConn(true) Connection con, final String id) throws SQLException {
		if(articleDao.valid(con, id)!=0){
			articleDao.delete(con, id);
			return 1;
		}
		return 0;
	}
}

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

@@ -0,0 +1,66 @@
package com.ekexiu.project.platform.article;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
@PrimaryKey("id")
@Table
public class InvalidArticle {
	
	private String id;
	private String title;
	private String creator;
	private String createTime;
	private String invalidTime;
	private String invalidOperator;
	
	@Column(DE.text_de)
	public String getId() {
		return id;
	}
	
	public void setId(String id) {
		this.id = id;
	}
	@Column(DE.text_de)
	public String getTitle() {
		return title;
	}
	public void setTitle(String title) {
		this.title = title;
	}
	@Column(DE.text_de)
	public String getCreator() {
		return creator;
	}
	public void setCreator(String creator) {
		this.creator = creator;
	}
	@Column(DE.text_de)
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	@Column(DE.text_de)
	public String getInvalidTime() {
		return invalidTime;
	}
	public void setInvalidTime(String invalidTime) {
		this.invalidTime = invalidTime;
	}
	@Column(DE.text_de)
	public String getInvalidOperator() {
		return invalidOperator;
	}
	public void setInvalidOperator(String invalidOperator) {
		this.invalidOperator = invalidOperator;
	}
	
	
	
}

src/main/java/com/ekexiu/project/platform/base/po/BaseTable.java

@@ -0,0 +1,21 @@
package com.ekexiu.project.platform.base.po;
import org.jfw.apt.annotation.JfwAptConfig;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.VirtualTable;
import org.jfw.apt.orm.core.defaultImpl.FixLenStringHandler;
@JfwAptConfig("DB:PostgreSQL")
@VirtualTable
public interface BaseTable {
	@Column(descp="创建时间（YYYYMMDDHH24MISS）不可修改", handlerClass = FixLenStringHandler.class, dbType = "CHAR(14)", fixSqlValueWithInsert = "TO_CHAR(NOW(),'YYYYMMDDHH24MISS')", insertable = true, nullable = false, queryable = true, renewable = false)
	String getCreateTime();
	void setCreateTime(String createTime);
	@Column(descp="最后修改时间（YYYYMMDDHH24MISS）,初始值:20000101010101", handlerClass = FixLenStringHandler.class, dbType = "CHAR(14)", fixSqlValueWithInsert = "'20000101010101'", fixSqlValueWithUpdate = "TO_CHAR(NOW(),'YYYYMMDDHH24MISS')", insertable = true, nullable = false, queryable = true, renewable = true)
	String getModifyTime();
	void setModifyTime(String modifyTime);
	
}

src/main/java/com/ekexiu/project/platform/base/po/ManagedBaseTable.java

@@ -0,0 +1,14 @@
package com.ekexiu.project.platform.base.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.core.enums.DE;
public interface ManagedBaseTable extends BaseTable {
	@Column(descp="创建人ID",value= DE.id_32)
	String getCreator();
	void setCreator(String creator);
	
	@Column(descp="最后修改人ID",value=DE.refid_32)
	String getModifier();
	void setModifier(String modifier);
}

src/main/java/com/ekexiu/project/platform/mail/MailService.java

@@ -0,0 +1,126 @@
package com.ekexiu.project.platform.mail;
import org.jfw.apt.annotation.Bean;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.AddressException;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import java.io.UnsupportedEncodingException;
import java.util.Map;
import java.util.Properties;
@Bean
public class MailService {
	private Properties sessionProperties = new Properties();;
	private String mailHost;
	private int port;
	private String username;
	private String password;
	private Session session;
	private String from;
	private String nick;
	public void setNick(String nick) {
		if (nick == null)
			return;
		try {
			this.nick = javax.mail.internet.MimeUtility.encodeText(nick);
		} catch (UnsupportedEncodingException e) {
			this.nick = null;
		}
	}
	public String getFrom() {
		return from;
	}
	public void setFrom(String from) {
		this.from = from;
	}
	private Session getSession() {
		if (null == this.session) {
			this.session = Session.getInstance(this.sessionProperties);
		}
		return this.session;
	}
	public int getPort() {
		return port;
	}
	public void setPort(int port) {
		this.port = port;
	}
	public Properties getSessionProperties() {
		return sessionProperties;
	}
	public void setSessionProperties(Map<String, String> map) {
		this.sessionProperties.clear();
		this.sessionProperties.putAll(map);
	}
	public String getMailHost() {
		return mailHost;
	}
	public void setMailHost(String mailHost) {
		this.mailHost = mailHost;
	}
	public String getUsername() {
		return username;
	}
	public void setUsername(String username) {
		this.username = username;
	}
	public String getPassword() {
		return password;
	}
	public void setPassword(String password) {
		this.password = password;
	}
	public void sendSimpleMail(String to, String template, Map<String, String> values, String subject) throws MessagingException {
		Transport ts = this.getSession().getTransport();
		ts.connect(this.mailHost, port, username, password);
		try {
			Message message = this.createSimpleMail(to, subject, template, values);
			ts.sendMessage(message, message.getAllRecipients());
		} finally {
			try {
				ts.close();
			} catch (Exception e) {
			}
		}
	}
	private MimeMessage createSimpleMail(String to, String subject, String template, Map<String, String> values) throws AddressException, MessagingException {
		MimeMessage message = new MimeMessage(session);
		if (null == this.nick) {
			message.setFrom(new InternetAddress(this.from));
		} else {
			message.setFrom(new InternetAddress(this.nick + " <" + this.from + ">"));
		}
		message.setRecipient(Message.RecipientType.TO, new InternetAddress(to));
		message.setSubject(subject);
		String content = template;
		if (null != values && values.size() > 0) {
			for (Map.Entry<String, String> entry : values.entrySet()) {
				content = content.replaceAll(entry.getKey(), entry.getValue());
			}
		}
		message.setContent(content, "text/html;charset=UTF-8");
		return message;
	}
}

src/main/java/com/ekexiu/project/platform/mobile/MobilePhoneResult.java

@@ -0,0 +1,36 @@
package com.ekexiu.project.platform.mobile;
import java.util.List;
public class MobilePhoneResult {
	public static final String SUCCESS="00000";	
	
	private String respCode;
	private String failCount;
	private List<MobilePhoneResultEntry> failList;
	private String smsId;
	public String getRespCode() {
		return respCode;
	}
	public void setRespCode(String respCode) {
		this.respCode = respCode;
	}
	public String getFailCount() {
		return failCount;
	}
	public void setFailCount(String failCount) {
		this.failCount = failCount;
	}
	public List<MobilePhoneResultEntry> getFailList() {
		return failList;
	}
	public void setFailList(List<MobilePhoneResultEntry> failList) {
		this.failList = failList;
	}
	public String getSmsId() {
		return smsId;
	}
	public void setSmsId(String smsId) {
		this.smsId = smsId;
	}
}

src/main/java/com/ekexiu/project/platform/mobile/MobilePhoneResultEntry.java

@@ -0,0 +1,20 @@
package com.ekexiu.project.platform.mobile;
public class MobilePhoneResultEntry {
	private String phone;
	private String respCode;
	public String getPhone() {
		return phone;
	}
	public void setPhone(String phone) {
		this.phone = phone;
	}
	public String getRespCode() {
		return respCode;
	}
	public void setRespCode(String respCode) {
		this.respCode = respCode;
	}
	
}

src/main/java/com/ekexiu/project/platform/mobile/MobilePhoneService.java

@@ -0,0 +1,312 @@
package com.ekexiu.project.platform.mobile;
import org.jfw.apt.annotation.Bean;
import org.jfw.util.ConstData;
import org.jfw.util.DateUtil;
import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.io.IoUtil;
import org.jfw.util.json.JsonService;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Locale;
import java.util.Map;
@Bean
public class MobilePhoneService {
	private static final Map<String, String> errorReason = new HashMap<String, String>();
	private String accountSid = "6f5c2612d691480a9bbbee0c64e10872";
	private String authToken = "4fac48f2d37d4ba89cc037e7d012348e";
	private String restUrl = "https://api.miaodiyun.com/20150822/industrySMS/sendSMS";
	private String marketUrl = "https://api.miaodiyun.com/20150822/affMarkSMS/sendSMS";
	private int sendTimeout = 10 * 1000;
	private int readTimeout = 10 * 1000;
	public int getSendTimeout() {
		return sendTimeout;
	}
	public void setSendTimeout(int sendTimeout) {
		this.sendTimeout = sendTimeout;
	}
	public int getReadTimeout() {
		return readTimeout;
	}
	public void setReadTimeout(int readTimeout) {
		this.readTimeout = readTimeout;
	}
	public String getRestUrl() {
		return restUrl;
	}
	public void setRestUrl(String restUrl) {
		this.restUrl = restUrl;
	}
	public String getMarketUrl() {
		return marketUrl;
	}
	public void setMarketUrl(String marketUrl) {
		this.marketUrl = marketUrl;
	}
	public String getAccountSid() {
		return accountSid;
	}
	public void setAccountSid(String accountSid) {
		this.accountSid = accountSid;
	}
	public String getAuthToken() {
		return authToken;
	}
	public void setAuthToken(String authToken) {
		this.authToken = authToken;
	}
	private byte[] send(String content) throws IOException {
		URL url = new URL(this.restUrl);
		HttpURLConnection conn = (HttpURLConnection) url.openConnection();
		conn.setRequestMethod("POST");// 提交模式
		conn.setRequestProperty("Content-type", "application/x-www-form-urlencoded");
		conn.setConnectTimeout(this.sendTimeout);// 连接超时 单位毫秒
		conn.setReadTimeout(this.readTimeout);// 读取超时 单位毫秒
		conn.setDoOutput(true);// 是否输入参数
		byte[] bypes = content.getBytes(ConstData.UTF8);
		OutputStream out = conn.getOutputStream();
		try {
			out.write(bypes);
			out.flush();
		} finally {
			out.close();
		}
		InputStream inStream = conn.getInputStream();
		return IoUtil.readStream(inStream, true);
	}
	
	private byte[] sendMarket(String content) throws IOException {
		URL url = new URL(this.marketUrl);
		HttpURLConnection conn = (HttpURLConnection) url.openConnection();
		conn.setRequestMethod("POST");// 提交模式
		conn.setRequestProperty("Content-type", "application/x-www-form-urlencoded");
		conn.setConnectTimeout(this.sendTimeout);// 连接超时 单位毫秒
		conn.setReadTimeout(this.readTimeout);// 读取超时 单位毫秒
		conn.setDoOutput(true);// 是否输入参数
		byte[] bypes = content.getBytes(ConstData.UTF8);
		OutputStream out = conn.getOutputStream();
		try {
			out.write(bypes);
			out.flush();
		} finally {
			out.close();
		}
		InputStream inStream = conn.getInputStream();
		return IoUtil.readStream(inStream, true);
	}
	private MobilePhoneResult parse(byte[] bytes) {
		return JsonService.fromJson(new InputStreamReader(new ByteArrayInputStream(bytes), ConstData.UTF8), MobilePhoneResult.class);
	}
	public void sendMessage(String to, String contentTemplate, String replateKey, String value) throws Exception {
		String content = contentTemplate.replaceAll(replateKey, value);
		String dateStr = DateUtil.formatDateTime(System.currentTimeMillis());
		StringBuilder sb = new StringBuilder();
		sb.append("accountSid=").append(this.accountSid).append("&smsContent=").append(URLEncoder.encode(content, "UTF-8")).append("&to=").append(to)
				.append("&timestamp=").append(dateStr).append("&sig=");
		String md5 = StringUtil.md5(this.accountSid + this.authToken + dateStr).toLowerCase(Locale.US);
		sb.append(md5);
		MobilePhoneResult mpr = this.parse(this.send(sb.toString()));
		if (!MobilePhoneResult.SUCCESS.equals(mpr.getRespCode())) {
			String reason = errorReason.get(mpr.getRespCode());
			if(reason==null) reason="未知错误，请联系技术客服。";
			throw new Exception(mpr.getRespCode()+"-"+reason);
		}
	}
	
	public void sendMarketMessage(String to, String contentTemplate) throws Exception {
		String dateStr = DateUtil.formatDateTime(System.currentTimeMillis());
		StringBuilder sb = new StringBuilder();
		sb.append("accountSid=").append(this.accountSid).append("&smsContent=").append(URLEncoder.encode(contentTemplate, "UTF-8")).append("&to=").append(to)
				.append("&timestamp=").append(dateStr).append("&sig=");
		String md5 = StringUtil.md5(this.accountSid + this.authToken + dateStr).toLowerCase(Locale.US);
		sb.append(md5);
		MobilePhoneResult mpr = this.parse(this.sendMarket(sb.toString()));
		if (!MobilePhoneResult.SUCCESS.equals(mpr.getRespCode())) {
			String reason = errorReason.get(mpr.getRespCode());
			if(reason==null) reason="未知错误，请联系技术客服。";
			throw new Exception(mpr.getRespCode()+"-"+reason);
		}
	}
	
	
	public static void main(String[] args) throws Exception{
		MobilePhoneService mps = new MobilePhoneService();
		try {
			mps.sendMarketMessage("13525007261", "【科袖】您收到了一个新的咨询，快去查看吧。http://a.app.qq.com/o/simple.jsp?pkgname=com.ekexiu.app退订回N");
			System.out.println("send success!");
		} catch (Exception e) {
			throw new JfwBaseException("send error!");
		}
		//mps.sendMessage("18601149468","【科袖科技】请输入验证码yzm，完成手机绑定。请于1分钟内正确输入验证码。如非本人操作，请忽略本短信。科袖科技","yzm","122234");
	}
	static {
		errorReason.put("00001", "未知错误，请联系技术客服。");
		errorReason.put("00002", "未知的方法名");
		errorReason.put("00003", "请求方式错误");
		errorReason.put("00004", "参数非法，如request parameter (key) is missing");
		errorReason.put("00005", "timestamp已过期");
		errorReason.put("00006", "sign错误");
		errorReason.put("00007", "重复提交");
		errorReason.put("00008", "操作频繁");
		errorReason.put("00011", "请求的xml格式不对");
		errorReason.put("00012", "不支持get请求，请使用post");
		errorReason.put("00013", "请求url格式不正确");
		errorReason.put("00015", "时间戳超出有效时间范围");
		errorReason.put("00016", "请求json格式不对");
		errorReason.put("00017", "数据库操作失败");
		errorReason.put("00018", "参数为空");
		errorReason.put("00019", "订单已存在");
		errorReason.put("00020", "用户不存在");
		errorReason.put("00021", "子账号余额不足");
		errorReason.put("00022", "操作频繁");
		errorReason.put("00023", "开发者余额不足");
		errorReason.put("00025", "手机格式不对");
		errorReason.put("00026", "手机号存在");
		errorReason.put("00027", "子账号名称已存在");
		errorReason.put("00028", "子账号名称过长");
		errorReason.put("00029", "回调开发者服务器异常");
		errorReason.put("00030", "回调地址为空");
		errorReason.put("00031", "appId为空或者没有传值");
		errorReason.put("00032", "主叫号码为空或者没有传值");
		errorReason.put("00033", "被叫号码为空或者没有传值");
		errorReason.put("00034", "子账号为空或者没有传值");
		errorReason.put("00035", "主叫号码和被叫号码相同");
		errorReason.put("00036", "验证码格式不对（4-8位数字）");
		errorReason.put("00037", "limit格式不对");
		errorReason.put("00038", "start格式不对");
		errorReason.put("00039", "验证码为空或者缺少此参数");
		errorReason.put("00040", "用户名或者密码错误");
		errorReason.put("00050", "短信或者语音验证码错误");
		errorReason.put("00051", "显示号码与被叫号码一样，不允许呼叫");
		errorReason.put("00052", "回拨主叫号码格式错误");
		errorReason.put("00053", "被叫号码格式错误");
		errorReason.put("00054", "显号格式错误");
		errorReason.put("00055", "应用不包含此子账号");
		errorReason.put("00056", "开发者不包含此应用");
		errorReason.put("00060", "请求数据不存在");
		errorReason.put("00061", "app不存在");
		errorReason.put("00062", "developerId 请求错误");
		errorReason.put("00063", "app未上线");
		errorReason.put("00064", "请求Content-Type错误");
		errorReason.put("00065", "请求Accept错误");
		errorReason.put("00066", "开发者余额已被冻结");
		errorReason.put("00070", "手机号未绑定");
		errorReason.put("00071", "通知类型已停用或者未创建");
		errorReason.put("00072", "balance格式不对（必须为大于等于0的double）");
		errorReason.put("00073", "charge格式不对（必须为大于等于0的double）");
		errorReason.put("00074", "主叫和子账户绑定的手机号不相同");
		errorReason.put("00075", "子账户没有绑定手机号");
		errorReason.put("00076", "时间格式不对");
		errorReason.put("00077", "开始时间小于结束时间");
		errorReason.put("00078", "开始时间和結束時間必須是同一天");
		errorReason.put("00079", "服务器内部异常");
		errorReason.put("00080", "子账号不存在");
		errorReason.put("00081", "通知计费系统失败");
		errorReason.put("00082", "参数校验失败");
		errorReason.put("00083", "充值失败");
		errorReason.put("00084", "子账号没有托管 不能进行充值");
		errorReason.put("00085", "开发者不包含子帐号");
		errorReason.put("00086", "DEMO不能进行充值");
		errorReason.put("00087", "IQ类型错误");
		errorReason.put("00090", "回调地址为空");
		errorReason.put("00091", "没有语音");
		errorReason.put("00093", "没有这个语音文件或者审核没通过");
		errorReason.put("00094", "每批发送的手机号数量不得超过100个");
		errorReason.put("00095", "未开通邮件短信功能");
		errorReason.put("00096", "邮件模板未审核通过");
		errorReason.put("00097", "邮件模板未启用");
		errorReason.put("00098", "同一手机号每天只能发送n条相同的内容");
		errorReason.put("00099", "相同的应用每天只能给同一手机号发送n条不同的内容");
		errorReason.put("00100", "短信内容不能含有关键字");
		errorReason.put("00101", "配置短信端口号失败");
		errorReason.put("00102", "一个开发者只能配置一个端口");
		errorReason.put("00103", "应用的邮件模板不存在");
		errorReason.put("00104", "相同的应用当天给同一手机号发送短信的条数小于等于n");
		errorReason.put("00105", "本开发者只能发短信给移动手机");
		errorReason.put("00106", "时间戳(timestamp)参数为空");
		errorReason.put("00107", "签名(sig)参数为空");
		errorReason.put("00108", "时间戳(timestamp)格式错误");
		errorReason.put("00109", "子账号已被关闭");
		errorReason.put("00110", "解析post数据失败，post数据不符合格式要求");
		errorReason.put("00111", "匹配到黑名单");
		errorReason.put("00112", "accountSid参数为空");
		errorReason.put("00113", "短信内容和模板匹配度过低");
		errorReason.put("00114", "clientNumber参数为空");
		errorReason.put("00115", "charge参数为空");
		errorReason.put("00116", "charge格式不对，不能解析成double");
		errorReason.put("00117", "fromTime参数为空");
		errorReason.put("00118", "toTime参数为空");
		errorReason.put("00119", "fromTime参数格式不正确");
		errorReason.put("00120", "toTime参数格式不正确");
		errorReason.put("00122", "date参数为空");
		errorReason.put("00123", "date的值不在指定范围内");
		errorReason.put("00124", "没有查询到话单（所以没有生成下载地址）");
		errorReason.put("00125", "emailTemplateId参数为空");
		errorReason.put("00126", "to参数为空");
		errorReason.put("00127", "param参数为空");
		errorReason.put("00128", "templateId参数为空");
		errorReason.put("00129", "模板类型错误");
		errorReason.put("00130", "serviceType参数为空");
		errorReason.put("00131", "content参数为空");
		errorReason.put("00132", "本接口的邮件短信业务只能发送移动手机");
		errorReason.put("00133", "错误的业务类型");
		errorReason.put("00134", "没有和内容匹配的模板");
		errorReason.put("00135", "应用没有属于指定类型业务并且已审核通过、已启用的模板");
		errorReason.put("00136", "开发者不能调用此接口");
		errorReason.put("00137", "没有权限自定义邮件内容");
		errorReason.put("00138", "短信没有签名不能发送");
		errorReason.put("00139", "短信签名已进入黑名单不能发送");
		errorReason.put("00140", "邮件短信发送间隔太小");
		errorReason.put("00141", "一小时内发送给单个手机次数超过限制");
		errorReason.put("00142", "一天内发送给单个手机次数超过限制");
		errorReason.put("00143", "含有非法关键字");
		errorReason.put("00144", "mobile参数为空");
		errorReason.put("00145", "新手机号和旧手机号相同，不必修改");
		errorReason.put("00146", "minutes格式不对（必须为大于等于0的double）");
		errorReason.put("00147", "被叫次数超限");
		errorReason.put("00148", "主叫次数超限");
		errorReason.put("00149", "流量包大小格式错误");
		errorReason.put("00150", "找不到匹配的流量包");
		errorReason.put("00151", "该签名下的手机号码黑名单");
		errorReason.put("00152", "端口号已被关闭");
		errorReason.put("00153", "未知的手机号运营商");
		errorReason.put("00154", "开发者无权限给此号码发短信");
		errorReason.put("00155", "流量充值提交失败");
		errorReason.put("00156", "packageId为空或者没有传值");
		errorReason.put("00157", "packageId不存在");
		errorReason.put("00158", "不允许发验证码");
		errorReason.put("00159", "超过每秒发送频率限制");
		errorReason.put("00160", "没有发送会员通知推广类短信权限");
		errorReason.put("00161", "短信签名没有报备");
		errorReason.put("00162", "没有发送营销短信权限");
		errorReason.put("00163", "会员营销短信内容必须包含退订");
		errorReason.put("00164", "端口号非法");
	}
}

src/main/java/com/ekexiu/project/platform/professor/po/Professor.java

@@ -0,0 +1,48 @@
package com.ekexiu.project.platform.professor.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
@PrimaryKey("id")
@Table
public class Professor {
	private String id;
	private long shareId;
	private Integer level;
	private String assTime;
	
	@Column(DE.text_de)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	@Column(DE.long_de)
	public long getShareId() {
		return shareId;
	}
	public void setShareId(long shareId) {
		this.shareId = shareId;
	}
	@Column(DE.Int_de)
	public Integer getLevel() {
		return level;
	}
	public void setLevel(Integer level) {
		this.level = level;
	}
	@Column(DE.text_de)
	public String getAssTime() {
		return assTime;
	}
	public void setAssTime(String assTime) {
		this.assTime = assTime;
	}
	
	
	
}

src/main/java/com/ekexiu/project/platform/system/dao/DictDao.java

@@ -0,0 +1,43 @@
package com.ekexiu.project.platform.system.dao;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.IncludeFixSet;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Set;
import com.ekexiu.project.platform.system.po.DictItem;
@DAO
public interface DictDao {
	@SelectList
	List<DictItem> query(Connection con) throws SQLException;
	@Insert
	int insert(Connection con, DictItem dict) throws SQLException;
	@UpdateWith
	@From(DictItem.class)
	@Where("ACTIVE = '1' AND READONLY <> '1'")
	@SetSentence("ACTIVE='0'")
	@IncludeFixSet
	int disable(Connection con, String dictCode, String code) throws SQLException;
	
	@UpdateWith
	@From(DictItem.class)
	@Where("ACTIVE = '1' AND READONLY <> '1'")
	int update(Connection con, @Nullable @Set String bcode, @Set String caption, @Nullable @Set String fullCaption, @Set @Nullable String shortCut,
			@Nullable @Set String remark, String code, String dictCode) throws SQLException;
}

src/main/java/com/ekexiu/project/platform/system/dao/UserDao.java

@@ -0,0 +1,100 @@
package com.ekexiu.project.platform.system.dao;
import java.sql.Connection;
import java.sql.SQLException;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.Batch;
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.From;
import org.jfw.apt.orm.annotation.dao.method.IncludeFixSet;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.DeleteWith;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.Update;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Alias;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.apt.orm.annotation.dao.param.UnEquals;
import com.ekexiu.project.platform.system.po.Manager;
import com.ekexiu.project.platform.system.po.SysRight;
import com.ekexiu.project.platform.system.po.User;
import com.ekexiu.project.platform.system.po.UserLoginLog;
@DAO
public interface UserDao {
	@Nullable
	@SelectOne
	User query(Connection con, String id) throws SQLException;
	@Nullable
	@SelectOne
	User queryByLoginPhone(Connection con,String loginPhone,Boolean active) throws SQLException;
	
	@Nullable
	@SelectOne
	User login(Connection con, String account, String passwd) throws SQLException;
	
	@Insert
	int insert(Connection con, User user) throws SQLException;
	
	@Insert
	int insert(Connection con,UserLoginLog uli)throws SQLException;
	
	@UpdateWith
	@From(UserLoginLog.class)
	int updateLoginLog(Connection con,String id,@Set String lastLoginTime)throws SQLException;
	@Update
	@Exclude({"passwd","active","loginPhone"})
	int update(Connection con, User user) throws SQLException;
	
	@UpdateWith
	@From(User.class)
	int changePasswd(Connection con,String id,String passwd,@Set @Alias("passwd") String newPasswd) throws SQLException;
	
	@UpdateWith
	@From(User.class)
	int resetPasswd(Connection con,String loginPhone,@Set String passwd) throws SQLException;
	
	
	
	@Insert
	int insert(Connection con,Manager user)throws SQLException;
	
	@Insert
	@Batch
	int[] insert(Connection con,SysRight[] rightcodes)throws SQLException;
	
	@DeleteWith
	@From(SysRight.class)
	int delete(Connection con,String uid,@UnEquals String rightCode)throws SQLException;
	
	
	@Update
	@Where("ACTIVE ='1'")
	@IncludeFixSet
	@Exclude(value = { "invalidTime","invalidOperator","passwd","active" })
	int update(Connection con,Manager user)throws SQLException;
	
	@UpdateWith
	@From(Manager.class)
	@Where("ACTIVE ='1'")
	@SetSentence("ACTIVE='0',INVALID_TIME=TO_CHAR(NOW(),'YYYYMMDDHH24MISS')")
	int disable(Connection con,String id,@Set String invalidOperator)throws SQLException;
	
	@UpdateWith
	@From(Manager.class)
	@Where("ACTIVE ='0'")
	@SetSentence("ACTIVE='1'")
	int disable(Connection con,String id)throws SQLException;
	
	
	
}

src/main/java/com/ekexiu/project/platform/system/po/DictItem.java

@@ -0,0 +1,88 @@
package com.ekexiu.project.platform.system.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
@PrimaryKey({"dictCode","code"})
@Table(descp="数据字典表",value="SYS_DICT")
public class DictItem {
	private String code;
	private String dictCode;
	private String bcode;
	private String caption;
	private String fullCaption;
	private String shortCut;
	private String remark;
	private boolean readonly;
	private boolean active;
	
	@Column(descp="字典项编码",value= DE.rtext_de)
	public String getCode() {
		return code;
	}
	public void setCode(String code) {
		this.code = code;
	}
	
	@Column(descp="字典项编码(业务编码)",value= DE.Text_de)
	public String getBcode() {
		return bcode;
	}
	public void setBcode(String bcode) {
		this.bcode = bcode;
	}
	@Column(descp="字典编码",value= DE.rtext_de)
	public String getDictCode() {
		return dictCode;
	}
	public void setDictCode(String dictCode) {
		this.dictCode = dictCode;
	}
	@Column(descp="字典项显示",value= DE.text_de)
	public String getCaption() {
		return caption;
	}
	public void setCaption(String caption) {
		this.caption = caption;
	}
	@Column(descp="字典项显示(全)",value= DE.Text_de)
	public String getFullCaption() {
		return fullCaption;
	}
	public void setFullCaption(String fullCaption) {
		this.fullCaption = fullCaption;
	}
	@Column(descp="助记码",value= DE.Text_de)
	public String getShortCut() {
		return shortCut;
	}
	public void setShortCut(String shortCut) {
		this.shortCut = shortCut;
	}
	@Column(descp="备注",value= DE.Text_de)
	public String getRemark() {
		return remark;
	}
	public void setRemark(String remark) {
		this.remark = remark;
	}
	@Column(descp="是否只读",value= DE.boolean_de)
	public boolean isReadonly() {
		return readonly;
	}
	public void setReadonly(boolean readonly) {
		this.readonly = readonly;
	}
	@Column(descp="是否有效",value= DE.boolean_de)
	public boolean isActive() {
		return active;
	}
	public void setActive(boolean active) {
		this.active = active;
	}
	
	
	
}

src/main/java/com/ekexiu/project/platform/system/po/Manager.java

@@ -0,0 +1,148 @@
package com.ekexiu.project.platform.system.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.project.platform.base.po.ManagedBaseTable;
@PrimaryKey("id")
@Table
public class Manager  implements ManagedBaseTable {
	private String id;
	private String account;
	private String passwd;
	private String name;
	private String phone;
	private String email;
	private String job;
	private String dep;
	private String comp;
	private boolean active;
	private String createTime;
	private String creator;
	private String modifyTime;
	private String modifier;
	private String invalidTime;
	
	private String invalidOperator;
	
	@Column(DE.id_32)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	@Column(DE.text_de)
	public String getAccount() {
		return account;
	}
	public void setAccount(String account) {
		this.account = account;
	}
	@Column(DE.text_de)
	public String getPasswd() {
		return passwd;
	}
	public void setPasswd(String passwd) {
		this.passwd = passwd;
	}
	@Column(DE.Text_de)
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	@Column(DE.Text_de)
	public String getPhone() {
		return phone;
	}
	public void setPhone(String phone) {
		this.phone = phone;
	}
	@Column(DE.Text_de)
	public String getEmail() {
		return email;
	}
	public void setEmail(String email) {
		this.email = email;
	}
	@Column(DE.Text_de)
	public String getJob() {
		return job;
	}
	
	public void setJob(String job) {
		this.job = job;
	}
	@Column(DE.Text_de)
	public String getDep() {
		return dep;
	}
	public void setDep(String dep) {
		this.dep = dep;
	}
	@Column(DE.Text_de)
	public String getComp() {
		return comp;
	}
	public void setComp(String comp) {
		this.comp = comp;
	}
	@Column(DE.boolean_de)
	public boolean isActive() {
		return active;
	}
	public void setActive(boolean active) {
		this.active = active;
	}
	
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	public String getCreator() {
		return creator;
	}
	public void setCreator(String creator) {
		this.creator = creator;
	}
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	public String getModifier() {
		return modifier;
	}
	public void setModifier(String modifier) {
		this.modifier = modifier;
	}
	@Column(DE.Text_de)
	public String getInvalidTime() {
		return invalidTime;
	}
	public void setInvalidTime(String invalidTime) {
		this.invalidTime = invalidTime;
	}
	@Column(DE.Text_de)
	public String getInvalidOperator() {
		return invalidOperator;
	}
	public void setInvalidOperator(String invalidOperator) {
		this.invalidOperator = invalidOperator;
	}
	
	
	
	
	
	
}

src/main/java/com/ekexiu/project/platform/system/po/SysRight.java

@@ -0,0 +1,22 @@
package com.ekexiu.project.platform.system.po;
import org.jfw.apt.orm.annotation.entry.Table;
@Table
public class SysRight {
	private String uid;
	private String rightCode;
	public String getUid() {
		return uid;
	}
	public void setUid(String uid) {
		this.uid = uid;
	}
	public String getRightCode() {
		return rightCode;
	}
	public void setRightCode(String rightCode) {
		this.rightCode = rightCode;
	}
	
}

src/main/java/com/ekexiu/project/platform/system/po/User.java

@@ -0,0 +1,140 @@
package com.ekexiu.project.platform.system.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.annotation.entry.Unique;
import org.jfw.apt.orm.annotation.entry.Uniques;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.project.platform.base.po.BaseTable;
@PrimaryKey("id")
@Uniques({@Unique(clolumns="account",name="UC_LUSER_ACCOUNT")})
@Table(descp="用户表",value="LUSER")
public class User implements BaseTable {
	private String createTime;
	private String modifyTime;
	
	private String id;
	private String account;
	private String name;
	private String sex;
	private String job;
	private String comp;
	private String loginPhone;
	private String linkPhone;
	private String email;
	private String passwd;
	private boolean active;
	private String addr;
	private String head;
	
	
	@Column(descp="是否可用",value=DE.boolean_de)
	public boolean isActive() {
		return active;
	}
	public void setActive(boolean active) {
		this.active = active;
	}
	@Column(descp="密码（MD5）",queryable=false,handlerClass = StringHandler.class,dbType = "TEXT")
	public String getPasswd() {
		return passwd;
	}
	public void setPasswd(String passwd) {
		this.passwd = passwd;
	}
	@Column(descp="用户ID",value =DE.id_32)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	@Column(descp="用户姓名",value =DE.Text_de)
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	@Column(descp="用户帐号",value=DE.text_de)
	public String getAccount() {
		return account;
	}
	public void setAccount(String account) {
		this.account = account;
	}
	@Column(descp="用户所属单位",value=DE.Text_de)
	public String getComp() {
		return comp;
	}
	public void setComp(String comp) {
		this.comp = comp;
	}
	@Column(value=DE.Text_de,descp="用户职位")
	public String getJob() {
		return job;
	}
	public void setJob(String job) {
		this.job = job;
	}
	@Column(descp="联系电话",value=DE.Text_de)
	public String getLinkPhone() {
		return linkPhone;
	}
	public void setLinkPhone(String phone) {
		this.linkPhone = phone;
	}
	@Column(descp="联系邮件",value=DE.Text_de)
	public String getEmail() {
		return email;
	}
	public void setEmail(String email) {
		this.email = email;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	@Column(value=DE.SingleChar,descp="性别")
	public String getSex() {
		return sex;
	}
	public void setSex(String sex) {
		this.sex = sex;
	}
	@Column(value=DE.text_de,descp="登录手机号")
	public String getLoginPhone() {
		return loginPhone;
	}
	public void setLoginPhone(String loginPhone) {
		this.loginPhone = loginPhone;
	}
	@Column(value=DE.Text_de,descp="所在城市编码")
	public String getAddr() {
		return addr;
	}
	public void setAddr(String addr) {
		this.addr = addr;
	}
	@Column(value=DE.Text_de,descp="头像")
	public String getHead() {
		return head;
	}
	public void setHead(String head) {
		this.head = head;
	}
}

src/main/java/com/ekexiu/project/platform/system/po/UserLoginLog.java

@@ -0,0 +1,29 @@
package com.ekexiu.project.platform.system.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
@Table
@PrimaryKey("id")
public class UserLoginLog {
	private String id;
	private String lastLoginTime;
	@Column(DE.text_de)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	@Column(DE.text_de)
	public String getLastLoginTime() {
		return lastLoginTime;
	}
	public void setLastLoginTime(String lastLoginTime) {
		this.lastLoginTime = lastLoginTime;
	}
	
	
}

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

@@ -0,0 +1,263 @@
package com.ekexiu.project.platform.system.service;
import java.awt.Color;
import java.awt.image.BufferedImage;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.concurrent.atomic.AtomicInteger;
import javax.imageio.ImageIO;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.param.Upload;
import org.jfw.util.io.IoUtil;
import org.jfw.util.web.fileupload.Item;
import org.jfw.util.web.fileupload.UploadItemIterator;
import com.ekexiu.project.vo.UploadFile;
@Path("")
public class CommonUtilService {
	public static final String JPG = "jpg";
	private static final AtomicInteger HEAD_FN_IDX = new AtomicInteger(1);
	private File headPath;
	
	private static final AtomicInteger LOGO_FN_IDX = new AtomicInteger(1);
	private File logoPath;
	
	
	private static final AtomicInteger ARTICLE_FN_IDX = new AtomicInteger(1);
	private File articlePath;
	
	private int headMaxHeight = Integer.MAX_VALUE;
	
	
	public File getHeadPath() {
		return headPath;
	}
	public void setHeadPath(File headPath) {
		this.headPath = headPath;
	}
	public File getArticlePath() {
		return articlePath;
	}
	public void setArticlePath(File articlePath) {
		this.articlePath = articlePath;
	}
	public File getLogoPath() {
		return logoPath;
	}
	public void setLogoPath(File logoPath) {
		this.logoPath = logoPath;
	}
	public int getHeadMaxHeight() {
		return headMaxHeight;
	}
	public void setHeadMaxHeight(int headMaxHeight) {
		this.headMaxHeight = headMaxHeight;
	}
	private String normalizeFileName(String fn) {
		int index = fn.indexOf('\\');
		if (index >= 0) {
			fn = fn.substring(fn.lastIndexOf('\\') + 1);
		}
		index = fn.indexOf('/');
		if (index >= 0) {
			fn = fn.substring(fn.lastIndexOf('/') + 1);
		}
		if (fn.length() == 0)
			throw new RuntimeException("invalid filename in Multipart/data request");
		return fn;
	}
	private UploadFile buildTargetFile(File parentPath, AtomicInteger FN_IDX, String ext) {
		StringBuilder sb = new StringBuilder();
		sb.append("/").append(System.currentTimeMillis() / (1000 * 60 * 60 * 24));
		File path = new File(parentPath, sb.toString());
		if (!path.exists()) {
			synchronized (this) {
				if (!path.mkdirs())
					throw new RuntimeException("mkdir error[" + path + "]");
				FN_IDX.set(1);
			}
		}
		File file;
		do {
			String fn = FN_IDX.toString();
			if (ext.isEmpty()) {
				file = new File(path, fn);
			} else {
				file = new File(path, fn + "." + ext);
			}
			FN_IDX.incrementAndGet();
		} while (file.exists());
		sb.append("/").append(file.getName());
		UploadFile uf = new UploadFile();
		uf.setFn(file);
		uf.setUri(sb.toString());
		return uf;
	}
	private void saveHeadPhoto(InputStream in, UploadFile file) throws IOException {
		byte[] buf = new byte[8092];
		int w, h, sx1, sx2, sy1, sy2;
		int len;
		ByteArrayOutputStream of = new ByteArrayOutputStream();
		while ((len = in.read(buf)) >= 0) {
			if (len > 0) {
				of.write(buf, 0, len);
			}
		}
		BufferedImage im = ImageIO.read(in);
		if(im == null){
			throw new IOException("unsupported image type");
		}
		sx1 = 0;
		sy1 = 0;
		sx2 = w = im.getWidth();
		sy2 = h = im.getHeight();
		if (w > h) {
			sx1 = (w - h) / 2;
			sx2 = sx1 + h;
			w = h;
		} else if (w < h) {
			sy1 = (h - w) / 2;
			sy2 = sy1 + w;
			h = w;
		}
		if (h > this.headMaxHeight) {
			w = h = this.headMaxHeight;
		}
		BufferedImage newBufferedImage = new BufferedImage(w, h, BufferedImage.TYPE_INT_RGB);
		newBufferedImage.createGraphics().drawImage(im, 0, 0, w, h, sx1, sy1, sx2, sy2, Color.WHITE, null);
		OutputStream fos = new FileOutputStream(file.getFn());
		try {
			ImageIO.write(newBufferedImage, JPG, fos);
			fos.flush();
			file.setSize(file.getFn().length());
		} finally {
			IoUtil.close(fos);
		}
	}
	@Post
	@Path("/user/head")
	public UploadFile userHeadUpload(@Upload UploadItemIterator it) throws IOException {
		UploadFile uf = null;
		try {
			while (it.hasNext()) {
				Item item = it.next();
				if (!item.isFormField()) {
					String name = normalizeFileName(item.getName());
					int index = name.lastIndexOf('.');
					String ext = index >= 0 ? name.substring(index + 1) : "";
					ext = ext.trim();
					uf = buildTargetFile(this.headPath, HEAD_FN_IDX, ext);
					uf.setName(name);
					InputStream in = item.getInputStream();
					try {
						saveHeadPhoto(in, uf);
						return uf;
					} finally {
						in.close();
					}
				}
			}
		} finally {
			if (it != null)
				it.clean();
		}
		return uf;
	}
	@Post
	@Path("/logo")
	public UploadFile logoUpload(@Upload UploadItemIterator it) throws IOException {
		UploadFile uf = null;
		try {
			while (it.hasNext()) {
				Item item = it.next();
				if (!item.isFormField()) {
					String name = normalizeFileName(item.getName());
					int index = name.lastIndexOf('.');
					String ext = index >= 0 ? name.substring(index + 1) : "";
					ext = ext.trim();
					uf = buildTargetFile(this.logoPath, LOGO_FN_IDX, ext);
					uf.setName(name);
					InputStream in = item.getInputStream();
					try {
						OutputStream fos = new FileOutputStream(uf.getFn());
						try{
							IoUtil.copy(in, fos, false,false);
							fos.flush();
						}finally{
							fos.close();
						}
						return uf;
					} finally {
						in.close();
					}
				}
			}
		} finally {
			if (it != null)
				it.clean();
		}
		return uf;
	}
	
	@Post
	@Path("/article/image")
	public UploadFile articleImageUpload(@Upload UploadItemIterator it) throws IOException {
		UploadFile uf = null;
		try {
			while (it.hasNext()) {
				Item item = it.next();
				if (!item.isFormField()) {
					String name = normalizeFileName(item.getName());
					int index = name.lastIndexOf('.');
					String ext = index >= 0 ? name.substring(index + 1) : "";
					ext = ext.trim();
					uf = buildTargetFile(this.articlePath, ARTICLE_FN_IDX, ext);
					uf.setName(name);
					InputStream in = item.getInputStream();
					try {
						OutputStream fos = new FileOutputStream(uf.getFn());
						try{
							IoUtil.copy(in, fos, false,false);
							fos.flush();
						}finally{
							fos.close();
						}
						return uf;
					} finally {
						in.close();
					}
				}
			}
		} finally {
			if (it != null)
				it.clean();
		}
		return uf;
	}
}

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

@@ -0,0 +1,164 @@
package com.ekexiu.project.platform.system.service;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Collections;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import org.jfw.apt.annotation.Autowrie;
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.operate.Post;
import org.jfw.apt.web.annotation.param.AfterCommit;
import org.jfw.apt.web.annotation.param.JdbcConn;
import com.ekexiu.project.platform.system.dao.DictDao;
import com.ekexiu.project.platform.system.po.DictItem;
@Path("/dict")
public class DictService {
	private static final HashMap<String, List<DictItem>> dictCache = new HashMap<String, List<DictItem>>();
	private static final List<DictItem> Empty_DICT = Collections.emptyList();
	@Autowrie
	private DictDao dictDao;
	public DictDao getDictDao() {
		return dictDao;
	}
	public void setDictDao(DictDao dictDao) {
		this.dictDao = dictDao;
	}
	@Path("/load")
	@Get
	public void load(@JdbcConn Connection con) throws SQLException {
		HashMap<String, List<DictItem>> map = new HashMap<String, List<DictItem>>();
		List<DictItem> items = this.dictDao.query(con);
		for (DictItem item : items) {
			List<DictItem> list = map.get(item.getDictCode());
			if (list == null) {
				list = new LinkedList<DictItem>();
				map.put(item.getDictCode(), list);
			}
			list.add(item);
		}
		synchronized(dictCache){
			dictCache.clear();
			dictCache.putAll(map);
		}
	}
	@Path("/items")
	@Get
	public List<DictItem> query(String dict) {
		List<DictItem> ret = null;
		synchronized (dictCache) {
			ret = dictCache.get(dict);
		}
		return ret == null ? Empty_DICT : ret;
	}
	@Path("/delete")
	@Post
	public int delete(@JdbcConn(true) Connection con, final String dict, final String code, @AfterCommit List<Runnable> runs) throws SQLException {
		int num = this.dictDao.disable(con, dict, code);
		if (num > 0) {
			runs.add(new Runnable() {
				@Override
				public void run() {
					synchronized (dictCache) {
						List<DictItem> list = dictCache.get(dict);
						if (list != null) {
							List<DictItem> newlist = new LinkedList<DictItem>();
							for (DictItem item : list) {
								if (!item.getCode().equals(code)) {
									newlist.add(item);
								}
							}
							dictCache.put(dict, newlist);
						}
					}
				}
			});
		}
		return num;
	}
	@Post
	@Path("/add")
	public void insert(@JdbcConn(true) Connection con, String code, String dict, @Nullable String bcode, String caption, @Nullable String fullCaption,
			@Nullable String shortCut, @Nullable String remark, boolean readonly, @AfterCommit List<Runnable> runs) throws SQLException {
		final DictItem item = new DictItem();
		item.setActive(true);
		item.setBcode(bcode);
		item.setCaption(caption);
		item.setCode(code);
		item.setDictCode(dict);
		item.setFullCaption(fullCaption);
		item.setReadonly(readonly);
		item.setRemark(remark);
		item.setShortCut(shortCut);
		this.dictDao.insert(con, item);
		runs.add(new Runnable() {
			@Override
			public void run() {
				synchronized (dictCache) {
					List<DictItem> newlist = new LinkedList<DictItem>();
					List<DictItem> list = dictCache.get(item.getDictCode());
					if (list != null) {
						newlist.addAll(list);
					}
					newlist.add(item);
					dictCache.put(item.getDictCode(), newlist);
				}
			}
		});
	}
	@Post
	@Path("/modify")
	public int update(@JdbcConn(true) Connection con, String code, String dict, @Nullable String bcode, String caption, @Nullable String fullCaption,
			@Nullable String shortCut, @Nullable String remark, @AfterCommit List<Runnable> runs) throws SQLException {
		int num = this.dictDao.update(con, bcode, caption, fullCaption, shortCut, remark, code, dict);
		if (num > 0) {
			final DictItem item = new DictItem();
			item.setActive(true);
			item.setBcode(bcode);
			item.setCaption(caption);
			item.setCode(code);
			item.setDictCode(dict);
			item.setFullCaption(fullCaption);
			item.setReadonly(false);
			item.setRemark(remark);
			item.setShortCut(shortCut);
			runs.add(new Runnable() {
				@Override
				public void run() {
					synchronized (dictCache) {
						List<DictItem> newlist = new LinkedList<DictItem>();
						List<DictItem> list = dictCache.get(item.getDictCode());
						if (list != null) {
							for (DictItem nitem : list) {
								if (!nitem.getCode().equals(item.getCode())) {
									newlist.add(nitem);
								}
							}
						}
						newlist.add(item);
						dictCache.put(item.getDictCode(), newlist);
					}
				}
			});
		}
		return num;
	}
}

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

@@ -0,0 +1,395 @@
package com.ekexiu.project.platform.system.service;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Random;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.LoginUser;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.method.InvalidSession;
import org.jfw.apt.web.annotation.method.ResultToNull;
import org.jfw.apt.web.annotation.method.SetSession;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.operate.Put;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.PathVar;
import org.jfw.apt.web.annotation.param.RequestBody;
import org.jfw.apt.web.annotation.param.RequestParam;
import org.jfw.apt.web.annotation.param.SessionVal;
import org.jfw.util.DateUtil;
import org.jfw.util.StringUtil;
import org.jfw.util.auth.AuthUser;
import org.jfw.util.context.JfwAppContext;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.jdbc.JdbcUtil;
import com.ekexiu.project.platform.mobile.MobilePhoneService;
import com.ekexiu.project.platform.system.dao.UserDao;
import com.ekexiu.project.platform.system.po.Manager;
import com.ekexiu.project.platform.system.po.SysRight;
import com.ekexiu.project.platform.system.po.User;
import com.ekexiu.project.platform.system.po.UserLoginLog;
import com.ekexiu.project.platform.system.vo.ManagerInfo;
import com.ekexiu.project.platform.system.vo.SessionUser;
@Path("/sys")
public class SysService {
	private String regMobilePhoneReplaceKey = "yzm";
	private String regMobilePhoneContentTemplate = "【声脉】您的验证码为yzm，请于3分钟内正确输入，如非本人操作，请忽略此短信。";
	private long timeLimitWithRegMobilePhone = 3 * 60 * 1000;
	
	
	private String fixRightCode="aaa";
	
	
	
	
	private String accountPrefix = "xtpt_";
	@Autowrie
	private UserDao userDao;
	@Autowrie
	private MobilePhoneService mobilePhoneService;
	public UserDao getUserDao() {
		return userDao;
	}
	public void setUserDao(UserDao userDao) {
		this.userDao = userDao;
	}
	public MobilePhoneService getMobilePhoneService() {
		return mobilePhoneService;
	}
	public void setMobilePhoneService(MobilePhoneService mobilePhoneService) {
		this.mobilePhoneService = mobilePhoneService;
	}
	public String getRegMobilePhoneReplaceKey() {
		return regMobilePhoneReplaceKey;
	}
	public void setRegMobilePhoneReplaceKey(String regMobilePhoneReplaceKey) {
		this.regMobilePhoneReplaceKey = regMobilePhoneReplaceKey;
	}
	public String getRegMobilePhoneContentTemplate() {
		return regMobilePhoneContentTemplate;
	}
	public void setRegMobilePhoneContentTemplate(String regMobilePhoneContentTemplate) {
		this.regMobilePhoneContentTemplate = regMobilePhoneContentTemplate;
	}
	public long getTimeLimitWithRegMobilePhone() {
		return timeLimitWithRegMobilePhone;
	}
	public void setTimeLimitWithRegMobilePhone(long timeLimitWithRegMobilePhone) {
		this.timeLimitWithRegMobilePhone = timeLimitWithRegMobilePhone;
	}
	public String getAccountPrefix() {
		return accountPrefix;
	}
	public void setAccountPrefix(String accountPrefix) {
		this.accountPrefix = accountPrefix;
	}
	@SetSession("JFW_SESSION_LOGIN_USER=result")
	@Path("/login")
	@Post
	public SessionUser login(@JdbcConn Connection con, String phone, String pw) throws SQLException, JfwBaseException {
		final User user = userDao.queryByLoginPhone(con, phone, null);
		if (user != null) {
			if (!user.isActive()) {
				throw new JfwBaseException(-60003, "user is disabled");
			}
			if (StringUtil.md5(pw).equals(user.getPasswd())) {
				JfwAppContext.getScheduledExecutorService().submit(new Runnable() {
					@Override
					public void run() {
						try {
							Connection conn = JfwAppContext.getDataSource().getConnection();
							try {
								userDao.updateLoginLog(conn, user.getId(), DateUtil.formatDateTime(System.currentTimeMillis()));
								conn.commit();
							} catch (SQLException ee) {
								JdbcUtil.rollback(conn);
							} finally {
								JdbcUtil.close(conn);
							}
						} catch (Exception e) {
						}
					}
				});
				return makeSessionUser(user);
			}
			throw new JfwBaseException(-60002, "invalid passwd");
		} else {
			throw new JfwBaseException(-60001, "user not exists");
		}
	}
	@Get
	@Path("/user")
	public SessionUser get(@LoginUser(false) SessionUser user) {
		return user;
	}
	@Post
	@Path("/user")
	public void modifyUser(@JdbcConn(true) Connection con,@LoginUser SessionUser loginUser,
			@RequestParam(excludeFields={"id","createTime","modifyTime","loginPhone","passwd","active"}) User user)throws SQLException{
		user.setId(loginUser.getId());
		userDao.update(con, user);
	}
	
	@Post
	@Path("/user/changepasswd")
	public int changePasswd(@JdbcConn(true) Connection con,@LoginUser SessionUser loginUser,String opw,String npw)throws SQLException{
		return userDao.changePasswd(con,loginUser.getId(), StringUtil.md5(opw),StringUtil.md5(npw));
	}
	@Get
	@Path("/logout")
	@InvalidSession
	public void logout() {
	}
	@Get
	@Path("/serviceTime")
	public long serviceTime() {
		return System.currentTimeMillis();
	}
	@Get
	@Path("/user/exists")
	public boolean existsUser(@JdbcConn Connection con, String phone, @Nullable Boolean active) throws SQLException {
		return null != userDao.queryByLoginPhone(con, phone, active);
	}
	@SetSession({ "REG_PHONE=result[0]", "REG_PHONE_VC=result[1]", "REG_PHONE_TIMEOUT=result[1]" })
	@ResultToNull
	@Get
	@Post
	@Path("/registe/phone/msg")
	public Object[] registePhoneMsg(String phone, String vc, @Nullable @SessionVal(value = "PIC_REG", remove = true) String code,
			@Nullable @SessionVal(value = "TIMEOUT_PIC_REG", remove = true) Long timeout) throws Exception {
		if (code == null || timeout == null || System.currentTimeMillis() > timeout ) {
			throw new JfwBaseException(-60001, "not found sessionVal");
		}
		if (!vc.equals(code)) {
			throw new JfwBaseException(-60003, "vc not right");
		}
		Random rd = new Random();
		int vi = rd.nextInt(10000);
		String vcode = String.format("%04d", vi);
		this.mobilePhoneService.sendMessage(phone, this.regMobilePhoneContentTemplate, this.regMobilePhoneReplaceKey, vcode);
		Object[] result = new Object[3];
		result[0] = phone;
		result[1] = vcode;
		result[2] = System.currentTimeMillis() + 5000 + timeLimitWithRegMobilePhone;
		return result;
	}
	
	
	
	@SetSession({ "RSP_PHONE=result[0]", "RSP_PHONE_VC=result[1]", "RSP_PHONE_TIMEOUT=result[1]" })
	@ResultToNull
	@Get
	@Post
	@Path("/resetpw/phone/msg")
	public Object[] resetpwPhoneMsg(@JdbcConn Connection con, String phone) throws Exception {
		if( null == userDao.queryByLoginPhone(con, phone, null)){
			throw new JfwBaseException(-60001, "invalid phone num");
		}
		Random rd = new Random();
		int vi = rd.nextInt(10000);
		String vcode = String.format("%04d", vi);
		this.mobilePhoneService.sendMessage(phone, this.regMobilePhoneContentTemplate, this.regMobilePhoneReplaceKey, vcode);
		Object[] result = new Object[3];
		result[0] = phone;
		result[1] = vcode;
		result[2] = System.currentTimeMillis() + 5000 + timeLimitWithRegMobilePhone;
		return result;
	}
	@Get
	@Path("/resetpw/phone/msgCheck")
	public boolean resetpwPhoneMsgCheck(String phone, String vc, @Nullable @SessionVal(value = "RSP_PHONE") String sPhone,
			@Nullable @SessionVal(value = "RSP_PHONE_VC") String sCode, @Nullable @SessionVal(value = "RSP_PHONE_TIMEOUT") Long timeout) throws Exception {
		if (sCode == null || timeout == null || System.currentTimeMillis() > timeout) {
			throw new JfwBaseException(-60001, "not found sessionVal");
		}
		return vc.equals(sCode) && phone.equals(sPhone);
	}
	
	
	
	
	
	
	@Get
	@Path("/registe/phone/msgCheck")
	public boolean registePhoneMsgCheck(String phone, String vc, @Nullable @SessionVal(value = "REG_PHONE") String sPhone,
			@Nullable @SessionVal(value = "REG_PHONE_VC") String sCode, @Nullable @SessionVal(value = "REG_PHONE_TIMEOUT") Long timeout) throws Exception {
		if (sCode == null || timeout == null || System.currentTimeMillis() > timeout) {
			throw new JfwBaseException(-60001, "timeout");
		}
		return vc.equals(sCode) && phone.equals(sPhone);
	}
	@Post
	@Path("/registe")
	public void registe(@JdbcConn(true) Connection con, @Nullable String head, String phone, String vc, String pw,
			@Nullable @SessionVal(value = "REG_PHONE", remove = true) String sPhone, @Nullable @SessionVal(value = "REG_PHONE_VC", remove = true) String sCode,
			@Nullable @SessionVal(value = "REG_PHONE_TIMEOUT", remove = true) Long timeout) throws Exception {
		if (sCode == null || timeout == null || System.currentTimeMillis() > timeout) {
			throw new JfwBaseException(-60001, "timeout");
		}
		if (!vc.equals(sCode) || !phone.equals(sPhone)) {
			throw new JfwBaseException(-60002, "invalid");
		}
		User user = userDao.queryByLoginPhone(con, phone, null);
		if (user != null) {
			throw new JfwBaseException(-60003, "phone num exists");
		}
		Random rd = new Random();
		user = new User();
		user.setId(StringUtil.buildUUID());
		user.setAccount(this.accountPrefix + String.format("%08d", rd.nextInt(100000000)));
		user.setActive(true);
		user.setHead(head);
		user.setLinkPhone(phone);
		user.setPasswd(StringUtil.md5(pw));
		userDao.insert(con, user);
		UserLoginLog uli = new UserLoginLog();
		uli.setId(user.getId());
		uli.setLastLoginTime(DateUtil.formatDateTime(System.currentTimeMillis()));
	}
	
	@Post
	@Path("/resetpw")
	@InvalidSession
	public void resetpw(@JdbcConn(true) Connection con, String phone, String vc, String pw,
			@Nullable @SessionVal(value = "RSP_PHONE", remove = true) String sPhone, @Nullable @SessionVal(value = "RSP_PHONE_VC", remove = true) String sCode,
			@Nullable @SessionVal(value = "RSP_PHONE_TIMEOUT", remove = true) Long timeout) throws Exception {
		if (sCode == null || timeout == null || System.currentTimeMillis() > timeout) {
			throw new JfwBaseException(-60001, "timeout");
		}
		if (!vc.equals(sCode) || !phone.equals(sPhone)) {
			throw new JfwBaseException(-60002, "invalid valid code");
		}
		if(0 == userDao.resetPasswd(con, phone, pw)){
			throw new JfwBaseException(-60003, "no found data");
		}
	}
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	@Path("/user/new")
	@Post
	public String addUser(@JdbcConn(true) Connection con , @LoginUser AuthUser au, @RequestParam(excludeFields={"id","acitve","createor"}) Manager user,String[] rightCode)throws SQLException{
		String id = StringUtil.buildUUID();
		user.setActive(true);
		user.setCreator(au.getId());
		user.setId(id);
		user.setInvalidOperator(null);
		user.setInvalidTime(null);
		user.setPasswd(StringUtil.md5("123456"));
		userDao.insert(con, user);
		if(rightCode != null && rightCode.length >0){
			SysRight rights[]  = new SysRight[rightCode.length];
			for(int i = 0; i < rightCode.length;++i){
				rights[i] = new SysRight();
				rights[i].setUid(id);
				rights[i].setRightCode(rightCode[i]);
			}
			userDao.insert(con, rights);
		}
		return id;
	}
	
	@Path("/user/renew")
	@Put
	public void renewUser(@JdbcConn(true) Connection con , @LoginUser AuthUser au, @RequestBody ManagerInfo user)throws SQLException{
		user.setModifier(au.getId());
		userDao.update(con, user);
		userDao.delete(con,user.getId(),this.fixRightCode);
		String[] rightCode = user.getRightCode();
		if(rightCode != null && rightCode.length >0){
			SysRight rights[]  = new SysRight[rightCode.length];
			for(int i = 0; i < rightCode.length;++i){
				rights[i] = new SysRight();
				rights[i].setUid(user.getId());
				rights[i].setRightCode(rightCode[i]);
			}
			userDao.insert(con, rights);
		}
	}
	
	@Path("/user/right/{uid}")
	@Put
	public void rightUser(@JdbcConn(true) Connection con , @LoginUser AuthUser au,@PathVar String uid, @RequestBody String[] rightCode)throws SQLException{
		userDao.delete(con,uid,this.fixRightCode);
		if(rightCode != null && rightCode.length >0){
			SysRight rights[]  = new SysRight[rightCode.length];
			for(int i = 0; i < rightCode.length;++i){
				rights[i] = new SysRight();
				rights[i].setUid(uid);
				rights[i].setRightCode(rightCode[i]);
			}
			userDao.insert(con, rights);
		}
	}
	
	
	private static SessionUser makeSessionUser(User user) {
		SessionUser sessionUser = new SessionUser();
		sessionUser.setAccount(user.getAccount());
		sessionUser.setComp(user.getComp());
		sessionUser.setEmail(user.getEmail());
		sessionUser.setId(user.getId());
		sessionUser.setJob(user.getJob());
		sessionUser.setName(user.getName());
		sessionUser.setActive(user.isActive());
		sessionUser.setAddr(user.getAccount());
		sessionUser.setCreateTime(user.getCreateTime());
		sessionUser.setHead(user.getHead());
		sessionUser.setLinkPhone(user.getLinkPhone());
		sessionUser.setLoginPhone(user.getLoginPhone());
		sessionUser.setModifyTime(user.getModifyTime());
		sessionUser.setSex(user.getSex());
		return sessionUser;
	}
}

src/main/java/com/ekexiu/project/platform/system/vo/ManagerInfo.java

@@ -0,0 +1,20 @@
package com.ekexiu.project.platform.system.vo;
import java.util.List;
import org.jfw.apt.orm.annotation.entry.ExtendTable;
import com.ekexiu.project.platform.system.po.Manager;
@ExtendTable
public class ManagerInfo extends Manager {
	private String[] rightCode;
	public String[] getRightCode() {
		return rightCode;
	}
	public void setRightCode(String[] rightCode) {
		this.rightCode = rightCode;
	}
}

src/main/java/com/ekexiu/project/platform/system/vo/SessionUser.java

@@ -0,0 +1,114 @@
package com.ekexiu.project.platform.system.vo;
import org.jfw.util.auth.AuthUser;
/**
 * Created by TT on 2018/8/7.
 */
public class SessionUser implements AuthUser {
    private String id;
    private String name;
    private String account;
    private String comp;
    private String job;
    private String email;
	private String createTime;
	private String modifyTime;
	private String sex;
	private String loginPhone;
	private String linkPhone;
	private String addr;
	private String head;
    private boolean active;
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public String getAccount() {
		return account;
	}
	public void setAccount(String account) {
		this.account = account;
	}
	public String getComp() {
		return comp;
	}
	public void setComp(String comp) {
		this.comp = comp;
	}
	public String getJob() {
		return job;
	}
	public void setJob(String job) {
		this.job = job;
	}
	public String getEmail() {
		return email;
	}
	public void setEmail(String email) {
		this.email = email;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	public String getSex() {
		return sex;
	}
	public void setSex(String sex) {
		this.sex = sex;
	}
	public String getLoginPhone() {
		return loginPhone;
	}
	public void setLoginPhone(String loginPhone) {
		this.loginPhone = loginPhone;
	}
	public String getLinkPhone() {
		return linkPhone;
	}
	public void setLinkPhone(String linkPhone) {
		this.linkPhone = linkPhone;
	}
	public String getAddr() {
		return addr;
	}
	public void setAddr(String addr) {
		this.addr = addr;
	}
	public String getHead() {
		return head;
	}
	public void setHead(String head) {
		this.head = head;
	}
	public boolean isActive() {
		return active;
	}
	public void setActive(boolean active) {
		this.active = active;
	}
	@Override
	public boolean hasAuthority(int auth) {
		return true;
	};
   
}

src/main/java/com/ekexiu/project/vo/UploadFile.java

@@ -0,0 +1,42 @@
package com.ekexiu.project.vo;
import java.io.File;
public class UploadFile {
	   private String name;
       private String uri;
       private long size;
       private transient File fn;
       public File getFn() {
           return fn;
       }
       public void setFn(File fn) {
           this.fn = fn;
       }
       public String getName() {
           return name;
       }
       public void setName(String name) {
           this.name = name;
       }
       public String getUri() {
           return uri;
       }
       public void setUri(String uri) {
           this.uri = uri;
       }
       public long getSize() {
           return size;
       }
       public void setSize(long size) {
           this.size = size;
       }
}

src/main/resources/.gitignore

@@ -0,0 +1 @@
/dev.properties

src/main/webapp/web.xml

@@ -0,0 +1,64 @@
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
                      http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
	version="3.0" metadata-complete="true">
	<servlet>
		<servlet-name>ajax</servlet-name>
		<servlet-class>org.jfw.web.servlet.core.JdbcConfigServlet</servlet-class>
		<init-param>
			<param-name>prefixLen</param-name>
			<param-value>15</param-value>
		</init-param>
		<init-param>
			<param-name>viewType</param-name>
			<param-value>1</param-value>
		</init-param>
		<init-param>
			<param-name>configFileName</param-name>
			<param-value>beanConfig.properties,dev.properties</param-value>
		</init-param>
		<init-param>
			<param-name>afterBeanFactory</param-name>
			<param-value>com.ekexiu.project.job.TaskJob</param-value>
		</init-param>
		<init-param>
			<param-name>overrideFileConfig</param-name>
			<param-value>true</param-value>
		</init-param>
		<init-param>
			<param-name>driverClassName</param-name>
			<param-value>org.postgresql.Driver</param-value>
		</init-param>
		<init-param>
			<param-name>url</param-name>
			<param-value>jdbc:postgresql://192.168.3.233:5432/platform</param-value>
		</init-param>
		<init-param>
			<param-name>username</param-name>
			<param-value>postgres</param-value>
		</init-param>
		<init-param>
			<param-name>password</param-name>
			<param-value>postgres</param-value>
		</init-param>
		<init-param>
			<param-name>sql</param-name>
			<param-value>SELECT CFG_NAME,CFG_VALUE FROM CONSOLE_CONFIG</param-value>
		</init-param>
		<load-on-startup>1</load-on-startup>
	</servlet>
	<servlet-mapping>
		<servlet-name>ajax</servlet-name>
		<url-pattern>/ajax/*</url-pattern>
	</servlet-mapping>
	
	<session-config>
		<cookie-config>
			<name>JSES_PF_M</name>
			<http-only>true</http-only>
			<path>/</path>
		</cookie-config>
	</session-config>
</web-app>