From f93ee1a42e8c47e472332287b7350b66a6b0fa11 Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期五, 24 七月 2020 18:28:57 +0800 Subject: [PATCH] 保存触发id之后的视频作为触发视频 --- goffmpeg.go | 83 +++++++++++++++++++++++++++++++++++++---- 1 files changed, 75 insertions(+), 8 deletions(-) diff --git a/goffmpeg.go b/goffmpeg.go index dedb2bf..bca75d2 100644 --- a/goffmpeg.go +++ b/goffmpeg.go @@ -12,6 +12,39 @@ "unsafe" ) +const ( + // ScaleNone self add no scale raw frame data + ScaleNone = 0 + // ScaleFastBilinear SWS_FAST_BILINEAR + ScaleFastBilinear = 1 + // ScaleBilinear SWS_BILINEAR + ScaleBilinear = 2 + // ScaleBicubic SWS_BICUBIC + ScaleBicubic = 4 + // ScaleX SWS_X + ScaleX = 8 + // ScalePoint SWS_POINT + ScalePoint = 0x10 + // ScaleArea SWS_AREA + ScaleArea = 0x20 + // ScaleBicublin SWS_BICUBLIN + ScaleBicublin = 0x40 + // ScaleGauss SWS_GAUSS + ScaleGauss = 0x80 + // ScaleSinc SWS_SINC + ScaleSinc = 0x100 + // ScaleLancZos SWS_LANCZOS + ScaleLancZos = 0x200 + // ScaleSpline SWS_SPLINE + ScaleSpline = 0x400 +) + +// SrcFormat format NV +const SrcFormat = 23 + +// DstFormat format +const DstFormat = 3 + var libcffmpeg C.libcffmpeg // InitFFmpeg init ffmepg @@ -42,16 +75,16 @@ // New 2nd new func New(GB, CPU bool) *GoFFMPEG { - f := C.wrap_fn_create() + f := C.wrap_fn_create(unsafe.Pointer(libcffmpeg)) if f == nil { return nil } if GB { - C.wrap_fn_run_gb28181(f) + C.wrap_fn_run_gb28181(unsafe.Pointer(libcffmpeg), f) } if CPU { - C.wrap_fn_use_cpu(f) + C.wrap_fn_use_cpu(unsafe.Pointer(libcffmpeg), f) } return &GoFFMPEG{ @@ -64,15 +97,15 @@ lf := C.CString(ffmpegLog) defer C.free(unsafe.Pointer(lf)) - f := C.wrap_fn_create2(lf) + f := C.wrap_fn_create2(unsafe.Pointer(libcffmpeg), lf) if f == nil { return nil } if GB { - C.wrap_fn_run_gb28181(f) + C.wrap_fn_run_gb28181(unsafe.Pointer(libcffmpeg), f) } if CPU { - C.wrap_fn_use_cpu(f) + C.wrap_fn_use_cpu(unsafe.Pointer(libcffmpeg), f) } return &GoFFMPEG{ @@ -83,7 +116,7 @@ // Free free handle func (h *GoFFMPEG) Free() { if h.ffmpeg != nil { - C.wrap_fn_destroy(h.ffmpeg) + C.wrap_fn_destroy(unsafe.Pointer(libcffmpeg), h.ffmpeg) } } @@ -92,5 +125,39 @@ in := C.CString(input) defer C.free(unsafe.Pointer(in)) - C.wrap_fn_run(h.ffmpeg, in) + C.wrap_fn_run(unsafe.Pointer(libcffmpeg), h.ffmpeg, in) +} + +// Run2 ffmpeg +func (h *GoFFMPEG) Run2(input string, minDuration int) { + in := C.CString(input) + defer C.free(unsafe.Pointer(in)) + + C.wrap_fn_run(unsafe.Pointer(libcffmpeg), h.ffmpeg, in) +} + +// FPS fps +func (h *GoFFMPEG) FPS() int { + return int(C.wrap_fn_fps(unsafe.Pointer(libcffmpeg), h.ffmpeg)) +} + +// ReleaseC release c memory +func ReleaseC(p unsafe.Pointer) { + if p == nil { + return + } + C.free(unsafe.Pointer(p)) +} + +// GetGBJpg Get GB28181 Jpg +func GetGBJpg(rtspUrl string) []byte { + rtsp := C.CString(rtspUrl) + defer C.free(unsafe.Pointer(rtsp)) + var jpgLen C.int + + pic := C.wrap_fn_get_gb28181_pic(unsafe.Pointer(libcffmpeg), rtsp, &jpgLen) + defer C.free(unsafe.Pointer(pic)) + + retJpg := C.GoBytes(unsafe.Pointer(pic), jpgLen) + return retJpg } -- Gitblit v1.8.0