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::query()->distinct()->pluck('node_id')->toArray();

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

		Log::info('----------------------------【添加节点流量日志】开始----------------------------');
		foreach($nodeArray as $nodeId){
			$query = UserDataFlowLog::query()
			                        ->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::query()->whereId($log->id)->update([
				'created_at' => date('Y-m-d H:i:s', strtotime("-1 days", strtotime($log->created_at)))
			]);
		}
		Log::info('----------------------------【用户个人流量日志修正】开始----------------------------');
		foreach(UserDataFlowLog::query()->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::query()
		                        ->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();
		}
	}

}