监控报错日志文件

app/Console/Commands/ErrorLogMonitor.php

@@ -0,0 +1,188 @@
+<?php namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
+use App\libs\sms;
+
+class ErrorLogMonitor extends Command {
+
+	/**
+	 * The console command name.
+	 *
+	 * @var string
+	 */
+	protected $name = 'ErrorLogMonitor';
+	protected $YP_TPL_ID = '3390076';
+
+	/**
+	 * The console command description.
+	 *
+	 * @var string
+	 */
+	protected $description = '监控最近3分钟错误日志';
+
+    public function handle()
+    {
+        //本地测试路径
+//        $path = dirname(__FILE__).'\..\..\..\public';
+$path = '\log\seafood_log\error';
+        $fileName = '\\'.date('Y-m-d',time()).'.txt';
+        //判断文件是否存在
+        $fileName = $path.$fileName;
+        $fileRes = file_exists($fileName);
+        if($fileRes){
+            //读取文件内容
+            $contents = $this->tailWithSkip($fileName);
+            $arr = json_decode($contents,true);
+            $time = strtotime($arr['time']);
+
+            //判断最后一行时间是否在3分钟内
+            if(time()-$time <= 180){
+                //报警
+                $this->sendMsg('13161864516');
+            }
+        }
+    }
+
+    //获取文件最后一行内容
+    public function tailWithSkip($filepath, $lines = 1, $skip = 0, $adaptive = true)
+    {
+        // Open file
+        $f = @fopen($filepath, "rb");
+        if (@flock($f, LOCK_SH) === false) return false;
+        if ($f === false) return false;
+
+        // Sets buffer size, according to the number of lines to retrieve.
+        // This gives a performance boost when reading a few lines from the file.
+        $max=max($lines, $skip);
+        if (!$adaptive) $buffer = 4096;
+        else $buffer = ($max < 2 ? 64 : ($max < 10 ? 512 : 4096));
+
+        // Jump to last character
+        fseek($f, -1, SEEK_END);
+
+        // Read it and adjust line number if necessary
+        // (Otherwise the result would be wrong if file doesn't end with a blank line)
+        if (fread($f, 1) == "\n") {
+            if ($skip > 0) { $skip++; $lines--; }
+        } else {
+            $lines--;
+        }
+
+        // Start reading
+        $output = '';
+        $chunk = '';
+        // While we would like more
+        while (ftell($f) > 0 && $lines >= 0) {
+            // Figure out how far back we should jump
+            $seek = min(ftell($f), $buffer);
+
+            // Do the jump (backwards, relative to where we are)
+            fseek($f, -$seek, SEEK_CUR);
+
+            // Read a chunk
+            $chunk = fread($f, $seek);
+
+            // Calculate chunk parameters
+            $count = substr_count($chunk, "\n");
+            $strlen = mb_strlen($chunk, '8bit');
+
+            // Move the file pointer
+            fseek($f, -$strlen, SEEK_CUR);
+
+            if ($skip > 0) { // There are some lines to skip
+                if ($skip > $count) { $skip -= $count; $chunk=''; } // Chunk contains less new line symbols than
+                else {
+                    $pos = 0;
+
+                    while ($skip > 0) {
+                        if ($pos > 0) $offset = $pos - $strlen - 1; // Calculate the offset - NEGATIVE position of last new line symbol
+                        else $offset=0; // First search (without offset)
+
+                        $pos = strrpos($chunk, "\n", $offset); // Search for last (including offset) new line symbol
+
+                        if ($pos !== false) $skip--; // Found new line symbol - skip the line
+                        else break; // "else break;" - Protection against infinite loop (just in case)
+                    }
+                    $chunk=substr($chunk, 0, $pos); // Truncated chunk
+                    $count=substr_count($chunk, "\n"); // Count new line symbols in truncated chunk
+                }
+            }
+
+            if (strlen($chunk) > 0) {
+                // Add chunk to the output
+                $output = $chunk . $output;
+                // Decrease our line counter
+                $lines -= $count;
+            }
+        }
+
+        // While we have too many lines
+        // (Because of buffer size we might have read too many)
+        while ($lines++ < 0) {
+            // Find first newline and remove all text before that
+            $output = substr($output, strpos($output, "\n") + 1);
+        }
+
+        // Close file and return
+        @flock($f, LOCK_UN);
+        fclose($f);
+        return trim($output);
+    }
+
+    private function init(){
+        $ch = curl_init();
+        /* 设置验证方式 */
+        curl_setopt($ch, CURLOPT_HTTPHEADER, array('Accept:text/plain;charset=utf-8',
+            'Content-Type:application/x-www-form-urlencoded', 'charset=utf-8'));
+        /* 设置返回结果为流 */
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+
+        /* 设置超时时间*/
+        curl_setopt($ch, CURLOPT_TIMEOUT, 10);
+
+        /* 设置通信方式 */
+        curl_setopt($ch, CURLOPT_POST, 1);
+        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
+        return $ch;
+
+    }
+
+    public function sendMsg($phone){
+
+        $tpl_id = $this->YP_TPL_ID;
+        $ch=$this->init();
+        //$data=array('tpl_id' => $tpl_id,'text'=>$text,'apikey'=>YP_SMS_KEY,'mobile'=>$phone);
+        $data = [
+            'apikey' => YP_SMS_KEY,
+            'mobile' => $phone,
+            'tpl_id' => $tpl_id,
+        ];
+        $json_data = $this->tpl_send($ch,$data);
+        //print_r($json_data);    ******************************maybe影响验证码发出
+        $array = json_decode($json_data,true);
+        // echo '<pre>';print_r($array);
+        curl_close($ch);
+        return $array;
+    }
+
+    private function tpl_send($ch,$data){
+        curl_setopt ($ch, CURLOPT_URL, YP_TPL_URL);
+        curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($data));
+        $result = curl_exec($ch);
+        $error = curl_error($ch);
+        $this->checkErr($result,$error);
+        return $result;
+    }
+
+    private static function checkErr($result,$error) {
+        if($result === false)
+        {
+            echo 'Curl error: ' . $error;
+        }
+//        else
+//        {
+//            echo '操作完成没有任何错误';
+//        }
+    }
+}

app/Console/Kernel.php

@@ -55,6 +55,7 @@ class Kernel extends ConsoleKernel {
         'App\Console\Commands\FxSyncMjOrderStatus',
         'App\Console\Commands\SyncSkuToRedis',
         'App\Console\Commands\MonitorSkuToRedis',
+        'App\Console\Commands\ErrorLogMonitor',
     ];
 
 	/**