发邮件

api/app/api/controller/Hprose.php

@@ -4,6 +4,7 @@
 namespace app\api\controller;
 
 
+use app\api\controller\hprose\Email;
 use app\api\controller\hprose\MyExample;
 use app\api\controller\hprose\MyExample2;
 use app\common\hprose\Server;
@@ -16,6 +17,7 @@ class Hprose extends Base
 
         $server->addInstanceMethods(new MyExample2());
         $server->addInstanceMethods(new MyExample());
+        $server->addInstanceMethods(new Email());
         return $server->start();
     }
 

api/app/api/controller/HproseClient.php

@@ -4,12 +4,14 @@
 namespace app\api\controller;
 
 
+use app\api\controller\hprose\util\EmailHelper;
 use Hprose\Http\Client;
 
 class HproseClient
 {
-    public function test1(){
-        $url="http://local74.lzj/yc_api/api/public/index.php/api/hprose/server";
+    public function test1()
+    {
+        $url = "http://local74.lzj/yc_api/api/public/index.php/api/hprose/server";
         $client = Client::create($url, false);
         $result = $client->hello('张三');
         var_dump($result);
@@ -17,4 +19,18 @@ class HproseClient
         print_r($result);
     }
 
+    public function testEmail()
+    {
+        $url = "http://local74.lzj/yc_api/api/public/index.php/api/hprose/server";
+        $client = Client::create($url, false);
+        $result = $client->emailSend("lzj5001@sina.com", "测试主题" . date("His"), "<div>" . date("Y-m-d H:i:s") . "这是正文的内容</div>");
+        print_r($result);
+       /* $res = EmailHelper::instance()->send("lzj500@qq.com", "测试主题" . date("His"), "<div>" . date("Y-m-d H:i:s") . ":这是正文的内容</div>");
+        var_dump($res);*/
+    }
+
+    public function testWx(){
+
+    }
+
 }

api/app/api/controller/hprose/Email.php

@@ -0,0 +1,22 @@
+<?php
+
+
+namespace app\api\controller\hprose;
+
+
+use app\api\controller\hprose\util\EmailHelper;
+
+class Email
+{
+
+    public function emailSend($toEmail, $subject, $content, $option = [])
+    {
+        $res = EmailHelper::instance()->send($toEmail, $subject, $content, $option);
+        if (!$res) {
+            return returnFormat(999, "发送失败", $res);
+        }
+        return returnFormat(0, "发送成功，请查收邮件", $res);
+    }
+
+
+}

api/app/api/controller/hprose/MyExample.php

@@ -6,8 +6,21 @@ namespace app\api\controller\hprose;
 
 class MyExample
 {
-    public function hello($name=""){
-        return "hello ".$name;
+    private $helloStr = " ,hello init";
+
+    public function __construct()
+    {
+        $this->helloStr = " , hello __construct";
+    }
+
+    private function test1(){
+        $this->helloStr.=" test1";
+    }
+
+    public function hello($name = "")
+    {
+        $this->test1();
+        return "hello " . $name . $this->helloStr;
     }
 
 }

api/app/api/controller/hprose/util/EmailHelper.php

@@ -0,0 +1,63 @@
+<?php
+
+
+namespace app\api\controller\hprose\util;
+
+
+use app\common\util\SingleObjectClass;
+use app\common\util\Smtp;
+
+class EmailHelper extends SingleObjectClass
+{
+    /**
+     * 发邮件
+     * @param $toEmail
+     * @param $subject
+     * @param $content
+     * @param array $option
+     */
+    public function send($toEmail, $subject, $content, $option = [])
+    {
+       /* $defaultOption = [
+            "smtp_server" => "smtp.sina.com",
+            "smtp_port" => 25,
+            "smtp_usermail" => "lzj5001@sina.com",
+            "smtp_user" => "lzj5001",
+            "smtp_pass" => "ec27a8081e0da164"
+        ];*/
+        $defaultOption = [
+            "smtp_server" => "smtp.qq.com",
+            "smtp_port" => 25,
+            "smtp_usermail" => "ycxxkj002@qq.com",
+            "smtp_user" => "2936890167",
+            "smtp_pass" => "ffogaueuypopdeeg"
+        ];
+        $option = array_merge($defaultOption, $option);
+        //使用的邮箱服务器，本例以163邮箱服务器为例
+        $smtpserver = $option["smtp_server"];
+        //163邮箱服务器端口
+        $smtpserverport = $option["smtp_port"];
+        //你的163服务器邮箱账号
+        $smtpusermail = $option["smtp_usermail"];
+        //收件人邮箱
+        $smtpemailto = $toEmail;
+        //你的邮箱账号(去掉@163.com)
+        $smtpuser = $option["smtp_user"];//SMTP服务器的用户帐号
+        ////你的邮箱密码
+        $smtppass = $option["smtp_pass"]; //SMTP服务器的用户密码
+        ////邮件主题
+        $mailsubject = $subject;
+        //邮件内容
+        $mailbody = $content;
+        //邮件格式（HTML/TXT）,TXT为文本邮件
+        $mailtype ="TXT";
+        //这里面的一个true是表示使用身份验证,否则不使用身份验证.
+
+        $smtp = new Smtp($smtpserver, $smtpserverport, true, $smtpuser, $smtppass);
+        //是否显示发送的调试信息
+        $smtp->debug = TRUE;
+        /// //发送邮件
+        $res = $smtp->sendmail($smtpemailto, $smtpusermail, $mailsubject, $mailbody, $mailtype);
+        return $res;
+    }
+}

api/app/common/util/Smtp.php

@@ -0,0 +1,445 @@
+<?php
+
+
+namespace app\common\util;
+
+
+class Smtp
+{
+
+
+    /* Public Variables */
+    public $smtp_port;
+
+    public $time_out;
+
+    public $host_name;
+
+    public $log_file;
+
+    public $relay_host;
+
+    public $debug;
+
+    public $auth;
+
+    public $user;
+
+    public $pass;
+
+    /* Private Variables */
+    private $sock;
+
+    /* Constractor */
+    function __construct($relay_host = "", $smtp_port = 25, $auth = false, $user, $pass)
+    {
+        $this->debug = FALSE;
+
+        $this->smtp_port = $smtp_port;
+
+        $this->relay_host = $relay_host;
+
+        $this->time_out = 30; //is used in fsockopen()
+
+
+        $this->auth = $auth;//auth
+
+        $this->user = $user;
+
+        $this->pass = $pass;
+
+
+        $this->host_name = "localhost"; //is used in HELO command
+        $this->log_file = "";
+
+        $this->sock = FALSE;
+
+    }
+
+    /* Main Function */
+
+    function sendmail($to, $from, $subject = "", $body = "", $mailtype, $cc = "", $bcc = "", $additional_headers = "")
+    {
+
+        $mail_from = $this->get_address($this->strip_comment($from));
+
+        $body = preg_replace("/(^|(\r\n))(\.)/", "\1.\3", $body);
+
+        $header = "MIME-Version:1.0\r\n";
+
+        if ($mailtype == "HTML") {
+
+            $header .= "Content-Type:text/html\r\n";
+
+        }
+
+        $header .= "To: " . $to . "\r\n";
+
+        if ($cc != "") {
+
+            $header .= "Cc: " . $cc . "\r\n";
+
+        }
+
+        $header .= "From: $from<" . $from . ">\r\n";
+
+        $header .= "Subject: " . $subject . "\r\n";
+
+        $header .= $additional_headers;
+
+        $header .= "Date: " . date("r") . "\r\n";
+
+        $header .= "X-Mailer:By Redhat (PHP/" . phpversion() . ")\r\n";
+
+        list($msec, $sec) = explode(" ", microtime());
+
+        $header .= "Message-ID: <" . date("YmdHis", $sec) . "." . ($msec * 1000000) . "." . $mail_from . ">\r\n";
+
+        $TO = explode(",", $this->strip_comment($to));
+
+        if ($cc != "") {
+
+            $TO = array_merge($TO, explode(",", $this->strip_comment($cc)));
+
+        }
+
+        if ($bcc != "") {
+
+            $TO = array_merge($TO, explode(",", $this->strip_comment($bcc)));
+
+        }
+
+        $sent = TRUE;
+
+        foreach ($TO as $rcpt_to) {
+
+            $rcpt_to = $this->get_address($rcpt_to);
+
+            if (!$this->smtp_sockopen($rcpt_to)) {
+
+                $this->log_write("Error: Cannot send email to " . $rcpt_to . "\n");
+
+                $sent = FALSE;
+
+                continue;
+
+            }
+
+            if ($this->smtp_send($this->host_name, $mail_from, $rcpt_to, $header, $body)) {
+
+                $this->log_write("E-mail has been sent to <" . $rcpt_to . ">\n");
+
+            } else {
+
+                $this->log_write("Error: Cannot send email to <" . $rcpt_to . ">\n");
+
+                $sent = FALSE;
+
+            }
+
+            fclose($this->sock);
+
+            $this->log_write("Disconnected from remote host\n");
+
+        }
+
+        return $sent;
+
+    }
+
+    /* Private Functions */
+
+    function smtp_send($helo, $from, $to, $header, $body = "")
+    {
+
+        if (!$this->smtp_putcmd("HELO", $helo)) {
+
+            return $this->smtp_error("sending HELO command");
+
+        }
+
+        //auth
+        if ($this->auth) {
+
+            if (!$this->smtp_putcmd("AUTH LOGIN", base64_encode($this->user))) {
+
+                return $this->smtp_error("sending HELO command");
+
+            }
+
+            if (!$this->smtp_putcmd("", base64_encode($this->pass))) {
+
+                return $this->smtp_error("sending HELO command");
+
+            }
+
+        }
+
+
+        if (!$this->smtp_putcmd("MAIL", "FROM:<" . $from . ">")) {
+
+            return $this->smtp_error("sending MAIL FROM command");
+
+        }
+
+        if (!$this->smtp_putcmd("RCPT", "TO:<" . $to . ">")) {
+
+            return $this->smtp_error("sending RCPT TO command");
+
+        }
+
+        if (!$this->smtp_putcmd("DATA")) {
+
+            return $this->smtp_error("sending DATA command");
+
+        }
+
+        if (!$this->smtp_message($header, $body)) {
+
+            return $this->smtp_error("sending message");
+
+        }
+
+        if (!$this->smtp_eom()) {
+
+            return $this->smtp_error("sending <CR><LF>.<CR><LF> [EOM]");
+
+        }
+
+        if (!$this->smtp_putcmd("QUIT")) {
+
+            return $this->smtp_error("sending QUIT command");
+
+        }
+
+        return TRUE;
+
+    }
+
+    function smtp_sockopen($address)
+    {
+
+        if ($this->relay_host == "") {
+
+            return $this->smtp_sockopen_mx($address);
+
+        } else {
+
+            return $this->smtp_sockopen_relay();
+
+        }
+
+    }
+
+    function smtp_sockopen_relay()
+    {
+
+        $this->log_write("Trying to " . $this->relay_host . ":" . $this->smtp_port . "\n");
+
+        $this->sock = @fsockopen($this->relay_host, $this->smtp_port, $errno, $errstr, $this->time_out);
+
+        if (!($this->sock && $this->smtp_ok())) {
+
+            $this->log_write("Error: Cannot connenct to relay host " . $this->relay_host . "\n");
+
+            $this->log_write("Error: " . $errstr . " (" . $errno . ")\n");
+
+            return FALSE;
+
+        }
+
+        $this->log_write("Connected to relay host " . $this->relay_host . "\n");
+
+        return TRUE;
+
+    }
+
+    function smtp_sockopen_mx($address)
+    {
+
+        $domain = preg_replace("/^.+@([^@]+)$/", "\1", $address);
+
+        if (!@getmxrr($domain, $MXHOSTS)) {
+
+            $this->log_write("Error: Cannot resolve MX \"" . $domain . "\"\n");
+
+            return FALSE;
+
+        }
+
+        //专注与php学习 http://www.daixiaorui.com 欢迎您的访问
+
+        foreach ($MXHOSTS as $host) {
+
+            $this->log_write("Trying to " . $host . ":" . $this->smtp_port . "\n");
+
+            $this->sock = @fsockopen($host, $this->smtp_port, $errno, $errstr, $this->time_out);
+
+            if (!($this->sock && $this->smtp_ok())) {
+
+                $this->log_write("Warning: Cannot connect to mx host " . $host . "\n");
+
+                $this->log_write("Error: " . $errstr . " (" . $errno . ")\n");
+
+                continue;
+
+            }
+
+            $this->log_write("Connected to mx host " . $host . "\n");
+
+            return TRUE;
+
+        }
+
+        $this->log_write("Error: Cannot connect to any mx hosts (" . implode(", ", $MXHOSTS) . ")\n");
+
+        return FALSE;
+
+    }
+
+    function smtp_message($header, $body)
+    {
+
+        fputs($this->sock, $header . "\r\n" . $body);
+
+        $this->smtp_debug("> " . str_replace("\r\n", "\n" . "> ", $header . "\n> " . $body . "\n> "));
+
+        return TRUE;
+
+    }
+
+    function smtp_eom()
+    {
+
+        fputs($this->sock, "\r\n.\r\n");
+
+        $this->smtp_debug(". [EOM]\n");
+
+        return $this->smtp_ok();
+
+    }
+
+    function smtp_ok()
+    {
+
+        $response = str_replace("\r\n", "", fgets($this->sock, 512));
+
+        $this->smtp_debug($response . "\n");
+
+        if (!preg_match("/^[23]/", $response)) {
+
+            fputs($this->sock, "QUIT\r\n");
+
+            fgets($this->sock, 512);
+
+            $this->log_write("Error: Remote host returned \"" . $response . "\"\n");
+
+            return FALSE;
+
+        }
+
+        return TRUE;
+
+    }
+
+    function smtp_putcmd($cmd, $arg = "")
+    {
+
+        if ($arg != "") {
+
+            if ($cmd == "") $cmd = $arg;
+
+            else $cmd = $cmd . " " . $arg;
+
+        }
+
+        fputs($this->sock, $cmd . "\r\n");
+
+        $this->smtp_debug("> " . $cmd . "\n");
+
+        return $this->smtp_ok();
+
+    }
+
+    function smtp_error($string)
+    {
+
+        $this->log_write("Error: Error occurred while " . $string . ".\n");
+
+        return FALSE;
+
+    }
+
+    function log_write($message)
+    {
+
+        $this->smtp_debug($message);
+
+        if ($this->log_file == "") {
+
+            return TRUE;
+
+        }
+
+        $message = date("M d H:i:s ") . get_current_user() . "[" . getmypid() . "]: " . $message;
+
+        if (!@file_exists($this->log_file) || !($fp = @fopen($this->log_file, "a"))) {
+
+            $this->smtp_debug("Warning: Cannot open log file \"" . $this->log_file . "\"\n");
+
+            return FALSE;
+
+        }
+
+        flock($fp, LOCK_EX);
+
+        fputs($fp, $message);
+
+        fclose($fp);
+
+
+        return TRUE;
+
+    }
+
+
+    function strip_comment($address)
+    {
+
+        $comment = "/\([^()]*\)/";
+
+        while (preg_match($comment, $address)) {
+
+            $address = preg_replace($comment, "", $address);
+
+        }
+
+        return $address;
+
+    }
+
+
+    function get_address($address)
+    {
+
+        $address = preg_replace("/([ \t\r\n])+/", "", $address);
+
+        $address = preg_replace("/^.*<(.+)>.*$/", "\1", $address);
+
+        return $address;
+
+    }
+
+    function smtp_debug($message)
+    {
+
+        if ($this->debug) {
+
+            echo $message;
+
+        }
+
+    }
+
+
+}