package com.mtgg.controller;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.jpay.ext.kit.HttpKit;
import com.jpay.ext.kit.IpKit;
import com.jpay.ext.kit.PaymentKit;
import com.jpay.ext.kit.StrKit;
import com.jpay.vo.AjaxResult;
import com.jpay.weixin.api.WxPayApi;
import com.jpay.weixin.api.WxPayApiConfig;
import com.jpay.weixin.api.WxPayApiConfigKit;
import com.mtgg.entity.H5ScencInfo;
import com.mtgg.entity.H5ScencInfo.H5;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.*;
@Controller
@RequestMapping("/wc")
public class WxPayController {
/**
* https://blog.csdn.net/Goligory/article/details/78392505
*/
// @Autowired
// private WxPayBean wxPayBean;
private Logger log = LoggerFactory.getLogger(this.getClass());
private AjaxResult result = new AjaxResult();
private static final String appID="";
private static final String secret="";
private static final String mchID="";
private static final String partnerKey="";
private String notify_url = "http://free.jiangshidi.top/Pay/wc/pay_notify.do";
private String H5_echo_url = "https://jiangshidi.top";
public static WxPayApiConfig getApiConfig() {
return WxPayApiConfig.New()
.setAppId(appID)
.setMchId(mchID)
.setPaternerKey(partnerKey)
.setPayModel(WxPayApiConfig.PayModel.BUSINESSMODEL);
}
/**
* 微信H5 支付--------------------好使
* 注意:必须再web页面中发起支付且域名已添加到开发配置中
*/
@RequestMapping(value ="/pay.do",method = {RequestMethod.POST,RequestMethod.GET})
public void wapPay(HttpServletRequest request,HttpServletResponse response){
System.out.println("--pay start--");
String ip = IpKit.getRealIp(request);
if (com.jpay.ext.kit.StrKit.isBlank(ip)) {
ip = "127.0.0.1";
}
ip = "218.247.237.146";
H5ScencInfo sceneInfo = new H5ScencInfo();
// String retUrl = request.getHeader("Referer")
System.out.println(" referer "+request.getHeader("Referer"));
H5 h5_info = new H5();
h5_info.setType("Wap");
//此域名必须在商户平台--"产品中心"--"开发配置"中添加
h5_info.setWap_url(H5_echo_url);
h5_info.setWap_name("网站测试");
sceneInfo.setH5_info(h5_info);
WxPayApiConfig wxPayApiConfig=getApiConfig();
Map<String, String> params=WxPayApiConfig.New()
.setAppId(appID)
.setMchId(mchID)
.setBody("H5支付测试")
.setSpbillCreateIp(ip)
.setTotalFee("1")
.setTradeType(WxPayApi.TradeType.MWEB)
.setNotifyUrl(notify_url)
.setPaternerKey(partnerKey)
.setOutTradeNo(String.valueOf(System.currentTimeMillis()))
.setSceneInfo("{\"h5_info\": {\"type\":\"IOS\",\"app_name\": \"mtgg\",\"package_name\": \"com.tencent.tmgp.sgame\"}}")
.setAttach("H5支付测试")
.build();
String xmlResult = WxPayApi.pushOrder(false,params);
Map<String, String> result = PaymentKit.xmlToMap(xmlResult);
String return_code = result.get("return_code");
String return_msg = result.get("return_msg");
if (!PaymentKit.codeIsOK(return_code)) {
log.error("return_code>"+return_code+" return_msg>"+return_msg);
throw new RuntimeException(return_msg);
}
String result_code = result.get("result_code");
if (!PaymentKit.codeIsOK(result_code)) {
log.error("result_code>"+result_code+" return_msg>"+return_msg);
throw new RuntimeException(return_msg);
}
// 以下字段在return_code 和result_code都为SUCCESS的时候有返回
String prepay_id = result.get("prepay_id");
String mweb_url = result.get("mweb_url");
log.info("prepay_id:"+prepay_id+" mweb_url:"+mweb_url);
try {
response.sendRedirect(mweb_url);
} catch (IOException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 公众号支付
*/
@RequestMapping(value ="/gzhPay.do",method = {RequestMethod.POST,RequestMethod.GET})
public ModelAndView webPay(HttpServletRequest request, HttpServletResponse response) {
System.out.println("------------------gzhPay start-------------------");
ModelAndView mv=new ModelAndView();
String total_fee = request.getParameter("total_fee");
//获取用户的code
String code = request.getParameter("code");
String openId=null;
try {
List<Object> list = accessToken(code);
openId=list.get(1).toString();
} catch (IOException e) {
System.out.println("--openid获取错误");
}
//openid可以通过网页授权获取存到session中从而获取,IJPay是这样做的,我是另一种方式
/*openId,采用 网页授权获取 access_token API:SnsAccessTokenApi获取
String openId = (String) request.getSession().getAttribute("openId");*/
if (StrKit.isBlank(openId)) {
return mv;
}
if (StrKit.isBlank(total_fee)) {
return mv;
}
String ip = IpKit.getRealIp(request);
if (StrKit.isBlank(ip)) {
ip = "127.0.0.1";
}
WxPayApiConfigKit.putApiConfig(getApiConfig());
Map<String, String> params = WxPayApiConfigKit.getWxPayApiConfig()
.setAttach("IJPay 公众号支付测试 -By Javen")
.setBody("IJPay 公众号支付测试 -By Javen")
.setOpenId(openId)
.setSpbillCreateIp(ip)
.setTotalFee(total_fee)
.setTradeType(WxPayApi.TradeType.JSAPI)
.setNotifyUrl(notify_url)
.setOutTradeNo(String.valueOf(System.currentTimeMillis()))
.build();
String xmlResult = WxPayApi.pushOrder(false,params);
log.info(xmlResult);
Map<String, String> resultMap = PaymentKit.xmlToMap(xmlResult);
String return_code = resultMap.get("return_code");
String return_msg = resultMap.get("return_msg");
if (!PaymentKit.codeIsOK(return_code)) {
return mv;
}
String result_code = resultMap.get("result_code");
if (!PaymentKit.codeIsOK(result_code)) {
return mv;
}
// 以下字段在return_code 和result_code都为SUCCESS的时候有返回
String prepay_id = resultMap.get("prepay_id");
String timeStamp=String.valueOf(System.currentTimeMillis() / 1000);
String nonce_str=String.valueOf(System.currentTimeMillis());
String packages = "prepay_id="+prepay_id;
Map<String, String> packageParams = new HashMap<String, String>();
packageParams.put("appId", appID);
packageParams.put("timeStamp", timeStamp);
packageParams.put("nonceStr", nonce_str);
packageParams.put("package", "prepay_id=" + prepay_id);
packageParams.put("signType", "MD5");
String packageSign = PaymentKit.createSign(packageParams, WxPayApiConfigKit.getWxPayApiConfig().getPaternerKey());
packageParams.put("paySign", packageSign);
//下面