venue/smart_venue
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

api-二维码显示问题

Browse Source
This commit is contained in:
limqhz
2020-08-03 00:26:03 +08:00
parent b51398129e
commit 570b322613
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
api/src/main/java/com/sv/netty/netty/message/MessageType.java
View File

@@ -1,8 +1,9 @@
package com.sv.netty.netty.message; package com.sv.netty.netty.message;
public enum MessageType { public enum MessageType {
LINK("连接"),
LOAD("加载"), LOAD("加载"),
OPENDOOR("开门"), OPEN_DOOR("开门"),
FAILED("开门校验失败"); FAILED("开门校验失败");
private String message; private String message;

6
api/src/main/java/com/sv/netty/netty/service/impl/AppMessageHandlerAdapter.java
View File

@@ -88,6 +88,8 @@ public class AppMessageHandlerAdapter implements MessageService {
} else { } else {
deviceService.online(heartBeat.getDeviceName(),heartBeat.getVenueId(),deviceType,thisVenue.getType(),clientId); deviceService.online(heartBeat.getDeviceName(),heartBeat.getVenueId(),deviceType,thisVenue.getType(),clientId);
putChannelType(heartBeat.getDeviceName(),heartBeat.getVenueId(),deviceType,channel); putChannelType(heartBeat.getDeviceName(),heartBeat.getVenueId(),deviceType,channel);
MessageDTO messageDTO = new MessageDTO(MessageType.LINK,"第一次心跳成功，返回二维码");
channel.writeAndFlush(messageDTO);
} }
} }
} }
@@ -185,7 +187,7 @@ public class AppMessageHandlerAdapter implements MessageService {
if(venueService.qrCodeEnterVenue(memberId,deviceName,venueId,venue)){ if(venueService.qrCodeEnterVenue(memberId,deviceName,venueId,venue)){
// 可以进场 // 可以进场
scheduledExecutorService.schedule(() -> { scheduledExecutorService.schedule(() -> {
sendMessage(channel,new MessageDTO(MessageType.OPENDOOR,"OK")); sendMessage(channel,new MessageDTO(MessageType.OPEN_DOOR,"OK"));
}, 5, TimeUnit.SECONDS); }, 5, TimeUnit.SECONDS);
} else { } else {
// 进场失败 // 进场失败
@@ -194,7 +196,7 @@ public class AppMessageHandlerAdapter implements MessageService {
} else { } else {
logger.info(member.getId() + "入场失败:连续入场"); logger.info(member.getId() + "入场失败:连续入场");
Config config = configService.findById(1); Config config = configService.findById(1);
sendMessage(channel,new MessageDTO(MessageType.OPENDOOR, MessageFormat.format(ErrorCode.CHECK_ENTER_INTERVAL.getMsg(),config.getValue()))); sendMessage(channel,new MessageDTO(MessageType.OPEN_DOOR, MessageFormat.format(ErrorCode.CHECK_ENTER_INTERVAL.getMsg(),config.getValue())));
} }
} }