function.go

package kgo

import (
	"bytes"
	"crypto/md5"
	"crypto/sha1"
	"crypto/sha256"
	"crypto/sha512"
	"encoding/base64"
	"encoding/binary"
	"encoding/hex"
	"encoding/json"
	"errors"
	"fmt"
	"hash"
	"io"
	"math"
	"net/url"
	"reflect"
	"strconv"
	"strings"
	"unicode"
	"unicode/utf8"
	"unsafe"
)

// dumpPrint 打印调试变量,变量可多个.
func dumpPrint(vs ...interface{}) {
	for _, v := range vs {
		fmt.Printf("%+v\n", v)
	}
}

// lenArrayOrSlice 获取数组/切片的长度.
// chkType为检查类型,枚举值有(1仅数组,2仅切片,3数组或切片);结果为-1表示变量不是数组或切片,>=0表示合法长度.
func lenArrayOrSlice(val interface{}, chkType uint8) int {
	if chkType != 1 && chkType != 2 && chkType != 3 {
		chkType = 3
	}

	var res = -1
	refVal := reflect.ValueOf(val)
	switch refVal.Kind() {
	case reflect.Array:
		if chkType == 1 || chkType == 3 {
			res = refVal.Len()
		}
	case reflect.Slice:
		if chkType == 2 || chkType == 3 {
			res = refVal.Len()
		}
	}

	return res
}

// isBool 是否布尔值.
func isBool(val interface{}) bool {
	return val == true || val == false
}

// isMap 检查变量是否字典.
func isMap(val interface{}) bool {
	return reflect.ValueOf(val).Kind() == reflect.Map
}

// isStruct 检查变量是否结构体.
func isStruct(val interface{}) bool {
	r, _ := reflectFinalValue(reflect.ValueOf(val))
	return r.Kind() == reflect.Struct
}

// isInterface 变量是否接口.
func isInterface(val interface{}) bool {
	r, _ := reflectFinalValue(reflect.ValueOf(val))
	return r.Kind() == reflect.Invalid
}

// isString 变量是否字符串.
func isString(val interface{}) bool {
	return GetVariateType(val) == "string"
}

// isByte 变量是否字节切片.
func isByte(val interface{}) bool {
	return GetVariateType(val) == "[]uint8"
}

// isBinary 字符串是否二进制.
func isBinary(s string) bool {
	for _, b := range s {
		if 0 == b {
			return true
		}
	}
	return false
}

// isHex 是否十六进制字符串.
func isHex(str string) (res bool) {
	if len(str) > 0 {
		_, err := hex2Byte(str)
		res = (err == nil)
	}

	return
}

// isInt 变量是否整型数值.
func isInt(val interface{}) bool {
	switch val.(type) {
	case int, int8, int16, int32, int64, uint, uint8, uint16, uint32, uint64:
		return true
	case string:
		str := val.(string)
		if str == "" {
			return false
		}
		_, err := strconv.Atoi(str)
		return err == nil
	}

	return false
}

// isFloat 变量是否浮点数值.
func isFloat(val interface{}) bool {
	switch val.(type) {
	case float32, float64:
		return true
	case string:
		str := val.(string)
		if str == "" {
			return false
		}

		if ok := RegFloat.MatchString(str); ok {
			return true
		}
	}

	return false
}

// isNumeric 变量是否数值(不包含复数).
func isNumeric(val interface{}) bool {
	switch val.(type) {
	case int, int8, int16, int32, int64, uint, uint8, uint16, uint32, uint64:
		return true
	case float32, float64:
		return true
	case string:
		str := val.(string)
		if str == "" {
			return false
		}
		_, err := strconv.ParseFloat(str, 64)
		return err == nil
	}

	return false
}

// isNil 检查变量是否nil.
func isNil(val interface{}) bool {
	rv := reflect.ValueOf(val)
	switch rv.Kind() {
	case reflect.Invalid:
		return true
	case reflect.Chan, reflect.Func, reflect.Map, reflect.Ptr, reflect.Slice, reflect.Interface:
		return rv.IsNil()
	}

	return val == nil
}

// isEmpty 检查变量是否为空.
func isEmpty(val interface{}) bool {
	v := reflect.ValueOf(val)
	switch v.Kind() {
	case reflect.Invalid:
		return true
	case reflect.String, reflect.Array:
		return v.Len() == 0
	case reflect.Map, reflect.Slice:
		return v.Len() == 0 || v.IsNil()
	case reflect.Bool:
		return !v.Bool()
	case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
		return v.Int() == 0
	case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64, reflect.Uintptr:
		return v.Uint() == 0
	case reflect.Float32, reflect.Float64:
		return v.Float() == 0
	case reflect.Interface, reflect.Ptr:
		return v.IsNil()
	}

	return reflect.DeepEqual(val, reflect.Zero(v.Type()).Interface())
}

// isLittleEndian 系统字节序类型是否小端存储.
func isLittleEndian() bool {
	var i int32 = 0x01020304

	// 将int32类型的指针转换为byte类型的指针
	u := unsafe.Pointer(&i)
	pb := (*byte)(u)

	// 取得pb位置对应的值
	b := *pb

	// 由于b是byte类型的,最多保存8位,那么只能取得开始的8位
	// 小端: 04 (03 02 01)
	// 大端: 01 (02 03 04)
	return (b == 0x04)
}

// isUrl 字符串是否URL.
func isUrl(str string) bool {
	if str == "" || len(str) <= 3 || utf8.RuneCountInString(str) >= 2083 || strings.HasPrefix(str, ".") {
		return false
	}

	u, err := url.Parse(str)

	//Couldn't even parse the url
	if err != nil {
		return false
	}

	//Invalid host
	if u.Host == "" || strings.HasPrefix(u.Host, ".") || strings.HasSuffix(u.Host, ":") {
		return false
	}

	//No Scheme found
	if u.Scheme == "" {
		return false
	}

	var inScheme bool
	var schemes = []string{"ftp", "tcp", "udp", "irc", "rtmp", "ws", "wss", "http", "https"}
	for _, s := range schemes {
		if u.Scheme == s {
			inScheme = true
			break
		}
	}
	if !inScheme {
		return false
	}

	return true
}

// getEndian 获取系统字节序类型,小端返回binary.LittleEndian,大端返回binary.BigEndian .
func getEndian() binary.ByteOrder {
	var nativeEndian binary.ByteOrder = binary.BigEndian
	buf := [2]byte{}
	*(*uint16)(unsafe.Pointer(&buf[0])) = uint16(0xABCD)

	switch buf {
	case [2]byte{0xCD, 0xAB}:
		nativeEndian = binary.LittleEndian
		//case [2]byte{0xAB, 0xCD}:
		//	nativeEndian = binary.BigEndian
	}

	return nativeEndian
}

// numeric2Float 将数值转换为float64.
func numeric2Float(val interface{}) (res float64, err error) {
	switch val.(type) {
	case int:
		res = float64(val.(int))
	case int8:
		res = float64(val.(int8))
	case int16:
		res = float64(val.(int16))
	case int32:
		res = float64(val.(int32))
	case int64:
		res = float64(val.(int64))
	case uint:
		res = float64(val.(uint))
	case uint8:
		res = float64(val.(uint8))
	case uint16:
		res = float64(val.(uint16))
	case uint32:
		res = float64(val.(uint32))
	case uint64:
		res = float64(val.(uint64))
	case float32:
		res = float64(val.(float32))
	case float64:
		res = val.(float64)
	case string:
		str := val.(string)
		res, err = strconv.ParseFloat(str, 64)
	}
	return
}

// md5Byte 计算字节切片的 MD5 散列值.
func md5Byte(str []byte, length uint8) []byte {
	var res []byte
	h := md5.New()
	_, err := h.Write(str)
	if err == nil {
		hashInBytes := h.Sum(nil)
		dst := make([]byte, hex.EncodedLen(len(hashInBytes)))
		hex.Encode(dst, hashInBytes)
		if length > 0 && length < 32 {
			res = dst[:length]
		} else {
			res = dst
		}
	}

	return res
}

// md5Reader 计算Reader的 MD5 散列值.
func md5Reader(reader io.Reader, length uint8) (res []byte, err error) {
	h := md5.New()
	if _, err = io.Copy(h, reader); err == nil {
		hashInBytes := h.Sum(nil)
		dst := make([]byte, hex.EncodedLen(len(hashInBytes)))
		hex.Encode(dst, hashInBytes)
		if length > 0 && length < 32 {
			res = dst[:length]
		} else {
			res = dst
		}
	}

	return
}

// shaXByte 计算字节切片的 shaX 散列值,x为1/256/512.
func shaXByte(str []byte, x uint16) []byte {
	var h hash.Hash
	switch x {
	case 1:
		h = sha1.New()
	case 256:
		h = sha256.New()
	case 512:
		h = sha512.New()
	default:
		panic(fmt.Sprintf("[shaXByte]`x must be in [1, 256, 512]; but: %d", x))
	}

	_, _ = h.Write(str)
	hashInBytes := h.Sum(nil)
	res := make([]byte, hex.EncodedLen(len(hashInBytes)))
	hex.Encode(res, hashInBytes)

	return res
}

// shaXReader 计算Reader的 shaX 散列值,x为1/256/512.
func shaXReader(reader io.Reader, x uint16) (res []byte, err error) {
	var h hash.Hash
	switch x {
	case 1:
		h = sha1.New()
	case 256:
		h = sha256.New()
	case 512:
		h = sha512.New()
	default:
		panic(fmt.Sprintf("[shaXReader]`x must be in [1, 256, 512]; but: %d", x))
	}

	if _, err = io.Copy(h, reader); err == nil {
		hashInBytes := h.Sum(nil)
		res = make([]byte, hex.EncodedLen(len(hashInBytes)))
		hex.Encode(res, hashInBytes)
	}

	return
}

// arrayValues 返回arr(数组/切片/字典/结构体)中所有的值.
// filterZero 是否过滤零值元素(nil,false,0,”,[]),true时排除零值元素,false时保留零值元素.
func arrayValues(arr interface{}, filterZero bool) []interface{} {
	var res []interface{}
	var fieldVal reflect.Value
	val := reflect.ValueOf(arr)
	switch val.Kind() {
	case reflect.Array, reflect.Slice:
		for i := 0; i < val.Len(); i++ {
			fieldVal = val.Index(i)
			if !filterZero || (filterZero && !fieldVal.IsZero()) {
				res = append(res, fieldVal.Interface())
			}
		}
	case reflect.Map:
		for _, k := range val.MapKeys() {
			fieldVal = val.MapIndex(k)
			if !filterZero || (filterZero && !fieldVal.IsZero()) {
				res = append(res, fieldVal.Interface())
			}
		}
	case reflect.Struct:
		for i := 0; i < val.NumField(); i++ {
			fieldVal = val.Field(i)
			if fieldVal.CanInterface() {
				if !filterZero || (filterZero && !fieldVal.IsZero()) {
					res = append(res, fieldVal.Interface())
				}
			}
		}
	default:
		panic("[arrayValues]`arr type must be array|slice|map|struct; but : " + val.Kind().String())
	}

	return res
}

// reflectFinalValue 获取反射的最终值.
func reflectFinalValue(r reflect.Value) (reflect.Value, bool) {
	var isPtr bool
	// 如果是指针,则获取其所指向的元素
	if r.Kind() == reflect.Ptr {
		r = r.Elem()
		isPtr = true
	}
	return r, isPtr
}

// reflectFinalType 获取反射的最终类型.
func reflectFinalType(r reflect.Type) (reflect.Type, bool) {
	var isPtr bool
	// 如果是指针,则获取其所指向的元素
	if r.Kind() == reflect.Ptr {
		r = r.Elem()
		isPtr = true
	}
	return r, isPtr
}

// reflectTypesMap 递归获取反射字段类型Map.
func reflectTypesMap(r reflect.Type, res map[string]reflect.Type) {
	for i := 0; i < r.NumField(); i++ {
		field := r.Field(i)
		if field.Anonymous { //匿名字段
			subTyp := r.Field(i).Type
			reflectTypesMap(subTyp, res)
		} else if field.PkgPath == "" { //公开字段
			res[field.Name] = field.Type
		}
	}
}

// reflect2Itf 将反射值转为接口(原值)
func reflect2Itf(r reflect.Value) (res interface{}) {
	switch r.Kind() {
	case reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int, reflect.Int64:
		res = r.Int()
	case reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint, reflect.Uint64:
		res = r.Uint()
	case reflect.Float32, reflect.Float64:
		res = r.Float()
	case reflect.String:
		res = r.String()
	case reflect.Bool:
		res = r.Bool()
	default:
		if r.CanInterface() {
			res = r.Interface()
		} else {
			res = r
		}
	}

	return
}

// structVal 获取结构体的反射值.
func structVal(obj interface{}) (reflect.Value, error) {
	v := reflect.ValueOf(obj)

	for v.Kind() == reflect.Ptr {
		v = v.Elem()
	}

	if v.Kind() != reflect.Struct {
		return v, errors.New("[structVal]`obj type must be struct; but : " + v.Kind().String())
	}

	return v, nil
}

// structFields 获取结构体的字段切片;all是否包含所有字段(包括未导出的).
func structFields(obj interface{}, all bool) ([]reflect.StructField, error) {
	v, e := structVal(obj)
	if e != nil {
		return nil, e
	}

	var fs []reflect.StructField
	var t = v.Type()
	for i := 0; i < t.NumField(); i++ {
		field := t.Field(i)
		// 不能访问未导出的字段
		if !all && field.PkgPath != "" {
			continue
		}

		fs = append(fs, field)
	}

	return fs, nil
}

// struct2Map 结构体转为字典;tagName为要导出的标签名,可以为空,为空时将导出所有字段.
func struct2Map(obj interface{}, tagName string) (map[string]interface{}, error) {
	v, e := structVal(obj)
	if e != nil {
		return nil, e
	}

	t := v.Type()
	var res = make(map[string]interface{})
	for i := 0; i < t.NumField(); i++ {
		field := t.Field(i)
		if tagName != "" {
			if tagValue := field.Tag.Get(tagName); tagValue != "" {
				res[tagValue] = reflect2Itf(v.Field(i))
			}
		} else {
			res[field.Name] = reflect2Itf(v.Field(i))
		}
	}

	return res, nil
}

// creditChecksum 计算身份证校验码,其中id为身份证号码.
func creditChecksum(id string) byte {
	//∑(ai×Wi)(mod 11)
	// 加权因子
	factor := []int{7, 9, 10, 5, 8, 4, 2, 1, 6, 3, 7, 9, 10, 5, 8, 4, 2}
	// 校验位对应值
	code := []byte{'1', '0', 'X', '9', '8', '7', '6', '5', '4', '3', '2'}

	leng := len(id)
	sum := 0
	for i, char := range id[:leng-1] {
		num, _ := strconv.Atoi(string(char))
		sum += num * factor[i]
	}

	return code[sum%11]
}

// compareConditionMap 比对数组是否匹配条件.condition为条件字典,arr为要比对的数据(字典/结构体).
func compareConditionMap(condition map[string]interface{}, arr interface{}) (res interface{}) {
	val := reflect.ValueOf(arr)
	conNum := len(condition)
	if conNum > 0 {
		chkNum := 0

		switch val.Kind() {
		case reflect.Map:
			if conNum > 0 {
				for _, k := range val.MapKeys() {
					if condVal, ok := condition[k.String()]; ok && reflect.DeepEqual(val.MapIndex(k).Interface(), condVal) {
						chkNum++
					}
				}
			}
		case reflect.Struct:
			var field reflect.Value
			for k, v := range condition {
				field = val.FieldByName(k)

				if field.IsValid() && field.CanInterface() && reflect.DeepEqual(field.Interface(), v) {
					chkNum++
				}
			}
		default:
			panic("[compareConditionMap]`arr type must be map|struct; but : " + val.Kind().String())
		}

		if chkNum == conNum {
			res = arr
		}
	}

	return
}

// getTrimMask 获取要修剪的字符串集合,masks为要屏蔽的字符切片.
func getTrimMask(masks []string) string {
	var str string
	if len(masks) == 0 {
		str = blankChars
	} else {
		str = strings.Join(masks, "")
	}
	return str
}

// methodExists 检查val结构体中是否存在methodName方法.
func methodExists(val interface{}, methodName string) (bool, error) {
	if methodName == "" {
		return false, errors.New("[methodExists]`methodName can not be empty.")
	}

	r := reflect.ValueOf(val)
	if r.Type().Kind() != reflect.Ptr {
		r = reflect.New(reflect.TypeOf(val))
	}

	method := r.MethodByName(methodName)
	if !method.IsValid() {
		return false, fmt.Errorf("[methodExists] Method `%s` not exists in interface `%s`", methodName, r.Type())
	}

	return true, nil
}

// getMethod 获取val结构体的methodName方法.
// 注意:返回的方法中的第一个参数是接收者.
// 所以,调用返回的方法时,必须将接收者作为第一个参数传递.
func getMethod(val interface{}, methodName string) interface{} {
	if val == nil || methodName == "" {
		return nil
	}

	r := reflect.ValueOf(val)
	if r.Type().Kind() != reflect.Ptr {
		r = reflect.New(reflect.TypeOf(val))
	}

	method := r.MethodByName(methodName)
	if !method.IsValid() {
		return nil
	}

	return method.Interface()
}

// getFuncNames 获取变量的所有函数名.
func getFuncNames(val interface{}) (res []string) {
	if val == nil {
		return
	}

	r := reflect.ValueOf(val)
	if r.Type().Kind() != reflect.Ptr {
		r = reflect.New(reflect.TypeOf(val))
	}

	typ := r.Type()
	for i := 0; i < r.NumMethod(); i++ {
		res = append(res, typ.Method(i).Name)
	}
	return
}

// camelCaseToLowerCase 驼峰转为小写.
func camelCaseToLowerCase(str string, connector rune) string {
	if len(str) == 0 {
		return ""
	}

	buf := &bytes.Buffer{}
	var prev, r0, r1 rune
	var size int

	r0 = connector

	for len(str) > 0 {
		prev = r0
		r0, size = utf8.DecodeRuneInString(str)
		str = str[size:]

		switch {
		case r0 == utf8.RuneError:
			continue

		case unicode.IsUpper(r0):
			if prev != connector && !unicode.IsNumber(prev) {
				buf.WriteRune(connector)
			}

			buf.WriteRune(unicode.ToLower(r0))

			if len(str) == 0 {
				break
			}

			r0, size = utf8.DecodeRuneInString(str)
			str = str[size:]

			if !unicode.IsUpper(r0) {
				buf.WriteRune(r0)
				break
			}

			// find next non-upper-case character and insert connector properly.
			// it's designed to convert `HTTPServer` to `http_server`.
			// if there are more than 2 adjacent upper case characters in a word,
			// treat them as an abbreviation plus a normal word.
			for len(str) > 0 {
				r1 = r0
				r0, size = utf8.DecodeRuneInString(str)
				str = str[size:]

				if r0 == utf8.RuneError {
					buf.WriteRune(unicode.ToLower(r1))
					break
				}

				if !unicode.IsUpper(r0) {
					if isCaseConnector(r0) {
						r0 = connector

						buf.WriteRune(unicode.ToLower(r1))
					} else if unicode.IsNumber(r0) {
						// treat a number as an upper case rune
						// so that both `http2xx` and `HTTP2XX` can be converted to `http_2xx`.
						buf.WriteRune(unicode.ToLower(r1))
						buf.WriteRune(connector)
						buf.WriteRune(r0)
					} else {
						buf.WriteRune(connector)
						buf.WriteRune(unicode.ToLower(r1))
						buf.WriteRune(r0)
					}

					break
				}

				buf.WriteRune(unicode.ToLower(r1))
			}

			if len(str) == 0 || r0 == connector {
				buf.WriteRune(unicode.ToLower(r0))
			}

		case unicode.IsNumber(r0):
			if prev != connector && !unicode.IsNumber(prev) {
				buf.WriteRune(connector)
			}

			buf.WriteRune(r0)

		default:
			if isCaseConnector(r0) {
				r0 = connector
			}

			buf.WriteRune(r0)
		}
	}

	return buf.String()
}

// isCaseConnector 是否字符转换连接符.
func isCaseConnector(r rune) bool {
	return r == '-' || r == '_' || unicode.IsSpace(r)
}

// pkcs7Padding PKCS7填充.
// cipherText为密文;blockSize为分组长度;isZero是否零填充.
func pkcs7Padding(cipherText []byte, blockSize int, isZero bool) []byte {
	clen := len(cipherText)
	if cipherText == nil || clen == 0 || blockSize <= 0 {
		return nil
	}

	var padtext []byte
	padding := blockSize - clen%blockSize
	if isZero {
		padtext = bytes.Repeat([]byte{0}, padding)
	} else {
		padtext = bytes.Repeat([]byte{byte(padding)}, padding)
	}

	return append(cipherText, padtext...)
}

// pkcs7UnPadding PKCS7拆解.
// origData为源数据;blockSize为分组长度.
func pkcs7UnPadding(origData []byte, blockSize int) (res []byte) {
	//origData = zeroUnPadding(origData)
	olen := len(origData)
	if origData == nil || olen == 0 || blockSize <= 0 || olen%blockSize != 0 {
		return
	}

	unPadding := int(origData[olen-1])
	if unPadding <= olen {
		res = origData[:(olen - unPadding)]
	}

	return
}

// zeroPadding PKCS7使用0填充.
func zeroPadding(cipherText []byte, blockSize int) []byte {
	return pkcs7Padding(cipherText, blockSize, true)
}

// zeroUnPadding PKCS7-0拆解.
func zeroUnPadding(origData []byte) []byte {
	return bytes.TrimRightFunc(origData, func(r rune) bool {
		return r == rune(0)
	})
}

// GetFieldValue 获取(字典/结构体的)字段值;fieldName为字段名,大小写敏感.
func GetFieldValue(arr interface{}, fieldName string) (res interface{}, err error) {
	val := reflect.ValueOf(arr)
	switch val.Kind() {
	case reflect.Map:
		for _, subKey := range val.MapKeys() {
			if fmt.Sprintf("%s", subKey) == fieldName {
				res = val.MapIndex(subKey).Interface()
				break
			}
		}
	case reflect.Struct:
		field := val.FieldByName(fieldName)
		if !field.IsValid() || !field.CanInterface() {
			break
		}
		res = field.Interface()
	default:
		err = errors.New("[GetFieldValue]`arr type must be map|struct; but : " + val.Kind().String())
	}

	return
}

// str2Int 将字符串转换为int.其中"true", "TRUE", "True"为1;若为浮点字符串,则取整数部分.
func str2Int(val string) (res int) {
	if val == "true" || val == "TRUE" || val == "True" {
		res = 1
		return
	} else if ok := RegFloat.MatchString(val); ok {
		fl, _ := strconv.ParseFloat(val, 1)
		res = int(fl)
		return
	}

	res, _ = strconv.Atoi(val)
	return
}

// str2Int 将字符串转换为uint.其中"true", "TRUE", "True"为1;若为浮点字符串,则取整数部分;若为负值则为0.
func str2Uint(val string) (res uint) {
	if val == "true" || val == "TRUE" || val == "True" {
		res = 1
		return
	} else if ok := RegFloat.MatchString(val); ok {
		fl, _ := strconv.ParseFloat(val, 1)
		if fl > 0 {
			res = uint(fl)
		}

		return
	}

	n, e := strconv.Atoi(val)
	if e == nil && n > 0 {
		res = uint(n)
	}

	return
}

// str2Float32 将字符串转换为float32;其中"true", "TRUE", "True"为1.0 .
func str2Float32(val string) (res float32) {
	if val == "true" || val == "TRUE" || val == "True" {
		res = 1.0
	} else {
		r, _ := strconv.ParseFloat(val, 32)
		res = float32(r)
	}

	return
}

// str2Float64 将字符串转换为float64;其中"true", "TRUE", "True"为1.0 .
func str2Float64(val string) (res float64) {
	if val == "true" || val == "TRUE" || val == "True" {
		res = 1.0
	} else {
		res, _ = strconv.ParseFloat(val, 64)
	}

	return
}

// str2Bool 将字符串转换为布尔值.
// 1, t, T, TRUE, true, True 等字符串为真;
// 0, f, F, FALSE, false, False 等字符串为假.
func str2Bool(val string) (res bool) {
	if val != "" {
		res, _ = strconv.ParseBool(val)
	}

	return
}

// bool2Int 将布尔值转换为整型.
func bool2Int(val bool) int {
	if val {
		return 1
	}
	return 0
}

// str2Bytes 将字符串转换为字节切片.
func str2Bytes(val string) []byte {
	return []byte(val)
}

// str2Runes 将字符串转为字符切片.
func str2Runes(val string) []rune {
	return []rune(val)
}

// bytes2Str 将字节切片转换为字符串.
func bytes2Str(val []byte) string {
	return string(val)
}

// str2BytesUnsafe (非安全的)将字符串转换为字节切片.
// 该方法零拷贝,但不安全.它直接转换底层指针,两者指向的相同的内存,改一个另外一个也会变.
// 仅当临时需将长字符串转换且不长时间保存时可以使用.
// 转换之后若没做其他操作直接改变里面的字符,则程序会崩溃.
// 如 b:=str2BytesUnsafe("xxx"); b[1]='d'; 程序将panic.
func str2BytesUnsafe(val string) []byte {
	psHeader := &reflect.SliceHeader{}
	strHeader := (*reflect.StringHeader)(unsafe.Pointer(&val))
	psHeader.Data = strHeader.Data
	psHeader.Len = strHeader.Len
	psHeader.Cap = strHeader.Len
	return *(*[]byte)(unsafe.Pointer(psHeader))
}

// bytes2StrUnsafe (非安全的)将字节切片转换为字符串.
// 零拷贝,不安全.效率是string([]byte{})的百倍以上,且转换量越大效率优势越明显.
func bytes2StrUnsafe(val []byte) string {
	return *(*string)(unsafe.Pointer(&val))
}

// runes2Bytes 将[]rune转为[]byte.
func runes2Bytes(rs []rune) []byte {
	size := 0
	for _, r := range rs {
		size += utf8.RuneLen(r)
	}

	bs := make([]byte, size)

	count := 0
	for _, r := range rs {
		count += utf8.EncodeRune(bs[count:], r)
	}

	return bs
}

// toStr 强制将变量转换为字符串.
func toStr(val interface{}) string {
	//先处理其他类型
	v := reflect.ValueOf(val)
	switch v.Kind() {
	case reflect.Invalid:
		return ""
	case reflect.Bool:
		return strconv.FormatBool(v.Bool())
	case reflect.String:
		return v.String()
	case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
		return strconv.FormatInt(v.Int(), 10)
	case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64, reflect.Uintptr:
		return strconv.FormatUint(v.Uint(), 10)
	case reflect.Float32:
		return strconv.FormatFloat(v.Float(), 'f', -1, 32)
	case reflect.Float64:
		return strconv.FormatFloat(v.Float(), 'f', -1, 64)
	case reflect.Ptr, reflect.Struct, reflect.Map: //指针、结构体和字典
		b, err := json.Marshal(v.Interface())
		if err != nil {
			return ""
		}
		return string(b)
	}

	//再处理字节切片
	switch val.(type) {
	case []uint8:
		return string(val.([]uint8))
	}

	return fmt.Sprintf("%v", val)
}

// toBool 强制将变量转换为布尔值.
// 数值类型将检查值是否>0;
// 字符串将使用str2Bool;
// 数组、切片、字典、通道类型将检查它们的长度是否>0;
// 指针、结构体类型为true,其他为false.
func toBool(val interface{}) (res bool) {
	switch val.(type) {
	case int:
		res = (val.(int) > 0)
	case int8:
		res = (val.(int8) > 0)
	case int16:
		res = (val.(int16) > 0)
	case int32:
		res = (val.(int32) > 0)
	case int64:
		res = (val.(int64) > 0)
	case uint:
		res = (val.(uint) > 0)
	case uint8:
		res = (val.(uint8) > 0)
	case uint16:
		res = (val.(uint16) > 0)
	case uint32:
		res = (val.(uint32) > 0)
	case uint64:
		res = (val.(uint64) > 0)
	case float32:
		res = (val.(float32) > 0)
	case float64:
		res = (val.(float64) > 0)
	case string:
		res = str2Bool(val.(string))
	case bool:
		res = val.(bool)
	default:
		v := reflect.ValueOf(val)
		switch v.Kind() {
		case reflect.Array, reflect.Slice, reflect.Map, reflect.Chan:
			res = v.Len() > 0
		case reflect.Ptr, reflect.Struct:
			res = true
		}
	}

	return
}

// toInt 强制将变量转换为整型.
// 数值类型将转为整型;
// 字符串将使用str2Int;
// 布尔型的true为1,false为0;
// 数组、切片、字典、通道类型将取它们的长度;
// 指针、结构体类型为1,其他为0.
func toInt(val interface{}) (res int) {
	switch val.(type) {
	case int:
		res = val.(int)
	case int8:
		res = int(val.(int8))
	case int16:
		res = int(val.(int16))
	case int32:
		res = int(val.(int32))
	case int64:
		res = int(val.(int64))
	case uint:
		res = int(val.(uint))
	case uint8:
		res = int(val.(uint8))
	case uint16:
		res = int(val.(uint16))
	case uint32:
		res = int(val.(uint32))
	case uint64:
		res = int(val.(uint64))
	case float32:
		res = int(val.(float32))
	case float64:
		res = int(val.(float64))
	case string:
		res = str2Int(val.(string))
	case bool:
		res = bool2Int(val.(bool))
	default:
		v := reflect.ValueOf(val)
		switch v.Kind() {
		case reflect.Array, reflect.Slice, reflect.Map, reflect.Chan:
			res = v.Len()
		case reflect.Ptr, reflect.Struct:
			res = 1
		}
	}

	return
}

// toFloat 强制将变量转换为浮点型.
// 数值类型将转为浮点型;
// 字符串将使用str2Float64;
// 布尔型的true为1.0,false为0;
// 数组、切片、字典、通道类型将取它们的长度;
// 指针、结构体类型为1.0,其他为0.
func toFloat(val interface{}) (res float64) {
	switch val.(type) {
	case int:
		res = float64(val.(int))
	case int8:
		res = float64(val.(int8))
	case int16:
		res = float64(val.(int16))
	case int32:
		res = float64(val.(int32))
	case int64:
		res = float64(val.(int64))
	case uint:
		res = float64(val.(uint))
	case uint8:
		res = float64(val.(uint8))
	case uint16:
		res = float64(val.(uint16))
	case uint32:
		res = float64(val.(uint32))
	case uint64:
		res = float64(val.(uint64))
	case float32:
		res = float64(val.(float32))
	case float64:
		res = val.(float64)
	case string:
		res = str2Float64(val.(string))
	case bool:
		if val.(bool) {
			res = 1.0
		}
	default:
		v := reflect.ValueOf(val)
		switch v.Kind() {
		case reflect.Array, reflect.Slice, reflect.Map, reflect.Chan:
			res = float64(v.Len())
		case reflect.Ptr, reflect.Struct:
			res = 1.0
		}
	}

	return
}

// dec2Bin 将十进制转换为二进制字符串.
func dec2Bin(num int64) string {
	return strconv.FormatInt(num, 2)
}

// bin2Dec 将二进制字符串转换为十进制.
func bin2Dec(str string) (int64, error) {
	i, err := strconv.ParseInt(str, 2, 0)
	if err != nil {
		return 0, err
	}
	return i, nil
}

// hex2Bin 将十六进制字符串转换为二进制字符串.
func hex2Bin(str string) (string, error) {
	i, err := strconv.ParseInt(str, 16, 0)
	if err != nil {
		return "", err
	}
	return strconv.FormatInt(i, 2), nil
}

// bin2Hex 将二进制字符串转换为十六进制字符串.
func bin2Hex(str string) (string, error) {
	i, err := strconv.ParseInt(str, 2, 0)
	if err != nil {
		return "", err
	}
	return strconv.FormatInt(i, 16), nil
}

// dec2Hex 将十进制转换为十六进制.
func dec2Hex(num int64) string {
	return strconv.FormatInt(num, 16)
}

// hex2Dec 将十六进制转换为十进制.
func hex2Dec(str string) (int64, error) {
	start := 0
	if len(str) > 2 && str[0:2] == "0x" {
		start = 2
	}

	// bitSize 表示结果的位宽（包括符号位），0 表示最大位宽
	return strconv.ParseInt(str[start:], 16, 0)
}

// hex2Byte 16进制字符串转字节切片.
func hex2Byte(str string) ([]byte, error) {
	start := 0
	if len(str) > 2 && str[0:2] == "0x" {
		start = 2
	}

	h, e := hex.DecodeString(str[start:])
	return h, e
}

// dec2Oct 将十进制转换为八进制.
func dec2Oct(num int64) string {
	return strconv.FormatInt(num, 8)
}

// oct2Dec 将八进制转换为十进制.
func oct2Dec(str string) (int64, error) {
	start := 0
	if len(str) > 1 && str[0:1] == "0" {
		start = 1
	}

	return strconv.ParseInt(str[start:], 8, 0)
}

// getIntersectStrings 获取两个字符串相同部分的切片.
// minLen为子串最小长度,为0则不限制.
func getIntersectStrings(minLen int, str1, str2 string) (res []string) {
	var lenA, lenB, runesLen int
	var runes []rune
	var longStr, itm string
	var chkMap = make(map[string]bool)
	var chk, ok bool

	lenA = len(str1)
	lenB = len(str2)

	if lenA == 0 || lenB == 0 {
		return
	}

	if lenA > lenB {
		longStr = str1
		runes = []rune(str2)
	} else {
		longStr = str2
		runes = []rune(str1)
	}
	runesLen = len(runes)

	for i := 0; i < runesLen; i++ {
		for j := i + 1; j <= runesLen; j++ {
			itm = string(runes[i:j])
			if minLen == 0 || (minLen > 0 && len(itm) >= minLen) {
				_, ok = chkMap[itm]
				if !ok {
					chk = strings.Contains(longStr, itm)
					chkMap[itm] = true
					if chk {
						res = append(res, itm)
					}
				}
			}
		}
	}

	return
}

// longestSameString 获取两个字符串最长相同的子串.
func longestSameString(str1, str2 string) (res string) {
	var resLen, itmLen int
	strs := getIntersectStrings(0, str1, str2)
	if len(strs) > 0 {
		res = strs[0]
		resLen = len(res)
		for _, v := range strs {
			itmLen = len(v)
			if itmLen > resLen {
				res = v
				resLen = itmLen
			}
		}
	}

	return
}

// img2Base64 将图片字节转换为base64字符串.imgType为图片扩展名.
func img2Base64(content []byte, imgType string) string {
	return fmt.Sprintf("data:image/%s;base64,%s", imgType, base64.StdEncoding.EncodeToString(content))
}

// formatPath 格式化路径.
func formatPath(fpath string) string {
	//替换特殊字符
	fpath = strings.NewReplacer(`|`, "", `<`, "", `>`, "", `?`, "", `\`, "/").Replace(fpath)
	//替换连续斜杠
	fpath = RegFormatDir.ReplaceAllString(fpath, "/")

	//处理windows路径(带":")
	slashPos := strings.Index(fpath, "/")
	colonPos := strings.Index(fpath, ":")
	if colonPos >= 0 { //路径中存在":"
		if slashPos == 0 { //路径以"/"开头
			fpath = strings.ReplaceAll(fpath, ":", "")
		} else {
			front := fpath[0 : colonPos+1]
			back := strings.ReplaceAll(fpath[colonPos:], ":", "")
			fpath = front + back
		}
	}

	return fpath
}

// formatDir 格式化目录,将"\","//"替换为"/",且以"/"结尾.
func formatDir(fpath string) string {
	if fpath == "" {
		return ""
	}

	fpath = formatPath(fpath)

	return strings.TrimRight(fpath, "/") + "/"
}

// buildQueryMap 创建URL Query参数字典.
// result 为结果字典;keys 为键数组;value为键值.
func buildQueryMap(result map[string]interface{}, keys []string, value interface{}) error {
	length := len(keys)
	// trim ',"
	key := strings.Trim(keys[0], "',\"")
	if length == 1 {
		result[key] = value
		return nil
	}

	// The end is slice. like f[], f[a][]
	if keys[1] == "" && length == 2 {
		if key == "" {
			return nil
		}
		val, ok := result[key]
		if !ok {
			result[key] = []interface{}{value}
			return nil
		}
		children, ok := val.([]interface{})
		if !ok {
			return fmt.Errorf("[buildQueryMap] expected type '[]interface{}' for key '%s', but got '%T'", key, val)
		}
		result[key] = append(children, value)
		return nil
	}

	// The end is slice + map. like f[][a]
	if keys[1] == "" && length > 2 && keys[2] != "" {
		val, ok := result[key]
		if !ok {
			result[key] = []interface{}{}
			val = result[key]
		}
		children, ok := val.([]interface{})
		if !ok {
			return fmt.Errorf("[buildQueryMap] expected type '[]interface{}' for key '%s', but got '%T'", key, val)
		}
		if l := len(children); l > 0 {
			if child, ok := children[l-1].(map[string]interface{}); ok {
				if _, ok := child[keys[2]]; !ok {
					_ = buildQueryMap(child, keys[2:], value)
					return nil
				}
			}
		}
		child := map[string]interface{}{}
		_ = buildQueryMap(child, keys[2:], value)
		result[key] = append(children, child)

		return nil
	}

	// map. like f[a], f[a][b]
	val, ok := result[key]
	if !ok {
		result[key] = map[string]interface{}{}
		val = result[key]
	}
	children, ok := val.(map[string]interface{})
	if !ok {
		return fmt.Errorf("[buildQueryMap] expected type 'map[string]interface{}' for key '%s', but got '%T'", key, val)
	}

	return buildQueryMap(children, keys[1:], value)
}

// isPort 变量值是否端口号(1~65535).
func isPort(val interface{}) bool {
	if isInt(val) {
		port := toInt(val)
		if port > 0 && port < 65536 {
			return true
		}
	}

	return false
}

// similarText 计算两个字符串的相似度.
func similarText(str1, str2 string, len1, len2 int) int {
	var sum, max int
	pos1, pos2 := 0, 0

	// Find the longest segment of the same section in two strings
	for i := 0; i < len1; i++ {
		for j := 0; j < len2; j++ {
			for l := 0; (i+l < len1) && (j+l < len2) && (str1[i+l] == str2[j+l]); l++ {
				if l+1 > max {
					max = l + 1
					pos1 = i
					pos2 = j
				}
			}
		}
	}

	if sum = max; sum > 0 {
		if pos1 > 0 && pos2 > 0 {
			sum += similarText(str1, str2, pos1, pos2)
		}
		if (pos1+max < len1) && (pos2+max < len2) {
			s1 := []byte(str1)
			s2 := []byte(str2)
			sum += similarText(string(s1[pos1+max:]), string(s2[pos2+max:]), len1-pos1-max, len2-pos2-max)
		}
	}

	return sum
}

// chunkBytes 将字节切片分割为多个小块.其中size为每块的长度.
func chunkBytes(bs []byte, size int) [][]byte {
	bsLen := len(bs)
	if bsLen == 0 || size <= 0 {
		return nil
	} else if bsLen < size {
		return [][]byte{bs}
	}

	var start, last int
	pages := int(math.Ceil(float64(bsLen) / float64(size)))
	res := make([][]byte, pages)
	for i := 0; i < pages; i++ {
		last = start + size
		if last > bsLen {
			res[i] = bs[start:]
		} else {
			res[i] = bs[start:last]
		}
		start = last
	}

	return res
}

// GetVariateType 获取变量类型.
func GetVariateType(v interface{}) string {
	return fmt.Sprintf("%T", v)
}

// GetVariatePointerAddr 获取变量的指针地址.
func GetVariatePointerAddr(val interface{}) int64 {
	var p string
	v := reflect.ValueOf(val)
	switch v.Kind() {
	case reflect.Ptr: //变量是指针
		p = fmt.Sprintf("%p", val)
	default:
		p = fmt.Sprintf("%p", &val)
	}

	res, _ := hex2Dec(p)
	return res
}

// IsPointer 检查变量是否指针类型;
// notNil 是否检查变量非nil.
func IsPointer(val interface{}, notNil bool) (res bool) {
	v := reflect.ValueOf(val)
	if v.Kind() == reflect.Ptr {
		if !notNil || (notNil && val != nil) {
			res = true
		}
	}

	return
}

// VerifyFunc 验证是否函数,并且参数个数、类型是否正确.
// 返回有效的函数、有效的参数.
func VerifyFunc(f interface{}, args ...interface{}) (vf reflect.Value, vargs []reflect.Value, err error) {
	vf = reflect.ValueOf(f)
	if vf.Kind() != reflect.Func {
		return reflect.ValueOf(nil), nil, fmt.Errorf("[VerifyFunc] %v is not the function", f)
	}

	tf := vf.Type()
	num := len(args)
	if tf.NumIn() != num {
		return reflect.ValueOf(nil), nil, fmt.Errorf("[VerifyFunc] %d number of the argument is incorrect", num)
	}

	vargs = make([]reflect.Value, num)
	for i := 0; i < num; i++ {
		typ := tf.In(i).Kind()
		if (typ != reflect.Interface) && (typ != reflect.TypeOf(args[i]).Kind()) {
			return reflect.ValueOf(nil), nil, fmt.Errorf("[VerifyFunc] %d-td argument`s type is incorrect", i+1)
		}
		vargs[i] = reflect.ValueOf(args[i])
	}

	return vf, vargs, nil
}

// CallFunc 动态调用函数.
func CallFunc(f interface{}, args ...interface{}) ([]interface{}, error) {
	vf, vargs, err := VerifyFunc(f, args...)
	if err != nil {
		return nil, err
	}

	ret := vf.Call(vargs)
	num := len(ret)
	results := make([]interface{}, num)
	for i := 0; i < num; i++ {
		results[i] = ret[i].Interface()
	}

	return results, nil
}

// trim 字符串修剪.
func trim(str string, characterMask ...string) string {
	mask := getTrimMask(characterMask)
	return strings.Trim(str, mask)
}