package cn.iocoder.yudao.module.mes.service.pro.process;

import cn.hutool.core.collection.CollUtil;
import cn.iocoder.yudao.module.mes.controller.admin.pro.process.vo.param.MesProProcessParamSaveReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.process.MesProProcessParamDO;
import cn.iocoder.yudao.module.mes.dal.mysql.pro.process.MesProProcessParamMapper;
import cn.iocoder.yudao.module.mes.service.pd.processparam.MesPdProcessParamService;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;

import java.util.ArrayList;
import java.util.Collection;
import java.util.List;

/**
 * MES 工序-工艺参数绑定 Service 实现类
 *
 * @author 超级管理员
 */
@Service
@Validated
public class MesProProcessParamServiceImpl implements MesProProcessParamService {

    @Resource
    private MesProProcessParamMapper processParamMapper;
    @Resource
    private MesProProcessService processService;
    @Resource
    private MesPdProcessParamService pdProcessParamService;

    @Override
    public List<MesProProcessParamDO> getProcessParamListByProcessId(Long processId) {
        return processParamMapper.selectListByProcessId(processId);
    }

    @Override
    public List<MesProProcessParamDO> getProcessParamListByProcessIds(Collection<Long> processIds) {
        if (CollUtil.isEmpty(processIds)) {
            return new ArrayList<>();
        }
        return processParamMapper.selectListByProcessIds(processIds);
    }

    @Override
    public List<MesProProcessParamDO> getProcessParamListByParamId(Long processParamId) {
        return processParamMapper.selectListByProcessParamId(processParamId);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateProcessParams(Long processId, List<MesProProcessParamSaveReqVO.Item> items) {
        // 1. 校验工序存在
        processService.validateProcessExists(processId);
        // 2. 校验工艺参数存在
        if (CollUtil.isNotEmpty(items)) {
            for (MesProProcessParamSaveReqVO.Item item : items) {
                pdProcessParamService.validateProcessParamExists(item.getProcessParamId());
            }
        }
        // 3. 全量覆盖：先删旧绑定，再插入新绑定
        processParamMapper.deleteByProcessId(processId);
        if (CollUtil.isEmpty(items)) {
            return;
        }
        List<MesProProcessParamDO> list = new ArrayList<>(items.size());
        for (int i = 0; i < items.size(); i++) {
            MesProProcessParamSaveReqVO.Item item = items.get(i);
            list.add(MesProProcessParamDO.builder()
                    .processId(processId)
                    .processParamId(item.getProcessParamId())
                    .required(Boolean.TRUE.equals(item.getRequired()))
                    .sort(item.getSort() != null ? item.getSort() : i + 1)
                    .remark(item.getRemark())
                    .build());
        }
        processParamMapper.insertBatch(list);
    }

    @Override
    public void deleteByParamId(Long processParamId) {
        processParamMapper.deleteByProcessParamId(processParamId);
    }

}