diff --git a/pom.xml b/pom.xml
index a9499b7..84eb159 100644
--- a/pom.xml
+++ b/pom.xml
@@ -5,7 +5,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>com.iemr.common.identity</groupId>
 	<artifactId>identity-api</artifactId>
-	<version>3.4.0</version>
+	<version>3.6.0</version>
 
 	<packaging>war</packaging>
 
diff --git a/src/main/java/com/iemr/common/identity/domain/User.java b/src/main/java/com/iemr/common/identity/domain/User.java
index cf0f505..916709f 100644
--- a/src/main/java/com/iemr/common/identity/domain/User.java
+++ b/src/main/java/com/iemr/common/identity/domain/User.java
@@ -15,8 +15,7 @@
 import jakarta.persistence.Table;
 import lombok.Data;
 @Entity
-@Table(name = "m_User")
-@JsonIgnoreProperties(ignoreUnknown = true)
+@Table(name = "m_User",schema = "db_iemr")
 @Data
 public class User {
 	@Id
diff --git a/src/main/java/com/iemr/common/identity/service/IdentityService.java b/src/main/java/com/iemr/common/identity/service/IdentityService.java
index aa91598..029b60a 100644
--- a/src/main/java/com/iemr/common/identity/service/IdentityService.java
+++ b/src/main/java/com/iemr/common/identity/service/IdentityService.java
@@ -1130,6 +1130,37 @@ public BeneficiaryCreateResp createIdentity(IdentityDTO identity) {
 
 		logger.info("IdentityService.createIdentity - saving Contacts");
 		MBeneficiarycontact mContc = identityDTOToMBeneficiarycontact(identity);
+
+		 if (mContc.getEmergencyContactNum() != null) {
+        mContc.setEmergencyContactNum(cleanPhoneNumber(mContc.getEmergencyContactNum()));
+    }
+    
+    if (mContc.getPhoneNum1() != null) {
+        mContc.setPhoneNum1(cleanPhoneNumber(mContc.getPhoneNum1()));
+    }
+    
+    if (mContc.getPhoneNum2() != null) {
+        mContc.setPhoneNum2(cleanPhoneNumber(mContc.getPhoneNum2()));
+    }
+      if (mContc.getPhoneNum3() != null) {
+        mContc.setPhoneNum3(cleanPhoneNumber(mContc.getPhoneNum3()));
+    }
+    
+    if (mContc.getPhoneNum4() != null) {
+        mContc.setPhoneNum4(cleanPhoneNumber(mContc.getPhoneNum4()));
+    }
+      if (mContc.getPhoneNum5() != null) {
+        mContc.setPhoneNum5(cleanPhoneNumber(mContc.getPhoneNum5()));
+    }
+        if (mContc.getPreferredSMSPhoneNum() != null) {
+        mContc.setPreferredSMSPhoneNum(cleanPhoneNumber(mContc.getPreferredSMSPhoneNum()));
+    }    if (mContc.getPreferredPhoneNum() != null) {
+        mContc.setPreferredPhoneNum(cleanPhoneNumber(mContc.getPreferredPhoneNum()));
+    }
+  
+
+
+		
 		// MBeneficiarycontact mContc =
 		// mapper.identityDTOToMBeneficiarycontact(identity);
 		if (mContc.getCreatedDate() == null) {
@@ -1302,7 +1333,22 @@ public BeneficiaryCreateResp createIdentity(IdentityDTO identity) {
 		logger.info("IdentityService.createIdentity - end. id = " + benMapping.getBenMapId());
 		return partialMapper.mBeneficiarymappingToBeneficiaryCreateResp(benMapping);
 	}
-
+private String cleanPhoneNumber(String phoneNumber) {
+    if (phoneNumber == null || phoneNumber.trim().isEmpty()) {
+        return phoneNumber;
+    }
+    
+    // Remove +91 prefix
+    String cleaned = phoneNumber.trim();
+    if (cleaned.startsWith("+91")) {
+        cleaned = cleaned.substring(3);
+    } else if (cleaned.startsWith("91") && cleaned.length() == 12) {
+        // Handle case where + is already removed but 91 remains
+        cleaned = cleaned.substring(2);
+    }
+    
+    return cleaned.trim();
+}
 	private MBeneficiarydetail convertIdentityDTOToMBeneficiarydetail(IdentityDTO dto) {
 		MBeneficiarydetail beneficiarydetail = new MBeneficiarydetail();
 		beneficiarydetail.setAreaId(dto.getAreaId());