package com.zy.asrs.common.utils;
|
|
import com.alibaba.excel.context.AnalysisContext;
|
import com.alibaba.excel.event.AnalysisEventListener;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.zy.asrs.common.domain.entity.MatExcel;
|
import com.zy.asrs.common.domain.entity.WaitPakinExcel;
|
import com.zy.asrs.common.wms.entity.Mat;
|
import com.zy.asrs.common.wms.entity.Tag;
|
import com.zy.asrs.common.wms.entity.WaitPakin;
|
import com.zy.asrs.common.wms.mapper.TagMapper;
|
import com.zy.asrs.common.wms.service.MatService;
|
import com.zy.asrs.common.wms.service.TagService;
|
import com.zy.asrs.common.wms.service.WaitPakinService;
|
import com.zy.asrs.framework.common.Cools;
|
import com.zy.asrs.framework.common.SpringUtils;
|
import com.zy.asrs.framework.exception.CoolException;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.BeanUtils;
|
|
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 WaitPakingExcelListener extends AnalysisEventListener<WaitPakinExcel> {
|
|
private int total = 0;
|
private Long userId;
|
private Long hostId;
|
|
public WaitPakingExcelListener() {
|
}
|
|
public WaitPakingExcelListener(Long userId, Long hostId) {
|
this.userId = userId;
|
this.hostId = hostId;
|
}
|
|
/**
|
* 每隔5条存储数据库，实际使用中可以3000条，然后清理list ，方便内存回收
|
*/
|
private static final int BATCH_COUNT = 50;
|
|
private final List<MatExcel> list = new ArrayList<>();
|
|
/**
|
* 这里会一行行的返回头
|
*/
|
@Override
|
public void invokeHeadMap(Map<Integer, String> headMap, AnalysisContext context) {
|
}
|
|
/**
|
* 这个每一条数据解析都会来调用
|
*/
|
@Override
|
public void invoke(WaitPakinExcel excel, AnalysisContext ctx) {
|
if(Cools.isEmpty(excel.getMatnr()) || Cools.isEmpty(excel.getAnfme()) || Cools.isEmpty(excel.getZpallet())){
|
throw new CoolException("缺少物料编码、数量、仓库、托盘码参数，无法组托");
|
}
|
|
MatService matService = SpringUtils.getBean(MatService.class);
|
WaitPakinService waitPakinService = SpringUtils.getBean(WaitPakinService.class);
|
|
LambdaQueryWrapper<WaitPakin> wrapper = new LambdaQueryWrapper<WaitPakin>()
|
.eq(WaitPakin::getMatnr, excel.getMatnr())
|
.eq(WaitPakin::getHostId, hostId)
|
.eq(WaitPakin::getZpallet, excel.getZpallet());
|
|
if(Cools.isEmpty(excel.getBatch())){
|
wrapper.isNull(WaitPakin::getBatch);
|
}else {
|
wrapper.eq(WaitPakin::getBatch, excel.getBatch());
|
}
|
|
WaitPakin waitPakinOld = waitPakinService.getOne(wrapper);
|
|
if(Cools.isEmpty(waitPakinOld)){
|
Mat mat = matService.getOne(new LambdaQueryWrapper<Mat>().eq(Mat::getMatnr, excel.getMatnr()).eq(Mat::getHostId, hostId));
|
WaitPakin waitPakin = new WaitPakin();
|
BeanUtils.copyProperties(mat,waitPakin);
|
waitPakin.setAnfme(excel.getAnfme());
|
waitPakin.setBatch(excel.getBatch());
|
waitPakin.setZpallet(excel.getZpallet());
|
waitPakin.setHostId(excel.getHostId());
|
waitPakin.setAppeTime(new Date());
|
waitPakin.setAppeUser(userId);
|
waitPakin.setModiTime(new Date());
|
waitPakin.setAppeUser(userId);
|
waitPakin.setHostId(hostId);
|
|
waitPakinService.save(waitPakin);
|
total ++;
|
|
}else {
|
waitPakinOld.setAnfme(waitPakinOld.getAnfme() + excel.getAnfme());
|
waitPakinOld.setModiTime(new Date());
|
waitPakinOld.setModiUser(userId);
|
|
waitPakinService.updateById(waitPakinOld);
|
total ++;
|
}
|
|
|
|
|
}
|
|
/**
|
* 所有数据解析完成了调用
|
* 适合事务
|
*/
|
@Override
|
public void doAfterAllAnalysed(AnalysisContext ctx) {
|
log.info("新增{}条物料信息！", total);
|
}
|
|
public int getTotal() {
|
return total;
|
}
|
}
|
