src-empire/Empire/Core/AbstractEntity.php line 25

Open in your IDE?
  1. <?php
  2. namespace Empire\Core;
  3. use Doctrine\DBAL\Connection;
  4. use Doctrine\DBAL\DBALException;
  5. use Doctrine\DBAL\FetchMode;
  7. abstract class AbstractEntity implements Entity {
  9.     public static $CACHE;
  11.     public $id;
  12.     public $type;
  14.     public function __construct($initialize = false) {
  15.         if($initialize)
  16.             $this->initialize();
  17.     }
  19.     /**
  20.      * @param int[] $ids
  21.      * @param bool $forceArray
  22.      * @param bool $cache
  23.      * @return static[]|static
  24.      */
  25.     static function load(array $ids, $forceArray=false, $cache = true) {
  26.         if(count($ids) < 1) {
  27.             return $forceArray ? [] : null;
  28.         }
  29.         $class = get_called_class();
  31.         if($cache && count($ids) == 1 && isset(self::$CACHE[$class][$ids[0]])) {
  32.             $res = [self::$CACHE[$class][$ids[0]]];
  33.         } else {
  35.             /** @var static $temp */
  36.             $temp = new $class;
  38.             try {
  39.                 $stmt = Core::db()->executeQuery(sprintf("SELECT * FROM %s WHERE %s IN (?)", $temp->getTable(), $temp->getPrimaryField()),
  40.                     [$ids],
  41.                     [Connection::PARAM_INT_ARRAY]);
  42.             } catch (DBALException $e) {
  43.                 return $forceArray ? [] : null;
  44.             }
  45.             /** @var AbstractEntity[] $res */
  46.             $res = $stmt->fetchAll(FetchMode::CUSTOM_OBJECT, $class, [true]);
  48.             foreach ($res as $r) $r->initialize(); // This is necessary when not using Empire\Legacy\db, because the constructor isn't always called.
  50.             if($cache && count($ids) == 1) {
  51.                 self::$CACHE[$class][$res[0]->id] = $res[0];
  52.             }
  53.         }
  56.         if(isset($res[1]) || $forceArray == true) {
  57.             return $res;
  58.         }
  59.         
  60.         return array_shift($res);
  61.     }
  62.     
  63.     function getID(){
  64.         return $this->id;
  65.     }
  68.     function uid($separator = ':'){
  69.         return (int)($this->type) . $separator . (int)($this->id);
  70.     }
  72.     /**
  73.      * @param static $other
  74.      * @return bool
  75.      */
  76.     function is($other){
  77.         if(!$other){
  78.             return false;
  79.         }
  80.         return $this->uid() == $other->uid();
  81.     }
  83.     /**
  84.      * @param array $fields
  85.      * @return int|bool
  86.      * @throws DBALException
  87.      */
  88.     function updateFields(array $fields = array()) {
  89.         return Core::db()->update($this->getTable(), $fields, [$this->getPrimaryField() => $this->getID()]);
  90.     }
  91.     
  92.     function refresh() {
  93.         /** @var static $class */
  94.         $class = get_called_class();
  95.         
  96.         $new = $class::load([$this->getID()], false, false);
  98.         //delete everything from the old object
  99.         foreach($this as $key => $value){
  100.             unset($this->$key);
  101.         }
  103.         //and set it again from our new object
  104.         foreach($new as $key => $value){
  105.             $this->$key = $value;
  106.         }
  107.         
  108.         return $this;
  109.     }
  110.     
  111.     /**
  112.      * Function to delete by unique ID.
  113.      * 
  114.      * Can be overwritten in the child classes to provide for more checking
  115.      * (child units, etc)
  116.      */
  117.     function delete() {
  118.         Core::db()->executeQuery( sprintf("DELETE FROM %s WHERE %s = ?", $this->getTable(), $this->getPrimaryField()), [$this->getID()]);
  119.         $this->isDeleted = true;
  120.         return true;
  121.     }
  122.     
  123. }