serviceManager = $serviceManager; $this->init(); return $this; } private function init () { $dbService = $this->serviceManager->get('Db'); $this->db = $dbService->getPdo(); } /** * @param $usertype * @return mixed */ public function fetchAll ($usertype) { $sql = "SELECT * FROM users WHERE usertype = '$usertype'"; $rs = $this->db->query($sql); return $rs->fetchAll(\PDO::FETCH_ASSOC); } /** * @return bool */ public function fetchAllHeiHe () { $sql = "SELECT * FROM heiheuser ORDER BY id DESC"; $rs = $this->db->query($sql); return $rs->fetchAll(\PDO::FETCH_ASSOC); return true; } public function fetchAllSendmail () { $time = date("Y-m-d H:i:s", time() - 3 * 365 * 24 * 3600); $sql = "SELECT * FROM users WHERE ts_last_login<'$time' ORDER BY ts_last_login DESC"; $rs = $this->db->query($sql); return $rs->fetchAll(\PDO::FETCH_ASSOC); } }