diff --git a/dao/device.go b/dao/device.go index 07254bd..70c54b8 100644 --- a/dao/device.go +++ b/dao/device.go @@ -18,7 +18,7 @@ type Device struct { func CreateDevice(authID int, deviceName, deviceType string, deviceStatus, deviceLocation, deviceIP, deviceInfo string) uint { device := Device{AuthID: authID, DeviceName: deviceName, DeviceType: deviceType, DeviceStatus: deviceStatus, DeviceLocation: deviceLocation, DeviceIP: deviceIP, DeviceInfo: deviceInfo} - result := DB.Debug().Create(&device) + result := DB.Create(&device) if result.Error != nil { fmt.Println("CreateDevice failed", result.Error) return 0 @@ -27,7 +27,7 @@ func CreateDevice(authID int, deviceName, deviceType string, deviceStatus, devic } func DeleteDeviceByID(id, user int) bool { - res := DB.Debug().Model(&Device{}).Where("id = ? and auth_id = ?", id, user).Delete(&Device{}) + res := DB.Model(&Device{}).Where("id = ? and auth_id = ?", id, user).Delete(&Device{}) if res.Error != nil { return false } @@ -36,18 +36,18 @@ func DeleteDeviceByID(id, user int) bool { func FindDeviceByID(id, auth_id int) Device { var device Device - DB.Debug().Where("id = ? and auth_id = ?", id, auth_id).First(&device) + DB.Where("id = ? and auth_id = ?", id, auth_id).First(&device) return device } func FindDeviceByAuthID(auth_id int) []Device { var devices []Device - DB.Debug().Where("auth_id = ?", auth_id).Find(&devices) + DB.Where("auth_id = ?", auth_id).Find(&devices) return devices } func SetDeviceStatus(status string, id, auth_id int) bool { - result := DB.Debug().Model(&Device{}).Where("id = ? and auth_id = ?", id, auth_id).Updates(Device{DeviceStatus: status}) + result := DB.Model(&Device{}).Where("id = ? and auth_id = ?", id, auth_id).Updates(Device{DeviceStatus: status}) if result.Error != nil { return false } @@ -78,7 +78,7 @@ func UpdateDeviceByID(id, auth_id int, deviceName, deviceType, deviceStatus, dev deviceInfo = pd.DeviceInfo } } - res := DB.Debug().Model(&Device{}).Where("id = ? and auth_id = ?", id, auth_id).Updates(Device{DeviceName: deviceName, DeviceType: deviceType, DeviceStatus: deviceStatus, DeviceLocation: deviceLocation, DeviceIP: deviceIP, DeviceInfo: deviceInfo}) + res := DB.Model(&Device{}).Where("id = ? and auth_id = ?", id, auth_id).Updates(Device{DeviceName: deviceName, DeviceType: deviceType, DeviceStatus: deviceStatus, DeviceLocation: deviceLocation, DeviceIP: deviceIP, DeviceInfo: deviceInfo}) if res.Error != nil { return false } diff --git a/dao/file.go b/dao/file.go index bb0be6a..54b79cb 100644 --- a/dao/file.go +++ b/dao/file.go @@ -15,7 +15,7 @@ type File struct { func CreateFile(fileStoreName, fileName, fileType, filePath string, fileSize, authID int) uint { file := File{FileStoreName: fileStoreName, FileName: fileName, FileType: fileType, FilePath: filePath, FileSize: fileSize, AuthID: authID} - result := DB.Debug().Create(&file) + result := DB.Create(&file) if result.Error != nil { return 0 } @@ -23,7 +23,7 @@ func CreateFile(fileStoreName, fileName, fileType, filePath string, fileSize, au } func DeleteFileByID(id, user int) bool { - res := DB.Debug().Model(&File{}).Where("id = ? and auth_id = ?", id, user).Delete(&File{}) + res := DB.Model(&File{}).Where("id = ? and auth_id = ?", id, user).Delete(&File{}) if res.Error != nil { return false } @@ -32,19 +32,19 @@ func DeleteFileByID(id, user int) bool { func FindFileByID(id, auth_id int) File { var file File - DB.Debug().Where("id = ? and auth_id = ?", id, auth_id).First(&file) + DB.Where("id = ? and auth_id = ?", id, auth_id).First(&file) return file } func FindFileByNames(fileName string, auth_id int) File { var file File - DB.Debug().Where("file_name = ? and auth_id = ?", fileName, auth_id).First(&file) + DB.Where("file_name = ? and auth_id = ?", fileName, auth_id).First(&file) return file } func FindFileByAuthID(auth_id int) []File { var files []File - DB.Debug().Where("auth_id = ?", auth_id).Find(&files) + DB.Where("auth_id = ?", auth_id).Find(&files) return files } @@ -53,7 +53,7 @@ func UpdateFileByID(id, auth_id int, fileStoreName, fileName, fileType, filePath if pd.ID == 0 { return false } - result := DB.Debug().Model(&File{}).Where("id = ? and auth_id = ?", id, auth_id).Updates(File{FileStoreName: fileStoreName, FileName: fileName, FileType: fileType, FilePath: filePath, FileSize: fileSize}) + result := DB.Model(&File{}).Where("id = ? and auth_id = ?", id, auth_id).Updates(File{FileStoreName: fileStoreName, FileName: fileName, FileType: fileType, FilePath: filePath, FileSize: fileSize}) if result.Error != nil { return false } @@ -61,7 +61,7 @@ func UpdateFileByID(id, auth_id int, fileStoreName, fileName, fileType, filePath } func DeleteFileByAuthID(auth_id int) bool { - res := DB.Debug().Model(&File{}).Where("auth_id = ?", auth_id).Delete(&File{}) + res := DB.Model(&File{}).Where("auth_id = ?", auth_id).Delete(&File{}) if res.Error != nil { return false } @@ -69,7 +69,7 @@ func DeleteFileByAuthID(auth_id int) bool { } func DeleteFileById(id int) bool { - res := DB.Debug().Model(&File{}).Where("id = ?", id).Delete(&File{}) + res := DB.Model(&File{}).Where("id = ?", id).Delete(&File{}) if res.Error != nil { return false } diff --git a/dao/im.go b/dao/im.go index d06b52d..5081eaa 100644 --- a/dao/im.go +++ b/dao/im.go @@ -40,13 +40,13 @@ type Friend struct { // 创建单聊消息 func CreateSimpleMessage(from_user_id, to_user_id int, message string) (error, uint) { msg := Message{FromUserID: from_user_id, ToUserID: to_user_id, Msg: message, Type: proto.MSG_TYPE_SIMPLE, Status: proto.MSG_STATUS_UNREAD} - res := DB.Debug().Create(&msg) + res := DB.Create(&msg) return res.Error, msg.ID } func CreateGeneralMessage(from_user_id, to_user_id, msg_type, status, group_id int, message string) (error error, id uint) { msg := Message{FromUserID: from_user_id, ToUserID: to_user_id, Msg: message, Type: msg_type, Status: status, GroupID: group_id} - res := DB.Debug().Create(&msg) + res := DB.Create(&msg) return res.Error, msg.ID } @@ -55,13 +55,13 @@ func GetMsgUserByIndex(from_user_id, to_user_id, msg_type, index, status int) ([ var msgs []Message var res *gorm.DB if msg_type == 4 { - res = DB.Debug().Where("from_user_id = ? and to_user_id = ? and type = ? and status = ? ", from_user_id, to_user_id, msg_type, status).Order("created_at DESC").Limit(20 * index).Find(&msgs) + res = DB.Where("from_user_id = ? and to_user_id = ? and type = ? and status = ? ", from_user_id, to_user_id, msg_type, status).Order("created_at DESC").Limit(20 * index).Find(&msgs) } else if msg_type == 1 { //单聊,只有两个人的消息 - res = DB.Debug().Raw("select * from messages where (from_user_id = ? AND to_user_id = ?) and type = ? or (from_user_id = ? AND to_user_id = ?) and type = ? order by created_at desc limit ?", from_user_id, to_user_id, msg_type, to_user_id, from_user_id, msg_type, 20*index).Scan(&msgs) - //res = DB.Debug().Where("(from_user_id = ? AND to_user_id = ?) or (from_user_id = ? AND to_user_id = ?) and type = ? ", from_user_id, to_user_id, to_user_id, from_user_id, msg_type).Order("created_at DESC").Limit(20 * index).Find(&msgs) + res = DB.Raw("select * from messages where (from_user_id = ? AND to_user_id = ?) and type = ? or (from_user_id = ? AND to_user_id = ?) and type = ? order by created_at desc limit ?", from_user_id, to_user_id, msg_type, to_user_id, from_user_id, msg_type, 20*index).Scan(&msgs) + //res = DB.Where("(from_user_id = ? AND to_user_id = ?) or (from_user_id = ? AND to_user_id = ?) and type = ? ", from_user_id, to_user_id, to_user_id, from_user_id, msg_type).Order("created_at DESC").Limit(20 * index).Find(&msgs) } else { - res = DB.Debug().Where("from_user_id = ? and to_user_id = ? and type = ? ", from_user_id, to_user_id, msg_type).Order("created_at DESC").Limit(20 * index).Find(&msgs) + res = DB.Where("from_user_id = ? and to_user_id = ? and type = ? ", from_user_id, to_user_id, msg_type).Order("created_at DESC").Limit(20 * index).Find(&msgs) } return msgs, res.Error } @@ -73,27 +73,27 @@ type GroupMessage struct { func GetMsgGroupByIndex(group_id, index int) ([]GroupMessage, error) { var msgs []GroupMessage - res := DB.Debug().Raw("select messages.*,users.name from messages join users on messages.from_user_id = users.id where type = 2 and group_id = ? order by created_at desc limit ?", group_id, 20*index).Scan(&msgs) + res := DB.Raw("select messages.*,users.name from messages join users on messages.from_user_id = users.id where type = 2 and group_id = ? order by created_at desc limit ?", group_id, 20*index).Scan(&msgs) return msgs, res.Error } func GetGroupRequestUsers(user_id int) []FriendRequest { var users []FriendRequest - DB.Debug().Raw("select id,im_id,name,email FROM (SELECT im_id,from_user_id,group_id FROM (( SELECT id as im_id,from_user_id,group_id FROM messages WHERE type=? and status=? ) as m JOIN groups as g on g.id=m.group_id ) where g.auth_id=? ) as e JOIN users as u ON e.from_user_id=u.id", proto.MSG_TYPE_GROUP_INVI, 0, user_id).Scan(&users) + DB.Raw("select id,im_id,name,email FROM (SELECT im_id,from_user_id,group_id FROM (( SELECT id as im_id,from_user_id,group_id FROM messages WHERE type=? and status=? ) as m JOIN groups as g on g.id=m.group_id ) where g.auth_id=? ) as e JOIN users as u ON e.from_user_id=u.id", proto.MSG_TYPE_GROUP_INVI, 0, user_id).Scan(&users) return users } func GetMsgUserGroupReq(from_user_id, group_id int) ([]Message, error) { var msgs []Message - res := DB.Debug().Where("from_user_id = ? and group_id = ? and type = ? and status = ?", from_user_id, group_id, 5, 0).Find(&msgs) + res := DB.Where("from_user_id = ? and group_id = ? and type = ? and status = ?", from_user_id, group_id, 5, 0).Find(&msgs) return msgs, res.Error } // 获取邀请消息 func GetFriendGroupReq(user_id int) ([]Message, error) { var msgs []Message - res := DB.Debug().Where("to_user_id = ? and type = ?", user_id, proto.MSG_TYPE_FRIEND).Find(&msgs) + res := DB.Where("to_user_id = ? and type = ?", user_id, proto.MSG_TYPE_FRIEND).Find(&msgs) return msgs, res.Error } @@ -146,21 +146,21 @@ func DeleteFriend(user_id, friend_id int) error { // 通过id查找消息 func FindMessageByID(id uint) []Message { var msgs []Message - DB.Debug().Where("id = ?", id).Find(&msgs) + DB.Where("id = ?", id).Find(&msgs) return msgs } // 通过id查找消息（包括name) func FindMessageByID2(id uint) []GroupMessage { var msgs []GroupMessage - DB.Debug().Raw("select messages.*,users.name from messages join users on messages.from_user_id = users.id where messages.id = ?", id).Scan(&msgs) + DB.Raw("select messages.*,users.name from messages join users on messages.from_user_id = users.id where messages.id = ?", id).Scan(&msgs) return msgs } // 更新消息状态 func UpdateMessageStatus(id uint, status int) error { - res := DB.Debug().Model(&Message{}).Where("id = ?", id).Update("status", status) + res := DB.Model(&Message{}).Where("id = ?", id).Update("status", status) return res.Error } @@ -188,45 +188,45 @@ func CreateGroup(groupName, groupInfo, groupType, groupIcon string, user_id int) // 查找用户是否在群聊 func FindGroupUser(user_id, group_id int) []GroupUser { var groupUsers []GroupUser - DB.Debug().Where("user_id = ? and group_id = ?", user_id, group_id).Find(&groupUsers) + DB.Where("user_id = ? and group_id = ?", user_id, group_id).Find(&groupUsers) return groupUsers } // 加入群聊 func JoinGroup(group_id, user_id int) (error, uint) { groupUser := GroupUser{GroupID: group_id, UserID: user_id} - res := DB.Debug().Create(&groupUser) + res := DB.Create(&groupUser) return res.Error, groupUser.ID } // 退出群聊 func QuitGroup(group_id, user_id int) error { - res := DB.Debug().Delete(&GroupUser{}, "group_id = ? and user_id = ?", group_id, user_id) + res := DB.Delete(&GroupUser{}, "group_id = ? and user_id = ?", group_id, user_id) return res.Error } // 根据群id查找群 func FindGroup(group_id int) []Group { var groups []Group - DB.Debug().Where("id = ?", group_id).Find(&groups) + DB.Where("id = ?", group_id).Find(&groups) return groups } // 删除群聊 func DeleteGroup(group_id int, auth_id int) error { - res := DB.Debug().Delete(&Group{}, "id = ? and auth_id = ?", group_id, auth_id) + res := DB.Delete(&Group{}, "id = ? and auth_id = ?", group_id, auth_id) return res.Error } // 删除群里的用户 func DeleteGroupUsers(group_id int) error { - res := DB.Debug().Delete(&GroupUser{}, "group_id = ?", group_id) + res := DB.Delete(&GroupUser{}, "group_id = ?", group_id) return res.Error } func FindFriend(from_user_id, to_user_id int) []Friend { var friends []Friend - DB.Debug().Where("user_id = ? and friend_id = ?", from_user_id, to_user_id).Find(&friends) + DB.Where("user_id = ? and friend_id = ?", from_user_id, to_user_id).Find(&friends) return friends } @@ -238,35 +238,35 @@ type FriendRet struct { func FindFriendsIDs(user_id int) []Friend { var friends []Friend - DB.Debug().Where("user_id = ?", user_id).Find(&friends) + DB.Where("user_id = ?", user_id).Find(&friends) return friends } func FindFriends(user_id int) []FriendRet { var friends []FriendRet - DB.Debug().Raw("select users.id, users.name, users.email from users join friends on users.id = friends.friend_id where friends.user_id = ? and friends.deleted_at is null", user_id).Scan(&friends) + DB.Raw("select users.id, users.name, users.email from users join friends on users.id = friends.friend_id where friends.user_id = ? and friends.deleted_at is null", user_id).Scan(&friends) return friends } func GetGroups(user_id int) []Group { var groups []Group - DB.Debug().Where("auth_id = ?", user_id).Find(&groups) + DB.Where("auth_id = ?", user_id).Find(&groups) return groups } func FindGroups(user_id int) []Group { var groups []Group - DB.Debug().Raw("select groups.* from groups join group_users on groups.id = group_users.group_id where group_users.user_id = ? and group_users.deleted_at is null", user_id).Scan(&groups) + DB.Raw("select groups.* from groups join group_users on groups.id = group_users.group_id where group_users.user_id = ? and group_users.deleted_at is null", user_id).Scan(&groups) return groups } func FindGroupByID(group_id int) []Group { var groups []Group - DB.Debug().Where("id = ?", group_id).Find(&groups) + DB.Where("id = ?", group_id).Find(&groups) return groups } func UpdateGroup(group_id int, groupName, groupInfo, groupIcon string) error { - res := DB.Debug().Model(&Group{}).Where("id = ?", group_id).Updates(map[string]interface{}{"group_name": groupName, "group_info": groupInfo, "group_icon": groupIcon}) + res := DB.Model(&Group{}).Where("id = ?", group_id).Updates(map[string]interface{}{"group_name": groupName, "group_info": groupInfo, "group_icon": groupIcon}) return res.Error } @@ -280,18 +280,18 @@ type FriendRequest struct { func GetFriendRequest(user_id int) []FriendRequest { var users []FriendRequest - DB.Debug().Raw("select users.id,users.name,users.email,users.age,messages.id as im_id from users join messages on users.id = messages.from_user_id where messages.to_user_id = ? and messages.type = ? and status = ?", user_id, proto.MSG_TYPE_FRIEND, 0).Scan(&users) + DB.Raw("select users.id,users.name,users.email,users.age,messages.id as im_id from users join messages on users.id = messages.from_user_id where messages.to_user_id = ? and messages.type = ? and status = ?", user_id, proto.MSG_TYPE_FRIEND, 0).Scan(&users) return users } func FindGroupUsers(group_id int) []GroupUser { var groupUsers []GroupUser - DB.Debug().Where("group_id = ?", group_id).Find(&groupUsers) + DB.Where("group_id = ?", group_id).Find(&groupUsers) return groupUsers } func FindGroupByNameLike(groupName string) []Group { var groups []Group - DB.Debug().Where("group_name like ?", "%"+groupName+"%").Limit(20).Find(&groups) + DB.Where("group_name like ?", "%"+groupName+"%").Limit(20).Find(&groups) return groups } diff --git a/dao/user.go b/dao/user.go index d7aae5f..0ec58d9 100644 --- a/dao/user.go +++ b/dao/user.go @@ -23,7 +23,7 @@ type User struct { func CreateUser(name, password, email, gender string, age int) uint { user := User{Name: name, Email: email, Password: password, Gender: gender, Age: age} - res := DB.Debug().Create(&user) + res := DB.Create(&user) if res.Error != nil { return 0 } @@ -37,38 +37,38 @@ func DeleteUserByID(id int) int { func FindUserByID(id int) []proto.User { var users []proto.User - DB.Debug().Where("id = ?", id).First(&users) + DB.Where("id = ?", id).First(&users) return users } func FindUserByID2(id int) User { var user User - DB.Debug().Where("id = ?", id).First(&user) + DB.Where("id = ?", id).First(&user) return user } func FindUserByUserID(id int) User { var user User - DB.Debug().Where("id = ?", id).First(&user) + DB.Where("id = ?", id).First(&user) return user } func FindUserByName(name string) User { var user User fmt.Println("name:", name) - DB.Debug().Where("name = ?", name).First(&user) + DB.Where("name = ?", name).First(&user) return user } // 根据name模糊查询，邮箱也是,不查询密码 func FindUserByNameLike(name string) []proto.User { var users []proto.User - DB.Debug().Where("name LIKE ? OR email LIKE ?", "%"+name+"%", "%"+name+"%").Find(&users).Limit(32) + DB.Where("name LIKE ? OR email LIKE ?", "%"+name+"%", "%"+name+"%").Find(&users).Limit(32) return users } func FindUserByEmail(email string) User { var user User - DB.Debug().Where("email = ?", email).First(&user) + DB.Where("email = ?", email).First(&user) return user } diff --git a/dao/video.go b/dao/video.go index f3d3a48..d9cfcbe 100644 --- a/dao/video.go +++ b/dao/video.go @@ -21,35 +21,35 @@ type Video struct { func FindWillDelVideoList(id int) []Video { var videos []Video - DB.Debug().Where("auth_id = ?", id).Where("delete_time<=now()").Where("isdelete=0").Find(&videos) + DB.Where("auth_id = ?", id).Where("delete_time<=now()").Where("isdelete=0").Find(&videos) return videos } 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, DeleteTime: deleteTime, FileSize: fileSize} - res := DB.Debug().Create(&video) + res := DB.Create(&video) if res.Error != nil { 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) + DB.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 } func DeleteVideoByID(id, user int) int { delete_time := time.Now().Format("2006-01-02 15:04:05") - DB.Debug().Where("id = ? and auth_id = ?", id, user).Updates(&Video{DeleteTime: delete_time, IsDelete: 1}) - DB.Debug().Where("id = ? and auth_id = ?", id, user).Delete(&Video{}) + DB.Where("id = ? and auth_id = ?", id, user).Updates(&Video{DeleteTime: delete_time, IsDelete: 1}) + DB.Where("id = ? and auth_id = ?", id, user).Delete(&Video{}) return id } func UpdateVideo(videoPath, videoName string, cameraID, videoID, authID, human, isDelete int, createTime, endTime string, fileSize int) bool { - res := DB.Debug().Model(&Video{}).Where("id = ? and auth_id = ?", videoID, authID).Updates(Video{VideoPath: videoPath, VideoName: videoName, CameraID: cameraID, AuthId: authID, Human: human, IsDelete: isDelete, CreateTime: createTime, EndTime: endTime, FileSize: fileSize}) + res := DB.Model(&Video{}).Where("id = ? and auth_id = ?", videoID, authID).Updates(Video{VideoPath: videoPath, VideoName: videoName, CameraID: cameraID, AuthId: authID, Human: human, IsDelete: isDelete, CreateTime: createTime, EndTime: endTime, FileSize: fileSize}) if res.Error != nil { return false } - res = DB.Debug().Exec("update videos set delete_time= DATE_ADD(NOW(), INTERVAL 20 DAY) where id=? and auth_id=?", videoID, authID) //delete_time= DATE_ADD(NOW(), INTERVAL 20 DAY) + res = DB.Exec("update videos set delete_time= DATE_ADD(NOW(), INTERVAL 20 DAY) where id=? and auth_id=?", videoID, authID) //delete_time= DATE_ADD(NOW(), INTERVAL 20 DAY) if res.Error != nil { return false } @@ -58,26 +58,26 @@ func UpdateVideo(videoPath, videoName string, cameraID, videoID, authID, human, func FindVideoByID(id, auth_id int) Video { var video Video - DB.Debug().Where("id = ? and auth_id = ?", id, auth_id).Where("isdelete = ?", 0).First(&video) + DB.Where("id = ? and auth_id = ?", id, auth_id).Where("isdelete = ?", 0).First(&video) return video } // 根据用户id查找视频列表,返回最新30条 func FindVideoListsByAuthID(auth_id int) []Video { var videos []Video - DB.Debug().Where("auth_id = ? and isdelete =? ", auth_id, 0).Order("created_at DESC").Limit(30).Find(&videos) + DB.Where("auth_id = ? and isdelete =? ", auth_id, 0).Order("created_at DESC").Limit(30).Find(&videos) return videos } func FindVideoListByTime(auth_id int, startTime, endTime string) []Video { var videos []Video - DB.Debug().Where("auth_id = ?", auth_id).Where("isdelete=0").Where("created_at > ? and created_at < ?", startTime, endTime).Find(&videos) + DB.Where("auth_id = ?", auth_id).Where("isdelete=0").Where("created_at > ? and created_at < ?", startTime, endTime).Find(&videos) return videos } // id 为视频id，auth_id为用户id，day为延长天数，返回修改的行数 func DelayVideo(id, auth_id, day int) int { - res := DB.Debug().Exec("update videos set delete_time = date_add(delete_time, interval ? day) where id = ? and auth_id = ? and isdelete=0", day, id, auth_id) + res := DB.Exec("update videos set delete_time = date_add(delete_time, interval ? day) where id = ? and auth_id = ? and isdelete=0", day, id, auth_id) if res.Error != nil { return 0 } @@ -86,7 +86,7 @@ func DelayVideo(id, auth_id, day int) int { // id 为用户id，day为延长天数，返回修改的行数 func DelayAllVideo(id, day int) int { - res := DB.Debug().Exec("update videos set delete_time = date_add(delete_time, interval ? day) where auth_id = ? and isdelete = 0", day, id) + res := DB.Exec("update videos set delete_time = date_add(delete_time, interval ? day) where auth_id = ? and isdelete = 0", day, id) if res.Error != nil { return 0 } @@ -94,7 +94,7 @@ func DelayAllVideo(id, day int) int { } func QuashOneDelay(id, user_id int, day int) int { - res := DB.Debug().Exec("update videos set delete_time = date_sub(delete_time, interval ? day) where id = ? and auth_id = ? and isdelete=0", day, id, user_id) + res := DB.Exec("update videos set delete_time = date_sub(delete_time, interval ? day) where id = ? and auth_id = ? and isdelete=0", day, id, user_id) if res.Error != nil { return 0 } @@ -102,7 +102,7 @@ func QuashOneDelay(id, user_id int, day int) int { } func QuashAllDelay(user_id int, day int) int { - res := DB.Debug().Exec("update videos set delete_time = date_sub(delete_time, interval ? day) where auth_id = ? and isdelete=0", day, user_id) + res := DB.Exec("update videos set delete_time = date_sub(delete_time, interval ? day) where auth_id = ? and isdelete=0", day, user_id) if res.Error != nil { return 0 } @@ -112,6 +112,6 @@ func QuashAllDelay(user_id int, day int) int { // 获取视频列表分页 func GetVideoListByPage(auth_id, page, pageSize int) []Video { var videos []Video - DB.Debug().Where("auth_id = ? and isdelete = ?", auth_id, 0).Order("created_at DESC").Offset((page - 1) * pageSize).Limit(pageSize).Find(&videos) //Offset((page - 1) * pageSize).Limit(pageSize),分页,page从1开始,pageSize每页多少条,Offset是偏移量,Limit是限制条数 + DB.Where("auth_id = ? and isdelete = ?", auth_id, 0).Order("created_at DESC").Offset((page - 1) * pageSize).Limit(pageSize).Find(&videos) //Offset((page - 1) * pageSize).Limit(pageSize),分页,page从1开始,pageSize每页多少条,Offset是偏移量,Limit是限制条数 return videos }