yanyu/v2board
1
0
Fork 0
mirror of https://github.com/v2board/v2board.git synced 2025-02-11 16:00:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

update: stat command

Browse Source
This commit is contained in:
v2board 2023-06-05 13:56:45 +08:00
parent 228355a520
commit b39299be23
1 changed files with 40 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
app/Console/Commands/V2boardStatistics.php
View File

@ -61,24 +61,28 @@ class V2boardStatistics extends Command
$statService->setStartAt($recordAt); $statService->setStartAt($recordAt);
$statService->setServerStats(); $statService->setServerStats();
$stats = $statService->getStatServer(); $stats = $statService->getStatServer();
DB::beginTransaction(); try {
foreach ($stats as $stat) { DB::beginTransaction();
if (!StatServer::insert([ foreach ($stats as $stat) {
'server_id' => $stat['server_id'], if (!StatServer::insert([
'server_type' => $stat['server_type'], 'server_id' => $stat['server_id'],
'u' => $stat['u'], 'server_type' => $stat['server_type'],
'd' => $stat['d'], 'u' => $stat['u'],
'created_at' => $createdAt, 'd' => $stat['d'],
'updated_at' => $createdAt, 'created_at' => $createdAt,
'record_type' => 'd', 'updated_at' => $createdAt,
'record_at' => $recordAt 'record_type' => 'd',
])) { 'record_at' => $recordAt
DB::rollback(); ])) {
throw new \Exception('stat server fail'); throw new \Exception('stat server fail');
}
} }
DB::commit();
$statService->clearStatServer();
} catch (\Exception $e) {
DB::rollback();
$this->error($e->getMessage());
} }
DB::commit();
$statService->clearStatServer();
} }
private function statUser() private function statUser()
@ -89,24 +93,28 @@ class V2boardStatistics extends Command
$statService->setStartAt($recordAt); $statService->setStartAt($recordAt);
$statService->setUserStats(); $statService->setUserStats();
$stats = $statService->getStatUser(); $stats = $statService->getStatUser();
DB::beginTransaction(); try {
foreach ($stats as $stat) { DB::beginTransaction();
if (!StatUser::insert([ foreach ($stats as $stat) {
'user_id' => $stat['user_id'], if (!StatUser::insert([
'u' => $stat['u'], 'user_id' => $stat['user_id'],
'd' => $stat['d'], 'u' => $stat['u'],
'server_rate' => $stat['server_rate'], 'd' => $stat['d'],
'created_at' => $createdAt, 'server_rate' => $stat['server_rate'],
'updated_at' => $createdAt, 'created_at' => $createdAt,
'record_type' => 'd', 'updated_at' => $createdAt,
'record_at' => $recordAt 'record_type' => 'd',
])) { 'record_at' => $recordAt
DB::rollback(); ])) {
throw new \Exception('stat user fail'); throw new \Exception('stat user fail');
}
} }
DB::commit();
$statService->clearStatUser();
} catch (\Exception $e) {
DB::rollback();
$this->error($e->getMessage());
} }
DB::commit();
$statService->clearStatUser();
} }
private function stat() private function stat()