webman/app/dao/UserPhoneLogDao.php

<?php

namespace app\dao;

use app\model\User;
use app\model\UserPhone;
use app\model\UserPhoneLog;

/**
 * 手机号在线时长日志
 */
class UserPhoneLogDao
{
    /**
     * 获取手机号 今天在线时长 单位秒
     */
    public static function getOnlineTimeByPhoneToday($phone)
    {
        $today = date('Y-m-d');
        $OnlineTime = UserPhoneLog::where('phone', $phone)->where('created_at', '>=', $today . " 00:00:00")->sum('time');
        return $OnlineTime;
    }
    /**
     * 自动处理time
     * phone 手机号
     * status — 是否在线 1: 在线，0: 不在线
     * currentTimestamp 考虑到运行性能差别 使用传递过来的时间戳
     */
    public static function setOnlineTimeByPhone($phone, $status, $currentTimestamp)
    {
        //这里因为和api的返回是反的所以需要这样
        $status = $status == 0 ? 1 : 0;
        $today = date('Y-m-d');
        // $UserPhoneLog=UserPhoneLog::where('phone',$phone)->where('created_at', '>=', $today." 00:00:00")->limit(2)->orderByDesc('id')->get();
        $UserPhoneLog = UserPhoneLog::where('phone', $phone)->where('created_at', '>=', $today . " 00:00:00")->orderBy('id', 'desc')->first();
        if (empty($UserPhoneLog)) {
            $new_UserPhoneLog = new UserPhoneLog();
            $new_UserPhoneLog->status = $status;
            $new_UserPhoneLog->phone = $phone;
            $new_UserPhoneLog->time = 0;
            $new_UserPhoneLog->save();
            return;
        }
        if ($UserPhoneLog->status == 1 && $status == 1) {
            $new_UserPhoneLog = new UserPhoneLog();
            $new_UserPhoneLog->status = $status;
            $new_UserPhoneLog->phone = $phone;
            $new_UserPhoneLog->time = $currentTimestamp - strtotime($UserPhoneLog->created_at);
            $new_UserPhoneLog->save();
            echo ($currentTimestamp - strtotime($UserPhoneLog->created_at));
        } else {
            $new_UserPhoneLog = new UserPhoneLog();
            $new_UserPhoneLog->status = $status;
            $new_UserPhoneLog->phone = $phone;
            $new_UserPhoneLog->time = 0;
            $new_UserPhoneLog->save();
        }
    }
    /**
     * 根据用户id查询 是否有手机号在线时间大于6小时
     * 有返回 true 没用返回false
     */
    public static function getOnlineTimeByPhoneTodayId($user_id)
    {
        $user_phones = UserPhone::where('user_id', $user_id)->get();
        foreach ($user_phones as $v) {
            if (self::getOnlineTimeByPhoneToday($v->phone) > 60 * 60 * 6) {
                return true;
            }
        }
        return false;
    }
    /**
     * 获取今天在线时长超过6小时的用户列表
     */
    public static function getOnlineTimeByPhone6HoserUserId()
    {
        $today = date('Y-m-d');
        // 获取当天每个手机号的在线时长总和
        $OnlineTime = UserPhoneLog::where('created_at', '>=', $today . " 00:00:00")
            ->groupBy('phone')
            ->selectRaw('phone, sum(time) as total_time')
            ->get();

        $phoneMax6hoser_phone = [];
        foreach ($OnlineTime as $v) {
            if ($v->total_time > 60 * 60 * 6) {  // 如果在线时长超过6小时
                $phoneMax6hoser_phone[] = $v->phone;  // 仅存储手机号
            }
        }

        // 获取这些手机号对应的用户ID
        $user_ids = UserPhone::whereIn('phone', $phoneMax6hoser_phone)
            ->groupBy('user_id')
            ->pluck('user_id'); // 使用pluck提取user_id字段

        // 输出用户ID
        // var_dump(json_encode($user_ids));

        return $user_ids; // 返回用户ID列表
    }
}