guochanhua/server/application/api/servies/message/MessageService.php

<?php

namespace app\api\servies\message;

use app\api\response\ZskkErrorResponse;
use app\api\servies\ZskkDefaultService;
use app\api\validate\message\MessageValidate;
use app\api\dao\message\MessageDao;
use app\api\servies\common\CommonService;
use think\facade\Log;
use think\Exception;


/**
 * 后台控制器基类
 * 接口方法权限 必传参数 接口返回 错误抛出 通用参数处理
 */

class MessageService extends ZskkDefaultService {
    protected $logName = "MessageService";
    private $message = null;

    public function __construct(MessageDao $messageDao) {
      parent::__construct();
      $this->message = $messageDao;
    }

    public function getMessageList($params,$token)
    {
        $user = $this->message->getUser($token);
        $info = $this->message->getMessageList($params,$user['id']);
        return $info;
    }

    public function handleAllRead($token)
    {
        try{
            $user = $this->message->getUser($token);
            $res = $this->message->readMessage($user['id'],$user);
            if(!$res){
                $this->throwError('修改失败',0016);
            }
            return $res;
        }catch (Exception $exception){
            $this->throwError($exception->getMessage(),0001);
        }
    }

    public function unRead($token)
    {
        try{
            $user = $this->message->getUser($token);
            $res = $this->message->unReadMessage($user['id']);
            $list = $this->message->getAppUnread($user['id']);
            $data = [
                'all_unread'=>$res,
                'list'=>$list
            ];
            return $data;
        }catch (Exception $exception){
            $this->throwError($exception->getMessage(),0001);
        }
    }

    public function handleDelRead($token)
    {
        try{
            $user = $this->message->getUser($token);
            $res  = $this->message->delReadMessage($user['id']);
            if(!$res){
                $this->throwError('修改失败',0016);
            }
            return $res;
        }catch (Exception $exception){
            $this->throwError($exception->getMessage(),0001);
        }
    }

    public function handleDelAll($token)
    {
        try{
            $user = $this->message->getUser($token);
            $res  = $this->message->delAllMessage($user['id'],$user);
            if(!$res){
                $this->throwError('修改失败',0016);
            }
            return $res;
        }catch (Exception $exception){
            $this->throwError($exception->getMessage(),0001);
        }
    }

    public function read($id,$token)
    {
        try{
            $user = $this->message->getUser($token);
            $res = $this->message->read($id,$user);
            if(!$res){
                $this->throwError('修改失败',0016);
            }
            return $res;
        }catch (Exception $exception){
            $this->throwError($exception->getMessage(),0001);
        }
    }

    public function getInfo($id,$token)
    {
        try{
            $user = $this->message->getUser($token);
            $res = $this->message->getInfo($id,$user);
            if(!$res){
                $this->throwError('获取失败',0017);
            }
            return $res;
        }catch (Exception $exception){
            $this->throwError($exception->getMessage(),0001);
        }
    }

    public function deleteone($id,$token)
    {
        try{
            $user = $this->message->getUser($token);
            $res = $this->message->deleteone($id,$user);
            if(!$res){
                $this->throwError('删除失败',0020);
            }
            return $res;
        }catch (Exception $exception){
            $this->throwError($exception->getMessage(),0001);
        }
    }

    public function getSpecialMessage($token)
    {
        $user = $this->message->getUser($token);
        $message = $this->message->getSpecialMessage($user['institution_id']);
        if(empty($message))
        {
            return ['code'=>0,'message'=>''];
        }else{
            return ['code'=>1,'message'=>$message];
        }
    }
}