319 lines
9.1 KiB
Go
319 lines
9.1 KiB
Go
package routers
|
|
|
|
//2026-4-2开始每个功能的数据表在各自的api路由下初始化
|
|
|
|
import (
|
|
"encoding/json"
|
|
"ops/models"
|
|
"slices"
|
|
"time"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
"github.com/mitchellh/mapstructure"
|
|
"gorm.io/gorm"
|
|
)
|
|
|
|
type TabSchedule struct {
|
|
ID uint `gorm:"primarykey"`
|
|
UserID uint `gorm:"not null;comment:创建人ID"`
|
|
Title string `gorm:"size:200;not null;comment:日程标题"`
|
|
StartDate string `gorm:"size:10;not null;index;comment:开始日期 YYYY-MM-DD"`
|
|
EndDate string `gorm:"size:10;not null;index;comment:结束日期 YYYY-MM-DD"`
|
|
BgColor string `gorm:"size:50;default:#3788d9;comment:背景颜色"`
|
|
Remark string `gorm:"type:text;comment:备注"`
|
|
|
|
CreatedAt *time.Time `gorm:"type:datetime;autoCreateTime;comment:创建时间"`
|
|
UpdatedAt *time.Time `gorm:"type:datetime;autoUpdateTime;comment:最后修改时间"`
|
|
DeletedAt gorm.DeletedAt `gorm:"index"`
|
|
}
|
|
|
|
type TabScheduleLog struct {
|
|
ID uint `gorm:"primarykey"`
|
|
ScheduleID uint `gorm:"not null;index;comment:关联日程ID"`
|
|
UserID uint `gorm:"not null;comment:操作人ID"`
|
|
ActionType string `gorm:"size:50;not null;comment:操作类型: create-创建 update-修改 delete-删除 query-查询"`
|
|
OldContent string `gorm:"type:text;comment:修改前内容(JSON)"`
|
|
NewContent string `gorm:"type:text;comment:修改后内容(JSON)"`
|
|
IP string `gorm:"size:50;comment:操作IP"`
|
|
Remark string `gorm:"size:500;comment:备注/操作描述"`
|
|
|
|
CreatedAt *time.Time `gorm:"type:datetime;autoCreateTime;comment:操作时间"`
|
|
}
|
|
type fromAddEvent struct {
|
|
ID uint `json:"id"`
|
|
Title string `json:"title" binding:"required"` // 日程标题
|
|
Start string `json:"start" binding:"required"` // 开始日期
|
|
End string `json:"end" binding:"required"` // 结束日期
|
|
Color string `json:"color" binding:"required"` // 背景颜色
|
|
}
|
|
|
|
type fromGetEvents struct {
|
|
Start string `json:"start" binding:"required"` // 开始日期
|
|
End string `json:"end" binding:"required"` // 结束日期
|
|
}
|
|
|
|
var (
|
|
userGroup TabUserGroups
|
|
scheduleAdmins []uint
|
|
)
|
|
|
|
// 更新管理员成员缓存
|
|
func ScheduleUpdateAdminsCash() {
|
|
//先清空切片
|
|
scheduleAdmins = nil
|
|
|
|
//获取管理员用户组id
|
|
//id 1是系统管理员 直接appen
|
|
scheduleAdmins = append(scheduleAdmins, 1)
|
|
//读取所有绑定了这个用户组的用户id
|
|
var usergroupbind []TabUserGroupBinds
|
|
usergroupbindfind := TabUserGroupBinds{
|
|
GroupID: userGroup.ID,
|
|
}
|
|
models.DB.Where(&usergroupbindfind).Find(&usergroupbind)
|
|
for _, item := range usergroupbind {
|
|
if !slices.Contains(scheduleAdmins, item.UserID) {
|
|
scheduleAdmins = append(scheduleAdmins, item.UserID)
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
func ApiScheduleInit() {
|
|
//先初始化数据表
|
|
// models.DB.AutoMigrate(&TabSchedule{})
|
|
// models.DB.AutoMigrate(&TabScheduleLog{})
|
|
|
|
// //先检查用户组有没有这个key
|
|
// userGroup.Name = "schedule_admin"
|
|
// if models.DB.Where(&userGroup).First(&userGroup).Error == nil {
|
|
// ScheduleUpdateAdminsCash()
|
|
// } else {
|
|
// userGroup.Type = "usergroup"
|
|
// models.DB.Create(&userGroup)
|
|
// }
|
|
}
|
|
|
|
func ApiSchedule(r *gin.RouterGroup) {
|
|
|
|
r.Use(func(ctx *gin.Context) { //此模块已停用，拦截所有请求
|
|
ReturnJson(ctx, "App off", nil)
|
|
ctx.Abort()
|
|
|
|
})
|
|
|
|
r.POST("/getevents", func(ctx *gin.Context) {
|
|
data, cookie := SeparateData(ctx)
|
|
user, er := AuthenticationAuthorityFromCookie(cookie)
|
|
|
|
var from fromGetEvents
|
|
if err := mapstructure.Decode(data, &from); err == nil {
|
|
//fmt.Println(from)
|
|
//从数据库获取相关数据
|
|
var list []TabSchedule
|
|
models.DB.Where("start_date <= ? AND end_date >= ?", from.End, from.Start).Where("deleted_at IS NULL").Find(&list)
|
|
var relist []map[string]interface{}
|
|
for _, item := range list {
|
|
data, _ := json.Marshal(item)
|
|
var temp map[string]interface{}
|
|
json.Unmarshal(data, &temp)
|
|
// 加自定义字段
|
|
if er == nil {
|
|
//已登录 进一步判断编辑权限
|
|
temp["edit"] = false
|
|
|
|
if slices.Contains(scheduleAdmins, user.ID) {
|
|
temp["edit"] = true
|
|
}
|
|
if item.UserID == user.ID {
|
|
temp["edit"] = true
|
|
}
|
|
|
|
// user_group_find := models.TabUserGroupBinds_{}
|
|
// if models.DB.Where("user_id = ? AND group_id = ?", user.ID, userGroup.ID).First(&user_group_find).Error == nil { //是应用管理员
|
|
// temp["edit"] = true
|
|
// }
|
|
} else {
|
|
temp["edit"] = false
|
|
}
|
|
|
|
relist = append(relist, temp)
|
|
|
|
}
|
|
|
|
//ReturnJson(ctx, "ApiOK", list)
|
|
ReturnJson(ctx, "apiOK", gin.H{"list": relist})
|
|
|
|
} else {
|
|
ReturnJson(ctx, "jsonErr", nil)
|
|
}
|
|
|
|
})
|
|
|
|
r.POST("/deleevent", func(ctx *gin.Context) {
|
|
isAuth, user, data := AuthenticationAuthority(ctx)
|
|
if isAuth {
|
|
var from fromAddEvent
|
|
if err := mapstructure.Decode(data, &from); err == nil {
|
|
//先从数据库拉取原始event数据
|
|
oldEvent := TabSchedule{}
|
|
if models.DB.Where("id = ?", from.ID).First(&oldEvent).Error == nil {
|
|
//需要先判断修改权限
|
|
var isCanEdit = false
|
|
if slices.Contains(scheduleAdmins, user.ID) { //用户id是管理员
|
|
isCanEdit = true
|
|
}
|
|
if oldEvent.UserID == user.ID { //event是用户创建的
|
|
isCanEdit = true
|
|
}
|
|
if isCanEdit {
|
|
tosql := TabSchedule{}
|
|
tosql.DeletedAt.Scan(time.Now())
|
|
//fmt.Println(tosql)
|
|
findEvent := TabSchedule{
|
|
ID: oldEvent.ID,
|
|
}
|
|
if models.DB.Where(&findEvent).Updates(&tosql).Error == nil {
|
|
//应该修改完了 写日志
|
|
//把最新数据再读出来
|
|
models.DB.Where(&findEvent).First(&findEvent)
|
|
newContent, _ := json.Marshal(findEvent) //转 JSON
|
|
oldContent, _ := json.Marshal(oldEvent) //转 JSON
|
|
tosqllog := TabScheduleLog{
|
|
UserID: user.ID,
|
|
ScheduleID: oldEvent.ID,
|
|
ActionType: "delete",
|
|
NewContent: string(newContent),
|
|
OldContent: string(oldContent),
|
|
IP: ctx.ClientIP(),
|
|
}
|
|
models.DB.Create(&tosqllog)
|
|
ReturnJson(ctx, "apiOK", nil)
|
|
} else {
|
|
ReturnJson(ctx, "apiErr", nil)
|
|
}
|
|
} else {
|
|
ReturnJson(ctx, "schedule_permission_denied", nil)
|
|
}
|
|
} else {
|
|
ReturnJson(ctx, "schedule_event_not_find", nil)
|
|
}
|
|
} else {
|
|
ReturnJson(ctx, "jsonErr", nil)
|
|
}
|
|
} else {
|
|
ReturnJson(ctx, "userCookieError", nil)
|
|
}
|
|
|
|
})
|
|
|
|
r.POST("/editevent", func(ctx *gin.Context) {
|
|
isAuth, user, data := AuthenticationAuthority(ctx)
|
|
if isAuth {
|
|
|
|
var from fromAddEvent
|
|
if err := mapstructure.Decode(data, &from); err == nil {
|
|
//先从数据库拉取原始event数据
|
|
oldEvent := TabSchedule{}
|
|
if models.DB.Where("id = ?", from.ID).First(&oldEvent).Error == nil {
|
|
//需要先判断修改权限
|
|
var isCanEdit = false
|
|
if slices.Contains(scheduleAdmins, user.ID) { //用户id是管理员
|
|
isCanEdit = true
|
|
}
|
|
if oldEvent.UserID == user.ID { //event是用户创建的
|
|
isCanEdit = true
|
|
}
|
|
|
|
if isCanEdit {
|
|
tosql := TabSchedule{
|
|
// UserID: user.ID, //如果是管理员修改的话会覆盖掉创建者的id
|
|
Title: from.Title,
|
|
StartDate: from.Start,
|
|
EndDate: from.End,
|
|
BgColor: from.Color,
|
|
}
|
|
//fmt.Println(tosql)
|
|
|
|
findEvent := TabSchedule{
|
|
ID: oldEvent.ID,
|
|
}
|
|
|
|
if models.DB.Where(&findEvent).Updates(&tosql).Error == nil {
|
|
//应该修改完了 写日志
|
|
//把最新数据再读出来
|
|
models.DB.Where(&findEvent).First(&findEvent)
|
|
newContent, _ := json.Marshal(findEvent) //转 JSON
|
|
oldContent, _ := json.Marshal(oldEvent) //转 JSON
|
|
tosqllog := TabScheduleLog{
|
|
UserID: user.ID,
|
|
ScheduleID: oldEvent.ID,
|
|
ActionType: "update",
|
|
NewContent: string(newContent),
|
|
OldContent: string(oldContent),
|
|
IP: ctx.ClientIP(),
|
|
}
|
|
models.DB.Create(&tosqllog)
|
|
ReturnJson(ctx, "apiOK", nil)
|
|
|
|
} else {
|
|
ReturnJson(ctx, "apiErr", nil)
|
|
}
|
|
|
|
} else {
|
|
ReturnJson(ctx, "schedule_permission_denied", nil)
|
|
}
|
|
|
|
} else {
|
|
ReturnJson(ctx, "schedule_event_not_find", nil)
|
|
}
|
|
|
|
} else {
|
|
ReturnJson(ctx, "jsonErr", nil)
|
|
}
|
|
} else {
|
|
ReturnJson(ctx, "userCookieError", nil)
|
|
}
|
|
})
|
|
r.POST("/addevent", func(ctx *gin.Context) {
|
|
isAuth, user, data := AuthenticationAuthority(ctx)
|
|
if isAuth {
|
|
|
|
var from fromAddEvent
|
|
if err := mapstructure.Decode(data, &from); err == nil {
|
|
|
|
tosql := TabSchedule{
|
|
UserID: user.ID,
|
|
Title: from.Title,
|
|
StartDate: from.Start,
|
|
EndDate: from.End,
|
|
BgColor: from.Color,
|
|
}
|
|
if models.DB.Create(&tosql).Error == nil {
|
|
//记录日志
|
|
newContent, _ := json.Marshal(tosql) // 👈 转 JSON
|
|
tosqllog := TabScheduleLog{
|
|
UserID: user.ID,
|
|
ScheduleID: tosql.ID,
|
|
ActionType: "create",
|
|
NewContent: string(newContent), // 👈 直接赋值
|
|
OldContent: "",
|
|
IP: ctx.ClientIP(),
|
|
}
|
|
models.DB.Create(&tosqllog)
|
|
ReturnJson(ctx, "apiOK", nil)
|
|
} else {
|
|
ReturnJson(ctx, "apiErr", nil)
|
|
}
|
|
|
|
} else {
|
|
ReturnJson(ctx, "jsonErr", nil)
|
|
}
|
|
} else {
|
|
ReturnJson(ctx, "userCookieError", nil)
|
|
}
|
|
|
|
})
|
|
|
|
}
|