正在显示
1 个修改的文件
包含
32 行增加
和
12 行删除
| @@ -7,6 +7,7 @@ import com.sy.model.GatherInfo | @@ -7,6 +7,7 @@ import com.sy.model.GatherInfo | ||
| 7 | import com.sy.model.LAND_BUSINEESTYPE_LIST_INFO | 7 | import com.sy.model.LAND_BUSINEESTYPE_LIST_INFO |
| 8 | import com.sy.model.LandBusinessTypeList | 8 | import com.sy.model.LandBusinessTypeList |
| 9 | import com.sy.response.ResultJson | 9 | import com.sy.response.ResultJson |
| 10 | +import com.sy.service.EnginCheckService | ||
| 10 | import com.sy.service.impl.GatherInfoHandle; | 11 | import com.sy.service.impl.GatherInfoHandle; |
| 11 | import feign.Feign | 12 | import feign.Feign |
| 12 | import feign.Headers | 13 | import feign.Headers |
| @@ -33,10 +34,10 @@ class BillDomTransportCheck extends Script implements ChannelCheckScript { | @@ -33,10 +34,10 @@ class BillDomTransportCheck extends Script implements ChannelCheckScript { | ||
| 33 | @Override | 34 | @Override |
| 34 | Boolean check(ExecuteParams executeParams) { | 35 | Boolean check(ExecuteParams executeParams) { |
| 35 | try { | 36 | try { |
| 36 | - Boolean checkFlag = false; | 37 | + Boolean checkFlag = true; |
| 37 | String cookieUserName = "admin" | 38 | String cookieUserName = "admin" |
| 38 | String cookieUserId = "1903e605-a2e1-404d-a1a6-a749752fb030" | 39 | String cookieUserId = "1903e605-a2e1-404d-a1a6-a749752fb030" |
| 39 | - String ServiceAdr = "http://192.168.1.63:10001" | 40 | + String ServiceAdr = "http://10.50.3.61:10001" |
| 40 | 41 | ||
| 41 | GatherInfo gatherInfo = (GatherInfo) executeParams.get("GatherInfo"); | 42 | GatherInfo gatherInfo = (GatherInfo) executeParams.get("GatherInfo"); |
| 42 | LandBusinessTypeList landBusinessTypeList = (LandBusinessTypeList) executeParams.get("ChanelFormInfo"); | 43 | LandBusinessTypeList landBusinessTypeList = (LandBusinessTypeList) executeParams.get("ChanelFormInfo"); |
| @@ -83,30 +84,42 @@ class BillDomTransportCheck extends Script implements ChannelCheckScript { | @@ -83,30 +84,42 @@ class BillDomTransportCheck extends Script implements ChannelCheckScript { | ||
| 83 | logger.info("[TRANS-API-RESPONSE]-单证:{},状态:{}",oBill,status) | 84 | logger.info("[TRANS-API-RESPONSE]-单证:{},状态:{}",oBill,status) |
| 84 | 85 | ||
| 85 | if (status>0){ | 86 | if (status>0){ |
| 87 | + sb.append("转运单证[").append(bill.getAwba()).append("]核验通过") | ||
| 86 | logger.info("[TRANS-CHECK-SUCCESS]-单证:{},状态:{},转运业务验放通过",oBill,status) | 88 | logger.info("[TRANS-CHECK-SUCCESS]-单证:{},状态:{},转运业务验放通过",oBill,status) |
| 87 | -// return true | ||
| 88 | - checkFlag = true | ||
| 89 | }else{ | 89 | }else{ |
| 90 | - logger.info("[TRANS-CHECK-FAILD]-转运单证{}核验失败",bill.getAwba()) | 90 | + logger.info("[TRANS-CHECK-FAILD]-转运单证{}核验失败,未审核通过",bill.getAwba()) |
| 91 | sb.append("转运单证[").append(bill.getAwba()).append("]核验失败,未审核通过") | 91 | sb.append("转运单证[").append(bill.getAwba()).append("]核验失败,未审核通过") |
| 92 | gatherInfoHandle.sendBw(gatherInfo,false,sb.toString(),landBusinessTypeList,listinfos); | 92 | gatherInfoHandle.sendBw(gatherInfo,false,sb.toString(),landBusinessTypeList,listinfos); |
| 93 | - return checkFlag; | 93 | + return checkFlag = false; |
| 94 | } | 94 | } |
| 95 | }) | 95 | }) |
| 96 | + }else{ | ||
| 97 | + logger.info("[TRANS-CHECK-FAILD]-转运单证{}核验失败,未找到申请数据",bill.getAwba()) | ||
| 98 | + sb.append("转运单证[").append(bill.getAwba()).append("]核验失败,未找到申请数据") | ||
| 99 | + gatherInfoHandle.sendBw(gatherInfo,false,sb.toString(),landBusinessTypeList,listinfos); | ||
| 100 | + return checkFlag = false; | ||
| 96 | } | 101 | } |
| 102 | + }else { | ||
| 103 | + logger.info("[TRANS-CHECK-FAILD]-转运单证{}核验失败,API未查询到转运申请数据",bill.getAwba()) | ||
| 104 | + sb.append("转运单证[").append(bill.getAwba()).append("]核验失败,API未查询到转运申请数据") | ||
| 105 | + gatherInfoHandle.sendBw(gatherInfo,false,sb.toString(),landBusinessTypeList,listinfos); | ||
| 106 | + return checkFlag = false; | ||
| 97 | } | 107 | } |
| 98 | }else{ | 108 | }else{ |
| 99 | - logger.info("[TRANS-CHECK-FAILD]-转运单证{}核验失败",bill.getAwba()) | 109 | + logger.info("[TRANS-CHECK-FAILD]-转运单证{}核验失败,API-FAILD",bill.getAwba()) |
| 100 | sb.append("转运单证[").append(bill.getAwba()).append("]核验失败,API-FAILD") | 110 | sb.append("转运单证[").append(bill.getAwba()).append("]核验失败,API-FAILD") |
| 101 | gatherInfoHandle.sendBw(gatherInfo,false,sb.toString(),landBusinessTypeList,listinfos); | 111 | gatherInfoHandle.sendBw(gatherInfo,false,sb.toString(),landBusinessTypeList,listinfos); |
| 102 | - return checkFlag; | 112 | + return checkFlag = false; |
| 103 | } | 113 | } |
| 104 | }) | 114 | }) |
| 105 | - //这里返回验放成功,验放失败从上面返回 | ||
| 106 | - return checkFlag; | ||
| 107 | }else{ | 115 | }else{ |
| 108 | - return checkFlag; | 116 | + gatherInfoHandle.sendBw(gatherInfo,false,"缺少申请单证信息",landBusinessTypeList,listinfos); |
| 117 | + return checkFlag = false; | ||
| 109 | } | 118 | } |
| 119 | + if (checkFlag){ | ||
| 120 | + commandLog(gatherInfo,true,"转运业务单证核放成功",executeParams) | ||
| 121 | + } | ||
| 122 | + return checkFlag; | ||
| 110 | 123 | ||
| 111 | } catch (Exception e) { | 124 | } catch (Exception e) { |
| 112 | e.printStackTrace(); | 125 | e.printStackTrace(); |
| @@ -120,7 +133,6 @@ class BillDomTransportCheck extends Script implements ChannelCheckScript { | @@ -120,7 +133,6 @@ class BillDomTransportCheck extends Script implements ChannelCheckScript { | ||
| 120 | return false; | 133 | return false; |
| 121 | } | 134 | } |
| 122 | 135 | ||
| 123 | - | ||
| 124 | // 获取spring容器 | 136 | // 获取spring容器 |
| 125 | ApplicationContext getContext() { | 137 | ApplicationContext getContext() { |
| 126 | // 获取spring IOC容器 | 138 | // 获取spring IOC容器 |
| @@ -128,6 +140,14 @@ class BillDomTransportCheck extends Script implements ChannelCheckScript { | @@ -128,6 +140,14 @@ class BillDomTransportCheck extends Script implements ChannelCheckScript { | ||
| 128 | return context; | 140 | return context; |
| 129 | } | 141 | } |
| 130 | 142 | ||
| 143 | + void commandLog(GatherInfo gatherInfo,boolean check,String reason,ExecuteParams executeParams){ | ||
| 144 | + // 调用方法 | ||
| 145 | + ApplicationContext context = getContext(); | ||
| 146 | + // 获取容器中的bean | ||
| 147 | + EnginCheckService enginCheckService = context.getBean(EnginCheckService.class); | ||
| 148 | + enginCheckService.commandlog(gatherInfo,check,reason,executeParams) | ||
| 149 | + } | ||
| 150 | + | ||
| 131 | private <T> T createFeignClient(Class<T> clientClass, String url,String username, String userid) { | 151 | private <T> T createFeignClient(Class<T> clientClass, String url,String username, String userid) { |
| 132 | return Feign.builder() | 152 | return Feign.builder() |
| 133 | .options(new Request.Options(5000, 5000)) | 153 | .options(new Request.Options(5000, 5000)) |
-
请 注册 或 登录 后发表评论