~fabiocbalbuquerque/sahana-agasti/web-services

  const CONN_TEMP_READ = 'import_temp_read';

  const CONN_TEMP_WRITE = 'import_temp_write';

 

  /**

   * @var agEventHandler An agEventHandler instance

   */

 

  abstract protected function setImportSpec();

 

 

    $adapter = Doctrine_Manager::connection()->getDbh();

    $this->_conn[self::CONN_TEMP_READ] = Doctrine_Manager::connection($adapter, self::CONN_TEMP_READ);

  }

 

  /**

  {

    // the parent's destructor will rollback any oustanding open transactions and close conns

    parent::__destruct();

      $this->eh->logAlert('Failed to delete the {' . $this->fileInfo['basename'] . '} import file.');

      $this->eh->logInfo('Successfully deleted the {' . $this->fileInfo['basename'] . '} import file.');

  }

 

  /**

        $this->importSpec[$cleanColumn] = $value;

 

        $eventMsg = 'Import spec column name {' . $column . '} was not clean and was ' .

        $this->eh->logWarning($eventMsg);

      }

    }

    $this->getFileInfo($importFile);

    if (strtolower($this->fileInfo['extension']) <> 'xls') {

      $errMsg = '{' . $this->fileInfo['basename'] .

      $this->eh->logEmerg($errMsg);

    }

 

      $sheetName = $xlsObj->boundsheets[$sheet]['name'];

 

      // We don't import sheets named "Lookup" so we'll skip the remainder of this loop

        $this->eh->logInfo('Ignoring {' . $sheetName . '} worksheet');

        continue;

      }

 

      // clean the column headers to ensure consistency

      $this->eh->logInfo('Cleaning worksheet headers');

        $header = $this->cleanColumnName($header);

      }

      unset($header);

        $this->createTempTable();

      }

 

        $this->eh->logInfo('Valid column headers found!');

          $errMsg = 'Unable to import file due to failed validation of import headers. (Strict ' .

          $this->eh->logEmerg($errMsg);

          $errMsg = 'Import sheet {' . $sheetName . '} failed column header validation. Skipping ' .

          $this->eh->logErr($errMsg);

          continue;

        }

      }

 

      // start by looping our batches

        $this->eh->logInfo('Processing batch {' . $batch . '} of {' . $batches . '}.');

        // each batch clears the import data array

        $importFileData = array();

 

        // begin adding rows and continue to the end for this batch

          $this->eh->logDebug('Reading row {' . $row . '} into import data array.');

 

          // used to tell if the row is empty

              $val = NULL;

            } elseif (strlen(strval($val)) > $this->importSpec[$currentSheetHeaders[$col]]['length']) {

              $eventMsg = 'Value in sheet {' . $sheet . '} row {' . $row . '} column {' .

              $this->eh->logWarning($eventMsg);

              $val = NULL;

            } else {

          }

 

          // check for empty rows early to prevent

            $this->eh->logWarning('Empty row found at sheet {' . $sheet . '} row {' . $row . '}. Skipping.');

            $importFileData[$row] = $importRow;

          }

        }

 

        // process this batch

        $this->eh->logInfo('Successfully loaded batch {' . $batch . '} from file, now inserting into ' .

 

        $inserted = $this->saveImportTempIter($importFileData, $query);

        $this->iterData['tempCount'] += $inserted;

 

    // Log our success and return T/F based on whether or not any non-fatal errors occurred

    $okMsg = 'Completed insertion of ' . $this->iterData['tempCount'] . ' rows from the import ' .

    $this->eh->logNotice($okMsg);

 

  }

 

  /**

                                      Doctrine_Connection_Statement $insertQuery)

  {

    // first check to see if it's even worth running

      $this->eh->logWarning('Cannot save empty dataset to temp table.');

    }

 

    // beginning a transaction should improve performance

      } catch (Exception $e) {

        // in the event of an insert error, don't continue

        $errMsg = 'Failed to insert to temp table with data (' . implode(',', $row) . '). ' .

        $this->eh->logErr($errMsg, count($importDataSet));

        $err = TRUE;

        break;

      // log this info event

      $eventMsg = 'Dropped temporary table {' . $this->tempTable . '}';

      $this->eh->logNotice($eventMsg);

      // we only want to silence 'no such table' errors

        $this->eh->logEmerg('Failed to drop temp table {' . $this->tempTable . '}');

        $this->eh->logInfo('Temp table {' . $this->tempTable . '} does not exist. Skipping drop.');

      }

    }

    try {

      // uses the Doctrine_Export methods see Doctrine_Export api for more details

      $conn->export->createTable($this->tempTable, $importSpec, $this->tempTableOptions);

      $this->eh->logEmerg('Error creating temp table ({' . $this->tempTable . '} for import.');

    }

  }

    // return true / false and return info as appropriate

    if (empty($importSpecDiff)) {

      return TRUE;

      $this->eh->logErr('Error processing sheet headers: Missing required columns.');

        $this->eh->logWarning('Column header {' . $missing . '} is missing.');

      }

      return FALSE;