juwan/juwan-backend
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

fix: 修正 player_services 数组字段的 SQL 序列化错误

Browse Source
This commit is contained in:
zetaloop
2026-04-04 01:43:02 +08:00
parent 64223ada67
commit 9bbc54ea66
3 changed files with 15 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/player/rpc/internal/models/playerservices.go
+5 -7
View File
@@ -3,9 +3,9 @@
package models package models
import ( import (
"encoding/json"
"fmt" "fmt"
"juwan-backend/app/player/rpc/internal/models/playerservices" "juwan-backend/app/player/rpc/internal/models/playerservices"
"juwan-backend/pkg/types"
"strings" "strings"
"time" "time"
@@ -52,7 +52,7 @@ func (*PlayerServices) scanValues(columns []string) ([]any, error) {
for i := range columns { for i := range columns {
switch columns[i] { switch columns[i] {
case playerservices.FieldAvailability: case playerservices.FieldAvailability:
values[i] = new([]byte) values[i] = new(types.TextArray)
case playerservices.FieldPrice, playerservices.FieldRating: case playerservices.FieldPrice, playerservices.FieldRating:
values[i] = new(decimal.Decimal) values[i] = new(decimal.Decimal)
case playerservices.FieldIsActive: case playerservices.FieldIsActive:
@@ -129,12 +129,10 @@ func (_m *PlayerServices) assignValues(columns []string, values []any) error {
*_m.RankRange = value.String *_m.RankRange = value.String
} }
case playerservices.FieldAvailability: case playerservices.FieldAvailability:
if value, ok := values[i].(*[]byte); !ok { if value, ok := values[i].(*types.TextArray); !ok {
return fmt.Errorf("unexpected type %T for field availability", values[i]) return fmt.Errorf("unexpected type %T for field availability", values[i])
} else if value != nil && len(*value) > 0 { } else if value != nil {
if err := json.Unmarshal(*value, &_m.Availability); err != nil { _m.Availability = append([]string{}, value.Elements...)
return fmt.Errorf("unmarshal field availability: %w", err)
}
} }
case playerservices.FieldRating: case playerservices.FieldRating:
if value, ok := values[i].(*decimal.Decimal); !ok { if value, ok := values[i].(*decimal.Decimal); !ok {
app/player/rpc/internal/models/playerservices_create.go
+3 -1
View File
@@ -7,6 +7,7 @@ import (
"errors" "errors"
"fmt" "fmt"
"juwan-backend/app/player/rpc/internal/models/playerservices" "juwan-backend/app/player/rpc/internal/models/playerservices"
"juwan-backend/pkg/types"
"time" "time"
"entgo.io/ent/dialect/sql/sqlgraph" "entgo.io/ent/dialect/sql/sqlgraph"
@@ -306,7 +307,8 @@ func (_c *PlayerServicesCreate) createSpec() (*PlayerServices, *sqlgraph.CreateS
_node.RankRange = &value _node.RankRange = &value
} }
if value, ok := _c.mutation.Availability(); ok { if value, ok := _c.mutation.Availability(); ok {
_spec.SetField(playerservices.FieldAvailability, field.TypeJSON, value) availability := types.TextArray{Elements: append([]string{}, value...), Valid: true}
_spec.SetField(playerservices.FieldAvailability, field.TypeOther, availability)
_node.Availability = value _node.Availability = value
} }
if value, ok := _c.mutation.Rating(); ok { if value, ok := _c.mutation.Rating(); ok {
app/player/rpc/internal/models/playerservices_update.go
+7 -4
View File
@@ -8,6 +8,7 @@ import (
"fmt" "fmt"
"juwan-backend/app/player/rpc/internal/models/playerservices" "juwan-backend/app/player/rpc/internal/models/playerservices"
"juwan-backend/app/player/rpc/internal/models/predicate" "juwan-backend/app/player/rpc/internal/models/predicate"
"juwan-backend/pkg/types"
"time" "time"
"entgo.io/ent/dialect/sql" "entgo.io/ent/dialect/sql"
@@ -319,7 +320,8 @@ func (_u *PlayerServicesUpdate) sqlSave(ctx context.Context) (_node int, err err
_spec.ClearField(playerservices.FieldRankRange, field.TypeString) _spec.ClearField(playerservices.FieldRankRange, field.TypeString)
} }
if value, ok := _u.mutation.Availability(); ok { if value, ok := _u.mutation.Availability(); ok {
_spec.SetField(playerservices.FieldAvailability, field.TypeJSON, value) availability := types.TextArray{Elements: append([]string{}, value...), Valid: true}
_spec.SetField(playerservices.FieldAvailability, field.TypeOther, availability)
} }
if value, ok := _u.mutation.AppendedAvailability(); ok { if value, ok := _u.mutation.AppendedAvailability(); ok {
_spec.AddModifier(func(u *sql.UpdateBuilder) { _spec.AddModifier(func(u *sql.UpdateBuilder) {
@@ -327,7 +329,7 @@ func (_u *PlayerServicesUpdate) sqlSave(ctx context.Context) (_node int, err err
}) })
} }
if _u.mutation.AvailabilityCleared() { if _u.mutation.AvailabilityCleared() {
_spec.ClearField(playerservices.FieldAvailability, field.TypeJSON) _spec.ClearField(playerservices.FieldAvailability, field.TypeOther)
} }
if value, ok := _u.mutation.Rating(); ok { if value, ok := _u.mutation.Rating(); ok {
_spec.SetField(playerservices.FieldRating, field.TypeOther, value) _spec.SetField(playerservices.FieldRating, field.TypeOther, value)
@@ -680,7 +682,8 @@ func (_u *PlayerServicesUpdateOne) sqlSave(ctx context.Context) (_node *PlayerSe
_spec.ClearField(playerservices.FieldRankRange, field.TypeString) _spec.ClearField(playerservices.FieldRankRange, field.TypeString)
} }
if value, ok := _u.mutation.Availability(); ok { if value, ok := _u.mutation.Availability(); ok {
_spec.SetField(playerservices.FieldAvailability, field.TypeJSON, value) availability := types.TextArray{Elements: append([]string{}, value...), Valid: true}
_spec.SetField(playerservices.FieldAvailability, field.TypeOther, availability)
} }
if value, ok := _u.mutation.AppendedAvailability(); ok { if value, ok := _u.mutation.AppendedAvailability(); ok {
_spec.AddModifier(func(u *sql.UpdateBuilder) { _spec.AddModifier(func(u *sql.UpdateBuilder) {
@@ -688,7 +691,7 @@ func (_u *PlayerServicesUpdateOne) sqlSave(ctx context.Context) (_node *PlayerSe
}) })
} }
if _u.mutation.AvailabilityCleared() { if _u.mutation.AvailabilityCleared() {
_spec.ClearField(playerservices.FieldAvailability, field.TypeJSON) _spec.ClearField(playerservices.FieldAvailability, field.TypeOther)
} }
if value, ok := _u.mutation.Rating(); ok { if value, ok := _u.mutation.Rating(); ok {
_spec.SetField(playerservices.FieldRating, field.TypeOther, value) _spec.SetField(playerservices.FieldRating, field.TypeOther, value)