| | |
| | | |
| | | import ( |
| | | "basic.com/dbapi.git" |
| | | "basic.com/pubsub/protomsg.git" |
| | | "encoding/json" |
| | | "fmt" |
| | | "strconv" |
| | | "strings" |
| | | "time" |
| | | "webserver/discovery" |
| | | "webserver/extend/config" |
| | | "webserver/extend/esutil" |
| | | "webserver/extend/logger" |
| | |
| | | } |
| | | if middle > 0 { |
| | | logger.Debug("修改成功") |
| | | if flag {//生效的 |
| | | discovery.AddDbMessage(&protomsg.EsPersonCacheChange{ |
| | | Type: protomsg.EsCacheChanged_T_DbTable, |
| | | PersonId: "", |
| | | TableId: id, |
| | | Feature: "", |
| | | Action: protomsg.DbAction_Insert, |
| | | }) |
| | | } else {//失效的 |
| | | discovery.AddDbMessage(&protomsg.EsPersonCacheChange{ |
| | | Type: protomsg.EsCacheChanged_T_DbTable, |
| | | PersonId: "", |
| | | TableId: id, |
| | | Feature: "", |
| | | Action: protomsg.DbAction_Insert, |
| | | }) |
| | | } |
| | | //if flag {//生效的 |
| | | // discovery.AddDbMessage(&protomsg.EsPersonCacheChange{ |
| | | // Type: protomsg.EsCacheChanged_T_DbTable, |
| | | // PersonId: "", |
| | | // TableId: id, |
| | | // Feature: "", |
| | | // Action: protomsg.DbAction_Insert, |
| | | // }) |
| | | //} else {//失效的 |
| | | // discovery.AddDbMessage(&protomsg.EsPersonCacheChange{ |
| | | // Type: protomsg.EsCacheChanged_T_DbTable, |
| | | // PersonId: "", |
| | | // TableId: id, |
| | | // Feature: "", |
| | | // Action: protomsg.DbAction_Insert, |
| | | // }) |
| | | //} |
| | | message = "修改成功" |
| | | } |
| | | return message |