aers_rewrite/commit
ADD routine to remove reports that are updated
author | Michiel Hildebrand |
---|---|
Thu Jan 31 13:35:14 2013 +0100 | |
committer | Michiel Hildebrand |
Thu Jan 31 13:35:14 2013 +0100 | |
commit | e492aa41b6ad27490aeb34afb6192b2dc785e36b |
tree | 95d81607245bbe54b3a59e8b3f5ac79049e44454 |
parent | 80f0340eecd688630cb04e1f603e39204dc13e2b |
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 + ).