package com.ruoyi.aftersalesservice.service.impl;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.aftersalesservice.dto.AfterSalesNearExpiryImportDto;
import com.ruoyi.aftersalesservice.mapper.AfterSalesNearExpiryMapper;
import com.ruoyi.aftersalesservice.pojo.AfterSalesNearExpiry;
import com.ruoyi.aftersalesservice.service.AfterSalesNearExpiryService;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.poi.ExcelUtil;
import com.ruoyi.framework.web.domain.AjaxResult;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import org.springframework.web.multipart.MultipartFile;

import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

/**
 * <br>
 * 临期售后管理接口实现类
 * </br>
 *
 * @author deslrey
 * @version 1.0
 * @since 2026/03/02 14:46
 */
@Slf4j
@Service
public class AfterSalesNearExpiryServiceImpl extends ServiceImpl<AfterSalesNearExpiryMapper, AfterSalesNearExpiry> implements AfterSalesNearExpiryService {

    @Override
    public void add(AfterSalesNearExpiry entity) {
        if (entity == null) {
            throw new ServiceException("添加失败，数据不能为空");
        }
        if (entity.getProductName() == null || entity.getProductName().trim().isEmpty()) {
            throw new ServiceException("产品名称不能为空");
        }
        if (entity.getBatchNumber() == null || entity.getBatchNumber().trim().isEmpty()) {
            throw new ServiceException("产品批号不能为空");
        }
        if (entity.getExpireDate() == null) {
            throw new ServiceException("临期日期不能为空");
        }

        entity.setId(null);
        entity.setStatus(1);
        entity.setDisposeUserId(null);
        entity.setDisposeNickName(null);
        entity.setDisDate(null);
        entity.setCreateTime(LocalDateTime.now());
        entity.setCreateUser(SecurityUtils.getLoginUser().getUserId());
        entity.setUpdateUser(null);
        entity.setUpdateTime(null);
        entity.setTenantId(SecurityUtils.getLoginUser().getTenantId());

        int result = baseMapper.insert(entity);
        if (result <= 0) {
            throw new ServiceException("新增失败");
        }
    }

    @Override
    public void update(AfterSalesNearExpiry entity) {
        if (entity == null || entity.getId() == null) {
            throw new ServiceException("更新失败，数据不完整");
        }
        entity.setStatus(2);
        entity.setUpdateUser(SecurityUtils.getLoginUser().getUserId());
        entity.setUpdateTime(LocalDateTime.now());
        int result = baseMapper.updateById(entity);
        if (result <= 0) {
            throw new ServiceException("更新失败");
        }
    }

    @Override
    public void delete(Long[] ids) {
        if (ids == null || ids.length == 0) {
            throw new ServiceException("请选择要删除的数据");
        }
        int result = baseMapper.deleteBatchIds(Arrays.asList(ids));
        if (result <= 0) {
            throw new ServiceException("删除失败");
        }
    }

    @Override
    public IPage<AfterSalesNearExpiry> listPage(Page<AfterSalesNearExpiry> page, AfterSalesNearExpiry entity) {
        return baseMapper.listPage(page, entity);
    }

    @Override
    public AjaxResult importData(MultipartFile file) {
        List<AfterSalesNearExpiryImportDto> rows;
        try {
            ExcelUtil<AfterSalesNearExpiryImportDto> util = new ExcelUtil<>(AfterSalesNearExpiryImportDto.class);
            rows = util.importExcel(file.getInputStream());
        } catch (Exception e) {
            log.error("临期售后管理导入-解析excel失败", e);
            return AjaxResult.error("解析Excel失败：" + e.getMessage());
        }
        if (CollectionUtils.isEmpty(rows)) {
            return AjaxResult.error("导入文件无数据");
        }
        int success = 0;
        List<String> errors = new ArrayList<>();
        for (int i = 0; i < rows.size(); i++) {
            AfterSalesNearExpiryImportDto row = rows.get(i);
            int rowNo = i + 2; // 首行为表头
            try {
                if (StringUtils.isEmpty(trim(row.getProductName()))) {
                    errors.add("第" + rowNo + "行：临期产品名称为空");
                    continue;
                }
                if (StringUtils.isEmpty(trim(row.getBatchNumber()))) {
                    errors.add("第" + rowNo + "行：产品批号为空");
                    continue;
                }
                if (row.getExpireDate() == null) {
                    errors.add("第" + rowNo + "行：临期日期为空");
                    continue;
                }
                if (row.getStockQuantity() == null) {
                    errors.add("第" + rowNo + "行：库存数量为空");
                    continue;
                }
                if (StringUtils.isEmpty(trim(row.getCustomerName()))) {
                    errors.add("第" + rowNo + "行：客户名称为空");
                    continue;
                }

                AfterSalesNearExpiry entity = new AfterSalesNearExpiry();
                entity.setProductName(trim(row.getProductName()));
                entity.setBatchNumber(trim(row.getBatchNumber()));
                entity.setExpireDate(row.getExpireDate());
                entity.setStockQuantity(row.getStockQuantity());
                entity.setCustomerName(trim(row.getCustomerName()));
                entity.setContactPhone(trim(row.getContactPhone()));
                entity.setDisRes(row.getDisRes());

                add(entity);
                success++;
            } catch (Exception e) {
                log.error("临期售后管理导入第{}行失败", rowNo, e);
                errors.add("第" + rowNo + "行：" + e.getMessage());
            }
        }

        AjaxResult result = AjaxResult.success();
        result.put("totalCount", rows.size());
        result.put("successCount", success);
        result.put("failCount", rows.size() - success);
        result.put("errors", errors);
        result.put("msg", "导入完成：成功 " + success + " 条，失败 " + (rows.size() - success) + " 条");
        return result;
    }

    private String trim(String value) {
        return value == null ? null : value.trim();
    }
}