1 Star 0 Fork 0

余济舟/aid

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
any_array.go 11.33 KB
一键复制 编辑 原始数据 按行查看 历史
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545
package anyArrayV2
import (
"encoding/json"
"fmt"
"math/rand"
"reflect"
"slices"
"sort"
"strings"
"sync"
"time"
"github.com/spf13/cast"
)
type AnyArray[T any] struct {
data []T
mu *sync.RWMutex
}
func New[T any](attrs ...Attributer[T]) AnyArray[T] {
a := AnyArray[T]{data: []T{}, mu: &sync.RWMutex{}}
return a.SetAttrs(attrs...)
}
func NewList[T any](list []T) AnyArray[T] { return New(List(list)) }
func NewItems[T any](items ...T) AnyArray[T] { return New(Items(items...)) }
func (my AnyArray[T]) SetAttrs(attrs ...Attributer[T]) AnyArray[T] {
if len(attrs) > 0 {
for idx := range attrs {
attrs[idx].Register(&my)
}
}
return my
}
func (my AnyArray[T]) Lock() AnyArray[T] {
my.mu.Lock()
return my
}
func (my AnyArray[T]) Unlock() AnyArray[T] {
my.mu.Unlock()
return my
}
func (my AnyArray[T]) RLock() AnyArray[T] {
my.mu.RLock()
return my
}
func (my AnyArray[T]) RUnlock() AnyArray[T] {
my.mu.RUnlock()
return my
}
// Empty 判断是否为空
func (my AnyArray[T]) Empty() bool { return len(my.data) == 0 }
// NotEmpty 判断是否不为空
func (my AnyArray[T]) NotEmpty() bool { return !my.Empty() }
// IfEmpty 判断是否为空:如果为空则执行回调
func (my AnyArray[T]) IfEmpty(fn func()) {
if len(my.data) == 0 {
fn()
}
}
// IfNotEmpty 判断是否不为空:如果不为空则执行回调
func (my AnyArray[T]) IfNotEmpty(fn func()) {
if len(my.data) != 0 {
fn()
}
}
// IfEmptyError 判断是否为空:如果为空则执行回调并返回错误
func (my AnyArray[T]) IfEmptyError(fn func() error) error {
if len(my.data) == 0 {
return fn()
}
return nil
}
// IfNotEmptyError 判断是否不为空:如果不为空则执行回调并返回错误
func (my AnyArray[T]) IfNotEmptyError(fn func() error) error {
if len(my.data) != 0 {
return fn()
}
return nil
}
// Has 检查是否存在
func (my AnyArray[T]) Has(k int) bool { return k >= 0 && k < len(my.data) }
func (my AnyArray[T]) SetValue(k int, v T) AnyArray[T] {
my.data[k] = v
return my
}
// Get 获取值
func (my AnyArray[T]) GetValue(idx int) T { return my.data[idx] }
// GetValuePtr 获取值指针
func (my AnyArray[T]) GetValuePtr(idx int) *T {
if idx < 0 || idx >= len(my.data) {
return nil
}
return &my.data[idx]
}
// GetValueOrDefault 获取值:如果索引不存在则返回默认值
func (my AnyArray[T]) GetValueOrDefault(idx int, defaultValue T) T {
if idx < 0 || idx >= len(my.data) {
return defaultValue
}
return my.data[idx]
}
func (my AnyArray[T]) GetValues(indexes ...int) []T {
res := make([]T, len(indexes))
for k, idx := range indexes {
res[k] = my.data[idx]
}
return res
}
func (my AnyArray[T]) Append(v ...T) AnyArray[T] {
return New(List(append(my.data, v...)))
}
// First 获取第一个值
func (my AnyArray[T]) First() T {
var t T
if len(my.data) > 0 {
return my.data[0]
}
return t
}
// Last 获取最后一个值
func (my AnyArray[T]) Last() T {
var t T
if len(my.data) > 0 {
return my.data[len(my.data)-1]
}
return t
}
// ToSlice 获取全部值:到切片
func (my AnyArray[T]) ToSlice() []T { return my.data }
// GetIndexes 获取所有索引
func (my AnyArray[T]) GetIndexes() []int {
var indexes = make([]int, len(my.data))
for i := range my.data {
indexes[i] = i
}
return indexes
}
// GetIndexByValue 根据值获取索引下标
func (my AnyArray[T]) GetIndexByValue(value T) int {
for idx, val := range my.data {
if reflect.DeepEqual(val, value) {
return idx
}
}
return -1
}
// GetIndexesByValues 通过值获取索引下标
func (my AnyArray[T]) GetIndexesByValues(values ...T) []int {
var indexes []int
for _, value := range values {
for idx, val := range my.data {
if reflect.DeepEqual(val, value) {
indexes = append(indexes, idx)
}
}
}
return indexes
}
// Shuffle 打乱切片中的元素顺序
func (my AnyArray[T]) Shuffle() AnyArray[T] {
randStr := rand.New(rand.NewSource(time.Now().UnixNano()))
newData := my.data
for i := range my.data {
j := randStr.Intn(i + 1) // 生成 [0, i] 范围内的随机数
newData[i], newData[j] = newData[j], newData[i] // 交换元素
}
return New(List(newData))
}
// Length 获取数组长度
func (my AnyArray[T]) Length() int { return len(my.data) }
// LengthNotEmpty 获取非0值长度
func (my *AnyArray[T]) LengthNotEmpty() int { return my.RemoveEmpty().Length() }
// Filter 过滤数组值
func (my AnyArray[T]) Filter(fn func(item T) bool) AnyArray[T] {
j := 0
ret := make([]T, len(my.data))
for i := range my.data {
if fn(my.data[i]) {
ret[j] = my.data[i]
j++
}
}
return New(List(ret[:j]))
}
// RemoveEmpty 清除0值元素
func (my AnyArray[T]) RemoveEmpty() AnyArray[T] {
return my.Filter(func(item T) bool {
ref := reflect.ValueOf(item)
if ref.Kind() == reflect.Ptr {
if ref.IsNil() {
return false
}
if ref.Elem().IsZero() {
return false
}
} else {
if ref.IsZero() {
return false
}
}
return true
})
}
// Join 拼接字符串
func (my AnyArray[T]) Join(sep string) string {
values := make([]string, my.Length())
for idx := range my.data {
values[idx] = cast.ToString(my.data[idx])
}
return strings.Join(values, sep)
}
// JoinNotEmpty 拼接非空元素
func (my AnyArray[T]) JoinNotEmpty(sep string) string { return my.RemoveEmpty().Join(sep) }
func (my AnyArray[T]) in(target T) bool {
for idx := range my.data {
if reflect.DeepEqual(target, my.data[idx]) {
return true
}
}
return false
}
// In 检查值是否存在
func (my AnyArray[T]) In(targets ...T) bool { return slices.ContainsFunc(targets, my.in) }
// NotIn 检查值是否不存在
func (my AnyArray[T]) NotIn(targets ...T) bool { return !slices.ContainsFunc(targets, my.in) }
func (my AnyArray[T]) IfIn(fn func(), targets ...T) {
if my.In(targets...) {
fn()
}
}
func (my AnyArray[T]) IfNotIn(fn func(), targets ...T) {
if my.NotIn(targets...) {
fn()
}
}
func (my AnyArray[T]) IfInError(fn func() error, targets ...T) error {
if my.In(targets...) {
return fn()
}
return nil
}
func (my AnyArray[T]) IfNotInError(fn func() error, targets ...T) error {
if my.NotIn(targets...) {
return fn()
}
return nil
}
// AllEmpty 判断当前数组是否0空
func (my AnyArray[T]) AllEmpty() bool { return my.RemoveEmpty().Length() == 0 }
// AnyEmpty 判断当前数组中是否存在0值
func (my AnyArray[T]) AnyEmpty() bool { return my.RemoveEmpty().Length() != my.Length() }
// Chunk 分块
func (my AnyArray[T]) Chunk(size int) [][]T {
var chunks [][]T
for i := 0; i < len(my.data); i += size {
end := min(i+size, len(my.data))
chunks = append(chunks, my.data[i:end])
}
return chunks
}
// Pluck 获取数组中指定字段的值
func (my AnyArray[T]) Pluck(fn func(item T) any) AnyArray[any] {
var ret = make([]any, 0)
for _, v := range my.data {
ret = append(ret, fn(v))
}
return New(List(ret))
}
// Intersection 取交集
func (my AnyArray[T]) Intersection(other AnyArray[T]) AnyArray[T] {
if other.Empty() {
return New[T]()
}
var intersection = make([]T, 0)
for idx := range my.data {
if other.In(my.data[idx]) {
intersection = append(intersection, my.data[idx])
}
}
return New(List(intersection))
}
// IntersectionBySlice 取交集:通过切片
func (my AnyArray[T]) IntersectionBySlice(other ...T) AnyArray[T] {
return my.Intersection(New(List(other)))
}
// Difference 取差集
func (my AnyArray[T]) Difference(other AnyArray[T]) AnyArray[T] {
if other.Empty() {
return New[T]()
}
var difference = make([]T, 0)
for _, value := range my.data {
if !other.In(value) {
difference = append(difference, value)
}
}
return New(List(difference))
}
// DifferenceBySlice 取差集:通过切片
func (my AnyArray[T]) DifferenceBySlice(other ...T) AnyArray[T] {
return my.Difference(New(List(other)))
}
// Union 取并集
func (my AnyArray[T]) Union(other AnyArray[T]) AnyArray[T] {
if other.Empty() {
return New[T]()
}
var union = make([]T, 0)
union = append(union, my.data...)
for _, value := range other.data {
if !my.In(value) {
union = append(union, value)
}
}
return New(List(union))
}
// UnionBySlice 取并集:通过切片
func (my AnyArray[T]) UnionBySlice(other []T) AnyArray[T] {
return my.Union(New(List(other)))
}
// Unique 去重
func (my AnyArray[T]) Unique() AnyArray[T] {
seen := make(map[string]struct{}) // 使用空结构体作为值,因为我们只关心键
result := make([]T, 0)
for _, value := range my.data {
key := fmt.Sprintf("%v", value)
if _, exists := seen[key]; !exists {
seen[key] = struct{}{}
result = append(result, value)
}
}
return New(List(result))
}
// RemoveByIndex 根据索引删除元素
func (my AnyArray[T]) RemoveByIndex(index int) AnyArray[T] {
if index < 0 || index >= len(my.data) {
return my
}
return New(List(append(my.data[:index], my.data[index+1:]...)))
}
// RemoveByIndexes 根据索引删除元素
func (my AnyArray[T]) RemoveByIndexes(indexes ...int) AnyArray[T] {
newData := make([]T, 0, len(my.data))
myIndexes := make([]int, 0, len(indexes))
for idx := range indexes {
if indexes[idx] < 0 || indexes[idx] >= len(my.data) {
myIndexes = append(myIndexes, indexes[idx])
}
}
for idx := range my.data {
for idx2 := range myIndexes {
if idx == idx2 {
continue
}
newData = append(newData, my.data[idx])
}
}
return New(List(newData))
}
// RemoveByValue 删除数组中对应的目标
func (my AnyArray[T]) RemoveByValue(target T) AnyArray[T] {
var ret = make([]T, len(my.data))
j := 0
for _, value := range my.data {
if !reflect.DeepEqual(value, target) {
ret[j] = value
j++
}
}
return New(List(ret[:j]))
}
// RemoveByValues 删除数组中对应的多个目标
func (my AnyArray[T]) RemoveByValues(targets ...T) AnyArray[T] {
data := my.data
for idx := range targets {
data = New(List(data)).RemoveByValues(targets[idx]).data
}
return New(List(data))
}
// Every 循环处理每一个
func (my AnyArray[T]) Every(fn func(item T) T) AnyArray[T] {
data := make([]T, len(my.data))
for idx := range my.data {
data[idx] = fn(my.data[idx])
}
return New(List(data))
}
// Each 遍历数组
func (my AnyArray[T]) Each(fn func(idx int, item T)) AnyArray[T] {
for idx := range my.data {
fn(idx, my.data[idx])
}
return my
}
// Sort 排序
func (my AnyArray[T]) Sort(fn func(i, j int) bool) AnyArray[T] {
sort.Slice(my.data, fn)
return my
}
// Clean 清理数据
func (my AnyArray[T]) Clean() AnyArray[T] {
my.data = make([]T, 0)
return my
}
// MarshalJSON 实现接口:json序列化
func (my AnyArray[T]) MarshalJSON() ([]byte, error) { return json.Marshal(&my.data) }
// UnmarshalJSON 实现接口:json反序列化
func (my AnyArray[T]) UnmarshalJSON(data []byte) error { return json.Unmarshal(data, &my.data) }
// ToString 导出string
func (my AnyArray[T]) ToString(formats ...string) string {
var format = "%v"
if len(formats) > 0 {
format = formats[0]
}
return fmt.Sprintf(format, my.data)
}
// Cast 转换值类型
func Cast[SRC, DST any](aa AnyArray[SRC], fn func(value SRC) DST) AnyArray[DST] {
if aa.Length() == 0 {
return New[DST]()
}
data := make([]DST, len(aa.data))
for idx := range aa.data {
data[idx] = fn(aa.data[idx])
}
return New(List(data))
}
// ToAny converts any slice to []any
func ToAny(slice any) []any {
v := reflect.ValueOf(slice)
if v.Kind() != reflect.Slice {
return nil
}
result := make([]any, v.Len())
for i := range v.Len() {
result[i] = v.Index(i).Interface()
}
return result
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/jericho-yu/aid.git
git@gitee.com:jericho-yu/aid.git
jericho-yu
aid
aid
v1.45.13

搜索帮助