1078-添加录像回放列表查询

This commit is contained in:
648540858 2024-04-04 16:54:08 +08:00
parent 3e5da98539
commit 81c2b5715c
4 changed files with 26 additions and 11 deletions

View File

@ -1,19 +1,13 @@
package com.genersoft.iot.vmp.jt1078.config; package com.genersoft.iot.vmp.jt1078.config;
import com.genersoft.iot.vmp.common.InviteSessionType;
import com.genersoft.iot.vmp.common.StreamInfo;
import com.genersoft.iot.vmp.conf.UserSetting; import com.genersoft.iot.vmp.conf.UserSetting;
import com.genersoft.iot.vmp.conf.security.JwtUtils; import com.genersoft.iot.vmp.conf.security.JwtUtils;
import com.genersoft.iot.vmp.gb28181.bean.Device;
import com.genersoft.iot.vmp.jt1078.bean.JTDevice; import com.genersoft.iot.vmp.jt1078.bean.JTDevice;
import com.genersoft.iot.vmp.jt1078.cmd.JT1078Template;
import com.genersoft.iot.vmp.jt1078.proc.response.*;
import com.genersoft.iot.vmp.jt1078.service.Ijt1078Service; import com.genersoft.iot.vmp.jt1078.service.Ijt1078Service;
import com.genersoft.iot.vmp.service.bean.InviteErrorCode; import com.genersoft.iot.vmp.service.bean.InviteErrorCode;
import com.genersoft.iot.vmp.vmanager.bean.ErrorCode; import com.genersoft.iot.vmp.vmanager.bean.ErrorCode;
import com.genersoft.iot.vmp.vmanager.bean.StreamContent; import com.genersoft.iot.vmp.vmanager.bean.StreamContent;
import com.genersoft.iot.vmp.vmanager.bean.WVPResult; import com.genersoft.iot.vmp.vmanager.bean.WVPResult;
import com.genersoft.iot.vmp.vmanager.gb28181.play.PlayController;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter; import io.swagger.v3.oas.annotations.Parameter;
@ -30,7 +24,6 @@ import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import java.net.MalformedURLException; import java.net.MalformedURLException;
import java.net.URL; import java.net.URL;
import java.util.List;
/** /**
* curl http://localhost:18080/api/jt1078/start/live/18864197066/1 * curl http://localhost:18080/api/jt1078/start/live/18864197066/1
@ -146,6 +139,24 @@ public class JT1078Controller {
service.continueLivePlay(deviceId, channelId); service.continueLivePlay(deviceId, channelId);
} }
@Operation(summary = "1078-回放-查询资源列表", security = @SecurityRequirement(name = JwtUtils.HEADER))
@Parameter(name = "deviceId", description = "设备国标编号", required = true)
@Parameter(name = "channelId", description = "通道国标编号, 一般为从1开始的数字", required = true)
@Parameter(name = "startTime", description = "开始时间,格式: yyyy-MM-dd HH:mm:ss", required = true)
@Parameter(name = "endTime", description = "结束时间,格式: yyyy-MM-dd HH:mm:ss", required = true)
@GetMapping("/record/list")
public void playbackList(HttpServletRequest request,
@Parameter(required = true) String deviceId,
@Parameter(required = false) String channelId,
@Parameter(required = true) String startTime,
@Parameter(required = true) String endTime
) {
if (ObjectUtils.isEmpty(channelId)) {
channelId = "1";
}
service.getRecordList(deviceId, channelId, startTime, endTime);
}
@Operation(summary = "分页查询部标设备", security = @SecurityRequirement(name = JwtUtils.HEADER)) @Operation(summary = "分页查询部标设备", security = @SecurityRequirement(name = JwtUtils.HEADER))
@Parameter(name = "page", description = "当前页", required = true) @Parameter(name = "page", description = "当前页", required = true)
@Parameter(name = "count", description = "每页查询数量", required = true) @Parameter(name = "count", description = "每页查询数量", required = true)

View File

@ -52,7 +52,7 @@ public class J1205 extends Re {
@Override @Override
protected Rs handler(Header header, Session session, Ijt1078Service service) { protected Rs handler(Header header, Session session, Ijt1078Service service) {
SessionManager.INSTANCE.response(header.getTerminalId(), "1205", (long) respNo, JSON.toJSONString(this)); SessionManager.INSTANCE.response(header.getTerminalId(), "1205", (long) respNo, JSON.toJSONString(this));
service.notifyRecordList()
J8001 j8001 = new J8001(); J8001 j8001 = new J8001();
j8001.setRespNo(header.getSn()); j8001.setRespNo(header.getSn());
j8001.setRespId(header.getMsgId()); j8001.setRespId(header.getMsgId());

View File

@ -1,13 +1,10 @@
package com.genersoft.iot.vmp.jt1078.service; package com.genersoft.iot.vmp.jt1078.service;
import com.genersoft.iot.vmp.common.CommonCallback;
import com.genersoft.iot.vmp.common.GeneralCallback; import com.genersoft.iot.vmp.common.GeneralCallback;
import com.genersoft.iot.vmp.common.StreamInfo; import com.genersoft.iot.vmp.common.StreamInfo;
import com.genersoft.iot.vmp.jt1078.bean.JTDevice; import com.genersoft.iot.vmp.jt1078.bean.JTDevice;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import java.util.List;
public interface Ijt1078Service { public interface Ijt1078Service {
JTDevice getDevice(String terminalId); JTDevice getDevice(String terminalId);
@ -28,4 +25,6 @@ public interface Ijt1078Service {
void pausePlay(String deviceId, String channelId); void pausePlay(String deviceId, String channelId);
void continueLivePlay(String deviceId, String channelId); void continueLivePlay(String deviceId, String channelId);
void getRecordList(String deviceId, String channelId, String startTime, String endTime);
} }

View File

@ -255,4 +255,9 @@ public class jt1078ServiceImpl implements Ijt1078Service {
j9102.setStreamType(1); j9102.setStreamType(1);
jt1078Template.stopLive(deviceId, j9102, 6); jt1078Template.stopLive(deviceId, j9102, 6);
} }
@Override
public void getRecordList(String deviceId, String channelId, String startTime, String endTime) {
}
} }