package org.dromara.eims.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import org.dromara.common.core.constant.DictConstants; import org.dromara.common.core.utils.MapstructUtils; import org.dromara.common.core.utils.StringUtils; import org.dromara.common.mybatis.core.page.TableDataInfo; import org.dromara.common.mybatis.core.page.PageQuery; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import lombok.RequiredArgsConstructor; import org.dromara.eims.domain.EimsSpare; import org.dromara.eims.domain.EimsSpareInoutdt; import org.dromara.eims.domain.bo.EimsSpareBo; import org.dromara.eims.domain.vo.EimsSpareInoutdtVo; import org.dromara.eims.domain.vo.EimsSpareVo; import org.dromara.eims.mapper.EimsSpareInoutdtMapper; import org.dromara.eims.mapper.EimsSpareMapper; import org.springframework.stereotype.Service; import org.dromara.eims.domain.bo.EimsSpareInoutBo; import org.dromara.eims.domain.vo.EimsSpareInoutVo; import org.dromara.eims.domain.EimsSpareInout; import org.dromara.eims.mapper.EimsSpareInoutMapper; import org.dromara.eims.service.IEimsSpareInoutService; import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; import java.util.*; import java.util.stream.Collectors; /** * 备件出入库Service业务层处理 * * @author zhuguifei * @date 2025-03-26 */ @RequiredArgsConstructor @Service public class EimsSpareInoutServiceImpl implements IEimsSpareInoutService { private final EimsSpareInoutMapper baseMapper; private final EimsSpareInoutdtMapper inoutdtMapper; private final EimsSpareMapper spareMapper; /** * 查询备件出入库 * * @param id 主键 * @return 备件出入库 */ @Override public EimsSpareInoutVo queryById(Long id){ EimsSpareInoutVo eimsSpareInoutVo = baseMapper.selectVoById(id); QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.lambda().eq(EimsSpareInoutdt::getInoutId, id); List dtVos = inoutdtMapper.selectVoList(queryWrapper); if(!dtVos.isEmpty()){ Map map = dtVos.stream() .collect(Collectors.toMap( EimsSpareInoutdtVo::getSpareId, EimsSpareInoutdtVo::getQuantity )); List spareIdList = dtVos.stream() .map(EimsSpareInoutdtVo::getSpareId) // 获取 spareId 字段 .toList(); List eimsSpareListVos = spareMapper.selectVoBatchIds(spareIdList); for (EimsSpareVo spareVo : eimsSpareListVos) { // 假设 quantity 的值是一个固定值（例如 10） spareVo.setQuantity(map.get(spareVo.getId())); } eimsSpareInoutVo.setSpareList(eimsSpareListVos); } return eimsSpareInoutVo; } /** * 分页查询备件出入库列表 * * @param bo 查询条件 * @param pageQuery 分页参数 * @return 备件出入库分页列表 */ @Override public TableDataInfo queryPageList(EimsSpareInoutBo bo, PageQuery pageQuery) { LambdaQueryWrapper lqw = buildQueryWrapper(bo); Page result = baseMapper.selectVoPage(pageQuery.build(), lqw); return TableDataInfo.build(result); } /** * 查询符合条件的备件出入库列表 * * @param bo 查询条件 * @return 备件出入库列表 */ @Override public List queryList(EimsSpareInoutBo bo) { LambdaQueryWrapper lqw = buildQueryWrapper(bo); return baseMapper.selectVoList(lqw); } private LambdaQueryWrapper buildQueryWrapper(EimsSpareInoutBo bo) { Map params = bo.getParams(); LambdaQueryWrapper lqw = Wrappers.lambdaQuery(); lqw.like(StringUtils.isNotBlank(bo.getOrderCode()), EimsSpareInout::getOrderCode, bo.getOrderCode()); lqw.between(params.get("beginOrderTime") != null && params.get("endOrderTime") != null, EimsSpareInout::getOrderTime ,params.get("beginOrderTime"), params.get("endOrderTime")); lqw.eq(bo.getChargeUser() != null, EimsSpareInout::getChargeUser, bo.getChargeUser()); lqw.eq(StringUtils.isNotBlank(bo.getType()), EimsSpareInout::getType, bo.getType()); lqw.like(StringUtils.isNotBlank(bo.getPartnerName()), EimsSpareInout::getPartnerName, bo.getPartnerName()); lqw.eq(StringUtils.isNotBlank(bo.getAssociatedOrder()), EimsSpareInout::getAssociatedOrder, bo.getAssociatedOrder()); return lqw; } /** * 新增备件出入库 * * @param bo 备件出入库 * @return 是否新增成功 */ @Transactional(rollbackFor = Exception.class) @Override public synchronized Boolean insertByBo(EimsSpareInoutBo bo) { EimsSpareInout add = MapstructUtils.convert(bo, EimsSpareInout.class); validEntityBeforeSave(add); boolean flag = baseMapper.insert(add) > 0; if (flag) { bo.setId(add.getId()); } //入库＋库存 出库-库存 （默认入库） int OperationType; //出库 if(bo.getType().equals(DictConstants.SPARE_INOUT_TYPE_DETAIL.CK)){ OperationType = -1; } else { OperationType = 1; } List spareList = Optional.ofNullable(bo.getSpareList()).orElse(new ArrayList<>()); // 插入出库明细 List dtList = spareList.stream() .map(eimsSpareBo -> { EimsSpareInoutdt dt = new EimsSpareInoutdt(); dt.setInoutId(add.getId()); dt.setSpareId(eimsSpareBo.getId()); dt.setBeforeStock(eimsSpareBo.getActualStock()); // 注意入库出库 dt.setActualStock(eimsSpareBo.getActualStock() + (eimsSpareBo.getQuantity() * OperationType)); dt.setQuantity(eimsSpareBo.getQuantity()); // 设置单价和金额 Optional.ofNullable(eimsSpareBo.getReferPrice()).ifPresent(referPrice -> { dt.setUnitPrice(referPrice); dt.setAmount(referPrice.multiply(BigDecimal.valueOf(eimsSpareBo.getQuantity()))); }); return dt; }) .toList(); // 批量插入数据 if (!dtList.isEmpty()) { inoutdtMapper.insertBatch(dtList); } // 更新备件的库存 List updateSpareList = spareList.stream().map(spareBo -> { EimsSpare spare = new EimsSpare(); spare.setId(spareBo.getId()); spare.setActualStock(spareBo.getActualStock() + (spareBo.getQuantity() * OperationType)); // 设置单价和金额 Optional.ofNullable(spareBo.getReferPrice()).ifPresent(referPrice -> { spare.setStockAmount(referPrice.multiply(BigDecimal.valueOf(spare.getActualStock()))); }); return spare; }).toList(); if (!updateSpareList.isEmpty()) { spareMapper.updateBatchById(updateSpareList); } return flag; } /** * 修改备件出入库 * * @param bo 备件出入库 * @return 是否修改成功 */ @Override public Boolean updateByBo(EimsSpareInoutBo bo) { EimsSpareInout update = MapstructUtils.convert(bo, EimsSpareInout.class); validEntityBeforeSave(update); return baseMapper.updateById(update) > 0; } /** * 保存前的数据校验 */ private void validEntityBeforeSave(EimsSpareInout entity){ //TODO 做一些数据校验,如唯一约束 } /** * 校验并批量删除备件出入库信息 * * @param ids 待删除的主键集合 * @param isValid 是否进行有效性校验 * @return 是否删除成功 */ @Override public Boolean deleteWithValidByIds(Collection ids, Boolean isValid) { if(isValid){ //TODO 做一些业务上的校验,判断是否需要校验 } return baseMapper.deleteByIds(ids) > 0; } }