Skip to content

W
whatsmars

caopu16 / whatsmars
与 Fork 源项目一致

Fork自 武汉红喜 / whatsmars

通知 1
Star 0
Fork 0
W
whatsmars

体验新版 GitCode，发现更多精彩内容 >>

提交 d4e1bf4b 编写于 作者: 武汉红喜's avatar 武汉红喜
浏览文件
操作

guava cache

上级 254ff02f
展开全部 显示空白变更内容
内联 并排
Showing with 53 addition and 1435 deletion
whatsmars-earth/whatsmars-earth-dao/src/main/java/org/hongxi/whatsmars/earth/dao/CityDao.java 0 → 100644
浏览文件 @ d4e1bf4b
package org.hongxi.whatsmars.earth.dao;
import org.hongxi.whatsmars.earth.domain.pojo.City;
import java.util.List;
/**
* Created by shenhongxi on 2018/1/16.
*/
public interface CityDao {
List<City> getByPid(String pid);
}
whatsmars-earth/whatsmars-earth-domain/src/main/java/org/hongxi/whatsmars/earth/domain/pojo/City.java 0 → 100644
浏览文件 @ d4e1bf4b
package org.hongxi.whatsmars.earth.domain.pojo;
/**
* Created by shenhongxi on 2018/1/16.
*/
public class City {
}
whatsmars-earth/whatsmars-earth-service/src/main/java/org/hongxi/whatsmars/earth/service/guava-cache-example.txt → whatsmars-earth/whatsmars-earth-service/src/main/java/org/hongxi/whatsmars/earth/service/CityService.java
浏览文件 @ d4e1bf4b
public class YibaoCityManagerImpl implements YibaoCityManager{
package org.hongxi.whatsmars.earth.service;
import com.google.common.cache.Cache;
import com.google.common.cache.CacheBuilder;
import org.hongxi.whatsmars.earth.dao.CityDao;
import org.hongxi.whatsmars.earth.domain.pojo.City;
private YibaoCityDao yibaoCityDao;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;
private static Cache<String,List<YibaoCityDO>> cache = CacheBuilder.newBuilder().maximumSize(2048).expireAfterAccess(15, TimeUnit.MINUTES).build();
/**
* Created by shenhongxi on 2018/1/16.
*/
public class CityService {
public void setYibaoCityDao(YibaoCityDao yibaoCityDao) {
this.yibaoCityDao = yibaoCityDao;
}
private CityDao cityDao;
private static Cache<String,List<City>> cache = CacheBuilder.newBuilder().maximumSize(2048).expireAfterAccess(15, TimeUnit.MINUTES).build();
public void setCityDao(CityDao cityDao) {
this.cityDao = cityDao;
}
@Override
public List<YibaoCityDO> getByPid(final String pid) {
public List<City> getByPid(final String pid) {
try {
//cache.get方法首先从Cache中查询key是否存在，如果存在则返回对应的value。
//如果不存在，则调用Callable.call方法。并把call方法返回的结果保存在cache中。
return cache.get(pid, new Callable<List<YibaoCityDO>>() {
return cache.get(pid, new Callable<List<City>>() {
@Override
public List<YibaoCityDO> call() throws Exception {
public List<City> call() throws Exception {
return load(pid);
}
});
......@@ -37,12 +48,11 @@ public class YibaoCityManagerImpl implements YibaoCityManager{
* @return
* @throws Exception
*/
protected List<YibaoCityDO> load(final String pid) throws Exception{
List<YibaoCityDO> result = this.yibaoCityDao.getByPid(pid);
protected List<City> load(final String pid) throws Exception{
List<City> result = this.cityDao.getByPid(pid);
if(result == null) {
throw new NullPointerException("pid not existed");
}
return result;
}
}
whatsmars-earth/whatsmars-earth-service/src/main/java/org/hongxi/whatsmars/earth/service/impl/AccountServiceImpl.java
浏览文件 @ d4e1bf4b
......@@ -4,6 +4,9 @@ import org.hongxi.whatsmars.common.pojo.Result;
import org.hongxi.whatsmars.earth.dao.AccountDao;
import org.hongxi.whatsmars.earth.service.AccountService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallback;
import org.springframework.transaction.support.TransactionTemplate;
/**
* Created by shenhongxi on 2016/4/1.
......@@ -14,7 +17,7 @@ public class AccountServiceImpl implements AccountService {
private AccountDao accountDao;
//@Autowired
//private TransactionTemplate transactionTemplate;
// private TransactionTemplate transactionTemplate;
public Result hello(String name) {
Result result = new Result();
......@@ -26,7 +29,12 @@ public class AccountServiceImpl implements AccountService {
// boolean isSuccess = transactionTemplate.execute(new TransactionCallback<Boolean>() {
// @Override
// public Boolean doInTransaction(TransactionStatus transactionStatus) {
//
// try {
// // ...
// return true;
// } catch (Exception e) {
// transactionStatus.setRollbackOnly();
// }
// return false;
// }
// });
......
whatsmars-earth/whatsmars-earth-service/src/main/java/org/hongxi/whatsmars/earth/service/transaction-example.txt 已删除 100644 → 0
浏览文件 @ 254ff02f
@Override
public Result withdraw(final Double withdraw, String clientIp, String dealPassword, String phoneCode) {
final Result result = new Result();
Integer lenderId = LoginContextHolder.getLoginUser().getId();
try {
final LenderAccountDO account = this.lenderAccountManager.validateDealPassword(lenderId, dealPassword);
if (account == null) {
result.setResultCode(ResultCode.VALIDATE_FAILURE);
result.setMessage("交易密码不正确");
return result;
}
if (StringUtils.isBlank(account.getBankName()) || StringUtils.isBlank(account.getBankCardId())){
result.setResultCode(ResultCode.VALIDATE_FAILURE);
result.setMessage("您还未绑定银行卡");
return result;
}
if(account.getBalance() <= 0 || account.getBalanceFrozen() < 0) {
result.setResultCode(ResultCode.VALIDATE_FAILURE);
result.setMessage("账户余额不足，无法提现");
return result;
}
//校验手机校验码是否正确
final LenderDO lender = lenderManager.getById(lenderId);
MongoCollection<Document> dbCollection = mongoDBClient.getCollection(Constants.MONGO_SMS_SEND_OPERATION_COLLECTION);
Bson parentFilter = Filters.and(Filters.eq("phone", lender.getPhone()), Filters.eq("type", withdrawPhoneCode));
Document document = dbCollection.find(parentFilter).limit(1).first();
result.setResultCode(ResultCode.VALIDATE_FAILURE);
result.addModel("flag", "code_error");
if (document == null) {
result.setMessage("验证码非法");
return result;
}
Long created = document.getLong("created");
if (created + 20 * 60000L <= System.currentTimeMillis()) {
result.setMessage("验证码已经过期");
return result;
}
if (!phoneCode.equals(document.get("checkCode"))) {
result.setMessage("验证码错误");
return result;
}
// 提现金额+手续费=交易总额
final Double amount = CalculatorUtils.format(withdraw + 2);
if (amount.compareTo(account.getBalance()) > 0){
result.setResultCode(ResultCode.VALIDATE_FAILURE);
result.setMessage("账户余额不足");
return result;
}
final long time = System.currentTimeMillis();
//计算出商家订单号
final String orderId = "LW" + lenderId + "-" + time;
/**
* 发送提现请求
*/
String bankCardId = account.getBankCardId();
String top = bankCardId.substring(0, 6);
String last = bankCardId.substring(bankCardId.length() - 4, bankCardId.length());
final WithdrawRequestEntity requestEntity = new WithdrawRequestEntity();
requestEntity.setRequestId(orderId);
requestEntity.setIdentityId(lender.getCardId());
requestEntity.setCardTop(top);
requestEntity.setCardLast(last);
requestEntity.setAmount(((Double) (withdraw * 100)).intValue());
requestEntity.setClientIp(clientIp);
//事务操作
boolean isSuccess = transactionTemplate.execute(new TransactionCallback<Boolean>() {
@Override
public Boolean doInTransaction(TransactionStatus transactionStatus) {
try {
//修改投资人账户
Double balanceBefore = account.getBalance();
Double balanceAfter = CalculatorUtils.format(balanceBefore - amount);
Double frozenBefore = account.getBalanceFrozen();
Double frozenAfter = CalculatorUtils.format(frozenBefore + amount);
account.setBalance(balanceAfter);
account.setBalanceFrozen(frozenAfter);
lenderAccountManager.updateBalance(account);
//新建一条投资人流水
final LenderAccountFlowDO flow = new LenderAccountFlowDO();
flow.setLenderId(lender.getId());
flow.setLenderName(lender.getName());
flow.setLenderRealName(lender.getRealName());
flow.setPhone(lender.getPhone());
flow.setType(LenderFlowTypeEnum.WITHDRAW.code);
flow.setOrderId(orderId);
flow.setAmount(amount);
flow.setWithdraw(withdraw);
flow.setFee(2.0D);
flow.setDescription("提现金额:" + withdraw + "元；手续费2元。");
flow.setBalanceBefore(balanceBefore);
flow.setBalanceAfter(balanceAfter);
flow.setFrozenBefore(frozenBefore);
flow.setFrozenAfter(frozenAfter);
//将流水状态设为提现处理中
flow.setStatus(FlowStatusEnum.ONGOING.code);
lenderAccountFlowManager.insert(flow);
JSONObject responseJson = null;
try {
responseJson = TZTUtils.withdraw(requestEntity);
withdrawLogger.error(responseJson.toString());
} catch (Exception e) {
logger.error("lender withdraw request error, lenderId:" + lender.getId(), e);
result.setMessage("第三方支付系统繁忙，请稍后再试");
throw new RuntimeException(e);
}
if (responseJson.containsKey("error_code")) {
result.setResultCode(ResultCode.VALIDATE_FAILURE);
result.setMessage("{" + responseJson.getString("error_code") + ":" + responseJson.getString("error_msg") + "}");
throw new RuntimeException("{" + responseJson.getString("error_code") + ":" + responseJson.getString("error_msg") + "}");
}
if (responseJson.containsKey("clientSignError")) {
result.setResultCode(ResultCode.VALIDATE_FAILURE);
result.setMessage(responseJson.getString("clientSignError"));
throw new RuntimeException(responseJson.getString("clientSignError"));
}
//提现请求状态：FAILURE：请求失败 SUCCESS：请求成功 UNKNOW:未知
String withdrawStatus = responseJson.getString("status");
if (withdrawStatus.equals("FAILURE")) {
result.setResultCode(ResultCode.VALIDATE_FAILURE);
result.setMessage("提现请求失败，请稍后重试!");
throw new RuntimeException("提现请求失败，状态：" + withdrawStatus);
}
//易宝返回的商家订单号
String requestId = responseJson.getString("requestid");
if (!orderId.equals(requestId)) {
result.setResultCode(ResultCode.VALIDATE_FAILURE);
result.setMessage("订单号不一致，订单号：" + orderId);
throw new RuntimeException("订单号不一致，订单号：" + orderId);
}
//提现流水日志
buildFlowLog(flow, time);
return true;
} catch (Exception e) {
transactionStatus.setRollbackOnly();
}
return false;
}
});
result.setSuccess(isSuccess);
} catch (Exception e) {
logger.error("withdraw error, lenderId:" + lenderId, e);
result.setResultCode(ResultCode.SYSTEM_ERROR);
result.setMessage("系统错误，请稍后再试!");
}
return result;
}
\ No newline at end of file
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或