| | |
| | | public Map<String, Object> syncMatnrsToCloud(Object body) { |
| | | if (!isCloudWmsConfigured()) { |
| | | log.warn("ErpApi(云仓WMS) 未配置 host/base-url,跳过物料基础信息同步"); |
| | | return stubSuccess("云仓地址未配置,未实际同步"); |
| | | return stubWithoutUpstream("云仓地址未配置,未实际同步"); |
| | | } |
| | | return cloudWmsErpFeignClient.syncMatnrs(body != null ? body : new HashMap<>()); |
| | | } |
| | |
| | | } |
| | | if (!isCloudWmsConfigured()) { |
| | | log.warn("ErpApi(云仓WMS) 未配置 host/base-url,跳过 9.1 入/出库结果上报,订单:{}", param.getOrderNo()); |
| | | return stubSuccess("云仓地址未配置,未实际上报"); |
| | | return stubWithoutUpstream("云仓地址未配置,未实际上报"); |
| | | } |
| | | String err = validateDapBaseForInOut(param); |
| | | if (err != null) { |
| | |
| | | } |
| | | if (!isCloudWmsConfigured()) { |
| | | log.warn("ErpApi(云仓WMS) 未配置 host/base-url,跳过 9.1 入出库合并上报"); |
| | | return stubSuccess("云仓地址未配置,未实际上报"); |
| | | return stubWithoutUpstream("云仓地址未配置,未实际上报"); |
| | | } |
| | | InOutResultReportParam first = lines.get(0); |
| | | boolean inbound = first.getInbound() == null || Boolean.TRUE.equals(first.getInbound()); |
| | |
| | | } |
| | | if (!isCloudWmsConfigured()) { |
| | | log.warn("ErpApi(云仓WMS) 未配置 host/base-url,跳过 9.2 库存调整上报,物料:{}", param.getMatNr()); |
| | | return stubSuccess("云仓地址未配置,未实际上报"); |
| | | return stubWithoutUpstream("云仓地址未配置,未实际上报"); |
| | | } |
| | | Integer changeType = param.getChangeType(); |
| | | if (changeType == null) { |
| | |
| | | return baseUrl != null && !baseUrl.trim().isEmpty(); |
| | | } |
| | | |
| | | private Map<String, Object> stubSuccess(String msg) { |
| | | /** 未走云仓 HTTP,code 非 200,避免调度误判成功 */ |
| | | private Map<String, Object> stubWithoutUpstream(String msg) { |
| | | Map<String, Object> data = new HashMap<>(); |
| | | data.put("result", "SUCCESS"); |
| | | return resultMap(200, msg, data); |
| | | data.put("result", "SKIPPED"); |
| | | return resultMap(503, msg, data); |
| | | } |
| | | |
| | | private Map<String, Object> resultMap(int code, String msg, Map<String, Object> data) { |