File:  [Repository] / MPIWGWeb / MPIWGStaff.py
Revision 1.10.2.11: download - view: text, annotated - select for diffs - revision graph
Mon Oct 17 20:37:05 2005 UTC (18 years, 7 months ago) by dwinter
Branches: r2
minor

    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"):
   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"
   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)
   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,insertTuple)
   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): 
   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)
   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:     security.declareProtected('View management screens','changeResearch')
  243:     def changeResearch(self,noredirect=None):
  244:         """change the research entries"""
  245:         newEntries={}
  246:         id_main=self.REQUEST.form['id_main']
  247: 
  248:         mainfieldL=self.REQUEST.form['main_fields'].split(",")
  249:         mainfield={}
  250:         for x in mainfieldL:
  251:             tmp=x.split('__')
  252:             mainfield[tmp[0]]=tmp[1]
  253:         for field in self.REQUEST.form.keys():
  254:             splittedField=field.split("__")
  255:             if len(splittedField)<3:
  256:                 pass #kein datenbank eintrag
  257: 
  258:             elif splittedField[2]=='new': # store new entries
  259:                 if not newEntries.has_key(splittedField[0]):
  260:                     newEntries[splittedField[0]]={}
  261:                     
  262:                 newEntries[splittedField[0]][splittedField[1]]=self.REQUEST.form[field]
  263: 
  264:             else:
  265:                 query="UPDATE %s "%splittedField[0]
  266:                 query+="SET %s = '%s' "%(splittedField[1],sql_quote(self.REQUEST.form[field]))
  267:                 query+="WHERE oid = '%s' "%sql_quote(splittedField[2])
  268:                 
  269:                 self.ZSQLQuery(query)
  270: 
  271: 
  272:         #new entries
  273:         for newEntry in newEntries.keys():
  274:             query="INSERT INTO %s "%newEntry
  275:             keys=['id_main']
  276:             values=["'"+id_main+"'"]
  277:             for key in newEntries[newEntry].keys():
  278:                 keys.append(key)
  279:                 values.append("'"+newEntries[newEntry][key]+"'")
  280: 
  281: 
  282:             keystring=",".join(keys)
  283:                 
  284:             valuestring=",".join(values)
  285:                 
  286:             query+=" (%s) "%keystring
  287:             query+="VALUES (%s)"%valuestring
  288:             if not (newEntries[newEntry][mainfield[newEntry]].lstrip().rstrip()==""):
  289:                 self.ZSQLQuery(query)
  290: 
  291:         if not noredirect:
  292:             self.REQUEST.RESPONSE.redirect(self.REQUEST['HTTP_REFERER'])
  293:             
  294:     security.declareProtected('View management screens','editCV')    
  295:     def editCV(self,cv=None,oid=None,RESPONSE=None):
  296:          """edit Cv"""
  297: 
  298:          if (not cv):
  299:              pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editCV.zpt')).__of__(self)
  300:              return pt()
  301:         
  302:          query="UPDATE personal_www SET cv ='%s' WHERE oid='%s'"
  303: 
  304:          self.ZSQLQuery(query%(cv,oid))
  305:         
  306:          if RESPONSE:
  307:             RESPONSE.redirect("editCV")
  308: 
  309:     security.declareProtected('View management screens','editAwards')    
  310:     def editAwards(self,awards=None,oid=None,RESPONSE=None):
  311:          """edit a awards"""
  312: 
  313:          if (not awards):
  314:              pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editAwards.zpt')).__of__(self)
  315:              return pt()
  316:         
  317:          query="UPDATE personal_www SET awards ='%s' WHERE oid='%s'"
  318: 
  319:          self.ZSQLQuery(query%(awards,oid))
  320:         
  321:          if RESPONSE:
  322:             RESPONSE.redirect("editAwards")
  323: 
  324:     security.declareProtected('View management screens','editTalks')    
  325:     def editTalks(self):
  326:         """edit talks"""
  327: 
  328:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editTalks.zpt')).__of__(self)
  329:         return pt()
  330:         
  331:     security.declareProtected('View management screens','editTeaching')    
  332:     def editTeaching(self):
  333:         """edit Teaching"""
  334: 
  335:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editTeaching.zpt')).__of__(self)
  336:         return pt()
  337:         
  338:     def getDocTypes(self):
  339:         finds = self.ZopeFind(self.metadata.main.meta.bib,obj_metatypes=["OSAS_MetadataMapping__neu"])
  340: 
  341:         list= [x[0] for x in finds]
  342:         return "\n".join(list)
  343: 
  344:     security.declareProtected('View management screens','editMainData')    
  345:     def editMainData(self,REQUEST=None,RESPONSE=None,name=None,**argv):
  346:         """edit main data"""
  347:         
  348:     
  349:         if not name:
  350:             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editMainData.zpt')).__of__(self)
  351:             return pt() 
  352:         else:
  353:             
  354:             self.ZSQLChange(argv,_table="personal_www",_identify="<%s"%self.getDBId(),USE_FORM="yes")
  355:             if RESPONSE:
  356:                 RESPONSE.redirect("editMainData")
  357:                 
  358:     security.declareProtected('View management screens','newBibliogrpaphy')    
  359:     def newBibliography(self,_docType=None, _addEntry=None,RESPONSE=None,**argv):
  360:         
  361:         """add an entry to the bibliography"""
  362:         if not _docType: #kein docType
  363:             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','newBibliographyEntryDocType.zpt')).__of__(self)
  364:             return pt() 
  365:         elif _docType and not _addEntry: #doctype aber keine daten
  366:             self.REQUEST['_docType']=_docType
  367:             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','newBibliographyEntry.zpt')).__of__(self)
  368:             return pt() 
  369:         else: #doctype und daten
  370:             try:
  371:                 newId=self.ZSQLSimpleSearch("select nextval('id_raw')")[0].nextval
  372:             except:#id_raw existiert nich, dann neu erzeugen
  373:                 
  374:                 self.createOrUpdateId_raw()
  375:                 newId=self.ZSQLSimpleSearch("select nextval('id_raw')")[0].nextval
  376:                                 
  377:             bookId="b%06i" % newId
  378:             
  379:             self.ZSQLAdd(argv,_table="bibliography",reference_type=_docType,id=bookId)
  380:             self.ZSQLAdd(_table="publications",id_gen_bib=bookId,id_main=self.getDBId(),publish='yes')
  381:             self.updatePublicationDB(personId=self.getDBId())
  382:             
  383:         
  384:         if RESPONSE:
  385:             RESPONSE.redirect("editPublications")
  386:             
  387:         return True
  388:     
  389:     security.declareProtected('View management screens','editImage')    
  390:     def editImage(self):
  391:         """edit images"""
  392:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editImageStaff.zpt')).__of__(self)
  393:         return pt()
  394:     
  395:     security.declareProtected('View management screens','editBibliography')    
  396:     def editBibliography(self):
  397:         """edit the bibliography"""
  398:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editBibliographyEntry.zpt')).__of__(self)
  399:         return pt()
  400:     
  401:       
  402:     security.declareProtected('View management screens','editPublications')    
  403:     def editPublications(self):
  404:         """edit the bibliographie"""
  405: 
  406:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','editPublications.zpt')).__of__(self)
  407:         return pt()
  408:     
  409:     def changeSortingMode(self,sortingMode,RESPONSE=None,REQUEST=None):
  410:         """change sorting mode"""
  411:         self.sortingMode=sortingMode
  412:         
  413:         if RESPONSE and REQUEST:
  414:             REQUEST.RESPONSE.redirect(REQUEST['HTTP_REFERER'])
  415: 
  416:         return True
  417: 
  418:     def getSortingMode(self):
  419:         """get sorting mode"""
  420:         return getattr(self,'sortingMode','priority')
  421:     
  422:     def integer(self,value):
  423:         try:
  424:             return int(value)
  425:         except:
  426:             return 0
  427:         
  428:     security.declareProtected('View management screens','changePublications')    
  429:     def changePublications(self):
  430:         """change the publication list"""
  431:         self.changeResearch(noredirect=True)
  432:         
  433:         #self.updatePublicationDB(personId=self.getDBId())
  434:         self.REQUEST.RESPONSE.redirect(self.REQUEST['HTTP_REFERER'])
  435:         
  436: 
  437:     security.declareProtected('View management screens','addPublications')    
  438:     def addPublications(self,submit=None,REQUEST=None,noredirect=None):
  439:         """add publications"""
  440: 
  441:         #setzte flag ob aufruf aus suchformular
  442:         
  443:         if REQUEST.get("QUERY_STRING",None) and (not submit):
  444:             self.REQUEST.set('fromSearch','1')
  445:         else:
  446:             self.REQUEST.set('fromSearch','0')
  447:              
  448:         if not submit or (not (submit == "add")):
  449:             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','addPublications.zpt')).__of__(self)
  450:             return pt()
  451:         
  452:         #new entries
  453:         entries = REQUEST.form.get('addEntries',None)
  454:         if not (type(entries) is ListType):
  455:             entries=[entries]
  456:             
  457:         for bibId in entries: 
  458:             query="INSERT INTO %s " % "publications"
  459:             query+="(id_main,id_institutsbibliographie,publish) "
  460:             query+="VALUES ('%s','%s','yes')" %(sql_quote(self.getDBId()),sql_quote(bibId))
  461:             print "ADD",query
  462:             #self.ZSQLAdd(_table="publications",id_institutsbibliographie=bibId,id_main=self.getDBId(),publish='yes')
  463:             self.ZSQLQuery(query)
  464:      
  465:         self.updatePublicationDB(personId=self.getDBId())
  466:         
  467:         if not noredirect:
  468:             
  469:             self.REQUEST.RESPONSE.redirect("./editPublications")
  470:             
  471:             return True
  472:         
  473:     
  474:     def getDBId(self):
  475:         """get id from the personal database"""
  476:         search=self.ZSQLInlineSearch(_table='personal_www',username=self.getId(),publish_the_data='yes')
  477:         if search:#name existiert und published, dann nimm diesen falls es mehrereeventuell nich publizierte datensaetze gibt.
  478:             return search[0].id
  479:         else:#nicht publiziert dann nimm einen davon
  480:             search2=self.ZSQLInlineSearch(_table='personal_www',username=self.getId())
  481:             if search2:
  482:                 return search2[0].id
  483:             else:
  484:                 return None
  485:         
  486:     
  487:     
  488:     formatBiblHelp=bibliography.formatBiblHelp
  489:     
  490:     def sortBibliography(self,list,sortingMode=None):
  491:         if not sortingMode:
  492:             sortingMode=self.getSortingMode()
  493:     
  494:         if sortingMode == "year":
  495:             return self.sortYear(list)
  496:         else:
  497:             return self.sortPriority(list)
  498:         
  499:     def sortPriority(self,list):
  500:         def sort(x,y):
  501:             try:
  502:                 xInt=int(x.priority)
  503:             except:
  504:                 xInt=0
  505:             try:
  506:                 yInt=int(y.priority)
  507:             except:
  508:                 yInt=0
  509: 
  510:             return cmp(xInt,yInt)
  511: 
  512:         tmp=[x for x in list]
  513:         tmp.sort(sort)           
  514:         return tmp
  515: 
  516:     def sortYear(self,list):
  517:         #TODO: sort TO APPEAR and TO BE PUBLISHED etc...
  518:         
  519:         def sort(x,y):
  520:             try:
  521:                 xInt=int(x.year)
  522:             except:
  523:                 xInt=0
  524:             try:
  525:                 yInt=int(y.year)
  526:             except:
  527:                 yInt=0
  528: 
  529:             return cmp(yInt,xInt)
  530:             
  531:             
  532:         tmp=[x for x in list]
  533:         
  534:         tmp.sort(sort)           
  535:         return tmp
  536:     
  537:     def deleteField(self,table,oid):
  538:         """delete entry"""
  539:         query="DELETE FROM %s WHERE oid = '%s'"%(table,oid)
  540: 
  541:         self.ZSQLQuery(query)
  542:         self.REQUEST.RESPONSE.redirect(self.REQUEST['HTTP_REFERER'])
  543:         
  544:     
  545: def manage_addMPIWGStaffForm(self):
  546:     """form for adding the project"""
  547:     pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','addMPIWGStaffForm.zpt')).__of__(self)
  548:     return pt()
  549: 
  550: def manage_addMPIWGStaff(self,id,lastName,firstName,RESPONSE=None):
  551:     """add it"""
  552:     newObj=MPIWGStaff(id,lastName,firstName)
  553: 
  554:     self._setObject(id,newObj)
  555: 
  556: 
  557:     if RESPONSE is not None:
  558:         RESPONSE.redirect('manage_main')
  559: 
  560:     

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