去掉大小key异常

back_recharge
mashiyu 2019-03-06 16:14:18 +08:00
parent 9ddf90637f
commit 9c71683e83
3 changed files with 18 additions and 19 deletions

View File

@ -24,25 +24,25 @@ public class MongoUpdateCache {
protected void addUpdateRequest(MongoBase mongoBase, String fullKey, Object value, int opCode) {
String key = mongoBase.getRootCollection() + ":" + mongoBase.getRootId();
Map<String, UpdateRequest> listRequest = requestMap.get(key);
if (listRequest == null) {
listRequest = new HashMap<>();
requestMap.put(key, listRequest);
} else {
Iterator<Map.Entry<String, UpdateRequest>> it = listRequest.entrySet().iterator();
while (it.hasNext()) {
Map.Entry<String, UpdateRequest> entry = it.next();
String key1 = entry.getKey();
if (fullKey.contains(key1)) {
return;
}
if (key1.contains(fullKey)) {
it.remove();
String key = mongoBase.getRootCollection() + ":" + mongoBase.getRootId();
Map<String, UpdateRequest> listRequest = requestMap.get(key);
if (listRequest == null) {
listRequest = new HashMap<>();
requestMap.put(key, listRequest);
} else {
Iterator<Map.Entry<String, UpdateRequest>> it = listRequest.entrySet().iterator();
while (it.hasNext()) {
Map.Entry<String, UpdateRequest> entry = it.next();
String key1 = entry.getKey();
if (fullKey.contains(key1)) {
return;
}
if (key1.contains(fullKey)) {
it.remove();
}
}
}
}
UpdateRequest request = new UpdateRequest(fullKey, value, opCode, mongoBase);
UpdateRequest request = new UpdateRequest(fullKey, value, opCode, mongoBase);
listRequest.put(fullKey, request);
}

View File

@ -18,7 +18,7 @@ public class PokemonManager extends MongoBase {
}
public void addPokemon(Pokemon pokemon) throws Exception {
updateString("pokemonMap." + pokemon.getId(), this);
updateString("pokemonMap." + pokemon.getId(), pokemon);
pokemonMap.put(pokemon.getId(),pokemon);
}

View File

@ -716,7 +716,6 @@ public class HeroLogic {
pokemonInfoList.add(CBean2Proto.getPokemon(pokemon));
}
HeroInfoProto.GetAllPokemonResponse build = HeroInfoProto.GetAllPokemonResponse.newBuilder().addAllPokemonInfo(pokemonInfoList).build();
MessageUtil.sendMessage(iSession,1,MessageTypeProto.MessageType.GET_ALL_POKEMON_RESPONSE_VALUE,build,true);
}