Subversion Repositories SmartDukaan

Rev

Rev 35594 | Rev 35603 | 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) {
408
            Map<Integer, CustomRetailer> validRetailers = retailerService.getFofoRetailers(false);
409
            for (int fofoId : selectedFofoIds) {
410
                if (!validRetailers.containsKey(fofoId)) {
411
                    throw new ProfitMandiBusinessException("Position", fofoId, "Invalid fofoId");
35571 amit 412
                }
413
            }
414
        }
415
 
32493 amit.gupta 416
        partnerPositionRepository.delete(positionId);
35571 amit 417
        if (selectedFofoIds != null) {
418
            for (int fofoId : selectedFofoIds) {
419
                PartnerPosition partnerPosition = new PartnerPosition();
420
                partnerPosition.setFofoId(fofoId);
421
                partnerPosition.setRegionId(regionId);
422
                partnerPosition.setPositionId(positionId);
423
                partnerPositionRepository.persist(partnerPosition);
424
            }
31762 tejbeer 425
        }
25570 tejbeer 426
 
31762 tejbeer 427
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
25570 tejbeer 428
 
31762 tejbeer 429
        return "response";
430
    }
24417 govind 431
 
31762 tejbeer 432
    @GetMapping(value = "/cs/createTicket")
433
    public String createTicket(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
434
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
35594 amit 435
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
436
        boolean isCrmUser = false;
437
 
31762 tejbeer 438
        List<TicketCategory> ticketCategories = csService.getAllTicketCategotyFromSubCategory();
35594 amit 439
 
440
        if (isAdmin) {
441
            AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
442
            isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
443
 
444
            // CRM users should not see Sales and RBM categories
445
            if (isCrmUser) {
446
                ticketCategories = ticketCategories.stream()
447
                        .filter(tc -> tc.getId() != ProfitMandiConstants.TICKET_CATEGORY_SALES
448
                                && tc.getId() != ProfitMandiConstants.TICKET_CATEGORY_RBM)
449
                        .collect(Collectors.toList());
450
            }
451
        }
452
 
453
        model.addAttribute("roleType", isAdmin);
31762 tejbeer 454
        model.addAttribute("ticketCategories", ticketCategories);
35594 amit 455
        model.addAttribute("isCrmUser", isCrmUser);
31762 tejbeer 456
        return "create-ticket";
457
    }
24417 govind 458
 
31762 tejbeer 459
    @GetMapping(value = "/cs/getSubCategoriesByCategoryId")
35594 amit 460
    public String getSubCategoriesByCategoryId(HttpServletRequest request, @RequestParam(name = "categoryId", defaultValue = "0") int categoryId, Model model) throws ProfitMandiBusinessException {
461
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
462
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
463
        boolean isCrmUser = false;
464
 
465
        if (isAdmin) {
466
            AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
467
            isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
468
        }
469
 
31830 amit.gupta 470
        List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAllVisible(categoryId);
35594 amit 471
 
472
        // CRM users should not see Sales Escalation and RBM Escalation subcategories
473
        if (isCrmUser) {
474
            ticketSubCategories = ticketSubCategories.stream()
475
                    .filter(tsc -> tsc.getId() != ProfitMandiConstants.TICKET_SUBCATEGORY_SALES_ESCALATION
476
                            && tsc.getId() != ProfitMandiConstants.TICKET_SUBCATEGORY_RBM_ESCALATION)
477
                    .collect(Collectors.toList());
478
        }
479
 
31762 tejbeer 480
        LOGGER.info(ticketSubCategories);
481
        model.addAttribute("ticketSubCategories", ticketSubCategories);
482
        return "ticket-sub-categories";
483
    }
24417 govind 484
 
24791 govind 485
 
31762 tejbeer 486
    @GetMapping(value = "/cs/getEscalationTypeByCategoryId")
487
    public String getEscalationTypeByCategoryId(HttpServletRequest request, @RequestParam(name = "categoryId", defaultValue = "0") int categoryId, @RequestParam(name = "authId", defaultValue = "0") int authId, Model model) {
488
        List<Position> positions = positionRepository.selectPositionbyCategoryIdAndAuthId(categoryId, authId);
489
        List<EscalationType> escalationTypes = new ArrayList<>();
24791 govind 490
 
31762 tejbeer 491
        if (!positions.isEmpty()) {
492
            escalationTypes = positions.stream().map(x -> x.getEscalationType()).distinct().collect(Collectors.toList());
493
        }
24620 govind 494
 
31762 tejbeer 495
        LOGGER.info("escalationTypes {}", escalationTypes);
24500 govind 496
 
31762 tejbeer 497
        model.addAttribute("escalationTypes", escalationTypes);
498
        return "ticket-escalationtype";
499
    }
24500 govind 500
 
24824 govind 501
 
31762 tejbeer 502
    @GetMapping(value = "/cs/getCategoriesByAuthId")
503
    public String getCategoriesByAuthId(HttpServletRequest request, @RequestParam(name = "authId", defaultValue = "0") int authId, Model model) {
24824 govind 504
 
24787 govind 505
 
31762 tejbeer 506
        List<Position> positions = positionRepository.selectPositionByAuthId(authId);
24791 govind 507
 
31762 tejbeer 508
        LOGGER.info("positions {}", positions);
24417 govind 509
 
31762 tejbeer 510
        List<TicketCategory> ticketCategories = new ArrayList<TicketCategory>();
24417 govind 511
 
31762 tejbeer 512
        if (!positions.isEmpty()) {
24417 govind 513
 
31762 tejbeer 514
            List<Integer> categoryIds = positions.stream().map(x -> x.getCategoryId()).collect(Collectors.toList());
515
            ticketCategories = ticketCategoryRepository.selectAll(categoryIds);
516
        }
517
        LOGGER.info("ticketCategories {}", ticketCategories);
518
        model.addAttribute("ticketCategories", ticketCategories);
519
        return "ticket-categories";
520
    }
27270 tejbeer 521
 
31762 tejbeer 522
    @PostMapping(value = "/cs/createTicket")
523
    public String createTicket(HttpServletRequest request, @RequestParam(name = "categoryId") int categoryId, @RequestParam(name = "subCategoryId") int subCategoryId, @RequestParam(name = "message") String message, Model model) throws Exception {
524
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
525
        List<Ticket> tickets = ticketRepository.selectAllResolvedMarkedTicketByCreator(loginDetails.getFofoId());
526
        if (tickets.size() > 3 || tickets.size() == 3) {
527
            model.addAttribute("response1", mvcResponseSender.createResponseString(false));
528
        } else {
529
            csService.createTicket(loginDetails.getFofoId(), categoryId, subCategoryId, message);
530
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
531
        }
532
        return "response";
533
    }
27270 tejbeer 534
 
31762 tejbeer 535
    @GetMapping(value = "/cs/myticket")
536
    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 {
537
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
538
        List<Ticket> tickets = null;
539
        List<TicketAssigned> ticketAssigneds = null;
540
        long size = 0;
541
        Map<Integer, AuthUser> authUserIdAndAuthUserMap = null;
35569 amit 542
        boolean isAdmin = roleManager.isAdmin(new HashSet<>(loginDetails.getRoleIds()));
543
        AuthUser currentAuthUser = isAdmin ? authRepository.selectByEmailOrMobile(loginDetails.getEmailId()) : null;
544
 
35592 amit 545
        // Check if user is CRM category - CRM users see ALL tickets to handle partner communications
546
        boolean isCrmUser = isAdmin && currentAuthUser != null && positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
547
 
35569 amit 548
        if (isAdmin) {
549
            int authUserId = currentAuthUser.getId();
35592 amit 550
 
551
            if (isCrmUser) {
35601 amit 552
                // CRM users see ALL tickets EXCEPT Sales Escalation and RBM Escalation subcategories
31762 tejbeer 553
                if (ticketStatus.equals(TicketStatus.RESOLVED)) {
35592 amit 554
                    tickets = ticketRepository.selectAllTickets(Optional.empty(), sortOrder, ticketSearchType, searchTerm);
31762 tejbeer 555
                } else {
35592 amit 556
                    tickets = ticketRepository.selectAllTickets(Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), sortOrder, ticketSearchType, searchTerm);
31762 tejbeer 557
                }
35601 amit 558
 
559
                // Filter out Sales Escalation and RBM Escalation subcategory tickets for CRM users
560
                tickets = tickets.stream()
561
                        .filter(t -> t.getSubCategoryId() != ProfitMandiConstants.TICKET_SUBCATEGORY_SALES_ESCALATION
562
                                && t.getSubCategoryId() != ProfitMandiConstants.TICKET_SUBCATEGORY_RBM_ESCALATION)
563
                        .collect(Collectors.toList());
564
                size = tickets.size();
31762 tejbeer 565
            } else {
35592 amit 566
                // Non-CRM admins see only tickets assigned to them
567
                if (ticketSearchType == null) {
568
                    if (ticketStatus.equals(TicketStatus.RESOLVED)) {
569
                        tickets = ticketRepository.selectAllByAssignee(authUserId, Optional.empty(), sortOrder, null, searchTerm);
570
                        size = ticketRepository.selectAllCountByAssignee(authUserId, Optional.empty(), null, searchTerm);
571
                    } else {
572
                        tickets = ticketRepository.selectAllByAssignee(authUserId, Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), sortOrder, null, searchTerm);
573
                        size = ticketRepository.selectAllCountByAssignee(authUserId, Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), null, searchTerm);
574
                    }
31762 tejbeer 575
                } else {
35592 amit 576
                    if (ticketStatus.equals(TicketStatus.RESOLVED)) {
577
                        tickets = ticketRepository.selectAllByAssignee(authUserId, Optional.empty(), sortOrder, ticketSearchType, searchTerm);
578
                        size = ticketRepository.selectAllCountByAssignee(authUserId, Optional.empty(), ticketSearchType, searchTerm);
579
                    } else {
580
                        tickets = ticketRepository.selectAllByAssignee(authUserId, Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), sortOrder, ticketSearchType, searchTerm);
581
                        size = ticketRepository.selectAllCountByAssignee(authUserId, Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), ticketSearchType, searchTerm);
582
                    }
31762 tejbeer 583
                }
584
            }
585
            // LOGGER.info(size + "size");
586
            if (tickets.size() > 0) {
587
                ticketAssigneds = ticketAssignedRepository.selectByTicketIds(tickets.stream().map(x -> x.getId()).collect(Collectors.toList()));
588
                authUserIdAndAuthUserMap = csService.getAuthUserIdAndAuthUserMap(ticketAssigneds);
589
                Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = csService.getPartnerByFofoIds(tickets);
590
                model.addAttribute("fofoIdsAndCustomRetailer", fofoIdsAndCustomRetailer);
591
            }
24500 govind 592
 
31762 tejbeer 593
        } else {
594
            tickets = ticketRepository.selectAllByCreator(loginDetails.getFofoId(), Optional.of(TicketStatus.OPENED.equals(ticketStatus)), sortOrder);
595
            size = ticketRepository.selectAllCountByCreator(loginDetails.getFofoId(), Optional.of(TicketStatus.OPENED.equals(ticketStatus)));
596
        }
597
        authUserIdAndAuthUserMap = csService.getTicketIdAndAuthUserMapUsingTickets(tickets);
35571 amit 598
        if (authUserIdAndAuthUserMap == null) {
599
            authUserIdAndAuthUserMap = new HashMap<>();
600
        }
24620 govind 601
 
31762 tejbeer 602
        model.addAttribute("size", size);
35569 amit 603
        model.addAttribute("roleType", isAdmin);
35592 amit 604
        // isCrmUser already calculated at start of method
35569 amit 605
        model.addAttribute("isCrmUser", isCrmUser);
24500 govind 606
 
31762 tejbeer 607
        List<Integer> subCategoryIds = tickets.stream().map(x -> x.getSubCategoryId()).collect(Collectors.toList());
608
        Map<Integer, TicketSubCategory> subCategoryIdAndSubCategoryMap = csService.getSubCategoryIdAndSubCategoryMap(subCategoryIds);
35571 amit 609
        if (subCategoryIdAndSubCategoryMap == null) {
610
            subCategoryIdAndSubCategoryMap = new HashMap<>();
611
        }
24747 govind 612
 
31762 tejbeer 613
        Map<Integer, TicketCategory> subCategoryIdAndCategoryMap = csService.getSubCategoryIdAndCategoryMap(subCategoryIds);
35571 amit 614
        if (subCategoryIdAndCategoryMap == null) {
615
            subCategoryIdAndCategoryMap = new HashMap<>();
616
        }
27318 amit.gupta 617
 
31762 tejbeer 618
        List<Integer> ticketIds = tickets.stream().map(x -> x.getId()).collect(Collectors.toList());
24500 govind 619
 
35569 amit 620
        Map<Integer, List<Activity>> activityMap = new HashMap<>();
33864 ranu 621
        Map<Integer, List<Activity>> activityMapWithActivityId = new HashMap<>();
35569 amit 622
        Map<Integer, AuthUser> authUserMap = new HashMap<>();
24500 govind 623
 
31762 tejbeer 624
        if (!ticketIds.isEmpty()) {
35569 amit 625
            // Fetch activities once and group by both ticketId and activityId
626
            List<Activity> allActivities = activityRepository.selectAll(ticketIds);
627
            activityMap = allActivities.stream().collect(Collectors.groupingBy(Activity::getTicketId));
628
            activityMapWithActivityId = allActivities.stream().collect(Collectors.groupingBy(Activity::getId));
24787 govind 629
 
35569 amit 630
            // Only fetch AuthUsers who created activities (instead of all users)
631
            Set<Integer> activityCreatorIds = allActivities.stream()
632
                    .map(Activity::getCreatedBy)
633
                    .filter(id -> id > 0)
634
                    .collect(Collectors.toSet());
635
            if (!activityCreatorIds.isEmpty()) {
636
                authUserMap = authRepository.selectByIds(new ArrayList<>(activityCreatorIds))
637
                        .stream().collect(Collectors.toMap(AuthUser::getId, x -> x));
638
            }
31762 tejbeer 639
        }
24787 govind 640
 
31762 tejbeer 641
        model.addAttribute("tickets", tickets);
642
        model.addAttribute("resolved", ActivityType.RESOLVED);
643
        model.addAttribute("resolved-accepted", ActivityType.RESOLVED_ACCEPTED);
644
        model.addAttribute("resolved-rejected", ActivityType.RESOLVED_REJECTED);
645
        model.addAttribute("authUserIdAndAuthUserMap", authUserIdAndAuthUserMap);
646
        model.addAttribute("subCategoryIdAndSubCategoryMap", subCategoryIdAndSubCategoryMap);
27318 amit.gupta 647
 
31762 tejbeer 648
        model.addAttribute("subCategoryIdAndCategoryMap", subCategoryIdAndCategoryMap);
649
        model.addAttribute("activityMap", activityMap);
33864 ranu 650
        model.addAttribute("authUserMap", authUserMap);
651
        model.addAttribute("activityMapWithActivityId", activityMapWithActivityId);
24500 govind 652
 
31762 tejbeer 653
        model.addAttribute("ticketStatusValues", TicketStatus.values());
654
        model.addAttribute("orderByValues", SortOrder.values());
655
        model.addAttribute("selectedticketStatus", ticketStatus);
656
        model.addAttribute("selectedorderby", sortOrder);
657
        model.addAttribute("ticketSearchTypes", TicketSearchType.values());
658
        model.addAttribute("ticketSearchType", ticketSearchType);
659
        model.addAttribute("searchTerm", searchTerm);
660
        return "ticket";
661
    }
24500 govind 662
 
27124 amit.gupta 663
 
31762 tejbeer 664
    @GetMapping(value = "/cs/getActivities")
665
    public String getActivity(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, Model model) throws Exception {
35592 amit 666
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
667
        Ticket ticket = ticketRepository.selectById(ticketId);
668
 
669
        if (ticket == null) {
670
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
671
        }
672
 
673
        // Authorization check: verify user has access to this ticket
674
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
675
        if (!isAdmin) {
676
            // Partners can only view their own tickets
677
            if (ticket.getFofoId() != loginDetails.getFofoId()) {
678
                throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to view this ticket");
679
            }
680
        } else {
681
            // Admins must be assigned to the ticket OR be CRM user OR be in the escalation chain
682
            AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
683
            boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
684
 
685
            if (!isCrmUser) {
686
                // Check if user is assigned or in escalation chain
687
                List<TicketAssigned> assignments = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
688
                boolean isAssigned = assignments.stream().anyMatch(ta -> ta.getAssineeId() == currentAuthUser.getId() || ta.getManagerId() == currentAuthUser.getId());
689
                boolean isInEscalationChain = ticket.getL1AuthUser() == currentAuthUser.getId() ||
690
                        ticket.getL2AuthUser() == currentAuthUser.getId() ||
691
                        ticket.getL3AuthUser() == currentAuthUser.getId() ||
692
                        ticket.getL4AuthUser() == currentAuthUser.getId() ||
693
                        ticket.getL5AuthUser() == currentAuthUser.getId();
694
 
695
                if (!isAssigned && !isInEscalationChain) {
696
                    throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to view this ticket");
697
                }
698
            }
699
        }
700
 
31762 tejbeer 701
        List<Activity> allactivities = activityRepository.selectAll(ticketId);
35570 amit 702
 
703
        // Batch fetch all documents for attachments (fix N+1 query)
704
        List<Integer> documentIds = allactivities.stream()
705
                .flatMap(a -> a.getActivityAttachment().stream())
706
                .map(ActivityAttachment::getDocumentId)
707
                .distinct()
708
                .collect(Collectors.toList());
709
 
710
        Map<Integer, Document> documentMap = Collections.emptyMap();
711
        if (!documentIds.isEmpty()) {
712
            documentMap = documentRepository.selectByIds(documentIds).stream()
713
                    .collect(Collectors.toMap(Document::getId, d -> d));
714
        }
715
 
716
        // Set document names transiently (do not persist during GET)
717
        for (Activity activity : allactivities) {
718
            for (ActivityAttachment attachment : activity.getActivityAttachment()) {
719
                Document document = documentMap.get(attachment.getDocumentId());
720
                if (document != null) {
721
                    attachment.setDocumentName(document.getDisplayName());
722
                }
31762 tejbeer 723
            }
724
        }
725
        List<Activity> activities = null;
35592 amit 726
        if (isAdmin) {
31762 tejbeer 727
            Set<Integer> authUserIds = allactivities.stream().map(x -> x.getCreatedBy()).collect(Collectors.toSet());
35395 amit 728
            List<AuthUser> users = authRepository.selectByIds(new ArrayList<>(authUserIds));
31762 tejbeer 729
            Map<Integer, String> authUserNameMap = users.stream().collect(Collectors.toMap(AuthUser::getId, x -> x.getFirstName() + " " + x.getLastName()));
730
            allactivities.stream().forEach(x -> x.setName(authUserNameMap.get(x.getCreatedBy())));
731
            activities = allactivities;
732
        } else {
733
            activities = allactivities.stream().filter(x -> ActivityType.PARTNER_ACTIVITIES.contains(x.getType())).collect(Collectors.toList());
734
        }
735
        if (activities == null) {
736
            throw new ProfitMandiBusinessException("Activity", ticketId, "No Activity Found");
737
        }
738
        model.addAttribute("response1", mvcResponseSender.createResponseString(activities));
739
        return "response";
24500 govind 740
 
31762 tejbeer 741
    }
24620 govind 742
 
31762 tejbeer 743
    @PostMapping(value = "/cs/createActivity")
744
    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 745
 
31762 tejbeer 746
                                 Model model) throws Exception {
24620 govind 747
 
31762 tejbeer 748
        LOGGER.info("documentIds" + documentIds);
749
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
750
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 751
 
752
        if (ticket == null) {
753
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
754
        }
755
 
756
        // Authorization check: verify user has access to add activity to this ticket
757
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
758
        if (!isAdmin) {
759
            // Partners can only add activity to their own tickets
760
            if (ticket.getFofoId() != loginDetails.getFofoId()) {
761
                throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to add activity to this ticket");
762
            }
763
        } else {
764
            // Admins must be assigned to the ticket OR be CRM user OR be in the escalation chain
765
            AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
766
            boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
767
 
768
            if (!isCrmUser) {
769
                List<TicketAssigned> assignments = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
770
                boolean isAssigned = assignments.stream().anyMatch(ta -> ta.getAssineeId() == currentAuthUser.getId() || ta.getManagerId() == currentAuthUser.getId());
771
                boolean isInEscalationChain = ticket.getL1AuthUser() == currentAuthUser.getId() ||
772
                        ticket.getL2AuthUser() == currentAuthUser.getId() ||
773
                        ticket.getL3AuthUser() == currentAuthUser.getId() ||
774
                        ticket.getL4AuthUser() == currentAuthUser.getId() ||
775
                        ticket.getL5AuthUser() == currentAuthUser.getId();
776
 
777
                if (!isAssigned && !isInEscalationChain) {
778
                    throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to add activity to this ticket");
779
                }
780
            }
781
        }
31762 tejbeer 782
        List<TicketAssigned> ticketAssignedList = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
783
        List<Integer> authUserIds = ticketAssignedList.stream().map(x -> x.getAssineeId()).collect(Collectors.toList());
784
        authUserIds.add(ticketAssignedList.get(ticketAssignedList.size() - 1).getManagerId());
35395 amit 785
        Map<Integer, AuthUser> authUsersMap = authRepository.selectByIds(authUserIds).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
31762 tejbeer 786
        if (ticket.getCloseTimestamp() == null) {
787
            Activity activity = new Activity();
788
            activity.setCreatedBy(0);
789
            activity.setCreateTimestamp(LocalDateTime.now());
790
            String subject = null;
791
            String mailMessage = null;
792
            activity.setMessage(message);
793
            if (!roleManager.isAdmin(new HashSet<>(loginDetails.getRoleIds()))) {
794
                CustomRetailer customRetailer = retailerService.getFofoRetailers(true).get(loginDetails.getFofoId());
795
                activity.setType(ActivityType.COMMUNICATION_IN);
796
                subject = String.format("Ticket Update #%s by franchisee %s", ticket.getId(), customRetailer.getBusinessName() + "(" + customRetailer.getCode() + ")");
797
                mailMessage = String.format("Franchisee message - %s", message);
798
            } else {
799
                AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
800
                activity.setCreatedBy(authUser.getId());
801
                authUsersMap.remove(authUser.getId());
802
                subject = String.format("Ticket Update #%s by %s", ticket.getId(), authUser.getName());
803
                mailMessage = String.format("%s's message - %s", authUser.getFirstName(), message);
35569 amit 804
                // Only CRM users can send external communications
805
                boolean isCrmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
806
                if (internal || !isCrmUser) {
31762 tejbeer 807
                    activity.setType(ActivityType.COMMUNICATION_INTERNAL);
808
                } else {
809
                    String updatedBy = "SD Team";
31854 amit.gupta 810
                    CustomRetailer customRetailer = retailerService.getFofoRetailers(false).get(ticket.getFofoId());
31762 tejbeer 811
                    subject = String.format("Ticket Update #%s by %s", ticket.getId(), updatedBy);
812
                    String partnerMessage = String.format("%s's message - %s", updatedBy, message);
813
                    this.activityRelatedMail(customRetailer.getEmail(), null, "subject", partnerMessage);
814
                    activity.setType(ActivityType.COMMUNICATION_OUT);
815
                }
816
            }
817
            activityRepository.persist(activity);
818
 
819
            for (Integer documentId : documentIds) {
820
                ActivityAttachment activityAttachment = new ActivityAttachment();
821
                activityAttachment.setActivityId(activity.getId());
822
                activityAttachment.setDocumentId(documentId);
823
                activityAttachmentRepository.persist(activityAttachment);
824
            }
825
 
826
            csService.addActivity(ticket, activity);
827
            AuthUser authUser = authUsersMap.remove(authUserIds.get(0));
828
            if (authUser == null) {
829
                authUser = authUsersMap.remove(authUserIds.get(1));
830
            }
831
            model.addAttribute("response1", mvcResponseSender.createResponseString(authUser));
832
            String[] cc = authUsersMap.entrySet().stream().map(x -> x.getValue().getEmailId()).toArray(String[]::new);
833
            this.activityRelatedMail(authUser.getEmailId(), cc, subject, mailMessage);
834
        } else {
835
            throw new ProfitMandiBusinessException("Ticket", ticket.getId(), "Already closed ticket");
836
        }
837
        return "response";
838
    }
839
 
840
    private void activityRelatedMail(String to, String[] cc, String subject, String message) throws ProfitMandiBusinessException {
841
        try {
842
            Utils.sendMailWithAttachments(mailSender, to, cc, subject, message, null);
843
        } catch (Exception e) {
844
            throw new ProfitMandiBusinessException("Ticket Activity", to, "Could not send ticket activity mail");
845
        }
846
    }
847
 
848
    @PostMapping(value = "/cs/closeTicket")
849
    public String closeTicket(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, @RequestParam(name = "happyCode") String happyCode, Model model) throws Exception {
35592 amit 850
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
31762 tejbeer 851
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 852
 
853
        if (ticket == null) {
854
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
855
        }
856
 
857
        // Authorization check: only the ticket owner (partner) can close the ticket
858
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
859
        if (isAdmin) {
860
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Only partners can close tickets using happy code");
861
        }
862
 
863
        // Verify the partner owns this ticket
864
        if (ticket.getFofoId() != loginDetails.getFofoId()) {
865
            throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to close this ticket");
866
        }
867
 
31762 tejbeer 868
        if (ticket.getHappyCode().equals(happyCode)) {
869
            ticket.setCloseTimestamp(LocalDateTime.now());
870
            ticketRepository.persist(ticket);
871
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
872
        } else {
873
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Happy Code can't match");
874
        }
875
        return "response";
876
    }
877
 
34913 ranu 878
    @GetMapping(value = "/cs/myPartyTicketTicket")
879
    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 {
880
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
881
        long size = 0;
882
        AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
883
        List<Ticket> tickets = new ArrayList<>();
884
        Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
885
        Set<Integer> fofoIds = storeGuyMap.get(authUser.getEmailId());
886
 
887
        Map<Integer, List<AuthUser>> authUserListMap = null;
888
        if (fofoIds != null && !fofoIds.isEmpty()) {
35571 amit 889
            // Batch fetch all open tickets for all fofoIds (fix N+1 query)
890
            List<Ticket> allPartnerTickets = ticketRepository.selectAllOpenTickets(new ArrayList<>(fofoIds));
891
            if (allPartnerTickets != null && !allPartnerTickets.isEmpty()) {
892
                // Filter tickets where last_activity is not "RESOLVED"
893
                tickets = allPartnerTickets.stream()
894
                        .filter(ticket -> ticket.getLastActivity() == null ||
895
                                ticket.getLastActivity() != ActivityType.RESOLVED)
896
                        .collect(Collectors.toList());
34913 ranu 897
            }
898
        }
899
 
900
        authUserListMap = csService.getAssignedAuthList(tickets);
901
 
902
 
903
        if (tickets.size() > 0) {
904
            Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = csService.getPartnerByFofoIds(tickets);
905
            model.addAttribute("fofoIdsAndCustomRetailer", fofoIdsAndCustomRetailer);
906
        }
907
 
908
        model.addAttribute("size", tickets.size());
909
        model.addAttribute("tickets", tickets);
910
 
911
        List<Integer> subCategoryIds = tickets.stream().map(x -> x.getSubCategoryId()).collect(Collectors.toList());
912
        Map<Integer, TicketSubCategory> subCategoryIdAndSubCategoryMap = csService.getSubCategoryIdAndSubCategoryMap(subCategoryIds);
35571 amit 913
        if (subCategoryIdAndSubCategoryMap == null) {
914
            subCategoryIdAndSubCategoryMap = new HashMap<>();
915
        }
34913 ranu 916
 
917
        Map<Integer, TicketCategory> subCategoryIdAndCategoryMap = csService.getSubCategoryIdAndCategoryMap(subCategoryIds);
35571 amit 918
        if (subCategoryIdAndCategoryMap == null) {
919
            subCategoryIdAndCategoryMap = new HashMap<>();
920
        }
34913 ranu 921
 
922
        List<Integer> ticketIds = tickets.stream().map(x -> x.getId()).collect(Collectors.toList());
923
        Map<Integer, List<Activity>> activityMap = new HashMap<>();
924
        Map<Integer, List<Activity>> activityMapWithActivityId = new HashMap<>();
35569 amit 925
        Map<Integer, AuthUser> authUserMap = new HashMap<>();
34913 ranu 926
 
927
        if (!ticketIds.isEmpty()) {
35569 amit 928
            // Fetch activities once and group by both ticketId and activityId
929
            List<Activity> allActivities = activityRepository.selectAll(ticketIds);
930
            activityMap = allActivities.stream().collect(Collectors.groupingBy(Activity::getTicketId));
931
            activityMapWithActivityId = allActivities.stream().collect(Collectors.groupingBy(Activity::getId));
34913 ranu 932
 
35569 amit 933
            // Only fetch AuthUsers who created activities (instead of all users)
934
            Set<Integer> activityCreatorIds = allActivities.stream()
935
                    .map(Activity::getCreatedBy)
936
                    .filter(id -> id > 0)
937
                    .collect(Collectors.toSet());
938
            if (!activityCreatorIds.isEmpty()) {
939
                authUserMap = authRepository.selectByIds(new ArrayList<>(activityCreatorIds))
940
                        .stream().collect(Collectors.toMap(AuthUser::getId, x -> x));
941
            }
34913 ranu 942
        }
943
 
944
        model.addAttribute("ticketStatusValues", TicketStatus.values());
945
        model.addAttribute("orderByValues", SortOrder.values());
946
        model.addAttribute("selectedticketStatus", ticketStatus);
947
        model.addAttribute("selectedorderby", sortOrder);
948
        model.addAttribute("tickets", tickets);
949
        model.addAttribute("ticketSearchTypes", TicketSearchType.values());
950
        model.addAttribute("ticketSearchType", ticketSearchType);
951
        model.addAttribute("searchTerm", searchTerm);
35571 amit 952
        model.addAttribute("authUserListMap", authUserListMap != null ? authUserListMap : new HashMap<>());
34913 ranu 953
        model.addAttribute("subCategoryIdAndSubCategoryMap", subCategoryIdAndSubCategoryMap);
954
 
955
        model.addAttribute("subCategoryIdAndCategoryMap", subCategoryIdAndCategoryMap);
956
 
957
        model.addAttribute("activityMap", activityMap);
958
        model.addAttribute("authUserMap", authUserMap);
959
        model.addAttribute("activityMapWithActivityId", activityMapWithActivityId);
35569 amit 960
        // Check if user is in CRM category (only CRM can send external communications)
961
        boolean isCrmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
962
        model.addAttribute("isCrmUser", isCrmUser);
34913 ranu 963
 
964
        return "my-partner-tickets";
965
    }
966
 
31762 tejbeer 967
    @GetMapping(value = "/cs/managerTicket")
968
    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 {
969
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
970
        long size = 0;
971
        AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
35594 amit 972
        boolean isCrmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
973
 
31762 tejbeer 974
        List<Ticket> tickets = null;
975
        Map<Integer, List<AuthUser>> authUserListMap = null;
35594 amit 976
 
977
        // CRM users can see all tickets to assign them (like managers)
978
        if (isCrmUser) {
31762 tejbeer 979
            if (ticketStatus.equals(TicketStatus.RESOLVED)) {
35594 amit 980
                tickets = ticketRepository.selectAllTickets(Optional.empty(), sortOrder, ticketSearchType, searchTerm);
981
                size = ticketRepository.selectAllTicketsCount(Optional.empty(), ticketSearchType, searchTerm);
982
            } else {
983
                tickets = ticketRepository.selectAllTickets(Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), sortOrder, ticketSearchType, searchTerm);
984
                size = ticketRepository.selectAllTicketsCount(Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), ticketSearchType, searchTerm);
985
            }
986
        } else if (ticketSearchType == null) {
987
            if (ticketStatus.equals(TicketStatus.RESOLVED)) {
31762 tejbeer 988
                tickets = ticketRepository.selectAllManagerTicket(authUser.getId(), sortOrder, Optional.empty(), null, searchTerm);
989
                size = ticketRepository.selectAllCountByManagerTicket(authUser.getId(), Optional.empty(), null, 0);
990
            } else {
991
                tickets = ticketRepository.selectAllManagerTicket(authUser.getId(), sortOrder, Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), null, searchTerm);
992
                size = ticketRepository.selectAllCountByManagerTicket(authUser.getId(), Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), null, 0);
993
            }
994
        } else {
995
            if (ticketStatus.equals(TicketStatus.RESOLVED)) {
996
                tickets = ticketRepository.selectAllManagerTicket(authUser.getId(), sortOrder, Optional.empty(), ticketSearchType, searchTerm);
997
                size = ticketRepository.selectAllCountByManagerTicket(authUser.getId(), Optional.empty(), ticketSearchType, searchTerm);
998
            } else {
999
                tickets = ticketRepository.selectAllManagerTicket(authUser.getId(), sortOrder, Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), ticketSearchType, searchTerm);
1000
                size = ticketRepository.selectAllCountByManagerTicket(authUser.getId(), Optional.of(TicketStatus.CLOSED.equals(ticketStatus)), ticketSearchType, searchTerm);
1001
            }
1002
 
1003
        }
1004
        authUserListMap = csService.getAssignedAuthList(tickets);
1005
 
1006
        if (tickets.size() > 0) {
1007
            Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = csService.getPartnerByFofoIds(tickets);
1008
            model.addAttribute("fofoIdsAndCustomRetailer", fofoIdsAndCustomRetailer);
1009
        }
1010
 
1011
        model.addAttribute("size", size);
1012
        model.addAttribute("tickets", tickets);
1013
 
1014
        List<Integer> subCategoryIds = tickets.stream().map(x -> x.getSubCategoryId()).collect(Collectors.toList());
1015
        Map<Integer, TicketSubCategory> subCategoryIdAndSubCategoryMap = csService.getSubCategoryIdAndSubCategoryMap(subCategoryIds);
35571 amit 1016
        if (subCategoryIdAndSubCategoryMap == null) {
1017
            subCategoryIdAndSubCategoryMap = new HashMap<>();
1018
        }
31762 tejbeer 1019
 
1020
        Map<Integer, TicketCategory> subCategoryIdAndCategoryMap = csService.getSubCategoryIdAndCategoryMap(subCategoryIds);
35571 amit 1021
        if (subCategoryIdAndCategoryMap == null) {
1022
            subCategoryIdAndCategoryMap = new HashMap<>();
1023
        }
31762 tejbeer 1024
 
1025
        List<Integer> ticketIds = tickets.stream().map(x -> x.getId()).collect(Collectors.toList());
1026
        Map<Integer, List<Activity>> activityMap = new HashMap<>();
33778 ranu 1027
        Map<Integer, List<Activity>> activityMapWithActivityId = new HashMap<>();
35570 amit 1028
        Map<Integer, AuthUser> authUserMap = new HashMap<>();
31762 tejbeer 1029
 
1030
        if (!ticketIds.isEmpty()) {
35570 amit 1031
            // Fetch activities once and reuse for both maps (fix duplicate query)
1032
            List<Activity> allActivities = activityRepository.selectAll(ticketIds);
1033
            activityMap = allActivities.stream().collect(Collectors.groupingBy(Activity::getTicketId));
1034
            activityMapWithActivityId = allActivities.stream().collect(Collectors.groupingBy(Activity::getId));
31762 tejbeer 1035
 
35570 amit 1036
            // Only fetch users who created activities (fix loading ALL users)
1037
            Set<Integer> activityCreatorIds = allActivities.stream()
1038
                    .map(Activity::getCreatedBy)
1039
                    .filter(id -> id > 0)
1040
                    .collect(Collectors.toSet());
1041
            if (!activityCreatorIds.isEmpty()) {
1042
                authUserMap = authRepository.selectByIds(new ArrayList<>(activityCreatorIds))
1043
                        .stream().collect(Collectors.toMap(AuthUser::getId, x -> x));
1044
            }
31762 tejbeer 1045
        }
33778 ranu 1046
 
31762 tejbeer 1047
        model.addAttribute("ticketStatusValues", TicketStatus.values());
1048
        model.addAttribute("orderByValues", SortOrder.values());
1049
        model.addAttribute("selectedticketStatus", ticketStatus);
1050
        model.addAttribute("selectedorderby", sortOrder);
1051
        model.addAttribute("tickets", tickets);
1052
        model.addAttribute("ticketSearchTypes", TicketSearchType.values());
1053
        model.addAttribute("ticketSearchType", ticketSearchType);
1054
        model.addAttribute("searchTerm", searchTerm);
1055
        model.addAttribute("authUserListMap", authUserListMap);
1056
        model.addAttribute("subCategoryIdAndSubCategoryMap", subCategoryIdAndSubCategoryMap);
1057
 
1058
        model.addAttribute("subCategoryIdAndCategoryMap", subCategoryIdAndCategoryMap);
1059
 
1060
        model.addAttribute("activityMap", activityMap);
33778 ranu 1061
        model.addAttribute("authUserMap", authUserMap);
1062
        model.addAttribute("activityMapWithActivityId", activityMapWithActivityId);
35594 amit 1063
        model.addAttribute("isCrmUser", isCrmUser);
31762 tejbeer 1064
 
1065
        return "managerTicket";
1066
    }
1067
 
1068
 
1069
    @GetMapping(value = "/cs/edit-ticket")
35594 amit 1070
    public String getEditTicket(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, Model model) throws ProfitMandiBusinessException {
1071
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1072
        AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1073
        boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1074
 
31762 tejbeer 1075
        Ticket ticket = ticketRepository.selectById(ticketId);
1076
        List<TicketCategory> ticketCategories = csService.getAllTicketCategotyFromSubCategory();
1077
        TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());
1078
        List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAll(ticketSubCategory.getCategoryId());
1079
        List<AuthUser> authUsers = authRepository.selectAllActiveUser();
35594 amit 1080
 
1081
        // CRM users should not see Sales/RBM categories and their Escalation subcategories
1082
        if (isCrmUser) {
1083
            ticketCategories = ticketCategories.stream()
1084
                    .filter(tc -> tc.getId() != ProfitMandiConstants.TICKET_CATEGORY_SALES
1085
                            && tc.getId() != ProfitMandiConstants.TICKET_CATEGORY_RBM)
1086
                    .collect(Collectors.toList());
1087
            ticketSubCategories = ticketSubCategories.stream()
1088
                    .filter(tsc -> tsc.getId() != ProfitMandiConstants.TICKET_SUBCATEGORY_SALES_ESCALATION
1089
                            && tsc.getId() != ProfitMandiConstants.TICKET_SUBCATEGORY_RBM_ESCALATION)
1090
                    .collect(Collectors.toList());
1091
        }
1092
 
1093
        // Get partner name for modal title
1094
        String partnerName = retailerService.getFofoRetailer(ticket.getFofoId()).getBusinessName();
1095
 
31762 tejbeer 1096
        model.addAttribute("ticket", ticket);
1097
        model.addAttribute("ticketCategories", ticketCategories);
1098
        model.addAttribute("ticketSubCategories", ticketSubCategories);
1099
        model.addAttribute("ticketSubCategory", ticketSubCategory);
1100
        model.addAttribute("authUsers", authUsers);
35594 amit 1101
        model.addAttribute("isCrmUser", isCrmUser);
1102
        model.addAttribute("partnerName", partnerName);
31762 tejbeer 1103
        return "edit-ticket-modal";
1104
    }
1105
 
34913 ranu 1106
    @GetMapping(value = "/cs/edit-partner-ticket")
35594 amit 1107
    public String getEditPartnerTicket(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, Model model) throws ProfitMandiBusinessException {
1108
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1109
        AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1110
        boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1111
 
34913 ranu 1112
        Ticket ticket = ticketRepository.selectById(ticketId);
1113
        List<TicketCategory> ticketCategories = csService.getAllTicketCategotyFromSubCategory();
1114
        TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());
1115
        List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAll(ticketSubCategory.getCategoryId());
1116
        List<AuthUser> authUsers = authRepository.selectAllActiveUser();
35594 amit 1117
 
1118
        // CRM users should not see Sales/RBM categories and their Escalation subcategories
1119
        if (isCrmUser) {
1120
            ticketCategories = ticketCategories.stream()
1121
                    .filter(tc -> tc.getId() != ProfitMandiConstants.TICKET_CATEGORY_SALES
1122
                            && tc.getId() != ProfitMandiConstants.TICKET_CATEGORY_RBM)
1123
                    .collect(Collectors.toList());
1124
            ticketSubCategories = ticketSubCategories.stream()
1125
                    .filter(tsc -> tsc.getId() != ProfitMandiConstants.TICKET_SUBCATEGORY_SALES_ESCALATION
1126
                            && tsc.getId() != ProfitMandiConstants.TICKET_SUBCATEGORY_RBM_ESCALATION)
1127
                    .collect(Collectors.toList());
1128
        }
1129
 
1130
        // Get partner name for modal title
1131
        String partnerName = retailerService.getFofoRetailer(ticket.getFofoId()).getBusinessName();
1132
 
34913 ranu 1133
        model.addAttribute("ticket", ticket);
1134
        model.addAttribute("ticketCategories", ticketCategories);
1135
        model.addAttribute("ticketSubCategories", ticketSubCategories);
1136
        model.addAttribute("ticketSubCategory", ticketSubCategory);
1137
        model.addAttribute("authUsers", authUsers);
35594 amit 1138
        model.addAttribute("isCrmUser", isCrmUser);
1139
        model.addAttribute("partnerName", partnerName);
34913 ranu 1140
        return "edit-ticket-partner-modal";
1141
    }
1142
 
31762 tejbeer 1143
    @PostMapping(value = "/cs/edit-ticket")
1144
    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 {
1145
        LOGGER.info("Ticket Id {}, CategoryId {}, SubCategory Id {} authUserId {}", ticketId, categoryId, subCategoryId, authUserId);
35592 amit 1146
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1147
 
1148
        // Only admins can edit tickets
1149
        if (!roleManager.isAdmin(loginDetails.getRoleIds())) {
1150
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Only admins can edit tickets");
1151
        }
1152
 
31762 tejbeer 1153
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 1154
        if (ticket == null) {
1155
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
1156
        }
1157
 
1158
        // Verify admin has access to this ticket (assigned, manager, escalation chain, or CRM)
1159
        AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1160
        boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1161
 
1162
        if (!isCrmUser) {
1163
            List<TicketAssigned> assignments = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
1164
            boolean isAssigned = assignments.stream().anyMatch(ta -> ta.getAssineeId() == currentAuthUser.getId() || ta.getManagerId() == currentAuthUser.getId());
1165
            boolean isInEscalationChain = ticket.getL1AuthUser() == currentAuthUser.getId() ||
1166
                    ticket.getL2AuthUser() == currentAuthUser.getId() ||
1167
                    ticket.getL3AuthUser() == currentAuthUser.getId() ||
1168
                    ticket.getL4AuthUser() == currentAuthUser.getId() ||
1169
                    ticket.getL5AuthUser() == currentAuthUser.getId();
1170
 
1171
            if (!isAssigned && !isInEscalationChain) {
1172
                throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to edit this ticket");
1173
            }
1174
        }
1175
 
31762 tejbeer 1176
        csService.updateTicket(categoryId, subCategoryId, ticket, authUserId, escalationType);
1177
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1178
        return "response";
1179
 
1180
    }
1181
 
34913 ranu 1182
    @PostMapping(value = "/cs/edit-partner-ticket")
1183
    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 {
1184
        LOGGER.info("Ticket Id {}, CategoryId {}, SubCategory Id {} authUserId {}", ticketId, categoryId, subCategoryId, authUserId);
35592 amit 1185
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1186
 
1187
        // Only admins can edit partner tickets
1188
        if (!roleManager.isAdmin(loginDetails.getRoleIds())) {
1189
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Only admins can edit partner tickets");
1190
        }
1191
 
34913 ranu 1192
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 1193
        if (ticket == null) {
1194
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
1195
        }
1196
 
1197
        // Verify admin has access (must be in Sales, ABM, or RBM position for the partner)
1198
        AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1199
        Map<String, Set<Integer>> authUserPartnerMap = csService.getAuthUserPartnerIdMapping();
1200
        Set<Integer> allowedPartnerIds = authUserPartnerMap.get(currentAuthUser.getEmailId());
1201
 
1202
        if (allowedPartnerIds == null || !allowedPartnerIds.contains(ticket.getFofoId())) {
1203
            // Also allow CRM users
1204
            boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1205
            if (!isCrmUser) {
1206
                throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to edit this partner's ticket");
1207
            }
1208
        }
1209
 
34913 ranu 1210
        csService.updateTicket(categoryId, subCategoryId, ticket, authUserId, escalationType);
1211
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1212
        return "response";
1213
 
1214
    }
1215
 
31762 tejbeer 1216
    @PostMapping(value = "/cs/changeTicketAssignee")
1217
    public String changeTicketAssignee(HttpServletRequest request, @RequestParam(name = "positionId", defaultValue = "0") int positionId, Model model) throws Exception {
1218
        Position position = positionRepository.selectById(positionId);
1219
        if (position.isTicketAssignee()) {
1220
            position.setTicketAssignee(false);
1221
        } else {
1222
            position.setTicketAssignee(true);
1223
        }
1224
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1225
        return "response";
1226
    }
1227
 
1228
 
1229
    @DeleteMapping(value = "/cs/removePosition")
1230
    public String removePosition(HttpServletRequest request, @RequestParam(name = "positionId", defaultValue = "0") int positionId, Model model) throws Exception {
1231
        positionRepository.delete(positionId);
1232
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1233
        return "response";
1234
    }
1235
 
1236
    @PostMapping(value = "/cs/create-last-activity")
1237
    public String createlastActivity(HttpServletRequest request, @RequestParam(name = "ticketId") int ticketId, @RequestParam(name = "lastactivity") ActivityType lastActivity, Model model) throws Exception {
1238
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1239
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 1240
 
1241
        if (ticket == null) {
1242
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
1243
        }
1244
 
1245
        // Authorization check for partners: can only update their own tickets
1246
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
1247
        if (!isAdmin && ticket.getFofoId() != loginDetails.getFofoId()) {
1248
            throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to update this ticket");
1249
        }
1250
 
31762 tejbeer 1251
        Activity activity = new Activity();
1252
        String subject = String.format(ACTIVITY_SUBJECT, ticket.getId());
35592 amit 1253
        if (isAdmin) {
1254
            // Only CRM team members can mark tickets as resolved
1255
            AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1256
            boolean isCrmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1257
            if (!isCrmUser) {
1258
                throw new ProfitMandiBusinessException("Ticket", ticketId, "Only CRM team members can mark tickets as resolved");
1259
            }
31762 tejbeer 1260
            ticket.setLastActivity(lastActivity);
1261
            String to = retailerService.getFofoRetailer(ticket.getFofoId()).getEmail();
1262
            String message = String.format(PARTNER_RESOLVED_TICKET_MAIL, ticketId, "REOPEN");
1263
            activity.setMessage(message);
35592 amit 1264
            activity.setCreatedBy(authUser.getId());
31762 tejbeer 1265
            activity.setTicketId(ticketId);
1266
            activity.setCreateTimestamp(LocalDateTime.now());
1267
            activity.setType(ActivityType.COMMUNICATION_OUT);
1268
            this.activityRelatedMail(to, null, subject, message);
1269
        } else {
1270
            if (ActivityType.RESOLVED_ACCEPTED == lastActivity) {
1271
                ticket.setLastActivity(lastActivity);
1272
                ticket.setCloseTimestamp(LocalDateTime.now());
1273
                activity.setMessage(ActivityType.RESOLVED_ACCEPTED.toString());
1274
                activity.setCreatedBy(0);
1275
                activity.setTicketId(ticketId);
1276
                activity.setType(ActivityType.COMMUNICATION_IN);
1277
                activity.setCreateTimestamp(LocalDateTime.now());
1278
            } else {
1279
                String message = String.format(INTERNAL_REOPEN_MAIL, ticketId, retailerService.getFofoRetailer(loginDetails.getFofoId()).getBusinessName());
1280
                String to = authRepository.selectById(ticket.getL1AuthUser()).getEmailId();
35395 amit 1281
                String[] ccTo = authRepository.selectByIds(Arrays.asList(ticket.getL2AuthUser(), ticket.getL3AuthUser(), ticket.getL4AuthUser(), ticket.getL5AuthUser())).stream().map(x -> x.getEmailId()).toArray(String[]::new);
31762 tejbeer 1282
                ticket.setLastActivity(lastActivity);
1283
                ticket.setUpdateTimestamp(LocalDateTime.now());
1284
                ticketAssignedRepository.deleteByTicketId(ticketId);
1285
                TicketAssigned ticketAssigned = new TicketAssigned();
1286
                ticketAssigned.setAssineeId(ticket.getL1AuthUser());
1287
                ticketAssigned.setTicketId(ticketId);
1288
                ticketAssignedRepository.persist(ticketAssigned);
1289
                activity.setMessage(INTERNAL_REOPEN_ACTIVITY_MESSAGE);
1290
                activity.setCreatedBy(0);
1291
                activity.setTicketId(ticketId);
1292
                activity.setType(ActivityType.COMMUNICATION_IN);
1293
                activity.setCreateTimestamp(LocalDateTime.now());
1294
                this.activityRelatedMail(to, ccTo, subject, message);
1295
                this.activityRelatedMail(retailerService.getFofoRetailer(loginDetails.getFofoId()).getEmail(), null, subject, String.format(PARTNER_REOPEN, ticketId));
1296
            }
1297
 
1298
        }
1299
        activityRepository.persist(activity);
1300
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1301
        return "response";
1302
    }
1303
 
32812 shampa 1304
 
1305
 
1306
 
1307
 
1308
    @PostMapping(value = "/partner-position/update")
1309
    public String positionUpdated(Model model, @RequestBody List<PartnerPositonUpdateModel> partnerPositionUpdateModels)
1310
            throws Exception {
1311
 
32821 shampa 1312
        Map<Integer, List<String>> positionIdsToAddMap = partnerPositionUpdateModels.stream().filter(x->x.getPositionIdTo()!=0).collect(Collectors.groupingBy(x->x.getPositionIdTo(),
32812 shampa 1313
                Collectors.mapping(x->x.getStoreCode(), Collectors.toList())));
1314
 
32821 shampa 1315
        Map<Integer, List<String>> positionIdsToRemoveMap = partnerPositionUpdateModels.stream().filter(x->x.getPositionIdFrom()!=0).collect(Collectors.groupingBy(x->x.getPositionIdFrom(),
32812 shampa 1316
                Collectors.mapping(x->x.getStoreCode(), Collectors.toList())));
1317
 
1318
        List<Integer> positionIdsToUpdate = new ArrayList<>();
1319
        positionIdsToUpdate.addAll(positionIdsToAddMap.keySet());
1320
        positionIdsToUpdate.addAll(positionIdsToRemoveMap.keySet());
1321
 
35395 amit 1322
        Map<Integer, Position> positionsToUpdateMap =  positionRepository.selectByIds(positionIdsToUpdate).stream().collect(Collectors.toMap(x->x.getId(), x->x));
32812 shampa 1323
        List<Integer> invalidPositionIds = positionsToUpdateMap.values().stream().filter(x-> x.getCategoryId()!= ProfitMandiConstants.TICKET_CATEGORY_RBM
34908 ranu 1324
                && x.getCategoryId() != ProfitMandiConstants.TICKET_CATEGORY_SALES && x.getCategoryId() != ProfitMandiConstants.TICKET_CATEGORY_ABM).map(x -> x.getId()).collect(Collectors.toList());
32812 shampa 1325
        if(invalidPositionIds.size() > 0) {
34908 ranu 1326
            String message = "Non RBM/Sales/ABM are not allowed - " + invalidPositionIds;
32812 shampa 1327
            throw new ProfitMandiBusinessException(message, message, message);
1328
        }
1329
 
1330
        for (Map.Entry<Integer, List<String>> positionIdStoreMapEntry : positionIdsToAddMap.entrySet()) {
1331
            int positionId = positionIdStoreMapEntry.getKey();
1332
            Position position = positionsToUpdateMap.get(positionId);
32821 shampa 1333
            LOGGER.info("positionId - {}, Position - {}", positionId, position);
32812 shampa 1334
            List<String> storeCodesToAdd = positionIdStoreMapEntry.getValue();
1335
            List<Integer> retailerIdsToAdd = fofoStoreRepository.selectByStoreCodes(storeCodesToAdd).stream().map(x->x.getId()).collect(Collectors.toList());
1336
            Map<Integer, PartnerPosition> partnerPositionsMapByFofoId  = partnerPositionRepository
32821 shampa 1337
                    .selectByRegionIdAndPostionId(Arrays.asList(position.getRegionId())
1338
                            ,Arrays.asList(positionId)).stream().collect(Collectors.toMap(x->x.getFofoId(),x->x));
32812 shampa 1339
            for (Integer retailerIdToAdd : retailerIdsToAdd) {
1340
                if (!partnerPositionsMapByFofoId.containsKey(retailerIdToAdd)) {
1341
                    PartnerPosition partnerPositionNew = new PartnerPosition();
1342
                    partnerPositionNew.setPositionId(positionId);
1343
                    partnerPositionNew.setFofoId(retailerIdToAdd);
1344
                    partnerPositionNew.setRegionId(position.getRegionId());
32865 amit.gupta 1345
                    partnerPositionRepository.persist(partnerPositionNew);
32812 shampa 1346
                }
1347
            }
1348
        }
1349
 
1350
        for (Map.Entry<Integer, List<String>> positionIdStoreMapEntry : positionIdsToRemoveMap.entrySet()) {
1351
 
1352
            int positionId = positionIdStoreMapEntry.getKey();
1353
            Position position = positionsToUpdateMap.get(positionId);
1354
            List<String> storeCodesToRemove = positionIdStoreMapEntry.getValue();
1355
            List<Integer> retailerIdsToRemove = fofoStoreRepository.selectByStoreCodes(storeCodesToRemove).stream().map(x->x.getId()).collect(Collectors.toList());
1356
            Map<Integer, PartnerPosition> partnerPositionsMapByFofoId  = partnerPositionRepository
1357
                    .selectByRegionIdAndPostionId(Arrays.asList(position.getRegionId()),Arrays.asList(positionId)).stream().collect(Collectors.toMap(x->x.getFofoId(),x->x));
1358
            for (Integer retailerIdToRemove : retailerIdsToRemove) {
1359
                if (partnerPositionsMapByFofoId.containsKey(retailerIdToRemove)) {
1360
                   PartnerPosition partnerPositionToRemove =  partnerPositionsMapByFofoId.get(retailerIdToRemove);
1361
                   partnerPositionRepository.delete(partnerPositionToRemove);
1362
                }
1363
            }
1364
        }
1365
 
1366
 
1367
 
1368
        /*partnerPositionUpdateModels.str
1369
 
1370
        Map<Integer, Position> positionIdMap = positionsToUpdate.stream().collect(Collectors.toMap(x->x.getId(), x->x));
1371
        for (PartnerPositonUpdateModel partnerPositionUpdateModel : partnerPositionUpdateModels) {
1372
            FofoStore fofoStore = fofoStoreRepository.selectByStoreCode(partnerPositionUpdateModel.getStoreCode());
1373
            Position positionFrom = positionIdMap.get(partnerPositionUpdateModel.getPositionIdFrom());
1374
            Position positionTo = positionIdMap.get(partnerPositionUpdateModel.getPositionIdTo());
1375
            if(positionFrom != null) {
1376
                partnerPositionRepository.selectByRegionIdAndPostionId(Arrays.)
1377
              int regionId = positionFrom.getRegionId()
1378
            }
1379
            if(positionTo != null) {
1380
 
1381
            }
1382
        }*/
1383
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1384
        return "response";
1385
 
1386
    }
1387
 
1388
 
24417 govind 1389
}