From eba983e8b2b647fcc2bd133cbe32b8f57d2fca27 Mon Sep 17 00:00:00 2001
From: a7458969 <290198252@qq.com>
Date: Sat, 21 Mar 2020 01:50:04 +0800
Subject: [PATCH] =?UTF-8?q?es=E6=95=B0=E6=8D=AE=E5=BA=93=E6=8E=A5=E5=8F=A3?=
 =?UTF-8?q?=E5=B0=81=E8=A3=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 db/elasticEngine.go | 53 +++++++++++++++++++++++++++++++++++++++++++--
 1 file changed, 51 insertions(+), 2 deletions(-)

diff --git a/db/elasticEngine.go b/db/elasticEngine.go
index 600254b..5cf8f40 100644
--- a/db/elasticEngine.go
+++ b/db/elasticEngine.go
@@ -3,9 +3,17 @@ package db
 import (
 	"background/config"
 	"background/logs"
+	"github.com/pkg/errors"
 	"gopkg.in/olivere/elastic.v3"
+	"reflect"
 )
+const(
+	ERROR_PTR = "nullpointer error"
+	INPUT_TYPE_ERROR = "wrong input parameter"
+	CREATED_ERROR = "create error"
+	DELETE_ERROR = "delete error"
 
+)
 type  ElkEngine struct {
 	cli *elastic.Client
 }
@@ -25,10 +33,51 @@ func InitELK()  {
 	}
 }
 
-func (*ElkEngine)Search(index string) (error)  {
-	if nil != gElkEngine.cli{
 
+
+func (p *ElkEngine)Create(index string,types string,id string,data interface{}) (error)  {
+	if nil != p{
+		if (reflect.TypeOf(data).Kind() != reflect.String)  && (reflect.TypeOf(data).Kind() != reflect.Struct){
+			resp, err := p.cli.Index().
+				Index(index).
+				Type(types).
+				Id(id).
+				BodyJson(data).
+				Do()
+			if !resp.Created{
+				return errors.New(CREATED_ERROR)
+			}
+			if err != nil {
+				return err
+			}
+		}else{
+			return errors.New(INPUT_TYPE_ERROR)
+		}
+	}else{
+		return errors.New(ERROR_PTR)
 	}
 	return nil
 }
 
+func (p *ElkEngine)Delete(index string,types string,id string) error{
+	if nil != p{
+		res, err := p.cli.Delete().Index(index).
+			Type(types).
+			Id(id).
+			Do()
+		if err != nil {
+			return  err
+	}
+		if !res.Found{
+			return errors.New(DELETE_ERROR)
+
+		}
+	}else{
+		return errors.New(ERROR_PTR)
+	}
+	return  nil
+}
+func (p *ElkEngine)Search(index string,types string,id string) (interface{},error){
+	
+	return nil,nil
+}
\ No newline at end of file