Merge remote-tracking branch 'origin/dev' into dev

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/pom.xml

@@ -96,6 +96,21 @@
             <groupId>com.liquidnet</groupId>
             <artifactId>liquidnet-client-admin-generator</artifactId>
         </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-test</artifactId>
+            <scope>test</scope>
+        </dependency>
 
     </dependencies>
 

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/templates/zhengzai/kylin/banners/banners.html

@@ -25,7 +25,7 @@
                             <label>是否上线：</label>
                             <select name="isOnline">
                                 <option value="">全部</option>
-                                <option value="0">下线</option>
+                                <option value="88">下线</option>
                                 <option value="1">上线</option>
                             </select>
                         </li>

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/test/java/com.liquidnet.client.admin/TestLocal.java

+package com.liquidnet.client.admin;
+
+import com.liquidnet.service.kylin.constant.KylinTableStatusConst;
+import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderRefundsVo;
+import com.liquidnet.service.kylin.entity.KylinOrderRefunds;
+import com.mongodb.BasicDBObject;
+import com.mongodb.client.result.UpdateResult;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.convert.MongoConverter;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+import java.time.LocalDateTime;
+
+/**
+ * Test
+ */
+@RunWith(SpringJUnit4ClassRunner.class)
+@SpringBootTest
+public class TestLocal {
+    @Autowired
+    private MongoTemplate mongoTemplate;
+
+    @Autowired
+    MongoConverter mongoConverter;
+
+    @Test
+    public void updateAt(){
+        KylinOrderRefunds kylinOrderRefunds = new KylinOrderRefunds();
+        kylinOrderRefunds.setStatus(KylinTableStatusConst.ORDER_REFUND_STATUS_APPLY);
+        kylinOrderRefunds.setApplicantId("1111");
+        kylinOrderRefunds.setApplicantName("2222");
+        kylinOrderRefunds.setApplicantAt(LocalDateTime.now());
+        KylinOrderRefundsVo kylinOrderRefundsVo = new KylinOrderRefundsVo();
+        BeanUtils.copyProperties(kylinOrderRefunds, kylinOrderRefundsVo);
+        kylinOrderRefundsVo.setUpdatedAt(LocalDateTime.now());
+        BasicDBObject EntitiesVov = new BasicDBObject("$set", mongoConverter.convertToMongoType(kylinOrderRefundsVo));
+
+        UpdateResult updateResult = mongoTemplate.getCollection(KylinOrderRefundsVo.class.getSimpleName()).updateOne(
+                Query.query(Criteria.where("orderRefundsId").in("2767295925071872949890")).getQueryObject(),
+                EntitiesVov
+        );
+    }
+}

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinBannersServiceImpl.java

@@ -38,6 +38,7 @@ import org.springframework.util.StringUtils;
 import java.time.LocalDateTime;
 import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
 /**
  * <p>
@@ -244,15 +245,6 @@ public class KylinBannersServiceImpl extends ServiceImpl<KylinBannersMapper, Kyl
         return pageInfoTmp;
     }
 
-    public Long bannerListCount(BannersSearchParam bannersSearchParam) {
-        try {
-            Long count = bannersMapper.searchBannersCount(BeanUtil.convertBeanToMap(bannersSearchParam));
-            return count;
-        } catch (Exception e) {
-            return 0L;
-        }
-    }
-
     public Boolean delete(List<String> bannersId) {
         try {
             LocalDateTime updatedAt = LocalDateTime.now();

liquidnet-bus-common/liquidnet-common-web/src/main/java/com/liquidnet/common/web/config/WebMvcConfig.java

 package com.liquidnet.common.web.config;
 
+import com.liquidnet.common.web.filter.GlobalLogTrackInterceptor;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
 import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport;
 
 @Configuration
 public class WebMvcConfig extends WebMvcConfigurationSupport {
-//    @Autowired
-//    GlobalAuthorityInterceptor globalAuthorityInterceptor;
+    @Autowired
+    GlobalLogTrackInterceptor globalLogTrackInterceptor;
 
     @Override
     public void addResourceHandlers(ResourceHandlerRegistry registry) {
@@ -26,11 +29,11 @@ public class WebMvcConfig extends WebMvcConfigurationSupport {
         super.addResourceHandlers(registry);
     }
 
-//    @Override
-//    protected void addInterceptors(InterceptorRegistry registry) {
-//        registry.addInterceptor(globalAuthorityInterceptor).addPathPatterns("/**");
-//        super.addInterceptors(registry);
-//    }
+    @Override
+    protected void addInterceptors(InterceptorRegistry registry) {
+        registry.addInterceptor(globalLogTrackInterceptor).addPathPatterns("/**");
+        super.addInterceptors(registry);
+    }
 
 //    @Bean
 //    public FilterRegistrationBean domainCrossFilterBean(){

liquidnet-bus-common/liquidnet-common-web/src/main/java/com/liquidnet/common/web/filter/GlobalAuthorityInterceptor.java

@@ -11,6 +11,7 @@ import io.jsonwebtoken.ExpiredJwtException;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
+import org.slf4j.MDC;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.core.env.Environment;
@@ -38,7 +39,6 @@ public class GlobalAuthorityInterceptor extends HandlerInterceptorAdapter {
     private static final String TOKEN_KICK = "40002";
     private static final String TOKEN_INVALID = "40003";
 
-    private static final String START_TIME = "_startTime";
     private static final String ENV_PROD = "prod";
     private static final String ENV_ACTIVE = "spring.profiles.active";
 
@@ -55,8 +55,6 @@ public class GlobalAuthorityInterceptor extends HandlerInterceptorAdapter {
 
     @Override
     public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
-        request.setAttribute(START_TIME, System.currentTimeMillis());
-
         String authorization = request.getHeader(CurrentUtil.uToken), uri = request.getRequestURI(),
                 responseCode = null, token = null, currentUid = null;
 
@@ -103,15 +101,6 @@ public class GlobalAuthorityInterceptor extends HandlerInterceptorAdapter {
         return false;
     }
 
-    @Override
-    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
-//        if (!StringUtils.equalsIgnoreCase(env.getProperty(ENV_ACTIVE), ENV_PROD)) {
-            Long endTime = System.currentTimeMillis();
-            Long startTime = (Long) request.getAttribute(START_TIME);
-            log.info("[{}]耗时:{}s", request.getRequestURI(), ((endTime - startTime) * 1.000) / 1000);
-//        }
-    }
-
     private void responseHandler(HttpServletResponse response, String responseCode) throws IOException {
         ResponseDto<Object> responseDto = ResponseDto.failure(ErrorMapping.get(responseCode));
         response.setCharacterEncoding(StandardCharsets.UTF_8.name());

liquidnet-bus-common/liquidnet-common-web/src/main/java/com/liquidnet/common/web/filter/GlobalLogTrackInterceptor.java

+package com.liquidnet.common.web.filter;
+
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+import org.slf4j.MDC;
+import org.springframework.stereotype.Component;
+import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+@Slf4j
+@Data
+@Component
+public class GlobalLogTrackInterceptor extends HandlerInterceptorAdapter {
+    private static final String LNS_TRANCE_ID = "lnsTranceId";
+
+    @Override
+    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
+        String t = MDC.get(LNS_TRANCE_ID);
+        MDC.put(LNS_TRANCE_ID, null == t ? String.valueOf(System.nanoTime()) : t);
+        return true;
+    }
+
+    @Override
+    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
+        long e = Long.parseLong(MDC.get(LNS_TRANCE_ID));
+        log.info("[{}]耗时:{}ms", request.getRequestURI(), (System.nanoTime() - e) / 1000000);
+        MDC.clear();
+    }
+}

liquidnet-bus-config/liquidnet-config/liquidnet-service-adam.yml

@@ -24,8 +24,8 @@ logging:
     name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}.log
     max-size: ${liquidnet.logfile.file-max-size}
   pattern:
-    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
-    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
+    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %X{lnsTranceId} [%logger{96}:%line] - %msg%n'
+    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %X{lnsTranceId} [%logger{96}:%line] - %msg%n'
     rolling-file-name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
   level:
     root: info

liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-adam.yml

@@ -18,8 +18,8 @@ logging:
     name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}.log
     max-size: 200MB
   pattern:
-    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
-    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
+    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{26}:%line] - %msg%n'
+    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{26}:%line] - %msg%n'
     rolling-file-name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
   level:
     root: info

liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer.yml

@@ -18,8 +18,8 @@ logging:
     name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}.log
     max-size: 200MB
   pattern:
-    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
-    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
+    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{26}:%line] - %msg%n'
+    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{26}:%line] - %msg%n'
     rolling-file-name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
   level:
     root: info

liquidnet-bus-config/liquidnet-config/liquidnet-service-kylin.yml

@@ -24,8 +24,8 @@ logging:
     name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}.log
     max-size: ${liquidnet.logfile.file-max-size}
   pattern:
-    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
-    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
+    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %X{lnsTranceId} [%logger{96}:%line] - %msg%n'
+    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %X{lnsTranceId} [%logger{96}:%line] - %msg%n'
     rolling-file-name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
   level:
     root: info

liquidnet-bus-config/liquidnet-config/liquidnet-service-order.yml

@@ -24,8 +24,8 @@ logging:
     name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}.log
     max-size: ${liquidnet.logfile.file-max-size}
   pattern:
-    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
-    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
+    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %X{lnsTranceId} [%logger{96}:%line] - %msg%n'
+    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %X{lnsTranceId} [%logger{96}:%line] - %msg%n'
     rolling-file-name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
   level:
     root: info

liquidnet-bus-config/liquidnet-config/liquidnet-service-platform.yml

@@ -24,8 +24,8 @@ logging:
     name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}.log
     max-size: ${liquidnet.logfile.file-max-size}
   pattern:
-    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
-    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
+    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %X{lnsTranceId} [%logger{96}:%line] - %msg%n'
+    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %X{lnsTranceId} [%logger{96}:%line] - %msg%n'
     rolling-file-name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
   level:
     root: info

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinBannersMapper.java

@@ -4,6 +4,7 @@ import com.liquidnet.service.kylin.dao.BannerDetailsDao;
 import com.liquidnet.service.kylin.dao.BannerDetailsListDao;
 import com.liquidnet.service.kylin.entity.KylinBanners;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 import java.util.Map;
@@ -21,6 +22,4 @@ public interface KylinBannersMapper extends BaseMapper<KylinBanners> {
     BannerDetailsDao detail(String bannersId);
     //列表
     List<BannerDetailsListDao> searchBannersList(Map<String,Object> map);
-    //分页数量
-    long searchBannersCount(Map<String,Object> map);
 }

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinBannersMapper.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.liquidnet.service.kylin.mapper.KylinBannersMapper">
-    <select id="detail" parameterType="java.lang.String">
+    <select id="detail" parameterType="java.lang.String" resultType="com.liquidnet.service.kylin.dao.BannerDetailsDao">
         SELECT
         *
         FROM kylin_banners
@@ -22,9 +22,12 @@
             <if test="targetType != ''">
                 AND target_type=${targetType}
             </if>
-            <if test="isOnline != ''">
+            <if test="isOnline != '' and isOnline != 88 ">
                 AND is_online=${isOnline}
             </if>
+            <if test="isOnline == 88 ">
+                AND is_online=0
+            </if>
             <if test="promotionType != ''">
                 AND promotion_type=${promotionType}
             </if>
@@ -32,25 +35,4 @@
         ORDER BY banners_sort DESC
     </select>
 
-    <!-- admin banner列表数量 -->
-    <select id="searchBannersCount" parameterType="java.util.Map" resultType="long">
-        SELECT COUNT(0)
-        FROM kylin_banners
-        <where>
-            is_deleted = 1
-            <if test="bannersName != ''">
-                AND banners_name LIKE concat('%', #{bannersName}, '%')
-            </if>
-            <if test="targetType != ''">
-                AND target_type=#{targetType}
-            </if>
-            <if test="isOnline != ''">
-                AND is_online=#{isOnline}
-            </if>
-            <if test="promotionType != ''">
-                AND promotion_type=#{promotionType}
-            </if>
-        </where>
-    </select>
-
 </mapper>

liquidnet-bus-service/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/service/processor/ConsumerAdamProcessor.java → liquidnet-bus-service/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/service/processor/ConsumerAdamUCenterProcessor.java

@@ -25,7 +25,7 @@ import java.io.IOException;
  */
 @Slf4j
 @Component
-public class ConsumerAdamProcessor {
+public class ConsumerAdamUCenterProcessor {
     @Resource
     IBaseDao baseDao;
 
@@ -81,115 +81,43 @@ public class ConsumerAdamProcessor {
 
     /* ================================================================== ｜ 用户注册 */
 
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UREGISTER,
+    @RabbitListener(
+            bindings = @QueueBinding(
+                    exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER),
+                    key = MQConst.RK_SQL_UREGISTER,
                     value = @Queue(MQConst.QUEUES_SQL_UREGISTER)
-    ))
-    public void consumerSqlForURegisterA(Message msg, Channel channel) {
-        this.consumerSqlDaoHandler(msg, channel);
-    }
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UREGISTER,
-            value = @Queue(MQConst.QUEUES_SQL_UREGISTER)
-    ))
-    public void consumerSqlForURegisterB(Message msg, Channel channel) {
-        this.consumerSqlDaoHandler(msg, channel);
-    }
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UREGISTER,
-            value = @Queue(MQConst.QUEUES_SQL_UREGISTER)
-    ))
-    public void consumerSqlForURegisterC(Message msg, Channel channel) {
-        this.consumerSqlDaoHandler(msg, channel);
-    }
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UREGISTER,
-            value = @Queue(MQConst.QUEUES_SQL_UREGISTER)
-    ))
-    public void consumerSqlForURegisterD(Message msg, Channel channel) {
-        this.consumerSqlDaoHandler(msg, channel);
-    }
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UREGISTER,
-            value = @Queue(MQConst.QUEUES_SQL_UREGISTER)
-    ))
-    public void consumerSqlForURegisterE(Message msg, Channel channel) {
+            ),
+            concurrency = "5"
+    )
+    public void consumerSqlForURegister(Message msg, Channel channel) {
         this.consumerSqlDaoHandler(msg, channel);
     }
 
     /* ================================================================== ｜ 用户信息 */
 
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UCENTER,
-            value = @Queue(MQConst.QUEUES_SQL_UCENTER)
-    ))
-    public void consumerSqlForUCenterA(Message msg, Channel channel) {
-        this.consumerSqlDaoHandler(msg, channel);
-    }
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UCENTER,
-            value = @Queue(MQConst.QUEUES_SQL_UCENTER)
-    ))
-    public void consumerSqlForUCenterB(Message msg, Channel channel) {
-        this.consumerSqlDaoHandler(msg, channel);
-    }
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UCENTER,
+    @RabbitListener(
+            bindings = @QueueBinding(
+                    exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER),
+                    key = MQConst.RK_SQL_UCENTER,
                     value = @Queue(MQConst.QUEUES_SQL_UCENTER)
-    ))
-    public void consumerSqlForUCenterC(Message msg, Channel channel) {
-        this.consumerSqlDaoHandler(msg, channel);
-    }
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UCENTER,
-            value = @Queue(MQConst.QUEUES_SQL_UCENTER)
-    ))
-    public void consumerSqlForUCenterD(Message msg, Channel channel) {
-        this.consumerSqlDaoHandler(msg, channel);
-    }
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UCENTER,
-            value = @Queue(MQConst.QUEUES_SQL_UCENTER)
-    ))
-    public void consumerSqlForUCenterE(Message msg, Channel channel) {
+            ),
+            concurrency = "5"
+    )
+    public void consumerSqlForUCenter(Message msg, Channel channel) {
         this.consumerSqlDaoHandler(msg, channel);
     }
 
     /* ================================================================== ｜ 会员购买 */
 
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UMEMBER,
-            value = @Queue(MQConst.QUEUES_SQL_UMEMBER)
-    ))
-    public void consumerSqlForUMemberA(Message msg, Channel channel) {
-        this.consumerSqlDaoHandler(msg, channel);
-    }
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UMEMBER,
-            value = @Queue(MQConst.QUEUES_SQL_UMEMBER)
-    ))
-    public void consumerSqlForUMemberB(Message msg, Channel channel) {
-        this.consumerSqlDaoHandler(msg, channel);
-    }
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UMEMBER,
-            value = @Queue(MQConst.QUEUES_SQL_UMEMBER)
-    ))
-    public void consumerSqlForUMemberC(Message msg, Channel channel) {
-        this.consumerSqlDaoHandler(msg, channel);
-    }
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UMEMBER,
-            value = @Queue(MQConst.QUEUES_SQL_UMEMBER)
-    ))
-    public void consumerSqlForUMemberD(Message msg, Channel channel) {
-        this.consumerSqlDaoHandler(msg, channel);
-    }
-    @RabbitListener(bindings = @QueueBinding(
-            exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UMEMBER,
+    @RabbitListener(
+            bindings = @QueueBinding(
+                    exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER),
+                    key = MQConst.RK_SQL_UMEMBER,
                     value = @Queue(MQConst.QUEUES_SQL_UMEMBER)
-    ))
-    public void consumerSqlForUMemberE(Message msg, Channel channel) {
+            ),
+            concurrency = "5"
+    )
+    public void consumerSqlForUMember(Message msg, Channel channel) {
         this.consumerSqlDaoHandler(msg, channel);
     }
 

liquidnet-bus-service/liquidnet-service-consumer-adam/src/test/java/com/liquidnet/service/consumer/service/processor/ConsumerAdamProcessorTest.java → liquidnet-bus-service/liquidnet-service-consumer-adam/src/test/java/com/liquidnet/service/consumer/service/processor/ConsumerAdamUCenterProcessorTest.java

@@ -8,9 +8,9 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
 @RunWith(SpringJUnit4ClassRunner.class)
 @SpringBootTest
-public class ConsumerAdamProcessorTest {
+public class ConsumerAdamUCenterProcessorTest {
     @Autowired
-    ConsumerAdamProcessor consumerAdamProcessor;
+    ConsumerAdamUCenterProcessor consumerAdamUCenterProcessor;
 
     @Test
     public void test() {