From f4e8f206a6760bdc31734dfcb1c65916b5b76311 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期四, 22 八月 2019 12:05:58 +0800
Subject: [PATCH] add cluster

---
 service/EnableStatusControlService.go |   40 +++++++++++++++++++---------------------
 1 files changed, 19 insertions(+), 21 deletions(-)

diff --git a/service/EnableStatusControlService.go b/service/EnableStatusControlService.go
index 7206b0b..0c760b7 100644
--- a/service/EnableStatusControlService.go
+++ b/service/EnableStatusControlService.go
@@ -2,13 +2,11 @@
 
 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"
@@ -19,7 +17,7 @@
 		"/" + config.EsInfo.EsIndex.DbTables.IndexName + "/_search"
 	var setApi dbapi.SysSetApi
 	_, sysconf := setApi.GetServerInfo()
-	jsonDsl := `{
+	jsonDSL := `{
 	"query": {
 		"bool": {
 			"filter": [{
@@ -38,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)
 	}
@@ -119,23 +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,
-			})
-		}
+		//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