监控异常运费订单

app/Console/Commands/MonitorEmptyFreightCost.php

@@ -0,0 +1,105 @@
+<?php namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
+define("YP_SMS_KEY_1", "fbdb5f2ddae13c2f4a592348bfe52137");
+
+class MonitorEmptyFreightCost extends Command {
+
+
+    protected $name = 'MonitorEmptyFreightCost';
+    protected $description = '监控分销商C仓已发货订单运费是否需要手动处理';
+    protected $templateId = '3750860';
+    protected $phoneArr = ['13161864516'];
+    protected $dr_name = '清平乐';
+
+
+    public function __construct()
+    {
+        parent::__construct();
+    }
+
+    public function handle()
+    {
+        $this->MonitorEmptyFreightCost();
+    }
+
+    public function MonitorEmptyFreightCost()
+    {
+        //查询2天前C仓已发货但订单运费为0的订单
+        $endTime = date('Y-m-d', strtotime('-2 days'));
+        $orderIdList = DB::table('order')->where('send_time','<',$endTime)->where('warehouse',3)->where('is_del',0)
+            ->where('logistics_id','>','')->where('status',3)->whereNull('freight_cost')->lists('id');
+        if(count($orderIdList) > 0) {
+            foreach($this->phoneArr as $phone) {
+                $this->sendMsg($phone, $orderIdList);
+            }
+        }
+        echo 'SUCCESS';
+    }
+
+    public function sendMsg($phone, $orders)
+    {
+        $orders = json_encode($orders,JSON_UNESCAPED_UNICODE);//防止中文被转义
+        $params = ('#order#').'='.$orders;
+        //提醒销售
+        self::sendMsgWithParams($phone,$params, $this->templateId);
+    }
+
+    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;
+
+    }
+    private static function checkErr($result,$error) {
+        if($result === false)
+        {
+            echo 'Curl error: ' . $error;
+        }
+//        else
+//        {
+//            echo '操作完成没有任何错误';
+//        }
+    }
+    private static function send($ch,$data){
+        curl_setopt ($ch, CURLOPT_URL, 'https://sms.yunpian.com/v2/sms/single_send.json');
+        curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($data));
+        $result = curl_exec($ch);
+        $error = curl_error($ch);
+        self::checkErr($result,$error);
+        return $result;
+    }
+
+    //有参数发送短信验证码
+    public static function sendMsgWithParams($phone, $params, $template_id) {
+        $ch=self::init();
+        $data=array('tpl_id' => $template_id,'apikey'=>YP_SMS_KEY_1,'mobile'=>$phone,'tpl_value'=>$params);
+        $json_data = self::send($ch,$data);
+        $array = json_decode($json_data,true);
+        curl_close($ch);
+        return $array;
+    }
+
+    //无参数发送短信验证码
+    public static function sendMsgSimple($phone, $template_id) {
+        $ch=self::init();
+        $data=array('tpl_id' => $template_id,'apikey'=>YP_SMS_KEY_1,'mobile'=>$phone);
+        $json_data = self::send($ch,$data);
+        $array = json_decode($json_data,true);
+        curl_close($ch);
+        return $array;
+    }
+
+}

app/Console/Kernel.php

@@ -57,6 +57,7 @@ class Kernel extends ConsoleKernel {
         'App\Console\Commands\MonitorSkuToRedis',
         'App\Console\Commands\ErrorLogMonitor',
         'App\Console\Commands\GroupFanAmountByMonth',
+        'App\Console\Commands\MonitorEmptyFreightCost',
     ];
 
 	/**