<?php

namespace app\shop\model\plus\operations;

use app\common\enum\plus\operations\OperationsLevelEnum;
use app\common\model\plus\operations\Operations as operationsModel;
use app\shop\model\plus\operations\Role as RoleModel;
use app\shop\model\plus\operations\User as UserLoginModel;
use app\shop\model\plus\operations\UserRole;

/**
 * 股东用户模型
 * Class User
 * @package app\shop\model\plus\operations
 */
class Operations extends operationsModel
{
    /**
     * 获取股东用户列表
     */
    public function getList($search, $limit = 15)
    {
        // 构建查询规则
        $model = $this->alias('operations')
            ->field('operations.*, user.nickName, user.avatarUrl')
            ->with(['grade'])
            ->join('user', 'user.user_id = operations.user_id')
            ->where('operations.is_delete', '=', 0)
            ->order(['operations.create_time' => 'desc']);
        // 查询条件
        if (!empty($search)) {
            $model = $model->where('user.nickName|operations.real_name|operations.mobile', 'like', '%' . $search . '%');
        }
        // 获取列表数据
        $list = $model->paginate($limit);
        foreach ($list as $user){
            $user['total_money'] = sprintf('%.2f', $user['money'] + $user['freeze_money'] + $user['total_money']);
        }
        return $list;
    }

    public static function getListAll($grade_id = 0)
    {
        $model = new static;
        if($grade_id > 0) {
            $model->where('grade_id', '=', $grade_id);
        }
        return $model->where('is_delete', '=', 0)->with(['grade'])->select();
    }

    /**
     * 编辑股东用户
     * @param $operations_id
     * @param $operations_level
     */
    public static function getUser($operations_id, $operations_level = OperationsLevelEnum::PROVINCE)
    {
        $model = new static;
        $model = $model->where('operations_level', '=', $operations_level);
        // 省代理
        if($operations_level == OperationsLevelEnum::PROVINCE) {
            $model = $model->where('province_id', '=', $operations_id);
        }
        if($operations_level == OperationsLevelEnum::CITY) {
            $model = $model->where('city_id', '=', $operations_id);
        }
        if($operations_level == OperationsLevelEnum::AREA) {
            $model = $model->where('area_id', '=', $operations_id);
        }
        return $model->where('is_delete', '=', 0)->select();
    }

    /**
     * 编辑股东用户
     * @param $data
     * @return bool
     */
    public function edit($data)
    {
        $this->startTrans();
        try {
            // 检查区域是否已被占用
            $model = $this->where('user_id', $data['user_id'])->find();
            $checkData = [
                'operations_level' => $model['operations_level']['value'],
                'is_delete' => 0
            ];
            if ($checkData['operations_level'] == 1) {
                $checkData['province_id'] = $model['province_id'];
            } elseif ($checkData['operations_level'] == 2) {
                $checkData['province_id'] = $model['province_id'];
                $checkData['city_id'] = $model['city_id'];
            } elseif ($checkData['operations_level'] == 3) {
                $checkData['province_id'] = $model['province_id'];
                $checkData['city_id'] = $model['city_id'];
                $checkData['area_id'] = $model['area_id'];
            }

            $conflict = $this->where($checkData)->where('user_id', '<>', $data['user_id'])->find();
            if ($conflict) {
                $this->error = '该区域已有代理,请先删除原有代理';
                return false;
            }

            // 更新区域代理基本信息
            $saveData = [
                'real_name' => $data['real_name'],
                'mobile' => $data['mobile'],
                'update_time' => time()
            ];
            
            if (!$this->save($saveData)) {
                throw new \Exception('更新失败');
            }

            // 处理管理员账号
            $userLoginModel = new UserLoginModel();
            $admin = $userLoginModel->where('user_id', '=', $data['user_id'])->where('is_super', '=', 1)->find();
            if ($userLoginModel->detail(['real_name'=>$data['real_name'],'user_id'=>['neq'=>$data['user_id']]])){
                throw new \Exception('该账号已存在');
            }
            // 如果传入了用户名,则更新或创建管理员账号
            if (isset($data['user_name']) && !empty($data['user_name'])) {
                $loginData = [
                    'user_id' => $data['user_id'],
                    'user_name' => $data['user_name'],
                    'real_name' => $data['real_name'],
                    'mobile' => $data['mobile'],
                    'is_delete' => 0,
                    'app_id' => self::$app_id,
                    'update_time' => time()
                ];
                
                if (!empty($data['password'])) {
                    $loginData['user_name'] = salt_hash($data['user_name']);
                    $loginData['password'] = salt_hash($data['password']);
                }
                
                if ($admin) {
                    // 更新现有管理员账号
                    if (!$userLoginModel->where('shop_user_id', '=', $admin['shop_user_id'])->update($loginData)) {
                        throw new \Exception('管理员账号更新失败');
                    }
                } else {
                    // 创建新的管理员账号
                    $loginData['create_time'] = time();
                    $loginData['is_super'] = 1;
                    $role_id = RoleModel::where('operations_level','=',$checkData['operations_level'])->value('role_id');
                    $loginData['role_id'] = $role_id;
                    
                    if (!$userLoginModel->save($loginData)) {
                        throw new \Exception('管理员账号创建失败');
                    }

                    // 为新管理员分配默认角色(如果有)
                    $add_arr = [];
                    $model = new UserRole();
                    $add_arr[] = [
                        'operations_user_id' => $userLoginModel['operations_user_id'],
                        'role_id' => $role_id,
                        'app_id' => self::$app_id,
                    ];
                    $model->saveAll($add_arr);
                }
            }

            $this->commit();
            return true;
        } catch (\Exception $e) {
            $this->error = $e->getMessage();
            $this->rollback();
            return false;
        }
    }

    /**
     * 删除股东用户
     * @return mixed
     */
    public function setDelete()
    {
        return $this->transaction(function () {
            // 标记当前股东记录为已删除
            return $this->save([
                'is_delete' => 1
            ]);
        });
    }

    /**
     * 提现打款成功：累积提现佣金
     */
    public static function totalMoney($user_id, $money)
    {
        $model = self::detail($user_id);
        return $model->save([
            'freeze_money' => $model['freeze_money'] - $money,
            'total_money' => $model['total_money'] + $money,
        ]);
    }

    /**
     * 提现驳回：解冻股东资金
     */
    public static function backFreezeMoney($user_id, $money)
    {
        $model = self::detail($user_id);
        return $model->save([
            'money' => $model['money'] + $money,
            'freeze_money' => $model['freeze_money'] - $money,
        ]);
    }

    /**
     * 添加区域代理(后台直接添加)
     * @param $data
     * @return bool
     */
    public function addoperationsUser($data)
    {
        $this->startTrans();
        try {
            // 检查用户是否已经是区域代理
            $existing = self::detail($data['user_id']);
            if ($existing && $existing['is_delete'] == 0) {
                $this->error = '该用户已经是区域代理';
                return false;
            }

            // 检查区域是否已被占用
            $checkData = [
                'operations_level' => $data['operations_level'],
                'is_delete' => 0
            ];
            if ($data['operations_level'] == 1) {
                $checkData['province_id'] = $data['province_id'];
            } elseif ($data['operations_level'] == 2) {
                $checkData['province_id'] = $data['province_id'];
                $checkData['city_id'] = $data['city_id'];
            } elseif ($data['operations_level'] == 3) {
                $checkData['province_id'] = $data['province_id'];
                $checkData['city_id'] = $data['city_id'];
                $checkData['area_id'] = $data['area_id'];
            }

            $conflict = $this->where($checkData)->find();
            if ($conflict) {
                $this->error = '该区域已有代理,请先删除原有代理';
                return false;
            }

            // 准备数据
            $saveData = [
                'user_id' => $data['user_id'],
                'real_name' => $data['real_name'],
                'mobile' => $data['mobile'],
                'operations_level' => $data['operations_level'],
                'province_id' => $data['province_id'],
                'city_id' => isset($data['city_id']) ? $data['city_id'] : 0,
                'area_id' => isset($data['area_id']) ? $data['area_id'] : 0,
                'referee_id' => isset($data['referee_id']) ? $data['referee_id'] : 0,
                'grade_id' => isset($data['grade_id']) ? $data['grade_id'] : 0,
                'money' => 0,
                'freeze_money' => 0,
                'total_money' => 0,
                'total_num' => 0,
                'first_num' => 0,
                'second_num' => 0,
                'third_num' => 0,
                'is_delete' => 0,
                'app_id' => self::$app_id,
                'create_time' => time(),
                'update_time' => time()
            ];

            // 如果之前有记录且已删除,则更新
            if ($existing && $existing['is_delete'] == 1) {
                $saveData['update_time'] = time();
                $result = $this->where('user_id', $data['user_id'])->update($saveData);
            } else {
                // 新增
                $result = $this->save($saveData);
            }
            $userLoginModel = new UserLoginModel();
            if ($userLoginModel->detail(['real_name'=>$data['real_name']])){
                throw new \Exception('该账号已存在');
            }
            // 创建管理员账号
            if (isset($data['user_name']) && !empty($data['user_name'])) {
                $loginData = [
                    'user_id' => $data['user_id'],
                    'user_name' => $data['user_name'],
                    'password' => salt_hash($data['password']),
                    'real_name' => $data['real_name'],
                    'is_super' => 1,
                    'mobile' => $data['mobile'],
                    'is_delete' => 0,
                    'app_id' => self::$app_id,
                    'client_id' => 0
                ];
                
                if (!$userLoginModel->save($loginData)) {
                    throw new \Exception('管理员账号创建失败');
                }
                $role_id = RoleModel::where('operations_level','=',$data['operations_level'])->value('role_id');
                // 这里可以分配默认角色ID,暂时不分配
                $model = new UserRole();
                $add_arr[] = [
                    'operations_user_id' => $userLoginModel['operations_user_id'],
                    'role_id' => $role_id,
                    'app_id' => self::$app_id,
                ];
                $model->saveAll($add_arr);
            }

            $this->commit();
            return true;
        } catch (\Exception $e) {
            $this->error = $e->getMessage();
            $this->rollback();
            return false;
        }
    }

    /**
     * 获取平台的总销售额
     */
    public function getTotalMoney($type = 'all_money')
    {
        $model = $this;
        if($type == 'money'){
            return $model->sum('money');
        } else if($type == 'freeze_money'){
            return $model->sum('freeze_money');
        } else if($type == 'total_money'){
            return $model->sum('total_money');
        } else if($type == 'all_money'){
            return $model->sum('total_money') + $model->sum('freeze_money') + $model->sum('money');
        }
        return 0;
    }
}