package com.iailab.module.prod.service.impl;

import com.iailab.common.dto.echarts.BarLineDTO;
import com.iailab.common.dto.echarts.SeriesItem;
import com.iailab.common.enums.CdbmEnum;
import com.iailab.common.utils.HttpsRequest;
import com.iailab.module.data.dto.FeignQueryPointDTO;
import com.iailab.module.data.dto.ApiDataDTO;
import com.iailab.module.data.api.IFeignDataApi;
import com.iailab.module.param.service.PageParmService;
import com.iailab.module.prod.dto.PageCharsDTO;
import com.iailab.module.quality.service.QualityQualityTrendDayService;
import com.iailab.module.prod.service.*;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.util.*;

@Service
public class PageCharsServiceImpl implements PageCharsService {

    @Resource
    private IFeignDataApi iFeignDataApi;

    @Resource
    private HttpsRequest httpsRequest;

    @Resource
    private PageParmService pageParmService;

    @Resource
    private PrdCurrentPerformanceService prdCurrentPerformanceService;

    @Resource
    private PrdCurrentSaleService prdCurrentSaleService;

    @Resource
    private PrdDayProdService prdDayProdService;

    @Resource
    private PrdPlanMonService prdPlanMonService;

    @Resource
    private PrdPlanYearService prdPlanYearService;

    @Resource
    private QualityQualityTrendDayService qualityQualityTrendDayService;

    @Override
    public List<PageCharsDTO> getData(String page) {

        String chars = pageParmService.selectValue(page, "chars");
        String length = pageParmService.selectValue(page, "length");
        String pointLength = pageParmService.selectValue(page, "point_length");
        String coal = pageParmService.selectValue(page, "coal");
        String point = pageParmService.selectValue(page, "point")==null?"":pageParmService.selectValue(page, "point");
        List<String> coalList = Arrays.asList(coal.split(";"));
        List<String> pointList = Arrays.asList(point.split(";"));
        List<String> charsCodeList = Arrays.asList(chars.split(";"));
        List<PageCharsDTO> list = new ArrayList<>();
        charsCodeList.stream().forEach(
                item -> {
                        //如果数据源为报表，类型为煤质或产量，传一个煤种参数
                    if(CdbmEnum.HF.getCode().equals(item)||CdbmEnum.LF.getCode().equals(item)||CdbmEnum.SF.getCode().equals(item)||CdbmEnum.RZ.getCode().equals(item)||CdbmEnum.CL.getCode().equals(item)) {
                        coalList.stream().forEach(
                                coalItem->{
                                    list.add(getPageChars(item, length,coalItem));
                                }
                        );
                    }else if(item.equals("point")){
                        //如果数据源为point，传一个测点参数
                        pointList.stream().forEach(
                                pointItem->{
                                    list.add(getPageChars(item,pointLength,pointItem));
                                }
                        );
                    }else {
                        list.add(getPageChars(item, length,""));
                    }
                }
        );

        return list;
    }

    public PageCharsDTO getPageChars(String charsCode, String length,String param) {
        PageCharsDTO dto = new PageCharsDTO();
        BarLineDTO barLine;

        try {
            switch (charsCode) {
                case "plan":
                    //计划
                    barLine = prdPlanMonService.barLine(length);
                    dto.setCurrentValue(prdPlanMonService.currentValue()==null?new BigDecimal(0):prdPlanMonService.currentValue());
                    dto.setBarLineDTO(barLine);
                    dto.setUnit(CdbmEnum.getEumByCode("plan").getUnit());
                    dto.setLength(length);
                    //调用模型方法
                    this.run(dto);
                    break;
                case "cl":
                    //产量
                    barLine = prdDayProdService.barLine(length,param);
                    dto.setCurrentValue(prdDayProdService.currentValue(param)==null?new BigDecimal(0):prdDayProdService.currentValue(param));
                    dto.setBarLineDTO(barLine);
                    dto.setUnit(CdbmEnum.getEumByCode("cl").getUnit());
                    dto.setLength(length);
                    //调用模型方法
                    this.run(dto);
                    break;
                case "groundsales":
                    //地销混煤
                    barLine = prdCurrentSaleService.barLine(length,"groundsales");
                    dto.setCurrentValue(prdCurrentSaleService.currentValue("groundsales")==null?new BigDecimal(0):prdCurrentSaleService.currentValue("groundsales"));
                    dto.setBarLineDTO(barLine);
                    dto.setUnit(CdbmEnum.getEumByCode("groundsales").getUnit());
                    dto.setLength(length);
                    //调用模型方法
                    this.run(dto);
                    break;
                case "medblock":
                    //洗中块外运
                    barLine = prdCurrentSaleService.barLine(length,"medblock");
                    dto.setCurrentValue(prdCurrentSaleService.currentValue("medblock")==null?new BigDecimal(0):prdCurrentSaleService.currentValue("medblock"));
                    dto.setBarLineDTO(barLine);
                    dto.setUnit(CdbmEnum.getEumByCode("medblock").getUnit());
                    dto.setLength(length);
                    //调用模型方法
                    this.run(dto);
                    break;
                case "nubmeasure":
                    //洗小块外运
                    barLine = prdCurrentSaleService.barLine(length,"nubmeasure");
                    dto.setCurrentValue(prdCurrentSaleService.currentValue("nubmeasure")==null?new BigDecimal(0):prdCurrentSaleService.currentValue("nubmeasure"));
                    dto.setBarLineDTO(barLine);
                    dto.setLength(length);
                    dto.setUnit(CdbmEnum.getEumByCode("nubmeasure").getUnit());
                    //调用模型方法
                    this.run(dto);
                    break;
                case "gangue":
                    //矸石外运
                    barLine = prdCurrentSaleService.barLine(length,"gangue");
                    dto.setCurrentValue(prdCurrentSaleService.currentValue("gangue")==null?new BigDecimal(0):prdCurrentSaleService.currentValue("gangue"));
                    dto.setBarLineDTO(barLine);
                    dto.setUnit(CdbmEnum.getEumByCode("gangue").getUnit());
                    dto.setLength(length);
                    //调用模型方法
                    this.run(dto);
                    break;
                case "reshipped":
                    //小块转载
                    barLine = prdCurrentSaleService.barLine(length,"reshipped");
                    dto.setCurrentValue(prdCurrentSaleService.currentValue("reshipped")==null?new BigDecimal(0):prdCurrentSaleService.currentValue("reshipped"));
                    dto.setBarLineDTO(barLine);
                    dto.setUnit(CdbmEnum.getEumByCode("reshipped").getUnit());
                    dto.setLength(length);
                    //调用模型方法
                    this.run(dto);
                    break;
                case "trainTon":
                    //火车外运吨数
                    barLine = prdCurrentSaleService.barLine(length,"trainTon");
                    dto.setCurrentValue(prdCurrentSaleService.currentValue("trainTon")==null?new BigDecimal(0):prdCurrentSaleService.currentValue("trainTon"));
                    dto.setBarLineDTO(barLine);
                    dto.setUnit(CdbmEnum.getEumByCode("trainTon").getUnit());
                    //调用模型方法
                    this.run(dto);
                    break;
                case "trainCount":
                    //火车外运列数
                    barLine = prdCurrentSaleService.barLine(length,"trainCount");
                    dto.setCurrentValue(prdCurrentSaleService.currentValue("trainCount")==null?new BigDecimal(0):prdCurrentSaleService.currentValue("trainCount"));
                    dto.setBarLineDTO(barLine);
                    dto.setUnit(CdbmEnum.getEumByCode("trainCount").getUnit());
                    dto.setLength(length);
                    //调用模型方法
                    this.run(dto);
                    break;
                case "dbl":
                    //达标率
                    dto.setUnit(CdbmEnum.getEumByCode("dbl").getUnit());
                    barLine = prdDayProdService.barLine(length,"dbl");
                    dto.setCurrentValue(prdDayProdService.currentValue("dbl")==null?new BigDecimal(0):prdDayProdService.currentValue("dbl"));
                    dto.setBarLineDTO(barLine);
                    dto.setLength(length);
                    //调用模型方法
                    this.run(dto);
                    break;
                case "hf":
                    //灰分
                    barLine = qualityQualityTrendDayService.barLine(length,"hf",param);
                    dto.setCurrentValue(qualityQualityTrendDayService.currentValue(param,"hf")==null?new BigDecimal(0):qualityQualityTrendDayService.currentValue(param,"hf"));
                    dto.setBarLineDTO(barLine);
                    dto.setUnit(CdbmEnum.getEumByCode("hf").getUnit());
                    dto.setLength(length);
                    //调用模型方法
                    this.run(dto);
                    break;
                case "lf":
                    //硫分
                    barLine = qualityQualityTrendDayService.barLine(length,"lf",param);
                    dto.setCurrentValue(qualityQualityTrendDayService.currentValue(param,"lf")==null?new BigDecimal(0):qualityQualityTrendDayService.currentValue(param,"lf"));
                    dto.setBarLineDTO(barLine);
                    dto.setUnit(CdbmEnum.getEumByCode("lf").getUnit());
                    dto.setLength(length);
                    //调用模型方法
                    this.run(dto);
                    break;
                case "sf":
                    //水分
                    barLine = qualityQualityTrendDayService.barLine(length,"sf",param);
                    dto.setCurrentValue(qualityQualityTrendDayService.currentValue(param,"sf")==null?new BigDecimal(0):qualityQualityTrendDayService.currentValue(param,"sf"));
                    dto.setBarLineDTO(barLine);
                    dto.setUnit(CdbmEnum.getEumByCode("sf").getUnit());
                    dto.setLength(length);
                    //调用模型方法
                    this.run(dto);
                    break;
                case "rz":
                    //热值
                    barLine = qualityQualityTrendDayService.barLine(length,"rz",param);
                    dto.setCurrentValue(qualityQualityTrendDayService.currentValue(param,"rz")==null?new BigDecimal(0):qualityQualityTrendDayService.currentValue(param,"rz"));
                    dto.setBarLineDTO(barLine);
                    dto.setUnit(CdbmEnum.getEumByCode("rz").getUnit());
                    dto.setLength(length);
                    //调用模型方法
                    this.run(dto);
                    break;
                case "point":
                    //测点
                    barLine = this.pointBarline(param,length);

                    dto.setBarLineDTO(barLine);
                    dto.setUnit(CdbmEnum.getEumByName(param).getUnit());
                    dto.setLength(length);
                    //调用模型方法
                    this.run(dto);
                    break;
                default:
                    break;
            }
        }catch (Exception e){
            e.printStackTrace();
            System.out.println(charsCode+"查图表渲染异常" + e.getMessage());
        }
        return dto;
    }

    private BarLineDTO pointBarline(String param,String length) {

        FeignQueryPointDTO dto = new FeignQueryPointDTO();
        dto.setEndTime(new Date());
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(new Date());
        calendar.add(Calendar.DAY_OF_YEAR, -Integer.parseInt(length));
        dto.setStartTime(calendar.getTime());
        dto.setPointCode(CdbmEnum.getEumByName(param).getCode());
        dto.setType("float");
        List<ApiDataDTO> list = iFeignDataApi.queryPointValues(dto);

        //封装echarsDto
        BarLineDTO barLineDTO = new BarLineDTO();
        List<String> legend = new ArrayList<>();
        List<String> categories = new ArrayList<>();
        List<SeriesItem> series = new ArrayList<>();
        SeriesItem seriesItem = new SeriesItem();
        seriesItem.setName(CdbmEnum.getEumByName(param).getDesc());
        List<Object[]> seriesData = new ArrayList<>();
        for (ApiDataDTO entity : list) {
            // 将数据作为图表数据
            seriesData.add(new Object[]{entity.getTimeStamp(), entity.getDataValue()});
        }
        seriesItem.setData(seriesData);
        series.add(seriesItem);
        barLineDTO.setLegend(legend);
        barLineDTO.setSeries(series);
        barLineDTO.setValueName(CdbmEnum.getEumByName(param).getDesc());

        return barLineDTO;

        }


    private PageCharsDTO run(PageCharsDTO dto){
        dto.setSuggest("暂无建议");
        dto.setSuggestTime(new Date());
        dto.setAvg("");
        dto.setMax("");
        dto.setMin("");
        return dto;
    }
}