File:  [Repository] / MPIWGWeb / MPIWGStaff.py
Revision 1.10.2.14: download - view: text, annotated - select for diffs - revision graph
Mon Oct 24 22:56:22 2005 UTC (18 years, 7 months ago) by dwinter
Branches: r2
stay added

    1: """This file contains the classes for the organization of the staff"""
    2: # TODO: pruefe ob die id der einzelnen tabellen, wie id in publications noch benutzt werden
    3: # TODO: pruefe ob die bibliographischen felder in publications noch benutzt werden
    4: # TODO: wird username gebraucht?
    5: 
    6: from OFS.Folder import Folder
    7: from Products.ZSQLExtend.ZSQLExtend import ZSQLExtendFolder
    8: from Products.PageTemplates.PageTemplateFile import PageTemplateFile
    9: from Products.PageTemplates.PageTemplate import PageTemplate
   10: from Products.ZCatalog.CatalogPathAwareness import CatalogAware
   11: import os
   12: import bibliography
   13: from Globals import package_home
   14: from Products.PythonScripts.standard import sql_quote
   15: from types import *
   16: from AccessControl import ClassSecurityInfo
   17: 
   18: departmentList="Renn\nRheinberger\nDaston\nKlein\nSibum\nIT\nInstitut\nBibliothek"
   19: 
   20: 
   21: def getTemplate(self, tpName):
   22:     """get a template file either form the instance or from the product"""
   23:     ext=self.ZopeFind(self.aq_parent,obj_ids=[tpName])
   24:     if ext:
   25:         pt = getattr(self,ext[0][1].getId())
   26:     else:
   27:         pt=PageTemplateFile(os.path.join(package_home(globals()), 'zpt/'+tpName)).__of__(self)
   28:     assert(pt)
   29:     return pt
   30: 
   31: class MPIWGStaff(CatalogAware,ZSQLExtendFolder):
   32:     """Staff"""
   33: 
   34:     meta_type="MPIWGStaff"
   35:     default_catalog='MembersCatalog'
   36:     departmentList=departmentList
   37:     security=ClassSecurityInfo()
   38:     
   39:     def getConnectionObj(self):#ueberschreibe connection id methode    
   40:          
   41:             return getattr(self.de,self.de.connection_id)
   42:         
   43:     def isPublished(self):
   44:         """gib publications status aus der datenbank aus"""
   45:         username=self.getId()
   46:         query="select count(publish_the_data) from personal_www where username='%s' and publish_the_data='yes'"%username
   47:         
   48:         res = self.ZSQLQuery(query)
   49:         
   50:         if res and res[0].count>0:
   51:             return True
   52:         else:
   53:             return False
   54:         
   55:     def createNewDBEntry(self,publish_the_data,id,name,vorname,username,title,e_mail,e_mail_p,date_from,date_to,abteilung,heimat_inst,funded_by="",e_mail2="",txt="",txt_p="no",stay_at_mpiwg=""):
   56:         """lege person in der datenbank an"""
   57:         msg=""
   58:         #test ob id schon existiert
   59:         if self.ZSQLQuery("select id from personal_www where id='%s'"%id):
   60:             return False,"ERROR:id %s already exists"%id
   61:         
   62:         if self.ZSQLQuery("select username from personal_www where username='%s' and publish_the_data='yes'"%username):
   63:             
   64:             return False,"ERROR:username %s already exists and has data published, id=%s not added (running update again might solve this problem)"%(username,id)
   65:         
   66:         if self.ZSQLQuery("select username from personal_www where username='%s' and not publish_the_data='yes'"%username):
   67:             msg="WARNING:username %s not unique but id=%s added"%(username,id)
   68:         #eintragen
   69:         columnlist="publish_the_data,id,name,vorname,username,title,e_mail,e_mail_p,date_from,date_to,abteilung,heimat_inst,funded_by,e_mail2,stay_at_mpiwg"
   70:         insertTuple=(publish_the_data,id,name,vorname,username,title,e_mail,e_mail_p,date_from,date_to,abteilung,heimat_inst,funded_by,e_mail2,stay_at_mpiwg)
   71:         
   72:         insert=[]
   73:         for element in insertTuple:
   74:             insert.append("'%s'"%element)
   75:         
   76:         insertStr=",".join(insert)
   77:         queryStr="INSERT INTO personal_www (%s) VALUES (%s)"%(columnlist,insertStr)
   78:         
   79:         self.ZSQLQuery(queryStr)
   80:         
   81:         #currentwork
   82:         if not (txt==""):
   83:             queryStr="INSERT INTO current_work (id_main,current,publish) VALUES ('%s','%s','%s')"%(id,txt,txt_p)
   84:             self.ZSQLQuery(queryStr)
   85:         
   86:         return True,msg
   87:     
   88:     def updateDBEntry(self,publish_the_data,date_from,date_to,DBid=None,stay_at_mpiwg=""): 
   89:         """zpddatedb"""
   90:         if not DBid:
   91:             DBid=self.getDBId()
   92:          
   93:         self.ZSQLQuery("SET DATESTYLE TO 'German'")
   94: 
   95:         self.ZSQLChange(_table="personal_www",_identify="id=%s"%DBid,publish_the_data=publish_the_data,
   96:                                    date_from=date_from,
   97:                                    date_to=date_to,stay_at_mpiwg=stay_at_mpiwg)
   98:                   
   99:           
  100:     def getPublicationSelectionMode(self):
  101:         """get publication selection mode, default 'priority'"""
  102:         return getattr(self,'publicationSelectionMode','priority')
  103:         
  104:     def changePublicationSelectionMode(self,publicationSelectionMode,RESPONSE=None):
  105:         """change PublicationSelectionMode"""
  106:         
  107:         self.publicationSelectionMode=publicationSelectionMode
  108:         
  109:         if RESPONSE:
  110:             RESPONSE.redirect("editPublications")
  111:             
  112:             
  113:     def getPublishImage(self):
  114:         """publish the image??, default no"""
  115:         return getattr(self,'publishImage','no')
  116:     
  117:     def updateImage(self,file,publishImage,rename=None,RESPONSE=None):
  118:         """update image"""
  119: 
  120:         if file and not(file.filename==""):
  121:             if self.getImageObj():
  122:                      self.getImageObj().updateImage(file,rename=None,RESPONSE=None)
  123:             else:
  124:                      self.getImageFolder().addImage2(file,fileName=self.getId())
  125:             
  126:         self.publishImage=publishImage
  127:         
  128:         if RESPONSE:
  129:             RESPONSE.redirect("edit")
  130:             
  131:     def getImageFolder(self):
  132:         """getImageFolder"""
  133:         return self.getPhysicalRoot().www_neu.images.staff_images
  134:     
  135:     def getImageObj(self):
  136:         """getImage"""
  137:         imageFolder=self.getImageFolder()
  138:         
  139:         image=getattr(imageFolder,self.getId(),None)
  140: 
  141:         if not image:
  142:             for suffix in ['jpg','tif']:
  143:                 
  144:                 image=getattr(imageFolder,self.getId()+"."+suffix,None)
  145:                 if image:
  146:                     break
  147:         return image
  148:             
  149:     def getImageUrl(self):
  150:         """getImageUrl"""
  151:         image=self.getImageObj()
  152:         if not image:
  153:             return None
  154:         else:
  155:             return self.getImageObj().absolute_url()+"/image"
  156:     
  157:     def PrincipiaSearchSource(self):
  158:         """Return cataloguable key for ourselves."""
  159:         return str(self)
  160: 
  161:     manage_options = Folder.manage_options+(
  162:         {'label':'Edit','action':'changeMPIWGStaffForm'},
  163:         {'label':'Change Publications Special','action':'changePublications_specialForm'},
  164:         )
  165:     
  166:     def __init__(self,id, lastName,firstName):
  167:         """init"""
  168:         self.id=id
  169:         self.title="%s, %s"%(lastName,firstName)
  170:         self.lastName=lastName
  171:         self.firstName=firstName
  172: 
  173: 
  174:     def index_html(self):
  175:         """show homepage"""
  176:         pt = getTemplate(self, "members_main")
  177:         return pt()
  178: 
  179:     def changePublications_specialForm(self):
  180:         """Priority publications manual field"""
  181:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','changePublications_special.zpt')).__of__(self)
  182:         return pt()
  183:         
  184:     def changePublications_special(self,usePublicationsSpecial=None,specialPublicationsField=None,RESPONSE=None):
  185:         """change publications special params"""
  186:         if usePublicationsSpecial:
  187:           self.usePublicationsSpecial=True
  188:          
  189:         else:
  190:           self.usePublicationsSpecial=False
  191: 
  192:         self.specialPublicationsField=specialPublicationsField[0:]
  193: 
  194:         if RESPONSE is not None:
  195:             RESPONSE.redirect('manage_main')
  196: 
  197:         
  198:     def publications_full(self):
  199:         """show publication"""
  200:         pt=getTemplate(self, "publications_full_main")
  201:         return pt()
  202: 
  203:     def talks_full(self):
  204:         """show talks"""
  205:         pt=getTemplate(self, 'talks_full_main')
  206:         return pt()
  207: 
  208:     def teaching_full(self):
  209:         """show talks"""
  210:         pt=getTemplate(self, 'teaching_full_main')
  211:         return pt()
  212:     
  213:     def changeMPIWGStaffForm(self):
  214:         """change form"""
  215:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','edit_MPIWGStaff.zpt')).__of__(self)
  216:         return pt()
  217:     
  218:     security.declareProtected('View management screens','changeMPIWGStaff')
  219:     def changeMPIWGStaff(self,lastName,firstName,RESPONSE=None):
  220:         """change it"""
  221:         self.title="%s, %s"%(lastName,firstName)
  222:         self.lastName=lastName
  223:         self.firstName=firstName
  224: 
  225:         if RESPONSE is not None:
  226:             RESPONSE.redirect('manage_main')
  227:             
  228:     security.declareProtected('View management screens','edit')
  229:     def edit(self):
  230:         """Edit the pages"""
  231:     #TODO: zusammenspiel mit apache, redirect auf 18080 rausnehmen bzw. zumindest verallgemeinern
  232:         if self.REQUEST['SERVER_URL']=="http://www.mpiwg-berlin.mpg.de":
  233:                 redURL="http://xserve04.mpiwg-berlin.mpg.de:18080/www_neu/de/mitarbeiter/members/%s/edit"%self.getId()
  234:         
  235:                 self.REQUEST.RESPONSE.redirect(redURL)
  236: 
  237:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editMPIWGStaff.zpt')).__of__(self)
  238:         return pt()
  239: 
  240:     mainEditFile=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editMPIWGStaff_main.zpt'))
  241: 
  242:     def getPathStyle(self, path, selected, style=""):
  243:         """returns a string with the given style + 'sel' if path == selected."""
  244: 
  245:         if path == selected:
  246:             return style + 'sel'
  247:         else:
  248:             return style    
  249: 
  250:     security.declareProtected('View management screens','changeResearch')
  251:     def changeResearch(self,noredirect=None):
  252:         """change the research entries"""
  253:         newEntries={}
  254:         id_main=self.REQUEST.form['id_main']
  255: 
  256:         mainfieldL=self.REQUEST.form['main_fields'].split(",")
  257:         mainfield={}
  258:         for x in mainfieldL:
  259:             tmp=x.split('__')
  260:             mainfield[tmp[0]]=tmp[1]
  261:         for field in self.REQUEST.form.keys():
  262:             splittedField=field.split("__")
  263:             if len(splittedField)<3:
  264:                 pass #kein datenbank eintrag
  265: 
  266:             elif splittedField[2]=='new': # store new entries
  267:                 if not newEntries.has_key(splittedField[0]):
  268:                     newEntries[splittedField[0]]={}
  269:                     
  270:                 newEntries[splittedField[0]][splittedField[1]]=self.REQUEST.form[field]
  271: 
  272:             else:
  273:                 query="UPDATE %s "%splittedField[0]
  274:                 query+="SET %s = '%s' "%(splittedField[1],sql_quote(self.REQUEST.form[field]))
  275:                 query+="WHERE oid = '%s' "%sql_quote(splittedField[2])
  276:                 
  277:                 self.ZSQLQuery(query)
  278: 
  279: 
  280:         #new entries
  281:         for newEntry in newEntries.keys():
  282:             query="INSERT INTO %s "%newEntry
  283:             keys=['id_main']
  284:             values=["'"+id_main+"'"]
  285:             for key in newEntries[newEntry].keys():
  286:                 keys.append(key)
  287:                 values.append("'"+newEntries[newEntry][key]+"'")
  288: 
  289: 
  290:             keystring=",".join(keys)
  291:                 
  292:             valuestring=",".join(values)
  293:                 
  294:             query+=" (%s) "%keystring
  295:             query+="VALUES (%s)"%valuestring
  296:             if not (newEntries[newEntry][mainfield[newEntry]].lstrip().rstrip()==""):
  297:                 self.ZSQLQuery(query)
  298: 
  299:         if not noredirect:
  300:             self.REQUEST.RESPONSE.redirect(self.REQUEST['HTTP_REFERER'])
  301:             
  302:     security.declareProtected('View management screens','editCV')    
  303:     def editCV(self,cv=None,oid=None,RESPONSE=None):
  304:          """edit Cv"""
  305: 
  306:          if (not cv):
  307:              pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editCV.zpt')).__of__(self)
  308:              return pt()
  309:         
  310:          query="UPDATE personal_www SET cv ='%s' WHERE oid='%s'"
  311: 
  312:          self.ZSQLQuery(query%(cv,oid))
  313:         
  314:          if RESPONSE:
  315:             RESPONSE.redirect("editCV")
  316: 
  317:     security.declareProtected('View management screens','editAwards')    
  318:     def editAwards(self,awards=None,oid=None,RESPONSE=None):
  319:          """edit a awards"""
  320: 
  321:          if (not awards):
  322:              pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editAwards.zpt')).__of__(self)
  323:              return pt()
  324:         
  325:          query="UPDATE personal_www SET awards ='%s' WHERE oid='%s'"
  326: 
  327:          self.ZSQLQuery(query%(awards,oid))
  328:         
  329:          if RESPONSE:
  330:             RESPONSE.redirect("editAwards")
  331: 
  332:     security.declareProtected('View management screens','editTalks')    
  333:     def editTalks(self):
  334:         """edit talks"""
  335: 
  336:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editTalks.zpt')).__of__(self)
  337:         return pt()
  338:         
  339:     security.declareProtected('View management screens','editTeaching')    
  340:     def editTeaching(self):
  341:         """edit Teaching"""
  342: 
  343:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editTeaching.zpt')).__of__(self)
  344:         return pt()
  345:         
  346:     def getDocTypes(self):
  347:         finds = self.ZopeFind(self.metadata.main.meta.bib,obj_metatypes=["OSAS_MetadataMapping__neu"])
  348: 
  349:         list= [x[0] for x in finds]
  350:         return "\n".join(list)
  351: 
  352:     security.declareProtected('View management screens','editMainData')    
  353:     def editMainData(self,REQUEST=None,RESPONSE=None,name=None,**argv):
  354:         """edit main data"""
  355:         
  356:     
  357:         if not name:
  358:             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editMainData.zpt')).__of__(self)
  359:             return pt() 
  360:         else:
  361:             
  362:             self.ZSQLChange(argv,_table="personal_www",_identify="<%s"%self.getDBId(),USE_FORM="yes")
  363:             if RESPONSE:
  364:                 RESPONSE.redirect("editMainData")
  365:                 
  366:     security.declareProtected('View management screens','newBibliogrpaphy')    
  367:     def newBibliography(self,_docType=None, _addEntry=None,RESPONSE=None,**argv):
  368:         
  369:         """add an entry to the bibliography"""
  370:         if not _docType: #kein docType
  371:             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','newBibliographyEntryDocType.zpt')).__of__(self)
  372:             return pt() 
  373:         elif _docType and not _addEntry: #doctype aber keine daten
  374:             self.REQUEST['_docType']=_docType
  375:             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','newBibliographyEntry.zpt')).__of__(self)
  376:             return pt() 
  377:         else: #doctype und daten
  378:             try:
  379:                 newId=self.ZSQLSimpleSearch("select nextval('id_raw')")[0].nextval
  380:             except:#id_raw existiert nich, dann neu erzeugen
  381:                 
  382:                 self.createOrUpdateId_raw()
  383:                 newId=self.ZSQLSimpleSearch("select nextval('id_raw')")[0].nextval
  384:                                 
  385:             bookId="b%06i" % newId
  386:             
  387:             self.ZSQLAdd(argv,_table="bibliography",reference_type=_docType,id=bookId)
  388:             self.ZSQLAdd(_table="publications",id_gen_bib=bookId,id_main=self.getDBId(),publish='yes')
  389:             self.updatePublicationDB(personId=self.getDBId())
  390:             
  391:         
  392:         if RESPONSE:
  393:             RESPONSE.redirect("editPublications")
  394:             
  395:         return True
  396:     
  397:     security.declareProtected('View management screens','editImage')    
  398:     def editImage(self):
  399:         """edit images"""
  400:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editImageStaff.zpt')).__of__(self)
  401:         return pt()
  402:     
  403:     security.declareProtected('View management screens','editBibliography')    
  404:     def editBibliography(self):
  405:         """edit the bibliography"""
  406:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editBibliographyEntry.zpt')).__of__(self)
  407:         return pt()
  408:     
  409:       
  410:     security.declareProtected('View management screens','editPublications')    
  411:     def editPublications(self):
  412:         """edit the bibliographie"""
  413: 
  414:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editPublications.zpt')).__of__(self)
  415:         return pt()
  416:     
  417:     def changeSortingMode(self,sortingMode,RESPONSE=None,REQUEST=None):
  418:         """change sorting mode"""
  419:         self.sortingMode=sortingMode
  420:         
  421:         if RESPONSE and REQUEST:
  422:             REQUEST.RESPONSE.redirect(REQUEST['HTTP_REFERER'])
  423: 
  424:         return True
  425: 
  426:     def getSortingMode(self):
  427:         """get sorting mode"""
  428:         return getattr(self,'sortingMode','priority')
  429:     
  430:     def integer(self,value):
  431:         try:
  432:             return int(value)
  433:         except:
  434:             return 0
  435:         
  436:     security.declareProtected('View management screens','changePublications')    
  437:     def changePublications(self):
  438:         """change the publication list"""
  439:         self.changeResearch(noredirect=True)
  440:         
  441:         #self.updatePublicationDB(personId=self.getDBId())
  442:         self.REQUEST.RESPONSE.redirect(self.REQUEST['HTTP_REFERER'])
  443:         
  444: 
  445:     security.declareProtected('View management screens','addPublications')    
  446:     def addPublications(self,submit=None,REQUEST=None,noredirect=None):
  447:         """add publications"""
  448: 
  449:         #setzte flag ob aufruf aus suchformular
  450:         
  451:         if REQUEST.get("QUERY_STRING",None) and (not submit):
  452:             self.REQUEST.set('fromSearch','1')
  453:         else:
  454:             self.REQUEST.set('fromSearch','0')
  455:              
  456:         if not submit or (not (submit == "add")):
  457:             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','addPublications.zpt')).__of__(self)
  458:             return pt()
  459:         
  460:         #new entries
  461:         entries = REQUEST.form.get('addEntries',None)
  462:         if not (type(entries) is ListType):
  463:             entries=[entries]
  464:             
  465:         for bibId in entries: 
  466:             query="INSERT INTO %s " % "publications"
  467:             query+="(id_main,id_institutsbibliographie,publish) "
  468:             query+="VALUES ('%s','%s','yes')" %(sql_quote(self.getDBId()),sql_quote(bibId))
  469:             print "ADD",query
  470:             #self.ZSQLAdd(_table="publications",id_institutsbibliographie=bibId,id_main=self.getDBId(),publish='yes')
  471:             self.ZSQLQuery(query)
  472:      
  473:         self.updatePublicationDB(personId=self.getDBId())
  474:         
  475:         if not noredirect:
  476:             
  477:             self.REQUEST.RESPONSE.redirect("./editPublications")
  478:             
  479:             return True
  480:         
  481:     
  482:     def getDBId(self):
  483:         """get id from the personal database"""
  484:         search=self.ZSQLInlineSearch(_table='personal_www',username=self.getId(),publish_the_data='yes')
  485:         if search:#name existiert und published, dann nimm diesen falls es mehrereeventuell nich publizierte datensaetze gibt.
  486:             return search[0].id
  487:         else:#nicht publiziert dann nimm einen davon
  488:             search2=self.ZSQLInlineSearch(_table='personal_www',username=self.getId())
  489:             if search2:
  490:                 return search2[0].id
  491:             else:
  492:                 return None
  493:         
  494:     
  495:     
  496:     formatBiblHelp=bibliography.formatBiblHelp
  497:     
  498:     def sortBibliography(self,list,sortingMode=None):
  499:         if not sortingMode:
  500:             sortingMode=self.getSortingMode()
  501:     
  502:         if sortingMode == "year":
  503:             return self.sortYear(list)
  504:         else:
  505:             return self.sortPriority(list)
  506:         
  507:     def sortPriority(self,list):
  508:         def sort(x,y):
  509:             try:
  510:                 xInt=int(x.priority)
  511:             except:
  512:                 xInt=0
  513:             try:
  514:                 yInt=int(y.priority)
  515:             except:
  516:                 yInt=0
  517: 
  518:             return cmp(xInt,yInt)
  519: 
  520:         tmp=[x for x in list]
  521:         tmp.sort(sort)           
  522:         return tmp
  523: 
  524:     def sortYear(self,list):
  525:         #TODO: sort TO APPEAR and TO BE PUBLISHED etc...
  526:         
  527:         def sort(x,y):
  528:             try:
  529:                 xInt=int(x.year)
  530:             except:
  531:                 xInt=0
  532:             try:
  533:                 yInt=int(y.year)
  534:             except:
  535:                 yInt=0
  536: 
  537:             return cmp(yInt,xInt)
  538:             
  539:             
  540:         tmp=[x for x in list]
  541:         
  542:         tmp.sort(sort)           
  543:         return tmp
  544:     
  545:     def deleteField(self,table,oid):
  546:         """delete entry"""
  547:         query="DELETE FROM %s WHERE oid = '%s'"%(table,oid)
  548: 
  549:         self.ZSQLQuery(query)
  550:         self.REQUEST.RESPONSE.redirect(self.REQUEST['HTTP_REFERER'])
  551:         
  552:     
  553: def manage_addMPIWGStaffForm(self):
  554:     """form for adding the project"""
  555:     pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','addMPIWGStaffForm.zpt')).__of__(self)
  556:     return pt()
  557: 
  558: def manage_addMPIWGStaff(self,id,lastName,firstName,RESPONSE=None):
  559:     """add it"""
  560:     newObj=MPIWGStaff(id,lastName,firstName)
  561: 
  562:     self._setObject(id,newObj)
  563: 
  564: 
  565:     if RESPONSE is not None:
  566:         RESPONSE.redirect('manage_main')
  567: 
  568:     

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