관리-도구

편집 파일: import3.php

<?php
require_once dirname(__FILE__).'/accesscheck.php';
if (!ALLOW_IMPORT) {
  print '<p>'.$GLOBALS['I18N']->get('import is not available').'</p>';
  return;
}

ob_end_flush();
print '<p>'.$GLOBALS['I18N']->get('Import emails from IMAP folders').'</p>';
$email_header_fields = array("to","from","cc","bcc","reply_to","sender","return_path");

if ($require_login && !isSuperUser()) {
  $access = accessLevel("import3");
  if ($access == "owner")
    $subselect = " where owner = ".$_SESSION["logindetails"]["id"];
  elseif ($access == "all")
    $subselect = "";
  elseif ($access == "none")
    $subselect = " where id = 0";
}

$result = Sql_query("SELECT id,name FROM ".$tables["list"]." $subselect ORDER BY listorder");
while ($row = Sql_fetch_array($result)) {
  $available_lists[$row["id"]] = $row["name"];
  $some = 1;
}
if (!$some)
  echo $GLOBALS['I18N']->get('No lists available').", ".PageLink2("editlist",$GLOBALS['I18N']->get('Add a list'));

$nodesdone = array();

function fetchEmailsFromHeader($header,$folder,$fieldlist = array()) {
  $res = array();
#  print "<br/>Processing $header";
  if (!sizeof($fieldlist))
    $fieldlist = $GLOBALS["email_header_fields"];
  $GLOBALS["messagecount"]++;

#  foreach (array("to","from","cc","bcc","reply_to","sender","return_path") as $item) {
  foreach ($fieldlist as $item) {
    if (is_array($header->$item)) {
#      print "<br/><b>Values in $item<br/>";
      foreach ($header->$item as $object) {
#        print "Personal: ".$object->personal."<br/>";
#        print "Adl: ".$object->adl."<br/>";
#        print "Mailbox: ".$object->mailbox."<br/>";
#        print "Host: ".$object->host."<br/>";
        #"$object->personal <".$object->mailbox.'@'.$object->host.">"
        if (!is_array($res[strtolower($object->mailbox.'@'.$object->host)]))
          $res[strtolower($object->mailbox.'@'.$object->host)] = array();
        array_push($res[strtolower($object->mailbox.'@'.$object->host)],
          array(
            'personal' => $object->personal,
            'email' => $object->mailbox.'@'.$object->host,
            'folder' => $folder,
            'date' => $header->udate,
          ));
       }
     }
  }
  return $res;
}

function getImapFolders($server,$user,$password) {
  $port =  "143/imap/notls";
  $mbox = @imap_open("{".$server.":".$port."}",$user,$password,OP_HALFOPEN);
  if (!$mbox) {
    Fatal_Error($GLOBALS['I18N']->get("can't connect").": ".imap_last_error());
    return 0;
   }

$list = imap_getmailboxes($mbox,"{".$server."}","*");
  if(is_array($list)) {
    return $list;
  } else {
    Fatal_Error($GLOBALS['I18N']->get("imap_getmailboxes failed").": ".imap_last_error()."\n");
    return 0;
  }
  imap_close($mbox);
}

function sortbydate ($a, $b) {
  return $a["date"] < $b["date"];
}

if (!$_POST["server"] || !$_POST["user"] || !$_POST["password"] || !is_array($_POST["lists"])) {
  print '
  <p>'.$GLOBALS['I18N']->get('Please enter details of the IMAP account').'</p>
  <form method=post>
  <table>
  <tr><td>'.$GLOBALS['I18N']->get('Server').':</td><td><input type=text name="server" value="" size=30></td></tr>
  <tr><td>'.$GLOBALS['I18N']->get('User').':</td><td><input type=text name="user" value="" size=30></td></tr>
  <tr><td>'.$GLOBALS['I18N']->get('Password').':</td><td><input type=password name="password" value="" size=30></td></tr>
  <tr><td colspan=2>'.$GLOBALS['I18N']->get('Select the headers fields to search').':</td></tr>
  ';
  foreach ($email_header_fields as $header_field) {
    printf('
    <tr><td>%s</td><td><input type="checkbox" name="selected_header_fields[]" value="%s"',$header_field,$header_field);
  }
  $c = 0;
  print '<tr><td>';
  if (sizeof($available_lists) > 1)
    print $GLOBALS['I18N']->get('Select the lists to add the emails to').'<br/>';
  print '<ul>';
  foreach ($available_lists as $index => $name) {
    if (sizeof($available_lists) == 1) {
      printf('<input type=hidden name="lists[0]" value="%d">
        <li>'.$GLOBALS['I18N']->get("Adding users to list").'. <b>%s</b>',$index,$name);
    } else {
      printf('<li><input type=checkbox name="lists[%d]" value="%d">%s',
        $c,$index,$name);
      $c++;
    }
  }

print '
  </ul></td></tr>
<tr><td>'.$GLOBALS['I18N']->get('Mark new users as HTML').':</td><td><input type="checkbox" name="markhtml" value="yes"></td></tr>
<tr><td colspan=2>'.$GLOBALS['I18N']->get('If you check')." '".$GLOBALS['I18N']->get('Overwrite Existing')."', ".$GLOBALS['I18N']->get("information about a user in the database will be replaced by the imported information. Users are matched by email.").'</td></tr>
<tr><td>'.$GLOBALS['I18N']->get('Overwrite Existing').':</td><td><input type="checkbox" name="overwrite" value="yes"></td></tr>
<tr><td colspan=2>'.$GLOBALS['I18N']->get('If you check')." '".$GLOBALS['I18N']->get('Only use complete addresses')."' ".$GLOBALS['I18N']->get("addresses that do not have a real name will be ignored. Otherwise all emails will be imported.").'</td></tr>
<tr><td>'.$GLOBALS['I18N']->get("Only use complete addresses").':</td><td><input type="checkbox" name="onlyfull" value="yes"></td></tr>
<tr><td colspan=2>'.$GLOBALS['I18N']->get('If you choose')." '".$GLOBALS['I18N']->get('send notification email')."' ".$GLOBALS['I18N']->get("the users you are adding will be sent the request for confirmation of subscription to which they will have to reply. This is recommended, because it will identify invalid emails.").'</td></tr>
<tr><td>'.$GLOBALS['I18N']->get("Send&nbsp;Notification&nbsp;email&nbsp;").'<input type="radio" name="notify" value="yes"></td><td>'.$GLOBALS['I18N']->get("Make confirmed immediately").'&nbsp;<input type="radio" name="notify" value="no"></td></tr>
<tr><td colspan=2>'.$GLOBALS['I18N']->get('import3info').'
</td></tr>
<tr><td>'.$GLOBALS['I18N']->get("Use one attribute for name").'<input type="radio" name="nameattributes" value="one"></td><td>'.$GLOBALS['I18N']->get('Use two attributes for the name').'&nbsp;<input type="radio" name="nameattributes" value="two"></td></tr>
<tr><td>'.$GLOBALS['I18N']->get('Attribute one').': </td><td><select name="attributeone">
<option value="create">'.$GLOBALS['I18N']->get('Create Attribute').'</option>
';
  $req = Sql_Query("select * from {$tables["attribute"]} where type=\"textline\"");
  while ($att = Sql_Fetch_array($req)) {
    printf('<option value="%d">%s</option>',$att["id"],$att["name"]);
  }
  print '</select></td></tr>
  <tr><td>'.$GLOBALS['I18N']->get('Attribute two').': </td><td><select name="attributetwo">
  <option value="create">'.$GLOBALS['I18N']->get('Create Attribute').'</option>';
  $req = Sql_Query("select * from {$tables["attribute"]} where type=\"textline\"");
  while ($att = Sql_Fetch_array($req)) {
    printf('<option value="%d">%s</option>',$att["id"],$att["name"]);
  }
  print '</select></td></tr>
  <tr><td colspan=2><input type=submit value="'.$GLOBALS['I18N']->get('Continue').'"></td></tr>
  </table></form>
  ';
} elseif (!is_array($_POST["checkfolder"])) {
  $folders = getImapFolders($server,$user,$password);
  if (!$folders) {
    Error($GLOBALS['I18N']->get('Cannot continue'));
    return;
  }

printf( '
  <form method=post name="folderlist">
  <input type=hidden name="parsefolders" value="1">
  ',$_POST["server"],$_POST["user"],$_POST["password"]);
  if (is_array($_POST["selected_header_fields"])) {
    foreach ($_POST["selected_header_fields"] as $field) {
      printf('<input type=hidden name="selected_header_fields[]" value="%s">',$field);
     }
  }
  if (is_array($_POST["lists"])) {
    foreach ($_POST["lists"] as $key => $val) {
      printf('<input type=hidden name="lists[%d]" value="%s">',$key,$val);
     }
  }
  foreach (array("server","user","password","markhtml",
    "overwrite","onlyfull","notify",
    "nameattributes","attributeone","attributetwo") as $item) {
    printf('<input type="hidden" name="%s" value="%s">',$item,$_POST[$item]);
  }

$done = 0;
  $level = 0;
  $foldersdone = array();
  $tree = array();
  while (sizeof($folderdone) < sizeof($folders) && $level < 10) {
    reset($folders);
    asort($folders);
    while (list($key, $val) = each($folders))  {
      $delim = $val->delimiter;
      $name = str_replace("{".$server."}INBOX","",imap_utf7_decode($val->name));
      $parent = mailBoxParent($name,$delim,$level);
      $folder = mailBoxName($name,$delim,$level);
      if ($folder) {
        if (!is_array($tree[$parent])) {
          $tree[$parent] = array(
            "node" => $parent,
            "children" => array()
          );
         }
        if (!in_array($folder,$tree[$parent]["children"]))
          array_push($tree[$parent]["children"],$folder);
     #   print $parent . " ".$folder."<br/>";
        flush();
      } else {
        array_push($foldersdone,$name);
      }
     }
    $level++;
  }
  ksort($tree);
  print '<ul>'.printTree($tree,"INBOX",".").'</ul>';
  print '<input type=submit value="'.$GLOBALS['I18N']->get('Process Selected Folders').'"></form>';
} else {
  $all_emails = array();
  while (list($key,$folder) = each($_POST["checkfolder"])) {
    print '<br/>';
    flush();

$emails = processImapFolder($_POST["server"],$_POST["user"],$_POST["password"]
      ,$folder,$_POST["selected_header_fields"]);
    if (is_array($emails)) {
      foreach ($emails as $email => $list) {
        if (!is_array($all_emails[$email]))
          $all_emails[$email] = array();
  #      $emaillist = array_merge($emaillist,$emails);
        foreach ($list as $key => $rec)
          array_push($all_emails[$email],$rec);
      }
      print "... ".$GLOBALS['I18N']->get('ok');
    } else {
      print "... ".$GLOBALS['I18N']->get('failed');
    }
    flush();
   }
  if (is_array($all_emails)) {
    $num = sizeof($all_emails);
    print "<p>".$GLOBALS['I18N']->get('Processed').":".$GLOBALS["foldercount"]. " ".$GLOBALS['I18N']->get('folders and')." ".$GLOBALS["messagecount"]." ".$GLOBALS['I18N']->get('messages')."</p>";
    print "<h1>".sizeof($all_emails)." ".$GLOBALS['I18N']->get('unique emails found')."</h1>";
    flush();

$usetwo = 0;
    # prepare the attributes
    if ($_POST["nameattributes"] == "two") {
      $usetwo = 1;
      if ($_POST["attributeone"] == "create") {
        $req = Sql_Query(sprintf('insert into %s (name,type)
          values("First Name","textline")',$tables["attribute"]));
         $firstname_att_id = Sql_Insert_id();
       } else {
        $firstname_att_id = $_POST["attributeone"];
      }
      if ($_POST["attributetwo"] == "create") {
        $req = Sql_Query(sprintf('insert into %s (name,type)
          values("Last Name","textline")',$tables["attribute"]));
         $lastname_att_id = Sql_Insert_id();
       } else {
        $lastname_att_id = $_POST["attributetwo"];
      }
    } else {
      if ($_POST["attributeone"] == "create") {
        $req = Sql_Query(sprintf('insert into %s (name,type)
          values("Name","textline")',$tables["attribute"]));
         $name_att_id = Sql_Insert_id();
       } else {
        $name_att_id = $_POST["attributeone"];
      }
    }

$x = 0;
    $count_email_add = 0;
    $count_exist = 0;
    $count_list_add = 0;

foreach ($all_emails as $key => $versions) {
      set_time_limit(60);
       $importuser = getBestVersion($versions);
 #     print $importuser["personal"]." &lt;".$importuser["email"]."&gt;<br/>";
      printf('<input type=hidden name="importemail[%s] value="%s">',
      $importuser["email"],$importuser["personal"]);

# split personal in first and last name
      list($importuser["firstname"],$importuser["lastname"]) = explode(" ",$importuser["personal"],2);

$x++;
      if ($x % 25 == 0) {
        print $x . "/$num ".$GLOBALS['I18N']->get('done')."<br/>";
        flush();
       }

# check for full email
      if ($_POST["onlyfull"] != "yes" ||
        ($_POST["onlyfull"] == "yes" && !ereg("@",$importuser["personal"])) &&
        strlen($importuser["email"]) > 4
        ) {

$new = 0;
        $result = Sql_query(sprintf('SELECT id,uniqid FROM %s
          WHERE email = "%s"',$tables["user"],$importuser["email"]));
        if (Sql_affected_rows()) {
          // Email exist, remember some values to add them to the lists
          $count_exist++;
          $user = Sql_fetch_array($result);
          $userid = $user["id"];
          $uniqid = $user["uniqid"];
          Sql_Query(sprintf('update %s set htmlemail = %d where id = %d',$tables["user"],$_POST["markhtml"]?"1":"0",$userid));
        } else {
          // Email does not exist
          $new = 1;

// Create unique number
          mt_srand((double)microtime()*1000000);
          $randval = mt_rand();
          $uniqid = getUniqid();

$query = sprintf('INSERT INTO %s (email,entered,confirmed,uniqid,htmlemail)
             values("%s",now(),%d,"%s",%d)',
             $tables["user"],$importuser["email"],$_POST["notify"] != "yes",$uniqid,$_POST["markhtml"]?"1":"0");
          $result = Sql_query($query);
          $userid = Sql_insert_id();

$count_email_add++;
          $some = 1;
        }

if ($_POST["overwrite"] == "yes") {
          if ($usetwo) {
            Sql_query(sprintf('replace into %s (attributeid,userid,value) values(%d,%d,"%s")',
              $tables["user_attribute"],$firstname_att_id,$userid,$importuser["firstname"]));
            Sql_query(sprintf('replace into %s (attributeid,userid,value) values(%d,%d,"%s")',
              $tables["user_attribute"],$lastname_att_id,$userid,$importuser["lastname"]));
          } else {
            Sql_query(sprintf('replace into %s (attributeid,userid,value) values(%d,%d,"%s")',
              $tables["user_attribute"],$name_att_id,$userid,$importuser["personal"]));
          }
        }
        #add this user to the lists identified
        reset($lists);
        $addition = 0;
        $listoflists = "";
        while (list($key,$listid) = each($lists)) {
          $query = "replace INTO ".$tables["listuser"]." (userid,listid,entered) values($userid,$listid,now())";
          $result = Sql_query($query);
          # if the affected rows is 2, the user was already subscribed
          $addition = $addition || Sql_Affected_Rows() == 1;
          $listoflists .= "  * ".$available_lists[$listid]."\n";
        }
        if ($addition)
          $additional_emails++;
        if (!TEST && $_POST["notify"] == "yes" && $addition) {
          $subscribemessage = ereg_replace('\[LISTS\]', $listoflists, getUserConfig("subscribemessage",$userid));
          sendMail($email, getConfig("subscribesubject"), $subscribemessage,system_messageheaders(),$envelope);
        }
      }; // end if
    }; // end foreach

$num_lists = sizeof($lists);

# be grammatically correct :-)
    $displists = ($num_lists == 1) ? $GLOBALS['I18N']->get('list'): $GLOBALS['I18N']->get('lists');
    $dispemail = ($count_email_add == 1) ? $GLOBALS['I18N']->get('new email was')." ": $GLOBALS['I18N']->get('new emails were')." ";
    $dispemail2 = ($additional_emails == 1) ? $GLOBALS['I18N']->get('email was')." ":$GLOBALS['I18N']->get('emails were')." ";

if(!$some && !$additional_emails) {
      print "<br>".$GLOBALS['I18N']->get("All the emails already exist in the database and are members of the")." $displists.";
    } else {
      print "$count_email_add $dispemail ".$GLOBALS['I18N']->get("succesfully imported to the database and added to")." $num_lists $displists.<br>$additional_emails $dispemail2 ".$GLOBALS['I18N']->get("subscribed to the")." $displists";
      if ($count_exist)
        print "<br/>$count_exist ".$GLOBALS['I18N']->get("emails already existed in the database");
      if ($invalid_email_count) {
        print "<br>$invalid_email_count ".$GLOBALS['I18N']->get("Invalid Emails found.");
        if (!$omit_invalid)
        print " ".$GLOBALS['I18N']->get("These records were added, but the email has been made up. You can find them by doing a search on")." \"Invalid Email\"";
        else
          print " ".$GLOBALS['I18N']->get("These records were deleted. Check your source and reimport the data. Duplicates will be identified.");
      }
    }
  } else {
    print $GLOBALS['I18N']->get("No emails found");
  }
  print '<p>'.PageLink2("import",$GLOBALS['I18N']->get('Import some more emails'));
}