package jnpf.elnService.impl;

import jnpf.base.ActionResult;
import jnpf.base.ActionResultCode;
import jnpf.elnService.ElnTestWorkItemSnapshotProvider;
import jnpf.exception.DataException;
import jnpf.lims.api.TestWorkItemSnapshotApi;
import jnpf.lims.api.ElnSourceApi;
import jnpf.lims.api.model.ElnSourceActorRequest;
import jnpf.lims.api.model.ElnSourcePropertyRef;
import jnpf.lims.api.model.ElnSourceSnapshot;
import jnpf.lims.api.model.TestWorkItemSnapshotBatch;
import jnpf.lims.api.model.TestWorkItemSnapshotRequest;
import jnpf.lims.api.model.TestWorkItemSnapshotActorRequest;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import java.util.List;

@Component
public class LimsTestWorkItemSnapshotProviderAdapter implements ElnTestWorkItemSnapshotProvider {

    private final TestWorkItemSnapshotApi snapshotApi;
    private final ElnSourceApi sourceApi;

    @Autowired
    public LimsTestWorkItemSnapshotProviderAdapter(TestWorkItemSnapshotApi snapshotApi, ElnSourceApi sourceApi) {
        this.snapshotApi = snapshotApi;
        this.sourceApi = sourceApi;
    }

    public LimsTestWorkItemSnapshotProviderAdapter(TestWorkItemSnapshotApi snapshotApi) {
        this(snapshotApi, null);
    }

    @Override
    public List<ElnSourceSnapshot> resolveConfiguredAsActor(String tenantId, String userId,
            List<String> itemIds, List<ElnSourcePropertyRef> properties) {
        if (!"0".equals(tenantId) || !StringUtils.hasText(userId)) {
            throw new DataException("LIMS 来源负责人身份无效");
        }
        if (sourceApi == null) throw new DataException("版本化 LIMS 来源接口不可用");
        ElnSourceActorRequest request = new ElnSourceActorRequest();
        request.setTenantId(tenantId);
        request.setUserId(userId.trim());
        request.setTestWorkItemIds(itemIds);
        request.setProperties(properties);
        ActionResult<List<ElnSourceSnapshot>> response = sourceApi.resolveAsActor(request);
        if (response == null || !ActionResultCode.SUCCESS.getCode().equals(response.getCode()) || response.getData() == null) {
            throw new DataException(response == null || !StringUtils.hasText(response.getMsg())
                    ? "版本化 LIMS 来源读取失败" : response.getMsg());
        }
        return response.getData();
    }

    @Override
    public TestWorkItemSnapshotBatch resolve(List<String> testWorkItemIds, List<String> properties) {
        TestWorkItemSnapshotRequest request = new TestWorkItemSnapshotRequest();
        request.setTestWorkItemIds(testWorkItemIds);
        request.setProperties(properties);
        return result(snapshotApi.snapshots(request));
    }

    @Override
    public TestWorkItemSnapshotBatch resolveAsActor(String tenantId, String userId,
                                                       List<String> testWorkItemIds, List<String> properties) {
        if (!StringUtils.hasText(tenantId) || !StringUtils.hasText(userId)) {
            throw new DataException("LIMS 负责人身份不能为空");
        }
        TestWorkItemSnapshotRequest request = new TestWorkItemSnapshotRequest();
        request.setTestWorkItemIds(testWorkItemIds);
        request.setProperties(properties);
        TestWorkItemSnapshotActorRequest actor = new TestWorkItemSnapshotActorRequest();
        actor.setTenantId(tenantId.trim());
        actor.setUserId(userId.trim());
        actor.setRequest(request);
        return result(snapshotApi.snapshotsAsActor(actor));
    }

    private static TestWorkItemSnapshotBatch result(ActionResult<TestWorkItemSnapshotBatch> result) {
        if (result == null
                || !ActionResultCode.SUCCESS.getCode().equals(result.getCode())
                || result.getData() == null) {
            throw new DataException(result == null || !StringUtils.hasText(result.getMsg())
                    ? "LIMS 检验任务快照读取失败，请稍后重试" : result.getMsg());
        }
        return result.getData();
    }
}