package com.yeshi.fanli.service.impl.user;
|
|
import java.io.Serializable;
|
import java.math.BigDecimal;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.UUID;
|
|
import javax.annotation.Resource;
|
|
import org.hibernate.HibernateException;
|
import org.hibernate.Query;
|
import org.hibernate.Session;
|
import org.hibernate.Transaction;
|
import org.springframework.orm.hibernate4.HibernateCallback;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.alipay.api.AlipayApiException;
|
import com.alipay.api.AlipayClient;
|
import com.alipay.api.DefaultAlipayClient;
|
import com.alipay.api.request.AlipayFundTransToaccountTransferRequest;
|
import com.alipay.api.response.AlipayFundTransToaccountTransferResponse;
|
import com.yeshi.fanli.dao.mybatis.AccountDetailsMapper;
|
import com.yeshi.fanli.dao.mybatis.AlipayAccountValidNormalHistoryMapper;
|
import com.yeshi.fanli.dao.mybatis.BindingAccountMapper;
|
import com.yeshi.fanli.dao.mybatis.UserInfoMapper;
|
import com.yeshi.fanli.dao.user.BindingAccountDao;
|
import com.yeshi.fanli.entity.bus.user.AccountDetails;
|
import com.yeshi.fanli.entity.bus.user.AlipayAccountValidNormalHistory;
|
import com.yeshi.fanli.entity.bus.user.BindingAccount;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.exception.AlipayAccountException;
|
import com.yeshi.fanli.exception.AlipayTransferException;
|
import com.yeshi.fanli.exception.BindingAccountException;
|
import com.yeshi.fanli.service.inter.user.BindingAccountService;
|
import com.yeshi.fanli.service.inter.user.UserNotificationService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.factory.AccountDetailsFactory;
|
|
import net.sf.json.JSONObject;
|
|
@Service
|
public class BindingAccountServiceImpl implements BindingAccountService {
|
|
@Resource
|
private BindingAccountDao bindingAccountDao;
|
@Resource
|
private BindingAccountMapper bindingAccountMapper;
|
@Resource
|
private AlipayAccountValidNormalHistoryMapper alipayAccountValidNormalHistoryMapper;
|
@Resource
|
private UserInfoMapper userInfoMapper;
|
@Resource
|
private AccountDetailsMapper accountDetailsMapper;
|
@Resource
|
private UserNotificationService userNotificationService;
|
|
public List<BindingAccount> getBindingAccountByUid(long uid) {
|
return bindingAccountDao.list("from BindingAccount ba where ba.userInfo.id=?", new Serializable[] { uid });
|
}
|
|
public void addBindingAccount(BindingAccount addAccount) throws BindingAccountException {
|
List<BindingAccount> list = bindingAccountDao.list(
|
"from BindingAccount ba where ba.userInfo.id=? and ba.type=?",
|
new Serializable[] { addAccount.getUserInfo().getId(), addAccount.getType() });
|
if (list == null || list.size() == 0) {
|
bindingAccountDao.save(addAccount);
|
} else {
|
throw new BindingAccountException(Constant.BA_EXIST);
|
}
|
}
|
|
public Integer deleteBindingAccount(final BindingAccount account) {
|
return (Integer) bindingAccountDao.excute(new HibernateCallback() {
|
|
public Integer doInHibernate(Session session) throws HibernateException {
|
Transaction transaction = session.beginTransaction();
|
Query delete = session.createQuery("delete BindingAccount ba where ba.userInfo.id=? and ba.type=?");
|
delete.setLong(0, account.getUserInfo().getId());
|
delete.setInteger(1, account.getType());
|
int update = delete.executeUpdate();
|
transaction.commit();
|
return update;
|
}
|
|
});
|
}
|
|
public BindingAccount getBindingAccountByUidAndType(long uid, int type) {
|
|
List<BindingAccount> list = bindingAccountDao
|
.list("from BindingAccount ba where ba.userInfo.id=? and ba.type=?", new Serializable[] { uid, type });
|
if (list != null && list.size() != 0) {
|
return list.get(0);
|
}
|
return null;
|
}
|
|
@Override
|
public BindingAccount changeAlipayBinding(Long uid, String name, String account) {
|
BindingAccount bindingAccount = getBindingAccountByUidAndType(uid, BindingAccount.TYPE_ALIPAY);
|
if (bindingAccount == null)// 创建账号
|
{
|
bindingAccount = new BindingAccount();
|
bindingAccount.setAccount(account);
|
bindingAccount.setName(name);
|
bindingAccount.setType(BindingAccount.TYPE_ALIPAY);
|
bindingAccount.setUserInfo(new UserInfo(uid));
|
bindingAccountDao.create(bindingAccount);
|
} else {
|
bindingAccount.setName(name);
|
bindingAccount.setAccount(account);
|
bindingAccountDao.update(bindingAccount);
|
}
|
return bindingAccount;
|
}
|
|
@Override
|
public int deleteByPrimaryKey(Long id) {
|
return bindingAccountMapper.deleteByPrimaryKey(id);
|
}
|
|
@Transactional
|
@Override
|
public void validAlipayAccount(Long uid, String account, String name)
|
throws AlipayTransferException, AlipayApiException, AlipayAccountException {
|
if (uid == null)
|
throw new AlipayAccountException(AlipayAccountException.CODE_NO_PARAMS, "用户ID不能为空");
|
if (StringUtil.isNullOrEmpty(account))
|
throw new AlipayAccountException(AlipayAccountException.CODE_NO_PARAMS, "账号不能为空");
|
if (StringUtil.isNullOrEmpty(name))
|
throw new AlipayAccountException(AlipayAccountException.CODE_NO_PARAMS, "真实姓名不能为空");
|
//
|
List<BindingAccount> bindingAccountList = bindingAccountMapper.selectByAccount(account);
|
if (bindingAccountList != null && bindingAccountList.size() > 0) {
|
if (bindingAccountList.get(0).getUserInfo().getId().longValue() != uid)
|
throw new AlipayAccountException(AlipayAccountException.CODE_ALREADY_BIND,
|
"该支付宝账号已被其他账号绑定，请更换其他的支付宝账号来绑定");
|
}
|
|
// TODO 做频率验证-每月验证一次
|
AlipayAccountValidNormalHistory latest = alipayAccountValidNormalHistoryMapper.selectLatestByUid(uid);
|
if (latest != null) {
|
Calendar caLatest = Calendar.getInstance();
|
caLatest.setTimeInMillis(latest.getCreateTime().getTime());
|
Calendar nowLatest = Calendar.getInstance();
|
if (caLatest.get(Calendar.MONTH) == nowLatest.get(Calendar.MONTH))// 上次更改和现在是同一个月
|
throw new AlipayAccountException(AlipayAccountException.CODE_TIMES_LIMIT, "每月只能更换绑定一次支付宝账号，请次月再试。");
|
}
|
|
UserInfo userInfo = userInfoMapper.selectByPrimaryKeyForUpdate(uid);
|
if (userInfo.getMyHongBao().compareTo(new BigDecimal("0")) <= 0)
|
throw new AlipayAccountException(AlipayAccountException.CODE_NO_MONEY, "你的账户目前没有余额，暂时不能绑定支付宝提现");
|
|
// 需要转账验证
|
BigDecimal money = new BigDecimal("0.1");
|
transferAlipayWithVerify(account, name);
|
// 扣款
|
userInfoMapper.subHongBaoByUid(uid, money);
|
// 转账成功
|
// 插入转账成功表
|
AlipayAccountValidNormalHistory history = new AlipayAccountValidNormalHistory();
|
history.setAccount(account);
|
history.setCreateTime(new Date());
|
history.setName(name);
|
history.setUid(uid);
|
alipayAccountValidNormalHistoryMapper.insertSelective(history);
|
// 资金记录 站内信
|
AccountDetails accountDetails = AccountDetailsFactory.create("-" + money.toString(),
|
AccountDetailsFactory.VALID_ALIPAY_ACCOUNT, null, null, new UserInfo(uid));
|
accountDetailsMapper.insertSelective(accountDetails);
|
userNotificationService.alipayAccountValidRight(uid, money, account);
|
|
}
|
|
private void transferAlipayWithVerify(String account, String name)
|
throws AlipayTransferException, AlipayApiException {
|
String privateKey = Constant.alipayConfig.getPrivateKey();
|
AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do",
|
Constant.alipayConfig.getAppId(), privateKey, "json", "gbk", null, "RSA2");
|
AlipayFundTransToaccountTransferRequest request = new AlipayFundTransToaccountTransferRequest();
|
String uuid = UUID.randomUUID().toString().replace("-", "");
|
String appName = Constant.systemCommonConfig.getProjectChineseName();
|
JSONObject json = new JSONObject();
|
json.put("out_biz_no", uuid);
|
json.put("payee_type", "ALIPAY_LOGONID");
|
json.put("payee_account", account);
|
json.put("amount", "0.1");
|
json.put("payer_show_name", appName + "支付宝验证");
|
json.put("payee_real_name", name);
|
json.put("remark", "来自" + appName + "的支付宝验证打款");
|
request.setBizContent(json.toString());
|
AlipayFundTransToaccountTransferResponse response = null;
|
response = alipayClient.execute(request);
|
// 成功转账
|
if (response != null && response.isSuccess() && "10000".equals(response.getCode())) {
|
return;
|
} else// 转账失败
|
{
|
throw new AlipayTransferException(Integer.parseInt(response.getCode()), response.getSubCode(),
|
response.getSubMsg());
|
}
|
}
|
|
@Transactional
|
@Override
|
public BindingAccount changeAlipayBindingWithVerify(Long uid, String name, String account)
|
throws AlipayTransferException, AlipayApiException, AlipayAccountException {
|
|
try {
|
validAlipayAccount(uid, account, name);
|
} catch (AlipayTransferException e1) {
|
throw new AlipayTransferException(e1.getCode(), e1.getSubCode(), e1.getMsg());
|
} catch (AlipayApiException e1) {
|
throw new AlipayApiException(e1.getErrCode(), e1.getErrMsg());
|
} catch (AlipayAccountException e1) {
|
throw new AlipayAccountException(e1.getCode(), e1.getMsg());
|
}
|
|
BindingAccount bindingAccount = bindingAccountMapper.selectByUidAndType(uid, BindingAccount.TYPE_ALIPAY);
|
if (bindingAccount == null)// 创建账号
|
{
|
bindingAccount = new BindingAccount();
|
bindingAccount.setAccount(account);
|
bindingAccount.setName(name);
|
bindingAccount.setType(BindingAccount.TYPE_ALIPAY);
|
bindingAccount.setUserInfo(new UserInfo(uid));
|
bindingAccountMapper.insertSelective(bindingAccount);
|
} else {
|
BindingAccount updateBindingAccount = new BindingAccount();
|
updateBindingAccount.setId(bindingAccount.getId());
|
updateBindingAccount.setName(name);
|
updateBindingAccount.setAccount(account);
|
bindingAccountMapper.updateByPrimaryKeySelective(updateBindingAccount);
|
bindingAccount.setName(updateBindingAccount.getName());
|
bindingAccount.setAccount(updateBindingAccount.getAccount());
|
}
|
|
return bindingAccount;
|
}
|
|
@Override
|
public boolean canVerifyAlipayAccount(Long uid) throws BindingAccountException {
|
UserInfo userInfo = userInfoMapper.selectByPrimaryKeyForUpdate(uid);
|
if (userInfo.getMyHongBao().compareTo(new BigDecimal("0")) <= 0)
|
throw new BindingAccountException(1, "你的账户目前没有余额，无需绑定提现帐号。");
|
|
AlipayAccountValidNormalHistory latest = alipayAccountValidNormalHistoryMapper.selectLatestByUid(uid);
|
if (latest != null) {
|
Calendar caLatest = Calendar.getInstance();
|
caLatest.setTimeInMillis(latest.getCreateTime().getTime());
|
Calendar nowLatest = Calendar.getInstance();
|
if (caLatest.get(Calendar.MONTH) == nowLatest.get(Calendar.MONTH))// 上次更改和现在是同一个月
|
throw new BindingAccountException(2, "本月支付宝绑定次数超限");
|
}
|
return true;
|
}
|
|
}
|
