JuelichDataProduct.php

gehe zur Dokumentation dieser Datei

<?php
require_once TM_PATH . 'constants.php';
require_once TM_PATH . 'juelich/JuelichGlobals.php';

class JuelichDataProduct {
  var $db;                      
  var $pData = array('product' => array(),
                     'detail'  => array(),
                     'access'  => array(),
                     'depend'  => array()
                     ); #
  var $accessCache = array();   
  function JuelichDataProduct() {
    $this->db =& getDbReaderInstance();
  }

  function getModel($modellId, &$modelData) {
    $sqlPrep = "SELECT m_name, m_besch, m_sort, m_forumSearch "
      . "FROM modell "
      . "LEFT JOIN modell_l10n USING(modell_id)"
      . "WHERE modell.modell_id = %d "
      . "AND l10n_id=%d ";
    $sql = sprintf($sqlPrep,
                   $modellId,
                   getDataInstance()->getAppData('l10n')
                   );
    $this->db->getOneRow($sql, $modelData);
    if (empty($modelData)) {
      include_once TM_PATH . 'juelich/web/JuelichError.php';
      $error = new JuelichError;
      $error->printError(4,
                         'Keine Daten zum Modell: '
                         . $modellId);
      exit();
    }
    return;
  }

  function getProducts($modellId, &$pData) {
    $data =& getDataInstance();
    $sqlPrep = "SELECT p_preis, p_bild, p_name, "
      . "p_besch2, produkt.produkt_id%s "
      . "FROM produkt "
      . "LEFT JOIN produkt_l10n USING(produkt_id) "
      . "LEFT JOIN %s USING(produkt_id) "
      . "WHERE modell_id = %d "
      . "AND p_online = '%s' "
      . "AND l10n_id = %d "
      . "ORDER BY %s";
    $short = implode(', ', $data->getModuleDbData('short'));
    if ($short != "") {
      $short = ', ' . $short;
    }
    $sql = sprintf($sqlPrep,
                   $short,
                   $data->getModuleDbData('table'),
                   $modellId,
                   SQL_ONLINE,
                   $data->getAppData('l10n'),
                   $data->getAppData('modelSort')
                   );
    $products = array();
    $rows = $this->db->getAllRows($sql, $products);
    if ($rows == 0) {
      include_once TM_PATH . 'juelich/web/JuelichError.php';
      $error = new JuelichError;
      $error->printError(4,
                         'Keine Produkte zum Modell: '
                         . $modell_id);
      exit();
    }
    foreach ($products as $p) {
      $pTmp = $this->pData;
      // Abhängige Produkte
      $dp = $data->getAppData('module')->depend;
      if ($dp && in_array(M_MODEL, $dp['mode'])) {
        $gId = $data->getAppData('module')->gruppe_id;
        $sql = $this->getDependSql($gId, $p['produkt_id']);
        $dpTmp = array();
        $this->db->getAllRows($sql, $dpTmp);
        array_unshift($dpTmp, $p['produkt_id']);
        $pTmp['depend'] = $dpTmp;
      }
      // Zubehör
      if ($data->getAppData('module')->showAccessory) {
        $zTmp   = array();
        $aIds   = array();
        $aDbIds = array();
        $this->getAccessIds($p['produkt_id'], $aIds);
        // Gibt es Zubehör?
        if (!empty($aIds)) {
          foreach ($aIds as $id) {
            // Schon im Cache?
            if (!empty($this->accessCache[$id])) {
              array_push($zTmp, $this->accessCache[$id]);
            }
            // Sonst aus DB holen
            else {
              array_push($aDbIds, $id);
            }
          }
          // Muss Zubehör aus der DB geholt werden?
          if (!empty($aDbIds)) {
            $sqlPrep = "SELECT z_preis, z_name, zubehoer.zubehoer_id, z_intern "
              . "FROM zubehoer "
              . "LEFT JOIN zubehoer_l10n USING(zubehoer_id) "
              . "WHERE z_online = '%s' "
              . "AND zubehoer.zubehoer_id IN(%s)"
              . "AND l10n_id = %d "
              . "ORDER BY z_sort, z_name";
            $sql = sprintf($sqlPrep,
                           SQL_ONLINE,
                           implode(', ', $aDbIds),
                           $data->getAppData('l10n')
                           );
            $this->db->getAllRows($sql, $zTmp);
            $pTmp['access'] = $zTmp;
            foreach ($zTmp as $z) {
              $id = $z['zubehoer_id'];
              $this->accessCache[$id] = $z;
            }
          }
        }
      }
      $s = count($p);
      $pTmp['product'] = array_slice($p, 0, 5);
      $pTmp['detail']  = array_slice($p, 5, $s - 5);
      if (!empty($p['access'])) {
        $pTmp['access']  = $p['access'];
      }
      if (!empty($p['depend'])) {
        $pTmp['depend']  = $p['depend'];
      }
      array_push($pData, $pTmp);
    }
    return $rows;
  }

  function getDetailProduct($id, &$pData) {
    $data =& getDataInstance();
    $dTmp = array('depend' => array(),
                  'data'   => array()
                  );

    if ($data->getAppData('dependDetail')) {
      $sqlPrep = "SELECT %s "
        . "FROM produkt "
        . "LEFT JOIN produkt_l10n USING(produkt_id) "
        . "LEFT JOIN %s USING(produkt_id) "
        . "WHERE produkt.produkt_id = %d "
        . "AND produkt_l10n.l10n_id = %d ";
      $sql = sprintf($sqlPrep,
                     implode(', ', $data->getModuleDbData('dpExtra')),
                     $data->getModuleDbData('dpTable'),
                     $data->getAppData('dependId'),
                     $data->getAppData('l10n')
                     );
      $this->db->getOneRow($sql, $dTmp['depend']);
    }

    $sqlPrep = "SELECT p_preis, p_bild, p_name, "
      . "p_besch1, p_besch2, produkt.produkt_id, m_name%s "
      . "FROM produkt "
      . "LEFT JOIN produkt_l10n USING(produkt_id) "
      . "LEFT JOIN %s USING(produkt_id) "
      . "%s " // l10n-Detaildaten
      . "LEFT JOIN modell_l10n "
      . "ON produkt.modell_id=modell_l10n.modell_id "
      . "WHERE produkt.produkt_id = %d "
      . "AND produkt_l10n.l10n_id = %d "
      . "AND modell_l10n.l10n_id = %d "
      . "%s"; // Sprache l10n-Detaildaten
    $long = implode(', ', $data->getModuleDbData('long'));
    if ($long != "") {
      $long = ', ' . $long;
    }
    $table = $data->getModuleDbData('table');
    $l10nData = '';
    $l10nDataLang = '';
    $l10n = $data->getAppData('l10n');
    if ($data->getModuleDbData('l10n')) {
      $t = $table . '_l10n';
      $l10nData = "LEFT JOIN $t USING(produkt_id) ";
      $l10nDataLang = "AND $t.l10n_id = $l10n";
    }
    $sql = sprintf($sqlPrep,
                   $long,
                   $table,
                   $l10nData,
                   $id,
                   $l10n,
                   $l10n,
                   $l10nDataLang
                   );
    
    $success = $this->db->getOneRow($sql, $dTmp['data']);
    if (!$success) {
      include_once TM_PATH . 'juelich/web/JuelichError.php';
      $error = new JuelichError;
      $error->printError(4,
                         'Keine Detail-Daten zum Produkt: ' . $id);
      exit();
    }
    $pData = $this->pData;
    $pData['product'] = array_slice($dTmp['data'], 0, 7);
    $pData['detail']  = array_slice($dTmp['data'], 7);
    if (!empty($dTmp['depend'])) {
      $pData['detail'] = array_merge($pData['detail'], $dTmp['depend']);
    }
    $t = $pData['product']['m_name'] 
      . ' '
      . $pData['product']['p_name'];
    getDataInstance()->setModelName($pData['product']['m_name']);
    getDataInstance()->setTitle($t);
    return;
  }

  function getDetailAccess($id, &$zData) {
    $data =& getDataInstance();
    $sqlPrep = "SELECT zubehoer.zubehoer_id, z_preis, z_bild, "
      . "z_name, z_besch1, z_besch2, h_name "
      . "FROM zubehoer "
      . "LEFT JOIN zubehoer_l10n USING(zubehoer_id) "
      . "LEFT JOIN hersteller "
      . "ON zubehoer.hersteller_id=hersteller.hersteller_id "
      . "WHERE zubehoer.zubehoer_id = %d "
      . "AND l10n_id = %d";
    $sql = sprintf($sqlPrep,
                   $id,
                   $data->getAppData('l10n')
                   );
    $success = $this->db->getOneRow($sql, $zData);
    if (!$success) {
      include_once TM_PATH . 'juelich/web/JuelichError.php';
      $error = new JuelichError;
      $error->printError(4,
                         'Keine Detail-Daten zum Zubehör: ' . $id);
      exit();
    }
    $t = $zData['h_name'] 
      . ' '
      . $zData['z_name'];
    getDataInstance()->setModelName($zData['h_name']);
    getDataInstance()->setTitle($t);
    return;
  }

  function getAccessIds($pId, &$ids) {
    $sql = "SELECT zubehoer_id "
      . "FROM r_PZ "
      . "WHERE produkt_id = " . $pId;
    $this->db->getAllCols($sql, $ids);
    return;
  }

  function getDependSql($gId, $pId) {
    switch ($gId) {
    case G_SPEKTIV:
      $sql = "SELECT hersteller_id "
        . "FROM produkt WHERE produkt_id=" . $pId;
      $hId = $this->db->getOneValue($sql);
      $sqlPrep = "SELECT p_preis, p_name, produkt.produkt_id "
        . "FROM produkt "
        . "LEFT JOIN produkt_l10n USING(produkt_id) "
        . "WHERE l10n_id = %d "
        . "AND p_online = '%s' "
        . "AND gruppe_id = %d "
        . "AND hersteller_id = %d "
        . "ORDER BY p_preis, p_sort";
      return sprintf($sqlPrep,
                     getDataInstance()->getAppData('l10n'),
                     SQL_ONLINE,
                     G_SPEKTIV_OKULAR,
                     $hId
                     );
    default:
      break;
    }
  }

}

?>

---