package com.panzhihua.applets.api;
|
|
import com.panzhihua.common.utlis.PayUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.IOException;
|
import java.io.PrintWriter;
|
import java.util.Map;
|
|
/**
|
* @auther lyq
|
* @create 2021-04-14 15:02:49
|
* @describe 微信支付回到函数
|
*/
|
@Slf4j
|
@RestController
|
@RequestMapping("/wx/")
|
public class WxCallbackApi {
|
|
@PostMapping("notify")
|
public void payCallback(HttpServletRequest request, HttpServletResponse response) {
|
log.info("微信回调接口方法 start");
|
log.info("微信回调接口 操作逻辑 start");
|
String inputLine = "";
|
String notityXml = "";
|
try {
|
while((inputLine = request.getReader().readLine()) != null){
|
notityXml += inputLine;
|
}
|
//关闭流
|
request.getReader().close();
|
log.info("微信回调内容信息："+notityXml);
|
//解析成Map
|
Map<String,String> map = PayUtil.doXMLParse(notityXml);
|
//判断 支付是否成功
|
if("SUCCESS".equals(map.get("result_code"))){
|
log.info("微信回调返回是否支付成功：是");
|
//获得 返回的商户订单号
|
String outTradeNo = map.get("out_trade_no");
|
log.info("微信回调返回商户订单号："+outTradeNo);
|
//访问DB
|
// WechatAppletGolfPayInfo payInfo = appletGolfPayInfoMapper.selectByPrimaryKey(outTradeNo);
|
log.info("微信回调 根据订单号查询订单状态：");
|
if("0".equals("0")){
|
|
//封装 返回值
|
StringBuffer buffer = new StringBuffer();
|
buffer.append("<xml>");
|
buffer.append("<return_code>SUCCESS</return_code>");
|
buffer.append("<return_msg>OK</return_msg>");
|
buffer.append("</xml>");
|
|
//给微信服务器返回 成功标示 否则会一直询问 咱们服务器 是否回调成功
|
PrintWriter writer = response.getWriter();
|
//返回
|
writer.print(buffer.toString());
|
}
|
}else{
|
log.info("微信回调返回支付失败");
|
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
