企业门店初始化

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/WxEnterpriseRelatedApiServiceImpl.java

@@ -345,8 +345,9 @@ public class WxEnterpriseRelatedApiServiceImpl implements WxEnterpriseRelatedApi
 	public void flushBindStoreToDelayMq(String enterpriseId, FlushStoreMqDTO mqDTO) {
 		String str = JSONObject.toJSONString(mqDTO);
 		String key = FLUSH_HAOBAN_BIND_STORE_MQ_DELAY + ":" + enterpriseId;
-		Object cache = RedisUtil.getCache(key);
-		if (null == cache) {
+        //无需加分布式锁
+        Object cache = RedisUtil.getCache(key);
+        if (null == cache) {
 			logger.info("放入队列，刷新绑定门店：{}", enterpriseId);
 			RedisUtil.setCache(key, 1, Long.valueOf(DELAY_TIME));
 			GicMQClient clientInstance = GICMQClientUtil.getClientInstance();