Commit fa3703ca by 周晓航

服务上报之后 删除对应的数据

parent 58b28046
...@@ -38,7 +38,8 @@ public class OrderReportJobHandler { ...@@ -38,7 +38,8 @@ public class OrderReportJobHandler {
public void sendYesterDayStoreMsg() { public void sendYesterDayStoreMsg() {
String date = getYesterdayString(pattern_yyyy_MM_dd); String date = getYesterdayString(pattern_yyyy_MM_dd);
BoundHashOperations<String, String, Set<String>> boundHashOperations = redisCache.getRedisTemplate().boundHashOps(RedisKeyConstant.KGD_NO_ORDER_STORE_DATE + date); String key = RedisKeyConstant.KGD_NO_ORDER_STORE_DATE + date;
BoundHashOperations<String, String, Set<String>> boundHashOperations = redisCache.getRedisTemplate().boundHashOps(key);
Map<String, Set<String>> entries = boundHashOperations.entries(); Map<String, Set<String>> entries = boundHashOperations.entries();
LogUtil.info("下单门店记录推送 entries", entries, null); LogUtil.info("下单门店记录推送 entries", entries, null);
if (!CollectionUtils.isEmpty(entries)) { if (!CollectionUtils.isEmpty(entries)) {
...@@ -55,7 +56,8 @@ public class OrderReportJobHandler { ...@@ -55,7 +56,8 @@ public class OrderReportJobHandler {
.build(); .build();
BaseResponse baseResponse = storeBackstageClient.pushOrderStore(pushOrderStoreDto); BaseResponse baseResponse = storeBackstageClient.pushOrderStore(pushOrderStoreDto);
LogUtil.info("上报门店支付情况", JSON.toJSONString(pushOrderStoreDto), JSON.toJSONString(baseResponse)); LogUtil.info("上报门店支付情况", JSON.toJSONString(pushOrderStoreDto), JSON.toJSONString(baseResponse));
// fisherman 数据推送之后的 redis 缓存数据 是否清理 暂时没需求 // 数据推送之后的 redis 缓存数据 清理
redisCache.delete(key);
} catch (Exception e) { } catch (Exception e) {
LogUtil.error("上报门店支付情况 error", null, JSON.toJSONString(e)); LogUtil.error("上报门店支付情况 error", null, JSON.toJSONString(e));
} }
......
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