| | |
| | | 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; |
| | | |
| | | /** 云仓上报待办 */ |
| | |
| | | |
| | | /** 通知状态:失败(系统配置优先,缺省 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); |
| | | } |