package jnpf.limsService.impl;

import jnpf.lims.api.model.TestWorkItemRequestIdentityBatch;
import jnpf.lims.api.model.TestWorkItemRequestIdentity;
import jnpf.lims.api.model.TestWorkItemRequestIdentityRequest;
import jnpf.limsEntity.LimsJianyanXiangEntity;
import jnpf.limsMapper.LimsJianyanXiangMapper;
import jnpf.limsService.LimsTestWorkItemRequestIdentityService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

import java.util.ArrayList;
import java.util.Collections;
import java.util.LinkedHashMap;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;

@Service
public class LimsTestWorkItemRequestIdentityServiceImpl
        implements LimsTestWorkItemRequestIdentityService {

    private final TaskLookup taskLookup;

    @Autowired
    public LimsTestWorkItemRequestIdentityServiceImpl(LimsJianyanXiangMapper mapper) {
        this(mapper::selectLiveTasks);
    }

    LimsTestWorkItemRequestIdentityServiceImpl(TaskLookup taskLookup) {
        this.taskLookup = taskLookup;
    }

    @Override
    public TestWorkItemRequestIdentityBatch resolve(String tenantId,
                                                       TestWorkItemRequestIdentityRequest request) {
        List<String> itemIds = itemIds(request);
        Map<String, LimsJianyanXiangEntity> tasks = tasks(tenantId, itemIds);
        TestWorkItemRequestIdentityBatch batch = new TestWorkItemRequestIdentityBatch();
        for (String itemId : itemIds) {
            TestWorkItemRequestIdentity item = new TestWorkItemRequestIdentity();
            item.setTestWorkItemId(itemId);
            LimsJianyanXiangEntity task = tasks.get(itemId);
            if (task == null) {
                item.setOutcomeCode("NOT_FOUND");
                item.setReason("检验项不存在或无权访问");
            } else if (!StringUtils.hasText(task.getQingyandanId())) {
                item.setTaskStatus(task.getJianyanZhuangtai());
                item.setOutcomeCode("TEST_REQUEST_INVALID");
                item.setReason("检验项缺少请验单身份");
            } else {
                item.setTestRequestId(task.getQingyandanId().trim());
                item.setTaskStatus(task.getJianyanZhuangtai());
                item.setOutcomeCode("SUCCESS");
            }
            batch.getItems().add(item);
        }
        return batch;
    }

    private Map<String, LimsJianyanXiangEntity> tasks(String tenantId, List<String> itemIds) {
        if (!StringUtils.hasText(tenantId) || itemIds.isEmpty()) return Collections.emptyMap();
        Map<String, LimsJianyanXiangEntity> result = new LinkedHashMap<>();
        for (LimsJianyanXiangEntity task : taskLookup.find(tenantId, itemIds)) {
            if (task != null && StringUtils.hasText(task.getId())
                    && tenantId.equals(task.getTenantId())) {
                result.put(task.getId(), task);
            }
        }
        return result;
    }

    private static List<String> itemIds(TestWorkItemRequestIdentityRequest request) {
        if (request == null || request.getTestWorkItemIds() == null) return Collections.emptyList();
        LinkedHashSet<String> result = new LinkedHashSet<>();
        for (String id : request.getTestWorkItemIds()) {
            if (StringUtils.hasText(id)) result.add(id.trim());
        }
        return new ArrayList<>(result);
    }

    @FunctionalInterface
    interface TaskLookup {
        List<LimsJianyanXiangEntity> find(String tenantId, List<String> testWorkItemIds);
    }
}