add person to sqlite

liuxiaolong

2019-08-17 6849a017d0a7070d765f011c78104349dcffa2c4

add person to sqlite

 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
}