novelPromote/app/Console/Commands/SunnyOrder.php

<?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 SunnyOrder extends Command
{
    protected $signature = 'SunnyOrder {year?}';

    protected $description = '阳光平台订单数据任务创建';

    protected $year;

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

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

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

    public function getOrderList()
    {
        if(is_null($this->year)) {
            if(date('Y-m-d H:i:s') <= date('Y-m-d') . ' 00:00:10') {
                $date = date('Y-m-d', strtotime('-1 days'));
            } else {
                $date = date('Y-m-d');
            }

            $this->order($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->order($day);
                }
            }
//            $this->order($this->year);
        }

        return true;
    }

    public function order($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::ORDER_LIST;

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

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

            $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, 'SunOrder');
                    $this->info('获取账号列表任务设置失败');
                    return false;
                }

                $result = SunnyTask::setTask($taskId, SunnyTask::ORDER_TYPE);
                if(!$result) {
                    Log::logError('订单列表获取任务创建失败', [
                        'task_id' => $taskId,
                        'type' => SunnyTask::ORDER_TYPE
                    ], 'SunOrder');
                    return false;
                }

            } else {
                Log::logError('订单列表获取任务获取失败', $responseData, 'SunOrder');
                return false;
            }

        } catch (\Exception $e) {
            Log::logError('阳光平台订单数据异常', [
                'msg' => $e->getMessage(),
                'line' => $e->getLine()
            ], 'SunOrder');

            return false;
        }

        return true;
    }
}