Mercurial > repos > davidvanzessen > shm_csr
comparison shm_csr.py @ 90:6809c63d9161 draft
"planemo upload commit fd64827ff6e63df008f6f50ddb8576ad2b1dbb26"
author | rhpvorderman |
---|---|
date | Tue, 25 Jan 2022 11:28:29 +0000 |
parents | 729738462297 |
children | 385dea3c6cb5 |
comparison
equal
deleted
inserted
replaced
89:3c9d4d976c47 | 90:6809c63d9161 |
---|---|
1 import argparse | 1 import argparse |
2 import logging | 2 import logging |
3 import sys | 3 import sys |
4 import os | 4 import os |
5 import re | 5 import typing |
6 from typing import Optional | |
6 | 7 |
7 from collections import defaultdict | 8 from collections import defaultdict |
9 | |
10 REGION_FILTERS = ("leader", "FR1", "CDR1", "FR2", "CDR2") | |
11 | |
12 | |
13 class Mutation(typing.NamedTuple): | |
14 """Represent a mutation type as a tuple""" | |
15 frm: str # 'from' is a reserved python keyword. | |
16 where: int | |
17 to: str | |
18 frmAA: Optional[str] = None | |
19 whereAA: Optional[int] = None | |
20 toAA: Optional[str] = None | |
21 thing: Optional[str] = None # '(---)' or '(+-+)' etc. No idea | |
22 | |
23 @classmethod | |
24 def from_string(cls, string: str): | |
25 # Complete mutation example: a88>g,I30>V(+ - +) | |
26 # Only nucleotide example: g303>t | |
27 # Including codon change: | |
28 # t169>g,Y57>D(- - -); Y57 tat 169-171 [ta 169-170]>D gac | |
29 # Including codon change (synonumous mutation): | |
30 # c114>t, Y38; Y38 tac 112-114 [tact 112-115]>Y tat | |
31 if ',' in string: | |
32 nucleotide_change, aa_change = string.split(',', maxsplit=1) # type: str, Optional[str] | |
33 else: | |
34 nucleotide_change = string | |
35 aa_change = None | |
36 frm_part, to = nucleotide_change.split('>', maxsplit=1) | |
37 frm = frm_part[0] | |
38 where = int(frm_part[1:]) | |
39 | |
40 if aa_change is None: | |
41 return cls(frm, where, to) | |
42 | |
43 aa_change = aa_change.strip() | |
44 # The part after semicolon indicates the codon change. This part may | |
45 # not be present. | |
46 semi_colon_index = aa_change.find(";") | |
47 if semi_colon_index == -1: | |
48 codon_change = "" | |
49 else: | |
50 codon_change = aa_change[semi_colon_index:] | |
51 aa_change = aa_change[:semi_colon_index] | |
52 change_operator_index = aa_change.find(">") | |
53 if change_operator_index == -1: | |
54 # Synonymous change | |
55 frmAA_part = aa_change | |
56 toAA_part = "" | |
57 else: | |
58 frmAA_part, toAA_part = aa_change.split('>', maxsplit=1) # type: str, str | |
59 frmAA = frmAA_part[0] | |
60 whereAA = int(frmAA_part[1:]) | |
61 if toAA_part: | |
62 brace_start = toAA_part.index('(') | |
63 toAA = toAA_part[:brace_start] | |
64 thing = toAA_part[brace_start:] + codon_change | |
65 else: | |
66 # Synonymous mutation | |
67 toAA = frmAA | |
68 thing = codon_change | |
69 return cls(frm, where, to, frmAA, whereAA, toAA, thing) | |
70 | |
71 | |
72 class Hotspot(typing.NamedTuple): | |
73 start: int | |
74 end: int | |
75 region: str | |
76 | |
77 @classmethod | |
78 def from_string(cls, string): | |
79 # Example: aa,40-41(FR1) | |
80 sequence, rest = string.split(',') # type: str, str | |
81 brace_pos = rest.index('(') | |
82 numbers = rest[:brace_pos] | |
83 start, end = numbers.split('-') | |
84 region = rest[brace_pos + 1:-1] # Remove the braces | |
85 return cls(int(start), int(end), region) | |
86 | |
8 | 87 |
9 def main(): | 88 def main(): |
10 parser = argparse.ArgumentParser() | 89 parser = argparse.ArgumentParser() |
11 parser.add_argument("--input", help="The '7_V-REGION-mutation-and-AA-change-table' and '10_V-REGION-mutation-hotspots' merged together, with an added 'best_match' annotation") | 90 parser.add_argument("--input", help="The '7_V-REGION-mutation-and-AA-change-table' and '10_V-REGION-mutation-hotspots' merged together, with an added 'best_match' annotation") |
12 parser.add_argument("--genes", help="The genes available in the 'best_match' column") | 91 parser.add_argument("--genes", help="The genes available in the 'best_match' column") |
13 parser.add_argument("--empty_region_filter", help="Where does the sequence start?", choices=['leader', 'FR1', 'CDR1', 'FR2']) | 92 parser.add_argument("--empty_region_filter", help="Where does the sequence start?", choices=REGION_FILTERS) |
14 parser.add_argument("--output", help="Output file") | 93 parser.add_argument("--output", help="Output file") |
15 | 94 |
16 args = parser.parse_args() | 95 args = parser.parse_args() |
17 | 96 |
18 infile = args.input | 97 infile = args.input |
21 outfile = args.output | 100 outfile = args.output |
22 | 101 |
23 genedic = dict() | 102 genedic = dict() |
24 | 103 |
25 mutationdic = dict() | 104 mutationdic = dict() |
26 mutationMatcher = re.compile("^(.)(\d+).(.),?[ ]?(.)?(\d+)?.?(.)?(.?.?.?.?.?)?") | |
27 mutationMatcher = re.compile("^([actg])(\d+).([actg]),?[ ]?([A-Z])?(\d+)?.?([A-Z])?(.*)?") | |
28 mutationMatcher = re.compile("^([actg])(\d+).([actg]),?[ ]?([A-Z])?(\d+)?[>]?([A-Z;])?(.*)?") | |
29 mutationMatcher = re.compile(r"^([nactg])(\d+).([nactg]),?[ ]?([A-Z*])?(\d+)?[>]?([A-Z*;])?(.*)?") | |
30 NAMatchResult = (None, None, None, None, None, None, '') | 105 NAMatchResult = (None, None, None, None, None, None, '') |
31 geneMatchers = {gene: re.compile("^" + gene + ".*") for gene in genes} | |
32 linecount = 0 | 106 linecount = 0 |
33 | 107 |
34 IDIndex = 0 | 108 IDIndex = 0 |
35 best_matchIndex = 0 | 109 best_matchIndex = 0 |
36 fr1Index = 0 | 110 fr1Index = 0 |
40 fr3Index = 0 | 114 fr3Index = 0 |
41 first = True | 115 first = True |
42 IDlist = [] | 116 IDlist = [] |
43 mutationList = [] | 117 mutationList = [] |
44 mutationListByID = {} | 118 mutationListByID = {} |
45 cdr1LengthDic = {} | 119 cdr1AALengthDic = {} |
46 cdr2LengthDic = {} | 120 cdr2AALengthDic = {} |
47 | 121 |
48 fr1LengthDict = {} | 122 LengthDic = {} |
49 fr2LengthDict = {} | |
50 fr3LengthDict = {} | |
51 | 123 |
52 cdr1LengthIndex = 0 | 124 cdr1LengthIndex = 0 |
53 cdr2LengthIndex = 0 | 125 cdr2LengthIndex = 0 |
54 | |
55 fr1SeqIndex = 0 | |
56 fr2SeqIndex = 0 | |
57 fr3SeqIndex = 0 | |
58 | 126 |
59 tandem_sum_by_class = defaultdict(int) | 127 tandem_sum_by_class = defaultdict(int) |
60 expected_tandem_sum_by_class = defaultdict(float) | 128 expected_tandem_sum_by_class = defaultdict(float) |
61 | 129 |
62 with open(infile, 'r') as i: | 130 with open(infile, 'r') as i: |
68 fr1Index = linesplt.index("FR1.IMGT") | 136 fr1Index = linesplt.index("FR1.IMGT") |
69 cdr1Index = linesplt.index("CDR1.IMGT") | 137 cdr1Index = linesplt.index("CDR1.IMGT") |
70 fr2Index = linesplt.index("FR2.IMGT") | 138 fr2Index = linesplt.index("FR2.IMGT") |
71 cdr2Index = linesplt.index("CDR2.IMGT") | 139 cdr2Index = linesplt.index("CDR2.IMGT") |
72 fr3Index = linesplt.index("FR3.IMGT") | 140 fr3Index = linesplt.index("FR3.IMGT") |
73 cdr1LengthIndex = linesplt.index("CDR1.IMGT.length") | 141 fr1LengthIndex = linesplt.index("FR1.IMGT.Nb.of.nucleotides") |
74 cdr2LengthIndex = linesplt.index("CDR2.IMGT.length") | 142 fr2LengthIndex = linesplt.index("FR2.IMGT.Nb.of.nucleotides") |
75 fr1SeqIndex = linesplt.index("FR1.IMGT.seq") | 143 fr3LengthIndex = linesplt.index("FR3.IMGT.Nb.of.nucleotides") |
76 fr2SeqIndex = linesplt.index("FR2.IMGT.seq") | 144 cdr1LengthIndex = linesplt.index("CDR1.IMGT.Nb.of.nucleotides") |
77 fr3SeqIndex = linesplt.index("FR3.IMGT.seq") | 145 cdr2LengthIndex = linesplt.index("CDR2.IMGT.Nb.of.nucleotides") |
146 cdr1AALengthIndex = linesplt.index("CDR1.IMGT.length") | |
147 cdr2AALengthIndex = linesplt.index("CDR2.IMGT.length") | |
78 first = False | 148 first = False |
79 continue | 149 continue |
80 linecount += 1 | 150 linecount += 1 |
81 linesplt = line.split("\t") | 151 linesplt = line.split("\t") |
82 ID = linesplt[IDIndex] | 152 ID = linesplt[IDIndex] |
83 genedic[ID] = linesplt[best_matchIndex] | 153 genedic[ID] = linesplt[best_matchIndex] |
84 | 154 |
85 mutationdic[ID + "_FR1"] = [] | 155 mutationdic[ID + "_FR1"] = [] |
86 if len(linesplt[fr1Index]) > 5 and empty_region_filter == "leader": | 156 if len(linesplt[fr1Index]) > 5 and empty_region_filter == "leader": |
87 mutationdic[ID + "_FR1"] = [mutationMatcher.match(x).groups() for x in linesplt[fr1Index].split("|") if x] | 157 mutationdic[ID + "_FR1"] = [Mutation.from_string(x) for x in linesplt[fr1Index].split("|") if x] |
88 | 158 |
89 mutationdic[ID + "_CDR1"] = [] | 159 mutationdic[ID + "_CDR1"] = [] |
90 if len(linesplt[cdr1Index]) > 5 and empty_region_filter in ["leader", "FR1"]: | 160 if len(linesplt[cdr1Index]) > 5 and empty_region_filter in ["leader", "FR1"]: |
91 mutationdic[ID + "_CDR1"] = [mutationMatcher.match(x).groups() for x in linesplt[cdr1Index].split("|") if x] | 161 mutationdic[ID + "_CDR1"] = [Mutation.from_string(x) for x in linesplt[cdr1Index].split("|") if x] |
92 | 162 |
93 mutationdic[ID + "_FR2"] = [] | 163 mutationdic[ID + "_FR2"] = [] |
94 if len(linesplt[fr2Index]) > 5 and empty_region_filter in ["leader", "FR1", "CDR1"]: | 164 if len(linesplt[fr2Index]) > 5 and empty_region_filter in ["leader", "FR1", "CDR1"]: |
95 mutationdic[ID + "_FR2"] = [mutationMatcher.match(x).groups() for x in linesplt[fr2Index].split("|") if x] | 165 mutationdic[ID + "_FR2"] = [Mutation.from_string(x) for x in linesplt[fr2Index].split("|") if x] |
96 | 166 |
97 mutationdic[ID + "_CDR2"] = [] | 167 mutationdic[ID + "_CDR2"] = [] |
98 if len(linesplt[cdr2Index]) > 5: | 168 if len(linesplt[cdr2Index]) > 5: |
99 mutationdic[ID + "_CDR2"] = [mutationMatcher.match(x).groups() for x in linesplt[cdr2Index].split("|") if x] | 169 mutationdic[ID + "_CDR2"] = [Mutation.from_string(x) for x in linesplt[cdr2Index].split("|") if x] |
100 | 170 |
101 mutationdic[ID + "_FR2-CDR2"] = mutationdic[ID + "_FR2"] + mutationdic[ID + "_CDR2"] | 171 mutationdic[ID + "_FR2-CDR2"] = mutationdic[ID + "_FR2"] + mutationdic[ID + "_CDR2"] |
102 | 172 |
103 mutationdic[ID + "_FR3"] = [] | 173 mutationdic[ID + "_FR3"] = [] |
104 if len(linesplt[fr3Index]) > 5: | 174 if len(linesplt[fr3Index]) > 5: |
105 mutationdic[ID + "_FR3"] = [mutationMatcher.match(x).groups() for x in linesplt[fr3Index].split("|") if x] | 175 mutationdic[ID + "_FR3"] = [Mutation.from_string(x) for x in linesplt[fr3Index].split("|") if x] |
106 | 176 |
107 mutationList += mutationdic[ID + "_FR1"] + mutationdic[ID + "_CDR1"] + mutationdic[ID + "_FR2"] + mutationdic[ID + "_CDR2"] + mutationdic[ID + "_FR3"] | 177 mutationList += mutationdic[ID + "_FR1"] + mutationdic[ID + "_CDR1"] + mutationdic[ID + "_FR2"] + mutationdic[ID + "_CDR2"] + mutationdic[ID + "_FR3"] |
108 mutationListByID[ID] = mutationdic[ID + "_FR1"] + mutationdic[ID + "_CDR1"] + mutationdic[ID + "_FR2"] + mutationdic[ID + "_CDR2"] + mutationdic[ID + "_FR3"] | 178 mutationListByID[ID] = mutationdic[ID + "_FR1"] + mutationdic[ID + "_CDR1"] + mutationdic[ID + "_FR2"] + mutationdic[ID + "_CDR2"] + mutationdic[ID + "_FR3"] |
109 | 179 |
110 try: | 180 fr1Length = int(linesplt[fr1LengthIndex]) |
111 cdr1Length = int(linesplt[cdr1LengthIndex]) | 181 fr2Length = int(linesplt[fr2LengthIndex]) |
112 except: | 182 fr3Length = int(linesplt[fr3LengthIndex]) |
113 cdr1Length = 0 | 183 cdr1Length = int(linesplt[cdr1LengthIndex]) |
114 | 184 cdr2Length = int(linesplt[cdr2LengthIndex]) |
115 try: | 185 LengthDic[ID] = (fr1Length, cdr1Length, fr2Length, cdr2Length, fr3Length) |
116 cdr2Length = int(linesplt[cdr2LengthIndex]) | 186 |
117 except: | 187 cdr1AALengthDic[ID] = int(linesplt[cdr1AALengthIndex]) |
118 cdr2Length = 0 | 188 cdr2AALengthDic[ID] = int(linesplt[cdr2AALengthIndex]) |
119 | |
120 #print linesplt[fr2SeqIndex] | |
121 fr1Length = len(linesplt[fr1SeqIndex]) if empty_region_filter == "leader" else 0 | |
122 fr2Length = len(linesplt[fr2SeqIndex]) if empty_region_filter in ["leader", "FR1", "CDR1"] else 0 | |
123 fr3Length = len(linesplt[fr3SeqIndex]) | |
124 | |
125 cdr1LengthDic[ID] = cdr1Length | |
126 cdr2LengthDic[ID] = cdr2Length | |
127 | |
128 fr1LengthDict[ID] = fr1Length | |
129 fr2LengthDict[ID] = fr2Length | |
130 fr3LengthDict[ID] = fr3Length | |
131 | 189 |
132 IDlist += [ID] | 190 IDlist += [ID] |
133 print("len(mutationdic) =", len(mutationdic)) | 191 print("len(mutationdic) =", len(mutationdic)) |
134 | 192 |
135 with open(os.path.join(os.path.dirname(os.path.abspath(infile)), "mutationdict.txt"), 'w') as out_handle: | 193 with open(os.path.join(os.path.dirname(os.path.abspath(infile)), "mutationdict.txt"), 'w') as out_handle: |
153 mutations_by_id_dic[splt[0]] = int(splt[1]) | 211 mutations_by_id_dic[splt[0]] = int(splt[1]) |
154 | 212 |
155 tandem_file = os.path.join(os.path.dirname(outfile), "tandems_by_id.txt") | 213 tandem_file = os.path.join(os.path.dirname(outfile), "tandems_by_id.txt") |
156 with open(tandem_file, 'w') as o: | 214 with open(tandem_file, 'w') as o: |
157 highest_tandem_length = 0 | 215 highest_tandem_length = 0 |
216 # LengthDic stores length as a tuple | |
217 # (fr1Length, cdr1Length, fr2Length, cdr2Length, fr3Length) | |
218 # To get the total length, we can sum(region_lengths) | |
219 # To get the total length for leader: | |
220 # sum(region_lengths[0:]) (Equivalent to everything) | |
221 # sum(region_lengths[1:]) Gets everything except FR1 etc. | |
222 # We determine the position to start summing below. | |
223 # This returns 0 for leader, 1 for FR1 etc. | |
224 length_start_pos = REGION_FILTERS.index(empty_region_filter) | |
158 | 225 |
159 o.write("Sequence.ID\tnumber_of_mutations\tnumber_of_tandems\tregion_length\texpected_tandems\tlongest_tandem\ttandems\n") | 226 o.write("Sequence.ID\tnumber_of_mutations\tnumber_of_tandems\tregion_length\texpected_tandems\tlongest_tandem\ttandems\n") |
160 for ID in IDlist: | 227 for ID in IDlist: |
161 mutations = mutationListByID[ID] | 228 mutations = mutationListByID[ID] |
229 region_length = sum(LengthDic[ID][length_start_pos:]) | |
162 if len(mutations) == 0: | 230 if len(mutations) == 0: |
163 continue | 231 continue |
164 last_mut = max(mutations, key=lambda x: int(x[1])) | 232 last_mut = max(mutations, key=lambda x: int(x[1])) |
165 | 233 |
166 last_mut_pos = int(last_mut[1]) | 234 last_mut_pos = int(last_mut[1]) |
192 | 260 |
193 if len(tandem_muts) > 0: | 261 if len(tandem_muts) > 0: |
194 if highest_tandem_length < len(tandem_muts): | 262 if highest_tandem_length < len(tandem_muts): |
195 highest_tandem_length = len(tandem_muts) | 263 highest_tandem_length = len(tandem_muts) |
196 | 264 |
197 region_length = fr1LengthDict[ID] + cdr1LengthDic[ID] + fr2LengthDict[ID] + cdr2LengthDic[ID] + fr3LengthDict[ID] | |
198 longest_tandem = max(tandem_muts, key=lambda x: x[1]) if len(tandem_muts) else (0, 0) | 265 longest_tandem = max(tandem_muts, key=lambda x: x[1]) if len(tandem_muts) else (0, 0) |
199 num_mutations = mutations_by_id_dic[ID] # len(mutations) | 266 num_mutations = mutations_by_id_dic[ID] # len(mutations) |
200 f_num_mutations = float(num_mutations) | 267 f_num_mutations = float(num_mutations) |
201 num_tandem_muts = len(tandem_muts) | 268 num_tandem_muts = len(tandem_muts) |
202 expected_tandem_muts = f_num_mutations * (f_num_mutations - 1.0) / float(region_length) | 269 expected_tandem_muts = f_num_mutations * (f_num_mutations - 1.0) / float(region_length) |
203 o.write("{0}\t{1}\t{2}\t{3}\t{4}\t{5}\t{6}\n".format(ID, | 270 # String format and round disagree slightly (see 3.605). |
204 str(num_mutations), | 271 # So round before formatting. |
205 str(num_tandem_muts), | 272 o.write(f"{ID}\t{num_mutations}\t{num_tandem_muts}\t{region_length}\t" |
206 str(region_length), | 273 f"{round(expected_tandem_muts, 2):.2f}\t" |
207 str(round(expected_tandem_muts, 2)), | 274 f"{longest_tandem[1]}\t{tandem_muts}\n") |
208 str(longest_tandem[1]), | |
209 str(tandem_muts))) | |
210 gene = genedic[ID] | 275 gene = genedic[ID] |
211 if gene.find("unmatched") == -1: | 276 if gene.find("unmatched") == -1: |
212 tandem_sum_by_class[gene] += num_tandem_muts | 277 tandem_sum_by_class[gene] += num_tandem_muts |
213 expected_tandem_sum_by_class[gene] += expected_tandem_muts | 278 expected_tandem_sum_by_class[gene] += expected_tandem_muts |
214 | 279 |
299 absentAACDR2Dic[7] = list(range(59,62)) | 364 absentAACDR2Dic[7] = list(range(59,62)) |
300 absentAACDR2Dic[8] = list(range(59,61)) | 365 absentAACDR2Dic[8] = list(range(59,61)) |
301 absentAACDR2Dic[9] = [60] | 366 absentAACDR2Dic[9] = [60] |
302 | 367 |
303 absentAA = [len(IDlist)] * (AALength-1) | 368 absentAA = [len(IDlist)] * (AALength-1) |
304 for k, cdr1Length in cdr1LengthDic.items(): | 369 for k, cdr1Length in cdr1AALengthDic.items(): |
305 for c in absentAACDR1Dic[cdr1Length]: | 370 for c in absentAACDR1Dic[cdr1Length]: |
306 absentAA[c] -= 1 | 371 absentAA[c] -= 1 |
307 | 372 |
308 for k, cdr2Length in cdr2LengthDic.items(): | 373 for k, cdr2Length in cdr2AALengthDic.items(): |
309 for c in absentAACDR2Dic[cdr2Length]: | 374 for c in absentAACDR2Dic[cdr2Length]: |
310 absentAA[c] -= 1 | 375 absentAA[c] -= 1 |
311 | 376 |
312 | 377 |
313 aa_mutations_by_id_file = outfile[:outfile.rindex("/")] + "/absent_aa_id.txt" | 378 aa_mutations_by_id_file = outfile[:outfile.rindex("/")] + "/absent_aa_id.txt" |
314 with open(aa_mutations_by_id_file, 'w') as o: | 379 with open(aa_mutations_by_id_file, 'w') as o: |
315 o.write("ID\tcdr1length\tcdr2length\tbest_match\t" + "\t".join([str(x) for x in range(1,AALength)]) + "\n") | 380 o.write("ID\tcdr1length\tcdr2length\tbest_match\t" + "\t".join([str(x) for x in range(1,AALength)]) + "\n") |
316 for ID in IDlist: | 381 for ID in IDlist: |
317 absentAAbyID = [1] * (AALength-1) | 382 absentAAbyID = [1] * (AALength-1) |
318 cdr1Length = cdr1LengthDic[ID] | 383 cdr1Length = cdr1AALengthDic[ID] |
319 for c in absentAACDR1Dic[cdr1Length]: | 384 for c in absentAACDR1Dic[cdr1Length]: |
320 absentAAbyID[c] -= 1 | 385 absentAAbyID[c] -= 1 |
321 | 386 |
322 cdr2Length = cdr2LengthDic[ID] | 387 cdr2Length = cdr2AALengthDic[ID] |
323 for c in absentAACDR2Dic[cdr2Length]: | 388 for c in absentAACDR2Dic[cdr2Length]: |
324 absentAAbyID[c] -= 1 | 389 absentAAbyID[c] -= 1 |
325 o.write(ID + "\t" + str(cdr1Length) + "\t" + str(cdr2Length) + "\t" + genedic[ID] + "\t" + "\t".join([str(x) for x in absentAAbyID]) + "\n") | 390 o.write(ID + "\t" + str(cdr1Length) + "\t" + str(cdr2Length) + "\t" + genedic[ID] + "\t" + "\t".join([str(x) for x in absentAAbyID]) + "\n") |
326 | 391 |
327 if linecount == 0: | 392 if linecount == 0: |
331 o.write("WRCY (%)," + ("0,0,0\n" * len(genes))) | 396 o.write("WRCY (%)," + ("0,0,0\n" * len(genes))) |
332 o.write("WA (%)," + ("0,0,0\n" * len(genes))) | 397 o.write("WA (%)," + ("0,0,0\n" * len(genes))) |
333 o.write("TW (%)," + ("0,0,0\n" * len(genes))) | 398 o.write("TW (%)," + ("0,0,0\n" * len(genes))) |
334 sys.exit() | 399 sys.exit() |
335 | 400 |
336 hotspotMatcher = re.compile("[actg]+,(\d+)-(\d+)\((.*)\)") | |
337 RGYWCount = {} | 401 RGYWCount = {} |
338 WRCYCount = {} | 402 WRCYCount = {} |
339 WACount = {} | 403 WACount = {} |
340 TWCount = {} | 404 TWCount = {} |
341 | 405 |
356 first = False | 420 first = False |
357 continue | 421 continue |
358 linesplt = line.split("\t") | 422 linesplt = line.split("\t") |
359 gene = linesplt[best_matchIndex] | 423 gene = linesplt[best_matchIndex] |
360 ID = linesplt[IDIndex] | 424 ID = linesplt[IDIndex] |
361 RGYW = [(int(x), int(y), z) for (x, y, z) in | 425 RGYW = [Hotspot.from_string(x) for x in linesplt[aggctatIndex].split("|") if x] |
362 [hotspotMatcher.match(x).groups() for x in linesplt[aggctatIndex].split("|") if x]] | 426 WRCY = [Hotspot.from_string(x) for x in linesplt[atagcctIndex].split("|") if x] |
363 WRCY = [(int(x), int(y), z) for (x, y, z) in | 427 WA = [Hotspot.from_string(x) for x in linesplt[ataIndex].split("|") if x] |
364 [hotspotMatcher.match(x).groups() for x in linesplt[atagcctIndex].split("|") if x]] | 428 TW = [Hotspot.from_string(x) for x in linesplt[tatIndex].split("|") if x] |
365 WA = [(int(x), int(y), z) for (x, y, z) in | |
366 [hotspotMatcher.match(x).groups() for x in linesplt[ataIndex].split("|") if x]] | |
367 TW = [(int(x), int(y), z) for (x, y, z) in | |
368 [hotspotMatcher.match(x).groups() for x in linesplt[tatIndex].split("|") if x]] | |
369 RGYWCount[ID], WRCYCount[ID], WACount[ID], TWCount[ID] = 0, 0, 0, 0 | 429 RGYWCount[ID], WRCYCount[ID], WACount[ID], TWCount[ID] = 0, 0, 0, 0 |
370 | 430 |
371 with open(os.path.join(os.path.dirname(os.path.abspath(infile)), "RGYW.txt"), 'a') as out_handle: | 431 with open(os.path.join(os.path.dirname(os.path.abspath(infile)), "RGYW.txt"), 'a') as out_handle: |
372 for hotspot in RGYW: | 432 for hotspot in RGYW: |
373 out_handle.write("{0}\t{1}\n".format(ID, "\t".join([str(x) for x in hotspot]))) | 433 out_handle.write("{0}\t{1}\n".format(ID, "\t".join([str(x) for x in hotspot]))) |
415 for start, end, region in motif_dic[motif]: | 475 for start, end, region in motif_dic[motif]: |
416 if start <= int(where) <= end: | 476 if start <= int(where) <= end: |
417 out_handle.write("{0}\n".format( | 477 out_handle.write("{0}\n".format( |
418 "\t".join([ | 478 "\t".join([ |
419 ID, | 479 ID, |
420 where, | 480 str(where), |
421 region, | 481 region, |
422 frm, | 482 frm, |
423 to, | 483 to, |
424 str(AAwhere), | 484 str(AAwhere), |
425 str(AAfrm), | 485 str(AAfrm), |
481 with open(foutfile, 'w') as o: | 541 with open(foutfile, 'w') as o: |
482 for typ in arr: | 542 for typ in arr: |
483 o.write(typ + " (%)") | 543 o.write(typ + " (%)") |
484 curr = dic[typ] | 544 curr = dic[typ] |
485 for gene in genes: | 545 for gene in genes: |
486 geneMatcher = geneMatchers[gene] | 546 if valuedic[gene + "_" + fname] == 0: |
487 if valuedic[gene + "_" + fname] is 0: | |
488 o.write(",0,0,0") | 547 o.write(",0,0,0") |
489 else: | 548 else: |
490 x, y, z = get_xyz([curr[x] for x in [y for y, z in genedic.items() if geneMatcher.match(z)]], gene, func, fname) | 549 x, y, z = get_xyz([curr[x] for x in [y for y, z in genedic.items() if z.startswith(gene)]], gene, func, fname) |
491 o.write("," + x + "," + y + "," + z) | 550 o.write("," + x + "," + y + "," + z) |
492 x, y, z = get_xyz([y for x, y in curr.items() if not genedic[x].startswith("unmatched")], "total", func, fname) | 551 x, y, z = get_xyz([y for x, y in curr.items() if not genedic[x].startswith("unmatched")], "total", func, fname) |
493 #x, y, z = get_xyz([y for x, y in curr.iteritems()], "total", func, fname) | 552 #x, y, z = get_xyz([y for x, y in curr.iteritems()], "total", func, fname) |
494 o.write("," + x + "," + y + "," + z + "\n") | 553 o.write("," + x + "," + y + "," + z + "\n") |
495 | 554 |