Subversion Repositories SmartDukaan

Rev

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