<?php


namespace app\common\repositories\system\config;


use app\common\dao\system\config\SystemConfigValueDao;
use app\common\repositories\BaseRepository;
use app\common\repositories\store\product\ProductRepository;
use app\common\repositories\system\groupData\GroupDataRepository;
use app\common\repositories\system\groupData\GroupRepository;
use app\common\repositories\user\UserBrokerageRepository;
use crmeb\jobs\SyncProductTopJob;
use crmeb\services\DownloadImageService;
use crmeb\services\RedisCacheService;
use think\exception\ValidateException;
use think\facade\Cache;
use think\facade\Db;
use think\facade\Queue;

/**
 * Class ConfigValueRepository
 * @package app\common\repositories\system\config
 * @mixin SystemConfigValueDao
 */
class ConfigValueRepository extends BaseRepository
{

    /**
     * ConfigValueRepository constructor.
     * @param SystemConfigValueDao $dao
     */
    public function __construct(SystemConfigValueDao $dao)
    {
        $this->dao = $dao;
    }

    /**
     * @param array $keys
     * @param int $merId
     * @return array
     * @author xaboy
     * @day 2020-03-27
     */
    public function more(array $keys, int $merId): array
    {
        $config = $this->dao->fields($keys, $merId);
        foreach ($keys as $key) {
            if (!isset($config[$key])) $config[$key] = '';
        }
        return $config;
    }

    /**
     * @param string $key
     * @param int $merId
     * @return mixed|string|null
     * @author xaboy
     * @day 2020-05-08
     */
    public function get(string $key, int $merId)
    {
        $value = $this->dao->value($key, $merId);
        return $value ?? '';
    }

    /**
     * @param int|array $cid
     * @param array $formData
     * @param int $merId
     * @author xaboy
     * @day 2020-03-27
     */
    public function save($cid, array $formData, int $merId)
    {
        $keys = array_keys($formData);
        $keys = app()->make(ConfigRepository::class)->intersectionKey($cid, $keys);
        if (!count($keys)) return;
        foreach ($keys as $key => $info) {
            if (!isset($formData[$key]))
                unset($formData[$key]);
            else {
                if ($info['config_type'] == 'number') {
                    if ($formData[$key] === '' || $formData[$key] < 0)
                        throw new ValidateException($info['config_name'] . '不能小于0');
                    $formData[$key] = floatval($formData[$key]);
                }
                $this->separate($key,$formData[$key],$merId);
            }
        }
        $this->setFormData($formData, $merId);
    }

    /**
     * TODO 需要做特殊处理的配置参数
     * @param $key
     * @author Qinii
     * @day 2022/11/17
     */
    public function separate($key,$value,$merId)
    {
        switch($key) {
            case 'mer_svip_status':
                //修改商户的会员状态
                app()->make(ProductRepository::class)->getSearch([])->where(['mer_id' => $merId,'product_type' => 0])->update([$key => $value]);
                break;
                //热卖排行
            case 'hot_ranking_switch':
                if ($value) {
                    Queue::push(SyncProductTopJob::class, []);
                }
                break;
            case 'margin_remind_day':
                if ($value && floor($value) != $value) throw new ValidateException('时间不可为小数');
                break;
            case 'svip_switch_status':
                if ($value == 1) {
                    $groupDataRepository = app()->make(GroupDataRepository::class);
                    $groupRepository = app()->make(GroupRepository::class);
                    $group_id = $groupRepository->getSearch(['group_key' => 'svip_pay'])->value('group_id');
                    $where['group_id'] = $group_id;
                    $where['status'] = 1;
                    $count = $groupDataRepository->getSearch($where)->field('group_data_id,value,sort,status')->count();
                    if (!$count)
                        throw new ValidateException('请先添加会员类型');
                }
                break;
            default:
                break;
        }
        return ;
    }

    public function setFormData(array $formData, int $merId)
    {
        Db::transaction(function () use ($merId, $formData) {
            foreach ($formData as $key => $value) {
                if ($this->dao->merExists($key, $merId))
                    $this->dao->merUpdate($merId, $key, ['value' => $value]);
                else
                    $this->dao->create([
                        'mer_id' => $merId,
                        'value' => $value,
                        'config_key' => $key
                    ]);
            }
        });
        $this->syncConfig();
    }

    public function syncConfig()
    {
        $list = $this->query([])->column('value,config_key,mer_id');
        $make = app()->make(RedisCacheService::class);
        $oldKeys = $make->keys('saga_sys_config_*') ?: [];
        $oldKeys = array_combine($oldKeys, $oldKeys);
        $mset = [];
        foreach ($list as $item) {
            $key = 'saga_sys_config_' . $item['mer_id'] . '_' . $item['config_key'];
            $mset[$key] = $item['value'];
            unset($oldKeys[$key]);
        }
        $mset['saga_sys_configFlag'] = time();
        $make->mset($mset);
        if (count($oldKeys)) {
            $make->handler()->del(...array_values($oldKeys));
        }
        Cache::delete('get_api_config');
    }

    public function getConfig(int $merId, $name)
    {
        $make = app()->make(RedisCacheService::class);
        if (is_array($name)) {
            if (!count($name)) {
                return [];
            }
            $names = $name;
        } else {
            $names = [$name];
        }
        $keys = [];
        foreach ($names as $item) {
            $keys[] = 'saga_sys_config_' . $merId . '_' . $item;
        }
        $values = $make->mGet($keys) ?: [];
        if (!is_array($name)) {
            return ($values[0] ?? '') ? json_decode($values[0]) : '';
        }
        $data = [];
        if (!count($values)) {
            foreach ($names as $v) {
                $data[$v] = '';
            }
            return $data;
        }
        foreach ($values as $i => $value) {
            $data[$names[$i]] = $value ? json_decode($value) : '';
        }
        return $data;
    }
    /**
     * Common: 获取商户分销商配置
     * Author: wu-hui
     * Time: 2023/11/15 16:47
     * @param int $merId
     * @return array
     */
    public function getMerPromoterConfig(int $merId){
        // 获取分销商等级
        $levelList = app()->make(UserBrokerageRepository::class)->getSearch(['type'=>0])
            ->field(['user_brokerage_id','brokerage_name'])
            ->order('brokerage_level Desc')
            ->select();
        // 获取配置信息
        $data['extension_status']    = (int)merchantConfig($merId,'extension_status');// 是否开启 0=关闭，1=开启
        $data['extension_one_rate']  = (float)merchantConfig($merId,'extension_one_rate');// 一级返佣比例
        $data['extension_two_rate']  = (float)merchantConfig($merId,'extension_two_rate');// 二级返佣比例
        $extensionLevelSet = merchantConfig($merId,'extension_level_set');// 每个等级设置的上浮比例
        if($extensionLevelSet) {
            $extensionLevelSet = json_decode($extensionLevelSet,true);
            $extensionLevelSet = array_column($extensionLevelSet,null,'user_brokerage_id');
        }
        $data['extension_level_set'] = [];
        foreach($levelList as $levelInfo){
            $data['extension_level_set'][$levelInfo['user_brokerage_id']] = [
                'user_brokerage_id' => $levelInfo['user_brokerage_id'],
                'brokerage_name'    => $levelInfo['brokerage_name'],
                'one_rate'          => $extensionLevelSet[$levelInfo['user_brokerage_id']]['one_rate'] ?? 0,
                'two_rate'          => $extensionLevelSet[$levelInfo['user_brokerage_id']]['two_rate'] ?? 0,
            ];
        }


        return $data;
    }


}