package org.jeecg.modules.lims.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import org.jeecg.modules.lims.entity.LimsAppointment;
import org.jeecg.modules.lims.entity.LimsAppointmentAudit;
import org.jeecg.modules.lims.entity.LimsInstrument;
import org.jeecg.modules.lims.entity.LimsUsageRecord;
import org.jeecg.modules.lims.mapper.LimsAppointmentAuditMapper;
import org.jeecg.modules.lims.mapper.LimsAppointmentMapper;
import org.jeecg.modules.lims.mapper.LimsInstrumentMapper;
import org.jeecg.modules.lims.mapper.LimsUsageRecordMapper;
import org.jeecg.modules.lims.service.ILimsInstrumentService;
import org.jeecg.modules.lims.service.ILimsUsageRecordService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

/**
 * @Description: 仪器
 * @Author: jeecg-boot
 * @Date:   2022-11-07
 * @Version: V1.0
 */
@Service
public class LimsInstrumentServiceImpl extends ServiceImpl<LimsInstrumentMapper, LimsInstrument> implements ILimsInstrumentService {
    @Autowired
    private LimsUsageRecordMapper usageRecordMapper;
    @Autowired
    private LimsInstrumentMapper instrumentMapper;
    @Autowired
    private LimsAppointmentAuditMapper auditMapper;
    @Autowired
    private LimsAppointmentMapper appointmentMapper;
    @Override
    public void resetInspection() {
        LambdaUpdateWrapper<LimsInstrument> updateWrapper = new LambdaUpdateWrapper<>();
        updateWrapper.set(LimsInstrument::getInspection, 0);
        baseMapper.update(null, updateWrapper);
    }

    @Override
    @Transactional
    public void resetInstrument() {
        QueryWrapper<LimsUsageRecord> usageRecordQueryWrapper = new QueryWrapper<>();
        //查询正在运行的设备
        usageRecordQueryWrapper.lambda().eq(LimsUsageRecord::getStatus,1);
        List<LimsUsageRecord> limsUsageRecords = usageRecordMapper.selectList(usageRecordQueryWrapper);
        if(limsUsageRecords!=null && limsUsageRecords.size() > 0){

            List<String> instrumentIds  = limsUsageRecords.stream().map(LimsUsageRecord::getInstrument).collect(Collectors.toList());
            //更新设备表
            if(instrumentIds.size()>0){
                QueryWrapper<LimsInstrument> instrumentQueryWrapper = new QueryWrapper<>();
                instrumentQueryWrapper.lambda().in(LimsInstrument::getId,instrumentIds);
                List<LimsInstrument> instrumentList = instrumentMapper.selectList(instrumentQueryWrapper);
                instrumentList.stream().forEach(item -> {
                    item.setUsed("0");
                    item.setUpdateBy(item.getCreateBy());
                    item.setUpdateTime(new Date());
                    instrumentMapper.updateById(item);
                });
            }

            //更新使用记录表
            limsUsageRecords.stream().forEach(item->{
                item.setUpdateBy(item.getCreateBy());
                item.setUpdateTime(new Date());
                item.setStatus(2);
                usageRecordMapper.updateById(item);
            });


        }



    }

    @Override
    public void resetAudit() {
        //1.当天未审批设置为超时状态
        QueryWrapper<LimsAppointmentAudit> auditQueryWrapper = new QueryWrapper<>();
        auditQueryWrapper.lambda().eq(LimsAppointmentAudit::getStatus,"0");
        List<LimsAppointmentAudit> limsAppointmentAudits = auditMapper.selectList(auditQueryWrapper);
        limsAppointmentAudits.stream().forEach(item->{
            item.setStatus("3");
            auditMapper.updateById(item);

            //2.设置预约为取消
            String appoId = item.getAppoId();
            LimsAppointment appointment = appointmentMapper.selectById(appoId);
            appointment.setStatus("2");
            appointmentMapper.updateById(appointment);

        });

    }
}