From 4f99f59668c9160ca60958b7347944def26f2228 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期日, 27 四月 2025 10:58:53 +0800
Subject: [PATCH] 回退配置
---
pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtuUpgrage/RtuUpgradeSv.java | 114 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 114 insertions(+), 0 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
new file mode 100644
index 0000000..018f0dc
--- /dev/null
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtuUpgrage/RtuUpgradeSv.java
@@ -0,0 +1,114 @@
+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.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
+ * @Date: 2024/11/12 8:33
+ * @Description
+ */
+@Slf4j
+@Service
+public class RtuUpgradeSv {
+ @Autowired
+ private UgRtuTaskMapper tdao ;
+ @Autowired
+ private UgRtuProgramMapper pdao ;
+ @Autowired
+ private UgRtuControllerMapper cdao ;
+
+ /**
+ * 閫氫俊涓婚敭鏌ヨ涓�涓崌绾т换鍔�
+ * @param taskId 涓婚敭
+ * @return
+ */
+ public UgRtuTask selectTaskById(String taskId){
+ return tdao.selectByPrimaryKey(Long.valueOf(taskId));
+ }
+
+ /**
+ * 閫氫俊涓婚敭鏌ヨ涓�涓崌绾х▼搴�
+ * @param id 涓婚敭
+ * @return
+ */
+ public UgRtuProgram selectProgramById(Long id){
+ return pdao.selectByPrimaryKey(id);
+ }
+
+ /**
+ * 鏌ヨ涓�涓崌绾т换鍔℃墍鏈夋帶鍒跺櫒鍦板潃
+ * @return 涓�浜涗竴浜涙帶鍒跺櫒鍦板潃
+ */
+ public List<String> selectAllRtuAddrByTask(String taskId){
+ return this.cdao.selectAllRtuAddrByTask(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 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();
+ }
+}
--
Gitblit v1.8.0