getdata.mywigs.com/controllers/IndexController.php

<?php

namespace app\controllers;

use Yii;
use yii\filters\AccessControl;
use yii\web\Controller;
use yii\web\Response;
use yii\filters\VerbFilter;
use app\lib\GA;
use app\models\ContentPage;
use app\models\Trafficsource;
use yii\data\Pagination;

class IndexController extends Controller
{
   

  
    public function  actionIndex(){
      echo 111;exit;
    }
    public function actionContentpage(){
      $request = Yii::$app->request;
      \Yii::$app->response->format = \yii\web\Response::FORMAT_JSON;
      $store = $request->get('store', "supernova");  
      $limit = $request->get('limit', "10");  
      $page = $request->get('page', "1"); 
      
      $page=$page-1>=0?$page-1:0;
      $where=[];
      if(!$store){
        return ['status'=>false,'msg'=>"参数异常"];
      }
      $where['store']=$store;

      $query=ContentPage::find()->where(["store"=>$where]);
      $count = $query->count();
      $pagination = new Pagination(['totalCount' => $count,'pageSize'=>$limit,'page'=>$page]);

      $items = $query->offset($pagination->offset)
          ->limit($pagination->limit)
          ->orderBy([
            'pageviews'=>SORT_DESC,
            'id'=>SORT_DESC
          ])
          ->all();
        foreach($items as $k=>$v){
          $items[$k]['created_at']=date('Y-m-d H:i:s',$v['created_at']);
        }
      $data=[
        'total'=>$count,
        'items'=>$items,
      ];
      
      return [
        'code' => 200,
        'data'=>$data,
        'status'=>true    
      ];
    }

    public function actionSynsdata(){
      $ga=new GA();
      $store="supernova";
      $request = Yii::$app->request;
      $start_day = $request->get('start', date('Y-m-d'),time()-24*3600);
      $end_day=$start_day;
      $contentpages=$ga->contentpages($store,$start_day,$end_day);
      $this->addContentpages($contentpages,$store);

      $data=$ga->trafficsource($store,$start_day,$end_day);
      $this->addSource($data,$store);
      echo $start_day." 任务完成";
      exit;


     

    }
    public function addSource($data,$store){
      $i=1;
      $limit=200;
      $modelKey=[
        'date',
        'store',
        'source',
        'channelGrouping',
        'landingPagePath',
        'keyword',
        'socialNetwork',
        'users',
        'newUsers',
        'sessions',
        'bounceRate',
        'pageviewsPerSession',
        'avgSessionDuration',
        'transactionsPerVisit',
        'transactions',
        'transactionRevenue',
        'created_at',
      ];
      if(!empty($data)){
        $list=[];
        foreach($data as $k=>$v){
          $item=[
            date('Y-m-d',strtotime($v['date'])),
            $store,
            $v['source'],
            $v['channelGrouping'],
            $v['landingPagePath']!=="(not set)"?$v["landingPagePath"]:"",
            $v['keyword']!=="(not set)"?$v['keyword']:"",
            $v['socialNetwork']!=="(not set)"?$v['socialNetwork']:"",
            $v['users'],
            $v['newUsers'],
            $v['sessions'],
            $v['bounceRate'],
            $v['pageviewsPerSession'],
            $v['avgSessionDuration'],
            $v['transactionsPerVisit'],
            $v['transactions'],
            $v['transactionRevenue'],
            time(),
          ];
          $list[]=$item;
          if($i%$limit==0||$i==count($data)){
            \Yii::$app->db->createCommand()->batchInsert(Trafficsource::tableName(), $modelKey, $list)->execute();
            $list=[];
            echo "addSource 任务完成".$i."个"."\n";
          }
          $i++;
        }
        echo "addSource 任务全部完成"."\n";
      }
    }




    public function addContentpages($contentpages,$store){
        $i=1;
        $limit=20;
        $modelKey=[
          'pagePath',
          'store',
          'date',
          'pageviews',
          'uniquePageviews',
          'avgTimeOnPage',
          'entrances',
          'bounceRate',
          'exitRate',
          'pageValue',
          'created_at',
        ];
        if(!empty($contentpages)){
          $list=[];
          foreach($contentpages as $k=>$v){
            $item=[
              $v['pagePath'],
              $store,
              date('Y-m-d',strtotime($v['date'])),
              $v['pageviews'],
              $v['uniquePageviews'],
              $v['avgTimeOnPage'],
              $v['entrances'],
              $v['bounceRate'],
              $v['exitRate'],
              $v['pageValue'],
              time(),
            ];
            $list[]=$item;
            if($i%$limit==0||$i==count($contentpages)){
              \Yii::$app->db->createCommand()->batchInsert(ContentPage::tableName(), $modelKey, $list)->execute();
              $list=[];
              echo "addContentpages 任务完成".$i."个"."\n";
            }
            $i++;
          }
          echo "addContentpages 任务全部完成"."\n";
        }

    }

  }