package com.dy.pipIrrBase.rtuUpgrade.program; 
 | 
  
 | 
import com.dy.common.webUtil.QueryResultVo; 
 | 
import com.dy.pipIrrGlobal.daoRm.UgRtuProgramMapper; 
 | 
import com.dy.pipIrrGlobal.pojoUg.UgRtuProgram; 
 | 
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 
 | 
 * @Date: 2024/11/5 8:33 
 | 
 * @Description 
 | 
 */ 
 | 
@Slf4j 
 | 
@Service 
 | 
public class UgRtuProgramSv { 
 | 
  
 | 
    @Autowired 
 | 
    private UgRtuProgramMapper dao ; 
 | 
  
 | 
    /** 
 | 
     * 得到一个一些升级程序 
 | 
     * @param id 一些升级程序ID 
 | 
     * @return 一些升级程序实体 
 | 
     */ 
 | 
    public UgRtuProgram selectById(Long id){ 
 | 
        return this.dao.selectByPrimaryKey(id) ; 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 得到一些升级程序 
 | 
     * @return 一些升级程序 
 | 
     */ 
 | 
    public QueryResultVo<List<UgRtuProgram>> selectSome(QueryVo queryVo){ 
 | 
        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo) ; 
 | 
        Long itemTotal = this.dao.selectTotal(params) ; 
 | 
  
 | 
        QueryResultVo<List<UgRtuProgram>> rsVo = new QueryResultVo<>() ; 
 | 
        rsVo.pageSize = queryVo.pageSize ; 
 | 
        rsVo.pageCurr = queryVo.pageCurr ; 
 | 
        rsVo.calculateAndSet(itemTotal, params); 
 | 
        rsVo.obj = this.dao.selectSome(params) ; 
 | 
  
 | 
        return rsVo ; 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 得到所有升级程序记录ID和文件名称 
 | 
     * @return 一些升级程序 
 | 
     */ 
 | 
    public QueryResultVo<List<UgRtuProgram>> selectAll(){ 
 | 
        QueryResultVo<List<UgRtuProgram>> rsVo = new QueryResultVo<>() ; 
 | 
        rsVo.obj = this.dao.selectAll() ; 
 | 
        return rsVo ; 
 | 
    } 
 | 
    /** 
 | 
     * 查询数据库,是否存在给定升级文件名称 
 | 
     * @param programFileName 文件名称 
 | 
     * @return bool 
 | 
     */ 
 | 
    public boolean existFileName(String programFileName){ 
 | 
        Long count = this.dao.selectByFileName(programFileName) ; 
 | 
        if(count != null && count > 0){ 
 | 
            return true ; 
 | 
        }else{ 
 | 
            return false ; 
 | 
        } 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 新增保存分水口实体 
 | 
     * @param po 实体 
 | 
     * @return 数量 
 | 
     */ 
 | 
    @Transactional 
 | 
    public int save(UgRtuProgram po){ 
 | 
        return this.dao.insertSelective(po) ; 
 | 
    } 
 | 
    /** 
 | 
     * 保存修改实体 
 | 
     * @param po 实体 
 | 
     * @return 数量 
 | 
     */ 
 | 
    @Transactional 
 | 
    public int update(UgRtuProgram po){ 
 | 
        return this.dao.updateByPrimaryKeySelective(po) ; 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 逻辑删除实体 
 | 
     * @param id 实体ID 
 | 
     * @return 数量 
 | 
     */ 
 | 
    @Transactional 
 | 
    public int delete(Long id){ 
 | 
        return this.dao.deleteLogicById(id) ; 
 | 
    } 
 | 
  
 | 
} 
 |