package tag import ( "git.sxidc.com/go-framework/baize/infrastructure/logger" "git.sxidc.com/go-tools/utils/reflectutils" "git.sxidc.com/go-tools/utils/strutils" "git.sxidc.com/service-supports/fserr" "reflect" "strings" "time" ) type OnAssignParsedFieldTagFunc func(fromFieldName string, fromFieldElemValue reflect.Value, retFieldElementValue reflect.Value, tag *AssignTag) error func AssignTo(from any, to any) error { return CustomAssignTo(from, to, func(fromFieldName string, fromFieldElemValue reflect.Value, retFieldElementValue reflect.Value, tag *AssignTag) error { if fromFieldElemValue.IsZero() { return nil } return assignField(fromFieldElemValue, retFieldElementValue, tag) }) } func CustomAssignTo(from any, to any, onParsedFieldTagFunc OnAssignParsedFieldTagFunc) error { if from == nil || to == nil { return nil } fromValue := reflect.ValueOf(from) retValue := reflect.ValueOf(to) // 类型校验 if !reflectutils.IsValueStructOrStructPointer(fromValue) { return fserr.New("参数不是结构或结构指针") } if !reflectutils.IsValueStructPointer(retValue) { return fserr.New("返回类型不是结构指针") } fromElemValue := reflectutils.PointerValueElem(fromValue) retElemValue := reflectutils.PointerValueElem(retValue) for i := 0; i < retElemValue.NumField(); i++ { retField := retElemValue.Field(i) if !retField.IsValid() { return fserr.New("被赋值的结构存在无效字段") } // 初始化空值指针 if retField.Kind() == reflect.Ptr && retField.IsNil() { retField.Set(reflect.New(retField.Type().Elem())) } } err := parseStructAssignTag(fromElemValue, &retElemValue, onParsedFieldTagFunc) if err != nil { return err } return nil } func assignField(fromFieldElemValue reflect.Value, retFieldElemValue reflect.Value, tag *AssignTag) error { fromKind := reflectutils.GroupValueKind(fromFieldElemValue) retKind := reflectutils.GroupValueKind(retFieldElemValue) var fromAny any switch fromKind { case reflect.Struct: // time.Time类型的结构,接收字段是string类型,使用FormatTime的格式转换 if reflectutils.IsValueTime(fromFieldElemValue) && retKind == reflect.String { fromString := fromFieldElemValue.Interface().(time.Time).Format(tag.FormatTime) fromAny = assignTrimFromString(fromString, tag) break } // 不是time.Time类型的结构,接收字段是结构,执行结构到结构字段的赋值 if !reflectutils.IsValueTime(fromFieldElemValue) && retKind == reflect.Struct { return parseStructAssignTag(fromFieldElemValue, &retFieldElemValue, func(fromFieldName string, fromFieldElemValue reflect.Value, retFieldElementValue reflect.Value, tag *AssignTag) error { return assignField(fromFieldElemValue, retFieldElementValue, tag) }) } // 直接将整个结构进行字段赋值 fromAny = fromFieldElemValue.Interface() case reflect.Slice: if reflectutils.IsSliceValueOf(fromFieldElemValue, reflect.String) && retKind == reflect.String { fromString := strings.Join(fromFieldElemValue.Interface().([]string), tag.JoinWith) fromAny = assignTrimFromString(fromString, tag) break } fromAny = fromFieldElemValue.Interface() case reflect.String: fromString := fromFieldElemValue.String() if reflectutils.IsValueTime(retFieldElemValue) { retTimeField, err := time.ParseInLocation(tag.ParseTime, fromString, time.Local) if err != nil { return err } fromAny = retTimeField break } if reflectutils.IsSliceValueOf(retFieldElemValue, reflect.String) { fromAny = strings.Split(fromString, tag.SplitWith) break } fromAny = assignTrimFromString(fromString, tag) default: fromAny = fromFieldElemValue.Interface() } switch retKind { case reflect.Int64: return reflectutils.AssignInt64Value(fromAny, retFieldElemValue) case reflect.Uint64: return reflectutils.AssignUint64Value(fromAny, retFieldElemValue) case reflect.Float64: return reflectutils.AssignFloat64Value(fromAny, retFieldElemValue) case reflect.Bool: return reflectutils.AssignBoolValue(fromAny, retFieldElemValue) case reflect.String: return reflectutils.AssignStringValue(fromAny, retFieldElemValue) default: retFieldElemValue.Set(reflect.ValueOf(fromAny)) return nil } } func assignTrimFromString(fromString string, tag *AssignTag) string { if strutils.IsStringNotEmpty(tag.Trim) { return strings.Trim(fromString, tag.Trim) } else { if strutils.IsStringNotEmpty(tag.TrimPrefix) { return strings.TrimPrefix(fromString, tag.TrimPrefix) } if strutils.IsStringNotEmpty(tag.TrimSuffix) { return strings.TrimSuffix(fromString, tag.TrimSuffix) } } return fromString } func parseStructAssignTag(fromElemValue reflect.Value, retElemValue *reflect.Value, onParsedFieldTagFunc OnAssignParsedFieldTagFunc) error { for i := 0; i < fromElemValue.NumField(); i++ { fromField := fromElemValue.Type().Field(i) fromFieldValue := fromElemValue.Field(i) // 无效值 if !fromFieldValue.IsValid() { continue } if fromFieldValue.Kind() == reflect.Pointer && fromFieldValue.IsNil() { fromFieldValue.Set(reflect.New(fromField.Type.Elem())) } fromFieldElemValue := reflectutils.PointerValueElem(fromFieldValue) tagStr := fromField.Tag.Get(assignTagKey) // 结构类型的字段上没有添加Tag, 先尝试直接按照字段赋值 if strutils.IsStringEmpty(tagStr) && fromFieldElemValue.Kind() == reflect.Struct && !reflectutils.IsValueTime(fromFieldElemValue) { err := parseStructAssignTag(fromFieldElemValue, retElemValue, onParsedFieldTagFunc) if err != nil { return err } continue } tag, err := parseAssignTag(fromField, tagStr) if err != nil { return err } if tag == nil { continue } retFieldValue := retElemValue.FieldByName(tag.ToField) // 不存在对应的字段 if !retFieldValue.IsValid() { continue } retFieldElemValue := retFieldValue if retFieldValue.Kind() == reflect.Pointer { if !retFieldValue.IsValid() { continue } if !retFieldValue.CanSet() { continue } // 空值针,初始化 if retFieldValue.IsNil() { retFieldValue.Set(reflect.New(retFieldValue.Type().Elem())) } retFieldElemValue = retFieldValue.Elem() } err = onParsedFieldTagFunc(fromField.Name, fromFieldElemValue, retFieldElemValue, tag) if err != nil { return err } } return nil } const ( assignDefaultStringSliceSeparator = "::" assignTagPartSeparator = ";" assignTagPartKeyValueSeparator = ":" ) const ( assignTagKey = "assign" assignIgnore = "-" assignToField = "toField" assignParseTime = "parseTime" assignFormatTime = "formatTime" assignJoinWith = "joinWith" assignSplitWith = "splitWith" assignTrim = "trim" assignTrimPrefix = "trimPrefix" assignTrimSuffix = "trimSuffix" ) type AssignTag struct { ToField string ParseTime string FormatTime string JoinWith string SplitWith string Trim string TrimPrefix string TrimSuffix string } func parseAssignTag(field reflect.StructField, tagStr string) (*AssignTag, error) { if tagStr == assignIgnore { return nil, nil } tag := &AssignTag{ ToField: field.Name, ParseTime: time.DateTime, FormatTime: time.DateTime, JoinWith: assignDefaultStringSliceSeparator, SplitWith: assignDefaultStringSliceSeparator, Trim: "", TrimPrefix: "", TrimSuffix: "", } if strutils.IsStringEmpty(tagStr) { return tag, nil } assignParts := strings.Split(tagStr, assignTagPartSeparator) if assignParts != nil || len(assignParts) != 0 { for _, assignPart := range assignParts { assignPartKeyValue := strings.SplitN(strings.TrimSpace(assignPart), assignTagPartKeyValueSeparator, 2) if assignPartKeyValue != nil && len(assignPartKeyValue) == 2 && strutils.IsStringNotEmpty(assignPartKeyValue[1]) { assignPartKeyValue[1] = strings.Trim(assignPartKeyValue[1], "'") } switch assignPartKeyValue[0] { case assignToField: tag.ToField = assignPartKeyValue[1] case assignParseTime: tag.ParseTime = assignPartKeyValue[1] case assignFormatTime: tag.FormatTime = assignPartKeyValue[1] case assignJoinWith: if strutils.IsStringEmpty(assignPartKeyValue[1]) { return nil, fserr.New(assignJoinWith + "没有赋值分隔符") } tag.JoinWith = assignPartKeyValue[1] case assignSplitWith: if strutils.IsStringEmpty(assignPartKeyValue[1]) { return nil, fserr.New(assignSplitWith + "没有赋值分隔符") } tag.SplitWith = assignPartKeyValue[1] case assignTrim: tag.Trim = assignPartKeyValue[1] case assignTrimPrefix: tag.TrimPrefix = assignPartKeyValue[1] case assignTrimSuffix: tag.TrimSuffix = assignPartKeyValue[1] default: err := fserr.New(assignTagKey + "不支持的tag: " + assignPartKeyValue[0]) logger.GetInstance().Error(err) continue } } } return tag, nil }