From 1e24626fa58f488f7744ce94e88a650f05c7a749 Mon Sep 17 00:00:00 2001 From: liuxiaolong <736321739@qq.com> Date: 星期四, 08 八月 2019 18:53:38 +0800 Subject: [PATCH] add log --- 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