diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/controller/FlightsController.java b/src/main/java/com/gzzn/omms/msgexchangeapi/controller/FlightsController.java new file mode 100644 index 00000000..84898c2a --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/controller/FlightsController.java @@ -0,0 +1,26 @@ +package com.gzzn.omms.msgexchangeapi.controller; + +import java.util.List; + +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RestController; + +import com.gzzn.omms.msgexchangeapi.dto.ResponseDto; +import com.gzzn.omms.msgexchangeapi.entity.msg.schd.dnld.FLTR; +import com.gzzn.omms.msgexchangeapi.service.flightInfo.IFlightInfoService; + +@RestController +public class FlightsController { + @Autowired + private IFlightInfoService flightInfoService; + + + /** + * 获取最新完整的动态航班信息 + */ + @GetMapping("/all/flights") + public ResponseDto> findAll( ) { + return ResponseDto.success(flightInfoService.findAll()); + } +} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/controller/TestController.java b/src/main/java/com/gzzn/omms/msgexchangeapi/controller/TestController.java deleted file mode 100644 index add444f4..00000000 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/controller/TestController.java +++ /dev/null @@ -1,17 +0,0 @@ -package com.gzzn.omms.msgexchangeapi.controller; - -import java.io.IOException; - -import javax.servlet.http.HttpServletResponse; - -import org.springframework.stereotype.Controller; -import org.springframework.web.bind.annotation.GetMapping; - -@Controller -public class TestController { - - @GetMapping("/test") - public void test(HttpServletResponse response) throws IOException { - response.getWriter().write("hello"); - } -} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/FlightInfoServiceImpl.java b/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/FlightInfoServiceImpl.java index 744e814a..8e8fe427 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/FlightInfoServiceImpl.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/FlightInfoServiceImpl.java @@ -117,4 +117,18 @@ public class FlightInfoServiceImpl implements IFlightInfoService { Set keys = redisService.keys(redisKey + "*"); redisService.del(keys); } + + + @Override + public List findAll() { + Set keys = redisService.keys(redisKey + "*"); + + List lsResult = new ArrayList(); + keys.forEach(key->{ + FLTR fltr = (FLTR) redisService.get(key); + lsResult.add(fltr); + }); + + return lsResult; + }//end method } diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/IFlightInfoService.java b/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/IFlightInfoService.java index c4c5f1a4..697c0137 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/IFlightInfoService.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/IFlightInfoService.java @@ -6,6 +6,14 @@ import com.gzzn.omms.msgexchangeapi.entity.Cminmsg; import com.gzzn.omms.msgexchangeapi.entity.msg.schd.dnld.FLTR; public interface IFlightInfoService { + + /** + * 获取所有动态航班信息 + * @return 所有最新的动态航班信息 + */ + public List findAll(); + + /** * 同步日计划更新航班信息 */