package com.dy.pipIrrRemote.mqttSd1.manure; 
 | 
  
 | 
import com.dy.common.webUtil.QueryResultVo; 
 | 
import com.dy.pipIrrGlobal.daoRm.RmManureHistoryMapper; 
 | 
import com.dy.pipIrrGlobal.daoRm.RmManureLastMapper; 
 | 
import com.dy.pipIrrGlobal.voRm.VoManure; 
 | 
import lombok.RequiredArgsConstructor; 
 | 
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 java.util.List; 
 | 
import java.util.Map; 
 | 
  
 | 
/** 
 | 
 * @Author: liurunyu 
 | 
 * @Date: 2025/6/25 16:18 
 | 
 * @Description 
 | 
 */ 
 | 
@Slf4j 
 | 
@Service("rmManureSv") 
 | 
@RequiredArgsConstructor 
 | 
public class ManureSv { 
 | 
  
 | 
    @Autowired 
 | 
    private RmManureHistoryMapper rmManureHistoryDao ; 
 | 
    @Autowired 
 | 
    private RmManureLastMapper rmManureLastDao ; 
 | 
  
 | 
    public VoManure oneLast(Long manureId) { 
 | 
        List<VoManure> list = this.rmManureLastDao.selectSomeByManureId(manureId) ; 
 | 
        if(list != null && list.size() > 0) { 
 | 
            return list.get(0) ; 
 | 
        } 
 | 
        return null ; 
 | 
    } 
 | 
  
 | 
    public QueryResultVo<List<VoManure>> oneHistory(ManureQo qo) { 
 | 
        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo); 
 | 
        Long itemTotal = rmManureHistoryDao.selectCount(params); 
 | 
  
 | 
        QueryResultVo<List<VoManure>> rsVo = new QueryResultVo<>() ; 
 | 
        rsVo.pageSize = qo.pageSize ; 
 | 
        rsVo.pageCurr = qo.pageCurr ; 
 | 
  
 | 
        rsVo.calculateAndSet(itemTotal, params); 
 | 
        rsVo.obj = rmManureHistoryDao.selectSome(params); 
 | 
        return rsVo ; 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据指定条件查询最新记录 
 | 
     * @param qo 
 | 
     * @return 
 | 
     */ 
 | 
    public QueryResultVo<List<VoManure>> someLast(ManureQo qo) { 
 | 
        qo.completionTime(); 
 | 
  
 | 
        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo); 
 | 
        Long itemTotal = rmManureLastDao.selectCount(params); 
 | 
  
 | 
        QueryResultVo<List<VoManure>> rsVo = new QueryResultVo<>() ; 
 | 
        rsVo.pageSize = qo.pageSize ; 
 | 
        rsVo.pageCurr = qo.pageCurr ; 
 | 
  
 | 
        rsVo.calculateAndSet(itemTotal, params); 
 | 
        rsVo.obj = rmManureLastDao.selectSome(params); 
 | 
        return rsVo ; 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据指定条件查询历史记录 
 | 
     * @param qo 
 | 
     * @return 
 | 
     */ 
 | 
    public QueryResultVo<List<VoManure>> someHistory(ManureQo qo) { 
 | 
        qo.completionTime(); 
 | 
  
 | 
        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo); 
 | 
        Long itemTotal = rmManureHistoryDao.selectCount(params); 
 | 
  
 | 
        QueryResultVo<List<VoManure>> rsVo = new QueryResultVo<>() ; 
 | 
        rsVo.pageSize = qo.pageSize ; 
 | 
        rsVo.pageCurr = qo.pageCurr ; 
 | 
  
 | 
        rsVo.calculateAndSet(itemTotal, params); 
 | 
        rsVo.obj = rmManureHistoryDao.selectSome(params); 
 | 
        return rsVo ; 
 | 
    } 
 | 
  
 | 
} 
 |