app = $app; $this->request = $this->app->request; $this->redis = new Redis(); // 控制器初始化 $this->initialize(); } // 初始化 protected function initialize() { //noNeedLogin全部转换小写 foreach ($this->noNeedLogin as &$action) { $action = strtolower($action); } //验证需要鉴权的方法名 $callMethodName = strtolower($this->request->action()); if (!in_array($callMethodName, $this->noNeedLogin)) { $userToken = Db::table('tb_admin_token') ->where(['token' => $this->request->header('token')]) ->where('expired_at', '>', time()) ->find(); if (!$userToken) { $this->fail(401, '请先登录后再操作'); } $this->token = $this->request->header('token'); } } protected function getUser() { $data = Db::table('tb_admin_token') ->where(['token' => $this->token]) ->find(); return (object) $data; } /** * 验证数据 * @access protected * @param array $data 数据 * @param string|array $validate 验证器名或者验证规则数组 * @param array $message 提示信息 * @param bool $batch 是否批量验证 * @return array|string|true * @throws ValidateException */ protected function validate(array $data, $validate, array $message = [], bool $batch = false) { if (is_array($validate)) { $v = new Validate(); $v->rule($validate); } else { if (strpos($validate, '.')) { // 支持场景 [$validate, $scene] = explode('.', $validate); } $class = false !== strpos($validate, '\\') ? $validate : $this->app->parseClass('validate', $validate); $v = new $class(); if (!empty($scene)) { $v->scene($scene); } } $v->message($message); // 是否批量验证 if ($batch || $this->batchValidate) { $v->batch(true); } return $v->failException(true)->check($data); } protected function success($msg, $data) { echo json_encode([ 'code' => 200, 'msg' => $msg, 'data' => $data, ]); exit(); } protected function fail($code, $msg) { echo json_encode([ 'code' => $code, 'msg' => $msg, ]); exit(); } //发送TCP消息 protected function sendTcpMessage() { } }