AppService.java
3.94 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
package com.ruoyi.service;
import com.ruoyi.common.config.RuoYiConfig;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.file.FileUploadUtils;
import com.ruoyi.common.utils.file.FileUtils;
import com.ruoyi.equipment.domain.Equipment;
import com.ruoyi.equipment.mapper.EquipmentMapper;
import com.ruoyi.framework.config.ServerConfig;
import com.ruoyi.pojo.request.HeartPackageVo;
import com.ruoyi.pojo.response.ApplicationResponseVo;
import com.ruoyi.upgrade.domain.VersionUpgrade;
import com.ruoyi.upgrade.mapper.VersionUpgradeMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.nio.file.Paths;
import java.util.Date;
import java.util.Objects;
import static com.ruoyi.common.ConstEquipmentProperties.DEVICE_ONLINE;
/**
* 应用service
*/
@Service
public class AppService {
@Value("${api.apk.path}")
String apkPath;
@Autowired
private EquipmentMapper equipmentMapper;
@Autowired
private ServerConfig serverConfig;
@Autowired
private VersionUpgradeMapper versionUpgradeMapper;
public ApplicationResponseVo checkVersionNum(Integer versionNum) {
// 比对版本 需要更新 判断是否需要强制更新
VersionUpgrade vu = versionUpgradeMapper.queryLatestVersionNum();
// 无需更新
if (!Objects.isNull(vu) && vu.getVersionCode().equals(versionNum)){
return ApplicationResponseVo.ApplicationResponseVoBuild().appNoUpdate(versionNum);
}
// 更新判断
return ApplicationResponseVo.ApplicationResponseVoBuild().appForceUpdate(vu.getVersionCode(),vu.getApkUrl());
}
public void downloadApk(String url, HttpServletResponse response) throws IOException {
// 把文件写入响应体
String realFileName = url.substring(url.indexOf("_") + 1);
response.setContentType(MediaType.APPLICATION_OCTET_STREAM_VALUE);
FileUtils.setAttachmentResponseHeader(response, realFileName);
FileUtils.writeBytes(RuoYiConfig.getUploadPath() + url, response.getOutputStream());
}
public AjaxResult uploadApk(MultipartFile file) throws IOException {
// 校验文件
checkFile(file);
// 上传文件路径
String filePath = RuoYiConfig.getUploadPath() + apkPath;
// 上传并返回新文件名称
String fileName = "app.apk";
// 获取相对路径
String absPath = FileUploadUtils.getAbsoluteFile(filePath, fileName).getAbsolutePath();
// 上传文件
file.transferTo(Paths.get(absPath));
fileName = FileUploadUtils.getPathFileName(filePath, fileName);
// 返回url
String url = serverConfig.getUrl() + fileName;
AjaxResult ajax = AjaxResult.success();
ajax.put("url", url);
ajax.put("fileName", fileName);
ajax.put("newFileName", FileUtils.getName(fileName));
ajax.put("originalFilename", file.getOriginalFilename());
return ajax;
}
private void checkFile(MultipartFile file) {
if (StringUtils.isEmpty(file.getOriginalFilename()) ){
throw new RuntimeException("不是apk文件请重新上传");
}
if (!file.getOriginalFilename().endsWith(".apk")) {
throw new RuntimeException("不是apk文件请重新上传");
}
}
public void checkAppHeart(HeartPackageVo vo) {
Equipment equipment = new Equipment();
equipment.setOnlineClient(DEVICE_ONLINE);
equipment.setLastHeartRes(new Date());
equipment.setDeviceId(vo.getDeviceId());
equipment.setRemark("版本号：" + vo.getVersionNum());
equipmentMapper.updateEquipmentByDeviceId(equipment);
}
}