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