feature: redis集群切换，支持传入活动id

common/src/main/java/com/pica/cloud/online/exam/analysis/common/CommonUtils.java

 package com.pica.cloud.online.exam.analysis.common;
 
 import com.alibaba.fastjson.JSON;
-import com.pica.cloud.foundation.redis.RedisClient;
 import com.pica.cloud.foundation.utils.entity.PicaUser;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -25,14 +24,4 @@ public class CommonUtils {
         }
         return JSON.parseObject(JSON.toJSONString(map), PicaUser.class);
     }
-
-    public static PicaUser getUserByToken(RedisClient client, String token) {
-        PicaUser picaUser = null;
-        try {
-            picaUser = CommonUtils.getUser(client.getToken(token));
-        } catch (Exception e) {
-            logger.error("根据token获取user失败：" + token);
-        }
-        return picaUser;
-    }
 }

pom.xml

@@ -12,7 +12,7 @@
         <dependency>
             <groupId>com.pica.cloud.foundation</groupId>
             <artifactId>pica-cloud-utils</artifactId>
-            <version>1.0.7-SNAPSHOT</version>
+            <version>2.0.0-SNAPSHOT</version>
             <scope>compile</scope>
         </dependency>
     </dependencies>

server/pom.xml

@@ -101,17 +101,15 @@
             <artifactId>springfox-swagger-ui</artifactId>
             <version>2.8.0</version>
         </dependency>
-
         <dependency>
-            <groupId>com.pica.cloud.foundation</groupId>
-            <artifactId>pica-cloud-redis</artifactId>
-            <version>1.1.2</version>
+            <groupId>redis.clients</groupId>
+            <artifactId>jedis</artifactId>
+            <version>2.9.0</version>
         </dependency>
-
         <dependency>
             <groupId>com.pica.cloud.foundation</groupId>
-            <artifactId>pica-cloud-utils</artifactId>
-            <version>1.0.7-SNAPSHOT</version>
+            <artifactId>pica-cloud-redis</artifactId>
+            <version>1.2.0-SNAPSHOT</version>
         </dependency>
 
         <dependency>
@@ -138,10 +136,6 @@
             <version>5.1.39</version>
         </dependency>
 
-        <dependency>
-            <groupId>org.springframework.cloud</groupId>
-            <artifactId>spring-cloud-sleuth-zipkin-stream</artifactId>
-        </dependency>
         <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
@@ -154,11 +148,6 @@
             <scope>compile</scope>
         </dependency>
 
-        <dependency>
-            <groupId>com.pica.cloud.foundation</groupId>
-            <artifactId>pica-cloud-utils</artifactId>
-            <version>1.0.7-SNAPSHOT</version>
-        </dependency>
 		<dependency>
 		    <groupId>com.dianping.cat</groupId>
 		    <artifactId>cat-core</artifactId>

server/src/main/java/com/pica/cloud/online/exam/analysis/server/App.java

@@ -9,10 +9,10 @@ import org.springframework.cloud.netflix.feign.EnableFeignClients;
 import springfox.documentation.swagger2.annotations.EnableSwagger2;
 
 @EnableCircuitBreaker
-@SpringBootApplication
+@SpringBootApplication(scanBasePackages = "com.pica.cloud")
 @EnableDiscoveryClient
 @EnableSwagger2
-@EnableFeignClients
+@EnableFeignClients(basePackages = "com.pica.cloud")
 @MapperScan("com.pica.cloud.online.exam.analysis.server.mapper")
 public class App {
     public static void main( String[] args )

server/src/main/java/com/pica/cloud/online/exam/analysis/server/configuration/BeanConfiguration.java

 package com.pica.cloud.online.exam.analysis.server.configuration;
 
+import com.pica.cloud.foundation.redis.CacheMigrateClient;
+import com.pica.cloud.foundation.redis.ICacheClient;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
-import com.pica.cloud.foundation.redis.RedisClient;
 
 @Configuration
 @RefreshScope
 public class BeanConfiguration {
+    @Autowired
+    private SpringContextAware springContextAware;
+
     @Value("${spring.redis.config}")
     private String configStr;
 
     @Bean
-    public RedisClient redisClient() {
-        System.out.println(configStr);
+    @ConditionalOnMissingBean
+    public ICacheClient cacheClient() {
+        return new CacheMigrateClient(springContextAware.getActiveProfile());
 
-        return new RedisClient(configStr);
     }
 }

server/src/main/java/com/pica/cloud/online/exam/analysis/server/configuration/SpringContextAware.java

+package com.pica.cloud.online.exam.analysis.server.configuration;
+
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author wuminghao
+ * @date 2018/12/27 14:11
+ */
+@Component
+public class SpringContextAware implements ApplicationContextAware {
+    private ApplicationContext context = null;
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext)
+            throws BeansException {
+        this.context = applicationContext;
+    }
+
+    public String getActiveProfile() {
+        return context.getEnvironment().getActiveProfiles()[0];
+    }
+}

server/src/main/java/com/pica/cloud/online/exam/analysis/server/controller/AntiSpamController.java

@@ -3,17 +3,16 @@ package com.pica.cloud.online.exam.analysis.server.controller;
 import com.alibaba.fastjson.JSONObject;
 import com.pica.cloud.foundation.entity.PicaResponse;
 import com.pica.cloud.foundation.entity.PicaResultCode;
-import com.pica.cloud.foundation.redis.RedisClient;
+import com.pica.cloud.foundation.redis.ICacheClient;
 import com.pica.cloud.foundation.utils.annotation.LoginPermission;
+import com.pica.cloud.foundation.utils.controller.BaseController;
 import com.pica.cloud.foundation.utils.entity.PicaUser;
-import com.pica.cloud.online.exam.analysis.common.CommonUtils;
 import com.pica.cloud.online.exam.analysis.common.util.ReturnUtil;
 import com.pica.cloud.online.exam.analysis.server.service.AntiSpamService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.web.bind.annotation.*;
 
 /**
@@ -22,10 +21,10 @@ import org.springframework.web.bind.annotation.*;
  */
 @RestController
 @RequestMapping("/antispam")
-@Api(value = "内容甄别解析", description = "检测文本、图片内容")
-public class AntiSpamController {
+public class AntiSpamController extends BaseController {
+    @Qualifier("cacheMigrateClient")
     @Autowired
-    private RedisClient redisClient;
+    private ICacheClient redisClient;
 
     @Autowired
     AntiSpamService antiSpamService;
@@ -36,8 +35,7 @@ public class AntiSpamController {
     public PicaResponse processText(@RequestBody String content,
                                 @RequestHeader String sysCode,
                                 @RequestHeader String token) {
-        PicaUser user = CommonUtils.getUserByToken(redisClient, token);
-
+        PicaUser user = fetchPicaUser();
         if (user == null || user.getId().intValue() == 0) {
             return ReturnUtil.getPicaResponse(PicaResultCode.LOGIN_FAILE);
         }
@@ -76,8 +74,7 @@ public class AntiSpamController {
     public PicaResponse processTextV2(@RequestBody String content,
                                       @RequestHeader String sysCode,
                                       @RequestHeader String token) {
-        PicaUser user = CommonUtils.getUserByToken(redisClient, token);
-
+        PicaUser user = fetchPicaUser();
         if (user == null || user.getId().intValue() == 0) {
             return ReturnUtil.getPicaResponse(PicaResultCode.LOGIN_FAILE);
         }
@@ -103,6 +100,7 @@ public class AntiSpamController {
         );
     }
 
+    @LoginPermission
     @ApiOperation(value = "图片检测", response = PicaResponse.class)
     @RequestMapping(value = "/image", method = RequestMethod.POST, produces = "application/json;charset=UTF-8")
     public PicaResponse processImage(@RequestBody String content,
@@ -111,9 +109,7 @@ public class AntiSpamController {
         if (token == null) {
             return ReturnUtil.getPicaResponse(PicaResultCode.SYSTEM_NO_TOKEN);
         }
-
-        PicaUser user = CommonUtils.getUserByToken(redisClient, token);
-
+        PicaUser user = fetchPicaUser();
         if (user == null || user.getId().intValue() == 0) {
             return ReturnUtil.getPicaResponse(PicaResultCode.LOGIN_FAILE);
         }

server/src/main/java/com/pica/cloud/online/exam/analysis/server/monitor/CatFilterConfigure.java

-package com.pica.cloud.online.exam.analysis.server.monitor;
-
-import org.springframework.boot.web.servlet.FilterRegistrationBean;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-
-import com.dianping.cat.servlet.CatFilter;
-
-
-@Configuration
-public class CatFilterConfigure {
-
-	@Bean
-	public FilterRegistrationBean catFilter() {
-		FilterRegistrationBean registration = new FilterRegistrationBean();
-		CatFilter filter = new CatFilter();
-		registration.setFilter(filter);
-		registration.addUrlPatterns("/*");
-		registration.setName("cat-filter");
-		registration.setOrder(1);
-		return registration;
-	}
-}
\ No newline at end of file

server/src/main/java/com/pica/cloud/online/exam/analysis/server/service/CHCAnalysisService.java

 package com.pica.cloud.online.exam.analysis.server.service;
 
+import com.pica.cloud.foundation.utils.entity.PicaUser;
 import com.pica.cloud.online.exam.analysis.common.dto.*;
 import com.pica.cloud.online.exam.analysis.server.entity.AnalysisRound;
 import com.pica.cloud.online.exam.analysis.server.entity.AnalysisRoundExamTitle;
@@ -14,6 +15,14 @@ import java.util.List;
  * @date 2018/8/17 9:40
  */
 public interface CHCAnalysisService {
+
+    /**
+     * 获取消息详情
+     * @param analysisId
+     * @return
+     */
+    CHCAnalysisDto getActivityDetail(Integer analysisId, PicaUser user);
+
     /**
      * 根据活动id获取活动详情
      * @param analysisId
@@ -168,7 +177,7 @@ public interface CHCAnalysisService {
 
     /**
      * 获取所有的历史轮详情
-     * @param ananlysisId
+     * @param analysisId
      * @return
      */
     List<AnalysisRoundDto> getCHCHistoryRound(Integer analysisId);

server/src/main/java/com/pica/cloud/online/exam/analysis/server/service/impl/CHCAnalysisServiceImpl.java

 package com.pica.cloud.online.exam.analysis.server.service.impl;
 
+import com.pica.cloud.foundation.utils.entity.PicaUser;
 import com.pica.cloud.online.exam.analysis.common.dto.*;
 import com.pica.cloud.online.exam.analysis.server.configuration.PropertiesConfiguration;
 import com.pica.cloud.online.exam.analysis.server.entity.*;
 import com.pica.cloud.online.exam.analysis.server.mapper.*;
 import com.pica.cloud.online.exam.analysis.server.service.CHCAnalysisService;
+import com.pica.cloud.online.exam.analysis.server.service.CHCRankingListService;
 import com.pica.cloud.online.exam.analysis.server.utils.DateUtils;
 import org.apache.commons.lang.StringUtils;
 import org.slf4j.Logger;
@@ -42,9 +44,51 @@ public class CHCAnalysisServiceImpl implements CHCAnalysisService {
     @Autowired
     DoctorMapper doctorMapper;
 
+    @Autowired
+    CHCRankingListMapper rankingListMapper;
+
     @Autowired
     private PropertiesConfiguration properties;
 
+    @Autowired
+    private CHCRankingListService chcRankingListService;
+
+    /**
+     * chc 活动详情
+     * @param analysisId
+     * @param user
+     * @return
+     */
+    @Override
+    public CHCAnalysisDto getActivityDetail(Integer analysisId, PicaUser user) {
+        CHCAnalysisDto analysisDto = this.getCHCAnalysisDtoById(analysisId);
+        if (chcRankingListService.isRankingInTop200(user != null ? user.getId() : 0)) {
+            analysisDto.setIsJoinIn(1);
+        } else {
+            analysisDto.setIsJoinIn(0);
+        }
+        List<AnalysisRoundDto> roundList = this.getRoundListByAnalysisId(analysisId);
+
+        /**
+         * chc活动固定返回两轮, 将第一轮设置为所有
+         */
+        if (roundList.size() > 0) {
+            roundList.get(0).setRoundId(-1);
+        }
+        /**
+         * 如果是最后一起, 补上最后一期 和前端约定为-2
+         */
+        if (roundList.size() == 1) {
+            AnalysisRoundDto analysisRoundDto = new AnalysisRoundDto();
+            analysisRoundDto.setRoundId(-2);
+            roundList.add(analysisRoundDto);
+        }
+
+        analysisDto.setRoundList(roundList);
+
+        return analysisDto;
+    }
+
     @Override
     public CHCAnalysis getAnalysisById(Integer analysisId) {
         return analysisMapper.selectByPrimaryKey(analysisId);
@@ -103,15 +147,14 @@ public class CHCAnalysisServiceImpl implements CHCAnalysisService {
 
     @Override
     public List<AnalysisRoundDto> getRoundListByAnalysisId(Integer analysisId) {
-
-        List<AnalysisRound> roundList = new ArrayList<>();
+        List<AnalysisRound> roundList = new ArrayList<AnalysisRound>();
 
         CHCAnalysis analysis = analysisMapper.selectByPrimaryKey(analysisId);
-        if (analysis.getType() == 1)
+        if (analysis.getType() == 1) {
             roundList = analysisRoundMapper.selectRoundListById(analysisId);
-        else
+        } else {
             roundList = analysisRoundMapper.selectPSARoundListById(analysisId);
-
+        }
         if (null == roundList){
             return null;
         }

server/src/main/resources/mybatis/AnalysisRoundMapper.xml

@@ -38,6 +38,7 @@
         seq_no from p_analysis_round
       where is_published = 1
       and is_deleted = 0
+      and analysis_id = #{id,jdbcType=INTEGER}
       order by seq_no desc
       limit 1)
     order by seq_no