Changeset 4353

Timestamp:

07/11/07 03:03:35 (6 years ago)

Author:

gregmac

Message:

Add notifications class (philippe)

Files:

• freepbx/branches/2.3/amp_conf/htdocs/admin/functions.inc.php (modified) (1 diff)

freepbx/branches/2.3/amp_conf/htdocs/admin/functions.inc.php

@@ -145 +145 @@
-  return $conf;
-}
+
+
+define("NOTIFICATION_TYPE_CRITICAL", 100);
+define("NOTIFICATION_TYPE_SECURITY", 200);
+define("NOTIFICATION_TYPE_UPDATE",  300);
+define("NOTIFICATION_TYPE_ERROR",    400);
+define("NOTIFICATION_TYPE_WARNING" , 500);
+define("NOTIFICATION_TYPE_NOTICE",   600);
+
+class notifications {
+
+  var $not_loaded = true;
+  var $notification_table = array();
+  var $_db;
+    
+  function &create(&$db) {
+    static $obj;
+    if (!isset($obj)) {
+      $obj = new notifications($db);
+    }
+    return $obj;
+  }
+
+  function notifications(&$db) {
+    $this->_db =& $db;
+  }
+
+
+  function add_critical($module, $id, $display_text, $extended_text="", $link="", $reset=true) {
+    $this->_add_type(NOTIFICATION_TYPE_CRITICAL, $module, $id, $display_text, $extended_text, $link, $reset);
+  }
+  function add_security($module, $id, $display_text, $extended_text="", $link="", $reset=true) {
+    $this->_add_type(NOTIFICATION_TYPE_SECURITY, $module, $id, $display_text, $extended_text, $link, $reset);
+  }
+  function add_update($module, $id, $display_text, $extended_text="", $link="", $reset=false) {
+    $this->_add_type(NOTIFICATION_TYPE_UPDATE, $module, $id, $display_text, $extended_text, $link, $reset);
+  }
+  function add_error($module, $id, $display_text, $extended_text="", $link="", $reset=false) {
+    $this->_add_type(NOTIFICATION_TYPE_ERROR, $module, $id, $display_text, $extended_text, $link, $reset);
+  }
+  function add_warning($module, $id, $display_text, $extended_text="", $link="", $reset=false) {
+    $this->_add_type(NOTIFICATION_TYPE_WARNING, $module, $id, $display_text, $extended_text, $link, $reset);
+  }
+  function add_notice($module, $id, $display_text, $extended_text="", $link="", $reset=false) {
+    $this->_add_type(NOTIFICATION_TYPE_NOTICE, $module, $id, $display_text, $extended_text, $link, $reset);
+  }
+
+
+  function list_critical($show_reset=false) {
+    return $this->_list(NOTIFICATION_TYPE_CRITICAL, $show_reset);
+  }
+  function list_security($show_reset=false) {
+    return $this->_list(NOTIFICATION_TYPE_SECURITY, $show_reset);
+  }
+  function list_update($show_reset=false) {
+    return $this->_list(NOTIFICATION_TYPE_UPDATE, $show_reset);
+  }
+  function list_error($show_reset=false) {
+    return $this->_list(NOTIFICATION_TYPE_ERROR, $show_reset);
+  }
+  function list_warning($show_reset=false) {
+    return $this->_list(NOTIFICATION_TYPE_WARNING, $show_reset);
+  }
+  function list_notice($show_reset=false) {
+    return $this->_list(NOTIFICATION_TYPE_NOTICE, $show_reset);
+  }
+  function list_all($show_reset=false) {
+    return $this->_list("", $show_reset);
+  }
+
+
+  function reset($module, $id) {
+    $module        = q($module);
+    $id            = q($id);
+
+    $sql = "UPDATE notifications SET reset = 1 WHERE module = $module AND id = $id";
+    sql($sql);
+  }
+
+  function delete($module, $id) {
+    $module        = q($module);
+    $id            = q($id);
+
+    $sql = "DELETE FROM notifications WHERE module = $module AND id = $id";
+    sql($sql);
+  }
+
+  /* Internal functions
+   */
+
+  function _add_type($level, $module, $id, $display_text, $extended_text="", $link="", $reset=false) {
+    if ($this->not_loaded) {
+      $this->notification_table = $this->_list("",true);
+      $this->not_loaded = false;
+    }
+
+    $existing_row = false;
+    foreach ($this->notification_table as $row) {
+      if ($row['module'] == $module && $row['id'] == $id ) {
+        $existing_row = $row;
+        break;
+      }
+    }
+    // Found an existing row - check if anything changed or if we are suppose to reset it
+    //
+    if ($existing_row) {
+      if (($reset && $existing_row['reset'] == 0) || $existing_row['level'] != $level || $existing_row['display_text'] != $display_text || $existing_row['extended_text'] != $extended_text || $existing_row['link'] != $link) {
+        $module        = q($module);
+        $id            = q($id);
+        $level         = q($level);
+        $display_text  = q($display_text);
+        $extended_text = q($extended_text);
+        $link          = q($link);
+        $now = time();
+        $sql = "UPDATE notifications SET
+          level = $level,
+          display_text = $display_text,
+          extended_text = $extended_text,
+          link = $link,
+          reset = 0,
+          timestamp = $now
+          WHERE module = $module AND id = $id
+        ";
+        sql($sql);
+
+        // TODO: I should really just add this to the internal cache, but really
+        //       how often does this get called that if is a big deal.
+        $this->not_loaded = true;
+      }
+    } else {
+      // No existing row so insert this new one
+      //
+      $now           = time();
+      $module        = q($module);
+      $id            = q($id);
+      $level         = q($level);
+      $display_text  = q($display_text);
+      $extended_text = q($extended_text);
+      $link          = q($link);
+      $sql = "INSERT INTO notifications 
+        (module, id, level, display_text, extended_text, link, reset, timestamp)
+        VALUES 
+        ($module, $id, $level, $display_text, $extended_text, $link, 0, $now)
+      ";
+      sql($sql);
+
+      // TODO: I should really just add this to the internal cache, but really
+      //       how often does this get called that if is a big deal.
+      $this->not_loaded = true;
+    }
+  }
+
+  function _list($level, $show_reset=false) {
+
+    $level = q($level);
+    $where = array();
+
+    if (!$show_reset) {
+      $where[] = "reset = 0";
+    }
+
+    switch ($level) {
+      case NOTIFICATION_TYPE_CRITICAL:
+      case NOTIFICATION_TYPE_SECURITY:
+      case NOTIFICATION_TYPE_UPDATE:
+      case NOTIFICATION_TYPE_ERROR:
+      case NOTIFICATION_TYPE_WARNING:
+      case NOTIFICATION_TYPE_NOTICE:
+        $where[] = "level = $level ";
+        break;
+      default:
+    }
+    $sql = "SELECT * FROM notifications ";
+    if (count($where)) {
+      $sql .= " WHERE ".implode(" AND ", $where);
+    }
+    $sql .= " ORDER BY level, module";
+
+    $list = sql($sql,"getAll",DB_FETCHMODE_ASSOC);
+    return $list;
+  }
+}
+
+
-
-/** Expands variables from amportal.conf