|
|
@@ -10,7 +10,6 @@ using System.Diagnostics;
|
|
|
using System.Linq;
|
|
|
using System.Linq.Dynamic.Core;
|
|
|
using System.Reflection;
|
|
|
-using System.Threading.Tasks;
|
|
|
using WCS.Core;
|
|
|
using WCS.Entity;
|
|
|
using WCS.Entity.Protocol;
|
|
|
@@ -252,9 +251,9 @@ namespace WCS.Service
|
|
|
YGWCS150Redis.RPush("Packs", pack);
|
|
|
LiaotcRedis.RPush("Packs", pack);
|
|
|
|
|
|
- if (Redis.LLen("Packs") > 200000)
|
|
|
+ if (Redis.LLen("Packs") > 100000)
|
|
|
{
|
|
|
- Redis.LTrim("Packs", 20000, -1);
|
|
|
+ Redis.LTrim("Packs", 5000, -1);
|
|
|
}
|
|
|
|
|
|
if (YGWCS150Redis.LLen("Packs") > 200000)
|
|
|
@@ -262,9 +261,9 @@ namespace WCS.Service
|
|
|
YGWCS150Redis.LTrim("Packs", 20000, -1);
|
|
|
}
|
|
|
|
|
|
- if (LiaotcRedis.LLen("Packs") > 200000)
|
|
|
+ if (LiaotcRedis.LLen("Packs") > 100000)
|
|
|
{
|
|
|
- LiaotcRedis.LTrim("Packs", 20000, -1);
|
|
|
+ LiaotcRedis.LTrim("Packs", 5000, -1);
|
|
|
}
|
|
|
|
|
|
foreach (var data in AllDatas)
|
