监控templates点击量脚本

app/Console/Commands/Monitor.php

@@ -0,0 +1,109 @@
+<?php namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
+use App\libs\sms;
+define("YP_SMS_KEY", "fbdb5f2ddae13c2f4a592348bfe52137");
+define('YP_SMS_YHQ', '73a74eb72c42b765669acd8e94096b9f');
+define("YP_SMS_KEY_FAMLI",'995629e02beaaf47118b84ac19c4b5b9');
+define("YP_VOICE_URL", "http://voice.yunpian.com/v2/voice/send.json");
+define("YP_TPL_URL", "https://sms.yunpian.com/v2/sms/tpl_single_send.json");
+define("YP_TPL_ID", "3310818");
+
+class Monitor extends Command {
+
+
+    protected $signature = 'Monitor';
+    protected $phone = '13161864516';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = '监控template5分钟内点击量';
+
+    public function handle() {
+        set_time_limit(0);
+        ini_set('memory_limit', '1024M');
+        $this->monitor();
+    }
+
+    public function monitor() {
+        #统计一定时间区间内的uv频率
+        $startTime = strtotime(date('Y-m-d 08:00:00',time()));
+        $endTime = strtotime(date('Y-m-d 19:00:00',time()));
+        $currentTime = time();
+
+        if($startTime > $currentTime || $endTime < $currentTime){
+            return false;
+        }
+
+        $fiveMinuteBefore = date('Y-m-d H:i:s',strtotime('-5 minutes'));
+
+        $uv = DB::table('templates_log')->where('create_time','<=',date('Y-m-d H:i:s',$currentTime))->where('create_time','>=',$fiveMinuteBefore)->count();
+
+        if($uv < 10){
+            #发送验证码报警
+            $res = self::sendMsg($this->phone);
+            print_r($res);
+        }
+
+    }
+
+    private static 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 static function sendMsg($phone){
+
+        $tpl_id = YP_TPL_ID;
+        $ch=self::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 = self::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 static 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);
+        self::checkErr($result,$error);
+        return $result;
+    }
+
+    private static function checkErr($result,$error) {
+        if($result === false)
+        {
+            echo 'Curl error: ' . $error;
+        }
+//        else
+//        {
+//            echo '操作完成没有任何错误';
+//        }
+    }
+}

app/Console/Commands/freightCost.php

@@ -1,10 +1,7 @@
 <?php namespace App\Console\Commands;
 
-use App\Order;
 use Illuminate\Console\Command;
 use Illuminate\Support\Facades\DB;
-use Symfony\Component\Console\Input\InputOption;
-use Symfony\Component\Console\Input\InputArgument;
 
 class freightCost extends Command {
 

app/Console/Kernel.php

@@ -49,6 +49,7 @@ class Kernel extends ConsoleKernel {
         'App\Console\Commands\freightCost',
         'App\Console\Commands\CustomerOrder',
         'App\Console\Commands\CleaningData',
+        'App\Console\Commands\Monitor',
     ];
 
 	/**