package com.yssh.service.impl;

import com.yssh.dao.DictRecordMapper;
import com.yssh.dao.Yssh2dreliMapper;
import com.yssh.entity.DictRecord;
import com.yssh.entity.Yssh2dreli;
import com.yssh.service.Yssh2dreliService;
import lombok.Synchronized;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

/**
 * @author lishijia
 * @ClassName Yssh2dreliServiceImpl
 * @Description TODO
 * @date 2022/12/3 21:25
 * @Version 1.0
 */
@Service
public class Yssh2dreliServiceImpl implements Yssh2dreliService {
    @Autowired
    private Yssh2dreliMapper yssh2dreliMapper;

    @Autowired
    private DictRecordMapper dictRecordMapper;

    @Override
    public List<Yssh2dreli> getAll() {
        return yssh2dreliMapper.getAll();
    }

    /**
     * 创建2维热力表接口
     */
    @Transactional(rollbackFor = Exception.class)
    @Synchronized
    @Override
    public int create2dreliTable() {
        String tablePrefix = "yssh_2dreli_";
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd");
        Calendar calendar1 = Calendar.getInstance();
        //明天
        calendar1.add(Calendar.DATE, +1);
        Date start = calendar1.getTime();
        String tomorrow = dateFormat.format(start);
        String tableName = tablePrefix + tomorrow;
        System.out.println("tableName = " + tableName);

        //把新增的表增加到字典表中
        DictRecord dictRecord = new DictRecord();
        dictRecord.setTableName(tableName);
        dictRecord.setResOne("2");
        dictRecord.setResTwo(tomorrow);
        dictRecord.setCreateTime(dateFormat("yyyy-MM-dd HH:mm:ss"));
        dictRecordMapper.insertDictRecord(dictRecord);
        return yssh2dreliMapper.create2dreliTable(tableName);
    }

    /**
     * 创建当天2维热力表接口
     */
    @Transactional(rollbackFor = Exception.class)
    @Synchronized
    @Override
    public int preReate2dreliTable() {
        String tablePrefix = "yssh_2dreli_";
        Date date = new Date();
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd");
        String localDday = dateFormat.format(date);
        String tableName = tablePrefix + localDday;
        int total = yssh2dreliMapper.create2dreliTable(tableName);
        //把新增的表增加到字典表中
        DictRecord dictRecord = new DictRecord();
        dictRecord.setTableName(tableName);
        dictRecord.setResOne("2");
        dictRecord.setResTwo(localDday);
        dictRecord.setCreateTime(dateFormat("yyyy-MM-dd HH:mm:ss"));
        dictRecordMapper.insertDictRecord(dictRecord);
        return total;
    }

    /**
     * 获取LocalDateTime的指定日期格式
     *
     * @param ofPattern 设置时间格式：yyyy-MM-dd HH:mm:ss
     * @return 2023-02-09 09:51:43
     */
    public String dateFormat(String ofPattern) {
        return LocalDateTime.now().format(DateTimeFormatter.ofPattern(ofPattern));
    }


    /**
     * 删除2维热力表接口
     */
    @Transactional(rollbackFor = Exception.class)
    @Synchronized
    @Override
    public int drop2dreliTable() {
        String tablePrefix = "yssh_2dreli_";
        //定义日期格式
        SimpleDateFormat format2 = new SimpleDateFormat("yyyyMMdd");
        Calendar calendar = Calendar.getInstance();
        //前一年
        calendar.add(Calendar.YEAR, -1);
        Date start = calendar.getTime();
        String yearBefore = format2.format(start);
        String tableName = tablePrefix + yearBefore;
        return yssh2dreliMapper.drop2dreliTable(tableName);
    }


    /**
     * 查询接口
     */
    @Override
    public List<Yssh2dreli> query2data(Yssh2dreli yssh2dreli, String tableName) {
        List<Yssh2dreli> resultList = yssh2dreliMapper.query2data(yssh2dreli.getTime(), tableName);
        return resultList;
    }

    /**
     * 查询2维热力表接口
     * 1、根据time字段传入的开始时间和结束时间
     * 2、根据时间查询记录表，获取数据表名
     * 3、查询出结果、合并结果并返回结果
     * ①time为同一天的不同时间
     * ②time为不同一天的范围时间
     */
    @Override
    public List<Yssh2dreli> twoDDataQuery(String startTime, String endOfTime) {
        String tablePrefix = "yssh_2dreli_";
        String tableName = "";
        System.out.println("startTime = " + startTime);
        System.out.println("endOfTime = " + endOfTime);
        String strTime = startTime.substring(0, 8);
        String endTime = endOfTime.substring(0, 8);
        List<Yssh2dreli> resultList = new ArrayList<>();
        //根据查询时间判断查询的数据表
        //①同一个表范围查询
        if (strTime.equals(endTime)) {
            tableName = tablePrefix + strTime;
            System.out.println("tableName = " + tableName);
            resultList = yssh2dreliMapper.twoDDataQuery1(tableName, startTime, endOfTime);
        } else {
            //②不在同一个表查询
            List<Yssh2dreli> list1 = new ArrayList<>();
            tableName = tablePrefix + strTime;
            list1 = yssh2dreliMapper.twoDDataQuery2(tableName, startTime);

            List<Yssh2dreli> list2 = new ArrayList<>();
            tableName = tablePrefix + endTime;
            list2 = yssh2dreliMapper.twoDDataQuery3(tableName, endOfTime);
            //合并结果
            resultList.addAll(list1);
            resultList.addAll(list2);
        }
        return resultList;
    }


    /**
     * 查询2维热力表接口
     * 1、根据time字段传入的开始时间和结束时间
     * 2、根据时间查询记录表，获取数据表名
     * 3、查询出结果、合并结果并返回结果
     * ①time为同一天的不同时间
     * ②time为不同一天的范围时间
     */
    @Override
    public List<Yssh2dreli> qubyt(String startTime, String endOfTime) {
        String tablePrefix = "yssh_2dreli_";
        String tableName = "";
        System.out.println("startTime = " + startTime);
        System.out.println("endOfTime = " + endOfTime);
        String strTime = startTime.substring(0, 8);
        String endTime = endOfTime.substring(0, 8);
        List<Yssh2dreli> resultList = new ArrayList<>();
        //根据查询时间判断查询的数据表
        //①同一个表范围查询
        if (strTime.equals(endTime)) {
            tableName = tablePrefix + strTime;
            System.out.println("tableName = " + tableName);
            resultList = yssh2dreliMapper.twoDDataQuery1(tableName, startTime, endOfTime);
            return resultList;
        } else {
            //②不在同一个表查询 创建一个返回的list
            List<Yssh2dreli> lists = new ArrayList<>();
            //去字典记录表中查询出需要查询的表名
            List<DictRecord> resDictRecords = dictRecordMapper.selectDictRecordList2dByTime(strTime, endTime);
            for (DictRecord dicts : resDictRecords) {
                System.out.println("dicts = " + dicts.getTableName());
                lists.addAll(yssh2dreliMapper.twoDDataQuery(dicts.getTableName()));//将返回的结果添加到list中
            }
            return lists;
        }

    }


}