version 1.49, 2005/03/18 16:57:21
|
version 1.67, 2005/10/17 19:20:49
|
Line 1
|
Line 1
|
|
|
|
genericServerPath="http://content.mpiwg-berlin.mpg.de/zogilib_images" |
|
#genericServerPath="http://127.0.0.1:8080/zogilib_images" |
|
|
|
|
from OFS.Folder import Folder |
from OFS.Folder import Folder |
from OFS.SimpleItem import SimpleItem |
from OFS.SimpleItem import SimpleItem |
from Globals import Persistent,package_home |
from Globals import Persistent,package_home |
from Acquisition import Implicit |
from Acquisition import Implicit |
from Products.PageTemplates.PageTemplateFile import PageTemplateFile |
from Products.PageTemplates.PageTemplateFile import PageTemplateFile |
from Products.PageTemplates.PageTemplate import PageTemplate |
from Products.PageTemplates.PageTemplate import PageTemplate |
|
from xmlrpclib import ServerProxy |
import re |
import re |
import os |
import os |
import os.path |
import os.path |
Line 14 import tempfile
|
Line 20 import tempfile
|
import shutil |
import shutil |
from types import * |
from types import * |
import time |
import time |
|
from threading import Thread |
|
import Queue |
|
import cgi |
|
|
|
from AccessControl import ClassSecurityInfo |
|
|
|
try: |
|
from Products.ZSQLExtend.ZSQLExtend import ZSQLExtendFolder |
|
except: |
|
print "ZSQL Extend Folder nicht importiert" |
|
print "Metadatendfolder funktioniert nicht!!!" |
|
|
|
|
|
|
try: |
try: |
from Products.ECHO_content.ECHO_collection import ECHO_basis |
from Products.ECHO_content.ECHO_collection import ECHO_basis |
Line 25 except:
|
Line 44 except:
|
manage_options=() |
manage_options=() |
|
|
|
|
|
tdir = "/mpiwg/temp/tmp/archivesImageServer/" |
|
#tdir="/tmp/archivesImageServer/" |
|
|
def splitPath(str): |
def splitPath(str): |
str2=str.replace("\\","/") |
str2=str.replace("\\","/") |
Line 47 def getTextFromNode(nodename):
|
Line 68 def getTextFromNode(nodename):
|
rc = rc + node.data |
rc = rc + node.data |
return rc |
return rc |
|
|
|
class generateSet: |
|
"""generateSetThread""" |
|
|
|
|
|
def __init__(self,filenames,filenamesIds,ImageViewerPath,ids,url,local=None,version="working"): |
|
"""init generateSet""" |
|
self.filenames=filenames |
|
self.filenamesIds=filenamesIds |
|
self.ImageViewerPath=ImageViewerPath |
|
self.ids=ids |
|
self.local=local |
|
self.url=url |
|
self.version=version |
|
self.done=None |
|
|
|
|
|
def __call__(self): |
|
"""call generate Set""" |
|
|
|
storeTempDir=tempfile.tempdir |
|
tempfile.tempdir=tdir |
|
|
|
tmpPath=tempfile.mktemp() |
|
tmpZip=tempfile.mktemp()+".gtz" |
|
tmpFn=os.path.split(tmpZip)[1] |
|
|
|
if not os.path.exists(tempfile.tempdir): |
|
os.mkdir(tempfile.tempdir) |
|
|
|
if not os.path.exists(tmpPath): |
|
os.mkdir(tmpPath) |
|
|
|
self.response="" |
|
|
|
|
|
self.response="<h3>1. step: getting the images</h3>" |
|
|
|
for id in self.filenames: |
|
|
|
if self.filenamesIds.has_key(id[0]): |
|
filename=self.filenamesIds[id[0]][0]+"_"+id[0] |
|
else: |
|
filename=id[0] |
|
|
|
self.response+=str("<p>Get File: %s<br>\n"%filename) |
|
|
|
|
|
if self.local: |
|
|
|
if self.version=="working": |
|
|
|
sourcePath="/mpiwg/temp/online/scaled/small/"+self.ImageViewerPath+"/"+os.path.splitext(id[0])[0]+".jpg" |
|
else: |
|
sourcePath="/mpiwg/online/"+self.ImageViewerPath+"/"+id[0] |
|
targetPath=tmpPath+"/"+filename |
|
try: |
|
shutil.copyfile(sourcePath,targetPath) |
|
except: |
|
self.response+=(str("<p>Error in File: %s (possible missing)<br>\n"%filename)) |
|
else: |
|
if self.version=="working": |
|
requestString=self.ImageViewerPath+"/"+os.path.splitext(urllib.quote(id[0]))[0]+"&dh=2000&dw=2000" |
|
path=getattr(self,'serverPath',genericServerPath)+"/scaledImage?fn="+requestString |
|
|
|
else: |
|
requestString=self.ImageViewerPath+"/"+os.path.splitext(urllib.quote(id[0]))[0]+"&mo=rawfile,hires" |
|
path=getattr(self,'serverPath',genericServerPath)+"/scaledImage?fn="+requestString |
|
|
|
|
|
image=urllib.urlopen(path).read() |
|
|
|
|
|
fh=file(tmpPath+"/"+filename,"w") |
|
|
|
|
|
fh.write(image) |
|
fh.close() |
|
|
|
#folgeseiten |
|
|
|
if int(self.filenamesIds[id[0]][1])>1: |
|
#ids=self.show_thumbs() |
|
|
|
try: |
|
nr=self.ids.index(id[0]) |
|
except: |
|
self.response+=str("<p>Error in File: %s (possible missing)<br>\n"%id[0]) |
|
|
|
|
|
nr=0 |
|
|
|
numberOfPages=self.filenamesIds[id[0]][1] |
|
for k in range(int(numberOfPages)-1): |
|
i=k+1 |
|
if self.filenamesIds.has_key(id[0]): |
|
filename=self.filenamesIds[id[0]][0]+"_"+self.ids[nr+i] |
|
else: |
|
filename=id[0] |
|
|
|
self.response+=str("<p>Get File: %s<br>\n"%filename) |
|
|
|
if self.local: |
|
sourcePath="/mpiwg/online/"+self.ImageViewerPath+"/"+self.ids[nr+i] |
|
targetPath=tmpPath+"/"+filename |
|
try: |
|
shutil.copyfile(sourcePath,targetPath) |
|
|
|
except: |
|
self.response+=str("<p>Error in File: %s (missing?)<br>\n"%filename) |
|
|
|
else: |
|
|
|
requestString=self.ImageViewerPath+"/"+os.path.splitext(ids[nr+i])[0]+"&mo=rawfile,hires" |
|
path=getattr(self,'serverPath',genericServerPath)+"/scaledImage?fn="+requestString |
|
|
|
image=urllib.urlopen(path).read() |
|
|
|
|
|
fh=file(tmpPath+"/"+filename,"w") |
|
fh.write(image) |
|
fh.close() |
|
|
|
self.response+="<h3>2. step: creating the downloadable file</h3>" |
|
self.response+="<p>Create gtar<br>" |
|
self.response+="<p>This can take a while....<br>\n" |
|
|
|
fh=os.popen2("gnutar zcvf %s %s/*"%(tmpZip,tmpPath),1)[1] |
|
self.response+="<br>" |
|
for c in fh.read(): |
|
self.response+=c |
|
if c==")": |
|
self.response+="<br>\n" |
|
|
|
|
|
|
|
|
|
shutil.rmtree(tmpPath) |
|
|
|
self.response+="<p>finished<br>\n" |
|
|
|
len=os.stat(tmpZip)[6] |
|
downloadUrl=self.url+"/downloadSet" |
|
self.response+="""<h1><a href="downloadSet?fn=%s">Click here for download ( %i Byte)</a></h1>\n"""%(tmpFn,len) |
|
self.response+="""<p>The file will be stored for a while, you can download it later, the URL is:</p> |
|
<p><a href="downloadSet?fn=%s">%s?fn=%s</a></h1>\n"""%(tmpFn,downloadUrl,tmpFn) |
|
|
|
self.done=True |
|
def getResult(self): |
|
"""get result""" |
|
return self.response |
|
|
|
def isDone(self): |
|
if self.done: |
|
return True |
|
else: |
|
return False |
|
|
class metaData(SimpleItem): |
class metaData(SimpleItem): |
"""Klasse fuer metadaten""" |
"""Klasse fuer metadaten""" |
meta_type="metaData" |
meta_type="metaData" |
Line 86 class metaData(SimpleItem):
|
Line 264 class metaData(SimpleItem):
|
return ret+"</body></html>" |
return ret+"</body></html>" |
|
|
|
|
|
|
|
|
class ImageDigilib(Folder,Persistent,Implicit): |
class ImageDigilib(Folder,Persistent,Implicit): |
"""Anzeige object fuer digilib""" |
"""Anzeige object fuer digilib""" |
meta_type="ImageDigilib" |
meta_type="ImageDigilib" |
|
security=ClassSecurityInfo() |
leiden_meta_fields=['image_id','date','country','place','people','description','photographer'] |
leiden_meta_fields=['image_id','date','country','place','people','description','photographer'] |
|
|
manage_options = Folder.manage_options+( |
manage_options = Folder.manage_options+( |
Line 127 class ImageDigilib(Folder,Persistent,Imp
|
Line 307 class ImageDigilib(Folder,Persistent,Imp
|
self.filename=filename |
self.filename=filename |
self.meta=meta |
self.meta=meta |
|
|
|
|
def getMeta(self): |
def getMeta(self): |
"""ausgabe der metadaten""" |
"""ausgabe der metadaten""" |
return self.meta |
return self.meta |
Line 180 class ImageDigilib(Folder,Persistent,Imp
|
Line 361 class ImageDigilib(Folder,Persistent,Imp
|
|
|
def download(self,fmt="&mo=rawfile,hires",suffix=None): |
def download(self,fmt="&mo=rawfile,hires",suffix=None): |
"""download""" |
"""download""" |
path="http://nausikaa2.rz-berlin.mpg.de/digitallibrary/servlet/Scaler/?fn="+self.ImageViewerPath+"/"+os.path.splitext(self.filename)[0]+fmt |
|
|
requestString=self.ImageViewerPath+"/"+os.path.splitext(self.filename)[0]+fmt |
|
path=getattr(self,'serverPath',genericServerPath)+"/scaledImage?fn="+requestString |
|
|
|
|
if self.REQUEST.SESSION.has_key('filenamesIds') and self.REQUEST.SESSION['filenamesIds'].has_key(self.filename): |
if self.REQUEST.SESSION.has_key('filenamesIds') and self.REQUEST.SESSION['filenamesIds'].has_key(self.filename): |
filename=self.REQUEST.SESSION['filenamesIds'][self.filename][0]+"_"+self.filename |
filename=self.REQUEST.SESSION['filenamesIds'][self.filename][0]+"_"+self.filename |
Line 204 class ImageDigilib(Folder,Persistent,Imp
|
Line 388 class ImageDigilib(Folder,Persistent,Imp
|
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','upDateImageForm.zpt')).__of__(self) |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','upDateImageForm.zpt')).__of__(self) |
return pt() |
return pt() |
|
|
|
|
|
security.declareProtected('View management screens','renameImageForm') |
def renameImageForm(self): |
def renameImageForm(self): |
"""form""" |
"""form""" |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','renameImageForm.zpt')).__of__(self) |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','renameImageForm.zpt')).__of__(self) |
return pt() |
return pt() |
|
|
|
security.declareProtected('View management screens','renameImage') |
def renameImage(self,newname,RESPONSE=None): |
def renameImage(self,newname,RESPONSE=None): |
"""umbenennen""" |
"""umbenennen""" |
#umbennen des files im folder |
#umbennen des files im folder |
Line 311 class ImageDigilib(Folder,Persistent,Imp
|
Line 498 class ImageDigilib(Folder,Persistent,Imp
|
def thumb(self,url=None): |
def thumb(self,url=None): |
"""show thumb""" |
"""show thumb""" |
thumbname=os.path.splitext(self.filename)[0]+".jpg" |
thumbname=os.path.splitext(self.filename)[0]+".jpg" |
## if not os.path.exists("/mpiwg/temp/online/scaled/small/"+self.ImageViewerPath+"/"+thumbname): |
requestString=self.ImageViewerPath+"/"+os.path.splitext(self.filename)[0]+"&dw=100&dh=100&mo=lores" |
## image=urllib.urlopen("http://nausikaa2.rz-berlin.mpg.de:18080/digitallibrary/servlet/Scaler/?fn="+self.ImageViewerPath+"/"+self.filename+"&dw=150&mo=lores").read() |
path=getattr(self,'serverPath',genericServerPath)+"/scaledImage?fn="+requestString |
## f=open("/mpiwg/temp/online/scaled/small/"+self.ImageViewerPath+"/"+thumbname,"w") |
|
## f.write(image) |
|
## f.close() |
|
## os.popen("ssh nausikaa2.rz-berlin.mpg.de /usr/local/mpiwg/scripts/scaleomat.pl %s /mpiwg/temp/online/scaled/small 150 &"% self.ImageViewerPath) |
|
|
|
#DEVEL:take nausikaa for server solution |
|
|
|
path="http://nausikaa2.rz-berlin.mpg.de/digitallibrary/servlet/Scaler/?fn="+self.ImageViewerPath+"/"+os.path.splitext(self.filename)[0]+"&dw=100&dh=100&mo=lores" |
|
#path="/mpiwg/online/"+self.ImageViewerPath+"/"+thumbname |
|
self.REQUEST.SESSION['string']="<img border=\"0\" src=\"%s\">"% path |
self.REQUEST.SESSION['string']="<img border=\"0\" src=\"%s\">"% path |
if url: |
if url: |
return "<img border=\"0\" src=\"%s\">"% path |
return "<img border=\"0\" src=\"%s\">"% path |
Line 329 class ImageDigilib(Folder,Persistent,Imp
|
Line 509 class ImageDigilib(Folder,Persistent,Imp
|
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','thumb.zpt')).__of__(self) |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','thumb.zpt')).__of__(self) |
return pt() |
return pt() |
|
|
|
|
|
def thumbMD(self,url=None): |
|
"""show thumb mit Metadaten erwarten image in ImageCollectionMD |
|
""" |
|
thumbname=os.path.splitext(self.filename)[0]+".jpg" |
|
|
|
requestString=self.ImageViewerPath+"/"+os.path.splitext(self.filename)[0]+"&dw=100&dh=100&mo=lores" |
|
path=getattr(self,'serverPath',genericServerPath)+"/scaledImage?fn="+requestString |
|
|
|
|
|
|
|
self.REQUEST.SESSION['string']="<img border=\"0\" src=\"%s\">"% path |
|
if url: |
|
return "<img border=\"0\" src=\"%s\">"% path |
|
else: |
|
|
|
overview=self.ZopeFind(self.aq_parent,obj_ids=['thumb.html']) |
|
if overview: |
|
return getattr(self,overview[0][0])() |
|
else: |
|
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','thumbMD.zpt')).__of__(self) |
|
return pt() |
|
|
|
|
|
def image(self,dw=None,dh=None): |
|
"""show image only with scaler""" |
|
str=[] |
|
if (not dw) and (not dh): |
|
str.append("mo=file") |
|
if dw: |
|
str.append("dw=%s"%dw) |
|
|
|
if dh: |
|
str.append("dw=%s"%dh) |
|
|
|
str.append("lv=2&fn=%s"%self.ImageViewerPath+"/"+os.path.splitext(self.filename)[0]) |
|
|
|
|
|
requestString="&".join(str) |
|
|
|
self.REQUEST.RESPONSE.redirect(getattr(self,'serverPath',genericServerPath)+"/scaledImage?"+requestString) |
|
|
def index_html(self): |
def index_html(self): |
"""show image""" |
"""show image with zogilib""" |
#DEVELOP: take first one for server |
#DEVELOP: take first one for server |
|
#path="http://127.0.0.1:8080/zogilib_images?lv=2&fn="+self.ImageViewerPath+"/"+os.path.splitext(self.filename)[0] |
path="http://content.mpiwg-berlin.mpg.de/zogilib_images?lv=2&fn="+self.ImageViewerPath+"/"+os.path.splitext(self.filename)[0] |
path=getattr(self,'serverPath',genericServerPath)+"?lv=2&fn="+self.ImageViewerPath+"/"+os.path.splitext(self.filename)[0] |
return self.REQUEST.RESPONSE.redirect(path) |
return self.REQUEST.RESPONSE.redirect(path) |
|
|
|
|
Line 358 def manage_AddImageDigilib(self,id,fileu
|
Line 580 def manage_AddImageDigilib(self,id,fileu
|
|
|
|
|
class ImageCollection(Folder, Persistent, Implicit,ECHO_basis): |
class ImageCollection(Folder, Persistent, Implicit,ECHO_basis): |
|
"""Sammelordner fuer Bilder""" |
"""Sammelordner für Bilder""" |
|
meta_type="ImageCollection" |
meta_type="ImageCollection" |
|
|
|
|
|
security=ClassSecurityInfo() |
|
|
|
#scalerPath="http://127.0.0.1:18080/digitallibrary/servlet/Scaler/?fn=" |
|
#scalerPath="http://nausikaa2.rz-berlin.mpg.de/digitallibrary/servlet/Scaler/?fn=" |
|
|
|
zipThreads={} |
|
zipThreads2={} |
|
|
genericMetaDataType="leiden_meta" |
genericMetaDataType="leiden_meta" |
|
|
Line 371 class ImageCollection(Folder, Persistent
|
Line 599 class ImageCollection(Folder, Persistent
|
|
|
defaultMetaString="http://fm-web.mpiwg-berlin.mpg.de:8050/FMRes/FMPJS?-db=Wissenschaftlerportraits.fp5&-layID=69&-token=25&-max=1&-format=formvwcss.htm&-mode=browse&images::filename=%s&-find" ## TEST FUER IMAGEDATENBANK WP |
defaultMetaString="http://fm-web.mpiwg-berlin.mpg.de:8050/FMRes/FMPJS?-db=Wissenschaftlerportraits.fp5&-layID=69&-token=25&-max=1&-format=formvwcss.htm&-mode=browse&images::filename=%s&-find" ## TEST FUER IMAGEDATENBANK WP |
|
|
|
def getScalerPath(self): |
|
"""get ScalerPath""" |
|
path=getattr(self,'serverPath',genericServerPath)+"/scaledImage?fn=" |
|
|
|
def getImageViewerPath(self): |
|
"""get ImageViewerPath""" |
|
return self.ImageViewerPath |
|
|
|
def getImageStoragePath(self): |
|
"""get ImageStoragePath""" |
|
return self.ImageStoragePath |
|
|
|
def refreshTxt(self): |
|
"""txt fuer refresh""" |
|
tn=self.REQUEST.SESSION['threadName'] |
|
return """ 2;url=%s?repeat=%s """%(self.absolute_url()+"/createSet",tn) |
|
|
|
def createSet(self,RESPONSE=None,local=None,version="working",repeat=None): |
def createSet(self,RESPONSE=None,local=None,version="working"): |
|
"""download aller gewaehlten files""" |
"""download aller gewaehlten files""" |
storeTempDir=tempfile.tempdir |
|
tempfile.tempdir="/tmp/archivesImageServer" |
|
|
|
tmpPath=tempfile.mktemp() |
|
|
|
|
threadName=repeat |
tmpZip=tempfile.mktemp()+".zip" |
|
tmpFn=os.path.split(tmpZip)[1] |
|
|
|
|
|
if not os.path.exists(tempfile.tempdir): |
if not threadName or threadName=="": |
os.mkdir(tempfile.tempdir) |
threadStart=generateSet(self.REQUEST.SESSION['filenames'],self.REQUEST.SESSION['filenamesIds'],self.ImageViewerPath,self.show_thumbs(),self.absolute_url(),local=local,version=version) |
|
thread=Thread(target=threadStart) |
|
|
if not os.path.exists(tmpPath): |
thread.start() |
os.mkdir(tmpPath) |
|
|
|
|
|
if RESPONSE: |
self.zipThreads[thread.getName()[0:]]=threadStart |
RESPONSE.setHeader("Content-Type","text/html") |
self.zipThreads2[thread.getName()[0:]]=thread |
RESPONSE.write("<h1>I am creating the download archive</h1>") |
self.REQUEST.SESSION['threadName']=thread.getName()[0:] |
RESPONSE.write("<h3>1. step: getting the images</h3>") |
wait_template=self.aq_parent.ZopeFind(self.aq_parent,obj_ids=['zip_wait_template']) |
|
if wait_template: |
if not self.REQUEST.SESSION.has_key('filenames'): |
return wait_template[0][1]() |
RESPONSE.write("<h2>ERROR</h2>") |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','zip_wait.zpt')).__of__(self) |
RESPONSE.write("<p>I forgot, the selected files. Please reselect.\n") |
return pt() |
return 0 |
#xmltrans.run() |
|
|
for id in self.REQUEST.SESSION['filenames']: |
|
|
|
if self.REQUEST.SESSION.has_key('filenamesIds') and self.REQUEST.SESSION['filenamesIds'].has_key(id[0]): |
|
filename=self.REQUEST.SESSION['filenamesIds'][id[0]][0]+"_"+id[0] |
|
else: |
else: |
filename=id[0] |
self.REQUEST.SESSION['threadName']=threadName |
|
|
if RESPONSE: |
if (self.zipThreads[threadName].getResult()==None): |
RESPONSE.write(str("<p>Get File: %s<br>\n"%filename)) |
|
|
|
if local: |
|
if version=="working": |
|
sourcePath="/mpiwg/temp/online/scaled/small/"+self.ImageViewerPath+"/"+os.path.splitext(id[0])[0]+".jpg" |
|
else: |
|
sourcePath="/mpiwg/online/"+self.ImageViewerPath+"/"+id[0] |
|
targetPath=tmpPath+"/"+filename |
|
try: |
|
shutil.copyfile(sourcePath,targetPath) |
|
except: |
|
if RESPONSE: |
|
RESPONSE.write(str("<p>Error in File: %s (possible missing)<br>\n"%filename)) |
|
else: |
|
"""nothing""" |
|
else: |
|
if version=="working": |
|
path="http://nausikaa2.rz-berlin.mpg.de/digitallibrary/servlet/Scaler/?fn="+self.ImageViewerPath+"/"+os.path.splitext(urllib.quote(id[0]))[0]+"&dh=2000&dw=2000" |
|
else: |
|
path="http://nausikaa2.rz-berlin.mpg.de/digitallibrary/servlet/Scaler/?fn="+self.ImageViewerPath+"/"+os.path.splitext(urllib.quote(id[0]))[0]+"&mo=rawfile,hires" |
|
image=urllib.urlopen(path).read() |
|
|
|
|
wait_template=self.aq_parent.ZopeFind(self.aq_parent,obj_ids=['wait_template']) |
|
if wait_template: |
|
return wait_template[0][1]() |
|
|
fh=file(tmpPath+"/"+filename,"w") |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','zip_wait.zpt')).__of__(self) |
|
return pt() |
|
|
fh.write(image) |
|
fh.close() |
|
|
|
#folgeseiten |
|
if int(self.REQUEST.SESSION['filenamesIds'][id[0]][1])>1: |
|
ids=self.show_thumbs() |
|
try: |
|
nr=ids.index(id[0]) |
|
except: |
|
if RESPONSE: |
|
RESPONSE.write(str("<p>Error in File: %s (possible missing)<br>\n"%id[0])) |
|
else: |
|
"""nothing""" |
|
|
|
nr=0 |
|
|
|
numberOfPages=self.REQUEST.SESSION['filenamesIds'][id[0]][1] |
|
for k in range(int(numberOfPages)-1): |
|
i=k+1 |
|
if self.REQUEST.SESSION.has_key('filenamesIds') and self.REQUEST.SESSION['filenamesIds'].has_key(id[0]): |
|
filename=self.REQUEST.SESSION['filenamesIds'][id[0]][0]+"_"+ids[nr+i] |
|
else: |
else: |
filename=id[0] |
if self.zipThreads[threadName].isDone(): |
|
self.REQUEST.SESSION['result']=self.zipThreads[threadName].getResult() |
if RESPONSE: |
self.zipThreads2[threadName].join() |
RESPONSE.write(str("<p>Get File: %s<br>\n"%filename)) |
del(self.zipThreads2[threadName]) |
|
del(self.zipThreads[threadName]) |
|
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','zip_result.zpt')).__of__(self) |
|
return pt() |
|
|
if local: |
|
sourcePath="/mpiwg/online/"+self.ImageViewerPath+"/"+ids[nr+1] |
|
targetPath=tmpPath+"/"+filename |
|
try: |
|
shutil.copyfile(sourcePath,targetPath) |
|
except: |
|
if RESPONSE: |
|
RESPONSE.write(str("<p>Error in File: %s (missing?)<br>\n"%filename)) |
|
else: |
else: |
"""nothing""" |
self.REQUEST.SESSION['result']=self.zipThreads[threadName].getResult() |
else: |
self.REQUEST.SESSION['threadName']=threadName |
path="http://nausikaa2.rz-berlin.mpg.de/digitallibrary/servlet/Scaler/?fn="+self.ImageViewerPath+"/"+os.path.splitext(ids[nr+i])[0]+"&mo=rawfile,hires" |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','zip_wait_result.zpt')).__of__(self) |
|
return pt() |
image=urllib.urlopen(path).read() |
|
|
|
|
|
fh=file(tmpPath+"/"+filename,"w") |
|
fh.write(image) |
|
fh.close() |
|
|
|
if RESPONSE: |
|
RESPONSE.write("<h3>2. step: creating the downloadable file</h3>") |
|
RESPONSE.write("<p>Create Zip<br>") |
|
RESPONSE.write("<p>This can take a while....<br>\n") |
|
if RESPONSE: |
|
fh=os.popen2("zip -u %s %s/*"%(tmpZip,tmpPath),1)[1] |
|
RESPONSE.write("<br>") |
|
for c in fh.read(): |
|
RESPONSE.write(c) |
|
|
|
if c==")": |
|
RESPONSE.write("<br>\n") |
|
|
|
|
def checkThreads(self): |
|
"""teste running threads""" |
|
ret="""<html> |
|
<head> |
|
<meta http-equiv="REFRESH" content="5;url=%s/checkThreads" |
|
<body><h2>Threads of %s</h2>"""%(self.absolute_url(),self.getId()) |
|
|
|
for threadName in self.zipThreads.keys(): |
|
if self.zipThreads2[threadName].isAlive(): |
|
ret+="<p>%s --> alive</p>"%threadName |
else: |
else: |
os.popen("zip -u %s %s/*"%(tmpZip,tmpPath)) |
ret+="<p>%s --> dead</p>"%threadName |
|
return ret+"</body></html>" |
|
|
shutil.rmtree(tmpPath) |
|
|
|
if RESPONSE: |
|
RESPONSE.write("<p>finished<br>\n") |
|
|
|
if RESPONSE: |
|
len=os.stat(tmpZip)[6] |
|
downloadUrl=self.absolute_url()+"/downloadSet" |
|
RESPONSE.write("""<h1><a href="downloadSet?fn=%s">Click here for download ( %i Byte)</a></h1>\n"""%(tmpFn,len)) |
|
RESPONSE.write("""<p>The file will be stored for a while, you can download it later, the URL is:</p> |
|
<p><a href="downloadSet?fn=%s">%s?fn=%s</a></h1>\n"""%(tmpFn,downloadUrl,tmpFn)) |
|
RESPONSE.close() |
|
|
|
def downloadSet(self,fn): |
def downloadSet(self,fn): |
"""download prepared set""" |
"""download prepared set""" |
filename="/tmp/archivesImageServer/"+fn |
filename=os.path.join(tdir,fn) |
|
|
|
|
self.REQUEST.RESPONSE.setHeader("Content-Disposition","""attachement; filename="%s" """%"image.zip") |
self.REQUEST.RESPONSE.setHeader("Content-Disposition","""attachement; filename="%s" """%"image.tgz") |
self.REQUEST.RESPONSE.setHeader("Content-Type","application/octet-stream") |
self.REQUEST.RESPONSE.setHeader("Content-Type","application/octet-stream") |
len=os.stat(filename)[6] |
len=os.stat(filename)[6] |
self.REQUEST.RESPONSE.setHeader("Content-Length",len) |
self.REQUEST.RESPONSE.setHeader("Content-Length",len) |
Line 552 class ImageCollection(Folder, Persistent
|
Line 721 class ImageCollection(Folder, Persistent
|
|
|
|
|
|
|
def __init__(self,id,title,ImageStoragePath,ImageViewerPath,defaultMetaString): |
def __init__(self,id,title,ImageStoragePath,ImageViewerPath,defaultMetaString,serverPath=genericServerPath): |
self.id=id |
self.id=id |
self.title=title |
self.title=title |
self.ImageStoragePath=ImageStoragePath |
self.ImageStoragePath=ImageStoragePath |
self.ImageViewerPath=ImageViewerPath |
self.ImageViewerPath=ImageViewerPath |
self.defaultMetaString=defaultMetaString |
self.defaultMetaString=defaultMetaString |
|
self.serverPath=serverPath |
|
|
optTMP= Folder.manage_options |
optTMP= Folder.manage_options |
|
|
Line 690 class ImageCollection(Folder, Persistent
|
Line 860 class ImageCollection(Folder, Persistent
|
|
|
|
|
def xmlinput(self,url): |
def xmlinput(self,url): |
"""Anzeige von ausgewaehlten thumbs""" |
"""Anzeige <n ausgewaehlten thumbs""" |
#return url |
#return url |
|
|
url=urllib.unquote(url) |
url=urllib.unquote(url) |
Line 752 class ImageCollection(Folder, Persistent
|
Line 922 class ImageCollection(Folder, Persistent
|
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','addImage.zpt')).__of__(self) |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','addImage.zpt')).__of__(self) |
return pt() |
return pt() |
|
|
def addImage2(self,fileupload,meta,use_default=None,RESPONSE=None): |
def addImage2(self,fileupload,fileName=None,meta=None,use_default=None,RESPONSE=None): |
"""Add""" |
"""Add""" |
|
|
#print "FU",fileupload |
#print "FU",fileupload |
Line 764 class ImageCollection(Folder, Persistent
|
Line 934 class ImageCollection(Folder, Persistent
|
meta=None |
meta=None |
else: |
else: |
meta=None |
meta=None |
|
|
|
if fileName: |
|
fn=fileName |
|
else: |
fn=splitPath(fileupload.filename) |
fn=splitPath(fileupload.filename) |
|
|
manage_AddImageDigilib(self,fn,fileupload,meta=meta) |
manage_AddImageDigilib(self,fn,fileupload,meta=meta) |
|
|
|
if RESPONSE: |
return RESPONSE.redirect(self.REQUEST['URL1']+'/'+fn) |
return RESPONSE.redirect(self.REQUEST['URL1']+'/'+fn) |
#return self.REQUEST['URL1']+'/'+fileupload.filename |
#return self.REQUEST['URL1']+'/'+fileupload.filename |
|
|
Line 802 class ImageCollection(Folder, Persistent
|
Line 978 class ImageCollection(Folder, Persistent
|
|
|
RESPONSE.redirect('manage_main') |
RESPONSE.redirect('manage_main') |
|
|
|
## def importStructure(self,path): |
|
## """import""" |
|
## splitted=os.path.split(path) |
|
## if os.path.isDir(path) and (len(splitted[1])>0) and (splitted[1][0]=="."): |
|
## manage_AddImageCollection(self,splitted[1],splitted[1],path,self.ImageViewerPath,self.defaultMetaString,RESPONSE=None) |
|
|
|
## obj=getattr(self,splitted[1]) |
|
## obj.ImportFiles() |
|
|
|
def ImportStructure(self,RESPONSE=None): |
|
"""Import the existing files of a folder""" |
|
files=os.listdir(self.ImageStoragePath) |
|
ret="" |
|
#print self.__dict__ |
|
|
|
|
|
for file in files: |
|
|
|
if os.path.isdir(os.path.join(self.ImageStoragePath,file)): |
|
imageStoragePath=os.path.join(self.ImageStoragePath,file) |
|
imageViewerPath=os.path.join(self.ImageViewerPath,file) |
|
manage_AddImageCollection(self,file,file,imageStoragePath,imageViewerPath,self.defaultMetaString) |
|
|
|
obj=getattr(self,file) |
|
obj.ImportStructure() |
|
else: |
|
if not file[0]==".": |
|
if self.__dict__.has_key(file): |
|
|
|
ret=ret+"<br>"+file+" already exists!" |
|
else: |
|
ret=ret+"<br>"+file+" created!" |
|
newObj=ImageDigilib(file,file) |
|
#print newObj,file |
|
#print newObj |
|
try: |
|
self._setObject(file,newObj) |
|
except: |
|
"""nothing yet""" |
|
#print ret |
|
#pt=PageTemplateFile('Products/ImageArchive/out.zpt')).__of__(self) |
|
#print self.ImageStoragePath |
|
|
|
#scale thumb |
|
|
|
#self.scaleThumbs() |
|
|
|
#scale standard |
|
|
|
#self.scaleWorkingVersions() |
|
|
|
if RESPONSE: |
|
RESPONSE.redirect('manage_main') |
|
|
def ImportFiles(self,RESPONSE=None): |
def ImportFiles(self,RESPONSE=None): |
"""Import the existing files of a folder""" |
"""Import the existing files of a folder""" |
files=os.listdir(self.ImageStoragePath) |
files=os.listdir(self.ImageStoragePath) |
Line 957 class ImageCollection(Folder, Persistent
|
Line 1187 class ImageCollection(Folder, Persistent
|
return "<a href=\""+self.REQUEST['URL1']+"?filename="+ids[nr]+"\" target=\"_top\">previous sets</a>" |
return "<a href=\""+self.REQUEST['URL1']+"?filename="+ids[nr]+"\" target=\"_top\">previous sets</a>" |
else: |
else: |
return "" |
return "" |
|
def showFolders(self): |
|
"""show subfolders""" |
|
ret="" |
|
link=""" <a target="_top" href="%s">%s</a><br>""" |
|
|
|
if self.aq_parent.meta_type=="ImageCollection": |
|
ret+=link%(self.aq_parent.absolute_url(), "back ("+self.aq_parent.title+")") |
|
ret+="<br>" |
|
|
|
iCs=self.ZopeFind(self,obj_metatypes=["ImageCollection"]) |
|
if not iCs: |
|
return ret |
|
else: |
|
|
|
link=""" <a target="_top" href="%s">%s</a><br>""" |
|
for iC in iCs: |
|
ret+=link%(iC[1].absolute_url(),iC[0]) |
|
ret+="<br>" |
|
return ret |
def showRuler(self,selected=None): |
def showRuler(self,selected=None): |
"""show ruler""" |
"""show ruler""" |
showall =self.REQUEST.SESSION.get('showall','no') |
showall =self.REQUEST.SESSION.get('showall','no') |
Line 1108 class ImageCollection(Folder, Persistent
|
Line 1356 class ImageCollection(Folder, Persistent
|
return (cols,rows) |
return (cols,rows) |
|
|
|
|
def show_thumbs_rows(self,numberOfColumns,numberOfRows=None,startId=None): |
def show_thumbs_rows(self,numberOfColumns,numberOfRows=None,startId=None,showall="No"): |
"""Ausgabe anzahl""" |
"""Ausgabe anzahl""" |
|
|
idsAll=self.show_thumbs() |
idsAll=self.show_thumbs() |
if len(idsAll)==0: #keine Einträge |
if len(idsAll)==0: #keine Einträge |
return 0 |
return 0 |
if self.REQUEST.SESSION.has_key("filename"): |
if self.REQUEST.SESSION.has_key("filename") and not (showall=="yes"): |
filename=self.REQUEST.SESSION["filename"] |
filename=self.REQUEST.SESSION["filename"] |
filename=self.getImageByName(filename,onlyName="yes") |
filename=self.getImageByName(filename,onlyName="yes") |
|
|
Line 1227 class ImageCollection(Folder, Persistent
|
Line 1475 class ImageCollection(Folder, Persistent
|
return filename |
return filename |
else: |
else: |
return fn |
return fn |
def index_html(self): |
|
|
|
|
security.declareProtected('View','index_html') |
|
def index_html(self,fn=None): |
"""main template collection""" |
"""main template collection""" |
|
|
|
if fn: |
|
ret=[] |
|
|
|
if type(fn) is ListType: |
|
"""experimentell mehr als ein filename""" |
|
for filename in fn: |
|
if not (filename == ""): |
|
ret.append((filename,'',1)) |
|
else: |
|
ret.append((fn,'',1)) |
|
|
|
self.REQUEST.SESSION['filenames']=ret |
|
#self.REQUEST.SESSION['filenamesIds']=fnIds |
|
|
|
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','overview_selected.zpt')).__of__(self) |
|
return pt() |
|
|
if self.REQUEST.has_key('filename'): |
if self.REQUEST.has_key('filename'): |
filen=self.REQUEST['filename'] |
filen=self.REQUEST['filename'] |
else: |
else: |
Line 1243 class ImageCollection(Folder, Persistent
|
Line 1512 class ImageCollection(Folder, Persistent
|
self.REQUEST.SESSION['showall']=self.REQUEST.SESSION.get('showall','no') |
self.REQUEST.SESSION['showall']=self.REQUEST.SESSION.get('showall','no') |
|
|
|
|
|
overview=self.ZopeFind(self,obj_ids=['overview.html']) |
|
if overview: |
|
return overview[0][1]() |
|
else: |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','overview.zpt')).__of__(self) |
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','overview.zpt')).__of__(self) |
return pt() |
return pt() |
|
|
Line 1260 def manage_AddImageCollection(self,id,ti
|
Line 1533 def manage_AddImageCollection(self,id,ti
|
RESPONSE.redirect('manage_main') |
RESPONSE.redirect('manage_main') |
|
|
|
|
|
|
|
class ImageCollectionMD(ImageCollection,ZSQLExtendFolder): |
|
"""Imageviewer and Metadata""" |
|
meta_type="ImageCollection MD" |
|
#scalerPath="http://127.0.0.1:18080/digitallibrary/servlet/Scaler/?fn=" |
|
scalerPath="http://nausikaa2.rz-berlin.mpg.de/digitallibrary/servlet/Scaler/?fn=" |
|
manage_options=ImageCollection.manage_options+( |
|
{'label':'ZSQLExtend','action':'changeZSQLExtendForm'}, |
|
) |
|
|
|
try: |
|
changeZSQLExtendForm=ZSQLExtendFolder.changeZSQLExtendForm |
|
except: |
|
pass |
|
|
|
def setGenericSearchStringForm(self): |
|
"""form setze generischen search string fuer MD""" |
|
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','setGenericSearchStringForm.zpt')).__of__(self) |
|
return pt() |
|
|
|
def setGenericSearchString(self,searchString): |
|
"""setze generischen search string""" |
|
self.searchString=searchString |
|
|
|
def thumblistMD(self): |
|
"""main template collection""" |
|
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','thumbListMD.zpt')).__of__(self) |
|
return pt() |
|
|
|
|
|
def manage_AddImageCollectionMDForm(self): |
|
"""Nothing yet""" |
|
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','AddImageCollectionFormMD.zpt')).__of__(self) |
|
return pt() |
|
|
|
def manage_AddImageCollectionMD(self,id,title,ImageStoragePath,ImageViewerPath,defaultMetaString,RESPONSE=None): |
|
"""Add ImageCollection""" |
|
newObj=ImageCollectionMD(id,title,ImageStoragePath,ImageViewerPath,defaultMetaString) |
|
self._setObject(id,newObj) |
|
|
|
if RESPONSE is not None: |
|
RESPONSE.redirect('manage_main') |
|
|
|
|
|
|
|
|
class ImageCollectionIFrame(ImageCollection): |
class ImageCollectionIFrame(ImageCollection): |
"""Class fuer Collection set als IFrame""" |
"""Class fuer Collection set als IFrame""" |
|
|
Line 1316 def manage_AddImageCollectionIFrame(self
|
Line 1635 def manage_AddImageCollectionIFrame(self
|
RESPONSE.redirect('manage_main') |
RESPONSE.redirect('manage_main') |
|
|
|
|
|
class ImageZogiLib(ImageDigilib): |
|
"""Anzeige Object fuer Bilder ausserhalb von collections |
|
ImageViewerPath und ImageStoragePath und wenn vorhanden Pfad zur Collection |
|
werden zusaetzlich abgespeichert |
|
""" |
|
#TODO: scaler path notwendig? |
|
meta_type="ImageZogiLib" |
|
|
|
manage_options=ImageDigilib.manage_options+( |
|
{'label':'Main Config','action':'changeImageZogiLibForm'}, |
|
) |
|
|
|
def __init__(self,id,fn,ImageViewerPath,ImageStoragePath,scalerPath,ImageCollectionPath=None,REQUEST=None): |
|
ImageDigilib.__init__(self,id,fn) |
|
self.ImageViewerPath=ImageViewerPath |
|
self.ImageStoragePath=ImageStoragePath |
|
self.ImageCollectionPath=ImageCollectionPath |
|
self.scalerPath=scalerPath |
|
|
|
def changeImageZogiLibForm(self): |
|
"""change zogilib Form""" |
|
pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','changeImageZogiLib.zpt')).__of__(self) |
|
return pt() |
|
|
|
|
|
def changeImageZogilib(fn,ImageViewerPath,ImageStoragePath,scalerPath,ImageCollectionPath,REQUEST=None): |
|
"""Change it""" |
|
self.ImageViewerPath=ImageViewerPath |
|
self.ImageStoragePath=ImageStoragePath |
|
self.ImageCollectionPath=ImageColectionPath |
|
self.scalerPath=scalerPath |
|
|
|
def manage_AddImageZogiLib(self,id=None,ImageViewerPath=None,ImageStoragePath=None,fileUpload=None,ImageCollectionPath=None,scalerPath=None,libPath=None,caption=None,RESPONSE=None): |
|
"""hinzufuegen eineis zogilibImage""" |
|
|
|
if libPath: |
|
splitted=libPath.split("?") |
|
urlSplit=splitted[0].split("/") |
|
params=cgi.parse_qs(splitted[1]) |
|
#is LibPath a digilib path? |
|
if urlSplit[-1]=="Scaler": |
|
if type(params['fn']) is ListType: |
|
fnParam=params['fn'][0] |
|
else: |
|
fnParam=params['fn'] |
|
fileNameSplit=os.path.split(fnParam) |
|
ImageViewerPath=fileNameSplit[0] |
|
id=fileNameSplit[1] |
|
scalerPath=splitted[0]+"?fn=" |
|
else: #assume if not the path is a path to an ImageCollection |
|
if type(params['filename']) is ListType: |
|
id=params['filename'][0] |
|
else: |
|
id=params['filename'] |
|
|
|
server=ServerProxy(splitted[0]) |
|
ImageCollectionPath=libPath |
|
ImageViewerPath=server.getImageViewerPath() |
|
ImageStoragePath=server.getImageStoragePath() |
|
scalerPath=server.getScalerPath() |
|
|
|
|
|
|
|
if fileUpload: |
|
fn=splitPath(fileUpload.filename) |
|
else: |
|
fn=id |
|
|
|
newObj=ImageZogiLib(id,fn,ImageViewerPath,ImageStoragePath,scalerPath,ImageCollectionPath) |
|
|
|
self._setObject(id,newObj) |
|
getattr(self,id).caption=caption[0:] |
|
if fileUpload: |
|
getattr(self,id).uploadImage(fileupload,self.ImageStoragePath) |
|
|
|
if RESPONSE is not None: |
|
RESPONSE.redirect('manage_main') |
|
|
|
|
|
def manage_AddImageZogiLibForm(self): |
|
"""to be done""" |
|
|