fix daq and redis store

core/daq/query.go

@@ -4,6 +4,7 @@ import (
 	"errors"
 	"fmt"
 	"reflect"
+	"strconv"
 	"strings"
 )
 
@@ -211,6 +212,21 @@ func (q *Query) Number() (float64, error) {
 		if !ok {
 			return 0, fmt.Errorf("%s: %s", NotFoundPath, strings.Join(q.paths, "."))
 		}
+		switch v := n.(type) {
+		case string:
+			s, err := strconv.ParseFloat(v, 64)
+			return s, err
+		case float64:
+			return v, nil
+		case float32:
+			return float64(v), nil
+		case int64:
+			return float64(v), nil
+		case int:
+			return float64(v), nil
+		default:
+		}
+
 		v := reflect.ValueOf(n)
 		if v.CanInt() {
 			v2 := v.Int()
@@ -238,6 +254,32 @@ func (q *Query) String() (string, error) {
 	if q.dataString != "" {
 		return q.dataString, nil
 	}
+	if q.index > len(q.paths)-1 {
+		return "", fmt.Errorf("%s: %s", NotFoundPath, strings.Join(q.paths, "."))
+	}
+	if q.Type() == Object {
+		name := q.paths[q.index]
+		data, err := q.object()
+		if err != nil {
+			return "", err
+		}
+		n, ok := data[name]
+		if !ok {
+			return "", fmt.Errorf("%s: %s", NotFoundPath, strings.Join(q.paths, "."))
+		}
+		switch v := n.(type) {
+		case string:
+			return v, nil
+		case float64, float32:
+			return fmt.Sprintf("%f", v), nil
+		case int, int64:
+			return fmt.Sprintf("%d", v), nil
+		default:
+		}
+		v := reflect.ValueOf(n)
+		q.dataString = v.String()
+		return q.dataString, nil
+	}
 	v := reflect.ValueOf(q.data)
 	q.dataString = v.String()
 	return q.dataString, nil

redis/store.go

@@ -32,6 +32,10 @@ func (r redisStore) getKey(sessionId uint64) string {
 }
 
 func (r redisStore) Add(sessionInfo *data.Info) error {
+
+	if r.Has(sessionInfo.Id) {
+		r.delete(sessionInfo.Id)
+	}
 	key := r.getKey(sessionInfo.Id)
 
 	data, err := util.ConvertToByte(sessionInfo)