爬取卖家云订单脚本以及用户订单统计

app/Console/Commands/freightCost.php

@@ -2,6 +2,7 @@
 
 use App\Order;
 use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
 use Symfony\Component\Console\Input\InputOption;
 use Symfony\Component\Console\Input\InputArgument;
 
@@ -33,11 +34,26 @@ class freightCost extends Command {
 //        if(1 == $this->script){
 //            $this->getSession();
 //        } else if(2 == $this->script){
+        try{
+            $message = ' info start';
+            $this->log($message);
             $this->getFreightCost();
+        } catch (\Exception $exception) {
+            $message = ' error line:'.$exception->getLine().' message:'.$exception->getMessage();
+            $this->log($message);
+        }
+
 //        }
     }
 
-    public function getSession() {
+    public function log($message = '') {
+        error_log(date('Y-m-d H:i:s',time()).$message." \n ",3,"/log/seafood_log/".date('Y-m-d',time()).'freightCost.log');
+//        print_r($message."\n");
+    }
+
+    public function getSession($times = 0) {
+        $message = ' info getSession';
+        $this->log($message);
         //获取图片验证码
         $imgArr = $this->getImage();
         //百度OCR图片识别
@@ -83,7 +99,12 @@ class freightCost extends Command {
         );
 
         $res = $this->curlWithIpPorxy($method,$url,$params,$header);
-        return $res['words_result'][0]['words'];
+        if($res['words_result'][0]['words']){
+            return $res['words_result'][0]['words'];
+        } else {
+            $this->getSession();
+        }
+
     }
 
     //卖家云登录接口获取HTSESSIONID
@@ -106,10 +127,12 @@ class freightCost extends Command {
 
     //根据日期获取发货订单列表
     public function getFreightCost($times = 0) {
+        $message = ' info getFreightCost times:'.$times.' page:'.$this->page;
+        $this->log($message);
         $url = 'http://erp.maijiayun.cn/dd/print/statistics/list/deliver.ht';
         $method = 'post';
 //        $startDate = '2019-10-15 00:00:00';
-        $startDate = date('Y-m-d 00:00:00',strtotime('-5 days'));
+        $startDate = date('Y-m-d 00:00:00',strtotime('-30 days'));
         $endDate = date('Y-m-d 23:59:59',time());
 
         $params = array(
@@ -136,7 +159,9 @@ class freightCost extends Command {
 
         //失败次数超过3次自动停止
         if($times >= 3){
-            print_r($res);
+//            print_r($res);
+            $message = ' fail getFreightCost times:'.$times.' page:'.$this->page;
+            $this->log($message);
             echo 'FAIL';die;
         }
 
@@ -158,14 +183,16 @@ class freightCost extends Command {
         }
     }
 
-    //更新近十日订单
+    //更新近五日C仓订单
     public function updateFiveDaysOrder( $data ) {
         foreach( $data as $value ) {
             if( $value['logisticsCost'] > 0 ){
                 $freightCost = $value['logisticsCost'];
-                $re = Order::where('logistics_id',$value['expressCode'])->where('is_del',0)->where('warehouse',3)
+                $re = DB::table('order_copy')->where('logistics_id',$value['expressCode'])->where('is_del',0)->where('warehouse',3)
                     ->update(['freight_cost'=>$freightCost]);
-                echo $value['expressCode'].' ';
+//                echo $value['expressCode'].' ';
+                $message = ' success update code:'.$value['logisticsCost'];
+                $this->log($message);
             } else {
                 continue;
             }
@@ -242,7 +269,7 @@ class freightCost extends Command {
         if(preg_match('/Set-Cookie:[\s]+([^=]+)=([^;]+)/i', $result,$match)) {
             $cookies[$match[1]] = $match[2];
             $this->HTSESSIONID = $cookies['HTSESSIONID'];
-            print_r($cookies['HTSESSIONID']);
+//            print_r($cookies['HTSESSIONID']);
             return $cookies['HTSESSIONID'];
 //            foreach ($cookies as $cookieKey => $cookieVal ) {
 //                setcookie($cookieKey,$cookieVal);