version 1.47.2.67, 2006/11/09 15:16:26
|
version 1.47.2.81, 2008/06/19 11:49:34
|
Line 19 import string
|
Line 19 import string
|
import re |
import re |
import os |
import os |
from types import * |
from types import * |
import zLOG |
import logging |
import xmlhelper # Methoden zur Verwaltung der projekt xml |
import xmlhelper # Methoden zur Verwaltung der projekt xml |
from OFS.SimpleItem import SimpleItem |
from OFS.SimpleItem import SimpleItem |
from OFS.Folder import Folder |
from OFS.Folder import Folder |
Line 34 from Ft.Xml.XPath.Context import Context
|
Line 34 from Ft.Xml.XPath.Context import Context
|
from Ft.Xml.Domlette import NonvalidatingReader,PrettyPrint, Print |
from Ft.Xml.Domlette import NonvalidatingReader,PrettyPrint, Print |
from Ft.Xml import EMPTY_NAMESPACE |
from Ft.Xml import EMPTY_NAMESPACE |
import copy |
import copy |
|
import updatePersonalWWW |
|
import MPIWGStaff |
|
|
definedFields=['WEB_title','xdata_01','xdata_02','xdata_03','xdata_04','xdata_05','xdata_06','xdata_07','xdata_08','xdata_09','xdata_10','xdata_11','xdata_12','xdata_13','WEB_project_header','WEB_project_description','WEB_related_pub'] |
definedFields=['WEB_title','xdata_01','xdata_02','xdata_03','xdata_04','xdata_05','xdata_06','xdata_07','xdata_08','xdata_09','xdata_10','xdata_11','xdata_12','xdata_13','WEB_project_header','WEB_project_description','WEB_related_pub'] |
|
|
checkFields = ['xdata_01'] |
checkFields = ['xdata_01'] |
|
|
|
#ersetzt logging |
|
def logger(txt,method,txt2): |
|
"""logging""" |
|
logging.info(txt+ txt2) |
|
|
def getTextFromNode(nodename): |
def getTextFromNode(nodename): |
nodelist=nodename.childNodes |
nodelist=nodename.childNodes |
Line 104 def sortI(x,y):
|
Line 110 def sortI(x,y):
|
except: |
except: |
return cmp(x[1],y[1]) |
return cmp(x[1],y[1]) |
|
|
|
|
|
def unicodify(str): |
|
"""decode str (utf-8 or latin-1 representation) into unicode object""" |
|
if not str: |
|
return "" |
|
if type(str) is StringType: |
|
try: |
|
return str.decode('utf-8') |
|
except: |
|
return str.decode('latin-1') |
|
else: |
|
return str |
|
|
|
def utf8ify(str): |
|
"""encode unicode object or string into byte string in utf-8 representation""" |
|
if not str: |
|
return "" |
|
if type(str) is StringType: |
|
return str |
|
else: |
|
return str.encode('utf-8') |
|
|
|
|
class MPIWGLink(SimpleItem): |
class MPIWGLink(SimpleItem): |
"""create a symbolic link to another page""" |
"""create a symbolic link to another page""" |
|
|
Line 143 class MPIWGLink(SimpleItem):
|
Line 172 class MPIWGLink(SimpleItem):
|
return obj |
return obj |
|
|
def getWeight(self): |
def getWeight(self): |
if self.linkWeight and linkWeight!="": |
if self.linkWeight and self.linkWeight!="": |
return self.linkWeight |
return self.linkWeight |
else: |
else: |
return self.getObj().weight |
return self.getObj().weight |
Line 167 class MPIWGLink(SimpleItem):
|
Line 196 class MPIWGLink(SimpleItem):
|
if RESPONSE is not None: |
if RESPONSE is not None: |
RESPONSE.redirect('manage') |
RESPONSE.redirect('manage') |
|
|
def index_html(self): |
def index_html(self,**argv): |
"""index""" |
"""index""" |
|
|
|
|
|
|
try: |
try: |
return self.getObj().pt_render(extra_context={'here':self}) |
return self.getObj().pt_render(extra_context={'here':self}) |
except: |
except: |
self.REQUEST.RESPONSE.redirect(self.getObj().absolute_url()) |
self.REQUEST.RESPONSE.redirect(self.getObj().absolute_url()) |
|
|
|
|
|
|
def manage_addMPIWGLinkForm(self): |
def manage_addMPIWGLinkForm(self): |
"""Form for adding link""" |
"""Form for adding link""" |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt/AddMPIWGLink.zpt')).__of__(self) |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt/AddMPIWGLink.zpt')).__of__(self) |
Line 242 def manage_addMPIWGTemplateForm(self):
|
Line 274 def manage_addMPIWGTemplateForm(self):
|
from urllib import quote |
from urllib import quote |
|
|
|
|
def manage_addMPIWGTemplate(self, MPIWGType,id, title=None,weight=0,REQUEST=None): |
def manage_addMPIWGTemplate(self, MPIWGType,id, text="",title=None,weight=0,REQUEST=None): |
"Add a Page Template with optional file content." |
"Add a Page Template with optional file content." |
if type(MPIWGType)==StringType: |
if type(MPIWGType)==StringType: |
MPIWGTypes=[MPIWGType] |
MPIWGTypes=[MPIWGType] |
Line 298 class MPIWGRoot(ZSQLExtendFolder):
|
Line 330 class MPIWGRoot(ZSQLExtendFolder):
|
folders=['MPIWGProject','Folder','ECHO_Navigation'] |
folders=['MPIWGProject','Folder','ECHO_Navigation'] |
meta_type='MPIWGRoot' |
meta_type='MPIWGRoot' |
|
|
|
|
def harvestProjects(self): |
def harvestProjects(self): |
"""harvest""" |
"""harvest""" |
folder="/tmp" |
folder="/tmp" |
Line 325 class MPIWGRoot(ZSQLExtendFolder):
|
Line 358 class MPIWGRoot(ZSQLExtendFolder):
|
except: |
except: |
return str.decode('latin-1') |
return str.decode('latin-1') |
else: |
else: |
|
|
return str |
return str |
|
|
|
|
|
def getat(self,array,idx=0,default=None): |
|
"""return array element idx or default (but no exception)""" |
|
if len(array) <= idx: |
|
return default |
|
else: |
|
return array[idx] |
|
|
|
|
def browserCheck(self): |
def browserCheck(self): |
"""check the browsers request to find out the browser type""" |
"""check the browsers request to find out the browser type""" |
bt = {} |
bt = {} |
Line 490 class MPIWGRoot(ZSQLExtendFolder):
|
Line 530 class MPIWGRoot(ZSQLExtendFolder):
|
"""returns the current section name""" |
"""returns the current section name""" |
root = self.absolute_url() |
root = self.absolute_url() |
url = self.REQUEST['URL'] |
url = self.REQUEST['URL'] |
|
if not url: |
|
return None |
path = string.replace(url, root, '') |
path = string.replace(url, root, '') |
paths = path.split('/') |
paths = path.split('/') |
if len(paths) > 0: |
if len(paths) > 0: |
Line 515 class MPIWGRoot(ZSQLExtendFolder):
|
Line 557 class MPIWGRoot(ZSQLExtendFolder):
|
"""updates SQL databases using fm.jar""" |
"""updates SQL databases using fm.jar""" |
fmJarPath=os.path.join(package_home(globals()), 'updateSQL/fm.jar') |
fmJarPath=os.path.join(package_home(globals()), 'updateSQL/fm.jar') |
xmlPath=os.path.join(package_home(globals()), "updateSQL/%s"%fileName) |
xmlPath=os.path.join(package_home(globals()), "updateSQL/%s"%fileName) |
zLOG.LOG("MPIWG Web",zLOG.INFO,"java -classpath %s -Djava.awt.headless=true Convert %s"%(fmJarPath,xmlPath)) |
logger("MPIWG Web",logging.INFO,"java -classpath %s -Djava.awt.headless=true Convert %s"%(fmJarPath,xmlPath)) |
ret=os.popen("java -classpath %s -Djava.awt.headless=true Convert %s"%(fmJarPath,xmlPath),"r").read() |
ret=os.popen("java -classpath %s -Djava.awt.headless=true Convert %s"%(fmJarPath,xmlPath),"r").read() |
zLOG.LOG("MPIWG Web",zLOG.INFO,"result convert: %s"%ret) |
logger("MPIWG Web",logging.INFO,"result convert: %s"%ret) |
return 1 |
return 1 |
|
|
def patchProjects(self,RESPONSE): |
def patchProjects(self,RESPONSE): |
Line 686 class MPIWGRoot(ZSQLExtendFolder):
|
Line 728 class MPIWGRoot(ZSQLExtendFolder):
|
if RESPONSE is not None: |
if RESPONSE is not None: |
RESPONSE.redirect('manage_main') |
RESPONSE.redirect('manage_main') |
|
|
def getDisciplineList(self): |
|
"""get disciplines as list""" |
|
list= self.disciplineList.split("\n") |
|
return [x.rstrip().lstrip() for x in list] |
|
|
|
def getThemeList(self): |
|
"""get themes as list""" |
|
list= self.themesList.split("\n") |
|
return [x.rstrip().lstrip() for x in list] |
|
|
|
def test(self): |
|
"""test""" |
|
return self.getProjectsByFieldContent('xdata_09',['biology'])[0].absolute_url |
|
|
|
def getContexts(self,childs=None,parents=None,depth=None,date=None,onlyActive=True): |
def getContexts(self,childs=None,parents=None,depth=None,date=None,onlyActive=True): |
"""childs alle childs, alle parents""" |
"""childs alle childs, alle parents""" |
Line 773 class MPIWGRoot(ZSQLExtendFolder):
|
Line 803 class MPIWGRoot(ZSQLExtendFolder):
|
|
|
|
|
manage_options = Folder.manage_options+( |
manage_options = Folder.manage_options+( |
{'label':'Update personal homepages','action':'updateHomepages'}, |
{'label':'Update personal homepages','action':'updatePersonalwww_html'}, |
{'label':'Reindex catalogs','action':'reindexCatalogs'}, |
{'label':'Reindex catalogs','action':'reindexCatalogs'}, |
{'label':'Main config','action':'changeMPIWGRootForm'}, |
{'label':'Main config','action':'changeMPIWGRootForm'}, |
|
{'label':'add e-mails','action':'showNewDBEntries'}, |
|
{'label':'update the institutsbibliography','action':'updateInstitutsbiliography'}, |
#{'label':'Edit Historical Persons','action':'editHistoricalPersonsForm'}, |
#{'label':'Edit Historical Persons','action':'editHistoricalPersonsForm'}, |
#{'label':'Store Historical Persons','action':'storeHistoricalPersons'}, |
#{'label':'Store Historical Persons','action':'storeHistoricalPersons'}, |
) |
) |
|
|
def importNamesForm(self): |
|
"""Form""" |
|
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','MPIWGNamesForm.zpt')).__of__(self) |
|
return pt() |
|
|
|
def importNames(self,fileupload,folderName,RESPONSE=None): |
|
"""import komma-sep list email,lastName,firstName""" |
|
project=getattr(self,folderName) |
|
load=fileupload.read() |
|
|
|
for line in load.split('\r'): |
|
|
|
|
|
splitted=line.split(",") |
|
# print splitted |
|
|
|
if not (splitted[0]==""): |
|
newObj=MPIWGStaff.MPIWGStaff(splitted[0],splitted[1],splitted[2]) |
|
|
|
try: |
|
project._setObject(splitted[0],newObj) |
|
#print "done:",splitted[0] |
|
except: |
|
zLOG.LOG("MPIWG Web (importNames)",zLOG.INFO,"cannot import: %s"%splitted[0]) |
|
|
|
|
|
if RESPONSE is not None: |
|
RESPONSE.redirect('manage_main') |
|
|
|
def updatePublicationDB(self,personId=None): |
def updatePublicationDB(self,personId=None): |
"""updates the publication db, i.e. copy year into the main table""" |
"""updates the publication db, i.e. copy year and type into the main table""" |
|
|
if personId: |
if personId: |
founds = self.ZSQLInlineSearch(_table="publications",id_main=personId) |
founds = self.ZSQLInlineSearch(_table="publications",key_main=personId) |
else: |
else: |
founds = self.ZSQLInlineSearch(_table="publications") |
founds = self.ZSQLInlineSearch(_table="publications") |
|
|
Line 832 class MPIWGRoot(ZSQLExtendFolder):
|
Line 836 class MPIWGRoot(ZSQLExtendFolder):
|
|
|
return True |
return True |
|
|
def updateHomepages(self,RESPONSE=None): |
def showNewDBEntries(self): |
""" update""" |
"""zeige neue Eintraege in der Datenbank ohne e-mail adressen bzw. fuer die noch kein Object angelegt wurde""" |
|
|
RESPONSE.setHeader('Content-type', 'text/html') |
qstr="select * from personal_www where web_object_created='no' and not key=''" |
RESPONSE.write("<html><body>\n") |
res=self.ZSQLQuery(qstr) |
RESPONSE.write("Update Institutsbibliography\n") |
|
ret=self.upDateSQL('personalwww.xml') |
|
RESPONSE.write("done Insitutsbibliography:%s\n"%ret) |
|
url="http://itgroup.mpiwg-berlin.mpg.de:8050/FMPro?-db=personal-www&-format=-dso_xml&-lay=sql_export&-max=20000&-findall" |
|
dom = NonvalidatingReader.parseUri(url) |
|
#fh=urllib.urlopen(url) |
|
#dom=xml.dom.minidom.parse(fh) |
|
|
|
RESPONSE.write("got_xml_File\n") |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','showNewDBEntries.zpt')).__of__(self) |
|
return pt(newEntries=res) |
|
|
|
def createNewStaffObjects(self,RESPONSE): |
|
"""create new staff object""" |
|
|
memberFolder=getattr(self,'members') |
memberFolder=getattr(self,'members') |
members=memberFolder.ZopeFind(memberFolder,obj_metatypes=["MPIWGStaff"]) |
args=self.REQUEST.form |
|
arg_k=args.keys() |
|
arg_k.remove("submit") |
|
ret="" |
|
for key in arg_k: |
|
k=self.urlUnQuote(key) |
|
|
|
qstr="select * from personal_www where key=%s"%self.ZSQLQuote(k) |
|
res=self.ZSQLQuery(qstr)[0] |
|
if args[key]!="": #email-adresse wurde eingetragen |
|
#create the object |
|
e_mail=args[key] |
|
try: |
|
newObj=MPIWGStaff.MPIWGStaff(e_mail,res.last_name,res.first_name,k) |
|
memberFolder._setObject(e_mail,newObj) |
|
obj=getattr(memberFolder,e_mail) |
|
obj.reindex_object() |
|
ret+="Created %s \n"%e_mail |
|
created=True |
|
except: |
|
msg="Cannot create new user %s (%s %s)"%(e_mail,sys.exc_info()[0],sys.exc_info()[1]) |
|
logging.error(msg) |
|
ret+=msg+"\n" |
|
created=False |
|
|
|
if created: |
|
qstr="update personal_www set web_object_created='yes',e_mail='%s@mpiwg-berlin.mpg.de' where key=%s"%(e_mail,self.ZSQLQuote(k)) |
|
self.ZSQLQuery(qstr) |
|
|
|
return ret |
|
|
|
|
|
def generateNewPersonEntry(self,data): |
|
"""generate a new person entry for data, neue personen werden zunaechst nur in der datenbank angelegt """ |
|
|
|
#memberFolder=getattr(self,'members') |
|
#create the object |
|
|
memberList=[x[0] for x in members] |
# try: |
#print dom |
# newObj=MPIWGStaff.MPIWGStaff(urllib.quote(data['key']),data['last_name'].encode('utf-8'),data['first_name'].encode('utf-8')) |
#ctx=Context(dom,processorNss={EMPTY_NAMESPACE:'http://www.filemaker.com/fmpdsoresult'}) |
# memberFolder._setObject(urllib.quote(data['key']),newObj) |
# Evaluate(u".//dn:ROW",contextNode=dom,explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'}) |
# except: |
#print dom.xpath(u'.//dn:ROW',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'}) |
# return False, "Cannot create new user %s (%s %s)"%(data['key'],sys.exc_info()[0],sys.exc_info()[1]) |
for row in dom.xpath(u'.//dn:ROW',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'}): |
|
|
|
username=getTextFromNode(row.xpath('./dn:username',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
id=getTextFromNode(row.xpath('./dn:ID',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
name=getTextFromNode(row.xpath('./dn:Name',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
vorname=getTextFromNode(row.xpath('./dn:Vorname',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
title=getTextFromNode(row.xpath('./dn:Title',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
position=getTextFromNode(row.xpath('./dn:Position',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
e_mail=getTextFromNode(row.xpath('./dn:e_mail',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
e_mail_p=getTextFromNode(row.xpath('./dn:e_mail_p',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
date_from=getTextFromNode(row.xpath('./dn:Date_from',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
date_to=getTextFromNode(row.xpath('./dn:Date_to',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
abteilung=getTextFromNode(row.xpath('./dn:Abteilung',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
heimat_inst=getTextFromNode(row.xpath('./dn:heimat_inst',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
funded_by=getTextFromNode(row.xpath('./dn:funded_by',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
e_mail2=getTextFromNode(row.xpath('./dn:e_mail2',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
publish_the_data=getTextFromNode(row.xpath('./dn:publish_the_data',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
stay_at_mpiwg=getTextFromNode(row.xpath('./dn:stay_at_mpiwg',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
#cwNode=row.xpath('./dn:current_work.current',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0] |
|
cw=row.xpath('./dn:current_work/dn:DATA',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'}) |
|
if cw: |
|
txt=getTextFromNode(cw[0]) |
|
else: |
|
txt="" |
|
|
|
#cwNode=row.xpath('.//dn:current_work.publish',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0] |
|
cw=row.xpath('./dn:current_work/dn:DATA',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'}) |
|
|
|
if cw: |
|
txt_p=getTextFromNode(cw[0]) |
|
else: |
|
txt_p="" |
|
|
|
project=getattr(self,'members') |
|
|
|
if not (username in memberList):#neuer eintrag |
|
|
|
try: |
|
newObj=MPIWGStaff.MPIWGStaff(str(username),name.encode('utf-8'),vorname.encode('utf-8')) |
|
memberFolder._setObject(str(username),newObj) |
|
RESPONSE.write("<p>new:%s</p>\n"%username.encode('utf-8')) |
|
obj=getattr(memberFolder,username) |
|
ret=obj.createNewDBEntry(publish_the_data,id,name, |
|
vorname,username,title,position,e_mail, |
|
e_mail_p,date_from,date_to, |
|
abteilung,heimat_inst,funded_by, |
|
e_mail2,txt,txt_p,stay_at_mpiwg) |
|
RESPONSE.write("""<p>%s</p>"""%ret[1].encode('utf-8')) |
|
except: |
|
RESPONSE.write("<p>ERROR:%s %s %s</p>\n"%(username.encode('utf-8'),name.encode('utf-8'),vorname.encode('utf-8'))) |
|
RESPONSE.write("<p> : %s %s"%sys.exc_info()[:2]) |
|
else: |
|
RESPONSE.write("<p>update:%s</p>\n"%username.encode('utf-8')) |
|
|
|
xquery=".//dn:ROW[dn:username='%s']"%username |
|
results=dom.xpath(xquery,explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'}) |
|
if len(results)>1: |
|
RESPONSE.write("<p>WARNING (update): username %s not unique</p>\n"%username.encode('utf-8')) |
|
xquery=".//dn:ROW[dn:publish_the_data='yes' and dn:username='%s']"%username |
|
rd=dom.xpath(xquery,explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'}) |
|
if len(rd)>1:#mehrere published |
|
RESPONSE.write("<p>ERROR (update): username %s not unique and more then one date set to be published</p>\n"%username.encode('utf-8')) |
|
# elif len(rd)==1:#nur einer published, kein published dann mache nichts |
|
# publish_the_data=getTextFromNode(rd[0].xpath('./dn:publish_the_data',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
# date_from=getTextFromNode(rd[0].xpath('./dn:Date_from',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
# date_to=getTextFromNode(rd[0].xpath('./dn:Date_to',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0]) |
|
# |
# |
|
|
obj=getattr(memberFolder,username) |
#create the new entry in the database |
|
|
done= obj.updateDBEntry(DBid=id,publish_the_data=publish_the_data, |
|
date_from=date_from, |
|
date_to=date_to,stay_at_mpiwg=stay_at_mpiwg,position=position,abteilung=abteilung) |
|
if not done and (publish_the_data=='yes'): |
|
|
|
ret=obj.createNewDBEntry(publish_the_data,id,name, |
result,msg=MPIWGStaff.createNewDBEntry(self,data['publish_the_data'],data['key'],data['last_name'], |
vorname,username,title,position,e_mail, |
data['first_name'],data['title'],data['status'],"", |
e_mail_p,date_from,date_to, |
"",data['date_from'],data['date_to'], |
abteilung,heimat_inst,funded_by, |
data['department'],data['home_inst'],data['funded_by'], |
e_mail2,txt,txt_p,stay_at_mpiwg) |
data['e_mail2'],data['current_work'],"yes",data['date_stay_at_mpiwg'],data['group'],"no",data['current_work']) |
if not ret[0]: |
|
|
|
RESPONSE.write("<p>Error: %s</p>\n"%repr(ret[1])) |
return result,msg |
else: |
|
RESPONSE.write("<p>New: %s</p>\n"%repr(ret[1])) |
|
|
|
#TODO: reindexCatlogs and updatePublications wieder einbaue |
def updatePersonEntry(self,data,ignoreEntries=[]): |
#self.reindexCatalogs(RESPONSE) |
"""update an person entry from data. but ignore all fields in ignore Entries""" |
|
|
#self.updatePublicationDB() |
ignoreEntries.append('current_work') # TODO:updatecurrent work |
|
|
#self.ZSQLResetConnection() |
if data['date_to']=="": # wenn date_to leer |
RESPONSE.write("<h2>Done</h2></body></html>") |
data['date_to']="date_none" |
|
|
return True |
if data['date_from']=="": # wenn date_fromleer |
|
data['date_from']="date_none" |
|
msg="" |
|
|
def reindexCatalogs(self,RESPONSE=None): |
|
"""reindex members and project catalog""" |
|
|
|
|
#eintragen |
|
|
try: |
columns=data.keys() |
self.MembersCatalog.manage_catalogReindex(self.REQUEST,RESPONSE,self.REQUEST['URL1']) |
for x in ignoreEntries: |
self.ProjectCatalog.manage_catalogReindex(self.REQUEST,RESPONSE,self.REQUEST['URL1']) |
logging.info("ign rem: %s"%x) |
|
try: #falls in ignore entries felder sind, die nicht in columns sind, fange den fehler ab |
|
columns.remove(x) |
except: |
except: |
zLOG.LOG("MPIWG Root (updatehomepage)",zLOG.WARNING," %s %s"%sys.exc_info()[:2]) |
pass |
|
|
|
|
|
|
|
insert=[] |
|
for key in columns: |
|
if data[key]=="date_none": # date_none eintrag wird zu null uebersetzt |
|
insert.append('%s=null'%key) |
|
else: |
|
insert.append(""" "%s"=%s"""%(key,self.ZSQLQuote(data[key]))) |
|
|
|
insertStr=",".join(insert) |
|
queryStr="update personal_www SET %s where key='%s'"%(insertStr,data['key']) |
|
self.ZSQLQuery("SET DATESTYLE TO 'German'") |
|
self.ZSQLQuery(queryStr) |
|
|
|
#currentwork |
|
#if not (txt==""): |
|
# queryStr="INSERT INTO current_work (id_main,current,publish) VALUES ('%s','%s','%s')"%(id,txt,txt_p) |
|
# |
|
# self.ZSQLQuery(queryStr) |
|
|
|
return True,msg |
|
|
if RESPONSE: |
|
RESPONSE.redirect('manage_main') |
|
|
|
|
def updatePersonalwww_doIt(self): |
|
"""do the update""" |
|
args=self.REQUEST.form |
|
resultSet=self.REQUEST.SESSION['personal_www']['resultSet'] |
|
news=self.REQUEST.SESSION['personal_www']['news'] |
|
conflicts=self.REQUEST.SESSION['personal_www']['conflicts'] |
|
ret="<html><body>" |
|
# generate the new entry |
|
|
|
if news and (len(news)>0): |
|
ret+="<h2>Hinzugefügt</h2>" |
|
ret+="<p>Neueinträge erscheinen erst auf der Homepage, wenn ihnen eine e-mail Adresse zugeordnet wurde.</p>" |
|
ret+="<ul>" |
|
for new in news: |
|
|
|
if args.has_key(self.urlQuote(new.encode('utf-8'))): # entry was selected |
|
result,msg=self.generateNewPersonEntry(resultSet[new]) |
|
if not result: |
|
logging.error("Error (generateNewPersonEntry) %s"%msg) |
|
ret+="<li>ERROR: %s %s"%(new.encode('utf-8'),msg) |
|
else: |
|
ret+="<li>OK: %s"%(new.encode('utf-8')) |
|
if news and (len(news)>0): |
|
ret+="<p>Neueinträge erscheinen erst auf der Homepage, wenn ihnen eine e-mail Adresse zugeordnet wurde.</p>" |
|
ret+="</ul>" |
|
|
|
# update |
|
|
|
if len(conflicts.keys())>0: |
|
ret+="<h2>Änderung des Benutzers übernehmen</h2>" |
|
ret+="<p>Wenn nötig in Filemaker-db ändern:</p>" |
|
|
|
# konflicte |
|
for conflict in conflicts.keys(): |
|
ignoreEntries=[] |
|
displayIgnored=[] |
|
for cf in conflicts[conflict]: |
|
if args[conflict.encode('utf-8')+'_'+cf[0]]=="stored": #use the stored one |
|
ignoreEntries.append(cf[0]) #so ignore field cf[0] |
|
displayIgnored.append(cf) |
|
if len(displayIgnored)>0: |
|
ret+="<h3>%s</h3>"%conflict.encode('utf-8') |
|
|
|
ret+="<table border='1'>" |
|
for iE in displayIgnored: |
|
ret+="<tr><td>%s</td><td>%s</td><td>%s</td>"%(iE[0].encode('utf-8'),iE[1].encode('utf-8'),iE[2].encode('utf-8')) |
|
ret+="</tabel>" |
|
|
|
self.updatePersonEntry(resultSet[conflict],ignoreEntries=ignoreEntries) |
|
|
|
# rest |
|
cl=list(conflicts.keys()) |
|
|
|
for key in resultSet.keys(): |
|
if key not in cl: |
|
self.updatePersonEntry(resultSet[key]) |
|
return ret+"</body></html>" |
|
|
|
|
def updateHomepages_old(self,RESPONSE): |
def updateInstitutsbiliography(self): |
"""lege members an, alte version vollstaendige kopie aller fm-dateien per fm.jar""" |
"""update the Institutsbibliogrpahy""" |
self.upDateSQL('personalwww.xml') |
self.upDateSQL('personalwww.xml') |
founds=self.ZSQLInlineSearch(_table='personal_www',publish_the_data='yes') |
return "<html><body>DONE</body></html>" |
project=getattr(self,'members') |
|
for found in founds: |
|
|
|
if not (found.e_mail==""): |
|
newObj=MPIWGStaff.MPIWGStaff(found.username,found.name,found.vorname) |
|
|
|
try: |
def updatePersonalwww_html(self): |
project._setObject(found.username,newObj) |
"""update form for the homepages web form""" |
RESPONSE.write("<p>new:%s</p>\n"%found.username) |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','updatePersonalwww.zpt')).__of__(self) |
except: |
return pt() |
RESPONSE.write("<p>old:%s (%s,%s)</p>\n"%(found.username,found.name,found.vorname)) |
|
|
|
|
def updatePersonalwww(self,uploadfile): |
|
"""update personalwww |
|
@param uploadfile: file handle auf das file |
|
""" |
|
dsn=self.getConnectionObj().connection_string |
|
#dsn="dbname=personalwww" |
|
resultSet=updatePersonalWWW.importFMPXML(uploadfile) |
|
news,conflicts=updatePersonalWWW.checkImport(dsn, resultSet) |
|
|
|
self.REQUEST.SESSION['personal_www']={} |
|
self.REQUEST.SESSION['personal_www']['resultSet']=resultSet |
|
self.REQUEST.SESSION['personal_www']['news']=news |
|
self.REQUEST.SESSION['personal_www']['conflicts']=conflicts |
|
|
|
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','updatePersonalwww_check.zpt')).__of__(self) |
|
return pt() |
|
|
|
|
#delete non existing |
|
|
|
|
def reindexCatalogs(self,RESPONSE=None): |
|
"""reindex members and project catalog""" |
|
|
foundUserNames=[x.username for x in founds] |
|
for member in self.ZopeFind(self,obj_metatypes=["MPIWGStaff"],search_sub=1): |
|
|
|
if member[1].getId() not in foundUserNames: |
|
member[1].aq_parent.manage_delObjects(ids=[member[1].getId()]) |
|
RESPONSE.write("<p>deleted:%s</p>\n"%member[1].getId()) |
|
try: |
try: |
self.MembersCatalog.manage_catalogReindex(self.REQUEST,RESPONSE,self.REQUEST['URL1']) |
|
except: |
|
pass |
|
self.ProjectCatalog.manage_catalogReindex(self.REQUEST,RESPONSE,self.REQUEST['URL1']) |
self.ProjectCatalog.manage_catalogReindex(self.REQUEST,RESPONSE,self.REQUEST['URL1']) |
|
except: |
|
logger("MPIWG Root (updatehomepage)",logging.WARNING," %s %s"%sys.exc_info()[:2]) |
|
|
self.updatePublicationDB() |
|
|
|
if RESPONSE is not None: |
|
|
|
|
|
|
if RESPONSE: |
RESPONSE.redirect('manage_main') |
RESPONSE.redirect('manage_main') |
|
|
|
|
# def getAllMembers(self,reset=None): |
|
# """give list of all members""" |
|
# ret=[] |
|
# |
|
# |
|
# if reset or (getattr(self,'_v_membersList',None) is None): |
|
# for member in self.members._objects: |
|
# if member['meta_type']=='MPIWGStaff': |
|
# memberObj=getattr(self.members,member['id']) |
|
# if memberObj.isPublished(): |
|
# ret.append(memberObj.title.decode('utf-8')) |
|
# |
|
# ret.sort() |
|
# self._v_membersList=ret[0:] |
|
# print ret |
|
# |
|
# return self._v_membersList |
|
|
|
def getAllMembers(self): |
def getAllMembers(self): |
#ret=[] |
#ret=[] |
Line 1054 class MPIWGRoot(ZSQLExtendFolder):
|
Line 1086 class MPIWGRoot(ZSQLExtendFolder):
|
return entry |
return entry |
|
|
|
|
def getTree(self,dep=None,date=None,onlyActive=None): |
def getTree(self,dep=None,date=None,onlyActive=0,onlyArchived=0): |
"""generate Tree from project list""" |
"""generate Tree from project list |
|
als Liste, jeder Eintrag ist ein Tupel ,(Tiefe, ProjektNummer,ProjektObject |
|
onlyActive = 0 : alle Projekte |
|
onlyActive = 1 : nur active Projekte |
|
onlyActive = 2: nur inactive Projekte |
|
|
|
onlyArchived=0: alle Projekte |
|
onlyArchived= 1 : nur aktuelle Projekte |
|
onlyArchived = 2: nur archivierte Projekte |
|
""" |
|
|
|
returnListTmp=[] |
returnList=[] |
returnList=[] |
|
|
for project in self.getProjectFields('xdata_05',sort="int",date=date): # get Projects sorted by xdata_05 |
for project in self.getProjectFields('xdata_05',sort="int",date=date): # get Projects sorted by xdata_05 |
|
|
for idNr in project[1].split(";"): # more than one number |
for idNr in project[1].split(";"): # more than one number |
Line 1073 class MPIWGRoot(ZSQLExtendFolder):
|
Line 1116 class MPIWGRoot(ZSQLExtendFolder):
|
project[0].setActiveFlag(False) |
project[0].setActiveFlag(False) |
|
|
if (not dep) or (idNr[0]==dep): #falls dep gesetzt ist nur dieses hinzufuegen. |
if (not dep) or (idNr[0]==dep): #falls dep gesetzt ist nur dieses hinzufuegen. |
if onlyActive and project[0].isActiveProject(): #nur active projekte |
|
returnList.append((depth,nr,title,project[0])) |
|
elif not onlyActive: |
|
returnList.append((depth,nr,title,project[0])) |
|
return returnList |
|
|
|
def formatElementsAsList(self,elements,onlyOneDept=False): |
|
"""formatiere tree als liste""" |
|
|
|
actualDepth=0 |
|
ret="" |
|
for element in elements: |
|
if (element[0]>actualDepth): |
|
#fuege soviele ul ein wie unterschied in tiefe |
|
if element[0]==1: |
|
ret+="""<div class="dept">\n<ul class="liste">\n""" |
|
else: |
|
for i in range(element[0]-actualDepth): |
|
if i>0: |
|
ret+="<li>" |
|
ret+="""<ul class="liste">\n""" |
|
|
|
actualDepth=element[0] |
|
|
|
elif (element[0]<actualDepth): |
|
#fuege soviele /ul ein wie unterschied in tiefe |
|
for i in range(-element[0]+actualDepth): |
|
|
|
ret+="<br><br></li></ul>\n" |
|
|
|
#ret+="<br><br>\n</li>\n</ul>\n</li>\n" |
|
|
|
|
|
if element[0]==1: |
if (onlyActive==0): |
department=int(element[3].getContent('xdata_05'))-1 |
returnListTmp.append((depth,nr,title,project[0])) |
|
elif (onlyActive==1) and project[0].isActiveProject(): #nur active projekte |
|
returnListTmp.append((depth,nr,title,project[0])) |
|
elif (onlyActive==2) and (not project[0].isActiveProject()): #nur active projekte |
|
returnListTmp.append((depth,nr,title,project[0])) |
|
|
|
|
|
#filter jetzt die Liste nach Archived oder nicht |
|
for entry in returnListTmp: |
|
if (onlyArchived==0): |
|
returnList.append(entry) |
|
elif (onlyArchived==1) and (not entry[3].isArchivedProject()): #nur active projekte |
|
returnList.append(entry) |
|
elif (onlyArchived==2) and (entry[3].isArchivedProject()): #nur active projekte |
|
returnList.append(entry) |
|
|
ret+="""</ul></div>\n""" |
|
if department==4: #hack |
|
department=3 |
|
|
|
ret+="""<div class="bildspalte"><img src="../grafik/dept%i.jpg" width="160" height="120" vspace="40"></div> |
return returnList |
<div class="dept">\n<ul class="liste">\n |
|
"""%department |
|
|
|
actualDepth=element[0] |
|
else: |
|
ret+="""\n</li>\n""" |
|
ret+="""<li>\n""" |
|
|
|
if actualDepth==1: |
|
departmentName={'1':'Department I','2':'Department II','3':'Department III', '4':'Ind. Research Group','5':'Ind. Research Group','6':'Ind. Research Group','7':'Research Network'} |
|
department=element[3].getContent('xdata_05') |
|
if not onlyOneDept: |
|
ret+="""<a href="#top"><img src="../grafik/totop.gif" vspace="10" border="0"></a><br><a name="dept%s"></a>%s: """%(department,departmentName[department]) |
|
|
|
if self.REQUEST.has_key('date'): |
|
ret+="""<a href="%s?date=%s">%s</a>"""%(self.generateUrlProject(element[3].absolute_url())+"/index.html",self.REQUEST['date'],element[3].getContent('WEB_title')) |
|
else: |
|
ret+="""<a href="%s">%s</a>"""%(self.generateUrlProject(element[3].absolute_url())+"/index.html",element[3].getContent('WEB_title')) |
|
return ret |
|
|
|
def formatElementForOverview(self,element): |
|
"""format the element for output in overview""" |
|
if element[0]==1: #department |
|
#print element[3].getContent('xdata_05') |
|
if element[3].getContent('xdata_05') == "4": |
|
return """<h2 class="hier"><a href="%s">Ind. Research Group I: %s</a></h2>"""%(element[3].absolute_url()+"/index.html",element[3].getContent('WEB_title')) |
|
if element[3].getContent('xdata_05') == "5": |
|
return """<h2 class="hier"><a href="%s">Ind. Research Group II: %s</a></h2>"""%(element[3].absolute_url()+"/index.html",element[3].getContent('WEB_title')) |
|
if element[3].getContent('xdata_05') == "6": |
|
return """<h2 class="hier"><a href="%s">Research Network "History of Scientific Objects": %s</a></h2>"""%(element[3].absolute_url()+"/index.html",element[3].getContent('WEB_title')) |
|
|
|
return """<h2 class="hier"><a href="%s">Department %s: %s</a></h2>"""%(element[3].absolute_url()+"/index.html",element[3].getContent('xdata_05'),element[3].getContent('WEB_title')) |
|
|
|
elif element[0]==2: #mainprojects |
|
return """<h3 class="hier"><a href="%s">%s</a></h3><p>"""%(element[3].absolute_url()+"/index.html",element[3].getContent('WEB_title')) |
|
|
|
elif element[0]==3: |
|
return """<p class="hier"><a href="%s">%s</a></p>"""%(element[3].absolute_url()+"/index.html",element[3].getContent('WEB_title')) |
|
|
|
|
|
def changePosition(self,treeId,select,RESPONSE=None): |
def changePosition(self,treeId,select,RESPONSE=None): |
Line 1190 class MPIWGRoot(ZSQLExtendFolder):
|
Line 1175 class MPIWGRoot(ZSQLExtendFolder):
|
"""change the complete tree""" |
"""change the complete tree""" |
form=self.REQUEST.form |
form=self.REQUEST.form |
hashList={} |
hashList={} |
fields=self.getTree() |
onlyArchived=int(form.get("onlyArchived",0)) |
|
onlyActive=int(form.get("onlyActive",0)) |
|
|
|
|
|
fields=self.getTree(onlyArchived=onlyArchived,onlyActive=onlyActive) |
|
|
for idNr in form.keys(): |
logging.info("GOT TREE!----------------------------------------------------") |
|
for field in form.keys(): |
|
|
splitted=idNr.split('_') |
splitted=field.split('_') |
|
if (len(splitted)>1) and (splitted[1]=="runningNumber"): #feld hat die Form Nummer_name und runnignNumber |
|
|
if len(splitted)==1: # name des Feldes = idNr, dann Aendere id_nr |
|
if not (fields[int(idNr)][3].xdata_05==form[idNr]): |
|
fields[int(idNr)][3].xdata_05=form[idNr] |
|
fields[int(idNr)][3].copyObjectToArchive() |
|
|
|
if form.has_key(idNr+'_active'): # active flag is set |
nr=int(splitted[0]) # nummer des Datensatzes |
|
currentEntry = fields[nr] |
|
|
fields[int(splitted[0])][3].setActiveFlag(True) |
if form.has_key(str(nr)+'_active'): # active flag is set |
|
fields[nr][3].setActiveFlag(True) |
else: |
else: |
|
fields[nr][3].setActiveFlag(False) |
|
|
|
#nummer hat sich geŠndert |
|
|
|
entryChanged = False; |
|
|
|
|
|
if not (fields[nr][3].xdata_05==form[str(nr)+'_number']): |
|
logging.info("Changed!Number+++++++++++++++++++++++++++++++++") |
|
fields[nr][3].xdata_05=form[str(nr)+'_number'] |
|
entryChanged = True |
|
|
|
#completed har sich geaendert |
|
|
|
if not (fields[nr][3].getCompletedAt()==fields[nr][3].transformDate(form[str(nr)+'_completed'])): |
|
fields[nr][3].setCompletedAt(form[str(nr)+'_completed']) |
|
logging.info("Changed!Completed+++++++++++++++++++++++++++++++++") |
|
entryChanged = True |
|
|
|
|
|
if entryChanged: |
|
logging.info("Changed!+++++++++++++++++++++++++++++++++") |
|
fields[nr][3].copyObjectToArchive() |
|
|
fields[int(splitted[0])][3].setActiveFlag(False) |
|
|
|
if RESPONSE is not None: |
if RESPONSE is not None: |
RESPONSE.redirect('showTree') |
RESPONSE.redirect('showTree') |
Line 1270 class MPIWGRoot(ZSQLExtendFolder):
|
Line 1280 class MPIWGRoot(ZSQLExtendFolder):
|
|
|
if not search=='': |
if not search=='': |
try: |
try: |
|
|
member=self.MembersCatalog({'title':search}) |
member=self.MembersCatalog({'title':search}) |
|
|
except: |
except: |
member=None |
member=None |
|
if member: |
|
logging.error("search publ %s:"%member[0].getObject().isPublished()) |
if member and (member[0].getObject().isPublished()): |
if member and (member[0].getObject().isPublished()): |
if person =="Otto Sibum" : person="H. Otto Sibum" |
if person =="Otto Sibum" : person="H. Otto Sibum" |
if person =="Norton Wise" : person="M. Norton Wise" |
if person =="Norton Wise" : person="M. Norton Wise" |
|
|
#memberlist.append("<a href=%s >%s</a>"%(member[0].absolute_url,person.encode('utf-8'))) |
#memberlist.append("<a href=%s >%s</a>"%(member[0].absolute_url,person.encode('utf-8'))) |
memberlist.append((person, member[0].getObject().getId())) |
memberlist.append((person, member[0].getObject().getId())) |
else: |
else: |
Line 1332 class MPIWGRoot(ZSQLExtendFolder):
|
Line 1346 class MPIWGRoot(ZSQLExtendFolder):
|
|
|
return ret |
return ret |
|
|
def getProjectsOfMember(self,name=None,email=None,date=None): |
def getProjectsOfMember(self,name=None,key=None,date=None,onlyArchived=1): |
"""get project of a member""" |
"""get projects of a member |
|
@param name: (optional)Vorname + Nachname |
|
@param key: (optional) Key zur Idenfikation des Benutzer |
|
@param date: (optional) Version die zum Zeitpunkt date gueltig war |
|
@param onlyArchived: |
|
onlyArchived=0: alle Projekte |
|
onlyArchived= 1 : nur aktuelle Projekte |
|
onlyArchived = 2: nur archivierte Projekte |
|
""" |
|
# TODO: Die ganze Loesung |
def sortP(x,y): |
def sortP(x,y): |
"""sort by sorting number""" |
"""sort by sorting number""" |
#print x.xdata_05,y.xdata_05 |
|
return cmp(x.WEB_title,y.WEB_title) |
return cmp(x.WEB_title,y.WEB_title) |
|
|
|
|
ret=[] |
ret=[] |
splitNeu=[] |
if key: |
if email: |
|
|
members=self.MembersCatalog({'getKey':key}) |
|
if len(members)==0: |
|
return ret |
|
splitted = [members[0].lastName,members[0].firstName] |
|
|
|
elif name: |
|
|
|
splitted=name.split(",") |
|
else: |
|
return ret # name oder key mussen definiert sein |
|
|
members=self.ZopeFind(self.members,obj_metatypes=['MPIWGStaff'],obj_ids=[email],search_sub=1) |
|
name = members[0][1].title.decode('utf-8') |
|
|
|
y=name |
|
splitted=y.split(",") |
|
#XXXX |
|
splitNeu=["\'"+splitted[1]+" "+splitted[0]+"\'"] |
splitNeu=["\'"+splitted[1]+" "+splitted[0]+"\'"] |
|
|
#for s in splitted: |
|
# splitNeu.append("\""+s+"\"") |
|
search=string.join(splitNeu,' AND ') |
search=string.join(splitNeu,' AND ') |
|
|
proj=self.ProjectCatalog({'xdata_01':search}) |
proj=self.ProjectCatalog({'xdata_01':search}) |
Line 1362 class MPIWGRoot(ZSQLExtendFolder):
|
Line 1386 class MPIWGRoot(ZSQLExtendFolder):
|
proj2=[] |
proj2=[] |
for x in proj: |
for x in proj: |
if (not getattr(x.getObject(),'invisible',None)) and (getattr(x.getObject(),'archiveTime','')==''): |
if (not getattr(x.getObject(),'invisible',None)) and (getattr(x.getObject(),'archiveTime','')==''): |
if not((splitted[1]==" Christoph") and (splitted[0]=="Hoffmann") and (str(x.WEB_title).find('Einstein')>0)): |
# furchtbarer hack um sicher zustellen dass christoph hoffmann nicht mit Dieter Hoffmann verwechselt wird. |
|
|
|
if not((splitted[1]=="Christoph") and (splitted[0]=="Hoffmann") and ( (("%s"%x.WEB_title).find('Einstein')>0) or (("%s"%x.WEB_title).find('Quantum')>0))): |
|
logging.info("XXXXXXXXXXXXXXXXXXXXXXXX") |
proj2.append(x) |
proj2.append(x) |
|
|
else: |
else: |
Line 1379 class MPIWGRoot(ZSQLExtendFolder):
|
Line 1406 class MPIWGRoot(ZSQLExtendFolder):
|
|
|
proj2.sort(sortP) |
proj2.sort(sortP) |
|
|
if len(proj2)>0: |
projectListe=[] |
ret.append((y,proj2)) |
|
|
for proj in proj2: |
|
obj=proj.getObject() |
|
if onlyArchived==1: #nur aktuell projecte |
|
if not obj.isArchivedProject(): |
|
projectListe.append(proj) |
|
elif onlyArchived==2: #nur archivierte |
|
if obj.isArchivedProject(): |
|
projectListe.append(proj) |
|
else: #alle |
|
projectListe.append(proj) |
|
|
|
|
|
|
|
if len(projectListe)>0: |
|
ret.append((name,projectListe)) |
|
|
return ret |
return ret |
|
|
Line 1426 class MPIWGRoot(ZSQLExtendFolder):
|
Line 1468 class MPIWGRoot(ZSQLExtendFolder):
|
## objs.append((obj,lastName+", "+firstName)) |
## objs.append((obj,lastName+", "+firstName)) |
|
|
|
|
return objs |
## return objs |
|
|
|
|
def personCheck(self,names): |
def personCheck(self,names): |
Line 1541 class MPIWGRoot(ZSQLExtendFolder):
|
Line 1583 class MPIWGRoot(ZSQLExtendFolder):
|
|
|
|
|
dh=getattr(self,'deletedHistoricalNames',{}) |
dh=getattr(self,'deletedHistoricalNames',{}) |
|
|
|
if type(dh) is ListType: |
|
dh={} |
if not dh.has_key(name): |
if not dh.has_key(name): |
dh=occurrances.split("\n") |
dh[name]=occurrances.split("\n") |
else: |
else: |
dh+=occurrances.split("\n") |
dh[name]+=occurrances.split("\n") |
|
|
self.deletedHistoricalNames=dh |
self.deletedHistoricalNames=dh |
|
|
Line 1574 class MPIWGRoot(ZSQLExtendFolder):
|
Line 1619 class MPIWGRoot(ZSQLExtendFolder):
|
self.nameIndexEdited=self.nameIndex |
self.nameIndexEdited=self.nameIndex |
return "done" |
return "done" |
|
|
def changeHistoricalNames(self,projId,nameListTmp): |
|
"""add resp change nameIndexEdited b |
|
y adding/changing names menitionen in project projId""" |
|
|
|
#clear namelist from blanks |
|
nameList=[x.lstrip().rstrip() for x in nameListTmp] |
|
|
|
nI=self.nameIndexEdited |
|
for name in nameList: |
|
if not nI.has_key(name): #neuer Name |
|
nI[name]=[projId] |
|
|
|
for name in nI.keys(): |
|
|
|
if name in nameList: #checke if name in name List |
|
|
|
if not(projId in nI[name]): #nicht in listt -> hinzufuegen |
|
|
|
nI[name].append(projId) |
|
|
|
"""loesche falls projekt in nI list aber der name nicht mehr |
|
in der namensliste des projectes auftaucht |
|
""" |
|
|
|
for pr in nI[name]: |
|
|
|
if (pr==projId) and (not name in nameList): |
|
|
|
nI[name].remove(pr) |
|
|
|
self.nameIndexEdited=nI |
|
|
|
|
|
|
|
def manage_addMPIWGRootForm(self): |
def manage_addMPIWGRootForm(self): |
Line 1675 class MPIWGProject(CatalogAware,Folder):
|
Line 1688 class MPIWGProject(CatalogAware,Folder):
|
meta_type='MPIWGProject' |
meta_type='MPIWGProject' |
default_catalog='ProjectCatalog' |
default_catalog='ProjectCatalog' |
|
|
|
def decode(self,str): |
|
"""return unicode object""" |
|
return unicodify(str) |
|
|
def sortedByPlace(self,metatype): |
def sortedByPlace(self,metatype): |
"""find metatype and sort by place""" |
"""find metatype and sort by place""" |
Line 1718 class MPIWGProject(CatalogAware,Folder):
|
Line 1734 class MPIWGProject(CatalogAware,Folder):
|
for split in splitted[1:]: |
for split in splitted[1:]: |
tmp=split.split("</p>") |
tmp=split.split("</p>") |
#return repr(splitted[1]) |
#return repr(splitted[1]) |
|
|
try: |
try: |
imageURLs.append(tmp[0].split("\"")[1].encode('utf-8')) |
imageURLs.append(tmp[0].split("\"")[1].encode('utf-8')) |
except: |
except: |
|
|
|
try: |
imageURLs.append(tmp[0].split("src=")[1].split(" ")[0].encode('utf-8')) |
imageURLs.append(tmp[0].split("src=")[1].split(" ")[0].encode('utf-8')) |
|
except: |
|
imageURLs.append("") |
|
|
split2="</p>".join(tmp[1:]) |
split2="</p>".join(tmp[1:]) |
|
|
Line 1738 class MPIWGProject(CatalogAware,Folder):
|
Line 1759 class MPIWGProject(CatalogAware,Folder):
|
imageCaptions.append("") |
imageCaptions.append("") |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#eintragen: |
#eintragen: |
for imageURL in imageURLs: |
for imageURL in imageURLs: |
filename=imageURL.split("/")[-1] |
filename=imageURL.split("/")[-1] |
Line 1763 class MPIWGProject(CatalogAware,Folder):
|
Line 1779 class MPIWGProject(CatalogAware,Folder):
|
try:#absolute |
try:#absolute |
data=urllib.urlopen(self.imageURL).read() |
data=urllib.urlopen(self.imageURL).read() |
except: |
except: |
zLOG.LOG("MPIWG Project",zLOG.ERROR,"can't open: %s"%url) |
logger("MPIWG Project",logging.ERROR,"can't open: %s"%url) |
|
|
obj=getattr(self,filename) |
obj=getattr(self,filename) |
obj.update_data(data) |
obj.update_data(data) |
Line 1871 class MPIWGProject(CatalogAware,Folder):
|
Line 1887 class MPIWGProject(CatalogAware,Folder):
|
|
|
def getImages(self): |
def getImages(self): |
"""get all Images""" |
"""get all Images""" |
|
|
def sort_images(x,y): |
def sort_images(x,y): |
return cmp(getattr(x[1],'place',0),getattr(y[1],'place',0)) |
return cmp(getattr(x[1],'place',0),getattr(y[1],'place',0)) |
|
|
|
|
|
if (getattr(self,'imageURL','')!='') or (getattr(self,'imagecap','')!='') : |
|
try: |
|
self.addImage(None,getattr(self,'imagecap',''),RESPONSE=None,filename=getattr(self,'imageURL','')) |
|
except: |
|
pass |
|
self.imageURL='' |
|
self.imagecap='' |
|
|
images=self.ZopeFind(self,obj_metatypes=['MPIWGProject_image']) |
images=self.ZopeFind(self,obj_metatypes=['MPIWGProject_image']) |
|
|
images.sort(sort_images) |
images.sort(sort_images) |
Line 1894 class MPIWGProject(CatalogAware,Folder):
|
Line 1920 class MPIWGProject(CatalogAware,Folder):
|
RESPONSE.redirect('manageImages') |
RESPONSE.redirect('manageImages') |
|
|
|
|
def hasChildren(self,date=None,onlyActive=True): |
def hasChildren(self,date=None,onlyActive=1,onlyArchived=1): |
"""check if project has children""" |
"""check if project has children""" |
ct=self.getContexts(childs=self.getContent('xdata_05'), |
ct=self.getContexts(childs=self.getContent('xdata_05'), |
depth=1,date=date,onlyActive=onlyActive) |
depth=1,date=date,onlyActive=onlyActive) |
Line 1904 class MPIWGProject(CatalogAware,Folder):
|
Line 1930 class MPIWGProject(CatalogAware,Folder):
|
else: |
else: |
return False |
return False |
|
|
|
|
def addImage(self,fileHd,caption,RESPONSE=None,filename=None): |
def addImage(self,fileHd,caption,RESPONSE=None,filename=None): |
"""add an MPIWG_Project_image""" |
"""add an MPIWG_Project_image""" |
|
|
Line 1920 class MPIWGProject(CatalogAware,Folder):
|
Line 1947 class MPIWGProject(CatalogAware,Folder):
|
obj.caption=caption[0:] |
obj.caption=caption[0:] |
obj.enabled=True; |
obj.enabled=True; |
obj.place=self.getLastImageNumber()+1 |
obj.place=self.getLastImageNumber()+1 |
|
obj.id=filename |
|
|
if RESPONSE is not None: |
if RESPONSE is not None: |
RESPONSE.redirect('manageImages') |
RESPONSE.redirect('manageImages') |
Line 2087 class MPIWGProject(CatalogAware,Folder):
|
Line 2115 class MPIWGProject(CatalogAware,Folder):
|
"""check if the project is still active, default is true, set to false is the project is accomplished""" |
"""check if the project is still active, default is true, set to false is the project is accomplished""" |
return getattr(self,'isActiveFlag',True) |
return getattr(self,'isActiveFlag',True) |
|
|
|
def isArchivedProject(self): |
|
"""check if the project is archived""" |
|
|
|
completed=getattr(self,'completedAt',0) |
|
|
|
#completed leer |
|
if completed=="" : |
|
return False; |
|
if completed == 0: |
|
return False; |
|
|
|
|
|
return True |
|
|
|
|
def setActiveFlag(self,status=True): |
def setActiveFlag(self,status=True): |
"""set the active flag""" |
"""set the active flag""" |
self.isActiveFlag=status |
self.isActiveFlag=status |
|
|
|
def setCompletedAt(self,date): |
|
"""set the date of completion, date should be in the form DD.MM.YYYY or MM.YYYY or YYYY""" |
|
logging.info("DATE:"+repr(date)) |
|
transformedDate=self.transformDate(date); |
|
logging.info("transformed"+repr(transformedDate)) |
|
if transformedDate is not None: |
|
setattr(self,"completedAt",transformedDate) |
|
return True; |
|
else: |
|
return False; |
|
|
|
def getCompletedAt(self): |
|
"""gibt das transformierte Datum zurŸck""" |
|
date=getattr(self,'completedAt','') |
|
if date: |
|
return self.reTransformDate(date); |
|
else: |
|
return ''; |
|
|
|
def reTransformDate(self,date): |
|
"""transformiert , transformdate zurueck""" |
|
year=int(date/10000) |
|
month=int((date-year*10000)/100) |
|
day=int((date-year*10000-month*100)) |
|
return """%s.%s.%s"""%(day,month,year); |
|
|
|
|
|
def transformDate(self,date): |
|
"""transformiert ein Datum von DD.MM.YYYY, MM.YYYY,YYYY nach YYYYMMDD, alle nicht angebebenn Werte |
|
werden auf 0 gesetzt, es wird null zurŸckgegeben falls das Datum ungueltig ist""" |
|
|
|
if (date=="" ) : |
|
return ""; |
|
|
|
if (date==None): |
|
return None; |
|
|
|
splitted=date.split(".") |
|
length=len(splitted) |
|
year=0 |
|
month=0 |
|
day=0 |
|
if length > 3: |
|
return ""; |
|
if length==3: |
|
day = int(splitted[0]) |
|
if length>1: |
|
month=int(splitted[length-2]) |
|
|
|
if length > 0: |
|
try: |
|
year = int(splitted[length-1]) |
|
except: |
|
pass |
|
|
|
## logging.info("month:"+(month)) |
|
if not (0<=month<13): |
|
return None; |
|
|
|
if not(0<=day<32): |
|
return None; |
|
|
|
if (year>0) and (year<1900): #jahr nicht vierstellig eingegeben |
|
year=2000+year; |
|
return year*10000+month*100+day |
|
|
|
|
|
|
def checkDate(self,date): |
def checkDate(self,date): |
"""teste ob zum Zeitpunkt date eine andere version existierte""" |
"""teste ob zum Zeitpunkt date eine andere version existierte""" |
|
|
Line 2312 class MPIWGProject(CatalogAware,Folder):
|
Line 2423 class MPIWGProject(CatalogAware,Folder):
|
try: |
try: |
self.imageURL=tmp[0].split("\"")[1].encode('utf-8') |
self.imageURL=tmp[0].split("\"")[1].encode('utf-8') |
except: |
except: |
|
try: |
self.imageURL=tmp[0].split("src=")[1].split(" ")[0].encode('utf-8') |
self.imageURL=tmp[0].split("src=")[1].split(" ")[0].encode('utf-8') |
|
except: |
|
self.imageURL="" |
|
|
split2="</p>".join(tmp[1:]) |
split2="</p>".join(tmp[1:]) |
|
|
Line 2342 class MPIWGProject(CatalogAware,Folder):
|
Line 2456 class MPIWGProject(CatalogAware,Folder):
|
|
|
#filter image |
#filter image |
|
|
|
text5=text5.lstrip().rstrip() #loescher leerzeichen und einzelndes br |
|
if (text5=="<br>") or (text5=="<br/>"): |
|
text5="" |
|
|
|
logging.debug("getcontent: field=%s filter=%s -> %s"%(field,filter,repr(text5))) |
|
#return unicodify(text5) |
|
return utf8ify(text5) # return as utf-8 byte string |
|
|
return text5.encode('utf-8') |
|
|
|
def showImagesOfPage(self,imageUrl=None): |
def showImagesOfPage(self,imageUrl=None): |
"""show Images of project""" |
"""show Images of project""" |
Line 2463 class MPIWGProject(CatalogAware,Folder):
|
Line 2583 class MPIWGProject(CatalogAware,Folder):
|
setattr(self,x,[self.REQUEST[x].decode('utf-8')]) |
setattr(self,x,[self.REQUEST[x].decode('utf-8')]) |
|
|
|
|
|
completedAt = self.REQUEST.get('completedAt') |
|
if not self.setCompletedAt(completedAt): |
|
RESPONSE.redirect('./editMPIWGBasisEditor?error="dateWrong') |
|
|
if self.REQUEST.has_key('historicalNames'): |
if self.REQUEST.has_key('historicalNames'): |
self.en.changeHistoricalNames(self.getId(),self.REQUEST['historicalNames'].split("\n")) |
self.en.changeHistoricalNames(self.getId(),self.REQUEST['historicalNames'].split("\n")) |
|
|