Customer-Service/application/service/controller/Message.php

<?php
namespace app\service\controller;

class Message extends Base
{
    public function index()
    {
        // 留言信息(默认查询前七天的留言)
        $start = time()-604800;
        $end = time();
        $where = array();
        if(request()->isGet()){
            $start_time = input("param.start_time/s");
            $end_time = input("param.end_time/s");
            $searchText = input("param.searchText/s");
            $limit  = input("param.pageSize/s");
            $pageNumber = input("param.pageNumber/s");
            $offset = (input("param.pageNumber/s") - 1) * $limit;
            if(!empty($searchText)){
                $where['content'] = array('like','%'.$searchText.'%');
            }
            if(!empty($start_time)){
                $start = strtotime($start_time);
            }
            if(!empty($end_time)){
                $end = strtotime($end_time . ' 23:59:59');
            }
        }
        $message = db('accountsmessage')->whereBetween('add_time', [$start, $end])->where($where)->limit($offset, $limit)->order('add_time', 'desc')->select();
        $total = db('accountsmessage')->whereBetween('add_time', [$start, $end])->order('add_time', 'desc')->count();
        $pages = ceil($total/$limit);

        $users = db('users')->select();
        foreach($message as $key=>$vo){
            //转为日期时间格式
            $message[$key]['add_time'] = date('Y-m-d H:i:s',$vo['add_time']);
            if(!empty($vo['dealWith_time'])){
                $message[$key]['dealWith_time'] = date('Y-m-d H:i:s',$vo['dealWith_time']);
            }
            $message[$key]['user_name'] = '';
            foreach($users as $k=>$v){
                if($vo['user_id'] == $v['id']){
                    $message[$key]['user_name'] = $users[$k]['user_name'];
                }
            }
        }
        $info = array();
        $info['total'] = $total;
        $info['pages'] = $pages;
        $info['pageSize'] = $limit;
        $info['pageNumber'] = $pageNumber;
        $info['list'] = $message;

        $data = [
            'status'=>1,
            'msg'=>'成功',
            'data'=>$info
        ];

        return json_encode($data,JSON_UNESCAPED_UNICODE);
    }

    // 处理留言
    public function dealmessage()
    {
        if(request()->isPost()){

            //客服id
            //$user_id = 2;
            $user_id = input("param.user_id/s");
            //留言id
            //$message_id = 14;
            $message_id = input("param.message_id/s");
            //回复内容
            $reply_content = input("param.reply_content/s");
            //回复图片
            $images = input("param.images/s");

            $user = db('users')->where('id', $user_id)->find();
            if(empty($user)){
                return json(['code' => -1, 'data' => '', 'msg' => '客服不存在']);
            }
            $message = db('accountsmessage')->where('message_id', $message_id)->find();
            if(empty($message)){
                return json(['code' => -1, 'data' => '', 'msg' => '留言不存在']);
            }

            // 更新留言状态
            $param = [
                'user_id' => $user_id,
                'message_status' => 1,
                'reply_content' => $reply_content,
                'images' => $images,
                'dealWith_time' => time()
            ];

            try{
                db('accountsmessage')->where('message_id', $message_id)->update($param);
            }catch(\Exception $e){
                return json(['code' => -1, 'data' => '', 'msg' => $e->getMessage()]);
            }

            return json(['code' => 1, 'data' => '', 'msg' => '留言处理成功']);
        }
    }

}