package com.lts.QC;

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 org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

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

@SpringBootTest
class QcApplicationTests {

    @Autowired
    private MesAnkerService mesAnkerService;

    @Autowired
    private AnkerMcgsMesService ankService;

    @Test
    void contextLoads() {

        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);
            }
        }
    }

}