Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions .github/workflows/push-trigger.yml
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,7 @@ on:
- develop
- MOSIP*
- tf_nira_dev
- digital_card

jobs:
build-maven-admin-services:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@
import org.springframework.web.bind.annotation.RestController;

import io.mosip.admin.packetstatusupdater.dto.PacketResumeUpdateResponseDto;
import io.mosip.admin.packetstatusupdater.dto.PacketSendToPersoResponseDto;
import io.mosip.admin.packetstatusupdater.dto.PacketStatusUpdateResponseDto;
import io.mosip.admin.packetstatusupdater.service.PacketStatusUpdateService;
import io.mosip.admin.packetstatusupdater.util.AuditUtil;
Expand Down Expand Up @@ -70,4 +71,23 @@ public ResponseWrapper<PacketResumeUpdateResponseDto> resumePacket(@RequestParam
return responseWrapper;

}

/**
* Validate packet.
*
* @param rId the r id
* @return the response wrapper
*/
@PreAuthorize("hasAnyRole(@authorizedRoles.getGetpacketstatusupdate())")
@PostMapping(value = { "/sentToPerso" }, consumes = { "multipart/form-data" })
//@PreAuthorize("hasAnyRole('ZONAL_ADMIN','GLOBAL_ADMIN')")
public ResponseWrapper<PacketSendToPersoResponseDto> sentPacketCardToPerso(@RequestParam(value = "rid") String rId,
@RequestParam(value = "langCode", required = false) String langCode) {
auditUtil.setAuditRequestDto(EventEnum.getEventEnumWithValue(EventEnum.PKT_STATUS_UPD_API_CALLED, rId), null);
ResponseWrapper<PacketSendToPersoResponseDto> responseWrapper = new ResponseWrapper<>();
responseWrapper.setResponse(packetUpdateStatusService.sentPacketCardToPerso(rId, langCode));
auditUtil.setAuditRequestDto(EventEnum.getEventEnumWithValue(EventEnum.PKT_STATUS_UPD_SUCCESS, rId), null);
return responseWrapper;

}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
package io.mosip.admin.packetstatusupdater.dto;

import lombok.Data;

@Data
public class PacketSendToPersoResponseDto {

private String message;
}
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package io.mosip.admin.packetstatusupdater.service;

import io.mosip.admin.packetstatusupdater.dto.PacketResumeUpdateResponseDto;
import io.mosip.admin.packetstatusupdater.dto.PacketSendToPersoResponseDto;
import io.mosip.admin.packetstatusupdater.dto.PacketStatusUpdateResponseDto;

/**
Expand All @@ -20,4 +21,6 @@ public interface PacketStatusUpdateService {
public PacketStatusUpdateResponseDto getStatus(String rid, String langCode);

public PacketResumeUpdateResponseDto updatePacket(String rid, String langCode);

public PacketSendToPersoResponseDto sentPacketCardToPerso(String rid, String langCode);
}
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@

import io.mosip.admin.packetstatusupdater.constant.PacketStatusUpdateErrorCode;
import io.mosip.admin.packetstatusupdater.dto.PacketResumeUpdateResponseDto;
import io.mosip.admin.packetstatusupdater.dto.PacketSendToPersoResponseDto;
import io.mosip.admin.packetstatusupdater.dto.PacketStatusUpdateDto;
import io.mosip.admin.packetstatusupdater.dto.PacketStatusUpdateResponseDto;
import io.mosip.admin.packetstatusupdater.exception.MasterDataServiceException;
Expand Down Expand Up @@ -59,6 +60,10 @@ public class PacketStatusUpdateServiceImpl implements PacketStatusUpdateService
/** The packet update status url. */
@Value("${mosip.admin.packet-resume-update-url}")
private String packetResumeUpdateUrl;

/** The packet send card to perso. */
@Value("${mosip.admin.packet-send-to-perso-url}")
private String packetSendToPerso;

/** The zone validation url. */
@Value("${mosip.kernel.zone-validation-url}")
Expand Down Expand Up @@ -113,6 +118,18 @@ public PacketResumeUpdateResponseDto updatePacket(String rId, String langCode) {
auditUtil.setAuditRequestDto(EventEnum.PACKET_STATUS,null);
return updatePacketResume(rId);
}

/*
* (non-Javadoc)
*
* @see io.mosip.admin.packetstatusupdater.service.PacketStatusUpdateService#
* sent packet to perso(java.lang.String)
*/
@Override
public PacketSendToPersoResponseDto sentPacketCardToPerso(String rId, String langCode) {
auditUtil.setAuditRequestDto(EventEnum.PACKET_STATUS,null);
return sendPacket(rId);
}

/**
* Gets the packet status.
Expand Down Expand Up @@ -206,6 +223,42 @@ private PacketResumeUpdateResponseDto updatePacketResume(String rId) {
);
}

/**
* Gets the packet status.
*
* @param rId
*
* @return the send packet to perso
*/
@SuppressWarnings({ "unchecked" })
private PacketSendToPersoResponseDto sendPacket(String rId) {
try {
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
HttpEntity<Void> entity = new HttpEntity<>(headers);
UriComponentsBuilder urlBuilder = UriComponentsBuilder.fromUriString(packetSendToPerso)
.path(rId);
logger.info("Calling Regproc API: {}", urlBuilder.toUriString());
ResponseEntity<String> response = restTemplate.postForEntity(urlBuilder.toUriString(), entity, String.class);
logger.info("RegProc raw response: {}", response.getBody());
if (response.getStatusCode().is2xxSuccessful()) {
PacketSendToPersoResponseDto dto = new PacketSendToPersoResponseDto();
dto.setMessage(response.getBody());
return dto;
}
} catch (RequestException e) {
logger.error("SESSIONID", "ADMIN-SERVICE", "ADMIN-SERVICE", e.getMessage() + ExceptionUtils.getStackTrace(e));
throw e;
} catch (Exception e) {
logger.error("SESSIONID", "ADMIN-SERVICE", "ADMIN-SERVICE", e.getMessage() + ExceptionUtils.getStackTrace(e));
throw new MasterDataServiceException(PacketStatusUpdateErrorCode.PACKET_FETCH_EXCEPTION.getErrorCode(),
PacketStatusUpdateErrorCode.PACKET_FETCH_EXCEPTION.getErrorMessage(),e);
}
auditUtil.setAuditRequestDto(EventEnum.getEventEnumWithValue(EventEnum.PACKET_STATUS_ERROR, rId), null);
throw new RequestException(PacketStatusUpdateErrorCode.PACKET_FETCH_EXCEPTION.getErrorCode(),
PacketStatusUpdateErrorCode.PACKET_FETCH_EXCEPTION.getErrorMessage()
);
}

/**
* Gets the packet response.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -196,6 +196,7 @@ mosip.admin.resource.pages = 5,10,15,20,25,30,35,40,45,50

mosip.kernel.packet-status-update-url=https://dev.mosip.net/registrationprocessor/v1/registrationtransaction/search/
mosip.admin.packet-resume-update-url=https://dev.mosip.net/registrationprocessor/v1/registrationtransaction/prioritize/
mosip.admin.packet-send-to-perso-url=https://dev.mosip.net/v1/print/print/sendCardToPerso/
mosip.kernel.zone-validation-url=https://dev.mosip.net/v1/masterdata/zones/authorize
mosip.kernel.registrationcenterid.length=5
javax.persistence.jdbc.url=jdbc:postgresql://dev.mosip.net:30090/mosip_master
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -267,6 +267,7 @@ mosip.admin.packetstatus.api.statuscode=PROCESSING
mosip.admin.packetstatus.api.packetId=mosip.registration.status
mosip.kernel.packet-status-update-url=https://dev.mosip.io/registrationprocessor/v1/registrationtransaction/search/
mosip.admin.packet-resume-update-url=https://dev.mosip.net/registrationprocessor/v1/registrationtransaction/prioritize/
mosip.admin.packet-send-to-perso-url=https://dev.mosip.net/v1/print/print/sendCardToPerso/
mosip.kernel.zone-validation-url=https://dev.mosip.io/v1/masterdata/zones/authorize
mosip.kernel.registrationcenterid.length=5

Expand Down
Loading