2022.10.21 1.环境守法小程序后台功能首发版本完成

feiyu02

2022-10-21 f22c4b9230808fed4fec80c435eccb4c833349a0

 src/main/kotlin/cn/flightfeather/supervision/common/net/WXHttpService.kt

@@ -1,5 +1,13 @@
package cn.flightfeather.supervision.common.net

import cn.flightfeather.supervision.common.wx.MessageWxVo
import cn.flightfeather.supervision.common.wx.WxConfig
import com.alibaba.fastjson.JSON
import com.alibaba.fastjson.JSONObject
import com.google.gson.Gson
import com.google.gson.JsonObject
import com.google.gson.JsonParser

/**
 * @author riku
 * Date: 2020/10/15
@@ -7,17 +15,87 @@
 */
object WXHttpService {

    private const val APP_ID=""
    private const val SECRET = ""
    private val httpMethod = HttpMethod("api.weixin.qq.com", 443, true)

    /**
     * 微信登录凭证校验
     */
    fun code2Session(code: String): HttpMethod.MyResponse =
        httpMethod.get(
    fun code2Session(code: String): Pair<String, String>? {
        val res =httpMethod.get(
            "/sns/jscode2session", listOf(
                Pair("appid", APP_ID), Pair("secret", SECRET), Pair("js_code", code), Pair("grant_type", "authorization_code")
                Pair("appid", WxConfig.APP_ID), Pair("secret", WxConfig.SECRET), Pair("js_code", code), Pair("grant_type", "authorization_code")
            )
        )
        return if (res.success) {
            val json = JSONObject.parseObject(res.m.responseBodyAsString)
            val errCode = json["errcode"]
            if (errCode == 0 || errCode == null) {
                val openid = json["openid"] as String
                val unionid = json["session_key"] as String
                Pair(openid, unionid)
            } else {
                null
            }
        } else {
            null
        }
    }

    /**
     * 微信发送订阅消息
     */
    fun sendMsg(accessToken:String, msgWxV0: MessageWxVo): Boolean {
        val data = Gson().toJson(msgWxV0)
        val response = httpMethod.post("/cgi-bin/message/subscribe/send?access_token=${accessToken}", data)
        if (response.success) {
            val json = JsonParser.parseString(response.m.responseBodyAsString)
            if (json.isJsonObject) {
                val jo = json.asJsonObject
                val eMsg = jo["errmsg"]?.asString
                when (jo["errcode"]?.asInt) {
                    40003 -> {
                        throw IllegalStateException("微信订阅消息，touser字段openid为空或者不正确，错误信息：${eMsg}")
                    }
                    40037 -> {
                        throw IllegalStateException("微信订阅消息，订阅模板id为空不正确，错误信息：${eMsg}")
                    }
                    43101 -> {
                        throw IllegalStateException("微信订阅消息，用户拒绝接收消息，错误信息：${eMsg}")
                    }
                    47003 -> {
                        throw IllegalStateException("微信订阅消息，模板参数不准确，具体错误：${eMsg}")
                    }
                    41030 -> {
                        throw IllegalStateException("微信订阅消息，page路径不正确，错误信息：${eMsg}")
                    }
                }
            }
            return true
        } else {
            return false
        }
    }

    /**
     * 获取小程序全局后台接口调用凭据
     */
    fun getAccessToken(): JsonObject? {
        val res = httpMethod.get(
            "/cgi-bin/token", listOf(
                Pair("grant_type", "client_credential"),
                Pair("appid", WxConfig.APP_ID),
                Pair("secret", WxConfig.SECRET)
            )
        )
        return if (res.success) {
            val json = JsonParser.parseString(res.m.responseBodyAsString)
            if (json.isJsonObject) {
                json.asJsonObject
            } else {
                null
            }
        } else {
            null
        }
    }
}