Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
H
haikang-client
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
图表
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
杨立
haikang-client
Commits
18c06f4a
提交
18c06f4a
authored
10月 15, 2021
作者:
yangli
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
.
上级
b8363840
隐藏空白字符变更
内嵌
并排
正在显示
2 个修改的文件
包含
11 行增加
和
21 行删除
+11
-21
InstalledProgramCache.java
...rc/main/java/com/priusis/cache/InstalledProgramCache.java
+1
-13
ProgramController.java
...c/main/java/com/priusis/controller/ProgramController.java
+10
-8
没有找到文件。
apq-pc-client/src/main/java/com/priusis/cache/InstalledProgramCache.java
浏览文件 @
18c06f4a
...
@@ -4,7 +4,6 @@ import lombok.extern.slf4j.Slf4j;
...
@@ -4,7 +4,6 @@ import lombok.extern.slf4j.Slf4j;
import
org.springframework.scheduling.annotation.Scheduled
;
import
org.springframework.scheduling.annotation.Scheduled
;
import
org.springframework.stereotype.Component
;
import
org.springframework.stereotype.Component
;
import
javax.annotation.PostConstruct
;
import
java.io.BufferedReader
;
import
java.io.BufferedReader
;
import
java.io.IOException
;
import
java.io.IOException
;
import
java.io.InputStreamReader
;
import
java.io.InputStreamReader
;
...
@@ -24,20 +23,10 @@ public class InstalledProgramCache {
...
@@ -24,20 +23,10 @@ public class InstalledProgramCache {
private
static
List
<
Map
<
String
,
String
>>
programList
;
private
static
List
<
Map
<
String
,
String
>>
programList
;
public
List
<
Map
<
String
,
String
>>
getPrograms
()
throws
IOException
{
public
List
<
Map
<
String
,
String
>>
getPrograms
()
throws
IOException
{
if
(
programList
==
null
)
loadProgramListJob
();
//
if (programList == null) loadProgramListJob();
return
programList
;
return
programList
;
}
}
@PostConstruct
public
void
init
()
{
try
{
loadProgramListJob
();
log
.
info
(
"程序List-Lines:{}"
,
programList
);
}
catch
(
IOException
e
)
{
log
.
error
(
"初始化失败"
,
e
);
}
}
@Scheduled
(
fixedDelay
=
5000
)
@Scheduled
(
fixedDelay
=
5000
)
public
void
loadProgramListJob
()
throws
IOException
{
public
void
loadProgramListJob
()
throws
IOException
{
...
@@ -57,7 +46,6 @@ public class InstalledProgramCache {
...
@@ -57,7 +46,6 @@ public class InstalledProgramCache {
process
.
destroy
();
process
.
destroy
();
}
}
}
}
programList
=
programs
;
programList
=
programs
;
}
}
...
...
apq-pc-client/src/main/java/com/priusis/controller/ProgramController.java
浏览文件 @
18c06f4a
...
@@ -73,6 +73,8 @@ public class ProgramController {
...
@@ -73,6 +73,8 @@ public class ProgramController {
@RequestParam
(
required
=
false
,
defaultValue
=
"1"
)
Integer
current
,
@RequestParam
(
required
=
false
,
defaultValue
=
"1"
)
Integer
current
,
@RequestParam
(
required
=
false
,
defaultValue
=
"10"
)
Integer
size
)
@RequestParam
(
required
=
false
,
defaultValue
=
"10"
)
Integer
size
)
throws
IOException
{
throws
IOException
{
List
<
Map
<
String
,
String
>>
programs
=
installedProgramCache
.
getPrograms
();
if
(
programs
==
null
)
return
R
.
error
(
"软件扫描未完成,请稍后重试!"
);
String
mac
=
MacAddrUtil
.
get
();
String
mac
=
MacAddrUtil
.
get
();
if
(
StrUtil
.
isBlank
(
mac
))
return
R
.
error
(
"未获取到MAC地址"
);
if
(
StrUtil
.
isBlank
(
mac
))
return
R
.
error
(
"未获取到MAC地址"
);
String
url
=
gateway
+
StrUtil
.
format
(
type
.
equals
(
"install"
)
?
installUrl
:
upgradeUrl
,
mac
,
current
,
size
);
String
url
=
gateway
+
StrUtil
.
format
(
type
.
equals
(
"install"
)
?
installUrl
:
upgradeUrl
,
mac
,
current
,
size
);
...
@@ -82,7 +84,7 @@ public class ProgramController {
...
@@ -82,7 +84,7 @@ public class ProgramController {
page
.
setCurrent
(
current
).
setSize
(
size
).
setTotal
(
rsp
.
getLong
(
"total"
));
page
.
setCurrent
(
current
).
setSize
(
size
).
setTotal
(
rsp
.
getLong
(
"total"
));
JSONArray
rows
=
rsp
.
getJSONArray
(
"rows"
);
JSONArray
rows
=
rsp
.
getJSONArray
(
"rows"
);
if
(
CollUtil
.
isEmpty
(
rows
))
return
R
.
success
(
page
.
setRecords
(
Collections
.
emptyList
()));
if
(
CollUtil
.
isEmpty
(
rows
))
return
R
.
success
(
page
.
setRecords
(
Collections
.
emptyList
()));
List
<
Map
<
String
,
String
>>
programs
=
installedProgramCache
.
getPrograms
();
List
<
Map
<
String
,
String
>>
list
=
rows
.
stream
().
map
(
JSONObject
.
class
::
cast
)
List
<
Map
<
String
,
String
>>
list
=
rows
.
stream
().
map
(
JSONObject
.
class
::
cast
)
.
map
(
o
->
{
.
map
(
o
->
{
Map
<
String
,
String
>
map
=
new
HashMap
<>();
Map
<
String
,
String
>
map
=
new
HashMap
<>();
...
@@ -219,13 +221,13 @@ public class ProgramController {
...
@@ -219,13 +221,13 @@ public class ProgramController {
}
}
public
static
void
main
(
String
[]
args
)
{
public
static
void
main
(
String
[]
args
)
{
int
exitVal
=
-
1
;
int
exitVal
=
-
1
;
try
{
try
{
exitVal
=
Runtime
.
getRuntime
().
exec
(
"cmd /c \"D:\\work\\priusis\\priusis-iot\\apq-iot\\apq-client\\tools\\install-package\\dist\\apq-info-install.exe\""
).
waitFor
();
exitVal
=
Runtime
.
getRuntime
().
exec
(
"cmd /c \"D:\\work\\priusis\\priusis-iot\\apq-iot\\apq-client\\tools\\install-package\\dist\\apq-info-install.exe\""
).
waitFor
();
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
log
.
error
(
"执行安装文件失败"
,
e
);
log
.
error
(
"执行安装文件失败"
,
e
);
}
}
System
.
out
.
println
(
exitVal
);
System
.
out
.
println
(
exitVal
);
System
.
out
.
println
(
"========"
);
System
.
out
.
println
(
"========"
);
}
}
}
}
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论