#入库同步串行请求

Junjie

1 天以前 641bf75f1b6684ee5b6d13497ad1106b82c59043

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

@@ -38,10 +38,6 @@
        return RedisKeyType.GENERATE_IN_TASK_LIMIT.key + context.getStationObjModel().getStationId();
    }

    default int getSubmitLockSeconds(StoreInTaskContext context) {
        return 2;
    }

    default int getRetryLockSeconds(StoreInTaskContext context) {
        return 2;
    }
@@ -67,17 +63,13 @@
    default void afterTaskCreated(StoreInTaskContext context, WrkMast wrkMast) {
    }

    default void onApplySubmitted(StoreInTaskContext context) {
        context.getStationProtocol().setSystemWarning("请求入库中");
    }

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

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