<?php
namespace app\common\repositories\system\merchant;


use app\common\dao\system\merchant\MerchantShareholderIntegralDao;
use app\common\repositories\BaseRepository;

class MerchantShareholderIntegralRepository extends BaseRepository{

    public function __construct(MerchantShareholderIntegralDao $dao){
        $this->dao = $dao;
    }

    /**
     * Common: 公共查询模型
     * Author: wu-hui
     * Time: 2024/06/19 16:04
     * @param $search
     * @return \app\common\model\system\merchant\MerchantShareholderIntegral
     */
    public function getSearchModel($search){
        return $this->dao->searchModel($search);
    }


    /**
     * Common: 获取分组持有信息（同股东等级、门店、用户为一组）
     * Author: wu-hui
     * Time: 2024/06/20 9:32
     * @param array $params
     * @param int   $page
     * @param int   $limit
     * @return array
     */
    public function groupList(array $params,int $page,int $limit){
        // 查询模型
        $query = $this->getSearchModel($params)
            ->field([
                'uid',
                'mer_id',
                'level_id',
                'CONCAT(uid,"_",mer_id,"_",level_id) as group_key',
                'SUM(integral_total) as sum_integral_total',
                'SUM(integral_use) as sum_integral_use',
                'SUM(CASE status WHEN 2 THEN (integral_total - integral_use) ELSE 0 END) as sum_used_overdue',// 已过期可用
                'SUM(CASE status WHEN 0 THEN integral_total ELSE 0 END) as sum_used_freeze',// 冻结中可用
                'SUM(CASE status WHEN 1 THEN (integral_total - integral_use) ELSE 0 END) as sum_used_surplus',// 当前可用
            ])
            ->group('group_key')
            ->order('create_time DESC,id DESC');
        // 信息获取
        $count = $query->count();
        $list = $query->page($page,$limit)->select()->toArray();

        return compact('count','list');
    }
    /**
     * Common: 获取信息列表
     * Author: wu-hui
     * Time: 2024/06/20 10:21
     * @param array $params
     * @param int   $page
     * @param int   $limit
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getList(array $params,int $page,int $limit){
        // 查询模型
        $query = $this->getSearchModel($params)->order('id asc');
        // 信息获取
        $count = $query->count();
        $list = $query->page($page,$limit)->select()->toArray();

        return compact('count','list');
    }
    /**
     * Common: 获取统计信息
     * Author: wu-hui
     * Time: 2024/06/20 16:44
     * @param $params
     * @return array
     */
    public function getStatistics($params){
        $info = $this->getSearchModel($params)
            ->field([
                'SUM(integral_total) as sum_integral_total',
                'SUM(integral_use) as sum_integral_use',
                'SUM(CASE status WHEN 2 THEN (integral_total - integral_use) ELSE 0 END) as sum_used_overdue',// 已过期可用
                'SUM(CASE status WHEN 0 THEN integral_total ELSE 0 END) as sum_used_freeze',// 冻结中可用
                'SUM(CASE status WHEN 1 THEN (integral_total - integral_use) ELSE 0 END) as sum_used_surplus',// 当前可用
            ])
            ->findOrEmpty()
            ->toArray();

        return  $info ?? [];
    }

    // 获取用户绑定商户列表
    public function getMerList(array $params,int $page,int $limit){
        // 获取股东列表
        $data = app()->make(MerchantShareholderRepository::class)->getList($params,$page,$limit);
        foreach($data['list'] as &$item){
            $item->statistics = $this->getStatistics([
                'uid' => $item->uid,
                'mer_id' => $item->mer_id,
            ]);
        }

        return $data;
    }


}