#入库同步串行请求

Junjie

22 小时以前 3a633a83c866feed08d192c74c7d86cc66440916

#入库同步串行请求

 src/main/java/com/zy/core/plugin/store/StoreInTaskGenerationService.java

@@ -146,6 +146,7 @@
            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);
@@ -199,7 +200,7 @@
            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);

 src/main/java/com/zy/core/plugin/store/StoreInTaskPolicy.java

@@ -63,12 +63,23 @@
    default void afterTaskCreated(StoreInTaskContext context, WrkMast wrkMast) {
    }

    default void onApplyFailed(StoreInTaskContext context, InTaskApplyResult result) {
        String warning = "请求入库失败，WMS返回=" + buildFailureMessage(result);
    default void setSystemWarning(StoreInTaskContext context, String warning) {
        if (context == null || context.getStationProtocol() == null) {
            return;
        }
        context.getStationProtocol().setSystemWarning(warning);
        syncWarningToBackStation(context, warning);
    }

    default void clearSystemWarning(StoreInTaskContext context) {
        setSystemWarning(context, "");
    }

    default void onApplyFailed(StoreInTaskContext context, InTaskApplyResult result) {
        String warning = "请求入库失败，WMS返回=" + buildFailureMessage(result);
        setSystemWarning(context, warning);
    }

    default String buildFailureMessage(InTaskApplyResult result) {
        if (!Cools.isEmpty(result.getResponse())) {
            return result.getResponse();