From 23c07b71a269f2540e5c09eb8d2002d9f20a857e Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Thu, 25 Apr 2024 16:07:43 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/service/impl/PayServiceImpl.java | 88 +++++++++++++++-----------------------------
1 files changed, 30 insertions(+), 58 deletions(-)
diff --git a/src/main/java/com/nq/service/impl/PayServiceImpl.java b/src/main/java/com/nq/service/impl/PayServiceImpl.java
index 3016e5c..e610557 100644
--- a/src/main/java/com/nq/service/impl/PayServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/PayServiceImpl.java
@@ -1,16 +1,18 @@
package com.nq.service.impl;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.google.gson.Gson;
import com.nq.common.CmcPayConfig;
import com.nq.common.ServerResponse;
import com.nq.dao.*;
import com.nq.pay.PayUtil;
import com.nq.pojo.*;
-import com.nq.service.IPayService;
-import com.nq.service.IUserService;
+import com.nq.service.*;
import com.nq.utils.*;
+import com.nq.utils.http.HttpClientUtil;
import com.nq.utils.pay.CmcPayOuterRequestUtil;
import com.nq.utils.pay.CmcPayTool;
+import com.nq.utils.timeutil.DateTimeUtil;
import com.nq.vo.pay.GuoPayVO;
import java.io.IOException;
@@ -32,8 +34,9 @@
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
-import static com.nq.utils.DateTimeUtil.STANDARD_FORMAT;
+import static com.nq.utils.timeutil.DateTimeUtil.STANDARD_FORMAT;
@Service("iPayService")
@@ -50,17 +53,22 @@
UserMapper userMapper;
@Resource
+ SitePayMapper sitePayMapper;
+
+
+ @Resource
+ IUserService userService;
+
+ @Resource
+ IUserAssetsServices iUserAssetsServices;
+
+ @Resource
UserWithdrawMapper userWithdrawMapper;
- @Resource
- SiteInfoMapper siteInfoMapper;
- @Resource
- PayChnnelMapper payChnnelMapper;
+ @Autowired
+ ISiteInfoService siteInfoService;
-
- @Resource
- AgentUserMapper agentUserMapper;
@@ -216,54 +224,24 @@
}
- public ServerResponse flyPay(String payType, String payAmt, String currency, HttpServletRequest request) {
- if( Integer.parseInt(payAmt)>=50000 || Integer.parseInt(payAmt)<100){
- return ServerResponse.createByErrorMsg("The maximum top-up amount is 100 and 50000");
- }
- User user = this.iUserService.getCurrentRefreshUser(request);
- if (user == null){
- return ServerResponse.createBySuccessMsg("Please Login");
- }
- if(user.getRealName() == null || user.getRealName().isEmpty()){
- return ServerResponse.createByErrorMsg("Please authenticate with your real name");
- }
-
-
+ @Transactional
+ public ServerResponse flyPay(Integer payType, String payAmt, String currency, HttpServletRequest request) {
+ User user = iUserService.getCurrentUser(request);
+ SitePay sitePay = sitePayMapper.selectById(payType);
UserRecharge userRecharge = new UserRecharge();
userRecharge.setUserId(user.getId());
userRecharge.setNickName(user.getRealName());
userRecharge.setAgentId(user.getAgentId());
String ordersn = KeyUtils.getRechargeOrderSn();
userRecharge.setOrderSn(ordersn);
- userRecharge.setPayChannel(payType);
+ userRecharge.setPayChannel(sitePay.getChannelName());
userRecharge.setPayAmt(new BigDecimal(payAmt));
userRecharge.setOrderStatus(Integer.valueOf(0));
userRecharge.setAddTime(new Date());
- int insertCount = this.userRechargeMapper.insert(userRecharge);
- if (insertCount > 0) {
- log.info("fly支付，创建支付订单成功！");
- } else {
- log.info("fly支付，创建支付订单失败！");
- }
-
-
-
- PayChnnel payChnnel = payChnnelMapper.selectById(payType);
- if(payChnnel.getChannelName().equals("USDT")){
- AgentUser agentUser = agentUserMapper.findAgentByAgentId(user.getAgentId());
- return ServerResponse.createBySuccess(agentUser.getOnLineServices());
- }else{
- if(payChnnel.getChannelDesc().equals("wowpay")){
- return rechargMethodWow(ordersn,payAmt);
- }else if(payChnnel.getChannelDesc().equals("dzxum")){
- return rechargMethodDz(ordersn,payAmt);
- }else if(payChnnel.getChannelDesc().equals("qeaepay")){
- return rechargMethodGe(ordersn,payAmt);
- } else{
- return rechargMethodTop4(ordersn,payAmt);
- }
- }
-
+ userRecharge.setPayId(payType);
+ userRecharge.setImg(currency);
+ userRechargeMapper.insert(userRecharge);
+ return ServerResponse.createBySuccess( ((SiteInfo)siteInfoService.getInfo(request).getData()).getOnlineService());
}
@@ -278,7 +256,7 @@
map.put("mch_order_no",ordersn);
map.put("pay_type","122");
map.put("trade_amount",payAmt);
- map.put("order_date",DateTimeUtil.getCurrentDate(STANDARD_FORMAT));
+ map.put("order_date", DateTimeUtil.getCurrentDate(STANDARD_FORMAT));
map.put("goods_name","充值");
String signStr = SignUtil.sortData(map);
map.put("sign_type","MD5");
@@ -559,7 +537,7 @@
return ServerResponse.createByErrorMsg("后台通知，查不到订单");
}
- User user = this.userMapper.selectByPrimaryKey(userRecharge.getUserId());
+ User user = this.userMapper.selectById(userRecharge.getUserId());
if (user == null) {
return ServerResponse.createByErrorMsg("后台通知，查不到用户");
}
@@ -577,13 +555,7 @@
int updateCount = this.userRechargeMapper.updateByPrimaryKeySelective(userRecharge);
if (updateCount > 0) {
log.info("后台通知，修改订单状态成功");
-
- BigDecimal total_amt = user.getUserAmt().add(userRecharge.getPayAmt());
- total_amt = total_amt.divide(new BigDecimal(100));
- user.setUserAmt(total_amt);
- BigDecimal total_enable = user.getEnableAmt().add(userRecharge.getPayAmt());
- user.setEnableAmt(total_enable);
- int updateUserCount = this.userMapper.updateByPrimaryKeySelective(user);
+ int updateUserCount = this.userMapper.updateById(user);
if (updateUserCount > 0) {
return ServerResponse.createBySuccessMsg("后台通知 处理成功");
}
--
Gitblit v1.9.3