剧目提审,使用提审时候的appid进行审核状态检测

app/Console/Commands/Video/WechatCheck/SyncDramaInfo.php

@@ -33,7 +33,6 @@ class SyncDramaInfo extends Command
         if($drama_ids) {
             $dramaIds = explode(',', $drama_ids);
         }
-        $accessToken = $this->getAccessToken();
         DB::table('video_wechat_check')
             ->when($dramaIds, function ($query, $dramaIds) {
                 return $query->whereIn('drama_id', $dramaIds);
@@ -43,10 +42,11 @@ class SyncDramaInfo extends Command
                 'status' => 1,
                 'is_enabled' => 1
             ])
-            ->select('drama_id', 'id', 'status')
+            ->select('drama_id', 'id', 'status', 'appid')
             ->orderBy('id')
-            ->chunk(100, function ($items) use ($accessToken){
+            ->chunk(100, function ($items) {
                 foreach ($items as $item) {
+                    $accessToken = $this->getAccessToken($item->appid ?: config('wechat.duanju.masterAppid'));
                     $result = HttpRequestService::simplePost(WechatURL::vod_getdrama. $accessToken, [
                         'drama_id' => $item->drama_id
                     ]);
@@ -71,7 +71,7 @@ class SyncDramaInfo extends Command
             });
     }
 
-    private function getAccessToken() {
-        return Redis::get(AccessTokenService::getAccessTokenRedisKey(config('wechat.duanju.masterAppid')));
+    private function getAccessToken($appid) {
+        return Redis::get(AccessTokenService::getAccessTokenRedisKey($appid));
     }
 }