Subversion Repositories SmartDukaan

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

import com.spice.profitmandi.dao.entity.fofo.FofoStore;

    @PostMapping(value = "/partner-position/update")

    public String positionUpdated(Model model, @RequestBody List<PartnerPositonUpdateModel> partnerPositionUpdateModels)

            throws Exception {

        Map<Integer, List<String>> positionIdsToAddMap = partnerPositionUpdateModels.stream().collect(Collectors.groupingBy(x->x.getPositionIdTo(),

                Collectors.mapping(x->x.getStoreCode(), Collectors.toList())));

        Map<Integer, List<String>> positionIdsToRemoveMap = partnerPositionUpdateModels.stream().collect(Collectors.groupingBy(x->x.getPositionIdFrom(),

                Collectors.mapping(x->x.getStoreCode(), Collectors.toList())));

        List<Integer> positionIdsToUpdate = new ArrayList<>();

        positionIdsToUpdate.addAll(positionIdsToAddMap.keySet());

        positionIdsToUpdate.addAll(positionIdsToRemoveMap.keySet());

        Map<Integer, Position> positionsToUpdateMap =  positionRepository.selectAll(positionIdsToUpdate).stream().collect(Collectors.toMap(x->x.getId(), x->x));

        List<Integer> invalidPositionIds = positionsToUpdateMap.values().stream().filter(x-> x.getCategoryId()!= ProfitMandiConstants.TICKET_CATEGORY_RBM

                && x.getCategoryId()!= ProfitMandiConstants.TICKET_CATEGORY_SALES).map(x->x.getId()).collect(Collectors.toList());

        if(invalidPositionIds.size() > 0) {

            String message = "Non RBM/Sales are not allowed - " + invalidPositionIds;

            throw new ProfitMandiBusinessException(message, message, message);

        }

        for (Map.Entry<Integer, List<String>> positionIdStoreMapEntry : positionIdsToAddMap.entrySet()) {

            int positionId = positionIdStoreMapEntry.getKey();

            Position position = positionsToUpdateMap.get(positionId);

            List<String> storeCodesToAdd = positionIdStoreMapEntry.getValue();

            List<Integer> retailerIdsToAdd = fofoStoreRepository.selectByStoreCodes(storeCodesToAdd).stream().map(x->x.getId()).collect(Collectors.toList());

            Map<Integer, PartnerPosition> partnerPositionsMapByFofoId  = partnerPositionRepository

                    .selectByRegionIdAndPostionId(Arrays.asList(position.getRegionId()),Arrays.asList(positionId)).stream().collect(Collectors.toMap(x->x.getFofoId(),x->x));

            for (Integer retailerIdToAdd : retailerIdsToAdd) {

                if (!partnerPositionsMapByFofoId.containsKey(retailerIdToAdd)) {

                    PartnerPosition partnerPositionNew = new PartnerPosition();

                    partnerPositionNew.setPositionId(positionId);

                    partnerPositionNew.setFofoId(retailerIdToAdd);

                    partnerPositionNew.setRegionId(position.getRegionId());

                }

            }

        }

        for (Map.Entry<Integer, List<String>> positionIdStoreMapEntry : positionIdsToRemoveMap.entrySet()) {

            int positionId = positionIdStoreMapEntry.getKey();

            Position position = positionsToUpdateMap.get(positionId);

            List<String> storeCodesToRemove = positionIdStoreMapEntry.getValue();

            List<Integer> retailerIdsToRemove = fofoStoreRepository.selectByStoreCodes(storeCodesToRemove).stream().map(x->x.getId()).collect(Collectors.toList());

            Map<Integer, PartnerPosition> partnerPositionsMapByFofoId  = partnerPositionRepository

                    .selectByRegionIdAndPostionId(Arrays.asList(position.getRegionId()),Arrays.asList(positionId)).stream().collect(Collectors.toMap(x->x.getFofoId(),x->x));

            for (Integer retailerIdToRemove : retailerIdsToRemove) {

                if (partnerPositionsMapByFofoId.containsKey(retailerIdToRemove)) {

                   PartnerPosition partnerPositionToRemove =  partnerPositionsMapByFofoId.get(retailerIdToRemove);

                   partnerPositionRepository.delete(partnerPositionToRemove);

                }

            }

        }

        /*partnerPositionUpdateModels.str

        Map<Integer, Position> positionIdMap = positionsToUpdate.stream().collect(Collectors.toMap(x->x.getId(), x->x));

        for (PartnerPositonUpdateModel partnerPositionUpdateModel : partnerPositionUpdateModels) {

            FofoStore fofoStore = fofoStoreRepository.selectByStoreCode(partnerPositionUpdateModel.getStoreCode());

            Position positionFrom = positionIdMap.get(partnerPositionUpdateModel.getPositionIdFrom());

            Position positionTo = positionIdMap.get(partnerPositionUpdateModel.getPositionIdTo());

            if(positionFrom != null) {

                partnerPositionRepository.selectByRegionIdAndPostionId(Arrays.)

              int regionId = positionFrom.getRegionId()

            }

            if(positionTo != null) {

            }

        }*/

        model.addAttribute("response1", mvcResponseSender.createResponseString(true));

        return "response";

    }