琼殿技术论坛»首页 › 后端/编程语言论坛 › 公众号/小程序论坛 › JAVA项目实战-微信小程序服务端开发(一)
返回列表 发新帖
查看: 97|回复: 0

[小程序] JAVA项目实战-微信小程序服务端开发(一)

[复制链接]
满霞

2

主题

0

回帖

0

积分

积极分子

金币
0
阅读权限
220
精华
0
威望
0
贡献
0
在线时间
0 小时
注册时间
2010-7-14
发表于 2019-11-15 09:22:00 | 显示全部楼层 |阅读模式

微信小程序越来越普遍,本章将分享给大家,实现微信小程序授权，推送微信通知消息。具体内容可参考微信小程序开发文档服务端(https://developers.weixin.qq.com/miniprogram/dev/api-backend/)。

==========================================================

                                      封装工具类

==========================================================

package com.sf.vsolution.hb.sfce.util.wechat.appletService;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.sf.vsolution.hb.sfce.util.wechat.appletService.param.*;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.util.Base64Utils;
import org.springframework.util.StringUtils;

import javax.crypto.Cipher;
import javax.crypto.spec.IvParameterSpec;
import javax.crypto.spec.SecretKeySpec;
import java.security.spec.AlgorithmParameterSpec;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.TimeUnit;

/**
 * @description: 微信小程序服务端开发
 * @author: zhucj
 * @date: 2019-11-14 15:10
 */
@Slf4j
public class AppletServiceUtil {

    @Value("${applet.appId}")
    private String appId;
    @Value("${applet.secret}")
    private String secret;

    @Value("${wx.template.id}")
    private String templateId;

    @Value("${wx.template.page}")
    private String templatePage;


    @Autowired
    private StringRedisTemplate redis;



    @ApiOperation(value = "微信小程序-获取用户openId或手机号信息")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "code",value = "微信授权code",required = true,dataType = "String"),
            @ApiImplicitParam(name = "encryptedData",value = "完整用户信息的加密数据(不传只获取openId)",required = false,dataType = "String"),
            @ApiImplicitParam(name = "iv",value = "加密算法的初始向量(如获取更多用户信息传)",required = false,dataType = "String")
    })
    public R getUserInfo(WeChatAuthorizeDto dto){
        if (StringUtils.isEmpty(dto.getCode())){
            throw new AppletServiceException(AppletServiceConstants.PARAM_ERROR_CODE,AppletServiceConstants.CODE_NULL_ERROR);
        }
        //封装请求参数map
        Map map = new HashMap();
        map.put("appid",appId);
        map.put("secret",secret);
        map.put("js_code",dto.getCode());
        map.put("grant_type","authorization_code");
        String resultString = HttpClientUtil.doGet(AppletServiceConstants.AUTH_CODE_API, map);
        AuthCodeResponse authCodeResponse = JSON.parseObject(resultString, AuthCodeResponse.class);
        //判断请求返回结果,errcode = 0 请求成功
        if (!Objects.equals(authCodeResponse.getErrcode(),AppletServiceConstants.SUCCESS_CODE)){
            log.error("小程序授权失败返回错误码:{},错误信息:{}",authCodeResponse.getErrcode(),authCodeResponse.getErrmsg());
            throw new AppletServiceException(AppletServiceConstants.PARAM_ERROR_CODE,AppletServiceConstants.AUTHORIZATION_ERROR);
        }

        HashMap<String,String> respMap = new HashMap<>();
        respMap.put("openId",authCodeResponse.getOpenid());
        //如果未传encryptedData和iv 即仅返回openId
        if (Objects.isNull(dto.getEncryptedData()) || Objects.isNull(dto.getIv())){
            return R.ok(respMap);
        }
        // 解密
        byte[] encrypData = Base64Utils.decodeFromString(dto.getEncryptedData());
        byte[] ivData = Base64Utils.decodeFromString(dto.getIv());
        byte[] sessionKey = Base64Utils.decodeFromString(authCodeResponse.getSession_key());
        try{
            AlgorithmParameterSpec ivSpec = new IvParameterSpec(ivData);
            Cipher cipher  = Cipher.getInstance("AES/CBC/PKCS5Padding");
            SecretKeySpec keySpec = new SecretKeySpec(sessionKey, "AES");
            cipher.init(Cipher.DECRYPT_MODE, keySpec, ivSpec);
            String string = new String(cipher.doFinal(encrypData), "UTF-8");
            JSONObject object = JSONObject.parseObject(string);
            //获取手机号码
            String phone = object.getString("phoneNumber");
            respMap.put("phone", phone);
        }catch (Exception e){
            e.getStackTrace();
            log.error("微信小程序手机号码解密异常:{}",e.getMessage());
            throw new AppletServiceException(AppletServiceConstants.EXCEPTION_ERROR_CODE,AppletServiceConstants.ENCTYP_EXECPTION);
        }
        return R.ok(resultString);
    }



    @ApiOperation(value = "获取-小程序accessToken值")
    public String getToken() throws AppletServiceException {
        //先从缓存中判断是否存在
        String redisString = redis.opsForValue().get(AppletServiceConstants.ACCESS_TOKEN);
        if (Objects.nonNull(redisString)){
            return redisString;
        }
        String reqUrl = AppletServiceConstants.ACCESS_TOKEN_API;
        Map map = new HashMap();
        map.put("grant_type","client_credential");
        map.put("appid",appId);
        map.put("secret",secret);
        String result = HttpClientUtil.doGet(reqUrl, map);
        AuthAccessTokenResponse auth = JSON.parseObject(result, AuthAccessTokenResponse.class);
        //判断errcode ==0 即请求成功
        if (Objects.equals(auth.getErrcode(),AppletServiceConstants.SUCCESS_CODE)){
            log.info("获取的accessToken值:{}",auth.getAccess_token());
            //将accessToken存入到redis 设置过期时间
            redis.opsForValue().set(AppletServiceConstants.ACCESS_TOKEN,auth.getAccess_token(),AppletServiceConstants.EXPIRES_IN, TimeUnit.SECONDS);
            return auth.getAccess_token();
        }else {
            log.error("小程序授权失败返回错误码:{},错误信息:{}",auth.getErrcode(),auth.getErrmsg());
            throw new AppletServiceException(AppletServiceConstants.PARAM_ERROR_CODE,AppletServiceConstants.ACCESS_TOKRN_ERROR);
        }


    }


    @ApiOperation(value = "推送模板微信模板信息")
    @ApiImplicitParams({
            @ApiImplicitParam(value = "openId",name = "用户openId",required = true,dataType = "String")
    })
    public Boolean sendTemplateMsg(String openId) throws AppletServiceException {
        WxTemplate wxTemplate = build(openId);
        String str = JSON.toJSONString(wxTemplate);
        log.info("微信推送模版消息:{}",str);
        String result = HttpClientUtil.doPostJson(AppletServiceConstants.TEMPLATE_MESSAGE_URL+getToken(), str);
        CommonResponse commonResponse = JSON.parseObject(result, CommonResponse.class);
        if (Objects.equals(commonResponse.getErrcode(),AppletServiceConstants.SUCCESS_CODE)) {
            return true;
        } else {
            return false;
        }
    }


    /**
     * 构建消息模板
     * @return
     */
    private WxTemplate build(String openId) {
        //以下是构建消息推送的model,具体情况需要根据模版做更改
        WxTemplate template = new WxTemplate();
        //模板Id
        template.setTemplate_id(templateId);
        //openId
        template.setTouser(openId);
        //此处小程序跳转链接,需要根据需要跳转拼接
        template.setPage(templatePage);
        Map<String, TemplateData> param = new HashMap<>();
        // 封装模板数据,依据小程序模板来设置(可设置成参数,传递过来)
        param.put("first", getTemplateData(xxxx));
        param.put("keyword1", getTemplateData("xxxxxx"));
        param.put("keyword2", getTemplateData("xxxx"));
        param.put("keyword3", getTemplateData("xxxx"));
        param.put("keyword4", getTemplateData("xxxx"));
        param.put("keyword5", getTemplateData("xxxx"));
        param.put("remark", getTemplateData("xxxx"));
        template.setData(param);
        return template;
    }


    /**
     * 设置 TemplateDate数据
     * @param value
     * @return
     */
    private static TemplateData getTemplateData(String value) {
        TemplateData templateData = new TemplateData();
        templateData.setValue(value);
        templateData.setColor("#173177");
        return templateData;
    }

}

==================================================================
  封装请求参数,响应参数,常量类,枚举类和异常类
==================================================================
package com.sf.vsolution.hb.sfce.util.wechat.appletService;

/**
 * @Author: zhucj
 * @Date: 2019/5/23 13:29
 * @apiNote: 微信小程序服务端常量
 */
public class AppletServiceConstants {


   //TODO:服务端Api
   /**
    * 小程序登录API
    */
   public static final String AUTH_CODE_API = "https://api.weixin.qq.com/sns/jscode2session";
   /**
    * accessToken授权API
    */
   public static final String ACCESS_TOKEN_API = "https://api.weixin.qq.com/cgi-bin/token";

   /**
    * 模板消息URL
    */
   public static String TEMPLATE_MESSAGE_URL = "https://api.weixin.qq.com/cgi-bin/message/wxopen/template/send?access_token=";

   /**
    * accessToken缓存key
    */
   public static final String ACCESS_TOKEN = "ACCESS_TOKEN";
   /**
    * accessToken缓存过期时间
    */
  
   public static final Integer EXPIRES_IN  = 7000;


   //TODO：请求状态码
   public static final Integer PARAM_ERROR_CODE = 400;

   public static final Integer EXCEPTION_ERROR_CODE = 500;

   public static final Integer SUCCESS_CODE = 0;


   //TODO: 异常信息状态

   public static final String CODE_NULL_ERROR = "微信授权码code不为空";

   public static final String  AUTHORIZATION_ERROR = "未获取到openId,授权失败";

   public static final String ENCTYP_EXECPTION = "微信小程序手机号码解密异常";

   public static final String ACCESS_TOKRN_ERROR = "小程序授权获取accessToken失败";

}

----------------------------------
package com.sf.vsolution.hb.sfce.util.wechat.appletService;

/**
 * @author ：zhucj
 * @date ：Created in 2019/6/17 17:46
 * @description: 小程序服务异常类
 */
public class AppletServiceException extends RuntimeException {
    private static final long serialVersionUID = -5317007026578376164L;

    /**
     * 错误码
     */
    private Integer errorCode;
    /**
     * 错误描述
     */
    private String errorMsg;

    /**
     * @param errorCode
     * @param errorMsg
     */
    public AppletServiceException(Integer errorCode, String errorMsg) {
        super(errorMsg);
        this.errorCode = errorCode;
        this.errorMsg = errorMsg;
    }

    public Integer getErrorCode() {
        return errorCode;
    }

    public String getErrorMsg() {
        return errorMsg;
    }
}
----------------------------------
package com.sf.vsolution.hb.sfce.util.wechat.appletService;

import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.utils.URIBuilder;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;

import java.io.IOException;
import java.net.URI;
import java.util.Map;

/**
 * @description: get/post请求工具类
 * @author: zhucj
 * @date: 2019-04-26 10:10
 */
@Slf4j
public class HttpClientUtil {

    /**
     * 发送get请求
     * @param url
     * @param param
     * @return
     */
    public static String doGet(String url, Map<String, String> param) {
        log.info("GET请求地址:{},请求参数内容:{}",url, JSON.toJSON(param));
        // 创建Httpclient对象
        CloseableHttpClient httpclient = HttpClients.createDefault();

        String resultString = "";
        CloseableHttpResponse response = null;
        try {
            // 创建uri
            URIBuilder builder = new URIBuilder(url);
            if (param != null) {
                for (String key : param.keySet()) {
                    builder.addParameter(key, param.get(key));
                }
            }
            URI uri = builder.build();

            // 创建http GET请求
            HttpGet httpGet = new HttpGet(uri);

            // 执行请求
            response = httpclient.execute(httpGet);
            // 判断返回状态是否为200
            if (response.getStatusLine().getStatusCode() == 200) {
                resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
            }
        } catch (Exception e) {
            e.printStackTrace();
            log.error("网络出现异常:{}",e.getMessage());
        } finally {
            try {
                if (response != null) {
                    response.close();
                }
                httpclient.close();
            } catch (IOException e) {
                e.printStackTrace();
                log.error("IO出现异常:{}",e.getMessage());
            }
        }
        log.info("GET响应参数:{}",resultString);
        return resultString;
    }

    /**
     * 发post请求 传入xml/json字符串
     * @param url
     * @param json
     * @return
     */
    public static String doPostJson(String url, String json) {
        log.info("POST请求地址:{},请求参数内容:{}",url,json);
        // 创建Httpclient对象
        CloseableHttpClient httpClient = HttpClients.createDefault();
        CloseableHttpResponse response = null;
        String resultString = "";
        try {
            // 创建Http Post请求
            HttpPost httpPost = new HttpPost(url);
            // 创建请求内容
            StringEntity entity = new StringEntity(json, ContentType.APPLICATION_JSON);
            httpPost.setEntity(entity);
            // 执行http请求
            response = httpClient.execute(httpPost);
            resultString = EntityUtils.toString(response.getEntity(), "utf-8");
        } catch (Exception e) {
            e.printStackTrace();
            log.error("网络出现异常:{}",e.getMessage());
        } finally {
            try {
                response.close();
            } catch (IOException e) {
                e.printStackTrace();
                log.error("IO出现异常:{}",e.getMessage());
            }
        }
        log.info("POST响应参数:{}",resultString);
        return resultString;
    }

}

-------------------------------------
package com.sf.vsolution.hb.sfce.util.wechat.appletService;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.ToString;

import java.io.Serializable;

/**
 * 返回类型
 * @author choleece
 * @date 2018/9/27
 */
@ApiModel
@ToString
public class R<T> implements Serializable {

    private static final long serialVersionUID = -6287952131441663819L;

    /**
     * 编码
     */
    @ApiModelProperty(value = "响应码", example = "200")
    private int code = 200;

    /**
     * 成功标志
     */
    @ApiModelProperty(value = "成功标志", example = "true")
    private Boolean success;

    /**
     * 返回消息
     */
    @ApiModelProperty(value = "返回消息说明", example = "操作成功")
    private String msg="操作成功";

    /**
     * 返回数据
     */
    @ApiModelProperty(value = "返回数据")
    private T data;

    /**
     * 创建实例
     * @return
     */
    public static R instance() {
        return new R();
    }

    public int getCode() {
        return code;
    }

    public R setCode(int code) {
        this.code = code;
        return this;
    }

    public Boolean getSuccess() {
        return success;
    }

    public R setSuccess(Boolean success) {
        this.success = success;
        return this;
    }

    public String getMsg() {
        return msg;
    }

    public R setMsg(String msg) {
        this.msg = msg;
        return this;
    }

    public T getData() {
        return data;
    }
    public R setData(T data) {
        this.data = data;
        return this;
    }

    public static R ok() {
        return R.instance().setSuccess(true);
    }

    public static R ok(Object data) {
        return ok().setData(data);
    }

    public static R ok(Object data, String msg) {
        return ok(data).setMsg(msg);
    }

    public static R error() {
        return R.instance().setSuccess(false);
    }

    public static R error(String msg) {
        return error().setMsg(msg);
    }

    /**
     * 无参
     */
    public R() {
    }

    public R(int code, String msg) {
        this.code = code;
        this.msg = msg;
    }

    public R(int code, T data){
        this.code = code;
        this.data = data;
    }

    /**
     * 有全参
     * @param code
     * @param msg
     * @param data
     * @param success
     */
    public R(int code, String msg, T data, Boolean success) {
        this.code = code;
        this.msg = msg;
        this.data = data;
        this.success = success;
    }

    /**
     * 有参
     * @param code
     * @param msg
     * @param data
     */
    public R(int code, String msg, T data) {
        this.code = code;
        this.msg = msg;
        this.data = data;
    }

   
}
---------------------------------------
package com.sf.vsolution.hb.sfce.util.wechat.appletService.param;

import lombok.*;

/**
 * @description: 小程序端返回共用参数
 * @author: zhucj
 * @date: 2019-11-14 16:41
 */
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@ToString
public class CommonResponse {

    /**
     * 错误码
     */
    private Integer errcode;

    /**
     * 错误信息
     */
    private String errmsg;
}


-----------------------------
package com.sf.vsolution.hb.sfce.util.wechat.appletService.param;

import lombok.*;

/**
 * @description: 小程序获取AccessToken返回参数
 * @author: zhucj
 * @date: 2019-11-14 16:43
 */
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@ToString
public class AuthAccessTokenResponse extends CommonResponse {


    /**
     * 获取到的凭证
     */
    private String access_token;

    /**
     * 凭证有效时间，单位：秒。目前是7200秒之内的值。
     */
    private Integer expires_in;
}

---------------------------

package com.sf.vsolution.hb.sfce.util.wechat.appletService.param;

import lombok.*;

/**
 * @description: 小程序获取openId返回参数
 * @author: zhucj
 * @date: 2019-11-14 16:13
 */
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@ToString
public class AuthCodeResponse extends CommonResponse {

    /**
     * 用户唯一标识
     */
    private String openid;

    /**
     * 会话密钥
     */
    private String session_key;

    /**
     * 用户在开放平台的唯一标识符，在满足 UnionID 下发条件的情况下会返回，详见 UnionID 机制说明。
     */
    private String unionid;

}

------------------------------
package com.sf.vsolution.hb.sfce.util.wechat.appletService.param;

import lombok.*;

/**
 * Template
 * @author zhucj
 */
@Data
@NoArgsConstructor
@AllArgsConstructor
@ToString
@Builder
public class TemplateData {

    /**
     * 模板显示值
     */
    private String value;
    /**
     * 模板显示颜色
     */
    private String color;
}


---------------------------
package com.sf.vsolution.hb.sfce.util.wechat.appletService.param;

import lombok.*;

/**
 * @description: 微信授权参数
 * @author: zhucj
 * @date: 2019-09-26 15:01
 */
@Data
@NoArgsConstructor
@AllArgsConstructor
@ToString
@Builder
public class WeChatAuthorizeDto {

    /**
     * 微信授权code
     */
    private String code;

    /**
     * 包括敏感数据在内的完整用户信息的加密数据
     */
    private String encryptedData;

    /**
     * 加密算法的初始向量，详见 用户数据的签名验证和加解密
     */
    private String iv;
}
-----------------------------
package com.sf.vsolution.hb.sfce.util.wechat.appletService.param;
import lombok.*;

import java.util.Map;

@Data
@NoArgsConstructor
@AllArgsConstructor
@ToString
@Builder
public class WxTemplate {

    /**
     * 微信通知模板ID
     */
    private String template_id;
    /**
     * 微信openId
     */
    private String touser;

    /** 小程序首页地址 */
    private String page;

    /**支付返回的 prepay_id,部分模板必传*/
    private String  form_id;

    private Map<String, String> miniprogram;

    private Map<String, TemplateData> data;
}
=================================================================
              yml配置文件
=================================================================
#微信支付参数
wx:
  #微信小程序appId
  appId: ******
  #小程序secret
  secret: *******
  template:
    #模板Id
    id: ******
    #通知跳转小程序页面
    page: ******


=================================================================
             项目maven支持
===============================================
<!-- swagger API -->
<dependency>
    <groupId>io.springfox</groupId>
    <artifactId>springfox-swagger2</artifactId>
    <version>2.6.0</version>
</dependency>
<dependency>
    <groupId>io.springfox</groupId>
    <artifactId>springfox-swagger-ui</artifactId>
    <version>2.6.0</version>
</dependency>

<!--htttpclient依赖-->
<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId>
    <version>4.5.5</version>
</dependency>

<!--fastjson依赖-->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>fastjson</artifactId>
    <version>1.2.47</version>
</dependency>

<!-- redis -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>


<!-- lombok -->
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <version>1.18.2</version>
    <scope>provided</scope>
</dependency>
 
 



来源：https://www.cnblogs.com/zhucj-java/p/11864317.html		





































回复




使用道具
举报










































返回列表
发新帖































高级模式



B
Color
Image
Link
Quote
Code
Smilies






您需要登录后才可以回帖 登录 | 立即注册



















本版积分规则



























	


        
        
        









Archiver|手机版|小黑屋|琼殿技术论坛
|nimba_sitemap:appname




相关侵权、举报、投诉及建议等，请发 E-mail：qiongdian@foxmail.com


Powered by Discuz!
X5.0
 © 2001-2026 Discuz! Team.











在本版发帖返回顶部