小程序-订阅消息推送

/**
 * 获取用户的openid
 *
 * @param int $uid 用户id
 *
 * @return mixed|string
 *
 * @throws ServiceException
 */
public static function getOpenId(int $uid)
{
    if (!$user = User::query()->find($uid, [\'token_id\'])) {
        throw new ServiceException(\'用户不存在或，openId 为空\');
    }
    if (!$openid = UserToken::query()->find($user->token_id, [\'miniprogram_token\'])->miniprogram_token ?? \'\') {
        throw new ServiceException(\'用户不存在或，openId 为空\');
    }
    return $openid;
}

/**
 * 采纳新品需求消息
 * $message = [
 *      \'uid\' => 用户id
 *      \'title\' => 商品名称
 *      \'state\' => 采纳结果
 *      \'remark\' => 备注
 * ]
 * @param array $message 发送消息
 *
 * @throws GuzzleException
 */
public function goodsDemandStatus(array $message)
{
    try {
        $postData = [
            \'touser\'      => self::getOpenId($message[\'uid\']), // 小程序openid
            \'template_id\' => \'16545\', // 订阅消息id
            "page"        => "pages/allGreens/allGreens", // 小程序跳转界面，订阅消息跳转界面
            \'data\'        => [
                \'thing1\'  => [
                    \'value\' => $message[\'title\'],
                ],
                \'phrase2\' => [
                    \'value\' => $message[\'state\'],
                ],
                \'thing3\'  => [
                    \'value\' => $message[\'remark\'],
                ],
            ],
        ];
        $response = $this->send($postData);
        $re       = json_decode($response->getBody()->getContents(), 1);
        if (!empty($re[\'errcode\'])) {
            Log::channel(\'message\')->info("消息发送失败：" . $re[\'errmsg\']);
        }
    } catch (\Exception $exception) {
        Log::channel(\'message\')->info("消息发送失败：" . $exception->getMessage());
    }
}

/**
 * 发送订阅消息
 *
 * @param $data
 *
 * @return ResponseInterface
 *
 * @throws GuzzleException
 */
public function send($data)
{
    return $this->httpPostJson(\'cgi-bin/message/subscribe/send\', $data);
}

/**
 * post 请求
 *
 * @param string $url 请求uri
 * @param array $data 请求参数
 *
 * @return ResponseInterface
 *
 * @throws GuzzleException
 */
public function httpPostJson(string $url, array $data = [])
{
    $tokenQuery = http_build_query([
        \'access_token\' => $this->accessToken
    ]);

    return $this->httpPostJsons($url . "?" . $tokenQuery, $data);
}

/**
 * 获取小程序token
 *
 * @return string
 *
 * @throws RequestException
 * @throws \App\Lib\Vendor\Miniprogram\RequestException
 * @throws GuzzleException
 */
public function getToken()
{
// 如果有做缓存，则读取缓存内容
    // if ($cache = Cache::get(\'cdy_wx:access_token\')) {
    //    return $cache;
    //}

    $re = $this->httpGet("token", [
        \'grant_type\' => \'client_credential\',
        \'appid\' => $this->appId,
        \'secret\' => $this->appSecret,
    ])->getBody()->getContents();
    $response = json_decode($re, true);

    if (!empty($response[\'errcode\'])) {
        Log::channel(\'store\')->error([
            \'getAccessTokenError\' => $response
        ]);
        throw new \App\Lib\Vendor\Miniprogram\RequestException("获取token失败：" . $response["errmsg"]);
    }

    Cache::put(
        \'cdy_wx:access_token\',
        $response[\'access_token\'],
        now()->addSeconds($response[\'expires_in\'] - 500)
    );
    return $response[\'access_token\'];
}

/**
 * post json 请求
 *
 * @param string $url 请求uri
 * @param array $data 请求参数
 *
 * @return ResponseInterface
 *
 * @throws GuzzleException
 */
public function httpPostJsons(string $url, array $data = [])
{
    return $this->request($url, \'POST\', [\'json\' => $data, \'verify\' => false]);
}