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.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 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:	189
Committed:	Fri Nov 2 15:18:39 2012 UTC (13 years, 4 months ago) by nino.borges
Content type:	text/x-python
Original Path:	*Python/NinoCode/Active_prgs/MCP/MCP_Console.py*
File size:	19993 byte(s)
Log Message:	Added backend 'view my case notes' ability to view edit and added same to ui and back end of copyUp.
#	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	ninoborges	8	def OpenCaseFolder(self,caseName,office):
253			"""Trys to open the case folder for the active case, regardless who owns it."""
254			caseFolderLocation = MCP_Lib.GetOtherCaseFolder(office)
255			clientMatter = caseName.split("_(")[1]
256			clientMatter = clientMatter[:-1]
257			if "." in clientMatter:
258			clientMatter = clientMatter.replace('.','-')
259			folderMatrix = {}
260			#caseFolderLocation = os.path.join(caseFolderLocation,case)
261			err = False
262			if caseFolderLocation:
263			if os.path.exists(caseFolderLocation):
264			for f in os.listdir(caseFolderLocation):
265			if "_(" in f:
266			folderClientMatter = f.split("_(")[1]
267			folderClientMatter = folderClientMatter[:-1]
268			folderMatrix[folderClientMatter] = f
269			try:
270			folderName = folderMatrix[clientMatter]
271			os.startfile(os.path.join(caseFolderLocation, folderName))
272			except:
273			err = True
274			else:
275			err = True
276			else:
277			print "A case folder for this case was not found."
278			err = True
279			return err
280
281
282			def SetCaseNameAndCLM(self, newCaseName, newClientMatterNumber):
283			"""Used when setting up a new case. Should have both or nothing"""
284			self.caseName = newCaseName
285			self.clientMatter = newClientMatterNumber
286			#print self.clientMatter
287
288			def SetChargableCase(self, chargBool):
289			"""sets or clears the chargable case settings"""
290			pass
291			def SetResponsibleVendor(self, vendorInfo):
292			"""Sets the vendor name that is responsible for the case"""
293			pass
294			def SetReviewPlatform(self, reviewPlatform):
295			"""Sets the review platform chosen for this case"""
296			if reviewPlatform == "Concordance":
297			print "Concordance selected. Creating DIS directories..."
298			hDrivePath = ConcordanceHelperTools.ParseClientMatter(self.clientMatter)
299			os.mkdir(hDrivePath)
300			print "Matter folder created."
301			os.mkdir(os.path.join(hDrivePath,'Match'))
302			os.mkdir(os.path.join(hDrivePath,'Tag_Databases'))
303			print "Supplemental folders created."
304			print "DIS directories done!"
305
306
307
308			def SyncWithAccessDB(self,case = 'ALL'):
309			"""Syncs your cases with the access database. This might only get run once when you first install
310			the program though..."""
311			## So this syncs 'your' databases only. even though you are looking at a list of eeryone's databases
312			## it will only sync yours. even if you did an upload for another tpm, that wouldnt get synced unles
313			## the owner did a sync all. for 2 way sync to work, you should check, in access, that they have the case name
314			## (with no funky characters) populated, before they run this for the first time.
315			if case == 'ALL':
316			## verify that all your cases are up there, if not add it. but have support for cases where is should be
317			## yours but is assigned to someone else...
318			fullClientMatterList = self.accessDB.RetrieveAllCaseList()
319			myAccessClientMatterList = self.accessDB.RetrieveMyCaseList(self.tPMID)
320			myLocalClientMatterList = []
321
322			## Sync cases from my local to access
323			for case in self.responsibleCasesList:
324			localCaseName,clientMatter = case.split("_(")
325			clientMatter = clientMatter.replace(")","")
326			clientMatter = clientMatter.replace("-",".")
327			myLocalClientMatterList.append(clientMatter)
328			for clm in myLocalClientMatterList:
329			if clm in myAccessClientMatterList:
330			print "%s exists"% clm
331			elif clm in fullClientMatterList:
332			print "%s cant be added to your cases because it's owned by someone else..."% clm
333			else:
334			print "%s does not exist in the database. Adding it..."% clm
335			self.AddCaseToAccessDB(localCaseName,clientMatter)
336
337			## Sync cases from Access to my local
338
339
340			uploadReportMatrix = {}
341			for caseName in self.responsibleCasesList:
342			print "now processing %s"% caseName
343			casePath = os.path.join(self.casesDir,caseName)
344			if os.path.exists(os.path.join(casePath,"UploadReport.txt")):
345			print "yup"
346			caseUploadContents = open(os.path.join(casePath,"UploadReport.txt")).readlines()
347			clientMatter = caseName.split("_(")[1]
348			clientMatter = clientMatter.replace(")","")
349			clientMatter = clientMatter.replace("-",".")
350			for i in caseUploadContents:
351			i = i.replace("\n","")
352			i = i.replace(" \| ","\|")
353			try:
354			uploadReportMatrix[clientMatter].append(("%s"%i.split("\|")[0],"%s"%i.split("\|")[1],"%s"%i.split("\|")[2],"%s"%i.split("\|")[3]))
355			except:
356			uploadReportMatrix[clientMatter] = [("%s"%i.split("\|")[0],"%s"%i.split("\|")[1],"%s"%i.split("\|")[2],"%s"%i.split("\|")[3])]
357			#print uploadReportMatrix
358
359			accessMyCaseUploads = self.accessDB.RetrieveMyCaseUploads('09756')
360			for x in uploadReportMatrix.keys():
361			localCaseUploadList = uploadReportMatrix[x]
362			tempMatrix = {}
363			try:
364			accessCaseUploadList = accessMyCaseUploads[x]
365			#print accessCaseUploadList
366			for y in localCaseUploadList:
367			epoch = y[0]
368			if int(epoch) > 1298462400:
369			#print epoch
370			reviewPlatform = y[1]
371			reportSize = y[3]
372			#print "."
373			#print accessCaseUploadList
374			if epoch in accessCaseUploadList:
375			print "%s, in the %s case, is already in there, skipping."%(y,x)
376			else:
377			print "%s, in the %s case, is missing. Will be added..."%(y,x)
378			date = y[2]
379			date = "%s/%s/%s"%(date[4:6],date[6:],date[:4])
380
381			self.accessDB.UpdateCaseUpload(x,reviewPlatform,{epoch:(date,reportSize)})
382			#tempMatrix[epoch] = [platform,(date,size)]
383			else:
384			#print "This entry is pre cutover"
385			pass
386			except KeyError:
387			print "nothing for this one"
388			for z in localCaseUploadList:
389			print "%s, in the %s case, is missing. Will be added..."%(z,x)
390			date = z[0]
391			date = "%s/%s/%s"%(date[4:6],date[6:],date[:4])
392			#try:
393			# tempMatrix[date].append(z[1])
394			#except:
395			# tempMatrix[date] = [z[1]]
396			#print tempMatrix
397			#if tempMatrix:
398			# #print tempMatrix
399			# self.accessDB.UpdateCaseUpload(x,'Concordance DIS', tempMatrix)
400			#pass
401
402
403			#print myLocalClientMatterList
404			## verify that all of your uploads are up there, if not, add it.
405			self.accessDB.CloseAccessConnection()
406
407			else:
408			fullClientMatterList = self.accessDB.RetrieveAllCaseList()
409			myAccessClientMatterList = self.accessDB.RetrieveMyCaseList(self.tPMID)
410
411