ljydlv
/
videoplayer
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修复创建视频记录的删除时间，无时间时自动执行延迟20天删除。

This commit is contained in:
junleea 2024-06-05 17:06:29 +08:00
parent ca29a55908
commit db4397ad56
3 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
dao/video.go
View File

@ -21,16 +21,19 @@ type Video struct {
func FindWillDelVideoList(id int) []Video { func FindWillDelVideoList(id int) []Video {
var videos []Video var videos []Video
DB.Debug().Where("auth_id = ?", id).Where("delete_time<=now()").Find(&videos) DB.Debug().Where("auth_id = ?", id).Where("delete_time<=now()").Where("isdelete=0").Find(&videos)
return videos return videos
} }
func CreateVideo(videoPath, videoName string, cameraID, authID, human, isDelete int, createTime, endTime string, fileSize int) uint { func CreateVideo(videoPath, videoName string, cameraID, authID, human, isDelete int, createTime, endTime, deleteTime string, fileSize int) uint {
video := Video{VideoPath: videoPath, VideoName: videoName, CameraID: cameraID, AuthId: authID, Human: human, IsDelete: isDelete, CreateTime: createTime, EndTime: endTime, FileSize: fileSize} video := Video{VideoPath: videoPath, VideoName: videoName, CameraID: cameraID, AuthId: authID, Human: human, IsDelete: isDelete, CreateTime: createTime, EndTime: endTime, DeleteTime: deleteTime, FileSize: fileSize}
res := DB.Debug().Create(&video) res := DB.Debug().Create(&video)
if res.Error != nil { if res.Error != nil {
return 0 return 0
} }
if deleteTime == "" {
DB.Debug().Exec("update videos set delete_time= DATE_ADD(NOW(), INTERVAL 20 DAY) where id=?", video.ID) //delete_time= DATE_ADD(NOW(), INTERVAL 20 DAY)
}
return video.ID return video.ID
} }

2
handler/video.go
View File

@ -137,7 +137,7 @@ func CreateVideo(c *gin.Context) {
user_id, _ := c.Get("id") user_id, _ := c.Get("id")
if err := c.ShouldBind(&video_req); err == nil { if err := c.ShouldBind(&video_req); err == nil {
fmt.Println(video_req) fmt.Println(video_req)
id := service.CreateVideo(video_req.VideoPath, video_req.VideoName, video_req.CameraID, int(user_id.(float64)), video_req.Human, video_req.IsDelete, video_req.CreateTime, video_req.EndTime, video_req.FileSize) id := service.CreateVideo(video_req.VideoPath, video_req.VideoName, video_req.CameraID, int(user_id.(float64)), video_req.Human, video_req.IsDelete, video_req.CreateTime, video_req.EndTime, video_req.DeleteTime, video_req.FileSize)
if id == 0 { if id == 0 {
c.JSON(http.StatusOK, gin.H{"error": "create video failed", "code": 1, "message": "failed"}) c.JSON(http.StatusOK, gin.H{"error": "create video failed", "code": 1, "message": "failed"})
return return

4
service/videoService.go
View File

@ -42,8 +42,8 @@ func DelayAllVideo(id, day int) int {
return dao.DelayAllVideo(id, day) return dao.DelayAllVideo(id, day)
} }
func CreateVideo(videoPath, videoName string, cameraID, authID, human, isDelete int, createTime, endTime string, fileSize int) uint { func CreateVideo(videoPath, videoName string, cameraID, authID, human, isDelete int, createTime, endTime, deleteTime string, fileSize int) uint {
return dao.CreateVideo(videoPath, videoName, cameraID, authID, human, isDelete, createTime, endTime, fileSize) return dao.CreateVideo(videoPath, videoName, cameraID, authID, human, isDelete, createTime, endTime, deleteTime, fileSize)
} }
func DeleteVideo(id, user int) int { func DeleteVideo(id, user int) int {