ZLMediaKit+SpringBoot+Vue+Geoserver实现拉取摄像头rtsp流并在web端播放

package com.ruoyi.system.service.impl; import com.ruoyi.common.constant.RedisPTConstants; import com.ruoyi.common.core.domain.AjaxResult; import com.ruoyi.common.core.redis.RedisCache; import com.ruoyi.system.domain.BusStreamMediaVideo; import com.ruoyi.system.domain.BusStreamMediaVideoParamDto; import com.ruoyi.system.mapper.BusStreamMediaVideoMapper; import com.ruoyi.system.service.IBusStreamMediaVideoService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.math.BigDecimal; import java.util.List; @Service public class BusStreamMediaVideoServiceImpl implements IBusStreamMediaVideoService { @Autowired private BusStreamMediaVideoMapper busStreamMediaVideoMapper; @Autowired private RedisCache redisService; @Override public BusStreamMediaVideoParamDto getStreamMediaParam() { if(redisService.hasKey(RedisPTConstants.STREAMMEDIAPARAM)){ BusStreamMediaVideoParamDto busStreamMediaVideoParamDto = redisService.getCacheObject(RedisPTConstants.STREAMMEDIAPARAM); return busStreamMediaVideoParamDto; }else { return new BusStreamMediaVideoParamDto(); } } @Override public AjaxResult setStreamMediaParam(BusStreamMediaVideoParamDto busStreamMediaVideoDto) { try { redisService.setCacheObject(RedisPTConstants.STREAMMEDIAPARAM,busStreamMediaVideoDto); return AjaxResult.success(); }catch (Exception exception){ return AjaxResult.error(); } } /** * 查询摄像头参数 * * @param id 摄像头参数ID * @return 摄像头参数 */ @Override public BusStreamMediaVideo selectBusStreamMediaVideoById(Long id) { return busStreamMediaVideoMapper.selectBusStreamMediaVideoById(id); } /** * 查询摄像头参数列表 * * @param BusStreamMediaVideo 摄像头参数 * @return 摄像头参数 */ @Override public List<BusStreamMediaVideo> selectBusStreamMediaVideoList(BusStreamMediaVideo BusStreamMediaVideo) { List<BusStreamMediaVideo> BusStreamMediaVideos = busStreamMediaVideoMapper.selectBusStreamMediaVideoList(BusStreamMediaVideo); BusStreamMediaVideos.forEach(videos -> { if (videos.getAreaName() != null) { String[] point = videos.getAreaName().substring(1, videos.getAreaName().length() - 1).split(","); if (!point[0].equals("null") && !point[1].equals("null")) { videos.setSiteX(new BigDecimal(point[0])); videos.setSiteY(new BigDecimal(point[1])); } } }); return BusStreamMediaVideos; } /** * 新增摄像头参数 * * @param BusStreamMediaVideo 摄像头参数 * @return 结果 */ @Override public int insertBusStreamMediaVideo(BusStreamMediaVideo BusStreamMediaVideo) { String area = "[" + BusStreamMediaVideo.getSiteX() + "," + BusStreamMediaVideo.getSiteY() + "]"; BusStreamMediaVideo.setAreaName(area); return busStreamMediaVideoMapper.insertBusStreamMediaVideo(BusStreamMediaVideo); } /** * 修改摄像头参数 * * @param BusStreamMediaVideo 摄像头参数 * @return 结果 */ @Override public int updateBusStreamMediaVideo(BusStreamMediaVideo BusStreamMediaVideo) { String area = "[" + BusStreamMediaVideo.getSiteX() + "," + BusStreamMediaVideo.getSiteY() + "]"; BusStreamMediaVideo.setAreaName(area); return busStreamMediaVideoMapper.updateBusStreamMediaVideo(BusStreamMediaVideo); } /** * 批量删除摄像头参数 * * @param ids 需要删除的摄像头参数ID * @return 结果 */ @Override public int deleteBusStreamMediaVideoByIds(Long[] ids) { return busStreamMediaVideoMapper.deleteBusStreamMediaVideoByIds(ids); } /** * 删除摄像头参数信息 * * @param id 摄像头参数ID * @return 结果 */ @Override public int deleteBusStreamMediaVideoById(Long id) { return busStreamMediaVideoMapper.deleteBusStreamMediaVideoById(id); } }