Compare commits

..

11 Commits

Author SHA1 Message Date
曹鹏飞 7d417a33d5 Merge branch 'feature/bug-528' into test
# Conflicts:
#	nflg-mobilebroken-admin/src/main/java/com/nflg/mobilebroken/admin/controller/TicketController.java
2025-08-07 10:59:37 +08:00
曹鹏飞 7c1281a689 feat: bug-528 app端添加管理功能
调整视频通话逻辑
2025-08-07 10:56:54 +08:00
曹鹏飞 e0c62ae8f2 feat: bug-528 app端添加管理功能
调整视频通话逻辑
2025-08-06 19:21:08 +08:00
曹鹏飞 a81d362c96 feat: bug-528 app端添加管理功能
管理端工单详情接口返回数据添加创建人来源字段
2025-08-06 13:58:15 +08:00
曹鹏飞 90d6a3c78f feat: bug-528 app端添加管理功能
修复管理端用户登录无法搜索到自己创建的订单的问题
2025-08-06 09:56:40 +08:00
曹鹏飞 8660fcd715 feat: bug-528 app端添加管理功能
1、根据菜单url查询菜单下的所有按钮列表
2、查询所有收藏夹信息,树形结构
2025-08-05 09:52:31 +08:00
曹鹏飞 5b9b277251 feat: bug-528 app端添加管理功能 2025-07-30 14:10:02 +08:00
曹鹏飞 9e911460b0 feat: bug-528 app端添加管理功能 2025-07-30 12:13:12 +08:00
曹鹏飞 ad50d8cc15 feat: bug-528 app端添加管理功能 2025-07-30 11:54:47 +08:00
曹鹏飞 5b74e604ab feat: bug-528 app端添加管理功能 2025-07-29 11:05:24 +08:00
曹鹏飞 63e1581a5e feat: bug-528 app端添加管理功能 2025-07-29 10:01:47 +08:00
23 changed files with 248 additions and 106 deletions

View File

@ -17,6 +17,7 @@ import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.validation.Valid;
import javax.validation.constraints.NotBlank;
import java.util.List;
import java.util.Objects;
@ -175,6 +176,16 @@ public class MenuController extends ControllerBase {
return ApiResult.success();
}
/**
* 根据菜单url获取菜单按钮列表
* @param url 请求url
* @return 菜单按钮列表
*/
@GetMapping("getMenuButtonList")
public ApiResult<List<AdminMenuButtonVO>> getMenuButtonList(@Valid @RequestParam @NotBlank String url) {
return ApiResult.success(adminMenuButtonService.getMenuButtonList(url));
}
/**
* 获取所有接口
* @return 接口列表

View File

@ -157,6 +157,16 @@ public class TicketController extends ControllerBase {
return ApiResult.success(ticketFavoritesService.getList(AdminUserUtil.getUserId(),Constant.FROM_ADMIN,id));
}
/**
* 获取收藏夹树结构
* @param id 父级id0为根节点
* @return 树结构
*/
@GetMapping("getFavoritesTree")
public ApiResult<FavoritesVO> getFavoritesTree(@RequestParam(defaultValue ="0") Integer id){
return ApiResult.success(ticketFavoritesService.getTree(AdminUserUtil.getUserId(),Constant.FROM_ADMIN,id));
}
/**
* 添加收藏夹
* @param request 请求信息
@ -629,6 +639,7 @@ public class TicketController extends ControllerBase {
.setAccidentLevel(ticket.getAccidentLevel())
.setUserIsHandle(handleIds.contains(AdminUserUtil.getUserId()))
.setUserIsCQM(cqms.contains(AdminUserUtil.getUserId()))
.setUserPlatform(ticket.getUserPlatform())
.setEvaluate(getTicketEvaluate(ticket.getId()));
return ApiResult.success(vo);
}
@ -734,6 +745,9 @@ public class TicketController extends ControllerBase {
.throwMessage("当前工单状态不允许发送消息");
List<Integer> adminUsers=adminUserService.getTickerMangagers();
adminUsers.addAll(StrUtil.split(ticket.getHandle(),",").stream().map(Integer::parseInt).collect(Collectors.toList()));
if (StrUtil.equals(Constant.FROM_ADMIN,ticket.getUserPlatform())){
adminUsers.add(ticket.getUserId());
}
VUtils.trueThrowBusinessError(adminUsers.stream()
.noneMatch(uid -> Objects.equals(uid, AdminUserUtil.getUserId())))
.throwMessage("你无权发送消息");
@ -1235,13 +1249,33 @@ public class TicketController extends ControllerBase {
VUtils.trueThrowBusinessError(!Objects.equals(ticket.getState(), TicketState.Processing.getState()))
.throwMessage("当前工单状态不允许请求通话");
Integer handlerUserId = Arrays.stream(ticket.getHandle().split(",")).map(Integer::parseInt).findFirst().get();
VUtils.trueThrowBusinessError(!Objects.equals(AdminUserUtil.getUserId(), handlerUserId))
.throwMessage("不是工单主负责人无权限呼叫");
if (StrUtil.equals(Constant.FROM_APP, ticket.getUserPlatform())) {
VUtils.trueThrowBusinessError(!Objects.equals(AdminUserUtil.getUserId(), handlerUserId))
.throwMessage("不是工单主负责人无权限呼叫");
} else {
VUtils.trueThrowBusinessError(!Objects.equals(ticket.getUserId(), AdminUserUtil.getUserId()) && !Objects.equals(AdminUserUtil.getUserId(), handlerUserId))
.throwMessage("无权限呼叫");
}
VUtils.trueThrowBusinessError(ticketCallService.isInCall(ticket.getUserId())).throwMessage("对方正在通话中");
AdminUser adminUser = adminUserService.getById(handlerUserId);
boolean userIdCreate = StrUtil.equals(ticket.getUserPlatform(), Constant.FROM_ADMIN) && Objects.equals(ticket.getUserId(), AdminUserUtil.getUserId());
Integer sendUserId = 0, receiveUserId = 0;
String sendUserFrom, receiveUserFrom;
if (userIdCreate) {
sendUserId = ticket.getUserId();
receiveUserId = handlerUserId;
sendUserFrom = Constant.FROM_ADMIN;
receiveUserFrom = Constant.FROM_ADMIN;
} else {
sendUserId = handlerUserId;
receiveUserId = ticket.getUserId();
sendUserFrom = Constant.FROM_ADMIN;
receiveUserFrom = Constant.FROM_APP;
}
ticketCallService.add(ticketId, sendUserId, sendUserFrom, receiveUserId, receiveUserFrom);
AdminUser adminUser = adminUserService.getById(sendUserId);
uniPushService.send(new UniPushMessage()
.setSenderId("admin-uid-" + handlerUserId)
.setReceiverId("app-uid-" + ticket.getUserId())
.setSenderId("admin-uid-" + sendUserId)
.setReceiverId(receiveUserFrom + "-uid-" + receiveUserId)
.setSendData(new UniPushMessageBody()
.setTitle("视频通话")
.setContent(adminUser.getUserName() + "请求与您视频通话")
@ -1255,8 +1289,11 @@ public class TicketController extends ControllerBase {
)
)
);
ssePushService.sendTicketCallToApp(adminUser, ticket.getUserId(), ticketId);
ticketCallService.add(ticketId, handlerUserId, ticket.getUserId(), Constant.FROM_ADMIN);
if (StrUtil.equals(Constant.FROM_APP, ticket.getUserPlatform())) {
ssePushService.sendTicketCallToApp(adminUser, ticket.getUserId(), ticketId);
} else {
ssePushService.sendTicketCallToAdmin(adminUser, receiveUserId, ticketId);
}
ticketEventPublisher.publishTicketCallBeginEvent(ticketId, adminUser.getUserName());
return ApiResult.success();
}
@ -1315,7 +1352,7 @@ public class TicketController extends ControllerBase {
ticketCallJoinService.join(ticketId, AdminUserUtil.getUserId(),Constant.FROM_ADMIN);
ssePushService.sendTicketCallJoinedToAdmin(AdminUserUtil.getUserId(), ticketId);
uniPushService.send(new UniPushMessage()
.setSenderId("admin-uid-" + AdminUserUtil.getUserId())
.setSenderId("admin-uid-" + AdminUserUtil.getUserId())//不重要
.setReceiverId("admin-uid-" + AdminUserUtil.getUserId())
.setSendData(new UniPushMessageBody()
.setTitle("视频通话")
@ -1340,7 +1377,9 @@ public class TicketController extends ControllerBase {
TicketCall ticketCall = ticketCallService.lambdaQuery()
.eq(TicketCall::getTicketId, request.getTicketId())
.ne(TicketCall::getState, 2)
.last("limit 1")
.one();
if (Objects.isNull(ticketCall)) return ApiResult.success();
boolean flag=false;
if (request.getReject()) {
AdminUser adminUser = adminUserService.getById(AdminUserUtil.getUserId());

View File

@ -13,6 +13,7 @@ import com.nflg.mobilebroken.repository.service.ITicketCallService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.MDC;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
@ -23,6 +24,7 @@ import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
@ConditionalOnProperty(name = "shengwang.sync.enable", havingValue = "true", matchIfMissing = true)
@Component
@Slf4j
public class ShengWangScheduledTasks {
@ -62,7 +64,7 @@ public class ShengWangScheduledTasks {
ticketCallService.updateById(ticketCall);
ticketCallJoinService.lambdaUpdate()
.set(TicketCallJoin::getState, 2)
.set(TicketCallJoin::getHangupTime, LocalDateTime.now())
// .set(TicketCallJoin::getHangupTime, LocalDateTime.now())
.eq(TicketCallJoin::getCallId, ticketCall.getId())
.update();
});
@ -80,7 +82,7 @@ public class ShengWangScheduledTasks {
if (CollectionUtil.isEmpty(channelUsers)) {
ticketCallJoinService.lambdaUpdate()
.set(TicketCallJoin::getState, 2)
.set(TicketCallJoin::getHangupTime, LocalDateTime.now())
// .set(TicketCallJoin::getHangupTime, LocalDateTime.now())
.eq(TicketCallJoin::getCallId, ticketCall.getId())
.update();
} else {
@ -94,7 +96,7 @@ public class ShengWangScheduledTasks {
if (CollectionUtil.isNotEmpty(userIds)) {
ticketCallJoinService.lambdaUpdate()
.set(TicketCallJoin::getState, 2)
.set(TicketCallJoin::getHangupTime, LocalDateTime.now())
// .set(TicketCallJoin::getHangupTime, LocalDateTime.now())
.eq(TicketCallJoin::getCallId, ticketCall.getId())
.eq(TicketCallJoin::getFrom, Constant.FROM_APP)
.notIn(TicketCallJoin::getUserId, userIds)
@ -110,7 +112,7 @@ public class ShengWangScheduledTasks {
if (CollectionUtil.isNotEmpty(userIds)) {
ticketCallJoinService.lambdaUpdate()
.set(TicketCallJoin::getState, 2)
.set(TicketCallJoin::getHangupTime, LocalDateTime.now())
// .set(TicketCallJoin::getHangupTime, LocalDateTime.now())
.eq(TicketCallJoin::getCallId, ticketCall.getId())
.eq(TicketCallJoin::getFrom, Constant.FROM_ADMIN)
.notIn(TicketCallJoin::getUserId, userIds)

View File

@ -9,15 +9,11 @@ import com.nflg.mobilebroken.common.constant.UserState;
import com.nflg.mobilebroken.common.pojo.ApiResult;
import com.nflg.mobilebroken.common.pojo.vo.AppLoginVO;
import com.nflg.mobilebroken.common.pojo.vo.MenuVO;
import com.nflg.mobilebroken.common.util.AppUserUtil;
import com.nflg.mobilebroken.common.util.SaTokenAppUtil;
import com.nflg.mobilebroken.common.util.VUtils;
import com.nflg.mobilebroken.common.pojo.vo.RoleVO;
import com.nflg.mobilebroken.common.util.*;
import com.nflg.mobilebroken.repository.entity.AdminUser;
import com.nflg.mobilebroken.repository.entity.AppUser;
import com.nflg.mobilebroken.repository.service.IAdminRoleService;
import com.nflg.mobilebroken.repository.service.IAdminUserService;
import com.nflg.mobilebroken.repository.service.IAppUserService;
import com.nflg.mobilebroken.repository.service.IDictionaryItemTranslateService;
import com.nflg.mobilebroken.repository.service.*;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@ -49,6 +45,10 @@ public class AppController extends ControllerBase {
@Resource
private IAdminRoleService adminRoleService;
@Resource
private IAdminUserRoleMapService adminUserRoleMapService;
/**
* 用户端登录
* @param userName 用户名
@ -57,8 +57,34 @@ public class AppController extends ControllerBase {
*/
@GetMapping("login")
public ApiResult<AppLoginVO> login(String userName, String password) {
AppUser user=appUserService.getUser(userName,password);
if (Objects.nonNull(user)) {
AdminUser adminUser =adminUserService.getUser(userName,password);
if (Objects.nonNull(adminUser)){
VUtils.trueThrow(Objects.equals(adminUser.getState(), UserState.Disabled.getState()))
.throwMessage(STATE.PassportErr, dictionaryItemTranslateService.getValueByCode(Constant.DICTIONARY_SYSTEMERROR, Constant.DICTIONARY_ITEM_ACCOUNT_DISABLED, MultilingualUtil.getLanguage()));
VUtils.trueThrow(Objects.equals(adminUser.getState(), UserState.ToBeActivated.getState()))
.throwMessage(STATE.PassportErr, dictionaryItemTranslateService.getValueByCode(Constant.DICTIONARY_SYSTEMERROR, Constant.DICTIONARY_ITEM_ACCOUNT_HAS_EXPIRED, MultilingualUtil.getLanguage()));
List<RoleVO> roleCodes = adminUserRoleMapService.getRoleList(adminUser.getId());
SaTokenAdminUtil.login(adminUser.getId(), SaLoginConfig
.setExtra("from", Constant.FROM_ADMIN)
.setExtra("name", adminUser.getUserName())
.setExtra("code", adminUser.getUserCode())
.setExtra("email", adminUser.getEmail())
.setExtra("roles", roleCodes.stream().map(RoleVO::getCode).collect(Collectors.toList())));
String adminToken=SaTokenAdminUtil.getTokenInfo().getTokenValue();
SaTokenAppUtil.login(adminUser.getId(), SaLoginConfig
.setExtra("from", Constant.FROM_ADMIN)
.setExtra("name", adminUser.getUserName())
.setExtra("email", adminUser.getEmail()));
SaTokenInfo tokenInfo = SaTokenAppUtil.getTokenInfo();
return ApiResult.success(new AppLoginVO()
.setUserId(adminUser.getId())
.setToken(tokenInfo.getTokenValue())
.setAdminToken(adminToken)
.setExpire(tokenInfo.getTokenTimeout())
.setLanguageCode(Constant.DEFAULT_LANGUAGE_CODE)
.setPlatform(Constant.FROM_ADMIN));
}else {
AppUser user=appUserService.getUser(userName,password);
VUtils.trueThrow(Objects.equals(user.getState(), UserState.Disabled.getState()))
.throwMessage(STATE.PassportErr, dictionaryItemTranslateService.getValueByCode(Constant.DICTIONARY_SYSTEMERROR, Constant.DICTIONARY_ITEM_ACCOUNT_DISABLED, user.getLanguageCode()));
VUtils.trueThrow(Objects.equals(user.getState(), UserState.ToBeActivated.getState()))
@ -68,7 +94,7 @@ public class AppController extends ControllerBase {
VUtils.trueThrow(user.getExpireTime().isBefore(ChronoLocalDate.from(LocalDateTime.now())) && !user.getIsPrimary())
.throwMessage(STATE.PassportErr, dictionaryItemTranslateService.getValueByCode(Constant.DICTIONARY_SYSTEMERROR, Constant.DICTIONARY_ITEM_ACCOUNT_HAS_EXPIRED, user.getLanguageCode()));
SaTokenAppUtil.login(user.getId(), SaLoginConfig
.setExtra("from", "app")
.setExtra("from", Constant.FROM_APP)
.setExtra("name", user.getName())
.setExtra("email", user.getEmail())
.setExtra("companyIds", StrUtil.split(user.getCompanyId(), ",").stream().map(Integer::valueOf).collect(Collectors.toList()))
@ -81,26 +107,7 @@ public class AppController extends ControllerBase {
.setToken(tokenInfo.getTokenValue())
.setExpire(tokenInfo.getTokenTimeout())
.setLanguageCode(user.getLanguageCode())
.setPlatform("app"));
}else {
AdminUser adminUser =adminUserService.getUser(userName,password);
VUtils.trueThrow(Objects.isNull(adminUser))
.throwMessage(STATE.PassportErr, dictionaryItemTranslateService.getValueByCode(Constant.DICTIONARY_SYSTEMERROR, Constant.DICTIONARY_ITEM_INCORRECTUSERNAMEORPASSWORD, Constant.DEFAULT_LANGUAGE_CODE));
VUtils.trueThrow(Objects.equals(adminUser.getState(), UserState.Disabled.getState()))
.throwMessage(STATE.PassportErr, dictionaryItemTranslateService.getValueByCode(Constant.DICTIONARY_SYSTEMERROR, Constant.DICTIONARY_ITEM_ACCOUNT_DISABLED, Constant.DEFAULT_LANGUAGE_CODE));
VUtils.trueThrow(Objects.equals(adminUser.getState(), UserState.ToBeActivated.getState()))
.throwMessage(STATE.PassportErr, dictionaryItemTranslateService.getValueByCode(Constant.DICTIONARY_SYSTEMERROR, Constant.DICTIONARY_ITEM_ACCOUNT_HAS_EXPIRED, Constant.DEFAULT_LANGUAGE_CODE));
SaTokenAppUtil.login(adminUser.getId(), SaLoginConfig
.setExtra("from", "admin")
.setExtra("name", adminUser.getUserName())
.setExtra("email", adminUser.getEmail()));
SaTokenInfo tokenInfo = SaTokenAppUtil.getTokenInfo();
return ApiResult.success(new AppLoginVO()
.setUserId(adminUser.getId())
.setToken(tokenInfo.getTokenValue())
.setExpire(tokenInfo.getTokenTimeout())
.setLanguageCode(Constant.DEFAULT_LANGUAGE_CODE)
.setPlatform("admin"));
.setPlatform(Constant.FROM_APP));
}
}

View File

@ -507,7 +507,7 @@ public class TicketController extends ControllerBase {
VUtils.trueThrowBusinessError(ticketCallService.isInCall(handlerUserId)).throwMessage("对方正在通话中");
AppUser appUser = appUserService.getById(ticket.getUserId());
uniPushService.send(new UniPushMessage()
.setSenderId("app-uid-" + ticket.getUserId())
.setSenderId(ticket.getUserPlatform()+"-uid-" + ticket.getUserId())
.setReceiverId("admin-uid-" + handlerUserId)
.setSendData(new UniPushMessageBody()
.setTitle("视频通话")
@ -523,7 +523,7 @@ public class TicketController extends ControllerBase {
)
);
ssePushService.sendTicketCallToAdmin(appUser, handlerUserId, ticketId);
ticketCallService.add(ticketId, AppUserUtil.getUserId(), handlerUserId, Constant.FROM_APP);
ticketCallService.add(ticketId, AppUserUtil.getUserId(),Constant.FROM_APP, handlerUserId, Constant.FROM_ADMIN);
ticketEventPublisher.publishTicketCallBeginEvent(ticketId,appUser.getName());
return ApiResult.success();
}
@ -538,13 +538,17 @@ public class TicketController extends ControllerBase {
VUtils.trueThrowBusinessError(Objects.isNull(ticket)).throwMessage("工单不存在");
VUtils.trueThrowBusinessError(!Objects.equals(ticket.getState(), TicketState.Processing.getState()))
.throwMessage("当前工单状态不允许通话");
VUtils.trueThrowBusinessError(!StrUtil.equals(ticket.getUserPlatform(), AppUserUtil.getFrom())
|| Objects.equals(AppUserUtil.getUserId(), ticket.getUserId()))
.throwMessage("不是创建人无法加入通话");
VUtils.trueThrowBusinessError(ticketCallService.isInCall(AppUserUtil.getUserId()))
.throwMessage("您已加入别的通话中");
ticketCallJoinService.join(ticketId, AppUserUtil.getUserId(), Constant.FROM_APP);
ssePushService.sendTicketCallJoinedToApp(AppUserUtil.getUserId(), ticketId);
Integer handlerUserId = Arrays.stream(ticket.getHandle().split(",")).map(Integer::parseInt).findFirst().get();
uniPushService.send(new UniPushMessage()
.setSenderId("app-uid-" + AppUserUtil.getUserId())
.setReceiverId("app-uid-" + AppUserUtil.getUserId())
.setSenderId(ticket.getUserPlatform()+"-uid-" + ticket.getUserId())
.setReceiverId("admin-uid-" + handlerUserId)
.setSendData(new UniPushMessageBody()
.setTitle("视频通话")
.setContent("您已加入别的通话中")
@ -572,7 +576,7 @@ public class TicketController extends ControllerBase {
Ticket ticket = ticketService.getById(request.getTicketId());
int handlerId= Integer.parseInt(StrUtil.split(ticket.getHandle(), ",").stream().findFirst().get());
uniPushService.send(new UniPushMessage()
.setSenderId("app-uid-" + appUser.getId())
.setSenderId(ticket.getUserPlatform()+"-uid-" + appUser.getId())
.setReceiverId("admin-uid-" + handlerId)
.setSendData(new UniPushMessageBody()
.setTitle("挂断视频通话")
@ -591,8 +595,9 @@ public class TicketController extends ControllerBase {
flag=ticketCallService.hangUp(request.getTicketId(), AppUserUtil.getUserId(), Constant.FROM_APP, true);
}else {
AppUser appUser = appUserService.getById(AppUserUtil.getUserId());
Ticket ticket = ticketService.getById(request.getTicketId());
uniPushService.send(new UniPushMessage()
.setSenderId("app-uid-" + appUser.getId())
.setSenderId(ticket.getUserPlatform()+"-uid-" + appUser.getId())
.setReceiverId("admin-uid-" + request.getFromUserId())
.setSendData(new UniPushMessageBody()
.setTitle("拒绝视频通话")

View File

@ -209,4 +209,10 @@ public class AdminTicketVO {
}
return null;
}
/**
* 问题描述
*/
@IgnoreExport
private String description;
}

View File

@ -11,6 +11,11 @@ public class AppLoginVO {
private String token;
/**
* 管理员端token
*/
private String adminToken;
private Long expire;
//语言编码

View File

@ -32,6 +32,11 @@ public class TicketInfoVO {
//创建人头像
private String createUserAvatar;
/**
* 用户来源平台app或者admin
*/
private String userPlatform;
//提交时间
private LocalDateTime createTime;

View File

@ -1,5 +1,6 @@
package com.nflg.mobilebroken.push;
import cn.hutool.core.util.IdUtil;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
@ -22,6 +23,8 @@ public class UserSseEmitter extends SseEmitter {
private Integer ticketId;
private String id = IdUtil.getSnowflakeNextIdStr();
private ScheduledFuture<?> heartbeatFuture;
public UserSseEmitter(){
@ -34,8 +37,8 @@ public class UserSseEmitter extends SseEmitter {
this.ticketId = ticketId;
}
public String getUser(){
return from + "-" + userId;
public String getLable() {
return from + "-" + userId + ",连接id:" + id;
}
public void startHeartbeat(TaskScheduler taskScheduler) {
@ -44,7 +47,7 @@ public class UserSseEmitter extends SseEmitter {
send(SseEmitter.event().data("ping"));
} catch (IOException e) {
heartbeatFuture.cancel(true);
log.error("sse发送ping数据出错({}):{}", getUser(),e.getMessage());
log.error("sse发送ping数据出错({}):{}", getLable(),e.getMessage());
completeWithError(e);
}
}, 30_000);

View File

@ -34,53 +34,53 @@ public class SSEManagerBase {
protected String from;
protected void check(){
VUtils.trueThrow(IS_SHUTDOWN).throwMessage(STATE.ServiceConnectRefused,"SSE服务已关闭");
protected void check() {
VUtils.trueThrow(IS_SHUTDOWN).throwMessage(STATE.ServiceConnectRefused, "SSE服务已关闭");
}
@PreDestroy
protected void shutdown() {
IS_SHUTDOWN=true;
IS_SHUTDOWN = true;
log.warn("准备关闭SSE服务");
SSE_EMITTERS.forEach(emitter->{
SSE_EMITTERS.forEach(emitter -> {
try {
emitter.send("因SSE服务关闭,连接即将断开");
emitter.complete();
}catch (Exception ex){
log.error("SSE发送消息失败",ex);
} catch (Exception ex) {
log.error("SSE发送消息失败", ex);
emitter.completeWithError(ex);
}
});
log.warn("SSE服务已关闭");
}
protected SseEmitter connect(Integer ticketId,Integer userId) {
protected SseEmitter connect(Integer ticketId, Integer userId) {
check();
log.info(from + "SSE连接:用户id:" + userId + ",工单id:" + ticketId);
UserSseEmitter emitter = new UserSseEmitter(from, userId, ticketId);
log.info(from + "SSE连接:用户id:" + userId + ",工单id:" + ticketId + ",连接id:" + emitter.getId());
emitter.startHeartbeat(taskScheduler);
SSE_EMITTERS.add(emitter);
emitter.onError((ex) -> {
remove(emitter);
log.error("SSE异常({}):{}", ex.getMessage(),emitter.getUser());
log.error("SSE异常({}):{}", ex.getMessage(), emitter.getLable());
});
emitter.onTimeout(() -> {
remove(emitter);
log.error("SSE超时:"+userId);
log.error("SSE超时:" + userId);
});
emitter.onCompletion(() -> {
remove(emitter);
log.error("SSE完成:"+userId);
log.error("SSE完成:" + userId);
});
try {
log.info("发送连接成功信息:" + emitter.getLable());
emitter.send(SseEmitter.event().data("已连接").reconnectTime(5000));
}catch (ClientAbortException e){
log.error("客户端断开连接:{}", userId);
emitter.completeWithError(e);
}
catch (IOException e) {
} catch (ClientAbortException e) {
log.error("断开已连接:{}", e.getMessage());
emitter.complete();
} catch (IOException e) {
log.error("sse发送数据出错:{}", e.getMessage());
emitter.completeWithError(e);
emitter.complete();
}
return emitter;
}
@ -90,19 +90,21 @@ public class SSEManagerBase {
List<UserSseEmitter> emitters = SSE_EMITTERS.stream()
.filter(s -> Objects.equals(s.getTicketId(), ticketId))
.collect(Collectors.toList());
if (CollectionUtil.isEmpty(emitters)){
if (CollectionUtil.isEmpty(emitters)) {
log.info(StrUtil.format(from + "没有用户连接工单:{}", ticketId));
return;
}
emitters.forEach(emitter -> {
try {
log.info("发送给用户:" + emitter.getLable());
emitter.send(SseEmitter.event().name(dto.getType()).data(dto.getData()));
log.info("发送成功");
} catch (ClientAbortException e) {
log.error("客户端断开连接:{}", emitter.getUser());
emitter.completeWithError(e);
log.error("发送失败,{}", e.getMessage());
emitter.complete();
} catch (IOException e) {
log.error("sse发送数据出错:{}", e.getMessage());
emitter.completeWithError(e);
log.error("发送失败,sse发送数据出错:{}", e.getMessage());
emitter.complete();
}
});
}
@ -118,21 +120,22 @@ public class SSEManagerBase {
}
emitters.forEach(emitter -> {
try {
log.info("发送给用户:" + emitter.getLable());
emitter.send(SseEmitter.event().name(dto.getType()).data(dto.getData()));
log.info("发送成功");
} catch (ClientAbortException e) {
log.error("客户端断开连接:{}", emitter.getUser());
emitter.completeWithError(e);
}catch (IOException e) {
log.error("sse发送数据出错:{}", e.getMessage());
emitter.completeWithError(e);
} catch (ClientAbortException e) {
log.error("发送失败,{}", e.getMessage());
emitter.complete();
} catch (IOException e) {
log.error("发送失败,sse发送数据出错:{}", e.getMessage());
emitter.complete();
}
});
}
private void remove(UserSseEmitter emitter){
private void remove(UserSseEmitter emitter) {
SSE_EMITTERS.remove(emitter);
emitter.complete();
emitter=null;
emitter = null;
}
}

View File

@ -1,8 +1,11 @@
package com.nflg.mobilebroken.repository.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.nflg.mobilebroken.common.pojo.vo.AdminMenuButtonVO;
import com.nflg.mobilebroken.repository.entity.AdminMenuButton;
import java.util.List;
/**
* <p>
* Mapper 接口
@ -13,4 +16,5 @@ import com.nflg.mobilebroken.repository.entity.AdminMenuButton;
*/
public interface AdminMenuButtonMapper extends BaseMapper<AdminMenuButton> {
List<AdminMenuButtonVO> getMenuButtonList(String url);
}

View File

@ -8,6 +8,8 @@ import com.nflg.mobilebroken.common.pojo.request.SearchMenuButtonRequest;
import com.nflg.mobilebroken.common.pojo.vo.AdminMenuButtonVO;
import com.nflg.mobilebroken.repository.entity.AdminMenuButton;
import java.util.List;
/**
* <p>
* 服务类
@ -23,4 +25,6 @@ public interface IAdminMenuButtonService extends IService<AdminMenuButton> {
void addMenuButton(MenuButtonAddRequest request);
void updateMenuButton(MenuButtonUpdateRequest request);
List<AdminMenuButtonVO> getMenuButtonList(String url);
}

View File

@ -17,7 +17,7 @@ public interface ITicketCallService extends IService<TicketCall> {
boolean isInCall(Integer userId);
void add(Integer ticketId, Integer callerUserId, Integer calledUserId, String from);
void add(Integer ticketId, Integer callerUserId,String callerUserFrom, Integer calledUserId, String calledUserFrom);
boolean hangUp(@NotNull Integer ticketId, Integer userId, String from, boolean reject);
}

View File

@ -29,4 +29,6 @@ public interface ITicketFavoritesService extends IService<TicketFavorites> {
void moveFavorites(FavoritesMoveRequest request);
void moveFavoritesTicket(Integer userId,String from, FavoritesTicketMoveRequest request);
FavoritesVO getTree(Integer userId, String from, Integer id);
}

View File

@ -18,6 +18,7 @@ import com.nflg.mobilebroken.repository.service.IAdminMenuButtonService;
import org.springframework.stereotype.Service;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Objects;
/**
@ -68,4 +69,9 @@ public class AdminMenuButtonServiceImpl extends ServiceImpl<AdminMenuButtonMappe
.setUpdateTime(LocalDateTime.now());
updateById(button);
}
@Override
public List<AdminMenuButtonVO> getMenuButtonList(String url) {
return baseMapper.getMenuButtonList(url);
}
}

View File

@ -17,6 +17,7 @@ import com.nflg.mobilebroken.common.pojo.vo.AdminUserSimpleVO;
import com.nflg.mobilebroken.common.pojo.vo.AdminUserVO;
import com.nflg.mobilebroken.common.pojo.vo.RoleSimpleVO;
import com.nflg.mobilebroken.common.util.AdminUserUtil;
import com.nflg.mobilebroken.common.util.MultilingualUtil;
import com.nflg.mobilebroken.common.util.VUtils;
import com.nflg.mobilebroken.repository.entity.*;
import com.nflg.mobilebroken.repository.mapper.AdminUserMapper;
@ -64,15 +65,22 @@ public class AdminUserServiceImpl extends ServiceImpl<AdminUserMapper, AdminUser
@Resource
private ITBaseDeviceTypeService deviceTypeService;
@Resource
private IDictionaryItemTranslateService dictionaryItemTranslateService;
@Override
public AdminUser getUser(String userName, String password) {
AdminUser user = lambdaQuery()
.eq(AdminUser::getLoginName, userName)
.one();
if (Objects.nonNull(user) && PASSWORDENCODER.matches(password, user.getPassword())) {
if (Objects.isNull(user)) return null;
if (PASSWORDENCODER.matches(password, user.getPassword())) {
return user;
}else {
VUtils.trueThrowBusinessError(true)
.throwMessage(dictionaryItemTranslateService.getValueByCode(Constant.DICTIONARY_SYSTEMERROR, Constant.DICTIONARY_ITEM_INCORRECTUSERNAMEORPASSWORD, MultilingualUtil.getLanguage()));
return null;
}
return null;
}
@Override

View File

@ -11,10 +11,7 @@ import com.nflg.mobilebroken.common.exception.NflgException;
import com.nflg.mobilebroken.common.pojo.PageData;
import com.nflg.mobilebroken.common.pojo.request.*;
import com.nflg.mobilebroken.common.pojo.vo.*;
import com.nflg.mobilebroken.common.util.AdminUserUtil;
import com.nflg.mobilebroken.common.util.AppUserUtil;
import com.nflg.mobilebroken.common.util.PageUtil;
import com.nflg.mobilebroken.common.util.VUtils;
import com.nflg.mobilebroken.common.util.*;
import com.nflg.mobilebroken.repository.entity.*;
import com.nflg.mobilebroken.repository.mapper.AppUserMapper;
import com.nflg.mobilebroken.repository.service.*;
@ -69,16 +66,18 @@ public class AppUserServiceImpl extends ServiceImpl<AppUserMapper, AppUser> impl
@Resource
private StringRedisTemplate stringRedisTemplate;
@Resource
private IDictionaryItemTranslateService dictionaryItemTranslateService;
@Override
public AppUser getUser(String userName, String password) {
AppUser user = lambdaQuery()
.eq(AppUser::getIsDel, false)
.eq(AppUser::getLoginName, userName)
.one();
if (Objects.nonNull(user) && PASSWORDENCODER.matches(password, user.getPassword())) {
return user;
}
return null;
VUtils.trueThrowBusinessError(Objects.isNull(user) || !PASSWORDENCODER.matches(password, user.getPassword()))
.throwMessage(dictionaryItemTranslateService.getValueByCode(Constant.DICTIONARY_SYSTEMERROR, Constant.DICTIONARY_ITEM_INCORRECTUSERNAMEORPASSWORD, MultilingualUtil.getLanguage()));
return user;
}
@Override

View File

@ -41,6 +41,7 @@ public class TicketCallJoinServiceImpl extends ServiceImpl<TicketCallJoinMapper,
TicketCall ticketCall = ticketCallService.lambdaQuery()
.eq(TicketCall::getTicketId, ticketId)
.ne(TicketCall::getState, 2)
.last("limit 1")
.one();
VUtils.trueThrowBusinessError(Objects.isNull(ticketCall)).throwMessage("加入失败,通话已结束");
TicketCallJoin ticketCallJoin = lambdaQuery()
@ -72,18 +73,19 @@ public class TicketCallJoinServiceImpl extends ServiceImpl<TicketCallJoinMapper,
.ne(TicketCallJoin::getState, 2)
.eq(TicketCallJoin::getUserId, userId)
.eq(TicketCallJoin::getFrom, from)
.last("limit 1")
.one();
boolean flag = false;
if (Objects.nonNull(ticketCallJoin)) {
ticketCallJoin.setState(2);
if (!reject) {
if (reject) {
ticketCallJoin.setHangupTime(LocalDateTime.now());
}
updateById(ticketCallJoin);
if (StrUtil.equals(from, Constant.FROM_APP)) {
lambdaUpdate()
.set(TicketCallJoin::getState, 2)
.set(!reject, TicketCallJoin::getHangupTime, LocalDateTime.now())
.set(reject, TicketCallJoin::getHangupTime, LocalDateTime.now())
.eq(TicketCallJoin::getCallId, callId)
.ne(TicketCallJoin::getFrom, from)
.update();
@ -94,7 +96,7 @@ public class TicketCallJoinServiceImpl extends ServiceImpl<TicketCallJoinMapper,
.exists()){
ticketCallService.lambdaUpdate()
.set(TicketCall::getState, 2)
.set(!reject,TicketCall::getHangupTime, LocalDateTime.now())
.set(reject,TicketCall::getHangupTime, LocalDateTime.now())
.eq(TicketCall::getId, callId)
.update();
flag = true;

View File

@ -41,17 +41,17 @@ public class TicketCallServiceImpl extends ServiceImpl<TicketCallMapper, TicketC
@Transactional
@Override
public void add(Integer ticketId, Integer callerUserId, Integer calledUserId, String from) {
public void add(Integer ticketId, Integer callerUserId,String callerUserFrom, Integer calledUserId, String calledUserFrom) {
TicketCall ticketCall = new TicketCall()
.setTicketId(ticketId)
.setCallerUserId(callerUserId)
.setState(0)
.setFrom(from)
.setFrom(callerUserFrom)
.setCreateTime(LocalDateTime.now());
save(ticketCall);
ticketCallJoinService.save(new TicketCallJoin()
.setCallId(ticketCall.getId())
.setFrom(StrUtil.equals(from, Constant.FROM_APP) ? Constant.FROM_ADMIN : Constant.FROM_APP)
.setFrom(calledUserFrom)
.setUserId(calledUserId)
.setState(0)
.setCreateTime(LocalDateTime.now())
@ -63,6 +63,7 @@ public class TicketCallServiceImpl extends ServiceImpl<TicketCallMapper, TicketC
TicketCall ticketCall = lambdaQuery()
.eq(TicketCall::getTicketId, ticketId)
.ne(TicketCall::getState, 2)
.last("limit 1")
.one();
boolean flag = false;
if (Objects.nonNull(ticketCall)){
@ -70,7 +71,7 @@ public class TicketCallServiceImpl extends ServiceImpl<TicketCallMapper, TicketC
|| ticketCallJoinService.allIsHangUp(ticketCall.getId())){
ticketCall.setState(2);
ticketCallJoinService.hangUpAll(ticketCall.getId());
if (!reject) {
if (reject) {
ticketCall.setHangupTime(LocalDateTime.now());
}
updateById(ticketCall);

View File

@ -19,6 +19,7 @@ import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
@ -102,4 +103,26 @@ public class TicketFavoritesServiceImpl extends ServiceImpl<TicketFavoritesMappe
.eq(TicketFollow::getFrom, StrUtil.equals(from, "app")?0:1)
.update();
}
@Override
public FavoritesVO getTree(Integer userId, String from, Integer id) {
TicketFavorites favorites = Objects.equals(id, 0) ? new TicketFavorites().setId(0).setName("收藏夹") : lambdaQuery().eq(TicketFavorites::getId, id).one();
FavoritesVO vo = new FavoritesVO().setId(favorites.getId()).setName(favorites.getName());
getChildren(userId, vo, from);
return vo;
}
private void getChildren(Integer userId, FavoritesVO vo, String from) {
List<FavoritesVO> favorites = lambdaQuery()
.eq(TicketFavorites::getParentId, vo.getId())
.eq(TicketFavorites::getUserPlatform, from)
.eq(TicketFavorites::getCreateBy, userId)
.orderByAsc(TicketFavorites::getOrderNum)
.list()
.stream()
.map(f -> new FavoritesVO().setId(f.getId()).setName(f.getName()))
.collect(Collectors.toList());
vo.setChildren(favorites);
favorites.forEach(f -> getChildren(userId, f, from));
}
}

View File

@ -2,4 +2,10 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.nflg.mobilebroken.repository.mapper.AdminMenuButtonMapper">
<select id="getMenuButtonList" resultType="com.nflg.mobilebroken.common.pojo.vo.AdminMenuButtonVO">
SELECT amb.*
FROM admin_menu am
INNER JOIN admin_menu_button amb ON am.id=amb.menu_id
WHERE am.url=#{url}
</select>
</mapper>

View File

@ -39,7 +39,7 @@
<where>
t.state!=4
<if test="!request.ticketManager">
AND (FIND_IN_SET(#{userId},t.handle)>0 OR fun_inAduit(t.id,#{userId})=1)
AND (FIND_IN_SET(#{userId},t.handle)>0 OR fun_inAduit(t.id,#{userId})=1 OR (t.user_platform='admin' AND t.user_id=#{userId}))
</if>
<if test="request.state!=null">
AND t.state=#{request.state}
@ -150,7 +150,7 @@
,t.create_time AS 'createTime',t.update_time AS 'completeTime',di.name AS 'warrantyStatusDesc',d.device_type AS 'deviceType'
,d.model_no AS 'equipmentModel',d.shipment_date AS 'shipmentDate',IF(tf.id IS NULL, false, true) AS 'followed',auc.user_name AS 'cqm'
,t.solve_time AS 'closeTime',auh.user_name AS 'currentHandle',dt.cqm_person_name AS 'cqms'
,t.handle_name AS 'handle'
,t.handle_name AS 'handle',t.description
FROM ticket t
LEFT JOIN app_user u ON t.user_id=u.id
LEFT JOIN admin_user au ON t.user_id=au.id
@ -173,7 +173,7 @@
,t.create_time AS 'createTime',t.update_time AS 'completeTime',di.name AS 'warrantyStatusDesc',d.device_type AS 'deviceType'
,d.model_no AS 'equipmentModel',d.shipment_date AS 'shipmentDate',IF(tf.id IS NULL, false, true) AS 'followed',auc.user_name AS 'cqm'
,t.solve_time AS 'closeTime',auh.user_name AS 'currentHandle',dt.cqm_person_name AS 'cqms'
,t.handle_name AS 'handle'
,t.handle_name AS 'handle',t.description
FROM ticket t
LEFT JOIN app_user u ON t.user_id=u.id
LEFT JOIN admin_user au ON t.user_id=au.id
@ -196,7 +196,7 @@
,t.create_time AS 'createTime',t.update_time AS 'completeTime',di.name AS 'warrantyStatusDesc',d.device_type AS 'deviceType'
,d.model_no AS 'equipmentModel',d.shipment_date AS 'shipmentDate',true AS 'followed',auc.user_name AS 'cqm'
,t.solve_time AS 'closeTime',auh.user_name AS 'currentHandle',dt.cqm_person_name AS 'cqms'
,t.handle_name AS 'handle'
,t.handle_name AS 'handle',t.description
FROM ticket t
LEFT JOIN app_user u ON t.user_id=u.id
LEFT JOIN admin_user au ON t.user_id=au.id
@ -218,7 +218,7 @@
,d.customer_name AS 'customerName',d.agent_name AS 'agentName',IF(t.user_platform='admin',au.user_name,u.`name`) AS 'createBy',t.device_no AS 'deviceNo',t.use_time AS 'useTime'
,t.create_time AS 'createTime',t.update_time AS 'completeTime',di.name AS 'warrantyStatusDesc',true AS 'followed'
,auc.user_name AS 'cqm',t.solve_time AS 'closeTime',auh.user_name AS 'currentHandle'
,dt.cqm_person_name AS 'cqms',t.handle_name AS 'handle'
,dt.cqm_person_name AS 'cqms',t.handle_name AS 'handle',t.description
FROM ticket t
LEFT JOIN app_user u ON t.user_id=u.id
LEFT JOIN admin_user au ON t.user_id=au.id
@ -251,7 +251,7 @@
,t.create_time AS 'createTime',t.update_time AS 'completeTime',di.name AS 'warrantyStatusDesc',d.device_type AS 'deviceType'
,d.model_no AS 'equipmentModel',d.shipment_date AS 'shipmentDate',true AS 'followed',auc.user_name AS 'cqm'
,t.solve_time AS 'closeTime',auh.user_name AS 'currentHandle',dt.cqm_person_name AS 'cqms'
,t.handle_name AS 'handle'
,t.handle_name AS 'handle',t.description
FROM ticket t
LEFT JOIN app_user u ON t.user_id=u.id
LEFT JOIN admin_user au ON t.user_id=au.id

View File

@ -24,9 +24,10 @@
<module>nflg-mobilebroken-product</module>
</modules>
<properties>
<java.version>11</java.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<maven.compiler.encoding>UTF-8</maven.compiler.encoding>
<java.version>11</java.version>
<spring-boot.version>2.3.12.RELEASE</spring-boot.version>
<spring-cloud.version>Hoxton.SR8</spring-cloud.version>
<spring-cloud-alibaba.version>2.2.3.RELEASE</spring-cloud-alibaba.version>