package com.yami.trading.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.google.gson.Gson; import com.yami.trading.bean.data.domain.Realtime; import com.yami.trading.bean.model.*; import com.yami.trading.bean.syspara.domain.Syspara; import com.yami.trading.common.constants.Constants; import com.yami.trading.common.constants.TipConstants; import com.yami.trading.common.exception.YamiShopBindException; import com.yami.trading.common.util.Arith; import com.yami.trading.common.util.DateUtil; import com.yami.trading.common.util.RandomUtil; import com.yami.trading.dao.user.RechargeBlockchainOrderMapper; import com.yami.trading.service.*; import com.yami.trading.service.c2c.C2cOrderService; import com.yami.trading.service.data.DataService; import com.yami.trading.service.syspara.SysparaService; import com.yami.trading.service.system.LogService; import com.yami.trading.service.system.TipService; import com.yami.trading.service.user.UserDataService; import com.yami.trading.service.user.UserService; import com.yami.trading.service.user.WalletLogService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.security.crypto.password.PasswordEncoder; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.io.Serializable; import java.math.BigDecimal; import java.util.ArrayList; import java.util.Date; import java.util.List; @Service @Slf4j public class RechargeBlockchainOrderServiceImpl extends ServiceImpl implements RechargeBlockchainOrderService { @Autowired PasswordEncoder passwordEncoder; @Autowired WalletService walletService; @Autowired UserService userService; @Autowired SysparaService sysparaService; @Autowired CapitaltWalletService capitaltWalletService; @Autowired WalletLogService walletLogService; @Autowired ChannelBlockchainService channelBlockchainService; @Autowired TipService tipService; @Autowired LogService logService; @Autowired MoneyLogService moneyLogService; @Autowired UserDataService userDataService; @Autowired RechargeBonusService rechargeBonusService; @Autowired DataService dataService; @Override public Page pageRecord(Page page, String rolename, String orderNo, String userName, Date startTime, Date endTime,String status) { return baseMapper.listRecord(page, rolename, orderNo, userName, startTime, endTime,status); } @Override @Transactional public void manualReceipt(String id, BigDecimal amount,String operator_username) { // Date now = new Date(); RechargeBlockchainOrder recharge = getById(id); if (recharge == null) { throw new YamiShopBindException("参数错误!"); } User party = userService.getById(recharge.getPartyId()); if (party == null) { throw new YamiShopBindException("用户不存在!"); } if (recharge.getSucceeded() == 1) { throw new YamiShopBindException("已操作过了!"); } recharge.setReviewTime(new Date()); recharge.setSucceeded(1); WalletLog walletLog = walletLogService.find(Constants.MONEYLOG_CATEGORY_RECHARGE, recharge.getOrderNo()); if (amount.doubleValue() != recharge.getVolume()) { Log log = new Log(); log.setCategory(Constants.LOG_CATEGORY_OPERATION); log.setExtra(recharge.getOrderNo()); log.setOperator(operator_username); log.setUsername(party.getUserName()); log.setUserId(recharge.getPartyId()); log.setCreateTime(new Date()); log.setLog("管理员修改充值数量，原充值数量[" + recharge.getVolume() + "],修改后充值数量[" + amount.doubleValue() + "]。订单号[" + recharge.getOrderNo()+ "]。"); logService.save(log); walletLog.setAmount(amount.doubleValue()); recharge.setVolume(amount.doubleValue()); } /** * 如果是usdt则加入wallet，否则寻找walletExtend里相同币种 */ Syspara user_recom_bonus_open = sysparaService.find("user_recom_bonus_open"); if ("usdt".equals(recharge.getSymbol())) { double amount1 = recharge.getVolume(); Wallet wallet = new Wallet(); wallet = walletService.saveWalletByPartyId(recharge.getPartyId()); // double amount_before = wallet.getMoney().doubleValue(); // walletService.update(wallet.getUserId(), amount1); // CapitaltWallet capitaltWallet = capitaltWalletService.getOne(new LambdaQueryWrapper<>(CapitaltWallet.class) // .eq(CapitaltWallet::getUserId, recharge.getPartyId()).last(" limit 1 ")); // double amount_before = capitaltWallet.getMoney().doubleValue(); // capitaltWalletService.update(capitaltWallet,amount1); // 保存资金日志 MoneyLog moneyLog = new MoneyLog(); moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN); moneyLog.setAmountBefore(new BigDecimal(amount_before)); moneyLog.setAmount(new BigDecimal(amount1)); moneyLog.setAmountAfter(BigDecimal.valueOf(Arith.add(amount_before, amount1))); moneyLog.setLog("充值订单[" + recharge.getOrderNo() + "]"); moneyLog.setUserId(recharge.getPartyId()); moneyLog.setWalletType(Constants.WALLET); moneyLog.setContentType(Constants.MONEYLOG_CONTENT_RECHARGE); moneyLog.setCreateTime(new Date()); moneyLogService.save(moneyLog); walletLog.setStatus(recharge.getSucceeded()); walletLogService.updateById(walletLog); updateById(recharge); /** * 给他的代理添加充值记录 */ userDataService.saveRechargeHandle(recharge.getPartyId(), recharge.getVolume(), recharge.getSymbol()); /** * 若已开启充值奖励 ，则充值到账后给他的代理用户添加奖金 */ if ("true".equals(user_recom_bonus_open.getSvalue())) { List orders =findByPartyIdAndToday(recharge.getPartyId()); rechargeBonusService.saveBounsHandle(recharge, 1,orders); } // 充值到账后给他增加提现流水限制金额 充值到账后，当前流水大于提现限制流水时是否重置提现限制流水并将Party表里的当前流水设置清零， // 1不重置，2重置 String recharge_sucess_reset_withdraw = this.sysparaService.find("recharge_sucess_reset_withdraw").getSvalue(); if ("1".equals(recharge_sucess_reset_withdraw)) { if (party.getWithdrawLimitAmount()==null){ party.setWithdrawLimitAmount(new BigDecimal(0)); } if (party.getWithdrawLimitNowAmount()==null){ party.setWithdrawLimitNowAmount(new BigDecimal(0)); } party.setWithdrawLimitAmount(new BigDecimal(Arith.add(party.getWithdrawLimitAmount().doubleValue(), amount.doubleValue()))); if (party.getWithdrawLimitNowAmount().doubleValue() > party.getWithdrawLimitAmount().doubleValue()) { party.setWithdrawLimitNowAmount(new BigDecimal(0)); } } if ("2".equals(recharge_sucess_reset_withdraw)) { double withdraw_limit_turnover_percent = Double .valueOf(sysparaService.find("withdraw_limit_turnover_percent").getSvalue()); double party_withdraw = Arith.mul(party.getWithdrawLimitAmount().doubleValue(), withdraw_limit_turnover_percent); if (party.getWithdrawLimitNowAmount().doubleValue() >= party_withdraw) { party.setWithdrawLimitAmount(amount); party.setWithdrawLimitNowAmount(new BigDecimal(0)); } else { party.setWithdrawLimitAmount(new BigDecimal(Arith.add(party.getWithdrawLimitAmount().doubleValue(), amount.doubleValue()))); } } userService.updateById(party); } else { List realtime_list =this.dataService.realtime(recharge.getSymbol()); log.error("手动到账realtime_list::"+realtime_list); Realtime realtime = null; if (realtime_list.size() > 0) { realtime = realtime_list.get(0); } else { throw new YamiShopBindException("系统错误，请稍后重试"); } // 对应usdt价格 double transfer_usdt = realtime.getClose().doubleValue(); WalletExtend walletExtend = new WalletExtend(); walletExtend = walletService.saveExtendByPara(recharge.getPartyId(), recharge.getSymbol()); double volume = recharge.getVolume(); double amount_before = walletExtend.getAmount(); // walletExtend = walletService.saveWalletExtendByParaAndUpdate(String.valueOf(recharge.getPartyId()), recharge.getSymbol(), volume); walletService.updateExtend(walletExtend.getPartyId().toString(), walletExtend.getWallettype(), volume); updateById(recharge); // 币种usdt价格= 币种价格×充值数量 double usdt_amount = Arith.mul(volume, transfer_usdt); // 保存资金日志 MoneyLog moneyLog = new MoneyLog(); moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN); moneyLog.setAmountBefore(new BigDecimal(amount_before)); moneyLog.setAmount(new BigDecimal(volume)); moneyLog.setAmountAfter(new BigDecimal(Arith.add(amount_before, volume))); moneyLog.setLog("充值订单[" + recharge.getOrderNo() + "]"); moneyLog.setUserId(recharge.getPartyId()); moneyLog.setWalletType(recharge.getSymbol()); moneyLog.setContentType(Constants.MONEYLOG_CONTENT_RECHARGE); moneyLog.setCreateTime(new Date()); moneyLogService.save(moneyLog); walletLog.setStatus(recharge.getSucceeded()); walletLogService.updateById(walletLog); /** * 给他的代理添加充值记录 */ userDataService.saveRechargeHandle(recharge.getPartyId(), recharge.getVolume(), recharge.getSymbol()); /** * 买币-币冲充值其他非usdt币时使用 */ // userDataService.saveBuy(recharge.getPartyId(), recharge.getSymbol(), recharge.getVolume()); /** * 充值到账后给他的代理用户添加奖金 */ if ("true".equals(user_recom_bonus_open.getSvalue())) { List orders =findByPartyIdAndToday(recharge.getPartyId()); rechargeBonusService.saveBounsHandle(recharge, transfer_usdt,orders); } /** * 充值到账后给他增加提现流水限制金额 */ /** * 充值到账后给他增加提现流水限制金额 充值到账后，当前流水大于提现限制流水时是否重置提现限制流水并将Party表里的当前流水设置清零，1不重置，2重置 */ String recharge_sucess_reset_withdraw = this.sysparaService.find("recharge_sucess_reset_withdraw") .getSvalue(); if ("1".equals(recharge_sucess_reset_withdraw)) { party.setWithdrawLimitAmount(new BigDecimal(Arith.add(party.getWithdrawLimitAmount().doubleValue(), usdt_amount))); if (party.getWithdrawLimitNowAmount().doubleValue() > party.getWithdrawLimitAmount().doubleValue()) { party.setWithdrawLimitNowAmount(new BigDecimal(0)); } } if ("2".equals(recharge_sucess_reset_withdraw)) { double withdraw_limit_turnover_percent = Double .valueOf(sysparaService.find("withdraw_limit_turnover_percent").getSvalue()); double party_withdraw = Arith.mul(party.getWithdrawLimitAmount().doubleValue(), withdraw_limit_turnover_percent); if (party.getWithdrawLimitNowAmount().doubleValue() >= party_withdraw) { party.setWithdrawLimitAmount(new BigDecimal(usdt_amount)); party.setWithdrawLimitNowAmount(new BigDecimal(0)); } else { party.setWithdrawLimitAmount(new BigDecimal(Arith.add(party.getWithdrawLimitAmount().doubleValue(), usdt_amount))); } } userService.updateById(party); } Log log = new Log(); log.setCategory(Constants.LOG_CATEGORY_OPERATION); log.setExtra(recharge.getOrderNo()); log.setOperator(operator_username); log.setUsername(party.getUserName()); log.setUserId(recharge.getPartyId()); log.setCreateTime(new Date()); log.setLog("手动到账一笔充值订单。订单号[" + recharge.getOrderNo() + "]。"); logService.save(log); tipService.deleteTip(recharge.getUuid().toString()); } @Override public long waitCount() { return count(Wrappers.query().lambda().eq(RechargeBlockchainOrder::getSucceeded,0)); } @Override public List findByPartyIdAndSucceeded(Serializable partyId, int succeeded) { List list =list(Wrappers.query().lambda().eq(RechargeBlockchainOrder::getPartyId,partyId).eq(RechargeBlockchainOrder::getSucceeded,succeeded)); if (list.size() > 0) { return list; } return null; } @Override public RechargeBlockchainOrder findByOrderNo(String order_no) { List list= list(Wrappers.query().lambda().eq(RechargeBlockchainOrder::getOrderNo,order_no)); if (list.size() > 0) { return list.get(0); } return null; } @Override public List findByPartyIdAndToday(String partyId) { Date now =new Date(); List list= list(Wrappers.query().lambda().eq(RechargeBlockchainOrder::getPartyId,partyId) .between(RechargeBlockchainOrder::getCreated,DateUtil.minDate(now),DateUtil.maxDate(now))); if (list.size() > 0) { return list; } return null; } @Override @Transactional public void saveOrder(RechargeBlockchainOrder recharge) { // 充值申请中的订单是否只能唯一：1唯一，2不限制 double recharge_only_one = Double.valueOf(sysparaService.find("recharge_only_one").getSvalue()); // 用户未完成USDT订单 List orders = this.findByPartyIdAndSucceeded(recharge.getPartyId(), 0); if (null != orders && 1 == recharge_only_one) { throw new YamiShopBindException("提交失败，当前有未处理USDT订单"); } // if (!"ETH".equals(recharge.getSymbol().toUpperCase())) { // ChannelBlockchain channel = channelBlockchainService.findByNameAndCoinAndAdd(recharge.getBlockchainName(), // recharge.getSymbol(), recharge.getChannelAddress()); // // if (channel == null || !recharge.getSymbol().toUpperCase().equals(channel.getCoin().toUpperCase())) { // throw new YamiShopBindException("充值链错误"); // } // } double recharge_limit_min = Double.valueOf(sysparaService.find("recharge_limit_min").getSvalue()); double recharge_limit_max = Double.valueOf(sysparaService.find("recharge_limit_max").getSvalue()); if ("usdt".equals(recharge.getSymbol())) { if (recharge.getVolume() < recharge_limit_min) { throw new YamiShopBindException("充值数量不得小于最小限额"); } if (recharge.getVolume() > recharge_limit_max) { throw new YamiShopBindException("充值数量不得大于最大限额"); } } recharge.setCreated(new Date()); log.info(new Gson().toJson(recharge)); if ("".equals(recharge.getOrderNo()) || recharge.getOrderNo() == null) { log.info(recharge.getOrderNo() +"==============================================="+recharge_limit_min); recharge.setOrderNo(DateUtil.getToday("yyMMddHHmmss") + RandomUtil.getRandomNum(8)); } save(recharge); // 保存资金日志 WalletLog walletLog = new WalletLog(); walletLog.setCategory(Constants.MONEYLOG_CATEGORY_RECHARGE); walletLog.setPartyId(recharge.getPartyId()); walletLog.setOrderNo(recharge.getOrderNo()); walletLog.setStatus(recharge.getSucceeded()); walletLog.setAmount(recharge.getVolume()); walletLog.setWallettype(recharge.getSymbol()); walletLog.setCreateTime(new Date()); walletLogService.save(walletLog); tipService.saveTip(recharge.getUuid(), TipConstants.RECHARGE_BLOCKCHAIN); } /** * 驳回申请 * @param id * @param content */ @Override public void refusalApply(String id, String content, String userName) { RechargeBlockchainOrder recharge = getById(id); if (recharge == null) { throw new YamiShopBindException("参数错误!"); } // 通过后不可驳回 if (recharge.getSucceeded() == 2 || recharge.getSucceeded() == 1) { return ; } Date date = new Date(); recharge.setReviewTime(date); recharge.setSucceeded(2); recharge.setDescription(content); updateById(recharge); WalletLog walletLog = walletLogService.find(Constants.MONEYLOG_CATEGORY_RECHARGE, recharge.getOrderNo()); walletLog.setStatus(recharge.getSucceeded()); walletLogService.updateById(walletLog); User sec = userService. getById(recharge.getPartyId()); Log log = new Log(); log.setCategory(Constants.LOG_CATEGORY_OPERATION); log.setExtra(recharge.getOrderNo()); log.setUsername(sec.getUserName()); log.setOperator(userName); log.setUserId(recharge.getPartyId()); log.setLog("管理员驳回一笔充值订单。充值订单号[" + recharge.getOrderNo() + "]，驳回理由[" + recharge.getDescription() + "]。"); logService.save(log); tipService.deleteTip(id); } }