From f628dd00d8f99b37a128243b941bb8cfefd02ac9 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期四, 14 十一月 2024 10:36:08 +0800
Subject: [PATCH] 1、优远程升级相关代码; 2、修改升级监视功能模块代码。

---
 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtuUpgrage/RtuUpgradeSv.java |   59 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 56 insertions(+), 3 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtuUpgrage/RtuUpgradeSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtuUpgrage/RtuUpgradeSv.java
index 59aa42f..3293427 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtuUpgrage/RtuUpgradeSv.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtuUpgrage/RtuUpgradeSv.java
@@ -1,15 +1,20 @@
 package com.dy.pipIrrRemote.rtuUpgrage;
 
+import com.dy.common.softUpgrade.state.UpgradeRtu;
 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.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;
 import org.springframework.stereotype.Service;
 
+import java.util.Date;
 import java.util.List;
+import java.util.Map;
 
 /**
  * @Author: liurunyu
@@ -28,7 +33,7 @@
 
     /**
      * 閫氫俊涓婚敭鏌ヨ涓�涓崌绾т换鍔�
-     * @param id 涓婚敭
+     * @param taskId 涓婚敭
      * @return
      */
     public UgRtuTask selectTaskById(String taskId){
@@ -51,4 +56,52 @@
     public List<String> selectAllRtuAddrByTask(String taskId){
         return this.cdao.selectAllRtuAddrByTask(Long.valueOf(taskId)) ;
     }
+
+    /**
+     * 鏌ヨ涓�涓崌绾т换鍔℃湁鍏充俊鎭�
+     * @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)) ;
+    }
+
+
+    /**
+     * 淇濆瓨RTU鍗囩骇缁撴潫鐘舵��
+     * @param taskId
+     * @param rtu
+     */
+    public void saveRtuUpgradeState(Long taskId, UpgradeRtu rtu){
+        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(rtu) ;
+        params.put("taskId", taskId) ;
+        params.put("overDt", new Date()) ;
+        cdao.updateRtuUpgradeState(params) ;
+    }
+
+    /////////////////////////////////////////////////////
+    //
+    // 浠ヤ笅妯℃嫙鏁版嵁
+    //
+    /////////////////////////////////////////////////////
+    /**
+     * 閫氫俊涓婚敭鏌ヨ涓�涓崌绾т换鍔�
+     * @return
+     */
+    public UgRtuTask selectLastTask(){
+        return tdao.selectLastTask();
+    }
+
 }

--
Gitblit v1.8.0