package com.whyc.service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.whyc.dto.Response;
|
import com.whyc.mapper.AbeTestDataInfMapper;
|
import com.whyc.mapper.CallBack;
|
import com.whyc.pojo.db_abe_ram.AbeInf;
|
import com.whyc.pojo.db_abe_testdata.AbeTestData;
|
import com.whyc.pojo.db_abe_testdata.AbeTestDataInf;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
@Service
|
public class AbeTestDataInfService {
|
|
@Resource
|
private AbeTestDataInfMapper mapper;
|
|
@Autowired
|
private AbeTestDataService abeTestDataService;
|
|
@Autowired
|
private AbeInfService abeInfService;
|
|
public Response<PageInfo<AbeTestDataInf>> getPage(int pageNum, int pageSize) {
|
PageHelper.startPage(pageNum,pageSize);
|
QueryWrapper<AbeTestDataInf> query = Wrappers.query();
|
query.orderByDesc("record_time");
|
List<AbeTestDataInf> list = mapper.selectList(query);
|
PageInfo<AbeTestDataInf> pageInfo = new PageInfo(list);
|
return new Response<PageInfo<AbeTestDataInf>>().set(1,pageInfo);
|
|
}
|
|
/*private List<AbeTestData> getList(int monId,List<Integer> testRecordCountList) {
|
String testRecordCount = testRecordCountList.stream().map(String::valueOf).collect(Collectors.joining(",","(",")"));
|
String sql = "select test_record_count,mon_vol,mon_tmp,mon_res from db_abe_testdata.tb_abe_testdata_"+monId +" where test_record_count in "+testRecordCount;
|
List<AbeTestData> monDatalist = jdbcSqlExecuteService.executeQuery_call(sql, new CallBack<AbeTestData>() {
|
|
@Override
|
public List<AbeTestData> getResults(ResultSet rs) throws SQLException {
|
LinkedList<AbeTestData> temp = new LinkedList<>();
|
while (rs.next()) {
|
AbeTestData abeTestData = new AbeTestData();
|
abeTestData.setTestRecordCount(rs.getInt("test_record_count"));
|
abeTestData.setMonVol(rs.getFloat("mon_vol"));
|
abeTestData.setMonTmp(rs.getFloat("mon_tmp"));
|
abeTestData.setMonRes(rs.getFloat("mon_res"));
|
temp.add(abeTestData);
|
}
|
return temp;
|
}
|
});
|
return monDatalist;
|
|
}*/
|
|
public Response<AbeTestDataInf> getByTaskNo(String taskNo) {
|
QueryWrapper<AbeTestDataInf> query = Wrappers.query();
|
query.eq("task_no",taskNo);
|
query.last(" limit 1");
|
AbeTestDataInf abeTestDataInf = mapper.selectOne(query);
|
Integer monId = abeTestDataInf.getMonId();
|
Integer testRecordCount = abeTestDataInf.getTestRecordCount();
|
List<AbeTestData> dataList = abeTestDataService.getList(monId, testRecordCount);
|
abeTestDataInf.setDataList(dataList);
|
return new Response<AbeTestDataInf>().set(1,abeTestDataInf);
|
}
|
|
public Response<AbeTestDataInf> getAbeOngoing() {
|
AbeInf abeInf = abeInfService.get();
|
String taskNo = abeInf.getTaskNo();
|
return getByTaskNo(taskNo);
|
}
|
}
|
