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;
    }
}