<?php

namespace RiderApi\Controller;

/**
 * 骑手端认证控制器
 */
class AuthController extends BaseController
{

    /**
     * 骑手登录
     */
    public function login()
    {
        try {
            // 支持JSON格式和form-data格式的输入
            $phone = '';
            $code = '';
            $password = '';
            $defaultPassword = '';

            // 检查Content-Type是否为JSON
            $contentType = isset($_SERVER['CONTENT_TYPE']) ? $_SERVER['CONTENT_TYPE'] : '';
            if (strpos($contentType, 'application/json') !== false) {
                // JSON格式输入
                $input = file_get_contents('php://input');
                $data = json_decode($input, true);
                $phone = isset($data['phone']) ? $data['phone'] : '';
                $code = isset($data['code']) ? $data['code'] : '';
                $password = isset($data['password']) ? $data['password'] : '';
                $defaultPassword = isset($data['default_password']) ? $data['default_password'] : '123456';
            } else {
                // 表单格式输入
                $phone = $this->getRequestParam('phone', '');
                $code = $this->getRequestParam('code', '');
                $password = $this->getRequestParam('password', '');
                $defaultPassword = $this->getRequestParam('default_password', '123456');
            }

            if (empty($phone)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '手机号不能为空'));
            }

            // 验证手机号格式
            if (!preg_match('/^1[3-9]\d{9}$/', $phone)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '手机号格式不正确'));
            }

            // 如果提供了验证码，则使用验证码登录
            if (!empty($code)) {
                // 检查是否为调试环境
                $isDebug = C('APP_DEBUG') && C('DEBUG_SMS_ENABLED');
                $debugCode = C('DEBUG_SMS_CODE');
                if (empty($debugCode)) {
                    $debugCode = '111111'; // 默认验证码
                }

                if ($isDebug && $code === $debugCode) {
                    // 调试模式：接受配置的默认验证码，跳过session检查
                    // 不需要检查session中的验证码
                } else {
                    // 非调试模式：验证码登录
                    $sessionCode = session('sms_code_' . $phone);

                    if (empty($sessionCode)) {
                        $this->ajaxReturn(array('code' => 0, 'msg' => '验证码已过期，请重新获取'));
                    }

                    if ($code !== $sessionCode) {
                        $this->ajaxReturn(array('code' => 0, 'msg' => '验证码错误'));
                    }

                    // 验证码正确，清除session中的验证码
                    session('sms_code_' . $phone, null);
                }
            } else if (!empty($password)) {
                // 密码登录 - 需要先查询用户验证密码
                $riderModel = M('rider_info');
                $rider = $riderModel->where(array('rider_phone' => $phone, 'status' => 1))->find();

                if (!$rider) {
                    $this->ajaxReturn(array('code' => 0, 'msg' => '用户不存在'));
                }

                // 验证密码
                if (!$this->verifyPassword($password, $rider['password'], $rider['salt'])) {
                    $this->ajaxReturn(array('code' => 0, 'msg' => '密码错误'));
                }

                // 更新最后登录时间
                $riderModel->where(array('id' => $rider['id']))->save(array(
                    'last_login_time' => date('Y-m-d H:i:s')
                ));
            } else {
                $this->ajaxReturn(array('code' => 0, 'msg' => '请提供验证码或密码'));
            }

            // 如果是验证码登录，需要查询或创建用户
            if (!empty($code)) {
                // 查询骑手信息（包括被禁用的用户）
                $riderModel = M('rider_info');
                $rider = $riderModel->where(array('rider_phone' => $phone))->find();

                if (!$rider) {
                    // 新用户自动注册，设置默认密码
                    $salt = $this->generateSalt();
                    $encryptedDefaultPassword = $this->encryptPassword($defaultPassword, $salt); // 使用参数传入的默认密码

                    $data = array(
                        'rider_phone' => $phone,
                        'rider_name' => '骑手' . substr($phone, -4),
                        'password' => $encryptedDefaultPassword,
                        'salt' => $salt,
                        'work_status' => 0,
                        'auth_status' => 0,
                        'add_time' => date('Y-m-d H:i:s'),
                        'last_login_time' => date('Y-m-d H:i:s'),
                        'status' => 1
                    );

                    $riderId = $riderModel->add($data);
                    if (!$riderId) {
                        $this->ajaxReturn(array('code' => 0, 'msg' => '注册失败'));
                    }

                    $rider = $riderModel->find($riderId);
                } else {
                    // 如果用户被禁用，不允许登录
                    if ($rider['status'] != 1) {
                        $this->ajaxReturn(array('code' => 0, 'msg' => '账户已被禁用，请联系管理员'));
                    }

                    // 更新最后登录时间
                    $riderModel->where(array('id' => $rider['id']))->save(array(
                        'last_login_time' => date('Y-m-d H:i:s')
                    ));
                }
            }

            // 生成token
            $token = md5($rider['id'] . $rider['rider_phone'] . time() . rand(1000, 9999));

            // 保存token到数据库
            $tokenModel = M('rider_token');

            // 先删除该骑手的旧token（实现单点登录）
            $tokenModel->where(array('rider_id' => $rider['id']))->delete();

            // 保存新token
            $tokenData = array(
                'rider_id' => $rider['id'],
                'token' => $token,
                'expires_at' => date('Y-m-d H:i:s', time() + 7 * 24 * 3600), // 7天过期
                'device_info' => isset($_SERVER['HTTP_USER_AGENT']) ? $_SERVER['HTTP_USER_AGENT'] : '',
                'ip_address' => $this->getClientIP()
                // created_at 和 updated_at 字段由 MySQL 自动设置
            );

            $tokenResult = $tokenModel->add($tokenData);
            if (!$tokenResult) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '登录失败，请重试'));
            }

            // 返回登录成功信息
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '登录成功',
                'data' => array(
                    'rider_id' => $rider['id'],
                    'rider_name' => $rider['rider_name'],
                    'rider_phone' => $rider['rider_phone'],
                    'rider_avatar' => $rider['rider_avatar'],
                    'work_status' => $rider['work_status'],
                    'auth_status' => $rider['auth_status'],
                    'balance' => $rider['balance'],
                    'rating' => $rider['rating'],
                    'token' => $token
                )
            ));
        } catch (\Exception $e) {
            // 记录错误日志
            error_log('Login Error: ' . $e->getMessage());
            $this->ajaxReturn(['code' => 0, 'msg' => '登录失败，请稍后再试']);
        }
    }

    /**
     * 发送短信验证码（复用现有阿里云短信模块）
     * @param string $phone 手机号
     * @param string $code 验证码
     * @return array
     */
    private function sendSmsCode($phone, $code)
    {
        try {
            // 获取系统短信配置
            $smsConfig = M('sms_config')->find();

            if (empty($smsConfig)) {
                return array('code' => 0, 'msg' => '系统暂不支持发送验证码功能');
            }

            if (
                empty($smsConfig['accesskeyid']) || empty($smsConfig['accesskeysecret'])
                || empty($smsConfig['accessname']) || empty($smsConfig['accesscode'])
            ) {
                return array('code' => 0, 'msg' => '系统短信配置有误');
            }

            // 调用阿里云短信发送
            $result = $this->sendAliyunSms($phone, $code, $smsConfig);

            return $result;
        } catch (\Exception $e) {
            return array('code' => 0, 'msg' => '短信发送异常：' . $e->getMessage());
        }
    }

    /**
     * 阿里云短信发送
     * @param string $phone 手机号
     * @param string $code 验证码
     * @param array $config 短信配置
     * @return array
     */
    private function sendAliyunSms($phone, $code, $config)
    {
        require_once VENDOR_PATH . "Aliyu/SignatureHelper.php";

        $params = array();

        // 设置短信参数
        $params["PhoneNumbers"] = $phone;
        $params["SignName"] = $config['accessname'];
        $params["TemplateCode"] = $config['accesscode'];
        $params['TemplateParam'] = array("code" => $code);
        $params['OutId'] = "rider_" . time();
        $params['SmsUpExtendCode'] = "1234567";

        // 转换模板参数为JSON
        if (!empty($params["TemplateParam"]) && is_array($params["TemplateParam"])) {
            $params["TemplateParam"] = json_encode($params["TemplateParam"], JSON_UNESCAPED_UNICODE);
        }

        require_once "./SignatureHelper.php";

        // 初始化SignatureHelper
        $helper = new \SignatureHelper();

        try {
            $content = $helper->request(
                $config['accesskeyid'],
                $config['accesskeysecret'],
                "dysmsapi.aliyuncs.com",
                array_merge($params, array(
                    "RegionId" => "cn-hangzhou",
                    "Action" => "SendSms",
                    "Version" => "2017-05-25",
                ))
            );

            $content = json_decode(json_encode($content), true);

            if ($content && $content['Code'] == 'OK') {
                return array('code' => 1, 'msg' => '发送成功', 'data' => $content, 'params' => $params);
            } else {
                $errorMsg = isset($content['Message']) ? $content['Message'] : '短信发送失败';
                return array('code' => 0, 'msg' => '发送失败：' . $errorMsg);
            }
        } catch (\Exception $e) {
            return array('code' => 0, 'msg' => '短信配置异常：' . $e->getMessage());
        }
    }

    /**
     * 生成密码盐值
     * @return string
     */
    private function generateSalt()
    {
        return substr(md5(uniqid(rand(), true)), 0, 10);
    }

    /**
     * 加密密码
     * @param string $password 原始密码
     * @param string $salt 盐值
     * @return string
     */
    private function encryptPassword($password, $salt)
    {
        return md5(md5($password) . $salt);
    }

    /**
     * 验证密码
     * @param string $password 输入的密码
     * @param string $encryptedPassword 数据库中的加密密码
     * @param string $salt 盐值
     * @return bool
     */
    private function verifyPassword($password, $encryptedPassword, $salt)
    {
        return $this->encryptPassword($password, $salt) === $encryptedPassword;
    }

    /**
     * 修改密码
     */
    public function changePassword()
    {
        $riderId = $this->riderId;
        $rider = $this->riderInfo;

        // 使用统一的参数处理方法
        $oldPassword = trim($this->getRequestParam('old_password', ''));
        $newPassword = trim($this->getRequestParam('new_password', ''));

        if (empty($oldPassword) || empty($newPassword)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '参数不完整'));
        }

        if (strlen($newPassword) < 6) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '新密码长度不能少于6位'));
        }

        if (!$rider) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '用户不存在'));
        }

        // 验证旧密码
        if (!$this->verifyPassword($oldPassword, $rider['password'], $rider['salt'])) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '原密码错误'));
        }

        // 生成新的盐值和加密新密码
        $newSalt = $this->generateSalt();
        $newEncryptedPassword = $this->encryptPassword($newPassword, $newSalt);

        // 更新密码
        $riderModel = M('rider_info');
        $result = $riderModel->where(array('id' => $riderId))->save(array(
            'password' => $newEncryptedPassword,
            'salt' => $newSalt
        ));

        if ($result !== false) {
            $this->ajaxReturn(array('code' => 1, 'msg' => '密码修改成功'));
        } else {
            $this->ajaxReturn(array('code' => 0, 'msg' => '密码修改失败'));
        }
    }

    /**
     * 发送验证码
     */
    public function sendCode()
    {
        try {
            // 支持JSON格式和form-data格式的输入
            $phone = '';

            // 检查Content-Type是否为JSON
            $contentType = isset($_SERVER['CONTENT_TYPE']) ? $_SERVER['CONTENT_TYPE'] : '';
            if (strpos($contentType, 'application/json') !== false) {
                // JSON格式输入
                $input = file_get_contents('php://input');
                $data = json_decode($input, true);
                $phone = isset($data['phone']) ? $data['phone'] : '';
            } else {
                // 表单格式输入
                $phone = $this->getRequestParam('phone', '');
            }

            if (empty($phone)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '手机号不能为空'));
            }

            // 验证手机号格式
            if (!preg_match('/^1[3-9]\d{9}$/', $phone)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '手机号格式不正确'));
            }

            // 检查是否为调试环境
            $isDebug = C('APP_DEBUG') && C('DEBUG_SMS_ENABLED');

            if ($isDebug) {
                // 调试环境：使用配置的默认验证码
                $code = C('DEBUG_SMS_CODE');
                if (empty($code)) {
                    $code = '111111'; // 默认验证码
                }

                // 将验证码存储到session中，有效期5分钟
                session('sms_code_' . $phone, $code, 300);

                $this->ajaxReturn(array(
                    'code' => 1,
                    'msg' => '验证码发送成功（调试模式）',
                    'data' => array(
                        'debug' => true,
                        'code' => $code // 调试模式下返回验证码
                    )
                ));
            } else {
                // 生产环境：调用阿里云短信服务发送验证码
                $code = sprintf('%06d', rand(100000, 999999));

                // 调用现有的短信发送服务
                $smsResult = $this->sendSmsCode($phone, $code);

                if ($smsResult['code'] == 1) {
                    // 短信发送成功，将验证码存储到session中，有效期5分钟
                    session('sms_code_' . $phone, $code, 300);

                    $this->ajaxReturn(array(
                        'code' => 1,
                        'msg' => '验证码发送成功',
                        'data' => array(
                            'debug' => false
                        )
                    ));
                } else {
                    // 短信发送失败
                    $this->ajaxReturn(array(
                        'code' => 0,
                        'msg' => $smsResult['msg'] ?: '验证码发送失败，请稍后重试'
                    ));
                }
            }
        } catch (\Exception $e) {
            $this->ajaxReturn(array('code' => 0, 'msg' => $e->getMessage()));
        }
    }

    /**
     * 实名认证
     */
    public function realAuth()
    {
        $riderId = $this->riderId;
        $rider = $this->riderInfo;

        // 检查Content-Type并解析参数
        $contentType = isset($_SERVER['CONTENT_TYPE']) ? $_SERVER['CONTENT_TYPE'] : '';
        if (strpos($contentType, 'application/json') !== false) {
            $input = json_decode(file_get_contents('php://input'), true);
            $realName = isset($input['real_name']) ? trim($input['real_name']) : '';
            $idCard = isset($input['id_card']) ? trim($input['id_card']) : '';
            $idCardFront = isset($input['id_card_front']) ? trim($input['id_card_front']) : '';
            $idCardBack = isset($input['id_card_back']) ? trim($input['id_card_back']) : '';
        } else {
            $realName = $this->getRequestParam('real_name', '');
            $idCard = $this->getRequestParam('id_card', '');
            $idCardFront = $this->getRequestParam('id_card_front', '');
            $idCardBack = $this->getRequestParam('id_card_back', '');
        }

        if (empty($realName)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '真实姓名不能为空'));
        }

        if (empty($idCard)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '身份证号不能为空'));
        }

        // 验证身份证号格式
        if (!preg_match('/^[1-9]\d{5}(18|19|20)\d{2}((0[1-9])|(1[0-2]))(([0-2][1-9])|10|20|30|31)\d{3}[0-9Xx]$/', $idCard)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '身份证号格式不正确'));
        }

        $riderModel = M('rider_info');
        $rider = $riderModel->find($riderId);

        if (!$rider) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '骑手不存在'));
        }

        // 更新认证信息
        $data = array(
            'rider_name' => $realName,
            'id_card' => $idCard,
            'id_card_front' => $idCardFront,
            'id_card_back' => $idCardBack,
            'auth_status' => 1 // 认证中
        );

        $result = $riderModel->where(array('id' => $riderId))->save($data);

        if ($result !== false) {
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '认证信息提交成功，请等待审核'
            ));
        } else {
            $this->ajaxReturn(array('code' => 0, 'msg' => '提交失败'));
        }
    }

    /**
     * 提交认证信息
     */
    public function submitAuthentication()
    {
        try {
            $riderId = $this->riderId;

            // 检查Content-Type并解析参数
            $contentType = isset($_SERVER['CONTENT_TYPE']) ? $_SERVER['CONTENT_TYPE'] : '';
            if (strpos($contentType, 'application/json') !== false) {
                $input = json_decode(file_get_contents('php://input'), true);
                $name = isset($input['name']) ? trim($input['name']) : '';
                $idCard = isset($input['id_card']) ? trim($input['id_card']) : '';
                $idCardFront = isset($input['id_card_front']) ? trim($input['id_card_front']) : '';
                $idCardBack = isset($input['id_card_back']) ? trim($input['id_card_back']) : '';
                $handheldPhoto = isset($input['handheld_photo']) ? trim($input['handheld_photo']) : '';
                $emergencyName = isset($input['emergency_name']) ? trim($input['emergency_name']) : '';
                $emergencyPhone = isset($input['emergency_phone']) ? trim($input['emergency_phone']) : '';
                $emergencyRelation = isset($input['emergency_relation']) ? trim($input['emergency_relation']) : '';
                $healthCert = isset($input['health_cert']) ? trim($input['health_cert']) : '';
                $healthCertExpire = isset($input['health_cert_expire']) ? trim($input['health_cert_expire']) : '';
            } else {
                $name = $this->getRequestParam('name', '');
                $idCard = $this->getRequestParam('id_card', '');
                $idCardFront = $this->getRequestParam('id_card_front', '');
                $idCardBack = $this->getRequestParam('id_card_back', '');
                $handheldPhoto = $this->getRequestParam('handheld_photo', '');
                $emergencyName = $this->getRequestParam('emergency_name', '');
                $emergencyPhone = $this->getRequestParam('emergency_phone', '');
                $emergencyRelation = $this->getRequestParam('emergency_relation', '');
                $healthCert = $this->getRequestParam('health_cert', '');
                $healthCertExpire = $this->getRequestParam('health_cert_expire', '');
            }

            // 参数验证
            if (empty($name)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '真实姓名不能为空'));
            }

            if (empty($idCard)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '身份证号不能为空'));
            }

            if (empty($idCardFront)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '身份证正面照片不能为空'));
            }

            if (empty($idCardBack)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '身份证反面照片不能为空'));
            }

            if (empty($handheldPhoto)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '手持身份证照片不能为空'));
            }

            if (empty($emergencyName)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '紧急联系人姓名不能为空'));
            }

            if (empty($emergencyPhone)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '紧急联系人电话不能为空'));
            }

            if (empty($emergencyRelation)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '与紧急联系人关系不能为空'));
            }

            if (empty($healthCert)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '健康证照片不能为空'));
            }

            if (empty($healthCertExpire)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '健康证有效期不能为空'));
            }

            // 验证身份证号格式
            if (!preg_match('/^[1-9]\d{5}(18|19|20)\d{2}((0[1-9])|(1[0-2]))(([0-2][1-9])|10|20|30|31)\d{3}[0-9Xx]$/', $idCard)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '身份证号格式不正确'));
            }

            // 验证紧急联系人电话格式
            if (!preg_match('/^1[3-9]\d{9}$/', $emergencyPhone)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '紧急联系人电话格式不正确'));
            }

            // 验证健康证有效期格式
            if (!preg_match('/^\d{4}-\d{2}-\d{2}$/', $healthCertExpire)) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '健康证有效期格式不正确，请使用YYYY-MM-DD格式'));
            }

            // 验证健康证有效期是否为未来日期
            if (strtotime($healthCertExpire) <= time()) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '健康证有效期必须为未来日期'));
            }

            $riderModel = M('rider_info');
            $rider = $riderModel->find($riderId);

            if (!$rider) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '骑手不存在'));
            }

            // 检查是否已经认证通过
            if ($rider['auth_status'] == 2) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '您已通过认证，无需重复提交'));
            }

            // 检查是否正在审核中
            if ($rider['auth_status'] == 1) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '您的认证正在审核中，请勿重复提交'));
            }

            // 检查身份证号是否已被其他用户使用
            $existRider = $riderModel->where(array(
                'id_card' => $idCard,
                'id' => array('neq', $riderId),
                'status' => 1
            ))->find();

            if ($existRider) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '该身份证号已被其他用户使用'));
            }

            // 更新认证信息
            $data = array(
                'rider_name' => $name,
                'id_card' => $idCard,
                'id_card_front' => $idCardFront,
                'id_card_back' => $idCardBack,
                'auth_status' => 1, // 认证中
                'auth_time' => date('Y-m-d H:i:s'),
                'auth_remark' => '' // 清空之前的备注
            );

            // 如果数据库表有对应字段，则添加这些字段
            $riderModel = M('rider_info');
            $tableFields = $riderModel->getDbFields();

            if (in_array('handheld_photo', $tableFields)) {
                $data['handheld_photo'] = $handheldPhoto;
            }
            if (in_array('emergency_name', $tableFields)) {
                $data['emergency_name'] = $emergencyName;
            }
            if (in_array('emergency_phone', $tableFields)) {
                $data['emergency_phone'] = $emergencyPhone;
            }
            if (in_array('emergency_relation', $tableFields)) {
                $data['emergency_relation'] = $emergencyRelation;
            }
            if (in_array('health_cert', $tableFields)) {
                $data['health_cert'] = $healthCert;
            }
            if (in_array('health_cert_expire', $tableFields)) {
                $data['health_cert_expire'] = $healthCertExpire;
            }

            $result = $riderModel->where(array('id' => $riderId))->save($data);

            if ($result !== false) {
                // 记录认证日志
                $logModel = M('rider_auth_log');
                if ($logModel) {
                    $logData = array(
                        'rider_id' => $riderId,
                        'action' => 'submit',
                        'old_status' => $rider['auth_status'],
                        'new_status' => 1,
                        'remark' => '骑手提交认证信息',
                        'ip_address' => $this->getClientIP(),
                        'add_time' => date('Y-m-d H:i:s')
                    );
                    $logModel->add($logData);
                }

                $this->ajaxReturn(array(
                    'code' => 1,
                    'msg' => '认证信息提交成功，请等待审核',
                    'data' => array(
                        'auth_status' => 1,
                        'auth_status_text' => '认证中',
                        'submit_time' => date('Y-m-d H:i:s')
                    )
                ));
            } else {
                $this->ajaxReturn(array('code' => 0, 'msg' => '提交失败，请重试'));
            }
        } catch (\Exception $e) {
            $this->ajaxReturn(array('code' => 0, 'msg' => $e->getMessage()));
        }
    }

    /**
     * 上传健康证
     */
    public function uploadHealthCert()
    {
        $riderId = $this->riderId;
        $rider = $this->riderInfo;

        // 检查Content-Type并解析参数
        $contentType = isset($_SERVER['CONTENT_TYPE']) ? $_SERVER['CONTENT_TYPE'] : '';
        if (strpos($contentType, 'application/json') !== false) {
            $input = json_decode(file_get_contents('php://input'), true);
            $healthCert = isset($input['health_cert']) ? trim($input['health_cert']) : '';
            $healthCertExpire = isset($input['health_cert_expire']) ? trim($input['health_cert_expire']) : '';
        } else {
            $healthCert = $this->getRequestParam('health_cert', '');
            $healthCertExpire = $this->getRequestParam('health_cert_expire', '');
        }

        if (empty($healthCert)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '健康证照片不能为空'));
        }

        if (empty($healthCertExpire)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '健康证过期时间不能为空'));
        }

        $riderModel = M('rider_info');
        $rider = $riderModel->find($riderId);

        if (!$rider) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '骑手不存在'));
        }

        // 更新健康证信息
        $data = array(
            'health_cert' => $healthCert,
            'health_cert_expire' => $healthCertExpire
        );

        $result = $riderModel->where(array('id' => $riderId))->save($data);

        if ($result !== false) {
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '健康证上传成功'
            ));
        } else {
            $this->ajaxReturn(array('code' => 0, 'msg' => '上传失败'));
        }
    }

    /**
     * 获取骑手信息
     */
    public function getRiderInfo()
    {
        $rider = $this->riderInfo;

        if (!$rider) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '获取骑手信息失败'));
        }

        // 确保通知设置字段存在
        if (!isset($rider['order_notification'])) {
            $rider['order_notification'] = 1; // 默认开启
        }
        if (!isset($rider['voice_broadcast'])) {
            $rider['voice_broadcast'] = 1; // 默认开启
        }
        if (!isset($rider['vibration_alert'])) {
            $rider['vibration_alert'] = 1; // 默认开启
        }

        $this->ajaxReturn(array(
            'code' => 1,
            'msg' => '获取成功',
            'data' => array_merge($rider, array(
                'online_start_time' => $rider['online_start_time'] ?: null
            ))
        ));
    }

    /**
     * 更新工作状态
     */
    public function updateWorkStatus()
    {
        try {
            $riderId = $this->riderId;

            // 检查Content-Type并解析参数
            $contentType = isset($_SERVER['CONTENT_TYPE']) ? $_SERVER['CONTENT_TYPE'] : '';
            if (strpos($contentType, 'application/json') !== false) {
                $input = json_decode(file_get_contents('php://input'), true);
                $workStatus = isset($input['work_status']) ? intval($input['work_status']) : -1;
            } else {
                $workStatus = $this->getRequestParam('work_status', -1, 'intval');
            }

            // 验证工作状态参数
            if ($workStatus < 0 || $workStatus > 2) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '工作状态参数错误'));
            }

            // 验证状态映射
            $statusMap = array(
                0 => '离线',
                1 => '在线',
                2 => '忙碌'
            );

            if (!isset($statusMap[$workStatus])) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '无效的工作状态'));
            }

            $riderModel = M('rider_info');

            $riderInfo = $riderModel->find($riderId);

            if (!$riderInfo) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '骑手不存在'));
            }

            // 检查认证状态，只有已认证的骑手才能上线
            if ($workStatus == 1 && $riderInfo['auth_status'] != 2) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '请先完成实名认证才能上线'));
            }

            // 更新工作状态
            $data = array(
                'work_status' => $workStatus,
                'status_update_time' => date('Y-m-d H:i:s')
            );

            // 处理在线开始时间
            if ($workStatus == 1) {
                // 上线时记录在线开始时间
                $data['online_start_time'] = time();
            } elseif ($workStatus == 0) {
                // 下线时清空在线开始时间
                $data['online_start_time'] = null;
            }

            $result = $riderModel->where(array('id' => $riderId))->save($data);

            if ($result !== false) {
                $this->ajaxReturn(array(
                    'code' => 1,
                    'msg' => '工作状态更新成功',
                    'data' => array(
                        'work_status' => $workStatus,
                        'work_status_text' => $statusMap[$workStatus],
                        'update_time' => date('Y-m-d H:i:s')
                    )
                ));
            } else {
                $this->ajaxReturn(array('code' => 0, 'msg' => '状态更新失败'));
            }
        } catch (\Exception $e) {
            $this->ajaxReturn(array('code' => 0, 'msg' => $e->getMessage()));
        }
    }

    /**
     * 获取客户端IP地址
     */
    private function getClientIP()
    {
        if (isset($_SERVER['HTTP_X_FORWARDED_FOR']) && !empty($_SERVER['HTTP_X_FORWARDED_FOR'])) {
            $ips = explode(',', $_SERVER['HTTP_X_FORWARDED_FOR']);
            return trim($ips[0]);
        } elseif (isset($_SERVER['HTTP_X_REAL_IP']) && !empty($_SERVER['HTTP_X_REAL_IP'])) {
            return $_SERVER['HTTP_X_REAL_IP'];
        } elseif (isset($_SERVER['REMOTE_ADDR'])) {
            return $_SERVER['REMOTE_ADDR'];
        }
        return '0.0.0.0';
    }
}