Process skipped clients

opensrp-giz-malawi/src/main/AndroidManifest.xml

@@ -291,6 +291,7 @@
         <service android:name="org.smartregister.sync.intent.ExtendedSyncIntentService" />
         <service android:name="org.smartregister.sync.intent.SettingsSyncIntentService" />
         <service android:name="org.smartregister.sync.intent.SyncIntentService" />
+        <service android:name=".service.ReProcessSyncIntentService"/>
 
         <uses-library
             android:name="org.apache.http.legacy"

opensrp-giz-malawi/src/main/java/org/smartregister/giz/application/GizMalawiApplication.java

@@ -1,6 +1,7 @@
 package org.smartregister.giz.application;
 
 import android.content.Intent;
+import android.content.IntentFilter;
 import android.content.res.Configuration;
 import android.content.res.Resources;
 import android.text.TextUtils;
@@ -62,6 +63,7 @@
 import org.smartregister.giz.job.GizMalawiJobCreator;
 import org.smartregister.giz.processor.GizMalawiProcessorForJava;
 import org.smartregister.giz.processor.TripleResultProcessor;
+import org.smartregister.giz.recievers.SyncStatusReciever;
 import org.smartregister.giz.repository.ChildAlertUpdatedRepository;
 import org.smartregister.giz.repository.ClientRegisterTypeRepository;
 import org.smartregister.giz.repository.DailyTalliesRepository;
@@ -364,6 +366,8 @@ public void onCreate() {
         initOfflineSchedules();
 
         SyncStatusBroadcastReceiver.init(this);
+        this.registerReceiver(new SyncStatusReciever(),
+                new IntentFilter(SyncStatusBroadcastReceiver.ACTION_SYNC_STATUS));
         LocationHelper.init(GizUtils.ALLOWED_LEVELS, GizUtils.DEFAULT_LOCATION_LEVEL);
         jsonSpecHelper = new JsonSpecHelper(this);
 

opensrp-giz-malawi/src/main/java/org/smartregister/giz/job/GizMalawiJobCreator.java

@@ -54,6 +54,8 @@ public Job create(@NonNull String tag) {
                 return new GizVaccineUpdateJob();
             case ImageUploadServiceJob.TAG:
                 return new ImageUploadServiceJob();
+            case  GizReProcessJob.TAG:
+                return  new GizReProcessJob();
 
             default:
                 Timber.w(GizMalawiJobCreator.class.getCanonicalName(), "%s is not declared in Job Creator", tag);

opensrp-giz-malawi/src/main/java/org/smartregister/giz/job/GizReProcessJob.java

@@ -0,0 +1,27 @@
+package org.smartregister.giz.job;
+
+import android.content.Intent;
+
+import androidx.annotation.NonNull;
+
+import com.evernote.android.job.Job;
+
+import org.jetbrains.annotations.NotNull;
+import org.smartregister.AllConstants;
+import org.smartregister.giz.service.ReProcessSyncIntentService;
+import org.smartregister.job.BaseJob;
+
+public class GizReProcessJob extends BaseJob {
+
+    public static final String TAG = "GizReValidationJob";
+
+    @NonNull
+    @NotNull
+    @Override
+    protected Result onRunJob(@NonNull @NotNull Job.Params params) {
+        Intent intent = new Intent(getApplicationContext(), ReProcessSyncIntentService.class);
+        getApplicationContext().startService(intent);
+        return params != null && params.getExtras().getBoolean(AllConstants.INTENT_KEY.TO_RESCHEDULE, false) ? Result.RESCHEDULE : Result.SUCCESS;
+
+    }
+}

opensrp-giz-malawi/src/main/java/org/smartregister/giz/recievers/SyncStatusReciever.java

@@ -0,0 +1,40 @@
+package org.smartregister.giz.recievers;
+
+import android.content.BroadcastReceiver;
+import android.content.Context;
+import android.content.Intent;
+import android.os.Bundle;
+
+import org.smartregister.domain.FetchStatus;
+import org.smartregister.giz.job.GizReProcessJob;
+
+import java.io.Serializable;
+
+import timber.log.Timber;
+
+import static org.smartregister.receiver.SyncStatusBroadcastReceiver.EXTRA_FETCH_STATUS;
+
+public class SyncStatusReciever  extends BroadcastReceiver {
+    @Override
+    public void onReceive(Context context, Intent intent) {
+        Bundle data = intent.getExtras();
+        if (data != null) {
+            Serializable fetchStatusSerializable = data.getSerializable(EXTRA_FETCH_STATUS);
+            if (fetchStatusSerializable instanceof FetchStatus) {
+                FetchStatus fetchStatus = (FetchStatus) fetchStatusSerializable;
+                    if (fetchStatus.equals(FetchStatus.fetched)) {
+                        GizReProcessJob.scheduleJobImmediately(GizReProcessJob.TAG);
+                        Timber.d("Broadcast data fetched");
+                    } else if (fetchStatus.equals(FetchStatus.nothingFetched)) {
+                        Timber.d("Broadcast data not fetched");
+                    } else if (fetchStatus.equals(FetchStatus.noConnection)) {
+                        Timber.d("Broadcast data fetch failed");
+                    }
+
+                //}
+            }
+        }
+
+        System.out.println("Broadcast Recieved");
+    }
+}

opensrp-giz-malawi/src/main/java/org/smartregister/giz/repository/GizEventRepository.java

@@ -5,8 +5,12 @@
 import net.sqlcipher.Cursor;
 import net.sqlcipher.database.SQLiteDatabase;
 
+import org.smartregister.giz.util.GizUtils;
 import org.smartregister.repository.BaseRepository;
 
+import java.util.ArrayList;
+import java.util.List;
+
 public class GizEventRepository extends BaseRepository {
 
     public boolean hasEvent(@NonNull String baseEntityId, @NonNull String eventType) {
@@ -21,4 +25,37 @@ public boolean hasEvent(@NonNull String baseEntityId, @NonNull String eventType)
         }
         return hasEvent;
     }
+
+    public void ReprocessClients()
+    {
+        String missingClientRegister = "SELECT DISTINCT baseEntityId, formSubmissionId AS formSubmissionId FROM event WHERE baseEntityId IN (SELECT baseEntityId FROM client WHERE baseEntityId NOT IN (SELECT DISTINCT base_entity_id FROM client_register_type)) AND eventType LIKE '%Registration%'";
+        String missingECClient = "SELECT DISTINCT baseEntityId, formSubmissionId AS formSubmissionId FROM event WHERE baseEntityId IN (SELECT baseEntityId FROM client WHERE baseEntityId NOT IN (SELECT DISTINCT base_entity_id FROM ec_client)) AND eventType LIKE '%Registration%'";
+        List<String> formSubmissionIDs = new ArrayList<>();
+        addFormSubmissionIds(formSubmissionIDs, missingClientRegister);
+        addFormSubmissionIds(formSubmissionIDs,missingECClient);
+
+
+        try {
+            if(formSubmissionIDs.size()>0)
+            GizUtils.initiateEventProcessing(formSubmissionIDs);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+
+
+    public void addFormSubmissionIds(List<String> ids, String query)
+    {
+        SQLiteDatabase database = getReadableDatabase();
+        Cursor cursor = database.rawQuery(query, null);
+        int columnIndex = cursor.getColumnIndex("formSubmissionId");
+        if(cursor.getCount() >  0) {
+            cursor.moveToFirst();
+           do {
+                ids.add(cursor.getString(columnIndex));
+            } while (cursor.moveToNext());
+        }
+        cursor.close();
+    }
 }

opensrp-giz-malawi/src/main/java/org/smartregister/giz/service/ReProcessSyncIntentService.java

@@ -0,0 +1,27 @@
+package org.smartregister.giz.service;
+
+import android.app.IntentService;
+import android.content.Intent;
+
+import androidx.annotation.Nullable;
+
+import org.smartregister.giz.application.GizMalawiApplication;
+
+public class ReProcessSyncIntentService extends IntentService {
+
+    public static final String TAG = "ReValidateSyncIntentService";
+
+    public ReProcessSyncIntentService()
+    {
+        super(TAG);
+    }
+
+    public ReProcessSyncIntentService(String name) {
+        super(name);
+    }
+
+    @Override
+    protected void onHandleIntent(@Nullable Intent intent) {
+        GizMalawiApplication.getInstance().gizEventRepository().ReprocessClients();
+    }
+}