修改表结构

core/proxy/filterPoly/blacklist.go

@@ -37,16 +37,16 @@ func syncBlackWhiteList() {
 	res := db.GateWatMySql.Query(`SELECT * FROM front_proxy_blackWhite Where status !=0`)
 	if res != nil && len(*res) > 0 {
 		for _, data := range *res {
-			userId := gconv.String(data["userId"])
+			value := gconv.String(data["value"])
 			status := gconv.Int(data["status"])
-			if key := fmt.Sprintf(WhiteListKey, userId); status == 1 && !AllRedis.Exists(key) {
+			if key := fmt.Sprintf(WhiteListKey, value); status == 1 && !AllRedis.Exists(key) {
 				addWhiteNum++
 				AllRedis.Set(key, 1, -1)
-				g.Log().Infof(gctx.New(), "同步白名单-加入%s", userId)
-			} else if key := fmt.Sprintf(BlackListKey, userId); status == -1 && !AllRedis.Exists(key) {
+				g.Log().Infof(gctx.New(), "同步白名单-加入%s", value)
+			} else if key := fmt.Sprintf(BlackListKey, value); status == -1 && !AllRedis.Exists(key) {
 				addBlackNum++
 				AllRedis.Set(key, 1, -1)
-				g.Log().Infof(gctx.New(), "同步黑名单-加入%s", userId)
+				g.Log().Infof(gctx.New(), "同步黑名单-加入%s", value)
 			}
 		}
 	}

gaway.sql

@@ -44,7 +44,7 @@ CREATE TABLE `front_proxy_poly` (
 ### 白名单 && 黑名单
 CREATE TABLE `front_proxy_blackWhite` (
     `id` int(11) NOT NULL AUTO_INCREMENT,
-    `userId` varchar(255) NOT NULL COMMENT '用户id',
+    `value` varchar(255) NOT NULL COMMENT '用户id or 用户ip',
     `status` tinyint(4) NOT NULL DEFAULT '1' COMMENT '0：正常 1：白名单 -1:黑名单',
     `remark` varchar(255) DEFAULT NULL COMMENT '备注',
     `create_time` datetime NOT NULL COMMENT '创建时间',
@@ -52,7 +52,6 @@ CREATE TABLE `front_proxy_blackWhite` (
     `update_time` datetime NOT NULL COMMENT '更新时间',
     `update_person` varchar(255) NOT NULL COMMENT '更新人',
     PRIMARY KEY (`id`),
-    UNIQUE KEY `onlyCode` (`userId`) USING BTREE
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='前置代理-黑白名单';
 
 ### 变更记录