Changeset 485 for trunk/phpbms/include/imports.php

Timestamp:

04/07/09 11:44:18 (3 years ago)

Author:

nate

Message:

• Merged Nathan branch back into trunk.

Files:

• trunk/phpbms/include/imports.php (modified) (16 diffs)

trunk/phpbms/include/imports.php

@@ -1 +1 @@
 <?php
         class phpbmsImport{
-                
+
                 var $table;
                 var $error = "";
@@ -10 +10 @@
                 var $data;
                 var $revertID = 0;
-                
+
                 // Do not manually override
                 var $transactionRecords = array();
                 var $tempFileID = 0;
                 var $pageType = "main";
-                
+
                 function phpbmsImport($table, $importType = "csv"){
-                        
+
                         $this->table = $table;
                         $this->importType = $importType;
@@ -25 +25 @@
                                 break;
                         }//end switch
-                        
+
                         $this->table->db->logError = true;
                         //So, that, when there is a db error, it will go all the way through and not just stop
                         $this->table->db->stopOnError = false;
-                        //Won't display db errors, just log them.       
+                        //Won't display db errors, just log them.
                         $this->table->db->showError = false;
                         if(isset($_POST["pageType"]))
                                 $this->pageType = $_POST["pageType"];
-                        
+
                         if(isset($_POST["tempFileID"]))
                                 $this->tempFileID = ((int)$_POST["tempFileID"]);
-                        
+
                 }//end method --imports--
-                
+
                 function _parseFromData($data){
-                        
+
                         switch($this->importType){
-                                
+
                                 case "csv":
-                                        
+
                                         if(is_readable($data)){
                                                 $contents = $this->_getFile($data);
-                                        
+
                                                 if(is_readable($contents)){
                                                         $this->docError = "invalid csv document";
                                                         return false;
                                                 }//end if
-                                                
+
                                         }//end if
-                                        
+
                                         $this->parser->parse($data);
-                                                
+
                                         if(!count($this->parser->titles) || !count($this->parser->data)){
                                                 $this->docError = "invalid csv document";
-                                                return false;   
+                                                return false;
                                         }//end if
-                                        
+
                                         return true;
                                 break;
-                        
+
                         }//end swtich
-                
+
                 }//end method --_parseFromFile--
-                
-                
+
+
                 function _getTransactionData(){
                 //needs to be changed for more complicated tables
@@ -75 +75 @@
                         foreach($this->transactionIDs as $theid)
                                 $inStatement .= $theid.",";
-                        
+
                         if($inStatement){
-                                
+
                                 $inStatement = substr($inStatement, 0, -1);
-                        
+
                                 $querystatement = "
                                         SELECT
@@ -88 +88 @@
                                                 `id` IN (".$inStatement.");
                                         ";
-                                
+
                                 $queryresult = $this->table->db->query($querystatement);
-                                
+
                                 while($therecord = $this->table->db->fetchArray($queryresult))
                                         $this->transactionRecords[] = $therecord;
-                                        
-                        }//end if 
-                        
+
+                        }//end if
+
                 }//end method --_getTransactionData--
-                
-                
+
+
                 function _getFile($fileName){
                         if(function_exists('file_get_contents')){
@@ -106 +106 @@
                                 $file = addslashes(fread(fopen($fileName, 'r'), filesize($fileName)));
                         }//end if
-                        
+
                         return $file;
                 }//end method --_getFile--
-                
+
                 //DO NOT CALL IN TRANSACTION
                 function _storeTempCSV($fileName){
-                        
+
                         $querystatement = "
                                 INSERT INTO
@@ -136 +136 @@
                                                 '".$_SESSION["userinfo"]["id"]."',
                                                 '".$_SESSION["userinfo"]["id"]."'
-                                                
+
                                         )
                                 ";
-                        
+
                         $this->table->db->query($querystatement);
-                        
+
                         $id = $this->table->db->insertId();
-                        
+
                         if($id)
                                 $this->tempFileID = ((int) $id);
                         else
                                 $this->error .= '<li> inserting temporary file failure </li>';
-                        
+
                 }//end method --_storeTempCSV--
-                
-                
+
+
                 function _getTempCSV($tempFileID){
-                        
+
                         if($tempFileID){
-                                
+
                                 $querystatement = "
                                         SELECT
@@ -164 +164 @@
                                                 id = ".((int)$tempFileID)."
                                         ";
-                                
+
                                 $queryresult = $this->table->db->query($querystatement);
-                                
+
                                 $therecord = $this->table->db->fetchArray($queryresult);
-                                
+
                                 return $therecord["file"];
-                        
+
                         }//end if
-                        
+
                         return false;
-                        
+
                 }//end method --_getTempCSV--
-                
+
                 //DO NOT CALL IN TRANSACTION
                 function _removeTempCSV($tempFileID = 0){
-                        
+
                         $querystatement = "
                                 DELETE FROM
@@ -192 +192 @@
                                         );
                                 ";
-                                
+
                         $queryresult = $this->table->db->query($querystatement);
-                        
+
                         $querystatement = "
                                 ALTER TABLE
@@ -200 +200 @@
                                 AUTO_INCREMENT = ".((int) $tempFileID).";
                                 ";
-                        
+
                         $queryresult = $this->table->db->query($querystatement);
-                        
+
                 }//end method --_removeTempCSV--
-                
+
                 //DO NOT USE THIS METHOD INSIDE AN OPEN TRANSACTION.
                 //IT WILL AUTOMATICALLY COMMIT THE TRANSACTION
                 function _revertAutoIncrement($revertID = 0){
-                        
+
                         //check to see if there is a revert id (i.e. there was a valid insert)
                         if($revertID)
                                 if(is_numeric($revertID)){
-                                        
+
                                         $querystatement = "
                                                 ALTER TABLE
@@ -218 +218 @@
                                                 AUTO_INCREMENT = ".((int) $revertID).";
                                                 ";
-                                        
+
                                         $this->table->db->query($querystatement);
-                                        
+
                                 }//end if
-                        
+
                 }//end method --_revertAutoIncrement--
-                
-                
+
+
                 function importRecords($rows, $titles){
-                        
+
                         switch($this->importType){
-                                
-                                case "csv":                     
+
+                                case "csv":
                                         //count total fieldnames (top row of csv document)
                                         $fieldNum = count($titles);
-                                        
+
                                         //the file starts at line number 1, but since line 1 is
                                         //supposed to be the fieldnames in the table(s), the lines
                                         //being insereted start @ 2.
                                         $rowNum = 2;
-                                        
+
                                         //get the data one row at a time
                                         foreach($rows as $rowData){
-                                                
-                                                $theid = 0;
-                                                
+
+                                                $theid = 0; // set for when verifification does not pass
+                                                $verify = array(); //set for when number of field rows does not match number of titles
+
                                                 //trim off leading/trailing spaces
                                                 $trimmedRowData = array();
+
                                                 foreach($rowData as $name => $data)
                                                         $trimmedRowData[$name] = trim($data);
-                                                
+
                                                 //check to see if number of fieldnames is consistent for each row
                                                 $rowFieldNum = count($trimmedRowData);
-                                                
+
                                                 //if valid, insert, if not, log error and don't insert.
-                                                if($rowFieldNum == $fieldNum)
-                                                        $theid = $this->table->insertRecord($trimmedRowData);
-                                                else
+                                                if($rowFieldNum == $fieldNum){
+                                                        $verify = $this->table->verifyVariables($trimmedRowData);
+                                                        if(!count($verify))
+                                                                $theid = $this->table->insertRecord($trimmedRowData);
+                                                }else
                                                         $this->error .= '<li> incorrect amount of fields for line number '.$rowNum.'.</li>';
-                                                
+
                                                 if($theid){
                                                         //keep track of the ids in the transaction to be able to select them
                                                         //for preview purposes
                                                         $this->transactionIDs[] = $theid;
-                                                        
+
                                                         //get first id to correct auto increment
                                                         if(!$this->revertID)
@@ -268 +272 @@
                                                 }else
                                                         $this->error .= '<li> failed insert for line number '.$rowNum.'.</li>';
-                                                
+
+                                                foreach($verify as $error)
+                                                        $this->error .= '<li class="subError">'.$error.'</li>';
+
                                                 $rowNum++;
-                                                
+
                                         }//end foreach
                                 break;
-                                
+
                         }//end switch
-                        
+
                 }//end method --importRecords--
-                
-                
+
+
                 function displayTransaction($recordsArray, $fieldsArray){
                 //needs to be changed for more complicated tables
@@ -317 +324 @@
                                 <?php
                         }//end if
-                        
+
                 }//end method --displayTransaction--
-                
-                
+
+
                 function processImportPage(){
-                        
+
                         $this->table->getTableInfo();
-                        
+
                         if(!isset($_POST["command"])){
-                                
+
                                 //happens upon first coming to page
-                                
+
                                 //remove any other temporary csv files in the `files` table
                                 //present from previous imports
                                 $this->_removeTempCSV();
-                                
+
                                 //check to see if user has the rights to be here.
                                 //If not, kick him to the no access page.
                                 if(!hasRights($this->table->importroleid))
                                         goURL(APP_PATH."noaccess.php");
-                                
+
                         }else{
                                 //form has been submitted
                                 switch($_POST["command"]){
-                                        
+
                                         //cancel button pressed.
                                         case "cancel":
@@ -354 +361 @@
                                                 }//end if
                                         break;
-                                
+
                                         case "upload":
-                                                
+
                                                 //check for valid file upload
                                                 if(!$_FILES["import"]["error"] && ($_FILES["import"]["size"] > 0)){
-                                                        
+
                                                         //check and parse the file
                                                         if($this->_parseFromData($_FILES["import"]["tmp_name"])){
-                                                                
+
                                                                 //start transaction
                                                                 $this->table->db->startTransaction();
-                                                                
+
                                                                 $this->importRecords($this->parser->data, $this->parser->titles);
-                                                                
+
                                                                 //get data for preview purposes
                                                                 $this->_getTransactionData();
                                                                 //"undo" any inserts
                                                                 $this->table->db->rollbackTransaction();
-                                                                
+
                                                                 //DO NOT CALL IN TRANSACTION
                                                                 //ALTER TABLES AUTO COMMIT AND THE FILE NEEDS TO CARRY
@@ -378 +385 @@
                                                                 $this->_revertAutoIncrement($this->revertID);
                                                                 $this->_storeTempCSV($_FILES["import"]["tmp_name"]);
-                                                                
+
                                                         }//end if
-                                                        
+
                                                 }else
                                                         $this->docError .= "failed file upload";
-                                                
+
                                                 //switch page types
                                                 $this->pageType = "confirm";
-                                                
+
                                                 if(!$this->error && !$this->docError){
                                                         $therecord["phpbmsStatus"] = "Confirm Import";
@@ -394 +401 @@
                                                 }else
                                                         $therecord["phpbmsStatus"] = "Import Error";
-                                                
+
                                         break;
-                                        
+
                                         case "import":
-                                                
+
                                                 //get the contents of the stored csv document
                                                 $CSVcontents = $this->_getTempCSV($this->tempFileID);
-                                                
+
                                                 //parser uses newline character to be able to parse the last line
                                                 if(substr($CSVcontents,-1,1) != "\n")
                                                         $CSVcontents .= "\n";
-                                                
-                                                
+
+
                                                 $this->parser->parse($CSVcontents);
-                                                
+
                                                 $this->importRecords($this->parser->data, $this->parser->titles);
-                                                
+
                                                 $this->table->db->commitTransaction();
-                                                
+
                                                 //DO NOT CALL IN TRANSACTION
-                                                
+
                                                 //get rid of temporary csv document
                                                 $this->_removeTempCSV($this->tempFileID);
-                                                
+
                                                 $therecord["phpbmsStatus"] = "Record(s) Imported";
                                                 //change page type
                                                 $this->pageType = "main";
                                         break;
-                                        
+
                                 }//end command switch
-                                        
+
                         }// end if
-                        
+
                         //display the title
                         $therecord["title"] = $this->table->displayname." Import";
                         return $therecord;
-                        
+
                 }//end method --imports--
-                
+
         }//end class --imports--
-        
-        
+
+
         //this class is to have different buttons, and no created/modified.
         if(class_exists("phpbmsForm")){
                 class importForm extends phpbmsForm{
-                        
+
                         function importForm($action = NULL, $method="post", $name="record", $onsubmit="return validateForm(this);", $dontSubmit = true){
-                                
+
                                 parent::phpbmsForm($action,$method,$name,$onsubmit,$dontSubmit);
-                                
+
                         }//end method --importForm--
-                        
-                        function startForm($pageTitle, $pageType){
-                
-                                ?><form action="<?php echo str_replace("&","&amp;",$this->action) ?>" method="<?php echo $this->method?>" name="<?php echo $this->name?>" onsubmit="<?php echo $this->onsubmit?>" <?php 
+
+                        function startForm($pageTitle, $pageType, $numberOfRecords = 0){
+
+                                ?><form action="<?php echo str_replace("&","&amp;",$this->action) ?>" method="<?php echo $this->method?>" name="<?php echo $this->name?>" onsubmit="<?php echo $this->onsubmit?>" <?php
                                         if(isset($this->enctype)) echo ' enctype="'.$this->enctype.'" ';
                                         if(isset($this->id)) echo ' id="'.$this->id.'" ';
-                                ?>><?php 
+                                ?>><?php
                                 if($this->dontSubmit){
                                         ?><div id="dontSubmit"><input type="submit" value=" " onclick="return false;" /></div><?php
                                 } ?>
-                                <div id="topButtons"><?php $this->showButtons(1, $pageType); ?></div>
-                                <h1 id="h1Title"><span><?php echo $pageTitle ?></span></h1><?php        
-                                
+                                <div id="topButtons"><?php $this->showButtons(1, $pageType, $numberOfRecords); ?></div>
+                                <h1 id="h1Title"><span><?php echo $pageTitle ?></span></h1><?php
+
                         }//end method --startForm--
-                        
-                        function showButtons($ids = 1, $pageType = "main"){
+
+                        function showButtons($ids = 1, $pageType = "main", $numberOfRecords = 0){
                                 ?>
                                 <div class="importCancels">
                                         <?php if($pageType == "main"){ ?>
-                                        <input <?php if($ids==1) {?>accesskey="i"<?php }?> title="Upload (alt+u)" id="uploadButton<?php echo $ids?>" name="command" type="submit" value="upload" class="Buttons" />
+                                        <input <?php if($ids==1) {?>accesskey="u"<?php }?> title="Upload (alt+u)" id="uploadButton<?php echo $ids?>" name="command" type="submit" value="upload" class="Buttons" />
                                         <input id="cancelButton<?php echo $ids?>" name="command" type="submit" value="cancel" class="Buttons" <?php if($ids==1) {?>accesskey="x" <?php }?> title="(access key+x)" />
                                         <?php }else{?>
-                                        <input type="submit" class="Buttons" value="import" name="command" id="import<?php echo $ids?>" title="commit"/>
+                                        <input type="submit" class="Buttons" value="import" name="command" id="import<?php echo $ids?>" title="commit" <?php echo ($numberOfRecords? '':'disabled="disabled"') ?>/>
                                         <input type="submit" class="Buttons" value="cancel" name="command" id="cancelButton<?php echo $ids?>" title="rollback"/>
                                         <?php }//end if ?>
                                 </div><?php
                         }//end method --showButtons--
-                
+
                 }//end class --importForm--
         }