Subversion Repositories SmartDukaan

Rev

Rev 35607 | Rev 35626 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
24417 govind 1
package com.spice.profitmandi.web.controller;
2
 
3
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
4
import com.spice.profitmandi.common.model.CustomRetailer;
32812 shampa 5
import com.spice.profitmandi.common.model.ProfitMandiConstants;
24620 govind 6
import com.spice.profitmandi.common.util.Utils;
24417 govind 7
import com.spice.profitmandi.dao.entity.auth.AuthUser;
27690 amit.gupta 8
import com.spice.profitmandi.dao.entity.cs.*;
27270 tejbeer 9
import com.spice.profitmandi.dao.entity.dtr.Document;
24417 govind 10
import com.spice.profitmandi.dao.entity.fofo.ActivityType;
11
import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
24699 govind 12
import com.spice.profitmandi.dao.enumuration.cs.TicketStatus;
25570 tejbeer 13
import com.spice.profitmandi.dao.model.CreatePositionModel;
24417 govind 14
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
27690 amit.gupta 15
import com.spice.profitmandi.dao.repository.cs.*;
27270 tejbeer 16
import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
25570 tejbeer 17
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
24417 govind 18
import com.spice.profitmandi.service.authentication.RoleManager;
19
import com.spice.profitmandi.service.user.RetailerService;
20
import com.spice.profitmandi.web.model.LoginDetails;
21
import com.spice.profitmandi.web.util.CookiesProcessor;
22
import com.spice.profitmandi.web.util.MVCResponseSender;
27690 amit.gupta 23
import org.apache.logging.log4j.LogManager;
24
import org.apache.logging.log4j.Logger;
25
import org.springframework.beans.factory.annotation.Autowired;
26
import org.springframework.mail.javamail.JavaMailSender;
27
import org.springframework.stereotype.Controller;
28
import org.springframework.transaction.annotation.Transactional;
29
import org.springframework.ui.Model;
30
import org.springframework.web.bind.annotation.*;
24417 govind 31
 
27690 amit.gupta 32
import javax.servlet.http.HttpServletRequest;
35571 amit 33
import javax.swing.SortOrder;
27690 amit.gupta 34
import java.time.LocalDateTime;
35
import java.util.*;
36
import java.util.stream.Collectors;
37
 
24417 govind 38
@Controller
39
@Transactional(rollbackFor = Throwable.class)
40
public class CsController {
41
 
31762 tejbeer 42
    private static final Logger LOGGER = LogManager.getLogger(CsController.class);
43
    private static final String ACTIVITY_SUBJECT = "Message related ticketId#%s";
44
    private static final String PARTNER_RESOLVED_TICKET_MAIL = "Dear Partner , we have resolved your ticket # %s , request to kindly accept the same. In case you still have any concerns regarding the same pls click on %s so that we can help you.Regards\nSmartdukaan";
45
    private static final String PARTNER_REOPEN = "Dear Partner , Your ticket # %s has been re-opened as per your confirmation & we are committed to resolve it on priority.Regards\nSmartdukaan";
46
    private static final String INTERNAL_REOPEN_MAIL = "Team, Pls note that the Ticket Id %s has been re-opened by %s , pls respond on priority";
47
    private static final String INTERNAL_REOPEN_ACTIVITY_MESSAGE = "Hi,My ticket is not resolved yet,so I have reopened it";
24699 govind 48
 
31762 tejbeer 49
    @Autowired
50
    JavaMailSender mailSender;
24620 govind 51
 
31762 tejbeer 52
    @Autowired
53
    private CsService csService;
24417 govind 54
 
31762 tejbeer 55
    @Autowired
56
    private CookiesProcessor cookiesProcessor;
24417 govind 57
 
31762 tejbeer 58
    @Autowired
59
    private TicketCategoryRepository ticketCategoryRepository;
24417 govind 60
 
31762 tejbeer 61
    @Autowired
62
    private TicketSubCategoryRepository ticketSubCategoryRepository;
24417 govind 63
 
31762 tejbeer 64
    @Autowired
65
    private RegionRepository regionRepository;
24417 govind 66
 
31762 tejbeer 67
    @Autowired
68
    private RetailerService retailerService;
24417 govind 69
 
31762 tejbeer 70
    @Autowired
71
    private MVCResponseSender mvcResponseSender;
24417 govind 72
 
31762 tejbeer 73
    @Autowired
74
    private AuthRepository authRepository;
24417 govind 75
 
31762 tejbeer 76
    @Autowired
77
    private PositionRepository positionRepository;
24417 govind 78
 
31762 tejbeer 79
    @Autowired
80
    private TicketRepository ticketRepository;
24417 govind 81
 
31762 tejbeer 82
    @Autowired
83
    private RoleManager roleManager;
24417 govind 84
 
31762 tejbeer 85
    @Autowired
86
    private ActivityRepository activityRepository;
24417 govind 87
 
31762 tejbeer 88
    @Autowired
89
    private ActivityAttachmentRepository activityAttachmentRepository;
27270 tejbeer 90
 
31762 tejbeer 91
    @Autowired
92
    private TicketAssignedRepository ticketAssignedRepository;
24569 govind 93
 
31762 tejbeer 94
    @Autowired
95
    private PartnerRegionRepository partnerRegionRepository;
24500 govind 96
 
31762 tejbeer 97
    @Autowired
32493 amit.gupta 98
    PartnerPositionRepository partnerPositionRepository;
25570 tejbeer 99
 
31762 tejbeer 100
    @Autowired
101
    FofoStoreRepository fofoStoreRepository;
25570 tejbeer 102
 
31762 tejbeer 103
    @Autowired
104
    DocumentRepository documentRepository;
27270 tejbeer 105
 
31762 tejbeer 106
    @GetMapping(value = "/cs/createCategory")
107
    public String getCreateCategory(HttpServletRequest request, Model model) {
108
        List<TicketCategory> ticketCategories = ticketCategoryRepository.selectAll();
109
        model.addAttribute("ticketCategories", ticketCategories);
110
        return "create-ticket-category";
111
    }
24417 govind 112
 
31762 tejbeer 113
    @PostMapping(value = "/cs/createCategory")
33081 ranu 114
    public String createCategory(HttpServletRequest request,
115
                                 @RequestParam(name = "name") String name,
116
                                 @RequestParam(name = "categoryType") int categoryType,
117
                                 @RequestParam(name = "description") String description,
118
                                 Model model) throws ProfitMandiBusinessException {
31762 tejbeer 119
        TicketCategory ticketCategory = ticketCategoryRepository.selectByName(name);
120
        if (ticketCategory != null) {
121
            throw new ProfitMandiBusinessException("name", name, "already exists!");
122
        }
33081 ranu 123
 
31762 tejbeer 124
        ticketCategory = new TicketCategory();
125
        ticketCategory.setName(name);
126
        ticketCategory.setDescription(description);
33081 ranu 127
 
128
        ticketCategory.setCategoryType(categoryType == 1);
31762 tejbeer 129
        ticketCategoryRepository.persist(ticketCategory);
130
        return "create-ticket-category";
131
    }
24417 govind 132
 
33081 ranu 133
 
31762 tejbeer 134
    @GetMapping(value = "/cs/createSubCategory")
135
    public String getCreateSubCategory(HttpServletRequest request, Model model) {
136
        List<TicketCategory> ticketCategories = ticketCategoryRepository.selectAll();
137
        model.addAttribute("ticketCategories", ticketCategories);
138
        return "create-ticket-sub-category";
139
    }
24417 govind 140
 
31762 tejbeer 141
    @GetMapping(value = "/cs/getSubCategoryByCategoryId")
142
    public String getSubCategoryByCategoryId(HttpServletRequest request, @RequestParam(name = "ticketCategoryId", defaultValue = "") int ticketCategoryId, Model model) {
143
        List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAll(ticketCategoryId);
144
        TicketCategory ticketCategory = ticketCategoryRepository.selectById(ticketCategoryId);
33081 ranu 145
        LOGGER.info("ticketSubCategories {}", ticketSubCategories);
146
        LOGGER.info("ticketCategory {}", ticketCategory);
31762 tejbeer 147
        model.addAttribute("ticketSubCategories", ticketSubCategories);
148
        model.addAttribute("ticketCategory", ticketCategory);
149
        return "ticket-sub-category";
150
    }
24417 govind 151
 
31762 tejbeer 152
    @PostMapping(value = "/cs/createSubCategory")
153
    public String createSubCategory(HttpServletRequest request, @RequestParam(name = "categoryId", defaultValue = "0") int categoryId, @RequestParam(name = "name") String name, @RequestParam(name = "description") String description, Model model) throws ProfitMandiBusinessException {
24417 govind 154
 
31762 tejbeer 155
        TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectTicketSubCategory(categoryId, name);
156
        if (ticketSubCategory != null) {
157
            throw new ProfitMandiBusinessException("name & categoryId", name + "  " + categoryId, "already exists!");
158
        }
24417 govind 159
 
31762 tejbeer 160
        ticketSubCategory = new TicketSubCategory();
161
        ticketSubCategory.setCategoryId(categoryId);
162
        ticketSubCategory.setName(name);
163
        ticketSubCategory.setDescription(description);
164
        ticketSubCategoryRepository.persist(ticketSubCategory);
165
        return "create-ticket-sub-category";
166
    }
24417 govind 167
 
31762 tejbeer 168
    @GetMapping(value = "/cs/createRegion")
169
    public String createRegion(HttpServletRequest request, Model model) {
170
        List<Region> regions = regionRepository.selectAll();
171
        model.addAttribute("regions", regions);
172
        return "create-region";
173
    }
24417 govind 174
 
31762 tejbeer 175
    @PostMapping(value = "/cs/createRegion")
176
    public String createRegion(HttpServletRequest request, @RequestParam(name = "name") String name, @RequestParam(name = "description") String description, Model model) throws Exception {
177
        Region region = regionRepository.selectByName(name);
178
        if (region != null) {
179
            throw new ProfitMandiBusinessException("name", name, "already exists!");
180
        }
181
        region = new Region();
182
        region.setName(name);
183
        region.setDescription(description);
184
        regionRepository.persist(region);
185
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
186
        return "response";
187
    }
24417 govind 188
 
31762 tejbeer 189
    @GetMapping(value = "/cs/getPartners")
33244 ranu 190
    public String getPartners(HttpServletRequest request, @RequestParam(name = "regionId", defaultValue = "0") int regionId, Model model) throws ProfitMandiBusinessException {
31762 tejbeer 191
        List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().map(x -> x.getId()).collect(Collectors.toList());
192
        List<Integer> addedfofoIds = partnerRegionRepository.selectByRegionId(regionId).stream().map(x -> x.getFofoId()).collect(Collectors.toList());
30426 tejbeer 193
 
31762 tejbeer 194
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
195
        Map<Integer, CustomRetailer> fofoRetailers = fofoIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
196
        model.addAttribute("fofoRetailers", fofoRetailers);
197
        model.addAttribute("addedfofoIds", addedfofoIds);
198
        return "added-region-partners";
199
    }
24569 govind 200
 
31762 tejbeer 201
    @GetMapping(value = "/cs/getPartnersByRegion")
33244 ranu 202
    public String getPartnersByRegion(HttpServletRequest request, @RequestParam(name = "regionId", defaultValue = "0") int regionId, Model model) throws ProfitMandiBusinessException {
31762 tejbeer 203
        List<Integer> fofoIds = null;
204
        fofoIds = partnerRegionRepository.selectByRegionId(regionId).stream().map(x -> x.getFofoId()).collect(Collectors.toList());
25570 tejbeer 205
 
31762 tejbeer 206
        if (fofoIds.contains(0)) {
207
            fofoIds = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive()).collect(Collectors.toList()).stream().map(x -> x.getId()).collect(Collectors.toList());
25570 tejbeer 208
 
31762 tejbeer 209
        }
210
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
25570 tejbeer 211
 
31762 tejbeer 212
        Map<Integer, CustomRetailer> fofoRetailers = fofoIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
213
        model.addAttribute("fofoRetailers", fofoRetailers);
214
        return "added-subregion-partners";
215
    }
25570 tejbeer 216
 
31762 tejbeer 217
    @GetMapping(value = "/cs/createPartnerRegion")
218
    public String createPartnerRegion(HttpServletRequest request, Model model) {
219
        List<Region> regions = regionRepository.selectAll();
220
        model.addAttribute("regions", regions);
221
        return "create-partner-region";
222
    }
24417 govind 223
 
31762 tejbeer 224
    @PostMapping(value = "/cs/createPartnerRegion")
225
    public String createPartnerRegion(HttpServletRequest request, @RequestParam(name = "regionId") int regionId, @RequestBody List<Integer> selectedFofoIds, Model model) throws Exception {
226
        partnerRegionRepository.delete(regionId);
227
        LOGGER.info("successfully removed");
228
        LOGGER.info(selectedFofoIds.size());
229
        csService.addPartnerToRegion(regionId, selectedFofoIds);
230
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
231
        return "response";
232
    }
24417 govind 233
 
31762 tejbeer 234
    @GetMapping(value = "/cs/getPosition")
33244 ranu 235
    public String getPosition(HttpServletRequest request, @RequestParam int positionId, Model model) throws ProfitMandiBusinessException {
27410 tejbeer 236
 
31762 tejbeer 237
        Position position = positionRepository.selectById(positionId);
27410 tejbeer 238
 
31762 tejbeer 239
        List<CustomRetailer> positionIdCustomRetailer = csService.getPositionCustomRetailerMap(Arrays.asList(position)).get(position.getId());
27410 tejbeer 240
 
31762 tejbeer 241
        Map<Integer, CustomRetailer> regionRetailerMap = csService.getRegionPartners(Arrays.asList(position)).get(position.getRegionId()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
27410 tejbeer 242
 
31762 tejbeer 243
        model.addAttribute("position", position);
244
        model.addAttribute("regionRetailerMap", regionRetailerMap);
245
        model.addAttribute("positionIdCustomRetailer", positionIdCustomRetailer);
27410 tejbeer 246
 
31762 tejbeer 247
        return "position-partner";
248
    }
27410 tejbeer 249
 
31762 tejbeer 250
    @GetMapping(value = "/cs/createPosition")
251
    public String createPosition(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) {
252
        List<AuthUser> authUsers = authRepository.selectAllActiveUser();
253
        List<TicketCategory> ticketCategories = ticketCategoryRepository.selectAll();
254
        List<Region> regions = regionRepository.selectAll();
255
        model.addAttribute("escalationTypes", EscalationType.values());
256
        model.addAttribute("authUsers", authUsers);
257
        model.addAttribute("ticketCategories", ticketCategories);
258
        model.addAttribute("regions", regions);
24500 govind 259
 
31762 tejbeer 260
        List<Position> positions = positionRepository.selectAllPosition();
261
        LOGGER.info("positions" + positions);
30426 tejbeer 262
 
31762 tejbeer 263
        Map<Integer, AuthUser> authUserIdAndAuthUserMap = csService.getAuthUserIdAndAuthUserMapUsingPositions(positions);
264
        Map<Integer, TicketCategory> categoryIdAndCategoryMap = csService.getCategoryIdAndCategoryUsingPositions(positions);
265
        Map<Integer, Region> regionIdAndRegionMap = csService.getRegionIdAndRegionMap(positions);
25570 tejbeer 266
 
27410 tejbeer 267
//	    Map<Integer, List<CustomRetailer>> positionIdAndpartnerRegionMap = csService
268
//			.getpositionIdAndpartnerRegionMap(positions);
25570 tejbeer 269
 
27410 tejbeer 270
//	     Map<Integer, List<CustomRetailer>> addedpositionIdAndCustomRetailerMap = csService
271
//				.getPositionCustomRetailerMap(positions);
272
//		LOGGER.info("fofoIdAndCustomRetailerMap" + addedpositionIdAndCustomRetailerMap);
24500 govind 273
 
31762 tejbeer 274
        model.addAttribute("start", offset + 1);
30426 tejbeer 275
 
31762 tejbeer 276
        model.addAttribute("positions", positions);
277
        model.addAttribute("authUserIdAndAuthUserMap", authUserIdAndAuthUserMap);
278
        model.addAttribute("categoryIdAndCategoryMap", categoryIdAndCategoryMap);
279
        model.addAttribute("regionIdAndRegionMap", regionIdAndRegionMap);
280
        // model.addAttribute("positionIdAndCustomRetailerMap",
281
        // addedpositionIdAndCustomRetailerMap);
282
        // model.addAttribute("positionIdAndpartnerRegionMap",
27410 tejbeer 283
// positionIdAndpartnerRegionMap);
25570 tejbeer 284
 
31762 tejbeer 285
        return "create-position";
286
    }
24500 govind 287
 
31762 tejbeer 288
    @GetMapping(value = "/cs/position-paginated")
289
    public String positionPaginated(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) {
24500 govind 290
 
31762 tejbeer 291
        List<Position> positions = positionRepository.selectAll(offset, limit);
292
        Map<Integer, AuthUser> authUserIdAndAuthUserMap = csService.getAuthUserIdAndAuthUserMapUsingPositions(positions);
293
        Map<Integer, TicketCategory> categoryIdAndCategoryMap = csService.getCategoryIdAndCategoryUsingPositions(positions);
294
        Map<Integer, Region> regionIdAndRegionMap = csService.getRegionIdAndRegionMap(positions);
295
        /*
296
         * Map<Integer, List<CustomRetailer>> positionIdAndpartnerRegionMap = csService
297
         * .getpositionIdAndpartnerRegionMap(positions);
298
         * 
299
         * Map<Integer, List<CustomRetailer>> addedpositionIdAndCustomRetailerMap =
300
         * csService .getPositionCustomRetailerMap(positions);
301
         */
25570 tejbeer 302
 
31762 tejbeer 303
        model.addAttribute("positions", positions);
304
        model.addAttribute("authUserIdAndAuthUserMap", authUserIdAndAuthUserMap);
305
        model.addAttribute("categoryIdAndCategoryMap", categoryIdAndCategoryMap);
306
        model.addAttribute("regionIdAndRegionMap", regionIdAndRegionMap);
307
        // model.addAttribute("positionIdAndCustomRetailerMap",
308
        // addedpositionIdAndCustomRetailerMap);
309
        // model.addAttribute("positionIdAndpartnerRegionMap",
310
        // positionIdAndpartnerRegionMap);
25570 tejbeer 311
 
31762 tejbeer 312
        return "position-paginated";
313
    }
24417 govind 314
 
31762 tejbeer 315
    @PostMapping(value = "/cs/createPosition")
316
    public String createPosition(HttpServletRequest request, @RequestBody CreatePositionModel createPositionModel, Model model) throws Exception {
24417 govind 317
 
35570 amit 318
        LOGGER.info("partnerPosition" + createPositionModel.isTicketAssigned());
25570 tejbeer 319
 
35570 amit 320
        // Validate authUserId exists
321
        int authUserId = createPositionModel.getAuthUserId();
322
        if (authUserId <= 0 || authRepository.selectById(authUserId) == null) {
323
            throw new ProfitMandiBusinessException("Position", authUserId, "Invalid authUserId");
324
        }
325
 
326
        // Validate categoryId exists (0 means "All Categories")
327
        int categoryId = createPositionModel.getCategoryId();
328
        if (categoryId > 0 && ticketCategoryRepository.selectById(categoryId) == null) {
329
            throw new ProfitMandiBusinessException("Position", categoryId, "Invalid categoryId");
330
        }
331
 
332
        // Validate regionId exists (0 or 5 typically means "All Partners/Regions")
333
        int regionId = createPositionModel.getRegionId();
334
        if (regionId > 0 && regionId != 5 && regionRepository.selectById(regionId) == null) {
335
            throw new ProfitMandiBusinessException("Position", regionId, "Invalid regionId");
336
        }
337
 
35589 amit 338
        // Validate fofoIds exist (0 means "All Partners")
35570 amit 339
        List<Integer> fofoIds = createPositionModel.getFofoIds();
35590 amit 340
        if (fofoIds == null || fofoIds.isEmpty()) {
341
            throw new ProfitMandiBusinessException("Position", 0, "At least one partner must be specified");
342
        }
343
        boolean hasAllPartners = fofoIds.contains(0);
344
        if (hasAllPartners && fofoIds.size() > 1) {
345
            throw new ProfitMandiBusinessException("Position", 0, "Cannot mix 'All Partners' (0) with specific partner IDs");
346
        }
347
        if (!hasAllPartners) {
348
            Map<Integer, CustomRetailer> validRetailers = retailerService.getFofoRetailers(false);
349
            for (int fofoId : fofoIds) {
350
                if (!validRetailers.containsKey(fofoId)) {
351
                    throw new ProfitMandiBusinessException("Position", fofoId, "Invalid fofoId");
35570 amit 352
                }
353
            }
354
        }
355
 
356
        Position position = positionRepository.selectPosition(authUserId, categoryId, regionId, createPositionModel.getEscalationType());
31762 tejbeer 357
        if (position == null) {
358
            position = new Position();
35570 amit 359
            position.setAuthUserId(authUserId);
360
            position.setCategoryId(categoryId);
31762 tejbeer 361
            position.setEscalationType(createPositionModel.getEscalationType());
35570 amit 362
            position.setRegionId(regionId);
31762 tejbeer 363
            position.setCreateTimestamp(LocalDateTime.now());
364
            position.setTicketAssignee(createPositionModel.isTicketAssigned());
365
            positionRepository.persist(position);
25570 tejbeer 366
 
35570 amit 367
            if (fofoIds != null) {
368
                for (int fofoId : fofoIds) {
369
                    PartnerPosition partnerPosition = new PartnerPosition();
370
                    partnerPosition.setFofoId(fofoId);
371
                    partnerPosition.setRegionId(regionId);
372
                    partnerPosition.setPositionId(position.getId());
373
                    partnerPositionRepository.persist(partnerPosition);
374
                    LOGGER.info("partnerPosition" + partnerPosition);
375
                }
31762 tejbeer 376
            }
24417 govind 377
 
31762 tejbeer 378
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
379
        } else {
35570 amit 380
            throw new ProfitMandiBusinessException("Position", authUserId, "already exists!");
31762 tejbeer 381
        }
382
        return "response";
383
    }
25570 tejbeer 384
 
31762 tejbeer 385
    @PostMapping(value = "/cs/updatePartnerPosition")
386
    public String updatePartnerPosition(HttpServletRequest request, @RequestParam(name = "regionId") int regionId, @RequestBody List<Integer> selectedFofoIds, @RequestParam(name = "positionId") int positionId, Model model) throws Exception {
25570 tejbeer 387
 
35571 amit 388
        // Validate positionId exists
389
        Position position = positionRepository.selectById(positionId);
390
        if (position == null) {
391
            throw new ProfitMandiBusinessException("Position", positionId, "Position not found");
392
        }
393
 
394
        // Validate regionId exists (0 or 5 typically means "All Partners/Regions")
395
        if (regionId > 0 && regionId != 5 && regionRepository.selectById(regionId) == null) {
396
            throw new ProfitMandiBusinessException("Position", regionId, "Invalid regionId");
397
        }
398
 
35589 amit 399
        // Validate fofoIds exist (0 means "All Partners")
35590 amit 400
        if (selectedFofoIds == null || selectedFofoIds.isEmpty()) {
401
            throw new ProfitMandiBusinessException("Position", 0, "At least one partner must be specified");
402
        }
403
        boolean hasAllPartners = selectedFofoIds.contains(0);
404
        if (hasAllPartners && selectedFofoIds.size() > 1) {
405
            throw new ProfitMandiBusinessException("Position", 0, "Cannot mix 'All Partners' (0) with specific partner IDs");
406
        }
407
        if (!hasAllPartners) {
35607 amit 408
            // Use direct database query instead of cached retailerService to include newly added partners
409
            Set<Integer> validFofoIds = fofoStoreRepository.selectAll().stream()
410
                    .map(fs -> fs.getId())
411
                    .collect(Collectors.toSet());
35590 amit 412
            for (int fofoId : selectedFofoIds) {
35607 amit 413
                if (!validFofoIds.contains(fofoId)) {
35590 amit 414
                    throw new ProfitMandiBusinessException("Position", fofoId, "Invalid fofoId");
35571 amit 415
                }
416
            }
417
        }
418
 
32493 amit.gupta 419
        partnerPositionRepository.delete(positionId);
35571 amit 420
        if (selectedFofoIds != null) {
421
            for (int fofoId : selectedFofoIds) {
422
                PartnerPosition partnerPosition = new PartnerPosition();
423
                partnerPosition.setFofoId(fofoId);
424
                partnerPosition.setRegionId(regionId);
425
                partnerPosition.setPositionId(positionId);
426
                partnerPositionRepository.persist(partnerPosition);
427
            }
31762 tejbeer 428
        }
25570 tejbeer 429
 
31762 tejbeer 430
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
25570 tejbeer 431
 
31762 tejbeer 432
        return "response";
433
    }
24417 govind 434
 
31762 tejbeer 435
    @GetMapping(value = "/cs/createTicket")
436
    public String createTicket(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
437
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
35594 amit 438
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
439
        boolean isCrmUser = false;
440
 
31762 tejbeer 441
        List<TicketCategory> ticketCategories = csService.getAllTicketCategotyFromSubCategory();
35594 amit 442
 
443
        if (isAdmin) {
444
            AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
445
            isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
446
 
447
            // CRM users should not see Sales and RBM categories
448
            if (isCrmUser) {
449
                ticketCategories = ticketCategories.stream()
450
                        .filter(tc -> tc.getId() != ProfitMandiConstants.TICKET_CATEGORY_SALES
451
                                && tc.getId() != ProfitMandiConstants.TICKET_CATEGORY_RBM)
452
                        .collect(Collectors.toList());
453
            }
454
        }
455
 
456
        model.addAttribute("roleType", isAdmin);
31762 tejbeer 457
        model.addAttribute("ticketCategories", ticketCategories);
35594 amit 458
        model.addAttribute("isCrmUser", isCrmUser);
31762 tejbeer 459
        return "create-ticket";
460
    }
24417 govind 461
 
31762 tejbeer 462
    @GetMapping(value = "/cs/getSubCategoriesByCategoryId")
35594 amit 463
    public String getSubCategoriesByCategoryId(HttpServletRequest request, @RequestParam(name = "categoryId", defaultValue = "0") int categoryId, Model model) throws ProfitMandiBusinessException {
464
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
465
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
466
        boolean isCrmUser = false;
467
 
468
        if (isAdmin) {
469
            AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
470
            isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
471
        }
472
 
31830 amit.gupta 473
        List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAllVisible(categoryId);
35594 amit 474
 
35617 amit 475
        // CRM users should not see invisible subcategories
35594 amit 476
        if (isCrmUser) {
477
            ticketSubCategories = ticketSubCategories.stream()
35617 amit 478
                    .filter(TicketSubCategory::isVisibility)
35594 amit 479
                    .collect(Collectors.toList());
480
        }
481
 
31762 tejbeer 482
        LOGGER.info(ticketSubCategories);
483
        model.addAttribute("ticketSubCategories", ticketSubCategories);
484
        return "ticket-sub-categories";
485
    }
24417 govind 486
 
24791 govind 487
 
31762 tejbeer 488
    @GetMapping(value = "/cs/getEscalationTypeByCategoryId")
489
    public String getEscalationTypeByCategoryId(HttpServletRequest request, @RequestParam(name = "categoryId", defaultValue = "0") int categoryId, @RequestParam(name = "authId", defaultValue = "0") int authId, Model model) {
490
        List<Position> positions = positionRepository.selectPositionbyCategoryIdAndAuthId(categoryId, authId);
491
        List<EscalationType> escalationTypes = new ArrayList<>();
24791 govind 492
 
31762 tejbeer 493
        if (!positions.isEmpty()) {
494
            escalationTypes = positions.stream().map(x -> x.getEscalationType()).distinct().collect(Collectors.toList());
495
        }
24620 govind 496
 
31762 tejbeer 497
        LOGGER.info("escalationTypes {}", escalationTypes);
24500 govind 498
 
31762 tejbeer 499
        model.addAttribute("escalationTypes", escalationTypes);
500
        return "ticket-escalationtype";
501
    }
24500 govind 502
 
24824 govind 503
 
31762 tejbeer 504
    @GetMapping(value = "/cs/getCategoriesByAuthId")
505
    public String getCategoriesByAuthId(HttpServletRequest request, @RequestParam(name = "authId", defaultValue = "0") int authId, Model model) {
24824 govind 506
 
24787 govind 507
 
31762 tejbeer 508
        List<Position> positions = positionRepository.selectPositionByAuthId(authId);
24791 govind 509
 
31762 tejbeer 510
        LOGGER.info("positions {}", positions);
24417 govind 511
 
31762 tejbeer 512
        List<TicketCategory> ticketCategories = new ArrayList<TicketCategory>();
24417 govind 513
 
31762 tejbeer 514
        if (!positions.isEmpty()) {
24417 govind 515
 
31762 tejbeer 516
            List<Integer> categoryIds = positions.stream().map(x -> x.getCategoryId()).collect(Collectors.toList());
517
            ticketCategories = ticketCategoryRepository.selectAll(categoryIds);
518
        }
519
        LOGGER.info("ticketCategories {}", ticketCategories);
520
        model.addAttribute("ticketCategories", ticketCategories);
521
        return "ticket-categories";
522
    }
27270 tejbeer 523
 
31762 tejbeer 524
    @PostMapping(value = "/cs/createTicket")
525
    public String createTicket(HttpServletRequest request, @RequestParam(name = "categoryId") int categoryId, @RequestParam(name = "subCategoryId") int subCategoryId, @RequestParam(name = "message") String message, Model model) throws Exception {
526
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
527
        List<Ticket> tickets = ticketRepository.selectAllResolvedMarkedTicketByCreator(loginDetails.getFofoId());
528
        if (tickets.size() > 3 || tickets.size() == 3) {
529
            model.addAttribute("response1", mvcResponseSender.createResponseString(false));
530
        } else {
531
            csService.createTicket(loginDetails.getFofoId(), categoryId, subCategoryId, message);
532
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
533
        }
534
        return "response";
535
    }
27270 tejbeer 536
 
31762 tejbeer 537
    @GetMapping(value = "/cs/myticket")
538
    public String getTicket(HttpServletRequest request, @RequestParam(name = "orderby", defaultValue = "DESCENDING") SortOrder sortOrder, @RequestParam(name = "ticketStatus", defaultValue = "OPENED") TicketStatus ticketStatus, @RequestParam(name = "ticketSearchType", defaultValue = "") TicketSearchType ticketSearchType, @RequestParam(name = "searchTerm", defaultValue = "0") int searchTerm, Model model) throws ProfitMandiBusinessException {
539
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
540
        List<Ticket> tickets = null;
541
        List<TicketAssigned> ticketAssigneds = null;
542
        long size = 0;
543
        Map<Integer, AuthUser> authUserIdAndAuthUserMap = null;
35569 amit 544
        boolean isAdmin = roleManager.isAdmin(new HashSet<>(loginDetails.getRoleIds()));
545
        AuthUser currentAuthUser = isAdmin ? authRepository.selectByEmailOrMobile(loginDetails.getEmailId()) : null;
546
 
35592 amit 547
        // Check if user is CRM category - CRM users see ALL tickets to handle partner communications
548
        boolean isCrmUser = isAdmin && currentAuthUser != null && positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
35603 amit 549
        // Check if user is Sales category - Sales users can resolve their own Sales tickets
550
        boolean isSalesUser = isAdmin && currentAuthUser != null && positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_SALES);
551
        // Check if user is RBM category - RBM users can resolve their own RBM tickets
552
        boolean isRbmUser = isAdmin && currentAuthUser != null && positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_RBM);
35592 amit 553
 
35569 amit 554
        if (isAdmin) {
555
            int authUserId = currentAuthUser.getId();
35592 amit 556
 
557
            if (isCrmUser) {
35601 amit 558
                // CRM users see ALL tickets EXCEPT Sales Escalation and RBM Escalation subcategories
31762 tejbeer 559
                if (ticketStatus.equals(TicketStatus.RESOLVED)) {
35592 amit 560
                    tickets = ticketRepository.selectAllTickets(Optional.empty(), sortOrder, ticketSearchType, searchTerm);
31762 tejbeer 561
                } else {
35592 amit 562
                    tickets = ticketRepository.selectAllTickets(Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), sortOrder, ticketSearchType, searchTerm);
31762 tejbeer 563
                }
35601 amit 564
 
35617 amit 565
                // Filter out invisible subcategory tickets for CRM users
566
                Map<Integer, TicketSubCategory> subCategoryMap = ticketSubCategoryRepository.getTicketSubCategoryMap();
35601 amit 567
                tickets = tickets.stream()
35617 amit 568
                        .filter(t -> {
569
                            TicketSubCategory subCategory = subCategoryMap.get(t.getSubCategoryId());
570
                            return subCategory != null && subCategory.isVisibility();
571
                        })
35601 amit 572
                        .collect(Collectors.toList());
573
                size = tickets.size();
31762 tejbeer 574
            } else {
35592 amit 575
                // Non-CRM admins see only tickets assigned to them
576
                if (ticketSearchType == null) {
577
                    if (ticketStatus.equals(TicketStatus.RESOLVED)) {
578
                        tickets = ticketRepository.selectAllByAssignee(authUserId, Optional.empty(), sortOrder, null, searchTerm);
579
                        size = ticketRepository.selectAllCountByAssignee(authUserId, Optional.empty(), null, searchTerm);
580
                    } else {
581
                        tickets = ticketRepository.selectAllByAssignee(authUserId, Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), sortOrder, null, searchTerm);
582
                        size = ticketRepository.selectAllCountByAssignee(authUserId, Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), null, searchTerm);
583
                    }
31762 tejbeer 584
                } else {
35592 amit 585
                    if (ticketStatus.equals(TicketStatus.RESOLVED)) {
586
                        tickets = ticketRepository.selectAllByAssignee(authUserId, Optional.empty(), sortOrder, ticketSearchType, searchTerm);
587
                        size = ticketRepository.selectAllCountByAssignee(authUserId, Optional.empty(), ticketSearchType, searchTerm);
588
                    } else {
589
                        tickets = ticketRepository.selectAllByAssignee(authUserId, Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), sortOrder, ticketSearchType, searchTerm);
590
                        size = ticketRepository.selectAllCountByAssignee(authUserId, Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), ticketSearchType, searchTerm);
591
                    }
31762 tejbeer 592
                }
593
            }
594
            // LOGGER.info(size + "size");
595
            if (tickets.size() > 0) {
596
                ticketAssigneds = ticketAssignedRepository.selectByTicketIds(tickets.stream().map(x -> x.getId()).collect(Collectors.toList()));
597
                authUserIdAndAuthUserMap = csService.getAuthUserIdAndAuthUserMap(ticketAssigneds);
598
                Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = csService.getPartnerByFofoIds(tickets);
599
                model.addAttribute("fofoIdsAndCustomRetailer", fofoIdsAndCustomRetailer);
600
            }
24500 govind 601
 
31762 tejbeer 602
        } else {
603
            tickets = ticketRepository.selectAllByCreator(loginDetails.getFofoId(), Optional.of(TicketStatus.OPENED.equals(ticketStatus)), sortOrder);
604
            size = ticketRepository.selectAllCountByCreator(loginDetails.getFofoId(), Optional.of(TicketStatus.OPENED.equals(ticketStatus)));
605
        }
606
        authUserIdAndAuthUserMap = csService.getTicketIdAndAuthUserMapUsingTickets(tickets);
35571 amit 607
        if (authUserIdAndAuthUserMap == null) {
608
            authUserIdAndAuthUserMap = new HashMap<>();
609
        }
24620 govind 610
 
31762 tejbeer 611
        model.addAttribute("size", size);
35569 amit 612
        model.addAttribute("roleType", isAdmin);
35592 amit 613
        // isCrmUser already calculated at start of method
35569 amit 614
        model.addAttribute("isCrmUser", isCrmUser);
35603 amit 615
        model.addAttribute("isSalesUser", isSalesUser);
616
        model.addAttribute("salesCategoryId", ProfitMandiConstants.TICKET_CATEGORY_SALES);
617
        model.addAttribute("isRbmUser", isRbmUser);
618
        model.addAttribute("rbmCategoryId", ProfitMandiConstants.TICKET_CATEGORY_RBM);
24500 govind 619
 
31762 tejbeer 620
        List<Integer> subCategoryIds = tickets.stream().map(x -> x.getSubCategoryId()).collect(Collectors.toList());
621
        Map<Integer, TicketSubCategory> subCategoryIdAndSubCategoryMap = csService.getSubCategoryIdAndSubCategoryMap(subCategoryIds);
35571 amit 622
        if (subCategoryIdAndSubCategoryMap == null) {
623
            subCategoryIdAndSubCategoryMap = new HashMap<>();
624
        }
24747 govind 625
 
31762 tejbeer 626
        Map<Integer, TicketCategory> subCategoryIdAndCategoryMap = csService.getSubCategoryIdAndCategoryMap(subCategoryIds);
35571 amit 627
        if (subCategoryIdAndCategoryMap == null) {
628
            subCategoryIdAndCategoryMap = new HashMap<>();
629
        }
27318 amit.gupta 630
 
31762 tejbeer 631
        List<Integer> ticketIds = tickets.stream().map(x -> x.getId()).collect(Collectors.toList());
24500 govind 632
 
35569 amit 633
        Map<Integer, List<Activity>> activityMap = new HashMap<>();
33864 ranu 634
        Map<Integer, List<Activity>> activityMapWithActivityId = new HashMap<>();
35569 amit 635
        Map<Integer, AuthUser> authUserMap = new HashMap<>();
24500 govind 636
 
31762 tejbeer 637
        if (!ticketIds.isEmpty()) {
35569 amit 638
            // Fetch activities once and group by both ticketId and activityId
639
            List<Activity> allActivities = activityRepository.selectAll(ticketIds);
640
            activityMap = allActivities.stream().collect(Collectors.groupingBy(Activity::getTicketId));
641
            activityMapWithActivityId = allActivities.stream().collect(Collectors.groupingBy(Activity::getId));
24787 govind 642
 
35569 amit 643
            // Only fetch AuthUsers who created activities (instead of all users)
644
            Set<Integer> activityCreatorIds = allActivities.stream()
645
                    .map(Activity::getCreatedBy)
646
                    .filter(id -> id > 0)
647
                    .collect(Collectors.toSet());
648
            if (!activityCreatorIds.isEmpty()) {
649
                authUserMap = authRepository.selectByIds(new ArrayList<>(activityCreatorIds))
650
                        .stream().collect(Collectors.toMap(AuthUser::getId, x -> x));
651
            }
31762 tejbeer 652
        }
24787 govind 653
 
31762 tejbeer 654
        model.addAttribute("tickets", tickets);
655
        model.addAttribute("resolved", ActivityType.RESOLVED);
656
        model.addAttribute("resolved-accepted", ActivityType.RESOLVED_ACCEPTED);
657
        model.addAttribute("resolved-rejected", ActivityType.RESOLVED_REJECTED);
658
        model.addAttribute("authUserIdAndAuthUserMap", authUserIdAndAuthUserMap);
659
        model.addAttribute("subCategoryIdAndSubCategoryMap", subCategoryIdAndSubCategoryMap);
27318 amit.gupta 660
 
31762 tejbeer 661
        model.addAttribute("subCategoryIdAndCategoryMap", subCategoryIdAndCategoryMap);
662
        model.addAttribute("activityMap", activityMap);
33864 ranu 663
        model.addAttribute("authUserMap", authUserMap);
664
        model.addAttribute("activityMapWithActivityId", activityMapWithActivityId);
24500 govind 665
 
31762 tejbeer 666
        model.addAttribute("ticketStatusValues", TicketStatus.values());
667
        model.addAttribute("orderByValues", SortOrder.values());
668
        model.addAttribute("selectedticketStatus", ticketStatus);
669
        model.addAttribute("selectedorderby", sortOrder);
670
        model.addAttribute("ticketSearchTypes", TicketSearchType.values());
671
        model.addAttribute("ticketSearchType", ticketSearchType);
672
        model.addAttribute("searchTerm", searchTerm);
673
        return "ticket";
674
    }
24500 govind 675
 
27124 amit.gupta 676
 
31762 tejbeer 677
    @GetMapping(value = "/cs/getActivities")
678
    public String getActivity(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, Model model) throws Exception {
35592 amit 679
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
680
        Ticket ticket = ticketRepository.selectById(ticketId);
681
 
682
        if (ticket == null) {
683
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
684
        }
685
 
686
        // Authorization check: verify user has access to this ticket
687
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
688
        if (!isAdmin) {
689
            // Partners can only view their own tickets
690
            if (ticket.getFofoId() != loginDetails.getFofoId()) {
691
                throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to view this ticket");
692
            }
693
        } else {
694
            // Admins must be assigned to the ticket OR be CRM user OR be in the escalation chain
695
            AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
696
            boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
697
 
698
            if (!isCrmUser) {
699
                // Check if user is assigned or in escalation chain
700
                List<TicketAssigned> assignments = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
701
                boolean isAssigned = assignments.stream().anyMatch(ta -> ta.getAssineeId() == currentAuthUser.getId() || ta.getManagerId() == currentAuthUser.getId());
702
                boolean isInEscalationChain = ticket.getL1AuthUser() == currentAuthUser.getId() ||
703
                        ticket.getL2AuthUser() == currentAuthUser.getId() ||
704
                        ticket.getL3AuthUser() == currentAuthUser.getId() ||
705
                        ticket.getL4AuthUser() == currentAuthUser.getId() ||
706
                        ticket.getL5AuthUser() == currentAuthUser.getId();
707
 
708
                if (!isAssigned && !isInEscalationChain) {
709
                    throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to view this ticket");
710
                }
711
            }
712
        }
713
 
31762 tejbeer 714
        List<Activity> allactivities = activityRepository.selectAll(ticketId);
35570 amit 715
 
716
        // Batch fetch all documents for attachments (fix N+1 query)
717
        List<Integer> documentIds = allactivities.stream()
718
                .flatMap(a -> a.getActivityAttachment().stream())
719
                .map(ActivityAttachment::getDocumentId)
720
                .distinct()
721
                .collect(Collectors.toList());
722
 
723
        Map<Integer, Document> documentMap = Collections.emptyMap();
724
        if (!documentIds.isEmpty()) {
725
            documentMap = documentRepository.selectByIds(documentIds).stream()
726
                    .collect(Collectors.toMap(Document::getId, d -> d));
727
        }
728
 
729
        // Set document names transiently (do not persist during GET)
730
        for (Activity activity : allactivities) {
731
            for (ActivityAttachment attachment : activity.getActivityAttachment()) {
732
                Document document = documentMap.get(attachment.getDocumentId());
733
                if (document != null) {
734
                    attachment.setDocumentName(document.getDisplayName());
735
                }
31762 tejbeer 736
            }
737
        }
738
        List<Activity> activities = null;
35592 amit 739
        if (isAdmin) {
31762 tejbeer 740
            Set<Integer> authUserIds = allactivities.stream().map(x -> x.getCreatedBy()).collect(Collectors.toSet());
35395 amit 741
            List<AuthUser> users = authRepository.selectByIds(new ArrayList<>(authUserIds));
31762 tejbeer 742
            Map<Integer, String> authUserNameMap = users.stream().collect(Collectors.toMap(AuthUser::getId, x -> x.getFirstName() + " " + x.getLastName()));
743
            allactivities.stream().forEach(x -> x.setName(authUserNameMap.get(x.getCreatedBy())));
744
            activities = allactivities;
745
        } else {
746
            activities = allactivities.stream().filter(x -> ActivityType.PARTNER_ACTIVITIES.contains(x.getType())).collect(Collectors.toList());
747
        }
748
        if (activities == null) {
749
            throw new ProfitMandiBusinessException("Activity", ticketId, "No Activity Found");
750
        }
751
        model.addAttribute("response1", mvcResponseSender.createResponseString(activities));
752
        return "response";
24500 govind 753
 
31762 tejbeer 754
    }
24620 govind 755
 
31762 tejbeer 756
    @PostMapping(value = "/cs/createActivity")
757
    public String createActivity(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, @RequestParam(name = "assigneeId", defaultValue = "0") int assigneeId, @RequestParam(name = "internal", defaultValue = "true") boolean internal, @RequestParam(name = "message", defaultValue = "") String message, @RequestBody List<Integer> documentIds,
24620 govind 758
 
31762 tejbeer 759
                                 Model model) throws Exception {
24620 govind 760
 
31762 tejbeer 761
        LOGGER.info("documentIds" + documentIds);
762
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
763
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 764
 
765
        if (ticket == null) {
766
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
767
        }
768
 
769
        // Authorization check: verify user has access to add activity to this ticket
770
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
771
        if (!isAdmin) {
772
            // Partners can only add activity to their own tickets
773
            if (ticket.getFofoId() != loginDetails.getFofoId()) {
774
                throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to add activity to this ticket");
775
            }
776
        } else {
777
            // Admins must be assigned to the ticket OR be CRM user OR be in the escalation chain
778
            AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
779
            boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
780
 
781
            if (!isCrmUser) {
782
                List<TicketAssigned> assignments = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
783
                boolean isAssigned = assignments.stream().anyMatch(ta -> ta.getAssineeId() == currentAuthUser.getId() || ta.getManagerId() == currentAuthUser.getId());
784
                boolean isInEscalationChain = ticket.getL1AuthUser() == currentAuthUser.getId() ||
785
                        ticket.getL2AuthUser() == currentAuthUser.getId() ||
786
                        ticket.getL3AuthUser() == currentAuthUser.getId() ||
787
                        ticket.getL4AuthUser() == currentAuthUser.getId() ||
788
                        ticket.getL5AuthUser() == currentAuthUser.getId();
789
 
790
                if (!isAssigned && !isInEscalationChain) {
791
                    throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to add activity to this ticket");
792
                }
793
            }
794
        }
31762 tejbeer 795
        List<TicketAssigned> ticketAssignedList = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
796
        List<Integer> authUserIds = ticketAssignedList.stream().map(x -> x.getAssineeId()).collect(Collectors.toList());
797
        authUserIds.add(ticketAssignedList.get(ticketAssignedList.size() - 1).getManagerId());
35395 amit 798
        Map<Integer, AuthUser> authUsersMap = authRepository.selectByIds(authUserIds).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
31762 tejbeer 799
        if (ticket.getCloseTimestamp() == null) {
800
            Activity activity = new Activity();
801
            activity.setCreatedBy(0);
802
            activity.setCreateTimestamp(LocalDateTime.now());
803
            String subject = null;
804
            String mailMessage = null;
805
            activity.setMessage(message);
806
            if (!roleManager.isAdmin(new HashSet<>(loginDetails.getRoleIds()))) {
807
                CustomRetailer customRetailer = retailerService.getFofoRetailers(true).get(loginDetails.getFofoId());
808
                activity.setType(ActivityType.COMMUNICATION_IN);
809
                subject = String.format("Ticket Update #%s by franchisee %s", ticket.getId(), customRetailer.getBusinessName() + "(" + customRetailer.getCode() + ")");
810
                mailMessage = String.format("Franchisee message - %s", message);
811
            } else {
812
                AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
813
                activity.setCreatedBy(authUser.getId());
814
                authUsersMap.remove(authUser.getId());
815
                subject = String.format("Ticket Update #%s by %s", ticket.getId(), authUser.getName());
816
                mailMessage = String.format("%s's message - %s", authUser.getFirstName(), message);
35569 amit 817
                // Only CRM users can send external communications
818
                boolean isCrmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
819
                if (internal || !isCrmUser) {
31762 tejbeer 820
                    activity.setType(ActivityType.COMMUNICATION_INTERNAL);
821
                } else {
822
                    String updatedBy = "SD Team";
31854 amit.gupta 823
                    CustomRetailer customRetailer = retailerService.getFofoRetailers(false).get(ticket.getFofoId());
31762 tejbeer 824
                    subject = String.format("Ticket Update #%s by %s", ticket.getId(), updatedBy);
825
                    String partnerMessage = String.format("%s's message - %s", updatedBy, message);
826
                    this.activityRelatedMail(customRetailer.getEmail(), null, "subject", partnerMessage);
827
                    activity.setType(ActivityType.COMMUNICATION_OUT);
828
                }
829
            }
830
            activityRepository.persist(activity);
831
 
832
            for (Integer documentId : documentIds) {
833
                ActivityAttachment activityAttachment = new ActivityAttachment();
834
                activityAttachment.setActivityId(activity.getId());
835
                activityAttachment.setDocumentId(documentId);
836
                activityAttachmentRepository.persist(activityAttachment);
837
            }
838
 
839
            csService.addActivity(ticket, activity);
840
            AuthUser authUser = authUsersMap.remove(authUserIds.get(0));
841
            if (authUser == null) {
842
                authUser = authUsersMap.remove(authUserIds.get(1));
843
            }
844
            model.addAttribute("response1", mvcResponseSender.createResponseString(authUser));
845
            String[] cc = authUsersMap.entrySet().stream().map(x -> x.getValue().getEmailId()).toArray(String[]::new);
846
            this.activityRelatedMail(authUser.getEmailId(), cc, subject, mailMessage);
847
        } else {
848
            throw new ProfitMandiBusinessException("Ticket", ticket.getId(), "Already closed ticket");
849
        }
850
        return "response";
851
    }
852
 
853
    private void activityRelatedMail(String to, String[] cc, String subject, String message) throws ProfitMandiBusinessException {
854
        try {
855
            Utils.sendMailWithAttachments(mailSender, to, cc, subject, message, null);
856
        } catch (Exception e) {
857
            throw new ProfitMandiBusinessException("Ticket Activity", to, "Could not send ticket activity mail");
858
        }
859
    }
860
 
861
    @PostMapping(value = "/cs/closeTicket")
862
    public String closeTicket(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, @RequestParam(name = "happyCode") String happyCode, Model model) throws Exception {
35592 amit 863
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
31762 tejbeer 864
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 865
 
866
        if (ticket == null) {
867
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
868
        }
869
 
870
        // Authorization check: only the ticket owner (partner) can close the ticket
871
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
872
        if (isAdmin) {
873
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Only partners can close tickets using happy code");
874
        }
875
 
876
        // Verify the partner owns this ticket
877
        if (ticket.getFofoId() != loginDetails.getFofoId()) {
878
            throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to close this ticket");
879
        }
880
 
31762 tejbeer 881
        if (ticket.getHappyCode().equals(happyCode)) {
882
            ticket.setCloseTimestamp(LocalDateTime.now());
883
            ticketRepository.persist(ticket);
884
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
885
        } else {
886
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Happy Code can't match");
887
        }
888
        return "response";
889
    }
890
 
34913 ranu 891
    @GetMapping(value = "/cs/myPartyTicketTicket")
892
    public String getMyPartyTicketTicket(HttpServletRequest request, @RequestParam(name = "orderby", defaultValue = "DESCENDING") SortOrder sortOrder, @RequestParam(name = "ticketStatus", defaultValue = "OPENED") TicketStatus ticketStatus, @RequestParam(name = "ticketSearchType", defaultValue = "") TicketSearchType ticketSearchType, @RequestParam(name = "searchTerm", defaultValue = "0") int searchTerm, Model model) throws ProfitMandiBusinessException {
893
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
894
        long size = 0;
895
        AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
896
        List<Ticket> tickets = new ArrayList<>();
897
        Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
898
        Set<Integer> fofoIds = storeGuyMap.get(authUser.getEmailId());
899
 
900
        Map<Integer, List<AuthUser>> authUserListMap = null;
901
        if (fofoIds != null && !fofoIds.isEmpty()) {
35571 amit 902
            // Batch fetch all open tickets for all fofoIds (fix N+1 query)
903
            List<Ticket> allPartnerTickets = ticketRepository.selectAllOpenTickets(new ArrayList<>(fofoIds));
904
            if (allPartnerTickets != null && !allPartnerTickets.isEmpty()) {
905
                // Filter tickets where last_activity is not "RESOLVED"
906
                tickets = allPartnerTickets.stream()
907
                        .filter(ticket -> ticket.getLastActivity() == null ||
908
                                ticket.getLastActivity() != ActivityType.RESOLVED)
909
                        .collect(Collectors.toList());
34913 ranu 910
            }
911
        }
912
 
913
        authUserListMap = csService.getAssignedAuthList(tickets);
914
 
915
 
916
        if (tickets.size() > 0) {
917
            Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = csService.getPartnerByFofoIds(tickets);
918
            model.addAttribute("fofoIdsAndCustomRetailer", fofoIdsAndCustomRetailer);
919
        }
920
 
921
        model.addAttribute("size", tickets.size());
922
        model.addAttribute("tickets", tickets);
923
 
924
        List<Integer> subCategoryIds = tickets.stream().map(x -> x.getSubCategoryId()).collect(Collectors.toList());
925
        Map<Integer, TicketSubCategory> subCategoryIdAndSubCategoryMap = csService.getSubCategoryIdAndSubCategoryMap(subCategoryIds);
35571 amit 926
        if (subCategoryIdAndSubCategoryMap == null) {
927
            subCategoryIdAndSubCategoryMap = new HashMap<>();
928
        }
34913 ranu 929
 
930
        Map<Integer, TicketCategory> subCategoryIdAndCategoryMap = csService.getSubCategoryIdAndCategoryMap(subCategoryIds);
35571 amit 931
        if (subCategoryIdAndCategoryMap == null) {
932
            subCategoryIdAndCategoryMap = new HashMap<>();
933
        }
34913 ranu 934
 
935
        List<Integer> ticketIds = tickets.stream().map(x -> x.getId()).collect(Collectors.toList());
936
        Map<Integer, List<Activity>> activityMap = new HashMap<>();
937
        Map<Integer, List<Activity>> activityMapWithActivityId = new HashMap<>();
35569 amit 938
        Map<Integer, AuthUser> authUserMap = new HashMap<>();
34913 ranu 939
 
940
        if (!ticketIds.isEmpty()) {
35569 amit 941
            // Fetch activities once and group by both ticketId and activityId
942
            List<Activity> allActivities = activityRepository.selectAll(ticketIds);
943
            activityMap = allActivities.stream().collect(Collectors.groupingBy(Activity::getTicketId));
944
            activityMapWithActivityId = allActivities.stream().collect(Collectors.groupingBy(Activity::getId));
34913 ranu 945
 
35569 amit 946
            // Only fetch AuthUsers who created activities (instead of all users)
947
            Set<Integer> activityCreatorIds = allActivities.stream()
948
                    .map(Activity::getCreatedBy)
949
                    .filter(id -> id > 0)
950
                    .collect(Collectors.toSet());
951
            if (!activityCreatorIds.isEmpty()) {
952
                authUserMap = authRepository.selectByIds(new ArrayList<>(activityCreatorIds))
953
                        .stream().collect(Collectors.toMap(AuthUser::getId, x -> x));
954
            }
34913 ranu 955
        }
956
 
957
        model.addAttribute("ticketStatusValues", TicketStatus.values());
958
        model.addAttribute("orderByValues", SortOrder.values());
959
        model.addAttribute("selectedticketStatus", ticketStatus);
960
        model.addAttribute("selectedorderby", sortOrder);
961
        model.addAttribute("tickets", tickets);
962
        model.addAttribute("ticketSearchTypes", TicketSearchType.values());
963
        model.addAttribute("ticketSearchType", ticketSearchType);
964
        model.addAttribute("searchTerm", searchTerm);
35571 amit 965
        model.addAttribute("authUserListMap", authUserListMap != null ? authUserListMap : new HashMap<>());
34913 ranu 966
        model.addAttribute("subCategoryIdAndSubCategoryMap", subCategoryIdAndSubCategoryMap);
967
 
968
        model.addAttribute("subCategoryIdAndCategoryMap", subCategoryIdAndCategoryMap);
969
 
970
        model.addAttribute("activityMap", activityMap);
971
        model.addAttribute("authUserMap", authUserMap);
972
        model.addAttribute("activityMapWithActivityId", activityMapWithActivityId);
35569 amit 973
        // Check if user is in CRM category (only CRM can send external communications)
974
        boolean isCrmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
975
        model.addAttribute("isCrmUser", isCrmUser);
34913 ranu 976
 
977
        return "my-partner-tickets";
978
    }
979
 
31762 tejbeer 980
    @GetMapping(value = "/cs/managerTicket")
981
    public String getManagerTickets(HttpServletRequest request, @RequestParam(name = "orderby", defaultValue = "DESCENDING") SortOrder sortOrder, @RequestParam(name = "ticketStatus", defaultValue = "OPENED") TicketStatus ticketStatus, @RequestParam(name = "ticketSearchType", defaultValue = "") TicketSearchType ticketSearchType, @RequestParam(name = "searchTerm", defaultValue = "0") int searchTerm, Model model) throws ProfitMandiBusinessException {
982
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
983
        long size = 0;
984
        AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
35594 amit 985
        boolean isCrmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
986
 
31762 tejbeer 987
        List<Ticket> tickets = null;
988
        Map<Integer, List<AuthUser>> authUserListMap = null;
35594 amit 989
 
990
        // CRM users can see all tickets to assign them (like managers)
991
        if (isCrmUser) {
31762 tejbeer 992
            if (ticketStatus.equals(TicketStatus.RESOLVED)) {
35594 amit 993
                tickets = ticketRepository.selectAllTickets(Optional.empty(), sortOrder, ticketSearchType, searchTerm);
994
                size = ticketRepository.selectAllTicketsCount(Optional.empty(), ticketSearchType, searchTerm);
995
            } else {
996
                tickets = ticketRepository.selectAllTickets(Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), sortOrder, ticketSearchType, searchTerm);
997
                size = ticketRepository.selectAllTicketsCount(Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), ticketSearchType, searchTerm);
998
            }
999
        } else if (ticketSearchType == null) {
1000
            if (ticketStatus.equals(TicketStatus.RESOLVED)) {
31762 tejbeer 1001
                tickets = ticketRepository.selectAllManagerTicket(authUser.getId(), sortOrder, Optional.empty(), null, searchTerm);
1002
                size = ticketRepository.selectAllCountByManagerTicket(authUser.getId(), Optional.empty(), null, 0);
1003
            } else {
1004
                tickets = ticketRepository.selectAllManagerTicket(authUser.getId(), sortOrder, Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), null, searchTerm);
1005
                size = ticketRepository.selectAllCountByManagerTicket(authUser.getId(), Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), null, 0);
1006
            }
1007
        } else {
1008
            if (ticketStatus.equals(TicketStatus.RESOLVED)) {
1009
                tickets = ticketRepository.selectAllManagerTicket(authUser.getId(), sortOrder, Optional.empty(), ticketSearchType, searchTerm);
1010
                size = ticketRepository.selectAllCountByManagerTicket(authUser.getId(), Optional.empty(), ticketSearchType, searchTerm);
1011
            } else {
1012
                tickets = ticketRepository.selectAllManagerTicket(authUser.getId(), sortOrder, Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), ticketSearchType, searchTerm);
1013
                size = ticketRepository.selectAllCountByManagerTicket(authUser.getId(), Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), ticketSearchType, searchTerm);
1014
            }
1015
 
1016
        }
1017
        authUserListMap = csService.getAssignedAuthList(tickets);
1018
 
1019
        if (tickets.size() > 0) {
1020
            Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = csService.getPartnerByFofoIds(tickets);
1021
            model.addAttribute("fofoIdsAndCustomRetailer", fofoIdsAndCustomRetailer);
1022
        }
1023
 
1024
        model.addAttribute("size", size);
1025
        model.addAttribute("tickets", tickets);
1026
 
1027
        List<Integer> subCategoryIds = tickets.stream().map(x -> x.getSubCategoryId()).collect(Collectors.toList());
1028
        Map<Integer, TicketSubCategory> subCategoryIdAndSubCategoryMap = csService.getSubCategoryIdAndSubCategoryMap(subCategoryIds);
35571 amit 1029
        if (subCategoryIdAndSubCategoryMap == null) {
1030
            subCategoryIdAndSubCategoryMap = new HashMap<>();
1031
        }
31762 tejbeer 1032
 
1033
        Map<Integer, TicketCategory> subCategoryIdAndCategoryMap = csService.getSubCategoryIdAndCategoryMap(subCategoryIds);
35571 amit 1034
        if (subCategoryIdAndCategoryMap == null) {
1035
            subCategoryIdAndCategoryMap = new HashMap<>();
1036
        }
31762 tejbeer 1037
 
1038
        List<Integer> ticketIds = tickets.stream().map(x -> x.getId()).collect(Collectors.toList());
1039
        Map<Integer, List<Activity>> activityMap = new HashMap<>();
33778 ranu 1040
        Map<Integer, List<Activity>> activityMapWithActivityId = new HashMap<>();
35570 amit 1041
        Map<Integer, AuthUser> authUserMap = new HashMap<>();
31762 tejbeer 1042
 
1043
        if (!ticketIds.isEmpty()) {
35570 amit 1044
            // Fetch activities once and reuse for both maps (fix duplicate query)
1045
            List<Activity> allActivities = activityRepository.selectAll(ticketIds);
1046
            activityMap = allActivities.stream().collect(Collectors.groupingBy(Activity::getTicketId));
1047
            activityMapWithActivityId = allActivities.stream().collect(Collectors.groupingBy(Activity::getId));
31762 tejbeer 1048
 
35570 amit 1049
            // Only fetch users who created activities (fix loading ALL users)
1050
            Set<Integer> activityCreatorIds = allActivities.stream()
1051
                    .map(Activity::getCreatedBy)
1052
                    .filter(id -> id > 0)
1053
                    .collect(Collectors.toSet());
1054
            if (!activityCreatorIds.isEmpty()) {
1055
                authUserMap = authRepository.selectByIds(new ArrayList<>(activityCreatorIds))
1056
                        .stream().collect(Collectors.toMap(AuthUser::getId, x -> x));
1057
            }
31762 tejbeer 1058
        }
33778 ranu 1059
 
31762 tejbeer 1060
        model.addAttribute("ticketStatusValues", TicketStatus.values());
1061
        model.addAttribute("orderByValues", SortOrder.values());
1062
        model.addAttribute("selectedticketStatus", ticketStatus);
1063
        model.addAttribute("selectedorderby", sortOrder);
1064
        model.addAttribute("tickets", tickets);
1065
        model.addAttribute("ticketSearchTypes", TicketSearchType.values());
1066
        model.addAttribute("ticketSearchType", ticketSearchType);
1067
        model.addAttribute("searchTerm", searchTerm);
1068
        model.addAttribute("authUserListMap", authUserListMap);
1069
        model.addAttribute("subCategoryIdAndSubCategoryMap", subCategoryIdAndSubCategoryMap);
1070
 
1071
        model.addAttribute("subCategoryIdAndCategoryMap", subCategoryIdAndCategoryMap);
1072
 
1073
        model.addAttribute("activityMap", activityMap);
33778 ranu 1074
        model.addAttribute("authUserMap", authUserMap);
1075
        model.addAttribute("activityMapWithActivityId", activityMapWithActivityId);
35594 amit 1076
        model.addAttribute("isCrmUser", isCrmUser);
31762 tejbeer 1077
 
1078
        return "managerTicket";
1079
    }
1080
 
1081
 
1082
    @GetMapping(value = "/cs/edit-ticket")
35594 amit 1083
    public String getEditTicket(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, Model model) throws ProfitMandiBusinessException {
1084
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1085
        AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1086
        boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1087
 
31762 tejbeer 1088
        Ticket ticket = ticketRepository.selectById(ticketId);
1089
        List<TicketCategory> ticketCategories = csService.getAllTicketCategotyFromSubCategory();
1090
        TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());
1091
        List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAll(ticketSubCategory.getCategoryId());
1092
        List<AuthUser> authUsers = authRepository.selectAllActiveUser();
35594 amit 1093
 
35617 amit 1094
        // CRM users should not see invisible subcategories
35594 amit 1095
        if (isCrmUser) {
1096
            ticketSubCategories = ticketSubCategories.stream()
35617 amit 1097
                    .filter(TicketSubCategory::isVisibility)
35594 amit 1098
                    .collect(Collectors.toList());
1099
        }
1100
 
1101
        // Get partner name for modal title
1102
        String partnerName = retailerService.getFofoRetailer(ticket.getFofoId()).getBusinessName();
1103
 
31762 tejbeer 1104
        model.addAttribute("ticket", ticket);
1105
        model.addAttribute("ticketCategories", ticketCategories);
1106
        model.addAttribute("ticketSubCategories", ticketSubCategories);
1107
        model.addAttribute("ticketSubCategory", ticketSubCategory);
1108
        model.addAttribute("authUsers", authUsers);
35594 amit 1109
        model.addAttribute("isCrmUser", isCrmUser);
1110
        model.addAttribute("partnerName", partnerName);
31762 tejbeer 1111
        return "edit-ticket-modal";
1112
    }
1113
 
34913 ranu 1114
    @GetMapping(value = "/cs/edit-partner-ticket")
35594 amit 1115
    public String getEditPartnerTicket(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, Model model) throws ProfitMandiBusinessException {
1116
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1117
        AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1118
        boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1119
 
34913 ranu 1120
        Ticket ticket = ticketRepository.selectById(ticketId);
1121
        List<TicketCategory> ticketCategories = csService.getAllTicketCategotyFromSubCategory();
1122
        TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());
1123
        List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAll(ticketSubCategory.getCategoryId());
1124
        List<AuthUser> authUsers = authRepository.selectAllActiveUser();
35594 amit 1125
 
35617 amit 1126
        // CRM users should not see invisible subcategories
35594 amit 1127
        if (isCrmUser) {
1128
            ticketSubCategories = ticketSubCategories.stream()
35617 amit 1129
                    .filter(TicketSubCategory::isVisibility)
35594 amit 1130
                    .collect(Collectors.toList());
1131
        }
1132
 
1133
        // Get partner name for modal title
1134
        String partnerName = retailerService.getFofoRetailer(ticket.getFofoId()).getBusinessName();
1135
 
34913 ranu 1136
        model.addAttribute("ticket", ticket);
1137
        model.addAttribute("ticketCategories", ticketCategories);
1138
        model.addAttribute("ticketSubCategories", ticketSubCategories);
1139
        model.addAttribute("ticketSubCategory", ticketSubCategory);
1140
        model.addAttribute("authUsers", authUsers);
35594 amit 1141
        model.addAttribute("isCrmUser", isCrmUser);
1142
        model.addAttribute("partnerName", partnerName);
34913 ranu 1143
        return "edit-ticket-partner-modal";
1144
    }
1145
 
31762 tejbeer 1146
    @PostMapping(value = "/cs/edit-ticket")
1147
    public String editTicket(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, @RequestParam(name = "subCategoryId", defaultValue = "0") int subCategoryId, @RequestParam(name = "categoryId", defaultValue = "0") int categoryId, @RequestParam(name = "authUserId", defaultValue = "0") int authUserId, @RequestParam(name = "escalationType", defaultValue = "L1") EscalationType escalationType, Model model) throws Exception {
1148
        LOGGER.info("Ticket Id {}, CategoryId {}, SubCategory Id {} authUserId {}", ticketId, categoryId, subCategoryId, authUserId);
35592 amit 1149
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1150
 
1151
        // Only admins can edit tickets
1152
        if (!roleManager.isAdmin(loginDetails.getRoleIds())) {
1153
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Only admins can edit tickets");
1154
        }
1155
 
31762 tejbeer 1156
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 1157
        if (ticket == null) {
1158
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
1159
        }
1160
 
1161
        // Verify admin has access to this ticket (assigned, manager, escalation chain, or CRM)
1162
        AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1163
        boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1164
 
1165
        if (!isCrmUser) {
1166
            List<TicketAssigned> assignments = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
1167
            boolean isAssigned = assignments.stream().anyMatch(ta -> ta.getAssineeId() == currentAuthUser.getId() || ta.getManagerId() == currentAuthUser.getId());
1168
            boolean isInEscalationChain = ticket.getL1AuthUser() == currentAuthUser.getId() ||
1169
                    ticket.getL2AuthUser() == currentAuthUser.getId() ||
1170
                    ticket.getL3AuthUser() == currentAuthUser.getId() ||
1171
                    ticket.getL4AuthUser() == currentAuthUser.getId() ||
1172
                    ticket.getL5AuthUser() == currentAuthUser.getId();
1173
 
1174
            if (!isAssigned && !isInEscalationChain) {
1175
                throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to edit this ticket");
1176
            }
1177
        }
1178
 
31762 tejbeer 1179
        csService.updateTicket(categoryId, subCategoryId, ticket, authUserId, escalationType);
1180
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1181
        return "response";
1182
 
1183
    }
1184
 
34913 ranu 1185
    @PostMapping(value = "/cs/edit-partner-ticket")
1186
    public String editPartnerTicket(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, @RequestParam(name = "subCategoryId", defaultValue = "0") int subCategoryId, @RequestParam(name = "categoryId", defaultValue = "0") int categoryId, @RequestParam(name = "authUserId", defaultValue = "0") int authUserId, @RequestParam(name = "escalationType", defaultValue = "L1") EscalationType escalationType, Model model) throws Exception {
1187
        LOGGER.info("Ticket Id {}, CategoryId {}, SubCategory Id {} authUserId {}", ticketId, categoryId, subCategoryId, authUserId);
35592 amit 1188
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1189
 
1190
        // Only admins can edit partner tickets
1191
        if (!roleManager.isAdmin(loginDetails.getRoleIds())) {
1192
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Only admins can edit partner tickets");
1193
        }
1194
 
34913 ranu 1195
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 1196
        if (ticket == null) {
1197
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
1198
        }
1199
 
1200
        // Verify admin has access (must be in Sales, ABM, or RBM position for the partner)
1201
        AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1202
        Map<String, Set<Integer>> authUserPartnerMap = csService.getAuthUserPartnerIdMapping();
1203
        Set<Integer> allowedPartnerIds = authUserPartnerMap.get(currentAuthUser.getEmailId());
1204
 
1205
        if (allowedPartnerIds == null || !allowedPartnerIds.contains(ticket.getFofoId())) {
1206
            // Also allow CRM users
1207
            boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1208
            if (!isCrmUser) {
1209
                throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to edit this partner's ticket");
1210
            }
1211
        }
1212
 
34913 ranu 1213
        csService.updateTicket(categoryId, subCategoryId, ticket, authUserId, escalationType);
1214
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1215
        return "response";
1216
 
1217
    }
1218
 
31762 tejbeer 1219
    @PostMapping(value = "/cs/changeTicketAssignee")
1220
    public String changeTicketAssignee(HttpServletRequest request, @RequestParam(name = "positionId", defaultValue = "0") int positionId, Model model) throws Exception {
1221
        Position position = positionRepository.selectById(positionId);
1222
        if (position.isTicketAssignee()) {
1223
            position.setTicketAssignee(false);
1224
        } else {
1225
            position.setTicketAssignee(true);
1226
        }
1227
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1228
        return "response";
1229
    }
1230
 
1231
 
1232
    @DeleteMapping(value = "/cs/removePosition")
1233
    public String removePosition(HttpServletRequest request, @RequestParam(name = "positionId", defaultValue = "0") int positionId, Model model) throws Exception {
1234
        positionRepository.delete(positionId);
1235
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1236
        return "response";
1237
    }
1238
 
1239
    @PostMapping(value = "/cs/create-last-activity")
1240
    public String createlastActivity(HttpServletRequest request, @RequestParam(name = "ticketId") int ticketId, @RequestParam(name = "lastactivity") ActivityType lastActivity, Model model) throws Exception {
1241
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1242
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 1243
 
1244
        if (ticket == null) {
1245
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
1246
        }
1247
 
1248
        // Authorization check for partners: can only update their own tickets
1249
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
1250
        if (!isAdmin && ticket.getFofoId() != loginDetails.getFofoId()) {
1251
            throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to update this ticket");
1252
        }
1253
 
31762 tejbeer 1254
        Activity activity = new Activity();
1255
        String subject = String.format(ACTIVITY_SUBJECT, ticket.getId());
35592 amit 1256
        if (isAdmin) {
35603 amit 1257
            // CRM team members can resolve any ticket
1258
            // Sales team members can resolve their own Sales category tickets
1259
            // RBM team members can resolve their own RBM category tickets
35592 amit 1260
            AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1261
            boolean isCrmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
35603 amit 1262
            boolean isSalesUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_SALES);
1263
            boolean isRbmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_RBM);
1264
 
1265
            // Check if ticket belongs to Sales or RBM category
1266
            TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());
1267
            boolean isSalesTicket = ticketSubCategory != null && ticketSubCategory.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_SALES;
1268
            boolean isRbmTicket = ticketSubCategory != null && ticketSubCategory.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_RBM;
1269
 
1270
            // Allow if CRM user OR (Sales user AND Sales ticket) OR (RBM user AND RBM ticket)
1271
            if (!isCrmUser && !(isSalesUser && isSalesTicket) && !(isRbmUser && isRbmTicket)) {
1272
                throw new ProfitMandiBusinessException("Ticket", ticketId, "Only CRM, Sales (for Sales tickets), or RBM (for RBM tickets) team can mark tickets as resolved");
35592 amit 1273
            }
31762 tejbeer 1274
            ticket.setLastActivity(lastActivity);
1275
            String to = retailerService.getFofoRetailer(ticket.getFofoId()).getEmail();
1276
            String message = String.format(PARTNER_RESOLVED_TICKET_MAIL, ticketId, "REOPEN");
1277
            activity.setMessage(message);
35592 amit 1278
            activity.setCreatedBy(authUser.getId());
31762 tejbeer 1279
            activity.setTicketId(ticketId);
1280
            activity.setCreateTimestamp(LocalDateTime.now());
1281
            activity.setType(ActivityType.COMMUNICATION_OUT);
1282
            this.activityRelatedMail(to, null, subject, message);
1283
        } else {
1284
            if (ActivityType.RESOLVED_ACCEPTED == lastActivity) {
1285
                ticket.setLastActivity(lastActivity);
1286
                ticket.setCloseTimestamp(LocalDateTime.now());
1287
                activity.setMessage(ActivityType.RESOLVED_ACCEPTED.toString());
1288
                activity.setCreatedBy(0);
1289
                activity.setTicketId(ticketId);
1290
                activity.setType(ActivityType.COMMUNICATION_IN);
1291
                activity.setCreateTimestamp(LocalDateTime.now());
1292
            } else {
1293
                String message = String.format(INTERNAL_REOPEN_MAIL, ticketId, retailerService.getFofoRetailer(loginDetails.getFofoId()).getBusinessName());
1294
                String to = authRepository.selectById(ticket.getL1AuthUser()).getEmailId();
35395 amit 1295
                String[] ccTo = authRepository.selectByIds(Arrays.asList(ticket.getL2AuthUser(), ticket.getL3AuthUser(), ticket.getL4AuthUser(), ticket.getL5AuthUser())).stream().map(x -> x.getEmailId()).toArray(String[]::new);
31762 tejbeer 1296
                ticket.setLastActivity(lastActivity);
1297
                ticket.setUpdateTimestamp(LocalDateTime.now());
1298
                ticketAssignedRepository.deleteByTicketId(ticketId);
1299
                TicketAssigned ticketAssigned = new TicketAssigned();
1300
                ticketAssigned.setAssineeId(ticket.getL1AuthUser());
1301
                ticketAssigned.setTicketId(ticketId);
1302
                ticketAssignedRepository.persist(ticketAssigned);
1303
                activity.setMessage(INTERNAL_REOPEN_ACTIVITY_MESSAGE);
1304
                activity.setCreatedBy(0);
1305
                activity.setTicketId(ticketId);
1306
                activity.setType(ActivityType.COMMUNICATION_IN);
1307
                activity.setCreateTimestamp(LocalDateTime.now());
1308
                this.activityRelatedMail(to, ccTo, subject, message);
1309
                this.activityRelatedMail(retailerService.getFofoRetailer(loginDetails.getFofoId()).getEmail(), null, subject, String.format(PARTNER_REOPEN, ticketId));
1310
            }
1311
 
1312
        }
1313
        activityRepository.persist(activity);
1314
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1315
        return "response";
1316
    }
1317
 
32812 shampa 1318
 
1319
 
1320
 
1321
 
1322
    @PostMapping(value = "/partner-position/update")
1323
    public String positionUpdated(Model model, @RequestBody List<PartnerPositonUpdateModel> partnerPositionUpdateModels)
1324
            throws Exception {
1325
 
32821 shampa 1326
        Map<Integer, List<String>> positionIdsToAddMap = partnerPositionUpdateModels.stream().filter(x->x.getPositionIdTo()!=0).collect(Collectors.groupingBy(x->x.getPositionIdTo(),
32812 shampa 1327
                Collectors.mapping(x->x.getStoreCode(), Collectors.toList())));
1328
 
32821 shampa 1329
        Map<Integer, List<String>> positionIdsToRemoveMap = partnerPositionUpdateModels.stream().filter(x->x.getPositionIdFrom()!=0).collect(Collectors.groupingBy(x->x.getPositionIdFrom(),
32812 shampa 1330
                Collectors.mapping(x->x.getStoreCode(), Collectors.toList())));
1331
 
1332
        List<Integer> positionIdsToUpdate = new ArrayList<>();
1333
        positionIdsToUpdate.addAll(positionIdsToAddMap.keySet());
1334
        positionIdsToUpdate.addAll(positionIdsToRemoveMap.keySet());
1335
 
35395 amit 1336
        Map<Integer, Position> positionsToUpdateMap =  positionRepository.selectByIds(positionIdsToUpdate).stream().collect(Collectors.toMap(x->x.getId(), x->x));
32812 shampa 1337
        List<Integer> invalidPositionIds = positionsToUpdateMap.values().stream().filter(x-> x.getCategoryId()!= ProfitMandiConstants.TICKET_CATEGORY_RBM
34908 ranu 1338
                && x.getCategoryId() != ProfitMandiConstants.TICKET_CATEGORY_SALES && x.getCategoryId() != ProfitMandiConstants.TICKET_CATEGORY_ABM).map(x -> x.getId()).collect(Collectors.toList());
32812 shampa 1339
        if(invalidPositionIds.size() > 0) {
34908 ranu 1340
            String message = "Non RBM/Sales/ABM are not allowed - " + invalidPositionIds;
32812 shampa 1341
            throw new ProfitMandiBusinessException(message, message, message);
1342
        }
1343
 
1344
        for (Map.Entry<Integer, List<String>> positionIdStoreMapEntry : positionIdsToAddMap.entrySet()) {
1345
            int positionId = positionIdStoreMapEntry.getKey();
1346
            Position position = positionsToUpdateMap.get(positionId);
32821 shampa 1347
            LOGGER.info("positionId - {}, Position - {}", positionId, position);
32812 shampa 1348
            List<String> storeCodesToAdd = positionIdStoreMapEntry.getValue();
1349
            List<Integer> retailerIdsToAdd = fofoStoreRepository.selectByStoreCodes(storeCodesToAdd).stream().map(x->x.getId()).collect(Collectors.toList());
1350
            Map<Integer, PartnerPosition> partnerPositionsMapByFofoId  = partnerPositionRepository
32821 shampa 1351
                    .selectByRegionIdAndPostionId(Arrays.asList(position.getRegionId())
1352
                            ,Arrays.asList(positionId)).stream().collect(Collectors.toMap(x->x.getFofoId(),x->x));
32812 shampa 1353
            for (Integer retailerIdToAdd : retailerIdsToAdd) {
1354
                if (!partnerPositionsMapByFofoId.containsKey(retailerIdToAdd)) {
1355
                    PartnerPosition partnerPositionNew = new PartnerPosition();
1356
                    partnerPositionNew.setPositionId(positionId);
1357
                    partnerPositionNew.setFofoId(retailerIdToAdd);
1358
                    partnerPositionNew.setRegionId(position.getRegionId());
32865 amit.gupta 1359
                    partnerPositionRepository.persist(partnerPositionNew);
32812 shampa 1360
                }
1361
            }
1362
        }
1363
 
1364
        for (Map.Entry<Integer, List<String>> positionIdStoreMapEntry : positionIdsToRemoveMap.entrySet()) {
1365
 
1366
            int positionId = positionIdStoreMapEntry.getKey();
1367
            Position position = positionsToUpdateMap.get(positionId);
1368
            List<String> storeCodesToRemove = positionIdStoreMapEntry.getValue();
1369
            List<Integer> retailerIdsToRemove = fofoStoreRepository.selectByStoreCodes(storeCodesToRemove).stream().map(x->x.getId()).collect(Collectors.toList());
1370
            Map<Integer, PartnerPosition> partnerPositionsMapByFofoId  = partnerPositionRepository
1371
                    .selectByRegionIdAndPostionId(Arrays.asList(position.getRegionId()),Arrays.asList(positionId)).stream().collect(Collectors.toMap(x->x.getFofoId(),x->x));
1372
            for (Integer retailerIdToRemove : retailerIdsToRemove) {
1373
                if (partnerPositionsMapByFofoId.containsKey(retailerIdToRemove)) {
1374
                   PartnerPosition partnerPositionToRemove =  partnerPositionsMapByFofoId.get(retailerIdToRemove);
1375
                   partnerPositionRepository.delete(partnerPositionToRemove);
1376
                }
1377
            }
1378
        }
1379
 
1380
 
1381
 
1382
        /*partnerPositionUpdateModels.str
1383
 
1384
        Map<Integer, Position> positionIdMap = positionsToUpdate.stream().collect(Collectors.toMap(x->x.getId(), x->x));
1385
        for (PartnerPositonUpdateModel partnerPositionUpdateModel : partnerPositionUpdateModels) {
1386
            FofoStore fofoStore = fofoStoreRepository.selectByStoreCode(partnerPositionUpdateModel.getStoreCode());
1387
            Position positionFrom = positionIdMap.get(partnerPositionUpdateModel.getPositionIdFrom());
1388
            Position positionTo = positionIdMap.get(partnerPositionUpdateModel.getPositionIdTo());
1389
            if(positionFrom != null) {
1390
                partnerPositionRepository.selectByRegionIdAndPostionId(Arrays.)
1391
              int regionId = positionFrom.getRegionId()
1392
            }
1393
            if(positionTo != null) {
1394
 
1395
            }
1396
        }*/
1397
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1398
        return "response";
1399
 
1400
    }
1401
 
1402
 
24417 govind 1403
}