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