package com.vincent.rsf.server.manager.service.impl; import cn.afterturn.easypoi.excel.ExcelImportUtil; import cn.afterturn.easypoi.excel.entity.result.ExcelImportResult; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.vincent.rsf.framework.common.R; import com.vincent.rsf.framework.exception.CoolException; import com.vincent.rsf.server.common.utils.ExcelUtil; import com.vincent.rsf.server.manager.entity.AsnOrder; import com.vincent.rsf.server.manager.entity.excel.AsnOrderTemplate; import com.vincent.rsf.server.manager.entity.excel.MatnrsTemplate; import com.vincent.rsf.server.manager.mapper.AsnOrderItemMapper; import com.vincent.rsf.server.manager.entity.AsnOrderItem; import com.vincent.rsf.server.manager.mapper.AsnOrderMapper; import com.vincent.rsf.server.manager.service.AsnOrderItemService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.multipart.MultipartFile; import javax.annotation.Resource; import java.io.IOException; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Objects; @Service("asnOrderItemService") public class AsnOrderItemServiceImpl extends ServiceImpl implements AsnOrderItemService { @Resource private AsnOrderMapper asnOrderMapper; @Override @Transactional(rollbackFor = Exception.class) public R excelImport(MultipartFile file, HashMap hashMap) throws Exception { ExcelImportResult result = ExcelImportUtil.importExcelMore(file.getInputStream(), MatnrsTemplate.class, ExcelUtil.getDefaultImportParams()); if (result.getList().isEmpty()) { throw new CoolException("物料导入失败!!"); } if (!Objects.isNull(hashMap.get("asnId"))) { throw new CoolException("主单ID为空,无法操作!!"); } AsnOrder order = asnOrderMapper.selectOne(new LambdaQueryWrapper().eq(AsnOrder::getId, hashMap.get("asnId"))); if (Objects.isNull(order)) { throw new CoolException("ASN单据不存在!!"); } List itemList = new ArrayList<>(); result.getList().forEach(template -> { AsnOrderItem orderItem = new AsnOrderItem(); BeanUtils.copyProperties(template, orderItem); orderItem.setAsnId(order.getId()) .setAsnCode(order.getCode()); itemList.add(orderItem); }); if (!this.saveBatch(itemList)) { throw new CoolException("保存失败!!"); } return R.ok("操作成功!!"); } }