$v){ if($v != null) $where2[] = "$k = '$v'"; else $where2[] = "$k IS NULL"; } $where = implode(" AND " ,$where2); try{ $db = Zend_Db_Table::getDefaultAdapter(); $select = $this->getDbTable()->select() ->from($this->_dbTable) ->where($where); if(is_array($order)){ foreach ($order as $k => $v) $a[] = "$k $v"; $select->order($a); } $stmt = $select->query(); $result = $stmt->fetchAll(); if(!$array){ $entries = array(); if(count($result) > 0) { foreach ($result as $row) { $entry = new Application_Model_Eventreport($row); $entry->setID($row['reportID']); $entries[] = $entry; } } return $entries; }else{ return $result; } }catch (Zend_Exception $e) { echo "Error message 2: " . $e->getMessage() . "\n"; } } public function setDbTable($dbTable) { if (is_string($dbTable)) { $dbTable = new $dbTable(); } if (!$dbTable instanceof Zend_Db_Table_Abstract) { throw new Exception('Invalid table data gateway provided'); } $this->_dbTable = $dbTable; return $this; } public function getDbTable() { if (null === $this->_dbTable) { $this->setDbTable('Application_Model_DbTable_Eventreport'); } return $this->_dbTable; } public function save(Application_Model_Eventreport $eventreport) { $data = array('reportID'=> $eventreport->getID() ,'eventID'=> $eventreport->getEventID() ,'result'=> $eventreport->getResult(), 'errors' => $eventreport->getErrors(), 'type' => $eventreport->getType(), 'created' => $eventreport->getCreated() ); if (null === ($id = $eventreport->getID()) ) { unset($data['reportID']); return $this->getDbTable()->insert($data); } else { $this->getDbTable()->update($data, array('reportID = ?' => $id)); } } public function delete(Application_Model_Eventreport $eventreport) { if (null === ($id = $eventreport->getID()) ) { return; } else { $this->getDbTable()->delete(array('reportID = ?' => $id)); } } public function find($id, Application_Model_Eventreport $eventreport = null) { $return = false; $result = $this->getDbTable()->find($id); if (0 == count($result)) { return; } $row = $result->current(); if($eventreport == null){ $return = true; } if($return) { $eventreport = new Application_Model_Eventreport(); $eventreport ->setID($row->reportID) ->setEventID($row->eventID) ->setResult($row->result) ->setErrors($row->errors) ->setCreated($row->created) ->setType($row->type); return $eventreport; } else { $eventreport ->setID($row->reportID) ->setEventID($row->eventID) ->setResult($row->result) ->setErrors($row->errors) ->setCreated($row->created) ->setType($row->type); } } public function fetchAll() { $resultSet = $this->getDbTable()->fetchAll(); $entries = array(); foreach ($resultSet as $row) { $entry = new Application_Model_Eventreport(); $entry ->setID($row->reportID) ->setEventID($row->eventID) ->setResult($row->result) ->setErrors($row->errors) ->setCreated($row->created) ->setType($row->type); $entries[$row->reportID] = $entry; } return $entries; } public function compare(Application_Model_Eventreport $v1,Application_Model_Eventreport $v2){ $vv1 = $v1->toArray(); $vv2 = $v2->toArray(); return array_diff_assoc($vv1,$vv2); } public function getSuccessBarCount($poolID) { $db = Zend_Db_Table::getDefaultAdapter(); if($poolID != 'all'){ $select = $this->getDbTable()->select() ->setIntegrityCheck(false) ->from(array('pcr' => 'poolctrl_eventreport'), array('count1' => 'SUM(IF(pcr.result="succeeded",1,0))', 'count0' => 'SUM(IF(pcr.result="failed",1,0))') ) ->join(array('pce' => 'poolctrl_event'), 'pce.eventID = pcr.eventID', array()) ->where('pce.pbs_poolID = ?', $poolID);} else { $select = $this->getDbTable()->select() ->setIntegrityCheck(false) ->from(array('pcr' => 'poolctrl_eventreport'), array('count1' => 'SUM(IF(pcr.result="succeeded",1,0))', 'count0' => 'SUM(IF(pcr.result="failed",1,0))') ) ->join(array('pce' => 'poolctrl_event'), 'pce.eventID = pcr.eventID', array()); } $stmt = $db->query($select); $result = $stmt->fetchAll(PDO::FETCH_NUM); foreach ($result as $r) { $ret1 = array((int)$r[0],'Successful'); $ret2 = array((int)$r[1],'Failed'); $return[] = array($ret1,$ret2); } return $return; } public function getSuccessPieCount($poolID) { $db = Zend_Db_Table::getDefaultAdapter(); if($poolID != 'all'){ $select = $this->getDbTable()->select() ->setIntegrityCheck(false) ->from(array('pcr' => 'poolctrl_eventreport'), array('count1' => 'SUM(IF(pcr.result="succeeded",1,0))', 'count0' => 'SUM(IF(pcr.result="failed",1,0))') ) ->join(array('pce' => 'poolctrl_event'), 'pce.eventID = pcr.eventID', array()) ->where('pce.pbs_poolID = ?', $poolID);} else { $select = $this->getDbTable()->select() ->setIntegrityCheck(false) ->from(array('pcr' => 'poolctrl_eventreport'), array('count1' => 'SUM(IF(pcr.result="succeeded",1,0))', 'count0' => 'SUM(IF(pcr.result="failed",1,0))') ) ->join(array('pce' => 'poolctrl_event'), 'pce.eventID = pcr.eventID', array()); } $stmt = $db->query($select); $result = $stmt->fetchAll(PDO::FETCH_NUM); foreach ($result as $r) { $ret1 = array('Successful', (int)$r[0]); $ret2 = array('Failed', (int)$r[1]); $return[] = array($ret1,$ret2); } return $return; } public function getSuccessTypePieCount($poolID) { $db = Zend_Db_Table::getDefaultAdapter(); if($poolID != 'all'){ $select = $this->getDbTable()->select() ->setIntegrityCheck(false) ->from(array('pcr' => 'poolctrl_eventreport'), array('errortype' => 'pcr.errors', 'count' => 'COUNT(*)')) ->join(array('pce' => 'poolctrl_event'), 'pce.eventID = pcr.eventID', array()) ->where('pce.pbs_poolID = ?', $poolID) ->group('pcr.errors') ->order('pce.category ASC');} else { $select = $this->getDbTable()->select() ->setIntegrityCheck(false) ->from(array('pcr' => 'poolctrl_eventreport'), array('errortype' => 'pcr.errors', 'count' => 'COUNT(*)')) ->join(array('pce' => 'poolctrl_event'), 'pce.eventID = pcr.eventID', array()) ->group('pcr.errors') ->order('pce.category ASC'); } $stmt = $db->query($select); $result = $stmt->fetchAll(PDO::FETCH_NUM); $ret = null; foreach ($result as $r) { $ret[] = array($r[0], (int)$r[1]); } return array($ret); } }