| | |
| | | result.setResponse(response); |
| | | result.setMessage(message); |
| | | |
| | | News.error("WMS入库请求失败,barcode={},stationId={},response={}", |
| | | request.getBarcode(), request.getSourceStaNo(), policy.buildFailureMessage(result)); |
| | | News.error("WMS入库请求失败,barcode={},stationId={},response={},WCS响应={}", |
| | | request.getBarcode(), request.getSourceStaNo(), result.getResponse(), result.getMessage()); |
| | | redisUtil.set(policy.getGenerateLockKey(context), "lock", policy.getRetryLockSeconds(context)); |
| | | policy.onApplyFailed(context, result); |
| | | } |
| | |
| | | } |
| | | |
| | | default void onApplyFailed(StoreInTaskContext context, InTaskApplyResult result) { |
| | | String warning = "请求入库失败,WMS返回=" + buildFailureMessage(result); |
| | | String warning = "请求入库失败,WMS返回=" + result.getResponse() + ",WCS响应=" + result.getMessage(); |
| | | setSystemWarning(context, warning); |
| | | } |
| | | |
| | | default String buildFailureMessage(InTaskApplyResult result) { |
| | | if (!Cools.isEmpty(result.getResponse())) { |
| | | return result.getResponse(); |
| | | } |
| | | return result.getMessage(); |
| | | } |
| | | |
| | | default void syncWarningToBackStation(StoreInTaskContext context, String warning) { |