[留言板]留言信息展示,详情,删除

zhang
1 parent 649e653d
Showing 4 changed files with 282 additions and 19 deletions
trunk/Message/Api/Controller/Comment/CommentController.class.php
trunk/Message/Api/Controller/Message/MsgController.class.php
trunk/Message/Api/Lang/zh-cn.php
trunk/Message/Common/Model/MessageModel.class.php
@@ -34,8 +34,8 @@ class CommentController extends AbstractController
  
         $m_comment = new CommentModel();
  
-        print_r($input);
-        $result = $m_comment->addOne($input);
+
+        $result = $m_comment->add($input);
  
         $this->_result = boolval($result);
     }
@@ -16,47 +16,73 @@ class MsgController  extends AbstractController
      */
     public function Index_post()
     {
-        // echo md5('123');
-        // echo $msectime; 1539069172335
         $input = I('post.');
  
-        if(! $input){
+        if (! $input) {
             E('_ERR_POST_EMPTY');
         }
  
         $title = $input['title'];
-        if(! $title){
+        if (! $title) {
             E('_ERROR_TITLE_EMPTY');
         }
  
-        if(get_str_len($title) > 80){
+        if (get_str_len($title) > 80) {
             E('_ERROR_MESSAGE_TITLE_LENGTH');
         }
  
         $message = $input['message'];
-        if(! $message){
+        if (! $message) {
             E('_ERROR_MESSAGE_EMPTY');
         }
  
-        if(get_str_len($message) > 500){
+        if (get_str_len($message) > 500) {
             E('_ERROR_MESSAGE_LENGTH');
         }
  
         $input['ip'] = $_SERVER['REMOTE_ADDR'];
-        $input['uid'] = session['auth_login']['uid'];
-        $input['attachment'] = '';
+
+
+        $uid = $input['uid'];
+        if (! $uid) {
+            E('_ERROR_USER_ID_EMPTY');
+        }
+
+        $m_attachment = new AttachmentModel();
+        $attach_id_str = $m_attachment->add();
+
+        if (false !== $attach_id_str) {
+            $input['attachment'] = $attach_id_str;
+        }
+
         // 素材id,多个使用逗号分隔
         // $input['receiver_uid'] = ''; // 不能是自己
         $input['domain'] = md5($_SERVER['HTTP_HOST']);
  
  
         $m_message = new MessageModel();
+        $result = $m_message->addOne($input);
  
-        $m_attachment = new AttachmentModel();
+        $this->_result = boolval($result);
+    }
  
-        $result = $m_attachment->add();
+    /**
+     * 留言列表
+     * @author <362431947@qq.com>
+     * @date   2018-10-10
+     */
+    public function list_post()
+    {
+        $input = I('post.');
  
-        $this->_result = boolval($result);
+        $uid = $input['uid'];
+        if (! $uid ) E('_ERROR_USER_ID_EMPTY');
+
+        $m_message = new MessageModel();
+
+        $message_list = $m_message->messageList($uid);
+
+        $this->_result = $message_list;
     }
  
 }
@@ -8,6 +8,7 @@ return [
     '_ERROR_TITLE_EMPTY'         => '2018005:标题为空',
     '_ERROR_MESSAGE_TITLE_LENGTH'=> '2018006:标题长度不能大于80个字符',
     '_ERROR_MESSAGE_EMPTY'       => '2018007:内容为空',
-    '_ERROR_MESSAGE_LENGTH'      => '2018007:内容长度不能大于500个字符',
+    '_ERROR_MESSAGE_LENGTH'      => '2018008:内容长度不能大于500个字符',
+    '_ERROR_USER_ID_EMPTY'       => '2091009:用户id为空',
     '_ERR_ID_EMPTY'              => '2091003:id为空',
 ];
 <?php
+
 namespace Common\Model;
  
 class MessageModel extends AbstractModel
 {
+    public function __construct()
+    {
+        parent::__construct();
+    }
+
     /**
      * 添加留言内容
-     * @author <362431947@qq.com>
-     * @date   2018-10-09
-     * @param  array      $data
+     * User: <362431947@qq.com>
+     * @param array $data
+     * @return bool|mixed
+     * Date: 2018-10-10 Time: 22:32
      */
-    public function addOne(array $data)
+    public function addOne($data = [])
     {
         if(! is_array($data)|| ! $data){
             return false;
@@ -21,4 +28,233 @@ class MessageModel extends AbstractModel
  
         return $result;
     }
+
+    /**
+     * 留言信息列表
+     * @author <362431947@qq.com>
+     * @date   2018-10-10
+     * @param  $page   int 页码
+     * @return array
+     */
+    public function messageList($conds = [],$page = 0)
+    {
+        $params = [];
+        $wheres = [];
+
+        $conds['a.status'] = $this->get_st_create();
+
+
+        if (!$this->_parse_where($wheres, $params, $conds)) {
+            return false;
+        }
+
+        $page_size = self::PAGING_DEFAULT_LIMIT;
+        $page_start = self::PAGING_DEFAULT_PAGE;
+
+        if ($page) {
+            $page_start = ($page - 1) * $page_size;
+        }
+
+        $option = [$page_start,$page_size];
+
+
+
+        $m_person = new PersonModel();
+        $table = $m_person->get_tname();
+
+
+        if (in_array('title',$conds)) {
+            $where = " title LIKE ? ";
+        }
+        else{
+            $fields = array_keys($conds);
+
+            if ($fields != 'status') {
+                $field = $fields[0];
+            }
+
+            $where = "  $field = ? ";
+
+        }
+
+        $sql = "SELECT a.* FROM __TABLE__ a 
+                LEFT JOIN {$table} b ON a.uid = b.person_id 
+                WHERE $where";
+
+        $list =  $this->_m->fetch_array($sql, $params,$option);
+
+        return $list;
+    }
+
+    /**
+     * 后台留言删除
+     * User: <362431947@qq.com>
+     * @param int $message_id
+     * @return bool
+     * Date: 2018-10-10 Time: 22:24
+     */
+    public function del($message_id = 0)
+    {
+        $this->_m->startTrans();
+
+
+        $attachment_id = $this->getAttachmentIdByMsgId($message_id);
+
+        // 删除相关附件图片
+        $attachment_del = true;
+        if ($attachment_id) {
+            $m_attachment = new AttachmentModel();
+            $attachment_del = $m_attachment->del($attachment_id);
+        }
+
+
+
+        // 删除留言
+        $message_del =  $this->_m->delete($message_id);
+
+
+        // 删除留言评论
+
+        $m_comment = new CommentModel();
+        $exists = $m_comment->getCommentByMsgId($message_id = 0);
+
+        $comment_del = true;
+        if ($exists) {
+            $comment_del = $m_comment->del($message_id);
+        }
+
+        if ($message_del && $comment_del && $attachment_del) {
+            $this->_m->commit();
+            return true;
+        }
+        else{
+            $this->_m->rollback();
+            return false;
+        }
+    }
+
+    /**
+     * 根据搜索条件获取留言信息
+     * User: <362431947@qq.com>
+     * @param array $conds 搜索条件
+     * @return array|bool
+     * Date: 2018-10-10 Time: 22:24
+     */
+    public function search($conds = [])
+    {
+        $params = [];
+        $wheres = [];
+
+        if (!$this->_parse_where($wheres, $params, $conds)) {
+            return false;
+        }
+
+        $m_person = new PersonModel();
+        $table = $m_person->get_tname();
+
+        if (in_array('title',$conds)) {
+            $where = " title LIKE ? ";
+        }
+        else{
+            $fields = array_keys($conds);
+            $field = $fields[0];
+
+            $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 
+                WHERE $where";
+        }
+        else {
+            return [];
+        }
+
+
+        return $this->_m->fetch_array($sql,$params);
+    }
+
+    /**
+     * 留言详情
+     * User: <362431947@qq.com>
+     * @param int $message_id
+     * @return array|bool
+     * Date: 2018-10-11 Time: 11:47
+     */
+    public function messageDetail($message_id = 0)
+    {
+        $params = [];
+        $wheres = [];
+
+        $conds = ['message_id' =>$message_id];
+
+        if (!$this->_parse_where($wheres, $params, $conds)) {
+            return false;
+        }
+
+        $m_person = new PersonModel();
+        $table_person = $m_person->get_tname();
+
+
+        $sql = "SELECT a.message_id,a.title,a.message,b.name as `from`,IFNULL(c.name,'') as `to` 
+            FROM __TABLE__ a
+            LEFT JOIN {$table_person} b ON a.uid = b.person_id
+            LEFT JOIN {$table_person} c ON a.receiver_uid = c.person_id
+            WHERE `message_id` = ? ";
+
+        $message =  $this->_m->fetch_row($sql,$params);
+
+
+        $m_attachment = new AttachmentModel();
+        $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'];
+
+        $sql = "SELECT `path` FROM {$table_attachment} 
+                WHERE attachment_id  IN ($attachment_id_str)";
+
+        $attachment = $this->_m->fetch_array($sql,$params);
+
+        $message['attachment'] = $attachment;
+
+        // 获取评论信息
+        $m_comment = new CommentModel();
+        $message['comment'] = $m_comment->getCommentByMsgId($message_id);
+
+        return $message;
+    }
+
+    /**
+     * getAttachmentIdByMsgId
+     * User: <362431947@qq.com>
+     * @param int $message_id
+     * @return bool
+     * Date: 2018-10-10 Time: 22:18
+     */
+    public function getAttachmentIdByMsgId($message_id = 0)
+    {
+        $params = [];
+        $wheres = [];
+        $conds = [
+            'message_id' => $message_id,
+        ];
+        if (!$this->_parse_where($wheres, $params, $conds)) {
+            return false;
+        }
+
+        $sql = "SELECT attachment
+                FROM __TABLE__ WHERE `message_id` = ? ";
+        $attachment =  $this->_m->fetch_row($sql,$params);
+
+
+       return isset($attachment['attachment']) ? $attachment['attachment'] : '';
+    }
 }