<?php
namespace app\service\controller;

class Message extends Base
{
    public function index()
    {
        // 留言信息
        $message = db('accountsmessage')->join('accounts','accounts.id=ws_accountsmessage.account_id')->where('message_status', 0)->select();
        //print_r($message);
        $this->assign([
            'message' => $message,
        ]);

        return $this->fetch();
    }

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

            //客服id
            $user_id = 2;
            //留言id
            $message_id = 14;

            $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,
                'dealWith_time' => time()
            ];
            db('accountsmessage')->where('message_id', $message_id)->update($param);

            return json(['code' => 1, 'data' => url('message/index'), 'msg' => '处理成功']);
        }
    }

}