DO单excel导入功能 任务工作档优化

skyouc

3 天以前 5074c51d978a490a1d0e9dc116a874d33ddeb16c

 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/DeliveryItemServiceImpl.java

@@ -10,10 +10,7 @@
import com.vincent.rsf.server.manager.entity.*;
import com.vincent.rsf.server.manager.entity.excel.AsnOrderTemplate;
import com.vincent.rsf.server.manager.entity.excel.DeliveryTemplate;
import com.vincent.rsf.server.manager.enums.CompanysType;
import com.vincent.rsf.server.manager.enums.OrderType;
import com.vincent.rsf.server.manager.enums.OrderWorkType;
import com.vincent.rsf.server.manager.enums.QlyIsptResult;
import com.vincent.rsf.server.manager.enums.*;
import com.vincent.rsf.server.manager.mapper.DeliveryItemMapper;
import com.vincent.rsf.server.manager.service.CompanysService;
import com.vincent.rsf.server.manager.service.DeliveryItemService;
@@ -44,7 +41,6 @@
    @Autowired
    private DeliveryItemService deliveryItemService;

//    private
    /**
     * excel DO单导入
     *
@@ -53,130 +49,114 @@
     * @param loginUserId
     * @return
     */
//    @Override
//    public R excelImport(MultipartFile file, Map<String, Object> hashMap, Long loginUserId) throws Exception {
//        ExcelImportResult result = ExcelImportUtil.importExcelMore(file.getInputStream(), DeliveryTemplate.class, ExcelUtil.getDefaultImportParams());
//        if (result.getList().isEmpty()) {
//            throw new CoolException("表格内容不能为空！！");
//        }
//        List<DeliveryTemplate> resultList = result.getList();
//        Map<String, List<DeliveryTemplate>> listMap = resultList.stream().collect(Collectors.groupingBy(DeliveryTemplate::getDoCode));
//        StringBuffer sbFaild = new StringBuffer();
//        for (String key : listMap.keySet()) {
//            if (StringUtils.isBlank(key)) {
//                throw new CoolException("单号不能为空！！");
//            }
//            DeliveryTemplate template = listMap.get(key).stream().findFirst().get();
//            Delivery order = deliveryService.getOne(new LambdaQueryWrapper<Delivery>().eq(Delivery::getCode, key));
//            if (!Objects.isNull(order)) {
//                sbFaild.append(template.getDoCode()).append(",已添加！！");
//                throw new CoolException(sbFaild.toString());
//            }
//            order = new Delivery();
//            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
//            Date date = dateFormat.parse(template.getArrTime());
//            if (Objects.isNull(date)) {
//                throw new CoolException("时间格式错误！！");
//            }
//            if (Objects.isNull((OrderType.getTypeVal(template.getType())))) {
//                sbFaild.append(template.getDoCode()).append(",单据状态不存在！！");
//                throw new CoolException(sbFaild.toString());
//            }
//            if (Objects.isNull((OrderWorkType.getWorkType(template.getWkType())))) {
//                sbFaild.append(template.getDoCode()).append(",业务状态不存在！！");
//                throw new CoolException(sbFaild.toString());
//            }
//
//            order.setCode(template.getDoCode())
//                    .setPoCode(template.getPoCode())
//                    .setMemo(template.getMemo())
//                    .setArrTime(date)
//                    .setUpdateBy(loginUserId)
//                    .setLogisNo(template.getLogicNo())
//                    .setCreateBy(loginUserId)
//                    .setType(OrderType.getTypeVal(template.getType()))
//                    .setWkType(OrderWorkType.getWorkType(template.getWkType()));
//            if (!deliveryService.save(order)) {
//                throw new CoolException("单据保存失败！！");
//            }
//            List<DeliveryItem> items = new ArrayList<>();
//            for (DeliveryTemplate orderTemplate : listMap.get(key)) {
//                DeliveryItem orderItem = new DeliveryItem();
//                if (StringUtils.isBlank(orderTemplate.getMatnrCode())) {
//                    throw new CoolException(orderTemplate.getDoCode() + "：物料编码不能为空！！");
//                }
//                if (StringUtils.isBlank(orderTemplate.getAnfme())) {
//                    throw new CoolException(orderTemplate.getDoCode() + "：数量不能为空！！");
//                }
//                if (StringUtils.isBlank(orderTemplate.getType())) {
//                    throw new CoolException(orderTemplate.getDoCode() + "：单据类型不能为空！！");
//                }
//                if (StringUtils.isBlank(orderTemplate.getWkType())) {
//                    throw new CoolException(orderTemplate.getDoCode() + "：业务类型不能为空！！");
//                }
//
//                Matnr matnr = matnrService.getOne(new LambdaQueryWrapper<Matnr>()
//                        .eq(Matnr::getCode, orderTemplate.getMatnrCode()));
//                if (Objects.isNull(matnr)) {
//                    sbFaild.append(orderTemplate.getMatnrCode()).append("物料不存在");
//                    throw new CoolException(sbFaild.toString());
//                }
//                String trackCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_LABEL_CODE, matnr);
//                orderItem.setDeliveryId(order.getId())
//                        .setDeliveryCode(order.getCode())
//                        .setSplrBatch(orderTemplate.getSplrBatch())
//                        .setPlatItemId(orderTemplate.getPlatItemId())
//                        .setAnfme(Double.parseDouble(orderTemplate.getAnfme()))
//                        .setIsptResult(QlyIsptResult.getDescVal(orderTemplate.getIsptResult()))
////                        .setTrackCode(trackCode)
//                        .setBarcode(trackCode)
//                        .setPlatOrderCode(orderTemplate.getPlatOrderCode())
//                        .setPlatWorkCode(orderTemplate.getPlatWorkCode())
//                        .setProjectCode(orderTemplate.getProjectCode())
//                        .setPoCode(orderTemplate.getDoCode())
//                        .setPurUnit(matnr.getUnit())
//                        .setCreateBy(loginUserId)
//                        .setUpdateBy(loginUserId)
//                        .setSpec(matnr.getSpec())
//                        .setModel(matnr.getModel())
//                        .setMaktx(matnr.getName())
//                        .setMatnrCode(matnr.getCode())
//                        .setMatnrId(matnr.getId())
//                        .setStockUnit(matnr.getUnit());
//                if (!Objects.isNull(orderTemplate.getSplrCode())) {
//                    Companys companys = companysService.getOne(new LambdaQueryWrapper<Companys>()
//                            .eq(Companys::getType, CompanysType.COMPANYS_TYPE_SUPPLIER.val)
//                            .eq(Companys::getCode, orderTemplate.getSplrCode()));
//                    if (!Objects.isNull(companys)) {
//                        orderItem.setSplrCode(companys.getCode()).setSplrName(companys.getName());
//                    } else {
//                        sbFaild.append("供应商:" + orderTemplate.getSplrCode()).append("不存在");
//                        throw new CoolException(sbFaild.toString());
//                    }
//                } else {
//                    continue;
//                }
//                items.add(orderItem);
//
//                if (!deliveryItemService.save(orderItem)) {
//                    throw new CoolException("单据明细保存失败！！");
//                }
//            }
//            if (!items.isEmpty()) {
////                double qty = items.stream().mapToDouble(AsnOrderItem::getQty).sum();
//                double anfme = items.stream().mapToDouble(DeliveryItem::getAnfme).sum();
//                if (!deliveryService.update(new LambdaUpdateWrapper<Delivery>()
////                        .set(AsnOrder::getQty, qty)
//                        .set(Delivery::getAnfme, anfme)
//                        .eq(Delivery::getId, order.getId()))) {
//                    throw new CoolException("单据数量修改失败！！");
//                }
//            }
//
//
//        }
//
//
//        return null;
//    }
    @Override
    public R excelImport(MultipartFile file, Map<String, Object> hashMap, Long loginUserId) throws Exception {
        ExcelImportResult result = ExcelImportUtil.importExcelMore(file.getInputStream(), DeliveryTemplate.class, ExcelUtil.getDefaultImportParams());
        if (result.getList().isEmpty()) {
            throw new CoolException("表格内容不能为空！！");
        }
        List<DeliveryTemplate> resultList = result.getList();
        Map<String, List<DeliveryTemplate>> listMap = resultList.stream().collect(Collectors.groupingBy(DeliveryTemplate::getDoCode));
        StringBuffer sbFaild = new StringBuffer();
        for (String key : listMap.keySet()) {
            if (StringUtils.isBlank(key)) {
                throw new CoolException("单号不能为空！！");
            }
            DeliveryTemplate template = listMap.get(key).stream().findFirst().get();
            Delivery order = deliveryService.getOne(new LambdaQueryWrapper<Delivery>().eq(Delivery::getCode, key));
            if (!Objects.isNull(order)) {
                sbFaild.append(template.getDoCode()).append(",已添加！！");
                throw new CoolException(sbFaild.toString());
            }
            order = new Delivery();
            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
            Date date = dateFormat.parse(template.getArrTime());
            if (Objects.isNull(date)) {
                throw new CoolException("时间格式错误！！");
            }
            if (Objects.isNull((OrderType.getTypeVal(template.getType())))) {
                sbFaild.append(template.getDoCode()).append(",单据状态不存在！！");
                throw new CoolException(sbFaild.toString());
            }
            if (Objects.isNull((OrderWorkType.getWorkType(template.getWkType())))) {
                sbFaild.append(template.getDoCode()).append(",业务状态不存在！！");
                throw new CoolException(sbFaild.toString());
            }

            order.setCode(template.getDoCode())
                    .setType(OrderType.getTypeVal(template.getType()))
                    .setWkType(OrderWorkType.getWorkType(template.getWkType()))
                    .setMemo(template.getMemo())
                    .setSource(OrderSourceType.ORDER_SOURCE_TYPE_ERP.desc)
                    .setAnfme(Double.parseDouble(template.getAnfme()))
                    .setUpdateBy(loginUserId)
                    .setCreateBy(loginUserId);
            if (!deliveryService.save(order)) {
                throw new CoolException("单据保存失败！！");
            }
            List<DeliveryItem> items = new ArrayList<>();
            for (DeliveryTemplate orderTemplate : listMap.get(key)) {
                DeliveryItem orderItem = new DeliveryItem();
                if (StringUtils.isBlank(orderTemplate.getMatnrCode())) {
                    throw new CoolException(orderTemplate.getDoCode() + "：物料编码不能为空！！");
                }
                if (StringUtils.isBlank(orderTemplate.getAnfme())) {
                    throw new CoolException(orderTemplate.getDoCode() + "：数量不能为空！！");
                }
                if (StringUtils.isBlank(orderTemplate.getType())) {
                    throw new CoolException(orderTemplate.getDoCode() + "：单据类型不能为空！！");
                }
                if (StringUtils.isBlank(orderTemplate.getWkType())) {
                    throw new CoolException(orderTemplate.getDoCode() + "：业务类型不能为空！！");
                }

                Matnr matnr = matnrService.getOne(new LambdaQueryWrapper<Matnr>()
                        .eq(Matnr::getCode, orderTemplate.getMatnrCode()));
                if (Objects.isNull(matnr)) {
                    sbFaild.append(orderTemplate.getMatnrCode()).append("物料不存在");
                    throw new CoolException(sbFaild.toString());
                }
                orderItem.setDeliveryId(order.getId())
                        .setDeliveryCode(order.getCode())
                        .setSplrBatch(orderTemplate.getSplrBatch())
                        .setPlatItemId(orderTemplate.getPlatItemId())
                        .setAnfme(Double.parseDouble(orderTemplate.getAnfme()))
                        .setUnit(matnr.getUnit())
                        .setCreateBy(loginUserId)
                        .setUpdateBy(loginUserId)
                        .setSplrBatch(orderTemplate.getSplrBatch())
                        .setMaktx(matnr.getName())
                        .setMatnrCode(matnr.getCode())
                        .setMatnrId(matnr.getId());
                if (!Objects.isNull(orderTemplate.getSplrCode())) {
                    Companys companys = companysService.getOne(new LambdaQueryWrapper<Companys>()
                            .eq(Companys::getType, CompanysType.COMPANYS_TYPE_SUPPLIER.val)
                            .eq(Companys::getCode, orderTemplate.getSplrCode()));
                    if (!Objects.isNull(companys)) {
                        orderItem.setSplrCode(companys.getCode()).setSplrName(companys.getName());
                    } else {
                        sbFaild.append("供应商:" + orderTemplate.getSplrCode()).append("不存在");
                        throw new CoolException(sbFaild.toString());
                    }
                } else {
                    continue;
                }
                items.add(orderItem);

                if (!deliveryItemService.save(orderItem)) {
                    throw new CoolException("单据明细保存失败！！");
                }
            }
            if (!items.isEmpty()) {
                Double anfme = items.stream().mapToDouble(DeliveryItem::getAnfme).sum();
                if (!deliveryService.update(new LambdaUpdateWrapper<Delivery>()
                        .set(Delivery::getAnfme, anfme)
                        .eq(Delivery::getId, order.getId()))) {
                    throw new CoolException("单据数量修改失败！！");
                }
            }
        }

        return null;
    }
}