|
|
@@ -1,6 +1,7 @@
|
|
|
package com.cyksj.service.pay.impl;
|
|
|
|
|
|
import cn.hutool.core.date.DateTime;
|
|
|
+import cn.hutool.core.util.ObjectUtil;
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
import cn.hutool.json.JSONObject;
|
|
|
import com.alipay.api.AlipayClient;
|
|
|
@@ -9,22 +10,37 @@ import com.alipay.api.AlipayResponse;
|
|
|
import com.alipay.api.domain.AlipayFundTransUniTransferModel;
|
|
|
import com.alipay.api.domain.Participant;
|
|
|
import com.alipay.api.request.AlipayFundTransUniTransferRequest;
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.cyksj.common.EnvCommonService;
|
|
|
+import com.cyksj.common.constant.Constant;
|
|
|
import com.cyksj.common.constant.TransferConstant;
|
|
|
+import com.cyksj.common.exception.BusinessRuntimeException;
|
|
|
import com.cyksj.common.snowflake.Sequence;
|
|
|
import com.cyksj.common.util.Jsons;
|
|
|
+import com.cyksj.common.util.SmsUtil;
|
|
|
import com.cyksj.config.zfb.AliPayClientFactory;
|
|
|
import com.cyksj.config.zfb.ZfbProductCode;
|
|
|
+import com.cyksj.dto.Result;
|
|
|
+import com.cyksj.enums.GatewayResponse;
|
|
|
import com.cyksj.mapper.TransferAccountsRecordMapper;
|
|
|
-import com.cyksj.model.entity.ShopConfig;
|
|
|
-import com.cyksj.model.entity.TransferAccountsRecord;
|
|
|
+import com.cyksj.mapper.UserMapper;
|
|
|
+import com.cyksj.mapper.manage.distribute.DistributeMoneyApplyMapper;
|
|
|
+import com.cyksj.mapper.manage.distribute.DistributePointsExchangeMoneyMapper;
|
|
|
+import com.cyksj.mapper.manage.distribute.UserDistributeMapper;
|
|
|
+import com.cyksj.mapper.shop.YhShopDistributeMoneyApplyMapper;
|
|
|
+import com.cyksj.mapper.shop.YhShopMapper;
|
|
|
+import com.cyksj.model.entity.*;
|
|
|
+import com.cyksj.model.request.ApplyMoneyReq;
|
|
|
import com.cyksj.model.request.TransferAccountsReq;
|
|
|
+import com.cyksj.model.request.YhShopApplyMoneyReq;
|
|
|
import com.cyksj.service.pay.TransferFuncService;
|
|
|
+import com.cyksj.service.user.UserBenefitsService;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
import java.math.BigDecimal;
|
|
|
+import java.math.RoundingMode;
|
|
|
import java.util.Optional;
|
|
|
|
|
|
/*
|
|
|
@@ -41,8 +57,223 @@ public class TransferFuncServiceImpl implements TransferFuncService {
|
|
|
|
|
|
private final TransferAccountsRecordMapper transferAccountsRecordMapper;
|
|
|
|
|
|
+ private final YhShopMapper yhShopMapper;
|
|
|
+
|
|
|
+ private final UserMapper userMapper;
|
|
|
+
|
|
|
+ private final UserBenefitsService userBenefitsService;
|
|
|
+
|
|
|
+ private final YhShopDistributeMoneyApplyMapper yhShopDistributeMoneyApplyMapper;
|
|
|
+
|
|
|
private final EnvCommonService envCommonService;
|
|
|
|
|
|
+ private final UserDistributeMapper userDistributeMapper;
|
|
|
+
|
|
|
+ private final DistributePointsExchangeMoneyMapper distributePointsExchangeMoneyMapper;
|
|
|
+
|
|
|
+ private final DistributeMoneyApplyMapper distributeMoneyApplyMapper;
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Result distributeApply(ApplyMoneyReq applyMoneyReq) throws Exception {
|
|
|
+ Long userId = applyMoneyReq.getUserId();
|
|
|
+ User user = userMapper.selectById(userId);
|
|
|
+ if (user == null) {
|
|
|
+ throw BusinessRuntimeException.getInstance("请先授权登录");
|
|
|
+ }
|
|
|
+ Boolean isTakeAll = applyMoneyReq.getIsTakeAll();
|
|
|
+ DistributeMoneyApply.Type type = applyMoneyReq.getType();
|
|
|
+ if (type == null) type = DistributeMoneyApply.Type.zfb;
|
|
|
+ if (type == DistributeMoneyApply.Type.zfb) {
|
|
|
+ if (ObjectUtil.hasEmpty(applyMoneyReq.getAccount(), applyMoneyReq.getRealName())) {
|
|
|
+ throw BusinessRuntimeException.getInstance("必填项不能为空");
|
|
|
+ }
|
|
|
+ if (applyMoneyReq.getAccount().length() > 255 || applyMoneyReq.getRealName().length() > 32) {
|
|
|
+ throw BusinessRuntimeException.getInstance("请输入正确的账户信息");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (type == DistributeMoneyApply.Type.usdt) {
|
|
|
+ if (StrUtil.isEmpty(applyMoneyReq.getWalletAddr())) {
|
|
|
+ throw BusinessRuntimeException.getInstance("USDT提现钱包地址不能为空");
|
|
|
+ }
|
|
|
+ if (applyMoneyReq.getWalletAddr().length() > 1000) {
|
|
|
+ throw BusinessRuntimeException.getInstance("请输入正确的钱包地址");
|
|
|
+ }
|
|
|
+ if (StrUtil.isNotBlank(applyMoneyReq.getRemark()) && applyMoneyReq.getRemark().length() > 512) {
|
|
|
+ throw BusinessRuntimeException.getInstance("备注过多");
|
|
|
+ }
|
|
|
+ isTakeAll = true;
|
|
|
+
|
|
|
+ }
|
|
|
+ DistributeMoneyApply distributeMoneyApply = null;
|
|
|
+ if (type == DistributeMoneyApply.Type.pwdRed) {
|
|
|
+ distributeMoneyApply = userDistributeMapper.selectRelationBusiness(userId);
|
|
|
+ isTakeAll = true;
|
|
|
+ }
|
|
|
+ BigDecimal userPoints = user.getPoints();
|
|
|
+ DistributePointsExchangeMoney distributePointsExchangeMoney = distributePointsExchangeMoneyMapper.selectOne(Wrappers.lambdaQuery(DistributePointsExchangeMoney.class).orderByDesc(DistributePointsExchangeMoney::getPoints).last("limit 1"));
|
|
|
+ BigDecimal minPoints = BigDecimal.valueOf(distributePointsExchangeMoney.getMinPoints());
|
|
|
+ BigDecimal ratePoints = BigDecimal.valueOf(distributePointsExchangeMoney.getPoints());
|
|
|
+ BigDecimal minMoney = distributePointsExchangeMoney.getMoney();
|
|
|
+ if (userPoints.compareTo(minPoints) < 0) {
|
|
|
+ throw BusinessRuntimeException.getInstance("您当前积分未达到积分门槛,无法提现");
|
|
|
+ }
|
|
|
+// //今日是否已提现
|
|
|
+// DistributeMoneyApply apply = distributeMoneyApplyMapper.selectOne(Wrappers.lambdaQuery(DistributeMoneyApply.class).eq(DistributeMoneyApply::getUserId, userId).between(DistributeMoneyApply::getCreatedTime, DateUtil.beginOfDay(DateTime.now()), DateUtil.endOfDay(DateTime.now())).last("limit 1"));
|
|
|
+// if (apply != null) {
|
|
|
+// throw BusinessRuntimeException.getInstance("今日已提现,请明日再进行操作");
|
|
|
+// }
|
|
|
+ BigDecimal num = userPoints.divide(ratePoints, 0, RoundingMode.DOWN);
|
|
|
+ BigDecimal needApplyMoney = num.multiply(minMoney);
|
|
|
+ BigDecimal needSubPoints = num.multiply(ratePoints);
|
|
|
+ BigDecimal fourHundred = BigDecimal.valueOf(4 * 100 * 100);
|
|
|
+ if (isTakeAll == null || !isTakeAll) {
|
|
|
+ if (needApplyMoney.compareTo(fourHundred) > 0) {
|
|
|
+ needApplyMoney = fourHundred;
|
|
|
+ needSubPoints = fourHundred.divide(minMoney).multiply(ratePoints);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ Integer update = userMapper.subPoints(user.getId(), needSubPoints);
|
|
|
+ if (update == 1) {
|
|
|
+ distributeMoneyApply = Optional.ofNullable(distributeMoneyApply).orElse(new DistributeMoneyApply());
|
|
|
+ distributeMoneyApply.setUserId(userId);
|
|
|
+ distributeMoneyApply.setPoints(needSubPoints);
|
|
|
+ distributeMoneyApply.setMoney(needApplyMoney);
|
|
|
+ distributeMoneyApply.setAccount(applyMoneyReq.getAccount());
|
|
|
+ distributeMoneyApply.setRealName(applyMoneyReq.getRealName());
|
|
|
+ distributeMoneyApply.setWalletAddr(applyMoneyReq.getWalletAddr());
|
|
|
+ distributeMoneyApply.setRemark(applyMoneyReq.getRemark());
|
|
|
+ distributeMoneyApply.setType(applyMoneyReq.getType());
|
|
|
+ if (isTakeAll != null && isTakeAll) {
|
|
|
+ distributeMoneyApply.setVerifyStatus(DistributeMoneyApply.Status.verifying);
|
|
|
+ } else {
|
|
|
+ TransferAccountsReq req = new TransferAccountsReq();
|
|
|
+ req.setMoney(needApplyMoney);
|
|
|
+ req.setAccount(applyMoneyReq.getAccount());
|
|
|
+ req.setName(applyMoneyReq.getRealName());
|
|
|
+ req.setPoints(needSubPoints);
|
|
|
+ req.setUserId(userId);
|
|
|
+ req.setChannelType(1);
|
|
|
+ req.setRemark("分销提现");
|
|
|
+ AlipayResponse alipayResponse = transferAccounts(req);
|
|
|
+ if (alipayResponse.isSuccess()) {
|
|
|
+ distributeMoneyApply.setVerifyStatus(DistributeMoneyApply.Status.success);
|
|
|
+ } else {
|
|
|
+ distributeMoneyApply.setVerifyStatus(DistributeMoneyApply.Status.fail);
|
|
|
+ distributeMoneyApply.setReason(alipayResponse.getSubMsg());
|
|
|
+ userBenefitsService.addDistributePoints(userId, distributeMoneyApply.getPoints());
|
|
|
+ if (StrUtil.equals(alipayResponse.getSubCode(), "SECURITY_CHECK_FAILED")) {
|
|
|
+ return GatewayResponse.FAIL.newBuilder().setMsg("当前支付宝提现人数较多，请稍后再试").toResult();
|
|
|
+ }
|
|
|
+ return GatewayResponse.FAIL.newBuilder().setMsg(alipayResponse.getSubMsg()).toResult();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ try {
|
|
|
+ distributeMoneyApplyMapper.insert(distributeMoneyApply);
|
|
|
+ //大额提现 超过400
|
|
|
+ if (envCommonService.isPrdEnv() && distributeMoneyApply.getVerifyStatus() == DistributeMoneyApply.Status.verifying && distributeMoneyApply.getMoney().compareTo(fourHundred) > 0) {
|
|
|
+ SmsUtil.sendLuoKey2Msg(Constant.ZK_MOBILE, "推广有大额提现申请【银河录像局】");
|
|
|
+ }
|
|
|
+ } catch (Exception e) {
|
|
|
+ userBenefitsService.addDistributePoints(userId, distributeMoneyApply.getPoints());
|
|
|
+ return GatewayResponse.FAIL.newBuilder().setMsg("网络错误,请重试").toResult();
|
|
|
+ }
|
|
|
+ return GatewayResponse.SUCCESS.newBuilder().toResult(distributeMoneyApply);
|
|
|
+ }
|
|
|
+ throw BusinessRuntimeException.getInstance("系统异常,请重新提交提现申请");
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Result yhShopDistributeApply(YhShopApplyMoneyReq applyMoneyReq) throws Exception {
|
|
|
+ Long userId = applyMoneyReq.getUserId();
|
|
|
+ User user = userMapper.selectById(userId);
|
|
|
+ if (user == null) {
|
|
|
+ throw BusinessRuntimeException.getInstance("请先授权登录");
|
|
|
+ }
|
|
|
+ Boolean isTakeAll = applyMoneyReq.getIsTakeAll();
|
|
|
+ YhShopDistributeMoneyApply.Type type = applyMoneyReq.getType();
|
|
|
+ if (type == null) type = YhShopDistributeMoneyApply.Type.zfb;
|
|
|
+ if (type == YhShopDistributeMoneyApply.Type.zfb) {
|
|
|
+ if (ObjectUtil.hasEmpty(applyMoneyReq.getAccount(), applyMoneyReq.getRealName())) {
|
|
|
+ throw BusinessRuntimeException.getInstance("必填项不能为空");
|
|
|
+ }
|
|
|
+ if (applyMoneyReq.getAccount().length() > 255 || applyMoneyReq.getRealName().length() > 32) {
|
|
|
+ throw BusinessRuntimeException.getInstance("请输入正确的账户信息");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (type == YhShopDistributeMoneyApply.Type.usdt) {
|
|
|
+ if (StrUtil.isEmpty(applyMoneyReq.getWalletAddr())) {
|
|
|
+ throw BusinessRuntimeException.getInstance("USDT提现钱包地址不能为空");
|
|
|
+ }
|
|
|
+ if (applyMoneyReq.getWalletAddr().length() > 1000) {
|
|
|
+ throw BusinessRuntimeException.getInstance("请输入正确的钱包地址");
|
|
|
+ }
|
|
|
+ if (StrUtil.isNotBlank(applyMoneyReq.getRemark()) && applyMoneyReq.getRemark().length() > 512) {
|
|
|
+ throw BusinessRuntimeException.getInstance("备注过多");
|
|
|
+ }
|
|
|
+ isTakeAll = true;
|
|
|
+
|
|
|
+ }
|
|
|
+ YhShopDistributeMoneyApply distributeMoneyApply = null;
|
|
|
+ if (type == YhShopDistributeMoneyApply.Type.pwdRed) {
|
|
|
+ distributeMoneyApply = yhShopMapper.selectRelationBusiness(userId);
|
|
|
+ isTakeAll = true;
|
|
|
+ }
|
|
|
+
|
|
|
+ BigDecimal needApplyMoney = user.getYhsMoney();
|
|
|
+ BigDecimal fourHundred = BigDecimal.valueOf(4 * 10000);
|
|
|
+ if (isTakeAll == null || !isTakeAll) {
|
|
|
+ if (needApplyMoney.compareTo(fourHundred) > 0) {
|
|
|
+ needApplyMoney = fourHundred;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ Integer update = userMapper.subYhsMoney(user.getId(), needApplyMoney);
|
|
|
+ if (update == 1) {
|
|
|
+ distributeMoneyApply = Optional.ofNullable(distributeMoneyApply).orElse(new YhShopDistributeMoneyApply());
|
|
|
+ distributeMoneyApply.setUserId(userId);
|
|
|
+ distributeMoneyApply.setMoney(needApplyMoney);
|
|
|
+ distributeMoneyApply.setAccount(applyMoneyReq.getAccount());
|
|
|
+ distributeMoneyApply.setRealName(applyMoneyReq.getRealName());
|
|
|
+ distributeMoneyApply.setWalletAddr(applyMoneyReq.getWalletAddr());
|
|
|
+ distributeMoneyApply.setRemark(applyMoneyReq.getRemark());
|
|
|
+ distributeMoneyApply.setType(applyMoneyReq.getType());
|
|
|
+ if (isTakeAll != null && isTakeAll) {
|
|
|
+ distributeMoneyApply.setVerifyStatus(YhShopDistributeMoneyApply.Status.verifying);
|
|
|
+ } else {
|
|
|
+ TransferAccountsReq req = new TransferAccountsReq();
|
|
|
+ req.setMoney(needApplyMoney);
|
|
|
+ req.setAccount(applyMoneyReq.getAccount());
|
|
|
+ req.setName(applyMoneyReq.getRealName());
|
|
|
+ req.setChannelType(2);
|
|
|
+ req.setUserId(userId);
|
|
|
+ req.setRemark("小店提现");
|
|
|
+ AlipayResponse alipayResponse = transferAccounts(req);
|
|
|
+ if (alipayResponse.isSuccess()) {
|
|
|
+ distributeMoneyApply.setVerifyStatus(YhShopDistributeMoneyApply.Status.success);
|
|
|
+ } else {
|
|
|
+ distributeMoneyApply.setVerifyStatus(YhShopDistributeMoneyApply.Status.fail);
|
|
|
+ distributeMoneyApply.setReason(alipayResponse.getSubMsg());
|
|
|
+ userBenefitsService.addYhsMoney(userId, distributeMoneyApply.getMoney());
|
|
|
+ if (StrUtil.equals(alipayResponse.getSubCode(), "SECURITY_CHECK_FAILED")) {
|
|
|
+ return GatewayResponse.FAIL.newBuilder().setMsg("当前支付宝提现人数较多，请稍后再试").toResult();
|
|
|
+ }
|
|
|
+ return GatewayResponse.FAIL.newBuilder().setMsg(alipayResponse.getSubMsg()).toResult();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ try {
|
|
|
+ yhShopDistributeMoneyApplyMapper.insert(distributeMoneyApply);
|
|
|
+ //大额提现 超过400
|
|
|
+ if (envCommonService.isPrdEnv() && distributeMoneyApply.getVerifyStatus() == YhShopDistributeMoneyApply.Status.verifying && distributeMoneyApply.getMoney().compareTo(fourHundred) > 0) {
|
|
|
+ SmsUtil.sendLuoKey2Msg(Constant.ZK_MOBILE, "小店店铺有大额提现申请【银河录像局】");
|
|
|
+ }
|
|
|
+ } catch (Exception e) {
|
|
|
+ userBenefitsService.addYhsMoney(userId, distributeMoneyApply.getMoney());
|
|
|
+ return GatewayResponse.FAIL.newBuilder().setMsg("网络错误,请重试").toResult();
|
|
|
+ }
|
|
|
+ return GatewayResponse.SUCCESS.newBuilder().toResult(distributeMoneyApply);
|
|
|
+ }
|
|
|
+ throw BusinessRuntimeException.getInstance("系统异常,请重新提交提现申请");
|
|
|
+ }
|
|
|
+
|
|
|
@Override
|
|
|
public AlipayResponse transferAccounts(TransferAccountsReq transferAccountsReq) throws Exception {
|
|
|
Long userId = transferAccountsReq.getUserId();
|
zoujiajian