high_per_api/app/services/TrackService.php

<?php

namespace App\services;

use App\model\DouyinTrack;
use support\Redis;
use support\Log;
use support\facade\Logger;

class TrackService 
{
    
    /**
     *  把请求信息，放到redis队列中
     *  @params  这是get请求的 数据的数组
     *  @fix     1 代表是从日志文件取出来的修复数据，默认是0；是监测链接过来的数据
     */
    public static function push ($params,$fix=0){
        $dycallback = getProp($params,'dycallback');
        if(empty($params['log_time'])){
            $params['log_time'] = date('Y-m-d H:i:s',time());
        }
        // 修复数据不需要-记录 json 日志信息;
        if (!$fix) {
            Logger::track(json_encode($params));
        }
        $track_data = json_encode($params);
        switch ($dycallback) {
            case 1:
                
                Redis::lpush('tiktok_track',$track_data);
                // if (!Redis::get('tiktok_track_deal_lock')) { // 锁住
                //     Redis::setEx('tiktok_track_deal_lock',1,1);
                //     self::TiktokRedisDeal();
                // }
                break;
            default:
                // code...
                break;
        }
    }
    
    /**
     *  定时任务批量处理
     */
    public static function cronDeal (){
        // 处理巨量平台的
        self::TiktokRedisDeal();
    }
    
    /**
     *  批量处理 巨量 平台发送过来的检测链接 数据信息。-避免过多的install
     */
    public static function TiktokRedisDeal ($data= []){
        if (!$data) {
            $len = Redis::llen('tiktok_track');
            //Logger::app('tiktok_track：len'.$len);
            if($len > 4000){
                $len= 4000;
            }
            for ($i = 1; $i <= $len; $i++) {
                 $data[] = Redis::rpop('tiktok_track');
            }
        }
        if(empty($data)){
            return false;
        }
        $inster = [] ;
        $model =  DouyinTrack::model();
        foreach ($data as $val){
           $params = json_decode($val,true);
           if(!getProp($params,'channel_id','')){
               continue;
           }
            //整理数据+
           $inster[] = [
                'link' => getProp($params,'link',''),
                'link_source' => 'tiktok',
                'ip' => getProp($params,'ip',''),
                'ua' => getProp($params,'ua',''),
                'source' => 'zsy',
                'ip_ua' => md5(getProp($params,'ip','') . getProp($params,'ua','')),
                'distribution_channel_id' => getProp($params,'channel_id',''),
                'log_time' => getProp($params,'log_time',''),
                'created_at' => date('Y-m-d H:i:s',time()),
                'adid' => getProp($params,'adid',''),
                'callback' => getProp($params,'clickid',''),
                //新添加
                'advertiser_id' => getProp($params,'advertiser_id',''),
                'campaign_id' => getProp($params,'campaign_id',''),
                'creativeid' => getProp($params,'creativeid',''),
                'callback'=> getProp($params,'callback',''),
                
            ];
            if(count($inster) >= 2000){
                $model->insert($inster);
                $inster = [];
            }
        }
        if ($inster) {
            $model->insert($inster);
        }
    }
    
    
}