rzerres/advotracker
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

imports: allianzdirectcall: use array to verify on startup

Browse Source 
* using test dataset

Signed-off-by: Ralf Zerres <ralf.zerres@networkx.de>
This commit is contained in:
Ralf Zerres
2020-07-03 00:58:35 +02:00
parent 8ec566b78a
commit 7f58ecb96c
1 changed files with 15 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
advotracker/src/services/imports/allianzdirectcall.rs
View File

@@ -47,7 +47,7 @@ pub fn import(p: &mut String, data_list: &mut PolicyDataList,
let file = File::open(path)?; let file = File::open(path)?;
trace!(target: "advotrackerd", extension = ?extension, file = ?file); trace!(target: "advotrackerd", extension = ?extension, file = ?file);
// Build the CSV reader and iterate over each record. // Build the CSV reader
let mut csv_reader = csv::ReaderBuilder::new() let mut csv_reader = csv::ReaderBuilder::new()
.has_headers(true) .has_headers(true)
.delimiter(b' ') .delimiter(b' ')
@@ -60,14 +60,15 @@ pub fn import(p: &mut String, data_list: &mut PolicyDataList,
trace!(target: "advotrackerd", header = ?headers); trace!(target: "advotrackerd", header = ?headers);
} }
//for result in csv_reader.records() { // Iterate over each record, deserialize und write to our structures
let mut count = 0; let mut count = 0;
for result in csv_reader.deserialize() { for result in csv_reader.deserialize() {
// The iterator yields Result<StringRecord, Error>, so we check the // The iterator yields Result<StringRecord, Error>, so we check the
// error here. // error here.
let record: PolicyData = result?; let record: PolicyData = result?;
//let record: data::AllianzPolicyNumber = result?; //if verbose > 3 {
println!("{:?}", record); // println!("{:?}", record);
//}
// WIP: write to redis backend // WIP: write to redis backend
// append the policy_number to the HashMap // append the policy_number to the HashMap
@@ -86,21 +87,16 @@ pub fn import(p: &mut String, data_list: &mut PolicyDataList,
// Tests // Tests
// Takes a reference and returns Option<&V> // Takes a reference and returns Option<&V>
let test_policy_number : usize = 1511111111; let my_policy_numbers : [usize; 2] = [1511111111, 9999999993];
match data_list.get(test_policy_number) { assert_eq!(my_policy_numbers, [1511111111, 9999999993]);
Some(policy_code) => { for p in &my_policy_numbers {
println!("Policy-Number {:?} {:?}", match policy_numbers.get(&p) {
test_policy_number, policy_code); Some(policy_code) => {
}, println!("Test: Policy-Number {:?} => Policy-Type {:?}, as expected!",
_ => println!("1. No number found!"), p, policy_code);
} },
_ => println!("Test: Policy-Number {:?} => not valid, can't dereference the Policy-Type as expected", p),
let test_policy_number_2 : usize = 9999999991; }
match data_list.get(test_policy_number_2) {
Some(policy_code) => { println!("Policy-Number: {:?} {:?}",
test_policy_number, policy_code);
},
_ => println!("2. No number found!"),
} }
state = t!("state.finished", lang); state = t!("state.finished", lang);