|  |  |  | 
|---|
|  |  |  | package com.dy.pipIrrRemote.report; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.dy.common.mw.protocol.p206V1_0_0.CommonV1_0_1; | 
|---|
|  |  |  | import com.dy.common.mw.protocol.p206V1.CommonV1; | 
|---|
|  |  |  | import com.dy.common.webUtil.QueryResultVo; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.daoRm.*; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voRm.VoOnHour; | 
|---|
|  |  |  | 
|---|
|  |  |  | import org.apache.dubbo.common.utils.PojoUtils; | 
|---|
|  |  |  | import org.springframework.stereotype.Service; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.time.LocalDate; | 
|---|
|  |  |  | import java.time.LocalDateTime; | 
|---|
|  |  |  | import java.util.List; | 
|---|
|  |  |  | import java.util.Map; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public QueryResultVo<List<VoOpenCloseValve>> getOpenCloseValveReports_history(OpenCloseValveQO qo) { | 
|---|
|  |  |  | qo.completionTimeNoEmpty() ; | 
|---|
|  |  |  | //下面由completionTimeNoEmpty()改为completionTime()原因, | 
|---|
|  |  |  | //开关阀记录中开阀时间和关阀时间有时不会同时有值,可能其中任一个是null值,如果用时间条件查询,则这样的记录就查不出来了。 | 
|---|
|  |  |  | //如果要缩小所查询记录的范围(数量),则可从记录ID上设备一个范围。 | 
|---|
|  |  |  | //qo.completionTimeNoEmpty() ; | 
|---|
|  |  |  | qo.completionTime() ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo); | 
|---|
|  |  |  | Long itemTotal = rmOpenCloseValveHistoryMapper.getOpenCloseValveReportsCount_history(params); | 
|---|
|  |  |  | 
|---|
|  |  |  | List<VoOpenCloseValve> list = rmOpenCloseValveHistoryMapper.getOpenCloseValveReports_history(params); | 
|---|
|  |  |  | if (list != null && list.size() > 0) { | 
|---|
|  |  |  | for (VoOpenCloseValve vo : list) { | 
|---|
|  |  |  | vo.setOpenType(CommonV1_0_1.openCloseValveType(vo.getOpenType_()==null?(byte)100:vo.getOpenType_())); | 
|---|
|  |  |  | vo.setCloseType(CommonV1_0_1.openCloseValveType(vo.getCloseType_()==null?(byte)100:vo.getCloseType_())); | 
|---|
|  |  |  | vo.setOpenType(CommonV1.openCloseValveType(vo.getOpType()==null?(byte)100:vo.getOpType())); | 
|---|
|  |  |  | if(vo.getClType() != null) { | 
|---|
|  |  |  | vo.setCloseType(CommonV1.openCloseValveType(vo.getClType() == null ? (byte) 100 : vo.getClType())); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | vo.setCloseType(""); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | rsVo.obj = list; | 
|---|
|  |  |  | 
|---|
|  |  |  | List<VoOpenCloseValve> list = rmOpenCloseValveLastMapper.getOpenCloseValveReports_last(params); | 
|---|
|  |  |  | if (list != null && list.size() > 0) { | 
|---|
|  |  |  | for (VoOpenCloseValve vo : list) { | 
|---|
|  |  |  | vo.setOpenType(CommonV1_0_1.openCloseValveType(vo.getOpenType_()==null?(byte)100:vo.getOpenType_())); | 
|---|
|  |  |  | vo.setCloseType(CommonV1_0_1.openCloseValveType(vo.getCloseType_()==null?(byte)100:vo.getCloseType_())); | 
|---|
|  |  |  | vo.setOpenType(CommonV1.openCloseValveType(vo.getOpType()==null?(byte)100:vo.getOpType())); | 
|---|
|  |  |  | if(vo.getClType() != null){ | 
|---|
|  |  |  | vo.setCloseType(CommonV1.openCloseValveType(vo.getClType()==null?(byte)100:vo.getClType())); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | vo.setCloseType(""); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | rsVo.obj = list; | 
|---|