<?php

namespace App;

use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Arr;

class QueueLog extends Model
{
    protected $hidden = ['pivot','updated_at','deleted_at','created_at'];
    protected $softDelete = true;

    protected $table = 'queue_log';
    protected $primaryKey = 'job_id';

    /**
     * The attributes that are mass assignable.
     *
     * @var array
     */
    protected $fillable = ['status','output','attempt_count','job_status'];

    static function create(array $argv) {
        $obj = new self;
        if (!empty(Arr::get($argv,'uid',''))) {
            $obj->uid = Arr::get($argv,'uid');
        }
        $obj->exchange = Arr::get($argv,'exchange','');
        $obj->route_key = Arr::get($argv,'route_key','');
        $obj->job_handler = Arr::get($argv,'job_handler','');
        $obj->input = Arr::get($argv,'input','');
        $obj->attempt_count = Arr::get($argv,'attempt',0);
        $obj->save();
        return $obj;
    }

    static function markCompleted($job_id, $param) {
        if (is_array($param)) {
            $queue_update = isset($param['queue_update']) && $param['queue_update'] == 1;
            $param = json_encode($param);
        }else{
            $params = json_decode($param, 1);
            $queue_update = isset($params['queue_update']) && $params['queue_update'] == 1;
        }

        if (!$queue_update) {
            self::findOrFail($job_id)->update(['status' => 'com', 'output' => $param, 'attempt_count' => 1]);
        }
    }

}