Inclusão de erro

api/dataapi/lib.go

@@ -62,9 +62,11 @@ func LCR_Create() {
 	}
 }
 
-func RegistrarExec(table string) {
+func RegistrarExec(table string, check bool) {
 	//Para robôs, age como contador e registra cada repetição no mês
 	c := NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
+	var registros int
+	var erro int
 	current := time.Now().Format("2006-01")
 	res, err := c.Do(&DataAPIRequest{
 		Col: table,
@@ -75,8 +77,9 @@ func RegistrarExec(table string) {
 		panic(err)
 	}
 	if len(res.Data) > 0 {
+		if check {
 			result := res.Data[0].(map[string]interface{})
-		registros := result["exec"].(float64)
+			registros = int(result["exec"].(float64))
 			registros = registros + 1
 			ident := strconv.Itoa(int(result["ID"].(float64)))
 
@@ -92,12 +95,38 @@ func RegistrarExec(table string) {
 				panic(err)
 			}
 		} else {
+			result := res.Data[0].(map[string]interface{})
+			registros = int(result["err"].(float64))
+			registros = registros + 1
+			ident := strconv.Itoa(int(result["ID"].(float64)))
+
+			_, err = c.Do(&DataAPIRequest{
+				Col: table,
+				Op:  UPDATE,
+				Id:  ident,
+				Data: map[string]interface{}{
+					"err": registros,
+				},
+			})
+			if err != nil {
+				panic(err)
+			}
+		}
+	} else {
+		if check {
+			registros = 1
+			erro = 0
+		} else {
+			registros = 0
+			erro = 1
+		}
 		_, err = c.Do(&DataAPIRequest{
 			Col: table,
 			Op:  CREATE,
 			Data: map[string]interface{}{
 				"date": current,
-				"exec": 1,
+				"exec": registros,
+				"err":  erro,
 			},
 		})
 		if err != nil {

api/dataapi/lib_test.go

@@ -2,7 +2,9 @@ package dataapi_test
 
 import (
 	"log"
+	"strconv"
 	"testing"
+	"time"
 
 	"go.digitalcircle.com.br/open/replaycli-go/api/dataapi"
 )
@@ -10,7 +12,7 @@ import (
 func TestAPIRetrieve(t *testing.T) {
 	c := dataapi.NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
 	res, err := c.Do(&dataapi.DataAPIRequest{
-		Col: "C1",
+		Col: "teste3",
 		Op:  dataapi.RETRIEVE,
 	})
 	if err != nil {
@@ -66,35 +68,78 @@ func TestAPIDelete(t *testing.T) {
 }
 
 func TestAPICreate(t *testing.T) {
+	if true {
+		print("a")
+		print("b")
+	}
 	c := dataapi.NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
-
+	var registros int
+	var erro int
+	current := time.Now().Format("2006-01")
 	res, err := c.Do(&dataapi.DataAPIRequest{
-		Col: "C1",
+		Col: "teste3",
-		Op:  dataapi.CREATE,
+		Op:  dataapi.RETRIEVE,
+		Q:   "@[?date=='" + current + "']",
+	})
+	if err != nil {
+		panic(err)
+	}
+	check := false
+	if len(res.Data) > 0 {
+		if check {
+			result := res.Data[0].(map[string]interface{})
+			registros = int(result["exec"].(float64))
+			registros = registros + 1
+			ident := strconv.Itoa(int(result["ID"].(float64)))
+
+			_, err = c.Do(&dataapi.DataAPIRequest{
+				Col: "teste3",
+				Op:  dataapi.UPDATE,
+				Id:  ident,
 				Data: map[string]interface{}{
-			"MSG": "OI LEO",
+					"exec": registros,
 				},
 			})
 			if err != nil {
-		t.Fatal(err.Error())
+				panic(err)
 			}
+		} else {
+			result := res.Data[0].(map[string]interface{})
+			registros = int(result["err"].(float64))
+			registros = registros + 1
+			ident := strconv.Itoa(int(result["ID"].(float64)))
 
-	log.Printf("%#v", res)
+			_, err = c.Do(&dataapi.DataAPIRequest{
-}
+				Col: "teste3",
-
+				Op:  dataapi.UPDATE,
-func LCR_Create(t *testing.T) {
+				Id:  ident,
-	c := dataapi.NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
-
-	res, err := c.Do(&dataapi.DataAPIRequest{
-		Col: "LCR_Bot",
-		Op:  dataapi.CREATE,
 				Data: map[string]interface{}{
-			"Registro": "1",
+					"err": registros,
 				},
 			})
 			if err != nil {
-		t.Fatal(err.Error())
+				panic(err)
+			}
+		}
+	} else {
+		if check {
+			registros = 1
+			erro = 0
+		} else {
+			registros = 0
+			erro = 1
+		}
+		_, err = c.Do(&dataapi.DataAPIRequest{
+			Col: "teste3",
+			Op:  dataapi.CREATE,
+			Data: map[string]interface{}{
+				"date": current,
+				"exec": registros,
+				"err":  erro,
+			},
+		})
+		if err != nil {
+			panic(err)
+		}
 	}
-
-	log.Printf("%#v", res)
 }