package com.nq.service.impl;
|
|
|
import cn.hutool.core.codec.Base64Encoder;
|
import cn.hutool.core.map.MapUtil;
|
import cn.hutool.crypto.SecureUtil;
|
import cn.hutool.crypto.asymmetric.Sign;
|
import cn.hutool.crypto.asymmetric.SignAlgorithm;
|
import cn.hutool.http.HttpResponse;
|
import cn.hutool.http.HttpUtil;
|
import cn.hutool.json.JSONUtil;
|
import com.nq.common.lanage.MessageLocaleResolver;
|
import com.nq.dao.UserBankMapper;
|
import com.nq.pay.PayUtil;
|
import com.nq.pojo.*;
|
import com.nq.service.*;
|
import com.github.pagehelper.PageHelper;
|
|
import com.github.pagehelper.PageInfo;
|
|
import com.nq.common.ServerResponse;
|
|
import com.nq.dao.AgentUserMapper;
|
|
import com.nq.dao.UserMapper;
|
|
import com.nq.dao.UserWithdrawMapper;
|
|
import com.nq.utils.stock.WithDrawUtils;
|
|
import java.math.BigDecimal;
|
|
import java.util.*;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
|
import net.sf.json.JSONObject;
|
import org.apache.commons.collections.map.HashedMap;
|
import org.apache.commons.lang3.StringUtils;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.stereotype.Service;
|
|
|
@Service("iUserWithdrawService")
|
public class UserWithdrawServiceImpl implements IUserWithdrawService {
|
|
private static final Logger log = LoggerFactory.getLogger(UserWithdrawServiceImpl.class);
|
|
|
@Resource
|
UserWithdrawMapper userWithdrawMapper;
|
|
|
@Autowired
|
IUserService iUserService;
|
|
|
@Resource
|
UserMapper userMapper;
|
|
|
@Autowired
|
IAgentUserService iAgentUserService;
|
|
@Resource
|
AgentUserMapper agentUserMapper;
|
|
@Autowired
|
IUserPositionService iUserPositionService;
|
|
@Autowired
|
IUserBankService iUserBankService;
|
|
@Autowired
|
ISiteSettingService iSiteSettingService;
|
|
@Autowired
|
ISiteProductService iSiteProductService;
|
|
@Resource
|
UserBankMapper userBankMapper;
|
|
|
@Transactional
|
public ServerResponse outMoney(String amt, String with_Pwd, HttpServletRequest request) throws Exception {
|
String lanage = request.getHeader(MessageLocaleResolver.LANG);
|
if (StringUtils.isBlank(amt)) {
|
return ServerResponse.createByErrorMsg("The parameter cannot be null",lanage);
|
}
|
User user = this.iUserService.getCurrentRefreshUser(request);
|
String w = user.getWithPwd();
|
if (w == null) {
|
w = "";
|
}
|
if (with_Pwd == null) {
|
with_Pwd = "";
|
}
|
BigDecimal outMoney = new BigDecimal(amt);
|
|
if(user.getUserAmt().compareTo(outMoney)<0){
|
return ServerResponse.createByErrorMsg("Insufficient balance",lanage);
|
}
|
|
|
if (w.equals(with_Pwd)) {
|
if (user.getIsLogin().intValue() == 1) {
|
return ServerResponse.createByErrorMsg("User locked",lanage);
|
}
|
|
|
List<UserPosition> userPositions = this.iUserPositionService.findPositionByUserIdAndSellIdIsNull(user.getId());
|
|
if (userPositions.size() > 0) {
|
return ServerResponse.createByErrorMsg("There is no deposit with warehouse receipt",lanage);
|
|
}
|
|
|
if (StringUtils.isBlank(user.getRealName()) || StringUtils.isBlank(user.getIdCard())) {
|
|
return ServerResponse.createByErrorMsg("No real name authentication",lanage);
|
|
}
|
|
UserBank userBank = this.iUserBankService.findUserBankByUserId(user.getId());
|
|
if (userBank == null) {
|
|
return ServerResponse.createByErrorMsg("No bank card added",lanage);
|
|
}
|
|
|
if (user.getAccountType().intValue() == 1) {
|
|
return ServerResponse.createByErrorMsg("Analog users cannot withdraw funds",lanage);
|
|
}
|
|
|
SiteSetting siteSetting = this.iSiteSettingService.getSiteSetting();
|
|
if ((new BigDecimal(amt)).compareTo(new BigDecimal(siteSetting.getWithMinAmt().intValue())) == -1) {
|
|
return ServerResponse.createByErrorMsg("Analog users cannot withdraw funds" + siteSetting.getWithMinAmt(),lanage);
|
|
}
|
|
|
int with_time_begin = siteSetting.getWithTimeBegin().intValue();
|
|
int with_time_end = siteSetting.getWithTimeEnd().intValue();
|
|
SiteProduct siteProduct = iSiteProductService.getProductSetting();
|
if(siteProduct.getHolidayDisplay()){
|
return ServerResponse.createByErrorMsg("Withdrawals are not allowed on weekends or holidays！",lanage);
|
}
|
|
if (!WithDrawUtils.checkIsWithTime(with_time_begin, with_time_end)) {
|
|
return ServerResponse.createByErrorMsg("Withdrawal failed. Withdrawal time is at" + with_time_begin + "point - " + with_time_end + "point among",lanage);
|
|
}
|
|
|
BigDecimal index_user_amt = user.getUserIndexAmt();
|
|
if (index_user_amt.compareTo(new BigDecimal("0")) == -1) {
|
|
return ServerResponse.createByErrorMsg("Index funds cannot be less than 0",lanage);
|
|
}
|
|
|
BigDecimal futures_user_amt = user.getUserFutAmt();
|
|
if (futures_user_amt.compareTo(new BigDecimal("0")) == -1) {
|
|
return ServerResponse.createByErrorMsg("Futures capital cannot be less than 0",lanage);
|
|
}
|
|
|
BigDecimal enable_amt = user.getEnableAmt();
|
|
int compareAmt = enable_amt.compareTo(new BigDecimal(amt));
|
|
if (compareAmt == -1) {
|
|
return ServerResponse.createByErrorMsg("Withdrawal failed, the user's available funds are insufficient",lanage);
|
|
}
|
|
|
BigDecimal user_all_amt = user.getUserAmt();
|
|
BigDecimal reckon_all_amt = user_all_amt.subtract(new BigDecimal(amt));
|
|
BigDecimal reckon_enable_amt = enable_amt.subtract(new BigDecimal(amt));
|
|
user.setUserAmt(reckon_all_amt);
|
|
user.setEnableAmt(reckon_enable_amt);
|
|
log.info("用户提现{}，金额 = {},总资金 = {},可用资金 = {}", new Object[]{user.getId(), amt, user_all_amt, enable_amt});
|
|
|
log.info("提现后，总金额={},可用资金={}", reckon_all_amt, reckon_enable_amt);
|
|
int updateUserCount = this.userMapper.updateByPrimaryKeySelective(user);
|
|
if (updateUserCount > 0) {
|
|
log.info("修改用户资金成功");
|
|
} else {
|
|
log.error("修改用户资金失败");
|
|
throw new Exception("用户提现，修改用户资金失败");
|
|
}
|
|
|
UserWithdraw userWithdraw = new UserWithdraw();
|
|
userWithdraw.setUserId(user.getId());
|
|
userWithdraw.setNickName(user.getRealName());
|
|
userWithdraw.setAgentId(user.getAgentId());
|
|
userWithdraw.setWithAmt(new BigDecimal(amt));
|
|
userWithdraw.setApplyTime(new Date());
|
|
userWithdraw.setWithName(user.getRealName());
|
|
userWithdraw.setBankNo(userBank.getBankNo());
|
|
userWithdraw.setBankName(userBank.getBankName());
|
|
userWithdraw.setBankAddress(userBank.getBankAddress());
|
|
userWithdraw.setWithStatus(Integer.valueOf(0));
|
|
|
BigDecimal withfee = siteSetting.getWithFeePercent().multiply(new BigDecimal(amt)).add(new BigDecimal(siteSetting.getWithFeeSingle().intValue()));
|
|
userWithdraw.setWithFee(withfee);
|
|
|
int insertCount = this.userWithdrawMapper.insert(userWithdraw);
|
|
if (insertCount > 0) {
|
return ServerResponse.createBySuccessMsg("Successful withdrawal",lanage);
|
}
|
|
log.error("保存提现记录失败");
|
|
throw new Exception("用户提现，保存提现记录失败");
|
} else {
|
return ServerResponse.createByErrorMsg("The withdrawal password is incorrect！！",lanage);
|
}
|
|
}
|
|
|
public ServerResponse<PageInfo> findUserWithList(String withStatus, HttpServletRequest request, int pageNum, int pageSize) {
|
|
PageHelper.startPage(pageNum, pageSize);
|
|
|
User user = this.iUserService.getCurrentUser(request);
|
|
|
List<UserWithdraw> userWithdraws = this.userWithdrawMapper.findUserWithList(user.getId(), withStatus);
|
|
|
PageInfo pageInfo = new PageInfo(userWithdraws);
|
|
|
return ServerResponse.createBySuccess(pageInfo);
|
|
}
|
|
|
public ServerResponse userCancel(Integer withId,HttpServletRequest request) {
|
String lanage = request.getHeader(MessageLocaleResolver.LANG);
|
if (withId == null) {
|
|
return ServerResponse.createByErrorMsg("id cannot be empty",lanage);
|
|
}
|
|
|
UserWithdraw userWithdraw = this.userWithdrawMapper.selectByPrimaryKey(withId);
|
|
if (userWithdraw == null) {
|
|
return ServerResponse.createByErrorMsg("Order does not exist",lanage);
|
|
}
|
|
|
if (0 != userWithdraw.getWithStatus().intValue()) {
|
|
return ServerResponse.createByErrorMsg("The current order cannot be canceled",lanage);
|
|
}
|
|
|
userWithdraw.setWithStatus(Integer.valueOf(3));
|
|
userWithdraw.setWithMsg("The user cancels the withdrawal");
|
|
int updateCount = this.userWithdrawMapper.updateByPrimaryKeySelective(userWithdraw);
|
|
if (updateCount > 0) {
|
|
log.info("修改用户提现订单 {} 状态成功", withId);
|
|
|
User user = this.userMapper.selectByPrimaryKey(userWithdraw.getUserId());
|
|
user.setUserAmt(user.getUserAmt().add(userWithdraw.getWithAmt()));
|
|
user.setEnableAmt(user.getEnableAmt().add(userWithdraw.getWithAmt()));
|
|
int updateUserCount = this.userMapper.updateByPrimaryKeySelective(user);
|
|
if (updateUserCount > 0) {
|
|
log.info("反还用户资金，总 {} 可用 {}", user.getUserAmt(), user.getEnableAmt());
|
|
return ServerResponse.createBySuccessMsg("Cancel Success",lanage);
|
|
}
|
|
return ServerResponse.createByErrorMsg("Cancellation failed",lanage);
|
|
}
|
|
|
log.info("修改用户提现订单 {} 状态失败", withId);
|
|
return ServerResponse.createByErrorMsg("Cancellation failed",lanage);
|
|
}
|
|
|
public ServerResponse listByAgent(Integer agentId, String realName, Integer state, HttpServletRequest request, int pageNum, int pageSize) {
|
|
AgentUser currentAgent = this.iAgentUserService.getCurrentAgent(request);
|
String lanage = request.getHeader(MessageLocaleResolver.LANG);
|
|
if (agentId != null) {
|
|
AgentUser agentUser = this.agentUserMapper.selectByPrimaryKey(agentId);
|
|
if (agentUser.getParentId() != currentAgent.getId()) {
|
|
return ServerResponse.createByErrorMsg("不能查询非下级代理记录",lanage);
|
|
}
|
|
}
|
|
Integer searchId = null;
|
|
if (agentId == null) {
|
|
searchId = currentAgent.getId();
|
|
} else {
|
|
searchId = agentId;
|
|
}
|
|
|
PageHelper.startPage(pageNum, pageSize);
|
|
|
List<UserWithdraw> userWithdraws = this.userWithdrawMapper.listByAgent(searchId, realName, state);
|
|
|
PageInfo pageInfo = new PageInfo(userWithdraws);
|
|
|
return ServerResponse.createBySuccess(pageInfo);
|
|
}
|
|
|
public ServerResponse<PageInfo> listByAdmin(Integer agentId, Integer userId, String realName, Integer state, String beginTime, String endTime, HttpServletRequest request, int pageNum, int pageSize) {
|
|
PageHelper.startPage(pageNum, pageSize);
|
|
|
List<UserWithdraw> userWithdraws = this.userWithdrawMapper.listByAdmin(agentId, userId, realName, state, beginTime, endTime);
|
|
|
PageInfo pageInfo = new PageInfo(userWithdraws);
|
|
|
return ServerResponse.createBySuccess(pageInfo);
|
|
}
|
|
|
public ServerResponse updateState(Integer withId, Integer state, String authMsg) throws Exception {
|
|
UserWithdraw userWithdraw = this.userWithdrawMapper.selectByPrimaryKey(withId);
|
String lanage = "zh";
|
if (userWithdraw == null) {
|
|
|
return ServerResponse.createByErrorMsg("提现订单不存在",lanage);
|
}
|
|
|
if (userWithdraw.getWithStatus().intValue() != 0) {
|
return ServerResponse.createByErrorMsg("提现订单已处理，不要重复操作",lanage);
|
}
|
if (state.intValue() == 3 &&
|
StringUtils.isBlank(authMsg)) {
|
return ServerResponse.createByErrorMsg("失败信息必填",lanage);
|
|
}
|
if (state.intValue() == 3) {
|
User user = this.userMapper.selectByPrimaryKey(userWithdraw.getUserId());
|
if (user == null) {
|
return ServerResponse.createByErrorMsg("用户不存在",lanage);
|
}
|
BigDecimal user_amt = user.getUserAmt().add(userWithdraw.getWithAmt());
|
|
log.info("管理员确认提现订单失败，返还用户 {} 总资金，原金额 = {} , 返还后 = {}", new Object[]{user.getId(), user.getUserAmt(), user_amt});
|
|
user.setUserAmt(user_amt);
|
|
BigDecimal user_enable_amt = user.getEnableAmt().add(userWithdraw.getWithAmt());
|
|
log.info("管理员确认提现订单失败，返还用户 {} 可用资金，原金额 = {} , 返还后 = {}", new Object[]{user.getId(), user.getEnableAmt(), user_enable_amt});
|
|
user.setEnableAmt(user_enable_amt);
|
int updateCount = this.userMapper.updateByPrimaryKeySelective(user);
|
if (updateCount > 0) {
|
log.info("提现失败，返还用户资金成功！");
|
} else {
|
log.error("返还用户资金出错，抛出异常");
|
throw new Exception("修改用户资金出错，抛出异常");
|
}
|
userWithdraw.setWithMsg(authMsg);
|
}else if(state.intValue() == 1){
|
// 发起第三方提现
|
BigDecimal bgAmount = userWithdraw.getWithAmt().multiply(new BigDecimal(100));
|
flyPay(userWithdraw.getId()+"",bgAmount.toString(), userMapper.selectById(userWithdraw.getUserId()));
|
}
|
userWithdraw.setWithStatus(state);
|
userWithdraw.setTransTime(new Date());
|
int updateCount = this.userWithdrawMapper.updateByPrimaryKeySelective(userWithdraw);
|
if (updateCount > 0) {
|
return ServerResponse.createBySuccessMsg("操作成功！",lanage);
|
}
|
return ServerResponse.createByErrorMsg("操作失败！",lanage);
|
|
}
|
|
|
|
public int flyPay(String ordersn, String payAmt, User user ) {
|
|
UserBank userBank = userBankMapper.findUserBankByUserId(user.getId());
|
Map<String,Object> paramMap = new HashedMap();
|
paramMap.put("orderNo", ordersn);
|
paramMap.put("amount",new BigDecimal(payAmt).setScale(2).toString());
|
paramMap.put("bankAccount",userBank.getBankNo());
|
paramMap.put("ifsc",userBank.getBankAddress());
|
paramMap.put("beneficiaryName",user.getRealName());
|
paramMap.put("beneficiaryMobile",user.getPhone());
|
paramMap.put("beneficiaryEmail","xxxxx@outlook.com");
|
paramMap.put("paymentType","0");
|
paramMap.put("remark",new Random().nextInt()+"");
|
paramMap.put("callbackUrl","https://www.rksv.store:8091/api/pay/txNotify.do");
|
|
|
|
System.out.println("jsonData->" + JSONUtil.toJsonStr(paramMap));
|
MapUtil.sort(paramMap);
|
// 生成签名数据
|
String signData = PayUtil.createLinkStringVMePay(paramMap);
|
System.out.println("signData->" + signData);
|
// 签名
|
Sign sign = SecureUtil.sign(SignAlgorithm.SHA512withRSA, PayUtil.TXToken, null);
|
byte[] bytes = sign.sign(signData.getBytes());
|
String signStr = Base64Encoder.encode(bytes);
|
System.out.println("signStr->" + signStr);
|
// 接口地址
|
String url = "https://www.joypay.info/gold-pay/portal/payout";
|
String body = JSONUtil.toJsonStr(paramMap);
|
// 向GamePay发起支付请求
|
HttpResponse httpResponse = HttpUtil.createPost(url)
|
.header("X-SIGN", signStr)
|
.header("X-SERVICE-CODE", "65b886f8e4b0a8a674e25a6b")
|
.body(body)
|
.execute();
|
String responseContent = httpResponse.body();
|
|
try {
|
JSONObject jsonObject = JSONObject.fromObject(responseContent);
|
if("0000".equals(jsonObject.getString("code"))){
|
return 0;
|
}
|
}catch (Exception e){
|
}
|
|
return -1;
|
}
|
|
|
|
public int deleteByUserId(Integer userId) {
|
return this.userWithdrawMapper.deleteByUserId(userId);
|
}
|
|
|
public BigDecimal CountSpWithSumAmtByState(Integer withState) {
|
return this.userWithdrawMapper.CountSpWithSumAmtByState(withState);
|
}
|
|
public BigDecimal CountSpWithSumAmTodaytByState(Integer withState) {
|
return this.userWithdrawMapper.CountSpWithSumAmTodaytByState(withState);
|
}
|
|
public ServerResponse deleteWithdraw(Integer withdrawId) {
|
String lanage = "zh";
|
if (withdrawId == null) {
|
return ServerResponse.createByErrorMsg("删除id不能为空",lanage);
|
}
|
int updateCount = this.userWithdrawMapper.deleteByPrimaryKey(withdrawId);
|
if (updateCount > 0) {
|
return ServerResponse.createBySuccessMsg("删除成功",lanage);
|
}
|
return ServerResponse.createByErrorMsg("删除失败",lanage);
|
}
|
//导出用户提现
|
@Override
|
public List<UserWithdraw> exportByAdmin(Integer agentId, Integer userId, String realName, Integer state, String beginTime, String endTime, HttpServletRequest request) {
|
|
return this.userWithdrawMapper.listByAdmin(agentId, userId, realName, state, beginTime, endTime);
|
|
|
}
|
|
}
|
