修改

xuhy

2025-01-16 2e97a0b58cc60cb076843b3a860732f71762cff7

 DriverOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/api/CallbackController.java

@@ -1,6 +1,12 @@
package com.stylefeng.guns.modular.api;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.stylefeng.guns.modular.system.model.Driver;
import com.stylefeng.guns.modular.system.model.TransactionDetails;
import com.stylefeng.guns.modular.system.service.IDriverService;
import com.stylefeng.guns.modular.system.service.IReassignService;
import com.stylefeng.guns.modular.system.service.ITransactionDetailsService;
import com.stylefeng.guns.modular.system.util.PayMoneyUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -9,6 +15,7 @@

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.PrintWriter;
import java.util.Map;

/**
@@ -78,4 +85,43 @@
            e.printStackTrace();
        }
    }
    @Autowired
    private ITransactionDetailsService transactionDetailsService;
    @Autowired
    private PayMoneyUtil payMoneyUtil;
    @Autowired
    private IDriverService driverService;
    @ResponseBody
    @PostMapping("/wxRecharge")
    public void wxRecharge(HttpServletRequest request, HttpServletResponse response){
        try {
            Map<String, String> map = payMoneyUtil.weixinpayCallback(request);
            if (null != map) {
                String out_trade_no = map.get("out_trade_no");
                String transaction_id = map.get("transaction_id");
                String result = map.get("result");
                TransactionDetails transactionDetails = transactionDetailsService.selectOne(new EntityWrapper<TransactionDetails>()
                        .eq("code", out_trade_no));
                if (transactionDetails!=null){
                    if (transactionDetails.getState()==2){
                        return;
                    }
                    Driver driver = driverService.selectById(transactionDetails.getUserId());
                    if (driver!=null){
                        driver.setBalance(driver.getBalance() + transactionDetails.getMoney());
                        driverService.updateById(driver);
                    }
                    transactionDetails.setState(2);
                    transactionDetailsService.updateById(transactionDetails);
                    PrintWriter out = response.getWriter();
                    out.write(result);
                    out.flush();
                    out.close();
                }
            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }

}