~NAXC~

File Content: `JModel.php`

<?php namespace App\Modules\GenModels;

/**
 * Created by PhpStorm.
 * User: jis
 * Date: 6/4/15
 * Time: 10:30 AM
 */

use MongoDB;
use Log;

class JModel
{
    public $collection;

    public function __construct($attributes = array())
    {
        $conObj = new MongoConnection();
//        $this->collection = $conObj->getCollection($attributes['table']);

        $this->collection = $conObj->selectCollection($attributes['table']);
    }

    public function create($data)
    {
        $data['createdTime'] = time();
        $response = $this->collection->insertOne($data);
        return $response->getInsertedId();
    }

    public function update($query, $newData, $multiple = true)
    {
        $newData['updatedTime'] = time();
        if (isset($newData['_id']))
            unset($newData['_id']);
        $this->collection->updateOne($query, array('$set' => $newData), array('multiple' => $multiple));
    }

    public function findOne($query)
    {
        return $this->collection->findOne($query);
    }

    public function find($query, $limit = null)
    {
        $cursor = $this->collection->findOne($query);        
        //Log::info('Limit:' . $limit);
        if ($cursor) {
            //Log::info('aaaaa');
            if ($limit) {
                //Log::info('inside if2');
                $cursor = $this->collection->find(
                    $query,
                    [
                        'limit' => $limit,
                        'sort' => array('updatedTime' => -1)
                    ]
                );
                if ($limit == 1) {

                    $cursor = $this->collection->findOne($query);
                    
                    if ($cursor->count() > 0) {
                        //Log::info('inside if4');                        
                        return $cursor;
                    }
                }
            } else {
           //     Log::info('limit 0');
                $cursor = $this->collection->find(
                    $query
                );                
            }        
            return $cursor;
        }
        return null;
    }

    public function getLastUpdatedItem($query)
    {
        $cursor = $this->collection->find($query);
        if ($cursor) {
            $cursor->sort(array('updatedTime' => -1))->limit(1);
            if ($cursor->count() > 0) {
                $cursor->getNext();
                return $cursor->current();
            }
        }
        return null;
    }


    public function updateMany($filter, $update, array $options = [])
    {
        return $this->collection->updateMany($filter, $update, $options = []);
    }
}
File Content: JModel.php

File Content: `JModel.php`
