作者 王勇

新舱单服务,简单改动

@@ -2,6 +2,7 @@ package com.sunyo.wlpt.cgonms.provide.controller; @@ -2,6 +2,7 @@ package com.sunyo.wlpt.cgonms.provide.controller;
2 2
3 import com.sunyo.wlpt.cgonms.provide.domain.*; 3 import com.sunyo.wlpt.cgonms.provide.domain.*;
4 import com.sunyo.wlpt.cgonms.provide.feign.GetCgoAsmFeign; 4 import com.sunyo.wlpt.cgonms.provide.feign.GetCgoAsmFeign;
  5 +import com.sunyo.wlpt.cgonms.provide.feign.GetDataWareHouseFeign;
5 import com.sunyo.wlpt.cgonms.provide.feign.GetTransportFeign; 6 import com.sunyo.wlpt.cgonms.provide.feign.GetTransportFeign;
6 import com.sunyo.wlpt.cgonms.provide.service.*; 7 import com.sunyo.wlpt.cgonms.provide.service.*;
7 import org.springframework.web.bind.annotation.*; 8 import org.springframework.web.bind.annotation.*;
@@ -41,10 +42,14 @@ public class CgoNmsController { @@ -41,10 +42,14 @@ public class CgoNmsController {
41 @Resource 42 @Resource
42 private GetTransportFeign getTransportFeign; 43 private GetTransportFeign getTransportFeign;
43 44
  45 + @Resource
  46 + GetDataWareHouseFeign getDataWareHouseFeign;
  47 +
44 /** 48 /**
45 - * 根据航班日期获取出新舱单服务中的响应数据 49 + * 根据航班日期、航班号,获取出出港业务统计数据
46 * 50 *
47 * @param flightDate 航班日期 51 * @param flightDate 航班日期
  52 + * @param flightNo 航班号
48 * @return {@link ResultExitData} 53 * @return {@link ResultExitData}
49 */ 54 */
50 @GetMapping("/getInfo") 55 @GetMapping("/getInfo")
@@ -117,11 +122,13 @@ public class CgoNmsController { @@ -117,11 +122,13 @@ public class CgoNmsController {
117 result.setAimStation(pm.get(0).getDestinationStation()); 122 result.setAimStation(pm.get(0).getDestinationStation());
118 } 123 }
119 } 124 }
120 - System.out.println("新舱单服务,获取完毕");  
121 System.out.println("代理人服务,开始获取"); 125 System.out.println("代理人服务,开始获取");
122 - List<ResultExitData> asmInfo = getCgoAsmFeign.getInfo(resultList); 126 + List<ResultExitData> asmInfo = getCgoAsmFeign.getInfo(resultList);
123 System.out.println("运输工具服务,开始获取"); 127 System.out.println("运输工具服务,开始获取");
124 - List<ResultExitData> info = getTransportFeign.getInfo(asmInfo); 128 + List<ResultExitData> transportInfo = getTransportFeign.getInfo(asmInfo);
  129 + System.out.println("数据仓库服务,开始获取");
  130 + List<ResultExitData> info = getDataWareHouseFeign.getInfo(transportInfo);
  131 + System.out.println("出港基本数据,获取完毕");
125 return info; 132 return info;
126 } 133 }
127 } 134 }
@@ -6,6 +6,7 @@ import lombok.Data; @@ -6,6 +6,7 @@ import lombok.Data;
6 import lombok.NoArgsConstructor; 6 import lombok.NoArgsConstructor;
7 7
8 import java.io.Serializable; 8 import java.io.Serializable;
  9 +import java.math.BigDecimal;
9 import java.util.Date; 10 import java.util.Date;
10 11
11 /** 12 /**
@@ -155,4 +156,14 @@ public class ResultExitData implements Serializable { @@ -155,4 +156,14 @@ public class ResultExitData implements Serializable {
155 */ 156 */
156 @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") 157 @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
157 private Date flightPlanTime; 158 private Date flightPlanTime;
  159 +
  160 + /**
  161 + * 27.计费重量
  162 + */
  163 + private BigDecimal totalGrossWeightMeasure;
  164 +
  165 + /**
  166 + * 28.体积
  167 + */
  168 + private BigDecimal volumeMeasure;
158 } 169 }
  1 +package com.sunyo.wlpt.cgonms.provide.feign;
  2 +
  3 +import com.sunyo.wlpt.cgonms.provide.domain.ResultExitData;
  4 +import org.springframework.cloud.openfeign.FeignClient;
  5 +import org.springframework.stereotype.Component;
  6 +import org.springframework.web.bind.annotation.PutMapping;
  7 +import org.springframework.web.bind.annotation.RequestBody;
  8 +
  9 +import java.util.List;
  10 +
  11 +/**
  12 + * @author 子诚
  13 + * Description:数据仓库的feign
  14 + * 时间:2020/5/25 14:47
  15 + */
  16 +@Component
  17 +@FeignClient(value = "data-warehouse", fallback = GetDataWareHouseFeignHystrix.class)
  18 +public interface GetDataWareHouseFeign {
  19 + @PutMapping("/data/getInfo")
  20 + List<ResultExitData> getInfo(@RequestBody List<ResultExitData> resultList);
  21 +}
  1 +package com.sunyo.wlpt.cgonms.provide.feign;
  2 +
  3 +import com.sunyo.wlpt.cgonms.provide.domain.ResultExitData;
  4 +import org.springframework.stereotype.Service;
  5 +
  6 +import java.util.List;
  7 +
  8 +/**
  9 + * @author 子诚
  10 + * Description:数据仓库的feign的熔断器
  11 + * 时间:2020/5/25 14:48
  12 + */
  13 +@Service
  14 +public class GetDataWareHouseFeignHystrix implements GetDataWareHouseFeign {
  15 + @Override
  16 + public List<ResultExitData> getInfo(List<ResultExitData> resultList) {
  17 + System.out.println("与 数据仓库 服务 断开连接,获取 数据仓库 服务信息失败");
  18 + return null;
  19 + }
  20 +}
1 package com.sunyo.wlpt.cgonms.provide.feign; 1 package com.sunyo.wlpt.cgonms.provide.feign;
2 2
3 import com.sunyo.wlpt.cgonms.provide.domain.ResultExitData; 3 import com.sunyo.wlpt.cgonms.provide.domain.ResultExitData;
  4 +import org.springframework.stereotype.Service;
4 5
5 import java.util.List; 6 import java.util.List;
6 7
7 /** 8 /**
8 * @author 子诚 9 * @author 子诚
9 - * Description: 10 + * Description:运输工具feign的熔断器
10 * 时间:2020/5/22 14:32 11 * 时间:2020/5/22 14:32
11 */ 12 */
  13 +@Service
12 public class GetTransportFeignHystrix implements GetTransportFeign { 14 public class GetTransportFeignHystrix implements GetTransportFeign {
13 @Override 15 @Override
14 public List<ResultExitData> getInfo(List<ResultExitData> resultList) { 16 public List<ResultExitData> getInfo(List<ResultExitData> resultList) {