88 lines
2.9 KiB
JavaScript
88 lines
2.9 KiB
JavaScript
|
import { httpGet, httpPost, httpDelete } from './http.js';
|
|||
|
|
import { ENV } from './env.js';
|
|||
|
|
|
|||
|
|
const BASE_PATH = '/wmsServer/wms/api/orderIn';
|
|||
|
|
|
|||
|
|
function buildUrl(endpoint) {
|
|||
|
|
return `${BASE_PATH}${endpoint}`;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 统一的响应数据解包器
|
|||
|
|
* @param {object} response - HTTP 响应对象 { code, data, message }
|
|||
|
|
* @param {string} fallbackMessage - 失败时的默认错误消息
|
|||
|
|
* @returns {object} 解包后的业务数据（附带 httpStatus）
|
|||
|
|
* @throws {Error} 当 HTTP 状态码不是 200 或响应格式不正确时抛出错误
|
|||
|
|
*/
|
|||
|
|
function unwrapResponse(response, fallbackMessage) {
|
|||
|
|
const { code: statusCode, data, message } = response || {};
|
|||
|
|
if (statusCode !== 200) {
|
|||
|
|
throw new Error(message || fallbackMessage || '请求失败');
|
|||
|
|
}
|
|||
|
|
if (!data || typeof data !== 'object') {
|
|||
|
|
throw new Error(fallbackMessage || '响应格式不正确');
|
|||
|
|
}
|
|||
|
|
return Object.assign({ httpStatus: statusCode }, data);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
export const WmsApiClient = {
|
|||
|
|
async engineStockIn({ standId, vehicleNo, goodsId, model, goodsNum = 0, timeout = 10000 }) {
|
|||
|
|
const payload = {
|
|||
|
|
efSelect: standId,
|
|||
|
|
vehicleNo,
|
|||
|
|
goodsId,
|
|||
|
|
goodsNum,
|
|||
|
|
model,
|
|||
|
|
};
|
|||
|
|
const res = await httpPost(buildUrl('/loginInBad'), payload, { timeout });
|
|||
|
|
return unwrapResponse(res, '发动机入库失败');
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
async emptyVehicleIn({ standId, vehicleNo = 'D99999999', timeout = 8000 }) {
|
|||
|
|
const payload = {
|
|||
|
|
efSelect: standId,
|
|||
|
|
vehicleNo,
|
|||
|
|
goodsId: '',
|
|||
|
|
goodsNum: 0,
|
|||
|
|
model: '',
|
|||
|
|
};
|
|||
|
|
const res = await httpPost(buildUrl('/loginToByVehicle'), payload, { timeout });
|
|||
|
|
return unwrapResponse(res, '空载具入库失败');
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
async bindVehicle({ vehicleNo, goodsId, goodsNum = 0, userName = 'PDA', timeout = 8000 }) {
|
|||
|
|
const payload = {
|
|||
|
|
goodsId,
|
|||
|
|
goodsNum,
|
|||
|
|
vehicleNo,
|
|||
|
|
userName,
|
|||
|
|
};
|
|||
|
|
const res = await httpPost(buildUrl('/bindingVehicl'), payload, { timeout });
|
|||
|
|
return unwrapResponse(res, '绑定物料失败');
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
async getOrderInWithVehicleNo({ vehicleNo, timeout = 8000 }) {
|
|||
|
|
const res = await httpGet(buildUrl('/getOrderInWithVehicleNo'), { vehicleNo }, { timeout });
|
|||
|
|
return unwrapResponse(res, '获取物料列表失败');
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
async rawStockIn({ vehicleNo, standId, timeout = 10000 }) {
|
|||
|
|
const payload = {
|
|||
|
|
vehicleNo,
|
|||
|
|
selectByIn: standId,
|
|||
|
|
};
|
|||
|
|
const res = await httpPost(buildUrl('/addInByTask'), payload, { timeout });
|
|||
|
|
return unwrapResponse(res, '原材料入库失败');
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
async deleteOrderIn({ rowId, timeout = 8000 }) {
|
|||
|
|
const res = await httpDelete(`${buildUrl('/deleteOrderIn')}/${rowId}`, { timeout });
|
|||
|
|
return unwrapResponse(res, '删除物料失败');
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
async testLink({ vehicleNo = 'LSP00168', timeout = 8000 } = {}) {
|
|||
|
|
const res = await httpGet(buildUrl('/getOrderInWithVehicleNo'), { vehicleNo }, { timeout });
|
|||
|
|
return unwrapResponse(res, '接口不通');
|
|||
|
|
},
|
|||
|
|
};
|