java实现微信企业付款到个人零钱(微信红包)

标签: 微信企业付款  微信企业发红包  java微信红包算法

        今天公司打算做一个活动,就是可以让用户领取平台发送的红包,根据微信官方文档实现微信企业付款到零钱(因为商户号不满足一些条件无法使用红包,红包跟零钱实现方法基本一样),然后又加入了一些简单的红包算法。微信官方文档地址:https://pay.weixin.qq.com/wiki/doc/api/tools/mch_pay.php?chapter=14_1

        红包发送的规则:总共有100个红包,总金额100元,最小红包0.05,最大红包3,也就是说100元,发100次基本上能领完。红包领取的规则:在移动端页面上展示红包,用户领取的时候,调用后台接口领取红包(一些领取规则可以自己添加)。

        零钱(红包)发放接口如下

    @ResponseBody
    @RequestMapping("wxSendWallet")
    public void wxSendWallet(String openid) {
        //微信金额的单位是分 所以这里要*100 
        float money = getRedPack();
        BigDecimal df = new BigDecimal(money+"");
     	df = df.multiply(new BigDecimal("100"));
     	int fee = df.intValue();
     	//创建一个唯一订单号
        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
        String time = sdf.format(new Date());
     	String orderId = time + (int)(Math.random()*1000000);
        String xml = WeixinCore.wxSendWallet(orderId,openid,String.valueOf(fee));
        try {
        	//指定TLS版本, Allow TLSv1 protocol only
            SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(
                    getSSL(), new String[] { "TLSv1" }, null, SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
            //设置httpclient的SSLSocketFactory
            CloseableHttpClient httpclient = HttpClients.custom().setSSLSocketFactory(sslsf).build();
            HttpPost httppost = new HttpPost("https://api.mch.weixin.qq.com/mmpaymkttransfers/promotion/transfers");
        	//这里要设置编码,不然xml中有中文的话会提示签名失败或者展示乱码
            httppost.addHeader("Content-Type", "text/xml");
            StringEntity se = new StringEntity(xml,"UTF-8");
            httppost.setEntity(se);
            CloseableHttpResponse responseEntry = httpclient.execute(httppost);
            try {
                HttpEntity entity = responseEntry.getEntity();
                if (entity != null) {
                    System.out.println("响应内容长度 : "+ entity.getContentLength());
                    SAXReader saxReader = new SAXReader();
                    Document document = saxReader.read(entity.getContent());
                    Element rootElt = document.getRootElement();
                    String resultCode = rootElt.elementText("result_code");
                    if(resultCode.equals("SUCCESS")){
                    	//保存红包信息到数据库
                        //保存用户领取记录
                    }else{
                    	System.out.println(rootElt.elementText("err_code_des"));
                    }
                }
                EntityUtils.consume(entity);
            }catch(Exception e){
            	System.out.println("请求失败");
            }
            finally {
                responseEntry.close();
            }
        }catch(Exception e){
        	System.out.println("请求失败");
        }
    }

       getRedPack方法如下, 假如第一次领取(后台获取表示从后台查询所得)

    public float getRedPack(){
		//红包数   (后台获取)
        int number = 100;    
        //剩余红包总额    (后台获取)
        float total = 100;  
		float money = 0f;    
        //最小红包    (后台获取)
        double min = 0.05;    
        //系统最大红包(后台获取)
        float systemMax = 3;
        //最大红包
        double max;
        //剩余领取次数(后台获取)
        int surplusNumber = 100;
        
        //本次领取之后,剩余领取次数减一
        surplusNumber--;
        
        DecimalFormat df = new DecimalFormat("###.##");    
        if (surplusNumber > 0) {     
            //保证即使一个红包是最大的了,后面剩下的红包,每个红包也不会小于最小值      
            max = total - min * surplusNumber;      
            int k = (int)surplusNumber / 2;      
            //保证最后两个人拿的红包不超出剩余红包     
            if (surplusNumber <= 2) {      
                k = surplusNumber;      
            }     
            //最大的红包限定的平均线上下      
            max = max / k;     
            //保证每个红包大于最小值,又不会大于最大值      
            money = (int) (min * 100 + Math.random() * (max * 100 - min * 100 + 1));    
            money = (float)money / 100;     
            //保留两位小数      
            money = Float.parseFloat(df.format(money));    
            //如果红包大于默认最大值,将红包职位默认最大值
            if(money > systemMax){
            	money = systemMax;
            }
            total=(int)(total*100 - money*100);     
            total = total/100;
            System.out.println("第" + (number - surplusNumber) + "个人拿到" + money + "剩下" + total);     
        } else if(surplusNumber == 0){//如果是最后一次,不需要计算
        	//如果最后一次红包超过系统最大红包,设置为系统默认最大红包
        	if(total > systemMax){
        		money = systemMax;
        		total=(int)(total*100 - money*100);
        		total = total/100;
        		System.out.println("最后一个人拿到" + money + "剩下"+total);  
        	}else{
        		money = total;
        		System.out.println("最后一个人拿到" + money + "剩下0");  
        	}
        }else{
        	System.out.println("红包已发放完毕");
        }
        return money;
    }

        进行签名,将参数排序并拼接成xml

    public static String wxSendWallet(String partner_trade_no, String openid,String total_amount) {
        String data = null;
        try {
            String nonceStr = genNonceStr();
            //SortedMap接口主要提供有序的Map实现,默认的排序是根据key值进行升序排序
            SortedMap<String,String> parameters = new TreeMap<String,String>();
            parameters.put("mch_appid", "商户appid");
            parameters.put("mchid", "商户号");
            parameters.put("nonce_str", nonceStr);
            parameters.put("partner_trade_no", partner_trade_no);
            parameters.put("openid", openid);
            parameters.put("check_name", "NO_CHECK");
            parameters.put("amount", total_amount);
            parameters.put("spbill_create_ip", WeChatPayUtil.getLocalIP());
            parameters.put("desc", "福利红包");
            //签名
            parameters.put("sign", createSign(parameters, "商户的key"));
            data =SortedMaptoXml(parameters);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return data;
    }

getLocalIp() 获取ip地址

    public static String getLocalIP() {   
        InetAddress addr = null;   
        try {
            addr = InetAddress.getLocalHost();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }         
        byte[] ipAddr = addr.getAddress();   
        String ipAddrStr = "";   
        for (int i = 0; i < ipAddr.length; i++) {   
            if (i > 0) {   
                ipAddrStr += ".";   
            }   
            ipAddrStr += ipAddr[i] & 0xFF;   
        }   
        return ipAddrStr;   
    } 

createSign() 签名算法

    /**
     * @Title: createSign
     * @Description: 签名算法,创建md5摘要,规则是:按参数名称a-z排序,遇到空值的参数不参加签名。
     * 参照:https://pay.weixin.qq.com/wiki/doc/api/tools/mch_pay.php?chapter=4_3
     */
    public static String createSign(SortedMap<String, String> packageParams, String AppKey) {
        StringBuffer sb = new StringBuffer();
        Set es = packageParams.entrySet();
        Iterator it = es.iterator();
        while (it.hasNext()) {
            Map.Entry entry = (Map.Entry) it.next();
            String k = (String) entry.getKey();
            String v = (String) entry.getValue();
            if (null != v && !"".equals(v) && !"sign".equals(k) && !"key".equals(k)) {
                sb.append(k + "=" + v + "&");
            }
        }
        sb.append("key=" + AppKey);
        String sign = MD5Util.MD5Encode(sb.toString(), "UTF-8").toUpperCase();
        return sign;
    }

MD5Encode() 常见md5摘要

    public static String MD5Encode(String origin, String charsetname) {  
           String resultString = null;  
        try {  
            resultString = new String(origin);  
            MessageDigest md = MessageDigest.getInstance("MD5");  
            if (charsetname == null || "".equals(charsetname))  
                resultString = byteArrayToHexString(md.digest(resultString  
                        .getBytes()));  
            else  
                resultString = byteArrayToHexString(md.digest(resultString  
                        .getBytes(charsetname)));  
        } catch (Exception exception) {  
        }  
        return resultString;  
    }

上面的就是整个的逻辑,需要的方法都在这里了,配置好了运行肯定是没问题的,测试的效果如下:

随笔记录一下,如果有问题请留言

版权声明:本文为niu15032144758原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/niu15032144758/article/details/82501202

智能推荐

Java编程思想 第三章:操作符

Java中的操作符和c/c++中的操作符基本一致,因为我之前学习过C语言和C++,所以本章的内容大部分都已熟知,下面只做简单的介绍。 Java操作符及优先级 Java中的操作符包括算术操作符,关系操作符,逻辑操作符,位运算符、自操作运算符、移位运算符、赋值运算符和其他运算符。 算术操作符:包括加减乘除和取余(%),优先级乘除取余高于加减,都是双元运算符,其中加法(+)可以用来连接两个字符串,比如:...

JetBrains 系列开发工具,如何配置 `SCSS` `File Watcher` ,相关输出配置参数详解:webStorm phpStorm IDEA

JetBrains 系列开发工具,如何配置 SCSS File Watcher ,相关输出配置参数详解:webStorm phpStorm IDEA 前言 你目前已经了解了如何使用 SCSS 进行开发,了解了该文章的内容:『 SCSS 日常用法 』 在 JetBrains 系列开发工具中通过 FileWatcher 进行编译的 SCSS 文件都是通过 sass 这个程序进行的。『 如何添加 Fil...

C语言小函数—二进制与十六进制

测试如下 “` int main() { long int num = 15; } “`...

仿微博或微信的文章多图显示(自定义MultiImageView)

按照一般的规矩,先上张图来供大伙看看 如果大致是大伙们需要实现的功能,不烦一观 自定义MultiImageView 工具类 具体使用 app.gradle中添加依赖 implementation 'com.github.bumptech.glide:glide:4.8.0' AndroidManifest.xml中配置联网权限 <uses-permission android:name=&q...

经典进程同步和互斥问题

经典进程同步与互斥问题 前言 一、生产者-消费者问题 1.问题描述 2.问题分析 3.代码 二、读者-写者问题 1.问题描述&&分析 2.代码 三、哲学家进餐问题 1.问题描述&&分析 2.代码 四、理发师问题 1.问题描述&&分析 2.代码 前言 在多道程序设计环境中,进程同步是一个非常重要的问题,下面讨论几个经典的进程同步问题。 一、生产者-消费...

猜你喜欢

java设计模式——ThreadLocal线程单例

1、定义一个ThreadLocal线程单例,代码如下: 2、定义一个多线程类,代码如下: 3、定义一个测试类,代码如下: 4、输出结果,如下图:...

【tensorflow】线性模型实战

线性模型:y = 1.477 * x + 0.089   1. 采样数据 采样噪声eps在均值0,方差0.01的高斯分布中,而后在均匀分布U(0,1)中,区间[-10,10]进行n=100次随机采样:   2. 计算误差 循环计算每个点的预测值与真是值之间差的平方并累加,从而获得训练集上的均芳误差损失值。   3. 计算梯度   4. 梯度更新 对权重w和偏...

常见损失函数和评价指标总结(附公式&代码)

网上看到一篇很实用的帖子关于常见损失函数和评价指标,收藏下来 本文转载于https://zhuanlan.zhihu.com/p/91511706 ------------------------------------------------------------------------------------------------------------------------------...

为什么 4G/5G 的直播延时依然很高

通信技术的发展促进了视频点播和直播业务的兴起,4G 和 5G 网络技术的进步也使得流媒体技术变得越来越重要,但是网络技术并不能解决流媒体直播的高延迟问题。 本文不会介绍网络对直播业务的影响,而是会分析直播中常见的现象 — 主播和观众之间能够感觉到的明显网络延迟。除了业务上要求的延迟直播之外,有哪些因素会导致视频直播的延迟这么高呢? live-streaming  图 1 - ...

springboot 过滤器Filter vs 拦截器Interceptor 详解

1 前言       最近接触到了过滤器和拦截器,网上查了查资料,这里记录一下,这篇文章就来仔细剖析下过滤器和拦截器的区别与联系。 2 拦截器与过滤器之间的区别 从上面对拦截器与过滤器的描述来看,它俩是非常相似的,都能对客户端发来的请求进行处理,它们的区别如下: 作用域不同 过滤器依赖于servlet容器,只能在 servlet容器,web环境下使用 拦截器依赖于sp...