package com.vincent.rsf.server.manager.service;
|
|
import com.baomidou.mybatisplus.extension.service.IService;
|
import com.vincent.rsf.framework.common.R;
|
import com.vincent.rsf.server.api.controller.erp.params.InOutResultReportParam;
|
import com.vincent.rsf.server.manager.entity.CloudWmsNotifyLog;
|
|
import java.io.IOException;
|
import java.util.List;
|
|
/** 云仓上报待办 */
|
public interface CloudWmsNotifyLogService extends IService<CloudWmsNotifyLog> {
|
|
List<CloudWmsNotifyLog> listPending(int limit, int maxRetry);
|
|
void fillFromConfig(CloudWmsNotifyLog log);
|
|
/** 上报类型：入出库结果（系统配置优先，缺省 IN_OUT_RESULT） */
|
String getReportTypeInOutResult();
|
|
/** 上报类型：库存调整（系统配置优先，缺省 INVENTORY_ADJUST） */
|
String getReportTypeInventoryAdjust();
|
|
/** 通知状态：待通知（系统配置优先，缺省 0） */
|
int getNotifyStatusPending();
|
|
/** 通知状态：已成功（系统配置优先，缺省 1） */
|
int getNotifyStatusSuccess();
|
|
/** 通知状态：失败（系统配置优先，缺省 2） */
|
int getNotifyStatusFail();
|
|
/** 入出库同单分组键（orderNo+入库/出库+仓），与调度内存合并一致 */
|
String inOutMergeKeyFromRequestBody(String requestBody);
|
|
/** 解析请求体为入出库行列表（单行 JSON 或 lines 数组） */
|
List<InOutResultReportParam> parseInOutLinesFromRequestBody(String requestBody) throws IOException;
|
|
/** 发送前占位，避免与合并并发；返回 false 表示已有实例在处理 */
|
boolean tryClaimSending(Long id);
|
|
void clearSending(Long id);
|
|
/** sending=1 且 update_time 超时：补偿清零；启用 Redis 时还要求占位已失 */
|
void recoverStaleSendingWhenRedisMiss();
|
|
/** manual 模式：按单号放行暂缓的入出库待办（send_hold=1→0） */
|
R manualFlushToNotifyByOrderCode(String orderCode, boolean inbound);
|
}
|
