dao执行sql不打印调试输出

This commit is contained in:
junleea 2024-10-04 11:37:25 +08:00
parent 414bf1589a
commit 356ab8962b
5 changed files with 65 additions and 65 deletions

View File

@ -18,7 +18,7 @@ type Device struct {
func CreateDevice(authID int, deviceName, deviceType string, deviceStatus, deviceLocation, deviceIP, deviceInfo string) uint { 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} 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 { if result.Error != nil {
fmt.Println("CreateDevice failed", result.Error) fmt.Println("CreateDevice failed", result.Error)
return 0 return 0
@ -27,7 +27,7 @@ func CreateDevice(authID int, deviceName, deviceType string, deviceStatus, devic
} }
func DeleteDeviceByID(id, user int) bool { 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 { if res.Error != nil {
return false return false
} }
@ -36,18 +36,18 @@ func DeleteDeviceByID(id, user int) bool {
func FindDeviceByID(id, auth_id int) Device { func FindDeviceByID(id, auth_id int) Device {
var device 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 return device
} }
func FindDeviceByAuthID(auth_id int) []Device { func FindDeviceByAuthID(auth_id int) []Device {
var devices []Device var devices []Device
DB.Debug().Where("auth_id = ?", auth_id).Find(&devices) DB.Where("auth_id = ?", auth_id).Find(&devices)
return devices return devices
} }
func SetDeviceStatus(status string, id, auth_id int) bool { 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 { if result.Error != nil {
return false return false
} }
@ -78,7 +78,7 @@ func UpdateDeviceByID(id, auth_id int, deviceName, deviceType, deviceStatus, dev
deviceInfo = pd.DeviceInfo 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 { if res.Error != nil {
return false return false
} }

View File

@ -15,7 +15,7 @@ type File struct {
func CreateFile(fileStoreName, fileName, fileType, filePath string, fileSize, authID int) uint { 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} 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 { if result.Error != nil {
return 0 return 0
} }
@ -23,7 +23,7 @@ func CreateFile(fileStoreName, fileName, fileType, filePath string, fileSize, au
} }
func DeleteFileByID(id, user int) bool { 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 { if res.Error != nil {
return false return false
} }
@ -32,19 +32,19 @@ func DeleteFileByID(id, user int) bool {
func FindFileByID(id, auth_id int) File { func FindFileByID(id, auth_id int) File {
var file 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 return file
} }
func FindFileByNames(fileName string, auth_id int) File { func FindFileByNames(fileName string, auth_id int) File {
var file 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 return file
} }
func FindFileByAuthID(auth_id int) []File { func FindFileByAuthID(auth_id int) []File {
var files []File var files []File
DB.Debug().Where("auth_id = ?", auth_id).Find(&files) DB.Where("auth_id = ?", auth_id).Find(&files)
return files return files
} }
@ -53,7 +53,7 @@ func UpdateFileByID(id, auth_id int, fileStoreName, fileName, fileType, filePath
if pd.ID == 0 { if pd.ID == 0 {
return false 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 { if result.Error != nil {
return false return false
} }
@ -61,7 +61,7 @@ func UpdateFileByID(id, auth_id int, fileStoreName, fileName, fileType, filePath
} }
func DeleteFileByAuthID(auth_id int) bool { 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 { if res.Error != nil {
return false return false
} }
@ -69,7 +69,7 @@ func DeleteFileByAuthID(auth_id int) bool {
} }
func DeleteFileById(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 { if res.Error != nil {
return false return false
} }

View File

@ -40,13 +40,13 @@ type Friend struct {
// 创建单聊消息 // 创建单聊消息
func CreateSimpleMessage(from_user_id, to_user_id int, message string) (error, uint) { 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} 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 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) { 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} 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 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 msgs []Message
var res *gorm.DB var res *gorm.DB
if msg_type == 4 { 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 { } 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.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.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 { } 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 return msgs, res.Error
} }
@ -73,27 +73,27 @@ type GroupMessage struct {
func GetMsgGroupByIndex(group_id, index int) ([]GroupMessage, error) { func GetMsgGroupByIndex(group_id, index int) ([]GroupMessage, error) {
var msgs []GroupMessage 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 return msgs, res.Error
} }
func GetGroupRequestUsers(user_id int) []FriendRequest { func GetGroupRequestUsers(user_id int) []FriendRequest {
var users []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 return users
} }
func GetMsgUserGroupReq(from_user_id, group_id int) ([]Message, error) { func GetMsgUserGroupReq(from_user_id, group_id int) ([]Message, error) {
var msgs []Message 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 return msgs, res.Error
} }
// 获取邀请消息 // 获取邀请消息
func GetFriendGroupReq(user_id int) ([]Message, error) { func GetFriendGroupReq(user_id int) ([]Message, error) {
var msgs []Message 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 return msgs, res.Error
} }
@ -146,21 +146,21 @@ func DeleteFriend(user_id, friend_id int) error {
// 通过id查找消息 // 通过id查找消息
func FindMessageByID(id uint) []Message { func FindMessageByID(id uint) []Message {
var msgs []Message var msgs []Message
DB.Debug().Where("id = ?", id).Find(&msgs) DB.Where("id = ?", id).Find(&msgs)
return msgs return msgs
} }
// 通过id查找消息包括name) // 通过id查找消息包括name)
func FindMessageByID2(id uint) []GroupMessage { func FindMessageByID2(id uint) []GroupMessage {
var msgs []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 return msgs
} }
// 更新消息状态 // 更新消息状态
func UpdateMessageStatus(id uint, status int) error { 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 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 { func FindGroupUser(user_id, group_id int) []GroupUser {
var groupUsers []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 return groupUsers
} }
// 加入群聊 // 加入群聊
func JoinGroup(group_id, user_id int) (error, uint) { func JoinGroup(group_id, user_id int) (error, uint) {
groupUser := GroupUser{GroupID: group_id, UserID: user_id} groupUser := GroupUser{GroupID: group_id, UserID: user_id}
res := DB.Debug().Create(&groupUser) res := DB.Create(&groupUser)
return res.Error, groupUser.ID return res.Error, groupUser.ID
} }
// 退出群聊 // 退出群聊
func QuitGroup(group_id, user_id int) error { 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 return res.Error
} }
// 根据群id查找群 // 根据群id查找群
func FindGroup(group_id int) []Group { func FindGroup(group_id int) []Group {
var groups []Group var groups []Group
DB.Debug().Where("id = ?", group_id).Find(&groups) DB.Where("id = ?", group_id).Find(&groups)
return groups return groups
} }
// 删除群聊 // 删除群聊
func DeleteGroup(group_id int, auth_id int) error { 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 return res.Error
} }
// 删除群里的用户 // 删除群里的用户
func DeleteGroupUsers(group_id int) 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 return res.Error
} }
func FindFriend(from_user_id, to_user_id int) []Friend { func FindFriend(from_user_id, to_user_id int) []Friend {
var friends []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 return friends
} }
@ -238,35 +238,35 @@ type FriendRet struct {
func FindFriendsIDs(user_id int) []Friend { func FindFriendsIDs(user_id int) []Friend {
var friends []Friend var friends []Friend
DB.Debug().Where("user_id = ?", user_id).Find(&friends) DB.Where("user_id = ?", user_id).Find(&friends)
return friends return friends
} }
func FindFriends(user_id int) []FriendRet { func FindFriends(user_id int) []FriendRet {
var friends []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 return friends
} }
func GetGroups(user_id int) []Group { func GetGroups(user_id int) []Group {
var groups []Group var groups []Group
DB.Debug().Where("auth_id = ?", user_id).Find(&groups) DB.Where("auth_id = ?", user_id).Find(&groups)
return groups return groups
} }
func FindGroups(user_id int) []Group { func FindGroups(user_id int) []Group {
var groups []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 return groups
} }
func FindGroupByID(group_id int) []Group { func FindGroupByID(group_id int) []Group {
var groups []Group var groups []Group
DB.Debug().Where("id = ?", group_id).Find(&groups) DB.Where("id = ?", group_id).Find(&groups)
return groups return groups
} }
func UpdateGroup(group_id int, groupName, groupInfo, groupIcon string) error { 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 return res.Error
} }
@ -280,18 +280,18 @@ type FriendRequest struct {
func GetFriendRequest(user_id int) []FriendRequest { func GetFriendRequest(user_id int) []FriendRequest {
var users []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 return users
} }
func FindGroupUsers(group_id int) []GroupUser { func FindGroupUsers(group_id int) []GroupUser {
var groupUsers []GroupUser var groupUsers []GroupUser
DB.Debug().Where("group_id = ?", group_id).Find(&groupUsers) DB.Where("group_id = ?", group_id).Find(&groupUsers)
return groupUsers return groupUsers
} }
func FindGroupByNameLike(groupName string) []Group { func FindGroupByNameLike(groupName string) []Group {
var groups []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 return groups
} }

View File

@ -23,7 +23,7 @@ type User struct {
func CreateUser(name, password, email, gender string, age int) uint { func CreateUser(name, password, email, gender string, age int) uint {
user := User{Name: name, Email: email, Password: password, Gender: gender, Age: age} 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 { if res.Error != nil {
return 0 return 0
} }
@ -37,38 +37,38 @@ func DeleteUserByID(id int) int {
func FindUserByID(id int) []proto.User { func FindUserByID(id int) []proto.User {
var users []proto.User var users []proto.User
DB.Debug().Where("id = ?", id).First(&users) DB.Where("id = ?", id).First(&users)
return users return users
} }
func FindUserByID2(id int) User { func FindUserByID2(id int) User {
var user User var user User
DB.Debug().Where("id = ?", id).First(&user) DB.Where("id = ?", id).First(&user)
return user return user
} }
func FindUserByUserID(id int) User { func FindUserByUserID(id int) User {
var user User var user User
DB.Debug().Where("id = ?", id).First(&user) DB.Where("id = ?", id).First(&user)
return user return user
} }
func FindUserByName(name string) User { func FindUserByName(name string) User {
var user User var user User
fmt.Println("name:", name) fmt.Println("name:", name)
DB.Debug().Where("name = ?", name).First(&user) DB.Where("name = ?", name).First(&user)
return user return user
} }
// 根据name模糊查询邮箱也是,不查询密码 // 根据name模糊查询邮箱也是,不查询密码
func FindUserByNameLike(name string) []proto.User { func FindUserByNameLike(name string) []proto.User {
var users []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 return users
} }
func FindUserByEmail(email string) User { func FindUserByEmail(email string) User {
var user User var user User
DB.Debug().Where("email = ?", email).First(&user) DB.Where("email = ?", email).First(&user)
return user return user
} }

View File

@ -21,35 +21,35 @@ 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()").Where("isdelete=0").Find(&videos) DB.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, deleteTime 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, DeleteTime: deleteTime, 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.Create(&video)
if res.Error != nil { if res.Error != nil {
return 0 return 0
} }
if deleteTime == "" { 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 return video.ID
} }
func DeleteVideoByID(id, user int) int { func DeleteVideoByID(id, user int) int {
delete_time := time.Now().Format("2006-01-02 15:04:05") 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.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).Delete(&Video{})
return id return id
} }
func UpdateVideo(videoPath, videoName string, cameraID, videoID, authID, human, isDelete int, createTime, endTime string, fileSize int) bool { 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 { if res.Error != nil {
return false 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 { if res.Error != nil {
return false return false
} }
@ -58,26 +58,26 @@ func UpdateVideo(videoPath, videoName string, cameraID, videoID, authID, human,
func FindVideoByID(id, auth_id int) Video { func FindVideoByID(id, auth_id int) Video {
var video 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 return video
} }
// 根据用户id查找视频列表,返回最新30条 // 根据用户id查找视频列表,返回最新30条
func FindVideoListsByAuthID(auth_id int) []Video { func FindVideoListsByAuthID(auth_id int) []Video {
var videos []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 return videos
} }
func FindVideoListByTime(auth_id int, startTime, endTime string) []Video { func FindVideoListByTime(auth_id int, startTime, endTime string) []Video {
var videos []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 return videos
} }
// id 为视频idauth_id为用户idday为延长天数返回修改的行数 // id 为视频idauth_id为用户idday为延长天数返回修改的行数
func DelayVideo(id, auth_id, day int) int { 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 { if res.Error != nil {
return 0 return 0
} }
@ -86,7 +86,7 @@ func DelayVideo(id, auth_id, day int) int {
// id 为用户idday为延长天数返回修改的行数 // id 为用户idday为延长天数返回修改的行数
func DelayAllVideo(id, day int) int { 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 { if res.Error != nil {
return 0 return 0
} }
@ -94,7 +94,7 @@ func DelayAllVideo(id, day int) int {
} }
func QuashOneDelay(id, user_id int, 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 { if res.Error != nil {
return 0 return 0
} }
@ -102,7 +102,7 @@ func QuashOneDelay(id, user_id int, day int) int {
} }
func QuashAllDelay(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 { if res.Error != nil {
return 0 return 0
} }
@ -112,6 +112,6 @@ func QuashAllDelay(user_id int, day int) int {
// 获取视频列表分页 // 获取视频列表分页
func GetVideoListByPage(auth_id, page, pageSize int) []Video { func GetVideoListByPage(auth_id, page, pageSize int) []Video {
var videos []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 return videos
} }