|  |  | 
 |  |  | package com.dy.pipIrrProject.mqtt.manure; | 
 |  |  |  | 
 |  |  | import com.dy.common.webUtil.QueryResultVo; | 
 |  |  | import com.dy.pipIrrGlobal.daoPr.PrStManureMapper; | 
 |  |  | import com.dy.pipIrrGlobal.pojoPr.PrStManure; | 
 |  |  | import com.dy.pipIrrGlobal.voPr.VoManure; | 
 |  |  | import com.dy.pipIrrGlobal.voPr.VoMqttSimple; | 
 |  |  | import lombok.extern.slf4j.Slf4j; | 
 |  |  | import org.apache.dubbo.common.utils.PojoUtils; | 
 |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
 |  |  | import org.springframework.stereotype.Service; | 
 |  |  | import org.springframework.transaction.annotation.Transactional; | 
 |  |  |  | 
 |  |  | import java.util.List; | 
 |  |  | import java.util.Map; | 
 |  |  |  | 
 |  |  | /** | 
 |  |  |  * @Author: liurunyu | 
 |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 根据指定条件查询记录 | 
 |  |  |      * | 
 |  |  |      * @param queryVo 查询值对象 | 
 |  |  |      * @return 记录列表 | 
 |  |  |      */ | 
 |  |  |     public QueryResultVo<List<VoManure>> selectSome(QueryVo queryVo) { | 
 |  |  |         Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo); | 
 |  |  |         Long itemTotal = dao.totalCount(params); | 
 |  |  |  | 
 |  |  |         QueryResultVo<List<VoManure>> rsVo = new QueryResultVo<>(); | 
 |  |  |         rsVo.pageSize = queryVo.pageSize; | 
 |  |  |         rsVo.pageCurr = queryVo.pageCurr; | 
 |  |  |         rsVo.calculateAndSet(itemTotal, params); | 
 |  |  |         rsVo.obj = dao.selectSome(params); | 
 |  |  |         return rsVo; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 得到一个实体 | 
 |  |  |      * @param id 实体ID | 
 |  |  |      * @return 实体 | 
 |  |  |      */ | 
 |  |  |     public PrStManure selectById(Long id){ | 
 |  |  |         return this.dao.selectById(id) ; | 
 |  |  |     public VoManure selectOne(Long id){ | 
 |  |  |         return this.dao.selectOne(id) ; | 
 |  |  |     } | 
 |  |  |     /** | 
 |  |  |      * 保存(添加)视频监控点 |