<?php
/**
 * @remark :
 * @name   :CountProject.php
 * @author :lyh
 * @method :post
 * @time   :2024/1/8 9:03
 */

namespace App\Console\Commands\DayCount;

use App\Helper\FormGlobalsoApi;
use App\Models\Domain\DomainInfo;
use App\Models\Inquiry\InquiryFormData;
use App\Models\Project\DeployOptimize;
use App\Models\Project\Project;
use App\Services\ProjectServer;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;
use App\Models\HomeCount\Count;

class CountProject extends Command
{
    const STATUS_ERROR = 400;
    public $error = 0;
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'count_project {project_id}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '按项目统计日记录';

    public function handle(){
        $project_id = $this->argument('project_id');
        ProjectServer::useProject($project_id);
        $this->count($project_id);
        DB::disconnect('custom_mysql');
    }

    /**
     * @remark :日统计记录
     * @name   :count
     * @author :lyh
     * @method :post
     * @time   :2024/1/8 9:05
     */
    public function count($project_id,$is_upgrade = 0){
        $list = DB::connection('custom_mysql')->table('gl_customer_visit')->select('updated_date')
            ->groupBy('updated_date')->get()->toArray();
        $project = new Project();
        $projectInfo = $project->read(['id'=>$project_id]);
        $projectOptimizeModel = new DeployOptimize();
        $optimizeInfo =  $projectOptimizeModel->read(['project_id'=>$project_id]);
        $domain = '';
        if(!empty($optimizeInfo['domain'])){
            $domainInfoModel = new DomainInfo();
            $domainInfo = $domainInfoModel->read(['id'=>$optimizeInfo['domain']]);
            if($domainInfo !== false){
                $domain = $domainInfo['domain'];
            }
        }
        if(empty($domain)){
            return false;
        }
        if(!empty($list)){
            $arr = [];
            foreach ($list as $k=>$v){
                $v = (array)$v;
                if($v['updated_date'] == date('Y-m-d')){
                    continue;
                }
                echo date('Y-m-d H:i:s') . '时间：'.$v['updated_date'] . PHP_EOL;
                $count = new Count();
                $arr['project_id'] = $project_id;
                $arr['date'] = $v['updated_date'];
                $arr['pv_num'] = $this->pv_num($v['updated_date']);
                $arr['ip_num'] = $this->ip_num($v['updated_date']);
                //服务达标天数
                $arr['compliance_day'] = $projectInfo['finish_remain_day'];
                //剩余服务时常
                $arr['service_day'] = $projectInfo['remain_day'];
                $arr = $this->inquiry($arr,$domain, $project_id,$projectInfo['is_upgrade'] ?? 0);
                if($arr === false){
                    continue;
                }
                //查询当天数据是否存在  存在则更新
                $info = $count->read(['date'=>$v['updated_date'],'project_id'=>$project_id]);
                if($info === false){
                    $arr['created_at'] = $v['updated_date'].' 01:00:00';
                    $arr['updated_at'] = $v['updated_date'].' 01:00:00';
                    $count->insert($arr);
                }else{
                    $count->edit($arr,['id'=>$info['id']]);
                }
            }
        }
        echo date('Y-m-d H:i:s') . 'end' . PHP_EOL;
    }

    /**
     * @remark :询盘数量
     * @name   :inquiry_num
     * @author :lyh
     * @method :post
     * @time   :2024/1/8 9:24
     */
    public function inquiry_num($day){
        $count = DB::connection('custom_mysql')->table('gl_customer_visit')->whereDate('updated_date', $day)->where('is_inquiry',1)->count();
        return $count;
    }

    /**
     * @name   :（统计pv）pv_num
     * @author :lyh
     * @method :post
     * @time   :2023/6/14 15:40
     */
    public function pv_num($day){
		$pv = DB::connection('custom_mysql')->table('gl_customer_visit')->whereDate('updated_date', $day)->sum('depth');
        return $pv;
    }

    /**
     * @name   :（统计ip）ip_num
     * @author :lyh
     * @method :post
     * @time   :2023/6/14 15:40
     */
    public function ip_num($day){
        $ip = DB::connection('custom_mysql')->table('gl_customer_visit')->whereDate('updated_date', $day)->count();
        return $ip;
    }

    /**
     * @param $arr
     * @param $domain
     * @name   :(询盘统计)inquiry
     * @author :lyh
     * @method :post
     * @time   :2023/6/14 15:44
     */
    public function inquiry($arr,$domain,$project_id,$is_upgrade = 0){
        $inquiry_list = (new FormGlobalsoApi())->getInquiryAll($domain,$is_upgrade);
        if($inquiry_list == false){
            return $arr;
        }
//        echo date('Y-m-d H:i:s') . '拉取询盘状态：' .json_encode($inquiry_list) . PHP_EOL;
        if($inquiry_list['status'] == self::STATUS_ERROR){
            $arr['inquiry_num'] = 0;
            $countryArr = [];
        }else{
            $arr['inquiry_num'] = $inquiry_list['data']['count'];
            //询盘国家统计
            $countryArr = $inquiry_list['data']['country'];
        }
        //加上其他询盘
        ProjectServer::useProject($project_id);
        $arr['inquiry_num'] += InquiryFormData::getCount();
        $countryData = InquiryFormData::getCountryCount();
        foreach ($countryData as $v1){
            if(isset($countryArr[$v1['country']])){
                $countryArr[$v1['country']] += $v1['count'];
            }else{
                $countryArr[$v1['country']] = $v1['count'];
            }
        }
        arsort($countryArr);
        $top20 = array_slice($countryArr, 0, 20, true);
        $arr['country'] = json_encode($top20);
        return $arr;
    }

}