<?php 

namespace App\Services;

use App\Modules\Oferta\Models\Oferta;
use App\Modules\MailchimpCampaign\Models\MailchimpCampaign;

use Illuminate\Support\Facades\Log;
use Exception;
use DB;

class CanalService {

    public static function setFastPass($canal_id, $fast_pass){

        $query = Oferta::select(
            'oferta.*',
            'produto.id as produto_id'
        )
        ->join('oferta_has_produto','oferta_has_produto.id_oferta','=','oferta.id')
        ->join('produto','produto.id','=','oferta_has_produto.id_produto')
        ->join('produto_caracteristica','produto.id','=','produto_caracteristica.id_produto')
        ->join('tipo_de_produto','tipo_de_produto.id','=','produto.id_tipo_produto')
        ->join('canal_has_oferta','canal_has_oferta.id_oferta','=','oferta.id')
        ->join('canal','canal_has_oferta.id_canal','=','canal.id')
        ->whereRaw('canal_has_oferta.deleted_at IS NULL')
        ->where('canal.id', $canal_id)
        ->groupBy('produto.id')
        ->orderBy('canal_has_oferta.ordenacao', 'asc');

        $listaOfertas = $query->get();

        $listaProdutos = [];
        foreach ($listaOfertas as $oferta):
            $listaProdutos[] = $oferta->produto_id;
        endforeach;

        $produtos = implode(",", $listaProdutos);

        if(count($listaProdutos) > 0):
            $sql = "UPDATE produto SET fast_pass = {$fast_pass} WHERE id IN ({$produtos})";
            Log::info($sql);
            DB::update($sql);
        endif;

        return true;

    }

    public static function updateOfertaCampaign($canal_id, $mailchimp_campaign_id){

        $MailchimpCampaign = MailchimpCampaign::where('id', $mailchimp_campaign_id)->first();
        if($MailchimpCampaign){
            $sql = "UPDATE oferta SET campaign_id = '{$MailchimpCampaign->campaign_id}' WHERE EXISTS (SELECT 1 FROM canal_has_oferta cho WHERE cho.id_oferta = oferta.id AND cho.id_canal = {$canal_id});";
            DB::update($sql);
        }
        return true;
    }

}