package cn.iocoder.yudao.module.mes.service.pro.scan;
|
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
import cn.iocoder.yudao.module.mes.controller.admin.pro.scan.vo.MesProScanEventCreateReqVO;
|
import cn.iocoder.yudao.module.mes.controller.admin.pro.scan.vo.MesProScanEventPageReqVO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.bagcode.MesProBagCodeDO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.batch.MesProBatchDO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.scan.MesProScanEventDO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.warehouse.MesWmWarehouseDO;
|
import cn.iocoder.yudao.module.mes.dal.mysql.pro.bagcode.MesProBagCodeMapper;
|
import cn.iocoder.yudao.module.mes.dal.mysql.pro.batch.MesProBatchMapper;
|
import cn.iocoder.yudao.module.mes.dal.mysql.pro.scan.MesProScanEventMapper;
|
import cn.iocoder.yudao.module.mes.enums.MesBizTypeConstants;
|
import cn.iocoder.yudao.module.mes.enums.MesProScanEventStatusEnum;
|
import cn.iocoder.yudao.module.mes.enums.wm.MesWmTransactionTypeEnum;
|
import cn.iocoder.yudao.module.mes.service.wm.transaction.MesWmTransactionService;
|
import cn.iocoder.yudao.module.mes.service.wm.transaction.dto.MesWmTransactionSaveReqDTO;
|
import cn.iocoder.yudao.module.mes.service.wm.warehouse.MesWmWarehouseService;
|
import jakarta.annotation.Resource;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.validation.annotation.Validated;
|
|
import java.time.LocalDateTime;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Service
|
@Validated
|
public class MesProScanEventServiceImpl implements MesProScanEventService {
|
@Resource private MesProScanEventMapper eventMapper;
|
@Resource private MesProBagCodeMapper bagCodeMapper;
|
@Resource private MesProBatchMapper batchMapper;
|
@Resource private MesWmTransactionService transactionService;
|
@Resource private MesWmWarehouseService warehouseService;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public MesProScanEventDO createInbound(MesProScanEventCreateReqVO req) {
|
MesProScanEventDO existing = eventMapper.selectByEventIdForUpdate(req.getEventId());
|
if (existing != null) {
|
if (!req.getBagCode().equals(existing.getBagCode()) || !req.getDeviceCode().equals(existing.getDeviceCode())) {
|
return failed(existing, "MES_SCAN_EVENT_ID_CONFLICT", "事件号已存在但内容不一致");
|
}
|
return existing;
|
}
|
MesProScanEventDO event = new MesProScanEventDO();
|
event.setEventId(req.getEventId()).setBagCode(req.getBagCode()).setQuantity(req.getQuantity())
|
.setDeviceCode(req.getDeviceCode()).setLineCode(req.getLineCode()).setRemark(req.getRemark())
|
.setStatus(MesProScanEventStatusEnum.FAILED).setReceivedTime(LocalDateTime.now());
|
eventMapper.insert(event);
|
MesProBagCodeDO bag = bagCodeMapper.selectByCodeForUpdate(req.getBagCode());
|
if (bag == null) return failed(event, "MES_SCAN_BAG_NOT_EXISTS", "袋码不存在");
|
event.setBagCodeId(bag.getId());
|
if (bag.getInboundEventId() != null) return failed(event, "MES_SCAN_BAG_ALREADY_INBOUND", "袋码已入库");
|
MesProBatchDO batch = batchMapper.selectByIdForUpdate(bag.getBatchId());
|
if (batch == null) return failed(event, "MES_SCAN_BATCH_NOT_EXISTS", "生产批次不存在");
|
event.setBatchId(batch.getId()).setBatchCode(batch.getCode()).setItemId(batch.getItemId());
|
MesWmWarehouseDO warehouse = warehouseService.getWarehouseByCode(MesWmWarehouseDO.WIP_VIRTUAL_WAREHOUSE);
|
if (warehouse == null) return failed(event, "MES_SCAN_WIP_WAREHOUSE_NOT_EXISTS", "WIP虚拟仓不存在");
|
event.setWarehouseId(warehouse.getId()).setLocationId(req.getLocationId()).setAreaId(req.getAreaId());
|
try {
|
Long txId = transactionService.createTransaction(new MesWmTransactionSaveReqDTO()
|
.setType(MesWmTransactionTypeEnum.IN.getType()).setBizType(MesBizTypeConstants.WM_PRODUCT_PRODUCE)
|
.setBizId(batch.getId()).setBizCode(batch.getCode()).setBizLineId(bag.getId())
|
.setItemId(batch.getItemId()).setQuantity(req.getQuantity()).setBatchCode(batch.getCode())
|
.setWarehouseId(warehouse.getId()).setLocationId(req.getLocationId()).setAreaId(req.getAreaId())
|
.setReceiptTime(LocalDateTime.now()).setCheckFlag(true));
|
event.setTransactionId(txId).setStatus(MesProScanEventStatusEnum.SUCCESS).setEventTime(LocalDateTime.now());
|
eventMapper.updateById(event);
|
bagCodeMapper.markInbound(bag.getId(), event.getId(), req.getDeviceCode(), req.getLineCode());
|
batchMapper.markInbound(batch.getId(), event.getId(), req.getDeviceCode(), req.getLineCode());
|
return event;
|
} catch (Exception ex) {
|
return failed(event, "MES_SCAN_TRANSACTION_FAILED", "库存事务处理失败");
|
}
|
}
|
|
private MesProScanEventDO failed(MesProScanEventDO event, String code, String message) {
|
event.setStatus(MesProScanEventStatusEnum.FAILED).setErrorCode(code).setErrorMessage(message)
|
.setFailedTime(LocalDateTime.now()).setEventTime(LocalDateTime.now());
|
eventMapper.updateById(event);
|
return event;
|
}
|
|
@Override public MesProScanEventDO getByEventId(String eventId) { return eventMapper.selectOne(MesProScanEventDO::getEventId, eventId); }
|
@Override public PageResult<MesProScanEventDO> getPage(MesProScanEventPageReqVO reqVO) { return eventMapper.selectPage(reqVO); }
|
@Override public MesProScanEventDO getLatest(String deviceCode) { return eventMapper.selectLatest(deviceCode); }
|
@Override public Map<String, Object> getDashboard() {
|
Map<String, Object> result = new HashMap<>();
|
result.put("latest", eventMapper.selectLatest(null));
|
result.put("total", eventMapper.selectCount(null));
|
result.put("success", eventMapper.selectCount(new com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper<MesProScanEventDO>().eq(MesProScanEventDO::getStatus, MesProScanEventStatusEnum.SUCCESS)));
|
result.put("failed", eventMapper.selectCount(new com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper<MesProScanEventDO>().eq(MesProScanEventDO::getStatus, MesProScanEventStatusEnum.FAILED)));
|
return result;
|
}
|
}
|
