package jnpf.limsService.impl;

import jnpf.audit.sdk.annotation.AuditLog;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import jnpf.base.UserInfo;
import jnpf.limsEntity.LimsSxtKanbanItemVo;
import jnpf.limsEntity.LimsSxtKanbanOptionsVo;
import jnpf.limsEntity.LimsSxtKanbanRowVo;
import jnpf.limsEntity.LimsSxtQuyangJihuaRenwuEntity;
import jnpf.limsMapper.LimsSxtKanbanMapper;
import jnpf.limsMapper.LimsSxtQuyangJihuaRenwuMapper;
import jnpf.limsService.LimsSxtKanbanService;
import jnpf.limsService.LimsSxtQuyangJihuaRenwuService;
import jnpf.limsService.support.LimsSxtQuyangJihuaRenwuStatus;
import jnpf.util.UserProvider;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

import java.time.LocalDate;
import java.time.ZoneId;
import java.util.ArrayList;
import java.util.List;

/**
 * 水系统计划看板行读取当前有效点位，日历项读取 Renwu 历史快照。
 */
@Service
public class LimsSxtKanbanServiceImpl implements LimsSxtKanbanService {

    @Autowired
    private LimsSxtKanbanMapper kanbanMapper;
    @Autowired
    private LimsSxtQuyangJihuaRenwuMapper renwuMapper;
    @Autowired
    private LimsSxtQuyangJihuaRenwuService renwuService;

    @Override
    public LimsSxtKanbanOptionsVo listKanbanOptions(String yangpinLeixing, String suoshuChejian,
                                                     String quyangDidian) {
        String tenantId = dangqianZuhuId();
        LimsSxtKanbanOptionsVo result = new LimsSxtKanbanOptionsVo();
        result.setYangpinLeixingList(kanbanMapper.selectSampleTypes(tenantId));
        if (!StringUtils.hasText(yangpinLeixing)) {
            return result;
        }
        result.setChejianList(kanbanMapper.selectWorkshops(tenantId, yangpinLeixing));
        if (!StringUtils.hasText(suoshuChejian)) {
            return result;
        }
        result.setQuyangDidianList(kanbanMapper.selectPlaces(tenantId, yangpinLeixing, suoshuChejian));
        if (!StringUtils.hasText(quyangDidian)) {
            return result;
        }
        result.setQuyangdianList(kanbanMapper.selectPoints(
                tenantId, yangpinLeixing, suoshuChejian, quyangDidian));
        return result;
    }

    @Override
    public List<LimsSxtKanbanRowVo> listKanbanRows(String yangpinLeixing, String suoshuChejian,
                                                    String quyangDidian, String quyangdianBianhao) {
        return kanbanMapper.selectRows(dangqianZuhuId(), yangpinLeixing, suoshuChejian,
                quyangDidian, quyangdianBianhao);
    }

    @Override
    public List<LimsSxtKanbanItemVo> listKanbanItems(LocalDate kaishiRiqi, LocalDate jieshuRiqi,
                                                      String yangpinLeixing, String suoshuChejian,
                                                      String quyangDidian, String quyangdianBianhao) {
        if (kaishiRiqi == null || jieshuRiqi == null || kaishiRiqi.isAfter(jieshuRiqi)) {
            throw new jnpf.exception.DataException("日期范围不正确");
        }
        List<LimsSxtKanbanItemVo> result = new ArrayList<>();
        for (LimsSxtQuyangJihuaRenwuEntity renwu : chaxunRenwu(
                kaishiRiqi, jieshuRiqi, yangpinLeixing, suoshuChejian, quyangDidian, quyangdianBianhao)) {
            result.add(toItem(renwu));
        }
        return result;
    }

    @Override
    @AuditLog(action = "DELETE", label = "取消水系统未来计划任务", bizType = "SXT",
            bizCodeExpr = "#renwuId", bizCodeRequired = false,
            targetTable = "lims_sxt_quyang_jihua_renwu", targetIdExpr = "#renwuId",
            diff = true, entityClass = LimsSxtQuyangJihuaRenwuEntity.class)
    public void quxiaoWeilaiRenwu(String renwuId) {
        renwuService.quxiaoWeishengchengWeilaiRenwu(renwuId, dangqianZuhuId(), "manual_cancelled");
    }

    private List<LimsSxtQuyangJihuaRenwuEntity> chaxunRenwu(LocalDate kaishiRiqi, LocalDate jieshuRiqi,
                                                              String yangpinLeixing, String suoshuChejian,
                                                              String quyangDidian, String quyangdianBianhao) {
        QueryWrapper<LimsSxtQuyangJihuaRenwuEntity> query = new QueryWrapper<>();
        query.eq("f_tenant_id", dangqianZuhuId()).eq("f_delete_mark", 0)
                .ge(kaishiRiqi != null, "jihua_riqi", kaishiRiqi)
                .le(jieshuRiqi != null, "jihua_riqi", jieshuRiqi)
                .eq(StringUtils.hasText(yangpinLeixing), "yangpin_leixing", yangpinLeixing)
                .eq(StringUtils.hasText(suoshuChejian), "suoshu_chejian_id", suoshuChejian)
                .eq(StringUtils.hasText(quyangDidian), "quyang_didian", quyangDidian)
                .eq(StringUtils.hasText(quyangdianBianhao), "quyangdian_bianhao", quyangdianBianhao)
                .notIn("renwu_zhuangtai", LimsSxtQuyangJihuaRenwuStatus.CANCELLED,
                        LimsSxtQuyangJihuaRenwuStatus.INVALIDATED)
                .orderByAsc("yangpin_leixing", "suoshu_chejian", "quyang_didian", "quyangdian_bianhao", "jihua_riqi");
        return renwuMapper.selectList(query);
    }

    private LimsSxtKanbanRowVo toRow(LimsSxtQuyangJihuaRenwuEntity renwu) {
        LimsSxtKanbanRowVo row = new LimsSxtKanbanRowVo();
        row.setQuyangdianId(renwu.getQuyangdianId());
        row.setYangpinLeixing(renwu.getYangpinLeixing());
        row.setYangpinLeixingMingcheng(renwu.getYangpinLeixingMingcheng());
        row.setSuoshuChejian(renwu.getSuoshuChejian());
        row.setQuyangDidian(renwu.getQuyangDidian());
        row.setQuyangdianBianhao(renwu.getQuyangdianBianhao());
        return row;
    }

    private LimsSxtKanbanItemVo toItem(LimsSxtQuyangJihuaRenwuEntity renwu) {
        LimsSxtKanbanItemVo item = new LimsSxtKanbanItemVo();
        BeanUtils.copyProperties(toRow(renwu), item);
        item.setRenwuId(renwu.getId());
        item.setJihuaId(renwu.getJihuaId());
        item.setJihuaMingcheng(renwu.getJihuaMingcheng());
        item.setJihuaRiqi(renwu.getJihuaRiqi());
        item.setRenwuZhuangtai(renwu.getRenwuZhuangtai());
        item.setRenwuZhuangtaiYuanyinDaima(renwu.getRenwuZhuangtaiYuanyinDaima());
        item.setRenwuZhuangtaiYuanyin(renwu.getRenwuZhuangtaiYuanyin());
        item.setJianyanXiangmu(renwu.getJianyanXiangmu());
        item.setJianyanXiangmuMingcheng(renwu.getJianyanXiangmuMingcheng());
        item.setQingyandanId(renwu.getQingyandanId());
        item.setQingyandanLiushuihao(renwu.getQingyandanLiushuihao());
        item.setQingyandanZhuangtai(renwu.getQingyandanZhuangtai());
        item.setCanDelete(isKeQuxiao(renwu));
        return item;
    }

    private boolean isKeQuxiao(LimsSxtQuyangJihuaRenwuEntity renwu) {
        LocalDate jihuaRiqi = renwu.getJihuaRiqi().toInstant().atZone(ZoneId.systemDefault()).toLocalDate();
        return jihuaRiqi.isAfter(LocalDate.now()) && !StringUtils.hasText(renwu.getQingyandanId())
                && (LimsSxtQuyangJihuaRenwuStatus.PENDING.equals(renwu.getRenwuZhuangtai())
                || LimsSxtQuyangJihuaRenwuStatus.BLOCKED_CONFIG_INVALID.equals(renwu.getRenwuZhuangtai()));
    }

    private String dangqianZuhuId() {
        UserInfo user = UserProvider.getUser();
        return user == null || !StringUtils.hasText(user.getTenantId()) ? "0" : user.getTenantId();
    }
}