info
This commit is contained in:
@@ -50,7 +50,7 @@ func (m *FsUserInfoModel) MergeMetadata(userId int64, meta any) error {
|
||||
return fssql.MetadataModulePATCH(m.db, "profile", FsUserInfo{}, meta, "user_id = ?", userId)
|
||||
}
|
||||
|
||||
func (m *FsUserInfoModel) GetDefaultProfile(ctx context.Context, tname string) (map[string]any, error) {
|
||||
func (m *FsUserInfoModel) getDefaultProfile(ctx context.Context, tname string) (map[string]any, error) {
|
||||
var baseinfo map[string]any
|
||||
condUser := "user_id = 0 and guest_id = 0"
|
||||
rawsql := fmt.Sprintf("select JSON_EXTRACT(metadata,'$') as query from %s where %s and module = 'profile' order by ctime DESC limit 1", tname, condUser)
|
||||
@@ -98,7 +98,7 @@ func (m *FsUserInfoModel) GetProfile(ctx context.Context, pkey string, userId in
|
||||
|
||||
v, ok := baseinfo["query"].(string)
|
||||
if !ok {
|
||||
return m.GetDefaultProfile(ctx, tname)
|
||||
return m.getDefaultProfile(ctx, tname)
|
||||
}
|
||||
|
||||
var info map[string]any
|
||||
@@ -108,11 +108,17 @@ func (m *FsUserInfoModel) GetProfile(ctx context.Context, pkey string, userId in
|
||||
}
|
||||
|
||||
if len(info) == 0 {
|
||||
return m.GetDefaultProfile(ctx, tname)
|
||||
return m.getDefaultProfile(ctx, tname)
|
||||
}
|
||||
|
||||
return info, nil
|
||||
}
|
||||
|
||||
func (m *FsUserInfoModel) GetDefaultProfile(ctx context.Context) (map[string]any, error) {
|
||||
tname := fssql.GetGormTableName(m.db, FsUserInfo{})
|
||||
return m.getDefaultProfile(ctx, tname)
|
||||
}
|
||||
|
||||
func (m *FsUserInfoModel) FindOneByUser(ctx context.Context, userId, guestId int64, module string) (resp *FsUserInfo, err error) {
|
||||
if userId > 0 {
|
||||
err = m.db.WithContext(ctx).Model(&FsUserInfo{}).Where("user_id = ? and module = ?", userId, module).Take(&resp).Error
|
||||
|
||||
Reference in New Issue
Block a user