package com.ruoyi.business.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
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.basic.entity.dto.SimpleStorageDto;
import com.ruoyi.basic.service.StorageBlobService;
import com.ruoyi.business.dto.DuePayableDto;
import com.ruoyi.business.entity.DuePayable;
import com.ruoyi.business.mapper.DuePayableMapper;
import com.ruoyi.business.service.DuePayableService;
import com.ruoyi.business.vo.DuePayableVo;
import com.ruoyi.business.vo.SearchDuePurchaseVo;
import com.ruoyi.common.utils.StringUtils;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;

/**
 * @author buhuazhen
 * @description 针对表【due_payable(应付款表)】的数据库操作Service实现
 * @createDate 2025-08-26 16:12:56
 */
@Service
@RequiredArgsConstructor
public class DuePayableServiceImpl extends ServiceImpl<DuePayableMapper, DuePayable>
        implements DuePayableService {
    private final StorageBlobService storageBlobService;
    private final DuePayableMapper duePayableMapper;

    @Getter
    @Value("${minio.default-bucket}")
    private String defaultBucket;

    @Override
    public int addDuePayable(DuePayableDto dto) {
        DuePayable duePayable = new DuePayable();
        duePayable.setPayableType(dto.getPayableType());
        duePayable.setAttachUpload(dto.getAttachUpload());
        duePayable.setPurchaseRegistrationId(dto.getPurchaseRegistrationId());
        duePayable.setPaymentAmount(new BigDecimal(dto.getPaymentAmount()));
        duePayable.setTicketNo(dto.getTicketNo());
        duePayable.setId(dto.getId());

        if (Objects.isNull(dto.getId())) {
            return duePayableMapper.insert(duePayable);
        }

        return duePayableMapper.updateById(duePayable);
    }

    @Override
    public IPage<DuePayableVo> selectPayableList(Page<DuePayable> page, SearchDuePurchaseVo vo) {
        LambdaQueryWrapper<DuePayable> queryWrapper = new LambdaQueryWrapper<>();
        // todo 搜索条件暂时不知道是什么🤷
        queryWrapper.orderByDesc(DuePayable::getCreateTime);

        Page<DuePayable> duePayablePage = duePayableMapper.selectPage(page, queryWrapper);
        /**
         * 查询出附件id 由于后续详细
         */
        Map<Long, List<Long>> attachMap = duePayablePage.getRecords().stream()
                .collect(Collectors.toMap(
                        DuePayable::getId,
                        it -> {
                            if (StringUtils.isNotBlank(it.getAttachUpload())) {
                                return Arrays.stream(it.getAttachUpload().split(","))
                                        .map(Long::parseLong)
                                        .collect(Collectors.toList());
                            } else {
                                return List.of();
                            }
                        }
                ));
        /**
         * 根据上面的ids 查询出具体信息
         */
        Map<Long,SimpleStorageDto> storageMap = storageBlobService.findStorageByIds(attachMap.values().stream().flatMap(List::stream).toList(), getDefaultBucket()).stream().collect(Collectors.toMap(SimpleStorageDto::getId,it->it));


        List<DuePayableVo> convertedList = duePayablePage.getRecords().stream().map(it -> {
            DuePayableVo dueVo = new DuePayableVo(it.getId(), it.getTicketNo(), it.getPurchaseRegistrationId(), it.getPayableType(), it.getPaymentAmount(),Long.parseLong(it.getCreateBy()),it.getCreateTime().toLocalDate());
            // 文件信息
            List<Long> storageIds = attachMap.get(it.getId());
            dueVo.setAttachFileList(
                    storageIds.stream()
                            .map(storageMap::get)   // O(1) 获取
                            .filter(Objects::nonNull)
                            .toList()
            );
            return dueVo;
        }).toList();

        IPage<DuePayableVo> voPage = new Page<>();
        voPage.setCurrent(duePayablePage.getCurrent());
        voPage.setSize(duePayablePage.getSize());
        voPage.setTotal(duePayablePage.getTotal());
        voPage.setRecords(convertedList);
        return voPage;
    }
}