crm/app/listener/Msg.php

<?php

namespace app\listener;

use app\event\Msg as EventMsg;
use app\model\EmployeeMsg;

class Msg
{
    public function handle(EventMsg $event)
    {
        if (is_array($event->employee)) {
            foreach ($event->employee as $empId) {
                $this->send($empId, $event->msg, $event->type, $event->data);
            }
        } else {
            $this->send($event->employee, $event->msg, $event->type, $event->data);
        }
    }

    public function send($empId, $msg, $type, $data)
    {
        (new EmployeeMsg)->save([
            'employee_id' => $empId,
            'msg' => $msg,
            'type' => $type,
            'data' => $data
        ]);
    }
}