支付记录和手机邮箱验证登录

src/main/java/com/ekexiu/portal/dao/PayHistoryDao.java

@@ -0,0 +1,70 @@
package com.ekexiu.portal.dao;
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.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.util.exception.JfwBaseException;
import com.ekexiu.portal.po.Operation;
import com.ekexiu.portal.po.PayHistory;
@DAO
public abstract class PayHistoryDao {
	@Insert
	public abstract int insert(Connection con, PayHistory payHistory) throws SQLException;
	
	@UpdateWith
	@From(PayHistory.class)
	public abstract int update(Connection con, String payHistoryId, @Set int payStatus) throws SQLException;
	
	@SelectOne
	public abstract PayHistory query(Connection con, String payHistoryId) throws SQLException, JfwBaseException;
	
//	@SelectList
//	public abstract List<PayHistory> queryOper(Connection con, String operationId) throws SQLException;
	
	public java.util.List<com.ekexiu.portal.po.PayHistory> queryDetail(java.sql.Connection con,java.lang.String operationId) throws java.sql.SQLException{
        int _m_1 = 1;
        String sql = "SELECT PAY_HISTORY_ID,PAY_HISTORY.OPERATION_ID,PAID_MONEY,RETURN_MONEY,REMARK,ISONLINE,PAY_TYPE,PAY_HISTORY.CREATE_TIME,OPERATION.DEAL_PRICE,OPERATION.CREATE_TIME FROM PAY_HISTORY LEFT JOIN OPERATION ON PAY_HISTORY.OPERATION_ID = OPERATION.OPERATION_ID WHERE PAY_HISTORY.OPERATION_ID = ?";
        java.sql.PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,operationId);
            java.sql.ResultSet rs = ps.executeQuery();
            try{
                java.util.List<com.ekexiu.portal.po.PayHistory> _result = new java.util.ArrayList<com.ekexiu.portal.po.PayHistory>();
                while(rs.next()){
                    com.ekexiu.portal.po.PayHistory _obj =  new com.ekexiu.portal.po.PayHistory();
                    _obj.setPayHistoryId(rs.getString(1));
                    Operation operation = new Operation();
                    operation.setOperationId(rs.getString(2));
                    _obj.setPaidMoney(rs.getBigDecimal(3));
                    _obj.setReturnMoney(rs.getBigDecimal(4));
                    java.lang.String _m_2 = rs.getString(5);
                    if(rs.wasNull()){
                        _m_2 = null;
                    }
                    _obj.setRemark(_m_2);
                    _obj.setIsonline(rs.getInt(6));
                    _obj.setPayType(rs.getInt(7));
                    _obj.setCreateTime(rs.getString(8));
                    operation.setDealPrice(rs.getBigDecimal(9));
                    operation.setCreateTime(rs.getString(10));
                    _obj.setOperation(operation);
                    _result.add(_obj);
                }
                return _result;
            }finally{
                try{rs.close();}catch(Exception _m_3){}
            }
        }finally{
            try{ps.close();}catch(Exception _m_4){}
        }
    }
	
}

src/main/java/com/ekexiu/portal/po/PayHistory.java

@@ -0,0 +1,105 @@
package com.ekexiu.portal.po;
import java.math.BigDecimal;
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.defaultImpl.StringHandler;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.portal.basepo.CreateTimeSupported;
@Table
@PrimaryKey("payHistoryId")
public class PayHistory implements CreateTimeSupported {
	private String payHistoryId;
	private String operationId;
	private BigDecimal paidMoney;
	private BigDecimal returnMoney;
	private String createTime;
	private String remark;
	private int isonline;
	private int payType;
	private int payStatus;
	private Operation operation;
	
	public Operation getOperation() {
		return operation;
	}
	public void setOperation(Operation operation) {
		this.operation = operation;
	}
	
	@Column(DE.id_32)
	public String getPayHistoryId() {
		return payHistoryId;
	}
	public void setPayHistoryId(String payHistoryId) {
		this.payHistoryId = payHistoryId;
	}
	
	@Column(DE.id_32)
	public String getOperationId() {
		return operationId;
	}
	public void setOperationId(String operationId) {
		this.operationId = operationId;
	}
	
	@Column(DE.bigDecmimal_de)
	public BigDecimal getPaidMoney() {
		return paidMoney;
	}
	public void setPaidMoney(BigDecimal paidMoney) {
		this.paidMoney = paidMoney;
	}
	
	@Column(DE.bigDecmimal_de)
	public BigDecimal getReturnMoney() {
		return returnMoney;
	}
	public void setReturnMoney(BigDecimal returnMoney) {
		this.returnMoney = returnMoney;
	}
	
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	
	@Column(handlerClass=StringHandler.class,dbType="TEXT",insertable=true,nullable=true,renewable=false,queryable=true)
	public String getRemark() {
		return remark;
	}
	public void setRemark(String remark) {
		this.remark = remark;
	}
	
	@Column(DE.int_de)
	public int getIsonline() {
		return isonline;
	}
	public void setIsonline(int isonline) {
		this.isonline = isonline;
	}
	
	@Column(DE.int_de)
	public int getPayType() {
		return payType;
	}
	public void setPayType(int payType) {
		this.payType = payType;
	}
	
	@Column(DE.int_de)
	public int getPayStatus() {
		return payStatus;
	}
	public void setPayStatus(int payStatus) {
		this.payStatus = payStatus;
	}
	
}

src/main/java/com/ekexiu/portal/service/PayHistoryService.java

@@ -0,0 +1,81 @@
package com.ekexiu.portal.service;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.annotation.Autowrie;
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.JdbcConn;
import org.jfw.apt.web.annotation.param.PathVar;
import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import com.ekexiu.portal.dao.PayHistoryDao;
import com.ekexiu.portal.po.PayHistory;
@Path("/payhistory")
public class PayHistoryService {
	@Autowrie
	private PayHistoryDao payHistoryDao;
	public PayHistoryDao getPayHistoryDao() {
		return payHistoryDao;
	}
	public void setPayHistoryDao(PayHistoryDao payHistoryDao) {
		this.payHistoryDao = payHistoryDao;
	}
	
	@Post
	@Path
	public String insert(@JdbcConn(true) Connection con, PayHistory payHistory) throws SQLException {
		String payHistoryId = StringUtil.buildUUID();
		payHistory.setPayHistoryId(payHistoryId);
		this.payHistoryDao.insert(con, payHistory);
		return payHistoryId;
	}
	
	@Post
	@Path("/status")
	public void updatePayStatus(@JdbcConn(true) Connection con, String payHistoryId, int payStatus) throws SQLException {
		this.payHistoryDao.update(con, payHistoryId, payStatus);
	}
	
	@Get
	@Path("/{payHistoryId}")
	public PayHistory query(@JdbcConn Connection con, @PathVar String payHistoryId) throws SQLException, JfwBaseException {
		return this.payHistoryDao.query(con, payHistoryId);
	}
	
//	@Get
//	@Path("/qaoper")
//	public List<PayHistory> queryOper(@JdbcConn Connection con, String operationId) throws SQLException {
//		return this.payHistoryDao.queryOper(con, operationId);
//	}
	
	@Get
	@Path("/qadetail")
	public List<PayHistory> queryDetail(@JdbcConn Connection con, String operationId) throws SQLException {
		return this.payHistoryDao.queryDetail(con, operationId);
	}
	
//	@Get
//	@Path("/qadetail")
//	public List<PayHistory> queryDetail(@JdbcConn Connection con, String operationId) throws SQLException {
//		List<PayHistory> historiesList = this.payHistoryDao.queryDetail(con, operationId);
//		for (PayHistory payHistory : historiesList) {
//			double remainMoney = payHistory.getOperation().getDealPrice().doubleValue();
//			if(payHistory.getPayType() == 0){
//				remainMoney = remainMoney - payHistory.getPaidMoney().doubleValue();
//			}
//			if(payHistory.getPayType() == 1){
//				remainMoney = remainMoney + payHistory.getReturnMoney().doubleValue();
//			}
//		}
//		return this.payHistoryDao.queryDetail(con, operationId);
//	}
	
}

src/main/java/com/ekexiu/portal/service/SysService.java

@@ -46,6 +46,10 @@ public class SysService {
	private String bindMailReplaceKey;
	private String bindMailReplaceContentTempalte;
	private long timeLimitWithBindMail = 10 * 60 * 1000;
	
	private String regMailReplaceKey;
	private String regMailReplaceContentTempalte;
	private long timeLimitWithRegMail = 10 * 60 * 1000;
	private String bindMobilePhoneReplaceKey;
	private String bindMobilePhoneContentTemplate;
@@ -64,6 +68,31 @@ public class SysService {
	private String regMobilePhoneContentTemplate;
	private long timeLimitWithRegMobilePhone = 60 * 1000;
	
	public String getRegMailReplaceKey() {
		return regMailReplaceKey;
	}
	public void setRegMailReplaceKey(String regMailReplaceKey) {
		this.regMailReplaceKey = regMailReplaceKey;
	}
	public String getRegMailReplaceContentTempalte() {
		return regMailReplaceContentTempalte;
	}
	public void setRegMailReplaceContentTempalte(
			String regMailReplaceContentTempalte) {
		this.regMailReplaceContentTempalte = regMailReplaceContentTempalte;
	}
	public long getTimeLimitWithRegMail() {
		return timeLimitWithRegMail;
	}
	public void setTimeLimitWithRegMail(long timeLimitWithRegMail) {
		this.timeLimitWithRegMail = timeLimitWithRegMail;
	}
	public String getRegMobilePhoneReplaceKey() {
		return regMobilePhoneReplaceKey;
	}
@@ -234,8 +263,8 @@ public class SysService {
	}
	@Post
	@Path("/reg")
	public String insert(@JdbcConn(true) Connection con, String state, String mobilePhone, String validateCode, String password) throws SQLException {
	@Path("/regmobile")
	public String regMobile(@JdbcConn(false) Connection con, String state, String mobilePhone, String validateCode, String password) throws SQLException {
		@SuppressWarnings("unchecked")
		StateCode<String, String> sc = (StateCode<String, String>) JfwAppContext.getCachedObject(state);
		if (sc == null)
@@ -259,6 +288,57 @@ public class SysService {
		}
	}
	
	@Post
	@Path("/regmail/{key}")
	public String regeMail(@JdbcConn(false) Connection con, @PathVar String key, String mail, String password) throws SQLException {
		@SuppressWarnings("unchecked")
		StateCode<String, String> sc = (StateCode<String, String>) JfwAppContext.getCachedObject(key);
		if (sc == null)
			return null;
		if (sc.getExpiredTime() < System.currentTimeMillis())
			return null;
		try {
			User user = new User();
			user.setId(StringUtil.buildUUID());
			String passwd = StringUtil.md5(password);
			user.setEmail(mail);
			user.setPasswd(passwd);
			user.setUserType(0+"");
			this.userDao.insert(con, user);
			return user.getId();
		} finally {
			JfwAppContext.removeCachedObject(key);
		}
	}
	
	@Get
	@Path("/regmail")
	public boolean regMail(@JdbcConn(false) Connection con, String mail) throws JfwBaseException, SQLException {
		StateCode<String, String> sc = new StateCode<String, String>();
		final String key = JfwAppContext.cacheObjectAndGenKey(sc);
		Map<String, String> map = new HashMap<String, String>();
		map.put(this.regMailReplaceKey, key);
		try {
			mailservice.sendSimpleMail(mail, this.regMailReplaceContentTempalte, map, this.bindMailSubject);
			long ct = System.currentTimeMillis();
			long et = ct + this.timeLimitWithRegMail + 10000;
			sc.setBuildTime(ct);
			sc.setExpiredTime(et);
			JfwAppContext.getScheduledExecutorService().schedule(new Runnable() {
				@Override
				public void run() {
					JfwAppContext.removeCachedObject(key);
				}
			}, this.timeLimitWithRegMail + 20000, TimeUnit.MILLISECONDS);
		} catch (Exception e) {
			JfwAppContext.removeCachedObject(key);
			throw new JfwBaseException(10011, "send mail to " + mail + " error", e);
		}
		return true;
	}
	
	@SetCookie(checkResultNull = true, path = "/", value = { "userid=result.getId()", "userMobilePhone=result.getMobilePhone()", "userType=result.getType()",
			"userAuth=String.valueOf(result.isAuth())", "userEmail=result.getEmail()==null?\"\":result.getEmail()","userName=result.getName()" })
	@Post
@@ -296,7 +376,9 @@ public class SysService {
		
		SessionUser ret = new SessionUser();
		ret.setId(user.getId());
		ret.setName(this.professorDao.query(con,user.getId()).getName());
		if(null!=this.professorDao.query(con,user.getId())) {
			ret.setName(this.professorDao.query(con,user.getId()).getName());
		}
		ret.setMobilePhone(user.getMobilePhone());
		ret.setType(user.getUserType());
		ret.setEmail(user.getEmail());