application/admin/controllerMessage.php

<?php 
namespace app\admin\controller;

use app\admin\model\MessageModel;

/**
 * 留言板
 */
class Message extends Base
{
	
	public function index()
	{
		$message = new MessageModel();

		$type     = input("param.type/d");
		$pagenum  = input("param.page/d") ;
		$pagesize = input("param.limit/d");
		$search   = input("param.search/d");
		$reply    = input("param.reply/d");

		if ($type == 1) {
			$order    = "scan asc, message_id asc";
			$pagenum  = $pagenum < 1 ? 1: $pagenum;
			$pagesize = $pagesize < 1 ? 10: $pagesize;
			$start    = ($pagenum - 1) * $pagesize;
			$size     = $pagesize;

			$where = [];
			if (!empty($reply)) {
				$where['reply_id'] = $reply;
			}
			if (!empty($search)) {
				if ($search == 3) {
					$where['scan'] = -1;
				}else{
					$where['type'] = $search;
				}
			}

			// 统计
			$sum   = $message->get_count($where);
			// 获取数据
			$list   = $message->get_list_page($where, $order, $fields = "*", $start, $size);

            $data = array();
            $data['code']   = '0';
            $data['msg']    = '';
            $data['count']  = $sum;
            $data['data']   = $list;

            echo json_encode($data);
            exit;
		}

		return $this->fetch('index');
	}
	
	// 删除
	public function delmessage()
	{
		$message = new MessageModel();
		$id      = input("param.message_id/d");
		$ids     = input("param.ids");

		if (!empty($id)) {
			$where = ['message_id' => $id];
		}

		if (!empty($ids)) {
			$ids   = json_decode($ids);
			$where = "message_id IN (".implode(",", $ids).")";
		}

		// 删除数据
		$res = $message->del_data($where);
		if (isset($res['msg'])) {
			echo json_encode($res);
		}else{
			echo json_encode(msg_success("删除成功"));
		}
		exit;
	}

	// 查看留言
	public function read_message()
	{
		$message    = new MessageModel();
		$message_id = input("param.message_id/d");

		if (request()->isAjax()) {

			// 获取数据
			$cont = input("param.content");
			$id   = input("param.message_id/d");
			$data = [
				'message_id'  => $id,
				'content'   => $cont,
			];
			$res  = $message->save_data($data);
			if (isset($res['msg'])) {
				echo json_encode($res);exit;
			}

			echo json_encode(msg_success("编辑成功"));
			exit;
		}else{

			$where = ['message_id' => $message_id];
			$data  = $message->get_info($where);
			// 改变查看状态
			if ($data['scan'] == -1) {
				// 获取数据
				$condtion = [
					'message_id' => $id,
					'scan'       => 1,
				];
				$res  = $message->save_data($condtion);
				if (isset($res['msg'])) {
					echo $res['msg'];exit;
				}
			}

			return $this->fetch('edit', ['data' => $data]);
		}
	}


	// 修改留言状态
	public function change_status()
	{
		$message = new MessageModel();

		if (request()->isAjax()) {

			// 获取数据
			
			$status = input("param.status/d");
			$id     = input("param.id/d");
			$data   = [
				'message_id' => $id,
				'status'	 => $status,
			];

			$res  = $message->save_data($data);
			if (isset($res['msg'])) {
				echo json_encode($res);exit;
			}
			
			echo json_encode(msg_success("编辑成功"));
			exit;
		}
	}

	// 回复留言
	public function reply_message()
	{
		$message    = new MessageModel();
		$message_id = input("param.message_id/d");

		if (request()->isAjax()) {

			// 获取数据
			
			$cont = input("param.content");
			$id   = input("param.message_id/d");
			$data = [
				'reply_id'  => $id,
				'content'   => $cont,
				'type'      => 2,
				'user_ip'   => '127.0.0.1',
				'user_name' => 'root',
				'scan'      => 1,
				'status'    => 1
			];

			$res  = $message->insert_data($data);
			if (isset($res['msg'])) {
				echo json_encode($res);exit;
			}
			
			echo json_encode(msg_success("回复成功"));
			exit;
		}else{

			$data = ['message_id' => $message_id];
			return $this->fetch('reply', $data);

		}
	}	

}


 ?>