| | |
|---|
| | | policy.onRequestPermitGranted(context); |
|---|
| | | |
|---|
| | | InTaskApplyRequest request = policy.buildApplyRequest(context); |
|---|
| | | policy.setSystemWarning(context, "请求WMS中"); |
|---|
| | | News.info("发起同步WMS入库请求，barcode={}，stationId={}，timeout={}s", |
|---|
| | | request.getBarcode(), request.getSourceStaNo(), APPLY_IN_TASK_TIMEOUT_SECONDS); |
|---|
| | | InTaskApplyResult result = applySyncInTask(request); |
|---|
| | |
|---|
| | | CreateInTaskParam taskParam = policy.buildCreateInTaskParam(context, dto); |
|---|
| | | WrkMast wrkMast = commonService.createInTask(taskParam); |
|---|
| | | policy.afterTaskCreated(context, wrkMast); |
|---|
| | | context.getStationProtocol().setSystemWarning(""); |
|---|
| | | policy.clearSystemWarning(context); |
|---|
| | | } catch (Exception e) { |
|---|
| | | News.error("处理WMS入库成功响应失败，barcode={}，stationId={}", request.getBarcode(), |
|---|
| | | request.getSourceStaNo(), e); |
|---|
