package cn.stylefeng.rest.ijpay.controller;

import cn.hutool.core.net.NetUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import cn.stylefeng.guns.modular.business.dto.request.OrderPayRequest;
import cn.stylefeng.guns.modular.business.entity.CounsellingOrder;
import cn.stylefeng.guns.modular.business.entity.CourseOrder;
import cn.stylefeng.guns.modular.business.entity.OrderConsultOne;
import cn.stylefeng.guns.modular.business.entity.OrderMentalTest;
import cn.stylefeng.guns.modular.business.service.ICounsellingOrderService;
import cn.stylefeng.guns.modular.business.service.ICourseOrderService;
import cn.stylefeng.guns.modular.business.service.IOrderConsultOneService;
import cn.stylefeng.guns.modular.business.service.IOrderMentalTestService;
import cn.stylefeng.rest.ijpay.entity.H5SceneInfo;
import cn.stylefeng.rest.ijpay.entity.WxPayBean;
import cn.stylefeng.rest.ijpay.entity.request.WxAppPayRequest;
import cn.stylefeng.rest.modular.order.service.MentalTestOrderBizService;
import cn.stylefeng.roses.kernel.rule.constants.RuleConstants;
import cn.stylefeng.roses.kernel.rule.enums.OrderTypeEnum;
import cn.stylefeng.roses.kernel.rule.enums.PayTypeEnum;
import cn.stylefeng.roses.kernel.rule.pojo.response.ErrorResponseData;
import cn.stylefeng.roses.kernel.rule.pojo.response.ResponseData;
import cn.stylefeng.roses.kernel.rule.pojo.response.SuccessResponseData;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.google.zxing.BarcodeFormat;
import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel;
import com.ijpay.core.enums.SignType;
import com.ijpay.core.enums.TradeType;
import com.ijpay.core.kit.*;
import com.ijpay.wxpay.WxPayApi;
import com.ijpay.wxpay.WxPayApiConfig;
import com.ijpay.wxpay.WxPayApiConfigKit;
import com.ijpay.wxpay.model.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.util.ResourceUtils;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.IOException;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.*;

@Slf4j
@Controller
@Api(tags = "支付接口")
@RequestMapping("/wxPay")
public class WxPayController {

	@Autowired
	WxPayBean wxPayBean;

	private String notifyUrl;
	private String refundNotifyUrl;
	private static final String USER_PAYING = "USERPAYING";

	@Resource
	IOrderMentalTestService orderMentalTestService;

	@Resource
	IOrderConsultOneService orderConsultOneService;

	@Resource
	MentalTestOrderBizService mentalTestOrderBizService;

	@Resource
	ICourseOrderService courseOrderService;

	@Resource
	ICounsellingOrderService counsellingOrderService;

	/**
	 * 微信APP支付
	 */
	@ApiOperation(value = "微信APP支付")
	@PostMapping(value = "/appPay")
	@ResponseBody
	public ResponseData appPay(@RequestBody @Validated WxAppPayRequest req) {
		// 支付金额
		BigDecimal totalAmount = BigDecimal.valueOf(0);

		// 订单编号判断订单类型
		if (req.getOrderNo().contains(OrderTypeEnum.MENTAL_TEST.getCode())) {
			// 心理测试订单
			OrderMentalTest order = orderMentalTestService.getOrderByNo(req.getOrderNo());
			totalAmount = order.getPayAmount();
		} else if (req.getOrderNo().contains(OrderTypeEnum.CONSULT_ONE.getCode())) {
			// 心理咨询1V1订单
			OrderConsultOne order = orderConsultOneService.getOrderByNo(req.getOrderNo());
			totalAmount = order.getPayAmount();
		}else if (req.getOrderNo().startsWith(OrderTypeEnum.COURSE_ORDER.getCode())){
			CourseOrder courseOrder = this.courseOrderService.getCourseOrderByNo(req.getOrderNo());
			totalAmount = courseOrder.getPayAmount();
		} else if (req.getOrderNo().startsWith(OrderTypeEnum.COUNSELLING_ORDER.getCode())) {
			CounsellingOrder counsellingOrder = this.counsellingOrderService.getCounsellingOrderByNo(req.getOrderNo());
			totalAmount = counsellingOrder.getPayAmount();
		}


		// 判断转换后的BigDecimal是否为0
		if (totalAmount.compareTo(BigDecimal.ZERO) == 0) {
			if (req.getOrderNo().startsWith(OrderTypeEnum.MENTAL_TEST.getCode())) {
				// 心理测试订单
				orderMentalTestService.paySuccess(req.getOrderNo(), req.getOrderNo(), String.valueOf(totalAmount), PayTypeEnum.ALIPAY.getCode());
			} else if (req.getOrderNo().startsWith(OrderTypeEnum.CONSULT_ONE.getCode())) {
				// 心理咨询1V1订单
				mentalTestOrderBizService.paySuccessOrderConsultOne(req.getOrderNo(), req.getOrderNo(), String.valueOf(totalAmount), PayTypeEnum.ALIPAY.getCode());
			} else if (req.getOrderNo().startsWith(OrderTypeEnum.COURSE_ORDER.getCode())) {
				//课程订单
				OrderPayRequest orderPayRequest = new OrderPayRequest();
				orderPayRequest.setOrderNo(req.getOrderNo());
				orderPayRequest.setTransactionNo(req.getOrderNo());
				orderPayRequest.setPayType("2");
				orderPayRequest.setOrderType(1);
				courseOrderService.payCourseOrder(orderPayRequest);
			} else if (req.getOrderNo().startsWith(OrderTypeEnum.COUNSELLING_ORDER.getCode())) {
				//咨询订单
				OrderPayRequest orderPayRequest = new OrderPayRequest();
				orderPayRequest.setOrderNo(req.getOrderNo());
				orderPayRequest.setTransactionNo(req.getOrderNo());
				orderPayRequest.setPayType("2");
				orderPayRequest.setOrderType(2);
				counsellingOrderService.payCounsellingOrder(orderPayRequest);
			}
			return new SuccessResponseData("支付成功");
		}

		// 设置支付配置
		WxPayApiConfigKit.putApiConfig(getApiConfig());
		//WxPayApiConfigKit.setThreadLocalAppId(wxPayBean.getAppId());
		//WxPayApiConfigKit.setThreadLocalWxPayApiConfig(getApiConfig());

		// 获取IP
		String ip = NetUtil.localIpv4s().stream().findFirst().orElse("127.0.0.1");

		// 获取微信支付配置
		WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

		// 支付金额X100求整
		String totalFee = totalAmount.multiply(BigDecimal.valueOf(100))
				.setScale(0, RoundingMode.HALF_UP)
				.toPlainString();
		// 组装支付参数
		Map<String, String> params = UnifiedOrderModel
				.builder()
				.appid(wxPayApiConfig.getAppId())
				.mch_id(wxPayApiConfig.getMchId())
				.nonce_str(WxPayKit.generateStr())
				.body(req.getSubject())
				.attach(req.getSubject())
				.out_trade_no(WxPayKit.generateStr())
//				.out_trade_no(req.getOrderNo())
				.total_fee(totalFee)
				.spbill_create_ip(ip)
				.notify_url(notifyUrl)
				.trade_type(TradeType.APP.getTradeType()).attach(req.getOrderNo())
				.build()
				.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);
		log.debug("微信APP支付请求params：{}", JSONUtil.toJsonStr(params));
		String xmlResult = WxPayApi.pushOrder(false, params);
		log.debug("微信APP支付结果xml：{}", xmlResult);

		Map<String, String> result = WxPayKit.xmlToMap(xmlResult);
		String returnCode = result.get("return_code");
		String resultCode = result.get("result_code");
		String returnMsg = result.get("return_msg");
		if (!WxPayKit.codeIsOk(returnCode) || !WxPayKit.codeIsOk(resultCode)) {
			log.error("微信APP支付异常！{}", result);
			return new ErrorResponseData(returnMsg);
		}

		// 以下字段在 return_code 和 result_code 都为 SUCCESS 的时候有返回
		String prepayId = result.get("prepay_id");

		Map<String, String> packageParams = WxPayKit.appPrepayIdCreateSign(wxPayApiConfig.getAppId(), wxPayApiConfig.getMchId(), prepayId, wxPayApiConfig.getPartnerKey(), SignType.MD5);

		log.info("微信APP支付返回参数：{}", JSONUtil.toJsonStr(packageParams));
		return new SuccessResponseData(packageParams);
	}

	/**
	 * 异步通知
	 */
	@RequestMapping(value = RuleConstants.NOT_LOGIN + "/payNotify", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String payNotify(HttpServletRequest request) {
		String xmlMsg = HttpKit.readData(request);
		log.info("微信支付异步通知：" + xmlMsg);
		Map<String, String> params = WxPayKit.xmlToMap(xmlMsg);
		String returnCode = params.get("return_code");

		// 注意重复通知的情况，同一订单号可能收到多次通知，请注意一定先判断订单状态
		// 注意此处签名方式需与统一下单的签名类型一致
		if (WxPayKit.verifyNotify(params, WxPayApiConfigKit.getWxPayApiConfig().getPartnerKey(), SignType.MD5)) {
			if (WxPayKit.codeIsOk(returnCode)) {
				// 参数文档: https://pay.weixin.qq.com/wiki/doc/api/jsapi.php?chapter=9_7&index=8
				String totalFee = new BigDecimal(params.get("total_fee")).divide(BigDecimal.valueOf(100)).toString();
				String transactionId = params.get("transaction_id");
				// 获取订单号
//				String orderNo = params.get("out_trade_no");
				String orderNo = params.get("attach");
				// 订单编号判断订单类型
				if (orderNo.startsWith(OrderTypeEnum.MENTAL_TEST.getCode())) {
					// 心理测试订单
					orderMentalTestService.paySuccess(orderNo, transactionId, totalFee, PayTypeEnum.WXPAY.getCode());
				} else if (orderNo.startsWith(OrderTypeEnum.CONSULT_ONE.getCode())) {
					// 心理咨询1V1订单
					mentalTestOrderBizService.paySuccessOrderConsultOne(orderNo, transactionId, totalFee, PayTypeEnum.WXPAY.getCode());
				} else if (orderNo.startsWith(OrderTypeEnum.COURSE_ORDER.getCode())) {
					//课程订单
					OrderPayRequest orderPayRequest = new OrderPayRequest();
					orderPayRequest.setOrderNo(orderNo);
					orderPayRequest.setTransactionNo(transactionId);
					orderPayRequest.setPayType("1");
					orderPayRequest.setOrderType(1);
					courseOrderService.payCourseOrder(orderPayRequest);
				} else if (orderNo.startsWith(OrderTypeEnum.COUNSELLING_ORDER.getCode())) {
					//咨询订单
					OrderPayRequest orderPayRequest = new OrderPayRequest();
					orderPayRequest.setOrderNo(orderNo);
					orderPayRequest.setTransactionNo(transactionId);
					orderPayRequest.setPayType("1");
					orderPayRequest.setOrderType(2);
					counsellingOrderService.payCounsellingOrder(orderPayRequest);
				}


				// 发送通知等
				Map<String, String> xml = new HashMap<String, String>(2);
				xml.put("return_code", "SUCCESS");
				xml.put("return_msg", "OK");
				return WxPayKit.toXml(xml);
			}
		}
		return null;
	}

	/**
	 * 获取Api配置
	 * @return
	 */
	public WxPayApiConfig getApiConfig() {
		WxPayApiConfig apiConfig;
		try {
			apiConfig = WxPayApiConfigKit.getApiConfig(wxPayBean.getAppId());
		} catch (Exception e) {
			apiConfig = WxPayApiConfig.builder()
					.appId(wxPayBean.getAppId())
					.mchId(wxPayBean.getMchId())
					.partnerKey(wxPayBean.getPartnerKey())
					.certPath(wxPayBean.getCertPath())
					.domain(wxPayBean.getDomain())
					.build();
		}
		notifyUrl = apiConfig.getDomain().concat("/wxPay" + RuleConstants.NOT_LOGIN + "/payNotify");
		refundNotifyUrl = apiConfig.getDomain().concat("/wxPay" + RuleConstants.NOT_LOGIN + "/refundNotify");
		return apiConfig;
	}

	@GetMapping("/getKey")
	@ResponseBody
	public String getKey() {
		return WxPayApi.getSignKey(wxPayBean.getMchId(), wxPayBean.getPartnerKey(), SignType.MD5);
	}

	/**
	 * 微信H5 支付
	 * 注意：必须再web页面中发起支付且域名已添加到开发配置中
	 */
	@RequestMapping(value = "/wapPay", method = {RequestMethod.POST, RequestMethod.GET})
	public void wapPay(HttpServletRequest request, HttpServletResponse response) throws IOException {
		String ip = IpKit.getRealIp(request);
		if (StrUtil.isBlank(ip)) {
			ip = "127.0.0.1";
		}

		H5SceneInfo sceneInfo = new H5SceneInfo();

		H5SceneInfo.H5 h5_info = new H5SceneInfo.H5();
		h5_info.setType("Wap");
		//此域名必须在商户平台--"产品中心"--"开发配置"中添加
		h5_info.setWap_url("https://gitee.com/javen205/IJPay");
		h5_info.setWap_name("IJPay VIP 充值");
		sceneInfo.setH5Info(h5_info);

		WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

		Map<String, String> params = UnifiedOrderModel
			.builder()
			.appid(wxPayApiConfig.getAppId())
			.mch_id(wxPayApiConfig.getMchId())
			.nonce_str(WxPayKit.generateStr())
			.body("IJPay 让支付触手可及-H5支付")
			.attach("Node.js 版:https://gitee.com/javen205/TNWX")
			.out_trade_no(WxPayKit.generateStr())
			.total_fee("1000")
			.spbill_create_ip(ip)
			.notify_url(notifyUrl)
			.trade_type(TradeType.MWEB.getTradeType())
			.scene_info(JSON.toJSONString(sceneInfo))
			.build()
			.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);

		String xmlResult = WxPayApi.pushOrder(false, params);
		log.info(xmlResult);

		Map<String, String> result = WxPayKit.xmlToMap(xmlResult);

		String return_code = result.get("return_code");
		String return_msg = result.get("return_msg");
		if (!WxPayKit.codeIsOk(return_code)) {
			throw new RuntimeException(return_msg);
		}
		String result_code = result.get("result_code");
		if (!WxPayKit.codeIsOk(result_code)) {
			throw new RuntimeException(return_msg);
		}
		// 以下字段在return_code 和result_code都为SUCCESS的时候有返回

		String prepayId = result.get("prepay_id");
		String webUrl = result.get("mweb_url");

		log.info("prepay_id:" + prepayId + " mweb_url:" + webUrl);
		response.sendRedirect(webUrl);
	}

	/**
	 * 公众号支付
	 */
	@RequestMapping(value = "/webPay", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public ResponseData webPay(HttpServletRequest request, @RequestParam("total_fee") String totalFee) {
		// openId，采用 网页授权获取 access_token API：SnsAccessTokenApi获取
		String openId = (String) request.getSession().getAttribute("openId");
		if (openId == null) {
			openId = "11111111";
		}

		if (StrUtil.isEmpty(openId)) {
			return new ErrorResponseData("openId is null");
		}
		if (StrUtil.isEmpty(totalFee)) {
			return new ErrorResponseData("请输入数字金额");
		}
		String ip = IpKit.getRealIp(request);
		if (StrUtil.isEmpty(ip)) {
			ip = "127.0.0.1";
		}

		WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

		Map<String, String> params = UnifiedOrderModel
			.builder()
			.appid(wxPayApiConfig.getAppId())
			.mch_id(wxPayApiConfig.getMchId())
			.nonce_str(WxPayKit.generateStr())
			.body("IJPay 让支付触手可及-公众号支付")
			.attach("Node.js 版:https://gitee.com/javen205/TNWX")
			.out_trade_no(WxPayKit.generateStr())
			.total_fee("1000")
			.spbill_create_ip(ip)
			.notify_url(notifyUrl)
			.trade_type(TradeType.JSAPI.getTradeType())
			.openid(openId)
			.build()
			.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);

		String xmlResult = WxPayApi.pushOrder(false, params);
		log.info(xmlResult);

		Map<String, String> resultMap = WxPayKit.xmlToMap(xmlResult);
		String returnCode = resultMap.get("return_code");
		String returnMsg = resultMap.get("return_msg");
		if (!WxPayKit.codeIsOk(returnCode)) {
			return new ErrorResponseData(returnMsg);
		}
		String resultCode = resultMap.get("result_code");
		if (!WxPayKit.codeIsOk(resultCode)) {
			return new ErrorResponseData(returnMsg);
		}

		// 以下字段在 return_code 和 result_code 都为 SUCCESS 的时候有返回

		String prepayId = resultMap.get("prepay_id");

		Map<String, String> packageParams = WxPayKit.prepayIdCreateSign(prepayId, wxPayApiConfig.getAppId(),
			wxPayApiConfig.getPartnerKey(), SignType.MD5);

		String jsonStr = JSON.toJSONString(packageParams);
		return new SuccessResponseData(jsonStr);
	}

	/**
	 * 扫码模式一
	 */
	@RequestMapping(value = "/scanCode1", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public ResponseData scanCode1(HttpServletRequest request, HttpServletResponse response,
								@RequestParam("productId") String productId) {
		try {
			if (StrUtil.isBlank(productId)) {
				return new ErrorResponseData("productId is null");
			}
			WxPayApiConfig config = WxPayApiConfigKit.getWxPayApiConfig();
			//获取扫码支付（模式一）url
			String qrCodeUrl = WxPayKit.bizPayUrl(config.getPartnerKey(), config.getAppId(), config.getMchId(), productId);
			log.info(qrCodeUrl);
			//生成二维码保存的路径
			String name = "payQRCode1.png";
			log.info(ResourceUtils.getURL("classpath:").getPath());
			boolean encode = QrCodeKit.encode(qrCodeUrl, BarcodeFormat.QR_CODE, 3, ErrorCorrectionLevel.H,
				"png", 200, 200,
				ResourceUtils.getURL("classpath:").getPath().concat("static").concat(File.separator).concat(name));
			if (encode) {
				//在页面上显示
				return new SuccessResponseData(name);
			}
		} catch (Exception e) {
			e.printStackTrace();
			return new ErrorResponseData("系统异常：" + e.getMessage());
		}
		return null;
	}

	/**
	 * 扫码支付模式一回调
	 */
	@RequestMapping(value = "/scanCodeNotify", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String scanCodeNotify(HttpServletRequest request, HttpServletResponse response) {
		try {
			String result = HttpKit.readData(request);
			log.info("scanCodeNotify>>>" + result);
			/**
			 * 获取返回的信息内容中各个参数的值
			 */
			Map<String, String> map = WxPayKit.xmlToMap(result);
			for (String key : map.keySet()) {
				log.info("key= " + key + " and value= " + map.get(key));
			}

			String appId = map.get("appid");
			String openId = map.get("openid");
			String mchId = map.get("mch_id");
			String isSubscribe = map.get("is_subscribe");
			String nonceStr = map.get("nonce_str");
			String productId = map.get("product_id");
			String sign = map.get("sign");

			Map<String, String> packageParams = new HashMap<String, String>(6);
			packageParams.put("appid", appId);
			packageParams.put("openid", openId);
			packageParams.put("mch_id", mchId);
			packageParams.put("is_subscribe", isSubscribe);
			packageParams.put("nonce_str", nonceStr);
			packageParams.put("product_id", productId);

			WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

			String packageSign = WxPayKit.createSign(packageParams, wxPayApiConfig.getPartnerKey(), SignType.MD5);

			String ip = IpKit.getRealIp(request);
			if (StrUtil.isBlank(ip)) {
				ip = "127.0.0.1";
			}
			Map<String, String> params = UnifiedOrderModel
				.builder()
				.appid(wxPayApiConfig.getAppId())
				.mch_id(wxPayApiConfig.getMchId())
				.nonce_str(WxPayKit.generateStr())
				.body("IJPay 让支付触手可及-扫码支付模式一")
				.attach("Node.js 版:https://gitee.com/javen205/TNWX")
				.out_trade_no(WxPayKit.generateStr())
				.total_fee("1")
				.spbill_create_ip(ip)
				.notify_url(notifyUrl)
				.trade_type(TradeType.NATIVE.getTradeType())
				.openid(openId)
				.build()
				.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);
			String xmlResult = WxPayApi.pushOrder(false, params);
			log.info("统一下单:" + xmlResult);
			/**
			 * 发送信息给微信服务器
			 */
			Map<String, String> payResult = WxPayKit.xmlToMap(xmlResult);
			String returnCode = payResult.get("return_code");
			String resultCode = payResult.get("result_code");
			if (WxPayKit.codeIsOk(returnCode) && WxPayKit.codeIsOk(resultCode)) {
				// 以下字段在 return_code 和 result_code 都为 SUCCESS 的时候有返回
				String prepayId = payResult.get("prepay_id");

				Map<String, String> prepayParams = new HashMap<String, String>(10);
				prepayParams.put("return_code", "SUCCESS");
				prepayParams.put("appid", appId);
				prepayParams.put("mch_id", mchId);
				prepayParams.put("nonce_str", System.currentTimeMillis() + "");
				prepayParams.put("prepay_id", prepayId);
				String prepaySign;
				if (sign.equals(packageSign)) {
					prepayParams.put("result_code", "SUCCESS");
				} else {
					prepayParams.put("result_code", "FAIL");
					//result_code为FAIL时，添加该键值对，value值是微信告诉客户的信息
					prepayParams.put("err_code_des", "订单失效");
				}
				prepaySign = WxPayKit.createSign(prepayParams, wxPayApiConfig.getPartnerKey(), SignType.MD5);
				prepayParams.put("sign", prepaySign);
				String xml = WxPayKit.toXml(prepayParams);
				log.error(xml);
				return xml;
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	/**
	 * 扫码支付模式二
	 */
	@RequestMapping(value = "/scanCode2", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public ResponseData scanCode2(HttpServletRequest request, HttpServletResponse response, @RequestParam("total_fee") String totalFee) {

		if (StrUtil.isBlank(totalFee)) {
			return new ErrorResponseData("支付金额不能为空");
		}

		String ip = IpKit.getRealIp(request);
		if (StrUtil.isBlank(ip)) {
			ip = "127.0.0.1";
		}
		WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

		Map<String, String> params = UnifiedOrderModel
			.builder()
			.appid(wxPayApiConfig.getAppId())
			.mch_id(wxPayApiConfig.getMchId())
			.nonce_str(WxPayKit.generateStr())
			.body("IJPay 让支付触手可及-扫码支付模式二")
			.attach("Node.js 版:https://gitee.com/javen205/TNWXX")
			.out_trade_no(WxPayKit.generateStr())
			.total_fee("1")
			.spbill_create_ip(ip)
			.notify_url(notifyUrl)
			.trade_type(TradeType.NATIVE.getTradeType())
			.build()
			.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);

		String xmlResult = WxPayApi.pushOrder(false, params);
		log.info("统一下单:" + xmlResult);

		Map<String, String> result = WxPayKit.xmlToMap(xmlResult);

		String returnCode = result.get("return_code");
		String returnMsg = result.get("return_msg");
		System.out.println(returnMsg);
		if (!WxPayKit.codeIsOk(returnCode)) {
			return new ErrorResponseData("error:" + returnMsg);
		}
		String resultCode = result.get("result_code");
		if (!WxPayKit.codeIsOk(resultCode)) {
			return new ErrorResponseData("error:" + returnMsg);
		}
		//生成预付订单success

		String qrCodeUrl = result.get("code_url");
		String name = "payQRCode2.png";

		boolean encode = QrCodeKit.encode(qrCodeUrl, BarcodeFormat.QR_CODE, 3, ErrorCorrectionLevel.H, "png", 200, 200,
			request.getSession().getServletContext().getRealPath("/") + File.separator + name);
		if (encode) {
			//在页面上显示
			return new SuccessResponseData(name);
		}
		return null;
	}

	/**
	 * 刷卡支付
	 */
	@RequestMapping(value = "/microPay", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public ResponseData microPay(HttpServletRequest request, HttpServletResponse response) {
		String authCode = request.getParameter("auth_code");
		String totalFee = request.getParameter("total_fee");
		if (StrUtil.isBlank(totalFee)) {
			return new ErrorResponseData("支付金额不能为空");
		}
		if (StrUtil.isBlank(authCode)) {
			return new ErrorResponseData("auth_code参数错误");
		}
		String ip = IpKit.getRealIp(request);
		if (StrUtil.isBlank(ip)) {
			ip = "127.0.0.1";
		}
		WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

		Map<String, String> params = MicroPayModel.builder()
			.appid(wxPayApiConfig.getAppId())
			.mch_id(wxPayApiConfig.getMchId())
			.nonce_str(WxPayKit.generateStr())
			.body("IJPay 让支付触手可及-刷卡支付")
			.attach("Node.js 版:https://gitee.com/javen205/TNWXX")
			.out_trade_no(WxPayKit.generateStr())
			.total_fee("1")
			.spbill_create_ip(ip)
			.auth_code(authCode)
			.build()
			.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);

		String xmlResult = WxPayApi.microPay(false, params);
		//同步返回结果
		log.info("xmlResult:" + xmlResult);
		Map<String, String> result = WxPayKit.xmlToMap(xmlResult);
		String returnCode = result.get("return_code");
		String returnMsg = result.get("return_msg");
		if (!WxPayKit.codeIsOk(returnCode)) {
			//通讯失败
			String errCode = result.get("err_code");
			if (StrUtil.isNotBlank(errCode)) {
				//用户支付中，需要输入密码
				if (USER_PAYING.equals(errCode)) {
					//等待5秒后调用【查询订单API】
				}
			}
			log.info("提交刷卡支付失败>>" + xmlResult);
			return new ErrorResponseData(returnMsg);
		}

		String resultCode = result.get("result_code");
		if (!WxPayKit.codeIsOk(resultCode)) {
			log.info("支付失败>>" + xmlResult);
			String errCodeDes = result.get("err_code_des");
			return new ErrorResponseData(errCodeDes);
		}
		//支付成功
		return new SuccessResponseData(xmlResult);
	}

	/**
	 * 微信小程序支付
	 */
	@RequestMapping(value = "/miniAppPay", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public ResponseData miniAppPay(HttpServletRequest request) {
		//需要通过授权来获取openId
		String openId = (String) request.getSession().getAttribute("openId");

		String ip = IpKit.getRealIp(request);
		if (StrUtil.isBlank(ip)) {
			ip = "127.0.0.1";
		}

		WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

		Map<String, String> params = UnifiedOrderModel
			.builder()
			.appid(wxPayApiConfig.getAppId())
			.mch_id(wxPayApiConfig.getMchId())
			.nonce_str(WxPayKit.generateStr())
			.body("IJPay 让支付触手可及-小程序支付")
			.attach("Node.js 版:https://gitee.com/javen205/TNWXX")
			.out_trade_no(WxPayKit.generateStr())
			.total_fee("1000")
			.spbill_create_ip(ip)
			.notify_url(notifyUrl)
			.trade_type(TradeType.JSAPI.getTradeType())
			.openid(openId)
			.build()
			.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);

		String xmlResult = WxPayApi.pushOrder(false, params);

		log.info(xmlResult);
		Map<String, String> result = WxPayKit.xmlToMap(xmlResult);

		String returnCode = result.get("return_code");
		String returnMsg = result.get("return_msg");
		if (!WxPayKit.codeIsOk(returnCode)) {
			return new ErrorResponseData(returnMsg);
		}
		String resultCode = result.get("result_code");
		if (!WxPayKit.codeIsOk(resultCode)) {
			return new ErrorResponseData(returnMsg);
		}
		// 以下字段在 return_code 和 result_code 都为 SUCCESS 的时候有返回
		String prepayId = result.get("prepay_id");
		Map<String, String> packageParams = WxPayKit.miniAppPrepayIdCreateSign(wxPayApiConfig.getAppId(), prepayId,
			wxPayApiConfig.getPartnerKey(), SignType.MD5);
		String jsonStr = JSON.toJSONString(packageParams);
		log.info("小程序支付的参数:" + jsonStr);
		return new SuccessResponseData(jsonStr);
	}

	@RequestMapping(value = "/queryOrder", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String queryOrder(@RequestParam(value = "transactionId", required = false) String transactionId, @RequestParam(value = "outTradeNo", required = false) String outTradeNo) {
		try {
			WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

			Map<String, String> params = OrderQueryModel.builder()
				.appid(wxPayApiConfig.getAppId())
				.mch_id(wxPayApiConfig.getMchId())
				.transaction_id(transactionId)
				.out_trade_no(outTradeNo)
				.nonce_str(WxPayKit.generateStr())
				.build()
				.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);
			log.info("请求参数：{}", WxPayKit.toXml(params));
			String query = WxPayApi.orderQuery(params);
			log.info("查询结果: {}", query);
			return query;
		} catch (Exception e) {
			e.printStackTrace();
			return "系统错误";
		}
	}

	/**
	 * 企业付款到零钱
	 */
	@RequestMapping(value = "/transfer", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String transfer(HttpServletRequest request, @RequestParam("openId") String openId) {

		String ip = IpKit.getRealIp(request);
		if (StrUtil.isBlank(ip)) {
			ip = "127.0.0.1";
		}

		WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

		Map<String, String> params = TransferModel.builder()
			.mch_appid(wxPayApiConfig.getAppId())
			.mchid(wxPayApiConfig.getMchId())
			.nonce_str(WxPayKit.generateStr())
			.partner_trade_no(WxPayKit.generateStr())
			.openid(openId)
			.check_name("NO_CHECK")
			.amount("100")
			.desc("IJPay 让支付触手可及-企业付款")
			.spbill_create_ip(ip)
			.build()
			.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5, false);

		// 提现
		String transfers = WxPayApi.transfers(params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());
		log.info("提现结果:" + transfers);
		Map<String, String> map = WxPayKit.xmlToMap(transfers);
		String returnCode = map.get("return_code");
		String resultCode = map.get("result_code");
		if (WxPayKit.codeIsOk(returnCode) && WxPayKit.codeIsOk(resultCode)) {
			// 提现成功
		} else {
			// 提现失败
		}
		return transfers;
	}

	/**
	 * 查询企业付款到零钱
	 */
	@RequestMapping(value = "/transferInfo", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String transferInfo(@RequestParam("partner_trade_no") String partnerTradeNo) {
		try {
			WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

			Map<String, String> params = GetTransferInfoModel.builder()
				.nonce_str(WxPayKit.generateStr())
				.partner_trade_no(partnerTradeNo)
				.mch_id(wxPayApiConfig.getMchId())
				.appid(wxPayApiConfig.getAppId())
				.build()
				.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5, false);

			return WxPayApi.getTransferInfo(params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	/**
	 * 获取RSA加密公钥
	 */
	@RequestMapping(value = "/getPublicKey", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String getPublicKey() {
		try {
			WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

			Map<String, String> params = new HashMap<String, String>(4);
			params.put("mch_id", wxPayApiConfig.getMchId());
			params.put("nonce_str", String.valueOf(System.currentTimeMillis()));
			params.put("sign_type", "MD5");
			String createSign = WxPayKit.createSign(params, wxPayApiConfig.getPartnerKey(), SignType.MD5);
			params.put("sign", createSign);
			return WxPayApi.getPublicKey(params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	/**
	 * 企业付款到银行卡
	 */
	@RequestMapping(value = "/payBank", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String payBank() {
		try {
			WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

			//通过WxPayApi.getPublicKey接口获取RSA加密公钥
			//假设获取到的RSA加密公钥为PUBLIC_KEY(PKCS#8格式)
			final String PUBLIC_KEY = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEA6Bl76IwSvBTiibZ+CNRUA6BfahMshZ0WJpHD1GpmvcQjeN6Yrv6c9eIl6gB4nU3isN7bn+LmoVTpH1gHViaV2YyG/zXj4z4h7r+V+ezesMqqorEg38BCNUHNmhnw4/C0I4gBAQ4x0SJOGnfKGZKR9yzvbkJtvEn732JcEZCbdTZmaxkwlenXvM+mStcJaxBCB/h5xJ5VOF5nDbTPzLphIpzddr3zx/Jxjna9QB1v/YSKYXn+iuwruNUXGCvvxBWaBGKrjOdRTRy9adWOgNmtuYDQJ2YOfG8PtPe06ELKjmr2CfaAGrKKUroyaGvy3qxAV0PlT+UQ4ADSXWt/zl0o5wIDAQAB";

			Map<String, String> params = new HashMap<String, String>(10);
			params.put("mch_id", wxPayApiConfig.getMchId());
			params.put("partner_trade_no", System.currentTimeMillis() + "");
			params.put("nonce_str", System.currentTimeMillis() + "");
			//收款方银行卡号
			params.put("enc_bank_no", RsaKit.encryptByPublicKeyByWx("银行卡号", PUBLIC_KEY));
			//收款方用户名
			params.put("enc_true_name", RsaKit.encryptByPublicKeyByWx("银行卡持有人姓名", PUBLIC_KEY));
			//收款方开户行
			params.put("bank_code", "1001");
			params.put("amount", "1");
			params.put("desc", "IJPay 让支付触手可及-付款到银行卡");
			params.put("sign", WxPayKit.createSign(params, wxPayApiConfig.getPartnerKey(), SignType.MD5));
			return WxPayApi.payBank(params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	/**
	 * 查询企业付款到银行
	 */
	@RequestMapping(value = "/queryBank", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String queryBank(@RequestParam("partner_trade_no") String partnerTradeNo) {
		try {
			WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

			Map<String, String> params = new HashMap<String, String>(4);
			params.put("mch_id", wxPayApiConfig.getMchId());
			params.put("partner_trade_no", partnerTradeNo);
			params.put("nonce_str", System.currentTimeMillis() + "");
			params.put("sign", WxPayKit.createSign(params, wxPayApiConfig.getPartnerKey(), SignType.MD5));
			return WxPayApi.queryBank(params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	/**
	 * 添加分账接收方
	 */
	@RequestMapping(value = "/profitSharingAddReceiver", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String profitSharingAddReceiver() {
		try {
			ReceiverModel receiver = ReceiverModel.builder()
				.type("PERSONAL_OPENID")
				.account("openid")
				.relation_type("PARTNER")
				.build();

			Map<String, String> params = ProfitSharingModel.builder()
				.mch_id(wxPayBean.getMchId())
				.appid(wxPayBean.getAppId())
				.nonce_str(WxPayKit.generateStr())
				.receiver(JSON.toJSONString(receiver))
				.build()
				.createSign(wxPayBean.getPartnerKey(), SignType.MD5);
			log.info("请求参数:{}", WxPayKit.toXml(params));
			String result = WxPayApi.profitSharingAddReceiver(params);
			log.info("请求结果:{}", result);
			return JSON.toJSONString(WxPayKit.xmlToMap(result));
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	/**
	 * 请求单次分账
	 */
	@RequestMapping(value = "/profitSharing", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String profitSharing(@RequestParam(value = "transactionId") String transactionId) {
		List<ReceiverModel> list = new ArrayList<>();

		list.add(ReceiverModel.builder()
			.type("PERSONAL_OPENID")
			.account("openid")
			.amount(66)
			.description("IJPay 分账")
			.build());

		Map<String, String> params = ProfitSharingModel.builder()
			.mch_id(wxPayBean.getMchId())
			.appid(wxPayBean.getAppId())
			.nonce_str(WxPayKit.generateStr())
			.transaction_id(transactionId)
			.out_order_no(WxPayKit.generateStr())
			.receivers(JSON.toJSONString(list))
			.build()
			.createSign(wxPayBean.getPartnerKey(), SignType.MD5);

		log.info("请求参数:{}", WxPayKit.toXml(params));
		String result = WxPayApi.profitSharing(params, wxPayBean.getCertPath(), wxPayBean.getMchId());
		log.info("请求结果:{}", result);
		return JSON.toJSONString(WxPayKit.xmlToMap(result));
	}


	/**
	 * 微信退款
	 */
	@ApiOperation("微信退款")
	@RequestMapping(value = RuleConstants.NOT_LOGIN+"/refund", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String refund(@RequestParam(value = "transactionId", required = false) String transactionId,
						 @RequestParam(value = "outTradeNo", required = false) String outTradeNo) {
		try {
			log.info("transactionId: {} outTradeNo:{}", transactionId, outTradeNo);

			if (StrUtil.isBlank(outTradeNo) && StrUtil.isBlank(transactionId)) {
				return "transactionId、out_trade_no二选一";
			}
			WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

			RefundModel refundModel = RefundModel.builder()
				.appid(wxPayApiConfig.getAppId())
				.mch_id(wxPayApiConfig.getMchId())
				.nonce_str(WxPayKit.generateStr())
				.transaction_id(transactionId)
				.out_trade_no(outTradeNo)
				.out_refund_no(WxPayKit.generateStr())
				.total_fee("1")
				.refund_fee("1")
				.notify_url(refundNotifyUrl)
				.build();

			if (outTradeNo.startsWith(OrderTypeEnum.COURSE_ORDER.getCode())) {
				//课程订单
				CourseOrder courseOrder = this.courseOrderService.getCourseOrderByNo(outTradeNo);
				//状态：0待支付,1已支付,2已过期,9取消,10退款
				if (courseOrder.getStatusFlag().intValue() == 1){
					refundModel.setTotal_fee(courseOrder.getPayAmount().toString());
					refundModel.setRefund_fee(courseOrder.getPayAmount().toString());

				}

			} else if (outTradeNo.startsWith(OrderTypeEnum.COUNSELLING_ORDER.getCode())) {
				//咨询订单
				CounsellingOrder counsellingOrder = this.counsellingOrderService.getCounsellingOrderByNo(outTradeNo);
				//状态：0待支付，1已支付，2已完成,9取消,10退款
//				if (counsellingOrder.getStatusFlag().intValue() == 1){
					refundModel.setTotal_fee(counsellingOrder.getPayAmount().toString());
					refundModel.setRefund_fee(counsellingOrder.getPayAmount().toString());
//				}
			}
			Map<String,String> params = refundModel.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);
			String refundStr = WxPayApi.orderRefund(false, params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());

			log.info("refundStr: {}", refundStr);
			return refundStr;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	/**
	 * 微信退款查询
	 */
	@RequestMapping(value = "/refundQuery", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String refundQuery(@RequestParam("transactionId") String transactionId,
							  @RequestParam("out_trade_no") String outTradeNo,
							  @RequestParam("out_refund_no") String outRefundNo,
							  @RequestParam("refund_id") String refundId) {

		WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

		Map<String, String> params = RefundQueryModel.builder()
			.appid(wxPayApiConfig.getAppId())
			.mch_id(wxPayApiConfig.getMchId())
			.nonce_str(WxPayKit.generateStr())
			.transaction_id(transactionId)
			.out_trade_no(outTradeNo)
			.out_refund_no(outRefundNo)
			.refund_id(refundId)
			.build()
			.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);

		return WxPayApi.orderRefundQuery(false, params);
	}

	/**
	 * 退款通知
	 */
	@RequestMapping(value = RuleConstants.NOT_LOGIN+"/refundNotify", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String refundNotify(HttpServletRequest request) {
		String xmlMsg = HttpKit.readData(request);
		log.info("退款通知=" + xmlMsg);
		Map<String, String> params = WxPayKit.xmlToMap(xmlMsg);

		String returnCode = params.get("return_code");
		// 注意重复通知的情况，同一订单号可能收到多次通知，请注意一定先判断订单状态
		if (WxPayKit.codeIsOk(returnCode)) {
			String reqInfo = params.get("req_info");
			String decryptData = WxPayKit.decryptData(reqInfo, WxPayApiConfigKit.getWxPayApiConfig().getPartnerKey());
			log.info("退款通知解密后的数据=" + decryptData);
			Map<String,String> requestMap = JSONObject.parseObject(decryptData,HashMap.class);
			String outTradeNo = requestMap.get("out_trade_no");
			// 更新订单信息
			if (outTradeNo.startsWith(OrderTypeEnum.COURSE_ORDER.getCode())) {
				//课程订单
				CourseOrder courseOrder = this.courseOrderService.getCourseOrderByNo(outTradeNo);
				courseOrder.setStatusFlag(9);
				courseOrder.setRefundTime(new Date());
				courseOrder.setRefundAmount(courseOrder.getPayAmount());
				this.courseOrderService.update(new LambdaUpdateWrapper<CourseOrder>()
						.set(CourseOrder::getStatusFlag,9).set(CourseOrder::getRefundTime,new Date())
						.set(CourseOrder::getRefundAmount,courseOrder.getPayAmount())
						.eq(CourseOrder::getId,courseOrder.getId()));


			} else if (outTradeNo.startsWith(OrderTypeEnum.COUNSELLING_ORDER.getCode())) {
				//咨询订单
				CounsellingOrder counsellingOrder = this.counsellingOrderService.getCounsellingOrderByNo(outTradeNo);
				counsellingOrder.setStatusFlag(9);
				counsellingOrder.setRefundTime(new Date());
				counsellingOrder.setRefundAmount(counsellingOrder.getPayAmount());
				this.counsellingOrderService.update(new LambdaUpdateWrapper<CounsellingOrder>()
						.set(CounsellingOrder::getStatusFlag,9).set(CounsellingOrder::getRefundTime,new Date())
						.set(CounsellingOrder::getRefundAmount,counsellingOrder.getPayAmount())
						.eq(CounsellingOrder::getId,counsellingOrder.getId()));
			}
			// 发送通知等
			Map<String, String> xml = new HashMap<String, String>(2);
			xml.put("return_code", "SUCCESS");
			xml.put("return_msg", "OK");
			return WxPayKit.toXml(xml);
		}
		return null;
	}


	@RequestMapping(value = "/sendRedPack", method = {RequestMethod.POST, RequestMethod.GET})
	@ResponseBody
	public String sendRedPack(HttpServletRequest request, @RequestParam("openId") String openId) {
		try {
			String ip = IpKit.getRealIp(request);
			if (StrUtil.isBlank(ip)) {
				ip = "127.0.0.1";
			}

			WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();

			Map<String, String> params = SendRedPackModel.builder()
				.nonce_str(WxPayKit.generateStr())
				.mch_billno(WxPayKit.generateStr())
				.mch_id(wxPayApiConfig.getMchId())
				.wxappid(wxPayApiConfig.getAppId())
				.send_name("IJPay 红包测试")
				.re_openid(openId)
				.total_amount("1000")
				.total_num("1")
				.wishing("感谢您使用 IJPay")
				.client_ip(ip)
				.act_name("感恩回馈活动")
				.remark("点 start 送红包，快来抢!")
				.build()
				.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);
			String result = WxPayApi.sendRedPack(params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());
			System.out.println("发送红包结果:" + result);
			Map<String, String> map = WxPayKit.xmlToMap(result);
			return JSON.toJSONString(map);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}
}