Page MenuHomeIn-Portal Phabricator
Files F772898

in-portal
No OneTemporary
Actions

File Metadata

Created
Sat, Feb 1, 8:50 PM

in-portal
View Options

Index: trunk/admin/import/import.php
===================================================================
--- trunk/admin/import/import.php (revision 246)
+++ trunk/admin/import/import.php (revision 247)
@@ -1,938 +1,941 @@
<?php
#import script
#taking care of actual importing from in-link db to in-portal db
if(!strlen($pathtoroot))
{
$path=dirname(realpath($_SERVER['SCRIPT_FILENAME']));
if(strlen($path))
{
/* determine the OS type for path parsing */
$pos = strpos($path,":");
if ($pos === false)
{
$gOS_TYPE="unix";
$pathchar = "/";
}
else
{
$gOS_TYPE="win";
$pathchar="\\";
}
$p = $path.$pathchar;
/*Start looking for the root flag file */
while(!strlen($pathtoroot) && strlen($p))
{
$sub = substr($p,strlen($pathchar)*-1);
if($sub==$pathchar)
{
$filename = $p."root.flg";
}
else
$filename = $p.$pathchar."root.flg";
if(file_exists($filename))
{
$pathtoroot = $p;
}
else
{
$parent = realpath($p.$pathchar."..".$pathchar);
if($parent!=$p)
{
$p = $parent;
}
else
$p = "";
}
}
if(!strlen($pathtoroot))
$pathtoroot = ".".$pathchar;
}
else
{
$pathtoroot = ".".$pathchar;
}
}
$sub = substr($pathtoroot,strlen($pathchar)*-1);
if($sub!=$pathchar)
{
$pathtoroot = $pathtoroot.$pathchar;
}
require_once($pathtoroot."kernel/startup.php");
$admin = $objConfig->Get("AdminDirectory");
if(!strlen($admin))
$admin = "admin";
if ($_POST["Action"]=="Import")
{
$objSession->SetVariable("import_user_admin",$_POST["user_admin"]);
$objSession->SetVariable("import_user_regular",$_POST["user_regular"]);
$objSession->SetVariable("import_init_cat",$_POST["init_cat"]);
$objSession->SetVariable("image_name",$_POST["image_name"]);
$objSession->SetVariable("importtodo","initialize");
$objSession->SetVariable("importstart",0);
$objSession->SetVariable("importtotal",0);
if((int)$_POST["init_cat"]>0)
{
$c = $objCatList->GetItemByField("ResourceId",(int)$_POST["init_cat"]);
$c->UpdateACL();
$c->UpdateCachedPath();
}
}
$allgroups = $objGroups->GetAllGroupList();
$inlink_sql_type=$objSession->GetVariable("import_inlink_sql_type");
$inlink_server=$objSession->GetVariable("import_inlink_server");
$inlink_db=$objSession->GetVariable("import_inlink_db");
$inlink_user=$objSession->GetVariable("import_inlink_user");
$inlink_pass=$objSession->GetVariable("import_inlink_pass");
$user_admin=$objSession->GetVariable("import_user_admin");
$user_regular=$objSession->GetVariable("import_user_regular");
if(!is_object($c))
$c = $objCatList->GetItemByField("ResourceId",$objSession->GetVariable("import_init_cat"));
$init_cat= $c->Get("CategoryId");
$image_name=$objSession->GetVariable("image_name");
$start = $objSession->GetVariable("importstart");
$acl = explode(",",$c->GetACL("CATEGORY.VIEW"));
//IN-LINK connection
$linkconn=&ADONewConnection($inlink_sql_type);
$linkconn->PConnect($inlink_server, $inlink_user, $inlink_pass, $inlink_db);
if(!$linkconn)
{ echo "Database connection failed. DB Type: $sql_type, DB Server: $inlink_server, DB User: $inlink_user, DB Name: $inlink_db"; //fatal;
echo $linkconn->ErrorMsg();
die();
}
if($pconnect)
{
$linkconn->Close();
$linkconn = ADONewConnection($inlink_sql_type);
$linkconn->PConnect($inlink_server, $inlink_user, $inlink_pass, $inlink_db);
}
//admin only util
$pathtolocal = $pathtoroot."kernel/";
require_once ($pathtoroot."admin/include/elements.php");
require_once ($pathtoroot."kernel/admin/include/navmenu.php");
require_once ($pathtolocal."admin/include/navmenu.php");
require_once($pathtoroot."admin/toolbar.php");
//Set Section
$section = "in-portal:inlink_inport";
//Set Environment Variable
$envar = "env=" . BuildEnv();
$sec = $objSections->GetSection($section);
$objCatToolBar = new clsToolBar();
$title = admin_language("la_performing_import")." - ".admin_language("la_Step")." 4";
//In-Portal
$portalconn = GetAdodbConnection();
$TablePrefix = "ses_".$objSession->GetSessionKey()."_".GetTablePrefix();
$olddbname=$inlink_db;
//$newdbname="inportal";
$newdbname=$g_DBName;
##############creating a temproary table have to be here
if ($_POST["Action"]=="Import")
{
$portalconn->Execute("DROP TABLE ".$TablePrefix."import");
$portalconn->Execute("DROP TABLE ".$TablePrefix."importcat");
$temptable = "CREATE TABLE ".$TablePrefix."import (otname varchar(40), oid int(11), ocustomid int(11), oparentid int(11), ntname varchar(40), nid int(11), nrid int(11), npid int(11)) ";
$portalconn->Execute($temptable);
$cattable ="CREATE TABLE ".$TablePrefix."importcat (op int(11), np int(11), flag int(11)) ";
$portalconn->Execute($cattable);
$newcat = 1;
}
global $admin, $pathtoroot;
require_once ($pathtoroot.$admin."/import/status.php"); #for status bar and all visual effects
$todo= $objSession->GetVariable("importtodo");
$total = $objSession->GetVariable("importtotal");
switch ($todo)
{
case "users":
status($start, $total, "users");
usersimport();
//setstart(0,"cats"); #for debugging
break;
case "cats":
status($start, $total, "cats");
catmanager();
#setstart(0,"links"); #for debugging
break;
case "links":
status($start, $total, "links");
linksimport();
#setstart(0,"custom");#For debugging only
break;
case "custom":
status($start, $total, "custom");
customimport();
#setstart(0,"relcat");#for debuggin only
break;
case "relcat":
status($start, $total, "relcat");
relcatimport();
#setstart(0,"terminate"); #for debuggin only
break;
case "terminate":
terminator();
status(1,1,"terminate");
break;
default:
status(0,0,"initializing");
setstart(0,"users"); #to start importing from users first
break;
}
function terminator()
{
global $portalconn, $TablePrefix;
$query="DROP TABLE IF EXISTS ".$TablePrefix."import, ".$TablePrefix."importcat";
$portalconn->Execute($query);
}
function reload()
{
global $newurl;
print '<script language="javascript">' ;
print " setTimeout('location.href=location.href',40);";
print ' </script>';
}
function setstart($mystart, $part)
{
global $objSession;
$objSession->SetVariable("importstart",$mystart);
$objSession->SetVariable("importtodo",$part);
reload();
}
function settotal($total)
{
global $objSession;
$objSession->SetVariable("importtotal",$total);
}
//users import from inlink to inportal
function usersimport()
{
global $objUsers, $objSession, $linkconn, $portalconn, $olddbname,
$user_admin,$objGroups, $user_regular, $start, $TablePrefix;
$counter = 0;
$limit = 350;
$oldtablename = "inl_users";
$newtablename = $objUsers->SourceTable;
if ($start == 0)
{
$query="select count(*) as NumUsers from inl_users";
$row =$linkconn->Execute($query);
if ($row && !$row->EOF)
{
settotal($row->fields["NumUsers"]);
}
}
$query="select * from inl_users LIMIT $start, $limit";
$row =$linkconn->Execute($query);
while($row && !$row->EOF)
{
$counter++; #needed to know when close to time out
if ($row->fields['user_name'] != "root") {
$olduserid=$row->fields["user_id"];
//$Login, $Password, $Email, $CreatedOn, $FirstName="", $LastName="", $Status=2,
// $Phone="", $Street="", $City="", $State="", $Zip="", $Country=""
if($row->fields["user_status"]==1)
{
$Status=1;
}
else
{
if($row->fields["user_pend"]==0)
{
$Status=2;
}
else
$Status=0;
}
$u = $objUsers->Add_User( $row->fields["user_name"], $row->fields["user_pass"], $row->fields["email"],
$row->fields["user_date"], $row->fields["first"], $row->fields["last"],
$Status);
$oldid=$row->fields["user_id"];
$oldcustom=$row->fields["user_cust"];
$newid=$u->Get("PortalUserId");
$resid=$u->Get("ResourceId");
#adding user to usergroup
$userpermission = $row->fields["user_perm"];
if ($userpermission==2 || $userpermission==1)
{
$glist = explode(",",$user_admin);
$Primary=1;
for($i=0;$i<count($glist);$i++)
{
$group=$objGroups->GetItem($glist[$i]);
$group->AddUser($newid,$Primary);
$Primary = 0;
}
}
else
{
$glist = explode(",",$user_regular);
$Primary=1;
for($i=0;$i<count($glist);$i++)
{
$group=$objGroups->GetItem($glist[$i]);
$group->AddUser($newid,$Primary);
$Primary = 0;
}
}
//$group=$objGroups->GetItem($g);
//$group->AddUser($newid,1);
#inserting values to the temproary table
$totemp = "INSERT INTO ".$TablePrefix."import (otname,oid,ocustomid,oparentid,ntname,nid,nrid,npid) ";
$tovalues= " VALUES ('$oldtablename',$olduserid,$oldcustom,0,'$newtablename', $newid, $resid, 0 )";
$totemp=$totemp.$tovalues;
$portalconn->Execute($totemp);
}
$row->moveNext();
}
if ($counter == $limit)
{
setstart($start+$limit, "users");
}
else
setstart(0,"cats");
}
//END OF USERS IMPORT ^^^^^^^^^^^^^^^^^^^^^
//Categories Import
function catmanager()
{
global $portalconn, $init_cat,$start,$TablePrefix;
if ($start == 0)
{
$counter = catimport(0,$init_cat);
setstart($counter,"cats");
$portalconn->Execute("UPDATE ".$TablePrefix."importcat SET flag=1 WHERE np=$init_cat");
}
else
{
$query="select * from ".$TablePrefix."importcat WHERE flag=0 LIMIT 0,1";
$row =$portalconn->Execute($query);
if($row && !$row->EOF)
{
$oldid= $row->fields["op"];
$newid = $row->fields["np"];
$counter= catimport($oldid,$newid);
$query2="UPDATE ".$TablePrefix."importcat SET flag=1 WHERE op=$oldid and np=$newid";
$portalconn->Execute($query2);
setstart($counter+$start-1,"cats");
$x=5;
}
else
{
setstart(0,"links");
}
}
}
#pushes into the quque
function pushid($op,$np)
{
global $linkconn, $portalconn, $TablePrefix;
$addnew = "INSERT INTO ".$TablePrefix."importcat (op,np,flag) VALUES ($op,$np,0)";
$portalconn->Execute($addnew);
}
function checkifexist($id)
{
global $linkconn;
$addnew = "select * from inl_cats where cat_sub=$id";
$row =$linkconn->Execute($addnew);
if ($row && !$row->EOF)
{
if ($row->fields["cat_id"] !=0)
{
return true;
}
else
{
return false;
}
}
else
{
return false;
}
}
#import itself
function catimport($oldparentid, $parentid)
{
global $objCatList, $linkconn, $objUsers, $linkconn, $portalconn,
$olddbname, $user_admin,$objGroups, $user_regular, $acl,$allgroups,
$c, $start, $TablePrefix;
$counter=0;
$objCacheCount = new clsCacheCountList();
if ($start == 0)
{
$query="select count(*) as CatCount from inl_cats";
$row =$linkconn->Execute($query);
if ($row && !$row->EOF)
{
settotal($row->fields["CatCount"]);
$catcount = $row->fields["CatCount"];
$catcount += (int)$c->Get("CachedDescendantCatsQty");
$c->Set("CachedDescendantCatsQty",$catcount);
$c->Update();
}
}
$query="select * from inl_cats WHERE cat_sub=$oldparentid";
$oldtablename = "inl_cats";
$newtablename = "Category";
$row =$linkconn->Execute($query);
if($row && !$row->EOF)
{
$RowCount = $row->NumRows();
$ResInc = $RowCount;
$ResourceId = GetNextResourceId($ResInc);
}
if($parentid>0)
{
$ParentCat = new clsCategory($parentid);
$Path = $ParentCat->Get("ParentPath");
}
while($row && !$row->EOF)
{
$counter++;
$cat = new clsCategory();
if($row->fields["cat_pend"]==0)
{
$Status=1;
}
else
{
if($row->fields["cat_vis"]==0)
{
$Status=2;
}
else
$Status=0;
}
$CreatedById = getnewid($row->fields["cat_id"]);
$cat->Set(array("ParentId", "Name", "Description", "CreatedOn", "EditorsPick", "Status", "HotItem",
"NewItem","PopItem", "Priority", "MetaKeywords", "MetaDescription", "CreatedById",
"CachedDescendantCatsQty"),
array($parentid, $row->fields["cat_name"], $row->fields["cat_desc"],
$row->fields["cat_date"], (int)$row->fields["cat_pick"], $Status, 2, 2, 2, 0,
$row->fields["meta_keywords"],$row->fields["meta_desc"],
(int)$CreatedById,(int)$row->fields["cat_cats"]));
$cat->Set("ResourceId",$ResourceId);
$ResourceId++;
$cat->Create();
$FullPath = $Path.$cat->Get("CategoryId")."|";
$cat->Set("ParentPath",$FullPath);
$cat->SetViewPerms("CATEGORY.VIEW",$acl,$allgroups);
$cat->SetViewPerms("LINK.VIEW",$acl,$allgroups);
$cat->Update();
$cat->UpdateCachedPath();
$objCacheCount->CategoryId= $cat->Get("CategoryId");
$objCacheCount->SetValue(0,0,0,0,0);
$newid = $cat->Get("CategoryId");
$resid = $cat->Get("ResourceId");
$oldid = $row->fields["cat_id"];
$oldcustom = $row->fields["cat_cust"];
$oldpid = $row->fields["cat_sub"];
#inserting values to the temproary table
$totemp = "INSERT INTO ".$TablePrefix."import (otname,oid,ocustomid,oparentid,ntname,nid,nrid,npid) ";
$tovalues= " VALUES ('$oldtablename',$oldid,$oldcustom,$oldpid,'$newtablename', $newid, $resid, $parentid )";
$totemp=$totemp.$tovalues;
$portalconn->Execute($totemp);
#pushes into the queue
if(checkifexist($oldid))
{
pushid($oldid,$newid);
}
$row->moveNext();
}
- // disable lost+found category
+ // disable lost+found category (if found one)
$tmp_cat = $objCatList->GetItemByField('Name','Lost+Found');
- $tmp_cat->Set('Status',0);
- $tmp_cat->Update();
+ if( is_object($tmp_cat) )
+ {
+ $tmp_cat->Set('Status',0);
+ $tmp_cat->Update();
+ }
return $counter;
}
//Links Import
function linksimport()
{
global $objLinkList, $init_cat, $linkconn, $portalconn, $olddbname,
$user_admin,$objGroups, $user_regular, $start, $TablePrefix;
$limit = 750; #need to change to a higher number like 100, forty is only for debugging
$counter = 0;
set_time_limit(0);
if ($start == 0)
{
$query="select count(*) as LinkCount from inl_lc";
$row =$linkconn->Execute($query);
if ($row && !$row->EOF)
{
settotal($row->fields["LinkCount"]);
}
}
$query="select * from inl_lc INNER JOIN inl_links ON (inl_lc.link_id=inl_links.link_id) limit $start,$limit";
$oldtablename="inl_links";
$newtablename="link";
$row =$linkconn->Execute($query);
if($row && !$row->EOF)
{
$RowCount = $row->NumRows();
$ResInc = $RowCount;
$ResourceId = GetNextResourceId($ResInc);
}
while($row && !$row->EOF)
{
$counter++;
$oldid=$row->fields["link_id"];
$flag=1;
$oldcatid = $row->fields["cat_id"];
$pending = $row->fields["link_pend"];
#getting a new category id
$rs = $portalconn->Execute("SELECT nid FROM ".$TablePrefix."import WHERE ntname='Category' and oid=$oldcatid");
if ($rs && ! $rs->EOF)
{
$categoryid=$rs->fields["nid"];
}
else
{
$categoryid = $init_cat;
}
$rs = $portalconn->Execute("SELECT * FROM ".$TablePrefix."import WHERE otname='inl_link' AND oid='$oldid'");
if($rs && ! $rs->EOF)
{
$NewLinkId = $rs->fields["nid"];
}
else
$NewLinkId=0;
if ($NewLinkId==0)
{
#gets the new user id of the user who created a link
$newuserid=getnewid($row->fields["link_user"]);
#adds link to the IN-PORTAL
$link = new clsLink();
if($Pending==0)
{
$Status=1;
}
else
$Status=2;
$link->Set(array("Name", "Description", "Url", "CreatedOn", "Status", "EditorsPick",
"NewItem","PopItem","HotItem", "CreatedById", "CachedRating",
"CachedVotesQty","Hits", "Priority"),
array($row->fields["link_name"], $row->fields["link_desc"], $row->fields["link_url"], $row->fields["link_date"], $Status,
$row->fields["link_pick"], 2, 2, 2, $newuserid, (int)$row->fields["link_rating"],
(int)$row->fields["link_votes"],(int)$row->fields["link_hits"], 0));
$link->Set("ResourceId",$ResourceId);
$ResourceId++;
$link->Create();
$link->AddToCategory($categoryid,"",1);
$newid = $link->Get("LinkId");
$resid = $link->Get("ResourceId");
$oldcustom=$row->fields["link_cust"];
$linkimage =$row->fields["link_image"];
if ($linkimage)
{
addimage($resid,$linkimage);
}
#calls to import reviews
reviewimport($link,$oldid,$resid);
$parentid = 0;
$totemp = "INSERT INTO ".$TablePrefix."import (odb,otname,oid,ocustomid,oparentid,ndb,ntname,nid,nrid,npid) ";
$tovalues= " VALUES ('$olddbname','$oldtablename',$oldid,$oldcustom,$oldcatid,'inportal','$newtablename', $newid, $resid, $parentid )";
$totemp = $totemp.$tovalues;
//$portalconn->Execute($totemp);
}
else #if link is related to more than one category
{
$link = new clsLink($NewLinkId);
$link->AddtoCategory($categoryid,"",0);
}
#prelast while
$row->moveNext();
}
if ($counter == $limit)
{
setstart($start+$limit, "links");
}
else
{
setstart(0,"custom");
}
}
#importing image from the in-link
function addimage($resourceid, $imageurl)
{
global $objImageList, $image_name;
#echo "<br />IMAGE RESOURCEID: $resourceid IMAGE URL: $imageurl <br />";
if(!is_object($objImageList))
$objImageList = new clsImageList();
$LocalImage = 0;
$LocalThumb = 0;
if(!strlen($image_name))
$image_name="inlink_image";
$img = $objImageList->Add($image_name,"",$resourceid, 0, 0,"", $imageurl, 1,0, 1, 0,1);
}
#Reviews Import for links
function reviewimport($myclass,$oldid,$rid)
{
global $objCustomFieldList, $linkconn, $portalconn;
#ITEM AddReview($createdBy,$reviewText,0)
$query="select * from inl_reviews where rev_link= $oldid";
$row =$linkconn->Execute($query);
while($row && !$row->EOF)
{
$oldreviewuser= $row->fields["rev_user"];
if($oldreviewuser !=0) #meaning was not created by guest
{
$newrid=getnewid($oldreviewuser);
if ($newrid)
{
$temp=$myclass->AddReview($newrid,$row->fields["rev_text"],0,"127.0.0.1",1, "In-Link");
}
else
{
$temp=$myclass->AddReview(0,$row->fields["rev_text"],0,"127.0.0.1",1, "In-Link");
}
}
else #meaning was created by guest
{
$temp=$myclass->AddReview(0,$row->fields["rev_text"],0,"127.0.0.1",1, "In-Link");
}
$row->moveNext();
}
}
#HELPER FUNCTION THAT GETS THE NEW ID of the USER
function getnewid($oldid)
{
global $portalconn, $TablePrefix;
$query2="select * from ".$TablePrefix."import where otname='inl_users' and oid=".$oldid;
$row2=$portalconn->Execute($query2);
if ($row2->fields["nid"])
{
return $row2->fields["nid"];
}
else
{
return 0;
}
}
//^^^^^^^^^^^^^^^^^^^^^^ABOVE IS LINKS IMPORT
#########################################Custom Fields Import
#create a new CustomField first and then
#by selecting all and receiving from one record of inl_config the values of cc1,cc2,cc3,cc4,cc5,cc6,uc1,uc2,uc3,uc4,uc5,uc6,lc1,lc2,lc3,lc4,lc5,lc6
#go through all import table and if ocustomid occures get the row from inl_custom and
#create CustomMetaData field
#---------------------
#Regarding CustomField:
#FieldName= cc1,cc2 .... from inl_config
#FieldLabel= value of cc1, cc2 ....
#Type=4 for links 6 for users 0 category
#------------
#Regarding CustomMetaData
#ResourceId <= link id
#CustomFieldId <= id from the top
#Value = Value from the table custom
//VVVVV BELOW ARE CUSTOM FIELD IMPORT REQUIRES TO HAVE A TEMPROARY TABLE IMPORT
function customimport()
{
global $linkconn, $portalconn, $start, $TablePrefix;
$limit = 40; #just for debugging purposes, in real life set it to higher number
$counter=0;
if ($start == 0)
{
$r=buildfields();
$query="SELECT count(*) as cc from ".$TablePrefix."import WHERE NOT ocustomid=0";
$row =$portalconn->Execute($query);
if ($row && !$row->EOF)
{
settotal($row->fields["cc"]);
}
}
else
{
$r=getfields();
}
$query="SELECT * from ".$TablePrefix."import WHERE ocustomid!=0 limit $start,$limit";
$row =$portalconn->Execute($query);
while($row && !$row->EOF)
{
$counter++;
if ($row->fields["ocustomid"]!=0)
{
loadcustom($row->fields["ocustomid"],$row->fields["nrid"],$row->fields["otname"],$r);
}
$row->moveNext();
}
if ($counter == $limit)
{
setstart($start+$limit, "custom");
}
else
{
setstart(0,"relcat");
}
}
function loadcustom($customid,$rid,$tablename,$r)
{
global $linkconn, $objCustomDataList, $objSession;
$objCustomDataList->Clear();
if ($tablename =="inl_cats")
{
//$myfieldname="cc";
$fields = explode(",",$objSession->GetVariable("custom_category"));
}
else if($tablename =="inl_users")
{
//$myfieldname="uc";
$fields = explode(",",$objSession->GetVariable("custom_user"));
}
else if($tablename =="inl_links")
{
//$myfieldname="lc";
$fields = explode(",",$objSession->GetVariable("custom_links"));
}
$oldtablename="inl_links";
$newtablename="link";
$query="select * from inl_custom Where cust_id=$customid";
$row =$linkconn->Execute($query);
if ($row)
{
for ($x=0; $x<count($fields);$x++)
{
$cust=$row->fields["cust".$x];
if ($cust!="")
{
$fieldid =$r[$fields[$x]];
$objCustomDataList->SetFieldValue($fieldid,$rid,$cust);
}
}
$objCustomDataList->SaveData();
}
}
function buildfields() #building and populating an array
{
global $objCustomFieldList, $objSession,$linkconn;
$lc="lc";
$uc="uc";
$cc="cc";
$query = "SELECT * FROM inl_config WHERE name LIKE 'uc%'";
$row =$linkconn->Execute($query);
$names = array();
while($row && !$row->EOF)
{
$data = $row->fields;
$fieldlabel=$data["name"];
if(strlen($data["value"]))
{
$fieldlabel = $data["value"];
}
$f=$objCustomFieldList->AddField(6,$data["name"],$fieldlabel);
$r["'".$data["name"]."'"]=$f->Get("CustomFieldId");
$objSession->SetVariable("custom_".$data["name"],$f->Get("CustomFieldId"));
$names[] = $data["name"];
$row->MoveNext();
}
$objSession->SetVariable("custom_user",implode(",",$names));
unset($names);
$names = array();
$query = "SELECT * FROM inl_config WHERE name LIKE 'cc%'";
$row =$linkconn->Execute($query);
while($row && !$row->EOF)
{
$data = $row->fields;
$fieldlabel=$data["name"];
if(strlen($data["value"]))
{
$fieldlabel = $data["value"];
}
$f=$objCustomFieldList->AddField(1,$data["name"],$fieldlabel);
$r["'".$data["name"]."'"]=$f->Get("CustomFieldId");
$objSession->SetVariable("custom_".$data["name"],$f->Get("CustomFieldId"));
$names[] = $data["name"];
$row->MoveNext();
}
$objSession->SetVariable("custom_category",implode(",",$names));
unset($names);
$names = array();
$query = "SELECT * FROM inl_config WHERE name LIKE 'lc%'";
$row =$linkconn->Execute($query);
while($row && !$row->EOF)
{
$data = $row->fields;
$fieldlabel=$data["name"];
if(strlen($data["value"]))
{
$fieldlabel = $data["value"];
}
$f=$objCustomFieldList->AddField(4,$data["name"],$fieldlabel);
$r["'".$data["name"]."'"]=$f->Get("CustomFieldId");
$objSession->SetVariable("custom_".$data["name"],$f->Get("CustomFieldId"));
$names[] = $data["name"];
$row->MoveNext();
}
$objSession->SetVariable("custom_links",implode(",",$names));
return $r;
}
function getfields() #building and populating an array
{
global $objSession;
$lc="lc";
$uc="uc";
$cc="cc";
$userfields = explode(",",$objSession->GetVariable("custom_user"));
for ($x=0;$x<=count($userfields);$x++)
{
$r[$userfields[$x]]=$objSession->GetVariable("custom_".$userfields[$x]);
}
$catfields = explode(",",$objSession->GetVariable("custom_category"));
for ($x=0;$x<=count($catfields);$x++)
{
$r[$catfields[$x]]=$objSession->GetVariable("custom_".$catfields[$x]);
}
$linkfields = explode(",",$objSession->GetVariable("custom_links"));
for ($x=0;$x<=count($linkfields);$x++)
{
$r[$linkfields[$x]]=$objSession->GetVariable("custom_".$linkfields[$x]);
}
return $r;
}
################################################Relationships Import
function relcatimport()
{
global $linkconn,$objSession, $start;
$limit = 100;
$counter =0;
if ($start == 0)
{
$query="SELECT count(*) from inl_rel_cats";
$row =$linkconn->Execute($query);
if ($row && !$row->EOF)
{
settotal($row->fields[0]);
}
}
$objRelList = new clsRelationshipList();
$query="select * from inl_rel_cats LIMIT $start, $limit";
$row =$linkconn->Execute($query);
while($row && !$row->EOF)
{
$counter++;
$sourceid = newcatrid($row->fields["cat_id"]);
$targetid = newcatrid($row->fields["rel_id"]);
if ($sourceid !="" && $targetid !="")
{
$r = $objRelList->Add($sourceid, 1,$targetid, 1);
$r->Create();
}
$row->moveNext();
}
if ($counter == $limit)
{
setstart($start+$limit, "relcat");
}
else
{
setstart(0,"terminate");
}
}
function newcatrid($oid)
{
global $portalconn, $TablePrefix;
$query2="select * from ".$TablePrefix."import where otname='inl_cats' and oid=$oid";
$row =$portalconn->Execute($query2);
if ($row->fields["nrid"])
{
return $row->fields["nrid"];
}
else
{
return "";
}
}
// END OF RELATIONSHIP IMPORT
?>
\ No newline at end of file
Property changes on: trunk/admin/import/import.php
___________________________________________________________________
Modified: cvs2svn:cvs-rev
## -1 +1 ##
-1.8
\ No newline at end of property
+1.9
\ No newline at end of property

Event Timeline

In-Portal CMS · In-Portal Community Pages · In-Portal Issue Tracker · In-Portal Repository Browser · Quality Assurance · In-Portal CI Server