java后台对接微信支付 -

Shuhui

浏览: 5701 次
性别:
来自: 成都

最近访客更多访客>>

linisbeauty

海角醉客-zsl

bugyun

mengx

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

java后台对接微信支付

//    MCH_ID = '';//商户ID
//    KEY = '';//商户key
public JSONObject createUnifiedOrder(String orderCode,String openid,String amount) throws Exception {
        //设置最终返回对象
        JSONObject resultJson = new JSONObject();
    
        //接口调用总金额单位为分换算一下(测试金额改成1,单位为分则是0.01,根据自己业务场景判断是转换成float类型还是int类型)
        
        BigDecimal amountFen = new BigDecimal(amount);
        BigDecimal fen = new BigDecimal(100);
        BigDecimal amountFen100 = amountFen.multiply(fen);
        
        BigDecimal setScale = amountFen100.setScale(0,BigDecimal.ROUND_HALF_DOWN);
        
        //创建hashmap(用户获得签名)
        SortedMap<String, String> paraMap = new TreeMap<String, String>();
        //设置body变量 (支付成功显示在微信支付 商品详情中)
        String body = "订单编号["+orderCode+"],金额为["+amount+"]";
        //设置随机字符串
        String nonceStr = UUID.randomUUID().toString().replaceAll("-", "");
        
        //设置请求参数(小程序ID)
        paraMap.put("appid", "");
        //设置请求参数(商户号)
        paraMap.put("mch_id", "");
        //设置请求参数(随机字符串)
        paraMap.put("nonce_str", nonceStr);
        //设置请求参数(商品描述)
        paraMap.put("body", body);
        //设置请求参数(商户订单号)
        paraMap.put("out_trade_no", orderCode);
        //设置请求参数(总金额)
        paraMap.put("total_fee", setScale.toString());
        //设置请求参数(终端IP)
        paraMap.put("spbill_create_ip", getIpAddress());
        //设置请求参数(通知地址)
        paraMap.put("notify_url", getIpAddress()+":8080/pay/payCallback");
        //设置请求参数(交易类型)
        paraMap.put("trade_type", "JSAPI");
        //设置请求参数(openid)(在接口文档中 该参数 是否必填项 但是一定要注意 如果交易类型设置成'JSAPI'则必须传入openid)
        paraMap.put("openid", openid);
        //调用逻辑传入参数按照字段名的 ASCII 码从小到大排序（字典序）
        String stringA = formatUrlMap(paraMap, false, false);
        //第二步，在stringA最后拼接上key得到stringSignTemp字符串，并对stringSignTemp进行MD5运算，再将得到的字符串所有字符转换为大写，得到sign值signValue。(签名)
        String sign = getMD5String(stringA+"&key="+KEY).toUpperCase();
        //将参数 编写XML格式
        StringBuffer paramBuffer = new StringBuffer();
        paramBuffer.append("<xml>");
        paramBuffer.append("<appid>"+BaseAppInfoMap.getInstance().findAppid()+"</appid>");
        paramBuffer.append("<mch_id>"+MCH_ID+"</mch_id>");
        paramBuffer.append("<nonce_str>"+paraMap.get("nonce_str")+"</nonce_str>");
        paramBuffer.append("<sign>"+sign+"</sign>");
        paramBuffer.append("<body>"+body+"</body>");
        paramBuffer.append("<out_trade_no>"+paraMap.get("out_trade_no")+"</out_trade_no>");
        paramBuffer.append("<total_fee>"+paraMap.get("total_fee")+"</total_fee>");
        paramBuffer.append("<spbill_create_ip>"+paraMap.get("spbill_create_ip")+"</spbill_create_ip>");
        paramBuffer.append("<notify_url>"+paraMap.get("notify_url")+"</notify_url>");
        paramBuffer.append("<trade_type>"+paraMap.get("trade_type")+"</trade_type>");
        paramBuffer.append("<openid>"+openid+"</openid>");
        paramBuffer.append("</xml>");
        
            //发送请求(POST)(获得数据包ID)(这有个注意的地方 如果body中 包含中文,需要对请求进行编码.)
        	
    	String map = getRestTemplateInstance("utf-8").postForObject(payUrl, paramBuffer.toString(), String.class);
    	
        Map<String,String> parseObject = doXMLParse(map);
        //应该创建 支付表数据
        if(parseObject != null){
                log.info("微信 统一下单 接口调用成功 新增支付信息 :"+paraMap.get("out_trade_no"));
                resultJson.put("prepayId", parseObject.get("prepay_id"));
                resultJson.put("outTradeNo", paraMap.get("out_trade_no"));
                
                String sql = " Update orders set transaction ='"+parseObject.get("prepay_id") +"' where orderCode = "+paraMap.get("out_trade_no");
                dao.update(sql);
                
                return resultJson;
        }
            //将 数据包ID 返回
            
        return resultJson;
    }

    public RestTemplate getRestTemplateInstance(String charset) {
    	
        List<HttpMessageConverter<?>> list = restTemplate.getMessageConverters();
        for (HttpMessageConverter<?> httpMessageConverter : list) {
            if(httpMessageConverter instanceof StringHttpMessageConverter) {
                ((StringHttpMessageConverter) httpMessageConverter).setDefaultCharset(Charset.forName(charset));
                break;
            }
        }
        return restTemplate;
    }

    private String getIpAddress() {
    	InetAddress address = null;;
		try {
			address = InetAddress.getLocalHost();
		} catch (UnknownHostException e) {
			e.printStackTrace();
		}
    	return address.getHostAddress();
		/*        // 避免反向代理不能获取真实地址, 取X-Forwarded-For中第一个非unknown的有效IP字符串
		String ip = request.getHeader("x-forwarded-for");
		       if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)){
		   ip = request.getHeader("Proxy-Client-IP");
		       }
		       if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)){
		   ip = request.getHeader("WL-Proxy-Client-IP");
		       }
		       if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)){
		   ip = request.getRemoteAddr();
		       }
		return ip;*/
    }

 private  InputStream String2Inputstream(String str) {
        return new ByteArrayInputStream(str.getBytes());
    }
    @SuppressWarnings("rawtypes")
    private String getChildrenText(List children) {
        StringBuffer sb = new StringBuffer();
        if(!children.isEmpty()) {
            Iterator it = children.iterator();
            while(it.hasNext()) {
                Element e = (Element) it.next();
                String name = e.getName();
                String value = e.getTextNormalize();
                List list = e.getChildren();
                sb.append("<" + name + ">");
                if(!list.isEmpty()) {
                    sb.append(getChildrenText(list));
                }
                sb.append(value);
                sb.append("</" + name + ">");
            }
        }
        
        return sb.toString();
    }
    
    private String getMD5String(String str) {
        try {
            // 生成一个MD5加密计算摘要
            MessageDigest md = MessageDigest.getInstance("MD5");
            // 计算md5函数
            md.update(str.getBytes());
            // digest()最后确定返回md5 hash值，返回值为8位字符串。因为md5 hash值是16位的hex值，实际上就是8位的字符
            // BigInteger函数则将8位的字符串转换成16位hex值，用字符串来表示；得到字符串形式的hash值
            //一个byte是八位二进制，也就是2位十六进制字符（2的8次方等于16的2次方）
            return new BigInteger(1, md.digest()).toString(16);
        } catch (Exception e) {
           e.printStackTrace();
           return null;
        }
    }
    
    private String formatUrlMap(Map<String, String> paraMap, boolean urlEncode, boolean keyToLower){  
        String buff = "";  
        Map<String, String> tmpMap = paraMap;  
        try{  
            List<Map.Entry<String, String>> infoIds = new ArrayList<Map.Entry<String, String>>(tmpMap.entrySet());  
            // 对所有传入参数按照字段名的 ASCII 码从小到大排序（字典序）  
            Collections.sort(infoIds, new Comparator<Map.Entry<String, String>>(){  
                @Override  
                public int compare(Map.Entry<String, String> o1, Map.Entry<String, String> o2){  
                    return (o1.getKey()).toString().compareTo(o2.getKey());  
                }  
            });  
            // 构造URL 键值对的格式  
            StringBuilder buf = new StringBuilder();  
            for (Map.Entry<String, String> item : infoIds){  
                if (StringUtils.isNotBlank(item.getKey())){  
                    String key = item.getKey();  
                    String val = item.getValue();  
                    if (urlEncode){  
                        val = URLEncoder.encode(val, "utf-8");  
                    }  
                    if(keyToLower){  
                        buf.append(key.toLowerCase() + "=" + val);  
                    }else{  
                        buf.append(key + "=" + val);  
                    }  
                    buf.append("&");  
                }  
            }  
            buff = buf.toString();  
            if (buff.isEmpty() == false){  
                buff = buff.substring(0, buff.length() - 1);  
            }  
        } catch (Exception e){  
           return null;  
        }  
        return buff;  
    }

@SuppressWarnings("rawtypes")
    private Map<String,String> doXMLParse(String strxml) throws JDOMException, IOException{
        if(null == strxml || "".equals(strxml)) {
            return null;
        }
        
        Map<String,String> m = new HashMap<String,String>();
        InputStream in = String2Inputstream(strxml);
        SAXBuilder builder = new SAXBuilder();
        Document doc = builder.build(in);
        Element root = doc.getRootElement();
        List list = root.getChildren();
        Iterator it = list.iterator();
        while(it.hasNext()) {
            Element e = (Element) it.next();
            String k = e.getName();
            String v = "";
            List children = e.getChildren();
            if(children.isEmpty()) {
                v = e.getTextNormalize();
            } else {
                v = getChildrenText(children);
            }
            
            m.put(k, v);
        }
        
        //关闭流
        in.close();
        
        return m;
    }

分享到：