package com.whyc.service;

import com.whyc.dto.BattCapFactory;
import com.whyc.dto.Response;
import com.whyc.mapper.CallBack;
import com.whyc.pojo.db_batt.PowerInf;
import com.whyc.pojo.db_dis_batt.BattTestInf;
import com.whyc.pojo.db_dis_batt.BattTestInfData;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.LinkedList;
import java.util.List;

@Service
public class BattTestInfDataService {

    @Autowired
    private JdbcSqlExecuteService jdbcSqlExecuteService;

    @Autowired
    private BattTestInfService battTestInfService;

    @Autowired
    private PowerInfService powerInfService;

    public Response getMonTestData(int battGroupId) {
        //查询最近一次的放电记录
        BattTestInf battTestInf =battTestInfService.getDischargeLast(battGroupId);
        PowerInf powerInf =powerInfService.getByBattGroupId(battGroupId);
        Float monCapStd = powerInf.getMonCap();
        Float monVolStd = powerInf.getMonVol();
        List<BattTestInfData> list = new LinkedList<>();
        if (battTestInf !=null){
            Integer testRecordCount = battTestInf.getTestRecordCount();
            Integer recordNum = battTestInf.getRecordNum();
            String sql = "select * from db_dis_batt.batt_test_inf_"+battGroupId+" where test_record_count ="+testRecordCount + " and record_num ="+recordNum;
            list = jdbcSqlExecuteService.executeQuery_call(sql, new CallBack<BattTestInfData>() {
                @Override
                public List<BattTestInfData> getResults(ResultSet rs) throws SQLException {
                    List<BattTestInfData> list = new LinkedList<>();
                    while (rs.next()) {
                        BattTestInfData data = new BattTestInfData();
                        data.setRecordTime(rs.getTimestamp("record_time"));
                        data.setTestStarttime(rs.getTimestamp("test_starttime"));
                        data.setTestTimelong(rs.getInt("test_timelong"));
                        data.setOnlineVol(rs.getFloat("online_vol"));
                        data.setGroupVol(rs.getFloat("group_vol"));
                        data.setTestCurr(rs.getFloat("test_curr"));
                        data.setTestCap(rs.getFloat("test_cap"));
                        data.setMonNum(rs.getInt("mon_num"));
                        data.setMonVol(rs.getFloat("mon_vol"));

                        list.add(data);

                    }
                    return list;
                }
            });
            list.forEach(item->{
                //小时率
                int hourRate = BattCapFactory.GetHourRate(monCapStd, item.getTestCurr());
                //容量计算
                Double realCap = BattCapFactory.GetMonomerCap(monCapStd, hourRate, item.getTestCap(), item.getMonVol(), item.getMonVol(), monVolStd, BattCapFactory.CapType_Real);
                item.setRealCap(realCap.floatValue());
            });

        }else{ //返回标称单体容量
            Integer monNum = powerInf.getMonNum();
            for (int i = 1; i < monNum+1; i++) {
                BattTestInfData battTestInfData = new BattTestInfData();
                battTestInfData.setMonNum(i);
                battTestInfData.setRealCap(monCapStd);
                list.add(battTestInfData);
            }
        }
        return new Response().set(1, list);
    }
}