| | |
| | | return; |
| | | } |
| | | |
| | | StationProtocol stationProtocol = context.getStationProtocol(); |
| | | if (stationProtocol == null) { |
| | | return; |
| | | } |
| | | |
| | | if (!stationProtocol.isAutoing()) { |
| | | return; |
| | | } |
| | | |
| | | if (!stationProtocol.isLoading()) { |
| | | return; |
| | | } |
| | | |
| | | if (!stationProtocol.isInEnable()) { |
| | | return; |
| | | } |
| | | |
| | | if (stationProtocol.getTaskNo() == 0) { |
| | | return; |
| | | } |
| | | |
| | | if (Cools.isEmpty(stationProtocol.getBarcode())) { |
| | | return; |
| | | } |
| | | |
| | | if (stationProtocol.getError() > 0) { |
| | | return; |
| | | } |
| | | |
| | | if (stationProtocol.isInBarcodeError()) { |
| | | return; |
| | | } |
| | | |
| | | long count = wrkMastService.count(new QueryWrapper<WrkMast>().eq("barcode", context.getStationProtocol().getBarcode())); |
| | | if (count > 0) { |
| | | policy.setSystemWarning(context, "系统任务已存在"); |
| | |
| | | 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); |
| | | } |