| 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) ; | 
|     } | 
|   | 
| } |