|
|
|
@ -12,6 +12,7 @@ import com.baiye.modules.system.service.MessageNotificationService;
|
|
|
|
|
import com.baiye.modules.system.service.UserMessageService;
|
|
|
|
|
import com.baiye.modules.system.service.dto.UserMessageDto;
|
|
|
|
|
import com.baiye.util.AESUtils;
|
|
|
|
|
import com.baiye.util.EncryptUtil;
|
|
|
|
|
import com.baiye.util.SpringContextHolder;
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
|
@ -53,7 +54,6 @@ public class WebSocketServer {
|
|
|
|
|
@OnOpen
|
|
|
|
|
public void onOpen(Session session) {
|
|
|
|
|
Long userId = getUserId(session);
|
|
|
|
|
log.info("=============== user id as {} ===================",userId);
|
|
|
|
|
if (userId != null) {
|
|
|
|
|
SESSIONS.put(userId, session);
|
|
|
|
|
// 在线数加1
|
|
|
|
@ -231,7 +231,7 @@ public class WebSocketServer {
|
|
|
|
|
if (queryString != null &&
|
|
|
|
|
StringUtils.isNotBlank(StringUtils.substring(queryString, DefaultNumberConstants.FOURTEEN_NUMBER))) {
|
|
|
|
|
String substring = queryString.substring(DefaultNumberConstants.FOURTEEN_NUMBER);
|
|
|
|
|
String decrypt = AESUtils.decrypt(substring, AdPlatFormConstants.PLATFORM_USER);
|
|
|
|
|
String decrypt = EncryptUtil.AESDecode(substring, AdPlatFormConstants.PLATFORM_USER);
|
|
|
|
|
if (StringUtils.isNotBlank(decrypt)) {
|
|
|
|
|
return Long.parseLong(decrypt);
|
|
|
|
|
}
|
|
|
|
|