From cd83793f48123d24aa11bf119434ca5cb6ed7329 Mon Sep 17 00:00:00 2001
From: Surabhi Suman <surabhisuman1509@gmail.com>
Date: Sat, 27 May 2023 22:10:09 +0530
Subject: [PATCH] chore: added claim status update and data update to central
 DB

---
 .idea/workspace.xml                           | 20 ++++--
 .irb_history                                  |  3 +
 .../health_care_provider_controller.rb        |  2 +-
 app/helpers/central_entity_helper.rb          | 14 ++--
 app/helpers/insurance_helper.rb               | 27 ++++---
 app/models/health_report.rb                   |  1 +
 app/services/fraud_detection_service.rb       | 72 +++++++++++++++++++
 config/application.rb                         |  1 +
 8 files changed, 121 insertions(+), 19 deletions(-)
 create mode 100644 .irb_history
 create mode 100644 app/services/fraud_detection_service.rb

diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index e95b257..3511233 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -3,11 +3,13 @@
   <component name="ChangeListManager">
     <list default="true" id="512346dc-051b-4a1f-8623-a2777c16bbfe" name="Changes" comment="">
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/app/controllers/health_care_provider_controller.rb" beforeDir="false" afterPath="$PROJECT_DIR$/app/controllers/health_care_provider_controller.rb" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/app/helpers/central_entity_helper.rb" beforeDir="false" afterPath="$PROJECT_DIR$/app/helpers/central_entity_helper.rb" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/app/helpers/insurance_helper.rb" beforeDir="false" afterPath="$PROJECT_DIR$/app/helpers/insurance_helper.rb" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/app/helpers/notification_helper.rb" beforeDir="false" afterPath="$PROJECT_DIR$/app/helpers/notification_helper.rb" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/app/models/invoice.rb" beforeDir="false" afterPath="$PROJECT_DIR$/app/models/invoice.rb" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/app/models/prescription.rb" beforeDir="false" afterPath="$PROJECT_DIR$/app/models/prescription.rb" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/db/seeds.rb" beforeDir="false" afterPath="$PROJECT_DIR$/db/seeds.rb" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/app/models/health_report.rb" beforeDir="false" afterPath="$PROJECT_DIR$/app/models/health_report.rb" afterDir="false" />
+    </list>
+    <list id="5ad25485-6d63-457f-870c-89d1472551ca" name="Changes by abhishek" comment="">
+      <change beforePath="$PROJECT_DIR$/config/application.rb" beforeDir="false" afterPath="$PROJECT_DIR$/config/application.rb" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -160,7 +162,7 @@
       <option name="number" value="Default" />
       <option name="presentableId" value="Default" />
       <updated>1685174401090</updated>
-      <workItem from="1685174402295" duration="22478000" />
+      <workItem from="1685174402295" duration="24313000" />
     </task>
     <servers />
   </component>
@@ -189,6 +191,14 @@
           </properties>
           <option name="timeStamp" value="6" />
         </line-breakpoint>
+        <line-breakpoint enabled="true" type="ruby-line">
+          <url>file://$PROJECT_DIR$/app/controllers/health_care_provider_controller.rb</url>
+          <line>29</line>
+          <properties myBlockOrdinal="-1">
+            <option name="block-ordinal" value="-1" />
+          </properties>
+          <option name="timeStamp" value="8" />
+        </line-breakpoint>
       </breakpoints>
     </breakpoint-manager>
   </component>
diff --git a/.irb_history b/.irb_history
new file mode 100644
index 0000000..bc663ef
--- /dev/null
+++ b/.irb_history
@@ -0,0 +1,3 @@
+IRB
+IRB.conf
+ls
diff --git a/app/controllers/health_care_provider_controller.rb b/app/controllers/health_care_provider_controller.rb
index 354b557..0b4509e 100644
--- a/app/controllers/health_care_provider_controller.rb
+++ b/app/controllers/health_care_provider_controller.rb
@@ -30,7 +30,7 @@ def update_docs_and_send_claim_request
     claim_id = params[:claim_id]
     amount = params[:claims_amount]
     claim_type = params[:claim_type]
-    CentralEntityHelper.add_data_to_health_record(params[:prescriptions], params[:invoices], params[:person_id])
+    CentralEntityHelper.add_data_to_health_record(params[:prescriptions], params[:invoices], null, params[:person_id])
     resp = InsuranceHelper.send_claim_request(claim_id, amount, claim_type)
     render json: resp
   rescue StandardError => e
diff --git a/app/helpers/central_entity_helper.rb b/app/helpers/central_entity_helper.rb
index d2b8019..b118c06 100644
--- a/app/helpers/central_entity_helper.rb
+++ b/app/helpers/central_entity_helper.rb
@@ -17,13 +17,19 @@ def get_eligibility(claim_amount, claim_type, customer_id)
       # particular claim_type is under covers
     end
 
-    def add_data_to_health_record(new_prescriptions, new_invoices, customer_id)
+    def add_data_to_health_record(new_prescriptions, new_invoices, new_claims, customer_id)
       health_report = HealthReport.find_by_person_id(customer_id)
       invoices = health_report.invoices
-      invoices.add(new_invoices)
       prescriptions = health_report.prescriptions
-      prescriptions.add(new_prescriptions)
-      health_report.update(invoices: invoices, prescriptions: prescriptions)
+      new_invoices.each do |ninv|
+        invoices.add(Invoice.create(amount: ninv[:amount], health_report: health_report))
+      end
+      new_prescriptions.each do |npr|
+        prescriptions.add(Prescription.create(medicines: npr[:medicines], lab_tests: npr[:lab_tests], health_report: health_report))
+      end
+      claims = health_report.claims
+      claims.add(new_claims)
+      health_report.update(invoices: invoices, prescriptions: prescriptions, claims: claims)
     end
 
   end
diff --git a/app/helpers/insurance_helper.rb b/app/helpers/insurance_helper.rb
index cc45afa..e36531f 100644
--- a/app/helpers/insurance_helper.rb
+++ b/app/helpers/insurance_helper.rb
@@ -13,7 +13,7 @@ def process_pre_auth(amount, claim_type, requester_id, customer_id)
         eligibility = CentralEntityHelper.get_eligibility(amount, claim_type, customer_id).with_indifferent_access
         eligible_policy_id = eligibility[:eligible_policy_id]
         claim = Claim.create(status: "pre-auth-approved", person_id: customer_id, insurance_policy_id: eligible_policy_id)
-        return { "success": true, "claim_id": claim.id, msg: "Pre auth claim registered successfully" }
+        return { "success": true, "claim_id": claim.id, "customer_id": customer_id, msg: "Pre auth claim registered successfully" }
       else
         NotificationHelper.send_notification(requester_id, customer_id, "Pre Auth Request")
         # send notification
@@ -37,15 +37,24 @@ def send_claim_request(claim_id, amount, claim_type)
       end
       eligibility = CentralEntityHelper.get_eligibility(amount, claim_type, claim.person_id)
       if eligibility[:is_eligible]
-        claim.update(status: "processing")
-        #todo: call fraud api
-      else
-        new_status = "rejected"
-        ClaimStatusHistory.create(transition_from: claim.status, transition_to: new_status, claim_id: claim.id)
-        claim.update(status: new_status)
-        # todo: create notif & notify customer
+        updateClaimStatus("processing", claim)
+        is_fraud = false # todo: replace with gpt call
+        unless is_fraud
+          updateClaimStatus("approved", claim)
+          CentralEntityHelper.add_data_to_health_record([], [], [claim], claim.person_id)
+          # NotificationHelper.send_notification(claim.insurance_policy.)
+          return
+        end
       end
-      #todo: update claim and max coverage to central DB too
+      self.updateClaimStatus("rejected", claim)
+      # todo: create notif & notify customer
+    end
+
+    private
+
+    def updateClaimStatus(new_status, claim)
+      ClaimStatusHistory.create(transition_from: claim.status, transition_to: new_status, claim_id: claim.id)
+      claim.update(status: new_status)
     end
   end
 end
\ No newline at end of file
diff --git a/app/models/health_report.rb b/app/models/health_report.rb
index 3da7eba..b2d0d2a 100644
--- a/app/models/health_report.rb
+++ b/app/models/health_report.rb
@@ -2,5 +2,6 @@ class HealthReport < ApplicationRecord
   has_many :invoices
   has_many :insurance_policies
   has_many :prescriptions
+  has_many :claims
   belongs_to :person
 end
diff --git a/app/services/fraud_detection_service.rb b/app/services/fraud_detection_service.rb
new file mode 100644
index 0000000..6286dc3
--- /dev/null
+++ b/app/services/fraud_detection_service.rb
@@ -0,0 +1,72 @@
+class FraudDetectionService
+  # TODO: add env variable
+  @@client = OpenAI::Client.new(access_token: ENV.fetch("OPEN_AI_TOKEN"))
+
+  MODEL = "gpt-3.5-turbo"
+
+  PREFIX = "
+Below is a Patient Insurance Claim History, Patient Medical History, Doctor-Patient Transcript, Doctor's Prescription it starts with <PatientMedicalHistory> and ends with </PatientMedicalHistory>
+"
+
+  INSTRUCTION = "
+Based on the Patient Insurance Claim History, Patient Medical History, Doctor-Patient Transcript, Doctor's Prescription provided below, generate a fraud detection response in JSON format:
+{
+  \"approved\": <Yes/No>,
+  \"confidence\": (0,1),
+  \"explanation\": <string>
+}
+"
+
+  TEXT = "
+<PatientMedicalHistory>
+%{medical_history}
+</PatientMedicalHistory>
+"
+
+  def self.detect(medical_history)
+    result = {
+      success: false,
+      approved: nil,
+      confidence: nil,
+      summary: nil,
+      error_message: ""
+    }
+
+    prompt = (PREFIX + "\n" + TEXT + "\n" + INSTRUCTION) % {medical_history: medical_history}
+
+    response = @@client.chat(
+      parameters: {
+        model: MODEL,
+        messages: [{ role: "user", content: prompt}],
+        temperature: 0.7
+      })
+
+    if response.dig("error", "message")
+      result[:error_message] = response.dig("error", "message")
+      return result
+    end
+
+    response_text = response.dig("choices", 0, "message", "content")
+    begin
+      parsed_response = JSON.parse(response_text)
+    rescue StandardError => e
+      puts("ChatGPT Error:", e.message)
+      parsed_response = {}
+    end
+
+    result[:approved] = parsed_response["approved"]
+    result[:confidence] = parsed_response["confidence"]
+    result[:summary] = parsed_response["explanation"]
+
+    result[:success] = !(result[:approved].nil? || result[:confidence].nil? || result[:summary].nil?)
+    return result
+
+    # binding.pry
+    # split_response = response_text.split("\n")
+    # result[:approved] = split_response.second if split_response.first.downcase == "approved:" && split_response.second.to_s.downcase.in?(["yes", "no"])
+    # result[:confidence] = split_response.fourth.to_f if split_response.third.downcase == "confidence:" && split_response.fourth.to_s.to_f.to_s == split_response.fourth
+    # result[:summary] = split_response.last if split_response.fifth.downcase == "explanation:" && split_response.last.to_s == split_response.last
+    # result[:success] = !(result[:approved].nil? || result[:confidence].nil? || result[:summary].nil?)
+    # return result
+  end
+end
\ No newline at end of file
diff --git a/config/application.rb b/config/application.rb
index 9430160..1ea0c29 100644
--- a/config/application.rb
+++ b/config/application.rb
@@ -23,5 +23,6 @@ class Application < Rails::Application
     # Middleware like session, flash, cookies can be added back manually.
     # Skip views, helpers and assets when generating a new resource.
     config.api_only = true
+    config.autoload_paths << "#{Rails.root}/app/services"
   end
 end