[留言板]留言模型类优化

zhang
1 parent 4652874d
Showing 2 changed files with 74 additions and 39 deletions
trunk/Message/Common/Model/MessageModel.class.php
trunk/Message/Common/Sql/structure.php
 <?php
-
 namespace Common\Model;
  
 class MessageModel extends AbstractModel
@@ -36,8 +35,12 @@ class MessageModel extends AbstractModel
      * @param  $page   int 页码
      * @return array
      */
-    public function messageList($conds = [],$page = 0)
+    public function message_list($conds = [],$page = 0)
     {
+        if ($page < 1 || !$page) {
+            $page = self::PAGING_DEFAULT_PAGE;
+        }
+
         $params = [];
         $wheres = [];
  
@@ -49,11 +52,8 @@ class MessageModel extends AbstractModel
         }
  
         $page_size = self::PAGING_DEFAULT_LIMIT;
-        $page_start = self::PAGING_DEFAULT_PAGE;
  
-        if ($page) {
-            $page_start = ($page - 1) * $page_size;
-        }
+        $page_start = ($page - 1) * $page_size;
  
         $option = [$page_start,$page_size];
  
@@ -64,7 +64,7 @@ class MessageModel extends AbstractModel
  
  
         if (in_array('title',$conds)) {
-            $where = " title LIKE ? ";
+            $where = " title LIKE '?' ";
         }
         else{
             $fields = array_keys($conds);
@@ -77,13 +77,20 @@ class MessageModel extends AbstractModel
  
         }
  
-        $sql = "SELECT a.* FROM __TABLE__ a 
+        $sql = "SELECT a.message_id,a.title,a.message,IFNULL(b.name,'') AS `from`,IFNULL(c.name,'') AS `to`,a.checked
+                FROM __TABLE__ a 
                 LEFT JOIN {$table} b ON a.uid = b.person_id 
+                LEFT JOIN {$table} c ON a.receiver_uid = c.person_id 
                 WHERE $where";
  
         $list =  $this->_m->fetch_array($sql, $params,$option);
  
-        return $list;
+        $messageList['total'] = count($list);
+        $messageList['page'] = $page;
+        $messageList['limit'] = $page_size;
+        $messageList['list'] = $list;
+
+        return $messageList;
     }
  
     /**
@@ -162,9 +169,6 @@ class MessageModel extends AbstractModel
             $where = " $field = ? ";
         }
  
-//        print_r($conds);
-//        print_r($where);
-//        die;
         if ($where) {
             $sql = "SELECT a.* FROM __TABLE__ a 
                 JOIN {$table} b ON a.uid = b.person_id 
@@ -185,7 +189,7 @@ class MessageModel extends AbstractModel
      * @return array|bool
      * Date: 2018-10-11 Time: 11:47
      */
-    public function messageDetail($message_id = 0)
+    public function message_detail($message_id = 0)
     {
         $params = [];
         $wheres = [];
@@ -213,15 +217,16 @@ class MessageModel extends AbstractModel
         $table_attachment = $m_attachment->get_tname();
  
  
-        $sql = "SELECT attachment FROM __TABLE__ m WHERE `message_id` = 5 ";
-        $attachment_id_arr = $this->_m->query($sql);
-
-        $attachment_id_str = $attachment_id_arr[0]['attachment'];
+        $attachment_id_str = $this->getAttachmentIdByMsgId($message_id);
  
-        $sql = "SELECT `path` FROM {$table_attachment} 
+        $attachment = [];
+        if ($attachment_id_str) {
+            $sql = "SELECT `path` FROM {$table_attachment} 
                 WHERE attachment_id  IN ($attachment_id_str)";
  
-        $attachment = $this->_m->fetch_array($sql,$params);
+            $attachment = $this->_m->fetch_array($sql,$params);
+        }
+
  
         $message['attachment'] = $attachment;
  
@@ -254,7 +259,36 @@ class MessageModel extends AbstractModel
                 FROM __TABLE__ WHERE `message_id` = ? ";
         $attachment =  $this->_m->fetch_row($sql,$params);
  
-
        return isset($attachment['attachment']) ? $attachment['attachment'] : '';
     }
+
+    /**
+     * 留言审核
+     * User: <362431947@qq.com>
+     * @param int $message_id
+     * @return bool
+     * Date: 2018-10-11 Time: 21:32
+     */
+    public function check($message_id = 0,$checked = 1)
+    {
+//        // 未审核状态
+//        $conds = [
+//            'message_id' => $message_id,
+//        ];
+
+        $exists = $this->_m->field('message_id')->find($message_id);
+
+        if ($exists) {
+
+            $data = [
+                'checked' =>$checked,
+            ];
+
+            return $this->update($message_id,$data,true);
+        }
+        else{
+            return false;
+        }
+
+    }
 }
@@ -46,25 +46,6 @@ CREATE TABLE IF NOT EXISTS `zx_message_message`(
     INDEX(`deleted`)
 )ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='留言板-留言信息表';
  
--- 留言与评论关联表
-CREATE TABLE IF NOT EXISTS `zx_message_msg_comment`(
-    `id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
-    `message_id` int(10) unsigned NOT NULL DEFAULT 0 COMMENT '留言记录id',
-    `comment_id` int(10) unsigned NOT NULL DEFAULT 0 COMMENT '评论记录id',
-    `domain` varchar(32) NOT NULL DEFAULT '' COMMENT '企业域名',
-    `status` tinyint(3) unsigned NOT NULL DEFAULT 1 COMMENT '状态, 1=初始化，2=已更新，3=已删除',
-    `created` bigint(13) unsigned NOT NULL DEFAULT 0 COMMENT '创建时间',
-    `updated` bigint(13) unsigned NOT NULL DEFAULT 0 COMMENT '更新时间',
-    `deleted` bigint(13) unsigned NOT NULL DEFAULT 0 COMMENT '删除时间',
-    PRIMARY KEY(`id`),
-    INDEX(`message_id`),
-    INDEX(`comment_id`),
-    INDEX(`domain`),
-    INDEX(`status`),
-    INDEX(`created`),
-    INDEX(`updated`),
-    INDEX(`deleted`)
-)ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='留言与评论关联表';
  
 -- 评论表
 CREATE TABLE IF NOT EXISTS `zx_message_comment`(
@@ -129,4 +110,24 @@ CREATE TABLE  IF NOT EXISTS `zx_message_setting` (
     PRIMARY KEY (`id`),
     KEY `domain_status` (`domain`,`status`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='留言板-设置表';
+
+-- 留言与评论关联表
+CREATE TABLE IF NOT EXISTS `zx_message_msg_comment`(
+    `id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
+    `message_id` int(10) unsigned NOT NULL DEFAULT 0 COMMENT '留言记录id',
+    `comment_id` int(10) unsigned NOT NULL DEFAULT 0 COMMENT '评论记录id',
+    `domain` varchar(32) NOT NULL DEFAULT '' COMMENT '企业域名',
+    `status` tinyint(3) unsigned NOT NULL DEFAULT 1 COMMENT '状态, 1=初始化，2=已更新，3=已删除',
+    `created` bigint(13) unsigned NOT NULL DEFAULT 0 COMMENT '创建时间',
+    `updated` bigint(13) unsigned NOT NULL DEFAULT 0 COMMENT '更新时间',
+    `deleted` bigint(13) unsigned NOT NULL DEFAULT 0 COMMENT '删除时间',
+    PRIMARY KEY(`id`),
+    INDEX(`message_id`),
+    INDEX(`comment_id`),
+    INDEX(`domain`),
+    INDEX(`status`),
+    INDEX(`created`),
+    INDEX(`updated`),
+    INDEX(`deleted`)
+)ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='留言与评论关联表';
 ";