[update] 微观大数据平台-添加异常处理

signal-optimize-service/src/main/java/net/wanji/opt/controller/TrendController.java

 package net.wanji.opt.controller;
 
-import com.fasterxml.jackson.core.JsonProcessingException;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiResponse;
@@ -73,7 +72,7 @@ public class TrendController {
     @ApiResponses({
             @ApiResponse(code = 200, message = "OK", response = GreenwaveDetailVO.class),
     })
-    public JsonViewObject greenwaveDetail(@RequestBody GreenwaveDetailBO bo) {
+    public JsonViewObject greenwaveDetail(@RequestBody GreenwaveDetailBO bo) throws Exception {
         GreenwaveDetailVO res = trendService.greenwaveDetail(bo);
         return JsonViewObject.newInstance().success(res);
     }
@@ -109,8 +108,7 @@ public class TrendController {
     @ApiResponses({
             @ApiResponse(code = 200, message = "OK", response = GreenwaveCrossMetricsVO.class),
     })
-    public JsonViewObject greenwaveCrossMetrics(@RequestBody GreenwaveIdAndTimeStampBO greenwaveIdAndTimeStampBO)
-            throws JsonProcessingException {
+    public JsonViewObject greenwaveCrossMetrics(@RequestBody GreenwaveIdAndTimeStampBO greenwaveIdAndTimeStampBO) throws Exception {
         List<GreenwaveCrossMetricsVO> res = trendService.greenwaveCrossMetrics(greenwaveIdAndTimeStampBO);
         return JsonViewObject.newInstance().success(res);
     }

signal-optimize-service/src/main/java/net/wanji/opt/service/TrendService.java

 package net.wanji.opt.service;
 
-import com.fasterxml.jackson.core.JsonProcessingException;
 import net.wanji.databus.bo.CrossIdBO;
 import net.wanji.databus.vo.GreenwaveListVO;
 import net.wanji.opt.bo.*;
@@ -35,9 +34,9 @@ public interface TrendService {
 
     List<GreenwaveRunMonitorVO> greenwaveRunMonitor(GreenwaveIdBO greenwaveIdBO);
 
-    GreenwaveDetailVO greenwaveDetail(GreenwaveDetailBO greenwaveDetailBO);
+    GreenwaveDetailVO greenwaveDetail(GreenwaveDetailBO greenwaveDetailBO) throws Exception;
 
-    List<GreenwaveCrossMetricsVO> greenwaveCrossMetrics(GreenwaveIdAndTimeStampBO greenwaveIdAndTimeStampBO) throws JsonProcessingException;
+    List<GreenwaveCrossMetricsVO> greenwaveCrossMetrics(GreenwaveIdAndTimeStampBO greenwaveIdAndTimeStampBO) throws Exception;
 
     void saveGreenwaveStrategy(SaveGreenwaveStrategyBO saveGreenwaveStrategyBO);
 

signal-optimize-service/src/main/java/net/wanji/opt/service/impl/TrendServiceImpl.java

@@ -7,7 +7,6 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.excel.util.DateUtils;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.extern.slf4j.Slf4j;
 import net.wanji.common.enums.*;
@@ -498,7 +497,7 @@ public class TrendServiceImpl implements TrendService {
     }
 
     @Override
-    public GreenwaveDetailVO greenwaveDetail(GreenwaveDetailBO greenwaveDetailBO) {
+    public GreenwaveDetailVO greenwaveDetail(GreenwaveDetailBO greenwaveDetailBO) throws Exception {
         String greenwaveName = greenwaveDetailBO.getGreenwaveName();
         String startDate = greenwaveDetailBO.getStartDate();
         String endDate = greenwaveDetailBO.getEndDate();
@@ -796,7 +795,7 @@ public class TrendServiceImpl implements TrendService {
     }
 
     private List<GreenwaveDetailVO.GreenwaveCross> buildGreenwaveCrossList(
-            Integer greenwaveId, String greenwaveName, String startDate, String endDate) {
+            Integer greenwaveId, String greenwaveName, String startDate, String endDate) throws Exception {
 
         String[] split = greenwaveName.split(" "); // 旅游路 东向西 转山西路至霞景路路段:正向绿波 工作日 19:00-20:00
         String s = split[4]; // 19:00-20:00
@@ -965,7 +964,7 @@ public class TrendServiceImpl implements TrendService {
     }
 
     private Double calcSpeed(String greenwaveName, String crossId,
-                             String startTime, String endTime, String startDate, String endDate) {
+                             String startTime, String endTime, String startDate, String endDate) throws Exception{
         // 确定协调方向
         String[] split = greenwaveName.split(" ");
         String dirStr = split[1];
@@ -1013,9 +1012,7 @@ public class TrendServiceImpl implements TrendService {
     }
 
     @Override
-    public List<GreenwaveCrossMetricsVO> greenwaveCrossMetrics(GreenwaveIdAndTimeStampBO greenwaveIdAndTimeStampBO)
-            throws JsonProcessingException {
-
+    public List<GreenwaveCrossMetricsVO> greenwaveCrossMetrics(GreenwaveIdAndTimeStampBO greenwaveIdAndTimeStampBO) throws Exception {
         List<GreenwaveCrossMetricsVO> res = new ArrayList<>();
         Long timeStamp = greenwaveIdAndTimeStampBO.getTimeStamp();
 
@@ -1081,14 +1078,19 @@ public class TrendServiceImpl implements TrendService {
         return res;
     }
 
-    private Integer calcTravelTime(String crossId, Integer inDir) throws JsonProcessingException {
-        // 从 Redis 中获取路段行程时间
-        String redisKey = crossId + ":" + inDir;
-        Object element = redisUtils.getMaxScoreElement(redisKey);
-        ObjectMapper objectMapper = new ObjectMapper();
-        if (element != null) {
-            CrossEventDTO dto = objectMapper.readValue(element.toString(), CrossEventDTO.class);
-            return dto.getTransitTime().intValue();
+    private Integer calcTravelTime(String crossId, Integer inDir) throws Exception {
+        try {
+            // 从 Redis 中获取路段行程时间
+            String redisKey = crossId + ":" + inDir;
+            Object element = redisUtils.getMaxScoreElement(redisKey);
+            ObjectMapper objectMapper = new ObjectMapper();
+            if (element != null) {
+                CrossEventDTO dto = objectMapper.readValue(element.toString(), CrossEventDTO.class);
+                return dto.getTransitTime().intValue();
+            }
+        } catch (Exception e) {
+            log.error("获取绿波旅行时间异常：", e);
+            throw new RuntimeException(e);
         }
         return 0;
     }