default report type

app/Console/Commands/BookTest.php

@@ -26,6 +26,7 @@ use App\Modules\SendOrder\Models\SendOrder;
 use App\Modules\SendOrder\Services\SendOrderService;
 use App\Modules\Subscribe\Models\Order;
 use App\Jobs\SendStatisticsList;
+use App\Jobs\UserAddDeskJob;
 use App\Modules\OfficialAccount\Models\ForceSubscribeUsers;
 use App\Modules\User\Services\UserSignService;
 use App\Modules\Book\Models\BookUvStat;
@@ -76,7 +77,9 @@ class BookTest extends Command
         //$this->transfromUserOrder();
         //$this->clearUserReadRecord();
         //$this->deleteToLongReadRecord();
-        $this->clearUserReadRecord();
+        // $this->clearUserReadRecord();
+        $job = new UserAddDeskJob(205384691);
+        $job->handle();
     }
 
 
@@ -94,42 +97,43 @@ class BookTest extends Command
         file_put_contents($file_name, $temp, FILE_APPEND);
     }
 
-    public function data1(){
+    public function data1()
+    {
         //1,图书uv
         $keys = Redis::SMEMBERS('book_before_five_uvs');
-        if(!$keys){
+        if (!$keys) {
             return 0;
         }
         $data = [];
         $book_name_arr = [];
         $i = 0;
-        foreach ($keys as $k){
-            $k_array = explode('_',$k);
-            $uv = Redis::scard('book_before_five_uv_'.$k);
-            Redis::del('book_before_five_uv_'.$k);
-            if(isset($book_name_arr[$k_array[1]]) &&  !empty($book_name_arr[$k_array[1]])){
+        foreach ($keys as $k) {
+            $k_array = explode('_', $k);
+            $uv = Redis::scard('book_before_five_uv_' . $k);
+            Redis::del('book_before_five_uv_' . $k);
+            if (isset($book_name_arr[$k_array[1]]) &&  !empty($book_name_arr[$k_array[1]])) {
                 $book_name = $book_name_arr[$k_array[1]];
-            }else{
-                $book_name_info = DB::table('book_configs')->where('bid',$k_array[1])->select('book_name')->first();
-                if($book_name_info){
+            } else {
+                $book_name_info = DB::table('book_configs')->where('bid', $k_array[1])->select('book_name')->first();
+                if ($book_name_info) {
                     $book_name_arr[$k_array[1]] = $book_name_info->book_name;
                     $book_name = $book_name_info->book_name;
-                }else{
+                } else {
                     $book_name = '未知';
                 }
             }
 
             $data[] = [
-                'bid'=>$k_array[1],
-                'day'=>$k_array[0],
-                'sequence'=>$k_array[2],
-                'book_name'=>$book_name,
-                'uv'=>$uv,
-                'created_at'=>date('Y-m-d H:i:s'),
-                'updated_at'=>date('Y-m-d H:i:s')
+                'bid' => $k_array[1],
+                'day' => $k_array[0],
+                'sequence' => $k_array[2],
+                'book_name' => $book_name,
+                'uv' => $uv,
+                'created_at' => date('Y-m-d H:i:s'),
+                'updated_at' => date('Y-m-d H:i:s')
             ];
             $i++;
-            if($i && $i%200 == 0){
+            if ($i && $i % 200 == 0) {
                 DB::table('book_five_chapter_uv')->insert($data);
                 $data = [];
             }
@@ -138,23 +142,24 @@ class BookTest extends Command
         Redis::del('book_before_five_uvs');
     }
 
-    public function data2(){
+    public function data2()
+    {
         //强关
         $keys = Redis::SMEMBERS('subscribe_page_uv_send_order_ids');
         $data = [];
         $i = 0;
-        foreach ($keys as $k){
-            $subscribe_uv = Redis::scard('subscribe_page_uv'.$k);
-            Redis::del('subscribe_page_uv'.$k);
+        foreach ($keys as $k) {
+            $subscribe_uv = Redis::scard('subscribe_page_uv' . $k);
+            Redis::del('subscribe_page_uv' . $k);
             $data[] = [
-                'send_order_id'=>$k,
-                'subscribe_uv'=>$subscribe_uv,
-                'pay_uv'=>0,
-                'created_at'=>date('Y-m-d H:i:s'),
-                'updated_at'=>date('Y-m-d H:i:s')
+                'send_order_id' => $k,
+                'subscribe_uv' => $subscribe_uv,
+                'pay_uv' => 0,
+                'created_at' => date('Y-m-d H:i:s'),
+                'updated_at' => date('Y-m-d H:i:s')
             ];
             $i++;
-            if($i && $i%200 == 0){
+            if ($i && $i % 200 == 0) {
                 DB::table('subscribe_pay_page_uv')->insert($data);
                 $data = [];
             }
@@ -165,21 +170,21 @@ class BookTest extends Command
         $data = [];
         //支付
         $keys = Redis::SMEMBERS('pay_page_uv_send_order_ids');
-        foreach ($keys as $v){
-            $pay_uv = Redis::scard('pay_page_uv'.$v);
-            Redis::del('pay_page_uv'.$v);
-            $o = DB::table('subscribe_pay_page_uv')->where('send_order_id',$v)->first();
-            if($o){
-                DB::table('subscribe_pay_page_uv')->where('send_order_id',$v)->update([
-                    'pay_uv'=>$pay_uv
+        foreach ($keys as $v) {
+            $pay_uv = Redis::scard('pay_page_uv' . $v);
+            Redis::del('pay_page_uv' . $v);
+            $o = DB::table('subscribe_pay_page_uv')->where('send_order_id', $v)->first();
+            if ($o) {
+                DB::table('subscribe_pay_page_uv')->where('send_order_id', $v)->update([
+                    'pay_uv' => $pay_uv
                 ]);
-            }else{
+            } else {
                 DB::table('subscribe_pay_page_uv')->insert([
-                    'send_order_id'=>$v,
-                    'subscribe_uv'=>0,
-                    'pay_uv'=>$pay_uv,
-                    'created_at'=>date('Y-m-d H:i:s'),
-                    'updated_at'=>date('Y-m-d H:i:s')
+                    'send_order_id' => $v,
+                    'subscribe_uv' => 0,
+                    'pay_uv' => $pay_uv,
+                    'created_at' => date('Y-m-d H:i:s'),
+                    'updated_at' => date('Y-m-d H:i:s')
                 ]);
             }
         }
@@ -187,15 +192,18 @@ class BookTest extends Command
         Redis::del('pay_page_uv_send_order_ids');
     }
 
-    public function testTest(){
+    public function testTest()
+    {
         $res = \App\Modules\Statistic\Services\WapVisitStatService::smartPushTestBookStats(6);
-        echo \Hashids::encode(6).PHP_EOL;
+        echo \Hashids::encode(6) . PHP_EOL;
         print_r($res);
     }
 
-    private function testBookChapterStats(){
+    private function testBookChapterStats()
+    {
 
-        function t($bid,$vip_seq){
+        function t($bid, $vip_seq)
+        {
             $data = [];
             $key1 = 'smartPushTestBookPayPageUv:bid:%s';
             $pay_page_uv = 0;
@@ -205,150 +213,154 @@ class BookTest extends Command
 
             $amount = 0;
 
-            for ($i = 1;$i<=60;$i++){
+            for ($i = 1; $i <= 60; $i++) {
                 $key3 = 'smartPushTestBookChapterUv:bid:%s:seq:%s';
-                $sequence_uv = (int)(Redis::scard(sprintf($key3,$bid,$i)));
-                if(!$sequence_uv){
+                $sequence_uv = (int)(Redis::scard(sprintf($key3, $bid, $i)));
+                if (!$sequence_uv) {
                     continue;
                 }
                 $data[] = [
-                    'bid'=>$bid,
-                    'sequence'=>$i,
-                    'sequence_uv'=>$sequence_uv,
-                    'vip_sequence'=>$vip_seq,
-                    'pay_page_uv'=>$pay_page_uv,
-                    'paid_user_num'=>$paid_num,
-                    'amount'=>$amount,
-                    'created_at'=>date('Y-m-d H:i:s'),
-                    'updated_at'=>date('Y-m-d H:i:s')
+                    'bid' => $bid,
+                    'sequence' => $i,
+                    'sequence_uv' => $sequence_uv,
+                    'vip_sequence' => $vip_seq,
+                    'pay_page_uv' => $pay_page_uv,
+                    'paid_user_num' => $paid_num,
+                    'amount' => $amount,
+                    'created_at' => date('Y-m-d H:i:s'),
+                    'updated_at' => date('Y-m-d H:i:s')
                 ];
                 //Redis::del($sequence_uv);
             }
-            if($data){
+            if ($data) {
                 DB::table('test_book_smart_push_stats20190709')->insert($data);
             }
         }
-        for ($i = 1;$i<6539;$i++){
-            t($i,0);
+        for ($i = 1; $i < 6539; $i++) {
+            t($i, 0);
         }
     }
-    private function testBookSmartPushStats(){
+    private function testBookSmartPushStats()
+    {
         $sql1 = 'TRUNCATE test_book_smart_push_stats';
         DB::update($sql1);
-        $result = DB::table('book_configs')->whereIn('test_status',[1,2])->select('bid','vip_seq')->get();
+        $result = DB::table('book_configs')->whereIn('test_status', [1, 2])->select('bid', 'vip_seq')->get();
         /*foreach ($result as $v){
             t($v->bid,$v->vip_seq);
         }*/
-        function t($bid,$vip_seq){
+        function t($bid, $vip_seq)
+        {
             $data = [];
             $key1 = 'smartPushTestBookPayPageUv:bid:%s';
-            $pay_page_uv = (int)(Redis::scard(sprintf($key1,$bid)));
+            $pay_page_uv = (int)(Redis::scard(sprintf($key1, $bid)));
 
             $key2 = 'smartPushTestBookPaidUv:bid:%s';
-            $paid_num = (int)(Redis::scard(sprintf($key2,$bid)));
+            $paid_num = (int)(Redis::scard(sprintf($key2, $bid)));
 
-            $amount = Redis::Hget('smartPushTestBookPaidAmount',$bid);
-            if(!$amount)
+            $amount = Redis::Hget('smartPushTestBookPaidAmount', $bid);
+            if (!$amount)
                 $amount = 0;
 
-            for ($i = 1;$i<=60;$i++){
+            for ($i = 1; $i <= 60; $i++) {
                 $key3 = 'smartPushTestBookChapterUv:bid:%s:seq:%s';
-                $sequence_uv = (int)(Redis::scard(sprintf($key3,$bid,$i)));
-                if(!$sequence_uv){
+                $sequence_uv = (int)(Redis::scard(sprintf($key3, $bid, $i)));
+                if (!$sequence_uv) {
                     continue;
                 }
                 $data[] = [
-                    'bid'=>$bid,
-                    'sequence'=>$i,
-                    'sequence_uv'=>$sequence_uv,
-                    'vip_sequence'=>$vip_seq,
-                    'pay_page_uv'=>$pay_page_uv,
-                    'paid_user_num'=>$paid_num,
-                    'amount'=>$amount,
-                    'created_at'=>date('Y-m-d H:i:s'),
-                    'updated_at'=>date('Y-m-d H:i:s')
+                    'bid' => $bid,
+                    'sequence' => $i,
+                    'sequence_uv' => $sequence_uv,
+                    'vip_sequence' => $vip_seq,
+                    'pay_page_uv' => $pay_page_uv,
+                    'paid_user_num' => $paid_num,
+                    'amount' => $amount,
+                    'created_at' => date('Y-m-d H:i:s'),
+                    'updated_at' => date('Y-m-d H:i:s')
                 ];
             }
-            if($data){
+            if ($data) {
                 DB::table('test_book_smart_push_stats')->insert($data);
             }
         }
-        foreach ($result as $v){
-            t($v->bid,$v->vip_seq);
+        foreach ($result as $v) {
+            t($v->bid, $v->vip_seq);
         }
     }
 
-    private function sendOrderStats105(){
+    private function sendOrderStats105()
+    {
         //$sql1 = 'TRUNCATE send_order_stats_105';
         //DB::update($sql1);
         $send_order_ids = Redis::hgetall('sendOrderIdToBid');
-        if(!$send_order_ids){
-            return ;
+        if (!$send_order_ids) {
+            return;
         }
 
-        function one(int $sendOrderId,int $time){
+        function one(int $sendOrderId, int $time)
+        {
             $info = SendOrderService::getById($sendOrderId);
-            if(!$info || !$info->book_id){
-                return ;
+            if (!$info || !$info->book_id) {
+                return;
             }
             $subscribe_chaper_seq = 0;
-            if($info && $info->subscribe_chapter_seq){
+            if ($info && $info->subscribe_chapter_seq) {
                 $subscribe_chaper_seq = $info->subscribe_chapter_seq;
             }
-            if(!$subscribe_chaper_seq){
-                $subscribe = BookSubscribleChapterService::getSubcribleChapter($info->book_id,$info->distribution_channel_id);
+            if (!$subscribe_chaper_seq) {
+                $subscribe = BookSubscribleChapterService::getSubcribleChapter($info->book_id, $info->distribution_channel_id);
                 if ($subscribe) {
                     $subscribe_chaper_seq =   (isset($subscribe->subscribe_chapter_id) && $subscribe->subscribe_chapter_id > 0) ? $subscribe->subscribe_chapter_id : 0;
                 }
             }
 
-            $key_1 = 'accurateSendOrderSubscribePageUv:bid:%s:sendorderid:'.$sendOrderId;
+            $key_1 = 'accurateSendOrderSubscribePageUv:bid:%s:sendorderid:' . $sendOrderId;
             //强关页面uv
-            $subscribe_uv = (int)(Redis::scard(sprintf($key_1,$info->book_id)));
-            Redis::del( sprintf($key_1,$info->book_id) );
-            $key_2 = 'accurateSendOrderPayPageUv:bid:%s:send_order_id:'.$sendOrderId;
+            $subscribe_uv = (int)(Redis::scard(sprintf($key_1, $info->book_id)));
+            Redis::del(sprintf($key_1, $info->book_id));
+            $key_2 = 'accurateSendOrderPayPageUv:bid:%s:send_order_id:' . $sendOrderId;
             //付费页面UV
-            $pay_page_uv = (int)(Redis::scard(sprintf($key_2,$info->book_id)));
+            $pay_page_uv = (int)(Redis::scard(sprintf($key_2, $info->book_id)));
 
-            Redis::del( sprintf($key_2,$info->book_id) );
+            Redis::del(sprintf($key_2, $info->book_id));
             //强关数
             $subscribe_num = DB::table('force_subscribe_users')
-                ->where('send_order_id',$sendOrderId)
-                ->where('bid',$info->book_id)
-                ->where('created_at','>=',date('Y-m-d H:i:s',$time))
+                ->where('send_order_id', $sendOrderId)
+                ->where('bid', $info->book_id)
+                ->where('created_at', '>=', date('Y-m-d H:i:s', $time))
                 ->count();
 
             $paid_user_num = DB::table('orders')
-                ->where('send_order_id',$sendOrderId)
-                ->where('from_bid',$info->book_id)
-                ->where('status','PAID')
-                ->where('created_at','>=',date('Y-m-d H:i:s',$time))
+                ->where('send_order_id', $sendOrderId)
+                ->where('from_bid', $info->book_id)
+                ->where('status', 'PAID')
+                ->where('created_at', '>=', date('Y-m-d H:i:s', $time))
                 ->count();
-            $book_info = DB::table('book_configs')->where('bid',$info->book_id)->select('book_name','force_subscribe_chapter_seq','vip_seq')->first();
-            $send_order_chapter_sequence_info = DB::table('chapters')->where('id',$info->chapter_id)->select('sequence')->first();
+            $book_info = DB::table('book_configs')->where('bid', $info->book_id)->select('book_name', 'force_subscribe_chapter_seq', 'vip_seq')->first();
+            $send_order_chapter_sequence_info = DB::table('chapters')->where('id', $info->chapter_id)->select('sequence')->first();
             $send_order_chapter_sequence = 0;
-            if($send_order_chapter_sequence_info && $send_order_chapter_sequence_info->sequence){
+            if ($send_order_chapter_sequence_info && $send_order_chapter_sequence_info->sequence) {
                 $send_order_chapter_sequence = $send_order_chapter_sequence_info->sequence;
             }
-            if(!$subscribe_chaper_seq){
-                if($book_info){
+            if (!$subscribe_chaper_seq) {
+                if ($book_info) {
                     $subscribe_chaper_seq = $book_info->force_subscribe_chapter_seq;
-                }else{
+                } else {
                     $subscribe_chaper_seq = 0;
                 }
             }
             $vip_seq = 0;
-            $vip_seq_info = Chapter::where('bid',$info->book_id)->where('is_vip',1)->orderBy('sequence')->select('sequence')->first();
-            if($vip_seq_info){
+            $vip_seq_info = Chapter::where('bid', $info->book_id)->where('is_vip', 1)->orderBy('sequence')->select('sequence')->first();
+            if ($vip_seq_info) {
                 $vip_seq = $vip_seq_info->sequence;
             }
             $data = [];
-            for ($i = 1;$i<=30;$i++){
-                $key_3 = 'accurateSendOrderChapterUv:bid:%s:seq:%s:sendorderid:'.$sendOrderId;
-                $chapter_seq_uv = (int)(Redis::scard(sprintf($key_3,$info->book_id,$i)));
+            for ($i = 1; $i <= 30; $i++) {
+                $key_3 = 'accurateSendOrderChapterUv:bid:%s:seq:%s:sendorderid:' . $sendOrderId;
+                $chapter_seq_uv = (int)(Redis::scard(sprintf($key_3, $info->book_id, $i)));
 
-                Redis::del( sprintf($key_3,$info->book_id,$i) );
-                if(!$chapter_seq_uv){
+                Redis::del(sprintf($key_3, $info->book_id, $i));
+                if (!$chapter_seq_uv) {
                     continue;
                 }
                 /*$data[] = [
@@ -367,108 +379,110 @@ class BookTest extends Command
                     'created_at'=>date('Y-m-d H:i:s'),
                     'updated_at'=>date('Y-m-d H:i:s')
                 ];*/
-           }
-           if($data){
-               DB::table('send_order_stats_105')->insert($data);
-           }
+            }
+            if ($data) {
+                DB::table('send_order_stats_105')->insert($data);
+            }
         }
 
-        foreach ($send_order_ids as $send_order_id=> $v){
-            $array = explode('-',$v);
-            if(count($array) == 2){
-                one($send_order_id,$array[1]);
+        foreach ($send_order_ids as $send_order_id => $v) {
+            $array = explode('-', $v);
+            if (count($array) == 2) {
+                one($send_order_id, $array[1]);
             }
         }
 
         Redis::del('sendOrderIdToBid');
     }
 
-    private function you2(){
+    private function you2()
+    {
         $sql1 = 'TRUNCATE yq_stats2';
         DB::update($sql1);
 
-        $info = BookUser::where('type','ENABLE')->select('bid','uid','type','updated_at')
+        $info = BookUser::where('type', 'ENABLE')->select('bid', 'uid', 'type', 'updated_at')
             ->orderBy('updated_at')->limit(1500)->get();
-        $info2 = BookUser::where('type','GROUP_1')
-            ->select('bid','uid','type','updated_at')->orderBy('updated_at')->limit(1500)->get();
-        $this->you2Type($info,'GROUP_2');
-        $this->you2Type($info2,'GROUP_1');
+        $info2 = BookUser::where('type', 'GROUP_1')
+            ->select('bid', 'uid', 'type', 'updated_at')->orderBy('updated_at')->limit(1500)->get();
+        $this->you2Type($info, 'GROUP_2');
+        $this->you2Type($info2, 'GROUP_1');
     }
 
 
-    private function you2Type($info,$type){
+    private function you2Type($info, $type)
+    {
         $result = [];
         $chapter_model = new ChapterOrder();
-        foreach ($info as $item){
-            $to_bids = YqUserBidRelation::where('uid',$item->uid)->where('to_bid','>',0)->select('to_bid','created_at')->get();
-            $from_bids = YqUserBidRelation::where('uid',$item->uid)->where('from_bid','>',0)->select('from_bid','created_at')->get();
+        foreach ($info as $item) {
+            $to_bids = YqUserBidRelation::where('uid', $item->uid)->where('to_bid', '>', 0)->select('to_bid', 'created_at')->get();
+            $from_bids = YqUserBidRelation::where('uid', $item->uid)->where('from_bid', '>', 0)->select('from_bid', 'created_at')->get();
             $chapter_model->setCurrentTable($item->uid);
-            if($to_bids){
-                foreach ($to_bids as $v){
+            if ($to_bids) {
+                foreach ($to_bids as $v) {
                     $to_bid = $v->to_bid;
                     $time = $v->created_at->format('Y-m-d H:i:s');
-                    $end_time = date('Y-m-d H:i:s',strtotime($time)+2*86400);
-                    if(!$to_bid) continue;
-                    $fee = $chapter_model->where('uid',$item->uid)
-                        ->where('bid',$to_bid)
-                        ->where('created_at','>=',$time)
-                        ->where('created_at','<=',$end_time)
+                    $end_time = date('Y-m-d H:i:s', strtotime($time) + 2 * 86400);
+                    if (!$to_bid) continue;
+                    $fee = $chapter_model->where('uid', $item->uid)
+                        ->where('bid', $to_bid)
+                        ->where('created_at', '>=', $time)
+                        ->where('created_at', '<=', $end_time)
                         ->sum('fee');
-                    $amount = Order::where('uid',$item->uid)
-                        ->where('from_bid',$to_bid)
-                        ->where('created_at','>=',$time)
-                        ->where('created_at','<=',$end_time)
-                        ->where('status','PAID')
+                    $amount = Order::where('uid', $item->uid)
+                        ->where('from_bid', $to_bid)
+                        ->where('created_at', '>=', $time)
+                        ->where('created_at', '<=', $end_time)
+                        ->where('status', 'PAID')
                         ->sum('price');
                     $result[] = [
-                        'bid'=>$to_bid,
-                        'uid'=>$item->uid,
-                        'fee'=>$fee,
-                        'amount'=>$amount,
-                        'start_time'=>$time,
-                        'type'=>'to',
-                        'group'=>$type,
-                        'created_at'=>date('Y-m-d H:i:s'),
-                        'updated_at'=>date('Y-m-d H:i:s')
+                        'bid' => $to_bid,
+                        'uid' => $item->uid,
+                        'fee' => $fee,
+                        'amount' => $amount,
+                        'start_time' => $time,
+                        'type' => 'to',
+                        'group' => $type,
+                        'created_at' => date('Y-m-d H:i:s'),
+                        'updated_at' => date('Y-m-d H:i:s')
                     ];
                 }
-                if($result){
+                if ($result) {
                     DB::table('yq_stats2')->insert($result);
                     $result = [];
                 }
             }
             $to_bid = null;
-            if($from_bids){
-                foreach ($from_bids as $from_bid){
+            if ($from_bids) {
+                foreach ($from_bids as $from_bid) {
                     $bid = $from_bid->from_bid;
                     $test = YqZsyTestService::getByBid($bid);
-                    if($test) continue;
+                    if ($test) continue;
                     $time = $from_bid->created_at->format('Y-m-d H:i:s');
-                    $end_time = date('Y-m-d H:i:s',strtotime($time)+2*86400);
-                    $fee = $chapter_model->where('uid',$item->uid)
-                        ->where('bid',$bid)
-                        ->where('created_at','>=',$time)
-                        ->where('created_at','<=',$end_time)
+                    $end_time = date('Y-m-d H:i:s', strtotime($time) + 2 * 86400);
+                    $fee = $chapter_model->where('uid', $item->uid)
+                        ->where('bid', $bid)
+                        ->where('created_at', '>=', $time)
+                        ->where('created_at', '<=', $end_time)
                         ->sum('fee');
-                    $amount = Order::where('uid',$item->uid)
-                        ->where('from_bid',$bid)
-                        ->where('created_at','>=',$time)
-                        ->where('created_at','<=',$end_time)
-                        ->where('status','PAID')
+                    $amount = Order::where('uid', $item->uid)
+                        ->where('from_bid', $bid)
+                        ->where('created_at', '>=', $time)
+                        ->where('created_at', '<=', $end_time)
+                        ->where('status', 'PAID')
                         ->sum('price');
                     $result[] = [
-                        'bid'=>$bid,
-                        'uid'=>$item->uid,
-                        'fee'=>$fee,
-                        'amount'=>$amount,
-                        'start_time'=>$time,
-                        'type'=>'from',
-                        'group'=>$type,
-                        'created_at'=>date('Y-m-d H:i:s'),
-                        'updated_at'=>date('Y-m-d H:i:s')
+                        'bid' => $bid,
+                        'uid' => $item->uid,
+                        'fee' => $fee,
+                        'amount' => $amount,
+                        'start_time' => $time,
+                        'type' => 'from',
+                        'group' => $type,
+                        'created_at' => date('Y-m-d H:i:s'),
+                        'updated_at' => date('Y-m-d H:i:s')
                     ];
                 }
-                if($result){
+                if ($result) {
                     DB::table('yq_stats2')->insert($result);
                     $result = [];
                 }
@@ -476,59 +490,59 @@ class BookTest extends Command
         }
     }
 
-    private function transfromUserOrder(){
+    private function transfromUserOrder()
+    {
         $user = DB::table('users')
-            ->where('distribution_channel_id',4815)
-            ->where('created_at','>=','2019-01-31 15:00:00')
-            ->select('openid','id')
+            ->where('distribution_channel_id', 4815)
+            ->where('created_at', '>=', '2019-01-31 15:00:00')
+            ->select('openid', 'id')
             ->get();
         $chapter_model = new ChapterOrder();
-        foreach ($user as $v){
+        foreach ($user as $v) {
             Log::info('now user is :');
-            Log::info('openid is: '.$v->openid.',old uid is :'.$v->id);
+            Log::info('openid is: ' . $v->openid . ',old uid is :' . $v->id);
             $froce_user = DB::table('force_subscribe_users')
-                ->where('openid',$v->openid)
-                ->where('distribution_channel_id',384)
+                ->where('openid', $v->openid)
+                ->where('distribution_channel_id', 384)
                 ->select('uid')
                 ->first();
-            if(!$froce_user){
+            if (!$froce_user) {
                 continue;
             }
             Log::info('$froce_user user is :');
-            Log::info('$froce_user is: '.$froce_user->uid);
+            Log::info('$froce_user is: ' . $froce_user->uid);
 
-            if($froce_user && $froce_user->uid != $v->id){
+            if ($froce_user && $froce_user->uid != $v->id) {
                 $chapter_model->setCurrentTable($froce_user->uid);
                 $data = [];
                 //章节订购
-                $chapter_order_info = $chapter_model->where('uid',$froce_user->uid)->get();
+                $chapter_order_info = $chapter_model->where('uid', $froce_user->uid)->get();
                 Log::info('$chapter_order_info user is :');
                 Log::info($chapter_order_info);
-                if($chapter_order_info){
-                    foreach ($chapter_order_info as $chapter_order_item){
+                if ($chapter_order_info) {
+                    foreach ($chapter_order_info as $chapter_order_item) {
                         $data = [
-                            'distribution_channel_id'=>4815,
-                            'bid'=>$chapter_order_item->bid,
-                            'cid'=>$chapter_order_item->cid,
-                            'chapter_name'=>$chapter_order_item->chapter_name,
-                            'book_name'=>$chapter_order_item->book_name,
-                            'uid'=>$v->id,
-                            'send_order_id'=>0,
-                            'fee'=>0,
-                            'created_at'=>$chapter_order_item->created_at,
-                            'updated_at'=>date('Y-m-d H:i:s'),
-                            'charge_balance'=>0,
-                            'reward_balance'=>0
+                            'distribution_channel_id' => 4815,
+                            'bid' => $chapter_order_item->bid,
+                            'cid' => $chapter_order_item->cid,
+                            'chapter_name' => $chapter_order_item->chapter_name,
+                            'book_name' => $chapter_order_item->book_name,
+                            'uid' => $v->id,
+                            'send_order_id' => 0,
+                            'fee' => 0,
+                            'created_at' => $chapter_order_item->created_at,
+                            'updated_at' => date('Y-m-d H:i:s'),
+                            'charge_balance' => 0,
+                            'reward_balance' => 0
                         ];
                         $chapter_model->setCurrentTable($v->id);
-                        $old = $chapter_model->where('uid',$v->id)
-                            ->where('bid',$chapter_order_item->bid)
-                            ->where('cid',$chapter_order_item->cid)
+                        $old = $chapter_model->where('uid', $v->id)
+                            ->where('bid', $chapter_order_item->bid)
+                            ->where('cid', $chapter_order_item->cid)
                             ->select('id')->first();
-                        if(!$old){
+                        if (!$old) {
                             $chapter_model->insert($data);
                         }
-
                     }
                 }
                 /*if($data){
@@ -539,36 +553,36 @@ class BookTest extends Command
                 }*/
 
                 //单本订购
-                if($froce_user && $froce_user->uid != $v->id){
+                if ($froce_user && $froce_user->uid != $v->id) {
                     $book_order_data = [];
-                    $book_orders = DB::table('book_orders')->where('uid',$froce_user->uid)->get();
+                    $book_orders = DB::table('book_orders')->where('uid', $froce_user->uid)->get();
                     Log::info('$book_orders user  is :');
-                    if($book_orders){
-                        foreach ($book_orders as $book_order_item){
+                    if ($book_orders) {
+                        foreach ($book_orders as $book_order_item) {
                             $book_order_data[] = [
-                                'uid'=>$v->id,
-                                'distribution_channel_id'=>4815,
-                                'bid'=>$book_order_item->bid,
-                                'book_name'=>$book_order_item->book_name,
-                                'u'=>$book_order_item->u,
-                                'send_order_id'=>0,
-                                'charge_balance'=>0,
-                                'reward_balance'=>0,
-                                'fee'=>0,
-                                'created_at'=>$book_order_item->created_at,
-                                'updated_at'=>date('Y-m-d H:i:s'),
+                                'uid' => $v->id,
+                                'distribution_channel_id' => 4815,
+                                'bid' => $book_order_item->bid,
+                                'book_name' => $book_order_item->book_name,
+                                'u' => $book_order_item->u,
+                                'send_order_id' => 0,
+                                'charge_balance' => 0,
+                                'reward_balance' => 0,
+                                'fee' => 0,
+                                'created_at' => $book_order_item->created_at,
+                                'updated_at' => date('Y-m-d H:i:s'),
                             ];
                         }
                     }
-                    if($book_order_data){
+                    if ($book_order_data) {
                         Log::info('$book_order_data user  is :');
                         Log::info($book_order_data);
-                        foreach ($book_order_data as $book_o ){
+                        foreach ($book_order_data as $book_o) {
                             $old = DB::table('book_orders')
-                                ->where('uid',$book_o['uid'])
-                                ->where('bid',$book_o['bid'])
+                                ->where('uid', $book_o['uid'])
+                                ->where('bid', $book_o['bid'])
                                 ->select('id')->first();
-                            if(!$old){
+                            if (!$old) {
                                 DB::table('book_orders')->insert($book_order_data);
                             }
                         }
@@ -582,119 +596,122 @@ class BookTest extends Command
                 Log::info('$read_bids   is :');
                 Log::info($read_bids);
 
-                if ($read_bids){
-                    foreach ($read_bids as  $key=>$field){
-                        Redis::hset('book_read:' . $v->id,$key,$field);
+                if ($read_bids) {
+                    foreach ($read_bids as  $key => $field) {
+                        Redis::hset('book_read:' . $v->id, $key, $field);
                     }
                 }
 
                 //用户信息
                 $old_user = DB::table('users')->where('id', $froce_user->uid)->first();
-                if($old_user){
-                    DB::table('users')->where('id',$v->id)->update([
-                        'balance'=>$old_user->balance,
-                        'charge_balance'=>$old_user->charge_balance,
-                        'reward_balance'=>$old_user->reward_balance,
+                if ($old_user) {
+                    DB::table('users')->where('id', $v->id)->update([
+                        'balance' => $old_user->balance,
+                        'charge_balance' => $old_user->charge_balance,
+                        'reward_balance' => $old_user->reward_balance,
                     ]);
                 }
 
                 //年费
-                $year = DB::table('year_orders')->where('uid',$froce_user->uid)->orderBy('id','desc')->first();
-                if($year){
-                    $old_year = DB::table('year_orders')->where('uid',$v->id)->orderBy('id','desc')->first();
-                    if(!$old_year){
+                $year = DB::table('year_orders')->where('uid', $froce_user->uid)->orderBy('id', 'desc')->first();
+                if ($year) {
+                    $old_year = DB::table('year_orders')->where('uid', $v->id)->orderBy('id', 'desc')->first();
+                    if (!$old_year) {
                         DB::table('year_orders')->insert([[
-                            'uid'=>$v->id,
-                            'begin_time'=>$year->begin_time,
-                            'end_time'=>$year->end_time,
-                            'distribution_channel_id'=>4815,
-                            'created_at'=>$year->created_at,
-                            'updated_at'=>date('Y-m-d H:i:s'),
-                            'fee'=>0,
+                            'uid' => $v->id,
+                            'begin_time' => $year->begin_time,
+                            'end_time' => $year->end_time,
+                            'distribution_channel_id' => 4815,
+                            'created_at' => $year->created_at,
+                            'updated_at' => date('Y-m-d H:i:s'),
+                            'fee' => 0,
                         ]]);
                     }
                 }
             }
-
         }
     }
 
-    private function clearUserReadRecord(){
+    private function clearUserReadRecord()
+    {
         $i = 108655782;
         //$not_uid_key = ['last_read','send_order_id','sign_count','sign_counts','sign_info','sign_day','smart_push','inner_send_order_id','gxhp','property','bind_phone_status','ua'];
         $k = 0;
-        while ( $i<137406313){
+        while ($i < 137406313) {
             $i++;
-            $last_read = ReadRecordService::getByField($i,'last_read');
-            if(!$last_read){
+            $last_read = ReadRecordService::getByField($i, 'last_read');
+            if (!$last_read) {
                 $k++;
-                Redis::del('book_read:'.$i,'userRecommendBids:'.$i);
+                Redis::del('book_read:' . $i, 'userRecommendBids:' . $i);
                 continue;
             }
-            $last_info = explode('_',$last_read);
-            if(!isset($last_info[2])){
+            $last_info = explode('_', $last_read);
+            if (!isset($last_info[2])) {
                 $k++;
-                Redis::del('book_read:'.$i,'userRecommendBids:'.$i);
+                Redis::del('book_read:' . $i, 'userRecommendBids:' . $i);
             }
-            if( (time()-$last_info[2]) >=2*30*86400 ){
-                $record = Redis::hgetall('book_read:'.$i);
+            if ((time() - $last_info[2]) >= 2 * 30 * 86400) {
+                $record = Redis::hgetall('book_read:' . $i);
                 $data = [];
 
-                foreach ($record as $ks=>$item){
-                    $data[] = ['uid'=>$i,'field'=>$ks,'value'=>$item,
-                        'created_at'=>date('Y-m-d H:i:s'),'updated_at'=>date('Y-m-d H:i:s')];
+                foreach ($record as $ks => $item) {
+                    $data[] = [
+                        'uid' => $i, 'field' => $ks, 'value' => $item,
+                        'created_at' => date('Y-m-d H:i:s'), 'updated_at' => date('Y-m-d H:i:s')
+                    ];
                 }
                 $k++;
-                Redis::del('book_read:'.$i,'userRecommendBids:'.$i);
+                Redis::del('book_read:' . $i, 'userRecommendBids:' . $i);
                 DB::table('read_record_from_redis')->insert($data);
             }
         }
         echo 'delete ' . $k . ' keys' . PHP_EOL;
     }
 
-    private function deleteToLongReadRecord(){
+    private function deleteToLongReadRecord()
+    {
         $i = 10000;
         ReadRecordService::delTheLastRecord(109861757);
-        while ($i <= 35600000){
+        while ($i <= 35600000) {
             ReadRecordService::delTheLastRecord($i);
             $i++;
         }
     }
 
-    private function userPropertyV2(){
+    private function userPropertyV2()
+    {
         $tmp = 0;
         //19493455
-        while (true){
+        while (true) {
             $info = DB::table('orders')
-                ->select('id','uid','price','status')
-                ->where('id','>',$tmp)
+                ->select('id', 'uid', 'price', 'status')
+                ->where('id', '>', $tmp)
                 ->orderBy('id')
                 ->limit(1000)
                 ->get();
-            if($info->isEmpty()) break;
-            foreach ($info as $item){
-                if($item->status != 'PAID') continue;
+            if ($info->isEmpty()) break;
+            foreach ($info as $item) {
+                if ($item->status != 'PAID') continue;
                 //$old = UserDivisionCpcPropertyService::getUserPropertyV2($item->uid);
                 //if($old) continue;
                 $property = UserDivisionCpcPropertyService::calculateUserPropertyV2($item->uid);
-                if($property){
+                if ($property) {
                     $info = UserDivisionCpcPropertyService::getUserPropertyV2($item->uid);
-                    if($info == 'none'){
+                    if ($info == 'none') {
                         DB::table('user_division_cpc_property_v2')->insert([
-                            'openid'=>$property['openid'],
-                            'property'=>$property['property'],
-                            'is_enable'=>1,
-                            'created_at'=>date('Y-m-d H:i:s'),
-                            'updated_at'=>date('Y-m-d H:i:s')
+                            'openid' => $property['openid'],
+                            'property' => $property['property'],
+                            'is_enable' => 1,
+                            'created_at' => date('Y-m-d H:i:s'),
+                            'updated_at' => date('Y-m-d H:i:s')
                         ]);
                     }
-                    if($info == 'high') continue;
+                    if ($info == 'high') continue;
                     UserDivisionCpcPropertyService::updateV2($property);
                 }
             }
             $tmp = $item->id;
-            if($tmp >=19493455) break;
+            if ($tmp >= 19493455) break;
         }
     }
-
 }

app/Modules/Trade/Pay/PaySuccessAbstract.php

@@ -71,7 +71,7 @@ abstract class PaySuccessAbstract
 
    private function getReportType(int $channel_id)
    {
-      return Redis::hGet('channel:setting:' . $channel_id, 'tiktok_report_type') ??  QappTikTokUserCharge::REGISTER_24_CHARGE;
+      return Redis::hGet('channel:setting:' . $channel_id, 'tiktok_report_type') ??  QappTikTokUserCharge::CURRENT_DAY_REGISTER;
    }