format('Y-m-d'); $start = $date; $end = date('Y-m-d', strtotime($date) + 86400); $offset = 0; $limit = 10000; $data = []; $_m_data = []; while (true) { print_r("select send_order_id,uid,appid,unsubscribe_time,distribution_channel_id,created_at from force_subscribe_users where created_at > '{$start}' and created_at < '{$end}' limit $offset,$limit" . date("y-m-d H:i:s" . "\n")); $users = DB::select("select send_order_id,uid,appid,unsubscribe_time,distribution_channel_id,created_at from force_subscribe_users where created_at > '{$start}' and created_at < '{$end}' limit $offset,$limit"); print_r("users_count:".count($users)); if (count($users) == 0) break; foreach ($users as $user) { $is_unsub_in_one_day = false; $is_pay_in_one_day = false; $_read_data = [ 'date' => $date, 'appid' => $user->appid, 'uid' => $user->uid, 'sub_time' => strtotime($user->created_at), 'unsub_time' => strtotime($user->unsubscribe_time), ]; $order = DB::table('orders')->where('uid', $user->uid)->where('status', 'PAID')->first(); if ($order) { if (strtotime($order->created_at) < strtotime($user->created_at) + 86400)//24小时内 { $_read_data['recharge_time_in_one_day'] = strtotime($order->created_at); $is_pay_in_one_day = true; } } $one_day_time = strtotime($user->created_at) + 86400; if ($user->unsubscribe_time && strtotime($user->unsubscribe_time) < strtotime($user->created_at) + 86400)//24小时内取注 { $is_unsub_in_one_day = true; $_read_data['is_unsub_in_one_day'] = 1; } $last_read_info = Redis::hget('book_base:' . $user->uid, 'last_read'); $send_order = DB::table('send_orders')->where('id', $user->send_order_id)->first(); if ($send_order && $send_order->book_id && $last_read_info) { $book = Redis::hget('book_read:' . $user->uid, $send_order->book_id); $book_info = explode('_', $book); $cid = $book_info[0]; $vip_chapter = DB::table('chapters')->select(['sequence'])->where('bid', $send_order->book_id)->where('is_vip', 1)->orderby('sequence')->first(); $read_last_free = DB::table('read_records')->where('bid', $send_order->book_id)->where('uid', $user->uid)->where('created_at', '<=', date('Y-m-d H:i:s', $one_day_time))->where('seq', $vip_chapter->sequence - 1)->first(); $last_read_array = explode('_', $last_read_info); $last_read_time = $last_read_array[4]; //$_read_data['last_read_time'] = $last_read_time; $_read_data['last_free_read_time'] = $read_last_free ? strtotime($read_last_free->created_at) : 0; $book_config = DB::table('book_configs')->select(['force_subscribe_chapter_seq','charge_type'])->where('bid', $send_order->book_id)->first(); //订阅 if($book_config->charge_type == 'CHAPTER') { $first_sub = DB::connection('chapter_order_mysql')->table('chapter_orders' . $user->uid % 512)->where('uid', $user->uid)->where('created_at', '<=', date('Y-m-d H:i:s', $one_day_time))->where('bid', $send_order->book_id)->orderBy('id', 'asc')->first(); $_read_data['first_sub_time'] = $first_sub ? strtotime($first_sub->created_at) : 0; } if($book_config->charge_type == 'BOOK') { $_read_last_free = DB::table('read_records')->where('bid', $send_order->book_id)->where('uid', $user->uid)->where('seq', $vip_chapter->sequence - 1)->first(); $_read_data['first_sub_time'] = $_read_last_free ? strtotime($_read_last_free->created_at) : 0; } } //第一次点击返回时间 $back_info = DB::table('back_actives')->where('uid',$user->uid)->first(); if($back_info) { $_read_data['first_click_back_time'] = strtotime($back_info->created_at); } $_read_data['created_at'] = date("Y-m-d H:i:s"); DB::table('force_users_date_read')->insert($_read_data); } $offset = $offset + $limit; } Log::info("======每日强关用户行为详细生成 【任务执行结束】=====" . date("y-m-d H:i:s" . "\n")); print_r("======每日强关用户行为详细生成 【任务执行结束】=====" . date("y-m-d H:i:s" . "\n")); } } }