初始化代码迁移

cuikaidong

2025-06-12 44e283b774bb1168d0c17dfe5070a1ca8e2274cd

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
Êþº¾4
¿
LÅ    WÆÇÈÎÏР   WÑÒ
ÅÓ
ÔÕ
Å
Ö
×Ø
ÙÚÛ
ÜÝ
ÙÞ
ßàá
Lßâ
Kãä
åæç
åè
é
åê
åë
åì
Kí
îïðñ    Wòóôõö÷ø
ùúÏû
ÿ
 
.Å
    -

Ï
Ï

 
4

4
ÿ


K
à




=
ð


@
ÿ

K

K
     W
!
"
#

$
%

&

$
'
(
)
4
*
W
+
,
-
.
4
/
Ù
0
"
1
2Ï
3
4

5
6
7
log
Lorg/slf4j/Logger;
influxdbDeployService
6Lorg/jeecg/modules/iot/service/IInfluxdbDeployService;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;

dataSource
Ljavax/sql/DataSource;
equipmentService
1Lorg/jeecg/modules/iot/service/IEquipmentService;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
-Lorg/jeecg/modules/quartz/job/SampleParamJob;
execute
#(Lorg/quartz/JobExecutionContext;)V
jobExecutionContext
 Lorg/quartz/JobExecutionContext;
influxdbDeployList
Ljava/util/List;
LocalVariableTypeTable
?Ljava/util/List<Lorg/jeecg/modules/iot/entity/InfluxdbDeploy;>;

Exceptions
8
MethodParameters
allEmptyStrings
([Ljava/lang/Object;)Z
str
Ljava/lang/Object;
values
[Ljava/lang/Object;
 StackMapTable{
lambda$execute$3
0(Lorg/jeecg/modules/iot/entity/InfluxdbDeploy;)V

i

I
tables
    influxdbs
fieldistMap
Ljava/util/Map;
    valueList
 timeStampList
measurementListMap

e
Ljava/lang/Exception;
query
Ljava/lang/String;
mysqlConnection
Ljava/sql/Connection;
Ljava/sql/SQLException;
in
-Lorg/jeecg/modules/iot/entity/InfluxdbDeploy;
    influxUrl
influxToken
    influxOrg
influxBucket
influxDBClient
$Lcom/influxdb/client/InfluxDBClient;
queryApi
Lcom/influxdb/client/QueryApi;
0Ljava/util/List<Lcom/influxdb/query/FluxTable;>;
=Ljava/util/List<Lorg/jeecg/modules/iot/depository/Influxdb;>;
`Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lorg/jeecg/modules/iot/depository/Influxdb;>;>;
4
9
(
:
;
<

=



 lambda$null$2
%(Ljava/lang/String;Ljava/util/List;)V
table
timeList
timeListMap
 lambda$null$1
7(Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
    parameter
    formatter
$Ljava/time/format/DateTimeFormatter;
dateTime
Ljava/time/LocalDateTime;
measurement
influxdbList
    lastIndex
code
    equipment
(Lorg/jeecg/modules/iot/entity/Equipment;
    tableName
columns
[Ljava/lang/String;
>¼
 lambda$null$0
E(Ljava/util/List;Ljava/util/List;Ljava/lang/String;Ljava/util/List;)V
field
<clinit>

SourceFile
SampleParamJob.javade\]
?
@
A
BootstrapMethods
B
C
D
E
F
=
G
HZ[
java/lang/StringBuilder
*实时数据任务执行，当前时间：
I
J
java/util/Date
K
L
M
N
O
P
Q
R
yyyy-MM-dd HH:mm:ss.SSS
S
T
U
V
W
X
Y
Z
[
\

]
^
http://
9
_
Y

:
`
a
I
b
c
Y
d
Y
e
Y
f
g
h
i
j
:
k
l`a
m
n
o
from(bucket: "
~") |> range(start: -58s) |> fill(usePrevious: true) |> filter(fn: (r) => r["_field"] == "TimeStamp" or r["_field"] == "Value")
;‹
p
q
r
s
t
u
v
w
x
y
z
{
|
}
~

€
 java/util/Map
java/util/ArrayList

‚©
E
ƒ
G
„
…
†
‡
ˆ
)org/jeecg/modules/iot/depository/Influxdb
‰
Y
Š
\
‹
Œ
E

java/lang/Exception
Ž


\
<
‘e
java/lang/Throwable
’
“
java/sql/SQLException
”eR
•
E
–
—
˜
™
šbc
›
œ

>
ž
Y
I
Ÿ
 
Y
java/lang/String
java/lang/Object
¡
Yvw
CollectTime
EquipmentID
yyyy-MM-dd HH:mm:ss
¢
Y
£
¤
¥
¦
Value
§
¨
+org/jeecg/modules/quartz/job/SampleParamJob
©
ª
«
org/quartz/Job
 org/quartz/JobExecutionException
+org/jeecg/modules/iot/entity/InfluxdbDeploy
"com/influxdb/client/InfluxDBClient
com/influxdb/client/QueryApi
java/sql/Connection
java/util/List
&org/jeecg/modules/iot/entity/Equipment
4org/jeecg/modules/iot/service/IInfluxdbDeployService
list
()Ljava/util/List;

¬
­
(Ljava/lang/Object;)V
W
®
accept
L(Lorg/jeecg/modules/quartz/job/SampleParamJob;)Ljava/util/function/Consumer;
forEach
 (Ljava/util/function/Consumer;)V
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
    toInstant
()Ljava/time/Instant;
java/time/ZoneId
 systemDefault
()Ljava/time/ZoneId;
java/time/LocalDateTime
    ofInstant
@(Ljava/time/Instant;Ljava/time/ZoneId;)Ljava/time/LocalDateTime;
"java/time/format/DateTimeFormatter
    ofPattern
8(Ljava/lang/String;)Ljava/time/format/DateTimeFormatter;
format
8(Ljava/time/format/DateTimeFormatter;)Ljava/lang/String;
toString
()Ljava/lang/String;
org/slf4j/Logger
info
(Ljava/lang/String;)V
equals
(Ljava/lang/Object;)Z

getAddress
getPort
()Ljava/lang/Integer;
-(Ljava/lang/Object;)Ljava/lang/StringBuilder;
getAuthorizeCode
getOrganization
    getBucket
toCharArray
()[C
)com/influxdb/client/InfluxDBClientFactory
create
:(Ljava/lang/String;[C)Lcom/influxdb/client/InfluxDBClient;
getQueryApi
 ()Lcom/influxdb/client/QueryApi;
javax/sql/DataSource
 getConnection
()Ljava/sql/Connection;
6(Ljava/lang/String;Ljava/lang/String;)Ljava/util/List;
-org/jeecg/modules/iot/depository/InfluxdbTest
processAndInsert
7(Ljava/util/List;Ljava/sql/Connection;)Ljava/util/List;
stream
()Ljava/util/stream/Stream;
&(Ljava/lang/Object;)Ljava/lang/Object;
4
¯
?(Lorg/jeecg/modules/iot/depository/Influxdb;)Ljava/lang/String;
apply
()Ljava/util/function/Function;
java/util/stream/Collectors

groupingBy
;(Ljava/util/function/Function;)Ljava/util/stream/Collector;
java/util/stream/Stream
collect
0(Ljava/util/stream/Collector;)Ljava/lang/Object;
'(Ljava/lang/Object;Ljava/lang/Object;)V
W
°
A(Ljava/util/List;Ljava/util/List;)Ljava/util/function/BiConsumer;
"(Ljava/util/function/BiConsumer;)V
size
()I
get
(I)Ljava/lang/Object;
getValue
setAcquisitionTime
4
±
W
²
N(Lorg/jeecg/modules/quartz/job/SampleParamJob;)Ljava/util/function/BiConsumer;
valueOf
&(Ljava/lang/Object;)Ljava/lang/String;
error
close
 addSuppressed
(Ljava/lang/Throwable;)V
printStackTrace
W
³
`(Lorg/jeecg/modules/quartz/job/SampleParamJob;Ljava/lang/String;)Ljava/util/function/BiConsumer;
lastIndexOf
(I)I
    substring
(I)Ljava/lang/String;
/org/jeecg/modules/iot/service/IEquipmentService
findEquipmentByCode
<(Ljava/lang/String;)Lorg/jeecg/modules/iot/entity/Equipment;
getControlSystem
(C)Ljava/lang/StringBuilder;
getEqptCode
getParameter
getAcquisitionTime
parse
W(Ljava/lang/CharSequence;Ljava/time/format/DateTimeFormatter;)Ljava/time/LocalDateTime;
insertMysqlData
;(Ljava/lang/String;[Ljava/lang/String;[Ljava/lang/Object;)V
addAll
(Ljava/util/Collection;)Z
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
´
µ
¹~
º
Y¿À
»
Y¨©­®
"java/lang/invoke/LambdaMetafactory
metafactory
½
Lookup
InnerClasses
Ì(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
getField
getMeasurement
¾
%java/lang/invoke/MethodHandles$Lookup
java/lang/invoke/MethodHandles!WL
YZ[\]
^
_`a
^
_bc
^
_
de
f/

*·
±g
#h
ij
klf±I*´¹
M,*º¹²»Y·    ¶
»Y·¶ ¸¸¸¶¶
¶¹±g-
/‡,ˆ7‰C‡HŠh IijImn

?opq

?ors
tu
m    vwf”3*Ǭ*L+¾=>¢"+2:ƶ¶š¬„
§ÿ߬gŽ‘)’+1–hxy3z{|þ}

øu
z~f‹
³»Y·¶
+¶¶
¶
+¶¶¶M+¶N+¶:+¶:,-¶ ¸!:¹"
:*´#¹$
:
:    »Y·%¶
¶
&¶
¶:
 
¹':¸(:¹)
º*¸+¹,À-: ».Y·/:».Y·/: º0¹16¹2
¢'¹3À4¹3À4¶5¶6„
§ÿÓ¹)
º7¸+¹,À-:*º8¹1§:²¸:¹;Æ]    Æ¹<
§N:
    
¶>§B¹<
§8:
 
:    
¿:Æ%    Æ¹<
§:    ¶>§
¹<
¿¹?
§ :¶A¹?
§:¹?
¿±
p

9
6
=
@=U
,
V=U
,
_
k
r
u=
V
a
_G
‹
•@G
‹
¦
•
œ
¦
¦
¨
¦g’$1#2(3.446>7G9U=pC}E†G’HŸI¨J±KÁRÐSîRôV
W
 X

}
~
,€
V9
_€
‹ƒ
’„
•€
—
œƒ
£„
¦ƒ
¯„
²…hÀÄ0€}‚p†”ƒpŸ{„… ¨r†p±i‡p
  ˆ…
 ‰Šp¼‹Œ
R
9Ž
—‰
³ij
³‘
#
’Œ(
‹“Œ.
…”Œ4
•Œ>
u–—G
l˜™q>}‚š†”ƒ›Ÿ{„œ ¨r†›±i‡›
  ˆœ|ÔÿĝžŸŸŸŸ ¡¢£Ÿ¤¤¥¤¤
ú/ÿ(žŸŸŸŸ ¡¢£Ÿ
¦úS£I£H£ÿžŸŸŸŸ ¡¢££
£ÿžŸŸŸŸ ¡I§P£u
¨©f‹%,¹)
ºB¸+¹,À-N-*+ºC¹1±gZ[\$|h*%ij%ªŒ
%«p¬…q
¬œu    ª«­®f[
 +.¶D6+`¶E:*´F¹G:»Y·¶H¶
_¶I¶J¶
¶:-¹2
`½K:-¹2
`½L:    6
 
-¹2
¢X-
¹3À4¶M:
-¶D`¶ES    
-
¹3À4¶5S    
2Æ     
2¦
    
S„

§ÿ£    ¸Nš]-¹2
`OS-¹2
PSQ¸:
-¹3À4¶R
¸S:    -¹2
`S    -¹2
S*´F    ¹T±gZ]^_`@bMcZehfxg‹hži°j·e½nÅoÒpÝräuøv
w
y
{hŽx?¯Œ]`€
ä;°±
ø'²³
 ij
 ªŒ

 ´Œ
 µp
¶
·Œ

¸¹@ຌMÓ»¼ZÆz{    |5ÿ]ŸŸ¤
Ÿ½Ÿ¾}
üRŸúúûau ª´µ
¿Àf{,U¶™*-¹VW§+-¹VW±gL    MOQh*†p‡p
ÁŒ«p|u†‡Á«Âe
f!
    W¸X³±
g
"ÃÄ
¸


¶
¼
·ÉHÊËÌÍÊüýþÊ


Êü
þÊ


Êü
þÊ