From b7f4aff07d179ce758852fd6ac79430ff589afc7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9B=B9=E9=B9=8F=E9=A3=9E?= Date: Fri, 21 Feb 2025 08:29:29 +0800 Subject: [PATCH 1/3] =?UTF-8?q?feat:=20=E4=B8=80=E4=BA=9B=E8=B0=83?= =?UTF-8?q?=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../nflg/mobilebroken/cfs/controller/UserController.java | 3 ++- .../service/impl/AppUserApplyforServiceImpl.java | 8 ++++++-- 2 files changed, 8 insertions(+), 3 deletions(-) diff --git a/nflg-mobilebroken-cfs-app/src/main/java/com/nflg/mobilebroken/cfs/controller/UserController.java b/nflg-mobilebroken-cfs-app/src/main/java/com/nflg/mobilebroken/cfs/controller/UserController.java index f47bde22..a689793f 100644 --- a/nflg-mobilebroken-cfs-app/src/main/java/com/nflg/mobilebroken/cfs/controller/UserController.java +++ b/nflg-mobilebroken-cfs-app/src/main/java/com/nflg/mobilebroken/cfs/controller/UserController.java @@ -203,11 +203,12 @@ public class UserController extends ControllerBase { public ApiResult changeUserEnable(@Valid @RequestBody EnableRequest request){ if (request.getEnable()){ AppUserApplyfor applyfor=appUserApplyforService.addEnable(request); + AppUser user=appUserService.getById(request.getId()); List adminUsers=adminUserService.getForAccountReview(); if (CollectionUtil.isNotEmpty(adminUsers)){ adminUsers.forEach(c -> adminMessageService.add( new AdminMessage() - .setNo(applyfor.getUserEmail()) + .setNo(user.getEmail()) .setUserId(c.getId()) .setSourceId(applyfor.getId()) .setSource(1) diff --git a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/impl/AppUserApplyforServiceImpl.java b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/impl/AppUserApplyforServiceImpl.java index db1c019f..b17fdb49 100644 --- a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/impl/AppUserApplyforServiceImpl.java +++ b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/impl/AppUserApplyforServiceImpl.java @@ -127,8 +127,12 @@ public class AppUserApplyforServiceImpl extends ServiceImpl customers =customerService.listByIds(Arrays.stream(appUser.getCompanyId().split(",")).map(Integer::parseInt).collect(Collectors.toList())); applyforInfo .setCompanyName(StrUtil.join(",",customers.stream().map(TBaseCustomer::getAgencyCompanyName).collect(Collectors.toList()))) From 507b2e085d70890d5725cab245b86e99c71b1716 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9B=B9=E9=B9=8F=E9=A3=9E?= Date: Fri, 21 Feb 2025 16:14:14 +0800 Subject: [PATCH 2/3] =?UTF-8?q?feat:=20=E4=B8=80=E4=BA=9B=E8=B0=83?= =?UTF-8?q?=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../admin/controller/TicketController.java | 7 +++++-- .../cfs/controller/TiketController.java | 4 +++- .../common/pojo/dto/ChatMessageDTO.java | 2 +- .../mobilebroken/common/pojo/dto/UserDTO.java | 3 +++ .../pojo/request/AddChatMessageRequest.java | 2 +- .../pojo/request/AreaSearchRequest.java | 5 +++++ .../common/pojo/vo/ChatMessageVO.java | 2 +- .../mobilebroken/common/util/AppUserUtil.java | 6 ++++++ .../repository/entity/AppArea.java | 10 +++++++-- .../repository/service/TicketChatService.java | 10 +++++++-- .../service/impl/AppAreaServiceImpl.java | 21 ++++++++++++++++--- .../starter/config/AliyunOSSConfig.java | 9 +++++--- 12 files changed, 65 insertions(+), 16 deletions(-) diff --git a/nflg-mobilebroken-admin/src/main/java/com/nflg/mobilebroken/admin/controller/TicketController.java b/nflg-mobilebroken-admin/src/main/java/com/nflg/mobilebroken/admin/controller/TicketController.java index 1f44715e..b7a8275c 100644 --- a/nflg-mobilebroken-admin/src/main/java/com/nflg/mobilebroken/admin/controller/TicketController.java +++ b/nflg-mobilebroken-admin/src/main/java/com/nflg/mobilebroken/admin/controller/TicketController.java @@ -455,13 +455,16 @@ public class TicketController extends ControllerBase { public ApiResult addChatMessage(@Valid @RequestBody AddChatMessageRequest request) { Ticket ticket = ticketService.getById(request.getTicketId()); VUtils.trueThrowBusinessError(Objects.isNull(ticket)).throwMessage("工单不存在"); - VUtils.trueThrowBusinessError(Byte.compare(ticket.getState(), TicketState.Processing.getState()) > 1) + VUtils.trueThrowBusinessError(!Objects.equals(ticket.getState(), TicketState.Processing.getState())) .throwMessage("当前工单状态不允许发送消息"); + VUtils.trueThrowBusinessError(Arrays.stream(ticket.getHandle().split(",")) + .noneMatch(uid -> StrUtil.equals(uid, AdminUserUtil.getUserId().toString()))) + .throwMessage("只有工单处理人能发送消息"); ticket.setCurrentHandle(AdminUserUtil.getUserId()); ticketService.updateById(ticket); AdminUser user = adminUserService.getById(AdminUserUtil.getUserId()); ChatMessageDTO message = new ChatMessageDTO() - .setId(cn.hutool.core.util.IdUtil.getSnowflakeNextId()) + .setId(cn.hutool.core.util.IdUtil.getSnowflakeNextIdStr()) .setFrom("admin") .setTicketState(ticket.getState()) .setSenderId(user.getId()) diff --git a/nflg-mobilebroken-cfs-app/src/main/java/com/nflg/mobilebroken/cfs/controller/TiketController.java b/nflg-mobilebroken-cfs-app/src/main/java/com/nflg/mobilebroken/cfs/controller/TiketController.java index e195b62d..13363390 100644 --- a/nflg-mobilebroken-cfs-app/src/main/java/com/nflg/mobilebroken/cfs/controller/TiketController.java +++ b/nflg-mobilebroken-cfs-app/src/main/java/com/nflg/mobilebroken/cfs/controller/TiketController.java @@ -290,9 +290,11 @@ public class TiketController extends ControllerBase { VUtils.trueThrowBusinessError(Objects.isNull(ticket)).throwMessage("工单不存在"); VUtils.trueThrowBusinessError(Byte.compare(ticket.getState(), TicketState.Processing.getState()) > 1) .throwMessage("当前工单状态不允许发送消息"); + VUtils.trueThrowBusinessError(!Objects.equals(ticket.getUserId(),AppUserUtil.getUserId())) + .throwMessage("工单创建人才能发送消息"); AppUser user = appUserService.getById(AppUserUtil.getUserId()); ChatMessageDTO message = new ChatMessageDTO() - .setId(IdUtil.getSnowflakeNextId()) + .setId(IdUtil.getSnowflakeNextIdStr()) .setFrom("app") .setTicketState(ticket.getState()) .setSenderId(user.getId()) diff --git a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/dto/ChatMessageDTO.java b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/dto/ChatMessageDTO.java index 4edb698c..f807f038 100644 --- a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/dto/ChatMessageDTO.java +++ b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/dto/ChatMessageDTO.java @@ -11,7 +11,7 @@ import java.util.List; @Accessors(chain = true) public class ChatMessageDTO { - private Long id; + private String id; //来源 private String from; diff --git a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/dto/UserDTO.java b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/dto/UserDTO.java index 7479b419..889ff982 100644 --- a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/dto/UserDTO.java +++ b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/dto/UserDTO.java @@ -21,6 +21,9 @@ public class UserDTO { //用户邮箱 private String email; + //是否是主账号 + private Boolean isPrimary; + //公司id private List companyIds; } diff --git a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/request/AddChatMessageRequest.java b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/request/AddChatMessageRequest.java index f9e1d85a..7995261a 100644 --- a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/request/AddChatMessageRequest.java +++ b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/request/AddChatMessageRequest.java @@ -22,5 +22,5 @@ public class AddChatMessageRequest { private List images; // 引用的消息 - private Long quoteId; + private String quoteId; } diff --git a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/request/AreaSearchRequest.java b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/request/AreaSearchRequest.java index 11d911a8..5eddd521 100644 --- a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/request/AreaSearchRequest.java +++ b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/request/AreaSearchRequest.java @@ -1,5 +1,6 @@ package com.nflg.mobilebroken.common.pojo.request; +import com.fasterxml.jackson.annotation.JsonIgnore; import lombok.Data; import lombok.EqualsAndHashCode; @@ -12,4 +13,8 @@ public class AreaSearchRequest extends PageRequest { //是否启用 private Boolean enabled; + + //区域创建人id + @JsonIgnore + private Integer createBy; } diff --git a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/vo/ChatMessageVO.java b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/vo/ChatMessageVO.java index 774ed263..dceddfc1 100644 --- a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/vo/ChatMessageVO.java +++ b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/vo/ChatMessageVO.java @@ -9,7 +9,7 @@ import java.util.List; @Accessors(chain = true) public class ChatMessageVO { - private Long id; + private String id; //来源 private String from; diff --git a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/util/AppUserUtil.java b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/util/AppUserUtil.java index 1d64afa8..fda34b9f 100644 --- a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/util/AppUserUtil.java +++ b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/util/AppUserUtil.java @@ -27,12 +27,18 @@ public class AppUserUtil { return (List) SaTokenAppUtil.getExtra("companyIds"); } + public static Boolean isPrimary() { + VUtils.trueThrow(!SaTokenAppUtil.isLogin()).throwMessage(STATE.LoginError,"请重新登录"); + return (Boolean) SaTokenAppUtil.getExtra("isPrimary"); + } + public static UserDTO getUser() { UserDTO user = new UserDTO(); user.setId(getUserId()); user.setName(getUserName()); user.setEmail(getEmail()); user.setCompanyIds(getCompanyIds()); + user.setIsPrimary(isPrimary()); return user; } } diff --git a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/entity/AppArea.java b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/entity/AppArea.java index 746d628a..0b211363 100644 --- a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/entity/AppArea.java +++ b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/entity/AppArea.java @@ -3,12 +3,13 @@ package com.nflg.mobilebroken.repository.entity; import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; -import java.io.Serializable; -import java.time.LocalDateTime; import lombok.Getter; import lombok.Setter; import lombok.experimental.Accessors; +import java.io.Serializable; +import java.time.LocalDateTime; + /** *

* 用户端-区域 @@ -48,6 +49,11 @@ public class AppArea implements Serializable { */ private String createBy; + /** + * 创建人id + */ + private Integer createById; + /** * 创建时间 */ diff --git a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/TicketChatService.java b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/TicketChatService.java index 223c60ea..10cec6ff 100644 --- a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/TicketChatService.java +++ b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/TicketChatService.java @@ -1,6 +1,7 @@ package com.nflg.mobilebroken.repository.service; import cn.hutool.core.date.DatePattern; +import cn.hutool.core.util.StrUtil; import com.nflg.mobilebroken.common.pojo.dto.ChatMessageDTO; import com.nflg.mobilebroken.common.pojo.dto.TicketChatDTO; import com.nflg.mobilebroken.common.pojo.vo.ChatMessageVO; @@ -69,13 +70,18 @@ public class TicketChatService { public void addMessage(Integer ticketId, ChatMessageDTO newMessage) { // 创建查询条件，查找 ticketId = ticketId 的 TicketChat Query query = new Query(Criteria.where("ticketId").is(ticketId)); + TicketChatDTO dto=mongoTemplate.findOne(query, TicketChatDTO.class); + if (Objects.isNull(dto)){ + dto=new TicketChatDTO().setTicketId(ticketId); + mongoTemplate.save(dto); + } // 创建更新操作，向 messages 列表中添加新消息 Update update = new Update().push("messages", newMessage); // 执行更新操作 mongoTemplate.findAndModify(query, update, TicketChatDTO.class); } - public ChatMessageDTO getMessage(Integer ticketId, Long messageId) { + public ChatMessageDTO getMessage(Integer ticketId, String messageId) { // 构建查询条件 Query query = new Query(); query.addCriteria(Criteria.where("ticketId").is(ticketId)); @@ -86,7 +92,7 @@ public class TicketChatService { // 从 TicketChatDTO 中提取 ChatMessageDTO if (ticketChat != null) { for (ChatMessageDTO message : ticketChat.getMessages()) { - if (messageId.equals(message.getId())) { + if (StrUtil.equals(messageId,message.getId())) { return message; } } diff --git a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/impl/AppAreaServiceImpl.java b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/impl/AppAreaServiceImpl.java index d1b78583..6050c16b 100644 --- a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/impl/AppAreaServiceImpl.java +++ b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/impl/AppAreaServiceImpl.java @@ -14,9 +14,11 @@ import com.nflg.mobilebroken.common.util.AppUserUtil; import com.nflg.mobilebroken.repository.entity.AppArea; import com.nflg.mobilebroken.repository.mapper.AppAreaMapper; import com.nflg.mobilebroken.repository.service.IAppAreaService; +import com.nflg.mobilebroken.repository.service.IAppUserService; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import javax.annotation.Resource; import java.time.LocalDateTime; import java.util.ArrayList; import java.util.Iterator; @@ -35,10 +37,14 @@ import java.util.stream.Collectors; @Service public class AppAreaServiceImpl extends ServiceImpl implements IAppAreaService { + @Resource + private IAppUserService appUserService; + @Override public boolean saveOrUpdate(AppArea entity) { if (Objects.isNull(entity.getId()) || entity.getId()<=0){ entity.setCreateBy(AppUserUtil.getUserName()); + entity.setCreateById(AppUserUtil.getUserId()); entity.setCreateTime(LocalDateTime.now()); return save(entity); }else { @@ -50,12 +56,18 @@ public class AppAreaServiceImpl extends ServiceImpl impl @Override public IPage search(AreaSearchRequest request) { + if (AppUserUtil.isPrimary()){ + request.setCreateBy(AppUserUtil.getUserId()); + }else { + request.setCreateBy(appUserService.getPrimaryByCompanyId(String.valueOf(AppUserUtil.getCompanyIds().get(0))).getId()); + } if (StrUtil.isBlank(request.getName()) && Objects.isNull(request.getEnabled())) { return getPage(request); }else { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.like(StrUtil.isNotBlank(request.getName()),AppArea::getName, request.getName()); + queryWrapper.eq(AppArea::getCreateById, request.getCreateBy()); queryWrapper.eq(Objects.nonNull(request.getEnabled()),AppArea::getEnable, request.getEnabled()); + queryWrapper.like(StrUtil.isNotBlank(request.getName()),AppArea::getName, request.getName()); queryWrapper.orderByDesc(AppArea::getId); List list = baseMapper.selectList(queryWrapper); //找出非根节点 @@ -175,7 +187,9 @@ public class AppAreaServiceImpl extends ServiceImpl impl IPage page = new Page<>(); page.setCurrent(request.getPage()); page.setSize(request.getPageSize()); - lambdaQuery().eq(AppArea::getParentId, 0) + lambdaQuery() + .eq(AppArea::getParentId, 0) + .eq(AppArea::getCreateById,request.getCreateBy()) .eq(Objects.nonNull(request.getEnabled()), AppArea::getEnable, request.getEnabled()) .orderByAsc(AppArea::getId) .page(page); @@ -190,7 +204,8 @@ public class AppAreaServiceImpl extends ServiceImpl impl } private List getChildren(Integer parentId, Boolean enable) { - List datas=convert(lambdaQuery().eq(AppArea::getParentId,parentId) + List datas=convert(lambdaQuery() + .eq(AppArea::getParentId,parentId) .eq(Objects.nonNull(enable), AppArea::getEnable, enable) .orderByAsc(AppArea::getId) .list()); diff --git a/nflg-mobilebroken-starter/src/main/java/com/nflg/mobilebroken/starter/config/AliyunOSSConfig.java b/nflg-mobilebroken-starter/src/main/java/com/nflg/mobilebroken/starter/config/AliyunOSSConfig.java index 20f3f5e8..96a61abc 100644 --- a/nflg-mobilebroken-starter/src/main/java/com/nflg/mobilebroken/starter/config/AliyunOSSConfig.java +++ b/nflg-mobilebroken-starter/src/main/java/com/nflg/mobilebroken/starter/config/AliyunOSSConfig.java @@ -1,6 +1,6 @@ package com.nflg.mobilebroken.starter.config; -import com.aliyun.oss.ClientBuilderConfiguration; +import com.aliyun.oss.ClientConfiguration; import com.aliyun.oss.OSS; import com.aliyun.oss.OSSClientBuilder; import com.aliyun.oss.common.auth.DefaultCredentialProvider; @@ -30,13 +30,16 @@ public class AliyunOSSConfig { //@Resource //private OSS ossClient; - @Bean + @Bean(destroyMethod = "shutdown") public OSS ossClient() { log.info("初始化阿里云OSS服务"); + ClientConfiguration config = new ClientConfiguration(); + config.setConnectionTimeout(10000); // 设置连接超时为 10 秒 + config.setSocketTimeout(600000); // 设置读取超时为 10 分钟 return OSSClientBuilder.create() .endpoint(endpoint) .credentialsProvider(new DefaultCredentialProvider(accessKeyId, accessKeySecret)) - .clientConfiguration(new ClientBuilderConfiguration()) + .clientConfiguration(config) .region(region) .build(); } From da7331309d6fb2b1aadb31579fabfb955cc8fe37 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9B=B9=E9=B9=8F=E9=A3=9E?= Date: Fri, 21 Feb 2025 20:26:20 +0800 Subject: [PATCH 3/3] =?UTF-8?q?feat:=20=E4=B8=80=E4=BA=9B=E8=B0=83?= =?UTF-8?q?=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../admin/task/TicketScheduledTasks.java | 70 ++++++++++++++++++- .../common/constant/Constant.java | 4 ++ .../request/TicketEvaluateAddRequest.java | 5 ++ .../repository/entity/TicketEvaluate.java | 5 ++ .../repository/service/ITicketService.java | 2 + .../impl/TicketEvaluateServiceImpl.java | 1 + .../service/impl/TicketServiceImpl.java | 24 +++++-- 7 files changed, 103 insertions(+), 8 deletions(-) diff --git a/nflg-mobilebroken-admin/src/main/java/com/nflg/mobilebroken/admin/task/TicketScheduledTasks.java b/nflg-mobilebroken-admin/src/main/java/com/nflg/mobilebroken/admin/task/TicketScheduledTasks.java index 4f39d011..29798abf 100644 --- a/nflg-mobilebroken-admin/src/main/java/com/nflg/mobilebroken/admin/task/TicketScheduledTasks.java +++ b/nflg-mobilebroken-admin/src/main/java/com/nflg/mobilebroken/admin/task/TicketScheduledTasks.java @@ -7,6 +7,10 @@ import cn.hutool.json.JSONUtil; import com.nflg.mobilebroken.admin.pojo.dto.TiketTimeoutDTO; import com.nflg.mobilebroken.common.constant.Constant; import com.nflg.mobilebroken.common.constant.MessageSubType; +import com.nflg.mobilebroken.common.constant.UserState; +import com.nflg.mobilebroken.common.pojo.request.TicketEvaluateAddRequest; +import com.nflg.mobilebroken.common.pojo.vo.TicketEvaluateAddVO; +import com.nflg.mobilebroken.common.pojo.vo.TicketEvaluateItemVO; import com.nflg.mobilebroken.repository.entity.*; import com.nflg.mobilebroken.repository.service.*; import com.nflg.mobilebroken.starter.service.EmailService; @@ -16,12 +20,14 @@ import org.springframework.stereotype.Component; import javax.annotation.Resource; import javax.mail.MessagingException; +import java.math.BigDecimal; import java.time.LocalDateTime; import java.time.ZoneId; import java.time.ZoneOffset; import java.time.format.DateTimeFormatter; import java.util.Arrays; import java.util.List; +import java.util.Objects; import java.util.stream.Collectors; @Component @@ -48,15 +54,73 @@ public class TicketScheduledTasks { @Resource private IDictionaryItemTranslateService dictionaryItemTranslateService; - @Resource - private ITBaseDeviceTypeService deviceTypeService; - @Resource private EmailService emailService; @Resource private IParamConfigService paramConfigService; + @Resource + private ITicketEvaluateService ticketEvaluateService; + + /** + * 工单评论邀请邮件 + * 每天午夜12点执行一次 + */ + @Scheduled(cron = "0 0 0 * * ?") + public void sendInviteCommentEmail() { + List tickets=ticketService.getNonComment(7); + tickets.forEach(ticket -> { + AdminUser createUser = adminUserService.getById(ticket.getUserId()); + if (Objects.equals(createUser.getState(), UserState.Activated.getState())) { + List adminUserIds = Arrays.stream(ticket.getHandle().split(",")) + .map(Integer::parseInt) + .collect(Collectors.toList()); + List adminUsers = adminUserService.listByIds(adminUserIds); + String subject = dictionaryItemTranslateService.getValueByCode(Constant.DICTIONARY_EMAIL_NOTIFY, Constant.DICTIONARY_ITEM_EMAIL_TITLE_TICKET_INVITE_COMMENT, Constant.DEFAULT_LANGUAGE_CODE); + String content = dictionaryItemTranslateService.getValueByCode(Constant.DICTIONARY_EMAIL_NOTIFY, Constant.DICTIONARY_ITEM_EMAIL_CONTENT_TICKET_INVITE_COMMENT, Constant.DEFAULT_LANGUAGE_CODE) + .replace("${no}", ticket.getNo()) + .replace("${title}", ticket.getTitle()) + .replace("${createUser}", createUser.getUserName()) + .replace("${handleUser}", StrUtil.join(",", adminUsers.stream().map(AdminUser::getUserName).collect(Collectors.toList()))) + .replace("${createTime}", toTimeString(ticket.getCreateTime())) + .replace("${msg}", subject); + try { + sendEamilForAdminUser(adminUsers, subject, content); + } catch (Exception e) { + log.error("邮件发送失败", e); + } + } + }); + } + + /** + * 工单自动评论 + * 每天午夜12点执行一次 + */ + @Scheduled(cron = "0 0 0 * * ?") + public void autoComment() { + List tickets=ticketService.getNonComment(10); + TicketEvaluateAddVO vo=dictionaryItemTranslateService.getTicketEvaluateSelect(Constant.DEFAULT_LANGUAGE_CODE); + TicketEvaluateAddRequest request = new TicketEvaluateAddRequest(); + request.setType(1); + request.setScore(new BigDecimal("5")); + TicketEvaluateItemVO se=vo.getServiceEvaluation().stream() + .filter(it->StrUtil.equals(it.getCode(), Constant.DICTIONARY_TYPE_SERVICE_EVALUATION+"Satisfied")) + .findFirst().get(); + request.setServiceEvaluationId(se.getId()); + request.setServiceEvaluationSelectIds(se.getChildren().stream().map(TicketEvaluateItemVO::getId).collect(Collectors.toList())); + TicketEvaluateItemVO pe=vo.getServiceEvaluation().stream() + .filter(it->StrUtil.equals(it.getCode(), Constant.DICTIONARY_TYPE_SERVICE_EVALUATION+"Satisfied")) + .findFirst().get(); + request.setProductEvaluationId(pe.getId()); + request.setProductEvaluationSelectIds(pe.getChildren().stream().map(TicketEvaluateItemVO::getId).collect(Collectors.toList())); + tickets.forEach(ticket -> { + request.setTicketId(ticket.getId()); + ticketEvaluateService.add(request); + }); + } + /** * 工单超时提醒 * 每天午夜12点执行一次 diff --git a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/constant/Constant.java b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/constant/Constant.java index ea28eb16..42980645 100644 --- a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/constant/Constant.java +++ b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/constant/Constant.java @@ -36,8 +36,12 @@ public class Constant { public static final String DICTIONARY_ITEM_EMAIL_TITLE_TICKET_TIMEOUT="TitleTicketTimeout"; + public static final String DICTIONARY_ITEM_EMAIL_TITLE_TICKET_INVITE_COMMENT="TitleInviteComment"; + public static final String DICTIONARY_ITEM_EMAIL_CONTENT_TICKET_NOTIFY="TicketNotify"; + public static final String DICTIONARY_ITEM_EMAIL_CONTENT_TICKET_INVITE_COMMENT="InviteComment"; + public static final String DICTIONARY_ITEM_EMAIL_TITLE_ACCOUNT_RESET_PASSWORD="TitleResetPassword"; public static final String DICTIONARY_ITEM_EMAIL_TITLE_ACCOUNT_ACTIVATION="TitleAccountActivation"; diff --git a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/request/TicketEvaluateAddRequest.java b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/request/TicketEvaluateAddRequest.java index 0e2aaad7..012d3626 100644 --- a/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/request/TicketEvaluateAddRequest.java +++ b/nflg-mobilebroken-common/src/main/java/com/nflg/mobilebroken/common/pojo/request/TicketEvaluateAddRequest.java @@ -1,5 +1,6 @@ package com.nflg.mobilebroken.common.pojo.request; +import com.fasterxml.jackson.annotation.JsonIgnore; import lombok.Data; import javax.validation.constraints.NotNull; @@ -32,4 +33,8 @@ public class TicketEvaluateAddRequest { //反馈 private String feedback; + + //来源，0：用户，1：系统 + @JsonIgnore + private Integer type=0; } diff --git a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/entity/TicketEvaluate.java b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/entity/TicketEvaluate.java index b112b670..5c511a7d 100644 --- a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/entity/TicketEvaluate.java +++ b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/entity/TicketEvaluate.java @@ -35,6 +35,11 @@ public class TicketEvaluate implements Serializable { */ private Integer ticketId; + /** + * 来源，0：用户，1：系统 + */ + private Integer type; + /** * 售后服务评价 */ diff --git a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/ITicketService.java b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/ITicketService.java index 58b6b108..cae4012b 100644 --- a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/ITicketService.java +++ b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/ITicketService.java @@ -45,4 +45,6 @@ public interface ITicketService extends IService { Ticket reopen(Integer id); Ticket addTicketHandle(TicketHandleAddRequest request); + + List getNonComment(int days); } diff --git a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/impl/TicketEvaluateServiceImpl.java b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/impl/TicketEvaluateServiceImpl.java index 55fe9737..d3404dd2 100644 --- a/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/impl/TicketEvaluateServiceImpl.java +++ b/nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/impl/TicketEvaluateServiceImpl.java @@ -38,6 +38,7 @@ public class TicketEvaluateServiceImpl extends ServiceImpl impleme Ticket ticket = getById(request.getTicketId()); VUtils.trueThrowBusinessError(Objects.isNull(ticket)).throwMessage("未找到工单"); VUtils.trueThrowBusinessError(!Objects.equals(ticket.getState(), TicketState.PendingProcessing.getState())).throwMessage("工单状态异常"); -// VUtils.trueThrowBusinessError(Objects.nonNull(ticket.getCqm()) && !Objects.equals(ticket.getCqm(), AdminUserUtil.getUserId())) -// .throwMessage("当前工单已归属别的CQM负责人"); + VUtils.trueThrowBusinessError(adminUserService.getCQM().stream() + .noneMatch(u -> Objects.equals(u.getId(), AdminUserUtil.getUserId()))) + .throwMessage("你不是CQM，无权关闭工单"); ticket.setUrgency(TicketUrgency.findByValue(request.getUrgency()).getState()); ticket.setQuestion(request.getQuestion()); ticket.setState(TicketState.Processing.getState()); @@ -168,7 +169,6 @@ public class TicketServiceImpl extends ServiceImpl impleme .noneMatch(uid->StrUtil.equals(uid, AdminUserUtil.getUserId().toString()))) .throwMessage("你无权操作该工单"); ticket.setState(TicketState.ProcessingCompleted.getState()); - ticket.setSolveTime(LocalDateTime.now()); ticket.setCurrentHandle(AdminUserUtil.getUserId()); ticket.setUpdateTime(LocalDateTime.now()); updateById(ticket); @@ -181,8 +181,13 @@ public class TicketServiceImpl extends ServiceImpl impleme VUtils.trueThrowBusinessError(Objects.isNull(ticket)).throwMessage("未找到工单"); VUtils.trueThrowBusinessError(!Objects.equals(ticket.getState(), TicketState.ProcessingCompleted.getState())) .throwMessage("工单状态不允许关闭"); -// VUtils.trueThrowBusinessError(!Objects.equals(ticket.getCqm(), AdminUserUtil.getUserId())) -// .throwMessage("当前工单未归属当前CQM负责人"); + VUtils.trueThrowBusinessError(!ticketEvaluateService.lambdaQuery() + .eq(TicketEvaluate::getTicketId, request.getTicketId()) + .exists()) + .throwMessage("工单尚未评价，不能关闭"); + VUtils.trueThrowBusinessError(adminUserService.getCQM().stream() + .noneMatch(u -> Objects.equals(u.getId(), AdminUserUtil.getUserId()))) + .throwMessage("你不是CQM，无权关闭工单"); ticket.setState(TicketState.Closed.getState()); ticket.setSolution(request.getSolution()); ticket.setSolutionAttachments(StrUtil.join(",", request.getAttachments())); @@ -273,4 +278,13 @@ public class TicketServiceImpl extends ServiceImpl impleme updateById(ticket); return ticket; } + + @Override + public List getNonComment(int days) { + return lambdaQuery() + .eq(Ticket::getState, TicketState.ProcessingCompleted.getState()) + .ge(Ticket::getUpdateTime, LocalDateTime.now().minusDays(days)) + .lt(Ticket::getUpdateTime, LocalDateTime.now().minusDays(days-1)) + .list(); + } }