|
|
| version 1.3, 2008/10/06 10:46:46 | version 1.5, 2008/10/06 13:35:39 |
|---|---|
| Line 90 class DownloadBasketFinallyThread(Thread | Line 90 class DownloadBasketFinallyThread(Thread |
| """print do the download""" | """print do the download""" |
| logging.debug("download thread") | logging.debug("download thread") |
| logging.debug("donwloadBasketasonefile: found basket:"+repr(basketVersion)) | logging.debug("downloadBasketasonefile: found basket:"+repr(basketVersion)) |
| ret="" | ret="" |
| self.counter=0 | self.counter=0 |
| #fh=file("/var/tmp/test","w") | #fh=file("/var/tmp/test","w") |
| files=[] | files=[] |
| lockedFiles=[] | |
| objects=basketVersion.getContent() | objects=basketVersion.getContent() |
| self.number=len(objects) | self.number=len(objects) |
| logging.error("objects:"+repr(self.number)) | |
| for object in objects: | for object in objects: |
| self.counter+=1 | self.counter+=1 |
| Line 113 class DownloadBasketFinallyThread(Thread | Line 115 class DownloadBasketFinallyThread(Thread |
| # lockedBy="" | # lockedBy="" |
| # logging.error(" -"+repr(lockedBy)) | # logging.error(" -"+repr(lockedBy)) |
| # | # |
| if (procedure=="downloadAll") or (lockedBy=='') or (lockedBy==user): | |
| #logging.error("ret1") | #logging.error("ret1") |
| if current=="no": #version as they are in the basket | if current=="no": #version as they are in the basket |
| #logging.error("ret2") | #logging.error("ret2") |
| Line 121 class DownloadBasketFinallyThread(Thread | Line 123 class DownloadBasketFinallyThread(Thread |
| #ret+=str(object[0].getData())+"\n" | #ret+=str(object[0].getData())+"\n" |
| files.append(object[0].getFileName()) | files.append(object[0].getFileName()) |
| elif current=="yes": | elif current=="yes": |
| logging.error("ret3") | #logging.error("ret3") |
| #search current object | #search current object |
| #founds=self.CDLICatalog.search({'title':object[1].getId().split(".")[0]}) | #founds=self.CDLICatalog.search({'title':object[1].getId().split(".")[0]}) |
| obj=self.ctx.getFileObjectLastVersion(object[1].getId()) | obj=self.ctx.getFileObjectLastVersion(object[1].getId()) |
| if obj: | if obj: |
| files.append(obj.getFileName()) | files.append(obj.getFileName()) |
| else: | else: |
| logging.error("donwloadBasketasonefile: don't know: "+repr(object[0].getId())) | logging.error("downloadBasketasonefile: don't know: "+repr(object[0].getId())) |
| #if len(founds)>0: | #if len(founds)>0: |
| # ret+=str(founds[0].getObject().getLastVersion().getData())+"\n" | # ret+=str(founds[0].getObject().getLastVersion().getData())+"\n" |
| #falls die Datei gesperrit ist nimm sie in die Liste auf. | |
| if not((procedure=="downloadAll") or (lockedBy=='') or (lockedBy==user)): | |
| #logging.error("ret4") | |
| lockedFiles.append((object[0].getId(),lockedBy)) | |
| #if lock and lockedBy=='': | #if lock and lockedBy=='': |
| #obj=self.ctx.getFileObject(object[1].getId()) | #obj=self.ctx.getFileObject(object[1].getId()) |
| Line 159 class DownloadBasketFinallyThread(Thread | Line 165 class DownloadBasketFinallyThread(Thread |
| if not hasattr(self.ctx,'resultHash'): | if not hasattr(self.ctx,'resultHash'): |
| self.ctx.resultHash={} | self.ctx.resultHash={} |
| self.ctx.resultHash[self.getName()]=files | self.ctx.resultHash[self.getName()]=files |
| if not hasattr(self.ctx,'resultLockedHash'): | |
| self.ctx.resultLockedHash={} | |
| self.ctx.resultLockedHash[self.getName()]=lockedFiles | |
| transaction.get().commit() | transaction.get().commit() |
| self.conn.close() | self.conn.close() |
| logging.error("---------download thread:run9") | logging.error("---------download thread:run9") |