fix delete dbtable add GetTotalFromDb and EsReq

sunty

2019-07-30 f86d25d5143847692779dd4e81b7e47d9b25376e

 controllers/dbtablesCon.go

@@ -38,6 +38,9 @@
   } else if isSync == "2" {
      analyServerFilterStr = "{\"term\":{\"analyServerId\":\"" + sysconf.ServerId + "\"}}" // 本地库
   }
   if analyServerFilterStr !="" {
      analyServerFilterStr = ","+ analyServerFilterStr
   }
   params := "{\"query\":{\"bool\":{\"must\":[" +
      "{\"term\":{\"isDelete\":\"0\"}}" + analyServerFilterStr + "]}}," +
      "\"from\":0,\"size\":1000,\"sort\":{\"id\":{\"order\":\"asc\"}}}"
@@ -47,9 +50,9 @@
   //c.JSON(200, data)
   util.ResponseFormat(c, code.Success, data)
}


// 依据底库id  查询数据
func QueryDbTableInfo(tableId string) map[string]interface{} {
func QueryDbTableInfo(tableId string) map[string]interface{} {
   url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport +
      "/" + config.EsInfo.EsIndex.DbTables.IndexName + "/" + config.EsInfo.EsIndex.DbTables.IndexName + "/" + tableId
   logger.Debug("请求url:%s;", url)
@@ -153,7 +156,7 @@
   uuid := c.Params.ByName("id")
   url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport +
      "/" + config.EsInfo.EsIndex.DbTables.IndexName + "/" + config.EsInfo.EsIndex.DbTables.IndexType + "/" + uuid + "/_update?refresh=wait_for"
   params := "{\"doc\":{\"isDelete\":\"1\"}}"
   params := "{\"doc\":{\"isDelete\":1}}"
   logger.Debug("删除请求url:%s;\n 请求参数params:%s", url, params)
   data := esutil.GetEsDataReq(url, params, false)
   //c.JSON(200, changeEsRespData(data, "删除成功"))