<?php

namespace Largezhou\WechatMenu;

use Largezhou\WechatMenu\Exceptions\WechatMenuException;

class Data
{
    /**
     * 允许的请求类型.
     */
    const REQUEST_TYPES = [
        // 公众号菜单
        'menus',
        // 菜单事件配置
        'menu_events',
        // 其他事件配置
        'other_events',
        // 素材列表
        'materials',
        // 素材详情
        'media',
    ];

    /**
     * 永久素材类型.
     */
    const MATERIAL_TYPES = [
        'news',
        'image',
        'video',
        'voice',
    ];

    /**
     * 素材每页数.
     */
    const MEDIA_PER_PAGE = 20;

    /**
     * 返回成功.
     *
     * @param string $msg  消息
     * @param string $data 附带数据
     *
     * @return string
     */
    public static function success($msg = '', $data = null): string
    {
        return json_encode(
            [
                'status' => true,
                'msg' => $msg,
                'data' => $data,
            ]
        );
    }

    /**
     * 返回错误.
     *
     * @param string $msg  消息
     * @param string $type 错误类型: default 默认，wechat 微信接口错误
     *
     * @return string
     */
    public static function error($msg = '', $type = 'default'): string
    {
        return json_encode(
            [
                'status' => false,
                'msg' => $msg,
                'type' => $type,
            ]
        );
    }

    /**
     * 获取存储的数据.
     *
     * @param string|null $type
     *
     * @return array|mixed|null
     */
    public static function getData(string $type = null)
    {
        $data = safe_json_decode(@file_get_contents(Manager::getInstance()->getConfig('data_path')), []);

        if (!$type) {
            return $data;
        } else {
            return $data[$type] ?? [];
        }
    }

    /**
     * 存储数据.
     *
     * @param mixed $allData 需要保存的数据
     */
    public static function saveData($allData)
    {
        file_put_contents(Manager::getInstance()->getConfig('data_path'), $allData);
    }

    /**
     * 返回从微信服务器获取的公众号菜单.
     *
     * @return string
     *
     * @throws Exceptions\WechatMenuException
     */
    public static function getMenus(): string
    {
        $res = Manager::getInstance()->getWechat()->menu->list();

        if ($err = static::getWechatError($res)) {
            return $err;
        }

        return static::success('', $res);
    }

    /**
     * 创建公众号菜单.
     *
     * @param array $menus
     *
     * @return string
     *
     * @throws Exceptions\WechatMenuException
     */
    public static function postMenus(array $menus): string
    {
        if (empty($menus)) {
            return static::error('至少要有一个菜单才能保存');
        }

        $res = Manager::getInstance()->getWechat()->menu->create($menus);

        if ($err = static::getWechatError($res)) {
            return $err;
        }

        return static::success('菜单保存成功');
    }

    /**
     * 获取指定类型的数据.
     *
     * @param array $data 请求中的数据
     *
     * @return string json_encode 后的数据
     *
     * @throws WechatMenuException
     * @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
     */
    public static function getResources(array $data)
    {
        $type = static::checkAndGetType($data);

        switch ($type) {
            case 'menus':
                return static::getMenus();
            case 'materials':
                return static::getMaterials($data);
            case 'media':
                return static::getMedia($data);
            default:
                return static::getSettings($type);
        }
    }

    /**
     * 存储指定类型的数据.
     *
     * @param array $data
     *
     * @return string
     *
     * @throws WechatMenuException
     */
    public static function postResources(array $data): string
    {
        $type = static::checkAndGetType($data);

        if ($type == 'menus') {
            return static::postMenus($data['data'] ?? null);
        } else {
            return static::postSettings($type, $data['data'] ?? null);
        }
    }

    /**
     * 获取指定键的数据.
     *
     * @param string $type
     *
     * @return string
     */
    public static function getSettings($type): string
    {
        return static::success('', static::getData($type));
    }

    /**
     * 保存来自请求的数据.
     *
     * @param string $type
     * @param mixed  $data
     *
     * @return string
     */
    public static function postSettings(string $type, $data): string
    {
        $allData = static::getData();
        $allData[$type] = $data;
        $allData = json_encode($allData, JSON_UNESCAPED_UNICODE + JSON_PRETTY_PRINT);

        static::saveData($allData);

        return static::success('保存设置成功');
    }

    /**
     * 检测请求中的 type 值，并返回.
     *
     * @param array $data 请求中的数据
     *
     * @return string
     *
     * @throws WechatMenuException
     */
    protected static function checkAndGetType(array $data): string
    {
        $type = trim($data['type'] ?? '');

        if (!$type) {
            throw new WechatMenuException('请求中 type 不能为空');
        }

        if (!in_array($type, static::REQUEST_TYPES)) {
            throw new WechatMenuException('请求中 type 参数不正确');
        }

        return $type;
    }

    /**
     * 获取素材列表.
     *
     * @param array $data
     *
     * @return string
     *
     * @throws WechatMenuException
     * @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
     */
    protected static function getMaterials(array $data): string
    {
        $materialType = $data['material_type'] ?? '';

        if (!in_array($materialType, static::MATERIAL_TYPES)) {
            throw new WechatMenuException('请求中素材类型 material_type 参数不正确');
        }

        $res = Manager::getInstance()
            ->getWechat()
            ->material
            ->list(
                $materialType,
                ($data['page'] - 1) * static::MEDIA_PER_PAGE,
                static::MEDIA_PER_PAGE
            );

        if ($err = static::getWechatError($res)) {
            return $err;
        }

        $res['per_page'] = static::MEDIA_PER_PAGE;
        $res['type'] = $materialType;

        return static::success('', $res);
    }

    /**
     * 获取素材详情
     *
     * @param array $data
     *
     * @return \EasyWeChat\Kernel\Http\StreamResponse|string
     *
     * @throws WechatMenuException
     * @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
     */
    protected static function getMedia(array $data)
    {
        $mediaId = $data['media_id'] ?? '';

        if (!$mediaId) {
            return static::error('必须有媒体 ID 参数：media_id');
        }

        $res = Manager::getInstance()->getWechat()->material->get($mediaId);

        if ($err = static::getWechatError($res)) {
            return $err;
        }

        // 其他则直接返回文件内容，前端打开可直接下载
        if ($res instanceof \EasyWeChat\Kernel\Http\StreamResponse) {
            return $res;
        }

        return static::success('', $res);
    }

    /**
     * 检查微信接口返回的消息是否有错误，有则返回响应内容，没有则返回 false
     *
     * @param mixed $res 微信接口返回的内容
     *
     * @return bool|string
     */
    protected static function getWechatError($res)
    {
        if (!is_array($res)) {
            return false;
        }

        $errCode = $res['errcode'] ?? null;
        if ($errCode) {
            return static::error("[{$res['errcode']}] {$res['errmsg']}", 'wechat');
        }

        return false;
    }
}