tag and installer&updater use english

2026-04-23 19:37:23 +08:00 · 2022-03-08 15:08:56 +08:00
parent a56891132d
commit 718a57539d
67 changed files with 1149 additions and 104 deletions
@@ -0,0 +1,131 @@
+<?php
+namespace App\Repositories;
+
+use App\Models\Tag;
+use App\Models\Torrent;
+use App\Models\TorrentTag;
+use Illuminate\Support\Collection;
+use Nexus\Database\NexusDB;
+
+class TagRepository extends BaseRepository
+{
+    public function getList(array $params)
+    {
+        $query = $this->createBasicQuery();
+        return $query->paginate();
+    }
+
+    public function store(array $params)
+    {
+        $model = Tag::query()->create($params);
+        return $model;
+    }
+
+    public function update(array $params, $id)
+    {
+        $model = Tag::query()->findOrFail($id);
+        $model->update($params);
+        return $model;
+    }
+
+    public function getDetail($id)
+    {
+        $model = Tag::query()->findOrFail($id);
+        return $model;
+    }
+
+    public function delete($id)
+    {
+        $model = Tag::query()->findOrFail($id);
+        $result = $model->delete();
+        return $result;
+    }
+
+    public function createBasicQuery()
+    {
+        return Tag::query()->orderBy('priority', 'desc')->orderBy('id', 'desc');
+    }
+
+    public function renderCheckbox(array $checked = []): string
+    {
+        $html = '';
+        $results = $this->createBasicQuery()->get();
+        foreach ($results as $value) {
+            $html .= sprintf(
+                '<label><input type="checkbox" name="tags[]" value="%s"%s />%s</label>',
+                $value->id, in_array($value->id, $checked) ? ' checked' : '', $value->name
+            );
+        }
+        return $html;
+    }
+
+    public function renderSpan(Collection $tagKeyById, array $renderIdArr = [], $withFilterLink = false): string
+    {
+        $html = '';
+        foreach ($renderIdArr as $tagId) {
+            $value = $tagKeyById->get($tagId);
+            if ($value) {
+                $item = "<span style=\"background-color:{$value->color};color:white;border-radius:15%\">{$value->name}</span> ";
+                if ($withFilterLink) {
+                    $html .= sprintf('<a href="torrents.php?tag_id=%s">%s</a>', $tagId, $item);
+                } else {
+                    $html .= $item;
+                }
+            }
+        }
+        return $html;
+    }
+
+    public function migrateTorrentTag()
+    {
+        $page = 1;
+        $size = 1000;
+        $baseQuery = Torrent::query()->where('tags', '>', 0);
+        do_log("torrent to migrate hr counts: " . (clone $baseQuery)->count());
+        $dateTimeStringNow = date('Y-m-d H:i:s');
+        $tags = [];
+        $priority = count(Tag::DEFAULTS);
+        foreach (Tag::DEFAULTS as $value) {
+            $attributes = [
+                'name' => $value['name'],
+            ];
+            $values = [
+                'priority' => $priority,
+                'color' => $value['color'],
+                'created_at' => $dateTimeStringNow,
+                'updated_at' => $dateTimeStringNow,
+            ];
+            $tags[] = Tag::query()->firstOrCreate($attributes, $values);
+            $priority--;
+        }
+        do_log("insert default tags done!");
+
+        $sql = "insert into torrent_tags (torrent_id, tag_id, created_at, updated_at) values ";
+        $values = [];
+        while (true) {
+            $logPrefix = "page: $page, size: $size";
+            $results = (clone $baseQuery)->forPage($page, $size)->get();
+            if ($results->isEmpty()) {
+                do_log("$logPrefix, no more data...");
+                break;
+            }
+            foreach ($results as $torrent) {
+                foreach ($tags as $key => $tag) {
+                    $currentValue = pow(2, $key);
+                    if ($currentValue & $torrent->tags) {
+                        //this torrent has this tag
+                        $values[] = sprintf("(%d, %d, '%s', '%s')", $torrent->id, $tag->id, $dateTimeStringNow, $dateTimeStringNow);
+                    }
+                }
+            }
+            $page++;
+        }
+        $sql .= sprintf("%s on duplicate key update updated_at = values(updated_at)", implode(', ', $values));
+        do_log("migrate sql: $sql");
+        NexusDB::statement($sql);
+        do_log("[MIGRATE_TORRENT_TAG] done!");
+        return count($values);
+    }
+
+
+}