package com.dy.pipIrrRemote.report; 
 | 
  
 | 
import com.dy.common.aop.SsoAop; 
 | 
import com.dy.common.webUtil.BaseResponse; 
 | 
import com.dy.common.webUtil.BaseResponseUtils; 
 | 
import com.dy.common.webUtil.QueryResultVo; 
 | 
import com.dy.pipIrrGlobal.voRm.VoOnHour; 
 | 
import com.dy.pipIrrGlobal.voRm.VoOpenCloseValve; 
 | 
import com.dy.pipIrrGlobal.voRm.VoTiming; 
 | 
import com.dy.pipIrrGlobal.voRm.VoWork; 
 | 
import com.dy.pipIrrRemote.report.qo.OnHourQO; 
 | 
import com.dy.pipIrrRemote.report.qo.OpenCloseValveQO; 
 | 
import lombok.RequiredArgsConstructor; 
 | 
import lombok.extern.slf4j.Slf4j; 
 | 
import org.springframework.web.bind.annotation.GetMapping; 
 | 
import org.springframework.web.bind.annotation.RequestMapping; 
 | 
import org.springframework.web.bind.annotation.RestController; 
 | 
  
 | 
import java.util.List; 
 | 
  
 | 
/** 
 | 
 * @author ZhuBaoMin 
 | 
 * @date 2024-07-23 16:01 
 | 
 * @LastEditTime 2024-07-23 16:01 
 | 
 * @Description 各类数据报控制类 
 | 
 */ 
 | 
  
 | 
@Slf4j 
 | 
@RestController 
 | 
@RequestMapping(path = "report") 
 | 
@RequiredArgsConstructor 
 | 
public class ReportCtrl { 
 | 
    private final ReportSv reportSv; 
 | 
  
 | 
    /** 
 | 
     * 根据指定条件获取整点报历史记录 
 | 
     * @param qo 
 | 
     * @return 
 | 
     */ 
 | 
    @GetMapping(path = "/on_hour_report_history") 
 | 
    @SsoAop() 
 | 
    public BaseResponse<QueryResultVo<List<VoOnHour>>> getOnHourReportHistory(OnHourQO qo){ 
 | 
        try { 
 | 
            return BaseResponseUtils.buildSuccess(reportSv.getOnHourReportsHistory(qo)); 
 | 
        } catch (Exception e) { 
 | 
            return BaseResponseUtils.buildException(e.getMessage()) ; 
 | 
        } 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据指定条件获取整点报最新记录 
 | 
     * @param qo 
 | 
     * @return 
 | 
     */ 
 | 
    @GetMapping(path = "/on_hour_report_last") 
 | 
    @SsoAop() 
 | 
    public BaseResponse<QueryResultVo<List<VoOnHour>>> getOnHourReportLast(OnHourQO qo){ 
 | 
        try { 
 | 
            return BaseResponseUtils.buildSuccess(reportSv.getOnHourReportsLast(qo)); 
 | 
        } catch (Exception e) { 
 | 
            return BaseResponseUtils.buildException(e.getMessage()) ; 
 | 
        } 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据指定条件获取开关阀报历史记录 
 | 
     * @param qo 
 | 
     * @return 
 | 
     */ 
 | 
    @GetMapping(path = "/opem_close_valve_report_history") 
 | 
    @SsoAop() 
 | 
    public BaseResponse<QueryResultVo<List<VoOpenCloseValve>>> getOpenCloseValveReportHistory(OpenCloseValveQO qo){ 
 | 
        try { 
 | 
            return BaseResponseUtils.buildSuccess(reportSv.getOpenCloseValveReports_history(qo)); 
 | 
        } catch (Exception e) { 
 | 
            return BaseResponseUtils.buildException(e.getMessage()) ; 
 | 
        } 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据指定条件获取开关阀报最新记录 
 | 
     * @param qo 
 | 
     * @return 
 | 
     */ 
 | 
    @GetMapping(path = "/opem_close_valve_report_last") 
 | 
    @SsoAop() 
 | 
    public BaseResponse<QueryResultVo<List<VoOpenCloseValve>>> getOpenCloseValveReportLast(OpenCloseValveQO qo){ 
 | 
        try { 
 | 
            return BaseResponseUtils.buildSuccess(reportSv.getOpenCloseValveReports_last(qo)); 
 | 
        } catch (Exception e) { 
 | 
            return BaseResponseUtils.buildException(e.getMessage()) ; 
 | 
        } 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据指定条件获取定时报历史记录 
 | 
     * @param qo 
 | 
     * @return 
 | 
     */ 
 | 
    @GetMapping(path = "/timing_report_history") 
 | 
    @SsoAop() 
 | 
    public BaseResponse<QueryResultVo<List<VoTiming>>> getTimingReportHistory(OnHourQO qo){ 
 | 
        try { 
 | 
            return BaseResponseUtils.buildSuccess(reportSv.getTimingReportsHistory(qo)); 
 | 
        } catch (Exception e) { 
 | 
            return BaseResponseUtils.buildException(e.getMessage()) ; 
 | 
        } 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据指定条件获取定时报最新记录 
 | 
     * @param qo 
 | 
     * @return 
 | 
     */ 
 | 
    @GetMapping(path = "/timing_report_last") 
 | 
    @SsoAop() 
 | 
    public BaseResponse<QueryResultVo<List<VoTiming>>> getTimingReportLast(OnHourQO qo){ 
 | 
        try { 
 | 
            return BaseResponseUtils.buildSuccess(reportSv.getTimingReportsLast(qo)); 
 | 
        } catch (Exception e) { 
 | 
            return BaseResponseUtils.buildException(e.getMessage()) ; 
 | 
        } 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据指定条件获取工作报历史记录 
 | 
     * @param qo 
 | 
     * @return 
 | 
     */ 
 | 
    @GetMapping(path = "/work_report_history") 
 | 
    @SsoAop() 
 | 
    public BaseResponse<QueryResultVo<List<VoWork>>> getWorkReportHistory(OnHourQO qo){ 
 | 
        try { 
 | 
            return BaseResponseUtils.buildSuccess(reportSv.getWorkReportsHistory(qo)); 
 | 
        } catch (Exception e) { 
 | 
            return BaseResponseUtils.buildException(e.getMessage()) ; 
 | 
        } 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据指定条件获取工作报最新记录 
 | 
     * @param qo 
 | 
     * @return 
 | 
     */ 
 | 
    @GetMapping(path = "/work_report_last") 
 | 
    @SsoAop() 
 | 
    public BaseResponse<QueryResultVo<List<VoWork>>> getWorkReportLast(OnHourQO qo){ 
 | 
        try { 
 | 
            return BaseResponseUtils.buildSuccess(reportSv.getWorkReportsLast(qo)); 
 | 
        } catch (Exception e) { 
 | 
            return BaseResponseUtils.buildException(e.getMessage()) ; 
 | 
        } 
 | 
    } 
 | 
} 
 |