use mangos req instead of deliver,add recv timeout

liuxiaolong

2019-07-29 cc962c1b6ffabd9d41e6db0571efbcc1a4568ce7

 controllers/dbtablesCon.go

@@ -1,6 +1,7 @@
package controllers

import (
   "basic.com/dbapi.git"
   "encoding/json"
   "github.com/gin-gonic/gin"
   "github.com/satori/go.uuid"
@@ -29,15 +30,20 @@
   url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport +
      "/" + config.EsInfo.EsIndex.DbTables.IndexName + "/_search"
   isSync := c.Params.ByName("isSync")
   syncTerm := ""
   var setApi dbapi.SysSetApi
   _, sysconf := setApi.GetServerInfo()
   analyServerFilterStr := ""
   if isSync == "1" {
      syncTerm = ",{\"term\":{\"isSync\":\"1\"}}" // 同步库
      analyServerFilterStr = "{\"term\":{\"analyServerId\":\"\"}}" // / 同步库
   } else if isSync == "2" {
      syncTerm = ",{\"term\":{\"isSync\":\"2\"}}" // / 本地库
      analyServerFilterStr = "{\"term\":{\"analyServerId\":\"" + sysconf.ServerId + "\"}}" // 本地库
   }
   if analyServerFilterStr !="" {
      analyServerFilterStr = ","+ analyServerFilterStr
   }
   params := "{\"query\":{\"bool\":{\"must\":[" +
      "{\"term\":{\"isDelete\":\"0\"}}" + syncTerm + "]}}," +
      "\"from\":0,\"size\":100,\"sort\":{\"id\":{\"order\":\"asc\"}}}"
      "{\"term\":{\"isDelete\":\"0\"}}" + analyServerFilterStr + "]}}," +
      "\"from\":0,\"size\":1000,\"sort\":{\"id\":{\"order\":\"asc\"}}}"
   logger.Debug("请求url:%s;\n 请求参数params:%s", url, params)

   data := esutil.GetEsDataReq(url, params, true)
@@ -107,6 +113,14 @@
   c.BindJSON(&dbtable)
   tableId := uuid.NewV4().String()
   dbtable.Id = tableId
   if dbtable.AnalyServerId == "sync" {
      dbtable.AnalyServerId = ""
   }
   if dbtable.AnalyServerId == "local" {
      var setApi dbapi.SysSetApi
      _, sysconf := setApi.GetServerInfo()
      dbtable.AnalyServerId = sysconf.ServerId
   }
   url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport +
      "/" + config.EsInfo.EsIndex.DbTables.IndexName + "/" + config.EsInfo.EsIndex.DbTables.IndexType + "/" + tableId + "?refresh=wait_for"
   dbtable.PriInsert() // 添加时间和创建人