Forráskód Böngészése

feat:redis增加key

wangchuanjin 1 éve
szülő
commit
38cb5163bd
2 módosított fájl, 3 hozzáadás és 2 törlés
  1. 1 0
      jyBXSubscribe/rpc/etc/db.yaml
  2. 2 2
      jyBXSubscribe/rpc/model/push.go

+ 1 - 0
jyBXSubscribe/rpc/etc/db.yaml

@@ -27,6 +27,7 @@ redis:
         - pushcache_1=192.168.3.128:5000
         - pushcache_1=192.168.3.128:5000
         - pushcache_2_a=192.168.3.128:5001
         - pushcache_2_a=192.168.3.128:5001
         - pushcache_2_b=192.168.3.128:5002
         - pushcache_2_b=192.168.3.128:5002
+        - pushcache_2_c=192.168.3.128:5003
 es:
 es:
     addr: http://192.168.3.241:9205,http://192.168.3.149:9200
     addr: http://192.168.3.241:9205,http://192.168.3.149:9200
     size: 5
     size: 5

+ 2 - 2
jyBXSubscribe/rpc/model/push.go

@@ -1142,7 +1142,6 @@ func (s *subscribePush) listManager(spqp *SubPushQueryParam, list []map[string]i
 				subscopeclassStr = strings.Join(subscopeclass, ",")
 				subscopeclassStr = strings.Join(subscopeclass, ",")
 			}
 			}
 		}
 		}
-		redisKey := fmt.Sprintf("pushinfo_%s_%s", spqp.UserId, common.ObjToString(v["_id"]))
 		entid := spqp.EntId
 		entid := spqp.EntId
 		entUserId := spqp.EntUserId
 		entUserId := spqp.EntUserId
 		deptid := spqp.DeptId
 		deptid := spqp.DeptId
@@ -1158,7 +1157,8 @@ func (s *subscribePush) listManager(spqp *SubPushQueryParam, list []map[string]i
 		case SubFreeFlag:
 		case SubFreeFlag:
 			pushInsert = append(pushInsert, common.InterfaceToStr(spqp.NewUserId), 0)
 			pushInsert = append(pushInsert, common.InterfaceToStr(spqp.NewUserId), 0)
 		}
 		}
-		redis.Put("pushcache_2_a", redisKey, 1, 86400)
+		redis.Put("pushcache_2_a", fmt.Sprintf("pushinfo_%s_%s", spqp.UserId, common.ObjToString(v["_id"])), 1, 86400)
+		redis.Put("pushcache_2_c", fmt.Sprintf("inactiveChange_%s_%s", spqp.UserId, common.ObjToString(v["_id"])), 1, 86400)
 		resultList[i] = s.InfoFormat(&PushCa{
 		resultList[i] = s.InfoFormat(&PushCa{
 			InfoId:     infoid,
 			InfoId:     infoid,
 			Date:       time.Now().Unix(),
 			Date:       time.Now().Unix(),