File tree Expand file tree Collapse file tree 6 files changed +15
-12
lines changed
src/main/java/tech/wetech/flexmodel Expand file tree Collapse file tree 6 files changed +15
-12
lines changed Original file line number Diff line number Diff line change 16
16
import tech .wetech .flexmodel .codegen .entity .ApiDefinition ;
17
17
import tech .wetech .flexmodel .codegen .entity .ApiRequestLog ;
18
18
import tech .wetech .flexmodel .domain .model .api .ApiDefinitionService ;
19
- import tech .wetech .flexmodel .domain .model .api .ApiLogRequestService ;
20
19
import tech .wetech .flexmodel .domain .model .api .ApiRateLimiterHolder ;
20
+ import tech .wetech .flexmodel .domain .model .api .ApiRequestLogService ;
21
21
import tech .wetech .flexmodel .domain .model .api .LogStat ;
22
22
import tech .wetech .flexmodel .domain .model .data .DataService ;
23
23
import tech .wetech .flexmodel .domain .model .idp .IdentityProviderService ;
@@ -63,7 +63,7 @@ public class ApiRuntimeApplicationService {
63
63
IdentityProviderService identityProviderService ;
64
64
65
65
@ Inject
66
- ApiLogRequestService apiLogService ;
66
+ ApiRequestLogService apiLogService ;
67
67
68
68
@ Inject
69
69
ModelService modelService ;
Original file line number Diff line number Diff line change 6
6
import tech .wetech .flexmodel .codegen .entity .ApiDefinition ;
7
7
import tech .wetech .flexmodel .codegen .entity .ApiRequestLog ;
8
8
import tech .wetech .flexmodel .domain .model .api .ApiDefinitionService ;
9
- import tech .wetech .flexmodel .domain .model .api .ApiLogRequestService ;
9
+ import tech .wetech .flexmodel .domain .model .api .ApiRequestLogService ;
10
10
import tech .wetech .flexmodel .domain .model .api .LogStat ;
11
11
import tech .wetech .flexmodel .domain .model .connect .DatasourceService ;
12
12
import tech .wetech .flexmodel .query .Predicate ;
@@ -31,7 +31,7 @@ public class OverviewApplicationService {
31
31
ApiDefinitionService apiDefinitionService ;
32
32
33
33
@ Inject
34
- ApiLogRequestService apiLogService ;
34
+ ApiRequestLogService apiLogService ;
35
35
36
36
@ Inject
37
37
DatasourceService datasourceService ;
Original file line number Diff line number Diff line change 18
18
@ Slf4j
19
19
@ ApplicationScoped
20
20
@ ActivateRequestContext
21
- public class ApiLogRequestService {
21
+ public class ApiRequestLogService {
22
22
23
23
@ Inject
24
24
ApiRequestLogRepository apiLogRepository ;
Original file line number Diff line number Diff line change 2
2
3
3
import io .quarkus .scheduler .Scheduled ;
4
4
import jakarta .inject .Inject ;
5
- import tech .wetech .flexmodel .domain .model .api .ApiLogRequestService ;
5
+ import tech .wetech .flexmodel .domain .model .api .ApiRequestLogService ;
6
+ import tech .wetech .flexmodel .domain .model .schedule .JobExecutionLogService ;
6
7
import tech .wetech .flexmodel .domain .model .settings .Settings ;
7
8
import tech .wetech .flexmodel .domain .model .settings .SettingsService ;
8
9
@@ -13,14 +14,16 @@ public class Jobs {
13
14
14
15
@ Inject
15
16
SettingsService settingsService ;
16
-
17
17
@ Inject
18
- ApiLogRequestService apiLogService ;
18
+ ApiRequestLogService apiLogService ;
19
+ @ Inject
20
+ JobExecutionLogService jobExecutionLogService ;
19
21
20
22
@ Scheduled (cron = "0 0 1 * * ?" )
21
23
void purgeOldLogs () {
22
24
Settings settings = settingsService .getSettings ();
23
25
apiLogService .purgeOldLogs (settings .getLog ().getMaxDays ());
26
+ jobExecutionLogService .purgeOldLogs (settings .getLog ().getMaxDays ());
24
27
}
25
28
26
29
}
Original file line number Diff line number Diff line change 4
4
import jakarta .enterprise .context .ApplicationScoped ;
5
5
import jakarta .inject .Inject ;
6
6
import tech .wetech .flexmodel .codegen .entity .ApiRequestLog ;
7
- import tech .wetech .flexmodel .domain .model .api .ApiLogRequestService ;
7
+ import tech .wetech .flexmodel .domain .model .api .ApiRequestLogService ;
8
8
9
9
/**
10
10
* @author cjbi
13
13
public class LogEventConsumer {
14
14
15
15
@ Inject
16
- ApiLogRequestService apiLogService ;
16
+ ApiRequestLogService apiLogService ;
17
17
18
18
@ ConsumeEvent ("request.logging" ) // 监听特定地址的事件
19
19
public void consume (ApiRequestLog apiLog ) {
Original file line number Diff line number Diff line change 8
8
import jakarta .ws .rs .ext .Provider ;
9
9
import lombok .extern .slf4j .Slf4j ;
10
10
import tech .wetech .flexmodel .codegen .entity .ApiRequestLog ;
11
- import tech .wetech .flexmodel .domain .model .api .ApiLogRequestService ;
11
+ import tech .wetech .flexmodel .domain .model .api .ApiRequestLogService ;
12
12
import tech .wetech .flexmodel .domain .model .settings .Settings ;
13
13
import tech .wetech .flexmodel .domain .model .settings .SettingsService ;
14
14
import tech .wetech .flexmodel .shared .utils .JsonUtils ;
25
25
public class LogFilter implements ContainerRequestFilter , ContainerResponseFilter {
26
26
27
27
@ Inject
28
- ApiLogRequestService apiLogService ;
28
+ ApiRequestLogService apiLogService ;
29
29
30
30
@ Inject
31
31
SettingsService settingsService ;
You can’t perform that action at this time.
0 commit comments