WebSVN – SmartDukaan – Diff – /trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/UserController.java

 package com.spice.profitmandi.web.controller;
 import java.time.LocalDateTime;
+import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.function.Predicate;
 import javax.servlet.http.HttpServletRequest;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
+import com.eclipsesource.json.Json;
+import com.eclipsesource.json.JsonArray;
+import com.eclipsesource.json.JsonObject;
+import com.eclipsesource.json.JsonValue;
+import com.google.gson.Gson;
 import com.spice.profitmandi.common.ResponseCodeHolder;
+import com.spice.profitmandi.common.enumuration.SchemeType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.ProfitMandiResponse;
 import com.spice.profitmandi.common.model.ResponseStatus;
 import com.spice.profitmandi.common.model.UserInfo;
 import com.spice.profitmandi.common.util.JWTUtil;
+import com.spice.profitmandi.common.web.client.RestClient;
 import com.spice.profitmandi.common.web.util.ResponseSender;
 import com.spice.profitmandi.dao.entity.dtr.Permission;
 import com.spice.profitmandi.dao.entity.dtr.Retailer;
 import com.spice.profitmandi.dao.entity.dtr.Role;
 import com.spice.profitmandi.dao.entity.dtr.User;
 import com.spice.profitmandi.service.UserService;
 import com.spice.profitmandi.web.enumuration.UserStatus;
 import com.spice.profitmandi.web.processor.GoogleLoginProcessor;
 import com.spice.profitmandi.web.req.UserAddRoleRequest;
 import com.spice.profitmandi.web.req.UserRequest;
+import com.spice.profitmandi.web.res.DealObjectResponse;
+import com.spice.profitmandi.web.res.DealsResponse;
+import com.spice.profitmandi.web.res.Notification;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
 /**
 	@Autowired
 	ResponseSender<?> responseSender;
 	private static final Logger LOGGER = LoggerFactory.getLogger(UserController.class);
+	@Value("${notifications.api.host}")
+	private String nodeHost;
+	@Value("${notifications.api.port}")
+	private int nodePort;
 	@Value("${admin.token}")
 	private String validAdminToken;
 	@Autowired
 	UserRepository userRepository;
 	@Autowired
 	PermissionRepository permissionRepository;
 	@Autowired
 	GoogleLoginProcessor googleLoginProcessor;
 	@Autowired
 	UserToRetailerMigrationUtil userToRetailerMigrationUtil;
 	@Autowired
 	UserService userService;
 	@SuppressWarnings("unchecked")
 	@RequestMapping(value = ProfitMandiConstants.URL_USER_GOOGLE_LOGIN, method = RequestMethod.POST)
 			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
 	public ResponseEntity<?> tokenInfo(HttpServletRequest request) throws Throwable {
 		Map<String, Object> responseMap = new HashMap<>();
 		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
 		User user = null;
-		if(userInfo.getUserId()>-1){
+		if (userInfo.getUserId() > -1) {
 			user = userRepository.selectById(userInfo.getUserId());
 		} else {
 			try {
 				user = userRepository.selectByEmailId(userInfo.getEmail());
 			} catch (ProfitMandiBusinessException e1) {
+			}
+		}
 		if (user != null) {
 			responseMap.put(ProfitMandiConstants.EMAIL_ID, user.getEmailId());
 			responseMap.put(ProfitMandiConstants.USER_ID, user.getId());
 			Set<Role> roles = user.getRoles();
-			//generate new token if roles size is different
+			// generate new token if roles size is different
-			if(userInfo.getRoleNames() == null || roles.size() != userInfo.getRoleNames().size()) {
+			if (userInfo.getRoleNames() == null || roles.size() != userInfo.getRoleNames().size()) {
 				String[] roleTypes = new String[roles.size()];
 				int index = 0;
 				for (Role role : roles) {
 					roleTypes[index++] = role.getType().toString();
+				}
 				String newToken = JWTUtil.create(user.getId(), roleTypes);
 				responseMap.put("newAuthToken", newToken);
+			}
 			// if user is retailer
 			if (user.getRoles().stream().anyMatch(new Predicate<Role>() {
 				@Override
 				public boolean test(Role t) {
 					return t.getType().equals(RoleType.RETAILER);
+				}
 			})) {
-				UserCart uc  = userAccountRepository.getUserCart(userInfo.getUserId());
+				UserCart uc = userAccountRepository.getUserCart(userInfo.getUserId());
-				Retailer retailer  = retailerRepository.selectById(uc.getUserId());
+				Retailer retailer = retailerRepository.selectById(uc.getUserId());
 				// if retailer is activated 1 then verified retailer
 				// else if migrated is 1 then old retailer
 				// else retailer is not verifed
 				if (retailer.isActive()) {
 					responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.VERIFIED_RETAILER.getValue());
-				} else if (retailer.isMigrated()){
+				} else if (retailer.isMigrated()) {
 					responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.RETAILER.getValue());
 				} else {
 					responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.NOT_VERIFIED_RETAILER.getValue());
+				}
 			} else if (user.getRoles().stream().anyMatch(new Predicate<Role>() {
+			}
 		} else {
 			responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.NOT_REGISTERED.getValue());
 			responseMap.put(ProfitMandiConstants.EMAIL_ID, userInfo.getEmail());
+		}
 		return responseSender.ok(responseMap);
+	}
 	@RequestMapping(value = ProfitMandiConstants.URL_USER, method = RequestMethod.POST)
 	@ApiImplicitParams({
-		@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
+			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
-	public ResponseEntity<?> createUser(HttpServletRequest request, @RequestBody UserRequest userRequest) throws Throwable{
+	public ResponseEntity<?> createUser(HttpServletRequest request, @RequestBody UserRequest userRequest)
+			throws Throwable {
 		LOGGER.info("requested url : " + request.getRequestURL().toString());
 		User user = new User();
 		user.setFirstName(userRequest.getFirstName());
 		user.setLastName(userRequest.getLastName());
 		user.setCity(userRequest.getCity());
 		user.setGroup_id(1);
 		user.setStatus(0);
 		user.setActivated(false);
 		user.setCreateTimestamp(LocalDateTime.now());
 		user.setUpdateTimestamp(LocalDateTime.now());
-		try{
+		try {
 			userRepository.persist(user);
 			UserRole userRole = new UserRole();
 			userRole.setRoleId(RoleType.USER.getValue());
 			userRole.setUserId(user.getId());
 			return responseSender.badRequest(profitMandiBusinessException);
+		}
+	}
 	@RequestMapping(value = ProfitMandiConstants.URL_USER_ALL, method = RequestMethod.GET)
+	public ResponseEntity<?> getAll(HttpServletRequest request,
-	public ResponseEntity<?> getAll(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.PAGE_NUMBER) int pageNumber, @RequestParam(name = ProfitMandiConstants.PAGE_SIZE) int pageSize) {
+			@RequestParam(name = ProfitMandiConstants.PAGE_NUMBER) int pageNumber,
+			@RequestParam(name = ProfitMandiConstants.PAGE_SIZE) int pageSize) {
 		LOGGER.info("requested url : " + request.getRequestURL().toString());
 		return responseSender.ok(userRepository.selectAll(pageNumber, pageSize));
+	}
 	@RequestMapping(value = ProfitMandiConstants.URL_USER_ID, method = RequestMethod.GET)
 		} catch (ProfitMandiBusinessException profitMandiBusinessException) {
 			LOGGER.error("ProfitMandi error: ", profitMandiBusinessException);
 			return responseSender.badRequest(profitMandiBusinessException);
+		}
+	}
 	@ApiImplicitParams({
 			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
 	@RequestMapping(value = ProfitMandiConstants.URL_USER_ACTIVATE, method = RequestMethod.POST)
 	public ResponseEntity<?> activateUser(HttpServletRequest request,
 			@RequestParam(name = "activationCode") String activationCode) throws Throwable {
-		int userId = (int)request.getAttribute("userId");
+		int userId = (int) request.getAttribute("userId");
 		UserCart uc = userAccountRepository.getUserCart(userId);
 		return responseSender.ok(userService.updateActivation(userId, uc.getUserId(), activationCode));
+	}
+	@ApiImplicitParams({
+			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
+	@RequestMapping(value = ProfitMandiConstants.URL_USER_NOTIFICATIONS, method = RequestMethod.GET)
+	public ResponseEntity<?> getNofitications(HttpServletRequest request,
+			@RequestParam(name = "androidId") String androidId, @RequestParam(name = "pageNumber") int pageNumber,
+			@RequestParam(name = "pageSize") int pageSize) throws Throwable {
+		int userId = (int) request.getAttribute("userId");
+		String restResponse = null;
+		Map<String, String> params = new HashMap<>();
+		String uri = "/getAllNotifications";
+		params.put("user_id", userId + "");
+		params.put("android_id", androidId);
+		params.put("limit", pageSize + "");
+		params.put("offset", "" + ((pageNumber - 1) * pageSize));
+		try {
+			RestClient rc = new RestClient(SchemeType.HTTP, nodeHost, nodePort);
+			restResponse = rc.get(uri, params);
+		} catch (Exception | ProfitMandiBusinessException e) {
+			LOGGER.error("Unable to data from node server", e);
+			return responseSender.internalServerError(e);
+		}
+		JsonArray result_json = Json.parse(restResponse).asArray();
+		List<Notification> notifications = new ArrayList<>();
+		for (JsonValue j : result_json) {
+			notifications.add(toNotifiaction(j.asObject()));
+		}
+		return responseSender.ok(notifications);
+	}
+	private Notification toNotifiaction(JsonObject jsonObject) {
+		Notification n = (Notification) (new Gson().fromJson(jsonObject.toString(), Notification.class));
+		if(n.getStatus().equals("opened") || n.getStatus().equals("referrer") || n.getStatus().equals("seen") ) {
+			n.setSeen(true);
+		}
+		return n;
+	}
 	@RequestMapping(value = ProfitMandiConstants.URL_USER_IS_EXIST_MOBILE_NUMBER, method = RequestMethod.GET)
 	public ResponseEntity<?> isMobileNumberExist(HttpServletRequest request,
 			@RequestParam(name = "mobileNumber") String mobileNumber) {
 		LOGGER.info("requested url : " + request.getRequestURL().toString());
 		return responseSender.ok(userRepository.isExistByMobileNumber(mobileNumber));
 			responseMap.put(ProfitMandiConstants.REGISTERED, false);
+		}
 		return responseSender.ok(responseMap);
+	}
 	@RequestMapping(value = ProfitMandiConstants.URL_ADMIN_MIGRATE, method = RequestMethod.GET)
 	public ResponseEntity<?> migrate(HttpServletRequest request) {
 		LOGGER.info("requested url : " + request.getRequestURL().toString());
 		userToRetailerMigrationUtil.migrate();
 		return responseSender.ok(ResponseCodeHolder.getMessage("OK_1000"));

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/UserController.java – Rev 21784 → 21855