package com.vincent.rsf.server.api.integration.dap;
|
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* 鼎捷 DAP 返回结构转云仓上报内部统一格式（供重试任务判断 code==200）
|
*/
|
public final class DapIlcwmsResponseNormalizer {
|
|
private DapIlcwmsResponseNormalizer() {
|
}
|
|
public static Map<String, Object> toNotifyFormat(Map<String, Object> dapBody) {
|
if (dapBody == null) {
|
return resultMap(500, "云仓返回空", null);
|
}
|
Object st = dapBody.get("status");
|
int status = 0;
|
if (st instanceof Number) {
|
status = ((Number) st).intValue();
|
}
|
if (status == 200) {
|
return resultMap(200, "OK", dapBody);
|
}
|
Object err = dapBody.get("errorMessage");
|
String msg = err != null ? String.valueOf(err) : String.valueOf(dapBody.get("statusDescription"));
|
if (msg == null || "null".equals(msg)) {
|
msg = "云仓返回失败";
|
}
|
return resultMap(500, msg, dapBody);
|
}
|
|
/**
|
* 9.2 等仍走旧路径的接口：若返回无顶层 status，则按原 code/msg 透传（兼容旧云仓 JSON）。
|
*/
|
public static Map<String, Object> toNotifyFormatFlexible(Map<String, Object> body) {
|
if (body == null) {
|
return toNotifyFormat(null);
|
}
|
if (body.containsKey("status")) {
|
return toNotifyFormat(body);
|
}
|
if (body.containsKey("code")) {
|
return body;
|
}
|
return toNotifyFormat(body);
|
}
|
|
private static Map<String, Object> resultMap(int code, String msg, Map<String, Object> data) {
|
Map<String, Object> map = new HashMap<>();
|
map.put("code", code);
|
map.put("msg", msg);
|
map.put("data", data);
|
return map;
|
}
|
}
|
