作者 王勇

新舱单服务,基本定型

@@ -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.GetTransportFeign;
5 import com.sunyo.wlpt.cgonms.provide.service.*; 6 import com.sunyo.wlpt.cgonms.provide.service.*;
6 import org.springframework.web.bind.annotation.*; 7 import org.springframework.web.bind.annotation.*;
7 8
@@ -37,6 +38,9 @@ public class CgoNmsController { @@ -37,6 +38,9 @@ public class CgoNmsController {
37 @Resource 38 @Resource
38 private GetCgoAsmFeign getCgoAsmFeign; 39 private GetCgoAsmFeign getCgoAsmFeign;
39 40
  41 + @Resource
  42 + private GetTransportFeign getTransportFeign;
  43 +
40 /** 44 /**
41 * 根据航班日期获取出新舱单服务中的响应数据 45 * 根据航班日期获取出新舱单服务中的响应数据
42 * 46 *
@@ -114,8 +118,10 @@ public class CgoNmsController { @@ -114,8 +118,10 @@ public class CgoNmsController {
114 } 118 }
115 } 119 }
116 System.out.println("新舱单服务,获取完毕"); 120 System.out.println("新舱单服务,获取完毕");
117 - List<ResultExitData> info = getCgoAsmFeign.getInfo(resultList);  
118 - System.out.println("代理人服务,获取完毕"); 121 + System.out.println("代理人服务,开始获取");
  122 + List<ResultExitData> asmInfo = getCgoAsmFeign.getInfo(resultList);
  123 + System.out.println("运输工具服务,开始获取");
  124 + List<ResultExitData> info = getTransportFeign.getInfo(asmInfo);
119 return info; 125 return info;
120 } 126 }
121 } 127 }
@@ -38,7 +38,7 @@ public class ResultExitData implements Serializable { @@ -38,7 +38,7 @@ public class ResultExitData implements Serializable {
38 /** 38 /**
39 * 4.航班日期 39 * 4.航班日期
40 */ 40 */
41 - @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") 41 + @JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
42 private Date flightDate; 42 private Date flightDate;
43 43
44 /** 44 /**
@@ -122,4 +122,37 @@ public class ResultExitData implements Serializable { @@ -122,4 +122,37 @@ public class ResultExitData implements Serializable {
122 * 20.一级类名称 122 * 20.一级类名称
123 */ 123 */
124 private String typeName; 124 private String typeName;
  125 +
  126 + /**
  127 + * 21.航空公司
  128 + */
  129 + private String airCompany;
  130 +
  131 + /**
  132 + * 22.机型
  133 + */
  134 + private String cfTp;
  135 +
  136 + /**
  137 + * 23.机号
  138 + */
  139 + private String cfNo;
  140 +
  141 + /**
  142 + * 24.航班(起飞)时间
  143 + */
  144 + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
  145 + private Date flightTime;
  146 +
  147 + /**
  148 + * 25.航班计划日期
  149 + */
  150 + @JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
  151 + private Date flightPlanDate;
  152 +
  153 + /**
  154 + * 26.航班计划时间
  155 + */
  156 + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
  157 + private Date flightPlanTime;
125 } 158 }
  1 +package com.sunyo.wlpt.cgonms.provide.feign;
  2 +
  3 +/**
  4 + * @author 子诚
  5 + * Description:
  6 + * 时间:2020/5/22 14:30
  7 + */
  8 +
  9 +import com.sunyo.wlpt.cgonms.provide.domain.ResultExitData;
  10 +import org.springframework.cloud.openfeign.FeignClient;
  11 +import org.springframework.stereotype.Component;
  12 +import org.springframework.web.bind.annotation.PutMapping;
  13 +import org.springframework.web.bind.annotation.RequestBody;
  14 +
  15 +import java.util.List;
  16 +
  17 +@Component
  18 +@FeignClient(value = "transport-provide", fallback = GetTransportFeignHystrix.class)
  19 +public interface GetTransportFeign {
  20 + @PutMapping("transport/getInfo")
  21 + public List<ResultExitData> getInfo(@RequestBody List<ResultExitData> resultList);
  22 +}
  1 +package com.sunyo.wlpt.cgonms.provide.feign;
  2 +
  3 +import com.sunyo.wlpt.cgonms.provide.domain.ResultExitData;
  4 +
  5 +import java.util.List;
  6 +
  7 +/**
  8 + * @author 子诚
  9 + * Description:
  10 + * 时间:2020/5/22 14:32
  11 + */
  12 +public class GetTransportFeignHystrix implements GetTransportFeign {
  13 + @Override
  14 + public List<ResultExitData> getInfo(List<ResultExitData> resultList) {
  15 + System.out.println("与“运输工具”服务断开连接,获取“运输工具”服务信息失败");
  16 + return null;
  17 + }
  18 +}
@@ -66,8 +66,8 @@ feign: @@ -66,8 +66,8 @@ feign:
66 client: 66 client:
67 config: 67 config:
68 default: 68 default:
69 - connectTimeout: 300000 # feign 的超时设置  
70 - readTimeout: 180000 69 + connectTimeout: 60000000 # feign 的超时设置
  70 + readTimeout: 60000000
71 # boot admin 71 # boot admin
72 management: 72 management:
73 endpoints: 73 endpoints: