|
@@ -75,7 +75,7 @@ public class UserRechargeServiceImpl implements IUserRechargeService {
|
|
|
}
|
|
|
|
|
|
|
|
|
- public ServerResponse inMoney(String amtRMB, String amt, String payType, HttpServletRequest request) {
|
|
|
+ public ServerResponse inMoney(String amtRMB, String amt, String payType,String orderDesc, HttpServletRequest request) {
|
|
|
if (StringUtils.isBlank(amtRMB) || StringUtils.isBlank(amt) || StringUtils.isBlank(payType)) {
|
|
|
return ServerResponse.createByErrorMsg("参数不能为空");
|
|
|
}
|
|
@@ -114,9 +114,10 @@ public class UserRechargeServiceImpl implements IUserRechargeService {
|
|
|
userRecharge.setPayChannel(payType);
|
|
|
userRecharge.setPayAmtRMB(new BigDecimal(amtRMB));
|
|
|
userRecharge.setPayAmt(new BigDecimal(amt));
|
|
|
- userRecharge.setOrderStatus(Integer.valueOf(0));
|
|
|
+ userRecharge.setOrderStatus(0);
|
|
|
userRecharge.setAddTime(new Date());
|
|
|
-
|
|
|
+ //商家名称
|
|
|
+ userRecharge.setOrderDesc(orderDesc);
|
|
|
// BigDecimal payAmt = new BigDecimal(amt);
|
|
|
// 账户充值
|
|
|
//汇率
|
|
@@ -126,23 +127,15 @@ public class UserRechargeServiceImpl implements IUserRechargeService {
|
|
|
// }else {
|
|
|
// userRecharge.setPayAmt(new BigDecimal(amt));
|
|
|
// }
|
|
|
-
|
|
|
-
|
|
|
int insertCount = this.userRechargeMapper.insert(userRecharge);
|
|
|
if (insertCount > 0) {
|
|
|
-
|
|
|
String email_token = KeyUtils.getUniqueKey();
|
|
|
-
|
|
|
String redisSetExResult = RedisShardedPoolUtils.setEx(email_token, email_token, 300);
|
|
|
-
|
|
|
log.info("用户充值,保存redis token成功,redisSetExResult = {}", redisSetExResult);
|
|
|
-
|
|
|
- SendHTMLMail.send(user, userRecharge, email_token, siteInfo
|
|
|
- .getSiteHost(), siteInfo.getSiteEmailTo());
|
|
|
- log.info("用户充值,发送审核邮件成功");
|
|
|
-
|
|
|
+// SendHTMLMail.send(user, userRecharge, email_token, siteInfo
|
|
|
+// .getSiteHost(), siteInfo.getSiteEmailTo());
|
|
|
+// log.info("用户充值,发送审核邮件成功");
|
|
|
messageService.sendTopicMessage(String.format("%s充值了%s", user.getRealName(), amt));
|
|
|
-
|
|
|
return ServerResponse.createBySuccessMsg("创建支付订单成功!");
|
|
|
}
|
|
|
return ServerResponse.createByErrorMsg("创建支付订单失败");
|
|
@@ -243,14 +236,9 @@ public class UserRechargeServiceImpl implements IUserRechargeService {
|
|
|
|
|
|
public ServerResponse<PageInfo> findUserChargeList(String payChannel, String orderStatus, HttpServletRequest request, int pageNum, int pageSize) {
|
|
|
PageHelper.startPage(pageNum, pageSize);
|
|
|
-
|
|
|
User user = this.iUserService.getCurrentUser(request);
|
|
|
-
|
|
|
-
|
|
|
List<UserRecharge> userRecharges = this.userRechargeMapper.findUserChargeList(user.getId(), payChannel, orderStatus);
|
|
|
-
|
|
|
PageInfo pageInfo = new PageInfo(userRecharges);
|
|
|
-
|
|
|
return ServerResponse.createBySuccess(pageInfo);
|
|
|
}
|
|
|
|