mtb_dcatadmin_plus/app/Console/Commands/TimerSsmPost.php

<?php

namespace App\Console\Commands;

use App\Distributor\Repositories\SmmPost;
use App\Distributor\Repositories\SmmPostLog;
use App\Distributor\Repositories\SmmUserAccount;
use App\Libraries\CommonHelper;
use App\Services\SmmService;
use Carbon\Carbon;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;
use Symfony\Component\DomCrawler\Crawler;


/**
 * 定时任务：发送社媒帖子
 * php artisan timer:ssmPost
 */
class TimerSsmPost extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'timer:ssmPost';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '发送社媒帖子';


    public function handle()
    {
        //创建日志
        $this->createLog();

        //刷新access_token
        $this->refreshAccessToken();
        exit;

        //发送社媒帖子开始
        $sendLog = SmmPostLog::getSendLog(5);
        $logIds = [];
        foreach ($sendLog as $log) {
            if ($log->media_name == 'twitter' && SmmPostLog::twitterCanSend() == false) {
                //15分钟内不重复发送
                    echo 'twitter可发送时间未到，暂时无法发送,ID'.$log->post_id;
                    continue;
            }
            $logIds[] = $log->id;
            //获取帖子内容
            $post = SmmPost::getPostById($log->post_id);
            $message = $post->message;
            $imageVideoUrl = $post->image_video_url;
            $mediaName = $log->media_name;
            $postType = $post->post_type;
            $accountInfo = SmmUserAccount::getAccountById($log->account_id);
            $accessToken = $accountInfo->access_token;
            //发送帖子
            $configData = ['accountInfo' => $accountInfo->toArray()];
            $ssmService = new SmmService($mediaName,$configData);
            if ($postType == 0) {
                //图片帖子
                $imageVideoUrl = explode(',', $imageVideoUrl);
                foreach ($imageVideoUrl as $key => $url) {
                    $imageVideoUrl[$key] = CommonHelper::ossUrl($url);
                }
                $response = $ssmService->postImage($message, $imageVideoUrl,$accessToken);
            } else {
                $imageVideoUrl = CommonHelper::ossUrl($imageVideoUrl);
                $response = $ssmService->postVideo($message, $imageVideoUrl,$accessToken);
            }
            //更新post_logs表
            if ($response['status'] == true) {
                $log->status = 1;
                $log->response_ids = json_encode($response['data']['responseIds']);
                $log->updated_at = Carbon::now();
                $log->send_time = Carbon::now();
                $log->save();
            } else {
                $log->status = 2;
                $log->remark = $response['data'];
                $log->updated_at = Carbon::now();
                $log->send_time = Carbon::now();
                $log->save();
            }
        }

        $logIds = print_r($logIds);
        dd('发送社媒帖子完成'.$logIds);
    }

    /*
     * access_token 过期重新获取
     * 1.Facebook 有效期60天，要手动重新获取
     * 2.Instagram 与 Facebook 一样
     * YouTube 有效期为 3600 秒，提前 10 分钟更新 access_token
     * Twitter 好像是过期
     */


    public function refreshAccessToken()
    {
        $accounts = SmmUserAccount::getAllYouTubeUserAccounts();
        foreach ($accounts as $account) {
            try {
                $expiresAt = Carbon::parse($account->expires_at);
                if ($expiresAt->diffInSeconds(Carbon::now()) <= 3000) {
                    $mediaName = $account->getParent->name;
                    $configData = ['accountInfo' => $account->toArray()];

                    $ssmService = new SmmService($mediaName, $configData);
                    $result = $ssmService->refreshAccessToken($account->refresh_token);

                    $account->update([
                        'access_token' => $result['data']['access_token'],
                        'expires_at' => Carbon::parse($result['data']['expires_at']->format('Y-m-d H:i:s')),
                        'refresh_token' => $result['data']['refresh_token'],
                    ]);

                    echo 'access_token 刷新成功：'. $account->name. "\n";
                }
            } catch (\Exception $e) {
                continue;
            }
        }
    }

    /*
     * 生成发送帖子日志
     */
    public function createLog()
    {
        // 发送社媒帖子
        $waitPost = SmmPost::getWaitPost();
        foreach ($waitPost as $post) {
            //插入post_logs表
            $accountIds = explode(',', $post->account_ids);
            $accounts = SmmUserAccount::getAccountsByIds($accountIds);
            foreach ($accounts as $account) {
                $send_time = $post->send_time;
                // 如果是Twitter,15分钟内只能发一个帖
                if ($account->getParent->name == 'Twitter') {
                    $send_time = SmmPostLog::getTwitterSendTime($send_time);
                }
                //生成post_logs表数据
                $data = [
                    'post_id' => $post->id,
                    'account_id' => $account->id,
                    'account_name' => $account->name,
                    'status' => 0,
                    'remark' => '',
                    'created_at' => Carbon::now(),
                    'updated_at' => Carbon::now(),
                    'dist_id' => $account->dist_id,
                    'media_name' => $account->getParent->name,
                    'response_ids'=> '',
                    'send_time' => $send_time,
                ];
                SmmPostLog::createLog($data);
            }
            $post->status = 1;
            $post->save();
        }
    }

}