| | |
|---|
| | | // 0未检,1已检 |
|---|
| | | if (type == 0) { |
|---|
| | | // Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize)); |
|---|
| | | // List<TjCustomer> customers = new ArrayList<>(); |
|---|
| | | // while(cursor.hasNext()){ |
|---|
| | | // String s = cursor.next().toString(); |
|---|
| | | // TjCustomer wj = redisCache.getCacheMapValue(s,"0"); |
|---|
| | | // if(null !=wj){ |
|---|
| | | // customerLists.add(wj); |
|---|
| | | // customers.add(wj); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // //切记这里一定要关闭，否则会耗尽连接数。报Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a |
|---|
| | | //// //切记这里一定要关闭，否则会耗尽连接数。报Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a |
|---|
| | | // cursor.close(); |
|---|
| | | customerLists = redisCache.getCacheMapValue(ksId + "ks", "wj"); |
|---|
| | | // customerLists = customers; |
|---|
| | | } |
|---|
| | | if (type == 1) { |
|---|
| | | // Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize)); |
|---|
| | | // List<TjCustomer> customers = new ArrayList<>(); |
|---|
| | | // while(cursor.hasNext()){ |
|---|
| | | // String s = cursor.next().toString(); |
|---|
| | | // TjCustomer wj = redisCache.getCacheMapValue(s,"1"); |
|---|
| | | // if(null !=wj){ |
|---|
| | | // customerLists.add(wj); |
|---|
| | | // customers.add(wj); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // //切记这里一定要关闭，否则会耗尽连接数。报Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a |
|---|
| | | //// //切记这里一定要关闭，否则会耗尽连接数。报Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a |
|---|
| | | // cursor.close(); |
|---|
| | | customerLists = redisCache.getCacheMapValue(ksId + "ks", "yj"); |
|---|
| | | // customerLists = customers; |
|---|
| | | } |
|---|
| | | asyncService.dockerSetCustomerLisByRedis(ksproList, String.valueOf(ksId)); |
|---|
| | | if (null !=customerLists && customerLists.size() > 0) { |
|---|
