记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 50415a27 authored by jiangwenhao's avatar jiangwenhao
Browse files
Options

停用rabbitmq+sql;

parent b67ae0f5
Show whitespace changes
Inline Side-by-side
Showing with 22 additions and 22 deletions
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamAddressesServiceImpl.java
View file @ 50415a27
...@@ -58,8 +58,8 @@ public class AdamAddressesServiceImpl extends ServiceImpl<AdamAddressesMapper, A ...@@ -58,8 +58,8 @@ public class AdamAddressesServiceImpl extends ServiceImpl<AdamAddressesMapper, A
// TODO: 2021/5/14 // TODO: 2021/5/14
List<Object> objectList = Arrays.asList(); List<Object> objectList = Arrays.asList();
rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL, // rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
SqlMapping.get("adam_addresses.add", objectList.toArray())); // SqlMapping.get("adam_addresses.add", objectList.toArray()));
redisUtil.hset(AdamRedisConst.INFO_ADDRESSES.concat(adamAddresses.getUid()), adamAddresses.getAddressesId(), adamAddresses); redisUtil.hset(AdamRedisConst.INFO_ADDRESSES.concat(adamAddresses.getUid()), adamAddresses.getAddressesId(), adamAddresses);
} }
...@@ -137,8 +137,8 @@ public class AdamAddressesServiceImpl extends ServiceImpl<AdamAddressesMapper, A ...@@ -137,8 +137,8 @@ public class AdamAddressesServiceImpl extends ServiceImpl<AdamAddressesMapper, A
redisUtil.hset(AdamRedisConst.INFO_ENTERS.concat(addresses.getUid()), addresses.getAddressesId(), addresses); redisUtil.hset(AdamRedisConst.INFO_ENTERS.concat(addresses.getUid()), addresses.getAddressesId(), addresses);
} }
rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL, // rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
SqlMapping.get("adam_addresses.update.is_default", linkedList)); // SqlMapping.get("adam_addresses.update.is_default", linkedList));
} }
...@@ -163,8 +163,8 @@ public class AdamAddressesServiceImpl extends ServiceImpl<AdamAddressesMapper, A ...@@ -163,8 +163,8 @@ public class AdamAddressesServiceImpl extends ServiceImpl<AdamAddressesMapper, A
paramList.add(unDeaultEnters.getIsDefault()); paramList.add(unDeaultEnters.getIsDefault());
paramList.add(unDeaultEnters.getUpdatedAt()); paramList.add(unDeaultEnters.getUpdatedAt());
paramList.add(doc.get("uid")); paramList.add(doc.get("uid"));
rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL, // rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
SqlMapping.get("adam_addresses.update.is_default", paramList.toArray())); // SqlMapping.get("adam_addresses.update.is_default", paramList.toArray()));
AdamAddresses addresses = BsonUtil.toBean(doc, AdamAddresses.class); AdamAddresses addresses = BsonUtil.toBean(doc, AdamAddresses.class);
redisUtil.hset(AdamRedisConst.INFO_ENTERS.concat(addresses.getUid()), addresses.getAddressesId(), addresses); redisUtil.hset(AdamRedisConst.INFO_ENTERS.concat(addresses.getUid()), addresses.getAddressesId(), addresses);
...@@ -179,8 +179,8 @@ public class AdamAddressesServiceImpl extends ServiceImpl<AdamAddressesMapper, A ...@@ -179,8 +179,8 @@ public class AdamAddressesServiceImpl extends ServiceImpl<AdamAddressesMapper, A
// TODO: 2021/5/14 // TODO: 2021/5/14
List<Object> paramList = Arrays.asList(null); List<Object> paramList = Arrays.asList(null);
rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL, // rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
SqlMapping.get("adam_addresses.edit", paramList.toArray())); // SqlMapping.get("adam_addresses.edit", paramList.toArray()));
redisUtil.hset(AdamRedisConst.INFO_ADDRESSES.concat(info.getUid()), info.getAddressesId(), BsonUtil.toBean(doc, AdamAddresses.class)); redisUtil.hset(AdamRedisConst.INFO_ADDRESSES.concat(info.getUid()), info.getAddressesId(), BsonUtil.toBean(doc, AdamAddresses.class));
} }
...@@ -198,8 +198,8 @@ public class AdamAddressesServiceImpl extends ServiceImpl<AdamAddressesMapper, A ...@@ -198,8 +198,8 @@ public class AdamAddressesServiceImpl extends ServiceImpl<AdamAddressesMapper, A
.updateOne(Query.query(Criteria.where("addressesId").is(addressesId)).getQueryObject(), object); .updateOne(Query.query(Criteria.where("addressesId").is(addressesId)).getQueryObject(), object);
List<Object> paramList = Arrays.asList(addresses.getUpdatedAt(), addresses.getDeletedAt(), addressesId); List<Object> paramList = Arrays.asList(addresses.getUpdatedAt(), addresses.getDeletedAt(), addressesId);
rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL, // rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
SqlMapping.get("adam_addresses.remove", paramList.toArray())); // SqlMapping.get("adam_addresses.remove", paramList.toArray()));
redisUtil.hdel(AdamRedisConst.INFO_ADDRESSES.concat(uid), addressesId); redisUtil.hdel(AdamRedisConst.INFO_ADDRESSES.concat(uid), addressesId);
} }
......
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamEntersServiceImpl.java
View file @ 50415a27
...@@ -89,8 +89,8 @@ public class AdamEntersServiceImpl extends ServiceImpl<AdamEntersMapper, AdamEnt ...@@ -89,8 +89,8 @@ public class AdamEntersServiceImpl extends ServiceImpl<AdamEntersMapper, AdamEnt
paramList.add(info.getUpdatedAt()); paramList.add(info.getUpdatedAt());
paramList.add(info.getDeletedAt()); paramList.add(info.getDeletedAt());
paramList.add(info.getComment()); paramList.add(info.getComment());
rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL, // rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
SqlMapping.get("adam_enters.add", paramList.toArray())); // SqlMapping.get("adam_enters.add", paramList.toArray()));
redisUtil.hset(AdamRedisConst.INFO_ENTERS.concat(info.getUid()), info.getEntersId(), info); redisUtil.hset(AdamRedisConst.INFO_ENTERS.concat(info.getUid()), info.getEntersId(), info);
} }
...@@ -155,8 +155,8 @@ public class AdamEntersServiceImpl extends ServiceImpl<AdamEntersMapper, AdamEnt ...@@ -155,8 +155,8 @@ public class AdamEntersServiceImpl extends ServiceImpl<AdamEntersMapper, AdamEnt
redisUtil.hset(AdamRedisConst.INFO_ENTERS.concat(enters.getUid()), enters.getEntersId(), enters); redisUtil.hset(AdamRedisConst.INFO_ENTERS.concat(enters.getUid()), enters.getEntersId(), enters);
} }
rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL, // rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
SqlMapping.get("adam_enters.update.is_default", linkedList)); // SqlMapping.get("adam_enters.update.is_default", linkedList));
} }
@Override @Override
...@@ -177,8 +177,8 @@ public class AdamEntersServiceImpl extends ServiceImpl<AdamEntersMapper, AdamEnt ...@@ -177,8 +177,8 @@ public class AdamEntersServiceImpl extends ServiceImpl<AdamEntersMapper, AdamEnt
paramList.add(info.getState()); paramList.add(info.getState());
paramList.add(info.getUpdatedAt()); paramList.add(info.getUpdatedAt());
paramList.add(info.getEntersId()); paramList.add(info.getEntersId());
rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL, // rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
SqlMapping.get("adam_enters.edit", paramList.toArray())); // SqlMapping.get("adam_enters.edit", paramList.toArray()));
redisUtil.hset(AdamRedisConst.INFO_ENTERS.concat(info.getUid()), info.getEntersId(), BsonUtil.toBean(doc, AdamEnters.class)); redisUtil.hset(AdamRedisConst.INFO_ENTERS.concat(info.getUid()), info.getEntersId(), BsonUtil.toBean(doc, AdamEnters.class));
} }
...@@ -199,8 +199,8 @@ public class AdamEntersServiceImpl extends ServiceImpl<AdamEntersMapper, AdamEnt ...@@ -199,8 +199,8 @@ public class AdamEntersServiceImpl extends ServiceImpl<AdamEntersMapper, AdamEnt
paramList.add(enters.getUpdatedAt()); paramList.add(enters.getUpdatedAt());
paramList.add(enters.getDeletedAt()); paramList.add(enters.getDeletedAt());
paramList.add(entersId); paramList.add(entersId);
rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL, // rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
SqlMapping.get("adam_enters.remove", paramList.toArray())); // SqlMapping.get("adam_enters.remove", paramList.toArray()));
redisUtil.hdel(AdamRedisConst.INFO_ENTERS.concat(uid), entersId); redisUtil.hdel(AdamRedisConst.INFO_ENTERS.concat(uid), entersId);
} }
......
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamUserInfoServiceImpl.java
View file @ 50415a27
...@@ -68,8 +68,8 @@ public class AdamUserInfoServiceImpl extends ServiceImpl<AdamUserInfoMapper, Ada ...@@ -68,8 +68,8 @@ public class AdamUserInfoServiceImpl extends ServiceImpl<AdamUserInfoMapper, Ada
userInfoVo.getTagMe(), userInfoVo.getTagMe(),
userInfoVo.getUid() userInfoVo.getUid()
); );
rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL, // rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
SqlMapping.get(isNotComplete ? "adam_user_info.add" : "adam_user_info.edit", paramList.toArray())); // SqlMapping.get(isNotComplete ? "adam_user_info.add" : "adam_user_info.edit", paramList.toArray()));
redisUtil.hset(AdamRedisConst.INFO_USER, userInfoVo.getUid(), userInfoVo); redisUtil.hset(AdamRedisConst.INFO_USER, userInfoVo.getUid(), userInfoVo);
} }
......
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamUserServiceImpl.java
View file @ 50415a27
...@@ -235,8 +235,8 @@ public class AdamUserServiceImpl extends ServiceImpl<AdamUserMapper, AdamUser> i ...@@ -235,8 +235,8 @@ public class AdamUserServiceImpl extends ServiceImpl<AdamUserMapper, AdamUser> i
object, new FindOneAndUpdateOptions().returnDocument(ReturnDocument.AFTER) object, new FindOneAndUpdateOptions().returnDocument(ReturnDocument.AFTER)
); );
List<Object> paramList = Arrays.asList(closeUserInfoVo.getState(), now, now, uid); List<Object> paramList = Arrays.asList(closeUserInfoVo.getState(), now, now, uid);
rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL, // rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
SqlMapping.get("adam_user.close", paramList.toArray())); // SqlMapping.get("adam_user.close", paramList.toArray()));
// TODO: 2021/5/14 Execute sql to mq // TODO: 2021/5/14 Execute sql to mq
redisUtil.hdel(AdamRedisConst.INFO_USER, uid); redisUtil.hdel(AdamRedisConst.INFO_USER, uid);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment