package com.zy.asrs.utils;
|
|
import com.alibaba.excel.context.AnalysisContext;
|
import com.alibaba.excel.event.AnalysisEventListener;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.common.Cools;
|
import com.core.common.DateUtils;
|
import com.core.common.SpringUtils;
|
import com.core.exception.CoolException;
|
import com.zy.asrs.entity.*;
|
import com.zy.asrs.entity.param.StockOutParam;
|
import com.zy.asrs.service.LocDetlService;
|
import com.zy.asrs.service.LocMastService;
|
import com.zy.asrs.service.WorkService;
|
import com.zy.common.entity.OrderGiftProofreadingExcel;
|
import com.zy.common.model.DetlDto;
|
import com.zy.common.model.LocDto;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* Created by vincent on 2019-11-25
|
*/
|
@Slf4j
|
public class OrderGiftProofreadingExcelListener extends AnalysisEventListener<OrderGiftProofreadingExcel> {
|
|
private int total = 0;
|
private String orderOneNo = null;
|
private Long userId;
|
List<OrderGiftProofreadingExcel> OrderGiftProofreadingCs = new ArrayList<>();
|
|
public OrderGiftProofreadingExcelListener() {
|
}
|
|
public OrderGiftProofreadingExcelListener(Long userId) {
|
this.userId = userId;
|
}
|
|
/**
|
* 每隔5条存储数据库，实际使用中可以3000条，然后清理list ，方便内存回收
|
*/
|
private static final int BATCH_COUNT = 50;
|
|
private final List<OrderGiftProofreadingExcel> list = new ArrayList<>();
|
|
/**
|
* 这里会一行行的返回头
|
*/
|
@Override
|
public void invokeHeadMap(Map<Integer, String> headMap, AnalysisContext context) {
|
}
|
|
/**
|
* 这个每一条数据解析都会来调用
|
*/
|
@Override
|
public void invoke(OrderGiftProofreadingExcel excel, AnalysisContext ctx) {
|
if (Cools.isEmpty(orderOneNo)){
|
if (!Cools.isEmpty(excel.getOrderNo())){
|
orderOneNo = excel.getOrderNo();
|
} else {
|
throw new CoolException("订单号参数为空");
|
}
|
}
|
OrderGiftProofreadingCs.add(excel);
|
total++;
|
}
|
|
/**
|
* 所有数据解析完成了调用
|
* 适合事务
|
*/
|
@Override
|
public void doAfterAllAnalysed(AnalysisContext ctx) {
|
if (!Cools.isEmpty(OrderGiftProofreadingCs) && !OrderGiftProofreadingCs.isEmpty()) {
|
WorkService workService = SpringUtils.getBean(WorkService.class);
|
List<LocDto> locDtos = new ArrayList<>();
|
for (OrderGiftProofreadingExcel orderGiftProofreadingExcel:OrderGiftProofreadingCs){
|
LocDto locDto = new LocDto(orderGiftProofreadingExcel);
|
locDtos.add(locDto);
|
}
|
|
StockOutParam param = new StockOutParam();
|
ArrayList<StockOutParam.LocDetl> locDetls = new ArrayList<>();
|
List<LocDto> locDtosList = new ArrayList<>();
|
List<String> batchList = new ArrayList<>();
|
for (LocDto locDto : locDtos) {
|
if (!batchList.contains(locDto.getBatch())){
|
batchList.add(locDto.getBatch());
|
locDtosList.add(locDto);
|
}
|
}
|
for (LocDto locDto:locDtosList){
|
StockOutParam.LocDetl locDetl = new StockOutParam.LocDetl();
|
locDetl.setBrand(locDto.getBrand());
|
locDetl.setLocNo(locDto.getLocNo());
|
locDetl.setAnfme(locDto.getAnfme());
|
locDetl.setMatnr(locDto.getMatnr());
|
locDetl.setBatch(locDto.getBatch());
|
locDetl.setModel(locDto.getModel());
|
locDetl.setSpecs(locDto.getSpecs());
|
locDetl.setZpallet(locDto.getZpallet());
|
locDetl.setOrigin(locDto.getOrigin());
|
locDetl.setWeight(locDto.getWeight());
|
locDetl.setMemo(locDto.getMemo());
|
locDetl.setVolume(locDto.getVolume());
|
locDetl.setPrice(locDto.getPrice());
|
locDetls.add(locDetl);
|
}
|
param.setLocDetls(locDetls);
|
param.setOrderNo(orderOneNo);
|
if (total>0){
|
workService.startupFullTakeStoreOrderGift(param,9999L);
|
}
|
}
|
|
log.info("导入{}条核对单据明细！", total);
|
}
|
|
public int getTotal() {
|
return total;
|
}
|
}
|
