sensor

proxy/meta/meta_sensor_item.go

@@ -0,0 +1,14 @@
+package meta
+
+import (
+	"encoding/json"
+	"git.loafle.net/overflow/commons_go/model/timestamp"
+)
+
+type MetaSensorItem struct {
+	Id                 json.Number         `json:"id,Number,omitempty"`
+	MetaSensorItemType MetaSensorItemType  `json:"metaSensorItemType,omitempty"`
+	Key                string              `json:"key,omitempty"`
+	Name               string              `json:"name,omitempty"`
+	CreateDate         timestamp.Timestamp `json:"createDate,omitempty"`
+}

proxy/meta/meta_sensor_item_type.go

@@ -0,0 +1,15 @@
+package meta
+
+import (
+	"encoding/json"
+	"git.loafle.net/overflow/commons_go/model/timestamp"
+)
+
+type MetaSensorItemType struct {
+	Id          json.Number         `json:"id,Number,omitempty"`
+	Name        string              `json:"name,omitempty"`
+	Description string              `json:"description,omitempty"`
+	CreateDate  timestamp.Timestamp `json:"createDate,omitempty"`
+}
+
+

proxy/sensor/sensor_item_service.go

@@ -0,0 +1,54 @@
+package sensor
+
+//
+//import (
+//	"encoding/json"
+//	"git.loafle.net/overflow/commons_go/model/timestamp"
+//	"git.loafle.net/overflow/overflow_service/proxy/meta"
+//	"git.loafle.net/overflow/overflow_service/proxy/target"
+//	"git.loafle.net/overflow/overflow_service/proxy/utils"
+//)
+//
+//type sensorItem struct {
+//	Id             json.Number          `json:"id,Number,omitempty"`
+//	Sensor         Sensor               `json:"sensor,omitempty"`
+//	MetaSensorItem *meta.MetaSensorItem `json:"item,omitempty"`
+//	CreateDate     timestamp.Timestamp  `json:"createDate,omitempty"`
+//}
+//
+//type sensorItemService struct {
+//}
+//
+//func NewsensorItemService() *sensorItemService {
+//	return &sensorItemService{}
+//}
+//
+//func (ss *sensorItemService) Regist(s *sensorItem) (string, error) {
+//	out, err := utils.InvokeDBByModel("sensor", "save", s, utils.MODEL_SENSOR)
+//
+//	if err != nil {
+//		return "", err
+//	}
+//
+//	return out, nil
+//}
+//
+//func (ss *sensorItemService) ReadAllByTarget(t *target.Target) (string, error) {
+//	out, err := utils.InvokeDBByModel("sensor", "findAllByTarget", t, utils.MODEL_TARGET)
+//
+//	if err != nil {
+//		return "", err
+//	}
+//
+//	return out, err
+//}
+//
+//func (ss *sensorItemService) Read(id string) (string, error) {
+//	out, err := utils.InvokeDBByModel("sensor", "findOne", id, utils.MODEL_LONG)
+//
+//	if err != nil {
+//		return "", err
+//	}
+//
+//	return out, nil
+//}

proxy/sensor/sensor_item_service_test.go

@@ -0,0 +1,64 @@
+package sensor
+
+import (
+	"encoding/json"
+	"git.loafle.net/overflow/commons_go/model/timestamp"
+	"git.loafle.net/overflow/overflow_service/proxy/infra"
+	"git.loafle.net/overflow/overflow_service/proxy/meta"
+	"git.loafle.net/overflow/overflow_service/proxy/probe"
+	"git.loafle.net/overflow/overflow_service/proxy/target"
+	"testing"
+)
+
+func TestSensorRegist(t *testing.T) {
+	ss := NewSensorService()
+
+	p := &probe.Probe{}
+	p.Id = json.Number("1")
+	i := &infra.Infra{}
+	i.Id = json.Number("1")
+	status := &meta.MetaSensorStatus{
+		Id: "2",
+	}
+	target := &target.Target{
+		Id: "1",
+	}
+	crawler := &meta.MetaCrawler{
+		Id: "2",
+	}
+	sensor := &Sensor{
+		CreateDate:       timestamp.Now(),
+		Description:      "This is a Sensor",
+		MetaSensorStatus: status,
+		Target:           target,
+		Crawler:          crawler,
+	}
+
+	res, err := ss.Regist(sensor)
+	if err != nil {
+		t.Fatal(err)
+	}
+	t.Log(res)
+
+}
+
+func TestSensorList(t *testing.T) {
+	ss := NewSensorService()
+	tar := &target.Target{
+		Id: "1",
+	}
+	res, err := ss.ReadAllByTarget(tar)
+	if err != nil {
+		t.Fatal(err)
+	}
+	t.Log(res)
+}
+
+func TestSensorRead(t *testing.T) {
+	ss := NewSensorService()
+	res, err := ss.Read("1")
+	if err != nil {
+		t.Fatal(err)
+	}
+	t.Log(res)
+}