From aed8c60c4b594b42939b7d33607b5f92e4891cae Mon Sep 17 00:00:00 2001
From: sige <sige@sige.com>
Date: Wed, 6 Mar 2024 11:46:04 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=BA=94=E7=94=A8=E9=80=9A?=
 =?UTF-8?q?=E7=9F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../diframe/model/DiMdbNotification.java           | 40 ++++++++++++++++++++++
 1 file changed, 40 insertions(+)
 create mode 100644 src/src/main/java/com/my/graphiteDigesterBg/diframe/model/DiMdbNotification.java

diff --git a/src/src/main/java/com/my/graphiteDigesterBg/diframe/model/DiMdbNotification.java b/src/src/main/java/com/my/graphiteDigesterBg/diframe/model/DiMdbNotification.java
new file mode 100644
index 0000000..7c9e882
--- /dev/null
+++ b/src/src/main/java/com/my/graphiteDigesterBg/diframe/model/DiMdbNotification.java
@@ -0,0 +1,40 @@
+package com.my.graphiteDigesterBg.diframe.model;
+import com.my.graphiteDigesterBg.diframe.ActiveRecordField;
+import com.my.graphiteDigesterBg.diframe.DiActiveRecord;
+import com.my.graphiteDigesterBg.diframe.DiTask;
+import com.my.graphiteDigesterBg.diframe.util.DiJsonHelper;
+import java.util.Map;
+public class DiMdbNotification extends DiActiveRecord {
+    @ActiveRecordField
+    public Integer id;
+    @ActiveRecordField
+    public String type;
+    @ActiveRecordField
+    public String data;
+    @ActiveRecordField
+    public String status;
+
+    // get table name
+    public static String getTableName() {
+        return "app_notifications";
+    }
+
+    // notify action
+    public static void taskAction(DiTask task, String action ) {
+        DiMdbNotification.taskAction(task, action, "");
+    }
+
+    // notify action
+    public static void taskAction( DiTask task, String action, Object data ) {
+        Map<String, Object> notifyData = Map.of(
+            "action", action,
+            "data", data,
+            "task", task.getUUID()
+        );
+        var notification = new DiMdbNotification();
+        notification.type = "task-action";
+        notification.data = DiJsonHelper.objectToJson(notifyData);
+        notification.status = "new";
+        notification.save();
+    }
+}