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