| | |
| | | package com.dy.pipIrrProject.mqtt.weather; |
| | | |
| | | import com.dy.common.webUtil.QueryResultVo; |
| | | import com.dy.pipIrrGlobal.daoPr.PrStWeatherMapper; |
| | | import com.dy.pipIrrGlobal.pojoPr.PrStWeather; |
| | | import com.dy.pipIrrGlobal.voPr.VoMqttSimple; |
| | | import com.dy.pipIrrGlobal.voPr.VoWeather; |
| | | import com.dy.pipIrrProject.mqtt.manure.QueryVo; |
| | | 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 |
| | |
| | | public List<VoMqttSimple> allSimple(){ |
| | | return this.dao.selectAllSimple() ; |
| | | } |
| | | /** |
| | | * 根据指定条件查询记录 |
| | | * |
| | | * @param queryVo 查询值对象 |
| | | * @return 记录列表 |
| | | */ |
| | | public QueryResultVo<List<VoWeather>> selectSome(QueryVo queryVo) { |
| | | Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo); |
| | | Long itemTotal = dao.totalCount(params); |
| | | |
| | | QueryResultVo<List<VoWeather>> 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 PrStWeather selectById(Long id){ |
| | | return this.dao.selectById(id) ; |
| | | public VoWeather selectOne(Long id){ |
| | | return this.dao.selectOne(id) ; |
| | | } |
| | | /** |
| | | * 保存(添加)视频监控点 |