sis-background/gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/custom/GoldenService.java

package com.gyee.sampleimpala.service.custom;


import com.gyee.sampleimpala.common.exception.CustomException;
import com.gyee.sampleimpala.common.feign.RemoteServiceBuilder;
import com.gyee.sampleimpala.common.result.ResultCode;
import com.gyee.sampleimpala.model.custom.TsPointData;
import com.gyee.sampleimpala.model.kudu.Caseperformance;
import com.gyee.sampleimpala.model.kudu.Windturbinepoint;
import com.gyee.sampleimpala.service.kudu.CaseperformanceService;
import com.gyee.sampleimpala.service.kudu.WindturbinepointService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Slf4j
@Service
public class GoldenService {

    @Autowired
    private RemoteServiceBuilder remoteService;

    @Autowired
    private WindturbinepointService windturbinepointService;


    @Autowired
    private CaseperformanceService caseperformanceService;


    /**
     * 查询原始数据
     * @param points
     * @param startTs  精确到毫秒
     * @param endTs
     * @param interval
     * @return
     */
    public List<Map> getOriginalData(String[] points, long startTs, long endTs, int interval){

        List<Map> list = new ArrayList<>();

        try{

            for (String point :points){
                Windturbinepoint w =  windturbinepointService.getByPoint(point);
                List<TsPointData> data = new ArrayList<>();
                Map m = new HashMap();
                if (interval <= 0){
                    data = remoteService.ShardingService().getHistoryRaw(point, startTs, endTs);
                }else {
                    data = remoteService.ShardingService().getHistorySnap(point, startTs, endTs, interval);
                }
                m.put("name",w.getPointdes());
                m.put("code",w.getWidgetcode());
                m.put("point",w.getPoint());
                m.put("list",data);
                list.add(m);
            }

        } catch (Exception e){
            log.error(e.getMessage());
            throw new CustomException(ResultCode.ERROR_DATA);
        }

        return list;
    }




    public List<Map> getOriginalData(Integer[] id, int interval){
        for (Integer i :id ){
            Caseperformance cp = caseperformanceService.getPerformanceByid(i);

//            data = remoteService.ShardingService().getHistorySnap(point, startTs, endTs, interval);
        }

        return null;

    }
}