MPIWGWeb: MPIWGProjects.py comparison

comparison MPIWGProjects.py @ 48:f59bdd5f4890

Merge with 5c6ad316e1ceef48e323907ab81dd50e7ef743b2

author	dwinter
date	Mon, 29 Apr 2013 16:02:24 +0200
parents	5c6ad316e1ce
children	e40ff9829108 e718d9a72f19

comparison

equal deleted inserted replaced

-:225179dfd892
+:f59bdd5f4890
 """This contains the class MPIWG Projects
 for organizing and maintaining the different project pages
-$author dwinter   - last change  26.06.2008
+$author dwinter 26.06.2008
 """
 from Products.PageTemplates.PageTemplateFile import PageTemplateFile
 from Products.PageTemplates.ZopePageTemplate import ZopePageTemplate
 from Products.ZCatalog.CatalogPathAwareness import CatalogAware
 import MPIWGTemplate
 import transaction
-# TODO: fix this
+# TODO: better names for the fields
-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']
 fieldLabels = {'WEB_title':'WEB_Title',
 'xdata_01':'Responsible Scientists',
 'xdata_02':'Department',
 'xdata_03':'Historical Persons',
 'xdata_04':'Time period',
 'xdata_13':'Funding institutions',
 'WEB_project_header':'WEB_project_header',
 'WEB_project_description':'WEB_project_description',
 'WEB_related_pub':'WEB_related_pub'}
+definedFields = fieldLabels.keys() # TODO: should this be sorted?
 checkFields = ['xdata_01']
 # die folgenden Klassen sind jetzt in einzelne Files ausgelagert aus Kompatibilitaetsgruenden, bleiben die Klassen hier noch drin.
 # Sonst funktionieren die alten Webseiten nicht mehr.
 return True
 except:
 logging.debug("MPIWGProject_publication - end FALSE ")
 self._v_hasLinkToBookPage = True
 return False
 def getImageUrls(self, mode="not_cached"):
 """get the image urls"""
 except:
 self._v_imageUrls = []
 return []
 self._v_imageUrls = ret[0:]
 return ret
 def editPublication(self, text=None, image1=None, image2=None, description=None, link=None, RESPONSE=None):
 """edit a publication"""
 if (not text) and (not description):
 if hasattr(self, 'publicationImage2'):
 self.publicationImage2.manage_upload(image2)
 else:
 nO = Image('publicationImage2', '', image2)
 self._setObject('publicationImage2', nO)
 self.ZCacheable_invalidate()
 if RESPONSE:
 self.redirect(RESPONSE, "../managePublications")
 class MPIWGProject_relatedProject(Folder):
 """publications object fuer project"""
 meta_type = "MPIWGProject_relatedProject"
 def redirect(self, RESPONSE, url):
 """edit a publication"""
 if (not link):
 pt = PageTemplateFile(os.path.join(package_home(globals()), 'zpt', 'edit_relatedProjectForm.zpt')).__of__(self)
 return pt()
 # hole die id des projektes
 splitted = link.split("/")
 # teste ob es das project gibt
 objid = splitted[-1]
 object = getattr(self.projects, objid, None)
 if object == None:
 self.redirect(RESPONSE, 'errorRelatedProjects?link=' + link)
 self.orginallink = link[0:]
 self.objid = objid[0:]
 self.projectWEB_title = object.getContent('WEB_title')[0:]
 self.enabled = True;
 self.ZCacheable_invalidate()
 if RESPONSE:
 self.redirect(RESPONSE, "../manageRelatedProjects")
 class MPIWGProject_image(Image):
 """Images for Projects"""
 meta_type = "MPIWGProject_image"
 edit_css.index_html = refreshingImageFileIndexHtml
 edit_basic = PageTemplateFile('zpt/project/edit_basic', globals())
 editForm = PageTemplateFile('zpt/project/edit_description', globals())
 edit_template = PageTemplateFile('zpt/project/edit_template', globals())
 project_template = PageTemplateFile('zpt/project/project_template', globals())
+# TODO: this should go away
+extendedBibliography = PageTemplateFile('zpt/project/extendedBibliography_template', globals())
 # TODO: compat
 edit_MPIWGProject_main = edit_template
 logging.debug("len(publ)" + repr(ret))
 return ret;
-def hasRelatedDigitalSources(self):
-"""test ob es digital sources gibt"""
-ret = (self.getContent('xdata_11').lstrip().rstrip() == '')
-return not ret;
 def copyImageToMargin(self, RESPONSE=None):
 """copy inline images to marginal images"""
 # getImages from WEB_project_description
 description = self.getContent('WEB_project_description')
 text2 = description
 splitted = text2.split("""<p class="picture">""")
 splitted = split2.split("""<p class="picturetitle">""")
 if len(splitted) > 1:
 tmp = splitted[1].split("</p>")
 imageCaptions.append(tmp[0].encode('utf-8'))
 else:
 # keine caption
 imageCaptions.append("")
 # eintragen:
 for imageURL in imageURLs:
 filename = imageURL.split("/")[-1]
 # lege neues images object an, mit leerem bild
 obj = getattr(self, filename)
 obj.update_data(data)
 if RESPONSE:
 self.redirect(RESPONSE, 'manageImages')
 def manageImages(self, imageName=None, op=None):
 """managage images"""
 if imageName and op:
 if op == 'up':
 def createExtendedPublicationList(self, RESPONSE=None):
 """erzeuge erweiterte publications liste"""
 pl = BibliographyManager("publicationList", "", "institutsbiblio", self.connection_id)
 self._setObject("publicationList", pl)
 zt = ZopePageTemplate('index.html')
 pl._setObject('index.html', zt)
 default_content_fn = os.path.join(package_home(globals()),
 'zpt/showExtendedProjectBibliography.zpt')
 text = open(default_content_fn).read()
 zt.pt_edit(text, 'text/html')
 if RESPONSE:
 self.redirect(RESPONSE, "managePublications")
 def getPublications(self):
 """get all Publications"""
 def sort_images(x, y):
 return cmp(getattr(x[1], 'place', 0), getattr(y[1], 'place', 0))
 def deletePublication(self, id, RESPONSE=None):
 """delete Publication id"""
 self.manage_delObjects([id])
 self.ZCacheable_invalidate()
 if RESPONSE:
 self.redirect(RESPONSE, 'managePublications')
 def deleteRelatedProject(self, id, RESPONSE=None):
 """delete Publication id"""
 self.manage_delObjects([id])
 self.ZCacheable_invalidate()
 if RESPONSE:
 self.redirect(RESPONSE, 'manageRelatedProjects')
 def getNumber(self):
 """returns sorting number"""
 if isinstance(t, list):
 # compat with old lists
 return t[0]
 else:
 return t
+def getLabel(self):
+"""returns label (or title) of this project"""
+l = getattr(self, 'xdata_07', None)
+if isinstance(l, list):
+# compat with old lists
+l = l[0]
+if l:
+return l
+else:
+return self.getProjectTitle()
 def getResponsibleScientists(self):
 """returns the responsible scientists as string"""
 t = getattr(self, 'xdata_01', None)
 if isinstance(t, list):
 else:
 scientistsList.append({'name': name})
 logging.debug("setResponsibleScientistsList: nameDict=%s new list=%s"%(repr(nameDict),repr(scientistsList)))
 self.responsibleScientistsList = scientistsList
+def getInvolvedScholars(self):
+"""returns the other involved scholars"""
+t = getattr(self, 'xdata_08', None)
+if isinstance(t, list):
+# compat with old lists
+return t[0]
+else:
+return t
+def getCooperationPartners(self):
+"""returns the cooperation partners"""
+t = getattr(self, 'xdata_12', None)
+if isinstance(t, list):
+# compat with old lists
+return t[0]
+else:
+return t
 def getUrl(self, baseUrl=None):
 """returns URL to this Project"""
 if baseUrl is None:
 return thumb.absolute_url()
 def getImageList(self):
 """returns the sorted list of images for this project"""
-items = self.objectValues(spec='MPIWGProject_image')[:]
+items = self.objectValues(spec='MPIWGProject_image')
+# sort by place
+return sorted(items, key=lambda x:int(getattr(x, 'place', 0)))
+def getDepartment(self):
+"""returns the department of this project"""
+num = self.getNumber()
+pp = num.find('.')
+if pp > 0:
+num = num[:pp]
+return self.getMPIWGRoot().getDepartment(projectNumber=num)
+def getDepartmentId(self):
+"""returns the id of the department of this project"""
+dep = self.getDepartment()
+if dep is not None:
+return dep.getId()
+return None
+def getDescription(self, filter=False):
+"""returns the project description"""
+t = getattr(self, 'WEB_project_description', None)
+if isinstance(t, list):
+# compat with old lists
+return t[0]
+else:
+return t
+def getSuperProjects(self):
+"""returns a list of ancestor projects to the root"""
+tree = self.getProjectTree()
+return tree.getAncestorsOf(self.getNumber())
+def getSubProjects(self, active=1):
+"""returns a list of child projects"""
+tree = self.getProjectTree()
+return [p for p in tree.getChildrenOf(self.getNumber()) if p.checkActive(active)]
+def getRelatedProjects(self):
+"""returns the list of related projects"""
+items = self.objectValues(spec='MPIWGProject_relatedProject')
 # sort by place
 items.sort(key=lambda x:int(getattr(x, 'place', 0)))
 return items
+def getRelatedPublications(self):
+"""returns the list of related publications"""
+items = self.objectValues(spec='MPIWGProject_publication')
+# sort by place
+items.sort(key=lambda x:int(getattr(x, 'place', 0)))
+return items
+def getRelatedDigitalSources(self):
+"""returns the related digital sources"""
+t = getattr(self, 'xdata_11', None)
+if isinstance(t, list):
+# compat with old lists
+return t[0]
+else:
+return t
+def getFundingInstitutions(self):
+"""returns the funding institutions"""
+t = getattr(self, 'xdata_13', None)
+if isinstance(t, list):
+# compat with old lists
+return t[0]
+else:
+return t
 def getImages(self):
 """get all Images"""
 """delete Image id"""
 try:
 self.manage_delObjects([id])
 except:
 logging.error("ERROR MPIWG: %s %s" % sys.exc_info()[0:2])
+# invalidate thumbnail
+self.projectThumb = None
 if RESPONSE:
 self.redirect(RESPONSE, 'manageImages')
 def hasChildren(self, date=None, onlyActive=1, onlyArchived=1):
 """check if project has children"""
 ct = self.getContexts(childs=self.getContent('xdata_05'),
 depth=1, date=date, onlyActive=onlyActive)
 if ct and len(ct) > 0:
 return True
 obj.caption = caption[0:]
 obj.enabled = True;
 obj.place = self.getLastImageNumber() + 1
 obj.id = filename
+# invalidate thumbnail
+self.projectThumb = None
 if RESPONSE is not None:
 self.redirect(RESPONSE, 'manageImages')
 def versionHeader(self):
 """actuelle version"""
 def sortProjectsByTime(x, y):
 return cmp(x[1].archiveTime, y[1].archiveTime)
 if not date:
-if self.isActual():
+if self.isCurrentVersion():
 return self
 else:
 return None
 # suche ob aeltere versionen vorhanden sind
 return self
 else:
 return None
-def isActual(self):
+def isCurrentVersion(self):
-"""gibt 1 zurueck wenn aktuell, 0 sonst"""
+"""Return if project is the current version."""
-actualTime = time.localtime()
+currentTime = time.localtime()
+# print getattr(self,'archiveTime',currentTime)
+return (getattr(self, 'archiveTime', currentTime) >= currentTime)
-# print getattr(self,'archiveTime',actualTime)
-if getattr(self, 'archiveTime', actualTime) < actualTime:
-return 0
-else:
-return 1
 def copyObjectToArchive(self):
 """kopiere aktuelles objekt ins archiv"""
 logging.info("copytoarchive 1")
 cb = self.aq_parent.manage_copyObjects(self.getId())
 if RESPONSE is not None:
 self.redirect(RESPONSE, 'manage_main')
-def crossLinker(self):
-"""experimental crosslinker"""
-splitted = self.WEB_project_description[0].split()
-new = []
-for split in splitted:
-try:
-found = self.DescriptionCatalog({'fulltext':split})
-if len(found) > 1:
-new.append("<a href=%s>%s</a>" % (split, split))
-else:
-new.append(split)
-except:
-new.append(split)
-return " ".join(new)
-def generateTemplate(self, RESPONSE=None):
-"""Erzeuge Template fuer defined fields not_used"""
-id = "index_html"
-title = id
-if self._getOb('index_html'):
-self._delObject('index_html')
-newObj = ZopePageTemplate(id, 'TEXT')
-self._setObject(id, newObj)
-# self.manage_addPageTemplate(id,title)
-if RESPONSE is not None:
-self.redirect(RESPONSE, 'manage_main')
 def isActiveProject(self):
-"""check if the project is still active, default is true, set to false is the project is accomplished"""
+"""check if the project is still active, default is true."""
 return getattr(self, 'isActiveFlag', True)
 def checkActive(self, active):
 """returns if the project state matches the active state.
 active = 0 : all projects
 return False;
 def getCompletedAt(self):
 """gibt das transformierte Datum zurueck, an dem das Projekt beendet wurde."""
 date = getattr(self, 'completedAt', '')
 if date:
 return self.reTransformDate(date);
 else:
 return ""
-# test ob parent abgeschlossen ist
-try:  # TODO: ersetzte try except durch vernuenftige abfrage
-ct = self.getContexts(parents=self.getContent('xdata_05'), depth=1)
-if (len(ct) > 0):  # is there are parent
-return ct[0][0].getCompletedAt()
-return '';
-except:
-return '';
 def getStartedAt(self):
 """gibt das transformierte Datum zurueck, an dem Projekt begonnen wurde."""
 date = getattr(self, 'startedAt', '')
 if date:
 """seite fuer harvesting fuer die Projektsuche"""
 if not context:
 context = self
-if self.isActiveProject() and self.isActual():
+if self.isActiveProject() and self.isCurrentVersion():
 templates = self.en.getHarvestCache()
 ext = getattr(self, "harvest_main", None)
 if ext:
 rendered = getattr(self, ext.getId())()
 ret.append('xdata_%02i' % x)
 return ret
 def getDefinedFields(self):
 """show all defined fields"""
 return definedFields
 def getAttribute(self, field):
 """get attrbiute"""
 return getattr(self, field)
 if path == selected:
 return style + 'sel'
 else:
 return style
-def getLabel(self):
+def getLabel_old(self):
 """returns label (or title) of this project"""
 l = self.getContent('xdata_07')
 if l:
 return l
 l = self.getContent('WEB_title')
 return crumbs
 def getRootProject(self):
 """returns the root (=top level) project of the current project"""
 ct = self.getContexts(parents=self.getContent('xdata_05'))
 if len(ct) > 0:
 return ct[-1][0]
 else:
 return self
 # make dict of responsible scientists
 checkedScientists = {}
 names = {}
 keys = {}
-for key in formdata.keys():
+for key in formdata:
 # gehe durch das Formular
 keyParts = key.split("_")
 if keyParts[0] == "responsibleScientist":
 # wenn es ein Feld der Form reponsibleScientist_nr_KEY gibt
 nr = keyParts[2]
 if keyParts[1] == "name":
 names[nr] = formdata[key]
 elif keyParts[1] == "key":
 keys[nr] = formdata[key]
-for nr in names.keys():
+for nr in names:
 name = names[nr]
 key = keys.get(nr, None)
 username = None
 if key:
 # get username from db
-member = self.executeZSQL("select * from personal_www where lower(key) = %s", [key.lower()])
+member = self.getMPIWGRoot().getStaffFolder().getMember(key=key)
-if len(member) > 0:
+if member is not None:
-username = re.sub('@mpiwg-berlin\.mpg\.de', '', member[0].e_mail)
+username = member.getUsername()
 # schreibe keys und namen in die Liste
 checkedScientists[names[nr]] = {'name' : name, 'key' : key, 'username' : username}
+# update responsibleScientistsList
 self.setResponsibleScientistsList(checkedScientists)
+self.updateProjectMembers()
 if fromEdit and (RESPONSE is not None):
 return self.editBasic()
 else:
 """updates project-member table"""
 if updateResponsibleScientistsList:
 # create responsibleScientistsList automatically
 newScientists = {}
 names = p.identifyNames(p.getResponsibleScientists())
-for name in names.keys():
+for name in names:
 logging.debug("updateAllProjectMembers: name=%s" % repr(name))
 members = names[name]
 if len(members) > 0:
 # take the first matching name
 newScientists[name] = {'name': name, 'key' : members[0].key, 'username' : re.sub('@mpiwg-berlin\.mpg\.de', '', members[0].e_mail)}
 return
 if len(memberlist) == 0:
 return
-# update old format responsibleScientistsList
-if isinstance(memberlist[0], tuple):
-logging.debug("updateAllProjectMembers: updating memberlist for project %s" % self)
-newScientists = {}
-for m in memberlist:
-name = m[0]
-key = m[1]
-username = None
-if key:
-if isinstance(key, list):
-key = key[0]
-# get username from db
-member = self.executeZSQL("select * from personal_www where lower(key) = %s", [key.lower()])
-if len(member) > 0:
-username = re.sub('@mpiwg-berlin\.mpg\.de', '', member[0].e_mail)
-newScientists[name] = {'name': name, 'key' : key, 'username' : username}
-# set and re-read new list
-self.setResponsibleScientistsList(newScientists)
-memberlist = self.getResponsibleScientistsList()
 # fill projects_members table
 self.executeZSQL("delete from projects_members where project_number = %s", [pNum])
 for m in memberlist:
-memberKey = m.get('key')
+memberKey = m.get('key', None)
 if not memberKey or not isinstance(memberKey, basestring):
 logging.error("updateProjectMembers: not a valid member key: %s" % repr(memberKey))
 continue
 self.executeZSQL("insert into projects_members (project_number, member_key) values (%s, %s)", (pNum, memberKey))
 # cached HashTree with project hierarchy
 _v_projectTree = None
 def getProjectTree(self):
-"""returns the project hierarchy tree (and caches it).
+"""Return the project hierarchy tree (and cache it).
-returns HashTree instance."""
+Returns HashTree instance."""
 tree = self._v_projectTree
 if tree is None:
-tree = HashTree(keySeparator='.', keyFn=lambda x:getInt(x))
+tree = HashTree(keySeparator='.', keyFn=getInt)
 for p in self.objectValues(spec='MPIWGProject'):
 tree.add(p.getNumber(), p)
 self._v_projectTree = tree
 # logging.debug("getProjectTree: tree=%s"%(tree.root.getSubtreeAsText()))
 return tree
 def getProjectsAsList(self, start, active=1, archived=1):
-"""returns flattened list of projects, starting from start.
+"""Return flattened list of projects, starting from start.
 active = 0 : all projects
 active = 1 : active projects
 active = 2 : inactive projects
 archived = 0 : all projects
 pl = node.getSubtreeAsList()
 # logging.debug("getProjectsAsList: node=(%s,%s) pl=%s"%(node.key,node.value,pl))
 # return filtered list
 return [p for p in pl if (p.checkActive(active) and p.checkArchived(archived))]
+def getProject(self, projectNumber=None):
+"""Return the matching project"""
+tree = self.getProjectTree()
+if projectNumber is not None:
+return tree.get(projectNumber)
+return None
 def getProjectsOfMember(self, key, active=1, archived=1):
-"""returns a list of all projects of a member.
+"""Return a list of all projects of a member.
 @param key: member's key
 active = 0 : all projects
 active = 1 : active projects
 active = 2 : inactive projects
 res = self.executeZSQL("select * from projects_members where lower(member_key) = %s", [key.lower()])
 tree = self.getProjectTree()
 # find projects in tree
 for r in res:
 p = tree.get(r.project_number)
+# check if active
 if p is not None and p.checkActive(active) and p.checkArchived(archived):
 projects.append(p)
+projects.sort(key=lambda p:[int(n) for n in p.getNumber().split('.')])
 return projects
 security.declareProtected('View management screens', 'updateAllProjectMembers')
 def updateAllProjectMembers(self, updateResponsibleScientistsList=False):
-"""re-creates responsibleScientistsLists and projects_members table from all current projects"""
+"""Re-create responsibleScientistsLists and projects_members table from all current projects."""
 # empty table
 self.executeZSQL('truncate table projects_members')
 cnt = 0
 # go through all projects
 for p in self.objectValues(spec='MPIWGProject'):
 logging.debug("updateAllProjectMembers: updating project %s" % p)
 p.updateProjectMembers(updateResponsibleScientistsList=updateResponsibleScientistsList)
 return "updated %s projects!" % cnt
+security.declareProtected('View management screens', 'updateAllProjects')
+def updateAllProjects(self, updateResponsibleScientistsList=False):
+"""Patch all current projects for legacy problems."""
+cnt = 0
+# go through all projects
+for (id, project) in self.ZopeFind(self, obj_metatypes=['MPIWGProject'], search_sub=1):
+cnt += 1
+#
+# hasRelatedPublicationsOldVersion
+#
+if project.hasRelatedPublicationsOldVersion():
+logging.debug("updateAllProjects(%s): update relatedPublicationsOldVersion!"%project.getId())
+project.copyPublicationsToList()
+#
+# old format responsibleScientistsList
+#
+memberlist = project.getResponsibleScientistsList()
+if len(memberlist) > 0 and isinstance(memberlist[0], tuple):
+logging.debug("updateAllProjects(%s): updating memberlist" % project.getId())
+newScientists = {}
+for m in memberlist:
+name = m[0]
+key = m[1]
+username = None
+if key:
+if isinstance(key, list):
+key = key[0]
+# get username from db
+member = self.getMPIWGRoot().getStaffFolder().getMember(key=key)
+if member is not None:
+username = member.getUsername()
+newScientists[name] = {'name': name, 'key' : key, 'username' : username}
+# set new list
+project.setResponsibleScientistsList(newScientists)
+#
+# remove old attributes
+#
+if hasattr(project, 'definedFields'):
+logging.debug("updateAllProjects(%s): has definedFields!"%project.getId())
+delattr(project, 'definedFields')
+#
+# update extended bibliography
+#
+if hasattr(project, 'publicationList'):
+logging.debug("updateAllProjects(%s): has publicationList!"%project.getId())
+extpub = project.publicationList
+if hasattr(extpub, 'connection_id'):
+logging.debug("updateAllProjects(%s): extended publication %s has connection_id=%s!"%(project.getId(),extpub.getId(),extpub.connection_id))
+return "updated %s projects!" % cnt
 def manage_addMPIWGProjectFolderForm(self):
 """form for adding a MPIWGProjectFolder"""
 pt = PageTemplateFile('zpt/project/manage_add_MPIWGProjectFolder', globals()).__of__(self)
 return pt()

Mercurial > hg > MPIWGWeb

comparison MPIWGProjects.py @ 48:f59bdd5f4890