package com.aps.core.service.impl;

import java.io.IOException;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.List;
import com.aps.common.core.utils.DateUtils;
import com.aps.common.core.utils.StringUtils;
import com.aps.common.security.utils.SecurityUtils;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.apache.poi.ss.usermodel.WorkbookFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.aps.core.mapper.ApsGasMaterialUsageMapper;
import com.aps.core.domain.ApsGasMaterialUsage;
import com.aps.core.service.IApsGasMaterialUsageService;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

/**
 * 气柜管路物料用量Service业务层处理
 * 
 * @author zhl
 * @date 2025-04-25
 */
@Service
public class ApsGasMaterialUsageServiceImpl implements IApsGasMaterialUsageService 
{
    @Autowired
    private ApsGasMaterialUsageMapper apsGasMaterialUsageMapper;

    /**
     * 查询气柜管路物料用量
     * 
     * @param id 气柜管路物料用量主键
     * @return 气柜管路物料用量
     */
    @Override
    public ApsGasMaterialUsage selectApsGasMaterialUsageById(Long id)
    {
        return apsGasMaterialUsageMapper.selectApsGasMaterialUsageById(id);
    }

    /**
     * 查询气柜管路物料用量列表
     * 
     * @param apsGasMaterialUsage 气柜管路物料用量
     * @return 气柜管路物料用量
     */
    @Override
    public List<ApsGasMaterialUsage> selectApsGasMaterialUsageList(ApsGasMaterialUsage apsGasMaterialUsage)
    {
        return apsGasMaterialUsageMapper.selectApsGasMaterialUsageList(apsGasMaterialUsage);
    }

    /**
     * 新增气柜管路物料用量
     * 
     * @param apsGasMaterialUsage 气柜管路物料用量
     * @return 结果
     */
    @Override
    public int insertApsGasMaterialUsage(ApsGasMaterialUsage apsGasMaterialUsage)
    {
        apsGasMaterialUsage.setCreateTime(DateUtils.getNowDate());
        return apsGasMaterialUsageMapper.insertApsGasMaterialUsage(apsGasMaterialUsage);
    }

    /**
     * 修改气柜管路物料用量
     * 
     * @param apsGasMaterialUsage 气柜管路物料用量
     * @return 结果
     */
    @Override
    public int updateApsGasMaterialUsage(ApsGasMaterialUsage apsGasMaterialUsage)
    {
        return apsGasMaterialUsageMapper.updateApsGasMaterialUsage(apsGasMaterialUsage);
    }

    /**
     * 批量删除气柜管路物料用量
     * 
     * @param ids 需要删除的气柜管路物料用量主键
     * @return 结果
     */
    @Override
    public int deleteApsGasMaterialUsageByIds(Long[] ids)
    {
        return apsGasMaterialUsageMapper.deleteApsGasMaterialUsageByIds(ids);
    }

    /**
     * 删除气柜管路物料用量信息
     * 
     * @param id 气柜管路物料用量主键
     * @return 结果
     */
    @Override
    public int deleteApsGasMaterialUsageById(Long id)
    {
        return apsGasMaterialUsageMapper.deleteApsGasMaterialUsageById(id);
    }

    @Transactional
    @Override
    public int batchInsertGasMaterialUsage(MultipartFile file) {
        ArrayList<ApsGasMaterialUsage> list = new ArrayList<>();

        Workbook workbook = null;
        try {
            workbook = WorkbookFactory.create(file.getInputStream());
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
        Sheet sheet =workbook.getSheetAt(0);
        int rows = sheet.getLastRowNum();
        if (rows > 0)
        {
            /*从表头中取出工序名称*/
            Hashtable<Integer,String> processTitle=new Hashtable<>();
            Row titleRow = sheet.getRow(0);
            short lastTitleNum = titleRow.getLastCellNum();
            for (int i = 4; i < lastTitleNum; i++) {
                processTitle.put(i,titleRow.getCell(i).getStringCellValue());
            }
            /*数据列从1开始*/
            for (int i =  1; i <= rows; i++)
            {
                Row row = sheet.getRow(i);
                String itemNumber = row.getCell(0).getStringCellValue();
                String drawingNo = row.getCell(1).getStringCellValue();
                String version = row.getCell(2).getStringCellValue();
                for (int j = 4; j < lastTitleNum; j++){
                    String processName = processTitle.get(j);
                    double standardAmount = row.getCell(j).getNumericCellValue();
                    ApsGasMaterialUsage apsGasMaterialUsage = new ApsGasMaterialUsage();
                    apsGasMaterialUsage.setItemNumber(itemNumber);
                    apsGasMaterialUsage.setDrawingNo(drawingNo);
                    apsGasMaterialUsage.setVersion(version);
                    apsGasMaterialUsage.setProcessName(processName);
                    apsGasMaterialUsage.setStandardAmount(BigDecimal.valueOf(standardAmount));
                    apsGasMaterialUsage.setDelFlag("0");
                    apsGasMaterialUsage.setCreateBy(SecurityUtils.getUsername());
                    apsGasMaterialUsage.setCreateTime(DateUtils.getNowDate());
                    list.add(apsGasMaterialUsage);
                }
            }
        }
        int batchSize = 1000;
        int totalInserted = 0;
        apsGasMaterialUsageMapper.batchDeleteGasMaterialUsage();
        for (int i = 0; i < list.size(); i += batchSize) {
            int end = Math.min(i + batchSize, list.size());
            List<ApsGasMaterialUsage> subList = list.subList(i, end);
            // 设置创建时间 登录人
            for (ApsGasMaterialUsage item : subList) {
                item.setCreateBy(SecurityUtils.getUsername());
                item.setCreateTime(DateUtils.getNowDate());
            }
            totalInserted += apsGasMaterialUsageMapper.batchInsertGasMaterialUsage(subList);
        }
        return totalInserted;
    }
}