package com.ruoyi.production.service.impl;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.basic.pojo.BaseParam;
import com.ruoyi.basic.service.BaseParamService;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.production.dto.ProcessRouteItemParamDto;
import com.ruoyi.production.mapper.ProcessRouteItemParamMapper;
import com.ruoyi.production.pojo.ProcessRouteItemParam;
import com.ruoyi.production.service.ProcessRouteItemParamService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.time.LocalDateTime;

/**
 * <br>
 * 工艺路线工序参数实例 ServiceImpl
 * </br>
 *
 * @author deslrey
 * @version 1.0
 * @since 2026/03/16 11:11
 */
@Slf4j
@Service
public class ProcessRouteItemParamServiceImpl extends ServiceImpl<ProcessRouteItemParamMapper, ProcessRouteItemParam> implements ProcessRouteItemParamService {

    @Autowired
    private BaseParamService baseParamService;

    @Override
    public IPage<ProcessRouteItemParamDto> pageList(Page<ProcessRouteItemParam> page, ProcessRouteItemParam param) {
        return baseMapper.selectParamPage(page, param);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean initParams(Long routeItemId, Long processId) {
        Long tenantId = SecurityUtils.getLoginUser().getTenantId();
        if (tenantId == null) {
            tenantId = 208L;
        }

        return baseMapper.insertFromProcessTemplate(routeItemId, processId, tenantId) > 0;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void saveParam(ProcessRouteItemParam param) {
        if (param == null) {
            throw new ServiceException("新增失败,参数不能为空");
        }
        if (param.getRouteItemId() == null || param.getParamId() == null) {
            throw new ServiceException("关联工序ID和参数项ID不能为空");
        }

        Long tenantId = SecurityUtils.getLoginUser().getTenantId();
        Long count = baseMapper.selectCount(Wrappers.<ProcessRouteItemParam>lambdaQuery()
                .eq(ProcessRouteItemParam::getRouteItemId, param.getRouteItemId())
                .eq(ProcessRouteItemParam::getParamId, param.getParamId())
                .eq(ProcessRouteItemParam::getTenantId, tenantId));
        if (count > 0) {
            throw new ServiceException("该工序已存在此参数项，请勿重复添加");
        }

        BaseParam baseParam = baseParamService.getById(param.getParamId());
        if (baseParam == null) {
            throw new ServiceException("新增失败,改基础参数不存在");
        }

        Integer maxSort = baseMapper.selectMaxSortByRouteItemId(param.getRouteItemId());
        param.setId(null);
        param.setProcessParamId(null);
        param.setSort(maxSort);
        param.setCreateTime(LocalDateTime.now());
        param.setTenantId(tenantId);

        this.save(param);
    }
}