From cfeba2dea02c1de54cde6c95f2a3f46c121d34aa Mon Sep 17 00:00:00 2001 From: liuxiaolong <736321739@qq.com> Date: 星期五, 16 八月 2019 15:16:14 +0800 Subject: [PATCH] dev add publicDomain --- service/EnableStatusControlService.go | 21 +++++++++++++++++++-- 1 files changed, 19 insertions(+), 2 deletions(-) diff --git a/service/EnableStatusControlService.go b/service/EnableStatusControlService.go index a7dae12..0c760b7 100644 --- a/service/EnableStatusControlService.go +++ b/service/EnableStatusControlService.go @@ -17,7 +17,7 @@ "/" + config.EsInfo.EsIndex.DbTables.IndexName + "/_search" var setApi dbapi.SysSetApi _, sysconf := setApi.GetServerInfo() - jsonDsl := `{ + jsonDSL := `{ "query": { "bool": { "filter": [{ @@ -36,7 +36,7 @@ "size": 10000 } ` - buf, err := esutil.EsReq("POST", url, []byte(jsonDsl)) + buf, err := esutil.EsReq("POST", url, []byte(jsonDSL)) if err != nil { logger.Debug(err) } @@ -117,6 +117,23 @@ } 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, + // }) + //} message = "淇敼鎴愬姛" } return message -- Gitblit v1.8.0