From 107c4d630c5b5c1b04f0d63a147e363b68dd1e8c Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 27 Oct 2023 17:57:53 +0800
Subject: [PATCH] 版本管理

---
 src/main/java/cc/mrbird/febs/pay/controller/UnipayController.java |   61 ++++++++++++++++++++++++++----
 1 files changed, 53 insertions(+), 8 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/pay/controller/UnipayController.java b/src/main/java/cc/mrbird/febs/pay/controller/UnipayController.java
index d7779f7..49a2210 100644
--- a/src/main/java/cc/mrbird/febs/pay/controller/UnipayController.java
+++ b/src/main/java/cc/mrbird/febs/pay/controller/UnipayController.java
@@ -14,10 +14,7 @@
 import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;
 import cc.mrbird.febs.mall.service.IMallAchieveService;
 import cc.mrbird.febs.mall.service.IMallMoneyFlowService;
-import cc.mrbird.febs.pay.model.AgreeMentPayCallBackDto;
-import cc.mrbird.febs.pay.model.AgreeMentPaySmsDto;
-import cc.mrbird.febs.pay.model.AgreementSignDto;
-import cc.mrbird.febs.pay.model.UniPayCallBackDto;
+import cc.mrbird.febs.pay.model.*;
 import cc.mrbird.febs.pay.service.UnipayService;
 import cc.mrbird.febs.pay.util.JsonUtil;
 import cc.mrbird.febs.rabbit.producter.AgentProducer;
@@ -27,6 +24,7 @@
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.RequiredArgsConstructor;
@@ -75,6 +73,12 @@
     private MallMemberBankMapper mallMemberBankMapper;
     @Autowired
     private MallMemberBankSignMapper mallMemberBankSignMapper;
+    @Autowired
+    private MallMemberWithdrawMapper mallMemberWithdrawMapper;
+    @Autowired
+    private MallMoneyFlowMapper mallMoneyFlowMapper;
+
+    private final IApiMallMemberWalletService iApiMallMemberWalletService;
 
     @GetMapping(value = "/unipayCallBack")
     public String unipayCallBack(HttpServletRequest request, UniPayCallBackDto uniPayCallBackDto){
@@ -133,8 +137,6 @@
                     }
 
                     mallMoneyFlowService.addMoneyFlow(mallMember.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue());
-                    agentProducer.sendAutoLevelUpMsg(mallMember.getId());
-                    agentProducer.sendOrderReturn(orderInfo.getId());
                 }
             }
         }
@@ -246,12 +248,55 @@
                     }
 
                     mallMoneyFlowService.addMoneyFlow(mallMember.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue());
-                    agentProducer.sendAutoLevelUpMsg(mallMember.getId());
-                    agentProducer.sendOrderReturn(orderInfo.getId());
                 }
             }
         }
         return "success";
     }
 
+    @PostMapping(value = "/singlePayCallBack")
+    public JSONObject singlePayCallBack(@RequestBody SinglePayCallBackDto singlePayCallBackDto){
+        log.info("进入汇聚支付代付回调"+ JSONUtil.parseObj(singlePayCallBackDto));
+        String status = singlePayCallBackDto.getStatus();
+        BigDecimal paidAmount = singlePayCallBackDto.getPaidAmount();
+        BigDecimal paidAmountFee = singlePayCallBackDto.getFee();
+        String errorCode = singlePayCallBackDto.getErrorCode();
+        String errorCodeDesc = singlePayCallBackDto.getErrorCodeDesc();
+        String merchantOrderNo = singlePayCallBackDto.getMerchantOrderNo();
+
+        log.info("进入汇聚支付代付回调"+status+";"+paidAmount+";"+paidAmountFee+";");
+        if("205".equals(status) && "".equals(errorCode)){
+            QueryWrapper<MallMemberWithdraw> objectQueryWrapper = new QueryWrapper<>();
+            objectQueryWrapper.eq("withdraw_no",merchantOrderNo);
+            MallMemberWithdraw mallMemberWithdraw = mallMemberWithdrawMapper.selectOne(objectQueryWrapper);
+            if(ObjectUtil.isNotEmpty(mallMemberWithdraw)){
+                mallMemberWithdraw.setStatus(2);
+                mallMemberWithdrawMapper.updateById(mallMemberWithdraw);
+
+                QueryWrapper<MallMoneyFlow> flowQueryWrapper = new QueryWrapper<>();
+                flowQueryWrapper.eq("order_no",mallMemberWithdraw.getWithdrawNo());
+                flowQueryWrapper.eq("type",MoneyFlowTypeEnum.WITHDRAWAL.getValue());
+                MallMoneyFlow mallMoneyFlow = mallMoneyFlowMapper.selectOne(flowQueryWrapper);
+                if(ObjectUtil.isNotEmpty(mallMoneyFlow)){
+                    mallMoneyFlow.setStatus(2);
+                    mallMoneyFlowMapper.updateById(mallMoneyFlow);
+                }
+            }
+        }else{
+            QueryWrapper<MallMemberWithdraw> objectQueryWrapper = new QueryWrapper<>();
+            objectQueryWrapper.eq("withdraw_no",merchantOrderNo);
+            MallMemberWithdraw mallMemberWithdraw = mallMemberWithdrawMapper.selectOne(objectQueryWrapper);
+            if(ObjectUtil.isNotEmpty(mallMemberWithdraw)){
+                mallMemberWithdraw.setRemark(errorCodeDesc);
+                mallMemberWithdrawMapper.updateById(mallMemberWithdraw);
+            }
+        }
+
+        SinglePayCallBackVo singlePayCallBackVo = new SinglePayCallBackVo();
+        singlePayCallBackVo.setStatusCode("2001");
+        singlePayCallBackVo.setMessage("成功");
+        JSONObject jsonObject = JSONUtil.parseObj(singlePayCallBackVo);
+        return jsonObject;
+    }
+
 }

--
Gitblit v1.9.1