package org.jeecg.modules.wms.service.impl;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.jeecg.common.aspect.annotation.ApiLog;
|
import org.jeecg.common.constant.ApiLogCategoryEnum;
|
import org.jeecg.modules.base.entity.LineSideWarehouse;
|
import org.jeecg.modules.base.service.ILineSideWarehouseService;
|
import org.jeecg.modules.lsw.entity.LswMaterial;
|
import org.jeecg.modules.lsw.entity.LswMaterialInbound;
|
import org.jeecg.modules.lsw.entity.LswMaterialInventory;
|
import org.jeecg.modules.lsw.entity.LswMaterialOutbound;
|
import org.jeecg.modules.lsw.service.ILswMaterialInboundService;
|
import org.jeecg.modules.lsw.service.ILswMaterialInventoryService;
|
import org.jeecg.modules.lsw.service.ILswMaterialOutboundService;
|
import org.jeecg.modules.lsw.service.ILswMaterialService;
|
import org.jeecg.modules.mes.entity.MesMaterialTransferRequest;
|
import org.jeecg.modules.mes.entity.MesTransferOrderPrint;
|
import org.jeecg.modules.mes.enums.MaterialTransferRequestStatus;
|
import org.jeecg.modules.mes.enums.TransferOrderStatusEnum;
|
import org.jeecg.modules.mes.service.IMesMaterialTransferRequestService;
|
import org.jeecg.modules.mes.service.IMesTransferOrderPrintService;
|
import org.jeecg.modules.wms.dto.WSResponse;
|
import org.jeecg.modules.wms.request.ReceiveWMSScanItemList;
|
import org.jeecg.modules.wms.request.WMSWebServiceSendItem;
|
import org.jeecg.modules.wms.service.MESWebServiceSoap;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.jws.WebMethod;
|
import javax.jws.WebParam;
|
import javax.jws.WebResult;
|
import javax.jws.WebService;
|
import javax.xml.ws.RequestWrapper;
|
import javax.xml.ws.ResponseWrapper;
|
import java.math.BigDecimal;
|
|
|
@Slf4j
|
@Service
|
@WebService(name = "MESWebServiceSoap", targetNamespace = "http://xhj008.server.webservice.com", endpointInterface = "org.jeecg.modules.wms.service.MESWebServiceSoap")
|
public class MESWebServiceSoapImpl implements MESWebServiceSoap {
|
|
@Autowired
|
private IMesMaterialTransferRequestService materialTransferRequestService;
|
@Autowired
|
private ILineSideWarehouseService lineSideWarehouseService;
|
@Autowired
|
private ILswMaterialInboundService materialInboundService;
|
@Autowired
|
private IMesTransferOrderPrintService transferOrderPrintService;
|
@Autowired
|
private ILswMaterialOutboundService materialOutboundService;
|
@Autowired
|
private ILswMaterialInventoryService materialInventoryService;
|
@Autowired
|
private ILswMaterialService materialService;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
@WebMethod(operationName = "ReceiveWMSScanItemList", action = "http://xhj008.server.webservice.com/ReceiveWMSScanItemList")
|
@RequestWrapper(localName = "ReceiveWMSScanItemList", targetNamespace = "http://xhj008.server.webservice.com/", className = "ReceiveWMSScanItemList")
|
@ResponseWrapper(localName = "ReceiveWMSScanItemListResponse", targetNamespace = "http://xhj008.server.webservice.com/", className = "ReceiveWMSScanItemListResponse")
|
@WebResult(name = "ReceiveWMSScanItemListResult", targetNamespace = "http://xhj008.server.webservice.com/")
|
@ApiLog(apiName = "接收WMS的移库信息(ReceiveWMSScanItemList(MES)", apiCategory = ApiLogCategoryEnum.WMS)
|
public WSResponse receiveWMSScanItemList(@WebParam(name = "ReceiveWMSScanItemList", targetNamespace = "http://xhj008.server.webservice.com/") ReceiveWMSScanItemList request) {
|
WSResponse response = new WSResponse();
|
if (request == null || CollectionUtil.isEmpty(request.getWmsWebServiceSendItemList())) {
|
response.setErrorCode("N");
|
response.setErrorDesc("传入的参数为空！");
|
return response;
|
}
|
int errorCount = 0;
|
int successCount = 0;
|
StringBuilder errorMsg = new StringBuilder();
|
for (WMSWebServiceSendItem item : request.getWmsWebServiceSendItemList()) {
|
if (StringUtils.isNotBlank(item.getReservationOrder())) {
|
//物料拉动回调
|
MesMaterialTransferRequest transferRequest = materialTransferRequestService.queryByReservationCode(item.getReservationOrder());
|
if (transferRequest == null) {
|
errorCount++;
|
errorMsg.append("根据预留号[").append(item.getReservationOrder()).append("]未找到物料拉动单！\n");
|
continue;
|
}
|
LineSideWarehouse warehouse = lineSideWarehouseService.getById(transferRequest.getTargetWarehouseId());
|
if (warehouse == null || !warehouse.getWarehouseCode().equals(item.getDestSection())) {
|
errorCount++;
|
errorMsg.append("线边库[").append(item.getDestSection()).append("]未找到！\n");
|
continue;
|
}
|
if (!transferRequest.getMaterialNumber().equals(item.getSkuCode())) {
|
errorCount++;
|
errorMsg.append("物料编号[").append(item.getSkuCode()).append("]不匹配！\n");
|
continue;
|
}
|
if (StringUtils.isBlank(item.getTrackLot())) {
|
errorCount++;
|
errorMsg.append("批次号[").append(item.getTrackLot()).append("]不能为空！\n");
|
continue;
|
}
|
transferRequest.setRequestStatus(MaterialTransferRequestStatus.CHECKED_IN.name());
|
//计算实际拉动数量
|
BigDecimal actualQuantity = transferRequest.getActualQuantity() == null ? item.getQuantity() : transferRequest.getActualQuantity().add(item.getQuantity());
|
transferRequest.setActualQuantity(actualQuantity);
|
|
//添加入库信息
|
LswMaterialInbound inbound = new LswMaterialInbound();
|
inbound.setWarehouseId(transferRequest.getTargetWarehouseId());
|
inbound.setReceiver("WMS");
|
inbound.setMaterialNumber(transferRequest.getMaterialNumber());
|
inbound.setMaterialName(transferRequest.getMaterialName());
|
inbound.setBatchNumber(item.getTrackLot());
|
inbound.setQuantity(item.getQuantity());
|
inbound.setFactoryId(warehouse.getFactoryId());
|
boolean b = materialInboundService.inboundMaterial(inbound);
|
if (!b) {
|
errorCount++;
|
errorMsg.append("预留号[").append(item.getReservationOrder()).append("]入库失败！\n");
|
continue;
|
}
|
//更新物料拉动单
|
materialTransferRequestService.updateById(transferRequest);
|
successCount++;
|
} else if (StringUtils.isNotBlank(item.getAlign())) {
|
//移库单回调
|
MesTransferOrderPrint transferOrder = transferOrderPrintService.queryByOrderCode(item.getAlign());
|
if (transferOrder == null) {
|
errorCount++;
|
errorMsg.append("移库单[").append(item.getAlign()).append("]不存在！\n");
|
continue;
|
}
|
LswMaterialInventory inventory = materialInventoryService.getById(item.getMesStockID());
|
if (inventory == null) {
|
errorCount++;
|
errorMsg.append("库存信息[").append(item.getMesStockID()).append("]不存在！\n");
|
continue;
|
}
|
LswMaterial material = materialService.queryByMaterialNumber(item.getSkuCode());
|
if(material == null) {
|
errorCount++;
|
errorMsg.append("物料编号[").append(item.getSkuCode()).append("]不存在！\n");
|
continue;
|
}
|
LineSideWarehouse warehouse = lineSideWarehouseService.getById(transferOrder.getOriginalWarehouseId());
|
if (warehouse == null || !warehouse.getWarehouseCode().equals(item.getDestSection())) {
|
errorCount++;
|
errorMsg.append("线边库[").append(item.getDestSection()).append("]未找到！\n");
|
continue;
|
}
|
//移库单更改
|
transferOrder.setOrderStatus(TransferOrderStatusEnum.COMPLETED.name());
|
//成品出库
|
LswMaterialOutbound outbound = new LswMaterialOutbound();
|
outbound.setBatchNumber(inventory.getBatchNumber());
|
outbound.setQuantity(item.getQuantity());
|
outbound.setMaterialNumber(material.getMaterialNumber());
|
outbound.setMaterialName(material.getMaterialName());
|
outbound.setInventoryId(inventory.getId());
|
outbound.setWarehouseId(transferOrder.getOriginalWarehouseId());
|
outbound.setFactoryId(warehouse.getFactoryId());
|
outbound.setOutboundStaff("WMS");
|
boolean b = materialOutboundService.outboundMaterial(outbound);
|
if (!b) {
|
errorCount++;
|
errorMsg.append("移库单[").append(item.getAlign()).append("]出库失败！\n");
|
continue;
|
}
|
transferOrderPrintService.updateById(transferOrder);
|
successCount++;
|
}
|
}
|
//处理返回结果
|
if (errorCount > 0) {
|
response.setErrorCode("N");
|
if (successCount > 0) {
|
String msg = "成功执行" + successCount + "条，失败" + errorCount + "条！\n";
|
errorMsg.insert(0, msg);
|
} else {
|
String msg = "失败" + errorCount + "条！\n";
|
errorMsg.insert(0, msg);
|
}
|
response.setErrorDesc(errorMsg.toString());
|
} else {
|
response.setErrorCode("Y");
|
String msg = "成功执行" + successCount + "条！\n";
|
response.setErrorDesc(msg);
|
}
|
return response;
|
}
|
}
|
