|  |  |  | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.daoRm.UgRtuControllerMapper; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.daoRm.UgRtuProgramMapper; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.daoRm.UgRtuTaskMapper; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.pojoRm.UgRtuProgram; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.pojoRm.UgRtuTask; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voRm.VoUpgradeDetail; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.pojoUg.UgRtuProgram; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.pojoUg.UgRtuTask; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voUg.VoUpgradeDetail; | 
|---|
|  |  |  | import lombok.extern.slf4j.Slf4j; | 
|---|
|  |  |  | import org.apache.dubbo.common.utils.PojoUtils; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 查询一个升级任务有关信息 | 
|---|
|  |  |  | * @return 升级任务有关信息 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public List<VoUpgradeDetail> selectTaskDetail(String taskId){ | 
|---|
|  |  |  | return this.tdao.selectTaskDetail(Long.valueOf(taskId)) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 保存升级任务为执行状态 | 
|---|
|  |  |  | * @param taskId 任务ID | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public void setUpgradeTaskExecuted(String taskId){ | 
|---|
|  |  |  | this.tdao.executeById(Long.valueOf(taskId)) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 保存RTU升级结束状态 | 
|---|
|  |  |  | * @param taskId | 
|---|
|  |  |  | * @param rtu | 
|---|
|  |  |  | 
|---|
|  |  |  | cdao.updateRtuUpgradeState(params) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ///////////////////////////////////////////////////// | 
|---|
|  |  |  | // | 
|---|
|  |  |  | // 以下模拟数据 | 
|---|
|  |  |  | // | 
|---|
|  |  |  | ///////////////////////////////////////////////////// | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 通信主键查询一个升级任务 | 
|---|
|  |  |  | * 查询一个升级任务有关信息 | 
|---|
|  |  |  | * @return 升级任务有关信息 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public VoUpgradeDetail selectTaskDetail(String taskId){ | 
|---|
|  |  |  | List<VoUpgradeDetail> list = this.tdao.selectTaskDetail(Long.valueOf(taskId)) ; | 
|---|
|  |  |  | if(list != null && list.size() > 0){ | 
|---|
|  |  |  | return list.get(0) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return null ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 保存升级任务为执行状态 | 
|---|
|  |  |  | * @param taskId 任务ID | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public void setUpgradeTaskExecuted(String taskId){ | 
|---|
|  |  |  | this.tdao.executeById(Long.valueOf(taskId)) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 设置升级任务已经完成 | 
|---|
|  |  |  | * @param taskId | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public void updateTaskOver(String taskId){ | 
|---|
|  |  |  | tdao.overById(Long.valueOf(taskId)) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ///////////////////////////////////////////////////// | 
|---|
|  |  |  | // | 
|---|
|  |  |  | // 以下演示升级功能用到 | 
|---|
|  |  |  | // | 
|---|
|  |  |  | ///////////////////////////////////////////////////// | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 查询最新一个升级任务 | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public UgRtuTask selectLastTask(){ | 
|---|
|  |  |  | return tdao.selectLastTask(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|