MCP/Trunk/MCP_Console.py

"""

MCP_Console

Created by
Emanuel Borges
08.28.2010

This will be the interface to add, edit and archive cases.

Should this work as one large GUI and you pick the below or read from argv and let you
just call it with what you want, making these three look like separate apps.


"""

import MCP_Lib,os,shutil,ConcordanceHelperTools, time,directorySize2

class MainConsole:
    def __init__(self):
        ## Gather the case list
        
        print "connecting to matter tracking access db..."
        ##  Production version
        self.accessDB = MCP_Lib.AccessDBConnection(r"\\chiads01\app\DS_CaseTrack\TPM_CaseTracking.mdb")
        self.fullTPMMatrix = self.accessDB.RetrieveAllTPMMatrix()
        self.tPMName, self.tPMID, self.tPMOffice = MCP_Lib.GetTPMInfo()
        #responsibleCases,casesDir = MCP_Lib.GetCaseList('',self.accessDB)
        myCases, myActiveCases,officeCases, allCases,casesDir, casePathStyleMatrix= MCP_Lib.GetCaseList('',self.accessDB)
        
        ##  Testing version
        #self.accessDB = MCP_Lib.AccessDBConnection(r"W:\Manny\testing\TPM_CaseTracking.mdb")
        #responsibleCases,casesDir = MCP_Lib.GetCaseList(r"C:\Documents and Settings\eborges\My Documents\My Dropbox\Dev\Python\NinoCode\Active_prgs\Concordance\MCP",self.accessDB)
        #self.tPMName, self.tPMID, self.tPMOffice = MCP_Lib.GetTPMInfo(r"C:\Documents and Settings\eborges\My Documents\My Dropbox\Dev\Python\NinoCode\Active_prgs\Concordance\MCP")
        
        print "connected to DB."
        
        self.responsibleCasesList = myCases
        self.casesDir = casesDir
        
    
    def AddNewCase(self, caseName, clientMatter, chargable = False, reviewPlatform = "", responsibleProcessingVendor = "",
                   responsibleScanningVendor = "",responsibleHostingVendor = ""):
        ## TODO: add a verification somehwere where it verify that the proposed name does not include characters that cant be used in a folder name.
        ## Add the local folders The GUI should test that the clm is 10 digits and has hyphen.
        template = os.path.join(self.casesDir,'_Template_')
        new = os.path.join(self.casesDir, caseName + '_(%s)'%clientMatter)
        if os.path.exists(new):
            print "ERROR: This case already exists!!"
        else:
            #print template
            #print new
            os.mkdir(new)
            for file in os.listdir(template):
                shutil.copy2(os.path.join(template,file),new)
            ## Check the H drive for the supplemental folders and the matter folder, only if they select Concordance.
            self.SetCaseNameAndCLM(caseName,clientMatter)
            #print "DEBUG: %s"% caseName
            #print "DEBUG: %s"% clientMatter
            self.AddCaseToAccessDB(caseName,clientMatter)
            
    def ChangeCaseName(self,caseName,newCaseName,newClientMatter):
        """This method will allow for editing the case name and number. This is different than settign the casename"""
        ## Test that there is only one entry for this clm in access.
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        accessCaseName = self.accessDB.GetCaseName(clientMatter)
        localCasesPath = self.casesDir
        if os.path.exists(os.path.join(localCasesPath,caseName)):
            if clientMatter != newClientMatter:
                if newCaseName != caseName.split("_("):
                    ## change both
                    self.accessDB.UpdateCaseName(clientMatter,newCaseName)
                    self.accessDB.UpdateClientMatterNum(clientMatter,newClientMatter)
                    os.rename(os.path.join(localCasesPath,caseName),os.path.join(localCasesPath,newCaseName + '_(%s)'%newClientMatter.replace(".","-")))
                else:
                    ## change just client matter
                    self.accessDB.UpdateClientMatterNum(clientMatter,newClientMatter)
                    os.rename(os.path.join(localCasesPath,caseName),os.path.join(localCasesPath,caseName + '_(%s)'%newClientMatter.replace(".","-")))
            elif newCaseName != caseName.split("_("):
                ## change just the casename
                self.accessDB.UpdateCaseName(clientMatter,newCaseName)
                os.rename(os.path.join(localCasesPath,caseName),os.path.join(localCasesPath,newCaseName + '_(%s)'%clientMatter.replace(".","-")))
                
            ## verify that the proposed name does not include characters that cant be used in a folder name.
            ## Change the name and or clm in access
            
            ## Test that it was changed in access
            ## change the folder name in cases.
        else:
            ## That case dir cant be found. They can't change other's casenames.
            err = 1
        
        
    def AddCaseToAccessDB(self, caseName,clientMatter):
        ##  First test to see if it's already in the DB.
        fullClientMatterList = self.accessDB.RetrieveAllCaseList()
        clientMatter = clientMatter.replace("-",".")
        if clientMatter in fullClientMatterList:
            print "This client matter already exists in the database. Skipping."
        else:
            print "New client matter. Adding."
            self.accessDB.AddNewCase(caseName, clientMatter, self.tPMName,self.tPMID,responsibleOffice = self.tPMOffice)
            print "Added!"
    
    def EditCaseData(self,caseName,chargeableBool,respAttorney,respParalegal,respVendorTpl,revPlatform,respTPM,respOffice, caseStatus, casePathStyle):
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        empID = self.fullTPMMatrix[respTPM][0]
        self.accessDB.UpdateChargable(clientMatter,chargeableBool)
        self.accessDB.UpdateResponsibleAttorney(clientMatter,respAttorney)
        self.accessDB.UpdateResponsibleParalegal(clientMatter,respParalegal)
        self.accessDB.UpdateReviewPlatform(clientMatter,revPlatform)
        self.accessDB.UpdateResponsibleTPM(clientMatter,respTPM,empID)
        self.accessDB.UpdatePrimaryOffice(clientMatter,respOffice)
        self.accessDB.UpdateResponsibleVendors(clientMatter,respVendorTpl)
        self.accessDB.UpdateCaseStatus(clientMatter, caseStatus)
        self.accessDB.UpdateCasePathStyle(clientMatter,casePathStyle)
    def GetCaseData(self, caseName):
        #use this to get the data on the selected case, to populate your GUI
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        chargeableBool = self.accessDB.GetChargable(clientMatter)
        respAttorney = self.accessDB.GetResponsibleAttorney(clientMatter)
        respParalegal = self.accessDB.GetResponsibleParalegal(clientMatter)
        respVendorTpl = self.accessDB.GetResponsibleVendorTpl(clientMatter)
        revPlatform = self.accessDB.GetReviewPlatform(clientMatter)
        respTPM = self.accessDB.GetResponsibleTPM(clientMatter)
        respOffice = self.accessDB.GetPrimaryOffice(clientMatter)
        caseStatus = self.accessDB.GetCaseStatus(clientMatter)
        uploadCost = self.accessDB.GetUploadCostRate(clientMatter)
        storageCost = self.accessDB.GetStorageCostRate(clientMatter)
        disclosureLetterBool,disclosureLetterPath = self.accessDB.GetDisclosureLetter(clientMatter)
        casePathStyle = self.accessDB.GetCasePathStyle(clientMatter)
        return (chargeableBool,respAttorney,respParalegal,respVendorTpl,revPlatform,respTPM,respOffice,caseStatus,uploadCost,storageCost,disclosureLetterBool,casePathStyle)
     
    def GetFullCLMList(self):
        """Returns the full list of client matters for every case in Access"""
        fullList = self.accessDB.RetrieveAllCaseList()
        return fullList
    
    def GetPossibleProducedToEntities(self,caseName):
        """Returns the possible produced to entities for a case"""
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        possibleProducedToEntities = self.accessDB.GetProducedToEntities(clientMatter)
        return possibleProducedToEntities
    
    def GetPossibleProdReqByNames(self,caseName):
        """Returns the possible requested by names for a case"""
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        possibleProdReqByNames = self.accessDB.GetProductionRequestedByNames(clientMatter)
        return possibleProdReqByNames
        
        
    def AddProductionEntry(self, CLM,prodID,prodProcessedDate,begBates,endBates,prodDocCount, prodPageCount, prodNotes, prodTo, prodMedia,prodSource,prodReqBy,prodSentDate,prodMediaPassword):
        """This method adds one production entry to the case."""
        errRpt = True
        if CLM:
            if prodID:
                if prodProcessedDate:
                    if begBates:
                        if endBates:
                            if prodDocCount:
                                if prodPageCount:
                                    if prodNotes:
                                        self.accessDB.UpdateProductionDetail(CLM,prodID,prodProcessedDate,begBates,endBates,prodDocCount, prodPageCount, prodNotes, prodTo, prodMedia,prodSource,prodReqBy,prodSentDate,prodMediaPassword)
                                        errRpt = False
        return errRpt
        
    def AddDataUpload(self,CLM, reviewPlatform, reportSize):
        """This method will add one case upload."""
        ##  TODO: one day change it so that copy up requst calls this instead
        ##        of it being internal to that prog.
        epoch = str(int(time.time()))
        self.accessDB.UpdateCaseUpload(CLM,reviewPlatform,{epoch:(time.strftime('%m/%d/%Y'),reportSize)})
        
    def RemoveDataUpload(self,CLM,UEPOCH):
        """This method calls DeleteCaseUpload and removes just one case upload. """
        err = self.accessDB.DeleteCaseUpload(CLM,UEPOCH)
        if err:
            print "ERROR: An Error occured and this value was not removed!"
        else:
            print "%s Removed"% UEPOCH
        
    def GetUploadData(self, caseName):
        # Used to get upload data, on the selected case, to populate the upload dialog
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        uploadList = self.accessDB.RetrieveUploadsByCLM(clientMatter)
        return uploadList
    
    def GetProductionData(self,caseName):
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        productionMatrix = self.accessDB.RetrieveProductionsByCLM(clientMatter)
        return productionMatrix
    
    def GetProductionTotal(self,productionList):
        """Using the above productionList, this returns the total docs and pages produced"""
        pgCountTotal = 0
        docCountTotal = 0
        for i in productionList:
            pageCount = i[-7]
            docCount = i[-8]
            if 'None' in pageCount:
                pass
            else:
                #print pageCount
                pgCountTotal = pgCountTotal+int(pageCount)
            if 'None' in pageCount:
                pass
            else:
                #print docCount
                docCountTotal = docCountTotal+int(docCount)
        return pgCountTotal,docCountTotal
    
    def ExportProductionDataToExcel(self,CaseName,pathToCSV):
        """Exports the production data to a csv file"""
        productionList = self.GetProductionData(CaseName)
        #print productionList
        outputFile = open(pathToCSV,'w')
        outputFile.write('Production ID,Production Completed Date,Production Sent Date,Start Bates,End Bates,Document Count,Page Count,Produced To,Requested By,Production Media,ProductionMediaPassword,Production Sources,Notes\n')
        for i in productionList:
            for x in i:
                outputFile.write(x+",")
            outputFile.write("\n")
        outputFile.close()
       
    def GetUploadTotal(self,uploadList):
        """ Using the above uploadList, this will return the total uploaded """
        count = 0.
        for i in uploadList:
            size = i[-1]
            
            if 'None' in size:
                pass
            else:
                rawSize = directorySize2.prettyToUnpretty_Filesize(size)
                count = count + rawSize
        prettySizeFinal = directorySize2.pretty_filesize2(count)
        return prettySizeFinal
        
    
    def TransferCase(self, caseName, sourceTpm, targetTpm):
        """Transfers case to another TPM"""
        sourceTPMOffice = self.fullTPMMatrix[sourceTpm][1]
        targetTPMOffice = self.fullTPMMatrix[targetTpm][1]
        ## Confirm that folder exists
        print "Confirming folder exists..."
        caseFolderLocation = MCP_Lib.GetOtherCaseFolder(sourceTPMOffice)
        targetCaseFolderLocation = MCP_Lib.GetOtherCaseFolder(targetTPMOffice)
        
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        if "." in clientMatter:
            clientMatter = clientMatter.replace('.','-')
        folderMatrix = {}
        #caseFolderLocation = os.path.join(caseFolderLocation,case)
        err = False
        if caseFolderLocation:
            if os.path.exists(caseFolderLocation):
                for f in os.listdir(caseFolderLocation):
                    if "_(" in f:
                        folderClientMatter = f.split("_(")[1]
                        folderClientMatter = folderClientMatter[:-1]
                        folderMatrix[folderClientMatter] = f
                try:
                    folderName = folderMatrix[clientMatter]
                    fullCasePath = os.path.join(caseFolderLocation, folderName)
                except:
                    err = True
            else:
                err = True
        else:
            print "A case folder for this case was not found."
            err = True
        if err:
            print "Transfer aborted"
        else:
            if os.path.exists(fullCasePath):
                print "Folder exists."
                ## Check that target folder does not exist, support same office transfer.
                print "Testing target directory..."
                fullTargetCasePath = os.path.join(targetCaseFolderLocation, folderName)
                if sourceTPMOffice == targetTPMOffice:
                    ## This is an inter office transfer, which is okay but dont move folders
                    pass
                else:
                    if os.path.exists(fullTargetCasePath):
                        err = True
                        print "This case folder already exists."
                    else:
                        ## First move the folder to the new location
                        try:
                            print "moving %s to %s"%(fullCasePath,fullTargetCasePath)
                            shutil.move(fullCasePath,fullTargetCasePath)
                        except:
                            err = True
                            print "The move failed!"
                        if os.path.exists(fullTargetCasePath):
                            print "Case folder moved."
                if err:
                    print "Transfer aborted"
                else:
                    ## Change the info in Access
                    #print targetTPMOffice
                    self.accessDB.UpdatePrimaryOffice(clientMatter.replace('-','.'),targetTPMOffice)
                    self.accessDB.UpdateResponsibleTPM(clientMatter.replace('-','.'),targetTpm,self.fullTPMMatrix[targetTpm][0])
                    print "Case Transfer Completed."   
        return err
    
    def MakeCaseDormant(self, caseAndCLM):
        """Moves the case to the Dormant folder"""
        ## Dont do this, just hide from your view.  Once archived, move off share.
        print "Making %s case dormant..."
        os.rename(os.path.join(self.casesDir,caseAndCLM),os.path.join(self.casesDir,os.path.join('zzzz_dormant_', caseAndCLM)))
        print "Case has been archived."


    def ViewCaseNotes(self,caseName,office):
        """Trys to open the case notes file,in the case folder, for the active case, regardless who owns it."""
        caseFolderLocation = MCP_Lib.GetOtherCaseFolder(office)
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        if "." in clientMatter:
            clientMatter = clientMatter.replace('.','-')
        folderMatrix = {}
        #caseFolderLocation = os.path.join(caseFolderLocation,case)
        err = False
        if caseFolderLocation:
            if os.path.exists(caseFolderLocation):
                for f in os.listdir(caseFolderLocation):
                    if "_(" in f:
                        folderClientMatter = f.split("_(")[1]
                        folderClientMatter = folderClientMatter[:-1]
                        folderMatrix[folderClientMatter] = f
                try:
                    folderName = folderMatrix[clientMatter]
                    os.startfile(os.path.join(caseFolderLocation, folderName)+"/Gen_Notes.txt")
                except:
                    err = True
            else:
                err = True
        else:
            print "A case folder for this case was not found."
            err = True
        return err
    
    def ViewProdSpec(self,caseName,office):
        """Trys to open the prod spec file,in the case folder, for the active case, regardless who owns it."""
        caseFolderLocation = MCP_Lib.GetOtherCaseFolder(office)
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        if "." in clientMatter:
            clientMatter = clientMatter.replace('.','-')
        folderMatrix = {}
        #caseFolderLocation = os.path.join(caseFolderLocation,case)
        err = False
        if caseFolderLocation:
            if os.path.exists(caseFolderLocation):
                for f in os.listdir(caseFolderLocation):
                    if "_(" in f:
                        folderClientMatter = f.split("_(")[1]
                        folderClientMatter = folderClientMatter[:-1]
                        folderMatrix[folderClientMatter] = f
                try:
                    folderName = folderMatrix[clientMatter]
                    os.startfile(os.path.join(caseFolderLocation, folderName+"/Production_Spec.txt"))
                except:
                    err = True
            else:
                err = True
        else:
            print "A case folder for this case was not found."
            err = True
        return err

    #def CreateCasePathStyleFolders(self,platform,clientMatter):
    #    """This method will create the "new style" case folder paths for a case on IDS"""
    #    ##  make sure that the CLMFolderPath exists, else make the folders needed to make it exist.
    #    CLMFolderPath = ConcordanceHelperTools.ParseClientMatterRemote(clientMatter)
    #    
    #    expeObj = MCP_Lib.ExpeDatConnection(platform)
    #    
    #    ##  Test each folder, and subfolder, on the new style spec to see if they are there, if not create them.
    #    newStyleFolderPathList = [
    #        "Productions\\MWE_Client\\Backloads",
    #        "Productions\\MWE_Client\\Exports",
    #        "Productions\\Other_Party",
    #        "Review_Docs\\Hard_Copy",
    #        "Review_Docs\\Loose",
    #        "Review_Docs\\Processed_Data",
    #        "Review_Docs\\TIFs",
    #        "Working"
    #    ]
    #    for pathPart in newStyleFolderPathList:
    #        newLocation = os.path.join(CLMFolderPath,pathPart)
    #        pathExists = expeObj.TestPath(newLocation)
    #        tempPath = newLocation
    #        pathRemainingList = []
    #        while pathExists == False:
    #            tempPath, tempPart = os.path.split(tempPath)
    #            pathRemainingList.append(tempPart)
    #            pathExists = expeObj.TestPath(tempPath)
    #        if pathRemainingList:
    #            pathRemainingList.reverse()
    #            #print pathRemainingList
    #            for pathPiece in pathRemainingList:
    #                tempPath = os.path.join(tempPath,pathPiece)
    #                expeObj.CreateNewPath(tempPath)
    #    print "DEBUG: testing password file"
    #    pathExists = expeObj.TestPath(os.path.join(CLMFolderPath,"Productions\\MWE_Client\\Exports\\_passwords.txt"))
    #    if pathExists:
    #        print "DEBUG: file already exists"
    #    else:
    #        pw_file = open(os.path.join(os.getenv('TEMP'),"_passwords.txt"),'w')
    #        pw_file.close()
    #        expeObj.CopyToLN(os.path.join(os.getenv('TEMP'),"_passwords.txt",),os.path.join(CLMFolderPath,"Productions\\MWE_Client\\Exports"))
    #        

    def CreateProductionReport(self,caseName,office):
        """Creates a html production report in the altMediaPath folder"""
        err = False
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        altMediaPath = self.accessDB.GetAlternateMediaPath(clientMatter)
        productionMatrix = self.GetProductionData(caseName)
        if os.path.exists(os.path.join(altMediaPath,'__MCP_Data')):
            pass
        else:
            os.mkdir(os.path.join(altMediaPath,'__MCP_Data'))
        reportFile = open(os.path.join(os.path.join(altMediaPath,'__MCP_Data'),'MCP_Production_Report.html'),'w')
        reportFile.write('''<html>\n<head>\n  <title>MCP: %s Production Report</title>\n  <style type="text/css" media="screen">\n\n'''%caseName)
        reportFile.write(r'''div#Rsidebar {
                         float: right;
                         width: 20%;
                         }
                         div#Lsidebar {
                         float: left;
                         width:20%;
                         height:380px;
                         }
                         
                         </style>''')
        reportFile.write('''
                         <meta http-equiv="content-type" content="text/html; charset=ISO-8859-1">
                         <meta name="author" content="Emanuel Borges">
                         </head>
                         <body>
                         
                         <h3><br>
                         </h3>
                         <center><h2>%s Production Report</h2></center>'''%caseName)
        reportFile.write(r'''<center><hr width="40%"></center>''')
        for k in productionMatrix.keys():
            productionList = productionMatrix[k]
            reportFile.write("<h4>%s Productions</h3>" % k)
            reportFile.write('''<center><table border=1 cellspacing=0 cellpadding=5 width=1800>\n<tr><th>Production ID</th><th>Processed Date</th><th>Sent Date</th><th>Start Bates</th><th>End Bates</th><th>Document Count</th><th>Page Count</th><th>Requested By</th><th>Production Media</th><th>Media Password</th><th>Production Sources</th><th>Notes</th></tr>''')
            for i in productionList:
                reportFile.write("<tr>")
                count = 1
                for x in i:
                    if count == 8:
                        count = count + 1
                    else:
                        reportFile.write("<td>%s</td>"%x)
                        count = count +1
                reportFile.write("</tr>")
            
            reportFile.write('</table></center>\n\n')
        reportFile.write('''<div id="footer">
                         <p><span>&copy; 2012 <a href="#">Emanuel Borges</a></span><br />
                         Website automatically generated by the MCP program.</p></div>''')
        reportFile.write('</body></html>\n')
        reportFile.close()
        return err

    def OpenAlternateMediaFolder(self,caseName,office,testOnly=False):
        """Trys to open the Alternate media folder, for the active case, regardless who owns it.
        If testOnly is set to True, it will only test that it exists and not open the folder."""
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        altMediaPath = self.accessDB.GetAlternateMediaPath(clientMatter)
        err = False
        if altMediaPath:
            if os.path.exists(altMediaPath):
                if testOnly:
                    pass
                else:
                    os.startfile(altMediaPath)
            else:
                print "An alternate media folder for this case was not found."
                err = True
        else:
            err = True
        return err
    
    def SetAlternateMediaFolder(self,caseName,altMediaPath):
        """Sets the alternate Media Path"""
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        self.accessDB.UpdateAlternateMediaPath(clientMatter,altMediaPath)

    def GetVendorFolders(self,caseName):
        """Returns the current list of vendor folders, for one case"""
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        vendorFolders = self.accessDB.GetVendorFolderPath(clientMatter)
        #print "V%s "%vendorFolders
        return vendorFolders
    
    def SetVendorFolders(self,caseName, vendorFolders):
        """Sets the Vendor Folder"""
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        self.accessDB.UpdateVendorFolderPath(clientMatter,vendorFolders)
    
    def GetVendorFoldersList(self):
        """Returns a list of all vendorFolders"""
        ## Change this so that it actually grabs the current ones from ln. Dont know if I should grab from a table in access.
        vendorFolderList = ["None"]
        for n in range(1,61):
            vendorFolderList.append("mwevendor%0*d"%(2,n))
        return vendorFolderList
    
    def GetDisclosureLetterData(self,caseName):
        """Returns the the bool of if a case has a disclosure letter and if so the path."""
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        disclosureLetterSet, disclosureLetterPath = self.accessDB.GetDisclosureLetter(clientMatter)
        return disclosureLetterSet, disclosureLetterPath
    
    def SetDisclosureLetterData(self,caseName,disclosureLetterPath):
        """Sets the disclosure letter path and checks it as true in the database"""
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        self.accessDB.UpdateDisclosureLetter(clientMatter,True,disclosureLetterPath)
        
    def GetCasePathsData(self,caseName, office):
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        altMediaPath = self.accessDB.GetAlternateMediaPath(clientMatter)
        caseFolderLocation = MCP_Lib.GetOtherCaseFolder(office)
        caseFolderLocation = os.path.join(caseFolderLocation,caseName)
        return altMediaPath, caseFolderLocation
    
    def SetUploadAndStorageCosts(self, caseName,uploadCost,storageCost):
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        if uploadCost:
            self.accessDB.UpdateUploadCostRate(clientMatter,uploadCost)
        if storageCost:
            self.accessDB.UpdateStorageCostRate(clientMatter,storageCost)

    def OpenCaseFolder(self,caseName,office):
        """Trys to open the case folder for the active case, regardless who owns it."""
        caseFolderLocation = MCP_Lib.GetOtherCaseFolder(office)
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        if "." in clientMatter:
            clientMatter = clientMatter.replace('.','-')
        folderMatrix = {}
        #caseFolderLocation = os.path.join(caseFolderLocation,case)
        err = False
        if caseFolderLocation:
            if os.path.exists(caseFolderLocation):
                for f in os.listdir(caseFolderLocation):
                    if "_(" in f:
                        folderClientMatter = f.split("_(")[1]
                        folderClientMatter = folderClientMatter[:-1]
                        folderMatrix[folderClientMatter] = f
                try:
                    folderName = folderMatrix[clientMatter]
                    os.startfile(os.path.join(caseFolderLocation, folderName))
                except:
                    err = True
            else:
                err = True
        else:
            print "A case folder for this case was not found."
            err = True
        return err


    def SetCaseNameAndCLM(self, newCaseName, newClientMatterNumber):
        """Used when setting up a new case. Should have both or nothing"""
        self.caseName = newCaseName
        self.clientMatter = newClientMatterNumber
        #print self.clientMatter
        
    def SetChargableCase(self, chargBool):
        """sets or clears the chargable case settings"""
        pass
    def SetResponsibleVendor(self, vendorInfo):
        """Sets the vendor name that is responsible for the case"""
        pass
    def SetReviewPlatform(self, reviewPlatform):
        """Sets the review platform chosen for this case"""
        if reviewPlatform == "Concordance":
            print "Concordance selected.  Creating DIS directories..."
            hDrivePath = ConcordanceHelperTools.ParseClientMatter(self.clientMatter)
            os.mkdir(hDrivePath)
            print "Matter folder created."
            os.mkdir(os.path.join(hDrivePath,'Match'))
            os.mkdir(os.path.join(hDrivePath,'Tag_Databases'))
            print "Supplemental folders created."
            print "DIS directories done!"
            
    def GetDatabaseList(self,caseName):
        """Returns the list of databases in the database list file."""
        return ['datbase1','database2','database3']
            
    def SyncWithAccessDB(self,case = 'ALL'):
        """Syncs your cases with the access database. This might only get run once when you first install
        the program though..."""
        ## So this syncs 'your' databases only. even though you are looking at a list of eeryone's databases
        ## it will only sync yours. even if you did an upload for another tpm, that wouldnt get synced unles
        ## the owner did a sync all. for 2 way sync to work, you should check, in access, that they have the case name
        ## (with no funky characters) populated, before they run this for the first time.
        if case == 'ALL':
            ## verify that all your cases are up there, if not add it. but have support for cases where is should be
            ## yours but is assigned to someone else...
            fullClientMatterList = self.accessDB.RetrieveAllCaseList()
            myAccessClientMatterList = self.accessDB.RetrieveMyCaseList(self.tPMID)
            myLocalClientMatterList = []
            
            ## Sync cases from my local to access
            for case in self.responsibleCasesList:
                localCaseName,clientMatter = case.split("_(")
                clientMatter = clientMatter.replace(")","")
                clientMatter = clientMatter.replace("-",".")
                myLocalClientMatterList.append(clientMatter)
            for clm in myLocalClientMatterList:
                if clm in myAccessClientMatterList:
                    print "%s exists"% clm
                elif clm in fullClientMatterList:
                    print "%s cant be added to your cases because it's owned by someone else..."% clm
                else:
                    print "%s does not exist in the database. Adding it..."% clm
                    self.AddCaseToAccessDB(localCaseName,clientMatter)
                    
            ## Sync cases from Access to my local
            
            
            uploadReportMatrix = {}
            for caseName in self.responsibleCasesList:
                print "now processing %s"% caseName
                casePath = os.path.join(self.casesDir,caseName)
                if os.path.exists(os.path.join(casePath,"UploadReport.txt")):
                    print "yup"
                    caseUploadContents = open(os.path.join(casePath,"UploadReport.txt")).readlines()
                    clientMatter = caseName.split("_(")[1]
                    clientMatter = clientMatter.replace(")","")
                    clientMatter = clientMatter.replace("-",".")
                    for i in caseUploadContents:
                        i = i.replace("\n","")
                        i = i.replace(" | ","|")
                        try:
                            uploadReportMatrix[clientMatter].append(("%s"%i.split("|")[0],"%s"%i.split("|")[1],"%s"%i.split("|")[2],"%s"%i.split("|")[3]))
                        except:
                            uploadReportMatrix[clientMatter] = [("%s"%i.split("|")[0],"%s"%i.split("|")[1],"%s"%i.split("|")[2],"%s"%i.split("|")[3])]
            #print uploadReportMatrix
            
            accessMyCaseUploads = self.accessDB.RetrieveMyCaseUploads('09756')
            for x in uploadReportMatrix.keys():
                localCaseUploadList = uploadReportMatrix[x]
                tempMatrix = {}
                try:
                    accessCaseUploadList = accessMyCaseUploads[x]
                    #print accessCaseUploadList
                    for y in localCaseUploadList:
                        epoch = y[0]
                        if int(epoch) > 1298462400: 
                            #print epoch
                            reviewPlatform = y[1]
                            reportSize = y[3]
                            #print "."
                            #print accessCaseUploadList
                            if epoch in accessCaseUploadList:
                                print "%s, in the %s case, is already in there, skipping."%(y,x)
                            else:
                                print "%s, in the %s case, is missing. Will be added..."%(y,x)
                                date = y[2]
                                date = "%s/%s/%s"%(date[4:6],date[6:],date[:4])
                                
                                self.accessDB.UpdateCaseUpload(x,reviewPlatform,{epoch:(date,reportSize)})
                                #tempMatrix[epoch] = [platform,(date,size)]
                        else:
                            #print "This entry is pre cutover"
                            pass
                except KeyError:
                    print "nothing for this one"
                    for z in localCaseUploadList:
                        print "%s, in the %s case, is missing. Will be added..."%(z,x)
                        date = z[0]
                        date = "%s/%s/%s"%(date[4:6],date[6:],date[:4])
                        #try:
                        #    tempMatrix[date].append(z[1])
                        #except:
                        #    tempMatrix[date] = [z[1]]
                #print tempMatrix
                #if tempMatrix:
                #    #print tempMatrix
                #    self.accessDB.UpdateCaseUpload(x,'Concordance DIS', tempMatrix)
                    #pass
                
                
            #print myLocalClientMatterList
            ## verify that all of your uploads are up there, if not, add it.
            self.accessDB.CloseAccessConnection()
            
        else:
            fullClientMatterList = self.accessDB.RetrieveAllCaseList()
            myAccessClientMatterList = self.accessDB.RetrieveMyCaseList(self.tPMID)
            

Revision:	489
Committed:	Thu Dec 5 16:36:56 2013 UTC (12 years, 3 months ago) by nino.borges
Content type:	text/x-python
Original Path:	*Python/NinoCode/Active_prgs/MCP/MCP_Console.py*
File size:	37105 byte(s)
Log Message:	Adding support for adding a case in the console UI.