File:  [Repository] / MPIWGWeb / MPIWGStaff.py
Revision 1.10.2.17: download - view: text, annotated - select for diffs - revision graph
Fri Nov 11 19:42:36 2005 UTC (18 years, 6 months ago) by dwinter
Branches: r2
bug in new user

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

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