Active_prgs/MCP/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.tPMName, self.tPMID, self.tPMOffice = MCP_Lib.GetTPMInfo()
        #responsibleCases,casesDir = MCP_Lib.GetCaseList('',self.accessDB)
        myCases, officeCases, allCases,casesDir= 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 = ""):
        ## 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)
            self.AddCaseToAccessDB(caseName,clientMatter)
            
    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):
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        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)
        self.accessDB.UpdatePrimaryOffice(clientMatter,respOffice)
        self.accessDB.UpdateResponsibleVendors(clientMatter,respVendorTpl)
        self.accessDB.UpdateCaseStatus(clientMatter, caseStatus)
        
    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)
        return (chargeableBool,respAttorney,respParalegal,respVendorTpl,revPlatform,respTPM,respOffice,caseStatus)
        
    def AddProductionEntry(self, CLM,prodID,prodDate,begBates,endBates,prodDocCount, prodPageCount, prodNotes):
        """This method adds one production entry to the case."""
        errRpt = True
        if CLM:
            if prodID:
                if prodDate:
                    if begBates:
                        if endBates:
                            if prodDocCount:
                                if prodPageCount:
                                    if prodNotes:
                                        self.accessDB.UpdateProductionDetail(CLM,prodID,prodDate,begBates,endBates,prodDocCount, prodPageCount, prodNotes)
                                        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('-','.')
        productionList = self.accessDB.RetrieveProductionsByCLM(clientMatter)
        return productionList
    
    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[-2]
            docCount = i[-3]
            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 Date,Start Bates,End Bates,Document Count,Page Count,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 MakeCaseDormant(self, caseAndCLM):
        """Moves the case to the Dormant folder"""
        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 OpenAlternateMediaFolder(self,caseName,office):
        """Trys to open the Alternate media folder, for the active case, regardless who owns it."""
        clientMatter = caseName.split("_(")[1]
        clientMatter = clientMatter[:-1]
        clientMatter = clientMatter.replace('-','.')
        altMediaPath = self.accessDB.GetAlternateMediaPath(clientMatter)
        err = False
        if altMediaPath:
            if os.path.exists(altMediaPath):
                os.startfile(altMediaPath)
            else:
                print "An alternate media folder for this case was not found."
                err = True
        else:
            err = True
        return err

    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 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:	261
Committed:	Fri Feb 1 19:57:46 2013 UTC (13 years, 1 month ago) by nino.borges
Content type:	text/x-python
File size:	20694 byte(s)
Log Message:	Added the alternate media path function and tested.
#	User	Rev	Content
1	ninoborges	8	"""
2
3			MCP_Console
4
5			Created by
6			Emanuel Borges
7			08.28.2010
8
9			This will be the interface to add, edit and archive cases.
10
11			Should this work as one large GUI and you pick the below or read from argv and let you
12			just call it with what you want, making these three look like separate apps.
13
14
15			"""
16
17			import MCP_Lib,os,shutil,ConcordanceHelperTools, time,directorySize2
18
19			class MainConsole:
20			def __init__(self):
21			## Gather the case list
22
23			print "connecting to matter tracking access db..."
24			## Production version
25			self.accessDB = MCP_Lib.AccessDBConnection(r"\\chiads01\app\DS_CaseTrack\TPM_CaseTracking.mdb")
26			self.tPMName, self.tPMID, self.tPMOffice = MCP_Lib.GetTPMInfo()
27	nino.borges	189	#responsibleCases,casesDir = MCP_Lib.GetCaseList('',self.accessDB)
28			myCases, officeCases, allCases,casesDir= MCP_Lib.GetCaseList('',self.accessDB)
29	ninoborges	8
30			## Testing version
31			#self.accessDB = MCP_Lib.AccessDBConnection(r"W:\Manny\testing\TPM_CaseTracking.mdb")
32			#responsibleCases,casesDir = MCP_Lib.GetCaseList(r"C:\Documents and Settings\eborges\My Documents\My Dropbox\Dev\Python\NinoCode\Active_prgs\Concordance\MCP",self.accessDB)
33			#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")
34
35			print "connected to DB."
36
37	nino.borges	189	self.responsibleCasesList = myCases
38	ninoborges	8	self.casesDir = casesDir
39
40
41			def AddNewCase(self, caseName, clientMatter, chargable = False, reviewPlatform = "", responsibleProcessingVendor = "",
42			responsibleScanningVendor = "",responsibleHostingVendor = ""):
43			## Add the local folders The GUI should test that the clm is 10 digits and has hyphen.
44			template = os.path.join(self.casesDir,'_Template_')
45			new = os.path.join(self.casesDir, caseName + '_(%s)'%clientMatter)
46			if os.path.exists(new):
47			print "ERROR: This case already exists!!"
48			else:
49			#print template
50			#print new
51			os.mkdir(new)
52			for file in os.listdir(template):
53			shutil.copy2(os.path.join(template,file),new)
54			## Check the H drive for the supplemental folders and the matter folder, only if they select Concordance.
55			self.SetCaseNameAndCLM(caseName,clientMatter)
56			self.AddCaseToAccessDB(caseName,clientMatter)
57
58			def AddCaseToAccessDB(self, caseName, clientMatter):
59			## First test to see if it's already in the DB.
60			fullClientMatterList = self.accessDB.RetrieveAllCaseList()
61			clientMatter = clientMatter.replace("-",".")
62			if clientMatter in fullClientMatterList:
63			print "This client matter already exists in the database. Skipping."
64			else:
65			print "New client matter. Adding."
66			self.accessDB.AddNewCase(caseName, clientMatter, self.tPMName,self.tPMID,responsibleOffice = self.tPMOffice)
67			print "Added!"
68
69			def EditCaseData(self,caseName,chargeableBool,respAttorney,respParalegal,respVendorTpl,revPlatform,respTPM,respOffice, caseStatus):
70			clientMatter = caseName.split("_(")[1]
71			clientMatter = clientMatter[:-1]
72			clientMatter = clientMatter.replace('-','.')
73			self.accessDB.UpdateChargable(clientMatter,chargeableBool)
74			self.accessDB.UpdateResponsibleAttorney(clientMatter,respAttorney)
75			self.accessDB.UpdateResponsibleParalegal(clientMatter,respParalegal)
76			self.accessDB.UpdateReviewPlatform(clientMatter,revPlatform)
77			self.accessDB.UpdateResponsibleTPM(clientMatter,respTPM)
78			self.accessDB.UpdatePrimaryOffice(clientMatter,respOffice)
79			self.accessDB.UpdateResponsibleVendors(clientMatter,respVendorTpl)
80			self.accessDB.UpdateCaseStatus(clientMatter, caseStatus)
81
82			def GetCaseData(self, caseName):
83			#use this to get the data on the selected case, to populate your GUI
84			clientMatter = caseName.split("_(")[1]
85			clientMatter = clientMatter[:-1]
86			clientMatter = clientMatter.replace('-','.')
87			chargeableBool = self.accessDB.GetChargable(clientMatter)
88			respAttorney = self.accessDB.GetResponsibleAttorney(clientMatter)
89			respParalegal = self.accessDB.GetResponsibleParalegal(clientMatter)
90			respVendorTpl = self.accessDB.GetResponsibleVendorTpl(clientMatter)
91			revPlatform = self.accessDB.GetReviewPlatform(clientMatter)
92			respTPM = self.accessDB.GetResponsibleTPM(clientMatter)
93			respOffice = self.accessDB.GetPrimaryOffice(clientMatter)
94			caseStatus = self.accessDB.GetCaseStatus(clientMatter)
95			return (chargeableBool,respAttorney,respParalegal,respVendorTpl,revPlatform,respTPM,respOffice,caseStatus)
96
97			def AddProductionEntry(self, CLM,prodID,prodDate,begBates,endBates,prodDocCount, prodPageCount, prodNotes):
98			"""This method adds one production entry to the case."""
99			errRpt = True
100			if CLM:
101			if prodID:
102			if prodDate:
103			if begBates:
104			if endBates:
105			if prodDocCount:
106			if prodPageCount:
107			if prodNotes:
108			self.accessDB.UpdateProductionDetail(CLM,prodID,prodDate,begBates,endBates,prodDocCount, prodPageCount, prodNotes)
109			errRpt = False
110			return errRpt
111
112			def AddDataUpload(self,CLM, reviewPlatform, reportSize):
113			"""This method will add one case upload."""
114			## TODO: one day change it so that copy up requst calls this instead
115			## of it being internal to that prog.
116			epoch = str(int(time.time()))
117			self.accessDB.UpdateCaseUpload(CLM,reviewPlatform,{epoch:(time.strftime('%m/%d/%Y'),reportSize)})
118
119			def RemoveDataUpload(self,CLM,UEPOCH):
120			"""This method calls DeleteCaseUpload and removes just one case upload. """
121			err = self.accessDB.DeleteCaseUpload(CLM,UEPOCH)
122			if err:
123			print "ERROR: An Error occured and this value was not removed!"
124			else:
125			print "%s Removed"% UEPOCH
126
127			def GetUploadData(self, caseName):
128			# Used to get upload data, on the selected case, to populate the upload dialog
129			clientMatter = caseName.split("_(")[1]
130			clientMatter = clientMatter[:-1]
131			clientMatter = clientMatter.replace('-','.')
132			uploadList = self.accessDB.RetrieveUploadsByCLM(clientMatter)
133			return uploadList
134
135			def GetProductionData(self,caseName):
136			clientMatter = caseName.split("_(")[1]
137			clientMatter = clientMatter[:-1]
138			clientMatter = clientMatter.replace('-','.')
139			productionList = self.accessDB.RetrieveProductionsByCLM(clientMatter)
140			return productionList
141
142			def GetProductionTotal(self,productionList):
143			"""Using the above productionList, this returns the total docs and pages produced"""
144			pgCountTotal = 0
145			docCountTotal = 0
146			for i in productionList:
147			pageCount = i[-2]
148			docCount = i[-3]
149			if 'None' in pageCount:
150			pass
151			else:
152			#print pageCount
153			pgCountTotal = pgCountTotal+int(pageCount)
154			if 'None' in pageCount:
155			pass
156			else:
157			#print docCount
158			docCountTotal = docCountTotal+int(docCount)
159			return pgCountTotal,docCountTotal
160
161			def ExportProductionDataToExcel(self,CaseName,pathToCSV):
162			"""Exports the production data to a csv file"""
163			productionList = self.GetProductionData(CaseName)
164			#print productionList
165			outputFile = open(pathToCSV,'w')
166			outputFile.write('Production ID,Production Date,Start Bates,End Bates,Document Count,Page Count,Notes\n')
167			for i in productionList:
168			for x in i:
169			outputFile.write(x+",")
170			outputFile.write("\n")
171			outputFile.close()
172
173			def GetUploadTotal(self,uploadList):
174			""" Using the above uploadList, this will return the total uploaded """
175			count = 0.
176			for i in uploadList:
177			size = i[-1]
178
179			if 'None' in size:
180			pass
181			else:
182			rawSize = directorySize2.prettyToUnpretty_Filesize(size)
183			count = count + rawSize
184			prettySizeFinal = directorySize2.pretty_filesize2(count)
185			return prettySizeFinal
186
187			def MakeCaseDormant(self, caseAndCLM):
188			"""Moves the case to the Dormant folder"""
189			print "Making %s case dormant..."
190			os.rename(os.path.join(self.casesDir,caseAndCLM),os.path.join(self.casesDir,os.path.join('zzzz_dormant_', caseAndCLM)))
191			print "Case has been archived."
192
193
194	nino.borges	158	def ViewCaseNotes(self,caseName,office):
195			"""Trys to open the case notes file,in the case folder, for the active case, regardless who owns it."""
196			caseFolderLocation = MCP_Lib.GetOtherCaseFolder(office)
197			clientMatter = caseName.split("_(")[1]
198			clientMatter = clientMatter[:-1]
199			if "." in clientMatter:
200			clientMatter = clientMatter.replace('.','-')
201			folderMatrix = {}
202			#caseFolderLocation = os.path.join(caseFolderLocation,case)
203			err = False
204			if caseFolderLocation:
205			if os.path.exists(caseFolderLocation):
206			for f in os.listdir(caseFolderLocation):
207			if "_(" in f:
208			folderClientMatter = f.split("_(")[1]
209			folderClientMatter = folderClientMatter[:-1]
210			folderMatrix[folderClientMatter] = f
211			try:
212			folderName = folderMatrix[clientMatter]
213			os.startfile(os.path.join(caseFolderLocation, folderName)+"/Gen_Notes.txt")
214			except:
215			err = True
216			else:
217			err = True
218			else:
219			print "A case folder for this case was not found."
220			err = True
221			return err
222
223			def ViewProdSpec(self,caseName,office):
224			"""Trys to open the prod spec file,in the case folder, for the active case, regardless who owns it."""
225			caseFolderLocation = MCP_Lib.GetOtherCaseFolder(office)
226			clientMatter = caseName.split("_(")[1]
227			clientMatter = clientMatter[:-1]
228			if "." in clientMatter:
229			clientMatter = clientMatter.replace('.','-')
230			folderMatrix = {}
231			#caseFolderLocation = os.path.join(caseFolderLocation,case)
232			err = False
233			if caseFolderLocation:
234			if os.path.exists(caseFolderLocation):
235			for f in os.listdir(caseFolderLocation):
236			if "_(" in f:
237			folderClientMatter = f.split("_(")[1]
238			folderClientMatter = folderClientMatter[:-1]
239			folderMatrix[folderClientMatter] = f
240			try:
241			folderName = folderMatrix[clientMatter]
242			os.startfile(os.path.join(caseFolderLocation, folderName+"/Production_Spec.txt"))
243			except:
244			err = True
245			else:
246			err = True
247			else:
248			print "A case folder for this case was not found."
249			err = True
250			return err
251
252	nino.borges	261	def OpenAlternateMediaFolder(self,caseName,office):
253			"""Trys to open the Alternate media folder, for the active case, regardless who owns it."""
254			clientMatter = caseName.split("_(")[1]
255			clientMatter = clientMatter[:-1]
256			clientMatter = clientMatter.replace('-','.')
257			altMediaPath = self.accessDB.GetAlternateMediaPath(clientMatter)
258			err = False
259			if altMediaPath:
260			if os.path.exists(altMediaPath):
261			os.startfile(altMediaPath)
262			else:
263			print "An alternate media folder for this case was not found."
264			err = True
265			else:
266			err = True
267			return err
268
269	ninoborges	8	def OpenCaseFolder(self,caseName,office):
270			"""Trys to open the case folder for the active case, regardless who owns it."""
271			caseFolderLocation = MCP_Lib.GetOtherCaseFolder(office)
272			clientMatter = caseName.split("_(")[1]
273			clientMatter = clientMatter[:-1]
274			if "." in clientMatter:
275			clientMatter = clientMatter.replace('.','-')
276			folderMatrix = {}
277			#caseFolderLocation = os.path.join(caseFolderLocation,case)
278			err = False
279			if caseFolderLocation:
280			if os.path.exists(caseFolderLocation):
281			for f in os.listdir(caseFolderLocation):
282			if "_(" in f:
283			folderClientMatter = f.split("_(")[1]
284			folderClientMatter = folderClientMatter[:-1]
285			folderMatrix[folderClientMatter] = f
286			try:
287			folderName = folderMatrix[clientMatter]
288			os.startfile(os.path.join(caseFolderLocation, folderName))
289			except:
290			err = True
291			else:
292			err = True
293			else:
294			print "A case folder for this case was not found."
295			err = True
296			return err
297
298
299			def SetCaseNameAndCLM(self, newCaseName, newClientMatterNumber):
300			"""Used when setting up a new case. Should have both or nothing"""
301			self.caseName = newCaseName
302			self.clientMatter = newClientMatterNumber
303			#print self.clientMatter
304
305			def SetChargableCase(self, chargBool):
306			"""sets or clears the chargable case settings"""
307			pass
308			def SetResponsibleVendor(self, vendorInfo):
309			"""Sets the vendor name that is responsible for the case"""
310			pass
311			def SetReviewPlatform(self, reviewPlatform):
312			"""Sets the review platform chosen for this case"""
313			if reviewPlatform == "Concordance":
314			print "Concordance selected. Creating DIS directories..."
315			hDrivePath = ConcordanceHelperTools.ParseClientMatter(self.clientMatter)
316			os.mkdir(hDrivePath)
317			print "Matter folder created."
318			os.mkdir(os.path.join(hDrivePath,'Match'))
319			os.mkdir(os.path.join(hDrivePath,'Tag_Databases'))
320			print "Supplemental folders created."
321			print "DIS directories done!"
322
323
324
325			def SyncWithAccessDB(self,case = 'ALL'):
326			"""Syncs your cases with the access database. This might only get run once when you first install
327			the program though..."""
328			## So this syncs 'your' databases only. even though you are looking at a list of eeryone's databases
329			## it will only sync yours. even if you did an upload for another tpm, that wouldnt get synced unles
330			## the owner did a sync all. for 2 way sync to work, you should check, in access, that they have the case name
331			## (with no funky characters) populated, before they run this for the first time.
332			if case == 'ALL':
333			## verify that all your cases are up there, if not add it. but have support for cases where is should be
334			## yours but is assigned to someone else...
335			fullClientMatterList = self.accessDB.RetrieveAllCaseList()
336			myAccessClientMatterList = self.accessDB.RetrieveMyCaseList(self.tPMID)
337			myLocalClientMatterList = []
338
339			## Sync cases from my local to access
340			for case in self.responsibleCasesList:
341			localCaseName,clientMatter = case.split("_(")
342			clientMatter = clientMatter.replace(")","")
343			clientMatter = clientMatter.replace("-",".")
344			myLocalClientMatterList.append(clientMatter)
345			for clm in myLocalClientMatterList:
346			if clm in myAccessClientMatterList:
347			print "%s exists"% clm
348			elif clm in fullClientMatterList:
349			print "%s cant be added to your cases because it's owned by someone else..."% clm
350			else:
351			print "%s does not exist in the database. Adding it..."% clm
352			self.AddCaseToAccessDB(localCaseName,clientMatter)
353
354			## Sync cases from Access to my local
355
356
357			uploadReportMatrix = {}
358			for caseName in self.responsibleCasesList:
359			print "now processing %s"% caseName
360			casePath = os.path.join(self.casesDir,caseName)
361			if os.path.exists(os.path.join(casePath,"UploadReport.txt")):
362			print "yup"
363			caseUploadContents = open(os.path.join(casePath,"UploadReport.txt")).readlines()
364			clientMatter = caseName.split("_(")[1]
365			clientMatter = clientMatter.replace(")","")
366			clientMatter = clientMatter.replace("-",".")
367			for i in caseUploadContents:
368			i = i.replace("\n","")
369			i = i.replace(" \| ","\|")
370			try:
371			uploadReportMatrix[clientMatter].append(("%s"%i.split("\|")[0],"%s"%i.split("\|")[1],"%s"%i.split("\|")[2],"%s"%i.split("\|")[3]))
372			except:
373			uploadReportMatrix[clientMatter] = [("%s"%i.split("\|")[0],"%s"%i.split("\|")[1],"%s"%i.split("\|")[2],"%s"%i.split("\|")[3])]
374			#print uploadReportMatrix
375
376			accessMyCaseUploads = self.accessDB.RetrieveMyCaseUploads('09756')
377			for x in uploadReportMatrix.keys():
378			localCaseUploadList = uploadReportMatrix[x]
379			tempMatrix = {}
380			try:
381			accessCaseUploadList = accessMyCaseUploads[x]
382			#print accessCaseUploadList
383			for y in localCaseUploadList:
384			epoch = y[0]
385			if int(epoch) > 1298462400:
386			#print epoch
387			reviewPlatform = y[1]
388			reportSize = y[3]
389			#print "."
390			#print accessCaseUploadList
391			if epoch in accessCaseUploadList:
392			print "%s, in the %s case, is already in there, skipping."%(y,x)
393			else:
394			print "%s, in the %s case, is missing. Will be added..."%(y,x)
395			date = y[2]
396			date = "%s/%s/%s"%(date[4:6],date[6:],date[:4])
397
398			self.accessDB.UpdateCaseUpload(x,reviewPlatform,{epoch:(date,reportSize)})
399			#tempMatrix[epoch] = [platform,(date,size)]
400			else:
401			#print "This entry is pre cutover"
402			pass
403			except KeyError:
404			print "nothing for this one"
405			for z in localCaseUploadList:
406			print "%s, in the %s case, is missing. Will be added..."%(z,x)
407			date = z[0]
408			date = "%s/%s/%s"%(date[4:6],date[6:],date[:4])
409			#try:
410			# tempMatrix[date].append(z[1])
411			#except:
412			# tempMatrix[date] = [z[1]]
413			#print tempMatrix
414			#if tempMatrix:
415			# #print tempMatrix
416			# self.accessDB.UpdateCaseUpload(x,'Concordance DIS', tempMatrix)
417			#pass
418
419
420			#print myLocalClientMatterList
421			## verify that all of your uploads are up there, if not, add it.
422			self.accessDB.CloseAccessConnection()
423
424			else:
425			fullClientMatterList = self.accessDB.RetrieveAllCaseList()
426			myAccessClientMatterList = self.accessDB.RetrieveMyCaseList(self.tPMID)
427
428