liuxiaolong
2019-08-16 f81035f3ecf0c02eaf94d6cba4ac07dfd757012c
controllers/dbtablesCon.go
@@ -2,14 +2,12 @@
import (
   "basic.com/dbapi.git"
   "basic.com/pubsub/protomsg.git"
   "encoding/json"
   "fmt"
   "github.com/gin-gonic/gin"
   "github.com/satori/go.uuid"
   "log"
   "time"
   "webserver/discovery"
   "webserver/extend/code"
   "webserver/extend/config"
   "webserver/extend/esutil"
@@ -100,25 +98,30 @@
   data := esutil.GetEsDataReq(url, params, false)
   //c.JSON(200, changeEsRespData(data, "修改成功"))
   result := changeEsRespData(data, "修改成功")
   if dbtable.Enable == 0 {
      res := UpdateDbPersonsOfDbTable(dbtable.Id)
      //fmt.Println("同步修改人员状态成功----",res)
      logger.Debug("同步修改人员状态成功----", res)
   }
   if result["success"].(bool) {
      //code.Success.Message = "修改底库成功"
      if dbtable.Enable ==1 {
         discovery.AddDbMessage(&protomsg.EsPersonCacheChange{
            Type: protomsg.EsCacheChanged_T_DbTable,
            PersonId: "",
            TableId: []string{ dbtable.Id },
            Feature: "",
            Action: protomsg.DbAction_Insert,
         })
      } else {
         discovery.AddDbMessage(&protomsg.EsPersonCacheChange{
            Type: protomsg.EsCacheChanged_T_DbTable,
            PersonId: "",
            TableId: []string{ dbtable.Id },
            Feature: "",
            Action: protomsg.DbAction_Delete,
         })
      }
      //if dbtable.Enable ==1 {
      //   discovery.AddDbMessage(&protomsg.EsPersonCacheChange{
      //      Type: protomsg.EsCacheChanged_T_DbTable,
      //      PersonId: "",
      //      TableId: []string{ dbtable.Id },
      //      Feature: "",
      //      Action: protomsg.DbAction_Insert,
      //   })
      //} else {
      //   discovery.AddDbMessage(&protomsg.EsPersonCacheChange{
      //      Type: protomsg.EsCacheChanged_T_DbTable,
      //      PersonId: "",
      //      TableId: []string{ dbtable.Id },
      //      Feature: "",
      //      Action: protomsg.DbAction_Delete,
      //   })
      //}
      util.ResponseFormat(c, code.Success, result["data"])
   } else {
      //code.ServiceInsideError.Message += result["msg"].(string)