aers_rewrite/commit

ADD routine to remove reports that are updated

authorMichiel Hildebrand
Thu Jan 31 13:35:14 2013 +0100
committerMichiel Hildebrand
Thu Jan 31 13:35:14 2013 +0100
commite492aa41b6ad27490aeb34afb6192b2dc785e36b
tree95d81607245bbe54b3a59e8b3f5ac79049e44454
parent80f0340eecd688630cb04e1f603e39204dc13e2b
Diff style: patch stat
diff --git a/lib/ascii_simplify.pl b/lib/ascii_simplify.pl
index 32d14ff..98c8ee8 100644
--- a/lib/ascii_simplify.pl
+++ b/lib/ascii_simplify.pl
@@ -14,6 +14,26 @@ quarter('04Q1').
 quarter('04Q2').
 quarter('04Q3').
 quarter('04Q4').
+quarter('05Q1').
+quarter('05Q2').
+quarter('05Q3').
+quarter('05Q4').
+quarter('06Q1').
+quarter('06Q2').
+quarter('06Q3').
+quarter('06Q4').
+quarter('07Q1').
+quarter('07Q2').
+quarter('07Q3').
+quarter('07Q4').
+quarter('08Q1').
+quarter('08Q2').
+quarter('08Q3').
+quarter('08Q4').
+quarter('09Q1').
+quarter('09Q2').
+quarter('09Q3').
+quarter('09Q4').
 
 :- debug(simplify).
 
@@ -41,7 +61,7 @@ report @@
 {S, aers:followup_status, _}?,
 {S, aers:foll_seq, _}?,
 {S, aers:mfr_dt, _}?,
-{S, aers:report_type, _}?,
+%{S, aers:report_type, _}?,
 {S, aers:mfr_num, _}?,
 {S, aers:mfr_sndr, _}?,
 {S, aers:e_sub, _}?,
@@ -54,40 +74,41 @@ report @@
 true.
 
 patient @@
-{S, rdf:type, aers:'Patient'}\
-{S, aers:age_type, _}?,
-{S, aers:weight_type, _}?,
-{S, aers:death_dt, _}?
+{_, aers:patient, P}\
+{P, aers:age_type, _}?,
+{P, aers:weight_type, _}?,
+{P, aers:death_dt, _}?
 <=>
 true.
 
 drug @@
-{S, rdf:type, aers:'Drug'}\
-{S, aers:name_type, _}?,
-{S, aers:dose_vbm, _}?,
-{S, aers:dechal, _}?,
-{S, aers:rechal, _}?,
-{S, aers:lot_num, _}?,
-{S, aers:exp_dt, _}?,
-{S, aers:nda_num, _}?
+{_, aers:drug, D}\
+%{D, aers:name_type, _}?,
+%{D, aers:dose_vbm, _}?,
+{D, aers:dechal, _}?,
+{D, aers:rechal, _}?,
+{D, aers:lot_num, _}?,
+{D, aers:exp_dt, _}?,
+{D, aers:nda_num, _}?
 <=>
 true.
 
 therapy @@
-{S, rdf:type, aers:'Therapy'},
-{_, aers:therapy, S},
-{S, _, _}
+{_, aers:therapy, T},
+{T, _, _}
 <=>
 true.
 
 % TBD load all files then remove the updated and save the update graphs
 
 remove_updated :-
+	load_quarters,
 	(    rdf(_,aers:case,Case),
 	     remove_updated(Case),
 	     fail
 	;    true
-	).
+	),
+	save_quarters.
 
 remove_updated(Case) :-
 	findall(S,rdf(S,aers:case,Case),Reports),
@@ -107,3 +128,24 @@ add_id_key(Report, Id-Report) :-
 
 retract_update(R) :-
 	rdf_retractall(R, _, _).
+
+
+load_quarters :-
+	 (   quarter(Q),
+	     atom_concat(aers, Q, Graph),
+	     atom_concat(Graph, '.ttl', RDF_FileName),
+	     absolute_file_name(ascii_simple_rdf(RDF_FileName), RDF_File),
+	     rdf_load(RDF_File, [graph(Graph)]),
+	     fail
+	 ;   true
+	 ).
+
+save_quarters :-
+	 (   quarter(Q),
+	     atom_concat(aers, Q, Graph),
+	     atom_concat(Graph, '.ttl', RDF_FileName),
+	     absolute_file_name(ascii_simple_rdf(RDF_FileName), RDF_File),
+	     rdf_save_turtle(RDF_File, [graph(Graph)]),
+	     fail
+	 ;   true
+	 ).