微信支付插件

你的名字 2021-09-27 05:22 372阅读 0赞

package com.qxwljs.app.waiter.component.plugin.paymentWeixin;

import java.io.IOException;  
import java.math.BigDecimal;  
import java.util.HashMap;  
import java.util.Map;  
import java.util.TreeMap;

import javax.servlet.http.HttpServletRequest;  
import javax.servlet.http.HttpServletResponse;

import org.dom4j.Document;  
import org.dom4j.DocumentException;  
import org.dom4j.io.SAXReader;  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.stereotype.Component;

import com.qxwljs.app.cms.payment.model.PayCfg;  
import com.qxwljs.app.cms.payment.model.PayEnable;  
import com.qxwljs.app.cms.payment.plugin.AbstractPaymentPlugin;  
import com.qxwljs.app.cms.payment.plugin.IPaymentEvent;  
import com.qxwljs.app.shop.core.order.model.Order;  
import com.qxwljs.app.shop.core.order.service.IOrderManager;  
import com.qxwljs.app.weixin.component.payment.plugin.WeixinUtil;  
import com.qxwljs.framework.context.webcontext.ThreadContextHolder;  
import com.qxwljs.framework.util.CurrencyUtil;  
import com.qxwljs.framework.util.DateUtil;  
import com.qxwljs.framework.util.StringUtil;  
import com.qxwljs.jxp.SystemSetting;  
import com.qxwljs.jxp.resource.model.JxpSite;

@Component  
public class AppWeixinPaymentPlugin extends AbstractPaymentPlugin implements IPaymentEvent \{  
      
    @Autowired  
    protected IOrderManager orderManager;  
      
    @SuppressWarnings(\{ "unchecked", "rawtypes" \})  
    @Override  
    public String onPay(PayCfg payCfg, PayEnable order) \{    
        Map<String, String> cfgparams = paymentManager.getConfigParams(this.getId());  
        String mchid = cfgparams.get("mch\_id");  
        String appid = cfgparams.get("appid");  
        String key = cfgparams.get("key");  
      
        HttpServletRequest request = ThreadContextHolder.getHttpRequest();  
      
      
        Map params = new TreeMap();  
        params.put("appid", appid);  
        params.put("mch\_id", mchid);  
        params.put("key", key);  
        String nonce\_str = StringUtil.getRandStr(10);  
        params.put("nonce\_str", nonce\_str);  
        String original\_sn=order.getSn();  
        String orderName = JxpSite.getInstance().getSitename();  
        String body = orderName+"订单\["+ original\_sn +"\]";  
//        String body =original\_sn ;  
        params.put("body", body);  
        String OrderNo=order.getSn()+StringUtil.getRandStr(6);//"20141104000003789253";  
        params.put("out\_trade\_no",OrderNo);  
      
        // 应付转为分  
        Double money = order.getNeedPayMoney();  
        params.put("total\_fee", toFen(money));  
        params.put("spbill\_create\_ip", request.getRemoteAddr());  
        System.out.println("-----"  + this.getCallBackUrl(payCfg, order));  
        params.put("notify\_url", this.getCallBackUrl(payCfg, order));  
        params.put("trade\_type", "APP");  
      
        String sign = WeixinUtil.createSign(params, key);  
        params.put("sign", sign);  
        String result = "";  
        String xml = "";  
        String re = params.toString();  
        try \{  
             xml = WeixinUtil.mapToXml(params);  
//            System.out.println(xml);  
//            Document resultDoc = WeixinUtil.post(  
//                    "https://api.mch.weixin.qq.com/pay/unifiedorder", xml);  
//            Element rootEl = resultDoc.getRootElement();  
//            String return\_code = rootEl.element("return\_code").getText(); // 返回码  
//            if ("SUCCESS".equals(return\_code)) \{  
//  
//                String result\_code = rootEl.element("result\_code").getText(); // 业务码  
//  
//                if ("SUCCESS".equals(result\_code)) \{  
//                    String prepay\_id = rootEl.element("prepay\_id").getText(); // 预支付订单id  
//                      
//                    result = this.getPayScript(mchid,prepay\_id, appid, key,original\_sn,nonce\_str);  
//  
//                \} else \{  
//                      
//                    String err\_code = rootEl.element("err\_code").getText();  
//                    String err\_code\_des = rootEl.element("err\_code\_des").getText();  
//                      
//                    result = "支付意外错误，请联系技术人员:"  
//                            + err\_code + "【"+err\_code\_des+"】'";  
//                \}  
//            \} else \{  
//                  
//                if ("FAIL".equals(return\_code)) \{  
//                    String return\_msg = resultDoc.getRootElement()  
//                            .element("return\_msg").getText(); // 错误信息  
//                    this.logger.error("微信端返回错误" + return\_code + "\["  
//                            + return\_msg + "\]");  
//                    this.logger.debug("-----------post xml-----------");  
//                    this.logger.debug(xml);  
//                    result = "'支付意外错误，请联系技术人员:" + return\_code + " 【" + return\_msg + "】'";  
//                \}else \{  
//                    result = "'支付意外错误，请联系技术人员:" + return\_code + "'";  
//                \}  
//                  
//            \}  
              
              
              
        \} catch (RuntimeException e) \{  
            this.logger.error("支付意外错误", e);  
        \}  
        System.out.println(re);  
        return re;  
    \}  
      
    private String toFen(Double money) \{  
        money = CurrencyUtil.mul(money, 100);  
        BigDecimal bg=new BigDecimal(money);    
        String str = bg.toPlainString();  
        return str;  
    \}  
      
      
    /\*\*  
     \* 获取wap的url  
     \* @return  
     \*/  
    public static String getWapDomainUrl()\{  
        HttpServletRequest request = ThreadContextHolder.getHttpRequest();  
        int port = request.getServerPort();  
          
        String portstr="";  
        if(port!=80)\{  
            portstr=":"+port;  
        \}  
        String contextPath = request.getContextPath();  
        if(contextPath.equals("/"))\{  
            contextPath="";  
        \}  
       
        String severname= SystemSetting.getWap\_domain();  
        String url  = "http://"+severname+portstr+contextPath;  
        return url;  
          
    \}  
      
    /\*\*  
     \* 生成支付的脚本  
     \*   
     \* @param prepay\_id  
     \*            预支付订单id  
     \* @return  
     \*/  
    private String getPayScript(String partnerid,String prepay\_id, String appid, String weixinkey,String original\_sn,String nonce\_str) \{

Map<String, String> params = new TreeMap();  
        params.put("appId", appid);  
        params.put("partnerid", partnerid);  
        params.put("prepayid", prepay\_id);  
//        params.put("nonceStr", StringUtil.getRandStr(10));  
        params.put("nonceStr", nonce\_str);  
        params.put("timeStamp", String.valueOf(DateUtil.getDateline()));  
        params.put("package", "Sign=WXPay");  
        String sign = WeixinUtil.createSign(params, weixinkey);  
        params.put("sign", sign);  
        String result = WeixinUtil.mapToXml(params);  
        return result;  
    \}

//成功后的回调  
    @Override  
    public String onCallBack(String ordertype) \{  
        Map<String, String> cfgparams = paymentManager.getConfigParams(this  
                .getId());  
        String key = cfgparams.get("key");

HttpServletRequest request = ThreadContextHolder.getHttpRequest();  
        Map map = new HashMap();

try \{  
            SAXReader saxReadr = new SAXReader();  
            Document document = saxReadr.read(request.getInputStream());

/\*\* 调试时可以打开下面注释 ，以观察通知的xml内容 \*\*/  
            // String docstr = WeixinUtil.doc2String(document);  
            // this.logger.debug("--------post xml-------");  
            // this.logger.debug(docstr);  
            // this.logger.debug("--------end-------");  
            System.err.println("ordertype+"+ordertype);  
            Map<String, String> params = WeixinUtil.xmlToMap(document);  
            System.err.println("params+"+params);

String return\_code = params.get("return\_code");  
            String result\_code = params.get("result\_code");  
            System.err.println("return\_code+"+return\_code+"-----result\_code---"+result\_code);  
            if ("SUCCESS".equals(return\_code) && "SUCCESS".equals(result\_code)) \{  
                String ordersn = params.get("out\_trade\_no");  
                String total\_fee = params.get("total\_fee");

String sign = WeixinUtil.createSign(params, key);  
                if (sign.equals(params.get("sign"))) \{  
                    ordersn=ordersn.substring(0, ordersn.length()-6);  
                    Order order = orderManager.get(ordersn);  
                    if(order.getNeed\_pay\_money()<=Double.valueOf(total\_fee)\*0.01)\{  
                        System.out.println("order.getNeed\_pay\_money()----"+order.getNeed\_pay\_money());  
                        System.out.println("Integer.valueOf(total\_fee)----"+Double.valueOf(total\_fee));  
                        System.out.println(order.getNeed\_pay\_money()<=Double.valueOf(total\_fee)\*0.01);  
                        System.out.println("开始判断");  
                        this.paySuccess(ordersn, "", "app",ordertype);  
                    \}else\{  
                        map.put("return\_code", "FAIL");  
                        map.put("return\_msg", "");  
                    \}  
                    map.put("return\_code", "SUCCESS");  
                    this.logger.debug("签名校验成功");  
                \} else \{  
                    this.logger.debug("-----------签名校验失败---------");  
                    this.logger.debug("weixin sign:" + params.get("sign"));  
                    this.logger.debug("my sign:" + sign);  
                    map.put("return\_code", "FAIL");  
                    map.put("return\_msg", "参数错误");  
                \}  
            \} else \{  
                map.put("return\_code", "FAIL");  
                this.logger.debug("微信通知的结果为失败");  
            \}

\} catch (IOException e) \{  
            map.put("return\_code", "FAIL");  
            map.put("return\_msg", "");  
            e.printStackTrace();  
        \} catch (DocumentException e) \{  
            map.put("return\_code", "FAIL");  
            map.put("return\_msg", "");  
            e.printStackTrace();  
        \}  
        HttpServletResponse response = ThreadContextHolder.getHttpResponse();  
        response.setHeader("Content-Type", "text/xml");  
        return WeixinUtil.mapToXml(map);  
    \}  
      
      
      
    @Override  
    public String onReturn(String ordertype) \{  
          
        return null;  
    \}

@Override  
    public String getId() \{

return "appWeixinPaymentPlugin";  
    \}

@Override  
    public String getName() \{  
        return "微信APP支付";  
    \}  
      
\}