Subversion Repositories SmartDukaan

import java.time.LocalDateTime;

import java.util.Arrays;

import java.util.Set;

import org.springframework.ui.Model;

import com.spice.profitmandi.common.enumuration.MessageType;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.model.CustomRetailer;

import com.spice.profitmandi.common.model.SendNotificationModel;

import com.spice.profitmandi.dao.entity.auth.AuthUser;

import com.spice.profitmandi.dao.entity.catalog.FocusedModelByPassRequest;

import com.spice.profitmandi.dao.entity.cs.Position;

import com.spice.profitmandi.dao.entity.dtr.User;

import com.spice.profitmandi.dao.enumuration.catalog.ByPassRequestStatus;

import com.spice.profitmandi.dao.enumuration.cs.EscalationType;

import com.spice.profitmandi.dao.repository.auth.AuthRepository;

import com.spice.profitmandi.dao.repository.catalog.FocusedModelByPassRepository;

import com.spice.profitmandi.dao.repository.cs.CsService;

import com.spice.profitmandi.dao.repository.cs.PositionRepository;

import com.spice.profitmandi.dao.repository.dtr.UserRepository;

import com.spice.profitmandi.service.FofoUser;

import com.spice.profitmandi.service.NotificationService;

import com.spice.profitmandi.service.PartnerInvestmentService;

import com.spice.profitmandi.service.inventory.ByPassRequestModel;

import com.spice.profitmandi.service.user.RetailerService;

	@Autowired

	private UserRepository userRepository;

	@Autowired

	private AuthRepository authRepository;

	@Autowired

	private CsService csService;

	@Autowired

	private PositionRepository positionRepository;

	@Autowired

	private FocusedModelByPassRepository focusedModelByPassRepository;

	@Autowired

	private RetailerService retailerService;

	@Autowired

	private PartnerInvestmentService partnerInvestmentService;

	@Autowired

	private FofoUser fofoUser;

	@Autowired

	private NotificationService notificationService;

	List<EscalationType> esclationType = Arrays.asList(EscalationType.L3, EscalationType.L4);

	List<String> emails = Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com");

	@RequestMapping(value = "/planogram", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	@ApiImplicitParams({

			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })

	@ApiOperation(value = "planogram")

	public ResponseEntity<?> Planogram(HttpServletRequest request, Model model) throws Exception {

		int userId = (int) request.getAttribute("userId");

		logger.info(" userId" + userId);

		User user = userRepository.selectById(39411);

		logger.info(" user" + user);

		AuthUser authUser = authRepository.selectByEmailOrMobile(user.getEmailId());

		logger.info("authUser" + authUser);

		List<FocusedModelByPassRequest> byPassRequests = null;

		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();

		Set<Integer> authfofoIds = null;

		List<Position> positions = positionRepository.selectPositionByAuthId(authUser.getId());

		if (emails.contains(authUser.getEmailId())) {

			authfofoIds = storeGuyMap.get("tarun.verma@smartdukaan.com");

			logger.info("authfofoeIds" + authfofoIds);

		} else {

			for (Position ps : positions) {

				if (esclationType.contains(ps.getEscalationType())) {

					authfofoIds = storeGuyMap.get(user.getEmailId());

					logger.info("authfofoIdsw" + authfofoIds);

					break;

				}

			}

		}

		logger.info("authfofoIds" + authfofoIds);

		if (authfofoIds != null) {

			byPassRequests = focusedModelByPassRepository.selectByStatusAndFofoIds(new ArrayList<>(authfofoIds),

					ByPassRequestStatus.PENDING);

		}

		Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();

		List<ByPassRequestModel> byPassList = new ArrayList<>();

		for (FocusedModelByPassRequest byPassRequest : byPassRequests) {

			Map<String, Object> investments = fofoUser.getInvestments(byPassRequest.getFofoId());

			ByPassRequestModel bp = new ByPassRequestModel();

			bp.setPartnerName(customRetailerMap.get(byPassRequest.getFofoId()).getBusinessName());

			bp.setCity(customRetailerMap.get(byPassRequest.getFofoId()).getAddress().getCity());

			bp.setState(customRetailerMap.get(byPassRequest.getFofoId()).getAddress().getState());

			bp.setCode(customRetailerMap.get(byPassRequest.getFofoId()).getCode());

			bp.setStatus(byPassRequest.getStatus());

			bp.setFofoId(byPassRequest.getFofoId());

			bp.setByPassRequestId(byPassRequest.getId());

			bp.setInvestmentOkDays((Long) investments.get("okDays"));

			bp.setInvestmentShort((int) investments.get("short"));

			bp.setMobileNumber(customRetailerMap.get(byPassRequest.getFofoId()).getMobileNumber());

			bp.setCreateTimestamp(byPassRequest.getCreatedTimeStamp());

			bp.setUpdateTimestamp(byPassRequest.getUpdatedTimestamp());

			byPassList.add(bp);

		}

		return responseSender.ok(byPassList);

	}

	@RequestMapping(value = "/byPassRequestAction", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)

	@ApiImplicitParams({

			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })

	@ApiOperation(value = "Add items to cart")

	public ResponseEntity<?> addAmountToWalletRequestRejected(HttpServletRequest request,

			@RequestParam(name = "id", defaultValue = "0") int id, @RequestParam ByPassRequestStatus status,

			Model model) throws Exception {

		FocusedModelByPassRequest byPassRequest = focusedModelByPassRepository.selectById(id);

		if (status.equals(ByPassRequestStatus.APPROVED)) {

			byPassRequest.setByPass(true);

			byPassRequest.setStatus(ByPassRequestStatus.APPROVED);

			byPassRequest.setUpdatedTimestamp(LocalDateTime.now());

		} else if (status.equals(ByPassRequestStatus.REJECTED)) {

			byPassRequest.setByPass(false);

			byPassRequest.setStatus(ByPassRequestStatus.REJECTED);

			byPassRequest.setUpdatedTimestamp(LocalDateTime.now());

		}

		SendNotificationModel sendNotificationModel = new SendNotificationModel();

		sendNotificationModel.setCampaignName("Billing Request");

		sendNotificationModel.setTitle("Billing Request");

		sendNotificationModel.setMessage(String.format("Your Billing  Request is " + " " + status

				+ "Please ensure to order the missing focus models as soon as possible"));

		sendNotificationModel.setType("url");

		sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");

		sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));

		sendNotificationModel.setMessageType(MessageType.notification);

		sendNotificationModel

				.setUserIds(Arrays.asList(userAccountRepository.selectUserIdByRetailerId(byPassRequest.getFofoId())));

		notificationService.sendNotification(sendNotificationModel);

		return responseSender.ok(true);

	}