From 6e6503ac2dc16868b87b4172d047e5c9979ddd6e Mon Sep 17 00:00:00 2001
From: lingling <1077478963@qq.com>
Date: Fri, 21 Mar 2025 20:49:57 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=96=B0=E5=A2=9E=E7=94=A8=E6=88=B7?=
 =?UTF-8?q?=E6=89=8B=E6=9C=BA=E5=8F=B7=E5=9C=A8=E7=BA=BF=E6=93=8D=E4=BD=9C?=
 =?UTF-8?q?=E7=B1=BB=EF=BC=8C=E6=94=AF=E6=8C=81=E5=9C=A8=E7=BA=BF=E7=8A=B6?=
 =?UTF-8?q?=E6=80=81=E5=A4=84=E7=90=86=E5=92=8C=E6=89=B9=E9=87=8F=E6=9B=B4?=
 =?UTF-8?q?=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/dao/PhoneDao.php | 137 +++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 137 insertions(+)
 create mode 100644 app/dao/PhoneDao.php

diff --git a/app/dao/PhoneDao.php b/app/dao/PhoneDao.php
new file mode 100644
index 0000000..f17f237
--- /dev/null
+++ b/app/dao/PhoneDao.php
@@ -0,0 +1,137 @@
+<?php
+
+namespace app\dao;
+
+
+use app\dao\UserPhoneLogDao;
+use app\model\UserPhone;
+use app\dao\UserRewardDao;
+use app\model\Dictionary;
+use support\Log;
+use App\Utils\API\Rocketgo;
+
+/**
+ * 用户手机号在线操作类
+ * 暂时未启用方便测试重写的类并没有通过测试
+ */
+class PhoneDao
+{
+    public static function main()
+    {
+        $start_time = time();
+        Rocketgo::test_login();
+        // 查询系统配置 是否自动删除用户
+        $autodelete = Dictionary::where('key', 'autodelete')->first();
+        Log::info("查询任务开始");
+
+        // 获取账号列表
+        $res = Rocketgo::account_list();
+        $usernames = array_column($res, 'username');
+
+        // 批量查询用户信息
+        $phones = UserPhone::whereIn('phone', $usernames)->get()->keyBy('phone');
+        $currentTimestamp = time();
+
+        $updateData = [];
+        $updateData2 = [];
+
+        // 批量处理用户信息
+        foreach ([$res, Rocketgo::account_storehouse_list()] as $index => $accountList) {
+            $phoneMap = ($index === 0) ? $phones : UserPhone::whereIn('phone', array_column($accountList, 'username'))->get()->keyBy('phone');
+            $allUsernames = array_column($accountList, 'username');
+
+            foreach ($accountList as $v) {
+                $phone = $phoneMap[$v['username']] ?? null;
+                if (!$phone) {
+                    continue;
+                }
+
+                // 处理在线和离线状态
+                if ($v['logged'] == 1) {
+                    self::processOnlineStatus($phone, $v, $currentTimestamp, $updateData);
+                } else {
+                    self::processOfflineStatus($phone, $currentTimestamp, $updateData);
+                }
+
+                // 更新状态
+                if ($index === 0) {
+                    $updateData[] = $phone;
+                } else {
+                    $updateData2[] = $phone;
+                }
+            }
+
+            // 更新离线用户状态
+            UserPhone::whereNotIn('phone', $allUsernames)
+                ->where('status', '!=', 2)
+                ->update(['status' => 2, 'last_time' => $currentTimestamp]);
+            UserPhone::where('status', 2)->update(['last_time' => $currentTimestamp, 'time' => 0]);
+        }
+
+        // 批量更新用户状态
+        self::batchUpdatePhones($updateData);
+        self::batchUpdatePhones($updateData2);
+
+        $end_time = time();
+        Log::info("Task2: Processed " . count($usernames) . " phones in " . ($end_time - $start_time) . " seconds");
+    }
+
+
+    /**
+     * 处理用户在线状态
+     */
+    private static function processOnlineStatus($phone, $v, $currentTimestamp, &$updateData)
+    {
+        if ($phone->time > 3600) {
+            // 计算超过 1 小时的积分
+            $hours = intdiv($phone->time, 3600);
+            $score = $hours * 20;
+            $remainingTime = $phone->time % 3600;
+
+            // 更新用户积分和时长
+            $phone->score += $score;
+            $phone->day_score += $score;
+            $phone->time = $remainingTime;
+
+            // 保存用户收益到 UserReward 表
+            UserRewardDao::Onhookincome($phone->user_id, $score, $phone->phone);
+        }
+
+        // 保存在线时长记录
+        UserPhoneLogDao::setOnlineTimeByPhone($phone->phone, 1, $currentTimestamp);
+        $phone->status = 1;
+        $phone->time += $currentTimestamp - $phone->last_time;
+        $phone->last_time = $currentTimestamp;
+
+        $updateData[] = $phone;
+    }
+
+    /**
+     * 处理用户离线状态
+     */
+    private static function processOfflineStatus($phone, $currentTimestamp, &$updateData)
+    {
+        $phone->status = 0;
+        $phone->last_time = $currentTimestamp;
+
+        // 保存在线时长记录
+        UserPhoneLogDao::setOnlineTimeByPhone($phone->phone, 0, $currentTimestamp);
+
+        $updateData[] = $phone;
+    }
+
+    /**
+     * 批量更新用户状态
+     */
+    private static function batchUpdatePhones($phones)
+    {
+        // 如果用户列表不为空，批量更新
+        if (!empty($phones)) {
+            UserPhone::whereIn('id', array_column($phones, 'id'))->update([
+                'status' => 1,
+                'time' => $phones[0]->time, // 更新时间等信息
+                'last_time' => $phones[0]->last_time,
+            ]);
+        }
+    }
+}