Pfm 1419 user search

business-services/egov-hrms/src/main/java/org/egov/hrms/config/PropertiesManager.java

@@ -64,6 +64,10 @@ public class PropertiesManager {
 
 	@Value("${egov.user.search.endpoint}")
 	public String userSearchEndpoint;
+
+	@Value("${egov.user.search.tenant.endpoint}")
+	public String userSearchByTenantEndpoint;
+
 
 	@Value("${egov.user.create.endpoint}")
 	public String userCreateEndpoint;

business-services/egov-hrms/src/main/java/org/egov/hrms/model/Employee.java

@@ -85,7 +85,7 @@ public class Employee {
 
     @Valid
     @NotEmpty
-    @Size(min = 1,max = 50)
+    @Size(min = 1,max = 5000)
     private List<Jurisdiction> jurisdictions = new ArrayList<>();
 
 

business-services/egov-hrms/src/main/java/org/egov/hrms/service/EmployeeService.java

@@ -62,6 +62,7 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
+import org.springframework.util.ObjectUtils;
 
 import java.util.*;
 import java.util.function.Function;
@@ -149,6 +150,11 @@ public EmployeeResponse search(EmployeeSearchCriteria criteria, RequestInfo requ
                 userSearchCriteria.put(HRMSConstants.HRMS_USER_SEARCH_CRITERA_MOBILENO,criteria.getPhone());
             if( !CollectionUtils.isEmpty(criteria.getRoles()) )
                 userSearchCriteria.put(HRMSConstants.HRMS_USER_SEARCH_CRITERA_ROLECODES,criteria.getRoles());
+			if(!ObjectUtils.isEmpty(criteria.isStateLevelSearch))
+				userSearchCriteria.put(HRMSConstants.HRMS_IS_STATE_LEVEL_SEARCH_CODE, criteria.getIsStateLevelSearch());
+			if(!ObjectUtils.isEmpty(criteria.getIsActive()))
+				userSearchCriteria.put(HRMSConstants.HRMS_IS_ACTIVE_SEARCH_CODE, criteria.getIsActive());
+
             UserResponse userResponse = userService.getUser(requestInfo, userSearchCriteria);
 			userChecked =true;
             if(!CollectionUtils.isEmpty(userResponse.getUser())) {
@@ -228,7 +234,6 @@ private void createUser(Employee employee, RequestInfo requestInfo) {
 			employee.getUser().setUuid(user.getUuid());
 		}catch(Exception e) {
 			log.error("Exception while creating user: ",e);
-			log.error("request: "+request);
 			throw new CustomException(ErrorConstants.HRMS_USER_CREATION_FAILED_CODE, ErrorConstants.HRMS_USER_CREATION_FAILED_MSG);
 		}
 
@@ -245,6 +250,7 @@ private void enrichUser(Employee employee) {
 		pwdParams.add(employee.getUser().getMobileNumber());
 		pwdParams.add(employee.getTenantId());
 		pwdParams.add(employee.getUser().getName().toUpperCase());
+		//TODO:Add localition of sms and add template to register SMS
 		employee.getUser().setPassword(hrmsUtils.generatePassword(pwdParams));
 		employee.getUser().setUserName(employee.getCode());
 		employee.getUser().setActive(true);
@@ -354,7 +360,6 @@ private void updateUser(Employee employee, RequestInfo requestInfo) {
 			userService.updateUser(request);
 		}catch(Exception e) {
 			log.error("Exception while updating user: ",e);
-			log.error("request: "+request);
 			throw new CustomException(ErrorConstants.HRMS_USER_UPDATION_FAILED_CODE, ErrorConstants.HRMS_USER_UPDATION_FAILED_MSG);
 		}
 
@@ -561,4 +566,77 @@ public Map<String,Object> getEmployeeCountResponse(RequestInfo requestInfo, Stri
 		return  response;
 	}
 
+	public Map<String,Object> getEmployeeCountResponseV1(RequestInfo requestInfo, List<String> roles, String tenantId, boolean isStateLevelSearch){
+		EmployeeSearchCriteria activeEmployeeCriteria= EmployeeSearchCriteria.builder().roles(roles).tenantId(tenantId).isStateLevelSearch(isStateLevelSearch).isActive(true).build();
+		EmployeeResponse activeEmployeeResponse = search(activeEmployeeCriteria, requestInfo);
+		EmployeeSearchCriteria inActiveEmployeeCriteria= EmployeeSearchCriteria.builder().roles(roles).tenantId(tenantId).isStateLevelSearch(isStateLevelSearch).isActive(false).build();
+		EmployeeResponse inActiveEmployeeResponse = search(inActiveEmployeeCriteria, requestInfo);
+		Integer activeEmployeeCount= activeEmployeeResponse.getEmployees().size();
+		Integer inActiveEmployeeCount = inActiveEmployeeResponse.getEmployees().size();
+		Integer totalcount = activeEmployeeCount + inActiveEmployeeCount;
+		Map<String,String> results = new HashMap<>();
+		Map<String,Object> response = new HashMap<>();
+		ResponseInfo responseInfo = factory.createResponseInfoFromRequestInfo(requestInfo, true);
+
+		response.put("ResponseInfo",responseInfo);
+
+		if(totalcount == 0){
+			Map<String,String> error = new HashMap<>();
+			error.put("NO_RECORDS","No records found for the tenantId: "+tenantId);
+			throw new CustomException(error);
+		}
+		results.put("totalEmployee",totalcount.toString());
+		results.put("activeEmployee",activeEmployeeCount.toString());
+		results.put("inactiveEmployee",inActiveEmployeeCount.toString());
+
+		response.put("EmployeCount",results);
+		return  response;
+	}
+
+	public EmployeeResponse searchListOfEmployee(EmployeeSearchCriteria criteria, RequestInfo requestInfo) {
+		boolean  userChecked = false;
+		/*if(null == criteria.getIsActive() || criteria.getIsActive())
+			criteria.setIsActive(true);
+		else
+			criteria.setIsActive(false);*/
+		Map<String, User> mapOfUsers = new HashMap<String, User>();
+		if((!CollectionUtils.isEmpty(criteria.getRoles())) && !CollectionUtils.isEmpty(criteria.getTenantIds())) {
+			Map<String, Object> userSearchCriteria = new HashMap<>();
+			userSearchCriteria.put(HRMSConstants.HRMS_USER_SEARCH_CRITERA_TENANTIDS,criteria.getTenantIds());
+			if( !CollectionUtils.isEmpty(criteria.getRoles()) )
+				userSearchCriteria.put(HRMSConstants.HRMS_USER_SEARCH_CRITERA_ROLECODES,criteria.getRoles());
+			UserResponse userResponse = userService.getUserByTenantids(requestInfo, userSearchCriteria);
+			userChecked =true;
+			if(!CollectionUtils.isEmpty(userResponse.getUser())) {
+				mapOfUsers.putAll(userResponse.getUser().stream()
+						.collect(Collectors.toMap(User::getUuid, Function.identity())));
+			}
+			List<String> userUUIDs = userResponse.getUser().stream().map(User :: getUuid).collect(Collectors.toList());
+			if(!CollectionUtils.isEmpty(criteria.getUuids()))
+				criteria.setUuids(criteria.getUuids().stream().filter(userUUIDs::contains).collect(Collectors.toList()));
+			else
+				criteria.setUuids(userUUIDs);
+		}
+		//checks if above criteria met and result is not  null will check for name search if list of names are given as user search on name is not bulk api
+		List <Employee> employees = new ArrayList<>();
+		employees = repository.fetchEmployees(criteria, requestInfo);
+		List<String> uuids = employees.stream().map(Employee :: getUuid).collect(Collectors.toList());
+		if(!CollectionUtils.isEmpty(uuids)){
+			Map<String, Object> UserSearchCriteria = new HashMap<>();
+			UserSearchCriteria.put(HRMSConstants.HRMS_USER_SEARCH_CRITERA_UUID,uuids);
+			if(mapOfUsers.isEmpty()){
+				UserResponse userResponse = userService.getUser(requestInfo, UserSearchCriteria);
+				if(!CollectionUtils.isEmpty(userResponse.getUser())) {
+					mapOfUsers = userResponse.getUser().stream()
+							.collect(Collectors.toMap(User :: getUuid, Function.identity()));
+				}
+			}
+			for(Employee employee: employees){
+				employee.setUser(mapOfUsers.get(employee.getUuid()));
+			}
+		}
+		return EmployeeResponse.builder().responseInfo(factory.createResponseInfoFromRequestInfo(requestInfo, true))
+				.employees(employees).build();
+	}
+
 }

business-services/egov-hrms/src/main/java/org/egov/hrms/service/UserService.java

@@ -78,6 +78,9 @@ public class UserService {
 	@Value("${egov.user.search.endpoint}")
 	private String userSearchEndpoint;
 
+	@Value("${egov.user.search.tenant.endpoint}")
+	private String userSearchByTenantEndpoint;
+
 	@Value("${egov.user.update.endpoint}")
 	private String userUpdateEndpoint;
 
@@ -124,6 +127,22 @@ public UserResponse getUser(RequestInfo requestInfo, Map<String, Object> UserSea
 
 		return userResponse;
 	}
+	public UserResponse getUserByTenantids(RequestInfo requestInfo, Map<String, Object> UserSearchCriteria ) {
+		StringBuilder uri = new StringBuilder();
+		Map<String, Object> userSearchReq = new HashMap<>();
+		userSearchReq.put(HRMSConstants.HRMS_USER_SERACH_CRITERIA_USERTYPE_CODE,HRMSConstants.HRMS_USER_SERACH_CRITERIA_USERTYPE);
+		for( String key: UserSearchCriteria.keySet())
+			userSearchReq.put(key, UserSearchCriteria.get(key));
+		uri.append(propertiesManager.getUserHost()).append(propertiesManager.getUserSearchByTenantEndpoint());
+		UserResponse userResponse = new UserResponse();
+		try {
+			userResponse = userCall(userSearchReq,uri);
+		}catch(Exception e) {
+			log.error("User search failed: ",e);
+		}
+
+		return userResponse;
+	}
 
 
 	/**
@@ -135,7 +154,7 @@ public UserResponse getUser(RequestInfo requestInfo, Map<String, Object> UserSea
 	@SuppressWarnings("all")
 	private UserResponse userCall(Object userRequest, StringBuilder uri) {
 		String dobFormat = null;
-		if(uri.toString().contains(userSearchEndpoint) || uri.toString().contains(userUpdateEndpoint))
+		if(uri.toString().contains(userSearchEndpoint) || uri.toString().contains(userUpdateEndpoint) || uri.toString().contains(userSearchByTenantEndpoint))
 			dobFormat="yyyy-MM-dd";
 		else if(uri.toString().contains(userCreateEndpoint))
 			dobFormat = "dd/MM/yyyy";

business-services/egov-hrms/src/main/java/org/egov/hrms/utils/HRMSConstants.java

@@ -9,6 +9,10 @@ public class HRMSConstants {
 	public static final String HRMS_MDMS_HR_MASTERS_CODE = "egov-hrms";
 	public static final String HRMS_AC_ROLES_MASTERS_CODE = "ACCESSCONTROL-ROLES";
 	public static final String HRMS_MDMS_EGOV_LOCATION_MASTERS_CODE = "egov-location";
+
+	public static final String HRMS_IS_STATE_LEVEL_SEARCH_CODE = "isStateLevelSearch";
+
+	public  static final String HRMS_IS_ACTIVE_SEARCH_CODE="active";
 
 	public static final String HRMS_MDMS_DEPT_CODE = "Department";
 	public static final String HRMS_MDMS_DESG_CODE = "Designation";
@@ -41,6 +45,7 @@ public class HRMSConstants {
 	public static final String HRMS_USER_SEARCH_CRITERA_UUID = "uuid";
 	public static final String HRMS_USER_SEARCH_CRITERA_ROLECODES = "roleCodes";
 	public static final String HRMS_USER_SEARCH_CRITERA_TENANTID = "tenantId";
+	public static final String HRMS_USER_SEARCH_CRITERA_TENANTIDS = "tenantIds";
 	public static final String HRMS_USER_SEARCH_CRITERA_MOBILENO = "mobileNumber";
 	public static final String HRMS_USER_SEARCH_CRITERA_NAME = "name";
 	public static final String HRMS_USER_SEARCH_CRITERA_USERNAME = "UserName";

business-services/egov-hrms/src/main/java/org/egov/hrms/web/contract/EmployeeSearchByTenantRequestWrapper.java

@@ -0,0 +1,33 @@
+package org.egov.hrms.web.contract;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.egov.common.contract.request.RequestInfo;
+import org.egov.hrms.model.Employee;
+import org.hibernate.validator.constraints.NotEmpty;
+import org.springframework.validation.annotation.Validated;
+
+import javax.validation.Valid;
+import javax.validation.constraints.NotNull;
+import java.util.List;
+
+@Validated
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class EmployeeSearchByTenantRequestWrapper {
+    @NotNull
+    @JsonProperty("RequestInfo")
+    private RequestInfo requestInfo;
+
+    @Valid
+    @JsonProperty("criteria")
+    private EmployeeSearchCriteria criteria;
+
+}
+
+

business-services/egov-hrms/src/main/java/org/egov/hrms/web/contract/EmployeeSearchCriteria.java

@@ -47,8 +47,12 @@ public class EmployeeSearchCriteria {
 
 	public Boolean isActive;
 
+	public Boolean isStateLevelSearch;
+
 	@Size(max = 250)
 	public String tenantId;
+
+	public List<String> tenantIds;
 
 	public String phone;
 

business-services/egov-hrms/src/main/java/org/egov/hrms/web/controller/EmployeeController.java

@@ -43,10 +43,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.egov.common.contract.request.RequestInfo;
 import org.egov.hrms.service.EmployeeService;
-import org.egov.hrms.web.contract.EmployeeRequest;
-import org.egov.hrms.web.contract.EmployeeResponse;
-import org.egov.hrms.web.contract.EmployeeSearchCriteria;
-import org.egov.hrms.web.contract.RequestInfoWrapper;
+import org.egov.hrms.web.contract.*;
 import org.egov.hrms.web.validator.EmployeeValidator;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpStatus;
@@ -56,6 +53,7 @@
 
 import javax.validation.Valid;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 
 @Slf4j
@@ -120,6 +118,14 @@ public ResponseEntity<?> search(@RequestBody @Valid RequestInfoWrapper requestIn
 		return new ResponseEntity<>(employeeResponse,HttpStatus.OK);
 	}
 
+	@PostMapping(value = "/_searchListOfEmployee")
+	@ResponseBody
+	public ResponseEntity<?> _searchListOfEmployee(@RequestBody @Valid EmployeeSearchByTenantRequestWrapper employeeSearchByTenantRequestWrapper) {
+		EmployeeResponse employeeResponse = employeeService.searchListOfEmployee(employeeSearchByTenantRequestWrapper.getCriteria(), employeeSearchByTenantRequestWrapper.getRequestInfo());
+		return new ResponseEntity<>(employeeResponse,HttpStatus.OK);
+	}
+
+
 	@PostMapping("_count")
 	@ResponseBody
 	private ResponseEntity<?> count(@RequestParam("tenantId") String tenantId, @RequestBody RequestInfo requestInfo) {
@@ -130,5 +136,15 @@ private ResponseEntity<?> count(@RequestParam("tenantId") String tenantId, @Requ
 		return new ResponseEntity<>(response,HttpStatus.OK);
 	}
 
+	@PostMapping("v1/_count")
+	@ResponseBody
+	private ResponseEntity<?> countV1(@RequestParam("tenantId") String tenantId, @RequestParam("roles") List<String> roles , @RequestParam("isStateLevelSearch") boolean isStateLevelSearch,  @RequestBody RequestInfo requestInfo) {
+
+		Map<String,Object> response = new HashMap<>();
+		validator.validateEmployeeCountRequest(tenantId);
+		response = employeeService.getEmployeeCountResponseV1(requestInfo,roles,tenantId,isStateLevelSearch);
+		return new ResponseEntity<>(response,HttpStatus.OK);
+	}
+
 
 }

business-services/egov-hrms/src/main/java/org/egov/hrms/web/validator/EmployeeValidator.java

@@ -234,7 +234,7 @@ private void validateMdmsData(Employee employee, Map<String, String> errorMap, M
 		validateEmployee(employee, errorMap, mdmsData);
 		validateAssignments(employee, errorMap, mdmsData);
 		validateServiceHistory(employee, errorMap, mdmsData);
-		validateJurisdicton(employee, errorMap, mdmsData, boundaryMap);
+		//validateJurisdicton(employee, errorMap, mdmsData, boundaryMap);
 		validateEducationalDetails(employee, errorMap, mdmsData);
 		validateDepartmentalTest(employee, errorMap, mdmsData);
 	}
@@ -251,7 +251,7 @@ private void validateMdmsData(Employee employee, Map<String, String> errorMap, M
 	public void validateDataConsistency(Employee employee, Map<String, String> errorMap, Map<String, List<String>> mdmsData, Employee existingEmp, RequestInfo requestInfo) {
 		validateUserData(existingEmp,employee,errorMap, requestInfo);
 		validateConsistencyAssignment(existingEmp,employee,errorMap);
-		validateConsistencyJurisdiction(existingEmp,employee,errorMap);
+		//validateConsistencyJurisdiction(existingEmp,employee,errorMap);
 		validateConsistencyDepartmentalTest(existingEmp,employee,errorMap);
 		validateConsistencyEducationalDetails(existingEmp,employee,errorMap);
 		validateConsistencyServiceHistory(existingEmp, employee, errorMap);
@@ -465,12 +465,15 @@ private void validateJurisdicton(Employee employee, Map<String, String> errorMap
 				List<String>  hierarchyTypes = JsonPath.read(boundaryMap,hierarchy_type_path);
 				List <String> boundaryTypes = JsonPath.read(boundaryMap,boundary_type_path);
 				List <String> boundaryValues = JsonPath.read(boundaryMap,boundary_value_path);
-				if(!hierarchyTypes.contains(jurisdiction.getHierarchy()))
+				if(!hierarchyTypes.contains(jurisdiction.getHierarchy())) {
 					errorMap.put(ErrorConstants.HRMS_INVALID_JURISDICTION_HEIRARCHY_CODE, ErrorConstants.HRMS_INVALID_JURISDICTION_HEIRARCHY_MSG);
-				if(!boundaryTypes.contains(jurisdiction.getBoundaryType()))
+				}
+				if(!boundaryTypes.contains(jurisdiction.getBoundaryType())) {
 					errorMap.put(ErrorConstants.HRMS_INVALID_JURISDICTION_BOUNDARY_TYPE_CODE, ErrorConstants.HRMS_INVALID_JURISDICTION_BOUNDARY_TYPE_MSG);
-				if(!boundaryValues.contains(jurisdiction.getBoundary()))
+				}
+				if(!boundaryValues.contains(jurisdiction.getBoundary())) {
 					errorMap.put(ErrorConstants.HRMS_INVALID_JURISDICTION_BOUNDARY_CODE, ErrorConstants.HRMS_INVALID_JURISDICTION_BOUNDARY_MSG);
+				}
 			}
 
 

business-services/egov-hrms/src/main/resources/application.properties

@@ -30,6 +30,8 @@ egov.services.data_sync_employee.required = false
 egov.mdms.host=https://dev.digit.org
 egov.mdms.search.endpoint=/egov-mdms-service/v1/_search
 #egov.mdms.search.endpoint=/egov-mdms-service-test/v1/_search
+egov.mdms.search.endpoint.old= /egov-mdms-service/v1/_search
+egov.mdms.host.old=https://dev.digit.org
 
 #filestore urls
 egov.filestore.host=https://dev.digit.org
@@ -48,6 +50,7 @@ egov.environment.domain=https://dev.digit.org/
 #user
 egov.user.host=https://dev.digit.org
 egov.user.search.endpoint=/user/v1/_search
+egov.user.search.tenant.endpoint=/user/_searchByTenant
 egov.user.create.endpoint=/user/users/_createnovalidate
 egov.user.update.endpoint=/user/users/_updatenovalidate
 

core-services/egov-user/src/main/java/org/egov/user/config/UserServiceConstants.java

@@ -59,7 +59,7 @@ public class UserServiceConstants {
     public static final String PATTERN_GENDER = "^[a-zA-Z ]*$";
     public static final String PATTERN_MOBILE = "(^$|[0-9]{10})";
     public static final String PATTERN_CITY = "^[a-zA-Z. ]*$";
-    public static final String PATTERN_TENANT = "^[a-zA-Z. ]*$";
+    public static final String PATTERN_TENANT = "^[a-zA-Z.0-9 ]*$";
     public static final String PATTERN_PINCODE = "^[1-9][0-9]{5}$";
 }
 

core-services/egov-user/src/main/java/org/egov/user/domain/model/UserSearchCriteria.java

@@ -29,6 +29,8 @@ public class UserSearchCriteria {
     private List<String> sort;
     private UserType type;
     private String tenantId;
+    private List<String> tenantIds;
+    private Boolean isStateLevelSearch;
     private List<String> roleCodes;
 
     public void validate(boolean isInterServiceCall) {