package com.whyc.service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.whyc.dto.Response;
|
import com.whyc.mapper.VideoMapper;
|
import com.whyc.pojo.Video;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.sql.Date;
|
import java.util.List;
|
|
@Service
|
public class VideoService {
|
|
@Resource
|
private VideoMapper mapper;
|
|
public Response add(Video video) {
|
video.setAccessDate(new Date(System.currentTimeMillis()));
|
//初始化,新加入的视频设备,默认是显示在页面的.
|
video.setStatus(1);
|
mapper.insert(video);
|
return new Response().setMsg(1,"添加成功");
|
}
|
|
public Response getInfo(Integer id) {
|
Video video = mapper.selectById(id);
|
return new Response().set(1,video);
|
}
|
|
public Response getPage(Integer pageNum, Integer pageSize, Video video) {
|
PageHelper.startPage(pageNum,pageSize);
|
List<Video> videoList = mapper.getList();
|
//对机房站点名称进行处理
|
videoList.stream().forEach(video2 -> {
|
String[] nameSplit = video2.getStationName().split("-");
|
String newStationName = new StringBuilder()
|
.append(nameSplit[0]).append("-")
|
.append(nameSplit[1]).append("-")
|
.append(nameSplit[2]).append("-")
|
.append(nameSplit[3]).toString();
|
|
video2.setStationName(newStationName);
|
});
|
PageInfo<Video> videoPageInfo = new PageInfo<>(videoList);
|
return new Response().set(1,videoPageInfo);
|
}
|
|
public Response getAllShow() {
|
QueryWrapper<Video> wrapper = Wrappers.query();
|
wrapper.select("ip","name")
|
.eq("status",1);
|
List<Video> videoList = mapper.selectList(wrapper);
|
return new Response().set(1,videoList);
|
}
|
|
public Response updateStatus(Integer id, Integer status) {
|
mapper.updateById(new Video(id,status));
|
return new Response().setMsg(1,"状态更新成功");
|
}
|
}
|
