From 539ee846f2a3a828b7c2b057325fbc2c85e04af4 Mon Sep 17 00:00:00 2001
From: lxw <810412026@qq.com>
Date: 星期四, 09 十一月 2023 17:08:10 +0800
Subject: [PATCH] 远程升级和停止
---
src/main/java/com/whyc/service/DevUpdateStateService.java | 60 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 60 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/whyc/service/DevUpdateStateService.java b/src/main/java/com/whyc/service/DevUpdateStateService.java
index 7ddc4bf..068cedf 100644
--- a/src/main/java/com/whyc/service/DevUpdateStateService.java
+++ b/src/main/java/com/whyc/service/DevUpdateStateService.java
@@ -1,7 +1,67 @@
package com.whyc.service;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.whyc.mapper.DevUpdateStateMapper;
+import com.whyc.pojo.DevUpdateState;
+import com.whyc.pojo.Response;
+import com.whyc.util.FileDirPath;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.File;
+import java.io.IOException;
+
+import static com.whyc.util.ActionUtil.createFilefolderIFNotExist;
@Service
public class DevUpdateStateService {
+ @Autowired(required = false)
+ private DevUpdateStateMapper mapper;
+ //妫�娴嬫槸鍚﹀瓨鍦ㄩ噸鏂颁笂浼犵殑浜鸿劯
+ public boolean updateDfu(MultipartFile file,int devId){
+ boolean bl=false;
+ String fileDirName = FileDirPath.getFileDirName();
+ String root=fileDirName+ File.separator+"FDFiles"+File.separator+devId+File.separator+"update";
+ String fileFileName = file.getOriginalFilename();
+ String filePath = root + fileFileName;
+ createFilefolderIFNotExist(filePath);
+ try {
+ file.transferTo(new File(filePath));
+ bl=true;
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ return bl;
+
+ }
+ //杩滅▼鍗囩骇
+ public Response updateDfu(MultipartFile file, DevUpdateState dfu) {
+ if(file==null){
+ return new Response().set(1,false,"鏂囦欢澶辫触,鏂囦欢涓嶅瓨鍦�");
+ }
+ String fileFileName = file.getOriginalFilename();
+ boolean bl=updateDfu(file,dfu.getDevId());
+ if(bl){
+ UpdateWrapper wrapper=new UpdateWrapper();
+ wrapper.set("dfu_file",fileFileName);
+ wrapper.set("dfu_en",1);
+ wrapper.set("dfu_wr_stat",dfu.getDfuWrStat());
+ wrapper.set("dfu_data_blocknum",dfu.getDfuDataBlocknum());
+ wrapper.eq("dev_id",dfu.getDevId());
+ mapper.update(null,wrapper);
+ return new Response().set(1,bl,"鍗囩骇鏂囦欢涓婁紶鎴愬姛");
+ }else {
+ return new Response().set(1,bl,"鍗囩骇鏂囦欢涓婁紶澶辫触");
+ }
+
+ }
+ //杩滅▼鍗囩骇鍋滄
+ public Response stopDfu(int devId) {
+ UpdateWrapper wrapper=new UpdateWrapper();
+ wrapper.set("dfu_en",3);
+ wrapper.eq("dev_id",devId);
+ mapper.update(null,wrapper);
+ return new Response().set(1,true);
+ }
}
--
Gitblit v1.9.1