Annotation of MPIWGWeb/MPIWGRoot.py, revision 1.1.2.9

1.1.2.1   dwinter     1: from Products.PageTemplates.PageTemplateFile import PageTemplateFile
                      2: from Products.PageTemplates.PageTemplate import PageTemplate
                      3: from Products.PageTemplates.ZopePageTemplate import ZopePageTemplate
                      4: from Products.ZSQLExtend.ZSQLExtend import ZSQLExtendFolder
                      5: from Products.ZCatalog.CatalogPathAwareness import CatalogAware
                      6: from OFS.Image import Image
                      7: from Globals import package_home
                      8: import urllib
                      9: import MPIWGStaff
                     10: import string
                     11: import re
                     12: import os
                     13: from types import *
                     14: import logging
                     15: import xmlhelper # Methoden zur Verwaltung der projekt xml
                     16: from OFS.SimpleItem import SimpleItem
                     17: from OFS.Folder import Folder
                     18: from Products.ZSQLMethods.SQL import SQLConnectionIDs
                     19: from AccessControl import ClassSecurityInfo
                     20: from bibliography import *
                     21: import time
                     22: import xml.dom.minidom
                     23: import sys
                     24: from Ft.Xml.XPath import Evaluate
                     25: from Ft.Xml.XPath.Context import Context
                     26: from Ft.Xml.Domlette import NonvalidatingReader,PrettyPrint, Print
                     27: from Ft.Xml import EMPTY_NAMESPACE
                     28: import copy
                     29: import updatePersonalWWW
                     30: import MPIWGStaff
                     31: from MPIWGHelper import *
                     32: 
1.1.2.6   casties    33: 
                     34: def sortWeight(x,y):
                     35:     x1=int(getattr(x[1],'weight','0'))
                     36:     y1=int(getattr(y[1],'weight','0'))
                     37:     return cmp(x1,y1)
                     38: 
                     39: 
1.1.2.1   dwinter    40: class MPIWGRoot(ZSQLExtendFolder):
                     41:     """Stammordner fuer den Web-Server"""
                     42: 
1.1.2.6   casties    43:     fieldLabels={'WEB_title':'WEB_Title',
                     44:                  'xdata_01':'Responsible Scientists',
                     45:                  'xdata_02':'Department',
                     46:                  'xdata_03':'Historical Persons',
                     47:                  'xdata_04':'Time period',
                     48:                  'xdata_05':'Sorting number',
                     49:                  'xdata_06':'Keywords',
                     50:                  'xdata_07':'Short title',
                     51:                  'xdata_08':'Other involved scholars' ,
                     52:                  'xdata_09':'Disciplines',
                     53:                  'xdata_10':'Themes',
                     54:                  'xdata_11':'Object Digitallibrary',
                     55:                  'xdata_12':'Cooperation partners',
                     56:                  'xdata_13':'Funding institutions',
                     57:                  'WEB_project_header':'WEB_project_header',
                     58:                  'WEB_project_description':'WEB_project_description',
                     59:                  'WEB_related_pub':'WEB_related_pub'}
1.1.2.1   dwinter    60:     
                     61:     folders=['MPIWGProject','Folder','ECHO_Navigation']
                     62:     meta_type='MPIWGRoot'
                     63: 
1.1.2.9 ! dwinter    64:     def copyAllImagesToMargin(self):
        !            65:         """tranformiere alle Bilder in die Margins"""
        !            66:         projects=self.getTree()
        !            67:         ret=""
        !            68:         for project in projects:
        !            69:             proj=project[3]
        !            70:             try:
        !            71:                 persons=proj.copyImageToMargin();
        !            72:             except:
        !            73:                 logging.error("Cannnot do: %s"%repr(project))
        !            74:                 
1.1.2.1   dwinter    75:     def transformProjectsToId(self):
                     76:         """trnasformiere zu ID, Hilfsfunktion die die alten Templates analysiert und mit der neuen Liste
                     77:         verantwortlicher Personen versieht"""
                     78:         projects=self.getTree()
                     79:         ret=""
                     80:         for project in projects:
                     81:             proj=project[3]
                     82:             persons=proj.identifyNames(proj.getContent('xdata_01'))
                     83:             if not hasattr(proj,'responsibleScientistsList'):
                     84:                         proj.responsibleScientistsList=[]
                     85:                         
                     86:             for person in persons.items():
1.1.2.2   dwinter    87:               
1.1.2.1   dwinter    88:                 if len(person[1]) >1: #nicht eindeutig
                     89:                     ret+="nicht eindeutig ---  %s:  %s\n"%(proj.getId(),person[0])
                     90:                     
                     91:                 elif len(person[1]) ==0: #kein eintrage
                     92:                     ret+="kein eintrag---  %s:  %s\n"%(proj.getId(),person[0])
                     93:                     proj.responsibleScientistsList.append((person[0],""))
                     94:                 else:           
                     95:                     proj.responsibleScientistsList.append((person[0],person[1][0].getObject().getKey()))
                     96:         
                     97:         return ret
1.1.2.9 ! dwinter    98:           
1.1.2.1   dwinter    99:                 
                    100:     def harvestProjects(self):
                    101:         """harvest"""
                    102:         folder="/tmp"
                    103:         try:
                    104:             os.mkdir("/tmp/harvest_MPIWG")
                    105:         except:
                    106:             pass
                    107:         founds=self.ZopeFind(self.aq_parent.projects,obj_metatypes=['MPIWGProject'],search_sub=1)
                    108:         for found in founds:
                    109:             txt=found[1].harvest_page()
                    110:         
                    111:             if txt and (txt != ""):
                    112:                 name=found[0].replace("/","_")
                    113:                 fh=file("/tmp/harvest_MPIWG/"+name,"w")
                    114:                 fh.write(txt)
                    115:                 fh.close()
                    116:                 
                    117:     def decode(self,str):
                    118:         """decoder"""
1.1.2.3   dwinter   119: 
1.1.2.1   dwinter   120:         if not str:
                    121:             return ""
                    122:         if type(str) is StringType:
                    123:             try:            
                    124:                 return str.decode('utf-8')
                    125:             except:
                    126:                 return str.decode('latin-1')
                    127:         else:
                    128:             return str
                    129: 
                    130: 
                    131:     def getat(self,array,idx=0,default=None):
                    132:         """return array element idx or default (but no exception)"""
                    133:         if len(array) <= idx:
                    134:             return default
                    135:         else:
                    136:             return array[idx]
                    137:         
                    138: 
                    139:     def browserCheck(self):
                    140:         """check the browsers request to find out the browser type"""
                    141:         bt = {}
                    142:         ua = self.REQUEST.get_header("HTTP_USER_AGENT")
                    143:         bt['ua'] = ua
                    144:         bt['isIE'] = False
                    145:         bt['isN4'] = False
                    146:         if string.find(ua, 'MSIE') > -1:
                    147:             bt['isIE'] = True
                    148:         else:
                    149:             bt['isN4'] = (string.find(ua, 'Mozilla/4.') > -1)
                    150: 
                    151:         try:
                    152:             nav = ua[string.find(ua, '('):]
                    153:             ie = string.split(nav, "; ")[1]
                    154:             if string.find(ie, "MSIE") > -1:
                    155:                 bt['versIE'] = string.split(ie, " ")[1]
                    156:         except: pass
                    157: 
                    158:         bt['isMac'] = string.find(ua, 'Macintosh') > -1
                    159:         bt['isWin'] = string.find(ua, 'Windows') > -1
                    160:         bt['isIEWin'] = bt['isIE'] and bt['isWin']
                    161:         bt['isIEMac'] = bt['isIE'] and bt['isMac']
                    162:         bt['staticHTML'] = False
                    163: 
                    164:         return bt
                    165: 
                    166: 
                    167:     def versionHeaderEN(self):
                    168:         """version header text"""
                    169:         
                    170:         date= self.REQUEST.get('date',None)
                    171:         if date:
                    172:             txt="""<h2>This pages shows the project which existed at %s</h2>"""%str(date)
                    173:             return txt
                    174:         return ""
                    175: 
                    176:     def versionHeaderDE(self):
                    177:         """version header text"""
                    178:         date= self.REQUEST.get('date',None)
                    179:         if date:
                    180:             txt="""<h2>Auf dieser Seite finden Sie die Projekte mit Stand vom %s</h2>"""%str(date)
                    181:         return ""
                    182:     
                    183:         
                    184:     def createOrUpdateId_raw(self):
                    185:         """create sequence to create ids for bibliography"""
                    186:         debug=None
                    187:         #suche groesste existierende id
                    188:         founds=self.ZSQLQuery("select id from bibliography")
                    189:         
                    190:         if founds:
                    191:             ids=[int(x.id[1:]) for x in founds]
                    192:             maximum=max(ids)
                    193:             
                    194:             id_raw=self.ZSQLQuery("select nextval('id_raw')",debug=debug)
                    195:             
                    196:             if id_raw:
                    197:                 self.ZSQLQuery("drop sequence id_raw",debug=debug)
                    198:             
                    199:             self.ZSQLQuery("create sequence id_raw start %i"%(maximum+1),debug=debug)
                    200:         
                    201:     
                    202:     def queryLink(self,link):
                    203:         """append querystring to the link"""
                    204:         return "%s?%s"%(link,self.REQUEST.get('QUERY_STRING',''))
                    205: 
                    206:     def getKategory(self,url):
                    207:         """kategorie"""
                    208:         splitted=url.split("/")
                    209:         return splitted[4]
                    210: 
                    211:     def generateUrlProject(self,url,project=None):
                    212:         """erzeuge aus absoluter url, relative des Projektes"""
                    213:         if project:
                    214:             splitted=url.split("/")
                    215:             length=len(splitted)
                    216:             short=splitted[length-2:length]
                    217:             
                    218:             base=self.REQUEST['URL3']+"/"+"/".join(short)
                    219: 
                    220:         else:
                    221:             findPart=url.find("/projects/")
                    222:             base=self.REQUEST['URL1']+"/"+url[findPart:]
                    223: 
                    224:                 
                    225:         return base
                    226:     
                    227:     def isNewCapital(self,text=None,reset=None):
                    228:         if reset:
                    229:             self.REQUEST['capital']="A"
                    230:             return True
                    231:         else:
                    232:             if len(text)>0 and not (text[0]==self.REQUEST['capital']):
                    233:                 self.REQUEST['capital']=text[0]
                    234:                 return True
                    235:             else:
                    236:                 return False
                    237:     
                    238:     def subNavStatic(self,obj):
                    239:         """subnav" von self"""
                    240:         def sortWeight(x,y):
                    241:             x1=int(getattr(x[1],'weight','0'))
                    242:             y1=int(getattr(y[1],'weight','0'))
                    243:             return cmp(x1,y1)
                    244:       
                    245:         subs=self.ZopeFind(obj,obj_metatypes=['MPIWGTemplate','MPIWGLink'])
                    246:         subret=[]
                    247: 
                    248:         for x in subs:
                    249:             if not(x[1].title==""):
                    250:                 subret.append(x)
                    251:         subret.sort(sortWeight)
                    252:         return subret
                    253:     
                    254:     def subNav(self,obj):
                    255:         """return subnav elemente"""
                    256:         def sortWeight(x,y):
                    257:             x1=int(getattr(x[1],'weight','0'))
                    258:             y1=int(getattr(y[1],'weight','0'))
                    259:             return cmp(x1,y1)
                    260:         #if obj.meta_type in ['MPIWGTemplate','MPIWGLink']:
                    261:         #    id=obj.aq_parent.getId()
                    262:         #else:
                    263: 
                    264:         #id=obj.getId()
                    265: 
                    266:         
                    267:         #suche die zweite ebene
                    268:         
                    269:         if not obj.aq_parent.getId() in ['de','en']:
                    270:             obj=obj.aq_parent
                    271:         
                    272:         while not self.ZopeFind(self,obj_ids=[obj.getId()]):
                    273:             obj=obj.aq_parent
                    274:         
                    275:       
                    276:         if hasattr(self,obj.getId()):
                    277:             
                    278:             subs=self.ZopeFind(getattr(self,obj.getId()),obj_metatypes=['MPIWGTemplate','MPIWGLink'])
                    279:             subret=[]
                    280: 
                    281:             for x in subs:
                    282:                 if not(x[1].title==""):
                    283:                     subret.append(x)
                    284:             subret.sort(sortWeight)
                    285:             return subret
                    286:         else:
                    287:             return None
                    288: 
                    289:     def isActive(self,name):
                    290:         """teste ob subnavigation aktiv"""
                    291:         for part in self.REQUEST['URL'].split("/"):
                    292:             if part==name:
                    293:                 return True
                    294:         return False
                    295:         
1.1.2.6   casties   296:     
                    297:     def getSections(self):
                    298:         """returns a list of all sections i.e. top-level MPIWGFolders"""
                    299:         secs = self.objectItems(['MPIWGFolder'])
                    300:         secs.sort(sortWeight)
                    301:         #logging.debug("root: %s secs: %s"%(repr(self.absolute_url()), repr(secs)))
                    302:         return secs
1.1.2.1   dwinter   303: 
                    304:     def getSectionStyle(self, name, style=""):
                    305:         """returns a string with the given style + '-sel' if the current section == name"""
                    306:         if self.getSection() == name:
                    307:             return style + '-sel'
                    308:         else:
                    309:             return style    
                    310: 
                    311:     def MPIWGrootURL(self):
                    312:         """returns the URL to the root"""
                    313:         return self.absolute_url()
                    314:         
                    315:     def upDateSQL(self,fileName):
                    316:         """updates SQL databases using fm.jar"""
                    317:         fmJarPath=os.path.join(package_home(globals()), 'updateSQL/fm.jar')
                    318:         xmlPath=os.path.join(package_home(globals()), "updateSQL/%s"%fileName)
                    319:         logger("MPIWG Web",logging.INFO,"java -classpath %s -Djava.awt.headless=true Convert %s"%(fmJarPath,xmlPath))
                    320:         ret=os.popen("java -classpath %s -Djava.awt.headless=true Convert %s"%(fmJarPath,xmlPath),"r").read()
                    321:         logger("MPIWG Web",logging.INFO,"result convert: %s"%ret)
                    322:         return 1
                    323:     
                    324:     def patchProjects(self,RESPONSE):
                    325:         """patch"""
                    326:         projects=self.ZopeFind(self.projects,obj_metatypes=['MPIWGProject'])
                    327:         for project in projects:
                    328:                 tmp=project[1].WEB_project_description[0].replace("/CD/projects/","")[0:]
                    329:                 setattr(project[1],'WEB_project_description',[tmp[0:]])
                    330:                 RESPONSE.write("<p>%s</p>\n"%project[0])
                    331:             
                    332:     def replaceNotEmpty(self,format,field):
                    333:         """replace not empty"""
                    334:         if field and (not field.lstrip()==''):
1.1.2.3   dwinter   335:             return self.decode(format%field)
1.1.2.1   dwinter   336:         else:
                    337:             return ""
                    338:         
                    339: 
                    340:     def isActiveMember(self,key):
                    341:         """tested ob Mitarbeiter key ist aktiv"""
                    342:         ret=self.getat(self.ZSQLInlineSearch(_table='personal_www',
                    343:                                             _op_key='eq',key=key,
                    344:                                             _op_publish_the_data='eq',
                    345:                                             publish_the_data='yes'))
                    346:         
                    347:         logging.info("ACTIVE_MEMBER  %s"%ret)
                    348:         if ret:
                    349:             return True
                    350:         else:
                    351:             return False
                    352:         
                    353:     def isActual(self,project):
                    354:         """checke if project is actual"""
                    355:         actualTime=time.localtime()
                    356:         
                    357:         if hasattr(project,'getObject'): #obj ist aus einer catalogTrefferList
                    358:             obj=project.getObject()
                    359:         else:
                    360:             obj=project
                    361:             
                    362:         if getattr(obj,'archiveTime',actualTime)< actualTime:
                    363:             return False
                    364:         else:
                    365:             return True
                    366:         
                    367:     def redirectIndex_html(self,request):
                    368:         #return request['URL1']+'/index_html'
                    369:         
                    370:         return urllib.urlopen(request['URL1']+'/index_html').read()
                    371: 
                    372:     
                    373:     def formatBibliography(self,here,found):
                    374:         """format"""
                    375:         return formatBibliography(here,found)
                    376:     
                    377:     def getValue(self,fieldStr):
                    378:         """Inhalt des Feldes"""
                    379:         
                    380:         if type(fieldStr)==StringType:
                    381:             field=fieldStr
                    382:         else:
                    383:             field=fieldStr[0]
                    384:         try:
                    385:             if field[len(field)-1]==";":
                    386:                 field=field[0:len(field)-1]
                    387:         except:
                    388: 
                    389:             """nothing"""
                    390:         field=re.sub(r';([^\s])','; \g<1>',field)
                    391:         return field.encode('utf-8')
                    392: 
                    393: 
                    394:     
                    395:     def sortedNames(self,list):
                    396:         """sort names"""
                    397: 
                    398:         def sortLastName(x_c,y_c):
                    399:             try:
                    400:                 x=urllib.unquote(x_c).encode('utf-8','ignore')
                    401:             except:
                    402:                 x=urllib.unquote(x_c)
                    403: 
                    404:             try:
                    405:                 y=urllib.unquote(y_c).encode('utf-8','ignore')
                    406:             except:
                    407:                 x=urllib.unquote(y_c)
                    408:                 
                    409: 
                    410:             
                    411:             try:
                    412:                 last_x=x.split()[len(x.split())-1]
                    413:                 last_y=y.split()[len(y.split())-1]
                    414: 
                    415:             except:
                    416: 
                    417:                 last_x=""
                    418:                 last_y=""
                    419:             
                    420:             
                    421:             
                    422:             if last_x<last_y:
                    423:                 return 1
                    424:             elif last_x>last_y:
                    425:                 return -1
                    426:             else:
                    427:                 return 0
                    428:             
                    429:         list.sort(sortLastName)
                    430:         list.reverse()
                    431:         
                    432:         return list
                    433:     
                    434:     def __init__(self, id, title):
                    435:         """init"""
                    436:         self.id=id
                    437:         self.title=title
                    438: 
                    439:     def removeStopWords(self,xo):
                    440:         """remove stop words from xo"""
                    441:         if not hasattr(self,'_v_stopWords'):
                    442:             self._v_stopWords=self.stopwords_en.data.split("\n")
                    443:     
                    444:         x=str(xo)
                    445:     
                    446:         strx=x.split(" ")
                    447:   
                    448:         for tmp in strx:
                    449:      
                    450:             if tmp.lower() in self._v_stopWords:
                    451:                 del strx[strx.index(tmp)]
                    452: 
                    453:         return " ".join(strx)
                    454:     
                    455:     def urlQuote(self,str):
                    456:         """quote"""
                    457:         return urllib.quote(str)
                    458: 
                    459:     def urlUnQuote(self,str):
                    460:         """quote"""
                    461:         return urllib.unquote(str)
                    462:     
                    463:         
                    464: 
                    465:     def getProjectsByFieldContent(self,fieldName,fieldContentsEntry, date=None):
                    466:         """gib alle Projekte aus mit Value von field mit fieldName enthaelt ein Element der Liste fieldContents"""
                    467:         def sort(x,y):
                    468:                 return cmp(x.WEB_title[0],y.WEB_title[0])
                    469: 
                    470:         if type(fieldContentsEntry) is StringType:
                    471:             fieldContentsTmp=[fieldContentsEntry]
                    472:         else:
                    473:             fieldContentsTmp=fieldContentsEntry
                    474: 
                    475:         fieldContents=[]
                    476:         for x in fieldContentsTmp:
                    477:             fieldContents.append(" AND ".join(x.split()))
                    478:         projects=self.ProjectCatalog({fieldName:string.join(fieldContents,' AND')})
                    479:         #print projects
                    480:         #ret=[x for x in projects]
                    481:         ret=[]
                    482:         for x in projects:
                    483:             obj=x.getObject()
                    484:             obj=obj.getActualVersion(date)
                    485:             if obj and (not getattr(obj,'invisible',None)):
                    486:                 #if not (x in ret):
                    487:                     ret.append(x)
                    488: 
                    489:         ret.sort(sort)
                    490:         return ret
                    491: 
                    492:     def changeMPIWGRootForm(self):
                    493:         """edit"""
                    494:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','changeMPIWGRootForm')).__of__(self)
                    495:         return pt()
                    496: 
                    497:     def changeMPIWGRoot(self,title,disciplineList,themesList,connection_id,RESPONSE=None):
                    498:         """change"""
                    499:         self.title=title
                    500:         self.connection_id=connection_id
                    501:         self.disciplineList=disciplineList
                    502:         self.themesList=themesList
                    503: 
                    504:         if RESPONSE is not None:
                    505:             RESPONSE.redirect('manage_main')
                    506: 
                    507: 
                    508:     def getContexts(self,childs=None,parents=None,depth=None,date=None,onlyActive=True):
                    509:         """childs alle childs, alle parents"""
                    510:         ret=[]
                    511:         
                    512:         if parents:
1.1.2.6   casties   513:             pnums=parents.split(".")
                    514:             while len(pnums) > 1:
                    515:                 pnums.pop()
                    516:                 parentId=string.join(pnums,".")
                    517:         
                    518:                 for project in self.getProjectFields('xdata_05',sort='int',date=date):
                    519:                     if project[1]==parentId:
                    520:                         ret.append(project)
                    521:                 
                    522:                 if (depth is not None) and (len(ret) >= depth):
                    523:                     break
1.1.2.1   dwinter   524: 
                    525:         if childs:
                    526:             for project in self.getProjectFields('xdata_05',sort='int',date=date):
                    527:                 searchStr=childs+"(\..*)"
                    528:                
                    529:                 if (onlyActive and project[0].isActiveProject()) or (not onlyActive):
                    530:                     if re.match(searchStr,project[1]):
                    531:                         
                    532:                         if depth:
                    533:     
                    534:                             if int(depth)>=len(project[1].split("."))-len(childs.split(".")):
                    535:                         
                    536:                                 ret.append(project)
                    537:                         else:
                    538:                             ret.append(project)
1.1.2.6   casties   539:         
                    540:         logging.debug("getContexts: childs=%s parents=%s depth=%s => %s"%(childs,parents,depth,repr(ret)))
1.1.2.1   dwinter   541:         return ret
1.1.2.6   casties   542: 
1.1.2.1   dwinter   543:     
                    544:     def getProjectFields(self,fieldName,date=None,folder=None,sort=None):
                    545:         """getListofFieldNames"""
                    546:         ret=[]
                    547:     
                    548:         objects=self.ZopeFind(self.projects,obj_metatypes=['MPIWGProject'],search_sub=0)
                    549: 
                    550:                 
                    551:         for object in objects:
                    552:             obj=object[1]
                    553:             obj=obj.getActualVersion(date)
                    554:             if obj and (not getattr(obj,'invisible',None)):
                    555:                 if fieldName=="WEB_title_or_short":
                    556: 
                    557:                     if len(obj.getContent('xdata_07'))<3: # hack weil z.Z. manchmal noch ein Trennzeichen ; oder , im Feld statt leer
                    558:                         fieldNameTmp="WEB_title"
                    559:                     else:
                    560:                         fieldNameTmp="xdata_07"
                    561:                 else:
                    562:                     fieldNameTmp=fieldName
                    563: 
                    564:                 ret.append((obj,obj.getContent(fieldNameTmp)))
                    565: 
                    566:         
                    567:         if sort=="int":
                    568:             ret.sort(sortI)
                    569:         elif sort=="stopWords":
                    570:  
                    571:             ret.sort(sortStopWords(self))
                    572:             
                    573:         else:
                    574:             ret.sort(sortF)
                    575:         
                    576:         return ret
                    577: 
                    578:     def showNewProjects(self):
                    579:         projects=[]
                    580:         for objs in self.getProjectFields('WEB_title_or_short'): # Get all Projets
                    581:             if objs[0].xdata_05 and (objs[0].xdata_05[0] == ""):
                    582:                 
                    583:                 projects.append(objs)
                    584:                 
                    585:         return projects
                    586:     
                    587:         
                    588:     manage_options = Folder.manage_options+(
                    589:         {'label':'Update personal homepages','action':'updatePersonalwww_html'},
                    590:         {'label':'Reindex catalogs','action':'reindexCatalogs'},
                    591:         {'label':'Main config','action':'changeMPIWGRootForm'},
                    592:         {'label':'add e-mails','action':'showNewDBEntries'},
                    593:         {'label':'update the institutsbibliography','action':'updateInstitutsbiliography'},
                    594:         #{'label':'Edit Historical Persons','action':'editHistoricalPersonsForm'},
                    595:         #{'label':'Store Historical Persons','action':'storeHistoricalPersons'},
                    596:         )
                    597:     
                    598: 
                    599:     def updatePublicationDB(self,personId=None):
                    600:         """updates the publication db, i.e. copy year and type into the main table"""
                    601:         
                    602:         if personId:
                    603:             founds = self.ZSQLInlineSearch(_table="publications",key_main=personId)
                    604:         else:
                    605:             founds = self.ZSQLInlineSearch(_table="publications")
                    606:             
                    607:         for found in founds:
                    608:                         
                    609:             if found.id_institutsbibliographie and (not found.id_institutsbibliographie =="") and (not found.id_institutsbibliographie =="0"):
                    610:                 
                    611:                 entries = self.ZSQLInlineSearch(_table="institutsbiblio",id=found.id_institutsbibliographie)
                    612:                 for entry in entries:
                    613:                     self.ZSQLChange(_table='publications',_identify='oid=%s' % found.oid,year=entry.year,referencetype=entry.reference_type)
                    614:                     
                    615:             if found.id_gen_bib and (not found.id_gen_bib ==""):
                    616:                 entries = self.ZSQLInlineSearch(_table="bibliography",id=found.id_gen_bib)
                    617:                 for entry in entries:
                    618:                     self.ZSQLChange(_table='publications',_identify='oid=%s' % found.oid,year=entry.year,referencetype=entry.reference_type)
                    619:                     
                    620:         return True        
                    621:     
                    622:     def showNewDBEntries(self):
                    623:         """zeige neue Eintraege in der Datenbank ohne e-mail adressen bzw. fuer die noch kein Object angelegt wurde"""
                    624:         
                    625:         qstr="select * from personal_www where web_object_created='no' and not key=''"
                    626:         res=self.ZSQLQuery(qstr)
                    627:         
                    628:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','showNewDBEntries.zpt')).__of__(self)
                    629:         return pt(newEntries=res)
                    630:    
                    631:     def createNewStaffObjects(self,RESPONSE):
                    632:         """create new staff object"""
                    633:         
                    634:         memberFolder=getattr(self,'members')
                    635:         args=self.REQUEST.form
                    636:         arg_k=args.keys()
                    637:         arg_k.remove("submit")
                    638:         ret=""
                    639:         for key in arg_k:
                    640:             k=self.urlUnQuote(key)
                    641:           
                    642:             qstr="select * from personal_www where key=%s"%self.ZSQLQuote(k)
                    643:             res=self.ZSQLQuery(qstr)[0]
                    644:             if args[key]!="": #email-adresse wurde eingetragen
                    645:                 #create the object
                    646:                 e_mail=args[key]
                    647:                 try:
                    648:                     newObj=MPIWGStaff.MPIWGStaff(e_mail,res.last_name,res.first_name,k)
                    649:                     memberFolder._setObject(e_mail,newObj)
                    650:                     obj=getattr(memberFolder,e_mail)
                    651:                     obj.reindex_object()
                    652:                     ret+="Created %s \n"%e_mail
                    653:                     created=True
                    654:                 except:
                    655:                     msg="Cannot create new user %s (%s %s)"%(e_mail,sys.exc_info()[0],sys.exc_info()[1])
                    656:                     logging.error(msg)
                    657:                     ret+=msg+"\n"
                    658:                     created=False
                    659:                 
                    660:                 if created:
                    661:                     qstr="update personal_www set web_object_created='yes',e_mail='%s@mpiwg-berlin.mpg.de' where key=%s"%(e_mail,self.ZSQLQuote(k))
                    662:                     self.ZSQLQuery(qstr)
                    663:         
                    664:         return ret
                    665:                    
                    666:         
                    667:     def generateNewPersonEntry(self,data):
                    668:         """generate a new person entry for data, neue personen werden zunaechst nur in der datenbank angelegt """
                    669:         
                    670:         #memberFolder=getattr(self,'members')
                    671:         #create the object
                    672:         
                    673: #        try:
                    674: #            newObj=MPIWGStaff.MPIWGStaff(urllib.quote(data['key']),data['last_name'].encode('utf-8'),data['first_name'].encode('utf-8')) 
                    675: #            memberFolder._setObject(urllib.quote(data['key']),newObj)
                    676: #        except:
                    677: #            return False, "Cannot create new user %s (%s %s)"%(data['key'],sys.exc_info()[0],sys.exc_info()[1])
                    678: #        
                    679:         
                    680:         #create the new entry in the database
                    681:         
                    682:         
                    683:         result,msg=MPIWGStaff.createNewDBEntry(self,data['publish_the_data'],data['key'],data['last_name'],
                    684:                                   data['first_name'],data['title'],data['status'],"",
                    685:                                   "",data['date_from'],data['date_to'],
                    686:                                   data['department'],data['home_inst'],data['funded_by'],
                    687:                                   data['e_mail2'],data['current_work'],"yes",data['date_stay_at_mpiwg'],data['group'],"no",data['current_work'])
                    688:         
                    689:         return result,msg
                    690:  
                    691:     def updatePersonEntry(self,data,ignoreEntries=[]):
                    692:         """update an person entry from data. but ignore all fields in ignore Entries"""
                    693:         
                    694:         ignoreEntries.append('current_work') # TODO:updatecurrent work
                    695:         
                    696:         if data['date_to']=="": # wenn date_to leer
                    697:              data['date_to']="date_none"
                    698:         
                    699:         if data['date_from']=="": # wenn date_fromleer
                    700:              data['date_from']="date_none"
                    701:         msg=""
                    702:    
                    703:         
                    704:         #eintragen
                    705:          
                    706:         columns=data.keys()
                    707:         for x in ignoreEntries:
                    708:             logging.info("ign rem: %s"%x)
                    709:             try: #falls in ignore entries felder sind, die nicht in columns sind, fange den fehler ab
                    710:              columns.remove(x)
                    711:             except:
                    712:                 pass
                    713: 
                    714:         
                    715:         insert=[]
                    716:         for key in columns:
                    717:             if data[key]=="date_none": # date_none eintrag wird zu null uebersetzt
                    718:                 insert.append('%s=null'%key)
                    719:             else:
                    720:                 insert.append(""" "%s"=%s"""%(key,self.ZSQLQuote(data[key])))
                    721:             
                    722:         insertStr=",".join(insert)
                    723:         queryStr="update personal_www SET %s where key='%s'"%(insertStr,data['key'])
                    724:         self.ZSQLQuery("SET DATESTYLE TO 'German'")
                    725:         self.ZSQLQuery(queryStr)
                    726:        
                    727:         #currentwork
                    728:         #if not (txt==""):
                    729:         #    queryStr="INSERT INTO current_work (id_main,current,publish) VALUES ('%s','%s','%s')"%(id,txt,txt_p)
                    730:         #
                    731:         #    self.ZSQLQuery(queryStr)
                    732:         
                    733:         return True,msg
                    734: 
                    735: 
                    736:     def updatePersonalwww_doIt(self):
                    737:         """do the update"""
                    738:         args=self.REQUEST.form
                    739:         resultSet=self.REQUEST.SESSION['personal_www']['resultSet']
                    740:         news=self.REQUEST.SESSION['personal_www']['news']
                    741:         conflicts=self.REQUEST.SESSION['personal_www']['conflicts']
                    742:         ret="<html><body>"
                    743:         # generate the new entry
                    744:       
                    745:         if news and (len(news)>0):
                    746:             ret+="<h2>Hinzugef&uuml;gt</h2>"
                    747:             ret+="<p>Neueintr&auml;ge erscheinen erst auf der Homepage, wenn ihnen eine e-mail Adresse zugeordnet wurde.</p>"
                    748:             ret+="<ul>"
                    749:         for new in news:
                    750:       
                    751:             if args.has_key(self.urlQuote(new.encode('utf-8'))): # entry was selected
                    752:                 result,msg=self.generateNewPersonEntry(resultSet[new])
                    753:                 if not result:
                    754:                     logging.error("Error (generateNewPersonEntry) %s"%msg)
                    755:                     ret+="<li>ERROR: %s %s"%(new.encode('utf-8'),msg)
                    756:                 else:
                    757:                     ret+="<li>OK: %s"%(new.encode('utf-8'))
                    758:         if news and (len(news)>0):
                    759:             ret+="<p>Neueintr&auml;ge erscheinen erst auf der Homepage, wenn ihnen eine e-mail Adresse zugeordnet wurde.</p>"
                    760:             ret+="</ul>"     
                    761:         
                    762:         # update
                    763: 
                    764:         if len(conflicts.keys())>0:
                    765:             ret+="<h2>&Auml;nderung des Benutzers &uuml;bernehmen</h2>"
                    766:             ret+="<p>Wenn n&ouml;tig in Filemaker-db &auml;ndern:</p>"
                    767:             
                    768:         # konflicte   
                    769:         for conflict in conflicts.keys():
                    770:             ignoreEntries=[]
                    771:             displayIgnored=[]
                    772:             for cf in conflicts[conflict]:
                    773:                 if args[conflict.encode('utf-8')+'_'+cf[0]]=="stored": #use the stored one
                    774:                     ignoreEntries.append(cf[0])  #so ignore field cf[0]       
                    775:                     displayIgnored.append(cf)
                    776:             if len(displayIgnored)>0:
                    777:                 ret+="<h3>%s</h3>"%conflict.encode('utf-8')
                    778:                 
                    779:                 ret+="<table border='1'>"
                    780:                 for iE in displayIgnored:
                    781:                     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'))
                    782:                 ret+="</tabel>"
                    783:                 
                    784:             self.updatePersonEntry(resultSet[conflict],ignoreEntries=ignoreEntries)
                    785:          
                    786:          # rest
                    787:         cl=list(conflicts.keys())
                    788:         
                    789:         for key in resultSet.keys():
                    790:              if key not in cl:
                    791:                  self.updatePersonEntry(resultSet[key])
                    792:         return ret+"</body></html>"
                    793:                      
                    794: 
                    795:     def updateInstitutsbiliography(self):
                    796:         """update the Institutsbibliogrpahy"""
                    797:         self.upDateSQL('personalwww.xml')
                    798:         return "<html><body>DONE</body></html>"
                    799: 
                    800: 
                    801:     def updatePersonalwww_html(self):
                    802:         """update form for the homepages web form"""
                    803:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','updatePersonalwww.zpt')).__of__(self)
                    804:         return pt()
                    805: 
                    806:     
                    807:     def updatePersonalwww(self,uploadfile):
                    808:         """update personalwww
                    809:         @param uploadfile: file handle auf das file
                    810:         """
                    811:         dsn=self.getConnectionObj().connection_string
                    812:         #dsn="dbname=personalwww"
                    813:         resultSet=updatePersonalWWW.importFMPXML(uploadfile)
                    814:         news,conflicts=updatePersonalWWW.checkImport(dsn, resultSet)
                    815: 
                    816:         self.REQUEST.SESSION['personal_www']={}
                    817:         self.REQUEST.SESSION['personal_www']['resultSet']=resultSet
                    818:         self.REQUEST.SESSION['personal_www']['news']=news
                    819:         self.REQUEST.SESSION['personal_www']['conflicts']=conflicts
                    820:         
                    821:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','updatePersonalwww_check.zpt')).__of__(self)
                    822:         return pt()
                    823:     
                    824: 
                    825:      
                    826:     def reindexCatalogs(self,RESPONSE=None):
                    827:         """reindex members and project catalog"""
                    828:         
                    829:         
                    830:         try:
                    831:             
                    832:             self.ProjectCatalog.manage_catalogReindex(self.REQUEST,RESPONSE,self.REQUEST['URL1'])
                    833:         except:
                    834:             logger("MPIWG Root (updatehomepage)",logging.WARNING," %s %s"%sys.exc_info()[:2])
                    835:             
                    836:         
                    837:     
                    838:         
                    839:            
                    840:         if RESPONSE:
                    841:             RESPONSE.redirect('manage_main')
                    842: 
                    843:         
                    844:         
                    845: 
                    846:     def getAllMembers(self):
                    847:         #ret=[]
                    848:         
                    849:         def sorter(x,y):
                    850:             return cmp(x[0],y[0])
                    851:                     
                    852:         results=self.MembersCatalog({'isPublished':True})
                    853:  
                    854:         ret=[(", ".join([proj.lastName, proj.firstName]).decode('utf-8'),proj.getKey) for proj in results]
                    855:         
                    856:         ret.sort(sorter)
                    857:         return ret
                    858:     
                    859:     
                    860:     def printAllMembers(self):
                    861:         """print"""
                    862:         members=self.getAllMembers()
                    863:         ret=""
                    864:         for x in members:
                    865:             ret+="<p>%s</p>"%x
                    866:         return ret
                    867:     
                    868:         
                    869:     def makeList(self,entry):
                    870:         """makes a list out of one entry or repeat a list"""
                    871:         if type(entry) is StringType:
                    872:             return [entry]
                    873:         else:
                    874:             return entry
                    875: 
1.1.2.7   dwinter   876:     def getTreeRSS(self,dep=None,date=None,onlyActive=1,onlyArchived=0):
1.1.2.5   dwinter   877:         """generateTree"""
                    878:         rss="""<?xml version="1.0" encoding="utf-8"?>
                    879:                  <rss version="2.0">
                    880:                    <channel>"""
                    881:         
                    882:         for obj in self.getTree(dep, date, onlyActive, onlyArchived):
1.1.2.7   dwinter   883:             linkStr="""<link>http://wwwneu.mpiwg-berlin.mpg.de/en/research/projects/%s</link>"""
1.1.2.5   dwinter   884:             rss+="""<item>"""
1.1.2.7   dwinter   885:             rss+=linkStr%obj[3].getId()
1.1.2.5   dwinter   886:             rss+="""</item>"""
1.1.2.8   dwinter   887:             if hasattr(obj[3],'publicationList'):
                    888:            rss+="""<item>"""
                    889:                 rss+=linkStr%(obj[3].getId()+"/publicationList");
                    890:                 rss+="""</item>"""
1.1.2.5   dwinter   891:         rss+="""</channel>
                    892:         </rss>"""
                    893: 
                    894:         
                    895:         return rss
1.1.2.1   dwinter   896: 
                    897:     def getTree(self,dep=None,date=None,onlyActive=0,onlyArchived=0):
                    898:         """generate Tree from project list
                    899:         als Liste, jeder Eintrag ist ein Tupel ,(Tiefe, ProjektNummer,ProjektObject
                    900:         onlyActive = 0  : alle Projekte
                    901:         onlyActive = 1 : nur active Projekte
                    902:         onlyActive = 2: nur inactive Projekte
                    903:         
                    904:         onlyArchived=0: alle Projekte
                    905:         onlyArchived= 1 : nur aktuelle Projekte
                    906:         onlyArchived = 2: nur archivierte Projekte
                    907:         """
                    908: 
                    909:         returnListTmp=[]
                    910:         returnList=[]
                    911:         
                    912:         for project in self.getProjectFields('xdata_05',sort="int",date=date): # get Projects sorted by xdata_05
                    913: 
                    914:             for idNr in project[1].split(";"): # more than one number
                    915:                 if not idNr=="":
                    916:                     splittedId=idNr.split(".")
                    917:                     depth=len(splittedId)
                    918:                     nr=idNr
                    919:                     #title=project[0].WEB_title
                    920:                     title=[project[0].getContent('WEB_title')]
                    921:                     #print title
                    922:                     
                    923:                     if idNr[0]=="x": # kompatibilitaet mit alter Konvention, x vor der Nummer macht project inactive
                    924:                         project[0].setActiveFlag(False)
                    925:                    
                    926:                     if (not dep) or (idNr[0]==dep): #falls dep gesetzt ist nur dieses hinzufuegen.
                    927:                         
                    928:                         if (onlyActive==0):
                    929:                             returnListTmp.append((depth,nr,title,project[0]))
                    930:                         elif (onlyActive==1) and project[0].isActiveProject(): #nur active projekte
                    931:                             returnListTmp.append((depth,nr,title,project[0]))
                    932:                         elif (onlyActive==2) and (not project[0].isActiveProject()): #nur active projekte
                    933:                             returnListTmp.append((depth,nr,title,project[0]))
                    934:                    
                    935:                    
                    936:         #filter jetzt die Liste nach Archived oder nicht
                    937:         for entry in returnListTmp:
                    938:                     if (onlyArchived==0):
                    939:                             returnList.append(entry)
                    940:                     elif (onlyArchived==1) and (not entry[3].isArchivedProject()): #nur active projekte
                    941:                             returnList.append(entry)
                    942:                     elif (onlyArchived==2) and (entry[3].isArchivedProject()): #nur active projekte
                    943:                             returnList.append(entry)
                    944:                    
                    945:         
                    946:         return returnList
                    947: 
                    948: 
                    949:         
                    950:     def changePosition(self,treeId,select,RESPONSE=None):
                    951:         """Change Postion Entry"""
                    952:         numbers=[]
                    953: 
                    954:         # Suche hoechste bisherige nummer
                    955:         projects=self.getProjectFields('xdata_05') # get Projects sorted by xdata_05
                    956:         #print "pj",projects
                    957:         for project in projects: #suche alle subtrees der treeId
                    958:             #print treeId
                    959:             
                    960:             founds=re.match(treeId+"\.(.*)",project[1].split(";")[0])
                    961:             if founds:
                    962:                 #print "x",founds.group(0),len(founds.group(0).split("."))
                    963:                 if len(founds.group(0).split("."))==len(treeId.split("."))+1: # nur ein punkt mehr, d.h. untere ebene
                    964:                     try:
                    965:                         numbers.append(int(founds.group(0).split(".")[len(founds.group(0).split("."))-1]))
                    966:                     except:
                    967:                         numbers.append(int(0))
                    968: 
                    969:         try:
                    970:             highest=max(numbers)
                    971:         except:
                    972:             highest=0
                    973:         projects=self.showNewProjects()
                    974:         for i in self.makeList(select):
                    975:             highest+=10
                    976:             projects[int(i)][0].xdata_05=treeId+"."+str(highest)
                    977: 
                    978: 
                    979:         if RESPONSE is not None:
                    980:             RESPONSE.redirect('showTree')
                    981:         
                    982:     def changeTree(self,RESPONSE=None):
                    983:         """change the complete tree"""
                    984:         form=self.REQUEST.form
                    985:         hashList={}
                    986:         onlyArchived=int(form.get("onlyArchived",0))
                    987:         onlyActive=int(form.get("onlyActive",0))
                    988:         
                    989:         
                    990:         fields=self.getTree(onlyArchived=onlyArchived,onlyActive=onlyActive)
                    991:         
                    992:         logging.info("GOT TREE!----------------------------------------------------")
                    993:         for field in form.keys():
                    994:             
                    995:             splitted=field.split('_')
                    996:             if (len(splitted)>1) and (splitted[1]=="runningNumber"): #feld hat die Form Nummer_name und runnignNumber
                    997:             
                    998:                 
                    999:                 nr=int(splitted[0]) # nummer des Datensatzes
                   1000:                 currentEntry = fields[nr]
                   1001:             
                   1002:                 if form.has_key(str(nr)+'_active'): # active flag is set
                   1003:                     fields[nr][3].setActiveFlag(True)
                   1004:                 else:
                   1005:                     fields[nr][3].setActiveFlag(False)
                   1006:                     
                   1007:                 #nummer hat sich geŠndert
                   1008:                 
                   1009:                 entryChanged = False;
                   1010:                 
                   1011:                 
                   1012:                 if not (fields[nr][3].xdata_05==form[str(nr)+'_number']):
                   1013:                     logging.info("Changed!Number+++++++++++++++++++++++++++++++++")
                   1014:                     fields[nr][3].xdata_05=form[str(nr)+'_number']
                   1015:                     entryChanged = True
                   1016:                     
                   1017:                 #completed har sich geaendert
                   1018:                             
                   1019:                 if not (fields[nr][3].getCompletedAt()==fields[nr][3].transformDate(form[str(nr)+'_completed'])):
                   1020:                     fields[nr][3].setCompletedAt(form[str(nr)+'_completed'])
                   1021:                     logging.info("Changed!Completed+++++++++++++++++++++++++++++++++")
                   1022:                     entryChanged = True
                   1023:                 
1.1.2.4   dwinter  1024:                 if not (fields[nr][3].getStartedAt()==fields[nr][3].transformDate(form[str(nr)+'_started'])):
                   1025:                     fields[nr][3].setStartedAt(form[str(nr)+'_started'])
                   1026:                     logging.info("Changed!Started+++++++++++++++++++++++++++++++++")
                   1027:                     entryChanged = True
                   1028:                 
1.1.2.1   dwinter  1029:                 
                   1030:                 if entryChanged:
                   1031:                     logging.info("Changed!+++++++++++++++++++++++++++++++++")
                   1032:                     fields[nr][3].copyObjectToArchive()
                   1033:                 
                   1034:                     
                   1035:         if RESPONSE is not None:
                   1036:             RESPONSE.redirect('showTree')
                   1037: 
                   1038:     def getProjectWithId(self,id):
                   1039:         fields=self.getProjectFields('xdata_05')
                   1040:         for field in fields:
                   1041:             if field[1]==id:
                   1042:                 return field[0]
                   1043: 
                   1044:         return None
                   1045:             
                   1046:         
                   1047:             
                   1048:         
                   1049:     def getRelativeUrlFromPerson(self,list):
                   1050:         """get urls to person list"""
                   1051:         ret=[]
                   1052:         persons=list.split(";")
                   1053:         for person in persons:
                   1054:             
                   1055:             if len(person)>1: #nicht nur Trennzeichen
                   1056:                 splitted=person.split(",")
                   1057:                 if len(splitted)==1:
                   1058:                     splitted=person.split(" ")
                   1059:                 splittedNew=[re.sub(r'\s(.*)','$1',split) for split in splitted]
                   1060:                 if splittedNew[0]=='':
                   1061:                     del splittedNew[0]
                   1062:                 search=string.join(splittedNew,' AND ')
                   1063:                 
                   1064:                 if not search=='':
                   1065: 
                   1066:                     try:
                   1067:                         proj=self.MembersCatalog({'title':search})
                   1068:                     except:
                   1069:                         proj=None
                   1070: 
                   1071:                 if proj:
                   1072:                     #ret.append("<a href=%s >%s</a>"%(proj[0].absolute_url,person.encode('utf-8')))
                   1073:                     ret.append("<a href=%s >%s</a>"%('members/'+proj[0].id+'/index.html',person))
                   1074:                 else:
                   1075:                     #ret.append("%s"%person.encode('utf-8'))
                   1076:                     ret.append("%s"%person)
                   1077:         return string.join(ret,";")
                   1078:         
                   1079:     def getMemberIdFromKey(self,key):
                   1080:         """gibt die ensprechende id  im members Ordner zum key"""
                   1081:         
                   1082:         if key=="":
                   1083:             return ""
                   1084:         catalogged=self.MembersCatalog({'getKey':key})
                   1085:         if len(catalogged)==0:
                   1086:             return ""
                   1087:         else:
                   1088:             return catalogged[0].getObject().getId()
                   1089:         
                   1090: 
                   1091:             
1.1.2.2   dwinter  1092: 
1.1.2.1   dwinter  1093:     def getProjectsOfMembers(self,date=None):
                   1094:         """give tuple member /projects"""
                   1095:         ret=[]
                   1096:         members=self.getAllMembers()
                   1097:        
                   1098:         #return str(members)
                   1099:         for x in members:
                   1100:             projects=self.getProjectsOfMember(key=x[1],date=date)
                   1101:             if len(projects)>0:
                   1102:                 ret.append((x[0],projects))
                   1103:             
                   1104:         return ret
                   1105: 
                   1106:     def getProjectsOfMember(self,key=None,date=None,onlyArchived=1,onlyActive=1):
                   1107:         """get projects of a member
                   1108:     
                   1109:         @param key: (optional) Key zur Idenfikation des Benutzer
                   1110:         @param date: (optional) Version die zum Zeitpunkt date gueltig war
                   1111:         @param onlyArchived: 
                   1112:         onlyArchived=0: alle Projekte
                   1113:         onlyArchived= 1 : nur aktuelle Projekte
                   1114:         onlyArchived = 2: nur archivierte Projekte
                   1115:         """
                   1116:         # TODO: Die ganze Loesung
                   1117:         def sortP(x,y):
                   1118:             """sort by sorting number"""
                   1119:             return cmp(x.WEB_title,y.WEB_title)
                   1120:         
                   1121:         ret=[]  
                   1122:         if key:     
                   1123:             proj=self.ProjectCatalog({'getPersonKeyList':key})
                   1124:         else:
                   1125:             return ret # key muss definiert sein
                   1126:         
                   1127:      
                   1128:         if proj:
                   1129:             proj2=[]
                   1130:             for x in proj:
                   1131:                 if (not getattr(x.getObject(),'invisible',None)) and (getattr(x.getObject(),'archiveTime','')==''):   
                   1132:                       proj2.append(x)
                   1133: 
                   1134:         else:
                   1135:             proj2=[]
                   1136:             
                   1137:        
                   1138:        
                   1139:         proj2.sort(sortP)
                   1140: 
                   1141:         projectListe=[]
                   1142:         
                   1143:         for proj in proj2:   
                   1144:             obj=proj.getObject()
                   1145:             add=False
                   1146:             if onlyArchived==1: #nur aktuell projecte
                   1147:                 if not obj.isArchivedProject():
                   1148:                     add=True
                   1149:             elif onlyArchived==2: #nur archivierte
                   1150:                 if obj.isArchivedProject():
                   1151:                     add=True
                   1152:             else: #alle
                   1153:                add=True
                   1154:                
                   1155:             if onlyActive==1: #nur active projecte
                   1156:                 if obj.isActiveProject():
                   1157:                     add=add & True
                   1158:                 else:
                   1159:                     add=add & False
                   1160:                 
                   1161:             elif onlyArchived==2: #nur nicht aktvive
                   1162:                 if not obj.isActiveProject():
                   1163:                     add=add & True
                   1164:             else: #alle
                   1165:                add=add & True
                   1166:                     
                   1167:             if add:
                   1168:                 projectListe.append(obj)
                   1169:                 
                   1170:      
                   1171:         return projectListe
                   1172:      
                   1173:     def givePersonList(self,name):
                   1174:         """check if person is in personfolder and return list of person objects"""
                   1175:         
                   1176:         splitted=name.split(",")
                   1177:         if len(splitted)==1:
                   1178:             splitted=name.lstrip().rstrip().split(" ")
                   1179:         splittedNew=[split.lstrip() for split in splitted]
                   1180:         
                   1181:         if splittedNew[0]=='':
                   1182:             del splittedNew[0]
                   1183:         search=string.join(splittedNew,' AND ')
                   1184:         
                   1185:         if not search=='':
                   1186:             proj=self.MembersCatalog({'title':search})
                   1187: 
                   1188:         if proj:
                   1189:             return [[x.lastName,x.firstName] for x in proj]
                   1190:         else:
                   1191:             return []
                   1192:             
                   1193: ##         splitted=name.split(",") # version nachname, vorname...
                   1194: ##         if len(splitted)>1:
                   1195: ##             lastName=splitted[0] 
                   1196: ##             firstName=splitted[1]
                   1197: ##         else: 
                   1198: ##             splitted=name.split(" ") #version vorname irgenwas nachnamae
                   1199:         
                   1200: ##             lastName=splitted[len(splitted)-1]
                   1201: ##             firstName=string.join(splitted[0:len(splitted)-1])
                   1202: 
                   1203: ##         objs=[]
                   1204: 
                   1205:         #print  self.members 
                   1206:       ##   for x in self.members.__dict__:
                   1207: ##             obj=getattr(self.members,x)
                   1208: ##             if hasattr(obj,'lastName') and hasattr(obj,'firstName'):
                   1209:                 
                   1210: ##                 if (re.match(".*"+obj.lastName+".*",lastName) or re.match(".*"+lastName+".*",obj.lastName)) and (re.match(".*"+obj.firstName+".*",firstName) or re.match(".*"+firstName+".*",obj.firstName)):
                   1211:                     
                   1212: ##                     objs.append((obj,lastName+", "+firstName))
                   1213: 
                   1214:         
                   1215: ##        return objs
                   1216: 
                   1217: 
                   1218:     def personCheck(self,names):
                   1219:         """all persons for list"""
                   1220:         #print "names",names
                   1221:         splitted=names.split(";")
                   1222:         ret={}
                   1223:         for name in splitted:
                   1224: 
                   1225:             if not (name==""):
                   1226:                 try:
                   1227:                     ret[name]=self.givePersonList(name)
                   1228:                 except:
                   1229:                     """NOTHIHN"""
                   1230:         #print "RET",ret
                   1231:         return ret
                   1232: 
                   1233:     def giveCheckList(self,person,fieldname):
                   1234:         """return checklist"""
                   1235:         #print "GCL",fieldname
                   1236:         if fieldname=='xdata_01':
                   1237:             x=self.personCheck(person.getContent(fieldname))
                   1238:             #print "GCLBACKX",x
                   1239:             return x
                   1240:         
                   1241: 
                   1242:     def isCheckField(self,fieldname):
                   1243:         """return chechfield"""
                   1244:         
                   1245:         return (fieldname in checkFields)
                   1246: 
                   1247:     
                   1248:     def generateNameIndex(self):
                   1249:         """erzeuge einen index verwendeter personen"""
                   1250:         import psycopg
                   1251:         o = psycopg.connect('dbname=authorities user=dwinter password=3333',serialize=0) 
                   1252:         results={}
                   1253:         print self.fulltext.historicalNames.items()
                   1254:         for nameItem in self.fulltext.historicalNames.items(): #gehe durch alle namen des lexikons
                   1255:             
                   1256:             c = o.cursor() 
                   1257:             name=nameItem[0]
                   1258:             print "check",name
                   1259:             c.execute("select lastname,firstname from persons where lower(lastname) = '%s'"%quote(name))
                   1260:             tmpres=c.fetchall()
                   1261:             firstnames=[result[1] for result in tmpres] # find all firstnames
                   1262:             if tmpres:
                   1263:                 lastname=tmpres[0][0]
                   1264:                 
                   1265:             for found in self.fulltext({'names':name}):
                   1266:                 if found.getObject().isActual():
                   1267:                     for nh in found.getObject().getGetNeighbourhood(name, length=50,tagging=False): #hole umgebung
                   1268:                         #schaue nun ob der vorname hinter oder vor dem name ist
                   1269:                         position=nh.find(lastname)
                   1270:                         # vorher
                   1271:                         #print "NH",nh
                   1272:                         bevorS=nh[0:position].split()
                   1273:                         #print "BV",bevorS
                   1274:                         if len(bevorS)>1:
                   1275:                             try:
                   1276:                                 bevor=[bevorS[-1],bevorS[-2]]
                   1277:                             except:
                   1278:                                 bevor=[bevorS[0]]
                   1279:                         else:
                   1280:                             bevor=[]
                   1281:                         #nachher
                   1282:                         behindS= re.split("[,|;| ]",nh[position:]) 
                   1283:                         #print "BH",behindS
                   1284:                         if len(behindS)>2:
                   1285:                             try:
                   1286:                                 behind=behindS[1:3]
                   1287:                             except:
                   1288:                                 behind=[bevorS[1]]
                   1289:                         else:
                   1290:                             behind=[]
                   1291:                         for firstname in firstnames:
                   1292:                             if firstname in bevor+behind: #Namen wie mit Adelspraedikaten werden so erstmal nich gefunden
                   1293:                                 id="%s,%s"%(lastname,firstname)
                   1294:                                 if not results.has_key(id):
                   1295:                                     results[id]=[]
                   1296:                                 objId=found.getObject().getId()
                   1297:                                 if not (objId in results[id]):
                   1298:                                     print "d %s for %s"%(id,objId)    
                   1299:                                     results[id].append(objId)    
                   1300:             self.nameIndex=results
                   1301:         return results
                   1302:                     
                   1303:     def editNameIndexHTML(self):
                   1304:         """edit the name index"""
                   1305:         if not hasattr(self,'nameIndexEdited'): # falls editierter index noch nicht existiert, kopiere automatisch erstellten
                   1306:             self.nameIndexEdited=copy.copy(self.nameIndex)
                   1307:             print "huh"
                   1308:         #self.nameIndexEdited=copy.copy(self.nameIndex)
                   1309:         #print self.nameIndexEdited
                   1310:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editHistoricalNames.zpt')).__of__(self)
                   1311:         return pt()
                   1312:     
                   1313:     def getNamesInProject(self,projectId):
                   1314:         """get all names ofnameIndexEdited which are references in projec with projectId"""
                   1315:         
                   1316:         ret=[]
                   1317:         for name in self.nameIndexEdited.keys():
                   1318:             if projectId in self.nameIndexEdited[name]:
                   1319:                 ret.append(name)
                   1320:         
                   1321:         return ret
                   1322:     
                   1323:     def editNameIndex(self,RESPONSE=None,name=None,occurrances=None,submit=None):
                   1324:         """edit the index"""
                   1325:         nI=self.nameIndexEdited # mI introduced to make sure that changes to nameIndexEdited are know to ZODB
                   1326:         if submit=="delete":
                   1327:            
                   1328: 
                   1329:             dh=getattr(self,'deletedHistoricalNames',{})
                   1330:             
                   1331:             if type(dh) is ListType:
                   1332:                 dh={}
                   1333:             if not dh.has_key(name):
                   1334:                 dh[name]=occurrances.split("\n")
                   1335:             else:
                   1336:                 dh[name]+=occurrances.split("\n")
                   1337:             
                   1338:             self.deletedHistoricalNames=dh
                   1339:             
                   1340:             del self.nameIndexEdited[name]
                   1341:             
                   1342:         
                   1343:         elif (submit=="change"):
                   1344:             
                   1345:             nI[name]=occurrances.split("\n")[0:]
                   1346:             
                   1347:         elif (submit=="add"):
                   1348:             if not nI.has_key(name):
                   1349:                 nI[name]=occurrances.split("\n")
                   1350:             else:
                   1351:                 nI[name]+=occurrances.split("\n")
                   1352:     
                   1353:         self.nameIndexEdited=nI
                   1354:    
                   1355:       
                   1356:         if RESPONSE is not None:
                   1357:             RESPONSE.redirect('editNameIndexHTML')
                   1358:         
                   1359:     
                   1360:     
                   1361:     def restoreIndex(self):
                   1362:         """restore"""
                   1363:         self.nameIndexEdited=self.nameIndex
                   1364:         return "done"
                   1365:     
                   1366: 
                   1367:             
                   1368: def manage_addMPIWGRootForm(self):
                   1369:     """form for adding the root"""
                   1370:     pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','addMPIWGRootForm.zpt')).__of__(self)
                   1371:     return pt()
                   1372: 
                   1373: def manage_addMPIWGRoot(self,id,title,connection_id="",RESPONSE=None):
                   1374:     """add a root folder"""
                   1375:     newObj=MPIWGRoot(id,title)
                   1376:     self._setObject(id,newObj)
                   1377:     ob=getattr(self,id)
                   1378:     setattr(ob,'connection_id',connection_id)
                   1379:     if RESPONSE is not None:
                   1380:         RESPONSE.redirect('manage_main')
                   1381:         

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