'.$GLOBALS['I18N']->get('import is not available').'

'; return; } # import from a different PHPlist installation if ($require_login && !isSuperUser()) { $access = accessLevel("import4"); if ($access == "owner") $subselect = " where owner = ".$_SESSION["logindetails"]["id"]; elseif ($access == "all") $subselect = ""; elseif ($access == "none") $subselect = " where id = 0"; } function connectLocal() { $database_connection = Sql_Connect( $GLOBALS["database_host"], $GLOBALS["database_user"], $GLOBALS["database_password"], $GLOBALS["database_name"]); return $database_connection; } function connectRemote() { return Sql_Connect($_POST["remote_host"], $_POST["remote_user"], $_POST["remote_password"], $_POST["remote_database"]); } $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) # @@@@ not sure about this one: echo $GLOBALS['I18N']->get('No lists available').', '.PageLink2("editlist",$GLOBALS['I18N']->get('add_list')); #foreach ($_POST as $key => $val) { # print "$key => $val
"; #} if (!$_POST["remote_host"] || !$_POST["remote_user"] || !$_POST["remote_password"] || !$_POST["remote_database"]) { printf( '

'.$GLOBALS['I18N']->get('remote_server').'

',$_POST["remote_server"],$_POST["remote_user"],$_POST["remote_password"], $_POST["remote_database"],$_POST["remote_prefix"],$_POST["remote_userprefix"]); $c = 0; print '

'.$GLOBALS['I18N']->get('server').'
'.$GLOBALS['I18N']->get('user').'
'.$GLOBALS['I18N']->get('passwd').'
'.$GLOBALS['I18N']->get('database').'
'.$GLOBALS['I18N']->get('table_prefix').'
'.$GLOBALS['I18N']->get('usertable_prefix').'
'; if (sizeof($available_lists) > 1) print $GLOBALS['I18N']->get('select_lists').' '; print ' '; foreach ($available_lists as $index => $name) { printf(' %s ', $c,$index,is_array($_POST["lists"]) && in_array($index,array_values($_POST["lists"]))?"checked":"",$name); $c++; } printf(' '.$GLOBALS['I18N']->get('copy_lists').'
'.$GLOBALS['I18N']->get('users_as_html').'
'.$GLOBALS['I18N']->get('info_overwrite_existing').'
'.$GLOBALS['I18N']->get('overwrite_existing').'

',$_POST["copyremotelists"] == "yes"?"checked":"",$_POST["markhtml"] == "yes"?"checked":"",$_POST["overwrite"] == "yes"?"checked":"" ); } else { set_time_limit(600); ob_end_flush(); include_once("structure.php"); print $GLOBALS['I18N']->get('connecting_remote')."
"; flush(); $remote = connectRemote(); if (!$remote) { Fatal_Error($GLOBALS['I18N']->get('cant_connect')); return; } $remote_tables = array( "user" => $_POST["remote_userprefix"] . "user", "list" => $_POST["remote_prefix"] . "list", "listuser" => $_POST["remote_prefix"] . "listuser", "attribute" => $_POST["remote_userprefix"] . "attribute", "user_attribute" => $_POST["remote_userprefix"] . "user_attribute", "config" => $_POST["remote_prefix"] . "config", ); print $GLOBALS['I18N']->get('getting_data').$_POST["remote_database"]."@".$_POST["remote_host"]."
"; $version = Sql_Fetch_Row_Query("select value from {$remote_tables["config"]} where item = \"version\""); print $GLOBALS['I18N']->get('remote_version')." $version[0]
\n"; $usercnt = Sql_Fetch_Row_Query("select count(*) from {$remote_tables["user"]}"); print $GLOBALS['I18N']->get('remote_has')." $usercnt[0] ".$GLOBALS['I18N']->get('users')."
"; if (!$usercnt[0]) { Fatal_Error($GLOBALS['I18N']->get('no_users_to_copy')); return; } $totalusers = $usercnt[0]; $listcnt = Sql_Fetch_Row_Query("select count(*) from {$remote_tables["list"]}"); print $GLOBALS['I18N']->get('remote_has')." $listcnt[0] ".$GLOBALS['I18N']->get('lists')."
"; flush(); print '

'.$GLOBALS['I18N']->get('copying_lists').'

'; # first copy the lists across $listmap = array(); $remote_lists = array(); $lists_req = Sql_Query("select * from {$remote_tables["list"]}"); while ($row = Sql_Fetch_Array($lists_req)) { array_push($remote_lists,$row); } connectLocal(); foreach ($remote_lists as $list) { $localid_req = Sql_Fetch_Row_Query(sprintf('select id from %s where name = "%s"', $tables["list"],$list["name"])); if ($localid_req[0]) { $listmap[$list["id"]] = $localid_req[0]; print $GLOBALS['I18N']->get('list').' '.$list["name"] .$GLOBALS['I18N']->get('exists_locally')."
\n"; } elseif ($_POST["copyremotelists"]) { $query = ""; foreach ($DBstruct["list"] as $colname => $colspec) { if ($colname != "id" && $colname != "index" && $colname != "unique" && $colname != "primary key") { $query .= sprintf('%s = "%s",',$colname,addslashes($list[$colname])); } } $query = substr($query,0,-1); print $GLOBALS['I18N']->get('list')." ".$list["name"] .$GLOBALS['I18N']->get('created_locally')."
\n"; Sql_Query("insert into {$tables["list"]} set $query"); $listmap[$list["id"]] = Sql_Insert_id(); } else { print $GLOBALS['I18N']->get('remote_list')." ".$list["name"] .$GLOBALS['I18N']->get('not_created')."
\n"; } } connectRemote(); print '

'.$GLOBALS['I18N']->get('copying_attribs').'

'; # now copy the attributes $attributemap = array(); $remote_atts = array(); $att_req = Sql_Query("select * from {$remote_tables["attribute"]}"); while ($row = Sql_Fetch_Array($att_req)) { array_push($remote_atts,$row); } connectLocal(); foreach ($remote_atts as $att) { $localid_req = Sql_Fetch_Row_Query(sprintf('select id from %s where name = "%s"', $tables["attribute"],stripslashes($att["name"]))); if ($localid_req[0]) { $attributemap[$att["id"]] = $localid_req[0]; print $GLOBALS['I18N']->get('attrib')." ".$att["name"] .$GLOBALS['I18N']->get('exists_locally')."
\n"; } else { $query = ""; foreach ($DBstruct["attribute"] as $colname => $colspec) { if ($colname != "id" && $colname != "index" && $colname != "unique" && $colname != "primary key") { $query .= sprintf('%s = "%s",',$colname,addslashes($att[$colname])); } } $query = substr($query,0,-1);# print $GLOBALS['I18N']->get('attrib')." ".$att["name"].$GLOBALS['I18N']->get('created_locally')."
\n"; Sql_Query("insert into {$tables["attribute"]} set $query"); $attributemap[$att["id"]] = Sql_Insert_id(); if ($att["type"] == "select" || $att["type"] == "radio" || $att["type"] == "checkboxgroup") { $query = "create table if not exists $table_prefix"."listattr_".$att["tablename"]." (id integer not null primary key auto_increment, name varchar(255) unique,listorder integer default 0)"; Sql_Query($query,0); connectRemote(); $attvalue_req = Sql_Query("select id,name,listorder from ".$_POST["remote_prefix"]."listattr_".$att["tablename"]); $values = array(); while ($value = Sql_Fetch_Array($attvalue_req)) { array_push($values,$value); } connectLocal(); foreach ($values as $value) { Sql_Query(sprintf('replace into %slistattr_%s (name,id,listorder) values("%s",%d,"%s")',$table_prefix,$att["tablename"],addslashes($value["name"]),$value["id"],$value["listorder"])); } } } } print '

'.$GLOBALS['I18N']->get('copying_users').'

'; # copy the users $usercnt = 0; $existcnt = 0; $newcnt = 0; while ($usercnt < $totalusers) { set_time_limit(60); connectRemote(); $req = Sql_Query("select * from {$remote_tables["user"]} limit $usercnt,1"); $user = Sql_Fetch_Array($req); $usercnt++; $new = 0; if ($usercnt % 20 == 0) { print "$usercnt / $totalusers
"; flush(); } connectLocal(); $query = ""; $exists = Sql_Fetch_Row_Query(sprintf('select id from %s where email = "%s"',$tables["user"],$user["email"])); if ($exists[0]) { $existcnt++; # print $user["email"] .$GLOBALS['I18N']->get('exists_locally')." .."; if ($_POST["overwrite"]) { # print " .. ".$GLOBALS['I18N']->get('overwrite_local')."
"; $query = "replace into ".$tables["user"] . " set id = ".$exists[0].", "; } else { # print " .. ".$GLOBALS['I18N']->get('keep_local')."
"; } $userid = $exists[0]; } else { $newcnt++; $new = 1; # print $user["email"] .$GLOBALS['I18N']->get('new_user')."
"; $query = "insert into ".$tables["user"]. " set "; } if ($query) { foreach ($DBstruct["user"] as $colname => $colspec) { if ($colname != "id" && $colname != "index" && $colname != "unique" && $colname != "primary key") { $query .= sprintf('%s = "%s",',$colname,addslashes($user[$colname])); } } $query = substr($query,0,-1); #print $query . "
"; Sql_Query("$query"); $userid = Sql_Insert_id(); } if ($userid && $_POST["markhtml"]) { Sql_Query("update {$tables["user"]} set htmlemail = 1 where id = $userid"); } if ($new || (!$new && $_POST["overwrite"])) { # now check for attributes and list membership connectRemote(); $useratt = array(); $req = Sql_Query("select * from {$remote_tables["user_attribute"]}, {$remote_tables["attribute"]} where {$remote_tables["user_attribute"]}.attributeid = {$remote_tables["attribute"]}.id and {$remote_tables["user_attribute"]}.userid = $user[0]"); while ($att = Sql_Fetch_Array($req)) { $value = ""; switch ($att["type"]) { case "select": case "radio": $valreq = Sql_Fetch_Row_Query(sprintf('select name from %slistattr_%s where id = %d', $_POST["remote_prefix"],$att["tablename"],$att["value"])); $value = $valreq[0]; break; case "checkboxgroup": $valreq = Sql_Query(sprintf('select name from %slistattr_%s where id in (%s)', $_POST["remote_prefix"],$att["tablename"],$att["value"])); while ($vals = Sql_fetch_Row($valreq)) { $value .= $vals[0].','; } break; } $att["displayvalue"] = $value; array_push($useratt,$att); } $userlists = array(); $userlists = array_merge($_POST["lists"],$userlists); if ($_POST["copyremotelists"]) { $req = Sql_Query("select * from {$remote_tables["listuser"]}, {$remote_tables["list"]} where {$remote_tables["listuser"]}.listid = {$remote_tables["list"]}.id and {$remote_tables["listuser"]}.userid = $user[0]"); while ($list = Sql_Fetch_Array($req)) { # print $list["name"]."
"; array_push($userlists,$list); } } connectLocal(); foreach ($useratt as $att) { $localattid = $attributemap[$att["attributeid"]]; if (!localattid) { print $GLOBALS['I18N']->get('no_mapped_attrib')." ".$att["name"]."
"; } else { $tname = Sql_Fetch_Row_Query("select tablename from {$tables["attribute"]} where id = $localattid"); switch ($att["type"]) { case "select": case "radio": $valueid = Sql_Fetch_Row_Query(sprintf('select id from %slistattr_%s where name = "%s"', $table_prefix,$tname[0],$att["displayvalue"])); if (!$valueid[0]) { Sql_Query(sprintf('insert into %slistattr_%s set name = "%s"', $table_prefix,$tname[0],$att["displayvalue"])); $att["value"] = Sql_Insert_id(); } else { $att["value"] = $valueid[0]; } break; case "checkboxgroup": $vals = explode(",",$att["displayvalue"]); array_pop($vals); $att["value"] = ""; foreach ($vals as $val) { $valueid = Sql_Fetch_Row_Query(sprintf('select id from %slistattr_%s where name = "%s"', $table_prefix,$tname[0],$val)); if (!$valueid[0]) { Sql_Query(sprintf('insert into %slistattr_%s set name = "%s"', $table_prefix,$tname[0],$val)); $att["value"] .= Sql_Insert_id().','; } else { $att["value"] .= $valueid[0].","; } } $att["value"] = substr($att["value"],0,-1); break; } if ($att["value"]) { Sql_Query(sprintf('replace into %s set attributeid = %d, userid = %d, value = "%s"', $tables["user_attribute"],$localattid,$userid,addslashes($att["value"]))); } } } } if (is_array($userlists)) foreach ($userlists as $list) { if ($listmap[$list["listid"]]) { Sql_Query(sprintf('replace into %s (listid,userid) values(%d,%d)', $tables["listuser"],$listmap[$list["listid"]],$userid)); } else { print $GLOBALS['I18N']->get('no_local_list')." ".$list["name"]."
"; } } } print "$totalusers / $totalusers
"; flush(); # @@@@ Not sure about this one: printf('%s %d %s %s %d %s
',$GLOBALS['I18N']->get('Done'),$newcnt, $GLOBALS['I18N']->get('new users'), $GLOBALS['I18N']->get('and'), $existcnt,$GLOBALS['I18N']->get('existing users')); } ?>