Subversion Repositories SmartDukaan

Rev

Rev 37145 | 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;
37559 ranu 6
import com.spice.profitmandi.common.util.FileUtil;
24417 govind 7
import com.spice.profitmandi.dao.entity.auth.AuthUser;
27690 amit.gupta 8
import com.spice.profitmandi.dao.entity.cs.*;
36040 ranu 9
import com.spice.profitmandi.dao.entity.cs.TicketReadStatus.UserType;
27270 tejbeer 10
import com.spice.profitmandi.dao.entity.dtr.Document;
24417 govind 11
import com.spice.profitmandi.dao.entity.fofo.ActivityType;
12
import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
24699 govind 13
import com.spice.profitmandi.dao.enumuration.cs.TicketStatus;
25570 tejbeer 14
import com.spice.profitmandi.dao.model.CreatePositionModel;
24417 govind 15
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
27690 amit.gupta 16
import com.spice.profitmandi.dao.repository.cs.*;
27270 tejbeer 17
import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
25570 tejbeer 18
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
24417 govind 19
import com.spice.profitmandi.service.authentication.RoleManager;
36040 ranu 20
import com.spice.profitmandi.service.mail.MailOutboxService;
37559 ranu 21
import com.spice.profitmandi.service.order.OrderService;
24417 govind 22
import com.spice.profitmandi.service.user.RetailerService;
23
import com.spice.profitmandi.web.model.LoginDetails;
24
import com.spice.profitmandi.web.util.CookiesProcessor;
25
import com.spice.profitmandi.web.util.MVCResponseSender;
27690 amit.gupta 26
import org.apache.logging.log4j.LogManager;
27
import org.apache.logging.log4j.Logger;
28
import org.springframework.beans.factory.annotation.Autowired;
37559 ranu 29
import org.springframework.http.ResponseEntity;
27690 amit.gupta 30
import org.springframework.mail.javamail.JavaMailSender;
31
import org.springframework.stereotype.Controller;
32
import org.springframework.transaction.annotation.Transactional;
33
import org.springframework.ui.Model;
34
import org.springframework.web.bind.annotation.*;
24417 govind 35
 
27690 amit.gupta 36
import javax.servlet.http.HttpServletRequest;
36040 ranu 37
import javax.swing.*;
27690 amit.gupta 38
import java.time.LocalDateTime;
39
import java.util.*;
40
import java.util.stream.Collectors;
41
 
24417 govind 42
@Controller
43
@Transactional(rollbackFor = Throwable.class)
44
public class CsController {
45
 
31762 tejbeer 46
    private static final Logger LOGGER = LogManager.getLogger(CsController.class);
47
    private static final String ACTIVITY_SUBJECT = "Message related ticketId#%s";
48
    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";
49
    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";
50
    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";
51
    private static final String INTERNAL_REOPEN_ACTIVITY_MESSAGE = "Hi,My ticket is not resolved yet,so I have reopened it";
24699 govind 52
 
31762 tejbeer 53
    @Autowired
36401 amit 54
    JavaMailSender gmailRelaySender;
24620 govind 55
 
31762 tejbeer 56
    @Autowired
35957 amit 57
    MailOutboxService mailOutboxService;
58
 
59
    @Autowired
31762 tejbeer 60
    private CsService csService;
24417 govind 61
 
31762 tejbeer 62
    @Autowired
63
    private CookiesProcessor cookiesProcessor;
24417 govind 64
 
31762 tejbeer 65
    @Autowired
66
    private TicketCategoryRepository ticketCategoryRepository;
24417 govind 67
 
31762 tejbeer 68
    @Autowired
69
    private TicketSubCategoryRepository ticketSubCategoryRepository;
24417 govind 70
 
31762 tejbeer 71
    @Autowired
72
    private RegionRepository regionRepository;
24417 govind 73
 
31762 tejbeer 74
    @Autowired
75
    private RetailerService retailerService;
24417 govind 76
 
31762 tejbeer 77
    @Autowired
78
    private MVCResponseSender mvcResponseSender;
24417 govind 79
 
31762 tejbeer 80
    @Autowired
81
    private AuthRepository authRepository;
24417 govind 82
 
31762 tejbeer 83
    @Autowired
84
    private PositionRepository positionRepository;
24417 govind 85
 
31762 tejbeer 86
    @Autowired
87
    private TicketRepository ticketRepository;
24417 govind 88
 
31762 tejbeer 89
    @Autowired
90
    private RoleManager roleManager;
24417 govind 91
 
31762 tejbeer 92
    @Autowired
93
    private ActivityRepository activityRepository;
24417 govind 94
 
31762 tejbeer 95
    @Autowired
37559 ranu 96
    private OrderService orderService;
97
 
98
    @Autowired
31762 tejbeer 99
    private ActivityAttachmentRepository activityAttachmentRepository;
27270 tejbeer 100
 
31762 tejbeer 101
    @Autowired
102
    private TicketAssignedRepository ticketAssignedRepository;
24569 govind 103
 
31762 tejbeer 104
    @Autowired
105
    private PartnerRegionRepository partnerRegionRepository;
24500 govind 106
 
31762 tejbeer 107
    @Autowired
32493 amit.gupta 108
    PartnerPositionRepository partnerPositionRepository;
25570 tejbeer 109
 
31762 tejbeer 110
    @Autowired
111
    FofoStoreRepository fofoStoreRepository;
25570 tejbeer 112
 
31762 tejbeer 113
    @Autowired
114
    DocumentRepository documentRepository;
27270 tejbeer 115
 
31762 tejbeer 116
    @GetMapping(value = "/cs/createCategory")
117
    public String getCreateCategory(HttpServletRequest request, Model model) {
118
        List<TicketCategory> ticketCategories = ticketCategoryRepository.selectAll();
119
        model.addAttribute("ticketCategories", ticketCategories);
120
        return "create-ticket-category";
121
    }
24417 govind 122
 
31762 tejbeer 123
    @PostMapping(value = "/cs/createCategory")
33081 ranu 124
    public String createCategory(HttpServletRequest request,
125
                                 @RequestParam(name = "name") String name,
126
                                 @RequestParam(name = "categoryType") int categoryType,
127
                                 @RequestParam(name = "description") String description,
128
                                 Model model) throws ProfitMandiBusinessException {
31762 tejbeer 129
        TicketCategory ticketCategory = ticketCategoryRepository.selectByName(name);
130
        if (ticketCategory != null) {
131
            throw new ProfitMandiBusinessException("name", name, "already exists!");
132
        }
33081 ranu 133
 
31762 tejbeer 134
        ticketCategory = new TicketCategory();
135
        ticketCategory.setName(name);
136
        ticketCategory.setDescription(description);
33081 ranu 137
 
138
        ticketCategory.setCategoryType(categoryType == 1);
31762 tejbeer 139
        ticketCategoryRepository.persist(ticketCategory);
140
        return "create-ticket-category";
141
    }
24417 govind 142
 
33081 ranu 143
 
31762 tejbeer 144
    @GetMapping(value = "/cs/createSubCategory")
145
    public String getCreateSubCategory(HttpServletRequest request, Model model) {
146
        List<TicketCategory> ticketCategories = ticketCategoryRepository.selectAll();
147
        model.addAttribute("ticketCategories", ticketCategories);
148
        return "create-ticket-sub-category";
149
    }
24417 govind 150
 
31762 tejbeer 151
    @GetMapping(value = "/cs/getSubCategoryByCategoryId")
152
    public String getSubCategoryByCategoryId(HttpServletRequest request, @RequestParam(name = "ticketCategoryId", defaultValue = "") int ticketCategoryId, Model model) {
153
        List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAll(ticketCategoryId);
154
        TicketCategory ticketCategory = ticketCategoryRepository.selectById(ticketCategoryId);
33081 ranu 155
        LOGGER.info("ticketSubCategories {}", ticketSubCategories);
156
        LOGGER.info("ticketCategory {}", ticketCategory);
31762 tejbeer 157
        model.addAttribute("ticketSubCategories", ticketSubCategories);
158
        model.addAttribute("ticketCategory", ticketCategory);
159
        return "ticket-sub-category";
160
    }
24417 govind 161
 
31762 tejbeer 162
    @PostMapping(value = "/cs/createSubCategory")
163
    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 164
 
31762 tejbeer 165
        TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectTicketSubCategory(categoryId, name);
166
        if (ticketSubCategory != null) {
167
            throw new ProfitMandiBusinessException("name & categoryId", name + "  " + categoryId, "already exists!");
168
        }
24417 govind 169
 
31762 tejbeer 170
        ticketSubCategory = new TicketSubCategory();
171
        ticketSubCategory.setCategoryId(categoryId);
172
        ticketSubCategory.setName(name);
173
        ticketSubCategory.setDescription(description);
174
        ticketSubCategoryRepository.persist(ticketSubCategory);
175
        return "create-ticket-sub-category";
176
    }
24417 govind 177
 
31762 tejbeer 178
    @GetMapping(value = "/cs/createRegion")
179
    public String createRegion(HttpServletRequest request, Model model) {
180
        List<Region> regions = regionRepository.selectAll();
181
        model.addAttribute("regions", regions);
182
        return "create-region";
183
    }
24417 govind 184
 
31762 tejbeer 185
    @PostMapping(value = "/cs/createRegion")
186
    public String createRegion(HttpServletRequest request, @RequestParam(name = "name") String name, @RequestParam(name = "description") String description, Model model) throws Exception {
187
        Region region = regionRepository.selectByName(name);
188
        if (region != null) {
189
            throw new ProfitMandiBusinessException("name", name, "already exists!");
190
        }
191
        region = new Region();
192
        region.setName(name);
193
        region.setDescription(description);
194
        regionRepository.persist(region);
195
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
196
        return "response";
197
    }
24417 govind 198
 
31762 tejbeer 199
    @GetMapping(value = "/cs/getPartners")
33244 ranu 200
    public String getPartners(HttpServletRequest request, @RequestParam(name = "regionId", defaultValue = "0") int regionId, Model model) throws ProfitMandiBusinessException {
31762 tejbeer 201
        List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().map(x -> x.getId()).collect(Collectors.toList());
202
        List<Integer> addedfofoIds = partnerRegionRepository.selectByRegionId(regionId).stream().map(x -> x.getFofoId()).collect(Collectors.toList());
30426 tejbeer 203
 
31762 tejbeer 204
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
205
        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));
206
        model.addAttribute("fofoRetailers", fofoRetailers);
207
        model.addAttribute("addedfofoIds", addedfofoIds);
208
        return "added-region-partners";
209
    }
24569 govind 210
 
31762 tejbeer 211
    @GetMapping(value = "/cs/getPartnersByRegion")
33244 ranu 212
    public String getPartnersByRegion(HttpServletRequest request, @RequestParam(name = "regionId", defaultValue = "0") int regionId, Model model) throws ProfitMandiBusinessException {
31762 tejbeer 213
        List<Integer> fofoIds = null;
214
        fofoIds = partnerRegionRepository.selectByRegionId(regionId).stream().map(x -> x.getFofoId()).collect(Collectors.toList());
25570 tejbeer 215
 
31762 tejbeer 216
        if (fofoIds.contains(0)) {
217
            fofoIds = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive()).collect(Collectors.toList()).stream().map(x -> x.getId()).collect(Collectors.toList());
25570 tejbeer 218
 
31762 tejbeer 219
        }
220
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
25570 tejbeer 221
 
31762 tejbeer 222
        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));
223
        model.addAttribute("fofoRetailers", fofoRetailers);
224
        return "added-subregion-partners";
225
    }
25570 tejbeer 226
 
31762 tejbeer 227
    @GetMapping(value = "/cs/createPartnerRegion")
228
    public String createPartnerRegion(HttpServletRequest request, Model model) {
229
        List<Region> regions = regionRepository.selectAll();
230
        model.addAttribute("regions", regions);
231
        return "create-partner-region";
232
    }
24417 govind 233
 
31762 tejbeer 234
    @PostMapping(value = "/cs/createPartnerRegion")
235
    public String createPartnerRegion(HttpServletRequest request, @RequestParam(name = "regionId") int regionId, @RequestBody List<Integer> selectedFofoIds, Model model) throws Exception {
236
        partnerRegionRepository.delete(regionId);
237
        LOGGER.info("successfully removed");
238
        LOGGER.info(selectedFofoIds.size());
239
        csService.addPartnerToRegion(regionId, selectedFofoIds);
240
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
241
        return "response";
242
    }
24417 govind 243
 
31762 tejbeer 244
    @GetMapping(value = "/cs/getPosition")
33244 ranu 245
    public String getPosition(HttpServletRequest request, @RequestParam int positionId, Model model) throws ProfitMandiBusinessException {
27410 tejbeer 246
 
31762 tejbeer 247
        Position position = positionRepository.selectById(positionId);
27410 tejbeer 248
 
31762 tejbeer 249
        List<CustomRetailer> positionIdCustomRetailer = csService.getPositionCustomRetailerMap(Arrays.asList(position)).get(position.getId());
27410 tejbeer 250
 
31762 tejbeer 251
        Map<Integer, CustomRetailer> regionRetailerMap = csService.getRegionPartners(Arrays.asList(position)).get(position.getRegionId()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
27410 tejbeer 252
 
31762 tejbeer 253
        model.addAttribute("position", position);
254
        model.addAttribute("regionRetailerMap", regionRetailerMap);
255
        model.addAttribute("positionIdCustomRetailer", positionIdCustomRetailer);
27410 tejbeer 256
 
31762 tejbeer 257
        return "position-partner";
258
    }
27410 tejbeer 259
 
31762 tejbeer 260
    @GetMapping(value = "/cs/createPosition")
261
    public String createPosition(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) {
262
        List<AuthUser> authUsers = authRepository.selectAllActiveUser();
263
        List<TicketCategory> ticketCategories = ticketCategoryRepository.selectAll();
264
        List<Region> regions = regionRepository.selectAll();
265
        model.addAttribute("escalationTypes", EscalationType.values());
266
        model.addAttribute("authUsers", authUsers);
267
        model.addAttribute("ticketCategories", ticketCategories);
268
        model.addAttribute("regions", regions);
24500 govind 269
 
31762 tejbeer 270
        List<Position> positions = positionRepository.selectAllPosition();
271
        LOGGER.info("positions" + positions);
30426 tejbeer 272
 
31762 tejbeer 273
        Map<Integer, AuthUser> authUserIdAndAuthUserMap = csService.getAuthUserIdAndAuthUserMapUsingPositions(positions);
274
        Map<Integer, TicketCategory> categoryIdAndCategoryMap = csService.getCategoryIdAndCategoryUsingPositions(positions);
275
        Map<Integer, Region> regionIdAndRegionMap = csService.getRegionIdAndRegionMap(positions);
25570 tejbeer 276
 
27410 tejbeer 277
//	    Map<Integer, List<CustomRetailer>> positionIdAndpartnerRegionMap = csService
278
//			.getpositionIdAndpartnerRegionMap(positions);
25570 tejbeer 279
 
27410 tejbeer 280
//	     Map<Integer, List<CustomRetailer>> addedpositionIdAndCustomRetailerMap = csService
281
//				.getPositionCustomRetailerMap(positions);
282
//		LOGGER.info("fofoIdAndCustomRetailerMap" + addedpositionIdAndCustomRetailerMap);
24500 govind 283
 
31762 tejbeer 284
        model.addAttribute("start", offset + 1);
30426 tejbeer 285
 
31762 tejbeer 286
        model.addAttribute("positions", positions);
287
        model.addAttribute("authUserIdAndAuthUserMap", authUserIdAndAuthUserMap);
288
        model.addAttribute("categoryIdAndCategoryMap", categoryIdAndCategoryMap);
289
        model.addAttribute("regionIdAndRegionMap", regionIdAndRegionMap);
290
        // model.addAttribute("positionIdAndCustomRetailerMap",
291
        // addedpositionIdAndCustomRetailerMap);
292
        // model.addAttribute("positionIdAndpartnerRegionMap",
27410 tejbeer 293
// positionIdAndpartnerRegionMap);
25570 tejbeer 294
 
31762 tejbeer 295
        return "create-position";
296
    }
24500 govind 297
 
31762 tejbeer 298
    @GetMapping(value = "/cs/position-paginated")
299
    public String positionPaginated(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) {
24500 govind 300
 
31762 tejbeer 301
        List<Position> positions = positionRepository.selectAll(offset, limit);
302
        Map<Integer, AuthUser> authUserIdAndAuthUserMap = csService.getAuthUserIdAndAuthUserMapUsingPositions(positions);
303
        Map<Integer, TicketCategory> categoryIdAndCategoryMap = csService.getCategoryIdAndCategoryUsingPositions(positions);
304
        Map<Integer, Region> regionIdAndRegionMap = csService.getRegionIdAndRegionMap(positions);
305
        /*
306
         * Map<Integer, List<CustomRetailer>> positionIdAndpartnerRegionMap = csService
307
         * .getpositionIdAndpartnerRegionMap(positions);
308
         * 
309
         * Map<Integer, List<CustomRetailer>> addedpositionIdAndCustomRetailerMap =
310
         * csService .getPositionCustomRetailerMap(positions);
311
         */
25570 tejbeer 312
 
31762 tejbeer 313
        model.addAttribute("positions", positions);
314
        model.addAttribute("authUserIdAndAuthUserMap", authUserIdAndAuthUserMap);
315
        model.addAttribute("categoryIdAndCategoryMap", categoryIdAndCategoryMap);
316
        model.addAttribute("regionIdAndRegionMap", regionIdAndRegionMap);
317
        // model.addAttribute("positionIdAndCustomRetailerMap",
318
        // addedpositionIdAndCustomRetailerMap);
319
        // model.addAttribute("positionIdAndpartnerRegionMap",
320
        // positionIdAndpartnerRegionMap);
25570 tejbeer 321
 
31762 tejbeer 322
        return "position-paginated";
323
    }
24417 govind 324
 
31762 tejbeer 325
    @PostMapping(value = "/cs/createPosition")
326
    public String createPosition(HttpServletRequest request, @RequestBody CreatePositionModel createPositionModel, Model model) throws Exception {
24417 govind 327
 
35570 amit 328
        LOGGER.info("partnerPosition" + createPositionModel.isTicketAssigned());
25570 tejbeer 329
 
35570 amit 330
        // Validate authUserId exists
331
        int authUserId = createPositionModel.getAuthUserId();
332
        if (authUserId <= 0 || authRepository.selectById(authUserId) == null) {
333
            throw new ProfitMandiBusinessException("Position", authUserId, "Invalid authUserId");
334
        }
335
 
336
        // Validate categoryId exists (0 means "All Categories")
337
        int categoryId = createPositionModel.getCategoryId();
338
        if (categoryId > 0 && ticketCategoryRepository.selectById(categoryId) == null) {
339
            throw new ProfitMandiBusinessException("Position", categoryId, "Invalid categoryId");
340
        }
341
 
342
        // Validate regionId exists (0 or 5 typically means "All Partners/Regions")
343
        int regionId = createPositionModel.getRegionId();
344
        if (regionId > 0 && regionId != 5 && regionRepository.selectById(regionId) == null) {
345
            throw new ProfitMandiBusinessException("Position", regionId, "Invalid regionId");
346
        }
347
 
37003 ranu 348
        // Partners are optional — a position can be created for a region that doesn't have
349
        // partners yet (e.g., a newly opened region). Partners can be added later via
350
        // /cs/updatePartnerPosition. When provided, validate the list; when empty, skip.
35570 amit 351
        List<Integer> fofoIds = createPositionModel.getFofoIds();
37003 ranu 352
        boolean hasAllPartners = fofoIds != null && fofoIds.contains(0);
35590 amit 353
        if (hasAllPartners && fofoIds.size() > 1) {
354
            throw new ProfitMandiBusinessException("Position", 0, "Cannot mix 'All Partners' (0) with specific partner IDs");
355
        }
37003 ranu 356
        if (fofoIds != null && !fofoIds.isEmpty() && !hasAllPartners) {
35590 amit 357
            Map<Integer, CustomRetailer> validRetailers = retailerService.getFofoRetailers(false);
358
            for (int fofoId : fofoIds) {
359
                if (!validRetailers.containsKey(fofoId)) {
360
                    throw new ProfitMandiBusinessException("Position", fofoId, "Invalid fofoId");
35570 amit 361
                }
362
            }
363
        }
364
 
365
        Position position = positionRepository.selectPosition(authUserId, categoryId, regionId, createPositionModel.getEscalationType());
31762 tejbeer 366
        if (position == null) {
367
            position = new Position();
35570 amit 368
            position.setAuthUserId(authUserId);
369
            position.setCategoryId(categoryId);
31762 tejbeer 370
            position.setEscalationType(createPositionModel.getEscalationType());
35570 amit 371
            position.setRegionId(regionId);
31762 tejbeer 372
            position.setCreateTimestamp(LocalDateTime.now());
373
            position.setTicketAssignee(createPositionModel.isTicketAssigned());
374
            positionRepository.persist(position);
25570 tejbeer 375
 
35570 amit 376
            if (fofoIds != null) {
377
                for (int fofoId : fofoIds) {
378
                    PartnerPosition partnerPosition = new PartnerPosition();
379
                    partnerPosition.setFofoId(fofoId);
380
                    partnerPosition.setRegionId(regionId);
381
                    partnerPosition.setPositionId(position.getId());
382
                    partnerPositionRepository.persist(partnerPosition);
383
                    LOGGER.info("partnerPosition" + partnerPosition);
384
                }
31762 tejbeer 385
            }
24417 govind 386
 
31762 tejbeer 387
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
388
        } else {
35570 amit 389
            throw new ProfitMandiBusinessException("Position", authUserId, "already exists!");
31762 tejbeer 390
        }
391
        return "response";
392
    }
25570 tejbeer 393
 
31762 tejbeer 394
    @PostMapping(value = "/cs/updatePartnerPosition")
395
    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 396
 
35571 amit 397
        // Validate positionId exists
398
        Position position = positionRepository.selectById(positionId);
399
        if (position == null) {
400
            throw new ProfitMandiBusinessException("Position", positionId, "Position not found");
401
        }
402
 
403
        // Validate regionId exists (0 or 5 typically means "All Partners/Regions")
404
        if (regionId > 0 && regionId != 5 && regionRepository.selectById(regionId) == null) {
405
            throw new ProfitMandiBusinessException("Position", regionId, "Invalid regionId");
406
        }
407
 
35589 amit 408
        // Validate fofoIds exist (0 means "All Partners")
35590 amit 409
        if (selectedFofoIds == null || selectedFofoIds.isEmpty()) {
410
            throw new ProfitMandiBusinessException("Position", 0, "At least one partner must be specified");
411
        }
412
        boolean hasAllPartners = selectedFofoIds.contains(0);
413
        if (hasAllPartners && selectedFofoIds.size() > 1) {
414
            throw new ProfitMandiBusinessException("Position", 0, "Cannot mix 'All Partners' (0) with specific partner IDs");
415
        }
416
        if (!hasAllPartners) {
35607 amit 417
            // Use direct database query instead of cached retailerService to include newly added partners
418
            Set<Integer> validFofoIds = fofoStoreRepository.selectAll().stream()
419
                    .map(fs -> fs.getId())
420
                    .collect(Collectors.toSet());
35590 amit 421
            for (int fofoId : selectedFofoIds) {
35607 amit 422
                if (!validFofoIds.contains(fofoId)) {
35590 amit 423
                    throw new ProfitMandiBusinessException("Position", fofoId, "Invalid fofoId");
35571 amit 424
                }
425
            }
426
        }
427
 
32493 amit.gupta 428
        partnerPositionRepository.delete(positionId);
35571 amit 429
        if (selectedFofoIds != null) {
430
            for (int fofoId : selectedFofoIds) {
431
                PartnerPosition partnerPosition = new PartnerPosition();
432
                partnerPosition.setFofoId(fofoId);
433
                partnerPosition.setRegionId(regionId);
434
                partnerPosition.setPositionId(positionId);
435
                partnerPositionRepository.persist(partnerPosition);
436
            }
31762 tejbeer 437
        }
25570 tejbeer 438
 
31762 tejbeer 439
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
25570 tejbeer 440
 
31762 tejbeer 441
        return "response";
442
    }
24417 govind 443
 
31762 tejbeer 444
    @GetMapping(value = "/cs/createTicket")
445
    public String createTicket(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
446
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
35594 amit 447
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
448
        boolean isCrmUser = false;
449
 
31762 tejbeer 450
        List<TicketCategory> ticketCategories = csService.getAllTicketCategotyFromSubCategory();
35594 amit 451
 
452
        if (isAdmin) {
453
            AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
454
            isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
455
 
456
            // CRM users should not see Sales and RBM categories
457
            if (isCrmUser) {
458
                ticketCategories = ticketCategories.stream()
459
                        .filter(tc -> tc.getId() != ProfitMandiConstants.TICKET_CATEGORY_SALES
460
                                && tc.getId() != ProfitMandiConstants.TICKET_CATEGORY_RBM)
461
                        .collect(Collectors.toList());
462
            }
35626 amit 463
        } else {
464
            // For partners/customers: hide categories where ALL subcategories are invisible
465
            ticketCategories = ticketCategories.stream()
466
                    .filter(category -> {
467
                        List<TicketSubCategory> subs = ticketSubCategoryRepository.selectAll(category.getId());
468
                        // Keep category if at least one subcategory is visible
469
                        return subs.stream().anyMatch(TicketSubCategory::isVisibility);
470
                    })
471
                    .collect(Collectors.toList());
35594 amit 472
        }
473
 
474
        model.addAttribute("roleType", isAdmin);
31762 tejbeer 475
        model.addAttribute("ticketCategories", ticketCategories);
35594 amit 476
        model.addAttribute("isCrmUser", isCrmUser);
31762 tejbeer 477
        return "create-ticket";
478
    }
24417 govind 479
 
31762 tejbeer 480
    @GetMapping(value = "/cs/getSubCategoriesByCategoryId")
35594 amit 481
    public String getSubCategoriesByCategoryId(HttpServletRequest request, @RequestParam(name = "categoryId", defaultValue = "0") int categoryId, Model model) throws ProfitMandiBusinessException {
482
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
483
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
484
        boolean isCrmUser = false;
485
 
486
        if (isAdmin) {
487
            AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
488
            isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
489
        }
490
 
31830 amit.gupta 491
        List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAllVisible(categoryId);
35594 amit 492
 
35617 amit 493
        // CRM users should not see invisible subcategories
35594 amit 494
        if (isCrmUser) {
495
            ticketSubCategories = ticketSubCategories.stream()
35617 amit 496
                    .filter(TicketSubCategory::isVisibility)
35594 amit 497
                    .collect(Collectors.toList());
498
        }
499
 
31762 tejbeer 500
        LOGGER.info(ticketSubCategories);
501
        model.addAttribute("ticketSubCategories", ticketSubCategories);
502
        return "ticket-sub-categories";
503
    }
24417 govind 504
 
24791 govind 505
 
31762 tejbeer 506
    @GetMapping(value = "/cs/getEscalationTypeByCategoryId")
507
    public String getEscalationTypeByCategoryId(HttpServletRequest request, @RequestParam(name = "categoryId", defaultValue = "0") int categoryId, @RequestParam(name = "authId", defaultValue = "0") int authId, Model model) {
508
        List<Position> positions = positionRepository.selectPositionbyCategoryIdAndAuthId(categoryId, authId);
509
        List<EscalationType> escalationTypes = new ArrayList<>();
24791 govind 510
 
31762 tejbeer 511
        if (!positions.isEmpty()) {
512
            escalationTypes = positions.stream().map(x -> x.getEscalationType()).distinct().collect(Collectors.toList());
513
        }
24620 govind 514
 
31762 tejbeer 515
        LOGGER.info("escalationTypes {}", escalationTypes);
24500 govind 516
 
31762 tejbeer 517
        model.addAttribute("escalationTypes", escalationTypes);
518
        return "ticket-escalationtype";
519
    }
24500 govind 520
 
24824 govind 521
 
31762 tejbeer 522
    @GetMapping(value = "/cs/getCategoriesByAuthId")
523
    public String getCategoriesByAuthId(HttpServletRequest request, @RequestParam(name = "authId", defaultValue = "0") int authId, Model model) {
24824 govind 524
 
24787 govind 525
 
31762 tejbeer 526
        List<Position> positions = positionRepository.selectPositionByAuthId(authId);
24791 govind 527
 
31762 tejbeer 528
        LOGGER.info("positions {}", positions);
24417 govind 529
 
31762 tejbeer 530
        List<TicketCategory> ticketCategories = new ArrayList<TicketCategory>();
24417 govind 531
 
31762 tejbeer 532
        if (!positions.isEmpty()) {
24417 govind 533
 
31762 tejbeer 534
            List<Integer> categoryIds = positions.stream().map(x -> x.getCategoryId()).collect(Collectors.toList());
535
            ticketCategories = ticketCategoryRepository.selectAll(categoryIds);
536
        }
537
        LOGGER.info("ticketCategories {}", ticketCategories);
538
        model.addAttribute("ticketCategories", ticketCategories);
539
        return "ticket-categories";
540
    }
27270 tejbeer 541
 
31762 tejbeer 542
    @PostMapping(value = "/cs/createTicket")
543
    public String createTicket(HttpServletRequest request, @RequestParam(name = "categoryId") int categoryId, @RequestParam(name = "subCategoryId") int subCategoryId, @RequestParam(name = "message") String message, Model model) throws Exception {
544
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
545
        List<Ticket> tickets = ticketRepository.selectAllResolvedMarkedTicketByCreator(loginDetails.getFofoId());
546
        if (tickets.size() > 3 || tickets.size() == 3) {
547
            model.addAttribute("response1", mvcResponseSender.createResponseString(false));
548
        } else {
549
            csService.createTicket(loginDetails.getFofoId(), categoryId, subCategoryId, message);
550
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
551
        }
552
        return "response";
553
    }
27270 tejbeer 554
 
31762 tejbeer 555
    @GetMapping(value = "/cs/myticket")
35626 amit 556
    public String getTicket(HttpServletRequest request,
557
                            @RequestParam(name = "orderby", defaultValue = "DESCENDING") SortOrder sortOrder,
558
                            @RequestParam(name = "ticketStatus", defaultValue = "OPENED") TicketStatus ticketStatus,
559
                            @RequestParam(name = "ticketSearchType", defaultValue = "") TicketSearchType ticketSearchType,
560
                            @RequestParam(name = "searchTerm", defaultValue = "0") int searchTerm,
561
                            @RequestParam(name = "page", defaultValue = "0") int page,
562
                            @RequestParam(name = "pageSize", defaultValue = "25") int pageSize,
563
                            @RequestParam(name = "search", required = false) String searchText,
564
                            Model model) throws ProfitMandiBusinessException {
565
        populateMyTicketModel(request, sortOrder, ticketStatus, ticketSearchType, searchTerm, page, pageSize, searchText, model);
566
        return "ticket";
567
    }
568
 
569
    @GetMapping(value = "/cs/myticket-content")
570
    public String getTicketContent(HttpServletRequest request,
571
                                   @RequestParam(name = "orderby", defaultValue = "DESCENDING") SortOrder sortOrder,
572
                                   @RequestParam(name = "ticketStatus", defaultValue = "OPENED") TicketStatus ticketStatus,
573
                                   @RequestParam(name = "ticketSearchType", defaultValue = "") TicketSearchType ticketSearchType,
574
                                   @RequestParam(name = "searchTerm", defaultValue = "0") int searchTerm,
575
                                   @RequestParam(name = "page", defaultValue = "0") int page,
576
                                   @RequestParam(name = "pageSize", defaultValue = "25") int pageSize,
577
                                   @RequestParam(name = "search", required = false) String searchText,
578
                                   Model model) throws ProfitMandiBusinessException {
579
        populateMyTicketModel(request, sortOrder, ticketStatus, ticketSearchType, searchTerm, page, pageSize, searchText, model);
580
        return "ticket-content";
581
    }
582
 
37559 ranu 583
    private static String nvl(String s) {
584
        return s == null ? "" : s;
585
    }
586
 
587
    // Download every ticket the user can see in the current filter (respects ticketStatus /
588
    // sortOrder / search — but ignores pagination) as CSV with the same 8 columns rendered
589
    // in ticket-content.vm: Ticket Id, Partner, Category, SubCategory, Message, Created By,
590
    // Assigned To, Created TimeStamp.
591
    @GetMapping(value = "/cs/downloadMyTickets")
592
    public ResponseEntity<?> downloadMyTickets(HttpServletRequest request,
593
                                               @RequestParam(name = "orderby", defaultValue = "DESCENDING") SortOrder sortOrder,
594
                                               @RequestParam(name = "ticketStatus", defaultValue = "OPENED") TicketStatus ticketStatus,
595
                                               @RequestParam(name = "ticketSearchType", defaultValue = "") TicketSearchType ticketSearchType,
596
                                               @RequestParam(name = "searchTerm", defaultValue = "0") int searchTerm,
597
                                               @RequestParam(name = "search", required = false) String searchText) throws Exception {
598
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
599
        boolean isAdmin = roleManager.isAdmin(new HashSet<>(loginDetails.getRoleIds()));
600
        AuthUser currentAuthUser = isAdmin ? authRepository.selectByEmailOrMobile(loginDetails.getEmailId()) : null;
601
        boolean isCrmUser = isAdmin && currentAuthUser != null
602
                && positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
603
        List<Integer> userCategoryIds = isAdmin && currentAuthUser != null
604
                ? positionRepository.selectCategoryIdsByAuthUserId(currentAuthUser.getId())
605
                : Collections.emptyList();
606
 
607
        List<Ticket> tickets;
608
        if (isAdmin) {
609
            int authUserId = currentAuthUser.getId();
610
            Optional<Boolean> resolvedOpt = ticketStatus.equals(TicketStatus.RESOLVED)
611
                    ? Optional.empty()
612
                    : Optional.of(TicketStatus.CLOSED.equals(ticketStatus));
613
            long total;
614
            if (isCrmUser) {
615
                total = ticketRepository.selectAllTicketsPaginatedCount(
616
                        resolvedOpt, ticketSearchType, searchTerm, searchText, userCategoryIds);
617
                tickets = ticketRepository.selectAllTicketsPaginated(
618
                        resolvedOpt, sortOrder, ticketSearchType, searchTerm, searchText,
619
                        userCategoryIds, 0, (int) Math.max(1L, total));
620
            } else {
621
                total = ticketRepository.selectAllByAssigneePaginatedCount(
622
                        authUserId, resolvedOpt, ticketSearchType, searchTerm, searchText);
623
                tickets = ticketRepository.selectAllByAssigneePaginated(
624
                        authUserId, resolvedOpt, sortOrder, ticketSearchType, searchTerm, searchText,
625
                        0, (int) Math.max(1L, total));
626
            }
627
        } else {
628
            tickets = ticketRepository.selectAllByCreator(
629
                    loginDetails.getFofoId(),
630
                    Optional.of(TicketStatus.OPENED.equals(ticketStatus)),
631
                    sortOrder);
632
        }
633
        if (tickets == null) tickets = new ArrayList<>();
634
 
635
        List<Integer> subCategoryIds = tickets.stream().map(Ticket::getSubCategoryId).collect(Collectors.toList());
636
        Map<Integer, TicketSubCategory> subMap = csService.getSubCategoryIdAndSubCategoryMap(subCategoryIds);
637
        if (subMap == null) subMap = new HashMap<>();
638
        Map<Integer, TicketCategory> catMap = csService.getSubCategoryIdAndCategoryMap(subCategoryIds);
639
        if (catMap == null) catMap = new HashMap<>();
640
        Map<Integer, CustomRetailer> partnerMap = tickets.isEmpty()
641
                ? new HashMap<>()
642
                : csService.getPartnerByFofoIds(tickets);
643
        if (partnerMap == null) partnerMap = new HashMap<>();
644
        Map<Integer, List<AuthUser>> assigneeListMap = csService.getAssignedAuthList(tickets);
645
        if (assigneeListMap == null) assigneeListMap = new HashMap<>();
646
        Map<Integer, AuthUser> authUserIdMap = csService.getTicketIdAndAuthUserMapUsingTickets(tickets);
647
        if (authUserIdMap == null) authUserIdMap = new HashMap<>();
648
 
649
        List<Integer> ticketIds = tickets.stream().map(Ticket::getId).collect(Collectors.toList());
650
        Map<Integer, Activity> lastMessageMap = ticketIds.isEmpty()
651
                ? new HashMap<>()
652
                : csService.getLastMessageActivitiesForTickets(ticketIds);
653
        if (lastMessageMap == null) lastMessageMap = new HashMap<>();
654
 
655
        List<Activity> allActs = ticketIds.isEmpty()
656
                ? new ArrayList<>()
657
                : activityRepository.selectAll(ticketIds);
658
        Map<Integer, List<Activity>> activityByTicket = allActs.stream()
659
                .collect(Collectors.groupingBy(Activity::getTicketId));
660
        Map<Integer, Activity> activityById = allActs.stream()
661
                .collect(Collectors.toMap(Activity::getId, x -> x, (a, b) -> a));
662
 
663
        Set<Integer> creatorIds = new HashSet<>();
664
        for (Activity a : allActs) if (a.getCreatedBy() > 0) creatorIds.add(a.getCreatedBy());
665
        for (Activity a : lastMessageMap.values()) if (a.getCreatedBy() > 0) creatorIds.add(a.getCreatedBy());
666
        Map<Integer, AuthUser> authUserMap = creatorIds.isEmpty()
667
                ? new HashMap<>()
668
                : authRepository.selectByIds(new ArrayList<>(creatorIds)).stream()
669
                .collect(Collectors.toMap(AuthUser::getId, x -> x));
670
 
671
        List<List<?>> rows = new ArrayList<>();
672
        for (Ticket t : tickets) {
673
            int id = t.getId();
674
            CustomRetailer cr = partnerMap.get(t.getFofoId());
675
            String partner = cr != null ? nvl(cr.getBusinessName()) : "";
676
            TicketCategory cat = catMap.get(t.getSubCategoryId());
677
            String category = cat != null ? nvl(cat.getName()) : "";
678
            TicketSubCategory sub = subMap.get(t.getSubCategoryId());
679
            String subCategory = sub != null ? nvl(sub.getName()) : "";
680
 
681
            String message = "-";
682
            Activity msgAct = lastMessageMap.get(id);
683
            if (msgAct == null) {
684
                List<Activity> list = activityByTicket.get(id);
685
                if (list != null && !list.isEmpty()) msgAct = list.get(0);
686
            }
687
            if (msgAct != null) {
688
                String prefix = "~Partner";
689
                if (msgAct.getCreatedBy() > 0 && authUserMap.get(msgAct.getCreatedBy()) != null) {
690
                    prefix = "~" + nvl(authUserMap.get(msgAct.getCreatedBy()).getFirstName());
691
                }
692
                message = prefix + " " + nvl(msgAct.getMessage());
693
            }
694
 
695
            String createdBy = "Partner";
696
            Activity firstAct = activityById.get(t.getFirstActivityId());
697
            if (firstAct != null && firstAct.getCreatedBy() > 0) {
698
                AuthUser u = authUserMap.get(firstAct.getCreatedBy());
699
                if (u != null) createdBy = (nvl(u.getFirstName()) + " " + nvl(u.getLastName())).trim();
700
            }
701
 
702
            String assignedTo = "";
703
            List<AuthUser> assignees = assigneeListMap.get(id);
704
            if (assignees != null && !assignees.isEmpty()) {
705
                assignedTo = assignees.stream()
706
                        .map(u -> (nvl(u.getFirstName()) + " " + nvl(u.getLastName())).trim())
707
                        .collect(Collectors.joining(", "));
708
            } else if (authUserIdMap.get(id) != null) {
709
                AuthUser a = authUserIdMap.get(id);
710
                assignedTo = (nvl(a.getFirstName()) + " " + nvl(a.getLastName())).trim();
711
            }
712
 
713
            String createdTs = t.getFormattedCreateTimestamp() != null ? t.getFormattedCreateTimestamp() : "";
714
            rows.add(Arrays.asList(id, partner, category, subCategory, message, createdBy, assignedTo, createdTs));
715
        }
716
 
717
        org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil.getCSVByteStream(
718
                Arrays.asList("Ticket Id", "Partner", "Category", "SubCategory", "Message",
719
                        "Created By", "Assigned To", "Created TimeStamp"),
720
                rows);
721
        return orderService.downloadReportInCsv(baos, rows, "Tickets_" + ticketStatus.name());
722
    }
723
 
35626 amit 724
    private void populateMyTicketModel(HttpServletRequest request, SortOrder sortOrder, TicketStatus ticketStatus,
725
                                       TicketSearchType ticketSearchType, int searchTerm, int page, int pageSize,
726
                                       String searchText, Model model) throws ProfitMandiBusinessException {
31762 tejbeer 727
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
728
        List<Ticket> tickets = null;
729
        List<TicketAssigned> ticketAssigneds = null;
35626 amit 730
        long totalRecords = 0;
31762 tejbeer 731
        Map<Integer, AuthUser> authUserIdAndAuthUserMap = null;
35569 amit 732
        boolean isAdmin = roleManager.isAdmin(new HashSet<>(loginDetails.getRoleIds()));
733
        AuthUser currentAuthUser = isAdmin ? authRepository.selectByEmailOrMobile(loginDetails.getEmailId()) : null;
734
 
35592 amit 735
        boolean isCrmUser = isAdmin && currentAuthUser != null && positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
35603 amit 736
        boolean isSalesUser = isAdmin && currentAuthUser != null && positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_SALES);
737
        boolean isRbmUser = isAdmin && currentAuthUser != null && positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_RBM);
35592 amit 738
 
35626 amit 739
        List<Integer> userCategoryIds = isAdmin && currentAuthUser != null
740
                ? positionRepository.selectCategoryIdsByAuthUserId(currentAuthUser.getId())
741
                : Collections.emptyList();
742
 
743
        int offset = page * pageSize;
744
 
35569 amit 745
        if (isAdmin) {
746
            int authUserId = currentAuthUser.getId();
35592 amit 747
 
748
            if (isCrmUser) {
35626 amit 749
                Optional<Boolean> resolvedOpt = ticketStatus.equals(TicketStatus.RESOLVED) ? Optional.empty() : Optional.of(TicketStatus.CLOSED.equals(ticketStatus));
750
                tickets = ticketRepository.selectAllTicketsPaginated(
751
                        resolvedOpt, sortOrder, ticketSearchType, searchTerm, searchText,
752
                        userCategoryIds, offset, pageSize);
753
                totalRecords = ticketRepository.selectAllTicketsPaginatedCount(
754
                        resolvedOpt, ticketSearchType, searchTerm, searchText, userCategoryIds);
31762 tejbeer 755
            } else {
35626 amit 756
                Optional<Boolean> resolvedOpt = ticketStatus.equals(TicketStatus.RESOLVED) ? Optional.empty() : Optional.of(TicketStatus.CLOSED.equals(ticketStatus));
757
                tickets = ticketRepository.selectAllByAssigneePaginated(
758
                        authUserId, resolvedOpt, sortOrder, ticketSearchType, searchTerm, searchText,
759
                        offset, pageSize);
760
                totalRecords = ticketRepository.selectAllByAssigneePaginatedCount(
761
                        authUserId, resolvedOpt, ticketSearchType, searchTerm, searchText);
31762 tejbeer 762
            }
35626 amit 763
 
31762 tejbeer 764
            if (tickets.size() > 0) {
765
                ticketAssigneds = ticketAssignedRepository.selectByTicketIds(tickets.stream().map(x -> x.getId()).collect(Collectors.toList()));
766
                authUserIdAndAuthUserMap = csService.getAuthUserIdAndAuthUserMap(ticketAssigneds);
767
                Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = csService.getPartnerByFofoIds(tickets);
768
                model.addAttribute("fofoIdsAndCustomRetailer", fofoIdsAndCustomRetailer);
769
            }
24500 govind 770
 
31762 tejbeer 771
        } else {
772
            tickets = ticketRepository.selectAllByCreator(loginDetails.getFofoId(), Optional.of(TicketStatus.OPENED.equals(ticketStatus)), sortOrder);
35626 amit 773
            totalRecords = ticketRepository.selectAllCountByCreator(loginDetails.getFofoId(), Optional.of(TicketStatus.OPENED.equals(ticketStatus)));
31762 tejbeer 774
        }
775
        authUserIdAndAuthUserMap = csService.getTicketIdAndAuthUserMapUsingTickets(tickets);
35571 amit 776
        if (authUserIdAndAuthUserMap == null) {
777
            authUserIdAndAuthUserMap = new HashMap<>();
778
        }
24620 govind 779
 
36040 ranu 780
        Map<Integer, List<AuthUser>> authUserListMap = csService.getAssignedAuthList(tickets);
781
        if (authUserListMap == null) {
782
            authUserListMap = new HashMap<>();
783
        }
784
 
35626 amit 785
        int totalPages = (int) Math.ceil((double) totalRecords / pageSize);
786
        if (totalPages == 0) totalPages = 1;
787
        int startRecord = totalRecords > 0 ? offset + 1 : 0;
788
        int endRecord = (int) Math.min(offset + pageSize, totalRecords);
789
 
790
        model.addAttribute("size", totalRecords);
791
        model.addAttribute("totalRecords", totalRecords);
792
        model.addAttribute("currentPage", page);
793
        model.addAttribute("pageSize", pageSize);
794
        model.addAttribute("totalPages", totalPages);
795
        model.addAttribute("startRecord", startRecord);
796
        model.addAttribute("endRecord", endRecord);
797
        model.addAttribute("searchText", searchText != null ? searchText : "");
798
        model.addAttribute("currentPageDisplay", page + 1);
799
        model.addAttribute("prevPage", page - 1);
800
        model.addAttribute("nextPage", page + 1);
801
        model.addAttribute("lastPage", totalPages - 1);
802
 
35569 amit 803
        model.addAttribute("roleType", isAdmin);
804
        model.addAttribute("isCrmUser", isCrmUser);
35603 amit 805
        model.addAttribute("isSalesUser", isSalesUser);
806
        model.addAttribute("salesCategoryId", ProfitMandiConstants.TICKET_CATEGORY_SALES);
807
        model.addAttribute("isRbmUser", isRbmUser);
808
        model.addAttribute("rbmCategoryId", ProfitMandiConstants.TICKET_CATEGORY_RBM);
35626 amit 809
        model.addAttribute("userCategoryIds", userCategoryIds);
24500 govind 810
 
31762 tejbeer 811
        List<Integer> subCategoryIds = tickets.stream().map(x -> x.getSubCategoryId()).collect(Collectors.toList());
812
        Map<Integer, TicketSubCategory> subCategoryIdAndSubCategoryMap = csService.getSubCategoryIdAndSubCategoryMap(subCategoryIds);
35571 amit 813
        if (subCategoryIdAndSubCategoryMap == null) {
814
            subCategoryIdAndSubCategoryMap = new HashMap<>();
815
        }
24747 govind 816
 
31762 tejbeer 817
        Map<Integer, TicketCategory> subCategoryIdAndCategoryMap = csService.getSubCategoryIdAndCategoryMap(subCategoryIds);
35571 amit 818
        if (subCategoryIdAndCategoryMap == null) {
819
            subCategoryIdAndCategoryMap = new HashMap<>();
820
        }
27318 amit.gupta 821
 
31762 tejbeer 822
        List<Integer> ticketIds = tickets.stream().map(x -> x.getId()).collect(Collectors.toList());
24500 govind 823
 
35569 amit 824
        Map<Integer, List<Activity>> activityMap = new HashMap<>();
33864 ranu 825
        Map<Integer, List<Activity>> activityMapWithActivityId = new HashMap<>();
35569 amit 826
        Map<Integer, AuthUser> authUserMap = new HashMap<>();
24500 govind 827
 
31762 tejbeer 828
        if (!ticketIds.isEmpty()) {
35569 amit 829
            List<Activity> allActivities = activityRepository.selectAll(ticketIds);
830
            activityMap = allActivities.stream().collect(Collectors.groupingBy(Activity::getTicketId));
831
            activityMapWithActivityId = allActivities.stream().collect(Collectors.groupingBy(Activity::getId));
24787 govind 832
 
35569 amit 833
            Set<Integer> activityCreatorIds = allActivities.stream()
834
                    .map(Activity::getCreatedBy)
835
                    .filter(id -> id > 0)
836
                    .collect(Collectors.toSet());
837
            if (!activityCreatorIds.isEmpty()) {
838
                authUserMap = authRepository.selectByIds(new ArrayList<>(activityCreatorIds))
839
                        .stream().collect(Collectors.toMap(AuthUser::getId, x -> x));
840
            }
31762 tejbeer 841
        }
24787 govind 842
 
35626 amit 843
        int currentUserId;
844
        UserType currentUserType;
845
        if (isAdmin) {
846
            currentUserId = currentAuthUser.getId();
847
            currentUserType = UserType.AUTH_USER;
848
        } else {
849
            currentUserId = loginDetails.getFofoId();
850
            currentUserType = UserType.PARTNER;
851
        }
852
        Map<Integer, Boolean> unreadMap = csService.getUnreadStatusForTickets(tickets, currentUserId, currentUserType);
853
        Map<Integer, Activity> lastActivityMap = csService.getLastActivitiesForTickets(ticketIds);
35640 amit 854
        Map<Integer, Activity> lastMessageMap = csService.getLastMessageActivitiesForTickets(ticketIds);
35626 amit 855
        model.addAttribute("unreadMap", unreadMap);
856
        model.addAttribute("lastActivityMap", lastActivityMap);
35640 amit 857
        model.addAttribute("lastMessageMap", lastMessageMap);
35626 amit 858
 
31762 tejbeer 859
        model.addAttribute("tickets", tickets);
860
        model.addAttribute("resolved", ActivityType.RESOLVED);
861
        model.addAttribute("resolved-accepted", ActivityType.RESOLVED_ACCEPTED);
862
        model.addAttribute("resolved-rejected", ActivityType.RESOLVED_REJECTED);
863
        model.addAttribute("authUserIdAndAuthUserMap", authUserIdAndAuthUserMap);
36040 ranu 864
        model.addAttribute("authUserListMap", authUserListMap);
31762 tejbeer 865
        model.addAttribute("subCategoryIdAndSubCategoryMap", subCategoryIdAndSubCategoryMap);
27318 amit.gupta 866
 
31762 tejbeer 867
        model.addAttribute("subCategoryIdAndCategoryMap", subCategoryIdAndCategoryMap);
868
        model.addAttribute("activityMap", activityMap);
33864 ranu 869
        model.addAttribute("authUserMap", authUserMap);
870
        model.addAttribute("activityMapWithActivityId", activityMapWithActivityId);
24500 govind 871
 
31762 tejbeer 872
        model.addAttribute("ticketStatusValues", TicketStatus.values());
873
        model.addAttribute("orderByValues", SortOrder.values());
874
        model.addAttribute("selectedticketStatus", ticketStatus);
875
        model.addAttribute("selectedorderby", sortOrder);
876
        model.addAttribute("ticketSearchTypes", TicketSearchType.values());
877
        model.addAttribute("ticketSearchType", ticketSearchType);
878
        model.addAttribute("searchTerm", searchTerm);
879
    }
24500 govind 880
 
27124 amit.gupta 881
 
31762 tejbeer 882
    @GetMapping(value = "/cs/getActivities")
883
    public String getActivity(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, Model model) throws Exception {
35592 amit 884
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
885
        Ticket ticket = ticketRepository.selectById(ticketId);
886
 
887
        if (ticket == null) {
888
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
889
        }
890
 
891
        // Authorization check: verify user has access to this ticket
892
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
893
        if (!isAdmin) {
894
            // Partners can only view their own tickets
895
            if (ticket.getFofoId() != loginDetails.getFofoId()) {
896
                throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to view this ticket");
897
            }
898
        } else {
899
            // Admins must be assigned to the ticket OR be CRM user OR be in the escalation chain
900
            AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
901
            boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
902
 
903
            if (!isCrmUser) {
37145 ranu 904
                // Assigned = user was ever the assignee or manager on this ticket (any level).
905
                // The old l1..l5AuthUser fallback check was fully subsumed by this since it
906
                // includes every past TicketAssigned row.
35592 amit 907
                List<TicketAssigned> assignments = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
908
                boolean isAssigned = assignments.stream().anyMatch(ta -> ta.getAssineeId() == currentAuthUser.getId() || ta.getManagerId() == currentAuthUser.getId());
909
 
36231 ranu 910
                // Check if user is related to this partner (RBM, ASM, BM etc.)
911
                boolean isRelatedToPartner = false;
37145 ranu 912
                if (!isAssigned) {
36231 ranu 913
                    List<AuthUser> relatedUsers = csService.getAuthUserIdByPartnerId(ticket.getFofoId());
914
                    isRelatedToPartner = relatedUsers.stream()
915
                            .anyMatch(au -> au.getId() == currentAuthUser.getId());
916
                    if (!isRelatedToPartner) {
917
                        throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to view this ticket");
918
                    }
35592 amit 919
                }
36231 ranu 920
 
37145 ranu 921
                // User can view but cannot take action if only related to partner (not assigned)
922
                model.addAttribute("canTakeAction", isAssigned);
35592 amit 923
            }
924
        }
925
 
31762 tejbeer 926
        List<Activity> allactivities = activityRepository.selectAll(ticketId);
35570 amit 927
 
928
        // Batch fetch all documents for attachments (fix N+1 query)
929
        List<Integer> documentIds = allactivities.stream()
930
                .flatMap(a -> a.getActivityAttachment().stream())
931
                .map(ActivityAttachment::getDocumentId)
932
                .distinct()
933
                .collect(Collectors.toList());
934
 
935
        Map<Integer, Document> documentMap = Collections.emptyMap();
936
        if (!documentIds.isEmpty()) {
937
            documentMap = documentRepository.selectByIds(documentIds).stream()
938
                    .collect(Collectors.toMap(Document::getId, d -> d));
939
        }
940
 
941
        // Set document names transiently (do not persist during GET)
942
        for (Activity activity : allactivities) {
943
            for (ActivityAttachment attachment : activity.getActivityAttachment()) {
944
                Document document = documentMap.get(attachment.getDocumentId());
945
                if (document != null) {
946
                    attachment.setDocumentName(document.getDisplayName());
947
                }
31762 tejbeer 948
            }
949
        }
950
        List<Activity> activities = null;
35592 amit 951
        if (isAdmin) {
31762 tejbeer 952
            Set<Integer> authUserIds = allactivities.stream().map(x -> x.getCreatedBy()).collect(Collectors.toSet());
36040 ranu 953
 
954
            // Fetch current assignees for this ticket to show in ASSIGNED/ESCALATED activities
955
            List<TicketAssigned> ticketAssignments = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
956
            Set<Integer> assigneeIds = ticketAssignments.stream()
957
                    .map(TicketAssigned::getAssineeId)
958
                    .collect(Collectors.toSet());
959
            authUserIds.addAll(assigneeIds);
960
 
35395 amit 961
            List<AuthUser> users = authRepository.selectByIds(new ArrayList<>(authUserIds));
31762 tejbeer 962
            Map<Integer, String> authUserNameMap = users.stream().collect(Collectors.toMap(AuthUser::getId, x -> x.getFirstName() + " " + x.getLastName()));
36040 ranu 963
 
964
            // Get current assignee name (most recent assignment)
965
            String currentAssigneeName = null;
966
            if (!ticketAssignments.isEmpty()) {
967
                int latestAssigneeId = ticketAssignments.get(ticketAssignments.size() - 1).getAssineeId();
968
                currentAssigneeName = authUserNameMap.get(latestAssigneeId);
969
            }
970
            final String assigneeName = currentAssigneeName;
971
 
972
            allactivities.stream().forEach(x -> {
973
                x.setName(authUserNameMap.get(x.getCreatedBy()));
974
                // For ASSIGNED/ESCALATED activities, use name field to show assignee
975
                ActivityType actType = x.getType();
976
                if (assigneeName != null && (actType == ActivityType.ASSIGNED || actType == ActivityType.ESCALATED || actType == ActivityType.ESCALATED_FINAL)) {
977
                    x.setName(assigneeName);
978
                }
979
            });
31762 tejbeer 980
            activities = allactivities;
981
        } else {
982
            activities = allactivities.stream().filter(x -> ActivityType.PARTNER_ACTIVITIES.contains(x.getType())).collect(Collectors.toList());
983
        }
984
        if (activities == null) {
985
            throw new ProfitMandiBusinessException("Activity", ticketId, "No Activity Found");
986
        }
987
        model.addAttribute("response1", mvcResponseSender.createResponseString(activities));
988
        return "response";
24500 govind 989
 
31762 tejbeer 990
    }
24620 govind 991
 
31762 tejbeer 992
    @PostMapping(value = "/cs/createActivity")
993
    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 994
 
31762 tejbeer 995
                                 Model model) throws Exception {
24620 govind 996
 
31762 tejbeer 997
        LOGGER.info("documentIds" + documentIds);
998
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
999
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 1000
 
1001
        if (ticket == null) {
1002
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
1003
        }
1004
 
1005
        // Authorization check: verify user has access to add activity to this ticket
1006
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
1007
        if (!isAdmin) {
1008
            // Partners can only add activity to their own tickets
1009
            if (ticket.getFofoId() != loginDetails.getFofoId()) {
1010
                throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to add activity to this ticket");
1011
            }
1012
        } else {
1013
            // Admins must be assigned to the ticket OR be CRM user OR be in the escalation chain
1014
            AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1015
            boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1016
 
1017
            if (!isCrmUser) {
1018
                List<TicketAssigned> assignments = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
1019
                boolean isAssigned = assignments.stream().anyMatch(ta -> ta.getAssineeId() == currentAuthUser.getId() || ta.getManagerId() == currentAuthUser.getId());
1020
 
37145 ranu 1021
                if (!isAssigned) {
35592 amit 1022
                    throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to add activity to this ticket");
1023
                }
1024
            }
1025
        }
31762 tejbeer 1026
        List<TicketAssigned> ticketAssignedList = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
1027
        List<Integer> authUserIds = ticketAssignedList.stream().map(x -> x.getAssineeId()).collect(Collectors.toList());
1028
        authUserIds.add(ticketAssignedList.get(ticketAssignedList.size() - 1).getManagerId());
35395 amit 1029
        Map<Integer, AuthUser> authUsersMap = authRepository.selectByIds(authUserIds).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
31762 tejbeer 1030
        if (ticket.getCloseTimestamp() == null) {
1031
            Activity activity = new Activity();
1032
            activity.setCreatedBy(0);
1033
            activity.setCreateTimestamp(LocalDateTime.now());
1034
            String subject = null;
1035
            String mailMessage = null;
1036
            activity.setMessage(message);
1037
            if (!roleManager.isAdmin(new HashSet<>(loginDetails.getRoleIds()))) {
1038
                CustomRetailer customRetailer = retailerService.getFofoRetailers(true).get(loginDetails.getFofoId());
1039
                activity.setType(ActivityType.COMMUNICATION_IN);
1040
                subject = String.format("Ticket Update #%s by franchisee %s", ticket.getId(), customRetailer.getBusinessName() + "(" + customRetailer.getCode() + ")");
1041
                mailMessage = String.format("Franchisee message - %s", message);
1042
            } else {
1043
                AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1044
                activity.setCreatedBy(authUser.getId());
1045
                authUsersMap.remove(authUser.getId());
1046
                subject = String.format("Ticket Update #%s by %s", ticket.getId(), authUser.getName());
1047
                mailMessage = String.format("%s's message - %s", authUser.getFirstName(), message);
35569 amit 1048
                // Only CRM users can send external communications
1049
                boolean isCrmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1050
                if (internal || !isCrmUser) {
31762 tejbeer 1051
                    activity.setType(ActivityType.COMMUNICATION_INTERNAL);
1052
                } else {
1053
                    String updatedBy = "SD Team";
31854 amit.gupta 1054
                    CustomRetailer customRetailer = retailerService.getFofoRetailers(false).get(ticket.getFofoId());
31762 tejbeer 1055
                    subject = String.format("Ticket Update #%s by %s", ticket.getId(), updatedBy);
1056
                    String partnerMessage = String.format("%s's message - %s", updatedBy, message);
1057
                    this.activityRelatedMail(customRetailer.getEmail(), null, "subject", partnerMessage);
1058
                    activity.setType(ActivityType.COMMUNICATION_OUT);
1059
                }
1060
            }
1061
            activityRepository.persist(activity);
1062
 
1063
            for (Integer documentId : documentIds) {
1064
                ActivityAttachment activityAttachment = new ActivityAttachment();
1065
                activityAttachment.setActivityId(activity.getId());
1066
                activityAttachment.setDocumentId(documentId);
1067
                activityAttachmentRepository.persist(activityAttachment);
1068
            }
1069
 
1070
            csService.addActivity(ticket, activity);
1071
            AuthUser authUser = authUsersMap.remove(authUserIds.get(0));
1072
            if (authUser == null) {
1073
                authUser = authUsersMap.remove(authUserIds.get(1));
1074
            }
1075
            model.addAttribute("response1", mvcResponseSender.createResponseString(authUser));
1076
            String[] cc = authUsersMap.entrySet().stream().map(x -> x.getValue().getEmailId()).toArray(String[]::new);
1077
            this.activityRelatedMail(authUser.getEmailId(), cc, subject, mailMessage);
1078
        } else {
1079
            throw new ProfitMandiBusinessException("Ticket", ticket.getId(), "Already closed ticket");
1080
        }
1081
        return "response";
1082
    }
1083
 
1084
    private void activityRelatedMail(String to, String[] cc, String subject, String message) throws ProfitMandiBusinessException {
1085
        try {
35957 amit 1086
            mailOutboxService.queueMail(to, cc, subject, message, "CsController.activityRelatedMail");
31762 tejbeer 1087
        } catch (Exception e) {
1088
            throw new ProfitMandiBusinessException("Ticket Activity", to, "Could not send ticket activity mail");
1089
        }
1090
    }
1091
 
1092
    @PostMapping(value = "/cs/closeTicket")
1093
    public String closeTicket(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, @RequestParam(name = "happyCode") String happyCode, Model model) throws Exception {
35592 amit 1094
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
31762 tejbeer 1095
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 1096
 
1097
        if (ticket == null) {
1098
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
1099
        }
1100
 
1101
        // Authorization check: only the ticket owner (partner) can close the ticket
1102
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
1103
        if (isAdmin) {
1104
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Only partners can close tickets using happy code");
1105
        }
1106
 
1107
        // Verify the partner owns this ticket
1108
        if (ticket.getFofoId() != loginDetails.getFofoId()) {
1109
            throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to close this ticket");
1110
        }
1111
 
31762 tejbeer 1112
        if (ticket.getHappyCode().equals(happyCode)) {
1113
            ticket.setCloseTimestamp(LocalDateTime.now());
1114
            ticketRepository.persist(ticket);
1115
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1116
        } else {
1117
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Happy Code can't match");
1118
        }
1119
        return "response";
1120
    }
1121
 
34913 ranu 1122
    @GetMapping(value = "/cs/myPartyTicketTicket")
1123
    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 {
35626 amit 1124
        populateMyPartnerTicketModel(request, sortOrder, ticketStatus, ticketSearchType, searchTerm, model);
1125
        return "my-partner-tickets";
1126
    }
1127
 
1128
    @GetMapping(value = "/cs/myPartyTicket-content")
1129
    public String getMyPartyTicketContent(HttpServletRequest request,
1130
                                          @RequestParam(name = "orderby", defaultValue = "DESCENDING") SortOrder sortOrder,
1131
                                          @RequestParam(name = "ticketStatus", defaultValue = "OPENED") TicketStatus ticketStatus,
1132
                                          @RequestParam(name = "ticketSearchType", defaultValue = "") TicketSearchType ticketSearchType,
1133
                                          @RequestParam(name = "searchTerm", defaultValue = "0") int searchTerm,
1134
                                          Model model) throws ProfitMandiBusinessException {
1135
        populateMyPartnerTicketModel(request, sortOrder, ticketStatus, ticketSearchType, searchTerm, model);
1136
        return "my-partner-tickets-content";
1137
    }
1138
 
1139
    private void populateMyPartnerTicketModel(HttpServletRequest request, SortOrder sortOrder, TicketStatus ticketStatus,
1140
                                              TicketSearchType ticketSearchType, int searchTerm, Model model) throws ProfitMandiBusinessException {
34913 ranu 1141
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1142
        AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1143
        List<Ticket> tickets = new ArrayList<>();
1144
        Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
1145
        Set<Integer> fofoIds = storeGuyMap.get(authUser.getEmailId());
1146
 
1147
        Map<Integer, List<AuthUser>> authUserListMap = null;
1148
        if (fofoIds != null && !fofoIds.isEmpty()) {
35571 amit 1149
            List<Ticket> allPartnerTickets = ticketRepository.selectAllOpenTickets(new ArrayList<>(fofoIds));
1150
            if (allPartnerTickets != null && !allPartnerTickets.isEmpty()) {
1151
                tickets = allPartnerTickets.stream()
1152
                        .filter(ticket -> ticket.getLastActivity() == null ||
1153
                                ticket.getLastActivity() != ActivityType.RESOLVED)
1154
                        .collect(Collectors.toList());
34913 ranu 1155
            }
1156
        }
1157
 
1158
        authUserListMap = csService.getAssignedAuthList(tickets);
1159
 
37145 ranu 1160
        // Find which tickets are assigned to or escalated to this user (can take action).
1161
        // TicketAssigned history covers every past assignee + manager pair, which fully
1162
        // subsumes the previous l1..l5AuthUser fallback loop.
36231 ranu 1163
        Set<Integer> actionableTicketIds = new HashSet<>();
34913 ranu 1164
        if (tickets.size() > 0) {
36231 ranu 1165
            List<TicketAssigned> allAssignments = ticketAssignedRepository.selectByTicketIds(
1166
                    tickets.stream().map(Ticket::getId).collect(Collectors.toList()));
1167
            for (TicketAssigned ta : allAssignments) {
1168
                if (ta.getAssineeId() == authUser.getId() || ta.getManagerId() == authUser.getId()) {
1169
                    actionableTicketIds.add(ta.getTicketId());
1170
                }
1171
            }
34913 ranu 1172
            Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = csService.getPartnerByFofoIds(tickets);
1173
            model.addAttribute("fofoIdsAndCustomRetailer", fofoIdsAndCustomRetailer);
1174
        }
36231 ranu 1175
        model.addAttribute("actionableTicketIds", actionableTicketIds);
34913 ranu 1176
 
35626 amit 1177
        // Pagination for partner tickets (in-memory since selectAllOpenTickets doesn't support DB-level pagination)
1178
        long totalRecords = tickets.size();
1179
        int totalPages = totalRecords > 0 ? (int) Math.ceil((double) totalRecords / 25) : 1;
1180
        model.addAttribute("totalRecords", totalRecords);
1181
        model.addAttribute("currentPage", 0);
1182
        model.addAttribute("pageSize", 25);
1183
        model.addAttribute("totalPages", totalPages);
1184
        model.addAttribute("startRecord", totalRecords > 0 ? 1 : 0);
1185
        model.addAttribute("endRecord", totalRecords);
1186
        model.addAttribute("currentPageDisplay", 1);
1187
        model.addAttribute("prevPage", 0);
1188
        model.addAttribute("nextPage", 1);
1189
        model.addAttribute("lastPage", totalPages - 1);
1190
 
34913 ranu 1191
        model.addAttribute("size", tickets.size());
1192
        model.addAttribute("tickets", tickets);
1193
 
1194
        List<Integer> subCategoryIds = tickets.stream().map(x -> x.getSubCategoryId()).collect(Collectors.toList());
1195
        Map<Integer, TicketSubCategory> subCategoryIdAndSubCategoryMap = csService.getSubCategoryIdAndSubCategoryMap(subCategoryIds);
35571 amit 1196
        if (subCategoryIdAndSubCategoryMap == null) {
1197
            subCategoryIdAndSubCategoryMap = new HashMap<>();
1198
        }
34913 ranu 1199
 
1200
        Map<Integer, TicketCategory> subCategoryIdAndCategoryMap = csService.getSubCategoryIdAndCategoryMap(subCategoryIds);
35571 amit 1201
        if (subCategoryIdAndCategoryMap == null) {
1202
            subCategoryIdAndCategoryMap = new HashMap<>();
1203
        }
34913 ranu 1204
 
1205
        List<Integer> ticketIds = tickets.stream().map(x -> x.getId()).collect(Collectors.toList());
1206
        Map<Integer, List<Activity>> activityMap = new HashMap<>();
1207
        Map<Integer, List<Activity>> activityMapWithActivityId = new HashMap<>();
35569 amit 1208
        Map<Integer, AuthUser> authUserMap = new HashMap<>();
34913 ranu 1209
 
1210
        if (!ticketIds.isEmpty()) {
35569 amit 1211
            List<Activity> allActivities = activityRepository.selectAll(ticketIds);
1212
            activityMap = allActivities.stream().collect(Collectors.groupingBy(Activity::getTicketId));
1213
            activityMapWithActivityId = allActivities.stream().collect(Collectors.groupingBy(Activity::getId));
34913 ranu 1214
 
35569 amit 1215
            Set<Integer> activityCreatorIds = allActivities.stream()
1216
                    .map(Activity::getCreatedBy)
1217
                    .filter(id -> id > 0)
1218
                    .collect(Collectors.toSet());
1219
            if (!activityCreatorIds.isEmpty()) {
1220
                authUserMap = authRepository.selectByIds(new ArrayList<>(activityCreatorIds))
1221
                        .stream().collect(Collectors.toMap(AuthUser::getId, x -> x));
1222
            }
34913 ranu 1223
        }
1224
 
35626 amit 1225
        Map<Integer, Boolean> unreadMap = csService.getUnreadStatusForTickets(tickets, authUser.getId(), UserType.AUTH_USER);
35640 amit 1226
        List<Integer> partnerTicketIds = tickets.stream().map(Ticket::getId).collect(Collectors.toList());
1227
        Map<Integer, Activity> lastActivityMap = csService.getLastActivitiesForTickets(partnerTicketIds);
1228
        Map<Integer, Activity> lastMessageMap = csService.getLastMessageActivitiesForTickets(partnerTicketIds);
35626 amit 1229
        model.addAttribute("unreadMap", unreadMap);
1230
        model.addAttribute("lastActivityMap", lastActivityMap);
35640 amit 1231
        model.addAttribute("lastMessageMap", lastMessageMap);
35626 amit 1232
 
34913 ranu 1233
        model.addAttribute("ticketStatusValues", TicketStatus.values());
1234
        model.addAttribute("orderByValues", SortOrder.values());
1235
        model.addAttribute("selectedticketStatus", ticketStatus);
1236
        model.addAttribute("selectedorderby", sortOrder);
1237
        model.addAttribute("ticketSearchTypes", TicketSearchType.values());
1238
        model.addAttribute("ticketSearchType", ticketSearchType);
1239
        model.addAttribute("searchTerm", searchTerm);
35571 amit 1240
        model.addAttribute("authUserListMap", authUserListMap != null ? authUserListMap : new HashMap<>());
34913 ranu 1241
        model.addAttribute("subCategoryIdAndSubCategoryMap", subCategoryIdAndSubCategoryMap);
1242
 
1243
        model.addAttribute("subCategoryIdAndCategoryMap", subCategoryIdAndCategoryMap);
1244
 
1245
        model.addAttribute("activityMap", activityMap);
1246
        model.addAttribute("authUserMap", authUserMap);
1247
        model.addAttribute("activityMapWithActivityId", activityMapWithActivityId);
35569 amit 1248
        boolean isCrmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1249
        model.addAttribute("isCrmUser", isCrmUser);
35626 amit 1250
    }
34913 ranu 1251
 
35626 amit 1252
    @GetMapping(value = "/cs/managerTicket")
1253
    public String getManagerTickets(HttpServletRequest request,
1254
                                    @RequestParam(name = "orderby", defaultValue = "DESCENDING") SortOrder sortOrder,
1255
                                    @RequestParam(name = "ticketStatus", defaultValue = "OPENED") TicketStatus ticketStatus,
1256
                                    @RequestParam(name = "ticketSearchType", defaultValue = "") TicketSearchType ticketSearchType,
1257
                                    @RequestParam(name = "searchTerm", defaultValue = "0") int searchTerm,
1258
                                    @RequestParam(name = "page", defaultValue = "0") int page,
1259
                                    @RequestParam(name = "pageSize", defaultValue = "25") int pageSize,
1260
                                    @RequestParam(name = "search", required = false) String searchText,
1261
                                    Model model) throws ProfitMandiBusinessException {
1262
        populateManagerTicketModel(request, sortOrder, ticketStatus, ticketSearchType, searchTerm, page, pageSize, searchText, model);
1263
        return "managerTicket";
34913 ranu 1264
    }
1265
 
35626 amit 1266
    @GetMapping(value = "/cs/managerTicket-content")
1267
    public String getManagerTicketContent(HttpServletRequest request,
1268
                                          @RequestParam(name = "orderby", defaultValue = "DESCENDING") SortOrder sortOrder,
1269
                                          @RequestParam(name = "ticketStatus", defaultValue = "OPENED") TicketStatus ticketStatus,
1270
                                          @RequestParam(name = "ticketSearchType", defaultValue = "") TicketSearchType ticketSearchType,
1271
                                          @RequestParam(name = "searchTerm", defaultValue = "0") int searchTerm,
1272
                                          @RequestParam(name = "page", defaultValue = "0") int page,
1273
                                          @RequestParam(name = "pageSize", defaultValue = "25") int pageSize,
1274
                                          @RequestParam(name = "search", required = false) String searchText,
1275
                                          Model model) throws ProfitMandiBusinessException {
1276
        populateManagerTicketModel(request, sortOrder, ticketStatus, ticketSearchType, searchTerm, page, pageSize, searchText, model);
1277
        return "managerTicket-content";
1278
    }
1279
 
1280
    private void populateManagerTicketModel(HttpServletRequest request, SortOrder sortOrder, TicketStatus ticketStatus,
1281
                                            TicketSearchType ticketSearchType, int searchTerm, int page, int pageSize,
1282
                                            String searchText, Model model) throws ProfitMandiBusinessException {
31762 tejbeer 1283
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
35626 amit 1284
        long totalRecords = 0;
31762 tejbeer 1285
        AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
35626 amit 1286
 
1287
        // Block L1-only users from accessing manager tickets
1288
        List<Position> positions = positionRepository.selectAllByAuthUserId(authUser.getId());
1289
        boolean isAboveL1 = positions.stream().anyMatch(pos -> pos.getEscalationType() != EscalationType.L1);
1290
        if (!isAboveL1) {
1291
            throw new ProfitMandiBusinessException("ManagerTicket", 0, "Access denied: requires at least L2 position");
1292
        }
1293
 
35594 amit 1294
        boolean isCrmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1295
 
35626 amit 1296
        List<Integer> userCategoryIds = positionRepository.selectCategoryIdsByAuthUserId(authUser.getId());
1297
 
31762 tejbeer 1298
        List<Ticket> tickets = null;
1299
        Map<Integer, List<AuthUser>> authUserListMap = null;
35594 amit 1300
 
35626 amit 1301
        int offset = page * pageSize;
1302
        Optional<Boolean> resolvedOpt = ticketStatus.equals(TicketStatus.RESOLVED) ? Optional.empty() : Optional.of(TicketStatus.CLOSED.equals(ticketStatus));
1303
 
35594 amit 1304
        if (isCrmUser) {
35626 amit 1305
            tickets = ticketRepository.selectAllTicketsPaginated(
1306
                    resolvedOpt, sortOrder, ticketSearchType, searchTerm, searchText,
1307
                    userCategoryIds, offset, pageSize);
1308
            totalRecords = ticketRepository.selectAllTicketsPaginatedCount(
1309
                    resolvedOpt, ticketSearchType, searchTerm, searchText, userCategoryIds);
31762 tejbeer 1310
        } else {
35626 amit 1311
            tickets = ticketRepository.selectAllManagerTicketPaginated(
1312
                    authUser.getId(), sortOrder, resolvedOpt, ticketSearchType, searchTerm, searchText,
1313
                    offset, pageSize);
1314
            totalRecords = ticketRepository.selectAllCountByManagerTicketPaginated(
1315
                    authUser.getId(), resolvedOpt, ticketSearchType, searchTerm, searchText);
31762 tejbeer 1316
        }
1317
        authUserListMap = csService.getAssignedAuthList(tickets);
1318
 
1319
        if (tickets.size() > 0) {
1320
            Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = csService.getPartnerByFofoIds(tickets);
1321
            model.addAttribute("fofoIdsAndCustomRetailer", fofoIdsAndCustomRetailer);
1322
        }
1323
 
35626 amit 1324
        int totalPages = (int) Math.ceil((double) totalRecords / pageSize);
1325
        if (totalPages == 0) totalPages = 1;
1326
        int startRecord = totalRecords > 0 ? offset + 1 : 0;
1327
        int endRecord = (int) Math.min(offset + pageSize, totalRecords);
1328
 
1329
        model.addAttribute("size", totalRecords);
1330
        model.addAttribute("totalRecords", totalRecords);
1331
        model.addAttribute("currentPage", page);
1332
        model.addAttribute("pageSize", pageSize);
1333
        model.addAttribute("totalPages", totalPages);
1334
        model.addAttribute("startRecord", startRecord);
1335
        model.addAttribute("endRecord", endRecord);
1336
        model.addAttribute("searchText", searchText != null ? searchText : "");
1337
        model.addAttribute("currentPageDisplay", page + 1);
1338
        model.addAttribute("prevPage", page - 1);
1339
        model.addAttribute("nextPage", page + 1);
1340
        model.addAttribute("lastPage", totalPages - 1);
31762 tejbeer 1341
        model.addAttribute("tickets", tickets);
1342
 
1343
        List<Integer> subCategoryIds = tickets.stream().map(x -> x.getSubCategoryId()).collect(Collectors.toList());
1344
        Map<Integer, TicketSubCategory> subCategoryIdAndSubCategoryMap = csService.getSubCategoryIdAndSubCategoryMap(subCategoryIds);
35571 amit 1345
        if (subCategoryIdAndSubCategoryMap == null) {
1346
            subCategoryIdAndSubCategoryMap = new HashMap<>();
1347
        }
31762 tejbeer 1348
 
1349
        Map<Integer, TicketCategory> subCategoryIdAndCategoryMap = csService.getSubCategoryIdAndCategoryMap(subCategoryIds);
35571 amit 1350
        if (subCategoryIdAndCategoryMap == null) {
1351
            subCategoryIdAndCategoryMap = new HashMap<>();
1352
        }
31762 tejbeer 1353
 
1354
        List<Integer> ticketIds = tickets.stream().map(x -> x.getId()).collect(Collectors.toList());
1355
        Map<Integer, List<Activity>> activityMap = new HashMap<>();
33778 ranu 1356
        Map<Integer, List<Activity>> activityMapWithActivityId = new HashMap<>();
35570 amit 1357
        Map<Integer, AuthUser> authUserMap = new HashMap<>();
31762 tejbeer 1358
 
1359
        if (!ticketIds.isEmpty()) {
35570 amit 1360
            List<Activity> allActivities = activityRepository.selectAll(ticketIds);
1361
            activityMap = allActivities.stream().collect(Collectors.groupingBy(Activity::getTicketId));
1362
            activityMapWithActivityId = allActivities.stream().collect(Collectors.groupingBy(Activity::getId));
31762 tejbeer 1363
 
35570 amit 1364
            Set<Integer> activityCreatorIds = allActivities.stream()
1365
                    .map(Activity::getCreatedBy)
1366
                    .filter(id -> id > 0)
1367
                    .collect(Collectors.toSet());
1368
            if (!activityCreatorIds.isEmpty()) {
1369
                authUserMap = authRepository.selectByIds(new ArrayList<>(activityCreatorIds))
1370
                        .stream().collect(Collectors.toMap(AuthUser::getId, x -> x));
1371
            }
31762 tejbeer 1372
        }
33778 ranu 1373
 
35626 amit 1374
        Map<Integer, Boolean> unreadMap = csService.getUnreadStatusForTickets(tickets, authUser.getId(), UserType.AUTH_USER);
35640 amit 1375
        List<Integer> managerTicketIds = tickets.stream().map(Ticket::getId).collect(Collectors.toList());
1376
        Map<Integer, Activity> lastActivityMap = csService.getLastActivitiesForTickets(managerTicketIds);
1377
        Map<Integer, Activity> lastMessageMap = csService.getLastMessageActivitiesForTickets(managerTicketIds);
35626 amit 1378
        model.addAttribute("unreadMap", unreadMap);
1379
        model.addAttribute("lastActivityMap", lastActivityMap);
35640 amit 1380
        model.addAttribute("lastMessageMap", lastMessageMap);
35626 amit 1381
 
31762 tejbeer 1382
        model.addAttribute("ticketStatusValues", TicketStatus.values());
1383
        model.addAttribute("orderByValues", SortOrder.values());
1384
        model.addAttribute("selectedticketStatus", ticketStatus);
1385
        model.addAttribute("selectedorderby", sortOrder);
1386
        model.addAttribute("ticketSearchTypes", TicketSearchType.values());
1387
        model.addAttribute("ticketSearchType", ticketSearchType);
1388
        model.addAttribute("searchTerm", searchTerm);
1389
        model.addAttribute("authUserListMap", authUserListMap);
1390
        model.addAttribute("subCategoryIdAndSubCategoryMap", subCategoryIdAndSubCategoryMap);
1391
 
1392
        model.addAttribute("subCategoryIdAndCategoryMap", subCategoryIdAndCategoryMap);
1393
 
1394
        model.addAttribute("activityMap", activityMap);
33778 ranu 1395
        model.addAttribute("authUserMap", authUserMap);
1396
        model.addAttribute("activityMapWithActivityId", activityMapWithActivityId);
35594 amit 1397
        model.addAttribute("isCrmUser", isCrmUser);
31762 tejbeer 1398
    }
1399
 
1400
 
1401
    @GetMapping(value = "/cs/edit-ticket")
35594 amit 1402
    public String getEditTicket(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, Model model) throws ProfitMandiBusinessException {
1403
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1404
        AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1405
        boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1406
 
31762 tejbeer 1407
        Ticket ticket = ticketRepository.selectById(ticketId);
35626 amit 1408
        if (ticket == null) {
1409
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
1410
        }
1411
 
1412
        TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());
1413
        int ticketCategoryId = ticketSubCategory.getCategoryId();
1414
        boolean isVisibleSubCategory = ticketSubCategory.isVisibility();
1415
 
1416
        // Check permissions
1417
        boolean hasPositionInCategory = positionRepository.hasCategory(currentAuthUser.getId(), ticketCategoryId);
1418
        List<TicketAssigned> assignments = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
1419
        boolean isAssigned = assignments.stream().anyMatch(ta -> ta.getAssineeId() == currentAuthUser.getId() || ta.getManagerId() == currentAuthUser.getId());
1420
 
1421
        boolean canEdit = (isCrmUser && isVisibleSubCategory)
1422
                || hasPositionInCategory
37145 ranu 1423
                || isAssigned;
35626 amit 1424
 
1425
        if (!canEdit) {
1426
            throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to edit this ticket");
1427
        }
1428
 
31762 tejbeer 1429
        List<TicketCategory> ticketCategories = csService.getAllTicketCategotyFromSubCategory();
1430
        List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAll(ticketSubCategory.getCategoryId());
1431
        List<AuthUser> authUsers = authRepository.selectAllActiveUser();
35594 amit 1432
 
35617 amit 1433
        // CRM users should not see invisible subcategories
35594 amit 1434
        if (isCrmUser) {
1435
            ticketSubCategories = ticketSubCategories.stream()
35617 amit 1436
                    .filter(TicketSubCategory::isVisibility)
35594 amit 1437
                    .collect(Collectors.toList());
1438
        }
1439
 
1440
        // Get partner name for modal title
1441
        String partnerName = retailerService.getFofoRetailer(ticket.getFofoId()).getBusinessName();
1442
 
31762 tejbeer 1443
        model.addAttribute("ticket", ticket);
1444
        model.addAttribute("ticketCategories", ticketCategories);
1445
        model.addAttribute("ticketSubCategories", ticketSubCategories);
1446
        model.addAttribute("ticketSubCategory", ticketSubCategory);
1447
        model.addAttribute("authUsers", authUsers);
35594 amit 1448
        model.addAttribute("isCrmUser", isCrmUser);
1449
        model.addAttribute("partnerName", partnerName);
31762 tejbeer 1450
        return "edit-ticket-modal";
1451
    }
1452
 
34913 ranu 1453
    @GetMapping(value = "/cs/edit-partner-ticket")
35594 amit 1454
    public String getEditPartnerTicket(HttpServletRequest request, @RequestParam(name = "ticketId", defaultValue = "0") int ticketId, Model model) throws ProfitMandiBusinessException {
1455
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1456
        AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1457
        boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1458
 
34913 ranu 1459
        Ticket ticket = ticketRepository.selectById(ticketId);
1460
        List<TicketCategory> ticketCategories = csService.getAllTicketCategotyFromSubCategory();
1461
        TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());
1462
        List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAll(ticketSubCategory.getCategoryId());
1463
        List<AuthUser> authUsers = authRepository.selectAllActiveUser();
35594 amit 1464
 
35617 amit 1465
        // CRM users should not see invisible subcategories
35594 amit 1466
        if (isCrmUser) {
1467
            ticketSubCategories = ticketSubCategories.stream()
35617 amit 1468
                    .filter(TicketSubCategory::isVisibility)
35594 amit 1469
                    .collect(Collectors.toList());
1470
        }
1471
 
1472
        // Get partner name for modal title
1473
        String partnerName = retailerService.getFofoRetailer(ticket.getFofoId()).getBusinessName();
1474
 
34913 ranu 1475
        model.addAttribute("ticket", ticket);
1476
        model.addAttribute("ticketCategories", ticketCategories);
1477
        model.addAttribute("ticketSubCategories", ticketSubCategories);
1478
        model.addAttribute("ticketSubCategory", ticketSubCategory);
1479
        model.addAttribute("authUsers", authUsers);
35594 amit 1480
        model.addAttribute("isCrmUser", isCrmUser);
1481
        model.addAttribute("partnerName", partnerName);
34913 ranu 1482
        return "edit-ticket-partner-modal";
1483
    }
1484
 
31762 tejbeer 1485
    @PostMapping(value = "/cs/edit-ticket")
1486
    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 {
1487
        LOGGER.info("Ticket Id {}, CategoryId {}, SubCategory Id {} authUserId {}", ticketId, categoryId, subCategoryId, authUserId);
35592 amit 1488
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1489
 
1490
        // Only admins can edit tickets
1491
        if (!roleManager.isAdmin(loginDetails.getRoleIds())) {
1492
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Only admins can edit tickets");
1493
        }
1494
 
31762 tejbeer 1495
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 1496
        if (ticket == null) {
1497
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
1498
        }
1499
 
35626 amit 1500
        // Verify admin has access to this ticket
35592 amit 1501
        AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1502
        boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1503
 
35626 amit 1504
        // Get ticket's subcategory to check visibility
1505
        TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());
1506
        int ticketCategoryId = ticketSubCategory.getCategoryId();
1507
        boolean isVisibleSubCategory = ticketSubCategory.isVisibility();
35592 amit 1508
 
35626 amit 1509
        // Check if user has position in ticket's category
1510
        boolean hasPositionInCategory = positionRepository.hasCategory(currentAuthUser.getId(), ticketCategoryId);
1511
 
37145 ranu 1512
        // Check if assigned (assignee or manager at any level in history)
35626 amit 1513
        List<TicketAssigned> assignments = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticketId));
1514
        boolean isAssigned = assignments.stream().anyMatch(ta -> ta.getAssineeId() == currentAuthUser.getId() || ta.getManagerId() == currentAuthUser.getId());
1515
 
1516
        // Permission rules:
1517
        // 1. CRM user AND ticket has visible subcategory, OR
1518
        // 2. Has position in ticket's category (can edit even invisible), OR
37145 ranu 1519
        // 3. Is assigned to ticket at any past level (assignee or manager)
35626 amit 1520
        boolean canEdit = (isCrmUser && isVisibleSubCategory)
1521
                || hasPositionInCategory
37145 ranu 1522
                || isAssigned;
35626 amit 1523
 
1524
        if (!canEdit) {
1525
            throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to edit this ticket");
35592 amit 1526
        }
1527
 
31762 tejbeer 1528
        csService.updateTicket(categoryId, subCategoryId, ticket, authUserId, escalationType);
1529
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1530
        return "response";
1531
 
1532
    }
1533
 
34913 ranu 1534
    @PostMapping(value = "/cs/edit-partner-ticket")
1535
    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 {
1536
        LOGGER.info("Ticket Id {}, CategoryId {}, SubCategory Id {} authUserId {}", ticketId, categoryId, subCategoryId, authUserId);
35592 amit 1537
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1538
 
1539
        // Only admins can edit partner tickets
1540
        if (!roleManager.isAdmin(loginDetails.getRoleIds())) {
1541
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Only admins can edit partner tickets");
1542
        }
1543
 
34913 ranu 1544
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 1545
        if (ticket == null) {
1546
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
1547
        }
1548
 
1549
        // Verify admin has access (must be in Sales, ABM, or RBM position for the partner)
1550
        AuthUser currentAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1551
        Map<String, Set<Integer>> authUserPartnerMap = csService.getAuthUserPartnerIdMapping();
1552
        Set<Integer> allowedPartnerIds = authUserPartnerMap.get(currentAuthUser.getEmailId());
1553
 
1554
        if (allowedPartnerIds == null || !allowedPartnerIds.contains(ticket.getFofoId())) {
1555
            // Also allow CRM users
1556
            boolean isCrmUser = positionRepository.hasCategory(currentAuthUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1557
            if (!isCrmUser) {
1558
                throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to edit this partner's ticket");
1559
            }
1560
        }
1561
 
34913 ranu 1562
        csService.updateTicket(categoryId, subCategoryId, ticket, authUserId, escalationType);
1563
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1564
        return "response";
1565
 
1566
    }
1567
 
31762 tejbeer 1568
    @PostMapping(value = "/cs/changeTicketAssignee")
1569
    public String changeTicketAssignee(HttpServletRequest request, @RequestParam(name = "positionId", defaultValue = "0") int positionId, Model model) throws Exception {
1570
        Position position = positionRepository.selectById(positionId);
1571
        if (position.isTicketAssignee()) {
1572
            position.setTicketAssignee(false);
1573
        } else {
1574
            position.setTicketAssignee(true);
1575
        }
1576
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1577
        return "response";
1578
    }
1579
 
1580
 
1581
    @DeleteMapping(value = "/cs/removePosition")
1582
    public String removePosition(HttpServletRequest request, @RequestParam(name = "positionId", defaultValue = "0") int positionId, Model model) throws Exception {
1583
        positionRepository.delete(positionId);
1584
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1585
        return "response";
1586
    }
1587
 
1588
    @PostMapping(value = "/cs/create-last-activity")
1589
    public String createlastActivity(HttpServletRequest request, @RequestParam(name = "ticketId") int ticketId, @RequestParam(name = "lastactivity") ActivityType lastActivity, Model model) throws Exception {
1590
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1591
        Ticket ticket = ticketRepository.selectById(ticketId);
35592 amit 1592
 
1593
        if (ticket == null) {
1594
            throw new ProfitMandiBusinessException("Ticket", ticketId, "Ticket not found");
1595
        }
1596
 
1597
        // Authorization check for partners: can only update their own tickets
1598
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
1599
        if (!isAdmin && ticket.getFofoId() != loginDetails.getFofoId()) {
1600
            throw new ProfitMandiBusinessException("Ticket", ticketId, "You do not have permission to update this ticket");
1601
        }
1602
 
31762 tejbeer 1603
        Activity activity = new Activity();
1604
        String subject = String.format(ACTIVITY_SUBJECT, ticket.getId());
35592 amit 1605
        if (isAdmin) {
35603 amit 1606
            // CRM team members can resolve any ticket
1607
            // Sales team members can resolve their own Sales category tickets
1608
            // RBM team members can resolve their own RBM category tickets
35592 amit 1609
            AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1610
            boolean isCrmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
35603 amit 1611
            boolean isSalesUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_SALES);
1612
            boolean isRbmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_RBM);
1613
 
1614
            // Check if ticket belongs to Sales or RBM category
1615
            TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());
1616
            boolean isSalesTicket = ticketSubCategory != null && ticketSubCategory.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_SALES;
1617
            boolean isRbmTicket = ticketSubCategory != null && ticketSubCategory.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_RBM;
1618
 
1619
            // Allow if CRM user OR (Sales user AND Sales ticket) OR (RBM user AND RBM ticket)
1620
            if (!isCrmUser && !(isSalesUser && isSalesTicket) && !(isRbmUser && isRbmTicket)) {
1621
                throw new ProfitMandiBusinessException("Ticket", ticketId, "Only CRM, Sales (for Sales tickets), or RBM (for RBM tickets) team can mark tickets as resolved");
35592 amit 1622
            }
31762 tejbeer 1623
            ticket.setLastActivity(lastActivity);
1624
            String to = retailerService.getFofoRetailer(ticket.getFofoId()).getEmail();
1625
            String message = String.format(PARTNER_RESOLVED_TICKET_MAIL, ticketId, "REOPEN");
1626
            activity.setMessage(message);
35592 amit 1627
            activity.setCreatedBy(authUser.getId());
31762 tejbeer 1628
            activity.setTicketId(ticketId);
1629
            activity.setCreateTimestamp(LocalDateTime.now());
1630
            activity.setType(ActivityType.COMMUNICATION_OUT);
1631
            this.activityRelatedMail(to, null, subject, message);
1632
        } else {
1633
            if (ActivityType.RESOLVED_ACCEPTED == lastActivity) {
1634
                ticket.setLastActivity(lastActivity);
1635
                ticket.setCloseTimestamp(LocalDateTime.now());
1636
                activity.setMessage(ActivityType.RESOLVED_ACCEPTED.toString());
1637
                activity.setCreatedBy(0);
1638
                activity.setTicketId(ticketId);
1639
                activity.setType(ActivityType.COMMUNICATION_IN);
1640
                activity.setCreateTimestamp(LocalDateTime.now());
1641
            } else {
1642
                String message = String.format(INTERNAL_REOPEN_MAIL, ticketId, retailerService.getFofoRetailer(loginDetails.getFofoId()).getBusinessName());
37145 ranu 1643
                // Reopen mail goes to the current assignee with the current manager on CC.
1644
                // Previously fanned out to all l1..l5 slots which were pre-populated at creation.
1645
                String to = ticket.getCurrentAssigneeId() > 0
1646
                        ? authRepository.selectById(ticket.getCurrentAssigneeId()).getEmailId()
1647
                        : null;
1648
                String[] ccTo = ticket.getCurrentManagerId() > 0
1649
                        ? new String[]{authRepository.selectById(ticket.getCurrentManagerId()).getEmailId()}
1650
                        : new String[0];
31762 tejbeer 1651
                ticket.setLastActivity(lastActivity);
1652
                ticket.setUpdateTimestamp(LocalDateTime.now());
1653
                ticketAssignedRepository.deleteByTicketId(ticketId);
1654
                TicketAssigned ticketAssigned = new TicketAssigned();
37145 ranu 1655
                ticketAssigned.setAssineeId(ticket.getCurrentAssigneeId());
31762 tejbeer 1656
                ticketAssigned.setTicketId(ticketId);
1657
                ticketAssignedRepository.persist(ticketAssigned);
1658
                activity.setMessage(INTERNAL_REOPEN_ACTIVITY_MESSAGE);
1659
                activity.setCreatedBy(0);
1660
                activity.setTicketId(ticketId);
1661
                activity.setType(ActivityType.COMMUNICATION_IN);
1662
                activity.setCreateTimestamp(LocalDateTime.now());
1663
                this.activityRelatedMail(to, ccTo, subject, message);
1664
                this.activityRelatedMail(retailerService.getFofoRetailer(loginDetails.getFofoId()).getEmail(), null, subject, String.format(PARTNER_REOPEN, ticketId));
1665
            }
1666
 
1667
        }
1668
        activityRepository.persist(activity);
1669
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1670
        return "response";
1671
    }
1672
 
32812 shampa 1673
 
1674
 
1675
 
1676
 
1677
    @PostMapping(value = "/partner-position/update")
1678
    public String positionUpdated(Model model, @RequestBody List<PartnerPositonUpdateModel> partnerPositionUpdateModels)
1679
            throws Exception {
1680
 
32821 shampa 1681
        Map<Integer, List<String>> positionIdsToAddMap = partnerPositionUpdateModels.stream().filter(x->x.getPositionIdTo()!=0).collect(Collectors.groupingBy(x->x.getPositionIdTo(),
32812 shampa 1682
                Collectors.mapping(x->x.getStoreCode(), Collectors.toList())));
1683
 
32821 shampa 1684
        Map<Integer, List<String>> positionIdsToRemoveMap = partnerPositionUpdateModels.stream().filter(x->x.getPositionIdFrom()!=0).collect(Collectors.groupingBy(x->x.getPositionIdFrom(),
32812 shampa 1685
                Collectors.mapping(x->x.getStoreCode(), Collectors.toList())));
1686
 
1687
        List<Integer> positionIdsToUpdate = new ArrayList<>();
1688
        positionIdsToUpdate.addAll(positionIdsToAddMap.keySet());
1689
        positionIdsToUpdate.addAll(positionIdsToRemoveMap.keySet());
1690
 
35395 amit 1691
        Map<Integer, Position> positionsToUpdateMap =  positionRepository.selectByIds(positionIdsToUpdate).stream().collect(Collectors.toMap(x->x.getId(), x->x));
32812 shampa 1692
        List<Integer> invalidPositionIds = positionsToUpdateMap.values().stream().filter(x-> x.getCategoryId()!= ProfitMandiConstants.TICKET_CATEGORY_RBM
34908 ranu 1693
                && x.getCategoryId() != ProfitMandiConstants.TICKET_CATEGORY_SALES && x.getCategoryId() != ProfitMandiConstants.TICKET_CATEGORY_ABM).map(x -> x.getId()).collect(Collectors.toList());
32812 shampa 1694
        if(invalidPositionIds.size() > 0) {
34908 ranu 1695
            String message = "Non RBM/Sales/ABM are not allowed - " + invalidPositionIds;
32812 shampa 1696
            throw new ProfitMandiBusinessException(message, message, message);
1697
        }
1698
 
1699
        for (Map.Entry<Integer, List<String>> positionIdStoreMapEntry : positionIdsToAddMap.entrySet()) {
1700
            int positionId = positionIdStoreMapEntry.getKey();
1701
            Position position = positionsToUpdateMap.get(positionId);
32821 shampa 1702
            LOGGER.info("positionId - {}, Position - {}", positionId, position);
32812 shampa 1703
            List<String> storeCodesToAdd = positionIdStoreMapEntry.getValue();
1704
            List<Integer> retailerIdsToAdd = fofoStoreRepository.selectByStoreCodes(storeCodesToAdd).stream().map(x->x.getId()).collect(Collectors.toList());
1705
            Map<Integer, PartnerPosition> partnerPositionsMapByFofoId  = partnerPositionRepository
32821 shampa 1706
                    .selectByRegionIdAndPostionId(Arrays.asList(position.getRegionId())
1707
                            ,Arrays.asList(positionId)).stream().collect(Collectors.toMap(x->x.getFofoId(),x->x));
32812 shampa 1708
            for (Integer retailerIdToAdd : retailerIdsToAdd) {
1709
                if (!partnerPositionsMapByFofoId.containsKey(retailerIdToAdd)) {
1710
                    PartnerPosition partnerPositionNew = new PartnerPosition();
1711
                    partnerPositionNew.setPositionId(positionId);
1712
                    partnerPositionNew.setFofoId(retailerIdToAdd);
1713
                    partnerPositionNew.setRegionId(position.getRegionId());
32865 amit.gupta 1714
                    partnerPositionRepository.persist(partnerPositionNew);
32812 shampa 1715
                }
1716
            }
1717
        }
1718
 
1719
        for (Map.Entry<Integer, List<String>> positionIdStoreMapEntry : positionIdsToRemoveMap.entrySet()) {
1720
 
1721
            int positionId = positionIdStoreMapEntry.getKey();
1722
            Position position = positionsToUpdateMap.get(positionId);
1723
            List<String> storeCodesToRemove = positionIdStoreMapEntry.getValue();
1724
            List<Integer> retailerIdsToRemove = fofoStoreRepository.selectByStoreCodes(storeCodesToRemove).stream().map(x->x.getId()).collect(Collectors.toList());
1725
            Map<Integer, PartnerPosition> partnerPositionsMapByFofoId  = partnerPositionRepository
1726
                    .selectByRegionIdAndPostionId(Arrays.asList(position.getRegionId()),Arrays.asList(positionId)).stream().collect(Collectors.toMap(x->x.getFofoId(),x->x));
1727
            for (Integer retailerIdToRemove : retailerIdsToRemove) {
1728
                if (partnerPositionsMapByFofoId.containsKey(retailerIdToRemove)) {
1729
                   PartnerPosition partnerPositionToRemove =  partnerPositionsMapByFofoId.get(retailerIdToRemove);
1730
                   partnerPositionRepository.delete(partnerPositionToRemove);
1731
                }
1732
            }
1733
        }
1734
 
1735
 
1736
 
1737
        /*partnerPositionUpdateModels.str
1738
 
1739
        Map<Integer, Position> positionIdMap = positionsToUpdate.stream().collect(Collectors.toMap(x->x.getId(), x->x));
1740
        for (PartnerPositonUpdateModel partnerPositionUpdateModel : partnerPositionUpdateModels) {
1741
            FofoStore fofoStore = fofoStoreRepository.selectByStoreCode(partnerPositionUpdateModel.getStoreCode());
1742
            Position positionFrom = positionIdMap.get(partnerPositionUpdateModel.getPositionIdFrom());
1743
            Position positionTo = positionIdMap.get(partnerPositionUpdateModel.getPositionIdTo());
1744
            if(positionFrom != null) {
1745
                partnerPositionRepository.selectByRegionIdAndPostionId(Arrays.)
1746
              int regionId = positionFrom.getRegionId()
1747
            }
1748
            if(positionTo != null) {
1749
 
1750
            }
1751
        }*/
1752
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1753
        return "response";
1754
 
1755
    }
1756
 
35626 amit 1757
    @PostMapping(value = "/cs/markTicketRead")
1758
    @ResponseBody
1759
    public Map<String, Object> markTicketRead(HttpServletRequest request,
1760
                                              @RequestParam(name = "ticketId") int ticketId,
1761
                                              Model model) throws ProfitMandiBusinessException {
1762
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1763
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
1764
        Map<String, Object> response = new HashMap<>();
32812 shampa 1765
 
35626 amit 1766
        if (isAdmin) {
1767
            AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1768
            csService.markTicketAsRead(ticketId, authUser.getId(), UserType.AUTH_USER);
1769
        } else {
1770
            csService.markTicketAsRead(ticketId, loginDetails.getFofoId(), UserType.PARTNER);
1771
        }
1772
 
1773
        response.put("success", true);
1774
        return response;
1775
    }
1776
 
1777
    @GetMapping(value = "/cs/unreadCount")
1778
    @ResponseBody
1779
    public Map<String, Object> getUnreadCount(HttpServletRequest request) throws ProfitMandiBusinessException {
1780
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1781
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
1782
        Map<String, Object> response = new HashMap<>();
1783
 
1784
        List<Ticket> tickets;
1785
        int userId;
1786
        UserType userType;
1787
 
1788
        if (isAdmin) {
1789
            AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1790
            userId = authUser.getId();
1791
            userType = UserType.AUTH_USER;
1792
            boolean isCrmUser = positionRepository.hasCategory(authUser.getId(), ProfitMandiConstants.TICKET_CATEGORY_CRM);
1793
            List<Integer> userCategoryIds = positionRepository.selectCategoryIdsByAuthUserId(authUser.getId());
1794
            if (isCrmUser) {
1795
                tickets = ticketRepository.selectAllTicketsPaginated(
1796
                        Optional.of(false), null, null, 0, null,
1797
                        userCategoryIds, 0, 1000);
1798
            } else {
1799
                tickets = ticketRepository.selectAllByAssigneePaginated(
1800
                        authUser.getId(), Optional.of(false), null, null, 0, null,
1801
                        0, 1000);
1802
            }
1803
        } else {
1804
            userId = loginDetails.getFofoId();
1805
            userType = UserType.PARTNER;
1806
            tickets = ticketRepository.selectAllByCreator(loginDetails.getFofoId(), Optional.of(true), null);
1807
        }
1808
 
1809
        Map<Integer, Boolean> unreadMap = csService.getUnreadStatusForTickets(tickets, userId, userType);
1810
        long unreadCount = unreadMap.values().stream().filter(v -> v).count();
1811
 
1812
        response.put("success", true);
1813
        response.put("unreadCount", unreadCount);
1814
        return response;
1815
    }
1816
 
24417 govind 1817
}