[add] 路口指标

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

@@ -6,6 +6,7 @@ import io.swagger.annotations.ApiResponse;
 import io.swagger.annotations.ApiResponses;
 import net.wanji.common.framework.rest.JsonViewObject;
 import net.wanji.databus.bo.CrossIdBO;
+import net.wanji.databus.po.CrossDataRealtimePO;
 import net.wanji.databus.po.CrossDirDataRealtimePO;
 import net.wanji.opt.dto.strategy.AddOrUpdateSceneDTO;
 import net.wanji.opt.service.CrossIndexService;
@@ -43,8 +44,16 @@ public class CrossIndexController {
         return JsonViewObject.newInstance().success(result);
     }
 
-    public static void main(String[] args) {
-        Date date = new Date();
-        System.err.println(date);
+    @ApiOperation(value = "路口指标", notes = "路口指标", response = JsonViewObject.class,
+            produces = MediaType.APPLICATION_JSON, consumes = MediaType.APPLICATION_JSON)
+    @PostMapping(value = "/crossIndex",
+            produces = MediaType.APPLICATION_JSON, consumes = MediaType.APPLICATION_JSON)
+    @ApiResponses({
+            @ApiResponse(code = 200, message = "OK", response = AddOrUpdateSceneDTO.class),
+    })
+    public JsonViewObject crossIndex(@RequestBody CrossIdBO crossIdBO) {
+        CrossDataRealtimePO crossDataRealtimePO = crossIndexService.crossIndex(crossIdBO);
+        return JsonViewObject.newInstance().success(crossDataRealtimePO);
     }
+
 }

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

 package net.wanji.opt.service;
 
 import net.wanji.databus.bo.CrossIdBO;
+import net.wanji.databus.po.CrossDataRealtimePO;
 import net.wanji.databus.po.CrossDirDataRealtimePO;
 
 import java.util.Map;
@@ -11,4 +12,5 @@ import java.util.Map;
  */
 public interface CrossIndexService {
     Map<Integer, CrossDirDataRealtimePO> crossDirIndex(CrossIdBO crossIdBO);
+    CrossDataRealtimePO crossIndex(CrossIdBO crossIdBO);
 }

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

@@ -2,7 +2,9 @@ package net.wanji.opt.service.impl;
 
 import lombok.extern.slf4j.Slf4j;
 import net.wanji.databus.bo.CrossIdBO;
+import net.wanji.databus.dao.mapper.CrossDataRealtimeMapper;
 import net.wanji.databus.dao.mapper.CrossDirDataRealtimeMapper;
+import net.wanji.databus.po.CrossDataRealtimePO;
 import net.wanji.databus.po.CrossDirDataRealtimePO;
 import net.wanji.opt.service.CrossIndexService;
 import org.springframework.stereotype.Service;
@@ -23,6 +25,8 @@ public class CrossIndexServiceImpl implements CrossIndexService {
 
     @Resource
     private CrossDirDataRealtimeMapper crossDirDataRealtimeMapper;
+    @Resource
+    private CrossDataRealtimeMapper crossDataRealtimeMapper;
 
     @Override
     public Map<Integer, CrossDirDataRealtimePO> crossDirIndex(CrossIdBO crossIdBO) {
@@ -36,4 +40,10 @@ public class CrossIndexServiceImpl implements CrossIndexService {
         }
         return null;
     }
+
+    @Override
+    public CrossDataRealtimePO crossIndex(CrossIdBO crossIdBO) {
+        CrossDataRealtimePO crossDataRealtimePO = crossDataRealtimeMapper.selectByCrossId(crossIdBO.getCrossId());
+        return crossDataRealtimePO;
+    }
 }