package com.ruoyi.measuringinstrumentledger.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.common.exception.ServiceException;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.measuringinstrumentledger.dto.SparePartsUseDto;
import com.ruoyi.measuringinstrumentledger.mapper.SparePartsMapper;
import com.ruoyi.measuringinstrumentledger.mapper.SparePartsRequisitionRecordMapper;
import com.ruoyi.measuringinstrumentledger.pojo.SpareParts;
import com.ruoyi.measuringinstrumentledger.pojo.SparePartsRequisitionRecord;
import com.ruoyi.measuringinstrumentledger.service.SparePartsRequisitionRecordService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.List;

@Service
public class SparePartsRequisitionRecordServiceImpl
        extends ServiceImpl<SparePartsRequisitionRecordMapper, SparePartsRequisitionRecord>
        implements SparePartsRequisitionRecordService {

    @Autowired
    private SparePartsRequisitionRecordMapper sparePartsRequisitionRecordMapper;

    @Autowired
    private SparePartsMapper sparePartsMapper;

    @Override
    public IPage<SparePartsRequisitionRecord> listPage(Page page, SparePartsRequisitionRecord query) {
        return sparePartsRequisitionRecordMapper.listPage(page, query);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void processSparePartsUse(Long deviceLedgerId, String deviceName, Long sourceId,
                                     Integer sourceType, String sourceText,
                                     List<SparePartsUseDto> useList) {
        if (useList == null || useList.isEmpty()) {
            return;
        }
        String operator = SecurityUtils.getLoginUser().getNickName();
        for (SparePartsUseDto useItem : useList) {
            if (useItem == null || useItem.getId() == null) {
                continue;
            }
            BigDecimal quantity = useItem.getQuantity();
            if (quantity == null || quantity.compareTo(BigDecimal.ZERO) <= 0) {
                throw new ServiceException("领用数量必须大于0");
            }
            SpareParts sparePart = sparePartsMapper.selectById(useItem.getId());
            if (sparePart == null) {
                throw new ServiceException("备件不存在");
            }
            if (sparePart.getQuantity() == null || sparePart.getQuantity().compareTo(quantity) < 0) {
                throw new ServiceException("备件[" + sparePart.getName() + "]库存不足");
            }
            sparePart.setQuantity(sparePart.getQuantity().subtract(quantity));
            sparePartsMapper.updateById(sparePart);

            SparePartsRequisitionRecord record = new SparePartsRequisitionRecord();
            record.setSparePartsId(sparePart.getId());
            record.setSparePartsName(sparePart.getName());
            record.setQuantity(quantity);
            record.setDeviceLedgerId(deviceLedgerId);
            record.setDeviceName(deviceName);
            record.setSourceId(sourceId);
            record.setSourceType(sourceType);
            record.setSourceText(StringUtils.isNotEmpty(sourceText) ? sourceText : (sourceType == 0 ? "维修" : "保养"));
            record.setOperator(operator);
            sparePartsRequisitionRecordMapper.insert(record);
        }
    }
}