新增组件服务

common/build.gradle

 plugins {
-//    id 'org.springframework.boot' version '2.2.7.RELEASE'
-//    id 'io.spring.dependency-management' version '1.0.9.RELEASE'
     id 'java'
 }
 
@@ -25,14 +23,12 @@ ext {
 }
 
 dependencies {
+    //引用redis组件
+    implementation project(':component-service:redis')
+
     //这里不能使用compile或implementation直接引用spring-boot-starter-web，否则与gateway冲突
     //可以使用 compileOnly，表示只在本模块编译时引用
     compileOnly "org.springframework.boot:spring-boot-starter-web:${springBootVersion}"
-   // implementation "org.springframework.boot:spring-boot-starter-amqp:${springBootVersion}"
-
-    //spring-session-data-redis没有对应的2.2.7.RELEASE版本
-    implementation 'org.springframework.session:spring-session-data-redis:2.2.0.RELEASE'
-    implementation 'redis.clients:jedis:3.1.0'
 
     //只引入上面一个的做法在Gradle 5.0以上被命令禁止了
     implementation 'org.projectlombok:lombok:1.18.12'

common/src/main/java/com/ssy/lingxi/common/controller/BaseController.java

@@ -5,7 +5,7 @@ import com.ssy.lingxi.common.constant.Constants;
 import com.ssy.lingxi.common.exception.BusinessException;
 import com.ssy.lingxi.common.model.dto.UserLoginCacheDTO;
 import com.ssy.lingxi.common.response.ResponseCode;
-import com.ssy.lingxi.common.utils.redis.IRedisUtils;
+import com.ssy.lingxi.component.redis.service.IRedisUtils;
 import org.modelmapper.ModelMapper;
 import org.modelmapper.convention.MatchingStrategies;
 import org.springframework.beans.factory.annotation.Autowired;

component-service/build.gradle

@@ -2,10 +2,16 @@ plugins {
     id 'java'
 }
 
-group 'com.ssy'
+group 'com.ssy.lingxi'
 version '2.0.0'
 
 repositories {
+    maven {
+        url 'http://10.0.0.21:8081/repository/maven-public/'
+    }
+    maven {
+        url 'https://maven.aliyun.com/repository/public'
+    }
     mavenCentral()
 }
 

component-service/rabbitMQ/build.gradle

 plugins {
-    id 'org.springframework.boot' version '2.2.7.RELEASE'
-    id 'io.spring.dependency-management' version '1.0.9.RELEASE'
     id 'java'
 }
 
-group 'com.ssy.lingxi.rabbitMQ'
+group 'com.ssy.lingxi'
 version '2.0.0'
+sourceCompatibility = 1.8
 
 repositories {
     maven {
@@ -14,23 +13,16 @@ repositories {
     maven {
         url 'https://maven.aliyun.com/repository/public'
     }
+    mavenLocal()
     mavenCentral()
 }
 
 dependencies {
-    implementation project(':common')
-    compileOnly "org.springframework.boot:spring-boot-starter-web"
-    implementation 'org.springframework.boot:spring-boot-starter-amqp'
-}
-
+    //引用mq
+    implementation 'org.springframework.boot:spring-boot-starter-amqp:2.2.7.RELEASE'
 
+    //只引入上面一个的做法在Gradle 5.0以上被命令禁止了
+    implementation 'org.projectlombok:lombok:1.18.12'
+    annotationProcessor 'org.projectlombok:lombok:1.18.12'
 
-ext {
-    set('springCloudVersion', "Hoxton.SR4")
-}
-
-dependencyManagement {
-    imports {
-        mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
-    }
 }

component-service/rabbitMQ/src/main/java/com/ssy/lingxi/rabbitMQ/config/CommodityCUD.java → component-service/rabbitMQ/src/main/java/com/ssy/lingxi/component/rabbitMQ/config/CommodityCUD.java

-package com.ssy.lingxi.rabbitMQ.config;
+package com.ssy.lingxi.component.rabbitMQ.config;
 
-import com.ssy.lingxi.common.constant.rabbitMQ.MessageConstants;
+import com.ssy.lingxi.component.rabbitMQ.constants.MessageConstants;
 import org.springframework.amqp.core.Binding;
 import org.springframework.amqp.core.BindingBuilder;
 import org.springframework.amqp.core.DirectExchange;

common/src/main/java/com/ssy/lingxi/common/constant/rabbitMQ/MessageConstants.java → component-service/rabbitMQ/src/main/java/com/ssy/lingxi/component/rabbitMQ/constants/MessageConstants.java

-package com.ssy.lingxi.common.constant.rabbitMQ;
+package com.ssy.lingxi.component.rabbitMQ.constants;
 
 import java.io.Serializable;
 

common/src/main/java/com/ssy/lingxi/common/constant/rabbitMQ/Operation.java → component-service/rabbitMQ/src/main/java/com/ssy/lingxi/component/rabbitMQ/constants/Operation.java

-package com.ssy.lingxi.common.constant.rabbitMQ;
+package com.ssy.lingxi.component.rabbitMQ.constants;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

component-service/rabbitMQ/src/main/java/com/ssy/lingxi/rabbitMQ/listener/CommodityListener.java → component-service/rabbitMQ/src/main/java/com/ssy/lingxi/component/rabbitMQ/listener/CommodityListener.java

-package com.ssy.lingxi.rabbitMQ.listener;
+package com.ssy.lingxi.component.rabbitMQ.listener;
 
-import com.ssy.lingxi.common.constant.rabbitMQ.MessageConstants;
+import com.ssy.lingxi.component.rabbitMQ.constants.MessageConstants;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.stereotype.Component;
 

component-service/rabbitMQ/src/main/java/com/ssy/lingxi/rabbitMQ/service/IRabbitMQUtils.java → component-service/rabbitMQ/src/main/java/com/ssy/lingxi/component/rabbitMQ/service/IRabbitMQUtils.java

-package com.ssy.lingxi.rabbitMQ.service;
+package com.ssy.lingxi.component.rabbitMQ.service;
 
-import com.ssy.lingxi.common.constant.rabbitMQ.Operation;
+import com.ssy.lingxi.component.rabbitMQ.constants.Operation;
 import org.springframework.stereotype.Service;
 
-import java.util.List;
-
 /**
  * 
  * @Description: rabbitMQ工具类

component-service/rabbitMQ/src/main/java/com/ssy/lingxi/rabbitMQ/serviceImpl/RabbitMQUtilsImpl.java → component-service/rabbitMQ/src/main/java/com/ssy/lingxi/component/rabbitMQ/serviceImpl/RabbitMQUtilsImpl.java

-package com.ssy.lingxi.rabbitMQ.serviceImpl;
+package com.ssy.lingxi.component.rabbitMQ.serviceImpl;
 
-import com.ssy.lingxi.common.constant.rabbitMQ.Operation;
-import com.ssy.lingxi.rabbitMQ.service.IRabbitMQUtils;
+import com.ssy.lingxi.component.rabbitMQ.constants.Operation;
+import com.ssy.lingxi.component.rabbitMQ.service.IRabbitMQUtils;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Repository;

component-service/rabbitMQ/src/main/java/com/ssy/lingxi/rabbitMQ/RabbitMQServiceApplication.java

-package com.ssy.lingxi.rabbitMQ;
-
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-
-/**
- * @Description: 公共服务启动类
- * @author jw.chen
- * @version 2.0.0
- * @date 2020/8/1
- */
-@SpringBootApplication
-public class RabbitMQServiceApplication {
-    public static void main(String[] args) {
-        SpringApplication.run(RabbitMQServiceApplication.class, args);
-    }
-}

component-service/redis/build.gradle

+plugins {
+    id 'java'
+}
+
+group 'com.ssy.lingxi'
+version '2.0.0'
+sourceCompatibility = 1.8
+
+repositories {
+    maven {
+        url 'http://10.0.0.21:8081/repository/maven-public/'
+    }
+    maven {
+        url 'https://maven.aliyun.com/repository/public'
+    }
+    mavenLocal()
+    mavenCentral()
+}
+
+dependencies {
+    //spring-session-data-redis没有对应的2.2.7.RELEASE版本
+    implementation 'org.springframework.session:spring-session-data-redis:2.2.0.RELEASE'
+    implementation 'redis.clients:jedis:3.1.0'
+
+    compile 'cn.hutool:hutool-all:5.3.7'
+}

common/src/main/java/com/ssy/lingxi/common/utils/redis/config/RedisSessionConfig.java → component-service/redis/src/main/java/com/ssy/lingxi/component/redis/config/RedisSessionConfig.java

-package com.ssy.lingxi.common.utils.redis.config;
+package com.ssy.lingxi.component.redis.config;
 
 
-import java.lang.reflect.Method;
-
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cache.CacheManager;
 import org.springframework.cache.annotation.CachingConfigurerSupport;
@@ -18,6 +16,8 @@ import org.springframework.data.redis.serializer.StringRedisSerializer;
 import org.springframework.session.data.redis.config.ConfigureRedisAction;
 import org.springframework.session.data.redis.config.annotation.web.http.EnableRedisHttpSession;
 
+import java.lang.reflect.Method;
+
 
 /**
  * 

common/src/main/java/com/ssy/lingxi/common/utils/redis/config/SerializeUtils.java → component-service/redis/src/main/java/com/ssy/lingxi/component/redis/config/SerializeUtils.java

-package com.ssy.lingxi.common.utils.redis.config;
+package com.ssy.lingxi.component.redis.config;
 
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;

common/src/main/java/com/ssy/lingxi/common/utils/redis/IRedisStringUtils.java → component-service/redis/src/main/java/com/ssy/lingxi/component/redis/service/IRedisStringUtils.java

-package com.ssy.lingxi.common.utils.redis;
+package com.ssy.lingxi.component.redis.service;
 
 import org.springframework.stereotype.Service;
 

common/src/main/java/com/ssy/lingxi/common/utils/redis/IRedisUtils.java → component-service/redis/src/main/java/com/ssy/lingxi/component/redis/service/IRedisUtils.java

-package com.ssy.lingxi.common.utils.redis;
+package com.ssy.lingxi.component.redis.service;
 
 import org.springframework.stereotype.Service;
 
 import java.util.List;
-import java.util.Set;
 
 /**
  * 

common/src/main/java/com/ssy/lingxi/common/utils/redis/impl/RedisStringUtilsImpl.java → component-service/redis/src/main/java/com/ssy/lingxi/component/redis/serviceImpl/RedisStringUtilsImpl.java

-package com.ssy.lingxi.common.utils.redis.impl;
+package com.ssy.lingxi.component.redis.serviceImpl;
 
-import com.ssy.lingxi.common.utils.redis.IRedisStringUtils;
-import com.ssy.lingxi.common.utils.redis.config.SerializeUtils;
+import com.ssy.lingxi.component.redis.service.IRedisStringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.dao.DataAccessException;
 import org.springframework.data.redis.connection.RedisConnection;
@@ -14,7 +13,6 @@ import java.util.ArrayList;
 import java.util.Collection;
 import java.util.List;
 import java.util.Set;
-import java.util.stream.Collectors;
 
 /**
  * 

common/src/main/java/com/ssy/lingxi/common/utils/redis/impl/RedisUtilsImpl.java → component-service/redis/src/main/java/com/ssy/lingxi/component/redis/serviceImpl/RedisUtilsImpl.java

-package com.ssy.lingxi.common.utils.redis.impl;
+package com.ssy.lingxi.component.redis.serviceImpl;
 
 import cn.hutool.json.JSONUtil;
-import com.ssy.lingxi.common.utils.redis.IRedisUtils;
-import com.ssy.lingxi.common.utils.redis.config.SerializeUtils;
+import com.ssy.lingxi.component.redis.config.SerializeUtils;
+import com.ssy.lingxi.component.redis.service.IRedisUtils;
 import org.springframework.dao.DataAccessException;
 import org.springframework.data.redis.connection.RedisConnection;
 import org.springframework.data.redis.core.RedisCallback;

merchant-member-service/build.gradle

@@ -26,6 +26,8 @@ dependencies {
     implementation project(':merchant-member-service:merchant-member-service-api')
     implementation project(':workflow-service:workflow-service-api')
     implementation project(':file-service:file-api')
+    //引用redis组件
+    implementation project(':component-service:redis')
 
     //implementation 'org.springframework.cloud:spring-cloud-starter-netflix-ribbon'
     implementation 'org.springframework.cloud:spring-cloud-starter-consul-discovery'

product-service/build.gradle

@@ -18,13 +18,15 @@ repositories {
 }
 
 dependencies {
-
     implementation project(':common')
-    implementation project(':component-service:rabbitMQ')
     implementation project(':platform-manage-service:platform-manage-service-api')
     implementation project(':sms-service:sms-service-api')
     implementation project(':product-service:product-service-api')
 
+    //引用组件
+    implementation project(':component-service:rabbitMQ')
+    implementation project(':component-service:redis')
+
     implementation 'org.springframework.boot:spring-boot-starter-actuator'
     implementation 'org.springframework.cloud:spring-cloud-starter-consul-discovery'
     implementation 'org.springframework.cloud:spring-cloud-starter-zipkin'

product-service/src/main/java/com/ssy/lingxi/product/serviceImpl/CommodityServiceImpl.java

@@ -3,7 +3,6 @@ package com.ssy.lingxi.product.serviceImpl;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.date.DateUtil;
 import com.ssy.lingxi.common.constant.Constants;
-import com.ssy.lingxi.common.constant.rabbitMQ.Operation;
 import com.ssy.lingxi.common.exception.BusinessException;
 import com.ssy.lingxi.common.model.dto.UserLoginCacheDTO;
 import com.ssy.lingxi.common.model.vo.PageVO;
@@ -28,6 +27,7 @@ import com.ssy.lingxi.product.repository.customer.CustomerAttributeRepository;
 import com.ssy.lingxi.product.repository.customer.CustomerAttributeValueRepository;
 import com.ssy.lingxi.product.repository.customer.CustomerCategoryRepository;
 import com.ssy.lingxi.product.service.ICommodityService;
+import com.ssy.lingxi.component.rabbitMQ.constants.Operation;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;

settings.gradle

@@ -38,10 +38,15 @@ include 'platform-template-service:platform-template-service-api'
 //include 'platform-template-service:platform-template-service-api'
 //findProject(':platform-template-service:platform-template-service-api')?.name = 'platform-template-service-api'
 
+//搜索服务
 include 'search-service'
 include 'search-service:search-service-api'
 findProject(':search-service:search-service-api')?.name = 'search-service-api'
+
+//组件服务
 include 'component-service'
 include 'component-service:rabbitMQ'
 findProject(':component-service:rabbitMQ')?.name = 'rabbitMQ'
+include 'component-service:redis'
+findProject(':component-service:redis')?.name = 'redis'