<?php

class XinonFibuMergeModel {
  public $source;
  public $old_custnum;
  public $new_custnum;
  public $name;
  public $vorname;
  public $strasse;
  public $plz;
  public $ort;
  public $land;
  
  public $create_by = null;
  public $edit_by = null;
  public $create = null;
  public $edit = null;

  public static function create(Array $data) {
    $model = new XinonFibuMerge();

    foreach ($data as $field => $value) {
      if (property_exists(get_called_class(), $field)) {
        $model->$field = $value;
      }
    }

    $me = mfValuecache::singleton()->get("me");
    if (!$me) {
      $me = new User();
      $me->loadMe();
      mfValuecache::singleton()->set("me", $me);
    }

    if ($model->create_by === null) {
      $model->create_by = $me->id;
    }
    if ($model->edit_by === null) {
      $model->edit_by = $me->id;
    }

    return $model;
  }

  public static function getFirst($filter = [], $order = false) {
    $db = FronkDB::singleton();

    if(!$order) {
      $order = "old_custnum";
    }
    $where = self::getSqlFilter($filter);
    $res = $db->select("XinonFibuMerge", "*", "$where ORDER BY $order LIMIT 1");
    if ($db->num_rows($res)) {
      $data = $db->fetch_object($res);
      $item = new XinonFibuMerge($data);
      if ($item->id) {
        return $item;
      } else {
        return null;
      }
    }
    return null;
  }

  public static function getAll($order = false) {
    $items = [];

    if(!$order) {
      $order = "old_custnum";
    }

    $db = FronkDB::singleton();

    $res = $db->select("XinonFibuMerge", "*", "1=1 ORDER BY $order");
    if ($db->num_rows($res)) {
      while ($data = $db->fetch_object($res)) {
        $items[] = new XinonFibuMerge($data);
      }
    }
    return $items;
  }

  public static function count($filter) {
    $db = FronkDB::singleton();

    $where = self::getSqlFilter($filter);
    $sql = "SELECT COUNT(*) as cnt FROM XinonFibuMerge
            WHERE $where
           ";

    $res = $db->query($sql);
    if ($db->num_rows($res)) {
      $data = $db->fetch_object($res);
      return $data->cnt;
    }
    return 0;
  }

  public static function search($filter = [], $limit = false, $order = false) {
    $items = [];
    $db = FronkDB::singleton();

    if(!$order) {
        $order = "old_custnum";
    }

    $where = self::getSqlFilter($filter);
    $sql = "SELECT * FROM XinonFibuMerge
            WHERE $where
            ORDER BY $order";


    mfLoghandler::singleton()->debug($sql);
    if (is_array($limit) && count($limit)) {
      if (is_numeric($limit['start']) && is_numeric($limit['count'])) {
        $sql .= " LIMIT " . $limit['start'] . ", " . $limit['count'];
      } elseif (is_numeric($limit['count'])) {
        $sql .= " LIMIT " . $limit['count'];
      }
    }

    $res = $db->query($sql);
    if ($db->num_rows($res)) {
      while ($data = $db->fetch_object($res)) {
        $items[] = new XinonFibuMerge($data);
      }
    }
    return $items;
  }

  private static function getSqlFilter($filter) {
    $where = "1=1 ";
    
    if(array_key_exists("old_custnum", $filter)) {
      $old_custnum = $filter['old_custnum'];
      if (is_numeric($old_custnum)) {
        $where .= " AND XinonFibuMerge.old_custnum=$old_custnum";
      }
    }
    
    if(array_key_exists("new_custnum", $filter)) {
      $new_custnum = $filter['new_custnum'];
      if (is_numeric($new_custnum)) {
        $where .= " AND XinonFibuMerge.new_custnum=$new_custnum";
      }
    }
    
    if(array_key_exists("name", $filter)) {
      $name = $filter["name"];
      if(is_array($name)) {
        
        $name = array_map(function ($value) {
          return FronkDB::singleton()->escape($value);
        }, $name);
        
        $where .= " AND XinonFibuMerge.name IN ('".implode("','", $name)."')";
      } elseif($name) {
        $name = FronkDB::singleton()->escape($filter['name']);
        $where .= " AND XinonFibuMerge.name='$name'";
      }
    }
    
    //var_dump($filter, $where);exit;
    return $where;
  }

}