<?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;
 }
}