novelPromote/app/Console/Commands/SunnyWxFansD...

<?php

namespace App\Console\Commands;

use App\Log;
use App\Models\SunnyTask;
use App\Services\HttpService;
use App\Services\SunService;
use Illuminate\Console\Command;

class SunnyWxFansData extends Command
{
    protected $signature = 'SunnyWxFansData {year?}';

    protected $description = '阳光平台每日粉丝变化数据获取';

    protected $year;

    public function __construct()
    {
        parent::__construct();
    }

    public function handle()
    {
        \DB::connection()->disableQueryLog();
        $this->year = $this->argument('year') ? $this->argument('year') : null;

        $this->info(date('m-d H:i:s') . ' 开始整理');
        $this->getFansData();

        $this->info(date('m-d H:i:s') . ' 整理结束');
    }

    public function getFansData()
    {
        if(is_null($this->year)) {
            $date = date('Y-m-d', strtotime('-1 days'));
            $this->getInfo($date);
        } else {
            for ($month = 1; $month <= 12; $month++) {
                $days = getDaysByMonth($this->year, $month);
                foreach ($days as $day) {
                    if($day > date("Y-m-d"))
                        return false;
                    sleep(2);
                    $this->getInfo($day);
                }
            }
        }

        return true;
    }

    public function getInfo($date)
    {
        try {
            $this->info($date);
            $sTime = $date . ' 00:00:00';
            $eTime = (($date . ' 23:59:59') > date('Y-m-d H:i:s')) ? date('Y-m-d H:i:s') : $date . ' 23:59:59';

            $params = [
                'vip_id' => SunService::VIP_ID,
                'start_time' => $sTime,
                'end_time' => $eTime,
            ];

            # 签名
            $params = SunService::sign($params);

            $requestUri = SunService::API_BASE_URL . SunService::FANS_DATA;

            # 获取响应数据
            $response = HttpService::httpPost($requestUri, $params);

            if($response === false)
                Log::logError('阳光粉丝数据获取失败' . $requestUri, $params, 'SunWxFans');

            $responseData = json_decode($response, true);

            if(isset($responseData['error_code']) && $responseData['error_code']==0) {
                # 记录任务信息
                $taskId = isset($responseData['data']['task_id']) ? $responseData['data']['task_id'] : null;
                if(empty($taskId)) {
                    Log::logError('粉丝每日数据获取任务失败', $responseData, 'SunWxFans');
                    $this->info('获取粉丝每日数据任务设置失败');
                    return false;
                }

                $result = SunnyTask::setTask($taskId, SunnyTask::FANS_DATA_TYPE);
                if(!$result) {
                    Log::logError('粉丝每日数据任务创建失败', [
                        'task_id' => $taskId,
                        'type' => SunnyTask::ORDER_TYPE
                    ], 'SunWxFans');
                    return false;
                }

            } else {
                Log::logError('粉丝每日数据任务获取失败', $responseData, 'SunWxFans');
                return false;
            }

        } catch (\Exception $e) {
            Log::logError('阳光粉丝每日数据获取发生异常', [
                'msg' => $e->getMessage(),
                'line' => $e->getLine(),
                'date' => $date
            ], 'SunWxFans');
            return false;
        }

        return true;
    }
}