'修复推送用户数据混乱'

app/Console/Commands/FixPushUserChannel.php

@@ -0,0 +1,75 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Modules\Book\Models\BookConfig;
+use App\Modules\Book\Services\BookConfigService;
+use App\Modules\Push\Models\QappPushUser;
+use GuzzleHttp\Cookie\SetCookie;
+use Illuminate\Console\Command;
+use GuzzleHttp\Client;
+use App\Modules\Book\Models\Book;
+use App\Modules\Book\Models\Chapter;
+use DB;
+
+class FixPushUserChannel extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'FixPushUserChannel {--channel_id=} {--distribution_channel_id=}';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Command description';
+
+    /**
+     * Create a new command instance.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+        parent::__construct();
+    }
+
+    /**
+     * Execute the console command.
+     *
+     * @return mixed
+     */
+    public function handle()
+    {
+        $channel_id = $this->option('channel_id');
+        $distribution_channel_id = $this->option('distribution_channel_id');
+        //
+        $qapp_push_users = QappPushUser::leftjoin('users','users.id','qapp_push_user.uid')
+            ->leftjoin('qapp_push_app',function($join){
+                $join->on('users.distribution_channel_id','=','qapp_push_app.uid')
+                    ->on('qapp_push_user.provider','=','qapp_push_app.provider');
+            })
+            ->where('qapp_push_user.channel_id',$channel_id)
+            ->where('users.distribution_channel_id',$distribution_channel_id)
+            ->select('qapp_push_user.*','users.send_order_id','users.distribution_channel_id','qapp_push_app.app_id as appId')
+            ->get();
+        if(!$qapp_push_users->isEmpty()){
+            try {
+                foreach($qapp_push_users as $item){
+                    if($item->distribution_channel_id != $item->channel_id && $item->app_id != $item->appId){
+                        DB::table('qapp_push_user')->where('id',$item->id)->update(['app_id' => $item->appId, 'channel_id' => $item->distribution_channel_id]);
+                    }
+                }
+            } catch (\Exception $e) {
+                \Log::info('FixPushUserChannel_error:channel_id'.$channel_id.' distribution_channel_id:'.$distribution_channel_id);
+                \Log::info('FixPushUserChannel_error:'.$e->getMessage());
+            }
+
+        }
+    }
+
+}

app/Console/Kernel.php

@@ -38,6 +38,7 @@ class Kernel extends ConsoleKernel
         Commands\updateFromNewYunqi::class,
         Commands\CheckOrderStatus::class,
         Commands\NewVersionPrepare::class,
+        Commands\FixPushUserChannel::class,
         Commands\Test::class,
     ];