1 files changed, 64 insertions, 0 deletions
diff --git a/lib/models/Forum/PostingRead.php b/lib/models/Forum/PostingRead.php
new file mode 100644
index 0000000..f690d1b
--- /dev/null
+++ b/lib/models/Forum/PostingRead.php
@@ -0,0 +1,64 @@
+<?php
+namespace Forum;
+
+use SimpleORMap;
+use User;
+
+/**
+ * @property string $discussion_id
+ * @property string $user_id
+ * @property int $read_index
+ * @property int $chdate
+ *
+ * @property Discussion $discussion
+ * @property User $users
+ */
+
+class PostingRead extends SimpleORMap
+{
+    protected static function configure($config = [])
+    {
+        $config['db_table'] = 'forum_posting_reads';
+
+        $config['belongs_to']['discussion'] = [
+            'class_name' => Discussion::class,
+            'foreign_key' => 'discussion_id',
+            'assoc_foreign_key' => 'discussion_id'
+        ];
+
+        $config['belongs_to']['user'] = [
+            'class_name' => User::class,
+            'foreign_key' => 'user_id',
+            'assoc_foreign_key' => 'user_id'
+        ];
+
+        parent::configure($config);
+    }
+
+    public static function updateUserReadPoint($user_id, $discussion_id, int $read_index = 0): PostingRead
+    {
+        $postingRead = PostingRead::findOneBySQL(
+            "discussion_id = :discussion_id AND user_id = :user_id",
+            [
+                'discussion_id' => $discussion_id,
+                'user_id' => $user_id
+            ]
+        );
+
+        if (!$postingRead) {
+            $postingRead = new PostingRead();
+            $postingRead->discussion_id = $discussion_id;
+            $postingRead->user_id = $user_id;
+        }
+
+        if (!$read_index) {
+            $read_index = $postingRead->read_index + 1;
+        }
+
+        $postingRead->read_index = $read_index;
+
+        $postingRead->store();
+
+        return $postingRead;
+    }
+}