视图库对接系列(GA-T 1400)四、视图库对接系列(本级)注册

视图库对接系列(本级)注册

在之前的步骤中，我们已经把项目大体的架构已经写出来了。那我们就来实现注册接口。

GA-T 1400中的步骤如下：

在这里插入图片描述
这里的话，我们实现的简单点，我们不进去鉴权，也就是设备或平台找我们注册的话，我们直接返回成功，不进行验证。
如果需要鉴权的话可看我的另外一篇文档。
视图库对接系列(GA-T 1400)七、视图库对接系列(本级)注册(包含鉴权)

注册前准备

因为视图库对接主要是解析、验证解析。所以我们先暂时把对应的文件创建好，这里的话我就直接先放截图，到时候有需要的直接加群拿，我把项目放在群里把。
在这里插入图片描述

注册

service层

我把注册、注销、保活、校时的接口一起写好，后续我们直接实现就可以了。

在common中添加ViewLibCommonRequestService

public interface ViewLibCommonRequestService {//注册ResponseStatusObject register(DeviceViewBaseParam param);//注销ResponseStatusObject unregister(DeviceViewBaseParam param);//保活ResponseStatusObject keepalive(DeviceViewBaseParam param);//校时ResponseStatusObject time(DeviceViewBaseParam param);
}

在server中添加PlatformService继承ViewLibCommonRequestService就可以了

public interface PlatformService extends ViewLibCommonRequestService {
}

service层实现

@Service
public class PlatformServiceImpl implements PlatformService, TaskService {@Resourceprivate IViewLibraryDomainDeviceService viewLibraryDomainDeviceService;/*** 心跳key*/public static final String TASK_CASCADE_KEEP_KEY = "platform_keep_alive";/*** 默认心跳周期*/public static final Integer DEFAULT_HEARTBEAT_CYCLE = 3;/*** 默认最大心跳超时时间*/public static final Integer DEFAULT_MAX_HEARTBEAT_TIMEOUT_NUM = 60;@Overridepublic ResponseStatusObject register(DeviceViewBaseParam param, String url) {int heartbeatCycle = DEFAULT_HEARTBEAT_CYCLE;int maxHeartbeatTimeoutNum = DEFAULT_MAX_HEARTBEAT_TIMEOUT_NUM;// 保存到domain_platform 中 设备id，状态(注册默认在线，保活时间取最新时间)ViewLibraryDomainDevice domainPlatform = viewLibraryDomainDeviceService.selectByDomainDeviceId(param.getDeviceId());if (domainPlatform == null) {viewLibraryDomainDeviceService.save(new ViewLibraryDomainDevice(param.getDeviceId(), PlatformStatus.ONLINE.getValue(), LocalDateTime.now(), DEFAULT_HEARTBEAT_CYCLE, DEFAULT_MAX_HEARTBEAT_TIMEOUT_NUM));} else {viewLibraryDomainDeviceService.updateRegisterStatus(param.getDeviceId(), PlatformStatus.ONLINE.getValue());heartbeatCycle = domainPlatform.getHeartbeatCycle();maxHeartbeatTimeoutNum = domainPlatform.getMaxHeartbeatTimeoutNum();}ScheduleUtil.start(new ScheduleTask(TASK_CASCADE_KEEP_KEY + param.getDeviceId(), this, ""),new Date(System.currentTimeMillis() + heartbeatCycle * maxHeartbeatTimeoutNum * 1000 * 1000));return ResponseStatusObject.initSuccess(url, param, "注册成功");}@Overridepublic ResponseStatusObject unregister(DeviceViewBaseParam param, String url) {return null;}@Overridepublic ResponseStatusObject keepalive(DeviceViewBaseParam param, String url) {return null;}@Overridepublic ResponseStatusObject time(DeviceViewBaseParam param, String url) {return null;}@Overridepublic void work(String id, String keyword) {String platformId = id.replace(TASK_CASCADE_KEEP_KEY, "");ViewLibraryDomainDevice viewLibraryDomainPlatform = viewLibraryDomainDeviceService.selectByDomainDeviceId(platformId);if (viewLibraryDomainPlatform != null) {LocalDateTime latestKeepAliveTime = viewLibraryDomainPlatform.getLatestKeepAliveTime();if (latestKeepAliveTime == null) {viewLibraryDomainDeviceService.updateRegisterStatus(viewLibraryDomainPlatform.getDeviceId(), PlatformStatus.LOGGED_OUT.getValue());return;}if (DateUtil.isAfterAddingSeconds(LocalDateTime.now(), latestKeepAliveTime, viewLibraryDomainPlatform.getMaxHeartbeatTimeoutNum() * viewLibraryDomainPlatform.getHeartbeatCycle())) {viewLibraryDomainDeviceService.updateRegisterStatus(viewLibraryDomainPlatform.getDeviceId(), PlatformStatus.LOGGED_OUT.getValue());}}}

这里有个TaskService实现，我稍微说一下。因为设备需要每隔一段时间给我们一个心跳，所以我们封装了一个定时器回调，回调方法是work。每隔多久对比一下时间，将状态进行更改。

设备层service

public interface IViewLibraryDomainDeviceService extends IService<ViewLibraryDomainDevice> {void updateRegisterStatus(String deviceId,Integer status);ViewLibraryDomainDevice selectByDomainDeviceId(String deviceId);
}

设备层service实现

@Service
public class ViewLibraryDomainDeviceServiceImpl extends ServiceImpl<ViewLibraryDomainDeviceMapper, ViewLibraryDomainDevice> implements IViewLibraryDomainDeviceService {@Overridepublic void updateRegisterStatus(String deviceId, Integer status) {LambdaUpdateWrapper<ViewLibraryDomainDevice> queryWrapper = Wrappers.lambdaUpdate();queryWrapper.eq(ViewLibraryDomainDevice::getDeviceId,deviceId);ViewLibraryDomainDevice domainPlatform = new ViewLibraryDomainDevice();domainPlatform.setDeviceStatus(status);domainPlatform.setLatestKeepAliveTime(LocalDateTime.now());this.baseMapper.update(domainPlatform,queryWrapper);}@Overridepublic ViewLibraryDomainDevice selectByDomainDeviceId(String deviceId) {LambdaQueryWrapper<ViewLibraryDomainDevice> queryWrapper = Wrappers.lambdaQuery();queryWrapper.eq(ViewLibraryDomainDevice::getDeviceId, deviceId);return  this.baseMapper.selectOne(queryWrapper);}
}

##Controller层

@RestController
@CrossOrigin(value = "*", maxAge = 3600)
@RequestMapping("/VIID")
@RequestLog(logReturn = true)
public class PlatformController {@Resourceprivate PlatformService platformService;//-------------------------------------------------设备或平台请求------------------------------------------@PostMapping("/System/Register")public ResponseStatusObject register(@RequestBody RegisterObjectRequest param, HttpServletRequest request, HttpServletResponse response) {String userIdentify = CommonUtlis.getUserIdentify(request);//{"RegisterObject":{"RequestURL":"/VIID/System/Register","StatusCode":0,"StatusString":"注册成功","Id":"33048300005030000237","LocalTime":"20220826085911"}}if(param == null || param.getDeviceBaseParam()== null || StringUtils.isEmpty(param.getDeviceBaseParam().getId())) {return ResponseStatusObject.initFailCode(request.getRequestURI(),userIdentify,String.valueOf( StatusCodeEnum.PLATFORM_PARAMETER_FAIL.getCode()));}return platformService.register(param.getDeviceBaseParam(),request.getRequestURI());}}