Overall process

Open

Deduplication is the task of finding records in a data set (MPI) that refer to the same Person. In order to guarantee data quality also should be make task of fraud defining. In case there are different persons with same document number/tax_id etc such cases won't be duplicated and it's a scope of fraud defining task.

In order to deduplicate persons next steps must be done:

• data cleaning and preparation 

• blocking and finding possible pairs

• calculating of variables for each pair

• probability linkage using model

• finding master persons in a pair and deactivation of person(s) which are not masters

• fetch declaration(s) which belongs to deactivated person(s) and declaration termination 

Data cleaning and preparation

For fields which are used for blocking or calculating variables next regular expressions must be applied:

• for first_name, second_name and last_name, birth_settlement  change: [ --'] to '',  'є' to 'е', 'и' to 'і'

• for birth_certificate change: [ /%#№ _-]  to '',  [iі!IІ] to 1

• for other documents: [ /%#№ _-]  to ''

• for birth_settlement - ([сc][ \.,])|([сc]ело[\.,]*)|([сc]мт[\.,]*)|([сc]елище [мm][іi][сc]ького типу)|([сc]елище[\.,]*)|([мm][іi][сc][tт][оo][\.,]*)|([мm][\.,]*)

Blocking and finding possible pairs

Duplicate records almost always share something in common. If we define groups of data that share something and only compare the records in that group, or block, then we can reduce the number of comparisons we will make. In other words it's we should apply smart comparison.

Predicate blocks

We need to define in such way to have much less pairs to compare and still have confidence that will compare records that truly are duplicates.

Current blocks is matching either of

• tax_id

• documents.number 

• authentication number 

• residence settlement + first_name

• residence settlement + last_name

Building index for blocks

In order to make process of pairing more efficient 

• build index for each field that take part in blocks

• add boolean flag field checked and build index on it

• one by one take persons with flag "checked" is null and take ids of persons with same characteristic (tax_id, document and all block fields)

Variables calculation for each pair

After building model on train dataset there is a knowledge which variables are correlated with target and have high IV. 

There is no linear dependency on variable and target. For example, if name has difference in 0 symbols the probability that this is same persons is high. In case the difference is 1 symbols  the probability decreases, 2 symbols - dramatically decreases, there is no linear dependency. So, we should to bin continuous variables in categorical, base on hit rate. Such approach also helps to define linear, non-linear dependency, handle missing values and predict power of missing values.

Variables that included into model are next:

Each categorical variable must be convert to continuous using WOE (which was calculated for train data sample). WOE describes the relationship between a predictive variable and a binary target variable.

The WOE/IV framework is based on the following relationship:

• logP(Y=1|Xj)P(Y=0|Xj) = logP(Y=1)P(Y=0) (sample log-odds) +log(Xj|Y=1)f(Xj|Y=0) (WOE)

• WOE = ln (% of non-merge/ % of merge)

After decoding each variable we can apply model and calculate probability

Probability linkage using model

As for now the logistic regression was chosen as a predicative method.

Logistic regression itself is a function:

Open

where  

is the intercept from the linear regression equation and

 is the regression coefficient multiplied by some value of the predictor.

As a result of model for each input pair will be calculated probability of merge/not merge events.

After that the threshold should be used to define which probability if satisfying to call the pair a duplicate.

From test sample suggestions for cut off are next:

• score >=0.9 - merge (as minimum score that should be saved to `merge candidates` and auto merged)

• score between 0.7 and 0.9 - manual merge  (as minimum score that should be merged manually)

• score < 0.7 - do not merge

Define master record and terminate declaration

As for now master_person_id is defined by updated_at. In other words the last record will be active and other will be merged into this one.

Make a record into merge_candidates:

Manual merge overview

For person_id in status 'NEW'  and score>=max_manul_score (0.9) from merge_candidates find declaration in status 'VERIFIED' and change status to 'TERMINATED' and change persons.id.status to INACTIVE

OPS kafka consumer should be used for the declaration termination. Declaration termination and person deactivation should be done at the same time.
Change merge_candidates.status from `NEW` to `MERGED`

Fetch record in status 'NEW'  and (0.8) min_manul_score < score < max_manul_score (0.9) from merge_candidates and write them into table manual_merge_candidates:

After that change merge_candidates.status from `NEW` to `MANUAL`

After decision reach more than decision_amount and final_decision is MERGE OPS kafka consumer should find declaration in status 'VERIFIED' and change status to 'TERMINATED'
and change persons.id.status to INACTIVE and 
Deactivate user:

1. search user by person_id, if exists (Mithril.users DB)

   1. set is_active = false

   2. set updated_at = now()

2. call expire_user_tokens function

Deactivate relationships:

1. Get relationships between two persons from confidant_person_relationships table where:

   • (person_id is equal to $.person_id

   • OR confidant_person_id is equal to $.person_id)

   • is_active = true

2. For each relationship from previous step set:

   • active_to = now()

   • updated_by = $.user_id

   • updated_at = now()

3. For each relationship from step 1 create new record:

4. Get all documents that prove relationships (confidant_person_relationship_documents DB)
   by confidant_person_relationship_id (from step #1)
   and duplicate them with new confidant_person_relationship_id (from step #3)  

Auto merge overview

After there was a decision to merge pair of persons do

1. Validate persons

   1. check if person or master_person exists in DB

   2. check persons `updated_at`, if (merge_candidate.person.inserted_at or merge_candidate.measter_person.inserted_at) < mpi.person.updated_at set status STALE to merge_candidates

2. Deactivate person

   1. search declaration for person_id, if exist

      1. create event to kafka

      2. set status DECLARATION_READY_DEACTIVATEto merge_candidates

   2. change person_id status to inactive

   3. add info to merged_pairs with person_id and master_person_id

   4. set status MERGED to merge_candidates

   5. add person status change info to event_manager

3. Deactivate user

   1. search user by person_id, if exists (Mithril.users DB)

      1. set user.is_active = false

      2. set updated_at = now()

   2. call expire_user_tokens function

4. Deactivate relationships

   1. Get relationships between two persons from confidant_person_relationships table where:

      • (person_id is equal to $.person_id

      • OR confidant_person_id is equal to $.person_id)

      • is_active = true

   2. For each relationship from previous step set:

      • is_active = false

      • updated_by = system_user()

      • updated_at = now()

   3. For each relationship from step 1 create new record:

Merge_candidates state diagram