Page Comparison

CREATE TABLE eg_bt_registration(
 id character varying(64),
 tenantId character varying(64),
 babyFirstNameapplicationNumber character varying(64),
 applicationNumberbabyFirstName character varying(64),
 babyLastName character varying(64),
 motherNamefatherName character varying(64),
 fatherNamemotherName character varying(64),
 doctorAttendingBirthdoctorName character varying(64),
 hospitalName character varying(64),
 placeOfBirth character varying(64),
 dateOfBirth bigint,
 createdTime bigint,
 lastModifiedTime bigint,
 CONSTRAINT uk_eg_tlbt_TradeLicenseregistration UNIQUE (id)
);
CREATE TABLE eg_bt_address(
   id character varying(64),
   tenantId character varying(64),
   doorNo character varying(64),
   latitude FLOAT,
   longitude FLOAT,
   buildingName character varying(64),
   addressId character varying(64),
   addressNumber character varying(64),
   type character varying(64),
   addressLine1 character varying(256),
   addressLine2 character varying(256),
   landmark character varying(64),
   street character varying(64),
   city character varying(64),
   locality character varying(64),
   pincode character varying(64),
   detail character varying(64),
   registrationId character varying(64),
   createdBy character varying(64),
   lastModifiedBy character varying(64),
   createdTime bigint,
   lastModifiedTime bigint,
   CONSTRAINT uk_eg_tlbt_address PRIMARY KEY (id),
   CONSTRAINT fk_eg_tlbt_address FOREIGN KEY (registrationId) REFERENCES eg_bt_registration (id)
     ON UPDATE CASCADE
     ON DELETE CASCADE
);

@Getter
@Setter@Component
@Data
@Import({TracerConfiguration.class})
@NoArgsConstructor
@AllArgsConstructor
@NoArgsConstructor@Setter
@Builder@Getter
public class Applicant  BTRConfiguration {
        @JsonProperty@Value("id${app.timezone}")
 
      private String timeZone;
id
= null;   @PostConstruct
    public void @JsonPropertyinitialize("babyFirstName") {
        private String babyFirstName = null; TimeZone.setDefault(TimeZone.getTimeZone(timeZone));
    }

    @Bean
    @Autowired
    public MappingJackson2HttpMessageConverter @JsonProperty("babyLastName"jacksonConverter(ObjectMapper objectMapper) {
       private StringMappingJackson2HttpMessageConverter babyLastNameconverter = new nullMappingJackson2HttpMessageConverter();
        converter.setObjectMapper(objectMapper);
        @JsonProperty("password")
return converter;
       private}
String
password = null;  // User Config
     @JsonProperty@Value("salutation${egov.user.host}")
        private String salutation = nulluserHost;

        @JsonProperty("gender")
  @Value("${egov.user.context.path}")
     private String genderuserContextPath;
=
null;    @Value("${egov.user.create.path}")
     @JsonProperty("mobileNumberprivate String userCreateEndpoint;

    @Value("${egov.user.search.path}")
        private String mobileNumber = nulluserSearchEndpoint;

        @JsonProperty("emailId")
  @Value("${egov.user.update.path}")
     private String emailIduserUpdateEndpoint;
=
null;    //Idgen Config
    @JsonProperty@Value("altContactNumber${egov.idgen.host}")
   
    private String altContactNumber = nullidGenHost;

        @JsonProperty@Value("fatherName${egov.idgen.path}")
 
      private String fatherNameidGenPath;
=
null;    //Workflow Config
    @JsonProperty@Value("motherName${egov.workflow.host}")
  
     private String motherNamewfHost;
=
null;    @Value("${egov.workflow.transition.path}")
    private String wfTransitionPath;

     @JsonProperty@Value("doctorAttendingBirth${egov.workflow.businessservice.search.path}")
  
     private String doctorAttendingBirth = nullwfBusinessServiceSearchPath;

        @JsonProperty("permanentAddress")
   @Value("${egov.workflow.processinstance.search.path}")
    private String permanentAddress = nullwfProcessInstanceSearchPath;

        @JsonProperty@Value("permanentCity${is.workflow.enabled}")
    private Boolean isWorkflowEnabled;

private
String permanentCity = null; // BTR Variables

     @JsonProperty@Value("permanentPincode${btr.kafka.create.topic}")
   
    private String permanentPincode = nullcreateTopic;

        @JsonProperty("correspondenceCity@Value("${btr.kafka.update.topic}")
        private String correspondenceCity = nullupdateTopic;

        @JsonProperty@Value("correspondencePincode${btr.default.offset}")
   
    private String correspondencePincode = nullInteger defaultOffset;

        @JsonProperty@Value("correspondenceAddress${btr.default.limit}")
    private Integer defaultLimit;

private String correspondenceAddress = null; @Value("${btr.search.max.limit}")
    private Integer maxLimit;


    //MDMS
    @JsonProperty@Value("hospitalName${egov.mdms.host}")
    private String mdmsHost;

private String hospitalName = null; @Value("${egov.mdms.search.endpoint}")
    private String mdmsEndPoint;

    //HRMS
    @JsonProperty@Value("placeOfBirth${egov.hrms.host}")
   
    private String placeOfBirth = nullhrmsHost;

        @JsonProperty("active@Value("${egov.hrms.search.endpoint}")
        private Boolean active = nullString hrmsEndPoint;

        @JsonProperty("locale@Value("${egov.url.shortner.host}")
    private String urlShortnerHost;

private String locale = null;

        @JsonProperty("type")
  @Value("${egov.url.shortner.endpoint}")
      private String type = nullurlShortnerEndpoint;

        @JsonProperty("signature")
@Value("${egov.sms.notification.topic}")
       private String signature = null;

  smsNotificationTopic;
}

@Component
public class ResponseInfoFactory {

    public ResponseInfo createResponseInfoFromRequestInfo(final RequestInfo requestInfo, final Boolean success) {

        final String apiId = requestInfo != null ? requestInfo.getApiId() : "";
        final String ver = requestInfo != null ? requestInfo.getVer() : "";
        Long ts = null;
        if(requestInfo!=null)
            ts = requestInfo.getTs();
        final String resMsgId = "uief87324";
        final String msgId = requestInfo != null ? requestInfo.getMsgId() : "";
        final String responseStatus = success ? "successful" : "failed";

        return ResponseInfo.builder().apiId(apiId).ver(ver).ts(ts).resMsgId(resMsgId).msgId(msgId).resMsgId(resMsgId)
                .status(responseStatus).build();
    }

}

@Component
public class IdgenUtil {
  

     @Value("${egov.idgen.host}")
    private String idGenHost;

    @Value("${egov.idgen.path}")
    private String idGenPath;

    @Autowired
    private ObjectMapper mapper;

    @Autowired
    private ServiceRequestRepository restRepo;

    public List<String> getIdList(RequestInfo requestInfo, String tenantId, String idName, String idformat, Integer count) {
        List<IdRequest> reqList = new ArrayList<>();
        for (int i = 0; i < count; i++) {
            reqList.add(IdRequest.builder().idName(idName).format(idformat).tenantId(tenantId).build());
        }

        IdGenerationRequest request = IdGenerationRequest.builder().idRequests(reqList).requestInfo(requestInfo).build();
        StringBuilder uri = new StringBuilder(idGenHost).append(idGenPath);
        IdGenerationResponse response = mapper.convertValue(restRepo.fetchResult(uri, request), IdGenerationResponse.class);

        List<IdResponse> idResponses = response.getIdResponses();

        if (CollectionUtils.isEmpty(idResponses))
            throw new CustomException("IDGEN ERROR", "No ids returned from idgen Service");

        return idResponses.stream().map(IdResponse::getId).collect(Collectors.toList());
    }
}

@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class IdGenerationResponseIdGenerationRequest {

    @JsonProperty("RequestInfo")
    private ResponseInfoRequestInfo responseInforequestInfo;

    private List<IdResponse>List<IdRequest> idResponsesidRequests;

}

#Idgen Config
egov.idgen.host=http://localhost:8285/
egov.idgen.path=egov-idgen/id/_generate

@Getter
@Setter
public class UserSearchRequest {

    @JsonProperty("RequestInfo")
    private RequestInfo requestInfo;

    @JsonProperty("uuid")
    private List<String> uuid;

    @JsonProperty("id")
    private List<String> id;

    @JsonProperty("userName")
    private String userName;

    @JsonProperty("name")
    private String name;

    @JsonProperty("babyFirstNamemobileNumber")
    private String babyFirstName;
       mobileNumber;

    @JsonProperty("babyLastNameaadhaarNumber")
    private String babyLastNameaadhaarNumber;

       
    @JsonProperty("doctorAttendingBirthpan")
    private String doctorAttendingBirth;

    @JsonProperty("mobileNumber")
    private String mobileNumberpan;

    @JsonProperty("emailId")
    private String emailId;

    @JsonProperty("fuzzyLogic")
    private boolean fuzzyLogic;
   

    @JsonProperty("hospitalName")
    private String hospitalName;
        
    @JsonProperty("placeOfBirth")
    private String placeOfBirth;

    @JsonProperty("active")
    @Setter
    private Boolean active;

    @JsonProperty("tenantId")
    private String tenantId;

    @JsonProperty("pageSize")
    private int pageSize;

    @JsonProperty("pageNumber")
    private int pageNumber = 0;

    @JsonProperty("sort")
    private List<String> sort = Collections.singletonList("name");

    @JsonProperty("userType")
    private String userType;

    @JsonProperty("roleCodes")
    private List<String> roleCodes;

}

@AllArgsConstructor
@NoArgsConstructor
@Getter
public class UserDetailResponse {
    @JsonProperty("responseInfo")
    ResponseInfo responseInfo;

    @JsonProperty("user")
    List<User> user;
}

@Service
public class UserService {
    private UserUtil userUtils;

    private BTRConfiguration config;

    @Autowired
    public UserService(UserUtil userUtils, BTRConfiguration config) {
        this.userUtils = userUtils;
        this.config = config;
    }

    /**
     * Calls user service to enrich user from search or upsert user
     * @param request
     */
    public void callUserService(BirthRegistrationRequest request){
        request.getBirthRegistrationApplications().forEach(application -> {
            if(!StringUtils.isEmpty(application.getApplicant().getId()))
                enrichUser(application, request.getRequestInfo());
            else
                upsertUser(application, request.getRequestInfo());
        });
    }

    private void upsertUser(BirthRegistrationApplication application, RequestInfo requestInfo){
        //Applicant applicant = application.getApplicant();
        User user = User.builder().userName(applicantapplication.getUserName())
                   .password(application.getPassword())
                .passwordname(applicantapplication.getPasswordgetBabyFirstName())
                   .gender(application.getGender())
                .salutationmobileNumber(applicantapplication.getSalutationgetApplicantMobileNumber())
                 .emailId(application.getEmailId())
                  .namealtContactNumber(applicantapplication.getNamegetAltContactNumber())
                  .permanentAddress(application.getPermanentAddress())
                 .genderpermanentCity(applicantapplication.getGendergetPermanentCity())
                   .permanentPincode(application.getPermanentPincode())
                .mobileNumbercorrespondenceCity(applicantapplication.getMobileNumbergetCorrespondenceCity())
                .correspondencePincode(application.getCorrespondencePincode())
                   .emailIdcorrespondenceAddress(applicantapplication.getEmailIdgetCorrespondenceAddress())
                   .active(application.getActive())
                .altContactNumberlocale(applicantapplication.getAltContactNumbergetLocale())
                  .signature(application.getSignature())
                 .babyFirstNameaccountLocked(applicantapplication.babyFirstNamegetAccountLocked())
                .fatherOrHusbandName(application.getFatherOrHusbandName())
                   .babyLastNamebloodGroup(applicantapplication.babyLastNamegetBloodGroup())
                .identificationMark(application.getIdentificationMark())
                   .doctorAttendingBirthphoto(applicantapplication.doctorAttendingBirthgetPhoto())
                   .otpReference(application.getOtpReference())
                .hospitalNametenantId(applicantapplication.hospitalNamegetTenantId())
                   .type(application.getType())
                .placeOfBirthtenantId(applicantapplication.placeOfBirthgetTenantId())
                .build();
        String tenantId   = application.getTenantId();
      .permanentAddress(applicant.getPermanentAddress())     User userServiceResponse = null;

        // Search on mobile number as user name
        UserDetailResponse userDetailResponse = searchUser(userUtils.permanentCity(applicant.getPermanentCitygetStateLevelTenant(tenantId),null, user.getMobileNumber());
        if (!userDetailResponse.getUser().isEmpty()) {
            User userFromSearch = userDetailResponse.getUser().get(0);
            .permanentPincode(applicant.getPermanentPincode())if(!user.getName().equalsIgnoreCase(userFromSearch.getName())){
                userServiceResponse = updateUser(requestInfo,user,userFromSearch);
            }
     .correspondenceCity(applicant.getCorrespondenceCity())       else userServiceResponse = userDetailResponse.getUser().get(0);
        }
        else {
       .correspondencePincode(applicant.getCorrespondencePincode())     userServiceResponse = createUser(requestInfo,tenantId,user);
        }

        // Enrich the accountId
        application.correspondenceAddresssetId(applicantuserServiceResponse.getCorrespondenceAddressgetUuid());
    }


    private void enrichUser(BirthRegistrationApplication application, RequestInfo requestInfo){

        String applicantMobileNumber         .active(applicant.getActive())= application.getApplicantMobileNumber();
        String tenantId = application.getTenantId();

        UserDetailResponse userDetailResponse = searchUser(userUtils.getStateLevelTenant(tenantId),null,applicantMobileNumber);

          .locale(applicant.getLocaleif(userDetailResponse.getUser().isEmpty())
            throw new CustomException("INVALID_ACCOUNTID","No user exist for the given accountId");

              .signature(applicant.getSignatureelse application.setId(userDetailResponse.getUser().get(0).getUuid());

    }

    /**
     * Creates the user from the given userInfo by calling user service
     *  .accountLocked(applicant.getAccountLocked())@param requestInfo
     * @param tenantId
     * @param userInfo
     * @return
             .fatherOrHusbandName(applicant.getFatherOrHusbandName())*/
    private User createUser(RequestInfo requestInfo,String tenantId, User userInfo) {

        userUtils.addUserDefaultFields(userInfo.getMobileNumber(),tenantId, userInfo);
        StringBuilder uri = new  .bloodGroupStringBuilder(applicantconfig.getBloodGroupgetUserHost())
                   .append(config.getUserContextPath())
                .identificationMarkappend(applicantconfig.getIdentificationMarkgetUserCreateEndpoint());


        UserDetailResponse userDetailResponse = userUtils.userCall(new CreateUserRequest(requestInfo, userInfo), uri);

                  .photo(applicant.getPhoto())return userDetailResponse.getUser().get(0);

    }

    /**
     * Updates the given user by calling user service
     * @param requestInfo
  .otpReference(applicant.getOtpReference())   * @param user
     * @param userFromSearch
     * @return
     */
    private User updateUser(RequestInfo requestInfo,User   .tenantId(applicant.getTenantId()user,User userFromSearch) {

        userFromSearch.setName(user.getName());
        userFromSearch.setActive(true);

        StringBuilder uri = new    .type(applicant.getTypeStringBuilder(config.getUserHost())
                   .append(config.getUserContextPath())
                .rolesappend(applicantconfig.getRolesgetUserUpdateEndpoint());


        UserDetailResponse userDetailResponse = userUtils.userCall(new CreateUserRequest(requestInfo, userFromSearch), uri);

                  .tenantId(applicant.getTenantId())return userDetailResponse.getUser().get(0);

    }

    /**
     * calls the user search API based on the given accountId and userName
      .aadhaarNumber(applicant.getAadhaarNumber())
* @param stateLevelTenant
     * @param accountId
     * @param userName
     * @return
     */
    private UserDetailResponse .buildsearchUser();String stateLevelTenant, String       accountId, String tenantIduserName){
=
applicant.getTenantId();        UserSearchRequest User userServiceResponseuserSearchRequest =new nullUserSearchRequest();
         // Search on mobile number as user name
 userSearchRequest.setActive(true);
        userSearchRequest.setUserType("CITIZEN");
      UserDetailResponse userDetailResponse = searchUser(userUtils.getStateLevelTenant(tenantId),null, user.getMobileNumber());userSearchRequest.setTenantId(stateLevelTenant);

        if (!userDetailResponseStringUtils.getUserisEmpty(accountId) && StringUtils.isEmpty(userName))
{             User userFromSearch = userDetailResponse.getUser().get(0)return null;

           if(!userStringUtils.getNameisEmpty(accountId).equalsIgnoreCase(userFromSearch.getName())){)
            userSearchRequest.setUuid(Collections.singletonList(accountId));

   userServiceResponse = updateUser(requestInfo,user,userFromSearch);   if(!StringUtils.isEmpty(userName))
         }   userSearchRequest.setUserName(userName);

        elseStringBuilder userServiceResponseuri = new userDetailResponseStringBuilder(config.getUsergetUserHost()).get(0append(config.getUserSearchEndpoint());
        }
return userUtils.userCall(userSearchRequest,uri);

    }

else {   /**
     * calls   userServiceResponse = createUser(requestInfo,tenantId,user);
        }
the user search API based on the given list of user uuids
     * @param uuids
// Enrich the accountId  * @return
     applicant.setId(userServiceResponse.getUuid());
    }

*/
    private voidMap<String,User> enrichUsersearchBulkUser(BirthRegistrationApplication application, RequestInfo requestInfoList<String> uuids){

        StringUserSearchRequest accountIduserSearchRequest =new application.getApplicantUserSearchRequest().getId();
        String tenantId = application.getApplicant().getTenantId()userSearchRequest.setActive(true);
         UserDetailResponse userDetailResponse = searchUser(userUtils.getStateLevelTenant(tenantId),accountId,null);userSearchRequest.setUserType("CITIZEN");


        if(userDetailResponse.getUser().!CollectionUtils.isEmpty(uuids))
            throw new CustomException("INVALID_ACCOUNTID","No user exist for the given accountId");userSearchRequest.setUuid(uuids);


        StringBuilder uri =   else application.getApplicant().setId(userDetailResponse.getUser().get(0).getUuidnew StringBuilder(config.getUserHost()).append(config.getUserSearchEndpoint());
     }   UserDetailResponse userDetailResponse  /**= userUtils.userCall(userSearchRequest,uri);
     * Creates the userList<User> from the given userInfo by calling user serviceusers = userDetailResponse.getUser();

    * @param requestInfo  if(CollectionUtils.isEmpty(users))
   * @param tenantId      * @paramthrow userInfo
     * @returnnew CustomException("USER_NOT_FOUND","No user found for the uuids");

     */   Map<String,User> idToUserMap private User createUser(RequestInfo requestInfo,String tenantId, User userInfo) {= users.stream().collect(Collectors.toMap(User::getUuid, Function.identity()));

        return idToUserMap;
   userUtils.addUserDefaultFields(userInfo.getMobileNumber(),tenantId, userInfo);
        StringBuilder uri = new StringBuilder(config.getUserHost())
 }

}

@Getter
@Setter
@AllArgsConstructor
@NoArgsConstructor
@Builder
@ToString
@EqualsAndHashCode(of = { "tenantId","businessServiceId","state"id" })
@ToString
public class StateProcessInstance   {

  

    @Size(max =256 64)

       @JsonProperty("uuidid")
   
    private String uuidid;

    @NotNull
    @Size(max =256 128)
        @JsonProperty("tenantId")
   
    private String tenantId;

    @NotNull
    @Size(max =256)
    128)
    @JsonProperty("businessServiceIdbusinessService")
   
    private String businessServiceIdbusinessService;

        @JsonProperty("sla")
        private Long sla;

@NotNull
       @Size(max =256 128)
        @JsonProperty("statebusinessId")
 
      private String statebusinessId;

    @NotNull
    @Size(max =256)
    128)
    @JsonProperty("applicationStatusaction")
        private String applicationStatusaction;

    @NotNull
    @JsonProperty("docUploadRequired")
        private Boolean docUploadRequired;@Size(max = 64)
          @JsonProperty("isStartStatemoduleName")
   
    private BooleanString isStartStatemoduleName;



      @JsonProperty("isTerminateStatestate")
   
    private BooleanState isTerminateStatestate;

        @JsonProperty("isStateUpdatablecomment")
   
    private BooleanString isStateUpdatablecomment;

        @JsonProperty("actionsdocuments")
   
    @Valid
    private List<Document> documents;

private List<Action> actions;     @JsonProperty("assignes")
    private AuditDetailsList<User> auditDetailsassignes;


  

    public StateProcessInstance addActionsItemaddDocumentsItem(ActionDocument actionsItemdocumentsItem) {
 
          if (this.actionsdocuments == null) {
            this.actionsdocuments = new ArrayList<>();
        }
   }     if (!this.documents.contains(documentsItem))
            this.actionsdocuments.add(actionsItemdocumentsItem);

        return this;
        }

}

@Getter
@Setter
@AllArgsConstructor
@NoArgsConstructor
@Builder
@ToString
@EqualsAndHashCode(of = {"tenantId","currentStatebusinessServiceId","actionstate"})
public class ActionState   {

        @Size(max=256)
   
    @JsonProperty("uuid")
   
    private String uuid;



      @Size(max=256)
 
      @JsonProperty("tenantId")
   
    private String tenantId;

  

    @Size(max=256)

       @JsonProperty("currentStatebusinessServiceId")
    private String businessServiceId;

    private String currentState;@JsonProperty("sla")
    private Long sla;

    @Size(max=256)
 
      @JsonProperty("actionstate")
   
    private String actionstate;

    @Size(max=256)
   @Size(max=256) @JsonProperty("applicationStatus")
    private String applicationStatus;

    @JsonProperty("nextStatedocUploadRequired")
    private Boolean docUploadRequired;

    @JsonProperty("isStartState")
    private StringBoolean nextStateisStartState;

    @JsonProperty("isTerminateState")
   @Size(max=1024) private Boolean isTerminateState;

    @JsonProperty("rolesisStateUpdatable")
    private Boolean isStateUpdatable;

@Valid    @JsonProperty("actions")
    @Valid
private List<String> roles;  private List<Action> actions;

    private AuditDetails auditDetails;


 


    public ActionState addRolesItemaddActionsItem(StringAction rolesItemactionsItem) {
   
        if (this.rolesactions == null) {
            this.rolesactions = new ArrayList<>();
   
        }
        this.rolesactions.add(rolesItemactionsItem);
        return this;
  
     }

}

@Getter
@Setter
@AllArgsConstructor
@NoArgsConstructor
@Builder
@ToString
@EqualsAndHashCode(of =
{"tenantId","businessService"})
@JsonInclude(JsonInclude.Include.NON_NULL)
public class BusinessService  ProcessInstanceRequest {

    @Size(max=256)
    @JsonProperty("tenantIdRequestInfo")
    private String tenantId = nullRequestInfo requestInfo;

    @Size(max=256)
    @JsonProperty("uuidProcessInstances")
    private@Valid
String uuid = null; @NotNull
    @Size(max=256)
 private List<ProcessInstance> processInstances;


@JsonProperty("businessService")    public privateProcessInstanceRequest String businessService = null;addProcessInstanceItem(ProcessInstance processInstanceItem) {
      @Size(max=256)  if (this.processInstances  @JsonProperty("business"== null) {
   private String business = null;     this.processInstances @Size(max=1024) new    @JsonProperty("getUri")ArrayList<>();
    private String getUri = null;}
     @Size(max=1024)     @JsonProperty("postUri")
    private String postUri = nullthis.processInstances.add(processInstanceItem);
     @JsonProperty("businessServiceSla")   return this;
private Long businessServiceSla = null;}

}

@Slf4j
@Repository
public class BirthRegistrationRepository {

    @Autowired
    private BirthApplicationQueryBuilder queryBuilder;

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Autowired
    private BirthApplicationRowMapper rowMapper;

    public List<BirthRegistrationApplication> getApplicationsList<BirthRegistrationApplication>getApplications(BirthApplicationSearchCriteria searchCriteria){
        List<Object> preparedStmtList = new ArrayList<>();
        String query = queryBuilder.getBirthApplicationSearchQuery(searchCriteria, preparedStmtList);
        log.info("Final query: " + query);
        return jdbcTemplate.query(query, preparedStmtList.toArray(), rowMapper);
     }
}

@Service
@Slf4j
public class Producer {

    @Autowired
    private CustomKafkaTemplate<String, Object> kafkaTemplate;

    public void push(String topic, Object value) {
        kafkaTemplate.send(topic, value);
    }
} 

@Slf4j
@Service
public class NotificationService {

    @Autowired
    private Producer producer;

    @Autowired
    private BTRConfiguration config;

    @Autowired
    private RestTemplate restTemplate;

    private static final String smsTemplate = "Dear {NAME}, your birth registration application has been successfully created on the system with application number - {APPNUMBER}.";

    public void prepareEventAndSend(BirthRegistrationRequest request){
        List<SMSRequest> smsRequestList = new ArrayList<>();
        request.getBirthRegistrationApplications().forEach(application -> {
            SMSRequest smsRequest = SMSRequest.builder().mobileNumber(application.getApplicantgetApplicantMobileNumber().getMobileNumber()).message(getCustomMessage(smsTemplate, application)).build();
            smsRequestList.add(smsRequest);
        });
        for (SMSRequest smsRequest : smsRequestList) {
            producer.push(config.getSmsNotificationTopic(), smsRequest);
            log.info("Messages: " + smsRequest.getMessage());
        }
    }

    private String getCustomMessage(String template, BirthRegistrationApplication application) {
        template = template.replace("{APPNUMBER}", application.getApplicationNumber());
        template = template.replace("{NAME}", application.getApplicant().getNamegetFatherName());
        return template;
    }

}

@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
@EqualsAndHashCode
public class Payment {

    	@Size(max = 64)
  	  @JsonProperty("id")
 	   private String id;

    	@NotNull
  	  @Size(max = 64))
    	@JsonProperty("tenantId")
    	private String tenantId;

    	@JsonProperty("totalDue")
   	 private BigDecimal totalDue;

    	@NotNull
 	   @JsonProperty("totalAmountPaid")
	    private BigDecimal totalAmountPaid;

    	@Size(max = 128)
 	   @JsonProperty("transactionNumber")
    	private String transactionNumber;

    	@JsonProperty("transactionDate")
 	   private Long transactionDate;

	@NotNull
	    @NotNull
    @JsonProperty("paymentMode")
 	   private String paymentMode;

    	@JsonProperty("instrumentDate")
    	private Long instrumentDate;

 	   @Size(max = 128)
    	@JsonProperty("instrumentNumber")
    	private String instrumentNumber;

 	   @JsonProperty("instrumentStatus")
    	private String instrumentStatus;

    	@Size(max = 64)
 	   @JsonProperty("ifscCode")
	    private String ifscCode;

    	@JsonProperty("auditDetails")
 	   private AuditDetails auditDetails;

    	@JsonProperty("additionalDetails")
    	private JsonNode additionalDetails;

 	   @JsonProperty("paymentDetails")
    	@Valid
    	private List<PaymentDetail> paymentDetails;

 	   @Size(max = 128)
    	@NotNull
    	@JsonProperty("paidBy")
 	   private String paidBy;

    	@Size(max = 64)
    	@NotNull
 	   @JsonProperty("mobileNumber")
    	private String mobileNumber;

    	@Size(max = 128)
 	   @JsonProperty("payerName")
    	private String payerName;

    	@Size(max = 1024)
 	   @JsonProperty("payerAddress")
    	private String payerAddress;

    	@Size(max = 64)
 	   @JsonProperty("payerEmail"))
    	private String payerEmail;

    	@Size(max = 64)
    	@JsonProperty("payerId")
  	  private String payerId;

    	@JsonProperty("paymentStatus")
	    private String paymentStatus;

	    public Payment addpaymentDetailsItem(PaymentDetail paymentDetail) {
		
        if (this.paymentDetails == null) {
			
            this.paymentDetails = new ArrayList<>();
		}
		        }
        this.paymentDetails.add(paymentDetail);
		
        return this;
    	}

}

@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
@EqualsAndHashCode
public class PaymentDetail {

    @Size(max = 64)
    @JsonProperty("id")
    private String id;

    @Size(max = 64)
    @JsonProperty("tenantId")
    private String tenantId;

    @JsonProperty("totalDue")
    private BigDecimal totalDue;

    @NotNull
    @JsonProperty("totalAmountPaid")
    private BigDecimal totalAmountPaid;

    @Size(max = 64)
    @JsonProperty("receiptNumber")
    private String receiptNumber;

    @Size(max = 64)
    @JsonProperty("manualReceiptNumber")
    private String manualReceiptNumber;

    @JsonProperty("manualReceiptDate")
    private Long manualReceiptDate;

    @JsonProperty("receiptDate")
    private Long receiptDate;

    @JsonProperty("receiptType")
    private String receiptType;

    @JsonProperty("businessService")
    private String businessService;

    @NotNull
    @Size(max = 64)
    @JsonProperty("billId")
    private String billId;

    @JsonProperty("bill")
    private Bill bill;

    @JsonProperty("additionalDetails")
    private JsonNode additionalDetails;

    @JsonProperty("auditDetails")
    private AuditDetails auditDetails;

}

@Getter
@Setter
@ToString
@Builder
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode
public class Bill {
 

  	  @JsonProperty("id")
	    private String id;

 	   @JsonProperty("mobileNumber")
  	  private String mobileNumber;

  	  @JsonProperty("paidBy")
  	  private String paidBy;

	    @JsonProperty("payerName")
 	   private String payerName;

	    @JsonProperty("payerAddress")
  	  private String payerAddress;

  	  @JsonProperty("payerEmail")
	    private String payerEmail;

 	   @JsonProperty("payerId")
  	  private String payerId;

  	  @JsonProperty("status")
  	  private StatusEnum status;

	    @JsonProperty("reasonForCancellation")
  	  private String reasonForCancellation;

	    @JsonProperty("isCancelled")
  	  private Boolean isCancelled;

  	  @JsonProperty("additionalDetails")
 	   private JsonNode additionalDetails;

  	  @JsonProperty("billDetails")
	    @Valid
  	  private List<BillDetail> billDetails;

  	  @JsonProperty("tenantId")
 	   private String tenantId;

  	  @JsonProperty("auditDetails")
	    private AuditDetails auditDetails;

  	  @JsonProperty("collectionModesNotAllowed")
  	  private List<String> collectionModesNotAllowed;

 	   @JsonProperty("partPaymentAllowed")
  	  private Boolean partPaymentAllowed;

	    @JsonProperty("isAdvanceAllowed")
  	  private Boolean isAdvanceAllowed;

  	  @JsonProperty("minimumAmountToBePaid")
 	   private BigDecimal minimumAmountToBePaid;

  	  @JsonProperty("businessService")
	    private String businessService;

  	  @JsonProperty("totalAmount")
  	  private BigDecimal totalAmount;

 	   @JsonProperty("consumerCode")
  	  private String consumerCode;

	    @JsonProperty("billNumber")
  	  private String billNumber;

  	  @JsonProperty("billDate")
 	   private Long billDate;

  	  @JsonProperty("amountPaid"))
  	  private BigDecimal amountPaid;



    	public enum StatusEnum {
      	  ACTIVE("ACTIVE"),

 	       CANCELLED("CANCELLED"),

  	      PAID("PAID"),

	        EXPIRED("EXPIRED");

   	     private String value;

      	  StatusEnum(String value) {
	
            this.value = value;
	}        }


        	@Override
	@JsonValue
	
        @JsonValue
        public String toString() {
		
            return String.valueOf(value);
	
        }

	        public static boolean contains(String test) {
		
            for (StatusEnum val : StatusEnum.values()) {
			
                if (val.name().equalsIgnoreCase(test)) {
				return true;
			}
		}
		return false;
	}

	@JsonCreator
	 {
                    return true;
                }
            }
            return false;
        }

        @JsonCreator
        public static StatusEnum fromValue(String text) {
		
            for (StatusEnum b : StatusEnum.values()) {
			
                if (String.valueOf(b.value).equals(text)) {
				
                    return b;
			}
		}
		
                }
            }
            return null;
	}
        }

    }

    	public Boolean addBillDetail(BillDetail billDetail) {

  		      if (CollectionUtils.isEmpty(billDetails)) {

       			     billDetails = new ArrayList<>();
			
            return billDetails.add(billDetail);
		
        } else {

            			if (!billDetails.contains(billDetail))
				
                return billDetails.add(billDetail);
			else
				
            else
                return false;
		}
	
        }
    }


}

@Setter
@Getter
@ToString
@Builder
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(of = { "id" })
public class BillDetail {

    @JsonProperty("id")
    private String id;

    @JsonProperty("tenantId")
    private String tenantId;

    @JsonProperty("demandId")
    private String demandId;

    @JsonProperty("billId")
    private String billId;

    @JsonProperty("amount")
    @NotNull
    private BigDecimal amount;

    @JsonProperty("amountPaid")
    private BigDecimal amountPaid;

    @NotNull
    @JsonProperty("fromPeriod")
    private Long fromPeriod;

    @NotNull
    @JsonProperty("toPeriod")
    private Long toPeriod;

    @JsonProperty("additionalDetails")
    private JsonNode additionalDetails;

    @JsonProperty("channel")
    private String channel;

    @JsonProperty("voucherHeader")
    private String voucherHeader;

    @JsonProperty("boundary")
    private String boundary;

    @JsonProperty("manualReceiptNumber")
    private String manualReceiptNumber;

    @JsonProperty("manualReceiptDate")
    private Long manualReceiptDate;

    @JsonProperty("billAccountDetails")
    private List<BillAccountDetail> billAccountDetails;

    @NotNull
    @JsonProperty("collectionType")
    private String collectionType;

    @JsonProperty("auditDetails")
    private AuditDetails auditDetails;

    private String billDescription;

    @NotNull
    @JsonProperty("expiryDate")
    private Long expiryDate;
 


      public Boolean addBillAccountDetail(BillAccountDetail billAccountDetail) {

        if (CollectionUtils.isEmpty(billAccountDetails)) {

            billAccountDetails = new ArrayList<>();
            return billAccountDetails.add(billAccountDetail);
        } else {

            if (!billAccountDetails.contains(billAccountDetail))
                return billAccountDetails.add(billAccountDetail);
            else
                return false;
        }
    }

}

@Setter
@Getter
@ToString
@Builder
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode
public class BillAccountDetail {

 	   @Size(max = 64)
	    @JsonProperty("id")
  	  private String id;

 	   @Size(max = 64)
    	@JsonProperty("tenantId")
  	  private String tenantId;

 	   @Size(max = 64)
    	@JsonProperty("billDetailId")
  	  private String billDetailId;

 	   @Size(max = 64)
    	@JsonProperty("demandDetailId")
  	  private String demandDetailId;

 	   @JsonProperty("order")
	    private Integer order;

  	  @JsonProperty("amount")
 	   private BigDecimal amount;

    	@JsonProperty("adjustedAmount")
  	  private BigDecimal adjustedAmount;

 	   @JsonProperty("isActualDemand")
    	private Boolean isActualDemand;

  	  @Size(max = 64)
 	   @JsonProperty("taxHeadCode")
    	private String taxHeadCode;

  	  @JsonProperty("additionalDetails")
 	   private JsonNode additionalDetails;

    	@JsonProperty("auditDetails")
  	  private AuditDetails auditDetails;
}

serviceMaps:
  serviceName: btr-services
  mappings:
    - version: 1.0
      description: Persists birth details in tables
      fromTopic: save-bt-application
      isTransaction: true
      queryMaps:

        - query: INSERT INTO eg_bt_registration(id,tenantid,applicationNumber,babyFirstName,applicationnumberbabyLastName,babyLastNamefatherName,motherName,fatherName,doctorAttendingBirthdoctorName,hospitalName,placeOfBirth,dateOfBirth,createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?);
          basePath: BirthRegistrationApplications.*
          jsonMaps:
            - jsonPath: $.BirthRegistrationApplications.*.id

            - jsonPath: $.BirthRegistrationApplications.*.tenantId

            - jsonPath: $.BirthRegistrationApplications.*.babyFirstNameapplicationNumber
          
              - jsonPath: $.BirthRegistrationApplications.*.applicationNumberbabyFirstName
            
            - jsonPath: $.BirthRegistrationApplications.*.babyLastName
          
              - jsonPath: $.BirthRegistrationApplications.*.motherNamefatherName
                                   
            - jsonPath: $.BirthRegistrationApplications.*.fatherNamemotherName
            
            - jsonPath: $.BirthRegistrationApplications.*.doctorAttendingBirthdoctorName
            
            - jsonPath: $.BirthRegistrationApplications.*.hospitalName
            
            - jsonPath: $.BirthRegistrationApplications.*.placeOfBirth

            - jsonPath: $.BirthRegistrationApplications.*.dateOfBirth

            - jsonPath: $.BirthRegistrationApplications.*.auditDetails.createdTime

            - jsonPath: $.BirthRegistrationApplications.*.auditDetails.lastModifiedTime

        - query: INSERT INTO eg_bt_address(id, tenantid, doorno, latitude, longitude, buildingname, addressid, addressnumber, type, addressline1, addressline2, landmark, street, city, locality, pincode, detail, registrationid, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?);
          basePath: BirthRegistrationApplications.*
          jsonMaps:
            - jsonPath: $.BirthRegistrationApplications.*.address.id

            - jsonPath: $.BirthRegistrationApplications.*.address.tenantId

            - jsonPath: $.BirthRegistrationApplications.*.address.doorNo

            - jsonPath: $.BirthRegistrationApplications.*.address.latitude

            - jsonPath: $.BirthRegistrationApplications.*.address.longitude

            - jsonPath: $.BirthRegistrationApplications.*.address.buildingName

            - jsonPath: $.BirthRegistrationApplications.*.address.addressId

            - jsonPath: $.BirthRegistrationApplications.*.address.addressNumber

            - jsonPath: $.BirthRegistrationApplications.*.address.type

            - jsonPath: $.BirthRegistrationApplications.*.address.addressLine1

            - jsonPath: $.BirthRegistrationApplications.*.address.addressLine2

            - jsonPath: $.BirthRegistrationApplications.*.address.landmark

            - jsonPath: $.BirthRegistrationApplications.*.address.street

            - jsonPath: $.BirthRegistrationApplications.*.address.city

            - jsonPath: $.BirthRegistrationApplications.*.address.locality.name

            - jsonPath: $.BirthRegistrationApplications.*.address.pincode

            - jsonPath: $.BirthRegistrationApplications.*.address.detail

            - jsonPath: $.BirthRegistrationApplications.*.address.registrationId

            - jsonPath: $.BirthRegistrationApplications.*.address.createdBy

            - jsonPath: $.BirthRegistrationApplications.*.address.lastModifiedBy

            - jsonPath: $.BirthRegistrationApplications.*.address.createdTime

            - jsonPath: $.BirthRegistrationApplications.*.address.lastModifiedTime

    - version: 1.0
      description: Update birth registration applications in table
      fromTopic: update-bt-application
      isTransaction: true
      queryMaps:
        - query: UPDATE eg_bt_registration SET tenantid = ?,babyFirstName = ?, dateOfBirth = ? WHERE id=?;
          basePath: BirthRegistrationApplications.*
          jsonMaps:
            - jsonPath: $.BirthRegistrationApplications.*.tenantId

            - jsonPath: $.BirthRegistrationApplications.*.babyFirstName

            - jsonPath: $.BirthRegistrationApplications.*.dateOfBirth

            - jsonPath: $.BirthRegistrationApplications.*.id

ServiceMaps:
  serviceName: Birth Registration Service
  version: 1.0.0
  mappings:
    - topic: save-bt-application
      configKey: INDEX
      indexes:
        - name: btindex-v1
          type: general
          id: $.id
          isBulk: true
          timeStampField: $.auditDetails.createdTime
          jsonPath: $.BirthRegistrationApplications
          customJsonMapping:
            indexMapping: {"Data":{"birthapplication":{},"history":{}}}
            fieldMapping:
              - inJsonPath: $
                outJsonPath: $.Data.birthapplication
            externalUriMapping:
              - path: http://localhost:8282/egov-workflow-v2/egov-wf/process/_search
                queryParam: businessIds=$.applicationNumber,history=true,tenantId=$.tenantId
                apiRequest: {"RequestInfo":{"apiId":"org.egov.pt","ver":"1.0","ts":1502890899493,"action":"asd","did":"4354648646","key":"xyz","msgId":"654654","requesterId":"61","authToken":"d9994555-7656-4a67-ab3a-a952a0d4dfc8","userInfo":{"id":1,"uuid":"1fec8102-0e02-4d0a-b283-cd80d5dab067","type":"EMPLOYEE","tenantId":"pb.amritsar","roles":[{"name":"Employee","code":"EMPLOYEE","tenantId":"pb.amritsar"}]}}}
                uriResponseMapping:
                  - inJsonPath: $.ProcessInstances
                    outJsonPath: $.Data.history

    - topic: update-bt-application
      configKey: INDEX
      indexes:
        - name: btindex-v1
          type: general
          id: $.id
          isBulk: true
          timeStampField: $.auditDetails.createdTime
          jsonPath: $.BirthRegistrationApplications
          customJsonMapping:
            indexMapping: {"Data":{"tradelicense":{},"history":{}}}
            fieldMapping:
              - inJsonPath: $
                outJsonPath: $.Data.tradelicense
            externalUriMapping:
              - path: http://localhost:8282/egov-workflow-v2/egov-wf/process/_search
                queryParam: businessIds=$.applicationNumber,history=true,tenantId=$.tenantId
                apiRequest: {"RequestInfo":{"apiId":"org.egov.pt","ver":"1.0","ts":1502890899493,"action":"asd","did":"4354648646","key":"xyz","msgId":"654654","requesterId":"61","authToken":"d9994555-7656-4a67-ab3a-a952a0d4dfc8","userInfo":{"id":1,"uuid":"1fec8102-0e02-4d0a-b283-cd80d5dab067","type":"EMPLOYEE","tenantId":"pb.amritsar","roles":[{"name":"Employee","code":"EMPLOYEE","tenantId":"pb.amritsar"}]}}}
                uriResponseMapping:
                  - inJsonPath: $.ProcessInstances
                    outJsonPath: $.Data.history