视图库开发示例，拿来即用

package com.secusoft.server.service.impl; import com.google.common.collect.Lists; import com.secusoft.common.bean.DeviceViewBaseParam; import com.secusoft.common.bean.PlatformStatus; import com.secusoft.common.bean.enums.SubscriptionStatus; import com.secusoft.common.bean.requenst.APEsRequest; import com.secusoft.common.bean.requenst.SubscribeRequest; import com.secusoft.common.bean.response.QueryDeviceResponseObject; import com.secusoft.common.bean.response.ResponseListStatusObject; import com.secusoft.common.bean.response.ResponseStatus; import com.secusoft.common.bean.response.ResponseStatusListModeObject; import com.secusoft.common.bean.response.ResponseStatusObject; import com.secusoft.common.bean.subscribes.SubscribeBase; import com.secusoft.common.bean.subscribes.SubscribeListObject; import com.secusoft.common.bean.subscribes.SubscribeObjects; import com.secusoft.common.exceptions.CustomResponseListModeException; import com.secusoft.common.http.HttpResponseBean; import com.secusoft.common.http.RESTClient; import com.secusoft.common.system.DomainConstant; import com.secusoft.common.task.ScheduleTask; import com.secusoft.common.task.ScheduleUtil; import com.secusoft.common.task.TaskService; import com.secusoft.common.utils.CommonUtlis; import com.secusoft.common.utils.DateUtil; import com.secusoft.common.utils.GsonUtil; import com.secusoft.common.utils.URLParameter; import com.secusoft.server.entity.ViewLibraryDomainChannel; import com.secusoft.server.entity.ViewLibraryDomainDevice; import com.secusoft.server.entity.ViewLibraryDomainSubscribe; import com.secusoft.server.service.IViewLibraryDomainChannelService; import com.secusoft.server.service.IViewLibraryDomainDeviceService; import com.secusoft.server.service.IViewLibraryDomainSubscribeService; import com.secusoft.server.service.PlatformService; import lombok.extern.log4j.Log4j2; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import org.springframework.util.StringUtils; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.time.LocalDateTime; import java.util.Date; import java.util.List; import java.util.stream.Collectors; import static com.secusoft.common.bean.enums.StatusCodeEnum.PLATFORM_PARAMETER_FAIL; /** * @author ：dzp * @date ：Created in 2024/6/25 15:43 * @description： */ @Service @Log4j2 public class PlatformServiceImpl implements PlatformService, TaskService { @Resource private IViewLibraryDomainDeviceService viewLibraryDomainDeviceService; @Resource private IViewLibraryDomainChannelService viewLibraryDomainChannelService; @Resource private IViewLibraryDomainSubscribeService viewLibraryDomainSubscribeService; @Resource private IViewLibraryDomainSubscribeService domainSubscribeService; /** * 心跳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; @Override public 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, "注册成功"); } @Override public ResponseStatusObject unregister(DeviceViewBaseParam param, String url) { // 保存到domain_platform 中 设备id，状态(注销状态) viewLibraryDomainDeviceService.updateRegisterStatus(param.getDeviceId(), PlatformStatus.LOGGED_OUT.getValue()); ScheduleUtil.cancel( TASK_CASCADE_KEEP_KEY + param.getDeviceId() ); return ResponseStatusObject.initSuccess(url, param, "注销成功"); } @Override public ResponseStatusObject keepalive(DeviceViewBaseParam param, String url) { // 根据设备id修改 保活时间取最新时间 viewLibraryDomainDeviceService.updateRegisterStatus(param.getDeviceId(), PlatformStatus.ONLINE.getValue()); ScheduleUtil.start( new ScheduleTask(TASK_CASCADE_KEEP_KEY + param.getDeviceId(), this, "心跳未保活"), new Date(System.currentTimeMillis()+DEFAULT_HEARTBEAT_CYCLE*DEFAULT_MAX_HEARTBEAT_TIMEOUT_NUM * 1000) ); return ResponseStatusObject.initSuccess(url, param, "保活成功"); } @Override public ResponseStatusObject time(DeviceViewBaseParam param, String url) { return null; } @Override public 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()); } } } @Override public <E> void queryDeviceList(DeviceViewBaseParam param, APEsRequest apEsRequest, List<E> list) { ViewLibraryDomainDevice viewLibraryDomainDevice = viewLibraryDomainDeviceService.selectByDomainDeviceId(param.getDeviceId()); if (viewLibraryDomainDevice == null || StringUtils.isEmpty(viewLibraryDomainDevice.getRegisterHost())) { log.warn("viewLibraryDomainPlatform or registerHost is null======>>{}", param.getDeviceId()); return; } // 通过设备id 查询host String responseStr = RESTClient.getClientConnectionPool() .fetchByGetMethod(viewLibraryDomainDevice.getRegisterHost() + DomainConstant.REQUEST_VIID_APES + "?" + URLParameter.toUrlParams(apEsRequest),param); if (StringUtils.isEmpty(responseStr)) { return; } //mock // String responseStr = "{\"APEListObject\":{\"PageRecordNum\":5000,\"StartNum\":0,\"TotalNum\":1,\"APEObject\":[{\"ApeID\":\"868834683e1d4b76bf9ec3c837ea55ab\",\"Name\":\"Camera