<?php
// +----------------------------------------------------------------------
// | Niucloud-admin 企业快速开发的多应用管理平台
// +----------------------------------------------------------------------
// | 官方网址：https://www.niucloud.com
// +----------------------------------------------------------------------
// | niucloud团队 版权所有 开源版本可自由商用
// +----------------------------------------------------------------------
// | Author: Niucloud Team
// +----------------------------------------------------------------------

namespace app\service\api\sys;

use app\model\sys\SysArea;
use app\service\admin\sys\ConfigService;
use core\base\BaseApiService;
use core\exception\ApiException;
use think\db\exception\DataNotFoundException;
use think\db\exception\DbException;
use think\db\exception\ModelNotFoundException;

/**
 * 地区服务层
 * Class AreaService
 * @package app\service\admin\sys
 */
class AreaService extends BaseApiService
{
    public static $cache_tag_name = 'area_cache';

    public function __construct()
    {
        parent::__construct();
        $this->model = new SysArea();
    }

    /**
     * 获取地区信息
     * @param int $pid //上级pid
     * @return mixed
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public function getListByPid(int $pid = 0)
    {

        $cache_name = self::$cache_tag_name . '_api_pid_' . $pid;
        return cache_remember(
            $cache_name,
            function() use ($pid) {
                return $this->model->where([ [ 'pid', '=', $pid ] ])->field('id, name')->select()->toArray();
            },
            [ self::$cache_tag_name ]
        );
    }

    /**
     * 查询地区树列表
     * @param int $level //层级1,2,3
     * @return mixed
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public function getAreaTree(int $level = 3)
    {
        $cache_name = self::$cache_tag_name . '_api_tree_' . $level;
        return cache_remember(
            $cache_name,
            function() use ($level) {
                $list = $this->model->where([ [ 'level', '<=', $level ] ])->field('id, pid, name')->select()->toArray();
                return list_to_tree($list);
            },
            [ self::$cache_tag_name ]
        );
    }

    public function getAreaByAreaCode($id)
    {
        $cache_name = self::$cache_tag_name . '_api_area_' . $id;
        return cache_remember(
            $cache_name,
            function() use ($id) {
                $level = [ 1 => 'province', 2 => 'city', 3 => 'district' ];
                $tree = [];
                $area = $this->model->where([ [ 'id', '=', $id ] ])->field('id,level,pid,name')->findOrEmpty();

                if (!$area->isEmpty()) {
                    $tree[ $level[ $area[ 'level' ] ] ] = $area->toArray();

                    while ($area[ 'level' ] > 1) {
                        $area = $this->model->where([ [ 'id', '=', $area[ 'pid' ] ] ])->field('id,level,pid,name')->findOrEmpty();
                        $tree[ $level[ $area[ 'level' ] ] ] = $area->toArray();
                    }
                }
                return $tree;
            },
            [ self::$cache_tag_name ]
        );
    }

    /**
     * 通过经纬度查询地址
     * @param $params
     * @return array|int
     */
    public function getAddressByLatlng($params)
    {
        $url = 'https://apis.map.qq.com/ws/geocoder/v1/';
        $map = ( new ConfigService() )->getMap();

        $get_data = array (
            'location' => $params[ 'latlng' ],
            'key' => $map[ 'key' ],
            'get_poi' => 0,//是否返回周边POI列表：1.返回；0不返回(默认)
        );

        $url = $url . '?' . http_build_query($get_data);
        $curl = curl_init();
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($curl, CURLOPT_HEADER, 0);
        curl_setopt($curl, CURLOPT_URL, $url);
        curl_setopt($curl, CURLOPT_TIMEOUT, 1);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);

        $res = curl_exec($curl);
        $res = json_decode($res, true);
        if ($res) {
            curl_close($curl);

            if ($res[ 'status' ] == 0) {
                $return_array = $res[ 'result' ][ 'address_component' ] ?? [];
                $address_data = array (
                    'province' => $return_array[ 'province' ] ?? '',
                    'city' => $return_array[ 'city' ] ?? '',
                    'district' => $return_array[ 'district' ] ?? '',
                    'address' => $return_array[ 'street_number' ] ?? '',
                    'full_address' => $res[ 'result' ][ 'address' ] ?? '',
                    'formatted_addresses' => $res[ 'result' ][ 'formatted_addresses' ] ?? []
                );

                $province = '';
                if ($address_data[ 'province' ]) {
                    $province = str_replace('省', '', $address_data[ 'province' ]);
                    $province = str_replace('市', '', $province);
                }
                $city = $address_data[ 'city' ] ?? '';
                $district = $address_data[ 'district' ] ?? '';

                $province_info = $this->model->where([ [ 'name', 'like', '%' . $province . '%' ], [ 'level', '=', 1 ] ])->field('id,name')->select()->toArray()[ 0 ] ?? [];

                $province_id = 0;
                $province_name = '';

                $city_id = 0;
                $city_name = '';

                $district_id = 0;
                $district_name = '';

                if (!empty($province_info)) {
                    $province_id = $province_info[ 'id' ];
                    $province_name = $province_info[ 'name' ];
                }

                if ($province_id > 0) {
                    $city_info = $this->model->where([ [ 'name', 'like', '%' . $city . '%' ], [ 'level', '=', 2 ], [ 'pid', '=', $province_id ] ])->field('id,name')->select()->toArray()[ 0 ] ?? [];

                    if (!empty($city_info)) {
                        $city_id = $city_info[ 'id' ];
                        $city_name = $city_info[ 'name' ];
                    }
                }

                if ($city_id > 0 && $province_id > 0) {
                    $district_info = $this->model->where([ [ 'name', 'like', '%' . $district . '%' ], [ 'level', '=', 3 ], [ 'pid', '=', $city_id ] ])->field('id,name')->select()->toArray()[ 0 ] ?? [];

                    if (!empty($district_info)) {
                        $district_id = $district_info[ 'id' ];
                        $district_name = $district_info[ 'name' ];
                    }
                }

                return [
                    'province_id' => $province_id,
                    'province' => $province_name,

                    'city_id' => $city_id,
                    'city' => $city_name,

                    'district_id' => $district_id,
                    'district' => $district_name,

                    'full_address' => $address_data[ 'full_address' ],
                    'formatted_addresses' => $address_data[ 'formatted_addresses' ]

                ];
            } else {
                throw new ApiException($res[ 'message' ]);
            }

        } else {
            $error = curl_errno($curl);
            curl_close($curl);
            throw new ApiException($error);
        }
    }

}