| | |
|---|
| | | |
|---|
| | | 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 |
|---|
| | | } |
|---|
| | | |
|---|
