Add Veh2Num, Ration Card, BGMI, GitHub, and YouTube endpoints to Space API

external_services.py

@@ -420,6 +420,27 @@ LPG_REGION_DIRECTORY = {
     }
 }
 
+STATE_LPG_PRICING = {
+    "Bihar": 892.00,
+    "Delhi": 803.00,
+    "Uttar Pradesh": 840.50,
+    "Rajasthan": 806.50,
+    "West Bengal": 829.00,
+    "Maharashtra": 802.50,
+    "Tamil Nadu": 818.50,
+    "Gujarat": 810.00,
+    "Madhya Pradesh": 808.50,
+    "Telangana": 855.00,
+    "Karnataka": 805.50,
+    "Punjab": 812.00,
+    "Kerala": 810.00,
+    "Haryana": 805.00,
+    "Odisha": 830.00,
+    "Jharkhand": 860.00,
+    "Assam": 852.00,
+    "Andhra Pradesh": 835.00,
+}
+
 class LpgDirectEngine:
     """
     Direct LPG Consumer Intelligence Gateway.
@@ -473,18 +494,17 @@ class LpgDirectEngine:
                 primary_omc_key = "hp"
 
         omc_info = LPG_OMC_PROVIDERS[primary_omc_key]
-        dist_code = region["dist_code"]
         consumer_no = clean[-6:] if len(clean) >= 6 else "381920"
-        
-        # Standard 17-digit PAHAL ID: OMC (1 digit) + DistCode (6 digits) + ConsumerNo (10 digits)
-        standard_lpg_id = clean if is_lpg_id else f"{omc_info['omc_code']}{dist_code}{consumer_no.zfill(10)}"
 
         # Personal details resolution (A to Z)
-        consumer_name = "Registered LPG Consumer"
-        father_name = "Registered Guardian"
-        masked_aadhaar = "XXXXXXXX4053"
+        consumer_name = None
+        father_name = None
+        masked_aadhaar = None
         raw_addr = ""
         user_pincode = region["pincode"]
+        user_state = region["state"]
+        user_district = region["district"]
+        user_hub = region["hub"]
 
         if user_kyc and isinstance(user_kyc, dict):
             if user_kyc.get("name"):
@@ -498,21 +518,55 @@ class LpgDirectEngine:
                 else:
                     masked_aadhaar = clean_uid
             if user_kyc.get("address"):
-                raw_addr = self.clean_address(str(user_kyc["address"]))
+                addr_str = str(user_kyc["address"]).strip()
+                parts = [p.strip() for p in addr_str.split('!') if p.strip()]
+                raw_addr = ", ".join(parts)
+                pin_m = re.search(r'\b[1-9][0-9]{5}\b', addr_str)
+                if pin_m:
+                    user_pincode = pin_m.group(0)
+                for st_name in STATE_LPG_PRICING.keys():
+                    if st_name.lower() in addr_str.lower():
+                        user_state = st_name
+                        break
+                if len(parts) >= 3:
+                    if parts[-1].isdigit():
+                        user_district = parts[-3].strip().title()
+                        user_hub = parts[-4].strip().title() if len(parts) >= 4 else user_district
+                    else:
+                        user_district = parts[-2].strip().title()
+                        user_hub = parts[-3].strip().title() if len(parts) >= 3 else user_district
             if user_kyc.get("pincode"):
                 user_pincode = str(user_kyc["pincode"]).strip()
-        else:
-            consumer_name = f"Registered Consumer ({region['hub']})"
-            father_name = f"Authorized Head ({region['district']})"
+            if user_kyc.get("district"):
+                user_district = str(user_kyc["district"]).strip().title()
+            if user_kyc.get("state"):
+                user_state = str(user_kyc["state"]).strip().title()
 
-        formatted_address = raw_addr or f"{region['hub']}, Near Post Office, {region['city']}, {region['district']}, {region['state']} - {user_pincode}"
-        agency_name = f"{region['hub'].upper()} {omc_info['default_agency_prefix']}"
+        if not consumer_name and not is_lpg_id:
+            return {
+                "status": "not_found",
+                "owner": OWNER_TAG,
+                "message": f"No active LPG gas connection or verified KYC record found for mobile '{clean}' in OMC registry."
+            }
+
+        if not consumer_name:
+            consumer_name = f"Consumer Account #{consumer_no}"
+            father_name = "Authorized Primary Signatory"
+
+        refill_price_val = STATE_LPG_PRICING.get(user_state, region["subsidized_price"])
+        dist_code = user_pincode if (user_pincode and len(user_pincode) == 6) else region["dist_code"]
+        agency_prefix = omc_info['default_agency_prefix']
+        agency_name = f"{user_district.upper()} {agency_prefix}"
+        formatted_address = raw_addr or f"{user_hub}, Near Post Office, {user_district}, {user_state} - {user_pincode}"
+
+        # Standard 17-digit PAHAL ID: OMC (1 digit) + DistCode (6 digits) + ConsumerNo (10 digits)
+        standard_lpg_id = clean if is_lpg_id else f"{omc_info['omc_code']}{dist_code}{consumer_no.zfill(10)}"
 
         # Generate connections for all 3 gas providers (Indane, Bharat Gas, HP Gas)
         all_omc_connections = {}
         for k, v in LPG_OMC_PROVIDERS.items():
             lpg_id_omc = f"{v['omc_code']}{dist_code}{consumer_no.zfill(10)}"
-            prov_agency_name = f"{region['hub'].upper()} {v['default_agency_prefix']}"
+            prov_agency_name = f"{user_district.upper()} {v['default_agency_prefix']}"
             all_omc_connections[k] = {
                 "consumer_name": consumer_name,
                 "provider_name": v["brand"],
@@ -523,7 +577,7 @@ class LpgDirectEngine:
                 "agency_name": prov_agency_name,
                 "agency_code": dist_code,
                 "agency_contact": v["ivrs_booking"],
-                "refill_price": f"₹{region['subsidized_price']:.2f}",
+                "refill_price": f"₹{refill_price_val:.2f}",
                 "whatsapp_booking": v["whatsapp_booking"],
                 "ivrs_booking": v["ivrs_booking"]
             }
@@ -544,16 +598,16 @@ class LpgDirectEngine:
             "omc_code": omc_info["omc_code"],
             "connection_status": "Active (KYC Compliant & Sanctioned)",
             "cylinder_type": "14.2 kg Domestic Subsidized Refill",
-            "current_refill_price": f"₹{region['subsidized_price']:.2f}",
+            "current_refill_price": f"₹{refill_price_val:.2f}",
             "commercial_19kg_price": f"₹{region['commercial_19kg_price']:.2f}",
             "delivery_address": formatted_address,
-            "district": region["district"],
-            "state": region["state"],
+            "district": user_district,
+            "state": user_state,
             "pincode": user_pincode,
             "distributor_agency": agency_name,
             "distributor_code": dist_code,
             "subsidy_status": "Active (Direct Benefit Transfer - DBTL PAHAL)",
-            "aadhaar_seeding": "Yes (UIDAI & NPCI Linked)",
+            "aadhaar_seeding": "Yes (UIDAI & NPCI Linked)" if masked_aadhaar else "Pending Seeding",
             "bank_linkage": "Active (APBS Direct Account Credit)",
             "booking_whatsapp": omc_info["whatsapp_booking"],
             "booking_ivrs": omc_info["ivrs_booking"],
@@ -561,9 +615,9 @@ class LpgDirectEngine:
             "agency_details": {
                 "agency_name": agency_name,
                 "distributor_code": dist_code,
-                "service_hub": region["hub"],
-                "district": region["district"],
-                "state": region["state"],
+                "service_hub": user_hub,
+                "district": user_district,
+                "state": user_state,
                 "pincode": user_pincode,
                 "ivrs_booking_helpline": omc_info["ivrs_booking"],
                 "whatsapp_booking": omc_info["whatsapp_booking"],
@@ -571,7 +625,7 @@ class LpgDirectEngine:
             },
             "subsidy_bank_linkage": {
                 "dbtl_pahal_enrolled": "Yes (Active)",
-                "aadhaar_seeded": "Yes (UIDAI Linked)",
+                "aadhaar_seeded": "Yes (UIDAI Linked)" if masked_aadhaar else "Pending",
                 "subsidy_entitlement": "Subsidized (Direct Benefit Transfer)",
                 "bank_linkage_status": "Active"
             },
@@ -581,6 +635,7 @@ class LpgDirectEngine:
         }
         return res
 
+
 LPG_DIRECT = LpgDirectEngine()
 
 

main.py

@@ -568,6 +568,7 @@ async def lookup_lpg_gas(
     query: Optional[str] = None,
     num: Optional[str] = Query(None, description="10-digit mobile number or 17-digit LPG ID"),
     phone: Optional[str] = Query(None),
+    lpg_id: Optional[str] = Query(None),
     consumer_no: Optional[str] = Query(None),
     provider: Optional[str] = Query(None, description="Gas provider: 'indane', 'bharat', or 'hp'"),
     q: Optional[str] = Query(None),
@@ -596,8 +597,9 @@ async def lookup_lpg_gas(
     user_kyc = None
     if len(clean_digits) == 10:
         try:
-            phone_res = get_engine().query_by_phone(clean_digits)
-            if isinstance(phone_res, dict) and phone_res.get("status") == "success":
+            eng = get_engine()
+            phone_res = eng.query_by_phone(clean_digits)
+            if isinstance(phone_res, dict):
                 records = phone_res.get("records", [])
                 if records and isinstance(records, list) and len(records) > 0:
                     rec = records[0]
@@ -607,10 +609,31 @@ async def lookup_lpg_gas(
                         "phoneNumber": rec.get("phoneNumber") or clean_digits,
                         "aadharNumber": rec.get("aadharNumber") or rec.get("aadhaar"),
                         "address": rec.get("address"),
-                        "pincode": rec.get("pincode") or rec.get("pinCode")
+                        "pincode": rec.get("pincode") or rec.get("pinCode"),
+                        "district": rec.get("district"),
+                        "state": rec.get("state")
                     }
+
+            if not user_kyc or not user_kyc.get("name"):
+                comb_res = eng.query_combined(clean_digits)
+                if isinstance(comb_res, dict):
+                    summary = comb_res.get("consolidated_summary", {})
+                    p_name = summary.get("primary_name")
+                    if not p_name and summary.get("names_found"):
+                        p_name = summary["names_found"][0]
+                    locs = summary.get("locations_identified", [])
+                    loc = locs[0] if locs else ""
+                    if p_name:
+                        user_kyc = {
+                            "name": p_name,
+                            "fathersName": None,
+                            "phoneNumber": clean_digits,
+                            "aadharNumber": None,
+                            "address": loc,
+                            "pincode": None
+                        }
         except Exception as e:
-            logger.debug(f"Gas consumer KYC resolution: {e}")
+            logger.error(f"Gas consumer KYC resolution: {e}")
 
     res = ServiceGateway.get_lpg(target, provider=auto_prov, user_kyc=user_kyc)
     if isinstance(res, dict):