|
|
@@ -252,22 +252,19 @@ namespace WCS.Service
|
|
|
YGWCS150Redis.RPush("Packs", pack);
|
|
|
LiaotcRedis.RPush("Packs", pack);
|
|
|
|
|
|
- var len = Redis.LLen("Packs");
|
|
|
- if (len > 150000)
|
|
|
+ if (Redis.LLen("Packs") > 200000)
|
|
|
{
|
|
|
- Redis.LTrim("Packs", 20000, len);
|
|
|
+ Redis.LTrim("Packs", 20000, -1);
|
|
|
}
|
|
|
|
|
|
- var len1 = YGWCS150Redis.LLen("Packs");
|
|
|
- if (len1 > 150000)
|
|
|
+ if (YGWCS150Redis.LLen("Packs") > 200000)
|
|
|
{
|
|
|
- YGWCS150Redis.LTrim("Packs", 20000, len1);
|
|
|
+ YGWCS150Redis.LTrim("Packs", 20000, -1);
|
|
|
}
|
|
|
|
|
|
- var len2 = LiaotcRedis.LLen("Packs");
|
|
|
- if (len2 > 150000)
|
|
|
+ if (LiaotcRedis.LLen("Packs") > 200000)
|
|
|
{
|
|
|
- LiaotcRedis.LTrim("Packs", 20000, len2);
|
|
|
+ LiaotcRedis.LTrim("Packs", 20000, -1);
|
|
|
}
|
|
|
|
|
|
foreach (var data in AllDatas)
|
