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-07-23 16:06:24 +08:00
parent 4fcd4b4d40
commit ade7baaa6b
3 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
api/src/main/java/com/sv/netty/controller/QREnterController.java
View File

@@ -1,13 +1,16 @@
package com.sv.netty.controller; package com.sv.netty.controller;
import com.enums.DeviceType; import com.enums.DeviceType;
import com.enums.VenueTypeEnum;
import com.sv.entity.Venue; import com.sv.entity.Venue;
import com.sv.entity.VenueType;
import com.sv.netty.config.ClientChannelCache; import com.sv.netty.config.ClientChannelCache;
import com.sv.netty.config.Constant; import com.sv.netty.config.Constant;
import com.sv.netty.netty.service.MessageService; import com.sv.netty.netty.service.MessageService;
import com.sv.service.api.QRCodeService; import com.sv.service.api.QRCodeService;
import com.ydd.framework.core.common.dto.ResponseDTO; import com.ydd.framework.core.common.dto.ResponseDTO;
import com.ydd.framework.core.controller.BaseApiController; import com.ydd.framework.core.controller.BaseApiController;
import com.ydd.framework.core.exception.ServiceException;
import io.netty.channel.Channel; import io.netty.channel.Channel;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -60,10 +63,8 @@ public class QREnterController extends BaseApiController {
String deviceName = getDeviceName(deviceId); String deviceName = getDeviceName(deviceId);
DeviceType enterOrOut = getEnterOrOut(deviceId); DeviceType enterOrOut = getEnterOrOut(deviceId);
Venue venue = qrCodeService.initEnter(venueId, deviceName); Venue venue = qrCodeService.initEnter(venueId, deviceName);
if (venue!=null){
Channel channel = ClientChannelCache.getCurrentChannel(deviceName,venueId ,enterOrOut); Channel channel = ClientChannelCache.getCurrentChannel(deviceName,venueId ,enterOrOut);
messageService.sendLoading(channel,memberId); messageService.sendLoading(channel,memberId);
}
return ResponseDTO.ok().addAttribute("venueInit", venue); return ResponseDTO.ok().addAttribute("venueInit", venue);
} }

1
entity/src/main/java/com/sv/exception/api/ExceptionCodeTemplate.java
View File

@@ -52,6 +52,7 @@ public class ExceptionCodeTemplate {
public static final ExceptionCode VENUE_ERROR = ExceptionCode.init(30023, "场馆暂未开放"); public static final ExceptionCode VENUE_ERROR = ExceptionCode.init(30023, "场馆暂未开放");
public static final ExceptionCode DEVICE_ERROR = ExceptionCode.init(30024, "未找到该设备"); public static final ExceptionCode DEVICE_ERROR = ExceptionCode.init(30024, "未找到该设备");
public static final ExceptionCode VENUE_TYPE_ERROR = ExceptionCode.init(30025, "该场馆暂不支持扫码入场");

10
service/src/main/java/com/sv/service/api/QRCodeService.java
View File

@@ -1,6 +1,7 @@
package com.sv.service.api; package com.sv.service.api;
import com.enums.DeviceType; import com.enums.DeviceType;
import com.enums.VenueTypeEnum;
import com.sv.entity.Venue; import com.sv.entity.Venue;
import com.sv.mapper.DeviceMapper; import com.sv.mapper.DeviceMapper;
import com.sv.mapper.VenueMapper; import com.sv.mapper.VenueMapper;
@@ -30,7 +31,14 @@ public class QRCodeService {
if (integer != 1){ if (integer != 1){
throw new ServiceException(com.sv.exception.api.ExceptionCodeTemplate.DEVICE_ERROR); throw new ServiceException(com.sv.exception.api.ExceptionCodeTemplate.DEVICE_ERROR);
} }
return venueMapper.findById(venueId); Venue venue = venueMapper.findById(venueId);
if (venue==null){
throw new ServiceException(com.sv.exception.api.ExceptionCodeTemplate.VENUE_ERROR);
}
if (!VenueTypeEnum.FITNESS.value.equals(venue.getType())){
throw new ServiceException(com.sv.exception.api.ExceptionCodeTemplate.VENUE_TYPE_ERROR);
}
return venue;
} }