fix endTime update to Permanent

sunty

2019-07-30 531039f288ed0c2a76b0ab316499d618d2deccc4

fix endTime update to Permanent

 controllers/dbtablesCon.go

@@ -3,6 +3,7 @@
import (
    "basic.com/dbapi.git"
    "encoding/json"
    "fmt"
    "github.com/gin-gonic/gin"
    "github.com/satori/go.uuid"
    "log"
@@ -38,8 +39,8 @@
    } else if isSync == "2" {
        analyServerFilterStr = "{\"term\":{\"analyServerId\":\"" + sysconf.ServerId + "\"}}" // 本地库
    }
    if analyServerFilterStr !="" {
        analyServerFilterStr = ","+ analyServerFilterStr
    if analyServerFilterStr != "" {
        analyServerFilterStr = "," + analyServerFilterStr
    }
    params := "{\"query\":{\"bool\":{\"must\":[" +
        "{\"term\":{\"isDelete\":\"0\"}}" + analyServerFilterStr + "]}}," +
@@ -77,6 +78,12 @@
        uuid = dbtable.Id
        logger.Debug("body中获取底库id")
    }
    if dbtable.EndTime == "" {
        flag := UpdateEndTime(dbtable.Id)
        if flag == false {
            util.ResponseFormat(c, code.ServiceInsideError, "修改失败")
        }
    }
    url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport +
        "/" + config.EsInfo.EsIndex.DbTables.IndexName + "/" + config.EsInfo.EsIndex.DbTables.IndexType + "/" + uuid + "/_update?refresh=wait_for"
    dbtable.PriUpdate()
@@ -99,6 +106,34 @@
    }
}

func UpdateEndTime(id string) (flag bool) {
    flag = false
    url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport +
        "/" + config.EsInfo.EsIndex.DbTables.IndexName + "/" + config.EsInfo.EsIndex.DbTables.IndexType + "/" + id + "/_update?refresh=wait_for"
    prama := "{\"script\":\"ctx._source.remove(\\\"endTime\\\")\"}"
    buf, err := esutil.EsReq("POST", url, []byte(prama))
    if err != nil {
        fmt.Println("http request info is err!")
        return
    }
    var info interface{}
    json.Unmarshal(buf, &info)
    out, ok := info.(map[string]interface{})
    if !ok {
        fmt.Println("http response interface can not change map[string]interface{}")
        return
    }
    middle, ok := out["result"].(string)
    if !ok {
        fmt.Println("first result change error!")
        return
    }
    if middle == "updated" {
        flag = true
    }
    return flag
}

// @Summary 添加底库
// @Description 添加同步或本地库
// @Accept  json