package com.dy.pipIrrRemote.report;
|
|
import com.dy.common.webUtil.QueryResultVo;
|
import com.dy.pipIrrGlobal.daoRm.*;
|
import com.dy.pipIrrGlobal.voRm.VoOnHour;
|
import com.dy.pipIrrRemote.report.qo.ReportQO;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.dubbo.common.utils.PojoUtils;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @author ZhuBaoMin
|
* @date 2024-07-23 16:02
|
* @LastEditTime 2024-07-23 16:02
|
* @Description 各类数据报服务类
|
*/
|
|
@Slf4j
|
@Service
|
@RequiredArgsConstructor
|
public class ReportSv {
|
// 阀控器整点报DAO
|
private final RmOnHourReportHistoryMapper rmOnHourReportHistoryMapper;
|
private final RmOnHourReportLastMapper rmOnHourReportLastMapper;
|
|
// 阀控器开关阀报DAO
|
private final RmOpenCloseValveHistoryMapper rmOpenCloseValveHistoryMapper;
|
private final RmOpenCloseValveLastMapper rmOpenCloseValveLastMapper;
|
|
// 阀控器定时报DAO
|
private final RmTimingReportHistoryMapper rmTimingReportHistoryMapper;
|
private final RmTimingReportLastMapper rmTimingReportLastMapper;
|
|
// 工作报DAO
|
private final RmWorkReportHistoryMapper rmWorkReportHistoryMapper;
|
private final RmWorkReportLastMapper rmWorkReportLastMapper;
|
|
/**
|
* 根据指定条件获取整点报历史记录
|
* @param qo
|
* @return
|
*/
|
public QueryResultVo<List<VoOnHour>> getOnHourReportsHistory(ReportQO qo) {
|
String timeStart = qo.getTimeStart();
|
String timeStop = qo.getTimeStop();
|
if(timeStart != null) {
|
timeStart = timeStart + " 00:00:00";
|
qo.setTimeStart(timeStart);
|
}
|
if(timeStop != null) {
|
timeStop = timeStop + " 23:59:59";
|
qo.setTimeStop(timeStop);
|
}
|
|
Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo);
|
Long itemTotal = rmOnHourReportHistoryMapper.getOnHourReportsCount_history(params);
|
|
QueryResultVo<List<VoOnHour>> rsVo = new QueryResultVo<>() ;
|
rsVo.pageSize = qo.pageSize ;
|
rsVo.pageCurr = qo.pageCurr ;
|
|
rsVo.calculateAndSet(itemTotal, params);
|
rsVo.obj = rmOnHourReportHistoryMapper.getOnHourReports_history(params);
|
return rsVo ;
|
}
|
|
|
}
|
