[BACK]Return to MPIWGProjects.py CVS log [TXT] [DIR] Up to [Repository] / MPIWGWeb

Diff for /MPIWGWeb/MPIWGProjects.py between versions 1.47.2.66 and 1.47.2.74

version 1.47.2.66, 2006/11/08 21:04:23 version 1.47.2.74, 2007/04/19 13:32:35
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 143  class MPIWGLink(SimpleItem): Line 149  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 173  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 251  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 307  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 515  class MPIWGRoot(ZSQLExtendFolder): Line 525  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 696  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 771  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 804  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)
                   
         memberList=[x[0] for x in members]              qstr="select * from personal_www where key=%s"%self.ZSQLQuote(k)
         #print dom              res=self.ZSQLQuery(qstr)[0]
         #ctx=Context(dom,processorNss={EMPTY_NAMESPACE:'http://www.filemaker.com/fmpdsoresult'})              if args[key]!="": #email-adresse wurde eingetragen
         # Evaluate(u".//dn:ROW",contextNode=dom,explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})                  #create the object
         #print dom.xpath(u'.//dn:ROW',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})                  e_mail=args[key]
         for row in dom.xpath(u'.//dn:ROW',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'}):                  try:
                               newObj=MPIWGStaff.MPIWGStaff(e_mail,res.last_name.encode('utf-8'),res.first_name.encode('utf-8'),k)
             username=getTextFromNode(row.xpath('./dn:username',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0])                      memberFolder._setObject(e_mail,newObj)
             id=getTextFromNode(row.xpath('./dn:ID',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0])                      obj=getattr(memberFolder,e_mail)
             name=getTextFromNode(row.xpath('./dn:Name',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0])                      obj.reindex_object()
             vorname=getTextFromNode(row.xpath('./dn:Vorname',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0])                      ret+="Created %s \n"%e_mail
             title=getTextFromNode(row.xpath('./dn:Title',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0])                      created=True
             position=getTextFromNode(row.xpath('./dn:Position',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0])                  except:
             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])                      msg="Cannot create new user %s (%s %s)"%(e_mail,sys.exc_info()[0],sys.exc_info()[1])
             date_from=getTextFromNode(row.xpath('./dn:Date_from',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0])                      logging.error(msg)
             date_to=getTextFromNode(row.xpath('./dn:Date_to',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0])                      ret+=msg+"\n"
             abteilung=getTextFromNode(row.xpath('./dn:Abteilung',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0])                      created=False
             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])                  if created:
             e_mail2=getTextFromNode(row.xpath('./dn:e_mail2',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0])                      qstr="update personal_www set web_object_created='yes',e_mail='%s' where key=%s"%(e_mail,self.ZSQLQuote(k))
             publish_the_data=getTextFromNode(row.xpath('./dn:publish_the_data',explicitNss={'dn':'http://www.filemaker.com/fmpdsoresult'})[0])                      self.ZSQLQuery(qstr)
             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)          return ret
                                   
                 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,      def generateNewPersonEntry(self,data):
                                           vorname,username,title,position,e_mail,          """generate a new person entry for data, neue personen werden zunaechst nur in der datenbank angelegt """
                                           e_mail_p,date_from,date_to,  
                                           abteilung,heimat_inst,funded_by,  
                                           e_mail2,txt,txt_p,stay_at_mpiwg)  
                     if not ret[0]:  
   
                             RESPONSE.write("<p>Error: %s</p>\n"%repr(ret[1]))          #memberFolder=getattr(self,'members')
                     else:          #create the object
                         RESPONSE.write("<p>New: %s</p>\n"%repr(ret[1]))  
   
         #TODO: reindexCatlogs and updatePublications wieder einbaue  #        try:
         #self.reindexCatalogs(RESPONSE)  #            newObj=MPIWGStaff.MPIWGStaff(urllib.quote(data['key']),data['last_name'].encode('utf-8'),data['first_name'].encode('utf-8')) 
   #            memberFolder._setObject(urllib.quote(data['key']),newObj)
   #        except:
   #            return False, "Cannot create new user %s (%s %s)"%(data['key'],sys.exc_info()[0],sys.exc_info()[1])
   #        
           
         #self.updatePublicationDB()          #create the new entry in the database
     
         #self.ZSQLResetConnection()  
         RESPONSE.write("<h2>Done</h2></body></html>")  
                                         
         return True          result,msg=MPIWGStaff.createNewDBEntry(self,data['publish_the_data'],data['key'],data['last_name'],
                                     data['first_name'],data['title'],data['status'],"",
                                     "",data['date_from'],data['date_to'],
                                     data['department'],data['home_inst'],data['funded_by'],
                                     data['e_mail2'],data['current_work'],"yes",data['date_stay_at_mpiwg'],data['group'],"no",data['current_work'])
             
     def reindexCatalogs(self,RESPONSE=None):          return result,msg
         """reindex members and project catalog"""  
                   
       def updatePersonEntry(self,data,ignoreEntries=[]):
           """update an person entry from data. but ignore all fields in ignore Entries"""
                   
         try:          ignoreEntries.append('current_work') # TODO:updatecurrent work
             self.MembersCatalog.manage_catalogReindex(self.REQUEST,RESPONSE,self.REQUEST['URL1'])  
             self.ProjectCatalog.manage_catalogReindex(self.REQUEST,RESPONSE,self.REQUEST['URL1'])  
         except:  
             zLOG.LOG("MPIWG Root (updatehomepage)",zLOG.WARNING," %s %s"%sys.exc_info()[:2])  
                           
           if data['date_to']=="": # wenn date_to leer
                data['date_to']="date_none"
                   
           if data['date_from']=="": # wenn date_fromleer
                data['date_from']="date_none"
           msg=""
           
                   
           #eintragen
                         
         if RESPONSE:          columns=data.keys()
             RESPONSE.redirect('manage_main')          for x in ignoreEntries:
               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:
                   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)
                   
     def updateHomepages_old(self,RESPONSE):          return True,msg
         """lege members an, alte version vollstaendige kopie aller fm-dateien per fm.jar"""      def updatePersonalwww_doIt(self):
         self.upDateSQL('personalwww.xml')          """do the update"""
         founds=self.ZSQLInlineSearch(_table='personal_www',publish_the_data='yes')          args=self.REQUEST.form
         project=getattr(self,'members')          resultSet=self.REQUEST.SESSION['personal_www']['resultSet']
         for found in founds:          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>Bei €nderung belassen</h2>"
               ret+="<p>Bitte die Filemaker-db entsprehchend Š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>"
                           
             if not (found.e_mail==""):      def updateInstitutsbiliography(self):
                 newObj=MPIWGStaff.MPIWGStaff(found.username,found.name,found.vorname)          """update the Institutsbibliogrpahy"""
           self.upDateSQL('personalwww.xml')
           return "<html><body>DONE</body></html>"
       def updatePersonalwww_html(self):
           """update form for the homepages web form"""
           pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','updatePersonalwww.zpt')).__of__(self)
           return pt()
                                   
                 try:      def updatePersonalwww(self,uploadfile):
                     project._setObject(found.username,newObj)          """update personalwww
                     RESPONSE.write("<p>new:%s</p>\n"%found.username)          @param uploadfile: file handle auf das file
                 except:          """
                     RESPONSE.write("<p>old:%s (%s,%s)</p>\n"%(found.username,found.name,found.vorname))          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 1079  class MPIWGRoot(ZSQLExtendFolder): Line 1074  class MPIWGRoot(ZSQLExtendFolder):
                           returnList.append((depth,nr,title,project[0]))                            returnList.append((depth,nr,title,project[0]))
         return returnList          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:  
                     department=int(element[3].getContent('xdata_05'))-1  
                       
                     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>  
                     <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 1332  class MPIWGRoot(ZSQLExtendFolder): Line 1254  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):
         """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
           """
           # TODO: Die ganze Lšsung
         def sortP(x,y):          def sortP(x,y):
             """sort by sorting number"""              """sort by sorting number"""
             #print x.xdata_05,y.xdata_05              #print x.xdata_05,y.xdata_05
Line 1341  class MPIWGRoot(ZSQLExtendFolder): Line 1268  class MPIWGRoot(ZSQLExtendFolder):
                   
                 
         ret=[]          ret=[]
         splitNeu=[]          logging.error("XXXXXXXXXXXXXXXXX")
         if email:          if key:
                           
             members=self.ZopeFind(self.members,obj_metatypes=['MPIWGStaff'],obj_ids=[email],search_sub=1)              #members=self.ZopeFind(self.members,obj_metatypes=['MPIWGStaff'],obj_ids=[email],search_sub=1)
             name =  members[0][1].title.decode('utf-8')              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
   
         y=name  
         splitted=y.split(",")  
         #XXXX          #XXXX
         splitNeu=["\'"+splitted[1]+" "+splitted[0]+"\'"]          splitNeu=["\'"+splitted[1]+" "+splitted[0]+"\'"]
                   
Line 1357  class MPIWGRoot(ZSQLExtendFolder): Line 1292  class MPIWGRoot(ZSQLExtendFolder):
         search=string.join(splitNeu,' AND ')          search=string.join(splitNeu,' AND ')
                   
         proj=self.ProjectCatalog({'xdata_01':search})          proj=self.ProjectCatalog({'xdata_01':search})
           logging.error("XXXXXXXXXXX %s"%proj)
         if proj:          if proj:
             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','')==''):
                       # furchtbarer hack um sicher zustellen dass christoph hoffmann nicht mit Dieter Hoffmann verwechselt wird.
                     if not((splitted[1]==" Christoph") and (splitted[0]=="Hoffmann") and (str(x.WEB_title).find('Einstein')>0)):                      if not((splitted[1]==" Christoph") and (splitted[0]=="Hoffmann") and (str(x.WEB_title).find('Einstein')>0)):
                        proj2.append(x)                         proj2.append(x)
   
Line 1380  class MPIWGRoot(ZSQLExtendFolder): Line 1316  class MPIWGRoot(ZSQLExtendFolder):
         proj2.sort(sortP)          proj2.sort(sortP)
   
         if len(proj2)>0:          if len(proj2)>0:
             ret.append((y,proj2))              ret.append((name,proj2))
   
         return ret          return ret
             
Line 1426  class MPIWGRoot(ZSQLExtendFolder): Line 1362  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 1477  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 1513  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 1718  class MPIWGProject(CatalogAware,Folder): Line 1625  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 1650  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 1670  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 1778  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 1904  class MPIWGProject(CatalogAware,Folder): Line 1821  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 1838  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 2312  class MPIWGProject(CatalogAware,Folder): Line 2231  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 2264  class MPIWGProject(CatalogAware,Folder):
   
         #filter image          #filter image
                   
           text5=text5.lstrip().rstrip() #loescher leerzeichen und einzelndes br
       if (text5=="<br>") or (text5=="<br/>"):
           text5=""
   
         return text5.encode('utf-8')          return text5.encode('utf-8')
   
Line 2462  class MPIWGProject(CatalogAware,Folder): Line 2387  class MPIWGProject(CatalogAware,Folder):
                                   
                 setattr(self,x,[self.REQUEST[x].decode('utf-8')])                  setattr(self,x,[self.REQUEST[x].decode('utf-8')])
   
   
           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"))
                   
         if self.REQUEST.has_key('active'):          if self.REQUEST.has_key('active'):
Removed from v.1.47.2.66  
changed lines
  Added in v.1.47.2.74

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>