Subversion Repositories SmartDukaan

package com.spice.profitmandi.dao.repository.cs;

import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
import com.spice.profitmandi.common.model.CustomRetailer;
import com.spice.profitmandi.dao.entity.auth.AuthUser;
import com.spice.profitmandi.dao.entity.cs.Activity;
import com.spice.profitmandi.dao.entity.cs.PartnerRegion;
import com.spice.profitmandi.dao.entity.cs.Position;
import com.spice.profitmandi.dao.entity.cs.Ticket;
import com.spice.profitmandi.dao.entity.cs.TicketSubCategory;
import com.spice.profitmandi.dao.entity.fofo.ActivityType;
import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
import com.spice.profitmandi.service.user.RetailerService;

@Component
public class CsServiceImpl implements CsService {

        @Autowired
        TicketRepository ticketRepository;

        @Autowired
        TicketCategoryRepository ticketCategoryRepository;

        @Autowired
        TicketSubCategoryRepository ticketSubCategoryRepository;

        @Autowired
        ActivityRepository activityRepository;

        @Autowired
        PartnerRegionRepository partnerRepository;

        @Autowired
        private PositionRepository positionRepository;

        @Autowired
        private AuthRepository authRepository;

        @Autowired
        private RetailerService retailerService;

        @Override
        public void createTicket(int fofoId, int categoryId, int subcategoryId, String message) {

                ActivityType type = ActivityType.OPENED;
                EscalationType escalationType = EscalationType.L1;
                Ticket ticket = new Ticket();
                ticket.setSubCategoryId(subcategoryId);
                ticket.setFofoId(fofoId);
                ticket.setCreateTimestamp(LocalDateTime.now());
                ticket.setUpdateTimestamp(LocalDateTime.now());
                try {
                        ticket.setAssigneeId(this.getAssigneeId(categoryId, escalationType));
                } catch (Exception e) {
                        e.printStackTrace();
                }
                ticketRepository.persist(ticket);
                Activity activity = this.createActivity(type, message, 0);
                this.addActivity(ticket.getId(), activity);
        }

        private Activity createActivity(ActivityType activityType, String message, int createdBy) {
                Activity activity = new Activity();
                activity.setMessage(message);
                activity.setCreatedBy(createdBy);
                activity.setType(activityType);
                activity.setCreateTimestamp(LocalDateTime.now());
                return activity;
        }

        private int getAssigneeId(int categoryId, EscalationType escalationType) throws ProfitMandiBusinessException {

                Position position = positionRepository.selectPositionbyCategoryIdAndEscalationType(categoryId, escalationType);
                return position.getAuthUserId();
                /*
                 * if(ActivityType.escalationTypes.contains(escalationType)) {
                 * //escalationMatrix } else { throw new
                 * ProfitMandiBusinessException("SubCategory", subcategoryId,
                 * "Could not find Assignee for "); }
                 */
        }

        @Override
        public void addActivity(int ticketId, Activity activity) {
                activity.setTicketId(ticketId);
                activityRepository.persist(activity);
        }

        @Override
        public void addPartnerToRegion(int regionId, List<Integer> fofoIds) {

                for (Integer fofoId : fofoIds) {
                        PartnerRegion partnerRegion = partnerRepository.selectByRegionIdAndFofoId(regionId, fofoId);
                        if (partnerRegion == null) {
                                partnerRegion = new PartnerRegion();
                                partnerRegion.setFofoId(fofoId);
                                partnerRegion.setRegionId(regionId);
                                partnerRepository.persist(partnerRegion);
                        } else {
                                continue;
                        }
                }
        }

        @Override
        public Map<Integer, AuthUser> getAuthUserIdAndAuthUserMap(List<Ticket> tickets) {
                Map<Integer, AuthUser> authUserIdAndAuthUserMap = new HashMap<>();
                for (Ticket ticket : tickets) {
                        AuthUser authUser = authRepository.selectById(ticket.getAssigneeId());
                        authUserIdAndAuthUserMap.put(ticket.getAssigneeId(), authUser);
                }
                return authUserIdAndAuthUserMap;
        }

        @Override
        public Map<Integer, TicketSubCategory> getSubCategoryIdAndSubCategoryMap(List<Ticket> tickets) {
                Map<Integer, TicketSubCategory> subCategoryIdAndSubCategoryMap = new HashMap<>();
                for (Ticket ticket : tickets) {
                        TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());
                        subCategoryIdAndSubCategoryMap.put(ticket.getSubCategoryId(), ticketSubCategory);
                }
                return subCategoryIdAndSubCategoryMap;
        }

        @Override
        public Map<Integer, CustomRetailer> getPartnerByFofoIds(List<Ticket> tickets) {
                List<Integer> fofoIds = new ArrayList<>();
                for (Ticket ticket : tickets) {
                        fofoIds.add(ticket.getFofoId());
                }
                Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = retailerService.getFofoRetailers(fofoIds);

                return fofoIdsAndCustomRetailer;
        }

}