PFM-4871: added the changes to persist sms in a table in mgramseva

egovernments · Oct 6, 2023 · f9818bc · f9818bc
1 parent 1ccdb4e
commit f9818bc
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 5 deletions.
diff --git a/...ov-notification-sms/src/main/java/org/egov/web/notification/sms/config/SMSProperties.java b/...ov-notification-sms/src/main/java/org/egov/web/notification/sms/config/SMSProperties.java
@@ -90,6 +90,9 @@ public class SMSProperties {
     @Value("${save.sms.entity.topic}")
     private String saveSmsTopic;
 
+    @Value("${save.sms.entity.enabled}")
+    private boolean isSaveSmsEnable;
+
     @Setter(AccessLevel.PROTECTED) private List<Pattern> whitelistPatterns;
     @Setter(AccessLevel.PROTECTED) private List<Pattern> blacklistPatterns;
 

diff --git a/...-notification-sms/src/main/java/org/egov/web/notification/sms/service/BaseSMSService.java b/...-notification-sms/src/main/java/org/egov/web/notification/sms/service/BaseSMSService.java
@@ -79,10 +79,12 @@ public void sendSMS(Sms sms) {
             return;
         }
         log.info("calling submitToExternalSmsService() method");
-        SmsSaveRequest smsSaveRequest = SmsSaveRequest.builder().mobileNumber(sms.getMobileNumber()).message(sms.getMessage())
-                .category(sms.getCategory()).templateId(sms.getTemplateId()).tenantId(sms.getTenantId()).createdtime(System.currentTimeMillis()).build();
-        log.info("SMS request to save sms topic" +smsSaveRequest );
-        producer.push(smsProperties.getSaveSmsTopic(), smsSaveRequest);
+        if(smsProperties.isSaveSmsEnable()) {
+            SmsSaveRequest smsSaveRequest = SmsSaveRequest.builder().mobileNumber(sms.getMobileNumber()).message(sms.getMessage())
+                    .category(sms.getCategory()).templateId(sms.getTemplateId()).tenantId(sms.getTenantId()).createdtime(System.currentTimeMillis()).build();
+            log.info("SMS request to save sms topic" + smsSaveRequest);
+            producer.push(smsProperties.getSaveSmsTopic(), smsSaveRequest);
+        }
         submitToExternalSmsService(sms);
     }
 

diff --git a/core-services/egov-notification-sms/src/main/resources/application.properties b/core-services/egov-notification-sms/src/main/resources/application.properties
@@ -90,4 +90,5 @@ spring.kafka.consumer.properties.spring.json.type.mapping=smsRequest:org.egov.we
 spring.kafka.listener.missing-topics-fatal=false
 
 #persister topic of sms
-save.sms.entity.topic = save-sms-entity-application
+save.sms.entity.topic = save-sms-entity-application
+save.sms.entity.enabled = true