From eadc1f646e81e8ffbe940b13163aee9d107d6663 Mon Sep 17 00:00:00 2001
From: 44323 <443237572@qq.com>
Date: 星期三, 13 三月 2024 09:03:32 +0800
Subject: [PATCH] Merge branch '2.0' of http://120.76.84.145:10101/gitblit/r/java/PlayPai into 2.0

---
 cloud-server-account/src/main/java/com/dsh/account/service/impl/RechargeRecordsServiceImpl.java |   43 ++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 40 insertions(+), 3 deletions(-)

diff --git a/cloud-server-account/src/main/java/com/dsh/account/service/impl/RechargeRecordsServiceImpl.java b/cloud-server-account/src/main/java/com/dsh/account/service/impl/RechargeRecordsServiceImpl.java
index 39e2c5b..8989a5c 100644
--- a/cloud-server-account/src/main/java/com/dsh/account/service/impl/RechargeRecordsServiceImpl.java
+++ b/cloud-server-account/src/main/java/com/dsh/account/service/impl/RechargeRecordsServiceImpl.java
@@ -7,6 +7,8 @@
 import com.dsh.account.entity.TAppUser;
 import com.dsh.account.entity.VipPayment;
 import com.dsh.account.enums.RechargeRecordEnum;
+import com.dsh.account.feignclient.communityWorldCup.WorldCupPaymentClinet;
+import com.dsh.account.feignclient.communityWorldCup.model.GetWorldCupPayment;
 import com.dsh.account.feignclient.competition.DeductionCompetitionsClient;
 import com.dsh.account.feignclient.competition.model.PaymentCompetition;
 import com.dsh.account.feignclient.course.CoursePaymentClient;
@@ -18,6 +20,7 @@
 import com.dsh.account.mapper.RechargeRecordsMapper;
 import com.dsh.account.mapper.TAppUserMapper;
 import com.dsh.account.model.IncomeQuery;
+import com.dsh.account.model.WorldCupPayment;
 import com.dsh.account.model.query.RechargeRecordsQuery;
 import com.dsh.account.model.vo.RechargeRecordsVO;
 import com.dsh.account.model.vo.userBenefitDetail.RechargeDetailsVo;
@@ -73,8 +76,11 @@
 
     @Resource
     private RechargeConfigClient reconMapper;
-    @Autowired
+    @Resource
     private RechargeRecordsMapper rechargeRecordsMapper;
+
+    @Resource
+    private WorldCupPaymentClinet worldCupPaymentClinet;
 
 
     @Override
@@ -195,6 +201,31 @@
                 details.add(consumeDetail);
             }
         }
+
+        //世界杯
+        GetWorldCupPayment getWorldCupPayment = new GetWorldCupPayment();
+        getWorldCupPayment.setAppUserId(appUserId);
+        getWorldCupPayment.setPayType(3);
+        getWorldCupPayment.setStartTime(monthStart);
+        getWorldCupPayment.setEndTime(monthEnd);
+        List<WorldCupPayment> worldCupPayment = worldCupPaymentClinet.getWorldCupPayment(getWorldCupPayment);
+        for (WorldCupPayment cupPayment : worldCupPayment) {
+            RechargesDetail consumeDetail = new RechargesDetail();
+            if(cupPayment.getPayStatus() != 3){
+                consumeDetail.setConsumeName(RechargeRecordEnum.WORLD_CIP_PAYMENT.getMsg() + ":¥" + cupPayment.getAmount());
+                consumeDetail.setConsumeTime(simpleDateFormat.format(cupPayment.getCreateTime()));
+                consumeDetail.setConsumeAmount("-" + cupPayment.getAmount());
+                consumeDetail.setRecordId(2);
+            }else{
+                consumeDetail.setConsumeName(RechargeRecordEnum.CANCEL_WORLD_CIP_PAYMENT.getMsg() + ":¥" + cupPayment.getAmount());
+                consumeDetail.setConsumeTime(simpleDateFormat.format(cupPayment.getCreateTime()));
+                consumeDetail.setConsumeAmount("+" + cupPayment.getAmount());
+                consumeDetail.setRecordId(1);
+            }
+            details.add(consumeDetail);
+        }
+
+
         if (ToolUtil.isNotEmpty(recordId)) {
             details = details.stream()
                     .filter(record -> record.getRecordId().equals(recordId))
@@ -288,9 +319,9 @@
         return ResultUtil.success();
     }
 
-
+    private String smid = "2088330203191220";//平台支付宝商户号
     private ResultUtil AlipayPayment(String code, BigDecimal amount) {
-        ResultUtil alipay = payMoneyUtil.alipay("玩湃币充值", "玩湃币充值", "", code, amount.toString(),
+        ResultUtil alipay = payMoneyUtil.alipay(smid,"玩湃币充值", "玩湃币充值", "", code, amount.toString(),
                 "/base/recharge/alipayRechargeCallback");
         if (alipay.getCode() == 200) {
             new Thread(new Runnable() {
@@ -328,8 +359,14 @@
                                 if ("TRADE_CLOSED".equals(tradeStatus) || "TRADE_FINISHED".equals(tradeStatus) || num == 10) {
                                     records.setState(3);
                                     rereMapper.deleteById(records.getId());
+                                    if ("TRADE_FINISHED".equals(tradeStatus)) {
+                                        // todo 资金结算
+                                        payMoneyUtil.confirm(smid,code,tradeNo,amount.toString());
+                                        break;
+                                    }
                                     break;
                                 }
+
                                 if ("TRADE_SUCCESS".equals(tradeStatus)) {
                                     records.setAppUserId(null);
                                     records.setPayStatus(2);

--
Gitblit v1.7.1