sync claims

Author: vaneck237

claimManagement/src/main/graphql/org.openimis.imisclaim/CreateClaim.graphql

@@ -0,0 +1,5 @@
+mutation CreateClaim($input: CreateClaimMutationInput!) {
+    createClaim(input: $input) {
+        clientMutationId
+    }
+}

claimManagement/src/main/graphql/org.openimis.imisclaim/GetAdminId.graphql

@@ -0,0 +1,11 @@
+query GetAdminId($code: String) {
+    claimAdmins(
+        code: $code
+    ) {
+        edges {
+            node {
+                id
+            }
+        }
+    }
+}

claimManagement/src/main/graphql/org.openimis.imisclaim/GetDiagnoseId.graphql

@@ -0,0 +1,11 @@
+query GetDiagnoseId($code: String) {
+    diagnoses(
+        code: $code
+    ) {
+        edges {
+            node {
+                id
+            }
+        }
+    }
+}

claimManagement/src/main/graphql/org.openimis.imisclaim/GetInsureeId.graphql

@@ -0,0 +1,11 @@
+query GetInsureeId($chfId: String) {
+    insurees(
+        chfId: $chfId
+    ) {
+        edges {
+            node {
+                id
+            }
+        }
+    }
+}

claimManagement/src/main/java/org/openimis/imisclaims/ClaimActivity.java

@@ -737,11 +737,13 @@ private boolean saveClaim() {
         selectedTypeButton = findViewById(SelectedId);
         String visitType = selectedTypeButton.getTag().toString();
 
-        int PatientConditionId;
-        PatientConditionId = rgPatientCondition.getCheckedRadioButtonId();
+        String patientCondition = "";
+        int PatientConditionId = rgPatientCondition.getCheckedRadioButtonId();
         RadioButton selectedPatientCondition;
         selectedPatientCondition = findViewById(PatientConditionId);
-        String patientCondition = selectedPatientCondition.getTag().toString();
+        if(selectedPatientCondition != null){
+            patientCondition = selectedPatientCondition.getTag().toString();
+        }
 
         ContentValues claimCV = new ContentValues();
 
@@ -786,8 +788,10 @@ private boolean saveClaim() {
         ArrayList<ContentValues> claimServiceCVs = new ArrayList<>(lvServiceList.size());
         for (int i = 0; i < lvServiceList.size(); i++) {
             ContentValues claimServiceCV = new ContentValues();
+            String serviceId = sqlHandler.getServiceId(lvServiceList.get(i).get("Code"));
 
             claimServiceCV.put("ClaimUUID", claimUUID);
+            claimServiceCV.put("ServiceId", serviceId);
             claimServiceCV.put("ServiceCode", lvServiceList.get(i).get("Code"));
             claimServiceCV.put("ServicePrice", lvServiceList.get(i).get("Price"));
             claimServiceCV.put("ServiceQuantity", lvServiceList.get(i).get("Quantity"));

claimManagement/src/main/java/org/openimis/imisclaims/SQLHandler.java

@@ -42,7 +42,7 @@ public class SQLHandler extends SQLiteOpenHelper {
     private static final String CreateTableReferences = "CREATE TABLE IF NOT EXISTS tblReferences(Code TEXT, Name TEXT, Type TEXT, Price TEXT);";
     private static final String createTableClaimDetails = "CREATE TABLE IF NOT EXISTS tblClaimDetails(ClaimUUID TEXT, ClaimDate TEXT, HFCode TEXT, ClaimAdmin TEXT, ClaimCode TEXT, GuaranteeNumber TEXT, InsureeNumber TEXT, StartDate TEXT, EndDate TEXT, ICDCode TEXT, Comment TEXT, Total TEXT, ICDCode1 TEXT, ICDCode2 TEXT, ICDCode3 TEXT, ICDCode4 TEXT, VisitType TEXT, ReferalHF TEXT, PatientCondition TEXT,PreAuthorization Int );";
     private static final String createTableClaimItems = "CREATE TABLE IF NOT EXISTS tblClaimItems(ClaimUUID TEXT, ItemCode TEXT, ItemPrice TEXT, ItemQuantity TEXT);";
-    private static final String createTableClaimServices = "CREATE TABLE IF NOT EXISTS tblClaimServices(ClaimUUID TEXT, ServiceCode TEXT, ServicePrice TEXT, ServiceQuantity TEXT, ServicePackageType TEXT, SubServicesItems TEXT);";
+    private static final String createTableClaimServices = "CREATE TABLE IF NOT EXISTS tblClaimServices(ClaimUUID TEXT,ServiceId TEXT, ServiceCode TEXT, ServicePrice TEXT, ServiceQuantity TEXT, ServicePackageType TEXT, SubServicesItems TEXT);";
     private static final String createTableClaimUploadStatus = "CREATE TABLE IF NOT EXISTS tblClaimUploadStatus(ClaimUUID TEXT, UploadDate TEXT, UploadStatus TEXT, UploadMessage TEXT);";
     private static final String CreateTableServices = "CREATE TABLE IF NOT EXISTS tblServices(Id text, Code text, Name text, Type text, Price text, PackageType text);";
     private static final String CreateTableItems = "CREATE TABLE IF NOT EXISTS tblItems(Id text, Code text, Name text, Type text, Price text);";
@@ -510,7 +510,7 @@ public JSONArray getClaimItems(String claimUUID) {
     public JSONArray getClaimServices(String claimUUID) {
         return getQueryResultAsJsonArray(
                 "tblClaimServices",
-                new String[]{"ServiceCode", "ServicePrice", "ServiceQuantity","ServicePackageType","SubServicesItems"},
+                new String[]{"ServiceId", "ServiceCode", "ServicePrice", "ServiceQuantity","ServicePackageType","SubServicesItems"},
                 "ClaimUUID = ?",
                 new String[]{claimUUID}
         );
@@ -912,4 +912,20 @@ public void InsertHealthFacilities(String Id, String Code, String Name) {
             e.printStackTrace();
         }
     }
+
+    public String getHfId(String code) {
+        String id = "";
+        try (Cursor c = db.query("tblHealthFacilities", new String[]{"Id"}, "LOWER(Code) = LOWER(?)", new String[]{code}, null, null, null, "1")) {
+            c.moveToFirst();
+            if (!c.isAfterLast()) {
+                String result = c.getString(0);
+                if (!TextUtils.isEmpty(result)) {
+                    id = result;
+                }
+            }
+        } catch (SQLException e) {
+            Log.d("ErrorOnFetchingData", String.format("Error while getting price of %s", code), e);
+        }
+        return id;
+    }
 }

claimManagement/src/main/java/org/openimis/imisclaims/SynchronizeService.java

@@ -12,12 +12,16 @@
 import org.json.JSONArray;
 import org.json.JSONException;
 import org.json.JSONObject;
+import org.openimis.imisclaims.domain.entity.Claim;
 import org.openimis.imisclaims.domain.entity.PendingClaim;
+import org.openimis.imisclaims.domain.entity.PendingClaimGQL;
 import org.openimis.imisclaims.tools.Log;
 import org.openimis.imisclaims.tools.StorageManager;
+import org.openimis.imisclaims.usecase.CreateClaims;
 import org.openimis.imisclaims.usecase.PostNewClaims;
 import org.openimis.imisclaims.util.DateUtils;
 import org.openimis.imisclaims.util.FileUtils;
+import org.openimis.imisclaims.util.JsonUtils;
 import org.openimis.imisclaims.util.XmlUtils;
 import org.openimis.imisclaims.util.ZipUtils;
 import org.xmlpull.v1.XmlSerializer;
@@ -30,6 +34,7 @@
 import java.util.Date;
 import java.util.List;
 import java.util.Locale;
+import java.util.Objects;
 
 public class SynchronizeService extends JobIntentService {
     private static final int JOB_ID = 6541259; //Random unique Job id
@@ -109,7 +114,10 @@ private void handleUploadClaims() {
         }
 
         try {
-            List<PostNewClaims.Result> results = new PostNewClaims().execute(PendingClaim.fromJson(claims));
+            String hfCode = sqlHandler.getClaimAdminInfo(global.getOfficerCode(),"HFCode");
+            String hfId = sqlHandler.getHfId(hfCode);
+            //List<PostNewClaims.Result> results = new PostNewClaims().execute(PendingClaim.fromJson(claims));
+            List<PostNewClaims.Result> results = new CreateClaims().execute(PendingClaimGQL.fromJson(claims), Integer.parseInt(hfId));
             JSONArray claimStatus = processClaimResponse(results);
             broadcastSyncSuccess(claimStatus);
         } catch (Exception e) {