logger

liuxiaolong

2019-07-26 2a9ea1c76b4f493fb974154a130ce682616c5a49

 controllers/dbtablesCon.go

@@ -2,13 +2,13 @@

import (
   "encoding/json"
   "fmt"
   "github.com/gin-gonic/gin"
   "github.com/satori/go.uuid"
   "log"
   "webserver/extend/code"
   "webserver/extend/config"
   "webserver/extend/esutil"
   "webserver/extend/logger"
   "webserver/extend/util"
   "webserver/models"
)
@@ -38,7 +38,7 @@
   params := "{\"query\":{\"bool\":{\"must\":[" +
      "{\"term\":{\"isDelete\":\"0\"}}" + syncTerm + "]}}," +
      "\"from\":0,\"size\":100,\"sort\":{\"id\":{\"order\":\"asc\"}}}"
   fmt.Print("请求url:%s;\n 请求参数params:%s", url, params)
   logger.Debug("请求url:%s;\n 请求参数params:%s", url, params)

   data := esutil.GetEsDataReq(url, params, true)
   //c.JSON(200, data)
@@ -49,7 +49,7 @@
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
   fmt.Print("请求url:%s;", url)
   logger.Debug("请求url:%s;", url)
   data := esutil.GetEsDataInfo(url, true)
   return data
}
@@ -69,7 +69,7 @@
   uuid := c.Params.ByName("id")
   if uuid == "" {
      uuid = dbtable.Id
      fmt.Println("body中获取底库id")
      logger.Debug("body中获取底库id")
   }
   url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport +
      "/" + config.EsInfo.EsIndex.DbTables.IndexName + "/" + config.EsInfo.EsIndex.DbTables.IndexType + "/" + uuid + "/_update?refresh=wait_for"
@@ -78,9 +78,9 @@
   if err != nil {
      log.Fatalf("Json marshaling failed：%s", err)
   }
   fmt.Printf("%s\n", dbTableByte)
   logger.Debug("%s\n", dbTableByte)
   params := "{\"doc\":" + string(dbTableByte) + "}"
   fmt.Print("请求url:%s;\n 请求参数params:%s", url, params)
   logger.Debug("请求url:%s;\n 请求参数params:%s", url, params)
   data := esutil.GetEsDataReq(url, params, false)
   //c.JSON(200, changeEsRespData(data, "修改成功"))
   result := changeEsRespData(data, "修改成功")
@@ -114,9 +114,9 @@
   if err != nil {
      log.Fatalf("Json marshaling failed：%s", err)
   }
   //fmt.Printf("%s\n", dbTableByte)
   //logger.Debugf("%s\n", dbTableByte)
   params := string(dbTableByte)
   fmt.Print("请求url:%s;\n 请求参数params:%s", url, params)
   logger.Debug("请求url:%s;\n 请求参数params:%s", url, params)
   data, _ := esutil.PutEsDataReq(url, params)
   //c.JSON(200, changeEsRespData(data, "添加成功"))
   result := changeEsRespData(data, "添加成功")
@@ -143,7 +143,7 @@
   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\"}}"
   fmt.Print("删除请求url:%s;\n 请求参数params:%s", url, params)
   logger.Debug("删除请求url:%s;\n 请求参数params:%s", url, params)
   data := esutil.GetEsDataReq(url, params, false)
   //c.JSON(200, changeEsRespData(data, "删除成功"))
   result := changeEsRespData(data, "删除成功")