Changeset 730 for trunk/phpbms/modules/mailchimp/include/list_sync.php

Timestamp:

01/07/10 18:13:51 (2 years ago)

Author:

brieb

Message:

• more sucrity tightening with roles.

Files:

• trunk/phpbms/modules/mailchimp/include/list_sync.php (modified) (34 diffs)

trunk/phpbms/modules/mailchimp/include/list_sync.php

@@ -1 +1 @@
 <?php
+/*
+ $Rev: 267 $ | $LastChangedBy: brieb $
+ $LastChangedDate: 2007-08-14 13:08:27 -0600 (Tue, 14 Aug 2007) $
+ +-------------------------------------------------------------------------+
+ | Copyright (c) 2004 - 2010, Kreotek LLC                                  |
+ | All rights reserved.                                                    |
+ +-------------------------------------------------------------------------+
+ |                                                                         |
+ | Redistribution and use in source and binary forms, with or without      |
+ | modification, are permitted provided that the following conditions are  |
+ | met:                                                                    |
+ |                                                                         |
+ | - Redistributions of source code must retain the above copyright        |
+ |   notice, this list of conditions and the following disclaimer.         |
+ |                                                                         |
+ | - Redistributions in binary form must reproduce the above copyright     |
+ |   notice, this list of conditions and the following disclaimer in the   |
+ |   documentation and/or other materials provided with the distribution.  |
+ |                                                                         |
+ | - Neither the name of Kreotek LLC nor the names of its contributore may |
+ |   be used to endorse or promote products derived from this software     |
+ |   without specific prior written permission.                            |
+ |                                                                         |
+ | THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS     |
+ | "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT       |
+ | LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A |
+ | PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT      |
+ | OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,   |
+ | SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT        |
+ | LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,   |
+ | DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY   |
+ | THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT     |
+ | (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE   |
+ | OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.    |
+ |                                                                         |
+ +-------------------------------------------------------------------------+
+*/
 class listSync{
-    
+
     /**
       *  $lastSyncDate
@@ -18 +55 @@
       */
     var $listId;
-    
+
     /**
       *  $api
@@ -41 +78 @@
       */
     var $stopScript = false;
-    
-    
+
+
     /**
       *  function listSync
@@ -54 +91 @@
       *  @param bool $secure Whether to send info over ssl
       */
-    
+
     function listSync($db, $apiKey, $listId, $lastSyncDate = NULL, $batchlimit = NULL, $secure = false){
-        
+
         $this->db = $db;
         $this->listId = $listId;
-        
+
         /**
           *   Check for a valid datetime format?
@@ -65 +102 @@
         if($lastSyncDate)
             $this->lastSyncDate = $lastSyncDate;
-            
+
         if((int)$batchlimit > 0)
            $this->batchlimit = (int)$batchlimit;
-        
+
         $this->api = new MCAPI($apiKey, NULL, $secure);
         $this->api->ping();
@@ -75 +112 @@
             return false;
         }//end if
-        
+
         /**
           *   check to see if there is a uuid field
@@ -85 +122 @@
             return false;
         }//end if
-            
+
         foreach($mergeVars as $mergeVar){
-            
+
             if($mergeVar["tag"] == "UUID"){
                 $hasUuid = true;
                 break;
             }//end if
-            
+
         }//end foreach
-        
+
         if(!$hasUuid){
             $this->_addError("The list does not have a merge variable with tag of 'UUID'.", NULL, true);
             return false;
         }
-        
+
     }//end function
-    
+
     /**
       *   function _addError
       *
       *   Add an error to the class' error array.
-      *   
+      *
       *   @param string $message Text of error message
       *   @param int $errorCode Error number
@@ -112 +149 @@
       *   function needs to be stopped.
       */
-    
+
     function _addError($message, $errorCode = NULL, $fatal = false){
-        
+
         $tempArray["message"] = $message;
         $tempArray["code"] = $errorCode;
-        
+
         if($fatal){
             $this->stopScript = true;
@@ -124 +161 @@
             $tempArray["errorType"] = "warning";
         }//end if
-        
+
         $this->errors[] = $tempArray;
-        
+
     }//end function
-    
-    
+
+
     /**
       *   function _reportResult
@@ -140 +177 @@
       *   code pairs.
       */
-    
+
     function _reportResult(){
-        
+
         $return = array();
-        
+
         if(count($this->errors)){
-            
+
             if($this->stopScript)
                 $return["type"] = "error";
             else
                 $return["type"] = "warning";
-            
+
             $return["details"] = $this->errors;
-            
+
         }else{
-            
+
             $return["type"] = "success";
             $return["details"] = array();
-            
-        }//end if
-            
+
+        }//end if
+
         return $return;
-        
+
     }//end foreach
-    
-    
+
+
     /**
       *  function pullChanges
@@ -173 +210 @@
       *  address.
       */
-    
+
     function pullChanges(){
-        
-        /**
-          *  pull all the unsubscribed 
+
+        /**
+          *  pull all the unsubscribed
           */
         $unsubscribed = array();
         $start = 0;
         do{
-            
+
             $members = $this->api->listMembers($this->listId, 'unsubscribed', $this->lastSyncDate, $start, $this->batchLimit);
             if($this->api->errorCode){
@@ -188 +225 @@
                 return false;
             }//end if
-            
+
             foreach($members as $member){
-                
+
                 $info = $this->api->listMemberInfo($this->listId, $member["email"]);
                 if($this->api->errorCode){
@@ -196 +233 @@
                     return false;
                 }//end if
-                    
+
                 $unsubscribed[] = $info["merges"]["UUID"];
-                
+
             }//end foreach
-            
+
             $start++;
         }while(count($members) == $this->batchLimit);
-        
-        /**
-          *  pull all the cleaned 
+
+        /**
+          *  pull all the cleaned
           */
         $start = 0;
         do{
-            
+
             $members = $this->api->listMembers($this->listId, 'cleaned', $this->lastSyncDate, $start, $this->batchLimit);
             if($this->api->errorCode){
@@ -215 +252 @@
                 return false;
             }//end ifd
-            
+
             foreach($members as $member){
-                
+
                 $info = $this->api->listMemberInfo($this->listId, $member["email"]);
                 if($this->api->errorCode){
@@ -224 +261 @@
                 }//end if
                 $unsubscribed[] = $info["merges"]["UUID"];
-                
+
             }//end foreach
-            
+
             $start++;
         }while(count($members) == $this->batchLimit);
-        
-        
+
+
         /**
           *  If there are records to unsubscribe, set their `canemail` to '0'
           */
         if(count($unsubscribed)){
-            
+
             /**
-              *  construct the in statement 
+              *  construct the in statement
               */
             $inValues = "";
             foreach($unsubscribed as $uuid)
                 $inValues .= ",'".$uuid."'";
-                
+
             $inValues = substr($inValues, 1);
-            
+
             /**
               *  set the cleaned/unsubscribed to canemail = 0
@@ -256 +293 @@
                     `uuid` IN (".$inValues.")
             ";
-            
+
             $queryresult = $this->db->query($querystatement);
-            
-        }//end if
-        
+
+        }//end if
+
     }//end function
-    
+
     /**
       *   function unsubscribeInvalid
-      *   
+      *
       *   Unsubscribe the emails that are related to
       *   client records those that don't have an email (or don't exist),
       *   or that can't be emailed anymore.
       */
-    
+
     function unsubscribeInvalid(){
-        
+
         /**
           *   Get rid of the temorary table.
@@ -281 +318 @@
         ";
         $this->db->query($dropTableStatement);
-        
-        /**
-          *  Create a temporary table 
+
+        /**
+          *  Create a temporary table
           */
         $createTableStatement = "
@@ -291 +328 @@
                 `email` varchar(128) default NULL
             ) ENGINE=INNODB";
-        
+
         $this->db->query($createTableStatement);
-        
-        /**
-          *  pull all the subscribed 
+
+        /**
+          *  pull all the subscribed
           */
         $start = 0;
-        do{    
+        do{
             $valuesClause = "";
-                        
+
             $members = $this->api->listMembers($this->listId, 'subscribed', NULL, $start, $this->batchLimit);
 
@@ -307 +344 @@
                 return false;
             }//end if
-            
+
             foreach($members as $member)
                 $valuesClause .= ",('".$member["email"]."')";
-            
+
             $valuesClause = substr($valuesClause, 1);
-            
-            
+
+
             /**
-              *  Put the subscribed into a temporary table 
+              *  Put the subscribed into a temporary table
               */
             if($valuesClause){
@@ -324 +361 @@
                         VALUES
                     ".$valuesClause;
-                
+
                 $this->db->query($insertStatement);
             }//end if
-            
+
             $start++;
         }while(count($members) == $this->batchLimit);
 
-        
+
         /**
           *  Get all the emails of client records that are subscribed
@@ -346 +383 @@
                 `clients`.`email` IS NULL
         ";
-        
+
         $selectresult = $this->db->query($selectStatement);
-        
+
         /**
           *   Unsubscribe them from the mailchimp list
@@ -355 +392 @@
         while($therecord = $this->db->fetchArray($selectresult))
             $unsubscribeList[] = $therecord["email"];
-        
-        /**
-          *  If there are records to unsubscribe (deleted), do so. 
+
+        /**
+          *  If there are records to unsubscribe (deleted), do so.
           */
         if(count($unsubscribeList)){
-            
+
             $return = $this->api->listBatchUnsubscribe($this->listId, $unsubscribeList, true, false);
             if ($this->api->errorCode){
@@ -368 +405 @@
                 foreach($return['errors'] as $val)
                     $this->_addError("Unsubscribing email ".$val["email"]." failed: ".$val["message"], $val["code"]);
-                    
-        }//end if
-            
+
+        }//end if
+
         /**
           *   Get rid of the temorary table.
@@ -379 +416 @@
         ";
         $this->db->query($dropTableStatement);
-        
+
     }//end function
-    
-    
+
+
     /**
       *  function pushChanges
@@ -390 +427 @@
       */
     function pushChanges(){
-        
+
         /**
           *   Get the changed records / fields
@@ -411 +448 @@
                 `canemail` != '0'
         ";
-        
+
         /**
           *  If there is a last sync *date*, limit the records by their modified
@@ -418 +455 @@
         if($this->lastSyncDate)
             $querystatement .= " AND `modifieddate` > '".$this->lastSyncDate."'";
-            
-        
+
+
         $queryresult = $this->db->query($querystatement);
-        
+
         /**
           *   Format the variables to be interpreted by Mailchimp.
@@ -427 +464 @@
         $batchVars = array();
         while($therecord = $this->db->fetchArray($queryresult)){
-            
+
             $tempArray["EMAIL"] = $therecord["email"];
             $tempArray["FNAME"] = $therecord["firstname"];
@@ -434 +471 @@
             $tempArray["TYPE"] = $therecord["type"];
             $tempArray["UUID"] = $therecord["uuid"];
-            
+
             $batchVars[] = $tempArray;
         }//end while
-        
-        /**
-          *  Update / Insert the changes 
+
+        /**
+          *  Update / Insert the changes
           */
         if(count($batchVars)){
-            
+
             $return = $this->api->listBatchSubscribe($this->listId, $batchVars, false, true);
             if($this->api->errorCode){
@@ -448 +485 @@
                 return false;
             }else{
-                
+
                 $instatement = "";
-                
+
                 foreach($return['errors'] as $val){
-                    
+
                     $this->_addError("Subscribing or updating uuid '".$val["row"]["UUID"]."' failed: ".$val["message"], $val["code"]);
-                    
+
                     $memberInfo = $this->api->listMemberInfo($this->listId, $val["row"]["EMAIL"]);
-                    
+
                     if($memberInfo["status"] != "subcribed")
                         $instatement .= ", '".$val["row"]["UUID"]."'";
-                    
+
                 }//end foreach
-                
+
                 if($instatement){
-                    
+
                     $instatement = substr($instatement, 2);
                     $instatement = "(".$instatement.")";
-                    
+
                     $updatestatement = "
                         UPDATE
@@ -475 +512 @@
                         WHERE
                             `uuid` IN ".$instatement;
-                    
+
                     $this->db->query($updatestatement);
-                    
+
                 }//end if
-                
+
             }//end if
-                    
-        }//end if
-        
+
+        }//end if
+
     }//end function
-    
-    
+
+
     /*
      * function resetSyncDate
@@ -492 +529 @@
      * Set the last sync date in the settings table to be NOW()
      */
-    
+
     function resetSyncDate() {
-        
+
         $querystatement = "
             UPDATE
@@ -503 +540 @@
                 `name` = 'mailchimp_last_sync_date'
         ";
-        
+
         $queryresult = $this->db->query($querystatement);
-        
+
     }//end if
-    
-    
+
+
     /**
       *  function process
-      *  
+      *
       *  Perform the list sync
       */
     function process(){
-        
+
         if(!$this->stopScript)
             $this->pullChanges();
@@ -524 +561 @@
         if(!$this->stopScript)
             $this->resetSyncDate();
-        
+
         return $this->_reportResult();
-        
+
     }//end function
-    
+
 }//end class
 ?>