package com.lts.QC.task;


import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.lts.QC.domain.MesAnker;
import com.lts.QC.service.AnkerMcgsMesService;
import com.lts.QC.service.MesAnkerService;
import com.lts.QC.sqlServerEntity.AnkerMcgsMes;
import lombok.RequiredArgsConstructor;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

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

@Component
@RequiredArgsConstructor
public class ScheduledTasks {

    private final MesAnkerService mesAnkerService;

    private final AnkerMcgsMesService ankService;

    /**
     * 每两分钟执行一次
     *
     * @return void
     * @author tjx
     * @description TODO
     * @date 2024/9/27 21:48
     */
    @Scheduled(cron = "0 0/2 * * * ?")
    public void getDeviceRealTimeData() {
        LambdaQueryWrapper<AnkerMcgsMes> queryWrapper1 = new LambdaQueryWrapper<>();
        queryWrapper1.eq(AnkerMcgsMes::getIsReceive, 0);

        List<AnkerMcgsMes> list = ankService.list(queryWrapper1);

        if (CollectionUtil.isNotEmpty(list)) {

            List<MesAnker> mesAnkers = new ArrayList<>();
            for (AnkerMcgsMes ank : list) {
                MesAnker mesAnker = new MesAnker();

                mesAnker.setCreateDate(new Date());

                mesAnker.setAnkerId(ank.getId().longValue());
                mesAnker.setMcgsTime(ank.getMcgsTime());
                mesAnker.setMcgsTimems(ank.getMcgsTimems().longValue());
                mesAnker.setItemBarcode(ank.getItemBarcode());
                mesAnker.setBoardConduction(ank.getBoardConduction());
                mesAnker.setHighVoltage(ank.getHighVoltage());
                mesAnker.setLeakageCurrentLn(ank.getLeakageCurrentLn());
                mesAnker.setLeakageCurrentLng(ank.getLeakageCurrentLng());
                mesAnker.setGroundCurrent(ank.getGroundCurrent());
                mesAnker.setLoad(ank.getLoadMes());
                mesAnker.setOverloadTimer(ank.getOverloadTimer());
                mesAnker.setComprehensiveJudgment(ank.getComprehensiveJudgment());
                mesAnkers.add(mesAnker);
            }

            boolean b = mesAnkerService.saveBatch(mesAnkers);
            if (b) {

                List<Integer> list1 = list.stream().map(AnkerMcgsMes::getId).collect(Collectors.toList());

                LambdaUpdateWrapper<AnkerMcgsMes> queryWrapper = new LambdaUpdateWrapper<>();
                queryWrapper.set(AnkerMcgsMes::getIsReceive, Integer.valueOf(1)).in(AnkerMcgsMes::getId, list1);

                ankService.update(queryWrapper);
            }
        }
    }
}