处理充值回调问题
This commit is contained in:
parent
c1de717eaa
commit
795a62bf1d
|
|
@ -28,7 +28,6 @@ import javax.servlet.http.HttpServletRequest;
|
||||||
import javax.validation.constraints.NotNull;
|
import javax.validation.constraints.NotNull;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
@RestController
|
@RestController
|
||||||
@RequestMapping("/api/pay")
|
@RequestMapping("/api/pay")
|
||||||
@Api(tags = "支付管理")
|
@Api(tags = "支付管理")
|
||||||
|
|
@ -102,14 +101,10 @@ public class PayController {
|
||||||
signatureHeader.setSerial(request.getHeader("wechatpay-serial"));
|
signatureHeader.setSerial(request.getHeader("wechatpay-serial"));
|
||||||
signatureHeader.setTimeStamp(request.getHeader("wechatpay-timestamp"));
|
signatureHeader.setTimeStamp(request.getHeader("wechatpay-timestamp"));
|
||||||
|
|
||||||
log.error("========================== 回调来了 ====================");
|
|
||||||
log.error("响应的: " + jsonData);
|
|
||||||
log.error("请求的: " + signatureHeader);
|
|
||||||
|
|
||||||
// 解密数据
|
// 解密数据
|
||||||
WxPayService wxPayService = WxPayDriver.handler(ClientEnum.MNP.getCode());
|
WxPayService wxPayService = WxPayDriver.handler(ClientEnum.MNP.getCode());
|
||||||
WxPayOrderNotifyV3Result.DecryptNotifyResult notifyResult = wxPayService.parseOrderNotifyV3Result(jsonData, signatureHeader).getResult();
|
WxPayOrderNotifyV3Result.DecryptNotifyResult notifyResult = wxPayService.parseOrderNotifyV3Result(jsonData, signatureHeader).getResult();
|
||||||
log.error("解密的: " + notifyResult);
|
|
||||||
// 取出数据
|
// 取出数据
|
||||||
String transactionId = notifyResult.getTransactionId();
|
String transactionId = notifyResult.getTransactionId();
|
||||||
String outTradeNo = notifyResult.getOutTradeNo();
|
String outTradeNo = notifyResult.getOutTradeNo();
|
||||||
|
|
|
||||||
|
|
@ -187,7 +187,7 @@ public class PayServiceImpl implements IPayService {
|
||||||
rechargeOrder.setUpdateTime(System.currentTimeMillis() / 1000);
|
rechargeOrder.setUpdateTime(System.currentTimeMillis() / 1000);
|
||||||
rechargeOrderMapper.updateById(rechargeOrder);
|
rechargeOrderMapper.updateById(rechargeOrder);
|
||||||
|
|
||||||
User user = userMapper.selectById(rechargeOrder.getId());
|
User user = userMapper.selectById(rechargeOrder.getUserId());
|
||||||
user.setMoney(user.getMoney().add(rechargeOrder.getOrderAmount()));
|
user.setMoney(user.getMoney().add(rechargeOrder.getOrderAmount()));
|
||||||
user.setUpdateTime(System.currentTimeMillis() / 1000);
|
user.setUpdateTime(System.currentTimeMillis() / 1000);
|
||||||
userMapper.updateById(user);
|
userMapper.updateById(user);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue