feature: cat集成到方法内部

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

 package com.pica.cloud.online.exam.analysis.server.controller;
 
 import com.alibaba.fastjson.JSONObject;
+import com.dianping.cat.Cat;
+import com.dianping.cat.message.Transaction;
 import com.pica.cloud.foundation.entity.PicaResponse;
 import com.pica.cloud.foundation.entity.PicaResultCode;
 import com.pica.cloud.foundation.redis.RedisClient;
@@ -82,6 +84,8 @@ public class AnalysisController {
     @RequestMapping(value = "/activityDetail", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
     public PicaResponse<CHCAnalysisDto> getActivityDetail(@RequestParam(required = false) Integer id,
                                                           @RequestHeader(required = false) String token) {
+        Transaction t = Cat.newTransaction("Link", "/activityDetail");
+
         PicaResponse.Builder<CHCAnalysisDto> builder = new PicaResponse.Builder<>();
 
         /**
@@ -122,19 +126,24 @@ public class AnalysisController {
 
             analysisDto.setRoundList(roundList);
             builder.setData(analysisDto);
+
+            t.setStatus(Transaction.SUCCESS);
         } catch (Exception e) {
+            t.setStatus(e);
+            Cat.logError(e);
+
             e.printStackTrace();
             return ReturnUtil.getPicaResponse(PicaResultCode.SYSTEM_INNER_ERROR);
         }
-
         return builder.build();
     }
 
     @ApiOperation(value = "获取活动详情", response = PicaResponse.class)
     @RequestMapping(value = "/psaActivityDetail", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
     public PicaResponse<CHCAnalysisDto> getPSAActivityDetail(@RequestParam(required = false) Integer id) {
-        PicaResponse.Builder<CHCAnalysisDto> builder = new PicaResponse.Builder<>();
+        Transaction t = Cat.newTransaction("Link", "/psaActivityDetail");
 
+        PicaResponse.Builder<CHCAnalysisDto> builder = new PicaResponse.Builder<>();
         /**
          * 如果不传活动id进来，活动id就用1
          */
@@ -146,7 +155,12 @@ public class AnalysisController {
 
             analysisDto.setRoundList(roundList);
             builder.setData(analysisDto);
+
+            t.setStatus(Transaction.SUCCESS);
         } catch (Exception e) {
+            t.setStatus(e);
+            Cat.logError(e);
+
             e.printStackTrace();
             return ReturnUtil.getPicaResponse(PicaResultCode.SYSTEM_INNER_ERROR);
         }
@@ -157,8 +171,9 @@ public class AnalysisController {
     @ApiOperation(value = "获取某一轮的题目", response = PicaResponse.class)
     @RequestMapping(value = "/roundDetail/{roundId}", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
     public PicaResponse<RoundExamTitleDto> getRoundDetail(@PathVariable("roundId") Integer roundId) {
-        logger.info("roundDetail: roundId" + roundId);
+        Transaction t = Cat.newTransaction("Link", "/roundDetail");
 
+        logger.info("roundDetail: roundId" + roundId);
         PicaResponse.Builder<RoundExamTitleDto> builder = new PicaResponse.Builder<>();
 
         try {
@@ -167,7 +182,12 @@ public class AnalysisController {
 
             roundExamTitleDto.setExamTitleList(examTitleDtoList);
             builder.setData(roundExamTitleDto);
+
+            t.setStatus(Transaction.SUCCESS);
         } catch (Exception e) {
+            t.setStatus(e);
+            Cat.logError(e);
+
             e.printStackTrace();
             return ReturnUtil.getPicaResponse(PicaResultCode.SYSTEM_INNER_ERROR);
         }
@@ -179,8 +199,9 @@ public class AnalysisController {
     @RequestMapping(value = "/replyList/{examTitleId}", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
     public PicaResponse<ExamTitleReplyDto> getReplyList(@PathVariable("examTitleId") Integer examTitleId,
                                                         @RequestHeader(required = false) String token) {
-        PicaUser user = null;
+        Transaction t = Cat.newTransaction("Link", "/replyList");
 
+        PicaUser user = null;
         if (token != null) {
             user = CommonUtils.getUserByToken(redisClient, token);
         }
@@ -230,7 +251,12 @@ public class AnalysisController {
             examTitleReplyDto.setType(analysis.getType().intValue());
 
             builder.setData(examTitleReplyDto);
+
+            t.setStatus(Transaction.SUCCESS);
         } catch (Exception e) {
+            t.setStatus(e);
+            Cat.logError(e);
+
             e.printStackTrace();
             return ReturnUtil.getPicaResponse(PicaResultCode.SYSTEM_INNER_ERROR);
         }
@@ -242,8 +268,9 @@ public class AnalysisController {
     @RequestMapping(value = "/replyDetail/{replyId}", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
     public PicaResponse<ExamTitleReplyDetailDto> getReplyDetail(@PathVariable("replyId") Integer replyId,
                                                                 @RequestHeader(required = false) String token) {
-        PicaUser user = null;
+        Transaction t = Cat.newTransaction("Link", "/replyDetail");
 
+        PicaUser user = null;
         if (token != null) {
             user = CommonUtils.getUserByToken(redisClient, token);
         }
@@ -286,7 +313,12 @@ public class AnalysisController {
             examTitleReplyDetailDto.setType(analysis.getType().intValue());
 
             builder.setData(examTitleReplyDetailDto);
+
+            t.setStatus(Transaction.SUCCESS);
         } catch (Exception e) {
+            t.setStatus(e);
+            Cat.logError(e);
+
             e.printStackTrace();
             return ReturnUtil.getPicaResponse(PicaResultCode.SYSTEM_INNER_ERROR);
         }
@@ -298,6 +330,9 @@ public class AnalysisController {
     @RequestMapping(value = "/replyDetailByExamTitleId/{examTitleId}", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
     public PicaResponse<ExamTitleReplyDetailDto> getReplyDetailByExamTitleId(@PathVariable("examTitleId") Integer examTitleId,
                                                                 @RequestHeader(required = false) String token) {
+
+        Transaction t = Cat.newTransaction("Link", "/replyDetailByExamTitleId");
+
         logger.info("replyDetailByExamTitleId: examTitleId == " + examTitleId.toString() + ", token=" + token);
         PicaUser user = null;
 
@@ -347,7 +382,12 @@ public class AnalysisController {
             examTitleReplyDetailDto.setType(analysis.getType().intValue());
 
             builder.setData(examTitleReplyDetailDto);
+
+            t.setStatus(Transaction.SUCCESS);
         } catch (Exception e) {
+            t.setStatus(e);
+            Cat.logError(e);
+
             e.printStackTrace();
         }
 
@@ -431,6 +471,8 @@ public class AnalysisController {
     public PicaResponse<ExamTitleReplyDto> nextReplyList(@PathVariable("examTitleId") Integer examTitleId,
                                                          @RequestHeader(required = false) String token) {
 
+        Transaction t = Cat.newTransaction("Link", "/nextExamTitle");
+
         PicaUser user = null;
 
         if (token != null) {
@@ -472,7 +514,12 @@ public class AnalysisController {
             examTitleReplyDto.setType(analysis.getType().intValue());
 
             builder.setData(examTitleReplyDto);
+
+            t.setStatus(Transaction.SUCCESS);
         } catch (Exception e) {
+            t.setStatus(e);
+            Cat.logError(e);
+
             e.printStackTrace();
             return ReturnUtil.getPicaResponse(PicaResultCode.SYSTEM_INNER_ERROR);
         }
@@ -485,6 +532,8 @@ public class AnalysisController {
     public PicaResponse<ExamTitleReplyDto> nextReplyDetail(@PathVariable("replyId") Integer replyId,
                                                            @RequestHeader(required = false) String token) {
 
+        Transaction t = Cat.newTransaction("Link", "/nextReply");
+
         PicaUser user = null;
 
         if (token != null) {
@@ -529,7 +578,12 @@ public class AnalysisController {
             examTitleReplyDetailDto.setType(analysis.getType().intValue());
 
             builder.setData(examTitleReplyDetailDto);
+
+            t.setStatus(Transaction.SUCCESS);
         } catch (Exception e) {
+            t.setStatus(e);
+            Cat.logError(e);
+
             e.printStackTrace();
             return ReturnUtil.getPicaResponse(PicaResultCode.SYSTEM_INNER_ERROR);
         }
@@ -543,6 +597,9 @@ public class AnalysisController {
                                @RequestBody String content,
                                @RequestHeader String sysCode,
                                @RequestHeader String token) {
+
+        Transaction t = Cat.newTransaction("Link", "/reply");
+
         if (token == null) {
             PicaResponse picaResponse = ReturnUtil.getPicaResponse(PicaResultCode.SYSTEM_NO_TOKEN);
             picaResponse.setData("");
@@ -579,7 +636,12 @@ public class AnalysisController {
          */
         try {
             analysisService.insertReply(examTitleId, content, user.getId());
+
+            t.setStatus(Transaction.SUCCESS);
         } catch (Exception e) {
+            t.setStatus(e);
+            Cat.logError(e);
+
             PicaResponse picaResponse = ReturnUtil.getPicaResponse(PicaResultCode.INTERFACE_INVOKE_EXCEPTION);
             picaResponse.setData("");
             return picaResponse;
@@ -627,6 +689,9 @@ public class AnalysisController {
     @ApiOperation(value = "获取某一轮的题目V2", response = PicaResponse.class)
     @RequestMapping(value = "/roundDetail/v2/{roundId}", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
     public PicaResponse<RoundExamTitleV2Dto> getRoundDetailV2(@PathVariable(value = "roundId") Integer roundId) {
+
+        Transaction t = Cat.newTransaction("Link", "/roundDetail/v2/");
+
         logger.info("roundDetail: roundId" + roundId);
         PicaResponse.Builder<RoundExamTitleV2Dto> builder = new PicaResponse.Builder<>();
 
@@ -680,7 +745,12 @@ public class AnalysisController {
             List<ExamTitleDto> examTitleDtoList = analysisService.getExamTitleListByRoundId(roundId);
             roundExamTitleV2Dto.setExamTitleList(examTitleDtoList);
             builder.setData(roundExamTitleV2Dto);
+
+            t.setStatus(Transaction.SUCCESS);
         } catch (Exception e) {
+            t.setStatus(e);
+            Cat.logError(e);
+
             e.printStackTrace();
             return ReturnUtil.getPicaResponse(PicaResultCode.SYSTEM_INNER_ERROR);
         }
@@ -692,6 +762,8 @@ public class AnalysisController {
     @RequestMapping(value = {"/myStar/{roundId}","/myStar/"}, method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
     public PicaResponse<MyStarDto> myStar( @PathVariable(value = "roundId", required = false) Integer roundId,
                                     @RequestHeader(required = false) String token) {
+        Transaction t = Cat.newTransaction("Link", "/roundDetail/v2/");
+
         if (token == null) {
             return ReturnUtil.getPicaResponse(PicaResultCode.SYSTEM_NO_TOKEN);
         }
@@ -701,18 +773,12 @@ public class AnalysisController {
             return ReturnUtil.getPicaResponse(PicaResultCode.LOGIN_FAILE);
         }
 
-        /**
-         * TODO: test，生产环境中打开，判断权限
-         */
-        /*if (!rankingListService.isRankingInTop200(user.getId())) {
-            return ReturnUtil.getPicaResponse(PicaResultCode.PERMISSION_NO_ACCESS);
-        }
-*/
-        if (roundId != null)
+        if (roundId != null) {
             logger.info("myStar: roundId=" + roundId.toString() + " token=" + token);
+        }
 
         PicaResponse.Builder<MyStarDto> builder = new PicaResponse.Builder<>();
-
+        try {
             MyStarDto myStarDto = new MyStarDto();
             myStarDto.setDoctor(doctorService.getDoctorDtoById(user.getId()));
             myStarDto.setRoundList(new ArrayList<>());
@@ -754,6 +820,14 @@ public class AnalysisController {
             myStarDto.setMyExamTitleList(analysisService.getMyStarRecordByRoundIdAndDoctorId(roundId, user.getId()));
 
             builder.setData(myStarDto);
+
+            t.setStatus(Transaction.SUCCESS);
+        } catch (Exception e) {
+            t.setStatus(e);
+            Cat.logError(e);
+
+            e.printStackTrace();
+        }
         return builder.build();
     }