neiyou_user_web/app/Console/Commands/fixDailyTrafficLogError.php

<?php

namespace App\Console\Commands;

use App\Models\NodeDailyDataFlow;
use App\Models\UserDailyDataFlow;
use App\Models\UserDataFlowLog;
use Illuminate\Console\Command;
use Log;

class fixDailyTrafficLogError extends Command
{

    protected $signature = 'fixDailyTrafficLogError';
    protected $description = '修复原版本的每日流量计算错误';

    private $end;

    public function handle(): void
    {
        // set value
        $this->end = date('Y-m-d 23:59:59', strtotime("-1 days"));
        $nodeArray = UserDataFlowLog::distinct()->pluck('node_id')->toArray();

        Log::info(
            '----------------------------【修复原版本的每日流量计算错误】开始----------------------------'
        );
        Log::info(
            '----------------------------【节点流量日志修正】开始----------------------------'
        );
        foreach (NodeDailyDataFlow::all() as $log) {
            NodeDailyDataFlow::whereId($log->id)->update(
                [
                    'created_at' => date(
                        'Y-m-d H:i:s',
                        strtotime("$log->created_at -1 days")
                    ),
                ]
            );
        }

        Log::info(
            '----------------------------【添加节点流量日志】开始----------------------------'
        );
        foreach ($nodeArray as $nodeId) {
            $query = UserDataFlowLog::whereNodeId($nodeId)
                                    ->whereBetween(
                                        'log_time',
                                        [
                                            strtotime(
                                                date(
                                                    'Y-m-d',
                                                    strtotime("-1 days")
                                                )
                                            ),
                                            strtotime($this->end),
                                        ]
                                    );

            $u     = $query->sum('u');
            $d     = $query->sum('d');
            $total = $u + $d;

            if ($total) { // 有数据才记录
                $obj             = new NodeDailyDataFlow();
                $obj->node_id    = $nodeId;
                $obj->u          = $u;
                $obj->d          = $d;
                $obj->total      = $total;
                $obj->traffic    = flowAutoShow($total);
                $obj->created_at = $this->end;
                $obj->save();
            }
        }
        Log::info(
            '----------------------------【添加节点流量日志】结束----------------------------'
        );
        Log::info(
            '----------------------------【节点流量日志修正】结束----------------------------'
        );
        Log::info(
            '----------------------------【用户流量日志修正】开始----------------------------'
        );
        foreach (UserDailyDataFlow::all() as $log) {
            UserDailyDataFlow::whereId($log->id)->update(
                [
                    'created_at' => date(
                        'Y-m-d H:i:s',
                        strtotime("$log->created_at -1 days")
                    ),
                ]
            );
        }
        Log::info(
            '----------------------------【用户个人流量日志修正】开始----------------------------'
        );
        foreach (
            UserDataFlowLog::distinct()->pluck('user_id')->toArray() as $userId
        ) {
            // 统计一次所有节点的总和
            $this->statisticsByUser($userId);
            // 统计每个节点产生的流量
            foreach ($nodeArray as $nodeId) {
                $this->statisticsByUser($userId, $nodeId);
            }
        }
        Log::info(
            '----------------------------【用户个人流量日志修正】结束----------------------------'
        );
        Log::info(
            '----------------------------【用户流量日志修正】结束----------------------------'
        );
        Log::info(
            '----------------------------【修复原版本的每日流量计算错误】结束----------------------------'
        );
    }

    private function statisticsByUser($user_id, $node_id = 0): void
    {
        $query = UserDataFlowLog::whereUserId($user_id)
                                ->whereBetween(
                                    'log_time',
                                    [
                                        strtotime(
                                            date('Y-m-d', strtotime("-1 days"))
                                        ),
                                        strtotime($this->end),
                                    ]
                                );

        if ($node_id) {
            $query->whereNodeId($node_id);
        }

        $u     = $query->sum('u');
        $d     = $query->sum('d');
        $total = $u + $d;

        if ($total) { // 有数据才记录
            $obj             = new UserDailyDataFlow();
            $obj->user_id    = $user_id;
            $obj->node_id    = $node_id;
            $obj->u          = $u;
            $obj->d          = $d;
            $obj->total      = $total;
            $obj->traffic    = flowAutoShow($total);
            $obj->created_at = $this->end;
            $obj->save();
        }
    }

}