From 2f73a671db8bf132baaba12a5c2a9c3b611589e9 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期四, 01 八月 2019 17:14:26 +0800
Subject: [PATCH] 修复 添加房屋时的侦听 类修改
---
OrderService/src/main/java/com/java110/order/OrderServiceApplicationStart.java | 13 +++++++++++++
1 files changed, 13 insertions(+), 0 deletions(-)
diff --git a/OrderService/src/main/java/com/java110/order/OrderServiceApplicationStart.java b/OrderService/src/main/java/com/java110/order/OrderServiceApplicationStart.java
index 65a3e5c..4237c5d 100644
--- a/OrderService/src/main/java/com/java110/order/OrderServiceApplicationStart.java
+++ b/OrderService/src/main/java/com/java110/order/OrderServiceApplicationStart.java
@@ -1,8 +1,12 @@
package com.java110.order;
+import com.java110.common.cache.MappingCache;
+import com.java110.common.constant.DomainContant;
import com.java110.common.factory.ApplicationContextFactory;
+import com.java110.common.util.StringUtil;
import com.java110.core.annotation.Java110ListenerDiscovery;
import com.java110.core.client.RestTemplate;
+import com.java110.entity.mapping.Mapping;
import com.java110.event.center.DataFlowEventPublishing;
import com.java110.order.smo.ICenterServiceCacheSMO;
import com.java110.service.init.ServiceStartInit;
@@ -88,6 +92,15 @@
private static void flushMainCache(String[] args) {
logger.debug("鍒ゆ柇鏄惁闇�瑕佸埛鏂版棩蹇楋紝鍙傛暟 args 涓� {}", args);
+
+ //鍥犱负濂藉鏈嬪弸鍚姩鏃� 涓嶅姞 鍙傛暟-Dcache 鎵�浠ュ惎鍔ㄦ椂妫�娴� redis 涓槸鍚﹀瓨鍦� java110_hc_version
+ String mapping = MappingCache.getValue("java110_hc_version");
+ if(StringUtil.isEmpty(mapping)){
+ ICenterServiceCacheSMO centerServiceCacheSMO = (ICenterServiceCacheSMO) ApplicationContextFactory.getBean("centerServiceCacheSMOImpl");
+ centerServiceCacheSMO.startFlush();
+ return ;
+ }
+
if (args == null || args.length == 0) {
return;
}
--
Gitblit v1.8.0