package cn.iocoder.yudao.module.mes.controller.admin.qc.attachment;

import cn.iocoder.yudao.framework.common.exception.ServiceException;
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
import cn.iocoder.yudao.framework.tenant.core.context.TenantContextHolder;
import cn.iocoder.yudao.module.mes.service.qc.iqc.MesQcIqcService;
import cn.iocoder.yudao.module.mes.service.qc.ipqc.MesQcIpqcService;
import cn.iocoder.yudao.module.mes.service.qc.oqc.MesQcOqcService;
import cn.iocoder.yudao.module.mes.service.qc.rqc.MesQcRqcService;
import cn.iocoder.yudao.module.system.api.storage.StorageAttachmentApi;
import cn.iocoder.yudao.module.system.api.storage.dto.StorageBlobRespDTO;
import jakarta.annotation.Resource;
import jakarta.validation.Valid;
import jakarta.validation.constraints.NotEmpty;
import jakarta.validation.constraints.NotNull;
import jakarta.validation.constraints.Pattern;
import jakarta.validation.constraints.Size;
import lombok.Data;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.List;
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;

/** 质检附件独立于检验结论，上传附件不自动将产品判为合格。 */
@RestController
@RequestMapping("/mes/qc/attachment")
@Validated
public class MesQcAttachmentController {
    @Resource private MesQcIqcService iqcService;
    @Resource private MesQcIpqcService ipqcService;
    @Resource private MesQcOqcService oqcService;
    @Resource private MesQcRqcService rqcService;
    @Resource private StorageAttachmentApi storageApi;
    @Resource private org.springframework.jdbc.core.JdbcTemplate jdbcTemplate;

    @GetMapping("/list")
    @PreAuthorize("@ss.hasPermission('mes:qc-' + #type.toLowerCase() + ':query')")
    public CommonResult<List<StorageBlobRespDTO>> list(
            @RequestParam @Pattern(regexp = "iqc|ipqc|oqc|rqc|patrol") String type,
            @RequestParam @NotNull Long id) {
        validateDocument(type, id);
        var files = storageApi.listAttachments(recordType(type), id);
        return success(files == null ? List.of() : files);
    }

    @PutMapping("/save")
    @PreAuthorize("@ss.hasPermission('mes:qc-' + #req.type.toLowerCase() + ':update')")
    @Transactional(rollbackFor = Exception.class)
    public CommonResult<Boolean> save(@Valid @RequestBody SaveReq req) {
        lockDocument(req.getType(), req.getId());
        validateDocument(req.getType(), req.getId());
        // bindAttachments 仅替换关联，不删除共享文件本体。
        storageApi.bindAttachments("file", recordType(req.getType()), req.getId(), req.getBlobIds().stream().distinct().toList());
        return success(true);
    }

    @PostMapping("/append")
    @PreAuthorize("@ss.hasPermission('mes:qc-' + #req.type.toLowerCase() + ':update')")
    @Transactional(rollbackFor = Exception.class)
    public CommonResult<Boolean> append(@Valid @RequestBody AppendReq req) {
        lockDocument(req.getType(), req.getId());
        validateDocument(req.getType(), req.getId());
        var existing = storageApi.listAttachments(recordType(req.getType()), req.getId());
        var ids = new java.util.LinkedHashSet<Long>();
        if (existing != null) existing.forEach(blob -> ids.add(blob.getId()));
        ids.add(req.getBlobId());
        if (ids.size() > 50) throw new ServiceException(400, "每张质检单最多上传50份附件");
        storageApi.bindAttachments("file", recordType(req.getType()), req.getId(), List.copyOf(ids));
        return success(true);
    }

    @DeleteMapping("/remove")
    @PreAuthorize("@ss.hasPermission('mes:qc-' + #type.toLowerCase() + ':update')")
    @Transactional(rollbackFor = Exception.class)
    public CommonResult<Boolean> remove(
            @RequestParam @Pattern(regexp = "iqc|ipqc|oqc|rqc|patrol") String type,
            @RequestParam @NotNull Long id, @RequestParam @NotNull Long blobId) {
        lockDocument(type, id);
        validateDocument(type, id);
        storageApi.removeReference("file", recordType(type), id, blobId);
        return success(true);
    }

    // ==================== 过程检验「检验行」附件 ====================

    /** 过程检验行附件：recordId 为检验结果明细 ID，每行独立上传 */
    @GetMapping("/ipqc-detail/list")
    @PreAuthorize("@ss.hasPermission('mes:qc-ipqc:query')")
    public CommonResult<List<StorageBlobRespDTO>> listIpqcDetail(@RequestParam @NotNull Long detailId) {
        validateIpqcDetail(detailId);
        var files = storageApi.listAttachments(IPQC_DETAIL_RECORD_TYPE, detailId);
        return success(files == null ? List.of() : files);
    }

    @PostMapping("/ipqc-detail/save")
    @PreAuthorize("@ss.hasPermission('mes:qc-ipqc:update')")
    @Transactional(rollbackFor = Exception.class)
    public CommonResult<Boolean> saveIpqcDetail(@Valid @RequestBody IpqcDetailSaveReq req) {
        validateIpqcDetail(req.getDetailId());
        storageApi.bindAttachments("file", IPQC_DETAIL_RECORD_TYPE, req.getDetailId(),
                req.getBlobIds().stream().distinct().toList());
        return success(true);
    }

    @DeleteMapping("/ipqc-detail/remove")
    @PreAuthorize("@ss.hasPermission('mes:qc-ipqc:update')")
    @Transactional(rollbackFor = Exception.class)
    public CommonResult<Boolean> removeIpqcDetail(@RequestParam @NotNull Long detailId,
                                                  @RequestParam @NotNull Long blobId) {
        validateIpqcDetail(detailId);
        storageApi.removeReference("file", IPQC_DETAIL_RECORD_TYPE, detailId, blobId);
        return success(true);
    }

    private static final String IPQC_DETAIL_RECORD_TYPE = "mes_qc_ipqc_detail_attachment";

    /** 校验明细存在且属于过程检验结果 */
    private void validateIpqcDetail(Long detailId) {
        var ids = jdbcTemplate.queryForList(
                "SELECT d.id FROM mes_qc_indicator_result_detail d "
                        + "JOIN mes_qc_indicator_result r ON r.id = d.result_id "
                        + "WHERE d.id = ? AND r.qc_type = ? AND d.deleted = 0 AND r.deleted = 0",
                Long.class, detailId, cn.iocoder.yudao.module.mes.enums.qc.MesQcTypeEnum.IPQC.getType());
        if (ids.isEmpty()) {
            throw new ServiceException(400, "过程检验行不存在或不属于过程检验单，无法上传附件");
        }
    }

    @Data public static class IpqcDetailSaveReq {
        @NotNull private Long detailId;
        /** 允许空列表：表示清空该行附件 */
        @NotNull @Size(max = 50) private List<@NotNull Long> blobIds;
    }

    private String recordType(String type) {
        return switch (type) {
            case "iqc", "ipqc", "oqc", "rqc", "patrol" -> "mes_qc_" + type + "_attachment";
            default -> throw new ServiceException(400, "质检类型无效");
        };
    }

    private void lockDocument(String type, Long id) {
        String table = switch (type) {
            case "iqc" -> "mes_qc_iqc";
            case "ipqc" -> "mes_qc_ipqc";
            case "oqc" -> "mes_qc_oqc";
            case "rqc" -> "mes_qc_rqc";
            case "patrol" -> "mes_qc_patrol";
            default -> throw new ServiceException(400, "质检类型无效");
        };
        var ids = jdbcTemplate.queryForList("SELECT id FROM " + table + " WHERE id = ? AND deleted = 0 FOR UPDATE", Long.class, id);
        if (ids.isEmpty()) throw new ServiceException(400, "质检单不存在");
    }

    private Integer validateDocument(String type, Long id) {
        return switch (type) {
            case "iqc" -> iqcService.validateIqcExists(id).getStatus();
            case "ipqc" -> ipqcService.validateIpqcExists(id).getStatus();
            case "oqc" -> oqcService.validateOqcExists(id).getStatus();
            case "rqc" -> rqcService.validateRqcExists(id).getStatus();
            case "patrol" -> {
                var ids = jdbcTemplate.queryForList(
                        "SELECT id FROM mes_qc_patrol WHERE id = ? AND tenant_id = ? AND deleted = 0",
                        Long.class, id, TenantContextHolder.getRequiredTenantId());
                if (ids.isEmpty()) throw new ServiceException(400, "巡检记录不存在");
                yield 0;
            }
            default -> throw new ServiceException(400, "质检类型无效");
        };
    }

    @Data public static class SaveReq {
        @NotNull @Pattern(regexp = "iqc|ipqc|oqc|rqc|patrol") private String type;
        @NotNull private Long id;
        @NotEmpty @Size(max = 50) private List<@NotNull Long> blobIds;
    }
    @Data public static class AppendReq {
        @NotNull @Pattern(regexp = "iqc|ipqc|oqc|rqc|patrol") private String type;
        @NotNull private Long id;
        @NotNull private Long blobId;
    }
}