|
|
|
package com.sy.groovy
|
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON
|
|
|
|
import com.alibaba.fastjson.JSONArray
|
|
|
|
import com.alibaba.fastjson.JSONObject
|
|
|
|
import com.sy.model.GatherInfo
|
|
|
|
import com.sy.model.LAND_BUSINEESTYPE_LIST_INFO
|
|
|
|
import com.sy.model.LandBusinessTypeList
|
|
|
|
import com.sy.response.ResultJson
|
|
|
|
import com.sy.service.impl.GatherInfoHandle;
|
|
|
|
import feign.Feign
|
|
|
|
import feign.Headers
|
|
|
|
import feign.Param;
|
|
|
|
import feign.Request
|
|
|
|
import feign.RequestLine;
|
|
|
|
import feign.hystrix.FallbackFactory;
|
|
|
|
import groovy.lang.Script;
|
|
|
|
import org.basis.enhance.groovy.entity.ExecuteParams;
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
import org.slf4j.LoggerFactory
|
|
|
|
import org.springframework.context.ApplicationContext
|
|
|
|
|
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 单证验放
|
|
|
|
* 放行验放
|
|
|
|
*/
|
|
|
|
class BillDomTransportCheck extends Script implements ChannelCheckScript {
|
|
|
|
|
|
|
|
private final Logger logger = LoggerFactory.getLogger(getClass());
|
|
|
|
|
|
|
|
@Override
|
|
|
|
Boolean check(ExecuteParams executeParams) {
|
|
|
|
try {
|
|
|
|
String cookieUserName = "admin"
|
|
|
|
String cookieUserId = "1903e605-a2e1-404d-a1a6-a749752fb030"
|
|
|
|
String ServiceAdr = "http://192.168.1.63:10001"
|
|
|
|
|
|
|
|
GatherInfo gatherInfo = (GatherInfo) executeParams.get("GatherInfo");
|
|
|
|
LandBusinessTypeList landBusinessTypeList = (LandBusinessTypeList) executeParams.get("ChanelFormInfo");
|
|
|
|
List<LAND_BUSINEESTYPE_LIST_INFO> listinfos = (List<LAND_BUSINEESTYPE_LIST_INFO>) executeParams.get("ChanelFormBillLists");
|
|
|
|
|
|
|
|
// 调用方法
|
|
|
|
ApplicationContext context = getContext();
|
|
|
|
// 获取容器中的bean
|
|
|
|
GatherInfoHandle gatherInfoHandle = context.getBean(GatherInfoHandle.class);
|
|
|
|
|
|
|
|
if (listinfos!=null && !listinfos.isEmpty()){
|
|
|
|
//数组过滤,只要单证,不要其他 板箱之类
|
|
|
|
List<LAND_BUSINEESTYPE_LIST_INFO> list_infos = listinfos.stream().filter({ listInfo ->
|
|
|
|
if ("B".equals(listInfo.getExt4())) {
|
|
|
|
return true;
|
|
|
|
} else {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}).collect(Collectors.toList());
|
|
|
|
|
|
|
|
list_infos.forEach({bill->
|
|
|
|
// 创建 Feign Client
|
|
|
|
//https://nmms.zzcargo.com:8443/api/wlpt-nmms-manage/trans/dom?originFlightno=&originFlightdate=&originFlightdateEnd=&originMasterwaybill=ML66158691&agentName=&transType=dom&pageNum=1&pageSize=10
|
|
|
|
MyFeignClient myFeignClient = createFeignClient(MyFeignClient, ServiceAdr,cookieUserName,cookieUserId);
|
|
|
|
|
|
|
|
// 调用第三方接口
|
|
|
|
String response = myFeignClient.callThirdPartyApi(bill.getAwba(),cookieUserName,cookieUserId);
|
|
|
|
logger.info("[TRANS-API-RESPONSE]-{}",response)
|
|
|
|
|
|
|
|
// 处理响应结果...
|
|
|
|
//返回的ResultJson实体类
|
|
|
|
JSONObject jo = JSONObject.parseObject(response);
|
|
|
|
StringBuilder sb = new StringBuilder("");
|
|
|
|
if ("200".equals(jo.getString("code"))){
|
|
|
|
//获取返回列表 data->list
|
|
|
|
JSONObject rData = jo.getJSONObject("data")
|
|
|
|
if (rData!=null){
|
|
|
|
JSONArray rList = rData.getJSONArray("list")
|
|
|
|
if (rList!=null && !rList.isEmpty()){
|
|
|
|
rList.forEach({ item ->
|
|
|
|
JSONObject jsonObject = (JSONObject) item;
|
|
|
|
Integer status = jsonObject.getInteger("status")
|
|
|
|
String oBill = jsonObject.getString("originMasterwaybill")
|
|
|
|
logger.info("[TRANS-API-RESPONSE]-单证:{},状态:{}",oBill,status)
|
|
|
|
|
|
|
|
if (status>0){
|
|
|
|
// return true
|
|
|
|
}else{
|
|
|
|
sb.append("转运单证[").append(bill.getAwba()).append("]核验失败,未审核通过")
|
|
|
|
gatherInfoHandle.sendBw(gatherInfo,false,sb.toString(),landBusinessTypeList,listinfos);
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
})
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}else{
|
|
|
|
logger.info("[TRANS-CHECK-FAILD]-转运单证{}核验失败",bill.getAwba())
|
|
|
|
sb.append("转运单证[").append(bill.getAwba()).append("]核验失败,API-FAILD")
|
|
|
|
gatherInfoHandle.sendBw(gatherInfo,false,sb.toString(),landBusinessTypeList,listinfos);
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
})
|
|
|
|
//这里返回验放成功,验放失败从上面返回
|
|
|
|
return true;
|
|
|
|
}else{
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
e.printStackTrace();
|
|
|
|
logger.error("[CACHE-PARSE-ERROR]:", e);
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
|
|
Object run() {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 获取spring容器
|
|
|
|
ApplicationContext getContext() {
|
|
|
|
// 获取spring IOC容器
|
|
|
|
ApplicationContext context = applicationContext;
|
|
|
|
return context;
|
|
|
|
}
|
|
|
|
|
|
|
|
private <T> T createFeignClient(Class<T> clientClass, String url,String username, String userid) {
|
|
|
|
return Feign.builder()
|
|
|
|
.options(new Request.Options(5000, 5000))
|
|
|
|
.requestInterceptor({ requestTemplate ->
|
|
|
|
String cookieValue = "username=" + username + "; userid=" + userid;
|
|
|
|
requestTemplate.header("Cookie", cookieValue);
|
|
|
|
})
|
|
|
|
.target(clientClass, url);
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
interface MyFeignClient {
|
|
|
|
@RequestLine("GET /trans/dom?originMasterwaybill={originMasterwaybill}")
|
|
|
|
@Headers("Cookie: username={username}; userid={userid}")
|
|
|
|
String callThirdPartyApi(@Param("originMasterwaybill") String originMasterwaybill,
|
|
|
|
@Param("username") String username,
|
|
|
|
@Param("userid") String userid);
|
|
|
|
}
|
|
|
|
|
|
|
|
class MyFallbackFactory implements FallbackFactory<MyFeignClient> {
|
|
|
|
@Override
|
|
|
|
public MyFeignClient create(Throwable throwable) {
|
|
|
|
return new MyFeignClient() {
|
|
|
|
@Override
|
|
|
|
public String callThirdPartyApi(String originMasterwaybill,String username,String userid) {
|
|
|
|
// 处理 fallback 逻辑...
|
|
|
|
ResultJson resultJson = new ResultJson("400","访问接口出错");
|
|
|
|
return JSON.toJSONString(resultJson);
|
|
|
|
}
|
|
|
|
};
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} |
...
|
...
|
|
