mirror of
https://github.com/go-admin-team/go-admin.git
synced 2026-09-30 20:58:33 +00:00
zhangwenjian
ea2d807071
WithContextDb and the five CRUD actions passed the *gin.Context itself to GORM as the query's context. database/sql watches the context of a query that returns rows inside a transaction from a goroutine of its own, which can still read it after the handler returns - and gin hands that Context to the next request as soon as the handler returns. GORM wraps every write in a transaction, and an INSERT on SQLite or PostgreSQL returns the new key as a row, so any write raced with the next request's reset. The race detector reports it on the second of two sequential requests. They now pass c.Request.Context(), which belongs to one request only and is cancelled when its client goes away.
68 lines
1.5 KiB
Go
68 lines
1.5 KiB
Go
package actions
|
|
|
|
import (
|
|
"errors"
|
|
"github.com/go-admin-team/go-admin-core/v2/response"
|
|
"net/http"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
log "github.com/go-admin-team/go-admin-core/v2/logger"
|
|
"github.com/go-admin-team/go-admin-core/v2/sdk/pkg"
|
|
"gorm.io/gorm"
|
|
|
|
"go-admin/common/dto"
|
|
"go-admin/common/models"
|
|
)
|
|
|
|
// ViewAction 通用详情动作
|
|
func ViewAction(control dto.Control, f func() interface{}) gin.HandlerFunc {
|
|
return func(c *gin.Context) {
|
|
db, err := pkg.GetOrm(c)
|
|
if err != nil {
|
|
log.Error(err)
|
|
return
|
|
}
|
|
|
|
msgID := pkg.GenerateMsgIDFromContext(c)
|
|
//查看详情
|
|
req := control.Generate()
|
|
err = req.Bind(c)
|
|
if err != nil {
|
|
response.Error(c, http.StatusUnprocessableEntity, err, "参数验证失败")
|
|
return
|
|
}
|
|
var object models.ActiveRecord
|
|
object, err = req.GenerateM()
|
|
if err != nil {
|
|
response.Error(c, 500, err, "模型生成失败")
|
|
return
|
|
}
|
|
|
|
var rsp interface{}
|
|
if f != nil {
|
|
rsp = f()
|
|
} else {
|
|
rsp, _ = req.GenerateM()
|
|
}
|
|
|
|
//数据权限检查
|
|
p := GetPermissionFromContext(c)
|
|
|
|
err = db.Model(object).WithContext(c.Request.Context()).Scopes(
|
|
Permission(object.TableName(), p),
|
|
).Where(req.GetId()).First(rsp).Error
|
|
|
|
if err != nil && errors.Is(err, gorm.ErrRecordNotFound) {
|
|
response.Error(c, http.StatusNotFound, nil, "查看对象不存在或无权查看")
|
|
return
|
|
}
|
|
if err != nil {
|
|
log.Errorf("MsgID[%s] View error: %s", msgID, err)
|
|
response.Error(c, 500, err, "查看失败")
|
|
return
|
|
}
|
|
response.OK(c, rsp, "查询成功")
|
|
c.Next()
|
|
}
|
|
}
|