From 6849a017d0a7070d765f011c78104349dcffa2c4 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期六, 17 八月 2019 14:18:14 +0800
Subject: [PATCH] add person to sqlite

---
 controllers/dbtableperson.go |   29 ++++++++++++++++++-----------
 1 files changed, 18 insertions(+), 11 deletions(-)

diff --git a/controllers/dbtableperson.go b/controllers/dbtableperson.go
index 6e69685..92f6a88 100644
--- a/controllers/dbtableperson.go
+++ b/controllers/dbtableperson.go
@@ -48,20 +48,27 @@
 
 func addDbPerson(dbperson *models.Dbtablepersons) (result map[string]interface{}) {
 
-	personId := uuid.NewV4().String() //  浠ュ悗鏇夸唬 渚濇嵁鐢熸垚瑙勫垯
+	personId := uuid.NewV4().String()
 	dbperson.Id = personId
 	dbperson.PriInsert()
-	url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport +
-		"/" + config.EsInfo.EsIndex.Dbtablepersons.IndexName + "/" + config.EsInfo.EsIndex.Dbtablepersons.IndexType + "/" + personId + "?refresh=wait_for"
-	personbytes, e := json.Marshal(dbperson)
-	if e != nil {
-		logger.Debug("Json marshaling failed锛�%s\n", e)
-	}
-	params := string(personbytes)
-	data, _ := esutil.PutEsDataReq(url, params)
 
-	//c.JSON(200, changeEsRespData(data, "娣诲姞浜哄憳鎴愬姛"))
-	result = changeEsRespData(data, "娣诲姞鎴愬姛")
+	var pApi dbapi.DbPersonApi
+	paramBody := util.Struct2Map(dbperson)
+	b, _ := pApi.AddDbPerson(paramBody)
+	result = map[string]interface{}{}
+	if b {
+		result["code"] = 200
+		data := make(map[string]interface{})
+		data["uuid"] = personId
+		result["data"] = data
+		result["success"] = true
+		result["msg"] = "娣诲姞鎴愬姛"
+	} else {
+		result["data"] = nil
+		result["success"] = false
+		result["msg"] = "鏈嶅姟鍣ㄥ紓甯�"
+		result["code"] = 500
+	}
 	return result
 }
 

--
Gitblit v1.8.0