class gcm extends db_connect
{
    private $accountId = 0;
    // private $url = "https://android.googleapis.com/gcm/send";
    private $url = "https://fcm.googleapis.com/fcm/send";
    private $ids = array();
    private $data = array();

    
    public function __construct($dbo = NULL, $accountId = 0)
    {
        parent::__construct($dbo);

        $this->accountId = $accountId;

        if ($this->accountId != 0) {

            $stmt = $this->db->prepare("SELECT fcm_regId, lang FROM access_data WHERE accountId = (:accountId) AND removeAt = 0 AND appType > 1 AND fcm_regId <> ''"); // appType = 1 -> APP_TYPE_WEB
            $stmt->bindParam(":accountId", $accountId, PDO::PARAM_INT);

            if ($stmt->execute()) {

                while ($row = $stmt->fetch()) {

                    [COLOR=#E25041]$this->addDeviceId($row['fcm_regId']);[/COLOR]
                    
                }
            }
        }
    }

    
    public function setIds($ids)
    {
        [COLOR=#E25041]$this->ids = $ids;[/COLOR]
    }

    public function getIds()
    {
        return $this->ids;
    }

    public function clearIds()
    {
        $this->ids = array();
    }

    public function sendToAll()
    {
        $laps = ceil(count([COLOR=#E25041]$this->ids[/COLOR]) / 999);

        if ($laps == 1) {

            $this->send();
        }

        $mod = count([COLOR=#E25041]$this->ids[/COLOR]) % 999;

        $marker = 0;

        $delivered = 0;
        $status = 0;

        while ($laps > 0) {

           [COLOR=#E25041] $fcm_ids = array();[/COLOR]
            
            if ($laps == 1) {

                $n = $marker + $mod;

            } else {

                $n = $marker + 999;
            }

            for ($i = $marker; $i < $n; $i++) {

                [COLOR=#E25041]$fcm_ids[] = $this->ids[$i];[/COLOR]
                
            }

            $marker = $marker + 999;

            // Send

            $delivered = $delivered + $this->send_to([COLOR=#E25041]$fcm_ids[/COLOR]);

            $laps--;
        }

        if ($delivered > 0) {

            $status = 1;
        }

         $this->addToHistory($this->data['msg'], $this->data['type'], $status, $delivered);
    }

    public function send_to([COLOR=#E25041]$fcm_ids[/COLOR])
    {
        $result = array("error" => true,
                        "description" => "regId not found");

        if (empty($fcm_ids)) {

            return $result;
        }





        $username="Ayse";

        if ($lang_ids=="tr") {
            $mmm = $username." üye oldu";
            }else{    
                    $mmm = $username." стала учасником";
        }
        
$notify = array("body" => $mmm, "priority" => "high");
        $post = array(
            'registration_ids'   => $fcm_ids,
            'notification'       => $notify,
            'priority'           => "high",
            'data'               => $this->data,
            'content_available'  => true,
        );

        $headers = array(
            'Authorization: key=AAAALLMnDgg:xxxxxxxxxxx-xxxxxx',
            'Content-Type: application/json'
        );

        $ch = curl_init();

        curl_setopt($ch, CURLOPT_URL, $this->url);
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($post));

        $result = curl_exec($ch);

        if (curl_errno($ch)) {

            $result = array("error" => true,
                            "failure" => 1,
                            "description" => curl_error($ch));
        }

        curl_close($ch);

        $obj = json_decode($result, true);

        return $obj['success'];
    }

    public function send()
    {
        $result = array("error" => true,
                        "description" => "regId not found");

        if (empty($this->ids)) {

            return $result;
        }
         //         $notify = array("body_loc_key" => "label_newuser_notify", "priority" => "high");
        //$notify = array('priority'=> "high");

        
        $username="Ayse";
                if ($lang_ids=="tr") {
            $mmm = $username." üye oldu";
            }else{    
                    $mmm = $username." стала учасником";
        }
        

$notify = array("body" => $mmm, "priority" => "high");
        $post = array(
            'registration_ids'   => $fcm_ids,
            'notification'       => $notify,
            'priority'           => "high",
            'data'               => $this->data,
            'content_available'  => true,
        );

        $headers = array(
            'Authorization: key=' . GOOGLE_API_KEY,
            'Content-Type: application/json'
        );
        
        $ch = curl_init();

        curl_setopt( $ch, CURLOPT_URL, $this->url);
        curl_setopt( $ch, CURLOPT_POST, true);
        curl_setopt( $ch, CURLOPT_HTTPHEADER, $headers);
        curl_setopt( $ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt( $ch, CURLOPT_POSTFIELDS, json_encode($post));

        $result = curl_exec($ch);

        if (curl_errno($ch)) {

            $result = array("error" => true,
                            "failure" => 1,
                            "description" => curl_error($ch));
        }

        curl_close($ch);

        $obj = json_decode($result, true);

        $status = 0;

        if ($obj['success'] != 0) {

            $status = 1;
        }

        $this->addToHistory($this->data['msg'], $this->data['type'], $status, $obj['success']);

        return $result;
    }

    private function addToHistory($msg, $msgType, $status, $success)
    {
        if ($msgType == 1 || $msgType == 2 || $msgType == 8) {

            $currentTime = time();

            $stmt = $this->db->prepare("INSERT INTO gcm_history (msg, msgType, accountId, status, success, createAt) value (:msg, :msgType, :accountId, :status, :success, :createAt)");
            $stmt->bindParam(":msg", $msg, PDO::PARAM_STR);
            $stmt->bindParam(":msgType", $msgType, PDO::PARAM_INT);
            $stmt->bindParam(":accountId", $this->accountId, PDO::PARAM_INT);
            $stmt->bindParam(":status", $status, PDO::PARAM_INT);
            $stmt->bindParam(":success", $success, PDO::PARAM_INT);
            $stmt->bindParam(":createAt", $currentTime, PDO::PARAM_INT);
            $stmt->execute();
        }
    }

    public function forAll()
    {
        $stmt = $this->db->prepare("SELECT fcm_regId, lang FROM access_data WHERE removeAt = 0 AND appType > 1 AND fcm_regId <> ''"); // appType = 1 -> APP_TYPE_WEB

        if ($stmt->execute()) {

            while ($row = $stmt->fetch()) {

                [COLOR=#E25041]$this->addDeviceId($row['fcm_regId']);[/COLOR]
                //$this->addDeviceId($row['lang']);
            }
        }
    }

şeklindeki kodla anlaşıldığı üzere fcm_regId alınıp parçalı şekilde tüm üyelere gönderiliyor. body_loc_key ile gönderemedim bir türlü yerel dilde. bende @OmerAti; üstadın dediği gibi db den çekerek göndereyim dedim. bu normalde hazır bi uygulama. düzenlemeye çalışıyorum sadece. lang fieldı ekleyip bunu dbde tutayım dedim. bu aşamada maalesef fcm_regId ile birlikte bir türlü "lang" fieldını alamadım. yardımcı olabilecek arkadaş var mı? bir kaç denemem oldu ancak hep "else" olarak gönderdi boş geldiği için..