package com.zy.asrs.utils;

import com.alibaba.excel.context.AnalysisContext;
import com.alibaba.excel.event.AnalysisEventListener;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.SpringUtils;
import com.core.exception.CoolException;
import com.zy.asrs.entity.DocType;
import com.zy.asrs.entity.Mat;
import com.zy.asrs.entity.Order;
import com.zy.asrs.entity.OrderDetl;
import com.zy.asrs.service.DocTypeService;
import com.zy.asrs.service.MatService;
import com.zy.asrs.service.OrderDetlService;
import com.zy.asrs.service.OrderService;
import com.zy.common.entity.OrderExcel;
import lombok.extern.slf4j.Slf4j;

import java.util.*;

import org.springframework.transaction.annotation.Transactional;

@Slf4j
public class OrderExcelListener  extends AnalysisEventListener<OrderExcel> {

    private int total = 0;
    private Long userId;

    public OrderExcelListener(Long userId) {
        this.userId = userId;
    }

    /**
     * 每隔5条存储数据库，实际使用中可以3000条，然后清理list ，方便内存回收
     */
    private static final int BATCH_COUNT = 50;

    private final List<OrderExcel> list = new ArrayList<>();

    /**
     * 这里会一行行的返回头
     */
    @Override
    public void invokeHeadMap(Map<Integer, String> headMap, AnalysisContext context) {

    }

    /**
     * 单据导入实现
     * @author Ryan
     * @date 2026/1/8 17:25
     * @param data
     * @param context 
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void invoke(OrderExcel data, AnalysisContext context) {
        OrderService orderService = (OrderService) SpringUtils.getBean(OrderService.class);
        OrderDetlService detlService = (OrderDetlService) SpringUtils.getBean(OrderDetlService.class);
        MatService matService = SpringUtils.getBean(MatService.class);
        DocTypeService docTypeService = SpringUtils.getBean(DocTypeService.class);
        Date now = new Date();
        if (Objects.isNull(data)) {
            throw new CoolException("参数不能为空！！");
        }
        if (Objects.isNull(data.getOrderNo())) {
            throw new CoolException("订单已创建，不可以重复创建！！");
        }
        if (Objects.isNull(data.getDocType())) {
            throw new CoolException("单据类型不能为空！");
        }
        DocType docType = docTypeService.selectOne(new EntityWrapper<DocType>().eq("doc_name", data.getDocType()));
        if (Objects.isNull(docType)) {
            throw new CoolException("单据类型[" + data.getDocType() + "]不存在！！");
        }

        Order order = new Order();
        order.setOrderNo(data.getOrderNo());
        order.setDocType(docType.getDocId());
        order.setUuid(UUID.randomUUID().toString());
        order.setCreateTime(now);
        order.setUpdateTime(now);
        order.setSettle(1L);
        order.setStatus(1);
        order.setCreateBy(userId);
        order.setUpdateBy(userId);
        order.setPakinPakoutStatus(docType.getPakin() == 1 ? 1 : 2);    
        if (!orderService.insert(order)) {
            throw new CoolException("订单创建失败！！");
        }
        if (Objects.isNull(data.getMatnr())) {
            throw new CoolException("物料编码不能为空！");
        }
        Mat mat = matService.selectOne(new EntityWrapper<Mat>().eq("matnr", data.getMatnr()));
        if (Objects.isNull(mat)) {
            throw new CoolException("物料[" + data.getMatnr() + "]不存在！！");
        }
        OrderDetl detl = new OrderDetl();
        detl.setOrderNo(data.getOrderNo());
        detl.setOrderId(order.getId());
        detl.setMatnr(data.getMatnr());
        detl.setMaktx(mat.getMaktx());
        detl.setQty(data.getQty());
        detl.setBatch(data.getBatch());
        detl.setVolume(data.getVolume());
        detl.setSafeQty(mat.getSafeQty());
        detl.setAnfme(data.getAnfme());
        detl.setBarcode(data.getBarcode());
        detl.setUpdateTime(now);
        detl.setCreateTime(now);
        detl.setUpdateBy(userId);
        detl.setCreateBy(userId);
        if (!detlService.insert(detl)) {
            throw new CoolException("订单详情创建失败！！");
        }
        total ++ ;
    }

    @Override
    public void doAfterAllAnalysed(AnalysisContext context) {
        log.info("新增{}条物料信息！", total);
    }

    public int getTotal() {
        return total;
    }

}