From b6a76de40ec625b440b28d8ec7977d355eec01c8 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Fri, 02 Sep 2022 17:08:11 +0800 Subject: [PATCH] 20220902 --- src/main/java/cc/mrbird/febs/pay/controller/UnipayController.java | 44 ++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 40 insertions(+), 4 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..4a10555 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,10 @@ private MallMemberBankMapper mallMemberBankMapper; @Autowired private MallMemberBankSignMapper mallMemberBankSignMapper; + @Autowired + private MallMemberWithdrawMapper mallMemberWithdrawMapper; + @Autowired + private MallMoneyFlowMapper mallMoneyFlowMapper; @GetMapping(value = "/unipayCallBack") public String unipayCallBack(HttpServletRequest request, UniPayCallBackDto uniPayCallBackDto){ @@ -254,4 +256,38 @@ return "success"; } + @PostMapping(value = "/singlePayCallBack") + public SinglePayCallBackVo 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 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); + } + } + } + SinglePayCallBackVo singlePayCallBackVo = new SinglePayCallBackVo(); + singlePayCallBackVo.setStatusCode("2001"); + singlePayCallBackVo.setMessage("成功"); + return singlePayCallBackVo; + } + } -- Gitblit v1.9.1